Gecko [ unitednationsplay.com ]

Name	Size	Permission	Date
CloseFrameChecker.php	643 B	-rw-r--r--	2018-05-02 09:00
DataInterface.php	672 B	-rw-r--r--	2018-05-02 09:00
Frame.php	13.5 KB	-rw-r--r--	2018-05-02 09:00
FrameInterface.php	650 B	-rw-r--r--	2018-05-02 09:00
Message.php	2.6 KB	-rw-r--r--	2018-05-02 09:00
MessageBuffer.php	6.85 KB	-rw-r--r--	2018-05-02 09:00
MessageInterface.php	383 B	-rw-r--r--	2018-05-02 09:00

Rename

<?php
namespace Ratchet\RFC6455\Messaging;

class Message implements \IteratorAggregate, MessageInterface {
    /**
     * @var \SplDoublyLinkedList
     */
    private $_frames;

public function __construct() {
        $this->_frames = new \SplDoublyLinkedList;
    }

public function getIterator() {
        return $this->_frames;
    }

/**
     * {@inheritdoc}
     */
    public function count() {
        return count($this->_frames);
    }

/**
     * {@inheritdoc}
     */
    public function isCoalesced() {
        if (count($this->_frames) == 0) {
            return false;
        }

$last = $this->_frames->top();

return ($last->isCoalesced() && $last->isFinal());
    }

/**
     * {@inheritdoc}
     */
    public function addFrame(FrameInterface $fragment) {
        $this->_frames->push($fragment);

return $this;
    }

/**
     * {@inheritdoc}
     */
    public function getOpcode() {
        if (count($this->_frames) == 0) {
            throw new \UnderflowException('No frames have been added to this message');
        }

return $this->_frames->bottom()->getOpcode();
    }

/**
     * {@inheritdoc}
     */
    public function getPayloadLength() {
        $len = 0;

foreach ($this->_frames as $frame) {
            try {
                $len += $frame->getPayloadLength();
            } catch (\UnderflowException $e) {
                // Not an error, want the current amount buffered
            }
        }

return $len;
    }

/**
     * {@inheritdoc}
     */
    public function getPayload() {
        if (!$this->isCoalesced()) {
            throw new \UnderflowException('Message has not been put back together yet');
        }

return $this->__toString();
    }

/**
     * {@inheritdoc}
     */
    public function getContents() {
        if (!$this->isCoalesced()) {
            throw new \UnderflowException("Message has not been put back together yet");
        }

$buffer = '';

foreach ($this->_frames as $frame) {
            $buffer .= $frame->getContents();
        }

return $buffer;
    }

public function __toString() {
        $buffer = '';

foreach ($this->_frames as $frame) {
            $buffer .= $frame->getPayload();
        }

return $buffer;
    }

/**
     * @return boolean
     */
    public function isBinary() {
        if ($this->_frames->isEmpty()) {
            throw new \UnderflowException('Not enough data has been received to determine if message is binary');
        }

return Frame::OP_BINARY === $this->_frames->bottom()->getOpcode();
    }
}