Function ply_net_ws_connect

js/net.js:79–113

(socket_id, addr)

var ply_net_sockets = {};

function ply_net_ws_connect(socket_id, addr) {
    var addr_string = consume_js_object(addr);
    var recv_buffer = [];

    var ws = new WebSocket(addr_string);
    ws.binaryType = 'arraybuffer';

    ws.onopen = function () {
        recv_buffer.push({ "type": PLY_WS_CONNECTED });
    };

    ws.onmessage = function (msg) {
        if (typeof msg.data === "string") {
            recv_buffer.push({ "type": PLY_WS_TEXT, "data": msg.data });
        } else {
            recv_buffer.push({ "type": PLY_WS_BINARY, "data": new Uint8Array(msg.data) });
        }
    };

    ws.onerror = function (error) {
        recv_buffer.push({
            "type": PLY_WS_ERROR,
            "data": JSON.stringify(error.message || "WebSocket error")
        });
    };

    ws.onclose = function () {
        recv_buffer.push({ "type": PLY_WS_CLOSED });
    };

    ply_net_sockets[socket_id] = {
        ws: ws,
        recv_buffer: recv_buffer
    };
}

function ply_net_ws_send_binary(socket_id, data) {
    var entry = ply_net_sockets[socket_id];