login feature improved for existing users

Author: anijitsao

src/dbRelated/logindDbOps.js

@@ -1,5 +1,41 @@
+// local dependencies
+import {
+  createConnectionToDB,
+  closeConnectionToDB,
+  selectDB,
+} from "../helpers/dbHelpers.js";
+import { sendResponse } from "../helpers/sendResponse.js";
+
+// all the db related process variables
+const { DB_NAME, COLLECTION_USER_STICKER } = process.env;
+
 const findUserFromDb = async (userInfo) => {
-  return true;
+  const client = await createConnectionToDB();
+
+  try {
+    // select the db, Collections are selected based on needs
+    const db = selectDB(client, DB_NAME);
+
+    const options = {
+      projection: {
+        _id: 0,
+        username: 1,
+        name: 1,
+      },
+    };
+
+    // query the collection for the specific  users
+    const data = await db
+      .collection(COLLECTION_USER_STICKER)
+      .findOne(userInfo, options);
+
+    // send the user info if present in DB
+    return data;
+  } catch (error) {
+    return { error: error.toString() };
+  } finally {
+    closeConnectionToDB(client);
+  }
 };
 
 export { findUserFromDb };

src/services/loginService.js

@@ -16,11 +16,17 @@ export async function loginHandler(event) {
     // if payload contains a valid username
     const userInfo = await findUserFromDb(payload);
 
+    if (!userInfo || !userInfo.username) {
+      return sendResponse(process.env.ERROR_CODE, {
+        message: userInfo?.error || "User is not present",
+      });
+    }
+
     // create token if a valid user found
     const token = createToken(payload);
 
     // send the  response
-    const res = { msg: "login successful" };
+    const res = { msg: "login successful", userInfo };
     return sendResponse(process.env.SUCCESS_CODE, res, token);
   } catch (error) {
     return sendResponse(process.env.ERROR_CODE, { error: error.toString() });