How to create a subscription with Stripe API

1const express = require('express');
2const stripe = require('stripe')(process.env.STRIPE_SECRET_KEY);
3
4const app = express();
5
6// Webhook — before express.json()
7app.post('/webhook', express.raw({ type: 'application/json' }), (req, res) => {
8  const sig = req.headers['stripe-signature'];
9  let event;
10  try {
11    event = stripe.webhooks.constructEvent(
12      req.body, sig, process.env.STRIPE_WEBHOOK_SECRET
13    );
14  } catch (err) {
15    return res.status(400).send(`Webhook Error: ${err.message}`);
16  }
17
18  switch (event.type) {
19    case 'customer.subscription.created':
20      console.log('Subscription created:', event.data.object.id);
21      break;
22    case 'customer.subscription.updated':
23      console.log('Subscription updated:', event.data.object.status);
24      break;
25    case 'customer.subscription.deleted':
26      console.log('Subscription cancelled:', event.data.object.id);
27      break;
28    case 'invoice.paid':
29      console.log('Invoice paid:', event.data.object.subscription);
30      break;
31    case 'invoice.payment_failed':
32      console.log('Payment failed:', event.data.object.subscription);
33      break;
34  }
35  res.json({ received: true });
36});
37
38app.use(express.json());
39
40// Create customer
41app.post('/create-customer', async (req, res) => {
42  const customer = await stripe.customers.create({
43    email: req.body.email,
44    metadata: { user_id: req.body.userId },
45  });
46  res.json({ customerId: customer.id });
47});
48
49// Setup intent for collecting payment method
50app.post('/create-setup-intent', async (req, res) => {
51  const setupIntent = await stripe.setupIntents.create({
52    customer: req.body.customerId,
53    automatic_payment_methods: { enabled: true },
54  });
55  res.json({ clientSecret: setupIntent.client_secret });
56});
57
58// Create subscription
59app.post('/create-subscription', async (req, res) => {
60  const { customerId, priceId, paymentMethodId } = req.body;
61
62  // Set default payment method
63  await stripe.customers.update(customerId, {
64    invoice_settings: { default_payment_method: paymentMethodId },
65  });
66
67  const subscription = await stripe.subscriptions.create({
68    customer: customerId,
69    items: [{ price: priceId }],
70    expand: ['latest_invoice.payment_intent'],
71  });
72
73  res.json({
74    subscriptionId: subscription.id,
75    status: subscription.status,
76    clientSecret: subscription.latest_invoice?.payment_intent?.client_secret,
77  });
78});
79
80app.listen(4000, () => console.log('Server on port 4000'));