JsonCollectionParser\Parser

Complexity

Total Complexity

11

Size/Duplication

Total Lines	106
Duplicated Lines	0 %

Coupling/Cohesion

Components	1
Dependencies	2

Importance

Changes	6
Bugs	1	Features	2

6 Methods

Rating	Name	Duplication	Size	Complexity
A	parse()	0	21	2
A	stop()	0	4	1
A	checkCallback()	0	6	2
A	openFile()	0	13	3
A	setOption()	0	4	1
A	getOption()	0	8	2

<?php
namespace JsonCollectionParser;

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

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

    /**
     * @param $filePath
     * @param $itemCallback
     *
     * @throws \Exception
     */
    public function parse($filePath, $itemCallback)
    {
        $this->checkCallback($itemCallback);

        $stream = $this->openFile($filePath);

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

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

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

    /**
     * @param $filePath
     *
     * @return resource
     * @throws \Exception
     */
    protected function openFile($filePath)
    {
        if (!is_file($filePath)) {
            throw new \Exception('File does not exist: ' . $filePath);
        }

        $stream = @fopen($filePath, 'r');
        if (false === $stream) {
            throw new \Exception('Unable to open file for read: ' . $filePath);
        }

        return $stream;
    }

    /**
     * @param string $name
     * @param $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;
        }
    }
}