Moved db query to core/client;py

Author: robinmahieu

bot.py

@@ -872,7 +872,9 @@ async def process_commands(self, message):
                         self.config["anon_reply_without_command"]
                     )
                 except ValueError:
-                    anon_reply_without_command = self.config.remove("anon_reply_without_command")
+                    anon_reply_without_command = self.config.remove(
+                        "anon_reply_without_command"
+                    )
 
                 if anon_reply_without_command:
                     await thread.reply(message, anonymous=True)

cogs/modmail.py

@@ -737,19 +737,7 @@ async def logs_responded(self, ctx, *, user: User = None):
         """
         user = user if user is not None else ctx.author
 
-        entries = []
-        async for l in self.bot.db.logs.find(
-            {
-                "messages": {
-                    "$elemMatch": {
-                        "author.id": str(user.id),
-                        "author.mod": True,
-                        "type": {"$in": ["anonymous", "thread_message"]},
-                    }
-                }
-            }
-        ):
-            entries.append(l)
+        entries = await self.bot.api.get_responded_logs(user.id)
 
         embeds = self.format_log_embeds(entries, avatar_url=self.bot.guild.icon_url)
 

core/clients.py

@@ -92,6 +92,23 @@ async def get_user_logs(self, user_id: Union[str, int]) -> list:
 
         return await self.logs.find(query, projection).to_list(None)
 
+    async def get_responded_logs(self, user_id: Union[str, int]) -> list:
+        entries = []
+        async for l in self.bot.db.logs.find(
+            {
+                "open": False,
+                "messages": {
+                    "$elemMatch": {
+                        "author.id": str(user_id),
+                        "author.mod": True,
+                        "type": {"$in": ["anonymous", "thread_message"]},
+                    }
+                }
+            }
+        ):
+            entries.append(l)
+        return entries
+
     async def get_log(self, channel_id: Union[str, int]) -> dict:
         logger.debug("Retrieving channel %s logs.", channel_id)
         return await self.logs.find_one({"channel_id": str(channel_id)})