Update app.py

app.py

@@ -8,7 +8,16 @@ from typing import Dict, List, Optional
 
 from telegram import Update
 from telegram.ext import Application, CommandHandler, MessageHandler, ContextTypes, filters
-import google.generativeai as genai
+
+# Используем новый google.genai вместо deprecated google.generativeai
+try:
+    import google.genai as genai
+except ImportError:
+    try:
+        import google.generativeai as genai
+    except ImportError:
+        genai = None
+
 import firebase_admin
 from firebase_admin import credentials, firestore
 import aiohttp
@@ -30,21 +39,27 @@ ACTIVITY_CHECK_INTERVAL = 1800  # 30 минут
 
 # Firebase инициализация
 try:
-    firebase_admin.initialize_app(credentials.Certificate("firebase_admin.json"))
+    if not firebase_admin._apps:
+        firebase_admin.initialize_app(credentials.Certificate("firebase_admin.json"))
     db = firestore.client()
     logger.info("✅ Firebase подключен")
 except Exception as e:
-    logger.error(f"❌ Firebase ошибка: {e}")
+    logger.warning(f"⚠️ Firebase: {e}")
     db = None
 
 # Google Generative AI
-genai.configure(api_key=GOOGLE_API_KEYS[0])
+try:
+    if genai:
+        genai.configure(api_key=GOOGLE_API_KEYS[0])
+        logger.info("✅ Google AI настроен")
+except Exception as e:
+    logger.warning(f"⚠️ Google AI: {e}")
 
 # ============= СОСТОЯНИЕ БОТА =============
 class BotState:
     def __init__(self):
-        self.request_queue: Dict[int, deque] = {}  # chat_id -> очередь запросов
-        self.processing: Dict[int, bool] = {}  # chat_id -> обрабатывается ли
+        self.request_queue: Dict[int, deque] = {}
+        self.processing: Dict[int, bool] = {}
         self.last_activity = datetime.now()
         self.is_sleeping = False
         self.whitelist: set = set()
@@ -57,14 +72,17 @@ class BotState:
             try:
                 doc = db.collection("bot_config").document("whitelist").get()
                 if doc.exists:
-                    self.whitelist = set(doc.get("users", []))
+                    data = doc.to_dict()
+                    self.whitelist = set(data.get("users", []))
                 else:
                     self.whitelist = {ADMIN_ID}
                     self.save_whitelist()
                 logger.info(f"📋 Белый список: {len(self.whitelist)} пользователей")
             except Exception as e:
-                logger.error(f"Ошибка загрузки списка: {e}")
+                logger.warning(f"⚠️ Ошибка загрузки списка: {e}")
                 self.whitelist = {ADMIN_ID}
+        else:
+            self.whitelist = {ADMIN_ID}
     
     def save_whitelist(self):
         """Сохранить белый список в Firebase"""
@@ -75,7 +93,7 @@ class BotState:
                     "updated_at": datetime.now()
                 })
             except Exception as e:
-                logger.error(f"Ошибка сохранения: {e}")
+                logger.warning(f"⚠️ Ошибка сохранения: {e}")
     
     def is_whitelisted(self, user_id: int) -> bool:
         return user_id in self.whitelist or user_id == ADMIN_ID
@@ -95,6 +113,9 @@ bot_state = BotState()
 # ============= AI ГЕНЕРАТОР =============
 async def generate_text(prompt: str, user_id: int) -> str:
     """Генерировать текст через Google Generative AI"""
+    if not genai:
+        return "❌ Google AI не настроен"
+    
     try:
         model = genai.GenerativeModel("gemini-pro")
         response = model.generate_content(prompt)
@@ -102,12 +123,15 @@ async def generate_text(prompt: str, user_id: int) -> str:
         
         # Сохранить в Firebase
         if db:
-            db.collection("users").document(str(user_id)).collection("history").add({
-                "prompt": prompt,
-                "response": result,
-                "timestamp": datetime.now(),
-                "model": "gemini-pro"
-            })
+            try:
+                db.collection("users").document(str(user_id)).collection("history").add({
+                    "prompt": prompt,
+                    "response": result,
+                    "timestamp": datetime.now(),
+                    "model": "gemini-pro"
+                })
+            except Exception as e:
+                logger.warning(f"⚠️ Не удалось сохранить: {e}")
         
         return result
     except Exception as e:
@@ -130,7 +154,7 @@ async def send_via_cloudflare(method: str, chat_id: int, text: str, **kwargs):
                 if resp.status == 200:
                     return await resp.json()
     except Exception as e:
-        logger.error(f"Cloudflare ошибка: {e}")
+        logger.warning(f"⚠️ Cloudflare: {e}")
     
     return None
 
@@ -149,7 +173,7 @@ async def start(update: Update, context: ContextTypes.DEFAULT_TYPE):
 /w - Управлять списком (админ)
 /help - Справка
 
-П��осто напишите "ии [текст)" и я отвечу!"""
+Просто напишите "ии [текст] и я отвечу!"""
     
     await update.message.reply_text(text)
 
@@ -296,16 +320,6 @@ async def handle_message(update: Update, context: ContextTypes.DEFAULT_TYPE):
         
         bot_state.last_activity = datetime.now()
 
-async def activity_monitor(context: ContextTypes.DEFAULT_TYPE):
-    """Мониторить активность каждые 30 минут"""
-    logger.info("🔍 Проверка активности")
-    
-    if (datetime.now() - bot_state.last_activity).seconds > ACTIVITY_CHECK_INTERVAL:
-        bot_state.is_sleeping = True
-        logger.info("😴 Бот спит - нет активности")
-    else:
-        bot_state.is_sleeping = False
-
 async def error_handler(update: Update, context: ContextTypes.DEFAULT_TYPE):
     logger.error(f"Ошибка: {context.error}")
 
@@ -328,10 +342,6 @@ def main():
     # Обработчик ошибок
     app.add_error_handler(error_handler)
     
-    # Job очередь для мониторинга
-    job_queue = app.job_queue
-    job_queue.run_repeating(activity_monitor, interval=ACTIVITY_CHECK_INTERVAL, first=60)
-    
     logger.info("✅ Бот запущен. Ctrl+C для остановки.")
     app.run_polling()