2 * ============LICENSE_START=======================================================
4 * ================================================================================
5 * Copyright (C) 2017 AT&T Intellectual Property. All rights reserved.
6 * ================================================================================
7 * Copyright (C) 2017 Amdocs
8 * =============================================================================
9 * Licensed under the Apache License, Version 2.0 (the "License");
10 * you may not use this file except in compliance with the License.
11 * You may obtain a copy of the License at
13 * http://www.apache.org/licenses/LICENSE-2.0
15 * Unless required by applicable law or agreed to in writing, software
16 * distributed under the License is distributed on an "AS IS" BASIS,
17 * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
18 * See the License for the specific language governing permissions and
19 * limitations under the License.
21 * ECOMP is a trademark and service mark of AT&T Intellectual Property.
22 * ============LICENSE_END=========================================================
25 package org.openecomp.appc.workflow;
27 import org.junit.Before;
28 import org.junit.Test;
29 import org.junit.runner.RunWith;
30 import org.mockito.Mockito;
31 import org.openecomp.appc.workflow.impl.WorkFlowManagerImpl;
32 import org.openecomp.appc.workflow.objects.WorkflowRequest;
33 import org.onap.ccsdk.sli.core.sli.SvcLogicException;
34 import org.onap.ccsdk.sli.core.sli.SvcLogicGraph;
35 import org.onap.ccsdk.sli.core.sli.SvcLogicNode;
36 import org.onap.ccsdk.sli.core.sli.SvcLogicStore;
37 import org.onap.ccsdk.sli.core.sli.provider.SvcLogicActivator;
38 import org.osgi.framework.Bundle;
39 import org.osgi.framework.BundleContext;
40 import org.osgi.framework.FrameworkUtil;
41 import org.osgi.framework.ServiceReference;
42 import org.powermock.core.classloader.annotations.PrepareForTest;
43 import org.powermock.modules.junit4.PowerMockRunner;
45 @RunWith(PowerMockRunner.class)
46 @PrepareForTest( {SvcLogicActivator.class, FrameworkUtil.class, WorkFlowManagerImpl.class} )
47 public class TestWorkFlowManager {
48 public TestWorkFlowManager() {
51 private WorkFlowManagerImpl workflowManger ;
52 private String command="Configure";
53 protected SvcLogicGraph svcLogicGraph=null;
57 private final SvcLogicStore svcLogicStore= Mockito.mock(SvcLogicStore.class);
58 private final BundleContext bundleContext=Mockito.mock(BundleContext.class);
59 private final Bundle bundleSvcLogicService=Mockito.mock(Bundle.class);
60 private final ServiceReference serviceReferenceSvcLogicService=Mockito.mock(ServiceReference.class);
65 public void setupMock() throws Exception {
68 dao = Mockito.mock(AppcDAOImpl.class);
69 PowerMockito.whenNew(AppcDAOImpl.class).withNoArguments().thenReturn(dao);
72 SvcLogicServiceImpl svcLogicService=new SvcLogicServiceImpl();
73 PowerMockito.mockStatic(SvcLogicActivator.class);
74 PowerMockito.mockStatic(FrameworkUtil.class);
75 PowerMockito.when(SvcLogicActivator.getStore()).thenReturn(svcLogicStore);
76 PowerMockito.when(FrameworkUtil.getBundle(SvcLogicService.class)).thenReturn(bundleSvcLogicService);
77 PowerMockito.when(bundleSvcLogicService.getBundleContext()).thenReturn(bundleContext);
78 PowerMockito.when(bundleContext.getServiceReference(SvcLogicService.NAME)).thenReturn(serviceReferenceSvcLogicService);
79 PowerMockito.when(bundleContext.getService(serviceReferenceSvcLogicService)).thenReturn(svcLogicService);
82 PowerMockito.when(svcLogicStore.fetch(anyString(), eq("FIREWALL_Configure"), anyString(), anyString())).thenReturn(createGraph("FIREWALL_Configure"));
83 PowerMockito.when(svcLogicStore.fetch(anyString(), eq("FIREWALL_Restart"), anyString(), anyString())).thenReturn(createGraph("FIREWALL_Restart"));
84 PowerMockito.when(svcLogicStore.fetch(anyString(), eq("FIREWALL_Test"), anyString(), anyString())).thenReturn(createGraph("FIREWALL_Test"));
85 PowerMockito.when(svcLogicStore.fetch(anyString(), eq("FIREWALL_Rebuild"), anyString(), anyString())).thenReturn(createGraph("FIREWALL_Rebuild"));
86 PowerMockito.when(svcLogicStore.fetch(anyString(), eq("FIREWALL_Terminate"), anyString(), anyString())).thenReturn(createGraph("FIREWALL_Terminate"));
87 PowerMockito.when(svcLogicStore.fetch(anyString(), eq("FIREWALL_Start"), anyString(), anyString())).thenReturn(createGraph("FIREWALL_Start"));
88 svcLogicService.registerExecutor("switch", new SwitchNodeExecutor());
89 svcLogicService.registerExecutor("execute",new ReturnNodeExecutor());
90 svcLogicService.registerExecutor("return",new ReturnNodeExecutor());
91 } catch (SvcLogicException e) {
95 workflowManger = new WorkFlowManagerImpl();
97 PowerMockito.when(getDao().retrieveWorkflowDetails("FIREWALL","Configure")).thenReturn(getWorkflow());
98 PowerMockito.when(getDao().retrieveWorkflowDetails("FIREWALL","")).thenThrow(new DAOException());
99 PowerMockito.when(getDao().retrieveWorkflowDetails("","Configure")).thenThrow(new DAOException());
104 public void testEmptyVnfTypeFlow(){
106 WorkflowRequest workflowRequest = getWorkflowRequest("","1","1",command);
107 setSvcLogicGraph(createGraph(""+"_"+command));
108 WorkflowResponse response =workflowManger.executeWorkflow(workflowRequest);
109 assertFalse(response.isExecutionSuccess());
115 public void testExecuteWorkflow(){
116 //PowerMockito.when(getDao().retrieveWorkflowDetails(anyString(),anyString())).thenReturn(getWorkflow());
117 WorkflowRequest workflowRequest = getWorkflowRequest("FIREWALL","1","1",command);
118 setSvcLogicGraph(createGraph("FIREWALL"+"_"+command));
119 WorkflowResponse response =workflowManger.executeWorkflow(workflowRequest);
120 assertFalse(response.isExecutionSuccess());
124 public void testExecuteWorkflowEmptyPayload(){
125 //PowerMockito.when(getDao().retrieveWorkflowDetails(anyString(),anyString())).thenReturn(getWorkflow());
126 WorkflowRequest workflowRequest = getWorkflowRequest("FIREWALL","1","1",command);
127 workflowRequest.setPayload("{payload:\"payload\"}");
128 setSvcLogicGraph(createGraph(""+"_"+command));
129 WorkflowResponse response =workflowManger.executeWorkflow(workflowRequest);
130 assertFalse(response.isExecutionSuccess());
134 public void testWorkflowExist(){
135 //PowerMockito.when(getDao().queryWorkflow(anyString(),anyString())).thenReturn(true);
136 WorkflowRequest workflowRequest = getWorkflowRequest("FIREWALL","1","1",command);
137 boolean success = workflowManger.workflowExists(workflowRequest);
142 public void testWorkflowExistFalse(){
143 //PowerMockito.when(getDao().queryWorkflow(anyString(),anyString())).thenReturn(false);
144 WorkflowRequest workflowRequest = getWorkflowRequest("FIREWALL","1","1",command);
145 setSvcLogicGraph(createGraph(""+"_"+command));
146 boolean success = workflowManger.workflowExists(workflowRequest);
147 assertFalse(success);
152 public void testEmptyCommandFlow(){
153 WorkflowRequest workflowRequest = getWorkflowRequest("FIREWALL","1","1","");
154 WorkflowResponse response =workflowManger.executeWorkflow(workflowRequest);
155 assertFalse(response.isExecutionSuccess());
160 public void setSvcLogicGraph(SvcLogicGraph svcLogicGraph) {
161 this.svcLogicGraph = svcLogicGraph;
164 public SvcLogicGraph getSvcLogicGraph() {
165 return svcLogicGraph;
168 protected SvcLogicGraph createGraph(String rpc) {
169 SvcLogicGraph svcLogicGraph = new SvcLogicGraph();
170 svcLogicGraph.setModule("APPC");
171 svcLogicGraph.setRpc(rpc);
172 svcLogicGraph.setMode("sync");
173 svcLogicGraph.setVersion("2.0.0");
174 SvcLogicNode svcLogicRootNode = new SvcLogicNode(1, "switch", svcLogicGraph);
175 SvcLogicNode svcLogicConfigureNode = new SvcLogicNode(2, "return", svcLogicGraph);
176 SvcLogicNode svcLogicOtherNode = new SvcLogicNode(3, "return", svcLogicGraph);
178 svcLogicConfigureNode.setAttribute("status", "success");
179 svcLogicOtherNode.setAttribute("status", "failure");
180 svcLogicRootNode.setAttribute("test", "$org.openecomp.appc.action");
181 svcLogicRootNode.addOutcome("Configure", svcLogicConfigureNode);
182 svcLogicRootNode.addOutcome("Other", svcLogicOtherNode);
183 } catch (SvcLogicException e) {
186 svcLogicGraph.setRootNode(svcLogicRootNode);
187 return svcLogicGraph;