Parse Mbox

parse-mbox.js

const fs = require("fs");
const Mbox = require("node-mbox");
const { simpleParser } = require("mailparser");

const mbox = new Mbox("./some.mbox/mbox");

const stream = fs.createWriteStream("./emails.json");
stream.write("[");

mbox.on("message", function (msg) {
  simpleParser(msg.toString(), null, (err, parsed) => {
    if (err) {
      throw new Error(err);
    }

    stream.write(JSON.stringify(parsed));
    stream.write(",");
  });
});

mbox.on("error", function (err) {
  throw new Error(err);
});

mbox.on("end", function () {
  stream.end("]");
  console.log('Done')
});