diff --git a/packages/stream_video/lib/protobuf/video/sfu/event/events.pb.dart b/packages/stream_video/lib/protobuf/video/sfu/event/events.pb.dart
index 015c5af8e..e01e692ef 100644
--- a/packages/stream_video/lib/protobuf/video/sfu/event/events.pb.dart
+++ b/packages/stream_video/lib/protobuf/video/sfu/event/events.pb.dart
@@ -36,6 +36,8 @@ enum SfuEvent_EventPayload {
   goAway, 
   iceRestart, 
   pinsUpdated, 
+  callEnded, 
+  participantUpdated, 
   notSet
 }
 
@@ -59,10 +61,12 @@ class SfuEvent extends $pb.GeneratedMessage {
     20 : SfuEvent_EventPayload.goAway,
     21 : SfuEvent_EventPayload.iceRestart,
     22 : SfuEvent_EventPayload.pinsUpdated,
+    23 : SfuEvent_EventPayload.callEnded,
+    24 : SfuEvent_EventPayload.participantUpdated,
     0 : SfuEvent_EventPayload.notSet
   };
   static final $pb.BuilderInfo _i = $pb.BuilderInfo(const $core.bool.fromEnvironment('protobuf.omit_message_names') ? '' : 'SfuEvent', package: const $pb.PackageName(const $core.bool.fromEnvironment('protobuf.omit_message_names') ? '' : 'stream.video.sfu.event'), createEmptyInstance: create)
-    ..oo(0, [1, 2, 3, 4, 5, 6, 10, 11, 12, 13, 14, 16, 17, 18, 19, 20, 21, 22])
+    ..oo(0, [1, 2, 3, 4, 5, 6, 10, 11, 12, 13, 14, 16, 17, 18, 19, 20, 21, 22, 23, 24])
     ..aOM<SubscriberOffer>(1, const $core.bool.fromEnvironment('protobuf.omit_field_names') ? '' : 'subscriberOffer', subBuilder: SubscriberOffer.create)
     ..aOM<PublisherAnswer>(2, const $core.bool.fromEnvironment('protobuf.omit_field_names') ? '' : 'publisherAnswer', subBuilder: PublisherAnswer.create)
     ..aOM<ConnectionQualityChanged>(3, const $core.bool.fromEnvironment('protobuf.omit_field_names') ? '' : 'connectionQualityChanged', subBuilder: ConnectionQualityChanged.create)
