appc-config/appc-data-services/provider/src/main/java/org/openecomp/appc/data/services/node/ConfigResourceNode.java

   1 /*-
   2  * ============LICENSE_START=======================================================
   3  * ONAP : APP-C
   4  * ================================================================================
   5  * Copyright (C) 2017 AT&T Intellectual Property.  All rights reserved.
   6  * ================================================================================
   7  * Licensed under the Apache License, Version 2.0 (the "License");
   8  * you may not use this file except in compliance with the License.
   9  * You may obtain a copy of the License at
  10  *
  11  *      http://www.apache.org/licenses/LICENSE-2.0
  12  *
  13  * Unless required by applicable law or agreed to in writing, software
  14  * distributed under the License is distributed on an "AS IS" BASIS,
  15  * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
  16  * See the License for the specific language governing permissions and
  17  * limitations under the License.
  18  * ============LICENSE_END=========================================================
  19  */
  20
  21 package org.openecomp.appc.data.services.node;
  22
  23 import java.util.Map;
  24
  25 import org.apache.commons.lang3.StringUtils;
  26 import com.att.eelf.configuration.EELFLogger;
  27 import com.att.eelf.configuration.EELFManager;
  28 import com.fasterxml.jackson.databind.JsonNode;
  29 import com.fasterxml.jackson.databind.ObjectMapper;
  30
  31 import org.openecomp.sdnc.sli.SvcLogicContext;
  32 import org.openecomp.sdnc.sli.SvcLogicException;
  33 import org.openecomp.sdnc.sli.SvcLogicJavaPlugin;
  34
  35 import org.openecomp.appc.data.services.AppcDataServiceConstant;
  36 import org.openecomp.appc.data.services.db.DGGeneralDBService;
  37 import org.openecomp.appc.data.services.utils.EscapeUtils;
  38
  39 import org.openecomp.sdnc.sli.SvcLogicResource.QueryStatus;
  40
  41 public class ConfigResourceNode implements SvcLogicJavaPlugin {
  42
  43         private static final EELFLogger log = EELFManager.getInstance().getLogger(ConfigResourceNode.class);
  44
  45         public void getConfigFileReference(Map<String, String> inParams, SvcLogicContext ctx) throws SvcLogicException {
  46
  47                 log.info("Received getConfigFiles call with params : " + inParams);
  48
  49                 String responsePrefix = inParams.get(AppcDataServiceConstant.INPUT_PARAM_RESPONSE_PREFIX);
  50
  51                 try {
  52
  53                         responsePrefix = StringUtils.isNotBlank(responsePrefix) ? (responsePrefix+".") : "";
  54                         DGGeneralDBService db = DGGeneralDBService.initialise();
  55                         QueryStatus status = db.getConfigFileReferenceByFileTypeNVnfType(ctx, "configfilereference-deviceconfig",
  56                                         "device_configuration");
  57
  58                         if (status == QueryStatus.NOT_FOUND || status == QueryStatus.FAILURE)
  59                                 throw new Exception("Unable to Read ConfigFileReference:device-configuration");
  60
  61                         status = db.getConfigFileReferenceByFileTypeNVnfType(ctx, "configfilereference-success",
  62                                         "configuration_success");
  63
  64                         if (status == QueryStatus.NOT_FOUND || status == QueryStatus.FAILURE)
  65                                 throw new Exception("Unable to Read ConfigFileReference:configuration_success");
  66
  67                         status = db.getConfigFileReferenceByFileTypeNVnfType(ctx, "configfilereference-failure",
  68                                         "configuration_error");
  69
  70                         if (status == QueryStatus.NOT_FOUND || status == QueryStatus.FAILURE)
  71                                 throw new Exception("Unable to Read ConfigFileReference:configuration_error");
  72
  73                         status = db.getConfigFileReferenceByFileTypeNVnfType(ctx, "configfilereference-log", "log");
  74
  75                         if (status == QueryStatus.NOT_FOUND || status == QueryStatus.FAILURE)
  76                                 throw new Exception("Unable to Read ConfigFileReference:configuration_log");
  77
  78
  79                         ctx.setAttribute(responsePrefix + AppcDataServiceConstant.OUTPUT_PARAM_STATUS,
  80                                         AppcDataServiceConstant.OUTPUT_STATUS_SUCCESS);
  81                         log.info("GetConfigFileReference Successful ");
  82                 } catch (Exception e) {
  83                         ctx.setAttribute(responsePrefix + AppcDataServiceConstant.OUTPUT_PARAM_STATUS,
  84                                         AppcDataServiceConstant.OUTPUT_STATUS_FAILURE);
  85                         ctx.setAttribute(responsePrefix + AppcDataServiceConstant.OUTPUT_PARAM_ERROR_MESSAGE, e.getMessage());
  86                         log.error("Failed in GetConfigFileReference " + e.getMessage());
  87
  88                         throw new SvcLogicException(e.getMessage());
  89                 }
  90         }
  91
  92         public void getCommonConfigInfo(Map<String, String> inParams, SvcLogicContext ctx) throws SvcLogicException {
  93
  94                 log.info("Received getDeviceInfo call with params : " + inParams);
  95
  96                 String responsePrefix = inParams.get(AppcDataServiceConstant.INPUT_PARAM_RESPONSE_PREFIX);
  97
  98                 try {
  99
 100                         responsePrefix = StringUtils.isNotBlank(responsePrefix) ? (responsePrefix+".") : "";
 101                         DGGeneralDBService db = DGGeneralDBService.initialise();
 102                         QueryStatus status = db.getDeviceAuthenticationByVnfType(ctx, "device-authentication");
 103
 104                         if (status == QueryStatus.NOT_FOUND || status == QueryStatus.FAILURE)
 105                                 throw new Exception("Unable to Read device_authentication");
 106
 107                         status = db.getDeviceProtocolByVnfType(ctx, "tmp.deviceinterfaceprotocol");
 108
 109                         if (status == QueryStatus.NOT_FOUND || status == QueryStatus.FAILURE)
 110                                 throw new Exception("Unable to Read device_interface_protocol");
 111
 112                         status = db.getConfigureActionDGByVnfTypeNAction(ctx, "tmp.configureactiondg");
 113                         if (status == QueryStatus.FAILURE)
 114                                 throw new Exception("Unable to Read configure_action_dg");
 115
 116                         if (status == QueryStatus.NOT_FOUND) {
 117                                 status = db.getConfigureActionDGByVnfType(ctx, "tmp.configureactiondg");
 118
 119                                 if (status == QueryStatus.NOT_FOUND || status == QueryStatus.FAILURE)
 120                                         throw new Exception("Unable to Read configure_action_dg");
 121                         }
 122
 123
 124
 125
 126
 127                         ctx.setAttribute(responsePrefix + AppcDataServiceConstant.OUTPUT_PARAM_STATUS,
 128                                         AppcDataServiceConstant.OUTPUT_STATUS_SUCCESS);
 129                         log.info("getCommonConfigInfo Successful ");
 130                 } catch (Exception e) {
 131                         ctx.setAttribute(responsePrefix + AppcDataServiceConstant.OUTPUT_PARAM_STATUS,
 132                                         AppcDataServiceConstant.OUTPUT_STATUS_FAILURE);
 133                         ctx.setAttribute(responsePrefix + AppcDataServiceConstant.OUTPUT_PARAM_ERROR_MESSAGE, e.getMessage());
 134                         log.error("Failed in getCommonConfigInfo " + e.getMessage());
 135
 136                         throw new SvcLogicException(e.getMessage());
 137                 }
 138         }
 139
 140
 141         // fileCategory Can be  config_template, parameter_definitions, parameter_yang
 142         public void getTemplate(Map<String, String> inParams, SvcLogicContext ctx) throws SvcLogicException {
 143
 144                 log.info("Received getTemplate call with params : " + inParams);
 145
 146
 147                 String responsePrefix = inParams.get(AppcDataServiceConstant.INPUT_PARAM_RESPONSE_PREFIX);
 148                 String fileCategory = inParams.get(AppcDataServiceConstant.INPUT_PARAM_FILE_CATEGORY);
 149                 String templateName = ctx.getAttribute("template-name");
 150                 QueryStatus status = null;
 151                 String responsePrefix1 = "";
 152
 153                 try {
 154
 155                         responsePrefix1 = StringUtils.isNotBlank(responsePrefix) ? (responsePrefix+".") : "";
 156                         log.info("RESPONSEPREFIX : " + responsePrefix);
 157                         log.info("RESPONSEPREFIX1 : " + responsePrefix1);
 158
 159                         DGGeneralDBService db = DGGeneralDBService.initialise();
 160
 161                         if (StringUtils.isBlank(templateName)) {
 162
 163                                 //if ( !StringUtils.isBlank(ctx.getAttribute("vnfc-type"))) {
 164
 165
 166                                 status = db.getTemplate(ctx, responsePrefix, fileCategory);
 167                                 if (status == QueryStatus.FAILURE)
 168                                         throw new Exception("Unable to Read " + fileCategory );
 169                                 //}
 170
 171                                 if (status == QueryStatus.NOT_FOUND) {
 172
 173
 174                                         status = db.getTemplateByVnfTypeNAction(ctx, responsePrefix, fileCategory);
 175
 176                                         if (status == QueryStatus.FAILURE)
 177                                                 throw new Exception("Unable to Read " + fileCategory );
 178
 179                                         if (status == QueryStatus.NOT_FOUND) {
 180
 181                                                 status = db.getTemplateByVnfType(ctx, responsePrefix, fileCategory);
 182
 183                                                 if (status == QueryStatus.NOT_FOUND || status == QueryStatus.FAILURE)
 184                                                         throw new Exception("Unable to Read " + fileCategory );
 185                                         }
 186                                 }
 187                         } else {
 188
 189                                 status = db.getTemplateByTemplateName(ctx, responsePrefix, templateName);
 190
 191                                 if (status == QueryStatus.NOT_FOUND || status == QueryStatus.FAILURE)
 192                                         throw new Exception("Unable to Read " + fileCategory + " template");
 193                         }
 194
 195
 196                         ctx.setAttribute(responsePrefix1 + AppcDataServiceConstant.OUTPUT_PARAM_STATUS,
 197                                         AppcDataServiceConstant.OUTPUT_STATUS_SUCCESS);
 198                         log.info("GetTemplate Successful ");
 199                 } catch (Exception e) {
 200                         ctx.setAttribute(responsePrefix1 + AppcDataServiceConstant.OUTPUT_PARAM_STATUS,
 201                                         AppcDataServiceConstant.OUTPUT_STATUS_FAILURE);
 202                         ctx.setAttribute(responsePrefix1 + AppcDataServiceConstant.OUTPUT_PARAM_ERROR_MESSAGE, e.getMessage());
 203                         log.error("Failed in getTemplate " + e.getMessage());
 204
 205                         throw new SvcLogicException(e.getMessage());
 206                 }
 207         }
 208
 209         public void saveConfigFiles(Map<String, String> inParams, SvcLogicContext ctx) throws SvcLogicException {
 210
 211                 log.info("Received saveConfigFiles call with params : " + inParams);
 212
 213                 String responsePrefix = inParams.get(AppcDataServiceConstant.INPUT_PARAM_RESPONSE_PREFIX);
 214
 215                 try {
 216
 217                         responsePrefix = StringUtils.isNotBlank(responsePrefix) ? (responsePrefix+".") : "";
 218                         DGGeneralDBService db = DGGeneralDBService.initialise();
 219                         QueryStatus status = db.saveConfigFiles(ctx, "tmp.configFiles");
 220
 221                         if (status == QueryStatus.FAILURE)
 222                                 throw new Exception("Unable to Save " + ctx.getAttribute("file-category") + " in configfiles");
 223
 224                         status = db.getMaxConfigFileId(ctx, "tmp.configfilesmax", ctx.getAttribute("file-category"));
 225
 226                         if (status == QueryStatus.NOT_FOUND || status == QueryStatus.FAILURE)
 227                                 throw new Exception("Unable to get " + ctx.getAttribute("file-category") + " from configfiles");
 228
 229                         status = db.savePrepareRelationship(ctx, "tmp.preparerel",
 230                                         ctx.getAttribute("tmp.configfilesmax.configfileid"), "N");
 231                         if (status == QueryStatus.FAILURE)
 232                                 throw new Exception("Unable to save prepare_relationship");
 233
 234                         ctx.setAttribute(responsePrefix + AppcDataServiceConstant.OUTPUT_PARAM_STATUS,
 235                                         AppcDataServiceConstant.OUTPUT_STATUS_SUCCESS);
 236                         log.info("saveConfigFiles Successful ");
 237                 } catch (Exception e) {
 238                         ctx.setAttribute(responsePrefix + AppcDataServiceConstant.OUTPUT_PARAM_STATUS,
 239                                         AppcDataServiceConstant.OUTPUT_STATUS_FAILURE);
 240                         ctx.setAttribute(responsePrefix + AppcDataServiceConstant.OUTPUT_PARAM_ERROR_MESSAGE, e.getMessage());
 241                         log.error("Failed in saveConfigFiles " + e.getMessage());
 242
 243                         throw new SvcLogicException(e.getMessage());
 244                 }
 245         }
 246
 247         public void updateUploadConfig(Map<String, String> inParams, SvcLogicContext ctx) throws SvcLogicException {
 248
 249                 log.info("Received updateUploadConfig call with params : " + inParams);
 250
 251                 String responsePrefix = inParams.get(AppcDataServiceConstant.INPUT_PARAM_RESPONSE_PREFIX);
 252
 253                 try {
 254
 255                         responsePrefix = StringUtils.isNotBlank(responsePrefix) ? (responsePrefix+".") : "";
 256                         DGGeneralDBService db = DGGeneralDBService.initialise();
 257
 258                         ctx.setAttribute("tmp.escaped.devicerunningconfig",
 259                                         EscapeUtils.escapeSql(ctx.getAttribute("device-running-config")));
 260
 261                         QueryStatus status = db.saveUploadConfig(ctx, "tmp.uploadConfig");
 262
 263                         if (status == QueryStatus.FAILURE)
 264                                 throw new Exception("Unable to Save configuration in upload_config");
 265
 266                         /*status = db.getMaxUploadConfigFileId(ctx, "tmp.uploadconfigmax");
 267
 268                         if (status == QueryStatus.NOT_FOUND || status == QueryStatus.FAILURE)
 269                                 throw new Exception("Unable to get record from upload_config");
 270
 271                         status = db.updateUploadConfig(ctx, "tmp.uploadConfig",
 272                                         Integer.parseInt(ctx.getAttribute("tmp.uploadconfigmax.uploadconfigid")));
 273                         if (status == QueryStatus.FAILURE)
 274                                 throw new Exception("Unable to upload upload_config");*/
 275
 276                         status = db.getUploadConfigInfo(ctx, "tmp.uploadConfigInfo");
 277
 278                         if (status == QueryStatus.NOT_FOUND || status == QueryStatus.FAILURE)
 279                                 throw new Exception("Unable to get record from upload_config");
 280
 281                         status = db.updateUploadConfig(ctx, "tmp.uploadConfig",
 282                                         Integer.parseInt(ctx.getAttribute("tmp.uploadConfigInfo.UPLOAD-CONFIG-ID")));
 283                         if (status == QueryStatus.FAILURE)
 284                                 throw new Exception("Unable to upload upload_config");
 285
 286                         ctx.setAttribute(responsePrefix + AppcDataServiceConstant.OUTPUT_PARAM_STATUS,
 287                                         AppcDataServiceConstant.OUTPUT_STATUS_SUCCESS);
 288                         log.info("updateUploadConfig Successful ");
 289                 } catch (Exception e) {
 290                         ctx.setAttribute(responsePrefix + AppcDataServiceConstant.OUTPUT_PARAM_STATUS,
 291                                         AppcDataServiceConstant.OUTPUT_STATUS_FAILURE);
 292                         ctx.setAttribute(responsePrefix + AppcDataServiceConstant.OUTPUT_PARAM_ERROR_MESSAGE, e.getMessage());
 293                         log.error("Failed in updateUploadConfig  " + e.getMessage());
 294
 295                         throw new SvcLogicException(e.getMessage());
 296                 }
 297         }
 298
 299         public void savePrepareRelationship(Map<String, String> inParams, SvcLogicContext ctx) throws SvcLogicException {
 300
 301                 log.info("Received savePrepareRelationship call with params : " + inParams);
 302
 303                 String responsePrefix = inParams.get(AppcDataServiceConstant.INPUT_PARAM_RESPONSE_PREFIX);
 304                 String sdcArtifactInd = inParams.get(AppcDataServiceConstant.INPUT_PARAM_SDC_ARTIFACT_IND);
 305                 String fileId = inParams.get(AppcDataServiceConstant.INPUT_PARAM_FILE_ID);
 306                 try {
 307
 308                         responsePrefix = StringUtils.isNotBlank(responsePrefix) ? (responsePrefix+".") : "";
 309                         DGGeneralDBService db = DGGeneralDBService.initialise();
 310
 311                         QueryStatus status = db.savePrepareRelationship(ctx, "tmp.preparerel", fileId, sdcArtifactInd);
 312                         if (status == QueryStatus.FAILURE)
 313                                 throw new Exception("Unable to save prepare_relationship");
 314
 315                         ctx.setAttribute(responsePrefix + AppcDataServiceConstant.OUTPUT_PARAM_STATUS,
 316                                         AppcDataServiceConstant.OUTPUT_STATUS_SUCCESS);
 317                         log.info("savePrepareRelationship Successful ");
 318                 } catch (Exception e) {
 319                         ctx.setAttribute(responsePrefix + AppcDataServiceConstant.OUTPUT_PARAM_STATUS,
 320                                         AppcDataServiceConstant.OUTPUT_STATUS_FAILURE);
 321                         ctx.setAttribute(responsePrefix + AppcDataServiceConstant.OUTPUT_PARAM_ERROR_MESSAGE, e.getMessage());
 322                         log.error("Failed in saveConfigFiles " + e.getMessage());
 323
 324                         throw new SvcLogicException(e.getMessage());
 325                 }
 326         }
 327
 328         public void saveConfigBlock(Map<String, String> inParams, SvcLogicContext ctx) throws SvcLogicException {
 329
 330                 log.info("Received saveConfigBlock call with params : " + inParams);
 331
 332                 String responsePrefix = inParams.get(AppcDataServiceConstant.INPUT_PARAM_RESPONSE_PREFIX);
 333
 334                 try {
 335
 336                         responsePrefix = StringUtils.isNotBlank(responsePrefix) ? (responsePrefix+".") : "";
 337                         ctx.setAttribute("tmp.convertconfig.escapeData",
 338                                         EscapeUtils.escapeSql(ctx.getAttribute("configuration")));
 339                         DGGeneralDBService db = DGGeneralDBService.initialise();
 340
 341                         if (StringUtils.isBlank(ctx.getAttribute("configuration-params"))) {
 342                                 saveDeviceConfiguration(inParams, ctx, "Request", ctx.getAttribute("tmp.convertconfig.escapeData"),
 343                                                 ctx.getAttribute("configuration"));
 344                         } else {
 345
 346                                 saveConfigurationBlock(inParams, ctx);
 347
 348                                 ctx.setAttribute("tmp.convertconfig.escapeData",
 349                                                 EscapeUtils.escapeSql(ctx.getAttribute("tmp.merge.mergedData")));
 350                                 saveDeviceConfiguration(inParams, ctx, "Configurator", ctx.getAttribute("tmp.convertconfig.escapeData"),
 351                                                 ctx.getAttribute("tmp.merge.mergedData"));
 352
 353                                 saveConfigurationData(inParams, ctx);
 354                         }
 355
 356                         ctx.setAttribute(responsePrefix + AppcDataServiceConstant.OUTPUT_PARAM_STATUS,
 357                                         AppcDataServiceConstant.OUTPUT_STATUS_SUCCESS);
 358                         log.info("saveConfigBlock Successful ");
 359                 } catch (Exception e) {
 360                         ctx.setAttribute(responsePrefix + AppcDataServiceConstant.OUTPUT_PARAM_STATUS,
 361                                         AppcDataServiceConstant.OUTPUT_STATUS_FAILURE);
 362                         ctx.setAttribute(responsePrefix + AppcDataServiceConstant.OUTPUT_PARAM_ERROR_MESSAGE, e.getMessage());
 363                         log.error("Failed in saveConfigBlock " + e.getMessage());
 364
 365                         throw new SvcLogicException(e.getMessage());
 366                 }
 367         }
 368
 369         public void saveTemplateConfig(Map<String, String> inParams, SvcLogicContext ctx) throws SvcLogicException {
 370
 371                 log.info("Received saveTemplateConfig call with params : " + inParams);
 372
 373                 String responsePrefix = inParams.get(AppcDataServiceConstant.INPUT_PARAM_RESPONSE_PREFIX);
 374
 375                 try {
 376
 377                         responsePrefix = StringUtils.isNotBlank(responsePrefix) ? (responsePrefix+".") : "";
 378                         DGGeneralDBService db = DGGeneralDBService.initialise();
 379
 380                         if (StringUtils.isBlank(ctx.getAttribute("configuration-params"))) {
 381
 382                                 ctx.setAttribute("tmp.convertconfig.escapeData",
 383                                                 EscapeUtils.escapeSql(ctx.getAttribute("config-template.file-content")));
 384                                 saveDeviceConfiguration(inParams, ctx, "Template", ctx.getAttribute("tmp.convertconfig.escapeData"),
 385                                                 ctx.getAttribute("config-template.file-content"));
 386
 387                         } else {
 388                                 saveConfigurationData(inParams, ctx);
 389
 390                                 ctx.setAttribute("tmp.convertconfig.escapeData",
 391                                                 EscapeUtils.escapeSql(ctx.getAttribute("tmp.merge.mergedData")));
 392                                 saveDeviceConfiguration(inParams, ctx, "Configurator", ctx.getAttribute("tmp.convertconfig.escapeData"),
 393                                                 ctx.getAttribute("tmp.merge.mergedData"));
 394
 395                         }
 396
 397                         QueryStatus status = db.savePrepareRelationship(ctx, "tmp.preparerel",
 398                                         ctx.getAttribute("config-template.config-file-id"), "Y");
 399                         if (status == QueryStatus.FAILURE)
 400                                 throw new Exception("Unable to save prepare_relationship");
 401
 402                         ctx.setAttribute(responsePrefix + AppcDataServiceConstant.OUTPUT_PARAM_STATUS,
 403                                         AppcDataServiceConstant.OUTPUT_STATUS_SUCCESS);
 404                         log.info("saveTemplateConfig Successful ");
 405                 } catch (Exception e) {
 406                         ctx.setAttribute(responsePrefix + AppcDataServiceConstant.OUTPUT_PARAM_STATUS,
 407                                         AppcDataServiceConstant.OUTPUT_STATUS_FAILURE);
 408                         ctx.setAttribute(responsePrefix + AppcDataServiceConstant.OUTPUT_PARAM_ERROR_MESSAGE, e.getMessage());
 409                         log.error("Failed in saveTemplateConfig " + e.getMessage());
 410
 411                         throw new SvcLogicException(e.getMessage());
 412                 }
 413         }
 414
 415
 416
 417
 418         public void saveStyleSheetConfig(Map<String, String> inParams, SvcLogicContext ctx) throws SvcLogicException {
 419
 420
 421                 log.info("Received saveStyleSheet call with params : " + inParams);
 422
 423                 String responsePrefix = inParams.get(AppcDataServiceConstant.INPUT_PARAM_RESPONSE_PREFIX);
 424
 425                 try {
 426
 427                         responsePrefix = StringUtils.isNotBlank(responsePrefix) ? (responsePrefix+".") : "";
 428                         ctx.setAttribute("tmp.convertconfig.escapeData",
 429                                         EscapeUtils.escapeSql(ctx.getAttribute("tmp.merge.mergedData")));
 430                         saveDeviceConfiguration(inParams, ctx, "StyleSheet", ctx.getAttribute("tmp.convertconfig.escapeData"),
 431                                         ctx.getAttribute("tmp.merge.mergedData"));
 432
 433
 434                         ctx.setAttribute(responsePrefix + AppcDataServiceConstant.OUTPUT_PARAM_STATUS, AppcDataServiceConstant.OUTPUT_STATUS_SUCCESS);
 435                         log.info("saveStyleSheet Successful ");
 436                 } catch (Exception e) {
 437                         ctx.setAttribute(responsePrefix + AppcDataServiceConstant.OUTPUT_PARAM_STATUS, AppcDataServiceConstant.OUTPUT_STATUS_FAILURE);
 438                         ctx.setAttribute(responsePrefix + AppcDataServiceConstant.OUTPUT_PARAM_ERROR_MESSAGE,e.getMessage());
 439                         log.error("Failed in saveStyleSheet " + e.getMessage());
 440
 441                         throw new SvcLogicException(e.getMessage());
 442                 }
 443         }
 444
 445
 446         public void getSmmChainKeyFiles(Map<String, String> inParams, SvcLogicContext ctx) throws SvcLogicException {
 447
 448
 449                 log.info("Received saveStyleSheet call with params : " + inParams);
 450
 451                 String responsePrefix = inParams.get(AppcDataServiceConstant.INPUT_PARAM_RESPONSE_PREFIX);
 452                 String siteLocation = ctx.getAttribute("site-location");
 453
 454                 QueryStatus status = null;
 455
 456                 try{
 457
 458
 459                         responsePrefix = StringUtils.isNotBlank(responsePrefix) ? (responsePrefix+".") : "";
 460                         DGGeneralDBService db = DGGeneralDBService.initialise();
 461
 462
 463
 464                         status = db.getTemplateByArtifactType(ctx,  "smm", "smm", siteLocation);
 465
 466                         if ( status == QueryStatus.FAILURE )
 467                                 throw new Exception("Unable to Read smm file");
 468
 469
 470                         status = db.getTemplateByArtifactType(ctx,  "intermediate-ca-chain", "intermediate_ca_chain", siteLocation);
 471
 472                         if ( status == QueryStatus.FAILURE )
 473                                 throw new Exception("Unable to Read intermediate_ca_chain file");
 474
 475
 476
 477
 478                         status = db.getTemplateByArtifactType(ctx,  "server-certificate-and-key", "server_certificate_and_key", siteLocation);
 479
 480                         if ( status == QueryStatus.FAILURE )
 481                                 throw new Exception("Unable to Read server_certificate_and_key file");
 482
 483
 484                         ctx.setAttribute(responsePrefix + AppcDataServiceConstant.OUTPUT_PARAM_STATUS, AppcDataServiceConstant.OUTPUT_STATUS_SUCCESS);
 485                         log.info("saveStyleSheet Successful ");
 486                 } catch (Exception e) {
 487                         ctx.setAttribute(responsePrefix + AppcDataServiceConstant.OUTPUT_PARAM_STATUS, AppcDataServiceConstant.OUTPUT_STATUS_FAILURE);
 488                         ctx.setAttribute(responsePrefix + AppcDataServiceConstant.OUTPUT_PARAM_ERROR_MESSAGE,e.getMessage());
 489                         log.error("Failed in saveStyleSheet " + e.getMessage());
 490
 491                         throw new SvcLogicException(e.getMessage());
 492                 }
 493         }
 494
 495
 496         public void saveDeviceConfiguration(Map<String, String> inParams, SvcLogicContext ctx, String dataSource,
 497                         String fileContent, String deviceConfig) throws SvcLogicException {
 498                 ctx.setAttribute("data-source", dataSource);
 499                 ctx.setAttribute("file-content", fileContent);
 500                 ctx.setAttribute("file-category", "device_configuration");
 501                 ctx.setAttribute("deviceconfig-file-content", deviceConfig);
 502
 503                 saveConfigFiles(inParams, ctx);
 504         }
 505
 506         public void saveConfigurationBlock(Map<String, String> inParams, SvcLogicContext ctx) throws SvcLogicException {
 507                 ctx.setAttribute("data-source", "Request");
 508                 ctx.setAttribute("file-content", ctx.getAttribute("tmp.convertconfig.escapeData"));
 509                 ctx.setAttribute("file-category", "configuration_block");
 510                 saveConfigFiles(inParams, ctx);
 511         }
 512
 513         public void saveConfigurationData(Map<String, String> inParams, SvcLogicContext ctx) throws SvcLogicException {
 514                 ctx.setAttribute("data-source", ctx.getAttribute("originator-id"));
 515                 ctx.setAttribute("file-content", ctx.getAttribute("configuration-params"));
 516                 ctx.setAttribute("file-category", "config_data");
 517                 saveConfigFiles(inParams, ctx);
 518         }
 519
 520
 521         public void getConfigFilesByVnfVmNCategory(Map<String, String> inParams, SvcLogicContext ctx) throws SvcLogicException {
 522
 523                 log.info("Received getConfigFilesByVnfVmNCategory call with params : " + inParams);
 524
 525                 String responsePrefix = inParams.get(AppcDataServiceConstant.INPUT_PARAM_RESPONSE_PREFIX);
 526                 String fileCategory = inParams.get(AppcDataServiceConstant.INPUT_PARAM_FILE_CATEGORY);
 527                 String vnfId = inParams.get(AppcDataServiceConstant.INPUT_PARAM_VNF_ID);
 528                 String vmName = inParams.get(AppcDataServiceConstant.INPUT_PARAM_VM_NAME);
 529                 try {
 530
 531
 532                         DGGeneralDBService db = DGGeneralDBService.initialise();
 533
 534                         QueryStatus status = db.getConfigFilesByVnfVmNCategory(ctx, responsePrefix, fileCategory, vnfId, vmName);
 535
 536                         if (status == QueryStatus.NOT_FOUND || status == QueryStatus.FAILURE)
 537                                 throw new Exception("Unable to get " + ctx.getAttribute("fileCategory") + " from configfiles");
 538
 539
 540                         responsePrefix = StringUtils.isNotBlank(responsePrefix) ? (responsePrefix+".") : "";
 541                         ctx.setAttribute(responsePrefix + AppcDataServiceConstant.OUTPUT_PARAM_STATUS,
 542                                         AppcDataServiceConstant.OUTPUT_STATUS_SUCCESS);
 543                         log.info("getConfigFilesByVnfVmNCategory Successful " + ctx.getAttribute(responsePrefix + AppcDataServiceConstant.OUTPUT_PARAM_STATUS));
 544                 } catch (Exception e) {
 545                         ctx.setAttribute(responsePrefix + AppcDataServiceConstant.OUTPUT_PARAM_STATUS,
 546                                         AppcDataServiceConstant.OUTPUT_STATUS_FAILURE);
 547                         ctx.setAttribute(responsePrefix + AppcDataServiceConstant.OUTPUT_PARAM_ERROR_MESSAGE, e.getMessage());
 548                         log.error("Failed in getConfigFilesByVnfVmNCategory " + e.getMessage());
 549
 550                         throw new SvcLogicException(e.getMessage());
 551                 }
 552         }
 553
 554
 555         public void getDownloadConfigTemplateByVnf(Map<String, String> inParams, SvcLogicContext ctx) throws SvcLogicException {
 556
 557                 log.info("Received getDownloadConfigTemplateByVnfNProtocol call with params : " + inParams);
 558
 559                 String responsePrefix = inParams.get(AppcDataServiceConstant.INPUT_PARAM_RESPONSE_PREFIX);
 560                 try {
 561                         DGGeneralDBService db = DGGeneralDBService.initialise();
 562
 563                         QueryStatus status = db.getDownloadConfigTemplateByVnf(ctx, responsePrefix);
 564
 565                         if (status == QueryStatus.NOT_FOUND || status == QueryStatus.FAILURE)
 566                                 throw new Exception("Unable to get download config template.");
 567
 568
 569                         responsePrefix = StringUtils.isNotBlank(responsePrefix) ? (responsePrefix+".") : "";
 570                         ctx.setAttribute(responsePrefix + AppcDataServiceConstant.OUTPUT_PARAM_STATUS,  AppcDataServiceConstant.OUTPUT_STATUS_SUCCESS);
 571                         log.info("getDownloadConfigTemplateByVnf Successful " + ctx.getAttribute(responsePrefix + AppcDataServiceConstant.OUTPUT_PARAM_STATUS));
 572                 } catch (Exception e) {
 573                         ctx.setAttribute(responsePrefix + AppcDataServiceConstant.OUTPUT_PARAM_STATUS,
 574                                         AppcDataServiceConstant.OUTPUT_STATUS_FAILURE);
 575                         ctx.setAttribute(responsePrefix + AppcDataServiceConstant.OUTPUT_PARAM_ERROR_MESSAGE, e.getMessage());
 576                         log.error("Failed in getDownloadConfigTemplateByVnf " + e.getMessage());
 577
 578                         throw new SvcLogicException(e.getMessage());
 579                 }
 580         }
 581
 582
 583         public void saveConfigTransactionLog(Map<String, String> inParams, SvcLogicContext ctx) throws SvcLogicException {
 584
 585
 586
 587                 String responsePrefix = inParams.get(AppcDataServiceConstant.INPUT_PARAM_RESPONSE_PREFIX);
 588
 589                 String messageType = inParams.get(AppcDataServiceConstant.INPUT_PARAM_MESSAGE_TYPE);
 590                 String message = inParams.get(AppcDataServiceConstant.INPUT_PARAM_MESSAGE);
 591
 592                 try {
 593
 594                         SvcLogicContext logctx = new SvcLogicContext();
 595
 596                         String escapedMessage = EscapeUtils.escapeSql(message);
 597
 598
 599                         logctx.setAttribute("request-id", ctx.getAttribute("request-id"));
 600                         logctx.setAttribute("log-message-type", messageType);
 601                         logctx.setAttribute("log-message", escapedMessage);
 602
 603
 604                         responsePrefix = StringUtils.isNotBlank(responsePrefix) ? (responsePrefix+".") : "";
 605                         DGGeneralDBService db = DGGeneralDBService.initialise();
 606                         QueryStatus status = db.saveConfigTransactionLog( logctx, responsePrefix);
 607
 608                         logctx.setAttribute("log-message", null);
 609
 610                         if (status == QueryStatus.FAILURE)
 611                                 throw new Exception("Unable to insert into config_transaction_log");
 612
 613
 614                 } catch (Exception e) {
 615                         ctx.setAttribute(responsePrefix + AppcDataServiceConstant.OUTPUT_PARAM_STATUS,
 616                                         AppcDataServiceConstant.OUTPUT_STATUS_FAILURE);
 617                         ctx.setAttribute(responsePrefix + AppcDataServiceConstant.OUTPUT_PARAM_ERROR_MESSAGE, e.getMessage());
 618
 619
 620                         throw new SvcLogicException(e.getMessage());
 621                 }
 622         }
 623
 624
 625
 626         public void getVnfcReference(Map<String, String> inParams, SvcLogicContext ctx) throws SvcLogicException {
 627
 628                 log.info("Received getVnfcReference call with params : " + inParams);
 629
 630                 String responsePrefix = inParams.get(AppcDataServiceConstant.INPUT_PARAM_RESPONSE_PREFIX);
 631
 632
 633                 QueryStatus status = null;
 634
 635                 try {
 636
 637
 638                         DGGeneralDBService db = DGGeneralDBService.initialise();
 639
 640                         if ( !StringUtils.isBlank(ctx.getAttribute("vnfc-type"))) {
 641                                 status = db.getVnfcReferenceByVnfcTypeNAction(ctx, responsePrefix);
 642
 643                                 if ( status == QueryStatus.FAILURE)
 644                                         throw new Exception("Unable to Read vnfc-reference");
 645                         }
 646                         //else if (status == QueryStatus.NOT_FOUND ) {
 647                         status = db.getVnfcReferenceByVnfTypeNAction(ctx, responsePrefix);
 648
 649                         if (status == QueryStatus.NOT_FOUND || status == QueryStatus.FAILURE)
 650                                 throw new Exception("Unable to Read vnfc reference");
 651
 652                         //}
 653
 654                         responsePrefix = StringUtils.isNotBlank(responsePrefix) ? (responsePrefix+".") : "";
 655                         ctx.setAttribute(responsePrefix + AppcDataServiceConstant.OUTPUT_PARAM_STATUS,
 656                                         AppcDataServiceConstant.OUTPUT_STATUS_SUCCESS);
 657                         log.info("getVnfcReference Successful ");
 658                 } catch (Exception e) {
 659                         ctx.setAttribute(responsePrefix + AppcDataServiceConstant.OUTPUT_PARAM_STATUS,
 660                                         AppcDataServiceConstant.OUTPUT_STATUS_FAILURE);
 661                         ctx.setAttribute(responsePrefix + AppcDataServiceConstant.OUTPUT_PARAM_ERROR_MESSAGE, e.getMessage());
 662                         log.error("Failed in getVnfcReference " + e.getMessage());
 663
 664                         throw new SvcLogicException(e.getMessage());
 665                 }
 666         }
 667
 668         public void getCapability(Map<String, String> inParams, SvcLogicContext ctx) throws SvcLogicException {
 669                 log.info("Received getCapability call with params : " + inParams);
 670                 String responsePrefix = inParams.get(AppcDataServiceConstant.INPUT_PARAM_RESPONSE_PREFIX);
 671                 responsePrefix = StringUtils.isNotBlank(responsePrefix) ? (responsePrefix+".") : "";
 672                 String caplevel = inParams.get("caplevel");
 673                 String findCapability = inParams.get("checkCapability");
 674
 675                 try {
 676                         DGGeneralDBService db = DGGeneralDBService.initialise();
 677                         String cap = db.getCapability(ctx, inParams.get("vnf-type"));
 678                         ObjectMapper mapper = new ObjectMapper();
 679                         JsonNode caps = mapper.readTree(cap);
 680                         log.info("From DB =   " + caps);
 681                         JsonNode capabilities = caps.get("capabilities");
 682                         log.info("capabilities =   " + capabilities);
 683                         if(caplevel !=null && !caplevel.isEmpty()){
 684                                 JsonNode subCapabilities = capabilities.get(caplevel);
 685                                 log.info("subCapabilities =  " +  caplevel + " : " + subCapabilities);
 686                                 if(findCapability !=null && !findCapability.isEmpty()){
 687                                         if(subCapabilities != null && subCapabilities.toString().contains(findCapability))
 688                                                 ctx.setAttribute(responsePrefix + "capabilities." + caplevel + "." +  findCapability,
 689                                                                 "Supported");
 690                                         else
 691                                                 ctx.setAttribute(responsePrefix + "capabilities." + caplevel + "." +  findCapability,
 692                                                                 "Not-Supported");
 693                                 }
 694                                 else
 695                                 {
 696                                         ctx.setAttribute(responsePrefix + "capabilities." + caplevel,
 697                                                         subCapabilities.toString());
 698                                 }
 699
 700                         }
 701                         else
 702                                 ctx.setAttribute(responsePrefix + "capabilities",
 703                                                 capabilities.toString());
 704                         ctx.setAttribute(responsePrefix + AppcDataServiceConstant.OUTPUT_PARAM_STATUS,
 705                                         AppcDataServiceConstant.OUTPUT_STATUS_SUCCESS);
 706                         log.info("getCapability Successful ");
 707                 } catch (Exception e) {
 708                         ctx.setAttribute(responsePrefix + AppcDataServiceConstant.OUTPUT_PARAM_STATUS,
 709                                         AppcDataServiceConstant.OUTPUT_STATUS_FAILURE);
 710                         ctx.setAttribute(responsePrefix + AppcDataServiceConstant.OUTPUT_PARAM_ERROR_MESSAGE, e.getMessage());
 711                         log.error("Failed in getCapability " + e.getMessage());
 712
 713                         throw new SvcLogicException(e.getMessage());
 714                 }
 715         }
 716
 717
 718         /*public void getUploadConfigInfo(Map<String, String> inParams, SvcLogicContext ctx) throws SvcLogicException {
 719
 720                 log.info("Received getUploadConfigInfo call with params : " + inParams);
 721
 722                 String responsePrefix = inParams.get(AppcDataServiceConstant.INPUT_PARAM_RESPONSE_PREFIX);
 723
 724                 String uploadConfigId = inParams.get(AppcDataServiceConstant.INPUT_PARAM_UPLOAD_CONFIG_ID);
 725                 QueryStatus status = null;
 726
 727                 int id = 0;
 728                 try {
 729
 730
 731                         DGGeneralDBService db = DGGeneralDBService.initialise();
 732
 733                         if ( uploadConfigId != null )
 734                                 id = Integer.parseInt(uploadConfigId);
 735
 736                         status = db.getUploadConfigInfo(ctx, responsePrefix,id);
 737
 738                         if ( status == QueryStatus.FAILURE || status == QueryStatus.NOT_FOUND)
 739                                 throw new Exception("Unable to Read upload-config");
 740
 741
 742                         responsePrefix = StringUtils.isNotBlank(responsePrefix) ? (responsePrefix+".") : "";
 743                         ctx.setAttribute(responsePrefix + AppcDataServiceConstant.OUTPUT_PARAM_STATUS,
 744                                         AppcDataServiceConstant.OUTPUT_STATUS_SUCCESS);
 745                         log.info("getUploadConfigInfo Successful ");
 746                 } catch (Exception e) {
 747                         ctx.setAttribute(responsePrefix + AppcDataServiceConstant.OUTPUT_PARAM_STATUS,
 748                                         AppcDataServiceConstant.OUTPUT_STATUS_FAILURE);
 749                         ctx.setAttribute(responsePrefix + AppcDataServiceConstant.OUTPUT_PARAM_ERROR_MESSAGE, e.getMessage());
 750                         log.error("Failed in getUploadConfigInfo " + e.getMessage());
 751
 752                         throw new SvcLogicException(e.getMessage());
 753                 }
 754         }
 755          */
 756
 757 }