How to cancel a subscription in Stripe

1const express = require('express');
2const stripe = require('stripe')(process.env.STRIPE_SECRET_KEY);
3
4const app = express();
5
6app.post('/webhook', express.raw({ type: 'application/json' }), (req, res) => {
7  const sig = req.headers['stripe-signature'];
8  let event;
9  try {
10    event = stripe.webhooks.constructEvent(
11      req.body, sig, process.env.STRIPE_WEBHOOK_SECRET
12    );
13  } catch (err) {
14    return res.status(400).send(`Webhook Error: ${err.message}`);
15  }
16
17  switch (event.type) {
18    case 'customer.subscription.deleted':
19      console.log('Access revoked for:', event.data.object.customer);
20      break;
21    case 'customer.subscription.updated':
22      if (event.data.object.cancel_at_period_end) {
23        console.log('Cancellation scheduled:', event.data.object.id);
24      }
25      break;
26  }
27  res.json({ received: true });
28});
29
30app.use(express.json());
31
32// Cancel immediately
33app.post('/cancel-subscription', async (req, res) => {
34  const { subscriptionId } = req.body;
35  const canceled = await stripe.subscriptions.cancel(subscriptionId);
36  res.json({ status: canceled.status });
37});
38
39// Cancel at period end
40app.post('/cancel-subscription-at-period-end', async (req, res) => {
41  const { subscriptionId } = req.body;
42  const updated = await stripe.subscriptions.update(subscriptionId, {
43    cancel_at_period_end: true,
44  });
45  res.json({
46    cancel_at_period_end: updated.cancel_at_period_end,
47    period_end: new Date(updated.current_period_end * 1000).toISOString(),
48  });
49});
50
51// Undo scheduled cancellation
52app.post('/reactivate-subscription', async (req, res) => {
53  const { subscriptionId } = req.body;
54  const updated = await stripe.subscriptions.update(subscriptionId, {
55    cancel_at_period_end: false,
56  });
57  res.json({ cancel_at_period_end: updated.cancel_at_period_end });
58});
59
60// Customer Portal
61app.post('/create-portal-session', async (req, res) => {
62  const portal = await stripe.billingPortal.sessions.create({
63    customer: req.body.customerId,
64    return_url: `${req.headers.origin}/account`,
65  });
66  res.json({ url: portal.url });
67});
68
69app.listen(4000, () => console.log('Server on port 4000'));