fix tests

Author: Regaddi

src/DailyParticipants.tsx

@@ -207,9 +207,8 @@ export const DailyParticipants: React.FC<React.PropsWithChildren<{}>> = ({
             evts.forEach((ev) => {
               switch (ev.action) {
                 case 'active-speaker-change': {
-                  const sessionId = ev.activeSpeaker.peerId;
-                  set(activeIdState, sessionId);
-                  set(participantState(sessionId), (prev) => {
+                  set(activeIdState, ev.activeSpeaker.peerId);
+                  set(participantState(ev.activeSpeaker.peerId), (prev) => {
                     if (!prev) return null;
                     return {
                       ...prev,

test/components/DailyAudio.test.tsx

@@ -352,6 +352,7 @@ describe('DailyAudio', () => {
       });
     });
     it('replaces least recent speaker slot', async () => {
+      jest.useFakeTimers();
       /**
        * Scenario: 4 participants to trigger sorting by last_active dates.
        * - Remote participant 1 becomes active speaker (subscribed)
@@ -392,19 +393,24 @@ describe('DailyAudio', () => {
       );
       act(() => emitJoinedMeeting(callObject, participants));
       act(() => emitStartedCamera(callObject));
-      act(() => emitActiveSpeakerChange(callObject, remoteParticipants[0]));
+      act(() => {
+        emitActiveSpeakerChange(callObject, remoteParticipants[0]);
+        jest.advanceTimersByTime(500);
+      });
       await waitFor(() => {
         expect(queryAudioById(remoteParticipants[0], container)).not.toBeNull();
       });
       act(() => {
         emitActiveSpeakerChange(callObject, remoteParticipants[1]);
+        jest.advanceTimersByTime(500);
       });
       await waitFor(() => {
         expect(queryAudioById(remoteParticipants[0], container)).not.toBeNull();
         expect(queryAudioById(remoteParticipants[1], container)).not.toBeNull();
       });
       act(() => {
         emitActiveSpeakerChange(callObject, remoteParticipants[2]);
+        jest.advanceTimersByTime(500);
       });
       await waitFor(() => {
         expect(queryAudioById(remoteParticipants[0], container)).not.toBeNull();
@@ -413,13 +419,15 @@ describe('DailyAudio', () => {
       });
       act(() => {
         emitActiveSpeakerChange(callObject, remoteParticipants[3]);
+        jest.advanceTimersByTime(500);
       });
       await waitFor(() => {
         expect(queryAudioById(remoteParticipants[0], container)).toBeNull();
         expect(queryAudioById(remoteParticipants[1], container)).not.toBeNull();
         expect(queryAudioById(remoteParticipants[2], container)).not.toBeNull();
         expect(queryAudioById(remoteParticipants[3], container)).not.toBeNull();
       });
+      jest.useRealTimers();
     });
   });
 });

test/hooks/useActiveSpeakerId.test.tsx

@@ -10,6 +10,11 @@ import React from 'react';
 
 import { DailyProvider } from '../../src/DailyProvider';
 import { useActiveSpeakerId } from '../../src/hooks/useActiveSpeakerId';
+import {
+  emitActiveSpeakerChange,
+  emitJoinedMeeting,
+} from '../.test-utils/event-emitter';
+import { mockParticipant } from '../.test-utils/mocks';
 
 jest.mock('../../src/DailyLiveStreaming', () => ({
   ...jest.requireActual('../../src/DailyLiveStreaming'),
@@ -82,15 +87,19 @@ describe('useActiveSpeakerId', () => {
     });
     it('does not change returned participant, when ignoreLocal is set', async () => {
       const daily = DailyIframe.createCallObject();
+      const local = mockParticipant({
+        local: true,
+        session_id: 'local',
+        user_name: '',
+      });
+      const a = mockParticipant({
+        local: false,
+        session_id: 'a',
+        user_name: 'Alpha',
+      });
       (daily.participants as jest.Mock).mockImplementation(() => ({
-        local: {
-          session_id: 'local',
-          user_name: '',
-        },
-        a: {
-          session_id: 'a',
-          user_name: 'Alpha',
-        },
+        local,
+        a,
       }));
       const { result, waitFor } = renderHook(
         () =>
@@ -101,16 +110,14 @@ describe('useActiveSpeakerId', () => {
           wrapper: createWrapper(daily),
         }
       );
-      const event: DailyEvent = 'active-speaker-change';
-      const payload: DailyEventObjectActiveSpeakerChange = {
-        action: event,
-        activeSpeaker: {
-          peerId: 'local',
-        },
-      };
       act(() => {
-        // @ts-ignore
-        daily.emit(event, payload);
+        emitJoinedMeeting(daily, {
+          local,
+          a,
+        });
+      });
+      act(() => {
+        emitActiveSpeakerChange(daily, local.session_id);
       });
       await waitFor(() => {
         expect(result.current).toEqual(null);

test/hooks/useThrottledDailyEvent.test.tsx

@@ -79,10 +79,13 @@ describe('useThrottledDailyEvent', () => {
     // And useThrottledDailyEvent registers call-instance-destroyed listener itself.
     expect(daily.on).toHaveBeenCalledTimes(2 + 2);
   });
-  it('calls callback once in a given throttle timeframe', async () => {
+  it('calls callback at most twice in a given throttle timeframe', async () => {
     jest.useFakeTimers();
     const daily = DailyIframe.createCallObject();
-    const callback = jest.fn();
+    const receivedEvents: DailyEventObjectAppMessage[] = [];
+    const callback = jest.fn((evts: DailyEventObjectAppMessage[]) => {
+      receivedEvents.push(...evts);
+    });
     const delay = 100;
     const { waitFor } = renderHook(
       () => {
@@ -107,8 +110,8 @@ describe('useThrottledDailyEvent', () => {
     });
     jest.advanceTimersByTime(delay);
     await waitFor(() => {
-      expect(callback).toHaveBeenCalledTimes(1);
-      expect(callback).toHaveBeenCalledWith(expect.arrayContaining(evts));
+      expect(callback.mock.calls.length).toBeLessThanOrEqual(2);
+      expect(receivedEvents).toEqual(evts);
     });
     jest.useRealTimers();
   });