sjw/MovieNight
1
0
Fork 0
Code Issues Pull Requests Releases Wiki Activity

Added reconnecting when websocket connection closes or errors

Browse Source 
resolves #38
This commit is contained in:
joeyak 2019-03-22 23:32:52 -04:00
parent bdfa75f8bc
commit a480c51454
1 changed files with 29 additions and 4 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

33
static/js/chat.js
View File

@ -89,7 +89,11 @@ function join() {
} }
function websocketSend(data) { function websocketSend(data) {
ws.send(data); if (ws.readyState == ws.OPEN) {
ws.send(data);
} else {
console.log("did not send data because websocket is not open", data);
}
} }
function sendChat() { function sendChat() {
@ -126,13 +130,34 @@ function help() {
sendMessage("/help"); sendMessage("/help");
} }
reconnectCount = 0
// Get the websocket setup in a function so it can be recalled // Get the websocket setup in a function so it can be recalled
function setupWebSocket() { function setupWebSocket() {
ws = new WebSocket(getWsUri()); ws = new WebSocket(getWsUri());
ws.onmessage = (m) => recieveMessage(m.data); ws.onmessage = (m) => recieveMessage(m.data);
ws.onopen = (e) => console.log("Websocket Open:", e); ws.onopen = () => console.log("Websocket Open");
ws.onclose = () => closeChat(); ws.onclose = () => {
ws.onerror = (e) => console.log("Websocket Error:", e); closeChat();
reconnectCount++
setNotifyBox("Something went wrong with the connection. Trying to reconnect " + reconnectCount + ".");
if (reconnectCount <= 5) {
setTimeout(() => {
setupWebSocket();
setTimeout(() => {
if (ws.readyState == ws.OPEN) {
join();
reconnectCount = 0;
}
}, 2000);
}, 2000);
} else {
setNotifyBox("Tried to reconnect " + reconnectCount + " times. Please refresh page or contact admin.")
}
}
ws.onerror = (e) => {
console.log("Websocket Error:", e);
e.target.close();
}
} }
function setupEvents() { function setupEvents() {