commonroutesServer/controllers/userController.js

//File: controllers/userController.js
var mongoose = require('mongoose');
var userModel = mongoose.model('userModel');
var notificationModel  = mongoose.model('notificationModel');
var travelModel  = mongoose.model('travelModel');


/* */
var jwt = require('jsonwebtoken'); // used to create, sign, and verify tokens
var express = require("express");
var app = express();
var config = require('../config'); // get our config file
app.set('superSecret', config.secret); // secret variable

var crypto = require('crypto');
/* */

//POST - Insert a new User in the DB
exports.signup = function(req, res) {

    var user = new userModel({
        username: req.body.username,
        password: crypto.createHash('sha256').update(req.body.password).digest('base64'),
        description: req.body.description,
        avatar: req.body.avatar,
        email: req.body.email,
        phone: req.body.phone,
        telegram: req.body.telegram
    });
    if (user.username == undefined) {
        return res.status(500).jsonp("empty inputs");
    } else if (user.password == undefined) {
        return res.status(500).jsonp("empty inputs");
    } else if (user.email == undefined) {
        return res.status(500).jsonp("empty inputs");
    }

    user.save(function(err, user) {
        if (err) return res.send(500, err.message);

		exports.login(req, res);
    });
};


//POST - auth user
exports.login = function(req, res) {
    // find the user
    userModel.findOne({
        username: req.body.username
    })
    .select('+password')
    .exec(function(err, user) {

        if (err) throw err;

        if (!user) {
            res.json({
                success: false,
                message: 'Authentication failed. User not found.'
            });
        } else if (user) {

            req.body.password = crypto.createHash('sha256').update(req.body.password).digest('base64');

            // check if password matches
            if (user.password != req.body.password) {
                res.json({
                    success: false,
                    message: 'Authentication failed. Wrong password.'
                });
            } else {

                // if user is found and password is right
                // create a token
                var token = jwt.sign({foo: 'bar'}, app.get('superSecret'), {
                    //expiresInMinutes: 1440 // expires in 24 hours
                    //expiresIn: '60m'
                });
                user.token = token;
                user.save(function(err, user) {
                    if (err) return res.send(500, err.message);
                    //res.status(200).jsonp(travel);
                    console.log(user);
                    // return the information including token as JSON
                    user.password = "";
                    res.json({
                        success: true,
                        message: 'Enjoy your token!',
                        token: token,
                        user: user
                    });
                });

            }

        }

    });
};

//GET - Return all Users in the DB
exports.getAllUsers = function(req, res) {
    userModel.find()
        .limit(Number(req.query.pageSize))
        .skip(Number(req.query.pageSize) * Number(req.query.page))
        .exec(function (err, users) {
            if (err) return res.send(500, err.message);
            res.status(200).jsonp(users);
        });
};


exports.getUserById = function (req, res) {
    userModel.findOne({_id: req.params.userid})
    .lean()
    .populate('travels', 'title from to date type')
    .exec(function (err, user) {
        if (err) return res.send(500, err.message);
        if (!user) {
            res.json({success: false, message: 'User not found.'});
        } else if (user) {

            res.status(200).jsonp(user);
        }
    });
};
exports.getUserByToken = function (req, res) {
    userModel.findOne({'token': req.headers['x-access-token']})
    .lean()
    .populate('travels', 'title from to date')
    .exec(function (err, user) {
        if (err) return res.send(500, err.message);
        if (!user) {
            res.json({success: false, message: 'User not found.'});
        } else if (user) {

            res.status(200).jsonp(user);
        }
    });
};

exports.getTravelsByUserId = function (req, res) {
    travelModel.find(
        {
            user: req.params.userid
        }
    )
    .lean()
    .exec(function (err, travels) {
        if (err) return res.send(500, err.message);
        travelModel.find(
            {
                joins: req.params.userid
            }
        )
        .lean()
        .exec(function (err, joins) {
            if (err) return res.send(500, err.message);
            res.json({
                travels: travels,
                joins: joins
            });
        });
    });
};
exports.getUserLikes = function (req, res) {
    userModel.findOne({_id: req.params.userid})
    .lean()
    .populate('likes', 'username avatar description')
    .exec(function (err, user) {
        if (err) return res.send(500, err.message);
        if (!user) {
            res.json({success: false, message: 'User not found.'});
        } else if (user) {
            res.status(200).jsonp(user.likes);
        }
    });
};
exports.getNotifications = function (req, res) {
    userModel.findOne({'token': req.headers['x-access-token']})
    .lean()
    .populate('notifications')
    .exec(function (err, user) {
        if (err) return res.send(500, err.message);
        if (!user) {
            res.json({success: false, message: 'User not found.'});
        } else if (user) {

            res.status(200).jsonp(user.notifications);
        }
    });
};

exports.updateUser = function (req, res) {
    userModel.update({'token': req.headers['x-access-token']}, req.body,
        function (err) {
            if (err) return console.log(err);
            exports.getUserByToken(req, res);
        });
};

