Merge pull request #12 from Property-Search-Engine/feat/employee-bookings-interaction

Employee-Booking Interaction

Author: devmxhv

src/controllers/bookings-controller.js

@@ -74,5 +74,38 @@ async function updateBookingAddress(req, res, next) {
         next(err);
     }
 }
-
-module.exports = { getBookings, bookProperty, cancelBooking, updateBookingAddress };
+async function getBookingsByEmployeeId(req, res, next) {
+    const { eid } = req.params;
+    try {
+        const bookings = await db.Bookings
+            .find({ employeeId: eid })
+            .select("-__v -contactInfo")
+            .sort({ createdAt: -1 })
+            .lean()
+            .exec();
+        res.status(200).send({
+            data: bookings,
+            error: null
+        });
+    } catch (err) {
+        next(err);
+    }
+}
+async function setStatus(req, res, next) {
+    const { propertyId } = req.params;
+    const { status } = req.body;
+    try {
+        const booking = await db.Bookings
+            .findByIdAndUpdate(propertyId, { status }, { new: true })
+            .select("-__v -contactInfo")
+            .lean()
+            .exec();
+        res.status(200).send({
+            data: booking,
+            error: null
+        });
+    } catch (err) {
+        next(err);
+    }
+}
+module.exports = { getBookings, bookProperty, cancelBooking, updateBookingAddress, getBookingsByEmployeeId, setStatus };

src/middleware/stsauth-middleware.js

@@ -15,6 +15,9 @@ const updateBookingAddressSchema = Joi.object({
     state: Joi.string().trim().required(),
     country: Joi.string().trim().required(),
 });
+const setStatusSchema = Joi.object({
+    status: Joi.string().trim().required().valid("pending", "rejected", "accepted"),
+});
 
 async function validateNewBooking(req, res, next) {
     try {
@@ -33,5 +36,13 @@ async function validateUpdateBookingAddress(req, res, next) {
         next({ statusCode: 400, message: err.details });
     }
 }
+async function validateSetStatus(req, res, next) {
+    try {
+        req.body = await setStatusSchema.validateAsync(req.body);
+        next();
+    } catch (err) {
+        next({ statusCode: 400, message: err.details });
+    }
+}
 
-module.exports = { validateNewBooking, validateUpdateBookingAddress };
+module.exports = { validateNewBooking, validateUpdateBookingAddress, validateSetStatus };

src/middleware/validators/bookings-validator.js

@@ -1,20 +1,26 @@
 const { Router } = require("express");
 const auth = require("../middleware/auth-middleware");
 const validateJWT = require("../middleware/jwt-middleware");
-const { validateNewBooking, validateUpdateBookingAddress } = require("../middleware/validators/bookings-validator");
+const { validateNewBooking, validateUpdateBookingAddress, validateSetStatus } = require("../middleware/validators/bookings-validator");
 
 const bookingsRouter = Router();
 
 const {
     getBookings,
     cancelBooking,
     bookProperty,
-    updateBookingAddress
+    updateBookingAddress,
+    getBookingsByEmployeeId,
+    setStatus
 } = require("../controllers/bookings-controller");
 
 bookingsRouter.post("/", auth(), validateNewBooking, bookProperty);
 bookingsRouter.delete("/:propertyId", auth(), cancelBooking);
 bookingsRouter.get("/all", auth(), getBookings);
-bookingsRouter.patch("/:propertyId", validateUpdateBookingAddress, updateBookingAddress);
+bookingsRouter.get("/employees/:eid", validateJWT, getBookingsByEmployeeId);
+
+bookingsRouter.post("/:propertyId", validateJWT, validateSetStatus, setStatus);
+
+bookingsRouter.patch("/:propertyId", validateJWT, validateUpdateBookingAddress, updateBookingAddress);
 
 module.exports = bookingsRouter;