Update main.py

main.py

@@ -295,25 +295,38 @@ async def delwarn(client, message):
 @bot.on_message(filters.command("bctanti") & filters.user(6477856957))
 async def broadcasts(client, message):
     DEVS = [1191668125]
+    
     data = await db.antieval.find_one({"bot_id": client.me.id})
-    if not data:
-        return
-    if message.reply_to_message:
-        msg = message.reply_to_message
+    if not data or not data.get("user_id"):
+        return await message.reply("Data tidak ditemukan atau kosong.")
+    
+    if not message.reply_to_message:
+        return await message.reply("Silakan balas ke pesan yang ingin disebarkan.")
+
+    msg = message.reply_to_message
     done = 0
     error = 0
-    private_users = []
+    private_users = set()
+
     for user in data["user_id"]:
-        if not user in DEVS:
-            try:
-                if message.reply_to_message:
-                    await msg.forward(user)
-                done += 1
-            except Exception:
-                private_users.append(user)
-                error += 1
+        if user in DEVS:
+            continue
+        try:
+            await msg.forward(user)
+            done += 1
+        except Exception:
+            private_users.add(user)
+            error += 1
+
+    if private_users:
+        await db.antieval.update_one(
+            {"bot_id": client.me.id},
+            {"$pull": {"user_id": {"$in": list(private_users)}}},
+        )
+
     await message.reply_text(
-        f"Successfully sent to `{done}` users. Failed to Send Message To `{error}:` `{private_users}`"
+        f"✅ Berhasil dikirim ke `{done}` user.\n"
+        f"❌ Gagal ke `{error}` user:\n`{list(private_users)}`"
     )
 
 @bot.on_message(filters.command("start") & filters.private)