[mirotalksfu] - refactoring
هذا الالتزام موجود في:
@@ -112,6 +112,18 @@ module.exports = class Peer {
|
|||||||
transport.close();
|
transport.close();
|
||||||
this.delTransport(transport_id);
|
this.delTransport(transport_id);
|
||||||
});
|
});
|
||||||
|
|
||||||
|
const peerTransports = this.getTransports();
|
||||||
|
const peerProducers = this.getProducers();
|
||||||
|
const peerConsumers = this.getConsumers();
|
||||||
|
|
||||||
|
log.debug('CLOSE PEER', {
|
||||||
|
peer_id: this.id,
|
||||||
|
peer_name: this.peer_name,
|
||||||
|
peerTransports: peerTransports,
|
||||||
|
peerProducers: peerProducers,
|
||||||
|
peerConsumers: peerConsumers,
|
||||||
|
});
|
||||||
}
|
}
|
||||||
|
|
||||||
// ####################################################
|
// ####################################################
|
||||||
|
|||||||
@@ -241,8 +241,6 @@ module.exports = class Room {
|
|||||||
|
|
||||||
const peer = this.getPeer(socket_id);
|
const peer = this.getPeer(socket_id);
|
||||||
|
|
||||||
const { id, peer_name } = peer;
|
|
||||||
|
|
||||||
peer.close();
|
peer.close();
|
||||||
|
|
||||||
this.peers.delete(socket_id);
|
this.peers.delete(socket_id);
|
||||||
@@ -250,18 +248,6 @@ module.exports = class Room {
|
|||||||
if (this.getPeers().size === 0) {
|
if (this.getPeers().size === 0) {
|
||||||
this.closeRouter();
|
this.closeRouter();
|
||||||
}
|
}
|
||||||
|
|
||||||
const peerTransports = peer.getTransports();
|
|
||||||
const peerProducers = peer.getProducers();
|
|
||||||
const peerConsumers = peer.getConsumers();
|
|
||||||
|
|
||||||
log.debug('REMOVE PEER', {
|
|
||||||
peer_id: id,
|
|
||||||
peer_name: peer_name,
|
|
||||||
peerTransports: peerTransports,
|
|
||||||
peerProducers: peerProducers,
|
|
||||||
peerConsumers: peerConsumers,
|
|
||||||
});
|
|
||||||
}
|
}
|
||||||
|
|
||||||
// ####################################################
|
// ####################################################
|
||||||
|
|||||||
المرجع في مشكلة جديدة
حظر مستخدم