xprt64/cqrs-es

<?php
/**
 * Copyright (c) 2019 Constantin Galbenu <xprt64@gmail.com>
 */

namespace Dudulina\Testing\EventStore\InMemory;


use Dudulina\EventStore\AggregateEventStream;

class InMemoryAggregateEventStream implements AggregateEventStream
{

    /**
     * @var array
     */
    private $eventsArray;
    private $version;
    private $sequence;
    /**
     * @var
     */
    private $aggregateClass;
    /**
     * @var
     */
    private $aggregateId;

    public function __construct(array $eventsArray, $aggregateClass, $aggregateId, int $sequence)
    {
        $this->version = count($eventsArray);
        $this->aggregateClass = $aggregateClass;
        $this->aggregateId = $aggregateId;
        $this->eventsArray = $eventsArray;
        $this->sequence = $sequence;
    }

    public function getIterator()
    {
        return new \ArrayIterator($this->eventsArray);
    }

    public function getVersion(): int
    {
        return $this->version;
    }

    public function getSequence(): int
    {
        return $this->sequence;
    }

    public function withIncrementedVersion():self
    {
        $other = clone $this;
        $other->version++;
        return $other;
    }

    public function withIncrementedSequence():self
    {
        $other = clone $this;
        $other->sequence++;
        return $other;
    }

    public function count()
    {
        return \count($this->eventsArray);
    }
}