File: /home/retile.ru/public_html/system/library/gkdXmlReaderIterators.php
<?php
/*
* XMLReaderIterator <http://git.io/xmlreaderiterator>
*
* Copyright (C) 2012, 2013 hakre <http://hakre.wordpress.com>
*
* This program is free software: you can redistribute it and/or modify
* it under the terms of the GNU Affero General Public License as
* published by the Free Software Foundation, either version 3 of the
* License, or (at your option) any later version.
*
* This program is distributed in the hope that it will be useful,
* but WITHOUT ANY WARRANTY; without even the implied warranty of
* MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the
* GNU Affero General Public License for more details.
*
* You should have received a copy of the GNU Affero General Public License
* along with this program. If not, see <http://www.gnu.org/licenses/>.
*
* @author hakre <http://hakre.wordpress.com>
* @license AGPL-3.0 <http://spdx.org/licenses/AGPL-3.0>
* @version 0.1.10
*/
/**
* Class XMLReaderAggregate
*
* @since 0.0.21
*/
interface XMLReaderAggregate
{
/**
* @return XMLReader
*/
public function getReader();
}
/**
* Module XMLBuild
*
* Some string functions helping to create XML
*
* @since 0.0.23
*/
abstract class XMLBuild
{
/**
* indentLines()
*
* this will add a line-separator at the end of the last line because if it was
* empty it is not any longer and deserves one.
*
* @param string $lines
* @param string $indent (optional)
*
* @return string
*/
public static function indentLines($lines, $indent = ' ')
{
$lineSeparator = "\n";
$buffer = '';
$line = strtok($lines, $lineSeparator);
while ($line) {
$buffer .= $indent . $line . $lineSeparator;
$line = strtok($lineSeparator);
}
strtok(null, null);
return $buffer;
}
/**
* @param string $name
* @param array|Traversable $attributes attributeName => attributeValue string pairs
* @param bool $emptyTag create an empty element tag (commonly known as short tags)
*
* @return string
*/
public static function startTag($name, $attributes, $emptyTag = false)
{
$buffer = '<' . $name;
$buffer .= static::attributes($attributes);
$buffer .= $emptyTag ? '/>' : '>';
return $buffer;
}
/**
* @param array|Traversable $attributes attributeName => attributeValue string pairs
*
* @return string
*/
public static function attributes($attributes)
{
$buffer = '';
foreach ($attributes as $name => $value) {
$buffer .= ' ' . $name . '="' . static::attributeValue($value) . '"';
}
return $buffer;
}
/**
* @param string $value
* @see XMLBuild::numericEntitiesSingleByte
*
* @return string
*/
public static function attributeValue($value)
{
$buffer = $value;
// REC-xml/#AVNormalize - preserve
// REC-xml/#sec-line-ends - preserve
$buffer = preg_replace_callback('~\r\n|\r(?!\n)|\t~', array('self', 'numericEntitiesSingleByte'), $buffer);
return htmlspecialchars($buffer, ENT_QUOTES, 'UTF-8', false);
}
/**
* @param string $name
* @param array|Traversable $attributes attributeName => attributeValue string pairs
* @param string $innerXML
*
* @return string
*/
public static function wrapTag($name, $attributes, $innerXML)
{
if (!strlen($innerXML)) {
return XMLBuild::startTag($name, $attributes, true);
}
return
XMLBuild::startTag($name, $attributes)
. "\n"
. XMLBuild::indentLines($innerXML)
. "</$name>";
}
/**
* @param XMLReader $reader
*
* @return string
*/
public static function readerNode(XMLReader $reader)
{
switch ($reader->nodeType) {
case XMLREADER::NONE:
return '%(0)%';
case XMLReader::ELEMENT:
return XMLBuild::startTag($reader->name, new XMLAttributeIterator($reader));
default:
$node = new XMLReaderNode($reader);
$nodeTypeName = $node->getNodeTypeName();
$nodeType = $reader->nodeType;
return sprintf('%%%s (%d)%%', $nodeTypeName, $nodeType);
}
}
/**
* @param array $matches
*
* @return string
* @see attributeValue()
*/
private static function numericEntitiesSingleByte($matches)
{
$buffer = str_split($matches[0]);
foreach ($buffer as &$char) {
$char = sprintf('&#%d;', ord($char));
}
return implode('', $buffer);
}
}
/**
* Class XMLAttributeIterator
*
* Iterator over all attributes of the current node (if any)
*/
class XMLAttributeIterator implements Iterator, Countable, ArrayAccess, XMLReaderAggregate
{
private $reader;
private $valid;
private $array;
public function __construct(XMLReader $reader)
{
$this->reader = $reader;
}
public function count()
{
return $this->reader->attributeCount;
}
public function current()
{
return $this->reader->value;
}
public function key()
{
return $this->reader->name;
}
public function next()
{
$this->valid = $this->reader->moveToNextAttribute();
if (!$this->valid) {
$this->reader->moveToElement();
}
}
public function rewind()
{
$this->valid = $this->reader->moveToFirstAttribute();
}
public function valid()
{
return $this->valid;
}
public function getArrayCopy()
{
if ($this->array === null) {
$this->array = iterator_to_array($this);
}
return $this->array;
}
public function getAttributeNames()
{
return array_keys($this->getArrayCopy());
}
public function offsetExists($offset)
{
$attributes = $this->getArrayCopy();
return isset($attributes[$offset]);
}
public function offsetGet($offset)
{
$attributes = $this->getArrayCopy();
return $attributes[$offset];
}
public function offsetSet($offset, $value)
{
throw new BadMethodCallException('XMLReader attributes are read-only');
}
public function offsetUnset($offset)
{
throw new BadMethodCallException('XMLReader attributes are read-only');
}
/**
* @return XMLReader
*/
public function getReader()
{
return $this->getReader();
}
}
/**
* Class XMLReaderIterator
*
* Iterate over all nodes of a reader
*/
class XMLReaderIterator implements Iterator, XMLReaderAggregate
{
/**
* @var XMLReader
*/
protected $reader;
/**
* @var int
*/
private $index;
/**
* stores the result of the last XMLReader::read() operation.
*
* additionally it's set to true if not initialized (null) on @see XMLReaderIterator::rewind()
*
* @var bool
*/
private $lastRead;
/**
* @var array
*/
private $elementStack;
public function __construct(XMLReader $reader)
{
$this->reader = $reader;
}
public function getReader()
{
return $this->reader;
}
public function moveToNextElementByName($name = null)
{
while (self::moveToNextElement()) {
if (!$name || $name === $this->reader->name) {
break;
}
self::next(); //@gkd, try to remove this line if issue with iteration
}
;
return self::valid() ? self::current() : false;
}
public function moveToNextElement()
{
return $this->moveToNextByNodeType(XMLReader::ELEMENT);
}
/**
* @param int $nodeType
*
* @return bool|\XMLReaderNode
*/
public function moveToNextByNodeType($nodeType)
{
if (null === self::valid()) {
self::rewind();
} elseif (self::valid()) {
self::next();
}
while (self::valid()) {
if ($this->reader->nodeType === $nodeType) {
break;
}
self::next();
}
return self::valid() ? self::current() : false;
}
public function rewind()
{
// this iterator can not really rewind
if ($this->reader->nodeType === XMLREADER::NONE) {
self::next();
} elseif ($this->lastRead === null) {
$this->lastRead = true;
}
$this->index = 0;
}
/**
* @return bool
*/
public function valid()
{
return $this->lastRead;
}
/**
* @return XMLReaderNode
*/
public function current()
{
return new XMLReaderNode($this->reader);
}
public function key()
{
return $this->index;
}
public function next()
{
if ($this->lastRead = $this->reader->read() and $this->reader->nodeType === XMLReader::ELEMENT) {
$depth = $this->reader->depth;
$this->elementStack[$depth] = new XMLReaderElement($this->reader);
if (count($this->elementStack) !== $depth + 1) {
$this->elementStack = array_slice($this->elementStack, 0, $depth + 1);
}
}
;
$this->index++;
}
/**
* @return string
* @since 0.0.19
*/
public function getNodePath()
{
return '/' . implode('/', $this->elementStack);
}
/**
* @return string
* @since 0.0.19
*/
public function getNodeTree()
{
$stack = $this->elementStack;
$buffer = '';
/* @var $element XMLReaderElement */
while ($element = array_pop($stack)) {
$buffer = $element->getXMLElementAround($buffer);
}
return $buffer;
}
}
/**
* Class XMLReaderIteration
*
* Very basic XMLReader iteration
*
* @since 0.1.0
*/
class XMLReaderIteration implements Iterator
{
/**
* @var XMLReader
*/
private $reader;
/**
* @var boolean
*/
private $valid;
/**
* @var int
*/
private $index;
/**
* @var bool
*/
private $skipNextRead;
function __construct(XMLReader $reader)
{
$this->reader = $reader;
}
/**
* skip the next read on next next()
*
* this is useful of the reader has moved to the next node already inside a foreach iteration and the next
* next would move the reader one off.
*
* @see next
*/
public function skipNextRead()
{
$this->skipNextRead = true;
}
/**
* @return XMLReader
*/
public function current()
{
return $this->reader;
}
public function next()
{
$this->index++;
if ($this->skipNextRead) {
$this->skipNextRead = false;
$this->valid = $this->reader->nodeType;
} else {
$this->valid = $this->reader->read();
}
}
public function key()
{
return $this->index;
}
public function valid()
{
return $this->valid;
}
public function rewind()
{
if ($this->reader->nodeType !== XMLReader::NONE) {
throw new BadMethodCallException('Reader can not be rewound');
}
$this->index = 0;
$this->valid = $this->reader->read();
}
}
/**
* Class XMLReaderNextIteration
*
* Iteration over XMLReader skipping subtrees
*
* @link http://php.net/manual/en/xmlreader.next.php
*
* @since 0.1.5
*/
class XMLReaderNextIteration implements Iterator
{
/**
* @var XMLReader
*/
private $reader;
private $index;
private $valid;
private $localName;
public function __construct(XMLReader $reader, $localName = null)
{
$this->reader = $reader;
$this->localName = $localName;
}
public function rewind()
{
// XMLReader can not rewind, instead we move on if before the first node
$this->moveReaderToCurrent();
$this->index = 0;
}
public function valid()
{
return $this->valid;
}
public function current()
{
return $this->reader;
}
public function key()
{
return $this->index;
}
public function next()
{
$this->valid && $this->index++;
if ($this->localName) {
$this->valid = $this->reader->next($this->localName);
} else {
$this->valid = $this->reader->next();
}
}
/**
* move cursor to the next element but only if it's not yet there
*/
private function moveReaderToCurrent()
{
if (
($this->reader->nodeType === XMLReader::NONE)
or ($this->reader->nodeType !== XMLReader::ELEMENT)
or ($this->localName && $this->localName !== $this->reader->localName)
) {
self::next();
}
}
}
/**
* Class DOMReadingIteration
*
* @since 0.1.0
*/
class DOMReadingIteration extends IteratorIterator
{
private $rootNode;
private $reader;
const XMLNS = 'xmlns';
/**
* @var array|DOMNode[]
*/
private $stack;
/**
* @var int
*/
private $depth;
/**
* @var int
*/
private $lastDepth;
/**
* @var DOMNode
*/
private $node;
/**
* @var DOMNode
*/
private $lastNode;
public function __construct(DOMNode $node, XMLReader $reader)
{
$this->rootNode = $node;
$this->reader = $reader;
parent::__construct(new XMLReaderIteration($reader));
}
/**
* The element by marked by type XMLReader::END_ELEMENT
* is empty (has no children) but not self-closing.
*
* @return bool
*/
public function isEndElementOfEmptyElement()
{
return
$this->reader->nodeType === XMLReader::END_ELEMENT
&& $this->lastDepth === $this->reader->depth
&& $this->lastNode instanceof DOMElement
&& !$this->reader->isEmptyElement;
}
public function rewind()
{
$this->stack = array($this->rootNode);
parent::rewind();
$this->build();
}
private function build()
{
if (!$this->valid()) {
$this->depth = NULL;
$this->lastDepth = NULL;
$this->node = NULL;
$this->lastNode = NULL;
$this->stack = NULL;
return;
}
$depth = $this->reader->depth;
switch ($this->reader->nodeType) {
case XMLReader::ELEMENT:
$parent = $this->stack[$depth];
$prefix = $this->reader->prefix;
/* @var $node DOMElement */
if ($prefix) {
$uri = $parent->lookupNamespaceURI($prefix) ?: $this->nsUriSelfLookup($prefix);
if ($uri === NULL) {
trigger_error(sprintf('Unable to lookup NS URI for element prefix "%s"', $prefix));
}
/* @var $doc DOMDocument */
$doc = ($parent->ownerDocument?:$parent);
$node = $doc->createElementNS($uri, $this->reader->name);
$node = $parent->appendChild($node);
} else {
$node = $parent->appendChild(new DOMElement($this->reader->name));
}
$this->stack[$depth + 1] = $node;
if ($this->reader->moveToFirstAttribute()) {
$nsUris = array();
do {
if ($this->reader->prefix === self::XMLNS) {
$nsUris[$this->reader->localName] = $this->reader->value;
}
} while ($this->reader->moveToNextAttribute());
$this->reader->moveToFirstAttribute();
do {
$prefix = $this->reader->prefix;
if ($prefix === self::XMLNS) {
$node->setAttributeNS('http://www.w3.org/2000/xmlns/', $this->reader->name, $this->reader->value);
} elseif ($prefix) {
$uri = $parent->lookupNamespaceUri($prefix) ?: @$nsUris[$prefix];
if ($uri === NULL) {
trigger_error(sprintf('Unable to lookup NS URI for attribute prefix "%s"', $prefix));
}
$node->setAttributeNS($uri, $this->reader->name, $this->reader->value);
} else {
$node->appendChild(new DOMAttr($this->reader->name, $this->reader->value));
}
} while ($this->reader->moveToNextAttribute());
}
break;
case XMLReader::END_ELEMENT:
$node = NULL;
break;
case XMLReader::COMMENT:
$node = $this->stack[$depth]->appendChild(new DOMComment($this->reader->value));
break;
case XMLReader::SIGNIFICANT_WHITESPACE:
case XMLReader::TEXT:
case XMLReader::WHITESPACE:
$node = $this->stack[$depth]->appendChild(new DOMText($this->reader->value));
break;
case XMLReader::PI:
$node = $this->stack[$depth]->appendChild(new DOMProcessingInstruction($this->reader->name, $this->reader->value));
break;
default:
$node = NULL;
$message = sprintf('Unhandled XMLReader node type %s', XMLReaderNode::dump($this->reader, TRUE));
trigger_error($message);
}
$this->depth = $depth;
$this->node = $node;
}
private function nsUriSelfLookup($prefix) {
$uri = NULL;
if ($this->reader->moveToFirstAttribute()) {
do {
if ($this->reader->prefix === self::XMLNS && $this->reader->localName === $prefix) {
$uri = $this->reader->value;
break;
}
} while ($this->reader->moveToNextAttribute());
$this->reader->moveToElement();
}
return $uri;
}
public function next()
{
parent::next();
$this->lastDepth = $this->depth;
$this->lastNode = $this->node;
$this->build();
}
/**
* @return \DOMNode
*/
public function getLastNode()
{
return $this->lastNode;
}
}
/**
* Class XMLWritingIteration
*
* @since 0.1.2
*/
class XMLWritingIteration extends IteratorIterator
{
/**
* @var XMLWriter
*/
private $writer;
/**
* @var XMLReader
*/
private $reader;
public function __construct(XMLWriter $writer, XMLReader $reader) {
$this->writer = $writer;
$this->reader = $reader;
parent::__construct(new XMLReaderIteration($reader));
}
public function write() {
$this->writeReaderImpl($this->writer, $this->reader);
}
private function writeReaderImpl(XMLWriter $writer, XMLReader $reader) {
switch ($reader->nodeType) {
case XMLReader::ELEMENT:
$writer->startElement($reader->name);
if ($reader->moveToFirstAttribute()) {
do {
$writer->writeAttribute($reader->name, $reader->value);
} while ($reader->moveToNextAttribute());
$reader->moveToElement();
}
if ($reader->isEmptyElement) {
$writer->endElement();
}
break;
case XMLReader::END_ELEMENT:
$writer->endElement();
break;
case XMLReader::COMMENT:
$writer->writeComment($reader->value);
break;
case XMLReader::SIGNIFICANT_WHITESPACE:
case XMLReader::TEXT:
$writer->text($reader->value);
break;
case XMLReader::PI:
$writer->writePi($reader->name, $reader->value);
break;
default:
XMLReaderNode::dump($reader);
}
}
}
/**
* Class XMLReaderNode
*
* @property string name inherited from XMLReader via IteratorIterator decoration
*/
class XMLReaderNode implements XMLReaderAggregate
{
/** @var XMLReader */
private $reader;
/** @var int */
private $nodeType;
/** @var string */
private $name;
/** @var string */
private $localName;
/**
* cache for expansion into SimpleXMLElement
*
* @var null|SimpleXMLElement
* @see asSimpleXML
*/
private $simpleXML;
/**
* cache for XMLAttributeIterator
*
* @var null|XMLAttributeIterator
* @see getAttributes
*/
private $attributes;
/** @var null|string */
private $string;
public function __construct(XMLReader $reader)
{
$this->reader = $reader;
$this->nodeType = $reader->nodeType;
$this->name = $reader->name;
}
public function __toString()
{
if (null === $this->string) {
$this->string = $this->readString();
}
return $this->string;
}
/**
* SimpleXMLElement for XMLReader::ELEMENT
*
* @return SimpleXMLElement|null in case the current node can not be converted into a SimpleXMLElement
* @since 0.1.4
*/
public function getSimpleXMLElement()
{
if (null === $this->simpleXML) {
if ($this->reader->nodeType !== XMLReader::ELEMENT) {
return null;
}
$node = $this->expand();
$this->simpleXML = simplexml_import_dom($node);
}
return $this->simpleXML;
}
/**
* Alias of @see getSimpleXMLElement()
*
* @return null|SimpleXMLElement
*/
public function asSimpleXML()
{
trigger_error('Deprecated ' . __METHOD__ . '() - use getSimpleXMLElement() in the future', E_USER_NOTICE);
return $this->getSimpleXMLElement();
}
/**
* @return XMLAttributeIterator|XMLReaderNode[]
*/
public function getAttributes()
{
if (null === $this->attributes) {
$this->attributes = new XMLAttributeIterator($this->reader);
}
return $this->attributes;
}
/**
* @param string $name attribute name
* @param string $default (optional) if the attribute with $name does not exists, the value to return
*
* @return null|string value of the attribute, if attribute with $name does not exists null (by $default)
*/
public function getAttribute($name, $default = null)
{
$value = $this->reader->getAttribute($name);
return null !== $value ? $value : $default;
}
/**
* @param string $name (optional) element name, null or '*' stand for each element
* @param bool $descendantAxis descend into children of children and so on?
*
* @return XMLChildElementIterator|XMLReaderNode[]
*/
public function getChildElements($name = null, $descendantAxis = false)
{
return new XMLChildElementIterator($this->reader, $name, $descendantAxis);
}
/**
* @return XMLChildIterator|XMLReaderNode[]
*/
public function getChildren()
{
return new XMLChildIterator($this->reader);
}
/**
* @return string name
*/
public function getName()
{
return $this->name;
}
/**
* @return string local name
*/
public function getLocalName()
{
return $this->localName;
}
public function getReader()
{
return $this->reader;
}
/**
* Decorated method
*
* @throws BadMethodCallException in case XMLReader can not expand the node
* @return string
*/
public function readOuterXml()
{
// Compatibility libxml 20620 (2.6.20) or later - LIBXML_VERSION / LIBXML_DOTTED_VERSION
if (method_exists($this->reader, 'readOuterXml')) {
return $this->reader->readOuterXml();
}
if (0 === $this->reader->nodeType) {
return '';
}
$doc = new DOMDocument();
$doc->preserveWhiteSpace = false;
$doc->formatOutput = true;
$node = $this->expand($doc);
return $doc->saveXML($node);
}
/**
* XMLReader expand node and import it into a DOMNode with a DOMDocument
*
* This is for example useful for DOMDocument::saveXML() @see readOuterXml
* or getting a SimpleXMLElement out of it @see getSimpleXMLElement
*
* @throws BadMethodCallException
* @param DOMNode $basenode
* @return DOMNode
*/
public function expand(DOMNode $basenode = null)
{
if (null === $basenode) {
$basenode = new DomDocument();
}
if ($basenode instanceof DOMDocument) {
$doc = $basenode;
} else {
$doc = $basenode->ownerDocument;
}
if (false === $node = $this->reader->expand($basenode)) {
throw new BadMethodCallException('Unable to expand node.');
}
if ($node->ownerDocument !== $doc) {
$node = $doc->importNode($node, true);
}
return $node;
}
/**
* Decorated method
*
* @throws BadMethodCallException
* @return string
*/
public function readString()
{
// Compatibility libxml 20620 (2.6.20) or later - LIBXML_VERSION / LIBXML_DOTTED_VERSION
if (method_exists($this->reader, 'readString')) {
return $this->reader->readString();
}
if (0 === $this->reader->nodeType) {
return '';
}
if (false === $node = $this->reader->expand()) {
throw new BadMethodCallException('Unable to expand node.');
}
return $node->textContent;
}
/**
* Return node-type as human readable string (constant name)
*
* @param null $nodeType
*
* @return string
*/
public function getNodeTypeName($nodeType = null)
{
$strings = array(
XMLReader::NONE => 'NONE',
XMLReader::ELEMENT => 'ELEMENT',
XMLReader::ATTRIBUTE => 'ATTRIBUTE',
XMLREADER::TEXT => 'TEXT',
XMLREADER::CDATA => 'CDATA',
XMLReader::ENTITY_REF => 'ENTITY_REF',
XMLReader::ENTITY => 'ENTITY',
XMLReader::PI => 'PI',
XMLReader::COMMENT => 'COMMENT',
XMLReader::DOC => 'DOC',
XMLReader::DOC_TYPE => 'DOC_TYPE',
XMLReader::DOC_FRAGMENT => 'DOC_FRAGMENT',
XMLReader::NOTATION => 'NOTATION',
XMLReader::WHITESPACE => 'WHITESPACE',
XMLReader::SIGNIFICANT_WHITESPACE => 'SIGNIFICANT_WHITESPACE',
XMLReader::END_ELEMENT => 'END_ELEMENT',
XMLReader::END_ENTITY => 'END_ENTITY',
XMLReader::XML_DECLARATION => 'XML_DECLARATION',
);
if (null === $nodeType) {
$nodeType = $this->nodeType;
}
return $strings[$nodeType];
}
/**
* decorate method calls
*
* @param string $name
* @param array $args
*
* @return mixed
*/
public function __call($name, $args)
{
return call_user_func_array(array($this->reader, $name), $args);
}
/**
* decorate property get
*
* @param string $name
*
* @return string
*/
public function __get($name)
{
return $this->reader->$name;
}
/**
* debug utility method
*
* @param XMLReader $reader
* @param bool $return (optional) prints by default but can return string
* @return string|null
*/
public static function dump(XMLReader $reader, $return = FALSE)
{
$node = new self($reader);
$nodeType = $reader->nodeType;
$nodeName = $node->getNodeTypeName();
$extra = '';
if ($reader->nodeType === XMLReader::ELEMENT) {
$extra = '<' . $reader->name . '> ';
$extra .= sprintf("(isEmptyElement: %s) ", $reader->isEmptyElement ? 'Yes' : 'No');
}
if ($reader->nodeType === XMLReader::END_ELEMENT) {
$extra = '</' . $reader->name . '> ';
}
if ($reader->nodeType === XMLReader::ATTRIBUTE) {
$str = $reader->value;
$len = strlen($str);
if ($len > 20) {
$str = substr($str, 0, 17) . '...';
}
$str = strtr($str, array("\n" => '\n'));
$extra = sprintf('%s = (%d) "%s" ', $reader->name, strlen($str), $str);
}
if ($reader->nodeType === XMLReader::TEXT || $reader->nodeType === XMLReader::WHITESPACE || $reader->nodeType === XMLReader::SIGNIFICANT_WHITESPACE) {
$str = $reader->readString();
$len = strlen($str);
if ($len > 20) {
$str = substr($str, 0, 17) . '...';
}
$str = strtr($str, array("\n" => '\n'));
$extra = sprintf('(%d) "%s" ', strlen($str), $str);
}
$label = sprintf("(#%d) %s %s", $nodeType, $nodeName, $extra);
if ($return) {
return $label;
}
printf("%s%s\n", str_repeat(' ', $reader->depth), $label);
return null;
}
}
/**
* Class XMLReaderElement
*
* This node is used in the elementStack
*
* @since 0.0.19
*/
class XMLReaderElement extends XMLReaderNode
{
private $name_;
private $attributes_;
public function __construct(XMLReader $reader)
{
parent::__construct($reader);
$this->initializeFrom($reader);
}
public function getXMLElementAround($innerXML = '')
{
return XMLBuild::wrapTag($this->name_, $this->attributes_, $innerXML);
}
public function getAttributes()
{
return $this->attributes_;
}
public function getAttribute($name, $default = null)
{
return isset($this->attributes_[$name])
? $this->attributes_[$name] : $default;
}
public function __toString()
{
return $this->name_;
}
private function initializeFrom(XMLReader $reader)
{
if ($reader->nodeType !== XMLReader::ELEMENT) {
$node = new XMLReaderNode($reader);
throw new RuntimeException(sprintf(
'Reader must be at an XMLReader::ELEMENT, is XMLReader::%s given.',
$node->getNodeTypeName()
));
}
$this->name_ = $reader->name;
$this->attributes_ = parent::getAttributes()->getArrayCopy();
}
}
/**
* Class XMLChildIterator
*
* Iterate over child-nodes of the current XMLReader node
*/
class XMLChildIterator extends XMLReaderIterator
{
private $stopDepth;
public function __construct(XMLReader $reader)
{
parent::__construct($reader);
$this->stopDepth = $reader->depth;
}
public function rewind()
{
parent::next();
parent::rewind();
}
public function valid()
{
$parent = parent::valid();
return $parent and $this->reader->depth > $this->stopDepth;
}
}
/**
* Class XMLElementIterator
*
* Iterate over XMLReader element nodes
*
* @method string readString() inherited from IteratorIterator decoration of XMLReader
*/
class XMLElementIterator extends XMLReaderIterator
{
private $index;
private $name;
private $didRewind;
/**
* @param XMLReader $reader
* @param null|string $name element name, leave empty or use '*' for all elements
*/
public function __construct(XMLReader $reader, $name = null)
{
parent::__construct($reader);
$this->setName($name);
}
/**
* @return void
*/
public function rewind()
{
parent::rewind();
$this->ensureCurrentElementState();
$this->didRewind = true;
$this->index = 0;
}
/**
* @return XMLReaderNode|null
*/
public function current()
{
$this->didRewind || self::rewind();
$this->ensureCurrentElementState();
return self::valid() ? new XMLReaderNode($this->reader) : null;
}
public function key()
{
return $this->index;
}
public function next()
{
if (parent::valid()) {
$this->index++;
}
parent::next();
$this->ensureCurrentElementState();
}
/**
* @return array
*/
public function toArray()
{
$array = array();
$this->didRewind || $this->rewind();
if (!$this->valid()) {
return array();
}
$this->ensureCurrentElementState();
while ($this->valid()) {
$element = new XMLReaderNode($this->reader);
if ($this->reader->hasValue) {
$string = $this->reader->value;
} else {
$string = $element->readString();
}
if ($this->name) {
$array[] = $string;
} else {
$array[$element->name] = $string;
}
$this->moveToNextElementByName($this->name);
}
return $array;
}
/**
* @return string
*/
public function __toString()
{
return $this->readString();
}
/**
* decorate method calls
*
* @param string $name
* @param array $args
*
* @return mixed
*/
public function __call($name, $args)
{
// @gkd
if (is_null($this->current()) && $name == 'readOuterXML') {
return '';
}
return call_user_func_array(array($this->current(), $name), $args);
}
/**
* decorate property get
*
* @param string $name
*
* @return string
*/
public function __get($name)
{
return $this->current()->$name;
}
/**
* @param null|string $name
*/
public function setName($name = null)
{
$this->name = '*' === $name ? null : $name;
}
/**
* take care the underlying XMLReader is at an element with a fitting name (if $this is looking for a name)
*/
private function ensureCurrentElementState()
{
if ($this->reader->nodeType !== XMLReader::ELEMENT) {
$this->moveToNextElementByName($this->name);
} elseif ($this->name && $this->name !== $this->reader->name) {
$this->moveToNextElementByName($this->name);
}
}
}
/**
* Class XMLChildElementIterator
*
* Iterate over child element nodes of the current XMLReader node
*/
class XMLChildElementIterator extends XMLElementIterator
{
/**
* @var null|int
*/
private $stopDepth;
/**
* @var bool
*/
private $descendTree;
/**
* @var bool
*/
private $didRewind;
/**
* @var int
*/
private $index;
/**
* @inheritdoc
*
* @param bool $descendantAxis traverse children of children
*/
public function __construct(XMLReader $reader, $name = null, $descendantAxis = false)
{
parent::__construct($reader, $name);
$this->descendTree = $descendantAxis;
}
/**
* @throws UnexpectedValueException
* @return void
*/
public function rewind()
{
// this iterator can not really rewind. instead it places itself onto the
// first children.
if ($this->reader->nodeType === XMLReader::NONE) {
$this->moveToNextElement();
}
if ($this->stopDepth === null) {
$this->stopDepth = $this->reader->depth;
}
// move to first child - if any
parent::next();
parent::rewind();
$this->index = 0;
$this->didRewind = true;
}
public function next()
{
if ($this->valid()) {
$this->index++;
}
while ($this->valid()) {
parent::next();
if ($this->descendTree || $this->reader->depth === $this->stopDepth + 1) {
break;
}
};
}
public function valid()
{
if (!($valid = parent::valid())) {
return $valid;
}
return $this->reader->depth > $this->stopDepth;
}
/**
* @return XMLReaderNode|null
*/
public function current()
{
$this->didRewind || self::rewind();
return parent::current();
}
public function key()
{
return $this->index;
}
}
/**
* Class XMLReaderFilterBase
*
* @since 0.0.21
*
* @method XMLReaderIterator getInnerIterator()
*/
abstract class XMLReaderFilterBase extends FilterIterator implements XMLReaderAggregate
{
public function __construct(XMLReaderIterator $elements) {
parent::__construct($elements);
}
/**
* @return XMLReader
*/
public function getReader()
{
return $this->getInnerIterator()->getReader();
}
}
/**
* Class XMLTypeFilter
*
* FilterIterator to only accept one or more specific XMLReader nodeTypes
*
*/
class XMLNodeTypeFilter extends XMLReaderFilterBase
{
private $allowed;
private $reader;
private $invert;
/**
* @param XMLReaderIterator $iterator
* @param int|int[] $nodeType one or more type constants <http://php.net/class.xmlreader>
* XMLReader::NONE XMLReader::ELEMENT XMLReader::ATTRIBUTE XMLReader::TEXT
* XMLReader::CDATA XMLReader::ENTITY_REF XMLReader::ENTITY XMLReader::PI
* XMLReader::COMMENT XMLReader::DOC XMLReader::DOC_TYPE XMLReader::DOC_FRAGMENT
* XMLReader::NOTATION XMLReader::WHITESPACE XMLReader::SIGNIFICANT_WHITESPACE
* XMLReader::END_ELEMENT XMLReader::END_ENTITY XMLReader::XML_DECLARATION
* @param bool $invert
*/
public function __construct(XMLReaderIterator $iterator, $nodeType, $invert = false)
{
parent::__construct($iterator);
$this->allowed = (array) $nodeType;
$this->reader = $iterator->getReader();
$this->invert = $invert;
}
public function accept()
{
$result = in_array($this->reader->nodeType, $this->allowed);
return $this->invert ? !$result : $result;
}
}
/**
* Class XMLAttributeFilterBase
*/
abstract class XMLAttributeFilterBase extends XMLReaderFilterBase
{
private $attr;
/**
* @param XMLElementIterator $elements
* @param string $attr name of the attribute, '*' for every attribute
*/
public function __construct(XMLElementIterator $elements, $attr)
{
parent::__construct($elements);
$this->attr = $attr;
}
protected function getAttributeValues()
{
/* @var $node XMLReaderNode */
$node = parent::current();
if ('*' === $this->attr) {
$attributes = $node->getAttributes()->getArrayCopy();
} else {
$attributes = (array) $node->getAttribute($this->attr);
}
return $attributes;
}
}
/**
* Class XMLAttributeFilter
*
* FilterIterator for attribute value(s)
*/
class XMLAttributeFilter extends XMLAttributeFilterBase
{
private $compare;
private $invert;
/**
* @param XMLElementIterator $elements
* @param string $attr name of the attribute, '*' for every attribute
* @param string|array $compare value(s) to compare against
* @param bool $invert
*/
public function __construct(XMLElementIterator $elements, $attr, $compare, $invert = false)
{
parent::__construct($elements, $attr);
$this->compare = (array) $compare;
$this->invert = (bool) $invert;
}
public function accept()
{
$result = $this->search($this->getAttributeValues(), $this->compare);
return $this->invert ? !$result : $result;
}
private function search($values, $compares)
{
foreach ($compares as $compare) {
if (in_array($compare, $values)) {
return true;
}
}
return false;
}
}
/**
* Class XMLAttributePreg
*
* PCRE regular expression based filter for elements with a certain attribute value
*/
class XMLAttributePreg extends XMLAttributeFilterBase
{
private $pattern;
private $invert;
/**
* @param XMLElementIterator $elements
* @param string $attr name of the attribute, '*' for every attribute
* @param string $pattern pcre based regex pattern for the attribute value
* @param bool $invert
* @throws InvalidArgumentException
*/
public function __construct(XMLElementIterator $elements, $attr, $pattern, $invert = false)
{
parent::__construct($elements, $attr);
if (false === preg_match("$pattern", '')) {
throw new InvalidArgumentException("Invalid pcre pattern '$pattern'.");
}
$this->pattern = $pattern;
$this->invert = (bool) $invert;
}
public function accept()
{
return (bool) preg_grep($this->pattern, $this->getAttributeValues(), $this->invert ? PREG_GREP_INVERT : 0);
}
}
/**
* Class XMLElementXpathFilter
*
* Filter an XMLReaderIterator with an Xpath expression
*
* @since 0.0.19
*
* @method XMLElementIterator getInnerIterator()
*/
class XMLElementXpathFilter extends XMLReaderFilterBase
{
private $expression;
public function __construct(XMLElementIterator $iterator, $expression)
{
parent::__construct($iterator);
$this->expression = $expression;
}
/* orig
public function accept_()
{
$buffer = $this->getInnerIterator()->getNodeTree();
$result = simplexml_load_string($buffer)->xpath($this->expression);
$count = count($result);
var_dump($count);
if ($count !== 1) {
return false;
}
var_dump($result);
return !($result[0]->children()->count());
}
*/
//@gkdfix
public function accept()
{
$buffer = $this->getInnerIterator()->getNodeTree();
$buffer = str_replace('xmlns:', 'ns', $buffer); //@gkdfix trick the namespaces in order to process correctly the xpath
if ($res = simplexml_load_string($buffer, "SimpleXMLElement" , LIBXML_NOERROR )) {
$result = $res->xpath($this->expression);
} else {
$result = array();
}
$count = count($result);
if (!$result || $count !== 1) {
return false;
}
return !($result[0]->children()->count());
}
}
/**
* Class BufferedFileRead
*
* @since 0.1.3
*/
final class BufferedFileRead
{
const MODE_READ_BINARY = 'rb';
/**
* @var string
*/
public $buffer;
/**
* @var resource
*/
private $handle;
/**
* @var string
*/
private $file;
/**
* number of bytes to have *maximum* ahead in buffer at read
*
* @var int
* @see readAhead
*/
private $maxAhead = 8192;
/**
* number of bytes to read ahead. can not be larger than
* maxAhead.
*
* @var int
* @see maxAhead
*/
private $readAhead = 0;
/**
* @param $filename
* @param $mode
* @param null $use_include_path
* @param null $context
*
* @return bool
*/
public function fopen($filename, $mode, $use_include_path = null, $context = null) {
if ($mode !== self::MODE_READ_BINARY) {
$message = sprintf(
"unsupported mode '%s', only '%s' is supported for buffered file read", $mode, self::MODE_READ_BINARY
);
trigger_error($message);
return false;
}
if ($context === null) {
$handle = fopen($filename, self::MODE_READ_BINARY, $use_include_path);
} else {
$handle = fopen($filename, self::MODE_READ_BINARY, $use_include_path, $context);
}
if (!$handle) {
return false;
}
$this->file = $filename;
$this->handle = $handle;
return true;
}
/**
* appends up to $count bytes to the buffer up to
* the read-ahead limit
*
* @param $count
*
* @return int|bool length of buffer or FALSE on error
*/
public function append($count)
{
$bufferLen = strlen($this->buffer);
if ($bufferLen >= $count + $this->maxAhead) {
return $bufferLen;
}
($ahead = $this->readAhead)
&& ($delta = $bufferLen - $ahead) < 0
&& $count -= $delta;
$read = fread($this->handle, $count);
if ($read === false) {
throw new UnexpectedValueException(sprintf('Can not deal with fread() errors.'));
}
if ($readLen = strlen($read)) {
$this->buffer .= $read;
$bufferLen += $readLen;
}
return $bufferLen;
}
/**
* shift bytes from buffer
*
* @param $bytes - up to buffer-length bytes
*
* @return string
*/
public function shift($bytes)
{
$bufferLen = strlen($this->buffer);
if ($bytes === $bufferLen) {
$return = $this->buffer;
$this->buffer = '';
} else {
$return = substr($this->buffer, 0, $bytes);
$this->buffer = substr($this->buffer, $bytes);
}
return $return;
}
public function fread($count) {
return fread($this->handle, $count);
}
public function feof() {
return feof($this->handle);
}
/**
* @return string
*/
public function getFile() {
return $this->file;
}
public function __toString() {
return $this->file;
}
/**
* @return int
*/
public function getReadAhead() {
return $this->readAhead;
}
/**
* @param int $readAhead
*/
public function setReadAhead($readAhead) {
$this->readAhead = max(0, (int)$readAhead);
}
public function close() {
if ($this->handle && fclose($this->handle)) {
$this->handle = null;
}
$this->buffer = '';
}
public function __destruct() {
$this->close();
}
}
/**
* Class BufferedFileReaders
*
* Brigade of BufferedFileRead objects as keyed instances based on
* their filename.
*
* @since 0.1.3
*/
class BufferedFileReaders
{
/**
* this wrapper is a multi-singleton based on the filename
*
* @var BufferedFileRead[]
*/
private $readers;
/**
* @param $filename
* @param $mode
* @param $use_include_path
* @param $context
*
* @return BufferedFileRead or null on error
*/
public function getReaderForFile($filename, $mode, $use_include_path, $context)
{
$readers = $this->readers;
if (!isset($readers[$filename])) {
$reader = new BufferedFileRead();
$result = $reader->fopen($filename, $mode, $use_include_path, $context);
return $this->readers[$filename] = $result ? $reader : null;
}
return $readers[$filename];
}
public function close()
{
if (!$this->readers) {
return;
}
foreach ($this->readers as $reader) {
$reader && $reader->close();
}
$this->readers = null;
}
public function removeReaderForFile($filename)
{
if (!isset($this->readers[$filename])) {
return false;
}
$this->readers[$filename]->close();
unset($this->readers[$filename]);
return true;
}
public function isFileConsumed($filename)
{
if (!isset($this->readers[$filename]) || !$reader = $this->readers[$filename]) {
return false;
}
if ($reader->feof() && !strlen($reader->buffer)) {
return true;
}
return false;
}
public function __destruct()
{
$this->close();
}
}
/**
* Class XMLSequenceStreamPath
*
* @since 0.1.3
*/
class XMLSequenceStreamPath
{
/**
* @var string
*/
private $path;
public function __construct($path) {
$this->path = $path;
}
public function getProtocol() {
$parts = $this->parsePath($this->path);
return $parts['scheme'];
}
public function getSpecific() {
$parts = $this->parsePath($this->path);
return $parts['specific'];
}
public function getFile() {
$specific = $this->getSpecific();
$specific = str_replace(array('\\', '/./'), '/', $specific);
return $specific;
}
private function parsePath($path) {
$parts = array_combine(array('scheme', 'specific'), explode('://', $path, 2) + array(null, null));
if (null === $parts['specific']) {
throw new UnexpectedValueException(sprintf("Path '%s' has no protocol", $path));
}
return $parts;
}
function __toString() {
return $this->path;
}
}
/**
* Class XMLSequenceStream
*
* @since 0.1.3
*/
class XMLSequenceStream
{
const DECL_POS_PATTERN = '(<\?xml\s+version\s*=\s*(["\'])(1\.\d+)\1(?:\s*\?>|\s+encoding\s*=\s*(["\'])(((?!\3).)*)\3))';
/**
* @var resource
*/
public $context;
/**
* @var string
*/
private $file;
/**
* @var BufferedFileRead
*/
private $reader;
/**
* this wrapper keeps a multi-singleton based on the filename
* for read buffers to allow multiple stream operations
* after another.
*
* @var BufferedFileReaders
*/
public static $readers;
/**
* @var bool
*/
private $flagEof;
private $declFound = 0;
/**
* clear reader buffers, close open files if any.
*/
public static function clean()
{
self::$readers && self::$readers->close();
}
/**
* @param string $path filename of the buffer to close, complete with wrapper prefix
*
* @return bool
*/
public static function closeBuffer($path)
{
if (!self::$readers) {
return false;
}
$path = new XMLSequenceStreamPath($path);
$file = $path->getFile();
return self::$readers->removeReaderForFile($file);
}
/**
* @param $path
*
* @return bool
*/
public static function notAtEndOfSequence($path)
{
if (!self::$readers) {
return true;
}
try {
$path = new XMLSequenceStreamPath($path);
} catch (UnexpectedValueException $e) {
return true;
}
$file = $path->getFile();
return !self::$readers->isFileConsumed($file);
}
public function __construct()
{
# fputs(STDOUT, sprintf('<construct>'));
self::$readers || self::$readers = new BufferedFileReaders();
}
/**
* @param string $path
* @param string $mode
* @param int $options
* @param string $opened_path
*
* @return bool
*/
public function stream_open($path, $mode, $options, &$opened_path)
{
# fputs(STDOUT, sprintf('<open: %s - raise errors: %d - use path: %d >', var_export($path, 1), $options & STREAM_REPORT_ERRORS, $options & STREAM_USE_PATH));
$path = new XMLSequenceStreamPath($path);
$file = $path->getFile();
$reader = self::$readers->getReaderForFile($file, $mode, null, $this->context);
$this->file = $file;
$this->reader = $reader;
if (!$reader) {
return false;
}
$reader->setReadAhead(256);
if ($reader->feof() && !strlen($reader->buffer)) {
$message = sprintf('Concatenated XML Stream: Resource %s at the end of stream', var_export($file, true));
trigger_error($message);
return false;
}
return true;
}
public function stream_stat()
{
return false;
}
/**
* @param string $path
* @param int $flags
*
* @return bool
*/
public function url_stat($path, $flags)
{
# fputs(STDOUT, sprintf('<url stat: %s - Link: %d - Quiet: %d>', var_export($path, 1), $flags & STREAM_URL_STAT_LINK, $flags | STREAM_URL_STAT_QUIET));
return array();
}
public function stream_read($count)
{
$reader = $this->reader;
# fputs(STDOUT, sprintf('<read: %d - buffer: %d - eof: %d>', $count, strlen($reader->buffer), $this->flagEof));
if ($this->flagEof) {
return false;
}
$bufferLen = $reader->append($count);
# fputs(STDOUT, sprintf('<buffer: %d>', $bufferLen));
$pos = $this->declPos();
if (!$this->declFound && $pos !== false) {
$this->declFound++;
if ($pos !== 0) {
throw new UnexpectedValueException(sprintf('First XML declaration expected at offset 0, found at %d', $pos));
}
$pos = $this->declPos(5);
}
if ($pos === false) {
$returnLen = min($bufferLen, $count);
} else {
$returnLen = min($pos, $count);
if ($returnLen >= $pos) {
$this->flagEof = true;
}
$this->declFound++;
}
$return = $reader->shift($returnLen);
return $return;
}
private function declPos($offset = 0)
{
$result = preg_match(self::DECL_POS_PATTERN, $this->reader->buffer, $matches, PREG_OFFSET_CAPTURE, $offset);
if ($result === FALSE) {
throw new UnexpectedValueException('Regex failed.');
}
return $result ? $matches[0][1] : false;
}
public function stream_eof()
{
return $this->flagEof;
}
}