gistfile1.js

function processInviteEmails(email_list, user_id, emailCallBack, completionCallback){
  function checkEmail(email){
    try {
      check(email).isEmail();
      //is valid email
      checkConnected(email, user_id, function(connect_status, user_row, user_meta_row, connect_row){
        var e_data;
        //insert to connect and send msg to queue
        if(connect_status === 'not connected'){
          var cur_date = moment().format('YYYY-MM-DD');
          var dbData = {
            "first_name": '',
            "last_name": '',
            "email": email,
            "user_id": user_id,
            "status": "invited",
            "unsubscribe_token": crypto.randomBytes(6).toString('base64'),
            "created": cur_date,
            "modified": cur_date
          };
          ConnectModel.insert(dbData, function(result){
            if (result.insertId > 0) {
              //send to email queue
              //Queue Email
              MailTemplateModel.getTemplateData('invitation', function(res_data){
                if(res_data.status === 'success'){
                  var unsubscribe_hash = crypto.createHash("md5")
                    .update(dbData.unsubscribe_token + email)
                    .digest('hex');
                  var unsubscribe_link = app.locals.SITE_URL+'/unsubscribe/' + result.insertId + '/' + unsubscribe_hash;
                  var template_row = res_data.template_row;
                  var user_full_name = user_row.user_firstname+' '+ user_row.user_lastname;
                  var invitation_link = 'http://'+user_row.url_alias+'.'+ app.locals.SITE_DOMAIN;
                  var mailOptions = {
                    "type": 'invitation',
                    "to": dbData.email,
                    "from_name" : user_full_name,
                    "subject": template_row.message_subject
                      .replace('[[USER]]',  user_full_name),
                    "text": template_row.message_text_body
                      .replace('[[USER]]', user_full_name)
                      .replace('[[INVITATION_LINK]]', invitation_link)
                      .replace('[[UNSUBSCRIBE_LINK]]', unsubscribe_link),
                    "html": template_row.message_body
                      .replace('[[USER]]', user_full_name)
                      .replace('[[INVITATION_LINK]]', invitation_link)
                      .replace('[[UNSUBSCRIBE_LINK]]', unsubscribe_link)
                  };
                  mailOptions = JSON.stringify(mailOptions);
                  //send email to queue
                  sqsHelper.addToQueue(cfg.sqs_invitation_url, mailOptions, function(data){
                    if(data){
                      e_data = null;
                    }
                    else{
                      e_data = new Error('Unable to Queue ');
                    }
                    emailCallBack(e_data, email);
                  });
                }
                else{
                  e_data = new Error('Unable to get email template');
                  emailCallBack(e_data, email);
                }
              });
            }
            else{
              e_data = new Error('Unable to Insert connect');
              emailCallBack(e_data, email);
            }
          });
        }
        else{
          e_data = new Error('Already connected');
          emailCallBack(e_data, email);
        }
        if (email_list.length) {
          checkEmail(email_list.pop());
        } else {
          completionCallback();
        }
      });
    } catch (e) {
      //invalid email
      emailCallBack(e, email);
      if (email_list.length) {
        checkEmail(email_list.pop());
      } else {
        completionCallback();
      }
    }
  }
  checkEmail(email_list.pop());
}