This commit is contained in:
Bruce Berrios 2024-09-09 23:07:57 -04:00
parent bf6a526678
commit 0d18e34c24
2 changed files with 2 additions and 4 deletions

View file

@ -59,9 +59,7 @@ async function deleteUsers(): Promise<void> {
return;
}
await mapLimit(softDeletedUsers, CONCURRENT_DELETIONS, async (user) => {
await deleteUser(user.uid);
});
await mapLimit(softDeletedUsers, CONCURRENT_DELETIONS, async (user) => deleteUser(user.uid));
}
export default new CronJob(CRON_SCHEDULE, deleteUsers);

View file

@ -344,7 +344,7 @@ export function replaceObjectIds<T extends { _id: ObjectId }>(
return data.map((it) => replaceObjectId(it));
}
type MapLimitIteratee<T, V> = (element: T, index: number) => V;
type MapLimitIteratee<T, V> = (element: T, index: number) => Promise<V>;
export async function mapLimit<T, V>(
input: T[],