Don't terminate PeerConnection after moving to the failed state

Author: mickel8

lib/ex_webrtc/peer_connection.ex

@@ -1186,7 +1186,8 @@ defmodule ExWebRTC.PeerConnection do
   end
 
   @impl true
-  def handle_cast({:send_rtp, track_id, packet, opts}, state) do
+  def handle_cast({:send_rtp, track_id, packet, opts}, %{conn_state: conn_state} = state)
+      when conn_state != :failed do
     rtx? = Keyword.get(opts, :rtx?, false)
 
     # TODO: iterating over transceivers is not optimal
@@ -1238,7 +1239,8 @@ defmodule ExWebRTC.PeerConnection do
   end
 
   @impl true
-  def handle_cast({:send_pli, track_id, rid}, state) do
+  def handle_cast({:send_pli, track_id, rid}, %{conn_state: conn_state} = state)
+      when conn_state != :failed do
     state.transceivers
     |> Enum.with_index()
     |> Enum.find(fn {tr, _idx} -> tr.receiver.track.id == track_id end)
@@ -1265,7 +1267,8 @@ defmodule ExWebRTC.PeerConnection do
   end
 
   @impl true
-  def handle_cast({:send_data, channel_ref, data_type, data}, state) do
+  def handle_cast({:send_data, channel_ref, data_type, data}, %{conn_state: conn_state} = state)
+      when conn_state != :failed do
     {events, sctp_transport} =
       SCTPTransport.send(state.sctp_transport, channel_ref, data_type, data)
 
@@ -1280,6 +1283,12 @@ defmodule ExWebRTC.PeerConnection do
     {:noreply, state}
   end
 
+  @impl true
+  def handle_cast(msg, state) do
+    Logger.warning("Unexpected cast in state: #{state.conn_state}. Cast: #{inspect(msg)}")
+    {:noreply, state}
+  end
+
   @impl true
   def handle_info({:ex_ice, _from, {:connection_state_change, new_ice_state}}, state) do
     state = %{state | ice_state: new_ice_state}
@@ -1294,7 +1303,7 @@ defmodule ExWebRTC.PeerConnection do
 
     if next_conn_state == :failed do
       Logger.debug("Stopping PeerConnection")
-      {:stop, {:shutdown, :conn_state_failed}, state}
+      {:noreply, state}
     else
       {:noreply, state}
     end