diff options
author | Sam Wilkins <samwilkins333@gmail.com> | 2019-12-07 18:35:32 -0500 |
---|---|---|
committer | Sam Wilkins <samwilkins333@gmail.com> | 2019-12-07 18:35:32 -0500 |
commit | 304d7f239ae6e7b854a8da1124a919b7ba093b48 (patch) | |
tree | 74e180548ba6eac2064251bf8a84de042da05728 /src/server/Websocket/Websocket.ts | |
parent | fef12d4ca96d35c230a3a5e7c053b9b90eb38243 (diff) |
initial commit
Diffstat (limited to 'src/server/Websocket/Websocket.ts')
-rw-r--r-- | src/server/Websocket/Websocket.ts | 4 |
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); } |