Stripe

Subscribe to user updates, automate payments, billing and more.

Using our official Stripe integration

Easily subscribe to Stripe webhooks to trigger your jobs.

Create any tasks possible with the Stripe API.

Use io.runTask() and the official SDK or fetch.

Example code using Stripe

Below are some working code examples of how you can use Stripe with Trigger.dev. These samples are open source and maintained by the community, you can copy and paste them into your own projects.

Update Airtable when a new subscription is added to Stripe.Update Airtable database when there is a sale in Stripe.Update Supabase every time a Stripe account is updated.

1
import { TriggerClient } from "@trigger.dev/sdk";
2
import { Stripe } from "@trigger.dev/stripe";
3
import { Airtable } from "@trigger.dev/airtable";
4
const stripe = new Stripe({
5
  id: "stripe",
6
  apiKey: process.env.STRIPE_API_KEY!,
7
});
8

9
const airtable = new Airtable({
10
  id: "airtable",
11
  token: process.env.AIRTABLE_TOKEN!,
12
});
13

14
type Customers = {
15
  stripe_customer_id?: string;
16
  Sales?: string[];
17
};
18

19
type Sales = {
20
  payment_intent_id: string;
21
  amount: number;
22
  currency: string;
23
  Customers?: string[];
24
  "stripe_customer_id (from Customers)": string;
25
};
26

27
client.defineJob({
28
  id: "stripe-new-sale-update-airtable",
29
  name: "On new Stripe sale update Airtable",
30
  version: "1.0.0",
31
  integrations: {
32
    stripe,
33
    airtable,
34
  },
35
  trigger: stripe.onPaymentIntentSucceeded(),
36
  run: async (payload, io, ctx) => {
37
    const customersTable = io.airtable
38
      .base("<your base id>")
39
      .table<Customers>("<your table name>");
40

41
    const salesTable = io.airtable
42
      .base("<your base id>")
43
      .table<Sales>("<your table name>");
44

45
    const {
46
      id: payment_intent_id,
47
      customer: stripe_customer_id,
48
      amount,
49
      currency,
50
    } = payload;
51

52
    // Use the filter formula to find a customer record with the given stripe_customer_id
53
    const records = await customersTable.getRecords(
54
      "Filter records by stripe_customer_id",
55
      {
56
        filterByFormula: `{stripe_customer_id} = "${stripe_customer_id}"`,
57
        fields: ["stripe_customer_id"],
58
      }
59
    );
60

61
    let customerRecordId;
62
    if (records && records.length > 0) {
63
      // There is an existing customer
64
      customerRecordId = records[0].id;
65
    } else {
66
      const newCustomerRecord = await customersTable.createRecords(
67
        "create new customer record",
68
        [
69
          {
70
            fields: { stripe_customer_id: stripe_customer_id as string },
71
          },
72
        ]
73
      );
74
      customerRecordId = newCustomerRecord[0].id;
75
    }
76

77
    // Add sale to the Sales table
78
    const newSaleRecord = await salesTable.createRecords(
79
      "create new sale record",
80
      [
81
        {
82
          fields: {
83
            payment_intent_id,
84
            amount,
85
            currency,
86
            Customers: [customerRecordId], // Link to the customer record using its ID
87
          },
88
        },
89
      ]
90
    );
91
  },
92
});