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

super advanced error handling™

Browse Source
This commit is contained in:
Flummi 2019-09-14 15:48:06 +00:00
parent bde8819e19
commit 59a2b77176
1 changed files with 9 additions and 6 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

15
src/clients/tg.mjs
View File

@ -45,9 +45,9 @@ export default class tg extends EventEmitter {
let res = await (await fetch(`${this.api}/getUpdates?offset=${this.lastUpdate}&allowed_updates=message`)).json(); let res = await (await fetch(`${this.api}/getUpdates?offset=${this.lastUpdate}&allowed_updates=message`)).json();
if (!res.ok) if (!res.ok)
return this.emit("data", ["error", res.description]); throw { type: "tg", message: res.description};
if (res.result.length === 0) if (res.result.length === 0)
return; throw { type: "generic", message: "empty response" };
res = res.result[res.result.length - 1]; res = res.result[res.result.length - 1];
this.lastUpdate = res.update_id + 1; this.lastUpdate = res.update_id + 1;
@ -62,11 +62,14 @@ export default class tg extends EventEmitter {
id: res.message.from.id id: res.message.from.id
}); });
} }
return this.emit("data", ["message", this.reply(res.message)]); this.emit("data", ["message", this.reply(res.message)]);
} }
} }
catch(lel) { catch(err) {
return this.emit("data", ["error", "tg timed out lol"]); if(!err.type)
this.emit("data", ["error", "tg timed out lol"]);
else if(err.type === "tg")
this.emit("data", ["error", err.message]);
} }
finally { finally {
setTimeout(async () => { await this.poll(); }, this.options.pollrate); setTimeout(async () => { await this.poll(); }, this.options.pollrate);
@ -80,7 +83,7 @@ export default class tg extends EventEmitter {
method: "POST", method: "POST",
body: { body: {
chat_id: chatid, chat_id: chatid,
text: this.format(msg),//msg.split("\n").length > 1 ? `<code>${this.format(msg)}</code>` : this.format(msg), text: this.format(msg),
parse_mode: "HTML" parse_mode: "HTML"
} }
}; };