supabase/realtime

Problem With config.broadcast.ack: true, a client that sends a broadcast on a private channel waits for the server to reply. When an RLS write policy denies the broadcast, or the broadcast fails on the server, Realtime never replies. The push times out, and supabase-js resolves send() with 'timed out' instead of 'error': https://github.com/supabase/supabase-js/blob/54c225dacb1fc5f5a0a97c93908a46b7e8f5c9cc/packages/core/realtime-js/src/RealtimeChannel.ts#L1119-L1125 A denied write looks like a network problem, so people debug latency instead of their policies. BroadcastHandler.handle/3 returns {:noreply, socket} regardless of ack_broadcast when the write policy denies the message and in every error clause: realtime/lib/realtime_web/channels/realtime_channel/broadcast_handler.ex Lines 80 to 104 in a3591b3 {:ok, policies} -> {:noreply, assign(socket, :po

Problem Subscriptions.delete_all/1 runs delete from realtime.subscription; without checking that the table exists: realtime/lib/extensions/postgres_cdc_rls/subscriptions.ex Lines 163 to 173 in a85489e @spec delete_all(conn()) :: :ok def delete_all(conn) do Logger.debug("Delete all subscriptions") case query(conn, "delete from realtime.subscription;", []) do {:ok, _} -> :ok {:error, reason} -> log_error("SubscriptionDeletionFailed", reason) end catch :exit, reason -> log_error("SubscriptionDeletionFailed", {