How to retry failed invoice payments in Stripe

1require('dotenv').config();
2const express = require('express');
3const stripe = require('stripe')(process.env.STRIPE_SECRET_KEY);
4
5const app = express();
6
7// Webhook endpoint for payment failure events
8app.post('/webhook', express.raw({ type: 'application/json' }), async (req, res) => {
9  const sig = req.headers['stripe-signature'];
10  let event;
11
12  try {
13    event = stripe.webhooks.constructEvent(
14      req.body, sig, process.env.STRIPE_WEBHOOK_SECRET
15    );
16  } catch (err) {
17    console.error('Signature verification failed:', err.message);
18    return res.status(400).send(`Webhook Error: ${err.message}`);
19  }
20
21  if (event.type === 'invoice.payment_failed') {
22    const invoice = event.data.object;
23    console.log(`Payment failed — invoice: ${invoice.id}, attempt: ${invoice.attempt_count}`);
24
25    if (invoice.attempt_count >= 3) {
26      console.log(`Flagging customer ${invoice.customer} for manual review`);
27      // TODO: restrict access, send urgent notification
28    }
29  }
30
31  if (event.type === 'invoice.payment_succeeded') {
32    const invoice = event.data.object;
33    console.log(`Payment recovered — invoice: ${invoice.id}`);
34    // TODO: restore access if previously restricted
35  }
36
37  res.json({ received: true });
38});
39
40app.use(express.json());
41
42// Manual retry endpoint
43app.post('/retry-invoice/:invoiceId', async (req, res) => {
44  try {
45    const invoice = await stripe.invoices.pay(req.params.invoiceId);
46    res.json({ status: invoice.status, id: invoice.id });
47  } catch (err) {
48    res.status(400).json({ error: err.message, code: err.code });
49  }
50});
51
52// List failed invoices for a customer
53app.get('/failed-invoices/:customerId', async (req, res) => {
54  try {
55    const invoices = await stripe.invoices.list({
56      customer: req.params.customerId,
57      status: 'open',
58      limit: 10,
59    });
60    res.json(invoices.data.map(inv => ({
61      id: inv.id,
62      amount_due: inv.amount_due,
63      currency: inv.currency,
64      attempt_count: inv.attempt_count,
65      next_payment_attempt: inv.next_payment_attempt,
66    })));
67  } catch (err) {
68    res.status(400).json({ error: err.message });
69  }
70});
71
72const PORT = process.env.PORT || 3000;
73app.listen(PORT, () => console.log(`Retry handler running on port ${PORT}`));