Gica\Cqrs\Event\EventSubscriber\EventSubscriberByMap

Complexity

Total Complexity

6

Size/Duplication

Total Lines	52
Duplicated Lines	0 %

Coupling/Cohesion

Components	1
Dependencies	1

Test Coverage

Coverage

100%

Importance

Changes

0

5 Methods

Rating	Name	Duplication	Size	Complexity
	getMap()	0	1	?
A	__construct()	0	6	1
A	createListenerByMethod()	0	4	1
A	createListenersByMethod()	0	10	2
A	getListenersForEvent()	0	10	2

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

namespace Gica\Cqrs\Event\EventSubscriber;


use Gica\Cqrs\Event\EventSubscriber;
use Gica\Dependency\AbstractFactory;

abstract class EventSubscriberByMap implements EventSubscriber
{
    abstract protected function getMap(): array;

    /** @var AbstractFactory */
    private $abstractFactory;

    public function __construct(
        AbstractFactory $abstractFactory
    )
    {
        $this->abstractFactory = $abstractFactory;
    }

    /**
     * @param array $listenerDescriptor
     * @return callable
     */
    private function createListenerByMethod(array $listenerDescriptor)
    {
        return [$this->abstractFactory->createObject($listenerDescriptor[0]), $listenerDescriptor[1]];
    }

    /**
     * @param array $listenersDescriptor
     * @return callable[]
     */
    private function createListenersByMethod(array $listenersDescriptor)
    {
        $result = [];

        foreach ($listenersDescriptor as $listenerDescriptor) {
            $result[] = $this->createListenerByMethod($listenerDescriptor);
        }

        return $result;
    }

    /**
     * @inheritdoc
     */
    public function getListenersForEvent($event)
    {
        $eventClass = get_class($event);

        if (isset($this->getMap()[$eventClass])) {
            return $this->createListenersByMethod($this->getMap()[$eventClass]);
        }

        return [];
    }
}