move most of the logic of IOSocketController into a dedicated class

back/src/Services/IoSocketHelpers.ts

@@ -0,0 +1,50 @@
+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);
+}