How to download invoices from Stripe

1require('dotenv').config();
2const fs = require('fs');
3const https = require('https');
4const path = require('path');
5const stripe = require('stripe')(process.env.STRIPE_SECRET_KEY);
6
7function downloadFile(url, filepath) {
8  return new Promise((resolve, reject) => {
9    const file = fs.createWriteStream(filepath);
10    https.get(url, (res) => {
11      if (res.statusCode === 302 || res.statusCode === 301) {
12        // Follow redirect
13        https.get(res.headers.location, (redirectRes) => {
14          redirectRes.pipe(file);
15          file.on('finish', () => { file.close(resolve); });
16        }).on('error', reject);
17      } else {
18        res.pipe(file);
19        file.on('finish', () => { file.close(resolve); });
20      }
21    }).on('error', reject);
22  });
23}
24
25async function downloadCustomerInvoices(customerId, outputDir = './invoices') {
26  fs.mkdirSync(outputDir, { recursive: true });
27
28  let downloaded = 0;
29  let hasMore = true;
30  let startingAfter;
31
32  while (hasMore) {
33    const params = { customer: customerId, status: 'paid', limit: 100 };
34    if (startingAfter) params.starting_after = startingAfter;
35
36    const invoices = await stripe.invoices.list(params);
37
38    for (const inv of invoices.data) {
39      if (!inv.invoice_pdf) continue;
40      const name = `${inv.number || inv.id}.pdf`;
41      const filepath = path.join(outputDir, name);
42      await downloadFile(inv.invoice_pdf, filepath);
43      downloaded++;
44      console.log(`[${downloaded}] ${name}`);
45    }
46
47    hasMore = invoices.has_more;
48    if (invoices.data.length) {
49      startingAfter = invoices.data[invoices.data.length - 1].id;
50    }
51  }
52
53  console.log(`\nDone. Downloaded ${downloaded} invoices to ${outputDir}`);
54}
55
56// Usage: pass customer ID as argument
57const customerId = process.argv[2];
58if (!customerId) {
59  console.error('Usage: node download-invoices.js cus_xxx');
60  process.exit(1);
61}
62
63downloadCustomerInvoices(customerId).catch(console.error);