Merge remote-tracking branch 'origin/main' into audio-sdk-impl

# Conflicts:
#	packages/noise-cancellation-react-native/android/build.gradle
#	packages/react-native-sdk/ios/StreamVideoReactNative.h
#	packages/react-native-sdk/ios/StreamVideoReactNative.m
#	sample-apps/react-native/dogfood/ios/Podfile.lock
#	sample-apps/react-native/expo-video-sample/package.json
#	yarn.lock

Author: santhoshvai

packages/client/CHANGELOG.md

@@ -2,6 +2,42 @@
 
 This file was generated using [@jscutlery/semver](https://github.com/jscutlery/semver).
 
+## [1.32.0](https://github.com/GetStream/stream-video-js/compare/@stream-io/video-client-1.31.0...@stream-io/video-client-1.32.0) (2025-09-29)
+
+### Features
+
+- **react-native:** reject call when busy ([#1856](https://github.com/GetStream/stream-video-js/issues/1856)) ([b60bc7c](https://github.com/GetStream/stream-video-js/commit/b60bc7cd2dc2e09d52496d7b5cb593cac4b89485))
+
+### Bug Fixes
+
+- restore calling state after unrecoverable join fail ([#1935](https://github.com/GetStream/stream-video-js/issues/1935)) ([8ab0168](https://github.com/GetStream/stream-video-js/commit/8ab01680d01cc47f9cf48078634358507f0c109d))
+- send unifiedSessionId in the initial join request ([#1934](https://github.com/GetStream/stream-video-js/issues/1934)) ([e6a533d](https://github.com/GetStream/stream-video-js/commit/e6a533d7e926086ac5930ebfb4648dade449d15a))
+
+## [1.31.0](https://github.com/GetStream/stream-video-js/compare/@stream-io/video-client-1.30.1...@stream-io/video-client-1.31.0) (2025-09-17)
+
+### Features
+
+- introduce @stream-io/worker-timers ([94c962b](https://github.com/GetStream/stream-video-js/commit/94c962b2c5f731c152771b7803a59664fa925477))
+
+### Bug Fixes
+
+- **video-filters:** prevent background tab throttling ([#1920](https://github.com/GetStream/stream-video-js/issues/1920)) ([f93d5cc](https://github.com/GetStream/stream-video-js/commit/f93d5cc5785957c7f181fcaf689ec366df9e646b))
+
+## [1.30.1](https://github.com/GetStream/stream-video-js/compare/@stream-io/video-client-1.30.0...@stream-io/video-client-1.30.1) (2025-09-16)
+
+### Bug Fixes
+
+- don't apply default camera state if video is off ([#1917](https://github.com/GetStream/stream-video-js/issues/1917)) ([9cf1d75](https://github.com/GetStream/stream-video-js/commit/9cf1d752d824a0527fbb187df21d8a020590d4bb))
+- **rn:** set direction state for flip after constraints are applied ([1f03c59](https://github.com/GetStream/stream-video-js/commit/1f03c59b9b3fecc0ff1f7cb6b0eccb083b4a3475))
+
+## [1.30.0](https://github.com/GetStream/stream-video-js/compare/@stream-io/video-client-1.29.0...@stream-io/video-client-1.30.0) (2025-09-11)
+
+- Skip tests for StreamVideoClient coordinator API ([aabe1d0](https://github.com/GetStream/stream-video-js/commit/aabe1d0ad3e3a95698b422991729e46289ab0277))
+
+### Features
+
+- Participant Source ([#1896](https://github.com/GetStream/stream-video-js/issues/1896)) ([b1cf710](https://github.com/GetStream/stream-video-js/commit/b1cf710ac3bfda573c0379dac1e6a107d2dbabf6))
+
 ## [1.29.0](https://github.com/GetStream/stream-video-js/compare/@stream-io/video-client-1.28.1...@stream-io/video-client-1.29.0) (2025-09-09)
 
 ### Features

packages/client/generate-timer-worker.sh

@@ -1,6 +1,6 @@
 {
   "name": "@stream-io/video-client",
-  "version": "1.29.0",
+  "version": "1.32.0",
   "main": "dist/index.cjs.js",
   "module": "dist/index.es.js",
   "browser": "dist/index.browser.es.js",
@@ -14,8 +14,7 @@
     "test": "vitest",
     "test-ci": "vitest run --coverage",
     "generate:open-api": "./generate-openapi.sh protocol",
-    "generate:open-api:dev": "./generate-openapi.sh chat",
-    "generate:timer-worker": "./generate-timer-worker.sh"
+    "generate:open-api:dev": "./generate-openapi.sh chat"
   },
   "files": [
     "dist",
@@ -30,6 +29,7 @@
     "@protobuf-ts/runtime": "^2.9.4",
     "@protobuf-ts/runtime-rpc": "^2.9.4",
     "@protobuf-ts/twirp-transport": "^2.9.4",
+    "@stream-io/worker-timer": "^1.2.4",
     "axios": "^1.8.1",
     "rxjs": "~7.8.1",
     "sdp-transform": "^2.15.0",

packages/client/package.json

@@ -112,6 +112,7 @@ import {
   ClientCapability,
   ClientDetails,
   Codec,
+  ParticipantSource,
   PublishOption,
   SubscribeOption,
   TrackType,
@@ -873,8 +874,6 @@ export class Call {
       throw new Error(`Illegal State: call.join() shall be called only once`);
     }
 
-    this.state.setCallingState(CallingState.JOINING);
-
     // we will count the number of join failures per SFU.
     // once the number of failures reaches 2, we will piggyback on the `migrating_from`
     // field to force the coordinator to provide us another SFU
@@ -904,8 +903,6 @@ export class Call {
         }
 
         if (attempt === maxJoinRetries - 1) {
-          // restore the previous call state if the join-flow fails
-          this.state.setCallingState(callingState);
           throw err;
         }
       }
@@ -980,6 +977,7 @@ export class Call {
           })
         : previousSfuClient;
     this.sfuClient = sfuClient;
+    this.unifiedSessionId ??= sfuClient.sessionId;
     this.dynascaleManager.setSfuClient(sfuClient);
 
     const clientDetails = await getClientDetails();
@@ -1007,6 +1005,7 @@ export class Call {
       try {
         const { callState, fastReconnectDeadlineSeconds, publishOptions } =
           await sfuClient.join({
+            unifiedSessionId: this.unifiedSessionId,
             subscriberSdp,
             publisherSdp,
             clientDetails,
@@ -1015,6 +1014,7 @@ export class Call {
             preferredPublishOptions,
             preferredSubscribeOptions,
             capabilities: Array.from(this.clientCapabilities),
+            source: ParticipantSource.WEBRTC_UNSPECIFIED,
           });
 
         this.currentPublishOptions = publishOptions;
@@ -1059,6 +1059,7 @@ export class Call {
         statsOptions,
         publishOptions: this.currentPublishOptions || [],
         closePreviousInstances: !performingMigration,
+        unifiedSessionId: this.unifiedSessionId,
       });
     }
 
@@ -1220,6 +1221,7 @@ export class Call {
     clientDetails: ClientDetails;
     publishOptions: PublishOption[];
     closePreviousInstances: boolean;
+    unifiedSessionId: string;
   }) => {
     const {
       sfuClient,
@@ -1228,6 +1230,7 @@ export class Call {
       statsOptions,
       publishOptions,
       closePreviousInstances,
+      unifiedSessionId,
     } = opts;
     const { enable_rtc_stats: enableTracing } = statsOptions;
     if (closePreviousInstances && this.subscriber) {
@@ -1286,7 +1289,6 @@ export class Call {
     this.tracer.setEnabled(enableTracing);
     this.sfuStatsReporter?.stop();
     if (statsOptions?.reporting_interval_ms > 0) {
-      this.unifiedSessionId ??= sfuClient.sessionId;
       this.sfuStatsReporter = new SfuStatsReporter(sfuClient, {
         clientDetails,
         options: statsOptions,
@@ -1296,7 +1298,7 @@ export class Call {
         camera: this.camera,
         state: this.state,
         tracer: this.tracer,
-        unifiedSessionId: this.unifiedSessionId,
+        unifiedSessionId,
       });
       this.sfuStatsReporter.start();
     }

packages/client/src/Call.ts

@@ -1,6 +1,7 @@
 import { Call } from './Call';
 import { StreamClient } from './coordinator/connection/client';
 import {
+  CallingState,
   StreamVideoReadOnlyStateStore,
   StreamVideoWriteableStateStore,
 } from './store';
@@ -74,6 +75,7 @@ export class StreamVideoClient {
   );
 
   private static _instances = new Map<string, StreamVideoClient>();
+  private rejectCallWhenBusy = false;
 
   /**
    * You should create only one instance of `StreamVideoClient`.
@@ -95,6 +97,7 @@ export class StreamVideoClient {
     setLogger(rootLogger, clientOptions?.logLevel || 'warn');
 
     this.logger = getLogger(['client']);
+    this.rejectCallWhenBusy = clientOptions?.rejectCallWhenBusy ?? false;
 
     this.streamClient = createCoordinatorClient(apiKey, clientOptions);
 
@@ -206,7 +209,18 @@ export class StreamVideoClient {
         let call = this.writeableStateStore.findCall(e.call.type, e.call.id);
         if (call) {
           if (ringing) {
-            await call.updateFromRingingEvent(e as CallRingEvent);
+            if (this.shouldRejectCall(call.cid)) {
+              this.logger(
+                'info',
+                `Leaving call with busy reject reason ${call.cid} because user is busy`,
+              );
+              // remove the instance from the state store
+              await call.leave();
+              // explicitly reject the call with busy reason as calling state was not ringing before and leave would not call it therefore
+              await call.reject('busy');
+            } else {
+              await call.updateFromRingingEvent(e as CallRingEvent);
+            }
           } else {
             call.state.updateFromCallResponse(e.call);
           }
@@ -221,11 +235,21 @@ export class StreamVideoClient {
           clientStore: this.writeableStateStore,
           ringing,
         });
-        call.state.updateFromCallResponse(e.call);
 
         if (ringing) {
-          await call.get();
+          if (this.shouldRejectCall(call.cid)) {
+            this.logger(
+              'info',
+              `Rejecting call ${call.cid} because user is busy`,
+            );
+            // call is not in the state store yet, so just reject api is enough
+            await call.reject('busy');
+          } else {
+            await call.updateFromRingingEvent(e as CallRingEvent);
+            await call.get();
+          }
         } else {
+          call.state.updateFromCallResponse(e.call);
           this.writeableStateStore.registerCall(call);
           this.logger('info', `New call created and registered: ${call.cid}`);
         }
@@ -572,4 +596,19 @@ export class StreamVideoClient {
       this.streamClient.connectAnonymousUser(user, tokenOrProvider),
     );
   };
+
+  private shouldRejectCall = (currentCallId: string) => {
+    if (!this.rejectCallWhenBusy) return false;
+
+    const hasOngoingRingingCall = this.state.calls.some(
+      (c) =>
+        c.cid !== currentCallId &&
+        c.ringing &&
+        c.state.callingState !== CallingState.IDLE &&
+        c.state.callingState !== CallingState.LEFT &&
+        c.state.callingState !== CallingState.RECONNECTING_FAILED,
+    );
+
+    return hasOngoingRingingCall;
+  };
 }

packages/client/src/StreamVideoClient.ts

@@ -25,7 +25,7 @@ const tokenProvider = (userId: string) => {
   };
 };
 
-describe('StreamVideoClient - coordinator API', () => {
+describe.skip('StreamVideoClient - coordinator API', () => {
   let client: StreamVideoClient;
   const user = {
     id: 'sara',

packages/client/src/__tests__/StreamVideoClient.api.test.ts

@@ -216,6 +216,11 @@ export type StreamClientOptions = Partial<AxiosRequestConfig> & {
    * @param allErrors all errors.
    */
   onConnectUserError?: (lastError: Error, allErrors: Error[]) => void;
+
+  /**
+   * When set to true, the incoming calls are rejected when the user is busy in an another call.
+   */
+  rejectCallWhenBusy?: boolean;
 };
 
 export type ClientAppIdentifier = {

packages/client/src/coordinator/connection/types.ts

@@ -38,18 +38,17 @@ export class CameraManager extends InputMediaDeviceManager<CameraManagerState> {
       return;
     }
 
-    // providing both device id and direction doesn't work, so we deselect the device
-    this.state.setDirection(direction);
-    this.state.setDevice(undefined);
-
     if (isReactNative()) {
       const videoTrack = this.getTracks()[0] as MediaStreamTrack | undefined;
       await videoTrack?.applyConstraints({
         facingMode: direction === 'front' ? 'user' : 'environment',
       });
+      this.state.setDirection(direction);
       return;
     }
-
+    // providing both device id and direction doesn't work, so we deselect the device
+    this.state.setDirection(direction);
+    this.state.setDevice(undefined);
     this.getTracks().forEach((track) => track.stop());
     try {
       await this.unmuteStream();
@@ -122,7 +121,8 @@ export class CameraManager extends InputMediaDeviceManager<CameraManagerState> {
     // Wait for any in progress camera operation
     await this.statusChangeSettled();
 
-    const { target_resolution, camera_facing, camera_default_on } = settings;
+    const { target_resolution, camera_facing, camera_default_on, enabled } =
+      settings;
     // normalize target resolution to landscape format.
     // on mobile devices, the device itself adjusts the resolution to portrait or landscape
     // depending on the orientation of the device. using portrait resolution
@@ -142,7 +142,11 @@ export class CameraManager extends InputMediaDeviceManager<CameraManagerState> {
     if (this.enabled && mediaStream) {
       // The camera is already enabled (e.g. lobby screen). Publish the stream
       await this.publishStream(mediaStream);
-    } else if (this.state.status === undefined && camera_default_on) {
+    } else if (
+      this.state.status === undefined &&
+      camera_default_on &&
+      enabled
+    ) {
       // Start camera if backend config specifies, and there is no local setting
       await this.enable();
     }

packages/client/src/devices/CameraManager.ts

@@ -243,6 +243,7 @@ describe('CameraManager', () => {
       await manager.apply(
         // @ts-expect-error - partial settings
         {
+          enabled: true,
           target_resolution: { width: 640, height: 480 },
           camera_facing: 'front',
           camera_default_on: true,
@@ -261,6 +262,7 @@ describe('CameraManager', () => {
       await manager.apply(
         // @ts-expect-error - partial settings
         {
+          enabled: true,
           target_resolution: { width: 640, height: 480 },
           camera_facing: 'front',
           camera_default_on: false,
@@ -327,6 +329,23 @@ describe('CameraManager', () => {
 
       expect(manager['publishStream']).toHaveBeenCalled();
     });
+
+    it('should not turn on the camera when video is disabled', async () => {
+      vi.spyOn(manager, 'enable');
+      await manager.apply(
+        // @ts-expect-error - partial settings
+        {
+          enabled: false,
+          target_resolution: { width: 640, height: 480 },
+          camera_facing: 'front',
+          camera_default_on: true,
+        },
+        false,
+      );
+
+      expect(manager.state.status).toBe(undefined);
+      expect(manager.enable).not.toHaveBeenCalled();
+    });
   });
 
   afterEach(() => {