@@ -81,6 +85,8 @@ class SfuEvent extends $pb.GeneratedMessage {
     ..aOM<GoAway>(20, const $core.bool.fromEnvironment('protobuf.omit_field_names') ? '' : 'goAway', subBuilder: GoAway.create)
     ..aOM<ICERestart>(21, const $core.bool.fromEnvironment('protobuf.omit_field_names') ? '' : 'iceRestart', subBuilder: ICERestart.create)
     ..aOM<PinsChanged>(22, const $core.bool.fromEnvironment('protobuf.omit_field_names') ? '' : 'pinsUpdated', subBuilder: PinsChanged.create)
+    ..aOM<CallEnded>(23, const $core.bool.fromEnvironment('protobuf.omit_field_names') ? '' : 'callEnded', subBuilder: CallEnded.create)
+    ..aOM<ParticipantUpdated>(24, const $core.bool.fromEnvironment('protobuf.omit_field_names') ? '' : 'participantUpdated', subBuilder: ParticipantUpdated.create)
     ..hasRequiredFields = false
   ;
 
@@ -104,6 +110,8 @@ class SfuEvent extends $pb.GeneratedMessage {
     GoAway? goAway,
     ICERestart? iceRestart,
     PinsChanged? pinsUpdated,
+    CallEnded? callEnded,
+    ParticipantUpdated? participantUpdated,
   }) {
     final _result = create();
     if (subscriberOffer != null) {
@@ -160,6 +168,12 @@ class SfuEvent extends $pb.GeneratedMessage {
     if (pinsUpdated != null) {
       _result.pinsUpdated = pinsUpdated;
     }
+    if (callEnded != null) {
+      _result.callEnded = callEnded;
+    }
+    if (participantUpdated != null) {
+      _result.participantUpdated = participantUpdated;
+    }
     return _result;
   }
   factory SfuEvent.fromBuffer($core.List<$core.int> i, [$pb.ExtensionRegistry r = $pb.ExtensionRegistry.EMPTY]) => create()..mergeFromBuffer(i, r);
@@ -383,6 +397,28 @@ class SfuEvent extends $pb.GeneratedMessage {
   void clearPinsUpdated() => clearField(22);
   @$pb.TagNumber(22)
   PinsChanged ensurePinsUpdated() => $_ensure(17);
+
+  @$pb.TagNumber(23)
+  CallEnded get callEnded => $_getN(18);
+  @$pb.TagNumber(23)
+  set callEnded(CallEnded v) { setField(23, v); }
+  @$pb.TagNumber(23)
+  $core.bool hasCallEnded() => $_has(18);
+  @$pb.TagNumber(23)
+  void clearCallEnded() => clearField(23);
+  @$pb.TagNumber(23)
+  CallEnded ensureCallEnded() => $_ensure(18);
+
+  @$pb.TagNumber(24)
+  ParticipantUpdated get participantUpdated => $_getN(19);
+  @$pb.TagNumber(24)
+  set participantUpdated(ParticipantUpdated v) { setField(24, v); }
+  @$pb.TagNumber(24)
+  $core.bool hasParticipantUpdated() => $_has(19);
+  @$pb.TagNumber(24)
+  void clearParticipantUpdated() => clearField(24);
+  @$pb.TagNumber(24)
+  ParticipantUpdated ensureParticipantUpdated() => $_ensure(19);
 }
 
 class PinsChanged extends $pb.GeneratedMessage {
@@ -429,17 +465,22 @@ class PinsChanged extends $pb.GeneratedMessage {
 class Error extends $pb.GeneratedMessage {
   static final $pb.BuilderInfo _i = $pb.BuilderInfo(const $core.bool.fromEnvironment('protobuf.omit_message_names') ? '' : 'Error', package: const $pb.PackageName(const $core.bool.fromEnvironment('protobuf.omit_message_names') ? '' : 'stream.video.sfu.event'), createEmptyInstance: create)
     ..aOM<$0.Error>(4, const $core.bool.fromEnvironment('protobuf.omit_field_names') ? '' : 'error', subBuilder: $0.Error.create)
+    ..e<$0.WebsocketReconnectStrategy>(5, const $core.bool.fromEnvironment('protobuf.omit_field_names') ? '' : 'reconnectStrategy', $pb.PbFieldType.OE, defaultOrMaker: $0.WebsocketReconnectStrategy.WEBSOCKET_RECONNECT_STRATEGY_UNSPECIFIED, valueOf: $0.WebsocketReconnectStrategy.valueOf, enumValues: $0.WebsocketReconnectStrategy.values)
     ..hasRequiredFields = false
   ;
 
   Error._() : super();
   factory Error({
     $0.Error? error,
+    $0.WebsocketReconnectStrategy? reconnectStrategy,
   }) {
     final _result = create();
     if (error != null) {
       _result.error = error;
     }
+    if (reconnectStrategy != null) {
+      _result.reconnectStrategy = reconnectStrategy;
+    }
     return _result;
   }
   factory Error.fromBuffer($core.List<$core.int> i, [$pb.ExtensionRegistry r = $pb.ExtensionRegistry.EMPTY]) => create()..mergeFromBuffer(i, r);
@@ -473,6 +514,15 @@ class Error extends $pb.GeneratedMessage {
   void clearError() => clearField(4);
   @$pb.TagNumber(4)
   $0.Error ensureError() => $_ensure(0);
+
+  @$pb.TagNumber(5)
+  $0.WebsocketReconnectStrategy get reconnectStrategy => $_getN(1);
+  @$pb.TagNumber(5)
+  set reconnectStrategy($0.WebsocketReconnectStrategy v) { setField(5, v); }
+  @$pb.TagNumber(5)
+  $core.bool hasReconnectStrategy() => $_has(1);
+  @$pb.TagNumber(5)
+  void clearReconnectStrategy() => clearField(5);
 }
 
 class ICETrickle extends $pb.GeneratedMessage {
@@ -1310,6 +1360,69 @@ class ParticipantLeft extends $pb.GeneratedMessage {
   $0.Participant ensureParticipant() => $_ensure(1);
 }
 
+class ParticipantUpdated extends $pb.GeneratedMessage {
+  static final $pb.BuilderInfo _i = $pb.BuilderInfo(const $core.bool.fromEnvironment('protobuf.omit_message_names') ? '' : 'ParticipantUpdated', package: const $pb.PackageName(const $core.bool.fromEnvironment('protobuf.omit_message_names') ? '' : 'stream.video.sfu.event'), createEmptyInstance: create)
+    ..aOS(1, const $core.bool.fromEnvironment('protobuf.omit_field_names') ? '' : 'callCid')
+    ..aOM<$0.Participant>(2, const $core.bool.fromEnvironment('protobuf.omit_field_names') ? '' : 'participant', subBuilder: $0.Participant.create)
+    ..hasRequiredFields = false
+  ;
+
+  ParticipantUpdated._() : super();
+  factory ParticipantUpdated({
+    $core.String? callCid,
+    $0.Participant? participant,
+  }) {
+    final _result = create();
+    if (callCid != null) {
+      _result.callCid = callCid;
+    }
+    if (participant != null) {
+      _result.participant = participant;
+    }
+    return _result;
+  }
+  factory ParticipantUpdated.fromBuffer($core.List<$core.int> i, [$pb.ExtensionRegistry r = $pb.ExtensionRegistry.EMPTY]) => create()..mergeFromBuffer(i, r);
+  factory ParticipantUpdated.fromJson($core.String i, [$pb.ExtensionRegistry r = $pb.ExtensionRegistry.EMPTY]) => create()..mergeFromJson(i, r);
+  @$core.Deprecated(
+  'Using this can add significant overhead to your binary. '
+  'Use [GeneratedMessageGenericExtensions.deepCopy] instead. '
+  'Will be removed in next major version')
+  ParticipantUpdated clone() => ParticipantUpdated()..mergeFromMessage(this);
+  @$core.Deprecated(
+  'Using this can add significant overhead to your binary. '
+  'Use [GeneratedMessageGenericExtensions.rebuild] instead. '
+  'Will be removed in next major version')
+  ParticipantUpdated copyWith(void Function(ParticipantUpdated) updates) => super.copyWith((message) => updates(message as ParticipantUpdated)) as ParticipantUpdated; // ignore: deprecated_member_use
+  $pb.BuilderInfo get info_ => _i;
+  @$core.pragma('dart2js:noInline')
+  static ParticipantUpdated create() => ParticipantUpdated._();
+  ParticipantUpdated createEmptyInstance() => create();
+  static $pb.PbList<ParticipantUpdated> createRepeated() => $pb.PbList<ParticipantUpdated>();
+  @$core.pragma('dart2js:noInline')
+  static ParticipantUpdated getDefault() => _defaultInstance ??= $pb.GeneratedMessage.$_defaultFor<ParticipantUpdated>(create);
+  static ParticipantUpdated? _defaultInstance;
+
+  @$pb.TagNumber(1)
+  $core.String get callCid => $_getSZ(0);
+  @$pb.TagNumber(1)
+  set callCid($core.String v) { $_setString(0, v); }
+  @$pb.TagNumber(1)
+  $core.bool hasCallCid() => $_has(0);
+  @$pb.TagNumber(1)
+  void clearCallCid() => clearField(1);
+
+  @$pb.TagNumber(2)
+  $0.Participant get participant => $_getN(1);
+  @$pb.TagNumber(2)
+  set participant($0.Participant v) { setField(2, v); }
+  @$pb.TagNumber(2)
+  $core.bool hasParticipant() => $_has(1);
+  @$pb.TagNumber(2)
+  void clearParticipant() => clearField(2);
+  @$pb.TagNumber(2)
+  $0.Participant ensureParticipant() => $_ensure(1);
+}
+
 class SubscriberOffer extends $pb.GeneratedMessage {
   static final $pb.BuilderInfo _i = $pb.BuilderInfo(const $core.bool.fromEnvironment('protobuf.omit_message_names') ? '' : 'SubscriberOffer', package: const $pb.PackageName(const $core.bool.fromEnvironment('protobuf.omit_message_names') ? '' : 'stream.video.sfu.event'), createEmptyInstance: create)
     ..aOB(1, const $core.bool.fromEnvironment('protobuf.omit_field_names') ? '' : 'iceRestart')
@@ -2277,3 +2390,50 @@ class GoAway extends $pb.GeneratedMessage {
   void clearReason() => clearField(1);
 }
 
+class CallEnded extends $pb.GeneratedMessage {
+  static final $pb.BuilderInfo _i = $pb.BuilderInfo(const $core.bool.fromEnvironment('protobuf.omit_message_names') ? '' : 'CallEnded', package: const $pb.PackageName(const $core.bool.fromEnvironment('protobuf.omit_message_names') ? '' : 'stream.video.sfu.event'), createEmptyInstance: create)
+    ..e<$0.CallEndedReason>(1, const $core.bool.fromEnvironment('protobuf.omit_field_names') ? '' : 'reason', $pb.PbFieldType.OE, defaultOrMaker: $0.CallEndedReason.CALL_ENDED_REASON_UNSPECIFIED, valueOf: $0.CallEndedReason.valueOf, enumValues: $0.CallEndedReason.values)
+    ..hasRequiredFields = false
+  ;
+
+  CallEnded._() : super();
+  factory CallEnded({
+    $0.CallEndedReason? reason,
+  }) {
+    final _result = create();
+    if (reason != null) {
+      _result.reason = reason;
+    }
+    return _result;
+  }
+  factory CallEnded.fromBuffer($core.List<$core.int> i, [$pb.ExtensionRegistry r = $pb.ExtensionRegistry.EMPTY]) => create()..mergeFromBuffer(i, r);
+  factory CallEnded.fromJson($core.String i, [$pb.ExtensionRegistry r = $pb.ExtensionRegistry.EMPTY]) => create()..mergeFromJson(i, r);
+  @$core.Deprecated(
+  'Using this can add significant overhead to your binary. '
+  'Use [GeneratedMessageGenericExtensions.deepCopy] instead. '
+  'Will be removed in next major version')
+  CallEnded clone() => CallEnded()..mergeFromMessage(this);
+  @$core.Deprecated(
+  'Using this can add significant overhead to your binary. '
+  'Use [GeneratedMessageGenericExtensions.rebuild] instead. '
+  'Will be removed in next major version')
+  CallEnded copyWith(void Function(CallEnded) updates) => super.copyWith((message) => updates(message as CallEnded)) as CallEnded; // ignore: deprecated_member_use
+  $pb.BuilderInfo get info_ => _i;
+  @$core.pragma('dart2js:noInline')
+  static CallEnded create() => CallEnded._();
+  CallEnded createEmptyInstance() => create();
+  static $pb.PbList<CallEnded> createRepeated() => $pb.PbList<CallEnded>();
+  @$core.pragma('dart2js:noInline')
+  static CallEnded getDefault() => _defaultInstance ??= $pb.GeneratedMessage.$_defaultFor<CallEnded>(create);
+  static CallEnded? _defaultInstance;
+
+  @$pb.TagNumber(1)
+  $0.CallEndedReason get reason => $_getN(0);
+  @$pb.TagNumber(1)
+  set reason($0.CallEndedReason v) { setField(1, v); }
+  @$pb.TagNumber(1)
+  $core.bool hasReason() => $_has(0);
+  @$pb.TagNumber(1)
+  void clearReason() => clearField(1);
+}
+
diff --git a/packages/stream_video/lib/protobuf/video/sfu/event/events.pbjson.dart b/packages/stream_video/lib/protobuf/video/sfu/event/events.pbjson.dart
index 8f63f31b6..4ad341005 100644
--- a/packages/stream_video/lib/protobuf/video/sfu/event/events.pbjson.dart
+++ b/packages/stream_video/lib/protobuf/video/sfu/event/events.pbjson.dart
@@ -30,6 +30,8 @@ const SfuEvent$json = const {
     const {'1': 'go_away', '3': 20, '4': 1, '5': 11, '6': '.stream.video.sfu.event.GoAway', '9': 0, '10': 'goAway'},
     const {'1': 'ice_restart', '3': 21, '4': 1, '5': 11, '6': '.stream.video.sfu.event.ICERestart', '9': 0, '10': 'iceRestart'},
     const {'1': 'pins_updated', '3': 22, '4': 1, '5': 11, '6': '.stream.video.sfu.event.PinsChanged', '9': 0, '10': 'pinsUpdated'},
+    const {'1': 'call_ended', '3': 23, '4': 1, '5': 11, '6': '.stream.video.sfu.event.CallEnded', '9': 0, '10': 'callEnded'},
+    const {'1': 'participant_updated', '3': 24, '4': 1, '5': 11, '6': '.stream.video.sfu.event.ParticipantUpdated', '9': 0, '10': 'participantUpdated'},
   ],
   '8': const [
     const {'1': 'event_payload'},
@@ -37,7 +39,7 @@ const SfuEvent$json = const {
 };
 
 /// Descriptor for `SfuEvent`. Decode as a `google.protobuf.DescriptorProto`.
-final $typed_data.Uint8List sfuEventDescriptor = $convert.base64Decode('CghTZnVFdmVudBJUChBzdWJzY3JpYmVyX29mZmVyGAEgASgLMicuc3RyZWFtLnZpZGVvLnNmdS5ldmVudC5TdWJzY3JpYmVyT2ZmZXJIAFIPc3Vic2NyaWJlck9mZmVyElQKEHB1Ymxpc2hlcl9hbnN3ZXIYAiABKAsyJy5zdHJlYW0udmlkZW8uc2Z1LmV2ZW50LlB1Ymxpc2hlckFuc3dlckgAUg9wdWJsaXNoZXJBbnN3ZXIScAoaY29ubmVjdGlvbl9xdWFsaXR5X2NoYW5nZWQYAyABKAsyMC5zdHJlYW0udmlkZW8uc2Z1LmV2ZW50LkNvbm5lY3Rpb25RdWFsaXR5Q2hhbmdlZEgAUhhjb25uZWN0aW9uUXVhbGl0eUNoYW5nZWQSWwoTYXVkaW9fbGV2ZWxfY2hhbmdlZBgEIAEoCzIpLnN0cmVhbS52aWRlby5zZnUuZXZlbnQuQXVkaW9MZXZlbENoYW5nZWRIAFIRYXVkaW9MZXZlbENoYW5nZWQSRgoLaWNlX3RyaWNrbGUYBSABKAsyIy5zdHJlYW0udmlkZW8uc2Z1Lm1vZGVscy5JQ0VUcmlja2xlSABSCmljZVRyaWNrbGUSZAoWY2hhbmdlX3B1Ymxpc2hfcXVhbGl0eRgGIAEoCzIsLnN0cmVhbS52aWRlby5zZnUuZXZlbnQuQ2hhbmdlUHVibGlzaFF1YWxpdHlIAFIUY2hhbmdlUHVibGlzaFF1YWxpdHkSWgoScGFydGljaXBhbnRfam9pbmVkGAogASgLMikuc3RyZWFtLnZpZGVvLnNmdS5ldmVudC5QYXJ0aWNpcGFudEpvaW5lZEgAUhFwYXJ0aWNpcGFudEpvaW5lZBJUChBwYXJ0aWNpcGFudF9sZWZ0GAsgASgLMicuc3RyZWFtLnZpZGVvLnNmdS5ldmVudC5QYXJ0aWNpcGFudExlZnRIAFIPcGFydGljaXBhbnRMZWZ0EmoKGGRvbWluYW50X3NwZWFrZXJfY2hhbmdlZBgMIAEoCzIuLnN0cmVhbS52aWRlby5zZnUuZXZlbnQuRG9taW5hbnRTcGVha2VyQ2hhbmdlZEgAUhZkb21pbmFudFNwZWFrZXJDaGFuZ2VkEksKDWpvaW5fcmVzcG9uc2UYDSABKAsyJC5zdHJlYW0udmlkZW8uc2Z1LmV2ZW50LkpvaW5SZXNwb25zZUgAUgxqb2luUmVzcG9uc2USYQoVaGVhbHRoX2NoZWNrX3Jlc3BvbnNlGA4gASgLMisuc3RyZWFtLnZpZGVvLnNmdS5ldmVudC5IZWFsdGhDaGVja1Jlc3BvbnNlSABSE2hlYWx0aENoZWNrUmVzcG9uc2USUQoPdHJhY2tfcHVibGlzaGVkGBAgASgLMiYuc3RyZWFtLnZpZGVvLnNmdS5ldmVudC5UcmFja1B1Ymxpc2hlZEgAUg50cmFja1B1Ymxpc2hlZBJXChF0cmFja191bnB1Ymxpc2hlZBgRIAEoCzIoLnN0cmVhbS52aWRlby5zZnUuZXZlbnQuVHJhY2tVbnB1Ymxpc2hlZEgAUhB0cmFja1VucHVibGlzaGVkEjUKBWVycm9yGBIgASgLMh0uc3RyZWFtLnZpZGVvLnNmdS5ldmVudC5FcnJvckgAUgVlcnJvchJbChNjYWxsX2dyYW50c191cGRhdGVkGBMgASgLMikuc3RyZWFtLnZpZGVvLnNmdS5ldmVudC5DYWxsR3JhbnRzVXBkYXRlZEgAUhFjYWxsR3JhbnRzVXBkYXRlZBI5Cgdnb19hd2F5GBQgASgLMh4uc3RyZWFtLnZpZGVvLnNmdS5ldmVudC5Hb0F3YXlIAFIGZ29Bd2F5EkUKC2ljZV9yZXN0YXJ0GBUgASgLMiIuc3RyZWFtLnZpZGVvLnNmdS5ldmVudC5JQ0VSZXN0YXJ0SABSCmljZVJlc3RhcnQSSAoMcGluc191cGRhdGVkGBYgASgLMiMuc3RyZWFtLnZpZGVvLnNmdS5ldmVudC5QaW5zQ2hhbmdlZEgAUgtwaW5zVXBkYXRlZEIPCg1ldmVudF9wYXlsb2Fk');
+final $typed_data.Uint8List sfuEventDescriptor = $convert.base64Decode('CghTZnVFdmVudBJUChBzdWJzY3JpYmVyX29mZmVyGAEgASgLMicuc3RyZWFtLnZpZGVvLnNmdS5ldmVudC5TdWJzY3JpYmVyT2ZmZXJIAFIPc3Vic2NyaWJlck9mZmVyElQKEHB1Ymxpc2hlcl9hbnN3ZXIYAiABKAsyJy5zdHJlYW0udmlkZW8uc2Z1LmV2ZW50LlB1Ymxpc2hlckFuc3dlckgAUg9wdWJsaXNoZXJBbnN3ZXIScAoaY29ubmVjdGlvbl9xdWFsaXR5X2NoYW5nZWQYAyABKAsyMC5zdHJlYW0udmlkZW8uc2Z1LmV2ZW50LkNvbm5lY3Rpb25RdWFsaXR5Q2hhbmdlZEgAUhhjb25uZWN0aW9uUXVhbGl0eUNoYW5nZWQSWwoTYXVkaW9fbGV2ZWxfY2hhbmdlZBgEIAEoCzIpLnN0cmVhbS52aWRlby5zZnUuZXZlbnQuQXVkaW9MZXZlbENoYW5nZWRIAFIRYXVkaW9MZXZlbENoYW5nZWQSRgoLaWNlX3RyaWNrbGUYBSABKAsyIy5zdHJlYW0udmlkZW8uc2Z1Lm1vZGVscy5JQ0VUcmlja2xlSABSCmljZVRyaWNrbGUSZAoWY2hhbmdlX3B1Ymxpc2hfcXVhbGl0eRgGIAEoCzIsLnN0cmVhbS52aWRlby5zZnUuZXZlbnQuQ2hhbmdlUHVibGlzaFF1YWxpdHlIAFIUY2hhbmdlUHVibGlzaFF1YWxpdHkSWgoScGFydGljaXBhbnRfam9pbmVkGAogASgLMikuc3RyZWFtLnZpZGVvLnNmdS5ldmVudC5QYXJ0aWNpcGFudEpvaW5lZEgAUhFwYXJ0aWNpcGFudEpvaW5lZBJUChBwYXJ0aWNpcGFudF9sZWZ0GAsgASgLMicuc3RyZWFtLnZpZGVvLnNmdS5ldmVudC5QYXJ0aWNpcGFudExlZnRIAFIPcGFydGljaXBhbnRMZWZ0EmoKGGRvbWluYW50X3NwZWFrZXJfY2hhbmdlZBgMIAEoCzIuLnN0cmVhbS52aWRlby5zZnUuZXZlbnQuRG9taW5hbnRTcGVha2VyQ2hhbmdlZEgAUhZkb21pbmFudFNwZWFrZXJDaGFuZ2VkEksKDWpvaW5fcmVzcG9uc2UYDSABKAsyJC5zdHJlYW0udmlkZW8uc2Z1LmV2ZW50LkpvaW5SZXNwb25zZUgAUgxqb2luUmVzcG9uc2USYQoVaGVhbHRoX2NoZWNrX3Jlc3BvbnNlGA4gASgLMisuc3RyZWFtLnZpZGVvLnNmdS5ldmVudC5IZWFsdGhDaGVja1Jlc3BvbnNlSABSE2hlYWx0aENoZWNrUmVzcG9uc2USUQoPdHJhY2tfcHVibGlzaGVkGBAgASgLMiYuc3RyZWFtLnZpZGVvLnNmdS5ldmVudC5UcmFja1B1Ymxpc2hlZEgAUg50cmFja1B1Ymxpc2hlZBJXChF0cmFja191bnB1Ymxpc2hlZBgRIAEoCzIoLnN0cmVhbS52aWRlby5zZnUuZXZlbnQuVHJhY2tVbnB1Ymxpc2hlZEgAUhB0cmFja1VucHVibGlzaGVkEjUKBWVycm9yGBIgASgLMh0uc3RyZWFtLnZpZGVvLnNmdS5ldmVudC5FcnJvckgAUgVlcnJvchJbChNjYWxsX2dyYW50c191cGRhdGVkGBMgASgLMikuc3RyZWFtLnZpZGVvLnNmdS5ldmVudC5DYWxsR3JhbnRzVXBkYXRlZEgAUhFjYWxsR3JhbnRzVXBkYXRlZBI5Cgdnb19hd2F5GBQgASgLMh4uc3RyZWFtLnZpZGVvLnNmdS5ldmVudC5Hb0F3YXlIAFIGZ29Bd2F5EkUKC2ljZV9yZXN0YXJ0GBUgASgLMiIuc3RyZWFtLnZpZGVvLnNmdS5ldmVudC5JQ0VSZXN0YXJ0SABSCmljZVJlc3RhcnQSSAoMcGluc191cGRhdGVkGBYgASgLMiMuc3RyZWFtLnZpZGVvLnNmdS5ldmVudC5QaW5zQ2hhbmdlZEgAUgtwaW5zVXBkYXRlZBJCCgpjYWxsX2VuZGVkGBcgASgLMiEuc3RyZWFtLnZpZGVvLnNmdS5ldmVudC5DYWxsRW5kZWRIAFIJY2FsbEVuZGVkEl0KE3BhcnRpY2lwYW50X3VwZGF0ZWQYGCABKAsyKi5zdHJlYW0udmlkZW8uc2Z1LmV2ZW50LlBhcnRpY2lwYW50VXBkYXRlZEgAUhJwYXJ0aWNpcGFudFVwZGF0ZWRCDwoNZXZlbnRfcGF5bG9hZA==');
 @$core.Deprecated('Use pinsChangedDescriptor instead')
 const PinsChanged$json = const {
   '1': 'PinsChanged',
@@ -53,11 +55,12 @@ const Error$json = const {
   '1': 'Error',
   '2': const [
     const {'1': 'error', '3': 4, '4': 1, '5': 11, '6': '.stream.video.sfu.models.Error', '10': 'error'},
+    const {'1': 'reconnect_strategy', '3': 5, '4': 1, '5': 14, '6': '.stream.video.sfu.models.WebsocketReconnectStrategy', '10': 'reconnectStrategy'},
   ],
 };
 
 /// Descriptor for `Error`. Decode as a `google.protobuf.DescriptorProto`.
-final $typed_data.Uint8List errorDescriptor = $convert.base64Decode('CgVFcnJvchI0CgVlcnJvchgEIAEoCzIeLnN0cmVhbS52aWRlby5zZnUubW9kZWxzLkVycm9yUgVlcnJvcg==');
+final $typed_data.Uint8List errorDescriptor = $convert.base64Decode('CgVFcnJvchI0CgVlcnJvchgEIAEoCzIeLnN0cmVhbS52aWRlby5zZnUubW9kZWxzLkVycm9yUgVlcnJvchJiChJyZWNvbm5lY3Rfc3RyYXRlZ3kYBSABKA4yMy5zdHJlYW0udmlkZW8uc2Z1Lm1vZGVscy5XZWJzb2NrZXRSZWNvbm5lY3RTdHJhdGVneVIRcmVjb25uZWN0U3RyYXRlZ3k=');
 @$core.Deprecated('Use iCETrickleDescriptor instead')
 const ICETrickle$json = const {
   '1': 'ICETrickle',
@@ -197,6 +200,17 @@ const ParticipantLeft$json = const {
 
 /// Descriptor for `ParticipantLeft`. Decode as a `google.protobuf.DescriptorProto`.
 final $typed_data.Uint8List participantLeftDescriptor = $convert.base64Decode('Cg9QYXJ0aWNpcGFudExlZnQSGQoIY2FsbF9jaWQYASABKAlSB2NhbGxDaWQSRgoLcGFydGljaXBhbnQYAiABKAsyJC5zdHJlYW0udmlkZW8uc2Z1Lm1vZGVscy5QYXJ0aWNpcGFudFILcGFydGljaXBhbnQ=');
+@$core.Deprecated('Use participantUpdatedDescriptor instead')
+const ParticipantUpdated$json = const {
+  '1': 'ParticipantUpdated',
+  '2': const [
+    const {'1': 'call_cid', '3': 1, '4': 1, '5': 9, '10': 'callCid'},
+    const {'1': 'participant', '3': 2, '4': 1, '5': 11, '6': '.stream.video.sfu.models.Participant', '10': 'participant'},
+  ],
+};
+
+/// Descriptor for `ParticipantUpdated`. Decode as a `google.protobuf.DescriptorProto`.
+final $typed_data.Uint8List participantUpdatedDescriptor = $convert.base64Decode('ChJQYXJ0aWNpcGFudFVwZGF0ZWQSGQoIY2FsbF9jaWQYASABKAlSB2NhbGxDaWQSRgoLcGFydGljaXBhbnQYAiABKAsyJC5zdHJlYW0udmlkZW8uc2Z1Lm1vZGVscy5QYXJ0aWNpcGFudFILcGFydGljaXBhbnQ=');
 @$core.Deprecated('Use subscriberOfferDescriptor instead')
 const SubscriberOffer$json = const {
   '1': 'SubscriberOffer',
@@ -379,3 +393,13 @@ const GoAway$json = const {
 
 /// Descriptor for `GoAway`. Decode as a `google.protobuf.DescriptorProto`.
 final $typed_data.Uint8List goAwayDescriptor = $convert.base64Decode('CgZHb0F3YXkSPQoGcmVhc29uGAEgASgOMiUuc3RyZWFtLnZpZGVvLnNmdS5tb2RlbHMuR29Bd2F5UmVhc29uUgZyZWFzb24=');
+@$core.Deprecated('Use callEndedDescriptor instead')
+const CallEnded$json = const {
+  '1': 'CallEnded',
+  '2': const [
+    const {'1': 'reason', '3': 1, '4': 1, '5': 14, '6': '.stream.video.sfu.models.CallEndedReason', '10': 'reason'},
+  ],
+};
+
+/// Descriptor for `CallEnded`. Decode as a `google.protobuf.DescriptorProto`.
+final $typed_data.Uint8List callEndedDescriptor = $convert.base64Decode('CglDYWxsRW5kZWQSQAoGcmVhc29uGAEgASgOMiguc3RyZWFtLnZpZGVvLnNmdS5tb2RlbHMuQ2FsbEVuZGVkUmVhc29uUgZyZWFzb24=');
diff --git a/packages/stream_video/lib/protobuf/video/sfu/models/models.pbenum.dart b/packages/stream_video/lib/protobuf/video/sfu/models/models.pbenum.dart
index 9f5b96104..07bf7ca96 100644
--- a/packages/stream_video/lib/protobuf/video/sfu/models/models.pbenum.dart
+++ b/packages/stream_video/lib/protobuf/video/sfu/models/models.pbenum.dart
@@ -197,3 +197,45 @@ class GoAwayReason extends $pb.ProtobufEnum {
   const GoAwayReason._($core.int v, $core.String n) : super(v, n);
 }
 
+class CallEndedReason extends $pb.ProtobufEnum {
+  static const CallEndedReason CALL_ENDED_REASON_UNSPECIFIED = CallEndedReason._(0, const $core.bool.fromEnvironment('protobuf.omit_enum_names') ? '' : 'CALL_ENDED_REASON_UNSPECIFIED');
+  static const CallEndedReason CALL_ENDED_REASON_ENDED = CallEndedReason._(1, const $core.bool.fromEnvironment('protobuf.omit_enum_names') ? '' : 'CALL_ENDED_REASON_ENDED');
+  static const CallEndedReason CALL_ENDED_REASON_LIVE_ENDED = CallEndedReason._(2, const $core.bool.fromEnvironment('protobuf.omit_enum_names') ? '' : 'CALL_ENDED_REASON_LIVE_ENDED');
+  static const CallEndedReason CALL_ENDED_REASON_KICKED = CallEndedReason._(3, const $core.bool.fromEnvironment('protobuf.omit_enum_names') ? '' : 'CALL_ENDED_REASON_KICKED');
+
+  static const $core.List<CallEndedReason> values = <CallEndedReason> [
+    CALL_ENDED_REASON_UNSPECIFIED,
+    CALL_ENDED_REASON_ENDED,
+    CALL_ENDED_REASON_LIVE_ENDED,
+    CALL_ENDED_REASON_KICKED,
+  ];
+
+  static final $core.Map<$core.int, CallEndedReason> _byValue = $pb.ProtobufEnum.initByValue(values);
+  static CallEndedReason? valueOf($core.int value) => _byValue[value];
+
+  const CallEndedReason._($core.int v, $core.String n) : super(v, n);
+}
+
+class WebsocketReconnectStrategy extends $pb.ProtobufEnum {
+  static const WebsocketReconnectStrategy WEBSOCKET_RECONNECT_STRATEGY_UNSPECIFIED = WebsocketReconnectStrategy._(0, const $core.bool.fromEnvironment('protobuf.omit_enum_names') ? '' : 'WEBSOCKET_RECONNECT_STRATEGY_UNSPECIFIED');
+  static const WebsocketReconnectStrategy WEBSOCKET_RECONNECT_STRATEGY_DISCONNECT = WebsocketReconnectStrategy._(1, const $core.bool.fromEnvironment('protobuf.omit_enum_names') ? '' : 'WEBSOCKET_RECONNECT_STRATEGY_DISCONNECT');
+  static const WebsocketReconnectStrategy WEBSOCKET_RECONNECT_STRATEGY_FAST = WebsocketReconnectStrategy._(2, const $core.bool.fromEnvironment('protobuf.omit_enum_names') ? '' : 'WEBSOCKET_RECONNECT_STRATEGY_FAST');
+  static const WebsocketReconnectStrategy WEBSOCKET_RECONNECT_STRATEGY_CLEAN = WebsocketReconnectStrategy._(3, const $core.bool.fromEnvironment('protobuf.omit_enum_names') ? '' : 'WEBSOCKET_RECONNECT_STRATEGY_CLEAN');
+  static const WebsocketReconnectStrategy WEBSOCKET_RECONNECT_STRATEGY_FULL = WebsocketReconnectStrategy._(4, const $core.bool.fromEnvironment('protobuf.omit_enum_names') ? '' : 'WEBSOCKET_RECONNECT_STRATEGY_FULL');
+  static const WebsocketReconnectStrategy WEBSOCKET_RECONNECT_STRATEGY_MIGRATE = WebsocketReconnectStrategy._(5, const $core.bool.fromEnvironment('protobuf.omit_enum_names') ? '' : 'WEBSOCKET_RECONNECT_STRATEGY_MIGRATE');
+
+  static const $core.List<WebsocketReconnectStrategy> values = <WebsocketReconnectStrategy> [
+    WEBSOCKET_RECONNECT_STRATEGY_UNSPECIFIED,
+    WEBSOCKET_RECONNECT_STRATEGY_DISCONNECT,
+    WEBSOCKET_RECONNECT_STRATEGY_FAST,
+    WEBSOCKET_RECONNECT_STRATEGY_CLEAN,
+    WEBSOCKET_RECONNECT_STRATEGY_FULL,
+    WEBSOCKET_RECONNECT_STRATEGY_MIGRATE,
+  ];
+
+  static final $core.Map<$core.int, WebsocketReconnectStrategy> _byValue = $pb.ProtobufEnum.initByValue(values);
+  static WebsocketReconnectStrategy? valueOf($core.int value) => _byValue[value];
+
+  const WebsocketReconnectStrategy._($core.int v, $core.String n) : super(v, n);
+}
+
diff --git a/packages/stream_video/lib/protobuf/video/sfu/models/models.pbjson.dart b/packages/stream_video/lib/protobuf/video/sfu/models/models.pbjson.dart
index af2a11dc7..2b6c89078 100644
--- a/packages/stream_video/lib/protobuf/video/sfu/models/models.pbjson.dart
+++ b/packages/stream_video/lib/protobuf/video/sfu/models/models.pbjson.dart
@@ -130,6 +130,34 @@ const GoAwayReason$json = const {
 
 /// Descriptor for `GoAwayReason`. Decode as a `google.protobuf.EnumDescriptorProto`.
 final $typed_data.Uint8List goAwayReasonDescriptor = $convert.base64Decode('CgxHb0F3YXlSZWFzb24SHgoaR09fQVdBWV9SRUFTT05fVU5TUEVDSUZJRUQQABIgChxHT19BV0FZX1JFQVNPTl9TSFVUVElOR19ET1dOEAESHAoYR09fQVdBWV9SRUFTT05fUkVCQUxBTkNFEAI=');
+@$core.Deprecated('Use callEndedReasonDescriptor instead')
+const CallEndedReason$json = const {
+  '1': 'CallEndedReason',
+  '2': const [
+    const {'1': 'CALL_ENDED_REASON_UNSPECIFIED', '2': 0},
+    const {'1': 'CALL_ENDED_REASON_ENDED', '2': 1},
+    const {'1': 'CALL_ENDED_REASON_LIVE_ENDED', '2': 2},
+    const {'1': 'CALL_ENDED_REASON_KICKED', '2': 3},
+  ],
+};
+
+/// Descriptor for `CallEndedReason`. Decode as a `google.protobuf.EnumDescriptorProto`.
+final $typed_data.Uint8List callEndedReasonDescriptor = $convert.base64Decode('Cg9DYWxsRW5kZWRSZWFzb24SIQodQ0FMTF9FTkRFRF9SRUFTT05fVU5TUEVDSUZJRUQQABIbChdDQUxMX0VOREVEX1JFQVNPTl9FTkRFRBABEiAKHENBTExfRU5ERURfUkVBU09OX0xJVkVfRU5ERUQQAhIcChhDQUxMX0VOREVEX1JFQVNPTl9LSUNLRUQQAw==');
+@$core.Deprecated('Use websocketReconnectStrategyDescriptor instead')
+const WebsocketReconnectStrategy$json = const {
+  '1': 'WebsocketReconnectStrategy',
+  '2': const [
+    const {'1': 'WEBSOCKET_RECONNECT_STRATEGY_UNSPECIFIED', '2': 0},
+    const {'1': 'WEBSOCKET_RECONNECT_STRATEGY_DISCONNECT', '2': 1},
+    const {'1': 'WEBSOCKET_RECONNECT_STRATEGY_FAST', '2': 2},
+    const {'1': 'WEBSOCKET_RECONNECT_STRATEGY_CLEAN', '2': 3},
+    const {'1': 'WEBSOCKET_RECONNECT_STRATEGY_FULL', '2': 4},
+    const {'1': 'WEBSOCKET_RECONNECT_STRATEGY_MIGRATE', '2': 5},
+  ],
+};
+
+/// Descriptor for `WebsocketReconnectStrategy`. Decode as a `google.protobuf.EnumDescriptorProto`.
+final $typed_data.Uint8List websocketReconnectStrategyDescriptor = $convert.base64Decode('ChpXZWJzb2NrZXRSZWNvbm5lY3RTdHJhdGVneRIsCihXRUJTT0NLRVRfUkVDT05ORUNUX1NUUkFURUdZX1VOU1BFQ0lGSUVEEAASKwonV0VCU09DS0VUX1JFQ09OTkVDVF9TVFJBVEVHWV9ESVNDT05ORUNUEAESJQohV0VCU09DS0VUX1JFQ09OTkVDVF9TVFJBVEVHWV9GQVNUEAISJgoiV0VCU09DS0VUX1JFQ09OTkVDVF9TVFJBVEVHWV9DTEVBThADEiUKIVdFQlNPQ0tFVF9SRUNPTk5FQ1RfU1RSQVRFR1lfRlVMTBAEEigKJFdFQlNPQ0tFVF9SRUNPTk5FQ1RfU1RSQVRFR1lfTUlHUkFURRAF');
 @$core.Deprecated('Use callStateDescriptor instead')
 const CallState$json = const {
   '1': 'CallState',
diff --git a/packages/stream_video/lib/protobuf/video/sfu/signal_rpc/signal.pb.dart b/packages/stream_video/lib/protobuf/video/sfu/signal_rpc/signal.pb.dart
index 82d165548..95e0a7080 100644
--- a/packages/stream_video/lib/protobuf/video/sfu/signal_rpc/signal.pb.dart
+++ b/packages/stream_video/lib/protobuf/video/sfu/signal_rpc/signal.pb.dart
@@ -14,47 +14,208 @@ import '../models/models.pb.dart' as $0;
 
 import '../models/models.pbenum.dart' as $0;
 
+class StartNoiseCancellationRequest extends $pb.GeneratedMessage {
+  static final $pb.BuilderInfo _i = $pb.BuilderInfo(const $core.bool.fromEnvironment('protobuf.omit_message_names') ? '' : 'StartNoiseCancellationRequest', package: const $pb.PackageName(const $core.bool.fromEnvironment('protobuf.omit_message_names') ? '' : 'stream.video.sfu.signal'), createEmptyInstance: create)
+    ..aOS(1, const $core.bool.fromEnvironment('protobuf.omit_field_names') ? '' : 'sessionId')
+    ..hasRequiredFields = false
+  ;
+
+  StartNoiseCancellationRequest._() : super();
+  factory StartNoiseCancellationRequest({
+    $core.String? sessionId,
+  }) {
+    final _result = create();
+    if (sessionId != null) {
+      _result.sessionId = sessionId;
+    }
+    return _result;
+  }
+  factory StartNoiseCancellationRequest.fromBuffer($core.List<$core.int> i, [$pb.ExtensionRegistry r = $pb.ExtensionRegistry.EMPTY]) => create()..mergeFromBuffer(i, r);
+  factory StartNoiseCancellationRequest.fromJson($core.String i, [$pb.ExtensionRegistry r = $pb.ExtensionRegistry.EMPTY]) => create()..mergeFromJson(i, r);
+  @$core.Deprecated(
+  'Using this can add significant overhead to your binary. '
+  'Use [GeneratedMessageGenericExtensions.deepCopy] instead. '
+  'Will be removed in next major version')
+  StartNoiseCancellationRequest clone() => StartNoiseCancellationRequest()..mergeFromMessage(this);
+  @$core.Deprecated(
+  'Using this can add significant overhead to your binary. '
+  'Use [GeneratedMessageGenericExtensions.rebuild] instead. '
+  'Will be removed in next major version')
+  StartNoiseCancellationRequest copyWith(void Function(StartNoiseCancellationRequest) updates) => super.copyWith((message) => updates(message as StartNoiseCancellationRequest)) as StartNoiseCancellationRequest; // ignore: deprecated_member_use
+  $pb.BuilderInfo get info_ => _i;
+  @$core.pragma('dart2js:noInline')
+  static StartNoiseCancellationRequest create() => StartNoiseCancellationRequest._();
+  StartNoiseCancellationRequest createEmptyInstance() => create();
+  static $pb.PbList<StartNoiseCancellationRequest> createRepeated() => $pb.PbList<StartNoiseCancellationRequest>();
+  @$core.pragma('dart2js:noInline')
+  static StartNoiseCancellationRequest getDefault() => _defaultInstance ??= $pb.GeneratedMessage.$_defaultFor<StartNoiseCancellationRequest>(create);
+  static StartNoiseCancellationRequest? _defaultInstance;
+
+  @$pb.TagNumber(1)
+  $core.String get sessionId => $_getSZ(0);
+  @$pb.TagNumber(1)
+  set sessionId($core.String v) { $_setString(0, v); }
+  @$pb.TagNumber(1)
+  $core.bool hasSessionId() => $_has(0);
+  @$pb.TagNumber(1)
+  void clearSessionId() => clearField(1);
+}
+
+class StartNoiseCancellationResponse extends $pb.GeneratedMessage {
+  static final $pb.BuilderInfo _i = $pb.BuilderInfo(const $core.bool.fromEnvironment('protobuf.omit_message_names') ? '' : 'StartNoiseCancellationResponse', package: const $pb.PackageName(const $core.bool.fromEnvironment('protobuf.omit_message_names') ? '' : 'stream.video.sfu.signal'), createEmptyInstance: create)
+    ..aOM<$0.Error>(1, const $core.bool.fromEnvironment('protobuf.omit_field_names') ? '' : 'error', subBuilder: $0.Error.create)
+    ..hasRequiredFields = false
+  ;
+
+  StartNoiseCancellationResponse._() : super();
+  factory StartNoiseCancellationResponse({
+    $0.Error? error,
+  }) {
+    final _result = create();
+    if (error != null) {
+      _result.error = error;
+    }
+    return _result;
+  }
+  factory StartNoiseCancellationResponse.fromBuffer($core.List<$core.int> i, [$pb.ExtensionRegistry r = $pb.ExtensionRegistry.EMPTY]) => create()..mergeFromBuffer(i, r);
+  factory StartNoiseCancellationResponse.fromJson($core.String i, [$pb.ExtensionRegistry r = $pb.ExtensionRegistry.EMPTY]) => create()..mergeFromJson(i, r);
+  @$core.Deprecated(
+  'Using this can add significant overhead to your binary. '
+  'Use [GeneratedMessageGenericExtensions.deepCopy] instead. '
+  'Will be removed in next major version')
+  StartNoiseCancellationResponse clone() => StartNoiseCancellationResponse()..mergeFromMessage(this);
+  @$core.Deprecated(
+  'Using this can add significant overhead to your binary. '
+  'Use [GeneratedMessageGenericExtensions.rebuild] instead. '
+  'Will be removed in next major version')
+  StartNoiseCancellationResponse copyWith(void Function(StartNoiseCancellationResponse) updates) => super.copyWith((message) => updates(message as StartNoiseCancellationResponse)) as StartNoiseCancellationResponse; // ignore: deprecated_member_use
+  $pb.BuilderInfo get info_ => _i;
+  @$core.pragma('dart2js:noInline')
+  static StartNoiseCancellationResponse create() => StartNoiseCancellationResponse._();
+  StartNoiseCancellationResponse createEmptyInstance() => create();
+  static $pb.PbList<StartNoiseCancellationResponse> createRepeated() => $pb.PbList<StartNoiseCancellationResponse>();
+  @$core.pragma('dart2js:noInline')
+  static StartNoiseCancellationResponse getDefault() => _defaultInstance ??= $pb.GeneratedMessage.$_defaultFor<StartNoiseCancellationResponse>(create);
+  static StartNoiseCancellationResponse? _defaultInstance;
+
+  @$pb.TagNumber(1)
+  $0.Error get error => $_getN(0);
+  @$pb.TagNumber(1)
+  set error($0.Error v) { setField(1, v); }
+  @$pb.TagNumber(1)
+  $core.bool hasError() => $_has(0);
+  @$pb.TagNumber(1)
+  void clearError() => clearField(1);
+  @$pb.TagNumber(1)
+  $0.Error ensureError() => $_ensure(0);
+}
+
+class StopNoiseCancellationRequest extends $pb.GeneratedMessage {
+  static final $pb.BuilderInfo _i = $pb.BuilderInfo(const $core.bool.fromEnvironment('protobuf.omit_message_names') ? '' : 'StopNoiseCancellationRequest', package: const $pb.PackageName(const $core.bool.fromEnvironment('protobuf.omit_message_names') ? '' : 'stream.video.sfu.signal'), createEmptyInstance: create)
+    ..aOS(1, const $core.bool.fromEnvironment('protobuf.omit_field_names') ? '' : 'sessionId')
+    ..hasRequiredFields = false
+  ;
+
+  StopNoiseCancellationRequest._() : super();
+  factory StopNoiseCancellationRequest({
+    $core.String? sessionId,
+  }) {
+    final _result = create();
+    if (sessionId != null) {
+      _result.sessionId = sessionId;
+    }
+    return _result;
+  }
+  factory StopNoiseCancellationRequest.fromBuffer($core.List<$core.int> i, [$pb.ExtensionRegistry r = $pb.ExtensionRegistry.EMPTY]) => create()..mergeFromBuffer(i, r);
+  factory StopNoiseCancellationRequest.fromJson($core.String i, [$pb.ExtensionRegistry r = $pb.ExtensionRegistry.EMPTY]) => create()..mergeFromJson(i, r);
+  @$core.Deprecated(
+  'Using this can add significant overhead to your binary. '
+  'Use [GeneratedMessageGenericExtensions.deepCopy] instead. '
+  'Will be removed in next major version')
+  StopNoiseCancellationRequest clone() => StopNoiseCancellationRequest()..mergeFromMessage(this);
+  @$core.Deprecated(
+  'Using this can add significant overhead to your binary. '
+  'Use [GeneratedMessageGenericExtensions.rebuild] instead. '
+  'Will be removed in next major version')
+  StopNoiseCancellationRequest copyWith(void Function(StopNoiseCancellationRequest) updates) => super.copyWith((message) => updates(message as StopNoiseCancellationRequest)) as StopNoiseCancellationRequest; // ignore: deprecated_member_use
+  $pb.BuilderInfo get info_ => _i;
+  @$core.pragma('dart2js:noInline')
+  static StopNoiseCancellationRequest create() => StopNoiseCancellationRequest._();
+  StopNoiseCancellationRequest createEmptyInstance() => create();
+  static $pb.PbList<StopNoiseCancellationRequest> createRepeated() => $pb.PbList<StopNoiseCancellationRequest>();
+  @$core.pragma('dart2js:noInline')
+  static StopNoiseCancellationRequest getDefault() => _defaultInstance ??= $pb.GeneratedMessage.$_defaultFor<StopNoiseCancellationRequest>(create);
+  static StopNoiseCancellationRequest? _defaultInstance;
+
+  @$pb.TagNumber(1)
+  $core.String get sessionId => $_getSZ(0);
+  @$pb.TagNumber(1)
+  set sessionId($core.String v) { $_setString(0, v); }
+  @$pb.TagNumber(1)
+  $core.bool hasSessionId() => $_has(0);
+  @$pb.TagNumber(1)
+  void clearSessionId() => clearField(1);
+}
+
+class StopNoiseCancellationResponse extends $pb.GeneratedMessage {
+  static final $pb.BuilderInfo _i = $pb.BuilderInfo(const $core.bool.fromEnvironment('protobuf.omit_message_names') ? '' : 'StopNoiseCancellationResponse', package: const $pb.PackageName(const $core.bool.fromEnvironment('protobuf.omit_message_names') ? '' : 'stream.video.sfu.signal'), createEmptyInstance: create)
+    ..aOM<$0.Error>(1, const $core.bool.fromEnvironment('protobuf.omit_field_names') ? '' : 'error', subBuilder: $0.Error.create)
+    ..hasRequiredFields = false
+  ;
+
+  StopNoiseCancellationResponse._() : super();
+  factory StopNoiseCancellationResponse({
+    $0.Error? error,
+  }) {
+    final _result = create();
+    if (error != null) {
+      _result.error = error;
+    }
+    return _result;
+  }
+  factory StopNoiseCancellationResponse.fromBuffer($core.List<$core.int> i, [$pb.ExtensionRegistry r = $pb.ExtensionRegistry.EMPTY]) => create()..mergeFromBuffer(i, r);
+  factory StopNoiseCancellationResponse.fromJson($core.String i, [$pb.ExtensionRegistry r = $pb.ExtensionRegistry.EMPTY]) => create()..mergeFromJson(i, r);
+  @$core.Deprecated(
+  'Using this can add significant overhead to your binary. '
+  'Use [GeneratedMessageGenericExtensions.deepCopy] instead. '
+  'Will be removed in next major version')
+  StopNoiseCancellationResponse clone() => StopNoiseCancellationResponse()..mergeFromMessage(this);
+  @$core.Deprecated(
+  'Using this can add significant overhead to your binary. '
+  'Use [GeneratedMessageGenericExtensions.rebuild] instead. '
+  'Will be removed in next major version')
+  StopNoiseCancellationResponse copyWith(void Function(StopNoiseCancellationResponse) updates) => super.copyWith((message) => updates(message as StopNoiseCancellationResponse)) as StopNoiseCancellationResponse; // ignore: deprecated_member_use
+  $pb.BuilderInfo get info_ => _i;
+  @$core.pragma('dart2js:noInline')
+  static StopNoiseCancellationResponse create() => StopNoiseCancellationResponse._();
+  StopNoiseCancellationResponse createEmptyInstance() => create();
+  static $pb.PbList<StopNoiseCancellationResponse> createRepeated() => $pb.PbList<StopNoiseCancellationResponse>();
+  @$core.pragma('dart2js:noInline')
+  static StopNoiseCancellationResponse getDefault() => _defaultInstance ??= $pb.GeneratedMessage.$_defaultFor<StopNoiseCancellationResponse>(create);
+  static StopNoiseCancellationResponse? _defaultInstance;
+
+  @$pb.TagNumber(1)
+  $0.Error get error => $_getN(0);
+  @$pb.TagNumber(1)
+  set error($0.Error v) { setField(1, v); }
+  @$pb.TagNumber(1)
+  $core.bool hasError() => $_has(0);
+  @$pb.TagNumber(1)
+  void clearError() => clearField(1);
+  @$pb.TagNumber(1)
+  $0.Error ensureError() => $_ensure(0);
+}
+
 class SendStatsRequest extends $pb.GeneratedMessage {
-  static final $pb.BuilderInfo _i = $pb.BuilderInfo(
-      const $core.bool.fromEnvironment('protobuf.omit_message_names')
-          ? ''
-          : 'SendStatsRequest',
-      package: const $pb.PackageName(
-          const $core.bool.fromEnvironment('protobuf.omit_message_names')
-              ? ''
-              : 'stream.video.sfu.signal'),
-      createEmptyInstance: create)
-    ..aOS(
-        1,
-        const $core.bool.fromEnvironment('protobuf.omit_field_names')
-            ? ''
-            : 'sessionId')
-    ..aOS(
-        2,
-        const $core.bool.fromEnvironment('protobuf.omit_field_names')
-            ? ''
-            : 'subscriberStats')
-    ..aOS(
-        3,
-        const $core.bool.fromEnvironment('protobuf.omit_field_names')
-            ? ''
-            : 'publisherStats')
-    ..aOS(
-        4,
-        const $core.bool.fromEnvironment('protobuf.omit_field_names')
-            ? ''
-            : 'webrtcVersion')
-    ..aOS(
-        5,
-        const $core.bool.fromEnvironment('protobuf.omit_field_names')
-            ? ''
-            : 'sdk')
-    ..aOS(
-        6,
-        const $core.bool.fromEnvironment('protobuf.omit_field_names')
-            ? ''
-            : 'sdkVersion')
-    ..hasRequiredFields = false;
+  static final $pb.BuilderInfo _i = $pb.BuilderInfo(const $core.bool.fromEnvironment('protobuf.omit_message_names') ? '' : 'SendStatsRequest', package: const $pb.PackageName(const $core.bool.fromEnvironment('protobuf.omit_message_names') ? '' : 'stream.video.sfu.signal'), createEmptyInstance: create)
+    ..aOS(1, const $core.bool.fromEnvironment('protobuf.omit_field_names') ? '' : 'sessionId')
+    ..aOS(2, const $core.bool.fromEnvironment('protobuf.omit_field_names') ? '' : 'subscriberStats')
+    ..aOS(3, const $core.bool.fromEnvironment('protobuf.omit_field_names') ? '' : 'publisherStats')
+    ..aOS(4, const $core.bool.fromEnvironment('protobuf.omit_field_names') ? '' : 'webrtcVersion')
+    ..aOS(5, const $core.bool.fromEnvironment('protobuf.omit_field_names') ? '' : 'sdk')
+    ..aOS(6, const $core.bool.fromEnvironment('protobuf.omit_field_names') ? '' : 'sdkVersion')
+    ..hasRequiredFields = false
+  ;
 
   SendStatsRequest._() : super();
   factory SendStatsRequest({
@@ -62,7 +223,7 @@ class SendStatsRequest extends $pb.GeneratedMessage {
     $core.String? subscriberStats,
     $core.String? publisherStats,
     $core.String? webrtcVersion,
-    $core.String sdk = 'stream-flutter',
+    $core.String? sdk,
     $core.String? sdkVersion,
   }) {
     final _result = create();
@@ -86,40 +247,31 @@ class SendStatsRequest extends $pb.GeneratedMessage {
     }
     return _result;
   }
-  factory SendStatsRequest.fromBuffer($core.List<$core.int> i,
-          [$pb.ExtensionRegistry r = $pb.ExtensionRegistry.EMPTY]) =>
-      create()..mergeFromBuffer(i, r);
-  factory SendStatsRequest.fromJson($core.String i,
-          [$pb.ExtensionRegistry r = $pb.ExtensionRegistry.EMPTY]) =>
-      create()..mergeFromJson(i, r);
-  @$core.Deprecated('Using this can add significant overhead to your binary. '
-      'Use [GeneratedMessageGenericExtensions.deepCopy] instead. '
-      'Will be removed in next major version')
+  factory SendStatsRequest.fromBuffer($core.List<$core.int> i, [$pb.ExtensionRegistry r = $pb.ExtensionRegistry.EMPTY]) => create()..mergeFromBuffer(i, r);
+  factory SendStatsRequest.fromJson($core.String i, [$pb.ExtensionRegistry r = $pb.ExtensionRegistry.EMPTY]) => create()..mergeFromJson(i, r);
+  @$core.Deprecated(
+  'Using this can add significant overhead to your binary. '
+  'Use [GeneratedMessageGenericExtensions.deepCopy] instead. '
+  'Will be removed in next major version')
   SendStatsRequest clone() => SendStatsRequest()..mergeFromMessage(this);
-  @$core.Deprecated('Using this can add significant overhead to your binary. '
-      'Use [GeneratedMessageGenericExtensions.rebuild] instead. '
-      'Will be removed in next major version')
-  SendStatsRequest copyWith(void Function(SendStatsRequest) updates) =>
-      super.copyWith((message) => updates(message as SendStatsRequest))
-          as SendStatsRequest; // ignore: deprecated_member_use
+  @$core.Deprecated(
+  'Using this can add significant overhead to your binary. '
+  'Use [GeneratedMessageGenericExtensions.rebuild] instead. '
+  'Will be removed in next major version')
+  SendStatsRequest copyWith(void Function(SendStatsRequest) updates) => super.copyWith((message) => updates(message as SendStatsRequest)) as SendStatsRequest; // ignore: deprecated_member_use
   $pb.BuilderInfo get info_ => _i;
   @$core.pragma('dart2js:noInline')
   static SendStatsRequest create() => SendStatsRequest._();
   SendStatsRequest createEmptyInstance() => create();
-  static $pb.PbList<SendStatsRequest> createRepeated() =>
-      $pb.PbList<SendStatsRequest>();
+  static $pb.PbList<SendStatsRequest> createRepeated() => $pb.PbList<SendStatsRequest>();
   @$core.pragma('dart2js:noInline')
-  static SendStatsRequest getDefault() => _defaultInstance ??=
-      $pb.GeneratedMessage.$_defaultFor<SendStatsRequest>(create);
+  static SendStatsRequest getDefault() => _defaultInstance ??= $pb.GeneratedMessage.$_defaultFor<SendStatsRequest>(create);
   static SendStatsRequest? _defaultInstance;
 
   @$pb.TagNumber(1)
   $core.String get sessionId => $_getSZ(0);
   @$pb.TagNumber(1)
-  set sessionId($core.String v) {
-    $_setString(0, v);
-  }
-
+  set sessionId($core.String v) { $_setString(0, v); }
   @$pb.TagNumber(1)
   $core.bool hasSessionId() => $_has(0);
   @$pb.TagNumber(1)
@@ -128,10 +280,7 @@ class SendStatsRequest extends $pb.GeneratedMessage {
   @$pb.TagNumber(2)
   $core.String get subscriberStats => $_getSZ(1);
   @$pb.TagNumber(2)
-  set subscriberStats($core.String v) {
-    $_setString(1, v);
-  }
-
+  set subscriberStats($core.String v) { $_setString(1, v); }
   @$pb.TagNumber(2)
   $core.bool hasSubscriberStats() => $_has(1);
   @$pb.TagNumber(2)
@@ -140,10 +289,7 @@ class SendStatsRequest extends $pb.GeneratedMessage {
   @$pb.TagNumber(3)
   $core.String get publisherStats => $_getSZ(2);
   @$pb.TagNumber(3)
-  set publisherStats($core.String v) {
-    $_setString(2, v);
-  }
-
+  set publisherStats($core.String v) { $_setString(2, v); }
   @$pb.TagNumber(3)
   $core.bool hasPublisherStats() => $_has(2);
   @$pb.TagNumber(3)
@@ -152,10 +298,7 @@ class SendStatsRequest extends $pb.GeneratedMessage {
   @$pb.TagNumber(4)
   $core.String get webrtcVersion => $_getSZ(3);
   @$pb.TagNumber(4)
-  set webrtcVersion($core.String v) {
-    $_setString(3, v);
-  }
-
+  set webrtcVersion($core.String v) { $_setString(3, v); }
   @$pb.TagNumber(4)
   $core.bool hasWebrtcVersion() => $_has(3);
   @$pb.TagNumber(4)
@@ -164,10 +307,7 @@ class SendStatsRequest extends $pb.GeneratedMessage {
   @$pb.TagNumber(5)
   $core.String get sdk => $_getSZ(4);
   @$pb.TagNumber(5)
-  set sdk($core.String v) {
-    $_setString(4, v);
-  }
-
+  set sdk($core.String v) { $_setString(4, v); }
   @$pb.TagNumber(5)
   $core.bool hasSdk() => $_has(4);
   @$pb.TagNumber(5)
@@ -176,10 +316,7 @@ class SendStatsRequest extends $pb.GeneratedMessage {
   @$pb.TagNumber(6)
   $core.String get sdkVersion => $_getSZ(5);
   @$pb.TagNumber(6)
-  set sdkVersion($core.String v) {
-    $_setString(5, v);
-  }
-
+  set sdkVersion($core.String v) { $_setString(5, v); }
   @$pb.TagNumber(6)
   $core.bool hasSdkVersion() => $_has(5);
   @$pb.TagNumber(6)
@@ -187,22 +324,10 @@ class SendStatsRequest extends $pb.GeneratedMessage {
 }
 
 class SendStatsResponse extends $pb.GeneratedMessage {
-  static final $pb.BuilderInfo _i = $pb.BuilderInfo(
-      const $core.bool.fromEnvironment('protobuf.omit_message_names')
-          ? ''
-          : 'SendStatsResponse',
-      package: const $pb.PackageName(
-          const $core.bool.fromEnvironment('protobuf.omit_message_names')
-              ? ''
-              : 'stream.video.sfu.signal'),
-      createEmptyInstance: create)
-    ..aOM<$0.Error>(
-        1,
-        const $core.bool.fromEnvironment('protobuf.omit_field_names')
-            ? ''
-            : 'error',
-        subBuilder: $0.Error.create)
-    ..hasRequiredFields = false;
+  static final $pb.BuilderInfo _i = $pb.BuilderInfo(const $core.bool.fromEnvironment('protobuf.omit_message_names') ? '' : 'SendStatsResponse', package: const $pb.PackageName(const $core.bool.fromEnvironment('protobuf.omit_message_names') ? '' : 'stream.video.sfu.signal'), createEmptyInstance: create)
+    ..aOM<$0.Error>(1, const $core.bool.fromEnvironment('protobuf.omit_field_names') ? '' : 'error', subBuilder: $0.Error.create)
+    ..hasRequiredFields = false
+  ;
 
   SendStatsResponse._() : super();
   factory SendStatsResponse({
@@ -214,40 +339,31 @@ class SendStatsResponse extends $pb.GeneratedMessage {
     }
     return _result;
   }
-  factory SendStatsResponse.fromBuffer($core.List<$core.int> i,
-          [$pb.ExtensionRegistry r = $pb.ExtensionRegistry.EMPTY]) =>
-      create()..mergeFromBuffer(i, r);
-  factory SendStatsResponse.fromJson($core.String i,
-          [$pb.ExtensionRegistry r = $pb.ExtensionRegistry.EMPTY]) =>
-      create()..mergeFromJson(i, r);
-  @$core.Deprecated('Using this can add significant overhead to your binary. '
-      'Use [GeneratedMessageGenericExtensions.deepCopy] instead. '
-      'Will be removed in next major version')
+  factory SendStatsResponse.fromBuffer($core.List<$core.int> i, [$pb.ExtensionRegistry r = $pb.ExtensionRegistry.EMPTY]) => create()..mergeFromBuffer(i, r);
+  factory SendStatsResponse.fromJson($core.String i, [$pb.ExtensionRegistry r = $pb.ExtensionRegistry.EMPTY]) => create()..mergeFromJson(i, r);
+  @$core.Deprecated(
+  'Using this can add significant overhead to your binary. '
+  'Use [GeneratedMessageGenericExtensions.deepCopy] instead. '
+  'Will be removed in next major version')
   SendStatsResponse clone() => SendStatsResponse()..mergeFromMessage(this);
-  @$core.Deprecated('Using this can add significant overhead to your binary. '
-      'Use [GeneratedMessageGenericExtensions.rebuild] instead. '
-      'Will be removed in next major version')
-  SendStatsResponse copyWith(void Function(SendStatsResponse) updates) =>
-      super.copyWith((message) => updates(message as SendStatsResponse))
-          as SendStatsResponse; // ignore: deprecated_member_use
+  @$core.Deprecated(
+  'Using this can add significant overhead to your binary. '
+  'Use [GeneratedMessageGenericExtensions.rebuild] instead. '
+  'Will be removed in next major version')
+  SendStatsResponse copyWith(void Function(SendStatsResponse) updates) => super.copyWith((message) => updates(message as SendStatsResponse)) as SendStatsResponse; // ignore: deprecated_member_use
   $pb.BuilderInfo get info_ => _i;
   @$core.pragma('dart2js:noInline')
   static SendStatsResponse create() => SendStatsResponse._();
   SendStatsResponse createEmptyInstance() => create();
-  static $pb.PbList<SendStatsResponse> createRepeated() =>
-      $pb.PbList<SendStatsResponse>();
+  static $pb.PbList<SendStatsResponse> createRepeated() => $pb.PbList<SendStatsResponse>();
   @$core.pragma('dart2js:noInline')
-  static SendStatsResponse getDefault() => _defaultInstance ??=
-      $pb.GeneratedMessage.$_defaultFor<SendStatsResponse>(create);
+  static SendStatsResponse getDefault() => _defaultInstance ??= $pb.GeneratedMessage.$_defaultFor<SendStatsResponse>(create);
   static SendStatsResponse? _defaultInstance;
 
   @$pb.TagNumber(1)
   $0.Error get error => $_getN(0);
   @$pb.TagNumber(1)
-  set error($0.Error v) {
-    setField(1, v);
-  }
-
+  set error($0.Error v) { setField(1, v); }
   @$pb.TagNumber(1)
   $core.bool hasError() => $_has(0);
   @$pb.TagNumber(1)
@@ -1181,11 +1297,17 @@ class SignalServerApi {
     var emptyResponse = ICERestartResponse();
     return _client.invoke<ICERestartResponse>(ctx, 'SignalServer', 'IceRestart', request, emptyResponse);
   }
-  $async.Future<SendStatsResponse> sendStats(
-      $pb.ClientContext? ctx, SendStatsRequest request) {
+  $async.Future<SendStatsResponse> sendStats($pb.ClientContext? ctx, SendStatsRequest request) {
     var emptyResponse = SendStatsResponse();
-    return _client.invoke<SendStatsResponse>(
-        ctx, 'SignalServer', 'SendStats', request, emptyResponse);
+    return _client.invoke<SendStatsResponse>(ctx, 'SignalServer', 'SendStats', request, emptyResponse);
+  }
+  $async.Future<StartNoiseCancellationResponse> startNoiseCancellation($pb.ClientContext? ctx, StartNoiseCancellationRequest request) {
+    var emptyResponse = StartNoiseCancellationResponse();
+    return _client.invoke<StartNoiseCancellationResponse>(ctx, 'SignalServer', 'StartNoiseCancellation', request, emptyResponse);
+  }
+  $async.Future<StopNoiseCancellationResponse> stopNoiseCancellation($pb.ClientContext? ctx, StopNoiseCancellationRequest request) {
+    var emptyResponse = StopNoiseCancellationResponse();
+    return _client.invoke<StopNoiseCancellationResponse>(ctx, 'SignalServer', 'StopNoiseCancellation', request, emptyResponse);
   }
 }
 
diff --git a/packages/stream_video/lib/protobuf/video/sfu/signal_rpc/signal.pbjson.dart b/packages/stream_video/lib/protobuf/video/sfu/signal_rpc/signal.pbjson.dart
index fba419766..8f3a95f11 100644
--- a/packages/stream_video/lib/protobuf/video/sfu/signal_rpc/signal.pbjson.dart
+++ b/packages/stream_video/lib/protobuf/video/sfu/signal_rpc/signal.pbjson.dart
@@ -10,6 +10,46 @@ import 'dart:convert' as $convert;
 import 'dart:typed_data' as $typed_data;
 import '../models/models.pbjson.dart' as $0;
 
+@$core.Deprecated('Use startNoiseCancellationRequestDescriptor instead')
+const StartNoiseCancellationRequest$json = const {
+  '1': 'StartNoiseCancellationRequest',
+  '2': const [
+    const {'1': 'session_id', '3': 1, '4': 1, '5': 9, '10': 'sessionId'},
+  ],
+};
+
+/// Descriptor for `StartNoiseCancellationRequest`. Decode as a `google.protobuf.DescriptorProto`.
+final $typed_data.Uint8List startNoiseCancellationRequestDescriptor = $convert.base64Decode('Ch1TdGFydE5vaXNlQ2FuY2VsbGF0aW9uUmVxdWVzdBIdCgpzZXNzaW9uX2lkGAEgASgJUglzZXNzaW9uSWQ=');
+@$core.Deprecated('Use startNoiseCancellationResponseDescriptor instead')
+const StartNoiseCancellationResponse$json = const {
+  '1': 'StartNoiseCancellationResponse',
+  '2': const [
+    const {'1': 'error', '3': 1, '4': 1, '5': 11, '6': '.stream.video.sfu.models.Error', '10': 'error'},
+  ],
+};
+
+/// Descriptor for `StartNoiseCancellationResponse`. Decode as a `google.protobuf.DescriptorProto`.
+final $typed_data.Uint8List startNoiseCancellationResponseDescriptor = $convert.base64Decode('Ch5TdGFydE5vaXNlQ2FuY2VsbGF0aW9uUmVzcG9uc2USNAoFZXJyb3IYASABKAsyHi5zdHJlYW0udmlkZW8uc2Z1Lm1vZGVscy5FcnJvclIFZXJyb3I=');
+@$core.Deprecated('Use stopNoiseCancellationRequestDescriptor instead')
+const StopNoiseCancellationRequest$json = const {
+  '1': 'StopNoiseCancellationRequest',
+  '2': const [
+    const {'1': 'session_id', '3': 1, '4': 1, '5': 9, '10': 'sessionId'},
+  ],
+};
+
+/// Descriptor for `StopNoiseCancellationRequest`. Decode as a `google.protobuf.DescriptorProto`.
+final $typed_data.Uint8List stopNoiseCancellationRequestDescriptor = $convert.base64Decode('ChxTdG9wTm9pc2VDYW5jZWxsYXRpb25SZXF1ZXN0Eh0KCnNlc3Npb25faWQYASABKAlSCXNlc3Npb25JZA==');
+@$core.Deprecated('Use stopNoiseCancellationResponseDescriptor instead')
+const StopNoiseCancellationResponse$json = const {
+  '1': 'StopNoiseCancellationResponse',
+  '2': const [
+    const {'1': 'error', '3': 1, '4': 1, '5': 11, '6': '.stream.video.sfu.models.Error', '10': 'error'},
+  ],
+};
+
+/// Descriptor for `StopNoiseCancellationResponse`. Decode as a `google.protobuf.DescriptorProto`.
+final $typed_data.Uint8List stopNoiseCancellationResponseDescriptor = $convert.base64Decode('Ch1TdG9wTm9pc2VDYW5jZWxsYXRpb25SZXNwb25zZRI0CgVlcnJvchgBIAEoCzIeLnN0cmVhbS52aWRlby5zZnUubW9kZWxzLkVycm9yUgVlcnJvcg==');
 @$core.Deprecated('Use sendStatsRequestDescriptor instead')
 const SendStatsRequest$json = const {
   '1': 'SendStatsRequest',
@@ -209,6 +249,8 @@ const $core.Map<$core.String, $core.dynamic> SignalServerServiceBase$json = cons
     const {'1': 'UpdateMuteStates', '2': '.stream.video.sfu.signal.UpdateMuteStatesRequest', '3': '.stream.video.sfu.signal.UpdateMuteStatesResponse'},
     const {'1': 'IceRestart', '2': '.stream.video.sfu.signal.ICERestartRequest', '3': '.stream.video.sfu.signal.ICERestartResponse'},
     const {'1': 'SendStats', '2': '.stream.video.sfu.signal.SendStatsRequest', '3': '.stream.video.sfu.signal.SendStatsResponse'},
+    const {'1': 'StartNoiseCancellation', '2': '.stream.video.sfu.signal.StartNoiseCancellationRequest', '3': '.stream.video.sfu.signal.StartNoiseCancellationResponse'},
+    const {'1': 'StopNoiseCancellation', '2': '.stream.video.sfu.signal.StopNoiseCancellationRequest', '3': '.stream.video.sfu.signal.StopNoiseCancellationResponse'},
   ],
 };
 
@@ -234,7 +276,11 @@ const $core.Map<$core.String, $core.Map<$core.String, $core.dynamic>> SignalServ
   '.stream.video.sfu.signal.ICERestartResponse': ICERestartResponse$json,
   '.stream.video.sfu.signal.SendStatsRequest': SendStatsRequest$json,
   '.stream.video.sfu.signal.SendStatsResponse': SendStatsResponse$json,
+  '.stream.video.sfu.signal.StartNoiseCancellationRequest': StartNoiseCancellationRequest$json,
+  '.stream.video.sfu.signal.StartNoiseCancellationResponse': StartNoiseCancellationResponse$json,
+  '.stream.video.sfu.signal.StopNoiseCancellationRequest': StopNoiseCancellationRequest$json,
+  '.stream.video.sfu.signal.StopNoiseCancellationResponse': StopNoiseCancellationResponse$json,
 };
 
 /// Descriptor for `SignalServer`. Decode as a `google.protobuf.ServiceDescriptorProto`.
-final $typed_data.Uint8List signalServerServiceDescriptor = $convert.base64Decode('CgxTaWduYWxTZXJ2ZXISawoMU2V0UHVibGlzaGVyEiwuc3RyZWFtLnZpZGVvLnNmdS5zaWduYWwuU2V0UHVibGlzaGVyUmVxdWVzdBotLnN0cmVhbS52aWRlby5zZnUuc2lnbmFsLlNldFB1Ymxpc2hlclJlc3BvbnNlEmUKClNlbmRBbnN3ZXISKi5zdHJlYW0udmlkZW8uc2Z1LnNpZ25hbC5TZW5kQW5zd2VyUmVxdWVzdBorLnN0cmVhbS52aWRlby5zZnUuc2lnbmFsLlNlbmRBbnN3ZXJSZXNwb25zZRJeCgpJY2VUcmlja2xlEiMuc3RyZWFtLnZpZGVvLnNmdS5tb2RlbHMuSUNFVHJpY2tsZRorLnN0cmVhbS52aWRlby5zZnUuc2lnbmFsLklDRVRyaWNrbGVSZXNwb25zZRKAAQoTVXBkYXRlU3Vic2NyaXB0aW9ucxIzLnN0cmVhbS52aWRlby5zZnUuc2lnbmFsLlVwZGF0ZVN1YnNjcmlwdGlvbnNSZXF1ZXN0GjQuc3RyZWFtLnZpZGVvLnNmdS5zaWduYWwuVXBkYXRlU3Vic2NyaXB0aW9uc1Jlc3BvbnNlEncKEFVwZGF0ZU11dGVTdGF0ZXMSMC5zdHJlYW0udmlkZW8uc2Z1LnNpZ25hbC5VcGRhdGVNdXRlU3RhdGVzUmVxdWVzdBoxLnN0cmVhbS52aWRlby5zZnUuc2lnbmFsLlVwZGF0ZU11dGVTdGF0ZXNSZXNwb25zZRJlCgpJY2VSZXN0YXJ0Eiouc3RyZWFtLnZpZGVvLnNmdS5zaWduYWwuSUNFUmVzdGFydFJlcXVlc3QaKy5zdHJlYW0udmlkZW8uc2Z1LnNpZ25hbC5JQ0VSZXN0YXJ0UmVzcG9uc2USYgoJU2VuZFN0YXRzEikuc3RyZWFtLnZpZGVvLnNmdS5zaWduYWwuU2VuZFN0YXRzUmVxdWVzdBoqLnN0cmVhbS52aWRlby5zZnUuc2lnbmFsLlNlbmRTdGF0c1Jlc3BvbnNl');
+final $typed_data.Uint8List signalServerServiceDescriptor = $convert.base64Decode('CgxTaWduYWxTZXJ2ZXISawoMU2V0UHVibGlzaGVyEiwuc3RyZWFtLnZpZGVvLnNmdS5zaWduYWwuU2V0UHVibGlzaGVyUmVxdWVzdBotLnN0cmVhbS52aWRlby5zZnUuc2lnbmFsLlNldFB1Ymxpc2hlclJlc3BvbnNlEmUKClNlbmRBbnN3ZXISKi5zdHJlYW0udmlkZW8uc2Z1LnNpZ25hbC5TZW5kQW5zd2VyUmVxdWVzdBorLnN0cmVhbS52aWRlby5zZnUuc2lnbmFsLlNlbmRBbnN3ZXJSZXNwb25zZRJeCgpJY2VUcmlja2xlEiMuc3RyZWFtLnZpZGVvLnNmdS5tb2RlbHMuSUNFVHJpY2tsZRorLnN0cmVhbS52aWRlby5zZnUuc2lnbmFsLklDRVRyaWNrbGVSZXNwb25zZRKAAQoTVXBkYXRlU3Vic2NyaXB0aW9ucxIzLnN0cmVhbS52aWRlby5zZnUuc2lnbmFsLlVwZGF0ZVN1YnNjcmlwdGlvbnNSZXF1ZXN0GjQuc3RyZWFtLnZpZGVvLnNmdS5zaWduYWwuVXBkYXRlU3Vic2NyaXB0aW9uc1Jlc3BvbnNlEncKEFVwZGF0ZU11dGVTdGF0ZXMSMC5zdHJlYW0udmlkZW8uc2Z1LnNpZ25hbC5VcGRhdGVNdXRlU3RhdGVzUmVxdWVzdBoxLnN0cmVhbS52aWRlby5zZnUuc2lnbmFsLlVwZGF0ZU11dGVTdGF0ZXNSZXNwb25zZRJlCgpJY2VSZXN0YXJ0Eiouc3RyZWFtLnZpZGVvLnNmdS5zaWduYWwuSUNFUmVzdGFydFJlcXVlc3QaKy5zdHJlYW0udmlkZW8uc2Z1LnNpZ25hbC5JQ0VSZXN0YXJ0UmVzcG9uc2USYgoJU2VuZFN0YXRzEikuc3RyZWFtLnZpZGVvLnNmdS5zaWduYWwuU2VuZFN0YXRzUmVxdWVzdBoqLnN0cmVhbS52aWRlby5zZnUuc2lnbmFsLlNlbmRTdGF0c1Jlc3BvbnNlEokBChZTdGFydE5vaXNlQ2FuY2VsbGF0aW9uEjYuc3RyZWFtLnZpZGVvLnNmdS5zaWduYWwuU3RhcnROb2lzZUNhbmNlbGxhdGlvblJlcXVlc3QaNy5zdHJlYW0udmlkZW8uc2Z1LnNpZ25hbC5TdGFydE5vaXNlQ2FuY2VsbGF0aW9uUmVzcG9uc2UShgEKFVN0b3BOb2lzZUNhbmNlbGxhdGlvbhI1LnN0cmVhbS52aWRlby5zZnUuc2lnbmFsLlN0b3BOb2lzZUNhbmNlbGxhdGlvblJlcXVlc3QaNi5zdHJlYW0udmlkZW8uc2Z1LnNpZ25hbC5TdG9wTm9pc2VDYW5jZWxsYXRpb25SZXNwb25zZQ==');
diff --git a/packages/stream_video/lib/protobuf/video/sfu/signal_rpc/signal.pbserver.dart b/packages/stream_video/lib/protobuf/video/sfu/signal_rpc/signal.pbserver.dart
index e77cb032f..409f8f50e 100644
--- a/packages/stream_video/lib/protobuf/video/sfu/signal_rpc/signal.pbserver.dart
+++ b/packages/stream_video/lib/protobuf/video/sfu/signal_rpc/signal.pbserver.dart
@@ -24,6 +24,8 @@ abstract class SignalServerServiceBase extends $pb.GeneratedService {
   $async.Future<$1.UpdateMuteStatesResponse> updateMuteStates($pb.ServerContext ctx, $1.UpdateMuteStatesRequest request);
   $async.Future<$1.ICERestartResponse> iceRestart($pb.ServerContext ctx, $1.ICERestartRequest request);
   $async.Future<$1.SendStatsResponse> sendStats($pb.ServerContext ctx, $1.SendStatsRequest request);
+  $async.Future<$1.StartNoiseCancellationResponse> startNoiseCancellation($pb.ServerContext ctx, $1.StartNoiseCancellationRequest request);
+  $async.Future<$1.StopNoiseCancellationResponse> stopNoiseCancellation($pb.ServerContext ctx, $1.StopNoiseCancellationRequest request);
 
   $pb.GeneratedMessage createRequest($core.String method) {
     switch (method) {
@@ -34,6 +36,8 @@ abstract class SignalServerServiceBase extends $pb.GeneratedService {
       case 'UpdateMuteStates': return $1.UpdateMuteStatesRequest();
       case 'IceRestart': return $1.ICERestartRequest();
       case 'SendStats': return $1.SendStatsRequest();
+      case 'StartNoiseCancellation': return $1.StartNoiseCancellationRequest();
+      case 'StopNoiseCancellation': return $1.StopNoiseCancellationRequest();
       default: throw $core.ArgumentError('Unknown method: $method');
     }
   }
@@ -47,6 +51,8 @@ abstract class SignalServerServiceBase extends $pb.GeneratedService {
       case 'UpdateMuteStates': return this.updateMuteStates(ctx, request as $1.UpdateMuteStatesRequest);
       case 'IceRestart': return this.iceRestart(ctx, request as $1.ICERestartRequest);
       case 'SendStats': return this.sendStats(ctx, request as $1.SendStatsRequest);
+      case 'StartNoiseCancellation': return this.startNoiseCancellation(ctx, request as $1.StartNoiseCancellationRequest);
+      case 'StopNoiseCancellation': return this.stopNoiseCancellation(ctx, request as $1.StopNoiseCancellationRequest);
       default: throw $core.ArgumentError('Unknown method: $method');
     }
   }
diff --git a/packages/stream_video/lib/protobuf/video/sfu/signal_rpc/signal.pbtwirp.dart b/packages/stream_video/lib/protobuf/video/sfu/signal_rpc/signal.pbtwirp.dart
index 38657cd2f..cf42a7971 100644
--- a/packages/stream_video/lib/protobuf/video/sfu/signal_rpc/signal.pbtwirp.dart
+++ b/packages/stream_video/lib/protobuf/video/sfu/signal_rpc/signal.pbtwirp.dart
@@ -25,6 +25,10 @@ abstract class SignalServer {
   Future<ICERestartResponse> iceRestart(twirp.Context ctx, ICERestartRequest req);
   
   Future<SendStatsResponse> sendStats(twirp.Context ctx, SendStatsRequest req);
+  
+  Future<StartNoiseCancellationResponse> startNoiseCancellation(twirp.Context ctx, StartNoiseCancellationRequest req);
+  
+  Future<StopNoiseCancellationResponse> stopNoiseCancellation(twirp.Context ctx, StopNoiseCancellationRequest req);
 }
 
 
@@ -176,8 +180,7 @@ class SignalServerJSONClient implements SignalServer {
   }
 
   @override
-  Future<SendStatsResponse> sendStats(
-      twirp.Context ctx, SendStatsRequest req) async {
+  Future<SendStatsResponse> sendStats(twirp.Context ctx, SendStatsRequest req) async {
     ctx = twirp.withPackageName(ctx, 'signal');
     ctx = twirp.withServiceName(ctx, 'SignalServer');
     ctx = twirp.withMethodName(ctx, 'SendStats');
@@ -186,11 +189,9 @@ class SignalServerJSONClient implements SignalServer {
     })(ctx, req);
   }
 
-  Future<SendStatsResponse> callSendStats(
-      twirp.Context ctx, SendStatsRequest req) async {
+  Future<SendStatsResponse> callSendStats(twirp.Context ctx, SendStatsRequest req) async {
     try {
-      Uri url = Uri.parse(
-          baseUrl + prefix + 'stream.video.sfu.signal.SignalServer/SendStats');
+      Uri url = Uri.parse(baseUrl + prefix + 'stream.video.sfu.signal.SignalServer/SendStats');
       final data = await doJSONRequest(ctx, url, hooks, req);
       final SendStatsResponse res = SendStatsResponse.create();
       res.mergeFromProto3Json(json.decode(data));
@@ -199,6 +200,50 @@ class SignalServerJSONClient implements SignalServer {
       rethrow;
     }
   }
+
+  @override
+  Future<StartNoiseCancellationResponse> startNoiseCancellation(twirp.Context ctx, StartNoiseCancellationRequest req) async {
+    ctx = twirp.withPackageName(ctx, 'signal');
+    ctx = twirp.withServiceName(ctx, 'SignalServer');
+    ctx = twirp.withMethodName(ctx, 'StartNoiseCancellation');
+    return interceptor((ctx, req) {
+      return callStartNoiseCancellation(ctx, req);
+    })(ctx, req);
+  }
+
+  Future<StartNoiseCancellationResponse> callStartNoiseCancellation(twirp.Context ctx, StartNoiseCancellationRequest req) async {
+    try {
+      Uri url = Uri.parse(baseUrl + prefix + 'stream.video.sfu.signal.SignalServer/StartNoiseCancellation');
+      final data = await doJSONRequest(ctx, url, hooks, req);
+      final StartNoiseCancellationResponse res = StartNoiseCancellationResponse.create();
+      res.mergeFromProto3Json(json.decode(data));
+      return Future.value(res);
+    } catch (e) {
+      rethrow;
+    }
+  }
+
+  @override
+  Future<StopNoiseCancellationResponse> stopNoiseCancellation(twirp.Context ctx, StopNoiseCancellationRequest req) async {
+    ctx = twirp.withPackageName(ctx, 'signal');
+    ctx = twirp.withServiceName(ctx, 'SignalServer');
+    ctx = twirp.withMethodName(ctx, 'StopNoiseCancellation');
+    return interceptor((ctx, req) {
+      return callStopNoiseCancellation(ctx, req);
+    })(ctx, req);
+  }
+
+  Future<StopNoiseCancellationResponse> callStopNoiseCancellation(twirp.Context ctx, StopNoiseCancellationRequest req) async {
+    try {
+      Uri url = Uri.parse(baseUrl + prefix + 'stream.video.sfu.signal.SignalServer/StopNoiseCancellation');
+      final data = await doJSONRequest(ctx, url, hooks, req);
+      final StopNoiseCancellationResponse res = StopNoiseCancellationResponse.create();
+      res.mergeFromProto3Json(json.decode(data));
+      return Future.value(res);
+    } catch (e) {
+      rethrow;
+    }
+  }
 }
 
 
@@ -350,8 +395,7 @@ class SignalServerProtobufClient implements SignalServer {
   }
 
   @override
-  Future<SendStatsResponse> sendStats(
-      twirp.Context ctx, SendStatsRequest req) async {
+  Future<SendStatsResponse> sendStats(twirp.Context ctx, SendStatsRequest req) async {
     ctx = twirp.withPackageName(ctx, 'signal');
     ctx = twirp.withServiceName(ctx, 'SignalServer');
     ctx = twirp.withMethodName(ctx, 'SendStats');
@@ -360,11 +404,9 @@ class SignalServerProtobufClient implements SignalServer {
     })(ctx, req);
   }
 
-  Future<SendStatsResponse> callSendStats(
-      twirp.Context ctx, SendStatsRequest req) async {
+  Future<SendStatsResponse> callSendStats(twirp.Context ctx, SendStatsRequest req) async {
     try {
-      Uri url = Uri.parse(
-          baseUrl + prefix + 'stream.video.sfu.signal.SignalServer/SendStats');
+      Uri url = Uri.parse(baseUrl + prefix + 'stream.video.sfu.signal.SignalServer/SendStats');
       final data = await doProtobufRequest(ctx, url, hooks, req);
       final SendStatsResponse res = SendStatsResponse.create();
       res.mergeFromBuffer(data);
@@ -373,6 +415,50 @@ class SignalServerProtobufClient implements SignalServer {
       rethrow;
     }
   }
+
+  @override
+  Future<StartNoiseCancellationResponse> startNoiseCancellation(twirp.Context ctx, StartNoiseCancellationRequest req) async {
+    ctx = twirp.withPackageName(ctx, 'signal');
+    ctx = twirp.withServiceName(ctx, 'SignalServer');
+    ctx = twirp.withMethodName(ctx, 'StartNoiseCancellation');
+    return interceptor((ctx, req) {
+      return callStartNoiseCancellation(ctx, req);
+    })(ctx, req);
+  }
+
+  Future<StartNoiseCancellationResponse> callStartNoiseCancellation(twirp.Context ctx, StartNoiseCancellationRequest req) async {
+    try {
+      Uri url = Uri.parse(baseUrl + prefix + 'stream.video.sfu.signal.SignalServer/StartNoiseCancellation');
+      final data = await doProtobufRequest(ctx, url, hooks, req);
+      final StartNoiseCancellationResponse res = StartNoiseCancellationResponse.create();
+      res.mergeFromBuffer(data);
+      return Future.value(res);
+    } catch (e) {
+      rethrow;
+    }
+  }
+
+  @override
+  Future<StopNoiseCancellationResponse> stopNoiseCancellation(twirp.Context ctx, StopNoiseCancellationRequest req) async {
+    ctx = twirp.withPackageName(ctx, 'signal');
+    ctx = twirp.withServiceName(ctx, 'SignalServer');
+    ctx = twirp.withMethodName(ctx, 'StopNoiseCancellation');
+    return interceptor((ctx, req) {
+      return callStopNoiseCancellation(ctx, req);
+    })(ctx, req);
+  }
+
+  Future<StopNoiseCancellationResponse> callStopNoiseCancellation(twirp.Context ctx, StopNoiseCancellationRequest req) async {
+    try {
+      Uri url = Uri.parse(baseUrl + prefix + 'stream.video.sfu.signal.SignalServer/StopNoiseCancellation');
+      final data = await doProtobufRequest(ctx, url, hooks, req);
+      final StopNoiseCancellationResponse res = StopNoiseCancellationResponse.create();
+      res.mergeFromBuffer(data);
+      return Future.value(res);
+    } catch (e) {
+      rethrow;
+    }
+  }
 }
 
 Future<List<int>> doProtobufRequest(twirp.Context ctx, Uri url,
@@ -388,7 +474,7 @@ Future<List<int>> doProtobufRequest(twirp.Context ctx, Uri url,
     req.bodyBytes = msgReq.writeToBuffer();
 
     // call onRequestPrepared hook for user to modify request
-    ctx = await hooks.onRequestPrepared(ctx, req);
+    ctx = hooks.onRequestPrepared(ctx, req);
 
     // send data
     final res = await httpClient.send(req);
@@ -432,7 +518,7 @@ Future<String> doJSONRequest(twirp.Context ctx, Uri url,
     req.body = json.encode(msgReq.toProto3Json());
 
     // call onRequestPrepared hook for user to modify request
-    ctx = await hooks.onRequestPrepared(ctx, req);
+    ctx = hooks.onRequestPrepared(ctx, req);
 
     // send data
     final res = await httpClient.send(req);
diff --git a/packages/stream_video/lib/src/call/session/call_session.dart b/packages/stream_video/lib/src/call/session/call_session.dart
index 7f2a36573..e6f90642f 100644
--- a/packages/stream_video/lib/src/call/session/call_session.dart
+++ b/packages/stream_video/lib/src/call/session/call_session.dart
@@ -307,6 +307,8 @@ class CallSession extends Disposable {
       stateManager.sfuJoinResponse(event);
     } else if (event is SfuParticipantJoinedEvent) {
       stateManager.sfuParticipantJoined(event);
+    } else if (event is SfuParticipantUpdatedEvent) {
+      stateManager.sfuParticipantUpdated(event);
     } else if (event is SfuParticipantLeftEvent) {
       stateManager.sfuParticipantLeft(event);
     } else if (event is SfuConnectionQualityChangedEvent) {
diff --git a/packages/stream_video/lib/src/call/state/mixins/state_sfu_mixin.dart b/packages/stream_video/lib/src/call/state/mixins/state_sfu_mixin.dart
index 7d631cf36..f71cec863 100644
--- a/packages/stream_video/lib/src/call/state/mixins/state_sfu_mixin.dart
+++ b/packages/stream_video/lib/src/call/state/mixins/state_sfu_mixin.dart
@@ -207,4 +207,37 @@ mixin StateSfuMixin on StateNotifier<CallState> {
       ],
     );
   }
+
+  void sfuParticipantUpdated(
+    SfuParticipantUpdatedEvent event,
+  ) {
+    _logger.d(
+      () => '[sfuParticipantUpdated] ${state.sessionId}; event: $event',
+    );
+    final participant = event.participant;
+
+    final participants = state.callParticipants.map((it) {
+      if (it.userId == participant.userId &&
+          it.sessionId == participant.sessionId) {
+        return it.copyWith(
+          name: participant.userName,
+          custom: participant.custom,
+          image: participant.userImage,
+          trackIdPrefix: participant.trackLookupPrefix,
+          audioLevel: participant.audioLevel,
+          isSpeaking: participant.isSpeaking,
+          isDominantSpeaker: participant.isDominantSpeaker,
+          connectionQuality: participant.connectionQuality,
+          role: participant.roles.firstOrNull ?? '',
+        );
+      } else {
+        return it;
+      }
+    });
+    state = state.copyWith(
+      callParticipants: [
+        ...participants,
+      ],
+    );
+  }
 }
diff --git a/packages/stream_video/lib/src/sfu/data/events/sfu_event_mapper_extensions.dart b/packages/stream_video/lib/src/sfu/data/events/sfu_event_mapper_extensions.dart
index 9a05882d3..5c8286330 100644
--- a/packages/stream_video/lib/src/sfu/data/events/sfu_event_mapper_extensions.dart
+++ b/packages/stream_video/lib/src/sfu/data/events/sfu_event_mapper_extensions.dart
@@ -144,6 +144,12 @@ extension SfuEventMapper on sfu_events.SfuEvent {
         return SfuGoAwayEvent(
           goAwayReason: payload.reason.toDomain(),
         );
+      case sfu_events.SfuEvent_EventPayload.participantUpdated:
+        final payload = participantUpdated;
+        return SfuParticipantUpdatedEvent(
+          callCid: payload.callCid,
+          participant: payload.participant.toDomain(),
+        );
       default:
         return const SfuUnknownEvent();
     }
diff --git a/packages/stream_video/lib/src/sfu/data/events/sfu_events.dart b/packages/stream_video/lib/src/sfu/data/events/sfu_events.dart
index a98196d88..68523537d 100644
--- a/packages/stream_video/lib/src/sfu/data/events/sfu_events.dart
+++ b/packages/stream_video/lib/src/sfu/data/events/sfu_events.dart
@@ -128,6 +128,20 @@ class SfuParticipantJoinedEvent extends SfuEvent {
   List<Object> get props => [callCid, participant];
 }
 
+@internal
+class SfuParticipantUpdatedEvent extends SfuEvent {
+  const SfuParticipantUpdatedEvent({
+    required this.callCid,
+    required this.participant,
+  });
+
+  final String callCid;
+  final SfuParticipant participant;
+
+  @override
+  List<Object> get props => [callCid, participant];
+} 
+
 @internal
 class SfuParticipantLeftEvent extends SfuEvent {
   const SfuParticipantLeftEvent({