phpWebSocketServer/server/RFC6455.php

protected function Handshake($Socket, $Buffer) {

        $errorResponds = [];
        $SocketID = intval($Socket);
        $Headers = [];
        $reqResource = [];
        $Lines = explode("\n", $Buffer);

        if ($Lines[0] == "php process") {
            $this->Log('Handshake:' . $Buffer);
            $this->Clients[$SocketID]->Headers = 'tcp';
            $this->Clients[$SocketID]->Handshake = true;
            preg_match("/GET (.*) HTTP/i", $Buffer, $reqResource);
            $Headers['get'] = trim($reqResource[1]);
            if (isset($this->allApps[$Headers['get']])) {
                $this->Clients[$SocketID]->app = $this->allApps[$Headers['get']];
            }
            return true;
        }
        $this->Log('Handshake: webClient');
        foreach ($Lines as $Line) {
            if (strpos($Line, ":") !== false) {
                $Header = explode(":", $Line, 2);
                $Headers[strtolower(trim($Header[0]))] = trim($Header[1]);
            } else if (stripos($Line, "get ") !== false) {
                preg_match("/GET (.*) HTTP/i", $Buffer, $reqResource);
                $Headers['get'] = trim($reqResource[1]);
            }
        }
  
        if (!isset($Headers['host']) || !isset($Headers['origin']) ||
                !isset($Headers['sec-websocket-key']) ||
                (!isset($Headers['upgrade']) || strtolower($Headers['upgrade']) != 'websocket') ||
                (!isset($Headers['connection']) || strpos(strtolower($Headers['connection']), 'upgrade') === FALSE)) {
            $errorResponds[] = "HTTP/1.1 400 Bad Request";
        }
        if (!isset($Headers['sec-websocket-version']) || strtolower($Headers['sec-websocket-version']) != 13) {
            $errorResponds[] = "HTTP/1.1 426 Upgrade Required\r\nSec-WebSocketVersion: 13";
        }
        if (!isset($Headers['get'])) {
            $errorResponds[] = "HTTP/1.1 405 Method Not Allowed\r\n\r\n";
        }
        if (count($errorResponds) > 0) {
            $message = implode("\r\n", $errorResponds);
            fwrite($Socket, $message, strlen($message));
            $this->onError($SocketID, "Handshake aborted - [" . trim($message) . "]");
            $this->Close($Socket);
            return false;
        }
        $Token = "";
        $sah1 = sha1($Headers['sec-websocket-key'] . "258EAFA5-E914-47DA-95CA-C5AB0DC85B11");
        for ($i = 0; $i < 20; $i++) {
            $Token .= chr(hexdec(substr($sah1, $i * 2, 2)));
        }
        $Token = base64_encode($Token);
        $statusLine = "HTTP/1.1 101 Switching Protocols\r\nUpgrade: websocket\r\nConnection: Upgrade\r\nSec-WebSocket-Accept: $Token\r\n\r\n";
        fwrite($Socket, $statusLine, strlen($statusLine));

        $this->Clients[$SocketID]->Headers = 'websocket';
        $this->Clients[$SocketID]->Handshake = true;
        if (isset($this->allApps[$Headers['get']])) {
            $this->Clients[$SocketID]->app = $this->allApps[$Headers['get']];
        }
        return true;
    }
    

phpWebSocketServer/server/RFC6455.php

    /* 
    Let's have a closer look at this method.
    We have decode the message and have a look at the opcode encoded.
    Next we will 'release' the client by sending the 'next' message.
    If the message will come in chunks we have to collect them.
    Finally we return the message 
    */

    private function extractMessage($SocketID, $message) {
        $client = $this->Clients[$SocketID];

        $message = $this->Decode($message);
        if ($this->opcode == 10) { //pong
            $this->log("Unsolicited Pong frame received from socket #$SocketID"); // just ignore
            return '';
        }
        if ($this->opcode == 8) { //Connection Close Frame 
            $this->log("Connection Close frame received from socket #$SocketID");
            $this->Close($SocketID);
            return '';
        }
        if ($this->fin == 0 && $this->opcode == 0) {
            $this->Clients[$SocketID]->fin = false; // fragmented message
        } else if ($this->fin != 0 && $this->opcode != 0) {
            $this->Clients[$SocketID]->fin = true;
        }


        $this->Write($SocketID, json_encode((object) [
                            'opcode' => 'next',
                            'fyi' => $this->Clients[$SocketID]->fyi]));
        /*
         * ***********************************************
         * take car of buffering messages either because
         * buffrerON===true or fin===false
         * ***********************************************
         */
        if ($this->serverCommand($client, $message)) {
            return '';
        }

        if ($client->bufferON) {
            if (count($client->buffer) <= $this->maxChunks) {
                $client->buffer[] = $message;
            } else {
                $this->log("Too many chunks from socket #$SocketID");
                $this->onCLose($SocketID);
            }
            return '';
        }
        return $message;
    }
    

