update

chatbot/plugins/chat.py

@@ -7,32 +7,22 @@
 # This project is proprietary software. Unauthorized redistribution is prohibited.
 
 import asyncio
-import importlib
-import math
 import random
 import os
 import base64
 import re
 import uuid
-import shlex
-import requests
-import subprocess
-import sys
-import time
-import traceback
 import requests
 import json
-import io
-import cohere
+import cohere # type: ignore
 from datetime import datetime as dt, timedelta
 
-from gpytranslate import SyncTranslator
+from gpytranslate import SyncTranslator # type: ignore
 from io import BytesIO
-from typing import Dict, List, Optional, Tuple, Union
+from typing import List
 
-from PIL import Image
+from PIL import Image # type: ignore
 from pyrogram import *
-from pyrogram.enums import ChatMemberStatus
 from pyrogram import enums
 from pyrogram import Client, filters
 from pyrogram.types import *
@@ -42,13 +32,13 @@ from database import users_collection, db
 from logger import LOGS
 
 from akenoai import *
-from akenoai.types import DifferentAPIDefault
+from akenoai.types import DifferentAPIDefault # type: ignore
 
 from google import genai
 from google.genai import types as ty
 
 trans = SyncTranslator()
-js = AkenoXJs(DifferentAPIDefault()).connect()
+js = AkenoXJs(DifferentAPIDefault()).connect() # type: ignore
 
 message_memory_state = {}
 DISABLED_COMMANDS =  [
@@ -269,6 +259,73 @@ async def coheresearch(client, callback):
     ])
     await callback.edit_message_reply_markup(reply_markup=InlineKeyboardMarkup(keyboard))
 
+
+def inline_error(inline_text, **args):
+    answers = [
+        InlineQueryResultArticle(
+            title="Error!",
+            thumb_url="https://telegra.ph//file/586a3867c3e16ca6bb4fa.jpg",
+            input_message_content=InputTextMessageContent(
+                message_text=inline_text,
+                disable_web_page_preview=True
+            ),
+            **args
+        )
+    ]
+    return answers
+
+@Client.on_inline_query()
+async def inline_search(client: Client, inline_query: InlineQuery):
+    search_query = inline_query.query.strip()
+    if not search_query:
+        return
+    if search_query:
+        try:
+            response = requests.get(
+                'https://www.googleapis.com/customsearch/v1',
+                params={
+                    "key": GOOGLE_API_SEARCH,
+                    "cx": "8386c816e6fff4b2a",
+                    "q": search_query,
+                    "searchType": "image"
+                }
+            )
+            response_json = response.json()
+            if 'items' in response_json:
+                results = []
+                for i, item in enumerate(response_json['items']):
+                    title = item['title']
+                    description = item['image']['contextLink']
+                    url = item['link']
+                    result = InlineQueryResultPhoto(
+                        photo_url=url,
+                        id=str(i),
+                        title=title,
+                        description=description,
+                        thumb_url=url,
+                        input_message_content=InputTextMessageContent(
+                            message_text=f"**Title:** {title}\n\n**Description:** {description}"
+                        ),
+                        reply_markup=InlineKeyboardMarkup(
+                            [[InlineKeyboardButton(text="Open Link", url=url)]]
+                        ),
+                    )
+                    results.append(result)
+                await client.answer_inline_query(inline_query.id, results=results, cache_time=10)
+            else:
+                no_found = inline_error("No found result.")
+                await client.answer_inline_query(
+                    inline_query.id,
+                    results=no_found
+                )
+        except Exception as e:
+            LOGS.error(f"Error Inline: {type(e).__name__}")
+            error_ = inline_error(f"Error try again.")
+            await client.answer_inline_query(
+                inline_query.id,
+                results=error_
+            )
+
 @Client.on_callback_query(filters.regex("^deeps_(on|off)_([a-f0-9]{8})$"))
 async def deepsearchmode(client, callback):
     user_id = callback.from_user.id
@@ -660,8 +717,8 @@ async def createchat_cb(client, callback):
     if not data:
         await callback.answer("Can't found user", True)
         return
-    create_chat = data.get("create_chat_uuid", None)
-    if not create_chat:
+    create_chat_uuid = data.get("create_chat_uuid", None)
+    if not create_chat_uuid:
         await callback.answer("You can reset chat, this no chat found", True)
         return
     await callback.answer(f"Created Chat: {create_chat_uuid}", True)
@@ -1600,3 +1657,5 @@ async def chatbot_talk(client: Client, message: Message):
         except Exception as e:
             LOGS.error(f"Error: message.text: {str(e)}")
             return await message.reply_text("Server busy try again later")
+
+# Developer by @xtdevs