EventSauce\EventSourcing\AggregateRootWithAggregates

Complexity

Total Complexity

10

Size/Duplication

Total Lines	57
Duplicated Lines	0 %

Importance

Changes	1
Bugs	0	Features	1

5 Methods

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

<?php

declare(strict_types=1);

namespace EventSauce\EventSourcing;

use SplObjectStorage;

trait AggregateRootWithAggregates
{
    use AggregateRootBehaviour, AggregateAppliesKnownEvents {
        AggregateAppliesKnownEvents::apply as applyOnAggregateRoot;
    }

    protected function eventRecorder(): EventRecorder
    {
        static $eventRecorder;

        if ($eventRecorder === null) {

            $eventRecorder = new EventRecorder(function(object $event) {
                $this->recordThat($event);
            });
        }

        return $eventRecorder;
    }

    /**
     * @var SplObjectStorage|null
     */
    private $aggregatesInsideRoot;

    private function aggregatesInsideRoot(): SplObjectStorage
    {
        if ($this->aggregatesInsideRoot instanceof SplObjectStorage) {
            return $this->aggregatesInsideRoot;
        }

        return $this->aggregatesInsideRoot = new SplObjectStorage();
    }

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

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

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

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