Antidot\EventSource\Domain\Model\Aggregate\AggregateRoot

Complexity

Total Complexity

7

Size/Duplication

Total Lines	46
Duplicated Lines	0 %

Test Coverage

Coverage

0%

Importance

Changes	1
Bugs	0	Features	0

5 Methods

Rating	Name	Duplication	Size	Complexity
A	popEvents()	0	14	2
A	aggregateId()	0	3	1
A	recordThat()	0	4	1
A	__construct()	0	3	1
A	apply()	0	8	2

<?php

declare(strict_types=1);

namespace Antidot\EventSource\Domain\Model\Aggregate;

use Antidot\EventSource\Domain\Event\AggregateChanged;
use Antidot\EventSource\Domain\Event\DomainEventEmitter;
use Antidot\EventSource\Domain\Event\EventCollection;

abstract class AggregateRoot
{
    public const EVENT_MAP = [];
    protected array $events;
    protected string $aggregateId;

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

    public function aggregateId(): string
    {
        return $this->aggregateId;
    }

    protected function recordThat(AggregateChanged $occur): void
    {
        $this->events[] = $occur;
        DomainEventEmitter::recordThat($occur);
    }

    public function popEvents(): EventCollection
    {
        $appliedEvents = [];
        /**
         * @var int $key
         * @var AggregateChanged $event
         */
        foreach ($this->events as $key => $event) {
            $this->apply($event);
            unset($this->events[$key]);
            $appliedEvents[] = $event;
        }

        return EventCollection::createImmutableCollection($appliedEvents);
    }

    public function apply(AggregateChanged $aggregateChanged): void
    {
        /** @var array<string, string>  */
        $eventMap = static::EVENT_MAP;
        $eventClass = get_class($aggregateChanged);
        if (array_key_exists($eventClass, $eventMap)) {
            $method = $eventMap[$eventClass];
            $this->{$method}($aggregateChanged);
        }
    }
}