Merge branch 'feature/child-processes' into feature/child-processes

Author: simonhamp

src/ChildProcess.php

@@ -6,26 +6,74 @@
 
 class ChildProcess
 {
+    public readonly int $pid;
+
+    public readonly string $alias;
+
+    public readonly array $cmd;
+
+    public readonly ?string $cwd;
+
+    public readonly ?array $env;
+
+    public readonly bool $persistent;
+
     public function __construct(protected Client $client) {}
 
-    public function start(string|array $cmd, string $alias, ?string $cwd = null, ?array $env = null, ?bool $persistent = false): self
+    public function get(?string $alias = null): ?static
+    {
+        $alias = $alias ?? $this->alias;
+
+        $process = $this->client->get("child-process/get/{$alias}")->json();
+
+        if (! $process) {
+            return null;
+        }
+
+        return $this->fromRuntimeProcess($process);
+    }
+
+    public function all(): array
     {
+        $processes = $this->client->get('child-process/')->json();
+
+        if (empty($processes)) {
+            return [];
+        }
+
+        $hydrated = [];
+
+        foreach ($processes as $alias => $process) {
+            $hydrated[$alias] = (new static($this->client))
+                ->fromRuntimeProcess($process);
+        }
+
+        return $hydrated;
+    }
+        
+    public function start(
+        string|array $cmd
+        string $alias,
+        ?string $cwd = null,
+        ?array $env = null,
+        bool $persistent = false
+    ): static {
         $cwd = $cwd ?? base_path();
 
         if (is_string($cmd)) {
             // When a string is passed, explode it on the space
             $cmd = array_values(array_filter(explode(' ', $cmd)));
         }
 
-        $this->client->post('child-process/start', [
+        $process = $this->client->post('child-process/start', [
             'alias' => $alias,
             'cmd' => $cmd,
             'cwd' => $cwd,
             'env' => $env,
             'persistent' => $persistent,
         ])->json();
 
-        return $this;
+        return $this->fromRuntimeProcess($process);
     }
 
     public function artisan(string|array $cmd, string $alias, ?array $env = null, ?bool $persistent = false): self
@@ -35,18 +83,46 @@ public function artisan(string|array $cmd, string $alias, ?array $env = null, ?b
         return $this->start($cmd, $alias, env: $env, persistent: $persistent);
     }
 
-    public function stop(string $alias): void
+    public function stop(?string $alias = null): void
     {
         $this->client->post('child-process/stop', [
-            'alias' => $alias,
+            'alias' => $alias ?? $this->alias,
+        ])->json();
+    }
+
+    public function restart(?string $alias = null): ?static
+    {
+        $process = $this->client->post('child-process/restart', [
+            'alias' => $alias ?? $this->alias,
         ])->json();
+
+        if (! $process) {
+            return null;
+        }
+
+        return $this->fromRuntimeProcess($process);
     }
 
-    public function message(mixed $message, string $alias): void
+    public function message(string $message, ?string $alias = null): static
     {
         $this->client->post('child-process/message', [
-            'message' => json_encode($message),
-            'alias' => $alias,
+            'alias' => $alias ?? $this->alias,
+            'message' => $message,
         ])->json();
+
+        return $this;
+    }
+
+    private function fromRuntimeProcess($process): static
+    {
+        if (isset($process['pid'])) {
+            $this->pid = $process['pid'];
+        }
+
+        foreach ($process['settings'] as $key => $value) {
+            $this->{$key} = $value;
+        }
+
+        return $this;
     }
 }

src/Facades/ChildProcess.php

@@ -5,9 +5,12 @@
 use Illuminate\Support\Facades\Facade;
 
 /**
- * @method static string start(string $alias, array $cmd, string $cwd = null, array $env = null)
- * @method static string stop(string $alias)
- * @method static string message(string $alias, mixed $message)
+ * @method static \Native\Laravel\ChildProcess[] all()
+ * @method static \Native\Laravel\ChildProcess get(string $alias)
+ * @method static \Native\Laravel\ChildProcess message(string $message, string $alias = null)
+ * @method static \Native\Laravel\ChildProcess restart(string $alias)
+ * @method static \Native\Laravel\ChildProcess start(string $alias, array $cmd, string $cwd = null, array $env = null, bool $persistent = false)
+ * @method static void stop(string $alias)
  */
 class ChildProcess extends Facade
 {