feat: add queue:run command

src/Queue.php

@@ -162,12 +162,13 @@ public function retryFailedJob($id, $retryCount = 0)
     /**
      * Return queue commands
      */
-    public function commands()
+    public static function commands()
     {
         return [
             \Leaf\Queue\Commands\DeleteJobCommand::class,
             \Leaf\Queue\Commands\GenerateJobCommand::class,
             \Leaf\Queue\Commands\QueuePauseCommand::class,
+            \Leaf\Queue\Commands\QueueRunCommand::class,
         ];
     }
 

src/Queue/Commands/QueueRunCommand.php

@@ -0,0 +1,40 @@
+<?php
+
+namespace Leaf\Queue\Commands;
+
+use Aloe\Command;
+use Leaf\Queue;
+
+class QueueRunCommand extends Command
+{
+    protected static $defaultName = 'queue:run';
+    public $description = 'Start your queue worker';
+    public $help = 'Start your queue worker';
+
+    protected function handle()
+    {
+        $this->writeln('Starting queue worker...');
+
+        $queue = new Queue;
+        $queueConfigFile = getcwd() . '/config/queue.php';
+        $queueConfig = [];
+
+        if (file_exists($queueConfigFile)) {
+            $queueConfig = require $queueConfigFile;
+        }
+
+        if (empty($queueConfig)) {
+            if (!file_exists($configFile = getcwd() . '/queue.config.php')) {
+                throw new \Exception("Queue config not found");
+            }
+
+            $queueConfig = require $configFile;
+        }
+
+        $queue->config($queueConfig);
+        $queue->connect();
+        $queue->run();
+
+        return 0;
+    }
+}