node.js - nodejs mailparser多次解析相同的消息

我同时使用 inbox 和 mailparser npm 模块来读取和解析邮箱中的电子邮件。
我在解析重复消息时遇到了一些麻烦。目前正在发生的是:
正如您对电子邮件服务器所期望的那样，电子邮件将被放入正确的邮箱中。然后它们被 inbox 在我的 node.js 应用程序中提取。然后它们被传送到 mailparser 并被解析。
这是正常工作。问题是当我发送第二封电子邮件时，我又收到了第一封电子邮件。有时我会得到多个，但我还没有弄清楚是什么原因造成的。

let _inbox      = require( "inbox"      );
let _MailParser = require( "mailparser" ).MailParser;

let parser  = new _MailParser();
let mail    = _inbox.createConnection( false, "mail.myemailserver.com", {
  auth: {
    user: "[email protected]",
    pass: "mypasswordthatissostrongnoonewilleverguessit:)"
  }
});

mail.on( "new", ( message ) => {
  console.log( message.UID, message.title );
  db_insert( DB.collection( "email_ids" ), { _id: message.UID } ).then( () => {
    mail.createMessageStream( message.UID ).pipe( parser );
  });
});

parser.on( "end", ( message ) => {
  // This works the first time, I get the correct message.
  // The second time this gets called I just get the first message again.
});

我的蜘蛛侠感觉告诉我这与我不知道 streams 和 pipe 如何工作的事实有关。还值得注意的是，这是我第一次使用这些库中的任何一个，我可能错过了一些东西。
mailparser
inbox
我正在使用 MongoDB，如果您尝试插入相同的 _id 两次，它会抛出一个不稳定的问题，但这根本不是在提示。这加强了我对 streams 和 pipe 的怀疑。
我将 es6 与 babel 转译器一起使用。
更新
我不再需要这个问题的答案。我决定寻找一个不同的图书馆。我现在正在使用 mail-notifier 。
以防万一有人感兴趣。这就是我解决问题的方法。

let _notifier = require( "mail-notifier" );

let imap = {
  user    : "[email protected]",
  password: "mypasswordthatissostrongnoonewilleverguessit:)",
  host    : "mail.mymailserver.com"
};

_notifier( imap ).on( "mail", ( mail ) => {
  // process email
}).start();

我仍然有兴趣知道是什么导致了另一种方法的问题，但这并不重要。

最佳答案

我有同样的问题。
原因是每次运行一个循环时都必须创建新的 MailParser 实例。

let _MailParser = require( "mailparser" ).MailParser;

mail.on( "new", ( message ) => {

  parser = new _MailParser();

  // do your stuff

  parser.on( "end", ( message ) => {

     // finished

  });
}

关于node.js - nodejs mailparser多次解析相同的消息，我们在Stack Overflow上找到一个类似的问题：https://stackoverflow.com/questions/32009878/