Update database.py
Browse files- database.py +0 -22
database.py
CHANGED
@@ -39,28 +39,6 @@ class Database:
|
|
39 |
LOGS.info(f"DatabaseErr: {e} ")
|
40 |
quit(1)
|
41 |
|
42 |
-
async def process_unfreezes(client):
|
43 |
-
while True:
|
44 |
-
now = dt.now()
|
45 |
-
expired = await self.user_blacklists.find({
|
46 |
-
"is_frozen": True,
|
47 |
-
"unfreeze_at": {"$lte": now}
|
48 |
-
})
|
49 |
-
for user in expired:
|
50 |
-
await self.user_blacklists.update_one(
|
51 |
-
{"_id": user["_id"]},
|
52 |
-
{"$set": {"is_frozen": False}}
|
53 |
-
)
|
54 |
-
try:
|
55 |
-
await client.send_message(
|
56 |
-
user["user_id"],
|
57 |
-
"✅ Your restrictions have been lifted"
|
58 |
-
)
|
59 |
-
except:
|
60 |
-
pass
|
61 |
-
|
62 |
-
await asyncio.sleep(300)
|
63 |
-
|
64 |
async def _close(self):
|
65 |
await self.client.close()
|
66 |
|
|
|
39 |
LOGS.info(f"DatabaseErr: {e} ")
|
40 |
quit(1)
|
41 |
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
42 |
async def _close(self):
|
43 |
await self.client.close()
|
44 |
|