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

fixes #159

Browse Source 
Signed-off-by: Andrey Platov <andrey@hardcoreeng.com>
This commit is contained in:
Andrey Platov 2021-09-08 10:34:48 +02:00
parent 6e79f55cbf
commit 3ab72eb819
No known key found for this signature in database
GPG Key ID: C8787EFEB4B64AF0
1 changed files with 7 additions and 7 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

14
server/mongo/src/storage.ts
View File

@ -19,11 +19,6 @@ import type { DbAdapter, TxAdapter } from '@anticrm/server-core'
import { MongoClient, Db, Filter, Document, Sort } from 'mongodb'
function translateQuery<T extends Doc> (clazz: Ref<Class<T>>, query: DocumentQuery<T>): Filter<Document> {
// return Object.assign({}, query, { _class: clazz })
return query as Filter<Document>
}
function translateDoc (doc: Doc): Document {
return doc as Document
}
@ -38,9 +33,14 @@ abstract class MongoAdapterBase extends TxProcessor {
async init (): Promise<void> {}
private translateQuery<T extends Doc> (clazz: Ref<Class<T>>, query: DocumentQuery<T>): Filter<Document> {
const classes = this.hierarchy.getDescendants(clazz)
return Object.assign({}, query, { _class: { $in: classes } })
}
private async lookup<T extends Doc> (clazz: Ref<Class<T>>, query: DocumentQuery<T>, options: FindOptions<T>): Promise<FindResult<T>> {
const pipeline = []
pipeline.push({ $match: translateQuery(clazz, query) })
pipeline.push({ $match: this.translateQuery(clazz, query) })
const lookups = options.lookup as any
for (const key in lookups) {
const clazz = lookups[key]
@ -76,7 +76,7 @@ abstract class MongoAdapterBase extends TxProcessor {
if (options.lookup !== undefined) { return await this.lookup(_class, query, options) }
}
const domain = this.hierarchy.getDomain(_class)
let cursor = this.db.collection(domain).find<T>(translateQuery(_class, query))
let cursor = this.db.collection(domain).find<T>(this.translateQuery(_class, query))
if (options !== null && options !== undefined) {
if (options.sort !== undefined) {
const sort: Sort = {}