Helix\Socket\WebSocket\MessageHandler

Complexity

Total Complexity

11

Size/Duplication

Total Lines	108
Duplicated Lines	0 %

Importance

Changes	1
Bugs	0	Features	0

10 Methods

Rating	Name	Duplication	Size	Complexity
A	onText()	0	3	1
A	setBinaryStream()	0	3	1
A	isBinaryStream()	0	2	1
A	onText_CheckUtf8()	0	3	2
A	getMaxLength()	0	2	1
A	onBinary()	0	3	1
A	setTextStream()	0	3	1
A	setMaxLength()	0	3	1
A	__construct()	0	2	1
A	isTextStream()	0	2	1

<?php

namespace Helix\Socket\WebSocket;

class MessageHandler {

    /**
     * Whether to handle each binary frame as a message.
     *
     * @var bool
     */
    protected $binaryStream = true;

    /**
     * @var WebSocketClient
     */
    protected $client;

    /**
     * The maximum size of a complete message.
     *
     * @var int
     */
    protected $maxLength = 10 * 1024 * 1024; // 10 MiB

    /**
     * Whether to handle each text frame as a message.
     *
     * @var bool
     */
    protected $textStream = true;

    /**
     * @param WebSocketClient $client
     */
    public function __construct (WebSocketClient $client) {
        $this->client = $client;
    }

    /**
     * @return int
     */
    final public function getMaxLength (): int {
        return $this->maxLength;
    }

    /**
     * @return bool
     */
    final public function isBinaryStream (): bool {
        return $this->binaryStream;
    }

    /**
     * @return bool
     */
    final public function isTextStream (): bool {
        return $this->textStream;
    }

    /**
     * @param string $binary
     */
    public function onBinary (string $binary): void {
        unset($binary);
        throw new WebSocketError(Frame::CLOSE_UNHANDLED_DATA, "I don't handle binary data.");
    }

    /**
     * @param string $text
     */
    public function onText (string $text): void {
        $this->onText_CheckUtf8($text);
        throw new WebSocketError(Frame::CLOSE_UNHANDLED_DATA, "I don't handle text.");
    }

    /**
     * Throws if the payload isn't UTF-8.
     *
     * @param string $text
     */
    protected function onText_CheckUtf8 (string $text): void {
        if (!mb_detect_encoding($text, 'UTF-8', true)) {
            throw new WebSocketError(Frame::CLOSE_BAD_DATA, "Received TEXT is not UTF-8.");
        }
    }

    /**
     * @param bool $flag
     * @return $this
     */
    public function setBinaryStream (bool $flag) {
        $this->binaryStream = $flag;
        return $this;
    }

    /**
     * @param int $maxLength
     * @return $this
     */
    public function setMaxLength (int $maxLength) {
        $this->maxLength = $maxLength;
        return $this;
    }

    /**
     * @param bool $flag
     * @return $this
     */
    public function setTextStream (bool $flag) {
        $this->textStream = $flag;
        return $this;
    }

}