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

perf(groups): use simplest possible query for cron script (#15457)

Browse source
This commit is contained in:
Kalista Payne 2025-06-25 14:56:50 -05:00 committed by GitHub
parent 2727da6f6c
commit f8a3e4d673
No known key found for this signature in database
GPG key ID: B5690EEEBB952194
1 changed files with 10 additions and 6 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

16
scripts/team-cron.js
View file

@ -8,7 +8,16 @@ const TASK_VALUE_CHANGE_FACTOR = 0.9747;
const MIN_TASK_VALUE = -47.27; const MIN_TASK_VALUE = -47.27;
async function updateTeamTasks (team) { async function updateTeamTasks (team) {
if (team.purchased.plan.dateTerminated) {
const dateTerminated = new Date(team.purchased.plan.dateTerminated);
if (dateTerminated < new Date()) {
team.purchased.plan.customerId = undefined;
return team.save();
}
}
const toSave = []; const toSave = [];
let teamLeader = await User.findOne({ _id: team.leader }, 'preferences').exec(); let teamLeader = await User.findOne({ _id: team.leader }, 'preferences').exec();
if (!teamLeader) { // why would this happen? if (!teamLeader) { // why would this happen?
@ -93,12 +102,7 @@ async function updateTeamTasks (team) {
export default async function processTeamsCron () { export default async function processTeamsCron () {
const activeTeams = await Group.find({ const activeTeams = await Group.find({
'purchased.plan.customerId': { $exists: true }, 'purchased.plan.customerId': { $exists: true },
$or: [ }, { cron: 1, leader: 1, purchased: 1 }).exec();
{ 'purchased.plan.dateTerminated': { $exists: false } },
{ 'purchased.plan.dateTerminated': null },
{ 'purchased.plan.dateTerminated': { $gt: new Date() } },
],
}).exec();
const cronPromises = activeTeams.map(updateTeamTasks); const cronPromises = activeTeams.map(updateTeamTasks);
return Promise.all(cronPromises); return Promise.all(cronPromises);