Update app.py

app.py

@@ -643,6 +643,91 @@ async def send_to_specific_group(client, message):
     except Exception as e:
         await status.edit_text(f"❌ <b>Failed to send!</b>\nError: {e}", parse_mode=enums.ParseMode.HTML)
 
+
+# ================= MASS CLONE FROM ALL GROUPS =================
+async def clone_all_background(client, dest_id, status_msg):
+    try:
+        groups_res = await db_query(lambda: supabase.table('groups').select('group_id').execute())
+        if not groups_res.data:
+            return await status_msg.edit_text("❌ <b>No groups found in database.</b>", parse_mode=enums.ParseMode.HTML)
+            
+        groups = [g['group_id'] for g in groups_res.data]
+        total_groups = len(groups)
+        
+        await status_msg.edit_text(f"✅ Found <b>{total_groups}</b> groups.\n🚀 Starting mass cloning from oldest videos...", parse_mode=enums.ParseMode.HTML)
+        
+        total_copied = 0
+        
+        for index, source_id in enumerate(groups, 1):
+            if source_id == dest_id or source_id == STORAGE_CHANNEL_ID or source_id == PREMIUM_CHANNEL_ID:
+                continue 
+                
+            try:
+                await status_msg.edit_text(f"⏳ <b>Cloning Group {index}/{total_groups}</b>\nID: <code>{source_id}</code>\nTotal Copied So Far: <b>{total_copied}</b>", parse_mode=enums.ParseMode.HTML)
+            except Exception: pass
+            
+            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 = progress_res.data[0]['last_copied_id'] if progress_res.data else None
+            
+            video_ids = []
+            retries = 3
+            while retries > 0:
+                try:
+                    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) % 100 == 0: await asyncio.sleep(0.1)
+                    break
+                except FloodWait as e:
+                    await asyncio.sleep(e.value + 1)
+                except Exception as e:
+                    err_msg = str(e).lower()
+                    if "disconnect" in err_msg or "connection" in err_msg or "timeout" in err_msg:
+                        retries -= 1
+                        video_ids = []
+                        await asyncio.sleep(5)
+                    else:
+                        break
+                        
+            if not video_ids:
+                continue
+                
+            video_ids.reverse() 
+            
+            for msg_id in video_ids:
+                copy_retries = 3
+                copy_success = False
+                while copy_retries > 0:
+                    try:
+                        await client.copy_message(chat_id=dest_id, from_chat_id=source_id, message_id=msg_id)
+                        total_copied += 1
+                        await save_progress(source_id, dest_id, msg_id)
+                        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:
+                            copy_retries -= 1
+                            await asyncio.sleep(3)
+                        else:
+                            break
+                await asyncio.sleep(2.5)
+                
+        await status_msg.edit_text(f"🎉 <b>Mass Cloning Completely Finished!</b>\n\nTotal Videos Copied from all groups: <b>{total_copied}</b>", parse_mode=enums.ParseMode.HTML)
+        
+    except Exception as e:
+        try: await status_msg.edit_text(f"❌ <b>Cloning Error:</b> {e}", parse_mode=enums.ParseMode.HTML)
+        except: pass
+
+@bot.on_message(filters.command("cloneall") & filters.private & filters.user(ADMIN_IDS))
+async def start_mass_cloning(client, message):
+    dest_id = -1003798479478 
+    status_msg = await message.reply(f"⏳ <b>Initializing mass cloning task to <code>{dest_id}</code>...</b>", parse_mode=enums.ParseMode.HTML)
+    asyncio.create_task(clone_all_background(client, dest_id, status_msg))
+
+
 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())
@@ -732,90 +817,6 @@ async def start_cloning(client, message):
     asyncio.create_task(clone_videos_background(client, source_id, dest_id, status_msg))
 
 
-# ================= MASS CLONE FROM ALL GROUPS =================
-async def clone_all_background(client, dest_id, status_msg):
-    try:
-        groups_res = await db_query(lambda: supabase.table('groups').select('group_id').execute())
-        if not groups_res.data:
-            return await status_msg.edit_text("❌ <b>No groups found in database.</b>", parse_mode=enums.ParseMode.HTML)
-            
-        groups = [g['group_id'] for g in groups_res.data]
-        total_groups = len(groups)
-        
-        await status_msg.edit_text(f"✅ Found <b>{total_groups}</b> groups.\n🚀 Starting mass cloning from oldest videos...", parse_mode=enums.ParseMode.HTML)
-        
-        total_copied = 0
-        
-        for index, source_id in enumerate(groups, 1):
-            if source_id == dest_id or source_id == STORAGE_CHANNEL_ID or source_id == PREMIUM_CHANNEL_ID:
-                continue 
-                
-            try:
-                await status_msg.edit_text(f"⏳ <b>Cloning Group {index}/{total_groups}</b>\nID: <code>{source_id}</code>\nTotal Copied So Far: <b>{total_copied}</b>", parse_mode=enums.ParseMode.HTML)
-            except Exception: pass
-            
-            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 = progress_res.data[0]['last_copied_id'] if progress_res.data else None
-            
-            video_ids = []
-            retries = 3
-            while retries > 0:
-                try:
-                    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) % 100 == 0: await asyncio.sleep(0.1)
-                    break
-                except FloodWait as e:
-                    await asyncio.sleep(e.value + 1)
-                except Exception as e:
-                    err_msg = str(e).lower()
-                    if "disconnect" in err_msg or "connection" in err_msg or "timeout" in err_msg:
-                        retries -= 1
-                        video_ids = []
-                        await asyncio.sleep(5)
-                    else:
-                        break
-                        
-            if not video_ids:
-                continue
-                
-            video_ids.reverse() 
-            
-            for msg_id in video_ids:
-                copy_retries = 3
-                copy_success = False
-                while copy_retries > 0:
-                    try:
-                        await client.copy_message(chat_id=dest_id, from_chat_id=source_id, message_id=msg_id)
-                        total_copied += 1
-                        await save_progress(source_id, dest_id, msg_id)
-                        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:
-                            copy_retries -= 1
-                            await asyncio.sleep(3)
-                        else:
-                            break
-                await asyncio.sleep(2.5)
-                
-        await status_msg.edit_text(f"🎉 <b>Mass Cloning Completely Finished!</b>\n\nTotal Videos Copied from all groups: <b>{total_copied}</b>", parse_mode=enums.ParseMode.HTML)
-        
-    except Exception as e:
-        try: await status_msg.edit_text(f"❌ <b>Cloning Error:</b> {e}", parse_mode=enums.ParseMode.HTML)
-        except: pass
-
-@bot.on_message(filters.command("cloneall") & filters.private & filters.user(ADMIN_IDS))
-async def start_mass_cloning(client, message):
-    dest_id = -1003798479478 
-    status_msg = await message.reply(f"⏳ <b>Initializing mass cloning task to <code>{dest_id}</code>...</b>", parse_mode=enums.ParseMode.HTML)
-    asyncio.create_task(clone_all_background(client, dest_id, status_msg))
-
-
 @bot.on_message(filters.command("upload") & filters.private & filters.user(ADMIN_IDS))
 async def set_upload_mode(client, message):
     global upload_mode