Merge pull request #6 from localstack-samples/app_updates

App updates

Author: tinyg210

docker-compose.yml

@@ -10,9 +10,9 @@ services:
     environment:
       - DEBUG=1  # enable more verbose logs
       - DOCKER_HOST=unix:///var/run/docker.sock #unix socket to communicate with the docker daemon
-#      - LAMBDA_KEEPALIVE_MS=0 # disable lambda keepalive
       - LOCALSTACK_HOST=localstack # where services are available from other containers
       - ENFORCE_IAM=1 # enforce IAM policies
+#      - LOCALSTACK_AUTH_TOKEN=${LOCALSTACK_AUTH_TOKEN}
     volumes:
       - "${LOCALSTACK_VOLUME_DIR:-./volume}:/var/lib/localstack"
       - "/var/run/docker.sock:/var/run/docker.sock"

pom.xml

@@ -82,7 +82,7 @@
       <dependency>
         <groupId>software.amazon.awssdk</groupId>
         <artifactId>bom</artifactId>
-        <version>2.20.26</version>
+        <version>2.22.12</version>
         <type>pom</type>
         <scope>import</scope>
       </dependency>

shipment-list-demo-cloud-pod

@@ -9,8 +9,8 @@
   <version>1.0-SNAPSHOT</version>
 
   <properties>
-    <maven.compiler.source>11</maven.compiler.source>
-    <maven.compiler.target>11</maven.compiler.target>
+    <maven.compiler.source>17</maven.compiler.source>
+    <maven.compiler.target>17</maven.compiler.target>
   </properties>
 
   <dependencies>
@@ -21,7 +21,6 @@
     <dependency>
       <groupId>software.amazon.awssdk</groupId>
       <artifactId>protocol-core</artifactId>
-      <version>2.20.47</version>
     </dependency>
     <dependency>
       <groupId>software.amazon.awssdk</groupId>
@@ -68,7 +67,7 @@
       <dependency>
         <groupId>software.amazon.awssdk</groupId>
         <artifactId>bom</artifactId>
-        <version>2.20.47</version>
+        <version>2.22.12</version>
         <type>pom</type>
         <scope>import</scope>
       </dependency>

shipment-picture-lambda-validator/pom.xml

@@ -5,12 +5,10 @@
 
 @Getter
 public enum Location {
+    REGION(Region.US_EAST_1);
+    private final Region region;
 
-
-  REGION(Region.US_EAST_1);
-
-  private final Region region;
-  Location(Region region) {
-    this.region = region;
-  }
+    Location(Region region) {
+        this.region = region;
+    }
 }

shipment-picture-lambda-validator/src/main/java/dev/ancaghenade/shipmentpicturelambdavalidator/Location.java

@@ -1,35 +1,33 @@
 package dev.ancaghenade.shipmentpicturelambdavalidator;
 
+import software.amazon.awssdk.services.sns.SnsClient;
+
 import java.net.URI;
 import java.util.Objects;
-import software.amazon.awssdk.services.sns.SnsClient;
 
 public class SNSClientHelper {
 
-  private static final String AWS_ENDPOINT_URL = System.getenv("AWS_ENDPOINT_URL");
-  private static String snsTopicArn;
+    private static final String AWS_ENDPOINT_URL = System.getenv("AWS_ENDPOINT_URL");
+    private static String snsTopicArn;
 
-  public static SnsClient getSnsClient() {
+    public static SnsClient getSnsClient() {
 
-    var clientBuilder = SnsClient.builder();
+        var clientBuilder = SnsClient.builder();
 
-    if (Objects.nonNull(AWS_ENDPOINT_URL)) {
-      snsTopicArn = String.format("arn:aws:sns:%s:000000000000:update_shipment_picture_topic",
-          Location.REGION.getRegion());
+        if (Objects.nonNull(AWS_ENDPOINT_URL)) {
+            snsTopicArn = System.getenv("SNS_TOPIC_ARN_DEV");
 
-      return clientBuilder
-          .region(Location.REGION.getRegion())
-          .endpointOverride(URI.create(AWS_ENDPOINT_URL))
-          .build();
-    } else {
-      snsTopicArn = String.format("arn:aws:sns:%s:%s:update_shipment_picture_topic",
-          Location.REGION.getRegion(), "932043840972");
-      return clientBuilder.build();
+            return clientBuilder
+                    .region(Location.REGION.getRegion())
+                    .endpointOverride(URI.create(AWS_ENDPOINT_URL))
+                    .build();
+        } else {
+            snsTopicArn = System.getenv("SNS_TOPIC_ARN_PROD");
+            return clientBuilder.build();
+        }
+    }
+    public static String topicARN() {
+        return snsTopicArn;
     }
-  }
-
-  public static String topicARN() {
-    return snsTopicArn;
-  }
 
 }

shipment-picture-lambda-validator/src/main/java/dev/ancaghenade/shipmentpicturelambdavalidator/PropertiesProvider.java

@@ -64,7 +64,7 @@ public void handleRequest(InputStream inputStream, OutputStream outputStream,
 
     // Check if the image was already processed
     if (s3ObjectResponse.response().metadata().entrySet().stream().anyMatch(
-        entry -> entry.getKey().equals("exclude-lambda") && entry.getValue().equals("true"))) {
+        entry -> entry.getKey().equals("skip-processing") && entry.getValue().equals("true"))) {
       context.getLogger().log("Object already present.");
       return;
     }
@@ -98,7 +98,7 @@ public void handleRequest(InputStream inputStream, OutputStream outputStream,
         var putObjectRequest = PutObjectRequest.builder()
             .bucket(BUCKET_NAME)
             .key(objectKey)
-            .metadata(Collections.singletonMap("exclude-lambda", "true"))
+            .metadata(Collections.singletonMap("skip-processing", "true"))
             .build();
 
         s3Client.putObject(putObjectRequest, RequestBody.fromBytes(imageBytes));
@@ -114,7 +114,7 @@ public void handleRequest(InputStream inputStream, OutputStream outputStream,
       var putObjectRequest = PutObjectRequest.builder()
           .bucket(BUCKET_NAME)
           .key(objectKey)
-          .metadata(Collections.singletonMap("exclude-lambda", "true"))
+          .metadata(Collections.singletonMap("skip-processing", "true"))
           .build();
 
       s3Client.putObject(putObjectRequest, RequestBody.fromBytes(
@@ -143,7 +143,7 @@ private String getObjectKey(InputStream inputStream, Context context) {
         return keys.iterator().next();
       }
     } catch (IOException ioe) {
-      context.getLogger().log("caught IOException reading input stream");
+      context.getLogger().log("caught IOException reading input stream: " + ioe.getMessage());
     }
     return null;
   }

shipment-picture-lambda-validator/src/main/java/dev/ancaghenade/shipmentpicturelambdavalidator/SNSClientHelper.java

@@ -7,5 +7,5 @@ aws:
   dynamodb:
     endpoint: http://localhost.localstack.cloud:4566/
   sqs:
-    endpoint: http://localhost:4566/000000000000
+    endpoint: http://localhost.localstack.cloud:4566/000000000000
   region: us-east-1

shipment-picture-lambda-validator/src/main/java/dev/ancaghenade/shipmentpicturelambdavalidator/ServiceHandler.java

@@ -1,2 +1,2 @@
-shipment-picture-bucket=shipment-picture-bucket-concise-malamute
-shipment-picture-bucket-validator=shipment-picture-lambda-validator-bucket-concise-malamute
+shipment-picture-bucket=shipment-picture-bucket-certain-yak
+shipment-picture-bucket-validator=shipment-picture-lambda-validator-bucket-certain-yak