create route api product

Author: hafidzdev17

routers.js

@@ -1,5 +1,7 @@
 const express = require('express')
 const routers = express.Router();
+const client = require('./connection')
+const ObjectId = require('mongodb').ObjectId
 
 const multer = require('multer')
 const imageFilter = (req, file, cb) => {
@@ -31,8 +33,6 @@ routers.post('/register', upload.single('avatar'), (req, res) => {
     res.send({ name: name, avatar: avatar })
 })
 
-
-
 // req semua method
 routers.all('/universal', function (req, res) {
     res.send('request dengan method ' + req.method)
@@ -51,7 +51,143 @@ routers.get('/foods', (req, res) => {
     res.end();
 });
 
+// Route Products
+
+routers.get('/products', async (req, res) => {
+    if (client.isConnected()) {
+        const db = client.db('latihan')
+        const products = await db.collection("products").find().toArray()
+        if (products.length > 0) {
+            res.send({
+                status: 'success',
+                message: 'list products ditemukan',
+                data: products
+            })
+        } else {
+            res.send({
+                status: 'success',
+                message: 'list products tidak ditemukan',
+            })
+        }
+    } else {
+        res.send({
+            status: 'error',
+            message: 'koneksi database gagal'
+        })
+    }
+})
+
+routers.get('/products/:id', async (req, res) => {
+    if (client.isConnected()) {
+        const db = client.db("latihan");
+        const productId = await db.collection("products").findOne({
+            _id: ObjectId(req.params.id)
+        })
+        res.send({
+            status: "success",
+            message: "single products",
+            data: productId
+        })
+    } else {
+        res.send({
+            status: "error",
+            message: "Koneksi Database Gagal"
+        })
+    }
+})
+
+routers.post('/products', multer().none(), async (req, res) => {
+    if (client.isConnected()) {
+        const { name, price, stock, status } = req.body
+        const db = client.db('latihan')
+
+        const result = await db.collection('products').insertOne({
+            name: name,
+            price: price,
+            stock: stock,
+            status: status
+        })
+
+        if (result.insertedCount == 1) {
+            res.send({
+                status: "success",
+                message: "add products success",
+            })
+        } else {
+            res.send({
+                status: 'warning',
+                message: 'tambah product gagal',
+            })
+        }
+    } else {
+        res.send({
+            status: "error",
+            message: "Koneksi Database Gagal"
+        })
+    }
+})
+
+routers.put('/products/:id', multer().none(), async (req, res) => {
+    if (client.isConnected()) {
+        const { name, price, stock, status } = req.body
+        const db = client.db('latihan')
+
+        const result = await db.collection('products').updateOne(
+            { _id: ObjectId(req.params.id) },
+            {
+                $set: {
+                    name: name,
+                    price: price,
+                    stock: stock,
+                    status: status
+                },
+            }
+        )
+
+        if (result.matchedCount == 1) {
+            res.send({
+                status: "success",
+                message: "update products success",
+            })
+        } else {
+            res.send({
+                status: 'warning',
+                message: 'update product gagal',
+            })
+        }
+    } else {
+        res.send({
+            status: "error",
+            message: "Koneksi Database Gagal"
+        })
+    }
+})
+
+routers.delete('/products/:id', multer().none(), async (req, res) => {
+    if (client.isConnected()) {
+        const db = client.db('latihan')
+        const result = await db.collection('products').deleteOne(
+            { _id: ObjectId(req.params.id) },
+        )
+
+        if (result.deletedCount == 1) {
+            res.send({
+                status: "success",
+                message: "delete products success",
+            })
+        } else {
+            res.send({
+                status: 'warning',
+                message: 'delete product gagal',
+            })
+        }
+    } else {
+        res.send({
+            status: "error",
+            message: "Koneksi Database Gagal"
+        })
+    }
+})
 
-// kode routing lainnya
 
 module.exports = routers