fix: update round / application stats for all strategies (#110)

# 🤖 Linear

Closes PAR-XXX

## Description

- update round donation stats for direct allocation

## Checklist before requesting a review

-   [ ] I have conducted a self-review of my code.
-   [ ] I have conducted a QA.
-   [ ] If it is a core feature, I have included comprehensive tests.


<!-- This is an auto-generated comment: release notes by coderabbit.ai
-->
## Summary by CodeRabbit

- **New Features**
- Enhanced donation processing by incorporating round-based donation
statistics tracking, providing a more comprehensive view of donation
performance across rounds.
- Added functionality to track unique donors for both applications and
rounds, improving insights into donor engagement.
- Introduced new operations for tracking total distributed amounts for
specific rounds, enhancing event handling logic.
- Added assertions in tests to verify the correct handling of new
donation statistics events.
<!-- end of auto-generated comment: release notes by coderabbit.ai -->

Author: thelostone-mc

packages/processors/src/processors/strategy/directAllocation/handlers/directAllocated.handler.ts

@@ -86,6 +86,14 @@ export class DirectAllocatedHandler implements IEventHandler<"Strategy", "Direct
                 type: "InsertDonation",
                 args: { donation },
             },
+            {
+                type: "IncrementRoundDonationStats",
+                args: {
+                    chainId: this.chainId,
+                    roundId: round.id,
+                    amountInUsd,
+                },
+            },
         ];
     }
 }

packages/processors/src/processors/strategy/directGrantsLite/handlers/allocated.handler.ts

@@ -30,7 +30,7 @@ export class DGLiteAllocatedHandler implements IEventHandler<"Strategy", "Alloca
 
     /**
      * Handles the AllocatedWithToken event for the Direct Grants Lite strategy.
-     * @returns The changeset with an InsertApplicationPayout operation.
+     * @returns The changeset with an InsertApplicationPayout and IncrementRoundTotalDistributed operation.
      * @throws RoundNotFound if the round is not found.
      * @throws ApplicationNotFound if the application is not found.
      * @throws TokenNotFound if the token is not found.
@@ -104,6 +104,14 @@ export class DGLiteAllocatedHandler implements IEventHandler<"Strategy", "Alloca
                     },
                 },
             },
+            {
+                type: "IncrementRoundTotalDistributed",
+                args: {
+                    chainId: this.chainId,
+                    roundId: round.id,
+                    amount: amountInRoundMatchToken,
+                },
+            },
         ];
     }
 }

packages/processors/test/strategy/directAllocation/handlers/directAllocated.handler.spec.ts

@@ -109,6 +109,14 @@ describe("DirectAllocatedHandler", () => {
                     },
                 },
             },
+            {
+                type: "IncrementRoundDonationStats",
+                args: {
+                    chainId,
+                    roundId: mockRound.id,
+                    amountInUsd: "20000",
+                },
+            },
         ]);
     });
 

packages/processors/test/strategy/directGrantsLite/handlers/allocated.handler.spec.ts

@@ -105,6 +105,15 @@ describe("DGLiteAllocatedHandler", () => {
                 },
             },
         });
+
+        expect(result[1]).toEqual({
+            type: "IncrementRoundTotalDistributed",
+            args: {
+                chainId,
+                roundId: "round1",
+                amount: BigInt(amount),
+            },
+        });
     });
 
     it("doesn't fetch token price if amount is 0", async () => {
@@ -159,6 +168,15 @@ describe("DGLiteAllocatedHandler", () => {
         expect(changeset.args.applicationPayout.amount).toBe(0n);
         expect(changeset.args.applicationPayout.amountInUsd).toBe("0");
         expect(changeset.args.applicationPayout.amountInRoundMatchToken).toBe(0n);
+
+        expect(result[1]).toEqual({
+            type: "IncrementRoundTotalDistributed",
+            args: {
+                chainId,
+                roundId: "round1",
+                amount: BigInt(0),
+            },
+        });
     });
 
     it("throws RoundNotFound if round is not found", async () => {
@@ -369,5 +387,13 @@ describe("DGLiteAllocatedHandler", () => {
             args: { applicationPayout: { amountInRoundMatchToken: bigint } };
         };
         expect(changeset.args.applicationPayout.amountInRoundMatchToken).toBe(parseEther("0.005"));
+        expect(result[1]).toEqual({
+            type: "IncrementRoundTotalDistributed",
+            args: {
+                chainId,
+                roundId: "round1",
+                amount: parseEther("0.005"),
+            },
+        });
     });
 });

packages/repository/src/kysely/repositories/application.repository.ts

@@ -169,11 +169,24 @@ export class KyselyApplicationRepository implements IApplicationRepository<Kysel
     ): Promise<void> {
         try {
             const queryBuilder = (tx || this.db).withSchema(this.schemaName);
+
+            const uniqueDonorsResult = await queryBuilder
+                .withSchema(this.schemaName)
+                .selectFrom("donations")
+                .where("chainId", "=", where.chainId)
+                .where("roundId", "=", where.roundId)
+                .where("applicationId", "=", where.id)
+                .select((qb) => qb.fn.count("donorAddress").distinct().as("uniqueDonorsCount"))
+                .executeTakeFirst();
+
+            const uniqueDonorsCount = Number(uniqueDonorsResult?.uniqueDonorsCount ?? 0);
+
             await queryBuilder
                 .updateTable("applications")
                 .set((eb) => ({
                     totalDonationsCount: eb("totalDonationsCount", "+", 1),
                     totalAmountDonatedInUsd: eb("totalAmountDonatedInUsd", "+", amountInUsd),
+                    uniqueDonorsCount,
                 }))
                 .where("id", "=", where.id)
                 .where("chainId", "=", where.chainId)

packages/repository/src/kysely/repositories/round.repository.ts

@@ -213,11 +213,23 @@ export class KyselyRoundRepository implements IRoundRepository<KyselyTransaction
     ): Promise<void> {
         try {
             const queryBuilder = (tx || this.db).withSchema(this.schemaName);
+
+            const uniqueDonorsResult = await queryBuilder
+                .withSchema(this.schemaName)
+                .selectFrom("donations")
+                .where("chainId", "=", where.chainId)
+                .where("roundId", "=", where.roundId)
+                .select((qb) => qb.fn.count("donorAddress").distinct().as("uniqueDonorsCount"))
+                .executeTakeFirst();
+
+            const uniqueDonorsCount = Number(uniqueDonorsResult?.uniqueDonorsCount ?? 0);
+
             await queryBuilder
                 .updateTable("rounds")
                 .set((eb) => ({
                     totalDonationsCount: eb("totalDonationsCount", "+", 1),
                     totalAmountDonatedInUsd: eb("totalAmountDonatedInUsd", "+", amountInUsd),
+                    uniqueDonorsCount,
                 }))
                 .where("chainId", "=", where.chainId)
                 .where("id", "=", where.roundId)