Mleko\Narrator\Bundle\DependencyInjection\Configuration\EventBusConfiguration

Complexity

Total Complexity

8

Size/Duplication

Total Lines	46
Duplicated Lines	0 %

Coupling/Cohesion

Components	0
Dependencies	3

Test Coverage

Coverage

95.65%

Importance

Changes

0

2 Methods

Rating	Name	Duplication	Size	Complexity
A	configureEventBus()	0	22	3
B	buildResolver()	0	16	5

<?php


namespace Mleko\Narrator\Bundle\DependencyInjection\Configuration;


use Mleko\Narrator\BasicEventBus;
use Mleko\Narrator\ListenerResolver\InstanceOfResolver;
use Mleko\Narrator\ListenerResolver\NameBasedResolver;
use Symfony\Component\DependencyInjection\ContainerBuilder;
use Symfony\Component\DependencyInjection\Definition;
use Symfony\Component\DependencyInjection\Reference;

class EventBusConfiguration
{
    /**
     * @param $buses
     * @param ContainerBuilder $container
     */
    public function configureEventBus($buses, ContainerBuilder $container)
    {
        foreach ($buses as $busName => $busConfig) {
            $resolverServiceId = "narrator.event_bus.$busName.resolver";
            $resolverConfig = isset($busConfig['resolver']) ? $busConfig['resolver'] : [];
            $container->setDefinition(
                $resolverServiceId,
                $this->buildResolver($resolverConfig)

It seems like $this->buildResolver($resolverConfig) targeting Mleko\Narrator\Bundle\DependencyInjection\Configuration\EventBusConfiguration::buildResolver() can also be of type object<Symfony\Component\DependencyInjection\Reference>; however, Symfony\Component\DependencyInjection\ContainerBuilder::setDefinition() does only seem to accept object<Symfony\Component\DependencyInjection\Definition>, maybe add an additional type check?

            );

            $container->setDefinition(
                "narrator.event_bus.$busName",
                new Definition(
                    BasicEventBus::class,
                    [
                        new Reference($resolverServiceId),
                        []
                    ]
                )
            );
        }
    }

    private function buildResolver($resolverConfig)
    {
        $resolverType = isset($resolverConfig['type']) ? $resolverConfig['type'] : 'name';
        switch ($resolverType) {
            case 'instanceof':
                return new Definition(InstanceOfResolver::class);
            case 'service':
                return new Reference($resolverType['service_id']);
            default:
                $nameExtractorId = isset($resolverConfig['name_extractor']) ? $resolverConfig['name_extractor'] : "narrator.name_extractor.class_name";
                return new Definition(
                    NameBasedResolver::class,
                    [new Reference($nameExtractorId)]
                );
        }
    }
}