|
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()) |
|
|