feat: scheduled task success notification

2024-12-09 17:00:33 +01:00
parent a849bfdc3e
commit bf58547082
1 changed files with 88 additions and 0 deletions
--- a/app/Notifications/ScheduledTask/TaskSuccess.php
+++ b/app/Notifications/ScheduledTask/TaskSuccess.php
@@ -0,0 +1,88 @@
+<?php
+
+namespace App\Notifications\ScheduledTask;
+
+use App\Models\ScheduledTask;
+use App\Notifications\CustomEmailNotification;
+use App\Notifications\Dto\DiscordMessage;
+use App\Notifications\Dto\SlackMessage;
+use Illuminate\Notifications\Messages\MailMessage;
+
+class TaskFailed extends CustomEmailNotification
+{
+    public ?string $url = null;
+
+    public function __construct(public ScheduledTask $task, public string $output)
+    {
+        $this->onQueue('high');
+        if ($task->application) {
+            $this->url = $task->application->failedTaskLink($task->uuid);
+        } elseif ($task->service) {
+            $this->url = $task->service->failedTaskLink($task->uuid);
+        }
+    }
+
+    public function via(object $notifiable): array
+    {
+        return $notifiable->getEnabledChannels('scheduled_task_success');
+    }
+
+    public function toMail(): MailMessage
+    {
+        $mail = new MailMessage;
+        $mail->subject("Coolify: Scheduled task ({$this->task->name}) succeeded.");
+        $mail->view('emails.scheduled-task-failed', [
+            'task' => $this->task,
+            'url' => $this->url,
+            'output' => $this->output,
+        ]);
+
+        return $mail;
+    }
+
+    public function toDiscord(): DiscordMessage
+    {
+        $message = new DiscordMessage(
+            title: ':check_mark: Scheduled task succeeded',
+            description: "Scheduled task ({$this->task->name}) succeeded.",
+            color: DiscordMessage::successColor(),
+        );
+
+        if ($this->url) {
+            $message->addField('Scheduled task', '[Link]('.$this->url.')');
+        }
+
+        return $message;
+    }
+
+    public function toTelegram(): array
+    {
+        $message = "Coolify: Scheduled task ({$this->task->name}) succeeded.";
+        if ($this->url) {
+            $buttons[] = [
+                'text' => 'Open task in Coolify',
+                'url' => (string) $this->url,
+            ];
+        }
+
+        return [
+            'message' => $message,
+        ];
+    }
+
+    public function toSlack(): SlackMessage
+    {
+        $title = 'Scheduled task succeeded';
+        $description = "Scheduled task ({$this->task->name}) succeeded.";
+
+        if ($this->url) {
+            $description .= "\n\n**Task URL:** {$this->url}";
+        }
+
+        return new SlackMessage(
+            title: $title,
+            description: $description,
+            color: SlackMessage::successColor()
+        );
+    }
+}