Update app.py

app.py

@@ -1,1267 +1,391 @@
-from flask import Flask, render_template_string, request, redirect, url_for, jsonify, flash
+import asyncio
 import json
-import os
 import logging
+import os
 import threading
-import time
-from datetime import datetime
-from huggingface_hub import HfApi, hf_hub_download
-from huggingface_hub.utils import RepositoryNotFoundError, HfHubHTTPError
-from werkzeug.utils import secure_filename
-from dotenv import load_dotenv
-import uuid
-import hmac
-import hashlib
-import urllib.parse
-
-load_dotenv()
+from pathlib import Path
 
-app = Flask(__name__)
-app.secret_key = os.getenv("FLASK_SECRET_KEY", 'tontalent_secret_key_for_flash_messages_only')
-DATA_FILE = 'tontalent_data.json'
-SYNC_FILES = [DATA_FILE]
+from aiogram import Bot, Dispatcher, types
+from aiogram.filters import CommandStart
+from aiogram.enums import ParseMode
+from aiogram.types import FSInputFile
+from aiogram.utils.markdown import html_escape
+from aiogram.exceptions import TelegramAPIError
 
-REPO_ID = os.getenv("HF_REPO_ID", "Kgshop/tontalent2")
-HF_TOKEN_WRITE = os.getenv("HF_TOKEN_WRITE")
-HF_TOKEN_READ = os.getenv("HF_TOKEN_READ")
+from flask import Flask, request, render_template_string, redirect, url_for
+from werkzeug.utils import secure_filename
 
-TELEGRAM_BOT_TOKEN = "7549355625:AAGhdbf6x1JEzpH0mUtuxTF83Soi7MFVNZ8"
+# --- Configuration ---
+BOT_TOKEN = "7835463659:AAGNePbelZIAOeaglyQi1qulOqnjs4BGQn4"
+FLASK_HOST = "0.0.0.0"
+FLASK_PORT = 7860
 
-DOWNLOAD_RETRIES = 3
-DOWNLOAD_DELAY = 5
+BASE_DIR = Path(__file__).resolve().parent
+SUBSCRIBED_USERS_FILE = BASE_DIR / "subscribed_users.json"
+UPLOAD_FOLDER = BASE_DIR / "uploads"
 
+# --- Logging ---
 logging.basicConfig(level=logging.INFO, format='%(asctime)s - %(levelname)s - %(message)s')
+logger = logging.getLogger(__name__)
+
+# --- Global Variables for Bot and Queue ---
+# These will be initialized in main_async
+bot_instance: Bot = None
+dp: Dispatcher = None
+message_queue: asyncio.Queue = None
+subscribed_users: set = set()
+bot_loop: asyncio.AbstractEventLoop = None # To run coroutines from Flask thread
+
+# --- User Persistence ---
+def load_subscribed_users():
+    global subscribed_users
+    if SUBSCRIBED_USERS_FILE.exists():
+        try:
+            with open(SUBSCRIBED_USERS_FILE, 'r') as f:
+                user_ids = json.load(f)
+                subscribed_users = set(user_ids)
+                logger.info(f"Loaded {len(subscribed_users)} subscribed users.")
+        except json.JSONDecodeError:
+            logger.error(f"Error decoding JSON from {SUBSCRIBED_USERS_FILE}. Starting with empty list.")
+            subscribed_users = set()
+        except Exception as e:
+            logger.error(f"Error loading subscribed users: {e}")
+            subscribed_users = set()
+    else:
+        logger.info("Subscribed users file not found. Starting with empty list.")
+        subscribed_users = set()
 
-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:
-                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",
-                    token=token_to_use, local_dir=".", local_dir_use_symlinks=False,
-                    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({'resumes': [], 'vacancies': [], 'freelance_offers': [], '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 = True
-                    break
-                else:
-                    logging.error(f"HTTP 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_WRITE not set. Skipping upload to Hugging Face.")
-        return
+def save_subscribed_users():
     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):
-                try:
-                    api.upload_file(
-                        path_or_fileobj=file_name, path_in_repo=file_name, repo_id=REPO_ID,
-                        repo_type="dataset", token=HF_TOKEN_WRITE,
-                        commit_message=f"Sync {file_name} {datetime.now().strftime('%Y-%m-%d %H:%M:%S')}"
-                    )
-                    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.")
+        with open(SUBSCRIBED_USERS_FILE, 'w') as f:
+            json.dump(list(subscribed_users), f)
+        logger.info(f"Saved {len(subscribed_users)} subscribed users.")
     except Exception as e:
-        logging.error(f"General error during Hugging Face upload initialization or process: {e}", exc_info=True)
+        logger.error(f"Error saving subscribed users: {e}")
 
-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 = {'resumes': [], 'vacancies': [], 'freelance_offers': [], 'users': {}}
+# --- Aiogram Bot Logic ---
+async def send_notification_to_user(user_id: int, text: str, file_path: str = None, file_type: str = None):
+    """Sends a notification to a single user, handling potential errors."""
+    global bot_instance
     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):
-             logging.warning(f"Local {DATA_FILE} is not a dictionary. Attempting download.")
-             raise FileNotFoundError
-        for key in default_data:
-            if key not in data: data[key] = default_data[key]
-        return data
-    except (FileNotFoundError, json.JSONDecodeError) as e:
-        logging.warning(f"Error loading local data ({e}). Attempting download from HF.")
+        input_file = FSInputFile(file_path) if file_path else None
+        
+        if file_path and input_file:
+            if file_type == 'photo':
+                await bot_instance.send_photo(chat_id=user_id, photo=input_file, caption=text, parse_mode=ParseMode.HTML)
+            elif file_type == 'video':
+                await bot_instance.send_video(chat_id=user_id, video=input_file, caption=text, parse_mode=ParseMode.HTML)
+            elif file_type == 'document':
+                await bot_instance.send_document(chat_id=user_id, document=input_file, caption=text, parse_mode=ParseMode.HTML)
+            elif file_type == 'audio':
+                await bot_instance.send_audio(chat_id=user_id, audio=input_file, caption=text, parse_mode=ParseMode.HTML)
+            else: # Default to sending text if file_type is unknown or file couldn't be processed
+                await bot_instance.send_message(chat_id=user_id, text=text, parse_mode=ParseMode.HTML)
+                if file_path: logger.warning(f"Unknown file type '{file_type}' for {file_path}, sent as text.")
+        elif text:
+            await bot_instance.send_message(chat_id=user_id, text=text, parse_mode=ParseMode.HTML)
+        
+        logger.info(f"Sent notification to {user_id}")
+        return True
+
+    except TelegramAPIError as e:
+        logger.error(f"Telegram API Error sending to {user_id}: {e}")
+        if "bot was blocked by the user" in str(e) or "user is deactivated" in str(e) or "chat not found" in str(e):
+            logger.info(f"User {user_id} blocked the bot or is deactivated. Removing from subscribers.")
+            if user_id in subscribed_users:
+                subscribed_users.remove(user_id)
+                save_subscribed_users()
+        return False
+    except Exception as e:
+        logger.error(f"Unexpected error sending to {user_id}: {e}")
+        return False
 
-    if download_db_from_hf(specific_file=DATA_FILE):
+async def process_notifications_from_queue():
+    """Continuously processes messages from the queue and sends them."""
+    global message_queue
+    while True:
         try:
