Mizah/Sharkey
1
0
Fork 0
Code Issues Pull requests Actions Packages Projects Releases Wiki Activity

Added heartbeat handler.

Browse source
This commit is contained in:
Werner Kroneman 2024-12-08 17:50:34 +01:00
parent d0cb08c2df
commit 2ead42c00b
1 changed files with 10 additions and 1 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

11
packages/backend/src/server/api/stream/Connection.ts
View file

@ -161,10 +161,19 @@ export default class Connection {
case 'disconnect': this.onChannelDisconnectRequested(body); break; case 'disconnect': this.onChannelDisconnectRequested(body); break;
case 'channel': this.onChannelMessageRequested(body); break; case 'channel': this.onChannelMessageRequested(body); break;
case 'ch': this.onChannelMessageRequested(body); break; // alias case 'ch': this.onChannelMessageRequested(body); break; // alias
case 'h': this.wsConnection.send('h'); break; // heartbeat response case 'hb': this.onHeartbeat(body); break;
} }
} }
@bindThis
private onHeartbeat(data: JsonValue | undefined) {
if (!isJsonObject(data)) {
console.error('Received invalid heartbeat payload: ', data);
return;
}
this.sendMessageToWs('hb', data);
}
@bindThis @bindThis
private onBroadcastMessage(data: GlobalEvents['broadcast']['payload']) { private onBroadcastMessage(data: GlobalEvents['broadcast']['payload']) {
this.sendMessageToWs(data.type, data.body); this.sendMessageToWs(data.type, data.body);