chore: rebase with upstream (#7)

* fix: e2e (#102)

## 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.


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

- **Tests**
  - Introduced a new automated end-to-end testing workflow.
- Standardized wait times in test setups for improved consistency across
scenarios.

- **Chores**
- Updated continuous integration configurations with refined naming and
sequencing for enhanced clarity and reliability during test executions.
<!-- end of auto-generated comment: release notes by coderabbit.ai -->

* chore: increase fetch limit to 200

---------

Co-authored-by: 0xkenj1 <[email protected]>

Author: thelostone-mc

.github/workflows/e2e-tests.yml

@@ -0,0 +1,23 @@
+name: E2E Tests
+
+on:
+    workflow_call:
+
+jobs:
+    e2e:
+        name: E2E Tests
+        runs-on: ubuntu-latest
+        steps:
+            - name: Check out github repository
+              uses: actions/checkout@v4
+              with:
+                  fetch-depth: 1
+
+            - name: Setup environment
+              uses: ./.github/actions/setup
+
+            - name: Install dependencies
+              run: pnpm install --frozen-lockfile
+
+            - name: Run tests
+              run: pnpm test:e2e

.github/workflows/main-workflow.yml

@@ -25,3 +25,7 @@ jobs:
     test:
         uses: ./.github/workflows/test.yml
         needs: lint
+
+    e2e-tests:
+        uses: ./.github/workflows/e2e-tests.yml
+        needs: test

.github/workflows/test.yml

@@ -1,11 +1,11 @@
-name: Tests
+name: Unit and Integration Tests
 
 on:
     workflow_call:
 
 jobs:
     unit:
-        name: Tests
+        name: Unit and Integration Tests
         runs-on: ubuntu-latest
         steps:
             - name: Check out github repository

scripts/hasura-config/src/index.ts

@@ -5,7 +5,7 @@ import { CustomFunction, HasuraMetadataApi, RelationshipConfig } from "./interna
 
 configDotenv();
 
-const DEFAULT_PUBLIC_FETCH_LIMIT = 50;
+const DEFAULT_PUBLIC_FETCH_LIMIT = 200;
 
 const envSchema = z.object({
     HASURA_ENDPOINT: z.string().url(),

tests/e2e/test/globalSetup.ts

@@ -2,6 +2,11 @@ import type { TestProject } from "vitest/node";
 
 import { TestEnvironment } from "../src/utils/test-environment.js";
 
+/**
+ * Delay in milliseconds to wait for the processing service to finish processing events
+ */
+export const PROCESSING_SERVICE_RUNNING_DELAY_MS = 10000;
+
 let env: TestEnvironment | undefined;
 
 /**

tests/e2e/test/scenarios/allocation.spec-e2e.ts

@@ -4,6 +4,7 @@ import { beforeAll, describe, expect, inject, it } from "vitest";
 import { Bytes32String, IndexerFetchedEvent, TimestampMs } from "@grants-stack-indexer/shared";
 
 import { TestHelper } from "../../src/utils/test-helper.js";
+import { PROCESSING_SERVICE_RUNNING_DELAY_MS } from "../globalSetup.js";
 
 /**
  * This test suite covers allocation event types:
@@ -272,7 +273,9 @@ describe("Allocation Events", () => {
             ]);
 
             await testHelper.startProcessingService();
-            await new Promise((resolve) => setTimeout(resolve, 4000));
+            await new Promise((resolve) =>
+                setTimeout(resolve, PROCESSING_SERVICE_RUNNING_DELAY_MS),
+            );
             await testHelper.stopProcessingService();
         });
 

tests/e2e/test/scenarios/attestation.spec-e2e.ts

@@ -4,6 +4,7 @@ import { beforeAll, describe, expect, inject, it } from "vitest";
 import { Bytes32String, IndexerFetchedEvent, TimestampMs } from "@grants-stack-indexer/shared";
 
 import { TestHelper } from "../../src/utils/test-helper.js";
+import { PROCESSING_SERVICE_RUNNING_DELAY_MS } from "../globalSetup.js";
 
 /**
  * This test suite covers attestation scenarios:
@@ -206,7 +207,7 @@ describe("Attestation Events", () => {
                 fetchDelayMs: 5000,
             },
         ]);
-        await new Promise((resolve) => setTimeout(resolve, 3500));
+        await new Promise((resolve) => setTimeout(resolve, PROCESSING_SERVICE_RUNNING_DELAY_MS));
         await testHelper.stopProcessingService();
         await testHelperOtherChain.stopProcessingService();
     });

tests/e2e/test/scenarios/profileCreated.spec-e2e.ts

@@ -4,6 +4,7 @@ import { beforeAll, describe, expect, inject, it } from "vitest";
 import { Bytes32String, IndexerFetchedEvent, TimestampMs } from "@grants-stack-indexer/shared";
 
 import { TestHelper } from "../../src/utils/test-helper.js";
+import { PROCESSING_SERVICE_RUNNING_DELAY_MS } from "../globalSetup.js";
 
 describe("Profile Created", () => {
     let testHelper: TestHelper;
@@ -54,7 +55,7 @@ describe("Profile Created", () => {
 
         await testHelper.startProcessingService();
         // give some time to fetch the events
-        await new Promise((resolve) => setTimeout(resolve, 1000));
+        await new Promise((resolve) => setTimeout(resolve, PROCESSING_SERVICE_RUNNING_DELAY_MS));
         await testHelper.stopProcessingService();
     });
 

tests/e2e/test/scenarios/roundApplication.spec-e2e.ts

@@ -5,6 +5,7 @@ import { beforeAll, describe, expect, expectTypeOf, inject, it } from "vitest";
 import { Bytes32String, IndexerFetchedEvent, TimestampMs } from "@grants-stack-indexer/shared";
 
 import { TestHelper } from "../../src/utils/test-helper.js";
+import { PROCESSING_SERVICE_RUNNING_DELAY_MS } from "../globalSetup.js";
 
 /**
  * Happy path events sequence:
@@ -133,7 +134,7 @@ describe("DVMD Round creation with Pending Role and Application", () => {
         ]);
 
         await testHelper.startProcessingService();
-        await new Promise((resolve) => setTimeout(resolve, 2500));
+        await new Promise((resolve) => setTimeout(resolve, PROCESSING_SERVICE_RUNNING_DELAY_MS));
         await testHelper.stopProcessingService();
     });
 
@@ -528,7 +529,7 @@ describe("Unsupported Strategy and Events", () => {
         ]);
 
         await testHelper.startProcessingService();
-        await new Promise((resolve) => setTimeout(resolve, 1500));
+        await new Promise((resolve) => setTimeout(resolve, 10000));
         await testHelper.stopProcessingService();
     });
 

tests/e2e/test/scenarios/searchProjects.spec-e2e.ts

@@ -4,6 +4,7 @@ import { beforeAll, describe, expect, inject, it } from "vitest";
 import { Bytes32String, Hex, IndexerFetchedEvent, TimestampMs } from "@grants-stack-indexer/shared";
 
 import { TestHelper } from "../../src/utils/test-helper.js";
+import { PROCESSING_SERVICE_RUNNING_DELAY_MS } from "../globalSetup.js";
 
 describe("Search Projects", () => {
     let testHelper: TestHelper;
@@ -84,7 +85,7 @@ describe("Search Projects", () => {
         await testHelper.addEvents(events);
 
         await testHelper.startProcessingService();
-        await new Promise((resolve) => setTimeout(resolve, 2000));
+        await new Promise((resolve) => setTimeout(resolve, PROCESSING_SERVICE_RUNNING_DELAY_MS));
         await testHelper.stopProcessingService();
     });