Use AWS SQS to update the initial order status (#5)

Author: marcelovbcfilho

pom.xml

@@ -16,6 +16,7 @@
     <description>FIAP SOAT1 2023 - Group 63 - Phase 5 - Production microservice </description>
     <properties>
         <java.version>17</java.version>
+        <aws.sdk.version>1.12.674</aws.sdk.version>
         <sonar.coverage.exclusions>
             **/config/*,
             **/dto/*DTO.*,
@@ -27,6 +28,17 @@
             <url>https://jitpack.io</url>
         </repository>
     </repositories>
+    <dependencyManagement>
+        <dependencies>
+            <dependency>
+                <groupId>io.awspring.cloud</groupId>
+                <artifactId>spring-cloud-aws-dependencies</artifactId>
+                <version>3.0.0</version>
+                <type>pom</type>
+                <scope>import</scope>
+            </dependency>
+        </dependencies>
+    </dependencyManagement>
     <dependencies>
         <dependency>
             <groupId>org.springframework.boot</groupId>
@@ -40,6 +52,14 @@
             <groupId>org.springframework.boot</groupId>
             <artifactId>spring-boot-starter-validation</artifactId>
         </dependency>
+        <dependency>
+            <groupId>io.awspring.cloud</groupId>
+            <artifactId>spring-cloud-aws-starter</artifactId>
+        </dependency>
+        <dependency>
+            <groupId>io.awspring.cloud</groupId>
+            <artifactId>spring-cloud-aws-starter-sqs</artifactId>
+        </dependency>
         <dependency>
             <groupId>org.springframework.boot</groupId>
             <artifactId>spring-boot-devtools</artifactId>
@@ -89,7 +109,12 @@
         <dependency>
             <groupId>com.amazonaws</groupId>
             <artifactId>aws-java-sdk-dynamodb</artifactId>
-            <version>1.12.641</version>
+            <version>${aws.sdk.version}</version>
+        </dependency>
+        <dependency>
+            <groupId>com.amazonaws</groupId>
+            <artifactId>aws-java-sdk-sqs</artifactId>
+            <version>${aws.sdk.version}</version>
         </dependency>
         <dependency>
             <groupId>com.github.derjust</groupId>

src/main/java/br/com/grupo63/serviceproduction/api/controller/status/StatusQueueController.java

@@ -0,0 +1,23 @@
+package br.com.grupo63.serviceproduction.api.controller.status;
+
+import br.com.grupo63.serviceproduction.controller.StatusController;
+import br.com.grupo63.techchallenge.common.exception.NotFoundException;
+import br.com.grupo63.techchallenge.common.exception.ValidationException;
+import com.amazonaws.services.sqs.model.Message;
+import io.awspring.cloud.sqs.annotation.SqsListener;
+import lombok.RequiredArgsConstructor;
+import org.springframework.stereotype.Component;
+
+import java.util.Arrays;
+
+@RequiredArgsConstructor
+
+@Component
+public class StatusQueueController {
+    private final StatusController controller;
+
+    @SqsListener(value = "approvedPayments.fifo")
+    public void processMessage(int orderId) throws ValidationException, NotFoundException {
+        controller.advanceStatus(orderId);
+    }
+}

src/main/java/br/com/grupo63/serviceproduction/config/DynamoDBConfig.java

@@ -32,9 +32,9 @@ public class DynamoDBConfig {
     private String awsSessionToken;
 
     @Bean
-    public AmazonDynamoDB amazonDynamoDB() {
+    public AmazonDynamoDB amazonDynamoDB(AWSCredentials awsCredentials) {
         AmazonDynamoDB amazonDynamoDB
-                = new AmazonDynamoDBClient(awsCredentials());
+                = new AmazonDynamoDBClient(awsCredentials);
 
         if (!StringUtils.isEmpty(awsDynamoDBEndpoint)) {
             amazonDynamoDB.setEndpoint(awsDynamoDBEndpoint);
@@ -44,7 +44,7 @@ public AmazonDynamoDB amazonDynamoDB() {
     }
 
     @Bean
-    public AWSCredentials awsCredentials() {
+    public AWSCredentials AWSCredentials() {
         if (awsSessionToken == null || awsSessionToken.isBlank()) {
             return new BasicAWSCredentials(
                     awsAccessKey, awsSecretKey);

src/main/java/br/com/grupo63/serviceproduction/config/SQSClientConfig.java

@@ -0,0 +1,45 @@
+package br.com.grupo63.serviceproduction.config;
+
+import org.springframework.beans.factory.annotation.Value;
+import org.springframework.context.annotation.Bean;
+import org.springframework.context.annotation.Configuration;
+import software.amazon.awssdk.auth.credentials.AwsBasicCredentials;
+import software.amazon.awssdk.auth.credentials.AwsCredentials;
+import software.amazon.awssdk.auth.credentials.AwsSessionCredentials;
+import software.amazon.awssdk.auth.credentials.StaticCredentialsProvider;
+import software.amazon.awssdk.regions.Region;
+import software.amazon.awssdk.services.sqs.SqsAsyncClient;
+
+@Configuration
+class SQSClientConfig {
+
+    @Value("${spring.cloud.aws.credentials.access-key}")
+    private String accessKey;
+
+    @Value("${spring.cloud.aws.credentials.secret-key}")
+    private String secretKey;
+
+    @Value("${app.aws.session-token}")
+    private String sessionToken;
+
+    @Value("${spring.cloud.aws.region.static}")
+    private String region;
+
+    @Bean
+    SqsAsyncClient sqsAsyncClient(AwsCredentials awsCredentials) {
+        return SqsAsyncClient
+                .builder()
+                .region(Region.of(region))
+                .credentialsProvider(StaticCredentialsProvider
+                        .create(awsCredentials))
+                .build();
+    }
+
+    @Bean
+    public AwsCredentials awsCredentials() {
+        if (sessionToken == null || sessionToken.isBlank()) {
+            return AwsBasicCredentials.create(accessKey, secretKey);
+        }
+        return AwsSessionCredentials.create(accessKey, secretKey, sessionToken);
+    }
+}

src/main/resources/application-dev.yml

@@ -13,7 +13,30 @@ spring:
   flyway:
     locations: classpath:db/migrations/{vendor}/
     enabled: true
+  cloud:
+    aws:
+      credentials:
+        access-key: "${AWS_ACCESS_KEY:accesskey}"
+        secret-key: "${AWS_SECRET_KEY:secretkey}"
+      region:
+        static: "${AWS_REGION:us-east-2}"
+      sqs:
+        endpoint: "${AWS_SQS_ENDPOINT:endpoint}"
 jwt:
   token:
     key:
       public: "${JWT_PUBLIC_KEY:MIIBIjANBgkqhkiG9w0BAQEFAAOCAQ8AMIIBCgKCAQEAqStd8n4SGNM0eZhV/hzU+urHA5/IMZPoP9YQ9ZcLKWiX33nI6bSuZMCrLZcJExf63xS+uxDpGxM8Mnk2zOdl+lPwANXLzP1us5P1PyA3YPycW9J7C5YTQW0GiEL3M93ZX7vMJiVoBYblP3JPlYnoYlBORuc0JPk33KtfEZP+78qXpPHM8imYrJLe8ceiDLLFDU/nh5KC2dWAy3ci1ahoJ1Q9ELhp3IZLvOTX57H/T2VKOYOya5+ST41h+JjzI+qGTVnLcKaW+k25YLlVnkSspvdx98+yQDi7kbOTS6yRZHUPD6wPk/nUozpD0nZKccoH4W+zMwmQVtsAA6JCA9gfGwIDAQAB}"
+
+app:
+  docs-api-url: "${DOCS_API_URL:(no value)}"
+  aws:
+    access-key: "${AWS_ACCESS_KEY:no_access_key}"
+    secret-key: "${AWS_SECRET_KEY:no_secret_key}"
+    session-token: "${AWS_SESSION_TOKEN:}"
+    dynamodb:
+      endpoint: "${AWS_DYNAMODB_ENDPOINT:dynamodb.us-east-1.amazonaws.com}"
+
+server:
+  port: 8082
+  servlet:
+    context-path: "/production"

src/main/resources/application.yml

@@ -14,6 +14,15 @@ spring:
   flyway:
     locations: classpath:db/migrations/{vendor}/
     enabled: true
+  cloud:
+    aws:
+      credentials:
+        access-key: "${AWS_ACCESS_KEY:accesskey}"
+        secret-key: "${AWS_SECRET_KEY:secretkey}"
+      region:
+        static: "${AWS_REGION:us-east-2}"
+      sqs:
+        endpoint: "${AWS_SQS_ENDPOINT:endpoint}"
 
 springdoc:
   swagger-ui: