Add Stripe payment integration with subscription support and webhooks

Author: ralyodio

.env.example

@@ -41,3 +41,4 @@ USDC_ADDRESS=0x402282c72a2f2b9f059C3b39Fa63932D6AA09f11
 STRIPE_ACCOUNT_ID=your-stripe-account-id
 STRIPE_PUBLISHABLE_KEY=your-stripe-publishable-key
 STRIPE_SECRET_KEY=your-stripe-secret-key
+STRIPE_WEBHOOK_SECRET=your-stripe-webhook-secret

bin/create-stripe-products.js

@@ -0,0 +1,185 @@
+#!/usr/bin/env node
+
+/**
+ * Stripe Product Management Script
+ * 
+ * This script manages Stripe products and prices for the PDF service.
+ * It ensures that the necessary products and prices exist in Stripe.
+ * 
+ * Usage:
+ *   node bin/create-stripe-products.js
+ * 
+ * Environment variables:
+ *   STRIPE_SECRET_KEY - Stripe API secret key
+ */
+
+import Stripe from 'stripe';
+import dotenv from 'dotenv-flow';
+import { fileURLToPath } from 'url';
+import { dirname, join } from 'path';
+import fs from 'fs';
+
+// Get the directory name
+const __filename = fileURLToPath(import.meta.url);
+const __dirname = dirname(__filename);
+
+// Load environment variables
+dotenv.config({ path: join(__dirname, '..') });
+
+// Initialize Stripe with the secret key
+const stripe = new Stripe(process.env.STRIPE_SECRET_KEY);
+
+// Product configuration
+const PRODUCTS = [
+  {
+    name: 'PDF Service Subscription',
+    description: 'Subscription for PDF conversion service',
+    prices: [
+      {
+        nickname: 'Monthly Subscription',
+        unit_amount: 500, // $5.00
+        currency: 'usd',
+        recurring: {
+          interval: 'month'
+        },
+        metadata: {
+          plan: 'monthly'
+        }
+      },
+      {
+        nickname: 'Yearly Subscription',
+        unit_amount: 3000, // $30.00
+        currency: 'usd',
+        recurring: {
+          interval: 'year'
+        },
+        metadata: {
+          plan: 'yearly'
+        }
+      }
+    ]
+  }
+];
+
+/**
+ * Create or update a product in Stripe
+ * @param {Object} productConfig - Product configuration
+ * @returns {Promise<Object>} - Created or updated product
+ */
+async function createOrUpdateProduct(productConfig) {
+  console.log(`Processing product: ${productConfig.name}`);
+  
+  // Check if product already exists
+  const existingProducts = await stripe.products.list({
+    active: true,
+    limit: 100
+  });
+  
+  const existingProduct = existingProducts.data.find(p => p.name === productConfig.name);
+  
+  let product;
+  
+  if (existingProduct) {
+    console.log(`Product "${productConfig.name}" already exists with ID: ${existingProduct.id}`);
+    product = existingProduct;
+    
+    // Update product if needed
+    if (existingProduct.description !== productConfig.description) {
+      console.log(`Updating product "${productConfig.name}"`);
+      product = await stripe.products.update(existingProduct.id, {
+        description: productConfig.description
+      });
+    }
+  } else {
+    // Create new product
+    console.log(`Creating new product "${productConfig.name}"`);
+    product = await stripe.products.create({
+      name: productConfig.name,
+      description: productConfig.description,
+      active: true
+    });
+  }
+  
+  // Process prices
+  for (const priceConfig of productConfig.prices) {
+    await createOrUpdatePrice(product.id, priceConfig);
+  }
+  
+  return product;
+}
+
+/**
+ * Create or update a price in Stripe
+ * @param {string} productId - Stripe product ID
+ * @param {Object} priceConfig - Price configuration
+ * @returns {Promise<Object>} - Created or updated price
+ */
+async function createOrUpdatePrice(productId, priceConfig) {
+  console.log(`Processing price: ${priceConfig.nickname}`);
+  
+  // Check if price already exists
+  const existingPrices = await stripe.prices.list({
+    product: productId,
+    active: true,
+    limit: 100
+  });
+  
+  const existingPrice = existingPrices.data.find(p => 
+    p.nickname === priceConfig.nickname && 
+    p.unit_amount === priceConfig.unit_amount &&
+    p.currency === priceConfig.currency &&
+    p.recurring?.interval === priceConfig.recurring?.interval
+  );
+  
+  if (existingPrice) {
+    console.log(`Price "${priceConfig.nickname}" already exists with ID: ${existingPrice.id}`);
+    
+    // Update metadata if needed
+    if (JSON.stringify(existingPrice.metadata) !== JSON.stringify(priceConfig.metadata)) {
+      console.log(`Updating metadata for price "${priceConfig.nickname}"`);
+      return await stripe.prices.update(existingPrice.id, {
+        metadata: priceConfig.metadata
+      });
+    }
+    
+    return existingPrice;
+  } else {
+    // Create new price
+    console.log(`Creating new price "${priceConfig.nickname}"`);
+    return await stripe.prices.create({
+      product: productId,
+      nickname: priceConfig.nickname,
+      unit_amount: priceConfig.unit_amount,
+      currency: priceConfig.currency,
+      recurring: priceConfig.recurring,
+      metadata: priceConfig.metadata
+    });
+  }
+}
+
+/**
+ * Main function to process all products
+ */
+async function main() {
+  try {
+    console.log('Starting Stripe product management...');
+    
+    // Check if Stripe API key is set
+    if (!process.env.STRIPE_SECRET_KEY) {
+      throw new Error('STRIPE_SECRET_KEY environment variable is not set');
+    }
+    
+    // Process all products
+    for (const productConfig of PRODUCTS) {
+      await createOrUpdateProduct(productConfig);
+    }
+    
+    console.log('Stripe product management completed successfully');
+  } catch (error) {
+    console.error('Error in Stripe product management:', error);
+    process.exit(1);
+  }
+}
+
+// Run the main function
+main();

package.json

@@ -8,7 +8,8 @@
     "start": "node src/index.js",
     "dev": "nodemon src/index.js",
     "test": "node test.js",
-    "deploy": "./bin/deploy.sh"
+    "deploy": "./bin/deploy.sh",
+    "stripe:products": "node bin/create-stripe-products.js"
   },
   "keywords": [
     "pdf",
@@ -27,15 +28,19 @@
     "@hono/node-server": "^1.8.2",
     "@profullstack/spa-router": "^1.0.1",
     "@supabase/supabase-js": "^2.49.4",
+    "chalk": "^5.3.0",
+    "commander": "^12.0.0",
     "dotenv-flow": "^4.1.0",
     "form-data": "^4.0.2",
     "hono": "^4.1.3",
+    "inquirer": "^9.2.15",
     "jsdom": "^26.1.0",
     "mailgun.js": "^12.0.1",
     "marked": "^15.0.8",
     "pptxgenjs": "^3.12.0",
     "puppeteer": "^22.5.0",
     "qrcode": "^1.5.4",
+    "stripe": "^14.22.0",
     "turndown": "^7.2.0",
     "uuid": "^11.1.0",
     "ws": "^8.18.1",