joins done ok

This commit is contained in:
arnaucode
2017-01-26 10:45:27 +01:00
parent da188b9b39
commit 21d477ae41
5 changed files with 125 additions and 95 deletions

View File

@@ -73,18 +73,18 @@ exports.addTravel = function(req, res) {
exports.updateTravel = function(req, res) { exports.updateTravel = function(req, res) {
userModel.findOne({'token': req.headers['x-access-token']}) userModel.findOne({'token': req.headers['x-access-token']})
.exec(function(err, user){ .exec(function(err, user){
if (err) return console.log(err); if (err) return res.send(500, err.message);
console.log(user); console.log(travel);
userModel.findOne({_id: user._id}) travelModel.findOne({_id: travel._id})
.lean() .lean()
.populate('travels', 'title from to date') .populate('travels', 'title from to date')
.exec(function (err, user) { .exec(function (err, travel) {
if (err) return res.send(500, err.message); if (err) return res.send(500, err.message);
if (!user) { if (!travel) {
res.json({success: false, message: 'User not found.'}); res.json({success: false, message: 'travel not found.'});
} else if (user) { } else if (travel) {
res.status(200).jsonp(user); res.status(200).jsonp(travel);
} }
}); });
}); });
@@ -92,21 +92,18 @@ exports.updateTravel = function(req, res) {
//DELETE //DELETE
exports.deleteTravel = function(req, res) { exports.deleteTravel = function(req, res) {
userModel.find({ userModel.findOne({'token': req.headers['x-access-token']})
token: req.headers['x-access-token'] .exec(function(err, user){
}, function(err, users){ if (err) return res.send(500, err.message);
var user=users[0]; travelModel.findById(req.params.travelid, function(err, travel) {
if (err) return res.send(500, err.message);
travelModel.findById(req.params.id, function(err, travel) { if(travel.user.equals(user._id))
if(travel.owner==user.username)
{ {
travel.remove(function(err) { travel.remove(function(err) {
if(err) return res.send(500, err.message); if(err) return res.send(500, err.message);
travelModel.find({date: {$gte: new Date()}}, function(err, travels) { console.log("deleted");
if(err) res.send(500, err.message); exports.getAllTravels(req, res);
res.status(200).jsonp(travels);
});
}); });
} }
}); });
@@ -114,79 +111,89 @@ exports.deleteTravel = function(req, res) {
}; };
/* join */ /* join */
exports.addJoin = function(req, res) { exports.addJoinPetition = function(req, res) {
userModel.findOne({'token': req.headers['x-access-token']}) userModel.findOne({'token': req.headers['x-access-token']})
.exec(function(err, user){ .exec(function(err, userJoining){
travelModel.findById(req.params.travelId, function(err, travel){ if (err) return res.send(500, err.message);
console.log(travel.title); if (!userJoining) {
var join = { res.json({success: false, message: 'User not found.'});
joinedUserId: user._id, } else if (userJoining) {
joinedUsername: user.username, travelModel.findOne({
acceptedUserId: req.body.acceptedUserId, _id: req.params.travelid,
joinedAvatar: user.avatar user: {'$ne': userJoining._id},
}; joins: {'$ne': userJoining._id},
travel.joins.push(join); 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 = {
type: "join",
message: "user "+userJoining.username+" joins your travel "+travel.title,
date: new Date(),
icon: 'join.png',
link: ""
};
user.notifications.push(notification);
user.save(function(err, user) {
if (err) return res.send(500, err.message);
console.log("notification saved");
travel.save(function(err, travel) { exports.getTravelById(req, res);
if(err) return res.send(500, err.message); });
//res.status(200).jsonp(travel); }
travelModel.find({date: {$gte: new Date()}}, function(err, travels) { });//end saving notification
if(err) res.send(500, err.message); });
res.status(200).jsonp(travels); }//end of else if travel
});
}); });
}//end of else if user
//start saving notification, get user owner of travel
userModel.find({
username: travel.owner
}, function(err, userowners) {
var userowner=userowners[0];
//notification
var notification = {
type: "join",
otherusername: user.username,
description: "user "+user.username+" joins your travel "+travel.title,
date: new Date(),
link: ""
};
userowner.notifications.push(notification);
userowner.save(function(err, userowner) {
console.log("notification saved");
});
});//end saving notification
});
}); });
}; };
exports.doUnjoin = function(req, res) { exports.unJoin = function(req, res) {
userModel.find({ userModel.findOne({'token': req.headers['x-access-token']})
token: req.headers['x-access-token'] .exec(function(err, user){
}, function(err, users){ if (!user) {
var user=users[0]; res.json({success: false, message: 'User not found.'});
} else if (user) {
travelModel.findById(req.params.travelId, function(err, travel){ travelModel.findOne({
for(var i=0; i<travel.joins.length; i++) _id: req.params.travelid,
{ joinPetitions: user._id
if(travel.joins[i].joinedUsername==user.username) })
{ .exec(function(err, travel){
travel.joins.splice(i, 1); 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(user._id))
{
travel.joinPetitions.splice(i, 1);
}
}
travel.save(function(err, travel) {
if(err) return res.send(500, err.message);
exports.getTravelById(req, res);
});
} }
}
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);
});
}); });
}
});
}); });
}; };

