wip

Author: FelonEkonom

dupa.sh

@@ -17,12 +17,13 @@ defmodule Membrane.Agora.IntegrationTest do
         reference_video = input_video
         audio_codec = unquote(audio_codec)
 
-        input_audio =
+        input_audio_extension =
           case audio_codec do
-            :aac -> "test/fixtures/in_audio.aac"
-            :opus -> "test/fixtures/in_audio_opus.ogg"
+            :aac -> "aac"
+            :opus -> "ogg"
           end
 
+        input_audio = "test/fixtures/in_audio." <> input_audio_extension
         reference_audio = "test/fixtures/in_audio.pcm"
         output_audio = "#{dir}/audio_#{audio_codec}.pcm"
 

encoded_output_audio.ogg

@@ -4,6 +4,16 @@ defmodule Membrane.Agora.Support.ReceiverPipeline do
   use Membrane.Pipeline
   alias Membrane.Agora.TokenGenerator
 
+  defmodule Tee do
+    use Membrane.Filter
+
+    def_input_pad :input, accepted_format: _any
+    def_output_pad :output, accepted_format: _any, availability: :on_request
+
+    @impl true
+    def handle_buffer(:input, buffer, _ctx, state), do: {[forward: buffer], state}
+  end
+
   defmodule FramerateAsserter do
     @moduledoc false
     use Membrane.Filter
@@ -137,6 +147,7 @@ defmodule Membrane.Agora.Support.ReceiverPipeline do
     spec =
       get_child(:dispatcher_audio)
       |> via_out(Pad.ref(:output, user_id))
+      |> child(:tee, Tee)
       |> child(:audio_sink, %Membrane.File.Sink{location: state.audio})
 
     {[spec: spec], state}