Conform to the new API

Author: Noarkhh

rtp/lib/membrane_demo_rtp/receive_pipeline.ex

@@ -11,9 +11,9 @@ defmodule Membrane.Demo.RTP.ReceivePipeline do
   def handle_init(_ctx, opts) do
     %{audio_port: audio_port, video_port: video_port, secure?: secure?, srtp_key: srtp_key} = opts
 
-    use_srtp =
+    srtp =
       if secure? do
-        {true, [%ExLibSRTP.Policy{ssrc: :any_inbound, key: srtp_key}]}
+        [%ExLibSRTP.Policy{ssrc: :any_inbound, key: srtp_key}]
       else
         false
       end
@@ -24,7 +24,7 @@ defmodule Membrane.Demo.RTP.ReceivePipeline do
            local_port_no: video_port,
            local_address: @local_ip
          })
-         |> child(:video_rtp_demuxer, %RTP.Demuxer{use_srtp: use_srtp})
+         |> child(:video_rtp_demuxer, %RTP.Demuxer{srtp: srtp})
          |> via_out(:output, options: [stream_id: {:encoding_name, :H264}])
          |> child(:video_depayloader, RTP.H264.Depayloader)
          |> child(:video_parser, %H264.Parser{
@@ -36,7 +36,7 @@ defmodule Membrane.Demo.RTP.ReceivePipeline do
            local_port_no: audio_port,
            local_address: @local_ip
          })
-         |> child(:audio_rtp_demuxer, %RTP.Demuxer{use_srtp: use_srtp})
+         |> child(:audio_rtp_demuxer, %RTP.Demuxer{srtp: srtp})
          |> via_out(:output, options: [stream_id: {:encoding_name, :opus}])
          |> child(:audio_depayloader, RTP.Opus.Depayloader)
          |> child(:audio_decoder, Opus.Decoder)

rtp/lib/membrane_demo_rtp/send_pipeline.ex

@@ -12,9 +12,9 @@ defmodule Membrane.Demo.RTP.SendPipeline do
       srtp_key: srtp_key
     } = opts
 
-    use_srtp =
+    srtp =
       if secure? do
-        {true, [%ExLibSRTP.Policy{ssrc: :any_inbound, key: srtp_key}]}
+        [%ExLibSRTP.Policy{ssrc: :any_inbound, key: srtp_key}]
       else
         false
       end
@@ -28,7 +28,7 @@ defmodule Membrane.Demo.RTP.SendPipeline do
         output_alignment: :nalu
       })
       |> child(:video_payloader, RTP.H264.Payloader)
-      |> child(:video_rtp_muxer, %RTP.Muxer{use_srtp: use_srtp})
+      |> child(:video_rtp_muxer, %RTP.Muxer{srtp: srtp})
       |> child(:video_realtimer, Membrane.Realtimer)
       |> child(:video_sink, %UDP.Sink{
         destination_port_no: video_port,
@@ -43,7 +43,7 @@ defmodule Membrane.Demo.RTP.SendPipeline do
         generate_best_effort_timestamps?: true
       })
       |> child(:audio_payloader, RTP.Opus.Payloader)
-      |> child(:audio_rtp_muxer, %RTP.Muxer{use_srtp: use_srtp})
+      |> child(:audio_rtp_muxer, %RTP.Muxer{srtp: srtp})
       |> child(:audio_realtimer, Membrane.Realtimer)
       |> child(:audio_sink, %UDP.Sink{
         destination_port_no: audio_port,

rtp/mix.exs

@@ -24,7 +24,8 @@ defmodule Membrane.Demo.RTP.MixProject do
   defp deps do
     [
       {:membrane_core, "~> 1.0"},
-      {:membrane_rtp_plugin, path: "../../membrane_rtp_plugin/"},
+      {:membrane_rtp_plugin,
+       github: "membraneframework/membrane_rtp_plugin", branch: "srtp-demuxer-muxer"},
       # {:membrane_rtp_plugin, "~> 0.27.1"},
       {:membrane_udp_plugin, "~> 0.13.0"},
       {:membrane_h264_ffmpeg_plugin, "~> 0.31.6"},