Wrap connection state change message into a tuple

Author: mickel8

lib/ice_agent.ex

@@ -44,22 +44,23 @@ defmodule ExICE.ICEAgent do
 
   For exact meaning refer to the W3C WebRTC standard, sec 5.6.3.
   """
-  @type gathering_state_changed() :: {:gathering_state_change, :new | :gathering | :complete}
+  @type gathering_state_change() :: {:gathering_state_change, :new | :gathering | :complete}
 
   @typedoc """
   Emitted when connection state has changed.
 
   For exact meaning refer to the W3C WebRTC standard, sec. 5.6.4.
   """
-  @type connection_state_changed() :: :checking | :connected | :completed | :failed
+  @type connection_state_change() ::
+          {:connection_state_change, :checking | :connected | :completed | :failed}
 
   @typedoc """
   Messages sent by the ExICE.
   """
   @type signal() ::
           {:ex_ice, pid(),
-           gathering_state_changed()
-           | connection_state_changed
+           gathering_state_change()
+           | connection_state_change()
            | {:data, binary()}
            | {:new_candidate, binary()}}
 
@@ -1403,7 +1404,7 @@ defmodule ExICE.ICEAgent do
   @spec change_connection_state(atom(), map()) :: map()
   def change_connection_state(new_conn_state, state) do
     Logger.debug("Connection state change: #{state.state} -> #{new_conn_state}")
-    send(state.controlling_process, {:ex_ice, self(), new_conn_state})
+    send(state.controlling_process, {:ex_ice, self(), {:connection_state_change, new_conn_state}})
     %{state | state: new_conn_state}
   end
 

test/integration/p2p_test.exs

@@ -131,7 +131,7 @@ defmodule ExICE.Integration.P2PTest do
         ICEAgent.end_of_candidates(agent2)
         p2p(agent1, agent2, a1_status, a2_status)
 
-      {:ex_ice, ^agent1, :connected} ->
+      {:ex_ice, ^agent1, {:connection_state_change, :connected}} ->
         Logger.info("Connected, sending file...")
 
         Task.start(fn ->
@@ -151,7 +151,7 @@ defmodule ExICE.Integration.P2PTest do
         :ok = IO.binwrite(a1_status.fd, data)
         p2p(agent1, agent2, a1_status, a2_status)
 
-      {:ex_ice, ^agent1, :completed} ->
+      {:ex_ice, ^agent1, {:connection_state_change, :completed}} ->
         Logger.info("Completed")
         a1_status = %{a1_status | completed: true}
         p2p(agent1, agent2, a1_status, a2_status)
@@ -164,12 +164,12 @@ defmodule ExICE.Integration.P2PTest do
         ICEAgent.end_of_candidates(agent1)
         p2p(agent1, agent2, a1_status, a2_status)
 
-      {:ex_ice, ^agent2, :completed} ->
+      {:ex_ice, ^agent2, {:connection_state_change, :completed}} ->
         Logger.info("Completed")
         a2_status = %{a2_status | completed: true}
         p2p(agent1, agent2, a1_status, a2_status)
 
-      {:ex_ice, ^agent2, :connected} ->
+      {:ex_ice, ^agent2, {:connection_state_change, :connected}} ->
         Logger.info("Connected, sending file...")
 
         Task.start(fn ->