PHPMessageBus / messagebus

use NilPortugues\MessageBus\CommandBus\Contracts\Command;

use NilPortugues\MessageBus\CommandBus\Contracts\CommandBusMiddleware as CommandBusMiddlewareInterface;

class CommandBus implements CommandBusMiddlewareInterface

{

    /** @var callable[] */

    protected $middleware = [];

    /**

     * StackedCommandBus constructor.

     *

     * @param callable[] $middleware

     */

    public function __construct(array $middleware = [])

    {

        foreach ($middleware as $commandBusMiddleware) {

            Assert::isInstanceOf($commandBusMiddleware, CommandBusMiddlewareInterface::class);

        }

        $this->middleware = $middleware;

    }

    /**

     * @param Command       $command

     * @param callable|null $next

     */

    public function __invoke(Command $command, callable $next = null)

    {

        $middleware = $this->middleware;

        $current = array_shift($middleware);

        if (empty($middleware) && !empty($current)) {

            $current->__invoke($command);

            return;

        }

        foreach ($middleware as $commandBusMiddleware) {

            $callable = function ($command) use ($commandBusMiddleware) {

                return $commandBusMiddleware($command);

            };

            $current->__invoke($command, $callable);

            $current = $commandBusMiddleware;

        }

    }

}

/**

 * Class EventBus.

 */

class EventBus implements EventBusMiddlewareInterface

{

    /** @var EventBusMiddleware[] */

    protected $middleware;

    /**

     * StackedEventBus constructor.

     *

     * @param array $middleware

     */

    public function __construct(array $middleware = [])

    {

        foreach ($middleware as $eventBusMiddleware) {

            Assert::isInstanceOf($eventBusMiddleware, EventBusMiddlewareInterface::class);

        }

        $this->middleware = $middleware;

    }

    /**

     * @param Event         $event

     * @param callable|null $next

     */

    public function __invoke(Event $event, callable $next = null)

    {

        $middleware = $this->middleware;

        $current = array_shift($middleware);

        if (empty($middleware) && !empty($current)) {

            $current->__invoke($event);

            return;

        }

        foreach ($middleware as $eventBusMiddleware) {

            $callable = function ($event) use ($eventBusMiddleware) {

                return $eventBusMiddleware($event);

            };

            $current->__invoke($event, $callable);

            $current = $eventBusMiddleware;

        }

    }

}