Integrate Spring Graphql with DGS Framework

graphql-dgs-example-java/src/test/java/RequestHeaderDataFetcherTest.java

@@ -44,7 +44,7 @@ void withHeaders() {
         MockHttpServletRequest servletRequest = new MockHttpServletRequest();
         servletRequest.addHeader("demo-header", "demo-header-value");
 
-        String message = queryExecutor.executeAndExtractJsonPath("{headers}", "data.headers", new ServletWebRequest(servletRequest));
+        String message = queryExecutor.executeAndExtractJsonPath("{demoHeader}", "data.demoHeader", new ServletWebRequest(servletRequest));
         assertThat(message).isEqualTo("demo-header-value");
     }
 
@@ -53,7 +53,7 @@ void withHeadersAndNoRequest() {
         HttpHeaders headers = new HttpHeaders();
         headers.add("demo-header", "demo-header-value");
 
-        String message = queryExecutor.executeAndExtractJsonPath("{headers}", "data.headers", headers);
+        String message = queryExecutor.executeAndExtractJsonPath("{demoHeader}", "data.demoHeader", headers);
         assertThat(message).isEqualTo("demo-header-value");
     }
 }

graphql-dgs-example-shared/src/main/java/com/netflix/graphql/dgs/example/shared/datafetcher/HelloDataFetcher.java

@@ -25,8 +25,6 @@
 import graphql.relay.SimpleListConnection;
 import graphql.schema.DataFetchingEnvironment;
 import org.dataloader.DataLoader;
-import org.springframework.http.HttpHeaders;
-import org.springframework.web.bind.annotation.RequestHeader;
 
 import java.util.ArrayList;
 import java.util.Collections;

graphql-dgs-example-shared/src/main/java/com/netflix/graphql/dgs/example/shared/datafetcher/RequestHeadersDataFetcher.java

