Clear invites from user when the request fails because the invite is invalid (#7852)

* making requests to accept or reject a request fail because the invite is invalid clear the invite from the user so it doesn't require admin intervention. part of #7653

* Adding await
This commit is contained in:
Travis
2016-08-05 10:34:06 -07:00
committed by Blade Barringer
parent 093c5a72df
commit d7c5d05f13
3 changed files with 39 additions and 12 deletions

View File

@@ -74,6 +74,21 @@ describe('POST /groups/:groupId/quests/accept', () => {
}); });
}); });
it('clears the invalid invite from the user when the request fails', async () => {
await leader.post(`/groups/${questingGroup._id}/quests/invite/${PET_QUEST}`);
await partyMembers[0].post(`/groups/${questingGroup._id}/quests/accept`);
await expect(partyMembers[0].post(`/groups/${questingGroup._id}/quests/accept`))
.to.eventually.be.rejected.and.eql({
code: 400,
error: 'BadRequest',
message: t('questAlreadyAccepted'),
});
await partyMembers[0].sync();
expect(partyMembers[0].party.quest.RSVPNeeded).to.be.false;
});
it('does not accept invite for a quest already underway', async () => { it('does not accept invite for a quest already underway', async () => {
await leader.post(`/groups/${questingGroup._id}/quests/invite/${PET_QUEST}`); await leader.post(`/groups/${questingGroup._id}/quests/invite/${PET_QUEST}`);
await partyMembers[0].post(`/groups/${questingGroup._id}/quests/accept`); await partyMembers[0].post(`/groups/${questingGroup._id}/quests/accept`);

View File

@@ -83,6 +83,21 @@ describe('POST /groups/:groupId/quests/reject', () => {
}); });
}); });
it('clears the user rsvp needed if the request fails because the request is invalid', async () => {
await leader.post(`/groups/${questingGroup._id}/quests/invite/${PET_QUEST}`);
await partyMembers[0].post(`/groups/${questingGroup._id}/quests/reject`);
await expect(partyMembers[0].post(`/groups/${questingGroup._id}/quests/reject`))
.to.eventually.be.rejected.and.eql({
code: 400,
error: 'BadRequest',
message: t('questAlreadyRejected'),
});
await partyMembers[0].sync();
expect(partyMembers[0].party.quest.RSVPNeeded).to.be.false;
});
it('return an error when a user rejects an invite already accepted', async () => { it('return an error when a user rejects an invite already accepted', async () => {
await leader.post(`/groups/${questingGroup._id}/quests/invite/${PET_QUEST}`); await leader.post(`/groups/${questingGroup._id}/quests/invite/${PET_QUEST}`);
await partyMembers[0].post(`/groups/${questingGroup._id}/quests/accept`); await partyMembers[0].post(`/groups/${questingGroup._id}/quests/accept`);

View File

@@ -161,6 +161,9 @@ api.acceptQuest = {
let validationErrors = req.validationErrors(); let validationErrors = req.validationErrors();
if (validationErrors) throw validationErrors; if (validationErrors) throw validationErrors;
user.party.quest.RSVPNeeded = false;
await user.save();
let group = await Group.getGroup({user, groupId: req.params.groupId, fields: 'type quest'}); let group = await Group.getGroup({user, groupId: req.params.groupId, fields: 'type quest'});
if (!group) throw new NotFound(res.t('groupNotFound')); if (!group) throw new NotFound(res.t('groupNotFound'));
@@ -171,16 +174,12 @@ api.acceptQuest = {
group.markModified('quest'); group.markModified('quest');
group.quest.members[user._id] = true; group.quest.members[user._id] = true;
user.party.quest.RSVPNeeded = false;
if (canStartQuestAutomatically(group)) { if (canStartQuestAutomatically(group)) {
await group.startQuest(user); await group.startQuest(user);
} }
let [savedGroup] = await Bluebird.all([ let savedGroup = await group.save();
group.save(),
user.save(),
]);
res.respond(200, savedGroup.quest); res.respond(200, savedGroup.quest);
@@ -218,6 +217,10 @@ api.rejectQuest = {
let validationErrors = req.validationErrors(); let validationErrors = req.validationErrors();
if (validationErrors) throw validationErrors; if (validationErrors) throw validationErrors;
user.party.quest = Group.cleanQuestProgress();
user.markModified('party.quest');
await user.save();
let group = await Group.getGroup({user, groupId: req.params.groupId, fields: 'type quest'}); let group = await Group.getGroup({user, groupId: req.params.groupId, fields: 'type quest'});
if (!group) throw new NotFound(res.t('groupNotFound')); if (!group) throw new NotFound(res.t('groupNotFound'));
if (group.type !== 'party') throw new NotAuthorized(res.t('guildQuestsNotSupported')); if (group.type !== 'party') throw new NotAuthorized(res.t('guildQuestsNotSupported'));
@@ -229,17 +232,11 @@ api.rejectQuest = {
group.quest.members[user._id] = false; group.quest.members[user._id] = false;
group.markModified('quest.members'); group.markModified('quest.members');
user.party.quest = Group.cleanQuestProgress();
user.markModified('party.quest');
if (canStartQuestAutomatically(group)) { if (canStartQuestAutomatically(group)) {
await group.startQuest(user); await group.startQuest(user);
} }
let [savedGroup] = await Bluebird.all([ let savedGroup = await group.save();
group.save(),
user.save(),
]);
res.respond(200, savedGroup.quest); res.respond(200, savedGroup.quest);