From d30f9c1d81e8db5c6e6aa7f4180ed90736132bd0 Mon Sep 17 00:00:00 2001 From: Christopher Date: Mon, 13 Apr 2020 15:10:08 -0500 Subject: [PATCH] add topic to published event --- lib/router/session.ex | 3 ++- test/wampex_test.exs | 6 +++--- 2 files changed, 5 insertions(+), 4 deletions(-) diff --git a/lib/router/session.ex b/lib/router/session.ex index 1e6f541..978144e 100644 --- a/lib/router/session.ex +++ b/lib/router/session.ex @@ -326,6 +326,7 @@ defmodule Wampex.Router.Session do pub_id = RealmSession.get_id() subs = RealmSession.subscriptions(db, realm, topic) + details = Map.put_new(opts, "topic", topic) Enum.each(subs, fn {id, {pid, node}} -> send( @@ -335,7 +336,7 @@ defmodule Wampex.Router.Session do publication_id: pub_id, arg_list: arg_l, arg_kw: arg_kw, - details: opts + details: details }, pid} ) end) diff --git a/test/wampex_test.exs b/test/wampex_test.exs index 7adb5be..c38ed57 100644 --- a/test/wampex_test.exs +++ b/test/wampex_test.exs @@ -173,8 +173,8 @@ defmodule WampexTest do } ) - assert_receive %Event{}, 2000 - assert_receive %Event{}, 2000 - assert_receive %Event{}, 2000 + assert_receive %Event{details: %{"topic" => "com.data.test.temp"}}, 2000 + assert_receive %Event{details: %{"topic" => "com.data.test.temp"}}, 2000 + assert_receive %Event{details: %{"topic" => "com.data.test.temp"}}, 2000 end end -- 2.45.3