adding tests and wrapping up futures service

Author: pedrolopes9-7

spring-cloud-modules/spring-cloud-openfeign-2/pom.xml

@@ -7,6 +7,18 @@
     <artifactId>spring-cloud-openfeign-2</artifactId>
     <name>spring-cloud-openfeign-2</name>
     <description>OpenFeign project for Spring Boot</description>
+    <build>
+        <plugins>
+            <plugin>
+                <groupId>org.apache.maven.plugins</groupId>
+                <artifactId>maven-compiler-plugin</artifactId>
+                <configuration>
+                    <source>9</source>
+                    <target>9</target>
+                </configuration>
+            </plugin>
+        </plugins>
+    </build>
 
     <parent>
         <groupId>com.baeldung.spring.cloud</groupId>

spring-cloud-modules/spring-cloud-openfeign-2/src/main/java/com/baeldung/cloud/openfeign/completablefuturefeignclient/PaymentMethodClient.java

@@ -7,9 +7,9 @@
 
 import java.util.List;
 
-@FeignClient(name = "paymentClient", url = "http://payments-api.com")
+@FeignClient(name = "paymentClient", url = "http://localhost:8083")
 public interface PaymentMethodClient {
 
-    @RequestMapping(method = RequestMethod.GET, value = "/payments/methods")
-    List<String> getAvailablePaymentMethods(@RequestParam(name = "site_id") String siteId);
+    @RequestMapping(method = RequestMethod.POST, value = "/purchase")
+    String processPurchase(@RequestParam(name = "site_id") String siteId);
 }

spring-cloud-modules/spring-cloud-openfeign-2/src/main/java/com/baeldung/cloud/openfeign/completablefuturefeignclient/Purchase.java

@@ -3,26 +3,12 @@
 public class Purchase {
 
     private String siteId;
-    private long orderId;
 
-    public Purchase(String siteId, long orderId) {
+    public Purchase(String siteId) {
         this.siteId = siteId;
-        this.orderId = orderId;
     }
 
     public String getSiteId() {
         return siteId;
     }
-
-    public void setSiteId(String siteId) {
-        this.siteId = siteId;
-    }
-
-    public long getOrderId() {
-        return orderId;
-    }
-
-    public void setOrderId(long orderId) {
-        this.orderId = orderId;
-    }
 }

spring-cloud-modules/spring-cloud-openfeign-2/src/main/java/com/baeldung/cloud/openfeign/completablefuturefeignclient/PurchaseService.java

@@ -1,9 +1,14 @@
 package com.baeldung.cloud.openfeign.completablefuturefeignclient;
 
+import feign.FeignException;
 import org.springframework.stereotype.Service;
 
 import java.util.List;
 import java.util.concurrent.CompletableFuture;
+import java.util.concurrent.ExecutionException;
+import java.util.concurrent.TimeUnit;
+
+import static java.lang.String.format;
 
 @Service
 public class PurchaseService {
@@ -16,13 +21,26 @@ public PurchaseService(PaymentMethodClient paymentMethodClient, ReportClient rep
         this.reportClient = reportClient;
     }
 
-    public void executePurchase(Purchase purchase) {
+    public String executePurchase(Purchase purchase) throws ExecutionException, InterruptedException {
+        CompletableFuture<String> paymentMethodsFuture = CompletableFuture.supplyAsync(() -> paymentMethodClient.processPurchase(purchase.getSiteId()))
+                .handle((res, ex) -> {
+                    if (ex.getCause() instanceof FeignException) {
+                        int status = ((FeignException) ex.getCause()).status();
+
+                        if (status == 404) {
+                            return null;
+                        }
+                    }
+                    return res;
+                })
+                .orTimeout(2, TimeUnit.SECONDS);
+
+        CompletableFuture<Void> reportFuture = CompletableFuture.runAsync(() -> reportClient.sendReport("Purchase Order Report"))
+                .orTimeout(1, TimeUnit.SECONDS);
 
-        ReportRequest report = new ReportRequest("Creating purchase for order", purchase.getOrderId(), purchase.getSiteId());
+        CompletableFuture.allOf(paymentMethodsFuture, reportFuture)
+                .join();
 
-        CompletableFuture.allOf(
-                CompletableFuture.supplyAsync(() -> paymentMethodClient.getAvailablePaymentMethods(purchase.getSiteId())),
-                CompletableFuture.runAsync(() -> reportClient.sendReport(report))
-        );
+        return paymentMethodsFuture.get();
     }
 }

spring-cloud-modules/spring-cloud-openfeign-2/src/main/java/com/baeldung/cloud/openfeign/completablefuturefeignclient/ReportClient.java

@@ -5,9 +5,9 @@
 import org.springframework.web.bind.annotation.RequestMapping;
 import org.springframework.web.bind.annotation.RequestMethod;
 
-@FeignClient(name = "reportClient", url = "http://reports-api.com")
+@FeignClient(name = "reportClient", url = "http://localhost:8083")
 public interface ReportClient {
 
     @RequestMapping(method = RequestMethod.POST, value = "/reports")
-    void sendReport(@RequestBody ReportRequest reportRequest);
+    void sendReport(@RequestBody String reportRequest);
 }

spring-cloud-modules/spring-cloud-openfeign-2/src/main/java/com/baeldung/cloud/openfeign/completablefuturefeignclient/ReportRequest.java

@@ -0,0 +1,62 @@
+package com.baeldung.cloud.openfeign.completablefuturefeignclient;
+
+import com.baeldung.cloud.openfeign.ExampleApplication;
+import com.github.tomakehurst.wiremock.WireMockServer;
+import org.junit.jupiter.api.AfterEach;
+import org.junit.jupiter.api.BeforeEach;
+import org.junit.jupiter.api.Test;
+import org.junit.jupiter.api.extension.ExtendWith;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.boot.test.context.SpringBootTest;
+import org.springframework.http.HttpStatus;
+import org.springframework.test.context.junit.jupiter.SpringExtension;
+
+import java.util.concurrent.ExecutionException;
+
+import static com.github.tomakehurst.wiremock.client.WireMock.*;
+import static org.junit.Assert.assertNull;
+import static org.junit.Assert.assertThrows;
+import static org.mockito.ArgumentMatchers.any;
+
+@ExtendWith(SpringExtension.class)
+@SpringBootTest(classes = ExampleApplication.class)
+class PurchaseServiceIntegrationTest {
+
+    @Autowired
+    private PurchaseService purchaseService;
+
+    @Autowired
+    private PaymentMethodClient paymentMethodClient;
+
+    @Autowired
+    private ReportClient reportClient;
+
+    private WireMockServer wireMockServer;
+
+    @BeforeEach
+    public void startWireMockServer() {
+        wireMockServer = new WireMockServer(8083);
+        configureFor("localhost", 8083);
+        wireMockServer.start();
+    }
+
+    @AfterEach
+    public void stopWireMockServer() {
+        wireMockServer.stop();
+    }
+
+    @Test
+    void executePurchase() throws ExecutionException, InterruptedException {
+        stubFor(post(urlEqualTo("/purchase?site_id=BR"))
+                .willReturn(aResponse().withStatus(HttpStatus.NOT_FOUND.value())));
+
+        stubFor(post(urlEqualTo("/reports"))
+                .willReturn(aResponse().withStatus(HttpStatus.OK.value())));
+
+        Purchase purchase = new Purchase("BR");
+
+        String result = purchaseService.executePurchase(purchase);
+
+        assertNull(result);
+    }
+}