flibusta-apps/book_bot
1
0
Fork 0
mirror of https://github.com/flibusta-apps/book_bot.git synced 2026-03-03 07:00:53 +01:00
Code Issues Actions 3 Packages Projects Releases Wiki Activity

Update debug logs

Browse Source
This commit is contained in:
Bulat Kurbanov
2022-03-14 20:13:03 +03:00
parent f73e7fe005
commit 6d50c45fa4
1 changed files with 5 additions and 5 deletions
Download Patch File Download Diff File Expand all files Collapse all files

10
src/bots/manager/index.ts
View File

@@ -25,7 +25,7 @@ export default class BotsManager {
// Bots // Bots
static bots: {[key: number]: Telegraf} = {}; static bots: {[key: number]: Telegraf} = {};
static botsStates: {[key: number]: BotState} = {}; static botsStates: {[key: number]: BotState} = {};
static botsPeddingUpdateCount: {[key: number]: number} = {}; static botsPendingUpdatesCount: {[key: number]: number} = {};
// Intervals // Intervals
static syncInterval: NodeJS.Timer | null = null; static syncInterval: NodeJS.Timer | null = null;
@@ -53,6 +53,8 @@ export default class BotsManager {
(value: BotState) => this._checkPendingUpdates(this.bots[value.id], value) (value: BotState) => this._checkPendingUpdates(this.bots[value.id], value)
) )
); );
console.log("Bots pending updates count:", this.botsPendingUpdatesCount);
} }
} }
@@ -89,15 +91,13 @@ export default class BotsManager {
static async _checkPendingUpdates(bot: Telegraf, state: BotState) { static async _checkPendingUpdates(bot: Telegraf, state: BotState) {
try { try {
const webhookInfo = await bot.telegram.getWebhookInfo(); const webhookInfo = await bot.telegram.getWebhookInfo();
const previousPendingUpdateCount = this.botsPeddingUpdateCount[state.id] || 0; const previousPendingUpdateCount = this.botsPendingUpdatesCount[state.id] || 0;
console.log("Check pending updates:", {state, webhookInfo});
if (previousPendingUpdateCount !== 0 && webhookInfo.pending_update_count !== 0) { if (previousPendingUpdateCount !== 0 && webhookInfo.pending_update_count !== 0) {
this._setWebhook(bot, state); this._setWebhook(bot, state);
} }
this.botsPeddingUpdateCount[state.id] = webhookInfo.pending_update_count; this.botsPendingUpdatesCount[state.id] = webhookInfo.pending_update_count;
} catch (e) { } catch (e) {
Sentry.captureException(e, { Sentry.captureException(e, {
extra: { extra: {