From: Christopher <chris@entropealabs.com>
Date: Mon, 13 Apr 2020 20:10:08 +0000 (-0500)
Subject: add topic to published event
X-Git-Url: http://git.entropealabs.com/?a=commitdiff_plain;h=d30f9c1d81e8db5c6e6aa7f4180ed90736132bd0;p=wampex_router.git

add topic to published event
---

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