From b15b381c5fa631699c1a3d27e482d3d77bed6ad8 Mon Sep 17 00:00:00 2001
From: Zhaoxing <meng.zhaoxing1@zte.com.cn>
Date: Sat, 30 Sep 2017 14:08:50 +0800
Subject: Add unit test for vfc-nfvo-wfengine

Change-Id: If70f670ce62c3ca577d11b036e705b07a80f82cf
Issue-id:  VFC-454
Signed-off-by: Zhaoxing <meng.zhaoxing1@zte.com.cn>
---
 .../org/onap/workflow/WorkflowAppConfigTest.java   |  35 +++++
 .../java/org/onap/workflow/WorkflowAppTest.java    |  44 ++++++
 .../onap/workflow/common/EnumModuleUrlTest.java    |  44 ++++++
 .../onap/workflow/common/RestClientUtilsTest.java  |  56 ++++++++
 .../org/onap/workflow/common/RestResponseTest.java |  34 +++++
 .../org/onap/workflow/common/ToolUtilTest.java     |  17 +++
 .../entity/DeployBpmnFileResponseTest.java         |  38 +++++
 .../onap/workflow/entity/MsbClientConfigTest.java  |  40 ++++++
 .../workflow/entity/StartProcessRequestTest.java   |  41 ++++++
 .../ActivitiDeployResponseTest.java                |  41 ++++++
 .../ActivitiStartProcessRequestParamTest.java      |  34 +++++
 .../ActivitiStartProcessRequestTest.java           |  38 +++++
 .../ActivitiServiceConsumerTest.java               | 153 +++++++++++++++++++++
 .../workflow/tools/HttpDeleteWithBodyTest.java     |  29 ++++
 .../onap/workflow/tools/RequestParametersTest.java |  22 ++-
 15 files changed, 660 insertions(+), 6 deletions(-)
 create mode 100644 wfenginemgrservice/src/test/java/org/onap/workflow/WorkflowAppConfigTest.java
 create mode 100644 wfenginemgrservice/src/test/java/org/onap/workflow/WorkflowAppTest.java
 create mode 100644 wfenginemgrservice/src/test/java/org/onap/workflow/common/EnumModuleUrlTest.java
 create mode 100644 wfenginemgrservice/src/test/java/org/onap/workflow/common/RestClientUtilsTest.java
 create mode 100644 wfenginemgrservice/src/test/java/org/onap/workflow/common/RestResponseTest.java
 create mode 100644 wfenginemgrservice/src/test/java/org/onap/workflow/entity/DeployBpmnFileResponseTest.java
 create mode 100644 wfenginemgrservice/src/test/java/org/onap/workflow/entity/MsbClientConfigTest.java
 create mode 100644 wfenginemgrservice/src/test/java/org/onap/workflow/entity/StartProcessRequestTest.java
 create mode 100644 wfenginemgrservice/src/test/java/org/onap/workflow/externalservice/entity/activitientitiy/ActivitiDeployResponseTest.java
 create mode 100644 wfenginemgrservice/src/test/java/org/onap/workflow/externalservice/entity/activitientitiy/ActivitiStartProcessRequestParamTest.java
 create mode 100644 wfenginemgrservice/src/test/java/org/onap/workflow/externalservice/entity/activitientitiy/ActivitiStartProcessRequestTest.java
 create mode 100644 wfenginemgrservice/src/test/java/org/onap/workflow/externalservice/service/activitiservice/ActivitiServiceConsumerTest.java
 create mode 100644 wfenginemgrservice/src/test/java/org/onap/workflow/tools/HttpDeleteWithBodyTest.java

(limited to 'wfenginemgrservice/src/test/java/org/onap')

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,11 +19,28 @@ 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==";
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));
   }
 }
-- 
cgit 1.2.3-korg