RawEventStream::skipCommits() - Code Metrics - Inspection of "added fetchCommits" - xprt64/cqrs-es - Measure and Improve Code Quality continuously with Scrutinizer

Passed

Push — master ( bb86fc...5e808b )

by Constantin

created 2017-02-22 16:35 UTC

RawEventStream::skipCommits() A

↳ Parent: RawEventStream

Complexity

Conditions	1
Paths	1

Size

Total Lines	4
Code Lines	2

Duplication

Lines	0
Ratio	0 %

Code Coverage

Tests	3
CRAP Score	1

Importance

Changes

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

<?php


namespace Gica\Cqrs\EventStore\InMemory;


use Gica\Cqrs\EventStore\ByClassNamesEventStream;
use Gica\Iterator\IteratorTransformer\IteratorExpander;

class RawEventStream implements ByClassNamesEventStream
{

    private $groupedEventsArray = [];

    /** @var int|null */
    private $limit;

    /** @var  int|null */
    private $afterSequenceNumber;

    public function __construct($groupedEventsArray)
    {
        $this->groupedEventsArray = $groupedEventsArray;
    }

    public function getIterator()
    {
        $groupedEvents = $this->fetchCommits();

        $deGrouper = new IteratorExpander(function ($group) {
            foreach ($group as $event) {
                yield $event;
            }
        });

        $events = iterator_to_array($deGrouper($groupedEvents));

        return new \ArrayIterator($events);
    }

    /**
     * @return array|\ArrayIterator
     */
    public function fetchCommits()
    {
        $groupedEvents = $this->groupedEventsArray;

        if ($this->groupedEventsArray instanceof \Iterator || $this->groupedEventsArray instanceof \IteratorAggregate) {
            $groupedEvents = iterator_to_array($this->groupedEventsArray);
        }

        if ($this->afterSequenceNumber) {
0   == false // true
0   == null  // true
123 == false // false
123 == null  // false

// It is often better to use strict comparison
0 === false // false
0 === null  // false
            $groupedEvents = array_slice($groupedEvents, $this->afterSequenceNumber);
        }

        if ($this->limit) {
0   == false // true
0   == null  // true
123 == false // false
123 == null  // false

// It is often better to use strict comparison
0 === false // false
0 === null  // false
            $groupedEvents = array_slice($groupedEvents, 0, $this->limit);
        }

        return $groupedEvents;
    }

    public function limitCommits(int $limit)
    {
        $this->limit = $limit;
    }

    public function afterSequence(int $sequenceNumber)
    {
        $this->afterSequenceNumber = $sequenceNumber;
    }

    public function countCommits(): int
    {
        return count($this->groupedEventsArray);
    }
}

1		<?php
2
3
4		namespace Gica\Cqrs\EventStore\InMemory;
5
6
7		use Gica\Cqrs\EventStore\ByClassNamesEventStream;
8		use Gica\Iterator\IteratorTransformer\IteratorExpander;
9
10		class RawEventStream implements ByClassNamesEventStream
11		{
12
13		private $groupedEventsArray = [];
14
15		/** @var int\|null */
16		private $limit;
17
18		/** @var int\|null */
19		private $afterSequenceNumber;
20
21	3	public function __construct($groupedEventsArray)
22		{
23	3	$this->groupedEventsArray = $groupedEventsArray;
24	3	}
25
26	2	public function getIterator()
27		{
28	2	$groupedEvents = $this->fetchCommits();
29
30	2	$deGrouper = new IteratorExpander(function ($group) {
31	2	foreach ($group as $event) {
32	2	yield $event;
33		}
34	2	});
35
36	2	$events = iterator_to_array($deGrouper($groupedEvents));
37
38	2	return new \ArrayIterator($events);
39		}
40
41		/**
42		* @return array\|\ArrayIterator
43		*/
44	2	public function fetchCommits()
45		{
46	2	$groupedEvents = $this->groupedEventsArray;
47
48	2	if ($this->groupedEventsArray instanceof \Iterator \|\| $this->groupedEventsArray instanceof \IteratorAggregate) {
49	1	$groupedEvents = iterator_to_array($this->groupedEventsArray);
50		}
51
52	2	if ($this->afterSequenceNumber) {
		0 ignored issues – show Bug Best Practice introduced 2017-02-22 16:38 UTC by Report Bug Copy Issue Report The expression `$this->afterSequenceNumber` of type `integer\|null` is loosely compared to `true`; this is ambiguous if the integer can be zero. You might want to explicitly use `!== null` instead. In PHP, under loose comparison (like `==`, or `!=`, or `switch` conditions), values of different types might be equal. For `integer` values, zero is a special case, in particular the following results might be unexpected: 0 == false // true 0 == null // true 123 == false // false 123 == null // false // It is often better to use strict comparison 0 === false // false 0 === null // false Loading history...
53	1	$groupedEvents = array_slice($groupedEvents, $this->afterSequenceNumber);
54		}
55
56	2	if ($this->limit) {
		0 ignored issues – show Bug Best Practice introduced 2017-02-22 12:44 UTC by Report Bug Copy Issue Report The expression `$this->limit` of type `integer\|null` is loosely compared to `true`; this is ambiguous if the integer can be zero. You might want to explicitly use `!== null` instead. In PHP, under loose comparison (like `==`, or `!=`, or `switch` conditions), values of different types might be equal. For `integer` values, zero is a special case, in particular the following results might be unexpected: 0 == false // true 0 == null // true 123 == false // false 123 == null // false // It is often better to use strict comparison 0 === false // false 0 === null // false Loading history...
57	1	$groupedEvents = array_slice($groupedEvents, 0, $this->limit);
58		}
59
60	2	return $groupedEvents;
61		}
62
63	1	public function limitCommits(int $limit)
64		{
65	1	$this->limit = $limit;
66	1	}
67
68	1	public function afterSequence(int $sequenceNumber)
69		{
70	1	$this->afterSequenceNumber = $sequenceNumber;
71	1	}
72
73	1	public function countCommits(): int
74		{
75	1	return count($this->groupedEventsArray);
76		}
77		}

xprt64 / cqrs-es

Push — master ( bb86fc...5e808b )

RawEventStream::skipCommits() A

Complexity

Size

Duplication

Code Coverage

Importance

Duplication Side-by-Side

Filter issues like