fix: Reduce janitor scope to only local tenants (#1303)

Reduce janitor scope to only local tenants
supabase · Feb 20, 2025 · 1c780b5 · 1c780b5
1 parent 74bbfca
commit 1c780b5
Show file tree

Hide file tree

Showing 2 changed files with 4 additions and 2 deletions.
diff --git a/lib/realtime/tenants/janitor.ex b/lib/realtime/tenants/janitor.ex
@@ -65,7 +65,9 @@ defmodule Realtime.Tenants.Janitor do
     Logger.info("Janitor started")
     %{chunks: chunks, tasks: tasks} = state
     all_tenants = :ets.select(@table_name, [{{:"$1"}, [], [:"$1"]}])
-    connected_tenants = :ets.select(@syn_table, [{{:"$1", :_, :_, :_, :_, :_}, [], [:"$1"]}])
+
+    connected_tenants =
+      :ets.select(@syn_table, [{{:"$1", :_, :_, :_, :_, :"$2"}, [{:==, :"$2", {:const, Node.self()}}], [:"$1"]}])
 
     new_tasks =
       MapSet.new(all_tenants ++ connected_tenants)

diff --git a/mix.exs b/mix.exs
@@ -4,7 +4,7 @@ defmodule Realtime.MixProject do
   def project do
     [
       app: :realtime,
-      version: "2.34.25",
+      version: "2.34.26",
       elixir: "~> 1.17.3",
       elixirc_paths: elixirc_paths(Mix.env()),
       start_permanent: Mix.env() == :prod,