Skip to content

Instantly share code, notes, and snippets.

@hakre

hakre/README.md

Last active August 18, 2022 12:57
Show Gist options
  • Star 28 You must be signed in to star a gist
  • Fork 8 You must be signed in to fork a gist
  • Save hakre/5147685 to your computer and use it in GitHub Desktop.
Save hakre/5147685 to your computer and use it in GitHub Desktop.
Download ZIP
Iterators for PHP XMLReader for ease of parsing
Raw
README.md

Iterators for PHP XMLReader for Ease of Parsing

Change Log:

  • 0.1.12 maintenance release with fixes.

  • 0.1.11 maintenance release with fixes. added XMLReader::CDATA and XMLReader::WHITESPACE node support for XMLWritingIteration. added XMLReaderItertor::skipNextRead() for nested iterations.

  • 0.1.10 maintenance release with fixes.

  • 0.1.9 maintenance release with fixes. added XMLReaderNode::expand().

  • 0.1.8 maintenance release with fixes.

  • 0.1.7 maintenance release with fixes.

  • 0.1.6 maintenance release with fixes. added xml-file-scanner command-line tool example.

  • 0.1.5 maintenance release with tests and new XMLReaderNextIteration to iterate in XMLReader::next() fashion.

  • 0.1.4 maintenance release with fixes.

  • 0.1.3 added XMLSequenceStream, a PHP stream wrapper to read XML from files which are a sequence of XML documents. Works transparently with XMLReader.

  • 0.1.2 added XMLWritingIteration, an iteration to write with XMLWriter from XMLReader.

  • 0.1.0 composer support has been added.

  • 0.0.23 first try of a compatibility layer for PHP installs with a libxml version below version 2.6.20. functions with compatibility checks are XMLReaderNode::readOuterXml() and XMLReaderNode::readString().

  • 0.0.21 moved library into new repository and added XMLReaderAggregate.

  • 0.0.19 added XMLElementXpathFilter, a FilterIterator for XMLReaderIterator by an xpath expression.

    $reader = new XMLReader();
$reader->open($xmlFile);
$it = new XMLElementIterator($reader);

$list = new XMLElementXpathFilter(
    $it,
    '//user[@id = "1" or @id = "6"]//message'
);

foreach($list as $message) {
    echo " * ",  $message->readString(), "\n";
}

Stackoverflow Q&A for the XMLReader Iterators

the latest on top (for more examples, checkout the examples folder):

