Antidot\EventSource\Infrastructure\Bus\TacticianDomainEventDispatcherMiddleware

Complexity

Total Complexity

3

Size/Duplication

Total Lines	19
Duplicated Lines	0 %

Test Coverage

Coverage

0%

Importance

Changes	1
Bugs	0	Features	0

2 Methods

Rating	Name	Duplication	Size	Complexity
A	execute()	0	10	2
A	__construct()	0	3	1

<?php

declare(strict_types=1);

namespace Antidot\EventSource\Infrastructure\Bus;

use Antidot\EventSource\Domain\Event\AggregateChanged;
use Antidot\EventSource\Domain\Event\DomainEventEmitter;
use League\Tactician\Middleware;
use Psr\EventDispatcher\EventDispatcherInterface;

class TacticianDomainEventDispatcherMiddleware implements Middleware
{
    private EventDispatcherInterface $dispatcher;

    public function __construct(EventDispatcherInterface $dispatcher)
    {
        $this->dispatcher = $dispatcher;
    }

    public function execute($command, callable $next)
    {
        /** @var mixed $result */
        $result = $next($command);
        /** @var AggregateChanged $event */
        foreach (DomainEventEmitter::emit() as $event) {
            $this->dispatcher->dispatch($event);
        }

        return $result;
    }
}