diff options
author | mehekj <mehek.jethani@gmail.com> | 2022-03-17 16:56:54 -0400 |
---|---|---|
committer | mehekj <mehek.jethani@gmail.com> | 2022-03-17 16:56:54 -0400 |
commit | 1e3ad4de06f83eab54628de660529fefb9a0dc63 (patch) | |
tree | b7c05080dac66366768f23e59a43f62533a22415 /src/server/websocket.ts | |
parent | cca2faa0bc4083db7b1a0b9cb6a9c5092e332d31 (diff) | |
parent | 5d50e0673fde8aabb2d87a75624b40d3b9c65df3 (diff) |
Merge branch 'master' into temporalmedia-mehek
Diffstat (limited to 'src/server/websocket.ts')
-rw-r--r-- | src/server/websocket.ts | 13 |
1 files changed, 12 insertions, 1 deletions
diff --git a/src/server/websocket.ts b/src/server/websocket.ts index 13d7237f6..0c79c1bbb 100644 --- a/src/server/websocket.ts +++ b/src/server/websocket.ts @@ -187,7 +187,7 @@ export namespace WebSocket { + currentdate.getMinutes() + ":" + currentdate.getSeconds(); console.log(blue(`user ${userEmail} has connected to the web socket at: ${datetime}`)); - socketMap.set(socket, userEmail); + socketMap.set(socket, userEmail + " at " + datetime); } function getField([id, callback]: [string, (result?: Transferable) => void]) { @@ -338,7 +338,18 @@ export namespace WebSocket { if (!pendingOps.get(id)!.length) pendingOps.delete(id); } + function printActiveUsers() { + socketMap.forEach((user, socket) => { + !socket.disconnected && console.log(user); + }); + } + var CurUser: string | undefined = undefined; + function UpdateField(socket: Socket, diff: Diff) { + if (CurUser !== socketMap.get(socket)) { + CurUser = socketMap.get(socket); + console.log("Switch User: " + CurUser); + } if (pendingOps.has(diff.id)) { pendingOps.get(diff.id)!.push({ diff, socket }); return true; |