Raw
xmlreader-iterators.php
<?php
/*
* XMLReaderIterator <https://github.com/hakre/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-or-later <https://spdx.org/licenses/AGPL-3.0-or-later>
* @version 0.1.12
*/
/**
* 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('', '');
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);
}
}
/**
* limit string to maximum length and C-escape non-printable ASCII chars
*
* @param string $str
* @param int|null $maxLen optional, defaults to 20 (null), 0 (or below) for 512 block size
* @return string
*/
public static function displayString($str, $maxLen = null)
{
null === $maxLen && $maxLen = 20;
$maxLen = (int) $maxLen;
($maxLen < 1) && $maxLen = 512;
($maxLen < 4) && $maxLen = 3;
$buffer = $str;
$len = strlen($buffer);
if ($len > $maxLen) {
$buffer = substr($buffer, 0, $maxLen - 3) . '...';
}
return addcslashes($buffer, "\0..\37\42\134\177..\377");
}
/**
* dump representation of a string
*
* @param string $str
* @param int|null $maxLen {@see XMLBuild::displayString()}
* @return string
*/
public static function dumpString($str, $maxLen = null)
{
$buffer = self::displayString($str, $maxLen);
return sprintf('(%d) "%s"', strlen($str), $buffer);
}
/**
* @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;
}
#[\ReturnTypeWillChange]
public function count()
{
return $this->reader->attributeCount;
}
#[\ReturnTypeWillChange]
public function current()
{
return $this->reader->value;
}
#[\ReturnTypeWillChange]
public function key()
{
return $this->reader->name;
}
#[\ReturnTypeWillChange]
public function next()
{
$this->valid = $this->reader->moveToNextAttribute();
if (!$this->valid) {
$this->reader->moveToElement();
}
}
#[\ReturnTypeWillChange]
public function rewind()
{
$this->valid = $this->reader->moveToFirstAttribute();
}
#[\ReturnTypeWillChange]
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());
}
#[\ReturnTypeWillChange]
public function offsetExists($offset)
{
$attributes = $this->getArrayCopy();
return isset($attributes[$offset]);
}
#[\ReturnTypeWillChange]
public function offsetGet($offset)
{
$attributes = $this->getArrayCopy();
return $attributes[$offset];
}
#[\ReturnTypeWillChange]
public function offsetSet($offset, $value)
{
throw new BadMethodCallException('XMLReader attributes are read-only');
}
#[\ReturnTypeWillChange]
public function offsetUnset($offset)
{
throw new BadMethodCallException('XMLReader attributes are read-only');
}
/**
* @return XMLReader
*/
public function getReader()
{
return $this->reader;
}
}
/**
* 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 bool
*/
private $skipNextRead;
/**
* @var array
*/
private $elementStack;
public function __construct(XMLReader $reader)
{
$this->reader = $reader;
}
public function getReader()
{
return $this->reader;
}
/**
* skip the next read on next "next()"
*
* compare {@see XMLReaderIteration::skipNextRead()}
*
* @see XMLReaderIterator::next()
*
*/
public function skipNextRead()
{
$this->skipNextRead = true;
}
public function moveToNextElementByName($name = null)
{
while (self::moveToNextElement()) {
if (!$name || $name === $this->reader->name) {
break;
}
self::next();
}
;
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;
}
#[\ReturnTypeWillChange]
public function rewind()
{
$this->skipNextRead = false;
// 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
*/
#[\ReturnTypeWillChange]
public function valid()
{
return $this->lastRead;
}
/**
* @return XMLReaderNode
*/
#[\ReturnTypeWillChange]
public function current()
{
return $this->lastRead ? new XMLReaderNode($this->reader) : null;
}
#[\ReturnTypeWillChange]
public function key()
{
return $this->index;
}
#[\ReturnTypeWillChange]
public function next()
{
$this->index ++;
if ($this->skipNextRead) {
$this->skipNextRead = false;
$this->lastRead = $this->reader->nodeType !== XMLReader::NONE;
} elseif ($this->lastRead = $this->reader->read() and $this->reader->nodeType === XMLReader::ELEMENT) {
$this->touchElementStack();
}
}
/**
* @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;
}
/**
* touch the internal element-stack
*
* update the element-stack for the current reader node - which must be
* of type XMLReader::ELEMENT otherwise undefined.
*
* @return void
*/
protected function touchElementStack()
{
$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);
}
}
}
/**
* 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;
public 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 too
* far.
*
* @see next
*/
public function skipNextRead()
{
$this->skipNextRead = true;
}
/**
* @return XMLReader
*/
#[\ReturnTypeWillChange]
public function current()
{
return $this->reader;
}
#[\ReturnTypeWillChange]
public function next()
{
$this->index++;
if ($this->skipNextRead) {
$this->skipNextRead = false;
$this->valid = $this->reader->nodeType;
} else {
$this->valid = $this->reader->read();
}
}
#[\ReturnTypeWillChange]
public function key()
{
return $this->index;
}
#[\ReturnTypeWillChange]
public function valid()
{
return $this->valid;
}
#[\ReturnTypeWillChange]
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;
}
#[\ReturnTypeWillChange]
public function rewind()
{
// XMLReader can not rewind, instead we move on if before the first node
$this->moveReaderToCurrent();
$this->index = 0;
}
#[\ReturnTypeWillChange]
public function valid()
{
return $this->valid;
}
#[\ReturnTypeWillChange]
public function current()
{
return $this->reader;
}
#[\ReturnTypeWillChange]
public function key()
{
return $this->index;
}
#[\ReturnTypeWillChange]
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;
}
#[\ReturnTypeWillChange]
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;
}
#[\ReturnTypeWillChange]
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
*
* @method XMLReader current()
* @mixin XMLReaderIteration
*/
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() {
$reader = $this->reader;
$writer = $this->writer;
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::CDATA:
$writer->writeCdata($reader->value);
break;
case XMLReader::COMMENT:
$writer->writeComment($reader->value);
break;
case XMLReader::SIGNIFICANT_WHITESPACE:
case XMLReader::TEXT:
case XMLReader::WHITESPACE:
$writer->text($reader->value);
break;
case XMLReader::PI:
$writer->writePi($reader->name, $reader->value);
break;
default:
trigger_error(sprintf(
'%s::write(): Node-type not implemented: %s',
__CLASS__,
XMLReaderNode::dump($reader, true)
), E_USER_WARNING);
}
}
}
/**
* 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 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
*
* @param string $className SimpleXMLElement class name of the simplexml element
* @return SimpleXMLElement|null in case the current node can not be converted into a SimpleXMLElement
* @since 0.1.4
*/
public function getSimpleXMLElement($className = null)
{
if (null === $this->simpleXML) {
if ($this->reader->nodeType !== XMLReader::ELEMENT) {
return null;
}
$this->simpleXML = simplexml_import_dom($this->expand(), $className);
}
if (is_string($className) && !($this->simpleXML instanceof $className)) {
$this->simpleXML = simplexml_import_dom(dom_import_simplexml($this->simpleXML), $className);
}
return $this->simpleXML;
}
/**
* @deprecated since v0.1.4, use {@see getSimpleXMLElement()} instead
* @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}
*
* @param DOMNode $baseNode
* @throws BadMethodCallException
* @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 (null === $doc) {
throw new InvalidArgumentException('BaseNode has no 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;
}
/**
* @param string $name
* @param mixed $value
* @return void
*/
public function __set($name, $value)
{
throw new BadMethodCallException('XMLReader properties are read-only: ' . $name);
}
/**
* @param string $name
* @return bool
*/
public function __isset($name)
{
return isset($this->reader->$name);
}
/**
* debug utility method
*
* @param XMLReader $reader
* @param bool $return (optional) prints by default but can return string
* @return string|void
*/
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) {
$extra = sprintf(' %s = %s', $reader->name, XMLBuild::dumpString($reader->value));
}
if ($reader->nodeType === XMLReader::CDATA
|| $reader->nodeType === XMLReader::TEXT
|| $reader->nodeType === XMLReader::WHITESPACE
|| $reader->nodeType === XMLReader::SIGNIFICANT_WHITESPACE
) {
$extra = sprintf( ' %s', XMLBuild::dumpString($reader->value));
}
$label = sprintf("(#%d) %s%s", $nodeType, $nodeName, $extra);
if ($return) {
return $label;
}
printf("%s%s\n", str_repeat(' ', $reader->depth), $label);
}
}
/**
* 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)
{
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;
/**
* @var string|null
*/
private $name;
/**
* @inheritdoc
*
* @param bool $descendantAxis traverse children of children
*/
public function __construct(XMLReader $reader, $name = null, $descendantAxis = false)
{
parent::__construct($reader);
$this->name = $name;
$this->descendTree = $descendantAxis;
}
/**
* @throws UnexpectedValueException
* @return void
*/
public function rewind()
{
// this iterator can not really rewind. instead it places itself onto the
// first child element - if any.
if ($this->didRewind) {
return;
}
if ($this->reader->nodeType === XMLReader::NONE) {
!$this->moveToNextByNodeType(XMLReader::ELEMENT);
}
if ($this->stopDepth === null) {
$this->stopDepth = $this->reader->depth;
}
// move to first child element - if any
$result = $this->nextChildElementByName($this->name);
$this->index = $result ? 0 : null;
$this->didRewind = true;
}
public function next()
{
if (!$this->valid()) {
return;
}
$this->index++;
$this->nextChildElementByName($this->name);
}
public function valid()
{
if (!$this->didRewind) {
return false;
}
$depth = $this->reader->depth;
if ($depth <= $this->stopDepth) {
return false;
}
if (!$this->descendTree && $depth !== $this->stopDepth + 1) {
return false;
}
if ($this->name === null || $this->reader->name === $this->name) {
return $this->reader->nodeType === XMLReader::ELEMENT; // always true here if reader in sync with $this
}
return false;
}
/**
* @return XMLReaderNode|null
*/
public function current()
{
$this->didRewind || $this->rewind();
return $this->valid() ? parent::current() : null;
}
/**
* @return int
*/
public function key()
{
return $this->index;
}
/**
* move to next child element by name
*
* @param string|null $name
* @return bool
*/
private function nextChildElementByName($name = null)
{
while ($next = $this->nextElement()) {
$depth = $this->reader->depth;
if ($depth <= $this->stopDepth) {
return false;
}
if (!$this->descendTree && $depth !== $this->stopDepth + 1) {
continue;
}
if ($name === null || $this->reader->name === $name) {
break;
}
}
return (bool)$next;
}
/**
* @return bool
*/
private function nextElement()
{
while ($this->reader->read()) {
if (XMLReader::ELEMENT !== $this->reader->nodeType) {
continue;
}
$this->touchElementStack();
return true;
}
return false;
}
}
/**
* 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;
}
#[\ReturnTypeWillChange]
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;
}
#[\ReturnTypeWillChange]
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((string)$pattern, '')) {
throw new InvalidArgumentException("Invalid pcre pattern '$pattern'.");
}
$this->pattern = $pattern;
$this->invert = (bool) $invert;
}
#[\ReturnTypeWillChange]
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()
* @method XMLReaderNode current()
*/
class XMLElementXpathFilter extends XMLReaderFilterBase
{
private $expression;
public function __construct(XMLElementIterator $iterator, $expression)
{
parent::__construct($iterator);
$this->expression = $expression;
}
#[\ReturnTypeWillChange]
public function accept()
{
$buffer = $this->getInnerIterator()->getNodeTree();
$result = simplexml_load_string($buffer)->xpath($this->expression);
$count = count($result);
if (0 === $count) {
return false;
}
return !($result[$count - 1]->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, (bool)$use_include_path);
} else {
$handle = fopen($filename, self::MODE_READ_BINARY, (bool)$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 = null === $this->buffer ? 0 : 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('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;
}
public 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 '';
}
$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;
}
}
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment