ft(relatedProducts):buyer should see related products

Author: JacquelineTuyisenge

src/__test__/product.test.ts

@@ -20,6 +20,7 @@ import { generateAccessToken } from "../helpers/security.helpers";
 import { read_function } from "../utils/db_methods";
 import { response } from "express";
 import searchProduct from "../controllers/searchProduct";
+import { Console } from "node:console";
 
 jest.setTimeout(100000);
 
@@ -35,6 +36,7 @@ function logErrors(
 
 const Jest_request = request(app.use(logErrors));
 let seller_token: string;
+let buyer_token: string;
 let category_id: string;
 let product_id: any;
 describe("PRODUCT API TEST", () => {
@@ -188,7 +190,6 @@ describe("PRODUCT API TEST", () => {
 		const { body } = await Jest_request.get(`/api/v1/products/${product_id}`)
 			.set("Authorization", `Bearer ${seller_token}`)
 			.expect(200);
-
 		expect(body.status).toStrictEqual("SUCCESS");
 		expect(body.message).toStrictEqual("Product fetched successfully!");
 		expect(body.data).toBeDefined();

src/controllers/productController.ts

@@ -13,6 +13,7 @@ import { insert_function, read_function } from "../utils/db_methods";
 import { category_utils } from "../utils/controller";
 import { Info, Message } from "../types/upload";
 import { isAvailable } from "../utils/nodeEvents";
+import { Op, OrderItem } from "sequelize";
 
 let product_id;
 const include = [
@@ -206,6 +207,7 @@ const read_single_product = async (req: Request, res: Response) => {
 					"Product not found or not owned!",
 				);
 			}
+
 			return sendResponse(
 				res,
 				200,
@@ -225,6 +227,57 @@ const read_single_product = async (req: Request, res: Response) => {
 	}
 };
 
+const getRecommendedProducts = async (req: Request, res: Response) => {
+	try {
+		const productId = req.params.id;
+		const product = await read_function<ProductAttributes>(
+			"Product",
+			"findOne",
+			{ where: { id: productId }, include },
+		);
+
+		if (!product) {
+			return sendResponse(
+				res,
+				404,
+				"NOT FOUND",
+				"Product not found or not owned!",
+			);
+		}
+
+		const condition = {
+			where: {
+				categoryId: product.categoryId,
+				isAvailable: true,
+				id: { [Op.ne]: productId },
+			},
+			include,
+			limit: 5,
+			order: [["createdAt", "DESC"]] as OrderItem[],
+		};
+		const recommended = await read_function<ProductAttributes>(
+			"Product",
+			"findAll",
+			condition,
+		);
+		return sendResponse(
+			res,
+			200,
+			"SUCCESS",
+			"Recommended Products fetched successfully!",
+			recommended,
+		);
+	} catch (error: unknown) {
+		return sendResponse(
+			res,
+			500,
+			"SERVER ERROR",
+			"Something went wrong!",
+			error as Error,
+		);
+	}
+};
+
 const update_product = async (req: Request, res: Response) => {
 	try {
 		product_id = category_utils(req, res).getId;
@@ -530,4 +583,5 @@ export default {
 	delete_product,
 	guest_read_all_products,
 	guest_read_single_product,
+	getRecommendedProducts,
 };

src/routes/productRoutes.ts

@@ -36,6 +36,12 @@ productRouter.get(
 	productController.read_single_product,
 );
 
+productRouter.get(
+	"/:id/recommended",
+	userAuthentication.authenticateUser,
+	productController.getRecommendedProducts,
+);
+
 productRouter.patch(
 	"/:id",
 	userAuthentication.isSeller,