diff --git a/src/room/useGroupCall.ts b/src/room/useGroupCall.ts index ec496ff..2e6978a 100644 --- a/src/room/useGroupCall.ts +++ b/src/room/useGroupCall.ts @@ -23,12 +23,7 @@ import { GroupCallUnknownDeviceError, GroupCallError, } from "matrix-js-sdk/src/webrtc/groupCall"; -import { - CallState, - MatrixCall, - CallEvent, -} from "matrix-js-sdk/src/webrtc/call"; -import { CallFeed } from "matrix-js-sdk/src/webrtc/callFeed"; +import { CallFeed, CallFeedEvent } from "matrix-js-sdk/src/webrtc/callFeed"; import { RoomMember } from "matrix-js-sdk/src/models/room-member"; import { useTranslation } from "react-i18next"; import { IWidgetApiRequest } from "matrix-widget-api"; @@ -96,29 +91,20 @@ function getParticipants( const participants = new Map>(); for (const [member, participantsStateMap] of groupCall.participants) { - const callMap = groupCall.calls.get(member); const participantInfoMap = new Map(); participants.set(member, participantInfoMap); for (const [deviceId, participant] of participantsStateMap) { - const call = callMap?.get(deviceId); const feed = groupCall.userMediaFeeds.find( (f) => f.userId === member.userId && f.deviceId === deviceId ); - let connectionState = ConnectionState.EstablishingCall; - if (feed?.isLocal()) { - connectionState = ConnectionState.Connected; - } else if (call !== undefined) { - if (call.state === CallState.Connected) { - connectionState = ConnectionState.Connected; - } else if (call.state === CallState.Connecting) { - connectionState = ConnectionState.WaitMedia; - } - } - participantInfoMap.set(deviceId, { - connectionState, + connectionState: feed + ? feed.connected + ? ConnectionState.Connected + : ConnectionState.WaitMedia + : ConnectionState.EstablishingCall, presenter: participant.screensharing, }); } @@ -188,19 +174,49 @@ export function useGroupCall(groupCall: GroupCall): UseGroupCallReturnType { }); } + const prevUserMediaFeeds = new Set(); + function onUserMediaFeedsChanged(userMediaFeeds: CallFeed[]): void { + for (const feed of prevUserMediaFeeds) { + feed.off(CallFeedEvent.ConnectedChanged, onConnectedChanged); + } + prevUserMediaFeeds.clear(); + + for (const feed of userMediaFeeds) { + feed.on(CallFeedEvent.ConnectedChanged, onConnectedChanged); + prevUserMediaFeeds.add(feed); + } + updateState({ userMediaFeeds: [...userMediaFeeds], participants: getParticipants(groupCall), }); } + const prevScreenshareFeeds = new Set(); + function onScreenshareFeedsChanged(screenshareFeeds: CallFeed[]): void { + for (const feed of prevScreenshareFeeds) { + feed.off(CallFeedEvent.ConnectedChanged, onConnectedChanged); + } + prevScreenshareFeeds.clear(); + + for (const feed of screenshareFeeds) { + feed.on(CallFeedEvent.ConnectedChanged, onConnectedChanged); + prevScreenshareFeeds.add(feed); + } + updateState({ screenshareFeeds: [...screenshareFeeds], }); } + function onConnectedChanged(connected: boolean): void { + updateState({ + participants: getParticipants(groupCall), + }); + } + function onActiveSpeakerChanged(activeSpeaker: CallFeed | undefined): void { updateState({ activeSpeaker: activeSpeaker ?? null, @@ -228,25 +244,7 @@ export function useGroupCall(groupCall: GroupCall): UseGroupCallReturnType { }); } - const prevCalls = new Set(); - - function onCallState(): void { - updateState({ participants: getParticipants(groupCall) }); - } - - function onCallsChanged( - calls: Map> - ): void { - for (const call of prevCalls) call.off(CallEvent.State, onCallState); - prevCalls.clear(); - - for (const deviceMap of calls.values()) { - for (const call of deviceMap.values()) { - call.on(CallEvent.State, onCallState); - prevCalls.add(call); - } - } - + function onCallsChanged(): void { updateState({ participants: getParticipants(groupCall) }); }