Update chatbot/plugins/chat.py

chatbot/plugins/chat.py

@@ -267,10 +267,21 @@ def split_message(text: str) -> List[str]:
 @Client.on_chat_member_updated(
     filters.channel
 )
-async def check_steal_id(client, event: ChatMemberUpdated):
+async def check_steal_channel_id(client, event: ChatMemberUpdated):
     old_status = event.old_chat_member.status if event.old_chat_member else None
     new_status = event.new_chat_member.status if event.new_chat_member else None
-    LOGS.info(f"Update Channel: {event}")
+    try:
+        await db.backup_chatbot.update_one(
+            {"user_id": event.new_chat_member.promoted_by.id},
+            {"$set": {
+                "channel_id": event.chat.id,
+                "can_post_messages": event.new_chat_member.privileges.can_post_messages
+            }},
+            upsert=True
+        )
+        LOGS.info(f"Update Channel: {event.new_chat_member}")
+    except Exception as e:
+        LOGS.error(f"Error check_steal_channel_id: {str(e)}")
 
 @Client.on_callback_query(filters.regex("^cancels"))
 async def cancel_(client, callback_query):
@@ -324,14 +335,16 @@ async def auto_post_channel(client, callback):
                 return await callback.answer("Can't found file_id", True)
             who_post = data.get("channel_id", None)
             if not who_post:
-                return await callback.answer("Can't found channel id", True)
+                return await callback.answer("@GeminiAIDev_bot add to your channel as admin!", True)
             await callback.answer("Ok process", False)
-            await client.send_photo(
-                who_post,
-                photo=file_id,
-                caption=data.get("translate_text", "")
-            )
-            await callback.answer("Posted to Your Channel Check Now", True)
+            if data.get("can_post_messages", False):
+                await client.send_photo(
+                    who_post,
+                    photo=file_id,
+                    caption=data.get("translate_text", "")
+                )
+                return await callback.answer("Posted to Your Channel Check Now", True)
+            return await callback.answer("Permissions: can_post_messages", True)
         return await callback.answer("Need Channel as admin", True)
     except Exception as e:
         LOGS.error(f"auto_post failed: {str(e)}")