From 0211ab428f3fe323777d3a7d21f46b4ee323a8e5 Mon Sep 17 00:00:00 2001 From: Flummi Date: Wed, 20 Nov 2019 13:20:06 +0100 Subject: [PATCH] reconnect lul --- src/clients/slack.mjs | 16 ++++++++++++++-- 1 file changed, 14 insertions(+), 2 deletions(-) diff --git a/src/clients/slack.mjs b/src/clients/slack.mjs index cf6afe5..472e0e1 100644 --- a/src/clients/slack.mjs +++ b/src/clients/slack.mjs @@ -90,11 +90,23 @@ export default class slack extends EventEmitter { this.emit("data", [ "error", err ]); } }) - .on("end", () => this.emit("data", [ "debug", "stream ended" ])) - .on("error", err => this.emit("data", [ "error", err ])); + .on("end", () => { + this.emit("data", [ "debug", "stream ended" ]); + this.reconnect(); + }) + .on("error", err => { + this.emit("data", [ "error", err ]); + this.reconnect(); + }); }); } + reconnect() { + this.server.wss.url = null; + this.server.wss.socket = null; + this.connect(); + } + async getChannel(channelId) { if(this.server.channel.has(channelId)) return this.server.channel.get(channelId);