Add Clear Queues Command (#5)

Add clear-queues console command

---------

Co-authored-by: Mark de Heij <m.deheij@vdlp.nl>
Co-authored-by: Sander Beenen <sander@sbeenen.nl>

Plugin.php

@@ -10,6 +10,7 @@
 use Illuminate\Notifications\NotificationServiceProvider;
 use Laravel\Horizon\Horizon;
 use System\Classes\PluginBase;
+use Vdlp\Horizon\Console\ClearQueuesCommand;
 use Vdlp\Horizon\Console\InstallCommand;
 use Vdlp\Horizon\Console\PushExampleJobsCommand;
 use Vdlp\Horizon\ServiceProviders\HorizonServiceProvider;
@@ -49,6 +50,7 @@ public function boot(): void
             $this->registerConsoleCommand(PushExampleJobsCommand::class, PushExampleJobsCommand::class);
         }
 
+        $this->registerConsoleCommand(ClearQueuesCommand::class, ClearQueuesCommand::class);
         $this->registerConsoleCommand(InstallCommand::class, InstallCommand::class);
     }
 

console/ClearQueuesCommand.php

@@ -0,0 +1,33 @@
+<?php
+
+declare(strict_types=1);
+
+namespace Vdlp\Horizon\Console;
+
+use Artisan;
+use Illuminate\Console\Command;
+use Illuminate\Contracts\Config\Repository;
+
+final class ClearQueuesCommand extends Command
+{
+    public function __construct()
+    {
+        $this->name = 'vdlp:horizon:clear-queues';
+        $this->description = 'Clears all the Horizon queues with one command.';
+
+        parent::__construct();
+    }
+
+    public function handle(Repository $config): void
+    {
+        $supervisors = $config->get('horizon.defaults');
+
+        foreach ($supervisors as $supervisor) {
+            foreach ($supervisor['queue'] as $queue) {
+                Artisan::call('horizon:clear', ['--queue' => $queue]);
+
+                $this->comment(preg_replace('/\R+/', ' ', Artisan::output()));
+            }
+        }
+    }
+}