welcome email event

Author: Sachin Maheshwari

buildtokenproperties.sh

@@ -44,7 +44,7 @@ AUTH0_NEW_DOMAIN=$(eval "echo \$${ENV}_AUTH0_NEW_DOMAIN")
 AUTH0_DOMAIN=$(eval "echo \$${ENV}_AUTH0_DOMAIN")
 
 SENDGRID_RESEND_ACTIVATION_EMAIL_TEMPLATE_ID=$(eval "echo \$${ENV}_SENDGRID_RESEND_ACTIVATION_EMAIL_TEMPLATE_ID")
-
+SENDGRID_WELCOME_EMAIL_TEMPLATE_ID=$(eval "echo \$${ENV}_SENDGRID_WELCOME_EMAIL_TEMPLATE_ID")
 
 
 if [[ -z "$ENV" ]] ; then
@@ -110,3 +110,4 @@ perl -pi -e "s|\{\{M2MAUTHCONFIG_USERPROFILES_DELETE\}\}|$M2MAUTHCONFIG_USERPROF
 perl -pi -e "s/\{\{AUTH0_NEW_DOMAIN\}\}/$AUTH0_NEW_DOMAIN/g" $CONFFILENAME
 perl -pi -e "s/\{\{AUTH0_DOMAIN\}\}/$AUTH0_DOMAIN/g" $CONFFILENAME
 perl -pi -e "s/\{\{SENDGRID_RESEND_ACTIVATION_EMAIL_TEMPLATE_ID\}\}/$SENDGRID_RESEND_ACTIVATION_EMAIL_TEMPLATE_ID/g" $CONFFILENAME
+perl -pi -e "s/\{\{SENDGRID_WELCOME_EMAIL_TEMPLATE_ID\}\}/$SENDGRID_WELCOME_EMAIL_TEMPLATE_ID/g" $CONFFILENAME

src/main/java/com/appirio/tech/core/service/identity/IdentityApplication.java

@@ -234,6 +234,7 @@ public void run(IdentityConfiguration configuration, Environment environment) th
     	userResource.setAuth0Client(configuration.getAuth0()); // TODO: constructor
     	userResource.setDomain(configuration.getAuthDomain());
 		userResource.setSendgridTemplateId(Utils.getString("sendGridTemplateId"));
+		userResource.setSendgridWelcomeTemplateId(Utils.getString("sendGridWelcomeTemplateId"));
     	// this secret _used_ to be different from the one used in AuthorizationResource.
     	// it _was_ the secret x2. (userResource.setSecret(getSecret()+getSecret());)
 		// we assume this was done to further limit the usability of the oneTimeToken generated in userResource

src/main/java/com/appirio/tech/core/service/identity/resource/UserResource.java

@@ -104,6 +104,8 @@ public class UserResource implements GetResource<User>, DDLResource<User> {
     private String domain;
 
     private String sendgridTemplateId;
+
+    private String sendgridWelcomeTemplateId;
 
     protected UserDAO userDao;
 
@@ -1742,10 +1744,19 @@ public String getSendgridTemplateId() {
         return sendgridTemplateId;
     }
 
+    public void setSendgridWelcomeTemplateId(String sendgridWelcomeTemplateId) {
+        this.sendgridWelcomeTemplateId = sendgridWelcomeTemplateId;
+    }
+
+    public String getSendgridWelcomeTemplateId() {
+        return sendgridWelcomeTemplateId;
+    }
+
     public void setSendgridTemplateId(String sendgridTemplateId) {
         this.sendgridTemplateId = sendgridTemplateId;
     }
 
+
     public String getSecret() {
         return secret;
     }
@@ -1816,6 +1827,38 @@ private void sendActivationEmailEvent(User user, String redirectUrl) {
             logger.error("Error occured while publishing the events to new kafka.");
         }
     }
+
+    private void sendWelcomeEmailEvent(User user) {
+
+        EventMessage msg = EventMessage.getDefault();
+        msg.setTopic("external.action.email");
+
+        Map<String,Object> payload = new LinkedHashMap<String,Object>();
+
+        Map<String,Object> data = new LinkedHashMap<String,Object>();
+        data.put("handle", user.getHandle());
+
+        payload.put("data", data);
+
+        Map<String,Object> from = new LinkedHashMap<String,Object>();
+        from.put("email", String.format("Topcoder <noreply@%s>", getDomain()));
+        payload.put("from", from);
+
+        payload.put("version", "v3");
+        payload.put("sendgrid_template_id", this.getSendgridWelcomeTemplateId());
+
+        ArrayList<String> recipients = new ArrayList<String>();
+        recipients.add(user.getEmail());
+
+        payload.put("recipients", recipients);
+
+        msg.setPayload(payload);
+        try {
+            this.eventBusServiceClient.reFireEvent(msg);
+        } catch (Exception e) {
+            logger.error("Error occured while publishing the events to new kafka.");
+        }
+    }
 
     protected NotificationPayload createActivationNotificationPayload(User user, String redirectUrl) {
     	//If for Connect registration, send activation email with activation code only.
@@ -1834,6 +1877,7 @@ protected void notifyPasswordReset(User user, String resetToken, String resetPas
     protected void notifyWelcome(User user) {
         publishNotificationEvent(
                 new NotificationPayload.WelcomePayload(user).getMailRepresentation());
+        sendWelcomeEmailEvent(user);
     }
 
     protected void publishNotificationEvent(MailRepresentation mail) {
@@ -1871,8 +1915,6 @@ protected void publishEvent(String topic, Object payload) {
             logger.error(String.format("Failed to convert the payload - %s", payload), e);
         }
 
-
-
     }
 
     /**

src/main/resources/config.yml

@@ -12,6 +12,7 @@ context:
   passwordHashKey: @application.password.key@
   ssoTokenSalt: @application.ssotoken.salt@
   sendGridTemplateId: @application.sendgrid.template.id@
+  sendGridWelcomeTemplateId: @application.sendgrid.welcome.template.id@
   jwtExpirySeconds: 600
   cookieExpirySeconds: 7776000
 

token.properties.template

@@ -9,6 +9,7 @@
 
 #sendgrid
 @application.sendgrid.template.id@={{SENDGRID_RESEND_ACTIVATION_EMAIL_TEMPLATE_ID}}
+@application.sendgrid.welcome.template.id@={{SENDGRID_WELCOME_EMAIL_TEMPLATE_ID}}
 
 @ldap.host@={{LDAP_SERVER}}
 @ldap.port@=389