✅ Add test verifying all sink consumer factories

Author: RTLS

test/sink_consumer_test.exs

@@ -0,0 +1,18 @@
+defmodule Sequin.SinkConsumerTest do
+  use Sequin.DataCase, async: true
+
+  alias Sequin.Consumers
+  alias Sequin.Consumers.SinkConsumer
+  alias Sequin.Factory.ConsumersFactory
+
+  describe "sink consumer create_changeset/2" do
+    test "all sinks have valid factories" do
+      for sink_type <- Consumers.SinkConsumer.types() do
+        attrs = ConsumersFactory.sink_consumer_attrs(type: sink_type)
+        changeset = SinkConsumer.create_changeset(%SinkConsumer{}, attrs)
+        errors = Sequin.Error.errors_on(changeset)
+        assert changeset.valid?, "Sink #{sink_type} has invalid factory: #{inspect(errors)}"
+      end
+    end
+  end
+end

test/support/factory/consumers_factory.ex

@@ -191,7 +191,8 @@ defmodule Sequin.Factory.ConsumersFactory do
         endpoint_url: "http://127.0.0.1:7700",
         primary_key: "masterKey",
         index_name: Factory.word(),
-        api_key: Factory.word()
+        api_key: Factory.word(),
+        routing_mode: "static"
       },
       attrs
     )