|
45 | 45 | import org.springframework.integration.dsl.IntegrationFlow;
|
46 | 46 | import org.springframework.integration.dsl.IntegrationFlows;
|
47 | 47 | import org.springframework.integration.dsl.MessageChannels;
|
48 |
| -import org.springframework.integration.expression.FunctionExpression; |
49 | 48 | import org.springframework.messaging.Message;
|
50 | 49 | import org.springframework.messaging.MessageHandlingException;
|
51 | 50 | import org.springframework.messaging.PollableChannel;
|
@@ -89,7 +88,7 @@ public class GraphQlMessageHandlerTests {
|
89 | 88 |
|
90 | 89 | @Test
|
91 | 90 | @SuppressWarnings("unchecked")
|
92 |
| - void testHandleMessageForQuery() { |
| 91 | + void testHandleMessageForQueryWithRequestInputProvided() { |
93 | 92 |
|
94 | 93 | StepVerifier verifier = StepVerifier.create(
|
95 | 94 | Flux.from(this.resultChannel)
|
@@ -136,50 +135,7 @@ void testHandleMessageForQueryWithQueryProvided() {
|
136 | 135 |
|
137 | 136 | @Test
|
138 | 137 | @SuppressWarnings("unchecked")
|
139 |
| - void testHandleMessageForQueryWithQueryAndOperationProvided() { |
140 |
| - |
141 |
| - String fakeQuery = "query FriendlyName { testQuery { id } }"; |
142 |
| - this.graphQlMessageHandler.setQuery(fakeQuery); |
143 |
| - this.graphQlMessageHandler.setOperationName("FriendlyName"); |
144 |
| - |
145 |
| - StepVerifier.create( |
146 |
| - Mono.from((Mono<ExecutionResult>) this.graphQlMessageHandler.handleRequestMessage(MessageBuilder.withPayload(fakeQuery).build())) |
147 |
| - ) |
148 |
| - .consumeNextWith(result -> { |
149 |
| - assertThat(result).isInstanceOf(ExecutionResultImpl.class); |
150 |
| - Map<String, Object> data = result.getData(); |
151 |
| - Map<String, Object> testQuery = (Map<String, Object>) data.get("testQuery"); |
152 |
| - assertThat(testQuery.get("id")).isEqualTo("test-data"); |
153 |
| - }) |
154 |
| - .expectComplete() |
155 |
| - .verify(); |
156 |
| - } |
157 |
| - |
158 |
| - @Test |
159 |
| - @SuppressWarnings("unchecked") |
160 |
| - void testHandleMessageForQueryWithQueryAndOperationNameAndVariablesProvided() { |
161 |
| - |
162 |
| - String fakeQuery = "query FriendlyName($id: String) { testQueryById(id: $id) { id } }"; |
163 |
| - this.graphQlMessageHandler.setQuery(fakeQuery); |
164 |
| - this.graphQlMessageHandler.setOperationName("FriendlyName"); |
165 |
| - this.graphQlMessageHandler.setVariablesExpression(new FunctionExpression<>(m -> Map.of("$id", "test-data"))); |
166 |
| - |
167 |
| - StepVerifier.create( |
168 |
| - Mono.from((Mono<ExecutionResult>) this.graphQlMessageHandler.handleRequestMessage(MessageBuilder.withPayload(fakeQuery).build())) |
169 |
| - ) |
170 |
| - .consumeNextWith(result -> { |
171 |
| - assertThat(result).isInstanceOf(ExecutionResultImpl.class); |
172 |
| - Map<String, Object> data = result.getData(); |
173 |
| - Map<String, Object> testQuery = (Map<String, Object>) data.get("testQueryById"); |
174 |
| - assertThat(testQuery.get("id")).isEqualTo("test-data"); |
175 |
| - }) |
176 |
| - .expectComplete() |
177 |
| - .verify(); |
178 |
| - } |
179 |
| - |
180 |
| - @Test |
181 |
| - @SuppressWarnings("unchecked") |
182 |
| - void testHandleMessageForMutation() { |
| 138 | + void testHandleMessageForMutationWithRequestInputProvided() { |
183 | 139 |
|
184 | 140 | String fakeId = UUID.randomUUID().toString();
|
185 | 141 | Update expected = new Update(fakeId);
|
@@ -218,7 +174,7 @@ void testHandleMessageForMutation() {
|
218 | 174 |
|
219 | 175 | @Test
|
220 | 176 | @SuppressWarnings("unchecked")
|
221 |
| - void testHandleMessageForSubscription() { |
| 177 | + void testHandleMessageForSubscriptionWithRequestInputProvided() { |
222 | 178 |
|
223 | 179 | StepVerifier verifier = StepVerifier.create(
|
224 | 180 | Flux.from(this.resultChannel)
|
|
0 commit comments