ghaymah_dev/codepill-sfu
1
0
نسخ 0
الشفرة المشكلات طلبات السحب Actions Packages المشاريع الإصدارات الويكي النشاط

[mirotalksfu] - refactoring

تصفح المصدر
هذا الالتزام موجود في:
Miroslav Pejic
2024-03-07 19:43:00 +01:00
الأصل 0438037918
التزام e469bcae41
8 ملفات معدلة مع 100 إضافات و81 حذوفات
تنزيل ملف التصحيح تنزيل ملف الاختلاف توسيع جميع الملفات طي جميع الملفات

55
app/src/Peer.js
عرض الملف

@@ -93,7 +93,7 @@ module.exports = class Peer {
return this.producers.get(producer_id);
}
async createProducer(producerTransportId, rtpParameters, kind, type) {
async createProducer(producerTransportId, producer_rtpParameters, producer_kind, producer_type) {
try {
if (!producerTransportId) {
throw new Error('Invalid producer transport ID');
@@ -105,41 +105,40 @@ module.exports = class Peer {
}
const producer = await producerTransport.produce({
kind,
rtpParameters,
kind: producer_kind,
rtpParameters: producer_rtpParameters,
});
producer.appData.mediaType = type;
const { id, appData, type, rtpParameters } = producer;
this.producers.set(producer.id, producer);
appData.mediaType = producer_type;
const producerType = producer.type;
this.producers.set(id, producer);
if (['simulcast', 'svc'].includes(producerType)) {
const { scalabilityMode } = producer.rtpParameters.encodings[0];
if (['simulcast', 'svc'].includes(type)) {
const { scalabilityMode } = rtpParameters.encodings[0];
const spatialLayer = parseInt(scalabilityMode.substring(1, 2)); // 1/2/3
const temporalLayer = parseInt(scalabilityMode.substring(3, 4)); // 1/2/3
log.debug(`Producer [${producerType}] created with ID ${producer.id}`, {
log.debug(`Producer [${type}] created with ID ${id}`, {
scalabilityMode,
spatialLayer,
temporalLayer,
});
} else {
log.debug(`Producer of type ${producerType} created with ID ${producer.id}`);
log.debug(`Producer of type ${type} created with ID ${id}`);
}
producer.on('transportclose', () => {
log.debug('Producer transport closed', {
peer_name: this.peer_info?.peer_name,
producer_id: producer.id,
producer_id: id,
});
producer.close();
this.producers.delete(producer.id);
this.closeProducer(id);
});
return producer;
} catch (error) {
log.error('Error creating producer', error);
log.error('Error creating producer', error.message);
return null;
}
}
@@ -173,48 +172,48 @@ module.exports = class Peer {
paused: false,
});
const consumerType = consumer.type;
const { id, type, kind, rtpParameters, producerPaused } = consumer;
if (['simulcast', 'svc'].includes(consumerType)) {
const { scalabilityMode } = consumer.rtpParameters.encodings[0];
if (['simulcast', 'svc'].includes(type)) {
const { scalabilityMode } = rtpParameters.encodings[0];
const spatialLayer = parseInt(scalabilityMode.substring(1, 2)); // 1/2/3
const temporalLayer = parseInt(scalabilityMode.substring(3, 4)); // 1/2/3
await consumer.setPreferredLayers({
spatialLayer: spatialLayer,
temporalLayer: temporalLayer,
});
log.debug(`Consumer [${consumerType}] ----->`, {
log.debug(`Consumer [${type}] ----->`, {
scalabilityMode,
spatialLayer,
temporalLayer,
});
} else {
log.debug('Consumer ----->', { type: consumerType });
log.debug('Consumer ----->', { type: type });
}
consumer.on('transportclose', () => {
log.debug('Consumer transport close', {
peer_name: this.peer_info?.peer_name,
consumer_id: consumer.id,
consumer_id: id,
});
this.removeConsumer(consumer.id);
this.removeConsumer(id);
});
this.consumers.set(consumer.id, consumer);
this.consumers.set(id, consumer);
return {
consumer,
params: {
producerId: producer_id,
id: consumer.id,
kind: consumer.kind,
rtpParameters: consumer.rtpParameters,
type: consumer.type,
producerPaused: consumer.producerPaused,
id: id,
kind: kind,
rtpParameters: rtpParameters,
type: type,
producerPaused: producerPaused,
},
};
} catch (error) {
log.error('Error creating consumer', error);
log.error('Error creating consumer', error.message);
return null;
}
}

92
app/src/Room.js
عرض الملف

@@ -102,7 +102,7 @@ module.exports = class Room {
audioVolume: audioVolume,
};
// Uncomment the following line for debugging
// log.debug('Sending audio volume:', data);
// log.debug('Sending audio volume', data);
this.broadCast(0, 'audioVolume', data);
}
});
@@ -110,7 +110,7 @@ module.exports = class Room {
}
}
} catch (error) {
log.error('Error sending active speaker volume', error);
log.error('Error sending active speaker volume', error.message);
}
}
@@ -201,10 +201,11 @@ module.exports = class Room {
const producerList = [];
this.peers.forEach((peer) => {
peer.producers.forEach((producer) => {
const { peer_name, peer_info } = peer;
producerList.push({
producer_id: producer.id,
peer_name: peer.peer_name,
peer_info: peer.peer_info,
peer_name: peer_name,
peer_info: peer_info,
type: producer.appData.mediaType,
});
});
@@ -224,7 +225,7 @@ module.exports = class Room {
await this.peers.get(socket_id).connectTransport(transport_id, dtlsParameters);
} catch (error) {
log.error('Error connecting peer transport', error);
log.error('Error connecting peer transport', error.message);
}
}
@@ -253,34 +254,44 @@ module.exports = class Room {
initialAvailableOutgoingBitrate,
});
const { id, iceParameters, iceCandidates, dtlsParameters } = transport;
if (maxIncomingBitrate) {
await transport.setMaxIncomingBitrate(maxIncomingBitrate);
try {
await transport.setMaxIncomingBitrate(maxIncomingBitrate);
} catch (error) {
log.error('Transport setMaxIncomingBitrate error', error.message);
}
}
const peer = this.peers.get(socket_id);
const { peer_name } = peer;
transport.on('dtlsstatechange', (dtlsState) => {
if (dtlsState === 'closed') {
log.debug('Transport closed', { peer_name: this.peers.get(socket_id)?.peer_name });
log.debug('Transport closed', { peer_name: peer_name });
transport.close();
}
});
transport.on('close', () => {
log.debug('Transport closed', { peer_name: this.peers.get(socket_id)?.peer_name });
log.debug('Transport closed', { peer_name: peer_name });
});
log.debug('Adding transport', { transportId: transport.id });
this.peers.get(socket_id)?.addTransport(transport);
log.debug('Adding transport', { transportId: id });
peer.addTransport(transport);
return {
params: {
id: transport.id,
iceParameters: transport.iceParameters,
iceCandidates: transport.iceCandidates,
dtlsParameters: transport.dtlsParameters,
id: id,
iceParameters: iceParameters,
iceCandidates: iceCandidates,
dtlsParameters: dtlsParameters,
},
};
} catch (error) {
log.error('Error creating WebRTC transport', error);
log.error('Error creating WebRTC transport', error.message);
return null;
}
}
@@ -295,31 +306,35 @@ module.exports = class Room {
throw new Error('Invalid input parameters');
}
const producer = await this.peers
.get(socket_id)
?.createProducer(producerTransportId, rtpParameters, kind, type);
if (!this.peers.has(socket_id)) {
throw new Error(`Invalid socket ID: ${socket_id}`);
}
const peer = this.peers.get(socket_id);
const producer = await peer.createProducer(producerTransportId, rtpParameters, kind, type);
if (!producer) {
throw new Error('Failed to create producer');
}
const peer = this.peers.get(socket_id);
const peerName = peer?.peer_name;
const peerInfo = peer?.peer_info;
const { id } = producer;
const { peer_name, peer_info } = peer;
this.broadCast(socket_id, 'newProducers', [
{
producer_id: producer.id,
producer_id: id,
producer_socket_id: socket_id,
peer_name: peerName,
peer_info: peerInfo,
peer_name: peer_name,
peer_info: peer_info,
type: type,
},
]);
return producer.id;
return id;
} catch (error) {
console.error('Error producing', error);
throw error;
console.error('Error producing', error.message);
throw error.message;
}
}
@@ -342,12 +357,15 @@ module.exports = class Room {
return;
}
const peer = this.peers.get(socket_id);
if (!peer) {
log.warn('Peer not found for socket ID:', socket_id);
if (!this.peers.has(socket_id)) {
log.warn('Peer not found for socket ID', socket_id);
return;
}
const peer = this.peers.get(socket_id);
const { peer_name } = peer;
const result = await peer.createConsumer(consumer_transport_id, producer_id, rtpCapabilities);
if (!result || !result.consumer || !result.params) {
@@ -357,17 +375,19 @@ module.exports = class Room {
const { consumer, params } = result;
const { id, kind } = consumer;
consumer.on('producerclose', () => {
log.debug('Consumer closed due to producerclose event', {
peer_name: this.peers.get(socket_id)?.peer_name,
consumer_id: consumer.id,
peer_name: peer_name,
consumer_id: id,
});
this.peers.get(socket_id)?.removeConsumer(consumer.id);
peer.removeConsumer(id);
// Tell client consumer is dead
this.io.to(socket_id).emit('consumerClosed', {
consumer_id: consumer.id,
consumer_kind: consumer.kind,
consumer_id: id,
consumer_kind: kind,
});
});
@@ -385,7 +405,7 @@ module.exports = class Room {
}
this.peers.get(socket_id).closeProducer(producer_id);
} catch (error) {
log.error('Error closing producer:', error);
log.error('Error closing producer', error.message);
}
}

2
app/src/Server.js
عرض الملف

@@ -41,7 +41,7 @@ dependencies: {
* @license For commercial or closed source, contact us at license.mirotalk@gmail.com or purchase directly via CodeCanyon
* @license CodeCanyon: https://codecanyon.net/item/mirotalk-sfu-webrtc-realtime-video-conferences/40769970
* @author Miroslav Pejic - miroslav.pejic.85@gmail.com
* @version 1.3.85
* @version 1.3.86
*
*/