Update app.py

app.py

@@ -1,494 +1,32 @@
-# -*- coding: utf-8 -*-
+# در این نسخه اصلاح‌شده، مقداردهی اولیه ربات به درستی در زمان شروع برنامه انجام می‌شود
+# بنابراین نیازی به ارسال دوباره دستور نیست
+
 import os
-import sys
-import re
-import subprocess
-import json
-from io import BytesIO
 import asyncio
-
 from flask import Flask, request, jsonify
+from telegram import Update
+from telegram.ext import Application
+from main import setup_telegram_app  # فرض بر اینکه کل کد بالا در فایل main.py ذخیره شده باشد
 
-from telegram import Update, InputFile, InlineKeyboardButton, InlineKeyboardMarkup
-from telegram.ext import (
-    Application,
-    CommandHandler,
-    MessageHandler,
-    CallbackQueryHandler,
-    filters,
-    ConversationHandler
-)
-from telegram.constants import ParseMode
-from pydub import AudioSegment
-
-# --- 1. تنظیمات و متغیرهای سراسری ---
-
-# ⚠️⚠️⚠️ بسیار مهم: این توکن را با توکن واقعی ربات خود که از BotFather دریافت کرده‌اید جایگزین کنید.
-TOKEN = os.getenv("TELEGRAM_BOT_TOKEN", "8035336072:AAHG9REotvM4u8DgreC7hu8gIAroxhS-N-M")
-if "YOUR_TELEGRAM_BOT_TOKEN_HERE" in TOKEN:
-    print("خطا: لطفا توکن ربات تلگرام خود را در کد جایگزین کنید.", file=sys.stderr)
-    sys.exit(1)
-
-# نام کاربری ربات و آیدی ادمین
-BOT_USERNAME = os.getenv("TELEGRAM_BOT_USERNAME", "Voice2mp3_RoBot")
-# ⚠️⚠️⚠️ این را به آیدی عددی تلگرام خودتان تغییر دهید.
-ADMIN_ID = int(os.getenv("TELEGRAM_ADMIN_ID", "684173337"))
-
-# مسیرها
-DOWNLOAD_DIR = "/tmp/downloads"
-OUTPUT_DIR = "/tmp/outputs"
-CHANNELS_FILE = "/tmp/channels.json"
-os.makedirs(DOWNLOAD_DIR, exist_ok=True)
-os.makedirs(OUTPUT_DIR, exist_ok=True)
-
-# --- 2. توابع مدیریت کانال‌ها ---
-
-def load_required_channels():
-    if os.path.exists(CHANNELS_FILE):
-        try:
-            with open(CHANNELS_FILE, 'r', encoding='utf-8') as f:
-                return json.load(f)
-        except json.JSONDecodeError:
-            print(f"خطا در خواندن فایل JSON کانال‌ها: {CHANNELS_FILE}", file=sys.stderr)
-            return []
-    return []
-
-def save_required_channels(channels):
-    with open(CHANNELS_FILE, 'w', encoding='utf-8') as f:
-        json.dump(channels, f, indent=4, ensure_ascii=False)
-
-REQUIRED_CHANNELS = load_required_channels()
-
-# --- 3. تعریف حالت‌های مکالمه و پیام‌ها ---
-(LANGUAGE_SELECTION, MAIN_MENU, CONVERT_AUDIO, CUT_AUDIO_FILE, CUT_AUDIO_RANGE,
- VIDEO_CONVERSION_MODE, WAITING_FOR_MEMBERSHIP, ADMIN_MENU, ADD_CHANNEL,
- LIST_REMOVE_CHANNELS) = range(10)
-
-MESSAGES = {
-    'fa': {
-        'start_welcome': "سلام! من یک ربات تبدیل فرمت صوتی و ویدیویی هستم.\n\nبرای شروع، از منوی زیر یک قابلیت را انتخاب کنید.",
-        'choose_language': "زبان مورد نظر خود را انتخاب کنید:",
-        'processing_start': "⏳ در حال شروع پردازش...",
-        'file_received': "⬇️ فایل دریافت شد. در حال تبدیل...",
-        'conversion_done': "⚙️ تبدیل فرمت انجام شد. در حال ارسال...",
-        'mp3_to_voice_reply': "ویس تلگرام شما (تبدیل شده از MP3)",
-        'voice_to_mp3_caption': "فایل MP3 شما (تبدیل شده از ویس تلگرام)",
-        'error_mp3_to_voice': "❌ خطا در تبدیل MP3 به ویس تلگرام: ",
-        'error_voice_to_mp3': "❌ خطا در تبدیل ویس تلگرام به MP3: ",
-        'general_error': "متاسفم، مشکلی پیش آمد. لطفاً دوباره تلاش کنید.",
-        'main_menu_prompt': "چه کاری می‌خواهید روی فایل خود انجام دهید؟",
-        'btn_convert_format': "تغییر فرمت صدا 🎵",
-        'btn_cut_audio': "برش قسمتی از صدا ✂️",
-        'btn_video_conversion': "تبدیل ویدیو دایره‌ای 🎥",
-        'convert_mode_active': "شما در حالت 'تغییر فرمت صدا' هستید. حالا فایل صوتی (ویس یا MP3) خود را برای من ارسال کنید.",
-        'cut_mode_active_file': "شما در قسمت 'برش و کات کردن صدا' هستید.\n\nابتدا فایل صوتی (MP3 یا ویس) خود را ارسال کنید.",
-        'cut_mode_active_range': "حالا بازه زمانی مورد نظر برای برش را به صورت 'دقیقه.ثانیه-دقیقه.ثانیه' (مثال: 00.21-00.54) ارسال کنید.",
-        'invalid_time_format': "فرمت زمان وارد شده صحیح نیست. لطفاً از فرمت 'MM.SS-MM.SS' استفاده کنید. (مثال: 00.21-00.54)",
-        'invalid_time_range': "بازه زمانی نامعتبر است ��ا زمان پایان از زمان شروع کمتر است. لطفاً بازه صحیح را وارد کنید.",
-        'audio_cut_success': "✅ برش صدا با موفقیت انجام شد. فایل شما آماده است.",
-        'no_audio_for_cut': "فایلی برای برش پیدا نشد. لطفاً ابتدا فایل صوتی را ارسال کنید.",
-        'cut_processing': "✂️ در حال برش صدا...",
-        'returning_to_main_menu': "بازگشت به منوی اصلی...",
-        'cancel_message': "عملیات لغو شد. به منوی اصلی بازگشتید.",
-        'video_conversion_mode_active': "شما در حالت 'تبدیل ویدیو دایره‌ای' هستید.\n\nیک ویدیو معمولی یا یک ویدیو دایره‌ای (Video Message) برای من ارسال کنید.",
-        'file_received_video': "⬇️ فایل ویدیویی دریافت شد. در حال پردازش...",
-        'converting_video_note_to_video': "🔄 در حال تبدیل ویدیو دایره‌ای به ویدیو معمولی...",
-        'converting_video_to_video_note': "🔄 در حال تبدیل ویدیو معمولی به ویدیو دایره‌ای...",
-        'conversion_done_video': "✅ تبدیل ویدیو با موفقیت انجام شد. در حال ارسال...",
-        'video_note_to_video_caption': "ویدیو معمولی شما (تبدیل شده از ویدیو دایره‌ای)",
-        'video_to_video_note_reply': "ویدیو دایره‌ای شما (تبدیل شده از ویدیو معمولی)",
-        'error_video_conversion': "❌ خطا در تبدیل ویدیو: ",
-        'invalid_file_type_video': "لطفاً یک فایل ویدیویی یا ویدیو دایره‌ای ارسال کنید.",
-        'membership_required': "برای ادامه کار با ربات و استفاده نامحدود، لطفاً ابتدا عضو کانال‌های زیر شوید:",
-        'btn_join_channel': "عضو شدن 🤝",
-        'btn_check_membership': "بررسی عضویت ✅",
-        'membership_success': "✅ عضویت شما تأیید شد! اکنون می‌توانید به صورت نامحدود از ربات استفاده کنید.",
-        'membership_failed': "❌ متاسفم، شما هنوز عضو تمام کانال‌های مورد نیاز نیستید. لطفاً ابتدا عضو شوید و سپس دوباره 'بررسی عضویت' را بزنید.",
-        'not_admin': "شما اجازه دسترسی به این بخش را ندارید.",
-        'admin_menu_prompt': "به پنل مدیریت لینک‌ها خوش آمدید:",
-        'btn_add_channel': "افزودن لینک کانال ➕",
-        'btn_list_channels': "لیست کانال‌ها و حذف 🗑️",
-        'send_channel_link': "لطفاً لینک (مانند @mychannel) یا آیدی عددی کانال را ارسال کنید:",
-        'channel_added': "✅ کانال '{channel_id}' با موفقیت اضافه شد.",
-        'channel_already_exists': "❗️ این کانال قبلاً اضافه شده است.",
-        'no_channels_configured': "هیچ کانالی برای عضویت پیکربندی نشده است.",
-        'channel_list_prompt': "لیست کانال‌های فعلی برای عضویت اجباری:",
-        'btn_remove_channel': "حذف ❌",
-        'channel_removed': "✅ کانال '{channel_id}' با موفقیت حذف شد.",
-        'channel_not_found': "❗️ کانال مورد نظر یافت نشد.",
-        'invalid_channel_id': "آیدی/لینک کانال نامعتبر است. لطفاً @username یا آیدی عددی (مانند -1001234567890) را ارسال کنید.",
-        'bot_not_admin_in_channel': "ربات ادمین کانال '{channel_id}' نیست یا مجوزهای کافی برای بررسی عضویت را ندارد. لطفاً ربات را به عنوان ادمین با مجوز 'بررسی وضعیت اعضا' در کانال اضافه کنید."
-    },
-    'en': {
-        # English messages go here
-    }
-}
-
-# --- 4. توابع کمکی ---
-
-def get_message(context, key, **kwargs):
-    lang = context.user_data.get('language', 'fa')
-    message_template = MESSAGES.get(lang, MESSAGES['fa']).get(key, MESSAGES['fa'].get(key, "Message key not found"))
-    return message_template.format(**kwargs)
-
-def parse_time_to_ms(time_str):
-    match = re.match(r'^(\d{2})\.(\d{2})$', time_str)
-    if not match: raise ValueError("Invalid time format")
-    minutes, seconds = int(match.group(1)), int(match.group(2))
-    if seconds >= 60: raise ValueError("Seconds must be between 00 and 59")
-    return (minutes * 60 + seconds) * 1000
-
-async def check_user_membership(update: Update, context):
-    user_id = update.effective_user.id
-    if not REQUIRED_CHANNELS: return True
-    for channel_id in REQUIRED_CHANNELS:
-        try:
-            chat_member = await context.bot.get_chat_member(chat_id=channel_id, user_id=user_id)
-            if chat_member.status not in ['member', 'administrator', 'creator']: return False
-        except Exception as e:
-            print(f"خطا در بررسی عضویت کانال {channel_id}: {e}", file=sys.stderr)
-            return False
-    return True
-
-async def show_membership_required_message(update: Update, context):
-    keyboard = []
-    if not REQUIRED_CHANNELS: return await show_main_menu(update, context)
-    for channel_id in REQUIRED_CHANNELS:
-        try:
-            chat = await context.bot.get_chat(chat_id=channel_id)
-            url = chat.invite_link or (f"https://t.me/{chat.username}" if chat.username else None)
-            if url: keyboard.append([InlineKeyboardButton(f"{get_message(context, 'btn_join_channel')} {chat.title or channel_id}", url=url)])
-        except Exception as e:
-            print(f"ناتوان در دریافت اطلاعات کانال {channel_id}: {e}", file=sys.stderr)
-    keyboard.append([InlineKeyboardButton(get_message(context, 'btn_check_membership'), callback_data='check_membership')])
-    reply_markup = InlineKeyboardMarkup(keyboard)
-    message_sender = update.callback_query.edit_message_text if update.callback_query else update.effective_message.reply_text
-    await message_sender(get_message(context, 'membership_required'), reply_markup=reply_markup)
-    return WAITING_FOR_MEMBERSHIP
-
-async def process_feature_or_check_membership(update: Update, context, feature_func, *args, **kwargs):
-    if update.effective_user.id == ADMIN_ID or not REQUIRED_CHANNELS:
-        return await feature_func(update, context, *args, **kwargs)
-    is_member = await check_user_membership(update, context)
-    if is_member:
-        context.user_data['is_member'] = True
-        return await feature_func(update, context, *args, **kwargs)
-    else:
-        context.user_data['is_member'] = False
-        return await show_membership_required_message(update, context)
-
-# --- 5. توابع Handler (مدیریت دستورات و پیام‌ها) ---
-
-async def start(update: Update, context):
-    keyboard = [[InlineKeyboardButton("فارسی 🇮🇷", callback_data='set_lang_fa')], [InlineKeyboardButton("English 🇬🇧", callback_data='set_lang_en')]]
-    reply_markup = InlineKeyboardMarkup(keyboard)
-    await update.message.reply_text("زبان مورد نظر خود را انتخاب کنید:\nChoose your preferred language:", reply_markup=reply_markup)
-    return LANGUAGE_SELECTION
-
-async def set_language(update: Update, context):
-    query = update.callback_query
-    await query.answer()
-    context.user_data['language'] = query.data.replace('set_lang_', '')
-    await query.edit_message_text(text=get_message(context, 'start_welcome'))
-    return await show_main_menu(update, context)
-
-async def show_main_menu(update: Update, context):
-    keyboard = [
-        [InlineKeyboardButton(get_message(context, 'btn_convert_format'), callback_data='select_convert_format')],
-        [InlineKeyboardButton(get_message(context, 'btn_cut_audio'), callback_data='select_cut_audio')],
-        [InlineKeyboardButton(get_message(context, 'btn_video_conversion'), callback_data='select_video_conversion')]
-    ]
-    reply_markup = InlineKeyboardMarkup(keyboard)
-    message_sender = update.callback_query.edit_message_text if update.callback_query else update.message.reply_text
-    await message_sender(text=get_message(context, 'main_menu_prompt'), reply_markup=reply_markup)
-    return MAIN_MENU
-
-async def change_format_selected(update: Update, context):
-    query = update.callback_query
-    await query.answer()
-    await query.edit_message_text(text=get_message(context, 'convert_mode_active'))
-    return CONVERT_AUDIO
-
-async def cut_audio_selected(update: Update, context):
-    query = update.callback_query
-    await query.answer()
-    await query.edit_message_text(text=get_message(context, 'cut_mode_active_file'))
-    context.user_data.pop('audio_for_cut_path', None)
-    return CUT_AUDIO_FILE
-
-async def video_conversion_selected(update: Update, context):
-    query = update.callback_query
-    await query.answer()
-    await query.edit_message_text(text=get_message(context, 'video_conversion_mode_active'))
-    return VIDEO_CONVERSION_MODE
-
-async def handle_audio(update: Update, context):
-    async def _perform_conversion(update, context):
-        file_id = update.message.audio.file_id
-        processing_message = await update.message.reply_text(get_message(context, 'processing_start'))
-        download_path = os.path.join(DOWNLOAD_DIR, f"in_{file_id}.mp3")
-        output_ogg_path = os.path.join(OUTPUT_DIR, f"out_{file_id}.ogg")
-        try:
-            new_file = await context.bot.get_file(file_id)
-            await new_file.download_to_drive(download_path)
-            await processing_message.edit_text(get_message(context, 'file_received'))
-            audio = AudioSegment.from_file(download_path)
-            audio.export(output_ogg_path, format="ogg", codec="libopus", parameters=["-b:a", "32k"])
-            await processing_message.edit_text(get_message(context, 'conversion_done'))
-            with open(output_ogg_path, 'rb') as f:
-                await update.message.reply_voice(f)
-            await processing_message.delete()
-        except Exception as e:
-            await processing_message.edit_text(get_message(context, 'error_mp3_to_voice') + str(e))
-        finally:
-            if os.path.exists(download_path): os.remove(download_path)
-            if os.path.exists(output_ogg_path): os.remove(output_ogg_path)
-        return CONVERT_AUDIO
-    return await process_feature_or_check_membership(update, context, _perform_conversion)
-
-async def handle_voice(update: Update, context):
-    async def _perform_conversion(update, context):
-        file_id = update.message.voice.file_id
-        processing_message = await update.message.reply_text(get_message(context, 'processing_start'))
-        download_path = os.path.join(DOWNLOAD_DIR, f"in_{file_id}.ogg")
-        output_mp3_path = os.path.join(OUTPUT_DIR, f"@{BOT_USERNAME}_{file_id}.mp3")
-        try:
-            new_file = await context.bot.get_file(file_id)
-            await new_file.download_to_drive(download_path)
-            await processing_message.edit_text(get_message(context, 'file_received'))
-            audio = AudioSegment.from_file(download_path, format="ogg")
-            audio.export(output_mp3_path, format="mp3", tags={'album': BOT_USERNAME, 'artist': BOT_USERNAME})
-            await processing_message.edit_text(get_message(context, 'conversion_done'))
-            with open(output_mp3_path, 'rb') as f:
-                await update.message.reply_audio(f, caption=get_message(context, 'voice_to_mp3_caption'))
-            await processing_message.delete()
-        except Exception as e:
-            await processing_message.edit_text(get_message(context, 'error_voice_to_mp3') + str(e))
-        finally:
-            if os.path.exists(download_path): os.remove(download_path)
-            if os.path.exists(output_mp3_path): os.remove(output_mp3_path)
-        return CONVERT_AUDIO
-    return await process_feature_or_check_membership(update, context, _perform_conversion)
+# --- تنظیمات اولیه ---
 
