diff options
author | Bob Zeleznik <zzzman@gmail.com> | 2019-12-08 22:32:31 -0500 |
---|---|---|
committer | Bob Zeleznik <zzzman@gmail.com> | 2019-12-08 22:32:31 -0500 |
commit | cfaf02757f5aebd2ccce0bbef8b6f5e232932693 (patch) | |
tree | 021efc9779dc329e4e9ba94ac74eb6ef7e9dcb20 /src/server/Websocket/Websocket.ts | |
parent | 6c28c3f00e5072b75a5d38da49a234cf347c6605 (diff) | |
parent | c3e0c3e7faf374a0d1b75c77d4f40abd7aec3a1f (diff) |
Merge branch 'master' of https://github.com/browngraphicslab/Dash-Web
Diffstat (limited to 'src/server/Websocket/Websocket.ts')
-rw-r--r-- | src/server/Websocket/Websocket.ts | 11 |
1 files changed, 8 insertions, 3 deletions
diff --git a/src/server/Websocket/Websocket.ts b/src/server/Websocket/Websocket.ts index f65cc235c..5c0bb508b 100644 --- a/src/server/Websocket/Websocket.ts +++ b/src/server/Websocket/Websocket.ts @@ -7,15 +7,16 @@ import { Search } from "../Search"; import * as io from 'socket.io'; import YoutubeApi from "../apis/youtube/youtubeApiSample"; import { GoogleCredentialsLoader } from "../credentials/CredentialsLoader"; -import { logPort, addBeforeExitHandler } from "../ActionUtilities"; +import { logPort } from "../ActionUtilities"; import { timeMap } from "../ApiManagers/UserManager"; import { green } from "colors"; -import { ExitHandlers } from ".."; +import { SolrManager } from "../ApiManagers/SearchManager"; export namespace WebSocket { const clients: { [key: string]: Client } = {}; export const socketMap = new Map<SocketIO.Socket, string>(); + export let disconnect: Function; export async function start(serverPort: number, isRelease: boolean) { await preliminaryFunctions(); @@ -54,8 +55,12 @@ export namespace WebSocket { Utils.AddServerHandlerCallback(socket, MessageStore.GetRefField, GetRefField); Utils.AddServerHandlerCallback(socket, MessageStore.GetRefFields, GetRefFields); - ExitHandlers.push(() => socket.broadcast.emit("connection_terminated", Date.now())); + disconnect = () => { + socket.broadcast.emit("connection_terminated", Date.now()); + socket.disconnect(true); + }; }); + endpoint.listen(socketPort); logPort("websocket", socketPort); } |