socket.js

Socket = function(onMudOutput, blit, gmcp) {
    var exports = {}
    var mudReader = new FileReader();
    var inQ = []; // binary blobs incoming from websock, waiting to be processed

    // eats strings or Uint8Arrays (GMCP)
    function send(stuff) {
        if (stuff.length > 0) {
            // console.debug("sock> ", stuff)
            var b = new Blob([stuff], {type: 'application/octet-stream'});
            websock.send(b);
        }
    }

    mudReader.addEventListener("loadend", function() {
        // console.debug("sock< ", mudReader.result)
        var parseResult = gmcp.parse(mudReader.result);
        var mudstr = parseResult[0];
        send(new Uint8Array(parseResult[1])); // outgoing GMCP commands
        if (mudstr) // just GMCP?
            onMudOutput(mudstr);
        if (inQ.length > 0)
            mudReader.readAsBinaryString(inQ.shift());
        else
            window.setTimeout(blit, 1); // release the mudReader faster, but still scroll on event
    });

    function flushQ() {
        if (mudReader.readyState != 1) {
            mudReader.readAsBinaryString(inQ.shift());
        }
    }

    var websock = new WebSocket('wss://' + window.location.hostname + '/ws', 'binary');
    websock.addEventListener('message', function (event) {
        inQ.push(event.data);
        flushQ();
    });
    websock.onerror=function (e) {
        onMudOutput("\n\n\nWebSocket Error: " + e.reason + "\n");
        blit();
    }
    websock.onclose=function(e){
        onMudOutput("\n\n\nWebSocket Close: " + e.code + " " + e.reason + "\n");
        blit();
    }

    exports.send = send;
    exports.gmcpSend = function(cmd) { send(new Uint8Array(gmcp.gmcpify(cmd))); send("\n"); };

    return exports;
};