aboutsummaryrefslogtreecommitdiff
path: root/src/server/Websocket/Websocket.ts
diff options
context:
space:
mode:
authorSam Wilkins <samwilkins333@gmail.com>2019-12-07 18:35:32 -0500
committerSam Wilkins <samwilkins333@gmail.com>2019-12-07 18:35:32 -0500
commit304d7f239ae6e7b854a8da1124a919b7ba093b48 (patch)
tree74e180548ba6eac2064251bf8a84de042da05728 /src/server/Websocket/Websocket.ts
parentfef12d4ca96d35c230a3a5e7c053b9b90eb38243 (diff)
initial commit
Diffstat (limited to 'src/server/Websocket/Websocket.ts')
-rw-r--r--src/server/Websocket/Websocket.ts4
1 files changed, 3 insertions, 1 deletions
diff --git a/src/server/Websocket/Websocket.ts b/src/server/Websocket/Websocket.ts
index 60c34aa44..de1d5eb25 100644
--- a/src/server/Websocket/Websocket.ts
+++ b/src/server/Websocket/Websocket.ts
@@ -10,6 +10,7 @@ import { GoogleCredentialsLoader } from "../credentials/CredentialsLoader";
import { logPort, addBeforeExitHandler } from "../ActionUtilities";
import { timeMap } from "../ApiManagers/UserManager";
import { green } from "colors";
+import { ExitHandlers } from "..";
export namespace WebSocket {
@@ -52,8 +53,9 @@ export namespace WebSocket {
Utils.AddServerHandler(socket, MessageStore.DeleteFields, ids => DeleteFields(socket, ids));
Utils.AddServerHandlerCallback(socket, MessageStore.GetRefField, GetRefField);
Utils.AddServerHandlerCallback(socket, MessageStore.GetRefFields, GetRefFields);
+
+ ExitHandlers.push(() => socket.broadcast.emit("connection_terminated", Date.now()));
});
- addBeforeExitHandler(async () => { await new Promise<void>(resolve => endpoint.close(resolve)); });
endpoint.listen(socketPort);
logPort("websocket", socketPort);
}