<?php
require_once __DIR__ . '/vendor/autoload.php';

use Workerman\Connection\TcpConnection;
use Workerman\Protocols\Http\Request;
use Workerman\Worker;
use Workerman\Protocols\Websocket;

$worker = new Worker('http://0.0.0.0:1234');
$worker->onMessage = function (TcpConnection $connection, $request) {
    if ($request instanceof Request) {
        if ($request->header('upgrade') == 'websocket') {
            $connection->protocol = Websocket::class;
            Websocket::input($request, $connection);
            return;
        }
        $connection->send('http');
        return;
    }
    $connection->send('websocket');
};
Worker::runAll();