var UTIL = require("util");
var HTTP = require("http");
var HTTPS = require("https");
var URL = require("url");
var HTMLPARSER = require("htmlparser2");
var FORMDATA = require("form-data");
var IMAP = require('imap');
var INSPECT = require('util').inspect;
var MAILPARSER = require('mailparser').MailParser;
var fs = require('fs'), fileStream;


var imap = new IMAP({
	user:'xx@xx',
	password:'password',
	host:'imap.qq.com',
	port:'993',
	tls:true
});

function openInbox(cb){
	imap.openBox('INBOX',true,cb);
}

imap.once('ready', function() {
    openInbox(function(err, box) {
        //邮件搜索
        imap.search([ 'SEEN', ['BEFORE', '2015-05-10'] ], function(err, results) {
            console.log(results);
            if (err) throw err;
            
            var f = imap.fetch(results, { 
                bodies: '',
                struct: true
            });
            
            f.on('message', function(msg, seqno) {
                console.log('Message #%d', seqno);
                var prefix = '(#' + seqno + ') ';
                msg.on('body', function(stream, info) {
                    console.log('INFO WHICH:',info.which);
                    if (info.which === 'TEXT'){
                        console.log(prefix + 'Body [%s] found, %d total bytes', INSPECT(info.which), info.size);
                    }
                    
                    var mailparser = new MAILPARSER();
                    stream.pipe(mailparser);
                    mailparser.on("end",function( mail ){
                        fs.writeFile('msg-' + seqno + '-body.html', mail.text, function (err) {
                            if (err) throw err;
                            console.log(prefix + 'saved!');
                        });
                    });
                });
                
                msg.once('attributes', function(attrs) {
                    console.log(prefix + 'Attributes: %s', INSPECT(attrs, false, 8));
                });
                msg.once('end', function() {
                    console.log(prefix + 'Finished');
                });
            });

            f.once('error', function(err) {
                console.log('Fetch error: ' + err);
            });

            f.once('end', function() {
                console.log('Done fetching all messages!');
                imap.end();
            });
        });
    });
});
 
imap.once('error', function(err) {
  console.log(err);
});
 
imap.once('end', function() {
  console.log('Connection ended');
});
 
imap.connect();

node app.js