nodemailer/wildduck
1
1
Fork 0
mirror of https://github.com/nodemailer/wildduck.git synced 2024-09-20 15:26:03 +08:00
Code Issues Packages Projects Releases Wiki Activity

use object for sorting

Browse source
This commit is contained in:
Andris Reinman 2020-01-29 17:58:59 +02:00
parent 1676c7336f
commit fafc124f83
No known key found for this signature in database
GPG key ID: 5388A30A31834D83
6 changed files with 7 additions and 6 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

2
lib/handlers/on-copy.js
View file

@ -55,7 +55,7 @@ module.exports = (server, messageHandler) => (mailbox, update, session, callback
mailbox: mailboxData._id, mailbox: mailboxData._id,
uid: tools.checkRangeQuery(update.messages) uid: tools.checkRangeQuery(update.messages)
}) // no projection as we need to copy the entire message }) // no projection as we need to copy the entire message
.sort([['uid', 1]]) .sort({ uid: 1 })
.maxTimeMS(consts.DB_MAX_TIME_MESSAGES); .maxTimeMS(consts.DB_MAX_TIME_MESSAGES);
let copiedMessages = 0; let copiedMessages = 0;

2
lib/handlers/on-expunge.js
View file

@ -78,7 +78,7 @@ module.exports = (server, messageHandler) => (mailbox, update, session, callback
let cursor = db.database let cursor = db.database
.collection('messages') .collection('messages')
.find(query) .find(query)
.sort([['uid', 1]]) .sort({ uid: 1 })
.maxTimeMS(consts.DB_MAX_TIME_MESSAGES); .maxTimeMS(consts.DB_MAX_TIME_MESSAGES);
let processNext = () => { let processNext = () => {

3
lib/handlers/on-fetch.js
View file

@ -130,11 +130,12 @@ module.exports = (server, messageHandler, userCache) => (mailbox, options, sessi
return callback(...args); return callback(...args);
}; };
let sort = { uid: 1 };
let cursor = db.database let cursor = db.database
.collection('messages') .collection('messages')
.find(query) .find(query)
.project(projection) .project(projection)
.sort([['uid', 1]]) .sort(sort)
.setReadPreference('secondaryPreferred') .setReadPreference('secondaryPreferred')
.maxTimeMS(consts.DB_MAX_TIME_MESSAGES); .maxTimeMS(consts.DB_MAX_TIME_MESSAGES);

2
lib/handlers/on-open.js
View file

@ -38,7 +38,7 @@ module.exports = server => (path, session, callback) => {
.project({ .project({
uid: true uid: true
}) })
//.sort([['uid', 1]]) //.sort({ uid: 1 })
.maxTimeMS(consts.DB_MAX_TIME_MESSAGES) .maxTimeMS(consts.DB_MAX_TIME_MESSAGES)
.toArray((err, messages) => { .toArray((err, messages) => {
if (err) { if (err) {

2
lib/handlers/on-store.js
View file

@ -92,7 +92,7 @@ module.exports = server => (mailbox, update, session, callback) => {
modseq: true modseq: true
}) })
.maxTimeMS(consts.DB_MAX_TIME_MESSAGES) .maxTimeMS(consts.DB_MAX_TIME_MESSAGES)
.sort([['uid', 1]]); .sort({ uid: 1 });
let shouldExpunge = false; let shouldExpunge = false;
let updateEntries = []; let updateEntries = [];

2
pop3.js
View file

@ -126,7 +126,7 @@ const serverOptions = {
flags: true, flags: true,
unseen: true unseen: true
}) })
.sort([['uid', -1]]) .sort({ uid: -1 })
.limit(config.pop3.maxMessages || MAX_MESSAGES) .limit(config.pop3.maxMessages || MAX_MESSAGES)
.toArray((err, messages) => { .toArray((err, messages) => {
if (err) { if (err) {