Add importDate to donation entity

migration/1706012712969-add_import_date_to_donation_entity.ts

@@ -0,0 +1,13 @@
+import { MigrationInterface, QueryRunner } from "typeorm";
+
+export class addImportDateToDonationEntity1706012712969 implements MigrationInterface {
+
+    public async up(queryRunner: QueryRunner): Promise<void> {
+        await queryRunner.query(`ALTER TABLE "donation" ADD COLUMN "importDate" TIMESTAMP WITH TIME ZONE`);
+    }
+
+    public async down(queryRunner: QueryRunner): Promise<void> {
+        await queryRunner.query(`ALTER TABLE "donation" DROP COLUMN "importDate"`);
+    }
+
+}

src/entities/donation.ts

@@ -214,6 +214,10 @@ export class Donation extends BaseEntity {
   @Column()
   createdAt: Date;
 
+  @Field(type => Date, { nullable: true })
+  @Column({ nullable: true })
+  importDate: Date;
+
   @Field(type => String, { nullable: true })
   @Column({ nullable: true })
   donationType?: string;

src/repositories/donationRepository.ts

@@ -387,12 +387,20 @@ export const getPendingDonationsIds = (): Promise<{ id: number }[]> => {
       hours: Number(process.env.DONATION_VERIFICAITON_EXPIRATION_HOURS),
     })
     .toDate();
+
   return Donation.find({
-    where: {
-      status: DONATION_STATUS.PENDING,
-      isFiat: false,
-      createdAt: MoreThan(date),
-    },
+    where: [
+      {
+        status: DONATION_STATUS.PENDING,
+        isFiat: false,
+        createdAt: MoreThan(date),
+      },
+      {
+        status: DONATION_STATUS.PENDING,
+        isFiat: false,
+        importDate: MoreThan(date),
+      },
+    ],
     select: ['id'],
   });
 };

src/services/cronJobs/backupDonationImport.test.ts

@@ -49,7 +49,7 @@ function createBackupDonationTestCases() {
     assert.equal(donation.status, DONATION_STATUS.PENDING);
 
     // should use input createdAt not now time
-    assert.equal(donation.createdAt.getTime(), 1705577862000);
+    assert.equal(donation.importDate.getTime(), 1705577862000);
   });
 
   it('should fail if projectId is invalid', async () => {

src/services/cronJobs/backupDonationImportJob.ts

@@ -110,7 +110,7 @@ export const createBackupDonation = async (
     safeTransactionId,
   );
   const donation = (await findDonationById(Number(donationId))) as Donation;
-  donation!.createdAt = getCreatedAtFromMongoObjectId(donationData._id);
+  donation!.importDate = getCreatedAtFromMongoObjectId(donationData._id);
 
   return donation.save();
 };