Merge pull request #28 from otobus/mustafaturan/empty_topic_listeners

Log empty topic listeners to prevent unnecessary ETS inserts

CHANGELOG.md

@@ -6,7 +6,8 @@ and this project adheres to [Semantic Versioning](http://semver.org/spec/v2.0.0.
 
 ## [1.3.X]
 
-
+- Log empty topic listeners
+- Add missing tests for existence check
 - Update time spent calculation for EventSource block
 - Remove support for system event tracing (Updated the wiki to create wrapper for system event tracing)
 

lib/event_bus/services/notification.ex

@@ -11,10 +11,15 @@ defmodule EventBus.Service.Notification do
   @spec notify(Event.t()) :: no_return()
   def notify(%Event{id: id, topic: topic} = event) do
     listeners = Subscription.subscribers(topic)
-    :ok = Store.create(event)
-    :ok = Observation.create({listeners, topic, id})
 
-    notify_listeners(listeners, {topic, id})
+    if listeners == [] do
+      Logger.log(@logging_level, "Topic :#{topic} listener set is empty!")
+    else
+      :ok = Store.create(event)
+      :ok = Observation.create({listeners, topic, id})
+
+      notify_listeners(listeners, {topic, id})
+    end
   end
 
   @spec notify_listeners(list(), tuple()) :: no_return()

test/event_bus/managers/observation_test.exs

@@ -15,6 +15,13 @@ defmodule EventBus.Manager.ObservationTest do
     :ok
   end
 
+  test "exist?" do
+    topic = :metrics_received_1
+    Observation.register_topic(topic)
+
+    assert Observation.exist?(topic)
+  end
+
   test "register_topic" do
     assert :ok == Observation.register_topic(:metrics_destroyed)
   end

test/event_bus/managers/store_test.exs

@@ -15,6 +15,13 @@ defmodule EventBus.Manager.StoreTest do
     :ok
   end
 
+  test "exist?" do
+    topic = :metrics_received_1
+    Store.register_topic(topic)
+
+    assert Store.exist?(topic)
+  end
+
   test "register_topic" do
     assert :ok == Store.register_topic(@topic)
   end

test/event_bus/managers/topic_test.exs

@@ -13,6 +13,13 @@ defmodule EventBus.Manager.TopicTest do
     :ok
   end
 
+  test "exist?" do
+    topic = :metrics_received_1
+    Topic.register(topic)
+
+    assert Topic.exist?(topic)
+  end
+
   test "register_topic" do
     assert :ok == Topic.register(:t1)
   end