taskServer.js

var http = require('http');
var express = require('express');
var path = require('path');
var bodyParser = require('body-parser');
var jwt = require('jsonwebtoken');
const {
    celebrate,
    Joi,
    errors
} = require('celebrate');


var httpPort = 8091;
var app = express();
var mongoClient = require('mongodb').MongoClient;
var url = "mongodb://localhost:27017/taskDB";



//initi parser
app.use(bodyParser.json());
app.use(bodyParser.urlencoded({
    extended: true
}));

//For the use of celebrate
app.use(errors());

//Handles the request to add a new task for a specific user.
app.post('/addtask', celebrate({
    body: Joi.object({
        task: Joi.object().required(),
        token: Joi.string().required(),
    })
}), function(req, res) {
    var errSet = [];
    var token = req.body.token;

    jwt.verify(token, 'super_secret_passsword123', function(err, decoded) {
        if (err) {
            //Token is not valid
            errSet.push("Please log in to do this request");
            res.send({
                errorSet: errSet
            });
        } else {
            //token is valid.
            //Get the username which is signed from token. (Not encrypted!)
            var username = jwt.decode(token).user;
            var recievedTask = req.body.task;
            mongoClient.connect(url, function(err, db) {
                if (err) {
                    throw err;
                }
                newEntry = {
                    user: username,
                    task: recievedTask
                };
                db.collection("taskCollection").insertOne(newEntry, function(err, res) {
                    if (err) throw err;
                    db.close();
                });
            });
            res.send();
        }
    });
});

//Handles the request to delete task for a specific user.
app.post("/deletetask", celebrate({
    body: Joi.object({
        toDelete: Joi.object().required(),
        token: Joi.string().required(),
    })
}), function(req, res) {
    var errSet = [];
    var token = req.body.token;
    jwt.verify(token, 'super_secret_passsword123', function(err, decoded) {
        if (err) {
            //Token is not valid
            errSet.push("Please log in to see this page");
            res.send({
                errorSet: errSet
            });
        } else {
            //token is valid
            //Get the username which is signed from token. (Not encrypted!)

            var username = jwt.decode(token).user;
            mongoClient.connect(url, function(err, db) {
                if (err) {
                    errSet.push("INTERNAL_ERROR");
                    console.log("Unable to connect to mongoDB: " + err);
                } else {
                    //Ready to query
                    query = {
                        task: req.body.toDelete,
                        user: username
                    };
                    db.collection("taskCollection").deleteOne(query, function(err, obj) {
                        if (err) throw err;
                    });
                }
                db.close();
            });
        }
        res.send();
    });
});

//Handles the request to mark a certain task as done
app.post("/taskdone", celebrate({
    body: Joi.object({
        task: Joi.object().required(),
        token: Joi.string().required(),
    })
}), function(req, res) {
    var errSet = [];
    var token = req.body.token;
    jwt.verify(token, 'super_secret_passsword123', function(err, decoded) {
        if (err) {
            //Token is not valid
            errSet.push("Please log in to see this page");
            res.send({
                errorSet: errSet
            });
        } else {
            //token is valid
            var username = jwt.decode(token).user;

            mongoClient.connect(url, function(err, db) {
                if (err) {
                    errSet.push("INTERNAL_ERROR");
                    console.log("Unable to connect to mongoDB: " + err);
                } else {

                    query = {
                        task: req.body.task,
                        user: username
                    };
                    //clone the object
                    newTask = JSON.parse(JSON.stringify(req.body.task));
                    newTask.done = true;
                    newValue = {
                        $set: {
                            task: newTask
                        }
                    };
                    db.collection("taskCollection").updateOne(query, newValue, function(err, obj) {
                        if (err) throw err;
                    });
                }
                db.close();
            });
        }
        res.send();
    });
});

//Handles the request to send all tasks of one specific user.
app.post('/gettasks', celebrate({
    body: Joi.object({
        token: Joi.string().required(),
    })
}), function(req, res) {
    var errSet = [];
    var token = req.body.token;

    jwt.verify(token, 'super_secret_passsword123', function(err, decoded) {
        if (err) {
            //Token is not valid
            errSet.push("Please log in to see this page");
            res.send({
                tasks: {},
                errorSet: errSet
            });
        } else {
            //token is valid
            var username = jwt.decode(token).user;
            mongoClient.connect(url, function(err, db) {
                if (err) {
                    //TODO do everywhere like that instead of throw err;
                    errSet.push("INTERNAL_ERROR");
                    console.log("Unable to connect to mongoDB: " + err);
                } else {
                    db.collection("taskCollection").find({
                        user: username
                    }, {
                        user: false,
                        _id: false
                    }).toArray(function(err, result) {
                        if (err) throw err;
                        taskArray = [];
                        result.forEach(function(item, index) {
                            taskArray.push(item.task);
                        });
                        res.send({
                            tasks: taskArray,
                            errorSet: errSet
                        });
                    });
                }
                db.close();
            });
        }
    });
});


http.createServer(app).listen(httpPort, function() {
    console.log('Started taskServer!');
});