Added APIGatewayController

Author: clintonbosch

pom.xml

@@ -23,6 +23,16 @@
             <artifactId>s3-event-notifications</artifactId>
             <version>${aws-java-sdk2-version}</version>
         </dependency>
+        <dependency>
+            <groupId>org.apache.httpcomponents.client5</groupId>
+            <artifactId>httpclient5</artifactId>
+            <version>5.5</version>
+        </dependency>
+        <dependency>
+            <groupId>com.amazonaws.serverless</groupId>
+            <artifactId>aws-serverless-java-container-core</artifactId>
+            <version>2.1.4</version>
+        </dependency>
         <dependency>
             <groupId>software.amazon.awssdk</groupId>
             <artifactId>s3</artifactId>

src/main/java/za/co/prescient/ApiGatewayController.java

@@ -0,0 +1,35 @@
+package za.co.prescient;
+
+import com.amazonaws.serverless.proxy.model.Headers;
+import com.amazonaws.services.lambda.runtime.Context;
+import com.amazonaws.services.lambda.runtime.RequestHandler;
+import com.amazonaws.serverless.proxy.model.AwsProxyRequest;
+import com.amazonaws.serverless.proxy.model.AwsProxyResponse;
+import jakarta.ws.rs.core.HttpHeaders;
+import org.apache.hc.core5.http.HttpStatus;
+
+import java.util.Map;
+
+/**
+ * The purpose of this handler is to kick off a process from and S3 trigger
+ */
+public class ApiGatewayController implements RequestHandler<AwsProxyRequest, AwsProxyResponse> {
+
+    @Override
+    public AwsProxyResponse handleRequest(AwsProxyRequest input, Context context) {
+        Map<String, String> requestParameters = input.getQueryStringParameters();
+        String endpoint = input.getResource();
+        try {
+            System.out.println(input.getHttpMethod() + " method called on endpoint " + endpoint);
+            return buildTextResponse(HttpStatus.SC_OK, "OK");
+        } catch (Exception e) {
+            return buildTextResponse(HttpStatus.SC_INTERNAL_SERVER_ERROR, "Error: " + e.getMessage());
+        }
+    }
+
+    public static AwsProxyResponse buildTextResponse(int code, String body) {
+        Headers headers = new Headers();
+        headers.add(HttpHeaders.CONTENT_TYPE, "text/html");
+        return new AwsProxyResponse(code, headers, body);
+    }
+}

src/main/java/za/co/prescient/S3Controller.java

@@ -2,18 +2,17 @@
 
 import com.amazonaws.services.lambda.runtime.Context;
 import com.amazonaws.services.lambda.runtime.RequestHandler;
-import software.amazon.awssdk.eventnotifications.s3.model.S3EventNotification;
+import com.amazonaws.services.lambda.runtime.events.S3Event;
 
 /**
  * The purpose of this handler is to kick off a process from and S3 trigger
  */
-public class S3Controller implements RequestHandler<String, Void> {
+public class S3Controller implements RequestHandler<S3Event, Void> {
 
     @Override
-    public Void handleRequest(String jsonS3Event, Context context) {
-        System.out.println("Message received: " + jsonS3Event);
-        S3EventNotification s3EventNotification = S3EventNotification.fromJson(jsonS3Event);
-        Utils.process(s3EventNotification);
+    public Void handleRequest(S3Event s3event, Context context) {
+        System.out.println("Message received: " + s3event);
+        Utils.process(s3event.getRecords().get(0));
         return null;
     }
 }

src/main/java/za/co/prescient/Utils.java

@@ -2,8 +2,7 @@
 
 import com.amazonaws.services.lambda.runtime.events.SNSEvent;
 import com.amazonaws.services.lambda.runtime.events.SQSEvent;
-import software.amazon.awssdk.eventnotifications.s3.model.S3EventNotification;
-import software.amazon.awssdk.eventnotifications.s3.model.S3EventNotificationRecord;
+import com.amazonaws.services.lambda.runtime.events.models.s3.S3EventNotification;
 
 public class Utils {
 
@@ -21,12 +20,12 @@ public static void process(SQSEvent.SQSMessage sqsMessage) {
     }
 
     public static void process(S3EventNotification s3EventNotification) {
-        for (S3EventNotificationRecord record : s3EventNotification.getRecords()) {
+        for (S3EventNotification.S3EventNotificationRecord record : s3EventNotification.getRecords()) {
             process(record);
         }
     }
 
-    public static void process(S3EventNotificationRecord record) {
+    public static void process(S3EventNotification.S3EventNotificationRecord record) {
         String bucket = record.getS3().getBucket().getName();
         String key = record.getS3().getObject().getKey();
         System.out.println("Processing: " + bucket + " : " + key);