Merge (#127)

app/Actions/Queue/CreateQueue.php

@@ -29,7 +29,23 @@ public function create(mixed $queueable, array $input): void
             'status' => QueueStatus::CREATING,
         ]);
         $queue->save();
-        $queue->deploy();
+
+        dispatch(function () use ($queue) {
+            $queue->server->processManager()->handler()->create(
+                $queue->id,
+                $queue->command,
+                $queue->user,
+                $queue->auto_start,
+                $queue->auto_restart,
+                $queue->numprocs,
+                $queue->getLogFile(),
+                $queue->site_id
+            );
+            $queue->status = QueueStatus::RUNNING;
+            $queue->save();
+        })->catch(function () use ($queue) {
+            $queue->delete();
+        })->onConnection('ssh');
     }
 
     /**
@@ -60,6 +76,6 @@ protected function validate(array $input): void
             ],
         ];
 
-        Validator::make($input, $rules)->validateWithBag('createQueue');
+        Validator::make($input, $rules)->validate();
     }
 }

app/Actions/Queue/DeleteQueue.php

@@ -0,0 +1,14 @@
+<?php
+
+namespace App\Actions\Queue;
+
+use App\Models\Queue;
+
+class DeleteQueue
+{
+    public function delete(Queue $queue): void
+    {
+        $queue->server->processManager()->handler()->delete($queue->id, $queue->site_id);
+        $queue->delete();
+    }
+}

app/Actions/Queue/GetQueueLogs.php

@@ -0,0 +1,13 @@
+<?php
+
+namespace App\Actions\Queue;
+
+use App\Models\Queue;
+
+class GetQueueLogs
+{
+    public function getLogs(Queue $queue): string
+    {
+        return $queue->server->processManager()->handler()->getLogs($queue->getLogFile());
+    }
+}

app/Actions/Queue/ManageQueue.php

@@ -0,0 +1,42 @@
+<?php
+
+namespace App\Actions\Queue;
+
+use App\Enums\QueueStatus;
+use App\Models\Queue;
+
+class ManageQueue
+{
+    public function start(Queue $queue): void
+    {
+        $queue->status = QueueStatus::STARTING;
+        $queue->save();
+        dispatch(function () use ($queue) {
+            $queue->server->processManager()->handler()->start($queue->id, $queue->site_id);
+            $queue->status = QueueStatus::RUNNING;
+            $queue->save();
+        })->onConnection('ssh');
+    }
+
+    public function stop(Queue $queue): void
+    {
+        $queue->status = QueueStatus::STOPPING;
+        $queue->save();
+        dispatch(function () use ($queue) {
+            $queue->server->processManager()->handler()->stop($queue->id, $queue->site_id);
+            $queue->status = QueueStatus::STOPPED;
+            $queue->save();
+        })->onConnection('ssh');
+    }
+
+    public function restart(Queue $queue): void
+    {
+        $queue->status = QueueStatus::RESTARTING;
+        $queue->save();
+        dispatch(function () use ($queue) {
+            $queue->server->processManager()->handler()->restart($queue->id, $queue->site_id);
+            $queue->status = QueueStatus::RUNNING;
+            $queue->save();
+        })->onConnection('ssh');
+    }
+}