fab2s\NodalFlow\Flows\FlowRegistry

Complexity

Total Complexity

11

Size/Duplication

Total Lines	114
Duplicated Lines	24.56 %

Coupling/Cohesion

Components	1
Dependencies	3

Importance

Changes

0

6 Methods

Rating	Name	Duplication	Size	Complexity
A	get()	0	4	1
A	load()	0	12	2
A	registerFlow()	14	14	2
A	registerNode()	14	14	2
A	getFlow()	0	4	2
A	getNode()	0	4	2

<?php

/*
 * This file is part of NodalFlow.
 *     (c) Fabrice de Stefanis / https://github.com/fab2s/NodalFlow
 * This source file is licensed under the MIT license which you will
 * find in the LICENSE file or at https://opensource.org/licenses/MIT
 */

namespace fab2s\NodalFlow\Flows;

use fab2s\NodalFlow\NodalFlowException;
use fab2s\NodalFlow\Nodes\NodeInterface;

/**
 * class FlowRegistry
 */
class FlowRegistry implements FlowRegistryInterface
{
    /**
     * @var array
     */
    protected static $registry = [];

    /**
     * @var FlowInterface[]
     */
    protected static $flows = [];

    /**
     * @var NodeInterface[]
     */
    protected static $nodes = [];

    /**
     * Get registry meta data reference
     *
     * @param string $flowId
     *
     * @return mixed
     */
    public function &get($flowId)
    {
        return static::$registry[$flowId];
    }

    /**
     * Used upon FlowMap un-serialization
     *
     * @param FlowInterface $flow
     * @param array         $entry
     *
     * @return $this
     */
    public function load(FlowInterface $flow, array $entry)
    {
        $this->registerFlow($flow);
        $flowId                    = $flow->getId();
        static::$registry[$flowId] = $entry;

        foreach ($flow->getNodes() as $node) {
            $this->registerNode($node);
        }

        return $this;
    }

    /**
     * @param FlowInterface $flow
     *
     * @throws NodalFlowException
     *
     * @return $this
     */
    public function registerFlow(FlowInterface $flow)

This method seems to be duplicated in your project.

    {
        $flowId = $flow->getId();
        if (isset(static::$flows[$flowId])) {
            throw new NodalFlowException('Duplicate Flow instances are not allowed', 1, null, [
                'flowClass' => get_class($flow),
                'flowId'    => $flowId,
            ]);
        }

        static::$flows[$flowId] = $flow;

        return $this;
    }

    /**
     * @param NodeInterface $node
     *
     * @throws NodalFlowException
     *
     * @return $this
     */
    public function registerNode(NodeInterface $node)

This method seems to be duplicated in your project.

    {
        $nodeId = $node->getId();
        if (isset(static::$nodes[$nodeId])) {
            throw new NodalFlowException('Duplicate Node instances are not allowed', 1, null, [
                'nodeClass' => get_class($node),
                'nodeId'    => $nodeId,
            ]);
        }

        static::$nodes[$nodeId] = $node;

        return $this;
    }

    /**
     * @param $flowId
     *
     * @return FlowInterface|null
     */
    public function getFlow($flowId)
    {
        return isset(static::$flows[$flowId]) ? static::$flows[$flowId] : null;
    }

    /**
     * @param $nodeId
     *
     * @return NodeInterface|null
     */
    public function getNode($nodeId)
    {
        return isset(static::$nodes[$nodeId]) ? static::$nodes[$nodeId] : null;
    }
}