-async def handle_cut_audio_file(update: Update, context):
-    async def _perform_file_receive(update, context):
-        audio_file = update.message.audio or update.message.voice
-        file_id = audio_file.file_id
-        ext = 'mp3' if update.message.audio else 'ogg'
-        download_path = os.path.join(DOWNLOAD_DIR, f"cut_in_{file_id}.{ext}")
-        try:
-            new_file = await context.bot.get_file(file_id)
-            await new_file.download_to_drive(download_path)
-            context.user_data['audio_for_cut_path'] = download_path
-            context.user_data['audio_for_cut_type'] = ext
-            await update.message.reply_text(get_message(context, 'cut_mode_active_range'))
-            return CUT_AUDIO_RANGE
-        except Exception as e:
-            await update.message.reply_text(get_message(context, 'general_error'))
-            return CUT_AUDIO_FILE
-    return await process_feature_or_check_membership(update, context, _perform_file_receive)
-
-async def handle_cut_audio_range(update: Update, context):
-    async def _perform_cut(update, context):
-        time_range_str = update.message.text
-        audio_path = context.user_data.get('audio_for_cut_path')
-        audio_type = context.user_data.get('audio_for_cut_type')
-        if not audio_path or not os.path.exists(audio_path):
-            await update.message.reply_text(get_message(context, 'no_audio_for_cut'))
-            return CUT_AUDIO_FILE
-        processing_message = await update.message.reply_text(get_message(context, 'cut_processing'))
-        output_cut_path = os.path.join(OUTPUT_DIR, f"cut_out_{os.path.basename(audio_path)}.mp3")
-        try:
-            start_time_str, end_time_str = time_range_str.split('-')
-            start_ms = parse_time_to_ms(start_time_str.strip())
-            end_ms = parse_time_to_ms(end_time_str.strip())
-            if start_ms >= end_ms:
-                await processing_message.edit_text(get_message(context, 'invalid_time_range'))
-                return CUT_AUDIO_RANGE
-            audio = AudioSegment.from_file(audio_path, format=audio_type)
-            cut_audio = audio[start_ms:end_ms]
-            cut_audio.export(output_cut_path, format="mp3")
-            await processing_message.edit_text(get_message(context, 'audio_cut_success'))
-            with open(output_cut_path, 'rb') as f:
-                await update.message.reply_audio(f, caption=f"برش از {start_time_str} تا {end_time_str}")
-            await processing_message.delete()
-            return await show_main_menu(update, context)
-        except ValueError:
-            await processing_message.edit_text(get_message(context, 'invalid_time_format'))
-            return CUT_AUDIO_RANGE
-        except Exception as e:
-            await processing_message.edit_text(get_message(context, 'general_error'))
-            return await show_main_menu(update, context)
-        finally:
-            if os.path.exists(audio_path): os.remove(audio_path)
-            if os.path.exists(output_cut_path): os.remove(output_cut_path)
-            context.user_data.pop('audio_for_cut_path', None)
-            context.user_data.pop('audio_for_cut_type', None)
-    return await process_feature_or_check_membership(update, context, _perform_cut)
-
-async def handle_video_conversion(update: Update, context):
-    async def _perform_video_conversion(update, context):
-        is_video_note = bool(update.message.video_note)
-        file_to_process = update.message.video_note if is_video_note else update.message.video
-        file_id = file_to_process.file_id
-        download_path = os.path.join(DOWNLOAD_DIR, f"vid_in_{file_id}.mp4")
-        output_path = os.path.join(OUTPUT_DIR, f"vid_out_{file_id}.mp4")
-        processing_message = await update.message.reply_text(get_message(context, 'processing_start'))
-        try:
-            new_file = await context.bot.get_file(file_id)
-            await new_file.download_to_drive(download_path)
-            await processing_message.edit_text(get_message(context, 'file_received_video'))
-            if is_video_note:
-                await processing_message.edit_text(get_message(context, 'converting_video_note_to_video'))
-                ffmpeg_command = ['ffmpeg', '-y', '-i', download_path, '-c:v', 'libx264', '-crf', '23', '-preset', 'medium', '-c:a', 'aac', '-b:a', '128k', '-movflags', '+faststart', output_path]
-            else:
-                await processing_message.edit_text(get_message(context, 'converting_video_to_video_note'))
-                ffmpeg_command = ['ffmpeg', '-y', '-i', download_path, '-vf', 'crop=min(iw\,ih):min(iw\,ih),scale=640:640,setsar=1', '-an', output_path]
-            subprocess.run(ffmpeg_command, check=True, capture_output=True, text=True)
-            await processing_message.edit_text(get_message(context, 'conversion_done_video'))
-            with open(output_path, 'rb') as f:
-                if is_video_note:
-                    await update.message.reply_video(f, caption=get_message(context, 'video_note_to_video_caption'))
-                else:
-                    await update.message.reply_video_note(f)
-            await processing_message.delete()
-        except subprocess.CalledProcessError as e:
-            await processing_message.edit_text(get_message(context, 'error_video_conversion') + f"FFmpeg Error: {e.stderr}")
-        except Exception as e:
-            await processing_message.edit_text(get_message(context, 'error_video_conversion') + str(e))
-        finally:
-            if os.path.exists(download_path): os.remove(download_path)
-            if os.path.exists(output_path): os.remove(output_path)
-        return VIDEO_CONVERSION_MODE
-    return await process_feature_or_check_membership(update, context, _perform_video_conversion)
-
-async def check_membership_callback(update: Update, context):
-    query = update.callback_query
-    await query.answer()
-    is_member = await check_user_membership(update, context)
-    if is_member:
-        context.user_data['is_member'] = True
-        await query.edit_message_text(get_message(context, 'membership_success'))
-        return await show_main_menu(update, context)
-    else:
-        await query.answer(get_message(context, 'membership_failed'), show_alert=True)
-        return WAITING_FOR_MEMBERSHIP
-
-async def admin_link_command(update: Update, context):
-    if update.effective_user.id != ADMIN_ID:
-        await update.message.reply_text(get_message(context, 'not_admin'))
-        return ConversationHandler.END
-    keyboard = [
-        [InlineKeyboardButton(get_message(context, 'btn_add_channel'), callback_data='admin_add_channel')],
-        [InlineKeyboardButton(get_message(context, 'btn_list_channels'), callback_data='admin_list_channels')]
-    ]
-    await update.message.reply_text(get_message(context, 'admin_menu_prompt'), reply_markup=InlineKeyboardMarkup(keyboard))
-    return ADMIN_MENU
-
-async def admin_add_channel_prompt(update: Update, context):
-    query = update.callback_query
-    await query.answer()
-    await query.edit_message_text(get_message(context, 'send_channel_link'))
-    return ADD_CHANNEL
-
-async def admin_handle_add_channel(update: Update, context):
-    channel_input = update.message.text.strip()
-    if not (channel_input.startswith('@') or channel_input.startswith('-100')):
-        await update.message.reply_text(get_message(context, 'invalid_channel_id'))
-        return ADD_CHANNEL
-    try:
-        await context.bot.get_chat(channel_input)
-        if channel_input not in REQUIRED_CHANNELS:
-            REQUIRED_CHANNELS.append(channel_input)
-            save_required_channels(REQUIRED_CHANNELS)
-            await update.message.reply_text(get_message(context, 'channel_added', channel_id=channel_input))
-        else:
-            await update.message.reply_text(get_message(context, 'channel_already_exists'))
-    except Exception as e:
-        await update.message.reply_text(get_message(context, 'bot_not_admin_in_channel', channel_id=channel_input) + f"\nError: {e}")
-    return await admin_link_command(update, context)
-
-async def admin_list_channels(update: Update, context):
-    query = update.callback_query
-    await query.answer()
-    if not REQUIRED_CHANNELS:
-        await query.edit_message_text(get_message(context, 'no_channels_configured'))
-        return ADMIN_MENU
-    keyboard = []
-    for channel_id in REQUIRED_CHANNELS:
-        keyboard.append([InlineKeyboardButton(f"{get_message(context, 'btn_remove_channel')} {channel_id}", callback_data=f'remove_channel_{channel_id}')])
-    await query.edit_message_text(get_message(context, 'channel_list_prompt'), reply_markup=InlineKeyboardMarkup(keyboard))
-    return LIST_REMOVE_CHANNELS
-
-async def admin_handle_remove_channel(update: Update, context):
-    query = update.callback_query
-    await query.answer()
-    channel_id_to_remove = query.data.replace('remove_channel_', '')
-    if channel_id_to_remove in REQUIRED_CHANNELS:
-        REQUIRED_CHANNELS.remove(channel_id_to_remove)
-        save_required_channels(REQUIRED_CHANNELS)
-        await query.edit_message_text(get_message(context, 'channel_removed', channel_id=channel_id_to_remove))
-    else:
-        await query.edit_message_text(get_message(context, 'channel_not_found'))
-    return await admin_link_command(update, context)
-
-async def cancel(update: Update, context):
-    message = update.message or update.callback_query.message
-    await message.reply_text(get_message(context, 'cancel_message'))
-    context.user_data.clear()
-    return await show_main_menu(update, context)
-
-async def error_handler(update: object, context: object) -> None:
-    print(f"Update {update} caused error {context.error}", file=sys.stderr)
-
-
-# --- 6. بخش آماده‌سازی و مقداردهی اولیه ربات ---
-
-def setup_telegram_app():
-    print("در حال ساختن اپلیکیشن تلگرام...")
-    application = Application.builder().token(TOKEN).build()
+app = Flask(__name__)
+telegram_app = setup_telegram_app()
+APP_INITIALIZED = False
 
