Linio\Component\SpreadsheetParser\Parser\CsvParser

Complexity

Total Complexity

21

Size/Duplication

Total Lines	194
Duplicated Lines	7.22 %

Coupling/Cohesion

Components	1
Dependencies	0

Importance

Changes

0

8 Methods

Rating	Name	Duplication	Size	Complexity
A	__construct()	0	13	1
A	open()	0	10	2
A	getColumnNames()	0	15	3
A	getData()	14	14	2
A	close()	0	9	2
A	__destruct()	0	4	1
B	loadParserOptions()	0	22	6
A	readDataFromFile()	0	19	4

<?php

namespace Linio\Component\SpreadsheetParser\Parser;

class CsvParser implements ParserInterface
{
    const OPTION_HAS_COLUMN_NAMES = 'has_column_names';
    const OPTION_LENGTH = 'length';
    const OPTION_DELIMITER = 'delimiter';
    const OPTION_ENCLOSURE = 'enclosure';
    const OPTION_ESCAPE = 'escape';

    /**
     * @var string
     */
    protected $filePath;

    /**
     * @var resource
     */
    protected $handle;

    /**
     * @var bool
     */
    protected $hasColumnNames;

    /**
     * @var int
     */
    protected $length;

    /**
     * @var string
     */
    protected $delimiter;

    /**
     * @var string
     */
    protected $enclosure;

    /**
     * @var string
     */
    protected $escape;

    /**
     * @var array
     */
    protected $columnNames;

    /**
     * @param string $filePath
     */
    public function __construct($filePath, array $options = [])
    {
        $this->filePath = $filePath;

        // default options
        $this->hasColumnNames = true;
        $this->length = 0;
        $this->delimiter = ',';
        $this->enclosure = '"';
        $this->escape = '\\';

        $this->loadParserOptions($options);
    }

    /**
     * @return bool
     */
    public function open()
    {
        if ($this->handle) {
            return true;
        }

        $this->handle = fopen($this->filePath, 'r');

        return true;
    }

    /**
     * @SuppressWarnings(PHPMD.ExcessiveMethodLength)
     *
     * @return array|false
     */
    public function getColumnNames()
    {
        if (!$this->hasColumnNames) {
            return false;
        }

        if ($this->columnNames) {

The expression $this->columnNames of type array is implicitly converted to a boolean; are you sure this is intended? If so, consider using ! empty($expr) instead to make it clear that you intend to check for an array without elements.

            return $this->columnNames;
        }

        $this->open();
        $this->columnNames = fgetcsv($this->handle, $this->length, $this->delimiter, $this->enclosure, $this->escape);

        return $this->columnNames;
    }

    /**
     * @param int $numRows
     *
     * @return array
     */
    public function getData($numRows = 0)

This method seems to be duplicated in your project.

    {
        $this->close();
        $this->open();

        $skipLine = false;
        if ($this->hasColumnNames) {
            $skipLine = true;
        }

        $data = $this->readDataFromFile($numRows, $skipLine);

        return $data;
    }

    /**
     * @return bool
     */
    public function close()
    {
        if ($this->handle) {
            fclose($this->handle);
            $this->handle = null;
        }

        return true;
    }

    public function __destruct()
    {
        $this->close();
    }

    /**
     * @param array $options
     *
     * @SuppressWarnings(PHPMD.ExcessiveMethodLength)
     */
    protected function loadParserOptions(array $options)
    {
        if (isset($options[static::OPTION_HAS_COLUMN_NAMES])) {
            $this->hasColumnNames = $options[static::OPTION_HAS_COLUMN_NAMES];
        }

        if (isset($options[static::OPTION_LENGTH])) {
            $this->length = $options[static::OPTION_LENGTH];
        }

        if (isset($options[static::OPTION_DELIMITER])) {
            $this->delimiter = $options[static::OPTION_DELIMITER];
        }

        if (isset($options[static::OPTION_ENCLOSURE])) {
            $this->enclosure = $options[static::OPTION_ENCLOSURE];
        }

        if (isset($options[static::OPTION_ESCAPE])) {
            $this->escape = $options[static::OPTION_ESCAPE];
        }
    }

    /**
     * @param $numRows
     * @param $skipLine
     *
     * @SuppressWarnings(PHPMD.ExcessiveMethodLength)
     *
     * @return array
     */
    protected function readDataFromFile($numRows, $skipLine)
    {
        $data = [];
        while (($row = fgetcsv($this->handle, $this->length, $this->delimiter, $this->enclosure, $this->escape)) !== false) {
            if ($skipLine) {
                $skipLine = false;
                continue;
            }

            $data[] = $row;

            $numRows--;
            if ($numRows == 0) {
                break;
            }
        }

        return $data;
    }
}