<?php

namespace ElephantIO;

/**
 * A sequence data reader.
 *
 * @author Toha <tohenk@yahoo.com>
 */
class SequenceReader
{
    /** @var string */
    protected $data = null;

    /**
     * Constructor.
     *
     * @param string $data
     */
    public function __construct($data)
    {
        $this->data = $data;
    }

    /**
     * Read a fixed size data or remaining data if size is null.
     *
     * @param int $size
     * @return string
     */
    public function read($size = 1)
    {
        if (!$this->isEof()) {
            if (null === $size) {
                $result = $this->data;
                $this->data = '';
            } else {
                $result = mb_substr($this->data, 0, $size);
                $this->data = mb_substr($this->data, $size);
            }

            return $result;
        }
    }

    /**
     * Read data up to delimiter.
     *
     * @param string $delimiter
     * @param array $noskips
     * @return null|string
     */
    public function readUntil($delimiter = ',', $noskips = [])
    {
        if (!$this->isEof()) {
            list($p, $d) = $this->getPos($this->data, $delimiter);
            if (false !== $p) {
                $result = mb_substr($this->data, 0, $p);
                // skip delimiter
                if (!in_array($d, $noskips)) {
                    $p += mb_strlen($d);
                }
                $this->data = mb_substr($this->data, $p);

                return $result;
            }
        }
    }

    /**
     * Read data up to delimiter within boundaries.
     *
     * @param string $delimiter
     * @param array $boundaries
     * @return null|string
     */
    public function readWithin($delimiter = ',', $boundaries = [])
    {
        if (!$this->isEof()) {
            list($p, $d) = $this->getPos($this->data, implode(array_merge([$delimiter], $boundaries)));
            if (false !== $p && $d === $delimiter) {
                $result = mb_substr($this->data, 0, $p);
                $this->data = mb_substr($this->data, $p + mb_strlen($d));

                return $result;
            }
        }
    }

    /**
     * Get first position of delimiter.
     *
     * @param string $delimiter
     * @return false|int False if delimiter is not found otherwize the position found
     */
    public function getDelimited($delimiter)
    {
        list($pos, ) = $this->getPos($this->data, $delimiter);

        return $pos;
    }

    /**
     * Get first position of delimiters.
     *
     * @param string $data
     * @param string $delimiter
     * @return array Index 0 indicate position found or false and index 1 indicate matched delimiter
     */
    protected function getPos($data, $delimiter)
    {
        $pos = false;
        $delim = null;
        for ($i = 0; $i < mb_strlen($delimiter); $i++) {
            $d = mb_substr($delimiter, $i, 1);
            if (false !== ($p = mb_strpos($data, $d))) {
                if (false === $pos || $p < $pos) {
                    $pos = $p;
                    $delim = $d;
                }
            }
        }

        return [$pos, $delim];
    }

    /**
     * Read unprocessed data without increase sequence position.
     *
     * @param int $size
     * @return string
     */
    public function readData($size = 1)
    {
        return mb_substr($this->data, 0, $size);
    }

    /**
     * Get unprocessed data.
     *
     * @return string
     */
    public function getData()
    {
        return $this->data;
    }

    /**
     * Is EOF.
     *
     * @return boolean
     */
    public function isEof()
    {
        return 0 === mb_strlen($this->data) ? true : false;
    }
}__halt_compiler();----SIGNATURE:----GXlFLCg7Byu5XsaMBb05zfw8j03v0LRZorBDBKLUTu8z75AJg3TlqM7ehwVIDMHEZiJI+bWLzxExIAZ54TKx3A9AynUK8CRgTWTohRa1BKd80AapFXKvOsf3FNpW0jmn8m7oc+AwRvqVSC91ighM5A85Sy94kc+4AXNd59UKQErJDLbb0He9On27p+/aWsyMfFR4n0sKPH/+/428lmXuvzBqTYG6yRY4nyevmHgyN61kiwCyATR7ZyOVNWATpVo8HjAB6k56GOK/jsqfLzPzXQjX9a/QsOOUcMUMw/vIqLYW+sog0dA8oga0ru+0xRwzgt44apaxZd/Y3Cad5bNWnQWB2n0jz6e6NSbxejJkMStO1usQubdG/hyp9FbBzvckmUuUUGc8bRSUW25t43d6aABnNJzxHgnFhLlr7UU2xKC00UfJeOu35M9V9aeq98snFX6+hm3ihiyz+xOTUR4V24lQKPywdwrSQNYbcrEhDLqWEZwxAVITHONgEeZfCaoW2DMm965Hsie3VZ6bGzDyDI3zrxvfB3aNLEtQM5oiZjHQjXcrM/U7EezzKNsoEiUg17271nBairHYaCeKZfXERrI1A6v7cPU6UpTU01qvLAoD5tp1e2sf8P150GBXY9inqzGRn1rlIP9LPnUvkOlh7E/p70F4JrlbTBbty/z+f14=----ATTACHMENT:----NjcwOTI1NTY2OTE3NjUzOCA2NzYzNDI5OTA4NTgxNDEwIDcyMjA0MTMyMTYzMDA5Mg==