Added the use of config vars

Known issue: channel will still close when the bot is down

Author: Taaku18

bot.py

@@ -203,7 +203,21 @@ async def on_ready(self):
         else:
             await self.threads.populate_cache()
 
-
+        closures = self.config.get('closures', {})
+        for recipient_id, items in closures.items():
+            after = (datetime.datetime.fromisoformat(items['time']) -
+                     datetime.datetime.utcnow()).total_seconds()
+            if after < 0:
+                after = 0
+            thread = await self.threads.find(
+                recipient=self.get_user(recipient_id))
+
+            # TODO: Retrieve messages/replies when bot is down, from history?
+            await thread.close(closer=self.get_user(items['closer_id']),
+                               after=after,
+                               silent=items['silent'],
+                               delete_channel=items['delete_channel'],
+                               message=items['message'])
 
     async def process_modmail(self, message):
         """Processes messages sent to the bot."""

core/config.py

@@ -14,7 +14,9 @@ class ConfigManager:
         }
 
     internal_keys = {
-        'snippets', 'aliases', 'blocked', 'notification_squad', 'subscriptions'
+        'snippets', 'aliases', 'blocked',
+        'notification_squad', 'subscriptions',
+        'closures'
         }
 
     protected_keys = {

core/thread.py

@@ -55,6 +55,22 @@ async def close(self, *, closer, after=0, silent=False,
             self.close_task.cancel()
 
         if after > 0:
+            # TODO: Add somewhere to clean up broken closures
+            #  (when channel is already deleted)
+            closures = self.bot.config.get('closures', {})
+            now = datetime.datetime.utcnow()
+            items = {
+                # 'initiation_time': now.isoformat(),
+                'time': (now + datetime.timedelta(seconds=after)).isoformat(),
+                'closer_id': closer.id,
+                'silent': silent,
+                'delete_channel': delete_channel,
+                'message': message
+            }
+            closures[self.id] = items
+            self.bot.config['closure'] = closures
+            await self.bot.config.update()
+
             self.close_task = self.bot.loop.call_later(
                 after, self._close_after, closer,
                 silent, delete_channel, message)
@@ -326,6 +342,7 @@ async def find(self, *, recipient=None, channel=None):
             )
             if channel:
                 self.cache[recipient.id] = thread = Thread(self, recipient)
+                # TODO: Fix this:
                 thread.channel = channel
                 thread.ready = True
         finally: