mirror of
https://github.com/overleaf/overleaf.git
synced 2024-10-31 21:21:03 -04:00
1112a1f085
This allows end-users to use AWS features such as instance roles, avoiding the use of explicit crendentials
78 lines
2.8 KiB
CoffeeScript
78 lines
2.8 KiB
CoffeeScript
logger = require('logger-sharelatex')
|
|
metrics = require('metrics-sharelatex')
|
|
Settings = require('settings-sharelatex')
|
|
nodemailer = require("nodemailer")
|
|
sesTransport = require('nodemailer-ses-transport')
|
|
sgTransport = require('nodemailer-sendgrid-transport')
|
|
rateLimiter = require('../../infrastructure/RateLimiter')
|
|
_ = require("underscore")
|
|
|
|
if Settings.email? and Settings.email.fromAddress?
|
|
defaultFromAddress = Settings.email.fromAddress
|
|
else
|
|
defaultFromAddress = ""
|
|
|
|
# provide dummy mailer unless we have a better one configured.
|
|
client =
|
|
sendMail: (options, callback = (err,status) ->) ->
|
|
logger.log options:options, "Would send email if enabled."
|
|
callback()
|
|
|
|
if Settings?.email?.parameters?.AWSAccessKeyID? or Settings?.email?.driver == 'ses'
|
|
logger.log "using aws ses for email"
|
|
nm_client = nodemailer.createTransport(sesTransport(Settings.email.parameters))
|
|
else if Settings?.email?.parameters?.sendgridApiKey?
|
|
logger.log "using sendgrid for email"
|
|
nm_client = nodemailer.createTransport(sgTransport({auth:{api_key:Settings?.email?.parameters?.sendgridApiKey}}))
|
|
else if Settings?.email?.parameters?
|
|
smtp = _.pick(Settings?.email?.parameters, "host", "port", "secure", "auth", "ignoreTLS")
|
|
|
|
|
|
logger.log "using smtp for email"
|
|
nm_client = nodemailer.createTransport(smtp)
|
|
else
|
|
nm_client = client
|
|
logger.warn "Email transport and/or parameters not defined. No emails will be sent."
|
|
|
|
if nm_client?
|
|
client = nm_client
|
|
else
|
|
logger.warn "Failed to create email transport. Please check your settings. No email will be sent."
|
|
|
|
checkCanSendEmail = (options, callback)->
|
|
if !options.sendingUser_id? #email not sent from user, not rate limited
|
|
return callback(null, true)
|
|
opts =
|
|
endpointName: "send_email"
|
|
timeInterval: 60 * 60 * 3
|
|
subjectName: options.sendingUser_id
|
|
throttle: 100
|
|
rateLimiter.addCount opts, callback
|
|
|
|
module.exports =
|
|
sendEmail : (options, callback = (error) ->)->
|
|
logger.log receiver:options.to, subject:options.subject, "sending email"
|
|
checkCanSendEmail options, (err, canContinue)->
|
|
if err?
|
|
return callback(err)
|
|
if !canContinue
|
|
logger.log sendingUser_id:options.sendingUser_id, to:options.to, subject:options.subject, canContinue:canContinue, "rate limit hit for sending email, not sending"
|
|
return callback("rate limit hit sending email")
|
|
metrics.inc "email"
|
|
options =
|
|
to: options.to
|
|
from: defaultFromAddress
|
|
subject: options.subject
|
|
html: options.html
|
|
text: options.text
|
|
replyTo: options.replyTo || Settings.email.replyToAddress
|
|
socketTimeout: 30 * 1000
|
|
if Settings.email.textEncoding?
|
|
opts.textEncoding = textEncoding
|
|
client.sendMail options, (err, res)->
|
|
if err?
|
|
logger.err err:err, "error sending message"
|
|
err = new Error('Cannot send email')
|
|
else
|
|
logger.log "Message sent to #{options.to}"
|
|
callback(err)
|