save

ObserveRTC · Nov 18, 2024 · 4439d17 · 4439d17
1 parent 5e427a7
commit 4439d17
Showing 3 changed files with 9 additions and 4 deletions.
diff --git a/media-server/src/client-listeners/CreateTransportRequestListener.ts b/media-server/src/client-listeners/CreateTransportRequestListener.ts
@@ -64,6 +64,9 @@ export function createCreateTransportRequestListener(listenerContext: CreateTran
 					if (webRtcServer) {
 						transportOptions = {
 							webRtcServer,
+							appData: {
+								webrtcTransport: true,
+							}
 						};
 
 						// also the ice candidate should be fetched here
@@ -75,6 +78,9 @@ export function createCreateTransportRequestListener(listenerContext: CreateTran
 								ip: server.config.serverIp,
 								announcedIp: server.config.announcedIp,
 							}],
+							appData: {
+								webrtcTransport: true,
+							}
 						};
 					}
 

diff --git a/media-server/src/hamok-listeners/ConsumeMediaProducerListener.ts b/media-server/src/hamok-listeners/ConsumeMediaProducerListener.ts
@@ -48,7 +48,6 @@ export function createConsumeMediaProducerListener(listenerContext: ConsumeMedia
 				mediaProducer = mediasoupService.mediaProducers.get(mediaProducerId);
 			}
 
-
 			if (!mediaProducer) {
 				return logger.warn(`Media producer ${mediaProducerId} not found in mediasoupService`);
 			}

diff --git a/media-server/src/services/MediasoupService.ts b/media-server/src/services/MediasoupService.ts
@@ -424,8 +424,8 @@ export class MediasoupService extends EventEmitter<MediasoupServiceEventMap> {
 		return localPipeTransport;
 	}
 
-	private _addTransport = (router: mediasoup.types.Router<RouterAppData>, transport: mediasoup.types.Transport) => {
-		if (transport.constructor.name !== 'WebRtcTransport') {
+	private _addTransport = (router: mediasoup.types.Router<RouterAppData>, transport: mediasoup.types.Transport<{ webrtcTransport?: boolean}>) => {
+		if (!transport.appData?.webrtcTransport) {
 			// at the moment we only add webrtc transport
 			return;
 		}
@@ -490,7 +490,7 @@ export class MediasoupService extends EventEmitter<MediasoupServiceEventMap> {
 		router.appData.mediaConsumers.set(consumer.id, consumer);
 		this.mediaConsumers.set(consumer.id, consumer);
 
-		if (transport.constructor.name === 'WebRtcTransport') {
+		if (transport.appData?.webrtcTransport) {
 			this.emit('new-webrtc-media-consumer', consumer);
 		}
 		logger.info(`Consumer ${consumer.id} created on transport ${transport.id} on router ${router.id}`);