Domain\Eventing\TimeMachine

Complexity

Total Complexity

9

Size/Duplication

Total Lines	48
Duplicated Lines	0 %

Coupling/Cohesion

Components	1
Dependencies	2

Importance

Changes	2
Bugs	0	Features	1

4 Methods

Rating	Name	Duplication	Size	Complexity
A	__construct()	0	4	1
A	attachListener()	0	4	1
A	attachListeners()	0	8	2
B	replayEvents()	0	22	5

<?php

namespace Domain\Eventing;

use Domain\Identity\Identity;
use Domain\Tools\ClassToString;

/**
 * @author Sebastiaan Hilbers <bashilbers@gmail.com>
 */
class TimeMachine
{
    protected $store;

    protected $listeners = [];

    public function __construct(EventStore $store)
    {
        $this->store = $store;
    }

    public function attachListener($eventName, Listener $listener)
    {
        $this->listeners[$eventName][] = $listener;
    }

    public function attachListeners(array $listeners)
    {
        foreach ($listeners as $event => $listener) {
            $this->attachListener($event, $listener);
        }

        return $this;
    }

    public function replayEvents(Identity $identity, $offset = null, $max = null)
    {
        $events = $this->store->getAggregateHistoryFor($identity, $offset, $max);

        foreach ($events as $event) {
            $method = 'when' . ClassToString::short($event);

            if (!isset($this->listeners[$method])) {
                continue;
            }

            if (is_array($this->listeners[$method])) {
                foreach ($this->listeners[$method] as $listener) {
                    call_user_func($listener, $event);
                }
            } else {
                call_user_func($this->listeners[$method], $event);
            }
        }

        return $this;
    }
}