You can not select more than 25 topics
Topics must start with a letter or number, can include dashes ('-') and can be up to 35 characters long.
518 lines
16 KiB
518 lines
16 KiB
//File: controllers/travelController.js
|
|
var mongoose = require('mongoose');
|
|
var userModel = mongoose.model('userModel');
|
|
var notificationModel = mongoose.model('notificationModel');
|
|
var travelModel = mongoose.model('travelModel');
|
|
var commentModel = mongoose.model('commentModel');
|
|
|
|
//GET
|
|
var pageSize=20;
|
|
exports.getAllTravels = function(req, res) {
|
|
//get travels with futures dates ($gte - greater than and equal than)
|
|
travelModel.find({date: {$gte: new Date()}})
|
|
.sort('date')
|
|
.limit(pageSize)
|
|
.skip(pageSize * Number(req.query.page))
|
|
.lean()
|
|
.populate('user', 'username avatar')
|
|
.exec(function (err, travels) {
|
|
if (err) return res.send(500, err.message);
|
|
res.status(200).jsonp(travels);
|
|
});
|
|
};
|
|
|
|
exports.getTravelById = function (req, res) {
|
|
travelModel.findOne({_id: req.params.travelid})
|
|
.lean()
|
|
.populate('user', 'username avatar telegram phone')
|
|
.populate('joins', 'username avatar')
|
|
.populate('joinPetitions', 'username avatar')
|
|
.populate('comments', 'comment user')
|
|
.exec(function (err, travel) {
|
|
if (err) return res.send(500, err.message);
|
|
if (!travel) {
|
|
res.json({success: false, message: 'travel not found.'});
|
|
} else if (travel) {
|
|
|
|
res.status(200).jsonp(travel);
|
|
}
|
|
});
|
|
};
|
|
|
|
exports.addTravel = function(req, res) {
|
|
userModel.findOne({'token': req.headers['x-access-token']})
|
|
.exec(function(err, user){
|
|
if (err) return res.send(500, err.message);
|
|
if (!user) {
|
|
console.log("user not found");
|
|
res.json({success: false, message: 'User not found.'});
|
|
} else if (user) {
|
|
var travel = new travelModel({
|
|
title: req.body.title,
|
|
description: req.body.description,
|
|
user: user._id,
|
|
from: req.body.from,
|
|
to: req.body.to,
|
|
date: req.body.date,
|
|
periodic: req.body.periodic,
|
|
generateddate: Date(),
|
|
seats: req.body.seats,
|
|
package: req.body.package,
|
|
collectivized: req.body.collectivized,
|
|
type: req.body.type
|
|
});
|
|
|
|
travel.save(function(err, travel) {
|
|
if(err) return res.send(500, err.message);
|
|
|
|
user.travels.push(travel._id);
|
|
user.save(function (err, user) {
|
|
if (err) return res.send(500, err.message);
|
|
exports.getAllTravels(req, res);
|
|
});
|
|
});//end of travel.save
|
|
}
|
|
});//end of usermodel.find
|
|
|
|
|
|
};
|
|
|
|
exports.updateTravel = function(req, res) {
|
|
userModel.findOne({'token': req.headers['x-access-token']})
|
|
.exec(function(err, user){
|
|
if (err) return res.send(500, err.message);
|
|
console.log(travel);
|
|
travelModel.findOne({_id: travel._id})
|
|
.lean()
|
|
.populate('travels', 'title from to date')
|
|
.exec(function (err, travel) {
|
|
if (err) return res.send(500, err.message);
|
|
if (!travel) {
|
|
res.json({success: false, message: 'travel not found.'});
|
|
} else if (travel) {
|
|
|
|
res.status(200).jsonp(travel);
|
|
}
|
|
});
|
|
});
|
|
};
|
|
|
|
//DELETE
|
|
exports.deleteTravel = function(req, res) {
|
|
userModel.findOne({'token': req.headers['x-access-token']})
|
|
.exec(function(err, user){
|
|
if (err) return res.send(500, err.message);
|
|
travelModel.findById(req.params.travelid, function(err, travel) {
|
|
if (err) return res.send(500, err.message);
|
|
if(travel.user.equals(user._id))
|
|
{
|
|
travel.remove(function(err) {
|
|
if(err) return res.send(500, err.message);
|
|
|
|
console.log("deleted");
|
|
exports.getAllTravels(req, res);
|
|
});
|
|
}
|
|
});
|
|
});
|
|
};
|
|
|
|
/* join */
|
|
exports.addJoinPetition = function(req, res) {
|
|
userModel.findOne({'token': req.headers['x-access-token']})
|
|
.exec(function(err, userJoining){
|
|
if (err) return res.send(500, err.message);
|
|
if (!userJoining) {
|
|
res.json({success: false, message: 'User not found.'});
|
|
} else if (userJoining) {
|
|
travelModel.findOne({
|
|
_id: req.params.travelid,
|
|
user: {'$ne': userJoining._id},
|
|
joins: {'$ne': userJoining._id},
|
|
joinPetitions: {'$ne': userJoining._id}
|
|
})
|
|
.exec(function(err, travel){
|
|
if (err) return res.send(500, err.message);
|
|
if (!travel) {
|
|
res.json({success: false, message: 'travel not found. You can not join a travel if you have created it, or if you have already joined'});
|
|
} else if (travel) {
|
|
travel.joinPetitions.push(userJoining._id);
|
|
travel.save(function(err, travel) {
|
|
if(err) return res.send(500, err.message);
|
|
|
|
//start saving notification, get user owner of travel
|
|
userModel.findOne({_id: travel.user})
|
|
.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) {
|
|
//notification
|
|
var notification = new notificationModel({
|
|
concept: "join",
|
|
message: "user "+userJoining.username+" joins your travel "+travel.title,
|
|
date: new Date(),
|
|
icon: 'join.png',
|
|
link: "travels/" + travel._id,
|
|
user: user._id
|
|
});
|
|
notification.save(function(err, notification) {
|
|
if (err) return res.send(500, err.message);
|
|
user.notifications.push(notification._id);
|
|
user.save(function(err, user) {
|
|
if (err) return res.send(500, err.message);
|
|
|
|
console.log("notification saved");
|
|
exports.getTravelById(req, res);
|
|
});
|
|
});
|
|
}
|
|
});//end saving notification
|
|
});
|
|
}//end of else if travel
|
|
});
|
|
}//end of else if user
|
|
});
|
|
};
|
|
|
|
exports.unJoin = function(req, res) {
|
|
userModel.findOne({'token': req.headers['x-access-token']})
|
|
.exec(function(err, userJoining){
|
|
if (!userJoining) {
|
|
res.json({success: false, message: 'userJoining not found.'});
|
|
} else if (userJoining) {
|
|
travelModel.findOne({
|
|
_id: req.params.travelid,
|
|
joinPetitions: userJoining._id
|
|
})
|
|
.exec(function(err, travel){
|
|
if (err) return res.send(500, err.message);
|
|
if (!travel) {
|
|
res.json({success: false, message: 'can not unjoin this travel'});
|
|
} else if (travel) {
|
|
for(var i=0; i<travel.joinPetitions.length; i++)
|
|
{
|
|
if(travel.joinPetitions[i].equals(userJoining._id))
|
|
{
|
|
travel.joinPetitions.splice(i, 1);
|
|
}
|
|
}
|
|
travel.save(function(err, travel) {
|
|
if(err) return res.send(500, err.message);
|
|
//start saving notification, get user owner of travel
|
|
userModel.findOne({_id: travel.user})
|
|
.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) {
|
|
//notification
|
|
var notification = new notificationModel({
|
|
concept: "unjoin",
|
|
message: "user "+userJoining.username+" unjoins your travel "+travel.title,
|
|
date: new Date(),
|
|
icon: 'unjoin.png',
|
|
link: "travels/" + travel._id,
|
|
user: user._id
|
|
});
|
|
notification.save(function(err, notification) {
|
|
if (err) return res.send(500, err.message);
|
|
user.notifications.push(notification._id);
|
|
user.save(function(err, user) {
|
|
if (err) return res.send(500, err.message);
|
|
|
|
console.log("notification saved");
|
|
exports.getTravelById(req, res);
|
|
});
|
|
});
|
|
}
|
|
});//end saving notification
|
|
});
|
|
}
|
|
});
|
|
}
|
|
|
|
});
|
|
};
|
|
|
|
|
|
exports.declineJoin = function(req, res) {
|
|
userModel.findOne({'token': req.headers['x-access-token']})
|
|
.exec(function(err, userOwner){
|
|
if (err) return res.send(500, err.message);
|
|
if (!userOwner) {
|
|
res.json({success: false, message: 'User not found.'});
|
|
} else if (userOwner) {
|
|
travelModel.findOne({
|
|
_id: req.params.travelid,
|
|
user: userOwner._id,
|
|
joinPetitions: req.body.userid
|
|
})
|
|
.exec(function(err, travel){
|
|
if (err) return res.send(500, err.message);
|
|
if (!travel) {
|
|
res.json({success: false, message: 'travel not found. You can not join a travel if you have created it, or if you have already joined'});
|
|
} else if (travel) {
|
|
var indexPetition=-1;
|
|
for(var i=0; i<travel.joinPetitions.length; i++)
|
|
{
|
|
if(travel.joinPetitions[i].equals(req.body.userid))
|
|
{
|
|
indexPetition=JSON.parse(JSON.stringify(i));
|
|
}
|
|
}
|
|
if(indexPetition>-1)
|
|
{
|
|
travel.joinPetitions.splice(indexPetition, 1);
|
|
}
|
|
travel.save(function(err, travel) {
|
|
if(err) return res.send(500, err.message);
|
|
|
|
//start saving notification, get user owner of travel
|
|
userModel.findOne({_id: req.body.userid})
|
|
.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) {
|
|
//notification
|
|
var notification = new notificationModel({
|
|
concept: "travel",
|
|
message: "user "+userOwner.username+" declines your petition for "+travel.title,
|
|
date: new Date(),
|
|
icon: 'travel.png',
|
|
link: "travels/" + travel._id,
|
|
user: user._id
|
|
});
|
|
notification.save(function(err, notification) {
|
|
if (err) return res.send(500, err.message);
|
|
user.notifications.push(notification._id);
|
|
user.save(function(err, user) {
|
|
if (err) return res.send(500, err.message);
|
|
|
|
console.log("notification saved");
|
|
exports.getTravelById(req, res);
|
|
});
|
|
});
|
|
}
|
|
});//end saving notification
|
|
});//end of travel save
|
|
}//end of else if travel
|
|
});
|
|
}//end of else if user
|
|
});
|
|
};
|
|
|
|
exports.acceptJoin = function(req, res) {
|
|
userModel.findOne({'token': req.headers['x-access-token']})
|
|
.exec(function(err, userOwner){
|
|
if (err) return res.send(500, err.message);
|
|
if (!userOwner) {
|
|
res.json({success: false, message: 'User not found.'});
|
|
} else if (userOwner) {
|
|
travelModel.findOne({
|
|
_id: req.params.travelid,
|
|
user: userOwner._id,
|
|
joinPetitions: req.body.userid
|
|
})
|
|
.exec(function(err, travel){
|
|
if (err) return res.send(500, err.message);
|
|
if (!travel) {
|
|
res.json({success: false, message: 'travel not found. You can not join a travel if you have created it, or if you have already joined'});
|
|
} else if (travel) {
|
|
var indexPetition=-1;
|
|
for(var i=0; i<travel.joinPetitions.length; i++)
|
|
{
|
|
if(travel.joinPetitions[i].equals(req.body.userid))
|
|
{
|
|
indexPetition=JSON.parse(JSON.stringify(i));
|
|
}
|
|
}
|
|
if(indexPetition>-1)
|
|
{
|
|
travel.joins.push(JSON.parse(JSON.stringify(travel.joinPetitions[indexPetition])));
|
|
travel.joinPetitions.splice(indexPetition, 1);
|
|
console.log(travel);
|
|
}
|
|
travel.save(function(err, travel) {
|
|
if(err) return res.send(500, err.message);
|
|
|
|
//start saving notification, get user owner of travel
|
|
userModel.findOne({_id: req.body.userid})
|
|
.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) {
|
|
//notification
|
|
var notification = new notificationModel({
|
|
concept: "travel",
|
|
message: "user "+userOwner.username+" accepts your petition for "+travel.title,
|
|
date: new Date(),
|
|
icon: 'travel.png',
|
|
link: "travels/" + travel._id,
|
|
user: user._id
|
|
});
|
|
notification.save(function(err, notification) {
|
|
if (err) return res.send(500, err.message);
|
|
user.notifications.push(notification._id);
|
|
user.save(function(err, user) {
|
|
if (err) return res.send(500, err.message);
|
|
|
|
console.log("notification saved");
|
|
exports.getTravelById(req, res);
|
|
});
|
|
});
|
|
}
|
|
});//end saving notification
|
|
});//end of travel save
|
|
}//end of else if travel
|
|
});
|
|
}//end of else if user
|
|
});
|
|
};
|
|
|
|
exports.leave = function(req, res) {
|
|
userModel.findOne({'token': req.headers['x-access-token']})
|
|
.exec(function(err, userLeaving){
|
|
if (!userLeaving) {
|
|
res.json({success: false, message: 'userLeaving not found.'});
|
|
} else if (userLeaving) {
|
|
travelModel.findOne({
|
|
_id: req.params.travelid,
|
|
joins: userLeaving._id
|
|
})
|
|
.exec(function(err, travel){
|
|
if (err) return res.send(500, err.message);
|
|
if (!travel) {
|
|
res.json({success: false, message: 'can not unjoin this travel'});
|
|
} else if (travel) {
|
|
for(var i=0; i<travel.joins.length; i++)
|
|
{
|
|
if(travel.joins[i].equals(userLeaving._id))
|
|
{
|
|
travel.joins.splice(i, 1);
|
|
}
|
|
}
|
|
travel.save(function(err, travel) {
|
|
if(err) return res.send(500, err.message);
|
|
//start saving notification, get user owner of travel
|
|
userModel.findOne({_id: travel.user})
|
|
.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) {
|
|
//notification
|
|
var notification = new notificationModel({
|
|
concept: "leave",
|
|
message: "user "+userLeaving.username+" leaves your travel "+travel.title,
|
|
date: new Date(),
|
|
icon: 'leave.png',
|
|
link: "travels/" + travel._id,
|
|
user: user._id
|
|
});
|
|
notification.save(function(err, notification) {
|
|
if (err) return res.send(500, err.message);
|
|
user.notifications.push(notification._id);
|
|
user.save(function(err, user) {
|
|
if (err) return res.send(500, err.message);
|
|
|
|
console.log("notification saved");
|
|
exports.getTravelById(req, res);
|
|
});
|
|
});
|
|
}
|
|
});//end saving notification
|
|
});
|
|
}
|
|
});
|
|
}
|
|
|
|
});
|
|
};
|
|
|
|
|
|
|
|
|
|
|
|
|
|
/* comment */
|
|
exports.addComment = function(req, res) {
|
|
/*var comment = new commentModel({
|
|
travelId: req.params.travelId,
|
|
commentUserId: req.body.commentUserId,
|
|
commentUsername: req.body.commentUsername,
|
|
comment: req.body.comment,
|
|
commentAvatar: req.body.commentAvatar
|
|
});
|
|
|
|
comment.save(function(err, comment) {
|
|
if(err) return res.send(500, err.message);
|
|
res.status(200).jsonp(comment);
|
|
});*/
|
|
userModel.find({
|
|
token: req.headers['x-access-token']
|
|
}, function(err, users){
|
|
var user=users[0];
|
|
|
|
travelModel.findById(req.params.travelId, function(err, travel){
|
|
console.log(travel.title);
|
|
var comment = {
|
|
commentUserId: user._id,
|
|
commentUsername: user.username,
|
|
comment: req.body.comment,
|
|
commentAvatar: user.avatar
|
|
};
|
|
travel.comments.push(comment);
|
|
|
|
travel.save(function(err, travel) {
|
|
if(err) return res.send(500, err.message);
|
|
//res.status(200).jsonp(travel);
|
|
travelModel.find({date: {$gte: new Date()}}, function(err, travels) {
|
|
if(err) res.send(500, err.message);
|
|
res.status(200).jsonp(travels);
|
|
});
|
|
});
|
|
|
|
//start saving notification, get user owner of travel
|
|
userModel.find({
|
|
username: travel.owner
|
|
}, function(err, userowners) {
|
|
var userowner=userowners[0];
|
|
//notification
|
|
var notification = {
|
|
concept: "comment",
|
|
otherusername: user.username,
|
|
description: "user "+user.username+" comments your travel "+travel.title,
|
|
date: new Date(),
|
|
link: "",
|
|
user: userowners[0]._id
|
|
};
|
|
userowner.notifications.push(notification);
|
|
userowner.save(function(err, userowner) {
|
|
console.log("notification saved");
|
|
});
|
|
});//end saving notification
|
|
|
|
});
|
|
});//end of userModel.find
|
|
};
|
|
|
|
exports.getCommentsByTravelId = function(req, res) {
|
|
commentModel.find({
|
|
travelId: req.params.travelId
|
|
}, function(err, comments) {
|
|
|
|
if (err) throw err;
|
|
|
|
if (!comments) {
|
|
res.json({ success: false, message: 'no comments for travelId' });
|
|
} else if (comments) {
|
|
// return the information including token as JSON
|
|
res.jsonp(comments);
|
|
|
|
}
|
|
|
|
});
|
|
};
|