Hook: Complete handling of modify events

hook.wsgi

@@ -7,7 +7,6 @@ import psycopg2
 import psycopg2.extras
 import traceback
 import dateutil.parser
-# import dateutil.tz
 
 ### Configuration ###
 
@@ -43,11 +42,8 @@ def db_query(query, args=()):
 
 # FIXME: Move to shared code?
 
-def parse_time(iso_time, tz_name):
-    utc = dateutil.parser.isoparse(iso_time)
-    # tz = dateutil.tz.gettz(tz_name)
-    # return utc.astimezone(tz)
-    return utc
+def parse_time(iso_time):
+    return dateutil.parser.isoparse(iso_time)
 
 ### Application ###
 
@@ -80,12 +76,10 @@ class HookApp:
                 uid,
                 meeting['topic'],
                 meeting['type'],
-                parse_time(meeting['start_time'], meeting['timezone']),
+                parse_time(meeting['start_time']),
                 meeting['duration'],
             ))
 
-        db_connection.commit()
-
 
     def create_recurring_meeting(self, uid, meeting):
         meeting_id = meeting["id"]
@@ -105,12 +99,10 @@ class HookApp:
                     uid,
                     meeting['topic'],
                     meeting['type'],
-                    parse_time(occ['start_time'], meeting['timezone']),
+                    parse_time(occ['start_time']),
                     occ['duration'],
                 ))
 
-        db_connection.commit()
-
 
     def create_meeting(self, js):
         payload = js["payload"]
@@ -145,8 +137,6 @@ class HookApp:
                 meeting_id,
             ))
 
-        db_connection.commit()
-
 
     def delete_recurring_meeting(self, meeting):
         meeting_id = meeting["id"]
@@ -165,8 +155,6 @@ class HookApp:
                     occ_id,
                 ))
 
-        db_connection.commit()
-
 
     def delete_meeting(self, js):
         payload = js["payload"]
@@ -183,6 +171,138 @@ class HookApp:
             return
 
 
