fix: av publishing broken initially

Author: BreadGenie

frontend/src/utils/media/TransportManager.ts

@@ -258,12 +258,7 @@ export class TransportManager {
 				errback: (error: unknown) => void,
 			) => {
 				try {
-					if (sendTransport.connectionState === "new") {
-						await client.connectWebRtcTransport(
-							sendTransportId,
-							dtlsParameters,
-						);
-					}
+					await client.connectWebRtcTransport(sendTransportId, dtlsParameters);
 					callback();
 				} catch (error) {
 					errback(error);
@@ -329,12 +324,7 @@ export class TransportManager {
 				errback: (error: unknown) => void,
 			) => {
 				try {
-					if (recvTransport.connectionState === "new") {
-						await client.connectWebRtcTransport(
-							recvTransport.id,
-							dtlsParameters,
-						);
-					}
+					await client.connectWebRtcTransport(recvTransport.id, dtlsParameters);
 					callback();
 				} catch (error) {
 					errback(error);

frontend/src/utils/sfu-meeting-manager.js

@@ -9,6 +9,39 @@ import { TransportManager } from "./media/TransportManager.ts";
 import { VideoElementManager } from "./media/VideoElementManager.js";
 import { getSFUClient } from "./sfu-client.js";
 
+function createMediaHandler() {
+	return {
+		localStream: null,
+		audioProducer: null,
+		videoProducer: null,
+		screenProducer: null,
+		setProducers(producers = {}) {
+			Object.assign(this, producers);
+		},
+		stopScreenShare() {
+			this.screenProducer = null;
+		},
+		cleanup() {
+			for (const producer of [
+				this.audioProducer,
+				this.videoProducer,
+				this.screenProducer,
+			]) {
+				try {
+					producer?.close?.();
+				} catch (error) {
+					console.warn("Failed to close producer during cleanup:", error);
+				}
+			}
+
+			this.localStream = null;
+			this.audioProducer = null;
+			this.videoProducer = null;
+			this.screenProducer = null;
+		},
+	};
+}
+
 export class SFUMeetingManager {
 	constructor() {
 		this.meetingId = null;
@@ -24,6 +57,7 @@ export class SFUMeetingManager {
 		this.participantManager = new ParticipantManager();
 		this.consumerManager = new ConsumerManager();
 		this.transportManager = new TransportManager();
+		this.mediaHandler = createMediaHandler();
 
 		this.sfuClient = null;
 		this.eventHandlers = {};