Enqueue\SimpleBus\Bridge\Symfony\Bundle\DependencyInjection\Configuration

Complexity

Total Complexity

2

Size/Duplication

Total Lines	51
Duplicated Lines	0 %

Importance

Changes

0

2 Methods

Rating	Name	Duplication	Size	Complexity
A	getConfigTreeBuilder()	0	13	1
A	messagesNode()	0	31	1

<?php

declare(strict_types=1);

namespace Enqueue\SimpleBus\Bridge\Symfony\Bundle\DependencyInjection;

use Symfony\Component\Config\Definition\Builder\ArrayNodeDefinition;
use Symfony\Component\Config\Definition\Builder\TreeBuilder;
use Symfony\Component\Config\Definition\ConfigurationInterface;

class Configuration implements ConfigurationInterface
{
    public const TYPE_COMMANDS = 'commands';
    public const TYPE_EVENTS = 'events';

    public function getConfigTreeBuilder(): TreeBuilder
    {
        $treeBuilder = new TreeBuilder('enqueue_simple_bus');

        $rootNode = $treeBuilder->getRootNode();
        $rootNode
            ->children()
                ->append($this->messagesNode(self::TYPE_COMMANDS))
                ->append($this->messagesNode(self::TYPE_EVENTS))
            ->end()
        ;

        return $treeBuilder;
    }

    private function messagesNode(string $type): ArrayNodeDefinition
    {
        return (new ArrayNodeDefinition($type))
            ->beforeNormalization()
                ->ifString()
                ->then(function (string $config): array {
                    return ['default_queue' => $config, 'enabled' => true];
                })
            ->end()
            ->canBeEnabled()

The method canBeEnabled() does not exist on Symfony\Component\Config\Definition\Builder\NodeDefinition. It seems like you code against a sub-type of Symfony\Component\Config\Definition\Builder\NodeDefinition such as Symfony\Component\Config\Definition\Builder\ArrayNodeDefinition.

            ->children()
                ->scalarNode('transport_name')
                    ->cannotBeEmpty()
                    ->defaultValue('default')
                ->end()
                ->scalarNode('default_queue')
                    ->cannotBeEmpty()
                    ->defaultValue(sprintf('asynchronous_%s', $type))
                ->end()
                ->scalarNode('processor_service_id')
                    ->cannotBeEmpty()
                    ->defaultValue(sprintf('enqueue.simple_bus.%s_processor', $type))
                ->end()
                ->arrayNode('queue_map')
                    ->requiresAtLeastOneElement()
                    ->useAttributeAsKey(true)
                    ->scalarPrototype()
                        ->isRequired()
                    ->end()
                ->end()
            ->end()
        ;
    }
}