Merge pull request #11 from anshulk/simple-crud

CrudController, TaskComment Crud

Author: dev-ashishk

server/config/Multer.js

@@ -8,7 +8,6 @@ const init = () => {
         destination: (req, file, callback) => {
             callback(null, path.resolve(__dirname, "../upload"));
         },
-        // eslint-disable-next-line consistent-return
         filename: (req, file, callback) => {
             const match = ["image/png", "image/jpeg", "image/jpg"];
 
@@ -17,7 +16,7 @@ const init = () => {
                 return callback(message, null);
             }
             const filename = `${Date.now()}-${req.query.taskId}-${file.originalname}`;
-            callback(null, filename);
+            return callback(null, filename);
         }
     });
     const upload = multer({ storage }).array("files");

server/controllers/CrudController.js

@@ -0,0 +1,122 @@
+class CrudController {
+    PAGE_SIZE = 10
+    LIMIT = 10
+
+    constructor(model) {
+        this.model = model;
+    }
+
+    create = async (req, res) => {
+        const data = await this.model.create(req.body);
+        return res.send({
+            data
+        });
+    }
+
+    list = async (req, res) => {
+        try {
+            const sort_by_string = req.query.sort_by;
+            delete req.query.sort_by;
+
+            const limit = req.query.limit || this.LIMIT;
+            delete req.query.limit;
+
+            const page = parseInt(req.query.page) || 1;
+            delete req.query.page;
+
+            const skip = (page - 1) * this.PAGE_SIZE;
+
+            for (let [key, value] of Object.entries(req.query)) {
+                req.query[key] = Mongoose.Types.ObjectId.isValid(value)
+                    ? Mongoose.Types.ObjectId(value)
+                    : value;
+            }
+
+            const sort_by = sort_by_string.split(' ').reduce((acc, item) => {
+                if (item.charAt(0) == '-') {
+                    acc[item.slice(1, item.length)] = -1
+                } else {
+                    acc[item] = 1
+                }
+                return acc;
+            }, {})
+
+            console.log(sort_by);
+
+            const result = await this.model.aggregate([{
+                $facet: {
+                    data: [
+                        { $match: req.query },
+                        { $skip: skip },
+                        { $limit: limit },
+                        { $sort: sort_by }
+                    ],
+                    totalCount: [
+                        { $match: req.query },
+                        { $count: 'count' }
+                    ]
+                }
+            }])
+
+            const [{ data }] = result;
+            let [{ totalCount }] = result;
+            let [{ count }] = totalCount;
+
+            console.log(totalCount, count);
+
+            return res.send({
+                page_size:this.PAGE_SIZE,
+                count,
+                page,
+                data,
+                count
+            });
+        } catch (error) {
+            return res.status(500).send({
+                'error': error.message
+            });
+        }
+    }
+
+    get = async (req, res) => {
+        const id = req.params.id;
+        const data = await this.model.findById(id);
+        return res.send({
+            error: false,
+            data,
+            message: "OK"
+        });
+    }
+
+    update = async (req, res) => {
+        try {
+            const id = req.params.id;
+            const new_data = req.body;
+            await this.model.findByIdAndUpdate(id, new_data);
+            const data = await this.model.findById(id);
+            return res.send({
+                data
+            });
+        } catch (error) {
+            return res.status(500).send({
+                'error': error.message
+            });
+        }
+    }
+
+    delete = async (req, res) => {
+        try {
+            const id = req.params.id;
+            let data = await this.model.findByIdAndRemove(id);
+            return res.send({
+                data
+            })
+        } catch (error) {
+            return res.status(500).send({
+                'error': error.message
+            });
+        }
+    }
+}
+
+module.exports = CrudController;

server/controllers/TaskCommentController.js

@@ -0,0 +1,3 @@
+const CrudController = require("./CrudController");
+
+module.exports = new CrudController(TaskComment);

server/routes/TaskComment.js

@@ -0,0 +1,27 @@
+module.exports = [
+    {
+        type: "GET",
+        path: "/",
+        handlers: ["TaskCommentController.list"]
+    },
+    {
+        type: "POST",
+        path: "/",
+        handlers: ["TaskCommentController.create"]
+    },
+    {
+        type: "GET",
+        path: "/:id",
+        handlers: ["TaskCommentController.get"]
+    },
+    {
+        type: "DELETE",
+        path: "/:id",
+        handlers: ["TaskCommentController.delete"]
+    },
+    {
+        type: "PATCH",
+        path: "/:id",
+        handlers: ["TaskCommentController.update"]
+    }
+];