Upload 4 files

Dockerfile

@@ -1,6 +1,6 @@
 FROM python:3.11-slim
 
-RUN apt-get update && apt-get install -y ffmpeg git && rm -rf /var/lib/apt/lists/*
+RUN apt-get update && apt-get install -y git && rm -rf /var/lib/apt/lists/*
 
 WORKDIR /app
 

ai_helper.py

@@ -3,11 +3,12 @@ import os
 import time
 
 def generate_answer(question, context_list):
-    api_key = os.getenv("GEMINI_API_KEY")
-    if not api_key:
+    # Get keys from environment; supports single key or comma-separated list
+    raw_keys = os.getenv("GEMINI_API_KEY")
+    if not raw_keys:
         return "❌ Gemini API key missing. Add GEMINI_API_KEY=your_key to .env"
 
-    genai.configure(api_key=api_key)
+    api_keys = [k.strip() for k in raw_keys.split(",") if k.strip()]
 
     # Truncate chunks and limit to 5 to avoid Token Per Minute (TPM) limits
     context = "\n\n".join([c[:2000] for c in context_list[:5]])
@@ -30,19 +31,21 @@ Instructions:
 Answer:
 """
 
-    # Using gemini-2.0-flash as gemini-1.5-flash returned 404
-    model = genai.GenerativeModel('gemini-2.0-flash')
-
-    # Simple retry logic for Rate Limits (RPM)
-    for attempt in range(3):
-        try:
-            response = model.generate_content(prompt)
-            return response.text
-        except Exception as e:
-            if "429" in str(e) and attempt < 2:
-                wait_time = (attempt + 1) * 5
-                time.sleep(wait_time)
-                continue
-            raise e
+    # Iterate through available API keys to bypass daily/minute quotas
+    for api_key in api_keys:
+        genai.configure(api_key=api_key)
+        model = genai.GenerativeModel('gemini-2.0-flash')
+
+        for attempt in range(2):  # Try twice per key
+            try:
+                response = model.generate_content(prompt)
+                return response.text
+            except Exception as e:
+                # If it's a 429 error, try the next key or wait briefly
+                if "429" in str(e):
+                    time.sleep(2)
+                    continue
+                logger.error(f"AI Error with key {api_key[:5]}...: {e}")
+                break # Try the next API key in the list
 
     return "❌ I'm currently receiving too many requests. Please try again in a minute."

bot.py

@@ -10,7 +10,6 @@ from pdf_loader import load_all_pdfs
 from search_engine import SmartSearch
 from ai_helper import generate_answer
 from translator import process_language, translate_back
-from voice import voice_to_text
 
 # Enable logging
 logging.basicConfig(
@@ -42,36 +41,10 @@ async def handle_text(update: Update, context: ContextTypes.DEFAULT_TYPE):
         await update.message.reply_text(final_answer)
     except Exception as e:
         if "429" in str(e):
-            await update.message.reply_text("🕒 The AI is currently busy (Rate limit reached). Please try again in 30 seconds.")
+            await update.message.reply_text("🕒 The system is currently busy (Rate limit reached). Please try again in 30 seconds.")
         logger.error(f"Error in handle_text: {e}")
         await update.message.reply_text("Sorry, I encountered an error processing your request.")
 
-# VOICE HANDLER
-async def handle_voice(update: Update, context: ContextTypes.DEFAULT_TYPE):
-    file = await update.message.voice.get_file()
-    logger.info(f"User {update.effective_user.id} sent voice")
-    file_path = f"voice_{update.effective_user.id}_{update.message.message_id}.ogg"
-    await file.download_to_drive(file_path)
-
-    try:
-        text = voice_to_text(file_path)
-
-        processed_text, lang = process_language(text)
-
-        results = search.query(processed_text)
-        answer = generate_answer(processed_text, results)
-
-        final_answer = translate_back(answer, lang)
-
-        await update.message.reply_text(final_answer)
-    except Exception as e:
-        if "429" in str(e):
-            await update.message.reply_text("🕒 The AI is currently busy. Please wait a moment.")
-        logger.error(f"Error in handle_voice: {e}")
-    finally:
-        if os.path.exists(file_path):
-            os.remove(file_path)
-
 # Added timeouts to help with slow connections or initial handshake delays
 # Increased timeouts and added max_retries for more robust startup in potentially unstable network conditions.
 app = (
@@ -83,6 +56,5 @@ app = (
 )
 app.add_handler(CommandHandler("start", start))
 app.add_handler(MessageHandler(filters.TEXT, handle_text))
-app.add_handler(MessageHandler(filters.VOICE, handle_voice))
 
 app.run_polling(poll_interval=5, timeout=60, bootstrap_retries=20) # Added explicit retries and increased timeout

requirements.txt

@@ -5,6 +5,5 @@ numpy
 PyPDF2
 langdetect
 deep-translator
-openai-whisper
 python-dotenv
 google-generativeai