Add candidate pairs stats (#203)

Author: mickel8

lib/ex_webrtc/peer_connection.ex

@@ -1119,6 +1119,23 @@ defmodule ExWebRTC.PeerConnection do
       }
     end
 
+    to_stats_pair = fn pair, timestamp ->
+      %{
+        id: pair.id,
+        timestamp: timestamp,
+        type: :candidate_pair,
+        local_candidate_id: pair.local_cand_id,
+        remote_candidate_id: pair.remote_cand_id,
+        state: pair.state,
+        nominated: pair.nominated?,
+        requests_received: pair.requests_received,
+        requests_sent: pair.requests_sent,
+        responses_received: pair.responses_received,
+        non_symmetric_responses_received: pair.non_symmetric_responses_received,
+        responses_sent: pair.responses_sent
+      }
+    end
+
     local_cands =
       Map.new(ice_stats.local_candidates, fn local_cand ->
         cand = to_stats_candidate.(local_cand, :local_candidate, timestamp)
@@ -1131,6 +1148,12 @@ defmodule ExWebRTC.PeerConnection do
         {cand.id, cand}
       end)
 
+    candidate_pairs =
+      Map.new(ice_stats.candidate_pairs, fn pair ->
+        pair = to_stats_pair.(pair, timestamp)
+        {pair.id, pair}
+      end)
+
     rtp_stats =
       state.transceivers
       |> Enum.flat_map(&RTPTransceiver.get_stats(&1, timestamp))
@@ -1179,6 +1202,7 @@ defmodule ExWebRTC.PeerConnection do
       stats
       |> Map.merge(local_cands)
       |> Map.merge(remote_cands)
+      |> Map.merge(candidate_pairs)
       |> Map.merge(rtp_stats)
       |> Map.merge(data_channel_stats)
 

mix.exs

