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

🐛 fix heartbeat error

Browse Source
This commit is contained in:
Flam3rboy 2021-04-06 04:06:47 +02:00
parent e4115d13ef
commit 8c0bde696d
1 changed files with 8 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

11
src/events/Message.ts
View File

@ -2,11 +2,11 @@ import WebSocket, { Data } from "../util/WebSocket";
import erlpack from "erlpack"; import erlpack from "erlpack";
import OPCodeHandlers from "../opcodes"; import OPCodeHandlers from "../opcodes";
import { Payload, CLOSECODES } from "../util/Constants"; import { Payload, CLOSECODES } from "../util/Constants";
import { instanceOf } from "lambert-server"; import { instanceOf, Tuple } from "lambert-server";
const PayloadSchema = { const PayloadSchema = {
op: Number, op: Number,
$d: Object, $d: new Tuple(Object, Number), // or number for heartbeat sequence
$s: Number, $s: Number,
$t: String, $t: String,
}; };
@ -26,7 +26,12 @@ export async function Message(this: WebSocket, buffer: Data) {
// @ts-ignore // @ts-ignore
const OPCodeHandler = OPCodeHandlers[data.op]; 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 { try {
return await OPCodeHandler.call(this, data); return await OPCodeHandler.call(this, data);