Merge pull request #257 from blockful/feat/anticapture_client

Feat/anticapture client

Author: LeonardoVieira1630

.env.example

@@ -2,7 +2,7 @@
 # Copy this file to .env and configure your settings
 
 # === REQUIRED CONFIGURATION ===
-ANTICAPTURE_GRAPHQL_ENDPOINT=https://api-gateway-production-0879.up.railway.app/graphql
+ANTICAPTURE_API_URL=https://api-gateway-production-0879.up.railway.app
 BLOCKFUL_API_TOKEN=
 
 # === NOTIFICATION PLATFORMS ===
@@ -16,7 +16,9 @@ TOKEN_ENCRYPTION_KEY=  # Generate: openssl rand -hex 32
 # === LOCAL DEV CONFIGURATION ===
 DATABASE_URL=postgresql://postgres:postgres@localhost:5432/postgres
 RABBITMQ_URL=amqp://admin:admin@localhost:5672
-PORT=3003
-TRIGGER_INTERVAL=30000  # ms
-PROPOSAL_STATUS=ACTIVE
-PORT=3002
+TRIGGER_INTERVAL=30000  # ms (logic-system)
+PROPOSAL_STATUS=ACTIVE  # (logic-system)
+
+# Per-service PORT — use per-app .env files for cleaner separation
+# subscription-server PORT=3002
+# logic-system PORT=3003

.github/workflows/test.yaml

@@ -18,7 +18,7 @@ jobs:
       - uses: actions/checkout@v3
       - uses: actions/setup-node@v3
         with:
-          node-version: "20"
+          node-version: "22"
       - uses: pnpm/action-setup@v2
         with:
           version: 10.14.0

.gitignore

@@ -26,7 +26,6 @@ coverage
 out/
 build
 dist
-!packages/anticapture-client/dist
 
 # Generated GraphQL files
 **/src/generated/

AGENTS.md

@@ -6,12 +6,12 @@
 
 Event-driven notification system for DAO governance, built as a **pnpm monorepo** with 4 microservices connected via RabbitMQ:
 
-1. **Logic System** (`apps/logic-system/`) - Polls AntiCapture GraphQL API every Xs, detects governance events, publishes trigger events
+1. **Logic System** (`apps/logic-system/`) - Polls AntiCapture REST API every Xs, detects governance events, publishes trigger events
 2. **Dispatcher** (`apps/dispatcher/`) - Consumes trigger events, fetches subscribers with temporal filtering, routes notifications
 3. **Subscription Server** (`apps/subscription-server/`) - Fastify REST API for user preferences, PostgreSQL persistence, Slack OAuth
 4. **Consumer** (`apps/consumers/`) - Delivers notifications via Telegram (telegraf) and Slack (@slack/bolt) bots
 
-Supporting packages: `anticapture-client` (GraphQL), `messages` (templates), `rabbitmq-client` (AMQP wrapper).
+Supporting packages: `anticapture-client` (REST SDK wrapper), `messages` (templates), `rabbitmq-client` (AMQP wrapper).
 
 Dashboard (`apps/dashboard/`) provides read-only metrics via Next.js.
 
@@ -37,9 +37,6 @@ NODE_ENV=test pnpm --filter @notification-system/integrated-tests test
 # Type checking and linting
 pnpm consumer check-types
 pnpm logic-system lint
-
-# GraphQL code generation (requires ANTICAPTURE_GRAPHQL_ENDPOINT)
-pnpm client codegen
 ```
 
 ## Notification Pipeline
@@ -123,7 +120,7 @@ Required `.env` variables:
 ```
 DATABASE_URL=postgresql://user:pass@localhost/dbname
 RABBITMQ_URL=amqp://localhost
-ANTICAPTURE_GRAPHQL_ENDPOINT=https://...
+ANTICAPTURE_API_URL=https://...
 TELEGRAM_BOT_TOKEN=...
 SLACK_SIGNING_SECRET=...
 TOKEN_ENCRYPTION_KEY=...  # 64-char hex for AES-256-CBC
