使用IMAP和JavaScript异步获取邮件及附件的问题排查

功能实现计划 #

• 按发件人、主题及时间范围筛选邮件
• 统计符合条件的邮件数量
• 为每封邮件筛选PDF格式的附件
• 将符合条件的附件构建为对象存入数组，操作完成后统一返回前端（空数组也可）

遇到的问题 #

向指定邮箱发送了2封含相同PDF附件、相同主题的测试邮件，但返回的数组有时仅含1个对象，有时为空数组，始终无法得到预期的2个对象。

已尝试的方案 #

• 定义IMAP搜索函数，提前初始化存储结果的空数组
• 基于搜索函数创建流，通过fetch函数接收message参数并以流形式处理
• 使用simpleParser解析函数，为每个含附件的解析结果构建返回给前端的对象

相关代码 #

邮件消息处理代码 #

fetch.on('message', (msg) => {
    msg.on('body', (stream) => {
        simpleParser(stream, async (err, parsed) => {
            if (err) throw err;
            if (parsed.attachments) {
                // 已提前定义为空数组    
                attachmentPromises = parsed.attachments.map(async (attachment, index) => {
                    return new Promise((resolve, reject) => {
                        if (attachment.contentType === 'application/pdf') {
                            // 处理PDF...
                            resolve({
                                // 键值对形式的对象详情
                            });
                        } else {
                            resolve(null); 
                        }
                    });
                });
                
                // 等待Promise resolve
                Promise.all(attachmentPromises).then(attachments => {
                    // 过滤掉null值
                    const validAttachments = attachments.filter(attachment => attachment !== null);
                    allAttachmentsData = allAttachmentsData.concat(validAttachments);
                });
            }
        });
    });
});

Fetch事件处理代码 #

fetch.once('error', (err) => {
    console.log('Fetch error: ' + err);
});

fetch.once('end', function () {
    // allAttachmentsData 为空
    return res.status(200).json(allAttachmentsData);
})

问题分析与解决方案 #

核心问题是异步操作未正确等待：fetch的end事件触发时，邮件解析和附件处理的异步任务还未完成，导致返回的allAttachmentsData为空或不完整。

修复步骤 #

1. 收集所有邮件处理的Promise，确保所有异步操作完成后再返回结果
2. 避免直接修改全局变量，改用Promise链式或async/await管理流程

修复后的代码示例 #

// 收集所有邮件处理的Promise
const mailProcessingPromises = [];

fetch.on('message', (msg) => {
    const mailPromise = new Promise((resolve) => {
        msg.on('body', (stream) => {
            simpleParser(stream, (err, parsed) => {
                if (err) {
                    console.error('解析邮件出错:', err);
                    return resolve([]); // 出错时返回空数组，不中断整体流程
                }
                if (!parsed.attachments) return resolve([]);
                
                // 处理附件的Promise集合
                const attachmentPromises = parsed.attachments.map(attachment => {
                    if (attachment.contentType === 'application/pdf') {
                        // 处理PDF并返回目标对象
                        return Promise.resolve({
                            // 键值对形式的对象详情
                        });
                    }
                    return Promise.resolve(null);
                });
                
                Promise.all(attachmentPromises).then(attachments => {
                    const validAttachments = attachments.filter(att => att !== null);
                    resolve(validAttachments);
                });
            });
        });
    });
    mailProcessingPromises.push(mailPromise);
});

fetch.once('error', (err) => {
    console.log('Fetch error: ' + err);
    return res.status(500).json({ error: err.message });
});

fetch.once('end', async function () {
    // 等待所有邮件处理完成
    const allAttachments = await Promise.all(mailProcessingPromises);
    // 扁平化二维数组，得到最终附件列表
    const allAttachmentsData = allAttachments.flat();
    return res.status(200).json(allAttachmentsData);
})

关键改进点 #

• 为每封邮件创建独立Promise，确保邮件解析和附件处理完成后再resolve
• 统一收集所有邮件Promise，在end事件中用Promise.all等待全部完成
• 使用flat()扁平化数组，整合所有有效附件
• 完善错误处理，单封邮件解析失败不会导致整体流程中断

内容的提问来源于stack exchange，提问作者daniel sas