JsonCollectionParser\Parser

Complexity

Total Complexity

17

Size/Duplication

Total Lines	138
Duplicated Lines	0 %

Coupling/Cohesion

Components	1
Dependencies	2

Importance

Changes

0

8 Methods

Rating	Name	Duplication	Size	Complexity
A	__construct()	0	4	1
A	parse()	0	22	4
A	parseAsObjects()	0	4	1
A	stop()	0	4	1
A	checkCallback()	0	6	2
A	openStream()	0	17	5
A	setOption()	0	4	1
A	getOption()	0	8	2

<?php
namespace JsonCollectionParser;

class Parser
{
    /**
     * @var array
     */
    protected $options = [
        'line_ending' => "\n",
        'emit_whitespace' => false
    ];

    /**
     * @var \JsonStreamingParser\Parser
     */
    protected $parser;

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

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

    public function __construct()
    {
        $this->gzipSupported = extension_loaded('zlib');
    }

    /**
     * @param string|resource $input File path or resource
     * @param callback|callable $itemCallback Callback
     * @param bool $assoc Parse as associative arrays
     *
     * @throws \Exception
     */
    public function parse($input, $itemCallback, $assoc = true)
    {
        $this->checkCallback($itemCallback);

        $stream = $this->openStream($input);

        try {
            $listener = new Listener($itemCallback, $assoc);
            $this->parser = new \JsonStreamingParser\Parser(
                $stream,
                $listener,
                $this->getOption('line_ending'),
                $this->getOption('emit_whitespace')
            );
            $this->parser->parse();
        } catch (\Exception $e) {
            $this->gzipSupported ? gzclose($stream) : fclose($stream);
            throw $e;
        }

        $this->gzipSupported ? gzclose($stream) : fclose($stream);
    }

    /**
     * @param string|resource $input File path or resource
     * @param callback|callable $itemCallback Callback
     *
     * @throws \Exception
     */
    public function parseAsObjects($input, $itemCallback)
    {
        $this->parse($input, $itemCallback, false);
    }

    /**
     *
     */
    public function stop()
    {
        $this->parser->stop();
    }

    /**
     * @param callback|callable $callback
     *
     * @throws \Exception
     */
    protected function checkCallback($callback)
    {
        if (!is_callable($callback)) {
            throw new \Exception("Callback should be callable");
        }
    }

    /**
     * @param string|resource $input File path or resource
     *
     * @return resource
     * @throws \Exception
     */
    protected function openStream($input)
    {
        if (is_resource($input)) {
            return $input;
        }

        if (!is_file($input)) {
            throw new \Exception('File does not exist: ' . $input);
        }

        $stream = $this->gzipSupported ? @gzopen($input, 'r') : @fopen($input, 'r');
        if (false === $stream) {
            throw new \Exception('Unable to open file for read: ' . $input);
        }

        return $stream;
    }

    /**
     * @param string $name
     * @param mixed $value
     */
    public function setOption($name, $value)
    {
        $this->options[$name] = $value;
    }

    /**
     * @param string $name
     *
     * @return mixed
     */
    public function getOption($name)
    {
        if (isset($this->options[$name])) {
            return $this->options[$name];
        } else {
            return null;
        }
    }
}