fix: standardize error messaging in all service

packages/lib/services/actions.ts

@@ -2,7 +2,7 @@ import "server-only";
 
 import z from "zod";
 import { prisma } from "@formbricks/database";
-import { DatabaseError } from "@formbricks/types/v1/errors";
+import { DatabaseError, ResourceNotFoundError } from "@formbricks/types/v1/errors";
 import { TAction } from "@formbricks/types/v1/actions";
 import { ZId } from "@formbricks/types/v1/environment";
 import { Prisma } from "@prisma/client";
@@ -65,7 +65,7 @@ export const createAction = async (data: TJsActionInput) => {
   const session = await getSessionCached(sessionId);
 
   if (!session) {
-    throw new Error("Session not found");
+    throw new ResourceNotFoundError("Session", sessionId);
   }
 
   const actionClass = await getActionClassCached(name, environmentId);

packages/lib/services/activity.tsx

@@ -5,6 +5,7 @@ import { TActivityFeedItem } from "@formbricks/types/v1/activity";
 import { validateInputs } from "../utils/validate";
 import { ZId } from "@formbricks/types/v1/environment";
 import { cache } from "react";
+import { ResourceNotFoundError } from "@formbricks/types/v1/errors";
 
 export const getActivityTimeline = cache(async (personId: string): Promise<TActivityFeedItem[]> => {
   validateInputs([personId, ZId]);
@@ -34,8 +35,9 @@ export const getActivityTimeline = cache(async (personId: string): Promise<TActi
       },
     },
   });
+
   if (!person) {
-    throw new Error("No such person found");
+    throw new ResourceNotFoundError("Person", personId);
   }
   const { attributes, displays, sessions } = person;
 

packages/lib/services/displays.ts

@@ -90,7 +90,9 @@ export const createDisplay = async (displayInput: TDisplayInput): Promise<TDispl
 export const markDisplayResponded = async (displayId: string): Promise<TDisplay> => {
   validateInputs([displayId, ZId]);
   try {
-    if (!displayId) throw new Error("Display ID is required");
+    if (!displayId) {
+      throw new ResourceNotFoundError("Display", displayId);
+    }
 
     const displayPrisma = await prisma.display.update({
       where: {

packages/lib/services/googleSheet.ts

@@ -1,6 +1,6 @@
 import { prisma } from "@formbricks/database";
 import { Prisma } from "@prisma/client";
-import { DatabaseError } from "@formbricks/types/v1/errors";
+import { DatabaseError, UnknownError } from "@formbricks/types/v1/errors";
 import { cache } from "react";
 import {
   TGoogleCredential,
@@ -87,8 +87,7 @@ export async function writeData(credentials: TGoogleCredential, spreadsheetId: s
       },
       (err: Error) => {
         if (err) {
-          throw new Error(`Error while appending data: ${err.message}`);
-        } else {
+          throw new UnknownError(`Error while appending data: ${err.message}`);
         }
       }
     );
@@ -102,8 +101,7 @@ export async function writeData(credentials: TGoogleCredential, spreadsheetId: s
       },
       (err: Error) => {
         if (err) {
-          throw new Error(`Error while appending data: ${err.message}`);
-        } else {
+          throw new UnknownError(`Error while appending data: ${err.message}`);
         }
       }
     );

packages/lib/services/membership.ts

@@ -1,5 +1,5 @@
 import { prisma } from "@formbricks/database";
-import { ResourceNotFoundError } from "@formbricks/types/v1/errors";
+import { ResourceNotFoundError, DatabaseError } from "@formbricks/types/v1/errors";
 import { TMember, TMembership, TMembershipUpdateInput } from "@formbricks/types/v1/memberships";
 import { Prisma } from "@prisma/client";
 import { cache } from "react";
@@ -80,9 +80,9 @@ export const updateMembership = async (
   } catch (error) {
     if (error instanceof Prisma.PrismaClientKnownRequestError && error.code === "P2016") {
       throw new ResourceNotFoundError("Membership", `userId: ${userId}, teamId: ${teamId}`);
-    } else {
-      throw error; // Re-throw any other errors
     }
+
+    throw error;
   }
 };
 
@@ -126,6 +126,10 @@ export const transferOwnership = async (currentOwnerId: string, newOwnerId: stri
       }),
     ]);
   } catch (error) {
-    throw new Error("Something went wrong");
+    if (error instanceof Prisma.PrismaClientKnownRequestError) {
+      throw new DatabaseError("Database operation failed");
+    }
+
+    throw error;
   }
 };

