From 3d07c2e4ff7fd369b66a81b682bd76209aeed406 Mon Sep 17 00:00:00 2001
From: Arif Hoque <arif@sulaco-tec.com>
Date: Thu, 13 Nov 2025 22:33:53 +0600
Subject: [PATCH] make:job command for queue

---
 src/Commands/MakeJobCommand.php  | 107 +++++++++++++++++++++++++++++++
 src/Commands/QueueRunCommand.php |   1 +
 src/QueueServiceProvider.php     |   4 +-
 3 files changed, 111 insertions(+), 1 deletion(-)
 create mode 100644 src/Commands/MakeJobCommand.php

diff --git a/src/Commands/MakeJobCommand.php b/src/Commands/MakeJobCommand.php
new file mode 100644
index 0000000..00e8de8
--- /dev/null
+++ b/src/Commands/MakeJobCommand.php
@@ -0,0 +1,107 @@
+<?php
+
+namespace Doppar\Queue\Commands;
+
+use Phaseolies\Console\Schedule\Command;
+
+class MakeJobCommand extends Command
+{
+    /**
+     * The name and signature of the console command.
+     *
+     * @var string
+     */
+    protected $name = 'make:job {name}';
+
+    /**
+     * The description of the console command.
+     *
+     * @var string
+     */
+    protected $description = 'Create a new Job class';
+
+    /**
+     * Execute the console command.
+     *
+     * @return int
+     */
+    protected function handle(): int
+    {
+        return $this->executeWithTiming(function () {
+            $name = $this->argument('name');
+            $parts = explode('/', $name);
+            $className = array_pop($parts);
+
+            // Ensure class name ends with Job
+            if (!str_ends_with($className, 'Job')) {
+                $className .= 'Job';
+            }
+
+            $namespace = 'App\\Jobs' . (count($parts) > 0 ? '\\' . implode('\\', $parts) : '');
+            $filePath = base_path('app/Jobs/' . str_replace('/', DIRECTORY_SEPARATOR, $name) . '.php');
+
+            // Check if Job already exists
+            if (file_exists($filePath)) {
+                $this->displayError('Job already exists at:');
+                $this->line('<fg=white>' . str_replace(base_path(), '', $filePath) . '</>');
+                return Command::FAILURE;
+            }
+
+            // Create directory if needed
+            $directoryPath = dirname($filePath);
+            if (!is_dir($directoryPath)) {
+                mkdir($directoryPath, 0755, true);
+            }
+
+            // Generate and save Job class
+            $content = $this->generateJobContent($namespace, $className);
+            file_put_contents($filePath, $content);
+
+            $this->displaySuccess('Job created successfully');
+            $this->line('<fg=yellow>📦 File:</> <fg=white>' . str_replace(base_path(), '', $filePath) . '</>');
+            $this->newLine();
+            $this->line('<fg=yellow>⚙️  Class:</> <fg=white>' . $className . '</>');
+
+            return Command::SUCCESS;
+        });
+    }
+
+    /**
+     * Generate Job class content.
+     */
+    protected function generateJobContent(string $namespace, string $className): string
+    {
+        return <<<EOT
+<?php
+
+namespace {$namespace};
+
+use Doppar\Queue\Job;
+
+class {$className} extends Job
+{
+    /**
+     * Execute the job.
+     *
+     * @return void
+     */
+    public function handle(): void
+    {
+        //
+    }
+
+    /**
+     * Handle a job failure.
+     *
+     * @param \\Throwable \$exception
+     * @return void
+     */
+    public function failed(\\Throwable \$exception): void
+    {
+        //
+    }
+}
+
+EOT;
+    }
+}
diff --git a/src/Commands/QueueRunCommand.php b/src/Commands/QueueRunCommand.php
index 237378c..bc51931 100644
--- a/src/Commands/QueueRunCommand.php
+++ b/src/Commands/QueueRunCommand.php
@@ -50,6 +50,7 @@ public function __construct(QueueManager $manager)
 
     /**
      * Execute the console command.
+     * Example: php pool queue:run --queue=reports --sleep=10 --memory=1024 --timeout=3600
      *
      * @return int
      */
diff --git a/src/QueueServiceProvider.php b/src/QueueServiceProvider.php
index 9676718..d0234a8 100644
--- a/src/QueueServiceProvider.php
+++ b/src/QueueServiceProvider.php
@@ -2,6 +2,7 @@
 
 namespace Doppar\Queue;
 
+use Doppar\Queue\Commands\MakeJobCommand;
 use Phaseolies\Providers\ServiceProvider;
 use Doppar\Queue\QueueManager;
 use Doppar\Queue\Commands\QueueRunCommand;
@@ -34,7 +35,8 @@ public function boot(): void
 
         $this->commands([
             QueueRunCommand::class,
-            QueueRetryCommand::class
+            QueueRetryCommand::class,
+            MakeJobCommand::class
         ]);
     }
 }