node-mbox

import { Mbox, MboxStream } from 'node-mbox'; import fs from 'fs'; import split from 'line-stream'; // 1. Pass it a filename const mboxFromFile = new Mbox(); fs.createReadStream('test/test-4-message.mbox').pipe(mboxFromFile); // 2. Pass it a stream and use a custom line splitter const mailboxStream = fs.createReadStream('test/test-4-message.mbox'); const splitter = split('\n'); const mboxFromCustomStream = mailboxStream.pipe(splitter).pipe(new Mbox()); // 3. Pass it a stream and use the default line splitter (same as #2 without explicit splitter) const mboxFromDefaultStream = MboxStream(fs.createReadStream('test/test-4-message.mbox'), { includeMboxHeader: false }); const activeMbox = mboxFromDefaultStream; // Choose one for demonstration activeMbox.on('data', function(msg) { // `msg` is a `Buffer` instance console.log('Got a message (first 100 chars):', msg.toString().substring(0, 100) + '...'); }); activeMbox.on('error', function(err) { console.log('Got an error:', err); }); activeMbox.on('finish', function() { console.log('Done reading mbox file.'); }); // Example for an input file. Create a dummy if it doesn't exist for running the quickstart. // You'd typically pipe real mbox data into this. // For quick testing, you can create a simple file: // echo "From MAILER-DAEMON Mon Apr 18 10:00:00 2022\nSubject: Test Email 1\n\nThis is the body of test email 1.\n\nFrom MAILER-DAEMON Mon Apr 18 10:01:00 2022\nSubject: Test Email 2\n\nThis is the body of test email 2." > test/test-4-message.mbox