[CCSDK-6] Populate seed code

Add seed code for sli/adaptors repository
Update code to use org.onap.ccsdk.sli.core

Change-Id: I477c7a24f2cc1fed8fb0975fe9f33733411c27f9
Signed-off-by: Dan Timoney <dtimoney@att.com>

9 files changed, 869 insertions, 0 deletions

diff --git a/mdsal-resource/provider/pom.xml b/mdsal-resource/provider/pom.xml
new file mode 100755
index 000000000..f41bf9c78
--- /dev/null
+++ b/mdsal-resource/provider/pom.xml
@@ -0,0 +1,122 @@
+<?xml version="1.0" encoding="UTF-8"?>
+<project xmlns="http://maven.apache.org/POM/4.0.0" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd">
+	<modelVersion>4.0.0</modelVersion>
+	<parent>
+		<groupId>org.openecomp.sdnc.adaptors</groupId>
+		<artifactId>mdsal-resource</artifactId>
+		<version>0.0.1-SNAPSHOT</version>
+	</parent>
+	<artifactId>mdsal-resource-provider</artifactId>
+	<packaging>bundle</packaging>
+	<name>MD-SAL Resource Adaptor - Provider</name>
+	<url>http://maven.apache.org</url>
+	<properties>
+		<project.build.sourceEncoding>UTF-8</project.build.sourceEncoding>
+	</properties>
+	<dependencies>
+
+		<dependency>
+			<groupId>junit</groupId>
+			<artifactId>junit</artifactId>
+			<version>3.8.1</version>
+			<scope>test</scope>
+		</dependency>
+		<dependency>
+			<groupId>org.onap.ccsdk.sli.core</groupId>
+			<artifactId>sli-common</artifactId>
+			<version>${sdnctl.sli.version}</version>
+			<scope>compile</scope>
+		</dependency>
+		<dependency>
+			<groupId>org.onap.ccsdk.sli.core</groupId>
+			<artifactId>sli-provider</artifactId>
+			<version>${sdnctl.sli.version}</version>
+			<scope>compile</scope>
+		</dependency>
+		<dependency>
+			<groupId>equinoxSDK381</groupId>
+			<artifactId>org.eclipse.osgi</artifactId>
+			<version>${equinox.osgi.version}</version>
+		</dependency>
+		<dependency>
+			<groupId>org.slf4j</groupId>
+			<artifactId>slf4j-api</artifactId>
+			<version>${slf4j.version}</version>
+		</dependency>
+		<dependency>
+			<groupId>org.slf4j</groupId>
+			<artifactId>jcl-over-slf4j</artifactId>
+			<version>${slf4j.version}</version>
+		</dependency>
+		<dependency>
+			<groupId>commons-codec</groupId>
+			<artifactId>commons-codec</artifactId>
+			<version>${commons.codec.version}</version>
+		</dependency>
+
+	</dependencies>
+
+	<build>
+		<plugins>
+
+			<plugin>
+				<groupId>org.apache.felix</groupId>
+				<artifactId>maven-bundle-plugin</artifactId>
+				<version>${bundle.plugin.version}</version>
+				<extensions>true</extensions>
+				<configuration>
+					<instructions>
+						<Bundle-SymbolicName>org.openecomp.sdnc.sli.resource.mdsal</Bundle-SymbolicName>
+						<Bundle-Activator>org.openecomp.sdnc.sli.resource.mdsal.MdsalResourceActivator</Bundle-Activator>
+						<Export-Package>org.openecomp.sdnc.sli.resource.mdsal</Export-Package>
+						<Import-Package>org.openecomp.sdnc.sli.*,org.osgi.framework.*,org.slf4j.*,com.mysql.jdbc.*</Import-Package>
+						<!-- <Embed-Dependency>*;scope=compile|runtime;artifactId=!sli-common|org.eclipse.osgi|slf4j-api|jcl-over-slf4j|mysql-connector-java|xml-apis</Embed-Dependency> -->
+						<Import-Package>*</Import-Package>
+						<Embed-Transitive>true</Embed-Transitive>
+					</instructions>
+
+
+				</configuration>
+
+			</plugin>
+
+
+		</plugins>
+		<pluginManagement>
+			<plugins>
+				<!--This plugin's configuration is used to store Eclipse m2e settings
+					only. It has no influence on the Maven build itself. -->
+				<plugin>
+					<groupId>org.eclipse.m2e</groupId>
+					<artifactId>lifecycle-mapping</artifactId>
+					<version>1.0.0</version>
+					<configuration>
+						<lifecycleMappingMetadata>
+							<pluginExecutions>
+								<pluginExecution>
+									<pluginExecutionFilter>
+										<groupId>
+											com.brocade.developer
+										</groupId>
+										<artifactId>
+											providermodule-plugin
+										</artifactId>
+										<versionRange>
+											[1.2.0.100-SNAPSHOT,)
+										</versionRange>
+										<goals>
+											<goal>process</goal>
+										</goals>
+									</pluginExecutionFilter>
+									<action>
+										<ignore />
+									</action>
+								</pluginExecution>
+							</pluginExecutions>
+						</lifecycleMappingMetadata>
+					</configuration>
+				</plugin>
+			</plugins>
+		</pluginManagement>
+	</build>
+</project>
diff --git a/mdsal-resource/provider/src/main/java/org/openecomp/sdnc/sli/resource/mdsal/ConfigResource.java b/mdsal-resource/provider/src/main/java/org/openecomp/sdnc/sli/resource/mdsal/ConfigResource.java
new file mode 100644
index 000000000..ed0ed0638
--- /dev/null
+++ b/mdsal-resource/provider/src/main/java/org/openecomp/sdnc/sli/resource/mdsal/ConfigResource.java
@@ -0,0 +1,151 @@
+/*-
+ * ============LICENSE_START=======================================================
+ * openECOMP : SDN-C
+ * ================================================================================
+ * Copyright (C) 2017 ONAP 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.resource.mdsal;
+
+import java.util.Map;
+
+import org.onap.ccsdk.sli.core.sli.SvcLogicContext;
+import org.onap.ccsdk.sli.core.sli.SvcLogicException;
+import org.onap.ccsdk.sli.core.sli.SvcLogicResource;
+import org.onap.ccsdk.sli.core.sli.SvcLogicResource.QueryStatus;
+import org.slf4j.Logger;
+import org.slf4j.LoggerFactory;
+import org.w3c.dom.Document;
+
+public class ConfigResource implements SvcLogicResource {
+
+	private static final Logger LOG = LoggerFactory.getLogger(ConfigResource.class);
+
+	private RestService restService;
+
+	public ConfigResource(String sdncProtocol, String sdncHost, String sdncPort, String sdncUser, String sdncPasswd)
+	{
+		restService = new RestService(sdncProtocol, sdncHost, sdncPort, sdncUser, sdncPasswd, RestService.PayloadType.XML);
+	}
+
+	@Override
+	public QueryStatus isAvailable(String resource, String key, String prefix, SvcLogicContext ctx) throws SvcLogicException
+	{
+		return(query(resource, false, null, key, prefix, null, null));
+	}
+
+	@Override
+	public QueryStatus exists(String resource, String key, String prefix, SvcLogicContext ctx) throws SvcLogicException
+	{
+
+		return(query(resource, false, null, key, prefix, null, null));
+
+	}
+
+	@Override
+	public QueryStatus query(String resource, boolean localOnly, String select, String key, String prefix,
+			String orderBy, SvcLogicContext ctx) throws SvcLogicException {
+
+
+		String module = resource;
+		StringBuffer restQuery = new StringBuffer();
+
+		String[] keyParts = key.split("/");
+
+		for (String keyPart : keyParts) {
+			if (restQuery.length() > 0) {
+				restQuery.append("/");
+			}
+			if (keyPart.startsWith("$")) {
+
+				restQuery.append(ctx.resolve(keyPart.substring(1)));
+			} else {
+				restQuery.append(keyPart);
+			}
+		}
+
+		String restQueryStr = restQuery.toString();
+		if ((restQueryStr.startsWith("'") && restQueryStr.endsWith("'")) ||
+				(restQueryStr.startsWith("\"") && restQueryStr.endsWith("\""))) {
+			restQueryStr = restQueryStr.substring(1, restQueryStr.length()-1);
+		}
+
+		String urlString = "restconf/config/" + module + ":" + restQueryStr;
+
+                LOG.info("Querying resource: " + resource + ". At URL: " + urlString);
+
+		Document results = restService.get(urlString);
+
+
+		if (results == null) {
+			return(QueryStatus.NOT_FOUND);
+		} else {
+
+			if (ctx != null) {
+				ctx.mergeDocument(prefix, results);
+			}
+			return(QueryStatus.SUCCESS);
+		}
+
+	}
+
+	@Override
+	public QueryStatus reserve(String resource, String select, String key, String prefix,
+			SvcLogicContext ctx) throws SvcLogicException {
+
+
+		return(QueryStatus.SUCCESS);
+
+	}
+
+	@Override
+	public QueryStatus release(String resource, String key, SvcLogicContext ctx) throws SvcLogicException {
+
+		return(QueryStatus.SUCCESS);
+	}
+
+	@Override
+	public QueryStatus delete(String arg0, String arg1, SvcLogicContext arg2)
+			throws SvcLogicException {
+		// TODO Auto-generated method stub
+		return(QueryStatus.SUCCESS);
+	}
+
+	@Override
+	public QueryStatus save(String arg0, boolean arg1, boolean localOnly, String arg2,
+			Map<String, String> arg3, String arg4, SvcLogicContext arg5)
+			throws SvcLogicException {
+		// TODO Auto-generated method stub
+		return(QueryStatus.SUCCESS);
+	}
+
+	@Override
+	public QueryStatus notify(String resource, String action, String key,
+			SvcLogicContext ctx) throws SvcLogicException {
+		return(QueryStatus.SUCCESS);
+	}
+
+
+	public QueryStatus update(String resource, String key,
+			Map<String, String> parms, String prefix, SvcLogicContext ctx)
+			throws SvcLogicException {
+		return(QueryStatus.SUCCESS);
+	}
+
+
+
+}
diff --git a/mdsal-resource/provider/src/main/java/org/openecomp/sdnc/sli/resource/mdsal/MdsalResourceActivator.java b/mdsal-resource/provider/src/main/java/org/openecomp/sdnc/sli/resource/mdsal/MdsalResourceActivator.java
new file mode 100644
index 000000000..ea0bab263
--- /dev/null
+++ b/mdsal-resource/provider/src/main/java/org/openecomp/sdnc/sli/resource/mdsal/MdsalResourceActivator.java
@@ -0,0 +1,106 @@
+/*-
+ * ============LICENSE_START=======================================================
+ * openECOMP : SDN-C
+ * ================================================================================
+ * Copyright (C) 2017 ONAP 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.resource.mdsal;
+
+import java.io.File;
+import java.io.FileInputStream;
+import java.util.LinkedList;
+import java.util.Properties;
+
+import org.onap.ccsdk.sli.core.sli.ConfigurationException;
+import org.onap.ccsdk.sli.core.sli.SvcLogicResource;
+import org.osgi.framework.BundleActivator;
+import org.osgi.framework.BundleContext;
+import org.osgi.framework.ServiceRegistration;
+import org.slf4j.Logger;
+import org.slf4j.LoggerFactory;
+
+public class MdsalResourceActivator implements BundleActivator {
+
+
+
+	private static final String SDNC_CONFIG_DIR = "SDNC_CONFIG_DIR";
+
+	public LinkedList<ServiceRegistration> registrations = new LinkedList<ServiceRegistration>();
+
+	private static final Logger LOG = LoggerFactory
+			.getLogger(MdsalResourceActivator.class);
+
+	@Override
+	public void start(BundleContext ctx) throws Exception {
+
+		// Read properties
+		Properties props = new Properties();
+
+		String propDir = System.getenv(SDNC_CONFIG_DIR);
+		if (propDir == null) {
+
+			propDir = "/opt/sdnc/data/properties";
+		}
+		String propPath = propDir + "/mdsal-resource.properties";
+
+
+		File propFile = new File(propPath);
+
+		if (!propFile.exists()) {
+
+			throw new ConfigurationException(
+					"Missing configuration properties file : "
+							+ propFile);
+		}
+		try {
+
+			props.load(new FileInputStream(propFile));
+		} catch (Exception e) {
+			throw new ConfigurationException(
+					"Could not load properties file " + propPath, e);
+
+		}
+
+		String sdncUser = props.getProperty("org.openecomp.sdnc.sli.resource.mdsal.sdnc-user", "admin");
+		String sdncPasswd = props.getProperty("org.openecomp.sdnc.sli.resource.mdsal.sdnc-passwd", "admin");
+		String sdncHost = props.getProperty("org.openecomp.sdnc.sli.resource.mdsal.sdnc-host", "localhost");
+		String sdncProtocol = props.getProperty("org.openecomp.sdnc.sli.resource.mdsal.sdnc-protocol", "https");
+		String sdncPort = props.getProperty("org.openecomp.sdnc.sli.resource.mdsal.sdnc-port", "8443");
+
+		// Advertise MD-SAL resource adaptors
+		SvcLogicResource impl = new ConfigResource(sdncProtocol, sdncHost, sdncPort, sdncUser, sdncPasswd);
+
+		LOG.debug("Registering MdsalResource service "+impl.getClass().getName());
+		registrations.add(ctx.registerService(impl.getClass().getName(), impl, null));
+
+		impl = new OperationalResource(sdncProtocol, sdncHost, sdncPort, sdncUser, sdncPasswd);
+
+		LOG.debug("Registering MdsalResource service "+impl.getClass().getName());
+		registrations.add(ctx.registerService(impl.getClass().getName(), impl, null));
+	}
+
+	@Override
+	public void stop(BundleContext ctx) throws Exception {
+
+		for (ServiceRegistration registration : registrations)
+		{
+			registration.unregister();
+		}
+	}
+
+}
diff --git a/mdsal-resource/provider/src/main/java/org/openecomp/sdnc/sli/resource/mdsal/OperationalResource.java b/mdsal-resource/provider/src/main/java/org/openecomp/sdnc/sli/resource/mdsal/OperationalResource.java
new file mode 100644
index 000000000..32323e3b1
--- /dev/null
+++ b/mdsal-resource/provider/src/main/java/org/openecomp/sdnc/sli/resource/mdsal/OperationalResource.java
@@ -0,0 +1,151 @@
+/*-
+ * ============LICENSE_START=======================================================
+ * openECOMP : SDN-C
+ * ================================================================================
+ * Copyright (C) 2017 ONAP 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.resource.mdsal;
+
+import java.util.Map;
+
+import org.onap.ccsdk.sli.core.sli.SvcLogicContext;
+import org.onap.ccsdk.sli.core.sli.SvcLogicException;
+import org.onap.ccsdk.sli.core.sli.SvcLogicResource;
+import org.onap.ccsdk.sli.core.sli.SvcLogicResource.QueryStatus;
+import org.slf4j.Logger;
+import org.slf4j.LoggerFactory;
+import org.w3c.dom.Document;
+
+public class OperationalResource implements SvcLogicResource {
+
+	private static final Logger LOG = LoggerFactory.getLogger(OperationalResource.class);
+
+	private RestService restService;
+
+	public OperationalResource(String sdncProtocol, String sdncHost, String sdncPort, String sdncUser, String sdncPasswd)
+	{
+		restService = new RestService(sdncProtocol, sdncHost, sdncPort, sdncUser, sdncPasswd, RestService.PayloadType.XML);
+
+
+	}
+
+	@Override
+	public QueryStatus isAvailable(String resource, String key, String prefix, SvcLogicContext ctx) throws SvcLogicException
+	{
+		return(query(resource, false, null, key, prefix, null, null));
+	}
+
+	@Override
+	public QueryStatus exists(String resource, String key, String prefix, SvcLogicContext ctx) throws SvcLogicException
+	{
+
+		return(query(resource, false, null, key, prefix, null, null));
+
+	}
+
+	@Override
+	public QueryStatus query(String resource, boolean localOnly, String select, String key, String prefix,
+			String orderBy, SvcLogicContext ctx) throws SvcLogicException {
+
+
+		String module = resource;
+		StringBuffer restQuery = new StringBuffer();
+
+		String[] keyParts = key.split("/");
+
+		for (String keyPart : keyParts) {
+			if (restQuery.length() > 0) {
+				restQuery.append("/");
+			}
+			if (keyPart.startsWith("$")) {
+
+				restQuery.append(ctx.resolve(keyPart.substring(1)));
+			} else {
+				restQuery.append(keyPart);
+			}
+		}
+
+        String restQueryStr = restQuery.toString();
+        if ((restQueryStr.startsWith("'") && restQueryStr.endsWith("'")) ||
+                (restQueryStr.startsWith("\"") && restQueryStr.endsWith("\""))) {
+            restQueryStr = restQueryStr.substring(1, restQueryStr.length()-1);
+        }
+
+		String urlString = "restconf/operational/" + module + ":" + restQueryStr;
+
+                LOG.info("Querying resource: " + resource + ". At URL: " + urlString);
+
+		Document results = restService.get(urlString);
+
+
+		if (results == null) {
+			return(QueryStatus.NOT_FOUND);
+		} else {
+
+			if (ctx != null) {
+				ctx.mergeDocument(prefix, results);
+			}
+			return(QueryStatus.SUCCESS);
+		}
+
+	}
+
+	@Override
+	public QueryStatus reserve(String resource, String select, String key, String prefix,
+			SvcLogicContext ctx) throws SvcLogicException {
+
+
+		return(QueryStatus.SUCCESS);
+
+	}
+
+	@Override
+	public QueryStatus release(String resource, String key, SvcLogicContext ctx) throws SvcLogicException {
+
+		return(QueryStatus.SUCCESS);
+	}
+
+	@Override
+	public QueryStatus delete(String arg0, String arg1, SvcLogicContext arg2)
+			throws SvcLogicException {
+		// TODO Auto-generated method stub
+		return(QueryStatus.SUCCESS);
+	}
+
+	@Override
+	public QueryStatus save(String arg0, boolean arg1, boolean localOnly, String arg2,
+			Map<String, String> arg3, String arg4, SvcLogicContext arg5)
+			throws SvcLogicException {
+		// TODO Auto-generated method stub
+		return(QueryStatus.SUCCESS);
+	}
+
+	@Override
+	public QueryStatus notify(String resource, String action, String key,
+			SvcLogicContext ctx) throws SvcLogicException {
+		return(QueryStatus.SUCCESS);
+	}
+
+	public QueryStatus update(String resource, String key,
+			Map<String, String> parms, String prefix, SvcLogicContext ctx)
+			throws SvcLogicException {
+		return(QueryStatus.SUCCESS);
+	}
+
+
+}
diff --git a/mdsal-resource/provider/src/main/java/org/openecomp/sdnc/sli/resource/mdsal/RestService.java b/mdsal-resource/provider/src/main/java/org/openecomp/sdnc/sli/resource/mdsal/RestService.java
new file mode 100644
index 000000000..21d3439d4
--- /dev/null
+++ b/mdsal-resource/provider/src/main/java/org/openecomp/sdnc/sli/resource/mdsal/RestService.java
@@ -0,0 +1,212 @@
+/*-
+ * ============LICENSE_START=======================================================
+ * openECOMP : SDN-C
+ * ================================================================================
+ * Copyright (C) 2017 ONAP 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.resource.mdsal;
+
+import java.io.BufferedReader;
+import java.io.ByteArrayInputStream;
+import java.io.DataOutputStream;
+import java.io.IOException;
+import java.io.InputStreamReader;
+import java.net.Authenticator;
+import java.net.HttpURLConnection;
+import java.net.PasswordAuthentication;
+import java.net.URL;
+
+import javax.net.ssl.HostnameVerifier;
+import javax.net.ssl.HttpsURLConnection;
+import javax.net.ssl.SSLSession;
+import javax.xml.parsers.DocumentBuilder;
+import javax.xml.parsers.DocumentBuilderFactory;
+
+import org.apache.commons.codec.binary.Base64;
+import org.slf4j.Logger;
+import org.slf4j.LoggerFactory;
+import org.w3c.dom.Document;
+
+
+
+
+public class RestService {
+	
+	private static final Logger LOG = LoggerFactory.getLogger(ConfigResource.class);
+	
+	public enum PayloadType {
+		XML,
+		JSON
+	}
+	
+	private class SdncAuthenticator extends Authenticator {
+		
+		private String user;
+		private String passwd;
+
+		SdncAuthenticator(String user, String passwd) {
+			this.user = user;
+			this.passwd = passwd;
+		}
+		@Override
+		protected PasswordAuthentication getPasswordAuthentication() {
+			return new PasswordAuthentication(user, passwd.toCharArray());
+		}
+		
+	}
+	
+	private String user;
+	private String passwd;
+	private PayloadType payloadType;
+
+	private String protocol;
+	private String host;
+	private String port;
+	
+	public RestService(String protocol, String host, String port, String user, String passwd, PayloadType payloadType) {
+		this.protocol = protocol;
+		this.host = host;
+		this.port = port;
+		this.user = user;
+		this.passwd = passwd;
+		this.payloadType = payloadType;
+	}
+	
+	private HttpURLConnection getRestConnection(String urlString, String method) throws IOException
+	{
+		
+		URL sdncUrl = new URL(urlString);
+		Authenticator.setDefault(new SdncAuthenticator(user, passwd));
+		
+		HttpURLConnection conn = (HttpURLConnection) sdncUrl.openConnection();
+		
+		String authStr = user+":"+passwd;
+		String encodedAuthStr = new String(Base64.encodeBase64(authStr.getBytes()));
+		
+		conn.addRequestProperty("Authentication", "Basic "+encodedAuthStr);
+		
+		conn.setRequestMethod(method);
+		
+		if (payloadType == PayloadType.XML) {
+			conn.setRequestProperty("Content-Type", "application/xml");
+			conn.setRequestProperty("Accept", "application/xml");
+		} else {
+
+			conn.setRequestProperty("Content-Type", "application/json");
+			conn.setRequestProperty("Accept", "application/json");
+		}
+		
+		conn.setDoInput(true);
+		conn.setDoOutput(true);
+		conn.setUseCaches(false);
+		
+		return(conn);
+		
+	}
+	
+
+	private Document send(String urlString, byte[] msgBytes, String method) {
+		Document response = null;
+		String fullUrl = protocol + "://" + host + ":" + port + "/" + urlString;
+		LOG.info("Sending REST "+method +" to "+fullUrl);
+		
+		if (msgBytes != null) {
+			LOG.info("Message body:\n"+msgBytes);
+		}
+		
+		try {
+			HttpURLConnection conn = getRestConnection(fullUrl, method);
+
+			if (conn instanceof HttpsURLConnection) {
+				HostnameVerifier hostnameVerifier = new HostnameVerifier() {
+					@Override
+					public boolean verify(String hostname, SSLSession session) {
+						return true;
+					}
+				};
+				((HttpsURLConnection)conn).setHostnameVerifier(hostnameVerifier);
+			}
+
+			// Write message
+			if (msgBytes != null) {
+				conn.setRequestProperty("Content-Length", ""+msgBytes.length);
+				DataOutputStream outStr = new DataOutputStream(conn.getOutputStream());
+				outStr.write(msgBytes);
+				outStr.close();
+			} else {
+				conn.setRequestProperty("Content-Length", "0");
+			}
+
+
+			// Read response
+			BufferedReader respRdr;
+			
+			LOG.info("Response: "+conn.getResponseCode()+" "+conn.getResponseMessage());
+			
+
+			if (conn.getResponseCode() < 300) {
+
+				respRdr = new BufferedReader(new InputStreamReader(conn.getInputStream()));
+			} else {
+				respRdr = new BufferedReader(new InputStreamReader(conn.getErrorStream()));
+			}
+
+			StringBuffer respBuff = new StringBuffer();
+
+			String respLn;
+
+			while ((respLn = respRdr.readLine()) != null) {
+				respBuff.append(respLn+"\n");
+			}
+			respRdr.close();
+
+			String respString = respBuff.toString();
+
+			LOG.info("Response body :\n"+respString);
+
+			DocumentBuilderFactory dbf = DocumentBuilderFactory.newInstance();
+			DocumentBuilder db = dbf.newDocumentBuilder();
+
+
+			response = db.parse(new ByteArrayInputStream(respString.getBytes()));
+
+		} catch (Exception e) {
+
+			LOG.error("Caught exception executing REST command", e);
+		}
+		
+		return (response);
+	}
+
+	
+	public Document get(String urlString) {
+		return(send(urlString, null, "GET"));
+	}
+	
+	public Document delete(String urlString) {
+		return(send(urlString, null, "DELETE"));
+	}
+	
+	public Document post(String urlString, byte[] msgBytes) {
+		return(send(urlString, msgBytes, "POST"));
+	}
+
+	public Document put(String urlString, byte[] msgBytes) {
+		return(send(urlString, msgBytes, "PUT"));
+	}
+}
diff --git a/mdsal-resource/provider/src/main/resources/IPV4_ADDRESS_POOL.csv b/mdsal-resource/provider/src/main/resources/IPV4_ADDRESS_POOL.csv
new file mode 100755
index 000000000..30ce117bc
--- /dev/null
+++ b/mdsal-resource/provider/src/main/resources/IPV4_ADDRESS_POOL.csv
@@ -0,0 +1,9 @@
+"192.168.1.2","OAM","AVAILABLE"
+"192.168.1.3","OAM","AVAILABLE"
+"192.168.1.4","OAM","AVAILABLE"
+"192.168.1.5","OAM","AVAILABLE"
+"192.168.1.6","OAM","AVAILABLE"
+"192.168.1.7","OAM","AVAILABLE"
+"192.168.1.8","OAM","AVAILABLE"
+"192.168.1.9","OAM","AVAILABLE"
+"192.168.1.10","OAM","AVAILABLE"
diff --git a/mdsal-resource/provider/src/main/resources/VLAN_ID_POOL.csv b/mdsal-resource/provider/src/main/resources/VLAN_ID_POOL.csv
new file mode 100755
index 000000000..6c4b0f775
--- /dev/null
+++ b/mdsal-resource/provider/src/main/resources/VLAN_ID_POOL.csv
@@ -0,0 +1,22 @@
+"1100","IPAG","AVAILABLE",NULL
+"1101","IPAG","AVAILABLE",NULL
+"1102","IPAG","AVAILABLE",NULL
+"1103","IPAG","AVAILABLE",NULL
+"1104","IPAG","AVAILABLE",NULL
+"1105","IPAG","AVAILABLE",NULL
+"1106","IPAG","AVAILABLE",NULL
+"1107","IPAG","AVAILABLE",NULL
+"1108","IPAG","AVAILABLE",NULL
+"1109","IPAG","AVAILABLE",NULL
+"1110","IPAG","AVAILABLE",NULL
+"1200","VPE","AVAILABLE",NULL
+"1201","VPE","AVAILABLE",NULL
+"1202","VPE","AVAILABLE",NULL
+"1203","VPE","AVAILABLE",NULL
+"1204","VPE","AVAILABLE",NULL
+"1205","VPE","AVAILABLE",NULL
+"1206","VPE","AVAILABLE",NULL
+"1207","VPE","AVAILABLE",NULL
+"1208","VPE","AVAILABLE",NULL
+"1209","VPE","AVAILABLE",NULL
+"1210","VPE","AVAILABLE",NULL
diff --git a/mdsal-resource/provider/src/main/resources/crtables.sql b/mdsal-resource/provider/src/main/resources/crtables.sql
new file mode 100644
index 000000000..a5dea5bf0
--- /dev/null
+++ b/mdsal-resource/provider/src/main/resources/crtables.sql
@@ -0,0 +1,70 @@
+---
+-- ============LICENSE_START=======================================================
+-- openECOMP : SDN-C
+-- ================================================================================
+-- Copyright (C) 2017 ONAP 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=========================================================
+---
+
+CREATE TABLE sdnctl.VNF (
+vnf_id varchar(80) NOT NULL,
+vnf_name varchar(80) NOT NULL,
+vnf_type varchar(10) NOT NULL,
+orchestration_status varchar(20),
+heat_stack_id varchar(80),
+mso_catalog_key varchar(80),
+availability_zone varchar(80),
+aic_site_id varchar(80),
+oam_ipv4_address varchar(20),
+CONSTRAINT P_VNF PRIMARY KEY(vnf_id));
+
+CREATE TABLE sdnctl.VNF_NETWORK_CONNECTION (
+connection_uuid varchar(80) NOT NULL,
+vnf_id varchar(80) NOT NULL,
+connection_id varchar(80),
+connection_type varchar(20),
+neutron_network_id varchar(80),
+neutron_network_name varchar(80),
+orchestration_status varchar(20),
+switch_id varchar(40),
+heat_stack_id varchar(80),
+mso_catalog_key varchar(80),
+provider_network varchar(80),
+port_group_id varchar(80),
+port_group_name varchar(80),
+CONSTRAINT P_NETWORK_CONNECTION PRIMARY KEY(connection_uuid));
+
+CREATE TABLE sdnctl.VNF_NETWORK_CONNECTION_VLAN (
+vlan_uuid varchar(80) NOT NULL,
+vlan_id numeric(4) NOT NULL,
+vlan_type varchar(5) NOT NULL,
+connection_uuid varchar(80),
+CONSTRAINT P_VNF_NETWORK_CONNECTION_VLAN PRIMARY KEY(vlan_uuid));
+
+CREATE TABLE sdnctl.VLAN_ID_POOL (
+vlan_id numeric(4) NOT NULL,
+universe varchar(40) NOT NULL,
+status varchar(40) NOT NULL,
+vlan_uuid varchar(80),
+CONSTRAINT P_VLAN_ID_POOL PRIMARY KEY(vlan_id,universe));
+
+CREATE TABLE sdnctl.IPV4_ADDRESS_POOL (
+ipv4_addr varchar(20) NOT NULL,
+universe varchar(40) NOT NULL,
+status varchar(40) NOT NULL,
+CONSTRAINT P_IPV4_ADDRESS_POOL PRIMARY KEY(ipv4_addr, universe));
+
+
diff --git a/mdsal-resource/provider/src/main/resources/svclogic.properties b/mdsal-resource/provider/src/main/resources/svclogic.properties
new file mode 100644
index 000000000..1a2cf0c78
--- /dev/null
+++ b/mdsal-resource/provider/src/main/resources/svclogic.properties
@@ -0,0 +1,26 @@
+###
+# ============LICENSE_START=======================================================
+# openECOMP : SDN-C
+# ================================================================================
+# Copyright (C) 2017 ONAP 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=========================================================
+###
+
+org.openecomp.sdnc.sli.dbtype = jdbc
+org.openecomp.sdnc.sli.jdbc.url = jdbc:mysql://dbhost:3306/sdnctl
+org.openecomp.sdnc.sli.jdbc.database = sdnctl
+org.openecomp.sdnc.sli.jdbc.user = sdnctl
+org.openecomp.sdnc.sli.jdbc.password = gamma