From aa6ca3d18ac27b4a41fec5d68a1772128a01b9ac Mon Sep 17 00:00:00 2001
From: Khushal Agarwal <khushal.agarwal987@gmail.com>
Date: Fri, 1 Dec 2023 12:22:44 +0530
Subject: [PATCH] tests: added tests for Microphone manager RN SDK

---
 .../__tests__/MicrophoneManagerRN.test.ts     | 126 ++++++++++++++++++
 1 file changed, 126 insertions(+)
 create mode 100644 packages/client/src/devices/__tests__/MicrophoneManagerRN.test.ts

diff --git a/packages/client/src/devices/__tests__/MicrophoneManagerRN.test.ts b/packages/client/src/devices/__tests__/MicrophoneManagerRN.test.ts
new file mode 100644
index 0000000000..6a9242619c
--- /dev/null
+++ b/packages/client/src/devices/__tests__/MicrophoneManagerRN.test.ts
@@ -0,0 +1,126 @@
+import { afterEach, beforeEach, describe, expect, it, vi } from 'vitest';
+import { MicrophoneManager } from '../MicrophoneManager';
+import { Call } from '../../Call';
+import { StreamClient } from '../../coordinator/connection/client';
+import { StreamVideoWriteableStateStore } from '../../store';
+import { mockAudioDevices, mockAudioStream, mockCall } from './mocks';
+import { of } from 'rxjs';
+import '../../rtc/__tests__/mocks/webrtc.mocks';
+import { OwnCapability } from '../../gen/coordinator';
+
+let handler;
+
+vi.mock('../../helpers/platforms.ts', () => {
+  return {
+    isReactNative: vi.fn(() => true),
+  };
+});
+
+vi.mock('../devices.ts', () => {
+  console.log('MOCKING devices API');
+  return {
+    disposeOfMediaStream: vi.fn(),
+    getAudioDevices: vi.fn(() => {
+      return of(mockAudioDevices);
+    }),
+    getAudioStream: vi.fn(() => Promise.resolve(mockAudioStream())),
+    deviceIds$: {},
+  };
+});
+
+vi.mock('../../Call.ts', () => {
+  console.log('MOCKING Call');
+  return {
+    Call: vi.fn(() => mockCall()),
+  };
+});
+
+vi.mock('../../helpers/RNSpeechDetector.ts', () => {
+  console.log('MOCKING RNSpeechDetector');
+  return {
+    RNSpeechDetector: vi.fn().mockImplementation(() => ({
+      start: vi.fn(),
+      stop: vi.fn(),
+      onSpeakingDetectedStateChange: vi.fn((callback) => {
+        handler = callback;
+        return vi.fn();
+      }),
+    })),
+  };
+});
+
+describe('MicrophoneManager React Native', () => {
+  let manager: MicrophoneManager;
+  beforeEach(() => {
+    manager = new MicrophoneManager(
+      new Call({
+        id: '',
+        type: '',
+        streamClient: new StreamClient('abc123'),
+        clientStore: new StreamVideoWriteableStateStore(),
+      }),
+    );
+  });
+
+  it(`should start sound detection if mic is disabled`, async () => {
+    await manager.enable();
+    // @ts-expect-error
+    vi.spyOn(manager, 'startSpeakingWhileMutedDetection');
+    await manager.disable();
+
+    expect(manager['startSpeakingWhileMutedDetection']).toHaveBeenCalled();
+    expect(manager['rnSpeechDetector']?.start).toHaveBeenCalled();
+  });
+
+  it(`should stop sound detection if mic is enabled`, async () => {
+    manager.state.setSpeakingWhileMuted(true);
+    manager['soundDetectorCleanup'] = () => {};
+
+    await manager.enable();
+
+    expect(manager.state.speakingWhileMuted).toBe(false);
+  });
+
+  it('should update speaking while muted state', async () => {
+    await manager['startSpeakingWhileMutedDetection']();
+
+    expect(manager.state.speakingWhileMuted).toBe(false);
+
+    handler!({ isSoundDetected: true, audioLevel: 2 });
+
+    expect(manager.state.speakingWhileMuted).toBe(true);
+
+    handler!({ isSoundDetected: false, audioLevel: 0 });
+
+    expect(manager.state.speakingWhileMuted).toBe(false);
+  });
+
+  it('should stop speaking while muted notifications if user loses permission to send audio', async () => {
+    await manager.enable();
+    await manager.disable();
+
+    // @ts-expect-error
+    vi.spyOn(manager, 'stopSpeakingWhileMutedDetection');
+    manager['call'].state.setOwnCapabilities([]);
+
+    expect(manager['stopSpeakingWhileMutedDetection']).toHaveBeenCalled();
+  });
+
+  it('should start speaking while muted notifications if user gains permission to send audio', async () => {
+    await manager.enable();
+    await manager.disable();
+
+    manager['call'].state.setOwnCapabilities([]);
+
+    // @ts-expect-error
+    vi.spyOn(manager, 'stopSpeakingWhileMutedDetection');
+    manager['call'].state.setOwnCapabilities([OwnCapability.SEND_AUDIO]);
+
+    expect(manager['stopSpeakingWhileMutedDetection']).toHaveBeenCalled();
+  });
+
+  afterEach(() => {
+    vi.clearAllMocks();
+    vi.resetModules();
+  });
+});