Coco\SourceWatcher\Core\SourceWatcher

Complexity

Total Complexity

16

Size/Duplication

Total Lines	149
Duplicated Lines	0 %

Importance

Changes	1
Bugs	0	Features	0

9 Methods

Rating	Name	Duplication	Size	Complexity
A	__construct()	0	4	1
A	getStepLoader()	0	3	1
A	getPipeline()	0	3	1
A	load()	0	19	2
A	extract()	0	19	2
A	run()	0	3	1
A	transform()	0	18	2
A	flush()	0	3	1
A	save()	0	35	5

<?php

namespace Coco\SourceWatcher\Core;

use Coco\SourceWatcher\Core\IO\Inputs\Input;
use Coco\SourceWatcher\Core\IO\Outputs\Output;
use Coco\SourceWatcher\Utils\Internationalization;
use Ramsey\Uuid\Uuid;


/**
 * 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 getStepLoader () : StepLoader
    {
        return $this->stepLoader;
    }

    public function getPipeline () : Pipeline
    {
        return $this->pipeline;
    }

    /**
     * @param string $extractorName
     * @param Input|null $input
     * @param array $options
     * @return $this
     * @throws SourceWatcherException
     */
    public function extract ( string $extractorName, ?Input $input, array $options = [] ) : SourceWatcher
    {
        $extractor = $this->stepLoader->getStep( Extractor::class, $extractorName );

        if ( $extractor == null ) {
            throw new SourceWatcherException(
                sprintf(
                    Internationalization::getInstance()->getText( SourceWatcher::class, "Extractor_Not_Found" ),
                    $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->pipe( $extractor );

        return $this;
    }

    /**
     * @param string $transformerName
     * @param array $options
     * @return $this
     * @throws SourceWatcherException
     */
    public function transform ( string $transformerName, array $options = [] ) : SourceWatcher
    {
        $transformer = $this->stepLoader->getStep( Transformer::class, $transformerName );

        if ( $transformer == null ) {
            throw new SourceWatcherException(
                sprintf(
                    Internationalization::getInstance()->getText( SourceWatcher::class, "Transformer_Not_Found" ),
                    $transformerName
                )
            );
        }

        $transformer->options( $options );

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

        return $this;
    }

    /**
     * @param string $loaderName
     * @param Output $output
     * @param array $options
     * @return $this
     * @throws SourceWatcherException
     */
    public function load ( string $loaderName, Output $output, array $options = [] ) : SourceWatcher
    {
        $loader = $this->stepLoader->getStep( Loader::class, $loaderName );

        if ( $loader == null ) {
            throw new SourceWatcherException(
                sprintf(
                    Internationalization::getInstance()->getText( SourceWatcher::class, "Loader_Not_Found" ),
                    $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 );

        return $this;
    }

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

    public function flush () : void
    {
        $this->pipeline = new Pipeline();
    }

    public function save ( string $name = null ) : string
    {
        $arrayRepresentation = [];

        $steps = $this->pipeline->getSteps();

        foreach ( $steps as $currentStep ) {
            $arrayRepresentation[] = $currentStep->getArrayRepresentation();
        }

        $jsonRepresentation = json_encode( $arrayRepresentation, JSON_PRETTY_PRINT );

        $mainDirectory = $_SERVER["HOME"] . DIRECTORY_SEPARATOR . ".source-watcher";

        if ( !file_exists( $mainDirectory ) ) {
            mkdir( $mainDirectory, 0777, true );
        }

        $transformationsDirectory = $mainDirectory . DIRECTORY_SEPARATOR . "transformations";

        if ( !file_exists( $transformationsDirectory ) ) {
            mkdir( $transformationsDirectory, 0777, true );
        }

        if ( empty( $name ) ) {
            $uuid = Uuid::uuid4();

            $name = $uuid->toString();
        }

        $transformationFile = $transformationsDirectory . DIRECTORY_SEPARATOR . $name . ".swt";

        file_put_contents( $transformationFile, $jsonRepresentation );

        return $transformationFile;
    }
}