Added WS gateway tests

scalecube · Dec 21, 2024 · db09b49 · db09b49
1 parent 3607c01
commit db09b49
Show file tree

Hide file tree

Showing 2 changed files with 26 additions and 0 deletions.
diff --git a/...s-gateway/src/test/java/io/scalecube/services/gateway/websocket/WebsocketGatewayTest.java b/...s-gateway/src/test/java/io/scalecube/services/gateway/websocket/WebsocketGatewayTest.java
@@ -1,6 +1,7 @@
 package io.scalecube.services.gateway.websocket;
 
 import static io.scalecube.services.gateway.GatewayErrorMapperImpl.ERROR_MAPPER;
+import static org.junit.jupiter.api.Assertions.assertEquals;
 
 import io.scalecube.services.Address;
 import io.scalecube.services.Microservices;
@@ -241,4 +242,16 @@ void shouldHeartbeat() {
         .assertNext(pongValue -> Assertions.assertEquals(value, pongValue))
         .verifyComplete();
   }
+
+  @Test
+  void shouldWorkWithDynamicQualifier() {
+    final var value = "12345";
+    final var data = System.currentTimeMillis();
+    final var request =
+        ServiceMessage.builder().qualifier("greeting/hello/" + value).data(data).build();
+
+    StepVerifier.create(serviceCall.requestOne(request, String.class).map(ServiceMessage::data))
+        .assertNext(result -> assertEquals(value + "@" + data, result))
+        .verifyComplete();
+  }
 }
diff --git a/...eway/src/test/java/io/scalecube/services/gateway/websocket/WebsocketLocalGatewayTest.java b/...eway/src/test/java/io/scalecube/services/gateway/websocket/WebsocketLocalGatewayTest.java
@@ -1,6 +1,7 @@
 package io.scalecube.services.gateway.websocket;
 
 import static io.scalecube.services.gateway.GatewayErrorMapperImpl.ERROR_MAPPER;
+import static org.junit.jupiter.api.Assertions.assertEquals;
 
 import io.scalecube.services.Address;
 import io.scalecube.services.Microservices;
@@ -212,4 +213,16 @@ void shouldReturnSomeExceptionOnFlux() {
   void shouldReturnSomeExceptionOnMono() {
     StepVerifier.create(errorService.oneError()).expectError(SomeException.class).verify(TIMEOUT);
   }
+
+  @Test
+  void shouldWorkWithDynamicQualifier() {
+    final var value = "12345";
+    final var data = System.currentTimeMillis();
+    final var request =
+        ServiceMessage.builder().qualifier("greeting/hello/" + value).data(data).build();
+
+    StepVerifier.create(serviceCall.requestOne(request, String.class).map(ServiceMessage::data))
+        .assertNext(result -> assertEquals(value + "@" + data, result))
+        .verifyComplete();
+  }
 }