@@ -87,26 +87,30 @@ public final Mono<ExecutionGraphQlResponse> execute(ExecutionGraphQlRequest requ
87
87
if (!this .isDefaultExecutionIdProvider && request .getExecutionId () == null ) {
88
88
request .configureExecutionInput (RESET_EXECUTION_ID_CONFIGURER );
89
89
}
90
+
90
91
ExecutionInput executionInput = request .toExecutionInput ();
91
- ContextSnapshot .captureFrom (contextView ).updateContext (executionInput .getGraphQLContext ());
92
- ExecutionInput updatedExecutionInput = registerDataLoaders (executionInput );
92
+
93
+ GraphQLContext graphQLContext = executionInput .getGraphQLContext ();
94
+ ContextSnapshot .captureFrom (contextView ).updateContext (graphQLContext );
95
+
96
+ ExecutionInput updatedExecutionInput =
97
+ (this .hasDataLoaderRegistrations ? registerDataLoaders (executionInput ) : executionInput );
98
+
93
99
return Mono .fromFuture (this .graphQlSource .graphQl ().executeAsync (updatedExecutionInput ))
94
100
.map (result -> new DefaultExecutionGraphQlResponse (updatedExecutionInput , result ));
95
101
});
96
102
}
97
103
98
104
private ExecutionInput registerDataLoaders (ExecutionInput executionInput ) {
99
- if (this .hasDataLoaderRegistrations ) {
100
- GraphQLContext graphQLContext = executionInput .getGraphQLContext ();
101
- DataLoaderRegistry existingRegistry = executionInput .getDataLoaderRegistry ();
102
- if (existingRegistry == DataLoaderDispatcherInstrumentationState .EMPTY_DATALOADER_REGISTRY ) {
103
- DataLoaderRegistry newRegistry = DataLoaderRegistry .newRegistry ().build ();
104
- applyDataLoaderRegistrars (newRegistry , graphQLContext );
105
- executionInput = executionInput .transform (builder -> builder .dataLoaderRegistry (newRegistry ));
106
- }
107
- else {
108
- applyDataLoaderRegistrars (existingRegistry , graphQLContext );
109
- }
105
+ GraphQLContext graphQLContext = executionInput .getGraphQLContext ();
106
+ DataLoaderRegistry existingRegistry = executionInput .getDataLoaderRegistry ();
107
+ if (existingRegistry == DataLoaderDispatcherInstrumentationState .EMPTY_DATALOADER_REGISTRY ) {
108
+ DataLoaderRegistry newRegistry = DataLoaderRegistry .newRegistry ().build ();
109
+ applyDataLoaderRegistrars (newRegistry , graphQLContext );
110
+ executionInput = executionInput .transform (builder -> builder .dataLoaderRegistry (newRegistry ));
111
+ }
112
+ else {
113
+ applyDataLoaderRegistrars (existingRegistry , graphQLContext );
110
114
}
111
115
return executionInput ;
112
116
}
0 commit comments