AbstractAggregateRoot::replayAggregateEventStream() - Code Metrics - Inspection of "tweak serialization" - phpgears/event-sourcing - Measure and Improve Code Quality continuously with Scrutinizer

Completed

Push — master ( 42bfdd...25163a )

by Julián

created 2020-03-07 20:12 UTC

replayAggregateEventStream() A

↳ Parent: AbstractAggregateRoot

Complexity

Conditions	3
Paths	3

Size

Total Lines	17
Code Lines	10

Duplication

Lines	0
Ratio	0 %

Importance

Changes

Metric	Value
cc	3
eloc	10
c	0
b	0
f	0
nc	3
nop	1
dl	0
loc	17
rs	9.9332

<?php

/*
 * event-sourcing (https://github.com/phpgears/event-sourcing).
 * Event Sourcing base.
 *
 * @license MIT
 * @link https://github.com/phpgears/event-sourcing
 * @author Julián Gutiérrez <[email protected]>
 */

declare(strict_types=1);

namespace Gears\EventSourcing\Aggregate;

use Gears\Aggregate\EventBehaviour;
use Gears\EventSourcing\Aggregate\Exception\AggregateException;
use Gears\EventSourcing\Aggregate\Exception\AggregateVersionException;
use Gears\EventSourcing\Aggregate\Serializer\Exception\AggregateSerializationException;
use Gears\EventSourcing\Event\AggregateEvent;
use Gears\EventSourcing\Event\AggregateEventIteratorStream;
use Gears\EventSourcing\Event\AggregateEventStream;
use Gears\Identity\Identity;

/**
 * Abstract aggregate root class.
 *
 * @SuppressWarnings(PHPMD.LongVariable)
 */
abstract class AbstractAggregateRoot implements AggregateRoot
{
    use AggregateBehaviour, EventBehaviour;

    /**
     * @var \ArrayObject<string, AggregateEvent>|null
     */
    private $recordedAggregateEvents;

    /**
     * Prevent aggregate root direct instantiation.
     */
    final protected function __construct()
    {
        $this->version = new AggregateVersion(0);
    }

    /**
     * Set aggregate identity.
     *
     * @param Identity $identity
     */
    final protected function setIdentity(Identity $identity): void
    {
        $this->identity = $identity;
    }

    /**
     * {@inheritdoc}
     */
    final public static function reconstituteFromEventStream(AggregateEventStream $eventStream): self
    {
        $instance = new static();
        $instance->replayAggregateEventStream($eventStream);

        if ($instance->getVersion()->isEqualTo(new AggregateVersion(0))) {
            throw new AggregateException('Aggregate cannot be reconstituted from empty event stream');
        }

        return $instance;
    }

    /**
     * {@inheritdoc}
     *
     * @throws AggregateVersionException
     */
    final public function replayAggregateEventStream(AggregateEventStream $eventStream): void
    {
        foreach ($eventStream as $event) {
            $aggregateVersion = $event->getAggregateVersion();

            if (!$aggregateVersion->isEqualTo($this->version->getNext())) {
                throw new AggregateVersionException(\sprintf(
                    'Aggregate event "%s" cannot be replayed, event version is "%s" and aggregate is "%s"',
                    \get_class($event),
                    $aggregateVersion->getValue(),
                    $this->version->getValue()
                ));
            }

            $this->applyAggregateEvent($event);

            $this->version = $aggregateVersion;
        }
    }

    /**
     * Record aggregate event.
     *
     * @param AggregateEvent $event
     *
     * @throws AggregateVersionException
     */
    final protected function recordAggregateEvent(AggregateEvent $event): void
    {
        if (!$event->getAggregateVersion()->isEqualTo(new AggregateVersion(0))) {
            throw new AggregateVersionException(\sprintf(
                'Only new aggregate events can be recorded, event "%s" with version "%s" given',
                \get_class($event),
                $event->getAggregateVersion()->getValue()
            ));
        }

        $this->applyAggregateEvent($event);

        $this->version = $this->version->getNext();

        /** @var AggregateEvent $recordedEvent */
        $recordedEvent = $event::reconstitute(
            $event->getPayload(),
            $event->getCreatedAt(),
            [
                'aggregateId' => $event->getAggregateId(),
                'aggregateVersion' => $this->version,
                'metadata' => $event->getMetadata(),
            ]
        );

        if ($this->recordedAggregateEvents === null) {
            $this->recordedAggregateEvents = new \ArrayObject();
        }

        $this->recordedAggregateEvents->append($recordedEvent);
    }

