bump elixir webrtc to 0.3

.circleci/config.yml

@@ -10,12 +10,15 @@ workflows:
           filters: &filters
             tags:
               only: /v.*/
+          cache-version: 2
       - elixir/test:
           filters:
             <<: *filters
+          cache-version: 2
       - elixir/lint:
           filters:
             <<: *filters
+          cache-version: 2
       - elixir/hex_publish:
           requires:
             - elixir/build_test

lib/membrane_webrtc/ex_webrtc/sink.ex

@@ -133,6 +133,38 @@ defmodule Membrane.WebRTC.ExWebRTCSink do
     raise "Track #{inspect(track_id)} was rejected by the other peer"
   end
 
+  @impl true
+  def handle_info({:ex_webrtc, _from, {:rtcp, rtcp_packets}}, ctx, state) do
+    request_keyframe? =
+      rtcp_packets
+      |> Enum.reduce(false, fn packet, request_keyframe? ->
+        case packet do
+          {_track_id, %ExRTCP.Packet.PayloadFeedback.PLI{}} ->
+            Membrane.Logger.debug("Keyframe request received: #{inspect(packet)}")
+            true
+
+          _other ->
+            Membrane.Logger.debug("Ignoring RTCP packet: #{inspect(packet)}")
+            request_keyframe?
+        end
+      end)
+
+    actions =
+      if request_keyframe? do
+        ctx.pads
+        |> Enum.flat_map(fn {pad_ref, pad_data} ->
+          case pad_data.options.kind do
+            :video -> [event: {pad_ref, %Membrane.KeyframeRequestEvent{}}]
+            :audio -> []
+          end
+        end)
+      else
+        []
+      end
+
+    {actions, state}
+  end
+
   @impl true
   def handle_info({:ex_webrtc, _from, message}, _ctx, state) do
     Membrane.Logger.debug("Ignoring ex_webrtc message: #{inspect(message)}")

lib/membrane_webrtc/ex_webrtc/source.ex

@@ -81,7 +81,7 @@ defmodule Membrane.WebRTC.ExWebRTCSource do
   end
 
   @impl true
-  def handle_info({:ex_webrtc, _from, {:rtp, id, packet}}, _ctx, state) do
+  def handle_info({:ex_webrtc, _from, {:rtp, id, _rid, packet}}, _ctx, state) do
     buffer = %Membrane.Buffer{
       payload: packet.payload,
       metadata: %{rtp: packet |> Map.from_struct() |> Map.delete(:payload)}

lib/membrane_webrtc/ex_webrtc/utils.ex

@@ -15,41 +15,21 @@ defmodule Membrane.WebRTC.ExWebRTCUtils do
     ]
 
   def codec_params(:h264) do
-    pt = 96
-    rtx_pt = 97
-
     [
       %RTPCodecParameters{
-        payload_type: pt,
+        payload_type: 96,
         mime_type: "video/H264",
-        clock_rate: codec_clock_rate(:h264),
-        rtcp_fbs: [%ExSDP.Attribute.RTCPFeedback{pt: pt, feedback_type: :nack}]
-      },
-      %RTPCodecParameters{
-        payload_type: rtx_pt,
-        mime_type: "video/rtx",
-        clock_rate: codec_clock_rate(:h264),
-        sdp_fmtp_line: %ExSDP.Attribute.FMTP{pt: rtx_pt, apt: pt}
+        clock_rate: codec_clock_rate(:h264)
       }
     ]
   end
 
   def codec_params(:vp8) do
-    pt = 102
-    rtx_pt = 103
-
     [
       %RTPCodecParameters{
-        payload_type: pt,
+        payload_type: 102,
         mime_type: "video/VP8",
-        clock_rate: codec_clock_rate(:vp8),
-        rtcp_fbs: [%ExSDP.Attribute.RTCPFeedback{pt: pt, feedback_type: :nack}]
-      },
-      %RTPCodecParameters{
-        payload_type: rtx_pt,
-        mime_type: "video/rtx",
-        clock_rate: codec_clock_rate(:vp8),
-        sdp_fmtp_line: %ExSDP.Attribute.FMTP{pt: rtx_pt, apt: pt}
+        clock_rate: codec_clock_rate(:vp8)
       }
     ]
   end

mix.exs

@@ -37,8 +37,8 @@ defmodule Membrane.WebRTC.Plugin.Mixfile do
   defp deps do
     [
       {:membrane_core, "~> 1.0"},
-      {:ex_webrtc, "~> 0.2.0"},
-      {:membrane_rtp_plugin, "~> 0.27.1"},
+      {:ex_webrtc, "~> 0.3.0"},
+      {:membrane_rtp_plugin, "~> 0.29.0"},
       {:membrane_rtp_h264_plugin, "~> 0.19.0"},
       {:membrane_rtp_vp8_plugin, "~> 0.9.0"},
       {:membrane_rtp_opus_plugin, "~> 0.9.0"},