diff options
author | usodhi <61431818+usodhi@users.noreply.github.com> | 2020-10-16 13:09:38 +0530 |
---|---|---|
committer | usodhi <61431818+usodhi@users.noreply.github.com> | 2020-10-16 13:09:38 +0530 |
commit | a002e0e5c5910f78c8f3910ad4101386d30ebf70 (patch) | |
tree | 60c1cebfcffb43fa0af221fa36a891beb806bafc /src/server/websocket.ts | |
parent | 3b81903962ac10bbf87013e045c7fdf101fea9ec (diff) | |
parent | e6d700159cb6c273a2df0fd02469e72aa5b48c86 (diff) |
merge
Diffstat (limited to 'src/server/websocket.ts')
-rw-r--r-- | src/server/websocket.ts | 3 |
1 files changed, 3 insertions, 0 deletions
diff --git a/src/server/websocket.ts b/src/server/websocket.ts index 1e02b9e58..e5692a7dd 100644 --- a/src/server/websocket.ts +++ b/src/server/websocket.ts @@ -313,6 +313,9 @@ export namespace WebSocket { function UpdateField(socket: Socket, diff: Diff) { if (diff.diff.$addToSet) return GetRefField([diff.id, (result?: Transferable) => addToListField(socket, diff, result)]); // would prefer to have Mongo handle list additions direclty, but for now handle it on our own if (diff.diff.$remFromSet) return GetRefField([diff.id, (result?: Transferable) => remFromListField(socket, diff, result)]); // would prefer to have Mongo handle list additions direclty, but for now handle it on our own + return GetRefField([diff.id, (result?: Transferable) => SetField(socket, diff, result)]); + } + function SetField(socket: Socket, diff: Diff, curListItems?: Transferable) { Database.Instance.update(diff.id, diff.diff, () => socket.broadcast.emit(MessageStore.UpdateField.Message, diff), false); const docfield = diff.diff.$set || diff.diff.$unset; |