Domain\Eventing\RedisEventStore

Complexity

Total Complexity

5

Size/Duplication

Total Lines	35
Duplicated Lines	0 %

Coupling/Cohesion

Components	1
Dependencies	1

Importance

Changes	1
Bugs	0	Features	1

3 Methods

Rating	Name	Duplication	Size	Complexity
A	__construct()	0	4	1
A	commit()	0	9	2
A	getAggregateHistoryFor()	0	15	2

<?php

namespace Domain\Eventing;

use Predis\Client;
use Domain\Identity\Identity;
use Domain\Eventing\CommittedEvents;

/**
 * @author Sebastiaan Hilbers <bashilbers@gmail.com>
 */
final class RedisEventStore implements EventStore
{
    private $redis;

    public function __construct(Client $redis)
    {
        $this->redis = $redis;
    }

    public function commit(UncommittedEvents $events)
    {
        foreach ($events as $event) {
            $this->redis->rpush(
                (string) $event->getAggregateIdentity(),
                (string) serialize($event)
            );
        }
    }

    public function getAggregateHistoryFor(Identity $id, $offset = 0, $max = null)
    {
        if (is_null($max)) {
            $max = $this->redis->llen((string) $id);
        }

        $events = $this->redis->lrange((string) $id, $offset, $max);

        return new CommittedEvents(
            $id,
            array_map(function ($raw) {
                return unserialize($raw);
            }, $events)
        );
    }
}