thereadme/node-telegram-api
1
0
Fork 0
Code Issues 9 Pull Requests Projects Releases Wiki Activity

Don't merge yet: Keep on listening to Telegram's updates even if requests with telegram server fail #40

Merged
laurynas-karvelis merged 2 commits from master into master 2018-02-18 17:21:07 +00:00
Conversation 10 Commits 2 Files Changed 2 +33 -19
2 changed files with 33 additions and 19 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

7
src/functions/poll.js
View File

@ -1,5 +1,6 @@
export default function poll(bot) { export default function poll(bot) {
return bot.api.getUpdates(bot.update).then(response => { return bot.api.getUpdates(bot.update)
.then(response => {
if (!response.result.length) { if (!response.result.length) {
return poll(bot); return poll(bot);
} }
@ -9,5 +10,9 @@ export default function poll(bot) {
return null; return null;
} }
return poll(bot); return poll(bot);
})
.catch(e => {
bot.emit('error', e);
return poll(bot);
}); });
} }

13
src/index.js
View File

@ -75,7 +75,8 @@ export default class Bot extends EventEmitter {
if (hook) { if (hook) {
return webhook(hook, this); return webhook(hook, this);
} }
return this.api.getMe().then(response => { return this.api.getMe()
.then(response => {
this.info = response.result; this.info = response.result;
this.on('update', this._update); this.on('update', this._update);
@ -85,6 +86,10 @@ export default class Bot extends EventEmitter {
} }
return poll(this); return poll(this);
})
.catch(e => {
this.emit('error', e);
throw e;
}); });
} }
@ -138,7 +143,11 @@ export default class Bot extends EventEmitter {
* @return {unknown} returns the result of calling message's send method * @return {unknown} returns the result of calling message's send method
*/ */
send(message) { send(message) {
return message.send(this); return message.send(this)
.catch(e => {
this.emit('error', e);
throw e;
});
} }
/** /**