wip

Author: simonhamp

src/ChildProcess/ChildProcess.php

@@ -0,0 +1,91 @@
+<?php
+
+namespace Native\Laravel\ChildProcess;
+
+use Illuminate\Support\Facades\Event;
+use Native\Laravel\Client\Client;
+use Native\Laravel\Events\ChildProcess\ErrorReceived;
+use Native\Laravel\Events\ChildProcess\MessageReceived;
+use Native\Laravel\Events\ChildProcess\ProcessSpawned;
+use Native\Laravel\Events\ChildProcess\ProcessExited;
+
+class ChildProcess
+{
+    private string $alias;
+    private ?array $process;
+
+    public function __construct(protected Client $client) {}
+
+    public function start(string $alias, array $cmd, string $cwd = null, array $env = null): object
+    {
+        $this->alias = $alias;
+
+        $this->process = $this->client->post('child-process/start', [
+            'alias' => $alias,
+            'cmd' => $cmd,
+            'cwd' => base_path(),
+            'env' => $env,
+        ])->json();
+
+        return $this;
+    }
+
+    public function stop(string $alias): void
+    {
+        $this->client->post('child-process/stop', [
+            'alias' => $alias,
+        ])->json();
+    }
+
+    public function message(string $alias, mixed $message): void
+    {
+        $this->client->post('child-process/message', [
+            'alias' => $alias,
+            'message' => json_encode($message),
+        ])->json();
+    }
+
+    public function onMessage(\Closure $callback) {
+        // Event::listen(function (MessageReceived $event) use ($callback) {
+        //    if ($event->alias !== $this->alias) {
+        //        return;
+        //    }
+        //
+        //    $callback($event);
+        // );
+        return $this;
+    }
+
+    public function onError(\Closure $callback) {
+        // Event::listen(function (ErrorReceived $event) use ($callback) {
+        //    if ($event->alias !== $this->alias) {
+        //        return;
+        //    }
+        //
+        //    $callback($event);
+        // );
+        return $this;
+    }
+
+    public function onSpawn(\Closure $callback) {
+        // Event::listen(function (ProcessSpawned $event) use ($callback) {
+        //    if ($event->alias !== $this->alias) {
+        //        return;
+        //    }
+        //
+        //    $callback($event);
+        // );
+        return $this;
+    }
+
+    public function onExit(\Closure $callback) {
+        // Event::listen(function (ProcessExited $event) use ($callback) {
+        //    if ($event->alias !== $this->alias) {
+        //        return;
+        //    }
+        //
+        //    $callback($event);
+        // );
+        return $this;
+    }
+}

src/ChildProcess/ChildProcessManager.php

@@ -0,0 +1,24 @@
+<?php
+
+namespace Native\Laravel\ChildProcess;
+
+use Native\Laravel\Client\Client;
+
+class ChildProcessManager
+{
+    public function __construct(protected Client $client) {}
+
+    public function start(string $alias, array $cmd, string $cwd = null, array $env = null): object
+    {
+        $this->process = $this->client->post('child-process/start')->json([
+            'alias' => $alias,
+            'cmd' => $cmd,
+            'cwd' => $cwd,
+            'env' => $env,
+        ]);
+    }
+
+    public function onMessage() {
+
+    }
+}

src/Events/ChildProcess/ProcessSpawned.php

@@ -0,0 +1,22 @@
+<?php
+
+namespace Native\Laravel\Events\ChildProcess;
+
+use Illuminate\Broadcasting\Channel;
+use Illuminate\Contracts\Broadcasting\ShouldBroadcast;
+use Illuminate\Foundation\Events\Dispatchable;
+use Illuminate\Queue\SerializesModels;
+
+class ProcessSpawned implements ShouldBroadcast
+{
+    use Dispatchable, SerializesModels;
+
+    public function __construct(public array $item) {}
+
+    public function broadcastOn()
+    {
+        return [
+            new Channel('nativephp'),
+        ];
+    }
+}

src/Facades/ChildProcess.php

@@ -0,0 +1,18 @@
+<?php
+
+namespace Native\Laravel\Facades;
+
+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)
+ */
+class ChildProcess extends Facade
+{
+    protected static function getFacadeAccessor()
+    {
+        return \Native\Laravel\ChildProcess\ChildProcess::class;
+    }
+}