~starkingdoms/starkingdoms

ref: c0896910b0dbca86f7bab9c75fc014cd922ae099 starkingdoms/starkingdoms-client/src/gateway.ts -rw-r--r-- 1.2 KiB
c0896910 — ghostlyzsh Merge branch 'bevy_rewrite' of https://gitlab.com/starkingdoms.tk/starkingdoms.tk into bevy_rewrite 2 years ago
                                                                                
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
import createDebug from "debug";
import {Packet, PacketType} from "./protocol.ts";

const logger = createDebug("gateway");

export interface GatewayClient {
    socket: WebSocket;
}

export async function gateway_connect(url: string, username: string) {
    logger("connecting to gateway socket at " + url)

    let ws = await _websocket_connect(url);

    logger("connected to gateway, sending username and auth details");

    let client: GatewayClient = {
        socket: ws
    };

    let packet: Packet = {
        t: PacketType.ClientLogin,
        c: {
            username,
            jwt: null
        }
    };
    ws.send(JSON.stringify(packet));

    ws.onmessage = (e) => {
        let packet: Packet = JSON.parse(e.data);
        logger(packet);
    }

    return client;
}

let socket: WebSocket | undefined = undefined;

function _websocket_connect(url: string): Promise<WebSocket> {
    if (socket && socket.readyState < 2) {
        // reuse socket connection
        return Promise.resolve(socket);
    }
    return new Promise((resolve, reject) => {
        socket = new WebSocket(url);
        socket.onopen = () => {
            resolve(socket!);
        };
        socket.onerror = (err) => {
            reject(err);
        };
    });
}