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

fix(migration): actually terminate

Browse source
This commit is contained in:
SabreCat 2023-07-19 14:46:04 -05:00
parent a26c5906d6
commit 16b766beef
1 changed files with 20 additions and 23 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

43
migrations/archive/2023/20230808_guild_gems.js
View file

@ -2,42 +2,35 @@
import { model as User } from '../../../website/server/models/user';
import { model as Group } from '../../../website/server/models/group';
const MIGRATION_NAME = '20230808_guild_gems';
const guildsPerRun = 500;
const progressCount = 1000;
const guildsQuery = {
migration: { $ne: MIGRATION_NAME }, // skip already migrated entries
'type': 'guild',
};
let count = 0;
async function updateGroup (guild) {
count++;
const set = {
migration: MIGRATION_NAME,
};
if (guild.balance > 0 && !guild.hasActiveGroupPlan()) {
const leader = await User
.findOne({ _id: guild.leader })
.select({ _id: true })
.exec();
if (!leader) {
return console.warn(`Leader not found for Guild ${guild._id}`);
}
await leader.updateOne({ $inc: { balance: guild.balance }}).exec();
set.balance = 0;
}
if (count % progressCount === 0) {
console.warn(`${count} ${guild._id}`);
}
return guild.updateOne({ $set: set }).exec();
if (guild.hasActiveGroupPlan()) {
return console.warn(`Guild ${guild._id} is active Group Plan`);
}
const leader = await User
.findOne({ _id: guild.leader })
.select({ _id: true })
.exec();
if (!leader) {
return console.warn(`Leader not found for Guild ${guild._id}`);
}
await leader.updateOne({ $inc: { balance: guild.balance }}).exec();
return guild.updateOne({ $set: { balance: 0 } }).exec();
}
export default async function processGroups () {
@ -59,6 +52,10 @@ export default async function processGroups () {
console.warn('All appropriate Guilds found and modified.');
console.warn(`\n${count} Guilds processed\n`);
break;
} else {
guildsQuery._id = {
$gt: foundGroups[foundGroups.length - 1],
};
}
await Promise.all(foundGroups.map(guild => updateGroup(guild))); // eslint-disable-line no-await-in-loop