Remove transcription download from history command

Author: gistrec

handlers/max/history.py

@@ -3,17 +3,12 @@
 
 import aiomax
 
-from pathlib import Path
-
-from aiomax.buttons import CallbackButton, KeyboardBuilder
-
-from database.models import PLATFORM_MAX, STATUS_COMPLETED, is_owner
-from database.queries import get_recent_transcriptions, get_transcription
-from utils.s3 import download_text, object_name_from_url
+from database.models import PLATFORM_MAX
+from database.queries import get_recent_transcriptions
 from utils.utils import format_duration, MoscowTimezone
 from utils.tg import STATUS_EMOJI, fmt_price
 from utils.sentry import sentry_bind_user_max, sentry_transaction
-from messengers.max import safe_callback_answer, safe_send_document, safe_send_message
+from messengers.max import safe_send_message
 
 
 @sentry_bind_user_max
@@ -36,7 +31,6 @@ async def handle_max_history(message: aiomax.Message, bot: aiomax.Bot) -> None:
         return
 
     lines: list[str] = []
-    doc_buttons: list[CallbackButton] = []
     for r in items:
         status = r.status if isinstance(r.status, str) else ""
         emoji = STATUS_EMOJI[status] if status in STATUS_EMOJI else "•"
@@ -47,51 +41,11 @@ async def handle_max_history(message: aiomax.Message, bot: aiomax.Bot) -> None:
         dur = format_duration(r.duration_seconds)
         price_for_user = fmt_price(r.price_for_user)
         lines.append(f"{emoji} {dt_str} МСК • {dur} • {price_for_user}")
-        if status == STATUS_COMPLETED and r.result_s3_path:
-            doc_buttons.append(CallbackButton(f"📄 {dt_str} • {dur}", f"history_doc:{r.id}"))
 
     msg = (
         "Последние 10 распознаваний:\n"
         + "\n".join(lines)
         + "\n\nСтатусы: 🕓 ожидание • ⏳ в работе • ✅ готово • ❌ ошибка • 🚫 отменено"
     )
 
-    keyboard = None
-    if doc_buttons:
-        msg += "\n\nГотовые тексты можно получить ещё раз:"
-        keyboard = KeyboardBuilder()
-        for btn in doc_buttons:
-            keyboard = keyboard.row(btn)
-
-    await safe_send_message(bot, msg, chat_id=message.recipient.chat_id, keyboard=keyboard)
-
-
-@sentry_bind_user_max
-@sentry_transaction(name="history.document", op="max.callback")
-async def handle_max_history_doc(callback: aiomax.Callback, bot: aiomax.Bot) -> None:
-    """Re-send a finished transcription document from S3."""
-    await safe_callback_answer(callback, notification="")
-
-    try:
-        transcription_id = int(callback.payload.split(":", 1)[1])
-        user_id = int(callback.user.user_id)
-    except (IndexError, ValueError, TypeError, AttributeError):
-        return
-
-    transcription = get_transcription(transcription_id)
-    if not is_owner(transcription, user_id, PLATFORM_MAX):
-        return
-    if not transcription.result_s3_path:
-        return
-
-    object_name = object_name_from_url(transcription.result_s3_path)
-    text = await download_text(object_name)
-    if not text:
-        await safe_send_message(bot,
-            "❌ Не удалось получить текст\n\n"
-            "Попробуйте ещё раз чуть позже",
-            chat_id=callback.message.recipient.chat_id,
-        )
-        return
-
-    await safe_send_document(bot, user_id, text.encode("utf-8"), Path(object_name).name, "")
+    await safe_send_message(bot, msg, chat_id=message.recipient.chat_id)

handlers/telegram/history.py

@@ -1,16 +1,13 @@
-from pathlib import Path
-
-from telegram import InlineKeyboardButton, InlineKeyboardMarkup, InputFile, Update
+from telegram import Update
 from telegram.ext import ContextTypes
 
-from database.models import PLATFORM_TELEGRAM, STATUS_COMPLETED, is_owner
-from database.queries import get_recent_transcriptions, get_transcription
+from database.models import PLATFORM_TELEGRAM
+from database.queries import get_recent_transcriptions
 
-from utils.s3 import download_text, object_name_from_url
 from utils.sentry import sentry_bind_user, sentry_transaction
 from utils.utils import format_duration, MoscowTimezone
 from utils.tg import STATUS_EMOJI, fmt_price
-from messengers.telegram import safe_query_answer, safe_reply_text, safe_send_document
+from messengers.telegram import safe_reply_text
 
 
 @sentry_bind_user
