NotifiesDomainEvents::handle() - Code Metrics - hmlb/ddd-bundle - Measure and Improve Code Quality continuously with Scrutinizer

NotifiesDomainEvents::handle() A
last analyzed 2016-09-02 17:10 UTC

↳ Parent: NotifiesDomainEvents

Complexity

Conditions	2
Paths	2

Size

Total Lines	12
Code Lines	8

Duplication

Lines	0
Ratio	0 %

Importance

Changes	2
Bugs	0	Features	0

Metric	Value
c	2
b	0
f	0
dl	0
loc	12
rs	9.4285
cc	2
eloc	8
nc	2
nop	2

<?php

declare (strict_types = 1);

namespace HMLB\DDDBundle\MessageBus\Middleware;

use HMLB\DDDBundle\EventListener\CollectsEventsFromEntities;
use Psr\Log\LoggerInterface;
use SimpleBus\Message\Bus\MessageBus;
use SimpleBus\Message\Bus\Middleware\MessageBusMiddleware;

/**
 * NotifiesDomainEvents.
 *
 * @author Hugues Maignol <[email protected]>
 */
class NotifiesDomainEvents implements MessageBusMiddleware
{
    /**
     * @var MessageBus
     */
    private $eventBus;
    /**
     * @var CollectsEventsFromEntities
     */
    private $collectsEventsFromEntities;

    /**
     * @var LoggerInterface
     */
    private $logger;

    /**
     * @param LoggerInterface            $logger
     * @param MessageBus                 $eventBus
     * @param CollectsEventsFromEntities $collectsEventsFromEntities
     */
    public function __construct(
        LoggerInterface $logger,
        MessageBus $eventBus,
        CollectsEventsFromEntities $collectsEventsFromEntities
    ) {
        $this->logger = $logger;
        $this->eventBus = $eventBus;
        $this->collectsEventsFromEntities = $collectsEventsFromEntities;
    }

    /**
     * @param object   $message
     * @param callable $next
     */
    public function handle($message, callable $next)
    {
        $this->logger->debug('NotifiesDomainEvents calls next before collect events');
        $next($message);
        $events = $this->collectsEventsFromEntities->recordedMessages();
        $this->collectsEventsFromEntities->eraseMessages();

        $this->logger->debug('NotifiesDomainEvents notifies '.count($events).' events');
        foreach ($events as $event) {
            $this->eventBus->handle($event);
        }
    }
}


1			<?php
2
3			declare (strict_types = 1);
4
5			namespace HMLB\DDDBundle\MessageBus\Middleware;
6
7			use HMLB\DDDBundle\EventListener\CollectsEventsFromEntities;
8			use Psr\Log\LoggerInterface;
9			use SimpleBus\Message\Bus\MessageBus;
10			use SimpleBus\Message\Bus\Middleware\MessageBusMiddleware;
11
12			/**
13			* NotifiesDomainEvents.
14			*
15			* @author Hugues Maignol <[email protected]>
16			*/
17			class NotifiesDomainEvents implements MessageBusMiddleware
18			{
19			/**
20			* @var MessageBus
21			*/
22			private $eventBus;
23			/**
24			* @var CollectsEventsFromEntities
25			*/
26			private $collectsEventsFromEntities;
27
28			/**
29			* @var LoggerInterface
30			*/
31			private $logger;
32
33			/**
34			* @param LoggerInterface $logger
35			* @param MessageBus $eventBus
36			* @param CollectsEventsFromEntities $collectsEventsFromEntities
37			*/
38			public function __construct(
39			LoggerInterface $logger,
40			MessageBus $eventBus,
41			CollectsEventsFromEntities $collectsEventsFromEntities
42			) {
43			$this->logger = $logger;
44			$this->eventBus = $eventBus;
45			$this->collectsEventsFromEntities = $collectsEventsFromEntities;
46			}
47
48			/**
49			* @param object $message
50			* @param callable $next
51			*/
52			public function handle($message, callable $next)
53			{
54			$this->logger->debug('NotifiesDomainEvents calls next before collect events');
55			$next($message);
56			$events = $this->collectsEventsFromEntities->recordedMessages();
57			$this->collectsEventsFromEntities->eraseMessages();
58
59			$this->logger->debug('NotifiesDomainEvents notifies '.count($events).' events');
60			foreach ($events as $event) {
61			$this->eventBus->handle($event);
62			}
63			}
64			}
65

hmlb / ddd-bundle

NotifiesDomainEvents::handle() A last analyzed 2016-09-02 17:10 UTC

Complexity

Size

Duplication

Importance

Duplication Side-by-Side

Filter issues like

NotifiesDomainEvents::handle() A
last analyzed 2016-09-02 17:10 UTC