InMemoryMessageRepository::retrieveAll() - 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

InMemoryMessageRepository::retrieveAll() A

↳ Parent: InMemoryMessageRepository

Complexity

Conditions	4
Paths	6

Size

Total Lines	12
Code Lines	6

Duplication

Lines	0
Ratio	0 %

Code Coverage

Tests	5
CRAP Score	4

Importance

Changes

Metric	Value
cc	4
eloc	6
c	0
b	0
f	0
nc	6
nop	1
dl	0
loc	12
rs	10
ccs	5
cts	5
cp	1
crap	4

<?php

declare(strict_types=1);

namespace EventSauce\EventSourcing;

use Generator;

final class InMemoryMessageRepository implements MessageRepository
{
    /**
     * @var Message[]
     */
    private $messages = [];

    /**
     * @var object[]
     */
    private $lastCommit = [];

    /**
     * @return object[]
     */
    public function lastCommit(): array
    {
        return $this->lastCommit;
    }

    public function purgeLastCommit(): void
    {
        $this->lastCommit = [];
    }

    public function persist(Message ...$messages): void
    {
        $this->lastCommit = [];

        /* @var Message $event */
        foreach ($messages as $message) {
            $this->messages[] = $message;
            $this->lastCommit[] = $message->event();
        }
    }

    public function retrieveAll(AggregateRootId $id): Generator
    {
        $lastMessage = null;

        foreach ($this->messages as $message) {
            if ($id->toString() === $message->header(Header::AGGREGATE_ROOT_ID)->toString()) {
                yield $message;
                $lastMessage = $message;
            }
        }

        return $lastMessage instanceof Message ? $lastMessage->aggregateVersion() : 0;
    }

    public function retrieveAllAfterVersion(AggregateRootId $id, int $aggregateRootVersion): Generator
    {
        $lastMessage = null;

        foreach ($this->messages as $message) {
            if ($id->toString() === $message->header(Header::AGGREGATE_ROOT_ID)->toString()
                && $message->header(Header::AGGREGATE_ROOT_VERSION) > $aggregateRootVersion) {
                yield $message;
                $lastMessage = $message;
            }
        }

        return $lastMessage instanceof Message ? $lastMessage->aggregateVersion() : 0;
    }
}


1		<?php
2
3		declare(strict_types=1);
4
5		namespace EventSauce\EventSourcing;
6
7		use Generator;
8
9		final class InMemoryMessageRepository implements MessageRepository
10		{
11		/**
12		* @var Message[]
13		*/
14		private $messages = [];
15
16		/**
17		* @var object[]
18		*/
19		private $lastCommit = [];
20
21		/**
22		* @return object[]
23		*/
24	8	public function lastCommit(): array
25		{
26	8	return $this->lastCommit;
27		}
28
29	8	public function purgeLastCommit(): void
30		{
31	8	$this->lastCommit = [];
32	8	}
33
34	9	public function persist(Message ...$messages): void
35		{
36	9	$this->lastCommit = [];
37
38		/* @var Message $event */
39	9	foreach ($messages as $message) {
40	5	$this->messages[] = $message;
41	5	$this->lastCommit[] = $message->event();
42		}
43	9	}
44
45	8	public function retrieveAll(AggregateRootId $id): Generator
46		{
47	8	$lastMessage = null;
48	3
49	2	foreach ($this->messages as $message) {
50		if ($id->toString() === $message->header(Header::AGGREGATE_ROOT_ID)->toString()) {
51		yield $message;
52		$lastMessage = $message;
53	8	}
54		}
55
56		return $lastMessage instanceof Message ? $lastMessage->aggregateVersion() : 0;
57		}
58
59		public function retrieveAllAfterVersion(AggregateRootId $id, int $aggregateRootVersion): Generator
60		{
61		$lastMessage = null;
62
63		foreach ($this->messages as $message) {
64		if ($id->toString() === $message->header(Header::AGGREGATE_ROOT_ID)->toString()
65		&& $message->header(Header::AGGREGATE_ROOT_VERSION) > $aggregateRootVersion) {
66		yield $message;
67		$lastMessage = $message;
68		}
69		}
70
71		return $lastMessage instanceof Message ? $lastMessage->aggregateVersion() : 0;
72		}
73		}
74

EventSaucePHP / EventSauce

Pull Request — master (#66)

InMemoryMessageRepository::retrieveAll() A

Complexity

Size

Duplication

Code Coverage

Importance

Duplication Side-by-Side

Filter issues like