mailer.js

/**
 * Created by championswimmer on 1/8/16.
 * Modified by uttpal.
 */
"use strict";

const Promise = require('bluebird');
const helper = require('sendgrid').mail;
const config = require('../../config.json');
const sg = require('sendgrid').SendGrid(process.env.SENDGRID_API_KEY || config.SENDGRID_API_KEY);
const distHelper = require('./dist.js');
const logger = require('./buildlogger.js');
const aws = require('aws-sdk');
const fs = require('fs');
const uuid = require('node-uuid');
const appUrl = process.env.HEROKU_URL;
const nodemailer = require('nodemailer');
const smtpTransport = require('nodemailer-smtp-transport');

aws.config.setPromisesDependency(Promise);
const s3 = new aws.S3();

process.env.AWS_ACCESS_KEY_ID = process.env.AWS_ACCESS_KEY_ID || config.AWS_ACCESS_KEY_ID;
process.env.AWS_SECRET_ACCESS_KEY = process.env.AWS_SECRET_ACCESS_KEY || config.AWS_SECRET_ACCESS_KEY;
process.env.DEFAULT_MAIL_STRATEGY = process.env.DEFAULT_MAIL_STRATEGY || config.DEFAULT_MAIL_STRATEGY;
process.env.DEFAULT_FROM_EMAIL = process.env.DEFAULT_FROM_EMAIL || config.DEFAULT_FROM_EMAIL;

function uploadToS3(file, fileName, socket) {
  const uploadParams = {Bucket: 'FOSSASIA',  Key: fileName};
  const fileStream = fs.createReadStream(file);

  fileStream.on('error', function(err) {
    console.log('File Error');
    logger.addLog('Error', 'Error during upload to S3', socket, err);
  });
  uploadParams.Body = fileStream;
  return s3.upload(uploadParams).promise();
}

function emailSend(toEmail, url, appName) {
  const subject = 'Your webapp ' + appName + ' is Ready';
  let downloadUrl = url;

  if(!url) {
    downloadUrl = appUrl + 'download/' + toEmail + '/' + appName;
  }
  const emailContent = 'Hi ! <br>' +
  ' Your webapp has been generated <br>' +
  'You can preview it live on ' + appUrl + 'live/preview/' + toEmail + '/' + encodeURIComponent(appName) + '<br>' +
  'You can download a zip of your website from  ' + downloadUrl +
  '<br><br><br>' +
  'Thank you for using Open Event Webapp Generator :) ';

  if(process.env.DEFAULT_MAIL_STRATEGY === 'SMTP') {
    const smtpConfig = {
      host: process.env.SMTP_HOST || config.SMTP_HOST,
      port: process.env.SMTP_PORT || config.SMTP_PORT,
      auth: {
        user: process.env.SMTP_USERNAME || config.SMTP_USERNAME,
        pass: process.env.SMTP_PASSWORD || config.SMTP_PASSWORD
      }
    };
    const transporter = nodemailer.createTransport(smtpTransport(smtpConfig));

    return transporter.sendMail({
      from: process.env.DEFAULT_FROM_EMAIL,
      to: toEmail,
      subject: subject,
      html: emailContent
    }).then((response) => {
      console.log('Successfully sent Email');
      console.log(response);
      return url;
    })
    .catch((err) => {
      console.log('Error sending Email', err);
      return url;
    });
  }
  const fromEmail = new helper.Email(process.env.DEFAULT_FROM_EMAIL);
  const recipientEmail = new helper.Email(toEmail);
  const content = new helper.Content('text/html', emailContent);
  const mail = new helper.Mail(fromEmail, subject, recipientEmail, content);
  const requestBody = mail.toJSON();
  const request = sg.emptyRequest();

  request.host = 'api.sendgrid.com';
  request.method = 'POST';
  request.path = '/v3/mail/send';
  request.body = requestBody;
  console.log(request);
  return sg.API(request)
    .then((response) => {
      console.log(response.statusCode);
      console.log(response.body);
      console.log(response.headers);
      return url;
    })
    .catch((err) => {
      console.log('Error sending Email', err);
      return url;
    });
}

function uploadAndsendMail(toEmail, appName, socket, done) {
  const file = distHelper.distPath + '/' + toEmail + '/event.zip';
  const fileName = uuid.v4() + appName + '.zip';

  uploadToS3(file, fileName, socket)
    .then((data) => {
      logger.addLog('Success', 'Upload successful to s3', socket);
      console.log('Upload Success', data.Location);
      return emailSend(toEmail, data.Location, appName);
    })
    .catch((err) => {
      console.log('Error', err);
      logger.addLog('Info', 'Failed while uploading the zip. No Amazon S3 keys found', socket);
      return emailSend(toEmail, null, appName);
    })
    .then((url) => {
      return done(url);
    });
}

module.exports = {
  uploadAndsendMail
};