Rawkode\Eidetic\EventSourcing\Repository

Complexity

Total Complexity

6

Size/Duplication

Total Lines	64
Duplicated Lines	0 %

Coupling/Cohesion

Components	1
Dependencies	3

Test Coverage

Coverage

0%

Importance

Changes	2
Bugs	0	Features	2

5 Methods

Rating	Name	Duplication	Size	Complexity
A	__construct()	0	5	1
A	createForType()	0	4	1
A	load()	0	10	1
A	save()	0	5	1
A	enforceTypeConstraint()	0	6	2

<?php

namespace Rawkode\Eidetic\EventSourcing;

use Rawkode\Eidetic\EventStore\EventStore;

/**
 * Class Repository
 * @package Rawkode\Eidetic\EventSourcing
 */
final class Repository
{
    /** @var $entityClass */
    private $entityClass;

    /** @var EventStore $eventStore */
    private $eventStore;

    /**
     * @param string $class
     * @param EventStore $eventStore
     */
    private function __construct($class, EventStore $eventStore)
    {
        $this->entityClass = $class;
        $this->eventStore = $eventStore;
    }

    /**
     * @param $class
     * @param EventStore $eventStore
     * @return Repository
     */
    public static function createForType($class, EventStore $eventStore)
    {
        return new self($class, $eventStore);
    }

    /**
     * @param $key
     * @return mixed
     */
    public function load($key)
    {
        $class = $this->eventStore->getClassForKey($key);

        $this->enforceTypeConstraint($class);

        $events = $this->eventStore->retrieve($key);

        return $class::initialise($events);
    }

    /**
     * @param EventSourcedEntity $eventSourcedEntity
     * @throws IncorrectEntityClassException
     */
    public function save(EventSourcedEntity $eventSourcedEntity)
    {
        $this->enforceTypeConstraint(get_class($eventSourcedEntity));
        $this->eventStore->store($eventSourcedEntity->identifier(), $eventSourcedEntity->stagedEvents());
    }

    /**
     * @param $class
     * @throws IncorrectEntityClassException
     */
    private function enforceTypeConstraint($class)
    {
        if ($class !== $this->entityClass) {
            throw new IncorrectEntityClassException($class . ' is not same as ' . $this->entityClass);
        }
    }
}