Added socket id to createWebRtcTransport
This commit is contained in:
parent
c1fe524ec7
commit
4b0c06e0b0
8
app.js
8
app.js
@ -226,7 +226,7 @@ peers.on('connection', async socket => {
|
||||
socket.on('createWebRtcTransport', async ({ sender }, callback) => {
|
||||
try {
|
||||
const callId = socketDetails[socket.id];
|
||||
console.log(`[createWebRtcTransport] sender ${sender} | callId ${callId}`);
|
||||
console.log(`[createWebRtcTransport] socket ${socket.id} | sender ${sender} | callId ${callId}`);
|
||||
if (sender) {
|
||||
if(!videoCalls[callId].receiverProducerTransport && !isInitiator(callId, socket.id)) {
|
||||
videoCalls[callId].receiverProducerTransport = await createWebRtcTransportLayer(callId, callback);
|
||||
@ -258,7 +258,7 @@ peers.on('connection', async socket => {
|
||||
const callId = socketDetails[socket.id];
|
||||
if (typeof dtlsParameters === 'string') dtlsParameters = JSON.parse(dtlsParameters);
|
||||
|
||||
console.log(`[transport-connect] socket.id ${socket.id} | callId ${callId}`);
|
||||
console.log(`[transport-connect] socket ${socket.id} | callId ${callId}`);
|
||||
if (!isInitiator(callId, socket.id)) {
|
||||
await videoCalls[callId].receiverProducerTransport.connect({ dtlsParameters });
|
||||
} else {
|
||||
@ -279,7 +279,7 @@ peers.on('connection', async socket => {
|
||||
const callId = socketDetails[socket.id];
|
||||
if (typeof rtpParameters === 'string') rtpParameters = JSON.parse(rtpParameters);
|
||||
|
||||
console.log(`[transport-produce] kind: ${kind} | socket.id: ${socket.id} | callId: ${callId}`);
|
||||
console.log(`[transport-produce] kind: ${kind} | socket: ${socket.id} | callId: ${callId}`);
|
||||
if (kind === 'video') {
|
||||
if (!isInitiator(callId, socket.id)) {
|
||||
videoCalls[callId].receiverVideoProducer = await videoCalls[callId].receiverProducerTransport.produce({
|
||||
@ -368,7 +368,7 @@ peers.on('connection', async socket => {
|
||||
socket.on('transport-recv-connect', async ({ dtlsParameters }) => {
|
||||
try {
|
||||
const callId = socketDetails[socket.id];
|
||||
console.log(`[transport-recv-connect] socket.id ${socket.id} | callId ${callId}`);
|
||||
console.log(`[transport-recv-connect] socket ${socket.id} | callId ${callId}`);
|
||||
// await videoCalls[callId].consumerTransport.connect({ dtlsParameters });
|
||||
if(!isInitiator(callId, socket.id)) {
|
||||
await videoCalls[callId].receiverConsumerTransport.connect({ dtlsParameters });
|
||||
|
Loading…
Reference in New Issue
Block a user