Bdf\Pipeline\Pipeline

Complexity

Total Complexity

11

Size/Duplication

Total Lines	143
Duplicated Lines	0 %

Importance

Changes

0

9 Methods

Rating	Name	Duplication	Size	Complexity
A	__construct()	0	3	2
A	__clone()	0	3	1
A	outlet()	0	6	1
A	setPipes()	0	6	1
A	send()	0	8	2
A	pipe()	0	6	1
A	__invoke()	0	3	1
A	prepend()	0	6	1
A	clear()	0	3	1

<?php

namespace Bdf\Pipeline;

use Bdf\Pipeline\CallableFactory\StackCallableFactory;

/**
 * Pipeline
 *
 * @author Sébastien Tanneux
 */
final class Pipeline
{
    /**
     * The callable factory
     *
     * @var CallableFactoryInterface
     */
    private $factory;

    /**
     * The pipes
     *
     * @var callable[]
     */
    private $pipes = [];

    /**
     * The destination of the last pipe
     *
     * @var callable
     */
    private $outlet;

    /**
     * The built callable
     *
     * @var callable
     */
    private $callable;

    /**
     * Pipeline constructor.
     *
     * @param CallableFactoryInterface $factory
     */
    public function __construct(CallableFactoryInterface $factory = null)
    {
        $this->factory = $factory ?: new StackCallableFactory();
    }

    /**
     * Set the pipes
     *
     * @param callable[] $pipes
     *
     * @return $this
     */
    public function setPipes(array $pipes)
    {
        $this->clear();
        $this->pipes = $pipes;

        return $this;
    }

    /**
     * Add a pipe at the beginning of the chain
     *
     * @param callable $first
     *
     * @return $this
     */
    public function prepend($first)
    {
        $this->clear();
        array_unshift($this->pipes, $first);

        return $this;
    }

    /**
     * Add a pipe
     *
     * @param callable $last
     *
     * @return $this
     */
    public function pipe($last)
    {
        $this->clear();
        $this->pipes[] = $last;

        return $this;
    }

    /**
     * Set the pipeline outlet
     *
     * @param callable $outlet
     *
     * @return $this
     */
    public function outlet(callable $outlet)
    {
        $this->clear();
        $this->outlet = $outlet;

        return $this;
    }

    /**
     * Send the payload into the pipeline.
     *
     * @param array $payload
     *
     * @return mixed
     */
    public function send(...$payload)
    {
        if ($this->callable === null) {
            $this->callable = $this->factory->createCallable($this->pipes, $this->outlet);
        }

        $callable = $this->callable;
        return $callable(...$payload);
    }

    /**
     * Pipeline invokation
     *
     * @param array $payload
     *
     * @return mixed
     */
    public function __invoke(...$payload)
    {
        return $this->factory->callPipeline($this, $payload);
    }

    /**
     * Clear the callable
     */
    public function __clone()
    {
        $this->clear();
    }

    /**
     * Clear the callable
     */
    private function clear()
    {
        $this->callable = null;
    }
}