Add streamed mini donations to qf round

related to Giveth/giveth-dapps-v2#3284

migration/1715521134568-relate_current_mini_stream_donations_to_qf_Rounds.ts

@@ -0,0 +1,25 @@
+import { MigrationInterface, QueryRunner } from 'typeorm';
+
+export class RelateCurrentMiniStreamDonationsToQfRounds1715521134568
+  implements MigrationInterface
+{
+  public async up(queryRunner: QueryRunner): Promise<void> {
+    await queryRunner.query(`
+            UPDATE donation
+            SET "qfRoundId" = qf_round.id
+            FROM project_qf_rounds_qf_round, qf_round
+            WHERE donation."recurringDonationId" IS NOT NULL
+                AND donation."projectId" = project_qf_rounds_qf_round."projectId"
+                AND project_qf_rounds_qf_round."qfRoundId" = qf_round."id"
+                AND donation."createdAt" BETWEEN qf_round."beginDate" AND qf_round."endDate"
+        `);
+  }
+
+  public async down(queryRunner: QueryRunner): Promise<void> {
+    // Since the `up` migration changes data based on existing conditions rather than schema,
+    // rolling back would ideally require prior knowledge of the previous state, which might
+    // not be practical or possible to restore.
+    // Therefore, typically for data migrations, the down method might be left empty or
+    // could reset changes based on specific requirements.
+  }
+}

src/services/recurringDonationService.ts

@@ -37,6 +37,7 @@ import { updateUserTotalDonated, updateUserTotalReceived } from './userService';
 import config from '../config';
 import { User } from '../entities/user';
 import { NOTIFICATIONS_EVENT_NAMES } from '../analytics/analytics';
+import { relatedActiveQfRoundForProject } from './qfRoundService';
 
 // Initially it will only be monthly data
 export const priceDisplay = 'month';
@@ -212,17 +213,16 @@ export const createRelatedDonationsToStream = async (
         amount: donation.amount,
       });
 
-      // TODO - uncomment this when QF is enabled
-      // const activeQfRoundForProject = await relatedActiveQfRoundForProject(
-      //   project.id,
-      // );
-      //
-      // if (
-      //   activeQfRoundForProject &&
-      //   activeQfRoundForProject.isEligibleNetwork(networkId)
-      // ) {
-      //   donation.qfRound = activeQfRoundForProject;
-      // }
+      const activeQfRoundForProject = await relatedActiveQfRoundForProject(
+        project.id,
+      );
+
+      if (
+        activeQfRoundForProject &&
+        activeQfRoundForProject.isEligibleNetwork(networkId)
+      ) {
+        donation.qfRound = activeQfRoundForProject;
+      }
 
       const { givbackFactor, projectRank, bottomRankInRound, powerRound } =
         await calculateGivbackFactor(project.id);