DefaultPipelineContext

Complexity

Total Complexity

10

Size/Duplication

Total Lines	103
Duplicated Lines	0 %

Coupling/Cohesion

Components	1
Dependencies	13

8 Methods

Rating	Name	Duplication	Size	Complexity
A	aFileNamedWith()	0	4	1
A	iCreateCsvToConsolePipeline()	0	10	1
A	iCreateCsvToDatabasePipeline()	0	17	1
A	iProcessIt()	0	4	1
A	iShouldSeeInConsole()	0	7	1
A	iShouldSeeInDatabase()	0	14	2
A	createCsvExtractor()	0	4	1
A	getConnection()	0	9	2

<?php

use Behat\Gherkin\Node\TableNode;
use Behat\Behat\Context\Context;
use Behat\Behat\Context\SnippetAcceptingContext;
use Doctrine\DBAL\DriverManager;
use Behat\Gherkin\Node\PyStringNode;
use Symfony\Component\Console\Helper\Table;
use Symfony\Component\Console\Output\BufferedOutput;
use Extraload\Pipeline\DefaultPipeline;
use Extraload\Extractor\CsvExtractor;
use Extraload\Transformer\NoopTransformer;
use Extraload\Transformer\CallbackTransformer;
use Extraload\Loader\ConsoleLoader;
use Extraload\Loader\Doctrine\DbalLoader;

class DefaultPipelineContext extends BaseContext implements Context, SnippetAcceptingContext
{
    private $workingTable = 'book';
    private $workingFile;
    private $pipeline;
    private $output;
    private $connection;

    /**
     * @Given a file named :name with:
     */
    public function aFileNamedWith($name, PyStringNode $content)
    {
        $this->workingFile = $this->createFileFromStringNode($name, $content);
    }

    /**
     * @Given I create csv to console pipeline
     */
    public function iCreateCsvToConsolePipeline()
    {
        return $this->pipeline = new DefaultPipeline(
            $this->createCsvExtractor(),
            new NoopTransformer(),
            new ConsoleLoader(
                new Table($this->output = new BufferedOutput())
            )
        );
    }

    /**
     * @Given I create csv to database pipeline
     */
    public function iCreateCsvToDatabasePipeline()
    {
        return $this->pipeline = new DefaultPipeline(
            $this->createCsvExtractor(),
            new CallbackTransformer(function ($data) {
                return [
                    'isbn' => $data[0],
                    'title' => $data[1],
                    'author' => $data[2],
                ];
            }),
            new DbalLoader(
                $this->getConnection(),
                $this->workingTable
            )
        );
    }

    /**
     * @Given I process it
     */
    public function iProcessIt()
    {
        $this->pipeline->process();
    }

    /**
     * @Then I should see in console:
     */
    public function iShouldSeeInConsole(PyStringNode $expected)
    {
        $expected = $this->stringNodeToString($expected);
        $actual = trim($this->output->fetch());

        PHPUnit_Framework_Assert::assertEquals($expected, $actual);
    }

    /**
     * @Then I should see in database:
     */
    public function iShouldSeeInDatabase(TableNode $table)
    {
        $actual = $this->getConnection()
            ->createQueryBuilder()
            ->select('*')
            ->from($this->workingTable)
            ->execute()
            ->fetchAll()
        ;

        foreach ($table->getHash() as $key => $expected) {
            PHPUnit_Framework_Assert::assertEquals($expected, $actual[$key]);
        }
    }

    private function createCsvExtractor()
    {
        return new CsvExtractor(new \SplFileObject($this->workingFile));
    }

    private function getConnection()
    {
        if (null === $this->connection) {
            $this->connection = DriverManager::getConnection(['url' => 'sqlite:///:memory:']);
            $this->connection->exec(sprintf('CREATE TABLE %s(isbn, title, author)', $this->workingTable));
        }

        return $this->connection;
    }
}