feat: add backup notifications

app/Http/Livewire/Notifications/DiscordSettings.php

@@ -15,6 +15,7 @@ class DiscordSettings extends Component
         'model.discord_notifications_test' => 'nullable|boolean',
         'model.discord_notifications_deployments' => 'nullable|boolean',
         'model.discord_notifications_status_changes' => 'nullable|boolean',
+        'model.discord_notifications_database_backups' => 'nullable|boolean',
     ];
     protected $validationAttributes = [
         'model.discord_webhook_url' => 'Discord Webhook',

app/Http/Livewire/Notifications/EmailSettings.php

@@ -26,6 +26,7 @@ class EmailSettings extends Component
         'model.smtp_notifications_test' => 'nullable|boolean',
         'model.smtp_notifications_deployments' => 'nullable|boolean',
         'model.smtp_notifications_status_changes' => 'nullable|boolean',
+        'model.smtp_notifications_database_backups' => 'nullable|boolean',
     ];
     protected $validationAttributes = [
         'model.smtp_from_address' => 'From Address',

app/Jobs/DatabaseBackupJob.php

@@ -8,6 +8,8 @@ use App\Models\ScheduledDatabaseBackupExecution;
 use App\Models\Server;
 use App\Models\StandalonePostgresql;
 use App\Models\Team;
+use App\Notifications\Database\BackupFailed;
+use App\Notifications\Database\BackupSuccess;
 use Carbon\Carbon;
 use Illuminate\Bus\Queueable;
 use Illuminate\Contracts\Queue\ShouldQueue;
@@ -73,10 +75,10 @@ class DatabaseBackupJob implements ShouldQueue
         }
         $this->calculate_size();
         $this->remove_old_backups();
-        $this->save_backup_logs();
         if ($this->backup->save_s3) {
-            $this->upload_to_s3();
+//            $this->upload_to_s3();
         }
+        $this->save_backup_logs();
         // TODO: Notify user
     }
 
@@ -98,10 +100,13 @@ class DatabaseBackupJob implements ShouldQueue
             ray('Backup done for ' . $this->database->uuid . ' at ' . $this->server->name . ':' . $this->backup_filename);
 
             $this->backup_status = 'success';
+            throw new \Error('test');
+            $this->team->notify(new BackupSuccess($this->backup, $this->database));
         } catch (Throwable $th) {
             $this->backup_status = 'failed';
             $this->add_to_backup_output($th->getMessage());
             ray('Backup failed for ' . $this->database->uuid . ' at ' . $this->server->name . ':' . $this->backup_filename . '\n\nError:' . $th->getMessage());
+            $this->team->notify(new BackupFailed($this->backup, $this->database));
         } finally {
             $this->backup_log->update([
                 'status' => $this->backup_status,
@@ -130,7 +135,6 @@ class DatabaseBackupJob implements ShouldQueue
         } else {
             $deletable = $this->backup->executions()->where('status', 'success')->orderByDesc('created_at')->skip($this->backup->number_of_backups_locally);
         }
-        ray($deletable->get());
         foreach ($deletable->get() as $execution) {
             delete_backup_locally($execution->filename, $this->server);
             $execution->delete();
@@ -159,13 +163,15 @@ class DatabaseBackupJob implements ShouldQueue
             $bucket = $this->s3->bucket;
             $endpoint = $this->s3->endpoint;
             $backup_dir = backup_dir() . "/{$this->database->uuid}";
+
             $base_command = "docker run -t --network {$this->database->destination->network} -v {$this->backup_filename}:{$this->backup_filename}:ro --rm --entrypoint=/bin/sh minio/mc -c \"mc config host add temporary {$endpoint} $key $secret && mc cp $this->backup_filename temporary/$bucket/$backup_dir/ \"";
+
             instant_remote_process([$base_command], $this->server);
+
             $this->add_to_backup_output('Uploaded to S3.');
         } catch (\Throwable $th) {
             $this->add_to_backup_output($th->getMessage());
             ray($th->getMessage());
-            //throw $th;
         }
     }
 }

app/Notifications/Database/BackupFailed.php

