From 24229569e35fe9f3cdbae4bc34296bdb19fd1015 Mon Sep 17 00:00:00 2001 From: Andris Reinman Date: Tue, 6 Nov 2018 10:36:26 +0200 Subject: [PATCH] fixed cursor leak in restore task --- lib/tasks/restore.js | 16 ++++++++-------- 1 file changed, 8 insertions(+), 8 deletions(-) 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) {