Fix try

akn/clientmulti_bot.py

@@ -14,63 +14,78 @@ from akn import ids, gemini_bot_id
 from pyrogram import __version__ as pyrogram_version
 from box import Box
 
-async def start_user() -> None:
-    sessions = await db.session.find({
-        "user_client": {
-            "$elemMatch": {
-                "is_active": True,
-                "status": "approved"
+async def start_user():
+    try:
+        sessions = await db.session.find({
+            "user_client": {
+                "$elemMatch": {
+                    "is_active": True,
+                    "status": "approved"
+                }
             }
-        }   
-    }).to_list(length=None)
-    if not sessions:
-        return
-    active_clients = []
-    for i, session_data in enumerate(sessions, 1):
-        user_client = session_data.get("user_client", [])
-        for user in user_client:
-            if not (user.get("status") == "approved" and user.get("is_active")):
-                continue
-            session_str = user.get("session_string")
-            user_id = user.get("user_id")
-            if not (session_str and user_id):
-                continue
-            try:
-                client = Client(
-                    name=f"UserBot_{i}_{user_id}",
-                    api_id=API_ID,
-                    api_hash=API_HASH,
-                    session_string=session_str,
-                    plugins=dict(root="akn.Akeno"),
-                    workdir="/tmp/akn_userbot",
-                    app_version="UserBot/latest",
-                    device_model="Anonymous",
-                    system_version="Linux/Kernel-6.5",
-                    sleep_threshold=30
-                )
-                await client.start()
-                me = await client.get_me()
-                if me.id != user_id:
-                    raise ValueError(f"Session user_id mismatch (expected {user_id}, got {me.id})")
-                ids.append(user_id)
-                LOGS.info(f"✅ Started User #{i}: Name: {me.first_name}")
-                active_clients.append(client)
-                asyncio.create_task(
-                    _check_session_health(client, user_id),
-                    name=f"health_monitor_{user_id}"
-                )
-            except (
-                UserDeactivatedBan,
-                AuthKeyDuplicated,
-                UserDeactivated,
-                AuthKeyUnregistered,
-                SessionRevoked
-            ) as e:
-                await _handle_dead_session(user_id, e)
-                continue
-            except Exception as e:
-                LOGS.error(f"⚠️ User #{i} failed: {type(e).__name__}: {str(e)}")
-                continue
+        }).to_list(length=None)
+
+        if not sessions:
+            LOGS.warning("No approved and active user sessions found.")
+            return
+
+        active_clients = []
+
+        for i, session_data in enumerate(sessions, 1):
+            user_client = session_data.get("user_client", [])
+            for user in user_client:
+                if not (user.get("status") == "approved" and user.get("is_active")):
+                    continue
+
+                session_str = user.get("session_string")
+                user_id = user.get("user_id")
+
+                if not (session_str and user_id):
+                    continue
+
+                try:
+                    client = Client(
+                        name=f"UserBot_{i}_{user_id}",
+                        api_id=API_ID,
+                        api_hash=API_HASH,
+                        session_string=session_str,
+                        plugins=dict(root="akn.Akeno"),
+                        workdir="/tmp/akn_userbot",
+                        app_version="UserBot/latest",
+                        device_model="Anonymous",
+                        system_version="Linux/Kernel-6.5",
+                        sleep_threshold=30
+                    )
+                    await client.start()
+                    me = await client.get_me()
+                    if me.id != user_id:
+                        raise ValueError(f"Session user_id mismatch (expected {user_id}, got {me.id})")
+
+                    ids.append(user_id)
+                    LOGS.info(f"✅ Started User #{i}: Name: {me.first_name}")
+                    active_clients.append(client)
+
+                    asyncio.create_task(
+                        _check_session_health(client, user_id),
+                        name=f"health_monitor_{user_id}"
+                    )
+
+                except (
+                    UserDeactivatedBan,
+                    AuthKeyDuplicated,
+                    UserDeactivated,
+                    AuthKeyUnregistered,
+                    SessionRevoked
+                ) as e:
+                    await _handle_dead_session(user_id, e)
+                    continue
+
+                except Exception as e:
+                    LOGS.error(f"⚠️ User #{i} failed: {type(e).__name__}: {str(e)}")
+                    continue
+
+    except Exception as err:
+        LOGS.error(f"start_user() crashed: {type(err).__name__}: {err}")
 
 async def start_magic_bot() -> None:
     sessions = await db.get_all_magic_bot()