Update app.py

app.py

@@ -1,10 +1,10 @@
+
 from flask import Flask, render_template_string, request, redirect, url_for, send_file, flash, jsonify
 import json
 import os
 import logging
 import threading
 import time
-import asyncio
 from datetime import datetime
 from huggingface_hub import HfApi, hf_hub_download
 from huggingface_hub.utils import RepositoryNotFoundError, HfHubHTTPError
@@ -12,9 +12,7 @@ from werkzeug.utils import secure_filename
 from dotenv import load_dotenv
 import requests
 import uuid
-from aiogram import Bot, Dispatcher, types, F
-from aiogram.filters import CommandStart
-from aiogram.types import Message
+import telebot
 
 load_dotenv()
 
@@ -49,9 +47,9 @@ logging.basicConfig(level=logging.INFO, format='%(asctime)s - %(levelname)s - %(
 data_lock = threading.Lock()
 
 bot = None
-dp = None
+if TELEGRAM_BOT_TOKEN:
+    bot = telebot.TeleBot(TELEGRAM_BOT_TOKEN, threaded=False)
 
-# Вспомогательные функции для работы с данными внутри потока бота
 def load_data_internal():
     default_data = {'products': [], 'categories': [], 'orders': {}, 'telegram_users': {}}
     try:
@@ -76,18 +74,12 @@ def save_data_internal(data):
 
         with open(DATA_FILE, 'w', encoding='utf-8') as file:
             json.dump(data, file, ensure_ascii=False, indent=4)
-        # Внутри обработчика бота мы не делаем загрузку на HF, чтобы не блокировать,
-        # сохраняем только локально. Синхронизация произойдет при периодическом бэкапе.
     except Exception as e:
         logging.error(f"Error saving data to {DATA_FILE}: {e}", exc_info=True)
 
-
-if TELEGRAM_BOT_TOKEN:
-    bot = Bot(token=TELEGRAM_BOT_TOKEN)
-    dp = Dispatcher()
-
-    @dp.message(CommandStart())
-    async def command_start_handler(message: Message):
+if bot:
+    @bot.message_handler(commands=['start'])
+    def send_welcome(message):
         user_id = message.from_user.id
         username = message.from_user.username
         first_name = message.from_user.first_name
@@ -98,7 +90,6 @@ if TELEGRAM_BOT_TOKEN:
                 data['telegram_users'] = {}
             
             str_id = str(user_id)
-            # Сохраняем или обновляем пользователя
             data['telegram_users'][str_id] = {
                 'username': username,
                 'first_name': first_name,
@@ -107,8 +98,7 @@ if TELEGRAM_BOT_TOKEN:
             save_data_internal(data)
             logging.info(f"New Telegram user registered: {user_id}")
         
-        # Отправляем сообщение о регистрации
-        await message.answer("Вы зарегистрированы. Теперь мы сможем присылать вам уведомления.")
+        bot.send_message(message.chat.id, "Вы зарегистрированы. Теперь мы сможем присылать вам уведомления.")
 
 def download_db_from_hf(specific_file=None, retries=DOWNLOAD_RETRIES, delay=DOWNLOAD_DELAY):
     if not HF_TOKEN_READ and not HF_TOKEN_WRITE:
@@ -270,34 +260,22 @@ def save_data(data):
             logging.error(f"Error saving data to {DATA_FILE}: {e}", exc_info=True)
 
 def start_bot_polling():
-    if bot and dp:
-        logging.info("Starting Aiogram bot polling...")
-        # Используем бесконечный цикл для перезапуска при ошибках сети
-        while True:
-            try:
-                # handle_signals=False критически важен при запуске в отдельном потоке
-                # asyncio.run создает и закрывает цикл событий автоматически
-                asyncio.run(dp.start_polling(bot, handle_signals=False))
-            except Exception as e:
-                logging.error(f"Bot polling crashed: {e}. Restarting in 10 seconds...")
-                time.sleep(10)
+    if bot:
+        logging.info("Starting Telebot polling...")
+        bot.infinity_polling()
 
-async def broadcast_message(user_ids, text):
-    # Создаем новый экземпляр бота для рассылки, чтобы избежать конфликта Event Loop
-    # с основным ботом, который работает в другом потоке.
-    if not TELEGRAM_BOT_TOKEN:
+def broadcast_message(user_ids, text):
+    if not bot:
         return 0
     
     count = 0
-    # Используем Bot как контекстный менеджер для корректного закрытия сессии
-    async with Bot(token=TELEGRAM_BOT_TOKEN) as temp_bot:
-        for user_id in user_ids:
-            try:
-                await temp_bot.send_message(chat_id=user_id, text=text)
-                count += 1
-                await asyncio.sleep(0.05) # Небольшая задержка, чтобы не спамить API
-            except Exception as e:
-                logging.error(f"Failed to send message to {user_id}: {e}")
+    for user_id in user_ids:
+        try:
+            bot.send_message(chat_id=user_id, text=text)
+            count += 1
+            time.sleep(0.05) 
+        except Exception as e:
+            logging.error(f"Failed to send message to {user_id}: {e}")
     return count
 
 CATALOG_TEMPLATE = '''
@@ -1795,13 +1773,7 @@ def admin():
                 if message_text:
                     if telegram_users:
                         user_ids = list(telegram_users.keys())
-                        
-                        # Запускаем рассылку в event loop текущего потока
-                        loop = asyncio.new_event_loop()
-                        asyncio.set_event_loop(loop)
-                        sent_count = loop.run_until_complete(broadcast_message(user_ids, message_text))
-                        loop.close()
-
+                        sent_count = broadcast_message(user_ids, message_text)
                         flash(f"Сообщение отправлено {sent_count} из {len(user_ids)} пользователей.", 'success')
                     else:
                         flash("Нет зарегистрированных пользователей Telegram для рассылки.", 'warning')