Merge pull request #225 from blockful/feat/anticapture-api-auth-token

feat: add Bearer token auth for Anticapture API Gateway

Author: pikonha

.env.example

@@ -3,6 +3,7 @@
 
 # === REQUIRED CONFIGURATION ===
 ANTICAPTURE_GRAPHQL_ENDPOINT=https://api-gateway-production-0879.up.railway.app/graphql
+BLOCKFUL_API_TOKEN=
 
 # === NOTIFICATION PLATFORMS ===
 TELEGRAM_BOT_TOKEN=

apps/consumers/example.env

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

apps/consumers/src/config/env.ts

@@ -10,6 +10,7 @@ const envSchema = z.object({
   SLACK_SIGNING_SECRET: z.string(),
   TOKEN_ENCRYPTION_KEY: z.string(),
   ANTICAPTURE_GRAPHQL_ENDPOINT: z.string().url("ANTICAPTURE_GRAPHQL_ENDPOINT must be a valid URL"),
+  BLOCKFUL_API_TOKEN: z.string().optional(),
   SUBSCRIPTION_SERVER_URL: z.string(),
   RABBITMQ_URL: z.string().url(),
   PORT: z.coerce.number().positive().optional().default(3002),
@@ -24,6 +25,7 @@ export function loadConfig() {
     slackSigningSecret: env.SLACK_SIGNING_SECRET,
     tokenEncryptionKey: env.TOKEN_ENCRYPTION_KEY,
     anticaptureGraphqlEndpoint: env.ANTICAPTURE_GRAPHQL_ENDPOINT,
+    blockfulApiToken: env.BLOCKFUL_API_TOKEN,
     subscriptionServerUrl: env.SUBSCRIPTION_SERVER_URL,
     rabbitmqUrl: env.RABBITMQ_URL,
     port: env.PORT,

apps/consumers/src/index.ts

@@ -35,7 +35,14 @@ const slackClient = new SlackClient(
 // Create and start the application
 const app = new App(
   config.subscriptionServerUrl,
-  axios.create({ baseURL: config.anticaptureGraphqlEndpoint }),
+  axios.create({
+    baseURL: config.anticaptureGraphqlEndpoint,
+    headers: {
+      ...(config.blockfulApiToken && {
+        Authorization: `Bearer ${config.blockfulApiToken}`,
+      }),
+    },
+  }),
   config.rabbitmqUrl,
   ensResolver,
   telegramClient,

apps/dispatcher/src/app.ts

@@ -23,7 +23,8 @@ export class App {
     private subscriptionServerUrl: string, 
     private rabbitmqUrl: string,
     private anticaptureGraphqlEndpoint: string,
-    private anticaptureHttpClient?: any
+    private anticaptureHttpClient?: any,
+    private blockfulApiToken?: string
   ) {}
 
   private async setupServices(): Promise<void> {
@@ -42,6 +43,9 @@ export class App {
       baseURL: this.anticaptureGraphqlEndpoint,
       headers: {
         'Content-Type': 'application/json',
+        ...(this.blockfulApiToken && {
+          Authorization: `Bearer ${this.blockfulApiToken}`,
+        }),
       },
     });
     const anticaptureClient = new AnticaptureClient(anticaptureAxiosClient);

apps/dispatcher/src/envConfig.ts

@@ -11,6 +11,7 @@ const envSchema = z.object({
   SUBSCRIPTION_SERVER_URL: z.string().url(),
   RABBITMQ_URL: z.string().url(),
   ANTICAPTURE_GRAPHQL_ENDPOINT: z.string().url(),
+  BLOCKFUL_API_TOKEN: z.string().optional(),
 });
 
 export function loadConfig() {
@@ -21,5 +22,6 @@ export function loadConfig() {
     subscriptionServerUrl: env.SUBSCRIPTION_SERVER_URL,
     rabbitmqUrl: env.RABBITMQ_URL,
     anticaptureGraphqlEndpoint: env.ANTICAPTURE_GRAPHQL_ENDPOINT,
+    blockfulApiToken: env.BLOCKFUL_API_TOKEN,
   } as const;
 } 

apps/dispatcher/src/index.ts

@@ -5,7 +5,9 @@ const config = loadConfig();
 const app = new App(
   config.subscriptionServerUrl, 
   config.rabbitmqUrl, 
-  config.anticaptureGraphqlEndpoint
+  config.anticaptureGraphqlEndpoint,
+  undefined,
+  config.blockfulApiToken
 );
 
 (async () => {

apps/logic-system/.env.example

@@ -1,5 +1,6 @@
 # Anticapture GraphQL API
 ANTICAPTURE_GRAPHQL_ENDPOINT="https://api-gateway/graphql"
+BLOCKFUL_API_TOKEN=
 
 # Dispatcher service configuration
 DISPATCHER_ENDPOINT="http://localhost:3000/api/dispatch"

apps/logic-system/src/config/env.ts

@@ -13,6 +13,7 @@ const validProposalStatuses = [
 // Define environment variables schema with validation
 const envSchema = z.object({
   ANTICAPTURE_GRAPHQL_ENDPOINT: z.string().url('ANTICAPTURE_GRAPHQL_ENDPOINT must be a valid URL'),
+  BLOCKFUL_API_TOKEN: z.string().optional(),
   RABBITMQ_URL: z.string().url(),
   TRIGGER_INTERVAL: z.coerce.number().optional().default(60000),
   PROPOSAL_STATUS: z.enum(validProposalStatuses),

apps/logic-system/src/index.ts

@@ -5,7 +5,14 @@ import { env } from './config/env';
 const app = new App(
   env.TRIGGER_INTERVAL,
   env.PROPOSAL_STATUS,
-  axios.create({ baseURL: env.ANTICAPTURE_GRAPHQL_ENDPOINT }),
+  axios.create({
+    baseURL: env.ANTICAPTURE_GRAPHQL_ENDPOINT,
+    headers: {
+      ...(env.BLOCKFUL_API_TOKEN && {
+        Authorization: `Bearer ${env.BLOCKFUL_API_TOKEN}`,
+      }),
+    },
+  }),
   env.RABBITMQ_URL,
 );