How to programmatically issue refunds with Stripe API

1const express = require('express');
2const stripe = require('stripe')(process.env.STRIPE_SECRET_KEY);
3
4const app = express();
5
6// Webhook handler (must be before express.json middleware)
7app.post('/webhook',
8  express.raw({ type: 'application/json' }),
9  (req, res) => {
10    const sig = req.headers['stripe-signature'];
11    let event;
12
13    try {
14      event = stripe.webhooks.constructEvent(
15        req.body,
16        sig,
17        process.env.STRIPE_WEBHOOK_SECRET
18      );
19    } catch (err) {
20      return res.status(400).send(`Webhook Error: ${err.message}`);
21    }
22
23    switch (event.type) {
24      case 'charge.refunded':
25        console.log('Refund confirmed:', event.data.object.id);
26        break;
27      case 'refund.failed':
28        console.log('Refund failed:', event.data.object.failure_reason);
29        break;
30    }
31
32    res.json({ received: true });
33  }
34);
35
36app.use(express.json());
37
38// Create refund endpoint
39app.post('/api/refunds', async (req, res) => {
40  try {
41    const { paymentIntentId, amount, reason, metadata } = req.body;
42
43    const params = {
44      payment_intent: paymentIntentId,
45      reason: reason || 'requested_by_customer',
46      metadata: metadata || {},
47    };
48    if (amount) params.amount = amount;
49
50    const refund = await stripe.refunds.create(params);
51
52    res.json({
53      id: refund.id,
54      amount: refund.amount / 100,
55      status: refund.status,
56      reason: refund.reason,
57    });
58  } catch (err) {
59    const status = err.code === 'charge_already_refunded' ? 400 : 500;
60    res.status(status).json({ error: err.message, code: err.code });
61  }
62});
63
64// List refunds for a payment
65app.get('/api/refunds', async (req, res) => {
66  try {
67    const { payment_intent } = req.query;
68    const refunds = await stripe.refunds.list({ payment_intent, limit: 20 });
69    res.json(refunds.data.map((r) => ({
70      id: r.id,
71      amount: r.amount / 100,
72      status: r.status,
73      reason: r.reason,
74      created: new Date(r.created * 1000).toISOString(),
75    })));
76  } catch (err) {
77    res.status(500).json({ error: err.message });
78  }
79});
80
81const PORT = process.env.PORT || 3000;
82app.listen(PORT, () => console.log(`Server on port ${PORT}`));