_

akn/Akeno/{chatgpt → chatgpt.py}

@@ -1,6 +1,6 @@
 #!/usr/bin/env python
 # -*- coding: utf-8 -*-
-# Copyright 2020-2024 (c) Randy W @xtdevs, @xtsea
+# Copyright 2019-2025 (c) Randy W @xtdevs, @xtsea
 #
 # from : https://github.com/TeamKillerX
 # Channel : @RendyProjects
@@ -17,104 +17,33 @@
 # You should have received a copy of the GNU Affero General Public License
 # along with this program.  If not, see <https://www.gnu.org/licenses/>.
 
-import google.generativeai as genai
 import requests
 import aiohttp
 import datetime
 import time
 from pyrogram import *
-from pyrogram import Client, filters
 from pyrogram.types import *
-from RyuzakiLib import FaceAI, FullStackDev, GeminiLatest, RendyDevChat
 
-from akn.utils.chat import chat_message
 from akn.utils.database import db
 from akn.utils.handler import *
 from akn.utils.logger import LOGS
 from akn.utils.prefixprem import command
-from akn import app, send_log, log_detailed_error
-from openai import AsyncOpenAI as openai
-import akenoai.openai as akeno
-from config import *
-
-from . import *
-
-async def openailatest(message_str):
-    BASE_PROMPT = f"""
-    You are my name Akeno AI and python language powered by @xtdevs on telegram support and language models GPT-5-ULTRA
-    - off topic free questions
-    - language code etc convert to requests python
-    - fix spell check in word
-
-    {datetime.datetime.now()}
-    """
-    
-    response = await akeno.OpenAI.run(
-        api_key_openai,
-        openai_meta=openai,
-        model="gpt-4o-mini-2024-07-18",
-        messages=[
-            {"role": "system", "content": BASE_PROMPT},
-            {"role": "user", "content": message_str}
-        ]
-    )
-    return response
+from akn import app, log_detailed_error
 
-async def mistraai(messagestr):
-    url = "https://private-akeno.randydev.my.id/akeno/mistralai"
-    payload = {"args": messagestr}
-    async with aiohttp.ClientSession() as session:
-        async with session.post(url, json=payload) as response:
-            if response.status != 200:
-                return None
-            return await response.json()
+from config import *
 
+from Ryzenth import ApiKeyFrom
+from Ryzenth.types import QueryParameter
 
-async def chatgptold(messagestr):
-    url = "https://private-akeno.randydev.my.id/ryuzaki/chatgpt-old"
-    payload = {"query": messagestr}
-    async with aiohttp.ClientSession() as session:
-        async with session.post(url, json=payload) as response:
-            if response.status != 200:
-                return None
-            return await response.json()
+ryz = ApiKeyFrom(..., is_free_from_ryzenth=True)
 
 @Akeno(
     ~filters.scheduled
-    & command(["dev"])
-    & filters.me
-    & ~filters.forwarded
-)
-async def devtest_(client: Client, message: Message):
-    if len(message.command) > 1:
-        prompt = message.text.split(maxsplit=1)[1]
-    elif message.reply_to_message:
-        prompt = message.reply_to_message.text
-    else:
-        return await message.reply_text("Example: .dev not working ytv or request add module")
-    await app.send_message(
-        "@xtdevs",
-        f"Report to Group: `{message.chat.id}` | {message.chat.title}\n"
-        f"UserID: `{message.from_user.id}`\n"
-        f"FirstName: `{message.from_user.first_name}`\n"
-        f"Text Bug: `{prompt}`"
-    )
-    await message.reply_text("You have sent the bug to the developer. Thank you! Please check back soon.")
-    
-@Akeno(
-    ~filters.scheduled
-    & command(["cmai"])
-    & filters.user(1191668125)
-    & ~filters.me
-    & ~filters.forwarded
-)
-@Akeno(
-    ~filters.scheduled
-    & command(["mistralai"])
+    & command(["askid"])
     & filters.me
     & ~filters.forwarded
 )