@@ -0,0 +1,55 @@
+<?php
+
+namespace App\Notifications\Database;
+
+use App\Models\ScheduledDatabaseBackup;
+use App\Notifications\Channels\DiscordChannel;
+use App\Notifications\Channels\EmailChannel;
+use Illuminate\Bus\Queueable;
+use Illuminate\Contracts\Queue\ShouldQueue;
+use Illuminate\Notifications\Messages\MailMessage;
+use Illuminate\Notifications\Notification;
+
+class BackupFailed extends Notification implements ShouldQueue
+{
+    use Queueable;
+
+    public string $message = 'Backup FAILED';
+
+
+    public function __construct(ScheduledDatabaseBackup $backup, public $database)
+    {
+        $this->message = "❌ Database backup for {$database->name} with frequency of $backup->frequency was FAILED.";
+    }
+
+    public function via(object $notifiable): array
+    {
+        $channels = [];
+        $isEmailEnabled = data_get($notifiable, 'smtp_enabled');
+        $isDiscordEnabled = data_get($notifiable, 'discord_enabled');
+        $isSubscribedToEmailEvent = data_get($notifiable, 'smtp_notifications_database_backups');
+        $isSubscribedToDiscordEvent = data_get($notifiable, 'discord_notifications_database_backups');
+
+        if ($isEmailEnabled && $isSubscribedToEmailEvent) {
+            $channels[] = EmailChannel::class;
+        }
+        if ($isDiscordEnabled && $isSubscribedToDiscordEvent) {
+            $channels[] = DiscordChannel::class;
+        }
+        ray($channels);
+        return $channels;
+    }
+
+    public function toMail(): MailMessage
+    {
+        $mail = new MailMessage();
+        $mail->subject("❌ Backup FAILED for {$this->database->name}");
+        $mail->line($this->message);
+        return $mail;
+    }
+
+    public function toDiscord(): string
+    {
+        return $this->message;
+    }
+}

app/Notifications/Database/BackupSuccess.php

@@ -0,0 +1,55 @@
+<?php
+
+namespace App\Notifications\Database;
+
+use App\Models\ScheduledDatabaseBackup;
+use App\Notifications\Channels\DiscordChannel;
+use App\Notifications\Channels\EmailChannel;
+use Illuminate\Bus\Queueable;
+use Illuminate\Contracts\Queue\ShouldQueue;
+use Illuminate\Notifications\Messages\MailMessage;
+use Illuminate\Notifications\Notification;
+
+class BackupSuccess extends Notification implements ShouldQueue
+{
+    use Queueable;
+
+    public string $message = 'Backup Success';
+
+
+    public function __construct(ScheduledDatabaseBackup $backup, public $database)
+    {
+        $this->message = "✅ Database backup for {$database->name} with frequency of $backup->frequency was successful.";
+    }
+
+    public function via(object $notifiable): array
+    {
+        $channels = [];
+        $isEmailEnabled = data_get($notifiable, 'smtp_enabled');
+        $isDiscordEnabled = data_get($notifiable, 'discord_enabled');
+        $isSubscribedToEmailEvent = data_get($notifiable, 'smtp_notifications_database_backups');
+        $isSubscribedToDiscordEvent = data_get($notifiable, 'discord_notifications_database_backups');
+
+        if ($isEmailEnabled && $isSubscribedToEmailEvent) {
+            $channels[] = EmailChannel::class;
+        }
+        if ($isDiscordEnabled && $isSubscribedToDiscordEvent) {
+            $channels[] = DiscordChannel::class;
+        }
+        ray($channels);
+        return $channels;
+    }
+
+    public function toMail(): MailMessage
+    {
+        $mail = new MailMessage();
+        $mail->subject("✅ Backup success for {$this->database->name}");
+        $mail->line($this->message);
+        return $mail;
+    }
+
+    public function toDiscord(): string
+    {
+        return $this->message;
+    }
+}

app/Notifications/TransactionalEmails/InvitationLink.php

@@ -15,7 +15,7 @@ class InvitationLink extends Notification implements ShouldQueue
 {
     use Queueable;
 
-    public function via()
+    public function via(): array
     {
         return [TransactionalEmailChannel::class];
     }