Update app.py

app.py

@@ -293,20 +293,16 @@ async def send_to_specific_group(client, message):
 # ================= DATABASE PROGRESS-BASED CLONING =================
 async def save_progress(source_id, dest_id, msg_id):
     try:
-        # ডাটাবেজে আগে থেকে প্রোগ্রেস আছে কিনা চেক করা হচ্ছে
         res = await db_query(lambda: supabase.table('clone_progress').select('id').eq('source_id', source_id).eq('dest_id', dest_id).execute())
         if res.data:
-            # থাকলে সেটা আপডেট হবে
             await db_query(lambda: supabase.table('clone_progress').update({'last_copied_id': msg_id}).eq('id', res.data[0]['id']).execute())
         else:
-            # না থাকলে নতুন রো ইনসার্ট হবে
             await db_query(lambda: supabase.table('clone_progress').insert({'source_id': source_id, 'dest_id': dest_id, 'last_copied_id': msg_id}).execute())
     except Exception as e:
         print(f"Error saving progress: {e}")
 
 async def clone_videos_background(client, source_id, dest_id, status_msg):
     try:
-        # ডাটাবেজে আগের কোনো সেভড প্রোগ্রেস আছে কিনা দেখা হচ্ছে
         progress_res = await db_query(lambda: supabase.table('clone_progress').select('last_copied_id').eq('source_id', source_id).eq('dest_id', dest_id).execute())
         
         last_copied_id = None
@@ -316,14 +312,34 @@ async def clone_videos_background(client, source_id, dest_id, status_msg):
         else:
             await status_msg.edit_text(f"⏳ <b>Cloning started!</b>\nFetching video list from <code>{source_id}</code>...\n<i>This might take a few minutes if the group has many videos.</i>", parse_mode=enums.ParseMode.HTML)
         
+        # === Auto Reconnect & Retry loop for Video Scanning ===
         video_ids = []
-        async for msg in client.search_messages(source_id, filter=enums.MessagesFilter.VIDEO):
-            # যদি আগের প্রোগ্রেস থাকে, তবে আগের কপি করা ভিডিওর আইডি থেকে ছোট সব ভিডিও স্কিপ করা হবে
-            if last_copied_id and msg.id <= last_copied_id:
-                continue
-            video_ids.append(msg.id)
-            if len(video_ids) % 200 == 0:
-                await asyncio.sleep(0.1)
+        retries = 5
+        while retries > 0:
+            try:
+                # যদি বট ক্লায়েন্ট কোনো কারণে ডিসকানেক্ট হয়, রিকানেক্ট করবে
+                if not client.is_connected:
+                    try: await client.connect()
+                    except: pass
+
+                async for msg in client.search_messages(source_id, filter=enums.MessagesFilter.VIDEO):
+                    if last_copied_id and msg.id <= last_copied_id:
+                        continue
+                    video_ids.append(msg.id)
+                    if len(video_ids) % 200 == 0:
+                        await asyncio.sleep(0.1)
+                break # সফল হলে লুপ থেকে বের হবে
+            except Exception as e:
+                err_msg = str(e).lower()
+                # যদি ডিসকানেক্ট বা কানেকশন জনিত সমস্যা হয়
+                if "disconnect" in err_msg or "connection" in err_msg or "timeout" in err_msg or "reset" in err_msg:
+                    retries -= 1
+                    video_ids = [] # লিস্ট রিসেট করা হলো যাতে কোনো ভিডিও মিস না যায়
+                    await status_msg.edit_text(f"⚠️ <b>Network issue detected!</b>\nRetrying in 10 seconds... (Attempts left: {retries})\nError: <code>{e}</code>", parse_mode=enums.ParseMode.HTML)
+                    await asyncio.sleep(10)
+                else:
+                    raise e # অন্য কোনো পারমিশন বা বড় এরর হলে কাজ থামিয়ে দেবে
+        # =======================================================
         
         if not video_ids:
             if last_copied_id:
@@ -343,21 +359,35 @@ async def clone_videos_background(client, source_id, dest_id, status_msg):
         failed = 0
         
         for index, msg_id in enumerate(video_ids, 1):
