GpsLab\Bundle\DomainEvent\DependencyInjection\Compiler\EventListenerPass

Complexity

Total Complexity

8

Size/Duplication

Total Lines	32
Duplicated Lines	0 %

Coupling/Cohesion

Components	0
Dependencies	2

Test Coverage

Coverage

81.25%

Importance

Changes

0

1 Method

Rating	Name	Duplication	Size	Complexity
C	process()	0	26	8

<?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\Compiler;

use Symfony\Component\DependencyInjection\Compiler\CompilerPassInterface;
use Symfony\Component\DependencyInjection\ContainerBuilder;

class EventListenerPass implements CompilerPassInterface
{
    /**
     * @param ContainerBuilder $container
     */
    public function process(ContainerBuilder $container)
    {
        if (!$container->has('domain_event.locator')) {
            return;
        }

        $current_locator = $container->findDefinition('domain_event.locator');
        $symfony_locator = $container->findDefinition('domain_event.locator.symfony');
        $container_locator = $container->findDefinition('domain_event.locator.container');

        if ($current_locator !== $symfony_locator && $current_locator !== $container_locator) {
            return;
        }

        foreach ($container->findTaggedServiceIds('domain_event.listener') as $id => $attributes) {
            foreach ($attributes as $attribute) {
                $method = !empty($attribute['method']) ? $attribute['method'] : '__invoke';
                $current_locator->addMethodCall('registerService', [$attribute['event'], $id, $method]);
            }
        }

        foreach ($container->findTaggedServiceIds('domain_event.subscriber') as $id => $attributes) {
            $subscriber = $container->findDefinition($id);
            $current_locator->addMethodCall('registerSubscriberService', [$id, $subscriber->getClass()]);
        }
    }
}