mirror of
https://github.com/nodemailer/wildduck.git
synced 2024-09-20 23:36:15 +08:00
use a separate mailer class
This commit is contained in:
Andris Reinman
parent
e721238a97
commit
741769fd3d
370
lib/maildrop.js
370
lib/maildrop.js
|
|
@ -2,127 +2,9 @@
|
||||||
|
|
||||||
const config = require('wild-config');
|
const config = require('wild-config');
|
||||||
const db = require('./db');
|
const db = require('./db');
|
||||||
const SeqIndex = require('seq-index');
|
const Maildropper = require('./Maildropper');
|
||||||
const DkimStream = require('./dkim-stream');
|
|
||||||
const MessageSplitter = require('./message-splitter');
|
|
||||||
const seqIndex = new SeqIndex();
|
|
||||||
const GridFSBucket = require('mongodb').GridFSBucket;
|
|
||||||
const uuid = require('uuid');
|
|
||||||
const os = require('os');
|
|
||||||
const hostname = os.hostname().toLowerCase();
|
|
||||||
const addressparser = require('addressparser');
|
|
||||||
const punycode = require('punycode');
|
|
||||||
const plugins = require('./plugins');
|
|
||||||
|
|
||||||
let gridstore;
|
let maildropper;
|
||||||
|
|
||||||
function convertAddresses(addresses, withNames, addressList) {
|
|
||||||
addressList = addressList || new Map();
|
|
||||||
|
|
||||||
flatten(addresses || []).forEach(address => {
|
|
||||||
if (address.address) {
|
|
||||||
let normalized = normalizeAddress(address, withNames);
|
|
||||||
let key = typeof normalized === 'string' ? normalized : normalized.address;
|
|
||||||
addressList.set(key, normalized);
|
|
||||||
} else if (address.group) {
|
|
||||||
convertAddresses(address.group, withNames, addressList);
|
|
||||||
}
|
|
||||||
});
|
|
||||||
|
|
||||||
return addressList;
|
|
||||||
}
|
|
||||||
|
|
||||||
function parseAddressList(headers, key, withNames) {
|
|
||||||
return parseAddressses(headers.getDecoded(key).map(header => header.value), withNames);
|
|
||||||
}
|
|
||||||
|
|
||||||
function parseAddressses(headerList, withNames) {
|
|
||||||
let map = convertAddresses(
|
|
||||||
headerList.map(address => {
|
|
||||||
if (typeof address === 'string') {
|
|
||||||
address = addressparser(address);
|
|
||||||
}
|
|
||||||
return address;
|
|
||||||
}),
|
|
||||||
withNames
|
|
||||||
);
|
|
||||||
return Array.from(map).map(entry => entry[1]);
|
|
||||||
}
|
|
||||||
|
|
||||||
function normalizeDomain(domain) {
|
|
||||||
domain = domain.toLowerCase().trim();
|
|
||||||
try {
|
|
||||||
domain = punycode.toASCII(domain);
|
|
||||||
} catch (E) {
|
|
||||||
// ignore
|
|
||||||
}
|
|
||||||
return domain;
|
|
||||||
}
|
|
||||||
|
|
||||||
// helper function to flatten arrays
|
|
||||||
function flatten(arr) {
|
|
||||||
let flat = [].concat(...arr);
|
|
||||||
return flat.some(Array.isArray) ? flatten(flat) : flat;
|
|
||||||
}
|
|
||||||
|
|
||||||
function normalizeAddress(address, withNames) {
|
|
||||||
if (typeof address === 'string') {
|
|
||||||
address = {
|
|
||||||
address
|
|
||||||
};
|
|
||||||
}
|
|
||||||
if (!address || !address.address) {
|
|
||||||
return '';
|
|
||||||
}
|
|
||||||
let user = address.address.substr(0, address.address.lastIndexOf('@'));
|
|
||||||
let domain = address.address.substr(address.address.lastIndexOf('@') + 1);
|
|
||||||
let addr = user.trim() + '@' + normalizeDomain(domain);
|
|
||||||
|
|
||||||
if (withNames) {
|
|
||||||
return {
|
|
||||||
name: address.name || '',
|
|
||||||
address: addr
|
|
||||||
};
|
|
||||||
}
|
|
||||||
|
|
||||||
return addr;
|
|
||||||
}
|
|
||||||
|
|
||||||
function updateHeaders(envelope) {
|
|
||||||
// Fetch sender and receiver addresses
|
|
||||||
envelope.parsedEnvelope = {
|
|
||||||
from: parseAddressList(envelope.headers, 'from').shift() || false,
|
|
||||||
to: parseAddressList(envelope.headers, 'to'),
|
|
||||||
cc: parseAddressList(envelope.headers, 'cc'),
|
|
||||||
bcc: parseAddressList(envelope.headers, 'bcc'),
|
|
||||||
replyTo: parseAddressList(envelope.headers, 'reply-to').shift() || false,
|
|
||||||
sender: parseAddressList(envelope.headers, 'sender').shift() || false
|
|
||||||
};
|
|
||||||
|
|
||||||
// Check Message-ID: value. Add if missing
|
|
||||||
let mId = envelope.headers.getFirst('message-id');
|
|
||||||
if (!mId) {
|
|
||||||
mId = '<' + uuid.v4() + '@' + (envelope.from.substr(envelope.from.lastIndexOf('@') + 1) || hostname) + '>';
|
|
||||||
|
|
||||||
envelope.headers.remove('message-id'); // in case there's an empty value
|
|
||||||
envelope.headers.add('Message-ID', mId);
|
|
||||||
}
|
|
||||||
envelope.messageId = mId;
|
|
||||||
|
|
||||||
// Check Date: value. Add if missing or invalid or future date
|
|
||||||
let date = envelope.headers.getFirst('date');
|
|
||||||
let dateVal = new Date(date);
|
|
||||||
if (!date || dateVal.toString() === 'Invalid Date' || dateVal < new Date(1000)) {
|
|
||||||
date = new Date().toUTCString().replace(/GMT/, '+0000');
|
|
||||||
envelope.headers.remove('date'); // remove old empty or invalid values
|
|
||||||
envelope.headers.add('Date', date);
|
|
||||||
}
|
|
||||||
|
|
||||||
envelope.date = date;
|
|
||||||
|
|
||||||
// Remove BCC if present
|
|
||||||
envelope.headers.remove('bcc');
|
|
||||||
}
|
|
||||||
|
|
||||||
module.exports = (options, callback) => {
|
module.exports = (options, callback) => {
|
||||||
if (!config.sender.enabled) {
|
if (!config.sender.enabled) {
|
||||||
|
|
@ -130,245 +12,15 @@ module.exports = (options, callback) => {
|
||||||
return false;
|
return false;
|
||||||
}
|
}
|
||||||
|
|
||||||
let id = options.id || seqIndex.get();
|
maildropper =
|
||||||
let seq = 0;
|
maildropper ||
|
||||||
let documents = [];
|
new Maildropper({
|
||||||
|
db,
|
||||||
let envelope = {
|
enabled: config.sender.enabled,
|
||||||
id,
|
zone: config.sender.zone,
|
||||||
|
collection: config.sender.collection,
|
||||||
from: options.from || '',
|
gfs: config.sender.gfs
|
||||||
to: Array.isArray(options.to) ? options.to : [].concat(options.to || []),
|
|
||||||
|
|
||||||
interface: options.interface || 'maildrop',
|
|
||||||
transtype: 'API',
|
|
||||||
time: Date.now(),
|
|
||||||
|
|
||||||
dkim: {
|
|
||||||
hashAlgo: 'sha256'
|
|
||||||
}
|
|
||||||
};
|
|
||||||
|
|
||||||
if (options.parentId) {
|
|
||||||
envelope.parentId = options.parentId;
|
|
||||||
}
|
|
||||||
|
|
||||||
if (options.reason) {
|
|
||||||
envelope.reason = options.reason;
|
|
||||||
}
|
|
||||||
|
|
||||||
let deliveries = [];
|
|
||||||
|
|
||||||
if (options.targets) {
|
|
||||||
options.targets.forEach(target => {
|
|
||||||
switch (target.type) {
|
|
||||||
case 'mail':
|
|
||||||
deliveries.push({
|
|
||||||
to: target.value
|
|
||||||
});
|
|
||||||
break;
|
|
||||||
case 'relay':
|
|
||||||
(Array.isArray(options.to) ? options.to : [].concat(options.to || [])).forEach(to => {
|
|
||||||
deliveries.push({
|
|
||||||
to,
|
|
||||||
mx: target.value.mx,
|
|
||||||
mxPort: target.value.mxPort,
|
|
||||||
mxAuth: target.value.mxAuth,
|
|
||||||
mxSecure: target.value.mxSecure
|
|
||||||
});
|
|
||||||
});
|
|
||||||
break;
|
|
||||||
case 'http':
|
|
||||||
(Array.isArray(options.to) ? options.to : [].concat(options.to || [])).forEach(to => {
|
|
||||||
deliveries.push({
|
|
||||||
to,
|
|
||||||
http: true,
|
|
||||||
targetUrl: target.value
|
|
||||||
});
|
|
||||||
});
|
|
||||||
break;
|
|
||||||
}
|
|
||||||
});
|
});
|
||||||
}
|
|
||||||
|
|
||||||
if (!deliveries.length) {
|
maildropper.push(options, callback);
|
||||||
deliveries = envelope.to.map(to => ({
|
|
||||||
to
|
|
||||||
}));
|
|
||||||
}
|
|
||||||
|
|
||||||
if (!deliveries.length) {
|
|
||||||
let err = new Error('No valid recipients');
|
|
||||||
err.code = 'ENORECIPIENTS';
|
|
||||||
setImmediate(() => callback(err));
|
|
||||||
return false;
|
|
||||||
}
|
|
||||||
|
|
||||||
let messageSplitter = new MessageSplitter();
|
|
||||||
let dkimStream = new DkimStream();
|
|
||||||
|
|
||||||
messageSplitter.once('headers', headers => {
|
|
||||||
envelope.headers = headers;
|
|
||||||
updateHeaders(envelope);
|
|
||||||
});
|
|
||||||
|
|
||||||
dkimStream.on('hash', bodyHash => {
|
|
||||||
// store relaxed body hash for signing
|
|
||||||
envelope.dkim.bodyHash = bodyHash;
|
|
||||||
envelope.bodySize = dkimStream.byteLength;
|
|
||||||
});
|
|
||||||
|
|
||||||
messageSplitter.once('error', err => dkimStream.emit('error', err));
|
|
||||||
|
|
||||||
store(id, dkimStream, err => {
|
|
||||||
if (err) {
|
|
||||||
return callback(err);
|
|
||||||
}
|
|
||||||
|
|
||||||
plugins.runHooks('maildrop', options, envelope, deliveries, () => {
|
|
||||||
envelope.headers = envelope.headers.getList();
|
|
||||||
setMeta(id, envelope, err => {
|
|
||||||
if (err) {
|
|
||||||
return removeMessage(id, () => callback(err));
|
|
||||||
}
|
|
||||||
|
|
||||||
let date = new Date();
|
|
||||||
|
|
||||||
for (let i = 0, len = deliveries.length; i < len; i++) {
|
|
||||||
let recipient = deliveries[i];
|
|
||||||
|
|
||||||
let deliveryZone = options.zone || config.sender.zone || 'default';
|
|
||||||
let recipientDomain = recipient.to.substr(recipient.to.lastIndexOf('@') + 1).replace(/[[\]]/g, '');
|
|
||||||
|
|
||||||
seq++;
|
|
||||||
let deliverySeq = (seq < 0x100 ? '0' : '') + (seq < 0x10 ? '0' : '') + seq.toString(16);
|
|
||||||
let delivery = {
|
|
||||||
id,
|
|
||||||
seq: deliverySeq,
|
|
||||||
|
|
||||||
// Actual delivery data
|
|
||||||
domain: recipientDomain,
|
|
||||||
sendingZone: deliveryZone,
|
|
||||||
|
|
||||||
assigned: 'no',
|
|
||||||
|
|
||||||
// actual recipient address
|
|
||||||
recipient: recipient.to,
|
|
||||||
|
|
||||||
locked: false,
|
|
||||||
lockTime: 0,
|
|
||||||
|
|
||||||
// earliest time to attempt delivery, defaults to now
|
|
||||||
queued: options.sendTime || date,
|
|
||||||
|
|
||||||
// queued date might change but created should not
|
|
||||||
created: date
|
|
||||||
};
|
|
||||||
|
|
||||||
if (recipient.http) {
|
|
||||||
delivery.http = recipient.http;
|
|
||||||
delivery.targetUrl = recipient.targetUrl;
|
|
||||||
}
|
|
||||||
|
|
||||||
['mx', 'mxPort', 'mxAuth', 'mxSecure'].forEach(key => {
|
|
||||||
if (recipient[key]) {
|
|
||||||
delivery[key] = recipient[key];
|
|
||||||
}
|
|
||||||
});
|
|
||||||
|
|
||||||
documents.push(delivery);
|
|
||||||
}
|
|
||||||
|
|
||||||
db.senderDb.collection(config.sender.collection).insertMany(
|
|
||||||
documents,
|
|
||||||
{
|
|
||||||
w: 1,
|
|
||||||
ordered: false
|
|
||||||
},
|
|
||||||
err => {
|
|
||||||
if (err) {
|
|
||||||
return callback(err);
|
|
||||||
}
|
|
||||||
|
|
||||||
callback(null, envelope);
|
|
||||||
}
|
|
||||||
);
|
|
||||||
});
|
|
||||||
});
|
|
||||||
});
|
|
||||||
messageSplitter.pipe(dkimStream);
|
|
||||||
return messageSplitter;
|
|
||||||
};
|
};
|
||||||
|
|
||||||
function store(id, stream, callback) {
|
|
||||||
gridstore =
|
|
||||||
gridstore ||
|
|
||||||
new GridFSBucket(db.senderDb, {
|
|
||||||
bucketName: config.sender.gfs
|
|
||||||
});
|
|
||||||
|
|
||||||
let returned = false;
|
|
||||||
let store = gridstore.openUploadStream('message ' + id, {
|
|
||||||
fsync: true,
|
|
||||||
contentType: 'message/rfc822',
|
|
||||||
metadata: {
|
|
||||||
created: new Date()
|
|
||||||
}
|
|
||||||
});
|
|
||||||
|
|
||||||
stream.once('error', err => {
|
|
||||||
if (returned) {
|
|
||||||
return;
|
|
||||||
}
|
|
||||||
returned = true;
|
|
||||||
|
|
||||||
store.once('finish', () => {
|
|
||||||
removeMessage(id, () => callback(err));
|
|
||||||
});
|
|
||||||
|
|
||||||
store.end();
|
|
||||||
});
|
|
||||||
|
|
||||||
store.once('error', err => {
|
|
||||||
if (returned) {
|
|
||||||
return;
|
|
||||||
}
|
|
||||||
returned = true;
|
|
||||||
callback(err);
|
|
||||||
});
|
|
||||||
|
|
||||||
store.once('finish', () => {
|
|
||||||
if (returned) {
|
|
||||||
return;
|
|
||||||
}
|
|
||||||
returned = true;
|
|
||||||
|
|
||||||
return callback(null, id);
|
|
||||||
});
|
|
||||||
|
|
||||||
stream.pipe(store);
|
|
||||||
}
|
|
||||||
|
|
||||||
function removeMessage(id, callback) {
|
|
||||||
gridstore.unlink('message ' + id, callback);
|
|
||||||
}
|
|
||||||
|
|
||||||
function setMeta(id, data, callback) {
|
|
||||||
db.senderDb.collection(config.sender.gfs + '.files').findOneAndUpdate(
|
|
||||||
{
|
|
||||||
filename: 'message ' + id
|
|
||||||
},
|
|
||||||
{
|
|
||||||
$set: {
|
|
||||||
'metadata.data': data
|
|
||||||
}
|
|
||||||
},
|
|
||||||
{},
|
|
||||||
err => {
|
|
||||||
if (err) {
|
|
||||||
return callback(err);
|
|
||||||
}
|
|
||||||
return callback();
|
|
||||||
}
|
|
||||||
);
|
|
||||||
}
|
|
||||||
|
|
|
||||||
385
lib/maildropper.js
Normal file
385
lib/maildropper.js
Normal file
|
|
@ -0,0 +1,385 @@
|
||||||
|
'use strict';
|
||||||
|
|
||||||
|
const SeqIndex = require('seq-index');
|
||||||
|
const DkimStream = require('./dkim-stream');
|
||||||
|
const MessageSplitter = require('./message-splitter');
|
||||||
|
const seqIndex = new SeqIndex();
|
||||||
|
const GridFSBucket = require('mongodb').GridFSBucket;
|
||||||
|
const uuid = require('uuid');
|
||||||
|
const os = require('os');
|
||||||
|
const hostname = os.hostname().toLowerCase();
|
||||||
|
const addressparser = require('addressparser');
|
||||||
|
const punycode = require('punycode');
|
||||||
|
const plugins = require('./plugins');
|
||||||
|
|
||||||
|
class Maildropper {
|
||||||
|
constructor(options) {
|
||||||
|
this.options = options || {};
|
||||||
|
this.db = options.db;
|
||||||
|
this.enabled = !!options.enabled;
|
||||||
|
this.zone = options.zone;
|
||||||
|
this.collection = options.collection;
|
||||||
|
this.gfs = options.gfs;
|
||||||
|
|
||||||
|
this.gridstore =
|
||||||
|
options.gridstore ||
|
||||||
|
new GridFSBucket(this.db.senderDb, {
|
||||||
|
bucketName: this.gfs
|
||||||
|
});
|
||||||
|
}
|
||||||
|
|
||||||
|
push(options, callback) {
|
||||||
|
if (!this.enabled) {
|
||||||
|
setImmediate(() => callback(null, false));
|
||||||
|
return false;
|
||||||
|
}
|
||||||
|
|
||||||
|
let id = options.id || seqIndex.get();
|
||||||
|
let seq = 0;
|
||||||
|
let documents = [];
|
||||||
|
|
||||||
|
let envelope = {
|
||||||
|
id,
|
||||||
|
|
||||||
|
from: options.from || '',
|
||||||
|
to: Array.isArray(options.to) ? options.to : [].concat(options.to || []),
|
||||||
|
|
||||||
|
interface: options.interface || 'maildrop',
|
||||||
|
transtype: 'API',
|
||||||
|
time: Date.now(),
|
||||||
|
|
||||||
|
dkim: {
|
||||||
|
hashAlgo: 'sha256'
|
||||||
|
}
|
||||||
|
};
|
||||||
|
|
||||||
|
if (options.parentId) {
|
||||||
|
envelope.parentId = options.parentId;
|
||||||
|
}
|
||||||
|
|
||||||
|
if (options.reason) {
|
||||||
|
envelope.reason = options.reason;
|
||||||
|
}
|
||||||
|
|
||||||
|
let deliveries = [];
|
||||||
|
|
||||||
|
if (options.targets) {
|
||||||
|
options.targets.forEach(target => {
|
||||||
|
switch (target.type) {
|
||||||
|
case 'mail':
|
||||||
|
deliveries.push({
|
||||||
|
to: target.value
|
||||||
|
});
|
||||||
|
break;
|
||||||
|
|
||||||
|
case 'relay':
|
||||||
|
(Array.isArray(options.to) ? options.to : [].concat(options.to || [])).forEach(to => {
|
||||||
|
deliveries.push({
|
||||||
|
to,
|
||||||
|
mx: target.value.mx,
|
||||||
|
mxPort: target.value.mxPort,
|
||||||
|
mxAuth: target.value.mxAuth,
|
||||||
|
mxSecure: target.value.mxSecure
|
||||||
|
});
|
||||||
|
});
|
||||||
|
break;
|
||||||
|
|
||||||
|
case 'http':
|
||||||
|
(Array.isArray(options.to) ? options.to : [].concat(options.to || [])).forEach(to => {
|
||||||
|
deliveries.push({
|
||||||
|
to,
|
||||||
|
http: true,
|
||||||
|
targetUrl: target.value
|
||||||
|
});
|
||||||
|
});
|
||||||
|
break;
|
||||||
|
}
|
||||||
|
});
|
||||||
|
}
|
||||||
|
|
||||||
|
if (!deliveries.length) {
|
||||||
|
deliveries = envelope.to.map(to => ({
|
||||||
|
to
|
||||||
|
}));
|
||||||
|
}
|
||||||
|
|
||||||
|
if (!deliveries.length) {
|
||||||
|
let err = new Error('No valid recipients');
|
||||||
|
err.code = 'ENORECIPIENTS';
|
||||||
|
setImmediate(() => callback(err));
|
||||||
|
return false;
|
||||||
|
}
|
||||||
|
|
||||||
|
let messageSplitter = new MessageSplitter();
|
||||||
|
let dkimStream = new DkimStream();
|
||||||
|
|
||||||
|
messageSplitter.once('headers', headers => {
|
||||||
|
envelope.headers = headers;
|
||||||
|
this.updateHeaders(envelope);
|
||||||
|
});
|
||||||
|
|
||||||
|
dkimStream.on('hash', bodyHash => {
|
||||||
|
// store relaxed body hash for signing
|
||||||
|
envelope.dkim.bodyHash = bodyHash;
|
||||||
|
envelope.bodySize = dkimStream.byteLength;
|
||||||
|
});
|
||||||
|
|
||||||
|
messageSplitter.once('error', err => dkimStream.emit('error', err));
|
||||||
|
|
||||||
|
this.store(id, dkimStream, err => {
|
||||||
|
if (err) {
|
||||||
|
return callback(err);
|
||||||
|
}
|
||||||
|
|
||||||
|
plugins.runHooks('maildrop', options, envelope, deliveries, () => {
|
||||||
|
envelope.headers = envelope.headers.getList();
|
||||||
|
this.setMeta(id, envelope, err => {
|
||||||
|
if (err) {
|
||||||
|
return this.removeMessage(id, () => callback(err));
|
||||||
|
}
|
||||||
|
|
||||||
|
let date = new Date();
|
||||||
|
|
||||||
|
for (let i = 0, len = deliveries.length; i < len; i++) {
|
||||||
|
let recipient = deliveries[i];
|
||||||
|
|
||||||
|
let deliveryZone = options.zone || this.zone || 'default';
|
||||||
|
let recipientDomain = recipient.to.substr(recipient.to.lastIndexOf('@') + 1).replace(/[[\]]/g, '');
|
||||||
|
|
||||||
|
seq++;
|
||||||
|
let deliverySeq = (seq < 0x100 ? '0' : '') + (seq < 0x10 ? '0' : '') + seq.toString(16);
|
||||||
|
let delivery = {
|
||||||
|
id,
|
||||||
|
seq: deliverySeq,
|
||||||
|
|
||||||
|
// Actual delivery data
|
||||||
|
domain: recipientDomain,
|
||||||
|
sendingZone: deliveryZone,
|
||||||
|
|
||||||
|
assigned: 'no',
|
||||||
|
|
||||||
|
// actual recipient address
|
||||||
|
recipient: recipient.to,
|
||||||
|
|
||||||
|
locked: false,
|
||||||
|
lockTime: 0,
|
||||||
|
|
||||||
|
// earliest time to attempt delivery, defaults to now
|
||||||
|
queued: options.sendTime || date,
|
||||||
|
|
||||||
|
// queued date might change but created should not
|
||||||
|
created: date
|
||||||
|
};
|
||||||
|
|
||||||
|
if (recipient.http) {
|
||||||
|
delivery.http = recipient.http;
|
||||||
|
delivery.targetUrl = recipient.targetUrl;
|
||||||
|
}
|
||||||
|
|
||||||
|
['mx', 'mxPort', 'mxAuth', 'mxSecure'].forEach(key => {
|
||||||
|
if (recipient[key]) {
|
||||||
|
delivery[key] = recipient[key];
|
||||||
|
}
|
||||||
|
});
|
||||||
|
|
||||||
|
documents.push(delivery);
|
||||||
|
}
|
||||||
|
|
||||||
|
this.db.senderDb.collection(this.collection).insertMany(
|
||||||
|
documents,
|
||||||
|
{
|
||||||
|
w: 1,
|
||||||
|
ordered: false
|
||||||
|
},
|
||||||
|
err => {
|
||||||
|
if (err) {
|
||||||
|
return callback(err);
|
||||||
|
}
|
||||||
|
|
||||||
|
callback(null, envelope);
|
||||||
|
}
|
||||||
|
);
|
||||||
|
});
|
||||||
|
});
|
||||||
|
});
|
||||||
|
messageSplitter.pipe(dkimStream);
|
||||||
|
return messageSplitter;
|
||||||
|
}
|
||||||
|
|
||||||
|
convertAddresses(addresses, withNames, addressList) {
|
||||||
|
addressList = addressList || new Map();
|
||||||
|
|
||||||
|
this.flatten(addresses || []).forEach(address => {
|
||||||
|
if (address.address) {
|
||||||
|
let normalized = this.normalizeAddress(address, withNames);
|
||||||
|
let key = typeof normalized === 'string' ? normalized : normalized.address;
|
||||||
|
addressList.set(key, normalized);
|
||||||
|
} else if (address.group) {
|
||||||
|
this.convertAddresses(address.group, withNames, addressList);
|
||||||
|
}
|
||||||
|
});
|
||||||
|
|
||||||
|
return addressList;
|
||||||
|
}
|
||||||
|
|
||||||
|
parseAddressList(headers, key, withNames) {
|
||||||
|
return this.parseAddressses(headers.getDecoded(key).map(header => header.value), withNames);
|
||||||
|
}
|
||||||
|
|
||||||
|
parseAddressses(headerList, withNames) {
|
||||||
|
let map = this.convertAddresses(
|
||||||
|
headerList.map(address => {
|
||||||
|
if (typeof address === 'string') {
|
||||||
|
address = addressparser(address);
|
||||||
|
}
|
||||||
|
return address;
|
||||||
|
}),
|
||||||
|
withNames
|
||||||
|
);
|
||||||
|
return Array.from(map).map(entry => entry[1]);
|
||||||
|
}
|
||||||
|
|
||||||
|
normalizeDomain(domain) {
|
||||||
|
domain = domain.toLowerCase().trim();
|
||||||
|
try {
|
||||||
|
domain = punycode.toASCII(domain);
|
||||||
|
} catch (E) {
|
||||||
|
// ignore
|
||||||
|
}
|
||||||
|
return domain;
|
||||||
|
}
|
||||||
|
|
||||||
|
// helper function to flatten arrays
|
||||||
|
flatten(arr) {
|
||||||
|
let flat = [].concat(...arr);
|
||||||
|
return flat.some(Array.isArray) ? this.flatten(flat) : flat;
|
||||||
|
}
|
||||||
|
|
||||||
|
normalizeAddress(address, withNames) {
|
||||||
|
if (typeof address === 'string') {
|
||||||
|
address = {
|
||||||
|
address
|
||||||
|
};
|
||||||
|
}
|
||||||
|
if (!address || !address.address) {
|
||||||
|
return '';
|
||||||
|
}
|
||||||
|
let user = address.address.substr(0, address.address.lastIndexOf('@'));
|
||||||
|
let domain = address.address.substr(address.address.lastIndexOf('@') + 1);
|
||||||
|
let addr = user.trim() + '@' + this.normalizeDomain(domain);
|
||||||
|
|
||||||
|
if (withNames) {
|
||||||
|
return {
|
||||||
|
name: address.name || '',
|
||||||
|
address: addr
|
||||||
|
};
|
||||||
|
}
|
||||||
|
|
||||||
|
return addr;
|
||||||
|
}
|
||||||
|
|
||||||
|
updateHeaders(envelope) {
|
||||||
|
// Fetch sender and receiver addresses
|
||||||
|
envelope.parsedEnvelope = {
|
||||||
|
from: this.parseAddressList(envelope.headers, 'from').shift() || false,
|
||||||
|
to: this.parseAddressList(envelope.headers, 'to'),
|
||||||
|
cc: this.parseAddressList(envelope.headers, 'cc'),
|
||||||
|
bcc: this.parseAddressList(envelope.headers, 'bcc'),
|
||||||
|
replyTo: this.parseAddressList(envelope.headers, 'reply-to').shift() || false,
|
||||||
|
sender: this.parseAddressList(envelope.headers, 'sender').shift() || false
|
||||||
|
};
|
||||||
|
|
||||||
|
// Check Message-ID: value. Add if missing
|
||||||
|
let mId = envelope.headers.getFirst('message-id');
|
||||||
|
if (!mId) {
|
||||||
|
mId = '<' + uuid.v4() + '@' + (envelope.from.substr(envelope.from.lastIndexOf('@') + 1) || hostname) + '>';
|
||||||
|
|
||||||
|
envelope.headers.remove('message-id'); // in case there's an empty value
|
||||||
|
envelope.headers.add('Message-ID', mId);
|
||||||
|
}
|
||||||
|
envelope.messageId = mId;
|
||||||
|
|
||||||
|
// Check Date: value. Add if missing or invalid or future date
|
||||||
|
let date = envelope.headers.getFirst('date');
|
||||||
|
let dateVal = new Date(date);
|
||||||
|
if (!date || dateVal.toString() === 'Invalid Date' || dateVal < new Date(1000)) {
|
||||||
|
date = new Date().toUTCString().replace(/GMT/, '+0000');
|
||||||
|
envelope.headers.remove('date'); // remove old empty or invalid values
|
||||||
|
envelope.headers.add('Date', date);
|
||||||
|
}
|
||||||
|
|
||||||
|
envelope.date = date;
|
||||||
|
|
||||||
|
// Remove BCC if present
|
||||||
|
envelope.headers.remove('bcc');
|
||||||
|
}
|
||||||
|
|
||||||
|
store(id, stream, callback) {
|
||||||
|
let returned = false;
|
||||||
|
let store = this.gridstore.openUploadStream('message ' + id, {
|
||||||
|
fsync: true,
|
||||||
|
contentType: 'message/rfc822',
|
||||||
|
metadata: {
|
||||||
|
created: new Date()
|
||||||
|
}
|
||||||
|
});
|
||||||
|
|
||||||
|
stream.once('error', err => {
|
||||||
|
if (returned) {
|
||||||
|
return;
|
||||||
|
}
|
||||||
|
returned = true;
|
||||||
|
|
||||||
|
store.once('finish', () => {
|
||||||
|
this.removeMessage(id, () => callback(err));
|
||||||
|
});
|
||||||
|
|
||||||
|
store.end();
|
||||||
|
});
|
||||||
|
|
||||||
|
store.once('error', err => {
|
||||||
|
if (returned) {
|
||||||
|
return;
|
||||||
|
}
|
||||||
|
returned = true;
|
||||||
|
callback(err);
|
||||||
|
});
|
||||||
|
|
||||||
|
store.once('finish', () => {
|
||||||
|
if (returned) {
|
||||||
|
return;
|
||||||
|
}
|
||||||
|
returned = true;
|
||||||
|
|
||||||
|
return callback(null, id);
|
||||||
|
});
|
||||||
|
|
||||||
|
stream.pipe(store);
|
||||||
|
}
|
||||||
|
|
||||||
|
removeMessage(id, callback) {
|
||||||
|
this.gridstore.unlink('message ' + id, callback);
|
||||||
|
}
|
||||||
|
|
||||||
|
setMeta(id, data, callback) {
|
||||||
|
this.db.senderDb.collection(this.gfs + '.files').findOneAndUpdate(
|
||||||
|
{
|
||||||
|
filename: 'message ' + id
|
||||||
|
},
|
||||||
|
{
|
||||||
|
$set: {
|
||||||
|
'metadata.data': data
|
||||||
|
}
|
||||||
|
},
|
||||||
|
{},
|
||||||
|
err => {
|
||||||
|
if (err) {
|
||||||
|
return callback(err);
|
||||||
|
}
|
||||||
|
return callback();
|
||||||
|
}
|
||||||
|
);
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
|
module.exports = Maildropper;
|
||||||
Loading…
Reference in a new issue