UCD\Infrastructure\Repository\CharacterRepository\XMLRepository\CodepointElementReader\StreamingReader

Complexity

Total Complexity

13

Size/Duplication

Total Lines	91
Duplicated Lines	0 %

Coupling/Cohesion

Components	1
Dependencies	1

Importance

Changes

0

7 Methods

Rating	Name	Duplication	Size	Complexity
A	__construct()	0	4	1
A	read()	0	12	2
A	preRead()	0	8	2
A	postRead()	0	4	1
A	cursorHasElement()	0	5	2
A	readNext()	0	11	2
A	moveToNextElement()	0	8	3

<?php

namespace UCD\Infrastructure\Repository\CharacterRepository\XMLRepository\CodepointElementReader;

use UCD\Infrastructure\Repository\CharacterRepository\XMLRepository\CodepointElementReader;
use UCD\Infrastructure\Repository\CharacterRepository\XMLRepository\XMLReader;

final class StreamingReader implements CodepointElementReader
{
    const ELEMENT_CHARACTER = 'char';
    const ELEMENT_NON_CHARACTER = 'noncharacter';
    const ELEMENT_SURROGATE = 'surrogate';

    /**
     * @var array
     */
    private static $elements = [
        self::ELEMENT_CHARACTER => true,
        self::ELEMENT_NON_CHARACTER => true,
        self::ELEMENT_SURROGATE => true
    ];

    /**
     * @var XMLReader
     */
    private $xmlReader;

    /**
     * @param XMLReader $xmlReader
     */
    public function __construct(XMLReader $xmlReader)
    {
        $this->xmlReader = $xmlReader;
    }

    /**
     * {@inheritDoc}
     */
    public function read()
    {
        $this->preRead();

        try {
            while ($element = $this->readNext()) {
                yield $element;
            }
        } finally {
            $this->postRead();
        }
    }

    private function preRead()
    {
        $this->xmlReader->reopen();

        while ($this->cursorHasElement() !== true) {
            $this->xmlReader->read();
        }
    }

    private function postRead()
    {
        $this->xmlReader->close();
    }

    /**
     * @return bool
     */
    private function cursorHasElement()
    {
        return $this->xmlReader->nodeType === XMLReader::ELEMENT
            && array_key_exists($this->xmlReader->name, self::$elements);
    }

    /**
     * @return \DOMElement|null
     */
    private function readNext()
    {
        if (!$this->cursorHasElement()) {
            return null;
        }

        $element = $this->xmlReader->expand();
        $this->moveToNextElement();

        return $element;
    }

    private function moveToNextElement()
    {
        while ($this->xmlReader->next() !== false) {
            if ($this->cursorHasElement()) {
                break;
            }
        }
    }
}