Moving all files to root directory

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

5 files changed, 557 insertions, 0 deletions

diff --git a/appc-dg/appc-dg-shared/appc-dg-netconf/src/main/java/org/openecomp/appc/dg/netconf/NetconfClientPlugin.java b/appc-dg/appc-dg-shared/appc-dg-netconf/src/main/java/org/openecomp/appc/dg/netconf/NetconfClientPlugin.java
new file mode 100644
index 000000000..3b75f4070
--- /dev/null
+++ b/appc-dg/appc-dg-shared/appc-dg-netconf/src/main/java/org/openecomp/appc/dg/netconf/NetconfClientPlugin.java
@@ -0,0 +1,39 @@
+/*-
+ * ============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.dg.netconf;
+
+import java.util.Map;
+
+import org.openecomp.appc.exceptions.APPCException;
+import org.openecomp.sdnc.sli.SvcLogicContext;
+import org.openecomp.sdnc.sli.SvcLogicJavaPlugin;
+
+
+
+public interface NetconfClientPlugin extends SvcLogicJavaPlugin {
+    void configure(Map<String, String> params, SvcLogicContext ctx) throws APPCException;
+    void operationStateValidation(Map<String, String> params, SvcLogicContext ctx) throws APPCException;
+    void modifyConfiguration(Map<String, String> params, SvcLogicContext ctx) throws APPCException;
+    void backupConfiguration(Map<String, String> params, SvcLogicContext ctx) throws APPCException;
+    void getConfig(Map<String, String> params, SvcLogicContext ctx) throws APPCException;
+    void getRunningConfig(Map<String, String> params, SvcLogicContext ctx) throws APPCException;
+}
diff --git a/appc-dg/appc-dg-shared/appc-dg-netconf/src/main/java/org/openecomp/appc/dg/netconf/NetconfDBPlugin.java b/appc-dg/appc-dg-shared/appc-dg-netconf/src/main/java/org/openecomp/appc/dg/netconf/NetconfDBPlugin.java
new file mode 100644
index 000000000..a48be94c7
--- /dev/null
+++ b/appc-dg/appc-dg-shared/appc-dg-netconf/src/main/java/org/openecomp/appc/dg/netconf/NetconfDBPlugin.java
@@ -0,0 +1,37 @@
+/*-
+ * ============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.dg.netconf;
+
+import java.util.Map;
+
+import org.openecomp.appc.exceptions.APPCException;
+import org.openecomp.sdnc.sli.SvcLogicContext;
+import org.openecomp.sdnc.sli.SvcLogicJavaPlugin;
+
+
+
+public interface NetconfDBPlugin extends SvcLogicJavaPlugin {
+    void retrieveDSConfiguration(Map<String, String> params, SvcLogicContext ctx) throws APPCException;
+    void retrieveVMDSConfiguration(Map<String, String> params, SvcLogicContext ctx) throws APPCException;
+    void retrieveConfigFile(Map<String, String> params, SvcLogicContext ctx) throws APPCException;
+    void retrieveConnectionDetails(Map<String, String> params, SvcLogicContext ctx) throws APPCException;
+}
diff --git a/appc-dg/appc-dg-shared/appc-dg-netconf/src/main/java/org/openecomp/appc/dg/netconf/impl/NetconfClientPluginImpl.java b/appc-dg/appc-dg-shared/appc-dg-netconf/src/main/java/org/openecomp/appc/dg/netconf/impl/NetconfClientPluginImpl.java
new file mode 100644
index 000000000..d063b5d28
--- /dev/null
+++ b/appc-dg/appc-dg-shared/appc-dg-netconf/src/main/java/org/openecomp/appc/dg/netconf/impl/NetconfClientPluginImpl.java
@@ -0,0 +1,316 @@
+/*-
+ * ============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.dg.netconf.impl;
+
+import com.fasterxml.jackson.databind.ObjectMapper;
+import org.apache.commons.lang.ObjectUtils;
+import org.apache.commons.lang3.StringUtils;
+import org.openecomp.appc.adapter.netconf.*;
+import org.openecomp.appc.adapter.netconf.util.Constants;
+import org.openecomp.appc.dg.netconf.NetconfClientPlugin;
+import org.openecomp.appc.exceptions.APPCException;
+import com.att.eelf.configuration.EELFLogger;
+import com.att.eelf.configuration.EELFManager;
+import org.openecomp.sdnc.sli.SvcLogicContext;
+import org.osgi.framework.BundleContext;
+import org.osgi.framework.FrameworkUtil;
+import org.osgi.framework.ServiceReference;
+
+import java.io.IOException;
+import java.text.DateFormat;
+import java.text.SimpleDateFormat;
+import java.util.Date;
+import java.util.Map;
+
+
+
+public class NetconfClientPluginImpl implements NetconfClientPlugin {
+
+    private static final String NETCONF_CLIENT_FACTORY_NAME = "org.openecomp.appc.adapter.netconf.NetconfClientFactory";
+    private static ObjectMapper mapper = new ObjectMapper();
+    private static EELFLogger logger = EELFManager.getInstance().getApplicationLogger();
+
+    private NetconfDataAccessService dao;
+    private NetconfClientFactory clientFactory;
+
+    public NetconfClientPluginImpl() {
+        BundleContext bctx = FrameworkUtil.getBundle(this.getClass()).getBundleContext();
+        ServiceReference srefNetconfClientFactory = bctx.getServiceReference(NetconfClientFactory.class);
+        clientFactory = (NetconfClientFactory) bctx.getService(srefNetconfClientFactory);
+    }
+
+    public void setDao(NetconfDataAccessService dao) {
+        this.dao = dao;
+        this.dao.setSchema(Constants.NETCONF_SCHEMA);
+    }
+
+    public void configure(Map<String, String> params, SvcLogicContext ctx) throws APPCException {
+
+        try {
+            NetconfClient client = clientFactory.GetNetconfClient(NetconfClientType.SSH);
+            try {
+                NetconfConnectionDetails connectionDetails = mapper.readValue(params.get("connection-details"), NetconfConnectionDetails.class);
+                String netconfMessage = params.get("file-content");
+                client.connect(connectionDetails);
+                client.configure(netconfMessage);
+            } catch (IOException e) {
+                logger.error("Error " + e.getMessage());
+                throw new APPCException(e);
+            } finally {
+                client.disconnect();
+            }
+        } catch (Exception e) {
+            ctx.setAttribute(Constants.DG_OUTPUT_STATUS_MESSAGE, e.getMessage());
+            logger.error("Error " + e.getMessage());
+            throw e;
+        }
+    }
+
+    @Override
+    public void operationStateValidation(Map<String, String> params, SvcLogicContext ctx) throws APPCException {
+        if (logger.isTraceEnabled()) {
+            logger.trace("Entering to operationStateValidation with params = "+ ObjectUtils.toString(params)+", SvcLogicContext = "+ObjectUtils.toString(ctx));
+        }
+        try{
+            String paramName = Constants.VNF_TYPE_FIELD_NAME;
+            String vfType = params.get(paramName);
+            validateMandatoryParam(paramName, vfType);
+            VnfType vnfType = VnfType.getVnfType(vfType);
+
+            paramName = Constants.VNF_HOST_IP_ADDRESS_FIELD_NAME;
+            String vnfHostIpAddress = params.get(paramName);
+            validateMandatoryParam(paramName, vnfHostIpAddress);
+
+            //get connectionDetails
+            String connectionDetailsStr = params.get(Constants.CONNECTION_DETAILS_FIELD_NAME);
+            NetconfConnectionDetails connectionDetails = null;
+            if(StringUtils.isEmpty(connectionDetailsStr)){
+                connectionDetails = retrieveConnectionDetails(vnfType);
+                connectionDetails.setHost(vnfHostIpAddress);
+                ctx.setAttribute(Constants.CONNECTION_DETAILS_FIELD_NAME, mapper.writeValueAsString(connectionDetails));
+            }else{
+                connectionDetails = mapper.readValue(connectionDetailsStr, NetconfConnectionDetails.class);
+            }
+            if(connectionDetails == null){
+                throw new IllegalStateException("missing connectionDetails for VnfType:"+vnfType.name());
+            }
+
+            //get operationsStateNetconfMessage
+            OperationalStateValidator operationalStateValidator = OperationalStateValidatorFactory.getOperationalStateValidator(vnfType);
+            String configurationFileName = operationalStateValidator.getConfigurationFileName();
+            String operationsStateNetconfMessage = null;
+            if(!StringUtils.isEmpty(configurationFileName)){
+                operationsStateNetconfMessage = retrieveConfigurationFileContent(configurationFileName);
+            }
+
+            //connect checK Opertaions state and dissconnect
+            NetconfClient client = clientFactory.GetNetconfClient(NetconfClientType.SSH);
+            try {
+                client.connect(connectionDetails);
+                String response = null;
+                if(!StringUtils.isEmpty(operationsStateNetconfMessage)) {
+                    response = client.exchangeMessage(operationsStateNetconfMessage);
+                }
+                operationalStateValidator.validateResponse(response);
+            } finally {
+                client.disconnect();
+            }
+        } catch (APPCException e) {
+            logger.error(e.getMessage());
+            ctx.setAttribute(Constants.DG_OUTPUT_STATUS_MESSAGE, e.toString());
+            throw e;
+        }
+        catch (Exception e) {
+            logger.error(e.toString());
+            ctx.setAttribute(Constants.DG_OUTPUT_STATUS_MESSAGE, e.toString());
+            throw new APPCException(e);
+        }
+    }
+
+    @Override
+    public void modifyConfiguration(Map<String, String> params, SvcLogicContext ctx) throws APPCException {
+        this.configure(params, ctx);
+    }
+
+    @Override
+    public void backupConfiguration(Map<String, String> params, SvcLogicContext ctx) throws APPCException {
+
+        NetconfClient client = null;
+        try {
+            if (logger.isDebugEnabled()) {
+                logger.debug("Entered backup to DEVICE_INTERFACE_LOG");
+            }
+
+            client = clientFactory.GetNetconfClient(NetconfClientType.SSH);
+            //get connection details
+            NetconfConnectionDetails connectionDetails = mapper.readValue(params.get("connection-details"), NetconfConnectionDetails.class);
+            //connect the client and get configuration
+            client.connect(connectionDetails);
+            String configuration = client.getConfiguration();
+
+            //store configuration in database
+            dao.logDeviceInteraction(null,null,getCurrentDateTime(),configuration);
+
+        } catch (Exception e) {
+            logger.error("Error " + e.getMessage());
+            ctx.setAttribute(Constants.DG_OUTPUT_STATUS_MESSAGE, e.getMessage());
+            throw new APPCException(e);
+        } finally {
+            //disconnect the client
+            if(client != null) {
+                client.disconnect();
+            }
+        }
+    }
+
+    @Override
+    public void getConfig(Map<String, String> params, SvcLogicContext ctx) throws APPCException {
+        NetconfClient client = null;
+        String confId=params.get("conf-id");
+        if(confId.equalsIgnoreCase("current")){
+            try {
+                if (logger.isDebugEnabled()) {
+                    logger.debug("Entered getConfig to DEVICE_INTERFACE_LOG");
+                }
+                //get netconf client to get configuration
+                BundleContext bctx = FrameworkUtil.getBundle(this.getClass()).getBundleContext();
+                ServiceReference sref = bctx.getServiceReference(NETCONF_CLIENT_FACTORY_NAME);
+                NetconfClientFactory clientFactory = (NetconfClientFactory) bctx.getService(sref);
+                client = clientFactory.GetNetconfClient(NetconfClientType.SSH);
+                //get connection details
+                NetconfConnectionDetails connectionDetails = mapper.readValue(params.get("connection-details"), NetconfConnectionDetails.class);
+                //connect the client and get configuration
+                client.connect(connectionDetails);
+                String configuration = client.getConfiguration();
+                if(configuration !=null){
+                    //  logger.info("*************************************Configuration Output*************************************");
+                    //  logger.info(configuration);
+                    String fullConfig = ctx.getAttribute("fullConfig");
+                    fullConfig = fullConfig==null?"":fullConfig;
+                    ctx.setAttribute("fullConfig",fullConfig + configuration);
+
+                    ctx.setAttribute("getConfig_Result","Success");
+                    String entityName=ctx.getAttribute("entity");//VM name
+                    if(entityName!=null){
+                        ctx.setAttribute(entityName+".Configuration",configuration);
+                    }
+                }else{
+                    ctx.setAttribute("getConfig_Result","failure");
+                }
+                //store configuration in database
+            /*NetconfJDBC dsImpl = new NetconfJDBCImpl();
+            dsImpl.logDeviceInteraction(null,null,getCurrentDateTime(),configuration);*/
+
+            } catch (Exception e) {
+                ctx.setAttribute("getConfig_Result","failure");
+                logger.error("Error " + e.getMessage());
+                ctx.setAttribute(Constants.DG_OUTPUT_STATUS_MESSAGE, e.getMessage());
+                throw new APPCException(e);
+            } finally {
+                //disconnect the client
+                if(client != null) {
+                    client.disconnect();
+                }
+            }
+        }else{
+            logger.info("Current Conf id value is not supported");
+        }
+
+    }
+
+
+    @Override
+    public void getRunningConfig(Map<String, String> params, SvcLogicContext ctx) throws APPCException {
+        NetconfClient client = null;
+        try {
+            logger.info("Entered getRunningConfig to DEVICE_INTERFACE_LOG");
+            //get netconf client to get configuration
+            BundleContext bctx = FrameworkUtil.getBundle(this.getClass()).getBundleContext();
+            ServiceReference sref = bctx.getServiceReference(NETCONF_CLIENT_FACTORY_NAME);
+            NetconfClientFactory clientFactory = (NetconfClientFactory) bctx.getService(sref);
+            client = clientFactory.GetNetconfClient(NetconfClientType.SSH);
+            //get connection details
+            NetconfConnectionDetails connectionDetails = new NetconfConnectionDetails();
+            connectionDetails.setHost(params.get("host-ip-address"));
+            connectionDetails.setUsername(params.get("user-name"));
+            connectionDetails.setPassword(params.get("password"));
+            connectionDetails.setPort(!("".equalsIgnoreCase(params.get("port-number")))?Integer.parseInt(params.get("port-number")):NetconfConnectionDetails.DEFAULT_PORT);
+            //connect the client and get configuration
+            client.connect(connectionDetails);
+            String configuration = client.getConfiguration();
+            if(configuration !=null){
+                //  logger.info("*************************************Configuration Output*************************************");
+                ctx.setAttribute("running-config", configuration);
+
+                ctx.setAttribute("getRunningConfig_Result","Success");
+            }else{
+                ctx.setAttribute("getRunningConfig_Result","failure");
+            }
+        } catch (Exception e) {
+            ctx.setAttribute("getRunningConfig_Result","failure");
+            logger.error("Error " + e.getMessage());
+            ctx.setAttribute(Constants.DG_OUTPUT_STATUS_MESSAGE, e.getMessage());
+            throw new APPCException(e);
+        } finally {
+            //disconnect the client
+            if(client != null) {
+                client.disconnect();
+            }
+        }
+    }
+
+    private String getCurrentDateTime() {
+
+        DateFormat dateFormat = new SimpleDateFormat("yyyy/MM/dd HH:mm:ss");
+        Date date = new Date();
+        return dateFormat.format(date);
+    }
+
+    private int getPort(String s) {
+        int port = 830;
+        if((s != null) && !s.isEmpty()) {
+            port = Integer.parseInt(s);
+        }
+        return port;
+    }
+
+    void validateMandatoryParam(String paramName, String paramValue) {
+        if(StringUtils.isEmpty(paramValue)){
+            throw new IllegalArgumentException("input "+paramName+" param is empty");
+        }
+    }
+
+    public NetconfConnectionDetails retrieveConnectionDetails( VnfType vnfType) throws APPCException{
+
+        NetconfConnectionDetails connectionDetails = new NetconfConnectionDetails();
+        if (!dao.retrieveNetconfConnectionDetails(vnfType.getFamilyType().name(), connectionDetails)) {
+            logger.error("Missing configuration for " + vnfType.getFamilyType().name());
+            throw new APPCException("Missing configuration for " + vnfType.getFamilyType().name() + " in " + Constants.DEVICE_AUTHENTICATION_TABLE_NAME);
+        }
+        return connectionDetails;
+    }
+
+    public String retrieveConfigurationFileContent(String configFileName){
+        return dao.retrieveConfigFileName(configFileName);
+    }
+
+}
diff --git a/appc-dg/appc-dg-shared/appc-dg-netconf/src/main/java/org/openecomp/appc/dg/netconf/impl/NetconfDBPluginImpl.java b/appc-dg/appc-dg-shared/appc-dg-netconf/src/main/java/org/openecomp/appc/dg/netconf/impl/NetconfDBPluginImpl.java
new file mode 100644
index 000000000..6fdfcc14c
--- /dev/null
+++ b/appc-dg/appc-dg-shared/appc-dg-netconf/src/main/java/org/openecomp/appc/dg/netconf/impl/NetconfDBPluginImpl.java
@@ -0,0 +1,122 @@
+/*-
+ * ============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.dg.netconf.impl;
+
+import com.fasterxml.jackson.core.JsonProcessingException;
+import com.fasterxml.jackson.databind.ObjectMapper;
+
+import java.util.Map;
+
+import org.openecomp.appc.adapter.netconf.NetconfConnectionDetails;
+import org.openecomp.appc.adapter.netconf.NetconfDataAccessService;
+import org.openecomp.appc.adapter.netconf.exception.DataAccessException;
+import org.openecomp.appc.adapter.netconf.util.Constants;
+import org.openecomp.appc.dg.netconf.NetconfDBPlugin;
+import org.openecomp.appc.exceptions.APPCException;
+import com.att.eelf.configuration.EELFLogger;
+import com.att.eelf.configuration.EELFManager;
+import org.openecomp.sdnc.sli.SvcLogicContext;
+
+public class NetconfDBPluginImpl implements NetconfDBPlugin {
+
+    private static EELFLogger logger = EELFManager.getInstance().getApplicationLogger();
+    private static ObjectMapper mapper = new ObjectMapper();
+
+    // populated by blueprint framework
+    private NetconfDataAccessService daoService;
+
+    public void setDaoService(NetconfDataAccessService daoService) {
+        this.daoService = daoService;
+        this.daoService.setSchema(Constants.NETCONF_SCHEMA);
+    }
+
+    public NetconfDBPluginImpl() {
+    }
+
+    public void retrieveDSConfiguration(Map<String, String> params, SvcLogicContext ctx) throws APPCException {
+
+        try {
+            String fileContent = daoService.retrieveConfigFileName(params.get(Constants.CONFIGURATION_FILE_FIELD_NAME));
+            ctx.setAttribute(Constants.FILE_CONTENT_FIELD_NAME, fileContent);
+        } catch(DataAccessException e) {
+            logger.error("Error " + e.getMessage());
+            ctx.setAttribute(Constants.DG_OUTPUT_STATUS_MESSAGE, e.getMessage());
+            throw e;
+        }
+
+        getConnection(params, ctx);
+    }
+
+    @Override
+    public void retrieveVMDSConfiguration(Map<String, String> params, SvcLogicContext ctx) throws APPCException {
+        logger.info("Setting entity value :" +params.get(Constants.RESOURCEKEY));
+        ctx.setAttribute("entity", params.get(Constants.RESOURCEKEY));
+        NetconfConnectionDetails connectionDetails = new NetconfConnectionDetails();
+        try {
+            if (!daoService.retrieveNetconfConnectionDetails(params.get(Constants.RESOURCEKEY), connectionDetails)) {
+                ctx.setAttribute("retrieveVMDSConfiguration_Result","failure");
+                logger.error("Missing configuration for " + params.get(Constants.VNF_TYPE_FIELD_NAME));
+                throw new APPCException("Missing configuration for " + params.get(Constants.VNF_TYPE_FIELD_NAME) + " in " + Constants.DEVICE_AUTHENTICATION_TABLE_NAME);
+            }
+            //            fileContent = dsImpl.retrieveConfigFileName(params.get(Constants.CONFIGURATION_FILE_FIELD_NAME));
+            //            ctx.setAttribute(Constants.FILE_CONTENT_FIELD_NAME, fileContent);
+            ctx.setAttribute(Constants.CONNECTION_DETAILS_FIELD_NAME, mapper.writeValueAsString(connectionDetails));
+            ctx.setAttribute("retrieveVMDSConfiguration_Result","success");
+        } catch(APPCException e) {
+            ctx.setAttribute(Constants.DG_OUTPUT_STATUS_MESSAGE, e.getMessage());
+            throw e;
+        } catch(DataAccessException | JsonProcessingException e) {
+            logger.error("Error " + e.getMessage());
+            ctx.setAttribute(Constants.DG_OUTPUT_STATUS_MESSAGE, e.getMessage());
+            throw new APPCException(e);
+        }
+    }
+
+    @Override
+    public void retrieveConfigFile(Map<String, String> params, SvcLogicContext ctx) throws APPCException {
+        String fileContent = daoService.retrieveConfigFileName(params.get(Constants.CONFIGURATION_FILE_FIELD_NAME));
+        ctx.setAttribute(Constants.FILE_CONTENT_FIELD_NAME, fileContent);
+    }
+
+    public void retrieveConnectionDetails(Map<String, String> params, SvcLogicContext ctx) throws APPCException {
+        getConnection(params, ctx);
+    }
+
+            private void getConnection(Map<String, String> params, SvcLogicContext ctx) throws APPCException {
+                NetconfConnectionDetails connectionDetails = new NetconfConnectionDetails();
+                try {
+                    if (!daoService.retrieveNetconfConnectionDetails(params.get(Constants.VNF_TYPE_FIELD_NAME), connectionDetails)) {
+                        logger.error("Missing configuration for " + params.get(Constants.VNF_TYPE_FIELD_NAME));
+                        throw new APPCException("Missing configuration for " + params.get(Constants.VNF_TYPE_FIELD_NAME) + " in " + Constants.DEVICE_AUTHENTICATION_TABLE_NAME);
+                    }
+                    connectionDetails.setHost(params.get(Constants.VNF_HOST_IP_ADDRESS_FIELD_NAME));
+                    ctx.setAttribute(Constants.CONNECTION_DETAILS_FIELD_NAME, mapper.writeValueAsString(connectionDetails));
+                } catch(APPCException e) {
+                    ctx.setAttribute(Constants.DG_OUTPUT_STATUS_MESSAGE, e.getMessage());
+                    throw e;
+                } catch(DataAccessException | JsonProcessingException e) {
+                    logger.error("Error " + e.getMessage());
+            ctx.setAttribute(Constants.DG_OUTPUT_STATUS_MESSAGE, e.getMessage());
+            throw new APPCException(e);
+        }
+    }
+}
diff --git a/appc-dg/appc-dg-shared/appc-dg-netconf/src/main/resources/OSGI-INF/blueprint/blueprint.xml b/appc-dg/appc-dg-shared/appc-dg-netconf/src/main/resources/OSGI-INF/blueprint/blueprint.xml
new file mode 100644
index 000000000..0b58ce0af
--- /dev/null
+++ b/appc-dg/appc-dg-shared/appc-dg-netconf/src/main/resources/OSGI-INF/blueprint/blueprint.xml
@@ -0,0 +1,43 @@
+<?xml version="1.0" encoding="UTF-8"?>
+<!--
+  ============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=========================================================
+  -->
+
+<!--
+    Starter Blueprint Camel Definition appc-aai-adapter-blueprint
+-->
+<blueprint xmlns="http://www.osgi.org/xmlns/blueprint/v1.0.0"
+		   xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
+		   xsi:schemaLocation="http://www.osgi.org/xmlns/blueprint/v1.0.0 http://www.osgi.org/xmlns/blueprint/v1.0.0/blueprint.xsd">
+
+	<reference id="DataAccessServiceRef" availability="mandatory" activation="eager" interface="org.openecomp.appc.adapter.netconf.NetconfDataAccessService" />
+
+
+	<bean id="NetconfDBPluginBean" class="org.openecomp.appc.dg.netconf.impl.NetconfDBPluginImpl" scope="singleton">
+		<property name="daoService" ref="DataAccessServiceRef" />
+	</bean>
+	<service id="NetconfDBPlugin" interface="org.openecomp.appc.dg.netconf.NetconfDBPlugin" ref="NetconfDBPluginBean"/>
+
+	<bean id="NetconfClientPluginBean" class="org.openecomp.appc.dg.netconf.impl.NetconfClientPluginImpl" scope="singleton">
+		<property name="dao" ref="DataAccessServiceRef" />
+	</bean>
+	<service id="NetconfClientPlugin" interface="org.openecomp.appc.dg.netconf.NetconfClientPlugin" ref="NetconfClientPluginBean"/>
+
+</blueprint>