Coco\SourceWatcher\Core\Pipeline

Complexity

Total Complexity

17

Size/Duplication

Total Lines	112
Duplicated Lines	0 %

Importance

Changes	1
Bugs	0	Features	0

12 Methods

Rating	Name	Duplication	Size	Complexity
A	key()	0	3	1
A	current()	0	3	1
A	pipe()	0	3	1
A	rewind()	0	3	1
A	setSteps()	0	3	1
A	next()	0	3	1
A	getExtractor()	0	3	1
A	setExtractor()	0	3	1
A	execute()	0	14	6
A	getResults()	0	3	1
A	valid()	0	3	1
A	getSteps()	0	3	1

<?php

namespace Coco\SourceWatcher\Core;

use Iterator;

/**
 * Class Pipeline
 * @package Coco\SourceWatcher\Core
 */
class Pipeline implements Iterator
{
    /**
     * @var Extractor
     */
    private ?Extractor $extractor = null;

    /**
     * @var array
     */
    private array $steps = [];

    /**
     * @var array
     */
    private array $results = [];

    /**
     * @return Extractor
     */
    public function getExtractor () : Extractor
    {
        return $this->extractor;

The expression return $this->extractor could return the type null which is incompatible with the type-hinted return Coco\SourceWatcher\Core\Extractor. Consider adding an additional type-check to rule them out.

    }

    /**
     * @param Extractor $extractor
     */
    public function setExtractor ( Extractor $extractor ) : void
    {
        $this->extractor = $extractor;
    }

    /**
     * @return array
     */
    public function getSteps () : array
    {
        return $this->steps;
    }

    /**
     * @param array $steps
     */
    public function setSteps ( array $steps ) : void
    {
        $this->steps = $steps;
    }

    /**
     * @param Step $step
     */
    public function pipe ( Step $step ) : void
    {
        $this->steps[] = $step;
    }

    public function execute () : void
    {
        $this->results = $this->extractor->extract();

The method extract() does not exist on null.

        foreach ( $this->steps as $currentStep ) {
            if ( $currentStep instanceof Transformer ) {
                foreach ( $this->results as $currentIndex => $currentItem ) {
                    $currentStep->transform( $this->results[$currentIndex] );
                }
            }

            if ( $currentStep instanceof Loader ) {
                foreach ( $this->results as $currentIndex => $currentItem ) {
                    $currentStep->load( $currentItem );
                }
            }
        }
    }

    /**
     * @return array
     */
    public function getResults () : array
    {
        return $this->results;
    }

    /**
     * @var int
     */
    private int $index = 0;

    public function current ()
    {
        return $this->results[$this->index];
    }

    public function next ()
    {
        $this->index++;
    }

    public function key ()
    {
        return $this->index;
    }

    public function valid ()
    {
        return isset( $this->results[$this->key()] );
    }

    public function rewind ()
    {
        $this->index = 0;
    }
}