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

Add WS_LOGEVENTS and WS_VERBOSE env vars

Browse Source
This commit is contained in:
Madeline 2022-12-31 12:00:00 +11:00
parent 0826d9125a
commit 0a09abbbfa
2 changed files with 17 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

16
src/gateway/events/Connection.ts
View File

@ -12,7 +12,7 @@ import { Config } from "@fosscord/util";
var erlpack: any; var erlpack: any;
try { try {
erlpack = require("@yukikaze-bot/erlpack"); erlpack = require("@yukikaze-bot/erlpack");
} catch (error) {} } catch (error) { }
// TODO: check rate limit // TODO: check rate limit
// TODO: specify rate limit in config // TODO: specify rate limit in config
@ -39,6 +39,20 @@ export async function Connection(
// `[Gateway] New connection from ${socket.ipAddress}, total ${this.clients.size}`, // `[Gateway] New connection from ${socket.ipAddress}, total ${this.clients.size}`,
// ); // );
if (process.env.WS_LOGEVENTS)
[
"close",
"error",
"upgrade",
//"message",
"open",
"ping",
"pong",
"unexpected-response"
].forEach((x) => {
socket.on(x, (y) => console.log(x, y));
});
const { searchParams } = new URL(`http://localhost${request.url}`); const { searchParams } = new URL(`http://localhost${request.url}`);
// @ts-ignore // @ts-ignore
socket.encoding = searchParams.get("encoding") || "json"; socket.encoding = searchParams.get("encoding") || "json";

2
src/gateway/events/Message.ts
View File

@ -33,6 +33,8 @@ export async function Message(this: WebSocket, buffer: WS.Data) {
} }
else return this.close(CLOSECODES.Decode_error); else return this.close(CLOSECODES.Decode_error);
if (process.env.WS_VERBOSE) console.log(`[Websocket] Incomming message: ${JSON.stringify(data)}`);
check.call(this, PayloadSchema, data); check.call(this, PayloadSchema, data);
// @ts-ignore // @ts-ignore