Allow encrypted_headers to be sent in via sequin config import

Author: acco

lib/sequin/transforms/transforms.ex

@@ -554,9 +554,11 @@ defmodule Sequin.Transforms do
             {:error, error} -> {:halt, {:error, error}}
           end
 
-        # Ignore encrypted_headers until encryption/decryption works
         "encrypted_headers" ->
-          {:cont, {:ok, acc}}
+          case parse_headers(value) do
+            {:ok, headers} -> {:cont, {:ok, Map.put(acc, :encrypted_headers, headers)}}
+            {:error, error} -> {:halt, {:error, error}}
+          end
 
         "webhook.site" ->
           if value in [true, "true"] do

test/sequin_web/controllers/yaml_controller_test.exs

@@ -4,6 +4,7 @@ defmodule SequinWeb.YamlControllerTest do
   alias Sequin.Databases.PostgresDatabase
   alias Sequin.Databases.Sequence
   alias Sequin.Test.UnboxedRepo
+  alias Sequin.TestSupport.Models.Character
   alias Sequin.TestSupport.ReplicationSlots
 
   @moduletag :unboxed
@@ -120,7 +121,7 @@ defmodule SequinWeb.YamlControllerTest do
             - insert
             - update
             - delete
-          source_table_name: accounts
+          source_table_name: #{Character.table_name()}
           source_table_schema: public
           destination_table_name: sequin_events
           destination_table_schema: public
@@ -133,19 +134,18 @@ defmodule SequinWeb.YamlControllerTest do
           pool_size: 10
           username: postgres
           password: '********'
-          database: sequin_example
+          database: sequin_test
           slot_name: sequin_slot
           use_local_tunnel: false
-          publication_name: sequin_pub
+          publication_name: characters_publication
       http_endpoints:
         - name: test_http_endpoint
           url: http://localhost:4000/something
           headers: {}
-          encrypted_headers: '(0 encrypted header(s)) - sha256sum: b4a8f200'
       sinks:
         - name: accounts_sink
           status: active
-          table: public.accounts
+          table: public.#{Character.table_name()}
           filters: []
           destination:
             port: 4222
@@ -164,7 +164,7 @@ defmodule SequinWeb.YamlControllerTest do
             - update
             - delete
           group_column_names:
-            - user_id
+            - id
       transforms:
         - name: record-transform
           type: path

test/support/models/character.ex

@@ -17,6 +17,10 @@ defmodule Sequin.TestSupport.Models.Character do
     timestamps(type: :naive_datetime_usec)
   end
 
+  def table_name do
+    "Characters"
+  end
+
   def quoted_table_name do
     ~s{"Characters"}
   end