@@ -134,7 +131,7 @@ TOKEN_ENCRYPTION_KEY=...  # 64-char hex for AES-256-CBC
 - **Language:** TypeScript (strict mode) across all services
 - **Validation:** Zod schemas for environment variables and API inputs
 - **Monorepo:** pnpm workspaces + Turbo for builds
-- **Testing:** Jest with ts-jest (most services), Node.js test runner (dashboard)
+- **Testing:** Vitest (all apps + packages), MSW for HTTP/JSON stubs in integrated-tests, Node.js test runner (dashboard)
 - **Package manager:** pnpm 10.x, Node.js >= 18
 
 ## Deployment
@@ -250,8 +247,6 @@ VALUES (
 - `state = 'closed'` (not `'active'`)
 - `end` = recent past (within last 24h so trigger cursor picks it up)
 
-**Gateway note:** If the production gateway returns a GraphQL error for DAOs with `null` in non-nullable fields (e.g. `supportOffchainData`), `getDAOs()` may return an empty list and skip all offchain queries. To avoid this during local testing, run the API gateway locally pointing only to the ENS API and set `ANTICAPTURE_GRAPHQL_ENDPOINT=http://host.docker.internal:4000/graphql` in `.env`.
-
 ### New Offchain Proposal Insert (Snapshot)
 ```sql
 -- No triggers on snapshot.proposals, safe to insert directly

apps/consumers/AGENTS.md

@@ -77,7 +77,7 @@ src/
 | `TELEGRAM_BOT_TOKEN` | Yes | Telegram BotFather token |
 | `SLACK_SIGNING_SECRET` | Yes | Slack app signing secret |
 | `TOKEN_ENCRYPTION_KEY` | Yes | 64-char hex for workspace token decryption |
-| `ANTICAPTURE_GRAPHQL_ENDPOINT` | Yes | GraphQL API endpoint |
+| `ANTICAPTURE_API_URL` | Yes | REST API base URL |
 | `SUBSCRIPTION_SERVER_URL` | Yes | Subscription Server base URL |
 | `RABBITMQ_URL` | Yes | RabbitMQ connection string |
 | `PORT` | No | Slack HTTP receiver port (default: 3002) |
@@ -88,7 +88,7 @@ src/
 pnpm consumer test
 ```
 
-Uses ts-jest. Type checking: `pnpm consumer check-types`.
+Uses Vitest. Type checking: `pnpm consumer check-types`.
 
 ## Key Implementation Details
 

apps/consumers/README.md

@@ -53,14 +53,14 @@ src/
 | Variable | Required | Description |
 |----------|----------|-------------|
 | `TELEGRAM_BOT_TOKEN` | ✅ | Telegram bot authentication token |
-| `ANTICAPTURE_GRAPHQL_ENDPOINT` | ✅ | GraphQL API endpoint for DAO data |
+| `ANTICAPTURE_API_URL` | ✅ | REST API endpoint for DAO data |
 | `SUBSCRIPTION_SERVER_URL` | ✅ | Subscription management API URL |
 | `RABBITMQ_URL` | ✅ | RabbitMQ connection string |
 
 ### Example Configuration
 ```bash
 TELEGRAM_BOT_TOKEN=123456:ABC-DEF1234ghIkl-zyx57W2v1u123ew11
-ANTICAPTURE_GRAPHQL_ENDPOINT=https://api.anticapture.xyz/graphql
+ANTICAPTURE_API_URL=https://api.anticapture.xyz
 SUBSCRIPTION_SERVER_URL=http://subscription-server:3001
 RABBITMQ_URL=amqp://user:pass@rabbitmq:5672
 ```

apps/consumers/example.env

@@ -1,5 +1,5 @@
 TELEGRAM_BOT_TOKEN=your_telegram_bot_token
-ANTICAPTURE_GRAPHQL_ENDPOINT=https://api-gateway/graphql
+ANTICAPTURE_API_URL=https://api-gateway
 BLOCKFUL_API_TOKEN=
 SUBSCRIPTION_SERVER_URL=http://localhost:3001
 API_PORT=3000

apps/consumers/jest.config.js

@@ -8,24 +8,23 @@
     "dev": "nodemon --exec 'ts-node' src/index.ts",
     "build": "tsc",
     "check-types": "tsc --noEmit",
-    "test": "jest"
+    "test": "vitest run"
   },
   "keywords": [],
   "author": "",
   "license": "ISC",
   "description": "",
   "devDependencies": {
-    "@jest/globals": "^29.7.0",
-    "@types/jest": "^29.5.11",
     "@types/node": "^20.17.46",
-    "jest": "^29.7.0",
+    "msw": "^2.12.10",
     "nodemon": "^3.1.0",
-    "ts-jest": "^29.1.1",
     "ts-node": "^10.9.2",
-    "typescript": "^5.8.3"
+    "typescript": "^5.8.3",
+    "vitest": "^4.1.5"
   },
   "dependencies": {
     "@anticapture/observability": "^1.0.0",
+    "@fastify/cors": "^11.0.1",
     "@notification-system/anticapture-client": "workspace:*",
     "@notification-system/messages": "workspace:*",
     "@notification-system/rabbitmq-client": "workspace:*",
@@ -34,10 +33,9 @@
     "@slack/web-api": "^7.10.0",
     "axios": "^1.7.2",
     "dotenv": "^16.4.7",
-    "telegraf": "^4.16.3",
     "fastify": "^5.3.2",
-    "@fastify/cors": "^11.0.1",
     "fastify-type-provider-zod": "^4.0.2",
+    "telegraf": "^4.16.3",
     "viem": "^2.34.0",
     "zod": "^3.24.3"
   }

