InMemoryMessageRepository::retrieveAll() - Code Metrics - EventSaucePHP/EventSauce - Measure and Improve Code Quality continuously with Scrutinizer

InMemoryMessageRepository::retrieveAll() A
last analyzed 2021-05-02 12:47 UTC

↳ Parent: InMemoryMessageRepository

Complexity

Conditions	4
Paths	6

Size

Total Lines	12
Code Lines	6

Duplication

Lines	0
Ratio	0 %

Code Coverage

Tests	7
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
ccs	7
cts	7
cp	1
crap	4
rs	10

<?php

declare(strict_types=1);

namespace EventSauce\EventSourcing;

use Generator;

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

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

EventSaucePHP / EventSauce

InMemoryMessageRepository::retrieveAll() A last analyzed 2021-05-02 12:47 UTC

Complexity

Size

Duplication

Code Coverage

Importance

Duplication Side-by-Side

Filter issues like

InMemoryMessageRepository::retrieveAll() A
last analyzed 2021-05-02 12:47 UTC