Skip to content
This repository was archived by the owner on May 20, 2025. It is now read-only.

Commit 67c4a24

Browse files
author
Corneil du Plessis
committed
[AT] Added checkEndpoints to ensure new endpoints are accessible.
1 parent 505982b commit 67c4a24

File tree

1 file changed

+16
-0
lines changed
  • src/test/java/org/springframework/cloud/dataflow/acceptance/test

1 file changed

+16
-0
lines changed

src/test/java/org/springframework/cloud/dataflow/acceptance/test/DataFlowAT.java

Lines changed: 16 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -76,6 +76,7 @@
7676
import org.springframework.cloud.dataflow.rest.client.dsl.StreamDefinition;
7777
import org.springframework.cloud.dataflow.rest.client.dsl.task.Task;
7878
import org.springframework.cloud.dataflow.rest.client.dsl.task.TaskBuilder;
79+
import org.springframework.cloud.dataflow.rest.client.support.VersionUtils;
7980
import org.springframework.cloud.dataflow.rest.resource.DetailedAppRegistrationResource;
8081
import org.springframework.cloud.dataflow.rest.resource.JobExecutionThinResource;
8182
import org.springframework.cloud.dataflow.rest.resource.LaunchResponseResource;
@@ -3673,6 +3674,21 @@ public void streamWithConfigServer() {
36733674
}
36743675
}
36753676

3677+
@Test
3678+
@Tag("smoke")
3679+
void checkEndpoints() {
3680+
AboutResource aboutResource = dataFlowOperations.aboutOperation().get();
3681+
assertThat(aboutResource).isNotNull();
3682+
logger.info("authenticated:{}", aboutResource.getSecurityInfo().isAuthenticated());
3683+
logger.info("testing:tasks/executions");
3684+
assertThat(dataFlowOperations.taskOperations().executionList()).isNotNull();
3685+
String version = aboutResource.getVersionInfo().getCore().getVersion();
3686+
if (VersionUtils.isDataFlowServerVersionGreaterThanOrEqualToRequiredVersion(VersionUtils.getThreePartVersion(version), "2.11.3")) {
3687+
logger.info("testing:tasks/thinexecutions");
3688+
assertThat(dataFlowOperations.taskOperations().thinExecutionList()).isNotNull();
3689+
}
3690+
// TODO add new endpoints
3691+
}
36763692
@Test
36773693
@Tag("groupF")
36783694
void willFail() {

0 commit comments

Comments
 (0)