Darkilliant\ImportBundle\Step\CsvExtractorStep

Complexity

Total Complexity

8

Size/Duplication

Total Lines	59
Duplicated Lines	0 %

Test Coverage

Coverage

100%

Importance

Changes

0

8 Methods

Rating	Name	Duplication	Size	Complexity
A	next()	0	6	1
A	configureOptionResolver()	0	5	1
A	__construct()	0	3	1
A	execute()	0	9	1
A	describe()	0	3	1
A	count()	0	5	1
A	valid()	0	3	1
A	getProgress()	0	3	1

<?php

namespace Darkilliant\ImportBundle\Step;

use Darkilliant\ImportBundle\Extractor\CsvExtractor;
use Symfony\Component\OptionsResolver\OptionsResolver;
use Darkilliant\ProcessBundle\State\ProcessState;
use Darkilliant\ProcessBundle\Step\AbstractConfigurableStep;
use Darkilliant\ProcessBundle\Step\IterableStepInterface;

class CsvExtractorStep extends AbstractConfigurableStep implements IterableStepInterface
{
    /** @var CsvExtractor */
    private $extractor;

    /** @var \Generator */
    private $iterator;

    public function __construct(CsvExtractor $extractor)
    {
        $this->extractor = $extractor;
    }

    public function configureOptionResolver(OptionsResolver $resolver): OptionsResolver
    {
        $resolver->setRequired(['filepath', 'delimiter', 'colums_names']);

        return parent::configureOptionResolver($resolver);
    }

    public function execute(ProcessState $state)
    {
        $this->iterator = $this->extractor->extract(
            $state->getOptions()['filepath'],
            $state->getOptions()['delimiter'],
            $state->getOptions()['colums_names']
        );

        $state->setContext('filepath', $state->getOptions()['filepath']);
    }

    public function next(ProcessState $state)
    {
        $state->setContext('line_csv', $this->iterator->key());
        $state->setData($this->iterator->current());

        $this->iterator->next();
    }

    public function count(ProcessState $state)
    {
        $file = $state->getOptions()['filepath'];

        return (int) `cat $file | wc -l`;
    }

    public function valid(ProcessState $state)
    {
        return $this->iterator->valid();
    }

    public function getProgress(ProcessState $state)
    {
        return $this->iterator->key();
    }

    public function describe(ProcessState $state)
    {
        $state->info('iterate on each line of {filepath} and transform into array', $state->getOptions());
    }
}