coastercast
/
Buzzer
2
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

Migrate to "robust-websocket" to have more stable reconnect.

This commit is contained in:
Oliver Rümpelein 2021-11-07 12:59:23 +01:00
parent 45e07d9393
commit 45f67d2cdf
3 changed files with 3 additions and 27 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

1
src/main/kotlin/de/pheerai/buzzer/clients/gameMasterClient.kt
View File

@ -21,6 +21,7 @@ fun HTML.createGameMasterDocument() {
src = "https://unpkg.com/alpinejs@3.x.x/dist/cdn.min.js"
defer = true
}
script { src = "https://unpkg.com/robust-websocket@1.0.0/robust-websocket.js" }
script { src = "/assets/buzzerWebSocket.js" }
}
body {

1
src/main/kotlin/de/pheerai/buzzer/clients/playerClient.kt
View File

@ -21,6 +21,7 @@ fun HTML.createPlayerDocument() {
src = "https://unpkg.com/alpinejs@3.x.x/dist/cdn.min.js"
defer = true
}
script { src = "https://unpkg.com/robust-websocket@1.0.0/robust-websocket.js" }
script {
src = "/assets/buzzerWebSocket.js"
}

28
src/main/resources/js/buzzerWebSocket.js
View File

@ -2,33 +2,7 @@
function startWebSocket(socketPath, messageHandler) {
const protocolPrefix = (window.location.protocol === 'https:') ? 'wss:' : 'ws:';
const webSocket = new WebSocket(`${protocolPrefix}//${location.host}${socketPath}`);
webSocket.onerror = (ev) => {
switch (ev.code) {
case 1000:
console.log("[WS]: Closed normally")
break
default:
console.log("[WS]: Closed abnormally")
reconnectWebSocket(socketPath, messageHandler);
}
};
webSocket.onclose = (ev) => {
switch (ev.code) {
case 'ECONNREFUSED':
reconnectWebSocket(socketPath, messageHandler);
break
default:
webSocket.onerror(ev);
}
};
const webSocket = new RobustWebSocket(`${protocolPrefix}//${location.host}${socketPath}`);
webSocket.onmessage = messageHandler ? messageHandler : () => {};
Alpine.data.buzzerWebSocket = webSocket
}
function reconnectWebSocket(socketPath, messageHandler) {
setTimeout(() => {
console.log("[WS]: Reconnecting...")
startWebSocket(socketPath, messageHandler)
}, 2000)
}