Dsantang\DomainEventsDoctrine\EventsRecorder\DoctrineEventsRecorder

Complexity

Total Complexity

4

Size/Duplication

Total Lines	35
Duplicated Lines	0 %

Test Coverage

Coverage

100%

Importance

Changes	1
Bugs	0	Features	0

3 Methods

Rating	Name	Duplication	Size	Complexity
A	__construct()	0	3	1
A	onFlush()	0	12	2
A	getEventAwareEntities()	0	9	1

<?php

declare(strict_types=1);

namespace Dsantang\DomainEventsDoctrine\EventsRecorder;

use Doctrine\ORM\Event\OnFlushEventArgs;
use Doctrine\ORM\UnitOfWork;
use Dsantang\DomainEvents\EventAware;
use Dsantang\DomainEventsDoctrine\Aggregator;

use function array_filter;
use function array_merge;

/**
 * Doctrine's listener in charge of staging the domain events before the flush operation is completed.
 */
final class DoctrineEventsRecorder
{
    private Aggregator $eventAggregator;

    public function __construct(Aggregator $eventAggregator)
    {
        $this->eventAggregator = $eventAggregator;
    }

    public function onFlush(OnFlushEventArgs $eventArgs): void
    {
        $unitOfWork = $eventArgs->getEntityManager()

The function Doctrine\ORM\Event\OnFlushEventArgs::getEntityManager() has been deprecated: 2.13. Use {@see getObjectManager} instead.

                                ->getUnitOfWork();

        $events = [];

        foreach (self::getEventAwareEntities($unitOfWork) as $entity) {
            $events = array_merge($events, $entity->expelRecordedEvents());
        }

        $this->eventAggregator->aggregate(...$events);
    }

    /**
     * @return EventAware[]
     */
    private static function getEventAwareEntities(UnitOfWork $unitOfWork): array
    {
        $entities = array_merge(
            $unitOfWork->getScheduledEntityInsertions(),
            $unitOfWork->getScheduledEntityUpdates(),
            $unitOfWork->getScheduledEntityDeletions()
        );

        return array_filter($entities, static fn ($entity): bool => $entity instanceof EventAware);
    }
}