feat(runable): add setPipe method to support process piping

guanguans · guanguans · commit 7be47881aadd · 2025-11-27T22:52:36.000+08:00
- Introduce a new protected property `$pipe` to hold a callable that transforms a Process instance
- Add `setPipe` method to assign a callable to `$pipe` and enable method chaining
- Modify `run` method to invoke the `$pipe` callable on the process if set, allowing process manipulation before returning
- Maintain existing functionality of `$tap` callable for side effects without altering the process
- Enhance flexibility in handling Process objects by enabling custom piping logic

Signed-off-by: guanguans &lt;ityaozm@gmail.com&gt;
diff --git a/src/Concerns/WithRunable.php b/src/Concerns/WithRunable.php
@@ -20,9 +20,19 @@
  */
 trait WithRunable
 {
+    /** @var null|callable(Process):Process */
+    protected $pipe;
+
     /** @var null|callable(Process):void */
     protected $tap;
 
+    public function setPipe(?callable $pipe): self
+    {
+        $this->pipe = $pipe;
+
+        return $this;
+    }
+
     public function setTap(?callable $tap): self
     {
         $this->tap = $tap;
@@ -43,19 +53,16 @@ public function run(?callable $callback = null): string
      */
     protected function toProcess(): Process
     {
-        $normalizedOptions = $this->clone()->getNormalizedOptions();
+        $command = [$this->soarBinary, ...$this->clone()->getNormalizedOptions()];
 
         $process = $this->shouldApplySudoPassword()
-            ? new Process(
-                command: ['sudo', '-S', $this->soarBinary, ...$normalizedOptions],
-                input: $this->getSudoPassword()
-            )
-            : new Process([$this->soarBinary, ...$normalizedOptions]);
+            ? new Process(command: ['sudo', '-S', ...$command], input: $this->getSudoPassword())
+            : new Process($command);
 
         if (\is_callable($this->tap)) {
             ($this->tap)($process);
         }
 
-        return $process;
+        return \is_callable($this->pipe) ? ($this->pipe)($process) : $process;
     }
 }
