Domain\Eventing\CommittedEvents

Complexity

Total Complexity

7

Size/Duplication

Total Lines	35
Duplicated Lines	0 %

Coupling/Cohesion

Components	0
Dependencies	3

Importance

Changes	2
Bugs	0	Features	1

3 Methods

Rating	Name	Duplication	Size	Complexity
B	__construct()	0	18	5
A	getFromVersion()	0	4	1
A	getToVersion()	0	4	1

<?php

namespace Domain\Eventing;

use Domain\Identity\Identity;
use Domain\Eventing\Exception\CorruptAggregateHistory;

/**
 * @author Sebastiaan Hilbers <bashilbers@gmail.com>
 */
class CommittedEvents extends AbstractEventStream
{
    private $fromVersion;

    private $toVersion;

    public function __construct(Identity $identity, array $events)
    {
        $this->identity = $identity;

        foreach ($events as $event) {
            if (!$event instanceof DomainEvent || !$event->getAggregateIdentity()->equals($identity)) {
                throw new CorruptAggregateHistory;
            }

            $this->events[] = $event;
        }

        if (count($events) > 0) {
            $this->fromVersion = array_shift(array_values($events));

array_values($events) cannot be passed to array_shift() as the parameter $array expects a reference.

            $this->toVersion = array_pop(array_values($events));

array_values($events) cannot be passed to array_pop() as the parameter $array expects a reference.

            reset($this->events);
        }
    }

    public function getFromVersion()
    {
        return $this->fromVersion->version;
    }

    public function getToVersion()
    {
        return $this->toVersion;
    }
}