flibusta-apps/book_bot
1
0
Fork 0
mirror of https://github.com/flibusta-apps/book_bot.git synced 2025-12-06 15:35:35 +01:00
Code Issues Actions Packages Projects Releases Wiki Activity

Add sending action

Browse Source
This commit is contained in:
Kurbanov Bulat
2022-01-09 18:50:40 +03:00
parent 21640764f7
commit 460da1fd8a
1 changed files with 31 additions and 14 deletions
Download Patch File Download Diff File Expand all files Collapse all files

37
src/bots/factory/bots/approved/index.ts
View File

@@ -1,6 +1,6 @@
import * as Sentry from '@sentry/node';
import { Context, Telegraf, Markup, TelegramError } from 'telegraf';
import { Context, Telegraf, Markup, TelegramError, Telegram } from 'telegraf';
import { BotState, Cache } from '@/bots/manager';
@@ -152,16 +152,22 @@ export async function createApprovedBot(token: string, state: BotState): Promise
const [_, format, id] = ctx.message.text.split('_');
const chatId = ctx.message.chat.id;
if (state.cache === Cache.NO_CACHE) {
const book = await BookLibrary.getBookById(parseInt(id));
const data = await download(book.source.id, book.remote_id, format);
ctx.telegram.sendDocument(ctx.message.chat.id, data, {
reply_to_message_id: ctx.message.message_id
})
return;
const sendSendingAction = async () => {
await ctx.telegram.sendChatAction(chatId, "upload_document");
}
let cache: CachedMessage | null = null;
const sendWithoutCache = async () => {
const action = setInterval(() => sendSendingAction(), 1000);
try {
sendSendingAction();
const book = await BookLibrary.getBookById(parseInt(id));
const data = await download(book.source.id, book.remote_id, format);
await ctx.telegram.sendDocument(chatId, data)
} finally {
clearInterval(action);
}
}
const getCachedMessage = async () => {
if (state.cache === Cache.ORIGINAL) {
@@ -172,12 +178,23 @@ export async function createApprovedBot(token: string, state: BotState): Promise
};
const sendCached = async () => {
cache = await getCachedMessage();
const action = setInterval(() => sendSendingAction(), 1000);
try {
sendSendingAction();
const cache = await getCachedMessage();
await ctx.telegram.copyMessage(chatId, cache.chat_id, cache.message_id, {
allow_sending_without_reply: true,
});
} finally {
clearInterval(action);
}
};
if (state.cache === Cache.NO_CACHE) {
await sendWithoutCache();
return;
}
try {
await sendCached();