fix update

akn/clientmulti_bot.py

@@ -15,54 +15,63 @@ from pyrogram import __version__ as pyrogram_version
 from box import Box
 
 async def start_user() -> None:
-    sessions = await db.get_all_sessions()
+    sessions = await db.session.find({
+        "user_client": {
+            "$elemMatch": {
+                "is_active": True
+            }
+        }   
+    }).to_list(length=None)
     if not sessions:
         return
     active_clients = []
     for i, session_data in enumerate(sessions, 1):
-        api_id = session_data.get("api_id")
-        api_hash = session_data.get("api_hash")
-        session_str = session_data.get("session")
-        user_id = session_data.get("user_id", 0)
-        try:
-            if not (api_id, api_hash, session_str, user_id):
+        user_client = session_data.get("user_client", [])
+        for user in user_client:
+            if not user.get("is_active"):
+                continue
+            api_id = user.get("api_id")
+            api_hash = user.get("api_hash")
+            session_str = user.get("session_string")
+            user_id = user.get("user_id")
+            if not (api_id and api_hash and 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_sessions",
+                    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
-            client = Client(
-                name=f"UserBot_{i}_{user_id}",
-                api_id=api_id,
-                api_hash=api_hash,
-                session_string=session_str,
-                in_memory=False,
-                plugins=dict(root="akn.Akeno"),
-                workdir="/tmp/akn_sessions",
-                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
 
 async def start_magic_bot() -> None:
     sessions = await db.get_all_magic_bot()

akn/manage/account.py

@@ -21,7 +21,7 @@ import asyncio
 import requests
 import pyromod
 from asyncio.exceptions import TimeoutError
-from datetime import datetime, timedelta
+from datetime import datetime as dt, timedelta
 
 import requests
 from pymongo import MongoClient
@@ -339,7 +339,6 @@ async def robot(client: Client, message: Message):
 )
 async def contact_check(bot, message):
     if message.contact:
-        return await message.reply_text("Sorry this can't menu.")
         user_id = message.from_user.id
         if not await db_client.get_privacy_policy(user_id):
             return await message.reply_text("You must agree to the privacy policy first.")
@@ -349,9 +348,6 @@ async def contact_check(bot, message):
         phone = "+" + contact.phone_number
         client = Client(
             "{}".format(client_name),
-            app_version="latest",
-            device_model="Akeno AI Dev",
-            system_version="Linux",
             api_id=API_ID,
             api_hash=API_HASH
         )
@@ -444,26 +440,75 @@ async def contact_check(bot, message):
                 message.chat.id, "**ERROR:** `{}`".format(e),
             )
         session_string = await client.export_session_string()
-        await db_client.update_session(
-            user_id,
-            API_ID,
-            API_HASH,
-            session=session_string,
-            email=None,
-            phone_number=phone,
-            verified_password=new_code_password
-        )
-        add_userbot(user_id, API_ID, API_HASH, session_string, phone)
         await client.disconnect()
-        urlink = "https://telegra.ph//file/586a3867c3e16ca6bb4fa.jpg"
-        okey = "Please click the button below"
-        keyboard = InlineKeyboardMarkup(
-            [[InlineKeyboardButton(text="Starting Userbot", callback_data="startcontrol")]]
+        user_data = {
+            "user_id": user_id,
+            "is_active": True,
+            "created_at": dt.now().strftime("%Y-%m-%d %H:%M:%S"),
+            "first_name": message.from_user.first_name,
+            "username": message.from_user.username,
+            "phone_number": phone,
+            "session_string": session_string,
+        }
+        await db_client.session.update_one(
+            {"user_id": user_id},
+            {"$push": {"user_client": user_data}},
+            upsert=True
         )
+        user_start = Client(
+            "{}".format(client_name),
+            api_id=API_ID,
+            api_hash=API_HASH,
+            session_string=session_string,
+            plugins={"root": "akn.Akeno"}
+        )
+        await user_start.start()
         try:
-            await bot.send_photo(message.chat.id, photo=urlink, caption=okey, reply_markup=keyboard)
+            user = await user_start.get_me()
         except Exception as e:
-            return await bot.send_message(message.chat.id, "Error : {}".format(e))
+            await bot.send_message(
+                message.chat.id,
+                f"Error: {e}"
+            )
+            return
+        username = "@" + user.username if user.username else "N/A"
+        first_name = user.first_name
+        bttn_new = InlineKeyboardMarkup(
+            [
+                [
+                    InlineKeyboardButton(
+                        text="Channel",
+                        url="https://t.me/RendyProjects"
+                    )
+                ],
+            ]
+        )
+        try:
+            await user_start.join_chat("RendyProjects")
+        except UserIsBlocked:
+            await user_start.stop()
+            return await bot.send_message(
+                message.chat.id,
+                "You have been blocked. Please support @xtdevs"
+            )
+        except Exception as e:
+            await user_start.stop()
+            return await bot.send_message(message.chat.id, f"Error: {type(e).__name__}")
+        new_logs = ""
+        new_logs += "<b>Akeno Userbot [BUILDER]</b>\n"
+        new_logs += "<b>Name User:</b> {}\n".format(first_name)
+        new_logs += "<b>Username:</b> @{}\n".format(username)
+        new_logs += "<b>UserID:</b> {}\n".format(user_id)
+        await bot.send_message(
+            "KillerXSupport",
+            text=new_logs
+        )
+        await bot.send_photo(
+            message.chat.id,
+            photo="https://telegra.ph//file/586a3867c3e16ca6bb4fa.jpg",
+            caption=new_logs,
+            reply_markup=bttn_new
+        )
 
 @Client.on_message(
     filters.private