Added start commands

Author: SniperSister

app/Console/Commands/PerformUpdate.php

@@ -0,0 +1,45 @@
+<?php
+
+namespace App\Console\Commands;
+
+use App\Jobs\UpdateSite;
+use App\Models\Site;
+use Illuminate\Console\Command;
+use App\Console\Traits\RequestTargetVersion;
+
+class PerformUpdate extends Command
+{
+    use RequestTargetVersion;
+
+    /**
+     * The name and signature of the console command.
+     *
+     * @var string
+     */
+    protected $signature = 'app:perform-update {siteId}';
+
+    /**
+     * The console command description.
+     *
+     * @var string
+     */
+    protected $description = 'Executes an update job for given site id';
+
+    /**
+     * Execute the console command.
+     */
+    public function handle()
+    {
+        $targetVersion = $this->getVersionChoices();
+
+        /** @var Site $site */
+        $site = Site::findOrFail($this->input->getArgument('siteId'));
+
+        UpdateSite::dispatchSync(
+            $site,
+            $targetVersion
+        );
+
+        return Command::SUCCESS;
+    }
+}

app/Console/Commands/QueueUpdates.php

@@ -0,0 +1,67 @@
+<?php
+
+namespace App\Console\Commands;
+
+use App\Console\Traits\RequestTargetVersion;
+use App\Jobs\UpdateSite;
+use App\Models\Site;
+use Illuminate\Console\Command;
+use Illuminate\Database\Eloquent\Collection;
+
+class QueueUpdates extends Command
+{
+    protected int $totalPushed = 0;
+
+    use RequestTargetVersion;
+
+    /**
+     * The name and signature of the console command.
+     *
+     * @var string
+     */
+    protected $signature = 'app:queue-updates';
+
+    /**
+     * The console command description.
+     *
+     * @var string
+     */
+    protected $description = 'Queues updates for all applicable registered sites';
+
+    /**
+     * Execute the console command.
+     */
+    public function handle()
+    {
+        $targetVersion = $this->getVersionChoices();
+
+        $this->confirm("Are you sure you would like to push the updates for " . $targetVersion);
+
+        $this->output->writeln('Pushing update jobs');
+
+        Site::query()
+            ->where(
+                'cms_version',
+                'like',
+                $targetVersion[0] . '%'
+            )
+            ->chunkById(
+                100,
+                function (Collection $chunk) use ($targetVersion) {
+                    // Show progress
+                    $this->output->write('.');
+
+                    $this->totalPushed += $chunk->count();
+
+                    // Push each site check to queue
+                    $chunk->each(fn ($site) => UpdateSite::dispatch($site, $targetVersion));
+                }
+            );
+
+        // Result
+        $this->output->writeln("");
+        $this->output->writeln('Pushed ' . $this->totalPushed . ' pending jobs to queue');
+
+        return Command::SUCCESS;
+    }
+}

app/Console/Traits/RequestTargetVersion.php

@@ -0,0 +1,20 @@
+<?php
+
+namespace App\Console\Traits;
+
+use App\TUF\TufFetcher;
+
+trait RequestTargetVersion
+{
+    protected function getVersionChoices()
+    {
+        $releases = (new TufFetcher())->getReleases();
+
+        $targetVersion = $this->choice(
+            "What's the target version?",
+            $releases->map(fn($release) => $release["version"])->values()->toArray()
+        );
+
+        return $targetVersion;
+    }
+}

app/Http/Controllers/Api/V1/SiteController.php

@@ -36,7 +36,7 @@ public function register(SiteRequest $request): JsonResponse
 
         $connectionService = App::makeWith(
             Connection::class,
-            ["baseUrl" => $url, "key" => $key]
+            ["baseUrl" => rtrim($url, "/"), "key" => $key]
         );
 
         // Do a health check
@@ -52,7 +52,7 @@ public function register(SiteRequest $request): JsonResponse
         $site = new Site();
 
         $site->key = $key;
-        $site->url = rtrim($url, "/");
+        $site->url = $url;
         $site->last_seen = Carbon::now();
 
         // Fill with site info
@@ -75,15 +75,20 @@ public function check(SiteRequest $request): JsonResponse
         $url = $request->string('url');
         $key = $request->string('key');
 
-        $connectionService = new Connection($url, $key);
+        try {
+            /** @var Site $site */
+            $site = Site::where('url', $url)->where('key', $key)->findOrFail();
+        } catch (\Exception $e) {
+            return $this->error("Not found", 404);
+        }
 
         // Do a health check
         try {
-            $connectionService->checkHealth();
-        } catch (ServerException $e) {
+            $site->getConnection()->checkHealth();
+        } catch (ServerException|ClientException $e) {
+            return $this->error($e->getMessage(), 400);
+        } catch (\Exception $e) {
             return $this->error($e->getMessage(), 500);
-        } catch (ClientException|\Exception $e) {
-            return $this->error($e->getMessage());
         }
 
         return $this->ok();
@@ -100,11 +105,13 @@ public function delete(SiteRequest $request): JsonResponse
         $key = $request->string('key');
 
         try {
-            Site::where('url', $url)->where('key', $key)->delete();
+            $site = Site::where('url', $url)->where('key', $key)->findOrFail();
         } catch (\Exception $e) {
-            return $this->error($e->getMessage());
+            return $this->error("Not found", 404);
         }
 
+        $site->delete();
+
         return $this->ok();
     }
 }

app/Jobs/UpdateSite.php

@@ -62,8 +62,7 @@ public function handle(): void
             return;
         }
 
-        $prepareResult = $connection->prepareUpdate($this->targetVersion);
-
+        $prepareResult = $connection->prepareUpdate(["targetVersion" => $this->targetVersion]);
         // Perform the actual extraction
         $this->performExtraction($prepareResult);
 

routes/console.php

@@ -3,6 +3,8 @@
 use Illuminate\Support\Facades\Schedule;
 use Illuminate\Queue\Console\PruneFailedJobsCommand;
 use App\Console\Commands\QueueHealthChecks;
+use App\Console\Commands\CleanupSitesList;
 
+Schedule::command(CleanupSitesList::class)->everySixHours();
 Schedule::command(PruneFailedJobsCommand::class)->daily();
 Schedule::command(QueueHealthChecks::class)->everyFifteenMinutes();