Added jobs to queeue pending health checks

Author: SniperSister

.env.example

@@ -63,3 +63,5 @@ AWS_BUCKET=
 AWS_USE_PATH_STYLE_ENDPOINT=false
 
 VITE_APP_NAME="${APP_NAME}"
+
+HEALTH_CHECK_INTERVAL=24

app/Console/Commands/PerformSiteHealthCheck.php

@@ -25,10 +25,12 @@ class PerformSiteHealthCheck extends Command
     /**
      * Execute the console command.
      */
-    public function handle()
+    public function handle(): int
     {
         CheckSiteHealth::dispatchSync(
             Site::findOrFail($this->input->getArgument('siteId'))
         );
+
+        return Command::SUCCESS;
     }
 }

app/Console/Commands/QueueHealthChecks.php

@@ -0,0 +1,57 @@
+<?php
+
+namespace App\Console\Commands;
+
+use App\Jobs\CheckSiteHealth;
+use App\Models\Site;
+use Carbon\Carbon;
+use Illuminate\Console\Command;
+use Illuminate\Database\Eloquent\Collection;
+
+class QueueHealthChecks extends Command
+{
+    protected int $totalPushed = 0;
+
+    /**
+     * The name and signature of the console command.
+     *
+     * @var string
+     */
+    protected $signature = 'app:queue-health-checks';
+
+    /**
+     * The console command description.
+     *
+     * @var string
+     */
+    protected $description = 'Pushes pending health checks to queue';
+
+    /**
+     * Execute the console command.
+     */
+    public function handle(): int
+    {
+        $this->output->writeln('Pushing pending health checks');
+
+        Site::query()
+            ->whereDate('last_seen', '<', Carbon::now()->subHours(env('HEALTH_CHECK_INTERVAL', 24)))
+            ->chunkById(
+                100,
+                function (Collection $chunk) {
+                    // Show progress
+                    $this->output->write('.');
+
+                    $this->totalPushed += $chunk->count();
+
+                    // Push each site check to queue
+                    $chunk->each(fn($site) => CheckSiteHealth::dispatch($site));
+                }
+            );
+
+        // Result
+        $this->output->writeln("");
+        $this->output->writeln('Pushed ' . $this->totalPushed . ' pending jobs to queue');
+
+        return Command::SUCCESS;
+    }
+}

app/Jobs/CheckSiteHealth.php

@@ -6,6 +6,7 @@
 
 use App\Models\Site;
 use App\Services\SiteConnectionService;
+use Carbon\Carbon;
 use Illuminate\Contracts\Queue\ShouldQueue;
 use Illuminate\Foundation\Queue\Queueable;
 
@@ -33,7 +34,7 @@ public function handle(): void
         $healthData = collect($response);
 
         // Write updated data to DB
-        $this->site->update(
+        $this->site->fill(
             $healthData->only([
                 'php_version',
                 'db_type',
@@ -42,5 +43,8 @@ public function handle(): void
                 'server_os'
             ])->toArray()
         );
+
+        $this->site->last_seen = Carbon::now();
+        $this->site->save();
     }
 }

routes/console.php

@@ -2,5 +2,7 @@
 
 use Illuminate\Support\Facades\Schedule;
 use Illuminate\Queue\Console\PruneFailedJobsCommand;
+use App\Console\Commands\QueueHealthChecks;
 
 Schedule::command(PruneFailedJobsCommand::class)->daily();
+Schedule::command(QueueHealthChecks::class)->everyFifteenMinutes();