Fix/cart api

src/constants/errorMessages.ts

@@ -8,6 +8,7 @@ export const INVALID_TOKEN = 'Invalid token !';
 export const NOT_FOUND_GENERIC = 'Not found !';
 export const INVALID_OTP = 'Invalid or expired OTP !';
 export const ADD_CART_FAILED = 'Failed to add some models';
+export const DELETE_CART_FAILED = 'Failed to delete some models';
 export const MODEL_NOT_FOUND = 'This model does not exist';
 export const DELETE_MODEL_FAILED = 'Model deletion failed';
 export const UPDATE_MODEL_FAILED = 'Model update failed';

src/dtos/in/addCart.dto.ts

@@ -5,8 +5,8 @@ import { Static, Type } from '@sinclair/typebox';
 export const AddCartInputDto = Type.Object({
     models: Type.Array(
         Type.Object({
-            id: Type.String(),
-            quantity: Type.Number()
+            id: Type.String({ description: 'The id of the model to add to cart' }),
+            quantity: Type.Number({ minimum: 1, description: 'The number to add to cart' })
         })
     )
 });

src/dtos/in/delCart.dto.ts

@@ -0,0 +1,9 @@
+import { Static, Type } from '@sinclair/typebox';
+
+// See https://github.com/sinclairzx81/typebox
+
+export const DelCartInputDto = Type.Object({
+    models: Type.Array(Type.String(), { description: 'A list of model ids to delete from the cart' })
+});
+
+export type DelCartInputDto = Static<typeof DelCartInputDto>;

src/dtos/in/index.ts

@@ -5,6 +5,7 @@
 export * from './addCart.dto';
 export * from './auth.dto';
 export * from './defaultModel.dto';
+export * from './delCart.dto';
 export * from './order.dto';
 export * from './paypal.dto';
 export * from './register.dto';

src/handlers/cart.handler.ts

@@ -1,7 +1,7 @@
 import { Handler } from '@interfaces';
-import { AddCartInputDto } from '@dtos/in';
+import { AddCartInputDto, DelCartInputDto } from '@dtos/in';
 import { prisma } from '@repositories';
-import { ADD_CART_FAILED } from '@constants';
+import { ADD_CART_FAILED, DELETE_CART_FAILED } from '@constants';
 import { GetCartResultDto } from '@dtos/out';
 
 const get: Handler<GetCartResultDto> = async (req, res) => {
@@ -36,23 +36,25 @@ const add: Handler<string, { Body: AddCartInputDto }> = async (req, res) => {
     const { models } = req.body;
 
     try {
-        await models.forEach((model) =>
-            prisma.cart.upsert({
-                create: {
-                    model_id: model.id,
-                    user_id: user_id,
-                    quantity: model.quantity
-                },
-                update: {
-                    quantity: model.quantity
-                },
-                where: {
-                    user_id_model_id: {
+        await Promise.all(
+            models.map((model) =>
+                prisma.cart.upsert({
+                    create: {
                         model_id: model.id,
-                        user_id: user_id
+                        user_id: user_id,
+                        quantity: model.quantity
+                    },
+                    update: {
+                        quantity: model.quantity
+                    },
+                    where: {
+                        user_id_model_id: {
+                            model_id: model.id,
+                            user_id: user_id
+                        }
                     }
-                }
-            })
+                })
+            )
         );
 
         return 'Added successfully';
@@ -61,7 +63,45 @@ const add: Handler<string, { Body: AddCartInputDto }> = async (req, res) => {
     }
 };
 
+const del: Handler<string, { Body: DelCartInputDto }> = async (req, res) => {
+    const user_id = req.userId;
+    const { models } = req.body;
+
+    try {
+        await Promise.all(
+            models.map((model_id) =>
+                prisma.cart.delete({
+                    where: {
+                        user_id_model_id: {
+                            model_id,
+                            user_id
+                        }
+                    }
+                })
+            )
+        );
+
+        return 'Deleted successfully';
+    } catch (e) {
+        return res.badRequest(DELETE_CART_FAILED);
+    }
+};
+
+const delAll: Handler<string> = async (req) => {
+    const user_id = req.userId;
+
+    await prisma.cart.deleteMany({
+        where: {
+            user_id
+        }
+    });
+
+    return 'Reset cart successfully';
+};
+
 export const cartHandler = {
     get,
-    add
+    add,
+    del,
+    delAll
 };

src/routes/apis/cart.plugin.ts

@@ -1,4 +1,4 @@
-import { AddCartInputDto } from '@dtos/in';
+import { AddCartInputDto, DelCartInputDto } from '@dtos/in';
 import { GetCartResultDto } from '@dtos/out';
 import { cartHandler } from '@handlers';
 import { verifyToken, verifyUserRole } from '@hooks';
@@ -24,13 +24,39 @@ export const cartPlugin = createRoutes('Cart', [
         url: '',
         onRequest: [verifyToken, verifyUserRole(UserRole.CUSTOMER)],
         schema: {
-            summary: 'Add a model to the current user (based on jwt)',
+            summary: 'Add some models to the cart of the current user (based on jwt)',
             body: AddCartInputDto,
             response: {
                 200: Type.String(),
                 400: Type.String()
             }
         },
         handler: cartHandler.add
+    },
+    {
+        method: 'DELETE',
+        url: '',
+        onRequest: [verifyToken, verifyUserRole(UserRole.CUSTOMER)],
+        schema: {
+            summary: 'Reset the cart of the current user (based on jwt)',
+            response: {
+                200: Type.String()
+            }
+        },
+        handler: cartHandler.delAll
+    },
+    {
+        method: 'POST',
+        url: '/delete',
+        onRequest: [verifyToken, verifyUserRole(UserRole.CUSTOMER)],
+        schema: {
+            summary: 'Remove some models from the cart of the current user (based on jwt)',
+            body: DelCartInputDto,
+            response: {
+                200: Type.String(),
+                400: Type.String()
+            }
+        },
+        handler: cartHandler.del
     }
 ]);