fix: test

Author: thelostone-mc

packages/data-flow/test/integration/strategy.integration.spec.ts

@@ -209,30 +209,14 @@ describe("Orchestrator Integration - Strategy Events Processing", () => {
             "fetchEventsByBlockNumberAndLogIndex",
         );
 
-        const mockDistribution = {
-            matchingDistribution: [
-                {
-                    contributionsCount: 44,
-                    projectPayoutAddress: "0x7340F1a1e4e38F43d2FCC85cdb2b764de36B40c0",
-                    applicationId: "3",
-                    matchPoolPercentage: 0.099999,
-                    projectId: "0x15c5e4db5530e05216abc9484025e2f1c4fb55b8525d29ef38fde237e767e324",
-                    projectName: "ReFi DAO - A Network Society to Regenerate Earth. ✨ 🌱",
-                    matchAmountInToken: "999999999999999475712",
-                    originalMatchAmountInToken: "999999999999999475712",
-                },
-                {
-                    contributionsCount: 69,
-                    projectPayoutAddress: "0x01d1909cA27E364904934849eab8399532dd5c8b",
-                    applicationId: "11",
-                    matchPoolPercentage: 0.099999,
-                    projectId: "0xca460772f5ba0840a589d2c19fb7e17ac259e4be884313e3712c06c9c885dc93",
-                    projectName: "Giveth",
-                    matchAmountInToken: "999999999999999475712",
-                    originalMatchAmountInToken: "999999999999999475712",
-                },
-            ],
-        };
+        const mockDistribution = [
+            {
+                anchorAddress: "0x7340F1a1e4e38F43d2FCC85cdb2b764de36B40c0",
+                payoutAddress: "0x7340F1a1e4e38F43d2FCC85cdb2b764de36B40c0",
+                amount: "1000000000000000000",
+                index: 0,
+            }
+        ];
 
         vi.spyOn(metadataProvider, "getMetadata").mockResolvedValue(mockDistribution);
 
@@ -254,7 +238,7 @@ describe("Orchestrator Integration - Strategy Events Processing", () => {
             { chainId, strategyAddress: distributionUpdatedEvent.srcAddress },
             {
                 readyForPayoutTransaction: distributionUpdatedEvent.transactionFields.hash,
-                matchingDistribution: mockDistribution.matchingDistribution,
+                matchingDistribution: mockDistribution,
             },
             {},
         );

packages/processors/test/strategy/easyRetroFunding/easyRetroFunding.handler.spec.ts

@@ -12,12 +12,12 @@ import { ChainId, ILogger, ProcessorEvent, StrategyEvent } from "@grants-stack-i
 
 import { UnsupportedEventException } from "../../../src/internal.js";
 import {
-    BaseDistributionUpdatedHandler,
     BaseFundsDistributedHandler,
     BaseRecipientStatusUpdatedHandler,
 } from "../../../src/processors/strategy/common/index.js";
 import { EasyRetroFundingStrategyHandler } from "../../../src/processors/strategy/easyRetroFunding/easyRetroFunding.handler.js";
 import {
+    ERFDistributionUpdatedHandler,
     ERFRegisteredHandler,
     ERFTimestampsUpdatedHandler,
     ERFUpdatedRegistrationHandler,
@@ -27,38 +27,37 @@ vi.mock("../../../src/processors/strategy/easyRetroFunding/handlers/index.js", a
     const ERFRegisteredHandler = vi.fn();
     const ERFTimestampsUpdatedHandler = vi.fn();
     const ERFUpdatedRegistrationHandler = vi.fn();
-
+    const ERFDistributionUpdatedHandler = vi.fn();
     // eslint-disable-next-line @typescript-eslint/no-unsafe-member-access
     ERFRegisteredHandler.prototype.handle = vi.fn();
     // eslint-disable-next-line @typescript-eslint/no-unsafe-member-access
     ERFTimestampsUpdatedHandler.prototype.handle = vi.fn();
     // eslint-disable-next-line @typescript-eslint/no-unsafe-member-access
     ERFUpdatedRegistrationHandler.prototype.handle = vi.fn();
     // eslint-disable-next-line @typescript-eslint/no-unsafe-member-access
+    ERFDistributionUpdatedHandler.prototype.handle = vi.fn();
+
     return {
         ERFRegisteredHandler,
         ERFTimestampsUpdatedHandler,
         ERFUpdatedRegistrationHandler,
+        ERFDistributionUpdatedHandler,
     };
 });
 
 vi.mock("../../../src/processors/strategy/common/index.js", async (importOriginal) => {
     const original =
         await importOriginal<typeof import("../../../src/processors/strategy/common/index.js")>();
     const BaseFundsDistributedHandler = vi.fn();
-    const BaseDistributionUpdatedHandler = vi.fn();
     const BaseRecipientStatusUpdatedHandler = vi.fn();
 
     // eslint-disable-next-line @typescript-eslint/no-unsafe-member-access
     BaseFundsDistributedHandler.prototype.handle = vi.fn();
     // eslint-disable-next-line @typescript-eslint/no-unsafe-member-access
-    BaseDistributionUpdatedHandler.prototype.handle = vi.fn();
-    // eslint-disable-next-line @typescript-eslint/no-unsafe-member-access
     BaseRecipientStatusUpdatedHandler.prototype.handle = vi.fn();
     return {
         ...original,
         BaseFundsDistributedHandler,
-        BaseDistributionUpdatedHandler,
         BaseRecipientStatusUpdatedHandler,
     };
 });
@@ -197,16 +196,16 @@ describe("EasyRetroFundingStrategyHandler", () => {
         expect(ERFTimestampsUpdatedHandler.prototype.handle).toHaveBeenCalled();
     });
 
-    it("calls BaseDistributionUpdatedHandler for DistributionUpdated event", async () => {
+    it("calls ERFDistributionUpdatedHandler for DistributionUpdated event", async () => {
         const mockEvent = {
             eventName: "DistributionUpdated",
         } as ProcessorEvent<"Strategy", "DistributionUpdated">;
 
-        vi.spyOn(BaseDistributionUpdatedHandler.prototype, "handle").mockResolvedValue([]);
+        vi.spyOn(ERFDistributionUpdatedHandler.prototype, "handle").mockResolvedValue([]);
 
         await handler.handle(mockEvent);
 
-        expect(BaseDistributionUpdatedHandler).toHaveBeenCalledWith(mockEvent, chainId, {
+        expect(ERFDistributionUpdatedHandler).toHaveBeenCalledWith(mockEvent, chainId, {
             metadataProvider: mockMetadataProvider,
             roundRepository: mockRoundRepository,
             projectRepository: mockProjectRepository,
@@ -215,7 +214,7 @@ describe("EasyRetroFundingStrategyHandler", () => {
             applicationRepository: mockApplicationRepository,
             logger,
         });
-        expect(BaseDistributionUpdatedHandler.prototype.handle).toHaveBeenCalled();
+        expect(ERFDistributionUpdatedHandler.prototype.handle).toHaveBeenCalled();
     });
 
     it("calls FundsDistributedHandler for FundsDistributed event", async () => {

packages/processors/test/strategy/easyRetroFunding/handlers/distributionUpdated.handler.spec.ts

@@ -111,11 +111,8 @@ describe("ERFDistributionUpdatedHandler", () => {
 
     it("handles empty matching distribution array", async () => {
         mockEvent = createMockEvent(eventName, defaultParams, defaultStrategyId);
-        const emptyDistribution = {
-            matchingDistribution: [],
-        };
 
-        vi.spyOn(mockMetadataProvider, "getMetadata").mockResolvedValue(emptyDistribution);
+        vi.spyOn(mockMetadataProvider, "getMetadata").mockResolvedValue([]);
 
         handler = new ERFDistributionUpdatedHandler(mockEvent, chainId, {
             metadataProvider: mockMetadataProvider,