<checksumPolicy>warn</checksumPolicy>\r
</snapshots>\r
</repository>\r
+ <repository>\r
+ <id>wfengine-staging</id>\r
+ <url>https://nexus.onap.org/content/groups/staging</url>\r
+ <releases>\r
+ <enabled>true</enabled>\r
+ <updatePolicy>always</updatePolicy>\r
+ <checksumPolicy>fail</checksumPolicy>\r
+ </releases>\r
+ <snapshots>\r
+ <enabled>false</enabled>\r
+ <updatePolicy>always</updatePolicy>\r
+ <checksumPolicy>warn</checksumPolicy>\r
+ </snapshots>\r
+ </repository>\r
<repository>\r
<id>wfengine-snapshots</id>\r
<url>https://nexus.onap.org/content/repositories/snapshots</url>\r
</snapshots>\r
</repository>\r
</repositories>\r
+ <pluginRepositories>\r
+ <pluginRepository>\r
+ <id>wfengine-releases</id>\r
+ <url>https://nexus.onap.org/content/repositories/releases</url>\r
+ </pluginRepository>\r
+ <pluginRepository>\r
+ <id>wfengine-snapshots</id>\r
+ <url>https://nexus.onap.org/content/repositories/snapshots</url>\r
+ </pluginRepository>\r
+ </pluginRepositories>\r
<build>\r
<plugins>\r
<plugin>\r
<dependency>\r
<groupId>org.onap.msb.java-sdk</groupId>\r
<artifactId>msb-java-sdk</artifactId>\r
- <version>1.0.0-SNAPSHOT</version>\r
+ <version>1.0.0</version>\r
</dependency> \r
+ <dependency>\r
+ <groupId>com.fasterxml.jackson.dataformat</groupId>\r
+ <artifactId>jackson-dataformat-xml</artifactId>\r
+ <version>2.5.1</version>\r
+ </dependency> \r
+ <dependency>\r
+ <groupId>com.fasterxml.jackson.core</groupId>\r
+ <artifactId>jackson-annotations</artifactId>\r
+ <version>2.5.1</version>\r
+ </dependency>\r
</dependencies>\r
</project>\r
-/**
- * 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.activitiext.common;
-
-
-import org.junit.Assert;
-import org.junit.Test;
-import org.junit.runner.RunWith;
-import org.onap.msb.sdk.discovery.common.RouteException;
-import org.onap.workflow.utils.MsbUtils;
-import org.powermock.api.mockito.PowerMockito;
-import org.powermock.core.classloader.annotations.PrepareForTest;
-import org.powermock.modules.junit4.PowerMockRunner;
-
-/**
- *
- */
-@PrepareForTest({MsbUtils.class})
-@RunWith(PowerMockRunner.class)
-public class EnumModuleUrlTest {
- @Test
- public void testGetBaseUrl() {
- try {
- String baseUrl = "http://127.0.0.1:80";
- PowerMockito.mockStatic(MsbUtils.class);
- PowerMockito.when(MsbUtils.getServiceAddress("catalog", "v1")).thenReturn(baseUrl);
- Assert.assertEquals(baseUrl, EnumModuleUrl.getBaseUrl(ServiceType.catalog));
- } catch (RouteException e) {
- assert (false);
- }
- }
-}
+/**\r
+ * Copyright 2017 ZTE Corporation.\r
+ *\r
+ * Licensed under the Apache License, Version 2.0 (the "License");\r
+ * you may not use this file except in compliance with the License.\r
+ * You may obtain a copy of the License at\r
+ *\r
+ * http://www.apache.org/licenses/LICENSE-2.0\r
+ *\r
+ * Unless required by applicable law or agreed to in writing, software\r
+ * distributed under the License is distributed on an "AS IS" BASIS,\r
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.\r
+ * See the License for the specific language governing permissions and\r
+ * limitations under the License.\r
+ */\r
+package org.onap.workflow.activitiext.common;\r
+\r
+\r
+import org.junit.Assert;\r
+import org.junit.Test;\r
+import org.junit.runner.RunWith;\r
+import org.onap.workflow.utils.MsbUtils;\r
+import org.powermock.api.mockito.PowerMockito;\r
+import org.powermock.core.classloader.annotations.PrepareForTest;\r
+import org.powermock.modules.junit4.PowerMockRunner;\r
+\r
+/**\r
+ *\r
+ */\r
+@PrepareForTest({MsbUtils.class})\r
+@RunWith(PowerMockRunner.class)\r
+public class EnumModuleUrlTest {\r
+ @Test\r
+ public void testGetBaseUrl() {\r
+ try {\r
+ String baseUrl = "http://127.0.0.1:80";\r
+ PowerMockito.mockStatic(MsbUtils.class);\r
+ PowerMockito.when(MsbUtils.getServiceAddress("catalog", "v1")).thenReturn(baseUrl);\r
+ Assert.assertEquals(baseUrl, EnumModuleUrl.getBaseUrl(ServiceType.catalog));\r
+ } catch (Exception e) {\r
+ assert (false);\r
+ }\r
+ }\r
+}\r
-/**
- * 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.activitiext.restservicetask;
-
-import static org.hamcrest.CoreMatchers.is;
-import static org.hamcrest.MatcherAssert.assertThat;
-
-import org.apache.commons.httpclient.HttpMethodBase;
-import org.apache.commons.httpclient.NameValuePair;
-import org.apache.commons.httpclient.methods.GetMethod;
-import org.junit.Before;
-import org.junit.Test;
-import org.junit.Assert;
-import org.junit.runner.RunWith;
-import org.mockito.Mockito;
-import org.onap.workflow.activitiext.common.RestInfo;
-import org.powermock.api.mockito.PowerMockito;
-import org.powermock.core.classloader.annotations.PrepareForTest;
-import org.powermock.modules.junit4.PowerMockRunner;
-
-@PrepareForTest({LowLevelRestApi.class})
-@RunWith(PowerMockRunner.class)
-public class HighLevelRestApiTest {
-
- private HighLevelRestApi highLevelRestApi;
-
- @Before
- public void setUp() {
- highLevelRestApi = new HighLevelRestApi();
- }
-
- @Test
- public void testInvoke() {
-
- try {
- RestInfo info = new RestInfo();
- info.setMethod("GET");
- info.setName("name");
- info.setPath("/catalog/v1");
- info.setUrl("csars");
- info.setRealUri("");
- info.setVersion("v1");
-
- HttpResponseMessage msg = new HttpResponseMessage();
- msg.setStatusCode(200);
- msg.setResponseBody(null);
- PowerMockito.mockStatic(LowLevelRestApi.class);
- PowerMockito.when(LowLevelRestApi.executeHttpMethod(Mockito.anyObject())).thenReturn(msg);
-
- assertThat(HighLevelRestApi.invoke(info), is(msg));;
- } catch (Exception e) {
- assert (false);
- }
- }
-
- @Test
- public void testGet() {
-
- try {
- HttpResponseMessage msg = new HttpResponseMessage();
- msg.setStatusCode(200);
- msg.setResponseBody(null);
- PowerMockito.mockStatic(LowLevelRestApi.class);
- PowerMockito.when(LowLevelRestApi.executeHttpMethod(Mockito.anyObject())).thenReturn(msg);
-
- String uri = "10.74.148.107/openoapi/catalog/v1/dbtest?id=5";
- String acceptValue = "application/json";
- String contentTypeValue = "application/json";
-
- assertThat(HighLevelRestApi.Get(uri, acceptValue, contentTypeValue), is(msg));
- } catch (Exception e) {
- assert (false);
- }
- }
-
- @Test
- public void testPost() {
-
- try {
- HttpResponseMessage msg = new HttpResponseMessage();
- msg.setStatusCode(200);
- msg.setResponseBody(null);
- PowerMockito.mockStatic(LowLevelRestApi.class);
- PowerMockito.when(LowLevelRestApi.executeHttpMethod(Mockito.anyObject())).thenReturn(msg);
-
- String uri = "10.74.148.107/openoapi/catalog/v1/dbtest?id=5";
- String requestBody = "{'type':'NFAR'}";
- String acceptValue = "application/json";
- String contentTypeValue = "application/json";
-
- assertThat(HighLevelRestApi.Post(uri, requestBody, acceptValue, contentTypeValue), is(msg));
- } catch (Exception e) {
- assert (false);
- }
- }
-
- @Test
- public void testDelete() {
-
- try {
- HttpResponseMessage msg = new HttpResponseMessage();
- msg.setStatusCode(200);
- msg.setResponseBody(null);
- PowerMockito.mockStatic(LowLevelRestApi.class);
- PowerMockito.when(LowLevelRestApi.executeHttpMethod(Mockito.anyObject())).thenReturn(msg);
-
- String uri = "10.74.148.107/openoapi/catalog/v1/csars/aa1bc611c9fbc08247d5ea71fd67ec3f";
- String acceptValue = "application/json";
- String contentTypeValue = "application/json";
-
- assertThat(HighLevelRestApi.Delete(uri, acceptValue, contentTypeValue), is(msg));
- } catch (Exception e) {
- assert (false);
- }
- }
-
- @Test
- public void testPut() {
-
- try {
- HttpResponseMessage msg = new HttpResponseMessage();
- msg.setStatusCode(200);
- msg.setResponseBody(null);
- PowerMockito.mockStatic(LowLevelRestApi.class);
- PowerMockito.when(LowLevelRestApi.executeHttpMethod(Mockito.anyObject())).thenReturn(msg);
-
- String uri = "10.74.148.107/openoapi/catalog/v1/csars";
- String requestBody = "{'type':'NFAR'}";
- String acceptValue = "application/json";
- String contentTypeValue = "application/json";
-
- assertThat(HighLevelRestApi.Put(uri, requestBody, acceptValue, contentTypeValue), is(msg));
- } catch (Exception e) {
- assert (false);
- }
- }
-
- @SuppressWarnings("static-access")
- @Test
- public void testCreateNameValuePairArrayFromQuery() {
- NameValuePair[] pair = new NameValuePair[2];
- NameValuePair p1 = new NameValuePair();
- p1.setName("name");
- p1.setValue("liuyao");
- NameValuePair p2 = new NameValuePair();
- p2.setName("pwd");
- p2.setValue("zte");
-
- pair[0] = p1;
- pair[1] = p2;
-
- String query = "name=liuyao&pwd=zte";
-
- assertThat(highLevelRestApi.createNameValuePairArrayFromQuery(query), is(pair));
- }
-
- @Test
- public void testSetAcceptHeader() {
- try {
- HttpMethodBase method = new GetMethod();
- HighLevelRestApi.setAcceptHeader(method, "[application/json]");
- Assert.assertTrue(true);
- } catch (Exception e) {
- Assert.assertTrue(false);
- }
- }
-
- @Test
- public void testSetContentTypeHeader() {
-
- try {
- HttpMethodBase method = new GetMethod();
- HighLevelRestApi.setContentTypeHeader(method, "[application/json]");
- Assert.assertTrue(true);
- } catch (Exception e) {
- Assert.assertTrue(false);
- }
- }
-
-}
+/**\r
+ * Copyright 2017 ZTE Corporation.\r
+ *\r
+ * Licensed under the Apache License, Version 2.0 (the "License");\r
+ * you may not use this file except in compliance with the License.\r
+ * You may obtain a copy of the License at\r
+ *\r
+ * http://www.apache.org/licenses/LICENSE-2.0\r
+ *\r
+ * Unless required by applicable law or agreed to in writing, software\r
+ * distributed under the License is distributed on an "AS IS" BASIS,\r
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.\r
+ * See the License for the specific language governing permissions and\r
+ * limitations under the License.\r
+ */\r
+package org.onap.workflow.activitiext.restservicetask;\r
+\r
+import static org.hamcrest.CoreMatchers.is;\r
+import static org.hamcrest.MatcherAssert.assertThat;\r
+\r
+import org.apache.commons.httpclient.HttpMethodBase;\r
+import org.apache.commons.httpclient.NameValuePair;\r
+import org.apache.commons.httpclient.methods.GetMethod;\r
+import org.junit.Assert;\r
+import org.junit.Test;\r
+import org.junit.runner.RunWith;\r
+import org.mockito.Mockito;\r
+import org.onap.workflow.activitiext.common.RestInfo;\r
+import org.powermock.api.mockito.PowerMockito;\r
+import org.powermock.core.classloader.annotations.PrepareForTest;\r
+import org.powermock.modules.junit4.PowerMockRunner;\r
+\r
+@PrepareForTest({LowLevelRestApi.class})\r
+@RunWith(PowerMockRunner.class)\r
+public class HighLevelRestApiTest {\r
+\r
+ @Test\r
+ public void testInvoke() {\r
+\r
+ try {\r
+ RestInfo info = new RestInfo();\r
+ info.setMethod("GET");\r
+ info.setName("name");\r
+ info.setPath("/catalog/v1");\r
+ info.setUrl("csars");\r
+ info.setRealUri("");\r
+ info.setVersion("v1");\r
+\r
+ HttpResponseMessage msg = new HttpResponseMessage();\r
+ msg.setStatusCode(200);\r
+ msg.setResponseBody(null);\r
+ PowerMockito.mockStatic(LowLevelRestApi.class);\r
+ PowerMockito.when(LowLevelRestApi.executeHttpMethod(Mockito.anyObject())).thenReturn(msg);\r
+\r
+ assertThat(HighLevelRestApi.invoke(info), is(msg));;\r
+ } catch (Exception e) {\r
+ assert (false);\r
+ }\r
+ }\r
+\r
+ @Test\r
+ public void testGet() {\r
+\r
+ try {\r
+ HttpResponseMessage msg = new HttpResponseMessage();\r
+ msg.setStatusCode(200);\r
+ msg.setResponseBody(null);\r
+ PowerMockito.mockStatic(LowLevelRestApi.class);\r
+ PowerMockito.when(LowLevelRestApi.executeHttpMethod(Mockito.anyObject())).thenReturn(msg);\r
+\r
+ String uri = "10.74.148.107/openoapi/catalog/v1/dbtest?id=5";\r
+ String acceptValue = "application/json";\r
+ String contentTypeValue = "application/json";\r
+\r
+ assertThat(HighLevelRestApi.Get(uri, acceptValue, contentTypeValue), is(msg));\r
+ } catch (Exception e) {\r
+ assert (false);\r
+ }\r
+ }\r
+\r
+ @Test\r
+ public void testPost() {\r
+\r
+ try {\r
+ HttpResponseMessage msg = new HttpResponseMessage();\r
+ msg.setStatusCode(200);\r
+ msg.setResponseBody(null);\r
+ PowerMockito.mockStatic(LowLevelRestApi.class);\r
+ PowerMockito.when(LowLevelRestApi.executeHttpMethod(Mockito.anyObject())).thenReturn(msg);\r
+\r
+ String uri = "10.74.148.107/openoapi/catalog/v1/dbtest?id=5";\r
+ String requestBody = "{'type':'NFAR'}";\r
+ String acceptValue = "application/json";\r
+ String contentTypeValue = "application/json";\r
+\r
+ assertThat(HighLevelRestApi.Post(uri, requestBody, acceptValue, contentTypeValue), is(msg));\r
+ } catch (Exception e) {\r
+ assert (false);\r
+ }\r
+ }\r
+\r
+ @Test\r
+ public void testDelete() {\r
+\r
+ try {\r
+ HttpResponseMessage msg = new HttpResponseMessage();\r
+ msg.setStatusCode(200);\r
+ msg.setResponseBody(null);\r
+ PowerMockito.mockStatic(LowLevelRestApi.class);\r
+ PowerMockito.when(LowLevelRestApi.executeHttpMethod(Mockito.anyObject())).thenReturn(msg);\r
+\r
+ String uri = "10.74.148.107/openoapi/catalog/v1/csars/aa1bc611c9fbc08247d5ea71fd67ec3f";\r
+ String acceptValue = "application/json";\r
+ String contentTypeValue = "application/json";\r
+\r
+ assertThat(HighLevelRestApi.Delete(uri, acceptValue, contentTypeValue), is(msg));\r
+ } catch (Exception e) {\r
+ assert (false);\r
+ }\r
+ }\r
+\r
+ @Test\r
+ public void testPut() {\r
+\r
+ try {\r
+ HttpResponseMessage msg = new HttpResponseMessage();\r
+ msg.setStatusCode(200);\r
+ msg.setResponseBody(null);\r
+ PowerMockito.mockStatic(LowLevelRestApi.class);\r
+ PowerMockito.when(LowLevelRestApi.executeHttpMethod(Mockito.anyObject())).thenReturn(msg);\r
+\r
+ String uri = "10.74.148.107/openoapi/catalog/v1/csars";\r
+ String requestBody = "{'type':'NFAR'}";\r
+ String acceptValue = "application/json";\r
+ String contentTypeValue = "application/json";\r
+\r
+ assertThat(HighLevelRestApi.Put(uri, requestBody, acceptValue, contentTypeValue), is(msg));\r
+ } catch (Exception e) {\r
+ assert (false);\r
+ }\r
+ }\r
+\r
+ @SuppressWarnings("static-access")\r
+ @Test\r
+ public void testCreateNameValuePairArrayFromQuery() {\r
+ NameValuePair[] pair = new NameValuePair[2];\r
+ NameValuePair p1 = new NameValuePair();\r
+ p1.setName("name");\r
+ p1.setValue("liuyao");\r
+ NameValuePair p2 = new NameValuePair();\r
+ p2.setName("pwd");\r
+ p2.setValue("zte");\r
+\r
+ pair[0] = p1;\r
+ pair[1] = p2;\r
+\r
+ String query = "name=liuyao&pwd=zte";\r
+\r
+ assertThat(HighLevelRestApi.createNameValuePairArrayFromQuery(query), is(pair));\r
+ }\r
+\r
+ @Test\r
+ public void testSetAcceptHeader() {\r
+ try {\r
+ HttpMethodBase method = new GetMethod();\r
+ HighLevelRestApi.setAcceptHeader(method, "[application/json]");\r
+ Assert.assertTrue(true);\r
+ } catch (Exception e) {\r
+ Assert.assertTrue(false);\r
+ }\r
+ }\r
+\r
+ @Test\r
+ public void testSetContentTypeHeader() {\r
+\r
+ try {\r
+ HttpMethodBase method = new GetMethod();\r
+ HighLevelRestApi.setContentTypeHeader(method, "[application/json]");\r
+ Assert.assertTrue(true);\r
+ } catch (Exception e) {\r
+ Assert.assertTrue(false);\r
+ }\r
+ }\r
+\r
+}\r
-/**
- * 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.activitiext.restservicetask;
-
-import static org.hamcrest.CoreMatchers.is;
-import static org.hamcrest.MatcherAssert.assertThat;
-
-import org.junit.Test;
-
-import com.alibaba.fastjson.JSON;
-
-public class HttpResponseMessageTest {
-
- @Test
- public void testToString(){
-
- String json = "{'name':'robert'}";
- JSON obj = (JSON) JSON.parse(json);
-
- HttpResponseMessage msg = new HttpResponseMessage();
- msg.setStatusCode(200);
- msg.setResponseBody(obj);
-
- String result = "{statusCode=200, responseBody={\"name\":\"robert\"}}";
-
- assertThat(msg.toString(), is(result));
- }
-}
+/**\r
+ * Copyright 2017 ZTE Corporation.\r
+ *\r
+ * Licensed under the Apache License, Version 2.0 (the "License");\r
+ * you may not use this file except in compliance with the License.\r
+ * You may obtain a copy of the License at\r
+ *\r
+ * http://www.apache.org/licenses/LICENSE-2.0\r
+ *\r
+ * Unless required by applicable law or agreed to in writing, software\r
+ * distributed under the License is distributed on an "AS IS" BASIS,\r
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.\r
+ * See the License for the specific language governing permissions and\r
+ * limitations under the License.\r
+ */\r
+package org.onap.workflow.activitiext.restservicetask;\r
+\r
+import static org.hamcrest.CoreMatchers.is;\r
+import static org.hamcrest.MatcherAssert.assertThat;\r
+\r
+import org.junit.Test;\r
+\r
+import com.alibaba.fastjson.JSON;\r
+\r
+public class HttpResponseMessageTest {\r
+\r
+ @Test\r
+ public void testToString(){\r
+ \r
+ String json = "{'name':'robert'}";\r
+ JSON obj = (JSON) JSON.parse(json);\r
+ \r
+ HttpResponseMessage msg = new HttpResponseMessage();\r
+ msg.setStatusCode(200);\r
+ msg.setResponseBody(obj);\r
+\r
+ String result = "{statusCode=" + msg.getStatusCode() + ", responseBody=" + msg.getResponseBody() + "}";\r
+\r
+ assertThat(msg.toString(), is(result));\r
+ }\r
+}\r
-/**
- * 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.activitiext.restservicetask;
-
-import static org.powermock.api.mockito.PowerMockito.mock;
-
-import org.activiti.engine.ActivitiException;
-import org.activiti.engine.delegate.DelegateExecution;
-import org.activiti.engine.delegate.Expression;
-import org.activiti.engine.impl.persistence.entity.ExecutionEntity;
-import org.junit.Assert;
-import org.junit.Before;
-import org.junit.Test;
-import org.onap.workflow.activitiext.common.Parameter;
-import org.onap.workflow.activitiext.common.RestInfo;
-import org.powermock.api.mockito.PowerMockito;
-
-import com.alibaba.fastjson.JSON;
-
-public class HttpUtilTest {
-
- private HttpUtil httpUtil;
-
- @Before
- public void setUp() {
- httpUtil = new HttpUtil();
- }
-
- @Test
- public void testExecute() {
-
- try {
- DelegateExecution executionEntity = mock(ExecutionEntity.class);
- HttpUtil httpUtil1 = mock(HttpUtil.class);
- PowerMockito.when(httpUtil1.executeMethod(executionEntity)).thenReturn(true);
- httpUtil1.execute(executionEntity);
- Assert.assertTrue(true);
- } catch (Exception e) {
- Assert.assertTrue(false);
- }
- }
-
- @Test
- public void testExecuteMethod() {
-
- DelegateExecution executionEntity = mock(ExecutionEntity.class);
- try {
- PowerMockito.when(executionEntity.getCurrentActivityId()).thenReturn("1111");
- HttpResponseMessage msg = new HttpResponseMessage();
- msg.setStatusCode(200);
- msg.setResponseBody(null);
- httpUtil.executeMethod(executionEntity);
- Assert.assertTrue(false);
- } catch (Exception e) {
- Assert.assertTrue(true);
- }
- }
-
- @Test
- public void testHandleParam1() {
-
- try {
- DelegateExecution executionEntity = mock(ExecutionEntity.class);
- Parameter param = new Parameter();
- param.setName("id");
- param.setPosition("path");
- param.setType("");
- param.setValue("abc");
-
- RestInfo info = new RestInfo();
- info.setMethod("GET");
- info.setName("name");
- info.setPath("/catalog/v1");
- info.setRealUri("");
- info.setUrl("csars");
- info.setVersion("v1");
-
- httpUtil.handleParam(executionEntity, param, info);
- Assert.assertTrue(true);
- } catch (ActivitiException e) {
- Assert.assertTrue(true);
- }
-
- }
-
- @Test
- public void testHandleParam2() {
- try {
- DelegateExecution executionEntity = mock(ExecutionEntity.class);
- Parameter param = new Parameter();
- param.setName("id");
- param.setPosition("query");
- param.setType("");
- param.setValue("abc");
-
- RestInfo info = new RestInfo();
- info.setMethod("GET");
- info.setName("name");
- info.setPath("/catalog/v1");
- info.setRealUri("");
- info.setUrl("csars");
- info.setVersion("v1");
-
- httpUtil.handleParam(executionEntity, param, info);
- Assert.assertTrue(true);
- } catch (ActivitiException e) {
- Assert.assertTrue(true);
- }
-
- }
-
- @Test
- public void testGetValue() {
- DelegateExecution executionEntity = mock(ExecutionEntity.class);
- Expression expression = mock(Expression.class);
- Object res = new String("result");
-
- PowerMockito.when(expression.getValue(executionEntity)).thenReturn(res);
-
- Assert.assertEquals(res, httpUtil.getValue(expression, executionEntity));
- }
-
- @SuppressWarnings("static-access")
- @Test
- public void testParsePlanExpression() {
-
- String exp = "[node0].[responseBody].[id]";
- String json = "{'id':'123'}";
- JSON obj = (JSON) JSON.parse(json);
- HttpResponseMessage msg = new HttpResponseMessage();
- msg.setStatusCode(200);
- msg.setResponseBody(obj);
-
- DelegateExecution executionEntity = mock(ExecutionEntity.class);
-
- PowerMockito.when(executionEntity.getVariable("node0")).thenReturn(msg);
-
- Assert.assertEquals("123", httpUtil.parsePlanExpression(exp, executionEntity));
- }
-}
+/**\r
+ * Copyright 2017 ZTE Corporation.\r
+ *\r
+ * Licensed under the Apache License, Version 2.0 (the "License");\r
+ * you may not use this file except in compliance with the License.\r
+ * You may obtain a copy of the License at\r
+ *\r
+ * http://www.apache.org/licenses/LICENSE-2.0\r
+ *\r
+ * Unless required by applicable law or agreed to in writing, software\r
+ * distributed under the License is distributed on an "AS IS" BASIS,\r
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.\r
+ * See the License for the specific language governing permissions and\r
+ * limitations under the License.\r
+ */\r
+package org.onap.workflow.activitiext.restservicetask;\r
+\r
+import static org.powermock.api.mockito.PowerMockito.mock;\r
+\r
+import org.activiti.engine.ActivitiException;\r
+import org.activiti.engine.delegate.DelegateExecution;\r
+import org.activiti.engine.delegate.Expression;\r
+import org.activiti.engine.impl.persistence.entity.ExecutionEntity;\r
+import org.junit.Assert;\r
+import org.junit.Before;\r
+import org.junit.Test;\r
+import org.onap.workflow.activitiext.common.Parameter;\r
+import org.onap.workflow.activitiext.common.RestInfo;\r
+import org.powermock.api.mockito.PowerMockito;\r
+\r
+import com.alibaba.fastjson.JSON;\r
+\r
+public class HttpUtilTest {\r
+\r
+ private HttpUtil httpUtil;\r
+\r
+ @Before\r
+ public void setUp() {\r
+ httpUtil = new HttpUtil();\r
+ }\r
+\r
+ @Test\r
+ public void testExecuteMethod() {\r
+\r
+ DelegateExecution executionEntity = mock(ExecutionEntity.class);\r
+ try {\r
+ PowerMockito.when(executionEntity.getCurrentActivityId()).thenReturn("1111");\r
+ HttpResponseMessage msg = new HttpResponseMessage();\r
+ msg.setStatusCode(200);\r
+ msg.setResponseBody(null);\r
+ httpUtil.execute(executionEntity);\r
+ Assert.assertTrue(false);\r
+ } catch (Exception e) {\r
+ Assert.assertTrue(true);\r
+ }\r
+ }\r
+\r
+ @Test\r
+ public void testHandleParam1() {\r
+\r
+ try {\r
+ DelegateExecution executionEntity = mock(ExecutionEntity.class);\r
+ Parameter param = new Parameter();\r
+ param.setName("id");\r
+ param.setPosition("path");\r
+ param.setType("");\r
+ param.setValue("abc");\r
+\r
+ RestInfo info = new RestInfo();\r
+ info.setMethod("GET");\r
+ info.setName("name");\r
+ info.setPath("/catalog/v1");\r
+ info.setRealUri("");\r
+ info.setUrl("csars");\r
+ info.setVersion("v1");\r
+\r
+ httpUtil.handleParam(executionEntity, param, info);\r
+ Assert.assertTrue(true);\r
+ } catch (ActivitiException e) {\r
+ Assert.assertTrue(true);\r
+ }\r
+\r
+ }\r
+\r
+ @Test\r
+ public void testHandleParam2() {\r
+ try {\r
+ DelegateExecution executionEntity = mock(ExecutionEntity.class);\r
+ Parameter param = new Parameter();\r
+ param.setName("id");\r
+ param.setPosition("query");\r
+ param.setType("");\r
+ param.setValue("abc");\r
+\r
+ RestInfo info = new RestInfo();\r
+ info.setMethod("GET");\r
+ info.setName("name");\r
+ info.setPath("/catalog/v1");\r
+ info.setRealUri("");\r
+ info.setUrl("csars");\r
+ info.setVersion("v1");\r
+\r
+ httpUtil.handleParam(executionEntity, param, info);\r
+ Assert.assertTrue(true);\r
+ } catch (ActivitiException e) {\r
+ Assert.assertTrue(true);\r
+ }\r
+ }\r
+ \r
+ @Test\r
+ public void testHandleParam3() {\r
+ try {\r
+ DelegateExecution executionEntity = mock(ExecutionEntity.class);\r
+ Parameter param = new Parameter();\r
+ param.setName("id");\r
+ param.setPosition("body");\r
+ param.setType("");\r
+ param.setValue("{'value':{'progress':{'value':'60','valueSource':'String'},'errcode':{'value':'200','valueSource':'Variable'},'desc':{'value':'','valueSource':'String'}},'valueSource':'Definition'}");\r
+\r
+ RestInfo info = new RestInfo();\r
+ info.setMethod("GET");\r
+ info.setName("name");\r
+ info.setPath("/catalog/v1");\r
+ info.setRealUri("");\r
+ info.setUrl("csars");\r
+ info.setVersion("v1");\r
+\r
+ httpUtil.handleParam(executionEntity, param, info);\r
+ Assert.assertTrue(true);\r
+ } catch (ActivitiException e) {\r
+ Assert.assertTrue(true);\r
+ }\r
+ }\r
+\r
+ @Test\r
+ public void testGetValue() {\r
+ DelegateExecution executionEntity = mock(ExecutionEntity.class);\r
+ Expression expression = mock(Expression.class);\r
+ Object res = new String("result");\r
+\r
+ PowerMockito.when(expression.getValue(executionEntity)).thenReturn(res);\r
+\r
+ Assert.assertEquals(res, httpUtil.getValue(expression, executionEntity));\r
+ }\r
+\r
+ @SuppressWarnings("static-access")\r
+ @Test\r
+ public void testParsePlanExpression() {\r
+\r
+ String exp = "[node0].[responseBody].[id]";\r
+ String json = "{'id':'123'}";\r
+ JSON obj = (JSON) JSON.parse(json);\r
+ HttpResponseMessage msg = new HttpResponseMessage();\r
+ msg.setStatusCode(200);\r
+ msg.setResponseBody(obj);\r
+\r
+ DelegateExecution executionEntity = mock(ExecutionEntity.class);\r
+\r
+ PowerMockito.when(executionEntity.getVariable("node0")).thenReturn(msg);\r
+\r
+ Assert.assertEquals("123", httpUtil.parsePlanExpression(exp, executionEntity));\r
+ }\r
+}\r
<checksumPolicy>warn</checksumPolicy>\r
</snapshots>\r
</repository>\r
+ <repository>\r
+ <id>wfengine-staging</id>\r
+ <url>https://nexus.onap.org/content/groups/staging</url>\r
+ <releases>\r
+ <enabled>true</enabled>\r
+ <updatePolicy>always</updatePolicy>\r
+ <checksumPolicy>fail</checksumPolicy>\r
+ </releases>\r
+ <snapshots>\r
+ <enabled>false</enabled>\r
+ <updatePolicy>always</updatePolicy>\r
+ <checksumPolicy>warn</checksumPolicy>\r
+ </snapshots>\r
+ </repository>\r
<repository>\r
<id>wfengine-snapshots</id>\r
<url>https://nexus.onap.org/content/repositories/snapshots</url>\r
<checksumPolicy>warn</checksumPolicy>\r
</snapshots>\r
</repository>\r
+ <repository>\r
+ <id>wfengine-staging</id>\r
+ <url>https://nexus.onap.org/content/groups/staging</url>\r
+ <releases>\r
+ <enabled>true</enabled>\r
+ <updatePolicy>always</updatePolicy>\r
+ <checksumPolicy>fail</checksumPolicy>\r
+ </releases>\r
+ <snapshots>\r
+ <enabled>false</enabled>\r
+ <updatePolicy>always</updatePolicy>\r
+ <checksumPolicy>warn</checksumPolicy>\r
+ </snapshots>\r
+ </repository>\r
<repository>\r
<id>wfengine-snapshots</id>\r
<url>https://nexus.onap.org/content/repositories/snapshots</url>\r
</snapshots>\r
</repository>\r
</repositories>\r
+ <pluginRepositories>\r
+ <pluginRepository>\r
+ <id>wfengine-releases</id>\r
+ <url>https://nexus.onap.org/content/repositories/releases</url>\r
+ </pluginRepository>\r
+ <pluginRepository>\r
+ <id>wfengine-snapshots</id>\r
+ <url>https://nexus.onap.org/content/repositories/snapshots</url>\r
+ </pluginRepository>\r
+ </pluginRepositories>\r
<build>\r
<plugins>\r
<plugin>\r
-/**
- * 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.IOException;
-
-import org.apache.http.HttpEntity;
-import org.apache.http.HttpHost;
-import org.apache.http.HttpRequest;
-import org.apache.http.HttpResponse;
-import org.apache.http.client.ClientProtocolException;
-import org.apache.http.client.ResponseHandler;
-import org.apache.http.client.methods.CloseableHttpResponse;
-import org.apache.http.client.methods.HttpDelete;
-import org.apache.http.client.methods.HttpGet;
-import org.apache.http.client.methods.HttpPost;
-import org.apache.http.client.methods.HttpPut;
-import org.apache.http.entity.StringEntity;
-import org.apache.http.impl.client.BasicResponseHandler;
-import org.apache.http.impl.client.CloseableHttpClient;
-import org.apache.http.impl.client.HttpClients;
-import org.apache.http.util.EntityUtils;
-import org.onap.workflow.externalservice.entity.activitientitiy.ActivitiStartProcessRequest;
-import org.onap.workflow.tools.Constants;
-import org.onap.workflow.tools.HttpDeleteWithBody;
-import org.onap.workflow.tools.RequestParameters;
-import org.slf4j.Logger;
-import org.slf4j.LoggerFactory;
-
-import com.google.gson.Gson;
-
-public class RestClient {
- private static final String HTTP = "http";
- private static final Logger logger = LoggerFactory.getLogger(RestClient.class);
-
- public enum HttpMethod {
- GET, POST, PUT, DELETE
- }
-
- /**
- *
- * @param method
- * @param ip
- * @param port
- * @param url
- * @param body
- * @return
- * @throws ClientProtocolException
- * @throws IOException
- */
- public static RestResponse executeHttp(HttpMethod method, String ip, Integer port, String url,
- HttpEntity body) throws ClientProtocolException, IOException {
- logger.info("deployfile method send");
- CloseableHttpClient httpclient = HttpClients.createDefault();
- HttpResponse httpResponse = null;
- RestResponse result = new RestResponse();
- try {
- if (ip == null) {
- ip = Config.getWorkflowAppConfig().getMsbClientConfig().getMsbSvrIp();
- }
- if (port == null) {
- port = Config.getWorkflowAppConfig().getMsbClientConfig().getMsbSvrPort();
- }
- HttpHost target = new HttpHost(ip, port, HTTP);
- HttpRequest request = getRequest(method, url, body);
- logger.info("deployfile method send ip" + ip);
- request.addHeader(Constants.AUTHORIZATION, ToolUtil.getHeader());
-
- httpResponse = httpclient.execute(target, request);
- HttpEntity entity = httpResponse.getEntity();
- logger.info("deployfile method send");
- if (entity != null && httpResponse.getStatusLine()!=null) {
- result.setStatusCode(httpResponse.getStatusLine().getStatusCode());
- logger.info("reply status code deploy"+httpResponse.getStatusLine().getStatusCode());
- result.setResult(EntityUtils.toString(entity));
- }
- } catch (IOException e) {
- logger.warn("Close httpclient failed.", e);
- } finally {
- if (httpclient != null) {
- try {
- httpclient.close();
- } catch (IOException e) {
- logger.warn("Close httpclient failed.", e);
- }
- }
- }
- return result;
- }
-
- public static HttpRequest getRequest(HttpMethod method, String url, HttpEntity body) {
- HttpRequest request = null;
- switch (method) {
- case GET:
- request = new HttpGet(url);
- break;
- case POST:
- request = new HttpPost(url);
- ((HttpPost) request).setEntity(body);
- break;
- case PUT:
- request = new HttpPut(url);
- ((HttpPut) request).setEntity(body);
- break;
- case DELETE:
- request = new HttpDelete(url);
- break;
- default:
- break;
- }
- return request;
- }
-
- /**
- *
- * @param ip
- * @param port
- * @param url
- * @param requestBody
- * @return
- * @throws ClientProtocolException
- * @throws IOException
- */
- public static RestResponse post(String ip, int port, String url, HttpEntity requestBody)
- throws ClientProtocolException, IOException {
- return executeHttp(HttpMethod.POST, ip, port, url, requestBody);
- }
-
-
-
- /**
- *
- * @param method
- * @param ip
- * @param port
- * @param url
- * @param body
- * @return
- * @throws ClientProtocolException
- * @throws IOException
- */
- public static RestResponse executeHttpDeleteDeploy(HttpMethod method, String ip, Integer port,
- String url) throws ClientProtocolException, IOException {
- if (ip == null) {
- ip = Config.getWorkflowAppConfig().getMsbClientConfig().getMsbSvrIp();
- }
- if(port==null) {
- port = Config.getWorkflowAppConfig().getMsbClientConfig().getMsbSvrPort();
- }
- RestResponse result = new RestResponse();
- CloseableHttpClient httpClient = HttpClients.createDefault();
- try {
- httpClient = HttpClients.createDefault();
- // "http://localhost:8080/activiti-rest/service/repository/deployments/167501"
- String deleteUrl = Constants.HTTP_HEADER + ip + Constants.COLON + port + url;
- HttpDeleteWithBody httpDeteTest = new HttpDeleteWithBody(deleteUrl);
- Gson gson = new Gson();
- RequestParameters reqPa = new RequestParameters();
- reqPa.setCasCade(true);
- String jsonStr = gson.toJson(reqPa, RequestParameters.class);
- StringEntity requestEntity = new StringEntity(jsonStr, "UTF-8");
- requestEntity.setContentEncoding("UTF-8");
- httpDeteTest.setHeader("Content-type", "application/json");
- httpDeteTest.setHeader(Constants.AUTHORIZATION, ToolUtil.getHeader());
- httpDeteTest.setEntity(new StringEntity(jsonStr));
- // returnValue = httpClient.execute(httpDeteTest, responseHandler); // 调接口获取返回值时，必须用此方法
- CloseableHttpResponse httpResonse = httpClient.execute(httpDeteTest);
- if(httpResonse!=null && httpResonse.getStatusLine()!=null) {
- int statusCode = httpResonse.getStatusLine().getStatusCode();
- result.setStatusCode(statusCode);
- }
- // result.setResult(EntityUtils.toString(httpResonse.getEntity()));
- } catch (Exception e) {
- e.printStackTrace();
- }
-
- finally {
- try {
- httpClient.close();
- } catch (IOException e) {
- // TODO Auto-generated catch block
- e.printStackTrace();
- }
- }
-
- return result;
- }
-
- /**
- *
- * @param method
- * @param ip
- * @param port
- * @param url
- * @param body
- * @return
- * @throws ClientProtocolException
- * @throws IOException
- */
- public static RestResponse executeHttpStartIntance(HttpMethod method, String ip, Integer port,
- String url, ActivitiStartProcessRequest object) throws ClientProtocolException, IOException {
- String returnValue = "";
- RestResponse result = new RestResponse();
- CloseableHttpClient httpClient = HttpClients.createDefault();
- ResponseHandler<String> responseHandler = new BasicResponseHandler();
- try {
- httpClient = HttpClients.createDefault();
- if (ip == null) {
- ip = Config.getWorkflowAppConfig().getMsbClientConfig().getMsbSvrIp();
- }
- if(ip==null) {
- port = Config.getWorkflowAppConfig().getMsbClientConfig().getMsbSvrPort();
- }
- HttpPost httpPost = new HttpPost(Constants.HTTP_HEADER + ip + ":" + port + url);
- Gson gson = new Gson();
- String jsonStr = gson.toJson(object, ActivitiStartProcessRequest.class);
- StringEntity requestEntity = new StringEntity(jsonStr, "utf-8");
- requestEntity.setContentEncoding("UTF-8");
- httpPost.setHeader("Content-type", "application/json");
- httpPost.setHeader(Constants.AUTHORIZATION, ToolUtil.getHeader());
- httpPost.setEntity(requestEntity);
- returnValue = httpClient.execute(httpPost, responseHandler); // 调接口获取返回值时，必须用此方法
- CloseableHttpResponse httpResonse = httpClient.execute(httpPost);
- if(httpResonse!=null && httpResonse.getStatusLine()!=null) {
- int statusCode = httpResonse.getStatusLine().getStatusCode();
- returnValue = EntityUtils.toString(httpResonse.getEntity(), "UTF-8");
- result.setStatusCode(statusCode);
- result.setResult(returnValue);
- }
- } catch (Exception e) {
- e.printStackTrace();
- }
-
- finally {
- try {
- httpClient.close();
- } catch (IOException e) {
- // TODO Auto-generated catch block
- e.printStackTrace();
- }
- }
-
- return result;
- }
-
- /**
- *
- * @param ip
- * @param port
- * @param url
- * @param requestBody
- * @return
- * @throws ClientProtocolException
- * @throws IOException
- */
- public static RestResponse post(String ip, Integer port, String url,
- ActivitiStartProcessRequest requestBody) throws ClientProtocolException, IOException {
- return executeHttpStartIntance(HttpMethod.POST, ip, port, url, requestBody);
- }
-
- /**
- *
- * @param ip
- * @param port
- * @param url
- * @param requestBody
- * @return
- * @throws ClientProtocolException
- * @throws IOException
- */
- public static RestResponse post(String ip, Integer port, String url)
- throws ClientProtocolException, IOException {
- return executeHttpDeleteDeploy(HttpMethod.DELETE, ip, port, url);
- }
-
-}
+/**\r
+ * Copyright 2017 ZTE Corporation.\r
+ *\r
+ * Licensed under the Apache License, Version 2.0 (the "License");\r
+ * you may not use this file except in compliance with the License.\r
+ * You may obtain a copy of the License at\r
+ *\r
+ * http://www.apache.org/licenses/LICENSE-2.0\r
+ *\r
+ * Unless required by applicable law or agreed to in writing, software\r
+ * distributed under the License is distributed on an "AS IS" BASIS,\r
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.\r
+ * See the License for the specific language governing permissions and\r
+ * limitations under the License.\r
+ */\r
+package org.onap.workflow.common;\r
+\r
+import java.io.IOException;\r
+\r
+import org.apache.http.HttpEntity;\r
+import org.apache.http.HttpHost;\r
+import org.apache.http.HttpRequest;\r
+import org.apache.http.HttpResponse;\r
+import org.apache.http.client.ClientProtocolException;\r
+import org.apache.http.client.ResponseHandler;\r
+import org.apache.http.client.methods.CloseableHttpResponse;\r
+import org.apache.http.client.methods.HttpDelete;\r
+import org.apache.http.client.methods.HttpGet;\r
+import org.apache.http.client.methods.HttpPost;\r
+import org.apache.http.client.methods.HttpPut;\r
+import org.apache.http.entity.StringEntity;\r
+import org.apache.http.impl.client.BasicResponseHandler;\r
+import org.apache.http.impl.client.CloseableHttpClient;\r
+import org.apache.http.impl.client.HttpClients;\r
+import org.apache.http.util.EntityUtils;\r
+import org.onap.workflow.externalservice.entity.activitientitiy.ActivitiStartProcessRequest;\r
+import org.onap.workflow.tools.Constants;\r
+import org.onap.workflow.tools.HttpDeleteWithBody;\r
+import org.onap.workflow.tools.RequestParameters;\r
+import org.slf4j.Logger;\r
+import org.slf4j.LoggerFactory;\r
+\r
+import com.google.gson.Gson;\r
+\r
+public class RestClient {\r
+ private static final String HTTP = "http";\r
+ private static final Logger logger = LoggerFactory.getLogger(RestClient.class);\r
+ public static boolean isTest = false;\r
+\r
+ public enum HttpMethod {\r
+ GET, POST, PUT, DELETE\r
+ }\r
+\r
+ /**\r
+ * \r
+ * @param method\r
+ * @param ip\r
+ * @param port\r
+ * @param url\r
+ * @param body\r
+ * @return\r
+ * @throws ClientProtocolException\r
+ * @throws IOException\r
+ */\r
+ public static RestResponse executeHttp(HttpMethod method, String ip, Integer port, String url,\r
+ HttpEntity body) throws ClientProtocolException, IOException {\r
+ if (isTest) {\r
+ return new RestResponse();\r
+ }\r
+\r
+ logger.info("deployfile method send");\r
+ CloseableHttpClient httpclient = HttpClients.createDefault();\r
+ HttpResponse httpResponse = null;\r
+ RestResponse result = new RestResponse();\r
+ try {\r
+ if (ip == null) {\r
+ ip = Config.getWorkflowAppConfig().getMsbClientConfig().getMsbSvrIp();\r
+ }\r
+ if (port == null) {\r
+ port = Config.getWorkflowAppConfig().getMsbClientConfig().getMsbSvrPort();\r
+ }\r
+ HttpHost target = new HttpHost(ip, port, HTTP);\r
+ HttpRequest request = getRequest(method, url, body);\r
+ logger.info("deployfile method send ip" + ip);\r
+ request.addHeader(Constants.AUTHORIZATION, ToolUtil.getHeader());\r
+\r
+ httpResponse = httpclient.execute(target, request);\r
+ HttpEntity entity = httpResponse.getEntity();\r
+ logger.info("deployfile method send");\r
+ if (entity != null && httpResponse.getStatusLine() != null) {\r
+ result.setStatusCode(httpResponse.getStatusLine().getStatusCode());\r
+ logger.info("reply status code deploy" + httpResponse.getStatusLine().getStatusCode());\r
+ result.setResult(EntityUtils.toString(entity));\r
+ }\r
+ } catch (IOException e) {\r
+ logger.warn("Close httpclient failed.", e);\r
+ } finally {\r
+ closeHttpClient(httpclient);\r
+ }\r
+ return result;\r
+ }\r
+\r
+ public static boolean closeHttpClient(CloseableHttpClient httpclient) {\r
+ if (httpclient != null) {\r
+ try {\r
+ httpclient.close();\r
+ return true;\r
+ } catch (IOException e) {\r
+ logger.warn("Close httpclient failed.", e);\r
+ return false;\r
+ }\r
+ }\r
+ return true;\r
+ }\r
+\r
+ public static HttpRequest getRequest(HttpMethod method, String url, HttpEntity body) {\r
+ HttpRequest request = null;\r
+ switch (method) {\r
+ case GET:\r
+ request = new HttpGet(url);\r
+ break;\r
+ case POST:\r
+ request = new HttpPost(url);\r
+ ((HttpPost) request).setEntity(body);\r
+ break;\r
+ case PUT:\r
+ request = new HttpPut(url);\r
+ ((HttpPut) request).setEntity(body);\r
+ break;\r
+ case DELETE:\r
+ request = new HttpDelete(url);\r
+ break;\r
+ default:\r
+ break;\r
+ }\r
+ return request;\r
+ }\r
+\r
+ /**\r
+ * \r
+ * @param ip\r
+ * @param port\r
+ * @param url\r
+ * @param requestBody\r
+ * @return\r
+ * @throws ClientProtocolException\r
+ * @throws IOException\r
+ */\r
+ public static RestResponse post(String ip, int port, String url, HttpEntity requestBody)\r
+ throws ClientProtocolException, IOException {\r
+ return executeHttp(HttpMethod.POST, ip, port, url, requestBody);\r
+ }\r
+\r
+\r
+\r
+ /**\r
+ * \r
+ * @param method\r
+ * @param ip\r
+ * @param port\r
+ * @param url\r
+ * @param body\r
+ * @return\r
+ * @throws ClientProtocolException\r
+ * @throws IOException\r
+ */\r
+ public static RestResponse executeHttpDeleteDeploy(HttpMethod method, String ip, Integer port,\r
+ String url) throws ClientProtocolException, IOException {\r
+ if (isTest) {\r
+ return new RestResponse();\r
+ }\r
+ if (ip == null) {\r
+ ip = Config.getWorkflowAppConfig().getMsbClientConfig().getMsbSvrIp();\r
+ }\r
+ if (port == null) {\r
+ port = Config.getWorkflowAppConfig().getMsbClientConfig().getMsbSvrPort();\r
+ }\r
+ RestResponse result = new RestResponse();\r
+ CloseableHttpClient httpClient = HttpClients.createDefault();\r
+ try {\r
+ httpClient = HttpClients.createDefault();\r
+ // "http://localhost:8080/activiti-rest/service/repository/deployments/167501"\r
+ String deleteUrl = Constants.HTTP_HEADER + ip + Constants.COLON + port + url;\r
+ HttpDeleteWithBody httpDeteTest = new HttpDeleteWithBody(deleteUrl);\r
+ Gson gson = new Gson();\r
+ RequestParameters reqPa = new RequestParameters();\r
+ reqPa.setCasCade(true);\r
+ String jsonStr = gson.toJson(reqPa, RequestParameters.class);\r
+ StringEntity requestEntity = new StringEntity(jsonStr, "UTF-8");\r
+ requestEntity.setContentEncoding("UTF-8");\r
+ httpDeteTest.setHeader("Content-type", "application/json");\r
+ httpDeteTest.setHeader(Constants.AUTHORIZATION, ToolUtil.getHeader());\r
+ httpDeteTest.setEntity(new StringEntity(jsonStr));\r
+ // returnValue = httpClient.execute(httpDeteTest, responseHandler); // 调接口获取返回值时，必须用此方法\r
+ CloseableHttpResponse httpResonse = httpClient.execute(httpDeteTest);\r
+ if (httpResonse != null && httpResonse.getStatusLine() != null) {\r
+ int statusCode = httpResonse.getStatusLine().getStatusCode();\r
+ result.setStatusCode(statusCode);\r
+ }\r
+ // result.setResult(EntityUtils.toString(httpResonse.getEntity()));\r
+ } catch (Exception e) {\r
+ e.printStackTrace();\r
+ } finally {\r
+ closeHttpClient(httpClient);\r
+ }\r
+\r
+ return result;\r
+ }\r
+\r
+ /**\r
+ * \r
+ * @param method\r
+ * @param ip\r
+ * @param port\r
+ * @param url\r
+ * @param body\r
+ * @return\r
+ * @throws ClientProtocolException\r
+ * @throws IOException\r
+ */\r
+ public static RestResponse executeHttpStartIntance(HttpMethod method, String ip, Integer port,\r
+ String url, ActivitiStartProcessRequest object) throws ClientProtocolException, IOException {\r
+ if (isTest) {\r
+ return new RestResponse();\r
+ }\r
+ String returnValue = "";\r
+ RestResponse result = new RestResponse();\r
+ CloseableHttpClient httpClient = HttpClients.createDefault();\r
+ ResponseHandler<String> responseHandler = new BasicResponseHandler();\r
+ try {\r
+ httpClient = HttpClients.createDefault();\r
+ if (ip == null) {\r
+ ip = Config.getWorkflowAppConfig().getMsbClientConfig().getMsbSvrIp();\r
+ }\r
+ if (port == null) {\r
+ port = Config.getWorkflowAppConfig().getMsbClientConfig().getMsbSvrPort();\r
+ }\r
+ HttpPost httpPost = new HttpPost(Constants.HTTP_HEADER + ip + ":" + port + url);\r
+ Gson gson = new Gson();\r
+ String jsonStr = gson.toJson(object, ActivitiStartProcessRequest.class);\r
+ StringEntity requestEntity = new StringEntity(jsonStr, "utf-8");\r
+ requestEntity.setContentEncoding("UTF-8");\r
+ httpPost.setHeader("Content-type", "application/json");\r
+ httpPost.setHeader(Constants.AUTHORIZATION, ToolUtil.getHeader());\r
+ httpPost.setEntity(requestEntity);\r
+ returnValue = httpClient.execute(httpPost, responseHandler); // 调接口获取返回值时，必须用此方法\r
+ CloseableHttpResponse httpResonse = httpClient.execute(httpPost);\r
+ if (httpResonse != null && httpResonse.getStatusLine() != null) {\r
+ int statusCode = httpResonse.getStatusLine().getStatusCode();\r
+ returnValue = EntityUtils.toString(httpResonse.getEntity(), "UTF-8");\r
+ result.setStatusCode(statusCode);\r
+ result.setResult(returnValue);\r
+ }\r
+ } catch (Exception e) {\r
+ e.printStackTrace();\r
+ }\r
+\r
+ finally {\r
+ closeHttpClient(httpClient);\r
+ }\r
+\r
+ return result;\r
+ }\r
+\r
+ /**\r
+ * \r
+ * @param ip\r
+ * @param port\r
+ * @param url\r
+ * @param requestBody\r
+ * @return\r
+ * @throws ClientProtocolException\r
+ * @throws IOException\r
+ */\r
+ public static RestResponse post(String ip, Integer port, String url,\r
+ ActivitiStartProcessRequest requestBody) throws ClientProtocolException, IOException {\r
+ return executeHttpStartIntance(HttpMethod.POST, ip, port, url, requestBody);\r
+ }\r
+\r
+ /**\r
+ * \r
+ * @param ip\r
+ * @param port\r
+ * @param url\r
+ * @param requestBody\r
+ * @return\r
+ * @throws ClientProtocolException\r
+ * @throws IOException\r
+ */\r
+ public static RestResponse post(String ip, Integer port, String url)\r
+ throws ClientProtocolException, IOException {\r
+ return executeHttpDeleteDeploy(HttpMethod.DELETE, ip, port, url);\r
+ }\r
+\r
+}\r
-/**
- * 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.service.activitiservice;
-
-import java.io.IOException;
-import java.io.InputStream;
-
-import javax.ws.rs.core.Response;
-
-import org.apache.http.client.ClientProtocolException;
-import org.onap.workflow.common.Config;
-import org.onap.workflow.common.EnumModuleUrl;
-import org.onap.workflow.common.RestClient;
-import org.onap.workflow.common.RestClientUtils;
-import org.onap.workflow.common.RestResponse;
-import org.onap.workflow.common.ToolUtil;
-import org.onap.workflow.externalservice.entity.activitientitiy.ActivitiDeployResponse;
-import org.onap.workflow.externalservice.entity.activitientitiy.ActivitiStartProcessRequest;
-import org.onap.workflow.tools.Constants;
-import org.slf4j.Logger;
-import org.slf4j.LoggerFactory;
-
-import com.google.gson.Gson;
-
-/**
- *
- * @author 10090474
- *
- */
-public class ActivitiServiceConsumer {
- private static final Logger logger = LoggerFactory.getLogger(ActivitiServiceConsumer.class);
- private static final String DEPLOY_BPMNFILE_URL =
- EnumModuleUrl.ACTIVITI.getApiRootDomain() + "/repository/deployments";
-
- public static RestResponse undeploybpmnfile(String deploymentId) {
- /*
- * IActivitiRestService activitiProxy = getActivitiService();
- * activitiProxy.undeployBpmnFile(deploymentId);
- */
- RestResponse res = deleteDeployProcess(deploymentId);
- // activitiProxy.startProcess(request);
-
- return res;
- }
-
- public static RestResponse startBpmnProcess(ActivitiStartProcessRequest request) {
- // IActivitiRestService activitiProxy = getActivitiService();
- // startProcess( request);
- // activitiProxy.startProcess(request);
- return startProcess(request);
- }
-
- public static RestResponse deleteDeployProcess(String deploymentId) {
- // TODO Auto-generated method stub
- RestResponse res = null;
- try {
- res = RestClient.post(null, null, Constants.DEPLOY_BPMNFILE_URL + "/" + deploymentId);
- } catch (ClientProtocolException e) {
- // TODO Auto-generated catch block
- e.printStackTrace();
- } catch (IOException e) {
- // TODO Auto-generated catch block
- e.printStackTrace();
- }
-
- return res;
- }
-
- public static RestResponse startProcess(ActivitiStartProcessRequest request) {
- // TODO Auto-generated method stub
- RestResponse res = null;
- try {
- res = RestClient.post(null, null, Constants.ACITIVI_START_INSTANCE_URL, request);
- } catch (ClientProtocolException e) {
- // TODO Auto-generated catch block
- e.printStackTrace();
- } catch (IOException e) {
- // TODO Auto-generated catch block
- e.printStackTrace();
- }
-
- // if (Response.Status.OK.getStatusCode() == res.getStatusCode()
- // || Response.Status.CREATED.getStatusCode() == res.getStatusCode()) {
- // Response response = new Gson().fromJson(res.getResult(), Response.class);
- // return response;
- // }
- return res;
- }
-
- public static ActivitiDeployResponse deploybpmnfile(InputStream ins, String filename)
- throws ClientProtocolException, IOException {
- try {
- return deployPackage2Activiti(ins, filename);
- } finally {
- ToolUtil.closeInputStream(ins);
- }
- }
-
- private static ActivitiDeployResponse deployPackage2Activiti(InputStream ins, String filename)
- throws ClientProtocolException, IOException {
- String ip = Config.getWorkflowAppConfig().getMsbClientConfig().getMsbSvrIp();
- int port = Config.getWorkflowAppConfig().getMsbClientConfig().getMsbSvrPort();
- RestResponse res = RestClient.post(ip, port, DEPLOY_BPMNFILE_URL,
- RestClientUtils.buildMultipartRequest(ins, filename));
- logger.info("deployfile to activiti return. {}", res);
-
- if (Response.Status.OK.getStatusCode() == res.getStatusCode()
- || Response.Status.CREATED.getStatusCode() == res.getStatusCode()) {
- ActivitiDeployResponse response =
- new Gson().fromJson(res.getResult(), ActivitiDeployResponse.class);
- return response;
- }
- return null;
- }
-}
+/**\r
+ * Copyright 2017 ZTE Corporation.\r
+ *\r
+ * Licensed under the Apache License, Version 2.0 (the "License");\r
+ * you may not use this file except in compliance with the License.\r
+ * You may obtain a copy of the License at\r
+ *\r
+ * http://www.apache.org/licenses/LICENSE-2.0\r
+ *\r
+ * Unless required by applicable law or agreed to in writing, software\r
+ * distributed under the License is distributed on an "AS IS" BASIS,\r
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.\r
+ * See the License for the specific language governing permissions and\r
+ * limitations under the License.\r
+ */\r
+package org.onap.workflow.externalservice.service.activitiservice;\r
+\r
+import java.io.IOException;\r
+import java.io.InputStream;\r
+\r
+import javax.ws.rs.core.Response;\r
+\r
+import org.apache.http.client.ClientProtocolException;\r
+import org.onap.workflow.common.Config;\r
+import org.onap.workflow.common.EnumModuleUrl;\r
+import org.onap.workflow.common.RestClient;\r
+import org.onap.workflow.common.RestClientUtils;\r
+import org.onap.workflow.common.RestResponse;\r
+import org.onap.workflow.common.ToolUtil;\r
+import org.onap.workflow.externalservice.entity.activitientitiy.ActivitiDeployResponse;\r
+import org.onap.workflow.externalservice.entity.activitientitiy.ActivitiStartProcessRequest;\r
+import org.onap.workflow.tools.Constants;\r
+import org.slf4j.Logger;\r
+import org.slf4j.LoggerFactory;\r
+\r
+import com.google.gson.Gson;\r
+\r
+/**\r
+ * \r
+ * @author 10090474\r
+ * \r
+ */\r
+public class ActivitiServiceConsumer {\r
+ private static final Logger logger = LoggerFactory.getLogger(ActivitiServiceConsumer.class);\r
+ private static final String DEPLOY_BPMNFILE_URL =\r
+ EnumModuleUrl.ACTIVITI.getApiRootDomain() + "/repository/deployments";\r
+\r
+ public static RestResponse undeploybpmnfile(String deploymentId) {\r
+ return deleteDeployProcess(deploymentId);\r
+ }\r
+\r
+ public static RestResponse startBpmnProcess(ActivitiStartProcessRequest request) {\r
+ return startProcess(request);\r
+ }\r
+\r
+ public static RestResponse deleteDeployProcess(String deploymentId) {\r
+ RestResponse res = null;\r
+ try {\r
+ res = RestClient.post(null, null, Constants.DEPLOY_BPMNFILE_URL + "/" + deploymentId);\r
+ } catch (Exception e) {\r
+ return null;\r
+ }\r
+\r
+ return res;\r
+ }\r
+\r
+ public static RestResponse startProcess(ActivitiStartProcessRequest request) {\r
+ RestResponse res = null;\r
+ try {\r
+ res = RestClient.post(null, null, Constants.ACITIVI_START_INSTANCE_URL, request);\r
+ } catch (Exception e) {\r
+ return null;\r
+ } \r
+ return res;\r
+ }\r
+\r
+ public static ActivitiDeployResponse deploybpmnfile(InputStream ins, String filename)\r
+ throws ClientProtocolException, IOException {\r
+ try {\r
+ return deployPackage2Activiti(ins, filename);\r
+ } finally {\r
+ ToolUtil.closeInputStream(ins);\r
+ }\r
+ }\r
+\r
+ private static ActivitiDeployResponse deployPackage2Activiti(InputStream ins, String filename)\r
+ throws ClientProtocolException, IOException {\r
+ String ip = Config.getWorkflowAppConfig().getMsbClientConfig().getMsbSvrIp();\r
+ int port = Config.getWorkflowAppConfig().getMsbClientConfig().getMsbSvrPort();\r
+ RestResponse res = RestClient.post(ip, port, DEPLOY_BPMNFILE_URL,\r
+ RestClientUtils.buildMultipartRequest(ins, filename));\r
+ logger.info("deployfile to activiti return. {}", res);\r
+\r
+ if (Response.Status.OK.getStatusCode() == res.getStatusCode()\r
+ || Response.Status.CREATED.getStatusCode() == res.getStatusCode()) {\r
+ ActivitiDeployResponse response =\r
+ new Gson().fromJson(res.getResult(), ActivitiDeployResponse.class);\r
+ return response;\r
+ }\r
+ return null;\r
+ }\r
+}\r
-/**
- * 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 static org.powermock.api.mockito.PowerMockito.mock;
-
-import org.apache.http.HttpEntity;
-import org.apache.http.HttpHost;
-import org.apache.http.HttpRequest;
-import org.apache.http.client.methods.CloseableHttpResponse;
-import org.apache.http.impl.client.CloseableHttpClient;
-import org.apache.http.impl.client.HttpClients;
-import org.junit.After;
-import org.junit.Before;
-import org.junit.Test;
-import org.junit.runner.RunWith;
-import org.mockito.Mockito;
-import org.onap.workflow.common.RestClient.HttpMethod;
-import org.onap.workflow.externalservice.entity.activitientitiy.ActivitiStartProcessRequest;
-import org.powermock.api.mockito.PowerMockito;
-import org.powermock.core.classloader.annotations.PowerMockIgnore;
-import org.powermock.core.classloader.annotations.PrepareForTest;
-import org.powermock.modules.junit4.PowerMockRunner;
-
-
-@PrepareForTest({RestClient.class, HttpClients.class})
-@RunWith(PowerMockRunner.class)
-@PowerMockIgnore("javax.net.ssl.*")
-public class RestClientTest {
- private RestClient restClient;
- @Before
- public void setUp() throws Exception {
- restClient = new RestClient();
- }
-
- @After
- public void tearDown() throws Exception {}
-
- @SuppressWarnings("static-access")
- @Test
- public final void testExecuteHttp() throws Exception {
- HttpEntity httpEntity = mock(HttpEntity.class);
- PowerMockito.mockStatic(HttpClients.class);
- CloseableHttpClient tt = mock(CloseableHttpClient.class);
- CloseableHttpResponse reponse = mock(CloseableHttpResponse.class);
-
- PowerMockito.when(HttpClients.createDefault()).thenReturn(tt);
- PowerMockito.when(tt.execute(Mockito.any(HttpHost.class), Mockito.any(HttpRequest.class)))
- .thenReturn(reponse);
- PowerMockito.when(reponse.getEntity()).thenReturn(httpEntity);
-
- restClient.executeHttp(HttpMethod.POST, "127.0.0.1", 80, "test", httpEntity);
- }
-
- @SuppressWarnings("static-access")
- @Test
- public final void testExecuteHttpDeleteDeploy() throws Exception {
- HttpEntity httpEntity = mock(HttpEntity.class);
- PowerMockito.mockStatic(HttpClients.class);
- CloseableHttpClient tt = mock(CloseableHttpClient.class);
- CloseableHttpResponse reponse = mock(CloseableHttpResponse.class);
- PowerMockito.when(HttpClients.createDefault()).thenReturn(tt);
- PowerMockito.when(tt.execute(Mockito.any(HttpHost.class), Mockito.any(HttpRequest.class)))
- .thenReturn(reponse);
- PowerMockito.when(reponse.getEntity()).thenReturn(httpEntity);
- restClient.executeHttpDeleteDeploy(HttpMethod.DELETE, "127.0.0.1", 80, "test");
- }
-
- @SuppressWarnings("static-access")
- @Test
- public final void testExecuteHttpStartIntance() throws Exception {
-
- ActivitiStartProcessRequest activitiStartProcessRequest =
- mock(ActivitiStartProcessRequest.class);
-
- HttpEntity httpEntity = mock(HttpEntity.class);
- PowerMockito.mockStatic(HttpClients.class);
- CloseableHttpClient tt = mock(CloseableHttpClient.class);
- CloseableHttpResponse reponse = mock(CloseableHttpResponse.class);
- PowerMockito.when(HttpClients.createDefault()).thenReturn(tt);
- PowerMockito.when(tt.execute(Mockito.any(HttpHost.class), Mockito.any(HttpRequest.class)))
- .thenReturn(reponse);
- PowerMockito.when(reponse.getEntity()).thenReturn(httpEntity);
- restClient.executeHttpStartIntance(HttpMethod.POST, "127.0.0.1", 80, "test",activitiStartProcessRequest);
-
- }
-}
+/**\r
+ * Copyright 2017 ZTE Corporation.\r
+ *\r
+ * Licensed under the Apache License, Version 2.0 (the "License");\r
+ * you may not use this file except in compliance with the License.\r
+ * You may obtain a copy of the License at\r
+ *\r
+ * http://www.apache.org/licenses/LICENSE-2.0\r
+ *\r
+ * Unless required by applicable law or agreed to in writing, software\r
+ * distributed under the License is distributed on an "AS IS" BASIS,\r
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.\r
+ * See the License for the specific language governing permissions and\r
+ * limitations under the License.\r
+ */\r
+package org.onap.workflow.common;\r
+\r
+import static org.powermock.api.mockito.PowerMockito.mock;\r
+\r
+import java.io.IOException;\r
+\r
+import org.apache.http.HttpEntity;\r
+import org.apache.http.HttpHost;\r
+import org.apache.http.HttpRequest;\r
+import org.apache.http.StatusLine;\r
+import org.apache.http.client.ClientProtocolException;\r
+import org.apache.http.client.methods.CloseableHttpResponse;\r
+import org.apache.http.conn.ClientConnectionManager;\r
+import org.apache.http.impl.client.CloseableHttpClient;\r
+import org.apache.http.impl.client.HttpClients;\r
+import org.apache.http.params.HttpParams;\r
+import org.apache.http.protocol.HttpContext;\r
+import org.junit.Assert;\r
+import org.junit.Test;\r
+import org.junit.runner.RunWith;\r
+import org.mockito.Mockito;\r
+import org.onap.workflow.WorkflowAppConfig;\r
+import org.onap.workflow.common.RestClient.HttpMethod;\r
+import org.onap.workflow.entity.MsbClientConfig;\r
+import org.onap.workflow.externalservice.entity.activitientitiy.ActivitiStartProcessRequest;\r
+import org.powermock.api.mockito.PowerMockito;\r
+import org.powermock.core.classloader.annotations.PrepareForTest;\r
+import org.powermock.modules.junit4.PowerMockRunner;\r
+\r
+\r
+@PrepareForTest({HttpClients.class})\r
+@RunWith(PowerMockRunner.class)\r
+public class RestClientTest {\r
+ @Test\r
+ public void testExecuteHttp() throws Exception {\r
+ HttpEntity httpEntity = mock(HttpEntity.class);\r
+ PowerMockito.mockStatic(HttpClients.class);\r
+ CloseableHttpClient httpclient = mock(CloseableHttpClient.class);\r
+ PowerMockito.when(HttpClients.createDefault()).thenReturn(httpclient);\r
+ PowerMockito.when(httpclient.execute(Mockito.any(HttpHost.class), Mockito.any(HttpRequest.class)))\r
+ .thenThrow(new IOException());\r
+ try{\r
+ RestClient.executeHttp(HttpMethod.POST, "127.0.0.1", 80, "test", httpEntity);\r
+ }catch(IOException e){\r
+ Assert.assertTrue(true);\r
+ }\r
+ }\r
+\r
+ @Test\r
+ public void testExecuteHttpException() throws Exception {\r
+ HttpEntity httpEntity = mock(HttpEntity.class);\r
+ PowerMockito.mockStatic(HttpClients.class);\r
+ CloseableHttpClient tt = mock(CloseableHttpClient.class);\r
+ CloseableHttpResponse reponse = mock(CloseableHttpResponse.class);\r
+ StatusLine sl = mock(StatusLine.class);\r
+ PowerMockito.when(HttpClients.createDefault()).thenReturn(tt);\r
+ PowerMockito.when(tt.execute(Mockito.any(HttpHost.class), Mockito.any(HttpRequest.class)))\r
+ .thenReturn(reponse);\r
+ PowerMockito.when(reponse.getEntity()).thenReturn(httpEntity);\r
+ PowerMockito.when(reponse.getStatusLine()).thenReturn(sl);\r
+ RestClient.executeHttp(HttpMethod.POST, "127.0.0.1", 80, "test", httpEntity);\r
+ \r
+ WorkflowAppConfig workflowconfig = makeWorkFlowConfig("127.0.0.1", 80);\r
+ Config.setWorkflowAppConfig(workflowconfig);\r
+ RestClient.executeHttp(HttpMethod.POST, null, null, "test", httpEntity);\r
+ }\r
+ \r
+ private WorkflowAppConfig makeWorkFlowConfig(String msbSvrIp, int msbSvrPort) {\r
+ MsbClientConfig msbClientConfig = new MsbClientConfig();\r
+ msbClientConfig.setMsbSvrIp(msbSvrIp);\r
+ msbClientConfig.setMsbSvrPort(msbSvrPort);\r
+ WorkflowAppConfig workflowconfig = new WorkflowAppConfig();\r
+ workflowconfig.setMsbClientConfig(msbClientConfig);\r
+ return workflowconfig;\r
+ }\r
+ \r
+ @Test\r
+ public void testExecuteHttpDeleteDeploy() throws Exception {\r
+ HttpEntity httpEntity = mock(HttpEntity.class);\r
+ PowerMockito.mockStatic(HttpClients.class);\r
+ CloseableHttpClient tt = mock(CloseableHttpClient.class);\r
+ CloseableHttpResponse reponse = mock(CloseableHttpResponse.class);\r
+ PowerMockito.when(HttpClients.createDefault()).thenReturn(tt);\r
+ PowerMockito.when(tt.execute(Mockito.any(HttpHost.class), Mockito.any(HttpRequest.class)))\r
+ .thenReturn(reponse);\r
+ PowerMockito.when(reponse.getEntity()).thenReturn(httpEntity);\r
+ RestClient.executeHttpDeleteDeploy(HttpMethod.DELETE, "127.0.0.1", 80, "test");\r
+ \r
+ WorkflowAppConfig workflowconfig = makeWorkFlowConfig("127.0.0.1", 80);\r
+ Config.setWorkflowAppConfig(workflowconfig);\r
+ RestClient.executeHttpDeleteDeploy(HttpMethod.DELETE, null, null, "test");\r
+ }\r
+\r
+ @Test\r
+ public void testExecuteHttpStartIntance() throws Exception {\r
+ ActivitiStartProcessRequest activitiStartProcessRequest =\r
+ mock(ActivitiStartProcessRequest.class);\r
+\r
+ HttpEntity httpEntity = mock(HttpEntity.class);\r
+ PowerMockito.mockStatic(HttpClients.class);\r
+ CloseableHttpClient tt = mock(CloseableHttpClient.class);\r
+ CloseableHttpResponse reponse = mock(CloseableHttpResponse.class);\r
+ PowerMockito.when(HttpClients.createDefault()).thenReturn(tt);\r
+ PowerMockito.when(tt.execute(Mockito.any(HttpHost.class), Mockito.any(HttpRequest.class)))\r
+ .thenReturn(reponse);\r
+ PowerMockito.when(reponse.getEntity()).thenReturn(httpEntity);\r
+ RestClient.executeHttpStartIntance(HttpMethod.POST, "127.0.0.1", 80, "test",activitiStartProcessRequest);\r
+\r
+ WorkflowAppConfig workflowconfig = makeWorkFlowConfig("127.0.0.1", 80);\r
+ Config.setWorkflowAppConfig(workflowconfig);\r
+ RestClient.executeHttpStartIntance(HttpMethod.POST, null, null, "test", activitiStartProcessRequest);\r
+ }\r
+ \r
+ @Test\r
+ public void testgetRequest() {\r
+ HttpRequest request = RestClient.getRequest(HttpMethod.GET, "/test/", null);\r
+ Assert.assertTrue (request.getRequestLine().getMethod().equals(HttpMethod.GET.toString()));\r
+ request = RestClient.getRequest(HttpMethod.POST, "/test/", null);\r
+ Assert.assertTrue (request.getRequestLine().getMethod().equals(HttpMethod.POST.toString()));\r
+ request = RestClient.getRequest(HttpMethod.DELETE, "/test/", null);\r
+ Assert.assertTrue (request.getRequestLine().getMethod().equals(HttpMethod.DELETE.toString()));\r
+ request = RestClient.getRequest(HttpMethod.PUT, "/test/", null);\r
+ Assert.assertTrue (request.getRequestLine().getMethod().equals(HttpMethod.PUT.toString()));\r
+ try {\r
+ request = RestClient.getRequest(null, "/test/", null);\r
+ } catch (NullPointerException e) {\r
+ Assert.assertTrue (true);\r
+ }\r
+ }\r
+ \r
+ @Test\r
+ public void testPost() throws Exception {\r
+ HttpEntity httpEntity = mock(HttpEntity.class);\r
+ PowerMockito.mockStatic(HttpClients.class);\r
+ CloseableHttpClient tt = mock(CloseableHttpClient.class);\r
+ CloseableHttpResponse reponse = mock(CloseableHttpResponse.class);\r
+ \r
+ PowerMockito.when(HttpClients.createDefault()).thenReturn(tt);\r
+ PowerMockito.when(tt.execute(Mockito.any(HttpHost.class), Mockito.any(HttpRequest.class)))\r
+ .thenReturn(reponse);\r
+ PowerMockito.when(reponse.getEntity()).thenReturn(httpEntity);\r
+ WorkflowAppConfig workflowconfig = makeWorkFlowConfig("127.0.0.1", 80);\r
+ Config.setWorkflowAppConfig(workflowconfig);\r
+ RestClient.post("127.0.0.1", 80, "test", null);\r
+ RestClient.post("127.0.0.1", 80, "test");\r
+ }\r
+ \r
+ @Test\r
+ public void testCloseHttpClient(){\r
+ Assert.assertTrue(RestClient.closeHttpClient(mock(CloseableHttpClient.class)));\r
+ Assert.assertTrue(RestClient.closeHttpClient(null));\r
+ Assert.assertFalse(RestClient.closeHttpClient(new CloseableHttpClientTest()));\r
+ }\r
+ \r
+ public class CloseableHttpClientTest extends CloseableHttpClient{\r
+ @Override\r
+ public void close() throws IOException {\r
+ throw new IOException();\r
+ }\r
+\r
+ @Override\r
+ protected CloseableHttpResponse doExecute(HttpHost target, HttpRequest request,\r
+ HttpContext context) throws IOException, ClientProtocolException {\r
+ return null;\r
+ }\r
+\r
+ @SuppressWarnings("deprecation")\r
+ @Override\r
+ public HttpParams getParams() {\r
+ return null;\r
+ }\r
+\r
+ @SuppressWarnings("deprecation")\r
+ @Override\r
+ public ClientConnectionManager getConnectionManager() {\r
+ return null;\r
+ }\r
+ }\r
+}\r
-/**
- * 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();
- }
- }
- }
-}
+/**\r
+ * Copyright 2017 ZTE Corporation.\r
+ *\r
+ * Licensed under the Apache License, Version 2.0 (the "License");\r
+ * you may not use this file except in compliance with the License.\r
+ * You may obtain a copy of the License at\r
+ *\r
+ * http://www.apache.org/licenses/LICENSE-2.0\r
+ *\r
+ * Unless required by applicable law or agreed to in writing, software\r
+ * distributed under the License is distributed on an "AS IS" BASIS,\r
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.\r
+ * See the License for the specific language governing permissions and\r
+ * limitations under the License.\r
+ */\r
+\r
+package org.onap.workflow.common;\r
+\r
+import java.io.File;\r
+import java.io.FileInputStream;\r
+import java.io.InputStream;\r
+\r
+import org.apache.http.HttpEntity;\r
+import org.apache.http.entity.ContentType;\r
+import org.junit.Assert;\r
+import org.junit.Test;\r
+\r
+/**\r
+ *\r
+ */\r
+public class RestClientUtilsTest {\r
+\r
+ @Test\r
+ public void testbuildMultipartRequest() {\r
+ String filePath = System.getProperty("java.io.tmpdir");\r
+ String fileName = "testfile";\r
+ File file = new File(filePath + File.separator + fileName);\r
+ InputStream is = null;\r
+ try {\r
+ if (!file.exists()) {\r
+ file.createNewFile();\r
+ }\r
+ is = new FileInputStream(file);\r
+ HttpEntity httpentity = RestClientUtils.buildMultipartRequest(is, fileName);\r
+ Assert.assertTrue(httpentity.getContentType().getValue()\r
+ .indexOf(ContentType.MULTIPART_FORM_DATA.getMimeType()) > -1);\r
+ } catch (Exception e) {\r
+ Assert.assertFalse (false);\r
+ } finally {\r
+ ToolUtil.closeInputStream(is);\r
+ if (file.exists()) {\r
+ file.delete();\r
+ }\r
+ }\r
+ }\r
+}\r
-/**
- * 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()));
- }
-
+/**\r
+ * Copyright 2017 ZTE Corporation.\r
+ * <p>\r
+ * Licensed under the Apache License, Version 2.0 (the "License");\r
+ * you may not use this file except in compliance with the License.\r
+ * You may obtain a copy of the License at\r
+ * <p>\r
+ * http://www.apache.org/licenses/LICENSE-2.0\r
+ * <p>\r
+ * Unless required by applicable law or agreed to in writing, software\r
+ * distributed under the License is distributed on an "AS IS" BASIS,\r
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.\r
+ * See the License for the specific language governing permissions and\r
+ * limitations under the License.\r
+ */\r
+package org.onap.workflow.externalservice.service.activitiservice;\r
+\r
+import static org.mockito.Mockito.mock;\r
+\r
+import java.io.IOException;\r
+import java.io.InputStream;\r
+\r
+import org.apache.http.client.ClientProtocolException;\r
+import org.junit.Assert;\r
+import org.junit.Test;\r
+import org.onap.workflow.WorkflowAppConfig;\r
+import org.onap.workflow.common.Config;\r
+import org.onap.workflow.common.RestClient;\r
+import org.onap.workflow.common.RestResponse;\r
+import org.onap.workflow.entity.MsbClientConfig;\r
+import org.onap.workflow.externalservice.entity.activitientitiy.ActivitiDeployResponse;\r
+import org.onap.workflow.externalservice.entity.activitientitiy.ActivitiStartProcessRequest;\r
+\r
+public class ActivitiServiceConsumerTest {\r
+ @Test\r
+ public void undeploybpmnfile() throws ClientProtocolException, IOException {\r
+ RestClient.isTest = true;\r
+ RestResponse response = ActivitiServiceConsumer.undeploybpmnfile("22");\r
+ Assert.assertTrue(response != null);\r
+ RestClient.isTest = false;\r
+ }\r
+\r
+ @Test\r
+ public void startBpmnProcess() throws Exception {\r
+ RestClient.isTest = true;\r
+ RestResponse response =\r
+ ActivitiServiceConsumer.startBpmnProcess(mock(ActivitiStartProcessRequest.class));\r
+ Assert.assertTrue(response != null);\r
+ RestClient.isTest = false;\r
+ }\r
+\r
+ @Test\r
+ public void testDeleteDeployProcess() throws Exception {\r
+ RestClient.isTest = true;\r
+ RestResponse response = ActivitiServiceConsumer.deleteDeployProcess("22");\r
+ Assert.assertTrue(response != null);\r
+ RestClient.isTest = false;\r
+ }\r
+\r
+ @Test\r
+ public void testDeleteDeployProcessReturnNull() throws Exception {\r
+ RestClient.isTest = false;\r
+ RestResponse response = ActivitiServiceConsumer.deleteDeployProcess("22");\r
+ if (response != null) {\r
+ Assert.assertTrue(response.getResult() == null);\r
+ } else {\r
+ Assert.assertTrue(response == null);\r
+ }\r
+ }\r
+\r
+ @Test\r
+ public void testStartProcessShouldReturnResponse() throws Exception {\r
+ RestClient.isTest = true;\r
+ RestResponse response =\r
+ ActivitiServiceConsumer.startProcess(mock(ActivitiStartProcessRequest.class));\r
+ Assert.assertTrue(response != null);\r
+ RestClient.isTest = false;\r
+ }\r
+\r
+ @Test\r
+ public void testStartProcessShouldReturnNull() {\r
+ RestClient.isTest = false;\r
+ RestResponse response =\r
+ ActivitiServiceConsumer.startProcess(mock(ActivitiStartProcessRequest.class));\r
+ Assert.assertTrue(response.getResult() == null);\r
+ }\r
+\r
+ @Test\r
+ public void deploybpmnfile() throws Exception {\r
+ RestClient.isTest = true;\r
+ WorkflowAppConfig workflowAppConfig = new WorkflowAppConfig();\r
+ MsbClientConfig msbClientConfig = new MsbClientConfig();\r
+ msbClientConfig.setMsbSvrPort(2);\r
+ msbClientConfig.setMsbSvrIp("127.0.0.1");\r
+ workflowAppConfig.setMsbClientConfig(msbClientConfig);\r
+ Config.setWorkflowAppConfig(workflowAppConfig);\r
+ InputStream ins = mock(InputStream.class);\r
+ ActivitiDeployResponse result = ActivitiServiceConsumer.deploybpmnfile(ins, "result");\r
+ Assert.assertTrue(result == null);\r
+ RestClient.isTest = false;\r
+ }\r
+\r
}
\ No newline at end of file
-/**
- * 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.resources;
-
-import static org.powermock.api.mockito.PowerMockito.mock;
-
-import java.io.InputStream;
-
-import org.glassfish.jersey.media.multipart.FormDataContentDisposition;
-import org.junit.After;
-import org.junit.AfterClass;
-import org.junit.Before;
-import org.junit.BeforeClass;
-import org.junit.Test;
-import org.junit.runner.RunWith;
-import org.onap.workflow.common.RestResponse;
-import org.onap.workflow.entity.StartProcessRequest;
-import org.onap.workflow.externalservice.entity.activitientitiy.ActivitiDeployResponse;
-import org.onap.workflow.externalservice.entity.activitientitiy.ActivitiStartProcessRequest;
-import org.onap.workflow.externalservice.service.activitiservice.ActivitiServiceConsumer;
-import org.onap.workflow.wrapper.WorkflowInstanceWrapper;
-import org.powermock.api.mockito.PowerMockito;
-import org.powermock.core.classloader.annotations.PrepareForTest;
-import org.powermock.modules.junit4.PowerMockRunner;
-
-@PrepareForTest({ActivitiServiceConsumer.class})
-@RunWith(PowerMockRunner.class)
-public class WorkflowInstanceWrapperTest {
-
- private WorkflowInstanceWrapper workflowInstanceWrapper;
-
- @BeforeClass
- public static void setUpBeforeClass() throws Exception {}
-
- @AfterClass
- public static void tearDownAfterClass() throws Exception {}
-
- @Before
- public void setUp() throws Exception {
- workflowInstanceWrapper = new WorkflowInstanceWrapper();
- PowerMockito.mockStatic(ActivitiServiceConsumer.class);// 3
- }
-
- @After
- public void tearDown() throws Exception {}
-
- @Test
- public final void testDeployBpmnFile() throws Exception {
-
- InputStream fileInputStream = mock(InputStream.class);
- FormDataContentDisposition f = mock(FormDataContentDisposition.class);
- String filename = "test";
- ActivitiDeployResponse reponse = new ActivitiDeployResponse();
- reponse.setId("123");
- reponse.setUrl("http://url");
- PowerMockito.mockStatic(ActivitiServiceConsumer.class);
- PowerMockito.when(ActivitiServiceConsumer.deploybpmnfile(fileInputStream, filename))
- .thenReturn(reponse);
- workflowInstanceWrapper.deployBpmnFile(filename, fileInputStream, f);
- // assertThat(, is(result));
- }
-
- @Test
- public final void testUndeployBpmnFile() throws Exception {
- WorkflowInstanceWrapper.getInstance().undeployBpmnFile(null);
- }
-
- @Test
- public final void testStartProcess() throws Exception {
- ActivitiStartProcessRequest startProcessRequest = new ActivitiStartProcessRequest();
- startProcessRequest.setProcessDefinitionKey("first");
- StartProcessRequest tt = new StartProcessRequest();
- tt.setProcessDefinitionKey("first");
- RestResponse reponse = new RestResponse();
- reponse.setResult("123");
- PowerMockito.mockStatic(ActivitiServiceConsumer.class);
- PowerMockito.when(ActivitiServiceConsumer.startBpmnProcess(startProcessRequest))
- .thenReturn(reponse);
- workflowInstanceWrapper.startProcess(tt);
- }
-
-}
+/**\r
+ * Copyright 2017 ZTE Corporation.\r
+ *\r
+ * Licensed under the Apache License, Version 2.0 (the "License");\r
+ * you may not use this file except in compliance with the License.\r
+ * You may obtain a copy of the License at\r
+ *\r
+ * http://www.apache.org/licenses/LICENSE-2.0\r
+ *\r
+ * Unless required by applicable law or agreed to in writing, software\r
+ * distributed under the License is distributed on an "AS IS" BASIS,\r
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.\r
+ * See the License for the specific language governing permissions and\r
+ * limitations under the License.\r
+ */\r
+package org.onap.workflow.resources;\r
+\r
+import static org.powermock.api.mockito.PowerMockito.mock;\r
+\r
+import java.io.InputStream;\r
+\r
+import javax.ws.rs.core.Response;\r
+\r
+import org.glassfish.jersey.media.multipart.FormDataContentDisposition;\r
+import org.junit.Assert;\r
+import org.junit.Before;\r
+import org.junit.Test;\r
+import org.onap.workflow.common.RestClient;\r
+import org.onap.workflow.common.RestResponse;\r
+import org.onap.workflow.entity.StartProcessRequest;\r
+import org.onap.workflow.externalservice.entity.activitientitiy.ActivitiStartProcessRequest;\r
+import org.onap.workflow.wrapper.WorkflowInstanceWrapper;\r
+\r
+public class WorkflowInstanceWrapperTest {\r
+\r
+ private WorkflowInstanceWrapper workflowInstanceWrapper;\r
+\r
+ @Before\r
+ public void setUp() throws Exception {\r
+ workflowInstanceWrapper = new WorkflowInstanceWrapper();\r
+ }\r
+\r
+ @Test\r
+ public final void testDeployBpmnFile() throws Exception {\r
+ RestClient.isTest = true;\r
+ InputStream fileInputStream = mock(InputStream.class);\r
+ FormDataContentDisposition f = mock(FormDataContentDisposition.class);\r
+ String filename = "test";\r
+ Response reponse = workflowInstanceWrapper.deployBpmnFile(filename, fileInputStream, f);\r
+ Assert.assertEquals(Response.Status.INTERNAL_SERVER_ERROR.getStatusCode(), reponse.getStatus());\r
+ RestClient.isTest = false;\r
+ }\r
+\r
+ @Test\r
+ public final void testUndeployBpmnFile() throws Exception {\r
+ RestClient.isTest = true;\r
+ RestResponse response = WorkflowInstanceWrapper.getInstance().undeployBpmnFile(null);\r
+ if (response != null) {\r
+ Assert.assertTrue(response.getResult() == null);\r
+ }\r
+ RestClient.isTest = false;\r
+ }\r
+\r
+ @Test\r
+ public final void testStartProcess() throws Exception {\r
+ RestClient.isTest = true;\r
+ ActivitiStartProcessRequest startProcessRequest = new ActivitiStartProcessRequest();\r
+ startProcessRequest.setProcessDefinitionKey("first");\r
+ StartProcessRequest tt = new StartProcessRequest();\r
+ tt.setProcessDefinitionKey("first");\r
+ Response reponse = workflowInstanceWrapper.startProcess(tt);\r
+ Assert.assertEquals(Response.Status.OK.getStatusCode(), reponse.getStatus());\r
+ RestClient.isTest = false;\r
+ }\r
+\r
+}\r
Code Review / vfc / nfvo / wfengine.git / commitdiff