wieerwill/platform
1
0
Fork 0
mirror of https://github.com/hcengineering/platform.git synced 2025-04-14 04:08:19 +00:00
Code Issues Actions 3 Packages Projects Releases Wiki Activity

Use query cache for find (#2607)

Browse Source 
Signed-off-by: Denis Bykhov <bykhov.denis@gmail.com>
This commit is contained in:
Denis Bykhov 2023-02-09 09:10:36 +06:00 committed by GitHub
parent 96fac678fc
commit e83fed7258
No known key found for this signature in database
GPG Key ID: 4AEE18F83AFDEB23
1 changed files with 23 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

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

@ -109,6 +109,16 @@ export class LiveQuery extends TxProcessor implements Client {
query: DocumentQuery<T>,
options?: FindOptions<T>
): Promise<FindResult<T>> {
const q = this.findQuery(_class, query, options)
if (q !== undefined) {
if (q.result instanceof Promise) {
q.result = await q.result
}
if (this.removeFromQueue(q)) {
this.queue.push(q)
}
return toFindResult(this.clone(q.result), q.total) as FindResult<T>
}
return await this.client.findAll(_class, query, options)
}
@ -117,6 +127,16 @@ export class LiveQuery extends TxProcessor implements Client {
query: DocumentQuery<T>,
options?: FindOptions<T>
): Promise<WithLookup<T> | undefined> {
const q = this.findQuery(_class, query, options)
if (q !== undefined) {
if (q.result instanceof Promise) {
q.result = await q.result
}
if (this.removeFromQueue(q)) {
this.queue.push(q)
}
return this.clone(q.result)[0] as WithLookup<T>
}
return await this.client.findOne(_class, query, options)
}
@ -133,13 +153,15 @@ export class LiveQuery extends TxProcessor implements Client {
}
}
private removeFromQueue (q: Query): void {
private removeFromQueue (q: Query): boolean {
if (q.callbacks.length === 0) {
const queueIndex = this.queue.indexOf(q)
if (queueIndex !== -1) {
this.queue.splice(queueIndex, 1)
return true
}
}
return false
}
private pushCallback (q: Query, callback: (result: Doc[]) => void): void {