@@ -57,7 +57,8 @@ defmodule ExWebRTC.MixProject do
   defp deps do
     [
       {:ex_sdp, "~> 1.0"},
-      {:ex_ice, "~> 0.9.0"},
+      # {:ex_ice, "~> 0.9.0"},
+      {:ex_ice, github: "elixir-webrtc/ex_ice"},
       {:ex_dtls, "~> 0.16.0"},
       {:ex_libsrtp, "~> 0.7.1"},
       {:ex_rtp, "~> 0.4.0"},

mix.lock

@@ -12,7 +12,7 @@
   "erlex": {:hex, :erlex, "0.2.7", "810e8725f96ab74d17aac676e748627a07bc87eb950d2b83acd29dc047a30595", [:mix], [], "hexpm", "3ed95f79d1a844c3f6bf0cea61e0d5612a42ce56da9c03f01df538685365efb0"},
   "ex_doc": {:hex, :ex_doc, "0.37.0", "970f92b39e62c460aa8a367508e938f5e4da6e2ff3eaed3f8530b25870f45471", [:mix], [{:earmark_parser, "~> 1.4.42", [hex: :earmark_parser, repo: "hexpm", optional: false]}, {:makeup_c, ">= 0.1.0", [hex: :makeup_c, repo: "hexpm", optional: true]}, {:makeup_elixir, "~> 0.14 or ~> 1.0", [hex: :makeup_elixir, repo: "hexpm", optional: false]}, {:makeup_erlang, "~> 0.1 or ~> 1.0", [hex: :makeup_erlang, repo: "hexpm", optional: false]}, {:makeup_html, ">= 0.1.0", [hex: :makeup_html, repo: "hexpm", optional: true]}], "hexpm", "b0ee7f17373948e0cf471e59c3a0ee42f3bd1171c67d91eb3626456ef9c6202c"},
   "ex_dtls": {:hex, :ex_dtls, "0.16.0", "3ae38025ccc77f6db573e2e391602fa9bbc02253c137d8d2d59469a66cbe806b", [:mix], [{:bundlex, "~> 1.5.3", [hex: :bundlex, repo: "hexpm", optional: false]}, {:unifex, "~> 1.0", [hex: :unifex, repo: "hexpm", optional: false]}], "hexpm", "2a4e30d74c6ddf95cc5b796423293c06a0da295454c3823819808ff031b4b361"},
-  "ex_ice": {:hex, :ex_ice, "0.9.3", "46700963acaba72737032500b6ee298a4effa7ad7189ab48887be5e9f4fe2107", [:mix], [{:elixir_uuid, "~> 1.0", [hex: :elixir_uuid, repo: "hexpm", optional: false]}, {:ex_stun, "~> 0.2.0", [hex: :ex_stun, repo: "hexpm", optional: false]}, {:ex_turn, "~> 0.2.0", [hex: :ex_turn, repo: "hexpm", optional: false]}], "hexpm", "4fd98d20a39ab70a62dd301c44e87437d479292c528ec7f21522ebfe0654b9cb"},
+  "ex_ice": {:git, "https://github.com/elixir-webrtc/ex_ice.git", "41f5c8aa8d9446f5833449f23ed22cd598da6fb7", []},
   "ex_libsrtp": {:hex, :ex_libsrtp, "0.7.2", "211bd89c08026943ce71f3e2c0231795b99cee748808ed3ae7b97cd8d2450b6b", [:mix], [{:bunch, "~> 1.6", [hex: :bunch, repo: "hexpm", optional: false]}, {:bundlex, "~> 1.3", [hex: :bundlex, repo: "hexpm", optional: false]}, {:membrane_precompiled_dependency_provider, "~> 0.1.0", [hex: :membrane_precompiled_dependency_provider, repo: "hexpm", optional: false]}, {:unifex, "~> 1.1", [hex: :unifex, repo: "hexpm", optional: false]}], "hexpm", "2e20645d0d739a4ecdcf8d4810a0c198120c8a2f617f2b75b2e2e704d59f492a"},
   "ex_rtcp": {:hex, :ex_rtcp, "0.4.0", "f9e515462a9581798ff6413583a25174cfd2101c94a2ebee871cca7639886f0a", [:mix], [], "hexpm", "28956602cf210d692fcdaf3f60ca49681634e1deb28ace41246aee61ee22dc3b"},
   "ex_rtp": {:hex, :ex_rtp, "0.4.0", "1f1b5c1440a904706011e3afbb41741f5da309ce251cb986690ce9fd82636658", [:mix], [], "hexpm", "0f72d80d5953a62057270040f0f1ee6f955c08eeae82ac659c038001d7d5a790"},

test/ex_webrtc/peer_connection_test.exs

@@ -979,6 +979,7 @@ defmodule ExWebRTC.PeerConnectionTest do
     assert Map.get(groups, :outbound_rtp) == nil
     assert Map.get(groups, :local_candidate) == nil
     assert Map.get(groups, :remote_candidate) == nil
+    assert Map.get(groups, :candidate_pair) == nil
 
     # negotiate tracks
     {:ok, pc2} = PeerConnection.start_link()
@@ -1025,6 +1026,7 @@ defmodule ExWebRTC.PeerConnectionTest do
     assert length(Map.get(groups, :outbound_rtp, [])) == 1
     assert length(Map.get(groups, :local_candidate, [])) > 0
     assert length(Map.get(groups, :remote_candidate, [])) > 0
+    assert length(Map.get(groups, :candidate_pair, [])) > 0
 
     assert %{
              peer_connection: %{
@@ -1056,6 +1058,7 @@ defmodule ExWebRTC.PeerConnectionTest do
     assert length(Map.get(groups, :outbound_rtp, [])) == 1
     assert length(Map.get(groups, :local_candidate, [])) > 0
     assert length(Map.get(groups, :remote_candidate, [])) > 0
+    assert length(Map.get(groups, :candidate_pair, [])) > 0
   end
 
   test "close/1" do