mirror of
https://github.com/nodemailer/wildduck.git
synced 2025-09-14 09:04:59 +08:00
Added API endpoint for sending emails
This commit is contained in:
Andris Reinman
parent
0e25618cda
commit
233a6fbd64
8 changed files with 825 additions and 156 deletions
2
api.js
2
api.js
|
|
@ -21,6 +21,7 @@ const u2fRoutes = require('./lib/api/2fa/u2f');
|
|||
const updatesRoutes = require('./lib/api/updates');
|
||||
const authRoutes = require('./lib/api/auth');
|
||||
const autoreplyRoutes = require('./lib/api/autoreply');
|
||||
const submitRoutes = require('./lib/api/submit');
|
||||
|
||||
const serverOptions = {
|
||||
name: 'Wild Duck API',
|
||||
|
|
@ -139,6 +140,7 @@ module.exports = done => {
|
|||
updatesRoutes(db, server, notifier);
|
||||
authRoutes(db, server, userHandler);
|
||||
autoreplyRoutes(db, server);
|
||||
submitRoutes(db, server, messageHandler);
|
||||
|
||||
server.on('error', err => {
|
||||
if (!started) {
|
||||
|
|
|
|||
File diff suppressed because one or more lines are too long
File diff suppressed because one or more lines are too long
|
|
@ -1 +1 @@
|
|||
define({
"name": "wildduck",
"version": "1.0.0",
"description": "WildDuck API docs. Under construction, see old docs here: https://github.com/nodemailer/wildduck/blob/master/docs/api.md",
"title": "WildDuck API",
"url": "http://localhost:8080",
"sampleUrl": false,
"defaultVersion": "0.0.0",
"apidoc": "0.3.0",
"generator": {
"name": "apidoc",
"time": "2017-11-28T14:13:22.559Z",
"url": "http://apidocjs.com",
"version": "0.17.6"
}
});
|
||||
define({
"name": "wildduck",
"version": "1.0.0",
"description": "WildDuck API docs. Under construction, see old docs here: https://github.com/nodemailer/wildduck/blob/master/docs/api.md",
"title": "WildDuck API",
"url": "http://localhost:8080",
"sampleUrl": false,
"defaultVersion": "0.0.0",
"apidoc": "0.3.0",
"generator": {
"name": "apidoc",
"time": "2017-11-29T11:59:34.485Z",
"url": "http://apidocjs.com",
"version": "0.17.6"
}
});
|
||||
|
|
|
|||
|
|
@ -1 +1 @@
|
|||
{
"name": "wildduck",
"version": "1.0.0",
"description": "WildDuck API docs. Under construction, see old docs here: https://github.com/nodemailer/wildduck/blob/master/docs/api.md",
"title": "WildDuck API",
"url": "http://localhost:8080",
"sampleUrl": false,
"defaultVersion": "0.0.0",
"apidoc": "0.3.0",
"generator": {
"name": "apidoc",
"time": "2017-11-28T14:13:22.559Z",
"url": "http://apidocjs.com",
"version": "0.17.6"
}
}
|
||||
{
"name": "wildduck",
"version": "1.0.0",
"description": "WildDuck API docs. Under construction, see old docs here: https://github.com/nodemailer/wildduck/blob/master/docs/api.md",
"title": "WildDuck API",
"url": "http://localhost:8080",
"sampleUrl": false,
"defaultVersion": "0.0.0",
"apidoc": "0.3.0",
"generator": {
"name": "apidoc",
"time": "2017-11-29T11:59:34.485Z",
"url": "http://apidocjs.com",
"version": "0.17.6"
}
}
|
||||
|
|
|
|||
652
lib/api/submit.js
Normal file
652
lib/api/submit.js
Normal file
|
|
@ -0,0 +1,652 @@
|
|||
'use strict';
|
||||
|
||||
const config = require('wild-config');
|
||||
const log = require('npmlog');
|
||||
const libmime = require('libmime');
|
||||
const MailComposer = require('nodemailer/lib/mail-composer');
|
||||
const Joi = require('../joi');
|
||||
const ObjectID = require('mongodb').ObjectID;
|
||||
const tools = require('../tools');
|
||||
const maildrop = require('../maildrop');
|
||||
const Transform = require('stream').Transform;
|
||||
|
||||
class StreamCollect extends Transform {
|
||||
constructor() {
|
||||
super();
|
||||
this.chunks = [];
|
||||
this.chunklen = 0;
|
||||
}
|
||||
_transform(chunk, encoding, done) {
|
||||
this.chunks.push(chunk);
|
||||
this.chunklen += chunk.length;
|
||||
this.push(chunk);
|
||||
done();
|
||||
}
|
||||
}
|
||||
|
||||
module.exports = (db, server, messageHandler) => {
|
||||
function sendMessage(options, callback) {
|
||||
let user = options.user;
|
||||
|
||||
db.users.collection('users').findOne(
|
||||
{ _id: user },
|
||||
{
|
||||
fields: {
|
||||
username: true,
|
||||
name: true,
|
||||
address: true,
|
||||
quota: true,
|
||||
storageUsed: true,
|
||||
recipients: true,
|
||||
encryptMessages: true,
|
||||
pubKey: true,
|
||||
disabled: true
|
||||
}
|
||||
},
|
||||
(err, userData) => {
|
||||
if (err) {
|
||||
err.code = 'ERRDB';
|
||||
return callback(err);
|
||||
}
|
||||
|
||||
if (!userData) {
|
||||
err = new Error('This user does not exist');
|
||||
err.code = 'ERRMISSINGUSER';
|
||||
return callback();
|
||||
}
|
||||
|
||||
if (userData.disabled) {
|
||||
err = new Error('User account is disabled');
|
||||
err.code = 'ERRDISABLEDUSER';
|
||||
return callback(err);
|
||||
}
|
||||
|
||||
userData.recipients = userData.recipients || config.maxRecipients;
|
||||
|
||||
db.users
|
||||
.collection('addresses')
|
||||
.find({ user: userData._id }, { address: true, addrview: true })
|
||||
.toArray((err, addresses) => {
|
||||
if (err) {
|
||||
err.code = 'ERRDB';
|
||||
return callback(err);
|
||||
}
|
||||
|
||||
let getReferencedMessage = done => {
|
||||
if (!options.reference) {
|
||||
return done(null, false);
|
||||
}
|
||||
let query = {};
|
||||
if (typeof options.reference === 'object') {
|
||||
query.mailbox = options.reference.mailbox;
|
||||
query.uid = options.reference.id;
|
||||
} else {
|
||||
return done(null, false);
|
||||
}
|
||||
query.user = user;
|
||||
db.users.collection('messages').findOne(
|
||||
query,
|
||||
{
|
||||
fields: {
|
||||
'mimeTree.parsedHeader': true,
|
||||
thread: true
|
||||
}
|
||||
},
|
||||
(err, messageData) => {
|
||||
if (err) {
|
||||
err.code = 'ERRDB';
|
||||
return callback(err);
|
||||
}
|
||||
|
||||
let headers = (messageData && messageData.mimeTree && messageData.mimeTree.parsedHeader) || {};
|
||||
let subject = headers.subject || '';
|
||||
try {
|
||||
subject = libmime.decodeWords(subject).trim();
|
||||
} catch (E) {
|
||||
// failed to parse value
|
||||
}
|
||||
|
||||
if (!/^\w+: /.test(subject)) {
|
||||
subject = ((options.reference.action === 'forward' ? 'Fwd' : 'Re') + ': ' + subject).trim();
|
||||
}
|
||||
|
||||
let sender = headers['reply-to'] || headers.from || headers.sender;
|
||||
let replyTo = [];
|
||||
let replyCc = [];
|
||||
let uniqueRecipients = new Set();
|
||||
|
||||
let checkAddress = (target, addr) => {
|
||||
let address = tools.normalizeAddress(addr.address);
|
||||
if (!inAddressList(addresses, address) && !uniqueRecipients.has(address)) {
|
||||
uniqueRecipients.add(address);
|
||||
if (addr.name) {
|
||||
try {
|
||||
addr.name = libmime.decodeWords(addr.name).trim();
|
||||
} catch (E) {
|
||||
// failed to parse value
|
||||
}
|
||||
}
|
||||
target.push(addr);
|
||||
}
|
||||
};
|
||||
|
||||
if (sender && sender.address) {
|
||||
checkAddress(replyTo, sender);
|
||||
}
|
||||
|
||||
if (options.reference.action === 'replyAll') {
|
||||
[].concat(headers.to || []).forEach(addr => {
|
||||
let walk = addr => {
|
||||
if (addr.address) {
|
||||
checkAddress(replyTo, addr);
|
||||
} else if (addr.group) {
|
||||
addr.group.forEach(walk);
|
||||
}
|
||||
};
|
||||
walk(addr);
|
||||
});
|
||||
[].concat(headers.cc || []).forEach(addr => {
|
||||
let walk = addr => {
|
||||
if (addr.address) {
|
||||
checkAddress(replyCc, addr);
|
||||
} else if (addr.group) {
|
||||
addr.group.forEach(walk);
|
||||
}
|
||||
};
|
||||
walk(addr);
|
||||
});
|
||||
}
|
||||
|
||||
let messageId = (headers['message-id'] || '').trim();
|
||||
let references = (headers.references || '')
|
||||
.trim()
|
||||
.replace(/\s+/g, ' ')
|
||||
.split(' ')
|
||||
.filter(mid => mid);
|
||||
|
||||
if (messageId && !references.includes(messageId)) {
|
||||
references.unshift(messageId);
|
||||
}
|
||||
if (references.length > 50) {
|
||||
references = references.slice(0, 50);
|
||||
}
|
||||
|
||||
return done(null, {
|
||||
replyTo,
|
||||
replyCc,
|
||||
inReplyTo: messageId,
|
||||
references: references.join(' '),
|
||||
subject,
|
||||
thread: messageData.thread
|
||||
});
|
||||
}
|
||||
);
|
||||
};
|
||||
|
||||
getReferencedMessage((err, referenceData) => {
|
||||
if (err) {
|
||||
return callback(err);
|
||||
}
|
||||
|
||||
let envelope = options.envelope;
|
||||
|
||||
if (!envelope) {
|
||||
envelope = {
|
||||
from: options.from,
|
||||
to: []
|
||||
};
|
||||
}
|
||||
|
||||
if (!envelope.from) {
|
||||
if (options.from) {
|
||||
envelope.from = options.from;
|
||||
} else {
|
||||
options.from = envelope.from = {
|
||||
name: userData.name || '',
|
||||
address: userData.address
|
||||
};
|
||||
}
|
||||
}
|
||||
|
||||
options.from = options.from || envelope.from;
|
||||
|
||||
if (!inAddressList(addresses, tools.normalizeAddress(options.from.address))) {
|
||||
options.from.address = userData.address;
|
||||
}
|
||||
|
||||
if (!inAddressList(addresses, tools.normalizeAddress(envelope.from.address))) {
|
||||
envelope.from.address = userData.address;
|
||||
}
|
||||
|
||||
if (!envelope.to.length) {
|
||||
envelope.to = envelope.to
|
||||
.concat(options.to || [])
|
||||
.concat(options.cc || [])
|
||||
.concat(options.bcc || []);
|
||||
if (!envelope.to.length && referenceData && ['reply', 'replyAll'].includes(options.reference.action)) {
|
||||
envelope.to = envelope.to.concat(referenceData.replyTo || []).concat(referenceData.replyCc || []);
|
||||
options.to = referenceData.replyTo;
|
||||
options.cc = referenceData.replyCc;
|
||||
}
|
||||
}
|
||||
|
||||
let extraHeaders = [];
|
||||
if (referenceData) {
|
||||
if (['reply', 'replyAll'].includes(options.reference.action)) {
|
||||
extraHeaders.push({ key: 'In-Reply-To', value: referenceData.inReplyTo });
|
||||
}
|
||||
extraHeaders.push({ key: 'References', value: referenceData.references });
|
||||
}
|
||||
|
||||
envelope.to = envelope.to.filter(addr => !inAddressList(addresses, tools.normalizeAddress(addr.address)));
|
||||
|
||||
let data = {
|
||||
envelope,
|
||||
from: options.from,
|
||||
to: options.to || [],
|
||||
cc: options.cc || [],
|
||||
bcc: options.bcc || [],
|
||||
subject: options.subject || (referenceData && referenceData.subject) || '',
|
||||
text: options.text || '',
|
||||
html: options.html || '',
|
||||
headers: extraHeaders.concat(options.headers || []),
|
||||
attachments: options.attachments || []
|
||||
};
|
||||
|
||||
let compiler = new MailComposer(data);
|
||||
let compiled = compiler.compile();
|
||||
let collector = new StreamCollect();
|
||||
let compiledEnvelope = compiled.getEnvelope();
|
||||
|
||||
messageHandler.counters.ttlcounter(
|
||||
'wdr:' + userData._id.toString(),
|
||||
compiledEnvelope.to.length,
|
||||
userData.recipients,
|
||||
false,
|
||||
(err, result) => {
|
||||
if (err) {
|
||||
err.code = 'ERRREDIS';
|
||||
return callback(err);
|
||||
}
|
||||
|
||||
let success = result.success;
|
||||
let sent = result.value;
|
||||
let ttl = result.ttl;
|
||||
|
||||
let ttlHuman = false;
|
||||
if (ttl) {
|
||||
if (ttl < 60) {
|
||||
ttlHuman = ttl + ' seconds';
|
||||
} else if (ttl < 3600) {
|
||||
ttlHuman = Math.round(ttl / 60) + ' minutes';
|
||||
} else {
|
||||
ttlHuman = Math.round(ttl / 3600) + ' hours';
|
||||
}
|
||||
}
|
||||
|
||||
if (!success) {
|
||||
log.info('API', 'RCPTDENY denied sent=%s allowed=%s expires=%ss.', sent, userData.recipients, ttl);
|
||||
let err = new Error(
|
||||
'You reached a daily sending limit for your account' + (ttl ? '. Limit expires in ' + ttlHuman : '')
|
||||
);
|
||||
err.code = 'ERRSENDINGLIMIT';
|
||||
return setImmediate(() => callback(err));
|
||||
}
|
||||
|
||||
let messageId = new ObjectID();
|
||||
let message = maildrop(
|
||||
{
|
||||
parentId: messageId,
|
||||
reason: 'submit',
|
||||
from: compiledEnvelope.from,
|
||||
to: compiledEnvelope.to,
|
||||
sendTime: options.sendTime
|
||||
},
|
||||
(err, ...args) => {
|
||||
if (err || !args[0]) {
|
||||
if (err) {
|
||||
err.code = 'ERRCOMPOSE';
|
||||
}
|
||||
return callback(err, ...args);
|
||||
}
|
||||
|
||||
let outbound = args[0].id;
|
||||
|
||||
// Checks if the message needs to be encrypted before storing it
|
||||
messageHandler.encryptMessage(
|
||||
userData.encryptMessages ? userData.pubKey : false,
|
||||
{ chunks: collector.chunks, chunklen: collector.chunklen },
|
||||
(err, encrypted) => {
|
||||
let raw = false;
|
||||
if (!err && encrypted) {
|
||||
// message was encrypted, so use the result instead of raw
|
||||
raw = encrypted;
|
||||
}
|
||||
|
||||
let messageOptions = {
|
||||
user: userData._id,
|
||||
specialUse: '\\Sent',
|
||||
|
||||
outbound,
|
||||
|
||||
meta: {
|
||||
source: 'API',
|
||||
from: compiledEnvelope.from,
|
||||
to: compiledEnvelope.to,
|
||||
origin: options.ip,
|
||||
sess: options.sess,
|
||||
time: new Date()
|
||||
},
|
||||
|
||||
date: false,
|
||||
flags: ['\\Seen'],
|
||||
|
||||
// if similar message exists, then skip
|
||||
skipExisting: true
|
||||
};
|
||||
|
||||
if (raw) {
|
||||
messageOptions.raw = raw;
|
||||
} else {
|
||||
messageOptions.raw = Buffer.concat(collector.chunks, collector.chunklen);
|
||||
}
|
||||
|
||||
messageHandler.add(messageOptions, (err, success, info) => {
|
||||
if (err) {
|
||||
log.error('API', 'SUBMITFAIL user=%s error=%s', user, err.message);
|
||||
err.code = 'SUBMITFAIL';
|
||||
return callback(err);
|
||||
} else if (!info) {
|
||||
log.info('API', 'SUBMITSKIP user=%s message=already exists', user);
|
||||
return callback(null, false);
|
||||
}
|
||||
|
||||
return callback(null, {
|
||||
id: info.uid,
|
||||
mailbox: info.mailbox,
|
||||
queueId: outbound
|
||||
});
|
||||
});
|
||||
}
|
||||
);
|
||||
}
|
||||
);
|
||||
|
||||
let stream = compiled.createReadStream();
|
||||
stream.once('error', err => message.emit('error', err));
|
||||
stream.pipe(collector).pipe(message);
|
||||
}
|
||||
);
|
||||
});
|
||||
});
|
||||
}
|
||||
);
|
||||
}
|
||||
|
||||
/**
|
||||
* @api {post} /users/:user/submit Submit a Message for Delivery
|
||||
* @apiName PostSubmit
|
||||
* @apiGroup Submission
|
||||
* @apiDescription Use this method to send emails from an user account
|
||||
* @apiHeader {String} X-Access-Token Optional access token if authentication is enabled
|
||||
* @apiHeaderExample {json} Header-Example:
|
||||
* {
|
||||
* "X-Access-Token": "59fc66a03e54454869460e45"
|
||||
* }
|
||||
*
|
||||
* @apiParam {String} user Users unique ID
|
||||
* @apiParam {Object} [reference] Optional referenced email. If submitted message is a reply and relevant fields are not provided then these are resolved from the message to be replied to
|
||||
* @apiParam {String} reference.mailbox Mailbox ID
|
||||
* @apiParam {Number} reference.id Message ID in Mailbox
|
||||
* @apiParam {String} reference.action Either <code>reply</code>, <code>replyAll</code> or <code>forward</code>
|
||||
* @apiParam {String} [sendTime] Datestring for delivery if message should be sent some later time
|
||||
* @apiParam {Object} [envelope] SMTP envelope. If not provided then resolved either from message headers or from referenced message
|
||||
* @apiParam {Object} [envelope.from] Sender information. If not set then it is resolved to User's default address
|
||||
* @apiParam {String} envelope.from.address Sender address. If this is not listed as allowed address for the sending User then it is replaced with the User's default address
|
||||
* @apiParam {Object[]} [envelope.to] Recipients information
|
||||
* @apiParam {String} envelope.to.address Recipient address
|
||||
* @apiParam {Object} [from] Address for the From: header
|
||||
* @apiParam {String} from.name Name of the sender
|
||||
* @apiParam {String} from.address Address of the sender
|
||||
* @apiParam {Object[]} [to] Addresses for the To: header
|
||||
* @apiParam {String} [to.name] Name of the recipient
|
||||
* @apiParam {String} to.address Address of the recipient
|
||||
* @apiParam {Object[]} [cc] Addresses for the Cc: header
|
||||
* @apiParam {String} [cc.name] Name of the recipient
|
||||
* @apiParam {String} cc.address Address of the recipient
|
||||
* @apiParam {Object[]} [bcc] Addresses for the Bcc: header
|
||||
* @apiParam {String} [bcc.name] Name of the recipient
|
||||
* @apiParam {String} bcc.address Address of the recipient
|
||||
* @apiParam {String} subject Message subject. If not then resolved from Reference message
|
||||
* @apiParam {String} text Plaintext message
|
||||
* @apiParam {String} html HTML formatted message
|
||||
* @apiParam {Object[]} [headers] Custom headers for the message. If reference message is set then In-Reply-To and References headers are set automatically
|
||||
* @apiParam {String} headers.key Header key ('X-Mailer')
|
||||
* @apiParam {String} headers.value Header value ('My Awesome Mailing Service')
|
||||
* @apiParam {Object[]} [attachments] Attachments for the message
|
||||
* @apiParam {String} attachments.content Base64 encoded attachment content
|
||||
* @apiParam {String} [attachments.filename] Attachment filename
|
||||
* @apiParam {String} [attachments.contentType] MIME type for the attachment file
|
||||
* @apiParam {String} [attachments.cid] Content-ID value if you want to reference to this attachment from HTML formatted message
|
||||
* @apiParam {String} [sess] Session identifier for the logs
|
||||
* @apiParam {String} [ip] IP address for the logs
|
||||
*
|
||||
* @apiSuccess {Boolean} success Indicates successful response
|
||||
* @apiSuccess {Object} message Information about submitted Message
|
||||
* @apiSuccess {String} message.mailbox Mailbox ID the message was stored to
|
||||
* @apiSuccess {Number} message.id Message ID in Mailbox
|
||||
* @apiSuccess {String} message.queueId Queue ID in MTA
|
||||
*
|
||||
* @apiError {String} error Description of the error
|
||||
* @apiError {String} code Reason for the error
|
||||
*
|
||||
* @apiExample {curl} Example usage:
|
||||
* curl -i -XPOST http://localhost:8080/users/59fc66a03e54454869460e45/submit \
|
||||
* -H 'Content-type: application/json' \
|
||||
* -d '{
|
||||
* "to": [{
|
||||
* "address": "andris@ethereal.email"
|
||||
* }],
|
||||
* "subject": "Hello world!",
|
||||
* "text": "Test message"
|
||||
* }'
|
||||
*
|
||||
* @apiSuccessExample {json} Success-Response:
|
||||
* HTTP/1.1 200 OK
|
||||
* {
|
||||
* "success": true,
|
||||
* "message": {
|
||||
* "id": 16,
|
||||
* "mailbox": "59fc66a03e54454869460e47",
|
||||
* "queueId": "1600798505b000a25f"
|
||||
* }
|
||||
* }
|
||||
*
|
||||
* @apiErrorExample {json} Error-Response:
|
||||
* HTTP/1.1 200 OK
|
||||
* {
|
||||
* "error": "Mailbox update failed with code ALREADYEXISTS"
|
||||
* }
|
||||
*/
|
||||
server.post({ name: 'send', path: '/users/:user/submit' }, (req, res, next) => {
|
||||
res.charSet('utf-8');
|
||||
|
||||
const schema = Joi.object().keys({
|
||||
user: Joi.string()
|
||||
.hex()
|
||||
.lowercase()
|
||||
.length(24)
|
||||
.required(),
|
||||
|
||||
reference: Joi.object().keys({
|
||||
mailbox: Joi.string()
|
||||
.hex()
|
||||
.lowercase()
|
||||
.length(24)
|
||||
.required(),
|
||||
id: Joi.number().required(),
|
||||
action: Joi.string()
|
||||
.valid('reply', 'replyAll', 'forward')
|
||||
.required()
|
||||
}),
|
||||
|
||||
sendTime: Joi.date(),
|
||||
|
||||
envelope: Joi.object().keys({
|
||||
from: Joi.object().keys({
|
||||
name: Joi.string()
|
||||
.empty('')
|
||||
.max(255),
|
||||
address: Joi.string()
|
||||
.email()
|
||||
.required()
|
||||
}),
|
||||
to: Joi.array().items(
|
||||
Joi.object().keys({
|
||||
name: Joi.string()
|
||||
.empty('')
|
||||
.max(255),
|
||||
address: Joi.string()
|
||||
.email()
|
||||
.required()
|
||||
})
|
||||
)
|
||||
}),
|
||||
|
||||
from: Joi.object().keys({
|
||||
name: Joi.string()
|
||||
.empty('')
|
||||
.max(255),
|
||||
address: Joi.string()
|
||||
.email()
|
||||
.required()
|
||||
}),
|
||||
|
||||
replyTo: Joi.object().keys({
|
||||
name: Joi.string()
|
||||
.empty('')
|
||||
.max(255),
|
||||
address: Joi.string()
|
||||
.email()
|
||||
.required()
|
||||
}),
|
||||
|
||||
to: Joi.array().items(
|
||||
Joi.object().keys({
|
||||
name: Joi.string()
|
||||
.empty('')
|
||||
.max(255),
|
||||
address: Joi.string()
|
||||
.email()
|
||||
.required()
|
||||
})
|
||||
),
|
||||
|
||||
cc: Joi.array().items(
|
||||
Joi.object().keys({
|
||||
name: Joi.string()
|
||||
.empty('')
|
||||
.max(255),
|
||||
address: Joi.string()
|
||||
.email()
|
||||
.required()
|
||||
})
|
||||
),
|
||||
|
||||
bcc: Joi.array().items(
|
||||
Joi.object().keys({
|
||||
name: Joi.string()
|
||||
.empty('')
|
||||
.max(255),
|
||||
address: Joi.string()
|
||||
.email()
|
||||
.required()
|
||||
})
|
||||
),
|
||||
|
||||
headers: Joi.array().items(
|
||||
Joi.object().keys({
|
||||
key: Joi.string()
|
||||
.empty('')
|
||||
.max(255),
|
||||
value: Joi.string()
|
||||
.empty('')
|
||||
.max(100 * 1024)
|
||||
})
|
||||
),
|
||||
|
||||
subject: Joi.string()
|
||||
.empty('')
|
||||
.max(255),
|
||||
text: Joi.string()
|
||||
.empty('')
|
||||
.max(1024 * 1024),
|
||||
html: Joi.string()
|
||||
.empty('')
|
||||
.max(1024 * 1024),
|
||||
|
||||
attachments: Joi.array().items(
|
||||
Joi.object().keys({
|
||||
filename: Joi.string()
|
||||
.empty('')
|
||||
.max(255),
|
||||
contentType: Joi.string()
|
||||
.empty('')
|
||||
.max(255),
|
||||
encoding: Joi.string()
|
||||
.empty('')
|
||||
.default('base64'),
|
||||
content: Joi.string().required(),
|
||||
cid: Joi.string()
|
||||
.empty('')
|
||||
.max(255)
|
||||
})
|
||||
),
|
||||
sess: Joi.string().max(255),
|
||||
ip: Joi.string().ip({
|
||||
version: ['ipv4', 'ipv6'],
|
||||
cidr: 'forbidden'
|
||||
})
|
||||
});
|
||||
|
||||
const result = Joi.validate(req.params, schema, {
|
||||
abortEarly: false,
|
||||
convert: true,
|
||||
allowUnknown: true
|
||||
});
|
||||
|
||||
if (result.error) {
|
||||
res.json({
|
||||
error: result.error.message
|
||||
});
|
||||
return next();
|
||||
}
|
||||
|
||||
result.value.user = new ObjectID(result.value.user);
|
||||
if (result.value.reference && result.value.reference.mailbox) {
|
||||
result.value.reference.mailbox = new ObjectID(result.value.reference.mailbox);
|
||||
}
|
||||
|
||||
sendMessage(result.value, (err, info) => {
|
||||
if (err) {
|
||||
log.error('API', 'SUBMIT error=%s', err.message);
|
||||
res.json({
|
||||
error: err.message,
|
||||
code: err.code
|
||||
});
|
||||
} else {
|
||||
res.json({
|
||||
success: true,
|
||||
message: info
|
||||
});
|
||||
}
|
||||
next();
|
||||
});
|
||||
});
|
||||
};
|
||||
|
||||
function inAddressList(addresses, address) {
|
||||
let addrview = address.substr(0, address.indexOf('@')).replace(/\./g, '') + address.substr(address.indexOf('@'));
|
||||
|
||||
return !!addresses.find(addr => addr.addrview === addrview);
|
||||
}
|
||||
268
lib/autoreply.js
268
lib/autoreply.js
|
|
@ -13,154 +13,160 @@ module.exports = (options, callback) => {
|
|||
}
|
||||
|
||||
let curtime = new Date();
|
||||
db.database.collection('autoreplies').findOne({
|
||||
user: options.userData._id,
|
||||
start: {
|
||||
$lte: curtime
|
||||
db.database.collection('autoreplies').findOne(
|
||||
{
|
||||
user: options.userData._id,
|
||||
start: {
|
||||
$lte: curtime
|
||||
},
|
||||
end: {
|
||||
$gte: curtime
|
||||
}
|
||||
},
|
||||
end: {
|
||||
$gte: curtime
|
||||
}
|
||||
}, (err, autoreply) => {
|
||||
if (err) {
|
||||
return callback(err);
|
||||
}
|
||||
|
||||
if (!autoreply || !autoreply.status) {
|
||||
return callback(null, false);
|
||||
}
|
||||
|
||||
// step 1. check if recipient is valid (non special address)
|
||||
// step 2. check if recipient not in cache list
|
||||
// step 3. parse headers, check if not automatic message
|
||||
// step 4. prepare message with special headers (in-reply-to, references, Auto-Submitted)
|
||||
|
||||
let messageHeaders = false;
|
||||
let messageSplitter = new MessageSplitter();
|
||||
|
||||
messageSplitter.once('headers', headers => {
|
||||
messageHeaders = headers;
|
||||
|
||||
let autoSubmitted = headers.getFirst('Auto-Submitted');
|
||||
if (autoSubmitted && autoSubmitted.toLowerCase() !== 'no') {
|
||||
// skip automatic messages
|
||||
return callback(null, false);
|
||||
(err, autoreply) => {
|
||||
if (err) {
|
||||
return callback(err);
|
||||
}
|
||||
let precedence = headers.getFirst('Precedence');
|
||||
if (precedence && ['list', 'junk', 'bulk'].includes(precedence.toLowerCase())) {
|
||||
return callback(null, false);
|
||||
}
|
||||
let listUnsubscribe = headers.getFirst('List-Unsubscribe');
|
||||
if (listUnsubscribe) {
|
||||
return callback(null, false);
|
||||
}
|
||||
let suppressAutoresponse = headers.getFirst('X-Auto-Response-Suppress');
|
||||
if (suppressAutoresponse && /OOF|AutoReply/i.test(suppressAutoresponse)) {
|
||||
|
||||
if (!autoreply || !autoreply.status) {
|
||||
return callback(null, false);
|
||||
}
|
||||
|
||||
db.redis
|
||||
.multi()
|
||||
// delete all old entries
|
||||
.zremrangebyscore('war:' + autoreply._id, '-inf', Date.now() - consts.MAX_AUTOREPLY_INTERVAL)
|
||||
// add new entry if not present
|
||||
.zadd('war:' + autoreply._id, 'NX', Date.now(), options.sender)
|
||||
// if no-one touches this key from now, then delete after max interval has passed
|
||||
.expire('war:' + autoreply._id, consts.MAX_AUTOREPLY_INTERVAL)
|
||||
.exec((err, result) => {
|
||||
if (err) {
|
||||
errors.notify(err, { userId: options.userData._id });
|
||||
return callback(null, false);
|
||||
}
|
||||
// step 1. check if recipient is valid (non special address)
|
||||
// step 2. check if recipient not in cache list
|
||||
// step 3. parse headers, check if not automatic message
|
||||
// step 4. prepare message with special headers (in-reply-to, references, Auto-Submitted)
|
||||
|
||||
if (!result || !result[1] || !result[1][1]) {
|
||||
// already responded
|
||||
return callback(null, false);
|
||||
}
|
||||
let messageHeaders = false;
|
||||
let messageSplitter = new MessageSplitter();
|
||||
|
||||
// check limiting counters
|
||||
options.messageHandler.counters.ttlcounter('wda:' + options.userData._id, 1, consts.MAX_AUTOREPLIES, false, (err, result) => {
|
||||
if (err || !result.success) {
|
||||
messageSplitter.once('headers', headers => {
|
||||
messageHeaders = headers;
|
||||
|
||||
let autoSubmitted = headers.getFirst('Auto-Submitted');
|
||||
if (autoSubmitted && autoSubmitted.toLowerCase() !== 'no') {
|
||||
// skip automatic messages
|
||||
return callback(null, false);
|
||||
}
|
||||
let precedence = headers.getFirst('Precedence');
|
||||
if (precedence && ['list', 'junk', 'bulk'].includes(precedence.toLowerCase())) {
|
||||
return callback(null, false);
|
||||
}
|
||||
let listUnsubscribe = headers.getFirst('List-Unsubscribe');
|
||||
if (listUnsubscribe) {
|
||||
return callback(null, false);
|
||||
}
|
||||
let suppressAutoresponse = headers.getFirst('X-Auto-Response-Suppress');
|
||||
if (suppressAutoresponse && /OOF|AutoReply/i.test(suppressAutoresponse)) {
|
||||
return callback(null, false);
|
||||
}
|
||||
|
||||
db.redis
|
||||
.multi()
|
||||
// delete all old entries
|
||||
.zremrangebyscore('war:' + autoreply._id, '-inf', Date.now() - consts.MAX_AUTOREPLY_INTERVAL)
|
||||
// add new entry if not present
|
||||
.zadd('war:' + autoreply._id, 'NX', Date.now(), options.sender)
|
||||
// if no-one touches this key from now, then delete after max interval has passed
|
||||
.expire('war:' + autoreply._id, consts.MAX_AUTOREPLY_INTERVAL)
|
||||
.exec((err, result) => {
|
||||
if (err) {
|
||||
errors.notify(err, { userId: options.userData._id });
|
||||
return callback(null, false);
|
||||
}
|
||||
|
||||
let data = {
|
||||
envelope: {
|
||||
from: '',
|
||||
to: options.sender
|
||||
},
|
||||
from: {
|
||||
name: options.userData.name,
|
||||
address: options.recipient
|
||||
},
|
||||
to: options.sender,
|
||||
subject: autoreply.subject
|
||||
? 'Auto: ' + autoreply.subject
|
||||
: {
|
||||
prepared: true,
|
||||
value: 'Auto: Re: ' + headers.getFirst('Subject')
|
||||
},
|
||||
headers: {
|
||||
'Auto-Submitted': 'auto-replied',
|
||||
'X-WD-Autoreply-For': (options.parentId || '').toString()
|
||||
},
|
||||
inReplyTo: headers.getFirst('Message-ID'),
|
||||
references: (headers.getFirst('Message-ID') + ' ' + headers.getFirst('References')).trim(),
|
||||
text: autoreply.text,
|
||||
html: autoreply.html
|
||||
};
|
||||
if (!result || !result[1] || !result[1][1]) {
|
||||
// already responded
|
||||
return callback(null, false);
|
||||
}
|
||||
|
||||
let compiler = new MailComposer(data);
|
||||
let message = maildrop(
|
||||
{
|
||||
parentId: options.parentId,
|
||||
reason: 'autoreply',
|
||||
from: '',
|
||||
// check limiting counters
|
||||
options.messageHandler.counters.ttlcounter('wda:' + options.userData._id, 1, consts.MAX_AUTOREPLIES, false, (err, result) => {
|
||||
if (err || !result.success) {
|
||||
return callback(null, false);
|
||||
}
|
||||
|
||||
let data = {
|
||||
envelope: {
|
||||
from: '',
|
||||
to: options.sender
|
||||
},
|
||||
from: {
|
||||
name: options.userData.name,
|
||||
address: options.recipient
|
||||
},
|
||||
to: options.sender,
|
||||
interface: 'autoreplies'
|
||||
},
|
||||
(err, ...args) => {
|
||||
if (err || !args[0]) {
|
||||
return callback(err, ...args);
|
||||
}
|
||||
db.database.collection('messagelog').insertOne({
|
||||
id: args[0].id,
|
||||
messageId: args[0].messageId,
|
||||
subject: autoreply.subject
|
||||
? 'Auto: ' + autoreply.subject
|
||||
: {
|
||||
prepared: true,
|
||||
value: 'Auto: Re: ' + headers.getFirst('Subject')
|
||||
},
|
||||
headers: {
|
||||
'Auto-Submitted': 'auto-replied',
|
||||
'X-WD-Autoreply-For': (options.parentId || '').toString()
|
||||
},
|
||||
inReplyTo: headers.getFirst('Message-ID'),
|
||||
references: (headers.getFirst('Message-ID') + ' ' + headers.getFirst('References')).trim(),
|
||||
text: autoreply.text,
|
||||
html: autoreply.html
|
||||
};
|
||||
|
||||
let compiler = new MailComposer(data);
|
||||
let message = maildrop(
|
||||
{
|
||||
parentId: options.parentId,
|
||||
action: 'AUTOREPLY',
|
||||
reason: 'autoreply',
|
||||
from: '',
|
||||
to: options.sender,
|
||||
created: new Date()
|
||||
}, () => callback(err, args && args[0] && args[0].id));
|
||||
}
|
||||
);
|
||||
interface: 'autoreplies'
|
||||
},
|
||||
(err, ...args) => {
|
||||
if (err || !args[0]) {
|
||||
return callback(err, ...args);
|
||||
}
|
||||
db.database.collection('messagelog').insertOne(
|
||||
{
|
||||
id: args[0].id,
|
||||
messageId: args[0].messageId,
|
||||
parentId: options.parentId,
|
||||
action: 'AUTOREPLY',
|
||||
from: '',
|
||||
to: options.sender,
|
||||
created: new Date()
|
||||
},
|
||||
() => callback(err, args && args[0].id)
|
||||
);
|
||||
}
|
||||
);
|
||||
|
||||
compiler
|
||||
.compile()
|
||||
.createReadStream()
|
||||
.pipe(message);
|
||||
compiler
|
||||
.compile()
|
||||
.createReadStream()
|
||||
.pipe(message);
|
||||
});
|
||||
});
|
||||
});
|
||||
});
|
||||
});
|
||||
|
||||
messageSplitter.on('error', () => false);
|
||||
messageSplitter.on('data', () => false);
|
||||
messageSplitter.on('end', () => false);
|
||||
messageSplitter.on('error', () => false);
|
||||
messageSplitter.on('data', () => false);
|
||||
messageSplitter.on('end', () => false);
|
||||
|
||||
setImmediate(() => {
|
||||
let pos = 0;
|
||||
let writeNextChunk = () => {
|
||||
if (messageHeaders || pos >= options.chunks.length) {
|
||||
return messageSplitter.end();
|
||||
}
|
||||
let chunk = options.chunks[pos++];
|
||||
if (!messageSplitter.write(chunk)) {
|
||||
return messageSplitter.once('drain', writeNextChunk);
|
||||
} else {
|
||||
setImmediate(writeNextChunk);
|
||||
}
|
||||
};
|
||||
setImmediate(writeNextChunk);
|
||||
});
|
||||
});
|
||||
setImmediate(() => {
|
||||
let pos = 0;
|
||||
let writeNextChunk = () => {
|
||||
if (messageHeaders || pos >= options.chunks.length) {
|
||||
return messageSplitter.end();
|
||||
}
|
||||
let chunk = options.chunks[pos++];
|
||||
if (!messageSplitter.write(chunk)) {
|
||||
return messageSplitter.once('drain', writeNextChunk);
|
||||
} else {
|
||||
setImmediate(writeNextChunk);
|
||||
}
|
||||
};
|
||||
setImmediate(writeNextChunk);
|
||||
});
|
||||
}
|
||||
);
|
||||
};
|
||||
|
|
|
|||
|
|
@ -255,7 +255,7 @@ module.exports = (options, callback) => {
|
|||
lockTime: 0,
|
||||
|
||||
// earliest time to attempt delivery, defaults to now
|
||||
queued: date,
|
||||
queued: options.sendTime || date,
|
||||
|
||||
// queued date might change but created should not
|
||||
created: date
|
||||
|
|
@ -275,16 +275,20 @@ module.exports = (options, callback) => {
|
|||
documents.push(delivery);
|
||||
}
|
||||
|
||||
db.senderDb.collection(config.sender.collection).insertMany(documents, {
|
||||
w: 1,
|
||||
ordered: false
|
||||
}, err => {
|
||||
if (err) {
|
||||
return callback(err);
|
||||
}
|
||||
db.senderDb.collection(config.sender.collection).insertMany(
|
||||
documents,
|
||||
{
|
||||
w: 1,
|
||||
ordered: false
|
||||
},
|
||||
err => {
|
||||
if (err) {
|
||||
return callback(err);
|
||||
}
|
||||
|
||||
callback(null, envelope);
|
||||
});
|
||||
callback(null, envelope);
|
||||
}
|
||||
);
|
||||
});
|
||||
});
|
||||
});
|
||||
|
|
@ -346,16 +350,21 @@ function removeMessage(id, callback) {
|
|||
}
|
||||
|
||||
function setMeta(id, data, callback) {
|
||||
db.senderDb.collection(config.sender.gfs + '.files').findOneAndUpdate({
|
||||
filename: 'message ' + id
|
||||
}, {
|
||||
$set: {
|
||||
'metadata.data': data
|
||||
db.senderDb.collection(config.sender.gfs + '.files').findOneAndUpdate(
|
||||
{
|
||||
filename: 'message ' + id
|
||||
},
|
||||
{
|
||||
$set: {
|
||||
'metadata.data': data
|
||||
}
|
||||
},
|
||||
{},
|
||||
err => {
|
||||
if (err) {
|
||||
return callback(err);
|
||||
}
|
||||
return callback();
|
||||
}
|
||||
}, {}, err => {
|
||||
if (err) {
|
||||
return callback(err);
|
||||
}
|
||||
return callback();
|
||||
});
|
||||
);
|
||||
}
|
||||
|
|
|
|||
Loading…
Add table
Reference in a new issue