Fix rest-clients quickstarts by using wiremock to get countries

The REST api https://restcountries.eu/rest used to get a list of countries was moved to https://countrylayer.com/ and requires an API key to keep using it.

With these changes, we'll start up a REST API mock server (does not require Docker) to provide a list of countries.

I confirmed that these two modules work fine on JVM and Native.

This change `quarkus.tls.trust-all=true` is not really necessary but by adding it, users will see the real issue (unauthorized access to https://restcountries.eu/rest)

rest-client-quickstart/pom.xml

@@ -14,6 +14,7 @@
         <quarkus.platform.version>999-SNAPSHOT</quarkus.platform.version>
         <compiler-plugin.version>3.8.1</compiler-plugin.version>
         <surefire-plugin.version>3.0.0-M5</surefire-plugin.version>
+        <wiremock.version>2.27.2</wiremock.version>
         <project.build.sourceEncoding>UTF-8</project.build.sourceEncoding>
         <maven.compiler.source>11</maven.compiler.source>
         <maven.compiler.target>11</maven.compiler.target>
@@ -59,6 +60,12 @@
             <artifactId>rest-assured</artifactId>
             <scope>test</scope>
         </dependency>
+        <dependency>
+            <groupId>com.github.tomakehurst</groupId>
+            <artifactId>wiremock-jre8</artifactId>
+            <scope>test</scope>
+            <version>${wiremock.version}</version>
+        </dependency>
     </dependencies>
     <build>
         <plugins>

rest-client-quickstart/src/main/resources/application.properties

@@ -1 +1,2 @@
+quarkus.tls.trust-all=true
 org.acme.rest.client.CountriesService/mp-rest/url=https://restcountries.eu/rest

rest-client-quickstart/src/test/java/org/acme/rest/client/CountriesResourceTest.java

@@ -3,11 +3,14 @@
 import static io.restassured.RestAssured.given;
 import static org.hamcrest.CoreMatchers.is;
 
+import org.acme.rest.client.resources.WireMockCountriesResource;
 import org.junit.jupiter.api.Test;
 
+import io.quarkus.test.common.QuarkusTestResource;
 import io.quarkus.test.junit.QuarkusTest;
 
 @QuarkusTest
+@QuarkusTestResource(WireMockCountriesResource.class)
 public class CountriesResourceTest {
 
     @Test

rest-client-quickstart/src/test/java/org/acme/rest/client/resources/WireMockCountriesResource.java

@@ -0,0 +1,71 @@
+package org.acme.rest.client.resources;
+
+import static com.github.tomakehurst.wiremock.client.WireMock.get;
+import static com.github.tomakehurst.wiremock.client.WireMock.okJson;
+import static com.github.tomakehurst.wiremock.client.WireMock.urlEqualTo;
+import static org.junit.jupiter.api.Assertions.fail;
+
+import java.io.IOException;
+import java.io.InputStream;
+import java.io.StringReader;
+import java.util.Collections;
+import java.util.Map;
+import java.util.Objects;
+
+import javax.json.Json;
+import javax.json.JsonValue;
+import javax.json.stream.JsonParser;
+
+import com.github.tomakehurst.wiremock.WireMockServer;
+
+import io.quarkus.test.common.QuarkusTestResourceLifecycleManager;
+
+public class WireMockCountriesResource implements QuarkusTestResourceLifecycleManager {
+
+    private static final String COUNTRIES_JSON_FILE = "/countries.json";
+    private static final String BASE_PATH = "/rest";
+    private static final int WIREMOCK_PORT = 7777;
+
+    private WireMockServer wireMockServer;
+
+    @Override
+    public Map<String, String> start() {
+        wireMockServer = new WireMockServer(WIREMOCK_PORT);
+        wireMockServer.start();
+        stubCountries();
+        return Collections.singletonMap("org.acme.rest.client.CountriesService/mp-rest/url",
+                wireMockServer.baseUrl() + BASE_PATH);
+    }
+
+    @Override
+    public void stop() {
+        if (Objects.nonNull(wireMockServer))
+            wireMockServer.stop();
+    }
+
+    private void stubCountries() {
+
+        try (InputStream is = WireMockCountriesResource.class.getResourceAsStream(COUNTRIES_JSON_FILE)) {
+            String countries = new String(is.readAllBytes());
+
+            // Stub for full list of countries:
+            wireMockServer.stubFor(get(urlEqualTo(BASE_PATH))
+                    .willReturn(okJson(countries)));
+
+            // Stub for each country
+            try (StringReader sr = new StringReader(countries);
+                    JsonParser parser = Json.createParser(sr)) {
+                parser.next();
+                for (JsonValue country : parser.getArray()) {
+                    String name = country.asJsonObject().getString("name");
+
+                    wireMockServer.stubFor(get(urlEqualTo(BASE_PATH + "/v2/name/" + name))
+                            .willReturn(okJson("[" + country + "]")));
+                }
+            }
+
+        } catch (IOException e) {
+            fail("Could not configure Wiremock server. Caused by: " + e.getMessage());
+        }
+    }
+}

rest-client-quickstart/src/test/resources/countries.json

@@ -0,0 +1,26 @@
+[
+  {
+    "name": "greece",
+    "capital": "Athens",
+    "currencies": [
+      {
+        "code": "EUR",
+        "name": "Euro",
+        "symbol": "€"
+      }
+    ],
+    "alpha2Code": "GR"
+  },
+  {
+    "name": "Germany",
+    "capital": "Berlin",
+    "currencies": [
+      {
+        "code": "EUR",
+        "name": "Euro",
+        "symbol": "€"
+      }
+    ],
+    "alpha2Code": "DE"
+  }
+]

rest-client-reactive-quickstart/pom.xml

@@ -17,6 +17,7 @@
     <quarkus.platform.group-id>io.quarkus</quarkus.platform.group-id>
     <quarkus.platform.version>999-SNAPSHOT</quarkus.platform.version>
     <surefire-plugin.version>3.0.0-M5</surefire-plugin.version>
+    <wiremock.version>2.27.2</wiremock.version>
   </properties>
   <dependencyManagement>
     <dependencies>
@@ -60,6 +61,12 @@
       <artifactId>rest-assured</artifactId>
       <scope>test</scope>
     </dependency>
+    <dependency>
+      <groupId>com.github.tomakehurst</groupId>
+      <artifactId>wiremock-jre8</artifactId>
+      <scope>test</scope>
+      <version>${wiremock.version}</version>
+    </dependency>
   </dependencies>
   <build>
     <plugins>

rest-client-reactive-quickstart/src/main/resources/application.properties

@@ -1 +1,2 @@
+quarkus.tls.trust-all=true
 country-api/mp-rest/url=https://restcountries.eu/rest

rest-client-reactive-quickstart/src/test/java/org/acme/rest/client/CountriesResourceTest.java

@@ -1,12 +1,16 @@
 package org.acme.rest.client;
 
+import io.quarkus.test.common.QuarkusTestResource;
 import io.quarkus.test.junit.QuarkusTest;
+
+import org.acme.rest.client.resources.WireMockCountriesResource;
 import org.junit.jupiter.api.Test;
 
 import static io.restassured.RestAssured.given;
 import static org.hamcrest.CoreMatchers.is;
 
 @QuarkusTest
+@QuarkusTestResource(WireMockCountriesResource.class)
 public class CountriesResourceTest {
 
     @Test

rest-client-reactive-quickstart/src/test/java/org/acme/rest/client/resources/WireMockCountriesResource.java

@@ -0,0 +1,71 @@
+package org.acme.rest.client.resources;
+
+import static com.github.tomakehurst.wiremock.client.WireMock.get;
+import static com.github.tomakehurst.wiremock.client.WireMock.okJson;
+import static com.github.tomakehurst.wiremock.client.WireMock.urlEqualTo;
+import static org.junit.jupiter.api.Assertions.fail;
+
+import java.io.IOException;
+import java.io.InputStream;
+import java.io.StringReader;
+import java.util.Collections;
+import java.util.Map;
+import java.util.Objects;
+
+import javax.json.Json;
+import javax.json.JsonValue;
+import javax.json.stream.JsonParser;
+
+import com.github.tomakehurst.wiremock.WireMockServer;
+
+import io.quarkus.test.common.QuarkusTestResourceLifecycleManager;
+
+public class WireMockCountriesResource implements QuarkusTestResourceLifecycleManager {
+
+    private static final String COUNTRIES_JSON_FILE = "/countries.json";
+    private static final String BASE_PATH = "/rest";
+    private static final int WIREMOCK_PORT = 7777;
+
+    private WireMockServer wireMockServer;
+
+    @Override
+    public Map<String, String> start() {
+        wireMockServer = new WireMockServer(WIREMOCK_PORT);
+        wireMockServer.start();
+        stubCountries();
+        return Collections.singletonMap("org.acme.rest.client.CountriesService/mp-rest/url",
+                wireMockServer.baseUrl() + BASE_PATH);
+    }
+
+    @Override
+    public void stop() {
+        if (Objects.nonNull(wireMockServer))
+            wireMockServer.stop();
+    }
+
+    private void stubCountries() {
+
+        try (InputStream is = WireMockCountriesResource.class.getResourceAsStream(COUNTRIES_JSON_FILE)) {
+            String countries = new String(is.readAllBytes());
+
+            // Stub for full list of countries:
+            wireMockServer.stubFor(get(urlEqualTo(BASE_PATH))
+                    .willReturn(okJson(countries)));
+
+            // Stub for each country
+            try (StringReader sr = new StringReader(countries);
+                    JsonParser parser = Json.createParser(sr)) {
+                parser.next();
+                for (JsonValue country : parser.getArray()) {
+                    String name = country.asJsonObject().getString("name");
+
+                    wireMockServer.stubFor(get(urlEqualTo(BASE_PATH + "/v2/name/" + name))
+                            .willReturn(okJson("[" + country + "]")));
+                }
+            }
+
+        } catch (IOException e) {
+            fail("Could not configure Wiremock server. Caused by: " + e.getMessage());
+        }
+    }
+}

rest-client-reactive-quickstart/src/test/resources/countries.json

@@ -0,0 +1,26 @@
+[
+  {
+    "name": "greece",
+    "capital": "Athens",
+    "currencies": [
+      {
+        "code": "EUR",
+        "name": "Euro",
+        "symbol": "€"
+      }
+    ],
+    "alpha2Code": "GR"
+  },
+  {
+    "name": "Germany",
+    "capital": "Berlin",
+    "currencies": [
+      {
+        "code": "EUR",
+        "name": "Euro",
+        "symbol": "€"
+      }
+    ],
+    "alpha2Code": "DE"
+  }
+]