chore: cast sync and flush events in client_handler (#357)

supabase · Jun 12, 2024 · 3321c10 · 3321c10
1 parent ed8840b
commit 3321c10
Show file tree

Hide file tree

Showing 2 changed files with 12 additions and 3 deletions.
diff --git a/VERSION b/VERSION
@@ -1 +1 @@
-1.1.60
+1.1.61
diff --git a/lib/supavisor/client_handler.ex b/lib/supavisor/client_handler.ex
@@ -422,10 +422,19 @@ defmodule Supavisor.ClientHandler do
     {:keep_state_and_data, handle_actions(data)}
   end
 
-  def handle_event(:info, {proto, _, <<?S, 4::32>> = msg}, _, data)
+  def handle_event(:info, {proto, _, <<?S, 4::32, _::binary>> = msg}, _, data)
       when proto in [:tcp, :ssl] do
     Logger.debug("ClientHandler: Receive sync while not idle")
-    Db.cast(data.db_pid, self(), msg)
+    {_, db_pid} = data.db_pid
+    Db.cast(db_pid, self(), msg)
+    :keep_state_and_data
+  end
+
+  def handle_event(:info, {proto, _, <<?H, 4::32, _::binary>> = msg}, _, data)
+      when proto in [:tcp, :ssl] do
+    Logger.debug("ClientHandler: Receive flush while not idle")
+    {_, db_pid} = data.db_pid
+    Db.cast(db_pid, self(), msg)
     :keep_state_and_data
   end