admin/next-downloader-bot
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

refactor: improve error handling and code readability in download feature; streamline URL validation and response logic

Browse Source
This commit is contained in:
vchikalkin 2025-08-15 18:59:45 +03:00
parent b38a1ef2b6
commit 8df2c47e1a
1 changed files with 11 additions and 9 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

20
apps/bot/src/bot/features/download.ts
View File

@ -8,7 +8,6 @@ import { Downloader } from '@tobyg74/tiktok-api-dl';
import { Composer, InputFile } from 'grammy'; import { Composer, InputFile } from 'grammy';
const composer = new Composer<Context>(); const composer = new Composer<Context>();
const feature = composer.chatType('private'); const feature = composer.chatType('private');
const redis = getRedisInstance(); const redis = getRedisInstance();
@ -17,17 +16,21 @@ feature.on('message:text', logHandle('download-message'), async (context) => {
try { try {
const url = context.message.text.trim(); const url = context.message.text.trim();
if (!validateTikTokUrl(url)) return context.reply(context.t('invalid_url')); if (!validateTikTokUrl(url)) {
return context.reply(context.t('invalid_url'));
}
const cachedFileId = await redis.get(url); const cachedFileId = await redis.get(url);
if (cachedFileId) {
if (cachedFileId) return context.replyWithVideo(cachedFileId); return context.replyWithVideo(cachedFileId);
}
const { message, result } = await Downloader(url, { version: 'v3' }); const { message, result } = await Downloader(url, { version: 'v3' });
if (message) {
throw new Error(message);
}
if (message) throw new Error(message); const videoUrl = result?.videoSD || result?.videoWatermark;
const videoUrl = result?.videoHD || result?.videoSD || result?.videoWatermark;
const imagesUrls = result?.images; const imagesUrls = result?.images;
if (!videoUrl && !imagesUrls?.length) { if (!videoUrl && !imagesUrls?.length) {
@ -36,8 +39,8 @@ feature.on('message:text', logHandle('download-message'), async (context) => {
if (result?.type === 'video' && videoUrl) { if (result?.type === 'video' && videoUrl) {
const { video } = await context.replyWithVideo(new InputFile({ url: videoUrl })); const { video } = await context.replyWithVideo(new InputFile({ url: videoUrl }));
await redis.set(url, video.file_id, 'EX', TTL); await redis.set(url, video.file_id, 'EX', TTL);
return;
} }
if (result?.type === 'image' && imagesUrls) { if (result?.type === 'image' && imagesUrls) {
@ -47,7 +50,6 @@ feature.on('message:text', logHandle('download-message'), async (context) => {
} }
} catch (error) { } catch (error) {
context.logger.error(error); context.logger.error(error);
return context.reply(context.t('generic')); return context.reply(context.t('generic'));
} }
}); });