Add more debug logging and remove nest_asyncio

main.py

@@ -1,4 +1,4 @@
-# main.py (Revised for Hugging Face - Added Application.initialize())
+# main.py (Revised for Hugging Face - Fix Event Loop Issue)
 import os
 import re
 import logging
@@ -13,7 +13,8 @@ from telegram.ext import (
     MessageHandler,
     filters,
     ContextTypes,
-    CallbackQueryHandler
+    CallbackQueryHandler,
+    ApplicationBuilder # Import ApplicationBuilder
 )
 from telegram.constants import ParseMode # Import ParseMode explicitly
 
@@ -26,18 +27,17 @@ _apify_token_exists = bool(os.environ.get('APIFY_API_TOKEN'))
 if _apify_token_exists:
     from apify_client import ApifyClient
 else:
-    ApifyClient = None # Define it as None if not used, to avoid errors later
+    ApifyClient = None
 
-# Apply nest_asyncio early, can help prevent event loop conflicts
-import nest_asyncio
-nest_asyncio.apply()
+# NO nest_asyncio needed here usually when using native async framework integration
+# import nest_asyncio
+# nest_asyncio.apply()
 
 # --- Logging Setup ---
 logging.basicConfig(
     format='%(asctime)s - %(name)s - %(levelname)s - %(message)s',
-    level=logging.DEBUG # Keep DEBUG level for now
+    level=logging.DEBUG # Keep DEBUG
 )
-# Reduce noise from libraries
 logging.getLogger("httpx").setLevel(logging.WARNING)
 if ApifyClient: logging.getLogger("apify_client").setLevel(logging.WARNING)
 logging.getLogger("telegram.ext").setLevel(logging.DEBUG)
@@ -47,17 +47,14 @@ logging.getLogger('gunicorn.error').setLevel(logging.INFO)
 logger = logging.getLogger(__name__)
 logger.info("Logging configured (DEBUG level).")
 
-# --- Environment Variable Loading & Debugging ---
+# --- Environment Variable Loading ---
 logger.info("Attempting to load secrets from environment variables...")
-
+# (Keep the get_secret function and secret loading as before)
 def get_secret(secret_name):
-    """Reads secret and logs the attempt and result."""
     logger.debug(f"Attempting to read secret: {secret_name}")
     value = os.environ.get(secret_name)
-    if value:
-        logger.info(f"Secret '{secret_name}': Found (Value length: {len(value)})")
-    else:
-        logger.warning(f"Secret '{secret_name}': Not Found")
+    if value: logger.info(f"Secret '{secret_name}': Found (Value length: {len(value)})")
+    else: logger.warning(f"Secret '{secret_name}': Not Found")
     return value
 
 TELEGRAM_TOKEN = get_secret('TELEGRAM_TOKEN')
@@ -65,11 +62,11 @@ OPENROUTER_API_KEY = get_secret('OPENROUTER_API_KEY')
 URLTOTEXT_API_KEY = get_secret('URLTOTEXT_API_KEY')
 SUPADATA_API_KEY = get_secret('SUPADATA_API_KEY')
 APIFY_API_TOKEN = get_secret('APIFY_API_TOKEN')
-
 logger.info("Secret loading attempt finished.")
 
 # --- Bot Logic Functions ---
 # [PASTE ALL YOUR BOT LOGIC FUNCTIONS HERE - FROM is_youtube_url to generate_summary]
+# --- [ Ensure all functions from previous main.py are here ] ---
 # Helper Functions
 def is_youtube_url(url):
     """Checks if the URL is a valid YouTube video or shorts URL."""
