Merge branch 'next' into feature/prod-cicd-fixes

implerhq · Jul 8, 2024 · 2830c72 · 2830c72
2 parents f887353 + dc67058
commit 2830c72
Show file tree

Hide file tree

Showing 2 changed files with 6,111 additions and 9,132 deletions.
diff --git a/apps/api/src/app/review/usecases/do-review/re-review-data.usecase.ts b/apps/api/src/app/review/usecases/do-review/re-review-data.usecase.ts
@@ -75,6 +75,29 @@ export class DoReReview extends BaseReview {
         uniqueItems[field].add(item.record[field]);
       });
     });
+    const bulkOperations = [];
+    for (const key of Object.keys(uniqueItems)) {
+      const itemsArray = Array.from(uniqueItems[key]);
+      // Iterate over each value in unique field
+      for (const item of itemsArray) {
+        // update first occurance of data
+        bulkOperations.push({
+          updateOne: {
+            filter: { [`record.${key}`]: item },
+            update: { $set: { [`updated.${key}`]: true } },
+          },
+        });
+        // update second occurance of data for validity
+        bulkOperations.push({
+          updateOne: {
+            filter: { [`record.${key}`]: item, [`updated.${key}`]: false },
+            update: { $set: { [`updated.${key}`]: true } },
+          },
+        });
+      }
+      uniqueItems[key].clear();
+    }
+    await this._modal.bulkWrite(bulkOperations);
 
     let result: ISaveResults = {
       uploadId: _uploadId,