+    def update_common_attrs(self, meeting_id, occurrence_id, new):
+        if "topic" in new:
+            self.log(f"Meeting {meeting_id}.{occurrence_id}: Updating topic")
+            db_query("UPDATE zoom_meetings SET topic=%s WHERE meeting_id=%s AND (occurrence_id=%s OR %s = '0')",
+                     (new["topic"], meeting_id, occurrence_id, occurrence_id))
+
+        for a in ['uuid', 'host_id']:
+            if a in new:
+                self.log(f"Meeting {meeting_id}.{occurrence_id}: Change of {a} not supported")
+
+
+    def update_schedule(self, meeting_id, occurrence_id, new):
+        if "start_time" in new:
+            self.log(f"Meeting {meeting_id}.{occurrence_id}: Updating start time")
+            db_query("UPDATE zoom_meetings SET start_time=%s WHERE meeting_id=%s AND (occurrence_id=%s OR %s = '0')",
+                     (parse_time(new['start_time']), meeting_id, occurrence_id, occurrence_id))
+
+        if "duration" in new:
+            self.log(f"Meeting {meeting_id}.{occurrence_id}: Updating duration")
+            db_query("UPDATE zoom_meetings SET duration=%s WHERE meeting_id=%s AND (occurrence_id=%s OR %s = '0')",
+                     (new['duration'], meeting_id, occurrence_id, occurrence_id))
+
+
+    def update_regular_meeting(self, meeting_id, old, new):
+        self.log(f"Meeting {meeting_id}: Updating regular meeting")
+        self.update_common_attrs(meeting_id, 0, new)
+        self.update_schedule(meeting_id, 0, new)
+
+
+    def update_recurring_meeting_single(self, meeting_id, old, new):
+        self.log(f"Meeting {meeting_id}: Updating single occurrence")
+        for occ in new["occurrences"]:
+            self.update_common_attrs(meeting_id, occ["occurrence_id"], new)
+            self.update_schedule(meeting_id, occ["occurrence_id"], new)     # e.g., duration can be set here
+            self.update_schedule(meeting_id, occ["occurrence_id"], occ)
+
+
+    def update_recurring_meeting_all(self, meeting_id, old, new):
+        meeting_id = new["id"]
+        self.log(f"Meeting {meeting_id}: Updating all occurrences")
+
+        if "occurrences" not in new:
+            self.update_common_attrs(meeting_id, 0, new)
+            return
+
+        db_query("SELECT * FROM zoom_meetings WHERE meeting_id=%s", (meeting_id,))
+        orig = db.fetchone()
+        if orig is None:
+            self.log(f"Meeting {meeting_id}: Update did not find previous version")
+            return
+
+        db_query("DELETE FROM zoom_meetings WHERE meeting_id=%s", (meeting_id,))
+
+        for occ in new["occurrences"]:
+            occurrence_id = occ["occurrence_id"]
+            self.log(f"Meeting {meeting_id}.{occurrence_id}: Re-creating")
+
+            db_query("""
+                    INSERT INTO zoom_meetings
+                    (meeting_id, uuid, occurrence_id, host_id, topic, type, start_time, duration)
+                    VALUES (%s, %s, %s, %s, %s, %s, %s, %s)
+                """, (
+                    meeting_id,
+                    new.get('uuid', orig.uuid),
+                    occurrence_id,
+                    orig.host_id,
+                    new.get('topic', orig.topic),
+                    new.get('type', orig.type),
+                    parse_time(occ['start_time']),
+                    occ['duration'],
+                ))
+
+
+    def update_regular_to_recurring(self, meeting_id, old, new):
+        self.log(f"Meeting {meeting_id}: Type change to recurring")
+        self.update_recurring_meeting_all(meeting_id, old, new)
+
+
+    def update_recurring_to_regular(self, meeting_id, old, new):
+        self.log(f"Meeting {meeting_id}: Type change to regular")
+
+        db_query("SELECT * FROM zoom_meetings WHERE meeting_id=%s", (meeting_id,))
+        orig = db.fetchone()
+        if orig is None:
+            self.log(f"Meeting {meeting_id}: Update did not find previous version")
+            return
+
+        db_query("DELETE FROM zoom_meetings WHERE meeting_id=%s", (meeting_id,))
+
+        db_query("""
+                INSERT INTO zoom_meetings
+                (meeting_id, uuid, host_id, topic, type, start_time, duration)
+                VALUES (%s, %s, %s, %s, %s, %s, %s)
+            """, (
+                meeting_id,
+                new.get('uuid', orig.uuid),
+                orig.host_id,
+                new.get('topic', orig.topic),
+                new['type'],
+                parse_time(new['start_time']),
+                new['duration'],
+            ))
+
+
+    def update_meeting(self, js):
+        payload = js["payload"]
+        new = payload["object"]
+        old = payload["old_object"]
+        meeting_id = new["id"]
+
+        new_type = new.get("type", -1)
+        old_type = old.get("type", -1)
+        if old_type != new_type:
+            if old_type == 2 and new_type == 8:
+                self.update_regular_to_recurring(meeting_id, old, new)
+            elif old_type == 8 and new_type == 2:
+                self.update_recurring_to_regular(meeting_id, old, new)
+            else:
+                self.log(f"Meeting {meeting_id}: Unsupported type change from {old_type} to {new_type}")
+            return
+
+        scope = payload.get("scope", "")
+        if scope == "":
+            self.update_regular_meeting(meeting_id, old, new)
+        elif scope == "all":
+            self.update_recurring_meeting_all(meeting_id, old, new)
+        elif scope == "single":
+            self.update_recurring_meeting_single(meeting_id, old, new)
+        else:
+            self.log(f"Meeting {meeting_id}: Unsupported update scope {scope}")
+
+
     def run(self):
         method = self.env['REQUEST_METHOD']
         if method != 'POST':
@@ -201,12 +321,17 @@ class HookApp:
             self.create_meeting(js)
         elif event == "meeting.deleted":
             self.delete_meeting(js)
+        elif event == "meeting.updated":
+            self.update_meeting(js)
         else:
             self.log(f"Unknown event: {event}")
 
+        db_connection.commit()
+
         self.wsgi_start("204 No Content", [])
         return b""
 
+
 def application(env, start_response):
     app = HookApp(env, start_response)
     try: