feat: integrate webhooks in the indexer (#114)

Signed-off-by: david <[email protected]> Co-authored-by: david <[email protected]>
across-protocol · Nov 26, 2024 · 22ddb90 · 22ddb90
1 parent 969a6a9
commit 22ddb90
Show file tree

Hide file tree

Showing 27 changed files with 452 additions and 557 deletions.
diff --git a/packages/indexer-api/src/main.ts b/packages/indexer-api/src/main.ts
@@ -87,10 +87,10 @@ export async function Main(
   const redis = await initializeRedis(redisConfig, logger);
   const webhooks = Webhooks.WebhookFactory(
     {
-      requireApiKey: false,
       enabledWebhooks: [Webhooks.WebhookTypes.DepositStatus],
+      enabledWebhookRequestWorkers: false,
     },
-    { postgres, logger },
+    { postgres, logger, redis },
   );
 
   const allRouters: Record<string, Router> = {

diff --git a/packages/indexer-database/src/entities/WebhookClient.ts b/packages/indexer-database/src/entities/WebhookClient.ts
@@ -1,14 +1,15 @@
-import { Entity, PrimaryColumn, Column, PrimaryGeneratedColumn } from "typeorm";
+import { Entity, Column, PrimaryGeneratedColumn, Unique } from "typeorm";
 
 @Entity()
+@Unique("UK_webhook_client_api_key", ["apiKey"])
 export class WebhookClient {
+  @PrimaryGeneratedColumn()
+  id: number;
+
   @Column()
   name: string;
 
-  @PrimaryGeneratedColumn()
-  id: string;
-
-  @Column({ unique: true })
+  @Column()
   apiKey: string;
 
   @Column("jsonb")

diff --git a/packages/indexer-database/src/entities/WebhookRequest.ts b/packages/indexer-database/src/entities/WebhookRequest.ts
@@ -1,16 +1,28 @@
-import { Entity, PrimaryColumn, Column } from "typeorm";
+import {
+  Entity,
+  PrimaryColumn,
+  Column,
+  Unique,
+  CreateDateColumn,
+  Index,
+} from "typeorm";
 
 @Entity()
+@Unique("UK_webhook_request_clientId_filter", ["clientId", "filter"])
+@Index("IX_webhook_request_filter", ["filter"])
 export class WebhookRequest {
   @PrimaryColumn()
   id: string;
 
+  @Column({ type: "integer" })
+  clientId: number;
+
   @Column()
   url: string;
 
   @Column()
   filter: string;
 
-  @Column({ type: "text", nullable: true, default: undefined })
-  clientId?: string | undefined;
+  @CreateDateColumn()
+  createdAt: Date;
 }
diff --git a/packages/indexer-database/src/main.ts b/packages/indexer-database/src/main.ts
@@ -36,6 +36,9 @@ export const createDataSource = (config: DatabaseConfig): DataSource => {
       entities.RootBundleExecutedJoinTable,
       // Others
       entities.RelayHashInfo,
+      // Webhooks
+      entities.WebhookRequest,
+      entities.WebhookClient,
     ],
     migrationsTableName: "_migrations",
     migrations: ["migrations/*.ts"],

diff --git a/packages/indexer-database/src/migrations/1732198003042-Webhook.ts b/packages/indexer-database/src/migrations/1732198003042-Webhook.ts