implemented webhook handling for customer_cash_balance_transaction.created event

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";
@@ -332,6 +333,7 @@ const stripeRoutes: FastifyPluginAsync = async (fastify, _options) => {
           sig,
           secretApiConfig.stripe_links_endpoint_secret as string,
         );
+        // event = JSON.parse(request.rawBody.toString()); <-- this is for testing without a stripe account via Curl
       } catch (err: unknown) {
         if (err instanceof BaseError) {
           throw err;
@@ -715,7 +717,57 @@ Please contact Officer Board with any questions.`,
           return reply
             .code(200)
             .send({ handled: false, requestId: request.id });
+        case "customer_cash_balance_transaction.created": {
+          const txn = event.data.object as any;
 
+          if (txn.funding_method === "bank_transfer") {
+            const customerId = txn.customer?.toString() ?? "UNKNOWN";
+            const amount = txn.net_amount;
+            const currency = txn.currency;
+            const status = txn.status;
+            const eventId = event.id;
+
+            request.log.info(
+              `Received ACH push ${status} txn ${txn.id} for ${customerId} (${amount} ${currency})`,
+            );
+
+            await fastify.dynamoClient.send(
+              new PutItemCommand({
+                TableName: genericConfig.StripePaymentsDynamoTableName,
+                Item: marshall({
+                  primaryKey: `CUSTOMER#${customerId}`,
+                  sortKey: `PAY#${txn.id}`,
+                  amount,
+                  currency,
+                  status,
+                  createdAt: Date.now(),
+                  eventId,
+                }),
+              }),
+            );
+
+            // if (status === "succeeded") {
+            //   await fastify.dynamoClient.send(
+            //     new UpdateItemCommand({
+            //       TableName: genericConfig.StripePaymentsDynamoTableName,
+            //       Key: marshall({
+            //         primaryKey: `CUSTOMER#${customerId}`,
+            //         sortKey: "SUMMARY",
+            //       }),
+            //       UpdateExpression: "ADD totalPaid :amount SET lastUpdated = :ts",
+            //       ExpressionAttributeValues: marshall({
+            //         ":amount": amount,
+            //         ":ts": Date.now(),
+            //       }),
+            //     })
+            //   );
+            // }
+          }
+
+          return reply
+            .status(200)
+            .send({ handled: true, requestId: request.id });
+        }
         default:
           request.log.warn(`Unhandled event type: ${event.type}`);
       }

src/common/config.ts

@@ -40,6 +40,7 @@ export type GenericConfigType = {
   CacheDynamoTableName: string;
   LinkryDynamoTableName: string;
   StripeLinksDynamoTableName: string;
+  StripePaymentsDynamoTableName: string;
   EntraSecretName: string;
   UpcomingEventThresholdSeconds: number;
   AwsRegion: string;
@@ -83,6 +84,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",