iframe-proxy | Sunbelt Computer Software

207 lines (177 loc) · 5.12 KB
namespace React\HttpClient;
use Evenement\EventEmitter;
use Exception;
use React\Stream\ReadableStreamInterface;
use React\Stream\Util;
use React\Stream\WritableStreamInterface;
 * @internal
class ChunkedStreamDecoder extends EventEmitter implements ReadableStreamInterface
    const CRLF = "\r\n";
     * @var string
    protected $buffer = '';
     * @var int
    protected $remainingLength = 0;
     * @var bool
    protected $nextChunkIsLength = true;
     * @var ReadableStreamInterface
    protected $stream;
     * @var bool
    protected $closed = false;
     * @var bool
    protected $reachedEnd = false;
     * @param ReadableStreamInterface $stream
    public function __construct(ReadableStreamInterface $stream)
        $this->stream = $stream;
        $this->stream->on('data', array($this, 'handleData'));
        $this->stream->on('end',  array($this, 'handleEnd'));
        Util::forwardEvents($this->stream, $this, array(
            'error',
        ));
    /** @internal */
    public function handleData($data)
        $this->buffer .= $data;
        do {
            $bufferLength = strlen($this->buffer);
            $continue = $this->iterateBuffer();
            $iteratedBufferLength = strlen($this->buffer);
        } while (
            $continue &&
            $bufferLength !== $iteratedBufferLength &&
            $iteratedBufferLength > 0
        if ($this->buffer === false) {
            $this->buffer = '';
    protected function iterateBuffer()
        if (strlen($this->buffer) <= 1) {
            return false;
        if ($this->nextChunkIsLength) {
            $crlfPosition = strpos($this->buffer, static::CRLF);
            if ($crlfPosition === false && strlen($this->buffer) > 1024) {
                $this->emit('error', array(
                    new Exception('Chunk length header longer then 1024 bytes'),
                $this->close();
                return false;
            if ($crlfPosition === false) {
                return false; // Chunk header hasn't completely come in yet
            $lengthChunk = substr($this->buffer, 0, $crlfPosition);
            if (strpos($lengthChunk, ';') !== false) {
                list($lengthChunk) = explode(';', $lengthChunk, 2);
            if ($lengthChunk !== '') {
                $lengthChunk = ltrim(trim($lengthChunk), "0");
                if ($lengthChunk === '') {
                    // We've reached the end of the stream
                    $this->reachedEnd = true;
                    $this->emit('end');
                    $this->close();
                    return false;
            $this->nextChunkIsLength = false;
            if (dechex((int)@hexdec($lengthChunk)) !== strtolower($lengthChunk)) {
                $this->emit('error', array(
                    new Exception('Unable to validate "' . $lengthChunk . '" as chunk length header'),
                $this->close();
                return false;
            $this->remainingLength = hexdec($lengthChunk);
            $this->buffer = substr($this->buffer, $crlfPosition + 2);
            return true;
        if ($this->remainingLength > 0) {
            $chunkLength = $this->getChunkLength();
            if ($chunkLength === 0) {
                return true;
            $this->emit('data', array(
                substr($this->buffer, 0, $chunkLength),
                $this
            $this->remainingLength -= $chunkLength;
            $this->buffer = substr($this->buffer, $chunkLength);
            return true;
        $this->nextChunkIsLength = true;
        $this->buffer = substr($this->buffer, 2);
        return true;
    protected function getChunkLength()
        $bufferLength = strlen($this->buffer);
        if ($bufferLength >= $this->remainingLength) {
            return $this->remainingLength;
        return $bufferLength;
    public function pause()
        $this->stream->pause();
    public function resume()
        $this->stream->resume();
    public function isReadable()
        return $this->stream->isReadable();
    public function pipe(WritableStreamInterface $dest, array $options = array())
        Util::pipe($this, $dest, $options);
        return $dest;
    public function close()
        $this->closed = true;
        return $this->stream->close();
    /** @internal */
    public function handleEnd()
        $this->handleData('');
        if ($this->closed) {
            return;
        if ($this->buffer === '' && $this->reachedEnd) {
            $this->emit('end');
            $this->close();
            return;
        $this->emit(
            'error',
            array(
                new Exception('Stream ended with incomplete control code')
        $this->close();
Sunbelt Computer Software

PL/B Language Development and Support

Provide feedback

Saved searches

Use saved searches to filter your results more quickly

Uh oh!

Uh oh!

Sunbelt Computer Software

PL/B Language Development and Support

Uh oh!

Uh oh!

FilesExpand file tree

ChunkedStreamDecoder.php

Latest commit

History

ChunkedStreamDecoder.php

File metadata and controls
