Graze\DataFlow\Builder

Complexity

Total Complexity

9

Size/Duplication

Total Lines	72
Duplicated Lines	0 %

Coupling/Cohesion

Components	1
Dependencies	2

Test Coverage

Coverage

100%

Importance

Changes	2
Bugs	0	Features	0

3 Methods

Rating	Name	Duplication	Size	Complexity
A	addNamespace()	0	4	1
A	getNamespaces()	0	4	1
C	buildFlow()	0	27	7

<?php
/**
 * This file is part of graze/data-flow
 *
 * Copyright (c) 2016 Nature Delivered Ltd. <https://www.graze.com>
 *
 * For the full copyright and license information, please view the LICENSE
 * file that was distributed with this source code.
 *
 * @license https://github.com/graze/data-flow/blob/master/LICENSE.md
 * @link    https://github.com/graze/data-flow
 */

namespace Graze\DataFlow;

use Graze\DataFile\Helper\OptionalLoggerTrait;
use InvalidArgumentException;
use Psr\Log\LoggerAwareInterface;
use Psr\Log\LogLevel;
use ReflectionClass;

class Builder implements FlowBuilderInterface, LoggerAwareInterface
{
    use OptionalLoggerTrait;

    /**
     * @var string[]
     */
    protected $namespaces = [
        '', // allow Fully qualified class names to be built
        'Graze\\DataFlow\\Flow\\',
        'Graze\\DataFlow\\Flow\\Collection\\',
        'Graze\\DataFlow\\Flow\\File\\',
        'Graze\\DataFlow\\Flow\\File\\Compression\\',
        'Graze\\DataFlow\\Flow\\Runner\\',
    ];

    /**
     * Add a namespace to check for flow names within
     *
     * @param string $namespace
     *
     * @return void
     */
    public function addNamespace($namespace)
    {
        $this->namespaces[] = $namespace;
    }

    /**
     * @return string[]
     */
    public function getNamespaces()
    {
        return $this->namespaces;
    }

    /**
     * Create a new Flow based on a name
     *
     * @param mixed $flowName
     * @param array $arguments
     *
     * @return FlowInterface
     */
    public function buildFlow($flowName, array $arguments = [])
    {
        if ($flowName instanceof FlowInterface) {
            return $flowName;
        }
        foreach ($this->getNamespaces() as $namespace) {
            $className = $namespace . ucfirst($flowName);
            if (!class_exists($className)) {
                continue;
            }
            $reflection = new ReflectionClass($className);
            if (!$reflection->isSubclassOf(FlowInterface::class)) {
                throw new InvalidArgumentException(sprintf(
                    "'%s' from flowName: '%s' is not a valid DataFlow",
                    $className,
                    $flowName
                ));
            }
            $this->log(LogLevel::DEBUG, "Building flow: {class}", ['class' => $className]);
            $flow = $reflection->newInstanceArgs($arguments);
            if ($this->logger && ($flow instanceof LoggerAwareInterface)) {
                $flow->setLogger($this->logger);
            }
            return $flow;
        }
        throw new InvalidArgumentException(sprintf("'%s' is not a valid flow name", $flowName));
    }
}