diff options
author | bob <bcz@cs.brown.edu> | 2020-01-06 09:42:11 -0500 |
---|---|---|
committer | bob <bcz@cs.brown.edu> | 2020-01-06 09:42:11 -0500 |
commit | df12bd5432f24796de25f9aa85e278eae944edf7 (patch) | |
tree | a3d4916891e0b6860e18c547cbdb23fcb620e947 /src/server/Websocket/Websocket.ts | |
parent | 8ae1d973896f8629e5d2030f756b7b63df530ad2 (diff) | |
parent | e4d9fd09f6ede20e79d58119d239bb7a3a7dae25 (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 | 10 |
1 files changed, 7 insertions, 3 deletions
diff --git a/src/server/Websocket/Websocket.ts b/src/server/Websocket/Websocket.ts index e1e157fc4..578147d60 100644 --- a/src/server/Websocket/Websocket.ts +++ b/src/server/Websocket/Websocket.ts @@ -13,21 +13,24 @@ import { green } from "colors"; export namespace WebSocket { + export let _socket: Socket; 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) { + export async function start(isRelease: boolean) { await preliminaryFunctions(); - initialize(serverPort, isRelease); + initialize(isRelease); } async function preliminaryFunctions() { } - export function initialize(socketPort: number, isRelease: boolean) { + function initialize(isRelease: boolean) { const endpoint = io(); endpoint.on("connection", function (socket: Socket) { + _socket = socket; + socket.use((_packet, next) => { const userEmail = socketMap.get(socket); if (userEmail) { @@ -60,6 +63,7 @@ export namespace WebSocket { }; }); + const socketPort = isRelease ? Number(process.env.socketPort) : 4321; endpoint.listen(socketPort); logPort("websocket", socketPort); } |