Add user database notifications for completed and failed speedtests (alexjustesen#2432)

Co-authored-by: Alex Justesen <[email protected]>

Author: alexjustesen

app/Listeners/ProcessCompletedSpeedtest.php

@@ -0,0 +1,44 @@
+<?php
+
+namespace App\Listeners;
+
+use App\Events\SpeedtestCompleted;
+use App\Models\Result;
+use App\Models\User;
+use Filament\Actions\Action;
+use Filament\Notifications\Notification;
+
+class ProcessCompletedSpeedtest
+{
+    /**
+     * Handle the event.
+     */
+    public function handle(SpeedtestCompleted $event): void
+    {
+        $result = $event->result;
+
+        if ($result->dispatched_by && ! $result->scheduled) {
+            $this->notifyDispatchingUser($result);
+        }
+    }
+
+    /**
+     * Notify the user who dispatched the speedtest.
+     */
+    private function notifyDispatchingUser(Result $result): void
+    {
+        $user = User::find($result->dispatched_by);
+
+        $user->notify(
+            Notification::make()
+                ->title(__('results.speedtest_completed'))
+                ->actions([
+                    Action::make('view')
+                        ->label(__('general.view'))
+                        ->url(route('filament.admin.resources.results.index')),
+                ])
+                ->success()
+                ->toDatabase(),
+        );
+    }
+}

app/Listeners/ProcessFailedSpeedtest.php

@@ -0,0 +1,44 @@
+<?php
+
+namespace App\Listeners;
+
+use App\Events\SpeedtestFailed;
+use App\Models\Result;
+use App\Models\User;
+use Filament\Actions\Action;
+use Filament\Notifications\Notification;
+
+class ProcessFailedSpeedtest
+{
+    /**
+     * Handle the event.
+     */
+    public function handle(SpeedtestFailed $event): void
+    {
+        $result = $event->result;
+
+        if ($result->dispatched_by && ! $result->scheduled) {
+            $this->notifyDispatchingUser($result);
+        }
+    }
+
+    /**
+     * Notify the user who dispatched the speedtest.
+     */
+    private function notifyDispatchingUser(Result $result): void
+    {
+        $user = User::find($result->dispatched_by);
+
+        $user->notify(
+            Notification::make()
+                ->title(__('results.speedtest_failed'))
+                ->actions([
+                    Action::make('view')
+                        ->label(__('general.view'))
+                        ->url(route('filament.admin.resources.results.index')),
+                ])
+                ->warning()
+                ->toDatabase(),
+        );
+    }
+}

lang/en/general.php

@@ -16,6 +16,7 @@
     'no' => 'No',
     'options' => 'Options',
     'details' => 'Details',
+    'view' => 'View',
 
     // Common labels
     'name' => 'Name',

lang/en/results.php

@@ -63,6 +63,7 @@
     // Notifications
     'speedtest_started' => 'Speedtest started',
     'speedtest_completed' => 'Speedtest completed',
+    'speedtest_failed' => 'Speedtest failed',
     'download_threshold_breached' => 'Download threshold breached!',
     'upload_threshold_breached' => 'Upload threshold breached!',
     'ping_threshold_breached' => 'Ping threshold breached!',