PEAR2/Net/RouterOS/Response.php

Go to the documentation of this file.

<?php

namespace PEAR2\Net\RouterOS;

class Response extends Message
{
    
    const TYPE_FINAL = '!done';
    
    const TYPE_DATA = '!re';
    
    const TYPE_ERROR = '!trap';
    
    const TYPE_FATAL = '!fatal';

    protected $unrecognizedWords = array();

    private $_type = null;

    public function __construct(Communicator $com, $asStream = false)
    {
        if (!$com->getTransmitter()->isDataAwaiting()) {
            throw new SocketException(
                'No data awaiting. Receiving aborted.', 206
            );
        }
        $this->setType($com->getNextWord());
        if ($asStream) {
            for (
            $word = $com->getNextWordAsStream(), fseek($word, 0, SEEK_END);
                    ftell($word) !== 0;
                    $word = $com->getNextWordAsStream(), fseek(
                        $word, 0, SEEK_END
                    )
            ) {
                rewind($word);
                $ind = fread($word, 1);
                if ('=' === $ind || '.' === $ind) {
                    $prefix = stream_get_line($word, null, '=');
                }
                if ('=' === $ind) {
                    $value = fopen('php://temp', 'r+b');
                    $bytesCopied = ftell($word);
                    while (!feof($word)) {
                        $bytesCopied += stream_copy_to_stream(
                            $word, $value, 0xFFFFF, $bytesCopied
                        );
                    }
                    rewind($value);
                    $this->setArgument($prefix, $value);
                    continue;
                }
                if ('.' === $ind && 'tag' === $prefix) {
                    $this->setTag(stream_get_contents($word, -1, -1));
                    continue;
                }
                rewind($word);
                $this->unrecognizedWords[] = $word;
            }
        } else {
            for ($word = $com->getNextWord(); '' !== $word;
                    $word = $com->getNextWord()
            ) {
                if (preg_match('/^=([^=]+)=(.*)$/sm', $word, $matches)) {
                    $this->setArgument($matches[1], $matches[2]);
                } elseif (preg_match('/^\.tag=(.*)$/sm', $word, $matches)) {
                    $this->setTag($matches[1]);
                } else {
                    $this->unrecognizedWords[] = $word;
                }
            }
        }
    }

    protected function setType($type)
    {
        switch ($type) {
        case self::TYPE_FINAL:
        case self::TYPE_DATA:
        case self::TYPE_ERROR:
        case self::TYPE_FATAL:
            $this->_type = $type;
            return $this;
        default:
            throw new UnexpectedValueException(
                'Unrecognized response type.', 207, null, $type
            );
        }
    }

    public function getType()
    {
        return $this->_type;
    }

    public function getUnrecognizedWords()
    {
        return $this->unrecognizedWords;
    }

}