Update chatbot/plugins/chat.py

chatbot/plugins/chat.py

@@ -1424,6 +1424,22 @@ async def chatbot_talk(client: Client, message: Message):
                     LOGS.error(f"Error: Gemini Image: {str(e)}")
                     return await message.reply_text("Server busy try again later")
 
+
+            if re.findall(r"\b(disabled:callusers)\b", query_base, re.IGNORECASE):
+                if message.from_user.id != 6477856957:
+                    return
+                try:
+                    data = await db.backup_chatbot.find({"is_system": True}).to_list(length=None)
+                    for user in data:
+                        await db.backup_chatbot.update_one(
+                            {"_id": user["_id"]},
+                            {"$set": {"is_system": False}},
+                        )
+                    await message.reply_text("All Users streaming is disabled now")
+                    return
+                except Exception as e:
+                    await message.reply_text(f"Error {str(e)}")
+                
             if re.findall(r"\b(enabled:chatstream)\b", query_base, re.IGNORECASE):
                 await db.backup_chatbot.update_one(
                     {"user_id": message.from_user.id},