sergiu/hub-video-tester
0
0
Fork 0
Code Issues Pull Requests Releases Wiki Activity

Update callId update

Browse Source
This commit is contained in:
Sergiu Toma 2021-02-17 14:12:27 +02:00
parent 20fd681242
commit 2c13b988f3
1 changed files with 3 additions and 19 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

22
src/App.js
View File

@ -135,13 +135,11 @@ class App extends Component {
// HUB 'video' event handler // HUB 'video' event handler
socket.on('video', async (data) => { socket.on('video', async (data) => {
const parseData = JSON.parse(data); const parseData = JSON.parse(data);
console.log('[VIDEO]', parseData);
if(parseData.type === 'notify-request') { if(parseData.type === 'notify-request') {
console.log('[NOTIFY-REQUEST]', parseData);
await pc.setLocalDescription(await pc.createOffer()) await pc.setLocalDescription(await pc.createOffer())
console.log('IIIIIIIIIIIIIIIIIIIIIIIII', this.state.callId);
socket.emit('video', JSON.stringify({ socket.emit('video', JSON.stringify({
origin_asset_id: this.state.user.asset.id, origin_asset_id: this.state.user.asset.id,
dest_asset_id: parseInt(parseData.origin_asset_id), dest_asset_id: parseInt(parseData.origin_asset_id),
@ -164,7 +162,6 @@ class App extends Component {
console.log('[ANSWER]'); console.log('[ANSWER]');
await pc.setRemoteDescription(parseData.sdp) await pc.setRemoteDescription(parseData.sdp)
pc.onicecandidate = ({candidate}) => { pc.onicecandidate = ({candidate}) => {
console.log('candidate1', candidate);
this.state.socket.emit('video', JSON.stringify({ this.state.socket.emit('video', JSON.stringify({
type: 'candidate', type: 'candidate',
candidate, candidate,
@ -175,9 +172,7 @@ class App extends Component {
} }
} }
} else if(parseData.type === 'candidate') { } else if(parseData.type === 'candidate') {
console.log('candidate parseData', parseData);
if(parseData.candidate) { if(parseData.candidate) {
console.log('parseData.candidate', parseData.candidate)
pc.addIceCandidate(parseData.candidate).catch(e => {console.log(e)}) pc.addIceCandidate(parseData.candidate).catch(e => {console.log(e)})
} }
} }
@ -190,28 +185,21 @@ class App extends Component {
} }
offerReceived = async (offer) => { offerReceived = async (offer) => {
console.log('Received offer', offer)
await pc.setRemoteDescription(offer.sdp) await pc.setRemoteDescription(offer.sdp)
pc.onicecandidate = ({candidate}) => { pc.onicecandidate = ({candidate}) => {
console.log('IIIIIIIIIIIIIIIIIIIIIIIII2', this.state.callId);
this.state.socket.emit('video', JSON.stringify({ this.state.socket.emit('video', JSON.stringify({
type: 'candidate', type: 'candidate',
candidate: candidate, candidate: candidate,
dest_asset_id: parseInt(this.state.dest_asset_id), dest_asset_id: parseInt(this.state.dest_asset_id),
video_call_id: this.state.callId, video_call_id: this.state.callId
test: '1111111111'
})); }));
} }
await pc.setLocalDescription(await pc.createAnswer()) await pc.setLocalDescription(await pc.createAnswer())
pc.onnegotiationneeded = async () => { pc.onnegotiationneeded = async () => {
console.log('---------onnegotiationneeded--------');
try { try {
console.log('IIIIIIIIIIIIIIIIIIIIIIIII3', this.state.callId);
await pc.setLocalDescription(await pc.createOffer()); await pc.setLocalDescription(await pc.createOffer());
// socket.emit('signal', {destination:remoteUser, data:pc.localDescription}) // socket.emit('signal', {destination:remoteUser, data:pc.localDescription})
socket.emit('video', JSON.stringify({ socket.emit('video', JSON.stringify({
@ -228,7 +216,6 @@ class App extends Component {
console.error(err); console.error(err);
} }
}; };
console.log('IIIIIIIIIIIIIIIIIIIIIIIII4', this.state.callId);
this.state.socket.emit('video', JSON.stringify({ this.state.socket.emit('video', JSON.stringify({
origin_asset_id: this.state.user.asset.id, origin_asset_id: this.state.user.asset.id,
dest_asset_id: parseInt(this.state.dest_asset_id), dest_asset_id: parseInt(this.state.dest_asset_id),
@ -239,7 +226,6 @@ class App extends Component {
video_call_id: this.state.callId, video_call_id: this.state.callId,
sdp: pc.localDescription sdp: pc.localDescription
})); }));
console.log('---------onnegotiationneeded END--------');
} }
handleChangeLogin = (e) => { handleChangeLogin = (e) => {
@ -271,7 +257,6 @@ class App extends Component {
} }
handleClickEvent = () => { handleClickEvent = () => {
console.log('IIIIIIIIIIIIIIIIIIIIIIIII6', this.state.callId);
this.state.socket.emit('video', JSON.stringify({ this.state.socket.emit('video', JSON.stringify({
origin_asset_id: this.state.user.asset.id, origin_asset_id: this.state.user.asset.id,
dest_asset_id: parseInt(this.state.dest_asset_id), dest_asset_id: parseInt(this.state.dest_asset_id),
@ -291,7 +276,6 @@ class App extends Component {
} }
closeVideo = () => { closeVideo = () => {
console.log('IIIIIIIIIIIIIIIIIIIIIIIII7', this.state.callId);
this.state.socket.emit('video', JSON.stringify({ this.state.socket.emit('video', JSON.stringify({
origin_asset_id: this.state.user.asset.id, origin_asset_id: this.state.user.asset.id,
dest_asset_id: parseInt(this.state.dest_asset_id), dest_asset_id: parseInt(this.state.dest_asset_id),