Update videoSyncServerScript.js
This commit is contained in:
parent
55b74bcb48
commit
353b82b436
@ -27,12 +27,23 @@
|
|||||||
var UserData = JSON.parse(entityUserData.userData);
|
var UserData = JSON.parse(entityUserData.userData);
|
||||||
ws = new WebSocket(wsUrl);
|
ws = new WebSocket(wsUrl);
|
||||||
ws.onopen = function () {
|
ws.onopen = function () {
|
||||||
|
var isLocked = Entities.getEntityProperties(videoPlayerChannel, ["locked"]);
|
||||||
|
if (isLocked) {
|
||||||
|
Entities.editEntity(videoPlayerChannel, {
|
||||||
|
locked: false
|
||||||
|
});
|
||||||
|
}
|
||||||
gatewayServerConnected = true;
|
gatewayServerConnected = true;
|
||||||
connectionAttempts = 0;
|
connectionAttempts = 0;
|
||||||
UserData.serverConnected = true;
|
UserData.serverConnected = true;
|
||||||
Entities.editEntity(videoPlayerChannel, {
|
Entities.editEntity(videoPlayerChannel, {
|
||||||
userData: JSON.stringify(UserData)
|
userData: JSON.stringify(UserData)
|
||||||
});
|
});
|
||||||
|
if (isLocked) {
|
||||||
|
Entities.editEntity(videoPlayerChannel, {
|
||||||
|
locked: true
|
||||||
|
});
|
||||||
|
}
|
||||||
}
|
}
|
||||||
ws.onmessage = function (evt) {
|
ws.onmessage = function (evt) {
|
||||||
var wsMessageData = JSON.parse(evt.data);
|
var wsMessageData = JSON.parse(evt.data);
|
||||||
@ -49,16 +60,33 @@
|
|||||||
}
|
}
|
||||||
}
|
}
|
||||||
ws.onclose = function () {
|
ws.onclose = function () {
|
||||||
|
var isLocked = Entities.getEntityProperties(videoPlayerChannel, ["locked"]);
|
||||||
|
if (isLocked) {
|
||||||
|
Entities.editEntity(videoPlayerChannel, {
|
||||||
|
locked: false
|
||||||
|
});
|
||||||
|
}
|
||||||
gatewayServerConnected = false;
|
gatewayServerConnected = false;
|
||||||
UserData.serverConnected = false;
|
UserData.serverConnected = false;
|
||||||
Entities.editEntity(videoPlayerChannel, {
|
Entities.editEntity(videoPlayerChannel, {
|
||||||
userData: JSON.stringify(UserData)
|
userData: JSON.stringify(UserData)
|
||||||
});
|
});
|
||||||
|
if (isLocked) {
|
||||||
|
Entities.editEntity(videoPlayerChannel, {
|
||||||
|
locked: true
|
||||||
|
});
|
||||||
|
}
|
||||||
if (useGatewayServer) {
|
if (useGatewayServer) {
|
||||||
Script.setTimeout(function () {
|
Script.setTimeout(function () {
|
||||||
connectionAttempts++;
|
connectionAttempts++;
|
||||||
openWebSocket();
|
openWebSocket();
|
||||||
if (connectionAttempts >= 5) {
|
if (connectionAttempts >= 5) {
|
||||||
|
var isLocked = Entities.getEntityProperties(videoPlayerChannel, ["locked"]);
|
||||||
|
if (isLocked) {
|
||||||
|
Entities.editEntity(videoPlayerChannel, {
|
||||||
|
locked: false
|
||||||
|
});
|
||||||
|
}
|
||||||
useGatewayServer = false;
|
useGatewayServer = false;
|
||||||
gatewayUserData = {
|
gatewayUserData = {
|
||||||
"useGatewayServer": false,
|
"useGatewayServer": false,
|
||||||
@ -69,6 +97,11 @@
|
|||||||
Entities.editEntity(videoPlayerChannel, {
|
Entities.editEntity(videoPlayerChannel, {
|
||||||
userData: JSON.stringify(gatewayUserData)
|
userData: JSON.stringify(gatewayUserData)
|
||||||
});
|
});
|
||||||
|
if (isLocked) {
|
||||||
|
Entities.editEntity(videoPlayerChannel, {
|
||||||
|
locked: true
|
||||||
|
});
|
||||||
|
}
|
||||||
}, 6000);
|
}, 6000);
|
||||||
}
|
}
|
||||||
}, 1000);
|
}, 1000);
|
||||||
@ -122,7 +155,8 @@
|
|||||||
videoPlaying = true;
|
videoPlaying = true;
|
||||||
ping();
|
ping();
|
||||||
var wsPlay = {
|
var wsPlay = {
|
||||||
"action": "play"
|
"action": "play",
|
||||||
|
"timeStamp": messageData.timeStamp
|
||||||
};
|
};
|
||||||
if (useGatewayServer && gatewayServerConnected) {
|
if (useGatewayServer && gatewayServerConnected) {
|
||||||
ws.send(JSON.stringify(wsPlay));
|
ws.send(JSON.stringify(wsPlay));
|
||||||
@ -131,7 +165,8 @@
|
|||||||
Script.clearInterval(timeStampInterval);
|
Script.clearInterval(timeStampInterval);
|
||||||
intervalIsRunning = false;
|
intervalIsRunning = false;
|
||||||
var wsPause = {
|
var wsPause = {
|
||||||
"action": "pause"
|
"action": "pause",
|
||||||
|
"timeStamp": messageData.timeStamp
|
||||||
};
|
};
|
||||||
if (useGatewayServer && gatewayServerConnected) {
|
if (useGatewayServer && gatewayServerConnected) {
|
||||||
ws.send(JSON.stringify(wsPause));
|
ws.send(JSON.stringify(wsPause));
|
||||||
|
Loading…
x
Reference in New Issue
Block a user