Properly handle throwing a duplicate patient error

sfbrigade · Sep 12, 2024 · 338c772 · 338c772
1 parent 30ffd56
commit 338c772
Showing 1 changed file with 38 additions and 26 deletions.
diff --git a/server/routes/api/v1/patients/create.js b/server/routes/api/v1/patients/create.js
@@ -1,6 +1,8 @@
 import { Role } from '../../../../models/user.js';
 import { StatusCodes } from 'http-status-codes';
 
+
+
 export default async function (fastify, _opts) {
   fastify.post(
     '/',
@@ -67,39 +69,49 @@ export default async function (fastify, _opts) {
       const { id } = request.body;
 
       const userId = request.user.id;
-
-      const newPatient = await fastify.prisma.$transaction(async (tx) => {
-        // Check if the patient already exists
-        const exists = await tx.patient.findUnique({
-          where: { id },
-        });
-        if (exists)
-          throw reply.status(StatusCodes.CONFLICT).send({
-            message: `Patient with ID ${id} already exists in database.`,
+      try {
+        const newPatient = await fastify.prisma.$transaction(async (tx) => {
+          // Check if the patient already exists
+          const exists = await tx.patient.findUnique({
+            where: { id },
           });
+          if (exists) {
+            throw new Error(
+
+              `Patient with ID ${id} already exists in database.`,
+            );
+          }
 
-        const newPatientData = {};
+          const newPatientData = {};
 
-        for (const [key, value] of Object.entries(request.body)) {
-          if (value) newPatientData[key] = value.trim();
-          if (key === 'middleName' && value.length === 0) {
-            newPatientData[key] = null;
+          for (const [key, value] of Object.entries(request.body)) {
+            if (value) newPatientData[key] = value.trim();
+            if (key === 'middleName' && value.length === 0) {
+              newPatientData[key] = null;
+            }
+            if (key === 'dateOfBirth') newPatientData[key] = new Date(value);
           }
-          if (key === 'dateOfBirth') newPatientData[key] = new Date(value);
-        }
 
-        let patient = await tx.patient.create({
-          data: {
-            ...newPatientData,
-            createdById: userId,
-            updatedById: userId,
-          },
-        });
+          let patient = await tx.patient.create({
+            data: {
+              ...newPatientData,
+              createdById: userId,
+              updatedById: userId,
+            },
+          });
 
-        return patient;
-      });
+          return patient;
+        });
 
-      reply.code(StatusCodes.CREATED).send(newPatient);
+        reply.code(StatusCodes.CREATED).send(newPatient);
+      } catch (error) {
+        if (error.message.includes('already exists')) {
+          return reply.status(StatusCodes.CONFLICT).send({
+            message: error.message,
+          });
+        }
+        throw error;
+      }
     },
   );
 }