fix:Added auth context and file upload during registration

backend/package.json

@@ -10,14 +10,16 @@
   },
   "type": "module",
   "dependencies": {
+    "axios": "^1.7.9",
     "bcrypt": "^5.1.1",
     "cloudinary": "^2.5.1",
     "cookie-parser": "^1.4.7",
     "cors": "^2.8.5",
     "dotenv": "^16.4.7",
     "express": "^4.21.2",
     "jsonwebtoken": "^9.0.2",
-    "mongoose": "^8.9.5",
+    "mongodb": "^6.13.0",
+    "mongoose": "^8.9.6",
     "mongoose-aggregate-paginate-v2": "^1.1.3",
     "multer": "^1.4.5-lts.1"
   },

backend/src/app.js

@@ -1,7 +1,7 @@
 import express from "express";
 import cors from "cors";
 import cookieParser from "cookie-parser";
-
+import axios from "axios";
 const app = express();
 
 app.use(
@@ -30,4 +30,15 @@ app.use("/users", userRouter);
 app.use("/assignments", assignmentRouter);
 app.use("/tasks", taskRouter);
 
+app.get('/quote', async (req, res) => {
+  try {
+    // Ensure you are hitting the correct API URL
+    const response = await axios.get("https://zenquotes.io/api/random");
+    res.json(response.data);
+  } catch (error) {
+    console.error("Error fetching quote from ZenQuotes API:", error);
+    res.status(500).json({ error: "Failed to fetch quote from ZenQuotes" });
+  }
+});
+
 export { app };

backend/src/controllers/assignment.controllers.js

@@ -3,7 +3,8 @@ import { ApiError } from "../utils/ApiError.js";
 import { ApiResponse } from "../utils/ApiResponse.js";
 import { asyncHandler } from "../utils/asyncHandler.js";
 import { uploadToCloud } from "../utils/cloudinary.js";
-
+import mongoose from "mongoose";
+import cloudinary from "cloudinary";
 const createAssignment = asyncHandler(async (req, res) => {
   const { title, description, due_date } = req.body;
 
@@ -31,6 +32,8 @@ const createAssignment = asyncHandler(async (req, res) => {
     user: req.user._id,
   });
 
+
+
   const assignmentFromDB = await Assignment.findById(assignment._id);
 
   if (!assignmentFromDB) {
@@ -63,7 +66,7 @@ const updateAssignment = asyncHandler(async (req, res) => {
   const { title, description, due_date } = req.body;
 
   // Validate ObjectId
-  if (!isValidObjectId(assignmentId)) {
+  if (!mongoose.Types.ObjectId.isValid(assignmentId)) {
     throw new ApiError(400, "Invalid Assignment ID");
   }
 

backend/src/controllers/message.controller.js

@@ -0,0 +1,93 @@
+import { User } from "../models/user.models.js";
+import Message from "../models/message.models.js";
+import { ApiError } from "../utils/ApiError.js";
+import { ApiResponse } from "../utils/ApiResponse.js";
+import { asyncHandler } from "../utils/asyncHandler.js";
+import { uploadToCloud } from "../utils/cloudinary.js";
+
+const getUsers = asyncHandler(async (req, res) => {
+  try {
+    const loggedUserId = req.user._id;
+
+    // Get all users except the logged in user
+    const filteredUsers = await User.find({
+      _id: { $ne: loggedUserId },
+    }).select("-password");
+
+    if (!filteredUsers) {
+      return res.status(404).json(new ApiResponse(404, null, "No users found"));
+    }
+
+    return res
+      .status(200)
+      .json(new ApiResponse(200, filteredUsers, "Users fetched"));
+  } catch (error) {
+    console.error("Error in getUsersForSidebar: ", error.message);
+    throw new ApiError(500, "Something went wrong while fetching users");
+  }
+});
+
+const getMessages = asyncHandler(async (req, res) => {
+  try {
+    const loggedUserId = req.user._id;
+    const receiverId = req.params.id;
+
+    // Fetching messages
+    const messages = await Message.find({
+      $or: [
+        { sender: loggedUserId, receiver: receiverId },
+        { sender: receiverId, receiver: loggedUserId },
+      ],
+    }).sort({ createdAt: 1 });
+
+    if (!messages) {
+      return res
+        .status(404)
+        .json(new ApiResponse(404, null, "No messages found"));
+    }
+
+    return res
+      .status(200)
+      .json(new ApiResponse(200, messages, "Messages fetched"));
+  } catch (error) {
+    console.error("Error in getMessages: ", error.message);
+    throw new ApiError(500, "Something went wrong while fetching messages");
+  }
+});
+
+const sendMessage = asyncHandler(async (req, res) => {
+  try {
+    const loggedUserId = req.user._id;
+    const receiverId = req.params.id;
+    const { text } = req.body;
+
+    let doc = null;
+    const file = req.file;
+    if (file) {
+      const localPath = file.path;
+      doc = await uploadToCloud(localPath);
+
+      if (!doc) {
+        throw new ApiError(400, "File couldn't be saved");
+      }
+    }
+
+    const message = await Message.create({
+      sender: loggedUserId,
+      receiver: receiverId,
+      text,
+      doc: doc ? doc.url : null,
+    });
+
+    if (!message) {
+      throw new ApiError(400, "Message couldn't be saved");
+    }
+
+    return res.status(201).json(new ApiResponse(201, message, "Message sent"));
+  } catch (error) {
+    console.error("Error in sendMessage: ", error.message);
+    throw new ApiError(500, "Something went wrong while sending message");
+  }
+});
+
+export { getUsers, getMessages, sendMessage };

backend/src/controllers/task.controller.js

@@ -1,3 +1,4 @@
+import mongoose from "mongoose";
 import { Task } from "../models/task.models.js";
 import { ApiError } from "../utils/ApiError.js";
 import { ApiResponse } from "../utils/ApiResponse.js";
@@ -47,7 +48,7 @@ const updateTask = asyncHandler(async (req, res) => {
   const { title, description, due_date } = req.body;
 
   // Validate ObjectId
-  if (!isValidObjectId(taskId)) {
+  if (!mongoose.Types.ObjectId.isValid(taskId)) {
     throw new ApiError(400, "Invalid Task ID");
   }
 

backend/src/models/message.models.js

@@ -0,0 +1,27 @@
+import mongoose, { Schema } from "mongoose";
+
+const messageSchema = new Schema(
+  {
+    senderId: {
+      type: mongoose.Schema.Types.ObjectId,
+      ref: "User",
+      required: true,
+    },
+    receiverId: {
+      type: mongoose.Schema.Types.ObjectId,
+      ref: "User",
+      required: true,
+    },
+    text: {
+      type: String,
+    },
+    image: {
+      type: String, //URL 😏
+    },
+  },
+  { timestamps: true }
+);
+
+const Message = mongoose.model("Message", messageSchema);
+
+export default Message;

backend/src/routes/assignment.routes.js

@@ -1,5 +1,5 @@
 import { Router } from "express";
-import { verifyJWT } from "../middlewares/auth.middleware";
+import {verifyJWT} from "../middlewares/auth.middleware.js";
 import { upload } from "../middlewares/multer.middleware.js";
 import {
   createAssignment,

backend/src/routes/message.routes.js

@@ -0,0 +1,17 @@
+import { Router } from "express";
+import { verifyJWT } from "../middlewares/auth.middleware.js";
+import {
+  getUsers,
+  getMessages,
+  sendMessage,
+} from "../controllers/message.controller.js";
+import { upload } from "../middlewares/multer.middleware.js";
+
+const router = Router();
+
+router.get("/users", verifyJWT, getUsers);
+router.get("/:id", verifyJWT, getMessages);
+
+router.post("/send/:id", verifyJWT, upload.single("img"), sendMessage);
+
+export default router;

backend/src/routes/task.routes.js

@@ -1,5 +1,5 @@
 import { Router } from "express";
-import { verifyJWT } from "../middlewares/auth.middleware";
+import { verifyJWT } from "../middlewares/auth.middleware.js";
 import {
   createTask,
   getUserTasks,