Timer for reloading page

This commit is contained in:
Artyom Abubakirov 2018-08-14 23:34:56 +05:00
parent 1fd2c0d52e
commit 181b51e7de

View File

@ -20,6 +20,7 @@ var socket;
var autoView = true; var autoView = true;
var room; var room;
var timerInterceptor = true;
function onError(msg){ function onError(msg){
console.log(msg); console.log(msg);
@ -43,10 +44,21 @@ $(function() {
console.log('Connected to socket'); console.log('Connected to socket');
socket.emit('subscribeToStream', currentRoom()); socket.emit('subscribeToStream', currentRoom());
// Instant start stream
viewer();
setTimeout(() => {
if(timerInterceptor){
console.log('INTERCEPTOR');
document.location.reload(true);
} else {
console.log('timerInterceptor is false');
}
}, 1000);
}); });
socket.on('disconnect', function(){ socket.on('disconnect', function(data){
console.log('Disconnected from socket'); console.log('Disconnected from socket' + data);
dispose(); dispose();
}); });
@ -55,6 +67,7 @@ $(function() {
}); });
socket.on('viewerResponse', function(data) { socket.on('viewerResponse', function(data) {
console.log('viewerResponse');
viewerResponse(data); viewerResponse(data);
}); });
@ -64,10 +77,13 @@ $(function() {
}); });
socket.on('iceCandidate', function(data) { socket.on('iceCandidate', function(data) {
console.log('iceCandidate');
timerInterceptor = false;
webRtcPeer.addIceCandidate(data.candidate) webRtcPeer.addIceCandidate(data.candidate)
}); });
socket.on('streamStarted', function(data) { socket.on('streamStarted', function(data) {
console.log('streamStarted');
if (autoView) { if (autoView) {
viewer(); viewer();
} }
@ -76,6 +92,10 @@ $(function() {
socket.on('streamEnded', function(data) { socket.on('streamEnded', function(data) {
dispose(); dispose();
}); });
socket.on('ping', function(data) {
console.log('ping');
});
}); });
function presenterResponse(message) { function presenterResponse(message) {
@ -94,6 +114,7 @@ function viewerResponse(message) {
console.warn('Call not accepted for the following reason: ' + errorMsg); console.warn('Call not accepted for the following reason: ' + errorMsg);
dispose(); dispose();
} else { } else {
console.log('processAnswer');
webRtcPeer.processAnswer(message.sdpAnswer); webRtcPeer.processAnswer(message.sdpAnswer);
} }
} }
@ -129,6 +150,7 @@ function onOfferPresenter(error, offerSdp) {
function viewer() { function viewer() {
autoView = true; autoView = true;
if (!webRtcPeer) { if (!webRtcPeer) {
console.log('viewer webRrcPeer');
showSpinner(video); showSpinner(video);
var options = { var options = {
@ -151,11 +173,15 @@ function onOfferViewer(error, offerSdp) {
sdpOffer : offerSdp, sdpOffer : offerSdp,
room: currentRoom() room: currentRoom()
}; };
console.log('onOfferVIewer');
socket.emit('viewer', message); socket.emit('viewer', message);
console.log(socket);
console.log(message);
} }
function onIceCandidate(candidate) { function onIceCandidate(candidate) {
//console.log('Local candidate' + JSON.stringify(candidate)); //console.log('Local candidate' + JSON.stringify(candidate));
console.log(candidate);
socket.emit('onIceCandidate', {candidate : candidate}); socket.emit('onIceCandidate', {candidate : candidate});
} }