summary refs log tree commit diff
diff options
context:
space:
mode:
-rw-r--r--src/events/Message.ts11
1 files changed, 8 insertions, 3 deletions
diff --git a/src/events/Message.ts b/src/events/Message.ts

index b72fd75f..6aa62a22 100644 --- a/src/events/Message.ts +++ b/src/events/Message.ts
@@ -2,11 +2,11 @@ import WebSocket, { Data } from "../util/WebSocket"; import erlpack from "erlpack"; import OPCodeHandlers from "../opcodes"; import { Payload, CLOSECODES } from "../util/Constants"; -import { instanceOf } from "lambert-server"; +import { instanceOf, Tuple } from "lambert-server"; const PayloadSchema = { op: Number, - $d: Object, + $d: new Tuple(Object, Number), // or number for heartbeat sequence $s: Number, $t: String, }; @@ -26,7 +26,12 @@ export async function Message(this: WebSocket, buffer: Data) { // @ts-ignore const OPCodeHandler = OPCodeHandlers[data.op]; - if (!OPCodeHandler) return this.close(CLOSECODES.Unknown_opcode); + if (!OPCodeHandler) { + console.error("Unknown_opcode: " + data.op); + // TODO: if all opcodes are implemented comment this out: + // this.close(CLOSECODES.Unknown_opcode); + return; + } try { return await OPCodeHandler.call(this, data);