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

advanced error handling™

Browse Source
This commit is contained in:
Flummi 2019-11-19 01:55:38 +01:00
parent 6885508e01
commit 09bb65a4d2
1 changed files with 11 additions and 7 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

18
src/clients/slack.mjs
View File

@ -62,18 +62,22 @@ export default class slack extends EventEmitter {
setInterval(async () => await this.ping(), 3e4); // 30 seconds lul setInterval(async () => await this.ping(), 3e4); // 30 seconds lul
this.server.wss.socket.on("data", async data => { this.server.wss.socket.on("data", async data => {
data = data.toString("utf-8").replace(/\0/g, ""); try {
data = JSON.parse(data.substr(data.indexOf("{"))); data = data.toString("utf-8").replace(/\0/g, "");
data = JSON.parse(data.substr(data.indexOf("{")));
//console.log(data, data.type); //console.log(data, data.type);
if(data.type !== "message") if(data.type !== "message")
return false; return false;
await Promise.all([this.getChannel(data.channel), this.getUser(data.user)]).catch(err => this.emit("data", [ "error", err ])); await Promise.all([this.getChannel(data.channel), this.getUser(data.user)]);
//await this.getUser(data.user).catch(err => this.emit("data", [ "error", err ]));
return this.emit("data", [ "message", this.reply(data) ]); return this.emit("data", [ "message", this.reply(data) ]);
}
catch(err) {
this.emit("data", [ "error", err ]);
}
}) })
.on("end", () => this.emit("data", [ "debug", "stream ended" ])) .on("end", () => this.emit("data", [ "debug", "stream ended" ]))
.on("error", err => this.emit("data", [ "error", err ])); .on("error", err => this.emit("data", [ "error", err ]));