GpsLab\Bundle\DomainEvent\DependencyInjection\GpsLabDomainEventExtension

Complexity

Total Complexity

9

Size/Duplication

Total Lines	84
Duplicated Lines	0 %

Coupling/Cohesion

Components	1
Dependencies	7

Test Coverage

Coverage

100%

Importance

Changes

0

5 Methods

Rating	Name	Duplication	Size	Complexity
A	load()	0	27	2
A	busRealName()	0	8	2
A	queueRealName()	0	8	2
A	locatorRealName()	0	8	2
A	getAlias()	0	4	1

<?php
/**
 * GpsLab component.
 *
 * @author    Peter Gribanov <info@peter-gribanov.ru>
 * @copyright Copyright (c) 2016, Peter Gribanov
 * @license   http://opensource.org/licenses/MIT
 */

namespace GpsLab\Bundle\DomainEvent\DependencyInjection;

use GpsLab\Domain\Event\Bus\EventBus;
use GpsLab\Domain\Event\Listener\Subscriber;
use GpsLab\Domain\Event\Queue\EventQueue;
use Symfony\Component\Config\FileLocator;
use Symfony\Component\DependencyInjection\ContainerBuilder;
use Symfony\Component\DependencyInjection\Loader;
use Symfony\Component\HttpKernel\DependencyInjection\Extension;

class GpsLabDomainEventExtension extends Extension
{
    /**
     * @param array            $configs
     * @param ContainerBuilder $container
     */
    public function load(array $configs, ContainerBuilder $container)
    {
        $loader = new Loader\YamlFileLoader($container, new FileLocator(__DIR__.'/../Resources/config'));
        $loader->load('queue.yml');
        $loader->load('bus.yml');
        $loader->load('locator.yml');
        $loader->load('publisher.yml');

        $config = $this->processConfiguration(new Configuration(), $configs);

        $container->setAlias('domain_event.bus', $this->busRealName($config['bus']));
        $container->setAlias('domain_event.queue', $this->queueRealName($config['queue']));
        $container->setAlias('domain_event.locator', $this->locatorRealName($config['locator']));
        $container->setAlias(EventBus::class, $this->busRealName($config['bus']));
        $container->setAlias(EventQueue::class, $this->queueRealName($config['queue']));

        $container->getDefinition('domain_event.publisher')->replaceArgument(2, $config['publish_on_flush']);

        // subscribers tagged automatically
        if (method_exists($container, 'registerForAutoconfiguration')) {
            $container
                ->registerForAutoconfiguration(Subscriber::class)
                ->addTag('domain_event.subscriber')
                ->setAutowired(true)
            ;
        }
    }

    /**
     * @param string $name
     *
     * @return string
     */
    private function busRealName($name)
    {
        if (in_array($name, ['listener_located', 'queue'])) {
            return 'domain_event.bus.'.$name;
        }

        return $name;
    }

    /**
     * @param string $name
     *
     * @return string
     */
    private function queueRealName($name)
    {
        if (in_array($name, ['pull_memory', 'subscribe_executing'])) {
            return 'domain_event.queue.'.$name;
        }

        return $name;
    }

    /**
     * @param string $name
     *
     * @return string
     */
    private function locatorRealName($name)
    {
        if (in_array($name, ['direct_binding', 'container', 'symfony'])) {
            return 'domain_event.locator.'.$name;
        }

        return $name;
    }

    /**
     * @return string
     */
    public function getAlias()
    {
        return 'gpslab_domain_event';
    }
}