Blixit\EventSourcing\Store\InMemory\InMemoryEventPersister

Complexity

Total Complexity

14

Size/Duplication

Total Lines	60
Duplicated Lines	0 %

Importance

Changes

0

3 Methods

Rating	Name	Duplication	Size	Complexity
A	getByStream()	0	7	2
B	find()	0	32	11
A	persist()	0	5	1

<?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;

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;
        });
    }

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

        return $event;
    }

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

        return array_filter($this->events, static function (EventInterface $event) use (
            $aggregateId,
            $aggregateClass,
            $fromSequence,
            $streamName,
            $timestamp
        ) {
            $condition = true;
            if (! empty($aggregateId)) {
                $condition = $condition && ($event->getAggregateId() === (string) $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->getStreamName() > $timestamp);
            }
            return $condition;
        });
    }
}