mongo.js

var MailParser = require("mailparser").MailParser;

exports.hook_queue = function (callback, connection) {
    // Parse the mail first...
    var mp = new MailParser({fix_smtp_escapes: 0});
    
    var headers;
    var body;
    var t = this;    
    mp.on('header', function (h) {
        headers = h;
        t.loginfo(headers);
    });
    
    mp.on('body', function (b) {
        body = b;
        t.loginfo(body);
    });
    mp.on('end', function() { t.loginfo('End!'); });
    this.loginfo(connection.transaction.data_lines);    
    connection.transaction.data_lines.forEach(mp.feed);

    mp.end();
};