mso-api-handlers/mso-api-handler-infra/src/main/java/org/openecomp/mso/apihandlerinfra/MsoRequest.java

   1 /*-
   2  * ============LICENSE_START=======================================================
   3  * OPENECOMP - MSO
   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.mso.apihandlerinfra;
  22
  23 import java.io.StringReader;
  24 import java.io.StringWriter;
  25 import java.sql.Timestamp;
  26 import java.text.SimpleDateFormat;
  27 import java.util.ArrayList;
  28 import java.util.Calendar;
  29 import java.util.Date;
  30 import java.util.HashMap;
  31 import java.util.List;
  32 import java.util.Map;
  33 import java.util.Map.Entry;
  34 import java.util.StringTokenizer;
  35
  36 import javax.ws.rs.core.MultivaluedMap;
  37 import javax.ws.rs.core.Response;
  38 import javax.xml.bind.JAXBContext;
  39 import javax.xml.bind.JAXBElement;
  40 import javax.xml.bind.JAXBException;
  41 import javax.xml.bind.Marshaller;
  42 import javax.xml.bind.Unmarshaller;
  43 import javax.xml.transform.OutputKeys;
  44 import javax.xml.transform.Transformer;
  45 import javax.xml.transform.TransformerFactory;
  46 import javax.xml.transform.dom.DOMSource;
  47 import javax.xml.transform.sax.SAXSource;
  48 import javax.xml.transform.stream.StreamResult;
  49
  50 import org.codehaus.jackson.map.ObjectMapper;
  51 import org.codehaus.jackson.map.SerializationConfig.Feature;
  52 import org.codehaus.jackson.map.annotate.JsonSerialize;
  53 import org.hibernate.Session;
  54 import org.jboss.resteasy.specimpl.MultivaluedMapImpl;
  55 import org.w3c.dom.Document;
  56 import org.w3c.dom.Element;
  57 import org.w3c.dom.Node;
  58 import org.w3c.dom.NodeList;
  59 import org.xml.sax.InputSource;
  60
  61 import org.openecomp.mso.apihandler.common.ErrorNumbers;
  62 import org.openecomp.mso.apihandler.common.ValidationException;
  63 import org.openecomp.mso.apihandlerinfra.serviceinstancebeans.CloudConfiguration;
  64 import org.openecomp.mso.apihandlerinfra.serviceinstancebeans.ModelInfo;
  65 import org.openecomp.mso.apihandlerinfra.serviceinstancebeans.PolicyException;
  66 import org.openecomp.mso.apihandlerinfra.serviceinstancebeans.RelatedInstance;
  67 import org.openecomp.mso.apihandlerinfra.serviceinstancebeans.RelatedInstanceList;
  68 import org.openecomp.mso.apihandlerinfra.serviceinstancebeans.RequestError;
  69 import org.openecomp.mso.apihandlerinfra.serviceinstancebeans.ServiceException;
  70 import org.openecomp.mso.apihandlerinfra.serviceinstancebeans.ServiceInstancesRequest;
  71 import org.openecomp.mso.apihandlerinfra.vnfbeans.ActionType;
  72 import org.openecomp.mso.apihandlerinfra.vnfbeans.ObjectFactory;
  73 import org.openecomp.mso.apihandlerinfra.serviceinstancebeans.RequestInfo;
  74 import org.openecomp.mso.apihandlerinfra.vnfbeans.RequestStatusType;
  75 import org.openecomp.mso.apihandlerinfra.vnfbeans.VnfInputs;
  76 import org.openecomp.mso.apihandlerinfra.vnfbeans.VnfRequest;
  77 import org.openecomp.mso.logger.MsoLogger;
  78 import org.openecomp.mso.logger.MessageEnum;
  79 import org.openecomp.mso.properties.MsoJavaProperties;
  80 import org.openecomp.mso.requestsdb.HibernateUtil;
  81 import org.openecomp.mso.requestsdb.InfraActiveRequests;
  82 import org.openecomp.mso.requestsdb.RequestsDatabase;
  83 import org.openecomp.mso.utils.UUIDChecker;
  84
  85 public class MsoRequest {
  86
  87     private String requestId;
  88     private String requestXML;
  89     private String requestJSON;
  90     private String requestUri;
  91     private VnfRequest vnfReq;
  92     private RequestInfo requestInfo;
  93     private ModelInfo modelInfo;
  94     private CloudConfiguration cloudConfiguration ;
  95     private VnfInputs vnfInputs;
  96     private String vnfParams;
  97     private Action action;
  98     private String errorMessage;
  99     private String errorCode;
 100     private String httpResponse;
 101     private String responseBody;
 102     private RequestStatusType status;
 103     private ServiceInstancesRequest sir;
 104     private long startTime;
 105     private long progress = Constants.PROGRESS_REQUEST_RECEIVED;
 106     private String serviceInstanceType;
 107     private String vnfType;
 108     private String vfModuleType;
 109     private String vfModuleModelName;
 110     private String networkType;
 111     private String asdcServiceModelVersion;
 112     private String requestScope;
 113
 114     private static MsoLogger msoLogger = MsoLogger.getMsoLogger (MsoLogger.Catalog.APIH);
 115     private static final String NOT_PROVIDED = "not provided";
 116
 117     MsoRequest (String requestId) {
 118         this.requestId = requestId;
 119         Calendar startTimeCalendar = Calendar.getInstance ();
 120         this.startTime = startTimeCalendar.getTimeInMillis ();
 121         MsoLogger.setLogContext (requestId, null);
 122
 123     }
 124
 125     MsoRequest () {
 126
 127         Calendar startTimeCalendar = Calendar.getInstance ();
 128         this.startTime = startTimeCalendar.getTimeInMillis ();
 129         MsoLogger.setLogContext (requestId, null);
 130
 131     }
 132
 133
 134     public Response buildServiceErrorResponse (int httpResponseCode,
 135             MsoException exceptionType,
 136             String text,
 137             String messageId,
 138             List<String> variables) {
 139
 140         this.errorCode = messageId;
 141
 142         if (text != null) {
 143                 this.errorMessage = text;
 144         }
 145         else {
 146                 this.errorMessage = "";
 147         }
 148         this.httpResponse = Integer.toString(httpResponseCode);
 149         if(errorMessage.length() > 1999){
 150             errorMessage = errorMessage.substring(0, 1999);
 151         }
 152
 153         RequestError re = new RequestError();
 154
 155         if(exceptionType.name().equals("PolicyException")){
 156
 157                 PolicyException pe = new PolicyException();
 158                 pe.setMessageId(messageId);
 159                 pe.setText(text);
 160                 if(variables != null){
 161                         for(String variable: variables){
 162                                 pe.getVariables().add(variable);
 163                         }
 164                 }
 165                 re.setPolicyException(pe);
 166
 167         } else {
 168
 169                 ServiceException se = new ServiceException();
 170                 se.setMessageId(messageId);
 171                 se.setText(text);
 172                 if(variables != null){
 173                         if(variables != null){
 174                                 for(String variable: variables){
 175                                         se.getVariables().add(variable);
 176                                 }
 177                         }
 178                 }
 179                 re.setServiceException(se);
 180         }
 181
 182         String requestErrorStr = null;
 183
 184         try{
 185                 ObjectMapper mapper = new ObjectMapper();
 186                 mapper.setSerializationInclusion(JsonSerialize.Inclusion.NON_DEFAULT);
 187                 requestErrorStr = mapper.writeValueAsString(re);
 188         }catch(Exception e){
 189                 msoLogger.error (MessageEnum.APIH_VALIDATION_ERROR, "", "", MsoLogger.ErrorCode.DataError, "Exception in buildServiceErrorResponse writing exceptionType to string ", e);
 190         }
 191
 192
 193         return Response.status (httpResponseCode).entity(requestErrorStr).build ();
 194
 195     }
 196
 197
 198     // Parse request JSON
 199     void parse (ServiceInstancesRequest sir, HashMap<String,String> instanceIdMap, Action action) throws ValidationException {
 200
 201         msoLogger.debug ("Validating the Service Instance request");
 202
 203         this.sir = sir;
 204         this.action = action;
 205
 206         try{
 207                 ObjectMapper mapper = new ObjectMapper();
 208                 //mapper.configure(Feature.WRAP_ROOT_VALUE, true);
 209                 requestJSON = mapper.writeValueAsString(sir.getRequestDetails());
 210
 211         } catch(Exception e){
 212                 throw new ValidationException ("Parse ServiceInstanceRequest to JSON string");
 213         }
 214
 215         if(instanceIdMap != null){
 216                 if(instanceIdMap.get("serviceInstanceId") != null){
 217                         if (!UUIDChecker.isValidUUID (instanceIdMap.get ("serviceInstanceId"))) {
 218                                 throw new ValidationException ("serviceInstanceId");
 219                         }
 220                         this.sir.setServiceInstanceId(instanceIdMap.get("serviceInstanceId"));
 221                 }
 222
 223                 if(instanceIdMap.get("vnfInstanceId") != null){
 224                         if (!UUIDChecker.isValidUUID (instanceIdMap.get ("vnfInstanceId"))) {
 225                                 throw new ValidationException ("vnfInstanceId");
 226                         }
 227                         this.sir.setVnfInstanceId(instanceIdMap.get("vnfInstanceId"));
 228                 }
 229
 230                 if(instanceIdMap.get("vfModuleInstanceId") != null){
 231                         if (!UUIDChecker.isValidUUID (instanceIdMap.get ("vfModuleInstanceId"))) {
 232                                 throw new ValidationException ("vfModuleInstanceId");
 233                         }
 234                         this.sir.setVfModuleInstanceId(instanceIdMap.get("vfModuleInstanceId"));
 235                 }
 236
 237                 if(instanceIdMap.get("volumeGroupInstanceId") != null){
 238                         if (!UUIDChecker.isValidUUID (instanceIdMap.get ("volumeGroupInstanceId"))) {
 239                                 throw new ValidationException ("volumeGroupInstanceId");
 240                         }
 241                         this.sir.setVolumeGroupInstanceId(instanceIdMap.get("volumeGroupInstanceId"));
 242                 }
 243
 244                 if(instanceIdMap.get("networkInstanceId") != null){
 245                         if (!UUIDChecker.isValidUUID (instanceIdMap.get ("networkInstanceId"))) {
 246                                 throw new ValidationException ("networkInstanceId");
 247                         }
 248                         this.sir.setNetworkInstanceId(instanceIdMap.get("networkInstanceId"));
 249                 }
 250         }
 251
 252         this.modelInfo = sir.getRequestDetails().getModelInfo();
 253
 254         if (this.modelInfo == null) {
 255             throw new ValidationException ("model-info");
 256         }
 257
 258         this.requestInfo = sir.getRequestDetails().getRequestInfo();
 259
 260         if (this.requestInfo == null) {
 261             throw new ValidationException ("requestInfo");
 262         }
 263
 264         if (modelInfo.getModelType () == null) {
 265                 throw new ValidationException ("modelType");
 266         }
 267
 268         this.requestScope = modelInfo.getModelType().name();
 269
 270         if (empty (modelInfo.getModelInvariantId ()) && !(requestScope.equalsIgnoreCase (ModelType.network.name ()) &&
 271                         (action == Action.createInstance || action == Action.updateInstance))) {
 272                 throw new ValidationException ("modelInvariantId");
 273         }
 274
 275         if (!empty (modelInfo.getModelInvariantId ()) && !UUIDChecker.isValidUUID (modelInfo.getModelInvariantId ())) {
 276                 throw new ValidationException ("modelInvariantId format");
 277         }
 278
 279         if (empty (modelInfo.getModelName ()) && (action == Action.createInstance || action == Action.updateInstance || (action == Action.deleteInstance &&
 280                         (requestScope.equalsIgnoreCase (ModelType.network.name ()) || requestScope.equalsIgnoreCase (ModelType.vfModule.name ()))))) {
 281                 throw new ValidationException ("modelName");
 282         }
 283
 284         if (empty (modelInfo.getModelVersion ()) && !(requestScope.equalsIgnoreCase (ModelType.network.name ()) &&
 285                         (action == Action.createInstance || action == Action.updateInstance))) {
 286                 throw new ValidationException ("modelVersion");
 287         }
 288
 289         if(requestScope.equalsIgnoreCase(ModelType.vnf.name()) && action != Action.deleteInstance && empty (modelInfo.getModelCustomizationName ())) {
 290                 throw new ValidationException ("modelCustomizationName");
 291         }
 292
 293         this.cloudConfiguration = sir.getRequestDetails ().getCloudConfiguration ();
 294         if (!requestScope.equalsIgnoreCase (ModelType.service.name ()) && cloudConfiguration == null) {
 295                 throw new ValidationException ("cloudConfiguration");
 296         }
 297
 298         if (cloudConfiguration != null) {
 299                 if (empty (cloudConfiguration.getLcpCloudRegionId ())) {
 300                         throw new ValidationException ("lcpCloudRegionId");
 301                 }
 302                 if (empty (cloudConfiguration.getTenantId ())) {
 303                         throw new ValidationException ("tenantId");
 304                 }
 305         }
 306
 307         if (requestScope.equalsIgnoreCase (ModelType.service.name ()) && action == Action.createInstance) {
 308                 if (sir.getRequestDetails ().getRequestParameters () == null) {
 309                         throw new ValidationException ("requestParameters");
 310                 }
 311                 if (empty (sir.getRequestDetails ().getRequestParameters ().getSubscriptionServiceType ())) {
 312                         throw new ValidationException ("subscriptionServiceType");
 313                 }
 314         }
 315
 316         if(requestScope.equalsIgnoreCase(ModelType.service.name())){
 317                 this.serviceInstanceType = modelInfo.getModelName();
 318         }
 319
 320         if(requestScope.equalsIgnoreCase(ModelType.network.name())){
 321                 this.networkType = modelInfo.getModelName();
 322         }
 323
 324         // Verify instanceName existence and format
 325         if (empty (requestInfo.getInstanceName ()) && action == Action.createInstance) {
 326                 throw new ValidationException ("instanceName");
 327         }
 328
 329         if (!empty (requestInfo.getInstanceName ()) && !requestInfo.getInstanceName ().matches (Constants.VALID_INSTANCE_NAME_FORMAT)) {
 330                         throw new ValidationException ("instanceName format");
 331         }
 332
 333         if (empty (requestInfo.getProductFamilyId ()) && ((requestScope.equalsIgnoreCase (ModelType.vnf.name ()) && action == Action.createInstance) ||
 334                         (requestScope.equalsIgnoreCase (ModelType.network.name ()) && (action == Action.createInstance || action == Action.updateInstance)))) {
 335                 throw new ValidationException ("productFamilyId");
 336         }
 337
 338         if (empty (requestInfo.getSource ())) {
 339                 throw new ValidationException ("source");
 340         }
 341
 342
 343         RelatedInstanceList[] instanceList = sir.getRequestDetails().getRelatedInstanceList();
 344
 345         String serviceModelName = null;
 346         String vnfModelName = null;
 347         String asdcServiceModelVersion = null;
 348         String volumeGroupId = null;
 349         boolean isRelatedServiceInstancePresent = false;
 350         boolean isRelatedVnfInstancePresent = false;
 351
 352         if (instanceList != null) {
 353                 for(RelatedInstanceList relatedInstanceList : instanceList){
 354                         RelatedInstance relatedInstance = relatedInstanceList.getRelatedInstance();
 355
 356                         if (!empty (relatedInstance.getInstanceName ()) && !relatedInstance.getInstanceName ().matches (Constants.VALID_INSTANCE_NAME_FORMAT)) {
 357                                 throw new ValidationException ("instanceName format in relatedInstance");
 358                         }
 359
 360                         if (empty (relatedInstance.getInstanceId ())) {
 361                                 throw new ValidationException ("instanceId in relatedInstance");
 362                         }
 363
 364                         if (!UUIDChecker.isValidUUID (relatedInstance.getInstanceId ())) {
 365                                 throw new ValidationException ("instanceId format in relatedInstance");
 366                         }
 367
 368                         if (relatedInstance.getModelInfo () == null) {
 369                                 throw new ValidationException ("modelInfo in relatedInstance");
 370                         }
 371
 372                         if (relatedInstance.getModelInfo ().getModelType () == null) {
 373                                 throw new ValidationException ("modelType in relatedInstance");
 374                         }
 375
 376                         if (action != Action.deleteInstance) {
 377
 378                                 if (empty (relatedInstance.getModelInfo ().getModelInvariantId ()) &&
 379                                                 !(requestScope.equalsIgnoreCase (ModelType.vfModule.name ()) && action == Action.createInstance &&
 380                                                         relatedInstance.getModelInfo ().getModelType ().equals(ModelType.volumeGroup))) {
 381                                         throw new ValidationException ("modelInvariantId in relatedInstance");
 382                                 }
 383
 384                                 if (!empty (relatedInstance.getModelInfo ().getModelInvariantId ()) &&
 385                                                 !UUIDChecker.isValidUUID (relatedInstance.getModelInfo ().getModelInvariantId ())) {
 386                                         throw new ValidationException ("modelInvariantId format in relatedInstance");
 387                                 }
 388
 389                                 if (empty(relatedInstance.getModelInfo ().getModelName ()) &&
 390                                                 !(requestScope.equalsIgnoreCase (ModelType.vfModule.name ()) && action == Action.createInstance &&
 391                                                 relatedInstance.getModelInfo ().getModelType ().equals (ModelType.volumeGroup))) {
 392                                         throw new ValidationException ("modelName in relatedInstance");
 393                                 }
 394
 395                                 if (empty (relatedInstance.getModelInfo ().getModelVersion ())  &&
 396                                                 !(requestScope.equalsIgnoreCase (ModelType.vfModule.name ()) && action == Action.createInstance &&
 397                                                 relatedInstance.getModelInfo ().getModelType ().equals (ModelType.volumeGroup))) {
 398                                         throw new ValidationException ("modelVersion in relatedInstance");
 399                                 }
 400                         }
 401
 402                         if (empty (relatedInstance.getModelInfo ().getModelCustomizationName ()) &&
 403                                         relatedInstance.getModelInfo ().getModelType ().equals (ModelType.vnf)) {
 404                                 throw new ValidationException ("modelCustomizationName in relatedInstance");
 405                         }
 406
 407                         if(relatedInstance.getModelInfo().getModelType().equals(ModelType.service)) {
 408                                 isRelatedServiceInstancePresent = true;
 409                                 if (!relatedInstance.getInstanceId ().equals (this.sir.getServiceInstanceId ())) {
 410                                         throw new ValidationException ("serviceInstanceId matching the serviceInstanceId in request URI");
 411                                 }
 412                                 serviceModelName = relatedInstance.getModelInfo ().getModelName ();
 413                                 asdcServiceModelVersion = relatedInstance.getModelInfo().getModelVersion ();
 414                         }
 415                         else if(relatedInstance.getModelInfo().getModelType().equals(ModelType.vnf)) {
 416                                 isRelatedVnfInstancePresent = true;
 417                                 if (!relatedInstance.getInstanceId ().equals (this.sir.getVnfInstanceId ())) {
 418                                         throw new ValidationException ("vnfInstanceId matching the vnfInstanceId in request URI");
 419                                 }
 420                                 vnfModelName = relatedInstance.getModelInfo().getModelCustomizationName();
 421                         }
 422                         else if(relatedInstance.getModelInfo().getModelType().equals(ModelType.volumeGroup)) {
 423                                 volumeGroupId = relatedInstance.getInstanceId ();
 424                         }
 425                 }
 426
 427
 428                 if(requestScope.equalsIgnoreCase (ModelType.volumeGroup.name ())) {
 429                         if (!isRelatedServiceInstancePresent) {
 430                                 throw new ValidationException ("related service instance for volumeGroup request");
 431                         }
 432                         if (!isRelatedVnfInstancePresent) {
 433                                 throw new ValidationException ("related vnf instance for volumeGroup request");
 434                         }
 435                         this.serviceInstanceType = serviceModelName;
 436                         this.vnfType = serviceModelName + "/" + vnfModelName;
 437                         this.asdcServiceModelVersion = asdcServiceModelVersion;
 438                 }
 439                 else if(requestScope.equalsIgnoreCase(ModelType.vfModule.name ())) {
 440                         if (!isRelatedServiceInstancePresent) {
 441                                 throw new ValidationException ("related service instance for vfModule request");
 442                         }
 443                         if (!isRelatedVnfInstancePresent) {
 444                                 throw new ValidationException ("related vnf instance for vfModule request");
 445                         }
 446                         String vfModuleModelName = modelInfo.getModelName ();
 447                         this.vfModuleModelName = vfModuleModelName;
 448                         this.serviceInstanceType = serviceModelName;
 449                         this.vnfType = serviceModelName + "/" + vnfModelName;
 450                         this.asdcServiceModelVersion = asdcServiceModelVersion;
 451                         this.vfModuleType = vnfType + "::" + vfModuleModelName;
 452                         this.sir.setVolumeGroupInstanceId (volumeGroupId);
 453                 }
 454                 else if (requestScope.equalsIgnoreCase (ModelType.vnf.name ())) {
 455                         if (!isRelatedServiceInstancePresent) {
 456                                 throw new ValidationException ("related service instance for vnf request");
 457                         }
 458                         this.vnfType = serviceModelName + "/" + sir.getRequestDetails().getModelInfo().getModelCustomizationName();
 459                }
 460         }
 461         else if (action != Action.deleteInstance && !requestScope.equalsIgnoreCase(ModelType.service.name ()) &&
 462                         !requestScope.equalsIgnoreCase(ModelType.network.name ())) {
 463                 throw new ValidationException ("related instances");
 464         }
 465
 466     }
 467
 468     public Map<String, List<String>> getOrchestrationFilters (MultivaluedMap<String, String> queryParams) throws ValidationException {
 469
 470         String queryParam = null;
 471         Map<String, List<String>> orchestrationFilterParams = new HashMap<String, List<String>>();
 472
 473
 474         for (Entry<String,List<String>> entry : queryParams.entrySet()) {
 475             queryParam = entry.getKey();
 476
 477             try{
 478                   if(queryParam.equalsIgnoreCase("filter")){
 479
 480                           StringTokenizer st = new StringTokenizer(entry.getValue().get(0), ":");
 481
 482                           int counter=0;
 483                           String mapKey=null;
 484                           List<String> orchestrationList = new ArrayList<String>();
 485                           while (st.hasMoreElements()) {
 486                                   if(counter == 0){
 487                                           mapKey = st.nextElement() + "";
 488                                   } else{
 489                                           orchestrationList.add(st.nextElement() + "");
 490                                   }
 491                                  counter++;
 492                           }
 493                         orchestrationFilterParams.put(mapKey, orchestrationList);
 494                   }
 495
 496             }catch(Exception e){
 497                 //msoLogger.error (MessageEnum.APIH_VALIDATION_ERROR, e);
 498                 throw new ValidationException ("QueryParam ServiceInfo", e);
 499
 500                 }
 501
 502         }
 503
 504
 505         return orchestrationFilterParams;
 506   }
 507
 508     public void createRequestRecord (Status status, Action action) {
 509
 510         Session session = null;
 511         try {
 512
 513             session = HibernateUtil.getSessionFactory ().openSession ();
 514             session.beginTransaction ();
 515
 516             InfraActiveRequests aq = new InfraActiveRequests ();
 517             aq.setRequestId (requestId);
 518
 519             aq.setRequestAction(action.name());
 520             aq.setAction(action.name());
 521
 522             Timestamp startTimeStamp = new Timestamp (Calendar.getInstance ().getTimeInMillis ());
 523
 524             aq.setStartTime (startTimeStamp);
 525
 526             if (requestInfo != null) {
 527
 528                 if(requestInfo.getSource() != null){
 529                         aq.setSource(requestInfo.getSource());
 530                 }
 531                 if(requestInfo.getCallbackUrl() != null){
 532                         aq.setCallBackUrl(requestInfo.getCallbackUrl());
 533                 }
 534                 if(requestInfo.getCorrelator() != null){
 535                         aq.setCorrelator(requestInfo.getCorrelator());
 536                 }
 537
 538             }
 539
 540             if (modelInfo != null) {
 541                 aq.setRequestScope(requestScope);
 542             }
 543
 544             if (cloudConfiguration != null) {
 545                 if(cloudConfiguration.getLcpCloudRegionId() != null) {
 546                         aq.setAicCloudRegion(cloudConfiguration.getLcpCloudRegionId());
 547                 }
 548
 549                 if(cloudConfiguration.getTenantId() != null) {
 550                         aq.setTenantId(cloudConfiguration.getTenantId());
 551                 }
 552
 553             }
 554
 555             if(sir.getServiceInstanceId() != null){
 556                 aq.setServiceInstanceId(sir.getServiceInstanceId());
 557             }
 558
 559             if(sir.getVnfInstanceId() != null){
 560                 aq.setVnfId(sir.getVnfInstanceId());
 561             }
 562
 563
 564             if(requestScope.equalsIgnoreCase(ModelType.service.name())){
 565                 if(requestInfo.getInstanceName() != null){
 566                         aq.setServiceInstanceName(requestInfo.getInstanceName());
 567                 }
 568             }
 569
 570             if(requestScope.equalsIgnoreCase(ModelType.network.name())){
 571                 aq.setNetworkName(requestInfo.getInstanceName());
 572                 aq.setNetworkType(networkType);
 573                 aq.setNetworkId(sir.getNetworkInstanceId());
 574             }
 575
 576             if(requestScope.equalsIgnoreCase(ModelType.volumeGroup.name())){
 577                 aq.setVolumeGroupId(sir.getVolumeGroupInstanceId());
 578                 aq.setVolumeGroupName(requestInfo.getInstanceName());
 579                 aq.setVnfType(vnfType);
 580
 581             }
 582
 583             if(requestScope.equalsIgnoreCase(ModelType.vfModule.name())){
 584                 aq.setVfModuleName(requestInfo.getInstanceName());
 585                 aq.setVfModuleModelName(modelInfo.getModelName());
 586                 aq.setVfModuleId(sir.getVfModuleInstanceId());
 587                 aq.setVolumeGroupId(sir.getVolumeGroupInstanceId());
 588                 aq.setVnfType(vnfType);
 589
 590             }
 591
 592             if(requestScope.equalsIgnoreCase(ModelType.vnf.name())){
 593                 aq.setVnfName(requestInfo.getInstanceName());
 594                 RelatedInstanceList[] instanceList = sir.getRequestDetails().getRelatedInstanceList();
 595
 596                 if (instanceList != null) {
 597
 598                         for(RelatedInstanceList relatedInstanceList : instanceList){
 599
 600                                 RelatedInstance relatedInstance = relatedInstanceList.getRelatedInstance();
 601                                 if(relatedInstance.getModelInfo().getModelType().equals(ModelType.service)){
 602                                         aq.setVnfType(vnfType);
 603                                 }
 604                         }
 605                 }
 606                 //aq.setVnfType(sir.getRequestDetails().getRelatedInstanceList());
 607
 608             }
 609
 610             aq.setRequestBody (this.requestJSON);
 611
 612
 613             aq.setRequestStatus (status.toString ());
 614             aq.setLastModifiedBy (Constants.MODIFIED_BY_APIHANDLER);
 615
 616             if ((status == Status.FAILED) || (status == Status.COMPLETE)) {
 617                 aq.setStatusMessage (this.errorMessage);
 618                 aq.setResponseBody (this.responseBody);
 619                 aq.setProgress(new Long(100));
 620
 621                 Calendar endTime = Calendar.getInstance ();
 622                 Timestamp endTimeStamp = new Timestamp (endTime.getTimeInMillis ());
 623                 aq.setEndTime (endTimeStamp);
 624             }
 625
 626             msoLogger.debug ("About to insert a record");
 627
 628             session.save (aq);
 629             session.getTransaction ().commit ();
 630             session.close ();
 631         } catch (Exception e) {
 632                 msoLogger.error (MessageEnum.APIH_DB_INSERT_EXC, "", "", MsoLogger.ErrorCode.DataError, "Exception when creation record request", e);
 633             if (session != null) {
 634                 session.close ();
 635             }
 636             if (!status.equals (Status.FAILED)) {
 637                 throw e;
 638             }
 639         }
 640     }
 641
 642     public void updateFinalStatus (Status status) {
 643         int result = 0;
 644         try {
 645             result = RequestsDatabase.updateInfraFinalStatus (requestId,
 646                                                               status.toString (),
 647                                                               this.errorMessage,
 648                                                               this.progress,
 649                                                               this.responseBody,
 650                                                               Constants.MODIFIED_BY_APIHANDLER);
 651         } catch (Exception e) {
 652                 msoLogger.error(MessageEnum.APIH_DB_UPDATE_EXC, e.getMessage(), "", "", MsoLogger.ErrorCode.DataError, "Exception when updating record in DB");
 653             msoLogger.debug ("Exception: ", e);
 654         }
 655     }
 656
 657     public Response buildResponse (int httpResponseCode, String errorCode, InfraActiveRequests inProgress) {
 658         return buildResponseWithError (httpResponseCode, errorCode, inProgress, null);
 659     }
 660
 661     public Response buildResponseWithError (int httpResponseCode,
 662                                             String errorCode,
 663                                             InfraActiveRequests inProgress,
 664                                             String errorString) {
 665
 666
 667
 668         // Log the failed request into the MSO Requests database
 669
 670         return Response.status (httpResponseCode).entity (null).build ();
 671
 672     }
 673
 674     public Response buildResponseFailedValidation (int httpResponseCode, String exceptionMessage) {
 675
 676
 677
 678         return Response.status (httpResponseCode).entity (null).build ();
 679     }
 680
 681     public String getRequestUri () {
 682         return requestUri;
 683     }
 684
 685     public void setRequestUri (String requestUri) {
 686         this.requestUri = requestUri;
 687     }
 688
 689     public VnfInputs getVnfInputs () {
 690         return vnfInputs;
 691     }
 692
 693     public RequestInfo getRequestInfo () {
 694         return requestInfo;
 695     }
 696
 697     public String getResponseBody () {
 698         return responseBody;
 699     }
 700
 701     public void setResponseBody (String responseBody) {
 702         this.responseBody = responseBody;
 703     }
 704
 705     public String getHttpResponse () {
 706         return httpResponse;
 707     }
 708
 709     public void setHttpResponse (String httpResponse) {
 710         this.httpResponse = httpResponse;
 711     }
 712
 713     public String getRequestId () {
 714         return requestId;
 715     }
 716
 717     public String getRequestXML () {
 718         return requestXML;
 719     }
 720
 721     public void setRequestXML (String requestXML) {
 722         this.requestXML = requestXML;
 723     }
 724
 725     public RequestStatusType getStatus () {
 726         return status;
 727     }
 728
 729     public String getServiceType () {
 730         if (this.vnfInputs.getServiceType () != null)
 731                 return this.vnfInputs.getServiceType ();
 732         if (this.vnfInputs.getServiceId () != null)
 733                 return this.vnfInputs.getServiceId ();
 734         return null;
 735     }
 736
 737     public void setStatus (RequestStatusType status) {
 738         this.status = status;
 739         switch (status) {
 740         case FAILED:
 741         case COMPLETE:
 742                 this.progress = Constants.PROGRESS_REQUEST_COMPLETED;
 743                 break;
 744         case IN_PROGRESS:
 745                 this.progress = Constants.PROGRESS_REQUEST_IN_PROGRESS;
 746                 break;
 747         }
 748     }
 749
 750     public ModelInfo getModelInfo() {
 751         return modelInfo;
 752     }
 753
 754     public ServiceInstancesRequest getServiceInstancesRequest() {
 755         return sir;
 756     }
 757
 758     public String getServiceInstanceType () {
 759         return serviceInstanceType;
 760     }
 761
 762     public String getNetworkType () {
 763         return networkType;
 764     }
 765
 766     public String getVnfType () {
 767         return vnfType;
 768     }
 769
 770     public String getVfModuleModelName () {
 771         return vfModuleModelName;
 772     }
 773
 774     public String getVfModuleType () {
 775         return vfModuleType;
 776     }
 777
 778     public String getAsdcServiceModelVersion () {
 779         return asdcServiceModelVersion;
 780     }
 781
 782     public static String domToStr (Document doc) {
 783         if (doc == null) {
 784             return null;
 785         }
 786
 787         try {
 788             StringWriter sw = new StringWriter ();
 789             StreamResult sr = new StreamResult (sw);
 790             TransformerFactory tf = TransformerFactory.newInstance ();
 791             Transformer t = tf.newTransformer ();
 792             t.setOutputProperty (OutputKeys.STANDALONE, "yes");
 793             NodeList nl = doc.getDocumentElement ().getChildNodes ();
 794             DOMSource source = null;
 795             for (int x = 0; x < nl.getLength (); x++) {
 796                 Node e = nl.item (x);
 797                 if (e instanceof Element) {
 798                     source = new DOMSource (e);
 799                     break;
 800                 }
 801             }
 802             if (source != null) {
 803                 t.transform (source, sr);
 804
 805                 String s = sw.toString ();
 806                 return s;
 807             }
 808
 809             return null;
 810
 811         } catch (Exception e) {
 812             msoLogger.error (MessageEnum.APIH_DOM2STR_ERROR, "", "", MsoLogger.ErrorCode.DataError, "Exception in domToStr", e);
 813         }
 814         return null;
 815     }
 816
 817     public void addBPMNSpecificInputs(String personaModelId, String personaModelVersion, Boolean isBaseVfModule,
 818                         String vnfPersonaModelId, String vnfPersonaModelVersion) {
 819         vnfInputs.setPersonaModelId(personaModelId);
 820         vnfInputs.setPersonaModelVersion(personaModelVersion);
 821         vnfInputs.setIsBaseVfModule(isBaseVfModule);
 822         vnfInputs.setVnfPersonaModelId(vnfPersonaModelId);
 823         vnfInputs.setVnfPersonaModelVersion(vnfPersonaModelVersion);
 824
 825         this.vnfReq.setVnfInputs(vnfInputs);
 826
 827           StringWriter stringWriter = new StringWriter ();
 828           try {
 829               JAXBContext jaxbContext = JAXBContext.newInstance (VnfRequest.class);
 830               Marshaller jaxbMarshaller = jaxbContext.createMarshaller ();
 831
 832               // output pretty printed
 833               jaxbMarshaller.setProperty (Marshaller.JAXB_FORMATTED_OUTPUT, true);
 834
 835               jaxbMarshaller.marshal (this.vnfReq, stringWriter);
 836
 837           } catch (JAXBException e) {
 838               msoLogger.debug ("Exception: ", e);
 839           }
 840
 841           this.requestXML = stringWriter.toString ();
 842           msoLogger.debug("REQUEST XML to BPEL: " + this.requestXML);
 843
 844
 845     }
 846
 847     private static boolean empty(String s) {
 848           return (s == null || s.trim().isEmpty());
 849     }
 850 }