Gica\Cqrs\Event\EventDispatcher\EventDispatcherBySubscriber

Complexity

Total Complexity

5

Size/Duplication

Total Lines	38
Duplicated Lines	0 %

Coupling/Cohesion

Components	1
Dependencies	3

Test Coverage

Coverage

100%

Importance

Changes

0

2 Methods

Rating	Name	Duplication	Size	Complexity
A	__construct()	0	8	1
A	dispatchEvent()	0	20	4

<?php
/******************************************************************************
 * Copyright (c) 2016 Constantin Galbenu <gica.galbenu@gmail.com>             *
 ******************************************************************************/

namespace Gica\Cqrs\Event\EventDispatcher;


use Gica\Cqrs\Event\EventDispatcher;
use Gica\Cqrs\Event\EventSubscriber;
use Gica\Cqrs\Event\EventWithMetaData;
use Psr\Log\LoggerInterface;

class EventDispatcherBySubscriber implements EventDispatcher
{
    /** @var EventSubscriber */
    private $eventSubscriber;

    /** @var LoggerInterface|null */
    private $logger;

    public function __construct(
        EventSubscriber $eventSubscriber,
        LoggerInterface $logger = null
    )
    {
        $this->eventSubscriber = $eventSubscriber;
        $this->logger = $logger;
    }

    public function dispatchEvent(EventWithMetaData $eventWithMetadata)
    {
        $listeners = $this->eventSubscriber->getListenersForEvent($eventWithMetadata->getEvent());

        foreach ($listeners as $listener) {
            try {
                call_user_func($listener, $eventWithMetadata->getEvent(), $eventWithMetadata->getMetaData());
            } catch (\Throwable $exception) {
                if ($this->logger) {
                    $this->logger->error(
                        sprintf(
                            "Dispatch event of type %s to %s failed: %s",
                            get_class($eventWithMetadata->getEvent()),
                            get_class($listener[0]),
                            $exception->getMessage()),
                        $exception->getTrace());
                }
            }
        }
    }
}