[10.x] Add syntax sugar to the Process::pipe method

src/Illuminate/Process/Factory.php

@@ -274,12 +274,14 @@ public function pool(callable $callback)
     /**
      * Start defining a series of piped processes.
      *
-     * @param  callable  $callback
+     * @param  callable|array  $callback
      * @return \Illuminate\Process\Pipe
      */
-    public function pipe(callable $callback, ?callable $output = null)
+    public function pipe(callable|array $callback, ?callable $output = null)
     {
-        return (new Pipe($this, $callback))->run(output: $output);
+        return is_array($callback)
+            ? (new Pipe($this, $callback))->runSimple()
+            : (new Pipe($this, $callback))->run(output: $output);
     }
 
     /**

src/Illuminate/Process/Pipe.php

@@ -18,9 +18,10 @@ class Pipe
     protected $factory;
 
     /**
-     * The callback that resolves the pending processes.
+     * The callback that resolves the pending processes,
+     * or array of string processes to run.
      *
-     * @var callable
+     * @var callable|array
      */
     protected $callback;
 
@@ -35,10 +36,10 @@ class Pipe
      * Create a new series of piped processes.
      *
      * @param  \Illuminate\Process\Factory  $factory
-     * @param  callable  $callback
+     * @param  callable|array  $callback
      * @return void
      */
-    public function __construct(Factory $factory, callable $callback)
+    public function __construct(Factory $factory, callable|array $callback)
     {
         $this->factory = $factory;
         $this->callback = $callback;
@@ -86,6 +87,32 @@ public function run(?callable $output = null)
                 });
     }
 
+    /**
+     * Runs the processes in the pipe as simple commands.
+     *
+     * @return \Illuminate\Contracts\Process\ProcessResult
+     */
+    public function runSimple()
+    {
+        return collect($this->callback)
+            ->reduce(function ($previousProcessResult, $command) {
+                if (! is_string($command)) {
+                    throw new InvalidArgumentException('Process pipe must only contain strings.');
+                }
+
+                if ($previousProcessResult && $previousProcessResult->failed()) {
+                    return $previousProcessResult;
+                }
+
+                $pendingProcess = $this->command($command);
+
+                return $pendingProcess->when(
+                    $previousProcessResult,
+                    fn () => $pendingProcess->input($previousProcessResult->output())
+                )->run();
+            });
+    }
+
     /**
      * Dynamically proxy methods calls to a new pending process.
      *

src/Illuminate/Support/Facades/Process.php

@@ -35,7 +35,7 @@
  * @method static \Illuminate\Process\Factory assertDidntRun(\Closure|string $callback)
  * @method static \Illuminate\Process\Factory assertNothingRan()
  * @method static \Illuminate\Process\Pool pool(callable $callback)
- * @method static \Illuminate\Process\Pipe pipe(callable $callback, callable|null $output = null)
+ * @method static \Illuminate\Process\Pipe pipe(callable|array $callback, callable|null $output = null)
  * @method static \Illuminate\Process\ProcessPoolResults concurrently(callable $callback, callable|null $output = null)
  * @method static \Illuminate\Process\PendingProcess newPendingProcess()
  * @method static void macro(string $name, object|callable $macro)

tests/Process/ProcessTest.php

@@ -534,6 +534,44 @@ public function testProcessPipeFailed()
         $this->assertTrue($pipe->failed());
     }
 
+    public function testProcessSimplePipe()
+    {
+        if (windows_os()) {
+            $this->markTestSkipped('Requires Linux.');
+        }
+
+        $factory = new Factory;
+        $factory->fake([
+            'cat *' => "Hello, world\nfoo\nbar",
+        ]);
+
+        $pipe = $factory->pipe([
+            'cat test',
+            'grep -i "foo"',
+        ]);
+
+        $this->assertSame("foo\n", $pipe->output());
+    }
+
+    public function testProcessSimplePipeFailed()
+    {
+        if (windows_os()) {
+            $this->markTestSkipped('Requires Linux.');
+        }
+
+        $factory = new Factory;
+        $factory->fake([
+            'cat *' => $factory->result(exitCode: 1),
+        ]);
+
+        $pipe = $factory->pipe([
+            'cat test',
+            'grep -i "foo"',
+        ]);
+
+        $this->assertTrue($pipe->failed());
+    }
+
     public function testFakeInvokedProcessOutputWithLatestOutput()
     {
         $factory = new Factory;