Merge pull request #12 from Whatnot-Inc/wwitek/broadcast-metric-subscriber

Add subscribers to broadcast event metadata

Author: wwitek-whatnot

lib/phoenix/channel/server.ex

@@ -122,7 +122,7 @@ defmodule Phoenix.Channel.Server do
     :telemetry.execute(
       [:phoenix, :endpoint, :broadcast],
       %{subscriber_count: subscriber_count},
-      %{message: Map.from_struct(msg)}
+      %{subscribers: subscribers, message: Map.from_struct(msg)}
     )
 
     :ok

test/phoenix/endpoint/endpoint_test.exs

@@ -288,22 +288,22 @@ defmodule Phoenix.Endpoint.EndpointTest do
     some = spawn fn -> :ok end
 
     Endpoint.broadcast_from(some, "atopic", "event1", %{key: :val})
-    assert_receive {:telemetry, _, %{subscriber_count: 1}, %{message: %{topic: "atopic", event: "event1", payload: %{key: :val}}}}
+    assert_receive {:telemetry, _, %{subscriber_count: 1}, %{subscribers: [{^me, nil}], message: %{topic: "atopic", event: "event1", payload: %{key: :val}}}}
 
     Endpoint.broadcast_from!(some, "atopic", "event2", %{key: :val})
-    assert_receive {:telemetry, _, %{subscriber_count: 1}, %{message: %{topic: "atopic", event: "event2", payload: %{key: :val}}}}
+    assert_receive {:telemetry, _, %{subscriber_count: 1}, %{subscribers: [{^me, nil}], message: %{topic: "atopic", event: "event2", payload: %{key: :val}}}}
 
     Endpoint.broadcast("atopic", "event3", %{key: :val})
-    assert_receive {:telemetry, _, %{subscriber_count: 1}, %{message: %{topic: "atopic", event: "event3", payload: %{key: :val}}}}
+    assert_receive {:telemetry, _, %{subscriber_count: 1}, %{subscribers: [{^me, nil}], message: %{topic: "atopic", event: "event3", payload: %{key: :val}}}}
 
     Endpoint.broadcast!("atopic", "event4", %{key: :val})
-    assert_receive {:telemetry, _, %{subscriber_count: 1}, %{message: %{topic: "atopic", event: "event4", payload: %{key: :val}}}}
+    assert_receive {:telemetry, _, %{subscriber_count: 1}, %{subscribers: [{^me, nil}], message: %{topic: "atopic", event: "event4", payload: %{key: :val}}}}
 
     Endpoint.local_broadcast_from(some, "atopic", "event5", %{key: :val})
-    assert_receive {:telemetry, _, %{subscriber_count: 1}, %{message: %{topic: "atopic", event: "event5", payload: %{key: :val}}}}
+    assert_receive {:telemetry, _, %{subscriber_count: 1}, %{subscribers: [{^me, nil}], message: %{topic: "atopic", event: "event5", payload: %{key: :val}}}}
 
     Endpoint.local_broadcast("atopic", "event6", %{key: :val})
-    assert_receive {:telemetry, _, %{subscriber_count: 1}, %{message: %{topic: "atopic", event: "event6", payload: %{key: :val}}}}
+    assert_receive {:telemetry, _, %{subscriber_count: 1}, %{subscribers: [{^me, nil}], message: %{topic: "atopic", event: "event6", payload: %{key: :val}}}}
 
     Endpoint.unsubscribe("atopic")
     Endpoint.broadcast("atopic", "event7", %{key: :val})