Dekescordes/spacebar
2
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

fix weird timing issue with onVideo message

Browse Source
This commit is contained in:
dank074 2025-05-07 19:44:39 -05:00
parent 11bb278c02
commit 4592ff1a11
1 changed files with 13 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

16
src/webrtc/opcodes/Video.ts
View File

@ -26,7 +26,7 @@ import {
import type { WebRtcClient } from "spacebar-webrtc-types";
export async function onVideo(this: WebRtcWebSocket, payload: VoicePayload) {
if (!this.webRtcClient || !this.webRtcClient.webrtcConnected) return;
if (!this.webRtcClient) return;
const { voiceRoomId } = this.webRtcClient;
@ -47,12 +47,22 @@ export async function onVideo(this: WebRtcWebSocket, payload: VoicePayload) {
const stream = d.streams?.find((element) => element.active);
await Send(this, { op: VoiceOPCodes.MEDIA_SINK_WANTS, d: { any: 100 } });
const clientsThatNeedUpdate = new Set<WebRtcClient<WebRtcWebSocket>>();
const wantsToProduceAudio = d.audio_ssrc !== 0;
const wantsToProduceVideo = d.video_ssrc !== 0 && stream?.active;
// this is to handle a really weird case where the client sends audio info before the
// dtls ice connection is completely connected. TODO: find a better way to handle this
if (!this.webRtcClient.webrtcConnected) {
if (wantsToProduceAudio) {
await new Promise<void>((resolve, reject) => {
this.webRtcClient?.emitter.once("connected", () => resolve());
});
} else return;
}
await Send(this, { op: VoiceOPCodes.MEDIA_SINK_WANTS, d: { any: 100 } });
// first check if we need stop any tracks
if (!wantsToProduceAudio && this.webRtcClient.isProducingAudio()) {
this.webRtcClient.stopPublishingTrack("audio");