Update app.py

app.py

@@ -5,7 +5,7 @@ import os
 import logging
 import threading
 import time
-import socket
+import asyncio
 from datetime import datetime
 from huggingface_hub import HfApi, hf_hub_download
 from huggingface_hub.utils import RepositoryNotFoundError, HfHubHTTPError
@@ -13,14 +13,9 @@ from werkzeug.utils import secure_filename
 from dotenv import load_dotenv
 import requests
 import uuid
-import asyncio
-from aiohttp import TCPConnector
-from aiogram import Bot, Dispatcher, types
-from aiogram.client.session.aiohttp import AiohttpSession
+from aiogram import Bot, Dispatcher, types, F
 from aiogram.filters import CommandStart
-from aiogram.types import InlineKeyboardMarkup, InlineKeyboardButton, WebAppInfo
-from aiogram.client.bot import DefaultBotProperties
-from aiogram.enums import ParseMode
+from aiogram.types import Message
 
 load_dotenv()
 
@@ -33,9 +28,7 @@ SYNC_FILES = [DATA_FILE]
 REPO_ID = "Kgshop/aiocult"
 HF_TOKEN_WRITE = os.getenv("HF_TOKEN")
 HF_TOKEN_READ = os.getenv("HF_TOKEN_READ")
-
-BOT_TOKEN = os.getenv("BOT_TOKEN", "8283649768:AAGYWatM-nUVQirgBiBwoAtWZgzfp3QnQjY")
-WEB_APP_URL = "https://shveiauto-wall.hf.space/"
+TELEGRAM_BOT_TOKEN = os.getenv("TELEGRAM_BOT_TOKEN")
 
 STORE_ADDRESS = " Алматы, «Байсат» 1 этаж, синий сектор 117-118 Бутик "
 
