From 2b7891e7887425baa924fa9d3a741b9f3ebd5ff5 Mon Sep 17 00:00:00 2001 From: Sabe Jones Date: Wed, 17 Jul 2019 06:05:38 -0500 Subject: [PATCH] WIP(migration): then --- .../archive/2019/20190716_groups_fix.js | 22 +++++++++---------- 1 file changed, 11 insertions(+), 11 deletions(-) diff --git a/migrations/archive/2019/20190716_groups_fix.js b/migrations/archive/2019/20190716_groups_fix.js index 62f2d60bdd..c5cf64515c 100644 --- a/migrations/archive/2019/20190716_groups_fix.js +++ b/migrations/archive/2019/20190716_groups_fix.js @@ -10,29 +10,29 @@ import { model as User } from '../../../website/server/models/user'; const progressCount = 1000; let count = 0; -async function updateUser (user) { +function updateUser (user) { count++; let set = { migration: MIGRATION_NAME }; let addToSet; - let backupUser = await backupUsers.findOne( + 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 (!user.party._id) { - set.party = backupUser.party; - } - addToSet = { guilds: { $each: backupUser.guilds }}; + if (count % progressCount === 0) console.warn(`${count} ${user._id}`); - if (count % progressCount === 0) console.warn(`${count} ${user._id}`); - - return await User.update({ _id: user._id }, { $set: set, $addToSet: addToSet }).exec(); + return User.update({ _id: user._id }, { $set: set, $addToSet: addToSet }).exec(); + }); } module.exports = async function processUsers () { - let query = { + const query = { 'auth.timestamps.loggedin': {$gt: new Date('2019-07-15')}, };