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

   1 /*-
   2  * ============LICENSE_START=======================================================
   3  * ONAP - SO
   4  * ================================================================================
   5  * Copyright (C) 2017 AT&T Intellectual Property. All rights reserved.
   6  * Copyright (C) 2017 Huawei Technologies Co., Ltd. All rights reserved.
   7  * ================================================================================
   8  * Licensed under the Apache License, Version 2.0 (the "License");
   9  * you may not use this file except in compliance with the License.
  10  * You may obtain a copy of the License at
  11  *
  12  *      http://www.apache.org/licenses/LICENSE-2.0
  13  *
  14  * Unless required by applicable law or agreed to in writing, software
  15  * distributed under the License is distributed on an "AS IS" BASIS,
  16  * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
  17  * See the License for the specific language governing permissions and
  18  * limitations under the License.
  19  * ============LICENSE_END=========================================================
  20  */
  21 package org.openecomp.mso.apihandlerinfra;
  22
  23 import java.text.SimpleDateFormat;
  24 import java.util.ArrayList;
  25 import java.util.List;
  26 import java.util.Map;
  27
  28 import javax.ws.rs.Consumes;
  29 import javax.ws.rs.GET;
  30 import javax.ws.rs.POST;
  31 import javax.ws.rs.Path;
  32 import javax.ws.rs.PathParam;
  33 import javax.ws.rs.Produces;
  34 import javax.ws.rs.core.Context;
  35 import javax.ws.rs.core.MediaType;
  36 import javax.ws.rs.core.MultivaluedMap;
  37 import javax.ws.rs.core.Response;
  38 import javax.ws.rs.core.UriInfo;
  39
  40 import org.apache.http.HttpStatus;
  41 import org.codehaus.jackson.map.ObjectMapper;
  42 import org.openecomp.mso.apihandler.common.ErrorNumbers;
  43 import org.openecomp.mso.apihandlerinfra.e2eserviceinstancebeans.E2ERequest;
  44 import org.openecomp.mso.apihandlerinfra.e2eserviceinstancebeans.GetE2EServiceInstanceResponse;
  45 import org.openecomp.mso.apihandlerinfra.serviceinstancebeans.GetOrchestrationListResponse;
  46 import org.openecomp.mso.apihandlerinfra.serviceinstancebeans.GetOrchestrationResponse;
  47 import org.openecomp.mso.apihandlerinfra.serviceinstancebeans.InstanceReferences;
  48 import org.openecomp.mso.apihandlerinfra.serviceinstancebeans.Request;
  49 import org.openecomp.mso.apihandlerinfra.serviceinstancebeans.RequestDetails;
  50 import org.openecomp.mso.apihandlerinfra.serviceinstancebeans.RequestList;
  51 import org.openecomp.mso.apihandlerinfra.serviceinstancebeans.RequestStatus;
  52 import org.openecomp.mso.apihandlerinfra.serviceinstancebeans.ServiceInstancesRequest;
  53 import org.openecomp.mso.logger.MessageEnum;
  54 import org.openecomp.mso.logger.MsoAlarmLogger;
  55 import org.openecomp.mso.logger.MsoLogger;
  56 import org.openecomp.mso.requestsdb.InfraActiveRequests;
  57 import org.openecomp.mso.requestsdb.OperationStatus;
  58 import org.openecomp.mso.requestsdb.RequestsDatabase;
  59
  60 import com.wordnik.swagger.annotations.Api;
  61 import com.wordnik.swagger.annotations.ApiOperation;
  62
  63 @Path("/")
  64 @Api(value = "/", description = "API Requests for Orchestration requests")
  65 public class OrchestrationRequests {
  66
  67         public final static String MSO_PROP_APIHANDLER_INFRA = "MSO_PROP_APIHANDLER_INFRA";
  68
  69         private static MsoLogger msoLogger = MsoLogger.getMsoLogger(MsoLogger.Catalog.APIH);
  70
  71         private static MsoAlarmLogger alarmLogger = new MsoAlarmLogger();
  72
  73         private RequestsDatabase requestsDB = RequestsDatabase.getInstance();
  74
  75         /**
  76          *
  77          */
  78         public OrchestrationRequests() {
  79                 // TODO Auto-generated constructor stub
  80         }
  81
  82         @GET
  83         @Path("orchestrationRequests/{version:[vV][2-5]}/{requestId}")
  84         @ApiOperation(value = "Find Orchestrated Requests for a given requestId", response = Response.class)
  85         @Produces(MediaType.APPLICATION_JSON)
  86         public Response getOrchestrationRequest(@PathParam("requestId") String requestId,
  87                         @PathParam("version") String version) {
  88
  89                 GetOrchestrationResponse orchestrationResponse = new GetOrchestrationResponse();
  90
  91                 MsoRequest msoRequest = new MsoRequest(requestId);
  92
  93                 long startTime = System.currentTimeMillis();
  94
  95                 InfraActiveRequests requestDB = null;
  96
  97                 try {
  98                         requestDB = requestsDB.getRequestFromInfraActive(requestId);
  99
 100                 } catch (Exception e) {
 101                         msoLogger.error(MessageEnum.APIH_DB_ACCESS_EXC, MSO_PROP_APIHANDLER_INFRA, "", "",
 102                                         MsoLogger.ErrorCode.AvailabilityError,
 103                                         "Exception while communciate with Request DB - Infra Request Lookup", e);
 104                         msoRequest.setStatus(org.openecomp.mso.apihandlerinfra.vnfbeans.RequestStatusType.FAILED);
 105                         Response response = msoRequest.buildServiceErrorResponse(HttpStatus.SC_NOT_FOUND,
 106                                         MsoException.ServiceException, e.getMessage(), ErrorNumbers.NO_COMMUNICATION_TO_REQUESTS_DB, null);
 107                         alarmLogger.sendAlarm("MsoDatabaseAccessError", MsoAlarmLogger.CRITICAL,
 108                                         Messages.errors.get(ErrorNumbers.NO_COMMUNICATION_TO_REQUESTS_DB));
 109                         msoLogger.recordAuditEvent(startTime, MsoLogger.StatusCode.ERROR, MsoLogger.ResponseCode.DBAccessError,
 110                                         "Exception while communciate with Request DB");
 111                         msoLogger.debug("End of the transaction, the final response is: " + (String) response.getEntity());
 112                         return response;
 113
 114                 }
 115
 116                 if (requestDB == null) {
 117                         Response resp = msoRequest.buildServiceErrorResponse(HttpStatus.SC_NO_CONTENT,
 118                                         MsoException.ServiceException, "Orchestration RequestId " + requestId + " is not found in DB",
 119                                         ErrorNumbers.SVC_DETAILED_SERVICE_ERROR, null);
 120                         msoLogger.error(MessageEnum.APIH_BPEL_COMMUNICATE_ERROR, MSO_PROP_APIHANDLER_INFRA, "", "",
 121                                         MsoLogger.ErrorCode.BusinessProcesssError,
 122                                         "Null response from RequestDB when searching by RequestId");
 123                         msoLogger.recordAuditEvent(startTime, MsoLogger.StatusCode.ERROR, MsoLogger.ResponseCode.DataNotFound,
 124                                         "Null response from RequestDB when searching by RequestId");
 125                         msoLogger.debug("End of the transaction, the final response is: " + (String) resp.getEntity());
 126                         return resp;
 127
 128                 }
 129
 130                 Request request = mapInfraActiveRequestToRequest(requestDB);
 131
 132                 orchestrationResponse.setRequest(request);
 133
 134                 return Response.status(200).entity(orchestrationResponse).build();
 135         }
 136
 137         @GET
 138         @Path("e2eServiceInstances/{version:[vV][3-5]}/{serviceId}/operations/{operationId}")
 139         @ApiOperation(value = "Find e2eServiceInstances Requests for a given serviceId and operationId", response = Response.class)
 140         @Produces(MediaType.APPLICATION_JSON)
 141         public Response getE2EServiceInstances(@PathParam("serviceId") String serviceId,
 142                         @PathParam("version") String version, @PathParam("operationId") String operationId) {
 143
 144                 GetE2EServiceInstanceResponse e2eServiceResponse = new GetE2EServiceInstanceResponse();
 145
 146                 MsoRequest msoRequest = new MsoRequest(serviceId);
 147
 148                 long startTime = System.currentTimeMillis();
 149
 150                 OperationStatus requestDB = null;
 151
 152                 try {
 153                         requestDB = requestsDB.getOperationStatus(serviceId, operationId);
 154
 155                 } catch (Exception e) {
 156                         msoLogger.error(MessageEnum.APIH_DB_ACCESS_EXC, MSO_PROP_APIHANDLER_INFRA, "", "",
 157                                         MsoLogger.ErrorCode.AvailabilityError,
 158                                         "Exception while communciate with Request DB - Infra Request Lookup", e);
 159                         msoRequest.setStatus(org.openecomp.mso.apihandlerinfra.vnfbeans.RequestStatusType.FAILED);
 160                         Response response = msoRequest.buildServiceErrorResponse(HttpStatus.SC_NOT_FOUND,
 161                                         MsoException.ServiceException, e.getMessage(), ErrorNumbers.NO_COMMUNICATION_TO_REQUESTS_DB, null);
 162                         alarmLogger.sendAlarm("MsoDatabaseAccessError", MsoAlarmLogger.CRITICAL,
 163                                         Messages.errors.get(ErrorNumbers.NO_COMMUNICATION_TO_REQUESTS_DB));
 164                         msoLogger.recordAuditEvent(startTime, MsoLogger.StatusCode.ERROR, MsoLogger.ResponseCode.DBAccessError,
 165                                         "Exception while communciate with Request DB");
 166                         msoLogger.debug("End of the transaction, the final response is: " + (String) response.getEntity());
 167                         return response;
 168
 169                 }
 170
 171                 if (requestDB == null) {
 172                         Response resp = msoRequest.buildServiceErrorResponse(HttpStatus.SC_NO_CONTENT,
 173                                         MsoException.ServiceException, "E2E serviceId " + serviceId + " is not found in DB",
 174                                         ErrorNumbers.SVC_DETAILED_SERVICE_ERROR, null);
 175                         msoLogger.error(MessageEnum.APIH_BPEL_COMMUNICATE_ERROR, MSO_PROP_APIHANDLER_INFRA, "", "",
 176                                         MsoLogger.ErrorCode.BusinessProcesssError,
 177                                         "Null response from RequestDB when searching by serviceId");
 178                         msoLogger.recordAuditEvent(startTime, MsoLogger.StatusCode.ERROR, MsoLogger.ResponseCode.DataNotFound,
 179                                         "Null response from RequestDB when searching by serviceId");
 180                         msoLogger.debug("End of the transaction, the final response is: " + (String) resp.getEntity());
 181                         return resp;
 182
 183                 }
 184
 185                 e2eServiceResponse.setE2eRequest(requestDB);
 186
 187                 return Response.status(200).entity(e2eServiceResponse).build();
 188         }
 189
 190         @GET
 191         @Path("orchestrationRequests/{version:[vV][2-5]}")
 192         @ApiOperation(value = "Find Orchestrated Requests for a URI Information", response = Response.class)
 193         @Produces(MediaType.APPLICATION_JSON)
 194         public Response getOrchestrationRequest(@Context UriInfo ui, @PathParam("version") String version) {
 195
 196                 long startTime = System.currentTimeMillis();
 197
 198                 MsoRequest msoRequest = new MsoRequest();
 199
 200                 MultivaluedMap<String, String> queryParams = ui.getQueryParameters();
 201
 202                 List<InfraActiveRequests> activeRequests = null;
 203
 204                 GetOrchestrationListResponse orchestrationList = null;
 205
 206                 try {
 207
 208                         Map<String, List<String>> orchestrationMap = msoRequest.getOrchestrationFilters(queryParams);
 209
 210                         activeRequests = requestsDB.getOrchestrationFiltersFromInfraActive(orchestrationMap);
 211
 212                         orchestrationList = new GetOrchestrationListResponse();
 213
 214                         List<RequestList> requestLists = new ArrayList<RequestList>();
 215
 216                         for (InfraActiveRequests infraActive : activeRequests) {
 217
 218                                 Request request = mapInfraActiveRequestToRequest(infraActive);
 219                                 RequestList requestList = new RequestList();
 220                                 requestList.setRequest(request);
 221
 222                                 requestLists.add(requestList);
 223
 224                         }
 225
 226                         orchestrationList.setRequestList(requestLists);
 227
 228                 } catch (Exception e) {
 229                         msoLogger.debug("Get Orchestration Request with Filters Failed : ", e);
 230                         Response response = msoRequest.buildServiceErrorResponse(HttpStatus.SC_INTERNAL_SERVER_ERROR,
 231                                         MsoException.ServiceException, "Get Orchestration Request with Filters Failed.  " + e.getMessage(),
 232                                         ErrorNumbers.SVC_GENERAL_SERVICE_ERROR, null);
 233                         msoLogger.error(MessageEnum.APIH_GENERAL_EXCEPTION, MSO_PROP_APIHANDLER_INFRA, "", "",
 234                                         MsoLogger.ErrorCode.BusinessProcesssError, "Get Orchestration Request with Filters Failed : " + e);
 235                         msoLogger.recordAuditEvent(startTime, MsoLogger.StatusCode.ERROR, MsoLogger.ResponseCode.DataError,
 236                                         "Get Orchestration Request with Filters Failed");
 237                         msoLogger.debug("End of the transaction, the final response is: " + (String) response.getEntity());
 238                         return response;
 239                 }
 240
 241                 return Response.status(200).entity(orchestrationList).build();
 242         }
 243
 244         @POST
 245         @Path("/{version: [vV][3-5]}/{requestId}/unlock")
 246         @Consumes(MediaType.APPLICATION_JSON)
 247         @Produces(MediaType.APPLICATION_JSON)
 248         @ApiOperation(value = "Unlock Orchestrated Requests for a given requestId", response = Response.class)
 249         public Response unlockOrchestrationRequest(String requestJSON, @PathParam("requestId") String requestId,
 250                         @PathParam("version") String version) {
 251
 252                 MsoRequest msoRequest = new MsoRequest(requestId);
 253
 254                 long startTime = System.currentTimeMillis();
 255                 msoLogger.debug("requestId is: " + requestId);
 256
 257                 InfraActiveRequests requestDB = null;
 258                 Request request = null;
 259
 260                 msoLogger.debug("requestId is: " + requestId);
 261                 ServiceInstancesRequest sir = null;
 262
 263                 try {
 264                         ObjectMapper mapper = new ObjectMapper();
 265                         sir = mapper.readValue(requestJSON, ServiceInstancesRequest.class);
 266
 267                 } catch (Exception e) {
 268                         msoLogger.debug("Mapping of request to JSON object failed : ", e);
 269                         Response response = msoRequest.buildServiceErrorResponse(HttpStatus.SC_BAD_REQUEST,
 270                                         MsoException.ServiceException, "Mapping of request to JSON object failed.  " + e.getMessage(),
 271                                         ErrorNumbers.SVC_BAD_PARAMETER, null);
 272                         if (msoRequest.getRequestId() != null) {
 273                                 msoLogger.debug("Mapping of request to JSON object failed");
 274                         }
 275                         msoLogger.error(MessageEnum.APIH_REQUEST_VALIDATION_ERROR, MSO_PROP_APIHANDLER_INFRA, "", "",
 276                                         MsoLogger.ErrorCode.SchemaError, requestJSON, e);
 277                         msoLogger.recordAuditEvent(startTime, MsoLogger.StatusCode.ERROR, MsoLogger.ResponseCode.SchemaError,
 278                                         "Mapping of request to JSON object failed");
 279                         msoLogger.debug("End of the transaction, the final response is: " + (String) response.getEntity());
 280                         return response;
 281                 }
 282
 283                 try {
 284                         msoRequest.parseOrchestration(sir);
 285                 } catch (Exception e) {
 286                         msoLogger.debug("Validation failed: ", e);
 287                         Response response = msoRequest.buildServiceErrorResponse(HttpStatus.SC_BAD_REQUEST,
 288                                         MsoException.ServiceException, "Error parsing request.  " + e.getMessage(),
 289                                         ErrorNumbers.SVC_BAD_PARAMETER, null);
 290                         if (msoRequest.getRequestId() != null) {
 291                                 msoLogger.debug("Logging failed message to the database");
 292                         }
 293                         msoLogger.error(MessageEnum.APIH_REQUEST_VALIDATION_ERROR, MSO_PROP_APIHANDLER_INFRA, "", "",
 294                                         MsoLogger.ErrorCode.SchemaError, requestJSON, e);
 295                         msoLogger.recordAuditEvent(startTime, MsoLogger.StatusCode.ERROR, MsoLogger.ResponseCode.SchemaError,
 296                                         "Validation of the input request failed");
 297                         msoLogger.debug("End of the transaction, the final response is: " + (String) response.getEntity());
 298                         return response;
 299                 }
 300
 301                 try {
 302                         requestDB = requestsDB.getRequestFromInfraActive(requestId);
 303
 304                         if (requestDB == null) {
 305                                 Response resp = msoRequest.buildServiceErrorResponse(HttpStatus.SC_NOT_FOUND,
 306                                                 MsoException.ServiceException, "Orchestration RequestId " + requestId + " is not found in DB",
 307                                                 ErrorNumbers.SVC_DETAILED_SERVICE_ERROR, null);
 308                                 msoLogger.error(MessageEnum.APIH_DB_ATTRIBUTE_NOT_FOUND, MSO_PROP_APIHANDLER_INFRA, "", "",
 309                                                 MsoLogger.ErrorCode.BusinessProcesssError,
 310                                                 "Null response from RequestDB when searching by RequestId");
 311                                 msoLogger.recordAuditEvent(startTime, MsoLogger.StatusCode.ERROR, MsoLogger.ResponseCode.DataNotFound,
 312                                                 "Null response from RequestDB when searching by RequestId");
 313                                 msoLogger.debug("End of the transaction, the final response is: " + (String) resp.getEntity());
 314                                 return resp;
 315
 316                         } else {
 317                                 request = mapInfraActiveRequestToRequest(requestDB);
 318                                 RequestStatus reqStatus = request.getRequestStatus();
 319                                 Status status = Status.valueOf(reqStatus.getRequestState());
 320                                 if (status == Status.IN_PROGRESS || status == Status.PENDING) {
 321                                         msoRequest.setStatus(org.openecomp.mso.apihandlerinfra.vnfbeans.RequestStatusType.UNLOCKED);
 322                                         reqStatus.setRequestState(Status.UNLOCKED.toString());
 323                                         requestsDB.updateInfraStatus(requestId, Status.UNLOCKED.toString(),
 324                                                         Constants.MODIFIED_BY_APIHANDLER);
 325
 326                                         msoLogger.recordAuditEvent(startTime, MsoLogger.StatusCode.COMPLETE, MsoLogger.ResponseCode.Suc,
 327                                                         "RequestId " + requestId + " has been unlocked");
 328
 329                                 } else {
 330                                         Response resp = msoRequest.buildServiceErrorResponse(HttpStatus.SC_BAD_REQUEST,
 331                                                         MsoException.ServiceException, "Orchestration RequestId " + requestId + " has a status of "
 332                                                                         + status + " and can not be unlocked",
 333                                                         ErrorNumbers.SVC_DETAILED_SERVICE_ERROR, null);
 334                                         msoLogger.error(MessageEnum.APIH_DB_ATTRIBUTE_NOT_FOUND, MSO_PROP_APIHANDLER_INFRA, "", "",
 335                                                         MsoLogger.ErrorCode.DataError, "Orchestration RequestId " + requestId + " has a status of "
 336                                                                         + status + " and can not be unlocked");
 337                                         msoLogger.recordAuditEvent(startTime, MsoLogger.StatusCode.ERROR, MsoLogger.ResponseCode.DataError,
 338                                                         "Orchestration RequestId " + requestId + " has a status of " + status
 339                                                                         + " and can not be unlocked");
 340                                         msoLogger.debug("End of the transaction, the final response is: " + (String) resp.getEntity());
 341                                         return resp;
 342                                 }
 343                         }
 344                 } catch (Exception e) {
 345                         msoLogger.error(MessageEnum.APIH_DB_ACCESS_EXC, MSO_PROP_APIHANDLER_INFRA, "", "",
 346                                         MsoLogger.ErrorCode.AvailabilityError,
 347                                         "Exception while communciate with Request DB - Infra Request Lookup", e);
 348                         msoRequest.setStatus(org.openecomp.mso.apihandlerinfra.vnfbeans.RequestStatusType.FAILED);
 349                         Response response = msoRequest.buildServiceErrorResponse(HttpStatus.SC_NOT_FOUND,
 350                                         MsoException.ServiceException, e.getMessage(), ErrorNumbers.NO_COMMUNICATION_TO_REQUESTS_DB, null);
 351                         alarmLogger.sendAlarm("MsoDatabaseAccessError", MsoAlarmLogger.CRITICAL,
 352                                         Messages.errors.get(ErrorNumbers.NO_COMMUNICATION_TO_REQUESTS_DB));
 353                         msoLogger.recordAuditEvent(startTime, MsoLogger.StatusCode.ERROR, MsoLogger.ResponseCode.DBAccessError,
 354                                         "Exception while communciate with Request DB");
 355                         msoLogger.debug("End of the transaction, the final response is: " + (String) response.getEntity());
 356                         return response;
 357
 358                 }
 359
 360                 return Response.status(HttpStatus.SC_NO_CONTENT).entity("").build();
 361         }
 362
 363         private Request mapInfraActiveRequestToRequest(InfraActiveRequests requestDB) {
 364
 365                 Request request = new Request();
 366
 367                 ObjectMapper mapper = new ObjectMapper();
 368                 // mapper.configure(Feature.WRAP_ROOT_VALUE, true);
 369
 370                 request.setRequestId(requestDB.getRequestId());
 371                 request.setRequestScope(requestDB.getRequestScope());
 372                 request.setRequestType(requestDB.getRequestAction());
 373
 374                 InstanceReferences ir = new InstanceReferences();
 375                 if (requestDB.getNetworkId() != null)
 376                         ir.setNetworkInstanceId(requestDB.getNetworkId());
 377                 if (requestDB.getNetworkName() != null)
 378                         ir.setNetworkInstanceName(requestDB.getNetworkName());
 379                 if (requestDB.getServiceInstanceId() != null)
 380                         ir.setServiceInstanceId(requestDB.getServiceInstanceId());
 381                 if (requestDB.getServiceInstanceName() != null)
 382                         ir.setServiceInstanceName(requestDB.getServiceInstanceName());
 383                 if (requestDB.getVfModuleId() != null)
 384                         ir.setVfModuleInstanceId(requestDB.getVfModuleId());
 385                 if (requestDB.getVfModuleName() != null)
 386                         ir.setVfModuleInstanceName(requestDB.getVfModuleName());
 387                 if (requestDB.getVnfId() != null)
 388                         ir.setVnfInstanceId(requestDB.getVnfId());
 389                 if (requestDB.getVnfName() != null)
 390                         ir.setVnfInstanceName(requestDB.getVnfName());
 391                 if (requestDB.getVolumeGroupId() != null)
 392                         ir.setVolumeGroupInstanceId(requestDB.getVolumeGroupId());
 393                 if (requestDB.getVolumeGroupName() != null)
 394                         ir.setVolumeGroupInstanceName(requestDB.getVolumeGroupName());
 395                 if (requestDB.getRequestorId() != null)
 396                         ir.setRequestorId(requestDB.getRequestorId());
 397
 398                 request.setInstanceReferences(ir);
 399
 400                 String requestBody = requestDB.getRequestBody();
 401
 402                 RequestDetails requestDetails = null;
 403
 404                 try {
 405                         requestDetails = mapper.readValue(requestBody, RequestDetails.class);
 406
 407                 } catch (Exception e) {
 408                         msoLogger.debug("Exception caught mapping requestBody to RequestDetails", e);
 409                 }
 410
 411                 request.setRequestDetails(requestDetails);
 412                 String startTimeStamp = new SimpleDateFormat("EEE, dd MMM yyyy HH:mm:ss").format(requestDB.getStartTime())
 413                                 + " GMT";
 414                 request.setStartTime(startTimeStamp);
 415
 416                 RequestStatus status = new RequestStatus();
 417                 if (requestDB.getStatusMessage() != null) {
 418                         status.setStatusMessage(requestDB.getStatusMessage());
 419                 }
 420
 421                 if (requestDB.getEndTime() != null) {
 422                         String endTimeStamp = new SimpleDateFormat("EEE, dd MMM yyyy HH:mm:ss").format(requestDB.getEndTime())
 423                                         + " GMT";
 424                         status.setFinishTime(endTimeStamp);
 425                 }
 426
 427                 if (requestDB.getRequestStatus() != null) {
 428                         status.setRequestState(requestDB.getRequestStatus());
 429                 }
 430
 431                 if (requestDB.getProgress() != null) {
 432                         status.setPercentProgress(requestDB.getProgress().intValue());
 433                 }
 434
 435                 request.setRequestStatus(status);
 436
 437                 return request;
 438         }
 439
 440         private E2ERequest mapInfraActiveRequestToE2ERequest(InfraActiveRequests requestDB) {
 441
 442                 E2ERequest e2erequest = new E2ERequest();
 443
 444                 e2erequest.setOperationId(requestDB.getRequestId());
 445                 // e2erequest.setRequestScope(requestDB.getRequestScope());
 446                 e2erequest.setOperation(requestDB.getRequestAction());
 447                 e2erequest.setResult(requestDB.getRequestStatus());
 448                 e2erequest.setReason(requestDB.getStatusMessage());
 449                 e2erequest.setUserId(requestDB.getRequestorId());
 450                 e2erequest.setOperationContent(requestDB.getStatusMessage());
 451                 e2erequest.setProgress(requestDB.getProgress());
 452
 453                 String startTimeStamp = new SimpleDateFormat("EEE, dd MMM yyyy HH:mm:ss").format(requestDB.getStartTime())
 454                                 + " GMT";
 455                 e2erequest.setOperateAt(startTimeStamp);
 456
 457                 if (requestDB.getEndTime() != null) {
 458                         String endTimeStamp = new SimpleDateFormat("EEE, dd MMM yyyy HH:mm:ss").format(requestDB.getEndTime())
 459                                         + " GMT";
 460                         e2erequest.setFinishedAt(endTimeStamp);
 461                 }
 462
 463                 return e2erequest;
 464         }
 465 }