-            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):
-                 logging.error(f"Downloaded {DATA_FILE} is not a dictionary. Using default.")
-                 return default_data
-            for key in default_data:
-                if key not in data: data[key] = default_data[key]
-            return data
-        except Exception as load_e:
-            logging.error(f"Error loading downloaded {DATA_FILE}: {load_e}. Using default.", exc_info=True)
-            return default_data
-    else:
-        logging.error(f"Failed to download {DATA_FILE} from HF. 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
+            notification_item = await message_queue.get()
+            text_content = notification_item.get("text")
+            file_path = notification_item.get("file_path")
+            file_type = notification_item.get("file_type")
 
-def save_data(data):
-    try:
-        if not isinstance(data, dict):
-            logging.error("Attempted to save invalid data structure (not a dict). Aborting save.")
-            return
-        default_keys = {'resumes': [], 'vacancies': [], 'freelance_offers': [], 'users': {}}
-        for key in default_keys:
-            if key not in data: data[key] = default_keys[key]
-
-        with open(DATA_FILE, 'w', encoding='utf-8') as file:
-            json.dump(data, file, ensure_ascii=False, indent=4)
-        logging.info(f"Data successfully saved to {DATA_FILE}")
-        upload_db_to_hf(specific_file=DATA_FILE)
-    except Exception as e:
-        logging.error(f"Error saving data to {DATA_FILE}: {e}", exc_info=True)
+            logger.info(f"Processing notification: Text='{text_content[:50]}...', File='{file_path}'")
+            
+            # Create a copy of subscribed_users to iterate over, in case it's modified
+            current_subscribers = list(subscribed_users) 
+            
+            for user_id in current_subscribers:
+                await send_notification_to_user(user_id, text_content, file_path, file_type)
+                await asyncio.sleep(0.1) # Small delay to avoid hitting rate limits too hard
 
-def verify_telegram_auth_data(auth_data_str, bot_token):
-    if not auth_data_str:
-        return False, None
-    
-    params = dict(urllib.parse.parse_qsl(auth_data_str))
-    if 'hash' not in params:
-        return False, None
+            if file_path and os.path.exists(file_path):
+                try:
+                    os.remove(file_path)
+                    logger.info(f"Temporary file {file_path} deleted.")
+                except Exception as e:
+                    logger.error(f"Error deleting temporary file {file_path}: {e}")
+            
+            message_queue.task_done()
+        except asyncio.CancelledError:
+            logger.info("Notification processor task cancelled.")
+            break
+        except Exception as e:
+            logger.error(f"Error in notification processor: {e}")
+            # Potentially re-queue or handle the error, for now just log
+            if 'message_queue' in locals() and message_queue is not None: # Check if message_queue exists
+                 message_queue.task_done() # Ensure task_done is called even on error to prevent blocking
+
+@dp.message(CommandStart())
+async def handle_start(message: types.Message):
+    user_id = message.from_user.id
+    if user_id not in subscribed_users:
+        subscribed_users.add(user_id)
+        save_subscribed_users()
+        logger.info(f"User {user_id} ({message.from_user.full_name}) subscribed.")
+        await message.reply("🎉 вы подписались на уведомления!")
+    else:
+        logger.info(f"User {user_id} ({message.from_user.full_name}) is already subscribed.")
+        await message.reply("Вы уже подписаны на уведомления. 👍")
 
-    received_hash = params.pop('hash')
-    
-    sorted_params = sorted(params.items())
-    data_check_string_parts = []
-    for key, value in sorted_params:
-        data_check_string_parts.append(f"{key}={value}")
-    
-    data_check_string = "\n".join(data_check_string_parts)
-    
-    secret_key = hmac.new("WebAppData".encode(), bot_token.encode(), hashlib.sha256).digest()
-    calculated_hash = hmac.new(secret_key, data_check_string.encode(), hashlib.sha256).hexdigest()
-    
-    if calculated_hash == received_hash:
-        try:
-            user_data = json.loads(params.get('user', '{}'))
-            return True, user_data
-        except json.JSONDecodeError:
-            return False, None
-    return False, None
+# --- Flask Admin Panel ---
+flask_app = Flask(__name__)
+flask_app.config['UPLOAD_FOLDER'] = str(UPLOAD_FOLDER) # Flask expects string path
+flask_app.config['MAX_CONTENT_LENGTH'] = 50 * 1024 * 1024  # 50 MB limit for uploads
 
+# Ensure UPLOAD_FOLDER exists
+UPLOAD_FOLDER.mkdir(parents=True, exist_ok=True)
 
-MAIN_APP_TEMPLATE = '''
+ADMIN_PANEL_HTML = """
 <!DOCTYPE html>
-<html lang="en">
+<html lang="ru">
 <head>
     <meta charset="UTF-8">
-    <meta name="viewport" content="width=device-width, initial-scale=1.0, user-scalable=no, viewport-fit=cover">
-    <title>TonTalent</title>
-    <script src="https://telegram.org/js/telegram-web-app.js"></script>
+    <meta name="viewport" content="width=device-width, initial-scale=1.0">
+    <title>Admin Panel - Telegram Notifier</title>
     <style>
-        :root {
-            --tg-theme-bg-color: #ffffff;
-            --tg-theme-text-color: #000000;
-            --tg-theme-hint-color: #999999;
-            --tg-theme-link-color: #007aff;
-            --tg-theme-button-color: #007aff;
-            --tg-theme-button-text-color: #ffffff;
-            --tg-theme-secondary-bg-color: #f0f0f0;
-            --tg-theme-header-bg-color: #efeff4;
-            --tg-theme-section-bg-color: #ffffff;
-            --tg-theme-section-header-text-color: #8e8e93;
-            --tg-theme-destructive-text-color: #ff3b30;
-            --tg-theme-accent-text-color: #007aff;
-        }
-        body {
-            font-family: -apple-system, BlinkMacSystemFont, "Segoe UI", "Roboto", "Helvetica Neue", Arial, sans-serif;
-            margin: 0;
-            padding: 0;
-            background-color: var(--tg-theme-bg-color);
-            color: var(--tg-theme-text-color);
-            overscroll-behavior-y: none;
-            -webkit-font-smoothing: antialiased;
-            -moz-osx-font-smoothing: grayscale;
-            line-height: 1.4;
-        }
-        .app-container { display: flex; flex-direction: column; min-height: 100vh; min-height: -webkit-fill-available; }
-        .header {
-            background-color: var(--tg-theme-header-bg-color);
-            padding: 12px 15px;
-            text-align: center;
-            font-weight: 600;
-            font-size: 17px;
-            border-bottom: 0.5px solid var(--tg-theme-secondary-bg-color);
-            position: sticky;
-            top: 0;
-            z-index: 100;
-        }
-        .user-info-bar {
-            display: flex;
-            align-items: center;
-            padding: 10px 15px;
-            background-color: var(--tg-theme-section-bg-color);
-            border-bottom: 0.5px solid var(--tg-theme-secondary-bg-color);
-        }
-        .user-info-bar.clickable {
-            cursor: pointer;
-            transition: background-color 0.2s ease;
-        }
-        .user-info-bar.clickable:active {
-            background-color: var(--tg-theme-secondary-bg-color);
-        }
-        .user-info-bar img {
-            width: 40px;
-            height: 40px;
-            border-radius: 50%;
-            margin-right: 12px;
-            object-fit: cover;
-            background-color: var(--tg-theme-secondary-bg-color);
+        body { font-family: sans-serif; margin: 20px; background-color: #f4f4f9; color: #333; }
+        .container { background-color: #fff; padding: 20px; border-radius: 8px; box-shadow: 0 0 10px rgba(0,0,0,0.1); }
+        h1 { color: #5a5a5a; text-align: center; }
+        label { display: block; margin-bottom: 8px; font-weight: bold; }
+        textarea, input[type="file"] {
+            width: calc(100% - 22px); /* Adjust for padding and border */
+            padding: 10px;
+            margin-bottom: 20px;
+            border: 1px solid #ddd;
+            border-radius: 4px;
+            box-sizing: border-box; /* Important for width calculation */
         }
-        .user-info-bar span {
-            font-size: 15px;
-            font-weight: 500;
-            color: var(--tg-theme-text-color);
+        textarea { min-height: 100px; resize: vertical; }
+        button {
+            background-color: #007bff; color: white; padding: 12px 20px;
+            border: none; border-radius: 4px; cursor: pointer; font-size: 16px;
+            transition: background-color 0.3s ease;
         }
-        .tabs { display: flex; background-color: var(--tg-theme-secondary-bg-color); padding: 5px; }
-        .tab-button {
-            flex: 1;
-            padding: 12px 10px;
+        button:hover { background-color: #0056b3; }
+        .status {
+            margin-top: 20px; padding: 10px; border-radius: 4px;
             text-align: center;
-            cursor: pointer;
-            background: none;
-            border: none;
-            color: var(--tg-theme-hint-color);
-            font-size: 15px;
-            font-weight: 500;
-            border-bottom: 2.5px solid transparent;
-            transition: color 0.2s ease, border-bottom-color 0.2s ease;
-            -webkit-tap-highlight-color: transparent;
-        }
-        .tab-button.active { color: var(--tg-theme-link-color); border-bottom-color: var(--tg-theme-link-color); }
-        .content { flex-grow: 1; padding: 0; overflow-x: hidden; transition: opacity 0.2s ease-out; }
-        .list-item {
-            background-color: var(--tg-theme-section-bg-color);
-            padding: 12px 15px;
-            margin: 10px 15px;
-            border-radius: 10px;
-            box-shadow: 0 2px 8px rgba(0,0,0,0.06);
-            cursor: pointer;
-            transition: transform 0.1s ease-out, background-color 0.1s ease;
-        }
-        .list-item:active { transform: scale(0.98); background-color: var(--tg-theme-secondary-bg-color); }
-        .list-item h3 { margin: 0 0 6px 0; font-size: 17px; font-weight: 600; color: var(--tg-theme-text-color); }
-        .list-item p { margin: 0 0 4px 0; font-size: 14px; color: var(--tg-theme-hint-color); }
-        .list-item .meta { font-size: 13px; color: var(--tg-theme-hint-color); margin-top: 8px; }
-        .form-container, .detail-view { padding: 20px 15px; background-color: var(--tg-theme-section-bg-color); min-height: calc(100vh - 180px); /* Adjust based on header/tabs/userbar height */ }
-        .form-group { margin-bottom: 18px; }
-        .form-group label { display: block; font-size: 14px; color: var(--tg-theme-section-header-text-color); margin-bottom: 6px; font-weight: 500; }
-        .form-group input, .form-group textarea {
-            width: 100%;
-            padding: 12px;
-            border: 1px solid var(--tg-theme-secondary-bg-color);
-            border-radius: 8px;
-            font-size: 16px;
-            background-color: var(--tg-theme-bg-color);
-            color: var(--tg-theme-text-color);
-            box-sizing: border-box;
-            transition: border-color 0.2s ease;
         }
-        .form-group input:focus, .form-group textarea:focus { border-color: var(--tg-theme-link-color); outline: none; }
-        .form-group textarea { min-height: 100px; resize: vertical; }
-        .fab {
-            position: fixed;
-            bottom: 25px;
-            right: 25px;
-            width: 56px;
-            height: 56px;
-            background-color: var(--tg-theme-button-color);
-            color: var(--tg-theme-button-text-color);
+        .status.success { background-color: #d4edda; color: #155724; border: 1px solid #c3e6cb; }
+        .status.error { background-color: #f8d7da; color: #721c24; border: 1px solid #f5c6cb; }
+        .loader {
+            border: 5px solid #f3f3f3; /* Light grey */
+            border-top: 5px solid #3498db; /* Blue */
             border-radius: 50%;
-            display: flex;
-            align-items: center;
-            justify-content: center;
-            font-size: 28px;
-            line-height: 1;
-            box-shadow: 0 4px 12px rgba(0,0,0,0.15);
-            cursor: pointer;
-            z-index: 1000;
-            border: none;
-            transition: transform 0.15s ease-out;
+            width: 30px;
+            height: 30px;
+            animation: spin 1s linear infinite;
+            margin: 10px auto;
+            display: none; /* Hidden by default */
         }
-        .fab:active { transform: scale(0.92); }
-        .detail-view h2 { margin-top: 0; font-size: 22px; font-weight: 600; color: var(--tg-theme-text-color); margin-bottom: 15px; }
-        .detail-view p { margin-bottom: 10px; line-height: 1.6; font-size: 16px; }
-        .detail-view strong { font-weight: 500; color: var(--tg-theme-text-color); }
-        .detail-view .meta-detail { font-size: 13px; color: var(--tg-theme-hint-color); margin-top: 20px; }
-        .detail-view a { color: var(--tg-theme-link-color); text-decoration: none; }
-        .detail-view a:hover { text-decoration: underline; }
-        .loading, .empty-state { text-align: center; padding: 50px 15px; color: var(--tg-theme-hint-color); font-size: 16px; }
-        
-        .action-button {
-            display: block;
-            width: 100%;
-            padding: 12px 15px;
-            margin-top: 15px;
-            border: none;
-            border-radius: 8px;
-            font-size: 16px;
-            font-weight: 500;
-            cursor: pointer;
-            text-align: center;
-            transition: background-color 0.2s ease;
-        }
-        .button-destructive {
-            background-color: var(--tg-theme-destructive-text-color);
-            color: #ffffff;
+        @keyframes spin {
+            0% { transform: rotate(0deg); }
+            100% { transform: rotate(360deg); }
         }
-        .button-destructive:active {
-             background-color: color-mix(in srgb, var(--tg-theme-destructive-text-color) 80%, black);
-        }
-        .error-message { color: var(--tg-theme-destructive-text-color); font-size: 14px; margin-top: 10px; text-align: center; }
     </style>
 </head>
 <body>
-    <div class="app-container">
-        <div class="header" id="appHeader">TonTalent</div>
-        <div class="user-info-bar" id="userInfoBar">
-            <img id="userAvatar" src="data:image/gif;base64,R0lGODlhAQABAIAAAAAAAP///yH5BAEAAAAALAAAAAABAAEAAAIBRAA7" alt="Avatar">
-            <span id="userInfoText">Loading user...</span>
-        </div>
-        <div class="tabs">
-            <button class="tab-button active" data-tab="resumes">Resumes</button>
-            <button class="tab-button" data-tab="vacancies">Vacancies</button>
-            <button class="tab-button" data-tab="freelance_offers">Freelance</button>
-        </div>
-        <div class="content" id="mainContent">
-            <div class="loading">Loading content...</div>
-        </div>
-        <button class="fab" id="fabButton" title="Add New Item">+</button>
+    <div class="container">
+        <h1>Отправить уведомление</h1>
+        <form id="notificationForm" enctype="multipart/form-data">
+            <div>
+                <label for="message_text">Текст сообщения (HTML поддерживается):</label>
+                <textarea id="message_text" name="message_text" rows="5" required></textarea>
+            </div>
+            <div>
+                <label for="media_file">Прикрепить медиафайл (фото, видео, документ, аудио):</label>
+                <input type="file" id="media_file" name="media_file" accept="image/*,video/*,audio/*,.pdf,.doc,.docx,.txt,.zip">
+            </div>
+            <button type="submit">Отправить всем</button>
+        </form>
+        <div class="loader" id="loader"></div>
+        <div id="statusMessage" class="status" style="display:none;"></div>
     </div>
 
     <script>
-        const tg = window.Telegram.WebApp;
-        let currentUser = null;
-        let currentView = 'resumes';
-        let currentItem = null; 
-        let previousViewBeforeMyPosts = 'resumes';
-        const mainContent = document.getElementById('mainContent');
-        const fabButton = document.getElementById('fabButton');
-        const appHeader = document.getElementById('appHeader');
-        const tabOrder = ['resumes', 'vacancies', 'freelance_offers'];
+        document.getElementById('notificationForm').addEventListener('submit', async function(event) {
+            event.preventDefault();
+            const form = event.target;
+            const formData = new FormData(form);
+            const statusDiv = document.getElementById('statusMessage');
+            const loader = document.getElementById('loader');
 
-        function capitalizeFirstLetter(string) {
-            return string.charAt(0).toUpperCase() + string.slice(1);
-        }
+            statusDiv.style.display = 'none';
+            statusDiv.className = 'status'; // Reset class
+            loader.style.display = 'block'; // Show loader
 
-        function applyThemeParams() {
-            const rootStyle = document.documentElement.style;
-            rootStyle.setProperty('--tg-theme-bg-color', tg.themeParams.bg_color || '#ffffff');
-            rootStyle.setProperty('--tg-theme-text-color', tg.themeParams.text_color || '#000000');
-            rootStyle.setProperty('--tg-theme-hint-color', tg.themeParams.hint_color || '#999999');
-            rootStyle.setProperty('--tg-theme-link-color', tg.themeParams.link_color || '#007aff');
-            rootStyle.setProperty('--tg-theme-button-color', tg.themeParams.button_color || '#007aff');
-            rootStyle.setProperty('--tg-theme-button-text-color', tg.themeParams.button_text_color || '#ffffff');
-            rootStyle.setProperty('--tg-theme-secondary-bg-color', tg.themeParams.secondary_bg_color || '#f0f0f0');
-            
-            rootStyle.setProperty('--tg-theme-header-bg-color', tg.themeParams.header_bg_color || tg.themeParams.secondary_bg_color || '#efeff4');
-            rootStyle.setProperty('--tg-theme-section-bg-color', tg.themeParams.section_bg_color || tg.themeParams.bg_color || '#ffffff');
-            rootStyle.setProperty('--tg-theme-section-header-text-color', tg.themeParams.section_header_text_color || tg.themeParams.hint_color || '#8e8e93');
-            rootStyle.setProperty('--tg-theme-destructive-text-color', tg.themeParams.destructive_text_color || '#ff3b30');
-            rootStyle.setProperty('--tg-theme-accent-text-color', tg.themeParams.accent_text_color || tg.themeParams.link_color || '#007aff');
-        }
-        
-        async function apiCall(endpoint, method = 'GET', body = null) {
-            const headers = { 'Content-Type': 'application/json' };
-            if (tg.initData) {
-                headers['X-Telegram-Auth'] = tg.initData;
-            }
-            const options = { method, headers };
-            if (body) options.body = JSON.stringify(body);
             try {
-                const response = await fetch(endpoint, options);
-                if (!response.ok) {
-                    const errorData = await response.json().catch(() => ({ error: 'Request failed without JSON body' }));
-                    throw new Error(errorData.error || `HTTP error ${response.status}`);
-                }
-                return response.json();
-            } catch (error) {
-                console.error('API Call Error:', error);
-                tg.showAlert(error.message || 'An API error occurred.');
-                throw error;
-            }
-        }
-
-        function renderList(items, type) {
-            mainContent.style.opacity = 0;
-            if (!items || items.length === 0) {
-                mainContent.innerHTML = `<div class="empty-state">No ${type} found. Be the first to add one!</div>`;
-            } else {
-                mainContent.innerHTML = items.map(item => `
-                    <div class="list-item" onclick="handleItemClick('${type}', '${item.id}')">
-                        <h3>${item.title || item.name || 'Untitled'}</h3>
-                        ${type === 'vacancies' && item.company_name ? `<p><strong>Company:</strong> ${item.company_name}</p>` : ''}
-                        ${type === 'freelance_offers' && item.budget ? `<p><strong>Budget:</strong> ${item.budget}</p>` : ''}
-                        <p class="meta">Posted by: @${item.user_telegram_username || 'anonymous'} on ${new Date(item.timestamp).toLocaleDateString()}</p>
-                    </div>
-                `).join('');
-            }
-            setTimeout(() => { mainContent.style.opacity = 1; }, 50);
-        }
-        
-        function handleItemClick(type, id) {
-            tg.HapticFeedback.impactOccurred('light');
-            showDetailView(type, id);
-        }
-
-        function formatContactField(contactValue, userTelegramUsername) {
-            let displayContact = contactValue;
-            if (!displayContact && userTelegramUsername) {
-                return `<a href="tg://resolve?domain=${userTelegramUsername}" target="_blank" rel="noopener noreferrer">@${userTelegramUsername}</a>`;
-            }
-            if (displayContact) {
-                if (displayContact.startsWith('@')) {
-                    const username = displayContact.substring(1);
-                    return `<a href="tg://resolve?domain=${username}" target="_blank" rel="noopener noreferrer">${displayContact}</a>`;
-                } else if (displayContact.startsWith('http://') || displayContact.startsWith('https://')) {
-                    return `<a href="${displayContact}" target="_blank" rel="noopener noreferrer">${displayContact}</a>`;
-                } else if (displayContact.includes('@') && displayContact.includes('.') && !displayContact.startsWith('http')) {
-                    return `<a href="mailto:${displayContact}">${displayContact}</a>`;
-                }
-            }
-            return displayContact || 'N/A';
-        }
-
-        function showDetailView(type, id) {
-            mainContent.style.opacity = 0;
-            tg.BackButton.show();
-            tg.BackButton.onClick(() => {
-                tg.HapticFeedback.impactOccurred('light');
-                if (currentView === 'my_posts') {
-                    showMyPostsView();
-                } else {
-                    loadView(type);
-                }
-            });
-            tg.MainButton.hide();
-            fabButton.style.display = 'none';
-
-            apiCall(`/api/${type}/${id}`)
-                .then(item => {
-                    currentItem = item;
-                    let detailsHtml = `<div class="detail-view"><h2>${item.title || item.name}</h2>`;
-                    
-                    const itemContact = formatContactField(item.contact, item.user_telegram_username);
-                    const postedByLink = item.user_telegram_username 
-                        ? `<a href="tg://resolve?domain=${item.user_telegram_username}" target="_blank" rel="noopener noreferrer">@${item.user_telegram_username}</a>`
-                        : 'anonymous';
-
-                    if (type === 'resumes') {
-                        detailsHtml += `
-                            <p><strong>Skills:</strong> ${item.skills || 'N/A'}</p>
-                            <p><strong>Experience:</strong><br>${item.experience ? item.experience.replace(/\\n/g, '<br>') : 'N/A'}</p>
-                            <p><strong>Education:</strong><br>${item.education ? item.education.replace(/\\n/g, '<br>') : 'N/A'}</p>
-                            <p><strong>Contact:</strong> ${itemContact}</p>
-                            ${item.portfolio_link ? `<p><strong>Portfolio:</strong> <a href="${item.portfolio_link}" target="_blank" rel="noopener noreferrer">${item.portfolio_link}</a></p>` : ''}
-                        `;
-                    } else if (type === 'vacancies') {
-                        detailsHtml += `
-                            <p><strong>Company:</strong> ${item.company_name || 'N/A'}</p>
-                            <p><strong>Description:</strong><br>${item.description ? item.description.replace(/\\n/g, '<br>') : 'N/A'}</p>
-                            <p><strong>Requirements:</strong><br>${item.requirements ? item.requirements.replace(/\\n/g, '<br>') : 'N/A'}</p>
-                            <p><strong>Salary:</strong> ${item.salary || 'N/A'}</p>
-                            <p><strong>Location:</strong> ${item.location || 'N/A'}</p>
-                            <p><strong>Contact/Apply:</strong> ${itemContact}</p>
-                        `;
-                    } else if (type === 'freelance_offers') {
-                        detailsHtml += `
-                            <p><strong>Description:</strong><br>${item.description ? item.description.replace(/\\n/g, '<br>') : 'N/A'}</p>
-                            <p><strong>Budget:</strong> ${item.budget || 'N/A'}</p>
-                            <p><strong>Deadline:</strong> ${item.deadline || 'N/A'}</p>
-                            <p><strong>Skills Needed:</strong> ${item.skills_needed || 'N/A'}</p>
-                            <p><strong>Contact:</strong> ${itemContact}</p>
-                        `;
-                    }
-                    detailsHtml += `<p class="meta-detail">Posted by: ${postedByLink} on ${new Date(item.timestamp).toLocaleDateString()}</p>`;
-                    
-                    if (currentUser && item.user_id === String(currentUser.id)) {
-                        detailsHtml += `<button id="editItemButton" class="action-button" style="background-color: var(--tg-theme-button-color); color: var(--tg-theme-button-text-color); margin-top: 25px;">Edit Post</button>`;
-                        detailsHtml += `<button id="deleteItemButton" class="action-button button-destructive">Delete Post</button>`;
-                    }
-                    detailsHtml += `</div>`;
-                    mainContent.innerHTML = detailsHtml;
-
-                    if (currentUser && item.user_id === String(currentUser.id)) {
-                        document.getElementById('editItemButton')?.addEventListener('click', () => {
-                            tg.HapticFeedback.impactOccurred('light');
-                            showForm(type, item);
-                        });
-                        document.getElementById('deleteItemButton')?.addEventListener('click', () => {
-                            tg.HapticFeedback.impactOccurred('light');
-                            handleDeleteItem(type, item.id);
-                        });
-                    }
-                    setTimeout(() => { mainContent.style.opacity = 1; }, 50);
-                })
-                .catch(err => {
-                    mainContent.innerHTML = `<div class="empty-state">Error loading details.</div>`;
-                    setTimeout(() => { mainContent.style.opacity = 1; }, 50);
+                const response = await fetch('/send_notification', {
+                    method: 'POST',
+                    body: formData
                 });
-        }
-        
-        function showForm(type, itemToEdit = null) {
-            mainContent.style.opacity = 0;
-            currentItem = itemToEdit;
-            tg.BackButton.show();
-            tg.BackButton.onClick(() => {
-                tg.HapticFeedback.impactOccurred('light');
-                if (itemToEdit) showDetailView(type, itemToEdit.id);
-                else if (currentView === 'my_posts') showMyPostsView();
-                else loadView(type);
-            });
-            fabButton.style.display = 'none';
-
-            let formHtml = `<div class="form-container"><h2>${itemToEdit ? 'Edit' : 'New'} ${type.slice(0, -1)}</h2>`;
-            if (type === 'resumes') {
-                formHtml += `
-                    <div class="form-group"><label for="name">Full Name *</label><input type="text" id="name" value="${itemToEdit?.name || ''}" required></div>
-                    <div class="form-group"><label for="title">Job Title / Desired Position *</label><input type="text" id="title" value="${itemToEdit?.title || ''}" required></div>
-                    <div class="form-group"><label for="skills">Skills (comma separated)</label><textarea id="skills">${itemToEdit?.skills || ''}</textarea></div>
-                    <div class="form-group"><label for="experience">Experience</label><textarea id="experience">${itemToEdit?.experience || ''}</textarea></div>
-                    <div class="form-group"><label for="education">Education</label><textarea id="education">${itemToEdit?.education || ''}</textarea></div>
-                    <div class="form-group"><label for="contact">Contact Info (e.g., email, or leave blank to use Telegram)</label><input type="text" id="contact" value="${itemToEdit?.contact || ''}"></div>
-                    <div class="form-group"><label for="portfolio_link">Portfolio Link (optional)</label><input type="url" id="portfolio_link" value="${itemToEdit?.portfolio_link || ''}"></div>
-                `;
-            } else if (type === 'vacancies') {
-                formHtml += `
-                    <div class="form-group"><label for="company_name">Company Name *</label><input type="text" id="company_name" value="${itemToEdit?.company_name || ''}" required></div>
-                    <div class="form-group"><label for="title">Job Title *</label><input type="text" id="title" value="${itemToEdit?.title || ''}" required></div>
-                    <div class="form-group"><label for="description">Description</label><textarea id="description">${itemToEdit?.description || ''}</textarea></div>
-                    <div class="form-group"><label for="requirements">Requirements</label><textarea id="requirements">${itemToEdit?.requirements || ''}</textarea></div>
-                    <div class="form-group"><label for="salary">Salary/Compensation</label><input type="text" id="salary" value="${itemToEdit?.salary || ''}"></div>
-                    <div class="form-group"><label for="location">Location (e.g., Remote, City)</label><input type="text" id="location" value="${itemToEdit?.location || ''}"></div>
-                    <div class="form-group"><label for="contact">Contact Info / How to Apply</label><textarea id="contact">${itemToEdit?.contact || ''}</textarea></div>
-                `;
-            } else if (type === 'freelance_offers') {
-                formHtml += `
-                    <div class="form-group"><label for="title">Project Title *</label><input type="text" id="title" value="${itemToEdit?.title || ''}" required></div>
-                    <div class="form-group"><label for="description">Description of Work</label><textarea id="description">${itemToEdit?.description || ''}</textarea></div>
-                    <div class="form-group"><label for="budget">Budget</label><input type="text" id="budget" value="${itemToEdit?.budget || ''}"></div>
-                    <div class="form-group"><label for="deadline">Expected Deadline</label><input type="text" id="deadline" value="${itemToEdit?.deadline || ''}"></div>
-                    <div class="form-group"><label for="skills_needed">Skills Needed (comma separated)</label><textarea id="skills_needed">${itemToEdit?.skills_needed || ''}</textarea></div>
-                    <div class="form-group"><label for="contact">Contact Info (or leave blank to use Telegram)</label><input type="text" id="contact" value="${itemToEdit?.contact || ''}"></div>
-                `;
-            }
-            formHtml += `<div id="formError" class="error-message"></div></div>`;
-            mainContent.innerHTML = formHtml;
-            setTimeout(() => { mainContent.style.opacity = 1; }, 50);
-
-            tg.MainButton.setText(itemToEdit ? 'Save Changes' : 'Post');
-            tg.MainButton.show();
-            tg.MainButton.onClick(() => handleSubmit(type, itemToEdit ? itemToEdit.id : null));
-        }
-
-        function handleSubmit(type, itemId = null) {
-            const payload = {};
-            let isValid = true;
-            document.getElementById('formError').textContent = '';
-
-            if (type === 'resumes') {
-                payload.name = document.getElementById('name').value.trim();
-                payload.title = document.getElementById('title').value.trim();
-                payload.skills = document.getElementById('skills').value.trim();
-                payload.experience = document.getElementById('experience').value.trim();
-                payload.education = document.getElementById('education').value.trim();
-                payload.contact = document.getElementById('contact').value.trim();
-                payload.portfolio_link = document.getElementById('portfolio_link').value.trim();
-                if (!payload.name || !payload.title) isValid = false;
-            } else if (type === 'vacancies') {
-                payload.company_name = document.getElementById('company_name').value.trim();
-                payload.title = document.getElementById('title').value.trim();
-                payload.description = document.getElementById('description').value.trim();
-                payload.requirements = document.getElementById('requirements').value.trim();
-                payload.salary = document.getElementById('salary').value.trim();
-                payload.location = document.getElementById('location').value.trim();
-                payload.contact = document.getElementById('contact').value.trim();
-                if (!payload.company_name || !payload.title) isValid = false;
-            } else if (type === 'freelance_offers') {
-                payload.title = document.getElementById('title').value.trim();
-                payload.description = document.getElementById('description').value.trim();
-                payload.budget = document.getElementById('budget').value.trim();
-                payload.deadline = document.getElementById('deadline').value.trim();
-                payload.skills_needed = document.getElementById('skills_needed').value.trim();
-                payload.contact = document.getElementById('contact').value.trim();
-                if (!payload.title) isValid = false;
-            }
-
-            if (!isValid) {
-                document.getElementById('formError').textContent = 'Please fill in all required fields (*).';
-                tg.HapticFeedback.notificationOccurred('error');
-                return;
-            }
-            
-            tg.MainButton.showProgress();
-            tg.HapticFeedback.impactOccurred('light');
-
-            const method = itemId ? 'PUT' : 'POST';
-            const endpoint = itemId ? `/api/${type}/${itemId}` : `/api/${type}`;
+                const result = await response.json();
 
-            apiCall(endpoint, method, payload)
-                .then(response => {
-                    tg.HapticFeedback.notificationOccurred('success');
-                    tg.MainButton.hideProgress();
-                    tg.MainButton.hide();
-                    if (currentView === 'my_posts') showMyPostsView();
-                    else loadView(type); 
-                })
-                .catch(err => {
-                    tg.HapticFeedback.notificationOccurred('error');
-                    tg.MainButton.hideProgress();
-                    document.getElementById('formError').textContent = err.message || 'Failed to submit.';
-                });
-        }
-
-        function handleDeleteItem(type, itemId) {
-            tg.showConfirm('Are you sure you want to delete this post?', (confirmed) => {
-                if (confirmed) {
-                    tg.HapticFeedback.impactOccurred('medium');
-                    apiCall(`/api/${type}/${itemId}`, 'DELETE')
-                        .then(() => {
-                            tg.HapticFeedback.notificationOccurred('success');
-                            tg.showAlert('Post deleted successfully.');
-                            if (currentView === 'my_posts') showMyPostsView();
-                            else loadView(type); 
-                        })
-                        .catch(err => {
-                            tg.HapticFeedback.notificationOccurred('error');
-                            tg.showAlert(err.message || 'Failed to delete post.');
-                        });
+                if (response.ok) {
+                    statusDiv.textContent = result.message || 'Уведомление успешно отправлено в очередь.';
+                    statusDiv.classList.add('success');
+                    form.reset(); // Clear the form
                 } else {
-                    tg.HapticFeedback.impactOccurred('light');
-                }
-            });
-        }
-
-        function loadView(tabName, fromSwipe = false) {
-            if (!fromSwipe && currentView !== tabName) tg.HapticFeedback.impactOccurred('light');
-            
-            if (currentView === 'my_posts' && tabName !== 'my_posts') {
-                appHeader.textContent = 'TonTalent';
-            }
-            currentView = tabName;
-
-            document.querySelectorAll('.tab-button').forEach(btn => btn.classList.remove('active'));
-            document.querySelector(`.tab-button[data-tab="${tabName}"]`).classList.add('active');
-            
-            mainContent.style.opacity = 0;
-            mainContent.innerHTML = `<div class="loading">Loading ${tabName}...</div>`;
-            
-            tg.BackButton.hide();
-            tg.MainButton.hide();
-            fabButton.style.display = 'block';
-
-            apiCall(`/api/${tabName}`)
-                .then(data => renderList(data, tabName))
-                .catch(err => {
-                    mainContent.innerHTML = `<div class="empty-state">Error loading ${tabName}.</div>`;
-                    setTimeout(() => { mainContent.style.opacity = 1; }, 50);
-                });
-        }
-
-        function renderMyPostsList(items) {
-            mainContent.style.opacity = 0;
-            if (!items || items.length === 0) {
-                mainContent.innerHTML = `<div class="empty-state">You haven't posted anything yet.</div>`;
-            } else {
-                mainContent.innerHTML = items.map(item => `
-                    <div class="list-item" onclick="handleItemClick('${item.type}', '${item.id}')">
-                        <h3>${item.title || item.name || 'Untitled'} <span style="font-weight:normal; font-size: 0.8em; color: var(--tg-theme-hint-color);">(${capitalizeFirstLetter(item.type.slice(0,-1))})</span></h3>
-                        ${item.type === 'vacancies' && item.company_name ? `<p><strong>Company:</strong> ${item.company_name}</p>` : ''}
-                        ${item.type === 'freelance_offers' && item.budget ? `<p><strong>Budget:</strong> ${item.budget}</p>` : ''}
-                        <p class="meta">Posted on ${new Date(item.timestamp).toLocaleDateString()}${item.updated_timestamp ? ' (Edited: ' + new Date(item.updated_timestamp).toLocaleDateString() + ')' : ''}</p>
-                    </div>
-                `).join('');
-            }
-            setTimeout(() => { mainContent.style.opacity = 1; }, 50);
-        }
-
-        function showMyPostsView() {
-            tg.HapticFeedback.impactOccurred('light');
-            if (currentView !== 'my_posts') { // Store the view only if we are not already in my_posts
-                previousViewBeforeMyPosts = currentView;
-            }
-            currentView = 'my_posts';
-            appHeader.textContent = 'My Posts';
-
-            document.querySelectorAll('.tab-button').forEach(btn => btn.classList.remove('active'));
-            fabButton.style.display = 'none';
-            tg.MainButton.hide();
-            
-            tg.BackButton.show();
-            tg.BackButton.onClick(() => {
-                tg.HapticFeedback.impactOccurred('light');
-                appHeader.textContent = 'TonTalent';
-                loadView(previousViewBeforeMyPosts);
-            });
-
-            mainContent.style.opacity = 0;
-            mainContent.innerHTML = '<div class="loading">Loading your posts...</div>';
-
-            Promise.all([
-                apiCall('/api/resumes'),
-                apiCall('/api/vacancies'),
-                apiCall('/api/freelance_offers')
-            ]).then(([resumes, vacancies, freelanceOffers]) => {
-                const myResumes = resumes.filter(item => String(item.user_id) === String(currentUser.id));
-                const myVacancies = vacancies.filter(item => String(item.user_id) === String(currentUser.id));
-                const myFreelanceOffers = freelanceOffers.filter(item => String(item.user_id) === String(currentUser.id));
-                
-                const allMyPosts = [
-                    ...myResumes.map(item => ({ ...item, type: 'resumes' })),
-                    ...myVacancies.map(item => ({ ...item, type: 'vacancies' })),
-                    ...myFreelanceOffers.map(item => ({ ...item, type: 'freelance_offers' }))
-                ].sort((a, b) => new Date(b.timestamp) - new Date(a.timestamp));
-
-                renderMyPostsList(allMyPosts);
-            }).catch(err => {
-                mainContent.innerHTML = '<div class="empty-state">Error loading your posts.</div>';
-                setTimeout(() => { mainContent.style.opacity = 1; }, 50);
-            });
-        }
-        
-        let touchstartX = 0;
-        let touchendX = 0;
-        const swipeThreshold = 70; 
-
-        mainContent.addEventListener('touchstart', e => {
-            if (currentView === 'my_posts') return; // Disable swipe on "My Posts" view
-            touchstartX = e.changedTouches[0].screenX;
-        }, { passive: true });
-
-        mainContent.addEventListener('touchend', e => {
-            if (currentView === 'my_posts') return; // Disable swipe on "My Posts" view
-            touchendX = e.changedTouches[0].screenX;
-            handleSwipeGesture();
-        });
-
-        function handleSwipeGesture() {
-            const swipeLength = touchendX - touchstartX;
-            if (Math.abs(swipeLength) < swipeThreshold) return;
-
-            let currentIndex = tabOrder.indexOf(currentView);
-            if (currentIndex === -1) return; // Should not happen if currentView is one of the tabs
-            let newIndex;
-
-            if (touchendX < touchstartX) { 
-                newIndex = (currentIndex + 1) % tabOrder.length;
-            } else { 
-                newIndex = (currentIndex - 1 + tabOrder.length) % tabOrder.length;
-            }
-            
-            if (newIndex !== currentIndex) {
-                tg.HapticFeedback.impactOccurred('light');
-                loadView(tabOrder[newIndex], true);
-            }
-        }
-
-        async function init() {
-            tg.ready();
-            applyThemeParams();
-            tg.expand();
-            tg.enableClosingConfirmation();
-
-            tg.onEvent('themeChanged', applyThemeParams);
-            
-            const userInfoText = document.getElementById('userInfoText');
-            const userAvatar = document.getElementById('userAvatar');
-            const userInfoBar = document.getElementById('userInfoBar');
-            
-            userInfoText.textContent = `Welcome, ${tg.initDataUnsafe.user?.first_name || 'User'}!`;
-            if (tg.initDataUnsafe.user?.username) {
-                userInfoText.textContent += ` (@${tg.initDataUnsafe.user.username})`;
-            }
-            
-            try {
-                const authResponse = await apiCall('/api/auth_user', 'POST', { init_data: tg.initData });
-                currentUser = authResponse.user;
-                if (currentUser) {
-                     userInfoText.textContent = `${currentUser.first_name || ''} ${currentUser.last_name || ''}`.trim();
-                     if (currentUser.username) userInfoText.textContent += ` (@${currentUser.username})`;
-                     else userInfoText.textContent += ` (ID: ${currentUser.id})`;
-                     
-                     if (currentUser.photo_url) {
-                        userAvatar.src = currentUser.photo_url;
-                     } else {
-                        // Keep default placeholder or hide
-                     }
-                     userInfoBar.classList.add('clickable');
-                     userInfoBar.addEventListener('click', () => {
-                        if(currentUser) showMyPostsView();
-                     });
+                    statusDiv.textContent = result.error || 'Ошибка при отправке уведомления.';
+                    statusDiv.classList.add('error');
                 }
             } catch (error) {
-                console.error("Auth error:", error);
-                userInfoText.textContent = `Auth failed. Using basic info.`;
-                // tg.showAlert("Authentication with the server failed. Some features might be limited.");
+                console.error('Fetch error:', error);
+                statusDiv.textContent = 'Сетевая ошибка или ошибка сервера. Подробности в консоли.';
+                statusDiv.classList.add('error');
+            } finally {
+                loader.style.display = 'none'; // Hide loader
+                statusDiv.style.display = 'block';
             }
-
-            document.querySelectorAll('.tab-button').forEach(button => {
-                button.addEventListener('click', () => loadView(button.dataset.tab));
-            });
-            fabButton.addEventListener('click', () => {
-                tg.HapticFeedback.impactOccurred('medium');
-                showForm(currentView); // currentView should be one of the main tabs here
-            });
-            
-            loadView('resumes');
-        }
-
-        init();
+        });
     </script>
 </body>
 </html>
-'''
-
-ADMIN_TEMPLATE = '''
-<!DOCTYPE html>
-<html lang="en">
-<head>
-    <meta charset="UTF-8">
-    <meta name="viewport" content="width=device-width, initial-scale=1.0">
-    <title>TonTalent Admin</title>
-    <style>
-        body { font-family: sans-serif; margin: 20px; background-color: #f4f4f4; color: #333; }
-        .container { background-color: #fff; padding: 20px; border-radius: 8px; box-shadow: 0 0 10px rgba(0,0,0,0.1); }
-        h1, h2 { color: #333; }
-        .section { margin-bottom: 30px; padding: 15px; border: 1px solid #ddd; border-radius: 5px; background-color: #f9f9f9;}
-        .item { border-bottom: 1px solid #eee; padding: 10px 0; }
-        .item:last-child { border-bottom: none; }
-        .item h3 { margin: 0 0 5px 0; }
-        .item p { margin: 3px 0; font-size: 0.9em; color: #555; }
-        .button { padding: 8px 15px; border: none; border-radius: 4px; cursor: pointer; font-size: 0.9em; margin-right: 5px; }
-        .button-primary { background-color: #007bff; color: white; }
-        .button-danger { background-color: #dc3545; color: white; }
-        .button-secondary { background-color: #6c757d; color: white; }
-        .message { padding: 10px; margin-bottom: 15px; border-radius: 4px; }
-        .message.success { background-color: #d4edda; color: #155724; border: 1px solid #c3e6cb; }
-        .message.error { background-color: #f8d7da; color: #721c24; border: 1px solid #f5c6cb; }
-        .message.warning { background-color: #fff3cd; color: #856404; border: 1px solid #ffeeba; }
-        .sync-buttons form { display: inline-block; margin-right: 10px; }
-    </style>
-</head>
-<body>
-    <div class="container">
-        <h1>TonTalent Admin Panel</h1>
-
-        {% with messages = get_flashed_messages(with_categories=true) %}
-            {% if messages %}
-                {% for category, message in messages %}
-                    <div class="message {{ category }}">{{ message }}</div>
-                {% endfor %}
-            {% endif %}
-        {% endwith %}
-
-        <div class="section">
-            <h2>Data Synchronization with Hugging Face</h2>
-            <div class="sync-buttons">
-                <form method="POST" action="{{ url_for('force_upload_admin') }}" onsubmit="return confirm('Upload local data to Hugging Face? This will overwrite server data.');">
-                    <button type="submit" class="button button-primary">Upload DB to HF</button>
-                </form>
-                <form method="POST" action="{{ url_for('force_download_admin') }}" onsubmit="return confirm('Download data from Hugging Face? This will overwrite local data.');">
-                    <button type="submit" class="button button-secondary">Download DB from HF</button>
-                </form>
-            </div>
-            <p style="font-size: 0.8em; color: #666;">Automatic backup runs every 30 minutes if HF_TOKEN_WRITE is set.</p>
-        </div>
-
-        <div class="section">
-            <h2>Resumes ({{ resumes|length }})</h2>
-            {% for resume in resumes %}
-            <div class="item">
-                <h3>{{ resume.name }} - {{ resume.title }}</h3>
-                <p>User ID: {{ resume.user_id }} (@{{ resume.user_telegram_username }})</p>
-                <p>Posted: {{ resume.timestamp }}</p>
-                <form method="POST" action="{{ url_for('admin_delete_item') }}" style="display:inline;" onsubmit="return confirm('Delete this resume?');">
-                    <input type="hidden" name="item_type" value="resumes">
-                    <input type="hidden" name="item_id" value="{{ resume.id }}">
-                    <button type="submit" class="button button-danger">Delete</button>
-                </form>
-            </div>
-            {% else %}
-            <p>No resumes found.</p>
-            {% endfor %}
-        </div>
-
-        <div class="section">
-            <h2>Vacancies ({{ vacancies|length }})</h2>
-            {% for vacancy in vacancies %}
-            <div class="item">
-                <h3>{{ vacancy.title }} - {{ vacancy.company_name }}</h3>
-                <p>User ID: {{ vacancy.user_id }} (@{{ vacancy.user_telegram_username }})</p>
-                <p>Posted: {{ vacancy.timestamp }}</p>
-                <form method="POST" action="{{ url_for('admin_delete_item') }}" style="display:inline;" onsubmit="return confirm('Delete this vacancy?');">
-                    <input type="hidden" name="item_type" value="vacancies">
-                    <input type="hidden" name="item_id" value="{{ vacancy.id }}">
-                    <button type="submit" class="button button-danger">Delete</button>
-                </form>
-            </div>
-            {% else %}
-            <p>No vacancies found.</p>
-            {% endfor %}
-        </div>
+"""
 
-        <div class="section">
-            <h2>Freelance Offers ({{ freelance_offers|length }})</h2>
-            {% for offer in freelance_offers %}
-            <div class="item">
-                <h3>{{ offer.title }}</h3>
-                <p>User ID: {{ offer.user_id }} (@{{ offer.user_telegram_username }})</p>
-                <p>Budget: {{ offer.budget }}</p>
-                <p>Posted: {{ offer.timestamp }}</p>
-                <form method="POST" action="{{ url_for('admin_delete_item') }}" style="display:inline;" onsubmit="return confirm('Delete this freelance offer?');">
-                    <input type="hidden" name="item_type" value="freelance_offers">
-                    <input type="hidden" name="item_id" value="{{ offer.id }}">
-                    <button type="submit" class="button button-danger">Delete</button>
-                </form>
-            </div>
-            {% else %}
-            <p>No freelance offers found.</p>
-            {% endfor %}
-        </div>
-    </div>
-</body>
-</html>
-'''
-
-@app.route('/')
-def main_app_view():
-    return render_template_string(MAIN_APP_TEMPLATE)
-
-@app.route('/api/auth_user', methods=['POST'])
-def auth_user():
-    auth_data_str = request.headers.get('X-Telegram-Auth')
-    if not auth_data_str:
-        init_data_payload = request.json.get('init_data')
-        if init_data_payload:
-            auth_data_str = init_data_payload
-        else:
-            return jsonify({"error": "Authentication data not provided"}), 401
-
-    is_valid, user_data_from_auth = verify_telegram_auth_data(auth_data_str, TELEGRAM_BOT_TOKEN)
-
-    if not is_valid or not user_data_from_auth:
-        return jsonify({"error": "Invalid authentication data"}), 403
-
-    data = load_data()
-    users = data.get('users', {})
-    user_id_str = str(user_data_from_auth.get('id'))
-
-    if user_id_str not in users:
-        users[user_id_str] = {
-            'id': user_data_from_auth.get('id'),
-            'first_name': user_data_from_auth.get('first_name'),
-            'last_name': user_data_from_auth.get('last_name'),
-            'username': user_data_from_auth.get('username'),
-            'language_code': user_data_from_auth.get('language_code'),
-            'photo_url': user_data_from_auth.get('photo_url'),
-            'first_seen': datetime.now().isoformat()
-        }
-    users[user_id_str]['last_seen'] = datetime.now().isoformat()
-    if user_data_from_auth.get('photo_url'):
-        users[user_id_str]['photo_url'] = user_data_from_auth.get('photo_url')
-    
-    data['users'] = users
-    save_data(data)
+@flask_app.route('/', methods=['GET'])
+def admin_panel():
+    return render_template_string(ADMIN_PANEL_HTML)
+
+def get_file_type(filename: str) -> str:
+    """Determines file type based on extension."""
+    ext = filename.rsplit('.', 1)[-1].lower() if '.' in filename else ''
+    if ext in ['jpg', 'jpeg', 'png', 'gif', 'bmp', 'webp']:
+        return 'photo'
+    elif ext in ['mp4', 'mov', 'avi', 'mkv', 'webm']:
+        return 'video'
+    elif ext in ['mp3', 'ogg', 'wav', 'flac', 'm4a']:
+        return 'audio'
+    elif ext in ['pdf', 'doc', 'docx', 'xls', 'xlsx', 'ppt', 'pptx', 'txt', 'zip', 'rar']:
+        return 'document'
+    return None # Unknown or unsupported for specific sending
+
+@flask_app.route('/send_notification', methods=['POST'])
+def handle_send_notification():
+    global message_queue, bot_loop
+    if not message_queue or not bot_loop:
+        logger.error("Bot components (queue or loop) not initialized for Flask.")
+        return {"error": "Серверная ошибка: компоненты бота не инициализированы."}, 500
+
+    message_text_html = request.form.get('message_text', '')
+    if not message_text_html and 'media_file' not in request.files:
+        return {"error": "Требуется текст сообщения или медиафайл."}, 400
+
+    # HTML escape text if you don't trust the admin input for Telegram HTML parsing
+    # For this example, we assume admin can use basic HTML like <b>, <i>, <a>
+    # text_content = html_escape(message_text) # if you want to be super safe and send as plain text
+    text_content = message_text_html # Use as is, assuming admin knows HTML for Telegram
+
+    file_path = None
+    file_type = None
     
-    return jsonify({"message": "User authenticated", "user": users[user_id_str]}), 200
-
-def get_authenticated_user_details(request_headers):
-    auth_data_str = request_headers.get('X-Telegram-Auth')
-    if not auth_data_str:
-        return None
-    is_valid, user_data_from_auth = verify_telegram_auth_data(auth_data_str, TELEGRAM_BOT_TOKEN)
-    if is_valid and user_data_from_auth:
-        data = load_data()
-        user_id_str = str(user_data_from_auth.get('id'))
-        return data.get('users', {}).get(user_id_str)
-    return None
-
-@app.route('/api/<item_type>', methods=['GET'])
-def get_items(item_type):
-    if item_type not in ['resumes', 'vacancies', 'freelance_offers']:
-        return jsonify({"error": "Invalid item type"}), 400
-    data = load_data()
-    items = sorted(data.get(item_type, []), key=lambda x: x.get('timestamp', ''), reverse=True)
-    return jsonify(items), 200
-
-@app.route('/api/<item_type>/<item_id>', methods=['GET'])
-def get_item(item_type, item_id):
-    if item_type not in ['resumes', 'vacancies', 'freelance_offers']:
-        return jsonify({"error": "Invalid item type"}), 400
-    data = load_data()
-    item = next((i for i in data.get(item_type, []) if i['id'] == item_id), None)
-    if item:
-        return jsonify(item), 200
-    return jsonify({"error": "Item not found"}), 404
-
-@app.route('/api/<item_type>', methods=['POST'])
-def create_item(item_type):
-    user = get_authenticated_user_details(request.headers)
-    if not user:
-        return jsonify({"error": "Authentication required or user not found in DB"}), 401
-
-    if item_type not in ['resumes', 'vacancies', 'freelance_offers']:
-        return jsonify({"error": "Invalid item type"}), 400
+    uploaded_file = request.files.get('media_file')
+    if uploaded_file and uploaded_file.filename != '':
+        filename = secure_filename(uploaded_file.filename)
+        file_path = str(UPLOAD_FOLDER / filename) # Store as string
+        try:
+            uploaded_file.save(file_path)
+            file_type = get_file_type(filename)
+            if not file_type:
+                logger.warning(f"Uploaded file {filename} has an unknown type for specific sending, will be sent as generic document or text only.")
+                # If file_type is crucial, you might want to return an error or default to 'document'
+        except Exception as e:
+            logger.error(f"Error saving uploaded file {filename}: {e}")
+            return {"error": f"Ошибка сохранения файла: {e}"}, 500
     
-    req_data = request.json
-    if not req_data:
-        return jsonify({"error": "No data provided"}), 400
-
-    new_item = {
-        "id": str(uuid.uuid4()),
-        "user_id": str(user.get('id')),
-        "user_telegram_username": user.get('username', 'unknown'),
-        "timestamp": datetime.now().isoformat(),
+    notification_item = {
+        "text": text_content,
+        "file_path": file_path,
+        "file_type": file_type
     }
 
-    if item_type == 'resumes':
-        required_fields = ['name', 'title']
-        for field in required_fields:
-            if not req_data.get(field): return jsonify({"error": f"Missing field: {field}"}), 400
-        new_item.update({
-            "name": req_data.get('name'), "title": req_data.get('title'),
-            "skills": req_data.get('skills', ''), "experience": req_data.get('experience', ''),
-            "education": req_data.get('education', ''), "contact": req_data.get('contact', ''),
-            "portfolio_link": req_data.get('portfolio_link', '')
-        })
-    elif item_type == 'vacancies':
-        required_fields = ['company_name', 'title']
-        for field in required_fields:
-            if not req_data.get(field): return jsonify({"error": f"Missing field: {field}"}), 400
-        new_item.update({
-            "company_name": req_data.get('company_name'), "title": req_data.get('title'),
-            "description": req_data.get('description', ''), "requirements": req_data.get('requirements', ''),
-            "salary": req_data.get('salary', ''), "location": req_data.get('location', ''),
-            "contact": req_data.get('contact', '')
-        })
-    elif item_type == 'freelance_offers':
-        required_fields = ['title']
-        for field in required_fields:
-            if not req_data.get(field): return jsonify({"error": f"Missing field: {field}"}), 400
-        new_item.update({
-            "title": req_data.get('title'), "description": req_data.get('description', ''),
-            "budget": req_data.get('budget', ''), "deadline": req_data.get('deadline', ''),
-            "skills_needed": req_data.get('skills_needed', ''), "contact": req_data.get('contact', '')
-        })
-    
-    data = load_data()
-    data[item_type].append(new_item)
-    save_data(data)
-    return jsonify(new_item), 201
-
-@app.route('/api/<item_type>/<item_id>', methods=['PUT'])
-def update_item(item_type, item_id):
-    user = get_authenticated_user_details(request.headers)
-    if not user: return jsonify({"error": "Authentication required or user not found in DB"}), 401
-
-    if item_type not in ['resumes', 'vacancies', 'freelance_offers']:
-        return jsonify({"error": "Invalid item type"}), 400
-    
-    req_data = request.json
-    if not req_data: return jsonify({"error": "No data provided"}), 400
-
-    data = load_data()
-    items_list = data.get(item_type, [])
-    item_index = -1
-    for idx, i in enumerate(items_list):
-        if i['id'] == item_id:
-            item_index = idx
-            break
-    
-    if item_index == -1: return jsonify({"error": "Item not found"}), 404
-    
-    original_item = items_list[item_index]
-    if str(original_item.get('user_id')) != str(user.get('id')):
-        return jsonify({"error": "Forbidden: You can only edit your own items"}), 403
-
-    updated_item = original_item.copy()
-    updated_item['updated_timestamp'] = datetime.now().isoformat()
-
-    if item_type == 'resumes':
-        updated_item.update({
-            "name": req_data.get('name', original_item.get('name')), 
-            "title": req_data.get('title', original_item.get('title')),
-            "skills": req_data.get('skills', original_item.get('skills')), 
-            "experience": req_data.get('experience', original_item.get('experience')),
-            "education": req_data.get('education', original_item.get('education')), 
-            "contact": req_data.get('contact', original_item.get('contact')),
-            "portfolio_link": req_data.get('portfolio_link', original_item.get('portfolio_link'))
-        })
-    elif item_type == 'vacancies':
-        updated_item.update({
-            "company_name": req_data.get('company_name', original_item.get('company_name')), 
-            "title": req_data.get('title', original_item.get('title')),
-            "description": req_data.get('description', original_item.get('description')), 
-            "requirements": req_data.get('requirements', original_item.get('requirements')),
-            "salary": req_data.get('salary', original_item.get('salary')), 
-            "location": req_data.get('location', original_item.get('location')),
-            "contact": req_data.get('contact', original_item.get('contact'))
-        })
-    elif item_type == 'freelance_offers':
-         updated_item.update({
-            "title": req_data.get('title', original_item.get('title')), 
-            "description": req_data.get('description', original_item.get('description')),
-            "budget": req_data.get('budget', original_item.get('budget')), 
-            "deadline": req_data.get('deadline', original_item.get('deadline')),
-            "skills_needed": req_data.get('skills_needed', original_item.get('skills_needed')), 
-            "contact": req_data.get('contact', original_item.get('contact'))
-        })
-
-    data[item_type][item_index] = updated_item
-    save_data(data)
-    return jsonify(updated_item), 200
-
-@app.route('/api/<item_type>/<item_id>', methods=['DELETE'])
-def delete_item(item_type, item_id):
-    user = get_authenticated_user_details(request.headers)
-    if not user: return jsonify({"error": "Authentication required or user not found in DB"}), 401
+    try:
+        # Put the item into the asyncio queue from this synchronous thread
+        future = asyncio.run_coroutine_threadsafe(message_queue.put(notification_item), bot_loop)
+        future.result(timeout=5) # Wait for the put operation to complete, with a timeout
+        logger.info(f"Notification enqueued: Text='{text_content[:30]}...', File='{file_path}'")
+        return {"message": "Уведомление добавлено в очередь на отправку."}, 200
+    except asyncio.TimeoutError:
+        logger.error("Timeout putting notification onto the queue.")
+        if file_path and os.path.exists(file_path): # Cleanup if queueing failed
+            os.remove(file_path)
+        return {"error": "Не удалось добавить уведомление в очередь (тайм-аут)."}, 500
+    except Exception as e:
+        logger.error(f"Error putting notification onto the queue: {e}")
+        if file_path and os.path.exists(file_path): # Cleanup if queueing failed
+            os.remove(file_path)
+        return {"error": f"Ошибка добавления в очередь: {e}"}, 500
 
-    if item_type not in ['resumes', 'vacancies', 'freelance_offers']:
-        return jsonify({"error": "Invalid item type"}), 400
+# --- Main Execution ---
+async def main_async():
+    global bot_instance, dp, message_queue, bot_loop
 
-    data = load_data()
-    items_list = data.get(item_type, [])
-    original_length = len(items_list)
-    
-    item_to_delete = next((i for i in items_list if i['id'] == item_id), None)
-    if not item_to_delete: return jsonify({"error": "Item not found"}), 404
+    bot_instance = Bot(token=BOT_TOKEN)
+    # dp is already initialized globally if you stick to that pattern,
+    # otherwise initialize here: dp = Dispatcher()
+    message_queue = asyncio.Queue()
+    bot_loop = asyncio.get_running_loop() # Get the current event loop
 
-    if str(item_to_delete.get('user_id')) != str(user.get('id')):
-        return jsonify({"error": "Forbidden: You can only delete your own items"}), 403
+    load_subscribed_users() # Load users before starting any tasks
 
-    data[item_type] = [i for i in items_list if i['id'] != item_id]
+    # Start the background task for processing notifications
+    asyncio.create_task(process_notifications_from_queue())
     
-    if len(data[item_type]) < original_length:
-        save_data(data)
-        return jsonify({"message": "Item deleted successfully"}), 200
-    return jsonify({"error": "Item not found or deletion failed"}), 404
-
-
-@app.route('/admin', methods=['GET'])
-def admin_panel():
-    data = load_data()
-    return render_template_string(ADMIN_TEMPLATE,
-                                  resumes=sorted(data.get('resumes', []), key=lambda x: x.get('timestamp', ''), reverse=True),
-                                  vacancies=sorted(data.get('vacancies', []), key=lambda x: x.get('timestamp', ''), reverse=True),
-                                  freelance_offers=sorted(data.get('freelance_offers', []), key=lambda x: x.get('timestamp', ''), reverse=True))
-
-@app.route('/admin/delete', methods=['POST'])
-def admin_delete_item():
-    item_type = request.form.get('item_type')
-    item_id = request.form.get('item_id')
-
-    if not item_type or not item_id or item_type not in ['resumes', 'vacancies', 'freelance_offers']:
-        flash('Invalid item type or ID for deletion.', 'error')
-        return redirect(url_for('admin_panel'))
-
-    data = load_data()
-    items_list = data.get(item_type, [])
-    original_length = len(items_list)
-    data[item_type] = [i for i in items_list if i['id'] != item_id]
-
-    if len(data[item_type]) < original_length:
-        save_data(data)
-        flash(f'{item_type.capitalize()[:-1]} deleted successfully.', 'success')
-    else:
-        flash('Item not found or already deleted.', 'warning')
-    return redirect(url_for('admin_panel'))
-
-@app.route('/admin/force_upload', methods=['POST'])
-def force_upload_admin():
-    logging.info("Admin forcing upload to Hugging Face...")
+    logger.info("Starting Telegram bot polling...")
     try:
-        upload_db_to_hf()
-        flash("Data successfully uploaded to Hugging Face.", 'success')
+        await dp.start_polling(bot_instance, allowed_updates=dp.resolve_used_update_types())
     except Exception as e:
-        logging.error(f"Error during forced upload: {e}", exc_info=True)
-        flash(f"Error uploading to Hugging Face: {e}", 'error')
-    return redirect(url_for('admin_panel'))
-
-@app.route('/admin/force_download', methods=['POST'])
-def force_download_admin():
-    logging.info("Admin forcing download from Hugging Face...")
-    try:
-        if download_db_from_hf():
-            flash("Data successfully downloaded from Hugging Face. Local files updated.", 'success')
-            load_data() 
-        else:
-            flash("Failed to download data from Hugging Face. Check logs.", 'error')
-    except Exception as e:
-        logging.error(f"Error during forced download: {e}", exc_info=True)
-        flash(f"Error downloading from Hugging Face: {e}", 'error')
-    return redirect(url_for('admin_panel'))
-
+        logger.critical(f"Fatal error in bot polling: {e}")
+    finally:
+        await bot_instance.session.close()
+        logger.info("Bot polling stopped and session closed.")
+
+def run_flask():
+    logger.info(f"Starting Flask server on {FLASK_HOST}:{FLASK_PORT}")
+    # Use a production-ready WSGI server like gunicorn or waitress in a real setup
+    # For simplicity, Flask's built-in server is used here.
+    # Setting debug=False is generally recommended for anything beyond local dev.
+    flask_app.run(host=FLASK_HOST, port=FLASK_PORT, debug=False, use_reloader=False)
 
 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.")
+    # Initialize Dispatcher here if not done globally already
+    # This pattern is common when dp needs to be accessible globally for route decorators
+    dp = Dispatcher() 
+    # Register handlers after dp is initialized
+    dp.message.register(handle_start, CommandStart())
 
-    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_WRITE not set).")
 
-    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)
+    # Start Flask in a separate thread
+    flask_thread = threading.Thread(target=run_flask, daemon=True)
+    flask_thread.start()
+
+    # Start Aiogram bot
+    try:
+        asyncio.run(main_async())
+    except KeyboardInterrupt:
+        logger.info("Application shutting down (KeyboardInterrupt)...")
+    except Exception as e:
+        logger.critical(f"Application crashed: {e}", exc_info=True)
+    finally:
+        logger.info("Application shutdown complete.")