@@ -127,7 +127,7 @@ defmodule LiveExWebRTC.Publisher do
127
127
@ type on_packet ::
128
128
( publisher_id :: String . t ( ) ,
129
129
packet_type :: :audio | :video ,
130
- layer :: nil | "l" | "m" | "h" ,
130
+ layer :: nil | String . t ( ) ,
131
131
packet :: ExRTP.Packet . t ( ) ,
132
132
socket :: Phoenix.LiveView.Socket . t ( ) ->
133
133
packet :: ExRTP.Packet . t ( ) )
@@ -551,6 +551,8 @@ defmodule LiveExWebRTC.Publisher do
551
551
def handle_info ( { :ex_webrtc , _pc , { :rtp , track_id , rid , packet } } , socket ) do
552
552
% { publisher: publisher } = socket . assigns
553
553
554
+ if publisher . record? , do: Recorder . record ( publisher . recorder , track_id , rid , packet )
555
+
554
556
{ kind , rid } =
555
557
case publisher do
556
558
% Publisher { video_track: % { id: ^ track_id } } -> { :video , rid || "h" }
@@ -562,8 +564,6 @@ defmodule LiveExWebRTC.Publisher do
562
564
do: publisher . on_packet . ( publisher . id , kind , rid , packet , socket ) ,
563
565
else: packet
564
566
565
- if publisher . record? , do: Recorder . record ( publisher . recorder , track_id , nil , packet )
566
-
567
567
{ layer , msg } =
568
568
case kind do
569
569
:audio -> { "" , { :live_ex_webrtc , kind , packet } }
0 commit comments