InMemoryEventPersister::find() - Code Metrics - Inspection of "Set aggregate sequence with the last event saved" - blixit/event-sourcing - Measure and Improve Code Quality continuously with Scrutinizer

Passed

Push — master ( 12fd79...01de3e )

by Blixit

created 2019-04-27 23:07 UTC

InMemoryEventPersister::find() B

↳ Parent: InMemoryEventPersister

Complexity

Conditions	11
Paths	1

Size

Total Lines	26
Code Lines	18

Duplication

Lines	0
Ratio	0 %

Importance

Changes

Metric	Value
cc	11
eloc	18
nc	1
nop	1
dl	0
loc	26
rs	7.3166
c	0
b	0
f	0

How to fix Complexity

<?php

declare(strict_types=1);

namespace Blixit\EventSourcing\Store\InMemory;

use Blixit\EventSourcing\Event\EventInterface;
use Blixit\EventSourcing\Store\Matcher\EventMatcherInterface;
use Blixit\EventSourcing\Store\Persistence\EventPersisterInterface;
use Blixit\EventSourcing\Stream\StreamName;
use function array_filter;
use function end;

class InMemoryEventPersister implements EventPersisterInterface
{
    /** @var EventInterface[] $events */
    private $events = [];

    /**
     * @return EventInterface[]
     */
    public function getByStream(StreamName $streamName, ?int $fromSequence = 0) : array
    {
        return array_filter($this->events, static function (EventInterface $event) use (
            $streamName,
            $fromSequence
        ) {
            return $event->getStreamName() === (string) $streamName && $event->getSequence() > $fromSequence;
        });
    }

    /**
     * Returns the last event stored into the stream
     */
    public function getLastEvent(StreamName $streamName) : ?EventInterface
    {
        return empty($this->events) ? null : end($this->events);
    }

    public function persist(EventInterface $event) : EventInterface
    {
        $this->events[] = $event;

        return $event;
    }

    /**
     * @return EventInterface[]
     */
    public function find(EventMatcherInterface $eventMatcher) : array
    {
        return array_filter($this->events, static function (EventInterface $event) use ($eventMatcher) {
            $aggregateId    = $eventMatcher->getAggregateId();
            $aggregateClass = $eventMatcher->getAggregateClass();
            $fromSequence   = $eventMatcher->getSequence();
            $streamName     = $eventMatcher->getStreamName();
            $timestamp      = $eventMatcher->getTimestamp();

            $condition = true;
            if (! empty($aggregateId)) {
                $condition = $condition && ($event->getAggregateId() === $aggregateId);
            }
            if (! empty($aggregateClass)) {
                $condition = $condition && ($event->getAggregateClass() === (string) $aggregateClass);
            }
            if (! empty($fromSequence)) {
                $condition = $condition && ($event->getSequence() > $fromSequence);
            }
            if (! empty($streamName)) {
                $condition = $condition && ($event->getStreamName() === (string) $streamName);
            }
            if (! empty($timestamp)) {
                $condition = $condition && ($event->getTimestamp() > $timestamp);
            }
            return $condition;
        });
    }
}


1			<?php
2
3			declare(strict_types=1);
4
5			namespace Blixit\EventSourcing\Store\InMemory;
6
7			use Blixit\EventSourcing\Event\EventInterface;
8			use Blixit\EventSourcing\Store\Matcher\EventMatcherInterface;
9			use Blixit\EventSourcing\Store\Persistence\EventPersisterInterface;
10			use Blixit\EventSourcing\Stream\StreamName;
11			use function array_filter;
12			use function end;
13
14			class InMemoryEventPersister implements EventPersisterInterface
15			{
16			/** @var EventInterface[] $events */
17			private $events = [];
18
19			/**
20			* @return EventInterface[]
21			*/
22			public function getByStream(StreamName $streamName, ?int $fromSequence = 0) : array
23			{
24			return array_filter($this->events, static function (EventInterface $event) use (
25			$streamName,
26			$fromSequence
27			) {
28			return $event->getStreamName() === (string) $streamName && $event->getSequence() > $fromSequence;
29			});
30			}
31
32			/**
33			* Returns the last event stored into the stream
34			*/
35			public function getLastEvent(StreamName $streamName) : ?EventInterface
36			{
37			return empty($this->events) ? null : end($this->events);
38			}
39
40			public function persist(EventInterface $event) : EventInterface
41			{
42			$this->events[] = $event;
43
44			return $event;
45			}
46
47			/**
48			* @return EventInterface[]
49			*/
50			public function find(EventMatcherInterface $eventMatcher) : array
51			{
52			return array_filter($this->events, static function (EventInterface $event) use ($eventMatcher) {
53			$aggregateId = $eventMatcher->getAggregateId();
54			$aggregateClass = $eventMatcher->getAggregateClass();
55			$fromSequence = $eventMatcher->getSequence();
56			$streamName = $eventMatcher->getStreamName();
57			$timestamp = $eventMatcher->getTimestamp();
58
59			$condition = true;
60			if (! empty($aggregateId)) {
61			$condition = $condition && ($event->getAggregateId() === $aggregateId);
62			}
63			if (! empty($aggregateClass)) {
64			$condition = $condition && ($event->getAggregateClass() === (string) $aggregateClass);
65			}
66			if (! empty($fromSequence)) {
67			$condition = $condition && ($event->getSequence() > $fromSequence);
68			}
69			if (! empty($streamName)) {
70			$condition = $condition && ($event->getStreamName() === (string) $streamName);
71			}
72			if (! empty($timestamp)) {
73			$condition = $condition && ($event->getTimestamp() > $timestamp);
74			}
75			return $condition;
76			});
77			}
78			}
79

blixit / event-sourcing

Push — master ( 12fd79...01de3e )

InMemoryEventPersister::find() B

Complexity

Size

Duplication

Importance

How to fix Complexity

Long Method

Duplication Side-by-Side

Filter issues like