C4tech\RayEmitter\Domain\Repository

Complexity

Total Complexity

11

Size/Duplication

Total Lines	105
Duplicated Lines	0 %

Coupling/Cohesion

Components	1
Dependencies	4

Test Coverage

Coverage

95.65%

Importance

Changes	9
Bugs	0	Features	0

4 Methods

Rating	Name	Duplication	Size	Complexity
A	get()	0	6	1
B	handle()	0	46	6
A	create()	0	4	1
A	find()	0	18	3

<?php namespace C4tech\RayEmitter\Domain;

use C4tech\RayEmitter\Contracts\Domain\Command as CommandInterface;
use C4tech\RayEmitter\Contracts\Domain\Repository as RepositoryInterface;
use C4tech\RayEmitter\Facades\EventStore;
use C4tech\RayEmitter\Exceptions\OutdatedSequence;
use C4tech\RayEmitter\Exceptions\SequenceMismatch;

abstract class Repository implements RepositoryInterface
{
    /**
     * Aggregate Cache
     * @var array
     */
    protected static $aggregates = [];

    /**
     * @inheritDoc
     */
    public static function get($identifier)
    {
        $aggregate = static::find($identifier);

        return $aggregate->getEntity();
    }

    /**
     * @inheritDoc
     */
    public static function handle(CommandInterface $command)
    {
        $aggregate = static::find($command->getAggregateId());

        // Optimistic concurrency handling
        $expected = $command->getExpectedSequence();
        $current = $aggregate->getSequence();
        if ($expected < $current) {
            throw new OutdatedSequence(
                sprintf(
                    'The Aggregate %s has newer data than expected (%s v %s).',
                    get_class($aggregate),
                    $expected,
                    $current
                ),
                409
            );
        } elseif ($expected > $current) {
            throw new SequenceMismatch(
                sprintf(
                    'The Aggregate %s is expected to have more data than it does (%s v %s).',
                    get_class($aggregate),
                    $expected,
                    $current
                ),
                422
            );
        }

        $identifier = null;

        // Queue event for storage
        if ($event = $aggregate->handle($command)) {
            $aggregate->apply($event);
            EventStore::enqueue($event);
            $identifier = $event->getId();
        }


        // Cache the aggregate in memory if it is not already.
        if (!empty($identifier) && !isset(self::$aggregates[$identifier])) {
            self::$aggregates[$identifier] = $aggregate;
        }

        return $identifier;
    }

    /**
     * Create
     *
     * Generate a new Aggregate with no history.
     * @return Aggregate
     */
    protected static function create()
    {
        throw new Exception('The ' . static::class . '::create method must be defined');
    }

    /**
     * Find
     *
     * Restore an existing Aggregate from the recorded events related to it.
     * @param  void|string $identifier Aggregate root entity identifier.
     * @return Aggregate
     */
    protected static function &find($identifier = null)
    {
        $aggregate = static::create();

        if ($identifier) {

The expression $identifier of type null|string is loosely compared to true; this is ambiguous if the string can be empty. You might want to explicitly use !== null instead.

            // Cache hydrated aggregate
            if (!isset(self::$aggregates[$identifier])) {
                $events = EventStore::getFor($identifier);
                $aggregate->hydrate($events);

                self::$aggregates[$identifier] = $aggregate;
            }

            $aggregate = self::$aggregates[$identifier];
        }

        return $aggregate;
    }
}