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

Mongo TX modified fields (#376)

Browse Source 
Signed-off-by: Denis Bykhov <bykhov.denis@gmail.com>
This commit is contained in:
Denis Bykhov 2021-11-26 17:06:21 +06:00 committed by GitHub
parent 72db2f3443
commit 3e0ac54267
No known key found for this signature in database
GPG Key ID: 4AEE18F83AFDEB23
1 changed files with 13 additions and 4 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

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

@ -151,6 +151,11 @@ class MongoAdapter extends MongoAdapterBase {
protected override async txUpdateDoc (tx: TxUpdateDoc<Doc>): Promise<TxResult> { protected override async txUpdateDoc (tx: TxUpdateDoc<Doc>): Promise<TxResult> {
const domain = this.hierarchy.getDomain(tx.objectClass) const domain = this.hierarchy.getDomain(tx.objectClass)
const operations = {
...tx.operations,
modifiedBy: tx.modifiedBy,
modifiedOn: tx.modifiedOn
}
if (isOperator(tx.operations)) { if (isOperator(tx.operations)) {
const operator = Object.keys(tx.operations)[0] const operator = Object.keys(tx.operations)[0]
if (operator === '$move') { if (operator === '$move') {
@ -172,6 +177,10 @@ class MongoAdapter extends MongoAdapterBase {
updateOne: { updateOne: {
filter: { _id: tx.objectId }, filter: { _id: tx.objectId },
update: { update: {
$set: {
modifiedBy: tx.modifiedBy,
modifiedOn: tx.modifiedOn
},
$push: { $push: {
[arr]: { [arr]: {
$each: [desc.$value], $each: [desc.$value],
@ -186,18 +195,18 @@ class MongoAdapter extends MongoAdapterBase {
return await this.db.collection(domain).bulkWrite(ops as any) return await this.db.collection(domain).bulkWrite(ops as any)
} else { } else {
if (tx.retrieve === true) { if (tx.retrieve === true) {
const result = await this.db.collection(domain).findOneAndUpdate({ _id: tx.objectId }, tx.operations, { returnDocument: 'after' }) const result = await this.db.collection(domain).findOneAndUpdate({ _id: tx.objectId }, operations, { returnDocument: 'after' })
return { object: result.value } return { object: result.value }
} else { } else {
return await this.db.collection(domain).updateOne({ _id: tx.objectId }, tx.operations) return await this.db.collection(domain).updateOne({ _id: tx.objectId }, operations)
} }
} }
} else { } else {
if (tx.retrieve === true) { if (tx.retrieve === true) {
const result = await this.db.collection(domain).findOneAndUpdate({ _id: tx.objectId }, { $set: tx.operations }, { returnDocument: 'after' }) const result = await this.db.collection(domain).findOneAndUpdate({ _id: tx.objectId }, { $set: operations }, { returnDocument: 'after' })
return { object: result.value } return { object: result.value }
} else { } else {
return await this.db.collection(domain).updateOne({ _id: tx.objectId }, { $set: tx.operations }) return await this.db.collection(domain).updateOne({ _id: tx.objectId }, { $set: operations })
} }
} }
} }