NotificationCompilerPass::process() - Code Metrics - sonata-project/SonataNotificationBundle - Measure and Improve Code Quality continuously with Scrutinizer

NotificationCompilerPass::process() B
last analyzed 2020-08-28 02:03 UTC

↳ Parent: NotificationCompilerPass

Complexity

Conditions	9
Paths	18

Size

Total Lines

Duplication

Lines	0
Ratio	0 %

Importance

Changes

Metric	Value
dl	0
loc	62
rs	7.2735
c	0
b	0
f	0
cc	9
nc	18
nop	1

How to fix Long Method

<?php

declare(strict_types=1);

/*
 * This file is part of the Sonata Project package.
 *
 * (c) Thomas Rabaix <[email protected]>
 *
 * For the full copyright and license information, please view the LICENSE
 * file that was distributed with this source code.
 */

namespace Sonata\NotificationBundle\DependencyInjection\Compiler;

use Sonata\NotificationBundle\Event\IterateEvent;
use Sonata\NotificationBundle\Event\IterationListener;
use Symfony\Component\DependencyInjection\Argument\ServiceClosureArgument;
use Symfony\Component\DependencyInjection\Compiler\CompilerPassInterface;
use Symfony\Component\DependencyInjection\ContainerBuilder;
use Symfony\Component\DependencyInjection\Exception\RuntimeException;
use Symfony\Component\DependencyInjection\Reference;

class NotificationCompilerPass implements CompilerPassInterface
{
    /**
     * {@inheritdoc}
     */
    public function process(ContainerBuilder $container): void
    {
        if (!$container->hasDefinition('sonata.notification.dispatcher')) {
            return;
        }

        $definition = $container->getDefinition('sonata.notification.dispatcher');

        $informations = [];

        foreach ($container->findTaggedServiceIds('sonata.notification.consumer') as $id => $events) {
            $container->getDefinition($id)->setPublic(true);

            foreach ($events as $event) {
                $priority = $event['priority'] ?? 0;

                if (!isset($event['type'])) {
                    throw new \InvalidArgumentException(sprintf(
                        'Service "%s" must define the "type" attribute on "sonata.notification" tags.',
                        $id
                    ));
                }

                if (!isset($informations[$event['type']])) {
                    $informations[$event['type']] = [];
                }

                $informations[$event['type']][] = $id;

                $definition->addMethodCall(
                    'addListener',
                    [
                        $event['type'],
                        [new ServiceClosureArgument(new Reference($id)), 'process'],
                        $priority,
                    ]
                );
            }
        }

        $container->getDefinition('sonata.notification.consumer.metadata')->replaceArgument(0, $informations);

        if ($container->getParameter('sonata.notification.event.iteration_listeners')) {
            $ids = $container->getParameter('sonata.notification.event.iteration_listeners');

            foreach ($ids as $serviceId) {
                $definition = $container->getDefinition($serviceId);

                $class = new \ReflectionClass($definition->getClass());
                if (!$class->implementsInterface(IterationListener::class)) {
                    throw new RuntimeException(
                        'Iteration listeners must implement Sonata\NotificationBundle\Event\IterationListener'
                    );
                }

                $definition->addTag(
                    'kernel.event_listener',
                    ['event' => IterateEvent::EVENT_NAME, 'method' => 'iterate']
                );
            }
        }
    }
}


1			<?php
2
3			declare(strict_types=1);
4
5			/*
6			* This file is part of the Sonata Project package.
7			*
8			* (c) Thomas Rabaix <[email protected]>
9			*
10			* For the full copyright and license information, please view the LICENSE
11			* file that was distributed with this source code.
12			*/
13
14			namespace Sonata\NotificationBundle\DependencyInjection\Compiler;
15
16			use Sonata\NotificationBundle\Event\IterateEvent;
17			use Sonata\NotificationBundle\Event\IterationListener;
18			use Symfony\Component\DependencyInjection\Argument\ServiceClosureArgument;
19			use Symfony\Component\DependencyInjection\Compiler\CompilerPassInterface;
20			use Symfony\Component\DependencyInjection\ContainerBuilder;
21			use Symfony\Component\DependencyInjection\Exception\RuntimeException;
22			use Symfony\Component\DependencyInjection\Reference;
23
24			class NotificationCompilerPass implements CompilerPassInterface
25			{
26			/**
27			* {@inheritdoc}
28			*/
29			public function process(ContainerBuilder $container): void
30			{
31			if (!$container->hasDefinition('sonata.notification.dispatcher')) {
32			return;
33			}
34
35			$definition = $container->getDefinition('sonata.notification.dispatcher');
36
37			$informations = [];
38
39			foreach ($container->findTaggedServiceIds('sonata.notification.consumer') as $id => $events) {
40			$container->getDefinition($id)->setPublic(true);
41
42			foreach ($events as $event) {
43			$priority = $event['priority'] ?? 0;
44
45			if (!isset($event['type'])) {
46			throw new \InvalidArgumentException(sprintf(
47			'Service "%s" must define the "type" attribute on "sonata.notification" tags.',
48			$id
49			));
50			}
51
52			if (!isset($informations[$event['type']])) {
53			$informations[$event['type']] = [];
54			}
55
56			$informations[$event['type']][] = $id;
57
58			$definition->addMethodCall(
59			'addListener',
60			[
61			$event['type'],
62			[new ServiceClosureArgument(new Reference($id)), 'process'],
63			$priority,
64			]
65			);
66			}
67			}
68
69			$container->getDefinition('sonata.notification.consumer.metadata')->replaceArgument(0, $informations);
70
71			if ($container->getParameter('sonata.notification.event.iteration_listeners')) {
72			$ids = $container->getParameter('sonata.notification.event.iteration_listeners');
73
74			foreach ($ids as $serviceId) {
75			$definition = $container->getDefinition($serviceId);
76
77			$class = new \ReflectionClass($definition->getClass());
78			if (!$class->implementsInterface(IterationListener::class)) {
79			throw new RuntimeException(
80			'Iteration listeners must implement Sonata\NotificationBundle\Event\IterationListener'
81			);
82			}
83
84			$definition->addTag(
85			'kernel.event_listener',
86			['event' => IterateEvent::EVENT_NAME, 'method' => 'iterate']
87			);
88			}
89			}
90			}
91			}
92

sonata-project / SonataNotificationBundle

NotificationCompilerPass::process() B last analyzed 2020-08-28 02:03 UTC

Complexity

Size

Duplication

Importance

How to fix Long Method

Long Method

Duplication Side-by-Side

Filter issues like

NotificationCompilerPass::process() B
last analyzed 2020-08-28 02:03 UTC