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 | |
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')
15 files changed, 660 insertions, 6 deletions
diff --git a/wfenginemgrservice/src/test/java/org/onap/workflow/WorkflowAppConfigTest.java b/wfenginemgrservice/src/test/java/org/onap/workflow/WorkflowAppConfigTest.java new file mode 100644 index 0000000..aa24996 --- /dev/null +++ b/wfenginemgrservice/src/test/java/org/onap/workflow/WorkflowAppConfigTest.java @@ -0,0 +1,35 @@ +/** + * 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; + +import static org.hamcrest.core.Is.is; +import static org.junit.Assert.assertThat; + +import org.junit.Test; +import org.onap.workflow.entity.MsbClientConfig; + +public class WorkflowAppConfigTest { + @Test + public void getMsbClientConfig() throws Exception { + WorkflowAppConfig workflowAppConfig = new WorkflowAppConfig(); + MsbClientConfig msbClientConfig = new MsbClientConfig(); + + workflowAppConfig.setMsbClientConfig(msbClientConfig); + + assertThat(workflowAppConfig.getMsbClientConfig(), is(msbClientConfig)); + } + +}
\ No newline at end of file diff --git a/wfenginemgrservice/src/test/java/org/onap/workflow/WorkflowAppTest.java b/wfenginemgrservice/src/test/java/org/onap/workflow/WorkflowAppTest.java new file mode 100644 index 0000000..a1ed93c --- /dev/null +++ b/wfenginemgrservice/src/test/java/org/onap/workflow/WorkflowAppTest.java @@ -0,0 +1,44 @@ +/** + * 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; + +import io.dropwizard.jersey.setup.JerseyEnvironment; +import io.dropwizard.setup.Environment; +import org.glassfish.jersey.media.multipart.MultiPartFeature; +import org.junit.Test; + +import static org.hamcrest.MatcherAssert.assertThat; +import static org.hamcrest.core.Is.is; +import static org.mockito.Mockito.*; + +public class WorkflowAppTest { + @Test + public void testRun() throws Exception { + WorkflowApp app = new WorkflowApp(); + WorkflowAppConfig config = mock(WorkflowAppConfig.class); + Environment environment = mock(Environment.class); + JerseyEnvironment jerseyEnvironment = mock(JerseyEnvironment.class); + + when(environment.jersey()).thenReturn(jerseyEnvironment); + + app.run(config, environment); + + verify(jerseyEnvironment).register(MultiPartFeature.class); + verify(jerseyEnvironment).packages("org.onap.workflow.resources"); + assertThat(app.getName(), is(" Workflow APP ")); + } + +}
\ No newline at end of file diff --git a/wfenginemgrservice/src/test/java/org/onap/workflow/common/EnumModuleUrlTest.java b/wfenginemgrservice/src/test/java/org/onap/workflow/common/EnumModuleUrlTest.java new file mode 100644 index 0000000..01028e6 --- /dev/null +++ b/wfenginemgrservice/src/test/java/org/onap/workflow/common/EnumModuleUrlTest.java @@ -0,0 +1,44 @@ +/** + * 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.common; + + +import org.junit.Assert; +import org.junit.Test; +import org.onap.workflow.WorkflowAppConfig; +import org.onap.workflow.entity.MsbClientConfig; + +public class EnumModuleUrlTest { + @Test + public void testEnumModel() { + String msbSvrIp = "127.0.0.1"; + WorkflowAppConfig workflowconfig = makeWorkFlowConfig(msbSvrIp); + Config.setWorkflowAppConfig(workflowconfig); + String activitiBaseUrl = EnumModuleUrl.getBaseUrl(EnumModuleUrl.ACTIVITI); + Assert.assertEquals("http://" + msbSvrIp + ":80" + EnumModuleUrl.ACTIVITI.getApiRootDomain(), + activitiBaseUrl); + } + + private WorkflowAppConfig makeWorkFlowConfig(String msbSvrIp) { + int msbSvrPort = 80; + MsbClientConfig msbClientConfig = new MsbClientConfig(); + msbClientConfig.setMsbSvrIp(msbSvrIp); + msbClientConfig.setMsbSvrPort(msbSvrPort); + WorkflowAppConfig workflowconfig = new WorkflowAppConfig(); + workflowconfig.setMsbClientConfig(msbClientConfig); + return workflowconfig; + } +}
\ No newline at end of file diff --git a/wfenginemgrservice/src/test/java/org/onap/workflow/common/RestClientUtilsTest.java b/wfenginemgrservice/src/test/java/org/onap/workflow/common/RestClientUtilsTest.java new file mode 100644 index 0000000..fc7317e --- /dev/null +++ b/wfenginemgrservice/src/test/java/org/onap/workflow/common/RestClientUtilsTest.java @@ -0,0 +1,56 @@ +/** + * 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.common; + +import java.io.File; +import java.io.FileInputStream; +import java.io.InputStream; + +import org.apache.http.HttpEntity; +import org.apache.http.entity.ContentType; +import org.junit.Assert; +import org.junit.Test; + +/** + * + */ +public class RestClientUtilsTest { + + @Test + public void testbuildMultipartRequest() { + String filePath = System.getProperty("java.io.tmpdir"); + String fileName = "testfile"; + File file = new File(filePath + File.separator + fileName); + InputStream is = null; + try { + if (!file.exists()) { + file.createNewFile(); + } + is = new FileInputStream(file); + HttpEntity httpentity = RestClientUtils.buildMultipartRequest(is, fileName); + Assert.assertTrue(httpentity.getContentType().getValue() + .indexOf(ContentType.MULTIPART_FORM_DATA.getMimeType()) > -1); + } catch (Exception e) { + assert (false); + } finally { + ToolUtil.closeInputStream(is); + if (file.exists()) { + file.delete(); + } + } + } +} diff --git a/wfenginemgrservice/src/test/java/org/onap/workflow/common/RestResponseTest.java b/wfenginemgrservice/src/test/java/org/onap/workflow/common/RestResponseTest.java new file mode 100644 index 0000000..5fc8d01 --- /dev/null +++ b/wfenginemgrservice/src/test/java/org/onap/workflow/common/RestResponseTest.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.common; + +import org.junit.Test; + +import static org.hamcrest.core.Is.is; +import static org.junit.Assert.assertThat; + +public class RestResponseTest { + @Test + public void getStatusCode() throws Exception { + RestResponse restResponse = new RestResponse(); + restResponse.setResult("1"); + restResponse.setStatusCode(1); + + assertThat(restResponse.getResult(), is("1")); + assertThat(restResponse.getStatusCode(), is(1)); + } + +}
\ No newline at end of file diff --git a/wfenginemgrservice/src/test/java/org/onap/workflow/common/ToolUtilTest.java b/wfenginemgrservice/src/test/java/org/onap/workflow/common/ToolUtilTest.java index 2c6e175..4407a24 100644 --- a/wfenginemgrservice/src/test/java/org/onap/workflow/common/ToolUtilTest.java +++ b/wfenginemgrservice/src/test/java/org/onap/workflow/common/ToolUtilTest.java @@ -19,12 +19,29 @@ package org.onap.workflow.common; import org.junit.Assert; import org.junit.Test; +import java.io.InputStream; + +import static org.mockito.Mockito.mock; +import static org.mockito.Mockito.verify; + /** * @author 10175158 * */ public class ToolUtilTest { @Test + public void testCloseInputStream() throws Exception { + InputStream inputStream = mock(InputStream.class); + ToolUtil.closeInputStream(inputStream); + verify(inputStream).close(); + } + + @Test + public void testCloseInputStreamWhenGivenNullInputStream() throws Exception { + ToolUtil.closeInputStream(null); + } + + @Test public void testgetHeader() { String actual = "Basic a2VybWl0Omtlcm1pdA=="; Assert.assertEquals(actual, ToolUtil.getHeader()); diff --git a/wfenginemgrservice/src/test/java/org/onap/workflow/entity/DeployBpmnFileResponseTest.java b/wfenginemgrservice/src/test/java/org/onap/workflow/entity/DeployBpmnFileResponseTest.java new file mode 100644 index 0000000..fe81c86 --- /dev/null +++ b/wfenginemgrservice/src/test/java/org/onap/workflow/entity/DeployBpmnFileResponseTest.java @@ -0,0 +1,38 @@ +/** + * 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.entity; + +import org.junit.Test; + +import static org.hamcrest.CoreMatchers.is; +import static org.junit.Assert.*; + +public class DeployBpmnFileResponseTest { + @Test + public void getStatus() throws Exception { + DeployBpmnFileResponse response = new DeployBpmnFileResponse(); + response.setDeployedId("1"); + response.setMessage("1"); + response.setProcessId("1"); + response.setStatus(1); + + assertThat(response.getDeployedId(), is("1")); + assertThat(response.getMessage(), is("1")); + assertThat(response.getProcessId(), is("1")); + assertThat(response.getStatus(), is(1)); + } + +}
\ No newline at end of file diff --git a/wfenginemgrservice/src/test/java/org/onap/workflow/entity/MsbClientConfigTest.java b/wfenginemgrservice/src/test/java/org/onap/workflow/entity/MsbClientConfigTest.java new file mode 100644 index 0000000..c48a9fb --- /dev/null +++ b/wfenginemgrservice/src/test/java/org/onap/workflow/entity/MsbClientConfigTest.java @@ -0,0 +1,40 @@ +/** + * 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.entity; + +import org.junit.Test; + +import static org.hamcrest.CoreMatchers.is; +import static org.hamcrest.MatcherAssert.assertThat; + +public class MsbClientConfigTest { + @Test + public void getMsbSvrIp() throws Exception { + MsbClientConfig clientConfig = new MsbClientConfig(); + clientConfig.setMsbSvrIp("127.0.0.1"); + + assertThat(clientConfig.getMsbSvrIp(), is("127.0.0.1")); + } + + @Test + public void getMsbSvrPort() throws Exception { + MsbClientConfig clientConfig = new MsbClientConfig(); + clientConfig.setMsbSvrPort(20); + + assertThat(clientConfig.getMsbSvrPort(), is(20)); + } + +}
\ No newline at end of file diff --git a/wfenginemgrservice/src/test/java/org/onap/workflow/entity/StartProcessRequestTest.java b/wfenginemgrservice/src/test/java/org/onap/workflow/entity/StartProcessRequestTest.java new file mode 100644 index 0000000..5b35e7f --- /dev/null +++ b/wfenginemgrservice/src/test/java/org/onap/workflow/entity/StartProcessRequestTest.java @@ -0,0 +1,41 @@ +/** + * 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.entity; + +import com.google.common.collect.ImmutableMap; +import org.junit.Test; + +import java.util.Map; + +import static org.hamcrest.core.Is.is; +import static org.junit.Assert.assertThat; + +public class StartProcessRequestTest { + @Test + public void getParams() throws Exception { + StartProcessRequest request = new StartProcessRequest(); + request.setProcessDefinitionKey("1"); + Map<String, String> map = ImmutableMap.<String, String>builder() + .put("1", "1") + .build(); + request.setParams(map); + + assertThat(request.getParams(), is(map)); + assertThat(request.getProcessDefinitionKey(), is("1")); + + } + +}
\ No newline at end of file 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 diff --git a/wfenginemgrservice/src/test/java/org/onap/workflow/tools/HttpDeleteWithBodyTest.java b/wfenginemgrservice/src/test/java/org/onap/workflow/tools/HttpDeleteWithBodyTest.java new file mode 100644 index 0000000..67cd8c9 --- /dev/null +++ b/wfenginemgrservice/src/test/java/org/onap/workflow/tools/HttpDeleteWithBodyTest.java @@ -0,0 +1,29 @@ +/** + * 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.tools; + + +import org.junit.Assert; +import org.junit.Test; + + +public class HttpDeleteWithBodyTest { + @Test + public void testHttpDeleteWithBody() { + HttpDeleteWithBody body = new HttpDeleteWithBody(); + Assert.assertEquals(HttpDeleteWithBody.METHOD_NAME, body.getMethod()); + } +} diff --git a/wfenginemgrservice/src/test/java/org/onap/workflow/tools/RequestParametersTest.java b/wfenginemgrservice/src/test/java/org/onap/workflow/tools/RequestParametersTest.java index 782ee84..aeeb3e3 100644 --- a/wfenginemgrservice/src/test/java/org/onap/workflow/tools/RequestParametersTest.java +++ b/wfenginemgrservice/src/test/java/org/onap/workflow/tools/RequestParametersTest.java @@ -1,12 +1,12 @@ /** * 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 - * - * http://www.apache.org/licenses/LICENSE-2.0 - * + * <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. @@ -17,13 +17,23 @@ package org.onap.workflow.tools; import org.junit.Test; +import static org.hamcrest.MatcherAssert.assertThat; +import static org.hamcrest.core.Is.is; + /** * */ public class RequestParametersTest { @Test - public void testToString(){ + public void testToString() { + RequestParameters result = new RequestParameters(); + assertThat(result.toString(), is("casCade [casCade=false]")); + } + + @Test + public void testMethod() { RequestParameters result = new RequestParameters(); - result.toString(); + result.setCasCade(true); + assertThat(result.isCasCade(), is(true)); } } |