fab2s\NodalFlow\Nodes\AggregateNode

Complexity

Total Complexity

7

Size/Duplication

Total Lines	76
Duplicated Lines	0 %

Coupling/Cohesion

Components	1
Dependencies	5

Importance

Changes	4
Bugs	0	Features	0

3 Methods

Rating	Name	Duplication	Size	Complexity
A	__construct()	0	6	1
A	addTraversable()	0	6	1
B	getTraversable()	0	29	5

<?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\Nodes;

use fab2s\NodalFlow\Flows\FlowInterface;
use fab2s\NodalFlow\NodalFlow;
use fab2s\NodalFlow\NodalFlowException;

/**
 * class AggregateNode
 */
class AggregateNode extends PayloadNodeAbstract implements AggregateNodeInterface
{
    /**
     * The underlying pseudo Flow
     *
     * @var FlowInterface
     */
    protected $payload;

    /**
     * Instantiate an Aggregate Node
     *
     * @param bool $isAReturningVal
     *
     * @throws NodalFlowException
     */
    public function __construct($isAReturningVal)
    {
        parent::__construct(new NodalFlow, $isAReturningVal);
        $this->isATraversable = true;
        $this->isAFlow        = false;
    }

    /**
     * Add a traversable to the aggregate
     *
     * @param TraversableNodeInterface $node
     *
     * @throws NodalFlowException
     *
     * @return $this
     */
    public function addTraversable(TraversableNodeInterface $node)
    {
        $this->payload->add($node);

        return $this;
    }

    /**
     * Get the traversable to traverse within the Flow
     *
     * @param mixed $param
     *
     * @return \Generator
     */
    public function getTraversable($param)
    {
        $value = null;
        /** @var $nodes TraversableNodeInterface[] */
        $nodes = $this->payload->getNodes();
        foreach ($nodes as $node) {
            $returnVal = $node->isReturningVal();
            $nodeStats = &$node->getCarrier()->getFlowMap()->getNodeStat($node->getId());
            foreach ($node->getTraversable($param) as $value) {
                ++$nodeStats['num_iterate'];
                if ($returnVal) {
                    yield $value;
                    continue;
                }

                yield $param;
            }

            ++$nodeStats['num_exec'];
            if ($returnVal) {
                // since this node is returning something
                // we will pass its last yield to the next
                // traversable. It will be up to him to
                // do whatever is necessary with it, including
                // nothing
                $param = $value;
            }
        }
    }
}