Increase coverage webflux starter

Author: oliemansm

graphql-kickstart-spring-boot-autoconfigure-webflux/build.gradle

@@ -5,4 +5,7 @@ dependencies {
     implementation "org.springframework.boot:spring-boot-autoconfigure"
     implementation "com.graphql-java-kickstart:graphql-java-kickstart:$LIB_GRAPHQL_SERVLET_VER"
     implementation "org.springframework.boot:spring-boot-starter-webflux"
+
+    testImplementation "org.springframework.boot:spring-boot-starter-test"
+    testImplementation(project(":graphql-kickstart-spring-boot-starter-tools"))
 }

graphql-kickstart-spring-boot-autoconfigure-webflux/src/main/java/graphql/kickstart/spring/webflux/boot/GraphQLSpringWebfluxAutoConfiguration.java

@@ -1,6 +1,7 @@
 package graphql.kickstart.spring.webflux.boot;
 
 import static graphql.kickstart.execution.GraphQLObjectMapper.newBuilder;
+import static org.springframework.boot.autoconfigure.condition.ConditionalOnWebApplication.Type.REACTIVE;
 
 import graphql.execution.instrumentation.dataloader.DataLoaderDispatcherInstrumentationOptions;
 import graphql.kickstart.execution.BatchedDataLoaderGraphQLBuilder;
@@ -39,6 +40,7 @@
 import org.springframework.boot.autoconfigure.AutoConfigureAfter;
 import org.springframework.boot.autoconfigure.condition.ConditionalOnBean;
 import org.springframework.boot.autoconfigure.condition.ConditionalOnMissingBean;
+import org.springframework.boot.autoconfigure.condition.ConditionalOnWebApplication;
 import org.springframework.context.annotation.Bean;
 import org.springframework.context.annotation.Configuration;
 import org.springframework.context.annotation.Import;
@@ -50,6 +52,7 @@
 @SuppressWarnings("SpringJavaInjectionPointsAutowiringInspection")
 @Slf4j
 @Configuration
+@ConditionalOnWebApplication(type = REACTIVE)
 @ConditionalOnBean(GraphQLSchema.class)
 @AutoConfigureAfter(GraphQLJavaToolsAutoConfiguration.class)
 @Import({GraphQLController.class, ReactiveWebSocketSubscriptionsHandler.class})

graphql-kickstart-spring-boot-autoconfigure-webflux/src/main/java/graphql/kickstart/spring/webflux/boot/MonoAutoConfiguration.java

@@ -1,18 +1,22 @@
 package graphql.kickstart.spring.webflux.boot;
 
+import static org.springframework.boot.autoconfigure.condition.ConditionalOnWebApplication.Type.REACTIVE;
+
 import graphql.kickstart.tools.SchemaParser;
 import graphql.kickstart.tools.SchemaParserOptions.GenericWrapper;
 import graphql.kickstart.tools.boot.GraphQLJavaToolsAutoConfiguration;
 import java.util.List;
 import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.boot.autoconfigure.AutoConfigureBefore;
 import org.springframework.boot.autoconfigure.condition.ConditionalOnClass;
+import org.springframework.boot.autoconfigure.condition.ConditionalOnWebApplication;
 import org.springframework.context.annotation.Bean;
 import org.springframework.context.annotation.Configuration;
 import reactor.core.publisher.Mono;
 
 @Configuration
 @ConditionalOnClass(SchemaParser.class)
