Added Macroable trait to Hyperf\Pipeline\Pipeline. (#7492)

Author: huangdijia

composer.json

@@ -17,6 +17,7 @@
     },
     "require": {
         "php": ">=8.1",
+        "hyperf/macroable": "~3.1.0",
         "psr/container": "^1.0 || ^2.0"
     },
     "autoload": {

src/Pipeline.php

@@ -13,6 +13,7 @@
 namespace Hyperf\Pipeline;
 
 use Closure;
+use Hyperf\Macroable\Macroable;
 use Psr\Container\ContainerInterface;
 
 /**
@@ -21,6 +22,8 @@
  */
 class Pipeline
 {
+    use Macroable;
+
     /**
      * The object being passed through the pipeline.
      */

tests/PipelineTest.php

@@ -211,6 +211,58 @@ public function testHandleCarry()
         $this->assertSame($id + 6, $result);
     }
 
+    public function testPipelineMacro()
+    {
+        Pipeline::macro('customMethod', function ($value) {
+            return 'custom_' . $value;
+        });
+
+        $pipeline = new Pipeline($this->getContainer());
+        $this->assertTrue($pipeline->hasMacro('customMethod'));
+        $this->assertSame('custom_test', $pipeline->customMethod('test'));
+    }
+
+    public function testPipelineMacroWithThis()
+    {
+        Pipeline::macro('getPipes', function () {
+            return $this->pipes;
+        });
+
+        $pipeline = new Pipeline($this->getContainer());
+        $pipeline->through(['pipe1', 'pipe2']);
+
+        $this->assertEquals(['pipe1', 'pipe2'], $pipeline->getPipes());
+    }
+
+    public function testPipelineHasMacro()
+    {
+        Pipeline::macro('existingMacro', function () {
+            return 'exists';
+        });
+
+        $pipeline = new Pipeline($this->getContainer());
+
+        $this->assertTrue($pipeline->hasMacro('existingMacro'));
+        $this->assertFalse($pipeline->hasMacro('nonExistingMacro'));
+    }
+
+    public function testPipelineMacroOverwrite()
+    {
+        Pipeline::macro('testMacro', function () {
+            return 'first';
+        });
+
+        $pipeline = new Pipeline($this->getContainer());
+        $this->assertSame('first', $pipeline->testMacro());
+
+        Pipeline::macro('testMacro', function () {
+            return 'second';
+        });
+
+        $pipeline2 = new Pipeline($this->getContainer());
+        $this->assertSame('second', $pipeline2->testMacro());
+    }
+
     protected function getContainer()
     {
         $container = Mockery::mock(ContainerInterface::class);