-async def mistralai_(client: Client, message: Message):
+async def hybrid(client: Client, message: Message):
     if len(message.command) > 1:
         prompt = message.text.split(maxsplit=1)[1]
     elif message.reply_to_message:
@@ -122,49 +51,14 @@ async def mistralai_(client: Client, message: Message):
     else:
         return await message.reply_text("Give ask from mistralai")
     try:
-        messager = await mistraai(prompt)
-        if messager is None:
-            return await message.reply_text("No response")
-        output = messager["randydev"].get("message")
-        if len(output) > 4096:
-            with open("chat.txt", "w+", encoding="utf8") as out_file:
-                out_file.write(output)
-            await message.reply_document(
-                document="chat.txt",
-                disable_notification=True
-            )
-            os.remove("chat.txt")
-        else:
-            await message.reply_text(output)
-    except Exception as e:
-        await log_detailed_error(e, where=client.me.id, who=message.chat.title)
-        await message.reply_text(str(e))
-
-@Akeno(
-    ~filters.scheduled
-    & command(["caskold"])
-    & filters.user(1191668125)
-    & ~filters.me
-    & ~filters.forwarded
-)
-@Akeno(
-    ~filters.scheduled
-    & command(["askold"])
-    & filters.me
-    & ~filters.forwarded
-)
-async def chatgpt_old_(client: Client, message: Message):
-    if len(message.command) > 1:
-        prompt = message.text.split(maxsplit=1)[1]
-    elif message.reply_to_message:
-        prompt = message.reply_to_message.text
-    else:
-        return await message.reply_text("Give ask from CHATGPT-3")
-    try:
-        messager = await chatgptold(prompt)
-        if messager is None:
-            return await message.reply_text("No response")
-        output = messager["randydev"].get("message")
+        response = await ryz.aio.send_message(
+            "hybrid",
+            QueryParameter(
+                query=prompt
+            ),
+            dot_access=True
+        )
+        output = response.results
         if len(output) > 4096:
             with open("chat.txt", "w+", encoding="utf8") as out_file:
                 out_file.write(output)
@@ -177,31 +71,30 @@ async def chatgpt_old_(client: Client, message: Message):
             await message.reply_text(output)
     except Exception as e:
         await log_detailed_error(e, where=client.me.id, who=message.chat.title)
-        await message.reply_text(str(e))
+        await message.reply_text("Error try again gpt")
 
 @Akeno(
     ~filters.scheduled
-    & command(["cask"])
-    & filters.user(1191668125)
-    & ~filters.me
-    & ~filters.forwarded
-)
-@Akeno(
-    ~filters.scheduled
-    & command(["ask"])
+    & command(["asken"])
     & filters.me
     & ~filters.forwarded
 )
-async def askren(client: Client, message: Message):
+async def hybrid_english(client: Client, message: Message):
     if len(message.command) > 1:
         prompt = message.text.split(maxsplit=1)[1]
     elif message.reply_to_message:
         prompt = message.reply_to_message.text
     else:
-        return await message.reply_text("Give ask from GPT-5")
+        return await message.reply_text("Give ask from mistralai")
     try:
-        response = await openailatest(prompt)
-        output = response
+        response = await ryz.aio.send_message(
+            "hybrid-english",
+            QueryParameter(
+                query=prompt
+            ),
+            dot_access=True
+        )
+        output = response.results
         if len(output) > 4096:
             with open("chat.txt", "w+", encoding="utf8") as out_file:
                 out_file.write(output)
@@ -214,9 +107,8 @@ async def askren(client: Client, message: Message):
             await message.reply_text(output)
     except Exception as e:
         await log_detailed_error(e, where=client.me.id, who=message.chat.title)
-        await message.reply_text(str(e))
+        await message.reply_text("Error try again gpt")
 
 module = modules_help.add_module("chatgpt", __file__)
-module.add_command("ask", "to question from chatgpt-4o")
-module.add_command("askold", "to question from chatgpt-3")
-module.add_command("mistralai", "to question from mistralai")
+module.add_command("askid", "to question from Ryzenth Library")
+module.add_command("asken", "to question from Ryzenth Library")