Gica\Cqrs\EventStore\InMemory\RawEventStream

Complexity

Total Complexity

10

Size/Duplication

Total Lines	58
Duplicated Lines	0 %

Coupling/Cohesion

Components	1
Dependencies	1

Test Coverage

Coverage

100%

Importance

Changes

0

5 Methods

Rating	Name	Duplication	Size	Complexity
A	__construct()	0	4	1
B	getIterator()	0	26	6
A	limitCommits()	0	4	1
A	skipCommits()	0	4	1
A	countCommits()	0	4	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 $skip;

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

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

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

        if ($this->skip) {

The expression $this->skip 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.

            $groupedEvents = array_slice($groupedEvents, $this->skip);
        }

        if ($this->limit) {

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.

            $groupedEvents = array_slice($groupedEvents, 0, $this->limit);
        }

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

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

        return new \ArrayIterator($events);
    }

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

    public function skipCommits(int $numberOfCommits)
    {
        $this->skip = $numberOfCommits;
    }

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