feat: stripe boilerplate

.env.example

@@ -9,3 +9,6 @@ SUPABASE_URL=
 DEEPGRAM_API_KEY=
 OPENAI_API_KEY=
 SLACK_POSTMAN_WEBHOOK_URL=
+
+STRIPE_SECRET_KEY=
+STRIPE_PUBLISHABLE_KEY=

env.mjs

@@ -19,6 +19,8 @@ export const env = createEnv({
     PODCAST_INDEX_API_KEY: process.env.PODCAST_INDEX_API_KEY,
     PODCAST_INDEX_SECRET: process.env.PODCAST_INDEX_SECRET,
     SLACK_POSTMAN_WEBHOOK_URL: process.env.SLACK_POSTMAN_WEBHOOK_URL,
+    STRIPE_PUBLISHABLE_KEY: process.env.STRIPE_PUBLISHABLE_KEY,
+    STRIPE_SECRET_KEY: process.env.STRIPE_SECRET_KEY,
     SUPABASE_SERVICE_ROLE_KEY: process.env.SUPABASE_SERVICE_ROLE_KEY,
     SUPABASE_URL: process.env.SUPABASE_URL,
   },
@@ -29,6 +31,8 @@ export const env = createEnv({
     PODCAST_INDEX_API_KEY: z.string().min(1),
     PODCAST_INDEX_SECRET: z.string().min(1),
     SLACK_POSTMAN_WEBHOOK_URL: z.string().min(1),
+    STRIPE_PUBLISHABLE_KEY: z.string().min(1),
+    STRIPE_SECRET_KEY: z.string().min(1),
     SUPABASE_SERVICE_ROLE_KEY: z.string().min(1),
     SUPABASE_URL: z.string().min(1),
   },

lib/errors.ts

@@ -80,3 +80,14 @@ export class DatabaseError extends ExtendableError {
     this.underlyingError = error;
   }
 }
+
+export const createExternalServiceError = (serviceName: string) =>
+  class ExternalServiceError extends ExtendableError {
+    serviceName = serviceName;
+    underlyingError: unknown;
+
+    constructor(error: unknown) {
+      super(`Error from ${serviceName}`);
+      this.underlyingError = error;
+    }
+  };

lib/services/stripe/checkout.ts

@@ -0,0 +1,25 @@
+'use server';
+
+import { stripe } from './client';
+
+export const createCheckoutSession = async ({
+  baseUrl,
+  priceId,
+}: {
+  baseUrl: string;
+  priceId: string;
+}) => {
+  const session = await stripe.checkout.sessions.create({
+    cancel_url: `${baseUrl}?status=cancel`,
+    line_items: [
+      {
+        price: priceId,
+        quantity: 1,
+      },
+    ],
+    mode: 'payment',
+    success_url: `${baseUrl}?status=success`,
+  });
+
+  return session;
+};

lib/services/stripe/client.ts

@@ -0,0 +1,7 @@
+import { env } from '@/env.mjs';
+import { createExternalServiceError } from '@/lib/errors';
+import { Stripe } from 'stripe';
+
+export const stripe = new Stripe(env.STRIPE_SECRET_KEY);
+
+export const StripeError = createExternalServiceError('Stripe');

lib/services/stripe/prices.ts

@@ -0,0 +1,22 @@
+'use server';
+
+import { StripeError, stripe } from './client';
+
+const getProduct = async () => {
+  const products = await stripe.products.list();
+  const product = products.data.find((p) => p.metadata.project === 'beecast');
+
+  if (!product) {
+    throw new StripeError('Product not found!');
+  }
+
+  return product;
+};
+
+export const getPrices = async () => {
+  const product = await getProduct();
+  const prices = await stripe.prices.list({ product: product.id });
+  return prices.data
+    .filter((p) => p.active)
+    .sort((a, b) => a.unit_amount! - b.unit_amount!);
+};

package.json

@@ -36,6 +36,7 @@
     "react": "^18",
     "react-dom": "^18",
     "react-icons": "^4.12.0",
+    "stripe": "^14.9.0",
     "zod": "^3.22.4"
   },
   "devDependencies": {