Merge pull request #2 from chriscarrollsmith/issue170

Issue170

Author: chriscarrollsmith

app/api/webhooks/route.ts

@@ -3,14 +3,18 @@ import { stripe } from '@/utils/stripe';
 import {
   upsertProductRecord,
   upsertPriceRecord,
+  deleteProductRecord,
+  deletePriceRecord,
   manageSubscriptionStatusChange
 } from '@/utils/supabase-admin';
 
 const relevantEvents = new Set([
   'product.created',
   'product.updated',
+  'product.deleted',
   'price.created',
   'price.updated',
+  'price.deleted',
   'checkout.session.completed',
   'customer.subscription.created',
   'customer.subscription.updated',
@@ -24,8 +28,9 @@ export async function POST(req: Request) {
   let event: Stripe.Event;
 
   try {
-    if (!sig || !webhookSecret) return;
+    if (!sig || !webhookSecret) throw new Error("Missing Stripe Signature or Webhook Secret!");
     event = stripe.webhooks.constructEvent(body, sig, webhookSecret);
+    console.log(`🔔  Webhook received: ${event.type}`);
   } catch (err: any) {
     console.log(`❌ Error message: ${err.message}`);
     return new Response(`Webhook Error: ${err.message}`, { status: 400 });
@@ -42,6 +47,12 @@ export async function POST(req: Request) {
         case 'price.updated':
           await upsertPriceRecord(event.data.object as Stripe.Price);
           break;
+        case 'product.deleted':
+          await deleteProductRecord(event.data.object as Stripe.Product);
+          break;
+        case 'price.deleted':
+          await deletePriceRecord(event.data.object as Stripe.Price);
+          break;
         case 'customer.subscription.created':
         case 'customer.subscription.updated':
         case 'customer.subscription.deleted':

utils/helpers.ts

@@ -3,14 +3,23 @@ import { Database } from '@/types_db';
 type Price = Database['public']['Tables']['prices']['Row'];
 
 export const getURL = () => {
-  let url =
-    process?.env?.NEXT_PUBLIC_SITE_URL ?? // Set this to your site URL in production env.
-    process?.env?.NEXT_PUBLIC_VERCEL_URL ?? // Automatically set by Vercel.
+  // Check if NEXT_PUBLIC_SITE_URL is set and non-empty. Set this to your site URL in production env.
+  let url = process?.env?.NEXT_PUBLIC_SITE_URL && process.env.NEXT_PUBLIC_SITE_URL.trim() !== ''
+    ? process.env.NEXT_PUBLIC_SITE_URL
+    : // If not set, check for NEXT_PUBLIC_VERCEL_URL, which is automatically set by Vercel.
+    process?.env?.NEXT_PUBLIC_VERCEL_URL && process.env.NEXT_PUBLIC_VERCEL_URL.trim() !== ''
+    ? process.env.NEXT_PUBLIC_VERCEL_URL
+    : // If neither is set, default to localhost for local development.
     'http://localhost:3000/';
+
+  url = url.trim();
+
   // Make sure to include `https://` when not localhost.
   url = url.includes('http') ? url : `https://${url}`;
-  // Make sure to including trailing `/`.
-  url = url.charAt(url.length - 1) === '/' ? url : `${url}/`;
+
+  // Make sure to include trailing `/`.
+  url = url.endsWith('/') ? url : `${url}/`;
+
   return url;
 };
 

utils/supabase-admin.ts

@@ -29,6 +29,15 @@ const upsertProductRecord = async (product: Stripe.Product) => {
   console.log(`Product inserted/updated: ${product.id}`);
 };
 
+const deleteProductRecord = async (product: Stripe.Product) => {
+  const { error } = await supabaseAdmin
+    .from('products')
+    .delete()
+    .eq('id', product.id);
+  if (error) throw error;
+  console.log(`Product deleted: ${product.id}`);
+};
+
 const upsertPriceRecord = async (price: Stripe.Price) => {
   const priceData: Price = {
     id: price.id,
@@ -49,6 +58,15 @@ const upsertPriceRecord = async (price: Stripe.Price) => {
   console.log(`Price inserted/updated: ${price.id}`);
 };
 
+const deletePriceRecord = async (price: Stripe.Price) => {
+  const { error } = await supabaseAdmin
+    .from('prices')
+    .delete()
+    .eq('id', price.id);
+  if (error) throw error;
+  console.log(`Price deleted: ${price.id}`);
+};
+
 const createOrRetrieveCustomer = async ({
   email,
   uuid
@@ -179,7 +197,9 @@ const manageSubscriptionStatusChange = async (
 
 export {
   upsertProductRecord,
+  deleteProductRecord,
   upsertPriceRecord,
+  deletePriceRecord,
   createOrRetrieveCustomer,
   manageSubscriptionStatusChange
 };