fix: Send functions sets topic properly

lib/realtime/tenants/migrations.ex

@@ -72,7 +72,8 @@ defmodule Realtime.Tenants.Migrations do
     RealtimeSendSetsConfig,
     RealtimeSubscriptionUnlogged,
     RealtimeSubscriptionLogged,
-    RemoveUnusedPublications
+    RemoveUnusedPublications,
+    RealtimeSendSetsTopicConfig
   }
 
   @migrations [
@@ -135,7 +136,8 @@ defmodule Realtime.Tenants.Migrations do
     {20_241_224_161_212, RealtimeSendSetsConfig},
     {20_250_107_150_512, RealtimeSubscriptionUnlogged},
     {20_250_110_162_412, RealtimeSubscriptionLogged},
-    {20_250_123_174_212, RemoveUnusedPublications}
+    {20_250_123_174_212, RemoveUnusedPublications},
+    {20_250_128_220_012, RealtimeSendSetsTopicConfig}
   ]
 
   defstruct [:tenant_external_id, :settings]

lib/realtime/tenants/repo/migrations/20250128220012_realtime_send_sets_topic_config.ex

@@ -0,0 +1,37 @@
+defmodule Realtime.Tenants.Migrations.RealtimeSendSetsTopicConfig do
+  @moduledoc false
+  use Ecto.Migration
+
+  # We missed the schema prefix of `realtime.` in the create table partition statement
+  def change do
+    execute("""
+    CREATE OR REPLACE FUNCTION realtime.send(payload jsonb, event text, topic text, private boolean DEFAULT true ) RETURNS void
+    AS $$
+    BEGIN
+      BEGIN
+        -- Set the topic configuration
+        EXECUTE format('SET LOCAL realtime.topic TO %L', topic);
+
+        -- Attempt to insert the message
+        INSERT INTO realtime.messages (payload, event, topic, private, extension)
+        VALUES (payload, event, topic, private, 'broadcast');
+      EXCEPTION
+        WHEN OTHERS THEN
+          -- Capture and notify the error
+          PERFORM pg_notify(
+              'realtime:system',
+              jsonb_build_object(
+                  'error', SQLERRM,
+                  'function', 'realtime.send',
+                  'event', event,
+                  'topic', topic,
+                  'private', private
+              )::text
+          );
+      END;
+    END;
+    $$
+    LANGUAGE plpgsql;
+    """)
+  end
+end

mix.exs

@@ -4,7 +4,7 @@ defmodule Realtime.MixProject do
   def project do
     [
       app: :realtime,
-      version: "2.34.11",
+      version: "2.34.12",
       elixir: "~> 1.17.3",
       elixirc_paths: elixirc_paths(Mix.env()),
       start_permanent: Mix.env() == :prod,