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

possible fix for script stuck script

Browse source
This commit is contained in:
Matteo Pagliazzi 2019-07-17 13:34:08 +02:00
parent 2b7891e788
commit 51f7ce3280
1 changed files with 21 additions and 13 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

34
migrations/archive/2019/20190716_groups_fix.js
View file

@ -10,25 +10,33 @@ import { model as User } from '../../../website/server/models/user';
const progressCount = 1000;
let count = 0;
function updateUser (user) {
async function updateUser (user) {
count++;
let set = { migration: MIGRATION_NAME };
let addToSet;
backupUsers.findOne(
{ _id: user._id },
{ fields: { party: 1, guilds: 1 }}
).then((backupUser) => {
if (!user.party._id) {
set.party = backupUser.party;
}
addToSet = { guilds: { $each: backupUser.guilds }};
if (count % progressCount === 0) console.warn(`${count} ${user._id}`);
return User.update({ _id: user._id }, { $set: set, $addToSet: addToSet }).exec();
const monkPromise = new Promise((resolve, reject) => {
backupUsers.findOne(
{ _id: user._id },
{ fields: { _id: 1, party: 1, guilds: 1 }},
).then(foundUserInBackup => {
resolve(foundUserInBackup);
}).catch(e => {
})
});
let backupUser = await monkPromise;
if (!backupUser) return;
if (!user.party._id) {
set.party = backupUser.party;
}
addToSet = { guilds: { $each: backupUser.guilds }};
if (count % progressCount === 0) console.warn(`${count} ${user._id}`);
return User.update({ _id: user._id }, { $set: set, $addToSet: addToSet }).exec();
}
module.exports = async function processUsers () {