Use AWS SQS to update the initial order status

Author: HZaim

pom.xml

@@ -29,6 +29,18 @@
 		</repository>
 	</repositories>
 
+	<dependencyManagement>
+		<dependencies>
+			<dependency>
+				<groupId>io.awspring.cloud</groupId>
+				<artifactId>spring-cloud-aws-dependencies</artifactId>
+				<version>3.0.4</version>
+				<type>pom</type>
+				<scope>import</scope>
+			</dependency>
+		</dependencies>
+	</dependencyManagement>
+
 	<dependencies>
 		<dependency>
 			<groupId>com.github.soat-tech-challenge</groupId>
@@ -51,6 +63,19 @@
 			<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>com.amazonaws</groupId>
+			<artifactId>aws-java-sdk-sqs</artifactId>
+			<version>1.12.674</version>
+		</dependency>
 		<dependency>
 			<groupId>org.springframework.boot</groupId>
 			<artifactId>spring-boot-devtools</artifactId>

src/main/java/br/com/grupo63/techchallenge/payment/config/SQSClientConfig.java

@@ -0,0 +1,45 @@
+package br.com.grupo63.techchallenge.payment.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/java/br/com/grupo63/techchallenge/payment/usecase/PaymentUseCase.java

@@ -8,7 +8,7 @@
 import br.com.grupo63.techchallenge.payment.gateway.order.dto.OrderDTO;
 import br.com.grupo63.techchallenge.payment.gateway.payment.IMercadoPagoGateway;
 import br.com.grupo63.techchallenge.payment.gateway.payment.IPaymentGateway;
-import br.com.grupo63.techchallenge.payment.gateway.status.IStatusGateway;
+import io.awspring.cloud.sqs.operations.SqsTemplate;
 import lombok.RequiredArgsConstructor;
 import org.springframework.stereotype.Service;
 
@@ -19,7 +19,7 @@ public class PaymentUseCase implements IPaymentUseCase {
     private final IMercadoPagoGateway mercadoPagoGateway;
     private final IOrderGateway orderGateway;
     private final IPaymentGateway paymentGateway;
-    private final IStatusGateway statusGateway;
+    private final SqsTemplate sqsTemplate;
 
     @Override
     public String startPayment(Long orderId) throws NotFoundException {
@@ -41,8 +41,12 @@ public void finishPayment(Long orderId) throws NotFoundException {
         payment.setStatus(PaymentStatus.PAID);
         paymentGateway.saveAndFlush(payment);
 
-        statusGateway.advanceStatus(orderId);
-
+        sqsTemplate.send(sqsSendOptions ->
+           sqsSendOptions
+                .queue("approvedPayments.fifo")
+                .payload(orderId)
+                   .messageDeduplicationId(orderId.toString())
+                   .messageGroupId(orderId.toString()));
     }
 
     @Override

src/main/resources/application-dev.yml

@@ -18,6 +18,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}"
 
 # --- Custom keys ---
 

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:

src/test/java/br/com/grupo63/techchallenge/payment/PaymentIntegrationTest.java

@@ -12,6 +12,7 @@
 import br.com.grupo63.techchallenge.payment.gateway.payment.*;
 import br.com.grupo63.techchallenge.payment.gateway.status.IStatusGateway;
 import br.com.grupo63.techchallenge.payment.usecase.PaymentUseCase;
+import io.awspring.cloud.sqs.operations.SqsTemplate;
 import lombok.SneakyThrows;
 import org.junit.jupiter.api.BeforeEach;
 import org.junit.jupiter.api.Test;
@@ -42,6 +43,8 @@ class PaymentIntegrationTest {
     private PaymentController paymentController;
     private PaymentAPIController paymentAPIController;
     private MercadoPagoGateway mercadoPagoGateway;
+    @Mock
+    private SqsTemplate sqsTemplate;
 
 
 
@@ -57,7 +60,7 @@ class PaymentIntegrationTest {
     void setUp() {
         MockitoAnnotations.openMocks(this);
         mercadoPagoGateway = new MercadoPagoGateway();
-        paymentUseCase = new PaymentUseCase(mercadoPagoGateway, orderGateway, paymentJpaAdapter, statusGateway);
+        paymentUseCase = new PaymentUseCase(mercadoPagoGateway, orderGateway, paymentJpaAdapter, sqsTemplate);
         paymentController = new PaymentController(paymentUseCase);
         paymentAPIController = new PaymentAPIController(paymentController);
     }