Spaces:
Running
Running
Update chatbot/plugins/chat.py
Browse files- chatbot/plugins/chat.py +12 -0
chatbot/plugins/chat.py
CHANGED
@@ -38,6 +38,7 @@ from database import db
|
|
38 |
from logger import LOGS
|
39 |
|
40 |
import google.generativeai as genai
|
|
|
41 |
from google.api_core.exceptions import InvalidArgument
|
42 |
|
43 |
async def geni_files_delete(name: str):
|
@@ -48,6 +49,12 @@ async def geni_files_delete(name: str):
|
|
48 |
return None
|
49 |
return response.text
|
50 |
|
|
|
|
|
|
|
|
|
|
|
|
|
51 |
|
52 |
FREE_GEMINI_TEXT = """
|
53 |
• User Free : {name}
|
@@ -65,6 +72,7 @@ FREE_GEMINI_TEXT = """
|
|
65 |
& filters.command(["status"])
|
66 |
& ~filters.forwarded
|
67 |
)
|
|
|
68 |
async def userstatus(client: Client, message: Message):
|
69 |
is_check_plan = await db.is_gemini_plan(user_id=message.from_user.id)
|
70 |
chat_user = await db.get_chatbot(message.chat.id)
|
@@ -101,6 +109,7 @@ async def test_payment(client: Client, message: Message):
|
|
101 |
& filters.command(["onchat"])
|
102 |
& ~filters.forwarded
|
103 |
)
|
|
|
104 |
async def addchatbot_user(client: Client, message: Message):
|
105 |
await db.add_chatbot(message.chat.id, client.me.id)
|
106 |
await message.reply_text("Added chatbot user")
|
@@ -111,6 +120,7 @@ async def addchatbot_user(client: Client, message: Message):
|
|
111 |
& filters.command(["offchat"])
|
112 |
& ~filters.forwarded
|
113 |
)
|
|
|
114 |
async def rmchatbot_user(client: Client, message: Message):
|
115 |
await db.remove_chatbot(message.chat.id)
|
116 |
await message.reply_text("ok stopped gemini")
|
@@ -127,11 +137,13 @@ async def rmchatbot_user(client: Client, message: Message):
|
|
127 |
| filters.regex(r"\b(Randy|Rendi)\b(.*)", flags=re.IGNORECASE)
|
128 |
)
|
129 |
& (filters.private | filters.group)
|
|
|
130 |
& ~filters.bot
|
131 |
& ~filters.via_bot
|
132 |
& ~filters.forwarded,
|
133 |
group=2,
|
134 |
)
|
|
|
135 |
async def chatbot_talk(client: Client, message: Message):
|
136 |
genai.configure(api_key=GOOGLE_API_KEY)
|
137 |
chat_user = await db.get_chatbot(message.chat.id)
|
|
|
38 |
from logger import LOGS
|
39 |
|
40 |
import google.generativeai as genai
|
41 |
+
import akeno.logger as akeno
|
42 |
from google.api_core.exceptions import InvalidArgument
|
43 |
|
44 |
async def geni_files_delete(name: str):
|
|
|
49 |
return None
|
50 |
return response.text
|
51 |
|
52 |
+
DISABLE_COMMAND = [
|
53 |
+
"start",
|
54 |
+
"status",
|
55 |
+
"offchat",
|
56 |
+
"onchat"
|
57 |
+
]
|
58 |
|
59 |
FREE_GEMINI_TEXT = """
|
60 |
• User Free : {name}
|
|
|
72 |
& filters.command(["status"])
|
73 |
& ~filters.forwarded
|
74 |
)
|
75 |
+
@akeno.LogChannel(channel_id=-1002290885889, is_track=True)
|
76 |
async def userstatus(client: Client, message: Message):
|
77 |
is_check_plan = await db.is_gemini_plan(user_id=message.from_user.id)
|
78 |
chat_user = await db.get_chatbot(message.chat.id)
|
|
|
109 |
& filters.command(["onchat"])
|
110 |
& ~filters.forwarded
|
111 |
)
|
112 |
+
@akeno.LogChannel(channel_id=-1002290885889, is_track=True)
|
113 |
async def addchatbot_user(client: Client, message: Message):
|
114 |
await db.add_chatbot(message.chat.id, client.me.id)
|
115 |
await message.reply_text("Added chatbot user")
|
|
|
120 |
& filters.command(["offchat"])
|
121 |
& ~filters.forwarded
|
122 |
)
|
123 |
+
@akeno.LogChannel(channel_id=-1002290885889, is_track=True)
|
124 |
async def rmchatbot_user(client: Client, message: Message):
|
125 |
await db.remove_chatbot(message.chat.id)
|
126 |
await message.reply_text("ok stopped gemini")
|
|
|
137 |
| filters.regex(r"\b(Randy|Rendi)\b(.*)", flags=re.IGNORECASE)
|
138 |
)
|
139 |
& (filters.private | filters.group)
|
140 |
+
& ~filters.command(DISABLE_COMMAND)
|
141 |
& ~filters.bot
|
142 |
& ~filters.via_bot
|
143 |
& ~filters.forwarded,
|
144 |
group=2,
|
145 |
)
|
146 |
+
@akeno.LogChannel(channel_id=-1002290885889, is_track=True)
|
147 |
async def chatbot_talk(client: Client, message: Message):
|
148 |
genai.configure(api_key=GOOGLE_API_KEY)
|
149 |
chat_user = await db.get_chatbot(message.chat.id)
|