HMLB\DDDBundle\MessageBus\Middleware\MonitorsDomainEvents

Complexity

Total Complexity

3

Size/Duplication

Total Lines	47
Duplicated Lines	0 %

Coupling/Cohesion

Components	1
Dependencies	3

Importance

Changes	1
Bugs	0	Features	0

2 Methods

Rating	Name	Duplication	Size	Complexity
A	__construct()	0	7	1
A	handle()	0	16	2

<?php

namespace HMLB\DDDBundle\MessageBus\Middleware;

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

/**
 * This subscribers throws an exception if DomainEvents have been collected and will not be notified.
 *
 * It should have High priority to check for Events after all Notifiers like "NotifiesDomainEvents" have been called.
 *
 * @author Hugues Maignol <hugues@hmlb.fr>
 */
class MonitorsDomainEvents implements MessageBusMiddleware
{
    /**
     * @var CollectsEventsFromEntities
     */
    private $collectsEventsFromEntities;

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

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

    /**
     * @param object   $message
     * @param callable $next
     *
     * @throws Exception
     */
    public function handle($message, callable $next)
    {
        $next($message);
        $events = $this->collectsEventsFromEntities->recordedMessages();
        $count = count($events);
        $this->logger->debug('MonitorsDomainEvents saw '.$count.' events');

        if ($count) {
            throw new Exception(
                sprintf(
                    '%s Domain Events have been collected but will not be notified.
                    You should not raise domain event during the handling of a Event message but only for a Command.'
                )
            );
        }
    }
}