fix: checking the streaming endpoint now properly handles the stream

Tests are only currently passing due to an Arc exception that stops the
stream after one item. Quarkus 3.24 fixes that issue thus making the
endpoint stream forever leading to the tests never ending.

Author: metacosm

server/pom.xml

@@ -22,6 +22,16 @@
       <artifactId>power-server-metadata</artifactId>
       <version>${project.version}</version>
     </dependency>
+    <dependency>
+      <groupId>org.assertj</groupId>
+      <artifactId>assertj-core</artifactId>
+      <scope>test</scope>
+    </dependency>
+    <dependency>
+      <groupId>io.quarkus</groupId>
+      <artifactId>quarkus-rest-client</artifactId>
+      <scope>test</scope>
+    </dependency>
   </dependencies>
   <build>
     <extensions>

server/src/test/java/net/laprun/sustainability/power/CIPowerResourceTest.java

@@ -1,53 +1,13 @@
 package net.laprun.sustainability.power;
 
-import static io.restassured.RestAssured.given;
-import static org.junit.jupiter.api.Assertions.*;
-
-import java.util.Set;
-
-import org.junit.jupiter.api.Test;
-
 import io.quarkus.test.junit.QuarkusTest;
 import io.quarkus.test.junit.TestProfile;
 
 @QuarkusTest
 @TestProfile(CIQuarkusTestProfile.class) // only activated when quarkus.test.profile.tags='ci', uses @Mock annotated beans
-public class CIPowerResourceTest {
+public class CIPowerResourceTest extends PowerResourceTest {
 
     protected long getPid() {
         return 29419;
     }
-
-    @Test
-    public void testPowerEndpoint() {
-        final var pid = getPid();
-        given()
-                .when().get("/power/" + pid)
-                .then()
-                .statusCode(200);
-    }
-
-    @Test
-    public void testMacOSAppleSiliconMetadataEndpoint() {
-        final var metadata = given()
-                .when().get("/power/metadata")
-                .then()
-                .statusCode(200)
-                .extract().body().as(SensorMetadata.class);
-        assertEquals(4, metadata.componentCardinality());
-        assertTrue(metadata.documentation().contains("powermetrics"));
-        assertTrue(metadata.components().keySet().containsAll(Set.of("CPU", "GPU", "ANE", "cpuShare")));
-
-        final var cpu = metadata.metadataFor("CPU");
-        assertEquals(0, cpu.index());
-        assertEquals("CPU", cpu.name());
-        assertEquals(SensorUnit.mW, cpu.unit());
-        assertTrue(cpu.isAttributed());
-
-        final var cpuShare = metadata.metadataFor("cpuShare");
-        assertEquals(3, cpuShare.index());
-        assertEquals("cpuShare", cpuShare.name());
-        assertEquals(SensorUnit.decimalPercentage, cpuShare.unit());
-        assertFalse(cpuShare.isAttributed());
-    }
 }

server/src/test/java/net/laprun/sustainability/power/PowerResourceTest.java

@@ -3,6 +3,7 @@
 import static io.restassured.RestAssured.given;
 import static org.junit.jupiter.api.Assertions.*;
 
+import java.net.URI;
 import java.time.Duration;
 import java.util.Set;
 
@@ -11,18 +12,19 @@
 import org.junit.jupiter.api.condition.EnabledOnOs;
 import org.junit.jupiter.api.condition.OS;
 
+import io.quarkus.test.common.http.TestHTTPResource;
 import io.quarkus.test.junit.QuarkusTest;
 
 @QuarkusTest
 public class PowerResourceTest {
 
+    @TestHTTPResource
+    URI uri;
+
     @Test
-    public void testPowerEndpoint() {
+    public void testPowerEndpoint() throws Exception {
         final var pid = getPid();
-        given()
-                .when().get("/power/" + pid)
-                .then()
-                .statusCode(200);
+        StreamChecker.checkPowerForPID(uri, pid);
     }
 
     @Test

server/src/test/java/net/laprun/sustainability/power/StreamChecker.java

@@ -0,0 +1,35 @@
+package net.laprun.sustainability.power;
+
+import java.net.URI;
+import java.util.ArrayList;
+import java.util.Collections;
+import java.util.List;
+import java.util.concurrent.CompletableFuture;
+import java.util.concurrent.TimeUnit;
+
+import jakarta.ws.rs.client.ClientBuilder;
+import jakarta.ws.rs.sse.SseEventSource;
+
+import org.assertj.core.api.Assertions;
+
+public class StreamChecker {
+
+    static void checkPowerForPID(URI uri, long pid) throws Exception {
+        final var powerForPid = ClientBuilder.newClient().target(uri.resolve("power"))
+                .path("{pid}").resolveTemplate("pid", pid);
+
+        try (final var eventSource = SseEventSource.target(powerForPid).build()) {
+            CompletableFuture<List<String>> res = new CompletableFuture<>();
+            List<String> collect = Collections.synchronizedList(new ArrayList<>());
+            eventSource.register(inboundSseEvent -> {
+                collect.add(inboundSseEvent.readData());
+                // stop after one event
+                eventSource.close();
+            },
+                    res::completeExceptionally,
+                    () -> res.complete(collect));
+            eventSource.open();
+            Assertions.assertThat(res.get(5, TimeUnit.SECONDS)).hasSize(1);
+        }
+    }
+}