Fix ping

Author: phonnz

firmware/lib/counter.ex

@@ -33,7 +33,7 @@ defmodule Firmware.Counter do
   end
 
   defp schedule_work do
-    IO.puts("Counter scheduling work")
+    # IO.puts("Counter scheduling work")
     Process.send_after(self(), :work, 5_000)
   end
 end

firmware/lib/server_link.ex

@@ -45,7 +45,14 @@ defmodule Firmware.ServerLink do
       |> assign(:mac_addr, Keyword.get(config, :mac_addr))
       |> assign(:main_topic, "group:main")
 
-    {:ok, socket}
+    {:ok, socket, {:continue, :start_ping}}
+  end
+
+  @impl Slipstream
+  def handle_continue(:start_ping, socket) do
+    timer = :timer.send_interval(1000, self(), :request_metrics)
+
+    {:noreply, assign(socket, :ping_timer, timer)}
   end
 
   @impl Slipstream
@@ -68,33 +75,27 @@ defmodule Firmware.ServerLink do
   def handle_join("group:main", topic, join_response, socket) do
     Logger.info("Join_response => #{inspect(join_response)}")
     # an asynchronous push with no reply:
-    #    push(socket, @topic, "handshake", %{:hello => :world})
-    ## something = send(self(), :start_ping)
-    ## IO.inspect("sent interval #{inspect(something)}")
+    push(socket, "group:main", "handshake", %{:hello => :world})
     {:ok, socket}
   end
 
   @impl Slipstream
-  def handle_info(:start_ping, socket) do
-    case connected?(socket) do
-      true ->
-        timer = :timer.send_interval(10_000, self(), :ping_server)
-        IO.inspect(timer, label: :TIMER)
-        {:noreply, assign(socket, :ping_timer, timer)}
-
-      false ->
-        IO.puts("Ping not available due socket conn down")
-        :timer.send_after(self(), :start_ping, 1_000)
-    end
+  def handle_info(:request_metrics, socket) do
+    # we will asynchronously receive a reply and handle it in the
+    # handle_reply/3 implementation below
+    {:ok, ref} = push(socket, "group:main", "get_metrics", %{format: "json"})
+
+    {:noreply, assign(socket, :metrics_request, ref)}
   end
 
   @impl Slipstream
-  def handle_info(:ping_server, socket) do
-    # we will asynchronously receive a reply and handle it in the
-    # handle_reply/3 implementation below
-    {:ok, ref} = push(socket, "group:main", "ping", %{format: "json"})
+  def handle_reply(ref, metrics, socket) do
+    if ref == socket.assigns.metrics_request do
+      Logger.info("Do some metrics #{inspect(metrics)}")
+      # :ok = MyApp.MetricsPublisher.publish(metrics)
+    end
 
-    {:noreply, assign(socket, :last_ping, ref)}
+    {:ok, socket}
   end
 
   @impl Slipstream
@@ -108,7 +109,7 @@ defmodule Firmware.ServerLink do
   def handle_info(:disconnect, socket) do
     IO.inspect("Disconect")
     ## result = :timer.cancel(socket.assigns.ping_timer)
-    ## IO.inspect(result, label: :RESULT)
+    # IO.inspect(result, label: :RESULT)
 
     {:ok, socket} =
       socket

fullstack/lib/fullstack_web/channels/group_channel.ex

@@ -1,6 +1,7 @@
 defmodule FullstackWeb.GroupChannel do
   use FullstackWeb, :channel
   alias FullstackWeb.Presence
+  require Logger
   #  intercept(["user_joined"])
 
   @impl true
@@ -28,10 +29,19 @@ defmodule FullstackWeb.GroupChannel do
   # Channels can be used in a request/response fashion
   # by sending replies to requests from the client
   @impl true
-  def handle_in("ping", _payload, socket) do
+  def handle_in("ping", payload, socket) do
+    Logger.info("Ping from #{inspect(payload)}")
     {:reply, {:ok, %{:ping => :pong}}, socket}
   end
 
+  @impl true
+  def handle_in("get_metrics", payload, socket) do
+    Logger.info("Ping from #{inspect(payload)}")
+
+    {:reply, {:ok, %{:metrics => <<104, 101, 108, 108, 111, 45, 119, 111, 114, 108, 100>>}},
+     socket}
+  end
+
   # It is also common to receive messages from the client and
   # broadcast to everyone in the current topic (group:lobby).
   @impl true