testing

Author: andimarek

graphql-java-spring-boot-starter-webflux/build.gradle

@@ -1,9 +1,11 @@
-
 version = "1.0"
 
 def springBootVersion = "2.1.0.RELEASE"
 
 dependencies {
     compile "org.springframework.boot:spring-boot-autoconfigure:$springBootVersion"
     compile project(':graphql-java-spring-webflux')
+
+    testImplementation("org.springframework.boot:spring-boot-starter-webflux:$springBootVersion")
+    testImplementation("org.springframework.boot:spring-boot-starter-test:$springBootVersion")
 }

graphql-java-spring-boot-starter-webflux/src/test/java/graphql/spring/web/reactive/IntegrationTest.java

@@ -0,0 +1,47 @@
+package graphql.spring.web.reactive;
+
+import graphql.ExecutionInput;
+import graphql.ExecutionResultImpl;
+import graphql.GraphQL;
+import org.junit.Test;
+import org.junit.runner.RunWith;
+import org.mockito.ArgumentCaptor;
+import org.mockito.Mockito;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.boot.test.context.SpringBootTest;
+import org.springframework.test.context.junit4.SpringRunner;
+import org.springframework.test.web.reactive.server.WebTestClient;
+
+import java.util.concurrent.CompletableFuture;
+
+import static org.hamcrest.CoreMatchers.is;
+import static org.junit.Assert.assertThat;
+
+@SpringBootTest(webEnvironment = SpringBootTest.WebEnvironment.RANDOM_PORT, classes = IntegrationTestConfig.class)
+@RunWith(SpringRunner.class)
+public class IntegrationTest {
+
+    @Autowired
+    private WebTestClient webClient;
+
+    @Autowired
+    GraphQL graphql;
+
+    @Test
+    public void endpointIsAvailable() {
+        String query = "{foo}";
+
+        ExecutionResultImpl executionResult = ExecutionResultImpl.newExecutionResult()
+                .data("bar")
+                .build();
+        CompletableFuture cf = CompletableFuture.completedFuture(executionResult);
+        ArgumentCaptor<ExecutionInput> captor = ArgumentCaptor.forClass(ExecutionInput.class);
+        Mockito.when(graphql.executeAsync(captor.capture())).thenReturn(cf);
+
+        this.webClient.get().uri("/graphql?query={query}", query).exchange().expectStatus().isOk()
+                .expectBody(String.class).isEqualTo("{\"data\":\"bar\"}");
+
+        assertThat(captor.getValue().getQuery(), is(query));
+    }
+
+}

graphql-java-spring-boot-starter-webflux/src/test/java/graphql/spring/web/reactive/IntegrationTestConfig.java

@@ -0,0 +1,18 @@
+package graphql.spring.web.reactive;
+
+import graphql.GraphQL;
+import org.mockito.Mockito;
+import org.springframework.boot.autoconfigure.SpringBootApplication;
+import org.springframework.context.annotation.Bean;
+
+@SpringBootApplication
+public class IntegrationTestConfig {
+
+
+    @Bean
+    public GraphQL graphQL() {
+        return Mockito.mock(GraphQL.class);
+    }
+
+}
+

graphql-java-spring-webflux/src/main/java/graphql/spring/web/reactive/components/GraphQLController.java

@@ -18,6 +18,7 @@
 import reactor.core.publisher.Mono;
 
 import java.io.IOException;
+import java.util.Collections;
 import java.util.Map;
 
 @RestController
@@ -61,6 +62,7 @@ public Object graphqlGET(
     }
 
     private Map<String, Object> convertVariablesJson(String jsonMap) {
+        if (jsonMap == null) return Collections.emptyMap();
         try {
             return objectMapper.readValue(jsonMap, Map.class);
         } catch (IOException e) {

graphql-java-spring-webflux/src/test/java/graphql/spring/web/reactive/components/GraphQLControllerTest.java

@@ -111,4 +111,30 @@ public void testGetRequest() throws Exception {
         assertThat(captor.getValue().getVariables(), is(variables));
         assertThat(captor.getValue().getOperationName(), is(operationName));
     }
+
+    @Test
+    public void testSimpleGetRequest() throws Exception {
+        String query = "{foo}";
+        String queryString = URLEncoder.encode(query, "UTF-8");
+
+        ExecutionResultImpl executionResult = ExecutionResultImpl.newExecutionResult()
+                .data("bar")
+                .build();
+        CompletableFuture cf = CompletableFuture.completedFuture(executionResult);
+        ArgumentCaptor<ExecutionInput> captor = ArgumentCaptor.forClass(ExecutionInput.class);
+        Mockito.when(graphql.executeAsync(captor.capture())).thenReturn(cf);
+
+        client.get().uri(uriBuilder -> uriBuilder.path("/graphql")
+                .queryParam("query", queryString)
+                .build())
+                .accept(MediaType.APPLICATION_JSON_UTF8)
+                .exchange()
+                .expectStatus().isOk()
+                .expectBody()
+                .jsonPath("data").isEqualTo("bar");
+
+        assertThat(captor.getAllValues().size(), is(1));
+        assertThat(captor.getValue().getQuery(), is(query));
+    }
+
 }