//DELETE - Delete a user with specified ID
exports.deleteUser = function(req, res) {
    userModel.findOne({'token': req.headers['x-access-token']})
    .exec(function(err, user) {
        user.remove(function(err) {
            if (err) return res.send(500, err.message);
            res.status(200).jsonp("deleted");
        })
    });
};
exports.likeUser = function(req, res) {
    userModel.findOne({'token': req.headers['x-access-token']})
    .exec(function (err, userL) {
        if (err) return res.send(500, err.message);
        if (!userL) {
            res.json({success: false, message: 'no user with that token, login again'});
        } else if (userL) {

            userModel.findOne({
                _id: req.params.userid,
                likes: {'$ne': userL._id}
            })
            .exec(function (err, user) {
                if (err) return res.send(500, err.message);
                if (!user) {
                    res.json({success: false, message: 'Like not posible, user not exist, or like was already done'});
                } else if (user) {
                    //res.status(200).jsonp(user);
                    var notification = new notificationModel({
                        concept: "like",
                        message: "user "+userL.username+" adds a like to you",
                        date: new Date(),
                        icon: 'like.png',
                        link: "users/" + user._id
                    });
                    notification.save(function(err, notification) {
                        if (err) return res.send(500, err.message);

                        user.likes.push(userL._id);
                        user.notifications.push(notification._id);
                        user.save(function(err, user) {
                            if (err) return res.send(500, err.message);

                            exports.getUserById(req, res);
                        });
                    });

                }//end of else if user
            });
        }//end of else if userL
    });
};
exports.unlikeUser = function(req, res) {
    userModel.findOne({'token': req.headers['x-access-token']})
    .exec(function (err, userL) {
        if (err) return res.send(500, err.message);
        if (!userL) {
            res.json({success: false, message: 'no user with that token, login again'});
        } else if (userL) {

            userModel.findOne({
                _id: req.params.userid,
                likes: userL._id
            })
            .exec(function (err, user) {
                if (err) return res.send(500, err.message);
                if (!user) {
                    res.json({success: false, message: 'Unlike not posible'});
                } else if (user) {
                    //res.status(200).jsonp(user);
                    var notification = new notificationModel({
                        concept: "like",
                        message: "user "+userL.username+" removes like on you",
                        date: new Date(),
                        icon: 'like.png',
                        link: "users/" + user._id
                    });
                    notification.save(function(err, notification) {
                        if (err) return res.send(500, err.message);

                        var indexOf= user.likes.indexOf(userL._id);
                        user.likes.splice(indexOf, 1);
                        user.notifications.push(notification._id);
                        user.save(function(err, user) {
                            if (err) return res.send(500, err.message);

                            exports.getUserById(req, res);
                        });
                    });

                }//end of else if user
            });
        }//end of else if userL
    });
};
/* fav */
exports.addFav = function(req, res) {
    var tokenuser;
    userModel.find({
        token: req.headers['x-access-token']
    }, function(err, users) {
        tokenuser = users[0];
    });
    userModel.findById(req.params.userId, function(err, user) {

        // first search if user have already said like
        var favRepeated = false;
        for (var i = 0; i < user.favs.length; i++) {
            if (user.favs[i].username == tokenuser.username) {
                favRepeated = true;
            }
        }
        console.log("favRepeated: " + favRepeated);
        if (favRepeated == false) {
            //fav
            var fav = {
                userId: tokenuser._id,
                username: tokenuser.username,
                avatar: tokenuser.avatar
            };
            user.favs.push(fav);

            //notification
            var notification = {
                concept: "like",
                otherusername: tokenuser.username,
                description: "user " + tokenuser.username + " favs you",
                date: new Date(),
                link: ""
            };
            user.notifications.push(notification);

            user.save(function(err, user) {
                if (err) return res.send(500, err.message);


                //once saved, send the users json to client
                userModel.find(function(err, users) {
                    if (err) res.send(500, err.message);
                    res.status(200).jsonp(users);
                });
            });
        } else {
            userModel.find(function(err, users) {
                if (err) res.send(500, err.message);
                res.status(200).jsonp(users);
            });
        }

    });
};
exports.doUnfav = function(req, res) {
    var tokenuser;
    userModel.find({
        token: req.headers['x-access-token']
    }, function(err, users) {
        tokenuser = users[0];
    });

    userModel.findById(req.params.userId, function(err, user) {
        for (var i = 0; i < user.favs.length; i++) {
            if (user.favs[i].username == tokenuser.username) {
                user.favs.splice(i, 1);
            }
        }

        user.save(function(err, travel) {
            if (err) return res.send(500, err.message);
            //res.status(200).jsonp(travel);
            userModel.find(function(err, users) {
                if (err) res.send(500, err.message);
                res.status(200).jsonp(users);
            });
        });
    });
};