Platzi master application backend node

package.json

@@ -7,7 +7,9 @@
     "cors": "^2.8.5",
     "dotenv": "^8.2.0",
     "express": "^4.17.1",
-    "mongodb": "^3.6.6"
+    "http-errors": "^1.8.0",
+    "mongodb": "^3.6.6",
+    "mongoose": "^5.12.10"
   },
   "devDependencies": {
     "jest": "^26.6.3",

src/app.js

@@ -1,12 +1,36 @@
 const express = require('express');
 const cors = require('cors');
+const mongoose = require('mongoose');
+const createError = require('http-errors');
+const productRoute = require('./routes/product.route');
+const categoryRoute = require('./routes/category.route');
+
+require('./db')();
 
 function createApp() { 
   const app = express();
   app.use(cors());
   app.use(express.json());
 
   // ADD YOUR ROUTES
+  app.use('/api/products/', productRoute);
+  app.use('/api/categories/', categoryRoute);
+
+  app.use((req,res,next) => {
+    next(createError(404,"Not Found"));
+  });
+
+  //Handling errors
+  app.use((err,req,res,next)=> {
+    res.status(err.status || 500);
+    res.send({
+      error: {
+        status: err.status || 500,
+        message: err.message
+      }
+    });
+  });
+
   return app;
 }
 

src/controllers/category.controller.js

@@ -0,0 +1,72 @@
+const createError = require('http-errors');
+const { Mongoose } = require('mongoose');
+
+const Category = require("../models/category.model");
+const Product = require("../models/product.model");
+
+module.exports = {
+    getAllCategories : async (req,res,next) => {
+        try{
+            const results = await Category.find({},{__v: 0 });
+            res.send(results);
+        }catch(error){
+            console.log(error.message);
+        }
+    },
+
+    findCategoryById : async (req,res,next)=> {
+        const id = req.params.id;
+        try {
+            const category = await Category.findById(id);
+            if(!category){
+                throw createError(404,"Category doesn't exist");
+            }
+            res.send(category);
+        } catch (error) {
+            console.log(error.message);
+            next(error);
+        }
+    },
+
+    createNewCategory: async (req,res,next)=> {
+        try{
+            const category = new Category(req.body);
+            const result  = await category.save();
+            res.status(201).send(result);
+        }catch(error){
+            console.log(error);
+        }
+    },
+
+    updateCategory: async (req,res,next)=> {
+        try {
+            const id = req.params.id;
+            const update = req.body;
+            const options = {new: true}
+            const result = await Category.findByIdAndUpdate(id, update, options);
+            res.send(result);
+        } catch (error) {
+           console.log(error);
+        }
+    },
+
+    deleteCategory: async (req,res,next)=> {
+        const id = req.params.id;
+        try {
+            const result = await Category.findByIdAndDelete(id);
+            res.status(200).send(true);
+        } catch (error) {
+           console.log(error);
+        }
+    },
+
+    getProductsByCategoryId: async (req,res,next) => {
+        const id = req.params.id;
+        try{
+            const results = await Product.find({categoryId: id },{__v:0});
+            res.send(results);
+        }catch(error){
+            console.log(error.message);
+        }
+    }
+};

src/controllers/product.controller.js

@@ -0,0 +1,61 @@
+const createError = require('http-errors');
+const { Mongoose } = require('mongoose');
+
+const Product = require("../models/product.model");
+
+module.exports = {
+    getAllProducts : async (req,res,next) => {
+        try{
+            const results = await Product.find({},{__v: 0 });
+            res.send(results);
+        }catch(error){
+            console.log(error.message);
+        }
+    },
+
+    findProductById : async (req,res,next)=> {
+        const id = req.params.id;
+        try {
+            const product = await Product.findById(id);
+            if(!product){
+                throw createError(404,"Product doesn't exist");
+            }
+            res.send(product);
+        } catch (error) {
+            console.log(error.message);
+            next(error);
+        }
+    },
+
+    createNewProduct: async (req,res,next)=> {
+        try{
+            const product = new Product(req.body);
+            const result  = await product.save();
+            res.status(201).send(result);
+        }catch(error){
+            console.log(error);
+        }
+    },
+
+    updateProduct: async (req,res,next)=> {
+        try {
+            const id = req.params.id;
+            const update = req.body;
+            const options = {new: true}
+            const result = await Product.findByIdAndUpdate(id, update, options);
+            res.send(result);
+        } catch (error) {
+           console.log(error);
+        }
+    },
+
+    deleteProduct: async (req,res,next)=> {
+        const id = req.params.id;
+        try {
+            const result = await Product.findByIdAndDelete(id);
+            res.status(200).send(true);
+        } catch (error) {
+           console.log(error);
+        }
+    }
+};

src/db.js

@@ -0,0 +1,19 @@
+const mongoose  = require("mongoose");
+
+const { config } = require('./config');
+
+module.exports = () => {
+  mongoose.
+  connect(config.dbConnection + "://" + config.dbHost,{
+  dbName: config.dbName,
+  user: config.dbUser,
+  pass: config.dbPassword,
+  useNewUrlParser: true,
+  useUnifiedTopology: true,
+  useFindAndModify: false
+})
+.then(()=>{
+    console.log('mongodb is connected')
+})
+.catch((err)=>console.log(err.message));
+}

src/models/category.model.js

@@ -0,0 +1,16 @@
+const mongoose = require('mongoose');
+const Schema = mongoose.Schema;
+
+const CategorySchema = new Schema({
+    name:{
+        type: String,
+        required: true
+    },
+    image:{
+        type: String,
+        required: true
+    }
+});
+
+const Category = mongoose.model('category', CategorySchema);
+module.exports = Category;

src/models/product.model.js

@@ -0,0 +1,19 @@
+const mongoose = require('mongoose');
+const Schema = mongoose.Schema;
+
+const ProductSchema = new Schema({
+    name:{
+        type: String,
+        required: true
+    },
+    price:{
+        type: Number,
+        required: true
+    },
+    description: String,
+    categoryId: String,
+    image: String
+});
+
+const Product = mongoose.model('product', ProductSchema);
+module.exports = Product;

src/routes/category.route.js

@@ -0,0 +1,19 @@
+const { request, response } = require('express');
+const express = require('express');
+const router = express.Router();
+
+const CategoryController = require('../controllers/category.controller');
+
+router.get('/', CategoryController.getAllCategories);
+
+router.get('/:id', CategoryController.findCategoryById);
+
+router.post('/', CategoryController.createNewCategory);
+
+router.put('/:id', CategoryController.updateCategory);
+
+router.delete('/:id', CategoryController.deleteCategory);
+
+router.get('/:id/products', CategoryController.getProductsByCategoryId);
+
+module.exports = router;

src/routes/product.route.js

@@ -0,0 +1,17 @@
+const { request, response } = require('express');
+const express = require('express');
+const router = express.Router();
+
+const ProductController = require('../controllers/product.controller');
+
+router.get('/', ProductController.getAllProducts);
+
+router.get('/:id', ProductController.findProductById);
+
+router.post('/', ProductController.createNewProduct);
+
+router.put('/:id', ProductController.updateProduct);
+
+router.delete('/:id', ProductController.deleteProduct);
+
+module.exports = router;