Domain\Eventing\InMemoryEventStore

Complexity

Total Complexity

3

Size/Duplication

Total Lines	44
Duplicated Lines	0 %

Coupling/Cohesion

Components	1
Dependencies	3

Importance

Changes	2
Bugs	0	Features	1

2 Methods

Rating	Name	Duplication	Size	Complexity
A	commit()	0	10	2
A	getAggregateHistoryFor()	0	12	1

<?php

namespace Domain\Eventing;

use Domain\Identity\Identity;

/**
 * @author Sebastiaan Hilbers <bashilbers@gmail.com>
 */
final class InMemoryEventStore implements EventStore
{
    /**
     * Events in memory
     * @var array
     */
    protected $events = [];

    /**
     * @param UncommittedEvents $stream
     * @return CommittedEvents
     */
    public function commit(UncommittedEvents $stream)
    {
        $aggregateId = $stream->first()->getAggregateIdentity();

        foreach ($stream as $event) {
            $this->events[(string) $aggregateId][] = $event;
        }

        return new CommittedEvents($aggregateId, $stream->getEvents());
    }

    /**
     * Gets the events stored as memory and wraps it in \CommittedEvents
     *
     * @param Identity $id
     * @param int $offset
     * @param null $max
     * @return CommittedEvents
     */
    public function getAggregateHistoryFor(Identity $id, $offset = 0, $max = null)
    {
        return new CommittedEvents(
            $id,
            array_filter(
                array_slice($this->events[(string)$id], $offset, $max, true),
                function (DomainEvent $event) use ($id) {
                    return $event->getAggregateIdentity()->equals($id);
                }
            )
        );
    }
}