add minimum log level to send to client

Author: joshamb

lib/phoenix_live_reload/channel.ex

@@ -64,12 +64,14 @@ defmodule Phoenix.LiveReloader.Channel do
   end
 
   def handle_info({@logs, %{level: level, msg: msg, file: file, line: line}}, socket) do
-    push(socket, "log", %{
-      level: to_string(level),
-      msg: msg,
-      file: file,
-      line: line
-    })
+    if is_log_min_log_level?(socket, level) do
+      push(socket, "log", %{
+        level: to_string(level),
+        msg: msg,
+        file: file,
+        line: line
+      })
+    end
 
     {:noreply, socket}
   end
@@ -122,6 +124,13 @@ defmodule Phoenix.LiveReloader.Channel do
     socket.endpoint.config(:live_reload)[:web_console_logger] == true
   end
 
+  defp is_log_min_log_level?(socket, log_level) do
+    socket.endpoint.config(:live_reload)[:web_console_logger_min_log_level] |> case do
+      nil -> true
+      level -> Logger.compare_levels(log_level, level) != :lt
+    end
+  end
+
   defp join_info do
     if url = System.get_env("PLUG_EDITOR") do
       %{editor_url: url}

test/channel_test.exs

@@ -152,4 +152,33 @@ defmodule Phoenix.LiveReloader.ChannelTest do
 
     assert info == %{editor_url: "vscode://file/__FILE__:__LINE__"}
   end
+
+  test "send valid logs with a minimum log level" do
+    System.delete_env("PLUG_EDITOR")
+
+    update_live_reload_env(@endpoint, fn conf ->
+      Keyword.merge(conf, web_console_logger: true, web_console_logger_min_log_level: :error)
+    end)
+
+    {:ok, info, _socket} =
+      LiveReloader.Socket |> socket() |> subscribe_and_join(Channel, "phoenix:live_reload", %{})
+
+    assert info == %{}
+    Logger.info("hello")
+
+    refute_receive _
+
+    update_live_reload_env(@endpoint, fn conf ->
+      Keyword.drop(conf, [:web_console_logger_min_log_level])
+    end)
+
+    {:ok, info, _socket} =
+      LiveReloader.Socket |> socket() |> subscribe_and_join(Channel, "phoenix:live_reload", %{})
+
+    assert info == %{}
+
+    Logger.info("hello again")
+    assert_receive %Phoenix.Socket.Message{event: "log", payload: %{msg: msg, level: "info"}}
+    assert msg =~ "hello again"
+  end
 end