feat: update protos & egress service client

Rakefile

@@ -20,5 +20,6 @@ task :proto do
          "./protocol/protobufs/livekit_metrics.proto",
          "./protocol/protobufs/livekit_models.proto",
          "./protocol/protobufs/livekit_room.proto",
-         "./protocol/protobufs/livekit_webhook.proto")
+         "./protocol/protobufs/livekit_webhook.proto",
+         "./protocol/protobufs/logger/options.proto")
 end

lib/livekit/egress_service_client.rb

@@ -31,7 +31,11 @@ def start_room_composite_egress(
       # true to record only audio
       audio_only: false,
       # true to record only video
-      video_only: false
+      video_only: false,
+      # DEFAULT_MIXING, DUAL_CHANNEL_AGENT, DUAL_CHANNEL_ALTERNATE
+      audio_mixing: nil,
+      # list of extra webhooks to call for this request
+      webhooks: nil
     )
       request = Proto::RoomCompositeEgressRequest.new(
         room_name: room_name,
@@ -41,6 +45,8 @@ def start_room_composite_egress(
         custom_base_url: custom_base_url,
         audio_only: audio_only,
         video_only: video_only,
+        audio_mixing: audio_mixing,
+        webhooks: webhooks,
       )
       self.set_output(request, output)
       self.rpc(
@@ -60,14 +66,17 @@ def start_participant_egress(
       # EncodingOptionsPreset, only one of preset or advanced could be set
       preset: nil,
       # EncodingOptions, only one of preset or advanced could be set
-      advanced: nil
+      advanced: nil,
+      # list of extra webhooks to call for this request
+      webhooks: nil
     )
       request = Proto::ParticipantEgressRequest.new(
         room_name: room_name,
         identity: identity,
         screen_share: screen_share,
         preset: preset,
         advanced: advanced,
+        webhooks: webhooks,
       )
       self.set_output(request, output)
       self.rpc(
@@ -88,14 +97,17 @@ def start_track_composite_egress(
       # EncodingOptionsPreset, only one of preset or advanced could be set
       preset: nil,
       # EncodingOptions, only one of preset or advanced could be set
-      advanced: nil
+      advanced: nil,
+      # list of extra webhooks to call for this request
+      webhooks: nil
     )
       request = Proto::TrackCompositeEgressRequest.new(
         room_name: room_name,
         preset: preset,
         advanced: advanced,
         audio_track_id: audio_track_id,
         video_track_id: video_track_id,
+        webhooks: webhooks,
       )
       self.set_output(request, output)
       self.rpc(
@@ -109,11 +121,14 @@ def start_track_egress(
       room_name,
       # either a DirectFileOutput - egress to storage or string - egress to WebSocket URL
       output,
-      track_id
+      track_id,
+      # list of extra webhooks to call for this request
+      webhooks: nil
     )
       request = Proto::TrackEgressRequest.new(
         room_name: room_name,
         track_id: track_id,
+        webhooks: webhooks,
       )
       if output.filepath
         request.file = output
@@ -140,7 +155,9 @@ def start_web_egress(
       # true to record only video
       video_only: false,
       # true to await START_RECORDING chrome log
-      await_start_signal: false
+      await_start_signal: false,
+      # list of extra webhooks to call for this request
+      webhooks: nil
     )
       request = Proto::WebEgressRequest.new(
         url: url,
@@ -149,6 +166,7 @@ def start_web_egress(
         audio_only: audio_only,
         video_only: video_only,
         await_start_signal: await_start_signal,
+        webhooks: webhooks,
       )
       self.set_output(request, output)
       self.rpc(