feat: Added blog module, api and controller

Author: kdhttps

src/blog/blog.controller.js

@@ -0,0 +1,53 @@
+const httpStatus = require('http-status');
+const blog = require('./blog.helper');
+const { handleCatch } = require('../utils/common');
+
+function search(req, res) {
+  blog.getBlogBySearch(req.body)
+    .then(blogs => {
+      return res.send(blogs);
+    })
+    .catch(error => handleCatch(error, res));
+}
+
+function get(req, res) {
+  blog.getAllBlogs()
+    .then(blogs => {
+      return res.send(blogs);
+    })
+    .catch(error => handleCatch(error, res));
+}
+
+function add(req, res) {
+  blog.addBlog(req.body)
+    .then(blog => {
+      return res.send(blog);
+    })
+    .catch(error => handleCatch(error, res));
+}
+
+function update(req, res) {
+  blog.updateBlog(req.body, req.params.id)
+    .then(blog => {
+      return res.send(blog);
+    })
+    .catch(error => handleCatch(error, res));
+}
+
+function remove(req, res) {
+  blog.removeBlog(req.params.id)
+    .then(blog => {
+      return res.send(blog);
+    })
+    .catch(error => {
+      return res.status(httpStatus.INTERNAL_SERVER_ERROR).send(error);
+    });
+}
+
+module.exports = {
+  search,
+  get,
+  add,
+  update,
+  remove,
+};

src/blog/blog.helper.js

@@ -0,0 +1,122 @@
+const blog = require('./blog.model');
+
+/**
+ * Get all active blogs
+ * @return {blogs} - return all blogs
+ * @return {err} - return error
+ */
+let getBlogBySearch = (params) => {
+  return blog
+    .search(params)
+    .then((blogs) => Promise.resolve(blogs))
+    .catch((err) => Promise.reject(err));
+};
+
+/**
+ * Get all active blogs
+ * @return {blogs} - return all blogs
+ * @return {err} - return error
+ */
+let getAllBlogs = () => {
+  return blog
+    .find({})
+    .sort({title: 1})
+    .exec()
+    .then((blogs) => Promise.resolve(blogs))
+    .catch((err) => Promise.reject(err));
+};
+
+/**
+ * Get blog by Id
+ * @param {ObjectId} id - blog id
+ * @return {blog} - return blog
+ * @return {err} - return error
+ */
+let getBlogById = (id) => {
+  return blog
+    .findById(id)
+    .exec()
+    .then((blog) => Promise.resolve(blog))
+    .catch((err) => Promise.reject(err));
+};
+
+/**
+ * Get blog by title
+ * @param {String} title - blog title
+ * @return {blogs} - return blog
+ * @return {err} - return error
+ */
+let getBlogByName = (title) => {
+  return blog
+    .findOne({
+      title: new RegExp('^' + title + '$', "i")
+    })
+    .exec()
+    .then((blog) => Promise.resolve(blog))
+    .catch((err) => Promise.reject(err));
+};
+
+/**
+ * Add blog
+ * @param {object} req - Request json object
+ * @return {blog} - return blog
+ * @return {err} - return error
+ */
+let addBlog = (req) => {
+  let oBlog = new blog();
+  oBlog.title = req.title;
+  oBlog.content = req.content;
+
+  return oBlog.save()
+    .then(blog => Promise.resolve(blog))
+    .catch(err => Promise.reject(err));
+};
+
+/**
+ * Update blog
+ * @param {object} req - Request json object
+ * @return {blog} - return blog
+ * @return {err} - return error
+ */
+let updateBlog = (req, id) => {
+  return blog
+    .findById(id)
+    .exec()
+    .then((oBlog) => {
+      oBlog.title = req.title || oBlog.title;
+      oBlog.content = req.content || oBlog.content;
+      return oBlog.save()
+        .then(updatedBlog => Promise.resolve(updatedBlog))
+        .catch(err => Promise.reject(err));
+    })
+    .catch(err => Promise.reject(err));
+};
+
+/**
+ * Remove blog by Id
+ * @param {ObjectId} id - blog id
+ * @return {blog} - return blog
+ * @return {err} - return error
+ */
+let removeBlog = (id) => {
+  return blog
+    .findById(id)
+    .exec()
+    .then((oBlog) => {
+      return oBlog
+        .remove()
+        .then((rBlog) => Promise.resolve(rBlog))
+        .catch(err => Promise.reject(err));
+    })
+    .catch(err => Promise.reject(err));
+};
+
+module.exports = {
+  getAllBlogs,
+  getBlogById,
+  getBlogByName,
+  addBlog,
+  updateBlog,
+  removeBlog,
+  getBlogBySearch
+};

src/blog/blog.model.js

@@ -0,0 +1,48 @@
+const mongoose = require('mongoose');
+
+// define the schema for our blog
+const blogSchema = mongoose.Schema({
+  title: {
+    type: String,
+    required: true,
+    unique: true
+  },
+  content: {
+    type: String
+  }
+}, {
+  timestamps: true
+});
+
+blogSchema.statics = {
+  search(params) {
+    //count documents https://stackoverflow.com/questions/43925662/mongoose-pagination-from-server-side
+
+    return this.count({})
+      .then((count) => {
+        if (count === 0) {
+          return Promise.reject({msg: 'No Document in Database..'});
+        }
+        return Promise.resolve(count);
+      })
+      .then((count) => {
+        //get paginated documents
+        return this.find().skip(params.pagination.start).limit(params.pagination.number).exec().then(function (docs) {
+          if (!docs) {
+            return Promise.reject({msg: 'No Document in Database..'});
+          } else {
+            const result = {
+              totalRecords: count,
+              numberOfPages: Math.ceil(count / params.pagination.number),
+              data: docs
+            };
+            return Promise.resolve(result);
+          }
+        });
+      })
+      .catch((err) => Promise.reject(err));
+  }
+};
+
+// create the model for badgeCategory and expose it to our app
+module.exports = mongoose.model('Blog', blogSchema);

src/blog/blog.route.js

@@ -0,0 +1,19 @@
+/**
+ * Created by KD
+ */
+const express = require('express');
+const router = express.Router();
+const blogController = require('./blog.controller');
+
+router.route('/')
+  .get(blogController.get)
+  .post(blogController.add);
+
+router.route('/:id')
+  .put(blogController.update)
+  .delete(blogController.remove);
+
+router.route('/search')
+  .post(blogController.search);
+
+module.exports = router;

src/index.js

@@ -10,6 +10,9 @@ const expressJwt = require('express-jwt');
 
 const server = require('http').Server(app);
 
+// Logger
+app.use(morgan('combined'));
+
 // MongoDB connection configuration
 mongoose.Promise = global.Promise;
 mongoose.connect(process.env.DB_URL, {useUnifiedTopology: true,  useNewUrlParser: true}, (err, res) => {
@@ -25,9 +28,6 @@ app.set('port', process.env.PORT || 8000);
 // Allow cross origin
 app.use(cors());
 
-// Logger
-app.use(morgan('combined'));
-
 // Validate each call before route
 app.use('/', function (err, req, res, next) {
   next();

src/index.route.js

@@ -2,6 +2,8 @@ const express = require('express');
 const router = express.Router();
 const todo = require('./todo/todo.route');
 const auth = require('./auth/auth.route');
+const blog = require('./blog/blog.route');
+
 /**
  * Default route.
  */
@@ -11,5 +13,6 @@ router.get('/health-check', (req, res) => res.status(200).send({
 
 router.use('/login', auth);
 router.use('/todo', todo);
+router.use('/blog', blog);
 
 module.exports = router;