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

catch poll timeout

Browse Source
This commit is contained in:
Flummi 2019-09-14 14:56:56 +00:00
parent 82ab5f7c91
commit bde8819e19
1 changed files with 27 additions and 19 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

46
src/clients/tg.mjs
View File

@ -41,27 +41,35 @@ export default class tg extends EventEmitter {
}; };
} }
async poll() { async poll() {
let res = await (await fetch(`${this.api}/getUpdates?offset=${this.lastUpdate}&allowed_updates=message`)).json(); try {
setTimeout(async () => { await this.poll(); }, this.options.pollrate); let res = await (await fetch(`${this.api}/getUpdates?offset=${this.lastUpdate}&allowed_updates=message`)).json();
if (!res.ok)
return this.emit("data", ["error", res.description]);
if (res.result.length === 0)
return;
res = res.result[res.result.length - 1]; if (!res.ok)
this.lastUpdate = res.update_id + 1; return this.emit("data", ["error", res.description]);
if (res.message.date >= ~~(Date.now() / 1000) - 10 && res.message.message_id !== this.lastMessage) { if (res.result.length === 0)
this.lastMessage = res.message.message_id; return;
if (!this.server.user.has(res.message.from.username || res.message.from.first_name)) {
this.server.user.set(res.message.from.username || res.message.from.first_name, { res = res.result[res.result.length - 1];
nick: res.message.from.first_name, this.lastUpdate = res.update_id + 1;
username: res.message.from.username, if (res.message.date >= ~~(Date.now() / 1000) - 10 && res.message.message_id !== this.lastMessage) {
account: res.message.from.id.toString(), this.lastMessage = res.message.message_id;
prefix: `${res.message.from.username}!${res.message.from.id.toString()}`, if (!this.server.user.has(res.message.from.username || res.message.from.first_name)) {
id: res.message.from.id this.server.user.set(res.message.from.username || res.message.from.first_name, {
}); nick: res.message.from.first_name,
username: res.message.from.username,
account: res.message.from.id.toString(),
prefix: `${res.message.from.username}!${res.message.from.id.toString()}`,
id: res.message.from.id
});
}
return this.emit("data", ["message", this.reply(res.message)]);
} }
return this.emit("data", ["message", this.reply(res.message)]); }
catch(lel) {
return this.emit("data", ["error", "tg timed out lol"]);
}
finally {
setTimeout(async () => { await this.poll(); }, this.options.pollrate);
} }
} }
async send(chatid, msg, reply = null) { async send(chatid, msg, reply = null) {