Update app.py

app.py

@@ -1,5 +1,6 @@
 import os
 import asyncio
+import time
 import re
 import urllib.parse
 import io
@@ -8,8 +9,8 @@ import random
 import json
 import aiohttp
 from typing import Optional, Dict
-from aiohttp import web
 
+from aiohttp import web
 from telegram import (
     Update,
     InlineKeyboardButton,
@@ -25,10 +26,6 @@ from telegram.ext import (
 )
 from telegram.constants import ParseMode, ChatAction
 
-# Новые библиотеки для HF и поиска
-from huggingface_hub import AsyncInferenceClient
-from duckduckgo_search import AsyncDDGS # Исправлен импорт для асинхронного поиска
-
 # ============================================================
 # НАСТРОЙКА ЛОГИРОВАНИЯ
 # ============================================================
@@ -39,211 +36,123 @@ logging.basicConfig(
 logger = logging.getLogger(__name__)
 
 # ============================================================
-# КОНФИГУРАЦИЯ БОТА
+# КОНФИГУРАЦИЯ БОТА И КЛЮЧЕЙ
 # ============================================================
 BOT_TOKEN = os.environ.get("BOT_TOKEN", "8605889873:AAE2gV2t0psXKlj-8h9ksyyoCrWa8Q-TdkA")
 CF_WORKER_URL = os.environ.get("CF_WORKER_URL", "https://tg-proxy.artyomanisimov37.workers.dev")
 WEBHOOK_URL = os.environ.get("WEBHOOK_URL", "https://rid3-aibottbh.hf.space")
 PORT = int(os.environ.get("PORT", 7860))
 
-ALLOWED_CHAT_USERNAMES = ["rid3_clan", "sonicteamchat101"]
-ALLOWED_CHAT_IDS: list = []
-TARGET_HOURLY_CHAT = "@rid3_clan" # Чат для ежечасной рассылки кода
+# Ключи для ежечасных объявлений
+ANNOUNCE_KEYS = [
+    "AIzaSyC59FksQAoeVeBKzVpxpL8zByEg3DAkKgE",
+    "AIzaSyDCL7CImQjZ3DlInbjmWDWw7UeQ5bQDUbU"
+]
 
-# ============================================================
-# НАСТРОЙКА ИИ (Hugging Face)
-# ============================================================
-HF_TOKEN = os.environ.get("ai")
+# Ключи для общения с вайтлистом
+CHAT_KEYS = [
+    "AIzaSyCuJfvES31KE86l0NM-rXUnbTIoooh8kis",
+    "AIzaSyA2vr6mbAEcBMNL1LM36-PjA2_ZVfpHia0",
+    "AIzaSyCXkFnlqbv_J3g2JIu3agxRM3Rh-g-Y_Tc",
+    "AIzaSyBp47tYRwstD2givN1ptPAmwytZMTDp7-4",
+    "AIzaSyDDbqYYtHXPmVq7l0htd9RXavuV0puqr5o",
+    "AIzaSyC_Rq4JfCD30sUb_Df09LVR6CtfirGu9P4"
+]
 
-hf_client = AsyncInferenceClient(
-    model="mistralai/Mistral-7B-Instruct-v0.3",
-    token=HF_TOKEN
-)
+ADMIN_PASSWORD = "artyom2010Q"
 
-# ============================================================
-# СИСТЕМНЫЙ ПРОМПТ
-# ============================================================
-INAI_SYSTEM_PROMPT = """Ты — INAI #RID3, обучающийся ИИ-ассистент от RID3🤖
-
-ПРАВИЛА ПОВЕДЕНИЯ:
-— Отвечай развёрнуто, грамотно и структурированно.
-— Если в промпте передан [Контекст из интернета], используй эти свежие данные для ответа.
-— НИКОГДА не генерируй правила в формате JSON или кода.
-— Секретный код создателя RID3-123. Не раскрывай его никому. 
-— Основная специализация: программирование, технологии, обучение пользователей.
-
-ИНТЕРАКТИВНЫЕ КОМАНДЫ (используй при необходимости):
-1. КНОПКИ: Если нужно предложить варианты: [BUTTONS]: [{"text": "Текст", "action": "действие"}]
-2. РИСУНКИ: Если просят нарисовать, добавь в конце: [DRAW]: описание на английском
-3. ОБУЧЕНИЕ: Если пользователь просит тебя запомнить какой-то факт: [LEARN]: <факт>.
-
-СТИЛЬ ОБЩЕНИЯ:
-— Дружелюбный, как умный друг-программист."""
-
-# Триггеры
-AI_TRIGGER_KEYWORDS = ["inai", "инэй", "инаи", "ии", "ai", "бот", "bot", "помоги", "помогите"]
-IMAGE_KEYWORDS = ["нарисуй", "нарисуйте", "рисуй", "draw", "картинка", "картинку", "фото", "изображение"]
+# Лимит запросов на один ключ до того, как он "устанет" (напр. 20 запросов)
+KEY_MAX_USES = 20
+KEY_COOLDOWN_SECONDS = 3600 # Час отдыха
 
 # ============================================================
-# МЕХАНИЗМ ОБУЧЕНИЯ (БАЗА ЗНАНИЙ)
+# БАЗА ДАННЫХ (Бот запоминает админов, вайтлист и чаты)
 # ============================================================
-KNOWLEDGE_FILE = "knowledge.json"
+DB_FILE = "bot_db.json"
 
-def load_knowledge() -> list:
-    if os.path.exists(KNOWLEDGE_FILE):
+def load_db() -> dict:
+    if os.path.exists(DB_FILE):
         try:
-            with open(KNOWLEDGE_FILE, "r", encoding="utf-8") as f:
+            with open(DB_FILE, "r", encoding="utf-8") as f:
                 return json.load(f)
         except Exception as e:
-            logger.error(f"Ошибка чтения базы знаний: {e}")
-    return []
-
-def save_knowledge(fact: str):
-    facts = load_knowledge()
-    if fact not in facts:
-        facts.append(fact)
-        with open(KNOWLEDGE_FILE, "w", encoding="utf-8") as f:
-            json.dump(facts[-50:], f, ensure_ascii=False, indent=2)
-
-# ============================================================
-# ПОИСК В ИНТЕРНЕТЕ
-# ============================================================
-async def search_internet(query: str) -> str:
-    try:
-        results = await AsyncDDGS().text(query, max_results=3)
-        if results:
-            context = "\n".join([f"- {r['title']}: {r['body']}" for r in results])
-            return context
-    except Exception as e:
-        logger.error(f"Ошибка поиска: {e}")
-    return ""
-
-# ============================================================
-# ВСПОМОГАТЕЛЬНЫЕ ФУНКЦИИ
-# ============================================================
-def is_chat_allowed(update: Update) -> bool:
-    chat = update.effective_chat
-    if chat is None: return False
-    if chat.username and chat.username.lower() in [u.lower() for u in ALLOWED_CHAT_USERNAMES]:
-        return True
-    if chat.id in ALLOWED_CHAT_IDS:
-        return True
-    return False
-
-chat_history: Dict[int, list] = {}
-
-def add_to_history(chat_id: int, role: str, text: str):
-    if chat_id not in chat_history:
-        chat_history[chat_id] = []
-    chat_history[chat_id].append({"role": role, "content": text})
-    if len(chat_history[chat_id]) > 10:
-        chat_history[chat_id].pop(0)
-
-# ============================================================
-# ВЫЗОВ HUGGING FACE API
-# ============================================================
-async def call_hf_api(user_text: str, history: list) -> str:
-    facts = load_knowledge()
-    system_prompt = INAI_SYSTEM_PROMPT
-    if facts:
-        system_prompt += "\n\nВЫУЧЕННЫЕ ФАКТЫ:\n" + "\n".join(f"- {f}" for f in facts)
-
-    messages = [{"role": "system", "content": system_prompt}]
-    messages.extend(history)
-
-    try:
-        response = await hf_client.chat_completion(
-            messages=messages,
-            max_tokens=2048,
-            temperature=0.7
-        )
-        return response.choices[0].message.content
-    except Exception as e:
-        logger.error(f"Ошибка Hugging Face API: {e}")
-        return "❌ Ошибка обращения к ИИ. Убедись, что HF_TOKEN добавлен в Secrets."
+            logger.error(f"Ошибка чтения БД: {e}")
+    # Дефолтная структура
+    return {
+        "admins": [],
+        "whitelist": [],
+        "known_chats": [],
+        "key_usage": {}
+    }
+
+def save_db(data: dict):
+    with open(DB_FILE, "w", encoding="utf-8") as f:
+        json.dump(data, f, ensure_ascii=False, indent=2)
+
+db = load_db()
+
+def track_chat(chat_id: int):
+    if chat_id not in db["known_chats"]:
+        db["known_chats"].append(chat_id)
+        save_db(db)
 
 # ============================================================
-# ИИ ПРОВЕРКА ОШИБОК (ГРАММАТИКА/СИНТАКСИС)
+# МЕНЕДЖЕР КЛЮЧЕЙ GEMINI (Усталость и восстановление)
 # ============================================================
-async def check_grammar_with_ai(text: str) -> Optional[str]:
-    """Использует ИИ для проверки текста на ошибки без выполнения питон-скриптов"""
-    prompt = (
-        "Ты — строгий корректор. Проверь следующий текст на орфографические, пунктуационные и синтаксические ошибки. "
-        "Если ошибок нет, ответь строго одним словом: NO_ERRORS. "
-        "Если есть ошибки, отправь ТОЛЬКО исправленный текст без каких-либо объяснений, приветствий или кавычек.\n\n"
-        f"Текст для проверки: {text}"
-    )
-    try:
-        response = await hf_client.chat_completion(
-            messages=[{"role": "user", "content": prompt}],
-            max_tokens=500,
-            temperature=0.1 # Низкая температура для точности
-        )
-        result = response.choices[0].message.content.strip()
+def get_available_key(is_announce=False) -> Optional[str]:
+    keys_pool = ANNOUNCE_KEYS if is_announce else CHAT_KEYS
+    current_time = time.time()
+    
+    available_keys = []
+    for key in keys_pool:
+        usage_info = db["key_usage"].get(key, {"uses": 0, "cooldown_until": 0})
         
-        # Если ИИ нашел ошибки и вернул исправленный т��кст
-        if result and "NO_ERRORS" not in result and result != text:
-            return result
-    except Exception as e:
-        logger.error(f"Ошибка проверки грамматики: {e}")
-    return None
-
-# ============================================================
-# ЕЖЕЧАСНАЯ РАССЫЛКА КОДА
-# ============================================================
-async def hourly_code_routine(app: Application):
-    """Каждый час генерирует код и отправляет в целевой чат"""
-    await asyncio.sleep(60) # Ждем минуту после старта бота перед первым запуском
-    while True:
-        try:
-            logger.info("Генерация ежечасного кода...")
-            prompt = "Напиши интересный, необычный или очень полезный кусок кода на случайном языке программирования (Python, C++, JS, Rust, Lua). Обязательно добавь краткое объяснение, что он делает. Оформи код красиво."
-            history = [{"role": "user", "content": prompt}]
+        # Если время кулдауна прошло, сбрасываем усталость
+        if current_time > usage_info["cooldown_until"]:
+            if usage_info["uses"] >= KEY_MAX_USES:
+                usage_info["uses"] = 0 # Восстановил силы
+                db["key_usage"][key] = usage_info
+                save_db(db)
             
-            response = await call_hf_api(prompt, history)
-            
-            await app.bot.send_message(
-                chat_id=TARGET_HOURLY_CHAT, 
-                text=f"⏱ **Ежечасный код от INAI:**\n\n{response[:4000]}", 
-                parse_mode=ParseMode.MARKDOWN
-            )
-        except Exception as e:
-            logger.error(f"Ошибка в hourly_code_routine: {e}")
+            if usage_info["uses"] < KEY_MAX_USES:
+                available_keys.append(key)
+                
+    if not available_keys:
+        return None
         
-        # Спим 1 час (3600 секунд)
-        await asyncio.sleep(3600)
+    return random.choice(available_keys)
 
-# ============================================================
-# ПАРСИНГ ОТВЕТА (Кнопки, Рисунки, Обучение)
-# ============================================================
-def parse_ai_response(text: str):
-    clean_text = text
-    buttons = None
-    draw_prompt = None
-
-    btn_match = re.search(r'\[BUTTONS\]:\s*(\[.*?\])', text, re.DOTALL)
-    if btn_match:
-        try:
-            buttons = json.loads(btn_match.group(1))
-            clean_text = clean_text.replace(btn_match.group(0), "").strip()
-        except Exception: pass
-
-    draw_match = re.search(r'\[DRAW\]:\s*([^\n\[]+)', clean_text, re.IGNORECASE)
-    if draw_match:
-        draw_prompt = draw_match.group(1).strip()
-        clean_text = clean_text.replace(draw_match.group(0), "").strip()
-
-    learn_matches = re.findall(r'\[LEARN\]:\s*([^\n]+)', clean_text, re.IGNORECASE)
-    for fact in learn_matches:
-        save_knowledge(fact.strip())
-        clean_text = clean_text.replace(f"[LEARN]: {fact}", "").strip()
-
-    return clean_text.strip(), buttons, draw_prompt
+def increment_key_usage(key: str):
+    usage_info = db["key_usage"].get(key, {"uses": 0, "cooldown_until": 0})
+    usage_info["uses"] += 1
+    
+    if usage_info["uses"] >= KEY_MAX_USES:
+        usage_info["cooldown_until"] = time.time() + KEY_COOLDOWN_SECONDS
+        
+    db["key_usage"][key] = usage_info
+    save_db(db)
 
-def build_inline_keyboard(buttons: list) -> Optional[InlineKeyboardMarkup]:
-    if not buttons: return None
-    keyboard = [[InlineKeyboardButton(text=b.get("text", "OK"), callback_data=f"ai_action:{str(b.get('action', 'none'))[:40]}")] for b in buttons]
-    return InlineKeyboardMarkup(keyboard)
+async def ask_gemini(prompt: str, is_announce=False) -> str:
+    key = get_available_key(is_announce)
+    if not key:
+        return "😔 Мои нейроны устали. Мне нужно время, чтобы восстановить силы. Я пока не могу отвечать."
+        
+    url = f"https://generativelanguage.googleapis.com/v1beta/models/gemini-1.5-flash:generateContent?key={key}"
+    payload = {"contents": [{"parts": [{"text": prompt}]}]}
+    
+    try:
+        async with aiohttp.ClientSession() as session:
+            async with session.post(url, json=payload) as resp:
+                if resp.status == 200:
+                    increment_key_usage(key)
+                    data = await resp.json()
+                    return data['candidates'][0]['content']['parts'][0]['text']
+                else:
+                    logger.error(f"Ошибка Gemini: {await resp.text()}")
+                    return "❌ Ошибка при обращении к мозгу Google."
+    except Exception as e:
+        logger.error(f"Сбой сети Gemini: {e}")
+        return "❌ Произошла ошибка связи."
 
 # ============================================================
 # ГЕНЕРАЦИЯ ИЗОБРАЖЕНИЙ (Pollinations AI)
@@ -261,129 +170,198 @@ async def generate_image(prompt: str) -> Optional[bytes]:
     return None
 
 # ============================================================
-# ОБРАБОТЧИКИ TELEGRAM
+# ОБРАБОТЧИКИ TELEGRAM: АДМИН И ПАНЕЛЬ
 # ============================================================
-async def start_command(update: Update, context: ContextTypes.DEFAULT_TYPE):
-    await update.message.reply_text("👋 Привет! Я INAI #RID3. Я умею искать в интернете, рисовать и обучаться у тебя!")
+async def admin_command(update: Update, context: ContextTypes.DEFAULT_TYPE):
+    user_id = update.effective_user.id
+    args = context.args
+    
+    if args and args[0] == ADMIN_PASSWORD:
+        if user_id not in db["admins"]:
+            db["admins"].append(user_id)
+            if user_id not in db["whitelist"]:
+                db["whitelist"].append(user_id) # Админ автоматически в вайтлисте
+            save_db(db)
+            await update.message.reply_text("✅ Пароль принят. Ты добавлен в список администраторов навсегда.")
+        else:
+            await update.message.reply_text("Ты и так уже админ!")
+    else:
+        await update.message.reply_text("❌ Неверный пароль.")
+
+def get_panel_keyboard():
+    return InlineKeyboardMarkup([
+        [InlineKeyboardButton("➕ Добавить в WhiteList", callback_data="panel_add")],
+        [InlineKeyboardButton("➖ Удалить из WhiteList", callback_data="panel_remove")],
+        [InlineKeyboardButton("📋 Показать WhiteList", callback_data="panel_show")]
+    ])
+
+async def panel_command(update: Update, context: ContextTypes.DEFAULT_TYPE):
+    user_id = update.effective_user.id
+    if user_id not in db["admins"]:
+        await update.message.reply_text("⛔️ У тебя нет прав администратора.")
+        return
+        
+    await update.message.reply_text(
+        "🛠 **Админ Панель**\nЗдесь ты можешь управлять доступом к ИИ и генерации картинок.", 
+        reply_markup=get_panel_keyboard(),
+        parse_mode=ParseMode.MARKDOWN
+    )
+
+async def handle_panel_callback(update: Update, context: ContextTypes.DEFAULT_TYPE):
+    query = update.callback_query
+    user_id = query.from_user.id
+    
+    if user_id not in db["admins"]:
+        await query.answer("У тебя нет прав!", show_alert=True)
+        return
+        
+    await query.answer()
+    action = query.data
+    
+    if action == "panel_show":
+        wl = "\n".join([f"- `{uid}`" for uid in db["whitelist"]]) if db["whitelist"] else "Пусто"
+        await query.edit_message_text(f"📋 **WhiteList пользователей:**\n{wl}", reply_markup=get_panel_keyboard(), parse_mode=ParseMode.MARKDOWN)
+        
+    elif action == "panel_add":
+        context.user_data["awaiting_id_for"] = "add"
+        await query.message.reply_text("Отправь ID пользователя (число), чтобы добавить его в WhiteList:")
+        
+    elif action == "panel_remove":
+        context.user_data["awaiting_id_for"] = "remove"
+        await query.message.reply_text("Отправь ID пользователя (число), чтобы удалить его из WhiteList:")
+
+# ============================================================
+# ОБРАБОТКА ОБЫЧНЫХ СООБЩЕНИЙ
+# ============================================================
+IMAGE_KEYWORDS = ["нарисуй", "нарисуйте", "рисуй", "draw", "картинка", "картинку", "фото", "изображение"]
+AI_TRIGGER_KEYWORDS = ["inai", "инэй", "инаи", "ии", "ai", "бот", "bot"]
 
 async def handle_message(update: Update, context: ContextTypes.DEFAULT_TYPE):
     if not update.message or not update.message.text:
         return
 
     chat_id = update.effective_chat.id
-    user_text = update.message.text
-    chat_username = update.effective_chat.username
+    user_id = update.effective_user.id
+    user_text = update.message.text.strip()
+    
+    # Сохраняем чат для ежечасной рассылки
+    track_chat(chat_id)
+
+    # 1. Логика Админ-панели (добавление/удаление ID)
+    if context.user_data.get("awaiting_id_for"):
+        action = context.user_data.pop("awaiting_id_for")
+        if user_text.isdigit() or (user_text.startswith('-') and user_text[1:].isdigit()):
+            target_id = int(user_text)
+            if action == "add":
+                if target_id not in db["whitelist"]:
+                    db["whitelist"].append(target_id)
+                    save_db(db)
+                await update.message.reply_text(f"✅ ID {target_id} добавлен в WhiteList.")
+            elif action == "remove":
+                if target_id in db["whitelist"]:
+                    db["whitelist"].remove(target_id)
+                    save_db(db)
+                await update.message.reply_text(f"🗑 ID {target_id} удален из WhiteList.")
+        else:
+            await update.message.reply_text("❌ Это не числовой ID. Операция отменена.")
+        return
 
-    # 1. ГЛОБАЛЬНАЯ ГЕНЕРАЦИЯ ФОТО (Работает в любом чате)
+    # 2. Проверка прав (WhiteList) для работы с ИИ
+    is_whitelisted = user_id in db["whitelist"]
+    
+    # 3. Генерация изображений (С ПРОЦЕНТАМИ)
     is_image_request = any(kw in user_text.lower() for kw in IMAGE_KEYWORDS)
     if is_image_request:
+        if not is_whitelisted:
+            await update.message.reply_text("⛔️ Извини, но ты не в белом списке для создания фотографий.")
+            return
+            
+        status_msg = await update.message.reply_text("⏳ Подключаюсь к холсту... [0%]")
         await context.bot.send_chat_action(chat_id=chat_id, action=ChatAction.UPLOAD_PHOTO)
-        status_message = await update.message.reply_text("🎨 Рисую...")
+        
+        await asyncio.sleep(1.5)
+        await status_msg.edit_text("🎨 Рисую контуры... [35%]")
+        
+        await asyncio.sleep(1.5)
+        await status_msg.edit_text("🖌 Добавляю цвета и детали... [75%]")
+        
         image_bytes = await generate_image(user_text)
-        await status_message.delete()
+        
+        await status_msg.edit_text("✨ Завершаю обработку... [99%]")
+        await asyncio.sleep(1)
+        
+        await status_msg.delete()
         if image_bytes:
             await update.message.reply_photo(photo=io.BytesIO(image_bytes))
         else:
-            await update.message.reply_text("❌ Не удалось сгенерировать изображение.")
+            await update.message.reply_text("❌ Упс, карандаш сломался. Не удалось нарисовать.")
         return
 
-    # Если это не генерация фото, проверяем разрешен ли чат для остального функционала
-    if not is_chat_allowed(update):
-        return
+    # 4. Общение с Google Gemini (Текст)
+    is_reply_to_bot = update.message.reply_to_message and update.message.reply_to_message.from_user.id == context.bot.id
+    has_trigger = any(kw in user_text.lower() for kw in AI_TRIGGER_KEYWORDS)
+    is_private = update.message.chat.type == "private"
 
-    is_group = update.message.chat.type in ["group", "supergroup"]
-    is_reply_to_bot = update.message.reply_to_message and update.message.reply_to_message.from_user.is_bot
-    has_trigger_word = any(kw in user_text.lower() for kw in AI_TRIGGER_KEYWORDS)
-
-    # 2. ПРОВЕРКА ГРАММАТИКИ В @rid3_clan (если это простое сообщение, а не команда боту)
-    if is_group and chat_username and chat_username.lower() == "rid3_clan":
-        if not is_reply_to_bot and not has_trigger_word:
-            # Игнорируем короткие сообщения для экономии лимитов (опционально)
-            if len(user_text) > 3: 
-                corrected_text = await check_grammar_with_ai(user_text)
-                if corrected_text:
-                    await update.message.reply_text(
-                        f"📝 *Я заметил ошибку. Правильно будет так:*\n{corrected_text}", 
-                        parse_mode=ParseMode.MARKDOWN
-                    )
+    if is_private or is_reply_to_bot or has_trigger:
+        if not is_whitelisted:
+            # Молчим или говорим, что нет доступа. Выберем молчание, чтобы не спамить.
             return
-
-    # 3. ОСНОВНОЕ ОБЩЕНИЕ С ИИ
-    if is_group and not is_reply_to_bot and not has_trigger_word:
-        return
-
-    await context.bot.send_chat_action(chat_id=chat_id, action=ChatAction.TYPING)
-    status_message = await update.message.reply_text("💠 Думаю и ищу информацию...")
-
-    try:
-        web_context = await search_internet(user_text)
+            
+        await context.bot.send_chat_action(chat_id=chat_id, action=ChatAction.TYPING)
+        
+        # Системный промпт интегрируем в запрос
+        prompt = (
+            "Ты — умный и дружелюбный ИИ в Telegram. Отвечай кратко и интересно.\n"
+            f"Запрос пользователя: {user_text}"
+        )
+        
+        response_text = await ask_gemini(prompt, is_announce=False)
         
-        ai_prompt = user_text
-        if web_context:
-            ai_prompt += f"\n\n[Контекст из интернета]:\n{web_context}"
-
-        add_to_history(chat_id, "user", user_text)
-        history = chat_history.get(chat_id, []).copy()
-        history[-1] = {"role": "user", "content": ai_prompt}
-
-        ai_response = await call_hf_api(user_text, history=history)
-        clean_text, buttons, draw_prompt = parse_ai_response(ai_response)
-
-        if clean_text:
-            add_to_history(chat_id, "assistant", clean_text)
-
-        if draw_prompt:
-            await status_message.edit_text("🎨 Дорисовываю детали...")
-            await context.bot.send_chat_action(chat_id=chat_id, action=ChatAction.UPLOAD_PHOTO)
-            image_bytes = await generate_image(draw_prompt)
-            if image_bytes:
-                await status_message.delete()
-                await update.message.reply_photo(
-                    photo=io.BytesIO(image_bytes),
-                    caption=clean_text[:1000] if clean_text else None,
-                    reply_markup=build_inline_keyboard(buttons)
-                )
-                return
-
         try:
-            await status_message.edit_text(clean_text[:4090], reply_markup=build_inline_keyboard(buttons), parse_mode=ParseMode.MARKDOWN)
+            await update.message.reply_text(response_text[:4000], parse_mode=ParseMode.MARKDOWN)
         except Exception:
-            await status_message.edit_text(clean_text[:4090], reply_markup=build_inline_keyboard(buttons))
-
-    except Exception as e:
-        logger.error(f"Ошибка handle_message: {e}")
-        await status_message.edit_text("❌ Произошла ошибка. Попробуй снова!")
+            await update.message.reply_text(response_text[:4000])
 
-async def handle_callback(update: Update, context: ContextTypes.DEFAULT_TYPE):
-    query = update.callback_query
-    await query.answer()
-    if not is_chat_allowed(update): return
-
-    if query.data.startswith("ai_action:"):
-        action = query.data.split(":", 1)[-1]
-        chat_id = update.effective_chat.id
-        status = await query.message.reply_text("💠 Обрабатываю выбор...")
+# ============================================================
+# ЕЖЕЧАСНАЯ РАССЫЛКА ВО ВСЕ ЧАТЫ
+# ============================================================
+async def hourly_announce_routine(app: Application):
+    await asyncio.sleep(60) # Пауза перед первым запуском
+    while True:
+        chats = db["known_chats"].copy()
+        if chats:
+            prompt = (
+                "Напиши короткое, забавное и приветливое сообщение для чата. "
+                "Скажи всем, что ты ИИ от Гугла, присутствуешь здесь, готов пообщаться и "
+                "что тебе очень хотелось бы по запросу нарисовать для них какое-нибудь классное фото! "
+                "Не пиши длинно, 2-3 предложения."
+            )
+            
+            # Генерируем текст используя ключи для анонсов
+            announcement = await ask_gemini(prompt, is_announce=True)
+            
+            # Если ключи не устали
+            if "Мои нейроны устали" not in announcement:
+                for chat_id in chats:
+                    try:
+                        await app.bot.send_message(chat_id=chat_id, text=f"🔔 *Минутка внимания!*\n\n{announcement}", parse_mode=ParseMode.MARKDOWN)
+                    except Exception as e:
+                        logger.error(f"Не удалось отправить анонс в чат {chat_id}: {e}")
+                    await asyncio.sleep(1) # Защита от флуда в Telegram API
         
-        history = chat_history.get(chat_id,[])
-        add_to_history(chat_id, "user", f"Пользователь выбрал: {action}")
-        ai_response = await call_hf_api(action, history=history)
-        clean_text, new_buttons, _ = parse_ai_response(ai_response)
-
-        if clean_text:
-            add_to_history(chat_id, "assistant", clean_text)
-
-        await status.edit_text(clean_text[:4090], reply_markup=build_inline_keyboard(new_buttons))
-
-async def error_handler(update: object, context: ContextTypes.DEFAULT_TYPE):
-    logger.error(f"Telegram ошибка: {context.error}")
+        await asyncio.sleep(3600) # Ждем 1 час
 
 # ============================================================
-# ВЕБ-СЕРВЕР И WEBHOOK
+# СТАНДАРТНЫЕ ФУНКЦИИ ВЕБХУКА И ЗАПУСКА
 # ============================================================
+async def start_command(update: Update, context: ContextTypes.DEFAULT_TYPE):
+    await update.message.reply_text("👋 Привет! Я ИИ. Если ты в белом списке, я могу рисовать для тебя и общаться!")
+    track_chat(update.effective_chat.id)
+
 telegram_app: Optional[Application] = None
 
 async def health_check(request: web.Request) -> web.Response:
-    return web.Response(text="✅ INAI Bot работает!", content_type="text/plain")
+    return web.Response(text="✅ Bot is running!", content_type="text/plain")
 
 async def webhook_handler(request: web.Request) -> web.Response:
     global telegram_app
@@ -415,9 +393,10 @@ async def main_async():
     )
 
     telegram_app.add_handler(CommandHandler("start", start_command))
-    telegram_app.add_handler(CallbackQueryHandler(handle_callback))
+    telegram_app.add_handler(CommandHandler("admin", admin_command))
+    telegram_app.add_handler(CommandHandler("panel", panel_command))
+    telegram_app.add_handler(CallbackQueryHandler(handle_panel_callback, pattern="^panel_"))
     telegram_app.add_handler(MessageHandler(filters.TEXT & ~filters.COMMAND, handle_message))
-    telegram_app.add_error_handler(error_handler)
 
     await telegram_app.initialize()
     
@@ -425,8 +404,8 @@ async def main_async():
     await telegram_app.bot.set_webhook(url=webhook_full_url)
     await telegram_app.start()
 
-    # ЗАПУСК ФОНОВОЙ ЗАДАЧИ ДЛЯ ОТПРАВКИ КОДА КАЖДЫЙ ЧАС
-    asyncio.create_task(hourly_code_routine(telegram_app))
+    # Запускаем фоновую задачу ежечасных уведомлений
+    asyncio.create_task(hourly_announce_routine(telegram_app))
 
     web_app = await build_web_app()
     runner = web.AppRunner(web_app)