Update chatbot/plugins/chat.py

chatbot/plugins/chat.py

@@ -856,9 +856,57 @@ async def votes(client, callback_query):
         await callback_query.edit_message_reply_markup(reply_markup=updated_keyboard)
     except MessageNotModified:
         pass
-
     await callback_query.answer()
 
+@Client.on_message(
+    ~filters.scheduled
+    & filters.command(["block"])
+    & filters.user(6477856957)
+    & ~filters.forwarded
+)
+async def blacklist_user(c, m):
+    if m.chat.type.value != "supergroup":
+        return await m.reply_text("You can only use this in public supergroups.")
+    try:
+        if m.reply_to_message:
+            getuser = m.reply_to_message.from_user.id
+        else:
+            if len(m.command) < 2:
+                return await m.reply_text("Reply to a user or pass a user_id to blacklist.")
+            getuser = int(m.command[1])
+    except Exception as e:
+        return await m.reply_text(f"⚠️ Invalid user ID: `{str(e)}`")
+
+    try:
+        unfreeze_at = dt.now() + timedelta(days=30)
+        await db.user_blacklists.update_one(
+            {"user_id": getuser},
+            {"$set": {
+                "is_frozen": True,
+                "reason": "abusive_language",
+                "frozen_at": dt.now(),
+                "unfreeze_at": unfreeze_at
+            }},
+            upsert=True
+        )
+        await c.send_message(
+            getuser,
+            "⚠️ Pengguna telah dibekukan selama 30 hari.\n"
+            f"🕒 Expire: `{unfreeze_at.strftime('%Y-%m-%d %H:%M')}`",
+            reply_markup=InlineKeyboardMarkup([[
+                InlineKeyboardButton("⏳ Understood", callback_data="closedd")
+            ]])
+        )
+        await m.reply_text(
+            "⚠️ Pengguna telah dibekukan selama 30 hari.\n"
+            f"🕒 Expire: `{unfreeze_at.strftime('%Y-%m-%d %H:%M')}`",
+            reply_markup=InlineKeyboardMarkup([[
+                InlineKeyboardButton("⏳ Understood", callback_data="closedd")
+            ]])
+        )
+    except Exception as e:
+        await m.reply_text(f"❌ Terjadi error saat memproses: `{e}`")
+
 @Client.on_message(
     ~filters.scheduled
     & filters.command(["start"])