[mirotalksfu] - fix typo
هذا الالتزام موجود في:
@@ -247,6 +247,7 @@ module.exports = class Room {
|
|||||||
}
|
}
|
||||||
|
|
||||||
const { maxIncomingBitrate, initialAvailableOutgoingBitrate, listenInfos } = this.webRtcTransport;
|
const { maxIncomingBitrate, initialAvailableOutgoingBitrate, listenInfos } = this.webRtcTransport;
|
||||||
|
|
||||||
const transport = await this.router.createWebRtcTransport({
|
const transport = await this.router.createWebRtcTransport({
|
||||||
listenInfos: listenInfos,
|
listenInfos: listenInfos,
|
||||||
enableUdp: true,
|
enableUdp: true,
|
||||||
@@ -269,10 +270,25 @@ module.exports = class Room {
|
|||||||
|
|
||||||
const { peer_name } = peer;
|
const { peer_name } = peer;
|
||||||
|
|
||||||
transport.on('dtlsstatechange', (dtlsState) => {
|
transport.on('icestatechange', (iceState) => {
|
||||||
if (dtlsState === 'closed') {
|
if (iceState === 'disconnected' || iceState === 'closed') {
|
||||||
log.debug('Transport closed', { peer_name: peer_name });
|
log.warn('Transport closed "icestatechange" event', { iceState: iceState });
|
||||||
transport.close();
|
transport.close();
|
||||||
|
//this.router.close();
|
||||||
|
//peer.close();
|
||||||
|
}
|
||||||
|
});
|
||||||
|
|
||||||
|
transport.on('sctpstatechange', (sctpState) => {
|
||||||
|
log.debug('Transport "sctpstatechange" event', { sctpState: sctpState });
|
||||||
|
});
|
||||||
|
|
||||||
|
transport.on('dtlsstatechange', (dtlsState) => {
|
||||||
|
if (dtlsState === 'failed' || dtlsState === 'closed') {
|
||||||
|
log.warn('Transport closed "dtlsstatechange" event', { dtlsState: dtlsState });
|
||||||
|
transport.close();
|
||||||
|
//this.router.close();
|
||||||
|
//peer.close();
|
||||||
}
|
}
|
||||||
});
|
});
|
||||||
|
|
||||||
@@ -281,6 +297,7 @@ module.exports = class Room {
|
|||||||
});
|
});
|
||||||
|
|
||||||
log.debug('Adding transport', { transportId: id });
|
log.debug('Adding transport', { transportId: id });
|
||||||
|
|
||||||
peer.addTransport(transport);
|
peer.addTransport(transport);
|
||||||
|
|
||||||
return {
|
return {
|
||||||
|
|||||||
@@ -1532,7 +1532,7 @@ function startServer() {
|
|||||||
|
|
||||||
log.debug('[Disconnect] - peer name', peerName);
|
log.debug('[Disconnect] - peer name', peerName);
|
||||||
|
|
||||||
room.removePeer(socket.id);
|
await room.removePeer(socket.id);
|
||||||
|
|
||||||
if (room.getPeers().size === 0) {
|
if (room.getPeers().size === 0) {
|
||||||
//
|
//
|
||||||
|
|||||||
@@ -866,7 +866,7 @@ class RoomClient {
|
|||||||
const baseUrl = `${window.location.origin}/join`;
|
const baseUrl = `${window.location.origin}/join`;
|
||||||
const queryParams = {
|
const queryParams = {
|
||||||
room: this.room_id,
|
room: this.room_id,
|
||||||
password: this.RoomPassword,
|
roomPassword: this.RoomPassword,
|
||||||
name: this.peer_name,
|
name: this.peer_name,
|
||||||
audio: this.peer_info.peer_audio,
|
audio: this.peer_info.peer_audio,
|
||||||
video: this.peer_info.peer_video,
|
video: this.peer_info.peer_video,
|
||||||
|
|||||||
المرجع في مشكلة جديدة
حظر مستخدم