Update

akn/manage/approve_params.py

@@ -44,7 +44,8 @@ async def ubadmin_action(client: Client, callback: CallbackQuery):
         action_type = action.split('_')[0]
         admin_id = callback.from_user.id
         admin_mention = callback.from_user.mention
-
+        if admin_id != 6477856957:
+            return await callback.answer("❌ Only Developer", show_alert=True)
         request = await db_client.session.find_one({"user_id": int(user_id)})
         if not request:
             await callback.answer("❌ User request not found!", show_alert=True)
@@ -131,12 +132,13 @@ async def handle_approvalub(client, callback, request, user_id, admin_id, admin_
         )
         await notify_userub(client, user_id, bot_user)
         await client.send_message(
-            PRIVATE_LOGS,
+            "AkenoXDevSupport",
             f"✅ Userbot Approved Successfully\n\n"
             f"👤 User: {request.get('username', 'N/A')} ({user_id})\n"
             f"⭐ Username: {bot_user.username}\n"
             f"🛠 Approved by: {admin_mention}\n"
-            f"⏰ Time: {dt.now().strftime('%Y-%m-%d %H:%M:%S')}"
+            f"⏰ Time: {dt.now().strftime('%Y-%m-%d %H:%M:%S')}",
+            message_thread_id=23159
         )
     except Exception as e:
         LOGS.error(f"Approval error: {str(e)}")
@@ -165,11 +167,12 @@ async def handle_errorub(client, callback, error, action, admin_mention):
         f"{callback.message.text}\n\n❌ Error: {str(error)}"
     )
     await client.send_message(
-        PRIVATE_LOGS,
+        "AkenoXDevSupport",
         f"🚨 Admin Action Error\n\n"
         f"Action: {action}\n"
         f"Admin: {admin_mention}\n"
-        f"Error: {str(error)}"
+        f"Error: {str(error)}",
+        message_thread_id=23245
     )
 
 @ren.on_callback_query(filters.regex(r"^(rejected_alldl|pending_alldl|approved_alldl)_(\d+)_(\w+)$"))
@@ -180,7 +183,8 @@ async def handle_admin_action(client: Client, callback: CallbackQuery):
     action_type = action.split('_')[0]
     admin_id = callback.from_user.id
     admin_mention = callback.from_user.mention
-
+    if admin_id != 6477856957:
+        return await callback.answer("❌ Only Developer", show_alert=True)
     try:
         request = await db_client.alldl_bot.find_one({"user_id": int(user_id)})
         if not request:
@@ -287,12 +291,13 @@ async def handle_admin_action(client: Client, callback: CallbackQuery):
                 )
 
                 await client.send_message(
-                    PRIVATE_LOGS,
+                    "AkenoXDevSupport",
                     f"✅ Bot Approved Successfully\n\n"
                     f"👤 User: {request.get('username', 'N/A')} ({user_id})\n"
                     f"🤖 Bot: {bot_username}\n"
                     f"🛠 Approved by: {admin_mention}\n"
-                    f"⏰ Time: {dt.now().strftime('%Y-%m-%d %H:%M:%S')}"
+                    f"⏰ Time: {dt.now().strftime('%Y-%m-%d %H:%M:%S')}",
+                    message_thread_id=23159
                 )
 
             except Exception as e:
