Dekescordes/spacebar
2
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

setup listeners

Browse Source
This commit is contained in:
Flam3rboy 2021-02-10 22:05:17 +01:00
parent caafbc606c
commit 3f8c652d68
7 changed files with 13 additions and 11 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

3
src/events/Connection.ts
View File

@ -5,7 +5,6 @@ import { Message } from "./Message";
import { setHeartbeat } from "../util/setHeartbeat"; import { setHeartbeat } from "../util/setHeartbeat";
import { Send } from "../util/Send"; import { Send } from "../util/Send";
import { CLOSECODES, OPCODES } from "../util/Constants"; import { CLOSECODES, OPCODES } from "../util/Constants";
import { setupListener } from "../listener/listener";
// TODO: check rate limit // TODO: check rate limit
// TODO: specify rate limit in config // TODO: specify rate limit in config
@ -37,8 +36,6 @@ export async function Connection(this: Server, socket: WebSocket, request: Incom
}, },
}); });
await setupListener.call(socket);
socket.readyTimeout = setTimeout(() => { socket.readyTimeout = setTimeout(() => {
return socket.close(CLOSECODES.Session_timed_out); return socket.close(CLOSECODES.Session_timed_out);
}, 1000 * 30); }, 1000 * 30);

3
src/events/Message.ts
View File

@ -18,7 +18,8 @@ export async function Message(this: WebSocket, buffer: Data) {
try { try {
if (this.encoding === "etf" && buffer instanceof Buffer) data = erlpack.unpack(buffer); if (this.encoding === "etf" && buffer instanceof Buffer) data = erlpack.unpack(buffer);
else if (this.encoding === "json" && typeof buffer === "string") data = JSON.parse(buffer); else if (this.encoding === "json" && typeof buffer === "string") data = JSON.parse(buffer);
if (!instanceOf(PayloadSchema, data)) throw "invalid data"; const result = instanceOf(PayloadSchema, data);
if (result !== true) throw "invalid data";
} catch (error) { } catch (error) {
return this.close(CLOSECODES.Decode_error); return this.close(CLOSECODES.Decode_error);
} }

2
src/opcodes/Heartbeat.ts
View File

@ -1,4 +1,4 @@
import { Payload } from "../util/Constants"; import { CLOSECODES, Payload } from "../util/Constants";
import { Send } from "../util/Send"; import { Send } from "../util/Send";
import { setHeartbeat } from "../util/setHeartbeat"; import { setHeartbeat } from "../util/setHeartbeat";
import WebSocket from "../util/WebSocket"; import WebSocket from "../util/WebSocket";

6
src/opcodes/PresenceUpdate.ts
View File

@ -1,4 +1,6 @@
import { Payload } from "../util/Constants"; import { CLOSECODES, Payload } from "../util/Constants";
import WebSocket from "../util/WebSocket"; import WebSocket from "../util/WebSocket";
export function onPresenceUpdate(this: WebSocket, data: Payload) {} export function onPresenceUpdate(this: WebSocket, data: Payload) {
return this.close(CLOSECODES.Unknown_error);
}

6
src/opcodes/RequestGuildMembers.ts
View File

@ -1,5 +1,7 @@
import { Payload } from "../util/Constants"; import { CLOSECODES, Payload } from "../util/Constants";
import WebSocket from "../util/WebSocket"; import WebSocket from "../util/WebSocket";
export function onRequestGuildMembers(this: WebSocket, data: Payload) {} export function onRequestGuildMembers(this: WebSocket, data: Payload) {
return this.close(CLOSECODES.Unknown_error);
}

2
src/opcodes/Resume.ts
View File

@ -1,4 +1,4 @@
import { Payload } from "../util/Constants"; import { CLOSECODES, Payload } from "../util/Constants";
import WebSocket from "../util/WebSocket"; import WebSocket from "../util/WebSocket";

2
src/opcodes/VoiceStateUpdate.ts
View File

@ -1,4 +1,4 @@
import { Payload } from "../util/Constants"; import { CLOSECODES, Payload } from "../util/Constants";
import WebSocket from "../util/WebSocket"; import WebSocket from "../util/WebSocket";