phpWebSocketServer/webClient/socketWebClient.php

Here are the functions that overwrite the internal dummy functions

 
function setCallbackStatus(func) {
    //  overwrite dummy call back with your own func
    callbackStatus = func;
}
function setCallbackReady(func) {
    //  overwrite dummy call back with your own func
    callbackReady = func;
}
function setCallbackReadMessage(func) {
    //  overwrite dummy call back with your own func
    callbackReadMessage = func;
}
    

phpWebSocketServer/server/webSocketServer.php

function __construct($Address, $Port, $logger, $keyAndCertFile = '', $pathToCert = '') {

    $errno = 0;
    $errstr = '';
    $this->logging = $logger;

    $usingSSL = '';
    $context = stream_context_create();
    if ($this->isSecure($Address)) {
        stream_context_set_option($context, 'ssl', 'local_cert', $keyAndCertFile);
        stream_context_set_option($context, 'ssl', 'capth', $pathToCert);
        stream_context_set_option($context, 'ssl', 'allow_self_signed', true);
        stream_context_set_option($context, 'ssl', 'verify_peer', false);
        $usingSSL = "using SSL";
    }
    $socket = stream_socket_server("$Address:$Port", $errno, $errstr, 
                                   STREAM_SERVER_BIND | STREAM_SERVER_LISTEN, $context);

    $this->Log("Server initialized on " . PHP_OS . "  $Address:$Port $usingSSL");
    if (!$socket) {
        $this->Log("Error $errno creating stream: $errstr", true);
        exit;
    }
    $this->serveros = PHP_OS;
    $this->Sockets[ intval($socket)] = $socket;
    $this->socketMaster = $socket;
    $this->allowedIP[] = gethostbyname($Address);
    $this->allowedIP[] = '::1'; // ipv6 

    error_reporting($this->errorReport);
    set_time_limit($this->timeLimit);
    if ($this->implicitFlush) {
        ob_implicit_flush();
    }
}
        

phpWebSocketServer/server/webSocketServer.php

public function registerResource($name, $app) {
    $this->allApps[$name] = $app;
    foreach (['registerServer', 'onOpen', 'onData', 'onClose', 'onError'] as $method) {
        if (!method_exists($app, $method)) {
            $this->allApps[$name] = NULL;
            return false;
        }
    }
    $app->registerServer($this);
    return true;
}
    

phpWebSocketServer/server/webSocketServer.php

private function specificChecks($SocketID) {

    $ok = true;
    $Client = $this->Clients[$SocketID];

    if ($Client->app === NULL) {
        $this->Log("Application incomplete or does not exist);"
                . " Telling Client to disconnect on  #$SocketID");
        $msg = (object) ['opcode' => 'close'];
        $this->Write($SocketID, json_encode($msg));
        $this->Close($SocketID);
        $ok = false;
    }

    if ($this->maxPerIP > 0 && $this->Clients[$SocketID]->clientType == 'websocket') {
        /*
         * ***********************************************
         * track number of websocket connectins from this IP
         * ***********************************************
         */
        $ip = $Client->ip;
        if (!isset($this->clientIPs[$ip])) {
            $this->clientIPs[$ip] = (object) [
                        'SocketId' => $SocketID,
                        'count' => 1
            ];
        } else {
            $this->clientIPs[$ip]->count++;
            if ($this->clientIPs[$ip]->count > $this->maxPerIP) {
                $msg = "To many connections from:  $ip";
                $this->Log("$SocketID, $msg");
                $this->Write($SocketID, json_encode((object) ['opcode' => 'close', 'error' => $msg]));
                $this->Close($SocketID);
                $ok = false;
            }
        }
    } else if (count($this->allowedIP) > 0 && $this->Clients[$SocketID]->clientType != 'websocket') {
        /*
         * ***********************************************
         * check if tcp client connects from allowed host
         * ***********************************************
         */
        if (!in_array($Client->ip, $this->allowedIP)) {
            $this->Close($SocketID);
            $this->Log("$SocketID, No connection allowed from: " . $Client->ip);
            $ok = false;
        }
    }
    return $ok;
}