RESTFUL API

BASIC RESTFUL API WITH MONGODB, NODEJS AND EXPRESS

Author: Nazehs

controllers/productController.js

@@ -0,0 +1,99 @@
+const mongoose = require("mongoose");
+const product = require("../models/products");
+const productinstance = require("../models/productinstance");
+
+// fetcing all documents from our db
+exports.get_all_products = (req, res, next) => {
+  product.find().then(results => {
+    res
+      .status(200)
+      .send({
+        products: results
+      })
+      
+  }).catch(next);;
+};
+
+// creating a new document
+
+// exports.create_document = (req, res, next) => {
+//   product.create(req.body).
+//     then(result => {
+//       res
+//         .status(200)
+//         .send({
+//           result: result,
+//           created: true
+//         })
+        
+//     }).catch(next);
+// };
+
+exports.create_document = (req, res, next) => {
+    product
+      .create(req.body)
+      .then(product => {
+        res.status(200).send({ product: product, create: true });
+      })
+      .catch(next);
+    // var product = new Products({
+    //   _id:new mongoose.Types.ObjectId(),
+    //   req:req.body
+    // });
+    // product.save((err)=> {
+    //   if(err) return next(err);
+    // });
+  };
+
+// fetching a single a document details
+exports.get_single_product = (req, res, next) => {
+  product.findById(req.params._id).then(product => {
+    res
+      .status(200)
+      .send({
+        product: product
+      })
+      
+  }).catch(next);;
+};
+
+// dleting a single document
+exports.delete_single_document = (req, res, next) => {
+  product.findByIdAndRemove({_id: req.params._id}).then(result => {
+    res
+      .status(200)
+      .send({
+        result: result,
+        deleted: true
+      })
+      
+  }).catch(next);;
+};
+
+// update a single a document
+exports.update_document = (req, res, next) => {
+  product
+    .findOneAndUpdate({ _id: req.params._id }, req.body)
+    .then(() => {
+      product.findOne({ _id: req.params._id }).then(result => {
+        res
+          .status(200)
+          .send({
+            result: result,
+            update: true
+          })
+          .catch(next);
+      });
+    })
+    .catch(next);
+};
+
+//delete all documents
+
+exports.delete_all =(req,res,next)=>{
+    product.remove({}).then((results)=>{
+        res.status(200).send({
+            result:results, deleted:true
+        })
+    }).catch(next);
+}

controllers/productinstanceController.js

@@ -0,0 +1,83 @@
+const mongoose = require("mongoose");
+const product = require("../models/products");
+const productinstance = require("../models/productinstance");
+
+// fetcing all documents from our db
+exports.get_all_productinstance = (req, res, next) => {
+    productinstance.find().populate('product').then(results => {
+    res
+      .status(200)
+      .send({
+        productsinstance: results
+      })
+      
+  }).catch(next);;
+};
+
+// creating a new document
+
+exports.create_instance_document = (req, res, next) => {
+    productinstance.create(req.body).
+    then(result => {
+      res
+        .status(200)
+        .send({
+          result: result,
+          created: true
+        })
+        
+    }).catch(next);;
+};
+
+// fetching a single a document details
+exports.get_single_product_instance = (req, res, next) => {
+    productinstance.findById(req.params._id).then(instance => {
+    res
+      .status(200)
+      .send({
+        product: instance
+      })
+      
+  }).catch(next);;
+};
+
+// dleting a single document
+exports.delete_single_document_instance = (req, res, next) => {
+    productinstance.findByIdAndRemove({_id: req.params._id}).then(result => {
+    res
+      .status(200)
+      .send({
+        result: result,
+        deleted: true
+      })
+      
+  }).catch(next);;
+};
+
+// update a single a document
+exports.update_document_instance = (req, res, next) => {
+    productinstance
+    .findOneAndUpdate({ _id: req.params._id }, req.body)
+    .then(() => {
+        productinstance.findOne({ _id: req.params._id }).then(result => {
+        res
+          .status(200)
+          .send({
+            result: result,
+            update: true
+          })
+          
+      })
+    })
+    .catch(next);
+};
+
+
+//delete all instance
+exports.delete_all =(req,res,next)=>{
+    productinstance.remove({}).then((results)=>{
+        res.status(200).send({
+            result:results, deleted:true
+        })
+    }).catch(next);
+}

index.js

@@ -1,18 +1,18 @@
 const express = require('express');
 const mongoose = require('mongoose');
 const bodyParser = require('body-parser');
-
-const url = "mongodb://localhost:27017/RestfulApi";
+const url =  'mongodb://localhost:27017/RestfulApi';
 
 mongoose.connect(url);
 
 const app = express();
+app.use(bodyParser.json());
 
 const productRouter = require('./routes/api');
 
-app.get('api/', productRouter);
+app.use('/api', productRouter);
+
 
-app.use(bodyParser.json());
 
 app.use((err,req,res,next)=>{
     console.log(err);
@@ -30,5 +30,4 @@ app.listen(PORT,(req,res,next)=>{
 });
 
 
-
 module.exports=app;

models/productinstance.js

@@ -4,6 +4,7 @@ const Schema = mongoose.Schema;
 
 const productSchema = new Schema({
   status: {
+    type:String,
     enum: ["Finished", "Available"],
     default: "Available",
     required: true

models/products.js

@@ -23,5 +23,5 @@ const productSchema = new Schema({
 });
 
 // export  the model
-module.exports = mongoose.model("product",productSchema);
+module.exports = mongoose.model("product", productSchema);
 

routes/api.js

@@ -5,10 +5,40 @@ const productInstance = require("../controllers/productinstanceController");
 const router = express.Router();
 
 // route for getting all products 
-router.get('/products', product.get_all_products)
+router.get('/products', product.get_all_products);
 
+//creating new document
+router.post('/products', product.create_document);
 
+//get a single document route
+router.get('/product/:_id', product.get_single_product);
 
+//update a single document route
+router.put('/product/:_id', product.update_document);
+
+//delete a document route
+router.delete('/product/:_id', product.delete_single_document);
+
+// delete all products
+router.delete('/product/', product.delete_all);
+
+// route for getting all products instance 
+router.get('/productinstance', productInstance.get_all_productinstance);
+
+//creating new document instance
+router.post('/productinstance', productInstance.create_instance_document);
+
+//get a single document route
+router.get('/productinstance/:_id', productInstance.get_single_product_instance);
+
+//update a single document route
+router.put('/productinstance/:_id', productInstance.update_document_instance);
+
+//delete a document route
+router.delete('/productinstance/:_id', productInstance.delete_single_document_instance);
+
+// delete all instance route
+router.delete('/productinstance/', productInstance.delete_all);
 
 
 module.exports=router;