Redis dev mode test

Author: ozangunalp

integration-tests/redis-devservices/pom.xml

@@ -15,6 +15,10 @@
             <groupId>io.quarkus</groupId>
             <artifactId>quarkus-redis-client</artifactId>
         </dependency>
+        <dependency>
+            <groupId>io.quarkus</groupId>
+            <artifactId>quarkus-rest-jackson</artifactId>
+        </dependency>
         <dependency>
             <groupId>io.quarkus</groupId>
             <artifactId>quarkus-arc</artifactId>
@@ -34,6 +38,11 @@
             <artifactId>quarkus-junit5-internal</artifactId>
             <scope>test</scope>
         </dependency>
+        <dependency>
+            <groupId>io.rest-assured</groupId>
+            <artifactId>rest-assured</artifactId>
+            <scope>test</scope>
+        </dependency>
         <!-- Minimal test dependencies to *-deployment artifacts for consistent build order -->
         <dependency>
             <groupId>io.quarkus</groupId>
@@ -61,6 +70,19 @@
                 </exclusion>
             </exclusions>
         </dependency>
+        <dependency>
+            <groupId>io.quarkus</groupId>
+            <artifactId>quarkus-rest-jackson-deployment</artifactId>
+            <version>${project.version}</version>
+            <type>pom</type>
+            <scope>test</scope>
+            <exclusions>
+                <exclusion>
+                    <groupId>*</groupId>
+                    <artifactId>*</artifactId>
+                </exclusion>
+            </exclusions>
+        </dependency>
     </dependencies>
 
     <build>

integration-tests/redis-devservices/src/main/java/io/quarkus/test/devservices/redis/TestResource.java

@@ -0,0 +1,34 @@
+package io.quarkus.test.devservices.redis;
+
+import jakarta.inject.Inject;
+import jakarta.ws.rs.GET;
+import jakarta.ws.rs.Path;
+import jakarta.ws.rs.PathParam;
+
+import io.quarkus.redis.datasource.RedisDataSource;
+
+@Path("/")
+public class TestResource {
+
+    @Inject
+    RedisDataSource redis;
+
+    @GET
+    @Path("/ping")
+    public String ping() {
+        return redis.execute("ping").toString();
+    }
+
+    @GET
+    @Path("/set/{key}/{value}")
+    public String set(@PathParam("key") String key, @PathParam("value") String value) {
+        redis.value(String.class).set(key, value);
+        return "OK";
+    }
+
+    @GET
+    @Path("/get/{key}")
+    public String get(@PathParam("key") String key) {
+        return redis.value(String.class).get(key);
+    }
+}

integration-tests/redis-devservices/src/test/java/io/quarkus/redis/devservices/continuoustesting/it/DevServicesRedisContinuousTestingTest.java

@@ -1,6 +1,9 @@
 package io.quarkus.redis.devservices.continuoustesting.it;
 
+import static io.restassured.RestAssured.when;
+import static org.hamcrest.Matchers.is;
 import static org.junit.jupiter.api.Assertions.assertEquals;
+import static org.junit.jupiter.api.Assertions.assertFalse;
 import static org.junit.jupiter.api.Assertions.assertTrue;
 
 import java.util.ArrayList;
@@ -22,6 +25,7 @@
 import io.quarkus.redis.devservices.it.PlainQuarkusTest;
 import io.quarkus.test.ContinuousTestingTestUtils;
 import io.quarkus.test.QuarkusDevModeTest;
+import io.quarkus.test.devservices.redis.TestResource;
 
 public class DevServicesRedisContinuousTestingTest {
 
@@ -37,7 +41,7 @@ public class DevServicesRedisContinuousTestingTest {
     @RegisterExtension
     public static QuarkusDevModeTest test = new QuarkusDevModeTest()
             .setArchiveProducer(() -> ShrinkWrap.create(JavaArchive.class)
-                    .addClasses()
+                    .addClasses(TestResource.class)
                     .addAsResource(new StringAsset(ContinuousTestingTestUtils.appProperties("")),
                             "application.properties"))
             .setTestArchiveProducer(() -> ShrinkWrap.create(JavaArchive.class).addClass(PlainQuarkusTest.class));
@@ -59,6 +63,33 @@ public void testContinuousTestingDisablesDevServicesWhenPropertiesChange() {
         // We could check the container goes away, but we'd have to check slowly, because ryuk can be slow
     }
 
+    @Test
+    public void testDevModeServiceConfigRefresh() {
+        List<Container> started = getRedisContainers();
+        ping();
+
+        assertFalse(started.isEmpty());
+        Container container = started.get(0);
+        assertTrue(Arrays.stream(container.getPorts()).noneMatch(p -> p.getPublicPort() == 6377),
+                "Expected random port 6377, but got: " + Arrays.toString(container.getPorts()));
+
+        test.modifyResourceFile("application.properties",
+                s -> ContinuousTestingTestUtils.appProperties("quarkus.redis.devservices.port=6377"));
+
+        ping();
+        List<Container> newContainers = getRedisContainersExcludingExisting(started);
+        assertEquals(1, newContainers.size()); // this can be wrong
+        Container newContainer = newContainers.get(0);
+        assertTrue(Arrays.stream(newContainer.getPorts()).anyMatch(p -> p.getPublicPort() == 6377),
+                "Expected port 6377, but got: " + Arrays.toString(newContainer.getPorts()));
+    }
+
+    void ping() {
+        when().get("/ping").then()
+                .statusCode(200)
+                .body(is("PONG"));
+    }
+
     @Test
     public void testContinuousTestingReusesInstanceWhenPropertiesAreNotChanged() {