Nip\Records\Locator\Resolver\Pipeline\PipelineBuilder

Complexity

Total Complexity

3

Size/Duplication

Total Lines	27
Duplicated Lines	0 %

Test Coverage

Coverage

100%

Importance

Changes	1
Bugs	0	Features	1

2 Methods

Rating	Name	Duplication	Size	Complexity
A	__construct()	0	6	1
A	build()	0	10	2

<?php

namespace Nip\Records\Locator\Resolver\Pipeline;

use League\Pipeline\InterruptibleProcessor;
use League\Pipeline\PipelineBuilder as AbstractBuilder;
use League\Pipeline\PipelineInterface;
use League\Pipeline\ProcessorInterface;
use Nip\Records\Locator\Resolver\Commands\Command;
use Nip\Records\Locator\Resolver\Pipeline\Stages\ClassInstance;
use Nip\Records\Locator\Resolver\Pipeline\Stages\NamespaceSearch;
use Nip\Records\Locator\Resolver\Pipeline\Stages\RegistryInstance;
use Nip\Records\Locator\Resolver\Pipeline\Stages\TableNameClassInstance;

/**
 * Class MethodsPipeline
 * @package Nip\Records\Locator\Resolver\Pipeline
 */
class PipelineBuilder extends AbstractBuilder
{
    public function __construct()
    {
        $this->add(new RegistryInstance());
        $this->add(new ClassInstance());
        $this->add(new NamespaceSearch());
        $this->add(new TableNameClassInstance());
    }

    /**
     * Build a new Pipeline object
     *
     * @param  ProcessorInterface|null $processor
     *
     * @return PipelineInterface
     */
    public function build(ProcessorInterface $processor = null): PipelineInterface
    {
        if ($processor == null) {
            $processor = new InterruptibleProcessor(
                function (Command $command) {
                    return !$command->hasInstance();
                }
            );
        }
        return parent::build($processor);
    }
}