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

   1 /*-
   2  * ============LICENSE_START=======================================================
   3  * ONAP - SO
   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.tenantisolation;
  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 com.fasterxml.jackson.databind.ObjectMapper;
  42 import org.openecomp.mso.apihandler.common.ErrorNumbers;
  43 import org.openecomp.mso.apihandlerinfra.Constants;
  44 import org.openecomp.mso.apihandlerinfra.Messages;
  45 import org.openecomp.mso.apihandlerinfra.MsoException;
  46 import org.openecomp.mso.apihandlerinfra.Status;
  47 import org.openecomp.mso.apihandlerinfra.tenantisolationbeans.CloudOrchestrationRequestList;
  48 import org.openecomp.mso.apihandlerinfra.tenantisolationbeans.CloudOrchestrationResponse;
  49 import org.openecomp.mso.apihandlerinfra.tenantisolationbeans.InstanceReferences;
  50 import org.openecomp.mso.apihandlerinfra.tenantisolationbeans.Request;
  51 import org.openecomp.mso.apihandlerinfra.tenantisolationbeans.RequestDetails;
  52 import org.openecomp.mso.apihandlerinfra.tenantisolationbeans.RequestStatus;
  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.RequestsDatabase;
  58 import org.openecomp.mso.utils.UUIDChecker;
  59
  60 import com.wordnik.swagger.annotations.Api;
  61 import com.wordnik.swagger.annotations.ApiOperation;
  62
  63 @Path("/cloudResourcesRequests")
  64 @Api(value="/cloudResourcesRequests",description="API GET Requests for cloud resources - Tenant Isolation")
  65 public class CloudResourcesOrchestration {
  66
  67         private static MsoLogger msoLogger = MsoLogger.getMsoLogger (MsoLogger.Catalog.APIH);
  68         private static MsoAlarmLogger alarmLogger = new MsoAlarmLogger ();
  69         private RequestsDatabase requestsDB = null;
  70
  71         @POST
  72         @Path("/{version: [vV][1]}/{requestId}/unlock")
  73         @Consumes(MediaType.APPLICATION_JSON)
  74         @Produces(MediaType.APPLICATION_JSON)
  75         @ApiOperation(value="Unlock CloudOrchestration requests for a specified requestId")
  76         public Response unlockOrchestrationRequest(String requestJSON, @PathParam("requestId") String requestId, @PathParam("version") String version) {
  77                 TenantIsolationRequest msoRequest = new TenantIsolationRequest(requestId);
  78                 InfraActiveRequests requestDB = null;
  79                 Request request = null;
  80                 CloudOrchestrationRequest cor = null;
  81
  82                 long startTime = System.currentTimeMillis ();
  83                 msoLogger.debug ("requestId is: " + requestId);
  84
  85                 try{
  86                         ObjectMapper mapper = new ObjectMapper();
  87                         cor = mapper.readValue(requestJSON, CloudOrchestrationRequest.class);
  88                 } catch(Exception e){
  89                         msoLogger.debug ("Mapping of request to JSON object failed : ", e);
  90                         Response response = msoRequest.buildServiceErrorResponse(HttpStatus.SC_BAD_REQUEST, MsoException.ServiceException,
  91                                                                                                                                         "Mapping of request to JSON object failed.  " + e.getMessage(),
  92                                                                                                                                         ErrorNumbers.SVC_BAD_PARAMETER, null);
  93                         if (msoRequest.getRequestId () != null) {
  94                                 msoLogger.debug ("Mapping of request to JSON object failed");
  95                         }
  96                         msoLogger.error (MessageEnum.APIH_REQUEST_VALIDATION_ERROR, Constants.MSO_PROP_APIHANDLER_INFRA, "", "", MsoLogger.ErrorCode.SchemaError, requestJSON, e);
  97                         msoLogger.recordAuditEvent (startTime, MsoLogger.StatusCode.ERROR, MsoLogger.ResponseCode.SchemaError, "Mapping of request to JSON object failed");
  98                         msoLogger.debug ("End of the transaction, the final response is: " + (String) response.getEntity ());
  99                         return response;
 100                 }
 101
 102                 try{
 103                         msoRequest.parseOrchestration(cor);
 104                 } catch (Exception e) {
 105                         msoLogger.debug ("Validation failed: ", e);
 106                         Response response = msoRequest.buildServiceErrorResponse(HttpStatus.SC_BAD_REQUEST, MsoException.ServiceException,
 107                                                                                                                                         "Error parsing request.  " + e.getMessage(),
 108                                                                                                                                         ErrorNumbers.SVC_BAD_PARAMETER, null);
 109                         if (msoRequest.getRequestId () != null) {
 110                                 msoLogger.debug ("Logging failed message to the database");
 111                         }
 112                         msoLogger.error (MessageEnum.APIH_REQUEST_VALIDATION_ERROR, Constants.MSO_PROP_APIHANDLER_INFRA, "", "", MsoLogger.ErrorCode.SchemaError, requestJSON, e);
 113                         msoLogger.recordAuditEvent (startTime, MsoLogger.StatusCode.ERROR, MsoLogger.ResponseCode.SchemaError, "Validation of the input request failed");
 114                         msoLogger.debug ("End of the transaction, the final response is: " + (String) response.getEntity ());
 115                         return response;
 116                 }
 117
 118                 try {
 119                         requestDB = getRequestsDB().getRequestFromInfraActive(requestId);
 120
 121                         if(requestDB == null) {
 122                                 Response resp = msoRequest.buildServiceErrorResponse (HttpStatus.SC_NOT_FOUND,
 123                                                                                                                                         MsoException.ServiceException,
 124                                                                                                                                         "Orchestration RequestId " + requestId + " is not found in DB",
 125                                                                                                                                         ErrorNumbers.SVC_DETAILED_SERVICE_ERROR,
 126                                                                                                                                         null);
 127                                 msoLogger.error (MessageEnum.APIH_DB_ATTRIBUTE_NOT_FOUND, Constants.MSO_PROP_APIHANDLER_INFRA, "", "", MsoLogger.ErrorCode.BusinessProcesssError, "Null response from RequestDB when searching by RequestId");
 128                                 msoLogger.recordAuditEvent (startTime, MsoLogger.StatusCode.ERROR, MsoLogger.ResponseCode.DataNotFound, "Null response from RequestDB when searching by RequestId");
 129                                 msoLogger.debug ("End of the transaction, the final response is: " + (String) resp.getEntity ());
 130                                 return resp;
 131
 132                         }else{
 133                                 request = mapInfraActiveRequestToRequest(requestDB);
 134                                 RequestStatus reqStatus = request.getRequestStatus();
 135                                 Status status = Status.valueOf(reqStatus.getRequestState());
 136                                 if(status == Status.IN_PROGRESS || status == Status.PENDING || status == Status.PENDING_MANUAL_TASK){
 137                                         msoRequest.setStatus (org.openecomp.mso.apihandlerinfra.vnfbeans.RequestStatusType.UNLOCKED);
 138                                         reqStatus.setRequestState(Status.UNLOCKED.toString ());
 139                                         getRequestsDB().updateInfraStatus (requestId,
 140                                                                                                                 Status.UNLOCKED.toString (),
 141                                                                                                                 Constants.MODIFIED_BY_APIHANDLER);
 142
 143                                         msoLogger.recordAuditEvent (startTime, MsoLogger.StatusCode.COMPLETE, MsoLogger.ResponseCode.Suc, "RequestId " + requestId + " has been unlocked");
 144
 145                                 }else{
 146                                         Response resp = msoRequest.buildServiceErrorResponse (HttpStatus.SC_BAD_REQUEST,
 147                                                                                                                                                         MsoException.ServiceException,
 148                                                                                                                                                         "Orchestration RequestId " + requestId + " has a status of " + status + " and can not be unlocked",
 149                                                                                                                                                         ErrorNumbers.SVC_DETAILED_SERVICE_ERROR,
 150                                                                                                                                                         null);
 151                                         msoLogger.error (MessageEnum.APIH_DB_ATTRIBUTE_NOT_FOUND, Constants.MSO_PROP_APIHANDLER_INFRA, "", "", MsoLogger.ErrorCode.DataError, "Orchestration RequestId " + requestId + " has a status of " + status + " and can not be unlocked");
 152                                         msoLogger.recordAuditEvent (startTime, MsoLogger.StatusCode.ERROR, MsoLogger.ResponseCode.DataError, "Orchestration RequestId " + requestId + " has a status of " + status + " and can not be unlocked");
 153                                         msoLogger.debug ("End of the transaction, the final response is: " + (String) resp.getEntity ());
 154                                         return resp;
 155                                 }
 156                         }
 157                 } catch (Exception e) {
 158                         msoLogger.error (MessageEnum.APIH_DB_ACCESS_EXC, Constants.MSO_PROP_APIHANDLER_INFRA, "", "", MsoLogger.ErrorCode.AvailabilityError, "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,
 162                                                                                                                                                 e.getMessage (),
 163                                                                                                                                                 ErrorNumbers.NO_COMMUNICATION_TO_REQUESTS_DB,
 164                                                                                                                                                 null);
 165                         alarmLogger.sendAlarm ("MsoDatabaseAccessError",
 166                                         MsoAlarmLogger.CRITICAL,
 167                                         Messages.getErrors().get (ErrorNumbers.NO_COMMUNICATION_TO_REQUESTS_DB));
 168                         msoLogger.recordAuditEvent (startTime, MsoLogger.StatusCode.ERROR, MsoLogger.ResponseCode.DBAccessError, "Exception while communciate with Request DB");
 169                         msoLogger.debug ("End of the transaction, the final response is: " + (String) response.getEntity ());
 170                         return response;
 171
 172                 }
 173
 174                 return Response.status (HttpStatus.SC_NO_CONTENT).entity ("").build ();
 175         }
 176
 177         @GET
 178         @Path("/{version:[vV][1]}")
 179         @Consumes(MediaType.APPLICATION_JSON)
 180         @Produces(MediaType.APPLICATION_JSON)
 181         @ApiOperation(value="Get status of an Operational Environment based on filter criteria",response=Response.class)
 182         public Response getOperationEnvironmentStatusFilter(@Context UriInfo ui, @PathParam("version") String version ) {
 183         MsoLogger.setServiceName ("getOperationEnvironmentStatusFilter");
 184         UUIDChecker.generateUUID(msoLogger);
 185         long startTime = System.currentTimeMillis ();
 186
 187         MultivaluedMap<String, String> queryParams = ui.getQueryParameters();
 188         List<String> requestIdKey = queryParams.get("requestId");
 189
 190         if(queryParams.size() == 1 && requestIdKey != null) {
 191                 msoLogger.debug ("Entered requestId GET OperationalEnvironment Request");
 192                         String requestId = requestIdKey.get(0);
 193
 194                         CloudOrchestrationResponse cloudOrchestrationGetResponse = new CloudOrchestrationResponse();
 195                         TenantIsolationRequest tenantIsolationRequest = new TenantIsolationRequest (requestId);
 196                         InfraActiveRequests requestDB = null;
 197
 198                 try {
 199                          requestDB = getRequestsDB().getRequestFromInfraActive(requestId);
 200
 201                     } catch (Exception e) {
 202                         msoLogger.error (MessageEnum.APIH_DB_ACCESS_EXC, Constants.MSO_PROP_APIHANDLER_INFRA, "", "", MsoLogger.ErrorCode.AvailabilityError, "Exception while communciate with Request DB - Infra Request Lookup", e);
 203                         //              TODO Will need to set Status  for  tenantIsolationRequest
 204                         //             tenantIsolationRequest.setStatus (org.openecomp.mso.apihandlerinfra.vnfbeans.RequestStatusType.FAILED);
 205                         Response response = tenantIsolationRequest.buildServiceErrorResponse (HttpStatus.SC_NOT_FOUND,
 206                                                                                                                                   MsoException.ServiceException,
 207                                                                                                                                   e.getMessage (),
 208                                                                                ErrorNumbers.NO_COMMUNICATION_TO_REQUESTS_DB,
 209                                                                                null);
 210                         alarmLogger.sendAlarm ("MsoDatabaseAccessError",
 211                                                MsoAlarmLogger.CRITICAL,
 212                                                Messages.getErrors().get (ErrorNumbers.NO_COMMUNICATION_TO_REQUESTS_DB));
 213                         msoLogger.recordAuditEvent (startTime, MsoLogger.StatusCode.ERROR, MsoLogger.ResponseCode.DBAccessError, "Exception while communciate with Request DB");
 214                         msoLogger.debug ("End of the transaction, the final response is: " + (String) response.getEntity ());
 215                         return response;
 216                     }
 217
 218                 if(requestDB == null) {
 219                     Response resp = tenantIsolationRequest.buildServiceErrorResponse (HttpStatus.SC_NO_CONTENT,
 220                                                                                                                          MsoException.ServiceException,
 221                                                                                                                         "Orchestration RequestId " + requestId + " is not found in DB",
 222                                                                      ErrorNumbers.SVC_DETAILED_SERVICE_ERROR,
 223                                                                      null);
 224                     msoLogger.error (MessageEnum.APIH_BPEL_COMMUNICATE_ERROR, Constants.MSO_PROP_APIHANDLER_INFRA, "", "", MsoLogger.ErrorCode.BusinessProcesssError, "Null response from RequestDB when searching by RequestId");
 225                     msoLogger.recordAuditEvent (startTime, MsoLogger.StatusCode.ERROR, MsoLogger.ResponseCode.DataNotFound, "Null response from RequestDB when searching by RequestId");
 226                     msoLogger.debug ("End of the transaction, the final response is: " + (String) resp.getEntity ());
 227                     return resp;
 228                 }
 229
 230                 Request request = mapInfraActiveRequestToRequest(requestDB);
 231                 cloudOrchestrationGetResponse.setRequest(request);
 232                 return Response.status(200).entity(cloudOrchestrationGetResponse).build();
 233
 234         } else  {
 235                 msoLogger.debug ("Entered GET OperationalEnvironment filter Request");
 236                 TenantIsolationRequest tenantIsolationRequest = new TenantIsolationRequest ();
 237                         List<InfraActiveRequests> activeRequests = null;
 238                         CloudOrchestrationRequestList orchestrationList = null;
 239
 240                         try{
 241                                 Map<String, String> orchestrationMap = tenantIsolationRequest.getOrchestrationFilters(queryParams);
 242                                 activeRequests = getRequestsDB().getCloudOrchestrationFiltersFromInfraActive(orchestrationMap);
 243                                 orchestrationList = new CloudOrchestrationRequestList();
 244                                 List<CloudOrchestrationResponse> requestLists = new ArrayList<CloudOrchestrationResponse>();
 245
 246                                 for(InfraActiveRequests infraActive : activeRequests){
 247
 248                                         Request request = mapInfraActiveRequestToRequest(infraActive);
 249                                         CloudOrchestrationResponse requestList = new CloudOrchestrationResponse();
 250                                         requestList.setRequest(request);
 251                                         requestLists.add(requestList);
 252                                 }
 253                                 orchestrationList.setRequestList(requestLists);
 254
 255                         }catch(Exception e){
 256                            msoLogger.debug ("Get Orchestration Request with Filters Failed : ", e);
 257                            Response response = tenantIsolationRequest.buildServiceErrorResponse(HttpStatus.SC_INTERNAL_SERVER_ERROR, MsoException.ServiceException,
 258                                    "Get CloudOrchestration Request with Filters Failed.  " + e.getMessage(),
 259                                    ErrorNumbers.SVC_GENERAL_SERVICE_ERROR, null);
 260                            msoLogger.error (MessageEnum.APIH_GENERAL_EXCEPTION, Constants.MSO_PROP_APIHANDLER_INFRA, "", "", MsoLogger.ErrorCode.BusinessProcesssError, "Get Orchestration Request with Filters Failed : " + e);
 261                            msoLogger.recordAuditEvent (startTime, MsoLogger.StatusCode.ERROR, MsoLogger.ResponseCode.DataError, "Get CloudOrchestration Request with Filters Failed");
 262                            msoLogger.debug ("End of the transaction, the final response is: " + (String) response.getEntity ());
 263                            return response;
 264                         }
 265                 return Response.status(200).entity(orchestrationList).build();
 266         }
 267         }
 268
 269     private Request mapInfraActiveRequestToRequest(InfraActiveRequests requestDB)  {
 270         Request request = new Request();
 271         request.setRequestId(requestDB.getRequestId());
 272         request.setRequestScope(requestDB.getRequestScope());
 273         request.setRequestType(requestDB.getRequestAction());
 274
 275        InstanceReferences ir = new InstanceReferences();
 276
 277        if(requestDB.getOperationalEnvId() != null)
 278           ir.setOperationalEnvironmentId(requestDB.getOperationalEnvId());
 279        if(requestDB.getOperationalEnvName() != null)
 280           ir.setOperationalEnvName(requestDB.getOperationalEnvName());
 281        if(requestDB.getRequestorId() != null)
 282                         ir.setRequestorId(requestDB.getRequestorId());
 283
 284            request.setInstanceReferences(ir);
 285        String requestBody = requestDB.getRequestBody();
 286        RequestDetails requestDetails = null;
 287
 288        try{
 289            ObjectMapper mapper = new ObjectMapper();
 290            requestDetails = mapper.readValue(requestBody, RequestDetails.class);
 291
 292        }catch(Exception e){
 293         msoLogger.debug("Exception caught mapping requestBody to RequestDetails");
 294        }
 295
 296        request.setRequestDetails(requestDetails);
 297        String startTimeStamp = new SimpleDateFormat("EEE, dd MMM yyyy HH:mm:ss").format(requestDB.getStartTime()) + " GMT";
 298        request.setStartTime(startTimeStamp);
 299
 300        RequestStatus status = new RequestStatus();
 301        if(requestDB.getStatusMessage() != null){
 302            status.setStatusMessage(requestDB.getStatusMessage());
 303        }
 304
 305        if(requestDB.getEndTime() != null){
 306            String endTimeStamp = new SimpleDateFormat("EEE, dd MMM yyyy HH:mm:ss").format(requestDB.getEndTime()) + " GMT";
 307            status.setTimeStamp(endTimeStamp);
 308        }
 309
 310        if(requestDB.getRequestStatus() != null){
 311            status.setRequestState(requestDB.getRequestStatus());
 312        }
 313
 314        if(requestDB.getProgress() != null){
 315            status.setPercentProgress(requestDB.getProgress().toString());
 316        }
 317
 318        request.setRequestStatus(status);
 319
 320        return request;
 321    }
 322
 323         public RequestsDatabase getRequestsDB() {
 324                 if(requestsDB == null) {
 325                         requestsDB = RequestsDatabase.getInstance();
 326                 }
 327                 return requestsDB;
 328         }
 329
 330         public void setRequestsDB(RequestsDatabase requestsDB) {
 331                 this.requestsDB = requestsDB;
 332         }
 333
 334
 335 }