39
39
import org .springframework .cloud .dataflow .schema .SchemaVersionTarget ;
40
40
import org .springframework .core .ParameterizedTypeReference ;
41
41
import org .springframework .hateoas .Link ;
42
- import org .springframework .hateoas .PagedModel ;
43
42
import org .springframework .hateoas .RepresentationModel ;
44
43
import org .springframework .http .HttpMethod ;
45
44
import org .springframework .util .Assert ;
@@ -66,8 +65,6 @@ public class TaskTemplate implements TaskOperations {
66
65
67
66
private static final String EXECUTIONS_CURRENT_RELATION_VERSION = "1.7.0" ;
68
67
69
- private static final String VALIDATION_RELATION_VERSION = "1.7.0" ;
70
-
71
68
private static final String VALIDATION_THIN_TASK_VERSION = "2.11.3" ;
72
69
73
70
private static final String VALIDATION_TASK_LAUNCH_VERSION = "2.11.0" ;
@@ -139,29 +136,29 @@ public class TaskTemplate implements TaskOperations {
139
136
EXECUTION_RELATION_BY_NAME ,
140
137
EXECUTIONS_INFO_RELATION ,
141
138
PLATFORM_LIST_RELATION ,
142
- RETRIEVE_LOG
139
+ RETRIEVE_LOG ,
140
+ VALIDATION_REL
143
141
).forEach (relation -> {
144
142
Assert .isTrue (resources .getLink (relation ).isPresent (), () -> relation + " relation is required" );
145
143
});
146
-
147
- this .restTemplate = restTemplate ;
148
144
this .dataFlowServerVersion = dataFlowServerVersion ;
145
+ this .restTemplate = restTemplate ;
146
+
149
147
String version = VersionUtils .getThreePartVersion (dataFlowServerVersion );
150
148
if (VersionUtils .isDataFlowServerVersionGreaterThanOrEqualToRequiredVersion (version , EXECUTIONS_CURRENT_RELATION_VERSION )) {
151
149
Assert .isTrue (resources .getLink (EXECUTIONS_CURRENT_RELATION ).isPresent (), ()-> EXECUTIONS_CURRENT_RELATION + " relation is required" );
152
150
this .executionsCurrentLink = resources .getLink (EXECUTIONS_CURRENT_RELATION ).get ();
153
151
} else {
154
152
this .executionsCurrentLink = null ;
155
153
}
156
- if (VersionUtils .isDataFlowServerVersionGreaterThanOrEqualToRequiredVersion (version , VALIDATION_RELATION_VERSION )) {
157
- Assert .isTrue (resources .getLink (VALIDATION_REL ).isPresent (), ()->VALIDATION_REL + " relation is required" );
158
- this .validationLink = resources .getLink (VALIDATION_REL ).get ();
159
- } else {
160
- this .validationLink = null ;
161
- }
162
154
155
+ this .aboutLink = resources .getLink ("about" ).get ();
163
156
164
- if (VersionUtils .isDataFlowServerVersionGreaterThanOrEqualToRequiredVersion (version , VALIDATION_THIN_TASK_VERSION ) && resources .getLink (THIN_EXECUTIONS_RELATION ).isPresent ()) {
157
+ this .definitionsLink = resources .getLink (DEFINITIONS_RELATION ).get ();
158
+ this .definitionLink = resources .getLink (DEFINITION_RELATION ).get ();
159
+ this .executionsLink = resources .getLink (EXECUTIONS_RELATION ).get ();
160
+ this .executionLink = resources .getLink (EXECUTION_RELATION ).get ();
161
+ if (VersionUtils .isDataFlowServerVersionGreaterThanOrEqualToRequiredVersion (version , VALIDATION_THIN_TASK_VERSION )) {
165
162
Assert .isTrue (resources .getLink (THIN_EXECUTIONS_RELATION ).isPresent (), () -> THIN_EXECUTIONS_RELATION + " relation is required" );
166
163
this .thinExecutionsLink = resources .getLink (THIN_EXECUTIONS_RELATION ).get ();
167
164
} else {
@@ -180,16 +177,10 @@ public class TaskTemplate implements TaskOperations {
180
177
} else {
181
178
this .executionLaunchLink = null ;
182
179
}
183
-
184
-
185
- this .aboutLink = resources .getLink ("about" ).get ();
186
-
187
- this .definitionsLink = resources .getLink (DEFINITIONS_RELATION ).get ();
188
- this .definitionLink = resources .getLink (DEFINITION_RELATION ).get ();
189
- this .executionsLink = resources .getLink (EXECUTIONS_RELATION ).get ();
190
- this .executionLink = resources .getLink (EXECUTION_RELATION ).get ();
191
180
this .executionByNameLink = resources .getLink (EXECUTION_RELATION_BY_NAME ).get ();
192
181
this .executionsInfoLink = resources .getLink (EXECUTIONS_INFO_RELATION ).get ();
182
+
183
+ this .validationLink = resources .getLink (VALIDATION_REL ).get ();
193
184
this .platformListLink = resources .getLink (PLATFORM_LIST_RELATION ).get ();
194
185
this .retrieveLogLink = resources .getLink (RETRIEVE_LOG ).get ();
195
186
}
0 commit comments