wist 0.1.5

Websocket Tunneling
Documentation 
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71

function appendBuffers(buffer1, buffer2) {
    var tmp = new Uint8Array(buffer1.byteLength + buffer2.byteLength);
    tmp.set(new Uint8Array(buffer1), 0);
    tmp.set(new Uint8Array(buffer2), buffer1.byteLength);
    return tmp.buffer;
}
;
export class WebSocket extends EventTarget {
    constructor(url) {
        super();
        var u = typeof url === "string" ? new URL(url) : url;
        if (u.protocol == "ws:") {
            u.protocol = "http:";
        }
        if (u.protocol == "wss:") {
            u.protocol = "https:";
        }
        u.pathname += ".wist";
        this._url = u;
        this._messages = [];
        this._start();
    }
    async _start() {
        let iid = await fetch(this._url).then(a => a.text());
        while (1) {
            var m = this._messages;
            if (!m.length) {
                await new Promise(requestAnimationFrame);
                continue;
            }
            this._messages = [];
            var m2 = m.reduce(appendBuffers, new ArrayBuffer(0));
            var a = await fetch(this._url, {
                method: "POST",
                body: m2,
                headers: {
                    "X-Instance-Id": iid,
                }
            }).then(a => a.arrayBuffer());
            var d = new DataView(a);
            var i = 0;
            while (i != a.byteLength) {
                var ty = d.getUint8(i);
                if (ty == 0xff) {
                    return;
                }
                var len = d.getUint32(i + 1);
                var b = a.slice(i + 5, i + 5 + len);
                i += len + 5;
                if (ty & 1) {
                    this.dispatchEvent(new MessageEvent("message", { data: new TextDecoder().decode(b) }));
                }
                else {
                    this.dispatchEvent(new MessageEvent("message", { data: b }));
                }
            }
        }
    }
    postMessage(message) {
        var b = typeof message == "string" ? new TextEncoder().encode(message) : new Uint8Array(message);
        var c = new ArrayBuffer(b.byteLength + 5);
        new Uint8Array(c, 5).set(b, 0);
        var d = new DataView(c);
        d.setUint8(0, typeof message == "string" ? 1 : 0);
        d.setUint32(1, b.byteLength);
        this._messages.push(c);
    }
    close(...args) {
        this._messages.push(new Uint8Array([0xff]).buffer);
    }
}