How to use Stripe Connect for marketplace payments

1const stripe = require('stripe')(process.env.STRIPE_SECRET_KEY);
2const express = require('express');
3const app = express();
4
5// Create a connected Express account for a new seller
6app.post('/api/create-seller', async (req, res) => {
7  try {
8    const account = await stripe.accounts.create({
9      type: 'express',
10      country: req.body.country || 'US',
11      email: req.body.email,
12      capabilities: {
13        card_payments: { requested: true },
14        transfers: { requested: true },
15      },
16    });
17
18    const accountLink = await stripe.accountLinks.create({
19      account: account.id,
20      refresh_url: `${req.headers.origin}/onboarding/refresh`,
21      return_url: `${req.headers.origin}/onboarding/complete`,
22      type: 'account_onboarding',
23    });
24
25    res.json({ accountId: account.id, onboardingUrl: accountLink.url });
26  } catch (err) {
27    res.status(400).json({ error: err.message });
28  }
29});
30
31// Create a destination charge (single seller)
32app.post('/api/charge', async (req, res) => {
33  try {
34    const { amount, sellerAccountId, platformFee } = req.body;
35    const paymentIntent = await stripe.paymentIntents.create({
36      amount: amount, // in cents
37      currency: 'usd',
38      payment_method_types: ['card'],
39      application_fee_amount: platformFee,
40      transfer_data: {
41        destination: sellerAccountId,
42      },
43    });
44    res.json({ clientSecret: paymentIntent.client_secret });
45  } catch (err) {
46    res.status(400).json({ error: err.message });
47  }
48});
49
50// Check connected account status
51app.get('/api/seller/:accountId', async (req, res) => {
52  try {
53    const account = await stripe.accounts.retrieve(req.params.accountId);
54    res.json({
55      payoutsEnabled: account.payouts_enabled,
56      chargesEnabled: account.charges_enabled,
57      requirements: account.requirements.currently_due,
58    });
59  } catch (err) {
60    res.status(400).json({ error: err.message });
61  }
62});
63
64// Webhook for Connect events
65app.post('/webhook', express.raw({ type: 'application/json' }), (req, res) => {
66  const sig = req.headers['stripe-signature'];
67  let event;
68  try {
69    event = stripe.webhooks.constructEvent(
70      req.body, sig, process.env.STRIPE_WEBHOOK_SECRET
71    );
72  } catch (err) {
73    return res.status(400).send(`Webhook Error: ${err.message}`);
74  }
75
76  switch (event.type) {
77    case 'account.updated':
78      console.log('Account updated:', event.data.object.id);
79      break;
80    case 'payment_intent.succeeded':
81      console.log('Payment succeeded:', event.data.object.id);
82      break;
83  }
84  res.json({ received: true });
85});
86
87app.use(express.json());
88app.listen(3000, () => console.log('Marketplace server on port 3000'));