Send a notification on slow query (#918)

* Send a notification on slow query

* Apply fixes from StyleCI

* Refactor to method

* Apply fixes from StyleCI

Co-authored-by: StyleCI Bot <[email protected]>

Author: joedixon

app/Notifications/SlowQueryLogged.php

@@ -0,0 +1,46 @@
+<?php
+
+namespace App\Notifications;
+
+use Illuminate\Bus\Queueable;
+use Illuminate\Contracts\Queue\ShouldQueue;
+use Illuminate\Notifications\Notification;
+use NotificationChannels\Telegram\TelegramMessage;
+
+class SlowQueryLogged extends Notification implements ShouldQueue
+{
+    use Queueable;
+
+    public function __construct(private string $query, private float|null $duration, private string $url)
+    {
+    }
+
+    public function via($notifiable)
+    {
+        if (
+            ! empty(config('services.telegram-bot-api.token')) &&
+            ! empty(config('services.telegram-bot-api.channel'))
+        ) {
+            return ['telegram'];
+        }
+
+        return [];
+    }
+
+    public function toTelegram($notifiable)
+    {
+        return TelegramMessage::create()
+            ->to(config('services.telegram-bot-api.channel'))
+            ->content($this->content());
+    }
+
+    private function content(): string
+    {
+        $content = "*Slow query logged!*\n\n";
+        $content .= "```{$this->query}```\n\n";
+        $content .= "Duration: {$this->duration}ms\n";
+        $content .= "URL: {$this->url}";
+
+        return $content;
+    }
+}

app/Providers/AppServiceProvider.php

@@ -6,7 +6,14 @@
 use App\Models\Reply;
 use App\Models\Thread;
 use App\Models\User;
+use App\Notifications\SlowQueryLogged;
+use Illuminate\Database\Connection;
 use Illuminate\Database\Eloquent\Relations\Relation;
+use Illuminate\Database\Events\QueryExecuted;
+use Illuminate\Notifications\AnonymousNotifiable;
+use Illuminate\Support\Facades\DB;
+use Illuminate\Support\Facades\Notification;
+use Illuminate\Support\Facades\Request;
 use Illuminate\Support\ServiceProvider;
 use Laravel\Horizon\Horizon;
 
@@ -17,6 +24,7 @@ public function boot()
         $this->bootEloquentMorphs();
         $this->bootMacros();
         $this->bootHorizon();
+        $this->bootSlowQueryLogging();
     }
 
     private function bootEloquentMorphs()
@@ -43,4 +51,18 @@ public function bootHorizon()
             return auth()->check() && auth()->user()->isAdmin();
         });
     }
+
+    private function bootSlowQueryLogging()
+    {
+        DB::whenQueryingForLongerThan(500, function (Connection $connection, QueryExecuted $event) {
+            Notification::send(
+                new AnonymousNotifiable,
+                new SlowQueryLogged(
+                    $event->sql,
+                    $event->time,
+                    Request::url(),
+                ),
+            );
+        });
+    }
 }