Stripe Link creation support in manage.acm

.github/workflows/deploy-dev.yml

@@ -92,6 +92,8 @@ jobs:
         run: make dev_health_check
       - name: Run live testing
         run: make test_live_integration
+        env:
+          JWT_KEY: ${{ secrets.JWT_KEY }}
       - name: Run E2E testing
         run: make test_e2e
         env:

.github/workflows/deploy-prod.yml

@@ -90,6 +90,8 @@ jobs:
           python-version: 3.11
       - name: Run live testing
         run: make test_live_integration
+        env:
+          JWT_KEY: ${{ secrets.JWT_KEY }}
       - name: Run E2E testing
         run: make test_e2e
         env:

cloudformation/iam.yml

@@ -106,6 +106,8 @@ Resources:
                 - !Sub arn:aws:dynamodb:${AWS::Region}:${AWS::AccountId}:table/infra-core-api-iam-userroles/*
                 - !Sub arn:aws:dynamodb:${AWS::Region}:${AWS::AccountId}:table/infra-core-api-iam-grouproles
                 - !Sub arn:aws:dynamodb:${AWS::Region}:${AWS::AccountId}:table/infra-core-api-iam-grouproles/*
+                - !Sub arn:aws:dynamodb:${AWS::Region}:${AWS::AccountId}:table/infra-core-api-stripe-links
+                - !Sub arn:aws:dynamodb:${AWS::Region}:${AWS::AccountId}:table/infra-core-api-stripe-links/*
 
         PolicyName: lambda-dynamo
 Outputs:

cloudformation/main.yml

@@ -262,6 +262,34 @@ Resources:
         Projection:
           ProjectionType: ALL
 
+  StripeLinksTable:
+    Type: 'AWS::DynamoDB::Table'
+    DeletionPolicy: "Retain"
+    UpdateReplacePolicy: "Retain"
+    Properties:
+      BillingMode: 'PAY_PER_REQUEST'
+      TableName: infra-core-api-stripe-links
+      DeletionProtectionEnabled: true
+      PointInTimeRecoverySpecification:
+        PointInTimeRecoveryEnabled: false
+      AttributeDefinitions:
+        - AttributeName: userId
+          AttributeType: S
+        - AttributeName: linkId
+          AttributeType: S
+      KeySchema:
+        - AttributeName: userId
+          KeyType: "HASH"
+        - AttributeName: linkId
+          KeyType: "RANGE"
+      GlobalSecondaryIndexes:
+        - IndexName: LinkIdIndex
+          KeySchema:
+            - AttributeName: linkId
+              KeyType: "HASH"
+          Projection:
+            ProjectionType: "ALL"
+
   CacheRecordsTable:
     Type: 'AWS::DynamoDB::Table'
     DeletionPolicy: "Retain"

generate_jwt.js

@@ -1,36 +1,36 @@
-import jwt from 'jsonwebtoken';
+import jwt from "jsonwebtoken";
 import * as dotenv from "dotenv";
 dotenv.config();
 
-const username = process.env.JWTGEN_USERNAME || '[email protected]'
+const username = process.env.JWTGEN_USERNAME || "[email protected]"
 const payload = {
-    aud: "custom_jwt",
-    iss: "custom_jwt",
-    iat: Math.floor(Date.now() / 1000),
-    nbf: Math.floor(Date.now() / 1000),
-    exp: Math.floor(Date.now() / 1000) + (3600 * 24), // Token expires after 24 hour
-    acr: "1",
-    aio: "AXQAi/8TAAAA",
-    amr: ["pwd"],
-    appid: "your-app-id",
-    appidacr: "1",
-    email: username,
-    groups: ["0"],
-    idp: "https://login.microsoftonline.com",
-    ipaddr: "192.168.1.1",
-    name: "Doe, John",
-    oid: "00000000-0000-0000-0000-000000000000",
-    rh: "rh-value",
-    scp: "user_impersonation",
-    sub: "subject",
-    tid: "tenant-id",
-    unique_name: username,
-    uti: "uti-value",
-    ver: "1.0"
+  aud: "custom_jwt",
+  iss: "custom_jwt",
+  iat: Math.floor(Date.now() / 1000),
+  nbf: Math.floor(Date.now() / 1000),
+  exp: Math.floor(Date.now() / 1000) + 3600 * 24, // Token expires after 24 hour
+  acr: "1",
+  aio: "AXQAi/8TAAAA",
+  amr: ["pwd"],
+  appid: "your-app-id",
+  appidacr: "1",
+  email: username,
+  groups: ["0"],
+  idp: "https://login.microsoftonline.com",
+  ipaddr: "192.168.1.1",
+  name: "Doe, John",
+  oid: "00000000-0000-0000-0000-000000000000",
+  rh: "rh-value",
+  scp: "user_impersonation",
+  sub: "subject",
+  tid: "tenant-id",
+  unique_name: username,
+  uti: "uti-value",
+  ver: "1.0",
 };
 
 const secretKey = process.env.JwtSigningKey;
-const token = jwt.sign(payload, secretKey, { algorithm: 'HS256' });
-console.log(`USERNAME=${username}`)
-console.log('=====================')
-console.log(token)
+const token = jwt.sign(payload, secretKey, { algorithm: "HS256" });
+console.log(`USERNAME=${username}`);
+console.log("=====================");
+console.log(token);

package.json

@@ -81,4 +81,4 @@
   "resolutions": {
     "pdfjs-dist": "^4.8.69"
   }
-}
+}

src/api/functions/stripe.ts

@@ -0,0 +1,56 @@
+import { FastifyBaseLogger } from "fastify";
+import Stripe from "stripe";
+
+export type StripeLinkCreateParams = {
+  invoiceId: string;
+  invoiceAmountUsd: number;
+  contactName: string;
+  contactEmail: string;
+  createdBy: string;
+  stripeApiKey: string;
+};
+
+/**
+ * Create a Stripe payment link for an invoice. Note that invoiceAmountUsd MUST IN CENTS!!
+ * @param {StripeLinkCreateParams} options
+ * @returns {string} A stripe link that can be used to pay the invoice
+ */
+export const createStripeLink = async ({
+  invoiceId,
+  invoiceAmountUsd,
+  contactName,
+  contactEmail,
+  createdBy,
+  stripeApiKey,
+}: StripeLinkCreateParams): Promise<{
+  linkId: string;
+  priceId: string;
+  productId: string;
+  url: string;
+}> => {
+  const stripe = new Stripe(stripeApiKey);
+  const description = `Created For: ${contactName} (${contactEmail}) by ${createdBy}.`;
+  const product = await stripe.products.create({
+    name: `Payment for Invoice: ${invoiceId}`,
+    description,
+  });
+  const price = await stripe.prices.create({
+    currency: "usd",
+    unit_amount: invoiceAmountUsd,
+    product: product.id,
+  });
+  const paymentLink = await stripe.paymentLinks.create({
+    line_items: [
+      {
+        price: price.id,
+        quantity: 1,
+      },
+    ],
+  });
+  return {
+    url: paymentLink.url,
+    linkId: paymentLink.id,
+    productId: product.id,
+    priceId: price.id,
+  };
+};

