Darkilliant\ImportBundle\Extractor\CsvExtractor

Complexity

Total Complexity

9

Size/Duplication

Total Lines	38
Duplicated Lines	0 %

Test Coverage

Coverage

100%

Importance

Changes

0

4 Methods

Rating	Name	Duplication	Size	Complexity
A	__construct()	0	3	1
A	isValidLine()	0	3	2
A	slugify()	0	5	1
A	extract()	0	15	5

<?php

declare(strict_types=1);

namespace Darkilliant\ImportBundle\Extractor;

use Cocur\Slugify\Slugify;

/**
 * @internal
 */
class CsvExtractor implements ExtractorInterface
{
    private $slugify;

    public function __construct(Slugify $slugify)
    {
        $this->slugify = $slugify;
    }

    public function extract(string $csvFilePath, string $delimiter = ',', array $columsNames = null, bool $skipFirstLine = true): \Traversable
    {
        $csvFileObjects = new \SplFileObject($csvFilePath);
        $csvFileObjects->setFlags((\SplFileObject::READ_CSV | \SplFileObject::SKIP_EMPTY | \SplFileObject::DROP_NEW_LINE | \ SplFileObject::READ_AHEAD));
        $csvFileObjects->setCsvControl($delimiter);

        $arrayKeys = array_map([$this, 'slugify'], $columsNames ?? (array) $csvFileObjects->current());
        $arrayKeys = array_map('trim', $arrayKeys);

        foreach ($csvFileObjects as $loopIndex => $csvFileObjectRow) {
            $currentData = (array) $csvFileObjectRow;
            if ((!$skipFirstLine || $csvFileObjects->key() > 0) && true === $this->isValidLine($currentData)) {
                $currentData = array_map('trim', $currentData);
                $arrayToYield = array_combine($arrayKeys, $currentData);
                yield $loopIndex => $arrayToYield;
            }
        }
    }

    private function slugify($key)
    {
        $key = str_replace('/', '_', $key);

        return $this->slugify->slugify($key, '_');
    }

    private function isValidLine(array $csvFileObjectRow): bool
    {
        return (count(array_keys($csvFileObjectRow, '')) === count($csvFileObjectRow)) ? false : true;
    }
}