fixup! fixup! Add telemetry support

lib/mongoose_push.ex

@@ -86,6 +86,30 @@ defmodule MongoosePush do
         :timer.tc(module, :push, [notification, device_id, pool, opts])
       end
 
+    :telemetry.execute(
+      [:mpush, :push],
+      %{time: time},
+      case push_result do
+        {:error, {type, reason}} ->
+          %{
+            result: :error,
+            type: type,
+            reason: reason
+          }
+
+        {:error, reason} ->
+          %{
+            result: :error,
+            reason: reason
+          }
+
+        other ->
+          %{
+            result: other
+          }
+      end
+    )
+
     push_result
     |> Metrics.update(:spiral, [:push, service, mode])
     |> Metrics.update(:timer, [:push, service, mode], time)

lib/mongoose_push/metrics.ex

@@ -52,29 +52,13 @@ defmodule MongoosePush.Metrics do
 
   defmacro update_metric(:spiral, metric, value) do
     quote bind_quoted: [metric: metric, value: value], unquote: true do
-      :telemetry.execute(
-        [:mpush, :metric, :spiral],
-        %{
-          value: value
-        },
-        %{
-          metric: metric
-        }
-      )
+      Elixometer.update_spiral(metric, value)
     end
   end
 
   defmacro update_metric(:timer, metric, value) do
     quote bind_quoted: [metric: metric, value: value], unquote: true do
-      :telemetry.execute(
-        [:mpush, :metric, :timer],
-        %{
-          value: value
-        },
-        %{
-          metric: metric
-        }
-      )
+      Elixometer.Updater.timer(metric, :microsecond, value)
     end
   end
 

lib/mongoose_push/telemetry.ex

@@ -14,10 +14,9 @@ defmodule MongoosePush.Telemetry do
   def attach_metrics do
     _res =
       :telemetry.attach_many(
-        "metrics-handler",
+        "handler",
         [
-          [:mpush, :metric, :spiral],
-          [:mpush, :metric, :timer]
+          [:mpush, :push]
         ],
         &MongoosePush.Telemetry.handle_event/4,
         nil

lib/mongoose_push/telemetry/handler.ex

@@ -17,14 +17,8 @@ defmodule MongoosePush.Telemetry.Handler do
     {:ok, %{}}
   end
 
-  def handle_cast({[:mpush, :metric, :spiral], measurements, metadata, _}, state) do
-    Elixometer.update_spiral(metadata.metric, measurements.value)
-
-    {:noreply, state}
-  end
-
-  def handle_cast({[:mpush, :metric, :timer], measurements, metadata, _}, state) do
-    Elixometer.Updater.timer(metadata.metric, :microsecond, measurements.value)
+  def handle_cast({[:mpush, :push], measurements, metadata, _}, state) do
+    IO.inspect([measurements, metadata])
 
     {:noreply, state}
   end