EventSauce\EventSourcing\AggregateRootWithAggregates

Complexity

Total Complexity

10

Size/Duplication

Total Lines	54
Duplicated Lines	0 %

Importance

Changes	3
Bugs	0	Features	1

5 Methods

Rating	Name	Duplication	Size	Complexity
A	apply()	0	7	2
A	unregisterAggregate()	0	4	2
A	registerAggregate()	0	4	2
A	eventRecorder()	0	7	2
A	aggregatesInsideRoot()	0	7	2

<?php

declare(strict_types=1);

namespace EventSauce\EventSourcing;

use SplObjectStorage;

/**
 * @template T of EventSourcedAggregate
 */
trait AggregateRootWithAggregates
{
    use AggregateRootBehaviour, AggregateAppliesKnownEvents {
        AggregateAppliesKnownEvents::apply as applyOnAggregateRoot;
    }

    /**
     * @var ?SplObjectStorage<T>
     */
    private ?SplObjectStorage $aggregatesInsideRoot = null;
    private ?EventRecorder $eventRecorder = null;

    protected function eventRecorder(): EventRecorder
    {
        if (null === $this->eventRecorder) {
            $this->eventRecorder = new EventRecorder(fn (object $event) => $this->recordThat($event));
        }

        return $this->eventRecorder;
    }

    /**
     * @return SplObjectStorage<T>
     */
    private function aggregatesInsideRoot(): SplObjectStorage
    {
        if (null === $this->aggregatesInsideRoot) {
            $this->aggregatesInsideRoot = new SplObjectStorage();
        }

        return $this->aggregatesInsideRoot;
    }

    private function registerAggregate(?EventSourcedAggregate $aggregate): void
    {
        if ($aggregate instanceof EventSourcedAggregate) {
            $this->aggregatesInsideRoot()->attach($aggregate);
        }
    }

    private function unregisterAggregate(?EventSourcedAggregate $aggregate): void
    {
        if ($aggregate instanceof EventSourcedAggregate) {
            $this->aggregatesInsideRoot()->detach($aggregate);
        }
    }

    protected function apply(object $event): void
    {
        $this->applyOnAggregateRoot($event);

        /** @var EventSourcedAggregate $aggregate */
        foreach ($this->aggregatesInsideRoot() as $aggregate) {
            $aggregate->apply($event);
        }
    }
}