Update webhook errors location

Author: infomiho

template/app/src/payment/errors.ts

@@ -0,0 +1,6 @@
+export class UnhandledWebhookEventError extends Error {
+  constructor(eventType: string) {
+    super(`Unhandled event type: ${eventType}`);
+    this.name = 'UnhandledWebhookEventError';
+  }
+}

template/app/src/payment/lemonSqueezy/webhook.ts

@@ -9,7 +9,7 @@ import crypto from 'crypto';
 import { requireNodeEnvVar } from '../../server/utils';
 import { parseWebhookPayload, type OrderData, type SubscriptionData } from './webhookPayload';
 import { assertUnreachable } from '../../shared/utils';
-import { UnhandledWebhookEvent } from '../webhook';
+import { UnhandledWebhookEventError } from '../errors';
 
 export const lemonSqueezyWebhook: PaymentsWebhook = async (request, response, context) => {
   try {
@@ -28,7 +28,7 @@ export const lemonSqueezyWebhook: PaymentsWebhook = async (request, response, co
     }
 
     const payload = await parseWebhookPayload(rawBody).catch((e) => {
-      if (e instanceof UnhandledWebhookEvent) {
+      if (e instanceof UnhandledWebhookEventError) {
         throw new HttpError(500, e.message);
       } else {
         console.error('Error parsing webhook payload', e);

template/app/src/payment/lemonSqueezy/webhookPayload.ts

@@ -1,5 +1,5 @@
 import * as z from 'zod';
-import { UnhandledWebhookEvent } from '../webhook';
+import { UnhandledWebhookEventError } from '../errors';
 
 export async function parseWebhookPayload(rawPayload: string) {
   const rawEvent = JSON.parse(rawPayload) as unknown;
@@ -25,7 +25,7 @@ export async function parseWebhookPayload(rawPayload: string) {
       return { eventName: event.meta.event_name, meta: event.meta, data: subscriptionData };
     default:
       // If you'd like to handle more events, you can add more cases above.
-      throw new UnhandledWebhookEvent(event.meta.event_name);
+      throw new UnhandledWebhookEventError(event.meta.event_name);
   }
 }
 

template/app/src/payment/stripe/webhook.ts

@@ -17,7 +17,7 @@ import {
   SubscriptionDeletedData,
   SubscriptionUpdatedData,
 } from './webhookPayload';
-import { UnhandledWebhookEvent } from '../webhook';
+import { UnhandledWebhookEventError } from '../errors';
 
 export const stripeWebhook: PaymentsWebhook = async (request, response, context) => {
   const secret = requireNodeEnvVar('STRIPE_WEBHOOK_SECRET');
@@ -27,7 +27,7 @@ export const stripeWebhook: PaymentsWebhook = async (request, response, context)
   }
   const rawStripeEvent = ensureStripeEvent(request, sig, secret);
   const payload = await parseWebhookPayload(rawStripeEvent).catch((e) => {
-    if (e instanceof UnhandledWebhookEvent) {
+    if (e instanceof UnhandledWebhookEventError) {
       throw new HttpError(500, e.message);
     } else {
       console.error('Error parsing webhook payload', e);

template/app/src/payment/stripe/webhookPayload.ts

@@ -1,6 +1,6 @@
 import * as z from 'zod';
 import { Stripe } from 'stripe';
-import { UnhandledWebhookEvent } from '../webhook';
+import { UnhandledWebhookEventError } from '../errors';
 
 export async function parseWebhookPayload(rawStripeEvent: Stripe.Event) {
   const event = await genericStripeEventSchema.parseAsync(rawStripeEvent).catch((e) => {
@@ -38,7 +38,7 @@ export async function parseWebhookPayload(rawStripeEvent: Stripe.Event) {
       return { eventName: event.type, data: deletedSubscription };
     default:
       // If you'd like to handle more events, you can add more cases above.
-      throw new UnhandledWebhookEvent(event.type);
+      throw new UnhandledWebhookEventError(event.type);
   }
 }
 

template/app/src/payment/webhook.ts

@@ -2,10 +2,3 @@ import { paymentProcessor } from './paymentProcessor';
 
 export const paymentsWebhook = paymentProcessor.webhook;
 export const paymentsMiddlewareConfigFn = paymentProcessor.webhookMiddlewareConfigFn;
-
-export class UnhandledWebhookEvent extends Error {
-  constructor(eventType: string) {
-    super(`Unhandled event type: ${eventType}`);
-    this.name = 'UnhandledWebhookEvent';
-  }
-}