InMemoryMessageRepository::persist() - Code Metrics - Inspection of "Merge pull request #11 from EventSaucePHP/feature/..." - EventSaucePHP/EventSauce - Measure and Improve Code Quality continuously with Scrutinizer

Passed

Push — master ( a68ac1...afa93b )

by Frank

created 2018-02-24 21:27 UTC

InMemoryMessageRepository::persist() A

↳ Parent: InMemoryMessageRepository

Complexity

Conditions	2
Paths	2

Size

Total Lines	11
Code Lines	6

Duplication

Lines	0
Ratio	0 %

Code Coverage

Tests	7
CRAP Score	2

Importance

Changes

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

<?php

namespace EventSauce\EventSourcing;

use Generator;

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

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

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

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

    public function persist(AggregateRootId $id, Message ... $messages)
    {
        $this->lastCommit = [];

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

    public function retrieveAll(AggregateRootId $id): Generator
    {
        yield from $this->messages[$id->toString()] ?? [];
    }
}

1		<?php
2
3		namespace EventSauce\EventSourcing;
4
5		use Generator;
6
7		class InMemoryMessageRepository implements MessageRepository
8		{
9		/**
10		* @var Message[]
11		*/
12		private $messages = [];
13
14		/**
15		* @var Event[]
16		*/
17		private $lastCommit = [];
18
19		/**
20		* @return Event[]
21		*/
22	5	public function lastCommit(): array
23		{
24	5	return $this->lastCommit;
25		}
26
27	5	public function purgeLastCommit()
28		{
29	5	$this->lastCommit = [];
30	5	}
31
32	7	public function persist(AggregateRootId $id, Message ... $messages)
33		{
34	7	$this->lastCommit = [];
35
36		/** @var Message $event */
37	7	foreach ($messages as $message) {
38	3	$event = $message->event();
39	3	$this->messages[$id->toString()][] = $message;
40	3	$this->lastCommit[] = $event;
41		}
42	7	}
43
44	7	public function retrieveAll(AggregateRootId $id): Generator
45		{
46	7	yield from $this->messages[$id->toString()] ?? [];
47		}
48		}

EventSaucePHP / EventSauce

Push — master ( a68ac1...afa93b )

InMemoryMessageRepository::persist() A

Complexity

Size

Duplication

Code Coverage

Importance

Duplication Side-by-Side

Filter issues like