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

keep an index of POP3 messages to show

Browse source
This commit is contained in:
Andris Reinman 2019-03-13 15:39:13 +02:00
parent 01463cf386
commit d7de6fadd4
1 changed files with 53 additions and 34 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

87
pop3.js
View file

@ -107,43 +107,62 @@ const serverOptions = {
session.user.mailbox = mailbox._id;
db.database
.collection('messages')
.find({
db.redis.hget('pop3uid', mailbox._id.toString(), (err, lastIndex) => {
let query = {
mailbox: mailbox._id
})
.project({
uid: true,
size: true,
mailbox: true,
// required to decide if we need to update flags after RETR
flags: true,
unseen: true
})
.sort([['uid', -1]])
.limit(config.pop3.maxMessages || MAX_MESSAGES)
.toArray((err, messages) => {
if (err) {
return callback(err);
}
};
if (!err && lastIndex && !isNaN(lastIndex)) {
query.uid = { $gte: Number(lastIndex) };
}
return callback(null, {
messages: messages
// showolder first
.reverse()
// compose message objects
.map(message => ({
id: message._id.toString(),
uid: message.uid,
mailbox: message.mailbox,
size: message.size,
flags: message.flags,
seen: !message.unseen
})),
count: messages.length,
size: messages.reduce((acc, message) => acc + message.size, 0)
db.database
.collection('messages')
.find(query)
.project({
uid: true,
size: true,
mailbox: true,
// required to decide if we need to update flags after RETR
flags: true,
unseen: true
})
.sort([['uid', -1]])
.limit(config.pop3.maxMessages || MAX_MESSAGES)
.toArray((err, messages) => {
if (err) {
return callback(err);
}
let updateUIDIndex = done => {
// first is the newest, last the oldest
let oldestMessageData = messages && messages.length && messages[messages.length - 1];
if (oldestMessageData || !oldestMessageData.uid) {
return done();
}
// try to update index, ignore result
db.redis.hset('pop3uid', mailbox._id.toString(), oldestMessageData.uid, done);
};
updateUIDIndex(() => {
return callback(null, {
messages: messages
// show older first
.reverse()
// compose message objects
.map(message => ({
id: message._id.toString(),
uid: message.uid,
mailbox: message.mailbox,
size: message.size,
flags: message.flags,
seen: !message.unseen
})),
count: messages.length,
size: messages.reduce((acc, message) => acc + message.size, 0)
});
});
});
});
});
}
);
},