Sergiors\Pipeline\Pipeline

Complexity

Total Complexity

7

Size/Duplication

Total Lines	75
Duplicated Lines	0 %

Coupling/Cohesion

Components	1
Dependencies	1

Test Coverage

Coverage

100%

Importance

Changes	4
Bugs	0	Features	3

5 Methods

Rating	Name	Duplication	Size	Complexity
A	__construct()	0	4	1
A	pipe()	0	4	1
A	process()	0	8	1
A	__call()	0	21	3
A	__invoke()	0	4	1

<?php

namespace Sergiors\Pipeline;

/**
 * @author Sérgio Rafael Siqueira <sergio@inbep.com.br>
 */
final class Pipeline
{
    /**
     * @var callable[]
     */
    private $callbacks;

    /**
     * @param array $callbacks
     */
    public function __construct(array $callbacks = [])
    {
        $this->callbacks = array_filter($callbacks, 'is_callable');
    }

    /**
     * @param callable $callback
     *
     * @return Pipeline
     */
    public function pipe(callable $callback)
    {
        return new self(array_merge($this->callbacks, [$callback]));
    }

    /**
     * @param mixed $payload
     *
     * @return mixed
     */
    public function process($payload /* ...$args */)
    {
        $rest = array_slice(func_get_args(), 1);

        return array_reduce($this->callbacks, function ($payload, $callback) use ($rest) {
            return call_user_func_array($callback, array_merge([$payload], $rest));
        }, $payload);
    }

    /**
     * @param callable $fn
     * @param array    $args
     *
     * @return Pipeline
     */
    public function __call(callable $fn, array $args)
    {
        $ks = (new self())
            ->pipe(new Filter(function ($x) {
                return '%' === $x;
            }))
            ->pipe(function ($xs) {
                return array_keys($xs) ?: [];
            })
            ->process($args);

        return $this->pipe(function ($payload) use ($fn, $args, $ks) {
            if ([] === $ks) {
                return call_user_func_array($fn, array_merge($args, [$payload]));
            }

            return call_user_func_array($fn, array_replace($args, [
                $ks[0] => $payload
            ]));
        });
    }

    /**
     * @return mixed
     */
    public function __invoke(/* ...$args */)
    {
        return call_user_func_array([$this, 'process'], func_get_args());
    }
}