eXpansion\Framework\Core\Services\Application\Dispatcher

Complexity

Total Complexity

8

Size/Duplication

Total Lines	89
Duplicated Lines	0 %

Coupling/Cohesion

Components	1
Dependencies	4

Test Coverage

Coverage

48.15%

Importance

Changes

0

5 Methods

Rating	Name	Duplication	Size	Complexity
A	__construct()	0	5	1
A	init()	0	13	2
A	reset()	0	5	1
A	addEventProcessor()	0	4	1
A	dispatch()	0	12	3

<?php

namespace eXpansion\Framework\Core\Services\Application;

use eXpansion\Framework\Core\Services\DataProviderManager;
use eXpansion\Framework\Core\Services\PluginManager;
use Maniaplanet\DedicatedServer\Connection;
use Maniaplanet\DedicatedServer\Structures\Map;

/**
 * Class Dispatcher, dispatches events to the Data Providers.
 *
 * @package eXpansion\Framework\Core\Services\Application
 * @author Oliver de Cramer
 */
class Dispatcher implements DispatcherInterface
{
    /** @var DataProviderManager  */
    protected $dataProviderManager;

    /** @var PluginManager */
    protected $pluginManager;

    /** @var EventProcessorInterface[] */
    protected $eventProcessors = [];

    /** @var bool  */
    protected $isInitialized = false;

    protected $temporizedEvents = [];

    /**
     * Dispatcher constructor.
     *
     * @param DataProviderManager $dataProviderManager
     * @param PluginManager $pluginManager
     */
    public function __construct(DataProviderManager $dataProviderManager, PluginManager $pluginManager)
    {
        $this->dataProviderManager = $dataProviderManager;
        $this->pluginManager = $pluginManager;
    }

    /**
     * @inheritdoc
     */
    public function init(Connection $connection)
    {
        $map = $connection->getCurrentMapInfo();

        $this->pluginManager->init($map);
        $this->dataProviderManager->reset($this->pluginManager, $map);
        $this->isInitialized = true;

        foreach ($this->temporizedEvents as $temporizedEvent) {
            $this->dispatch($temporizedEvent['event'], $temporizedEvent['params']);
        }
        $this->temporizedEvents = [];
    }

    /**
     * Reset when game mode changes.
     */
    /**
     * Reset the dispatcher elements when game mode changes.
     *
     * @param Map $map Current map.
     *
     * @return void
     *
     * @throws
     */
    public function reset(Map $map)
    {
        $this->pluginManager->reset($map);
        $this->dataProviderManager->reset($this->pluginManager, $map);
    }

    /**
     * Add a processor of events.
     *
     * @param EventProcessorInterface $eventProcessor
     */
    public function addEventProcessor(EventProcessorInterface $eventProcessor)
    {
        $this->eventProcessors[] = $eventProcessor;
    }

    /**
     * @inheritdoc
     */
    public function dispatch($event, $params)
    {
        foreach ($this->eventProcessors as $eventProcessor) {
            $eventProcessor->dispatch($event, $params);
        }

        if ($this->isInitialized) {
            $this->dataProviderManager->dispatch($event, $params);
        } else {
            $this->temporizedEvents[] = ['event' => $event, 'params' => $params];
        }
    }
}