compensation updates are removed by serialisation

electric-sql · Nov 13, 2023 · 439a7cd · 439a7cd
1 parent f7ba362
commit 439a7cd
Show file tree

Hide file tree

Showing 2 changed files with 0 additions and 15 deletions.
diff --git a/components/electric/lib/electric/postgres/shadow_table_transformation.ex b/components/electric/lib/electric/postgres/shadow_table_transformation.ex
@@ -98,11 +98,6 @@ defmodule Electric.Postgres.ShadowTableTransformation do
 
   defp build_bitmask(%Changes.Compensation{}, columns), do: Enum.map(columns, fn _ -> "f" end)
 
-  # TODO: Kept for compatibility with old clients that send a special update for compensation
-  # messages. remove once we're sure all clients have been updated.
-  defp build_bitmask(%Changes.UpdatedRecord{old_record: nil}, columns),
-    do: Enum.map(columns, fn _ -> "f" end)
-
   defp build_bitmask(%Changes.UpdatedRecord{old_record: old, record: new}, columns),
     do: Enum.map(columns, fn col -> if old[col] != new[col], do: "t", else: "f" end)
 

diff --git a/components/electric/lib/electric/replication/postgres/slot_server.ex b/components/electric/lib/electric/replication/postgres/slot_server.ex
@@ -465,16 +465,6 @@ defmodule Electric.Replication.Postgres.SlotServer do
     }
   end
 
-  defp changes_to_wal(
-         %Changes.UpdatedRecord{relation: table, old_record: nil, 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: old, record: new},
          relations