diff options
author | 2017-09-30 14:08:50 +0800 | |
---|---|---|
committer | 2017-09-30 14:08:50 +0800 | |
commit | b15b381c5fa631699c1a3d27e482d3d77bed6ad8 (patch) | |
tree | 7f058e7f289553cc402f603909c7e3698a9e3d4d /wfenginemgrservice/src/test/java/org/onap/workflow/externalservice | |
parent | 83e300240cea9fb1fa7cf011c8fa8d4aeb0ebca6 (diff) |
Add unit test for vfc-nfvo-wfengine
Change-Id: If70f670ce62c3ca577d11b036e705b07a80f82cf
Issue-id: VFC-454
Signed-off-by: Zhaoxing <meng.zhaoxing1@zte.com.cn>
Diffstat (limited to 'wfenginemgrservice/src/test/java/org/onap/workflow/externalservice')
4 files changed, 266 insertions, 0 deletions
diff --git a/wfenginemgrservice/src/test/java/org/onap/workflow/externalservice/entity/activitientitiy/ActivitiDeployResponseTest.java b/wfenginemgrservice/src/test/java/org/onap/workflow/externalservice/entity/activitientitiy/ActivitiDeployResponseTest.java new file mode 100644 index 0000000..5627f11 --- /dev/null +++ b/wfenginemgrservice/src/test/java/org/onap/workflow/externalservice/entity/activitientitiy/ActivitiDeployResponseTest.java @@ -0,0 +1,41 @@ +/** + * Copyright 2017 ZTE Corporation. + * + * Licensed under the Apache License, Version 2.0 (the "License"); + * you may not use this file except in compliance with the License. + * You may obtain a copy of the License at + * + * http://www.apache.org/licenses/LICENSE-2.0 + * + * Unless required by applicable law or agreed to in writing, software + * distributed under the License is distributed on an "AS IS" BASIS, + * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. + * See the License for the specific language governing permissions and + * limitations under the License. + */ + +package org.onap.workflow.externalservice.entity.activitientitiy; + + +import org.junit.Assert; +import org.junit.Test; + + +/** + * + */ +public class ActivitiDeployResponseTest { + @Test + public void testMethod() { + ActivitiDeployResponse response = new ActivitiDeployResponse(); + String id = "111id"; + String deploymentTime = "2017-10-11"; + String url = "http://127.0.0.1"; + response.setId(id); + response.setDeploymentTime(deploymentTime); + response.setUrl(url); + Assert.assertEquals(id, response.getId()); + Assert.assertEquals(deploymentTime, response.getDeploymentTime()); + Assert.assertEquals(url, response.getUrl()); + } +} diff --git a/wfenginemgrservice/src/test/java/org/onap/workflow/externalservice/entity/activitientitiy/ActivitiStartProcessRequestParamTest.java b/wfenginemgrservice/src/test/java/org/onap/workflow/externalservice/entity/activitientitiy/ActivitiStartProcessRequestParamTest.java new file mode 100644 index 0000000..a0d82ce --- /dev/null +++ b/wfenginemgrservice/src/test/java/org/onap/workflow/externalservice/entity/activitientitiy/ActivitiStartProcessRequestParamTest.java @@ -0,0 +1,34 @@ +/** + * Copyright 2017 ZTE Corporation. + * <p> + * Licensed under the Apache License, Version 2.0 (the "License"); + * you may not use this file except in compliance with the License. + * You may obtain a copy of the License at + * <p> + * http://www.apache.org/licenses/LICENSE-2.0 + * <p> + * Unless required by applicable law or agreed to in writing, software + * distributed under the License is distributed on an "AS IS" BASIS, + * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. + * See the License for the specific language governing permissions and + * limitations under the License. + */ +package org.onap.workflow.externalservice.entity.activitientitiy; + +import org.junit.Test; + +import static org.hamcrest.CoreMatchers.is; +import static org.hamcrest.MatcherAssert.assertThat; + +public class ActivitiStartProcessRequestParamTest { + + @Test + public void testGetMethod() throws Exception { + ActivitiStartProcessRequestParam param = new ActivitiStartProcessRequestParam(); + param.setName("name"); + param.setValue("value"); + + assertThat(param.getName(), is("name")); + assertThat(param.getValue(), is("value")); + } +}
\ No newline at end of file diff --git a/wfenginemgrservice/src/test/java/org/onap/workflow/externalservice/entity/activitientitiy/ActivitiStartProcessRequestTest.java b/wfenginemgrservice/src/test/java/org/onap/workflow/externalservice/entity/activitientitiy/ActivitiStartProcessRequestTest.java new file mode 100644 index 0000000..13229ea --- /dev/null +++ b/wfenginemgrservice/src/test/java/org/onap/workflow/externalservice/entity/activitientitiy/ActivitiStartProcessRequestTest.java @@ -0,0 +1,38 @@ +/** + * Copyright 2017 ZTE Corporation. + * + * Licensed under the Apache License, Version 2.0 (the "License"); + * you may not use this file except in compliance with the License. + * You may obtain a copy of the License at + * + * http://www.apache.org/licenses/LICENSE-2.0 + * + * Unless required by applicable law or agreed to in writing, software + * distributed under the License is distributed on an "AS IS" BASIS, + * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. + * See the License for the specific language governing permissions and + * limitations under the License. + */ +package org.onap.workflow.externalservice.entity.activitientitiy; + +import org.junit.Assert; +import org.junit.Test; + + + +/** + * + */ +public class ActivitiStartProcessRequestTest { + + @Test + public void testMethod() { + ActivitiStartProcessRequestParam[] variables = null; + String processDefinitionKey = "test"; + ActivitiStartProcessRequest request = new ActivitiStartProcessRequest(); + request.setProcessDefinitionKey(processDefinitionKey); + request.setVariables(variables); + Assert.assertEquals(processDefinitionKey, request.getProcessDefinitionKey()); + Assert.assertSame(variables, request.getVariables()); + } +} diff --git a/wfenginemgrservice/src/test/java/org/onap/workflow/externalservice/service/activitiservice/ActivitiServiceConsumerTest.java b/wfenginemgrservice/src/test/java/org/onap/workflow/externalservice/service/activitiservice/ActivitiServiceConsumerTest.java new file mode 100644 index 0000000..f9dd990 --- /dev/null +++ b/wfenginemgrservice/src/test/java/org/onap/workflow/externalservice/service/activitiservice/ActivitiServiceConsumerTest.java @@ -0,0 +1,153 @@ +/** + * Copyright 2017 ZTE Corporation. + * <p> + * Licensed under the Apache License, Version 2.0 (the "License"); + * you may not use this file except in compliance with the License. + * You may obtain a copy of the License at + * <p> + * http://www.apache.org/licenses/LICENSE-2.0 + * <p> + * Unless required by applicable law or agreed to in writing, software + * distributed under the License is distributed on an "AS IS" BASIS, + * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. + * See the License for the specific language governing permissions and + * limitations under the License. + */ +package org.onap.workflow.externalservice.service.activitiservice; + +import com.google.gson.Gson; +import org.apache.http.HttpEntity; +import org.junit.Before; +import org.junit.Test; +import org.junit.runner.RunWith; +import org.onap.workflow.WorkflowAppConfig; +import org.onap.workflow.common.Config; +import org.onap.workflow.common.RestClient; +import org.onap.workflow.common.RestResponse; +import org.onap.workflow.entity.MsbClientConfig; +import org.onap.workflow.externalservice.entity.activitientitiy.ActivitiDeployResponse; +import org.onap.workflow.externalservice.entity.activitientitiy.ActivitiStartProcessRequest; +import org.powermock.core.classloader.annotations.PrepareForTest; +import org.powermock.modules.junit4.PowerMockRunner; + +import java.io.IOException; +import java.io.InputStream; + +import static org.hamcrest.core.Is.is; +import static org.junit.Assert.assertThat; +import static org.mockito.Matchers.*; +import static org.mockito.Mockito.mock; +import static org.powermock.api.mockito.PowerMockito.mockStatic; +import static org.powermock.api.mockito.PowerMockito.when; + +@PrepareForTest({RestClient.class, Config.class}) +@RunWith(PowerMockRunner.class) +public class ActivitiServiceConsumerTest { + + @Before + public void setUp() throws Exception { + mockStatic(RestClient.class); + } + + @Test + public void undeploybpmnfile() throws Exception { + + RestResponse restResponse = mock(RestResponse.class); + when(RestClient.post(anyString(), any(Integer.class), anyString())) + .thenReturn(restResponse); + + RestResponse response = ActivitiServiceConsumer.undeploybpmnfile("22"); + + assertThat(response, is(restResponse)); + } + + @Test + public void startBpmnProcess() throws Exception { + RestResponse restResponse = mock(RestResponse.class); + when(RestClient.post(anyString(), any(Integer.class), anyString(), + any(ActivitiStartProcessRequest.class))) + .thenReturn(restResponse); + + RestResponse response = ActivitiServiceConsumer.startBpmnProcess( + mock(ActivitiStartProcessRequest.class)); + + assertThat(response, is(restResponse)); + } + + @Test + public void testDeleteDeployProcess() throws Exception { + RestResponse restResponse = mock(RestResponse.class); + when(RestClient.post(anyString(), any(Integer.class), anyString())) + .thenReturn(restResponse); + + RestResponse response = ActivitiServiceConsumer.deleteDeployProcess("22"); + + assertThat(response, is(restResponse)); + } + + @Test + public void testDeleteDeployProcessReturnNull() throws Exception { + when(RestClient.post(anyString(), any(Integer.class), anyString())) + .thenThrow(new IOException()); + + RestResponse response = ActivitiServiceConsumer.deleteDeployProcess("22"); + + assertThat(response, is((RestResponse) null)); + } + + @Test + public void testStartProcessShouldReturnResponse() throws Exception { + RestResponse restResponse = mock(RestResponse.class); + when(RestClient.post(anyString(), any(Integer.class), anyString(), + any(ActivitiStartProcessRequest.class))) + .thenReturn(restResponse); + + RestResponse response = ActivitiServiceConsumer.startProcess( + mock(ActivitiStartProcessRequest.class)); + + assertThat(response, is(restResponse)); + } + + @Test + public void testStartProcessShouldReturnNull() throws Exception { + when(RestClient.post(anyString(), any(Integer.class), anyString(), + any(ActivitiStartProcessRequest.class))) + .thenThrow(new IOException()); + + RestResponse response = ActivitiServiceConsumer.startProcess( + mock(ActivitiStartProcessRequest.class)); + + assertThat(response, is((RestResponse) null)); + } + + @Test + public void deploybpmnfile() throws Exception { + mockStatic(Config.class); + WorkflowAppConfig workflowAppConfig = mock(WorkflowAppConfig.class); + MsbClientConfig msbClientConfig = new MsbClientConfig(); + msbClientConfig.setMsbSvrPort(2); + msbClientConfig.setMsbSvrIp("127.0.0.1"); + + when(workflowAppConfig.getMsbClientConfig()).thenReturn(msbClientConfig); + when(Config.getWorkflowAppConfig()).thenReturn(workflowAppConfig); + + RestResponse restResponse = mock(RestResponse.class); + + ActivitiDeployResponse activitiDeployResponse = new ActivitiDeployResponse(); + activitiDeployResponse.setId("2"); + activitiDeployResponse.setUrl("xxxx"); + activitiDeployResponse.setDeploymentTime("22"); + + when(restResponse.getStatusCode()).thenReturn(200); + when(restResponse.getResult()).thenReturn(new Gson().toJson(activitiDeployResponse)); + when(RestClient.post(anyString(), anyInt(), anyString(), + any(HttpEntity.class))) + .thenReturn(restResponse); + + InputStream ins = mock(InputStream.class); + ActivitiDeployResponse result = ActivitiServiceConsumer.deploybpmnfile(ins, "result"); + + assertThat(result.getId(), is(activitiDeployResponse.getId())); + } + +}
\ No newline at end of file |