[K8sBroadcaster] Add some debug logs

l7mp · Jan 8, 2025 · 8f0a315 · 8f0a315
1 parent 5dfe5e2
commit 8f0a315
Show file tree

Hide file tree

Showing 2 changed files with 24 additions and 11 deletions.
diff --git a/k8s_broadcaster/lib/k8s_broadcaster_web/controllers/page_controller.ex b/k8s_broadcaster/lib/k8s_broadcaster_web/controllers/page_controller.ex
@@ -23,22 +23,13 @@ defmodule K8sBroadcasterWeb.PageController do
           args: [Path.join(:code.priv_dir(:k8s_broadcaster), "headless_client.js")],
           env: [
             {~c"TOKEN", String.to_charlist(whip_token)},
-            {~c"URL", String.to_charlist("#{conn.scheme}://#{conn.host}:#{conn.port}")}
+            {~c"URL", String.to_charlist("#{conn.scheme}://#{conn.host}:#{conn.port}") |> dbg()}
           ]
         )
 
       Port.monitor(port)
 
-      receive do
-        :exit ->
-          {:os_pid, os_pid} = Port.info(port, :os_pid)
-          Logger.info("Closing headless client")
-          # For some reason, doing Port.close does not work
-          System.shell("kill #{os_pid}")
-
-        {:DOWN, _ref, :port, _, reason} ->
-          Logger.info("Headless client exited with reason: #{inspect(reason)}")
-      end
+      stream_receive(port)
     end)
 
     conn
@@ -56,4 +47,21 @@ defmodule K8sBroadcasterWeb.PageController do
     |> resp(201, "")
     |> send_resp()
   end
+
+  defp stream_receive(port) do
+    receive do
+      :exit ->
+        {:os_pid, os_pid} = Port.info(port, :os_pid)
+        Logger.info("Closing headless client")
+        # For some reason, doing Port.close does not work
+        System.shell("kill #{os_pid}")
+
+      {:DOWN, _ref, :port, _, reason} ->
+        Logger.info("Headless client exited with reason: #{inspect(reason)}")
+
+      other ->
+        dbg(other)
+        stream_receive(port)
+    end
+  end
 end
diff --git a/k8s_broadcaster/priv/headless_client.js b/k8s_broadcaster/priv/headless_client.js
@@ -6,6 +6,8 @@ const url =
   process.env.URL === undefined ? "http://localhost:4000" : process.env.URL;
 const token = process.env.TOKEN === undefined ? "example" : process.env.TOKEN;
 
+console.log(url);
+
 async function stream(url, token) {
   console.log("Starting new stream...");
   let response;
@@ -48,6 +50,9 @@ async function stream(url, token) {
   const offer = await pc.createOffer();
   await pc.setLocalDescription(offer);
 
+  console.log(url);
+  console.log(window.location.origin);
+
   response = await fetch(`${url}/api/whip`, {
     method: "POST",
     cache: "no-cache",