ServiceBus\EventSourcing\EventStream\AggregateEventStream

Complexity

Total Complexity

4

Size/Duplication

Total Lines	107
Duplicated Lines	0 %

Test Coverage

Coverage

100%

Importance

Changes	1
Bugs	0	Features	0

3 Methods

Rating	Name	Duplication	Size	Complexity
A	__construct()	0	13	1
A	sortEvents()	0	13	2
A	extractOriginEvents()	0	8	1

<?php

/**
 * Event Sourcing implementation.
 *
 * @author  Maksim Masiukevich <dev@async-php.com>
 * @license MIT
 * @license https://opensource.org/licenses/MIT
 */

declare(strict_types = 1);

namespace ServiceBus\EventSourcing\EventStream;

use ServiceBus\EventSourcing\AggregateId;

/**
 * Event stream.
 *
 * @psalm-readonly
 */
final class AggregateEventStream
{
    /**
     * Stream (aggregate) identifier.
     *
     * @var AggregateId
     */
    public $id;

    /**
     * Aggregate class.
     *
     * @psalm-var class-string<\ServiceBus\EventSourcing\Aggregate>
     *
     * @var string
     */
    public $aggregateClass;

    /**
     * Event collection.
     *
     * @psalm-var array<int, \ServiceBus\EventSourcing\EventStream\AggregateEvent>
     *
     * @var \ServiceBus\EventSourcing\EventStream\AggregateEvent[]
     */
    public $events;

    /**
     * Origin event collection.
     *
     * @psalm-var array<int, object>
     *
     * @var object[]
     */
    public $originEvents;

    /**
     * Created at datetime.
     *
     * @var \DateTimeImmutable
     */
    public $createdAt;

    /**
     * Closed at datetime.
     *
     * @var \DateTimeImmutable|null
     */
    public $closedAt = null;

    /**
     * @psalm-param class-string<\ServiceBus\EventSourcing\Aggregate> $aggregateClass
     * @psalm-param array<int, \ServiceBus\EventSourcing\EventStream\AggregateEvent> $events
     *
     * @param \ServiceBus\EventSourcing\EventStream\AggregateEvent[] $events
     */
    public function __construct(
        AggregateId $id,
        string $aggregateClass,
        array $events,
        \DateTimeImmutable $createdAt,
        ?\DateTimeImmutable $closedAt
    ) {
        $this->id             = $id;
        $this->aggregateClass = $aggregateClass;
        $this->events         = self::sortEvents($events);
        $this->originEvents   = self::extractOriginEvents($this->events);
        $this->createdAt      = $createdAt;
        $this->closedAt       = $closedAt;
    }

    /**
     * @psalm-param  array<int, \ServiceBus\EventSourcing\EventStream\AggregateEvent> $events
     *
     * @psalm-return array<int, \ServiceBus\EventSourcing\EventStream\AggregateEvent>
     */
    private static function sortEvents(array $events): array
    {
        $result = [];

        foreach ($events as $aggregateEvent)
        {
            /** @var \ServiceBus\EventSourcing\EventStream\AggregateEvent $aggregateEvent */
            $result[$aggregateEvent->playhead] = $aggregateEvent;
        }

        \ksort($result);

        return $result;
    }

    /**
     * @psalm-param  array<int, \ServiceBus\EventSourcing\EventStream\AggregateEvent> $events
     * @psalm-return array<int, object>
     *
     * @param \ServiceBus\EventSourcing\EventStream\AggregateEvent[] $events
     *
     * @return object[]
     */
    private static function extractOriginEvents(array $events): array
    {
        return \array_map(
            static function(AggregateEvent $event): object
            {
                return $event->event;
            },
            $events
        );
    }
}