feat(calling): add updateMedia in call (webex#3284)

docs/samples/calling/app.js

@@ -488,6 +488,28 @@ function populateSourceDevices(mediaDevice) {
   select && select.appendChild(option);
 }
 
+async function changeInputStream() {
+  const selectedDevice = audioInputDevicesElem.options[audioInputDevicesElem.selectedIndex].value;
+
+  const constraints = {
+    audio: true,
+    deviceId: selectedDevice ? { exact: selectedDevice } : undefined
+  };
+  const newStream  = await Calling.createMicrophoneStream(constraints);
+
+  call.updateMedia(newStream);
+}
+
+async function changeOutputStream() {
+  const selectedDevice = audioOutputDevicesElem.options[audioOutputDevicesElem.selectedIndex].value;
+  mediaStreamsRemoteAudio.setSinkId(selectedDevice);
+}
+
+async function changeStream() {
+  changeInputStream();
+  changeOutputStream();
+}
+
 /**
  *
  */

docs/samples/calling/index.html

@@ -205,9 +205,8 @@ <h3 style="color: #1a73e8; margin-bottom: 0.25rem;">Call Transfer</h3>
               <div>
                 <p class="note">NOTE: Choose your sending and receiving options for the meeting.</p>
 
-                <button id="sd-get-media-devices" type="button" onclick="clearMediaDeviceList(); getMediaDevices()">Get
-                  Devices</button>
-
+                <button id="sd-get-media-devices" type="button" onclick="clearMediaDeviceList(); getMediaDevices()">Get Devices</button>
+                <button id="sd-change-media" type="button" onclick="changeStream()">Change Device</button>
                 <div class="u-mv">
                   <label>
                     <input type="checkbox" name="ts-media-direction" value="receiveAudio" checked="">receiveAudio

packages/calling/src/CallingClient/calling/call.test.ts

@@ -412,6 +412,7 @@ describe('Call Tests', () => {
 
     expect(webex.request.mock.calls[0][0].body.metrics).toStrictEqual(disconnectStats);
   });
+
   it('dial fails if localAudioTrack is empty', async () => {
     const mockStream = {
       outputStream: {
@@ -439,14 +440,86 @@ describe('Call Tests', () => {
     await waitForMsecs(50);
     expect(warnSpy).toBeCalledTimes(1);
     expect(warnSpy).toBeCalledWith(
-      `Did not find a local track while dialling the call ${call.getCorrelationId()}`,
+      `Did not find a local track while dialing the call ${call.getCorrelationId()}`,
       {file: 'call', method: 'dial'}
     );
     expect(call['callStateMachine'].state.value).toBe('S_IDLE');
     expect(call['mediaStateMachine'].state.value).toBe('S_ROAP_IDLE');
 
     expect(webex.request).not.toBeCalledOnceWith();
   });
+
+  it('update media after call creation with valid stream', () => {
+    const callManager = getCallManager(webex, defaultServiceIndicator);
+
+    const mockStream = {
+      outputStream: {
+        getAudioTracks: jest.fn().mockReturnValue([mockTrack]),
+      },
+      on: jest.fn(),
+    };
+
+    const localAudioStream = mockStream as unknown as MediaSDK.LocalMicrophoneStream;
+
+    const call = callManager.createCall(dest, CallDirection.OUTBOUND, deviceId, mockLineId);
+
+    call.dial(localAudioStream);
+
+    expect(mockTrack.enabled).toEqual(true);
+
+    const mockTrack2 = {
+      enabled: true,
+    };
+
+    const mockStream2 = {
+      outputStream: {
+        getAudioTracks: jest.fn().mockReturnValue([mockTrack2]),
+      },
+      on: jest.fn(),
+    };
+
+    const localAudioStream2 = mockStream2 as unknown as MediaSDK.LocalMicrophoneStream;
+
+    call.updateMedia(localAudioStream2);
+
+    expect(call['mediaConnection'].updateLocalTracks).toBeCalledOnceWith({audio: mockTrack2});
+  });
+
+  it('update media with invalid stream', () => {
+    const callManager = getCallManager(webex, defaultServiceIndicator);
+    const warnSpy = jest.spyOn(log, 'warn');
+
+    const mockStream = {
+      outputStream: {
+        getAudioTracks: jest.fn().mockReturnValue([mockTrack]),
+      },
+      on: jest.fn(),
+    };
+
+    const localAudioStream = mockStream as unknown as MediaSDK.LocalMicrophoneStream;
+
+    const call = callManager.createCall(dest, CallDirection.OUTBOUND, deviceId, mockLineId);
+
+    call.dial(localAudioStream);
+
+    expect(mockTrack.enabled).toEqual(true);
+
+    const errorStream = {
+      outputStream: {
+        getAudioTracks: jest.fn().mockReturnValue([]),
+      },
+    };
+
+    const localAudioStream2 = errorStream as unknown as MediaSDK.LocalMicrophoneStream;
+
+    call.updateMedia(localAudioStream2);
+
+    expect(call['mediaConnection'].updateLocalTracks).not.toBeCalled();
+    expect(warnSpy).toBeCalledOnceWith(
+      `Did not find a local track while updating media for call ${call.getCorrelationId()}. Will not update media`,
+      {file: 'call', method: 'updateMedia'}
+    );
+  });
 });
 
 describe('State Machine handler tests', () => {

packages/calling/src/CallingClient/calling/call.ts

@@ -2016,7 +2016,7 @@ export class Call extends Eventing<CallEventTypes> implements ICall {
   public async dial(localAudioStream: LocalMicrophoneStream) {
     const localAudioTrack = localAudioStream.outputStream.getAudioTracks()[0];
     if (!localAudioTrack) {
-      log.warn(`Did not find a local track while dialling the call ${this.getCorrelationId()}`, {
+      log.warn(`Did not find a local track while dialing the call ${this.getCorrelationId()}`, {
         file: CALL_FILE,
         method: 'dial',
       });
@@ -2640,7 +2640,7 @@ export class Call extends Eventing<CallEventTypes> implements ICall {
   }
 
   /**
-   * .
+   * Mutes/Unmutes the call.
    *
    * @param localAudioTrack -.
    */
@@ -2655,6 +2655,32 @@ export class Call extends Eventing<CallEventTypes> implements ICall {
     }
   };
 
+  /**
+   * Change the audio stream of the call.
+   *
+   * @param newAudioStream - The new audio stream to be used in the call.
+   */
+
+  public updateMedia = (newAudioStream: LocalMicrophoneStream): void => {
+    const localAudioTrack = newAudioStream.outputStream.getAudioTracks()[0];
+
+    if (!localAudioTrack) {
+      log.warn(
+        `Did not find a local track while updating media for call ${this.getCorrelationId()}. Will not update media`,
+        {
+          file: CALL_FILE,
+          method: 'updateMedia',
+        }
+      );
+
+      return;
+    }
+
+    this.mediaConnection.updateLocalTracks({
+      audio: localAudioTrack,
+    });
+  };
+
   /**
    * @param broadworksCorrelationInfo
    */

packages/calling/src/CallingClient/calling/types.ts

@@ -369,6 +369,13 @@ export interface ICall extends Eventing<CallEventTypes> {
     transferTarget?: string
   ): void;
 
+  /**
+   * Change the audio stream of the call.
+   *
+   * @param newAudioStream - The new audio stream to be used in the call.
+   */
+  updateMedia(newAudioStream: LocalMicrophoneStream): void;
+
   /**
    * Fetches the information related to the call's Broadworks correlationId.
    *