AggregateRoot::popEvents() - Code Metrics - antidot-framework/event-sourcing - Measure and Improve Code Quality continuously with Scrutinizer

AggregateRoot::popEvents() A
last analyzed 2022-08-31 16:13 UTC

↳ Parent: AggregateRoot

Complexity

Conditions	2
Paths	2

Size

Total Lines	14
Code Lines	6

Duplication

Lines	0
Ratio	0 %

Code Coverage

Tests	0
CRAP Score	6

Importance

Changes	1
Bugs	0	Features	0

Metric	Value
cc	2
eloc	6
c	1
b	0
f	0
nc	2
nop	0
dl	0
loc	14
ccs	0
cts	7
cp	0
crap	6
rs	10

<?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);
        }
    }
}


1			<?php
2
3			declare(strict_types=1);
4
5			namespace Antidot\EventSource\Domain\Model\Aggregate;
6
7			use Antidot\EventSource\Domain\Event\AggregateChanged;
8			use Antidot\EventSource\Domain\Event\DomainEventEmitter;
9			use Antidot\EventSource\Domain\Event\EventCollection;
10
11			abstract class AggregateRoot
12			{
13			public const EVENT_MAP = [];
14			protected array $events;
15			protected string $aggregateId;
16
17			final public function __construct()
18			{
19			$this->events = [];
20			}
21
22			public function aggregateId(): string
23			{
24			return $this->aggregateId;
25			}
26
27			protected function recordThat(AggregateChanged $occur): void
28			{
29			$this->events[] = $occur;
30			DomainEventEmitter::recordThat($occur);
31			}
32
33			public function popEvents(): EventCollection
34			{
35			$appliedEvents = [];
36			/**
37			* @var int $key
38			* @var AggregateChanged $event
39			*/
40			foreach ($this->events as $key => $event) {
41			$this->apply($event);
42			unset($this->events[$key]);
43			$appliedEvents[] = $event;
44			}
45
46			return EventCollection::createImmutableCollection($appliedEvents);
47			}
48
49			public function apply(AggregateChanged $aggregateChanged): void
50			{
51			/** @var array<string, string> */
52			$eventMap = static::EVENT_MAP;
53			$eventClass = get_class($aggregateChanged);
54			if (array_key_exists($eventClass, $eventMap)) {
55			$method = $eventMap[$eventClass];
56			$this->{$method}($aggregateChanged);
57			}
58			}
59			}
60

antidot-framework / event-sourcing

AggregateRoot::popEvents() A last analyzed 2022-08-31 16:13 UTC

Complexity

Size

Duplication

Code Coverage

Importance

Duplication Side-by-Side

Filter issues like

AggregateRoot::popEvents() A
last analyzed 2022-08-31 16:13 UTC