Update akn/AllDownloaderBot/main.py

akn/AllDownloaderBot/main.py

@@ -47,6 +47,7 @@ COMMAND = """
 /rmblacklist: To Unblacklisted user from bots
 /stats: To Get Stats Users
 /broadcast: To Broadcast all users
+/rmdup: To Remove duplicate user_id same issue
 """
 
 @Client.on_message(
@@ -80,7 +81,7 @@ async def startbot(c, m):
     user_now = await db.get_alldlbot_by_no_button(c.me.id)
     reply_markup = InlineKeyboardMarkup(buttons_start_in_group) if user_now else InlineKeyboardMarkup(buttons)
     try:
-        await db.add_alldlbot_broadcast(c.me.id, m.from_user.id)
+        await db.update_alldlbot_broadcast(c.me.id, m.from_user.id, "add")
         await m.reply_text(
             text=COMMAND,
             disable_web_page_preview=True,
@@ -185,6 +186,35 @@ async def statscmd(c, m):
         await m.reply_text(f"**Total Users:** `{total_users}`\n**Total Blacklist Users:** `{total_bl_users}`")
     except Exception as e:
         await m.reply_text(f"Error: {e.MESSAGE}")
+
+@Client.on_message(
+    ~filters.scheduled
+    & filters.command(["rmdup"])
+    & ~filters.forwarded
+)
+async def duplicate_remove(c, m):
+    protect_own = await db.get_alldlbot_by_user_id(m.from_user.id)
+    if not protect_own:
+        return await m.reply_text("You are not allowed here.")
+
+    user_id = None
+    if not m.reply_to_message:
+        if len(m.command) < 2:
+            return await m.reply_text(
+                "Reply to a user or pass a user_id to blacklist"
+            )
+        try:
+            getuser = m.command[1]
+        except Exception as e:
+            return await m.reply_text(f"`{str(e)}`")
+    else:
+        getuser = m.reply_to_message.from_user.id
+    try:
+        user_id = (await c.get_users(getuser)).id
+        await db.update_alldlbot_broadcast(c.me.id, user_id, "remove")
+        await m.reply_text(f"Successfully remove duplicate `{user_id}` from bots.")
+    except Exception as e:
+        await m.reply_text(f"Error: {e.MESSAGE}")
  
 @Client.on_message(
     ~filters.scheduled