server/src/utils/scriptUtils/testUtils/initCustomerV3.ts 8:// V3 initializes the customer in Stripe, then creates the customer in Autumn 29: const { stripeCli } = ctx; 38: const testClock = await stripeCli.testHelpers.testClocks.create({ 44: // 1. Create stripe customer 45: const stripeCus = await stripeCli.customers.create({ 62: stripe_id: stripeCus.id, 70: stripeCli, 71: stripeCusId: stripeCus.id, server/src/utils/scriptUtils/testUtils/cusTestUtils.ts 4:import { createStripeCli } from "@/external/connect/createStripeCli.js"; 20: const stripeCli = createStripeCli({ org, env }); 32: const sub = await cusProductToSub({ cusProduct, stripeCli }); server/src/utils/scriptUtils/testClockUtils.ts 9:import { Stripe } from "stripe"; 12:export const getStripeNow = async ({ 13: stripeCli, 14: stripeCus, 15: stripeSub, 18: stripeCli: Stripe; 19: stripeCus?: Stripe.Customer; 20: stripeSub?: Stripe.Subscription; 25: let stripeClock = 26: await stripeCli.testHelpers.testClocks.retrieve(testClockId); 27: return stripeClock.frozen_time * 1000; 31: if (stripeSub && !stripeSub.livemode && stripeSub.test_clock) { 33: const stripeClock = await stripeCli.testHelpers.testClocks.retrieve( 34: stripeSub.test_clock as string, 36: return stripeClock.frozen_time * 1000; 40: if (stripeCus && !stripeCus.livemode && stripeCus.test_clock) { 42: const stripeClock = await stripeCli.testHelpers.testClocks.retrieve( 43: stripeCus.test_clock as string, 45: return stripeClock.frozen_time * 1000; 53: stripeCli, 63: stripeCli: Stripe; 98: await stripeCli.testHelpers.testClocks.advance(testClockId, { 109: // waitForSeconds ? waitForSeconds * 1000 : STRIPE_TEST_CLOCK_TIMING, server/src/utils/scriptUtils/scriptUtils.ts 6:import type { Stripe } from "stripe"; 8:import { createStripeCli } from "@/external/connect/createStripeCli.js"; 15:import { createReadOnlyStripeCli } from "./readOnlyStripe.js"; 17:export const getAllStripeCustomers = async ({ 20: stripeCli, 24: stripeCli: Stripe; 32: const response: any = await stripeCli.customers.list({ 55:export const getAllStripeSubscriptions = async ({ 58: stripeCli, 63: stripeCli: Stripe; 72: const response: any = await stripeCli.subscriptions.list({ 100:export const getAllStripeProducts = async ({ 103: stripeCli, 108: stripeCli: Stripe; 114: const products: Stripe.Product[] = []; 118: const response: Stripe.ApiList = 119: await stripeCli.products.list({ 162: ) as Stripe.Customer[]; 165: ) as Stripe.Subscription[]; 172: stripeCli, 179: stripeCli: Stripe; 194: const { products } = await getAllStripeProducts({ 195: stripeCli, 205: // const { customers } = await getAllStripeCustomers({ 206: // stripeCli, 215: const { subscriptions } = await getAllStripeSubscriptions({ 216: stripeCli, 247: const stripeCli: Stripe = createStripeCli({ org, env }); 261: return { stripeCli, autumnProducts, req }; 266: * This variant wraps the Stripe client in a read-only proxy that blocks all write operations. 272: * const { stripeCli, autumnProducts, req } = await initReadScript({ orgId, env }); 275: * await stripeCli.invoices.retrieve("in_xxx"); 277: * // ❌ Write operations throw ReadOnlyStripeError 278: * await stripeCli.invoices.create({ customer: "cus_xxx" }); 302: const stripeCliRaw: Stripe = createStripeCli({ org, env }); 303: const stripeCli = createReadOnlyStripeCli(stripeCliRaw); 317: return { stripeCli, autumnProducts, req }; server/src/utils/scriptUtils/resetOrgStripe.ts 3: deactivateStripeMeters, 4: deleteAllStripeProducts, 5:} from "@/external/stripe/stripeProductUtils.js"; 6:import { deleteAllStripeCustomers } from "@/external/stripe/stripeCusUtils.js"; 8:export const resetOrgStripe = async ({ org }: { org: Organization }) => { 11: await deleteAllStripeCustomers({ 16: await deleteAllStripeProducts({ 21: await deactivateStripeMeters({ server/src/utils/scriptUtils/readOnlyStripe.ts 1:import type Stripe from "stripe"; 4: * List of allowed read-only Stripe methods. 29:class ReadOnlyStripeError extends Error { 36: this.name = "ReadOnlyStripeError"; 41: * Creates a read-only proxy for a Stripe resource 57: throw new ReadOnlyStripeError(resourceName, prop); 68: * Creates a read-only Stripe client that only allows safe read operations. 73: * const stripeCli = createReadOnlyStripeCli({ org, env }); 76: * await stripeCli.invoices.retrieve("in_xxx"); 77: * await stripeCli.customers.list({ limit: 10 }); 79: * // ❌ These throw ReadOnlyStripeError 80: * await stripeCli.invoices.create({ customer: "cus_xxx" }); 81: * await stripeCli.customers.update("cus_xxx", { name: "New Name" }); 84:export function createReadOnlyStripeCli(stripeCli: Stripe): Stripe { 85: return new Proxy(stripeCli, { 97: }) as Stripe; server/src/utils/scriptUtils/logUtils/logSubItems.ts 1:import { stripeToAtmnAmount } from "@autumn/shared"; 2:import type Stripe from "stripe"; 3:import { subItemToAutumnInterval } from "@/external/stripe/utils.js"; 13: sub?: Stripe.Subscription; 14: subItems?: Stripe.SubscriptionItem[]; 28: const atmnPrice = stripeToAtmnAmount({ server/src/utils/scriptUtils/initCustomer.ts 9:import type Stripe from "stripe"; 12:import { createStripeCli } from "@/external/connect/createStripeCli.js"; 16: createStripeCustomer, 17:} from "../../external/stripe/stripeCusUtils.js"; 19:export const createCusInStripe = async ({ 32: const stripeCustomer = await createStripeCustomer({ 46: type: ProcessorType.Stripe, 47: id: stripeCustomer.id, 53: id: stripeCustomer.id, 54: type: "stripe", 57: return stripeCustomer; 108: const stripeCli = createStripeCli({ org: org, env: env }); 111: const testClock = await stripeCli.testHelpers.testClocks.create({ 127: await createCusInStripe({ 147: stripeCli, 148: stripeCusId, 151: stripeCli: Stripe; 152: stripeCusId: string; 159: await stripeCli.paymentMethods.attach("pm_card_authenticationRequired", { 160: customer: stripeCusId, 163: const pms = await stripeCli.paymentMethods.list({ 164: customer: stripeCusId, 167: await stripeCli.customers.update(stripeCusId, { 174: const pm = await stripeCli.paymentMethods.create({ 181: await stripeCli.paymentMethods.attach(pm.id, { 182: customer: stripeCusId, 185: await stripeCli.customers.update(stripeCusId, { 195:// V2 initializes the customer in Stripe, then creates the customer in Autumn 218: const stripeCli = createStripeCli({ org, env }); 223: const testClock = await stripeCli.testHelpers.testClocks.create({ 229: // 1. Create stripe customer 230: const stripeCus = await stripeCli.customers.create({ 246: stripe_id: stripeCus.id, 253: stripeCli, 254: stripeCusId: stripeCus.id, server/src/utils/scriptUtils/getAll/getAllStripeSubs.ts 1:import type { Stripe } from "stripe"; 4:export const getAllStripeSubscriptions = async ({ 7: stripeCli, 12: stripeCli: Stripe; 21: const response: any = await stripeCli.subscriptions.list({ 52:export const getAllStripeSchedules = async ({ 55: stripeCli, 60: stripeCli: Stripe; 69: const response: any = await stripeCli.subscriptionSchedules.list({ server/src/utils/routerUtils/expressErrorSkip.ts 6:import Stripe from "stripe"; 68: // Handle Stripe errors 69: if (error instanceof Stripe.errors.StripeError) { server/src/trigger/arrearProratedUsage/handleProratedUpgrade.ts 10:import type Stripe from "stripe"; 97: stripeCli, 108: stripeCli: Stripe; 112: sub: Stripe.Subscription; 113: subItem: Stripe.SubscriptionItem; 154: stripeCli, 180: await stripeCli.subscriptionItems.update(subItem.id, { server/src/utils/models/ItemSet.ts 2:import type Stripe from "stripe"; 16: subItems: (Stripe.SubscriptionUpdateParams.Item & { 19: invoiceItems: Stripe.SubscriptionUpdateParams.AddInvoiceItem[]; server/src/utils/initUtils.ts 12: `ENCRYPTION_IV or ENCRYPTION_PASSWORD is not set (used for Stripe key encryption)`, server/src/trigger/arrearProratedUsage/handleProratedDowngrade.ts 14:import type Stripe from "stripe"; 17:import { constructStripeInvoiceItem } from "@/internal/invoices/invoiceItemUtils/invoiceItemUtils.js"; 28:import { getStripeNow } from "@/utils/scriptUtils/testClockUtils.js"; 33: stripeCli, 47: stripeCli: Stripe; 48: sub: Stripe.Subscription; 49: subItem: Stripe.SubscriptionItem; 61: const now = await getStripeNow({ stripeCli, stripeSub: sub }); 92: const invoiceItem = constructStripeInvoiceItem({ 98: stripeSubId: sub.id, 99: stripeCustomerId: sub.customer as string, 104: await stripeCli.invoiceItems.create(invoiceItem); 114: stripeCli, 116: stripeCusId: sub.customer as string, 117: stripeSubId: sub.id, 130: stripeCli, 141: stripeCli: Stripe; 144: sub: Stripe.Subscription; 145: subItem: Stripe.SubscriptionItem; 195: stripeCli, 232: await stripeCli.subscriptionItems.update(subItem.id, { server/src/utils/importUtils/importUtils.ts 1:import Stripe from "stripe"; 12: subItems: Stripe.SubscriptionItem[]; server/src/trigger/arrearProratedUsage/createUpgradeProrationInvoice.ts 12:import type Stripe from "stripe"; 13:import { getCusPaymentMethod } from "@/external/stripe/stripeCusUtils.js"; 14:import { constructStripeInvoiceItem } from "@/internal/invoices/invoiceItemUtils/invoiceItemUtils.js"; 22:import { getStripeNow } from "@/utils/scriptUtils/testClockUtils.js"; 35: stripeSub, 48: stripeSub: Stripe.Subscription; 49: subItem: Stripe.SubscriptionItem; 78: const invoiceItem = constructStripeInvoiceItem({ 84: stripeSubId: stripeSub.id, 85: stripeCustomerId: stripeSub.customer as string, 100: stripeCli, 114: stripeCli: Stripe; 115: sub: Stripe.Subscription; 116: subItem: Stripe.SubscriptionItem; 126: const now = await getStripeNow({ stripeCli, stripeSub: sub }); 129: stripeCli, 130: stripeId: sub.customer as string, 143: stripeSub: sub, 159: await stripeCli.invoiceItems.create(invoiceItem); 163: stripeCli, 165: stripeCusId: sub.customer as string, 166: stripeSubId: sub.id, server/src/utils/importUtils/addUsagePricesToSub.ts 1:import { findStripeItemForPrice } from "@/external/stripe/stripeSubUtils/stripeSubItemUtils.js"; 10:import Stripe from "stripe"; 13:import { getUsageBasedSub } from "@/external/stripe/stripeSubUtils.js"; 18: stripe, 24: stripe: Stripe; 25: sub: Stripe.Subscription; 43: const latestSub = await stripe.subscriptions.retrieve(sub.id); 44: let subItem = findStripeItemForPrice({ 46: stripeItems: latestSub.items.data, 54: const newSubItem = await stripe.subscriptionItems.create({ 56: price: usagePrice.config.stripe_price_id!, 71: stripeCli, 72: stripeSub, 76: stripeCli: Stripe; 77: stripeSub: Stripe.Subscription; 89: stripeCli, 95: let subItem = findStripeItemForPrice({ 97: stripeItems: stripeSub.items.data, 106: logger.info(`Adding ${config.feature_id} to sub ${stripeSub.id}`); 107: let stripePrice = await stripeCli.prices.retrieve( 108: price.config.stripe_price_id!, 111: if (stripePrice.recurring?.usage_type !== "metered") { 118: await stripeCli.subscriptionItems.create({ 119: subscription: stripeSub.id, 120: price: price.config.stripe_price_id!, server/src/utils/importUtils/addProductFromSubs.ts 11:import type Stripe from "stripe"; 12:import { subToPeriodStartEnd } from "@/external/stripe/stripeSubUtils/convertSubUtils.js"; 13:import { stripeToAutumnSubStatus } from "@/external/stripe/stripeSubUtils.js"; 14:import { subToAutumnInterval } from "@/external/stripe/utils.js"; 36: sub?: Stripe.Subscription; 116: ? (stripeToAutumnSubStatus(sub?.status) as CusProductStatus) 135: const subFromDb = await SubService.getInStripeIds({ 146: stripeId: sub.id, server/src/trigger/adjustAllowance.ts 16:import type Stripe from "stripe"; 18:import { createStripeCli } from "@/external/connect/createStripeCli.js"; 19:import { findStripeItemForPrice } from "@/external/stripe/stripeSubUtils/stripeSubItemUtils.js"; 117: const stripeCli = createStripeCli({ org, env }); 120: stripeCli, 125: // stripeCli, 135: const subItem = findStripeItemForPrice({ 137: stripeItems: sub.items.data, 150: stripeCli, 154: subItem: subItem as Stripe.SubscriptionItem, 164: stripeCli, 168: subItem: subItem as Stripe.SubscriptionItem, server/src/utils/errorUtils.ts 5:import Stripe from "stripe"; 12: error instanceof RecaseError && error.code === ErrCode.StripeCardDeclined 89: if (error instanceof Stripe.errors.StripeError) { 99: `STRIPE ERROR (${req.org?.slug || "unknown"}): ${error.message}`, 109: message: `(Stripe Error) ${error.message}`, 110: code: `stripe_error`, server/src/scan/runScan.ts 14:import type Stripe from "stripe"; 16:import { createStripeCli } from "@/external/connect/createStripeCli.js"; 17:import { getStripeSchedules } from "@/external/stripe/stripeSubUtils.js"; 31: getAllStripeSchedules, 32: getAllStripeSubscriptions, 33:} from "@/utils/scriptUtils/getAll/getAllStripeSubs.js"; 48: stripeCli, 53: stripeCli: Stripe; 67: const stripeCusId = customers[0].processor?.id; 68: const stripeSubs = stripeCusId 70: await stripeCli.subscriptions.list({ 71: customer: stripeCusId, 77: // const stripeSubs = await getStripeSubs({ 78: // stripeCli, 90: const stripeSchedules = await getStripeSchedules({ 91: stripeCli, 100: return { customers, stripeSubs, stripeSchedules, entities }; 111: subs: Stripe.Subscription[]; 112: schedules: Stripe.SubscriptionSchedule[]; 179: const stripeSubs = subs.filter((sub: any) => 184: stripeSubs.length === cusProduct.subscription_ids!.length, 185: "number of stripe subs should be the same as number of subscription ids", 188: // let subItems = stripeSubs.flatMap((sub: any) => sub.items.data); 222: subs: Stripe.Subscription[]; 224: schedules: Stripe.SubscriptionSchedule[]; 266: const stripeCli = createStripeCli({ 275: let stripeSubs: Stripe.Subscription[] = []; 276: let stripeSchedules: Stripe.SubscriptionSchedule[] = []; 281: stripeCli, 288: stripeSubs = res.stripeSubs; 291: const [customersRes, stripeSubsRes, stripeSchedulesRes, entitiesRes] = 298: getAllStripeSubscriptions({ 299: stripeCli, 302: getAllStripeSchedules({ 303: stripeCli, 314: stripeSubs = stripeSubsRes.subscriptions; 315: stripeSchedules = stripeSchedulesRes.schedules; 329: subs: stripeSubs, 330: schedules: stripeSchedules, server/src/utils/checkUtils/checkSubCountMatch.ts 4:import type Stripe from "stripe"; 17: subs: Stripe.Subscription[]; 23: const stripeSubs = subs.filter((sub) => { 34: if (stripeSubs.length !== filteredSubIds.length) { 36: // const invoiceMetadata = await MetadataService.getByStripeInvoiceId({ 38: // stripeInvoiceId: stripeSubs.map((sub) => sub.latest_invoice), 41: const invoiceIds = stripeSubs.map((sub) => sub.latest_invoice); 42: // Count of rows in metadata table with stripe_invoice_id in invoiceIds 46: .where(inArray(metadata.stripe_invoice_id, invoiceIds as string[])); 52: stripeSubs.length - (metadataCount?.[0]?.count || 0) !== 56: const errorMsg = `Expected ${subIds.length} subs in total, found ${stripeSubs.length} in Stripe`; 67: // `Expected ${subIds.length} subs in total, found ${stripeSubs.length} in Stripe`, server/src/utils/checkUtils/checkCustomerState.ts 3:import type Stripe from "stripe"; 33: subs: Stripe.Subscription[]; 34: schedules: Stripe.SubscriptionSchedule[]; 44: // If fullCus has no processor ID, unlinked from Stripe 47: result.warnings.push("Customer is unlinked from Stripe"); 73: // Check: Subscription IDs match Stripe 108: subs: Stripe.Subscription[]; 109: schedules: Stripe.SubscriptionSchedule[]; server/src/utils/checkUtils/checkCustomerCorrect.ts 15:import { priceToStripeItem } from "@server/external/stripe/priceToStripeItem/priceToStripeItem"; 16:import { isStripeSubscriptionCanceled } from "@server/external/stripe/stripeSubUtils"; 38:import type Stripe from "stripe"; 83: items: { price: string; quantity: number; stripeProdId?: string }[]; 87: const autumnPrices = await PriceService.getByStripeIds({ 89: stripePriceIds: priceIds, 144: // If only one item, allow matching by stripe prod id 146: // If prices match, allow item.stripeProdId to match... 148: // if (item.stripeProdId == (expectedItem as any).stripeProdId) return true; 155: return item.stripeProdId === expectedItem.stripeProdId; 214: const price = await PriceService.getByStripeId({ 216: stripePriceId: expectedItem.price, 267: subs: Stripe.Subscription[]; 268: schedules: Stripe.SubscriptionSchedule[]; 406: const res = priceToStripeItem({ 448: stripeProdId: product.processor?.id, 494: stripeProdId: item.price.product, 540: isStripeSubscriptionCanceled({ sub: sub! }), 572: price: (item.price as Stripe.Price).id, server/src/utils/authUtils/afterOrgCreated.ts 42: createStripeAccount = true, 46: createStripeAccount?: boolean; 60: // 1. Add stripe connect config 61: if (createStripeAccount) { 62: console.log("Creating stripe connect account"); 63: const stripeConnectAccount = await createConnectAccount({ 73: test_stripe_connect: { 74: default_account_id: stripeConnectAccount.id, server/src/honoUtils/MIGRATION_SUMMARY.md 79:/webhooks/stripe # Stripe webhooks 128:- [ ] `/webhooks/stripe` server/src/honoUtils/HonoEnv.ts 41: // Optional (should be populated in Stripe customer?) server/src/honoUtils/EXPRESS_TO_HONO_MIGRATION.md 32:- `/stripe/oauth_callback` - `handleOAuthCallback` (Hono) 119:- GET `/organization/stripe` - handleGetStripeAccount 120:- DELETE `/organization/stripe` - handleDeleteStripe 121:- POST `/organization/stripe` - handleConnectStripe 122:- GET `/organization/stripe/oauth_url` - handleGetOAuthUrl 167:POST /dev/cli/stripe # Update Stripe keys from CLI 265:GET /v1/invoices/:stripe_invoice_id/stripe # Get Stripe invoice 380:POST /webhooks/stripe/:orgId/:env # stripeWebhookRouter 419:21. `/webhooks/stripe` - stripeWebhookRouter server/src/honoMiddlewares/errorSkipMiddleware.ts 4:import Stripe from "stripe"; 47: name: "Stripe webhook secret not set in development", 50: "STRIPE_WEBHOOK_SECRET env variable is not set (live)", 56:/** Stripe-specific error handling rules */ 57:const STRIPE_RULES = [ 61: err instanceof Stripe.errors.StripeError && 70: err instanceof Stripe.errors.StripeError && 79: err instanceof Stripe.errors.StripeError && 88: err instanceof Stripe.errors.StripeError && 96: err instanceof Stripe.errors.StripeError && 104: err instanceof Stripe.errors.StripeError && 114: err instanceof Stripe.errors.StripeError && 124: err instanceof Stripe.errors.StripeError && 250: // 4. Check Stripe-specific rules 251: for (const rule of STRIPE_RULES) { 253: const stripeErr = err as Stripe.errors.StripeError; 258: message: stripeErr.message, server/src/honoMiddlewares/errorMiddleware.ts 5:import Stripe from "stripe"; 65: // 2. Handle Stripe errors 66: if (err instanceof Stripe.errors.StripeError) { 68: `STRIPE ERROR (${ctx.org?.slug || "unknown"}): ${err.message}`, 80: message: `(Stripe Error) ${err.message}`, 81: code: ErrCode.StripeError, server/src/internal/subscriptions/subUtils.ts 5: stripeId, 6: stripeScheduleId, 13: stripeId?: string; 14: stripeScheduleId?: string; 23: stripe_id: stripeId || null, 24: stripe_schedule_id: stripeScheduleId || null, server/src/internal/subscriptions/SubService.ts 8:import { subToPeriodStartEnd } from "@server/external/stripe/stripeSubUtils/convertSubUtils.js"; 12:import type Stripe from "stripe"; 31: stripeId, 38: stripeId?: string; 44: if (!stripeId && !scheduleId) { 45: throw new Error("Either stripeId or scheduleId must be provided"); 53: stripeId ? eq(subscriptions.stripe_id, stripeId) : undefined, 55: ? eq(subscriptions.stripe_schedule_id, scheduleId) 66: stripe_id: stripeId || null, 67: stripe_schedule_id: scheduleId || null, 99: static async updateFromStripe({ 101: stripeSub, 104: stripeSub: Stripe.Subscription; 106: const { start, end } = subToPeriodStartEnd({ sub: stripeSub }); 113: .where(eq(subscriptions.stripe_id, stripeSub.id)) 133: .where(eq(subscriptions.stripe_schedule_id, scheduleId)); 151: .where(eq(subscriptions.stripe_schedule_id, scheduleId)); 168: .where(eq(subscriptions.stripe_schedule_id, scheduleId)) 178: static async getInStripeIds({ db, ids }: { db: DrizzleCli; ids: string[] }) { 182: .where(inArray(subscriptions.stripe_id, ids))) as Subscription[]; server/src/internal/rewards/triggerCheckoutReward.ts 10:import { createStripeCli } from "@/external/connect/createStripeCli.js"; 28: const stripeCli = createStripeCli({ 83: const sub = await stripeCli.subscriptions.retrieve(subId); server/src/internal/rewards/rewardUtils.ts 12: stripeToAtmnAmount, 15:import type Stripe from "stripe"; 21:import { initProductInStripe } from "../products/productUtils.js"; 120:export const initRewardStripePrices = async ({ 134: nullish(p.config.stripe_price_id), 152: initProductInStripe({ 197: subDiscounts: Stripe.Discount[]; 216: const atmnDiscountValue = stripeToAtmnAmount({ 238: discount: Stripe.Discount; 253: (stripeProdId) => stripeProdId === product.processor?.id, 258: (stripeProdId) => stripeProdId === price.config.stripe_product_id, 285:export const getAmountAfterStripeDiscounts = ({ 289: stripeDiscounts, 295: stripeDiscounts: Stripe.Discount[]; 300: for (const discount of stripeDiscounts) { 317: const atmnDiscountAmount = stripeToAtmnAmount({ server/src/external/vercel/misc/vercelSubscriptions.ts 12:import type Stripe from "stripe"; 14:import { getCusPaymentMethod } from "@/external/stripe/stripeCusUtils.js"; 15:import { getStripeSubItems2 } from "@/external/stripe/stripeSubUtils/getStripeSubItems.js"; 17:import { createStripeSub2 } from "@/internal/customers/attach/attachFunctions/addProductFlow/createStripeSub2.js"; 28: * Creates a Stripe subscription for Vercel marketplace integration (installation-level billing only) 33: * 3. Creates Stripe subscription with collection_method: "charge_automatically" 47: stripeCustomer, 48: stripeCli, 61: stripeCustomer: Stripe.Customer; 62: stripeCli: Stripe; 72: const existingSubscription = stripeCustomer.subscriptions?.data.find( 116: stripeCli, 117: stripeId: customer.processor.id, 144: stripeCli, 145: stripeCustomer, 174: const itemSet = await getStripeSubItems2({ 179: // 7. Create Stripe subscription 180: await createStripeSub2({ 182: stripeCli, 196: // - Reports payment to Stripe via Payment Records API server/src/internal/rewards/referralUtils/triggerFreePaidProduct.ts 13:import type Stripe from "stripe"; 14:import { createStripeCli } from "@/external/connect/createStripeCli.js"; 15:import { createStripeCusIfNotExists } from "@/external/stripe/stripeCusUtils.js"; 21:import { isStripeConnected } from "@/internal/orgs/orgUtils.js"; 80: if (!isStripeConnected({ org, env })) { 82: message: "Stripe is not connected", 83: code: ErrCode.StripeConfigNotFound, 89: const stripeCli = createStripeCli({ org, env }); 114: const curDiscounts = (sub.discounts as Stripe.Discount[]) || []; 122: await stripeCli.subscriptions.update(sub.id, { 124: ...curDiscounts.map((d: Stripe.Discount) => ({ 138: // Create stripe customer if not exists 139: await createStripeCusIfNotExists({ server/src/external/vercel/misc/vercelInvoicing.ts 19:import type Stripe from "stripe"; 32: * 4. marketplace.invoice.paid → handleMarketplaceInvoicePaid creates cus_product and reports payment to Stripe 47: invoice: Stripe.Invoice; 113: invoice: Stripe.Invoice; 233: stripeCli, 234: stripeCustomer, 249: stripeCli: Stripe; 250: stripeCustomer: Stripe.Customer; 261: customPaymentMethod: Stripe.PaymentMethod | null; 266: stripeCli, 267: stripeCus: stripeCustomer, 288: // Store Vercel metadata on the Stripe subscription for webhook handlers server/src/internal/rewards/referralUtils.ts 10:import type Stripe from "stripe"; 12:import { createStripeCli } from "@/external/connect/createStripeCli.js"; 13:import { createStripeCusIfNotExists } from "@/external/stripe/stripeCusUtils.js"; 104: const stripeCli = createStripeCli({ 110: await createStripeCusIfNotExists({ 118: const stripeCusId = customer.processor.id; 119: const stripeCus = (await stripeCli.customers.retrieve( 120: stripeCusId, 121: )) as Stripe.Customer; 123: if (!stripeCus.discount) { 124: await stripeCli.customers.update(stripeCusId, { 135: logger.info(`Applied coupon to customer in Stripe`); server/src/external/vercel/handlers/resources/handleDeleteResource.ts 2:import { createStripeCli } from "@/external/connect/createStripeCli.js"; 21: const stripeCli = createStripeCli({ org, env: env as AppEnv }); 56: await stripeCli.subscriptions.cancel(subId); server/src/internal/products/productV2Utils.ts 98: stripe_id: product.processor?.id || null, server/src/external/vercel/handlers/resources/handleCreateResource.ts 12:import { createStripeCli } from "@/external/connect/createStripeCli.js"; 64: const stripeCli = createStripeCli({ org, env: env as AppEnv }); 65: const stripeCustomer = await stripeCli.customers.retrieve( 72: if (stripeCustomer.deleted) { 107: stripeCustomer, 108: stripeCli, server/src/external/vercel/handlers/marketplace/handleMarketplaceInvoidNotPaid.ts 3:import { createStripeCli } from "@/external/connect/createStripeCli.js"; 31: const stripeCli = createStripeCli({ org, env }); 34: const invoice = await stripeCli.invoices.retrieve(externalInvoiceId, { 45: const subscription = await stripeCli.subscriptions.retrieve( 53: const customPaymentMethod = await stripeCli.paymentMethods.retrieve( 58: const partialCustomer = await CusService.getByStripeId({ 60: stripeId: invoice.customer as string, 67: stripeCustomerId: invoice.customer, 126: // 5. Report failed payment to Stripe via Payment Records API 127: // This marks the payment as "failed" and allows Stripe to mark the invoice as not paid 128: const paymentRecord = await stripeCli.paymentRecords.reportPayment({ 155: await stripeCli.invoices.attachPayment(externalInvoiceId, { 166: await stripeCli.subscriptions.cancel(subscription.id); server/src/external/vercel/handlers/marketplace/handleMarketplaceInvoicePaid.ts 8:import { createStripeCli } from "@/external/connect/createStripeCli.js"; 10:import { sendUsageAndReset } from "@/external/stripe/webhookHandlers/handleInvoiceCreated/handleInvoiceCreated.js"; 42: const stripeCli = createStripeCli({ org, env }); 45: const invoice = await stripeCli.invoices.retrieve(externalInvoiceId, { 56: const subscription = await stripeCli.subscriptions.retrieve( 64: const customPaymentMethod = await stripeCli.paymentMethods.retrieve( 69: const partialCustomer = await CusService.getByStripeId({ 71: stripeId: invoice.customer as string, 109: const existingCusProducts = await CusProductService.getByStripeSubId({ 111: stripeSubId: subscription.id, 183: stripeCli, 210: // 5. Report successful payment to Stripe via Payment Records API 211: // This marks the payment as "guaranteed" and allows Stripe to mark the invoice as paid 212: const paymentRecord = await stripeCli.paymentRecords.reportPayment({ 239: await stripeCli.invoices.attachPayment(externalInvoiceId, { server/src/external/vercel/handlers/installations/handleUpsertInstallation.ts 8:import { createStripeCli } from "@/external/connect/createStripeCli.js"; 9:import { createCustomStripeCard } from "@/external/stripe/stripeCardUtils.js"; 10:import { createStripeCustomer } from "@/external/stripe/stripeCusUtils.js"; 73: const stripeCli = createStripeCli({ org: ctx.org, env: ctx.env }); 74: const testClock = await stripeCli.testHelpers.testClocks.create({ 80: const stripeCustomer = await createStripeCustomer({ 90: if (stripeCustomer) { 92: const customPaymentMethod = await createCustomStripeCard({ 98: id: stripeCustomer.id, 99: type: ProcessorType.Stripe, 117: id: stripeCustomer.id, 118: type: ProcessorType.Stripe, server/src/external/vercel/handlers/installations/handleDeleteInstallation.ts 65: deleteInStripe: true, server/src/external/vercel/handlers/handleUpdateBillingPlan.ts 5:import { createStripeCli } from "@/external/connect/createStripeCli.js"; 56: const stripeCli = createStripeCli({ 61: const stripeCustomer = await stripeCli.customers.retrieve( 68: if (stripeCustomer.deleted) { 76: const existingSubscription = stripeCustomer.subscriptions?.data.find( 97: stripeCustomer, 98: stripeCli, 120: await stripeCli.subscriptions.cancel(existingSubscription.id); 132: // If higher tier → upgrade (updateStripeSub2), if lower tier → downgrade server/src/internal/products/productUtils.ts 25:import { createStripeCli } from "@server/external/connect/createStripeCli.js"; 26:import { createStripePriceIFNotExist } from "@server/external/stripe/createStripePrice/createStripePrice.js"; 34:import { Stripe } from "stripe"; 39:import { isStripeConnected } from "../orgs/orgUtils.js"; 230:export const checkStripeProductExists = async ({ 244: const stripeCli = createStripeCli({ 253: const stripeProduct = await stripeCli.products.retrieve( 257: if (!stripeProduct.active) { 258: await stripeCli.products.update(product.processor!.id, { 264: error instanceof Stripe.errors.StripeError && 275: logger.info(`Creating new product in Stripe for ${product.name}`); 276: const stripeProduct = await stripeCli.products.create({ 284: processor: { id: stripeProduct.id, type: ProcessorType.Stripe }, 289: id: stripeProduct.id, 290: type: ProcessorType.Stripe, 407: // Clear Stripe IDs 408: config.stripe_meter_id = undefined; 409: config.stripe_product_id = undefined; 410: config.stripe_placeholder_price_id = undefined; 411: config.stripe_price_id = undefined; 486: // await initProductInStripe({ 526:export const initProductInStripe = async ({ 539: if (!isStripeConnected({ org, env })) return; 541: await checkStripeProductExists({ 550: const stripeCli = createStripeCli({ 556: createStripePriceIFNotExist({ 559: stripeCli, 571:export const searchProductsByStripeId = async ({ 573: stripeId, 576: stripeId: string; 578: return products.find((p) => p.processor?.id === stripeId); server/src/internal/products/product-items/productItemUtils/itemToPriceAndEnt.ts 78: stripe_product_id: null, 302: newConfig.stripe_meter_id = curConfig.stripe_meter_id; 303: newConfig.stripe_product_id = curConfig.stripe_product_id; server/src/external/stripe/webhookUtils/webhookUtils.ts 9:import type Stripe from "stripe"; 15: stripeCli, 22: stripeCli: Stripe; 23: paymentMethod?: Stripe.PaymentMethod | null; 32: stripeCli, server/src/external/stripe/webhookMiddlewares/stripeWebhookRefreshMiddleware.ts 7:import type { StripeWebhookHonoEnv } from "./stripeWebhookContext.js"; 28:export const stripeWebhookRefreshMiddleware = async ( 29: c: Context, 37: const { db, logger, org, env, stripeEvent } = ctx; 39: if (!stripeEvent) return; 41: const eventType = stripeEvent.type; 42: const data = stripeEvent.data; 50: const stripeCusId = (data.object as { customer?: string }).customer; 51: if (!stripeCusId) { 53: `stripe webhook cache refresh, object doesn't contain customer id`, 109: source: `stripeWebhookRefreshMiddleware: ${eventType}`, 114: logger.error(`Stripe webhook, error refreshing cache: ${error}`, { server/src/external/stripe/webhookMiddlewares/stripeWebhookContext.ts 2:import type Stripe from "stripe"; 5:export interface StripeWebhookContext extends AutumnContext { 6: stripeEvent: Stripe.Event; 7: stripeCli: Stripe; 11:export type StripeWebhookHonoEnv = { 13: ctx: StripeWebhookContext; server/src/external/stripe/webhookMiddlewares/stripeToCustomerIdMiddleware.ts 4: StripeWebhookContext, 5: StripeWebhookHonoEnv, 6:} from "./stripeWebhookContext"; 11: ctx: StripeWebhookContext; 13: const { stripeEvent } = ctx; 15: // 1. Get stripe customer ID from stripe event 16: const getStripeCustomerId = () => { 17: switch (stripeEvent.type) { 27: return stripeEvent.data.object.customer; 30: return stripeEvent.data.object.id; 34: const stripeCustomerId = getStripeCustomerId(); 35: if (!stripeCustomerId) return; 37: const cus = await CusService.getByStripeId({ 39: stripeId: stripeCustomerId as string, 49:export const stripeToCustomerIdMiddleware = async ( 50: c: Context, 53: const ctx = c.get("ctx") as StripeWebhookContext; server/src/external/stripe/webhookMiddlewares/stripeLegacySeederMiddleware.ts 3:import Stripe from "stripe"; 6: getStripeWebhookSecret, 7: isStripeConnected, 9:import { createStripeCli } from "../../connect/createStripeCli.js"; 11: StripeWebhookContext, 12: StripeWebhookHonoEnv, 13:} from "./stripeWebhookContext.js"; 16: * Seeder middleware for legacy Stripe webhooks (orgs that pasted their secret keys) 19: * - Sets up StripeWebhookContext (org, env, features, stripeEvent) 21:export const stripeLegacySeederMiddleware = async ( 22: c: Context, 25: const ctx = c.get("ctx") as StripeWebhookContext; 43: // Step 2: Check if org is connected to Stripe 44: if (!isStripeConnected({ org, env })) { 45: logger.info(`Org ${orgId} and env ${env} is not connected to stripe`); 47: { message: `Org ${orgId} and env ${env} is not connected to stripe` }, 54: const signature = c.req.header("stripe-signature") || ""; 56: let event: Stripe.Event; 58: const webhookSecret = getStripeWebhookSecret(org, env); 59: event = await Stripe.webhooks.constructEventAsync( 73: ctx.authType = AuthType.Stripe; 74: ctx.stripeEvent = event; 75: ctx.stripeCli = createStripeCli({ org, env }); server/src/external/stripe/webhookMiddlewares/stripeInitLoggerMiddleware.ts 3:import type { StripeWebhookHonoEnv } from "./stripeWebhookContext"; 5:export const stripeInitLoggerMiddleware = async ( 6: c: Context, 10: const { stripeEvent, org, env, customer } = ctx; 15: event_type: stripeEvent.type, 16: event_id: stripeEvent.id, 18: object_id: `${stripeEvent.data?.object?.id}` || "N/A", 19: authType: AuthType.Stripe, server/src/internal/products/prices/priceUtils/usagePriceUtils/classifyUsagePrice.ts 13:import type Stripe from "stripe"; 84:export const onIncreaseToStripeProration = ({ 96: return behavior as Stripe.SubscriptionItemUpdateParams.ProrationBehavior; 99:export const onDecreaseToStripeProration = ({ 111: return behavior as Stripe.SubscriptionItemUpdateParams.ProrationBehavior; server/src/external/stripe/webhookMiddlewares/stripeConnectSeederMiddleware.ts 8:import type { Stripe } from "stripe"; 10: getStripeWebhookSecret, 11: initMasterStripe, 12:} from "@/external/connect/initStripeCli.js"; 14:import { createStripeCli } from "../../connect/createStripeCli.js"; 16: StripeWebhookContext, 17: StripeWebhookHonoEnv, 18:} from "./stripeWebhookContext.js"; 21: * Seeder middleware for Stripe Connect webhooks 22: * - Verifies webhook signature using master stripe 24: * - Sets up StripeWebhookContext (org, env, features, stripeEvent) 26:export const stripeConnectSeederMiddleware = async ( 27: c: Context, 30: const ctx = c.get("ctx") as StripeWebhookContext; 34: // Step 1: Initialize master stripe client 35: let masterStripe: Stripe; 37: masterStripe = initMasterStripe(); 39: logger.error(`Failed to initialize master stripe client ${error}`); 40: return c.json({ error: "Failed to initialize stripe client" }, 500); 44: const webhookSecret = await getStripeWebhookSecret({ 52: const signature = c.req.header("stripe-signature") || ""; 54: let event: Stripe.Event; 56: event = await masterStripe.webhooks.constructEventAsync( 88: `Account ID ${accountId} not linked to any org, skipping Stripe webhook`, 92: { message: "Account ID not linked to any org, skipping Stripe webhook" }, 101: ctx.authType = AuthType.Stripe; 102: ctx.stripeEvent = event; 103: ctx.stripeCli = createStripeCli({ org, env }); server/src/internal/products/prices/priceUtils/findPriceUtils.ts 83: return config.stripe_placeholder_price_id == placeholderId; 87:export const findPriceFromStripeId = ({ 89: stripePriceId, 93: stripePriceId: string; 98: const idMatch = config.stripe_price_id == stripePriceId; server/src/internal/products/prices/priceUtils/constructPriceUtils.ts 4: stripeToAtmnAmount, 6:import type Stripe from "stripe"; 7:import { subItemToAutumnInterval } from "@/external/stripe/utils.js"; 15: subItem: Stripe.SubscriptionItem; 23: const atmnAmount = stripeToAtmnAmount({ 37: stripe_price_id: price.id, 39: stripe_product_id: undefined, server/src/external/stripe/webhookHandlers/handleSubUpdated/handleSubRenewed.ts 2:import type Stripe from "stripe"; 15: sub: Stripe.Subscription; 41: sub: Stripe.Subscription; 74: await CusProductService.updateByStripeSubId({ 76: stripeSubId: sub.id, server/src/external/stripe/webhookHandlers/handleSubUpdated/handleSubPastDue.ts 6:import type Stripe from "stripe"; 17: sub: Stripe.Subscription; 37: sub: Stripe.Subscription; server/src/external/stripe/webhookHandlers/handleSubUpdated/handleSubCanceled.ts 7:import type Stripe from "stripe"; 20:} from "../../stripeSubUtils/convertSubUtils.js"; 27: sub: Stripe.Subscription; 56: sub: Stripe.Subscription; 66: `sub.updated: updating cus products to canceled, stripeSubId=${sub.id}, canceledAt=${canceledAt}`, 71: await CusProductService.updateByStripeSubId({ 73: stripeSubId: sub.id, 91: sub: Stripe.Subscription; server/src/external/stripe/webhookHandlers/handleSubUpdated/handleSchedulePhaseCompleted.ts 6:import type Stripe from "stripe"; 7:import { createStripeCli } from "@/external/connect/createStripeCli.js"; 13:import { getStripeNow } from "@/utils/scriptUtils/testClockUtils.js"; 23: subObject: Stripe.Subscription; 34: const stripeCli = createStripeCli({ org, env }); 35: const schedule = await stripeCli.subscriptionSchedules.retrieve( 49: const now = await getStripeNow({ 50: stripeCli, 51: stripeCus: schedule.customer as Stripe.Customer, 126: await stripeCli.subscriptionSchedules.release(schedule.id); 127: await CusProductService.updateByStripeScheduledId({ 129: stripeScheduledId: schedule.id, server/src/internal/products/prices/priceUtils/arrearProratedUtils/getContUsageDowngradeItem.ts 76: // stripeCli, server/src/external/stripe/webhookHandlers/handleSubUpdated.ts 6:import type Stripe from "stripe"; 7:import { createStripeCli } from "@/external/connect/createStripeCli.js"; 22: subscription: Stripe.Subscription; 33: // Get cus products by stripe sub id 34: const cusProducts = await CusProductService.getByStripeSubId({ 36: stripeSubId: subscription.id, 45: const stripeCli = createStripeCli({ 49: const fullSub = await stripeCli.subscriptions.retrieve(subscription.id); 60: const updatedCusProducts = await CusProductService.updateByStripeSubId({ 62: stripeSubId: subscription.id, 101: await SubService.updateFromStripe({ 103: stripeSub: fullSub, 107: `Failed to update sub from stripe. Stripe sub ID: ${subscription.id}, org: ${org.slug}, env: ${env}`, 124: const stripeCli = createStripeCli({ 129: const latestInvoice = await stripeCli.invoices.retrieve( 149: await stripeCli.subscriptions.cancel(subscription.id); 151: await stripeCli.invoices.voidInvoice(subscription.latest_invoice); server/src/external/stripe/webhookHandlers/handleSubScheduleCanceled.ts 2:import type Stripe from "stripe"; 13: schedule: Stripe.SubscriptionSchedule; server/src/internal/products/prices/billingIntervalUtils.ts 257:// e.g. Sep 30 anchor -> Aug 30, Jul 30, Feb 28/29 (follows Stripe behavior) 292: // This follows Stripe's behavior: Sep 30 -> Feb 28, Jul 31 -> Feb 28, etc. 335:// e.g. Sep 30 anchor -> Oct 30, Nov 30, Feb 28/29 (follows Stripe behavior) 371: // This follows Stripe's behavior: Sep 30 -> Feb 28, Jul 31 -> Feb 28, etc. server/src/external/stripe/webhookHandlers/handleSubDeleted/handleCusProductDeleted.ts 9:import type Stripe from "stripe"; 21:import { getCusPaymentMethod } from "../../stripeCusUtils.js"; 27: stripeCli, 34: stripeCli: Stripe; 36: subscription: Stripe.Subscription; 50: stripeCli, 51: stripeId: fullCus.processor?.id, 75: stripeCli, server/src/internal/products/prices/PriceService.ts 85: static async getByStripeId({ 87: stripePriceId, 90: stripePriceId: string; 94: sql`${prices.config} ->> 'stripe_price_id' = ${stripePriceId}`, 95: sql`${prices.config} ->> 'stripe_empty_price_id' = ${stripePriceId}`, 103: static async getByStripeIds({ 105: stripePriceIds, 108: stripePriceIds: string[]; 110: if (!stripePriceIds || stripePriceIds.length === 0) 116: ${prices.config} ->> 'stripe_price_id' = ANY(ARRAY[${sql.join( 117: stripePriceIds.map((id) => sql`${id}`), 120: OR ${prices.config} ->> 'stripe_empty_price_id' = ANY(ARRAY[${sql.join( 121: stripePriceIds.map((id) => sql`${id}`), 128: const byStripeId: Record = {}; 131: const ids = [cfg.stripe_price_id, cfg.stripe_empty_price_id].filter( 134: for (const id of ids) byStripeId[id] = row; 136: return byStripeId; server/src/external/stripe/webhookHandlers/handleSubDeleted.ts 1:import type Stripe from "stripe"; 5: getFullStripeSub, 7:} from "../stripeSubUtils.js"; 12: stripeCli, 16: stripeCli: Stripe; 17: data: Stripe.Subscription; 21: const activeCusProducts = await CusProductService.getByStripeSubId({ 23: stripeSubId: data.id, 37: const subscription = await getFullStripeSub({ 38: stripeCli, 39: stripeId: data.id, 68: stripeCli, server/src/external/stripe/webhookHandlers/handleSubCreated.ts 7:import type Stripe from "stripe"; 8:import { createStripeCli } from "@/external/connect/createStripeCli.js"; 15:import { getStripeExpandedInvoice } from "../stripeInvoiceUtils.js"; 19:} from "../stripeSubUtils/convertSubUtils.js"; 20:import { getFullStripeSub } from "../stripeSubUtils.js"; 21:import type { StripeWebhookContext } from "../webhookMiddlewares/stripeWebhookContext.js"; 26: ctx: StripeWebhookContext; 28: const { db, org, env, logger, stripeCli, stripeEvent } = ctx; 29: const stripeObject = stripeEvent.data.object as Stripe.Subscription; 31: const subscription = await getFullStripeSub({ 32: stripeCli, 33: stripeId: stripeObject.id, 38: const cusProds = await CusProductService.getByStripeScheduledId({ 40: stripeScheduledId: subscription.schedule as string, 63: stripe_id: subscription.id, 84: stripe_id: subscription.id, 85: stripe_schedule_id: subscription.schedule as string, 117: const stripeCli = createStripeCli({ org, env }); 118: const invoice = await getStripeExpandedInvoice({ 119: stripeCli, 120: stripeInvoiceId: subscription.latest_invoice as string, 124: stripeInvoice: invoice, 131: await InvoiceService.createInvoiceFromStripe({ 133: stripeInvoice: invoice, 150: const cusProds = await CusProductService.getByStripeSubId({ 152: stripeSubId: subscription.id, 176: (i) => i.price.id === arrearPrice.config?.stripe_price_id, 191: await stripeCli.subscriptions.update(subscription.id, { server/src/external/stripe/webhookHandlers/handleInvoiceUpdated.ts 4: stripeToAtmnAmount, 7:import type Stripe from "stripe"; 13:import { getFullStripeInvoice, invoiceToSubId } from "../stripeInvoiceUtils.js"; 18: stripeCli, 23: stripeCli: Stripe; 24: invoiceObject: Stripe.Invoice; 27: const fullInvoice = await getFullStripeInvoice({ 28: stripeCli, 29: stripeId: invoiceObject.id!, 74: const sub = await stripeCli.subscriptions.retrieve(subId); 78: await stripeCli.subscriptions.cancel(subId); 89: event: Stripe.Event; 92: const invoiceObject = event.data.object as Stripe.Invoice; 93: const currentInvoice = await InvoiceService.getByStripeId({ 95: stripeId: invoiceObject.id!, 109: const newAtmnTotal = stripeToAtmnAmount({ 122: await InvoiceService.updateByStripeId({ 124: stripeId: invoiceObject.id, server/src/external/stripe/webhookHandlers/handleInvoicePaymentAttemptRequired.ts 2:// import type Stripe from "stripe"; 4:// import { createStripeCli } from "@/external/connect/createStripeCli.js"; 27:// invoice: Stripe.Invoice; 32:// const stripeCli = createStripeCli({ org, env }); 52:// const subscription = await stripeCli.subscriptions.retrieve( 84:// const customPaymentMethod = await stripeCli.paymentMethods.retrieve( 169:// stripeInvoiceId: invoice.id, 211:// stripeCli, 230:// // 8. Report payment to Stripe via Payment Records API 231:// logger.info("Reporting payment to Stripe via Payment Records API"); 234:// const paymentRecord = await stripeCli.paymentRecords.reportPayment({ 273:// await stripeCli.invoices.attachPayment(invoice.id, { 288:// logger.error("❌ Failed to report payment to Stripe", { server/src/external/stripe/webhookHandlers/handleInvoicePaidDiscount.ts 11:import type Stripe from "stripe"; 13:import { createStripeCli } from "@/external/connect/createStripeCli.js"; 16:import { getStripeNow } from "@/utils/scriptUtils/testClockUtils.js"; 20:} from "../stripeCouponUtils/deleteCouponFromCus.js"; 21:import { invoiceToSubId } from "../stripeInvoiceUtils.js"; 31: expandedInvoice: Stripe.Invoice; 37: const stripeCli = createStripeCli({ org, env, legacyVersion: true }); 40: const stripeCus = await stripeCli.customers.retrieve( 44: const legacyInvoice = await stripeCli.invoices.retrieve(expandedInvoice.id, { 55: const curCoupon = discount.coupon as Stripe.Coupon; 81: const originalCoupon = await stripeCli.coupons.retrieve(couponId, { 99: const now = await getStripeNow({ 100: stripeCli, 101: stripeCus: stripeCus as Stripe.Customer, 109: `Coupon ${couponId}, stripeCus: ${stripeCus.id}: credits used up or expired. discountFinished: ${discountFinished}, expired: ${expired}`, 114: stripeCli, 115: stripeSubId: subId, 116: stripeCusId: expandedInvoice.customer as string, 126: `Coupon ${couponId}, stripeCus: ${stripeCus.id}, updating amount from ${curAmount} to ${newAmount}`, 138: const newCoupon = await stripeCli.coupons.create({ 150: await stripeCli.rawRequest( 158: await stripeCli.coupons.del(newCoupon.id); 162: stripeCli, 163: stripeSubId: subId, server/src/external/stripe/webhookHandlers/handleInvoicePaid/handleInvoicePaidMetadata.ts 2:import type Stripe from "stripe"; 14: invoice: Stripe.Invoice; server/src/external/stripe/webhookHandlers/handleInvoicePaid/handleInvoiceActionRequiredCompleted.ts 2:import { createStripeCli } from "@server/external/connect/createStripeCli"; 3:import { getCusPaymentMethod } from "@server/external/stripe/stripeCusUtils"; 12:import type Stripe from "stripe"; 20: invoice: Stripe.Invoice; 26: const stripeCli = createStripeCli({ org, env }); 29: stripeCli, 30: stripeId: invoice.customer as string, 35: stripeCli, server/src/internal/products/handlers/productActions/updateProduct.ts 24:import { initProductInStripe } from "../../productUtils.js"; 189: await initProductInStripe({ server/src/external/stripe/webhookHandlers/handleInvoicePaid.ts 8:import type Stripe from "stripe"; 10:import { createStripeCli } from "@/external/connect/createStripeCli.js"; 20: getFullStripeInvoice, 24:} from "../stripeInvoiceUtils.js"; 25:import { lineItemInCusProduct } from "../stripeSubUtils/stripeSubItemUtils.js"; 26:import { getStripeSubs } from "../stripeSubUtils.js"; 32: stripeInvoice, 35: stripeInvoice: Stripe.Invoice; 36: event: Stripe.Event; 39: const invoice = await InvoiceService.getByStripeId({ 41: stripeId: stripeInvoice.id!, 47: await InvoiceService.updateByStripeId({ 49: stripeId: stripeInvoice.id!, 51: status: stripeInvoice.status as InvoiceStatus, 52: hosted_invoice_url: stripeInvoice.hosted_invoice_url, 54: expandedInvoice: stripeInvoice, 59: console.log(`Updated one off invoice status to ${stripeInvoice.status}`); 71: invoice: Stripe.Invoice; 75: const stripeCli = createStripeCli({ org, env }); 77: const subs = await getStripeSubs({ 78: stripeCli, 100: await stripeCli.paymentIntents.retrieve(paymentIntentId); 103: const paymentMethod = await stripeCli.paymentMethods.retrieve( 107: await stripeCli.paymentMethods.attach(paymentMethod.id, { 112: const updateSub = async (sub: Stripe.Subscription) => { 114: await stripeCli.subscriptions.update(sub.id, { 144: invoiceData: Stripe.Invoice; 145: event: Stripe.Event; 148: const stripeCli = createStripeCli({ org, env }); 149: const invoice = await getFullStripeInvoice({ 150: stripeCli, 151: stripeId: invoiceData.id!, 173: const activeCusProducts = await CusProductService.getByStripeSubId({ 175: stripeSubId: subId, 207: stripeInvoice: invoice, 235: await InvoiceService.createInvoiceFromStripe({ 237: stripeInvoice: invoice, 273: stripeInvoice: invoice, server/src/internal/products/handlers/productActions/createProduct.ts 20:import { constructProduct, initProductInStripe } from "../../productUtils.js"; 100: await initProductInStripe({ server/src/external/stripe/webhookHandlers/handleInvoiceFinalized.ts 9:import type Stripe from "stripe"; 11:import { createStripeCli } from "@/external/connect/createStripeCli.js"; 24: getFullStripeInvoice, 25: getStripeExpandedInvoice, 28:} from "../stripeInvoiceUtils.js"; 45: data: Stripe.Invoice; 49: const stripeCli = createStripeCli({ org, env }); 50: const invoice = await getFullStripeInvoice({ 51: stripeCli, 52: stripeId: data.id!, 64: const stripeCli = createStripeCli({ org, env }); 67: const subscription = await stripeCli.subscriptions.retrieve(subId); 78: const paymentMethod = await stripeCli.paymentMethods.retrieve( 95: const customer = await CusService.getByStripeId({ 97: stripeId: invoice.customer as string, 104: stripeCustomerId: invoice.customer, 141: // Do NOT report payment to Stripe here - we've only submitted the invoice to Vercel 145: // 2. Report payment as "guaranteed" to Stripe 158: const expandedInvoice = await getStripeExpandedInvoice({ 159: stripeCli, 160: stripeInvoiceId: invoice.id!, 163: const activeProducts = await CusProductService.getByStripeSubId({ 165: stripeSubId: subId, 187: stripeInvoice: invoice, 192: await InvoiceService.createInvoiceFromStripe({ 194: stripeInvoice: expandedInvoice, server/src/internal/products/handlers/handleVersionProduct.ts 18: initProductInStripe, 29: skipStripeInit = false, 40: skipStripeInit?: boolean; 123: if (skipStripeInit) { 127: await initProductInStripe({ server/src/external/stripe/webhookHandlers/handleInvoiceCreated/handleUsagePrices.ts 12:import type Stripe from "stripe"; 19:import { submitUsageToStripe } from "../../stripeMeterUtils.js"; 20:import { getInvoiceItemForUsage } from "../../stripePriceUtils.js"; 21:import { subToPeriodStartEnd } from "../../stripeSubUtils/convertSubUtils.js"; 29: stripeCli, 39: invoice: Stripe.Invoice; 42: stripeCli: Stripe; 44: usageSub: Stripe.Subscription; 84: // Use new invoice items method (not Stripe Meters) for: 96: stripeInvoiceId: invoice.id!, 107: await stripeCli.invoiceItems.create(invoiceItem); 110: if (!config.stripe_meter_id) { 112: `Price ${price.id} has no stripe meter id, skipping invoice.created for usage in arrear`, 127: await submitUsageToStripe({ 129: stripeCli, server/src/external/stripe/webhookHandlers/handleInvoiceCreated/handlePrepaidPrices.ts 8:import type Stripe from "stripe"; 18:import { subToPeriodStartEnd } from "../../stripeSubUtils/convertSubUtils.js"; 32: usageSub: Stripe.Subscription; 33: invoice: Stripe.Invoice; server/src/internal/products/handlers/handleUpdateProduct/updateProductDetails.ts 15:import { createStripeCli } from "@/external/connect/createStripeCli.js"; 17:import { isStripeConnected } from "@/internal/orgs/orgUtils.js"; 55:const updateStripeProductNames = async ({ 68: if (!isStripeConnected({ org, env: curProduct.env as AppEnv })) return; 70: const stripeCli = createStripeCli({ 74: const stripeProdId = curProduct.processor?.id; 76: if (!stripeProdId || !newName) { 81: await stripeCli.products.update(stripeProdId, { 86: `Error updating product ${curProduct.id} name in Stripe: ${error.message}`, 89: stripeProdId, 96: const stripeProdId = price.config?.stripe_product_id; 98: if (stripeProdId) { 108: await stripeCli.products.update(stripeProdId, { 113: `Error updating price ${price.id} name in Stripe: ${error.message}`, 243: // Update product name in Stripe 246: `Updating product (${curProduct.id}) name in Stripe to ${newProduct.name}`, 248: await updateStripeProductNames({ server/src/external/stripe/webhookHandlers/handleInvoiceCreated/handleInvoiceCreated.ts 8:import type Stripe from "stripe"; 10:import { createStripeCli } from "@/external/connect/createStripeCli.js"; 19: getFullStripeInvoice, 21:} from "../../stripeInvoiceUtils.js"; 22:import { subToPeriodStartEnd } from "../../stripeSubUtils/convertSubUtils.js"; 23:import { getStripeSubs } from "../../stripeSubUtils.js"; 47: invoice: Stripe.Invoice; 52: const stripeCli = createStripeCli({ org, env }); 74: stripeCli, 96: stripeCli, 156: data: Stripe.Invoice; 160: const stripeCli = createStripeCli({ org, env }); 161: const invoice = await getFullStripeInvoice({ 162: stripeCli, 163: stripeId: data.id!, 169: const activeProducts = await CusProductService.getByStripeSubId({ 171: stripeSubId: subId, 183: `Stripe invoice.created -- no active products found (${org.slug})`, 200: // let stripeCli = createStripeCli({ org, env }); 217: // await stripeCli.invoices.update(invoice.id!, { 234: const stripeSubs = await getStripeSubs({ 235: stripeCli: createStripeCli({ org, env }), 241: const subscription = stripeSubs.find((s) => s.id === subId); 264: subscription?: Stripe.Subscription; 265: _invoice: Stripe.Invoice; server/src/internal/products/handlers/handleUpdateProduct/handleUpdatePlan.ts 34:import { initProductInStripe } from "../../productUtils.js"; 214: await initProductInStripe({ server/src/external/stripe/webhookHandlers/handleInvoiceCreated/handleContUsePrices.ts 5:import type Stripe from "stripe"; 12:import { subToPeriodStartEnd } from "../../stripeSubUtils/convertSubUtils.js"; 26: invoice: Stripe.Invoice; 27: usageSub: Stripe.Subscription; server/src/external/stripe/webhookHandlers/handleCusDiscountDeleted.ts 1:import type Stripe from "stripe"; 3:import { createStripeCli } from "@/external/connect/createStripeCli.js"; 22: const customer = await CusService.getByStripeId({ 24: stripeId: discount.customer, 69: const stripeCli = createStripeCli({ 75: const sub = await stripeCli.subscriptions.retrieve(discount.subscription); 79: await stripeCli.subscriptions.update(discount.subscription, { 116: const stripeCli = createStripeCli({ 121: const stripeCus = (await stripeCli.customers.retrieve( 123: )) as Stripe.Customer; 125: if (stripeCus && notNullish(stripeCus.discount)) { 127: `discount.deleted: stripe customer ${discount.customer} already has a discount`, 146: const legacyStripe = createStripeCli({ 152: await legacyStripe.customers.update(discount.customer, { server/src/internal/products/handlers/handleCreatePlan.ts 28:import { constructProduct, initProductInStripe } from "../productUtils.js"; 125: await initProductInStripe({ server/src/external/stripe/webhookHandlers/handleCheckoutCompleted/handleSetupCheckout.ts 2:import { createStripeCli } from "@/external/connect/createStripeCli.js"; 9:import { getCusPaymentMethod } from "../../stripeCusUtils.js"; 23: stripeCli: createStripeCli({ org, env: customer.env }), 24: stripeId: customer.processor?.id, 45: stripeCli: createStripeCli({ org, env: customer.env }), server/src/external/stripe/webhookHandlers/handleCheckoutCompleted/handleRemainingSets.ts 2:import type Stripe from "stripe"; 4:import { getEmptyPriceItem } from "../../priceToStripeItem/priceToStripeItem.js"; 7: stripeCli, 13: stripeCli: Stripe; 15: checkoutSession: Stripe.Checkout.Session; 17: checkoutSub: Stripe.Subscription | null; 32: const emptyPrice = config.stripe_empty_price_id; 39: (item) => item.price === config.stripe_price_id, 45: price: config.stripe_empty_price_id, 54: await stripeCli.subscriptions.update(checkoutSub!.id, { server/src/external/stripe/webhookHandlers/handleCheckoutCompleted/handleCheckoutSub.ts 2:import type Stripe from "stripe"; 7: findPriceFromStripeId, 11:import { getEmptyPriceItem } from "../../priceToStripeItem/priceToStripeItem.js"; 12:import { subToPeriodStartEnd } from "../../stripeSubUtils/convertSubUtils.js"; 15: stripeCli, 20: stripeCli: Stripe; 22: subscription: Stripe.Subscription | null; 34: stripeId: subscription.id, 47: const stripePriceId = item.price.id; 51: placeholderId: stripePriceId, 56: price: arrearProratedPrice.config.stripe_price_id!, 67: const arrearPrice = findPriceFromStripeId({ 69: stripePriceId, 88: .stripe_empty_price_id; 102: await stripeCli.subscriptions.update(subscription.id, { 108: await stripeCli.subscriptions.migrate(subscription.id, { server/src/external/stripe/webhookHandlers/handleCheckoutCompleted/getOptionsFromCheckout.ts 2:import type Stripe from "stripe"; 9:import { findStripeItemForPrice } from "../../stripeSubUtils/stripeSubItemUtils.js"; 15: checkoutSession: Stripe.Checkout.Session; 29: const lineItems: Stripe.LineItem[] = checkoutSession.line_items?.data || []; 37: const lineItem = findStripeItemForPrice({ 39: stripeItems: lineItems, server/src/external/stripe/webhookHandlers/handleCheckoutCompleted.ts 8:import type { Stripe } from "stripe"; 10:import { createStripeCli } from "@/external/connect/createStripeCli.js"; 21:import { getEarliestPeriodEnd } from "../stripeSubUtils/convertSubUtils.js"; 37: data: Stripe.Checkout.Session; 48: const stripeCli = createStripeCli({ org, env }); 50: const checkoutSession = await stripeCli.checkout.sessions.retrieve(data.id, { 55: attachParams.stripeCli = stripeCli; 86: checkoutSession.subscription as Stripe.Subscription | null; 89: const activeCusProducts = await CusProductService.getByStripeSubId({ 91: stripeSubId: checkoutSub.id, 104: stripeCli, 112: stripeCli, 197: // If the customer in Autumn is missing metadata, and Stripe has atleast one of the fields, update the customer in Autumn 198: // with whatever is present in Stripe. 199: // Skip if both are missing in Stripe. server/src/external/stripe/utils.ts 7:import type Stripe from "stripe"; 46:export const subToAutumnInterval = (sub: Stripe.Subscription) => { 68:// export const stripeToAutumnInterval = ({ 94:export const subItemToAutumnInterval = (item: Stripe.SubscriptionItem) => { 99: // return stripeToAutumnInterval({ server/src/external/stripe/stripeWebhookRouter.ts 2:import { handleStripeWebhookEvent } from "./handleStripeWebhookEvent.js"; 3:import { stripeConnectSeederMiddleware } from "./webhookMiddlewares/stripeConnectSeederMiddleware.js"; 4:import { stripeInitLoggerMiddleware } from "./webhookMiddlewares/stripeInitLoggerMiddleware.js"; 5:import { stripeLegacySeederMiddleware } from "./webhookMiddlewares/stripeLegacySeederMiddleware.js"; 6:import { stripeToCustomerIdMiddleware } from "./webhookMiddlewares/stripeToCustomerIdMiddleware.js"; 7:import type { StripeWebhookHonoEnv } from "./webhookMiddlewares/stripeWebhookContext.js"; 8:import { stripeWebhookRefreshMiddleware } from "./webhookMiddlewares/stripeWebhookRefreshMiddleware.js"; 10:export const stripeWebhookRouter = new Hono(); 12:// Legacy webhook - for orgs that pasted their Stripe secret keys 13:stripeWebhookRouter.post( 14: "/webhooks/stripe/:orgId/:env", 15: stripeLegacySeederMiddleware, 16: stripeWebhookRefreshMiddleware, 17: stripeToCustomerIdMiddleware, 18: stripeInitLoggerMiddleware, 19: handleStripeWebhookEvent, 22:// Connect webhook - for orgs using Stripe Connect (our managed account) 23:stripeWebhookRouter.post( 25: stripeConnectSeederMiddleware, 26: stripeWebhookRefreshMiddleware, 27: stripeToCustomerIdMiddleware, 28: stripeInitLoggerMiddleware, 29: handleStripeWebhookEvent, server/src/internal/products/free-trials/freeTrialUtils.ts 73:export const freeTrialToStripeTimestamp = ({ server/src/external/stripe/stripeSubUtils/updateStripeSub/createProrationinvoice.ts 3:import type Stripe from "stripe"; 8:import { payForInvoice } from "../../stripeInvoiceUtils.js"; 11: stripeCli, 15: stripeCli: Stripe; 16: curSub: Stripe.Subscription; 17: updatedSub: Stripe.Subscription; 54: await stripeCli.subscriptions.update(curSub.id, { 72: curSub: Stripe.Subscription; 73: updatedSub: Stripe.Subscription; 77: const { stripeCli, customer, paymentMethod } = attachParams; 80: const items = await stripeCli.invoiceItems.list({ 93: const invoice = await stripeCli.invoices.create({ 105: const finalizedInvoice = await stripeCli.invoices.finalizeInvoice( 128: stripeCli, 137: await undoSubUpdate({ stripeCli, curSub, updatedSub }); 147: stripeInvoiceId: subInvoice.id, 151: await stripeCli.invoices.update(subInvoice.id, { server/src/external/stripe/stripeSubUtils/stripeSubItemUtils.ts 9:import type Stripe from "stripe"; 14:const autumnStripePricesMatch = ({ 15: stripePrice, 17: stripeProdId, 19: stripePrice: Stripe.Price; 21: stripeProdId?: string; 27: config.stripe_price_id === stripePrice.id || 28: (stripeProdId && stripePrice.product === stripeProdId) 32: config.stripe_price_id === stripePrice.id || 33: config.stripe_product_id === stripePrice.product || 34: config.stripe_empty_price_id === stripePrice.id 42: stripeProdId, 45: scheduleItems: Stripe.SubscriptionSchedule.Phase.Item[]; 46: stripeProdId?: string; 50: const schedulePrice = scheduleItem.price as Stripe.Price; 53: autumnStripePricesMatch({ 54: stripePrice: schedulePrice, 56: stripeProdId, 67:export const findStripeItemForPrice = ({ 69: stripeItems, 71: stripeProdId, 74: stripeItems?: Stripe.SubscriptionItem[] | Stripe.LineItem[]; 75: invoiceLineItems?: Stripe.InvoiceLineItem[]; 76: stripeProdId?: string; 80: return li.pricing?.price_details?.price === price.config.stripe_price_id; 84: if (stripeItems) { 85: const stripeItem = stripeItems.find( 86: (si: Stripe.SubscriptionItem | Stripe.LineItem) => { 90: config.stripe_price_id === si.price?.id || 91: config.stripe_product_id === si.price?.product || 92: config.stripe_empty_price_id === si.price?.id 97: if (stripeItem) return stripeItem; 101: return stripeItems.find( 102: (si: Stripe.SubscriptionItem | Stripe.LineItem) => { 106: config.stripe_price_id === si.price?.id || 107: (stripeProdId && si.price?.product === stripeProdId) 117:export const findPriceInStripeItems = ({ 124: subItem?: Stripe.SubscriptionItem; 125: lineItem?: Stripe.InvoiceItem | Stripe.InvoiceLineItem; 134: config.stripe_price_id === subItem.price?.id || 135: config.stripe_product_id === subItem.price?.product; 141: config.stripe_price_id === priceDetails?.price || 142: config.stripe_product_id === priceDetails?.product; 154:export const findStripePriceFromPrices = ({ 155: stripePrices, 158: stripePrices: Stripe.Price[]; 161: return stripePrices.find((p: Stripe.Price) => 162: autumnStripePricesMatch({ 163: stripePrice: p, 174: lineItem: Stripe.InvoiceLineItem; 176: const stripeProdId = cusProduct.product.processor?.id; 179: const price = findPriceInStripeItems({ prices, lineItem }); 183: return stripeProdId === priceDetails?.product || notNullish(price); 191: subItem: Stripe.SubscriptionItem; 193: const stripeProdId = cusProduct.product.processor?.id; 196: const price = findPriceInStripeItems({ prices, subItem }); 198: return stripeProdId === subItem.price.product || notNullish(price); 205: scheduleItem: Stripe.SubscriptionSchedule.Phase.Item; 211: const stripePrice = scheduleItem.price as Stripe.Price; 212: return autumnStripePricesMatch({ 213: stripePrice, 231: scheduleItem: Stripe.SubscriptionSchedule.Phase.Item; 233: const stripeProdId = cusProduct.product.processor?.id; 237: const stripePrice = scheduleItem.price as Stripe.Price; 239: return autumnStripePricesMatch({ 240: stripePrice, 242: stripeProdId, 250: stripeItem, 252: stripeItem: Stripe.SubscriptionItem | Stripe.LineItem; 254: return stripeItem.price?.recurring?.usage_type === "licensed"; 258: stripeItem, 260: stripeItem: Stripe.SubscriptionItem | Stripe.LineItem; 262: return stripeItem.price?.recurring?.usage_type === "metered"; server/src/external/stripe/stripeSubUtils/getSubItemAmount.ts 2:import type Stripe from "stripe"; 9: tiers: Stripe.Price.Tier[]; 40: subItem: Stripe.SubscriptionItem; server/src/internal/platform/platformLegacy/platformRouter.ts 6: type StripeConfig, 15:import { connectStripe } from "@/internal/orgs/handlers/handleConnectStripe_old.js"; 16:import { shouldReconnectStripe } from "@/internal/orgs/orgUtils.js"; 73: stripe_test_key: z.string().nonempty().optional(), 74: stripe_live_key: z.string().nonempty().optional(), 83: const { organization, email, stripe_test_key, stripe_live_key } = 91: stripe_test_key, 92: stripe_live_key, 95: if (!stripe_test_key && !stripe_live_key) { 97: message: "Either stripe_test_key or stripe_live_key is required", 163: logger.info(`Connected to Stripe`); 192: await afterOrgCreated({ org, user, createStripeAccount: false }); 203: let finalStripeConfig: StripeConfig = {}; 206: // Connect stripe if not exists... 207: if (stripe_test_key) { 208: const reconnectStripe = await shouldReconnectStripe({ 211: stripeKey: stripe_test_key, 215: if (reconnectStripe) { 220: } = await connectStripe({ 222: apiKey: stripe_test_key, 226: finalStripeConfig = { 227: ...finalStripeConfig, 247: if (stripe_live_key) { 248: const reconnectStripe = await shouldReconnectStripe({ 251: stripeKey: stripe_live_key, 255: if (reconnectStripe) { 256: console.log("Reconnecting stripe live"); 261: } = await connectStripe({ 263: apiKey: stripe_live_key, 267: finalStripeConfig = { 268: ...finalStripeConfig, 288: // if (!org.stripe_config?.success_url) { 289: // finalStripeConfig.success_url = `https://useautumn.com`; 296: stripe_connected: true, 297: stripe_config: { 298: ...org.stripe_config, 299: ...finalStripeConfig, 300: } as StripeConfig, server/src/external/stripe/stripeSubUtils/getStripeSubItems/getArrearItems.ts 10:import { billingIntervalToStripe } from "../../stripePriceUtils.js"; 42: product: config.stripe_product_id!, 46: ...billingIntervalToStripe({ server/src/external/stripe/stripeSubUtils/getStripeSubItems.ts 36:import { priceToStripeItem } from "../priceToStripeItem/priceToStripeItem.js"; 37:import { getArrearItems } from "./getStripeSubItems/getArrearItems.js"; 67:export const getStripeSubItems = async ({ 159: const stripeItem = priceToStripeItem({ 172: if (!stripeItem) { 176: const { lineItem } = stripeItem; 221:export const getStripeSubItems2 = async ({ 281: const stripeItem = priceToStripeItem({ 299: if (!stripeItem) { 303: const { lineItem } = stripeItem; server/src/external/stripe/stripeSubUtils/convertSubUtils.ts 1:import type Stripe from "stripe"; 7: sub?: Stripe.Subscription; 8: subItems?: Stripe.SubscriptionItem[]; 22:export const getEarliestPeriodEnd = ({ sub }: { sub: Stripe.Subscription }) => { 35: sub: Stripe.Subscription; 45:export const getLatestPeriodStart = ({ sub }: { sub: Stripe.Subscription }) => { 55:export const subToPeriodStartEnd = ({ sub }: { sub?: Stripe.Subscription }) => { server/src/external/stripe/stripeSubUtils.ts 14:import type Stripe from "stripe"; 18:} from "./stripeSubUtils/convertSubUtils.js"; 20:export const getFullStripeSub = async ({ 21: stripeCli, 22: stripeId, 24: stripeCli: Stripe; 25: stripeId: string; 27: return await stripeCli.subscriptions.retrieve(stripeId); 30:export const getStripeSubs = async ({ 31: stripeCli, 35: stripeCli: Stripe; 43: const getStripeSub = async (subId: string) => { 45: return await stripeCli.subscriptions.retrieve(subId, { 50: `(warning) getStripeSubs: Failed to get sub ${subId}`, 59: batchGet.push(getStripeSub(subId)); 76: return subs as Stripe.Subscription[]; 79:export const stripeToAutumnSubStatus = (stripeSubStatus: string) => { 80: switch (stripeSubStatus) { 91: return stripeSubStatus; 96: stripeCli, 99: stripeCli: Stripe; 104: await stripeCli.subscriptionSchedules.cancel(scheduledId); 114: stripeCli, 117: stripeSubs, 120: stripeCli: Stripe; 123: stripeSubs?: Stripe.Subscription[]; 126: if (stripeSubs) { 127: subs = stripeSubs; 129: subs = await getStripeSubs({ 130: stripeCli, 137: const autumnSubs = await SubService.getInStripeIds({ 142: for (const stripeSub of subs) { 146: const autumnSub = autumnSubs?.find((sub) => sub.stripe_id === stripeSub.id); 152: return stripeSub; 157: usageFeatures = JSON.parse(stripeSub.metadata.usage_features); 171: return stripeSub; 178: stripeSub, 181: stripeSub: Stripe.Subscription; 187: const subItems: Stripe.SubscriptionItem[] = []; 188: for (const item of stripeSub.items.data) { 194: p.config.stripe_price_id === item.price.id || 195: p.config.stripe_product_id === item.price.product, 201: const otherSubItems = stripeSub.items.data.filter( 208:export const getStripeSchedules = async ({ 209: stripeCli, 212: stripeCli: Stripe; 216: const getStripeSchedule = async (scheduleId: string) => { 218: const schedule = await stripeCli.subscriptionSchedules.retrieve( 232: stripeCli.prices.retrieve((item.price as Stripe.Price).id as string), 237: // const billingInterval = stripeToAutumnInterval({ 249: console.log("Error getting stripe schedule.", error.message); 255: batchGet.push(getStripeSchedule(scheduleId)); 261: schedule: Stripe.SubscriptionSchedule; 264: prices: Stripe.Price[]; 269:export const subIsPrematurelyCanceled = (sub: Stripe.Subscription) => { 279:export const autumnToStripeProrationBehavior = ({ 294:export const getStripeProrationBehavior = ({ 317: * Checks if a Stripe subscription is canceled. 318: * @param sub - The Stripe subscription to check. 321:export const isStripeSubscriptionCanceled = ({ 324: sub: Stripe.Subscription; server/src/internal/platform/platformBeta/platformBetaRouter.ts 9:import { handleUpdateOrganizationStripe } from "./handlers/handleUpdateOrganizationStripe.js"; 70: * Generates Stripe OAuth URL for platform organizations 75: * POST /organization/stripe 76: * Updates Stripe Connect configuration for platform organization 79: "/organization/stripe", 80: ...handleUpdateOrganizationStripe, 83: "/organizations/stripe", 84: ...handleUpdateOrganizationStripe, server/src/external/stripe/stripeProductUtils.ts 8:import { createStripeCli } from "@/external/connect/createStripeCli.js"; 11:export const createStripeProduct = async ( 17: const stripe = createStripeCli({ org, env }); 19: const stripeProduct = await stripe.products.create({ 27: return stripeProduct; 30: message: `Error creating product in Stripe. ${error.message}`, 31: code: ErrCode.CreateStripeProductFailed, 37:export const deleteStripeProduct = async ( 42: const stripe = createStripeCli({ org, env }); 54: await stripe.products.del(product.processor.id); 57: message: "Failed to delete stripe product", 58: code: ErrCode.DeleteStripeProductFailed, 64:export const deactivateStripeMeters = async ({ 71: const stripeCli = createStripeCli({ org, env }); 73: const allStripeMeters = []; 78: const response: any = await stripeCli.billing.meters.list({ 84: allStripeMeters.push(...response.data); 93: for (let i = 0; i < allStripeMeters.length; i += batchSize) { 94: const batch = allStripeMeters.slice(i, i + batchSize); 96: batch.map((meter) => stripeCli.billing.meters.deactivate(meter.id)), 99: `Deactivated ${i + batch.length}/${allStripeMeters.length} meters`, 105:export const deleteAllStripeProducts = async ({ 112: const stripeCli = createStripeCli({ org, env }); 114: const stripeProducts = await stripeCli.products.list({ 119: if (stripeProducts.data.length === 0) { 123: const firstProduct = stripeProducts.data[0]; 127: code: ErrCode.DeleteStripeProductFailed, 133: for (let i = 0; i < stripeProducts.data.length; i += batchSize) { 134: const batch = stripeProducts.data.slice(i, i + batchSize); 138: await stripeCli.products.del(p.id); 140: await stripeCli.products.update(p.id, { 147: `Deleted ${i + batch.length}/${stripeProducts.data.length} products`, server/src/external/stripe/stripePriceUtils.ts 12:import type Stripe from "stripe"; 22:export const billingIntervalToStripe = ({ 28:}): Stripe.PriceCreateParams.Recurring | Record => { 57: // throw new Error(`billingIntervalToStripe: invalid interval ${interval}`); 63: stripeInvoiceId, 72: stripeInvoiceId: string; 90: const invoiceItem: Stripe.InvoiceItemCreateParams = { 91: invoice: stripeInvoiceId, 97: product: config.stripe_product_id!, 129: ...billingIntervalToStripe({ 141: stripeProductId, 143: recurring: Stripe.PriceCreateParams.Recurring; 144: stripeProductId: string; 148: product: stripeProductId, 154: } satisfies Stripe.SubscriptionCreateParams.Item; server/src/external/stripe/stripeOnboardingUtils.ts 2:import Stripe from "stripe"; 6: const stripe = new Stripe(apiKey); 9: await stripe.customers.list(); 17: const stripe = new Stripe(apiKey); 20: process.env.STRIPE_WEBHOOK_URL || process.env.SERVER_URL; 24: message: "Stripe webhook baseURL not found", 25: code: ErrCode.StripeKeyInvalid, 30: const endpoint = await stripe.webhookEndpoints.create({ 31: url: `${webhookBaseUrl}/webhooks/stripe/${orgId}/${env}`, server/src/internal/platform/platformBeta/handlers/handleUpdateOrganizationStripe.ts 4:import { initPlatformStripe } from "@/external/connect/initStripeCli.js"; 11:const UpdateOrganizationStripeSchema = z 23: * Validates that master org can access the Stripe account and updates the org's Stripe Connect config 25:const validateAndUpdateStripeAccount = async ({ 36: const stripeCli = initPlatformStripe({ 42: const account = await stripeCli.accounts.retrieve(accountId); 43: logger.info(`Stripe account ${account?.id} retrieved successfully`); 45: // Update the organization's Stripe Connect configuration 47: env === AppEnv.Sandbox ? org.test_stripe_connect : org.live_stripe_connect; 57: * POST /organization/stripe 58: * Updates Stripe Connect account for a platform organization 59: * - Requires master org to have Stripe secret key connected 61: * - Stores master_org_id in the tenant org's stripe_connect config 63:export const handleUpdateOrganizationStripe = createRoute({ 64: body: UpdateOrganizationStripeSchema, 79: // Validate and update Stripe accounts 81: test_stripe_connect?: any; 82: live_stripe_connect?: any; 86: updates.test_stripe_connect = await validateAndUpdateStripeAccount({ 95: updates.live_stripe_connect = await validateAndUpdateStripeAccount({ 112: `Updated Stripe Connect for platform org ${org.slug}: test=${test_account_id}, live=${live_account_id}`, 118: message: "Stripe Connect configuration updated successfully", server/src/external/stripe/stripeMeterUtils.ts 8:import type Stripe from "stripe"; 11:export const submitUsageToStripe = async ({ 13: stripeCli, 20: stripeCli: Stripe; 36: const stripeMeter = await stripeCli.billing.meters.retrieve( 37: config.stripe_meter_id!, 40: await stripeCli.billing.meterEvents.create({ 41: event_name: stripeMeter.event_name, 43: stripe_customer_id: customer.processor.id, server/src/internal/platform/platformBeta/handlers/handleGetPlatformOAuth.ts 15: * Generates Stripe OAuth URL for platform organizations 43: // Get appropriate Stripe client ID based on environment 46: ? process.env.STRIPE_LIVE_CLIENT_ID 47: : process.env.STRIPE_SANDBOX_CLIENT_ID; 51: message: `Stripe ${env} client ID not configured`, 58: const oauthUrl = new URL("https://connect.stripe.com/oauth/v2/authorize"); 65: `${process.env.BETTER_AUTH_URL || "https://express.dev.useautumn.com"}/stripe/oauth_callback`, server/src/external/stripe/stripeInvoiceUtils.ts 6: stripeToAtmnAmount, 11:import type Stripe from "stripe"; 14:export const getStripeExpandedInvoice = async ({ 15: stripeCli, 16: stripeInvoiceId, 18: stripeCli: Stripe; 19: stripeInvoiceId: string; 21: const invoice = await stripeCli.invoices.retrieve(stripeInvoiceId, { 28:export const getFullStripeInvoice = async ({ 29: stripeCli, 30: stripeId, 33: stripeCli: Stripe; 34: stripeId: string; 37: const invoice = await stripeCli.invoices.retrieve(stripeId, { 44:export const invoiceToSubId = ({ invoice }: { invoice: Stripe.Invoice }) => { 50: stripeCli, 57: stripeCli: Stripe; 58: paymentMethod?: Stripe.PaymentMethod | null; 84: const invoice = await stripeCli.invoices.retrieve(invoiceId); 95: const invoice = await stripeCli.invoices.pay(invoiceId, { 105: `❌ Stripe error: Failed to pay invoice: ${error?.message || error}`, 110: await stripeCli.invoices.voidInvoice(invoiceId); 140: invoice: Stripe.Invoice; 143: const existingInvoice = await InvoiceService.getByStripeId({ 145: stripeId: invoice.id!, 149: await InvoiceService.updateByStripeId({ 151: stripeId: invoice.id!, 167: expandedInvoice: Stripe.Invoice; 192: const atmnAmountOff = stripeToAtmnAmount({ 197: const atmnAmountUsed = stripeToAtmnAmount({ 202: let stripeCouponId = ""; 205: stripeCouponId = discount.source.coupon; 208: stripeCouponId = discount.source.coupon?.id || ""; 213: stripe_coupon_id: stripeCouponId, server/src/external/stripe/stripeEnsureUtils.ts 3:import { createStripeCli } from "@/external/connect/createStripeCli.js"; 6:import { initProductInStripe } from "@/internal/products/productUtils.js"; 9:export async function ensureStripeProducts({ 22: await ensureStripeProductsWithEnv({ 30:export async function ensureStripeProductsWithEnv({ 43: // let existingStripeProducts = await stripe.products.list(); 50: const stripeCli = createStripeCli({ org, env }); 52: // Fetch updated org data to ensure we have the latest Stripe configuration 53: const products = await stripeCli.products.list({ limit: 100 }); 59: const existsInStripe = products.data.find( 63: if (existsInStripe) { 68: await initProductInStripe({ 77: `initialized product ${fullProduct.id} in Stripe during Stripe connection, env: ${env}`, 80: logger.error(`Failed to init product in stripe: ${error}`); server/src/internal/platform/platformBeta/handlers/handleDeletePlatformOrg.ts 13: deleteStripeAccounts, 14: deleteStripeWebhooks, 63: // Delete stripe webhooks 64: logger.info("2. Deleting stripe webhooks"); 65: await deleteStripeWebhooks({ org, logger }); 67: // Delete stripe accounts 68: logger.info("3. Deleting stripe accounts"); 69: await deleteStripeAccounts({ org, logger }); server/src/internal/platform/platformBeta/handlers/handleCreatePlatformOrg.ts 28: * - Creates test account via Stripe Connect 128: // Initialize org (creates default Stripe test account, svix apps, etc.) server/src/internal/platform/platformBeta/PLATFORM_API.md 3:The Platform API allows you to manage organizations and Stripe Connect accounts on behalf of your tenants. All endpoints require platform feature access. 71:Generates a Stripe Connect OAuth URL for a platform organization. Use this to allow your tenants to connect their Stripe accounts. 85:| `oauth_url` | string | Stripe Connect OAuth URL to redirect the user to. | 96: "redirect_url": "https://yourapp.com/stripe/callback" 103: "oauth_url": "https://connect.stripe.com/oauth/v2/authorize?response_type=code&client_id=ca_xxx&scope=read_write&state=abc123&redirect_uri=https://express.dev.useautumn.com/stripe/oauth_callback" 110:3. User authorizes their Stripe account 111:4. Stripe redirects to Autumn's callback URL 120:- After successful OAuth, the Stripe account is automatically linked to the tenant organization 124:### POST /v1/platform/beta/organization/stripe 126:Updates a platform organization's Stripe Connect configuration. Associates a Stripe account ID with the organization using your master Stripe credentials. 133:| `test_account_id` | string | No* | Stripe account ID for test environment (e.g., `acct_xxx`). | 134:| `live_account_id` | string | No* | Stripe account ID for live environment (e.g., `acct_xxx`). | 149:curl -X POST https://api.useautumn.com/v1/platform/beta/organization/stripe \ 162: "message": "Stripe Connect configuration updated successfully", 171:- Your organization must have the corresponding Stripe secret key connected (test/live) 172:- The endpoint validates that your master Stripe account can access the provided account ID 176:- Use this endpoint when you want to manage Stripe accounts on behalf of your tenants using your own Stripe Connect credentials 178:- All Stripe operations for the tenant will use your master Stripe credentials with the tenant's account ID 179:- This is an alternative to the OAuth flow for cases where you have direct access to the tenant's Stripe account ID server/src/external/stripe/stripeCusUtils.ts 10:import { Stripe } from "stripe"; 12:import { createStripeCli } from "@/external/connect/createStripeCli.js"; 18:export const getStripeCus = async ({ 19: stripeCli, 20: stripeId, 22: stripeCli: Stripe; 23: stripeId: string; 26: const stripeCus = await stripeCli.customers.retrieve(stripeId); 27: return stripeCus as Stripe.Customer; 33:export const createStripeCusIfNotExists = async ({ 46: const stripeCli = createStripeCli({ org, env }); 48: const getCurrentStripeCus = async () => { 53: const stripeCus = await stripeCli.customers.retrieve( 61: if (stripeCus.deleted) return null; 64: return stripeCus as Stripe.Customer; 68: _error instanceof Stripe.errors.StripeError && 77: // 1. Get current stripe customer 78: const stripeCus = await getCurrentStripeCus(); 80: if (stripeCus) return stripeCus; 82: // 2. If no current stripe customer, create new customer 83: logger.info(`Creating new stripe customer for ${customer.id}`); 85: `stripe-create-cus:${customer.id || customer.internal_id}:${org.id}:${env}:${Math.floor(Date.now() / 5000)}`, 88: const stripeCustomer = await createStripeCustomer({ 102: id: stripeCustomer.id, 103: type: ProcessorType.Stripe, 109: id: stripeCustomer.id, 110: type: ProcessorType.Stripe, 113: return stripeCustomer; 116: // const stripeCli = createStripeCli({ org, env }); 121: // const stripeCus = await stripeCli.customers.retrieve( 127: // if (!stripeCus.deleted) { 128: // return stripeCus as Stripe.Customer; 138: // logger.info(`Creating new stripe customer for ${customer.id}`); 139: // const stripeCustomer = await createStripeCustomer({ 152: // id: stripeCustomer.id, 153: // type: ProcessorType.Stripe, 159: // id: stripeCustomer.id, 160: // type: ProcessorType.Stripe, 163: // return stripeCustomer; 167:export const createStripeCustomer = async ({ 182: const stripeCli = createStripeCli({ org, env }); 185: const stripeCustomer = await stripeCli.customers.create( 203: return stripeCustomer; 206: message: `Error creating customer in Stripe. ${error.message}`, 207: code: ErrCode.StripeCreateCustomerFailed, 213:export const deleteStripeCustomer = async ({ 216: stripeId, 220: stripeId: string; 222: const stripeCli = createStripeCli({ org, env }); 224: const stripeCustomer = await stripeCli.customers.del(stripeId); 226: return stripeCustomer; 230: stripeCli, 231: stripeId, 233: stripeCli: Stripe; 234: stripeId: string; 236: const res = await stripeCli.paymentMethods.list({ 237: customer: stripeId, 247: stripeCli, 248: stripeId, 252: stripeCli: Stripe; 253: stripeId?: string; 257: if (!stripeId) { 261: const stripeCustomer = (await stripeCli.customers.retrieve( 262: stripeId, 263: )) as Stripe.Customer; 266: stripeCustomer.invoice_settings?.default_payment_method; 269: const res = await stripeCli.paymentMethods.list({ 270: customer: stripeId, 282: code: ErrCode.StripeGetPaymentMethodFailed, 283: message: `No payment method found for customer ${stripeId}`, 292: const paymentMethod = await stripeCli.paymentMethods.retrieve( 315: // 1. Create stripe customer if not exists 317: let stripeCusId = customer.processor?.id; 318: if (!stripeCusId) { 319: const stripeCustomer = await createStripeCustomer({ 333: id: stripeCustomer.id, 334: type: ProcessorType.Stripe, 339: stripeCusId = stripeCustomer.id; 341: id: stripeCustomer.id, 342: type: "stripe", 346: const stripeCli = createStripeCli({ org, env }); 350: const pm = await stripeCli.paymentMethods.create({ 356: await stripeCli.paymentMethods.attach(pm.id, { 357: customer: stripeCusId, 360: await stripeCli.customers.update(stripeCusId, { 372: stripeCli, 375: stripeCli: Stripe; 379: const paymentMethods = await stripeCli.paymentMethods.list({ 383: await stripeCli.paymentMethods.detach(pm.id); 386: const pm = await stripeCli.paymentMethods.create({ 392: await stripeCli.paymentMethods.attach(pm.id, { 405: const stripeCli = createStripeCli({ org, env }); 413: const stripeCustomer = await stripeCli.customers.retrieve( 417: const paymentMethods = await stripeCli.paymentMethods.list({ 418: customer: stripeCustomer.id, 421: await stripeCli.paymentMethods.detach(pm.id); 424: await stripeCli.paymentMethods.attach("pm_card_authenticationRequired", { 425: customer: stripeCustomer.id, 429:export const deleteAllStripeCustomers = async ({ 436: const stripeCli = createStripeCli({ org, env }); 438: const stripeCustomers = await stripeCli.customers.list({ 442: if (stripeCustomers.data.length === 0) { 446: const firstCustomer = stripeCustomers.data[0]; 450: code: ErrCode.StripeDeleteCustomerFailed, 456: for (let i = 0; i < stripeCustomers.data.length; i += batchSize) { 457: const batch = stripeCustomers.data.slice(i, i + batchSize); 458: await Promise.all(batch.map((c) => stripeCli.customers.del(c.id))); 460: `Deleted ${i + batch.length}/${stripeCustomers.data.length} customers`, server/src/external/stripe/stripeCouponUtils/stripeCouponUtils.ts 3: atmnToStripeAmount, 15:import { createStripeCli } from "@/external/connect/createStripeCli.js"; 19:const couponToStripeDuration = ({ 78:const couponToStripeValue = ({ 95: console.log("amountOff in couponToStripeValue", amountOff); 98: amount_off: atmnToStripeAmount({ amount: amountOff, currency }), 114: amount_off: atmnToStripeAmount({ 123:export const createStripeCoupon = async ({ 140: const stripeCli = createStripeCli({ 147: await stripeCli.coupons.del(reward.id); 150: const stripeProdIds = prices.map((price) => { 155: if (!config.stripe_product_id) { 156: logger.warn("No stripe product id for price", { price }); 159: message: `No stripe product id for price ${price.id}`, 164: return config.stripe_product_id; 170: const stripePromoCode = await stripeCli.promotionCodes.retrieve( 174: message: `Promo code ${promoCode.code} (${stripePromoCode.id}) already exists in Stripe`, 175: code: ErrCode.PromoCodeAlreadyExistsInStripe, 180: const stripeCoupon = await stripeCli.coupons.create({ 183: ...(couponToStripeDuration({ 187: ...(couponToStripeValue({ reward, org, prices }) as any), 197: products: stripeProdIds, 204: await stripeCli.promotionCodes.create({ 207: coupon: stripeCoupon.id, server/src/internal/orgs/orgUtils/handleStripeSecretKey.ts 2:import Stripe from "stripe"; 6:} from "@/external/stripe/stripeOnboardingUtils.js"; 9:export const handleStripeSecretKey = async ({ 20: const stripe = new Stripe(secretKey); 21: const account = await stripe.accounts.retrieve(); 24: const curWebhooks = await stripe.webhookEndpoints.list(); 27: await stripe.webhookEndpoints.del(webhook.id); server/src/external/stripe/stripeCouponUtils/extendCouponDuration.ts 1:// import Stripe from "stripe"; 8:// stripeCli, 14:// stripeCli: Stripe; 15:// sub: Stripe.Subscription; 30:// const existingCoupon = await stripeCli.coupons.retrieve(existingCouponId); 31:// const currentDiscounts = (sub.discounts as Stripe.Discount[]) || []; 78:// const couponCreateParams: Stripe.CouponCreateParams = { 108:// const extendedCoupon = await stripeCli.coupons.create(couponCreateParams); 113:// .map((d: Stripe.Discount) => ({ discount: d.id })); 115:// await stripeCli.subscriptions.update(sub.id, { 123:// await stripeCli.coupons.del(existingCouponId); server/src/internal/orgs/orgUtils/deleteOrgUtils.ts 8:import { deleteStripeWebhook } from "../orgUtils.js"; 41:export const deleteStripeWebhooks = async ({ 49: await deleteStripeWebhook({ 54: await deleteStripeWebhook({ 60: `Failed to delete stripe webhooks for ${org.id}, ${org.slug}. ${error.message})`, 65:export const deleteStripeAccounts = async ({ 72: if (org.test_stripe_connect?.account_id) { 74: accountId: org.test_stripe_connect.account_id, 80: if (org.live_stripe_connect?.account_id) { 82: accountId: org.live_stripe_connect.account_id, 88: if (org.test_stripe_connect?.default_account_id) { 90: accountId: org.test_stripe_connect.default_account_id, server/src/external/stripe/stripeCouponUtils/deleteCouponFromCus.ts 1:import type { Stripe } from "stripe"; 4: stripeCli, 5: stripeSubId, 9: stripeCli: Stripe; 10: stripeSubId: string; 15: const stripeSub = await stripeCli.subscriptions.retrieve(stripeSubId); 17: if (stripeSub.discounts.some((d: any) => d === discountId)) { 18: await stripeCli.subscriptions.deleteDiscount(stripeSubId); 21: logger.error(`Failed to delete discount from subscription ${stripeSubId}`); 27: stripeCli, 28: stripeSubId, 29: stripeCusId, 33: stripeCli: Stripe; 34: stripeSubId: string; 35: stripeCusId: string; 40: const stripeSub = await stripeCli.subscriptions.retrieve(stripeSubId); 41: if (stripeSub.discounts.some((d: any) => d === discountId)) { 42: await stripeCli.subscriptions.deleteDiscount(stripeSubId); 45: logger.error(`Failed to delete discount from subscription ${stripeSubId}`); 50: const stripeCus = (await stripeCli.customers.retrieve( 51: stripeCusId, 52: )) as Stripe.Customer; 53: if (stripeCus.discount?.id === discountId) { 54: await stripeCli.customers.deleteDiscount(stripeCusId, discountId); 57: logger.error(`Failed to delete discount from customer ${stripeCusId}`); server/src/internal/orgs/orgUtils/createConnectAccount.ts 5:import { initMasterStripe } from "@/external/connect/initStripeCli.js"; 15: const stripe = initMasterStripe({ 22: // Stripe v2 API for connected accounts 23: const account = await stripe.v2.core.accounts.create({ 35: losses_collector: "stripe", 36: fees_collector: "stripe", server/src/external/stripe/stripeCardUtils.ts 8:import { createStripeCli } from "../connect/createStripeCli.js"; 10:export const isStripeCardDeclined = (error: any) => { 18: error.code === "payment_intent_payment_attempt_failed" // Stripe link 22:export const createCustomStripeCard = async ({ 40: const stripeCli = createStripeCli({ org, env }); 46: const pm = await stripeCli.paymentMethods.create({ 56: await stripeCli.paymentMethods.attach(pm.id, { 60: await stripeCli.customers.update(customer.processor.id, { server/src/internal/orgs/orgUtils/convertOrgUtils.ts 11: return org.stripe_config?.sandbox_success_url || "https://useautumn.com"; 13: return org.stripe_config?.success_url || "https://useautumn.com"; server/src/internal/orgs/orgUtils.ts 14:import { createStripeCli } from "@server/external/connect/createStripeCli.js"; 23:import Stripe from "stripe"; 31:export const shouldReconnectStripe = async ({ 35: stripeKey, 40: stripeKey: string; 42: if (!isStripeConnected({ org, env })) return true; 45: const stripeCli = createStripeCli({ org, env }); 46: const newKey = new Stripe(stripeKey); 48: const oldAccount = await stripeCli.accounts.retrieve(); 53: logger.error("Error checking if stripe should be reconnected", { error }); 58:export const isStripeConnected = ({ 89: return notNullish(org.stripe_config?.test_api_key); 93: notNullish(org.stripe_config?.test_api_key) || notNullish(testAccountId) 101: return notNullish(org.stripe_config?.live_api_key); 105: notNullish(org.stripe_config?.live_api_key) || notNullish(liveAccountId) 109: notNullish(org.stripe_config?.test_api_key) && 110: notNullish(org.stripe_config?.live_api_key) 121: stripe_connected: false, 122: stripe_config: null, 133:export const deleteStripeWebhook = async ({ 140: if (!isStripeConnected({ org, env, throughSecretKey: true })) return; 142: const stripeCli = createStripeCli({ org, env, throughSecretKey: true }); 143: const webhookEndpoints = await stripeCli.webhookEndpoints.list({ 150: await stripeCli.webhookEndpoints.del(webhook.id); 151: console.log(`Deleted stripe webhook (${env}) ${webhook.url}`); 153: console.log(`Failed to delete stripe webhook (${env}) ${webhook.url}`); 160:export const getStripeWebhookSecret = (org: Organization, env: AppEnv) => { 163: ? org.stripe_config?.test_webhook_secret 164: : org.stripe_config?.live_webhook_secret; 168: code: ErrCode.StripeConfigNotFound, 169: message: `Stripe webhook secret not found for org ${org.id}`, 197: const secretKeyConnected = isStripeConnected({ 206: const stripeConnection = secretKeyConnected 226: // stripe_connected: isStripeConnected({ org, env: AppEnv.Sandbox }), 231: // stripe_connected: isStripeConnected({ org, env: AppEnv.Live }), 238: stripe_connection: stripeConnection, 308:export const unsetOrgStripeKeys = async ({ 317: const newStripeConfig: any = structuredClone(org.stripe_config) || {}; 319: newStripeConfig.test_api_key = null; 320: newStripeConfig.test_webhook_secret = null; 322: newStripeConfig.live_api_key = null; 323: newStripeConfig.live_webhook_secret = null; 330: stripe_config: newStripeConfig, server/src/internal/orgs/orgRouter.ts 22:import { handleConnectStripe } from "./handlers/stripeHandlers/handleConnectStripe.js"; 23:import { handleDeleteStripe } from "./handlers/stripeHandlers/handleDeleteStripe.js"; 24:import { handleGetOAuthUrl } from "./handlers/stripeHandlers/handleGetOAuthUrl.js"; 25:import { handleGetStripeAccount } from "./handlers/stripeHandlers/handleGetStripeAccount.js"; 39:honoOrgRouter.get("/stripe", ...handleGetStripeAccount); 40:honoOrgRouter.delete("/stripe", ...handleDeleteStripe); 41:honoOrgRouter.post("/stripe", ...handleConnectStripe); 42:honoOrgRouter.get("/stripe/oauth_url", ...handleGetOAuthUrl); server/src/external/stripe/priceToStripeItem/priceToUsageInAdvance.ts 17: stripeProductId, 24: stripeProductId: string; 31: if (!config.stripe_product_id) { 33: `WARNING: One off & tiered in advance price has no stripe product id: ${price.id}, ${relatedEnt.feature.name}`, 38: product: config.stripe_product_id 39: ? config.stripe_product_id 40: : stripeProductId, 84: price: config.stripe_price_id, server/src/external/stripe/priceToStripeItem/priceToStripeItem.ts 21:import { billingIntervalToStripe } from "../stripePriceUtils"; 37: product: price.config!.stripe_product_id!, 41: ...billingIntervalToStripe({ 51:// GET STRIPE LINE / SUB ITEM 52:export const priceToStripeItem = ({ 79: const stripeProductId = product.processor?.id; 85: if (!stripeProductId) { 87: message: `product ${product.id} has no stripe product id`, 102: price: config.stripe_price_id, 117: stripeProductId, 133: const priceId = config.stripe_price_id; 141: price: config.stripe_empty_price_id, 150: message: `Couldn't find Autumn price: ${price.id} in Stripe`, server/src/external/stripe/priceToStripeItem/priceToArrearProrated.ts 17: price: config.stripe_placeholder_price_id, 21: price: config.stripe_price_id, server/src/external/stripe/handleStripeWebhookEvent.ts 4:import { Stripe } from "stripe"; 5:import { createStripeCli } from "@/external/connect/createStripeCli.js"; 6:import { unsetOrgStripeKeys } from "@/internal/orgs/orgUtils.js"; 21: StripeWebhookContext, 22: StripeWebhookHonoEnv, 23:} from "./webhookMiddlewares/stripeWebhookContext.js"; 25:const logStripeWebhook = ({ ctx }: { ctx: StripeWebhookContext }) => { 26: const { logger, org, stripeEvent } = ctx; 28: `${chalk.yellow("STRIPE").padEnd(18)} ${stripeEvent.type.padEnd(30)} ${org.slug} | ${stripeEvent.id}`, 33: * Hono handler for Stripe webhook events 36:export const handleStripeWebhookEvent = async ( 37: c: Context, 39: const ctx = c.get("ctx") as StripeWebhookContext; 40: const { db, logger, org, env, stripeEvent } = ctx; 41: const event = stripeEvent; 42: logStripeWebhook({ ctx }); 45: const stripeCli = createStripeCli({ org, env }); 64: stripeCli, 151: if (error instanceof Stripe.errors.StripeError) { 153: logger.warn(`stripe customer missing: ${error.message}`); 158: await unsetOrgStripeKeys({ 171: error.message.includes("No stripe account linked to organization") 178: logger.error(`Stripe webhook error: ${error}`, { error }); 183: // Note: Cache refresh is now handled by stripeWebhookRefreshMiddleware server/src/internal/orgs/handlers/stripeHandlers/handleOAuthCallback.ts 4:import { createStripeCli } from "@/external/connect/createStripeCli.js"; 5:import { initMasterStripe } from "@/external/connect/initStripeCli.js"; 11: * Handles Stripe OAuth callback 24: redirectUrl.searchParams.set("tab", "stripe"); 26: // Handle OAuth error from Stripe 64: `${frontendUrl}${env === AppEnv.Sandbox ? "/sandbox" : ""}/dev?tab=stripe`, 77: const stripe = initMasterStripe({ env }); 78: const response = await stripe.oauth.token({ 83: const accountId = response.stripe_user_id; 92: const existingOrg = await OrgService.findByStripeAccountId({ 110: const master = createStripeCli({ org: existingOrg, env }); 126: // Update organization with Stripe Connect account 127: await OrgService.updateStripeConnect({ 134: console.log(`Successfully connected Stripe account for org ${org.id}`); server/src/internal/orgs/handlers/stripeHandlers/handleGetStripeAccount.ts 1:import { createStripeCli } from "@/external/connect/createStripeCli.js"; 3:import { isStripeConnected } from "../../orgUtils.js"; 5:export const handleGetStripeAccount = createRoute({ 10: if (!isStripeConnected({ org, env })) { 15: const stripeCli = createStripeCli({ org, env }); 16: const accountDetails = await stripeCli.accounts.retrieve(); 20: `Failed to retrieve Stripe account for org ${org.slug}, ${error}`, server/src/external/stripe/createStripePrice/createStripePrice.ts 16:import Stripe from "stripe"; 17:import { billingIntervalToStripe } from "../stripePriceUtils.js"; 19: createStripeArrearProrated, 20: createStripeMeteredPrice, 21:} from "./createStripeArrearProrated"; 22:import { createStripeFixedPrice } from "./createStripeFixedPrice"; 23:import { createStripeInArrearPrice } from "./createStripeInArrear"; 24:import { createStripeOneOffTieredProduct } from "./createStripeOneOffTiered"; 25:import { createStripePrepaid } from "./createStripePrepaid"; 27:export const checkCurStripePrice = async ({ 29: stripeCli, 33: stripeCli: Stripe; 38: let stripePrice: Stripe.Price | null = null; 39: if (!config.stripe_price_id) { 40: stripePrice = null; 43: stripePrice = await stripeCli.prices.retrieve(config.stripe_price_id!, { 47: if (!stripePrice.active) { 48: stripePrice = await stripeCli.prices.update(config.stripe_price_id!, { 54: stripePrice && 55: stripePrice.currency.toLowerCase() !== currency.toLowerCase() 57: stripePrice = null; 61: _error instanceof Stripe.errors.StripeError && 64: stripePrice = null; 71: // Get stripe product 72: let stripeProd: Stripe.Product | null = null; 73: if (!config.stripe_product_id) { 74: stripeProd = null; 77: stripeProd = await stripeCli.products.retrieve(config.stripe_product_id!); 78: if (!stripeProd.active) { 79: stripeProd = null; 82: stripeProd = null; 87: stripePrice, 88: stripeProd, 92:export const createStripePriceIFNotExist = async ({ 94: stripeCli, 104: stripeCli: Stripe; 117: const { stripePrice, stripeProd } = await checkCurStripePrice({ 119: stripeCli, 124: config.stripe_price_id = stripePrice?.id; 125: config.stripe_product_id = stripeProd?.id; 135: if (!stripePrice) { 136: await createStripeFixedPrice({ 138: stripeCli, 148: if (isOneOffAndTiered && !stripeProd) { 149: logger.info(`Creating stripe one off tiered product`); 150: await createStripeOneOffTieredProduct({ 152: stripeCli, 159: if (!isOneOffAndTiered && !stripePrice) { 160: logger.info(`Creating stripe prepaid price`); 161: await createStripePrepaid({ 163: stripeCli, 168: curStripeProd: stripeProd, 174: if (!stripePrice) { 175: logger.info(`Creating stripe in arrear prorated product`); 176: await createStripeArrearProrated({ 178: stripeCli, 183: curStripeProd: stripeProd, 185: } else if (!config.stripe_placeholder_price_id) { 186: logger.info(`Creating stripe placeholder price`); 187: const placeholderPrice = await createStripeMeteredPrice({ 188: stripeCli, 194: config.stripe_placeholder_price_id = placeholderPrice.id; 204: await createStripeInArrearPrice({ 206: stripeCli, 212: curStripePrice: stripePrice, 213: curStripeProduct: stripeProd, 218: if (!config.stripe_empty_price_id) { 220: logger.info(`Creating stripe empty price`); 221: // console.log(`Product: ${config.stripe_product_id || stripeProd?.id}`); 222: const emptyPrice = await stripeCli.prices.create({ 223: // product: stripeProd!.id, 224: product: config.stripe_product_id || product.processor?.id, 228: ...(billingIntervalToStripe({ 235: config.stripe_empty_price_id = emptyPrice.id; 242: logger.error(`Error creating stripe empty price!`, { server/src/internal/orgs/handlers/stripeHandlers/handleGetOAuthUrl.ts 17: ? process.env.STRIPE_LIVE_CLIENT_ID 18: : process.env.STRIPE_SANDBOX_CLIENT_ID; 22: message: `Stripe ${env === AppEnv.Live ? "live" : "test"} client ID not configured`, 31: const redirectUri = redirect_url || `${frontendUrl}/dev?tab=stripe`; 41: `https://connect.stripe.com/oauth/v2/authorize?response_type=code&client_id=${clientId}&scope=read_write`, 57: `${serverUrl}/stripe/oauth_callback`, server/src/external/stripe/createStripePrice/createStripePrepaidPriceV2.ts 2: atmnToStripeAmountDecimal, 12:import type Stripe from "stripe"; 16:import { billingIntervalToStripe } from "../stripePriceUtils.js"; 19:const prepaidToStripeTiers = ({ 36: const paidTiers: Stripe.PriceCreateParams.Tier[] = usageTiers.map( 42: const stripeUnitAmountDecimal = atmnToStripeAmountDecimal({ 48: unit_amount_decimal: stripeUnitAmountDecimal, 76:export const createStripePrepaidPriceV2 = async ({ 78: stripeCli, 83: curStripeProd, 86: stripeCli: Stripe; 91: curStripeProd: Stripe.Product | null; 95: recurringData = billingIntervalToStripe({ 104: const productData = curStripeProd 105: ? { product: curStripeProd.id } 113: let stripePrice = null; 117: const unitAmountDecimalStr = atmnToStripeAmountDecimal({ 122: stripePrice = await stripeCli.prices.create({ 128: config.stripe_product_id = stripePrice.product as string; 129: config.stripe_price_id = stripePrice.id; 132: let priceAmountData: Partial; 135: unit_amount_decimal: atmnToStripeAmountDecimal({ 144: tiers: prepaidToStripeTiers({ ent, price, org }), 147: stripePrice = await stripeCli.prices.create({ 156: config.stripe_price_id = stripePrice.id; 157: config.stripe_product_id = stripePrice.product as string; server/src/internal/orgs/handlers/stripeHandlers/handleDeleteStripe.ts 4: type StripeConnectConfig, 8:import { createStripeCli } from "@/external/connect/createStripeCli.js"; 9:import { initMasterStripe } from "@/external/connect/initStripeCli.js"; 14:import { isStripeConnected } from "../../orgUtils.js"; 16:export const disconnectStripe = async ({ 25: if (isStripeConnected({ org, env, throughSecretKey: true })) { 26: const stripeCli = createStripeCli({ org, env, throughSecretKey: true }); 27: const webhooks = await stripeCli.webhookEndpoints.list(); 30: await stripeCli.webhookEndpoints.del(webhook.id); 38: const masterStripe = initMasterStripe({ env }); 43: await masterStripe.oauth.deauthorize({ 46: ? process.env.STRIPE_LIVE_CLIENT_ID || "" 47: : process.env.STRIPE_SANDBOX_CLIENT_ID || "", 48: stripe_user_id: accountId, 61:export const clearStripeConfig = async ({ 70: const newStripeConfig: any = structuredClone(org.stripe_config) || {}; 73: newStripeConfig.test_api_key = null; 75: newStripeConfig.live_api_key = null; 82: stripe_config: newStripeConfig, 87:export const handleDeleteStripe = createRoute({ 99: await disconnectStripe({ org, env, logger }); 101: logger.error(`Failed to disconnect stripe for ${org.id}, ${org.slug}`, { 106: // Update stripe config: 108: if (isStripeConnected({ org, env, throughSecretKey: true })) { 109: await clearStripeConfig({ db, org, env }); 112: const newStripeConnect: StripeConnectConfig = 113: structuredClone(org.test_stripe_connect) || {}; 114: delete newStripeConnect.account_id; 120: test_stripe_connect: newStripeConnect, 124: const newStripeConnect: StripeConnectConfig = 125: structuredClone(org.live_stripe_connect) || {}; 126: delete newStripeConnect.account_id; 132: live_stripe_connect: newStripeConnect, server/src/external/stripe/createStripePrice/createStripePrepaid.ts 2: atmnToStripeAmountDecimal, 15:import type Stripe from "stripe"; 16:import { billingIntervalToStripe } from "../stripePriceUtils"; 18:export const prepaidToStripeTiers = ({ 36: const amount = atmnToStripeAmountDecimal({ 54:export const createStripePrepaid = async ({ 60: curStripeProd, 61: stripeCli, 68: curStripeProd: Stripe.Product | null; 69: stripeCli: Stripe; 75: recurringData = billingIntervalToStripe({ 88: const productData = curStripeProd 89: ? { product: curStripeProd.id } 97: let stripePrice = null; 101: const unitAmountDecimalStr = atmnToStripeAmountDecimal({ 106: stripePrice = await stripeCli.prices.create({ 112: config.stripe_product_id = stripePrice.product as string; 113: config.stripe_price_id = stripePrice.id; 115: const tiers = prepaidToStripeTiers({ price, org }); 130: stripePrice = await stripeCli.prices.create({ 140: config.stripe_price_id = stripePrice.id; 141: config.stripe_product_id = stripePrice.product as string; server/src/internal/orgs/handlers/stripeHandlers/handleConnectStripe.ts 1:import { AppEnv, type StripeConfig } from "@autumn/shared"; 3:import { ensureStripeProductsWithEnv } from "@/external/stripe/stripeEnsureUtils.js"; 7:import { handleStripeSecretKey } from "../../orgUtils/handleStripeSecretKey.js"; 9:// Connecting stripe 10:const validateConnectStripeRequest = () => {}; 19: configUpdates: StripeConfig; 30:export const handleConnectStripe = createRoute({ 41: const configUpdates: StripeConfig = org.stripe_config || {}; 44: const result = await handleStripeSecretKey({ 70: stripe_config: configUpdates, 75: await ensureStripeProductsWithEnv({ 85: message: "Connect Stripe", server/src/external/stripe/createStripePrice/createStripeOneOffTiered.ts 10:import type Stripe from "stripe"; 12:export const createStripeOneOffTieredProduct = async ({ 14: stripeCli, 20: stripeCli: Stripe; 31: const stripeProduct = await stripeCli.products.create({ 35: config.stripe_product_id = stripeProduct.id; server/src/external/stripe/createStripePrice/createStripeInArrear.ts 2: atmnToStripeAmountDecimal, 19:import type Stripe from "stripe"; 20:import { billingIntervalToStripe } from "../stripePriceUtils"; 22:export const searchStripeMeter = async ({ 23: stripeCli, 28: stripeCli: Stripe; 33: const allStripeMeters = []; 39: const response: any = await stripeCli.billing.meters.list({ 45: allStripeMeters.push(...response.data); 53: logger.info(`Stripe meter list took ${end - start}ms`); 55: const stripeMeter = allStripeMeters.find( 59: return stripeMeter; 62:export const getStripeMeter = async ({ 65: stripeCli, 71: stripeCli: Stripe; 78: const stripeMeter = await searchStripeMeter({ 79: stripeCli, 81: meterId: config.stripe_meter_id!, 85: if (stripeMeter) { 89: return stripeMeter; 93: const meter = await stripeCli.billing.meters.create({ 135: const stripeUnitAmountDecimal = atmnToStripeAmountDecimal({ 141: unit_amount_decimal: stripeUnitAmountDecimal, 149:export const createStripeInArrearPrice = async ({ 151: stripeCli, 157: curStripePrice, 158: curStripeProduct, 163: stripeCli: Stripe; 169: curStripePrice?: Stripe.Price | null; 170: curStripeProduct?: Stripe.Product | null; 183: // 1. If internal entity ID and not curStripe product, create product 185: if (!curStripeProduct) { 187: `Creating stripe in arrear product for ${relatedEnt?.feature.name} (internal entity ID exists!)`, 189: const stripeProduct = await stripeCli.products.create({ 192: config.stripe_product_id = stripeProduct.id; 203: // 2. If no internal entity ID, create Stripe price if not exists... 204: if (curStripePrice) { 209: `Creating stripe in arrear price for ${relatedEnt?.feature.name} (no internal entity ID)`, 214: message: `createStripeInArrearPrice: feature not found for price ${price.id}`, 221: const meter = await getStripeMeter({ 224: stripeCli, 229: config.stripe_meter_id = meter.id; 251: if (config.stripe_product_id) { 253: product: config.stripe_product_id, 263: const recurringData = billingIntervalToStripe({ 268: const stripePrice = await stripeCli.prices.create({ 281: config.stripe_price_id = stripePrice.id; 282: config.stripe_product_id = stripePrice.product as string; 283: config.stripe_meter_id = meter.id; server/src/external/stripe/createStripePrice/createStripeFixedPrice.ts 7:import { atmnToStripeAmount } from "@autumn/shared"; 10:import type Stripe from "stripe"; 11:import { billingIntervalToStripe } from "../stripePriceUtils"; 13:export const createStripeFixedPrice = async ({ 15: stripeCli, 21: stripeCli: Stripe; 29: const amount = atmnToStripeAmount({ 34: const stripePrice = await stripeCli.prices.create({ 39: ...(billingIntervalToStripe({ 48: config.stripe_price_id = stripePrice.id; server/src/internal/orgs/handlers/handleResetDefaultAccount.ts 2:import { initMasterStripe } from "@/external/connect/initStripeCli.js"; 31: const currentDefaultAccountId = org.test_stripe_connect?.default_account_id; 36: const masterStripe = initMasterStripe({ env: AppEnv.Sandbox }); 40: await masterStripe.accounts.del(currentDefaultAccountId); 72: test_stripe_connect: { 73: ...org.test_stripe_connect, server/src/external/stripe/createStripePrice/createStripeArrearProrated.ts 18:import type Stripe from "stripe"; 19:import { billingIntervalToStripe } from "../stripePriceUtils"; 20:import { priceToInArrearTiers } from "./createStripeInArrear"; 22:export interface StripeMeteredPriceParams { 23: stripeCli: Stripe; 30:export const createStripeMeteredPrice = async ({ 31: stripeCli, 36:}: StripeMeteredPriceParams) => { 43: meter = await stripeCli.billing.meters.create({ 51: const meters = await stripeCli.billing.meters.list({ 81: if (config.stripe_product_id) { 83: product: config.stripe_product_id, 93: const stripePrice = await stripeCli.prices.create({ 99: ...(billingIntervalToStripe({ 108: return stripePrice; 111:export const arrearProratedToStripeTiers = ( 147:export const createStripeArrearProrated = async ({ 153: curStripeProd, 154: stripeCli, 161: curStripeProd: Stripe.Product | null; 162: stripeCli: Stripe; 168: recurringData = billingIntervalToStripe({ 181: const productData = curStripeProd 182: ? { product: curStripeProd.id } 189: // let tiers = arrearProratedToStripeTiers(price, relatedEnt); 209: const stripePrice = await stripeCli.prices.create({ 219: config.stripe_price_id = stripePrice.id; 220: config.stripe_product_id = stripePrice.product as string; 225: const placeholderPrice = await createStripeMeteredPrice({ 226: stripeCli, 232: config.stripe_placeholder_price_id = placeholderPrice.id; server/src/internal/orgs/handlers/handleConnectStripe_old.ts 2:import Stripe from "stripe"; 4:import { createStripeCli } from "@/external/connect/createStripeCli.js"; 5:import { ensureStripeProductsWithEnv } from "@/external/stripe/stripeEnsureUtils.js"; 9:} from "@/external/stripe/stripeOnboardingUtils.js"; 15:import { isStripeConnected } from "../orgUtils.js"; 17:export const connectStripe = async ({ 29: const stripe = new Stripe(apiKey); 31: const account = await stripe.accounts.retrieve(); 34: const curWebhooks = await stripe.webhookEndpoints.list(); 37: await stripe.webhookEndpoints.del(webhook.id); 70:const connectStripeBody = z.object({ 76:export const handleConnectStripe = async (req: any, res: any) => 80: action: "connect stripe", 85: connectStripeBody.parse(req.body); 95: // 2. If secret_key present, but stripe not disconnected, throw an error 96: if (secret_key && isStripeConnected({ org: req.org, env: req.env })) { 99: "Please disconnect Stripe before connecting a new secret key", 120: logger.info(`Connecting stripe for org ${req.org.slug}, ENV: ${req.env}`); 122: if (!isStripeConnected({ org: req.org, env: req.env }) && !secret_key) { 124: message: "Please provide your stripe secret key", 134: // 1. Reconnect stripe 137: const result = await connectStripe({ 143: logger.info(`Created new stripe connection`); 146: stripe_config: { 147: ...curOrg.stripe_config, 155: updates.stripe_config.test_api_key = result.test_api_key; 156: updates.stripe_config.test_webhook_secret = 159: updates.stripe_config.live_api_key = result.live_api_key; 160: updates.stripe_config.live_webhook_secret = 170: stripe_config: { 171: ...curOrg.stripe_config, 172: ...(updates?.stripe_config || {}), 177: updates.stripe_config.sandbox_success_url = success_url; 179: updates.stripe_config.success_url = success_url; 201: // Initialize stripe prices... 202: await ensureStripeProductsWithEnv({ 211: message: "Stripe connected", 216:export const handleGetStripe = async (req: any, res: any) => { 220: if (!isStripeConnected({ org, env: req.env })) { 225: const stripeCli = createStripeCli({ org, env: req.env }); 226: const account_details = await stripeCli.accounts.retrieve(); server/src/internal/orgs/handlers/crudHandlers/handleDeleteOrg.ts 11:import { deleteStripeWebhook } from "../../orgUtils.js"; 44:const deleteStripeWebhooks = async ({ 52: await deleteStripeWebhook({ 57: await deleteStripeWebhook({ 63: `Failed to delete stripe webhooks for ${org.id}, ${org.slug}. ${error.message})`, 68:export const deleteStripeAccounts = async ({ 75: if (org.test_stripe_connect?.account_id) { 77: accountId: org.test_stripe_connect.account_id, 83: if (org.live_stripe_connect?.account_id) { 85: accountId: org.live_stripe_connect.account_id, 91: if (org.test_stripe_connect?.default_account_id) { 93: accountId: org.test_stripe_connect.default_account_id, 121: // 3. Delete stripe webhooks 122: logger.info("2. Deleting stripe webhooks"); 123: await deleteStripeWebhooks({ org, logger }); 125: // 4. Delete stripe accounts 126: logger.info("3. Deleting stripe accounts"); 127: await deleteStripeAccounts({ org, logger }); server/src/internal/orgs/OrgService.ts 341: sql`${organizations.test_stripe_connect}->>'default_account_id'`, 344: eq(sql`${organizations.test_stripe_connect}->>'account_id'`, accountId), 345: eq(sql`${organizations.live_stripe_connect}->>'account_id'`, accountId), 360: const defaultAccountId = result?.test_stripe_connect?.default_account_id; 361: const testAccountId = result?.test_stripe_connect?.account_id; 384: static async findByStripeAccountId({ 394: eq(sql`${organizations.test_stripe_connect}->>'account_id'`, accountId), 395: eq(sql`${organizations.live_stripe_connect}->>'account_id'`, accountId), 403: * Update Stripe Connect account ID for an organization 405: static async updateStripeConnect({ 431: const currentConnect = org.test_stripe_connect || {}; 435: test_stripe_connect: { 442: const currentConnect = org.live_stripe_connect || {}; 446: live_stripe_connect: { 475: stripe_config: { 476: ...(org.stripe_config || {}), server/src/external/revenueCat/webhookHandlers/handleRevenuecatNonRenewingPurchase.ts 8:import { createStripeCli } from "@/external/connect/createStripeCli"; 56: stripeCli: createStripeCli({ org, env }), server/src/external/revenueCat/webhookHandlers/handleRevenuecatInitialPurchase.ts 10:import { createStripeCli } from "@/external/connect/createStripeCli"; 102: stripeCli: createStripeCli({ org, env }), server/src/internal/migrations/runRewardMigrationTask.ts 16:import { createStripeCoupon } from "@/external/stripe/stripeCouponUtils/stripeCouponUtils.js"; 147: // Get organization for Stripe operations 196: matchingNewPrice.config.stripe_price_id !== 197: oldPrice.config.stripe_price_id || 198: matchingNewPrice.config.stripe_product_id !== 199: oldPrice.config.stripe_product_id; 213: // Update Stripe coupon and reward if price IDs have changed 215: `Updating ${reward.id}, updating reward and Stripe coupon...`, 238: // Recreate the Stripe coupon with new product restrictions 239: await createStripeCoupon({ 248: `Successfully updated Stripe coupon for reward ${reward.id} with new product restrictions`, server/src/external/revenueCat/webhookHandlers/handleRevenucatRenewal.ts 9:import { createStripeCli } from "@/external/connect/createStripeCli"; 143: stripeCli: createStripeCli({ org, env }), server/src/external/revenueCat/revenuecatTypes.ts 40: | "STRIPE" server/src/internal/migrations/migrationUtils/migrationToAttachParams.ts 2:import type Stripe from "stripe"; 3:import { getStripeCusData } from "@/internal/customers/attach/attachUtils/attachParams/attachParamsUtils/getStripeCusData.js"; 10: stripeCli, 16: stripeCli: Stripe; 24: const { stripeCus, paymentMethod, now } = await getStripeCusData({ 25: stripeCli, 31: allowNoStripe: true, 37: stripeCli, 38: stripeCus, server/src/internal/migrations/migrationSteps/migrateStripeCustomer.ts 7:import type { Stripe } from "stripe"; 14:export const migrateStripeCustomer = async ({ 16: stripeCli, 26: stripeCli: Stripe; 37: stripeCli, server/src/internal/migrations/migrationSteps/migrateRevenuecatCustomer.ts 10:import { createStripeCli } from "@/external/connect/createStripeCli.js"; 99: stripeCli: createStripeCli({ org: req.org, env: req.env }), server/src/internal/migrations/migrationSteps/migrateCustomers.ts 13:import { createStripeCli } from "@/external/connect/createStripeCli.js"; 14:import { createStripePriceIFNotExist } from "@/external/stripe/createStripePrice/createStripePrice.js"; 52: // Create stripe prices if they don't exist 53: const stripeCli = createStripeCli({ org, env }); 57: createStripePriceIFNotExist({ 59: stripeCli, server/src/internal/migrations/migrationSteps/migrateCustomer.ts 11:import { createStripeCli } from "@/external/connect/createStripeCli.js"; 16:import { migrateStripeCustomer } from "./migrateStripeCustomer.js"; 42: const stripeCli = createStripeCli({ org, env }); 80: await migrateStripeCustomer({ 82: stripeCli, server/src/internal/metadata/metadataUtils.ts 1:import type Stripe from "stripe"; 6: checkoutSession: Stripe.Checkout.Session, server/src/internal/metadata/MetadataService.ts 29: static async getByStripeInvoiceId({ 31: stripeInvoiceId, 35: stripeInvoiceId: string; 40: eq(metadata.stripe_invoice_id, stripeInvoiceId), server/src/internal/mainRouter.ts 7:import { createStripeCli } from "@/external/connect/createStripeCli.js"; 59: const stripeCli = createStripeCli({ 64: const stripeInvoice = await stripeCli.invoices.retrieve( 65: invoice.stripe_id, 68: if (stripeInvoice.status === "draft") { 74: res.redirect(stripeInvoice.hosted_invoice_url); server/src/internal/invoices/previewItemUtils/getItemsForNewProduct.ts 21:import type Stripe from "stripe"; 178: sub?: Stripe.Subscription; server/src/internal/invoices/previewItemUtils/getItemsForCurProduct.ts 9:import type Stripe from "stripe"; 35: sub?: Stripe.Subscription; 65: stripeItems: subItems, 69: latestInvoice: sub?.latest_invoice as Stripe.Invoice, 70: subDiscounts: sub?.discounts as Stripe.Discount[], server/src/internal/invoices/previewItemUtils/getCurContUseItems.ts 8: stripeToAtmnAmount, 11:import type Stripe from "stripe"; 12:import { getSubItemAmount } from "@/external/stripe/stripeSubUtils/getSubItemAmount.js"; 13:import { findPriceInStripeItems } from "@/external/stripe/stripeSubUtils/stripeSubItemUtils.js"; 31: sub: Stripe.Subscription; 49: const price = findPriceInStripeItems({ 60: const atmnTotalAmount = stripeToAtmnAmount({ server/src/external/connect/registerConnectWebhook.ts 1:import type Stripe from "stripe"; 6:import { initPlatformStripe } from "./initStripeCli.js"; 14: // Init master stripe 15: const stripeCli = initPlatformStripe({ masterOrg: org, env }); 17: const curWebhookEndpoints = await stripeCli.webhookEndpoints.list(); 18: const backendUrl = process.env.SERVER_URL || process.env.STRIPE_WEBHOOK_URL; 25: const webhook = await stripeCli.webhookEndpoints.create({ 28: WEBHOOK_EVENTS as Stripe.WebhookEndpointCreateParams.EnabledEvent[], server/src/external/connect/initStripeCli.ts 10:import Stripe from "stripe"; 13:export const initMasterStripe = (params?: { 21: if (!process.env.STRIPE_LIVE_SECRET_KEY) { 23: message: "STRIPE_LIVE_SECRET_KEY env variable is not set", 26: secretKey = process.env.STRIPE_LIVE_SECRET_KEY; 28: if (!process.env.STRIPE_SANDBOX_SECRET_KEY) { 30: message: "STRIPE_SANDBOX_SECRET_KEY env variable is not set", 33: secretKey = process.env.STRIPE_SANDBOX_SECRET_KEY; 37: // return new Stripe(secretKey); 40: return new Stripe(secretKey, { 41: stripeAccount: params?.accountId, 48:export const initPlatformStripe = ({ 61: message: "Master organization is undefined in initPlatformStripe", 68: ? masterOrg.stripe_config?.test_api_key 69: : masterOrg.stripe_config?.live_api_key; 74: message: `Master organization must have Stripe ${envLabel} secret key connected`, 81: message: `Failed to decrypt master organization's Stripe secret key`, 85: return new Stripe(decrypted, { 86: stripeAccount: accountId || undefined, 91:export const getStripeWebhookSecret = async ({ 107: secret = process.env.STRIPE_LIVE_WEBHOOK_SECRET || ""; 109: secret = process.env.STRIPE_SANDBOX_WEBHOOK_SECRET || ""; 114: message: `STRIPE_WEBHOOK_SECRET env variable is not set (${env})`, server/src/internal/invoices/invoiceUtils/createAndFinalizeInvoice.ts 1:import type Stripe from "stripe"; 2:import { payForInvoice } from "@/external/stripe/stripeInvoiceUtils.js"; 5: stripeCli, 7: stripeCusId, 8: stripeSubId, 15: stripeCli: Stripe; 16: paymentMethod: Stripe.PaymentMethod | null; 17: stripeCusId: string; 18: stripeSubId: string; 19: invoiceItems?: Stripe.InvoiceItemCreateParams[]; 25: const invoice = await stripeCli.invoices.create({ 26: customer: stripeCusId, 28: subscription: stripeSubId, 37: await stripeCli.invoiceItems.create({ 40: customer: stripeCusId, 46: let finalInvoice = await stripeCli.invoices.retrieve(invoice.id!); 48: finalInvoice = await stripeCli.invoices.finalizeInvoice(invoice.id!); 53: let finalInvoice = await stripeCli.invoices.finalizeInvoice(invoice.id!, { 63: stripeCli, server/src/external/connect/createStripeCli.ts 8:import { isStripeConnected } from "@server/internal/orgs/orgUtils.js"; 10:import Stripe from "stripe"; 12:import { initMasterStripe, initPlatformStripe } from "./initStripeCli.js"; 14:export const createStripeCli = ({ 26: if (isStripeConnected({ org, env, throughSecretKey: true })) { 30: ? org.stripe_config?.test_api_key 31: : org.stripe_config?.live_api_key; 35: message: `Please connect your Stripe ${env === AppEnv.Sandbox ? "test" : "live"} secret key. You can find it here: https://dashboard.stripe.com${env === AppEnv.Sandbox ? "/test" : ""}/apikeys`, 36: code: ErrCode.StripeConfigNotFound, 42: return new Stripe(decrypted, { 54: return initPlatformStripe({ 62: // Standard flow - use Autumn's master Stripe keys 63: return initMasterStripe({ accountId, legacyVersion, env }); 67: message: `No stripe account linked to organization ${org.id}`, server/src/internal/invoices/invoiceUtils.ts 8:import type Stripe from "stripe"; 10:import { getStripeExpandedInvoice } from "@/external/stripe/stripeInvoiceUtils.js"; 11:import { findPriceInStripeItems } from "@/external/stripe/stripeSubUtils/stripeSubItemUtils.js"; 21: stripeInvoice, 27: stripeInvoice?: Stripe.Invoice; 31: if (!stripeInvoice) { 32: stripeInvoice = await getStripeExpandedInvoice({ 33: stripeCli: attachParams.stripeCli, 34: stripeInvoiceId: invoiceId!, 39: const invoice = await InvoiceService.getByStripeId({ 41: stripeId: stripeInvoice.id!, 45: stripeInvoice, 59: `[insertInvoiceFromAttach] invoice: ${stripeInvoice?.id}, productIds: ${productIds.join(", ")}`, 63: await InvoiceService.updateByStripeId({ 65: stripeId: stripeInvoice.id!, 72: await InvoiceService.createInvoiceFromStripe({ 74: stripeInvoice, 83: return stripeInvoice; 103: stripeInvoice, 107: stripeInvoice: Stripe.Invoice; 114: for (const line of stripeInvoice.lines.data) { 115: const price = findPriceInStripeItems({ 127: stripe_id: line.id, 136: `Failed to get invoice items for invoice ${stripeInvoice.id}`, 148: invoice?: Stripe.Invoice | null; 156: stripe_id: invoice.id, 161: // stripe_id: invoice.stripe_id, server/src/external/connect/connectUtils.ts 6:import { initMasterStripe } from "./initStripeCli.js"; 18: const config = org.test_stripe_connect; 24: return org.live_stripe_connect?.account_id; 40: const masterStripe = initMasterStripe({ env }); 42: await masterStripe.oauth.deauthorize({ 45: ? process.env.STRIPE_LIVE_CLIENT_ID || "" 46: : process.env.STRIPE_SANDBOX_CLIENT_ID || "", 47: stripe_user_id: accountId, 66: const masterStripe = initMasterStripe({ env }); 68: await masterStripe.accounts.del(accountId); 84: ? Boolean(org.test_stripe_connect?.master_org_id) && 85: Boolean(org.test_stripe_connect?.account_id) 86: : Boolean(org.live_stripe_connect?.master_org_id) && 87: Boolean(org.live_stripe_connect?.account_id); 111: const secret = org.stripe_config?.[`${prefix}_connect_webhook_secret`]; server/src/internal/invoices/invoiceItemUtils/invoiceItemUtils.ts 3:import Stripe from "stripe"; 5:export const constructStripeInvoiceItem = ({ 11: stripeSubId, 12: stripeCustomerId, 21: stripeSubId: string; 22: stripeCustomerId: string; 38: product: config.stripe_product_id || product.processor?.id!, 46: let invoiceItem: Stripe.InvoiceItemCreateParams = { 47: subscription: stripeSubId, 51: customer: stripeCustomerId, server/src/internal/invoices/InvoiceService.ts 10: stripeToAtmnAmount, 13:import { getInvoiceDiscounts } from "@server/external/stripe/stripeInvoiceUtils.js"; 17:import type Stripe from "stripe"; 31: stripe_id: invoice.stripe_id, 102: static async getByStripeId({ 104: stripeId, 107: stripeId: string; 110: where: eq(invoices.stripe_id, stripeId), 120: static async createInvoiceFromStripe({ 122: stripeInvoice, 133: stripeInvoice: Stripe.Invoice; 147: const atmnTotal = stripeToAtmnAmount({ 148: amount: stripeInvoice.total, 149: currency: stripeInvoice.currency, 156: created_at: stripeInvoice.created * 1000, 157: stripe_id: stripeInvoice.id!, 158: hosted_invoice_url: stripeInvoice.hosted_invoice_url || null, 159: status: status || (stripeInvoice.status as InvoiceStatus | null), 163: // Stripe stuff 165: currency: stripeInvoice.currency, 167: expandedInvoice: stripeInvoice, 180: console.error(" ❌ Error inserting Stripe invoice: ", error); 187: if (!stripeInvoice.livemode || !sendRevenueEvent) { 206: static async updateByStripeId({ 208: stripeId, 212: stripeId: string; 218: .where(eq(invoices.stripe_id, stripeId)) server/src/internal/features/utils/updateFeatureUtils/handleFeatureUsageTypeChanged.ts 101: stripe_price_id: null, server/src/external/autumn/autumnCliV2.ts 150: deleteInStripe = false, 152: deleteInStripe?: boolean; 155: const queryParams = deleteInStripe ? "?delete_in_stripe=true" : ""; 304: deleteInStripe = false, 306: deleteInStripe?: boolean; 310: deleteInStripe, 387: return await this.post(`/rewards?legacyStripe=true`, reward); 457: stripe = { 463: return await this.post(`/organization/stripe`, params); 467: return await this.delete(`/organization/stripe`); server/src/external/autumn/autumnCli.ts 201: deleteInStripe = false, 203: deleteInStripe?: boolean; 207: `${this.baseUrl}${path}?${deleteInStripe ? "delete_in_stripe=true" : ""}`, 427: deleteInStripe = false, 429: deleteInStripe?: boolean; 433: deleteInStripe, 530: const data = await this.post(`/rewards?legacyStripe=true`, reward); 605: stripe = { 611: const data = await this.post(`/organization/stripe`, params); 616: const data = await this.delete(`/organization/stripe`); server/src/errors/errCodes.ts 19:// StripeKeyNotFound: "stripe_key_not_found", 21:// // Stripe 22:// StripeKeyInvalid: "stripe_key_invalid", 23:// StripeConfigNotFound: "stripe_config_not_found", 24:// StripeDeleteCustomerFailed: "stripe_delete_customer_failed", 25:// StripeCreateCustomerFailed: "stripe_create_customer_failed", 26:// StripeCreateProductFailed: "stripe_create_product_failed", 27:// StripeCancelSubscriptionFailed: "stripe_cancel_subscription_failed", 51:// CreateStripeProductFailed: "create_stripe_product_failed", 52:// DeleteStripeProductFailed: "delete_stripe_product_failed", 53:// CreateStripeSubscriptionFailed: "create_stripe_subscription_failed", server/src/internal/entities/handlers/handleDeleteEntity/cancelSubsForEntity.ts 6:import { createStripeCli } from "@/external/connect/createStripeCli.js"; 9:import { cusProductsToStripeSubs } from "@/internal/customers/cusProducts/cusProductUtils/convertCusProduct.js"; 23: const stripeCli = createStripeCli({ org, env }); 24: const curSubs = await cusProductsToStripeSubs({ 26: stripeCli, 43: stripeCli, server/src/cron/invoiceCron/runInvoiceCron.ts 4:import { createStripeCli } from "../../external/connect/createStripeCli"; 5:import { invoiceToSubId } from "../../external/stripe/stripeInvoiceUtils"; 20: const stripeCli = createStripeCli({ org, env: customer.env }); 22: if (!metadata.stripe_invoice_id) return; 24: const invoice = await stripeCli.invoices.retrieve(metadata.stripe_invoice_id); 29: `Invoice: ${metadata.stripe_invoice_id} for customer ${customer.id} (org: ${org.slug}) - status: ${invoice.status}`, 34: await stripeCli.invoices.voidInvoice(metadata.stripe_invoice_id); 36: `voided invoice ${metadata.stripe_invoice_id} for customer ${customer.id} (org: ${org.slug})`, 42: await stripeCli.subscriptions.cancel(subId); 83: isNotNull(metadata.stripe_invoice_id), server/src/cron/cronUtils.ts 16:import { createStripeCli } from "@/external/connect/createStripeCli.js"; 61: const stripeCli = createStripeCli({ org, env }); 70: const sub = await stripeCli.subscriptions.retrieve(subId); server/src/internal/dev/devRouter.ts 5:import type Stripe from "stripe"; 9:} from "@/external/stripe/stripeOnboardingUtils.js"; 18:import { isStripeConnected } from "../orgs/orgUtils.js"; 120: stripeFlowAuthKey: string; 159: const stripeConnected = isStripeConnected({ org, env: AppEnv.Sandbox }); 163: stripe_connected: stripeConnected, 177: if (!stripeConnected) { 180: responseData.stripeFlowAuthKey = key; 181: const stripeCacheData = { 184: await CacheManager.setJson(key, stripeCacheData, OTP_TTL); 191:devRouter.post("/cli/stripe", async (req: any, res: any) => { 195: action: "Get Stripe Flow Auth Key", 211: const { stripeTestKey, stripeLiveKey } = req.body; 219: await checkKeyValid(stripeTestKey); 220: await checkKeyValid(stripeLiveKey); 222: let testWebhook: Stripe.WebhookEndpoint; 223: let liveWebhook: Stripe.WebhookEndpoint; 227: stripeTestKey, 233: stripeLiveKey, 239: res.status(500).json({ message: "Error creating stripe webhook" }); 247: stripe_connected: true, 249: stripe_config: { 250: test_api_key: encryptData(stripeTestKey), 251: live_api_key: encryptData(stripeLiveKey), 262: message: "Stripe keys updated", server/src/_luaScripts/cusLuaScripts/setCustomer.lua 65: stripe_id = customerData.stripe_id, server/src/internal/customers/CusService.ts 188: static async getByStripeId({ 190: stripeId, 195: stripeId: string; 201: eq(sql`processor->>'id'`, stripeId), server/src/internal/customers/internalHandlers/handleGetCusReferrals.ts 3:import { createStripeCli } from "@/external/connect/createStripeCli.js"; 5:import { isStripeConnected } from "@/internal/orgs/orgUtils.js"; 27: const [referred, redeemed, stripeCus] = await Promise.all([ 41: if (isStripeConnected({ org, env }) && internalCustomer.processor?.id) { 42: const stripeCli = createStripeCli({ org, env }); 43: const stripeCus: any = await stripeCli.customers.retrieve( 46: return stripeCus; 74: stripeCus, server/src/internal/billing/handlers/handleSetupPayment.ts 6:import { createStripeCli } from "@/external/connect/createStripeCli.js"; 7:import { createStripeCusIfNotExists } from "@/external/stripe/stripeCusUtils.js"; 29: await createStripeCusIfNotExists({ 37: const stripeCli = createStripeCli({ org, env }); 52: // let stripe automatically determine payment methods 53: const session = await stripeCli.checkout.sessions.create(sessionParams); 65: logger.warn("Stripe checkout session creation failed", { 76: const fallbackSession = await stripeCli.checkout.sessions.create({ 102: "Unable to create checkout session. Please ensure you have activated card payment method in your Stripe dashboard.", server/src/internal/customers/handlers/handleUpdateCustomerV2.ts 11:import { createStripeCli } from "@/external/connect/createStripeCli.js"; 65: // Try to update stripe ID 66: let stripeId = originalCustomer.processor?.id; 67: const newStripeId = newCusData.stripe_id; 69: if (notNullish(newStripeId) && stripeId !== newStripeId) { 70: const stripeCli = createStripeCli({ org, env }); 71: await stripeCli.customers.retrieve(newStripeId); 73: stripeId = newCusData.stripe_id; 75: `Updating customer's Stripe ID from ${originalCustomer.processor?.id} to ${stripeId}`, 89: const stripeUpdate = { 98: if (Object.keys(stripeUpdate).length > 0 && stripeId) { 99: const stripeCli = createStripeCli({ org, env }); 100: await stripeCli.customers.update(stripeId, stripeUpdate as any); 112: // Only set processor if newStripeId is provided 113: if (newStripeId) { 114: updateData.processor = { id: newStripeId, type: ProcessorType.Stripe }; server/src/internal/billing/checkout/handleCheckoutV2.ts 12: checkStripeConnections, 47: await checkStripeConnections({ server/src/internal/customers/handlers/handleTransferProduct/handleDecreaseAndTransfer.ts 10:import { createStripeCli } from "@/external/connect/createStripeCli.js"; 32: const stripeCli = createStripeCli({ org, env }); 83: stripeCli: stripeCli, server/src/internal/customers/handlers/handleDeleteCustomerV2.ts 4:import { deleteStripeCustomer } from "@/external/stripe/stripeCusUtils.js"; 13: deleteInStripe = false, 17: deleteInStripe?: boolean; 38: if (customer.processor?.id && deleteInStripe) { 39: await deleteStripeCustomer({ 42: stripeId: customer.processor.id, 47: `Couldn't delete ${chalk.yellow("stripe customer")} ${ 74: delete_in_stripe: z.boolean().optional().default(false), 84: const { delete_in_stripe } = c.req.valid("query"); 103: if (customer.processor?.id && delete_in_stripe) { 104: await deleteStripeCustomer({ 107: stripeId: customer.processor.id, 112: `Couldn't delete ${chalk.yellow("stripe customer")} ${ server/src/internal/customers/handlers/handleCreateCustomer.ts 12:import { createStripeCusIfNotExists } from "@/external/stripe/stripeCusUtils.js"; 14:import { initProductInStripe } from "@/internal/products/productUtils.js"; 20:export const initStripeCusAndProducts = async ({ 36: createStripeCusIfNotExists({ 47: initProductInStripe({ server/src/internal/billing/attach/utils/attachParamsToMetadata.ts 12: stripeInvoiceId, 18: stripeInvoiceId?: string; 24: stripeCli: _stripeCli, 37: stripe_invoice_id: stripeInvoiceId, server/src/internal/customers/handlers/handleBillingPortal/handleGetBillingPortal.ts 3:import { createStripeCli } from "../../../../external/connect/createStripeCli"; 4:import { createStripeCusIfNotExists } from "../../../../external/stripe/stripeCusUtils"; 36: const stripeCli = createStripeCli({ org, env: req.env }); 38: let stripeCusId: string = customer.processor?.id; 40: const newCus = await createStripeCusIfNotExists({ 50: message: `Failed to create Stripe customer`, 54: stripeCusId = newCus.id; 57: const portal = await stripeCli.billingPortal.sessions.create({ 58: customer: stripeCusId, server/src/internal/billing/attach/handleAttachV2.ts 8:import { checkStripeConnections } from "../../customers/attach/attachRouter"; 65: await checkStripeConnections({ server/src/internal/customers/handlers/handleBillingPortal/createDefaultPortalConfig.ts 3:import type Stripe from "stripe"; 5:export const createDefaultPortalConfig = async (stripeCli: Stripe) => { 7: const configuration = await stripeCli.billingPortal.configurations.create({ 32: code: ErrCode.StripeError, server/src/internal/customers/handlers/handleBillingPortal/createBillingPortalSession.ts 2:import { createStripeCli } from "../../../../external/connect/createStripeCli"; 3:import { createStripeCusIfNotExists } from "../../../../external/stripe/stripeCusUtils"; 20: const stripeCli = createStripeCli({ org, env }); 22: // Determine the Stripe customer ID to use 23: let stripeCustomerId: string; 26: const newCus = await createStripeCusIfNotExists({ 36: message: `Failed to create Stripe customer`, 40: stripeCustomerId = newCus.id; 42: stripeCustomerId = customer.processor.id; 48: return await stripeCli.billingPortal.sessions.create({ 49: customer: stripeCustomerId, 71: const configuration = await createDefaultPortalConfig(stripeCli).catch( 89: return await stripeCli.billingPortal.sessions.create({ 90: customer: stripeCustomerId, server/src/internal/customers/handlers/handleAddCouponToCusV2.ts 6:import { createStripeCli } from "@/external/connect/createStripeCli.js"; 7:import { createStripeCusIfNotExists } from "@/external/stripe/stripeCusUtils.js"; 44: const stripeCli = createStripeCli({ 50: await createStripeCusIfNotExists({ 59: await stripeCli.rawRequest( server/src/internal/customers/getFullCusQuery.ts 167: json_agg(row_to_json(s)) FILTER (WHERE s.stripe_id IS NOT NULL), 173: WHERE cpwp.subscription_ids @> ARRAY[s.stripe_id] 533: json_agg(row_to_json(s)) FILTER (WHERE s.stripe_id IS NOT NULL), 537: JOIN subscriptions s ON s.stripe_id = ANY(cpwp.subscription_ids) server/src/internal/customers/cusUtils/getOrCreateCustomer.ts 77: stripe_id: customerData?.stripe_id, server/src/internal/customers/cusUtils/getOrCreateApiCustomer.ts 47: stripe_id: customerData?.stripe_id, 94: stripe_id: customerData?.stripe_id, server/src/internal/customers/cusUtils/cusResponseUtils/stripeDiscountToResponse.ts 4: stripeToAtmnAmount, 6:import type Stripe from "stripe"; 8:const parseStripeCouponDuration = (coupon: Stripe.Coupon) => { 29:export const stripeDiscountToResponse = ({ 33: discount: Stripe.Discount; 34: totalDiscountAmounts?: Stripe.Invoice.TotalDiscountAmount[]; 43: const { duration_type, duration_value } = parseStripeCouponDuration(coupon); 49: const totalAtmnDiscountAmount = stripeToAtmnAmount({ server/src/internal/customers/cusUtils/cusResponseUtils/getCusUpcomingInvoice.ts 7: stripeToAtmnAmount, 9:import type Stripe from "stripe"; 11:import { createStripeCli } from "@/external/connect/createStripeCli.js"; 12:import { getEarliestPeriodEnd } from "@/external/stripe/stripeSubUtils/convertSubUtils.js"; 13:import { lineItemInCusProduct } from "@/external/stripe/stripeSubUtils/stripeSubItemUtils.js"; 14:import { getStripeSubs } from "@/external/stripe/stripeSubUtils.js"; 15:import { stripeDiscountToResponse } from "./stripeDiscountToResponse.js"; 38: const stripeCli = createStripeCli({ org, env }); 40: const subs = await getStripeSubs({ 41: stripeCli, 51: const upcomingInvoice = await stripeCli.invoices.createPreview({ 63: const atmnLineAmount = stripeToAtmnAmount({ 75: const stripeDiscounts = upcomingInvoice.discounts.filter( 76: (d): d is Stripe.Discount => 78: ) as Stripe.Discount[]; 82: const discounts = stripeDiscounts 84: stripeDiscountToResponse({ 92: const atmnSubtotal = stripeToAtmnAmount({ 97: const atmnTotal = stripeToAtmnAmount({ server/src/internal/customers/cusUtils/cusResponseUtils/getCusRewards.ts 10:import type Stripe from "stripe"; 11:import { createStripeCli } from "@/external/connect/createStripeCli.js"; 12:import { getStripeSubs } from "@/external/stripe/stripeSubUtils.js"; 36: const stripeCli = createStripeCli({ 42: const [stripeCus, stripeSubs] = await Promise.all([ 43: stripeCli.customers.retrieve(fullCus.processor?.id, { 45: }) as Promise, 46: getStripeSubs({ 47: stripeCli, 53: const stripeDiscounts: Stripe.Discount[] = stripeSubs?.flatMap( 55: ) as Stripe.Discount[]; 57: if (stripeCus.discount) { 58: stripeDiscounts.push(stripeCus.discount); 62: discounts: stripeDiscounts 68: const coupon = d.coupon as Stripe.Coupon; server/src/internal/customers/cusUtils/cusResponseUtils/getCusPaymentMethodRes.ts 7:import { createStripeCli } from "@/external/connect/createStripeCli.js"; 8:import { getCusPaymentMethod } from "@/external/stripe/stripeCusUtils.js"; 25: const stripeCli = createStripeCli({ 31: stripeCli, 32: stripeId: fullCus.processor?.id, server/src/internal/customers/cusUtils/createNewCustomer.ts 14:import { createStripeCli } from "@/external/connect/createStripeCli.js"; 30:import { initStripeCusAndProducts } from "../handlers/handleCreateCustomer.js"; 110: processor: parsedCustomer.stripe_id 112: id: parsedCustomer.stripe_id, 113: type: "stripe", 118: // Check if stripeCli exists 120: createStripeCli({ org, env }); 154: let stripeCli = null; 156: stripeCli = createStripeCli({ org, env }); 157: await initStripeCusAndProducts({ 191: stripeCli, server/src/internal/balances/track/trackUtils/runDeductionTx.ts 272: // Bill on Stripe for each updated entitlement server/src/internal/customers/cusUtils/apiCusUtils/getApiSubscription/getApiSubscription.ts 33: (s) => s.id === subId || (s as Subscription).stripe_id === subId, 36: let stripeSubData: { 45: stripeSubData = { 56: stripeSubData = { 100: current_period_start: stripeSubData?.current_period_start || null, 101: current_period_end: stripeSubData?.current_period_end || null, server/src/internal/customers/cusUtils/apiCusUtils/getApiCustomerBase.ts 51: stripe_id: fullCus.processor?.id || null, server/src/internal/customers/cusProducts/insertCusProduct/initCusEnt/initNextResetAt.ts 11:import { freeTrialToStripeTimestamp } from "@/internal/products/free-trials/freeTrialUtils.js"; 47: ? freeTrialToStripeTimestamp({ freeTrial, now }) server/src/internal/customers/cusProducts/cusProductUtils/getExistingCusProducts.ts 14: // processorType = ProcessorType.Stripe, server/src/internal/customers/cusProducts/cusProductUtils/convertCusProduct.ts 5:import type Stripe from "stripe"; 8: getStripeSchedules, 9: getStripeSubs, 10:} from "@/external/stripe/stripeSubUtils.js"; 14: stripeCli, 17: stripeCli: Stripe; 26: return getStripeSchedules({ 27: stripeCli, 34: stripeCli, 37: stripeCli: Stripe; 44: const schedule = await stripeCli.subscriptionSchedules.retrieve( 60: stripeCli, 63: stripeCli: Stripe; 69: const sub = await stripeCli.subscriptions.retrieve(subId, { 76:export const cusProductsToStripeSubs = ({ 78: stripeCli, 81: stripeCli: Stripe; 83: return getStripeSubs({ 84: stripeCli, server/src/internal/customers/cusProducts/cusProductUtils.ts 10:import { createStripeCli } from "@/external/connect/createStripeCli.js"; 19:import { initStripeCusAndProducts } from "../handlers/handleCreateCustomer.js"; 77: const stripeCli = createStripeCli({ org, env }); 80: // Initialize Stripe customer and products if needed (for paid non-trial products) 82: await initStripeCusAndProducts({ 111: stripeCli, 219:export const getCusProductsWithStripeSubId = ({ 221: stripeSubId, 225: stripeSubId: string; 230: cusProduct.subscription_ids?.includes(stripeSubId) && server/src/internal/api/rewards/handlers/rewards/handleUpdateCoupon.ts 2:import { createStripeCli } from "@/external/connect/createStripeCli.js"; 3:import { createStripeCoupon } from "@/external/stripe/stripeCouponUtils/stripeCouponUtils.js"; 23: const stripeCli = createStripeCli({ 75: // 1. Delete old prices from stripe 77: await stripeCli.coupons.del(reward.id); 78: await stripeCli.coupons.del(reward.internal_id); 85: await createStripeCoupon({ 91: legacyVersion: req.query.legacyStripe === "true", server/src/internal/api/rewards/handlers/rewards/handleDeleteCoupon.ts 2:import { createStripeCli } from "@/external/connect/createStripeCli.js"; 18: const stripeCli = createStripeCli({ 38: await stripeCli.coupons.del(reward.id); 41: `Failed to delete coupon from stripe: ${(error as { message: string }).message}`, server/src/internal/api/rewards/handlers/rewards/handleCreateCoupon.ts 6:import { createStripeCoupon } from "@/external/stripe/stripeCouponUtils/stripeCouponUtils.js"; 16: initRewardStripePrices, 49: await initRewardStripePrices({ 57: await createStripeCoupon({ 63: legacyVersion: req.query.legacyStripe === "true", 83: await createStripeCoupon({ server/src/internal/api/invoiceRouter.ts 2:import { createStripeCli } from "@/external/connect/createStripeCli.js"; 8:invoiceRouter.get("/:stripe_invoice_id/stripe", async (req: any, res: any) => { 12: const stripeCli = createStripeCli({ org, env: req.env }); 14: const stripeInvoice = await stripeCli.invoices.retrieve( 15: req.params.stripe_invoice_id, 18: res.status(200).json(stripeInvoice); server/src/internal/customers/cusProducts/cusEnts/cusEntUtils.ts 16:import { createStripeCli } from "@server/external/connect/createStripeCli.js"; 120:export const updateCusEntInStripe = async ({ 143: // Send event to Stripe 144: const stripeCli = createStripeCli({ 149: await stripeCli.billing.meterEvents.create({ 152: stripe_customer_id: customer.processor.id, 157: console.log(` ✅ Stripe event sent, amount: (${amountUsed})`); server/src/internal/customers/cusProducts/CusProductService.ts 271: static async getByStripeSubId({ 273: stripeSubId, 279: stripeSubId: string; 284: // sql`${customerProducts.subscription_ids} @> ${sql`ARRAY[${stripeSubId}]`}`, 288: or(arrayContains(customerProducts.subscription_ids, [stripeSubId])), 324: static async getByStripeScheduledId({ 326: stripeScheduledId, 331: stripeScheduledId: string; 341: stripeScheduledId, 343: sql`${customerProducts.scheduled_ids} @> ${sql`ARRAY[${stripeScheduledId}]`}`, 442: static async updateByStripeSubId({ 444: stripeSubId, 449: stripeSubId: string; 458: arrayContains(customerProducts.subscription_ids, [stripeSubId]), 480: static async updateByStripeScheduledId({ 482: stripeScheduledId, 486: stripeScheduledId: string; 494: arrayContains(customerProducts.scheduled_ids, [stripeScheduledId]), server/src/internal/api/entities/entityUtils.ts 17:import { createStripeCli } from "@/external/connect/createStripeCli.js"; 18:import { submitUsageToStripe } from "@/external/stripe/stripeMeterUtils.js"; 122: // TODO: Send usage to stripe if cus price exists 123: const stripeCli = createStripeCli({ 138: await submitUsageToStripe({ 144: stripeCli, server/src/internal/customers/cusProducts/AttachParams.ts 20:import type Stripe from "stripe"; 26: stripeCli: Stripe; 27: stripeCus?: Stripe.Customer; 29: paymentMethod: Stripe.PaymentMethod | null | undefined; 87: stripeInvoiceId?: string; server/src/internal/customers/change-product/scheduleUtils/updateScheduleWithNewItems.ts 1:import Stripe from "stripe"; 14: stripeCli, 23: stripeCli: Stripe; 46: const stripeSchedule = await stripeCli.subscriptionSchedules.update( 69: return stripeSchedule; server/src/internal/customers/change-product/scheduleUtils/getFilteredScheduleItems.ts 26: const stripePrice = prices.find((price) => price.id === scheduleItem.price); 31: price.config?.stripe_price_id === scheduleItem.price || 32: price.config?.stripe_product_id === stripePrice?.product, 35: (product) => product.processor?.id === stripePrice?.product, server/src/internal/customers/change-product/scheduleUtils/ScheduleObj.ts 2:import Stripe from "stripe"; 5: schedule: Stripe.SubscriptionSchedule; 8: prices: Stripe.Price[]; server/src/internal/customers/change-product/handleDowngrade/cancelCurSubs.ts 1:import { getSubItemsForCusProduct } from "@/external/stripe/stripeSubUtils.js"; 2:import { subToAutumnInterval } from "@/external/stripe/utils.js"; 11:import Stripe from "stripe"; 16: stripeCli, 19: curSubs: Stripe.Subscription[]; 20: stripeCli: Stripe; 26: // otherSubItems: Stripe.SubscriptionItem[]; 27: // otherSub: Stripe.Subscription; 34: // stripeSub: sub, 45: // await stripeCli.subscriptionSchedules.release(sub.schedule as string); 48: // await stripeCli.subscriptions.update(sub.id, { 55: // await stripeCli.subscriptions.update(sub.id, { server/src/internal/customers/cancel/handleCancelProduct.ts 11:import { createStripeCli } from "@/external/connect/createStripeCli.js"; 13:import { getCusPaymentMethod } from "../../../external/stripe/stripeCusUtils.js"; 53: const stripeCli = createStripeCli({ org, env }); 67: stripeCli, 138: stripeCli, 164: stripeCli, 165: stripeId: fullCus.processor?.id, 172: stripeCli, server/src/internal/customers/cancel/cancelScheduledProduct.ts 6:import { createStripeCli } from "@/external/connect/createStripeCli.js"; 23: const stripeCli = createStripeCli({ org, env }); 29: stripeCli, 33: await stripeCli.subscriptionSchedules.cancel(schedule.id); 46: await stripeCli.subscriptions.update(subId, { cancel_at: null }); server/src/internal/customers/cancel/cancelImmediately.ts 8:import { createStripeCli } from "@/external/connect/createStripeCli.js"; 29: const stripeCli = createStripeCli({ org, env }); 37: const sub = await cusProductToSub({ cusProduct, stripeCli }); 40: await stripeCli.subscriptions.cancel(sub.id, { server/src/internal/customers/cancel/cancelEndOfCycle.ts 6:import { createStripeCli } from "@/external/connect/createStripeCli.js"; 7:import { getLatestPeriodEnd } from "@/external/stripe/stripeSubUtils/convertSubUtils.js"; 22: const stripeCli = createStripeCli({ org, env }); 24: const sub = await cusProductToSub({ cusProduct, stripeCli }); 27: await stripeCli.subscriptions.update(sub.id, { server/src/internal/analytics/analyticsUtils.ts 77: subscription.stripe_id === subscriptionId, server/src/internal/customers/attach/models/AttachContext.ts 9:// import Stripe from "stripe"; 15:// paymentMethod: Stripe.PaymentMethod; 16:// stripeCli: Stripe; server/src/internal/customers/attach/mergeUtils/updateCurSchedule.ts 1:import type Stripe from "stripe"; 15: schedule: Stripe.SubscriptionSchedule; 16: sub: Stripe.Subscription; 17: newPhases: Stripe.SubscriptionScheduleUpdateParams.Phase[]; 19: const { stripeCli } = attachParams; 22: await stripeCli.subscriptions.update(sub.id, { 27: await stripeCli.subscriptionSchedules.update(schedule.id, { server/src/internal/customers/attach/mergeUtils/subToNewSchedule.ts 2:import type Stripe from "stripe"; 3:import { getStripeSubItems2 } from "@/external/stripe/stripeSubUtils/getStripeSubItems.js"; 19: sub: Stripe.Subscription; 25: const itemSet = await getStripeSubItems2({ 49: const { stripeCli } = attachParams; 50: let newSchedule: Stripe.SubscriptionSchedule | undefined; 54: // await stripeCli.subscriptions.update(sub.id, { 70: newSchedule = await stripeCli.subscriptionSchedules.create({ 78: await stripeCli.subscriptionSchedules.update(newScheduleId, { 97: await CusProductService.updateByStripeSubId({ 99: stripeSubId: sub.id!, 106: return newSchedule as Stripe.SubscriptionSchedule; server/src/initHono.ts 6:import { stripeWebhookRouter } from "./external/stripe/stripeWebhookRouter.js"; 13:import { handleOAuthCallback } from "./internal/orgs/handlers/stripeHandlers/handleOAuthCallback.js"; 72: app.get("/stripe/oauth_callback", handleOAuthCallback); 96: app.route("", stripeWebhookRouter); server/src/internal/customers/attach/mergeUtils/phaseUtils/upsertNewPhase.ts 2:import Stripe from "stripe"; 8: phase: Stripe.SubscriptionSchedule.Phase; 24: schedule: Stripe.SubscriptionSchedule; 28: phases: Stripe.SubscriptionScheduleUpdateParams.Phase[]; 33: const phases: Stripe.SubscriptionScheduleUpdateParams.Phase[] = 36: price: (item.price as Stripe.Price).id, server/src/internal/customers/attach/mergeUtils/phaseUtils/phaseUtils.ts 7:import type Stripe from "stripe"; 45: items: Stripe.SubscriptionScheduleUpdateParams.Phase.Item[]; 53: return (item.price as unknown as Stripe.Price)?.id; 57: const autumnPrices = await PriceService.getByStripeIds({ 59: stripePriceIds: priceIds, 79: schedule: Stripe.SubscriptionSchedule; 107: phases: Stripe.SubscriptionScheduleUpdateParams.Phase[]; server/src/internal/customers/attach/mergeUtils/phaseUtils/mergeSimilarPhases.ts 1:import Stripe from "stripe"; 5: items: Stripe.SubscriptionScheduleUpdateParams.Phase.Item[], 20: a: Stripe.SubscriptionScheduleUpdateParams.Phase.Item[], 21: b: Stripe.SubscriptionScheduleUpdateParams.Phase.Item[], 34:const hasNoItems = (phase: Stripe.SubscriptionScheduleUpdateParams.Phase) => { 36: (phase.items as Stripe.SubscriptionScheduleUpdateParams.Phase.Item[]) || []; 42: phases: Stripe.SubscriptionScheduleUpdateParams.Phase[], 43:): Stripe.SubscriptionScheduleUpdateParams.Phase[] => { 46: const result: Stripe.SubscriptionScheduleUpdateParams.Phase[] = []; 85: phases: Stripe.SubscriptionScheduleUpdateParams.Phase[], 86:): Stripe.SubscriptionScheduleUpdateParams.Phase[] => { 95: const merged: Stripe.SubscriptionScheduleUpdateParams.Phase[] = []; 101: (current.items as Stripe.SubscriptionScheduleUpdateParams.Phase.Item[]) || 103: (next.items as Stripe.SubscriptionScheduleUpdateParams.Phase.Item[]) || server/src/internal/customers/attach/mergeUtils/paramsToSubItems.ts 8:import type Stripe from "stripe"; 9:import { getStripeSubItems2 } from "@/external/stripe/stripeSubUtils/getStripeSubItems.js"; 11: findStripeItemForPrice, 13:} from "@/external/stripe/stripeSubUtils/stripeSubItemUtils.js"; 103: sub?: Stripe.Subscription; 113: : await getStripeSubItems2({ 145: const existingSubItem = findStripeItemForPrice({ 147: stripeItems: curSubItems, 148: stripeProdId: cusProduct.product.processor?.id, 149: }) as Stripe.SubscriptionItem | undefined; 177: subItem: existingSubItem as Stripe.SubscriptionItem, server/src/internal/customers/attach/attachUtils/handleAttachErrors.ts 153: "This customer is billed outside of Stripe, please use the origin platform to manage their billing.", 158: "This customer is billed outside of Stripe, please use the origin platform to manage their billing.", 170: (cp) => cusProductToProcessorType(cp) !== ProcessorType.Stripe, 175: "This customer is billed outside of Stripe, please use the origin platform to manage their billing.", server/src/internal/customers/attach/mergeUtils/paramsToScheduleItems.ts 7:import type Stripe from "stripe"; 8:import { getStripeSubItems2 } from "@/external/stripe/stripeSubUtils/getStripeSubItems.js"; 12:} from "@/external/stripe/stripeSubUtils/stripeSubItemUtils.js"; 34: curScheduleItems: Stripe.SubscriptionSchedule.Phase.Item[]; 35: updateScheduleItems: Stripe.SubscriptionScheduleUpdateParams.Phase.Item[]; 52: stripeProdId: cusProduct.product.processor?.id, 62: (existingScheduleItem?.price as Stripe.Price)?.id, 98: (si) => si.price === (existingScheduleItem.price as Stripe.Price)?.id, 104: removePriceIds.push((existingScheduleItem.price as Stripe.Price).id); 119: (si) => si.price === (existingScheduleItem.price as Stripe.Price)?.id, 148: items: Stripe.SubscriptionScheduleUpdateParams.Phase.Item[]; 157: return p.config.stripe_price_id === item.price; 188: baseCurScheduleItems: Stripe.SubscriptionSchedule.Phase.Item[]; 192:}): Promise => { 193: let newScheduleItems: Stripe.SubscriptionScheduleUpdateParams.Phase.Item[] = 241: sub?: Stripe.Subscription; 242: schedule?: Stripe.SubscriptionSchedule; 248: const itemSet = await getStripeSubItems2({ 296: price: (item.price as Stripe.Price).id, 336: .items as Stripe.SubscriptionSchedule.Phase.Item[]; server/src/internal/customers/attach/mergeUtils/mergeUtils.ts 8:import type Stripe from "stripe"; 29: sub: Stripe.Subscription; server/src/internal/customers/attach/attachUtils/getContUseItems/priceToContUseItem.ts 9:import type Stripe from "stripe"; 10:import { subToPeriodStartEnd } from "@/external/stripe/stripeSubUtils/convertSubUtils.js"; 11:import { findStripeItemForPrice } from "@/external/stripe/stripeSubUtils/stripeSubItemUtils.js"; 37: sub: Stripe.Subscription | undefined; 53: const subItem = findStripeItemForPrice({ 55: stripeItems: sub?.items.data || [], 59: start = (subItem as Stripe.SubscriptionItem).current_period_start; 60: end = (subItem as Stripe.SubscriptionItem).current_period_end; server/src/internal/customers/attach/mergeUtils/mergeNewSubItems.ts 3:import Stripe from "stripe"; 10: curSubItems: Stripe.SubscriptionItem[]; 50: curScheduleItems: Stripe.SubscriptionSchedule.Phase.Item[]; 54: price: (si.price as Stripe.Price).id, 79: // (osi) => (osi.price as Stripe.Price)?.id === si.price server/src/internal/customers/attach/attachUtils/getContUseItems/getContUseInvoiceItems.ts 12:import type Stripe from "stripe"; 126: sub?: Stripe.Subscription; server/src/internal/customers/attach/handleAttachPreview/getUpgradeProductPreview.ts 17:import type Stripe from "stripe"; 21:import { freeTrialToStripeTimestamp } from "@/internal/products/free-trials/freeTrialUtils.js"; 45: sub?: Stripe.Subscription; 63: freeTrialToStripeTimestamp({ server/src/internal/customers/attach/attachUtils/getContUseItems/createContUseInvoiceItems.ts 8: stripeToAtmnAmount, 10:import type Stripe from "stripe"; 11:import { subToPeriodStartEnd } from "@/external/stripe/stripeSubUtils/convertSubUtils.js"; 12:import { findPriceInStripeItems } from "@/external/stripe/stripeSubUtils/stripeSubItemUtils.js"; 13:import { subToAutumnInterval } from "@/external/stripe/utils.js"; 21: stripeCli, 26: sub: Stripe.Subscription; 27: stripeCli: Stripe; 37: // const upcomingLines = await stripeCli.invoices.listUpcomingLines({ 41: const pendingItems = await stripeCli.invoiceItems.list({ 52: const price = findPriceInStripeItems({ 60: const atmnAmount = stripeToAtmnAmount({ 69: await stripeCli.invoiceItems.del(item.id); 83: sub: Stripe.Subscription; 88: const { stripeCli, customer, org } = attachParams; 102: stripeCli, 139: await stripeCli.invoiceItems.create({ server/src/internal/customers/attach/handleAttachPreview/getNewProductPreview.ts 10:import { freeTrialToStripeTimestamp } from "@/internal/products/free-trials/freeTrialUtils.js"; 50: freeTrialToStripeTimestamp({ server/src/internal/customers/attach/attachUtils/getAttachFunction.ts 125: const { stripeCli } = attachParams; 196: await stripeCli.subscriptions.cancel(subId, { server/src/internal/customers/attach/handleAttachPreview/getMultiAttachPreview.ts 9:import type Stripe from "stripe"; 10:import { getEarliestPeriodEnd } from "@/external/stripe/stripeSubUtils/convertSubUtils.js"; 11:import { freeTrialToStripeTimestamp } from "@/internal/products/free-trials/freeTrialUtils.js"; 60: stripeItems: subItems, 64: latestInvoice: sub?.latest_invoice as Stripe.Invoice, 65: subDiscounts: (sub?.discounts ?? []) as Stripe.Discount[], 103: subDiscounts: (sub?.discounts ?? []) as Stripe.Discount[], 117: subDiscounts: (sub?.discounts ?? []) as Stripe.Discount[], 138: ? freeTrialToStripeTimestamp({ freeTrial, now: attachParams.now })! * 1000 server/src/internal/customers/attach/handleAttachPreview/getDowngradeProductPreview.ts 6:import { getLatestPeriodEnd } from "@/external/stripe/stripeSubUtils/convertSubUtils.js"; server/src/internal/customers/attach/attachUtils/convertAttachParams.ts 6:import type Stripe from "stripe"; 102: stripeCli, 105: stripeCli: Stripe; 107: const sub = await stripeCli.subscriptions.retrieve(subId, { 123: const { stripeCli } = attachParams; 191: const sub = await stripeCli.subscriptions.retrieve(subId, { 213: const { stripeCli } = attachParams; 258: const schedules = await stripeCli.subscriptionSchedules.list({ 283: const { stripeCli } = attachParams; 292: const sub = await stripeCli.subscriptions.retrieve(subIds[0], { 310: const { stripeCli } = attachParams; 318: const schedule = await stripeCli.subscriptionSchedules.retrieve( 329: return schedule as Stripe.SubscriptionSchedule; server/src/internal/customers/attach/attachUtils/attachUtils.ts 2:import type Stripe from "stripe"; 3:import { subItemInCusProduct } from "@/external/stripe/stripeSubUtils/stripeSubItemUtils.js"; 4:import { subToAutumnInterval } from "@/external/stripe/utils.js"; 18: stripeSubs, 21: stripeSubs: Stripe.Subscription[]; 25: const prevInterval = subToAutumnInterval(stripeSubs[0]); 37: sub?: Stripe.Subscription | null; server/src/internal/customers/attach/attachPreviewUtils/priceToUnusedPreviewItem.ts 14:import type Stripe from "stripe"; 15:import { findStripeItemForPrice } from "@/external/stripe/stripeSubUtils/stripeSubItemUtils.js"; 32: invoiceItem?: Stripe.InvoiceLineItem; 33: subDiscounts?: Stripe.Discount[]; 36: const discountsApplied: Stripe.Discount[] = []; 50: stripeItems, 60: stripeItems: Stripe.SubscriptionItem[]; 64: subDiscounts?: Stripe.Discount[]; 65: latestInvoice?: Stripe.Invoice; 71: const subItem = findStripeItemForPrice({ 73: stripeItems, 74: stripeProdId: cusProduct?.product.processor?.id, 75: }) as Stripe.SubscriptionItem | undefined; 77: const invoiceItem = findStripeItemForPrice({ 80: stripeProdId: cusProduct?.product.processor?.id, 81: }) as Stripe.InvoiceLineItem | undefined; server/src/internal/customers/attach/attachPreviewUtils/priceToNewPreviewItem.ts 9:import type Stripe from "stripe"; 22: getAmountAfterStripeDiscounts, 49: subDiscounts?: Stripe.Discount[]; 98: amount = getAmountAfterStripeDiscounts({ 102: stripeDiscounts: subDiscounts ?? [], server/src/internal/customers/attach/attachUtils/attachParams/processAttachBody.ts 2:import type Stripe from "stripe"; 3:import { createStripeCli } from "@/external/connect/createStripeCli.js"; 9:import { getStripeCusData } from "./attachParamsUtils/getStripeCusData.js"; 14: stripeCli, 18: stripeCli: Stripe; 56: // const stripeCoupon = await stripeCli.coupons.retrieve(reward.id); 60: // stripeCoupon, 74: const stripeCli = createStripeCli({ org, env }); 81: const [stripeCusData, rewardData] = await Promise.all([ 82: getStripeCusData({ 83: stripeCli, 93: stripeCli, 97: const { stripeCus, paymentMethod, now } = stripeCusData; 125: stripeVars: { 126: stripeCli, 127: stripeCus, server/src/internal/customers/attach/attachUtils/attachParams/getAttachParams.ts 23: stripeVars, 33: const { stripeCli, stripeCus, paymentMethod, now } = stripeVars; 40: stripeCli, 41: stripeCus, server/src/internal/customers/attach/attachUtils/attachParams/convertToParams.ts 14:import type Stripe from "stripe"; 15:import { createStripeCli } from "@/external/connect/createStripeCli.js"; 26: stripeCli, 33: stripeCli: Stripe; 34: paymentMethod?: Stripe.PaymentMethod | null; 42: stripeCli, 96: stripeCli, 103: stripeCli: Stripe; 119: stripeCli, 194: stripeCli: createStripeCli({ org, env }), server/src/internal/customers/attach/attachFunctions/upgradeFlow/upgradeFlowUtils.ts 1:import Stripe from "stripe"; 7: sub: Stripe.Subscription; 8: newSubItems: Stripe.SubscriptionUpdateParams.Item[]; server/src/internal/customers/attach/attachUtils/attachParams/checkToAttachParams.ts 2:import { createStripeCli } from "@/external/connect/createStripeCli.js"; 6:import { getStripeCusData } from "./attachParamsUtils/getStripeCusData.js"; 26: const stripeCli = createStripeCli({ org, env }); 27: const stripeCusData = await getStripeCusData({ 28: stripeCli, 34: allowNoStripe: true, 46: const { stripeCus, paymentMethod, now } = stripeCusData; 49: stripeCli, 50: stripeCus, server/src/internal/customers/attach/attachFunctions/upgradeFlow/updateStripeSub2.ts 8:import type Stripe from "stripe"; 9:import { sanitizeSubItems } from "@/external/stripe/stripeSubUtils/getStripeSubItems.js"; 12:import { freeTrialToStripeTimestamp } from "@/internal/products/free-trials/freeTrialUtils.js"; 16:import { createProrationInvoice } from "../../../../../external/stripe/stripeSubUtils/updateStripeSub/createProrationinvoice.js"; 17:import { isStripeSubscriptionCanceled } from "../../../../../external/stripe/stripeSubUtils.js"; 27:export const updateStripeSub2 = async ({ 39: curSub: Stripe.Subscription; 46: const { stripeCli, paymentMethod } = attachParams; 57: curSub = await stripeCli.subscriptions.migrate(curSub.id, { 66: ? freeTrialToStripeTimestamp({ 74: const updatedSub = await stripeCli.subscriptions.update(curSub.id, { 96: cancel_at_period_end: isStripeSubscriptionCanceled({ sub: curSub }) 101: let latestInvoice = updatedSub.latest_invoice as Stripe.Invoice | null; 103: await SubService.updateFromStripe({ db, stripeSub: updatedSub }); 115: // latestInvoice: updatedSub.latest_invoice as Stripe.Invoice, 158: res.invoice || (updatedSub.latest_invoice as Stripe.Invoice); server/src/internal/customers/attach/attachFunctions/upgradeFlow/handleUpgradeFlowSchedule.ts 2:import type Stripe from "stripe"; 27: schedule: Stripe.SubscriptionSchedule; 28: curSub: Stripe.Subscription; 40: const { stripeCli, customer, prices } = attachParams; 75: await stripeCli.subscriptionSchedules.release(schedule!.id); 76: await CusProductService.updateByStripeScheduledId({ 78: stripeScheduledId: schedule!.id, 96: await stripeCli.subscriptions.update(curSub.id, { server/src/internal/customers/attach/attachUtils/attachParams/attachParamsUtils/getStripeCusData.ts 2:import type Stripe from "stripe"; 5: createStripeCusIfNotExists, 7:} from "@/external/stripe/stripeCusUtils.js"; 9:export const getStripeCusData = async ({ 10: stripeCli, 16: allowNoStripe, 18: stripeCli: Stripe; 24: allowNoStripe?: boolean; 26: if (allowNoStripe && !customer.processor?.id) { 27: return { stripeCus: undefined, paymentMethod: null, now: undefined }; 30: const stripeCus = (await createStripeCusIfNotExists({ 36: })) as Stripe.Customer; 38: const testClock = stripeCus.test_clock as Stripe.TestHelpers.TestClock | null; 43: let paymentMethod = stripeCus.invoice_settings 44: ?.default_payment_method as Stripe.PaymentMethod | null; 48: stripeCli, 49: stripeId: stripeCus.id, 55: return { stripeCus, paymentMethod, now }; server/src/internal/customers/attach/attachFunctions/upgradeFlow/handleUpgradeFlow.ts 12:import type Stripe from "stripe"; 13:import { getEarliestPeriodEnd } from "@/external/stripe/stripeSubUtils/convertSubUtils.js"; 14:import { getStripeSubItems2 } from "@/external/stripe/stripeSubUtils/getStripeSubItems.js"; 15:import { isStripeSubscriptionCanceled } from "@/external/stripe/stripeSubUtils.js"; 37:import { updateStripeSub2 } from "./updateStripeSub2.js"; 62: let latestInvoice: Stripe.Invoice | undefined; 64: const itemSet = await getStripeSubItems2({ 119: const { stripeCli } = attachParams; 121: await stripeCli.subscriptions.cancel(curSub.id, { 132: const res = await updateStripeSub2({ 143: // console.log("Sub is canceled!", isStripeSubscriptionCanceled({ sub: res.updatedSub })); 144: // if (isStripeSubscriptionCanceled({ sub: res.updatedSub })) { 145: // await attachParams.stripeCli.subscriptions.update(res.updatedSub.id, { 156: stripeInvoice: res.latestInvoice, 222: if (sub && isStripeSubscriptionCanceled({ sub })) { server/src/internal/customers/attach/attachRouter.ts 8:import { createStripeCli } from "@/external/connect/createStripeCli.js"; 9:import { createStripePriceIFNotExist } from "@/external/stripe/createStripePrice/createStripePrice.js"; 11: createStripeCusIfNotExists, 13:} from "@/external/stripe/stripeCusUtils.js"; 24: checkStripeProductExists, 126:export const checkStripeConnections = async ({ 137: const { org, customer, products, stripeCus, stripeCli } = attachParams; 154: stripeCus && 155: stripeCli.customers.update(stripeCus.id, { 165: createStripeCusIfNotExists({ 177: checkStripeProductExists({ 188: await createStripePrices({ 196:export const createStripePrices = async ({ 207: const { prices, entitlements, products, org, stripeCli } = attachParams; 216: createStripePriceIFNotExist({ 218: stripeCli, 239: stripeCli: createStripeCli({ 243: stripeId: attachParams.customer.processor?.id, server/src/internal/customers/attach/attachFunctions/upgradeDiffIntFlow/upgradeUtils.ts 1:import { subToPeriodStartEnd } from "@/external/stripe/stripeSubUtils/convertSubUtils.js"; 2:import Stripe from "stripe"; 4:export const getNextCycle = (stripeSubs: Stripe.Subscription[]) => { 5: const { end } = subToPeriodStartEnd({ sub: stripeSubs[0] }); server/src/internal/customers/attach/attachFunctions/upgradeDiffIntFlow/createUsageInvoiceItems.ts 11:import type Stripe from "stripe"; 13:import { subToAutumnInterval } from "@/external/stripe/utils.js"; 30: // stripeSubs, 39: // stripeSubs: Stripe.Subscription[]; 40: sub: Stripe.Subscription; 44: const { stripeCli, org } = attachParams; 98: product: config.stripe_product_id!, 121: // stripeSubs, 131: // stripeSubs: Stripe.Subscription[]; 132: sub: Stripe.Subscription; 138: const { stripeCli } = attachParams; 144: // stripeSubs, 160: await stripeCli.invoiceItems.create({ server/src/internal/customers/attach/attachFunctions/multiAttach/handleMultiAttachFlow.ts 11:import type Stripe from "stripe"; 12:import { getLatestPeriodEnd } from "@/external/stripe/stripeSubUtils/convertSubUtils.js"; 29:import { createStripeSub2 } from "../addProductFlow/createStripeSub2.js"; 31:import { updateStripeSub2 } from "../upgradeFlow/updateStripeSub2.js"; 52: const { stripeCli } = attachParams; 58: let latestInvoice: Stripe.Invoice | null = null; 79: const newSub = await createStripeSub2({ 83: stripeCli, 90: invoices: [newSub.latest_invoice as Stripe.Invoice], 97: latestInvoice = newSub.latest_invoice as Stripe.Invoice; 103: const updateResult = await updateStripeSub2({ 155: stripeInvoice: latestInvoice, server/src/internal/customers/attach/attachFunctions/upgradeDiffIntFlow/createUsageInvoice.ts 2:import type Stripe from "stripe"; 4:import { payForInvoice } from "@/external/stripe/stripeInvoiceUtils.js"; 22: sub: Stripe.Subscription; 25: const { stripeCli, paymentMethod } = attachParams; 27: const invoice = await stripeCli.invoices.create({ 41: await stripeCli.invoices.finalizeInvoice(invoice.id!, { 50: stripeCli, server/src/internal/customers/attach/attachFunctions/multiAttach/getAddAndRemoveProducts.ts 9:import { getStripeSubItems2 } from "@/external/stripe/stripeSubUtils/getStripeSubItems.js"; 81: const newItemSet = await getStripeSubItems2({ server/src/internal/customers/attach/attachFunctions/handleRenewProduct.ts 9:import type Stripe from "stripe"; 10:import { getLatestPeriodEnd } from "@/external/stripe/stripeSubUtils/convertSubUtils.js"; 11:import { subItemInCusProduct } from "@/external/stripe/stripeSubUtils/stripeSubItemUtils.js"; 42: const { stripeCli } = attachParams; 64: stripeCli, 77: stripeCli, 89: await stripeCli.subscriptionSchedules.release(schedule.id); 91: await CusProductService.updateByStripeScheduledId({ 93: stripeScheduledId: schedule.id, 108: await stripeCli.subscriptions.update(curSubId, { 143: })) as Stripe.Subscription; 167: await stripeCli.subscriptionSchedules.release(schedule.id); 169: await CusProductService.updateByStripeScheduledId({ 171: stripeScheduledId: schedule.id, 194: stripeCli, 195: })) as Stripe.Subscription; server/src/internal/customers/attach/attachFunctions/updateQuantityFlow/updateQuantityFlow.ts 6:import type Stripe from "stripe"; 8: getStripeSubs, 9: isStripeSubscriptionCanceled, 10:} from "@/external/stripe/stripeSubUtils.js"; 33: const stripeCli = attachParams.stripeCli; 35: const stripeSubs = await getStripeSubs({ 36: stripeCli: stripeCli, 40: const invoices: Stripe.Invoice[] = []; 48: stripeSubs, 58: for (const stripeSub of stripeSubs) { 59: if (isStripeSubscriptionCanceled({ sub: stripeSub })) { 60: await stripeCli.subscriptions.update(stripeSub.id, { server/src/internal/customers/attach/attachFunctions/updateQuantityFlow/updateFeatureQuantity.ts 7:import type { Stripe } from "stripe"; 8:import { findStripeItemForPrice } from "@/external/stripe/stripeSubUtils/stripeSubItemUtils.js"; 21: stripeSubs, 29: stripeSubs: Stripe.Subscription[]; 33: const subToUpdate = stripeSubs?.[0]; 50: const subItem = findStripeItemForPrice({ 52: stripeItems: subToUpdate.items.data, 53: }) as Stripe.SubscriptionItem; 61: stripeSub: subToUpdate, 72: stripeSubs, 76: stripeSub: subToUpdate, server/src/internal/customers/attach/attachFunctions/addProductFlow/handlePaidProduct.ts 12:import type Stripe from "stripe"; 13:import { getEarliestPeriodEnd } from "@/external/stripe/stripeSubUtils/convertSubUtils.js"; 14:import { getStripeSubItems2 } from "@/external/stripe/stripeSubUtils/getStripeSubItems.js"; 15:import { isStripeSubscriptionCanceled } from "@/external/stripe/stripeSubUtils.js"; 34:import { updateStripeSub2 } from "../upgradeFlow/updateStripeSub2.js"; 35:import { createStripeSub2 } from "./createStripeSub2.js"; 57: stripeCli, 64: const itemSet = await getStripeSubItems2({ 69: const subscriptions: Stripe.Subscription[] = []; 80: let sub: Stripe.Subscription | null = null; 81: let schedule: Stripe.SubscriptionSchedule | null | undefined = null; 82: let invoice: Stripe.Invoice | undefined; 105: const { updatedSub, latestInvoice, url } = await updateStripeSub2({ 120: stripeInvoice: latestInvoice, 134: if (isStripeSubscriptionCanceled({ sub: mergeSub })) { 193: sub = await createStripeSub2({ 195: stripeCli, 206: stripeInvoice: sub.latest_invoice as Stripe.Invoice, 212: const subInvoice: Stripe.Invoice | undefined = 213: sub.latest_invoice as Stripe.Invoice; 228: stripeInvoiceId: subInvoice.id as string, 232: await stripeCli.invoices.update(subInvoice.id, { 251: invoice: subscriptions?.[0]?.latest_invoice as Stripe.Invoice, 252: stripeSub: subscriptions?.[0], server/src/internal/customers/attach/attachFunctions/updateQuantityFlow/handleQuantityUpgrade.ts 14:import type { Stripe } from "stripe"; 15:import { subToPeriodStartEnd } from "@/external/stripe/stripeSubUtils/convertSubUtils.js"; 20:import { constructStripeInvoiceItem } from "@/internal/invoices/invoiceItemUtils/invoiceItemUtils.js"; 35: stripeSubs, 40: stripeSub, 47: stripeSubs: Stripe.Subscription[]; 51: stripeSub: Stripe.Subscription; 52: subItem: Stripe.SubscriptionItem; 56: const { stripeCli, now, paymentMethod } = attachParams; 79: if (prorate && stripeSub?.status !== "trialing") { 80: const { start, end } = subToPeriodStartEnd({ sub: stripeSub }); 107: const invoiceItem = constructStripeInvoiceItem({ 120: stripeSubId: stripeSub.id, 121: stripeCustomerId: stripeSub.customer as string, 130: await stripeCli.invoiceItems.create(invoiceItem); 134: stripeCli, 135: stripeCusId: stripeSub.customer as string, 136: stripeSubId: stripeSub.id, 144: stripeInvoice: finalInvoice, 149: await InvoiceService.createInvoiceFromStripe({ 151: stripeInvoice: finalInvoice, 161: logger.error(`Failed to create invoice from stripe: ${error}`); 169: if (!cusPrice.price.config.stripe_price_id) { 171: "Trying to add new sub item for upgrade quantity flow, but no Stripe price ID found", 175: await stripeCli.subscriptionItems.create({ 176: subscription: stripeSub.id, 177: price: cusPrice.price.config.stripe_price_id, 182: await stripeCli.subscriptionItems.update(subItem.id, { server/src/internal/customers/attach/attachFunctions/addProductFlow/handleOneOffFunction.ts 11:import { payForInvoice } from "@/external/stripe/stripeInvoiceUtils.js"; 42: stripeCli, 74: price: price.config.stripe_price_id, 103: product: price.config?.stripe_product_id || product?.processor?.id, 135: let stripeInvoice = await stripeCli.invoices.create({ 147: await stripeCli.invoiceItems.create({ 150: invoice: stripeInvoice.id, 155: if (stripeInvoice.status === "draft" && config.finalizeInvoice) { 156: stripeInvoice = await stripeCli.invoices.finalizeInvoice( 157: stripeInvoice.id!, 164: invoiceId: stripeInvoice.id, 169: invoice: stripeInvoice, 173: logger.info("3. Creating invoice from stripe"); 177: invoiceId: stripeInvoice.id, 183: stripeInvoice = await stripeCli.invoices.finalizeInvoice(stripeInvoice.id!); 191: stripeCli, 192: invoiceId: stripeInvoice.id!, 200: stripeInvoice = paidInvoice; 205: if (stripeInvoice && stripeInvoice.status === "open") { 207: `[one off function] invoice action required: ${stripeInvoice.id}`, 213: stripeInvoiceId: stripeInvoice.id as string, 217: await stripeCli.invoices.update(stripeInvoice.id, { 224: checkout_url: stripeInvoice.hosted_invoice_url, 259: invoice: invoiceOnly ? stripeInvoice : undefined, server/src/internal/customers/attach/attachFunctions/updateQuantityFlow/handleQuantityDowngrade.ts 14:import type { Stripe } from "stripe"; 15:import { subToPeriodStartEnd } from "@/external/stripe/stripeSubUtils/convertSubUtils.js"; 21:import { constructStripeInvoiceItem } from "@/internal/invoices/invoiceItemUtils/invoiceItemUtils.js"; 36: stripeSub, 45: stripeSub: Stripe.Subscription; 48: subItem: Stripe.SubscriptionItem; 51: const { stripeCli, paymentMethod } = attachParams; 79: const { start, end } = subToPeriodStartEnd({ sub: stripeSub }); 105: const invoiceItem = constructStripeInvoiceItem({ 118: stripeSubId: stripeSub.id, 119: stripeCustomerId: stripeSub.customer as string, 130: await stripeCli.invoiceItems.create(invoiceItem); 134: stripeCli, 135: stripeCusId: stripeSub.customer as string, 136: stripeSubId: stripeSub.id, 146: stripeInvoice: finalInvoice, 151: await InvoiceService.createInvoiceFromStripe({ 153: stripeInvoice: finalInvoice, 163: logger.error(`Failed to create invoice from stripe: ${error}`); 168: await stripeCli.subscriptionItems.update(subItem.id, { 170: // proration_behavior: stripeProration, server/src/internal/customers/attach/attachFunctions/addProductFlow/handleAddProduct.ts 7:import { subToPeriodStartEnd } from "@/external/stripe/stripeSubUtils/convertSubUtils.js"; server/src/internal/customers/attach/attachFunctions/scheduleFlow/handleScheduleFlow2.ts 8:import { getLatestPeriodEnd } from "@/external/stripe/stripeSubUtils/convertSubUtils.js"; 9:import { subItemInCusProduct } from "@/external/stripe/stripeSubUtils/stripeSubItemUtils.js"; 43: const { stripeCli } = attachParams; 103: await stripeCli.subscriptionSchedules.release(schedule.id); 104: await CusProductService.updateByStripeScheduledId({ 106: stripeScheduledId: schedule.id, 171: await stripeCli.subscriptions.update(curSub.id, { server/src/internal/customers/attach/attachFunctions/addProductFlow/getMergeCusProduct.ts 8:import { getStripeSubs } from "@/external/stripe/stripeSubUtils.js"; 22: const { stripeCli, cusProducts, freeTrial } = attachParams; 33: stripeCli, 35: // let mergeSubs = await getStripeSubs({ 36: // stripeCli, server/src/internal/customers/attach/attachFunctions/scheduleFlow/createSubSchedule.ts 1:import type Stripe from "stripe"; 3:import { sanitizeSubItems } from "@/external/stripe/stripeSubUtils/getStripeSubItems.js"; 22: const { stripeCli } = attachParams; 36: const newSubscriptionSchedule = await stripeCli.subscriptionSchedules.create({ 45: invoiceItems as Stripe.SubscriptionScheduleCreateParams.Phase.AddInvoiceItem[], 54: stripe_id: null, 55: stripe_schedule_id: newSubscriptionSchedule.id, server/src/internal/customers/attach/attachFunctions/addProductFlow/createStripeSub2.ts 3:import type Stripe from "stripe"; 5:import { getCusPaymentMethod } from "@/external/stripe/stripeCusUtils.js"; 9:} from "@/external/stripe/stripeSubUtils/convertSubUtils.js"; 10:import { sanitizeSubItems } from "@/external/stripe/stripeSubUtils/getStripeSubItems.js"; 13:import { freeTrialToStripeTimestamp } from "@/internal/products/free-trials/freeTrialUtils.js"; 19:export const createStripeSub2 = async ({ 21: stripeCli, 29: stripeCli: Stripe; 40: stripeCli, 41: stripeId: customer.processor.id, 62: const subscription = await stripeCli.subscriptions.create({ 105: trial_end: freeTrialToStripeTimestamp({ freeTrial, now }), 109: const latestInvoice = subscription.latest_invoice as Stripe.Invoice; 125: await stripeCli.invoices.update(latestInvoice.id!, { 129: logger.error("CREATE STRIPE SUB: error adding invoice memo", { error }); 140: subscription.latest_invoice = await stripeCli.invoices.finalizeInvoice( 141: (subscription.latest_invoice as Stripe.Invoice).id!, 153: stripe_id: subscription.id, 154: stripe_schedule_id: subscription.schedule as string, 166: console.log("Warning: Failed to create stripe subscription"); 173: code: ErrCode.CreateStripeSubscriptionFailed, 174: message: `Create stripe subscription failed ${ server/src/internal/customers/add-product/handleCreateInvoiceCheckout.ts 28: const { stripeCli } = attachParams; 47: const { invoice, stripeSub, anchorToUnix } = invoiceResult; 54: subId: stripeSub?.id, 58: stripeInvoiceId: invoice?.id, 62: await stripeCli.invoices.update(invoice.id, { server/src/internal/customers/add-product/handleCreateCheckout.ts 8:import type Stripe from "stripe"; 9:import { createStripeCli } from "@/external/connect/createStripeCli.js"; 10:import { getStripeSubItems } from "@/external/stripe/stripeSubUtils/getStripeSubItems.js"; 13:import { freeTrialToStripeTimestamp } from "@/internal/products/free-trials/freeTrialUtils.js"; 37: const stripeCli = createStripeCli({ 43: const itemSets = await getStripeSubItems({ 83: | Stripe.Checkout.SessionCreateParams.SubscriptionData 88: ? freeTrialToStripeTimestamp({ freeTrial }) 103: | Partial 118: let checkout: Stripe.Checkout.Session | undefined; 124: let sessionParams: Stripe.Checkout.SessionCreateParams = { 166: checkout = await stripeCli.checkout.sessions.create(sessionParams); 173: checkout = await stripeCli.checkout.sessions.create({ server/src/internal/customers/add-product/createFullCusProduct.ts 24:import { freeTrialToStripeTimestamp } from "@/internal/products/free-trials/freeTrialUtils.js"; 84: processor = ProcessorType.Stripe, 113: trialEnds = freeTrialToStripeTimestamp({ freeTrial })! * 1000; 132: type: processor ?? ProcessorType.Stripe, 293: processorType = ProcessorType.Stripe, 448: processor: processorType ?? ProcessorType.Stripe,