Kreta\SharedKernel\Infrastructure\Event\SimpleBus\EventRecorder\Doctrine\ORM\AggregateRootEventRecorder

Complexity

Total Complexity

10

Size/Duplication

Total Lines	56
Duplicated Lines	0 %

Coupling/Cohesion

Components	1
Dependencies	2

Importance

Changes

0

8 Methods

Rating	Name	Duplication	Size	Complexity
A	__construct()	0	4	1
A	getSubscribedEvents()	0	8	1
A	postPersist()	0	4	1
A	postUpdate()	0	4	1
A	postRemove()	0	4	1
A	recordedMessages()	0	4	1
A	eraseMessages()	0	4	1
A	collectEventsFromAggregateRoot()	0	12	3

<?php

/*
 * This file is part of the Kreta package.
 *
 * (c) Beñat Espiña <benatespina@gmail.com>
 * (c) Gorka Laucirica <gorka.lauzirika@gmail.com>
 *
 * For the full copyright and license information, please view the LICENSE
 * file that was distributed with this source code.
 */

declare(strict_types=1);

namespace Kreta\SharedKernel\Infrastructure\Event\SimpleBus\EventRecorder\Doctrine\ORM;

use Doctrine\Common\EventSubscriber;
use Doctrine\ORM\Event\LifecycleEventArgs;
use Doctrine\ORM\Events;
use Kreta\SharedKernel\Domain\Model\AggregateRoot;
use SimpleBus\Message\Recorder\ContainsRecordedMessages;

class AggregateRootEventRecorder implements EventSubscriber, ContainsRecordedMessages
{
    private $collectedEvents;

    public function __construct()
    {
        $this->collectedEvents = [];
    }

    public function getSubscribedEvents() : array
    {
        return [
            Events::postPersist,
            Events::postUpdate,
            Events::postRemove,
        ];
    }

    public function postPersist(LifecycleEventArgs $event)
    {
        $this->collectEventsFromAggregateRoot($event);
    }

    public function postUpdate(LifecycleEventArgs $event)
    {
        $this->collectEventsFromAggregateRoot($event);
    }

    public function postRemove(LifecycleEventArgs $event)
    {
        $this->collectEventsFromAggregateRoot($event);
    }

    public function recordedMessages() : array
    {
        return $this->collectedEvents;
    }

    public function eraseMessages()
    {
        $this->collectedEvents = [];
    }

    private function collectEventsFromAggregateRoot(LifecycleEventArgs $event)
    {
        $entity = $event->getEntity();

        if ($entity instanceof AggregateRoot) {
            foreach ($entity->recordedEvents() as $event) {
                $this->collectedEvents[] = $event;
            }

            $entity->clearEvents();
        }
    }
}