Fix query of getting failed donations from mongo API

Giveth · Jan 23, 2024 · 9c7d9cf · 9c7d9cf
1 parent de14c4b
commit 9c7d9cf
Show file tree

Hide file tree

Showing 2 changed files with 16 additions and 2 deletions.
diff --git a/src/adapters/donationSaveBackup/donationSaveBackupAdapter.ts b/src/adapters/donationSaveBackup/donationSaveBackupAdapter.ts
@@ -41,8 +41,8 @@ export class DonationSaveBackupAdapter implements DonationSaveBackupInterface {
         dataSource: DONATION_SAVE_BACKUP_DATA_SOURCE,
         limit: params.limit,
         filter: {
-          imported: { $ne: true },
-          importError: { $ne: true },
+          imported: { $exists: false },
+          importError: { $exists: false },
         },
         sort: { _id: 1 },
       },

diff --git a/src/services/cronJobs/backupDonationImportJob.ts b/src/services/cronJobs/backupDonationImportJob.ts
@@ -25,18 +25,28 @@ export const runSyncBackupServiceDonations = () => {
 
 // Mock Mongo Methods to write a test
 export const importBackupServiceDonations = async () => {
+  logger.info('importBackupServiceDonations() has been called');
   const limit = 10;
   let donations =
     await getDonationSaveBackupAdapter().getNotImportedDonationsFromBackup({
       limit,
     });
+  logger.info(
+    'importBackupServiceDonations() donations.length: ',
+    donations.length,
+  );
   while (donations.length > 0) {
     for (const donation of donations) {
       try {
         await createBackupDonation(donation);
         await getDonationSaveBackupAdapter().markDonationAsImported(
           donation._id,
         );
+        logger.info('Failed donation has imported successfully', {
+          donationId: donation._id,
+          txHash: donation.txHash,
+          networkId: donation.chainId,
+        });
       } catch (e) {
         await getDonationSaveBackupAdapter().markDonationAsImportError(
           donation._id,
@@ -50,6 +60,10 @@ export const importBackupServiceDonations = async () => {
       await getDonationSaveBackupAdapter().getNotImportedDonationsFromBackup({
         limit,
       });
+    logger.info('importBackupServiceDonations() inside loop ', {
+      donationsLength: donations.length,
+      limit,
+    });
   }
 };