feat: sync payment intents (#70)

Author: kevcodez

README.md

@@ -60,11 +60,14 @@ This server synchronizes your Stripe account to a Postgres database. It can be a
 - [ ] `issuing_authorization.request`
 - [ ] `issuing_card.created`
 - [ ] `issuing_cardholder.created`
-- [ ] `payment_intent.amount_capturable_updated`
-- [ ] `payment_intent.canceled`
-- [ ] `payment_intent.created`
-- [ ] `payment_intent.payment_failed`
-- [ ] `payment_intent.succeeded`
+- [x] `payment_intent.amount_capturable_updated` 🟢
+- [x] `payment_intent.canceled` 🟢
+- [x] `payment_intent.created` 🟢
+- [x] `payment_intent.partially_refunded` 🟢
+- [x] `payment_intent.payment_failed` 🟢
+- [x] `payment_intent.processing` 🟢
+- [x] `payment_intent.requires_action` 🟢
+- [x] `payment_intent.succeeded` 🟢
 - [x] `payment_method.attached` 🟢
 - [x] `payment_method.automatically_updated` 🟢
 - [x] `payment_method.detached` 🟢
@@ -110,7 +113,7 @@ body: {
 }
 ```
 
-- `object` **all** | **customer** | **invoice** | **price** | **product** | **subscription** | **setup_intent** | **payment_method** | **dispute** | **charge**
+- `object` **all** | **customer** | **invoice** | **price** | **product** | **subscription** | **setup_intent** | **payment_method** | **dispute** | **charge** | **payment_intent**
 - `created` is Stripe.RangeQueryParam. It supports **gt**, **gte**, **lt**, **lte**
 
 #### Alternative routes to sync `daily/weekly/monthly` data

db/migrations/0021_payment_intent.sql

@@ -0,0 +1,42 @@
+create table if not exists "stripe"."payment_intents" (
+  id text primary key,
+  object text,
+  amount integer,
+  amount_capturable integer,
+  amount_details jsonb,
+  amount_received integer,
+  application text,
+  application_fee_amount integer,
+  automatic_payment_methods text,
+  canceled_at integer,
+  cancellation_reason text,
+  capture_method text,
+  client_secret text,
+  confirmation_method text,
+  created integer,
+  currency text,
+  customer text,
+  description text,
+  invoice text,
+  last_payment_error text,
+  livemode boolean,
+  metadata jsonb,
+  next_action text,
+  on_behalf_of text,
+  payment_method text,
+  payment_method_options jsonb,
+  payment_method_types jsonb,
+  processing text,
+  receipt_email text,
+  review text,
+  setup_future_usage text,
+  shipping jsonb,
+  statement_descriptor text,
+  statement_descriptor_suffix text,
+  status text,
+  transfer_data jsonb,
+  transfer_group text
+);
+
+CREATE INDEX stripe_payment_intents_customer_idx ON "stripe"."payment_intents" USING btree (customer);
+CREATE INDEX stripe_payment_intents_invoice_idx ON "stripe"."payment_intents" USING btree (invoice);

src/lib/payment_intents.ts

@@ -0,0 +1,22 @@
+import { getConfig } from '../utils/config'
+import Stripe from 'stripe'
+import { constructUpsertSql } from '../utils/helpers'
+import { backfillCustomers } from './customers'
+import { getUniqueIds, upsertMany } from './database_utils'
+import { backfillInvoices } from './invoices'
+import { paymentIntentSchema } from '../schemas/payment_intent'
+
+const config = getConfig()
+
+export const upsertPaymentIntents = async (
+  paymentIntents: Stripe.PaymentIntent[]
+): Promise<Stripe.PaymentIntent[]> => {
+  await Promise.all([
+    backfillCustomers(getUniqueIds(paymentIntents, 'customer')),
+    backfillInvoices(getUniqueIds(paymentIntents, 'invoice')),
+  ])
+
+  return upsertMany(paymentIntents, () =>
+    constructUpsertSql(config.SCHEMA || 'stripe', 'payment_intents', paymentIntentSchema)
+  )
+}

src/lib/sync.ts

@@ -12,6 +12,7 @@ import { upsertCharges } from './charges'
 import { query } from '../utils/PostgresConnection'
 import { getConfig } from '../utils/config'
 import { pg as sql } from 'yesql'
+import { upsertPaymentIntents } from './payment_intents'
 
 const config = getConfig()
 
@@ -26,6 +27,7 @@ interface SyncBackfill {
   subscriptions?: Sync
   invoices?: Sync
   setupIntents?: Sync
+  paymentIntents?: Sync
   paymentMethods?: Sync
   disputes?: Sync
   charges?: Sync
@@ -47,6 +49,7 @@ type SyncObject =
   | 'payment_method'
   | 'dispute'
   | 'charge'
+  | 'payment_intent'
 
 export async function syncBackfill(params?: SyncBackfillParams): Promise<SyncBackfill> {
   const { created, object } = params ?? {}
@@ -58,7 +61,8 @@ export async function syncBackfill(params?: SyncBackfillParams): Promise<SyncBac
     setupIntents,
     paymentMethods,
     disputes,
-    charges
+    charges,
+    paymentIntents
 
   switch (object) {
     case 'all':
@@ -70,6 +74,7 @@ export async function syncBackfill(params?: SyncBackfillParams): Promise<SyncBac
       charges = await syncCharges(created)
       setupIntents = await syncSetupIntents(created)
       paymentMethods = await syncPaymentMethods()
+      paymentIntents = await syncPaymentIntents(created)
       break
     case 'customer':
       customers = await syncCustomers(created)
@@ -98,6 +103,9 @@ export async function syncBackfill(params?: SyncBackfillParams): Promise<SyncBac
     case 'charge':
       charges = await syncCharges(created)
       break
+    case 'payment_intent':
+      paymentIntents = await syncPaymentIntents(created)
+      break
     default:
       break
   }
@@ -112,6 +120,7 @@ export async function syncBackfill(params?: SyncBackfillParams): Promise<SyncBac
     paymentMethods,
     disputes,
     charges,
+    paymentIntents,
   }
 }
 
@@ -178,6 +187,15 @@ export async function syncSetupIntents(created?: Stripe.RangeQueryParam): Promis
   return fetchAndUpsert(() => stripe.setupIntents.list(params), upsertSetupIntents)
 }
 
+export async function syncPaymentIntents(created?: Stripe.RangeQueryParam): Promise<Sync> {
+  console.log('Syncing payment_intents')
+
+  const params: Stripe.PaymentIntentListParams = { limit: 100 }
+  if (created) params.created = created
+
+  return fetchAndUpsert(() => stripe.paymentIntents.list(params), upsertPaymentIntents)
+}
+
 export async function syncPaymentMethods(): Promise<Sync> {
   // We can't filter by date here, it is also not possible to get payment methods without specifying a customer (you need Stripe Sigma for that -.-)
   // Thus, we need to loop through all customers

src/schemas/payment_intent.ts

@@ -0,0 +1,46 @@
+import { JsonSchema } from '../types/types'
+
+export const paymentIntentSchema: JsonSchema = {
+  $id: 'paymentIntentSchema',
+  type: 'object',
+  properties: {
+    id: { type: 'text' },
+    object: { type: 'text' },
+    amount: { type: 'integer' },
+    amount_capturable: { type: 'integer' },
+    amount_details: { type: 'object' },
+    amount_received: { type: 'integer' },
+    application: { type: 'text' },
+    application_fee_amount: { type: 'integer' },
+    automatic_payment_methods: { type: 'text' },
+    canceled_at: { type: 'integer' },
+    cancellation_reason: { type: 'text' },
+    capture_method: { type: 'text' },
+    client_secret: { type: 'text' },
+    confirmation_method: { type: 'text' },
+    created: { type: 'integer' },
+    currency: { type: 'text' },
+    customer: { type: 'text' },
+    description: { type: 'text' },
+    invoice: { type: 'text' },
+    last_payment_error: { type: 'text' },
+    livemode: { type: 'boolean' },
+    metadata: { type: 'object' },
+    next_action: { type: 'text' },
+    on_behalf_of: { type: 'text' },
+    payment_method: { type: 'text' },
+    payment_method_options: { type: 'object' },
+    payment_method_types: { type: 'object' },
+    processing: { type: 'text' },
+    receipt_email: { type: 'text' },
+    review: { type: 'text' },
+    setup_future_usage: { type: 'text' },
+    shipping: { type: 'object' },
+    statement_descriptor: { type: 'text' },
+    statement_descriptor_suffix: { type: 'text' },
+    status: { type: 'text' },
+    transfer_data: { type: 'object' },
+    transfer_group: { type: 'text' },
+  },
+  required: ['id'],
+} as const