SmoothPhp\CommandBus\CommandBus

Complexity

Total Complexity

5

Size/Duplication

Total Lines	48
Duplicated Lines	0 %

Coupling/Cohesion

Components	1
Dependencies	2

Test Coverage

Coverage

93.33%

Importance

Changes

0

3 Methods

Rating	Name	Duplication	Size	Complexity
A	__construct()	0	4	1
A	execute()	0	6	1
A	generateMiddlewareCallChain()	0	17	3

<?php
namespace SmoothPhp\CommandBus;

use SmoothPhp\CommandBus\Exception\InvalidMiddlewareException;
use SmoothPhp\Contracts\CommandBus\Command;
use SmoothPhp\Contracts\CommandBus\CommandBusMiddleware;

/**
 * Class CommandBus
 * @package SmoothPhp\CommandBus
 * @author Simon Bennett <simon@bennett.im>
 */
final class CommandBus implements \SmoothPhp\Contracts\CommandBus\CommandBus
{
    /**
     * @var callable
     */
    private $middlewareChain;

    /**
     * CommandBus constructor.
     * @param CommandBusMiddleware[] $middleware
     */
    public function __construct(array $middleware)
    {
        $this->middlewareChain = $this->generateMiddlewareCallChain($middleware);
    }

    /**
     * @param Command $command
     */
    public function execute(Command $command)
    {
        $middlewareChain = $this->middlewareChain;

        return $middlewareChain($command);
    }

    /**
     * @param $middleware
     * @return \Closure
     */
    private function generateMiddlewareCallChain($middlewareList)
    {
        $lastCallable = function () {
            // the final callable does not run
        };

        while ($middleware = array_pop($middlewareList)) {
            if (!$middleware instanceof CommandBusMiddleware) {
                throw InvalidMiddlewareException::forMiddleware($middleware);
            }
            $lastCallable = function ($command) use ($middleware, $lastCallable) {
                return $middleware->execute($command, $lastCallable);
            };
        }

        return $lastCallable;
    }
}