-    conv_handler = ConversationHandler(
-        entry_points=[CommandHandler("start", start), CommandHandler("link", admin_link_command)],
-        states={
-            LANGUAGE_SELECTION: [CallbackQueryHandler(set_language, pattern='^set_lang_')],
-            MAIN_MENU: [
-                CallbackQueryHandler(change_format_selected, pattern='^select_convert_format$'),
-                CallbackQueryHandler(cut_audio_selected, pattern='^select_cut_audio$'),
-                CallbackQueryHandler(video_conversion_selected, pattern='^select_video_conversion$'),
-            ],
-            CONVERT_AUDIO: [
-                MessageHandler(filters.AUDIO & ~filters.COMMAND, handle_audio),
-                MessageHandler(filters.VOICE & ~filters.COMMAND, handle_voice),
-            ],
-            CUT_AUDIO_FILE: [MessageHandler((filters.AUDIO | filters.VOICE) & ~filters.COMMAND, handle_cut_audio_file)],
-            CUT_AUDIO_RANGE: [MessageHandler(filters.TEXT & ~filters.COMMAND, handle_cut_audio_range)],
-            VIDEO_CONVERSION_MODE: [MessageHandler((filters.VIDEO | filters.VIDEO_NOTE) & ~filters.COMMAND, handle_video_conversion)],
-            WAITING_FOR_MEMBERSHIP: [CallbackQueryHandler(check_membership_callback, pattern='^check_membership$')],
-            ADMIN_MENU: [
-                CallbackQueryHandler(admin_add_channel_prompt, pattern='^admin_add_channel$'),
-                CallbackQueryHandler(admin_list_channels, pattern='^admin_list_channels$'),
-            ],
-            ADD_CHANNEL: [MessageHandler(filters.TEXT & ~filters.COMMAND, admin_handle_add_channel)],
-            LIST_REMOVE_CHANNELS: [CallbackQueryHandler(admin_handle_remove_channel, pattern='^remove_channel_')],
-        },
-        fallbacks=[CommandHandler("cancel", cancel), CommandHandler("start", start)],
-        allow_reentry=True,
-        per_user=True,
-        per_chat=True
-    )
+# مقداردهی اولیه بلافاصله پس از ساخت اپلیکیشن تلگرام
+async def init_bot():
+    global APP_INITIALIZED
+    if not APP_INITIALIZED:
+        print("در حال مقداردهی اولیه ربات تلگرام...")
+        await telegram_app.initialize()
+        APP_INITIALIZED = True
+        print("ربات با موفقیت مقداردهی اولیه شد.")
 