+@ConditionalOnWebApplication(type = REACTIVE)
 @AutoConfigureBefore(GraphQLJavaToolsAutoConfiguration.class)
 public class MonoAutoConfiguration {
 

graphql-kickstart-spring-boot-autoconfigure-webflux/src/test/java/graphql/kickstart/spring/webflux/boot/HelloQuery.java

@@ -0,0 +1,14 @@
+package graphql.kickstart.spring.webflux.boot;
+
+import graphql.kickstart.tools.GraphQLQueryResolver;
+import org.springframework.stereotype.Component;
+import reactor.core.publisher.Mono;
+
+@Component
+class HelloQuery implements GraphQLQueryResolver {
+
+  public Mono<String> hello() {
+    return Mono.just("Hello world");
+  }
+
+}

graphql-kickstart-spring-boot-autoconfigure-webflux/src/test/java/graphql/kickstart/spring/webflux/boot/MonoAutoConfigurationTest.java

@@ -0,0 +1,37 @@
+package graphql.kickstart.spring.webflux.boot;
+
+import static org.assertj.core.api.Assertions.assertThat;
+
+import java.io.IOException;
+import lombok.RequiredArgsConstructor;
+import lombok.val;
+import org.junit.jupiter.api.Test;
+import org.junit.jupiter.api.extension.ExtendWith;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.boot.test.context.SpringBootTest;
+import org.springframework.http.MediaType;
+import org.springframework.test.context.junit.jupiter.SpringExtension;
+import org.springframework.test.web.reactive.server.WebTestClient;
+
+@SuppressWarnings("ALL")
+@RequiredArgsConstructor
+@ExtendWith(SpringExtension.class)
+@SpringBootTest(webEnvironment = SpringBootTest.WebEnvironment.RANDOM_PORT)
+class MonoAutoConfigurationTest {
+
+  @Autowired
+  private WebTestClient webTestClient;
+
+  @Test
+  void monoWrapper() throws IOException {
+    val result = webTestClient.post()
+        .uri("/graphql")
+        .contentType(MediaType.APPLICATION_JSON)
+        .bodyValue("{ \"query\": \"query { hello } \"}")
+        .exchange()
+        .returnResult(String.class);
+    val response = result.getResponseBody().blockFirst();
+    assertThat(response).isEqualTo("{\"data\":{\"hello\":\"Hello world\"}}");
+  }
+
+}

graphql-kickstart-spring-boot-autoconfigure-webflux/src/test/java/graphql/kickstart/spring/webflux/boot/MySubscriptionResolver.java

@@ -0,0 +1,17 @@
+package graphql.kickstart.spring.webflux.boot;
+
+import graphql.kickstart.tools.GraphQLSubscriptionResolver;
+import graphql.schema.DataFetchingEnvironment;
+import java.time.Duration;
+import org.reactivestreams.Publisher;
+import org.springframework.stereotype.Service;
+import reactor.core.publisher.Flux;
+
+@Service
+class MySubscriptionResolver implements GraphQLSubscriptionResolver {
+
+  Publisher<Integer> hello(DataFetchingEnvironment env) {
+    return Flux.range(0, 100).delayElements(Duration.ofSeconds(1));
+  }
+
+}

graphql-kickstart-spring-boot-autoconfigure-webflux/src/test/java/graphql/kickstart/spring/webflux/boot/WebfluxApplication.java

@@ -0,0 +1,13 @@
+package graphql.kickstart.spring.webflux.boot;
+
+import org.springframework.boot.SpringApplication;
+import org.springframework.boot.autoconfigure.SpringBootApplication;
+
+@SpringBootApplication
+public class WebfluxApplication {
+
+  public static void main(String[] args) {
+    SpringApplication.run(WebfluxApplication.class, args);
+  }
+
+}

graphql-kickstart-spring-boot-autoconfigure-webflux/src/test/resources/query-hello-world.graphql

@@ -0,0 +1,3 @@
+query {
+    hello
+}

graphql-kickstart-spring-boot-autoconfigure-webflux/src/test/resources/schema.graphqls

@@ -0,0 +1,7 @@
+type Query {
+    hello: String
+}
+
+type Subscription {
+    hello: Int
+}

graphql-spring-boot-autoconfigure/src/main/java/graphql/kickstart/spring/web/boot/GraphQLWebAutoConfiguration.java

@@ -72,6 +72,7 @@
 import org.springframework.boot.autoconfigure.condition.ConditionalOnMissingBean;
 import org.springframework.boot.autoconfigure.condition.ConditionalOnProperty;
 import org.springframework.boot.autoconfigure.condition.ConditionalOnWebApplication;
+import org.springframework.boot.autoconfigure.condition.ConditionalOnWebApplication.Type;
 import org.springframework.boot.autoconfigure.jackson.JacksonAutoConfiguration;
 import org.springframework.boot.context.properties.ConfigurationProperties;
 import org.springframework.boot.context.properties.EnableConfigurationProperties;
@@ -92,7 +93,7 @@
 @Slf4j
 @Configuration
 @RequiredArgsConstructor
-@ConditionalOnWebApplication
+@ConditionalOnWebApplication(type = Type.SERVLET)
 @ConditionalOnClass(DispatcherServlet.class)
 @Conditional(OnSchemaOrSchemaProviderBean.class)
 @SuppressWarnings("SpringJavaInjectionPointsAutowiringInspection")