npm read email

1npm install emailjs-com --save

1var Imap = require("imap");
2var MailParser = require("mailparser").MailParser;
3var Promise = require("bluebird");
4Promise.longStackTraces();
5
6var imapConfig = {
7    user: 'USERNAME',
8    password: 'PASSWORD',
9    host: 'HOST',
10    port: 993,
11    tls: true
12};
13
14var imap = new Imap(imapConfig);
15Promise.promisifyAll(imap);
16
17imap.once("ready", execute);
18imap.once("error", function(err) {
19    log.error("Connection error: " + err.stack);
20});
21
22imap.connect();
23
24function execute() {
25    imap.openBox("INBOX", false, function(err, mailBox) {
26        if (err) {
27            console.error(err);
28            return;
29        }
30        imap.search(["UNSEEN"], function(err, results) {
31            if(!results || !results.length){console.log("No unread mails");imap.end();return;}
32            /* mark as seen
33            imap.setFlags(results, ['\\Seen'], function(err) {
34                if (!err) {
35                    console.log("marked as read");
36                } else {
37                    console.log(JSON.stringify(err, null, 2));
38                }
39            });*/
40
41            var f = imap.fetch(results, { bodies: "" });
42            f.on("message", processMessage);
43            f.once("error", function(err) {
44                return Promise.reject(err);
45            });
46            f.once("end", function() {
47                console.log("Done fetching all unseen messages.");
48                imap.end();
49            });
50        });
51    });
52}
53
54
55function processMessage(msg, seqno) {
56    console.log("Processing msg #" + seqno);
57    // console.log(msg);
58
59    var parser = new MailParser();
60    parser.on("headers", function(headers) {
61        console.log("Header: " + JSON.stringify(headers));
62    });
63
64    parser.on('data', data => {
65        if (data.type === 'text') {
66            console.log(seqno);
67            console.log(data.text);  /* data.html*/
68        }
69
70        // if (data.type === 'attachment') {
71        //     console.log(data.filename);
72        //     data.content.pipe(process.stdout);
73        //     // data.content.on('end', () => data.release());
74        // }
75     });
76
77    msg.on("body", function(stream) {
78        stream.on("data", function(chunk) {
79            parser.write(chunk.toString("utf8"));
80        });
81    });
82    msg.once("end", function() {
83        // console.log("Finished msg #" + seqno);
84        parser.end();
85    });
86}