-            try:
-                await client.copy_message(chat_id=dest_id, from_chat_id=source_id, message_id=msg_id)
-                success += 1
-                # সফলভাবে কপি হওয়ার সাথে সাথেই ডাটাবেজে প্রোগ্রেস সেভ
-                await save_progress(source_id, dest_id, msg_id)
-            except FloodWait as e:
-                await asyncio.sleep(e.value + 2)
+            copy_success = False
+            copy_retries = 3
+            
+            # === Video Sending Auto Reconnect & Retry ===
+            while copy_retries > 0:
                 try:
+                    if not client.is_connected:
+                        try: await client.connect()
+                        except: pass
+                        
                     await client.copy_message(chat_id=dest_id, from_chat_id=source_id, message_id=msg_id)
                     success += 1
                     await save_progress(source_id, dest_id, msg_id)
-                except Exception:
-                    failed += 1
-            except Exception:
+                    copy_success = True
+                    break # কপি সফল হলে রিট্রাই লুপ থেকে বের হবে
+                except FloodWait as e:
+                    # লিমিট এররে রিট্রাই কমানো হবে না, শুধু ওয়েট করবে
+                    await asyncio.sleep(e.value + 2)
+                except Exception as e:
+                    err_msg = str(e).lower()
+                    if "disconnect" in err_msg or "connection" in err_msg or "timeout" in err_msg or "reset" in err_msg:
+                        copy_retries -= 1
+                        await asyncio.sleep(5) # ৫ সেকেন্ড পর আবার চেষ্টা করবে
+                    else:
+                        break # অন্য কোনো এরর (যেমন: ভিডিও ডিলিট করা) হলে লুপ স্কিপ করবে
+            
+            if not copy_success:
                 failed += 1
+            # ============================================
             
             if index % 20 == 0 or index == total:
                 try:
@@ -498,6 +528,7 @@ async def handle_media_upload(client, message):
     original_file, watermarked_file, blurred_file = None, None, None
     clean_upload_file, telegram_file, embed_link = None, None, None
     
+    # === Progress Bar Function ===
     last_update_time = time.time()
     async def download_progress(current, total):
         nonlocal last_update_time
@@ -509,11 +540,13 @@ async def handle_media_upload(client, message):
                 last_update_time = now
             except Exception:
                 pass
+    # =============================
     
     try:
         original_file = await message.download(progress=download_progress)
         clean_upload_file = original_file 
         
+        # ১. ওয়াটারমার্ক (Watermark) করা - Balanced (Superfast + CRF 23)
         if media_type == "video" and not is_large_video:
             await status_msg.edit_text("⏳ Watermarking video... (HD + Superfast Processing)")
             watermarked_file = f"{original_file}_wm.mp4"
@@ -528,6 +561,7 @@ async def handle_media_upload(client, message):
             if process.returncode == 0 and os.path.exists(watermarked_file): 
                 clean_upload_file = watermarked_file
 
+        # ২. byse.sx সার্ভারে HD / Clean ভিডিও আপলোড করা
         if media_type == "video":
             await status_msg.edit_text("⏳ Uploading Clean HD video to byse.sx server...")
             api_endpoint = "https://api.byse.sx/upload/server"
@@ -555,6 +589,7 @@ async def handle_media_upload(client, message):
             await status_msg.delete()
             return  
 
+        # ৩. টেলিগ্রামে পাঠানোর জন্য ভিডিও ব্লার করা
         telegram_file = clean_upload_file
         if is_blur and not is_large_video:
             await status_msg.edit_text(f"⏳ Applying {blur_percent}% blur for Telegram broadcast...")
@@ -623,6 +658,7 @@ async def handle_media_upload(client, message):
             
         await status_msg.delete()
         
+        # ================= FloodWait Handler for Broadcast =================
         groups_res = await db_query(lambda: supabase.table('groups').select('group_id').execute())
         group_ids = [g['group_id'] for g in groups_res.data]
         success_count, fail_count = 0, 0