made checkout lock fail open

server/src/external/stripe/webhookHandlers/handleStripeCheckoutSessionCompleted/tasks/handleCheckoutSessionMetadataV2/handleCheckoutSessionMetadataV2.ts

@@ -73,10 +73,12 @@ export const handleCheckoutSessionMetadataV2 = async ({
 	});
 
 	// Clear checkout session lock now that customer_product rows exist
-	await checkoutSessionLock.clear({
+	const lockCustomerId =
-		ctx,
+		updatedDeferredData.billingContext.fullCustomer.id ??
-		customerId: ctx.fullCustomer?.id ?? "",
+		updatedDeferredData.billingContext.fullCustomer.internal_id;
-	});
+	if (lockCustomerId) {
+		await checkoutSessionLock.clear({ ctx, customerId: lockCustomerId });
+	}
 
 	// Queue customer.products.updated webhook (mirrors executeBillingPlan)
 	await billingPlanToSendProductsUpdated({

server/src/internal/billing/v2/actions/locks/checkoutSessionLock/checkoutSessionLock.ts

@@ -1,9 +1,8 @@
-import { ms } from "@autumn/shared";
 import { createStripeCli } from "@/external/connect/createStripeCli";
 import type { AutumnContext } from "@/honoUtils/HonoEnv";
 import { CacheManager } from "@/utils/cacheUtils/CacheManager";
 
-const CHECKOUT_LOCK_TTL_SECONDS = ms.minutes(2);
+const CHECKOUT_LOCK_TTL_SECONDS = 2 * 60;
 
 interface CheckoutSessionLockData {
 	paramsHash: string;
@@ -26,9 +25,14 @@ const get = async ({
 	ctx: AutumnContext;
 	customerId: string;
 }): Promise<CheckoutSessionLockData | null> => {
-	return CacheManager.getJson<CheckoutSessionLockData>(
+	try {
-		buildKey({ ctx, customerId }),
+		return await CacheManager.getJson<CheckoutSessionLockData>(
-	);
+			buildKey({ ctx, customerId }),
+		);
+	} catch (error) {
+		ctx.logger.error(`Failed to get checkout session lock: ${error}`);
+		return null;
+	}
 };
 
 const set = async ({
@@ -40,11 +44,15 @@ const set = async ({
 	customerId: string;
 	data: CheckoutSessionLockData;
 }): Promise<void> => {
-	await CacheManager.setJson(
+	try {
-		buildKey({ ctx, customerId }),
+		await CacheManager.setJson(
-		data,
+			buildKey({ ctx, customerId }),
-		CHECKOUT_LOCK_TTL_SECONDS,
+			data,
-	);
+			CHECKOUT_LOCK_TTL_SECONDS,
+		);
+	} catch (error) {
+		ctx.logger.error(`Failed to set checkout session lock: ${error}`);
+	}
 };
 
 const clear = async ({
@@ -54,7 +62,11 @@ const clear = async ({
 	ctx: AutumnContext;
 	customerId: string;
 }): Promise<void> => {
-	await CacheManager.del(buildKey({ ctx, customerId }));
+	try {
+		await CacheManager.del(buildKey({ ctx, customerId }));
+	} catch (error) {
+		ctx.logger.error(`Failed to clear checkout session lock: ${error}`);
+	}
 };
 
 /** Expire the old Stripe Checkout session then delete the Redis lock. */
@@ -73,8 +85,10 @@ const expireAndClear = async ({
 			env: ctx.env,
 		});
 		await stripeCli.checkout.sessions.expire(checkoutSessionId);
-	} catch {
+	} catch (error) {
-		// Session may already be expired / completed
+		ctx.logger.error(
+			`Failed to expire checkout session ${checkoutSessionId}: ${error}`,
+		);
 	}
 
 	await clear({ ctx, customerId });

server/src/utils/hash/hashJson.ts

@@ -10,6 +10,10 @@ const deterministicStringify = (value: unknown): string => {
 		return `[${value.map(deterministicStringify).join(",")}]`;
 
 	const obj = value as Record<string, unknown>;
+
+	if (typeof obj.toJSON === "function")
+		return deterministicStringify(obj.toJSON());
+
 	const sortedKeys = Object.keys(obj)
 		.filter((k) => obj[k] !== undefined)
 		.sort();

shared/models/billingModels/plan/billingResult.ts

@@ -5,7 +5,9 @@ export interface StripeBillingPlanResult {
 	deferred?: boolean;
 	stripeInvoice?: Stripe.Invoice;
 	stripeSubscription?: Stripe.Subscription;
-	stripeCheckoutSession?: Partial<Stripe.Checkout.Session>;
+	stripeCheckoutSession?:
+		| Stripe.Checkout.Session
+		| (Pick<Stripe.Checkout.Session, "id"> & { url?: string | null });
 	stripeInvoiceItems?: Stripe.InvoiceItem[];
 	requiredAction?: {
 		code: PaymentFailureCode;