Feature/webhook delivery retry 102

backend/eslint.config.mjs

@@ -43,4 +43,10 @@ export default tseslint.config(
       }],
     },
   },
+  {
+    files: ['**/*.spec.ts', '**/*.test.ts'],
+    rules: {
+      '@typescript-eslint/unbound-method': 'off',
+    },
+  },
 );

backend/package.json

@@ -32,16 +32,19 @@
   },
   "dependencies": {
     "@invoisio/soroban-client": "file:../soroban/client",
+    "@nestjs/axios": "^4.0.1",
     "@nestjs/common": "^11.0.1",
     "@nestjs/config": "^4.0.2",
     "@nestjs/core": "^11.0.1",
     "@nestjs/jwt": "^11.0.2",
     "@nestjs/passport": "^11.0.5",
     "@nestjs/platform-express": "^11.0.1",
+    "@nestjs/schedule": "^6.1.1",
     "@nestjs/typeorm": "^11.0.0",
     "@prisma/adapter-pg": "^7.4.2",
     "@prisma/client": "^7.4.2",
     "@stellar/stellar-sdk": "^14.6.0",
+    "axios": "^1.13.6",
     "class-transformer": "^0.5.1",
     "class-validator": "^0.14.2",
     "cross-env": "^10.1.0",
@@ -115,4 +118,4 @@
     "coverageDirectory": "../coverage",
     "testEnvironment": "node"
   }
-}
+}

backend/prisma/migrations/20260307171500_add_webhooks/migration.sql

@@ -0,0 +1,29 @@
+-- CreateEnum
+CREATE TYPE "DeliveryStatus" AS ENUM ('pending', 'success', 'failed');
+
+-- AlterTable
+ALTER TABLE "users" ADD COLUMN     "webhook_url" TEXT,
+ADD COLUMN     "webhook_secret" TEXT;
+
+-- CreateTable
+CREATE TABLE "webhook_deliveries" (
+    "id" TEXT NOT NULL,
+    "invoice_id" TEXT NOT NULL,
+    "user_id" TEXT NOT NULL,
+    "url" TEXT NOT NULL,
+    "payload" JSONB NOT NULL,
+    "status" "DeliveryStatus" NOT NULL DEFAULT 'pending',
+    "attempts" INTEGER NOT NULL DEFAULT 0,
+    "last_attempt_at" TIMESTAMP(3),
+    "next_attempt_at" TIMESTAMP(3),
+    "created_at" TIMESTAMP(3) NOT NULL DEFAULT CURRENT_TIMESTAMP,
+    "updated_at" TIMESTAMP(3) NOT NULL,
+
+    CONSTRAINT "webhook_deliveries_pkey" PRIMARY KEY ("id")
+);
+
+-- AddForeignKey
+ALTER TABLE "webhook_deliveries" ADD CONSTRAINT "webhook_deliveries_invoice_id_fkey" FOREIGN KEY ("invoice_id") REFERENCES "invoices"("id") ON DELETE CASCADE ON UPDATE CASCADE;
+
+-- AddForeignKey
+ALTER TABLE "webhook_deliveries" ADD CONSTRAINT "webhook_deliveries_user_id_fkey" FOREIGN KEY ("user_id") REFERENCES "users"("id") ON DELETE CASCADE ON UPDATE CASCADE;

backend/prisma/schema.prisma

@@ -20,11 +20,39 @@ model User {
   createdAt      DateTime  @default(now())
   updatedAt      DateTime  @updatedAt
 
+  webhookUrl     String?   @map("webhook_url")
+  webhookSecret  String?   @map("webhook_secret")
+
   invoices Invoice[]
+  webhooks WebhookDelivery[]
 
   @@map("users")
 }
 
