Implemented user signin, signup, user searching

Author: foyzulkarim

src/domains/user/api.js

@@ -9,6 +9,7 @@ const {
   getById,
   updateById,
   deleteById,
+  followUser,
 } = require('./service');
 
 const {
@@ -56,6 +57,29 @@ const routes = () => {
     }
   );
 
+  router.get(
+    '/:id/follow',
+    logRequest({}),
+    validateRequest({ schema: idSchema, isParam: true }),
+    async (req, res, next) => {
+      const currentUserId = req.user._id;
+      try {
+        if (currentUserId === req.params.id) {
+          throw new AppError(
+            'Cannot follow yourself',
+            'Cannot follow yourself',
+            400
+          );
+        }
+
+        const result = await followUser(currentUserId, req.params.id);
+        res.status(200).json({ result });
+      } catch (error) {
+        next(error);
+      }
+    }
+  );
+
   router.post(
     '/',
     logRequest({}),

src/domains/user/schema.js

@@ -76,6 +76,20 @@ const schema = new mongoose.Schema({
     type: Boolean,
     default: false,
   },
+
+  // commitstreams related similar properties
+  csFollowers: [
+    {
+      id: { type: mongoose.Schema.Types.ObjectId },
+      date: { type: Date, default: Date.now },
+    },
+  ],
+  csFollowing: [
+    {
+      id: { type: mongoose.Schema.Types.ObjectId },
+      date: { type: Date, default: Date.now },
+    },
+  ],
 });
 schema.add(baseSchema);
 

src/domains/user/service.js

@@ -122,6 +122,47 @@ const getByGitHubId = async (id) => {
   } catch (error) {}
 };
 
+const followUser = async (followerId, followedId) => {
+  try {
+    // Check existing following status (Optimized)
+    const follower = await Model.findById(followerId);
+    const existingFollowing = follower.csFollowing.find((item) =>
+      item.id.equals(followedId)
+    );
+
+    if (existingFollowing) {
+      logger.info(
+        `followUser(): User ${followerId} is already following user ${followedId}`
+      );
+      return false;
+    }
+
+    // Perform the updates
+    const [followedUserUpdate, followerUserUpdate] = await Promise.all([
+      // Update csFollowers of the followed user
+      Model.findByIdAndUpdate(followedId, {
+        $push: { csFollowers: { id: followerId, date: Date.now() } }, // Add follow date
+      }),
+
+      // Update csFollowing of the follower user
+      Model.findByIdAndUpdate(followerId, {
+        $push: { csFollowing: { id: followedId, date: Date.now() } },
+      }),
+    ]);
+
+    logger.info(`followUser(): success`, {
+      followedId,
+      followedId,
+      followedUserUpdate,
+      followerUserUpdate,
+    });
+    return true;
+  } catch (error) {
+    logger.error(`followUser(): Failed to update follow status`, error);
+    throw new AppError(`Failed to update follow status`, error.message);
+  }
+};
+
 module.exports = {
   create,
   search,
@@ -130,4 +171,5 @@ module.exports = {
   updateById,
   deleteById,
   getByGitHubId,
+  followUser,
 };

src/libraries/error-handling/index.js

@@ -39,6 +39,7 @@ const errorHandler = {
       if (!appError.isTrusted) {
         terminateHttpServerAndExit();
       }
+      return appError;
     } catch (handlingError) {
       // No logger here since it might have failed
       process.stdout.write(

src/server.js

@@ -169,8 +169,15 @@ function defineErrorHandlingMiddleware(expressApp) {
       }
     }
 
-    errorHandler.handleError(error);
-    res.status(error?.HTTPStatus || 500).end();
+    const appError = await errorHandler.handleError(error);
+    res
+      .status(error?.HTTPStatus || 500)
+      .json(
+        { ...appError, errorMessage: appError.message } || {
+          message: 'Internal server error',
+        }
+      )
+      .end();
   });
 }