appc-config/appc-config-adaptor/provider/src/main/java/org/onap/appc/ccadaptor/ConfigComponentAdaptor.java

   1 /*-
   2  * ============LICENSE_START=======================================================
   3  * ONAP : APPC
   4  * ================================================================================
   5  * Copyright (C) 2017-2018 AT&T Intellectual Property. All rights reserved.
   6  * =============================================================================
   7  * Modifications Copyright (C) 2018-2019 IBM.
   8  * =============================================================================
   9  * Modifications Copyright (C) 2018-2019 Ericsson
  10  * =============================================================================
  11  * Licensed under the Apache License, Version 2.0 (the "License");
  12  * you may not use this file except in compliance with the License.
  13  * You may obtain a copy of the License at
  14  *
  15  *      http://www.apache.org/licenses/LICENSE-2.0
  16  *
  17  * Unless required by applicable law or agreed to in writing, software
  18  * distributed under the License is distributed on an "AS IS" BASIS,
  19  * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
  20  * See the License for the specific language governing permissions and
  21  * limitations under the License.
  22  *
  23  * ============LICENSE_END=========================================================
  24  */
  25
  26 package org.onap.appc.ccadaptor;
  27
  28 import com.att.eelf.configuration.EELFLogger;
  29 import com.att.eelf.configuration.EELFManager;
  30 import com.sun.jersey.api.client.Client;
  31 import com.sun.jersey.api.client.ClientResponse;
  32 import com.sun.jersey.api.client.WebResource;
  33 import com.sun.jersey.core.util.Base64;
  34 import java.io.BufferedReader;
  35 import java.io.ByteArrayInputStream;
  36 import java.io.FileReader;
  37 import java.io.IOException;
  38 import java.io.InputStream;
  39 import java.io.InputStreamReader;
  40 import java.net.HttpURLConnection;
  41 import java.util.HashMap;
  42 import java.util.Map;
  43 import java.util.NoSuchElementException;
  44 import java.util.Properties;
  45 import java.util.StringTokenizer;
  46 import org.onap.ccsdk.sli.core.sli.SvcLogicAdaptor;
  47 import org.onap.ccsdk.sli.core.sli.SvcLogicContext;
  48
  49 public class ConfigComponentAdaptor implements SvcLogicAdaptor {
  50
  51     private static EELFLogger log = EELFManager.getInstance().getLogger(ConfigComponentAdaptor.class);
  52     DebugLog debugLog = new DebugLog();
  53     private String configUrl = null;
  54     private String configUser = null;
  55     private String configPassword = null;
  56     private String auditUrl = null;
  57     private String auditUser = null;
  58     private String auditPassword = null;
  59
  60     public String getConfigUrl() {
  61         return configUrl;
  62     }
  63
  64     public String getConfigUser() {
  65         return configUser;
  66     }
  67
  68     public String getConfigPassword() {
  69         return configPassword;
  70     }
  71
  72     public String getAuditUrl() {
  73         return auditUrl;
  74     }
  75
  76     public String getAuditUser() {
  77         return auditUser;
  78     }
  79
  80     public String getAuditPassword() {
  81         return auditPassword;
  82     }
  83
  84     public String getConfigCallbackUrl() {
  85         return configCallbackUrl;
  86     }
  87
  88     public String getAuditCallbackUrl() {
  89         return auditCallbackUrl;
  90     }
  91
  92     private String configCallbackUrl = null;
  93     private String auditCallbackUrl = null;
  94     private int DEFAULT_TIMEOUT_GETRUNNING_CLI = 120 * 1000 ;
  95
  96     public ConfigComponentAdaptor(Properties props) {
  97         if (props != null) {
  98             configUrl = props.getProperty("configComponent.url", "");
  99             configUser = props.getProperty("configComponent.user", "");
 100             configPassword = props.getProperty("configComponent.passwd", "");
 101             auditUrl = props.getProperty("auditComponent.url", "");
 102             auditUser = props.getProperty("auditComponent.user", "");
 103             auditPassword = props.getProperty("auditComponent.passwd", "");
 104             configCallbackUrl = props.getProperty("service-configuration-notification-url", "");
 105             auditCallbackUrl = props.getProperty("audit-configuration-notification-url", "");
 106         } else {
 107             configUrl = "";
 108             configUser = "";
 109             configPassword = "";
 110             auditUrl = "";
 111             auditUser = "";
 112             auditPassword = "";
 113             configCallbackUrl = "";
 114             auditCallbackUrl = "";
 115         }
 116     }
 117
 118     @Override
 119     public ConfigStatus configure(String key, Map<String, String> parameters, SvcLogicContext ctx) {
 120         String fnName = "ConfigComponentAdaptor.configure";
 121         HttpResponse r = new HttpResponse();
 122         r.code = 200;
 123         log.debug("ConfigComponentAdaptor.configure - key = " + key);
 124         DebugLog.printRTAriDebug(fnName, "key = " + key);
 125         log.debug("Parameters:");
 126         DebugLog.printRTAriDebug(fnName, "Parameters:");
 127         for (String parmName : parameters.keySet()) {
 128             log.debug("        " + parmName + " = " + parameters.get(parmName));
 129             DebugLog.printRTAriDebug(fnName, "        " + parmName + " = " + parameters.get(parmName));
 130         }
 131
 132         String parmval = parameters.get("config-component-configUrl");
 133         if ((parmval != null) && (parmval.length() > 0)) {
 134             log.debug("Overwriting URL with " + parmval);
 135             configUrl = parmval;
 136         }
 137
 138         parmval = parameters.get("config-component-configPassword");
 139         if ((parmval != null) && (parmval.length() > 0)) {
 140             log.debug("Overwriting configPassword with " + parmval);
 141             configPassword = parmval;
 142         }
 143
 144         parmval = parameters.get("config-component-configUser");
 145         if ((parmval != null) && (parmval.length() > 0)) {
 146             log.debug("Overwriting configUser id with " + parmval);
 147             configUser = parmval;
 148         }
 149
 150         String action = parameters.get("action");
 151
 152         String chg = ctx.getAttribute(
 153                 "service-data.vnf-config-parameters-list.vnf-config-parameters[0].update-configuration[0].block-key-name");
 154         if (chg != null && "prepare".equalsIgnoreCase(action)) {
 155             return prepare(ctx, "CHANGE", "change");
 156         }
 157         if (chg != null && "activate".equalsIgnoreCase(action)) {
 158             return activate(ctx, true);
 159         }
 160
 161         String scale = ctx.getAttribute(
 162                 "service-data.vnf-config-parameters-list.vnf-config-parameters[0].scale-configuration[0].network-type");
 163         if (scale != null && "prepare".equalsIgnoreCase(action)) {
 164             return prepare(ctx, "CHANGE", "scale");
 165         }
 166         if (scale != null && "activate".equalsIgnoreCase(action)) {
 167             return activate(ctx, true);
 168         }
 169
 170         if ("prepare".equalsIgnoreCase(action)) {
 171             return prepare(ctx, "BASE", "create");
 172         }
 173         if ("activate".equalsIgnoreCase(action)) {
 174             return activate(ctx, false);
 175         }
 176
 177         if ("backup".equalsIgnoreCase(action)) {
 178             return prepare(ctx, "BACKUP", "backup");
 179         }
 180         if ("restorebackup".equalsIgnoreCase(action)) {
 181             return prepare(ctx, "RESTOREBACKUP", "restorebackup");
 182         }
 183         if ("deletebackup".equalsIgnoreCase(action)) {
 184             return prepare(ctx, "DELETEBACKUP", "deletebackup");
 185         }
 186         if ("audit".equalsIgnoreCase(action)) {
 187             return audit(ctx, "FULL");
 188         }
 189         if ("getrunningconfig".equalsIgnoreCase(action)) {
 190             return audit(ctx, "RUNNING");
 191         }
 192
 193         if (("put".equals(key)) || ("get".equals(key))) {
 194             String loginId = parameters.get("loginId");
 195             String host = parameters.get("host");
 196             String password = parameters.get("password");
 197             password = EncryptionTool.getInstance().decrypt(password);
 198             String fullPathFileName = parameters.get("fullPathFileName");
 199             String data = null;
 200
 201             SshJcraftWrapper sshJcraftWrapper = getSshJcraftWrapper();
 202             log.debug("SCP: SshJcraftWrapper has been instantiated");
 203             DebugLog.printRTAriDebug(fnName, "SCP: SshJcraftWrapper has been instantiated");
 204             try {
 205                 if (key.equals("put")) {
 206                     data = parameters.get("data");
 207                     if (data != null) {
 208                         DebugLog.printRTAriDebug(fnName, "Command is for put: Length of data is: " + data.length());
 209                         InputStream is = new ByteArrayInputStream(data.getBytes());
 210                         log.debug("SCP: Doing a put: fullPathFileName=" + fullPathFileName);
 211                         DebugLog.printRTAriDebug(fnName, "SCP: Doing a put: fullPathFileName=" + fullPathFileName);
 212                         sshJcraftWrapper.put(is, fullPathFileName, host, loginId, password);
 213                         try {
 214                             DebugLog.printRTAriDebug(fnName, "Sleeping for 180 seconds....");
 215                             Thread.sleep(1000l * 180);
 216                             DebugLog.printRTAriDebug(fnName, "Woke up....");
 217                         } catch (java.lang.InterruptedException ee) {
 218                             boolean ignore = true;
 219                             Thread.currentThread().interrupt();
 220                         }
 221                     } else {
 222                         r.code = HttpURLConnection.HTTP_INTERNAL_ERROR;
 223                         log.debug(fnName + " Command is for put: data is null");
 224                     }
 225                 } else     // Must be a get
 226                 {
 227                     log.debug("SCP: Doing a get: fullPathFileName=" + fullPathFileName);
 228                     DebugLog.printRTAriDebug(fnName, "SCP: Doing a get: fullPathFileName=" + fullPathFileName);
 229                     String response = sshJcraftWrapper.get(fullPathFileName, host, loginId, password);
 230                     DebugLog.printRTAriDebug(fnName, "Got the response and putting into the ctx object");
 231                     ctx.setAttribute("fileContents", response);
 232                     log.debug("SCP: Closing the SFTP connection");
 233                 }
 234                 sshJcraftWrapper = null;
 235                 return (setResponseStatus(ctx, r));
 236             } catch (IOException e) {
 237                 DebugLog.printAriDebug(fnName, "Caught a IOException e=" + e);
 238                 log.debug(fnName + " : Caught a IOException e=" + e);
 239                 r.code = HttpURLConnection.HTTP_INTERNAL_ERROR;
 240                 r.message = e.getMessage();
 241                 sshJcraftWrapper = null;
 242                 return (setResponseStatus(ctx, r));
 243             }
 244         }
 245         if (key.equals("cli")) {
 246             String loginId = parameters.get("loginId");
 247             String host = parameters.get("host");
 248             String password = parameters.get("password");
 249             password = EncryptionTool.getInstance().decrypt(password);
 250             String cliCommand = parameters.get("cli");
 251             String portNumber = parameters.get("portNumber");
 252             SshJcraftWrapper sshJcraftWrapper = getSshJcraftWrapper();
 253             try {
 254                 log.debug("CLI: Attempting to login: host=" + host + " loginId=" + loginId +
 255                         " portNumber=" + portNumber);
 256                 DebugLog.printRTAriDebug(fnName, "CLI: Attempting to login: host=" + host + " loginId=" + loginId +
 257                         " portNumber=" + portNumber);
 258                 sshJcraftWrapper.connect(host, loginId, password, Integer.parseInt(portNumber));
 259
 260                 DebugLog.printAriDebug(fnName, "Sending 'sdc'");
 261                 String response = sshJcraftWrapper.send("sdc", ":");
 262                 DebugLog.printAriDebug(fnName, "Sending 1");
 263                 response = sshJcraftWrapper.send("1", ":");
 264                 DebugLog.printAriDebug(fnName, "Sending 1, the second time");
 265                 response = sshJcraftWrapper.send("1", "#");
 266                 DebugLog.printAriDebug(fnName, "Sending paging-options disable");
 267                 response = sshJcraftWrapper.send("paging-options disable", "#");
 268                 DebugLog.printAriDebug(fnName, "Sending show config");
 269                 response = sshJcraftWrapper.send("show config", "#");
 270
 271                 DebugLog.printAriDebug(fnName, "response is now:'" + response + "'");
 272                 DebugLog.printAriDebug(fnName, "Populating the ctx object with the response");
 273                 ctx.setAttribute("cliOutput", response);
 274                 sshJcraftWrapper.closeConnection();
 275                 r.code = 200;
 276                 sshJcraftWrapper = null;
 277                 return (setResponseStatus(ctx, r));
 278             } catch (IOException e) {
 279                 DebugLog.printAriDebug(fnName, "Caught a IOException e=" + e);
 280                 log.debug(fnName + " : Caught a IOException e=" + e);
 281                 sshJcraftWrapper.closeConnection();
 282                 r.code = HttpURLConnection.HTTP_INTERNAL_ERROR;
 283                 r.message = e.getMessage();
 284                 sshJcraftWrapper = null;
 285                 DebugLog.printAriDebug(fnName, "Returning error message");
 286                 return (setResponseStatus(ctx, r));
 287             }
 288         }
 289         if (key.equals("escapeSql")) {
 290             String data = parameters.get("artifactContents");
 291             log.debug("ConfigComponentAdaptor.configure - escapeSql");
 292             data = escapeMySql(data);
 293             ctx.setAttribute("escapedData", data);
 294             return (setResponseStatus(ctx, r));
 295         }
 296         if (key.equals("GetCliRunningConfig")) {
 297             DebugLog.printRTAriDebug(fnName, "key was: GetCliRunningConfig: ");
 298             log.debug("key was: GetCliRunningConfig: ");
 299             String User_name = parameters.get("User_name");
 300             String Host_ip_address = parameters.get("Host_ip_address");
 301             String Password = parameters.get("Password");
 302             Password = EncryptionTool.getInstance().decrypt(Password);
 303             String Port_number = parameters.get("Port_number");
 304             String Get_config_template = parameters.get("Get_config_template");
 305             SshJcraftWrapper sshJcraftWrapper = getSshJcraftWrapper();
 306             log.debug("GetCliRunningConfig: sshJcraftWrapper was instantiated");
 307             DebugLog.printRTAriDebug(fnName, "GetCliRunningConfig: sshJcraftWrapper was instantiated");
 308             try {
 309                 DebugLog.printAriDebug(fnName, "GetCliRunningConfig: User_name=" + User_name +
 310                         " Host_ip_address=" + Host_ip_address + " Port_number="
 311                         + Port_number);
 312                 log.debug("GetCliRunningConfig: Attempting to login: Host_ip_address=" + Host_ip_address +
 313                         " User_name=" + User_name + " Port_number=" + Port_number);
 314                 StringBuffer sb = new StringBuffer();
 315                 String response = "";
 316                 String CliResponse = "";
 317                 boolean showConfigFlag = false;
 318                 sshJcraftWrapper.connect(Host_ip_address,
 319                         User_name,
 320                         Password,
 321                         "",
 322                         30000,
 323                         Integer.parseInt(Port_number));
 324                 DebugLog.printAriDebug(fnName, "GetCliRunningConfig: On the VNF device");
 325                 StringTokenizer st = new StringTokenizer(Get_config_template, "\n");
 326                 String command = null;
 327                 try {
 328                     while (st.hasMoreTokens()) {
 329                         String line = st.nextToken();
 330                         DebugLog.printAriDebug(fnName, "line=" + line);
 331                         if (line.indexOf("Request:") != -1) {
 332                             DebugLog.printAriDebug(fnName, "Found a Request line: line=" + line);
 333                             command = getStringBetweenQuotes(line);
 334                             DebugLog.printAriDebug(fnName, "Sending command=" + command);
 335                             sshJcraftWrapper.send(command);
 336                             DebugLog.printAriDebug(fnName, "command has been sent");
 337                             if (line.indexOf("show config") != -1) {
 338                                 showConfigFlag = true;
 339                                 DebugLog.printAriDebug(fnName, "GetCliRunningConfig: setting 'showConfigFlag' to true");
 340                                 log.debug("GetCliRunningConfig: GetCliRunningConfig: setting 'showConfigFlag' to true");
 341                             }
 342                         }
 343                         if (line.indexOf("Response: Ends_With") != -1) {
 344                             DebugLog.printAriDebug(fnName, "Found a Response line: line=" + line);
 345                             String delemeter = getStringBetweenQuotes(line);
 346                             DebugLog.printAriDebug(fnName, "The delemeter=" + delemeter);
 347                             //DEFAULT_TIMEOUT_GETRUNNING_CLI : changed the default time out to 2 mins in 1806
 348                             String tmpResponse = sshJcraftWrapper.receiveUntil(delemeter,
 349                                     DEFAULT_TIMEOUT_GETRUNNING_CLI, command);
 350                             response += tmpResponse;
 351                             if (showConfigFlag) {
 352                                 showConfigFlag = false;
 353                                 StringTokenizer st2 = new StringTokenizer(tmpResponse, "\n");
 354                                 //    Strip off the last line which is the command prompt from the VNF device.
 355                                 while (st2.hasMoreTokens()) {
 356                                     String line2 = st2.nextToken();
 357                                     if (line2.indexOf("#") == -1) {
 358                                         CliResponse += line2 + "\n";
 359                                     }
 360                                 }
 361                             }
 362                         }
 363                     }
 364                 } catch (NoSuchElementException e) {
 365                     DebugLog.printAriDebug(fnName, "Caught a NoSuchElementException: e=" + e);
 366                 }
 367                 DebugLog.printAriDebug(fnName, "CliResponse=\n" + CliResponse);
 368                 ctx.setAttribute("cliOutput", CliResponse);
 369                 sshJcraftWrapper.closeConnection();
 370                 r.code = 200;
 371                 sshJcraftWrapper = null;
 372                 return (setResponseStatus(ctx, r));
 373             } catch (IOException e) {
 374                 DebugLog.printAriDebug(fnName, "GetCliRunningConfig: Caught a IOException e=" + e);
 375                 log.debug(fnName + " : GetCliRunningConfig: Caught a IOException e=" + e);
 376                 sshJcraftWrapper.closeConnection();
 377                 r.code = HttpURLConnection.HTTP_INTERNAL_ERROR;
 378                 r.message = e.getMessage();
 379                 sshJcraftWrapper = null;
 380                 DebugLog.printAriDebug(fnName, "GetCliRunningConfig: Returning error message");
 381                 return (setResponseStatus(ctx, r));
 382             }
 383         }
 384         if (key.equals("xml-download")) {
 385             log(fnName, "key was:    xml-download");
 386             String User_name = parameters.get("User_name");
 387             String Host_ip_address = parameters.get("Host_ip_address");
 388             String Password = parameters.get("Password");
 389             Password = EncryptionTool.getInstance().decrypt(Password);
 390             String Port_number = parameters.get("Port_number");
 391             String Contents = parameters.get("Contents");
 392             String netconfHelloCmd = "<?xml version=\"1.0\" encoding=\"UTF-8\"?>\n <hello xmlns=\"urn:ietf:params:xml:ns:netconf:base:1.0\">\n    <capabilities>\n   <capability>urn:ietf:params:netconf:base:1.0</capability>\n  <capability>urn:com:ericsson:ebase:1.1.0</capability> </capabilities>\n </hello>";
 393             String terminateConnectionCmd = "<?xml version=\"1.0\" encoding=\"UTF-8\"?>\n    <rpc message-id=\"terminateConnection\" xmlns:netconf=\"urn:ietf:params:xml:ns:netconf:base:1.0\" xmlns=\"urn:ietf:params:xml:ns:netconf:base:1.0\">\n <close-session/> \n </rpc>\n ]]>]]>";
 394             String commitCmd = "<?xml version=\"1.0\" encoding=\"UTF-8\"?>\n <rpc xmlns=\"urn:ietf:params:xml:ns:netconf:base:1.0\" message-id=\"1\"> <commit/> </rpc>\n ]]>]]>";
 395
 396             log(fnName,
 397                     "xml-download: User_name=" + User_name + " Host_ip_address=" + Host_ip_address
 398                     + " Port_number=" + Port_number);
 399             SshJcraftWrapper sshJcraftWrapper = getSshJcraftWrapper();
 400             try {
 401                 sshJcraftWrapper.connect(Host_ip_address,
 402                         User_name,
 403                         Password,
 404                         "]]>]]>",
 405                         30000,
 406                         Integer.parseInt(Port_number),
 407                         "netconf");
 408                 String NetconfHelloCmd = netconfHelloCmd;
 409                 NetconfHelloCmd = NetconfHelloCmd + "]]>]]>";
 410                 log(fnName, "Sending the hello command");
 411                 sshJcraftWrapper.send(NetconfHelloCmd);
 412                 String response = sshJcraftWrapper.receiveUntil("]]>]]>", 10000, "");
 413                 log(fnName, "Sending xmlCmd cmd");
 414                 String xmlCmd = Contents;
 415                 String messageId = "1";
 416                 messageId = "\"" + messageId + "\"";
 417                 String loadConfigurationString =
 418                         "<?xml version=\"1.0\" encoding=\"UTF-8\"?> <rpc xmlns=\"urn:ietf:params:xml:ns:netconf:base:1.0\" message-id="
 419                                 + messageId
 420                                 + "> <edit-config> <target> <candidate /> </target> <default-operation>merge</default-operation> <config xmlns:xc=\"urn:ietf:params:xml:ns:netconf:base:1.0\">"
 421                                 + xmlCmd + "</config> </edit-config> </rpc>";
 422                 loadConfigurationString = loadConfigurationString + "]]>]]>";
 423                 sshJcraftWrapper.send(loadConfigurationString);
 424                 DebugLog.printAriDebug(fnName, ":After sending loadConfigurationString");
 425                 response = sshJcraftWrapper.receiveUntil("</rpc-reply>", 600000, "");
 426                 if (response.indexOf("rpc-error") != -1) {
 427                     DebugLog.printAriDebug(fnName, "Error from device: Response from device had 'rpc-error'");
 428                     DebugLog.printAriDebug(fnName, "response=\n" + response + "\n");
 429                     r.code = HttpURLConnection.HTTP_INTERNAL_ERROR;
 430                     r.message = response;
 431                 } else {
 432                     DebugLog.printAriDebug(fnName, ":LoadConfiguration was a success, sending commit cmd");
 433                     sshJcraftWrapper.send(commitCmd);
 434                     DebugLog.printAriDebug(fnName, ":After sending commitCmd");
 435                     response = sshJcraftWrapper.receiveUntil("</rpc-reply>", 180000, "");
 436                     if (response.indexOf("rpc-error") != -1) {
 437                         DebugLog.printAriDebug(fnName, "Error from device: Response from device had 'rpc-error'");
 438                         DebugLog.printAriDebug(fnName, "response=\n" + response + "\n");
 439                         r.code = HttpURLConnection.HTTP_INTERNAL_ERROR;
 440                         r.message = response;
 441                     } else {
 442                         DebugLog.printAriDebug(fnName, ":Looks like a success");
 443                         DebugLog.printAriDebug(fnName, "response=\n" + response + "\n");
 444                         r.code = 200;
 445                     }
 446                 }
 447                 sshJcraftWrapper.send(terminateConnectionCmd);
 448                 sshJcraftWrapper.closeConnection();
 449                 sshJcraftWrapper = null;
 450                 return (setResponseStatus(ctx, r));
 451             } catch (Exception e) {
 452                 log(fnName, "Caught an Exception, e=" + e);
 453                 log(fnName, "StackTrace=" + DebugLog.getStackTraceString(e));
 454                 sshJcraftWrapper.closeConnection();
 455                 r.code = HttpURLConnection.HTTP_INTERNAL_ERROR;
 456                 r.message = e.getMessage();
 457                 sshJcraftWrapper = null;
 458                 log(fnName, "Returning error message");
 459                 return (setResponseStatus(ctx, r));
 460             }
 461         }
 462         if (key.equals("xml-getrunningconfig")) {
 463             log(fnName, "key was: : xml-getrunningconfig");
 464             String xmlGetRunningConfigCmd = "<?xml version=\"1.0\" encoding=\"UTF-8\"?> <rpc xmlns=\"urn:ietf:params:xml:ns:netconf:base:1.0\" message-id=\"1\">    <get-config> <source> <running /> </source> </get-config> </rpc>\n";
 465             String Host_ip_address = parameters.get("Host_ip_address");
 466             String User_name = parameters.get("User_name");
 467             String Password = parameters.get("Password");
 468             Password = EncryptionTool.getInstance().decrypt(Password);
 469             String Port_number = parameters.get("Port_number");
 470             String Protocol = parameters.get("Protocol");
 471             String netconfHelloCmd = "<?xml version=\"1.0\" encoding=\"UTF-8\"?>\n <hello xmlns=\"urn:ietf:params:xml:ns:netconf:base:1.0\">\n    <capabilities>\n   <capability>urn:ietf:params:netconf:base:1.0</capability>\n <capability>urn:com:ericsson:ebase:1.1.0</capability> </capabilities>\n </hello>";
 472             String terminateConnectionCmd = "<?xml version=\"1.0\" encoding=\"UTF-8\"?>\n    <rpc message-id=\"terminateConnection\" xmlns:netconf=\"urn:ietf:params:xml:ns:netconf:base:1.0\" xmlns=\"urn:ietf:params:xml:ns:netconf:base:1.0\">\n <close-session/> \n </rpc>\n ]]>]]>";
 473             log(fnName,
 474                     "xml-getrunningconfig: User_name=" + User_name + " Host_ip_address=" + Host_ip_address
 475                     + " Port_number=" + Port_number);
 476             SshJcraftWrapper sshJcraftWrapper = getSshJcraftWrapper();
 477             try {
 478                 String NetconfHelloCmd = netconfHelloCmd;
 479                 sshJcraftWrapper.connect(Host_ip_address,
 480                         User_name,
 481                         Password,
 482                         "]]>]]>",
 483                         30000,
 484                         Integer.parseInt(Port_number),
 485                         "netconf");
 486                 NetconfHelloCmd = NetconfHelloCmd + "]]>]]>";
 487                 log(fnName, ":Sending the hello command");
 488                 sshJcraftWrapper.send(NetconfHelloCmd);
 489                 String response = sshJcraftWrapper.receiveUntil("]]>]]>", 10000, "");
 490                 log(fnName, "Sending get running config command");
 491                 sshJcraftWrapper.send(xmlGetRunningConfigCmd + "]]>]]>\n");
 492                 response = sshJcraftWrapper.receiveUntil("</rpc-reply>", 180000, "");
 493                 DebugLog.printAriDebug(fnName, "Response from getRunningconfigCmd=" + response);
 494                 response = trimResponse(response);
 495                 ctx.setAttribute("xmlRunningConfigOutput", response);
 496                 sshJcraftWrapper.send(terminateConnectionCmd);
 497                 sshJcraftWrapper.closeConnection();
 498                 r.code = 200;
 499                 sshJcraftWrapper = null;
 500                 return (setResponseStatus(ctx, r));
 501             } catch (Exception e) {
 502                 log(fnName, "Caught an Exception, e=" + e);
 503                 log(fnName, "StackTrace=" + DebugLog.getStackTraceString(e));
 504                 sshJcraftWrapper.closeConnection();
 505                 r.code = HttpURLConnection.HTTP_INTERNAL_ERROR;
 506                 r.message = e.getMessage();
 507                 sshJcraftWrapper = null;
 508                 log(fnName, "Returning error message");
 509                 return (setResponseStatus(ctx, r));
 510             }
 511         }
 512         if (key.equals("DownloadCliConfig")) {
 513             DebugLog.printRTAriDebug(fnName, "key was: DownloadCliConfig: ");
 514             log.debug("key was: DownloadCliConfig: ");
 515             String User_name = parameters.get("User_name");
 516             String Host_ip_address = parameters.get("Host_ip_address");
 517             String Password = parameters.get("Password");
 518             Password = EncryptionTool.getInstance().decrypt(Password);
 519             String Port_number = parameters.get("Port_number");
 520             String Download_config_template = parameters.get("Download_config_template");
 521             String Config_contents = parameters.get("Config_contents");
 522             DebugLog.printAriDebug(fnName, "Contents of the 'Config_contents' are: " + Config_contents);
 523             SshJcraftWrapper sshJcraftWrapper = getSshJcraftWrapper();
 524             log.debug("DownloadCliConfig: sshJcraftWrapper was instantiated");
 525             DebugLog.printRTAriDebug(fnName, "DownloadCliConfig: sshJcraftWrapper was instantiated");
 526             int timeout = 4 * 60 * 1000;
 527             try {
 528                 DebugLog.printAriDebug(fnName, "DownloadCliConfig: User_name=" + User_name +
 529                         " Host_ip_address=" + Host_ip_address + " Port_number="
 530                         + Port_number);
 531                 log.debug("DownloadCliConfig: Attempting to login: Host_ip_address=" + Host_ip_address +
 532                         " User_name=" + User_name + " Port_number=" + Port_number);
 533                 StringBuffer sb = new StringBuffer();
 534                 String response = "";
 535                 String CliResponse = "";
 536                 sshJcraftWrapper.connect(Host_ip_address,
 537                         User_name,
 538                         Password,
 539                         "",
 540                         30000,
 541                         Integer.parseInt(Port_number));
 542                 DebugLog.printAriDebug(fnName, "DownloadCliConfig: On the VNF device");
 543                 StringTokenizer st = new StringTokenizer(Download_config_template, "\n");
 544                 String command = null;
 545                 String executeConfigContentsDelemeter = null;
 546                 try {
 547                     while (st.hasMoreTokens()) {
 548                         String line = st.nextToken();
 549                         DebugLog.printAriDebug(fnName, "line=" + line);
 550                         if (line.indexOf("Request:") != -1) {
 551                             DebugLog.printAriDebug(fnName, "Found a Request line: line=" + line);
 552                             command = getStringBetweenQuotes(line);
 553                             DebugLog.printAriDebug(fnName, "Sending command=" + command);
 554                             sshJcraftWrapper.send(command);
 555                             DebugLog.printAriDebug(fnName, "command has been sent");
 556                         } else if ((line.indexOf("Response: Ends_With") != -1) && (
 557                                 line.indexOf("Execute_config_contents Response: Ends_With") == -1)) {
 558                             DebugLog.printAriDebug(fnName, "Found a Response line: line=" + line);
 559                             String delemeter = getStringBetweenQuotes(line);
 560                             DebugLog.printAriDebug(fnName, "The delemeter=" + delemeter);
 561                             String tmpResponse = sshJcraftWrapper.receiveUntil(delemeter, timeout, command);
 562                             response += tmpResponse;
 563                             CliResponse += tmpResponse;
 564                         } else if (line.indexOf("Execute_config_contents Response: Ends_With") != -1) {
 565                             DebugLog.printAriDebug(fnName, "Found a 'Execute_config_contents Response:' line=" + line);
 566                             executeConfigContentsDelemeter = getStringBetweenQuotes(line);
 567                             DebugLog.printAriDebug(fnName,
 568                                     "executeConfigContentsDelemeter=" + executeConfigContentsDelemeter);
 569                             StringTokenizer st2 = new StringTokenizer(Config_contents, "\n");
 570                             while (st2.hasMoreTokens()) {
 571                                 String cmd = st2.nextToken();
 572                                 DebugLog.printAriDebug(fnName, "Config_contents: cmd=" + cmd);
 573                                 sshJcraftWrapper.send(cmd);
 574                                 String tmpResponse = sshJcraftWrapper.receiveUntil(executeConfigContentsDelemeter,
 575                                         timeout,
 576                                         command);
 577                                 CliResponse += tmpResponse;
 578                             }
 579                         }
 580                     }
 581                 } catch (NoSuchElementException e) {
 582                     DebugLog.printAriDebug(fnName, "Caught a NoSuchElementException: e=" + e);
 583                 }
 584                 sshJcraftWrapper.closeConnection();
 585                 sshJcraftWrapper = null;
 586                 DebugLog.printAriDebug(fnName, ":Escaping all the single and double quotes in the response");
 587                 CliResponse = CliResponse.replaceAll("\"", "\\\\\"");
 588                 CliResponse = CliResponse.replaceAll("\'", "\\\\'");
 589                 DebugLog.printAriDebug(fnName, "CliResponse=\n" + CliResponse);
 590                 ctx.setAttribute("cliOutput", CliResponse);
 591                 r.code = 200;
 592                 return (setResponseStatus(ctx, r));
 593             } catch (IOException e) {
 594                 DebugLog.printAriDebug(fnName, "DownloadCliConfig: Caught a IOException e=" + e);
 595                 log.debug(fnName + " : DownloadCliConfig: Caught a IOException e=" + e);
 596                 sshJcraftWrapper.closeConnection();
 597                 r.code = HttpURLConnection.HTTP_INTERNAL_ERROR;
 598                 r.message = e.getMessage();
 599                 sshJcraftWrapper = null;
 600                 DebugLog.printAriDebug(fnName, "DownloadCliConfig: Returning error message");
 601                 return (setResponseStatus(ctx, r));
 602             }
 603         }
 604
 605         DebugLog.printRTAriDebug(fnName, "Unsupported action - " + action);
 606         log.error("Unsupported action - " + action);
 607         return ConfigStatus.FAILURE;
 608     }
 609
 610     private void log(String fileName, String messg) {
 611         DebugLog.printRTAriDebug(fileName, messg);
 612         log.debug(fileName + ": " + messg);
 613     }
 614
 615     private ConfigStatus prepare(SvcLogicContext ctx, String requestType, String operation) {
 616         String templateName = requestType.equals("BASE") ? "/config-base.xml" : "/config-data.xml";
 617         String ndTemplate = readFile(templateName);
 618         String nd = buildNetworkData2(ctx, ndTemplate, operation);
 619
 620         String reqTemplate = readFile("/config-request.xml");
 621         Map<String, String> param = new HashMap<String, String>();
 622         param.put("request-id", ctx.getAttribute("service-data.appc-request-header.svc-request-id"));
 623         param.put("request-type", requestType);
 624         param.put("callback-url", configCallbackUrl);
 625         if (operation.equals("create") || operation.equals("change") || operation.equals("scale")) {
 626             param.put("action", "GenerateOnly");
 627         }
 628         param.put("equipment-name", ctx.getAttribute("service-data.service-information.service-instance-id"));
 629         param.put("equipment-ip-address", ctx.getAttribute("service-data.vnf-config-information.vnf-host-ip-address"));
 630         param.put("vendor", ctx.getAttribute("service-data.vnf-config-information.vendor"));
 631         param.put("network-data", nd);
 632
 633         String req = null;
 634         try {
 635             req = buildXmlRequest(param, reqTemplate);
 636         } catch (Exception e) {
 637             log.error("Error building the XML request: ", e);
 638
 639             HttpResponse r = new HttpResponse();
 640             r.code = HttpURLConnection.HTTP_INTERNAL_ERROR;
 641             r.message = e.getMessage();
 642             return setResponseStatus(ctx, r);
 643         }
 644
 645         HttpResponse r = sendXmlRequest(req, configUrl, configUser, configPassword);
 646         return setResponseStatus(ctx, r);
 647     }
 648
 649     private ConfigStatus activate(SvcLogicContext ctx, boolean change) {
 650         String reqTemplate = readFile("/config-request.xml");
 651         Map<String, String> param = new HashMap<String, String>();
 652         param.put("request-id", ctx.getAttribute("service-data.appc-request-header.svc-request-id"));
 653         param.put("callback-url", configCallbackUrl);
 654         param.put("action", change ? "DownloadChange" : "DownloadBase");
 655         param.put("equipment-name", ctx.getAttribute("service-data.service-information.service-instance-id"));
 656
 657         String req = null;
 658         try {
 659             req = buildXmlRequest(param, reqTemplate);
 660         } catch (Exception e) {
 661             log.error("Error building the XML request: ", e);
 662
 663             HttpResponse r = new HttpResponse();
 664             r.code = HttpURLConnection.HTTP_INTERNAL_ERROR;
 665             r.message = e.getMessage();
 666             return setResponseStatus(ctx, r);
 667         }
 668
 669         HttpResponse r = sendXmlRequest(req, configUrl, configUser, configPassword);
 670         return setResponseStatus(ctx, r);
 671     }
 672
 673     private ConfigStatus audit(SvcLogicContext ctx, String auditLevel) {
 674         String reqTemplate = readFile("/audit-request.xml");
 675         Map<String, String> param = new HashMap<String, String>();
 676         param.put("request-id", ctx.getAttribute("service-data.appc-request-header.svc-request-id"));
 677         param.put("callback-url", auditCallbackUrl);
 678         param.put("equipment-name", ctx.getAttribute("service-data.service-information.service-instance-id"));
 679         param.put("audit-level", auditLevel);
 680
 681         String req = null;
 682         try {
 683             req = buildXmlRequest(param, reqTemplate);
 684         } catch (Exception e) {
 685             log.error("Error building the XML request: ", e);
 686
 687             HttpResponse r = new HttpResponse();
 688             r.code = HttpURLConnection.HTTP_INTERNAL_ERROR;
 689             r.message = e.getMessage();
 690             return setResponseStatus(ctx, r);
 691         }
 692
 693         HttpResponse r = sendXmlRequest(req, auditUrl, auditUser, auditPassword);
 694         return setResponseStatus(ctx, r);
 695     }
 696
 697     @Override
 698     public ConfigStatus activate(String key, SvcLogicContext ctx) {
 699         return ConfigStatus.SUCCESS;
 700     }
 701
 702     @Override
 703     public ConfigStatus deactivate(String key, SvcLogicContext ctx) {
 704         return ConfigStatus.SUCCESS;
 705     }
 706
 707     private String escapeMySql(String input) {
 708         if (input == null) {
 709             return null;
 710         }
 711
 712         input = input.replace("\\", "\\\\");
 713         input = input.replace("\'", "\\'");
 714
 715         return input;
 716     }
 717
 718     protected String readFile(String fileName) {
 719         InputStream is = getClass().getResourceAsStream(fileName);
 720         InputStreamReader isr = new InputStreamReader(is);
 721         BufferedReader in = new BufferedReader(isr);
 722         StringBuilder ss = new StringBuilder();
 723         try {
 724             String s = in.readLine();
 725             while (s != null) {
 726                 ss.append(s).append('\n');
 727                 s = in.readLine();
 728             }
 729         } catch (IOException e) {
 730             System.out.println("Error reading " + fileName + ": " + e.getMessage());
 731             throw new RuntimeException("Error reading " + fileName + ": " + e.getMessage(), e);
 732         } finally {
 733             try {
 734                 in.close();
 735             } catch (Exception e) {
 736                 log.warn("Could not close BufferedReader", e);
 737             }
 738             try {
 739                 isr.close();
 740             } catch (Exception e) {
 741                 log.warn("Could not close InputStreamReader", e);
 742             }
 743             try {
 744                 is.close();
 745             } catch (Exception e) {
 746                 log.warn("Could not close InputStream", e);
 747             }
 748         }
 749         return ss.toString();
 750     }
 751
 752     private String buildXmlRequest(Map<String, String> param, String template) {
 753         StringBuilder ss = new StringBuilder();
 754         int i = 0;
 755         while (i < template.length()) {
 756             int i1 = template.indexOf("${", i);
 757             if (i1 < 0) {
 758                 ss.append(template.substring(i));
 759                 break;
 760             }
 761
 762             int i2 = template.indexOf('}', i1 + 2);
 763             if (i2 < 0) {
 764                 throw new RuntimeException("Template error: Matching } not found");
 765             }
 766
 767             String var1 = template.substring(i1 + 2, i2);
 768             String value1 = param.get(var1);
 769             if (value1 == null || value1.trim().length() == 0) {
 770                 // delete the whole element (line)
 771                 int i3 = template.lastIndexOf('\n', i1);
 772                 if (i3 < 0) {
 773                     i3 = 0;
 774                 }
 775                 int i4 = template.indexOf('\n', i1);
 776                 if (i4 < 0) {
 777                     i4 = template.length();
 778                 }
 779
 780                 if (i < i3) {
 781                     ss.append(template.substring(i, i3));
 782                 }
 783                 i = i4;
 784             } else {
 785                 ss.append(template.substring(i, i1)).append(value1);
 786                 i = i2 + 1;
 787             }
 788         }
 789
 790         return ss.toString();
 791     }
 792
 793     private String buildNetworkData2(SvcLogicContext ctx, String template, String operation) {
 794         log.info("Building XML started");
 795         long t1 = System.currentTimeMillis();
 796
 797         template = expandRepeats(ctx, template, 1);
 798
 799         Map<String, String> mm = new HashMap<>();
 800         for (String s : ctx.getAttributeKeySet()) {
 801             mm.put(s, ctx.getAttribute(s));
 802         }
 803         mm.put("operation", operation);
 804
 805         StringBuilder ss = new StringBuilder();
 806         int i = 0;
 807         while (i < template.length()) {
 808             int i1 = template.indexOf("${", i);
 809             if (i1 < 0) {
 810                 ss.append(template.substring(i));
 811                 break;
 812             }
 813
 814             int i2 = template.indexOf('}', i1 + 2);
 815             if (i2 < 0) {
 816                 throw new RuntimeException("Template error: Matching } not found");
 817             }
 818
 819             String var1 = template.substring(i1 + 2, i2);
 820             String value1 = XmlUtil.getXml(mm, var1);
 821             if (value1 == null || value1.trim().length() == 0) {
 822                 // delete the whole element (line)
 823                 int i3 = template.lastIndexOf('\n', i1);
 824                 if (i3 < 0) {
 825                     i3 = 0;
 826                 }
 827                 int i4 = template.indexOf('\n', i1);
 828                 if (i4 < 0) {
 829                     i4 = template.length();
 830                 }
 831
 832                 if (i < i3) {
 833                     ss.append(template.substring(i, i3));
 834                 }
 835                 i = i4;
 836             } else {
 837                 ss.append(template.substring(i, i1)).append(value1);
 838                 i = i2 + 1;
 839             }
 840         }
 841
 842         long t2 = System.currentTimeMillis();
 843         log.info("Building XML completed. Time: " + (t2 - t1));
 844
 845         return ss.toString();
 846     }
 847
 848     private String expandRepeats(SvcLogicContext ctx, String template, int level) {
 849         StringBuilder newTemplate = new StringBuilder();
 850         int k = 0;
 851         while (k < template.length()) {
 852             int i1 = template.indexOf("${repeat:", k);
 853             if (i1 < 0) {
 854                 newTemplate.append(template.substring(k));
 855                 break;
 856             }
 857
 858             int i2 = template.indexOf(':', i1 + 9);
 859             if (i2 < 0) {
 860                 throw new RuntimeException(
 861                         "Template error: Context variable name followed by : is required after repeat");
 862             }
 863
 864             // Find the closing }, store in i3
 865             int nn = 1;
 866             int i3 = -1;
 867             int i = i2;
 868             while (nn > 0 && i < template.length()) {
 869                 i3 = template.indexOf('}', i);
 870                 if (i3 < 0) {
 871                     throw new RuntimeException("Template error: Matching } not found");
 872                 }
 873                 int i32 = template.indexOf('{', i);
 874                 if (i32 >= 0 && i32 < i3) {
 875                     nn++;
 876                     i = i32 + 1;
 877                 } else {
 878                     nn--;
 879                     i = i3 + 1;
 880                 }
 881             }
 882
 883             String var1 = template.substring(i1 + 9, i2);
 884             String value1 = ctx.getAttribute(var1);
 885             log.info("         " + var1 + ": " + value1);
 886             int n = 0;
 887             try {
 888                 n = Integer.parseInt(value1);
 889             } catch (Exception e) {
 890                 n = 0;
 891             }
 892
 893             newTemplate.append(template.substring(k, i1));
 894
 895             String rpt = template.substring(i2 + 1, i3);
 896
 897             for (int ii = 0; ii < n; ii++) {
 898                 String ss = rpt.replaceAll("\\[\\$\\{" + level + "\\}\\]", "[" + ii + "]");
 899                 newTemplate.append(ss);
 900             }
 901
 902             k = i3 + 1;
 903         }
 904
 905         if (k == 0) {
 906             return newTemplate.toString();
 907         }
 908
 909         return expandRepeats(ctx, newTemplate.toString(), level + 1);
 910     }
 911
 912     private HttpResponse sendXmlRequest(String xmlRequest, String url, String user, String password) {
 913         try {
 914             Client client = getClient();
 915             client.setConnectTimeout(5000);
 916             WebResource webResource = client.resource(url);
 917
 918             log.info("SENDING...............");
 919             if (log.isTraceEnabled()) {
 920                 log.trace(xmlRequest);
 921             }
 922             else {
 923                 if(xmlRequest.length() > 255 ) {
 924                     log.info(xmlRequest.substring(0, 255));
 925                     log.info("\n...\n" + xmlRequest.length() +
 926                             " characters in request, turn on TRACE logging to log entire request");
 927                 }
 928                 else {
 929                     log.info(xmlRequest);
 930                 }
 931             }
 932             String authString = user + ":" + password;
 933             byte[] authEncBytes = Base64.encode(authString);
 934             String authStringEnc = new String(authEncBytes);
 935             authString = "Basic " + authStringEnc;
 936
 937             ClientResponse response = getClientResponse(webResource, authString, xmlRequest);
 938
 939             int code = response.getStatus();
 940             String message = null;
 941
 942             log.info("RESPONSE...............");
 943             log.info("HTTP response code: " + code);
 944             log.info("HTTP response message: " + message);
 945             log.info("");
 946
 947             HttpResponse r = new HttpResponse();
 948             r.code = code;
 949             r.message = message;
 950             return r;
 951
 952         } catch (Exception e) {
 953             log.error("Error sending the request: ", e);
 954
 955             HttpResponse r = new HttpResponse();
 956             r.code = HttpURLConnection.HTTP_INTERNAL_ERROR;
 957             r.message = e.getMessage();
 958             return r;
 959         }
 960     }
 961
 962     private static class HttpResponse {
 963
 964         public int code;
 965
 966         public String message;
 967     }
 968
 969     private ConfigStatus setResponseStatus(SvcLogicContext ctx, HttpResponse r) {
 970         ctx.setAttribute("error-code", String.valueOf(r.code));
 971         ctx.setAttribute("error-message", r.message);
 972
 973         return r.code > 299 ? ConfigStatus.FAILURE : ConfigStatus.SUCCESS;
 974     }
 975
 976     private String getStringBetweenQuotes(String string) {
 977         String fnName = "ConfigComponentAdaptor.getStringBetweenQuotes";
 978         DebugLog.printAriDebug(fnName, "string=" + string);
 979         String retString = null;
 980         int start = string.indexOf("\"");
 981         int end = string.lastIndexOf("\"");
 982         retString = string.substring(start + 1, end);
 983         DebugLog.printAriDebug(fnName, "retString=" + retString);
 984         return (retString);
 985     }
 986
 987     public static String _readFile(String fileName) {
 988         StringBuffer strBuff = new StringBuffer();
 989         String line;
 990         try (BufferedReader in = new BufferedReader(new FileReader(fileName))) {
 991             while ((line = in.readLine()) != null) {
 992                 strBuff.append(line + "\n");
 993             }
 994         } catch (IOException e) {
 995             System.out.println("Caught an IOException in method readFile(): e=" + e.toString());
 996         }
 997         return (strBuff.toString());
 998     }
 999
1000     private String trimResponse(String response) {
1001         log.debug("runningConfig before trimResponse : " + response);
1002         StringTokenizer line = new StringTokenizer(response, "\n");
1003         StringBuffer sb = new StringBuffer();
1004         String runningConfig = "" ;
1005         boolean captureText = false;
1006         while (line.hasMoreTokens()) {
1007             String token = line.nextToken();
1008             if (token.indexOf("<configuration xmlns=") != -1) {
1009                 captureText = true;
1010             }else if(token.indexOf("<data>") != -1) {
1011                 log.debug("token-line:with in Data: "+token);
1012                 captureText = true;
1013                 continue;
1014             }
1015
1016             if(token.indexOf("</data>") != -1) {
1017                 log.debug("token-line:with in </data>"+token);
1018                 captureText = false;
1019             }
1020             if (captureText) {
1021                 sb.append(token + "\n");
1022             }
1023             if (token.indexOf("</configuration>") != -1) {
1024                 captureText = false;
1025             }
1026         }
1027         runningConfig = sb.toString();
1028
1029         if (log.isTraceEnabled()) {
1030             log.trace("ConfigComponentAdaptor:RunningConfig after trimResponse : " + runningConfig);
1031         }
1032         else {
1033             if (runningConfig.length() > 255) {
1034                 log.info("ConfigComponentAdaptor:RunningConfig after trimResponse : " +
1035                         runningConfig.substring(0, 255));
1036                 log.info("\n...\n" + runningConfig.length() +
1037                         " characters in config, turn on TRACE logging to log entire config");
1038             }
1039             else {
1040                 log.info("ConfigComponentAdaptor:RunningConfig after trimResponse : " +
1041                         runningConfig);
1042             }
1043         }
1044         log.info("ConfigComponentAdaptor:RunningConfig after trimResponse : " + runningConfig);
1045         return runningConfig;
1046     }
1047
1048     public static void main(String args[]) throws Exception {
1049         Properties props = null;
1050         System.out.println("*************************Hello*****************************");
1051         ConfigComponentAdaptor cca = new ConfigComponentAdaptor(props);
1052         String Get_config_template = _readFile("/home/userID/data/Get_config_template");
1053         String Download_config_template = _readFile("/home/userID/data/Download_config_template_2");
1054         String key = "GetCliRunningConfig";
1055         Map<String, String> parameters = new HashMap();
1056         parameters.put("Host_ip_address", "000.00.000.00");
1057         parameters.put("User_name", "root");
1058         parameters.put("Password", "!bootstrap");
1059         parameters.put("Port_number", "22");
1060         parameters.put("Get_config_template", Get_config_template);
1061
1062         SvcLogicContext ctx = null;
1063         System.out.println("*************************TRACE 1*****************************");
1064         cca.configure(key, parameters, ctx);
1065     }
1066
1067     protected SshJcraftWrapper getSshJcraftWrapper() {
1068         return new SshJcraftWrapper();
1069     }
1070
1071     protected Client getClient() {
1072         return Client.create();
1073     }
1074
1075     protected ClientResponse getClientResponse(WebResource webResource, String authString, String xmlRequest) {
1076         return webResource.header("Authorization", authString).accept("UTF-8").type("application/xml").post(
1077                 ClientResponse.class, xmlRequest);
1078     }
1079 }