WebSocketClient::onReadable() - Code Metrics - Inspection of "refactored some things, init websockets" - hfw/socket - Measure and Improve Code Quality continuously with Scrutinizer

Passed

Push — master ( b4e552...a91d54 )

by y

created 2020-03-02 13:52 UTC

WebSocketClient::onReadable() A

↳ Parent: WebSocketClient

Complexity

Conditions	5
Paths	5

Size

Total Lines	14
Code Lines	10

Duplication

Lines	0
Ratio	0 %

Importance

Changes	1
Bugs	0	Features	0

Metric	Value
cc	5
eloc	10
c	1
b	0
f	0
nc	5
nop	0
dl	0
loc	14
rs	9.6111

<?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 {
    protected function onData (/** @scrutinizer ignore-unused */ string $payload): void {
    }

    /**
     * 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 {
    protected function onText (/** @scrutinizer ignore-unused */ string $text): void {
    }

    /**
     * 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);
    }
}

hfw / socket

Push — master ( b4e552...a91d54 )

WebSocketClient::onReadable() A

Complexity

Size

Duplication

Importance

Duplication Side-by-Side

Filter issues like