SnapshottingBehaviour::reconstituteFromSnapshotAndEvents() - Code Metrics - Inspection of "Release: 0.7.0" - EventSaucePHP/EventSauce - Measure and Improve Code Quality continuously with Scrutinizer

Completed

Pull Request — master (#66)

by Frank

created 2019-09-24 20:19 UTC

reconstituteFromSnapshotAndEvents() A

↳ Parent: SnapshottingBehaviour

Complexity

Conditions	3
Paths	2

Size

Total Lines	14
Code Lines	7

Duplication

Lines	0
Ratio	0 %

Importance

Changes	2
Bugs	0	Features	0

Metric	Value
cc	3
eloc	7
c	2
b	0
f	0
nc	2
nop	2
dl	0
loc	14
rs	10

<?php

declare(strict_types=1);

namespace EventSauce\EventSourcing\Snapshotting;

use EventSauce\EventSourcing\AggregateRoot;
use EventSauce\EventSourcing\AggregateRootId;
use Generator;

trait SnapshottingBehaviour
{
    /**
     * @var int
     */
    private $aggregateRootVersion = 0;

    abstract public function aggregateRootVersion(): int;

    abstract public function aggregateRootId(): AggregateRootId;

    abstract protected function apply(object $event): void;

    public function createSnapshot(): Snapshot
    {
        return new Snapshot($this->aggregateRootId(), $this->aggregateRootVersion(), $this->createSnapshotState());
    }

    abstract protected function createSnapshotState();

    /**
     * @param Snapshot  $snapshot
     * @param Generator $events
     *
     * @return static
     */
    public static function reconstituteFromSnapshotAndEvents(Snapshot $snapshot, Generator $events): AggregateRoot
    {
        $id = $snapshot->aggregateRootId();
        /** @var static&AggregateRoot $aggregateRoot */
        $aggregateRoot = static::reconstituteFromSnapshotState($id, $snapshot->state());
        $aggregateRoot->aggregateRootVersion = $snapshot->aggregateRootVersion();

        foreach ($events as $event) {
            $aggregateRoot->apply($event);
        }

        $aggregateRoot->aggregateRootVersion = $events->getReturn() ?: $aggregateRoot->aggregateRootVersion;

        return $aggregateRoot;
    }

    abstract protected static function reconstituteFromSnapshotState(AggregateRootId $id, $state): AggregateRootWithSnapshotting;
}


1			<?php
2
3			declare(strict_types=1);
4
5			namespace EventSauce\EventSourcing\Snapshotting;
6
7			use EventSauce\EventSourcing\AggregateRoot;
8			use EventSauce\EventSourcing\AggregateRootId;
9			use Generator;
10
11			trait SnapshottingBehaviour
12			{
13			/**
14			* @var int
15			*/
16			private $aggregateRootVersion = 0;
17
18			abstract public function aggregateRootVersion(): int;
19
20			abstract public function aggregateRootId(): AggregateRootId;
21
22			abstract protected function apply(object $event): void;
23
24			public function createSnapshot(): Snapshot
25			{
26			return new Snapshot($this->aggregateRootId(), $this->aggregateRootVersion(), $this->createSnapshotState());
27			}
28
29			abstract protected function createSnapshotState();
30
31			/**
32			* @param Snapshot $snapshot
33			* @param Generator $events
34			*
35			* @return static
36			*/
37			public static function reconstituteFromSnapshotAndEvents(Snapshot $snapshot, Generator $events): AggregateRoot
38			{
39			$id = $snapshot->aggregateRootId();
40			/** @var static&AggregateRoot $aggregateRoot */
41			$aggregateRoot = static::reconstituteFromSnapshotState($id, $snapshot->state());
42			$aggregateRoot->aggregateRootVersion = $snapshot->aggregateRootVersion();
43
44			foreach ($events as $event) {
45			$aggregateRoot->apply($event);
46			}
47
48			$aggregateRoot->aggregateRootVersion = $events->getReturn() ?: $aggregateRoot->aggregateRootVersion;
49
50			return $aggregateRoot;
51			}
52
53			abstract protected static function reconstituteFromSnapshotState(AggregateRootId $id, $state): AggregateRootWithSnapshotting;
54			}
55

EventSaucePHP / EventSauce

Pull Request — master (#66)

reconstituteFromSnapshotAndEvents() A

Complexity

Size

Duplication

Importance

Duplication Side-by-Side

Filter issues like