Add quick_populate_cache method to ThreadManager

quick_populate_cache uses the database as the source of truth, and pulls all logs matching a channel ID in the server.

bot.py

@@ -583,7 +583,7 @@ async def on_ready(self):
             )
             logger.line()
 
-        await self.threads.populate_cache()
+        await self.threads.quick_populate_cache()
 
         # closures
         closures = self.config["closures"]

core/clients.py

@@ -567,6 +567,9 @@ 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)})
 
+    async def get_logs(self, channel_id: List[Union[str, int]]) -> dict:
+        return await self.logs.find({"channel_id": {"$in": [str(i) for i in channel_id]}}).to_list(None)
+
     async def get_log_link(self, channel_id: Union[str, int]) -> str:
         doc = await self.get_log(channel_id)
         logger.debug("Retrieving log link for channel %s.", channel_id)

core/thread.py

@@ -4,6 +4,8 @@
 import functools
 import io
 import re
+from time import perf_counter
+
 import time
 import traceback
 import typing
@@ -1244,6 +1246,7 @@ async def add_users(self, users: typing.List[typing.Union[discord.Member, discor
 
         topic += f"\nOther Recipients: {ids}"
 
+        # Add recipients to database
         await self.bot.api.add_recipients(self._channel.id, users)
 
         await self.channel.edit(topic=topic)
@@ -1273,11 +1276,14 @@ class ThreadManager:
 
     def __init__(self, bot):
         self.bot = bot
-        self.cache = {}
+        self.cache: typing.Dict[int, Thread] = {}
 
     async def populate_cache(self) -> None:
+        # time method runtime
+        start = perf_counter()
         for channel in self.bot.modmail_guild.text_channels:
             await self.find(channel=channel)
+        logger.info("Cache populated in %fs.", time.perf_counter() - start)
 
     def __len__(self):
         return len(self.cache)
@@ -1288,6 +1294,24 @@ def __iter__(self):
     def __getitem__(self, item: str) -> Thread:
         return self.cache[item]
 
+    async def quick_populate_cache(self) -> None:
+        start = perf_counter()
+
+        # create a list containing the id of every text channel in the modmail guild
+        channel_ids = [channel.id for channel in self.bot.modmail_guild.text_channels]
+        logs = await self.bot.api.get_logs(channel_ids)
+
+        for log in logs:
+            recipients = log["other_recipients"]
+
+            tasks = [self.bot.get_or_fetch_user(user_data["id"]) for user_data in recipients]
+            recipient_users: list[discord.Member] = await asyncio.gather(*tasks)
+
+            self.cache[log["recipient"]["id"]] = Thread(
+                self, recipient=log["creator"]["id"], channel=log["channel_id"], other_recipients=recipient_users
+            )
+        logger.debug("Cache populated in %fs.", perf_counter() - start)
+
     async def find(
         self,
         *,