ignore old events

lib/debezium.py

@@ -1,6 +1,15 @@
+from datetime import datetime
+
 import msgspec
 
 
+class Source(msgspec.Struct):
+    ts_ms: int
+
+    def timestamp(self) -> datetime:
+        return datetime.fromtimestamp(self.ts_ms / 1000).astimezone()
+
+
 class ChiiNotify(msgspec.Struct):
     """table of chii_notify as json"""
 
@@ -39,3 +48,4 @@ class MemberValue(msgspec.Struct):
     before: ChiiMember | None
     after: ChiiMember | None
     op: str  # 'r', 'c', 'd' ...
+    source: Source

main.py

@@ -287,6 +287,10 @@ async def handle_member(self, msg: Msg):
             except msgspec.ValidationError:
                 return
 
+            # ignore events before 2024-09-26T01:06:26+00:00
+            if value.source.ts_ms < 1727312791000:
+                return
+
             if value.op != "u":
                 return
 

pyproject.toml

@@ -90,6 +90,7 @@ ignore = [
     'S104',
     'C901',
     'ISC003',
+    'PLR0911',
     'PLR0913',
     'RUF001',
     'SIM108',