fix: Improve error handling on realtime channel (#1234)

supabase · Nov 25, 2024 · 0aed575 · 0aed575
1 parent 18dfc46
commit 0aed575
Show file tree

Hide file tree

Showing 2 changed files with 6 additions and 1 deletion.
diff --git a/lib/realtime_web/channels/realtime_channel.ex b/lib/realtime_web/channels/realtime_channel.ex
@@ -279,6 +279,11 @@ defmodule RealtimeWeb.RealtimeChannel do
       nil ->
         Logger.warning("Re-connecting to PostgreSQL with params: " <> inspect(pg_change_params))
         {:noreply, assign(socket, :pg_sub_ref, postgres_subscribe())}
+
+      error ->
+        log_error("UnableToSubscribeToPostgres", error)
+        push_system_message("postgres_changes", socket, "error", error, channel_name)
+        {:noreply, assign(socket, :pg_sub_ref, postgres_subscribe(5, 10))}
     end
   end
 

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