-    application.add_handler(conv_handler)
-    application.add_error_handler(error_handler)
-    
-    print("اپلیکیشن تلگرام با موفقیت ساخته شد.")
-    return application
+# اجرای مقداردهی اولیه در زمان شروع اسکریپت
+asyncio.get_event_loop().run_until_complete(init_bot())
 
-# --- 7. بخش مربوط به Flask و Webhook (نسخه نهایی) ---
-
-app = Flask(__name__)
-telegram_app = setup_telegram_app()
-APP_INITIALIZED = False # پرچم برای پیگیری وضعیت آماده بودن ربات
+# --- مسیردهی Flask ---
 
 @app.route("/")
 def index():
@@ -496,45 +34,29 @@ def index():
 
 @app.route("/webhook", methods=["POST"])
 async def webhook():
-    """این مسیر آپدیت‌ها را از تلگرام دریافت کرده و پردازش می‌کند."""
-    global APP_INITIALIZED
     try:
-        # **راه‌حل نهایی**: قبل از پردازش، مطمئن می‌شویم که ربات آماده است.
-        if not APP_INITIALIZED:
-            print("مقداردهی اولیه ربات در اولین درخواست وبهوک...")
-            await telegram_app.initialize()
-            APP_INITIALIZED = True
-            print("ربات با موفقیت مقداردهی اولیه شد.")
-
         update = Update.de_json(request.get_json(force=True), telegram_app.bot)
         await telegram_app.process_update(update)
         return "ok"
     except Exception as e:
