1 files changed, 287 insertions, 0 deletions
diff --git a/sli/provider/src/main/java/org/openecomp/sdnc/sli/provider/SvcLogicServiceImpl.java b/sli/provider/src/main/java/org/openecomp/sdnc/sli/provider/SvcLogicServiceImpl.java
new file mode 100644
index 0000000..bd97224
--- /dev/null
+++ b/sli/provider/src/main/java/org/openecomp/sdnc/sli/provider/SvcLogicServiceImpl.java
@@ -0,0 +1,287 @@
+/*-
+ * ============LICENSE_START=======================================================
+ * openECOMP : SDN-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.sdnc.sli.provider;
+
+import java.util.HashMap;
+import java.util.Properties;
+
+import org.opendaylight.controller.md.sal.dom.api.DOMDataBroker;
+import org.openecomp.sdnc.sli.MetricLogger;
+import org.openecomp.sdnc.sli.SvcLogicContext;
+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.osgi.framework.BundleContext;
+import org.osgi.framework.FrameworkUtil;
+import org.osgi.framework.InvalidSyntaxException;
+import org.osgi.framework.ServiceEvent;
+import org.osgi.framework.ServiceListener;
+import org.osgi.framework.ServiceReference;
+import org.osgi.util.tracker.ServiceTracker;
+import org.slf4j.Logger;
+import org.slf4j.LoggerFactory;
+import org.slf4j.MDC;
+
+public class SvcLogicServiceImpl implements SvcLogicService {
+
+	private static final Logger LOG = LoggerFactory
+			.getLogger(SvcLogicServiceImpl.class);
+
+	private HashMap<String, SvcLogicNodeExecutor> nodeExecutors = null;
+
+	private BundleContext bctx = null;
+
+	private void registerExecutors() {
+
+		LOG.info("Entered register executors");
+		if (bctx == null) {
+			bctx = FrameworkUtil.getBundle(this.getClass()).getBundleContext();
+		}
+
+		if (nodeExecutors == null) {
+			nodeExecutors = new HashMap<String, SvcLogicNodeExecutor>();
+		}
+
+		LOG.info("Opening service tracker");
+		ServiceTracker tracker = new ServiceTracker(bctx,
+				SvcLogicNodeExecutor.class.getName(), null);
+		
+		tracker.open();
+
+		ServiceListener listener = new ServiceListener() {
+
+			public void serviceChanged(ServiceEvent ev) {
+				ServiceReference sr = ev.getServiceReference();
+				switch (ev.getType()) {
+				case ServiceEvent.REGISTERED: {
+					registerExecutor(sr);
+				}
+					break;
+				case ServiceEvent.UNREGISTERING: {
+					unregisterExecutor(sr);
+				}
+					break;
+				}
+			}
+		};
+
+		LOG.info("Adding service listener");
+		String filter = "(objectclass=" + SvcLogicNodeExecutor.class.getName()
+				+ ")";
+		try {
+			bctx.addServiceListener(listener, filter);
+			ServiceReference[] srl = bctx.getServiceReferences(
+					SvcLogicNodeExecutor.class.getName(), null);
+			for (int i = 0; srl != null && i < srl.length; i++) {
+				listener.serviceChanged(new ServiceEvent(
+						ServiceEvent.REGISTERED, srl[i]));
+			}
+		} catch (InvalidSyntaxException e) {
+			e.printStackTrace();
+		}
+		LOG.info("Done registerExecutors");
+	}
+
+	public void registerExecutor(ServiceReference sr) {
+
+		String nodeName = (String) sr.getProperty("nodeType");
+		if (nodeName != null) {
+
+			SvcLogicNodeExecutor executor = null;
+
+			try {
+				executor = (SvcLogicNodeExecutor) bctx.getService(sr);
+			} catch (Exception e) {
+				LOG.error("Cannot get service executor for " + nodeName);
+				return;
+			}
+
+            registerExecutor(nodeName, executor);
+
+		}
+	}
+	
+	public void registerExecutor(String nodeName, SvcLogicNodeExecutor executor)
+	{
+		if (nodeExecutors == null) {
+			nodeExecutors = new HashMap<String, SvcLogicNodeExecutor>();
+		}
+		LOG.info("SLI - registering executor for node type "+nodeName);
+		nodeExecutors.put(nodeName, executor);
+	}
+
+	public void unregisterExecutor(ServiceReference sr) {
+		String nodeName = (String) sr.getProperty("nodeType");
+
+		if (nodeName != null) {
+			
+             unregisterExecutor(nodeName);
+
+		}
+
+	}
+	
+	public void unregisterExecutor(String nodeName)
+	{
+
+		LOG.info("SLI - unregistering executor for node type "+nodeName);
+		nodeExecutors.remove(nodeName);
+	}
+	
+
+
+	
+	public SvcLogicContext execute(SvcLogicGraph graph, SvcLogicContext ctx)
+			throws SvcLogicException {
+
+		if (nodeExecutors == null) {
+			registerExecutors();
+		}
+		
+		// Set service name in MDC to reference current working directed graph
+		MDC.put(MetricLogger.SERVICE_NAME, graph.getModule()+":"+graph.getRpc()+"/v"+graph.getVersion());
+
+		SvcLogicNode curNode = graph.getRootNode();
+		LOG.info("About to execute graph " + graph.toString());
+		
+		
+
+		while (curNode != null) {
+			LOG.info("About to execute node # "+curNode.getNodeId()+" ("+curNode.getNodeType()+")");
+			
+			SvcLogicNode nextNode = executeNode(curNode, ctx);
+			curNode = nextNode;
+		}
+
+		return (ctx);
+	}
+
+
+	public SvcLogicNode executeNode(SvcLogicNode node, SvcLogicContext ctx)
+			throws SvcLogicException {
+		if (node == null) {
+			return (null);
+		}
+
+		if (LOG.isDebugEnabled()) {
+			LOG.debug("Executing node " + node.getNodeId());
+		}
+
+		SvcLogicNodeExecutor executor = nodeExecutors.get(node.getNodeType());
+
+		if (executor != null) {
+			LOG.debug("Executing node executor for node type "+node.getNodeType()+" - "+executor.getClass().getName());
+			return (executor.execute(this, node, ctx));
+		} else {
+			if (LOG.isDebugEnabled()) {
+				LOG.debug(node.getNodeType() + " node not implemented");
+			}
+			SvcLogicNode nextNode = node.getOutcomeValue("failure");
+			if (nextNode != null) {
+				if (LOG.isDebugEnabled()) {
+					LOG.debug("about to execute failure branch");
+				}
+				return (nextNode);
+			}
+
+			nextNode = node.getOutcomeValue("Other");
+			if (nextNode != null) {
+				if (LOG.isDebugEnabled()) {
+					LOG.debug("about to execute Other branch");
+				}
+			} else {
+				if (LOG.isDebugEnabled()) {
+					LOG.debug("no failure or Other branch found");
+				}
+			}
+			return (nextNode);
+		}
+
+	}
+
+	@Override
+	public boolean hasGraph(String module, String rpc, String version, String mode) throws SvcLogicException
+	{
+		SvcLogicStore store = SvcLogicActivator.getStore();
+
+		return (store.hasGraph(module, rpc, version, mode));
+	}
+	
+	@Override
+	public Properties execute(String module, String rpc, String version, String mode, Properties props)
+			throws SvcLogicException {
+		return(execute(module, rpc, version, mode, props, null));
+	}
+	
+	
+	@Override
+	public Properties execute(String module, String rpc, String version, String mode,
+			Properties props, DOMDataBroker domDataBroker) throws SvcLogicException {
+		
+
+		// See if there is a service logic defined
+		//
+		SvcLogicStore store = SvcLogicActivator.getStore();
+
+		LOG.info("Fetching service logic from data store");
+		SvcLogicGraph graph = store.fetch(module, rpc, version, mode);
+		
+		
+		
+		if (graph == null)
+		{
+			Properties retProps = new Properties();
+			retProps.setProperty("error-code", "401");
+			retProps.setProperty("error-message", "No service logic found for ["+module+","+rpc+","+version+","+mode+"]");
+			return(retProps);
+
+		}
+		
+		if (nodeExecutors == null) {
+			LOG.info("Start: registering node executors");
+			registerExecutors();
+
+			LOG.info("Done: registering node executors");
+		}
+		
+		LOG.info("About to execute graph " + graph.toString());
+
+		LOG.info("Executing root node");
+		SvcLogicContext ctx = new SvcLogicContext(props);
+		ctx.setDomDataBroker(domDataBroker);
+		SvcLogicNode curNode = graph.getRootNode();
+
+		while (curNode != null) {
+			LOG.info("About to execute node # "+curNode.getNodeId()+" ("+curNode.getNodeType()+")");
+			SvcLogicNode nextNode = executeNode(curNode, ctx);
+			curNode = nextNode;
+		}
+		
+
+		return(ctx.toProperties());
+	}
+	
+
+
+	
+}