gistfile1.js

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

exports.hook_queue = function (callback, connection) {
    var plugin = this;
    
    // Parse the mail first...
    var mp = new MailParser({fix_smtp_escapes: 0});
    
    var headers;
    var body;
    
    this.loginfo("parsing mail...");
    
    mp.on('headers', function (h) {
        plugin.loginfo(util.inspect(h));
        headers = h;
    });
    
    mp.on('body', function (b) {
        plugin.loginfo(util.inspect(b));
        body = b;
    });
    
    connection.transaction.data_lines.forEach(function(l) { plugin.logprotocol(l); mp.feed(l); });
    
    mp.end();
    
    callback(CONT);
};