Socket.js

import { encode, decode, decodeAsync } from "@msgpack/msgpack";

class Socket {
    constructor(game, url) {
        this.game = game;
        this.ws = new WebSocket(url);
        this.handlers = new Map();
        this.ws.onmessage = async (message) => {
            try {
                const [type, ...data] = await this.decodeFromBlob(message.data);
                const handler = this.handlers.get(type);

                handler && handler(...data);
            } catch (err) {
                console.log(err);
            }
        };
    }
    emit(type, ...data) {
        this.ws.send(
            encode([
                type,
                ...data.filter((d) => typeof d !== "function"), // Temp solution
            ])
        );
    }
    on(type, handler) {
        this.handlers.set(type, handler);
    }
    async decodeFromBlob(blob) {
        if (blob.stream) {
            return await decodeAsync(blob.stream());
        }

        return decode(await blob.arrayBuffer());
    }
}
export { Socket };