From 8c0bde696d4e03742f3b20797743415d7ba7b41f Mon Sep 17 00:00:00 2001
From: Flam3rboy <34555296+Flam3rboy@users.noreply.github.com>
Date: Tue, 6 Apr 2021 04:06:47 +0200
Subject: [PATCH] :bug: fix heartbeat error

---
 src/events/Message.ts | 11 ++++++++---
 1 file 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);