Something went wrong. Try again.
[READ-ONLY] Mirror of https://github.com/openstatusHQ/openstatus. 🫖 Status page with uptime monitoring & API monitoring as code 🫖 openstatus.dev
bun drizzle-orm monitoring monitoring-as-code nextjs observability on-call open-source shadcn-ui status-page statuspage synthetic-monitoring tinybird turso uptime uptime-checker uptime-monitor
Something went wrong. Try again.
TypeScript
at incident-api
123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420421422423424425426427428429430431432433434435436437438439440441442443444445446447448449450451452453454455456457458459460461462463464465466467468469470471472473474475476477478479480481482483484485486487488489490491492493494495496497498499500501502503504505506507508509510511512513514515516517518519520521522523524525526527528529530531532533534535536537538539540541542543544545546547548549550551552553554555556557558559560561562563564565566567568569570571572573574575576577578579580import { and, db, desc, eq } from "@openstatus/db";import { auditLog, selectUserSchema, selectWorkspaceSchema, user, workspace,} from "@openstatus/db/src/schema";import { addUserToWorkspace, createTestWorkspace, createWorkspace,} from "@openstatus/db/src/test/factories";import { delivery, resend } from "@openstatus/emails/src/send";import { expect } from "@std/expect";import { afterEach, beforeEach, describe, test } from "@std/testing/bdd";import { assertSpyCalls, type Stub, stub } from "@std/testing/mock";import type Stripe from "stripe";
import { edgeRouter } from "../../edge";import { createInnerTRPCContext } from "../../trpc";import { stripeRouter } from "./index";import { cancelSubscription, stripe } from "./shared";import { FEATURES, PLANS } from "./utils";import { webhookRouter } from "./webhook";
const DAY = 86_400;const now = () => Math.floor(Date.now() / 1000);const STARTER_PRICE = PLANS.find((p) => p.plan === "starter")?.price.monthly.priceIds.test ?? "";const TEAM_PRICE = PLANS.find((p) => p.plan === "team")?.price.monthly.priceIds.test ?? "";const WHITE_LABEL_PRICE = FEATURES.find((f) => f.feature === "white-label")?.price.monthly.priceIds .test ?? "";
function subscription( customer: string, overrides: Partial<Stripe.Subscription> = {}, price = STARTER_PRICE,) { const periodEnd = now() + 14 * DAY; return { id: `sub_${crypto.randomUUID()}`, customer, status: "trialing", created: now() - DAY, trial_end: periodEnd, cancel_at_period_end: false, default_payment_method: null, metadata: {}, currency: "usd", items: { data: [ { id: "si_plan", price: { id: price, recurring: { interval: "month" } }, quantity: 1, current_period_end: periodEnd, }, ], }, ...overrides, } as Stripe.Subscription;}
async function seedTrial() { const stripeId = `cus_${crypto.randomUUID()}`; const trialEndsAt = new Date((now() + 14 * DAY) * 1000); const fixture = await createTestWorkspace({ plan: "starter", stripeId, limits: "{}", trialEndsAt, }); const ws = selectWorkspaceSchema.parse(fixture.workspace); return { ...fixture, ws, stripeId, trialEndsAt };}
function customerWith(defaultPaymentMethod: string | null) { const invoiceSettings: Partial<Stripe.Customer.InvoiceSettings> = { default_payment_method: defaultPaymentMethod, }; const partial: Partial<Stripe.Customer> = { invoice_settings: invoiceSettings as Stripe.Customer.InvoiceSettings, }; return partial as Stripe.Customer;}
async function readWorkspace(id: number) { return db.select().from(workspace).where(eq(workspace.id, id)).get();}
async function lastPlanAuditReason(workspaceId: number) { const row = await db .select({ metadata: auditLog.metadata }) .from(auditLog) .where( and( eq(auditLog.workspaceId, workspaceId), eq(auditLog.entityType, "workspace"), eq(auditLog.action, "workspace.update"), ), ) .orderBy(desc(auditLog.id)) .get(); return (row?.metadata as { reason?: string } | null)?.reason;}
function asCaller(fixture: Awaited<ReturnType<typeof seedTrial>>) { return createInnerTRPCContext({ session: { user: { id: String(fixture.user.id) } }, workspace: fixture.ws, user: selectUserSchema.parse(fixture.user), });}
describe("trial lifecycle", () => { let live: Stripe.Subscription[]; let customer: Stripe.Customer; let stubs: Stub[]; let updateSubscription: Stub; let cancelStripeSubscription: Stub; let createSession: Stub;
beforeEach(() => { live = []; customer = customerWith(null); updateSubscription = stub( stripe.subscriptions, "update", (id: string, params?: Stripe.SubscriptionUpdateParams) => { const base = live.find((s) => s.id === id) ?? subscription("cus_x"); const items = params?.items?.[0]?.price ? { ...base.items, data: [ { ...base.items.data[0], price: { id: params.items[0].price }, } as Stripe.SubscriptionItem, ], } : base.items; return Promise.resolve({ ...base, items, status: params?.trial_end === "now" ? "active" : base.status, trial_end: params?.trial_end === "now" ? null : base.trial_end, } as Stripe.Response<Stripe.Subscription>); }, ); cancelStripeSubscription = stub(stripe.subscriptions, "cancel", () => Promise.resolve({} as Stripe.Response<Stripe.Subscription>), ); createSession = stub(stripe.checkout.sessions, "create", () => Promise.resolve({ url: "https://checkout.stripe.test/session", } as Stripe.Response<Stripe.Checkout.Session>), ); stubs = [ updateSubscription, cancelStripeSubscription, createSession, stub( stripe.subscriptions, "list", () => ({ autoPagingToArray: (_opts: { limit: number }) => Promise.resolve(live), }) as Stripe.ApiListPromise<Stripe.Subscription>, ), stub(stripe.customers, "retrieve", () => Promise.resolve(customer as Stripe.Response<Stripe.Customer>), ), ]; });
afterEach(() => { for (const s of stubs) s.restore(); });
function withCard() { customer = customerWith("pm_card"); }
describe("getCheckoutSession", () => { test("trialing without a card → regular checkout, no in-place swap", async () => { const s = await seedTrial(); live = [subscription(s.stripeId)];
const result = await stripeRouter .createCaller(asCaller(s)) .getCheckoutSession({ currency: "USD", workspaceSlug: s.ws.slug, plan: "team", });
expect(result?.type).toBe("checkout"); assertSpyCalls(updateSubscription, 0); expect(createSession.calls[0]?.args[0]).toMatchObject({ mode: "subscription", customer: s.stripeId, line_items: [{ price: TEAM_PRICE, quantity: 1 }], }); });
test("trialing without a card on Starter monthly → setup session", async () => { const s = await seedTrial(); const sub = subscription(s.stripeId); live = [sub];
const result = await stripeRouter .createCaller(asCaller(s)) .getCheckoutSession({ currency: "USD", workspaceSlug: s.ws.slug, plan: "starter", });
expect(result?.type).toBe("setup"); expect(createSession.calls[0]?.args[0]).toMatchObject({ mode: "setup", customer: s.stripeId, setup_intent_data: { metadata: { subscriptionId: sub.id } }, }); });
test("trialing with a card → plan swapped and the trial ended now", async () => { const s = await seedTrial(); withCard(); const sub = subscription(s.stripeId); live = [sub];
const result = await stripeRouter .createCaller(asCaller(s)) .getCheckoutSession({ currency: "USD", workspaceSlug: s.ws.slug, plan: "team", });
expect(result?.type).toBe("updated"); expect(updateSubscription.calls[0]?.args).toEqual([ sub.id, { items: [{ id: "si_plan", price: TEAM_PRICE }], proration_behavior: "create_prorations", cancel_at_period_end: false, trial_end: "now", payment_behavior: "error_if_incomplete", }, ]); const after = await readWorkspace(s.ws.id); expect(after?.plan).toBe("team"); expect(after?.trialEndsAt).toBeNull(); }); });
describe("addAddon", () => { test("trialing without a card → precondition failed", async () => { const s = await seedTrial(); live = [subscription(s.stripeId)];
await expect( stripeRouter.createCaller(asCaller(s)).addAddon({ workspaceSlug: s.ws.slug, feature: "white-label", value: true, }), ).rejects.toMatchObject({ code: "PRECONDITION_FAILED" }); assertSpyCalls(updateSubscription, 0); });
test("trialing with a card → trial ended before the addon is added", async () => { const s = await seedTrial(); withCard(); const sub = subscription(s.stripeId); live = [sub]; const planItem = sub.items.data[0]; const listItems = stub( stripe.subscriptionItems, "list", () => Promise.resolve({ data: planItem ? [planItem] : [], } as Stripe.Response< Stripe.ApiList<Stripe.SubscriptionItem> >) as Stripe.ApiListPromise<Stripe.SubscriptionItem>, ); const createItem = stub(stripe.subscriptionItems, "create", () => Promise.resolve({} as Stripe.Response<Stripe.SubscriptionItem>), ); stubs.push(listItems, createItem);
await stripeRouter.createCaller(asCaller(s)).addAddon({ workspaceSlug: s.ws.slug, feature: "white-label", value: true, });
expect(updateSubscription.calls[0]?.args).toEqual([ sub.id, { trial_end: "now", payment_behavior: "error_if_incomplete" }, ]); expect(createItem.calls[0]?.args[0]).toMatchObject({ price: WHITE_LABEL_PRICE, subscription: sub.id, }); const after = await readWorkspace(s.ws.id); expect(after?.trialEndsAt).toBeNull(); expect(JSON.parse(after?.limits ?? "{}")["white-label"]).toBe(true); });
test("a boolean on a quantity addon is rejected before Stripe is touched", async () => { const s = await seedTrial(); withCard(); live = [subscription(s.stripeId)]; const delItem = stub(stripe.subscriptionItems, "del", () => Promise.resolve({} as Stripe.Response<Stripe.DeletedSubscriptionItem>), ); stubs.push(delItem);
await expect( stripeRouter.createCaller(asCaller(s)).addAddon({ workspaceSlug: s.ws.slug, feature: "monitors", value: false, }), ).rejects.toMatchObject({ code: "BAD_REQUEST" }); assertSpyCalls(delItem, 0); assertSpyCalls(updateSubscription, 0); }); });
describe("cancelSubscription", () => { test("trialing → cancelled immediately", async () => { const sub = subscription("cus_cancel_trial"); live = [sub];
await cancelSubscription("cus_cancel_trial");
expect(cancelStripeSubscription.calls[0]?.args[0]).toBe(sub.id); assertSpyCalls(updateSubscription, 0); });
test("active → cancelled at period end", async () => { const sub = subscription("cus_cancel_active", { status: "active" }); live = [sub];
await cancelSubscription("cus_cancel_active");
assertSpyCalls(cancelStripeSubscription, 0); expect(updateSubscription.calls[0]?.args[1]).toMatchObject({ cancel_at_period_end: true, }); }); });
describe("deleteAccount", () => { test("a trial is cancelled and the account deleted", async () => { const s = await seedTrial(); const sub = subscription(s.stripeId); live = [sub];
await edgeRouter.createCaller(asCaller(s)).user.deleteAccount();
expect(cancelStripeSubscription.calls[0]?.args[0]).toBe(sub.id); const after = await readWorkspace(s.ws.id); expect(after?.plan).toBe("free"); expect(after?.trialEndsAt).toBeNull(); expect(await lastPlanAuditReason(s.ws.id)).toBe("account_deleted"); const deleted = await db .select() .from(user) .where(eq(user.id, s.user.id)) .get(); expect(deleted?.deletedAt).not.toBeNull(); });
test("a paid workspace elsewhere rejects the delete and keeps the trial", async () => { const s = await seedTrial(); live = [subscription(s.stripeId)]; const paid = await createWorkspace({ plan: "team", trialEndsAt: null }); await addUserToWorkspace(s.user.id, paid.id, "owner");
await expect( edgeRouter.createCaller(asCaller(s)).user.deleteAccount(), ).rejects.toMatchObject({ code: "PRECONDITION_FAILED" });
assertSpyCalls(cancelStripeSubscription, 0); const after = await readWorkspace(s.ws.id); expect(after?.plan).toBe("starter"); expect(after?.trialEndsAt).toEqual(s.trialEndsAt); }); });
describe("webhook", () => { const caller = () => webhookRouter.createCaller(createInnerTRPCContext({ session: null }));
function event( type: string, object: Stripe.Subscription | Stripe.Checkout.Session, previous_attributes?: Partial<Stripe.Subscription>, ) { return { event: { id: `evt_${crypto.randomUUID()}`, created: now(), type, data: { object: { ...object }, previous_attributes }, }, }; }
test("setup checkout completed → card set as the default everywhere", async () => { const intent: Partial<Stripe.SetupIntent> = { payment_method: "pm_new", metadata: { subscriptionId: "sub_setup" }, }; const retrieveIntent = stub(stripe.setupIntents, "retrieve", () => Promise.resolve(intent as Stripe.Response<Stripe.SetupIntent>), ); const retrieveSub = stub(stripe.subscriptions, "retrieve", () => Promise.resolve( subscription("cus_setup", { id: "sub_setup", }) as Stripe.Response<Stripe.Subscription>, ), ); const updateCustomer = stub(stripe.customers, "update", () => Promise.resolve({} as Stripe.Response<Stripe.Customer>), ); stubs.push(retrieveIntent, retrieveSub, updateCustomer);
await caller().sessionCompleted( event("checkout.session.completed", { mode: "setup", customer: "cus_setup", setup_intent: "seti_1", } as Stripe.Checkout.Session), );
expect(updateCustomer.calls[0]?.args).toEqual([ "cus_setup", { invoice_settings: { default_payment_method: "pm_new" } }, ]); expect(updateSubscription.calls[0]?.args).toEqual([ "sub_setup", { default_payment_method: "pm_new" }, ]); });
test("trialing → active clears trialEndsAt", async () => { const s = await seedTrial(); const sub = subscription(s.stripeId, { status: "active" }); live = [sub];
await caller().customerSubscriptionUpdated( event("customer.subscription.updated", sub, { status: "trialing" }), );
const after = await readWorkspace(s.ws.id); expect(after?.plan).toBe("starter"); expect(after?.trialEndsAt).toBeNull(); });
test("a live trial keeps trialEndsAt in sync", async () => { const s = await seedTrial(); const sub = subscription(s.stripeId, { trial_end: now() + 20 * DAY }); live = [sub];
await caller().customerSubscriptionUpdated( event("customer.subscription.updated", sub), );
const after = await readWorkspace(s.ws.id); expect(after?.trialEndsAt).toEqual(new Date((sub.trial_end ?? 0) * 1000)); });
test("a trial that ran out is audited as trial_ended, not churn", async () => { const send = stub(resend.emails, "send"); const enabled = stub(delivery, "enabled", () => true); stubs.push(send, enabled); const s = await seedTrial(); live = [];
await caller().customerSubscriptionDeleted( event( "customer.subscription.deleted", subscription(s.stripeId, { status: "canceled" }), ), );
const after = await readWorkspace(s.ws.id); expect(after?.plan).toBe("free"); expect(after?.trialEndsAt).toBeNull(); expect(await lastPlanAuditReason(s.ws.id)).toBe("trial_ended"); });
test("a trial the customer cancelled is audited as trial_cancelled", async () => { const send = stub(resend.emails, "send"); const enabled = stub(delivery, "enabled", () => true); stubs.push(send, enabled); const s = await seedTrial(); live = [];
await caller().customerSubscriptionDeleted( event( "customer.subscription.deleted", subscription(s.stripeId, { status: "canceled", cancellation_details: { reason: "cancellation_requested", } as Stripe.Subscription.CancellationDetails, }), ), );
const after = await readWorkspace(s.ws.id); expect(after?.plan).toBe("free"); expect(after?.trialEndsAt).toBeNull(); expect(await lastPlanAuditReason(s.ws.id)).toBe("trial_cancelled"); });
test("a converted trial cancelled later is churn even if the marker is stale", async () => { const send = stub(resend.emails, "send"); const enabled = stub(delivery, "enabled", () => true); stubs.push(send, enabled); // The trial-to-active webhook never landed, so `trialEndsAt` is set. const s = await seedTrial(); live = []; const trialEnd = now() - 30 * DAY;
await caller().customerSubscriptionDeleted( event( "customer.subscription.deleted", subscription(s.stripeId, { status: "canceled", trial_end: trialEnd, ended_at: now(), cancellation_details: { reason: "cancellation_requested", } as Stripe.Subscription.CancellationDetails, }), ), );
const after = await readWorkspace(s.ws.id); expect(after?.plan).toBe("free"); expect(after?.trialEndsAt).toBeNull(); expect(await lastPlanAuditReason(s.ws.id)).toBe("subscription_deleted"); });
test("deleted on an already-free workspace → nothing happens", async () => { const send = stub(resend.emails, "send"); const enabled = stub(delivery, "enabled", () => true); stubs.push(send, enabled); const stripeId = `cus_${crypto.randomUUID()}`; await createTestWorkspace({ plan: "free", stripeId, subscriptionId: null, });
await caller().customerSubscriptionDeleted( event( "customer.subscription.deleted", subscription(stripeId, { status: "canceled" }), ), );
assertSpyCalls(send, 0); }); });});