Moving all files to root directory

Change-Id: Ica5535fd6ec85f350fe1640b42137b49f83f10f0
Signed-off-by: Patrick Brady <pb071s@att.com>

2 files changed, 286 insertions, 0 deletions

diff --git a/appc-dispatcher/appc-workflow-management/appc-workflow-management-core/src/test/java/org/openecomp/appc/workflow/TestWorkFlowManager.java b/appc-dispatcher/appc-workflow-management/appc-workflow-management-core/src/test/java/org/openecomp/appc/workflow/TestWorkFlowManager.java
new file mode 100644
index 000000000..0a4b0de76
--- /dev/null
+++ b/appc-dispatcher/appc-workflow-management/appc-workflow-management-core/src/test/java/org/openecomp/appc/workflow/TestWorkFlowManager.java
@@ -0,0 +1,186 @@
+/*-
+ * ============LICENSE_START=======================================================
+ * openECOMP : APP-C
+ * ================================================================================
+ * Copyright (C) 2017 AT&T Intellectual Property. All rights
+ * 						reserved.
+ * ================================================================================
+ * 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.
+ * ============LICENSE_END=========================================================
+ */
+
+package org.openecomp.appc.workflow;
+
+import org.junit.Before;
+import org.junit.Test;
+import org.junit.runner.RunWith;
+import org.mockito.Mockito;
+import org.openecomp.appc.workflow.impl.WorkFlowManagerImpl;
+import org.openecomp.appc.workflow.objects.WorkflowRequest;
+import org.openecomp.sdnc.sli.SvcLogicException;
+import org.openecomp.sdnc.sli.SvcLogicGraph;
+import org.openecomp.sdnc.sli.SvcLogicNode;
+import org.openecomp.sdnc.sli.SvcLogicStore;
+import org.openecomp.sdnc.sli.provider.SvcLogicActivator;
+import org.osgi.framework.Bundle;
+import org.osgi.framework.BundleContext;
+import org.osgi.framework.FrameworkUtil;
+import org.osgi.framework.ServiceReference;
+import org.powermock.core.classloader.annotations.PrepareForTest;
+import org.powermock.modules.junit4.PowerMockRunner;
+
+@RunWith(PowerMockRunner.class)
+@PrepareForTest( {SvcLogicActivator.class, FrameworkUtil.class, WorkFlowManagerImpl.class} )
+public class TestWorkFlowManager {
+    public TestWorkFlowManager() {
+    }
+
+    private WorkFlowManagerImpl workflowManger ;
+    private String command="Configure";
+    protected SvcLogicGraph svcLogicGraph=null;
+
+
+    //
+    private final SvcLogicStore svcLogicStore= Mockito.mock(SvcLogicStore.class);
+    private final BundleContext bundleContext=Mockito.mock(BundleContext.class);
+    private final Bundle bundleSvcLogicService=Mockito.mock(Bundle.class);
+    private final ServiceReference serviceReferenceSvcLogicService=Mockito.mock(ServiceReference.class);
+
+
+
+    @Before
+    public void setupMock() throws Exception {
+        /*
+        // DAO Mock
+        dao = Mockito.mock(AppcDAOImpl.class);
+        PowerMockito.whenNew(AppcDAOImpl.class).withNoArguments().thenReturn(dao);
+
+        // SVC Logic Mock
+        SvcLogicServiceImpl svcLogicService=new SvcLogicServiceImpl();
+        PowerMockito.mockStatic(SvcLogicActivator.class);
+        PowerMockito.mockStatic(FrameworkUtil.class);
+        PowerMockito.when(SvcLogicActivator.getStore()).thenReturn(svcLogicStore);
+        PowerMockito.when(FrameworkUtil.getBundle(SvcLogicService.class)).thenReturn(bundleSvcLogicService);
+        PowerMockito.when(bundleSvcLogicService.getBundleContext()).thenReturn(bundleContext);
+        PowerMockito.when(bundleContext.getServiceReference(SvcLogicService.NAME)).thenReturn(serviceReferenceSvcLogicService);
+        PowerMockito.when(bundleContext.getService(serviceReferenceSvcLogicService)).thenReturn(svcLogicService);
+
+        try {
+            PowerMockito.when(svcLogicStore.fetch(anyString(), eq("FIREWALL_Configure"), anyString(), anyString())).thenReturn(createGraph("FIREWALL_Configure"));
+            PowerMockito.when(svcLogicStore.fetch(anyString(), eq("FIREWALL_Restart"), anyString(), anyString())).thenReturn(createGraph("FIREWALL_Restart"));
+            PowerMockito.when(svcLogicStore.fetch(anyString(), eq("FIREWALL_Test"), anyString(), anyString())).thenReturn(createGraph("FIREWALL_Test"));
+            PowerMockito.when(svcLogicStore.fetch(anyString(), eq("FIREWALL_Rebuild"), anyString(), anyString())).thenReturn(createGraph("FIREWALL_Rebuild"));
+            PowerMockito.when(svcLogicStore.fetch(anyString(), eq("FIREWALL_Terminate"), anyString(), anyString())).thenReturn(createGraph("FIREWALL_Terminate"));
+            PowerMockito.when(svcLogicStore.fetch(anyString(), eq("FIREWALL_Start"), anyString(), anyString())).thenReturn(createGraph("FIREWALL_Start"));
+            svcLogicService.registerExecutor("switch", new SwitchNodeExecutor());
+            svcLogicService.registerExecutor("execute",new ReturnNodeExecutor());
+            svcLogicService.registerExecutor("return",new ReturnNodeExecutor());
+        } catch (SvcLogicException e) {
+            e.printStackTrace();
+        }
+
+        workflowManger = new WorkFlowManagerImpl();
+
+        PowerMockito.when(getDao().retrieveWorkflowDetails("FIREWALL","Configure")).thenReturn(getWorkflow());
+        PowerMockito.when(getDao().retrieveWorkflowDetails("FIREWALL","")).thenThrow(new DAOException());
+        PowerMockito.when(getDao().retrieveWorkflowDetails("","Configure")).thenThrow(new DAOException());
+         */
+    }
+
+    @Test
+    public void testEmptyVnfTypeFlow(){
+        /*
+        WorkflowRequest workflowRequest = getWorkflowRequest("","1","1",command);
+        setSvcLogicGraph(createGraph(""+"_"+command));
+        WorkflowResponse response =workflowManger.executeWorkflow(workflowRequest);
+        assertFalse(response.isExecutionSuccess());
+         */
+    }
+
+    /*
+    @Test
+    public void testExecuteWorkflow(){
+        //PowerMockito.when(getDao().retrieveWorkflowDetails(anyString(),anyString())).thenReturn(getWorkflow());
+        WorkflowRequest workflowRequest = getWorkflowRequest("FIREWALL","1","1",command);
+        setSvcLogicGraph(createGraph("FIREWALL"+"_"+command));
+        WorkflowResponse response =workflowManger.executeWorkflow(workflowRequest);
+        assertFalse(response.isExecutionSuccess());
+    }
+
+    @Test
+    public void testExecuteWorkflowEmptyPayload(){
+        //PowerMockito.when(getDao().retrieveWorkflowDetails(anyString(),anyString())).thenReturn(getWorkflow());
+        WorkflowRequest workflowRequest = getWorkflowRequest("FIREWALL","1","1",command);
+        workflowRequest.setPayload("{payload:\"payload\"}");
+        setSvcLogicGraph(createGraph(""+"_"+command));
+        WorkflowResponse response =workflowManger.executeWorkflow(workflowRequest);
+        assertFalse(response.isExecutionSuccess());
+    }
+
+    @Test
+    public void testWorkflowExist(){
+        //PowerMockito.when(getDao().queryWorkflow(anyString(),anyString())).thenReturn(true);
+        WorkflowRequest workflowRequest = getWorkflowRequest("FIREWALL","1","1",command);
+        boolean success = workflowManger.workflowExists(workflowRequest);
+        assertTrue(success);
+    }
+
+    @Test
+    public void testWorkflowExistFalse(){
+        //PowerMockito.when(getDao().queryWorkflow(anyString(),anyString())).thenReturn(false);
+        WorkflowRequest workflowRequest = getWorkflowRequest("FIREWALL","1","1",command);
+        setSvcLogicGraph(createGraph(""+"_"+command));
+        boolean success = workflowManger.workflowExists(workflowRequest);
+        assertFalse(success);
+    }
+
+
+    @Test
+    public void testEmptyCommandFlow(){
+        WorkflowRequest workflowRequest = getWorkflowRequest("FIREWALL","1","1","");
+        WorkflowResponse response =workflowManger.executeWorkflow(workflowRequest);
+        assertFalse(response.isExecutionSuccess());
+    }
+     */
+
+
+    public void setSvcLogicGraph(SvcLogicGraph svcLogicGraph) {
+        this.svcLogicGraph = svcLogicGraph;
+    }
+
+    public SvcLogicGraph getSvcLogicGraph() {
+        return svcLogicGraph;
+    }
+
+    protected SvcLogicGraph createGraph(String rpc) {
+        SvcLogicGraph svcLogicGraph = new SvcLogicGraph();
+        svcLogicGraph.setModule("APPC");
+        svcLogicGraph.setRpc(rpc);
+        svcLogicGraph.setMode("sync");
+        svcLogicGraph.setVersion("2.0.0");
+        SvcLogicNode svcLogicRootNode = new SvcLogicNode(1, "switch", svcLogicGraph);
+        SvcLogicNode svcLogicConfigureNode = new SvcLogicNode(2, "return", svcLogicGraph);
+        SvcLogicNode svcLogicOtherNode = new SvcLogicNode(3, "return", svcLogicGraph);
+        try {
+            svcLogicConfigureNode.setAttribute("status", "success");
+            svcLogicOtherNode.setAttribute("status", "failure");
+            svcLogicRootNode.setAttribute("test", "$org.openecomp.appc.action");
+            svcLogicRootNode.addOutcome("Configure", svcLogicConfigureNode);
+            svcLogicRootNode.addOutcome("Other", svcLogicOtherNode);
+        } catch (SvcLogicException e) {
+            e.printStackTrace();
+        }
+        svcLogicGraph.setRootNode(svcLogicRootNode);
+        return svcLogicGraph;
+    }
+}
diff --git a/appc-dispatcher/appc-workflow-management/appc-workflow-management-core/src/test/resources/org/openecomp/appc/default.properties b/appc-dispatcher/appc-workflow-management/appc-workflow-management-core/src/test/resources/org/openecomp/appc/default.properties
new file mode 100644
index 000000000..713e03430
--- /dev/null
+++ b/appc-dispatcher/appc-workflow-management/appc-workflow-management-core/src/test/resources/org/openecomp/appc/default.properties
@@ -0,0 +1,100 @@
+###
+# ============LICENSE_START=======================================================
+# openECOMP : APP-C
+# ================================================================================
+# Copyright (C) 2017 AT&T Intellectual Property. All rights
+# 						reserved.
+# ================================================================================
+# 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.
+# ============LICENSE_END=========================================================
+###
+
+# Define the name and path of any user-provided configuration (bootstrap) file that can be loaded to supply configuration options
+#org.openecomp.appc.bootstrap.file=executor-test.properties
+org.openecomp.appc.bootstrap.file=appc.properties
+org.openecomp.appc.bootstrap.path=/opt/openecomp/appc/data/properties,${user.home},.
+
+
+#
+# Certificate keystore and truststore
+#
+#org.openecomp.sdnc.sli.aai.ssl.trust=<jks_FILE_HERE>
+#org.openecomp.sdnc.sli.aai.ssl.trust.psswd=adminadmin
+#org.openecomp.sdnc.sli.aai.ssl.key=<p12_FILE_HERE>
+#org.openecomp.sdnc.sli.aai.ssl.key.psswd=adminadmin
+org.openecomp.sdnc.sli.aai.host.certificate.ignore=true
+org.openecomp.sdnc.sli.aai.certificate.trust.all=true
+
+#
+# Configuration file for A&AI Adapter
+#
+
+# OPEN SOURCE - EXTERNAL A&AI INSTANCE IN TEST ENVIRONMENT
+org.openecomp.sdnc.sli.aai.uri=https://10.0.1.1:8443
+
+org.openecomp.sdnc.sli.aai.path.query=/aai/v8/search/sdn-zone-query
+
+# service instance
+org.openecomp.sdnc.sli.aai.path.svcinst=/aai/v8/business/customers/customer/{customer-id}/service-subscriptions/service-subscription/{service-type}/service-instances
+org.openecomp.sdnc.sli.aai.path.svcinst.query=/aai/v8/search/generic-query?key=service-instance.service-instance-id:{svc-instance-id}&start-node-type=service-instance&include=service-instance
+
+# complex
+org.openecomp.sdnc.sli.aai.path.complexes=/aai/v8/cloud-infrastructure/complexes
+org.openecomp.sdnc.sli.aai.path.complex=/aai/v8/cloud-infrastructure/complexes/complex/{physical-location-id}
+
+# vservers
+org.openecomp.sdnc.sli.aai.path.vservers=/aai/v8/cloud-infrastructure/tenants/tenant/{tenant-id}/vservers
+org.openecomp.sdnc.sli.aai.path.vserver =/aai/v8/cloud-infrastructure/tenants/tenant/{tenant-id}/vservers/vserver/{vserver-id}
+
+# generic-vnf
+org.openecomp.sdnc.sli.aai.path.generic.vnfs=/aai/v8/network/generic-vnfs/generic-vnf/
+org.openecomp.sdnc.sli.aai.path.generic.vnf=/aai/v8/network/generic-vnfs/generic-vnf/{vnf-id}
+
+#
+# Formatting
+#
+org.openecomp.sdnc.sli.aai.param.format=filter=%s:%s
+org.openecomp.sdnc.sli.aai.param.vnf_type=vnf-type
+org.openecomp.sdnc.sli.aai.param.physical.location.id=physical-location-id
+org.openecomp.sdnc.sli.aai.param.service.type=service-type
+
+
+org.openecomp.appc.logging.path=${user.home},etc,../etc,.
+org.openecomp.appc.logging.file=logback.xml
+
+org.openecomp.appc.db.url.%s", schema), "");
+org.openecomp.appc.db.user.%s", schema), "");
+org.openecomp.appc.db.pass.%s", schema), "");
+
+# This value is provided in appc.properties
+#dmaap.poolMembers=<DMAAP_IP>:3904
+
+dmaap.topic.read=APPC-TEST2
+dmaap.topic.write=APPC-TEST2
+#dmaap.topic.read.filter={"class":"Assigned","field":"request"}
+dmaap.topic.read.filter={"class": "And","filters": [{"class": "Assigned","field": "request"},{"class": "Unassigned","field": "response"}]}
+dmaap.client.name=APPC-TEST-CLIENT
+dmaap.client.name.id=0
+#dmaap.client.key=random
+#dmaap.client.secret=random
+
+dmaap.threads.queuesize.min=1
+dmaap.threads.queuesize.max=1000
+dmaap.threads.poolsize.min=2
+dmaap.threads.poolsize.max=2
+
+#
+# This needs to be changed so that the action can be appended to the end of the URL path
+#
+#provider.urls.topology=https://admin:password@<IP_ADDRESS>:8443/restconf/operations/appc-provider:topology-service
+#provider.urls.topology=https://admin:password@<IP_ADDRESS>:8443/restconf/operations/appc-provider: