Pipeline::execute() - Code Metrics - Inspection of "Adding changes to pipeline class and unit tests fo..." - TheCocoTeam/source-watcher-core - Measure and Improve Code Quality continuously with Scrutinizer

Passed

Push — master ( 3491bf...0603fe )

by Jean Paul

created 2020-05-19 00:36 UTC

Pipeline::execute() A

↳ Parent: Pipeline

Complexity

Conditions	6
Paths	7

Size

Total Lines	14
Code Lines	8

Duplication

Lines	0
Ratio	0 %

Importance

Changes

Metric	Value
cc	6
eloc	8
c	0
b	0
f	0
nc	7
nop	0
dl	0
loc	14
rs	9.2222

<?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;

    }

    /**
     * @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();
        $this->results = $this->extractor->extract();

        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;
    }
}


TheCocoTeam / source-watcher-core

Push — master ( 3491bf...0603fe )

Pipeline::execute() A

Complexity

Size

Duplication

Importance

Duplication Side-by-Side

Filter issues like