Helix\Socket\WebSocketClient

Complexity

Total Complexity

13

Size/Duplication

Total Lines	80
Duplicated Lines	0 %

Importance

Changes	1
Bugs	0	Features	0

9 Methods

Rating	Name	Duplication	Size	Complexity
A	onText()	0	1	1
A	writeText()	0	3	1
A	onData()	0	1	1
A	onReadable()	0	14	5
A	ping()	0	2	1
A	onPong()	0	1	1
A	onClose()	0	2	1
A	onOutOfBand()	0	1	1
A	__construct()	0	3	1

<?php

namespace Helix\Socket;

/**
 * Client data framing.
 *
 * https://tools.ietf.org/html/rfc6455
 */
class WebSocketClient extends StreamClient implements ReactiveInterface {

    /**
     * @var WebSocketServer
     */
    protected $server;

    /**
     * @param $resource
     * @param WebSocketServer $server
     */
    public function __construct ($resource, WebSocketServer $server) {
        parent::__construct($resource);
        $this->server = $server;
    }

    /**
     * Removes the client from the server and reactor.
     */
    protected function onClose () {
        $this->server->remove($this);
    }

    /**
     * @param string $payload
     */
    protected function onData (string $payload): void {

The parameter $payload is not used and could be removed.

    }

    /**
     * WebSockets do not use the out-of-band channel.
     */
    final public function onOutOfBand () {
    }

    /**
     * When a browser responds to a ping.
     */
    protected function onPong (): void {
        // stub
    }

    /**
     * Reads framed messages.
     */
    public function onReadable (): void {
        $data = $this->recv(4096);
        $frame = new WebSocketFrame($data);
        if ($frame->isText()) {
            $this->onText($frame->getPayload());
        }
        elseif ($frame->isBinary()) {
            $this->onData($frame->getPayload());
        }
        elseif ($frame->isPong()) {
            $this->onPong();
        }
        elseif ($frame->isClose()) {
            $this->close();
        }
    }

    /**
     * Stub.
     *
     * @param string $text
     */
    protected function onText (string $text): void {

The parameter $text is not used and could be removed.

    }

    /**
     * Pings the browser.
     */
    public function ping () {
        $this->write(WebSocketFrame::pack('', WebSocketFrame::OP_PING));
    }

    public function writeText (string $message) {
        $packed = WebSocketFrame::pack($message);
        $this->write($packed);
    }
}