feat: add client payment schema and webhook handling of payments

Author: bassgeta

src/app/api/webhook/route.ts

@@ -4,6 +4,8 @@ import { generateInvoiceNumber } from "@/lib/helpers/client";
 import { getInvoiceCount } from "@/lib/helpers/invoice";
 import { db } from "@/server/db";
 import {
+  clientPaymentTable,
+  ecommerceClientTable,
   paymentDetailsPayersTable,
   recurringPaymentTable,
   type requestStatusEnum,
@@ -14,6 +16,37 @@ import { and, eq, not } from "drizzle-orm";
 import { NextResponse } from "next/server";
 import { ulid } from "ulid";
 
+async function addClientPayment(webhookBody: any) {
+  await db.transaction(async (tx) => {
+    const ecommerceClient = await tx
+      .select()
+      .from(ecommerceClientTable)
+      .where(eq(ecommerceClientTable.rnClientId, webhookBody.clientId))
+      .limit(1);
+
+    if (!ecommerceClient.length) {
+      throw new ResourceNotFoundError(
+        `No ecommerce client found with client ID: ${webhookBody.clientId}`,
+      );
+    }
+
+    const client = ecommerceClient[0];
+
+    await tx.insert(clientPaymentTable).values({
+      id: ulid(),
+      userId: client.userId,
+      requestId: webhookBody.requestId,
+      invoiceCurrency: webhookBody.currency,
+      paymentCurrency: webhookBody.paymentCurrency,
+      amount: webhookBody.amount,
+      customerInfo: webhookBody.customerInfo || null,
+      reference: webhookBody.reference || null,
+      clientId: webhookBody.clientId,
+      origin: webhookBody.origin,
+    });
+  });
+}
+
 /**
  * Updates the request status in the database
  */
@@ -132,6 +165,8 @@ export async function POST(req: Request) {
             txHash: body.txHash,
             requestScanUrl: body.explorer,
           });
+        } else if (body.clientId) {
+          await addClientPayment(body);
         } else {
           await updateRequestStatus(
             requestId,

src/server/db/schema.ts

@@ -177,6 +177,35 @@ export const paymentDetailsPayersTable = createTable("payment_details_payers", {
   createdAt: timestamp("created_at").defaultNow(),
 });
 
+export const clientPaymentTable = createTable("client_payment", {
+  id: text().primaryKey().notNull(),
+  userId: text()
+    .notNull()
+    .references(() => userTable.id, {
+      onDelete: "cascade",
+    }),
+  requestId: text().notNull(),
+  invoiceCurrency: text().notNull(),
+  paymentCurrency: text().notNull(),
+  amount: text().notNull(),
+  customerInfo: json().$type<{
+    firstName?: string;
+    lastName?: string;
+    email?: string;
+    address?: {
+      street?: string;
+      city?: string;
+      state?: string;
+      postalCode?: string;
+      country?: string;
+    };
+  }>(),
+  reference: text(),
+  clientId: text().notNull(),
+  origin: text(),
+  createdAt: timestamp("created_at").defaultNow(),
+});
+
 export const requestTable = createTable("request", {
   id: text().primaryKey().notNull(),
   type: text().notNull(),
@@ -322,6 +351,9 @@ export const ecommerceClientTable = createTable(
       table.userId,
       table.domain,
     ),
+    clientIdIndex: uniqueIndex("ecommerce_client_user_id_client_id_unique").on(
+      table.rnClientId,
+    ),
   }),
 );
 
@@ -332,6 +364,7 @@ export const userRelations = relations(userTable, ({ many }) => ({
   session: many(sessionTable),
   invoiceMe: many(invoiceMeTable),
   paymentDetailsPayers: many(paymentDetailsPayersTable),
+  clientPayments: many(clientPaymentTable),
 }));
 
 export const requestRelations = relations(requestTable, ({ one }) => ({
@@ -394,6 +427,16 @@ export const ecommerceClientRelations = relations(
   }),
 );
 
+export const clientPaymentRelations = relations(
+  clientPaymentTable,
+  ({ one }) => ({
+    user: one(userTable, {
+      fields: [clientPaymentTable.userId],
+      references: [userTable.id],
+    }),
+  }),
+);
+
 export const paymentDetailsRelations = relations(
   paymentDetailsTable,
   ({ one, many }) => ({
@@ -430,3 +473,4 @@ export type PaymentDetailsPayers = InferSelectModel<
 >;
 export type RecurringPayment = InferSelectModel<typeof recurringPaymentTable>;
 export type EcommerceClient = InferSelectModel<typeof ecommerceClientTable>;
+export type ClientPayment = InferSelectModel<typeof clientPaymentTable>;