chore: rename public API error class

apps/web/src/server/public-api/api-error.ts

@@ -59,7 +59,7 @@ function statusToCode(status: StatusCode): z.infer<typeof ErrorCode> {
   }
 }
 
-export class UnsendApiError extends HTTPException {
+export class UseSendApiError extends HTTPException {
   public readonly code: z.infer<typeof ErrorCode>;
 
   constructor({
@@ -78,7 +78,7 @@ export function handleError(err: Error, c: Context): Response {
   /**
    * We can handle this very well, as it is something we threw ourselves
    */
-  if (err instanceof UnsendApiError) {
+  if (err instanceof UseSendApiError) {
     if (err.status >= 500) {
       logger.error(
         { name: err.name, code: err.code, status: err.status, err },

apps/web/src/server/public-api/api-utils.ts

@@ -1,12 +1,12 @@
 import { Context } from "hono";
 import { db } from "../db";
-import { UnsendApiError } from "./api-error";
+import { UseSendApiError } from "./api-error";
 
 export const getContactBook = async (c: Context, teamId: number) => {
   const contactBookId = c.req.param("contactBookId");
 
   if (!contactBookId) {
-    throw new UnsendApiError({
+    throw new UseSendApiError({
       code: "BAD_REQUEST",
       message: "contactBookId is mandatory",
     });
@@ -17,7 +17,7 @@ export const getContactBook = async (c: Context, teamId: number) => {
   });
 
   if (!contactBook) {
-    throw new UnsendApiError({
+    throw new UseSendApiError({
       code: "NOT_FOUND",
       message: "Contact book not found for this team",
     });
@@ -30,7 +30,7 @@ export const checkIsValidEmailId = async (emailId: string, teamId: number) => {
   const email = await db.email.findUnique({ where: { id: emailId, teamId } });
 
   if (!email) {
-    throw new UnsendApiError({ code: "NOT_FOUND", message: "Email not found" });
+    throw new UseSendApiError({ code: "NOT_FOUND", message: "Email not found" });
   }
 };
 
@@ -51,7 +51,7 @@ export const checkIsValidEmailIdWithDomainRestriction = async (
   const email = await db.email.findUnique({ where: whereClause });
 
   if (!email) {
-    throw new UnsendApiError({ code: "NOT_FOUND", message: "Email not found" });
+    throw new UseSendApiError({ code: "NOT_FOUND", message: "Email not found" });
   }
 
   return email;

apps/web/src/server/public-api/api/contacts/get-contact.ts

@@ -2,7 +2,7 @@ import { createRoute, z } from "@hono/zod-openapi";
 import { PublicAPIApp } from "~/server/public-api/hono";
 import { getTeamFromToken } from "~/server/public-api/auth";
 import { db } from "~/server/db";
-import { UnsendApiError } from "../../api-error";
+import { UseSendApiError } from "../../api-error";
 import { getContactBook } from "../../api-utils";
 
 const route = createRoute({
@@ -63,7 +63,7 @@ function getContact(app: PublicAPIApp) {
     });
 
     if (!contact) {
-      throw new UnsendApiError({
+      throw new UseSendApiError({
         code: "NOT_FOUND",
         message: "Contact not found",
       });

apps/web/src/server/public-api/api/contacts/get-contacts.ts

@@ -2,7 +2,7 @@ import { createRoute, z } from "@hono/zod-openapi";
 import { PublicAPIApp } from "~/server/public-api/hono";
 import { getTeamFromToken } from "~/server/public-api/auth";
 import { db } from "~/server/db";
-import { UnsendApiError } from "../../api-error";
+import { UseSendApiError } from "../../api-error";
 import { getContactBook } from "../../api-utils";
 
 const route = createRoute({

apps/web/src/server/public-api/api/domains/delete-domain.ts

@@ -1,7 +1,7 @@
 import { createRoute, z } from "@hono/zod-openapi";
 import { PublicAPIApp } from "../../hono";
 import { db } from "~/server/db";
-import { UnsendApiError } from "../../api-error";
+import { UseSendApiError } from "../../api-error";
 import { deleteDomain as deleteDomainService } from "~/server/service/domain-service";
 
 const route = createRoute({
@@ -61,7 +61,7 @@ function deleteDomain(app: PublicAPIApp) {
 
     // Enforce API key domain restriction
     if (team.apiKey.domainId && team.apiKey.domainId !== domainId) {
-      throw new UnsendApiError({
+      throw new UseSendApiError({
         code: "FORBIDDEN",
         message: "API key doesn't have access to this domain",
       });
@@ -75,7 +75,7 @@ function deleteDomain(app: PublicAPIApp) {
     });
 
     if (!domain) {
-      throw new UnsendApiError({
+      throw new UseSendApiError({
         code: "NOT_FOUND",
         message: "Domain not found",
       });

apps/web/src/server/public-api/api/domains/get-domain.ts

@@ -1,7 +1,7 @@
 import { createRoute, z } from "@hono/zod-openapi";
 import { DomainSchema } from "~/lib/zod/domain-schema";
 import { PublicAPIApp } from "~/server/public-api/hono";
-import { UnsendApiError } from "../../api-error";
+import { UseSendApiError } from "../../api-error";
 import { db } from "~/server/db";
 import { getDomain as getDomainService } from "~/server/service/domain-service";
 
@@ -35,7 +35,7 @@ function getDomain(app: PublicAPIApp) {
 
     // Enforce API key domain restriction (if any)
     if (team.apiKey.domainId && team.apiKey.domainId !== id) {
-      throw new UnsendApiError({
+      throw new UseSendApiError({
         code: "NOT_FOUND",
         message: "Domain not found",
       });
@@ -46,7 +46,7 @@ function getDomain(app: PublicAPIApp) {
     try {
       enriched = await getDomainService(id, team.id);
     } catch (e) {
-      throw new UnsendApiError({
+      throw new UseSendApiError({
         code: "INTERNAL_SERVER_ERROR",
         message: e instanceof Error ? e.message : "Internal server error",
       });

apps/web/src/server/public-api/api/emails/get-email.ts

@@ -3,7 +3,7 @@ import { PublicAPIApp } from "~/server/public-api/hono";
 import { getTeamFromToken } from "~/server/public-api/auth";
 import { db } from "~/server/db";
 import { EmailStatus } from "@prisma/client";
-import { UnsendApiError } from "../../api-error";
+import { UseSendApiError } from "../../api-error";
 
 const route = createRoute({
   method: "get",
@@ -88,7 +88,7 @@ function send(app: PublicAPIApp) {
     });
 
     if (!email) {
-      throw new UnsendApiError({
+      throw new UseSendApiError({
         code: "NOT_FOUND",
         message: "Email not found",
       });

apps/web/src/server/public-api/auth.ts

@@ -1,6 +1,6 @@
 import { Context } from "hono";
 import { db } from "../db";
-import { UnsendApiError } from "./api-error";
+import { UseSendApiError } from "./api-error";
 import { getTeamAndApiKey } from "../service/api-service";
 import { isSelfHosted } from "~/utils/common";
 import { logger } from "../logger/log";
@@ -12,7 +12,7 @@ export const getTeamFromToken = async (c: Context) => {
   const authHeader = c.req.header("Authorization");
 
   if (!authHeader) {
-    throw new UnsendApiError({
+    throw new UseSendApiError({
       code: "UNAUTHORIZED",
       message: "No Authorization header provided",
     });
@@ -21,7 +21,7 @@ export const getTeamFromToken = async (c: Context) => {
   const token = authHeader.split(" ")[1];
 
   if (!token) {
-    throw new UnsendApiError({
+    throw new UseSendApiError({
       code: "UNAUTHORIZED",
       message: "No Authorization header provided",
     });
@@ -30,7 +30,7 @@ export const getTeamFromToken = async (c: Context) => {
   const teamAndApiKey = await getTeamAndApiKey(token);
 
   if (!teamAndApiKey) {
-    throw new UnsendApiError({
+    throw new UseSendApiError({
       code: "FORBIDDEN",
       message: "Invalid API token",
     });
@@ -39,7 +39,7 @@ export const getTeamFromToken = async (c: Context) => {
   const { team, apiKey } = teamAndApiKey;
 
   if (!team) {
-    throw new UnsendApiError({
+    throw new UseSendApiError({
       code: "FORBIDDEN",
       message: "Invalid API token",
     });

apps/web/src/server/public-api/hono.ts

@@ -6,7 +6,7 @@ import { env } from "~/env";
 import { getRedis } from "~/server/redis";
 import { getTeamFromToken } from "~/server/public-api/auth";
 import { isSelfHosted } from "~/utils/common";
-import { UnsendApiError } from "./api-error";
+import { UseSendApiError } from "./api-error";
 import { Team, ApiKey } from "@prisma/client";
 import { logger } from "../logger/log";
 
@@ -36,11 +36,11 @@ export function getApp() {
       const team = await getTeamFromToken(c as any);
       c.set("team", team);
     } catch (error) {
-      if (error instanceof UnsendApiError) {
+      if (error instanceof UseSendApiError) {
         throw error;
       }
       logger.error({ err: error }, "Error in getTeamFromToken middleware");
-      throw new UnsendApiError({
+      throw new UseSendApiError({
         code: "INTERNAL_SERVER_ERROR",
         message: "Authentication failed",
       });
@@ -104,7 +104,7 @@ export function getApp() {
         "Retry-After",
         String(ttl > 0 ? ttl : RATE_LIMIT_WINDOW_SECONDS)
       );
-      throw new UnsendApiError({
+      throw new UseSendApiError({
         code: "RATE_LIMITED",
         message: `Rate limit exceeded. Try again in ${ttl > 0 ? ttl : RATE_LIMIT_WINDOW_SECONDS} seconds.`,
       });

apps/web/src/server/public-api/schemas/campaign-schema.ts

@@ -1,6 +1,6 @@
 import { z } from "@hono/zod-openapi";
 import * as chrono from "chrono-node";
-import { UnsendApiError } from "../api-error";
+import { UseSendApiError } from "../api-error";
 
 const stringOrStringArray = z.union([
   z.string().min(1),
@@ -22,7 +22,7 @@ export const parseScheduledAt = (scheduledAt?: string): Date | undefined => {
     return chronoDate;
   }
 
-  throw new UnsendApiError({
+  throw new UseSendApiError({
     code: "BAD_REQUEST",
     message: `Invalid date format: ${scheduledAt}. Use ISO 8601 format or natural language like 'tomorrow 9am'.`,
   });

apps/web/src/server/service/campaign-service.ts

@@ -18,7 +18,7 @@ import {
 import { logger } from "../logger/log";
 import { createWorkerHandler, TeamJob } from "../queue/bullmq-context";
 import { SuppressionService } from "./suppression-service";
-import { UnsendApiError } from "../public-api/api-error";
+import { UseSendApiError } from "../public-api/api-error";
 import {
   validateApiKeyDomainAccess,
   validateDomainFromEmail,
@@ -190,7 +190,7 @@ export async function createCampaignFromApi({
   batchSize?: number;
 }) {
   if (!content && !html) {
-    throw new UnsendApiError({
+    throw new UseSendApiError({
       code: "BAD_REQUEST",
       message: "Either content or html must be provided",
     });
@@ -201,7 +201,7 @@ export async function createCampaignFromApi({
       JSON.parse(content);
     } catch (error) {
       logger.error({ err: error }, "Invalid campaign content JSON from API");
-      throw new UnsendApiError({
+      throw new UseSendApiError({
         code: "BAD_REQUEST",
         message: "Invalid content JSON",
       });
@@ -214,7 +214,7 @@ export async function createCampaignFromApi({
   });
 
   if (!contactBook) {
-    throw new UnsendApiError({
+    throw new UseSendApiError({
       code: "BAD_REQUEST",
       message: "Contact book not found",
     });
@@ -229,7 +229,7 @@ export async function createCampaignFromApi({
     });
 
     if (!apiKey || apiKey.teamId !== teamId) {
-      throw new UnsendApiError({
+      throw new UseSendApiError({
         code: "FORBIDDEN",
         message: "Invalid API key",
       });
@@ -249,7 +249,7 @@ export async function createCampaignFromApi({
   );
 
   if (!unsubPlaceholderFound) {
-    throw new UnsendApiError({
+    throw new UseSendApiError({
       code: "BAD_REQUEST",
       message: "Campaign must include an unsubscribe link before sending",
     });
@@ -319,7 +319,7 @@ export async function getCampaignForTeam({
   });
 
   if (!campaign) {
-    throw new UnsendApiError({
+    throw new UseSendApiError({
       code: "NOT_FOUND",
       message: "Campaign not found",
     });
@@ -396,7 +396,7 @@ export async function scheduleCampaign({
     where: { id: campaignId, teamId },
   });
   if (!campaign) {
-    throw new UnsendApiError({
+    throw new UseSendApiError({
       code: "NOT_FOUND",
       message: "Campaign not found",
     });
@@ -408,21 +408,21 @@ export async function scheduleCampaign({
     campaign = prepared.campaign;
     html = prepared.html;
   } catch (err) {
-    throw new UnsendApiError({
+    throw new UseSendApiError({
       code: "BAD_REQUEST",
       message: err instanceof Error ? err.message : "Invalid campaign content",
     });
   }
 
   if (!campaign.contactBookId) {
-    throw new UnsendApiError({
+    throw new UseSendApiError({
       code: "BAD_REQUEST",
       message: "No contact book found for campaign",
     });
   }
 
   if (!html) {
-    throw new UnsendApiError({
+    throw new UseSendApiError({
       code: "BAD_REQUEST",
       message: "No HTML content for campaign",
     });
@@ -433,7 +433,7 @@ export async function scheduleCampaign({
     html
   );
   if (!unsubPlaceholderFound) {
-    throw new UnsendApiError({
+    throw new UseSendApiError({
       code: "BAD_REQUEST",
       message: "Campaign must include an unsubscribe link before scheduling",
     });
@@ -445,7 +445,7 @@ export async function scheduleCampaign({
   });
 
   if (total === 0) {
-    throw new UnsendApiError({
+    throw new UseSendApiError({
       code: "BAD_REQUEST",
       message: "No subscribed contacts to send",
     });
@@ -486,7 +486,7 @@ export async function pauseCampaign({
   });
 
   if (!campaign) {
-    throw new UnsendApiError({
+    throw new UseSendApiError({
       code: "NOT_FOUND",
       message: "Campaign not found",
     });
@@ -512,7 +512,7 @@ export async function resumeCampaign({
   });
 
   if (!campaign) {
-    throw new UnsendApiError({
+    throw new UseSendApiError({
       code: "NOT_FOUND",
       message: "Campaign not found",
     });