SRIO\ChainOfResponsibility\ChainRunner

Complexity

Total Complexity

8

Size/Duplication

Total Lines	62
Duplicated Lines	0 %

Coupling/Cohesion

Components	1
Dependencies	5

Test Coverage

Coverage

100%

Importance

Changes

0

4 Methods

Rating	Name	Duplication	Size	Complexity
A	__construct()	0	5	2
A	run()	0	10	2
A	getHead()	0	4	1
A	getDecoratedProcesses()	0	17	3

<?php

namespace SRIO\ChainOfResponsibility;

class ChainRunner extends ProcessCollection
{
    /**
     * @var DecoratorFactoryInterface
     */
    private $decoratorFactory;

    /**
     * @param ChainProcessInterface[]        $processes
     * @param DecoratorFactoryInterface|null $decoratorFactory
     */
    public function __construct(array $processes, DecoratorFactoryInterface $decoratorFactory = null)
    {
        $this->decoratorFactory = $decoratorFactory !== null ? $decoratorFactory : new DecoratorFactory();
        $this->add($processes);
    }

    /**
     * @param ChainContext $context
     *
     * @return ChainContext
     */
    public function run(ChainContext $context = null)
    {
        if (null === $context) {
            $context = new ArrayChainContext();
        }

        $this->getHead()->execute($context);

        return $context;
    }

    /**
     * @return ChainProcessInterface
     */
    public function getHead()
    {
        return $this->getDecoratedProcesses()[0];
    }

    /**
     * @return ChainProcessInterface[]
     */
    public function getDecoratedProcesses()
    {
        $processes = $this->getProcesses();
        $numberOfProcesses = count($processes);
        if ($numberOfProcesses === 0) {
            throw new \RuntimeException('You must have at least one process to run');
        }

        $decoratedProcesses = [];
        $next = null;

        for ($i = $numberOfProcesses - 1; $i >= 0; --$i) {
            $decoratedProcesses[$i] = $next = $this->decoratorFactory->decorate($processes[$i], $next);
        }

        return $decoratedProcesses;
    }
}