This commit is contained in:
acgist
2023-03-14 08:08:17 +08:00
parent 0cd054dbb0
commit dfec49892d
2 changed files with 5 additions and 4 deletions

View File

@@ -1343,7 +1343,7 @@ class Taoyao {
...webRtcTransportOptions, ...webRtcTransportOptions,
webRtcServer: room.webRtcServer, webRtcServer: room.webRtcServer,
}); });
me.transportEvent("webrtc", roomId, transport); self.transportEvent("webrtc", roomId, transport);
transport.clientId = clientId; transport.clientId = clientId;
room.transports.set(transport.id, transport); room.transports.set(transport.id, transport);
message.body = { message.body = {
@@ -1371,6 +1371,7 @@ class Taoyao {
* @param {*} transport 通道 * @param {*} transport 通道
*/ */
transportEvent(type, roomId, transport) { transportEvent(type, roomId, transport) {
const self = this;
/********************* 通用通道事件 *********************/ /********************* 通用通道事件 *********************/
transport.on("routerclose", () => { transport.on("routerclose", () => {
console.info("transport routerclose", transport.id); console.info("transport routerclose", transport.id);

View File

@@ -586,11 +586,11 @@ class Taoyao extends RemoteClient {
/************************ 管理 ************************/ /************************ 管理 ************************/
getProducer(producerId) { getProducer(producerId) {
const me = this; const me = this;
if(me?.audioProducer.id === producerId) { if(me.audioProducer?.id === producerId) {
return me.audioProducer; return me.audioProducer;
} else if(me?.videoProducer.id === producerId) { } else if(me.videoProducer?.id === producerId) {
return me.videoProducer; return me.videoProducer;
} else if(me?.dataProducer.id === producerId) { } else if(me.dataProducer?.id === producerId) {
return me.dataProducer; return me.dataProducer;
} else { } else {
return null; return null;