Gica\Cqrs\Saga\State\InMemoryStateManager

Complexity

Total Complexity

10

Size/Duplication

Total Lines	63
Duplicated Lines	0 %

Coupling/Cohesion

Components	1
Dependencies	0

Test Coverage

Coverage

100%

Importance

Changes

0

6 Methods

Rating	Name	Duplication	Size	Complexity
A	getStateClass()	0	12	2
A	loadState()	0	10	2
A	hasState()	0	6	1
A	updateState()	0	17	3
A	clearAllStates()	0	4	1
A	createStorage()	0	4	1

<?php
/**
 * Copyright (c) 2017 Constantin Galbenu <xprt64@gmail.com>
 */

namespace Gica\Cqrs\Saga\State;


class InMemoryStateManager implements ProcessStateLoader, ProcessStateUpdater
{
    private $states = [];

    public function loadState(string $stateClass, $stateId, string $namespace = 'global_namespace')
    {
        $key = $stateClass . $stateId;

        if (isset($this->states[$namespace][$key])) {
            return $this->states[$namespace][$key];
        }

        return null;
    }

    public function hasState(string $stateClass, $stateId, string $namespace)
    {
        $key = $stateClass . $stateId;

        return isset($this->states[$namespace][$key]);
    }

    public function updateState($stateId, callable $updater, string $namespace = 'global_namespace')
    {
        list($stateClass, $isOptional) = $this->getStateClass($updater);

        $oldState = $this->loadState($stateClass, $stateId, $namespace);
        if (!$this->hasState($stateClass, $stateId, $namespace)) {
            if (!$isOptional) {
                $oldState = new $stateClass;
            }
        }

        $newState = call_user_func($updater, $oldState);

        $key = $stateClass . $stateId;

        $this->states[$namespace][$key] = $newState;
    }

    private function getStateClass(callable $update)
    {
        $reflection = new \ReflectionFunction($update);

        if ($reflection->getNumberOfParameters() <= 0) {
            throw new \Exception("Updater callback must have one type-hinted parameter");
        }

        $parameter = $reflection->getParameters()[0];

        return [$parameter->getClass()->name, $parameter->isOptional()];
    }

    public function clearAllStates(string $namespace = 'global_namespace')
    {
        $this->states[$namespace] = [];
    }

    public function createStorage(string $namespace = 'global_namespace')
    {
        $this->states[$namespace] = [];
    }
}