send email event for email invites

Author: gondzo

config/default.json

@@ -51,5 +51,8 @@
   "AUTH0_URL": "",
   "TOKEN_CACHE_TIME": "",
   "whitelistedOriginsForUserIdAuth": "[\"https:\/\/topcoder-newauth.auth0.com\/\",\"https:\/\/api.topcoder-dev.com\"]",
-  "AUTH0_PROXY_SERVER_URL" : ""
+  "AUTH0_PROXY_SERVER_URL" : "",
+  "EMAIL_INVITE_FROM_NAME":"Topcoder Connect",
+  "EMAIL_INVITE_FROM_EMAIL":"noreply@connect.topcoder.com"
+
 }

src/constants.js

@@ -131,6 +131,7 @@ export const BUS_API_EVENT = {
   // Project Member Invites
   PROJECT_MEMBER_INVITE_CREATED: 'notifications.connect.project.member.invite.created',
   PROJECT_MEMBER_INVITE_UPDATED: 'notifications.connect.project.member.invite.updated',
+  PROJECT_MEMBER_EMAIL_INVITE_CREATED: 'connect.action.project.membet.invite.created',
 };
 
 export const REGEX = {

src/routes/projectMemberInvites/create.js

@@ -3,11 +3,14 @@
 import validate from 'express-validation';
 import _ from 'lodash';
 import Joi from 'joi';
+import config from 'config';
 import { middleware as tcMiddleware } from 'tc-core-library-js';
 import models from '../../models';
 import util from '../../util';
 import { PROJECT_MEMBER_ROLE, PROJECT_MEMBER_MANAGER_ROLES,
-  MANAGER_ROLES, INVITE_STATUS, EVENT } from '../../constants';
+  MANAGER_ROLES, INVITE_STATUS, EVENT, PROJECT_MEMBER_EMAIL_INVITE_CREATED } from '../../constants';
+import { createEvent } from '../../services/busApi';
+
 
 /**
  * API to create member invite to project.
@@ -140,8 +143,33 @@ module.exports = [
                             v,
                             { correlationId: req.id },
                         );
+                    // send email invite (async)
+                    if (v.email) {
+                      models.Project
+                      .find({
+                        where: { id: projectId },
+                        raw: true,
+                      })
+                      .then((_project) => {
+                        createEvent(PROJECT_MEMBER_EMAIL_INVITE_CREATED,
+                          {
+                            data: {
+                              date: (new Date()).toISOString(),
+                              projectName: _project.name,
+                              projectId,
+                            },
+                            recipients: [v.email],
+                            version: 'v3',
+                            from: {
+                              name: config.get('EMAIL_INVITE_FROM_NAME'),
+                              email: config.get('EMAIL_INVITE_FROM_EMAIL'),
+                            },
+                            categories: [PROJECT_MEMBER_EMAIL_INVITE_CREATED],
+                          }, req.log);
+                      });
+                    }
+                    return res.status(201).json(util.wrapResponse(req.id, values, null, 201));
                   });
-                  return res.status(201).json(util.wrapResponse(req.id, values, null, 201));
                 });
             });
     }).catch(err => next(err));