gerrit.onap Code Review - so.git/blob

   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         return orchestrationFilterParams;
 505     }
 506
 507     public void createRequestRecord (Status status, Action action) {
 508
 509         Session session = null;
 510         try {
 511
 512             session = HibernateUtil.getSessionFactory ().openSession ();
 513             session.beginTransaction ();
 514
 515             if (null == sir) {
 516                 sir = new ServiceInstancesRequest ();
 517             }
 518
 519             InfraActiveRequests aq = new InfraActiveRequests ();
 520             aq.setRequestId (requestId);
 521
 522             aq.setRequestAction(action.name());
 523             aq.setAction(action.name());
 524
 525             Timestamp startTimeStamp = new Timestamp (Calendar.getInstance ().getTimeInMillis ());
 526
 527             aq.setStartTime (startTimeStamp);
 528
 529             if (requestInfo != null) {
 530
 531                 if(requestInfo.getSource() != null){
 532                     aq.setSource(requestInfo.getSource());
 533                 }
 534                 if(requestInfo.getCallbackUrl() != null){
 535                     aq.setCallBackUrl(requestInfo.getCallbackUrl());
 536                 }
 537                 if(requestInfo.getCorrelator() != null){
 538                     aq.setCorrelator(requestInfo.getCorrelator());
 539                 }
 540
 541             }
 542
 543             if (modelInfo != null) {
 544                 aq.setRequestScope(requestScope);
 545             }
 546
 547             if (cloudConfiguration != null) {
 548                 if(cloudConfiguration.getLcpCloudRegionId() != null) {
 549                     aq.setAicCloudRegion(cloudConfiguration.getLcpCloudRegionId());
 550                 }
 551
 552                 if(cloudConfiguration.getTenantId() != null) {
 553                     aq.setTenantId(cloudConfiguration.getTenantId());
 554                 }
 555
 556             }
 557
 558             if(sir.getServiceInstanceId() != null){
 559                 aq.setServiceInstanceId(sir.getServiceInstanceId());
 560             }
 561
 562             if(sir.getVnfInstanceId() != null){
 563                 aq.setVnfId(sir.getVnfInstanceId());
 564             }
 565
 566             if (null != requestScope) {
 567                 if (requestScope.equalsIgnoreCase(ModelType.service.name())) {
 568                     if (requestInfo.getInstanceName() != null) {
 569                         aq.setServiceInstanceName(requestInfo.getInstanceName());
 570                     }
 571                 }
 572
 573                 if (requestScope.equalsIgnoreCase(ModelType.network.name())) {
 574                     aq.setNetworkName(requestInfo.getInstanceName());
 575                     aq.setNetworkType(networkType);
 576                     aq.setNetworkId(sir.getNetworkInstanceId());
 577
 578                 }
 579
 580                 if (requestScope.equalsIgnoreCase(ModelType.volumeGroup.name())) {
 581                     aq.setVolumeGroupId(sir.getVolumeGroupInstanceId());
 582                     aq.setVolumeGroupName(requestInfo.getInstanceName());
 583                     aq.setVnfType(vnfType);
 584
 585                 }
 586
 587                 if (requestScope.equalsIgnoreCase(ModelType.vfModule.name())) {
 588                     aq.setVfModuleName(requestInfo.getInstanceName());
 589                     aq.setVfModuleModelName(modelInfo.getModelName());
 590                     aq.setVfModuleId(sir.getVfModuleInstanceId());
 591                     aq.setVolumeGroupId(sir.getVolumeGroupInstanceId());
 592                     aq.setVnfType(vnfType);
 593
 594                 }
 595
 596                 if (requestScope.equalsIgnoreCase(ModelType.vnf.name())) {
 597                     aq.setVnfName(requestInfo.getInstanceName());
 598                     if (null != sir.getRequestDetails()) {
 599                         RelatedInstanceList[] instanceList = sir.getRequestDetails().getRelatedInstanceList();
 600
 601                         if (instanceList != null) {
 602
 603                             for (RelatedInstanceList relatedInstanceList : instanceList) {
 604
 605                                 RelatedInstance relatedInstance = relatedInstanceList.getRelatedInstance();
 606                                 if (relatedInstance.getModelInfo().getModelType().equals(ModelType.service)) {
 607                                     aq.setVnfType(vnfType);
 608                                 }
 609                             }
 610                         }
 611                     }
 612                     //aq.setVnfType(sir.getRequestDetails().getRelatedInstanceList());
 613
 614                 }
 615             }
 616
 617             aq.setRequestBody (this.requestJSON);
 618
 619
 620             aq.setRequestStatus (status.toString ());
 621             aq.setLastModifiedBy (Constants.MODIFIED_BY_APIHANDLER);
 622
 623             if ((status == Status.FAILED) || (status == Status.COMPLETE)) {
 624                 aq.setStatusMessage (this.errorMessage);
 625                 aq.setResponseBody (this.responseBody);
 626                 aq.setProgress(new Long(100));
 627
 628                 Calendar endTime = Calendar.getInstance ();
 629                 Timestamp endTimeStamp = new Timestamp (endTime.getTimeInMillis ());
 630                 aq.setEndTime (endTimeStamp);
 631             }
 632
 633             msoLogger.debug ("About to insert a record");
 634
 635             session.save (aq);
 636             session.getTransaction ().commit ();
 637             session.close ();
 638         } catch (Exception e) {
 639             msoLogger.error (MessageEnum.APIH_DB_INSERT_EXC, "", "", MsoLogger.ErrorCode.DataError, "Exception when creation record request", e);
 640             if (session != null) {
 641                 session.close ();
 642             }
 643             if (!status.equals (Status.FAILED)) {
 644                 throw e;
 645             }
 646         }
 647     }
 648
 649     public void updateFinalStatus (Status status) {
 650         int result = 0;
 651         try {
 652             result = RequestsDatabase.updateInfraFinalStatus (requestId,
 653                                                               status.toString (),
 654                                                               this.errorMessage,
 655                                                               this.progress,
 656                                                               this.responseBody,
 657                                                               Constants.MODIFIED_BY_APIHANDLER);
 658         } catch (Exception e) {
 659             msoLogger.error(MessageEnum.APIH_DB_UPDATE_EXC, e.getMessage(), "", "", MsoLogger.ErrorCode.DataError, "Exception when updating record in DB");
 660             msoLogger.debug ("Exception: ", e);
 661         }
 662     }
 663
 664     public Response buildResponse (int httpResponseCode, String errorCode, InfraActiveRequests inProgress) {
 665         return buildResponseWithError (httpResponseCode, errorCode, inProgress, null);
 666     }
 667
 668     public Response buildResponseWithError (int httpResponseCode,
 669                                             String errorCode,
 670                                             InfraActiveRequests inProgress,
 671                                             String errorString) {
 672
 673
 674
 675         // Log the failed request into the MSO Requests database
 676
 677         return Response.status (httpResponseCode).entity (null).build ();
 678
 679     }
 680
 681     public Response buildResponseFailedValidation (int httpResponseCode, String exceptionMessage) {
 682
 683
 684
 685         return Response.status (httpResponseCode).entity (null).build ();
 686     }
 687
 688     public String getRequestUri () {
 689         return requestUri;
 690     }
 691
 692     public void setRequestUri (String requestUri) {
 693         this.requestUri = requestUri;
 694     }
 695
 696     public VnfInputs getVnfInputs () {
 697         return vnfInputs;
 698     }
 699
 700     public RequestInfo getRequestInfo () {
 701         return requestInfo;
 702     }
 703
 704     public String getResponseBody () {
 705         return responseBody;
 706     }
 707
 708     public void setResponseBody (String responseBody) {
 709         this.responseBody = responseBody;
 710     }
 711
 712     public String getHttpResponse () {
 713         return httpResponse;
 714     }
 715
 716     public void setHttpResponse (String httpResponse) {
 717         this.httpResponse = httpResponse;
 718     }
 719
 720     public String getRequestId () {
 721         return requestId;
 722     }
 723
 724     public String getRequestXML () {
 725         return requestXML;
 726     }
 727
 728     public void setRequestXML (String requestXML) {
 729         this.requestXML = requestXML;
 730     }
 731
 732     public RequestStatusType getStatus () {
 733         return status;
 734     }
 735
 736     public String getServiceType () {
 737         if (this.vnfInputs.getServiceType () != null)
 738             return this.vnfInputs.getServiceType ();
 739         if (this.vnfInputs.getServiceId () != null)
 740             return this.vnfInputs.getServiceId ();
 741         return null;
 742     }
 743
 744     public void setStatus (RequestStatusType status) {
 745         this.status = status;
 746         switch (status) {
 747         case FAILED:
 748         case COMPLETE:
 749             this.progress = Constants.PROGRESS_REQUEST_COMPLETED;
 750             break;
 751         case IN_PROGRESS:
 752             this.progress = Constants.PROGRESS_REQUEST_IN_PROGRESS;
 753             break;
 754         }
 755     }
 756
 757     public ModelInfo getModelInfo() {
 758         return modelInfo;
 759     }
 760
 761     public ServiceInstancesRequest getServiceInstancesRequest() {
 762         return sir;
 763     }
 764
 765     public String getServiceInstanceType () {
 766         return serviceInstanceType;
 767     }
 768
 769     public String getNetworkType () {
 770         return networkType;
 771     }
 772
 773     public String getVnfType () {
 774         return vnfType;
 775     }
 776
 777     public String getVfModuleModelName () {
 778         return vfModuleModelName;
 779     }
 780
 781     public String getVfModuleType () {
 782         return vfModuleType;
 783     }
 784
 785     public String getAsdcServiceModelVersion () {
 786         return asdcServiceModelVersion;
 787     }
 788
 789     public static String domToStr (Document doc) {
 790         if (doc == null) {
 791             return null;
 792         }
 793
 794         try {
 795             StringWriter sw = new StringWriter ();
 796             StreamResult sr = new StreamResult (sw);
 797             TransformerFactory tf = TransformerFactory.newInstance ();
 798             Transformer t = tf.newTransformer ();
 799             t.setOutputProperty (OutputKeys.STANDALONE, "yes");
 800             NodeList nl = doc.getDocumentElement ().getChildNodes ();
 801             DOMSource source = null;
 802             for (int x = 0; x < nl.getLength (); x++) {
 803                 Node e = nl.item (x);
 804                 if (e instanceof Element) {
 805                     source = new DOMSource (e);
 806                     break;
 807                 }
 808             }
 809             if (source != null) {
 810                 t.transform (source, sr);
 811
 812                 String s = sw.toString ();
 813                 return s;
 814             }
 815
 816             return null;
 817
 818         } catch (Exception e) {
 819             msoLogger.error (MessageEnum.APIH_DOM2STR_ERROR, "", "", MsoLogger.ErrorCode.DataError, "Exception in domToStr", e);
 820         }
 821         return null;
 822     }
 823
 824     public void addBPMNSpecificInputs(String personaModelId, String personaModelVersion, Boolean isBaseVfModule,
 825                 String vnfPersonaModelId, String vnfPersonaModelVersion) {
 826         vnfInputs.setPersonaModelId(personaModelId);
 827         vnfInputs.setPersonaModelVersion(personaModelVersion);
 828         vnfInputs.setIsBaseVfModule(isBaseVfModule);
 829         vnfInputs.setVnfPersonaModelId(vnfPersonaModelId);
 830         vnfInputs.setVnfPersonaModelVersion(vnfPersonaModelVersion);
 831
 832         this.vnfReq.setVnfInputs(vnfInputs);
 833
 834           StringWriter stringWriter = new StringWriter ();
 835           try {
 836               JAXBContext jaxbContext = JAXBContext.newInstance (VnfRequest.class);
 837               Marshaller jaxbMarshaller = jaxbContext.createMarshaller ();
 838
 839               // output pretty printed
 840               jaxbMarshaller.setProperty (Marshaller.JAXB_FORMATTED_OUTPUT, true);
 841
 842               jaxbMarshaller.marshal (this.vnfReq, stringWriter);
 843
 844           } catch (JAXBException e) {
 845               msoLogger.debug ("Exception: ", e);
 846           }
 847
 848           this.requestXML = stringWriter.toString ();
 849           msoLogger.debug("REQUEST XML to BPEL: " + this.requestXML);
 850
 851
 852     }
 853
 854     private static boolean empty(String s) {
 855         return (s == null || s.trim().isEmpty());
 856     }
 857 }