Ok updated

chatbot/plugins/chat.py

@@ -1053,6 +1053,7 @@ async def chatbot_talk(client: Client, message: Message):
             stream_image_now = re.match(r"--stream-images\s*(.*)", caption, re.IGNORECASE)
             if stream_image_now:
                 STREAM_IMAGE_PATH = await message.download()
+                uuid_code = str(uuid.uuid4())[:8]
                 try:
                     backup_chat = await db._get_chatbot_chat_from_db(message.from_user.id)
                     backup_chat.append({"role": "user", "parts": [{"text": caption}]})
@@ -1070,16 +1071,24 @@ async def chatbot_talk(client: Client, message: Message):
                     if captions == "":
                         return await message.reply_text("Server busy try again later")
 
-                    keyboard = create_keyboard(user_id=message.from_user.id)
+                    keyboard = create_keyboard(
+                        user_id=message.from_user.id,
+                        uuid_str=uuid_code
+                    )
                     await message.reply_text(
                         captions,
                         disable_web_page_preview=True,
                         reply_markup=keyboard
                     )
 
+                    translation_entry = {
+                        "uuid": uuid_code,
+                        "text": captions,
+                        "timestamp": dt.now().isoformat()
+                    }
                     await db.backup_chatbot.update_one(
                         {"user_id": message.from_user.id},
-                        {"$set": {"translate_text": captions}},
+                        {"$push": {"translate_history": translation_entry}},
                         upsert=True
                     )
                     backup_chat.append({"role": "model", "parts": [{"text": captions}]})
@@ -1236,20 +1245,29 @@ async def chatbot_talk(client: Client, message: Message):
                 model=model_,
                 contents=[str(caption), file_photo]
             )
+            uuid_code = str(uuid.uuid4())[:8]
             if len(response.text) > 4096:
                 text_parts = split_message(response.text)
                 for part in text_parts:
                     await message.reply_text(part)
             else:
-                keyboard_like = create_keyboard(user_id=message.from_user.id)
+                keyboard_like = create_keyboard(
+                    user_id=message.from_user.id,
+                    uuid_str=uuid_code
+                )
                 await message.reply_text(
                     response.text,
                     disable_web_page_preview=True,
                     reply_markup=keyboard_like
                 )
+            translation_entry = {
+                "uuid": uuid_code,
+                "text": response.text,
+                "timestamp": dt.now().isoformat()
+            }
             await db.backup_chatbot.update_one(
                 {"user_id": message.from_user.id},
-                {"$set": {"translate_text": response.text}},
+                {"$push": {"translate_history": translation_entry}},
                 upsert=True
             )
             backup_chat.append({"role": "model", "parts": [{"text": response.text}]})
@@ -1290,20 +1308,29 @@ async def chatbot_talk(client: Client, message: Message):
                 model=model_,
                 contents=[str(caption), video_file]
             )
+            uuid_code = str(uuid.uuid4())[:8]
             if len(response.text) > 4096:
                 text_parts = split_message(response.text)
                 for part in text_parts:
                     await message.reply_text(part)
             else:
-                keyboard_like = create_keyboard(user_id=message.from_user.id)
+                keyboard_like = create_keyboard(
+                    user_id=message.from_user.id,
+                    uuid_str=uuid_code
+                )
                 await message.reply_text(
                     response.text,
                     disable_web_page_preview=True,
                     reply_markup=keyboard_like
                 )
+            translation_entry = {
+                "uuid": uuid_code,
+                "text": response.text,
+                "timestamp": dt.now().isoformat()
+            }
             await db.backup_chatbot.update_one(
                 {"user_id": message.from_user.id},
-                {"$set": {"translate_text": response.text}},
+                {"$push": {"translate_history": translation_entry}},
                 upsert=True
             )
             backup_chat.append({"role": "model", "parts": [{"text": response.text}]})
@@ -1343,20 +1370,30 @@ async def chatbot_talk(client: Client, message: Message):
                     model=model_,
                     contents=["funny random meme sticker words", sticker_file]
                 )
+                uuid_code = str(uuid.uuid4())[:8]
                 if len(response.text) > 4096:
                     text_parts = split_message(response.text)
                     for part in text_parts:
                         await message.reply_text(part)
                 else:
-                    keyboard_like = create_keyboard(user_id=message.from_user.id)
+                    keyboard_like = create_keyboard(
+                        user_id=message.from_user.id,
+                        uuid_str=uuid_code
+                    )
                     await message.reply_text(
                         response.text,
                         disable_web_page_preview=True,
                         reply_markup=keyboard_like
                     )
+
+                translation_entry = {
+                    "uuid": uuid_code,
+                    "text": response.text,
+                    "timestamp": dt.now().isoformat()
+                }
                 await db.backup_chatbot.update_one(
                     {"user_id": message.from_user.id},
-                    {"$set": {"translate_text": response.text}},
+                    {"$push": {"translate_history": translation_entry}},
                     upsert=True
                 )
                 backup_chat.append({"role": "model", "parts": [{"text": response.text}]})
@@ -1552,6 +1589,7 @@ async def chatbot_talk(client: Client, message: Message):
                     return
 
                 test_result = ""
+                uuid_code = str(uuid.uuid4())[:8]
                 backup_chat = await db._get_chatbot_chat_from_db(message.from_user.id)
                 backup_chat.append({"role": "user", "parts": [{"text": query_base}]})
                 async for chunk in await gen.aio.models.generate_content_stream(
@@ -1581,15 +1619,23 @@ async def chatbot_talk(client: Client, message: Message):
                     for part in text_parts:
                         await message.reply_text(part)
                 else:
-                    keyboard_like = create_keyboard(user_id=message.from_user.id)
+                    keyboard_like = create_keyboard(
+                        user_id=message.from_user.id,
+                        uuid_str=uuid_code
+                    )
                     await message.reply_text(
                         test_result,
                         disable_web_page_preview=True,
                         reply_markup=keyboard_like
                     )
+                translation_entry = {
+                    "uuid": uuid_code,
+                    "text": test_result,
+                    "timestamp": dt.now().isoformat()
+                }
                 await db.backup_chatbot.update_one(
                     {"user_id": message.from_user.id},
-                    {"$set": {"translate_text": test_result}},
+                    {"$push": {"translate_history": translation_entry}},
                     upsert=True
                 )
                 backup_chat.append({"role": "model", "parts": [{"text": test_result}]})