mercuryworkshop-mirror/bare-mux
1
0
Fork 0
mirror of https://github.com/MercuryWorkshop/bare-mux.git synced 2025-05-14 14:50:03 -04:00
Code Issues Projects Releases Packages Wiki Activity Actions

im dumb

Browse source
This commit is contained in:
Percs 2024-09-04 19:04:27 -05:00
parent fae6b90225
commit 4b1c06d484
1 changed files with 15 additions and 6 deletions
Download patch file Download diff file Expand all files Collapse all files

21
src/websocket.ts
View file

@ -37,11 +37,14 @@ export class BareWebSocket extends EventTarget {
};
const event = new Event("open")
this.dispatchEvent(event);
this.onopen(event);
if (this.onopen) {
this.onopen(event);
}
};
const onmessage = async (payload) => {
if ("byteLength" in payload) {
if (typeof payload === "string") {
} else if ("byteLength" in payload) {
if (this.binaryType === "blob") {
payload = new Blob([payload]);
} else {
@ -56,21 +59,27 @@ export class BareWebSocket extends EventTarget {
const event = new MessageEvent("message", {data: payload });
this.dispatchEvent(event);
this.onmessage(event);
if (this.onmessage) {
this.onmessage(event);
}
};
const onclose = (code: number, reason: string) => {
this.readyState = WebSocketFields.CLOSED;
const event = new CloseEvent("close", { code, reason })
this.dispatchEvent(event);
this.onclose(event)
if (this.onclose) {
this.onclose(event);
}
};
const onerror = () => {
this.readyState = WebSocketFields.CLOSED;
const event = new Event("error");
this.dispatchEvent(event)
this.onerror(event)
this.dispatchEvent(event);
if (this.onerror) {
this.onerror(event);
};
};
this.channel = new MessageChannel();