Add test for query params

Signed-off-by: Artur Ciocanu <[email protected]>

Author: Artur Ciocanu

sdk-tests/src/test/java/io/dapr/it/methodinvoke/http/MethodInvokeController.java

@@ -6,6 +6,7 @@
 import org.springframework.web.bind.annotation.PostMapping;
 import org.springframework.web.bind.annotation.PutMapping;
 import org.springframework.web.bind.annotation.RequestBody;
+import org.springframework.web.bind.annotation.RequestParam;
 import org.springframework.web.bind.annotation.RestController;
 
 import java.util.ArrayList;
@@ -80,6 +81,11 @@ public List<Person> getPersons() {
         return persons;
     }
 
+    @GetMapping(path = "/query-params")
+    public String getQueryParams(@RequestParam String uri) {
+        return uri;
+    }
+
     @PostMapping(path = "/sleep")
     public void sleep(@RequestBody int seconds) throws InterruptedException {
         if (seconds < 0) {

sdk-tests/src/test/java/io/dapr/it/methodinvoke/http/MethodInvokeIT.java

@@ -2,6 +2,7 @@
 
 import io.dapr.client.DaprClient;
 import io.dapr.client.DaprClientBuilder;
+import io.dapr.client.DaprHttp;
 import io.dapr.client.domain.HttpExtension;
 import io.dapr.exceptions.DaprException;
 import io.dapr.it.BaseIT;
@@ -14,6 +15,7 @@
 import java.util.Arrays;
 import java.util.Calendar;
 import java.util.Date;
+import java.util.HashMap;
 import java.util.List;
 import java.util.Map;
 
@@ -140,4 +142,20 @@ public void testInvokeException() throws Exception {
             assertTrue(new String(exception.getPayload()).contains("Internal Server Error"));
         }
     }
+
+    @Test
+    public void testInvokeQueryParams() throws Exception {
+        try (DaprClient client = daprRun.newDaprClientBuilder().build()) {
+            client.waitForSidecar(10000).block();
+
+            String uri = "abc/abc/pqr";
+            Map<String, List<String>> queryParams = Map.of("uri", List.of(uri));
+            HttpExtension httpExtension = new HttpExtension(DaprHttp.HttpMethods.GET, queryParams, Map.of());
+            String result = client.invokeMethod(daprRun.getAppName(), "query-params", null,
+                httpExtension, String.class).block();
+
+            assertEquals(uri, result);
+        }
+    }
+
 }