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){\r
  50                 Status appCStatus = null;\r
  51                 try{\r
  52                         String vnfName = payloadInfo.getOrDefault("vnfName", "");\r
  53                         String aicIdentity = payloadInfo.getOrDefault("vnfName","");\r
  54                         String vnfHostIpAddress = payloadInfo.getOrDefault("vnfHostIpAddress","");\r
  55                         String vmIdList = payloadInfo.getOrDefault("vmIdList", "");\r
  56                         String identityUrl = payloadInfo.getOrDefault("identityUrl", "");\r
  57                         switch(action){\r
  58                                 case ResumeTraffic:\r
  59                                         appCStatus = resumeTrafficAction(msoRequestId, vnfId, vnfName);\r
  60                                         break;\r
  61                             case Start:\r
  62                             case Stop:\r
  63                                 appCStatus = startStopAction(action, msoRequestId, vnfId, aicIdentity);\r
  64                                 break;\r
  65                                 case Unlock:\r
  66                                 case Lock:\r
  67                                         appCStatus = client.vnfCommand(action, msoRequestId, vnfId, Optional.empty());\r
  68                                         break;\r
  69                                 case QuiesceTraffic:\r
  70                                         appCStatus = quiesceTrafficAction(msoRequestId, vnfId, payload, vnfName);\r
  71                                         break;\r
  72                                 case HealthCheck:\r
  73                                         appCStatus = healthCheckAction(msoRequestId, vnfId, vnfName, vnfHostIpAddress);\r
  74                                         break;\r
  75                                 case Snapshot:\r
  76                                         String vmIds = JsonUtils.getJsonValue(vmIdList, "vmIds");\r
  77                                         String vmId = "";\r
  78                                         ObjectMapper mapper = new ObjectMapper();\r
  79                                         List<String> vmIdJsonList = mapper.readValue(vmIds, new TypeReference<List<String>>(){});\r
  80                                         int i = 0;\r
  81                                         while(i < vmIdJsonList.size()){\r
  82                                                 vmId = vmIdJsonList.get(i);\r
  83                                                 appCStatus = snapshotAction(msoRequestId, vnfId, vmId, identityUrl);\r
  84                                                 i++;\r
  85                                         }\r
  86                                         break;\r
  87                                 case ConfigModify:\r
  88                                         appCStatus = payloadAction(action, msoRequestId, vnfId, payload);\r
  89                                         break;\r
  90                                 case UpgradePreCheck:\r
  91                                 case UpgradePostCheck:\r
  92                                 case UpgradeSoftware:\r
  93                                 case UpgradeBackup:\r
  94                                         appCStatus = upgradeAction(action,msoRequestId, vnfId, payload, vnfName);\r
  95                                         break;\r
  96                                 default:\r
  97                                         errorMessage = "Unable to idenify Action request for AppCClient";\r
  98                                         break;\r
  99                         }\r
 100                         if(appCStatus != null){\r
 101                                 errorCode = Integer.toString(appCStatus.getCode());\r
 102                                 errorMessage = appCStatus.getMessage();\r
 103  \r
 104                         }\r
 105                         if(ApplicationControllerSupport.getCategoryOf(appCStatus).equals(StatusCategory.NORMAL)){\r
 106                                 errorCode = "0";\r
 107                         }\r
 108                 }\r
 109                 catch(JsonProcessingException e){\r
 110                         auditLogger.log(Level.ERROR, "Incorrect Payload format for action request" + action.toString(),e, e.getMessage());\r
 111                         errorMessage = e.getMessage();\r
 112                 }\r
 113                 catch(ApplicationControllerOrchestratorException e){\r
 114                         auditLogger.log(Level.ERROR, "Error building Appc request: ", e, e.getMessage());\r
 115                         errorCode = "1002";\r
 116                         errorMessage = e.getMessage();\r
 117                 }\r
 118                 catch (NoSuchMethodError e) {\r
 119                         auditLogger.log(Level.ERROR, "Error building Appc request: ", e, e.getMessage());\r
 120                         errorMessage = e.getMessage();\r
 121                 } \r
 122                 catch(Exception e){\r
 123                         auditLogger.log(Level.ERROR, "Error building Appc request: ", e, e.getMessage());\r
 124                         errorMessage = e.getMessage();\r
 125                 }\r
 126         }\r
 127         \r
 128         private Status payloadAction(Action action, String msoRequestId, String vnfId, Optional<String> payload) throws JsonProcessingException, Exception{\r
 129                 if(!(payload.isPresent())){\r
 130                         throw new IllegalArgumentException("Payload is not present for " + action.toString());\r
 131                 }\r
 132                 return client.vnfCommand(action, msoRequestId, vnfId, payload);\r
 133         }\r
 134         \r
 135         private Status quiesceTrafficAction(String msoRequestId, String vnfId, Optional<String> payload, String vnfName) throws JsonProcessingException, Exception{\r
 136                 if(!(payload.isPresent())){\r
 137                         throw new IllegalArgumentException("Payload is not present for " + Action.QuiesceTraffic.toString());\r
 138                 }\r
 139                 payload = PayloadClient.quiesceTrafficFormat(payload, vnfName);\r
 140                 return client.vnfCommand(Action.QuiesceTraffic, msoRequestId, vnfId, payload);\r
 141         }\r
 142         \r
 143         private Status upgradeAction(Action action, String msoRequestId, String vnfId, Optional<String> payload, String vnfName) throws JsonProcessingException, Exception{\r
 144                 if(!(payload.isPresent())){\r
 145                         throw new IllegalArgumentException("Payload is not present for " + action.toString());\r
 146                 }\r
 147                 payload = PayloadClient.upgradeFormat(payload, vnfName);\r
 148                 return client.vnfCommand(action, msoRequestId, vnfId, payload);\r
 149         }\r
 150         \r
 151         private Status resumeTrafficAction(String msoRequestId, String vnfId, String vnfName)throws JsonProcessingException, Exception{\r
 152                 Optional<String> payload = PayloadClient.resumeTrafficFormat(vnfName);\r
 153                 return client.vnfCommand(Action.ResumeTraffic, msoRequestId, vnfId, payload);\r
 154         }\r
 155         \r
 156         private Status startStopAction(Action action, String msoRequestId, String vnfId, String aicIdentity)throws JsonProcessingException, Exception{\r
 157                 Optional<String> payload = PayloadClient.startStopFormat(aicIdentity);\r
 158                 return client.vnfCommand(action, msoRequestId, vnfId, payload);\r
 159         }\r
 160         \r
 161         private Status healthCheckAction(String msoRequestId, String vnfId, String vnfName, String vnfHostIpAddress)throws JsonProcessingException, Exception{\r
 162                 Optional<String> payload = PayloadClient.healthCheckFormat(vnfName, vnfHostIpAddress);\r
 163                 return client.vnfCommand(Action.HealthCheck, msoRequestId, vnfId, payload);\r
 164         }\r
 165         \r
 166         private Status snapshotAction(String msoRequestId, String vnfId, String vmId, String identityUrl) throws JsonProcessingException, Exception{\r
 167                 Optional<String> payload = PayloadClient.snapshotFormat(vmId, identityUrl);\r
 168                 return client.vnfCommand(Action.Snapshot, msoRequestId, vnfId, payload);\r
 169         }\r
 170         \r
 171         public String getErrorMessage(){\r
 172                 return errorMessage;\r
 173         }\r
 174         \r
 175         public String getErrorCode(){\r
 176                 return errorCode;\r
 177         }\r
 178 }\r