Upload database.py
Browse files- Akeno/utils/database.py +13 -0
Akeno/utils/database.py
CHANGED
@@ -24,6 +24,7 @@ class Database:
|
|
24 |
self.gachabots = self.db["gachabots"]
|
25 |
self.cohere = self.db["cohere"]
|
26 |
self.chatbot = self.db["chatbot"]
|
|
|
27 |
self.antiarabic = self.db["antiarabic"]
|
28 |
self.gban = self.db["gban"]
|
29 |
self.gmute = self.db["gmute"]
|
@@ -635,4 +636,16 @@ class Database:
|
|
635 |
unset_data = {"user_id": None}
|
636 |
return await self.chatbot.update_one({"chat_id": chat_id}, {"$unset": unset_data})
|
637 |
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
638 |
db = Database(MONGO_URL)
|
|
|
24 |
self.gachabots = self.db["gachabots"]
|
25 |
self.cohere = self.db["cohere"]
|
26 |
self.chatbot = self.db["chatbot"]
|
27 |
+
self.backup_chatbot = self.db["backupchatbot"]
|
28 |
self.antiarabic = self.db["antiarabic"]
|
29 |
self.gban = self.db["gban"]
|
30 |
self.gmute = self.db["gmute"]
|
|
|
636 |
unset_data = {"user_id": None}
|
637 |
return await self.chatbot.update_one({"chat_id": chat_id}, {"$unset": unset_data})
|
638 |
|
639 |
+
async def _update_chatbot_chat_in_db(self, user_id, chatbot_chat):
|
640 |
+
await self.backup_chatbot.update_one(
|
641 |
+
{"user_id": user_id},
|
642 |
+
{"$set": {"chatbot_chat": chatbot_chat}},
|
643 |
+
upsert=True
|
644 |
+
)
|
645 |
+
|
646 |
+
async def _get_chatbot_chat_from_db(self, user_id):
|
647 |
+
user_data = await self.backup_chatbot.find_one({"user_id": user_id})
|
648 |
+
return user_data.get("chatbot_chat", []) if user_data else []
|
649 |
+
|
650 |
+
|
651 |
db = Database(MONGO_URL)
|