Stripe webhook updates for ACH transfer (#357)

<!-- This is an auto-generated comment: release notes by coderabbit.ai
-->
## Summary by CodeRabbit

* **New Features**
* Automatic recording and acknowledgement of successful Stripe payments
(captures amount, currency, status, billing email, timestamp, and event
identifier).
* **Chores**
* Added a configuration option to specify where Stripe payment records
are stored.
* **Continued**
* Continued support for bank transfer funding and automatic tracking of
bank-transfer transactions.
<!-- end of auto-generated comment: release notes by coderabbit.ai -->

---------

Co-authored-by: github-actions[bot] <41898282+github-actions[bot]@users.noreply.github.com>

Author: AdityaK2905

src/api/routes/stripe.ts

@@ -3,6 +3,7 @@ import {
   ScanCommand,
   TransactWriteItemsCommand,
   UpdateItemCommand,
+  PutItemCommand,
 } from "@aws-sdk/client-dynamodb";
 import { marshall, unmarshall } from "@aws-sdk/util-dynamodb";
 import { withRoles, withTags } from "api/components/index.js";
@@ -715,7 +716,88 @@ Please contact Officer Board with any questions.`,
           return reply
             .code(200)
             .send({ handled: false, requestId: request.id });
+        case "payment_intent.succeeded": {
+          const intent = event.data.object as Stripe.PaymentIntent;
 
+          const amount = intent.amount_received;
+          const currency = intent.currency;
+          const customerId = intent.customer?.toString();
+          const email = intent.receipt_email ?? intent.metadata?.billing_email;
+          const acmOrg = intent.metadata?.acm_org;
+
+          if (!customerId) {
+            request.log.info("Skipping payment intent with no customer ID.");
+            return reply
+              .code(200)
+              .send({ handled: false, requestId: request.id });
+          }
+
+          if (!email) {
+            request.log.warn("Missing email for payment intent.");
+            return reply
+              .code(200)
+              .send({ handled: false, requestId: request.id });
+          }
+
+          if (!acmOrg) {
+            request.log.warn("Missing acm_org for payment intent.");
+            return reply
+              .code(200)
+              .send({ handled: false, requestId: request.id });
+          }
+
+          const normalizedEmail = email.trim();
+          if (!normalizedEmail.includes("@")) {
+            request.log.warn("Invalid email format for payment intent.");
+            return reply
+              .code(200)
+              .send({ handled: false, requestId: request.id });
+          }
+          const [, domainPart] = normalizedEmail.split("@");
+          if (!domainPart) {
+            request.log.warn(
+              "Could not derive email domain for payment intent.",
+            );
+            return reply
+              .code(200)
+              .send({ handled: false, requestId: request.id });
+          }
+          const domain = domainPart.toLowerCase();
+
+          try {
+            await fastify.dynamoClient.send(
+              new PutItemCommand({
+                TableName: genericConfig.StripePaymentsDynamoTableName,
+                Item: marshall({
+                  primaryKey: `${acmOrg}#${domain}`,
+                  sortKey: event.id,
+                  amount,
+                  currency,
+                  status: "succeeded",
+                  billingEmail: normalizedEmail,
+                  createdAt: new Date().toISOString(),
+                  eventId: event.id,
+                }),
+              }),
+            );
+
+            request.log.info(
+              `Recorded successful payment ${intent.id} from ${normalizedEmail} (${amount} ${currency})`,
+            );
+
+            return reply
+              .status(200)
+              .send({ handled: true, requestId: request.id });
+          } catch (e) {
+            if (e instanceof BaseError) {
+              throw e;
+            }
+            request.log.error(e);
+            throw new DatabaseInsertError({
+              message: `Could not insert Stripe payment record: ${(e as Error).message}`,
+            });
+          }
+        }
         default:
           request.log.warn(`Unhandled event type: ${event.type}`);
       }

src/common/config.ts

@@ -41,6 +41,7 @@ export type GenericConfigType = {
   CacheDynamoTableName: string;
   LinkryDynamoTableName: string;
   StripeLinksDynamoTableName: string;
+  StripePaymentsDynamoTableName: string;
   EntraSecretName: string;
   UpcomingEventThresholdSeconds: number;
   AwsRegion: string;
@@ -84,6 +85,7 @@ export const commChairsGroupId = "105e7d32-7289-435e-a67a-552c7f215507";
 const genericConfig: GenericConfigType = {
   EventsDynamoTableName: "infra-core-api-events",
   StripeLinksDynamoTableName: "infra-core-api-stripe-links",
+  StripePaymentsDynamoTableName: "infra-core-api-stripe-payments",
   CacheDynamoTableName: "infra-core-api-cache",
   LinkryDynamoTableName: "infra-core-api-linkry",
   EntraSecretName: "infra-core-api-entra",