diff --git a/lib/storage/metadata/mongoclient/MongoClientInterface.ts b/lib/storage/metadata/mongoclient/MongoClientInterface.ts index 0e7354c47..bd74d28b1 100644 --- a/lib/storage/metadata/mongoclient/MongoClientInterface.ts +++ b/lib/storage/metadata/mongoclient/MongoClientInterface.ts @@ -803,7 +803,6 @@ class MongoClientInterface { isRetry?: boolean, ) { const versionId = generateVersionId(this.replicationGroupId); - objVal.versionId = versionId; const versionKey = formatVersionKey(objName, versionId, params.vFormat); const masterKey = formatMasterKey(objName, params.vFormat); @@ -916,7 +915,6 @@ class MongoClientInterface { cb: ArsenalCallback, ) { const versionId = generateVersionId(this.replicationGroupId); - objVal.versionId = versionId; const masterKey = formatMasterKey(objName, params.vFormat); c.updateOne({ _id: masterKey }, @@ -959,7 +957,6 @@ class MongoClientInterface { log: werelogs.Logger, cb: ArsenalCallback, ) { - objVal.versionId = params.versionId; const versionKey = formatVersionKey(objName, params.versionId, params.vFormat); const masterKey = formatMasterKey(objName, params.vFormat); @@ -1592,7 +1589,6 @@ class MongoClientInterface { ) { const masterKey = formatMasterKey(objName, vFormat); MongoUtils.serialize(objVal); - objVal.originOp = 's3:ObjectRemoved:Delete'; c.findOneAndReplace({ '_id': masterKey, @@ -2229,11 +2225,9 @@ class MongoClientInterface { newParams.gt = undefined; if (newParams.secondaryStreamParams) { - newParams.mainStreamParams.gte = range[0]; newParams.secondaryStreamParams.gte = range[1]; } else { - newParams.mainStreamParams.gte = range; } // then continue listing the next key range @@ -2643,11 +2637,9 @@ class MongoClientInterface { return cb(errors.InternalError); } // overwrite bucket info since we have latest info - results.bucketList = retBucketInfos; results.buckets = bucketCount; results.bucketWithQuotaCount = bucketWithQuotaCount; - return cb(null, results); }); }); @@ -2671,7 +2663,6 @@ class MongoClientInterface { } }); } - } scanItemCount(log, cb) {