import java.util.List;
import org.onap.portalsdk.core.controller.RestrictedBaseController;
import org.onap.vid.model.SOWorkflow;
+import org.onap.vid.model.SOWorkflowParameterDefinitions;
import org.onap.vid.services.ExtWorkflowsService;
import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.web.bind.annotation.PathVariable;
import org.springframework.web.bind.annotation.RequestMapping;
import org.springframework.web.bind.annotation.RequestMethod;
import org.springframework.web.bind.annotation.RequestParam;
return extWorkflowsService.getWorkflows(vnfName);
}
+ @RequestMapping(value = "workflow-parameters/{id}", method = RequestMethod.GET)
+ SOWorkflowParameterDefinitions getParameters(@PathVariable Long id) {
+ return extWorkflowsService.getWorkflowParameterDefinitions(id);
+ }
+
}
fun clone(): SOWorkflows {
return copy(workflows?.toMutableList())
}
-}
\ No newline at end of file
+}
+
+
+enum class SOWorkflowType(var type: String? = "STRING") {
+ STRING("STRING")
+}
+
+data class SOWorkflowParameterDefinition(var id: Long? = null, var name: String? = null, var pattern: String? = null, var type: SOWorkflowType? = null, val required: Boolean? = null)
+data class SOWorkflowParameterDefinitions(var parameterDefinitions: List<SOWorkflowParameterDefinition>? = null)
\ No newline at end of file
import java.util.Collections;
import org.jetbrains.annotations.NotNull;
import org.onap.vid.client.SyncRestClient;
+import org.onap.vid.model.SOWorkflowParameterDefinitions;
import org.onap.vid.model.SOWorkflows;
import org.onap.vid.mso.MsoResponseWrapper2;
SOWorkflows.class));
}
+ public MsoResponseWrapper2<SOWorkflowParameterDefinitions> getWorkflowParameterDefinitions(Long workflowId) {
+ return new MsoResponseWrapper2<>(syncRestClient
+ .get((workflowId <= 3 && workflowId > 0) ? getParametersUrl(workflowId) : getParametersUrl(),
+ Collections.emptyMap(),
+ Collections.emptyMap(),
+ SOWorkflowParameterDefinitions.class));
+ }
+
@NotNull
private String getWorkflowsUrl() {
return baseUrl + "so/workflows";
}
+
+ @NotNull
+ private String getParametersUrl() {
+ return baseUrl + "so/workflow-parameters";
+ }
+
+ @NotNull
+ private String getParametersUrl(Long workflowId) {
+ return baseUrl + "so/workflow-parameters/" + workflowId;
+ }
}
import java.util.List;
import org.onap.vid.model.SOWorkflow;
+import org.onap.vid.model.SOWorkflowParameterDefinitions;
public interface ExtWorkflowsService {
List<SOWorkflow> getWorkflows(String vnfName);
+
+ SOWorkflowParameterDefinitions getWorkflowParameterDefinitions(Long workflowId);
}
import java.util.List;
import org.onap.vid.model.SOWorkflow;
+import org.onap.vid.model.SOWorkflowParameterDefinitions;
import org.onap.vid.model.SOWorkflows;
import org.onap.vid.mso.MsoResponseWrapper2;
import org.onap.vid.mso.rest.MockedWorkflowsRestClient;
@Override
public List<SOWorkflow> getWorkflows(String vnfName) {
MsoResponseWrapper2<SOWorkflows> msoResponse = mockedWorkflowsRestClient.getWorkflows(vnfName);
- if (msoResponse.getStatus() >= 400 || msoResponse.getEntity() == null) {
- throw new BadResponseFromMso(msoResponse);
- }
+ validateSOResponse(msoResponse, SOWorkflows.class);
return convertMsoResponseToWorkflowList(msoResponse);
}
+ @Override
+ public SOWorkflowParameterDefinitions getWorkflowParameterDefinitions(Long workflowId) {
+ MsoResponseWrapper2<SOWorkflowParameterDefinitions> msoResponse = mockedWorkflowsRestClient.getWorkflowParameterDefinitions(workflowId);
+ validateSOResponse(msoResponse, SOWorkflowParameterDefinitions.class);
+ return (SOWorkflowParameterDefinitions) msoResponse.getEntity();
+ }
+
private List<SOWorkflow> convertMsoResponseToWorkflowList(MsoResponseWrapper2<SOWorkflows> msoResponse) {
SOWorkflows soWorkflows = (SOWorkflows) msoResponse.getEntity();
return soWorkflows.getWorkflows();
}
+ private void validateSOResponse(MsoResponseWrapper2 response, Class<?> expectedResponseClass){
+ if (response.getStatus() >= 400 || !expectedResponseClass.isInstance(response.getEntity())) {
+ throw new BadResponseFromMso(response);
+ }
+ }
+
public static class BadResponseFromMso extends RuntimeException {
- private final MsoResponseWrapper2<SOWorkflows> msoResponse;
+ private final MsoResponseWrapper2<?> msoResponse;
- public BadResponseFromMso(MsoResponseWrapper2<SOWorkflows> msoResponse) {
+ BadResponseFromMso(MsoResponseWrapper2<?> msoResponse) {
this.msoResponse = msoResponse;
}
- public MsoResponseWrapper2<SOWorkflows> getMsoResponse() {
+ public MsoResponseWrapper2<?> getMsoResponse() {
return msoResponse;
}
}
package org.onap.vid.services;
-import static org.hamcrest.CoreMatchers.*;
-import static org.hamcrest.MatcherAssert.assertThat;
+
+import com.google.common.collect.Lists;
import io.joshworks.restclient.http.HttpResponse;
import java.util.Collections;
import java.util.List;
+
+import org.assertj.core.api.Assertions;
import org.mockito.Mock;
import org.mockito.Mockito;
import org.mockito.MockitoAnnotations;
import org.onap.vid.model.SOWorkflow;
+import org.onap.vid.model.SOWorkflowParameterDefinition;
+import org.onap.vid.model.SOWorkflowParameterDefinitions;
+import org.onap.vid.model.SOWorkflowType;
import org.onap.vid.model.SOWorkflows;
import org.onap.vid.mso.MsoResponseWrapper2;
import org.onap.vid.mso.rest.MockedWorkflowsRestClient;
import org.testng.annotations.BeforeMethod;
import org.testng.annotations.Test;
+
+
public class ExtWorkflowServiceImplTest {
@Mock
@Mock
private HttpResponse<SOWorkflows> response;
+ @Mock
+ private HttpResponse<SOWorkflowParameterDefinitions> parameterDefinitionsHttpResponse;
+
+
@BeforeMethod
public void init(){
MockitoAnnotations.initMocks(this);
List<SOWorkflow> workflows = extWorkflowsService.getWorkflows("test");
// then
Mockito.verify(client).getWorkflows("test");
- assertThat(workflows.get(0).getName(), is("xyz"));
+ Assertions.assertThat(workflows.get(0).getName()).isEqualTo("xyz");
}
@Test(expectedExceptions = BadResponseFromMso.class)
extWorkflowsService.getWorkflows("test");
// then throw exception
}
+ @Test
+ public void shouldReturnWorkflowParametersOnValidResponse() {
+ SOWorkflowParameterDefinitions parameters = new SOWorkflowParameterDefinitions(Collections.singletonList(new SOWorkflowParameterDefinition(1L, "sample", "[0-9]", SOWorkflowType.STRING, true)));
+ ExtWorkflowsService extWorkflowsService = new ExtWorkflowsServiceImpl(client);
+ Mockito.when(parameterDefinitionsHttpResponse.getStatus()).thenReturn(200);
+ Mockito.when(parameterDefinitionsHttpResponse.getBody()).thenReturn(parameters);
+ MsoResponseWrapper2<SOWorkflowParameterDefinitions> msoResponseWrapper = new MsoResponseWrapper2<>(parameterDefinitionsHttpResponse);
+ Mockito.when(client.getWorkflowParameterDefinitions(1L)).thenReturn(msoResponseWrapper);
+
+ SOWorkflowParameterDefinitions workflowParameterDefinitions = extWorkflowsService.getWorkflowParameterDefinitions(1L);
+
+ Assertions.assertThat(workflowParameterDefinitions).isEqualTo(parameters);
+ }
+
+ @Test
+ public void shouldProperlyHandleEmptyParametersList(){
+ ExtWorkflowsService extWorkflowsService = new ExtWorkflowsServiceImpl(client);
+ Mockito.when(parameterDefinitionsHttpResponse.getStatus()).thenReturn(200);
+ Mockito.when(parameterDefinitionsHttpResponse.getBody()).thenReturn(new SOWorkflowParameterDefinitions(Lists.newArrayList()));
+
+ MsoResponseWrapper2<SOWorkflowParameterDefinitions> msoResponseWrapper = new MsoResponseWrapper2<>(parameterDefinitionsHttpResponse);
+ Mockito.when(client.getWorkflowParameterDefinitions(1L)).thenReturn(msoResponseWrapper);
+
+
+ SOWorkflowParameterDefinitions workflowParameterDefinitions = extWorkflowsService.getWorkflowParameterDefinitions(1L);
+ Assertions.assertThat(workflowParameterDefinitions.getParameterDefinitions()).isEmpty();
+ }
}
--- /dev/null
+{
+ "simulatorRequest": {
+ "method": "GET",
+ "path": "/so/workflow-parameters"
+ },
+ "simulatorResponse": {
+ "responseCode": 200,
+ "body": {
+ "parameterDefinitions": [
+ {
+ "id": 1,
+ "name": "general param 1",
+ "required": true,
+ "type": "STRING",
+ "pattern": "[0-9]*"
+ },
+ {
+ "id": 2,
+ "name": "general param 2",
+ "required": false,
+ "type": "STRING",
+ "pattern": "[-+]?[0-9]*\\.?[0-9]*"
+ },
+ {
+ "id": 3,
+ "name": "general param 3",
+ "required": true,
+ "type": "STRING",
+ "pattern": "[a-zA-Z0-9]{7}"
+ },
+ {
+ "id": 4,
+ "name": "general param 4",
+ "required": true,
+ "type": "STRING",
+ "pattern": "[0-9]{3}"
+ }
+ ]
+ }
+ }
+}
\ No newline at end of file
--- /dev/null
+{
+ "simulatorRequest": {
+ "method": "GET",
+ "path": "/so/workflow-parameters/1"
+ },
+ "simulatorResponse": {
+ "responseCode": 200,
+ "body": {
+ "parameterDefinitions": [
+ {
+ "id": 1,
+ "name": "[FIRST]parameter 1",
+ "required": true,
+ "type": "STRING",
+ "pattern": "[0-9]*"
+ }
+ ]
+ }
+ }
+}
\ No newline at end of file
--- /dev/null
+{
+ "simulatorRequest": {
+ "method": "GET",
+ "path": "/so/workflow-parameters/2"
+ },
+ "simulatorResponse": {
+ "responseCode": 200,
+ "body": {
+ "parameterDefinitions": [
+ {
+ "id": 1,
+ "name": "[SECOND] parameter 1",
+ "required": true,
+ "type": "STRING",
+ "pattern": "[0-9]*"
+ },
+ {
+ "id": 2,
+ "name": "[SECOND] parameter 2",
+ "required": false,
+ "type": "STRING",
+ "pattern": "[a-zA-Z0-9]*"
+ }
+ ]
+ }
+ }
+}
\ No newline at end of file
--- /dev/null
+{
+ "simulatorRequest": {
+ "method": "GET",
+ "path": "/so/workflow-parameters/3"
+ },
+ "simulatorResponse": {
+ "responseCode": 200,
+ "body": {
+ "parameterDefinitions": [
+ {
+ "id": 1,
+ "name": "[THIRD] parameter 1",
+ "required": true,
+ "type": "STRING",
+ "pattern": "[0-9]*"
+ },
+ {
+ "id": 2,
+ "name": "[THIRD] parameter 2",
+ "required": false,
+ "type": "STRING",
+ "pattern": "[a-zA-Z]*"
+ },
+ {
+ "id": 3,
+ "name": "[THIRD] parameter 3",
+ "required": true,
+ "type": "STRING",
+ "pattern": "[0-9]{3}"
+ }
+ ]
+ }
+ }
+}
\ No newline at end of file