60 lines
1.9 KiB
TypeScript
60 lines
1.9 KiB
TypeScript
import {ExSocketInterface} from "_Model/Websocket/ExSocketInterface";
|
|
import {BatchMessage, ErrorMessage, ServerToClientMessage, SubMessage} from "../Messages/generated/messages_pb";
|
|
|
|
export function emitInBatch(socket: ExSocketInterface, payload: SubMessage): void {
|
|
socket.batchedMessages.addPayload(payload);
|
|
|
|
if (socket.batchTimeout === null) {
|
|
socket.batchTimeout = setTimeout(() => {
|
|
if (socket.disconnecting) {
|
|
return;
|
|
}
|
|
|
|
const serverToClientMessage = new ServerToClientMessage();
|
|
serverToClientMessage.setBatchmessage(socket.batchedMessages);
|
|
|
|
socket.send(serverToClientMessage.serializeBinary().buffer, true);
|
|
socket.batchedMessages = new BatchMessage();
|
|
socket.batchTimeout = null;
|
|
}, 100);
|
|
}
|
|
|
|
// If we send a message, we don't need to keep the connection alive
|
|
resetPing(socket);
|
|
}
|
|
|
|
export function resetPing(ws: ExSocketInterface): void {
|
|
if (ws.pingTimeout) {
|
|
clearTimeout(ws.pingTimeout);
|
|
}
|
|
ws.pingTimeout = setTimeout(() => {
|
|
if (ws.disconnecting) {
|
|
return;
|
|
}
|
|
ws.ping();
|
|
resetPing(ws);
|
|
}, 29000);
|
|
}
|
|
|
|
export function emitError(Client: ExSocketInterface, message: string): void {
|
|
const errorMessage = new ErrorMessage();
|
|
errorMessage.setMessage(message);
|
|
|
|
const serverToClientMessage = new ServerToClientMessage();
|
|
serverToClientMessage.setErrormessage(errorMessage);
|
|
|
|
if (!Client.disconnecting) {
|
|
Client.send(serverToClientMessage.serializeBinary().buffer, true);
|
|
}
|
|
console.warn(message);
|
|
}
|
|
|
|
export const pongMaxInterval = 30000; // the maximum duration (in ms) between pongs before we shutdown the connexion.
|
|
|
|
export function refresLogoutTimerOnPong(ws: ExSocketInterface): void {
|
|
if(ws.pongTimeout) clearTimeout(ws.pongTimeout);
|
|
ws.pongTimeout = setTimeout(() => {
|
|
ws.close();
|
|
}, pongMaxInterval);
|
|
}
|