+++ /dev/null
-/*-
- * ============LICENSE_START=======================================================
- * ONAP : APPC
- * ================================================================================
- * Copyright (C) 2017 AT&T Intellectual Property. All rights reserved.
- * ================================================================================
- * Copyright (C) 2017 Amdocs
- * =============================================================================
- * 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.
- *
- * ECOMP is a trademark and service mark of AT&T Intellectual Property.
- * ============LICENSE_END=========================================================
- */
-
-package org.onap.appc.dg.netconf.impl;
-
-import com.fasterxml.jackson.databind.ObjectMapper;
-import org.apache.commons.lang.ObjectUtils;
-import org.apache.commons.lang3.StringUtils;
-import org.onap.appc.adapter.netconf.*;
-import org.onap.appc.adapter.netconf.util.Constants;
-import org.onap.appc.dg.netconf.NetconfClientPlugin;
-import org.onap.appc.exceptions.APPCException;
-import com.att.eelf.configuration.EELFLogger;
-import com.att.eelf.configuration.EELFManager;
-import org.onap.ccsdk.sli.core.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.onap.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 {
- // by default, it uses the jsch Netconf Adapter implementation by calling GetNetconfClient(NetconfClientType.SSH).
- 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){
- 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");
- }
- } 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);
- }
-
-}
Code Review / appc.git / blobdiff