@@ -311,11 +316,12 @@ async def handle_admin_action(client: Client, callback: CallbackQuery):
                     }
                 )
                 await client.send_message(
-                    PRIVATE_LOGS,
+                    "AkenoXDevSupport",
                     f"❌ Bot Approval Failed\n\n"
                     f"User ID: {user_id}\n"
                     f"Error: {str(e)}\n"
-                    f"UUID: `{uuid}`"
+                    f"UUID: `{uuid}`",
+                    message_thread_id=23245
                 )
                 await client.send_message(
                     user_id,
@@ -340,17 +346,18 @@ async def handle_admin_action(client: Client, callback: CallbackQuery):
 
     except Exception as e:
         LOGS.error(f"Admin action error: {str(e)}")
-        await callback.answer("⚠️ An error occurred!", show_alert=True)
+        await callback.answer("⚠️ error!", show_alert=True)
         await callback.message.edit_text(
             f"{callback.message.text}\n\n"
             f"❌ Error: {str(e)}"
         )
         await client.send_message(
-            PRIVATE_LOGS,
+            "AkenoXDevSupport",
             f"🚨 Admin Action Error\n\n"
             f"Action: {action}\n"
             f"Admin: {admin_mention}\n"
-            f"Error: {str(e)}"
+            f"Error: {str(e)}",
+            message_thread_id=23245
         )
 
 @ren.on_callback_query(filters.regex(r"^(approve_capt|reject_capt)_(\d+)$"))
@@ -358,7 +365,8 @@ async def handle_captbot_action(client, callback: CallbackQuery):
     global storage_running
     action, user_id = callback.matches[0].groups()
     action_type = action.replace("_capt", "")
-    
+    if callback.from_user.id != 6477856957:
+        return await callback.answer("❌ Only Developer", show_alert=True)
     update_data = {
         "status": "approved" if action_type == "approve" else "rejected",
         "admin_action": {
@@ -385,7 +393,11 @@ async def handle_captbot_action(client, callback: CallbackQuery):
             storage_running[user_id] = user_bots
         except Exception as e:
             await client.send_message(user_id, "Sorry Try Again")
-            await client.send_message(PRIVATE_LOGS, f"Error {e}")
+            await client.send_message(
+                "AkenoXDevSupport",
+                f"Error captcha {str(e)}",
+                message_thread_id=23245
+            )
             return
             
         try:
@@ -426,7 +438,11 @@ async def handle_captbot_action(client, callback: CallbackQuery):
                 upsert=True
             )
         except Exception as e:
-            await client.send_message(PRIVATE_LOGS, f"Error {e}")
+            await client.send_message(
+                "AkenoXDevSupport",
+                f"Error captcha {str(e)}",
+                message_thread_id=23245
+            )
             await client.send_message(user_id, "Sorry Try Again")
             return
     
@@ -443,7 +459,8 @@ async def handle_sesibot_action(client, callback: CallbackQuery):
     global storage_running
     action, user_id = callback.matches[0].groups()
     action_type = action.replace("_sesibot", "")
-    
+    if callback.from_user.id != 6477856957:
+        return await callback.answer("❌ Only Developer", show_alert=True)
     update_data = {
         "status": "approved" if action_type == "approve" else "rejected",
         "admin_action": {
@@ -470,7 +487,11 @@ async def handle_sesibot_action(client, callback: CallbackQuery):
             storage_running[user_id] = user_bots
         except Exception as e:
             await client.send_message(user_id, "Sorry Try Again")
-            await client.send_message(PRIVATE_LOGS, f"Error {e}")
+            await client.send_message(
+                "AkenoXDevSupport",
+                f"Error sesibot {str(e)}",
+                message_thread_id=23245
+            )
             return
             
         try:
@@ -507,7 +528,11 @@ async def handle_sesibot_action(client, callback: CallbackQuery):
                 upsert=True
             )
         except Exception as e:
-            await client.send_message(PRIVATE_LOGS, f"Error {e}")
+            await client.send_message(
+                "AkenoXDevSupport",
+                f"Error sesibot {str(e)}",
+                message_thread_id=23245
+            )
             await client.send_message(user_id, "Sorry Try Again")
             return
     
@@ -524,7 +549,8 @@ async def handle_magicbot_action(client, callback: CallbackQuery):
     global storage_running
     action, user_id = callback.matches[0].groups()
     action_type = action.replace("_magicbot", "")
-    
+    if callback.from_user.id != 6477856957:
+        return await callback.answer("❌ Only Developer", show_alert=True)
     update_data = {
         "status": "approved" if action_type == "approve" else "rejected",
         "admin_action": {
@@ -551,7 +577,11 @@ async def handle_magicbot_action(client, callback: CallbackQuery):
             storage_running[user_id] = user_bots
         except Exception as e:
             await client.send_message(user_id, "Sorry Try Again")
-            await client.send_message(PRIVATE_LOGS, f"Error {e}")
+            await client.send_message(
+                "AkenoXDevSupport",
+                f"Error magic {str(e)}",
+                message_thread_id=23245
+            )
             return
             
         try:
@@ -592,7 +622,11 @@ async def handle_magicbot_action(client, callback: CallbackQuery):
                 upsert=True
             )
         except Exception as e:
-            await client.send_message(PRIVATE_LOGS, f"Error {e}")
+            await client.send_message(
+                "AkenoXDevSupport",
+                f"Error Magic {str(e)}",
+                message_thread_id=23245
+            )
             await client.send_message(user_id, "Sorry Try Again")
             return
     
@@ -609,7 +643,8 @@ async def handle_ytbot_action(client, callback: CallbackQuery):
     global storage_running
     action, user_id = callback.matches[0].groups()
     action_type = action.replace("_magicbot", "")
-    
+    if callback.from_user.id != 6477856957:
+        return await callback.answer("❌ Only Developer", show_alert=True)
     update_data = {
         "status": "approved" if action_type == "approve" else "rejected",
         "admin_action": {
@@ -635,7 +670,11 @@ async def handle_ytbot_action(client, callback: CallbackQuery):
             await user_bots.start()
         except Exception as e:
             await client.send_message(user_id, "Sorry Try Again")
-            await client.send_message(PRIVATE_LOGS, f"Error {e}")
+            await client.send_message(
+                "AkenoXDevSupport",
+                f"Error ytbot {str(e)}",
+                message_thread_id=23245
+            )
             return
             
         try:
@@ -676,7 +715,11 @@ async def handle_ytbot_action(client, callback: CallbackQuery):
                 upsert=True
             )
         except Exception as e:
-            await client.send_message(PRIVATE_LOGS, f"Error {e}")
+            await client.send_message(
+                "AkenoXDevSupport",
+                f"Error Ytbot {str(e)}",
+                message_thread_id=23245
+            )
             await client.send_message(user_id, "Sorry Try Again")
             return
     
@@ -693,7 +736,8 @@ async def handle_geminibot_action(client, callback: CallbackQuery):
     global storage_running
     action, user_id = callback.matches[0].groups()
     action_type = action.replace("_geminibot", "")
-    
+    if callback.from_user.id != 6477856957:
+        return await callback.answer("❌ Only Developer", show_alert=True)
     update_data = {
         "status": "approved" if action_type == "approve" else "rejected",
         "admin_action": {
@@ -761,7 +805,11 @@ async def handle_geminibot_action(client, callback: CallbackQuery):
                 upsert=True
             )
         except Exception as e:
-            await client.send_message(PRIVATE_LOGS, f"Error {e}")
+            await client.send_message(
+                "AkenoXDevSupport",
+                f"Error Gemini {str(e)}",
+                message_thread_id=23245
+            )
             await client.send_message(user_id, "Sorry Try Again")
             return