bpmn/MSOCommonBPMN/src/main/java/org/openecomp/mso/client/appc/ApplicationControllerAction.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.client.appc;\r
  22 \r
  23 import java.util.HashMap;\r
  24 import java.util.List;\r
  25 \r
  26 import org.openecomp.mso.client.appc.ApplicationControllerSupport.StatusCategory;\r
  27 import org.openecomp.mso.bpmn.appc.payload.PayloadClient;\r
  28 import org.openecomp.mso.bpmn.core.json.JsonUtils;\r
  29 import org.openecomp.mso.client.appc.ApplicationControllerOrchestrator;\r
  30 import java.util.Optional;\r
  31 import org.onap.appc.client.lcm.model.Action;\r
  32 import org.onap.appc.client.lcm.model.Status;\r
  33 import com.att.eelf.configuration.EELFLogger;\r
  34 import com.att.eelf.configuration.EELFManager;\r
  35 import com.att.eelf.configuration.EELFLogger.Level;\r
  36 import java.lang.NoSuchMethodError;\r
  37 import com.fasterxml.jackson.core.JsonProcessingException;\r
  38 import com.fasterxml.jackson.core.type.TypeReference;\r
  39 import com.fasterxml.jackson.databind.JsonMappingException;\r
  40 import com.fasterxml.jackson.databind.ObjectMapper;\r
  41 \r
  42 \r
  43 public class ApplicationControllerAction {\r
  44         protected ApplicationControllerOrchestrator client = new ApplicationControllerOrchestrator();\r
  45         private String errorCode = "1002";\r
  46         private String errorMessage = "Unable to reach App C Servers";\r
  47         protected final EELFLogger auditLogger = EELFManager.getInstance().getAuditLogger();\r
  48         \r
  49         public void runAppCCommand(Action action, String msoRequestId, String vnfId, Optional<String> payload, HashMap<String, String> payloadInfo, String controllerType){             Status appCStatus = null;\r
  50                 try{\r
  51                         String vnfName = payloadInfo.getOrDefault("vnfName", "");\r
  52                         String aicIdentity = payloadInfo.getOrDefault("vnfName","");\r
  53                         String vnfHostIpAddress = payloadInfo.getOrDefault("vnfHostIpAddress","");\r
  54                         String vmIdList = payloadInfo.getOrDefault("vmIdList", "");\r
  55                         String identityUrl = payloadInfo.getOrDefault("identityUrl", "");\r
  56                         switch(action){\r
  57                                 case ResumeTraffic:\r
  58                                         appCStatus = resumeTrafficAction(msoRequestId, vnfId, vnfName, controllerType);\r
  59                                         break;\r
  60                             case Start:\r
  61                             case Stop:\r
  62                                 appCStatus = startStopAction(action, msoRequestId, vnfId, aicIdentity, controllerType);\r
  63                                 break;\r
  64                                 case Unlock:\r
  65                                 case Lock:\r
  66                                         appCStatus = client.vnfCommand(action, msoRequestId, vnfId, Optional.empty(), controllerType);\r
  67                                         break;\r
  68                                 case QuiesceTraffic:\r
  69                                         appCStatus = quiesceTrafficAction(msoRequestId, vnfId, payload, vnfName, controllerType);\r
  70                                         break;\r
  71                                 case HealthCheck:\r
  72                                         appCStatus = healthCheckAction(msoRequestId, vnfId, vnfName, vnfHostIpAddress, controllerType);\r
  73                                         break;\r
  74                                 case Snapshot:\r
  75                                         String vmIds = JsonUtils.getJsonValue(vmIdList, "vmIds");\r
  76                                         String vmId = "";\r
  77                                         ObjectMapper mapper = new ObjectMapper();\r
  78                                         List<String> vmIdJsonList = mapper.readValue(vmIds, new TypeReference<List<String>>(){});\r
  79                                         int i = 0;\r
  80                                         while(i < vmIdJsonList.size()){\r
  81                                                 vmId = vmIdJsonList.get(i);\r
  82                                                 appCStatus = snapshotAction(msoRequestId, vnfId, vmId, identityUrl, controllerType);\r
  83                                                 i++;\r
  84                                         }\r
  85                                         break;\r
  86                                 case ConfigModify:\r
  87                                         appCStatus = payloadAction(action, msoRequestId, vnfId, payload, controllerType);\r
  88                                         break;\r
  89                                 case UpgradePreCheck:\r
  90                                 case UpgradePostCheck:\r
  91                                 case UpgradeSoftware:\r
  92                                 case UpgradeBackup:\r
  93                                         appCStatus = upgradeAction(action,msoRequestId, vnfId, payload, vnfName, controllerType);\r
  94                                         break;\r
  95                                 default:\r
  96                                         errorMessage = "Unable to idenify Action request for AppCClient";\r
  97                                         break;\r
  98                         }\r
  99                         if(appCStatus != null){\r
 100                                 errorCode = Integer.toString(appCStatus.getCode());\r
 101                                 errorMessage = appCStatus.getMessage();\r
 102  \r
 103                         }\r
 104                         if(ApplicationControllerSupport.getCategoryOf(appCStatus).equals(StatusCategory.NORMAL)){\r
 105                                 errorCode = "0";\r
 106                         }\r
 107                 }\r
 108                 catch(JsonProcessingException e){\r
 109                         auditLogger.log(Level.ERROR, "Incorrect Payload format for action request" + action.toString(),e, e.getMessage());\r
 110                         errorMessage = e.getMessage();\r
 111                 }\r
 112                 catch(ApplicationControllerOrchestratorException e){\r
 113                         auditLogger.log(Level.ERROR, "Error building Appc request: ", e, e.getMessage());\r
 114                         errorCode = "1002";\r
 115                         errorMessage = e.getMessage();\r
 116                 }\r
 117                 catch (NoSuchMethodError e) {\r
 118                         auditLogger.log(Level.ERROR, "Error building Appc request: ", e, e.getMessage());\r
 119                         errorMessage = e.getMessage();\r
 120                 } \r
 121                 catch(Exception e){\r
 122                         auditLogger.log(Level.ERROR, "Error building Appc request: ", e, e.getMessage());\r
 123                         errorMessage = e.getMessage();\r
 124                 }\r
 125         }\r
 126         \r
 127         private Status payloadAction(Action action, String msoRequestId, String vnfId, Optional<String> payload, String controllerType) throws JsonProcessingException, Exception{\r
 128                 if(!(payload.isPresent())){\r
 129                         throw new IllegalArgumentException("Payload is not present for " + action.toString());\r
 130                 }\r
 131                 return client.vnfCommand(action, msoRequestId, vnfId, payload, controllerType);\r
 132         }\r
 133         \r
 134         private Status quiesceTrafficAction(String msoRequestId, String vnfId, Optional<String> payload, String vnfName, String controllerType) throws JsonProcessingException, Exception{\r
 135                 if(!(payload.isPresent())){\r
 136                         throw new IllegalArgumentException("Payload is not present for " + Action.QuiesceTraffic.toString());\r
 137                 }\r
 138                 payload = PayloadClient.quiesceTrafficFormat(payload, vnfName);\r
 139                 return client.vnfCommand(Action.QuiesceTraffic, msoRequestId, vnfId, payload, controllerType);\r
 140         }\r
 141         \r
 142         private Status upgradeAction(Action action, String msoRequestId, String vnfId, Optional<String> payload, String vnfName, String controllerType) throws JsonProcessingException, Exception{\r
 143                 if(!(payload.isPresent())){\r
 144                         throw new IllegalArgumentException("Payload is not present for " + action.toString());\r
 145                 }\r
 146                 payload = PayloadClient.upgradeFormat(payload, vnfName);\r
 147                 return client.vnfCommand(action, msoRequestId, vnfId, payload, controllerType);\r
 148         }\r
 149         \r
 150         private Status resumeTrafficAction(String msoRequestId, String vnfId, String vnfName, String controllerType)throws JsonProcessingException, Exception{\r
 151                 Optional<String> payload = PayloadClient.resumeTrafficFormat(vnfName);\r
 152                 return client.vnfCommand(Action.ResumeTraffic, msoRequestId, vnfId, payload, controllerType);\r
 153         }\r
 154         \r
 155         private Status startStopAction(Action action, String msoRequestId, String vnfId, String aicIdentity, String controllerType)throws JsonProcessingException, Exception{\r
 156                 Optional<String> payload = PayloadClient.startStopFormat(aicIdentity);\r
 157                 return client.vnfCommand(action, msoRequestId, vnfId, payload, controllerType);\r
 158         }\r
 159         \r
 160         private Status healthCheckAction(String msoRequestId, String vnfId, String vnfName, String vnfHostIpAddress, String controllerType)throws JsonProcessingException, Exception{\r
 161                 Optional<String> payload = PayloadClient.healthCheckFormat(vnfName, vnfHostIpAddress);\r
 162                 return client.vnfCommand(Action.HealthCheck, msoRequestId, vnfId, payload, controllerType);\r
 163         }\r
 164         \r
 165         private Status snapshotAction(String msoRequestId, String vnfId, String vmId, String identityUrl, String controllerType) throws JsonProcessingException, Exception{\r
 166                 Optional<String> payload = PayloadClient.snapshotFormat(vmId, identityUrl);\r
 167                 return client.vnfCommand(Action.Snapshot, msoRequestId, vnfId, payload, controllerType);\r
 168         }\r
 169         \r
 170         public String getErrorMessage(){\r
 171                 return errorMessage;\r
 172         }\r
 173         \r
 174         public String getErrorCode(){\r
 175                 return errorCode;\r
 176         }\r
 177 }\r