Created an automatic job nagger periodic

periodicals.py

@@ -1,9 +1,12 @@
 import asyncio
 from datetime import datetime
+from typing import Optional, List
 
 from slackclient import SlackClient
 
 import channel_util
+import house_management
+import identifier
 import slack_util
 
 
@@ -28,3 +31,61 @@ class ItsTenPM(slack_util.Passive):
 
             # Wait a while before trying it again, to prevent duplicates
             await asyncio.sleep(60)
+
+
+class RemindJobs(slack_util.Passive):
+    async def run(self, slack: SlackClient) -> None:
+        while True:
+            # Get the end of the current day (Say, 9PM)
+            today_remind_time = datetime.now().replace(hour=22, minute=0, second=0)
+
+            # Get the current day of week
+            dow = ["Monday",
+                   "Tuesday",
+                   "Wednesday",
+                   "Thursday",
+                   "Friday",
+                   "Saturday",
+                   "Sunday"][datetime.now().weekday()]
+
+            # Sleep until that time
+            delay = seconds_until(today_remind_time)
+            await asyncio.sleep(delay)
+
+            # Now it is that time. Get the current jobs
+            assigns = await house_management.import_assignments()
+
+            # Filter to incomplete, and today
+            def valid_filter(a: Optional[house_management.JobAssignment]):
+                # If it doesn't exist, it a thot
+                if a is None:
+                    return False
+                # If its not today, we shouldn't nag
+                if a.job.day_of_week.lower() != dow.lower():
+                    return False
+                # If it is unassigned, we can't nag
+                if a.assignee is None:
+                    return False
+                # If its been signed off, no need to nag
+                if a.signer is not None:
+                    return False
+                # If the brother wasn't recognized, don't try nagging
+                if not a.assignee.is_valid():
+                    return False
+                return True
+
+            assigns: List[house_management.JobAssignment] = [a for a in assigns if valid_filter(a)]
+
+            # Now, we want to nag each person. If we don't actually know who they are, so be it.
+            for a in assigns:
+                # Get the relevant slack ids
+                assignee_ids = identifier.lookup_brother_userids(a.assignee)
+
+                # For each, send them a DM
+                for slack_id in assignee_ids:
+                    dm_id = slack_util.im_channel_for_id(slack, slack_id)
+                    msg = "Your job ({}) is currently not signed off. Don't forget!".format(a.job.pretty_fmt())
+                    slack_util.send_message(slack, msg, dm_id)
+
+            # Take a break to ensure no double-shots
+            await asyncio.sleep(10)