Nip\Records\Locator\Resolver\HasResolverPipelineTrait

Complexity

Total Complexity

7

Size/Duplication

Total Lines	57
Duplicated Lines	0 %

Test Coverage

Coverage

47.06%

Importance

Changes	1
Bugs	0	Features	1

6 Methods

Rating	Name	Duplication	Size	Complexity
A	setCallPipelineBuilder()	0	3	1
A	buildCallPipeline()	0	3	1
A	addCallPipeline()	0	3	1
A	getCallPipelineBuilder()	0	6	2
A	initCallPipeline()	0	3	1
A	processCommand()	0	4	1

<?php

namespace Nip\Records\Locator\Resolver;

use League\Pipeline\InterruptibleProcessor;
use Nip\Records\Locator\Resolver\Commands\Command;
use Nip\Records\Locator\Resolver\Pipeline\PipelineBuilder;
use Nip\Records\Locator\Resolver\Pipeline\Stages\StageInterface;
use Psr\Http\Message\ResponseInterface;

/**
 * Trait HasResolverPipelineTrait
 * @package Nip\Records\Locator\Resolver
 */
trait HasResolverPipelineTrait
{
    /**
     * @var null|PipelineBuilder
     */
    protected $callPipelineBuilder = null;

    /**
     * @param Command $command
     * @return Command
     * @throws ForwardException
     */
    protected function processCommand(Command $command)
    {
        $pipeline = $this->buildCallPipeline();
        return $pipeline->process($command);
    }

    /**
     * @return \League\Pipeline\PipelineInterface|\League\Pipeline\Pipeline
     */
    protected function buildCallPipeline()
    {
        return $this->getCallPipelineBuilder()->build();
    }

    /**
     * @return PipelineBuilder
     */
    public function getCallPipelineBuilder()
    {
        if ($this->callPipelineBuilder === null) {
            $this->initCallPipeline();
        }
        return $this->callPipelineBuilder;
    }

    /**
     * @param StageInterface $stage
     */
    public function addCallPipeline(StageInterface $stage)
    {
        $this->getCallPipelineBuilder()->add($stage);
    }

    /**
     * @param PipelineBuilder $callPipelineBuilder
     */
    public function setCallPipelineBuilder(PipelineBuilder $callPipelineBuilder): void
    {
        $this->callPipelineBuilder = $callPipelineBuilder;
    }


    public function initCallPipeline()
    {
        $this->callPipelineBuilder = (new PipelineBuilder);
    }
}