Feat: listProduct and updateProduct routes (#17)

Author: macmiller87

src/controllers/productsController.js

@@ -1,13 +1,16 @@
+import { ProductsModelRepository } from "../models/productsModel.js";
 import { ProductsService } from "../services/productsService.js";
 import { Middleware } from "../utils/auth/middleware.js";
 import { decode } from "jsonwebtoken"
 import { once } from "node:events";
 
 export class ProductsController {
+    _productsModelRepository;
     _productsService;
     _userMiddleware;
 
-    constructor(productsService = new ProductsService, userMiddleware = new Middleware()) {
+    constructor(productsService = new ProductsService, userMiddleware = new Middleware(), productsModelRepository = new ProductsModelRepository()) {
+        this._productsModelRepository = productsModelRepository;
         this._productsService = productsService;
         this._userMiddleware = userMiddleware;
     }
@@ -61,4 +64,95 @@ export class ProductsController {
         return response.end(JSON.stringify({ message: checkToken }));
     }
 
+    async listProduct(request, response) {
+
+        const checkToken = await this._userMiddleware.ensureUserAuthenthicated(request, response);
+
+        if(checkToken === true) {
+
+            const url = request.url;
+            const splitUrl = url.split("/");
+            const productId = splitUrl[2];
+
+            if(productId === "") {
+                response.writeHead(401);
+                return response.end(JSON.stringify({ message: "Product ID must have a value !" }));
+            }
+
+            const findProductById = await this._productsService.listProduct(productId);
+
+            if(!findProductById) {
+                response.writeHead(404);
+                return response.end(JSON.stringify({ message: "Product not found !" }));
+            }
+
+            response.writeHead(200);
+            return response.end(JSON.stringify({
+                product: {
+                    product_id: findProductById.product_id,
+                    product_name: findProductById.product_name,
+                    price: findProductById.price,
+                    category: findProductById.category,
+                    createdAt: findProductById.createdAt
+                }
+            }));
+
+        }
+
+        response.writeHead(401);
+        return response.end(JSON.stringify({ message: checkToken }));
+    }
+
+    async updateProduct(request, response) {
+
+        const checkToken = await this._userMiddleware.ensureUserAuthenthicated(request, response);
+
+        if(checkToken === true) {
+
+            const url = request.url;
+            const splitUrl = url.split("/");
+            const product_id = splitUrl[2];
+
+            if(product_id === "") {
+                response.writeHead(401);
+                return response.end(JSON.stringify({ message: "Product ID must have a value !" }));
+            }
+
+            const { price } = JSON.parse(await once(request, "data"));
+
+            if(price === "") {
+                response.writeHead(401);
+                return response.end(JSON.stringify({ message: "Price must have a value !" }));
+
+            }else if(typeof(price) !== "number") {
+                response.writeHead(401);
+                return response.end(JSON.stringify({ message: "Price must be a float/decimal number !" }));
+            }
+
+            const findProductById = await this._productsModelRepository.findProductById(product_id);
+
+            if(!findProductById) {
+                response.writeHead(404);
+                return response.end(JSON.stringify({ message: "User not found !" }));
+            }
+
+            const updateProduct = await this._productsService.updateProduct(product_id, price);
+
+            response.writeHead(201);
+            return response.end(JSON.stringify({
+                product: {
+                    product_id: updateProduct.product_id,
+                    product_name: updateProduct.product_name,
+                    price: updateProduct.price,
+                    category: updateProduct.category,
+                    createdAt: updateProduct.createdAt
+                }
+            }));
+
+        }
+
+        response.writeHead(401);
+        return response.end(JSON.stringify({ message: checkToken }));
+    }
+
 }

src/models/productsModel.js

@@ -15,4 +15,37 @@ export class ProductsModelRepository {
         return create;
     }
 
+    async listProduct(product_id) {
+        const find = await this._database._prismaService.products.findUnique({
+            where: {
+                product_id: product_id
+            }
+        });
+
+        return find;
+    }
+
+    async updateProduct(product_id, price) {
+        const update = await this._database._prismaService.products.update({
+            where: {
+                product_id: product_id
+            },
+            data: {
+                price: price
+            }
+        });
+
+        return update;
+    }
+
+    async findProductById(product_id) {
+        const find = await this._database._prismaService.products.findUnique({
+            where: {
+                product_id: product_id
+            }
+        });
+
+        return find;
+    }
+
 }

src/routes/user.routes.js

@@ -38,6 +38,14 @@ export class UserRoutes {
             case "/createProduct":
                 await productController.createProduct(request, response);
                 break;
+
+            case "/listProduct/":
+                await productController.listProduct(request, response);
+                break;
+
+            case "/updateProduct/":
+                await productController.updateProduct(request, response);
+                break;
 
             default:
                 response.writeHead(404);

src/services/productsService.js

@@ -12,4 +12,14 @@ export class ProductsService {
         return create;
     }
 
+    async listProduct(product_id) {
+        const find =  await this._productsModelRepository.listProduct(product_id);
+        return find;
+    }
+
+    async updateProduct(product_id, price) {
+        const update = await this._productsModelRepository.updateProduct(product_id, price);
+        return update;
+    }
+
 }