feat(stripe): implement replaceProductPrice function to manage default price updates

Author: achneerov

app/(authenticated)/services/actions.ts

@@ -10,8 +10,8 @@ import { cadStringToCents } from "@/lib/money";
 import {
    createPrice,
    createProduct,
-   deactivatePrices,
-   listActivePriceIds,
+   getStripeServiceData,
+   replaceProductPrice,
    updateProduct,
 } from "@/lib/stripe";
 
@@ -322,11 +322,10 @@ export async function updateService(
       });
 
       if (cents !== undefined) {
-         const { priceId } = await createPrice(row.stripeProductId, cents);
-         const oldPriceIds = (await listActivePriceIds(row.stripeProductId)).filter(
-            (id) => id !== priceId,
-         );
-         await deactivatePrices(oldPriceIds);
+         const current = await getStripeServiceData(row.stripeProductId);
+         if (current?.priceCents !== cents) {
+            await replaceProductPrice(row.stripeProductId, cents);
+         }
       }
 
       const dbPatch: Partial<typeof services.$inferInsert> = {};

lib/stripe.ts

@@ -171,10 +171,57 @@ export async function createPrice(
       unit_amount: amountCents,
       currency: "cad",
    });
-   await stripe.products.update(productId, { default_price: price.id });
+
    return { priceId: price.id };
 }
 
+export async function replaceProductPrice(
+   productId: string,
+   amountCents: number,
+): Promise<{ priceId: string }> {
+   // get the current default price for the product
+   const product = await stripe.products.retrieve(productId, {
+      expand: ["default_price"],
+   });
+
+   const currentDefaultPrice =
+      typeof product.default_price === "string"
+         ? product.default_price
+         : product.default_price?.id;
+
+   // create the new price FIRST (rlly important)
+   const newPrice = await stripe.prices.create({
+      product: productId,
+      unit_amount: amountCents,
+      currency: "cad",
+   });
+
+   // set the new price as the product default
+   await stripe.products.update(productId, {
+      default_price: newPrice.id,
+   });
+
+   // archive old active prices but NEVER archive the new default price
+   const prices = await stripe.prices.list({
+      product: productId,
+      active: true,
+      limit: 100,
+   });
+
+   for (const p of prices.data) {
+      if (p.id !== newPrice.id && p.id !== currentDefaultPrice) {
+         await stripe.prices.update(p.id, { active: false });
+      }
+   }
+
+   // archive the old default price after default_price has been swapped
+   if (currentDefaultPrice && currentDefaultPrice !== newPrice.id) {
+      await stripe.prices.update(currentDefaultPrice, { active: false });
+   }
+
+   return { priceId: newPrice.id };
+}
+
 export async function deactivateActivePricesForProduct(
    productId: string,
 ): Promise<void> {