apps/consumers/package.json

@@ -1,4 +1,3 @@
-import { AxiosInstance } from 'axios';
 import { TelegramBotService } from './services/bot/telegram-bot.service';
 import { SlackBotService } from './services/bot/slack-bot.service';
 import { WebhookService } from './services/webhook/webhook.service';
@@ -11,7 +10,7 @@ import { TelegramDAOService } from './services/dao/telegram-dao.service';
 import { TelegramWalletService } from './services/wallet/telegram-wallet.service';
 import { TelegramSettingsService } from './services/settings/telegram-settings.service';
 import { ExplorerService } from '@notification-system/messages';
-import { EnsResolverService } from './services/ens-resolver.service';
+import { IEnsResolver } from './services/ens-resolver.service';
 import { AnticaptureClient } from '@notification-system/anticapture-client';
 import { SubscriptionAPIService } from './services/subscription-api.service';
 import { RabbitMQNotificationConsumerService } from './services/rabbitmq-notification-consumer.service';
@@ -34,15 +33,19 @@ export class App {
 
   constructor(
     subscriptionServerUrl: string,
-    httpClient: AxiosInstance,
+    anticaptureBaseURL: string,
     rabbitmqUrl: string,
-    ensResolver: EnsResolverService,
+    ensResolver: IEnsResolver,
     telegramClient: TelegramClientInterface,
     slackClient: SlackClientInterface,
-    webhookPort: number
+    webhookPort: number,
+    anticaptureHeaders?: Record<string, string>
   ) {
     const subscriptionApi = wrapWithTracing(new SubscriptionAPIService(subscriptionServerUrl, logger));
-    const anticaptureClient = wrapWithTracing(new AnticaptureClient(httpClient));
+    const anticaptureClient = wrapWithTracing(new AnticaptureClient({
+      baseURL: anticaptureBaseURL,
+      defaultHeaders: anticaptureHeaders,
+    }));
     const explorerService = new ExplorerService();
 
     // Telegram services