View File

@@ -121,6 +121,21 @@ exports.getUserById = function (req, res) {
} }
}); });
}; };
//GET - Return a User with specified ID
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.updateUser = function (req, res) { exports.updateUser = function (req, res) {
userModel.update({'token': req.headers['x-access-token']}, req.body, userModel.update({'token': req.headers['x-access-token']}, req.body,

View File

@@ -22,6 +22,10 @@ var travelSchema = new Schema({
type: mongoose.Schema.Types.ObjectId, type: mongoose.Schema.Types.ObjectId,
ref: 'userModel' ref: 'userModel'
}], }],
joinPetitions: [{
type: mongoose.Schema.Types.ObjectId,
ref: 'userModel'
}],
comments: [{ comments: [{
type: mongoose.Schema.Types.ObjectId, type: mongoose.Schema.Types.ObjectId,
ref: 'commentModel' ref: 'commentModel'

View File

@@ -8,8 +8,8 @@ var userSchema = new Schema({
username: { type: String, required: true, unique: true }, username: { type: String, required: true, unique: true },
password: { type: String, required: true, selected: false }, password: { type: String, required: true, selected: false },
token: { type: String, selected: false }, token: { type: String, selected: false },
description: { type: String }, description: { type: String, default: "Hello world" },
avatar: { type: String }, avatar: { type: String, default: "racoon" },
email: { type: String, required: true }, email: { type: String, required: true },
phone: { type: String }, phone: { type: String },
telegram: { type: String }, telegram: { type: String },
@@ -33,7 +33,7 @@ var userSchema = new Schema({
ref: 'travelModel' ref: 'travelModel'
}], }],
notifications: [{ notifications: [{
state: {type: String},//viewed, pendent state: {type: String, default: "pendent"},//viewed, pendent
message: {type: String}, message: {type: String},
link: {type: String},//aquí oju, a la app i a la web calen links diferents, però ho podem fer posant sempre a la app i a la web el prefix del link (#!/app) o (#/app/), i després afegint-hi la pàgina on volem enviar el routing, per exemple (dashboard) link: {type: String},//aquí oju, a la app i a la web calen links diferents, però ho podem fer posant sempre a la app i a la web el prefix del link (#!/app) o (#/app/), i després afegint-hi la pàgina on volem enviar el routing, per exemple (dashboard)
icon: {type: String}, icon: {type: String},

View File

@@ -106,19 +106,23 @@ apiRoutes.use(function(req, res, next) {
}); //fi verificació de token }); //fi verificació de token
apiRoutes.route('/users/:id') apiRoutes.route('/users/getByToken')
.put(userCtrl.updateUser) .get(userCtrl.getUserByToken);
apiRoutes.route('/users')//agafa l'user a partir del token
.put(userCtrl.updateUser)//no comprovat
.delete(userCtrl.deleteUser); .delete(userCtrl.deleteUser);
apiRoutes.route('/travels') apiRoutes.route('/travels')
.post(travelCtrl.addTravel); .post(travelCtrl.addTravel);
//FINS AQUÏ COMPROVAT apiRoutes.route('/travels/modifyById/:travelid')
apiRoutes.route('/travels/:id') .put(travelCtrl.updateTravel)//no comprovat
.put(travelCtrl.updateTravel)
.delete(travelCtrl.deleteTravel); .delete(travelCtrl.deleteTravel);
apiRoutes.route('/travels/join/:travelid')
.get(travelCtrl.addJoinPetition);
apiRoutes.route('/travels/unjoin/:travelid')
.get(travelCtrl.unJoin);
//FINS AQUÏ COMPROVAT
apiRoutes.route('/travels/addJoin/:travelId') apiRoutes.route('/travels/comment/:travelid')
.get(travelCtrl.getJoinsByTravelId);
apiRoutes.route('/travels/comment/:travelId')
.get(travelCtrl.getCommentsByTravelId); .get(travelCtrl.getCommentsByTravelId);
/*apiRoutes.route('/travels/join/:travelId') /*apiRoutes.route('/travels/join/:travelId')
@@ -126,11 +130,11 @@ apiRoutes.route('/travels/comment/:travelId')
apiRoutes.route('/travels/unjoin/:travelId') apiRoutes.route('/travels/unjoin/:travelId')
.post(travelCtrl.doUnjoin);*/ .post(travelCtrl.doUnjoin);*/
apiRoutes.route('/travels/:travelId/join') /*apiRoutes.route('/travels/:travelId/join')
.post(travelCtrl.addJoin); .post(travelCtrl.addJoin);
apiRoutes.route('/travels/:travelId/unjoin') apiRoutes.route('/travels/:travelId/unjoin')
.post(travelCtrl.doUnjoin); .post(travelCtrl.doUnjoin);
*/
apiRoutes.route('/users/:userId/fav') apiRoutes.route('/users/:userId/fav')
.post(userCtrl.addFav); .post(userCtrl.addFav);
apiRoutes.route('/users/:userId/unfav') apiRoutes.route('/users/:userId/unfav')