EVOLUTION-MANAGER

Edit File: PipelineTest.php

<?php

namespace Mpociot\Pipeline\Tests;

use PHPUnit\Framework\TestCase;
use Mpociot\Pipeline\Pipeline;

class PipelineTest extends TestCase
{
    public function testPipelineBasicUsage()
    {
        $pipeOne = function ($piped, $next) {
            $_SERVER['__test.pipe.one'] = $piped;

return $next($piped);
        };
        $pipeTwo = function ($piped, $next) {
            $_SERVER['__test.pipe.two'] = $piped;

return $next($piped);
        };

$result = (new Pipeline())
                    ->send('foo')
                    ->through([$pipeOne, $pipeTwo])
                    ->then(function ($piped) {
                        return $piped;
                    });

$this->assertEquals('foo', $result);
        $this->assertEquals('foo', $_SERVER['__test.pipe.one']);
        $this->assertEquals('foo', $_SERVER['__test.pipe.two']);

unset($_SERVER['__test.pipe.one']);
        unset($_SERVER['__test.pipe.two']);
    }

public function testPipelineUsageWithObjects()
    {
        $result = (new Pipeline())
            ->send('foo')
            ->through([new PipelineTestPipeOne])
            ->then(function ($piped) {
                return $piped;
            });

$this->assertEquals('foo', $result);
        $this->assertEquals('foo', $_SERVER['__test.pipe.one']);

unset($_SERVER['__test.pipe.one']);
    }

public function testPipelineUsageWithParameters()
    {
        $parameters = ['one', 'two'];

$result = (new Pipeline())
            ->send('foo')
            ->through('Mpociot\Pipeline\Tests\PipelineTestParameterPipe:'.implode(',', $parameters))
            ->then(function ($piped) {
                return $piped;
            });

$this->assertEquals('foo', $result);
        $this->assertEquals($parameters, $_SERVER['__test.pipe.parameters']);

unset($_SERVER['__test.pipe.parameters']);
    }

public function testPipelineUsageWithMultiplePassables()
    {

$pipeOne = function ($piped, $pipedTwo, $next) {
            $_SERVER['__test.pipe.one_1'] = $piped;
            $_SERVER['__test.pipe.one_2'] = $pipedTwo;

return $next($piped, $pipedTwo);
        };
        $pipeTwo = function ($piped, $pipedTwo, $next) {
            $_SERVER['__test.pipe.two_1'] = $piped;
            $_SERVER['__test.pipe.two_2'] = $pipedTwo;

return $next($piped, $pipedTwo);
        };

$result = (new Pipeline())
            ->send('foo', 'bar')
            ->through([$pipeOne, $pipeTwo])
            ->then(function ($piped, $pipedTwo) {
                return [$piped, $pipedTwo];
            });

$this->assertEquals(['foo', 'bar'], $result);
        $this->assertEquals('foo', $_SERVER['__test.pipe.one_1']);
        $this->assertEquals('bar', $_SERVER['__test.pipe.one_2']);
        $this->assertEquals('foo', $_SERVER['__test.pipe.two_1']);
        $this->assertEquals('bar', $_SERVER['__test.pipe.two_2']);

unset($_SERVER['__test.pipe.one_1']);
        unset($_SERVER['__test.pipe.one_2']);
        unset($_SERVER['__test.pipe.two_1']);
        unset($_SERVER['__test.pipe.two_2']);
    }

public function testPipelineUsageWithMultipleParameters()
    {

$pipeOne = function ($piped, $next, $pipedTwo) {
            $_SERVER['__test.pipe.one_1'] = $piped;
            $_SERVER['__test.pipe.one_2'] = $pipedTwo;

return $next($piped);
        };
        $pipeTwo = function ($piped, $next, $pipedTwo) {
            $_SERVER['__test.pipe.two_1'] = $piped;
            $_SERVER['__test.pipe.two_2'] = $pipedTwo;

return $next($piped);
        };

$result = (new Pipeline())
            ->send('foo')
            ->through([$pipeOne, $pipeTwo])
            ->with('bar')
            ->then(function ($piped) {
                return $piped;
            });

$this->assertEquals('foo', $result);
        $this->assertEquals('foo', $_SERVER['__test.pipe.one_1']);
        $this->assertEquals('bar', $_SERVER['__test.pipe.one_2']);
        $this->assertEquals('foo', $_SERVER['__test.pipe.two_1']);
        $this->assertEquals('bar', $_SERVER['__test.pipe.two_2']);

unset($_SERVER['__test.pipe.one_1']);
        unset($_SERVER['__test.pipe.one_2']);
        unset($_SERVER['__test.pipe.two_1']);
        unset($_SERVER['__test.pipe.two_2']);
    }

public function testPipelineViaChangesTheMethodBeingCalledOnThePipes()
    {
        $pipelineInstance = new Pipeline();
        $result = $pipelineInstance->send('data')
            ->through(new PipelineTestPipeOne)
            ->via('differentMethod')
            ->then(function ($piped) {
                return $piped;
            });
        $this->assertEquals('data', $result);
    }
}

class PipelineTestPipeOne
{
    public function handle($piped, $next)
    {
        $_SERVER['__test.pipe.one'] = $piped;

return $next($piped);
    }

public function differentMethod($piped, $next)
    {
        return $next($piped);
    }
}

class PipelineTestParameterPipe
{
    public function handle($piped, $next, $parameter1 = null, $parameter2 = null)
    {
        $_SERVER['__test.pipe.parameters'] = [$parameter1, $parameter2];

return $next($piped);
    }
}