hiapi\middlewares\EventEmitterMiddleware

Complexity

Total Complexity

5

Size/Duplication

Total Lines	54
Duplicated Lines	0 %

Coupling/Cohesion

Components	1
Dependencies	4

Importance

Changes

0

3 Methods

Rating	Name	Duplication	Size	Complexity
A	__construct()	0	6	1
A	execute()	0	9	1
A	emitEvents()	0	12	3

<?php

namespace hiapi\middlewares;

use hiapi\event\EventStorageInterface;
use League\Event\EmitterInterface;
use League\Event\EventInterface;
use League\Tactician\Middleware;
use Psr\Log\LoggerInterface;

/**
 * Class EventEmitterMiddleware
 *
 * @author Dmytro Naumenko <d.naumenko.a@gmail.com>
 */
class EventEmitterMiddleware implements Middleware
{
    /**
     * @var \hiapi\event\EventStorageInterface
     */
    private $eventStorage;
    /**
     * @var EmitterInterface
     */
    private $emitter;
    /**
     * @var LoggerInterface
     */
    private $logger;

    public function __construct(EventStorageInterface $eventStorage, EmitterInterface $emitter, LoggerInterface $logger)
    {
        $this->eventStorage = $eventStorage;
        $this->emitter = $emitter;
        $this->logger = $logger;
    }

    /**
     * @param object $command
     * @param callable $next
     *
     * @return mixed
     */
    public function execute($command, callable $next)
    {
        $result = $next($command);

        $events = $this->eventStorage->release();
        $this->emitEvents($events);

        return $result;
    }

    /**
     * @param EventInterface[] $events
     */
    private function emitEvents(array $events = []): void
    {
        foreach ($events as $event) {
            try {
                $this->emitter->emit($event);
            } catch (\Exception $exception) {
                $this->logger->error("Failed to handle event {$event->getName()}: {$exception->getMessage()}", [
                    'exception' => $exception,
                ]);
            }
        }
    }
}