From ab995b9b59426fb4210301283a3a84fbff425737 Mon Sep 17 00:00:00 2001
From: dnomd343 <i@343.re>
Date: Wed, 10 Aug 2022 12:35:55 +0800
Subject: [PATCH] feat: demo of Process class

---
 src/Process.php | 78 +++++++++++++++++++++++++++++++++++++++++++++++++
 1 file changed, 78 insertions(+)
 create mode 100644 src/Process.php

diff --git a/src/Process.php b/src/Process.php
new file mode 100644
index 0000000..84fbc74
--- /dev/null
+++ b/src/Process.php
@@ -0,0 +1,78 @@
+<?php
+
+class Process {
+    private $process;
+    public int $pid = -1;
+    public mixed $stdin = null;
+    public mixed $stdout = null; // only capture enabled
+    public mixed $stderr = null; // only capture enabled
+
+    public function __construct(array $command, bool $capture = false, array $env = array()) {
+        $desc = array(
+            0 => array('pipe', 'r') // stdin
+        );
+        if ($capture) {
+            $desc[1] = array('pipe', 'w'); // stdout
+            $desc[2] = array('pipe', 'w'); // stderr
+        }
+        $this->process = proc_open($command, $desc, $pipes, null, $env); // start process
+        if (is_resource($this->process)) { // process start success
+            $this->pid = proc_get_status($this->process)['pid'];
+            $this->stdin = $pipes[0];
+            if ($capture) { // add capture pipes
+                $this->stdout = $pipes[1];
+                $this->stderr = $pipes[2];
+            }
+        }
+    }
+
+    private function getCapture(mixed $stream): string { // read data from target stream
+        return ($stream == null) ? '' : stream_get_contents($stream);
+    }
+
+    public function getStdout(): string { // fetch data from stdout pipe
+        return $this->getCapture($this->stdout);
+    }
+
+    public function getStderr(): string { // fetch data from stderr pipe
+        return $this->getCapture($this->stderr);
+    }
+
+    public function signal(int $signal): void { // send signal to sub process
+        proc_terminate($this->process, $signal);
+    }
+
+    public function isAlive(): bool { // whether sub process still running
+        return proc_get_status($this->process)['running'];
+    }
+
+    public function quit(): int {
+        fclose($this->stdout); // close pipe before proc_close (prevent deadlock)
+        fclose($this->stderr);
+        return proc_close($this->process); // return status code
+    }
+}
+
+
+$p = new Process(['sleep', '10'], $capture = true);
+echo "PID -> $p->pid\n";
+
+echo "Alive -> " . ($p->isAlive() ? 'yes' : 'no') . "\n";
+echo "Sleep 5s...\n";
+sleep(5);
+
+echo "Alive -> " . ($p->isAlive() ? 'yes' : 'no') . "\n";
+echo "Send kill signal\n";
+$p->signal(15);
+sleep(1);
+echo "Alive -> " . ($p->isAlive() ? 'yes' : 'no') . "\n";
+
+echo '--------------------------------------------' . PHP_EOL;
+echo $p->getStdout();
+echo '--------------------------------------------' . PHP_EOL;
+echo $p->getStdout();
+echo '--------------------------------------------' . PHP_EOL;
+echo $p->getStderr();
+echo '--------------------------------------------' . PHP_EOL;
+
+echo "Return code -> " . $p->quit() . "\n";