Reviews_BE

server/app.js

@@ -16,6 +16,7 @@ const messageRouter = require("./routes/message");
 const requestRouter = require("./routes/request");
 const notificationRouter = require("./routes/notification");
 const profileRouter = require("./routes/profile");
+const reviewRouter = require("./routes/review");
 
 const { json, urlencoded } = express;
 
@@ -45,6 +46,7 @@ app.use("/message", messageRouter);
 app.use("/request", requestRouter);
 app.use("/notification", notificationRouter);
 app.use("/profile", profileRouter);
+app.use("/review", reviewRouter);
 
 if (process.env.NODE_ENV === "production") {
     app.use(express.static(path.join(__dirname, "/client/build")));

server/controllers/review.js

@@ -8,29 +8,32 @@ const Review = require("../models/Review");
 // @Given parameters passed in, create a review.
 exports.createReview = asyncHandler(async (req, res, next) => {
   const userId = req.user.id;
-  const profileId = req.params.id;
-  const reviewData = req.body;
-
+
   if (!ObjectId(userId)) {
     return res.status(400).send(Error("User id is invalid"));
   }
 
+  if (userId === req.body.userId) {
+    return res.status(401).json({
+      error: "User is not authorized for reviewing their own profile"
+    });
+  }
+
   try {
-    const user = await User.findById(
-      userId
-    ).populate("profile");
-    const sitterProfile = await Profile.findById(profileId);
-    const newReview = new Review({
-      ...reviewData,
-      user: {
-        firstName: user.profile.firstName,
-        lastName: user.profile.lastName,
-        profileImg: user.profile.profileImg,
-      },
+    const newReview = new Review(req.body);
+    newReview.save((error, review) => {
+      if (error) {
+        return res.status(400).json({
+          error: "Error in saving the review",
+          message: error.message
+        });
+      }
+
+      return res.status(200).json({
+        success: "Review is submitted successfully."
+      })
+
     });
-    sitterProfile.review.push(newReview.id);
-    await newReview.save();
-    await sitterProfile.save();
     res.status(200).json({
       success: {
         review: newReview,
@@ -42,6 +45,26 @@ exports.createReview = asyncHandler(async (req, res, next) => {
   }
 });
 
+exports.getAvgUserReview = asyncHandler(async (req, res, next) => {
+  Review.aggregate(
+    [
+      { $group: { _id: "$userId", avgRating: { $avg: "$rating" } } }
+    ]
+  ).exec((error, reviews) => {
+    if (error) {
+      return res.status(400).json({
+        error: "error in getting reviews",
+        message: error.message
+      })
+    }
+
+    return res.status(200).json({
+      success: "Retrieved successfully",
+      reviews
+    })
+  })
+})
+
 // @route GET /review/:id
 // @Given profile id, get all reviews
 exports.getAllReviews = asyncHandler(async (req, res, next) => {

server/models/Review.js

@@ -1,23 +1,32 @@
 const mongoose = require("mongoose");
 
-const reviewSchema = new mongoose.Schema(
-  {
-    user: {
-      firstName: String,
-      lastName: String,
-      profileImg: String,
-    },
-    rating: {
-      type: Number,
-      min: 1,
-      max: 5,
-      required: true,
-    },
-    message: String,
+const { Schema } = mongoose;
+const { ObjectId } = Schema;
+
+const reviewSchema = new mongoose.Schema({
+  reviewerUserId: {
+    type: ObjectId,
+    ref: "user",
+    unique: true,
+    requried: true
+  },
+  userId: {
+    type: ObjectId,
+    ref: "user",
+    unique: true,
+    required: true
+  },
+  rating: {
+    type: Number,
+    min: 1,
+    max: 5,
+    required: true,
   },
-  {
-    timestamps: true,
+  requestId: {
+    type: ObjectId,
+    ref: "request",
+    required: true
   }
-);
+},{ timestamps: true });
 
 module.exports = Review = mongoose.model("review", reviewSchema);

server/routes/review.js

@@ -0,0 +1,10 @@
+const express = require('express');
+const router = express.Router();
+
+const protect = require('../middleware/auth');
+const { createReview, getAvgUserReview } = require('../controllers/review');
+
+router.post("/create", protect, createReview);
+router.get("/avg", protect, getAvgUserReview);
+
+module.exports = router;