Coco\SourceWatcher\Tests\Core\PipelineTest

Complexity

Total Complexity

8

Size/Duplication

Total Lines	78
Duplicated Lines	0 %

Importance

Changes	1
Bugs	0	Features	0

7 Methods

Rating	Name	Duplication	Size	Complexity
A	testSetGetSteps()	0	18	1
A	setUp()	0	18	1
A	testExecute()	0	3	1
A	testIterator()	0	7	2
A	testPipeStep()	0	7	1
A	testGetResults()	0	5	1
A	tearDown()	0	3	1

<?php declare( strict_types=1 );

namespace Coco\SourceWatcher\Tests\Core;

use Coco\SourceWatcher\Core\Extractors\CsvExtractor;
use Coco\SourceWatcher\Core\IO\Inputs\FileInput;
use Coco\SourceWatcher\Core\Loader;
use Coco\SourceWatcher\Core\Loaders\DatabaseLoader;
use Coco\SourceWatcher\Core\Pipeline;
use Coco\SourceWatcher\Core\Transformer;
use Coco\SourceWatcher\Core\Transformers\RenameColumnsTransformer;
use PHPUnit\Framework\TestCase;

/**
 * Class PipelineTest
 *
 * @package Coco\SourceWatcher\Tests\Core
 */
class PipelineTest extends TestCase
{
    private Pipeline $pipeline;

    protected function setUp () : void
    {
        $this->pipeline = new Pipeline();

        $csvExtractor = new CsvExtractor();
        $csvExtractor->setInput( new FileInput( __DIR__ . "/../../samples/data/csv/csv1.csv" ) );

        // pipe the extractor
        $this->pipeline->pipe( $csvExtractor );

        $transformer = new RenameColumnsTransformer();
        $transformer->options( [ "columns" => [ "email" => "email_address" ] ] );

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

        // pipe the loader
        $this->pipeline->pipe( $this->createMock( DatabaseLoader::class ) );
    }

    protected function tearDown () : void
    {
        unset( $this->pipeline );
    }

    public function testExecute () : void
    {
        $this->assertNull( $this->pipeline->execute() );

Are you sure the usage of $this->pipeline->execute() targeting Coco\SourceWatcher\Core\Pipeline::execute() seems to always return null.

    }

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

        $this->assertNotNull( $this->pipeline->getResults() );
    }

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

        foreach ( $this->pipeline as $key => $value ) {
            $this->assertNotNull( $key );
            $this->assertNotNull( $value );
        }
    }

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

        $givenSteps = [];
        $expectedSteps = [];

        $transformer = $this->createMock( Transformer::class );
        $givenSteps[] = $transformer;
        $expectedSteps[] = $transformer;

        $loader = $this->createMock( Loader::class );
        $givenSteps[] = $loader;
        $expectedSteps[] = $loader;

        $this->pipeline->setSteps( $givenSteps );

        $this->assertEquals( $expectedSteps, $this->pipeline->getSteps() );
    }

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

        $transformer = $this->createMock( Transformer::class );

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

Are you sure the usage of $this->pipeline->pipe($transformer) targeting Coco\SourceWatcher\Core\Pipeline::pipe() seems to always return null.

    }
}