Coco\SourceWatcher\Core\SourceWatcher

Complexity

Total Complexity

8

Size/Duplication

Total Lines	59
Duplicated Lines	0 %

Importance

Changes	1
Bugs	0	Features	0

5 Methods

Rating	Name	Duplication	Size	Complexity
A	load()	0	13	2
A	extract()	0	13	2
A	__construct()	0	4	1
A	run()	0	3	1
A	transform()	0	12	2

<?php

namespace Coco\SourceWatcher\Core;

use Coco\SourceWatcher\Core\IO\Inputs\Input;

/**
 * Class SourceWatcher
 * @package Coco\SourceWatcher\Core
 */
class SourceWatcher
{
    private StepLoader $stepLoader;

    private Pipeline $pipeline;

    public function __construct ()
    {
        $this->stepLoader = new StepLoader();
        $this->pipeline = new Pipeline();
    }

    public function extract ( string $extractorName, Input $input, array $options = [] ) : SourceWatcher
    {
        try {
            $extractor = $this->stepLoader->getStep( Extractor::class, $extractorName );
            $extractor->setInput( $input );

The method setInput() does not exist on Coco\SourceWatcher\Core\Step. It seems like you code against a sub-type of Coco\SourceWatcher\Core\Step such as Coco\SourceWatcher\Core\Extractor.

            $extractor->options( $options );

            $this->pipeline->setExtractor( $extractor );

It seems like $extractor can also be of type null; however, parameter $extractor of Coco\SourceWatcher\Core\Pipeline::setExtractor() does only seem to accept Coco\SourceWatcher\Core\Extractor, maybe add an additional type check?

        } catch ( SourceWatcherException $sourceWatcherException ) {

Consider adding a comment why this CATCH block is empty.

        }

        return $this;
    }

    public function transform ( string $transformerName, array $options = [] ) : SourceWatcher
    {
        try {
            $transformer = $this->stepLoader->getStep( Transformer::class, $transformerName );
            $transformer->options( $options );

            $this->pipeline->pipe( $transformer );

It seems like $transformer can also be of type null; however, parameter $step of Coco\SourceWatcher\Core\Pipeline::pipe() does only seem to accept Coco\SourceWatcher\Core\Step, maybe add an additional type check?

        } catch ( SourceWatcherException $sourceWatcherException ) {

Consider adding a comment why this CATCH block is empty.

        }

        return $this;
    }

    public function load ( string $loaderName, $output, $options = [] ) : SourceWatcher
    {
        try {
            $loader = $this->stepLoader->getStep( Loader::class, $loaderName );
            $loader->setOutput( $output );

The method setOutput() does not exist on Coco\SourceWatcher\Core\Step. It seems like you code against a sub-type of Coco\SourceWatcher\Core\Step such as Coco\SourceWatcher\Core\Loader.

            $loader->options( $options );

            $this->pipeline->pipe( $loader );

It seems like $loader can also be of type null; however, parameter $step of Coco\SourceWatcher\Core\Pipeline::pipe() does only seem to accept Coco\SourceWatcher\Core\Step, maybe add an additional type check?

        } catch ( SourceWatcherException $sourceWatcherException ) {

Consider adding a comment why this CATCH block is empty.

        }

        return $this;
    }

    public function run () : void
    {
        $this->pipeline->execute();
    }
}