-/**
- * 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.impl.persistence.entity.ExecutionEntity;
-import org.junit.Assert;
-import org.junit.Before;
-import org.junit.Test;
-import org.junit.runner.RunWith;
-import org.mockito.Mockito;
-import org.onap.workflow.activitiext.common.Parameter;
-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({HighLevelRestApi.class})
-@RunWith(PowerMockRunner.class)
-public class HttpUtilTest {
-
- private HttpUtil httpUtil;
-
- @Before
- public void setUp() {
- httpUtil = new HttpUtil();
- }
-
- @Test
- public void testExecute(){
-
- DelegateExecution executionEntity = mock(ExecutionEntity.class);
-
- HttpUtil httpUtil1 = mock(HttpUtil.class);;
- try {
- httpUtil1.execute(executionEntity);
-
- Assert.assertTrue(true);
- } catch (Exception e) {
- // TODO Auto-generated catch block
- e.printStackTrace();
- Assert.assertTrue(false);
- }
- }
-
- @Test
- public void testExecuteMethod() {
-
- DelegateExecution executionEntity = mock(ExecutionEntity.class);
- HttpUtil httpUtil1 = mock(HttpUtil.class);;
- try {
-
- PowerMockito.when(executionEntity.getCurrentActivityId()).thenReturn("1111");
-
- HttpResponseMessage msg = new HttpResponseMessage();
- msg.setStatusCode(200);
- msg.setResponseBody(null);
- PowerMockito.mockStatic(HighLevelRestApi.class);
- PowerMockito.when(HighLevelRestApi.invoke(Mockito.anyObject())).thenReturn(msg);
-
- httpUtil1.executeMethod(executionEntity);
- Assert.assertTrue(true);
- } catch (Exception e) {
- e.printStackTrace();
- Assert.assertTrue(false);
- }
- }
-
- @Test
- public void testHandleParam(){
-
- 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) {
- // TODO Auto-generated catch block
- e.printStackTrace();
- Assert.assertTrue(true);
- }
-
- }
-}
+/**\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
Code Review / vfc / nfvo / wfengine.git / blobdiff