fix: improve yaml load for sinks with active_backfill and max_retry_count set to nil

As handling `active_backfill` seems to be entirely unsupported we are ignoring
that field for now until we have a proper implementation

Author: davoclavo

lib/sequin/transforms/transforms.ex

@@ -597,6 +597,9 @@ defmodule Sequin.Transforms do
         "max_retry_count" when is_integer(value) and value >= 0 ->
           {:cont, {:ok, Map.put(acc, :max_retry_count, value)}}
 
+        "max_retry_count" when is_nil(value) ->
+          {:cont, {:ok, acc}}
+
         "max_retry_count" ->
           {:halt, {:error, Error.validation(summary: "max_retry_count must be a non-negative integer")}}
 
@@ -612,7 +615,7 @@ defmodule Sequin.Transforms do
           {:cont, {:ok, acc}}
 
         # Ignore internal fields that might be present in the external data
-        ignored when ignored in ~w(id inserted_at updated_at account_id replication_slot_id sequence_id) ->
+        ignored when ignored in ~w(id inserted_at updated_at account_id replication_slot_id sequence_id active_backfill) ->
           {:cont, {:ok, acc}}
 
         # Unknown field

test/sequin_web/controllers/yaml_controller_test.exs

@@ -108,6 +108,72 @@ defmodule SequinWeb.YamlControllerTest do
                "summary" => "Error creating database 'test-db': - database: can't be blank"
              }
     end
+
+    test "successfully plans configuration with wider set of fields", %{conn: conn} do
+      yaml = """
+      change_retentions:
+        - name: test_retention
+          filters: []
+          destination_database: sequin_test_two
+          source_database: sequin_test_two
+          actions:
+            - insert
+            - update
+            - delete
+          source_table_name: accounts
+          source_table_schema: public
+          destination_table_name: sequin_events
+          destination_table_schema: public
+      databases:
+        - name: sequin_test_two
+          port: 5432
+          ssl: false
+          ipv6: false
+          hostname: localhost
+          pool_size: 10
+          username: postgres
+          password: '********'
+          database: sequin_example
+          slot_name: sequin_slot
+          use_local_tunnel: false
+          publication_name: sequin_pub
+      sinks:
+        - name: accounts_sink
+          status: active
+          table: public.accounts
+          filters: []
+          destination:
+            port: 4222
+            type: nats
+            host: localhost
+            tls: false
+          database: sequin_test_two
+          transform: record-transform
+          active_backfill:
+          batch_size: 1
+          load_shedding_policy: pause_on_full
+          max_retry_count:
+          timestamp_format: iso8601
+          actions:
+            - insert
+            - update
+            - delete
+          group_column_names:
+            - user_id
+      transforms:
+        - name: record-transform
+          type: path
+          path: record
+          description: Extracts just the record from the Sequin message shape.
+      """
+
+      conn = post(conn, ~p"/api/config/plan", %{yaml: yaml})
+
+      response = json_response(conn, 200)
+      assert %{"changes" => changes} = response
+      assert is_list(changes)
+    end
+
   end
 
   describe "apply/2" do