:bug: fix heartbeat error

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);