Update chatbot/plugins/chat.py
Browse files- chatbot/plugins/chat.py +14 -5
chatbot/plugins/chat.py
CHANGED
@@ -270,9 +270,17 @@ def split_message(text: str) -> List[str]:
|
|
270 |
async def check_steal_channel_id(client, event: ChatMemberUpdated):
|
271 |
old_status = event.old_chat_member.status if event.old_chat_member else None
|
272 |
new_status = event.new_chat_member.status if event.new_chat_member else None
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
273 |
try:
|
274 |
await db.backup_chatbot.update_one(
|
275 |
-
{"user_id":
|
276 |
{"$set": {
|
277 |
"channel_id": event.chat.id,
|
278 |
"can_post_messages": event.new_chat_member.privileges.can_post_messages
|
@@ -280,8 +288,9 @@ async def check_steal_channel_id(client, event: ChatMemberUpdated):
|
|
280 |
upsert=True
|
281 |
)
|
282 |
await client.send_message(
|
283 |
-
|
284 |
-
f"Successfully connected to your [`{event.chat.id}`] channel"
|
|
|
285 |
)
|
286 |
# LOGS.info(f"Update Channel: {event.new_chat_member}")
|
287 |
except Exception as e:
|
@@ -340,15 +349,15 @@ async def auto_post_channel(client, callback):
|
|
340 |
who_post = data.get("channel_id", None)
|
341 |
if not who_post:
|
342 |
return await callback.answer("@GeminiAIDev_bot add to your channel as admin!", True)
|
343 |
-
await callback.answer("Ok process", False)
|
344 |
if data.get("can_post_messages", False):
|
|
|
345 |
await client.send_photo(
|
346 |
who_post,
|
347 |
photo=file_id,
|
348 |
caption=data.get("translate_text", "")
|
349 |
)
|
350 |
keyboard = create_keyboard(user_id=user_id)
|
351 |
-
await callback.answer("Posted to Your Channel Check Now", True)
|
352 |
await callback.edit_message_reply_markup(reply_markup=keyboard)
|
353 |
return
|
354 |
|
|
|
270 |
async def check_steal_channel_id(client, event: ChatMemberUpdated):
|
271 |
old_status = event.old_chat_member.status if event.old_chat_member else None
|
272 |
new_status = event.new_chat_member.status if event.new_chat_member else None
|
273 |
+
user_id = event.new_chat_member.promoted_by.id if event.new_chat_member.promoted_by else None
|
274 |
+
if not user_id:
|
275 |
+
return
|
276 |
+
keyboard = []
|
277 |
+
keyboard.append([
|
278 |
+
InlineKeyboardButton("🔎 View Channel", url=f"https://t.me/{event.chat.username}"),
|
279 |
+
InlineKeyboardButton("❌ Close", callback_data="closedd")
|
280 |
+
])
|
281 |
try:
|
282 |
await db.backup_chatbot.update_one(
|
283 |
+
{"user_id": user_id},
|
284 |
{"$set": {
|
285 |
"channel_id": event.chat.id,
|
286 |
"can_post_messages": event.new_chat_member.privileges.can_post_messages
|
|
|
288 |
upsert=True
|
289 |
)
|
290 |
await client.send_message(
|
291 |
+
user_id,
|
292 |
+
f"Successfully connected to your [`{event.chat.id}`] channel",
|
293 |
+
reply_markup=InlineKeyboardMarkup(keyboard)
|
294 |
)
|
295 |
# LOGS.info(f"Update Channel: {event.new_chat_member}")
|
296 |
except Exception as e:
|
|
|
349 |
who_post = data.get("channel_id", None)
|
350 |
if not who_post:
|
351 |
return await callback.answer("@GeminiAIDev_bot add to your channel as admin!", True)
|
352 |
+
# await callback.answer("Ok process", False)
|
353 |
if data.get("can_post_messages", False):
|
354 |
+
await callback.answer("Posted to Your Channel Check Now", True)
|
355 |
await client.send_photo(
|
356 |
who_post,
|
357 |
photo=file_id,
|
358 |
caption=data.get("translate_text", "")
|
359 |
)
|
360 |
keyboard = create_keyboard(user_id=user_id)
|
|
|
361 |
await callback.edit_message_reply_markup(reply_markup=keyboard)
|
362 |
return
|
363 |
|