Add interestCategories Mutation

src/Type_Definitions/User_User.js

@@ -1,6 +1,7 @@
 import gql from 'graphql-tag';
 import commonDefs from './Common_Common.js';
 import skillDefs from './Skill_Skill.js';
+import categoryDefs from './Category_Category.js';
 
 const userDefs = gql`
   extend type Query {
@@ -58,6 +59,8 @@ const userDefs = gql`
     addSkill(data: AddSkillInput!): User!
     endorseSkill(data: EndorseSkillInput!): User!
     unEndorseSkill(data: EndorseSkillInput!): User!
+    addInterestCategories(data: InterestCategoriesInput!): User!
+    removeInterestCategories(data: InterestCategoriesInput!): User!
   }
 
   input EndorseSkillInput {
@@ -74,6 +77,11 @@ const userDefs = gql`
     content: String!
   }
 
+  input InterestCategoriesInput {
+    userId: ID!
+    categoryIds: [String]!
+  }
+
   input AddSkillInput {
     userId: ID!
     skillIds: [String]!
@@ -130,7 +138,9 @@ const userDefs = gql`
 
     biography: String
     userEndorsements: [Endorsement]
+    interestCategories: [Category]
   }
+  ${categoryDefs}
 
   type Endorsement {
     id: ID!

src/prisma/schema.prisma

@@ -61,6 +61,10 @@ model User {
 
   endorsementIds      String[]      @db.ObjectId
   endorsements Endorsement[] @relation(name: "endorser", fields: [endorsementIds], references: [id])
+
+  interestCategoryIds      String[]      @db.ObjectId
+  interestCategories Category[] @relation(name: "interest", fields: [interestCategoryIds], references: [id])
+
 }
 
 // model Notification {
@@ -167,6 +171,9 @@ model Category {
 
   posts            String[] @db.ObjectId
   category_to_post Post[]   @relation(fields: [posts], references: [id])
+
+  interestUserIds String[] @db.ObjectId 
+  category_to_user User[]   @relation(name: "interest", fields: [interestUserIds], references: [id])
 }
 
 model Album {

src/resolvers/Mutation/profile.js

@@ -40,6 +40,19 @@ const profileMutation = {
     if (!user) {
       throw Error('User is not existed');
     }
+
+    const existedSkills = await prisma.skill.findMany({
+      where: {
+        id: {
+          in: skillIds,
+        },
+      },
+    });
+
+    if (existedSkills.length !== skillIds.length) {
+      throw Error('Some of skill not existed');
+    }
+
     const userSkillIds = user.user_to_endorsement.map((each) => each.skillId);
 
     skillIds.forEach((id) => {
@@ -54,13 +67,6 @@ const profileMutation = {
       },
       data: {
         user_to_endorsement: {
-          // create: {
-          //   skill: {
-          //     connect: {
-          //       id: skillId,
-          //     },
-          //   },
-          // },
           create: skillIds.map((id) => {
             return {
               skill: {

src/resolvers/Mutation/user.js

@@ -39,6 +39,8 @@ const userMutation = {
     }
     return user;
   },
+
+  // TODO: Update delele User that lead to all records relate to user also be deleted
   deleteUser: async (parent, args, info) => {
     let user;
     try {
@@ -85,6 +87,72 @@ const userMutation = {
 
     return updatedUser;
   },
+
+  /**
+   * @param {*} parent
+   * @param {{data: {categoryIds: string[], userId: string}}} args
+   * @param {*} info
+   * @returns
+   */
+  addInterestCategories: async (parent, args, info) => {
+    const { categoryIds, userId } = args.data;
+
+    const user = await prisma.user.findUnique({
+      where: {
+        id: userId,
+      },
+      include: {
+        interestCategories: true,
+      },
+    });
+    if (!user) {
+      throw Error('User is not existed');
+    }
+
+    categoryIds.forEach((id) => {
+      if (user.interestCategoryIds.includes(id)) {
+        throw Error('User has already added this category to interest');
+      }
+    });
+
+    const existedCategories = await prisma.category.findMany({
+      where: {
+        id: {
+          in: categoryIds,
+        },
+      },
+    });
+
+    if (existedCategories.length !== categoryIds.length) {
+      throw Error('Some of category not existed');
+    }
+
+    return await prisma.user.update({
+      where: {
+        id: userId,
+      },
+      data: {
+        interestCategories: {
+          connect: categoryIds.map((id) => {
+            return {
+              id: id,
+            };
+          }),
+        },
+      },
+    });
+  },
+
+  /**
+   * @param {*} parent
+   * @param {{data: {categoryIds: string, userId: string}}} args
+   * @param {*} info
+   * @returns
+   */
+  // Todo done this
+  removeInterestCategories: async (parent, args, info) => {
+    throw Error('Not implement yet');
+  },
 };
 
 export default userMutation;

src/resolvers/Type/User___.js

@@ -53,6 +53,16 @@ const User = {
       },
     });
   },
+
+  interestCategories: async (parent, args, info) => {
+    return await prisma.category.findMany({
+      where: {
+        interestUserIds: {
+          has: parent.id,
+        },
+      },
+    });
+  },
 };
 
 export default User;