aff

app.py

@@ -0,0 +1,106 @@
+import gradio as gr
+import asyncio
+from telethon.sync import TelegramClient
+from telethon.errors import FloodWaitError
+from telethon.tl.types import ChannelParticipantsAdmins
+
+# 🔐 Your fixed API credentials
+api_id = 29716085
+api_hash = '75073ce12878f4e510bbaae6642a9752'
+
+# Get user's channels
+async def fetch_channels(session_name):
+    async with TelegramClient(session_name, api_id, api_hash) as client:
+        dialogs = await client.get_dialogs(limit=100)
+        channels = [d for d in dialogs if d.is_channel]
+        return [(ch.name, ch.id) for ch in channels]
+
+# Remove non-admin, non-whitelisted users
+async def remove_members(session_name, channel_id, allowed_user_ids_str):
+    output = []
+
+    allowed_ids = {int(uid.strip()) for uid in allowed_user_ids_str.split(',') if uid.strip().isdigit()}
+
+    async with TelegramClient(session_name, api_id, api_hash) as client:
+        me = await client.get_me()
+        output.append(f"Logged in as: {me.username or me.first_name} (ID: {me.id})")
+
+        channel = await client.get_entity(channel_id)
+        output.append(f"Selected Channel: {channel.title}")
+
+        admins = await client.get_participants(channel, filter=ChannelParticipantsAdmins)
+        admin_ids = {admin.id for admin in admins}
+        exclude_ids = admin_ids.union({me.id}, allowed_ids)
+
+        output.append(f"Total admins (including you): {len(admin_ids)}")
+        output.append(f"Starting to remove members (excluding {len(exclude_ids)} allowed users)...")
+
+        total_removed = 0
+
+        async for user in client.iter_participants(channel):
+            if user.id in exclude_ids:
+                continue
+
+            try:
+                await client.kick_participant(channel, user.id)
+                output.append(f"Removed: {user.first_name or user.username} (ID: {user.id})")
+                total_removed += 1
+            except FloodWaitError as e:
+                output.append(f"FloodWait: Need to wait {e.seconds} seconds.")
+                await asyncio.sleep(e.seconds)
+                try:
+                    await client.kick_participant(channel, user.id)
+                    output.append(f"Retried and removed: {user.first_name or user.username} (ID: {user.id})")
+                    total_removed += 1
+                except Exception as e2:
+                    output.append(f"Retry failed for {user.id}: {e2}")
+            except Exception as e:
+                output.append(f"Could not remove {user.id}: {e}")
+
+        output.append(f"\n✅ Done. Total members removed: {total_removed}")
+        return "\n".join(output)
+
+# Wrappers
+def list_channels(session_name):
+    return asyncio.run(fetch_channels(session_name))
+
+def cleanup_members(session_name, channel_id, allowed_users):
+    return asyncio.run(remove_members(session_name, channel_id, allowed_users))
+
+# Gradio UI
+with gr.Blocks() as app:
+    gr.Markdown("## 🧹 Telegram Channel Cleaner (Telethon + Gradio)")
+
+    session_name = gr.Textbox(label="Session Name", placeholder="e.g., mysession")
+
+    get_channels_btn = gr.Button("📥 Fetch Channels")
+    channel_dropdown = gr.Dropdown(label="Select Channel", choices=[], interactive=True)
+
+    allowed_users = gr.Textbox(
+        label="Allowed User IDs (comma-separated)", 
+        placeholder="e.g., 12345678,87654321"
+    )
+
+    run_button = gr.Button("🚀 Run Cleanup")
+    output_log = gr.Textbox(label="Output Log", lines=20, interactive=False)
+
+    def populate_channels(session_name):
+        try:
+            channels = list_channels(session_name)
+            return gr.update(choices=[(name, id) for name, id in channels], value=None)
+        except Exception as e:
+            return gr.update(choices=[], value=None), f"❌ Error: {e}"
+
+    get_channels_btn.click(
+        populate_channels,
+        inputs=[session_name],
+        outputs=[channel_dropdown]
+    )
+
+    run_button.click(
+        cleanup_members,
+        inputs=[session_name, channel_dropdown, allowed_users],
+        outputs=[output_log]
+    )
+
+app.launch()