feat: add route for delete many

hmif-itb · May 19, 2024 · 26ccae3 · 26ccae3
1 parent 7615326
commit 26ccae3
Show file tree

Hide file tree

Showing 3 changed files with 101 additions and 5 deletions.
diff --git a/src/controllers/user-unsubscribe.controller.ts b/src/controllers/user-unsubscribe.controller.ts
@@ -16,6 +16,8 @@ import {
   deleteUserUnsubscribeCategoryRoute,
 } from '~/routes/user-unsubscribe.route';
 import {
+  DeleteListUserUnsubscribeCategoryResponseSchema,
+  DeleteUserUnsubscribeCategorySchema,
   GetUserUnsubscribeCategoryResponseSchema,
   PostUserUnsubscribeCategorySchema,
 } from '~/types/user-unsubscribe.types';
@@ -232,3 +234,84 @@ userUnsubscribeRouter.openapi(deleteUserUnsubscribeCategoryRoute, async (c) => {
     return c.json({ error: 'Something went wrong!' }, 500);
   }
 });
+
+userUnsubscribeRouter.openapi(deleteListUserUnsubscribeRoute, async (c) => {
+  const { id } = c.var.user;
+  const categoryIds = c.req.valid('json').categoryId;
+
+  try {
+    const existingCategories: string[] = [];
+    const checkExistingCategoryPromises: Array<
+      Promise<false | z.infer<typeof CategorySchema>>
+    > = [];
+
+    categoryIds.forEach((categoryId) => {
+      checkExistingCategoryPromises.push(isCategoryExists(db, categoryId));
+    });
+
+    const res = await Promise.allSettled(checkExistingCategoryPromises);
+    res.forEach((result) => {
+      if (result.status === 'fulfilled') {
+        if (result.value) {
+          existingCategories.push(result.value.id);
+        }
+      }
+    });
+
+    if (existingCategories.length === 0) {
+      return c.json({ error: 'All categories does not exist!' }, 400);
+    }
+
+    const notFoundCategories = categoryIds.filter(
+      (categoryId) => !existingCategories.includes(categoryId),
+    );
+
+    const deletePromises: Array<
+      Promise<z.infer<typeof DeleteUserUnsubscribeCategorySchema>>
+    > = [];
+
+    existingCategories.forEach((categoryId) => {
+      deletePromises.push(
+        deleteUserUnsubscribeCategory(
+          db,
+          {
+            userId: id,
+            categoryId,
+          },
+          id,
+        ),
+      );
+    });
+
+    const resDelete = await Promise.allSettled(deletePromises);
+    const deletedCategories: string[] = [];
+    const alreadySubscribedCategories: string[] = [];
+
+    resDelete.forEach((result) => {
+      if (result.status === 'fulfilled') {
+        if (result.value) {
+          deletedCategories.push(result.value.categoryId);
+        }
+      }
+    });
+
+    existingCategories.forEach((categoryId) => {
+      if (!deletedCategories.includes(categoryId)) {
+        alreadySubscribedCategories.push(categoryId);
+      }
+    });
+
+    const returnObj: z.infer<
+      typeof DeleteListUserUnsubscribeCategoryResponseSchema
+    > = {
+      userId: id,
+      categoryId: deletedCategories,
+      categoriesNotFound: notFoundCategories,
+      categoriesAlreadySubscribed: alreadySubscribedCategories,
+    };
+
+    return c.json(returnObj, 201);
+  } catch (e) {
+    return c.json({ error: 'Something went wrong!' }, 500);
+  }
+});
diff --git a/src/routes/user-unsubscribe.route.ts b/src/routes/user-unsubscribe.route.ts
@@ -6,16 +6,15 @@ import {
   ServerErrorSchema,
 } from '~/types/responses.type';
 import {
-  DeleteListUserUnsubscribeCategorySchema,
+  DeleteListUserUnsubscribeCategoryParamsSchema,
+  DeleteListUserUnsubscribeCategoryResponseSchema,
   DeleteUserUnsubscribeCategoryParamsSchema,
   DeleteUserUnsubscribeCategorySchema,
   GetListUserUnsubscribeCategorySchema,
   GetUserUnsubscribeCategoryParamsSchema,
   GetUserUnsubscribeCategoryResponseSchema,
-  GetUserUnsubscribeCategorySchema,
   PostListUserUnsubscribeCategoryParamsSchema,
   PostListUserUnsubscribeCategoryResponseSchema,
-  PostListUserUnsubscribeCategorySchema,
   PostUserUnsubscribeCategoryParamsSchema,
   PostUserUnsubscribeCategorySchema,
 } from '~/types/user-unsubscribe.types';
@@ -225,7 +224,7 @@ export const deleteListUserUnsubscribeRoute = createRoute({
     body: {
       content: {
         'application/json': {
-          schema: DeleteUserUnsubscribeCategoryParamsSchema,
+          schema: DeleteListUserUnsubscribeCategoryParamsSchema,
         },
       },
       required: true,
@@ -236,7 +235,7 @@ export const deleteListUserUnsubscribeRoute = createRoute({
       description: 'User is subscribed to all given categories',
       content: {
         'application/json': {
-          schema: DeleteListUserUnsubscribeCategorySchema,
+          schema: DeleteListUserUnsubscribeCategoryResponseSchema,
         },
       },
     },

diff --git a/src/types/user-unsubscribe.types.ts b/src/types/user-unsubscribe.types.ts
@@ -66,6 +66,10 @@ export const DeleteUserUnsubscribeCategoryParamsSchema = z.object({
   categoryId: z.string().openapi({ example: '1' }),
 });
 
+export const DeleteListUserUnsubscribeCategoryParamsSchema = z.object({
+  categoryId: z.array(z.string()).openapi({ example: ['1', '2', '3'] }),
+});
+
 // Response types
 export const GetUserUnsubscribeCategoryResponseSchema = z.object({
   ...GetUserUnsubscribeCategorySchema.shape,
@@ -84,3 +88,13 @@ export const PostListUserUnsubscribeCategoryResponseSchema = z.object({
     example: ['5', '6'],
   }),
 });
+
+export const DeleteListUserUnsubscribeCategoryResponseSchema = z.object({
+  ...DeleteListUserUnsubscribeCategorySchema.shape,
+  categoriesNotFound: z.array(z.string()).openapi({
+    example: ['3', '4'],
+  }),
+  categoriesAlreadySubscribed: z.array(z.string()).openapi({
+    example: ['5', '6'],
+  }),
+});