SNS email notifications

Author: mwunderl

.ebextensions/env.config

@@ -1,3 +1,6 @@
 option_settings:
+  aws:elasticbeanstalk:customoption:
+    NotificationEmail: [email protected]
   aws:elasticbeanstalk:application:environment:
     AWS_REGION: '`{"Ref" : "AWS::Region"}`'
+    NOTIFICATION_TOPIC: '`{"Ref" : "NotificationTopic"}`'

.ebextensions/sns-topic.config

@@ -0,0 +1,8 @@
+Resources:
+  NotificationTopic:
+    Type: AWS::SNS::Topic
+    Properties:
+      Subscription:
+      - Endpoint:
+          Fn::GetOptionSetting: {DefaultValue: [email protected], OptionName: NotificationEmail}
+        Protocol: email

build.gradle

@@ -30,6 +30,7 @@ dependencies {
     compile("org.springframework.boot:spring-boot-starter-web")
     testCompile("org.springframework.boot:spring-boot-starter-test")
     compile("com.amazonaws:aws-java-sdk-dynamodb")
+    compile("com.amazonaws:aws-java-sdk-sns")
     testCompile("junit:junit:4.11")
     compile("com.fasterxml.jackson.core:jackson-databind:2.8.4")
 }

src/main/java/scorekeep/MoveFactory.java

@@ -55,6 +55,10 @@ public Move newMove(String sessionId, String gameId, String userId, String moveT
     } catch ( ClassNotFoundException | NoSuchMethodException | IllegalAccessException | InvocationTargetException e) { throw new RulesException(rulesName); }
     // save new game state
     State newState = new State(stateId, sessionId, gameId, newStateText, newTurn);
+    // send notification on game end
+    if ( newStateText.startsWith("A") || newStateText.startsWith("B")) {
+      Utils.sendNotification("Scorekeep game completed", "Winner: " + userId);
+    }
     // register state and move id to game
     gameController.setGameMove(sessionId, gameId, moveId);
     gameController.setGameState(sessionId, gameId, stateId);

src/main/java/scorekeep/Utils.java

@@ -0,0 +1,26 @@
+package scorekeep;
+
+import com.amazonaws.regions.Regions;
+import com.amazonaws.services.sns.AmazonSNS;
+import com.amazonaws.services.sns.AmazonSNSClientBuilder;
+import com.amazonaws.services.sns.model.PublishRequest;
+import com.amazonaws.services.sns.model.PublishResult;
+
+import org.slf4j.Logger;
+import org.slf4j.LoggerFactory;
+
+public class Utils {
+  private static final Logger logger = LoggerFactory.getLogger("scorekeep.Utils");
+  private static AmazonSNS snsclient = AmazonSNSClientBuilder.standard()
+        .withRegion(Regions.fromName(System.getenv("AWS_REGION")))
+        .build();
+  /*
+   * Send a notification email.
+   */
+  public static void sendNotification(String subject, String body) {
+    String topicarn = System.getenv("NOTIFICATION_TOPIC");
+    PublishRequest publishRequest = new PublishRequest(topicarn, body, subject);
+    PublishResult publishResult = snsclient.publish(publishRequest);
+    logger.info("Email sent: " + publishResult.getMessageId());
+  }
+}