Khalil Azaiez Assignment Done

.env

@@ -0,0 +1,4 @@
+# DB #
+ DATABASE_URL = mongodb+srv://khalilazaiez:[email protected]/assignment1?retryWrites=true&w=majority
+ JWT_SECRET= SECRET#123
+ JWT_EXP= 10m

Helpers/error.js

@@ -0,0 +1,20 @@
+class ErrorHandler extends Error {
+    constructor(statusCode, message) {
+      super();
+      this.statusCode = statusCode;
+      this.message = message;
+    }
+  }
+  const handleError = (err, res) => {
+    const { statusCode, message } = err;
+    res.status(statusCode).json({ 
+      status: "error",
+      statusCode,
+      message
+    });
+  };
+  module.exports = {
+    ErrorHandler,
+    handleError
+  }
+

app.js

@@ -0,0 +1,72 @@
+require("./config/config");
+require("./config/passportConfig");
+const { handleError } = require("./helpers/error");
+
+if (process.env.NODE_ENV !== "production") {
+  require("dotenv").config();
+}
+const express = require("express");
+const app = express();
+const bodyParser = require("body-parser");
+const cors = require("cors");
+const rtsIndex = require("./routes/index.router");
+const passport = require("passport");
+
+const mongoose = require("mongoose");
+mongoose.connect(process.env.DATABASE_URL, { useNewUrlParser: true });
+const db = mongoose.connection;
+db.on("error", (error) => console.error(error));
+db.once("open", () => console.log("Connected to Mongoose"));
+
+// middleware
+app.use(bodyParser.json());
+app.use(cors());
+app.use("/api", rtsIndex);
+app.use(passport.initialize());
+app.use((err, req, res, next) => {
+  handleError(err, res);
+});
+
+app.listen(process.env.PORT || 3000);
+
+var userSchema = new mongoose.Schema({
+  email: {
+    type: String,
+    required: "Email can't be empty",
+    unique: true,
+  },
+  password: {
+    type: String,
+    required: "Password can't be empty",
+    minlength: [4, "Password must be atleast 4 character long"],
+  },
+  saltSecret: String,
+});
+
+// Custom validation for email
+userSchema.path("email").validate((val) => {
+  emailRegex = /^(([^<>()\[\]\\.,;:\s@"]+(\.[^<>()\[\]\\.,;:\s@"]+)*)|(".+"))@((\[[0-9]{1,3}\.[0-9]{1,3}\.[0-9]{1,3}\.[0-9]{1,3}\])|(([a-zA-Z\-0-9]+\.)+[a-zA-Z]{2,}))$/;
+  return emailRegex.test(val);
+}, "Invalid e-mail.");
+
+// Events
+userSchema.pre("save", function(next) {
+  bcrypt.genSalt(10, (err, salt) => {
+    bcrypt.hash(this.password, salt, (err, hash) => {
+      this.password = hash;
+      this.saltSecret = salt;
+      next();
+    });
+  });
+});
+
+// Methods
+userSchema.methods.verifyPassword = function(password) {
+  return bcrypt.compareSync(password, this.password);
+};
+
+userSchema.methods.generateJwt = function() {
+  return jwt.sign({ _id: this._id }, process.env.JWT_SECRET, {
+    expiresIn: process.env.JWT_EXP,
+  });
+};

config/config.json

@@ -0,0 +1,14 @@
+{
+  "development": {
+    "PORT": 3000,
+    "MONGODB_URL": "mongodb+srv://khalilazaiez:[email protected]/assignment1?retryWrites=true&w=majority",
+    "JWT_SECRET": "SECRET#123",
+    "JWT_EXP": "10m"
+  },
+  "production": {
+    "PORT": 80,
+    "MONGODB_URL": "mongodb+srv://khalilazaiez:[email protected]/assignment1?retryWrites=true&w=majority",
+    "JWT_SECRET": "SECRET#123",
+    "JWT_EXP": "2m"
+  }
+}

config/jwtHelper.js

@@ -0,0 +1,22 @@
+const jwt = require("jsonwebtoken");
+
+module.exports.verifyJwtToken = (req, res, next) => {
+  var token;
+  if ("authorization" in req.headers)
+    token = req.headers["authorization"].split(" ")[1];
+
+  if (!token)
+    return res.status(401).send({ auth: false, message: "No token provided." });
+  else {
+    jwt.verify(token, process.env.JWT_SECRET, (err, decoded) => {
+      if (err)
+        return res
+          .status(500) 
+          .send({ auth: false, message: "Token authentication failed." });
+      else {
+        req._id = decoded._id;
+        next();
+      }
+    });
+  }
+};

config/passportConfig.js

