change emailer

server/api/emailer.js

@@ -8,24 +8,27 @@ const templateDir = path.join(__dirname, '../../', 'templates')
 let templateCache = {}
 let transporter
 
-function sendMail (email, headers) {
-  if (!transporter) return
-  transporter.sendMail({
+// Send an email to `email` with `headers`
+async function sendMail (email, headers) {
+  return new Promise(function (resolve, reject) {
+    if (!transporter) return reject(new Error('No transporter present!'))
+
+    transporter.sendMail(Object.assign({
       from: config.email.admin,
-    to: email,
-    subject: headers.subject,
-    html: headers.html,
-    text: headers.text
-  }, (error, info) => {
+      to: email
+    }, headers), (error, info) => {
       if (error) {
-      return console.error(error)
+        return reject(error)
       }
-    console.debug(info)
+
+      resolve(info)
+    })
   })
 }
 
+// Send an email to `email` using `template` rendered with variables from `context`
 async function pushMail (template, email, context) {
-  if (!transporter) return
+  if (!transporter) return null
   let templ = null
 
   if (!templateCache[template]) {
@@ -38,9 +41,10 @@ async function pushMail (template, email, context) {
 
   console.debug('Mail being sent: %s to %s', template, email)
 
-  sendMail(email, result)
+  return sendMail(email, result)
 }
 
+// Transporter initialization
 async function init () {
   if (!config.email || config.email.enabled === false) return
   transporter = nodemailer.createTransport(config.email.transport)
@@ -58,6 +62,7 @@ async function init () {
 }
 
 module.exports = {
+  sendMail: sendMail,
   pushMail: pushMail,
   init: init
 }

server/api/index.js

@@ -380,11 +380,19 @@ const API = {
         // Send Activation Email
         console.debug('Activation token:', activationToken)
         if (email) {
-          await emailer.pushMail('activate', user.email, {
+          try {
+            let em = await emailer.pushMail('activate', user.email, {
               domain: config.server.domain,
               display_name: user.display_name,
               activation_token: activationToken
             })
+
+            console.debug(em)
+          } catch (e) {
+            console.error(e)
+            await models.User.query().delete().where('id', user.id)
+            return {error: 'Invalid email address!'}
+          }
         }
 
         return {error: null, user: user}