@@ -54,23 +47,54 @@ STATUS_MAP_RU = {
 
 logging.basicConfig(level=logging.INFO, format='%(asctime)s - %(levelname)s - %(message)s')
 
-connector = TCPConnector(family=socket.AF_INET, ssl=True)
-session = AiohttpSession(connector=connector)
-bot = Bot(token=BOT_TOKEN, session=session, default=DefaultBotProperties(parse_mode=ParseMode.HTML))
-dp = Dispatcher()
-bot_loop = asyncio.new_event_loop()
+data_lock = threading.Lock()
+
+bot = None
+dp = None
+
+if TELEGRAM_BOT_TOKEN:
+    bot = Bot(token=TELEGRAM_BOT_TOKEN)
+    dp = Dispatcher()
+
+    @dp.message(CommandStart())
+    async def command_start_handler(message: Message):
+        user_id = message.from_user.id
+        username = message.from_user.username
+        first_name = message.from_user.first_name
+        
+        with data_lock:
+            data = load_data_internal()
+            if 'telegram_users' not in data:
+                data['telegram_users'] = {}
+            
+            str_id = str(user_id)
+            if str_id not in data['telegram_users']:
+                data['telegram_users'][str_id] = {
+                    'username': username,
+                    'first_name': first_name,
+                    'joined_at': datetime.now().strftime('%Y-%m-%d %H:%M:%S')
+                }
+                save_data_internal(data)
+                logging.info(f"New Telegram user registered: {user_id}")
+        
+        await message.answer(f"Добро пожаловать в Мобильный мир, {first_name}! Здесь вы будете получать обновления о новинках.")
 
 def download_db_from_hf(specific_file=None, retries=DOWNLOAD_RETRIES, delay=DOWNLOAD_DELAY):
+    if not HF_TOKEN_READ and not HF_TOKEN_WRITE:
+        logging.warning("HF_TOKEN_READ/HF_TOKEN_WRITE not set. Download might fail for private repos.")
+
     token_to_use = HF_TOKEN_READ if HF_TOKEN_READ else HF_TOKEN_WRITE
 
     files_to_download = [specific_file] if specific_file else SYNC_FILES
+    logging.info(f"Attempting download for {files_to_download} from {REPO_ID}...")
     all_successful = True
 
     for file_name in files_to_download:
         success = False
         for attempt in range(retries + 1):
             try:
-                hf_hub_download(
+                logging.info(f"Downloading {file_name} (Attempt {attempt + 1}/{retries + 1})...")
+                local_path = hf_hub_download(
                     repo_id=REPO_ID,
                     filename=file_name,
                     repo_type="dataset",
@@ -80,38 +104,50 @@ def download_db_from_hf(specific_file=None, retries=DOWNLOAD_RETRIES, delay=DOWN
                     force_download=True,
                     resume_download=False
                 )
+                logging.info(f"Successfully downloaded {file_name} to {local_path}.")
                 success = True
                 break
             except RepositoryNotFoundError:
+                 logging.error(f"Repository {REPO_ID} not found. Download cancelled for all files.")
                  return False
             except HfHubHTTPError as e:
                 if e.response.status_code == 404:
+                    logging.warning(f"File {file_name} not found in repo {REPO_ID} (404). Skipping this file.")
                     if attempt == 0 and not os.path.exists(file_name):
                         try:
                             if file_name == DATA_FILE:
                                 with open(file_name, 'w', encoding='utf-8') as f:
-                                    json.dump({'products': [], 'categories': [], 'orders': {}, 'bot_users': []}, f)
-                        except Exception:
-                            pass
+                                    json.dump({'products': [], 'categories': [], 'orders': {}, 'telegram_users': {}}, f)
+                                logging.info(f"Created empty local file {file_name} because it was not found on HF.")
+                        except Exception as create_e:
+                            logging.error(f"Failed to create empty local file {file_name}: {create_e}")
                     success = False
                     break
-            except Exception:
-                pass
+                else:
+                    logging.error(f"HTTP error downloading {file_name} (Attempt {attempt + 1}): {e}. Retrying in {delay}s...")
+            except requests.exceptions.RequestException as e:
+                 logging.error(f"Network error downloading {file_name} (Attempt {attempt + 1}): {e}. Retrying in {delay}s...")
+            except Exception as e:
+                 logging.error(f"Unexpected error downloading {file_name} (Attempt {attempt + 1}): {e}. Retrying in {delay}s...", exc_info=True)
 
             if attempt < retries:
                 time.sleep(delay)
 
         if not success:
+            logging.error(f"Failed to download {file_name} after {retries + 1} attempts.")
             all_successful = False
 
+    logging.info(f"Download process finished. Overall success: {all_successful}")
     return all_successful
 
 def upload_db_to_hf(specific_file=None):
     if not HF_TOKEN_WRITE:
+        logging.warning("HF_TOKEN (for writing) not set. Skipping upload to Hugging Face.")
         return
     try:
         api = HfApi()
         files_to_upload = [specific_file] if specific_file else SYNC_FILES
+        logging.info(f"Starting upload of {files_to_upload} to HF repo {REPO_ID}...")
 
         for file_name in files_to_upload:
             if os.path.exists(file_name):
@@ -124,19 +160,26 @@ def upload_db_to_hf(specific_file=None):
                         token=HF_TOKEN_WRITE,
                         commit_message=f"Sync {file_name} {datetime.now().strftime('%Y-%m-%d %H:%M:%S')}"
                     )
-                except Exception:
-                     pass
-    except Exception:
-        pass
+                    logging.info(f"File {file_name} successfully uploaded to Hugging Face.")
+                except Exception as e:
+                     logging.error(f"Error uploading file {file_name} to Hugging Face: {e}")
+            else:
+                logging.warning(f"File {file_name} not found locally, skipping upload.")
+        logging.info("Finished uploading files to HF.")
+    except Exception as e:
+        logging.error(f"General error during Hugging Face upload initialization or process: {e}", exc_info=True)
 
 def periodic_backup():
     backup_interval = 1800
+    logging.info(f"Setting up periodic backup every {backup_interval} seconds.")
     while True:
         time.sleep(backup_interval)
+        logging.info("Starting periodic backup...")
         upload_db_to_hf()
+        logging.info("Periodic backup finished.")
 
-def load_data():
-    default_data = {'products': [], 'categories': [], 'orders': {}, 'bot_users': []}
+def load_data_internal():
+    default_data = {'products': [], 'categories': [], 'orders': {}, 'telegram_users': {}}
     try:
         with open(DATA_FILE, 'r', encoding='utf-8') as file:
             data = json.load(file)
@@ -145,102 +188,89 @@ def load_data():
         if 'products' not in data: data['products'] = []
         if 'categories' not in data: data['categories'] = []
         if 'orders' not in data: data['orders'] = {}
-        if 'bot_users' not in data: data['bot_users'] = []
+        if 'telegram_users' not in data: data['telegram_users'] = {}
         return data
     except (FileNotFoundError, json.JSONDecodeError):
-        pass
+        return default_data
 
-    if download_db_from_hf(specific_file=DATA_FILE):
+def load_data():
+    with data_lock:
+        default_data = {'products': [], 'categories': [], 'orders': {}, 'telegram_users': {}}
         try:
             with open(DATA_FILE, 'r', encoding='utf-8') as file:
                 data = json.load(file)
+            logging.info(f"Local data loaded successfully from {DATA_FILE}")
             if not isinstance(data, dict):
-                 return default_data
+                 logging.warning(f"Local {DATA_FILE} is not a dictionary. Attempting download.")
+                 raise FileNotFoundError
             if 'products' not in data: data['products'] = []
             if 'categories' not in data: data['categories'] = []
             if 'orders' not in data: data['orders'] = {}
-            if 'bot_users' not in data: data['bot_users'] = []
+            if 'telegram_users' not in data: data['telegram_users'] = {}
             return data
-        except Exception:
-            return default_data
-    else:
-        if not os.path.exists(DATA_FILE):
+        except FileNotFoundError:
+            logging.warning(f"Local file {DATA_FILE} not found. Attempting download from HF.")
+        except json.JSONDecodeError:
+            logging.error(f"Error decoding JSON in local {DATA_FILE}. File might be corrupt. Attempting download.")
+
+        if download_db_from_hf(specific_file=DATA_FILE):
             try:
-                with open(DATA_FILE, 'w', encoding='utf-8') as f:
-                    json.dump(default_data, f)
-            except Exception:
-                pass
-        return default_data
+                with open(DATA_FILE, 'r', encoding='utf-8') as file:
+                    data = json.load(file)
+                logging.info(f"Data loaded successfully from {DATA_FILE} after download.")
+                if not isinstance(data, dict):
+                     return default_data
+                if 'products' not in data: data['products'] = []
+                if 'categories' not in data: data['categories'] = []
+                if 'orders' not in data: data['orders'] = {}
+                if 'telegram_users' not in data: data['telegram_users'] = {}
+                return data
+            except Exception as e:
+                logging.error(f"Unknown error loading downloaded {DATA_FILE}: {e}. Using default.", exc_info=True)
+                return default_data
+        else:
+            logging.error(f"Failed to download {DATA_FILE} from HF after retries. Using empty default data structure.")
+            if not os.path.exists(DATA_FILE):
+                try:
+                    with open(DATA_FILE, 'w', encoding='utf-8') as f:
+                        json.dump(default_data, f)
+                    logging.info(f"Created empty local file {DATA_FILE} after failed download.")
+                except Exception as create_e:
+                    logging.error(f"Failed to create empty local file {DATA_FILE}: {create_e}")
+            return default_data
 
-def save_data(data):
+def save_data_internal(data):
     try:
-        if not isinstance(data, dict):
-            return
         if 'products' not in data: data['products'] = []
         if 'categories' not in data: data['categories'] = []
         if 'orders' not in data: data['orders'] = {}
-        if 'bot_users' not in data: data['bot_users'] = []
+        if 'telegram_users' not in data: data['telegram_users'] = {}
 
         with open(DATA_FILE, 'w', encoding='utf-8') as file:
             json.dump(data, file, ensure_ascii=False, indent=4)
         upload_db_to_hf(specific_file=DATA_FILE)
-    except Exception:
-        pass
-
-async def send_new_product_notification(product_name, price, photo_filename=None):
-    data = load_data()
-    users = data.get('bot_users', [])
-    if not users:
-        return
-
-    keyboard = InlineKeyboardMarkup(inline_keyboard=[
-        [InlineKeyboardButton(text="Посмотреть новинку", web_app=WebAppInfo(url=WEB_APP_URL))]
-    ])
-    message_text = f"✨ <b>Поступление нового товара!</b> ✨\n\nВ нашем каталоге появился <b>{product_name}</b> по цене {price} {CURRENCY_CODE}."
+    except Exception as e:
+        logging.error(f"Error saving data to {DATA_FILE}: {e}", exc_info=True)
 
-    for user_id in users:
-        try:
-            if photo_filename:
-                photo_url = f"https://huggingface.co/datasets/{REPO_ID}/resolve/main/photos/{photo_filename}"
-                await bot.send_photo(chat_id=user_id, photo=photo_url, caption=message_text, reply_markup=keyboard)
-            else:
-                await bot.send_message(user_id, message_text, reply_markup=keyboard)
-            await asyncio.sleep(0.1)
-        except Exception:
-            pass
-
-@dp.message(CommandStart())
-async def send_welcome(message: types.Message):
-    user_id = message.from_user.id
-    data = load_data()
-    if user_id not in data.get('bot_users', []):
-        data.setdefault('bot_users', []).append(user_id)
-        save_data(data)
+def save_data(data):
+    with data_lock:
+        save_data_internal(data)
 
-    keyboard = InlineKeyboardMarkup(inline_keyboard=[
-        [InlineKeyboardButton(text="Перейти в каталог", web_app=WebAppInfo(url=WEB_APP_URL))]
-    ])
-    await message.answer("Добро пожаловать в Мобильный мир! Нажмите кнопку ниже, чтобы открыть наш каталог.", reply_markup=keyboard)
+def start_bot_polling():
+    if bot and dp:
+        logging.info("Starting Aiogram bot polling...")
+        asyncio.run(dp.start_polling(bot))
 
-async def main_bot():
-    for i in range(20):
+async def broadcast_message(user_ids, text):
+    count = 0
+    for user_id in user_ids:
         try:
-            await bot.delete_webhook(drop_pending_updates=True)
-            logging.info("Webhook deleted successfully.")
-            break
+            await bot.send_message(chat_id=user_id, text=text)
+            count += 1
+            await asyncio.sleep(0.05) 
         except Exception as e:
-            logging.warning(f"Network not ready yet (Attempt {i+1}/20): {e}")
-            await asyncio.sleep(5)
-    
-    try:
-        await dp.start_polling(bot)
-    except Exception as e:
-        logging.error(f"Polling failed to start: {e}")
-
-def run_bot():
-    time.sleep(5) 
-    asyncio.set_event_loop(bot_loop)
-    bot_loop.run_until_complete(main_bot())
+            logging.error(f"Failed to send message to {user_id}: {e}")
+    return count
 
 CATALOG_TEMPLATE = '''
     <!DOCTYPE html>
@@ -252,10 +282,9 @@ CATALOG_TEMPLATE = '''
         <link rel="stylesheet" href="https://cdnjs.cloudflare.com/ajax/libs/font-awesome/6.5.1/css/all.min.css">
         <link href="https://fonts.googleapis.com/css2?family=Roboto:wght@300;400;500;700&display=swap" rel="stylesheet">
         <link rel="stylesheet" href="https://cdnjs.cloudflare.com/ajax/libs/Swiper/10.2.0/swiper-bundle.min.css">
-        <script src="https://telegram.org/js/telegram-web-app.js"></script>
         <style>
             :root {
-                --primary-color: #007AFF;
+                --primary-color: #007AFF; 
                 --primary-dark: #0056b3;
                 --surface-color: #FFFFFF;
                 --surface-dark: #21252B;
@@ -280,10 +309,6 @@ CATALOG_TEMPLATE = '''
             .theme-toggle { background: none; border: none; font-size: 1.3rem; cursor: pointer; color: var(--primary-color); padding: 5px; }
             .theme-toggle:hover { opacity: 0.8; }
             
-            #user-info { display: none; align-items: center; gap: 8px; font-size: 0.9rem; }
-            #user-info img { width: 35px; height: 35px; border-radius: 50%; }
-            #user-info span { font-weight: 500; }
-
             .store-address { padding: 12px 15px; text-align: center; background-color: var(--surface-color); border-radius: 8px; box-shadow: 0 1px 3px rgba(0,0,0,0.05); font-size: 0.9rem; color: #555; margin: 15px; }
             body.dark-mode .store-address { background-color: var(--surface-dark); color: var(--text-color-dark); box-shadow: 0 1px 3px rgba(255,255,255,0.1); }
 
@@ -311,7 +336,7 @@ CATALOG_TEMPLATE = '''
             .product h2 { font-size: 0.95rem; font-weight: 500; margin: 0 0 5px 0; text-align: center; white-space: nowrap; overflow: hidden; text-overflow: ellipsis; color: var(--text-color); }
             body.dark-mode .product h2 { color: var(--text-color-dark); }
             .product-price { font-size: 1.1rem; color: var(--primary-color); font-weight: 700; text-align: center; margin: 5px 0; }
-            .product-description { display: none; }
+            .product-description { display: none; } 
             .product-actions { padding: 0 10px 10px 10px; display: flex; flex-direction: column; gap: 6px; }
             
             .product-button { display: block; width: 100%; padding: 8px; border: none; border-radius: 8px; background-color: var(--primary-color); color: white; font-size: 0.85rem; font-weight: 500; cursor: pointer; transition: all 0.2s ease; text-align: center; text-decoration: none; }
@@ -369,10 +394,6 @@ CATALOG_TEMPLATE = '''
                  <div class="logo-title-container" style="display: flex; align-items: center; gap: 10px;">
                     <img src="https://huggingface.co/spaces/Kgshop/mobilnymir/resolve/main/IMG_20251019_120056_121.jpg" alt="Мобильный мир Logo">
                     <h1>Мобильный мир</h1>
-                </div>
-                 <div id="user-info">
-                    <img id="user-avatar" src="" alt="avatar">
-                    <span id="user-name"></span>
                 </div>
                 <button class="theme-toggle" onclick="toggleTheme()" aria-label="Переключить тему">
                     <i class="fas fa-moon"></i>
@@ -630,7 +651,7 @@ CATALOG_TEMPLATE = '''
                     return;
                  }
 
-                const cartItemId = `${product.name}-${color}-${model}`;
+                const cartItemId = `${product.name}-${color}-${model}`; 
                 const existingItemIndex = cart.findIndex(item => item.id === cartItemId);
 
                 if (existingItemIndex > -1) {
@@ -643,7 +664,7 @@ CATALOG_TEMPLATE = '''
                         photo: product.photos && product.photos.length > 0 ? product.photos[0] : null,
                         quantity: quantity,
                         color: color,
-                        model: model
+                        model: model 
                     });
                 }
 
@@ -690,7 +711,7 @@ CATALOG_TEMPLATE = '''
                         
                         let variantText = [];
                         if (item.color !== 'N/A') variantText.push(`Цвет: ${item.color}`);
-                        if (item.model !== 'N/A') variantText.push(`Модель: ${item.model}`);
+                        if (item.model !== 'N/A') variantText.push(`Модель: ${item.model}`); 
 
                         const variantDisplay = variantText.length > 0 ? ` (${variantText.join(', ')})` : '';
 
@@ -787,7 +808,7 @@ CATALOG_TEMPLATE = '''
                 if (existingNoResults) existingNoResults.remove();
                 
                 const allProductElements = document.querySelectorAll('.products-grid .product');
-                if (allProductElements.length === 0 && products.length > 0) return;
+                if (allProductElements.length === 0 && products.length > 0) return; 
 
                 document.querySelectorAll('.products-grid .product').forEach(productElement => {
                     const name = productElement.getAttribute('data-name');
@@ -865,40 +886,11 @@ CATALOG_TEMPLATE = '''
                     notification.addEventListener('transitionend', () => notification.remove());
                 }, duration);
              }