+model WebhookDelivery {
+  id             String         @id @default(uuid())
+  invoiceId      String         @map("invoice_id")
+  invoice        Invoice        @relation(fields: [invoiceId], references: [id], onDelete: Cascade)
+  userId         String         @map("user_id")
+  user           User           @relation(fields: [userId], references: [id], onDelete: Cascade)
+  url            String
+  payload        Json
+  status         DeliveryStatus @default(pending)
+  attempts       Int            @default(0)
+  lastAttemptAt  DateTime?      @map("last_attempt_at")
+  nextAttemptAt  DateTime?      @map("next_attempt_at")
+  createdAt      DateTime       @default(now()) @map("created_at")
+  updatedAt      DateTime       @updatedAt @map("updated_at")
+
+  @@map("webhook_deliveries")
+}
+
+enum DeliveryStatus {
+  pending
+  success
+  failed
+}
+
 // Invoice model matching backend/src/invoices/entities/invoice.entity.ts
 model Invoice {
   id                 String        @id @default(uuid())
@@ -49,6 +77,8 @@ model Invoice {
   createdAt          DateTime      @default(now()) @map("created_at")
   updatedAt          DateTime      @updatedAt @map("updated_at")
 
+  webhooks           WebhookDelivery[]
+
   @@map("invoices")
 }
 

backend/src/app.module.ts

@@ -14,6 +14,8 @@ import { HorizonWatcherModule } from "./stellar/horizon-watcher.module";
 import { AuthModule } from "./auth/auth.module";
 import { UsersModule } from "./users/user.module";
 import { PrismaModule } from "./prisma/prisma.module";
+import { ScheduleModule } from "@nestjs/schedule";
+import { WebhooksModule } from "./webhooks/webhooks.module";
 
 /**
  * Root application module
@@ -51,12 +53,14 @@ import { PrismaModule } from "./prisma/prisma.module";
       }),
     }),
     PrismaModule,
+    ScheduleModule.forRoot(),
     HealthModule,
     InvoicesModule,
     StellarModule,
     HorizonWatcherModule,
     AuthModule,
     UsersModule,
+    WebhooksModule,
   ],
 })
 export class AppModule {}

backend/src/invoices/invoices.module.ts

@@ -7,6 +7,7 @@ import { StellarModule } from "../stellar/stellar.module";
 import { SorobanModule } from "../soroban/soroban.module";
 import { AuthGuard } from "../auth/auth.guard";
 import { PrismaModule } from "../prisma/prisma.module";
+import { WebhooksModule } from "../webhooks/webhooks.module";
 
 /**
  * Invoices module
@@ -17,6 +18,7 @@ import { PrismaModule } from "../prisma/prisma.module";
     StellarModule,
     SorobanModule,
     PrismaModule,
+    WebhooksModule,
     JwtModule.registerAsync({
       imports: [ConfigModule],
       inject: [ConfigService],

backend/src/invoices/invoices.service.spec.ts

@@ -7,6 +7,7 @@ import { CreateInvoiceDto } from "./dto/create-invoice.dto";
 import { validate } from "class-validator";
 import { plainToInstance } from "class-transformer";
 import { PrismaService } from "../prisma/prisma.service";
+import { WebhooksService } from "../webhooks/webhooks.service";
 
 describe("InvoicesService", () => {
   let service: InvoicesService;
@@ -195,6 +196,10 @@ describe("InvoicesService", () => {
     };
   };
 
+  const mockWebhooksService = {
+    enqueueWebhook: jest.fn().mockResolvedValue(undefined),
+  };
+
   beforeEach(async () => {
     const module: TestingModule = await Test.createTestingModule({
       providers: [
@@ -203,6 +208,7 @@ describe("InvoicesService", () => {
         { provide: StellarService, useValue: mockStellarService },
         { provide: SorobanService, useValue: mockSorobanService },
         { provide: PrismaService, useFactory: mockPrisma },
+        { provide: WebhooksService, useValue: mockWebhooksService },
       ],
     }).compile();
 

backend/src/invoices/invoices.service.ts

@@ -11,6 +11,7 @@ import { StellarService } from "../stellar/stellar.service";
 import { SorobanService } from "../soroban/soroban.service";
 import { PrismaService } from "../prisma/prisma.service";
 import { Prisma, InvoiceStatus } from "@prisma/client";
+import { WebhooksService } from "../webhooks/webhooks.service";
 
 /**
  * Invoices service — manages invoice lifecycle and Soroban on-chain settlement.
@@ -24,6 +25,7 @@ export class InvoicesService implements OnModuleInit {
     private readonly stellarService: StellarService,
     private readonly sorobanService: SorobanService,
     private readonly prisma: PrismaService,
+    private readonly webhooksService: WebhooksService,
   ) {}
 
   async onModuleInit() {
@@ -122,6 +124,10 @@ export class InvoicesService implements OnModuleInit {
       where: { id },
       data: { status },
     });
+
+    // Enqueue webhook
+    await this.webhooksService.enqueueWebhook(id, status, updated.txHash);
+
     return this.normalizeInvoice(updated);
   }
 
@@ -136,6 +142,10 @@ export class InvoicesService implements OnModuleInit {
       where: { id },
       data: { status: "paid", txHash: txHash },
     });
+
+    // Enqueue webhook
+    await this.webhooksService.enqueueWebhook(id, "paid", txHash);
+
     return this.normalizeInvoice(updated);
   }
 

backend/src/stellar/soroban.integration.spec.ts

@@ -107,13 +107,11 @@ describe("Soroban Integration", () => {
 
       await new Promise((resolve) => setTimeout(resolve, 100));
 
-      // eslint-disable-next-line @typescript-eslint/unbound-method
       expect(invoicesService.markAsPaid).toHaveBeenCalledWith(
         mockInvoice.id,
         "horizon-tx-hash-abc",
       );
 
-      // eslint-disable-next-line @typescript-eslint/unbound-method
       expect(sorobanService.recordPayment).toHaveBeenCalledWith({
         invoiceId: mockInvoice.memo,
         payer: mockPaymentRecord.from,
@@ -122,7 +120,6 @@ describe("Soroban Integration", () => {
         amount: "100000000",
       });
 
-      // eslint-disable-next-line @typescript-eslint/unbound-method
       expect(invoicesService.updateSorobanMetadata).toHaveBeenCalledWith(
         mockInvoice.id,
         "soroban-tx-hash-xyz",
@@ -146,11 +143,10 @@ describe("Soroban Integration", () => {
 
       await new Promise((resolve) => setTimeout(resolve, 100));
 
-      // eslint-disable-next-line @typescript-eslint/unbound-method
       expect(invoicesService.markAsPaid).toHaveBeenCalled();
-      // eslint-disable-next-line @typescript-eslint/unbound-method
+
       expect(sorobanService.recordPayment).toHaveBeenCalled();
-      // eslint-disable-next-line @typescript-eslint/unbound-method
+
       expect(invoicesService.updateSorobanMetadata).not.toHaveBeenCalled();
     });
 
@@ -179,7 +175,6 @@ describe("Soroban Integration", () => {
 
       await new Promise((resolve) => setTimeout(resolve, 100));
 
-      // eslint-disable-next-line @typescript-eslint/unbound-method
       expect(sorobanService.recordPayment).toHaveBeenCalledWith(
         expect.objectContaining({
           assetCode: "USDC",

backend/src/webhooks/webhooks.module.ts

@@ -0,0 +1,10 @@
+import { Module } from "@nestjs/common";
+import { PrismaModule } from "../prisma/prisma.module";
+import { WebhooksService } from "./webhooks.service";
+
+@Module({
+  imports: [PrismaModule],
+  providers: [WebhooksService],
+  exports: [WebhooksService],
+})
+export class WebhooksModule {}