sudoxreboot/habitica
1
0
Fork 0
mirror of https://github.com/sudoxnym/habitica.git synced 2026-04-14 19:56:23 +00:00
Code Issues Projects Releases Packages Wiki Activity Actions

fix quests migration

Browse source
This commit is contained in:
Matteo Pagliazzi 2019-07-17 22:04:25 +02:00
parent 581a40ffad
commit 519a580b7b
1 changed files with 19 additions and 17 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

36
migrations/archive/2019/20190717_groups_fix_2.js
View file

@ -13,28 +13,30 @@ const questScrolls = shared.content.quests;
const progressCount = 1000;
let count = 0;
let backupUsers;
async function updateGroup (group) {
count++;
if (group && group.quest && group.quest.leader) {
if (group && group.quest && group.quest.key && group.quest.leader) {
const quest = questScrolls[group.quest.key];
const leader = await User.findOne({_id: group.quest.leader}).exec();
if (!leader) return;
if (leader && quest) {
await User.update({
_id: leader._id,
migration: {$ne: MIGRATION_NAME},
}, {
$set: {migration: MIGRATION_NAME},
$inc: {
balance: 1,
[`items.quests.${group.quest.key}`]: 1,
},
}).exec();
await User.update({ _id: leader._id }, {
$set: {migration: MIGRATION_NAME},
$inc: {
balance: 1,
[`items.quests.${group.quest.key}`]: 1,
},
}).exec();
// unsubscribe from all is already checked by sendTxnEmail
if (leader.preferences && leader.preferences.emailNotifications && leader.preferences.emailNotifications.majorUpdates !== false) {
sendTxnEmail(leader, 'groups-outage');
// unsubscribe from all is already checked by sendTxnEmail
if (leader.preferences && leader.preferences.emailNotifications && leader.preferences.emailNotifications.majorUpdates !== false) {
sendTxnEmail(leader, 'groups-outage');
}
}
}
@ -58,7 +60,7 @@ module.exports = async function processUsers () {
while (true) { // eslint-disable-line no-constant-condition
const groupsPromise = new Promise((resolve, reject) => {
backupGroups
.find(query, {
.find(query, {
limit: 250,
sort: {_id: 1}
})
@ -66,7 +68,7 @@ module.exports = async function processUsers () {
resolve(foundGroupInBackup);
}).catch(e => {
reject(e);
})
});
});
const groups = await groupsPromise;
@ -77,7 +79,7 @@ module.exports = async function processUsers () {
break;
} else {
query._id = {
$gt: groups[groups.length - 1],
$gt: groups[groups.length - 1]._id,
};
}