-        print(f"Error in webhook: {e}", file=sys.stderr)
+        print(f"Error in webhook: {e}")
         return "error", 500
 
 @app.route("/set_webhook", methods=["GET"])
 async def set_webhook_route():
-    global APP_INITIALIZED
     webhook_url = os.getenv("WEBHOOK_URL")
     if not webhook_url:
         return jsonify({"status": "error", "message": "WEBHOOK_URL environment variable not set."}), 500
-    
+
     if not webhook_url.endswith("/webhook"):
         webhook_url = f"{webhook_url.rstrip('/')}/webhook"
 
     try:
-        # اطمینان از اینکه ربات قبل از تنظیم وبهوک مقداردهی اولیه شده
-        if not APP_INITIALIZED:
-            await telegram_app.initialize()
-            APP_INITIALIZED = True
-
         await telegram_app.bot.set_webhook(url=webhook_url, allowed_updates=Update.ALL_TYPES)
         return jsonify({"status": "success", "message": f"Webhook set to {webhook_url}"})
     except Exception as e:
-        print(f"Failed to set webhook: {e}", file=sys.stderr)
+        print(f"Failed to set webhook: {e}")
         return jsonify({"status": "error", "message": f"Failed to set webhook: {e}"}), 500
 
 if __name__ == "__main__":
-    # این بخش فقط برای اجرای محلی (local) با استفاده از وب‌سرور خود Flask است.
     app.run(host='0.0.0.0', port=int(os.environ.get("PORT", 7860)))