set publication and slot name through start function

abc3 · Feb 3, 2022 · f8b8053 · f8b8053
1 parent 5807ea0
commit f8b8053
Show file tree

Hide file tree

Showing 3 changed files with 21 additions and 26 deletions.
diff --git a/README.md b/README.md
diff --git a/lib/ewalrus.ex b/lib/ewalrus.ex
@@ -11,12 +11,28 @@ defmodule Ewalrus do
   Start db poller.
 
   """
-  @spec start(String.t(), String.t(), String.t(), String.t(), String.t()) ::
+  @spec start(String.t(), String.t(), String.t(), String.t(), String.t(), String.t(), String.t()) ::
           :ok | {:error, :already_started}
-  def start(scope, host, db_name, db_user, db_pass) do
+  def start(
+        scope,
+        host,
+        db_name,
+        db_user,
+        db_pass,
+        publication \\ "supabase_multiplayer",
+        slot_name \\ "supabase_multiplayer_replication_slot"
+      ) do
     case :global.whereis_name({:supervisor, scope}) do
       :undefined ->
-        opts = [id: scope, db_host: host, db_name: db_name, db_user: db_user, db_pass: db_pass]
+        opts = [
+          id: scope,
+          db_host: host,
+          db_name: db_name,
+          db_user: db_user,
+          db_pass: db_pass,
+          publication: publication,
+          slot_name: slot_name
+        ]
 
         {:ok, pid} =
           DynamicSupervisor.start_child(Ewalrus.RlsSupervisor, %{

diff --git a/lib/ewalrus/db_supervisor.ex b/lib/ewalrus/db_supervisor.ex
@@ -25,8 +25,8 @@ defmodule Ewalrus.DbSupervisor do
       backoff_min: 100,
       backoff_max: 120_000,
       replication_poll_interval: 1000,
-      publication: "supabase_multiplayer",
-      slot_name: "supabase_multiplayer_replication_slot",
+      publication: args[:publication],
+      slot_name: args[:slot_name],
       max_record_bytes: 1_048_576
     ]