@@ -0,0 +1,20 @@
+const passport = require("passport");
+const localStrategy = require("passport-local").Strategy;
+const mongoose = require("mongoose");
+const User = require("../models/user.model");
+
+passport.use(
+  new localStrategy({ usernameField: "email" }, (username, password, done) => {
+    User.findOne({ email: username }, (err, user) => {
+      if (err) return done(err);
+      // unknown user
+      else if (!user)
+        return done(null, false, { message: "Email is not registered" });
+      // wrong password
+      else if (!user.verifyPassword(password))
+        return done(null, false, { message: "Wrong password." });
+      // authentication succeeded
+      else return done(null, user);
+    });
+  })
+);

controller/category.controller.js

@@ -0,0 +1,77 @@
+const mongoose = require("mongoose");
+const passport = require("passport");
+const _ = require("lodash");
+const Category = require("../models/category.model");
+const { handleError, ErrorHandler } = require("../helpers/error");
+
+module.exports.createCategory = async (req, res, next) => {
+  try{
+    var category = new Category();
+    category.name = req.body.name;
+    category.created_at = req.body.created_at;
+    category.updated_at = req.body.updated_at;
+    category.user_id = req.params.id;
+    category.save((err, doc) => {
+      if (!err) res.send(doc);
+      else {
+        return next(err);
+      }
+    });
+  }
+  catch(error){
+    if(error.status===500) error = new ErrorHandler(500,"Internal server error") 
+      next(error)
+  }
+}
+  module.exports.getCategory  = (req, res, next) => {
+    try{
+    Category .find({ user_id: req._id }, (err, category ) => {
+      if (category )
+        return res
+          .status(200)
+          .json({ status: true, category} );
+      else
+        return res.status(404).json({ status: false, message: "category  not found" });
+    });
+  }
+  catch(error){
+    if(error.status===500) error = new ErrorHandler(500,"Internal server error") 
+      next(error)
+  }
+}
+  module.exports.updateCategory  = (req, res, next) => {
+    try{
+    Category .findOneAndUpdate(
+      { _id: req.params.id },
+      { $set: { name: req.body.name } },
+      { $set:{note:req.body.note}},
+      { $set:{image: req.body.image} },
+      function(error, success) {
+        if (error) {
+          res.status(404).json({ status: false });
+        } else {
+          res.status(200).json({ status: true });
+        }
+      }
+    );
+  }catch(error){
+    if(error.status===500) error = new ErrorHandler(500,"Internal server error") 
+      next(error)
+  }
+}
+
+  module.exports.deleteCategory  = (req, res, next) => {
+    try{
+    Category .findOneAndDelete({ id: req.params.id }, function(error, success) {
+      if (error) {
+        res.status(404).json({ status: false });
+      } else {
+        res.status(200).json({ status: true });
+      }
+    });
+  }catch(error){
+    if(error.status===500) error = new ErrorHandler(500,"Internal server error") 
+      next(error)
+  }
+}
+

controller/item.controller.js

@@ -0,0 +1,82 @@
+const mongoose = require("mongoose");
+const passport = require("passport");
+const _ = require("lodash");
+const Item = require("../models/Item.model");
+const { handleError, ErrorHandler } = require("../helpers/error");
+
+module.exports.createItem = async (req, res, next) => {
+  try{
+  var item = new Item();
+  item.name = req.body.name;
+  item.category_id = req.params.category_id;
+  item.list_id = req.body.list_id;
+  item.note = req.body.note;
+  item.image = req.body.image;
+  item.created_at = req.body.created_at;
+  item.updated_at = req.body.updated_at;
+  item.user_id = req.params.user_id;
+  item.save((err, doc) => {
+    if (!err) res.send(doc);
+    else {
+      return next(err);
+    }
+  });
+}
+catch(error){
+  if(error.status===500) error = new ErrorHandler(500,"Internal server error") 
+    next(error)
+}
+}
+module.exports.getItems = (req, res, next) => {
+  try{
+  Item.find({ user_id: req._id }, (err, items) => {
+    if (items)
+      return res
+        .status(200)
+        .json({ status: true, items});
+
+    else
+      return res.status(404).json({ status: false, message: "item not found" });
+  });
+}
+catch(error){
+  if(error.status===500) error = new ErrorHandler(500,"Internal server error") 
+    next(error)
+}
+}
+module.exports.updateItem = (req, res, next) => {
+  try{
+  Item.findOneAndUpdate(
+    { _id: req.params.id },
+    { $set: { name: req.body.name } },
+    { $set:{note:req.body.note}},
+    { $set:{image: req.body.image} },
+    function(error, success) {
+      if (error) {
+        res.status(404).json({ status: false });
+      } else {
+        res.status(200).json({ status: true });
+      }
+    }
+  );
+}catch(error){
+  if(error.status===500) error = new ErrorHandler(500,"Internal server error") 
+    next(error)
+}
+}
+module.exports.deleteItem = (req, res, next) => {
+  try{
+  Item.findOneAndDelete({ _id: req.params.id }, function(error, success) {
+    if (error) {
+      res.status(404).json({ status: false });
+    } else {
+      res.status(200).json({ status: true });
+    }
+  });
+}
+catch(error){
+  if(error.status===500) error = new ErrorHandler(500,"Internal server error") 
+    next(error)
+}
+}
+