Update app.py

app.py

@@ -105,7 +105,8 @@ class ContentAggregator:
         - "insights": массив из 5 инсайтов, которых нет в исходных данных
         """
         try:
-            response = await genai_client.models.generate_content(
+            # ИСПОЛЬЗУЕМ .aio ДЛЯ АСИНХРОННЫХ ВЫЗОВОВ
+            response = await genai_client.aio.models.generate_content(
                 model=GEMINI_MODEL_NAME,
                 contents=prompt
             )
@@ -226,10 +227,12 @@ async def ask_ai(update: Update, context: ContextTypes.DEFAULT_TYPE):
         return
     msg = await update.message.reply_text("🤔 Думаю...")
     try:
-        resp = await genai_client.models.generate_content(model=GEMINI_MODEL_NAME, contents=query)
+        # ИСПОЛЬЗУЕМ .aio
+        resp = await genai_client.aio.models.generate_content(model=GEMINI_MODEL_NAME, contents=query)
         await msg.edit_text(resp.text[:4000], parse_mode='Markdown')
     except Exception as e:
-        await msg.edit_text(f"❌ Ошибка: {e}")
+        await msg.edit_text("❌ Извините, сервера Google сейчас перегружены или произошла ошибка. Попробуйте позже.")
+        logging.error(f"Ошибка Gemini: {e}")
 
 async def create_content(update: Update, context: ContextTypes.DEFAULT_TYPE):
     user_id = update.effective_user.id
@@ -291,14 +294,23 @@ async def handle_text(update: Update, context: ContextTypes.DEFAULT_TYPE):
     user_id = update.effective_user.id
     if not bot_state.is_allowed(user_id):
         return
+        
+    # Вспомогательная функция с обработкой ошибок API
+    async def process_prompt(prompt_text):
+        try:
+            # ИСПОЛЬЗУЕМ .aio
+            resp = await genai_client.aio.models.generate_content(model=GEMINI_MODEL_NAME, contents=prompt_text)
+            await update.message.reply_text(resp.text[:4000], parse_mode='Markdown')
+        except Exception as e:
+            logging.error(f"Gemini API Error: {e}")
+            await update.message.reply_text("⚠️ Ошибка: Сервера Google сейчас перегружены. Пожалуйста, попробуйте чуть позже.")
+
     if text.lower().startswith(("ии ", "ai ")):
         prompt = text[3:].strip()
         if prompt:
-            resp = await genai_client.models.generate_content(model=GEMINI_MODEL_NAME, contents=prompt)
-            await update.message.reply_text(resp.text[:4000], parse_mode='Markdown')
+            await process_prompt(prompt)
     elif len(text) > 20 and not text.startswith("/"):
-        resp = await genai_client.models.generate_content(model=GEMINI_MODEL_NAME, contents=text)
-        await update.message.reply_text(resp.text[:4000], parse_mode='Markdown')
+        await process_prompt(text)
 
 async def premium_info(update: Update, context: ContextTypes.DEFAULT_TYPE):
     await update.message.reply_text(f"💎 Premium даёт видео, музыку, приоритет.\nПолучите: {BOOST_LINK}")
@@ -334,12 +346,11 @@ async def callback_handler(update: Update, context: ContextTypes.DEFAULT_TYPE):
     elif data == "gen_video":
         await query.edit_message_text("Premium команда: /video [описание]")
 
-# ============= MAIN =============
 # ============= MAIN =============
 def main():
     logging.basicConfig(level=logging.INFO)
     
-    # Убираем proxy/proxy_url отсюда, оставляем только настройки таймаутов
+    # Оставляем только настройки таймаутов, proxy_url убран
     request = HTTPXRequest(
         connect_timeout=30.0,
         read_timeout=40.0,
@@ -348,7 +359,7 @@ def main():
         connection_pool_size=20
     )
     
-    # Передаем CF_WORKER_URL через метод base_url() (не забудьте добавить /bot)
+    # CF_WORKER_URL передан в base_url
     application = (
         Application.builder()
         .token(TG_BOT_TOKEN)