_

chatbot/plugins/chat.py

@@ -37,6 +37,11 @@ from config import *
 from database import db, users_collection
 from logger import LOGS
 
+from Ryzenth import ApiKeyFrom, SmallConvertDot
+from Ryzenth.types import RequestHumanizer
+
+ryz = ApiKeyFrom(..., True)
+
 trans = SyncTranslator()
 js = AkenoXJs(DifferentAPIDefault()).connect()
 
@@ -264,6 +269,24 @@ async def coheresearch(client, callback):
     ])
     await callback.edit_message_reply_markup(reply_markup=InlineKeyboardMarkup(keyboard))
 
+@Client.on_callback_query(filters.regex("^human:([a-f0-9]{8})"))
+async def _humancb(client, callback):
+    user_id = callback.from_user.id
+    uuidstr = callback.matches[0].group(1)
+    user_bl = await db.user_blacklists.find_one({"user_id": user_id})
+    if user_bl and user_bl.get("is_frozen", False) and user_id not in [6477856957]:
+        await callback.answer("Sorry your account is frozen", True)
+        return
+    keyboard = []
+    keyboard.append([
+        InlineKeyboardButton("Humanizer ON", callback_data=f"humanizer_on_{uuidstr}"),
+        InlineKeyboardButton("Humanizer OFF", callback_data=f"humanizer_off_{uuidstr}")
+    ])
+    keyboard.append([
+        InlineKeyboardButton("Back To Menu", callback_data=f"menu_back:{uuidstr}")
+    ])
+    await callback.edit_message_reply_markup(reply_markup=InlineKeyboardMarkup(keyboard))
+
 def inline_error(text: str):
     return [
         InlineQueryResultArticle(
@@ -326,6 +349,38 @@ async def inline_search(client: Client, inline_query: InlineQuery):
         await inline_query.answer(inline_error("Internal error. Try again later."), cache_time=1)
         LOGS.error(f"[INLINE ERROR] {type(e).__name__}: {e}")
 
+@Client.on_callback_query(filters.regex("^humanizer_(on|off)_([a-f0-9]{8})$"))
+async def humanizermode(client, callback):
+    user_id = callback.from_user.id
+    user_bl = await db.user_blacklists.find_one({"user_id": user_id})
+    if user_bl and user_bl.get("is_frozen", False) and user_id not in [6477856957]:
+        await callback.answer("Sorry your account is frozen", True)
+        return
+    check_is_system = await db.backup_chatbot.find_one({"user_id": user_id})
+    if check_is_system and check_is_system.get("is_deepsearch", False):
+        await callback.answer(f"You can OFF in deep search", show_alert=True)
+        return
+    mode, uuidstr = callback.matches[0].groups()
+    try:
+        if mode not in ("on", "off"):
+            await callback.answer("Mode invalid", show_alert=True)
+            return
+        is_human = mode == "on"
+        await db.backup_chatbot.update_one(
+            {"user_id": user_id},
+            {"$set": {"is_humanizer": is_human}},
+            upsert=True
+        )
+        await callback.answer(f"Humanizer mode is set to {mode}.", show_alert=True)
+        keyboard = create_keyboard(
+            user_id=user_id,
+            uuid_str=uuidstr
+        )
+        await callback.edit_message_reply_markup(reply_markup=keyboard)
+    except Exception as e:
+        LOGS.error(f"Humanizer Error: {e}")
+        await callback.answer("Please try again later..", show_alert=True)
+
 @Client.on_callback_query(filters.regex("^deeps_(on|off)_([a-f0-9]{8})$"))
 async def deepsearchmode(client, callback):
     user_id = callback.from_user.id
@@ -333,6 +388,10 @@ async def deepsearchmode(client, callback):
     if user_bl and user_bl.get("is_frozen", False) and user_id not in [6477856957]:
         await callback.answer("Sorry your account is frozen", True)
         return
+    check_is_system = await db.backup_chatbot.find_one({"user_id": user_id})
+    if check_is_system and check_is_system.get("is_humanizer", False):
+        await callback.answer(f"You can OFF in humanizer", show_alert=True)
+        return
     mode, uuidstr = callback.matches[0].groups()
     try:
         if mode not in ("on", "off"):
@@ -362,6 +421,9 @@ async def modelgeminimenu(client, callback):
     if check_is_system and check_is_system.get("is_deepsearch", False):
         await callback.answer(f"You can OFF in deep search", show_alert=True)
         return
+    if check_is_system and check_is_system.get("is_humanizer", False):
+        await callback.answer(f"You can OFF in humanizer", show_alert=True)
+        return
     keyboard = []
     keyboard.append([
         InlineKeyboardButton("G Flash EXP", callback_data=f"us:gemini-2.0-flash-exp:{uuidstr}"),
@@ -838,6 +900,7 @@ def create_keyboard(
                     InlineKeyboardButton(f"🔒", callback_data=f"showchat"),
                     InlineKeyboardButton(f"⛏️", callback_data=f"modelmenu:{uuid_str}"),
                     InlineKeyboardButton(f"💡", callback_data=f"comode:{uuid_str}"),
+                    InlineKeyboardButton(f"🚶‍♀️", callback_data=f"human:{uuid_str}"),
                     InlineKeyboardButton(f"💾", callback_data=f"memory_{uuid_str}")
                 ],
                 [
@@ -1535,6 +1598,51 @@ async def chatbot_talk(client: Client, message: Message):
                 )
                 return
 
+            uuid_human = str(uuid.uuid4())[:8]
+            if check_is_system.get("is_humanizer", False):
+                backup_chat = await db._get_chatbot_chat_from_db(message.from_user.id)
+                backup_chat.append({"role": "user", "parts": [{"text": query_base}]})
+                response = await ryz.aio.humanizer.rewrite(
+                    RequestHumanizer(
+                        text=str(query_base),
+                        writing_style="casual",
+                        author_id=str(message.from_user.id),
+                        timestamp=str(dt.now())
+                    ),
+                    pickle_json=True
+                )
+                data = SmallConvertDot(response).to_dot()
+                if len(data.text) > 4096:
+                    text_parts = split_message(data.text)
+                    for part in text_parts:
+                        await message.reply_text(part)
+                else:
+                    keyboard_like = create_keyboard(
+                        user_id=message.from_user.id,
+                        uuid_str=uuid_human
+                    )
+                    await message.reply_text(
+                        data.text,
+                        disable_web_page_preview=True,
+                        reply_markup=keyboard_like
+                    )
+                translation_entry = {
+                    "uuid": uuid_cohere,
+                    "text": data.text,
+                    "timestamp": dt.now().isoformat()
+                }
+                await db.backup_chatbot.update_one(
+                    {"user_id": message.from_user.id},
+                    {"$push": {"translate_history": translation_entry}},
+                    upsert=True
+                )
+                backup_chat.append({"role": "model", "parts": [{"text": data.text}]})
+                await db._update_chatbot_chat_in_db(message.from_user.id, backup_chat)
+                LOGS.info(f"Response Humanizer: {message.from_user.first_name} | {message.from_user.id}\n\nText: {query_base}")
+                await client.send_chat_action(message.chat.id, enums.ChatAction.CANCEL)
+                return
+
+
             uuid_cohere = str(uuid.uuid4())[:8]
             if check_is_system.get("is_deepsearch", False):
                 backup_chat = await db._get_chatbot_chat_from_db(message.from_user.id)