packages/lib/services/person.ts

@@ -2,7 +2,7 @@ import "server-only";
 
 import { prisma } from "@formbricks/database";
 import { ZId } from "@formbricks/types/v1/environment";
-import { DatabaseError } from "@formbricks/types/v1/errors";
+import { DatabaseError, ResourceNotFoundError } from "@formbricks/types/v1/errors";
 import { TPerson, TPersonUpdateInput } from "@formbricks/types/v1/people";
 import { Prisma } from "@prisma/client";
 import { revalidateTag, unstable_cache } from "next/cache";
@@ -249,7 +249,7 @@ export const getOrCreatePersonByUserId = async (userId: string, environmentId: s
     const userIdAttributeClass = await getAttributeClassByName(environmentId, "userId");
 
     if (!userIdAttributeClass) {
-      throw new Error("Attribute class not found for the given environmentId");
+      throw new ResourceNotFoundError("Attribute class not found for the given environment", environmentId);
     }
 
     const personPrisma = await prisma.person.create({

packages/lib/services/product.ts

@@ -1,6 +1,6 @@
 import { prisma } from "@formbricks/database";
 import { ZId } from "@formbricks/types/v1/environment";
-import { DatabaseError, ValidationError } from "@formbricks/types/v1/errors";
+import { DatabaseError, ValidationError, ResourceNotFoundError } from "@formbricks/types/v1/errors";
 import type { TProduct, TProductUpdateInput } from "@formbricks/types/v1/product";
 import { ZProduct, ZProductUpdateInput } from "@formbricks/types/v1/product";
 import { Prisma } from "@prisma/client";
@@ -221,7 +221,7 @@ export const createProduct = async (environmentId: string, productName: string):
   });
 
   if (!environment) {
-    throw new Error("Invalid environment");
+    throw new ResourceNotFoundError("Environment", environmentId);
   }
 
   const newProduct = await prisma.product.create({

packages/lib/services/team.ts

@@ -1,6 +1,6 @@
 import { prisma } from "@formbricks/database";
 import { ZId } from "@formbricks/types/v1/environment";
-import { DatabaseError, ResourceNotFoundError } from "@formbricks/types/v1/errors";
+import { DatabaseError, ResourceNotFoundError, ValidationError } from "@formbricks/types/v1/errors";
 import { TTeam, TTeamUpdateInput } from "@formbricks/types/v1/teams";
 import { createId } from "@paralleldrive/cuid2";
 import { Prisma } from "@prisma/client";
@@ -236,7 +236,7 @@ export const createDemoProduct = async (teamId: string) => {
 
   // check if updatedEnvironment exists and it has attributeClasses
   if (!updatedEnvironment || !updatedEnvironment.attributeClasses) {
-    throw new Error("Attribute classes could not be created");
+    throw new ValidationError("Attribute classes could not be created");
   }
 
   const attributeClasses = updatedEnvironment.attributeClasses;
@@ -323,8 +323,12 @@ export const createDemoProduct = async (teamId: string) => {
         })),
       }),
     ]);
-  } catch (err: any) {
-    throw new Error(err);
+  } catch (error: any) {
+    if (error instanceof Prisma.PrismaClientKnownRequestError) {
+      throw new DatabaseError("Database operation failed");
+    }
+
+    throw error;
   }
 
   // Create a function that creates a survey

packages/types/v1/errors.ts

@@ -22,6 +22,14 @@ class ValidationError extends Error {
   }
 }
 
+class UnknownError extends Error {
+  statusCode = 500;
+  constructor(message: string) {
+    super(message);
+    this.name = "DatabaseError";
+  }
+}
+
 class DatabaseError extends Error {
   statusCode = 500;
   constructor(message: string) {
@@ -83,6 +91,7 @@ export {
   ValidationError,
   DatabaseError,
   UniqueConstraintError,
+  UnknownError,
   ForeignKeyConstraintError,
   OperationNotAllowedError,
   AuthenticationError,