queue-manager-bundle/src/Mcfedr/QueueManagerBundle/DependencyInjection/Configuration.php at a417eb332ffb51a11f1e9ce21b77a796d27cfd73 · mcfedr/queue-manager-bundle · GitHub

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
<?php

declare(strict_types=1);

namespace Mcfedr\QueueManagerBundle\DependencyInjection;

use Mcfedr\QueueManagerBundle\Controller\PubSubController;
use Symfony\Component\Config\Definition\Builder\TreeBuilder;
use Symfony\Component\Config\Definition\ConfigurationInterface;

class Configuration implements ConfigurationInterface
{
    public function getConfigTreeBuilder(): TreeBuilder
    {
        $treeBuilder = new TreeBuilder('mcfedr_queue_manager');
        $rootNode = $treeBuilder->getRootNode();
        $rootNode
            ->children()
            ->integerNode('retry_limit')->defaultValue(3)->end()
            ->integerNode('sleep_seconds')->defaultValue(5)->end()
            ->booleanNode('report_memory')->defaultFalse()->end()
            ->booleanNode('doctrine_reset')->defaultTrue()->end()
            ->integerNode('swift_mailer_batch_size')->defaultValue(10)->end()
            ->arrayNode('drivers')
            ->requiresAtLeastOneElement()
            ->useAttributeAsKey('name')
            ->arrayPrototype()
            ->children()
            ->scalarNode('class')->isRequired()->cannotBeEmpty()->end()
            ->scalarNode('command_class')->end()
            ->variableNode('options')->end()
            ->end()
            ->end()
            ->end()
            ->arrayNode('managers')
            ->requiresAtLeastOneElement()
            ->useAttributeAsKey('name')
            ->arrayPrototype()
            ->addDefaultsIfNotSet()
            ->children()
            ->scalarNode('driver')->cannotBeEmpty()->end()
            ->arrayNode('options')
            ->children()
            // Generic
            ->scalarNode('host')->end()
            ->integerNode('port')->end()
            ->scalarNode('default_queue')->end()
            //Beanstalk
            ->arrayNode('connection')
            ->children()
            ->integerNode('timeout')->end()
            ->booleanNode('persistent')->end()
            ->end()
            ->end()
            ->scalarNode('pheanstalk')->end()
            //Doctrine Delay
            ->scalarNode('entity_manager')->end()
            ->scalarNode('default_manager')->end()
            ->variableNode('default_manager_options')->end()
            //SQS
            ->arrayNode('queues')
            ->scalarPrototype()->end()
            ->end()
            ->scalarNode('default_url')->end()
            ->scalarNode('region')->end()
            ->variableNode('credentials')->end()
            ->scalarNode('sqs_client')->end()
            //Pub/Sub
            ->arrayNode('pub_sub_queues')
            ->arrayPrototype()
            ->children()
            ->scalarNode('topic')->end()
            ->scalarNode('subscription')->end()
            ->scalarNode('audience')->defaultValue(PubSubController::DEFAULT_AUDIENCE)->end()
            ->end()
            ->end()
            ->end()
            ->variableNode('projectId')->end()
            ->scalarNode('default_subscription')->end()
            ->scalarNode('default_topic')->end()
            ->scalarNode('pub_sub_client')->end()
            ->scalarNode('key_file_path')->end()
            // Periodic
            ->scalarNode('delay_manager')->end()
            ->variableNode('delay_manager_options')->end()
            ->end()
            ->end()
            ->end()
            ->end()
            ->end()
            ->end()
        ;

        return $treeBuilder;
    }
}