aboutsummaryrefslogtreecommitdiff
path: root/src/server/Websocket/Websocket.ts
diff options
context:
space:
mode:
authorBob Zeleznik <zzzman@gmail.com>2019-12-08 22:32:31 -0500
committerBob Zeleznik <zzzman@gmail.com>2019-12-08 22:32:31 -0500
commitcfaf02757f5aebd2ccce0bbef8b6f5e232932693 (patch)
tree021efc9779dc329e4e9ba94ac74eb6ef7e9dcb20 /src/server/Websocket/Websocket.ts
parent6c28c3f00e5072b75a5d38da49a234cf347c6605 (diff)
parentc3e0c3e7faf374a0d1b75c77d4f40abd7aec3a1f (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.ts11
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);
}