From 0a09abbbfadbdd38781e633cf9858d8e7b795866 Mon Sep 17 00:00:00 2001 From: Madeline <46743919+MaddyUnderStars@users.noreply.github.com> Date: Sat, 31 Dec 2022 12:00:00 +1100 Subject: Add WS_LOGEVENTS and WS_VERBOSE env vars --- src/gateway/events/Connection.ts | 16 +++++++++++++++- src/gateway/events/Message.ts | 2 ++ 2 files changed, 17 insertions(+), 1 deletion(-) (limited to 'src/gateway') diff --git a/src/gateway/events/Connection.ts b/src/gateway/events/Connection.ts index ee75212f..d47ac314 100644 --- a/src/gateway/events/Connection.ts +++ b/src/gateway/events/Connection.ts @@ -12,7 +12,7 @@ import { Config } from "@fosscord/util"; var erlpack: any; try { erlpack = require("@yukikaze-bot/erlpack"); -} catch (error) {} +} catch (error) { } // TODO: check rate limit // TODO: specify rate limit in config @@ -39,6 +39,20 @@ export async function Connection( // `[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}`); // @ts-ignore socket.encoding = searchParams.get("encoding") || "json"; diff --git a/src/gateway/events/Message.ts b/src/gateway/events/Message.ts index a88495f6..57af0c69 100644 --- a/src/gateway/events/Message.ts +++ b/src/gateway/events/Message.ts @@ -33,6 +33,8 @@ export async function Message(this: WebSocket, buffer: WS.Data) { } 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); // @ts-ignore -- cgit 1.4.1