fix: special case for local abcast

Author: edgurgel

lib/realtime/gen_rpc.ex

@@ -25,9 +25,15 @@ defmodule Realtime.GenRpc do
   @spec abcast([node], atom, any, keyword()) :: :ok
   def abcast(nodes, name, msg, opts) when is_list(nodes) and is_atom(name) and is_list(opts) do
     key = Keyword.get(opts, :key, nil)
-    nodes = cast_rpc_nodes(nodes, key)
 
-    :gen_rpc.abcast(nodes, name, msg)
+    {local, remote} = Enum.split_with(nodes, &(&1 == node()))
+
+    if local != [], do: send({name, node()}, msg)
+
+    remote
+    |> cast_rpc_nodes(key)
+    |> :gen_rpc.abcast(name, msg)
+
     :ok
   end
 

test/realtime/gen_rpc_test.exs

@@ -193,6 +193,20 @@ defmodule Realtime.GenRpcTest do
       refute_receive _any
     end
 
+    test "abcast to registered process on the local node" do
+      name =
+        System.unique_integer()
+        |> to_string()
+        |> String.to_atom()
+
+      :erlang.register(name, self())
+
+      assert GenRpc.abcast([node()], name, "a message", []) == :ok
+
+      assert_receive "a message"
+      refute_receive _any
+    end
+
     @tag extra_config: [{:gen_rpc, :tcp_server_port, 9999}]
     test "tcp error" do
       Logger.put_process_level(self(), :debug)