Merge pull request #11 from adrolli/dev

.gitignore

@@ -0,0 +1,2 @@
+
+.DS_Store

routes/web.php

@@ -0,0 +1,11 @@
+<?php
+
+use Adrolli\FilamentJobManager\Controllers\QueueController;
+use Illuminate\Support\Facades\Route;
+
+// queue:work control features
+//Route::middleware(['auth'])->group(function () {
+Route::get('queue/status', [QueueController::class, 'queueStatus']);
+Route::get('queue/start', [QueueController::class, 'startQueue']);
+Route::get('queue/stop', [QueueController::class, 'stopQueue']);
+//});

src/Controllers/QueueController.php

@@ -0,0 +1,49 @@
+<?php
+
+namespace Adrolli\FilamentJobManager\Controllers;
+
+use Illuminate\Routing\Controller;
+use Illuminate\Support\Facades\Artisan;
+use Illuminate\Support\Facades\Queue;
+
+class QueueController extends Controller
+{
+    public function queueStatus()
+    {
+        $isRunning = Queue::isRunning('default');
+        dd($isRunning);
+    }
+
+    public function startQueue()
+    {
+        // Start the queue worker
+        Artisan::call('queue:work', ['--daemon' => true]);
+
+        $this->queueStatus();
+    }
+
+    public function stopQueue()
+    {
+        // Stop the queue worker
+        // Find the queue worker process ID
+        //        $pidFilePath = storage_path('app/queue_worker.pid');
+        $pidFilePath = base_path('storage/app/queue_worker.pid');
+
+        $pid = file_get_contents($pidFilePath);
+
+        if ($pid) {
+            posix_kill($pid, SIGTERM);
+
+            // Wait for the process to exit
+            while (posix_kill($pid, 0)) {
+                usleep(100000); // Sleep for 0.1 seconds
+            }
+
+            $this->info("Queue worker with PID $pid has stopped.");
+        } else {
+            $this->info('No queue worker process found.');
+        }
+
+        $this->queueStatus();
+    }
+}

src/FilamentJobManagerServiceProvider.php

@@ -12,7 +12,7 @@ public function configurePackage(Package $package): void
         $package->name('filament-job-manager')
             ->hasConfigFile()
             ->hasTranslations()
-            ->hasMigration('create_filament-job-manager_table');
-
+            ->hasMigration('create_filament-job-manager_table')
+            ->hasRoutes('web');
     }
 }

src/Resources/JobsResource.php

@@ -46,6 +46,8 @@ public static function form(Form $form): Form
     public static function table(Table $table): Table
     {
         return $table
+            ->poll('5s')
+            ->deferLoading()
             ->columns([
                 TextColumn::make('status')
                     ->badge()