From e03b55be17261ed13ddf421bcf4a804a083a7614 Mon Sep 17 00:00:00 2001
From: Thorsten Ortlepp <post@ortlepp.eu>
Date: Fri, 26 Apr 2024 00:30:46 +0200
Subject: added implementation

---
 .../service/SnsNotificationSender.java             | 63 ++++++++++++++++++++++
 1 file changed, 63 insertions(+)
 create mode 100644 src/main/java/eu/ortlepp/notificationsender/service/SnsNotificationSender.java

(limited to 'src/main/java/eu/ortlepp/notificationsender/service/SnsNotificationSender.java')

diff --git a/src/main/java/eu/ortlepp/notificationsender/service/SnsNotificationSender.java b/src/main/java/eu/ortlepp/notificationsender/service/SnsNotificationSender.java
new file mode 100644
index 0000000..958365a
--- /dev/null
+++ b/src/main/java/eu/ortlepp/notificationsender/service/SnsNotificationSender.java
@@ -0,0 +1,63 @@
+package eu.ortlepp.notificationsender.service;
+
+import com.amazonaws.services.lambda.runtime.LambdaLogger;
+import eu.ortlepp.notificationsender.util.Config;
+import java.util.List;
+import software.amazon.awssdk.http.HttpStatusCode;
+import software.amazon.awssdk.services.sns.SnsClient;
+import software.amazon.awssdk.services.sns.model.PublishRequest;
+import software.amazon.awssdk.services.sns.model.PublishResponse;
+import software.amazon.awssdk.services.sns.model.SnsException;
+
+/**
+ * A notification sender for Amazon SNS.
+ */
+public class SnsNotificationSender implements NotificationSender {
+
+  private final LambdaLogger logger;
+
+
+  /**
+   * Constructor to initialize the sender.
+   *
+   * @param logger The logger of the AWS Lambda
+   */
+  public SnsNotificationSender(final LambdaLogger logger) {
+    this.logger = logger;
+  }
+
+
+  /**
+   * Send a list of notifications to the configured SNS topic.
+   * All notifications are combined into a single message.
+   *
+   * @param notifications The notifications to send
+   * @return The result of the sending; true = successful, false = error occurred
+   */
+  @Override
+  public boolean sendNotifications(final List<String> notifications) {
+    String notification = formatNotifications(notifications);
+
+    try (SnsClient snsClient = SnsClient.builder().region(Config.REGION).build()) {
+      PublishRequest request =
+          PublishRequest.builder().message(notification).topicArn(Config.ARN).build();
+      PublishResponse result = snsClient.publish(request);
+      int resultStatusCode = result.sdkHttpResponse().statusCode();
+
+      if (resultStatusCode ==  HttpStatusCode.OK) {
+        logger.log("notification sent successfully");
+        return true;
+      }
+
+      logger.log("sending notification failed with status " + resultStatusCode);
+      logger.log("failed message was " + notification);
+      return false;
+
+    } catch (SnsException ex) {
+      logger.log("sending notification failed: " + ex.getMessage());
+      logger.log("failed message was " + notification);
+      return false;
+    }
+  }
+
+}
-- 
cgit v1.2.3