feat(server): implement server patch check notifications
- Added a new job, ServerPatchCheckJob, to handle server patch checks and notifications. - Introduced a new notification class, ServerPatchCheck, for sending updates via email, Discord, Slack, Pushover, and Telegram. - Updated notification settings models to include server patch notification options for email, Discord, Slack, Pushover, and Telegram. - Created a migration to add server patch notification fields to the respective settings tables. - Enhanced the UI to allow users to enable/disable server patch notifications across different channels.
This commit is contained in:
Andras Bacsai
@@ -34,6 +34,7 @@ class TelegramChannel
|
||||
\App\Notifications\Server\HighDiskUsage::class => $settings->telegram_notifications_server_disk_usage_thread_id,
|
||||
\App\Notifications\Server\Unreachable::class => $settings->telegram_notifications_server_unreachable_thread_id,
|
||||
\App\Notifications\Server\Reachable::class => $settings->telegram_notifications_server_reachable_thread_id,
|
||||
\App\Notifications\Server\ServerPatchCheck::class => $settings->telegram_notifications_server_patch_thread_id,
|
||||
|
||||
default => null,
|
||||
};
|
||||
|
||||
245
app/Notifications/Server/ServerPatchCheck.php
Normal file
245
app/Notifications/Server/ServerPatchCheck.php
Normal file
@@ -0,0 +1,245 @@
|
||||
<?php
|
||||
|
||||
namespace App\Notifications\Server;
|
||||
|
||||
use App\Models\Server;
|
||||
use App\Notifications\CustomEmailNotification;
|
||||
use App\Notifications\Dto\DiscordMessage;
|
||||
use App\Notifications\Dto\PushoverMessage;
|
||||
use App\Notifications\Dto\SlackMessage;
|
||||
use Illuminate\Notifications\Messages\MailMessage;
|
||||
|
||||
class ServerPatchCheck extends CustomEmailNotification
|
||||
{
|
||||
public string $serverUrl;
|
||||
|
||||
public function __construct(public Server $server, public array $patchData)
|
||||
{
|
||||
$this->onQueue('high');
|
||||
$this->serverUrl = route('server.security.patches', ['server_uuid' => $this->server->uuid]);
|
||||
if (isDev()) {
|
||||
$this->serverUrl = 'https://staging-but-dev.coolify.io/server/'.$this->server->uuid.'/security/patches';
|
||||
}
|
||||
}
|
||||
|
||||
public function via(object $notifiable): array
|
||||
{
|
||||
return $notifiable->getEnabledChannels('server_patch');
|
||||
}
|
||||
|
||||
public function toMail($notifiable = null): MailMessage
|
||||
{
|
||||
$mail = new MailMessage;
|
||||
$totalUpdates = $this->patchData['total_updates'] ?? 0;
|
||||
$mail->subject("Coolify: [ACTION REQUIRED] {$totalUpdates} server patches available on {$this->server->name}");
|
||||
$mail->view('emails.server-patches', [
|
||||
'name' => $this->server->name,
|
||||
'total_updates' => $totalUpdates,
|
||||
'updates' => $this->patchData['updates'] ?? [],
|
||||
'osId' => $this->patchData['osId'] ?? 'unknown',
|
||||
'package_manager' => $this->patchData['package_manager'] ?? 'unknown',
|
||||
'server_url' => $this->serverUrl,
|
||||
]);
|
||||
|
||||
return $mail;
|
||||
}
|
||||
|
||||
public function toDiscord(): DiscordMessage
|
||||
{
|
||||
$totalUpdates = $this->patchData['total_updates'] ?? 0;
|
||||
$updates = $this->patchData['updates'] ?? [];
|
||||
$osId = $this->patchData['osId'] ?? 'unknown';
|
||||
$packageManager = $this->patchData['package_manager'] ?? 'unknown';
|
||||
|
||||
$description = "**{$totalUpdates} package updates** available for server {$this->server->name}\n\n";
|
||||
$description .= "**Summary:**\n";
|
||||
$description .= '• OS: '.ucfirst($osId)."\n";
|
||||
$description .= "• Package Manager: {$packageManager}\n";
|
||||
$description .= "• Total Updates: {$totalUpdates}\n\n";
|
||||
|
||||
// Show first few packages
|
||||
if (count($updates) > 0) {
|
||||
$description .= "**Sample Updates:**\n";
|
||||
$sampleUpdates = array_slice($updates, 0, 5);
|
||||
foreach ($sampleUpdates as $update) {
|
||||
$description .= "• {$update['package']}: {$update['current_version']} → {$update['new_version']}\n";
|
||||
}
|
||||
if (count($updates) > 5) {
|
||||
$description .= '• ... and '.(count($updates) - 5)." more packages\n";
|
||||
}
|
||||
|
||||
// Check for critical packages
|
||||
$criticalPackages = collect($updates)->filter(function ($update) {
|
||||
return str_contains(strtolower($update['package']), 'docker') ||
|
||||
str_contains(strtolower($update['package']), 'kernel') ||
|
||||
str_contains(strtolower($update['package']), 'openssh') ||
|
||||
str_contains(strtolower($update['package']), 'ssl');
|
||||
});
|
||||
|
||||
if ($criticalPackages->count() > 0) {
|
||||
$description .= "\n **Critical packages detected** ({$criticalPackages->count()} packages may require restarts)";
|
||||
}
|
||||
$description .= "\n [Manage Server Patches]($this->serverUrl)";
|
||||
}
|
||||
|
||||
return new DiscordMessage(
|
||||
title: ':warning: Coolify: [ACTION REQUIRED] Server patches available on '.$this->server->name,
|
||||
description: $description,
|
||||
color: DiscordMessage::errorColor(),
|
||||
);
|
||||
|
||||
}
|
||||
|
||||
public function toTelegram(): array
|
||||
{
|
||||
$totalUpdates = $this->patchData['total_updates'] ?? 0;
|
||||
$updates = $this->patchData['updates'] ?? [];
|
||||
$osId = $this->patchData['osId'] ?? 'unknown';
|
||||
$packageManager = $this->patchData['package_manager'] ?? 'unknown';
|
||||
|
||||
$message = "🔧 Coolify: [ACTION REQUIRED] {$totalUpdates} server patches available on {$this->server->name}!\n\n";
|
||||
$message .= "📊 Summary:\n";
|
||||
$message .= '• OS: '.ucfirst($osId)."\n";
|
||||
$message .= "• Package Manager: {$packageManager}\n";
|
||||
$message .= "• Total Updates: {$totalUpdates}\n\n";
|
||||
|
||||
if (count($updates) > 0) {
|
||||
$message .= "📦 Sample Updates:\n";
|
||||
$sampleUpdates = array_slice($updates, 0, 5);
|
||||
foreach ($sampleUpdates as $update) {
|
||||
$message .= "• {$update['package']}: {$update['current_version']} → {$update['new_version']}\n";
|
||||
}
|
||||
if (count($updates) > 5) {
|
||||
$message .= '• ... and '.(count($updates) - 5)." more packages\n";
|
||||
}
|
||||
|
||||
// Check for critical packages
|
||||
$criticalPackages = collect($updates)->filter(function ($update) {
|
||||
return str_contains(strtolower($update['package']), 'docker') ||
|
||||
str_contains(strtolower($update['package']), 'kernel') ||
|
||||
str_contains(strtolower($update['package']), 'openssh') ||
|
||||
str_contains(strtolower($update['package']), 'ssl');
|
||||
});
|
||||
|
||||
if ($criticalPackages->count() > 0) {
|
||||
$message .= "\n⚠️ Critical packages detected: {$criticalPackages->count()} packages may require restarts\n";
|
||||
foreach ($criticalPackages->take(3) as $package) {
|
||||
$message .= "• {$package['package']}: {$package['current_version']} → {$package['new_version']}\n";
|
||||
}
|
||||
if ($criticalPackages->count() > 3) {
|
||||
$message .= '• ... and '.($criticalPackages->count() - 3)." more critical packages\n";
|
||||
}
|
||||
}
|
||||
}
|
||||
|
||||
return [
|
||||
'message' => $message,
|
||||
'buttons' => [
|
||||
[
|
||||
'text' => 'Manage Server Patches',
|
||||
'url' => $this->serverUrl,
|
||||
],
|
||||
],
|
||||
];
|
||||
}
|
||||
|
||||
public function toPushover(): PushoverMessage
|
||||
{
|
||||
$totalUpdates = $this->patchData['total_updates'] ?? 0;
|
||||
$updates = $this->patchData['updates'] ?? [];
|
||||
$osId = $this->patchData['osId'] ?? 'unknown';
|
||||
$packageManager = $this->patchData['package_manager'] ?? 'unknown';
|
||||
|
||||
$message = "[ACTION REQUIRED] {$totalUpdates} server patches available on {$this->server->name}!\n\n";
|
||||
$message .= "Summary:\n";
|
||||
$message .= '• OS: '.ucfirst($osId)."\n";
|
||||
$message .= "• Package Manager: {$packageManager}\n";
|
||||
$message .= "• Total Updates: {$totalUpdates}\n\n";
|
||||
|
||||
if (count($updates) > 0) {
|
||||
$message .= "Sample Updates:\n";
|
||||
$sampleUpdates = array_slice($updates, 0, 3);
|
||||
foreach ($sampleUpdates as $update) {
|
||||
$message .= "• {$update['package']}: {$update['current_version']} → {$update['new_version']}\n";
|
||||
}
|
||||
if (count($updates) > 3) {
|
||||
$message .= '• ... and '.(count($updates) - 3)." more packages\n";
|
||||
}
|
||||
|
||||
// Check for critical packages
|
||||
$criticalPackages = collect($updates)->filter(function ($update) {
|
||||
return str_contains(strtolower($update['package']), 'docker') ||
|
||||
str_contains(strtolower($update['package']), 'kernel') ||
|
||||
str_contains(strtolower($update['package']), 'openssh') ||
|
||||
str_contains(strtolower($update['package']), 'ssl');
|
||||
});
|
||||
|
||||
if ($criticalPackages->count() > 0) {
|
||||
$message .= "\nCritical packages detected: {$criticalPackages->count()} may require restarts";
|
||||
}
|
||||
}
|
||||
|
||||
return new PushoverMessage(
|
||||
title: 'Server patches available',
|
||||
level: 'error',
|
||||
message: $message,
|
||||
buttons: [
|
||||
[
|
||||
'text' => 'Manage Server Patches',
|
||||
'url' => $this->serverUrl,
|
||||
],
|
||||
],
|
||||
);
|
||||
}
|
||||
|
||||
public function toSlack(): SlackMessage
|
||||
{
|
||||
$totalUpdates = $this->patchData['total_updates'] ?? 0;
|
||||
$updates = $this->patchData['updates'] ?? [];
|
||||
$osId = $this->patchData['osId'] ?? 'unknown';
|
||||
$packageManager = $this->patchData['package_manager'] ?? 'unknown';
|
||||
|
||||
$description = "{$totalUpdates} server patches available on '{$this->server->name}'!\n\n";
|
||||
$description .= "*Summary:*\n";
|
||||
$description .= '• OS: '.ucfirst($osId)."\n";
|
||||
$description .= "• Package Manager: {$packageManager}\n";
|
||||
$description .= "• Total Updates: {$totalUpdates}\n\n";
|
||||
|
||||
if (count($updates) > 0) {
|
||||
$description .= "*Sample Updates:*\n";
|
||||
$sampleUpdates = array_slice($updates, 0, 5);
|
||||
foreach ($sampleUpdates as $update) {
|
||||
$description .= "• `{$update['package']}`: {$update['current_version']} → {$update['new_version']}\n";
|
||||
}
|
||||
if (count($updates) > 5) {
|
||||
$description .= '• ... and '.(count($updates) - 5)." more packages\n";
|
||||
}
|
||||
|
||||
// Check for critical packages
|
||||
$criticalPackages = collect($updates)->filter(function ($update) {
|
||||
return str_contains(strtolower($update['package']), 'docker') ||
|
||||
str_contains(strtolower($update['package']), 'kernel') ||
|
||||
str_contains(strtolower($update['package']), 'openssh') ||
|
||||
str_contains(strtolower($update['package']), 'ssl');
|
||||
});
|
||||
|
||||
if ($criticalPackages->count() > 0) {
|
||||
$description .= "\n:warning: *Critical packages detected:* {$criticalPackages->count()} packages may require restarts\n";
|
||||
foreach ($criticalPackages->take(3) as $package) {
|
||||
$description .= "• `{$package['package']}`: {$package['current_version']} → {$package['new_version']}\n";
|
||||
}
|
||||
if ($criticalPackages->count() > 3) {
|
||||
$description .= '• ... and '.($criticalPackages->count() - 3)." more critical packages\n";
|
||||
}
|
||||
}
|
||||
}
|
||||
|
||||
$description .= "\n:link: <{$this->serverUrl}|Manage Server Patches>";
|
||||
|
||||
return new SlackMessage(
|
||||
title: 'Coolify: [ACTION REQUIRED] Server patches available',
|
||||
description: $description,
|
||||
color: SlackMessage::errorColor()
|
||||
);
|
||||
}
|
||||
}
|
||||
Reference in New Issue
Block a user