JsonCollectionParser\Listener

Complexity

Total Complexity

19

Size/Duplication

Total Lines	162
Duplicated Lines	0 %

Coupling/Cohesion

Components	1
Dependencies	0

Importance

Changes	4
Bugs	0	Features	0

12 Methods

Rating	Name	Duplication	Size	Complexity
A	__construct()	0	5	1
A	startDocument()	0	9	1
A	endDocument()	0	5	1
A	startObject()	0	6	1
A	endObject()	0	12	2
A	startArray()	0	4	1
A	startCommon()	0	8	2
A	endArray()	0	4	1
B	endCommon()	0	22	5
A	key()	0	4	1
A	value()	0	13	2
A	whitespace()	0	3	1

<?php
namespace JsonCollectionParser;

class Listener implements \JsonStreamingParser\Listener
{
    /**
     * @var array
     */
    protected $stack;

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

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

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

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

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

    /**
     * @var callback|callable
     */
    protected $callback;

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

    /**
     * @param callback|callable $callback callback for parsed collection item
     * @param bool $assoc When @c true, returned objects will be converted into associative arrays.
     */
    public function __construct($callback, $assoc = false)
    {
        $this->callback = $callback;
        $this->assoc = $assoc;
    }

    public function startDocument()
    {
        $this->stack = [];
        $this->key = null;
        $this->keys = [];
        $this->objectLevel = 0;
        $this->level = 0;
        $this->objectKeys = [];
    }

    public function endDocument()
    {
        $this->stack = [];
        $this->keys = [];
    }

    public function startObject()
    {
        $this->objectLevel++;

        $this->startCommon();
    }

    public function endObject()
    {
        $this->endCommon(true);

        $this->objectLevel--;
        if ($this->objectLevel === 0) {
            $obj = $this->stack[0][0];
            array_shift($this->stack[0]);

            call_user_func($this->callback, $obj);
        }
    }

    public function startArray()
    {
        $this->startCommon();
    }

    public function startCommon()
    {
        $this->level++;
        $this->objectKeys[$this->level] = ($this->key) ? $this->key : null;
        $this->key = null;

        array_push($this->stack, []);
    }

    public function endArray()
    {
        $this->endCommon(false);
    }

    public function endCommon($isObject)
    {
        $obj = array_pop($this->stack);

        if ($isObject && !$this->assoc) {
            $obj = (object)$obj;
        }

        if (!empty($this->stack)) {
            $parentObj = array_pop($this->stack);

            if ($this->objectKeys[$this->level]) {
                $parentObj[$this->objectKeys[$this->level]] = $obj;
            } else {
                array_push($parentObj, $obj);
            }

            array_push($this->stack, $parentObj);
        }

        $this->level--;
    }

    /**
     * @param string $key
     */
    public function key($key)
    {
        $this->key = $key;
    }

    /**
     * @param mixed $value
     */
    public function value($value)
    {
        $obj = array_pop($this->stack);

        if ($this->key) {
            $obj[$this->key] = $value;
            $this->key = null;
        } else {
            array_push($obj, $value);
        }

        array_push($this->stack, $obj);
    }

    /**
     * @param string $whitespace
     */
    public function whitespace($whitespace)
    {
    }
}