@@ -526,6 +523,7 @@ Here is the text to summarise:"""
         return "Sorry, an unexpected error occurred while generating the summary."
 
 
+
 # --- Telegram Bot Handlers (Command, Message, CallbackQuery) ---
 
 async def start(update: Update, context: ContextTypes.DEFAULT_TYPE) -> None:
@@ -591,7 +589,13 @@ async def handle_summary_type_callback(update: Update, context: ContextTypes.DEF
     """Handles button presses for summary type selection."""
     query = update.callback_query
     if not query: return
-    await query.answer() # Acknowledge button press immediately
+    # --- Acknowledge callback query ---
+    try:
+        await query.answer() # Acknowledge button press immediately
+        logger.debug(f"Callback query {query.id} answered.")
+    except Exception as e:
+        logger.error(f"Failed to answer callback query {query.id}: {e}", exc_info=True)
+        # Proceed anyway, but logging the error is important
 
     summary_type = query.data
     user = update.effective_user or query.from_user # Get user info
@@ -640,9 +644,10 @@ async def handle_summary_type_callback(update: Update, context: ContextTypes.DEF
     try:
         # Edit the message to show processing status
         await query.edit_message_text(processing_message)
+        logger.debug(f"Edited message for query {query.id} to show processing status.")
     except Exception as e:
         # If editing fails (e.g., message too old), send a new status message
-        logger.warning(f"Could not edit original message: {e}, sending new status message.")
+        logger.warning(f"Could not edit original message for query {query.id}: {e}. Sending new status message.")
         try:
             message_to_delete_later = await context.bot.send_message(chat_id=user.id, text=processing_message)
         except Exception as send_err:
@@ -657,6 +662,7 @@ async def handle_summary_type_callback(update: Update, context: ContextTypes.DEF
 
     try:
         # Show "typing..." status in Telegram chat
+        logger.debug(f"Sending 'typing' action for chat {user.id}")
         await context.bot.send_chat_action(chat_id=user.id, action='typing')
 
         # --- Content Fetching Logic ---
@@ -664,6 +670,7 @@ async def handle_summary_type_callback(update: Update, context: ContextTypes.DEF
             video_id = extract_youtube_id(url)
             if video_id:
                 # Fetch YT transcript using the function with fallbacks
+                logger.info(f"Fetching YouTube transcript for video_id: {video_id}")
                 content = await get_youtube_transcript(
                     video_id,
                     url, # Pass full URL for Apify
@@ -672,6 +679,7 @@ async def handle_summary_type_callback(update: Update, context: ContextTypes.DEF
                 )
                 # Set feedback message only if content fetching failed
                 user_feedback_message = None if content else "Sorry, I couldn't get the transcript for that YouTube video using any available method (unavailable/private/no captions?)."
+                logger.info(f"YouTube transcript fetch completed. Content found: {bool(content)}")
             else:
                 user_feedback_message = "Sorry, I couldn't understand that YouTube URL format."
         else: # Website Logic (Requests/BS4 -> URLToText API)
@@ -712,6 +720,7 @@ async def handle_summary_type_callback(update: Update, context: ContextTypes.DEF
                  logger.warning(f"Summary generation failed or returned error: {summary}")
             else:
                  # Send the successful summary
+                 logger.info("Summary generated successfully. Sending response.")
                  await context.bot.send_message(
                      chat_id=user.id,
                      text=summary,
@@ -727,6 +736,7 @@ async def handle_summary_type_callback(update: Update, context: ContextTypes.DEF
 
         # --- Send Feedback if any step failed ---
         if user_feedback_message and not success:
+            logger.warning(f"Sending failure feedback to user: {user_feedback_message}")
             await context.bot.send_message(chat_id=user.id, text=user_feedback_message)
 
     except Exception as e:
@@ -741,12 +751,14 @@ async def handle_summary_type_callback(update: Update, context: ContextTypes.DEF
     finally:
         # --- Cleanup ---
         # Delete the "Processing..." status message or the original message with buttons
+        logger.debug("Cleaning up status message...")
         try:
              if message_to_delete_later: # If we sent a separate status message
                  await context.bot.delete_message(chat_id=user.id, message_id=message_to_delete_later.message_id)
+                 logger.debug("Deleted separate status message.")
              elif query: # Otherwise, delete the original message with the buttons
-                 # We might have already edited it, but deleting ensures cleanup
                  await query.delete_message()
+                 logger.debug(f"Deleted original message for query {query.id}.")
         except Exception as del_e:
              # Log if deletion fails, but don't let it stop anything
              logger.warning(f"Could not delete status/button message: {del_e}")
@@ -756,33 +768,8 @@ async def error_handler(update: object, context: ContextTypes.DEFAULT_TYPE) -> N
     """Log Errors caused by Updates."""
     # Log the error and traceback
     logger.error(f"Exception while handling an update: {context.error}", exc_info=context.error)
+    # (Keep optional developer notification code as before if desired)
 
-    # Optionally send a notification to developer chat ID (replace with your actual ID)
-    # developer_chat_id = 12345678
-    # try:
-    #     # Extract user/chat info if available
-    #     chat_info = "N/A"
-    #     user_info = "N/A"
-    #     update_details = "N/A"
-    #     if isinstance(update, Update) and update.effective_chat:
-    #         chat_info = f"Chat: {update.effective_chat.id} ({update.effective_chat.type})"
-    #     if isinstance(update, Update) and update.effective_user:
-    #          user_info = f"User: {update.effective_user.id} (@{update.effective_user.username})"
-    #     if update:
-    #         update_details = f"Update Type: {update.__class__.__name__}"
-
-    #     tb_list = traceback.format_exception(None, context.error, context.error.__traceback__)
-    #     tb_string = "".join(tb_list)
-    #     # Keep message reasonably short
-    #     error_message = (
-    #         f"🚨 Bot Error 🚨\n"
-    #         f"{chat_info}\n{user_info}\n{update_details}\n"
-    #         f"Error: {context.error}\n\n"
-    #         f"Traceback (last part):\n```\n{tb_string[-1000:]}\n```" # Limit traceback length
-    #     )
-    #     await context.bot.send_message(chat_id=developer_chat_id, text=error_message[:4096]) # Limit msg len
-    # except Exception as e:
-    #     logger.error(f"Failed to send error notification to developer: {e}")
 
 # --- Bot Application Setup Function ---
 async def setup_bot():
@@ -812,8 +799,6 @@ async def setup_bot():
 
 # --- Run Setup and Store Application Instance ---
 logger.info("Running bot setup...")
-# Run the async setup function and store the application instance globally
-# This runs once when the script/module is first loaded by Gunicorn worker
 ptb_app = asyncio.run(setup_bot())
 logger.info(f"Bot setup finished. Application instance: {'OK' if ptb_app else 'Failed'}")