Foundry376/Mailspring
1
1
Fork 0
mirror of https://github.com/Foundry376/Mailspring.git synced 2024-09-21 07:46:06 +08:00
Code Issues Packages Projects Releases Wiki Activity

[local-sync] Run message processor for one message at a time

Browse source 
This avoids issues that arise when we process two messages on the same thread concurrently!
This commit is contained in:
Ben Gotow 2016-11-30 17:26:23 -08:00
parent 94722f27ab
commit 3d79f9b8be
1 changed files with 21 additions and 19 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

40
packages/local-sync/src/new-message-processor/index.js
View file

@ -3,27 +3,29 @@ const extractFiles = require('./extract-files')
const extractContacts = require('./extract-contacts')
const LocalDatabaseConnector = require('../shared/local-database-connector')
const Queue = require('promise-queue');
const queue = new Queue(1, Infinity);
function processNewMessage(message, imapMessage) {
process.nextTick(() => {
const {accountId} = message
queue.add(async () => {
const {accountId} = message;
const logger = global.Logger.forAccount({id: accountId}).child({message})
LocalDatabaseConnector.forAccount(accountId).then((db) => {
detectThread({db, message})
.then((thread) => {
message.threadId = thread.id
return db.Message.create(message)
})
.then(() => extractFiles({db, message, imapMessage}))
.then(() => extractContacts({db, message}))
.then(() => {
logger.info({
message_id: message.id,
uid: message.folderImapUID,
}, `MessageProcessor: Created and processed message`)
})
.catch((err) => logger.error(err, `MessageProcessor: Failed`))
})
})
const db = await LocalDatabaseConnector.forAccount(accountId);
try {
const thread = await detectThread({db, message});
message.threadId = thread.id;
await db.Message.create(message);
await extractFiles({db, message, imapMessage});
await extractContacts({db, message});
logger.info({
message_id: message.id,
uid: message.folderImapUID,
}, `MessageProcessor: Created and processed message`);
} catch (err) {
logger.error(err, `MessageProcessor: Failed`);
}
});
}
module.exports = {processNewMessage}