fix update

akn/manage/account.py

@@ -427,8 +427,8 @@ async def contact_check(bot, message):
         await client.disconnect()
         now = dt.now().strftime("%Y-%m-%d %H:%M:%S")
         admin_buttons = InlineKeyboardMarkup([
-            [InlineKeyboardButton("✅ Approve", callback_data=f"approved_ub_{user_id}"),
-             InlineKeyboardButton("❌ Reject",  callback_data=f"rejected_ub_{user_id}")],
+            [InlineKeyboardButton("✅ Approve", callback_data=f"approvedub_{user_id}"),
+             InlineKeyboardButton("❌ Reject",  callback_data=f"rejectedub_{user_id}")],
             [InlineKeyboardButton("👤 View User", url=f"tg://user?id={user_id}")]
         ])
         user_data = {

akn/manage/approve_params.py

@@ -65,7 +65,15 @@ async def ubadmin_action(client: Client, callback: CallbackQuery):
             update_data["user_client.$.admin_action"]["reason"] = "No reason provided"
 
         update_result = await db_client.session.update_one(
-            {"user_id": int(user_id)},
+            {
+                "_id": request["_id"],
+                "user_client": {
+                    "$elemMatch": {
+                        "status": "pending",
+                        "user_id": int(user_id)
+                    }
+                }
+            },
             {"$set": update_data}
         )
 
@@ -119,7 +127,18 @@ async def handle_approvalub(client, callback, request, user_id, admin_id, admin_
             }
         }
         
-        await db_client.session.update_one({"user_id": int(user_id)}, update)
+        await db_client.session.update_one(
+            {
+                "_id": request["_id"],
+                "user_client": {
+                    "$elemMatch": {
+                        "status": "pending",
+                        "user_id": int(user_id)
+                    }
+                }
+            },
+            update
+        )
         await notify_userub(client, user_id, bot_user)
         await client.send_message(
             PRIVATE_LOGS,

test.py

@@ -1,2 +1,38 @@
-import os
-print("Lang files:", os.listdir("akn/langs"))
+import asyncio
+from motor.motor_asyncio import AsyncIOMotorClient
+
+client_tiktok = AsyncIOMotorClient("mongodb://localhost:27017/")
+db_tiktok = client_tiktok["Akeno"]
+collection = db_tiktok["session"]
+
+async def get_session_all():
+    session = await collection.find().to_list(length=None)
+    print(session)
+
+async def delete_session_all():
+    ok = await collection.delete_many({})
+    print("All sessions deleted.", ok.deleted_count)
+
+async def approve_session_all():
+    session = await collection.find().to_list(length=None)
+    for i in session:
+       for client in i["user_client"]:
+        if client["status"] == "approved":
+           await collection.update_one(
+              {
+                 "_id": i["_id"],
+                 "user_client": {
+                    "$elemMatch": {
+                       "status": "approved"
+                    }
+                }
+            },
+            {
+               "$set": {
+                    "user_client.$.status": "approved",
+                    "user_client.$.is_active": True,
+                }
+            }
+        )
+
+asyncio.run(delete_session_all())