    /**
     * Apply aggregate event.
     *
     * @param AggregateEvent $event
     *
     * @throws AggregateException
     */
    final protected function applyAggregateEvent(AggregateEvent $event): void
    {
        $method = $this->getAggregateEventApplyMethodName($event);

        if (!\method_exists($this, $method)) {
            throw new AggregateException(\sprintf(
                'Aggregate event handling method "%s" for event "%s" does not exist',
                $method,
                \get_class($event)
            ));
        }

        /** @var callable $callable */
        $callable = [$this, $method];

        \call_user_func($callable, $event);
    }

    /**
     * Get event apply method name.
     *
     * @param AggregateEvent $event
     *
     * @return string
     */
    protected function getAggregateEventApplyMethodName(AggregateEvent $event): string
    {
        $typeParts = \explode('\\', $event->getEventType());
        /** @var string $eventType */
        $eventType = \end($typeParts);

        return 'apply' . \str_replace(' ', '', \ucwords(\strtr($eventType, '_-', '  ')));
    }

    /**
     * {@inheritdoc}
     */
    final public function getRecordedAggregateEvents(): AggregateEventStream
    {
        return new AggregateEventIteratorStream(
            $this->recordedAggregateEvents !== null
                ? $this->recordedAggregateEvents->getIterator()
                : new \EmptyIterator()
        );
    }

    /**
     * {@inheritdoc}
     */
    final public function clearRecordedAggregateEvents(): void
    {
        $this->recordedAggregateEvents = null;
    }

    /**
     * {@inheritdoc}
     */
    final public function collectRecordedAggregateEvents(): AggregateEventStream
    {
        $recordedEvents = new AggregateEventIteratorStream(
            $this->recordedAggregateEvents !== null
                ? $this->recordedAggregateEvents->getIterator()
                : new \EmptyIterator()
        );

        $this->recordedAggregateEvents = new \ArrayObject();

        return $recordedEvents;
    }

    /**
     * @return array<string, mixed>
     */
    final public function __serialize(): array
    {
        return $this->getSerializationAttributes();
    }

    /**
     * @param array<string, mixed> $data
     */
    final public function __unserialize(array $data): void
    {
        $this->unserializeAttributes($data);
    }

    /**
     * {@inheritdoc}
     */
    final public function serialize(): string
    {
        return \serialize($this->getSerializationAttributes());
    }

    /**
     * {@inheritdoc}
     *
     * @param mixed $serialized
     */
    final public function unserialize($serialized): void
    {
        $this->unserializeAttributes(\unserialize($serialized));
    }

    /**
     * Get serialization data.
     *
     * @throws AggregateSerializationException
     *
     * @return array<string, mixed>
     */
    private function getSerializationAttributes(): array
    {
        if (($this->recordedAggregateEvents !== null && $this->recordedAggregateEvents->count() !== 0)
            || ($this->recordedEvents !== null && $this->recordedEvents->count() !== 0)
        ) {
            throw new AggregateSerializationException('Aggregate root with recorded events cannot be serialized');
        }

        $attributes = [];
        foreach ((new \ReflectionObject($this))->getProperties() as $reflectionProperty) {
            if (!$reflectionProperty->isStatic()) {
                $reflectionProperty->setAccessible(true);
                $attributes[$reflectionProperty->getName()] = $reflectionProperty->getValue($this);
            }
        }

        $attributes['identity'] = $this->identity;
        $attributes['version'] = $this->version;

        return $attributes;
    }

    /**
     * Unserialize attributes.
     *
     * @param array<string, mixed> $attributes
     */
    private function unserializeAttributes(array $attributes): void
    {
        foreach ($attributes as $attribute => $value) {
            if (!\in_array($attribute, ['recordedAggregateEvents', 'recordedEvents'], true)) {
                $this->{$attribute} = $value;
            }
        }
    }
}


