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
123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180import { ConflictError, type DB, type ServiceContext,} from "@openstatus/services";import { hasPendingInvitation } from "@openstatus/services/invitation";import { downgradeWorkspaceToFree, findTrialEligibleWorkspace, listOwnedTrialWorkspaces, updateWorkspacePlan, updateWorkspaceStripeId,} from "@openstatus/services/workspace";import MailChecker from "mailchecker";
import { env } from "../../env";import { buildFromSubscriptionOrThrow, cancelSubscription, stripe,} from "./shared";import { getPriceIdForPlan } from "./utils";
export const TRIAL_DAYS = 14;
export type TrialSkipReason = | "disabled" | "sso" | "email" | "invited" | "disposable" | "already_trialed" | "not_eligible" | "stripe_error";
export type SignupTrialResult = | { started: true; trialEndsAt: Date } | { started: false; reason: TrialSkipReason };
// `customers.list` is read-after-write consistent; the Search API is not, so// a re-signup right after a trial could slip past it.async function hasTrialedBefore(email: string) { const result = await stripe.customers.list({ email, limit: 100 }); return result.data.some((c) => c.metadata.trialed === "true");}
async function resolveCurrency(priceId: string, requested: "USD" | "EUR") { const price = await stripe.prices.retrieve(priceId, { expand: ["currency_options"], }); const wanted = requested.toLowerCase(); return wanted === price.currency || price.currency_options?.[wanted] ? wanted : price.currency;}
export async function maybeStartSignupTrial(args: { userId: number; email: string; provider?: string; currency: "USD" | "EUR"; db?: DB;}): Promise<SignupTrialResult> { const { db } = args; const email = args.email.trim().toLowerCase();
if ( env.SELF_HOST || env.NODE_ENV === "development" || !env.STRIPE_SECRET_KEY ) { return { started: false, reason: "disabled" }; } if (args.provider === "workos") return { started: false, reason: "sso" }; // A magic link proves only inbox access, so email signups start on free and // upgrade through checkout. if (args.provider === "resend") return { started: false, reason: "email" }; if (await hasPendingInvitation({ email, db })) { return { started: false, reason: "invited" }; } if (!MailChecker.isValid(email)) { return { started: false, reason: "disposable" }; } if (await hasTrialedBefore(email)) { return { started: false, reason: "already_trialed" }; }
const ws = await findTrialEligibleWorkspace({ input: { userId: args.userId }, db, }); if (!ws) return { started: false, reason: "not_eligible" };
const ctx: ServiceContext = { workspace: ws, actor: { type: "system", job: "signup-trial" }, db, };
const priceId = getPriceIdForPlan("starter", "monthly"); if (!priceId) throw new Error("Missing Starter monthly price"); const currency = await resolveCurrency(priceId, args.currency);
const customer = await stripe.customers.create( { email, metadata: { workspaceId: String(ws.id), trialed: "true" } }, { idempotencyKey: `trial-customer:ws_${ws.id}` }, );
try { await updateWorkspaceStripeId({ ctx, input: { stripeId: customer.id } }); } catch (err) { if (!(err instanceof ConflictError)) throw err; // Another request (a checkout, say) linked a customer since the // eligibility read. Drop ours so its `trialed` flag doesn't block a // later trial for this email. await stripe.customers.del(customer.id).catch(() => undefined); return { started: false, reason: "not_eligible" }; }
const subscription = await stripe.subscriptions.create( { customer: customer.id, currency, items: [{ price: priceId }], trial_period_days: TRIAL_DAYS, trial_settings: { end_behavior: { missing_payment_method: "cancel" }, }, payment_settings: { save_default_payment_method: "on_subscription" }, metadata: { source: "signup_trial", workspaceId: String(ws.id) }, }, { idempotencyKey: `trial-sub:ws_${ws.id}` }, );
const built = buildFromSubscriptionOrThrow(subscription); if (!built || !subscription.trial_end) { throw new Error(`Trial subscription ${subscription.id} is not a trial`); }
const trialEndsAt = new Date(subscription.trial_end * 1000);
await updateWorkspacePlan({ ctx, input: { plan: built.plan, subscriptionId: subscription.id, endsAt: trialEndsAt, paidUntil: trialEndsAt, trialEndsAt, limits: built.limits, reason: "trial_started", }, });
return { started: true, trialEndsAt };}
export async function cancelOwnedTrials(args: { userId: number; db?: DB;}): Promise<string[]> { const { db } = args; const trials = await listOwnedTrialWorkspaces({ input: { userId: args.userId }, db, });
const customDomains: string[] = []; for (const ws of trials) { await cancelSubscription(ws.stripeId ?? undefined); const result = await downgradeWorkspaceToFree({ ctx: { workspace: ws, actor: { type: "user", userId: args.userId }, db }, input: { reason: "account_deleted" }, }); customDomains.push(...result.customDomains); }
return customDomains;}