fixed invalid db for audits

nodemailer · Nov 21, 2019 · 2681ceb · 2681ceb
1 parent 7059f00
commit 2681ceb
Showing 1 changed file with 7 additions and 5 deletions.
diff --git a/lib/tasks/audit.js b/lib/tasks/audit.js
@@ -30,10 +30,12 @@ let run = async (taskData, options) => {
     }
 
     let mailboxes = new Map(
-        (await db.database
-            .collection('mailboxes')
-            .find({ user: taskData.user })
-            .toArray()).map(mailboxData => [mailboxData._id.toString(), mailboxData])
+        (
+            await db.database
+                .collection('mailboxes')
+                .find({ user: taskData.user })
+                .toArray()
+        ).map(mailboxData => [mailboxData._id.toString(), mailboxData])
     );
 
     let processMessage = async messageData => {
@@ -61,7 +63,7 @@ let run = async (taskData, options) => {
     let status = 'imported'; //expect to complete successfully
 
     let processMessages = async collection => {
-        let cursor = await db.users.collection(collection).find(query, {
+        let cursor = await db.database.collection(collection).find(query, {
             projection: {
                 _id: true,
                 user: true,