Update main.py

main.py

@@ -21,39 +21,46 @@ app = Flask(__name__)
 
 @app.route('/')
 def home():
-    return "ربات یکپارچه آلفا (نسخه پرو + دانلود فایل ۱۰۰٪ تضمینی + چت چندرسانه‌ای + پرامپت‌نویس هوشمند + ساخت پادکست) روشن است! 🚀"
+    return "ربات یکپارچه آلفا (نسخه پرو + دانلود فایل ۱۰۰٪ تضمینی + چت چندرسانه‌ای + پرامپت‌نویس + ساخت پادکست + ویرایش عکس) روشن است! 🚀"
 
 def run_flask():
     app.run(host="0.0.0.0", port=7860)
 
 
-# --- ساختار کیبورد پایین صفحه (Chat Keypad) ---
+# --- ساختار کیبورد آپدیت شده (اضافه شدن ویرایش تصویر و حساب کاربری) ---
 MAIN_KEYPAD_DICT = {
     "rows":[
-        # ردیف اول (فقط ۱ دکمه)
+        # ردیف اول
         {
             "buttons":[
+                {"id": "account_btn", "type": "Simple", "button_text": "حساب کاربری 👤"},
                 {"id": "chat_btn", "type": "Simple", "button_text": "چت با هوش مصنوعی 🤖"}
             ]
         },
-        # ردیف دوم (۲ دکمه)
+        # ردیف دوم
         {
             "buttons":[
-                {"id": "img_btn", "type": "Simple", "button_text": "ساخت تصاویر🎨"},
-                {"id": "tts_btn", "type": "Simple", "button_text": "تبدیل متن به صدا🗣️"}
+                {"id": "edit_img_btn", "type": "Simple", "button_text": "ویرایش تصاویر 🪄"},
+                {"id": "img_btn", "type": "Simple", "button_text": "ساخت تصاویر🎨"}
             ]
         },
-        # ردیف سوم (۲ دکمه)
+        # ردیف سوم
         {
             "buttons":[
                 {"id": "podcast_btn", "type": "Simple", "button_text": "ساخت پادکست 🎙️"},
-                {"id": "file_btn", "type": "Simple", "button_text": "تحلیل فایل 📁"}
+                {"id": "tts_btn", "type": "Simple", "button_text": "تبدیل متن به صدا🗣️"}
             ]
         },
-        # ردیف چهارم (۲ دکمه)
+        # ردیف چهارم
         {
             "buttons":[
                 {"id": "stt_btn", "type": "Simple", "button_text": "فایل صوتی به متن 📝"},
+                {"id": "file_btn", "type": "Simple", "button_text": "تحلیل فایل 📁"}
+            ]
+        },
+        # ردیف پنجم
+        {
+            "buttons":[
                 {"id": "cancel_btn", "type": "Simple", "button_text": "برگشت♻️"}
             ]
         }
@@ -62,7 +69,7 @@ MAIN_KEYPAD_DICT = {
 }
 
 
-# --- تابع ارسال منحصراً برای کیبورد پایین صفحه (اصلاح شده برای جلوگیری از اسپم) ---
+# --- تابع ارسال منحصراً برای کیبورد پایین صفحه ---
 async def send_with_keyboard(client, chat_id, text, use_keyboard=True):
     try:
         if not use_keyboard:
@@ -77,7 +84,6 @@ async def send_with_keyboard(client, chat_id, text, use_keyboard=True):
         return await client._make_request("sendMessage", payload)
     except Exception:
         try:
-            # اگر حالت کیبورد دار در سطح API خطا داد، فقط یکبار به صورت ساده پیام ارسال شود
             return await client.send_message(chat_id, text)
         except Exception:
             return None
@@ -85,7 +91,7 @@ async def send_with_keyboard(client, chat_id, text, use_keyboard=True):
 
 # --- 🚨 تابع هوشمند دانلود فایل 🚨 ---
 async def helper_download_file(client, msg_obj):
-    errors =[]
+    errors = []
     
     file_id = None
     file_obj = None
@@ -139,10 +145,10 @@ async def helper_download_file(client, msg_obj):
 
 # --- تنظیمات کلیدها ---
 GEMINI_KEYS_STR = os.environ.get("GEMINI_API_KEYS", "")
-GEMINI_KEYS =[k.strip() for k in GEMINI_KEYS_STR.split(",") if k.strip()]
+GEMINI_KEYS = [k.strip() for k in GEMINI_KEYS_STR.split(",") if k.strip()]
 
 HF_TOKENS_STR = os.environ.get("HF_TOKENS", "")
-HF_TOKENS =[k.strip() for k in HF_TOKENS_STR.split(",") if k.strip()]
+HF_TOKENS = [k.strip() for k in HF_TOKENS_STR.split(",") if k.strip()]
 
 bot_token = os.environ.get("RUBIKA_AUTH", "").strip()
 
@@ -150,7 +156,7 @@ bot_token = os.environ.get("RUBIKA_AUTH", "").strip()
 # --- 🚨 تابع اختصاصی آپلود فایل به روبیکا 🚨 ---
 async def helper_upload_file(client, chat_id, file_name, file_type="Image", caption=""):
     abs_path = os.path.abspath(file_name)
-    error_logs =[]
+    error_logs = []
     
     api_file_type = "Image" if file_type in ["photo", "Image", "image"] else "Voice" if file_type in ["voice", "Voice", "audio"] else "File"
     
@@ -211,7 +217,7 @@ async def helper_upload_file(client, chat_id, file_name, file_type="Image", capt
     return "\n".join(error_logs)
 
 
-WORKER_URLS =[
+WORKER_URLS = [
     "https://hamed744-ttspro.hf.space/generate",
     "https://hamed744-ttspro2.hf.space/generate",
     "https://hamed744-ttspro3.hf.space/generate",
@@ -237,21 +243,68 @@ SPEAKERS = {
 }
 
 user_states = {}
-
-# --- متغیرهای کَش برای جلوگیری از پیام تکراری و اسپم شدن ---
 processed_message_ids = set()
 user_last_request_time = {}
 
 
-# --- ۱. پردازش چت متنی و چندرسانه‌ای ---
-async def process_gemini(client, chat_id, prompt, file_bytes=None, file_name=None):
-    if not GEMINI_KEYS:
-        await send_with_keyboard(client, chat_id, "❌ کلیدهای API جیمینای تنظیم نشده‌اند.", False)
+# --- بخش جدید: پردازش ویرایش عکس با FLUX.2-dev ---
+async def process_image_edit(client, chat_id, image_bytes, prompt):
+    if not HF_TOKENS:
+        await send_with_keyboard(client, chat_id, "❌ توکن‌های هاگینگ فیس تنظیم نشده‌اند.", False)
         return
 
+    proc_msg = await send_with_keyboard(client, chat_id, "🪄 در حال پردازش و اعمال جادوی FLUX.2 روی عکس شما...\n(این فرآیند ممکن است کمی طول بکشد)", False)
+    
+    keys_to_try = HF_TOKENS.copy()
+    random.shuffle(keys_to_try)
+    generated_image = None
+    last_error_log = "سرور پاسخ نداد."
+    
+    for token in keys_to_try:
+        try:
+            hf_client = AsyncInferenceClient(provider="fal-ai", api_key=token)
+            # استفاده از متد image_to_image با ارسال دیتای بایت عکس و پرامپت متنی کاربر
+            generated_image = await hf_client.image_to_image(
+                image_bytes,
+                prompt=prompt,
+                model="black-forest-labs/FLUX.2-dev"
+            )
+            break 
+        except Exception as e:
+            last_error_log = str(e)
+            continue
+            
+    try:
+        if proc_msg:
+            msg_id = getattr(proc_msg, 'message_id', None)
+            if isinstance(proc_msg, dict): msg_id = proc_msg.get('message_update', {}).get('message_id') or proc_msg.get('message_id')
+            if msg_id: await client.delete_messages(chat_id, [msg_id])
+    except Exception: pass
+
+    if not generated_image:
+        await send_with_keyboard(client, chat_id, f"❌ متأسفانه ویرایش عکس انجام نشد.\n\n⚠️ علت:\n{last_error_log[:200]}", True)
+        return
+
+    try:
+        file_name = f"edited_flux_{random.randint(1000, 999999)}.jpg"
+        rgb_im = generated_image.convert('RGB')
+        rgb_im.save(file_name, format="JPEG", quality=100)
+        await asyncio.sleep(1)
+        caption_text = f"🪄 ویرایش عکس با هوش مصنوعی Flux.2 انجام شد!\n\n✨ تغییرات خواسته شده: {prompt}"
+        upload_result = await helper_upload_file(client, chat_id, file_name, "Image", caption_text)
+        if upload_result is not True:
+            await send_with_keyboard(client, chat_id, f"❌ عکس ساخته شد اما خطا در ارسال به روبیکا رخ داد:\n`{str(upload_result)[:800]}`", True)
+        if os.path.exists(file_name): os.remove(file_name)
+    except Exception as e:
+        await send_with_keyboard(client, chat_id, f"❌ خطا در ذخیره عکس ویرایش شده:\n{str(e)[:150]}", True)
+
+
+# --- پردازش‌های قبلی (چت، عکس، صدا، پادکست، استخراج متن و تحلیل) بدون تغییر ---
+async def process_gemini(client, chat_id, prompt, file_bytes=None, file_name=None):
+    if not GEMINI_KEYS: return await send_with_keyboard(client, chat_id, "❌ کلیدهای API جیمینای تنظیم نشده‌اند.", False)
     proc_msg = await send_with_keyboard(client, chat_id, "🧠 در حال پردازش...", False)
-    history = user_states[chat_id].get("history",[])
-    new_parts =[]
+    history = user_states[chat_id].get("history", [])
+    new_parts = []
     
     if prompt: new_parts.append({"text": prompt})
     elif file_bytes: new_parts.append({"text": "لطفاً این فایل را به دقت بررسی کن."})
@@ -259,16 +312,7 @@ async def process_gemini(client, chat_id, prompt, file_bytes=None, file_name=Non
     if file_bytes and file_name:
         base64_data = base64.b64encode(file_bytes).decode('utf-8')
         mime_type, _ = mimetypes.guess_type(file_name)
-        if not mime_type:
-            if file_name.endswith(('.jpg', '.jpeg')): mime_type = "image/jpeg"
-            elif file_name.endswith('.png'): mime_type = "image/png"
-            elif file_name.endswith('.pdf'): mime_type = "application/pdf"
-            elif file_name.endswith('.mp4'): mime_type = "video/mp4"
-            elif file_name.endswith('.mp3'): mime_type = "audio/mp3"
-            elif file_name.endswith(('.ogg', '.oga')): mime_type = "audio/ogg"
-            elif file_name.endswith('.wav'): mime_type = "audio/wav"
-            else: mime_type = "image/jpeg"
-            
+        if not mime_type: mime_type = "image/jpeg"
         new_parts.append({"inlineData": {"mimeType": mime_type, "data": base64_data}})
 
     if history and history[-1]["role"] == "user": history[-1]["parts"].extend(new_parts)
@@ -300,22 +344,21 @@ async def process_gemini(client, chat_id, prompt, file_bytes=None, file_name=Non
         if proc_msg:
             msg_id = getattr(proc_msg, 'message_id', None)
             if isinstance(proc_msg, dict): msg_id = proc_msg.get('message_update', {}).get('message_id') or proc_msg.get('message_id')
-            if msg_id: await client.delete_messages(chat_id,[msg_id])
+            if msg_id: await client.delete_messages(chat_id, [msg_id])
     except Exception: pass
 
     if not final_answer:
         if history and history[-1]["role"] == "user": history.pop()
-        await send_with_keyboard(client, chat_id, "❌ متأسفانه پاسخی دریافت نشد. (شاید سایز فایل بیش از حد مجاز بوده است)", False)
+        await send_with_keyboard(client, chat_id, "❌ متأسفانه پاسخی دریافت نشد.", False)
         return
 
-    history.append({"role": "model", "parts":[{"text": final_answer}]})
+    history.append({"role": "model", "parts": [{"text": final_answer}]})
     user_states[chat_id]["history"] = history
 
     try:
         max_len = 1000 
-        chunks =[]
+        chunks = []
         temp_text = final_answer
-        
         while len(temp_text) > max_len:
             split_idx = temp_text.rfind('\n', 0, max_len)
             if split_idx == -1: split_idx = temp_text.rfind(' ', 0, max_len)
@@ -334,29 +377,18 @@ async def process_gemini(client, chat_id, prompt, file_bytes=None, file_name=Non
     except Exception:
         await send_with_keyboard(client, chat_id, "❌ خطایی در ارسال پیام رخ داد.", False)
 
-
-# --- ۲. پردازش ساخت عکس ---
 async def process_image(client, chat_id, prompt):
-    if not HF_TOKENS:
-        await send_with_keyboard(client, chat_id, "❌ توکن‌های هاگینگ فیس تنظیم نشده‌اند.", False)
-        return
-
+    if not HF_TOKENS: return await send_with_keyboard(client, chat_id, "❌ توکن‌ها تنظیم نشده‌اند.", False)
     proc_msg = await send_with_keyboard(client, chat_id, "✨ در حال ترجمه و بهینه‌سازی پرامپت شما توسط جیمینای...\n(تبدیل به پرامپت حرفه‌ای)", False)
     enhanced_prompt = prompt 
     if GEMINI_KEYS:
         keys_to_try_gemini = GEMINI_KEYS.copy()
         random.shuffle(keys_to_try_gemini)
-        gemini_sys_prompt = (
-            "You are an expert AI image generation prompt engineer. "
-            "Translate the following user input to English, and enhance it with high-quality, "
-            "highly detailed, 4k resolution, cinematic lighting, and visually striking descriptive keywords. "
-            "Return ONLY the final English prompt string."
-            f"\nUser input: {prompt}"
-        )
+        gemini_sys_prompt = f"You are an expert AI image generation prompt engineer. Translate the following user input to English, and enhance it with high-quality, highly detailed, 4k resolution, cinematic lighting keywords. Return ONLY the final English prompt string.\nUser input: {prompt}"
         async with aiohttp.ClientSession() as session:
             for key in keys_to_try_gemini:
                 url = f"https://generativelanguage.googleapis.com/v1beta/models/gemini-2.5-flash:generateContent?key={key}"
-                payload = {"contents":[{"parts":[{"text": gemini_sys_prompt}]}], "generationConfig": {"temperature": 0.7}}
+                payload = {"contents": [{"parts": [{"text": gemini_sys_prompt}]}], "generationConfig": {"temperature": 0.7}}
                 try:
                     async with session.post(url, json=payload, timeout=20) as response:
                         if response.status == 200:
@@ -369,7 +401,7 @@ async def process_image(client, chat_id, prompt):
         if proc_msg:
             msg_id = getattr(proc_msg, 'message_id', None)
             if isinstance(proc_msg, dict): msg_id = proc_msg.get('message_update', {}).get('message_id') or proc_msg.get('message_id')
-            if msg_id: await client.delete_messages(chat_id,[msg_id])
+            if msg_id: await client.delete_messages(chat_id, [msg_id])
     except Exception: pass
     
     short_preview = enhanced_prompt[:150] + "..." if len(enhanced_prompt) > 150 else enhanced_prompt
@@ -393,12 +425,10 @@ async def process_image(client, chat_id, prompt):
         if proc_msg:
             msg_id = getattr(proc_msg, 'message_id', None)
             if isinstance(proc_msg, dict): msg_id = proc_msg.get('message_update', {}).get('message_id') or proc_msg.get('message_id')
-            if msg_id: await client.delete_messages(chat_id,[msg_id])
+            if msg_id: await client.delete_messages(chat_id, [msg_id])
     except Exception: pass
 
-    if not generated_image:
-        await send_with_keyboard(client, chat_id, f"❌ عکس ساخته نشد.\n\n⚠️ خطا:\n{last_error_log[:200]}", True)
-        return
+    if not generated_image: return await send_with_keyboard(client, chat_id, f"❌ عکس ساخته نشد.\n\n⚠️ خطا:\n{last_error_log[:200]}", True)
 
     try:
         file_name = f"image_{random.randint(1000, 999999)}.jpg"
@@ -407,14 +437,10 @@ async def process_image(client, chat_id, prompt):
         await asyncio.sleep(1)
         caption_text = f"🎨 تصویر شما با پرامپت هوشمند آماده شد!\n\n✨ ایده اولیه: {prompt}"
         upload_result = await helper_upload_file(client, chat_id, file_name, "Image", caption_text)
-        if upload_result is not True:
-            await send_with_keyboard(client, chat_id, f"❌ خطا در آپلود روبیکا:\n`{str(upload_result)[:800]}`", True)
+        if upload_result is not True: await send_with_keyboard(client, chat_id, f"❌ خطا در آپلود:\n`{str(upload_result)[:800]}`", True)
         if os.path.exists(file_name): os.remove(file_name)
-    except Exception as e:
-        await send_with_keyboard(client, chat_id, f"❌ خطا در ذخیره عکس:\n{str(e)[:150]}", True)
+    except Exception as e: await send_with_keyboard(client, chat_id, f"❌ خطا در ذخیره عکس:\n{str(e)[:150]}", True)
 
-
-# --- ۳. پردازش ساخت صدا ---
 async def process_tts(client, chat_id, user_text, speaker_id, speaker_name):
     try:
         proc_msg = await send_with_keyboard(client, chat_id, f"⏳ در حال ساخت صدا با «{speaker_name}»...\n(لطفاً صبور باشید)", False)
@@ -442,7 +468,7 @@ async def process_tts(client, chat_id, user_text, speaker_id, speaker_name):
             if proc_msg:
                 msg_id = getattr(proc_msg, 'message_id', None)
                 if isinstance(proc_msg, dict): msg_id = proc_msg.get('message_update', {}).get('message_id') or proc_msg.get('message_id')
-                if msg_id: await client.delete_messages(chat_id,[msg_id])
+                if msg_id: await client.delete_messages(chat_id, [msg_id])
         except Exception: pass
 
         if audio_bytes:
@@ -455,57 +481,40 @@ async def process_tts(client, chat_id, user_text, speaker_id, speaker_name):
         else: await send_with_keyboard(client, chat_id, f"❌ سرورها درگیر هستند.\nدلیل: {last_error}", True)
     except Exception: traceback.print_exc()
 
-# --- بخش جدید: پردازش و ساخت پادکست (اتصال به سرور HF) ---
 async def process_podcast(client, chat_id, prompt):
-    proc_msg = await send_with_keyboard(client, chat_id, "📻 در حال بررسی موضوع و نگارش سناریوی پادکست توسط هوش مصنوعی...\n(لطفاً صبور باشید)", False)
-    
-    # آماده‌سازی دیتای گویندگان پیش‌فرض (همانند مرورگر)
-    available_speakers =[]
+    proc_msg = await send_with_keyboard(client, chat_id, "📻 در حال بررسی موضوع و نگارش سناریوی پادکست...\n(لطفاً صبور باشید)", False)
+    available_speakers = []
     for num_key, (spk_name, spk_id) in SPEAKERS.items():
         gender = "male" if "مرد" in spk_name else "female"
         available_speakers.append({"id": spk_id, "name": spk_name.split(' (')[0], "gender": gender})
 
     url_create = "https://ezmarynoori-podgen.hf.space/api/create-full-podcast"
-    payload_create = {
-        "prompt": prompt,
-        "available_speakers": available_speakers
-    }
+    payload_create = {"prompt": prompt, "available_speakers": available_speakers}
     
     async with aiohttp.ClientSession() as session:
         try:
-            # 1. درخواست نگارش سناریو به اسپیس ساخت پادکست
             async with session.post(url_create, json=payload_create, timeout=60) as resp:
-                if resp.status != 202:
-                    await send_with_keyboard(client, chat_id, f"❌ خطا در سرور پادکست: وضعیت {resp.status}", True)
-                    return
-                data = await resp.json()
-                task_id = data.get("task_id")
-        except Exception as e:
-            await send_with_keyboard(client, chat_id, f"❌ خطا در اتصال به سرور پادکست:\n{str(e)}", True)
-            return
+                if resp.status != 202: return await send_with_keyboard(client, chat_id, f"❌ خطا: وضعیت {resp.status}", True)
+                task_id = (await resp.json()).get("task_id")
+        except Exception as e: return await send_with_keyboard(client, chat_id, f"❌ خطا اتصال:\n{str(e)}", True)
 
-        # 2. بررسی وضعیت (Polling) تا زمان آماده شدن سناریو
         url_status = f"https://ezmarynoori-podgen.hf.space/api/podcast-status/{task_id}"
         script_data = None
-        for _ in range(40): # تا 120 ثانیه صبر میکند
+        for _ in range(40):
             await asyncio.sleep(3)
             try:
                 async with session.get(url_status) as resp:
                     if resp.status == 200:
                         status_data = await resp.json()
                         if status_data.get("status") == "completed":
-                            script_data = status_data.get("data", {}).get("script",[])
+                            script_data = status_data.get("data", {}).get("script", [])
                             break
                         elif status_data.get("status") == "failed":
-                            await send_with_keyboard(client, chat_id, "❌ متأسفانه هوش مصنوعی نتوانست برای این موضوع سناریو بنویسد.", True)
-                            return
+                            return await send_with_keyboard(client, chat_id, "❌ هوش مصنوعی نتوانست سناریو بنویسد.", True)
             except Exception: pass
             
-        if not script_data:
-            await send_with_keyboard(client, chat_id, "❌ زمان انتظار برای نوشتن سناریو به پایان رسید.", True)
-            return
+        if not script_data: return await send_with_keyboard(client, chat_id, "❌ پایان زمان انتظار برای نوشتن سناریو.", True)
 
-        # آپدیت پیام به کاربر
         try:
             if proc_msg:
                 msg_id = getattr(proc_msg, 'message_id', None)
@@ -513,42 +522,29 @@ async def process_podcast(client, chat_id, prompt):
                 if msg_id: await client.delete_messages(chat_id, [msg_id])
         except: pass
         
-        proc_msg = await send_with_keyboard(client, chat_id, f"🎙 سناریو نوشته شد! در حال ریکورد و میکس دیالوگ‌های گویندگان (شامل {len(script_data)} نوبت صحبت)...\nاین مرحله زمان‌بر است...", False)
+        proc_msg = await send_with_keyboard(client, chat_id, f"🎙 سناریو نوشته شد! در حال میکس (شامل {len(script_data)} نوبت صحبت)...\nزمان‌بر است...", False)
 
-        # 3. دریافت فایل صوتی هر دیالوگ و میکس آن‌ها
         combined_audio = AudioSegment.empty()
         url_generate = "https://ezmarynoori-podgen.hf.space/api/generate"
         
         for index, turn in enumerate(script_data):
-            payload_gen = {
-                "text": turn["dialogue"],
-                "speaker": turn["speaker_id"],
-                "temperature": 0.9
-            }
-            
+            payload_gen = {"text": turn["dialogue"], "speaker": turn["speaker_id"], "temperature": 0.9}
             chunk_audio_bytes = None
-            for attempt in range(3): # ۳ بار تلاش برای هر بخش
+            for attempt in range(3):
                 try:
                     async with session.post(url_generate, json=payload_gen, timeout=120) as resp:
                         if resp.status == 200:
                             chunk_audio_bytes = await resp.read()
                             break
-                except Exception:
-                    await asyncio.sleep(2)
+                except Exception: await asyncio.sleep(2)
             
-            if not chunk_audio_bytes:
-                await send_with_keyboard(client, chat_id, f"❌ خطا در تولید صدای بخش {index+1} از سرور. عملیات متوقف شد.", True)
-                return
+            if not chunk_audio_bytes: return await send_with_keyboard(client, chat_id, f"❌ خطا در بخش {index+1}", True)
                 
             try:
-                # تبدیل بایت به AudioSegment با استفاده از pydub
                 audio_segment = AudioSegment.from_file(io.BytesIO(chunk_audio_bytes))
                 combined_audio += audio_segment
-            except Exception as e:
-                await send_with_keyboard(client, chat_id, f"❌ خطا در پردازش صدا (آیا pydub و ffmpeg نصب است؟):\n{str(e)}", True)
-                return
+            except Exception as e: return await send_with_keyboard(client, chat_id, f"❌ خطا میکس:\n{str(e)}", True)
 
-        # 4. خروجی گرفتن و ارسال به کاربر
         file_name = f"final_podcast_{random.randint(1000, 999999)}.mp3"
         combined_audio.export(file_name, format="mp3")
         
@@ -559,21 +555,14 @@ async def process_podcast(client, chat_id, prompt):
                 if msg_id: await client.delete_messages(chat_id, [msg_id])
         except: pass
 
-        caption = f"🎧 پادکست شما با موفقیت میکس و ساخته شد!\n\n💡 موضوع شما: {prompt}"
+        caption = f"🎧 پادکست شما میکس شد!\n\n💡 موضوع: {prompt}"
         upload_result = await helper_upload_file(client, chat_id, file_name, "Voice", caption)
-        
-        if upload_result is not True:
-            err_msg = str(upload_result)[:800]
-            await send_with_keyboard(client, chat_id, f"❌ پادکست با موفقیت در سرور ساخته شد اما روبیکا خطای آپلود داد.\n\n`{err_msg}`", True)
-        
-        if os.path.exists(file_name):
-            os.remove(file_name)
-
+        if upload_result is not True: await send_with_keyboard(client, chat_id, f"❌ خطای آپلود روبیکا.\n\n`{str(upload_result)[:800]}`", True)
+        if os.path.exists(file_name): os.remove(file_name)
 
-# --- ۴. پردازش تبدیل فایل صوتی/تصویری به متن ---
 async def process_stt(client, chat_id, audio_bytes, file_name):
-    if not GEMINI_KEYS: return await send_with_keyboard(client, chat_id, "❌ کلیدهای جیمینای تنظیم نشده‌اند.", False)
-    proc_msg = await send_with_keyboard(client, chat_id, "📝 در حال گوش دادن و پیاده‌سازی متن...", False)
+    if not GEMINI_KEYS: return await send_with_keyboard(client, chat_id, "❌ کلید تنظیم نشده", False)
+    proc_msg = await send_with_keyboard(client, chat_id, "📝 در حال پیاده‌سازی متن...", False)
     base64_data = base64.b64encode(audio_bytes).decode('utf-8')
     mime_type, _ = mimetypes.guess_type(file_name)
     if not mime_type: mime_type = "audio/ogg" 
@@ -581,12 +570,12 @@ async def process_stt(client, chat_id, audio_bytes, file_name):
     keys_to_try = GEMINI_KEYS.copy()
     random.shuffle(keys_to_try)
     transcribed_text = None
-    prompt = "لطفاً این فایل صوتی/تصویری را با دقت کامل گوش بده و صحبت‌های داخل آن را کلمه به کلمه به متن تبدیل کن. هیچ توضیح اضافه‌ای نده."
+    prompt = "این فایل صوتی/تصویری را دقیق گوش بده و صحبت‌ها را کلمه به کلمه به متن تبدیل کن. هیچ توضیح اضافه‌ای نده."
     
     async with aiohttp.ClientSession() as session:
         for key in keys_to_try:
             url = f"https://generativelanguage.googleapis.com/v1beta/models/gemini-2.5-flash:generateContent?key={key}"
-            payload = {"contents":[{"parts":[{"text": prompt}, {"inlineData": {"mimeType": mime_type, "data": base64_data}}]}], "generationConfig": {"temperature": 0.2}}
+            payload = {"contents": [{"parts": [{"text": prompt}, {"inlineData": {"mimeType": mime_type, "data": base64_data}}]}], "generationConfig": {"temperature": 0.2}}
             try:
                 async with session.post(url, json=payload, timeout=60) as response:
                     if response.status == 200:
@@ -599,16 +588,14 @@ async def process_stt(client, chat_id, audio_bytes, file_name):
         if proc_msg:
             msg_id = getattr(proc_msg, 'message_id', None)
             if isinstance(proc_msg, dict): msg_id = proc_msg.get('message_update', {}).get('message_id') or proc_msg.get('message_id')
-            if msg_id: await client.delete_messages(chat_id,[msg_id])
+            if msg_id: await client.delete_messages(chat_id, [msg_id])
     except Exception: pass
 
-    if transcribed_text: await send_with_keyboard(client, chat_id, f"📝 **متن استخراج شده:**\n\n{transcribed_text}", True)
-    else: await send_with_keyboard(client, chat_id, f"❌ تبدیل فایل به متن ناموفق بود.", True)
+    if transcribed_text: await send_with_keyboard(client, chat_id, f"📝 **متن:**\n\n{transcribed_text}", True)
+    else: await send_with_keyboard(client, chat_id, f"❌ تبدیل ناموفق", True)
 
-
-# --- ۵. پردازش تحلیل فایل مستقل ---
 async def process_file_analysis(client, chat_id, file_bytes, file_name, prompt):
-    if not GEMINI_KEYS: return await send_with_keyboard(client, chat_id, "❌ کلید جیمینای تنظیم نیست.", False)
+    if not GEMINI_KEYS: return await send_with_keyboard(client, chat_id, "❌ کلید تنظیم نیست.", False)
     proc_msg = await send_with_keyboard(client, chat_id, "👁️ در حال تحلیل فایل...", False)
     base64_data = base64.b64encode(file_bytes).decode('utf-8')
     mime_type, _ = mimetypes.guess_type(file_name)
@@ -621,7 +608,7 @@ async def process_file_analysis(client, chat_id, file_bytes, file_name, prompt):
     async with aiohttp.ClientSession() as session:
         for key in keys_to_try:
             url = f"https://generativelanguage.googleapis.com/v1beta/models/gemini-2.5-flash:generateContent?key={key}"
-            payload = {"contents":[{"parts":[{"text": prompt}, {"inlineData": {"mimeType": mime_type, "data": base64_data}}]}], "generationConfig": {"temperature": 0.6}}
+            payload = {"contents": [{"parts": [{"text": prompt}, {"inlineData": {"mimeType": mime_type, "data": base64_data}}]}], "generationConfig": {"temperature": 0.6}}
             try:
                 async with session.post(url, json=payload, timeout=45) as response:
                     if response.status == 200:
@@ -634,10 +621,10 @@ async def process_file_analysis(client, chat_id, file_bytes, file_name, prompt):
         if proc_msg:
             msg_id = getattr(proc_msg, 'message_id', None)
             if isinstance(proc_msg, dict): msg_id = proc_msg.get('message_update', {}).get('message_id') or proc_msg.get('message_id')
-            if msg_id: await client.delete_messages(chat_id,[msg_id])
+            if msg_id: await client.delete_messages(chat_id, [msg_id])
     except Exception: pass
 
-    if final_answer: await send_with_keyboard(client, chat_id, f"💡 **نتیجه تحلیل:**\n\n{final_answer}", True)
+    if final_answer: await send_with_keyboard(client, chat_id, f"💡 **تحلیل:**\n\n{final_answer}", True)
     else: await send_with_keyboard(client, chat_id, "❌ پاسخی دریافت نشد.", True)
 
 
@@ -651,39 +638,26 @@ else:
     async def main_handler(client, update):
         try:
             current_time = time.time()
-            
-            # --- 🛡 سیستم ضد اسپم و حذف پیام‌های تکراری 🛡 ---
             msg_obj = getattr(update, "message", None) or getattr(update, "new_message", None)
             msg_id = getattr(update, "message_id", None)
             if not msg_id and msg_obj:
-                if isinstance(msg_obj, dict):
-                    msg_id = msg_obj.get("message_id")
-                else:
-                    msg_id = getattr(msg_obj, "message_id", None)
+                msg_id = msg_obj.get("message_id") if isinstance(msg_obj, dict) else getattr(msg_obj, "message_id", None)
             
-            # جلوگیری از پردازش یک آیدی پیام برای دفعات متعدد
             if msg_id:
-                if msg_id in processed_message_ids:
-                    return
+                if msg_id in processed_message_ids: return
                 processed_message_ids.add(msg_id)
-                # پاکسازی کش برای جلوگیری از پر شدن رم
-                if len(processed_message_ids) > 5000:
-                    processed_message_ids.clear()
+                if len(processed_message_ids) > 5000: processed_message_ids.clear()
             
             chat_id = getattr(update, "chat_id", None) or getattr(update, "author_guid", None) or getattr(update, "object_guid", None)
             if not chat_id: return
 
-            # سیستم Rate Limit برای کاربران (جلوگیری از پاسخ به پیام‌های جمع شده در بک‌لاگ ربات)
             last_req_time = user_last_request_time.get(chat_id, 0)
-            if current_time - last_req_time < 1.0: # اگر کاربر در کمتر از ۱ ثانیه پیام جدید داده، آن را نادیده بگیر
-                return
+            if current_time - last_req_time < 1.0: return
             user_last_request_time[chat_id] = current_time
-            # ----------------------------------------------------
 
             user_text = getattr(update, "text", "") or getattr(msg_obj, "text", "")
             user_text_str = str(user_text).strip() if user_text else ""
             
-            # تشخیص فایل
             is_file = False
             file_name = "unknown_file.jpg"
             
@@ -692,7 +666,7 @@ else:
                     file_attr = getattr(msg_obj, attr, None)
                     if file_attr:
                         is_file = True
-                        if hasattr(file_attr, 'file_name'): file_name = file_attr.file_name
+                        file_name = getattr(file_attr, 'file_name', file_name)
                         break
                 
                 if not is_file and hasattr(msg_obj, 'to_dict'):
@@ -701,62 +675,87 @@ else:
                         if attr in msg_dict:
                             is_file = True
                             file_attr = msg_dict.get(attr, {})
-                            if isinstance(file_attr, dict) and 'file_name' in file_attr: file_name = file_attr['file_name']
+                            file_name = file_attr.get('file_name', file_name) if isinstance(file_attr, dict) else file_name
                             break
 
             if chat_id not in user_states:
-                user_states[chat_id] = {"mode": None, "text": "", "history":[], "file_bytes": None, "file_name": None}
+                user_states[chat_id] = {"mode": None, "text": "", "history": [], "file_bytes": None, "file_name": None}
 
             if user_text_str in ["/start", "سلام", "لغو", "/cancel", "❌ لغو", "برگشت♻️"]:
-                user_states[chat_id] = {"mode": None, "text": "", "history":[], "file_bytes": None, "file_name": None}
-                await send_with_keyboard(client, chat_id, "سلام! به ربات هوشمند آلفا خوش آمدید 🤖\n\nلطفاً برای شروع، از کیبورد پایین یکی از بخش‌ها را انتخاب کنید:", True)
+                user_states[chat_id] = {"mode": None, "text": "", "history": [], "file_bytes": None, "file_name": None}
+                await send_with_keyboard(client, chat_id, "سلام! به ربات هوشمند آلفا خوش آمدید 🤖\n\nلطفاً برای شروع، یکی از بخش‌های زیر را انتخاب کنید:", True)
+                return
+
+            # --- بخش جدید: حساب کاربری ---
+            if user_text_str in ["/account", "حساب کاربری 👤"]:
+                # متن پیشنهادی برای محدودیت‌های نسخه رایگان
+                account_profile = f"""👤 **اطلاعات حساب کاربری**
+
+🔹 **نام:** حامد نوری
+🔹 **شناسه یکتا:** `{chat_id}`
+🔹 **وضعیت اشتراک:** 🥉 نسخه رایگان (آزمایشی)
+
+📊 **سهمیه روزانه شما در نسخه رایگان:**
+- 💬 چت هوشمند: ۳۰ پیام
+- 🎨 ساخت عکس: ۵ تصویر
+- 🪄 ویرایش عکس پیشرفته: ۳ تصویر
+- 🎙 ساخت پادکست: ۱ برنامه
+- 🗣 تبدیل متن به صدا: ۵ فایل
+
+*نکته: در آینده با ارتقا به نسخه آلفا پرو می‌توانید تمام این محدودیت‌ها را بردارید.* 🚀"""
+                await send_with_keyboard(client, chat_id, account_profile, True)
                 return
 
             if user_text_str in ["/chat", "💬 چت", "چت با هوش مصنوعی 🤖"]:
-                user_states[chat_id] = {"mode": "chat", "text": "", "history":[]}
-                await send_with_keyboard(client, chat_id, "💬 شما وارد بخش **چت با هوش مصنوعی** شدید.\n\nهر سوالی دارید بفرستید تا جواب بدم:\n(برای خروج دکمه «برگشت♻️» را بزنید)", True)
+                user_states[chat_id] = {"mode": "chat", "text": "", "history": []}
+                await send_with_keyboard(client, chat_id, "💬 وارد بخش **چت هوشمند** شدید.\nسوالی بپرسید تا جواب بدهم:", True)
                 return
 
             if user_text_str in ["/image", "🎨 عکس", "ساخت تصاویر🎨"]:
-                user_states[chat_id] = {"mode": "image_waiting_for_text", "text": "", "history":[]}
-                await send_with_keyboard(client, chat_id, "🎨 شما وارد بخش **ساخت عکس پیشرفته** شدید.\n\nمتن خود را ارسال کنید:\n(برای خروج دکمه «برگشت♻️» را بزنید)", True)
+                user_states[chat_id] = {"mode": "image_waiting_for_text", "text": "", "history": []}
+                await send_with_keyboard(client, chat_id, "🎨 وارد بخش **ساخت عکس** شدید.\nمتن خود را بفرستید:", True)
+                return
+
+            # --- بخش جدید: ویرایش عکس ---
+            if user_text_str in ["/edit_image", "ویرایش تصاویر 🪄"]:
+                user_states[chat_id] = {"mode": "image_edit_waiting_for_image", "text": "", "history": [], "file_bytes": None, "file_name": None}
+                await send_with_keyboard(client, chat_id, "🪄 به بخش **ویرایش عکس (Flux.2)** خوش آمدید.\n\nلطفاً ابتدا عکسی که می‌خواهید ویرایش کنید را بفرستید:", True)
                 return
 
             if user_text_str in ["/tts", "🎙️ صدا", "تبدیل متن به صدا🗣️"]:
-                user_states[chat_id] = {"mode": "tts_waiting_for_text", "text": "", "history":[]}
-                await send_with_keyboard(client, chat_id, "🎙️ شما وارد بخش **تبدیل متن به صدا** شدید.\n\nلطفاً متنی که می‌خواهید به صدا تبدیل شود را ارسال کنید:\n(برای خروج دکمه «برگشت♻️» را بزنید)", True)
+                user_states[chat_id] = {"mode": "tts_waiting_for_text", "text": "", "history": []}
+                await send_with_keyboard(client, chat_id, "🎙️ وارد بخش **تبدیل متن به صدا** شدید.\nمتن خود را بفرستید:", True)
                 return
             
             if user_text_str in ["/podcast", "📻 پادکست", "ساخت پادکست 🎙️"]:
-                user_states[chat_id] = {"mode": "podcast_waiting_for_topic", "text": "", "history":[]}
-                await send_with_keyboard(client, chat_id, "📻 شما وارد بخش **ساخت پادکست** شدید.\n\nلطفاً موضوع پادکست خود را بفرستید.\nمثال: درباره تاریخچه پیدایش قهوه با ۳ گوینده یک پادکست جذاب بساز\n\n(برای خروج دکمه «برگشت♻️» را بزنید)", True)
+                user_states[chat_id] = {"mode": "podcast_waiting_for_topic", "text": "", "history": []}
+                await send_with_keyboard(client, chat_id, "📻 وارد بخش **ساخت پادکست** شدید.\nموضوع پادکست را بفرستید:", True)
                 return
 
             if user_text_str in ["/file", "تحلیل فایل 📁"]:
-                user_states[chat_id] = {"mode": "file_waiting_for_file", "text": "", "history":[], "file_bytes": None, "file_name": None}
-                await send_with_keyboard(client, chat_id, "📁 شما وارد بخش **تحلیل فایل اختصاصی** شدید.\n\nلطفاً فایل خود را ارسال کنید:\n(برای خروج دکمه «برگشت���️» را بزنید)", True)
+                user_states[chat_id] = {"mode": "file_waiting_for_file", "text": "", "history": [], "file_bytes": None, "file_name": None}
+                await send_with_keyboard(client, chat_id, "📁 وارد بخش **تحلیل فایل** شدید.\nفایل خود را ارسال کنید:", True)
                 return
 
             if user_text_str in ["/stt", "فایل صوتی به متن 📝"]:
-                user_states[chat_id] = {"mode": "stt_waiting_for_audio", "text": "", "history":[]}
-                await send_with_keyboard(client, chat_id, "📝 شما وارد بخش **تبدیل صدا به متن** شدید.\n\nلطفاً فایل خود (ویس، آهنگ، ویدیو و...) را ارسال کنید:\n(برای خروج دکمه «برگشت♻️» را بزنید)", True)
+                user_states[chat_id] = {"mode": "stt_waiting_for_audio", "text": "", "history": []}
+                await send_with_keyboard(client, chat_id, "📝 وارد بخش **تبدیل صدا به متن** شدید.\nفایل خود را بفرستید:", True)
                 return
 
             current_mode = user_states[chat_id].get("mode")
 
             if current_mode is None:
                 if is_file: pass 
-                elif user_text_str: await send_with_keyboard(client, chat_id, "⚠️ لطفاً ابتدا از کیبورد پایین، بخش مورد نظرتان را انتخاب کنید:", True)
+                elif user_text_str: await send_with_keyboard(client, chat_id, "⚠️ لطفاً ابتدا یک بخش را از کیبورد پایین انتخاب کنید:", True)
                 return
 
-            # --- مسیریابی ---
             elif current_mode == "chat":
                 if is_file:
                     await send_with_keyboard(client, chat_id, "📥 در حال دانلود فایل...", False)
                     try:
                         file_bytes = await helper_download_file(client, msg_obj)
                         asyncio.create_task(process_gemini(client, chat_id, user_text_str, file_bytes=file_bytes, file_name=file_name))
-                    except Exception as dl_err: await send_with_keyboard(client, chat_id, f"❌ خطا در دریافت فایل!\n{str(dl_err)}", False)
+                    except Exception as dl_err: await send_with_keyboard(client, chat_id, f"❌ خطا!\n{str(dl_err)}", False)
                 elif user_text_str: asyncio.create_task(process_gemini(client, chat_id, user_text_str))
                 return
 
@@ -764,65 +763,68 @@ else:
                 if user_text_str: asyncio.create_task(process_image(client, chat_id, user_text_str))
                 return
 
+            # --- مسیریابی بخش ویرایش تصویر ---
+            elif current_mode == "image_edit_waiting_for_image":
+                if not is_file: return await send_with_keyboard(client, chat_id, "⚠️ لطفاً ابتدا یک عکس ارسال کنید.", False)
+                await send_with_keyboard(client, chat_id, "📥 در حال دانلود عکس...", False)
+                try:
+                    file_bytes = await helper_download_file(client, msg_obj)
+                    user_states[chat_id]["file_bytes"] = file_bytes
+                    user_states[chat_id]["mode"] = "image_edit_waiting_for_prompt"
+                    await send_with_keyboard(client, chat_id, "✅ عکس با موفقیت دریافت شد.\n\nحالا دستور خود را به صورت متنی تایپ کنید.\nمثال: یک کلاه قرمز روی سر این گربه بگذار.", False)
+                except Exception as dl_err: await send_with_keyboard(client, chat_id, f"❌ خطا در دریافت فایل!\n{str(dl_err)}", False)
+                return
+
+            elif current_mode == "image_edit_waiting_for_prompt":
+                if user_text_str:
+                    saved_bytes = user_states[chat_id].get("file_bytes")
+                    user_states[chat_id]["mode"] = None 
+                    user_states[chat_id]["file_bytes"] = None
+                    asyncio.create_task(process_image_edit(client, chat_id, saved_bytes, user_text_str))
+                else: await send_with_keyboard(client, chat_id, "⚠️ لطفاً درخواست خود را متنی بنویسید.", False)
+                return
+
             elif current_mode == "tts_waiting_for_text":
                 if user_text_str:
-                    if len(user_text_str) > 2500:
-                        await send_with_keyboard(client, chat_id, "⚠️ لطفاً متنی کوتاه‌تر از 2500 کاراکتر بفرستید.", False)
-                        return
+                    if len(user_text_str) > 2500: return await send_with_keyboard(client, chat_id, "⚠️ متن خیلی طولانی است.", False)
                     user_states[chat_id]["text"] = user_text_str
                     user_states[chat_id]["mode"] = "tts_waiting_for_speaker"
-                    speakers_menu = """✅ متن شما ذخیره شد.
-لطفاً **شماره** گوینده مورد نظر خود را بفرستید:
-1. شهاب | 2. آوا | 3. نوید
-4. آرمان | 5. مهسا | 6. دانا
-7. سامان | 8. آرش | 9. شبنم
-10. سحر | 11. مریم | 12. بهرام
-13. نیکان| 14. فرناز | 15. سارا
-16. مانی | 17. آرتین | 18. دلنواز
-19. روژان | 20. امید | 21. بردیا
-22. ترانه | 23. نیکو | 24. هستی
-25. کامیار| 26. کیانوش| 27. پویا
-28. مهتاب | 29. سام | 30. لیدا"""
-                    await send_with_keyboard(client, chat_id, speakers_menu, False)
+                    await send_with_keyboard(client, chat_id, "✅ متن ذخیره شد.\nلطفاً **شماره** گوینده (بین 1 تا 30) را بفرستید:", False)
                 return
 
             elif current_mode == "tts_waiting_for_speaker":
                 if user_text_str.isdigit() and user_text_str in SPEAKERS:
-                    speaker_name, speaker_id = SPEAKERS[user_text_str]
-                    saved_text = user_states[chat_id]["text"]
+                    spk_name, spk_id = SPEAKERS[user_text_str]
+                    txt = user_states[chat_id]["text"]
                     user_states[chat_id]["mode"] = "tts_waiting_for_text"
-                    user_states[chat_id]["text"] = ""
-                    asyncio.create_task(process_tts(client, chat_id, saved_text, speaker_id, speaker_name))
-                else:
-                    await send_with_keyboard(client, chat_id, "❌ شماره نامعتبر است! لطفاً فقط یک عدد بین 1 تا 30 بفرستید.", False)
+                    asyncio.create_task(process_tts(client, chat_id, txt, spk_id, spk_name))
+                else: await send_with_keyboard(client, chat_id, "❌ شماره نامعتبر!", False)
                 return
 
             elif current_mode == "podcast_waiting_for_topic":
-                if user_text_str:
-                    asyncio.create_task(process_podcast(client, chat_id, user_text_str))
-                else:
-                    await send_with_keyboard(client, chat_id, "⚠️ لطفاً موضوع پادکست خود را به صورت متنی بفرستید.", False)
+                if user_text_str: asyncio.create_task(process_podcast(client, chat_id, user_text_str))
+                else: await send_with_keyboard(client, chat_id, "⚠️ لطفاً موضوع را متنی بفرستید.", False)
                 return
 
             elif current_mode == "stt_waiting_for_audio":
-                if not is_file: return await send_with_keyboard(client, chat_id, "⚠️ لطفاً یک فایل ارسال کنید.", False)
-                await send_with_keyboard(client, chat_id, "📥 در حال دانلود فایل...", False)
+                if not is_file: return await send_with_keyboard(client, chat_id, "⚠️ لطفاً فایل بفرستید.", False)
+                await send_with_keyboard(client, chat_id, "📥 در حال دانلود...", False)
                 try:
                     audio_bytes = await helper_download_file(client, msg_obj)
                     asyncio.create_task(process_stt(client, chat_id, audio_bytes, file_name))
-                except Exception as dl_err: await send_with_keyboard(client, chat_id, f"❌ خطا در دانلود فایل!\n{str(dl_err)}", False)
+                except Exception as dl_err: await send_with_keyboard(client, chat_id, f"❌ خطا!\n{str(dl_err)}", False)
                 return
 
             elif current_mode == "file_waiting_for_file":
-                if not is_file: return await send_with_keyboard(client, chat_id, "⚠️ لطفاً ابتدا یک فایل ارسال کنید.", False)
-                await send_with_keyboard(client, chat_id, "📥 در حال دریافت فایل...", False)
+                if not is_file: return await send_with_keyboard(client, chat_id, "⚠️ فایل بفرستید.", False)
+                await send_with_keyboard(client, chat_id, "📥 دریافت فایل...", False)
                 try:
                     file_bytes = await helper_download_file(client, msg_obj)
                     user_states[chat_id]["file_bytes"] = file_bytes
                     user_states[chat_id]["file_name"] = file_name 
                     user_states[chat_id]["mode"] = "file_waiting_for_prompt"
-                    await send_with_keyboard(client, chat_id, "✅ فایل با موفقیت دریافت شد.\n\nحالا لطفاً متنی بگویید **چگونه تحلیل شود؟**", False)
-                except Exception as dl_err: await send_with_keyboard(client, chat_id, f"❌ خطا در دریافت فایل!\n{str(dl_err)}", False)
+                    await send_with_keyboard(client, chat_id, "✅ دریافت شد.\nچگونه تحلیل شود؟", False)
+                except Exception as dl_err: await send_with_keyboard(client, chat_id, f"❌ خطا!\n{str(dl_err)}", False)
                 return
 
             elif current_mode == "file_waiting_for_prompt":
@@ -830,17 +832,14 @@ else:
                     saved_bytes = user_states[chat_id].get("file_bytes")
                     saved_name = user_states[chat_id].get("file_name", "file.jpeg")
                     user_states[chat_id]["mode"] = "file_waiting_for_file" 
-                    user_states[chat_id]["file_bytes"] = None
-                    user_states[chat_id]["file_name"] = None
                     asyncio.create_task(process_file_analysis(client, chat_id, saved_bytes, saved_name, user_text_str))
-                else: await send_with_keyboard(client, chat_id, "⚠️ لطفاً درخواست خود را متنی بنویسید.", False)
+                else: await send_with_keyboard(client, chat_id, "⚠️ متن بفرستید.", False)
                 return
 
         except Exception: traceback.print_exc()
 
 if __name__ == "__main__":
     threading.Thread(target=run_flask, daemon=True).start()
-    
     if bot_token:
-        print("ربات یکپارچه آلفا روشن شد...")
+        print("ربات آلفا روشن شد...")
         bot.run()