Bdf\Pipeline\Processor\StackProcessor

Complexity

Total Complexity

6

Size/Duplication

Total Lines	56
Duplicated Lines	0 %

Importance

Changes

0

3 Methods

Rating	Name	Duplication	Size	Complexity
A	clearCache()	0	3	1
A	process()	0	5	1
A	getCallable()	0	21	4

<?php

namespace Bdf\Pipeline\Processor;

use Bdf\Pipeline\ProcessorInterface;

/**
 * StackProcessor
 *
 * @author Sébastien Tanneux
 */
class StackProcessor implements ProcessorInterface
{
    /**
     * The pipes callable
     *
     * @var callable
     */
    private $callable;

    /**
     * {@inheritdoc}
     */
    public function process(array $pipes, array $payload, callable $outlet = null)
    {
        $callable = $this->getCallable($pipes, $outlet);

        return $callable(...$payload);
    }

    /**
     * Build the chain callable
     *
     * @param array $pipes
     * @param callable|null $outlet
     *
     * @return \Closure
     */
    private function getCallable($pipes, $outlet)
    {
        if ($this->callable !== null) {
            return $this->callable;
        }

        if ($outlet !== null) {
            $callable = $outlet;
        } else {
            $callable = function ($payload) {
                return $payload;
            };
        };

        while ($pipe = array_pop($pipes)) {
            $callable = function (...$payload) use ($pipe, $callable) {
                return $pipe($callable, ...$payload);
            };
        }

        return $callable;
    }

    /**
     * {@inheritdoc}
     */
    public function clearCache()
    {
        $this->callable = null;
    }
}