src/api/index.ts

@@ -22,6 +22,7 @@ import NodeCache from "node-cache";
 import { DynamoDBClient } from "@aws-sdk/client-dynamodb";
 import { SecretsManagerClient } from "@aws-sdk/client-secrets-manager";
 import mobileWalletRoute from "./routes/mobileWallet.js";
+import stripeRoutes from "./routes/stripe.js";
 
 dotenv.config();
 
@@ -113,6 +114,7 @@ async function init() {
       api.register(iamRoutes, { prefix: "/iam" });
       api.register(ticketsPlugin, { prefix: "/tickets" });
       api.register(mobileWalletRoute, { prefix: "/mobileWallet" });
+      api.register(stripeRoutes, { prefix: "/stripe" });
       if (app.runEnvironment === "dev") {
         api.register(vendingPlugin, { prefix: "/vending" });
       }

src/api/package.json

@@ -45,6 +45,7 @@
     "passkit-generator": "^3.3.1",
     "pino": "^9.6.0",
     "pluralize": "^8.0.0",
+    "stripe": "^17.6.0",
     "uuid": "^11.0.5",
     "zod": "^3.23.8",
     "zod-to-json-schema": "^3.23.2",

src/api/plugins/auth.ts

@@ -15,7 +15,7 @@
 } from "../../common/errors/index.js";
 import { genericConfig, SecretConfig } from "../../common/config.js";
 import { getGroupRoles, getUserRoles } from "../functions/authorization.js";
 import { DynamoDBClient } from "@aws-sdk/client-dynamodb";
 
 function intersection<T>(setA: Set<T>, setB: Set<T>): Set<T> {
   const _intersection = new Set<T>();
@@ -237,6 +237,7 @@
         });
       }
       request.log.info(`authenticated request from ${request.username} `);
+      request.userRoles = userRoles;
       return userRoles;
     },
   );

src/api/routes/events.ts

@@ -17,6 +17,7 @@ import {
   DatabaseFetchError,
   DatabaseInsertError,
   DiscordEventError,
+  NotFoundError,
   ValidationError,
 } from "../../common/errors/index.js";
 import { randomUUID } from "crypto";
@@ -85,7 +86,7 @@ const eventsPlugin: FastifyPluginAsync = async (fastify, _options) => {
     "/:id?",
     {
       schema: {
-        response: { 200: responseJsonSchema },
+        response: { 201: responseJsonSchema },
       },
       preValidation: async (request, reply) => {
         await fastify.zodValidateBody(request, reply, postRequestSchema);
@@ -168,7 +169,7 @@ const eventsPlugin: FastifyPluginAsync = async (fastify, _options) => {
           }
           throw new DiscordEventError({});
         }
-        reply.send({
+        reply.status(201).send({
           id: entryUUID,
           resource: `/api/v1/events/${entryUUID}`,
         });
@@ -211,10 +212,15 @@ const eventsPlugin: FastifyPluginAsync = async (fastify, _options) => {
         );
         const items = response.Items?.map((item) => unmarshall(item));
         if (items?.length !== 1) {
-          throw new Error("Event not found");
+          throw new NotFoundError({
+            endpointName: request.url,
+          });
         }
         reply.send(items[0]);
       } catch (e: unknown) {
+        if (e instanceof BaseError) {
+          throw e;
+        }
         if (e instanceof Error) {
           request.log.error("Failed to get from DynamoDB: " + e.toString());
         }
@@ -233,7 +239,7 @@ const eventsPlugin: FastifyPluginAsync = async (fastify, _options) => {
     "/:id",
     {
       schema: {
-        response: { 200: responseJsonSchema },
+        response: { 201: responseJsonSchema },
       },
       onRequest: async (request, reply) => {
         await fastify.authorize(request, reply, [AppRoles.EVENTS_MANAGER]);
@@ -254,7 +260,7 @@ const eventsPlugin: FastifyPluginAsync = async (fastify, _options) => {
           true,
           request.log,
         );
-        reply.send({
+        reply.status(201).send({
           id,
           resource: `/api/v1/events/${id}`,
         });