diff options
author | Sam Wilkins <samwilkins333@gmail.com> | 2019-12-03 15:32:52 -0500 |
---|---|---|
committer | Sam Wilkins <samwilkins333@gmail.com> | 2019-12-03 15:32:52 -0500 |
commit | 6b29c8177dae43f5d6a4ccdc2ca5dfc6f60e83eb (patch) | |
tree | 931a699f35a380b630f0977b7dbaef51d72cbe73 /src/server/Websocket/Websocket.ts | |
parent | 7866dd1700d6a3457e0f0255428ee42e5c7d8ff9 (diff) |
close connections before exit
Diffstat (limited to 'src/server/Websocket/Websocket.ts')
-rw-r--r-- | src/server/Websocket/Websocket.ts | 3 |
1 files changed, 2 insertions, 1 deletions
diff --git a/src/server/Websocket/Websocket.ts b/src/server/Websocket/Websocket.ts index 2eb764945..60c34aa44 100644 --- a/src/server/Websocket/Websocket.ts +++ b/src/server/Websocket/Websocket.ts @@ -7,7 +7,7 @@ import { Search } from "../Search"; import * as io from 'socket.io'; import YoutubeApi from "../apis/youtube/youtubeApiSample"; import { GoogleCredentialsLoader } from "../credentials/CredentialsLoader"; -import { logPort } from "../ActionUtilities"; +import { logPort, addBeforeExitHandler } from "../ActionUtilities"; import { timeMap } from "../ApiManagers/UserManager"; import { green } from "colors"; @@ -53,6 +53,7 @@ export namespace WebSocket { Utils.AddServerHandlerCallback(socket, MessageStore.GetRefField, GetRefField); Utils.AddServerHandlerCallback(socket, MessageStore.GetRefFields, GetRefFields); }); + addBeforeExitHandler(async () => { await new Promise<void>(resolve => endpoint.close(resolve)); }); endpoint.listen(socketPort); logPort("websocket", socketPort); } |