ByJG\AnyDataset\Dataset\FixedTextFileDataset

Complexity

Total Complexity

12

Size/Duplication

Total Lines	107
Duplicated Lines	0 %

Coupling/Cohesion

Components	1
Dependencies	3

Test Coverage

Coverage

43.24%

Importance

Changes

0

4 Methods

Rating	Name	Duplication	Size	Complexity
A	getIterator()	0	7	2
B	getIteratorHttp()	0	27	3
A	getIteratorFile()	0	14	3
A	__construct()	0	19	4

<?php

namespace ByJG\AnyDataset\Dataset;

use ByJG\AnyDataset\Enum\FixedTextDefinition;
use ByJG\AnyDataset\Exception\DatasetException;
use ByJG\AnyDataset\Exception\NotFoundException;
use Exception;
use InvalidArgumentException;

class FixedTextFileDataset
{

    protected $source;

    /**
     * @var FixedTextDefinition[]
     */
    protected $fieldDefinition;
    protected $sourceType;

    /**
     * Text File Data Set
     *
     * @param string $source
     * @param FixedTextDefinition[] $fieldDefinition
     * @throws NotFoundException
     */
    public function __construct($source, $fieldDefinition)
    {
        if (!is_array($fieldDefinition)) {
            throw new InvalidArgumentException("You must define an array of field definition.");
        }

        $this->source = $source;
        $this->sourceType = "HTTP";

        if (!preg_match("~^https?://~", $source)) {
            if (!file_exists($this->source)) {
                throw new NotFoundException("The specified file " . $this->source . " does not exists");
            }

            $this->sourceType = "FILE";
        }

        $this->fieldDefinition = $fieldDefinition;
    }

    /**
     * @access public
     * @return GenericIterator
     * @throws DatasetException
     * @throws Exception
     */
    public function getIterator()
    {
        if ($this->sourceType == "HTTP") {
            return $this->getIteratorHttp();
        }
        return $this->getIteratorFile();
    }

    /**
     * @return \ByJG\AnyDataset\Dataset\FixedTextFileIterator
     * @throws \ByJG\AnyDataset\Exception\DatasetException
     * @throws \Exception
     * @return GenericIterator
     */
    protected function getIteratorHttp()
    {
        // Expression Regular:
        // [1]: http or ftp

46% of this comment could be valid code. Did you maybe forget this after debugging?

        // [2]: Server name

45% of this comment could be valid code. Did you maybe forget this after debugging?

        // [3]: Full Path

45% of this comment could be valid code. Did you maybe forget this after debugging?

        $pat = "/(http|ftp|https):\/\/([\w+|\.]+)/i";
        $urlParts = preg_split($pat, $this->source, -1, PREG_SPLIT_DELIM_CAPTURE);

        $handle = fsockopen($urlParts[2], 80, $errno, $errstr, 30);
        if (!$handle) {
            throw new DatasetException("TextFileDataset Socket error: $errstr ($errno)");
        }

        $out = "GET " . $urlParts[4] . " HTTP/1.1\r\n";
        $out .= "Host: " . $urlParts[2] . "\r\n";
        $out .= "Connection: Close\r\n\r\n";

        fwrite($handle, $out);

        try {
            return new FixedTextFileIterator($handle, $this->fieldDefinition);
        } catch (Exception $ex) {
            fclose($handle);
            throw $ex;
        }
    }

    /**
     * @return \ByJG\AnyDataset\Dataset\FixedTextFileIterator
     * @throws \ByJG\AnyDataset\Exception\DatasetException
     * @throws \Exception
     * @return GenericIterator
     */
    protected function getIteratorFile()
    {
        $handle = fopen($this->source, "r");
        if (!$handle) {
            throw new DatasetException("TextFileDataset File open error");
        }

        try {
            return new FixedTextFileIterator($handle, $this->fieldDefinition);
        } catch (Exception $ex) {
            fclose($handle);
            throw $ex;
        }
    }
}