map compensation message to replication update

electric-sql · Nov 9, 2023 · be69b14 · be69b14
1 parent 6628142
commit be69b14
Showing 1 changed file with 7 additions and 0 deletions.
diff --git a/components/electric/lib/electric/replication/postgres/slot_server.ex b/components/electric/lib/electric/replication/postgres/slot_server.ex
@@ -458,6 +458,13 @@ defmodule Electric.Replication.Postgres.SlotServer do
     }
   end
 
+  defp changes_to_wal(%Changes.Compensation{relation: table, record: new}, relations) do
+    %ReplicationMessages.Update{
+      relation_id: relations[table].oid,
+      tuple_data: record_to_tuple(new, relations[table].columns)
+    }
+  end
+
   defp changes_to_wal(
          %Changes.UpdatedRecord{relation: table, old_record: nil, record: new},
          relations