@@ -27,9 +24,7 @@ async def handle_history(update: Update, context: ContextTypes.DEFAULT_TYPE) ->
         )
         return
 
-
     lines: list[str] = []
-    buttons: list[list[InlineKeyboardButton]] = []
     for r in items:
         status = r.status if isinstance(r.status, str) else ""
         emoji = STATUS_EMOJI[status] if status in STATUS_EMOJI else "•"
@@ -40,53 +35,11 @@ async def handle_history(update: Update, context: ContextTypes.DEFAULT_TYPE) ->
         dur = format_duration(r.duration_seconds)
         price_for_user = fmt_price(r.price_for_user)
         lines.append(f"{emoji} {dt_str} МСК • {dur} • {price_for_user}")
-        if status == STATUS_COMPLETED and r.result_s3_path:
-            buttons.append([InlineKeyboardButton(
-                f"📄 {dt_str} • {dur}", callback_data=f"history_doc:{r.id}"
-            )])
 
     msg = (
         "Последние 10 распознаваний:\n"
         + "\n".join(lines)
         + "\n\nСтатусы: 🕓 ожидание • ⏳ в работе • ✅ готово • ❌ ошибка • 🚫 отменено"
     )
-    if buttons:
-        msg += "\n\nГотовые тексты можно получить ещё раз:"
-
-    await safe_reply_text(
-        update.message, msg,
-        reply_markup=InlineKeyboardMarkup(buttons) if buttons else None,
-    )
 
-
-@sentry_bind_user
-@sentry_transaction(name="history.document", op="telegram.callback")
-async def handle_history_doc(update: Update, context: ContextTypes.DEFAULT_TYPE) -> None:
-    """Re-send a finished transcription document from S3."""
-    query = update.callback_query
-    await safe_query_answer(query)
-
-    transcription_id = int(query.data.split(":", 1)[1])
-    transcription = get_transcription(transcription_id)
-    if not is_owner(transcription, query.from_user.id, PLATFORM_TELEGRAM):
-        return
-    if not transcription.result_s3_path:
-        return
-
-    object_name = object_name_from_url(transcription.result_s3_path)
-    text = await download_text(object_name)
-    if not text:
-        await safe_reply_text(
-            query.message,
-            "❌ Не удалось получить текст\n\n"
-            "Попробуйте ещё раз чуть позже"
-        )
-        return
-
-    await safe_send_document(
-        context.bot,
-        query.message.chat_id,
-        query.message.message_id,
-        InputFile(text.encode("utf-8"), filename=Path(object_name).name),
-        "",
-    )
+    await safe_reply_text(update.message, msg)

main.py

@@ -29,7 +29,7 @@
 from handlers.telegram.cancel_task import handle_cancel_task
 from handlers.telegram.create_task import handle_create_task
 from handlers.telegram.file import handle_file
-from handlers.telegram.history import handle_history, handle_history_doc
+from handlers.telegram.history import handle_history
 from handlers.telegram.price import handle_price
 from handlers.telegram.text import handle_text, handle_unsupported
 from handlers.telegram.topup import handle_topup, handle_topup_callback, handle_cancel_payment
@@ -43,7 +43,7 @@
 from handlers.max.cancel_task import handle_max_cancel_task
 from handlers.max.create_task import handle_max_create_task
 from handlers.max.file import handle_max_file
-from handlers.max.history import handle_max_history, handle_max_history_doc
+from handlers.max.history import handle_max_history
 from handlers.max.price import handle_max_price
 from handlers.max.rate_transcription import handle_max_rate
 from handlers.max.summarize import handle_max_summarize
@@ -158,9 +158,6 @@ async def run_bots() -> None:
     application.add_handler(
         CallbackQueryHandler(handle_timecodes_format, pattern=r"^tc_fmt:\d+:(txt|srt|vtt)$")
     )
-    application.add_handler(
-        CallbackQueryHandler(handle_history_doc, pattern=r"^history_doc:\d+$")
-    )
 
     # --- Build Max bot (optional) ---
     max_bot = None
@@ -263,8 +260,6 @@ async def _on_max_callback(callback: aiomax.Callback) -> None:
                 await handle_max_send_as_text(callback, max_bot)
             elif payload.startswith("improve:"):
                 await handle_max_improve(callback, max_bot)
-            elif payload.startswith("history_doc:"):
-                await handle_max_history_doc(callback, max_bot)
             elif payload.startswith("tc_fmt:"):
                 await handle_max_timecodes_format(callback, max_bot)
             elif payload.startswith("tc_back:"):