@@ -28,7 +28,14 @@
 
 @DgsComponent
 public class RequestHeadersDataFetcher {
+
     @DgsData(parentType = "Query", field = "headers")
+    public String headers(DgsDataFetchingEnvironment dfe) {
+        HttpHeaders headers = dfe.getDgsContext().getRequestData().getHeaders();
+        return headers.toString();
+    }
+
+    @DgsData(parentType = "Query", field = "demoHeader")
     public String headers(DgsDataFetchingEnvironment dfe, @RequestHeader("demo-header") String demoHeader) {
         return demoHeader;
     }

graphql-dgs-example-shared/src/main/resources/schema/schema.graphqls

@@ -25,6 +25,7 @@ type Query {
 
     headers: String
     referer: String
+    demoHeader: String
 
     ### To show how to handle HttpHeaders
     helloWithHeaders(name: String): String
@@ -95,3 +96,5 @@ type Stock {
 scalar Upload
 scalar LocalTime
 
+directive @connection on OBJECT
+

graphql-dgs-pagination/src/main/kotlin/com/netflix/graphql/dgs/pagination/DgsPaginationEnvironmentPostProcessor.kt

@@ -0,0 +1,35 @@
+/*
+ * Copyright 2024 Netflix, Inc.
+ *
+ * Licensed under the Apache License, Version 2.0 (the "License");
+ * you may not use this file except in compliance with the License.
+ * You may obtain a copy of the License at
+ *
+ *    http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
+
+package com.netflix.graphql.dgs.pagination
+
+import org.springframework.boot.SpringApplication
+import org.springframework.boot.env.EnvironmentPostProcessor
+import org.springframework.core.env.ConfigurableEnvironment
+import org.springframework.core.env.MapPropertySource
+
+class DgsPaginationEnvironmentPostProcessor : EnvironmentPostProcessor {
+    override fun postProcessEnvironment(environment: ConfigurableEnvironment, application: SpringApplication) {
+        val properties = mutableMapOf<String, Any>()
+        properties["dgs.springgraphql.pagination.enabled"] = false
+        environment.propertySources.addLast(
+            MapPropertySource(
+                "dgs-pagination-defaults",
+                properties
+            )
+        )
+    }
+}

graphql-dgs-pagination/src/main/resources/META-INF/spring.factories

@@ -0,0 +1 @@
+org.springframework.boot.env.EnvironmentPostProcessor=com.netflix.graphql.dgs.pagination.DgsPaginationEnvironmentPostProcessor

graphql-dgs-reactive/build.gradle.kts

@@ -16,8 +16,9 @@
 
 dependencies {
     api(project(":graphql-dgs"))
-    implementation("org.springframework.boot:spring-boot-starter")
-    implementation("org.springframework:spring-webflux")
+    compileOnly("org.springframework.boot:spring-boot-starter")
+    compileOnly("org.springframework:spring-webflux")
+
     implementation("com.fasterxml.jackson.module:jackson-module-kotlin")
     implementation("org.jetbrains.kotlinx:kotlinx-coroutines-core")
     implementation("io.projectreactor.kotlin:reactor-kotlin-extensions")

graphql-dgs-spring-boot-oss-autoconfigure/src/main/kotlin/com/netflix/graphql/dgs/autoconfig/DgsAutoConfiguration.kt

@@ -101,6 +101,7 @@ open class DgsAutoConfiguration(
     }
 
     @Bean
+    @ConditionalOnMissingBean
     open fun dgsQueryExecutor(
         applicationContext: ApplicationContext,
         schema: GraphQLSchema,

graphql-dgs-spring-graphql-example-java-webflux/.gitignore

@@ -0,0 +1,42 @@
+.gradle
+build/
+!gradle/wrapper/gradle-wrapper.jar
+!**/src/main/**/build/
+!**/src/test/**/build/
+
+### IntelliJ IDEA ###
+.idea/modules.xml
+.idea/jarRepositories.xml
+.idea/compiler.xml
+.idea/libraries/
+*.iws
+*.iml
+*.ipr
+out/
+!**/src/main/**/out/
+!**/src/test/**/out/
+
+### Eclipse ###
+.apt_generated
+.classpath
+.factorypath
+.project
+.settings
+.springBeans
+.sts4-cache
+bin/
+!**/src/main/**/bin/
+!**/src/test/**/bin/
+
+### NetBeans ###
+/nbproject/private/
+/nbbuild/
+/dist/
+/nbdist/
+/.nb-gradle/
+
+### VS Code ###
+.vscode/
+
+### Mac OS ###
+.DS_Store

graphql-dgs-spring-graphql-example-java-webflux/README.md

@@ -0,0 +1,8 @@
+This example app demonstrates some DGS framework features.
+It also includes a very simple React UI that uses Apollo Client that connects to both the /graphql and /subscriptions endpoints.
+Start the app by running the `ExampleApp` class (e.g. from an IDE).
+
+* Graphiql will be available on: http://localhost:8080/graphiql
+* The example UI will be available on: http://localhost:8080/index.html
+
+The example project includes a number of tests as well.

graphql-dgs-spring-graphql-example-java-webflux/build.gradle.kts

@@ -0,0 +1,31 @@
+/*
+ * Copyright 2021 Netflix, Inc.
+ *
+ * Licensed under the Apache License, Version 2.0 (the "License");
+ * you may not use this file except in compliance with the License.
+ * You may obtain a copy of the License at
+ *
+ *    http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
+
+dependencies {
+
+    implementation(project(":graphql-dgs-example-shared"))
+    implementation(project(":graphql-dgs-pagination"))
+    implementation(project(":graphql-dgs-reactive"))
+    implementation("org.springframework.boot:spring-boot-starter-webflux")
+    implementation(project(":graphql-dgs-spring-graphql-starter"))
+    implementation("org.springframework.boot:spring-boot-starter-actuator")
+    implementation(project(":graphql-dgs-spring-boot-micrometer"))
+    implementation("com.github.ben-manes.caffeine:caffeine")
+
+    testImplementation("org.springframework.boot:spring-boot-starter-webflux")
+    testImplementation(project(":graphql-dgs-client"))
+    testImplementation("io.projectreactor:reactor-test")
+}