Creates prices & test stripe payment links correctly

Author: Daveed

src/api/markket/controllers/markket.ts

@@ -5,6 +5,8 @@ import { version } from '../../../../package.json';
 const { createCoreController } = require('@strapi/strapi').factories;
 const modelId = "api::markket.markket";
 
+import { createPaymentLinkWithPriceIds } from '../services/stripe';
+
 const NODE_ENV = process.env.NODE_ENV || 'development';
 const STRIPE_PUBLIC_KEY = process.env.STRIPE_PUBLIC_KEY || 'n/a';
 const SENDGRID_REPLY_TO_EMAIL = process.env.SENDGRID_REPLY_TO_EMAIL || 'n/a';
@@ -24,22 +26,40 @@ module.exports = createCoreController(modelId, ({ strapi }) => ({
     });
   },
   async create(ctx: any) {
-    console.info('markket.create');
+    const body = JSON.parse(ctx.request.body);
+    let message = 'action completed';
+    console.log(`markket.create:${body.action}`, { body });
+
+    let link = null;
+    if (body?.action === 'stripe.link') {
+      link = await createPaymentLinkWithPriceIds(body?.prices || []);
+      message = 'stripe link created';
+    }
+
+    if (body?.action === 'stripe.webhook') {
+      // @TODO Store transaction record & send pertinent notifications
+    }
+
+    // Storing record of transaction
     await strapi.service(modelId).create({
       locale: 'en',
       data: {
-        Key: "markket.create",
-        Content: ctx.request.body,
+        Key: `markket.create.${body?.action || 'default'}`,
+        Content: {
+          link,
+          produt: body?.product,
+          total: body?.total,
+        },
         user_key_or_id: "", // @TODO: Review authorization, token or related user
       }
     });
-    // @TODO: send notification emails, perform STRIPE actions, etc, here
+
     ctx.send({
-      message: 'This is the create endpoint',
+      message: `action ${body?.action} completed`,
       data: {
-        info: 'Markket.place is an international commercial community',
-        version,
+        info: message,
+        link,
       },
     });
-  }
+  },
 }));

src/api/markket/routes/markket.ts

@@ -21,6 +21,6 @@ module.exports = {
         policies: [],
         middlewares: [],
       },
-    }
+    },
   ],
 };

src/api/markket/services/stripe.ts

@@ -0,0 +1,66 @@
+// const STRIPE_SECRET_KEY = process.env.STRIPE_SECRET_KEY;
+const STRIPE_SECRET_TEST_KEY = process.env.STRIPE_SECRET_TEST_KEY;
+
+// const stripe = require('stripe')(STRIPE_SECRET_KEY);
+const stripeTest = require('stripe')(STRIPE_SECRET_TEST_KEY);
+
+/**
+ *  Create a payment link with price ids, or create new prices for the custom amounts
+ * @param prices
+ * @returns
+ */
+export const createPaymentLinkWithPriceIds = async (prices: { id: string, quantity: number }[]) => {
+  console.log({ prices });
+
+  const line_items = [];
+
+  const custom_price: any = prices.find((price: any) => price.product);
+  const set_price: any = prices.find((price: any) => price.price);
+
+  if (custom_price?.product) {
+    const new_price = await stripeTest.prices.create({
+      currency: 'usd',
+      unit_amount: (custom_price?.unit_amount * 100) || 0,
+      product: custom_price?.product,
+    });
+
+    console.log({ new_price });
+
+    if (new_price?.id) {
+      line_items.push({
+        price: new_price.id,
+        quantity: 1,
+      });
+    }
+  }
+
+  if (set_price?.price) {
+    line_items.push({
+      price: set_price.price,
+      quantity: set_price.quantity || 1,
+    });
+  }
+
+  if (line_items?.length < 1) {
+    return null;
+  }
+
+  console.log({ line_items });
+
+  const paymentLink = await stripeTest.paymentLinks.create({
+    // @TODO: maximum 20 items
+    line_items: line_items.splice(0, 20) || [],
+    after_completion: {
+      type: 'redirect',
+      redirect: {
+        url: 'https://markket.place/receipt?session_id={CHECKOUT_SESSION_ID}',
+      },
+    },
+    // on_behalf_of: 'connected_acct_id',
+    // transfer_data: {
+    //   destination: 'connected_acct_id',
+    // },
+  });
+
+  return paymentLink;
+};