Compare commits

..

No commits in common. "1d7c994036ccb52afa99a0a98837a72e1dc3d6b8" and "cdbfc7891d4e7841006fa08f27fa724aa9ccb341" have entirely different histories.

2 changed files with 68 additions and 70 deletions

View File

@ -20373,10 +20373,7 @@ console.log('[URL] ASSET_ID', ASSET_ID, '| ACCOUNT_ID', ACCOUNT_ID, '| callId',
console.log('🟩 config', config) console.log('🟩 config', config)
let socket let socket
hub = io(config.hubAddress)
setTimeout(() => {
hub = io(config.hubAddress)
}, 2000);
const connectToMediasoup = () => { const connectToMediasoup = () => {
@ -20398,39 +20395,41 @@ const connectToMediasoup = () => {
} }
if (IS_PRODUCER === true) { if (IS_PRODUCER === true) {
hub.on('connect', async () => { setTimeout(() => {
console.log(`[HUB]! ${config.hubAddress} | connected: ${hub.connected}`) hub.on('connect', async () => {
connectToMediasoup() console.log(`[HUB]! ${config.hubAddress} | connected: ${hub.connected}`)
connectToMediasoup()
hub.emit( hub.emit(
'ars', 'ars',
JSON.stringify({ JSON.stringify({
ars: true, ars: true,
asset_id: ASSET_ID, asset_id: ASSET_ID,
account_id: ACCOUNT_ID, account_id: ACCOUNT_ID,
})
)
hub.on('video', (data) => {
const parsedData = JSON.parse(data);
if (parsedData.type === 'notify-request') {
console.log('video', parsedData)
originAssetId = parsedData.origin_asset_id;
// originAssetName = parsedData.origin_asset_name;
// originAssetTypeName = parsedData.origin_asset_type_name;
callId = parsedData.video_call_id;
console.log('[VIDEO] notify-request | IS_PRODUCER', IS_PRODUCER, 'callId', callId);
getLocalStream()
}
if (parsedData.type === 'notify-end') {
console.log('[VIDEO] notify-end | IS_PRODUCER', IS_PRODUCER, 'callId', callId);
resetCallSettings()
}
}) })
)
hub.on('video', (data) => {
const parsedData = JSON.parse(data);
if (parsedData.type === 'notify-request') {
console.log('video', parsedData)
originAssetId = parsedData.origin_asset_id;
// originAssetName = parsedData.origin_asset_name;
// originAssetTypeName = parsedData.origin_asset_type_name;
callId = parsedData.video_call_id;
console.log('[VIDEO] notify-request | IS_PRODUCER', IS_PRODUCER, 'callId', callId);
getLocalStream()
}
if (parsedData.type === 'notify-end') {
console.log('[VIDEO] notify-end | IS_PRODUCER', IS_PRODUCER, 'callId', callId);
resetCallSettings()
}
}) })
}) }, 2000);
hub.on('connect_error', (error) => { hub.on('connect_error', (error) => {
console.log('connect_error', error); console.log('connect_error', error);

View File

@ -15,10 +15,7 @@ console.log('[URL] ASSET_ID', ASSET_ID, '| ACCOUNT_ID', ACCOUNT_ID, '| callId',
console.log('🟩 config', config) console.log('🟩 config', config)
let socket let socket
hub = io(config.hubAddress)
setTimeout(() => {
hub = io(config.hubAddress)
}, 2000);
const connectToMediasoup = () => { const connectToMediasoup = () => {
@ -40,39 +37,41 @@ const connectToMediasoup = () => {
} }
if (IS_PRODUCER === true) { if (IS_PRODUCER === true) {
hub.on('connect', async () => { setTimeout(() => {
console.log(`[HUB]! ${config.hubAddress} | connected: ${hub.connected}`) hub.on('connect', async () => {
connectToMediasoup() console.log(`[HUB]! ${config.hubAddress} | connected: ${hub.connected}`)
connectToMediasoup()
hub.emit( hub.emit(
'ars', 'ars',
JSON.stringify({ JSON.stringify({
ars: true, ars: true,
asset_id: ASSET_ID, asset_id: ASSET_ID,
account_id: ACCOUNT_ID, account_id: ACCOUNT_ID,
})
)
hub.on('video', (data) => {
const parsedData = JSON.parse(data);
if (parsedData.type === 'notify-request') {
console.log('video', parsedData)
originAssetId = parsedData.origin_asset_id;
// originAssetName = parsedData.origin_asset_name;
// originAssetTypeName = parsedData.origin_asset_type_name;
callId = parsedData.video_call_id;
console.log('[VIDEO] notify-request | IS_PRODUCER', IS_PRODUCER, 'callId', callId);
getLocalStream()
}
if (parsedData.type === 'notify-end') {
console.log('[VIDEO] notify-end | IS_PRODUCER', IS_PRODUCER, 'callId', callId);
resetCallSettings()
}
}) })
)
hub.on('video', (data) => {
const parsedData = JSON.parse(data);
if (parsedData.type === 'notify-request') {
console.log('video', parsedData)
originAssetId = parsedData.origin_asset_id;
// originAssetName = parsedData.origin_asset_name;
// originAssetTypeName = parsedData.origin_asset_type_name;
callId = parsedData.video_call_id;
console.log('[VIDEO] notify-request | IS_PRODUCER', IS_PRODUCER, 'callId', callId);
getLocalStream()
}
if (parsedData.type === 'notify-end') {
console.log('[VIDEO] notify-end | IS_PRODUCER', IS_PRODUCER, 'callId', callId);
resetCallSettings()
}
}) })
}) }, 2000);
hub.on('connect_error', (error) => { hub.on('connect_error', (error) => {
console.log('connect_error', error); console.log('connect_error', error);