feat: adding sqs send and listener for tests

Author: marcelovbcfilho

pom.xml

@@ -16,13 +16,25 @@
     <description>FIAP SOAT1 2023 - Group 63 - Phase 4</description>
     <properties>
         <java.version>17</java.version>
+        <aws.sdk.version>1.12.674</aws.sdk.version>
     </properties>
     <repositories>
         <repository>
             <id>jitpack.io</id>
             <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>
@@ -36,6 +48,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>
@@ -85,7 +105,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/StatusAPIController.java

@@ -6,6 +6,7 @@
 import br.com.grupo63.techchallenge.common.api.controller.AbstractAPIController;
 import br.com.grupo63.techchallenge.common.exception.NotFoundException;
 import br.com.grupo63.techchallenge.common.exception.ValidationException;
+import io.awspring.cloud.sqs.operations.SqsTemplate;
 import io.swagger.v3.oas.annotations.Operation;
 import io.swagger.v3.oas.annotations.Parameter;
 import io.swagger.v3.oas.annotations.tags.Tag;
@@ -22,6 +23,15 @@
 public class StatusAPIController extends AbstractAPIController {
 
     private final StatusController controller;
+    private final SqsTemplate sqsTemplate;
+
+    @GetMapping("/batata")
+    public void batata() {
+        sqsTemplate.send(sqsSendOptions ->
+                sqsSendOptions
+                        .queue("approvedPayments.fifo")
+                        .payload(12));
+    }
 
     @Operation(
             tags = "5ª chamada - Fluxo principal - Acompanhamento e entrega",

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

@@ -0,0 +1,21 @@
+package br.com.grupo63.serviceproduction.api.controller.status;
+
+import br.com.grupo63.serviceproduction.controller.StatusController;
+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 message) {
+        System.err.println(message);
+    }
+}

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

@@ -28,9 +28,9 @@ public class DynamoDBConfig {
     private String amazonAWSSecretKey;
 
     @Bean
-    public AmazonDynamoDB amazonDynamoDB() {
+    public AmazonDynamoDB amazonDynamoDB(AWSCredentials awsCredentials) {
         AmazonDynamoDB amazonDynamoDB
-                = new AmazonDynamoDBClient(amazonAWSCredentials());
+                = new AmazonDynamoDBClient(awsCredentials);
 
         if (!StringUtils.isEmpty(amazonDynamoDBEndpoint)) {
             amazonDynamoDB.setEndpoint(amazonDynamoDBEndpoint);

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

@@ -0,0 +1,38 @@
+package br.com.grupo63.serviceproduction.config;
+
+import io.awspring.cloud.sqs.operations.SqsTemplate;
+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.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("${spring.cloud.aws.region.static}")
+    private String region;
+
+    @Bean
+    SqsAsyncClient sqsAsyncClient(){
+        return SqsAsyncClient
+                .builder()
+                .region(Region.of(region))
+                .credentialsProvider(StaticCredentialsProvider
+                        .create(AwsBasicCredentials.create(accessKey, secretKey)))
+                .build();
+    }
+
+    @Bean
+    public SqsTemplate sqsTemplate(SqsAsyncClient sqsAsyncClient){
+        return SqsTemplate.builder().sqsAsyncClient(sqsAsyncClient).build();
+    }
+}

src/main/resources/application-dev.yml

@@ -13,6 +13,15 @@ spring:
   flyway:
     locations: classpath:db/migrations/{vendor}/
     enabled: true
+  cloud:
+    aws:
+      credentials:
+        access-key: "${AMAZON_AWS_ACCESSKEY:accesskey}"
+        secret-key: "${AMAZON_AWS_SECRETKEY:secretkey}"
+      region:
+        static: "us-east-2"
+      sqs:
+        endpoint: "${AMAZON_AWS_SQS_ENDPOINT:endpoint}"
 jwt:
   token:
     key:
@@ -23,6 +32,8 @@ amazon:
   aws:
     accesskey: "${AMAZON_AWS_ACCESSKEY:accesskey}"
     secretkey: "${AMAZON_AWS_SECRETKEY:secretkey}"
+
 server:
+  port: 8082
   servlet:
     context-path: "/production"

src/test/java/br/com/grupo63/serviceproduction/ProductionIntegrationTest.java

@@ -45,7 +45,7 @@ public void setUp() {
         MockitoAnnotations.openMocks(this);
         statusUseCase = new StatusUseCase(statusJpaAdapter);
         statusController = new StatusController(statusUseCase);
-        statusAPIController = new StatusAPIController(statusController);
+        statusAPIController = new StatusAPIController(statusController, null);
     }
 
     @SneakyThrows