changed to payment intent

Author: AdityaK2905

src/api/routes/stripe.ts

@@ -328,12 +328,13 @@ const stripeRoutes: FastifyPluginAsync = async (fastify, _options) => {
             message: "Could not connect to Stripe.",
           });
         }
+        const webhookSecret =
+          "whsec_d4839918a81492d000c72bdc4ecff3fb080818156a15dc63b64f519d0edc1ed1";
         event = stripe.webhooks.constructEvent(
           request.rawBody,
           sig,
-          secretApiConfig.stripe_links_endpoint_secret as string,
+          webhookSecret, //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;
@@ -717,52 +718,38 @@ 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;
+        case "payment_intent.succeeded": {
+          const intent = event.data.object as Stripe.PaymentIntent;
 
-          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})`,
-            );
+          const amount = intent.amount_received;
+          const currency = intent.currency;
+          const customerId = intent.customer?.toString() ?? "UNKNOWN";
+          const email =
+            intent.receipt_email ??
+            intent.metadata?.billing_email ??
+            "unknown@example.com";
+          const acmOrg = intent.metadata?.acm_org ?? "ACM@UIUC";
+          const domain = email.split("@")[1] ?? "unknown.com";
 
-            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,
-                }),
+          await fastify.dynamoClient.send(
+            new PutItemCommand({
+              TableName: genericConfig.StripePaymentsDynamoTableName,
+              Item: marshall({
+                primaryKey: `${acmOrg}#${domain}`,
+                sortKey: `customer`,
+                amount,
+                currency,
+                status: "succeeded",
+                billingEmail: email,
+                createdAt: Date.now(),
+                eventId: event.id,
               }),
-            );
+            }),
+          );
 
-            // 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(),
-            //       }),
-            //     })
-            //   );
-            // }
-          }
+          request.log.info(
+            `Recorded successful payment ${intent.id} from ${email} (${amount} ${currency})`,
+          );
 
           return reply
             .status(200)