Graze\CsvToken\Parser

Complexity

Total Complexity

22

Size/Duplication

Total Lines	118
Duplicated Lines	8.47 %

Coupling/Cohesion

Components	1
Dependencies	1

Test Coverage

Coverage

100%

Importance

Changes	2
Bugs	1	Features	0

5 Methods

Rating	Name	Duplication	Size	Complexity
A	__construct()	0	4	1
A	addValueParser()	0	4	1
A	removeValueParser()	0	7	2
A	hasValueParser()	0	4	1
C	parse()	10	68	17

<?php

namespace Graze\CsvToken;

use ArrayIterator;
use Graze\CsvToken\Tokeniser\Token;
use Graze\CsvToken\ValueParser\Value;
use Graze\CsvToken\ValueParser\ValueParserInterface;
use Iterator;
use RuntimeException;

class Parser implements ParserInterface
{
    /** @var ValueParserInterface[] */
    private $valueParsers = [];

    /**
     * Parser constructor.
     *
     * @param ValueParserInterface[] $valueParsers
     */
    public function __construct(array $valueParsers = [])
    {
        array_map([$this, 'addValueParser'], $valueParsers);
    }

    /**
     * @param Iterator $tokens
     *
     * @return Iterator Iterator of csv line Iterators
     */
    public function parse(Iterator $tokens)
    {
        $value = new Value($this->valueParsers);
        $row = new ArrayIterator();

        $tokens->rewind();
        /** @var Token $token */
        $token = $tokens->current();
        while (!is_null($token)) {
            switch (true) {
                case $token->getType() == Token::T_ESCAPE:
                    $tokens->next();
                    $token = $tokens->current();
                    if (is_null($token)) {
                        throw new RuntimeException(
                            "Invalid CSV: The csv strings final character is an escape character"
                        );
                    }
                    $value->addContent($token->getContent());
                    break;

                case ($value->isInQuotes() && $token->getType() == Token::T_DOUBLE_QUOTE):
                    $value->addContent(substr($token->getContent(), 0, $token->getLength() / 2));
                    break;

                case $token->getType() == Token::T_QUOTE:
                    $value->setInQuotes(!$value->isInQuotes());
                    break;

                case $value->isInQuotes():
                    $value->addContent($token->getContent());
                    break;

                case ($value->isEmpty()
                    && !$value->isInQuotes()
                    && !$value->wasQuoted()
                    && $token->getType() == Token::T_NULL):
                    $value->addContent($token->getContent());
                    $value->setIsNull();
                    break;

                case (!$value->isInQuotes() && $token->getType() == Token::T_DELIMITER):

This code seems to be duplicated across your project.

                    $row->append($value->getValue());
                    $value->reset();
                    break;

                case (!$value->isInQuotes() && $token->getType() == Token::T_NEW_LINE):

This code seems to be duplicated across your project.

                    $row->append($value->getValue());
                    $value->reset();
                    yield $row;
                    $row = new ArrayIterator();
                    break;

                default:
                    $value->addContent($token->getContent());
                    break;
            }

            $tokens->next();
            $token = $tokens->current();
        }

        if (!$value->isEmpty()) {
            $row->append($value->getValue());
        }

        yield new ArrayIterator($row);
    }

    /**
     * @param ValueParserInterface $valueParser
     */
    public function addValueParser(ValueParserInterface $valueParser)
    {
        $this->valueParsers[] = $valueParser;
    }

    /**
     * @param ValueParserInterface $valueParser
     */
    public function removeValueParser(ValueParserInterface $valueParser)
    {
        $index = array_search($valueParser, $this->valueParsers, true);
        if ($index !== false) {
            unset($this->valueParsers[$index]);
        }
    }

    /**
     * @param ValueParserInterface $valueParser
     *
     * @return bool
     */
    public function hasValueParser(ValueParserInterface $valueParser)
    {
        return in_array($valueParser, $this->valueParsers);
    }
}