Bump WebRTC plugin

Author: FelonEkonom

examples.livemd

@@ -509,7 +509,7 @@ System.shell("ffplay #{out_dir}/rtmp_to_mp4.mp4")
 ## Stream MP4 via WebRTC, receive it and record to MP4 again
 
 ```elixir
-signaling = Membrane.WebRTC.SignalingChannel.new()
+signaling = Membrane.WebRTC.Signaling.new()
 
 t =
   Task.async(fn ->

lib/boombox.ex

@@ -8,7 +8,7 @@ defmodule Boombox do
 
   alias Membrane.RTP
 
-  @type webrtc_signaling :: Membrane.WebRTC.SignalingChannel.t() | String.t()
+  @type webrtc_signaling :: Membrane.WebRTC.Signaling.t() | String.t()
   @type in_stream_opts :: [
           {:audio, :binary | boolean()}
           | {:video, :image | boolean()}
@@ -186,7 +186,7 @@ defmodule Boombox do
       {:mp4, location} when is_binary(location) and direction == :output ->
         {:mp4, location}
 
-      {:webrtc, %Membrane.WebRTC.SignalingChannel{}} ->
+      {:webrtc, %Membrane.WebRTC.Signaling{}} ->
         value
 
       {:webrtc, uri} when is_binary(uri) ->

lib/boombox/webrtc.ex

@@ -89,8 +89,8 @@ defmodule Boombox.WebRTC do
       if webrtc_input?(state) do
         # let's spawn websocket server for webrtc source before the source starts
         {:webrtc, input_signaling} = state.input
-        signaling_channel = resolve_signaling(input_signaling, :input, ctx.utility_supervisor)
-        state = %{state | input: {:webrtc, signaling_channel}}
+        signaling = resolve_signaling(input_signaling, :input, ctx.utility_supervisor)
+        state = %{state | input: {:webrtc, signaling}}
 
         {%Wait{actions: [spec: spec]}, state}
       else
@@ -188,7 +188,7 @@ defmodule Boombox.WebRTC do
   end
 
   defp resolve_signaling(
-         %WebRTC.SignalingChannel{} = signaling,
+         %WebRTC.Signaling{} = signaling,
          _direction,
          _utility_supervisor
        ) do
@@ -202,7 +202,7 @@ defmodule Boombox.WebRTC do
   end
 
   defp resolve_signaling({:whip, uri, opts}, :output, utility_supervisor) do
-    signaling = WebRTC.SignalingChannel.new()
+    signaling = WebRTC.Signaling.new()
 
     Membrane.UtilitySupervisor.start_link_child(
       utility_supervisor,
@@ -221,7 +221,7 @@ defmodule Boombox.WebRTC do
   end
 
   defp setup_whip_server(opts, utility_supervisor) do
-    signaling = WebRTC.SignalingChannel.new()
+    signaling = WebRTC.Signaling.new()
     clients_cnt = :atomics.new(1, [])
     {valid_token, opts} = Keyword.pop(opts, :token)
 

mix.exs

@@ -48,8 +48,7 @@ defmodule Boombox.Mixfile do
     [
       {:membrane_core, "~> 1.1"},
       {:membrane_transcoder_plugin, "~> 0.1.2"},
-      # {:membrane_webrtc_plugin, "~> 0.23.2"},
-      {:membrane_webrtc_plugin, github: "membraneframework/membrane_webrtc_plugin"},
+      {:membrane_webrtc_plugin, "~> 0.24.0"},
       {:membrane_mp4_plugin, "~> 0.35.2"},
       {:membrane_realtimer_plugin, "~> 0.9.0"},
       {:membrane_http_adaptive_stream_plugin, "~> 0.18.5"},