summaryrefslogtreecommitdiffstats
path: root/wfenginemgrservice/src
diff options
context:
space:
mode:
Diffstat (limited to 'wfenginemgrservice/src')
-rw-r--r--wfenginemgrservice/src/main/java/org/onap/workflow/common/EnumModuleUrl.java3
-rw-r--r--wfenginemgrservice/src/main/java/org/onap/workflow/common/RestResponse.java25
-rw-r--r--wfenginemgrservice/src/main/java/org/onap/workflow/entity/DeployBpmnFileResponse.java30
-rw-r--r--wfenginemgrservice/src/main/java/org/onap/workflow/entity/MsbClientConfig.java16
-rw-r--r--wfenginemgrservice/src/main/java/org/onap/workflow/entity/StartProcessRequest.java22
-rw-r--r--wfenginemgrservice/src/main/java/org/onap/workflow/externalservice/entity/activitientitiy/ActivitiDeployResponse.java21
-rw-r--r--wfenginemgrservice/src/main/java/org/onap/workflow/externalservice/entity/activitientitiy/ActivitiStartProcessRequest.java15
-rw-r--r--wfenginemgrservice/src/main/java/org/onap/workflow/externalservice/entity/activitientitiy/ActivitiStartProcessRequestParam.java17
-rw-r--r--wfenginemgrservice/src/main/java/org/onap/workflow/tools/RequestParameters.java8
-rw-r--r--wfenginemgrservice/src/test/java/org/onap/workflow/WorkflowAppConfigTest.java35
-rw-r--r--wfenginemgrservice/src/test/java/org/onap/workflow/WorkflowAppTest.java44
-rw-r--r--wfenginemgrservice/src/test/java/org/onap/workflow/common/EnumModuleUrlTest.java44
-rw-r--r--wfenginemgrservice/src/test/java/org/onap/workflow/common/RestClientUtilsTest.java56
-rw-r--r--wfenginemgrservice/src/test/java/org/onap/workflow/common/RestResponseTest.java34
-rw-r--r--wfenginemgrservice/src/test/java/org/onap/workflow/common/ToolUtilTest.java17
-rw-r--r--wfenginemgrservice/src/test/java/org/onap/workflow/entity/DeployBpmnFileResponseTest.java38
-rw-r--r--wfenginemgrservice/src/test/java/org/onap/workflow/entity/MsbClientConfigTest.java40
-rw-r--r--wfenginemgrservice/src/test/java/org/onap/workflow/entity/StartProcessRequestTest.java41
-rw-r--r--wfenginemgrservice/src/test/java/org/onap/workflow/externalservice/entity/activitientitiy/ActivitiDeployResponseTest.java41
-rw-r--r--wfenginemgrservice/src/test/java/org/onap/workflow/externalservice/entity/activitientitiy/ActivitiStartProcessRequestParamTest.java34
-rw-r--r--wfenginemgrservice/src/test/java/org/onap/workflow/externalservice/entity/activitientitiy/ActivitiStartProcessRequestTest.java38
-rw-r--r--wfenginemgrservice/src/test/java/org/onap/workflow/externalservice/service/activitiservice/ActivitiServiceConsumerTest.java153
-rw-r--r--wfenginemgrservice/src/test/java/org/onap/workflow/tools/HttpDeleteWithBodyTest.java29
-rw-r--r--wfenginemgrservice/src/test/java/org/onap/workflow/tools/RequestParametersTest.java22
24 files changed, 779 insertions, 44 deletions
diff --git a/wfenginemgrservice/src/main/java/org/onap/workflow/common/EnumModuleUrl.java b/wfenginemgrservice/src/main/java/org/onap/workflow/common/EnumModuleUrl.java
index 00f10d8..120e3de 100644
--- a/wfenginemgrservice/src/main/java/org/onap/workflow/common/EnumModuleUrl.java
+++ b/wfenginemgrservice/src/main/java/org/onap/workflow/common/EnumModuleUrl.java
@@ -1,5 +1,5 @@
/**
- * Copyright 2017 [ZTE] and others.
+ * 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.
@@ -13,6 +13,7 @@
* See the License for the specific language governing permissions and
* limitations under the License.
*/
+
package org.onap.workflow.common;
public enum EnumModuleUrl {
diff --git a/wfenginemgrservice/src/main/java/org/onap/workflow/common/RestResponse.java b/wfenginemgrservice/src/main/java/org/onap/workflow/common/RestResponse.java
index 21467bf..f55387b 100644
--- a/wfenginemgrservice/src/main/java/org/onap/workflow/common/RestResponse.java
+++ b/wfenginemgrservice/src/main/java/org/onap/workflow/common/RestResponse.java
@@ -15,17 +15,24 @@
*/
package org.onap.workflow.common;
-import lombok.AllArgsConstructor;
-import lombok.Data;
-import lombok.NoArgsConstructor;
-import com.fasterxml.jackson.annotation.JsonIgnoreProperties;
-
-@Data
-@NoArgsConstructor
-@AllArgsConstructor
-@JsonIgnoreProperties(ignoreUnknown = true)
public class RestResponse {
+ public int getStatusCode() {
+ return statusCode;
+ }
+
+ public void setStatusCode(int statusCode) {
+ this.statusCode = statusCode;
+ }
+
+ public String getResult() {
+ return result;
+ }
+
+ public void setResult(String result) {
+ this.result = result;
+ }
+
private int statusCode;
private String result;
diff --git a/wfenginemgrservice/src/main/java/org/onap/workflow/entity/DeployBpmnFileResponse.java b/wfenginemgrservice/src/main/java/org/onap/workflow/entity/DeployBpmnFileResponse.java
index 6a1920e..bb6fcbb 100644
--- a/wfenginemgrservice/src/main/java/org/onap/workflow/entity/DeployBpmnFileResponse.java
+++ b/wfenginemgrservice/src/main/java/org/onap/workflow/entity/DeployBpmnFileResponse.java
@@ -15,15 +15,33 @@
*/
package org.onap.workflow.entity;
-import lombok.AllArgsConstructor;
-import lombok.Data;
-import lombok.NoArgsConstructor;
-@Data
-@NoArgsConstructor
-@AllArgsConstructor
public class DeployBpmnFileResponse {
+ public int getStatus() {
+ return status;
+ }
+ public void setStatus(int status) {
+ this.status = status;
+ }
+ public String getMessage() {
+ return message;
+ }
+ public void setMessage(String message) {
+ this.message = message;
+ }
+ public String getDeployedId() {
+ return deployedId;
+ }
+ public void setDeployedId(String deployedId) {
+ this.deployedId = deployedId;
+ }
+ public String getProcessId() {
+ return processId;
+ }
+ public void setProcessId(String processId) {
+ this.processId = processId;
+ }
private int status;
private String message;
private String deployedId;
diff --git a/wfenginemgrservice/src/main/java/org/onap/workflow/entity/MsbClientConfig.java b/wfenginemgrservice/src/main/java/org/onap/workflow/entity/MsbClientConfig.java
index e73c4f2..4867bd6 100644
--- a/wfenginemgrservice/src/main/java/org/onap/workflow/entity/MsbClientConfig.java
+++ b/wfenginemgrservice/src/main/java/org/onap/workflow/entity/MsbClientConfig.java
@@ -16,11 +16,21 @@
package org.onap.workflow.entity;
-import lombok.Data;
-@Data
public class MsbClientConfig {
- private String msbSvrIp;
+ public String getMsbSvrIp() {
+ return msbSvrIp;
+ }
+ public void setMsbSvrIp(String msbSvrIp) {
+ this.msbSvrIp = msbSvrIp;
+ }
+ public Integer getMsbSvrPort() {
+ return msbSvrPort;
+ }
+ public void setMsbSvrPort(Integer msbSvrPort) {
+ this.msbSvrPort = msbSvrPort;
+ }
+ private String msbSvrIp;
private Integer msbSvrPort;
}
diff --git a/wfenginemgrservice/src/main/java/org/onap/workflow/entity/StartProcessRequest.java b/wfenginemgrservice/src/main/java/org/onap/workflow/entity/StartProcessRequest.java
index cddaa09..3258722 100644
--- a/wfenginemgrservice/src/main/java/org/onap/workflow/entity/StartProcessRequest.java
+++ b/wfenginemgrservice/src/main/java/org/onap/workflow/entity/StartProcessRequest.java
@@ -17,17 +17,19 @@ package org.onap.workflow.entity;
import java.util.Map;
-import lombok.AllArgsConstructor;
-import lombok.Data;
-import lombok.NoArgsConstructor;
-
-import com.fasterxml.jackson.annotation.JsonIgnoreProperties;
-
-@Data
-@NoArgsConstructor
-@AllArgsConstructor
-@JsonIgnoreProperties(ignoreUnknown = true)
public class StartProcessRequest {
+ public String getProcessDefinitionKey() {
+ return processDefinitionKey;
+ }
+ public void setProcessDefinitionKey(String processDefinitionKey) {
+ this.processDefinitionKey = processDefinitionKey;
+ }
+ public Map<String, String> getParams() {
+ return params;
+ }
+ public void setParams(Map<String, String> params) {
+ this.params = params;
+ }
private String processDefinitionKey;
private Map<String, String> params;
}
diff --git a/wfenginemgrservice/src/main/java/org/onap/workflow/externalservice/entity/activitientitiy/ActivitiDeployResponse.java b/wfenginemgrservice/src/main/java/org/onap/workflow/externalservice/entity/activitientitiy/ActivitiDeployResponse.java
index 5ad3d12..71b3bd0 100644
--- a/wfenginemgrservice/src/main/java/org/onap/workflow/externalservice/entity/activitientitiy/ActivitiDeployResponse.java
+++ b/wfenginemgrservice/src/main/java/org/onap/workflow/externalservice/entity/activitientitiy/ActivitiDeployResponse.java
@@ -15,10 +15,27 @@
*/
package org.onap.workflow.externalservice.entity.activitientitiy;
-import lombok.Data;
-@Data
+
public class ActivitiDeployResponse {
+ public String getId() {
+ return id;
+ }
+ public void setId(String id) {
+ this.id = id;
+ }
+ public String getDeploymentTime() {
+ return deploymentTime;
+ }
+ public void setDeploymentTime(String deploymentTime) {
+ this.deploymentTime = deploymentTime;
+ }
+ public String getUrl() {
+ return url;
+ }
+ public void setUrl(String url) {
+ this.url = url;
+ }
private String id;
private String deploymentTime;
private String url;
diff --git a/wfenginemgrservice/src/main/java/org/onap/workflow/externalservice/entity/activitientitiy/ActivitiStartProcessRequest.java b/wfenginemgrservice/src/main/java/org/onap/workflow/externalservice/entity/activitientitiy/ActivitiStartProcessRequest.java
index ae7edf1..a925c2f 100644
--- a/wfenginemgrservice/src/main/java/org/onap/workflow/externalservice/entity/activitientitiy/ActivitiStartProcessRequest.java
+++ b/wfenginemgrservice/src/main/java/org/onap/workflow/externalservice/entity/activitientitiy/ActivitiStartProcessRequest.java
@@ -16,10 +16,21 @@
package org.onap.workflow.externalservice.entity.activitientitiy;
-import lombok.Data;
-@Data
+
public class ActivitiStartProcessRequest {
+ public String getProcessDefinitionKey() {
+ return processDefinitionKey;
+ }
+ public void setProcessDefinitionKey(String processDefinitionKey) {
+ this.processDefinitionKey = processDefinitionKey;
+ }
+ public ActivitiStartProcessRequestParam[] getVariables() {
+ return variables;
+ }
+ public void setVariables(ActivitiStartProcessRequestParam[] variables) {
+ this.variables = variables;
+ }
private String processDefinitionKey;
private ActivitiStartProcessRequestParam[] variables;
}
diff --git a/wfenginemgrservice/src/main/java/org/onap/workflow/externalservice/entity/activitientitiy/ActivitiStartProcessRequestParam.java b/wfenginemgrservice/src/main/java/org/onap/workflow/externalservice/entity/activitientitiy/ActivitiStartProcessRequestParam.java
index 35dc487..7ca54dd 100644
--- a/wfenginemgrservice/src/main/java/org/onap/workflow/externalservice/entity/activitientitiy/ActivitiStartProcessRequestParam.java
+++ b/wfenginemgrservice/src/main/java/org/onap/workflow/externalservice/entity/activitientitiy/ActivitiStartProcessRequestParam.java
@@ -1,5 +1,5 @@
/**
- * Copyright 2017 [ZTE] and others.
+ * 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.
@@ -13,15 +13,26 @@
* See the License for the specific language governing permissions and
* limitations under the License.
*/
+
package org.onap.workflow.externalservice.entity.activitientitiy;
-import lombok.Data;
/**
*
*/
-@Data
public class ActivitiStartProcessRequestParam {
+ public String getName() {
+ return name;
+ }
+ public void setName(String name) {
+ this.name = name;
+ }
+ public String getValue() {
+ return value;
+ }
+ public void setValue(String value) {
+ this.value = value;
+ }
private String name;
private String value;
}
diff --git a/wfenginemgrservice/src/main/java/org/onap/workflow/tools/RequestParameters.java b/wfenginemgrservice/src/main/java/org/onap/workflow/tools/RequestParameters.java
index b8e76d8..8fc79ff 100644
--- a/wfenginemgrservice/src/main/java/org/onap/workflow/tools/RequestParameters.java
+++ b/wfenginemgrservice/src/main/java/org/onap/workflow/tools/RequestParameters.java
@@ -16,15 +16,19 @@
package org.onap.workflow.tools;
-import lombok.Data;
/**
* @author 10175158
*
*/
-@Data
public class RequestParameters {
+ public boolean isCasCade() {
+ return casCade;
+ }
+ public void setCasCade(boolean casCade) {
+ this.casCade = casCade;
+ }
protected boolean casCade;
@Override
public String toString() {
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));
}
}