diff --git a/meilisync/source/postgres.py b/meilisync/source/postgres.py index 5d3fff9..2950ac0 100644 --- a/meilisync/source/postgres.py +++ b/meilisync/source/postgres.py @@ -81,12 +81,23 @@ def _consumer(self, msg: ReplicationMessage): return columnnames = change.get("columnnames") columnvalues = change.get("columnvalues") - values = dict(zip(columnnames, columnvalues)) + if kind == "update": + values = dict(zip(columnnames, columnvalues)) event_type = EventType.update elif kind == "delete": + values = ( + dict(zip(columnnames, columnvalues)) + if columnvalues + else { + change["oldkeys"]["keynames"][0]: change["oldkeys"][ + "keyvalues" + ][0] + } + ) event_type = EventType.delete elif kind == "insert": + values = dict(zip(columnnames, columnvalues)) event_type = EventType.create else: return