Send ICE candidates from subscriber

Author: mickel8

assets/publisher.js

@@ -184,7 +184,6 @@ export function createPublisherHook(iceServers = []) {
 
       view.disableControls(view);
 
-      console.log(iceServers);
       view.pc = new RTCPeerConnection({ iceServers: iceServers });
 
       // handle local events

assets/subscriber.js

@@ -2,6 +2,11 @@ export function createSubscriberHook(iceServers = []) {
   return {
     async mounted() {
       this.pc = new RTCPeerConnection({ iceServers: iceServers });
+
+      this.pc.onicecandidate = (ev) => {
+        this.pushEventTo(this.el, "ice", JSON.stringify(ev.candidate));
+      };
+
       this.pc.ontrack = (ev) => {
         console.log("ontrack");
         this.el.srcObject = ev.streams[0];

lib/live_ex_webrtc/subscriber.ex

@@ -11,6 +11,10 @@ defmodule LiveExWebRTC.Subscriber do
     """
   end
 
+  def handle_event(_event, _unsigned_params, %{assigns: %{pc: nil}} = socket) do
+    {:noreply, socket}
+  end
+
   def handle_event("offer", unsigned_params, socket) do
     offer = SessionDescription.from_json(unsigned_params)
     {:ok, pc} = spawn_peer_connection(socket)
@@ -37,6 +41,22 @@ defmodule LiveExWebRTC.Subscriber do
     {:noreply, socket}
   end
 
+  def handle_event("ice", "null", socket) do
+    :ok = PeerConnection.add_ice_candidate(socket.assigns.pc, %{candidate: ""})
+    {:noreply, socket}
+  end
+
+  def handle_event("ice", unsigned_params, socket) do
+    cand =
+      unsigned_params
+      |> Jason.decode!()
+      |> ExWebRTC.ICECandidate.from_json()
+
+    :ok = PeerConnection.add_ice_candidate(socket.assigns.pc, cand)
+
+    {:noreply, socket}
+  end
+
   defp spawn_peer_connection(socket) do
     pc_opts =
       [