hcengineering/platform
1
0
Fork 0
mirror of https://github.com/hcengineering/platform.git synced 2024-11-22 21:50:34 +03:00
Code Issues Actions 4 Packages Projects Releases Wiki Activity

fixes #109

Browse Source 
Signed-off-by: Andrey Platov <andrey@hardcoreeng.com>
This commit is contained in:
Andrey Platov 2021-09-01 10:42:07 +02:00
parent b43737c8a9
commit 5013109f7e
No known key found for this signature in database
GPG Key ID: C8787EFEB4B64AF0
1 changed files with 9 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

11
packages/query/src/index.ts
View File

@ -94,7 +94,7 @@ export class LiveQuery extends TxProcessor implements Client {
}
const updatedDoc = q.result.find(p => p._id === tx.objectId)
if (updatedDoc !== undefined) {
await this.__updateDoc(updatedDoc, tx)
await this.__updateDoc(q, updatedDoc, tx)
this.sort(q, tx)
await this.callback(updatedDoc, q)
}
@ -155,7 +155,8 @@ export class LiveQuery extends TxProcessor implements Client {
await super.tx(tx)
}
private async __updateDoc (updatedDoc: Doc, tx: TxUpdateDoc<Doc>): Promise<void> {
// why this is separate from txUpdateDoc?
private async __updateDoc (q: Query, updatedDoc: WithLookup<Doc>, tx: TxUpdateDoc<Doc>): Promise<void> {
const ops = tx.operations as any
for (const key in ops) {
if (key.startsWith('$')) {
@ -163,6 +164,12 @@ export class LiveQuery extends TxProcessor implements Client {
operator(updatedDoc, ops[key])
} else {
(updatedDoc as any)[key] = ops[key]
if (q.options !== undefined) {
const lookup = (q.options.lookup as any)?.[key]
if (lookup !== undefined) {
(updatedDoc.$lookup as any)[key] = await this.client.findOne(lookup, { _id: ops[key] })
}
}
}
}
updatedDoc.modifiedBy = tx.modifiedBy