diff --git a/lib/tasks/restore.js b/lib/tasks/restore.js index 7c020e0f..b2e35ee7 100644 --- a/lib/tasks/restore.js +++ b/lib/tasks/restore.js @@ -6,14 +6,6 @@ const db = require('../db'); module.exports = (taskData, options, callback) => { const messageHandler = options.messageHandler; - let cursor = db.database.collection('archived').find({ - user: taskData.user, - archived: { - $gte: taskData.start, - $lte: taskData.end - } - }); - db.users.collection('users').findOne({ _id: taskData.user }, (err, userData) => { if (err) { log.error('Tasks', 'task=restore id=%s user=%s error=%s', taskData._id, taskData.user, err.message); @@ -50,6 +42,14 @@ module.exports = (taskData, options, callback) => { } }); + let cursor = db.database.collection('archived').find({ + user: taskData.user, + archived: { + $gte: taskData.start, + $lte: taskData.end + } + }); + let processNext = () => { cursor.next((err, messageData) => { if (err) {