1			<?php
2
3			/*
4			* event-sourcing (https://github.com/phpgears/event-sourcing).
5			* Event Sourcing base.
6			*
7			* @license MIT
8			* @link https://github.com/phpgears/event-sourcing
9			* @author Julián Gutiérrez <[email protected]>
10			*/
11
12			declare(strict_types=1);
13
14			namespace Gears\EventSourcing\Aggregate;
15
16			use Gears\Aggregate\EventBehaviour;
17			use Gears\EventSourcing\Aggregate\Exception\AggregateException;
18			use Gears\EventSourcing\Aggregate\Exception\AggregateVersionException;
19			use Gears\EventSourcing\Aggregate\Serializer\Exception\AggregateSerializationException;
20			use Gears\EventSourcing\Event\AggregateEvent;
21			use Gears\EventSourcing\Event\AggregateEventIteratorStream;
22			use Gears\EventSourcing\Event\AggregateEventStream;
23			use Gears\Identity\Identity;
24
25			/**
26			* Abstract aggregate root class.
27			*
28			* @SuppressWarnings(PHPMD.LongVariable)
29			*/
30			abstract class AbstractAggregateRoot implements AggregateRoot
31			{
32			use AggregateBehaviour, EventBehaviour;
33
34			/**
35			* @var \ArrayObject<string, AggregateEvent>\|null
36			*/
37			private $recordedAggregateEvents;
38
39			/**
40			* Prevent aggregate root direct instantiation.
41			*/
42			final protected function __construct()
43			{
44			$this->version = new AggregateVersion(0);
45			}
46
47			/**
48			* Set aggregate identity.
49			*
50			* @param Identity $identity
51			*/
52			final protected function setIdentity(Identity $identity): void
53			{
54			$this->identity = $identity;
55			}
56
57			/**
58			* {@inheritdoc}
59			*/
60			final public static function reconstituteFromEventStream(AggregateEventStream $eventStream): self
61			{
62			$instance = new static();
63			$instance->replayAggregateEventStream($eventStream);
64
65			if ($instance->getVersion()->isEqualTo(new AggregateVersion(0))) {
66			throw new AggregateException('Aggregate cannot be reconstituted from empty event stream');
67			}
68
69			return $instance;
70			}
71
72			/**
73			* {@inheritdoc}
74			*
75			* @throws AggregateVersionException
76			*/
77			final public function replayAggregateEventStream(AggregateEventStream $eventStream): void
78			{
79			foreach ($eventStream as $event) {
80			$aggregateVersion = $event->getAggregateVersion();
81
82			if (!$aggregateVersion->isEqualTo($this->version->getNext())) {
83			throw new AggregateVersionException(\sprintf(
84			'Aggregate event "%s" cannot be replayed, event version is "%s" and aggregate is "%s"',
85			\get_class($event),
86			$aggregateVersion->getValue(),
87			$this->version->getValue()
88			));
89			}
90
91			$this->applyAggregateEvent($event);
92
93			$this->version = $aggregateVersion;
94			}
95			}
96
97			/**
98			* Record aggregate event.
99			*
100			* @param AggregateEvent $event
101			*
102			* @throws AggregateVersionException
103			*/
104			final protected function recordAggregateEvent(AggregateEvent $event): void
105			{
106			if (!$event->getAggregateVersion()->isEqualTo(new AggregateVersion(0))) {
107			throw new AggregateVersionException(\sprintf(
108			'Only new aggregate events can be recorded, event "%s" with version "%s" given',
109			\get_class($event),
110			$event->getAggregateVersion()->getValue()
111			));
112			}
113
114			$this->applyAggregateEvent($event);
115
116			$this->version = $this->version->getNext();
117
118			/** @var AggregateEvent $recordedEvent */
119			$recordedEvent = $event::reconstitute(
120			$event->getPayload(),
121			$event->getCreatedAt(),
122			[
123			'aggregateId' => $event->getAggregateId(),
124			'aggregateVersion' => $this->version,
125			'metadata' => $event->getMetadata(),
126			]
127			);
128
129			if ($this->recordedAggregateEvents === null) {
130			$this->recordedAggregateEvents = new \ArrayObject();
131			}
132
133			$this->recordedAggregateEvents->append($recordedEvent);
134			}
135
136			/**
137			* Apply aggregate event.
138			*
139			* @param AggregateEvent $event
140			*
141			* @throws AggregateException
142			*/
143			final protected function applyAggregateEvent(AggregateEvent $event): void
144			{
145			$method = $this->getAggregateEventApplyMethodName($event);
146
147			if (!\method_exists($this, $method)) {
148			throw new AggregateException(\sprintf(
149			'Aggregate event handling method "%s" for event "%s" does not exist',
150			$method,
151			\get_class($event)
152			));
153			}
154
155			/** @var callable $callable */
156			$callable = [$this, $method];
157
158			\call_user_func($callable, $event);
159			}
160
161			/**
162			* Get event apply method name.
163			*
164			* @param AggregateEvent $event
165			*
166			* @return string
167			*/
168			protected function getAggregateEventApplyMethodName(AggregateEvent $event): string
169			{
170			$typeParts = \explode('\\', $event->getEventType());
171			/** @var string $eventType */
172			$eventType = \end($typeParts);
173
174			return 'apply' . \str_replace(' ', '', \ucwords(\strtr($eventType, '_-', ' ')));
175			}
176
177			/**
178			* {@inheritdoc}
179			*/
180			final public function getRecordedAggregateEvents(): AggregateEventStream
181			{
182			return new AggregateEventIteratorStream(
183			$this->recordedAggregateEvents !== null
184			? $this->recordedAggregateEvents->getIterator()
185			: new \EmptyIterator()
186			);
187			}
188
189			/**
190			* {@inheritdoc}
191			*/
192			final public function clearRecordedAggregateEvents(): void
193			{
194			$this->recordedAggregateEvents = null;
195			}
196
197			/**
198			* {@inheritdoc}
199			*/
200			final public function collectRecordedAggregateEvents(): AggregateEventStream
201			{
202			$recordedEvents = new AggregateEventIteratorStream(
203			$this->recordedAggregateEvents !== null
204			? $this->recordedAggregateEvents->getIterator()
205			: new \EmptyIterator()
206			);
207
208			$this->recordedAggregateEvents = new \ArrayObject();
209
210			return $recordedEvents;
211			}
212
213			/**
214			* @return array<string, mixed>
215			*/
216			final public function __serialize(): array
217			{
218			return $this->getSerializationAttributes();
219			}
220
221			/**
222			* @param array<string, mixed> $data
223			*/
224			final public function __unserialize(array $data): void
225			{
226			$this->unserializeAttributes($data);
227			}
228
229			/**
230			* {@inheritdoc}
231			*/
232			final public function serialize(): string
233			{
234			return \serialize($this->getSerializationAttributes());
235			}
236
237			/**
238			* {@inheritdoc}
239			*
240			* @param mixed $serialized
241			*/
242			final public function unserialize($serialized): void
243			{
244			$this->unserializeAttributes(\unserialize($serialized));
245			}
246
247			/**
248			* Get serialization data.
249			*
250			* @throws AggregateSerializationException
251			*
252			* @return array<string, mixed>
253			*/
254			private function getSerializationAttributes(): array
255			{
256			if (($this->recordedAggregateEvents !== null && $this->recordedAggregateEvents->count() !== 0)
257			\|\| ($this->recordedEvents !== null && $this->recordedEvents->count() !== 0)
258			) {
259			throw new AggregateSerializationException('Aggregate root with recorded events cannot be serialized');
260			}
261
262			$attributes = [];
263			foreach ((new \ReflectionObject($this))->getProperties() as $reflectionProperty) {
264			if (!$reflectionProperty->isStatic()) {
265			$reflectionProperty->setAccessible(true);
266			$attributes[$reflectionProperty->getName()] = $reflectionProperty->getValue($this);
267			}
268			}
269
270			$attributes['identity'] = $this->identity;
271			$attributes['version'] = $this->version;
272
273			return $attributes;
274			}
275
276			/**
277			* Unserialize attributes.
278			*
279			* @param array<string, mixed> $attributes
280			*/
281			private function unserializeAttributes(array $attributes): void
282			{
283			foreach ($attributes as $attribute => $value) {
284			if (!\in_array($attribute, ['recordedAggregateEvents', 'recordedEvents'], true)) {
285			$this->{$attribute} = $value;
286			}
287			}
288			}
289			}
290

phpgears / event-sourcing

Push — master ( 42bfdd...25163a )

replayAggregateEventStream() A

Complexity

Size

Duplication

Importance

Duplication Side-by-Side

Filter issues like