-             
-            function initTelegramWebApp() {
-                if (window.Telegram && window.Telegram.WebApp) {
-                    const tg = window.Telegram.WebApp;
-                    tg.ready();
-
-                    if (tg.initDataUnsafe && tg.initDataUnsafe.user) {
-                        const user = tg.initDataUnsafe.user;
-                        const userInfoDiv = document.getElementById('user-info');
-                        const userAvatarImg = document.getElementById('user-avatar');
-                        const userNameSpan = document.getElementById('user-name');
-
-                        if (userInfoDiv && userAvatarImg && userNameSpan) {
-                            if (user.photo_url) {
-                                userAvatarImg.src = user.photo_url;
-                            } else {
-                                userAvatarImg.style.display = 'none';
-                            }
-                            userNameSpan.textContent = user.first_name + (user.last_name ? ' ' + user.last_name : '');
-                            userInfoDiv.style.display = 'flex';
-                        }
-                    } else {
-                        console.log("Telegram Web App user data not found.");
-                    }
-                } else {
-                    console.log("Telegram Web App script not loaded or not in Telegram environment.");
-                }
-            }
 
             document.addEventListener('DOMContentLoaded', () => {
                 applyInitialTheme();
                 updateCartButton();
                 setupFilters();
-                initTelegramWebApp();
 
                 window.addEventListener('click', function(event) {
                     if (event.target.classList.contains('modal')) {
@@ -1102,7 +1094,7 @@ ADMIN_TEMPLATE = '''
         <link rel="stylesheet" href="https://cdnjs.cloudflare.com/ajax/libs/font-awesome/6.5.1/css/all.min.css">
         <style>
             :root {
-                --primary-color: #007AFF;
+                --primary-color: #007AFF; 
                 --primary-dark: #0056b3;
                 --surface-color: #FFFFFF;
                 --surface-dark: #21252B;
@@ -1176,10 +1168,10 @@ ADMIN_TEMPLATE = '''
             .status-indicator.out-of-stock { background-color: #fed7d7; color: #c53030; }
             .status-indicator.top-product { background-color: #fff3c4; color: #9c4221; margin-left: 5px;}
             
-            .status-indicator.new { background-color: #ffe0b2; color: #e65100; }
-            .status-indicator.accepted { background-color: #b3e5fc; color: #0277bd; }
-            .status-indicator.prepared { background-color: #c6f6d5; color: #2f855a; }
-            .status-indicator.shipped { background-color: #a7f3d0; color: #065f46; }
+            .status-indicator.new { background-color: #ffe0b2; color: #e65100; } 
+            .status-indicator.accepted { background-color: #b3e5fc; color: #0277bd; } 
+            .status-indicator.prepared { background-color: #c6f6d5; color: #2f855a; } 
+            .status-indicator.shipped { background-color: #a7f3d0; color: #065f46; } 
             
             details { background-color: var(--surface-color); border: 1px solid var(--border-color); border-radius: 8px; margin-bottom: 10px; }
             body.dark-mode details { background-color: var(--surface-dark); border-color: var(--border-color-dark); }
@@ -1231,6 +1223,24 @@ ADMIN_TEMPLATE = '''
                     {% endfor %}
                 {% endif %}
             {% endwith %}
+            
+            <div class="section">
+                <h2><i class="fab fa-telegram-plane"></i> Рассылка Telegram</h2>
+                <details>
+                    <summary>Отправить сообщение всем пользователям бота</summary>
+                    <div class="form-content" style="padding: 15px;">
+                        <form method="POST">
+                            <input type="hidden" name="action" value="send_telegram_broadcast">
+                            <label for="broadcast_message">Текст сообщения:</label>
+                            <textarea id="broadcast_message" name="message" rows="4" required></textarea>
+                            <p style="font-size: 0.85rem; color: #666; margin-top: 5px;">
+                                Сообщение будет отправлено {{ telegram_users_count }} пользователям.
+                            </p>
+                            <button type="submit" class="button"><i class="fas fa-paper-plane"></i> Отправить</button>
+                        </form>
+                    </div>
+                </details>
+            </div>
 
             <div class="section">
                 <h2><i class="fas fa-history"></i> История заказов</h2>
@@ -1562,7 +1572,7 @@ ADMIN_TEMPLATE = '''
                 if (container) {
                     const existingInputs = container.querySelectorAll('input[name="' + fieldName + '"]');
                     if (existingInputs.length === 1 && existingInputs[0].value.trim() === '') {
-                        existingInputs[0].value = '';
+                        existingInputs[0].value = ''; 
                     }
 
                     const newInputGroup = document.createElement('div');
@@ -1632,6 +1642,7 @@ def product_detail(index):
     try:
         product = products_sorted[index]
     except IndexError:
+        logging.warning(f"Attempted access to non-existent or out-of-stock product with index {index}")
         return "Товар не найден или отсутствует в наличии.", 404
     
     products_index = index
@@ -1649,6 +1660,7 @@ def create_order():
     order_data = request.get_json()
 
     if not order_data or 'cart' not in order_data or not order_data['cart']:
+        logging.warning("Create order request missing cart data or cart is empty.")
         return jsonify({"error": "Корзина пуста или не передана."}), 400
 
     cart_items = order_data['cart']
@@ -1657,6 +1669,7 @@ def create_order():
     processed_cart = []
     for item in cart_items:
         if not all(k in item for k in ('name', 'price', 'quantity')):
+            logging.error(f"Invalid cart item structure received: {item}")
             return jsonify({"error": "Неверный формат товара в корзине."}), 400
         try:
             price = float(item['price'])
@@ -1678,6 +1691,7 @@ def create_order():
                 "photo_url": photo_url
             })
         except (ValueError, TypeError) as e:
+            logging.error(f"Invalid price/quantity in cart item: {item}. Error: {e}")
             return jsonify({"error": "Неверная цена или количество в товаре."}), 400
 
     order_id = f"{datetime.now().strftime('%Y%m%d%H%M%S')}-{uuid.uuid4().hex[:6]}"
@@ -1699,9 +1713,11 @@ def create_order():
 
         data['orders'][order_id] = new_order
         save_data(data)
+        logging.info(f"Order {order_id} created successfully (anonymously).")
         return jsonify({"order_id": order_id}), 201
 
     except Exception as e:
+        logging.error(f"Failed to save order {order_id}: {e}", exc_info=True)
         return jsonify({"error": "Ошибка сервера при сохранении заказа."}), 500
 
 @app.route('/order/<order_id>')
@@ -1709,6 +1725,11 @@ def view_order(order_id):
     data = load_data()
     order = data.get('orders', {}).get(order_id)
 
+    if order:
+        logging.info(f"Displaying order {order_id}")
+    else:
+        logging.warning(f"Order {order_id} not found.")
+
     return render_template_string(ORDER_TEMPLATE,
                                   order=order,
                                   status_map_ru=STATUS_MAP_RU,
@@ -1721,6 +1742,7 @@ def admin():
     products = data.get('products', [])
     categories = data.get('categories', [])
     orders = data.get('orders', {})
+    telegram_users = data.get('telegram_users', {})
 
     needs_save = False
     for product in products:
@@ -1728,18 +1750,36 @@ def admin():
             product['id'] = str(uuid.uuid4())
             needs_save = True
     if needs_save:
+        logging.info("Assigning unique IDs to products that were missing them.")
         data['products'] = products
         save_data(data)
 
-
     if 'orders' not in data or not isinstance(data.get('orders'), dict):
             data['orders'] = {}
 
     if request.method == 'POST':
         action = request.form.get('action')
+        logging.info(f"Admin action received: {action}")
 
         try:
-            if action == 'update_order_status':
+            if action == 'send_telegram_broadcast':
+                message_text = request.form.get('message', '').strip()
+                if message_text:
+                    if telegram_users:
+                        user_ids = list(telegram_users.keys())
+                        
+                        loop = asyncio.new_event_loop()
+                        asyncio.set_event_loop(loop)
+                        sent_count = loop.run_until_complete(broadcast_message(user_ids, message_text))
+                        loop.close()
+
+                        flash(f"Сообщение отправлено {sent_count} из {len(user_ids)} пользователей.", 'success')
+                    else:
+                        flash("Нет зарегистрированных пользователей Telegram для рассылки.", 'warning')
+                else:
+                    flash("Текст сообщения не может быть пустым.", 'error')
+
+            elif action == 'update_order_status':
                 order_id = request.form.get('order_id')
                 new_status = request.form.get('new_status')
 
@@ -1748,9 +1788,12 @@ def admin():
                     valid_statuses = list(STATUS_MAP_RU.keys())
                     
                     if new_status in valid_statuses:
+                        old_status_key = order.get('status', 'new')
+                        
                         order['status'] = new_status
                         data['orders'][order_id] = order
                         save_data(data)
+                        logging.info(f"Order {order_id} status updated from {old_status_key} to {new_status}")
                         flash(f"Статус заказа №{order_id} успешно изменен на '{STATUS_MAP_RU.get(new_status)}'.", 'success')
                     else:
                         flash(f"Неверный статус: {new_status}", 'error')
@@ -1765,10 +1808,13 @@ def admin():
                     categories.append(category_name)
                     data['categories'] = categories
                     save_data(data)
+                    logging.info(f"Category '{category_name}' added.")
                     flash(f"Категория '{category_name}' успешно добавлена.", 'success')
                 elif not category_name:
+                     logging.warning("Attempted to add empty category.")
                      flash("Название категории не может быть пустым.", 'error')
                 else:
+                     logging.warning(f"Category '{category_name}' already exists.")
                      flash(f"Категория '{category_name}' уже существует.", 'error')
 
             elif action == 'delete_category':
@@ -1783,8 +1829,10 @@ def admin():
                     data['categories'] = categories
                     data['products'] = products
                     save_data(data)
+                    logging.info(f"Category '{category_to_delete}' deleted. Updated products: {updated_count}.")
                     flash(f"Категория '{category_to_delete}' удалена. {updated_count} товаров обновлено.", 'success')
                 else:
+                    logging.warning(f"Attempted to delete non-existent or empty category: {category_to_delete}")
                     flash(f"Не удалось удалить категорию '{category_to_delete}'.", 'error')
 
             elif action == 'add_product':
@@ -1794,7 +1842,7 @@ def admin():
                 category = request.form.get('category')
                 photos_files = request.files.getlist('photos')
                 colors = [c.strip() for c in request.form.getlist('colors') if c.strip()]
-                models = [m.strip() for m in request.form.getlist('models') if m.strip()]
+                models = [m.strip() for m in request.form.getlist('models') if m.strip()] 
                 in_stock = 'in_stock' in request.form
                 is_top = 'is_top' in request.form
 
@@ -1818,12 +1866,14 @@ def admin():
                     uploaded_count = 0
                     for photo in photos_files:
                         if uploaded_count >= photo_limit:
+                            logging.warning(f"Photo limit ({photo_limit}) reached, ignoring remaining photos.")
                             flash(f"Загружено только первые {photo_limit} фото.", "warning")
                             break
                         if photo and photo.filename:
                             try:
                                 ext = os.path.splitext(photo.filename)[1].lower()
                                 if ext not in ['.jpg', '.jpeg', '.png', '.gif', '.webp']:
+                                     logging.warning(f"Skipping non-image file upload: {photo.filename}")
                                      flash(f"Файл {photo.filename} не является изображением и был пропущен.", "warning")
                                      continue
 
@@ -1831,6 +1881,7 @@ def admin():
                                 photo_filename = f"{safe_name}_{datetime.now().strftime('%Y%m%d%H%M%S%f')}{ext}"
                                 temp_path = os.path.join(uploads_dir, photo_filename)
                                 photo.save(temp_path)
+                                logging.info(f"Uploading photo {photo_filename} to HF for product {name}...")
                                 api.upload_file(
                                     path_or_fileobj=temp_path,
                                     path_in_repo=f"photos/{photo_filename}",
@@ -1840,18 +1891,22 @@ def admin():
                                     commit_message=f"Add photo for product {name}"
                                 )
                                 photos_list.append(photo_filename)
+                                logging.info(f"Photo {photo_filename} uploaded successfully.")
                                 os.remove(temp_path)
                                 uploaded_count += 1
-                            except Exception:
+                            except Exception as e:
+                                logging.error(f"Error uploading photo {photo.filename} to HF: {e}", exc_info=True)
                                 flash(f"Ошибка при загрузке фото {photo.filename}.", 'error')
                                 if os.path.exists(temp_path):
                                     try: os.remove(temp_path)
                                     except OSError: pass
+                        elif photo and not photo.filename:
+                             logging.warning("Received an empty photo file object when adding product.")
                     try:
                          if os.path.exists(uploads_dir) and not os.listdir(uploads_dir):
                              os.rmdir(uploads_dir)
-                    except OSError:
-                        pass
+                    except OSError as e:
+                        logging.warning(f"Could not remove temporary upload directory {uploads_dir}: {e}")
                 elif not HF_TOKEN_WRITE and photos_files and any(f.filename for f in photos_files):
                     flash("HF_TOKEN (write) не настроен. Фотографии не были загружены.", "warning")
 
@@ -1860,19 +1915,14 @@ def admin():
                     'id': str(uuid.uuid4()),
                     'name': name, 'price': price, 'description': description,
                     'category': category if category in categories else 'Без категории',
-                    'photos': photos_list, 'colors': colors, 'models': models,
+                    'photos': photos_list, 'colors': colors, 'models': models, 
                     'in_stock': in_stock, 'is_top': is_top
                 }
                 products.append(new_product)
                 data['products'] = products
                 save_data(data)
+                logging.info(f"Product '{name}' added.")
                 flash(f"Товар '{name}' успешно добавлен.", 'success')
-                
-                first_photo_filename = photos_list[0] if photos_list else None
-                if bot_loop and bot_loop.is_running():
-                    coro = send_new_product_notification(name, price, first_photo_filename)
-                    asyncio.run_coroutine_threadsafe(coro, bot_loop)
-
 
             elif action == 'edit_product':
                 product_id = request.form.get('product_id')
@@ -1888,6 +1938,7 @@ def admin():
 
                 if product_index == -1:
                     flash(f"Ошибка редактирования: товар с ID '{product_id}' не найден.", 'error')
+                    logging.error(f"Invalid product ID '{product_id}' for editing.")
                     return redirect(url_for('admin'))
 
                 product_to_edit = products[product_index]
@@ -1899,7 +1950,7 @@ def admin():
                 category = request.form.get('category')
                 product_to_edit['category'] = category if category in categories else 'Без категории'
                 product_to_edit['colors'] = [c.strip() for c in request.form.getlist('colors') if c.strip()]
-                product_to_edit['models'] = [m.strip() for m in request.form.getlist('models') if m.strip()]
+                product_to_edit['models'] = [m.strip() for m in request.form.getlist('models') if m.strip()] 
                 product_to_edit['in_stock'] = 'in_stock' in request.form
                 product_to_edit['is_top'] = 'is_top' in request.form
 
@@ -1908,6 +1959,7 @@ def admin():
                     if price < 0: price = 0
                     product_to_edit['price'] = price
                 except ValueError:
+                     logging.warning(f"Invalid price format '{price_str}' during edit of product {original_name}. Price not changed.")
                      flash(f"Неверный формат цены для товара '{original_name}'. Цена не изменена.", 'warning')
 
                 photos_files = request.files.getlist('photos')
@@ -1918,14 +1970,17 @@ def admin():
                     new_photos_list = []
                     photo_limit = 10
                     uploaded_count = 0
+                    logging.info(f"Uploading new photos for product {product_to_edit['name']}...")
                     for photo in photos_files:
                         if uploaded_count >= photo_limit:
+                            logging.warning(f"Photo limit ({photo_limit}) reached, ignoring remaining photos.")
                             flash(f"Загружено только первые {photo_limit} фото.", "warning")
                             break
                         if photo and photo.filename:
                             try:
                                 ext = os.path.splitext(photo.filename)[1].lower()
                                 if ext not in ['.jpg', '.jpeg', '.png', '.gif', '.webp']:
+                                     logging.warning(f"Skipping non-image file upload during edit: {photo.filename}")
                                      flash(f"Файл {photo.filename} не является изображением и был пропущен.", "warning")
                                      continue
 
@@ -1933,13 +1988,16 @@ def admin():
                                 photo_filename = f"{safe_name}_{datetime.now().strftime('%Y%m%d%H%M%S%f')}{ext}"
                                 temp_path = os.path.join(uploads_dir, photo_filename)
                                 photo.save(temp_path)
+                                logging.info(f"Uploading new photo {photo_filename} to HF...")
                                 api.upload_file(path_or_fileobj=temp_path, path_in_repo=f"photos/{photo_filename}",
                                                 repo_id=REPO_ID, repo_type="dataset", token=HF_TOKEN_WRITE,
                                                 commit_message=f"Update photo for product {product_to_edit['name']}")
                                 new_photos_list.append(photo_filename)
+                                logging.info(f"New photo {photo_filename} uploaded successfully.")
                                 os.remove(temp_path)
                                 uploaded_count += 1
-                            except Exception:
+                            except Exception as e:
+                                logging.error(f"Error uploading new photo {photo.filename}: {e}", exc_info=True)
                                 flash(f"Ошибка при загрузке нового фото {photo.filename}.", 'error')
                                 if os.path.exists(temp_path):
                                      try: os.remove(temp_path)
@@ -1947,12 +2005,14 @@ def admin():
                     try:
                          if os.path.exists(uploads_dir) and not os.listdir(uploads_dir):
                              os.rmdir(uploads_dir)
-                    except OSError:
-                        pass
+                    except OSError as e:
+                        logging.warning(f"Could not remove temporary upload directory {uploads_dir}: {e}")
 
                     if new_photos_list:
+                        logging.info(f"New photo list for product {product_to_edit['name']} generated.")
                         old_photos = product_to_edit.get('photos', [])
                         if old_photos:
+                            logging.info(f"Attempting to delete old photos: {old_photos}")
                             try:
                                 api.delete_files(
                                     repo_id=REPO_ID,
@@ -1961,7 +2021,9 @@ def admin():
                                     token=HF_TOKEN_WRITE,
                                     commit_message=f"Delete old photos for product {product_to_edit['name']}"
                                 )
-                            except Exception:
+                                logging.info(f"Old photos for product {product_to_edit['name']} deleted from HF.")
+                            except Exception as e:
+                                logging.error(f"Error deleting old photos {old_photos} from HF: {e}", exc_info=True)
                                 flash("Не удалось удалить старые фотографии с сервера. Новые фото загружены.", "warning")
                         product_to_edit['photos'] = new_photos_list
                         flash("Фотографии товара успешно обновлены.", "success")
@@ -1973,6 +2035,7 @@ def admin():
                 products[product_index] = product_to_edit
                 data['products'] = products
                 save_data(data)
+                logging.info(f"Product '{original_name}' (ID {product_id}) updated to '{product_to_edit['name']}'.")
                 flash(f"Товар '{product_to_edit['name']}' успешно обновлен.", 'success')
 
             elif action == 'delete_product':
@@ -1993,6 +2056,7 @@ def admin():
 
                     photos_to_delete = product_to_delete.get('photos', [])
                     if photos_to_delete and HF_TOKEN_WRITE:
+                        logging.info(f"Attempting to delete photos for product '{product_name}' from HF: {photos_to_delete}")
                         try:
                             api = HfApi()
                             api.delete_files(
@@ -2002,23 +2066,30 @@ def admin():
                                 token=HF_TOKEN_WRITE,
                                 commit_message=f"Delete photos for deleted product {product_name}"
                             )
-                        except Exception:
+                            logging.info(f"Photos for product '{product_name}' deleted from HF.")
+                        except Exception as e:
+                             logging.error(f"Error deleting photos {photos_to_delete} for product '{product_name}' from HF: {e}", exc_info=True)
                              flash(f"Не удалось удалить фото для товара '{product_name}' с сервера. Товар удален локально.", "warning")
                     elif photos_to_delete and not HF_TOKEN_WRITE:
+                        logging.warning(f"HF_TOKEN (write) not set. Cannot delete photos {photos_to_delete} for deleted product '{product_name}'.")
                         flash(f"Товар '{product_name}' удален локально, но фото не удалены с сервера (токен не задан).", "warning")
 
                     data['products'] = products
                     save_data(data)
+                    logging.info(f"Product '{product_name}' (ID {product_id}) deleted.")
                     flash(f"Товар '{product_name}' удален.", 'success')
                 else:
                     flash(f"Ошибка удаления: неверный ID товара '{product_id}'.", 'error')
+                    logging.error(f"Invalid product ID '{product_id}' for deletion.")
 
             else:
+                 logging.warning(f"Received unknown admin action: {action}")
                  flash(f"Неизвестное действие: {action}", 'warning')
 
             return redirect(url_for('admin'))
 
-        except Exception:
+        except Exception as e:
+             logging.error(f"Error processing admin action '{action}': {e}", exc_info=True)
              flash(f"Произошла внутренняя ошибка при выполнении действия '{action}'. Подробности в логе сервера.", 'error')
              return redirect(url_for('admin'))
 
@@ -2027,6 +2098,7 @@ def admin():
     display_products = sorted(current_data.get('products', []), key=lambda p: p.get('name', '').lower())
     display_categories = sorted(current_data.get('categories', []))
     display_orders = list(current_data.get('orders', {}).values())
+    telegram_users_count = len(current_data.get('telegram_users', {}))
 
     return render_template_string(
         ADMIN_TEMPLATE,
@@ -2037,19 +2109,30 @@ def admin():
         repo_id=REPO_ID,
         store_address=STORE_ADDRESS,
         currency_code=CURRENCY_CODE,
-        currency_name=CURRENCY_NAME
+        currency_name=CURRENCY_NAME,
+        telegram_users_count=telegram_users_count
     )
 
 if __name__ == '__main__':
+    logging.info("Application starting up. Performing initial data load/download...")
     download_db_from_hf()
     load_data()
+    logging.info("Initial data load complete.")
 
     if HF_TOKEN_WRITE:
         backup_thread = threading.Thread(target=periodic_backup, daemon=True)
         backup_thread.start()
+        logging.info("Periodic backup thread started.")
+    else:
+        logging.warning("Periodic backup will NOT run (HF_TOKEN for writing not set).")
     
-    bot_thread = threading.Thread(target=run_bot, daemon=True)
-    bot_thread.start()
+    if TELEGRAM_BOT_TOKEN:
+        bot_thread = threading.Thread(target=start_bot_polling, daemon=True)
+        bot_thread.start()
+        logging.info("Telegram bot polling thread started.")
+    else:
+        logging.warning("TELEGRAM_BOT_TOKEN not set. Telegram bot features disabled.")
 
     port = int(os.environ.get('PORT', 7860))
+    logging.info(f"Starting Flask app on host 0.0.0.0 and port {port}")
     app.run(debug=False, host='0.0.0.0', port=port)