keinBot/cuffeo
2
2
Fork 0
Code Issues Pull Requests Projects Releases Wiki Activity

reconnect lul

Browse Source
This commit is contained in:
Flummi 2019-11-20 13:20:06 +01:00
parent 4247b8e82d
commit 0211ab428f
1 changed files with 14 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

16
src/clients/slack.mjs
View File

@ -90,11 +90,23 @@ export default class slack extends EventEmitter {
this.emit("data", [ "error", err ]); this.emit("data", [ "error", err ]);
} }
}) })
.on("end", () => this.emit("data", [ "debug", "stream ended" ])) .on("end", () => {
.on("error", err => this.emit("data", [ "error", err ])); 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) { async getChannel(channelId) {
if(this.server.channel.has(channelId)) if(this.server.channel.has(channelId))
return this.server.channel.get(channelId); return this.server.channel.get(channelId);