feat: base strategy processor & dvmd strategy factory (#16)

# 🤖 Linear

Closes GIT-60 GIT-61 GIT-62

## Description

- `StrategyHandlerFactory` to create the proper Strategy handler based
on strategyId
- `BaseStrategyHandler` abstract class w/ default implementation for
fetch functions (some strategies require custom logic)
- `DVMDDirectTransferStrategy` handler
- `Distributed` and `Registered` handlers for DVMD strategy (PR #17)
- refactored TODOs from `PoolCreatedHandler`

## Checklist before requesting a review

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

Author: 0xnigir1

.husky/pre-commit

@@ -1 +1 @@
-pnpm lint-staged && pnpm check-types
+pnpm lint-staged && pnpm check-types --force

packages/data-flow/test/unit/eventsFetcher.spec.ts

@@ -27,7 +27,7 @@ describe("EventsFetcher", () => {
                 eventName: "PoolCreated",
                 srcAddress: "0x1234567890123456789012345678901234567890",
                 logIndex: 0,
-                params: { contractAddress: "0x1234" },
+                params: { contractAddress: "0x1234", tokenAddress: "0x1234", amount: 1000 },
                 transactionFields: { hash: "0x1234", transactionIndex: 0 },
             },
             {
@@ -38,7 +38,11 @@ describe("EventsFetcher", () => {
                 eventName: "PoolCreated",
                 srcAddress: "0x1234567890123456789012345678901234567890",
                 logIndex: 0,
-                params: { contractAddress: "0x1234" },
+                params: {
+                    contractAddress: "0x1234",
+                    tokenAddress: "0x1234",
+                    amount: 1000,
+                },
                 transactionFields: { hash: "0x1234", transactionIndex: 1 },
             },
         ];

packages/indexer-client/test/unit/envioIndexerClient.spec.ts

@@ -51,7 +51,7 @@ describe("EnvioIndexerClient", () => {
                 eventName: "PoolCreated",
                 srcAddress: "0x1234567890123456789012345678901234567890",
                 logIndex: 0,
-                params: { contractAddress: "0x1234" },
+                params: { contractAddress: "0x1234", tokenAddress: "0x1234", amount: 1000 },
                 transactionFields: {
                     hash: "0x123",
                     transactionIndex: 1,

packages/processors/src/allo/handlers/poolCreated.handler.ts

@@ -1,15 +1,12 @@
-import { getAddress, parseUnits, zeroAddress } from "viem";
+import { getAddress, zeroAddress } from "viem";
 
 import type { Changeset, NewRound, PendingRoundRole } from "@grants-stack-indexer/repository";
 import type { ChainId, ProtocolEvent, Token } from "@grants-stack-indexer/shared";
-import { isAlloNativeToken } from "@grants-stack-indexer/shared";
-import { getToken } from "@grants-stack-indexer/shared/dist/src/internal.js";
+import { getToken, isAlloNativeToken } from "@grants-stack-indexer/shared";
 
 import type { IEventHandler, ProcessorDependencies, StrategyTimings } from "../../internal.js";
-import { getRoundRoles } from "../../helpers/roles.js";
-import { extractStrategyFromId, getStrategyTimings } from "../../helpers/strategy.js";
-import { calculateAmountInUsd } from "../../helpers/tokenMath.js";
-import { TokenPriceNotFoundError } from "../../internal.js";
+import { calculateAmountInUsd, getRoundRoles } from "../../helpers/index.js";
+import { StrategyHandlerFactory, TokenPriceNotFoundError } from "../../internal.js";
 import { RoundMetadataSchema } from "../../schemas/index.js";
 
 type Dependencies = Pick<
@@ -61,7 +58,11 @@ export class PoolCreatedHandler implements IEventHandler<"Allo", "PoolCreated">
             ? zeroAddress
             : checksummedTokenAddress;
 
-        const strategy = extractStrategyFromId(strategyId);
+        const strategyHandler = StrategyHandlerFactory.createHandler(
+            this.chainId,
+            this.dependencies as ProcessorDependencies,
+            strategyId,
+        );
 
         const token = getToken(this.chainId, matchTokenAddress);
 
@@ -72,26 +73,17 @@ export class PoolCreatedHandler implements IEventHandler<"Allo", "PoolCreated">
             donationsEndTime: null,
         };
 
-        let matchAmount = 0n;
-        let matchAmountInUsd = "0";
-
-        if (strategy) {
-            strategyTimings = await getStrategyTimings(evmProvider, strategy, strategyAddress);
-
-            //TODO: when creating strategy handlers, should this be moved there?
-            if (
-                strategy.name === "allov2.DonationVotingMerkleDistributionDirectTransferStrategy" &&
-                parsedRoundMetadata.success &&
-                token
-            ) {
-                matchAmount = parseUnits(
-                    parsedRoundMetadata.data.quadraticFundingConfig.matchingFundsAvailable.toString(),
-                    token.decimals,
-                );
+        let matchAmountObj = {
+            matchAmount: 0n,
+            matchAmountInUsd: "0",
+        };
 
-                matchAmountInUsd = await this.getTokenAmountInUsd(
+        if (strategyHandler) {
+            strategyTimings = await strategyHandler.fetchStrategyTimings(strategyAddress);
+            if (parsedRoundMetadata.success && token) {
+                matchAmountObj = await strategyHandler.fetchMatchAmount(
+                    Number(parsedRoundMetadata.data.quadraticFundingConfig.matchingFundsAvailable),
                     token,
-                    matchAmount,
                     this.event.blockTimestamp,
                 );
             }
@@ -120,8 +112,8 @@ export class PoolCreatedHandler implements IEventHandler<"Allo", "PoolCreated">
             totalAmountDonatedInUsd: "0",
             uniqueDonorsCount: 0,
             matchTokenAddress,
-            matchAmount,
-            matchAmountInUsd,
+            matchAmount: matchAmountObj.matchAmount,
+            matchAmountInUsd: matchAmountObj.matchAmountInUsd,
             fundedAmount,
             fundedAmountInUsd,
             applicationMetadataCid: metadataPointer,
@@ -132,7 +124,7 @@ export class PoolCreatedHandler implements IEventHandler<"Allo", "PoolCreated">
             ...roundRoles,
             strategyAddress,
             strategyId,
-            strategyName: strategy?.name ?? "",
+            strategyName: strategyHandler?.name ?? "",
             createdByAddress: getAddress(createdBy),
             createdAtBlock: BigInt(this.event.blockNumber),
             updatedAtBlock: BigInt(this.event.blockNumber),

packages/processors/src/exceptions/index.ts

@@ -1,3 +1,6 @@
 export * from "./tokenPriceNotFound.exception.js";
 export * from "./unsupportedEvent.exception.js";
 export * from "./invalidArgument.exception.js";
+export * from "./unsupportedStrategy.exception.js";
+export * from "./projectNotFound.exception.js";
+export * from "./roundNotFound.exception.js";

packages/processors/src/exceptions/projectNotFound.exception.ts

@@ -0,0 +1,7 @@
+import { ChainId } from "@grants-stack-indexer/shared";
+
+export class ProjectNotFound extends Error {
+    constructor(chainId: ChainId, anchorAddress: string) {
+        super(`Project not found for chainId: ${chainId} and anchorAddress: ${anchorAddress}`);
+    }
+}

packages/processors/src/exceptions/roundNotFound.exception.ts

@@ -0,0 +1,7 @@
+import { ChainId } from "@grants-stack-indexer/shared";
+
+export class RoundNotFound extends Error {
+    constructor(chainId: ChainId, strategyAddress: string) {
+        super(`Round not found for chainId: ${chainId} and strategyAddress: ${strategyAddress}`);
+    }
+}

packages/processors/src/exceptions/unsupportedStrategy.exception.ts

@@ -0,0 +1,7 @@
+import { Hex } from "viem";
+
+export class UnsupportedStrategy extends Error {
+    constructor(strategyId: Hex) {
+        super(`Strategy ${strategyId} unsupported`);
+    }
+}

packages/processors/src/external.ts

@@ -1,3 +1,5 @@
 // Add your external exports here
 export { StrategyProcessor, AlloProcessor } from "./internal.js";
 export type { IProcessor } from "./internal.js";
+
+export { existsHandler } from "./internal.js";

packages/processors/src/helpers/index.ts

@@ -0,0 +1,3 @@
+export * from "./roles.js";
+export * from "./utils.js";
+export * from "./tokenMath.js";