Server : Apache System : Linux server2.corals.io 4.18.0-348.2.1.el8_5.x86_64 #1 SMP Mon Nov 15 09:17:08 EST 2021 x86_64 User : corals ( 1002) PHP Version : 7.4.33 Disable Function : exec,passthru,shell_exec,system Directory :  /home/corals/old/vendor/textalk/websocket/examples/

Upload File : current_dir [ Writeable ] document_root [ Writeable ]

<?php

/**
 * This file is used for the tests, but can also serve as an example of a WebSocket\Server.
 * Run in console: php examples/echoserver.php
 *
 * Console options:
 *  --port <int> : The port to listen to, default 8000
 *  --timeout <int> : Timeout in seconds, default 200 seconds
 *  --debug : Output log data (if logger is available)
 */

namespace WebSocket;

require __DIR__ . '/../vendor/autoload.php';

error_reporting(-1);

echo "> Echo server\n";

// Server options specified or random
$options = array_merge([
    'port'          => 8000,
    'timeout'       => 200,
    'filter'        => ['text', 'binary', 'ping', 'pong', 'close'],
], getopt('', ['port:', 'timeout:', 'debug']));

// If debug mode and logger is available
if (isset($options['debug']) && class_exists('WebSocket\EchoLog')) {
    $logger = new EchoLog();
    $options['logger'] = $logger;
    echo "> Using logger\n";
}

// Initiate server.
try {
    $server = new Server($options);
} catch (ConnectionException $e) {
    echo "> ERROR: {$e->getMessage()}\n";
    die();
}

echo "> Listening to port {$server->getPort()}\n";

// Force quit to close server
while (true) {
    try {
        while ($server->accept()) {
            echo "> Accepted on port {$server->getPort()}\n";
            while (true) {
                $message = $server->receive();
                $opcode = $server->getLastOpcode();
                if (is_null($message)) {
                    echo "> Closing connection\n";
                    continue 2;
                }
                echo "> Got '{$message}' [opcode: {$opcode}]\n";
                if (in_array($opcode, ['ping', 'pong'])) {
                    $server->send($message);
                    continue;
                }
                // Allow certain string to trigger server action
                switch ($message) {
                    case 'exit':
                        echo "> Client told me to quit.  Bye bye.\n";
                        $server->close();
                        echo "> Close status: {$server->getCloseStatus()}\n";
                        exit;
                    case 'headers':
                        $server->text(implode("\r\n", $server->getRequest()));
                        break;
                    case 'ping':
                        $server->ping($message);
                        break;
                    case 'auth':
                        $auth = $server->getHeader('Authorization');
                        $server->text("{$auth} - {$message}");
                        break;
                    default:
                        $server->text($message);
                }
            }
        }
    } catch (ConnectionException $e) {
        echo "> ERROR: {$e->getMessage()}\n";
    }
}