ves-agent/src/main/java/org/commscope/tr069adapter/vesagent/controller/PnfRegMappingHandler.java

   1 /*\r
   2  * ============LICENSE_START========================================================================\r
   3  * ONAP : tr-069-adapter\r
   4  * =================================================================================================\r
   5  * Copyright (C) 2020 CommScope Inc Intellectual Property.\r
   6  * =================================================================================================\r
   7  * This tr-069-adapter software file is distributed by CommScope Inc under the Apache License,\r
   8  * Version 2.0 (the "License"); you may not use this file except in compliance with the License. You\r
   9  * may obtain a copy of the License at\r
  10  *\r
  11  * http://www.apache.org/licenses/LICENSE-2.0\r
  12  *\r
  13  * This file is distributed on an "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND,\r
  14  * either express or implied. See the License for the specific language governing permissions and\r
  15  * limitations under the License.\r
  16  * ===============LICENSE_END=======================================================================\r
  17  */\r
  18 \r
  19 package org.commscope.tr069adapter.vesagent.controller;\r
  20 \r
  21 import com.fasterxml.jackson.core.JsonProcessingException;\r
  22 import com.fasterxml.jackson.databind.ObjectMapper;\r
  23 \r
  24 import java.text.SimpleDateFormat;\r
  25 import java.util.Date;\r
  26 \r
  27 import org.commscope.tr069adapter.acs.common.DeviceInform;\r
  28 import org.commscope.tr069adapter.mapper.model.NetConfServerDetails;\r
  29 import org.commscope.tr069adapter.mapper.model.VESNotification;\r
  30 import org.commscope.tr069adapter.mapper.model.VESNotificationResponse;\r
  31 import org.commscope.tr069adapter.vesagent.VesConfiguration;\r
  32 import org.commscope.tr069adapter.vesagent.fault.Parser;\r
  33 import org.commscope.tr069adapter.vesagent.http.HttpRequestSender;\r
  34 import org.commscope.tr069adapter.vesagent.model.CommonEventHeader;\r
  35 import org.commscope.tr069adapter.vesagent.model.Event;\r
  36 import org.commscope.tr069adapter.vesagent.model.EventMessage;\r
  37 import org.commscope.tr069adapter.vesagent.model.PnfRegEventAdditionalFeilds;\r
  38 import org.commscope.tr069adapter.vesagent.model.PnfRegEventFields;\r
  39 import org.commscope.tr069adapter.vesagent.util.EventUtil;\r
  40 import org.slf4j.Logger;\r
  41 import org.slf4j.LoggerFactory;\r
  42 import org.springframework.beans.factory.annotation.Autowired;\r
  43 import org.springframework.stereotype.Component;\r
  44 \r
  45 @Component\r
  46 public class PnfRegMappingHandler {\r
  47   private static final Logger logger = LoggerFactory.getLogger(PnfRegMappingHandler.class);\r
  48   public static final String SSH_USERNAME = "netconf";\r
  49   public static final String SSH_PSSWORD = "netconf";\r
  50 \r
  51   @Autowired\r
  52   VesConfiguration config;\r
  53 \r
  54   @Autowired\r
  55   HttpRequestSender sender;\r
  56 \r
  57   public VESNotificationResponse handlePnfRegNotification(VESNotification vesNoti)\r
  58       throws JsonProcessingException {\r
  59     Event event = convertNotificationToVESEvent(vesNoti.getDevnotification(),\r
  60         vesNoti.getNetconfDetails(), vesNoti.geteNodeBName());\r
  61     if (null != event) {\r
  62       EventMessage evMsg = new EventMessage();\r
  63       evMsg.setEvent(event);\r
  64 \r
  65       ObjectMapper mapper = new ObjectMapper();\r
  66 \r
  67       String requestBody = mapper.writeValueAsString(evMsg);\r
  68       if (requestBody.isEmpty()) {\r
  69         logger.debug("VES Event body is empty");\r
  70       }\r
  71 \r
  72       String url = config.getPnfRegVesUrl();\r
  73       return sender.postRequest(url, requestBody);\r
  74     } else {\r
  75       return new VESNotificationResponse(-1,\r
  76           "unable to prepare ves event due to insufficient data");\r
  77     }\r
  78   }\r
  79 \r
  80   public VESNotificationResponse handlePnfRegNotificationOnRestart(VESNotification vesNoti)\r
  81       throws JsonProcessingException {\r
  82     Event event = convertNotificationToVESEventOnRestart(vesNoti.getNetconfDetails());\r
  83 \r
  84     EventMessage evMsg = new EventMessage();\r
  85     evMsg.setEvent(event);\r
  86 \r
  87     ObjectMapper mapper = new ObjectMapper();\r
  88 \r
  89     String requestBody = mapper.writeValueAsString(evMsg);\r
  90     if (requestBody.isEmpty()) {\r
  91       logger.debug("VES Event body is empty");\r
  92     }\r
  93 \r
  94     String url = config.getPnfRegVesUrl();\r
  95     return sender.postRequest(url, requestBody);\r
  96   }\r
  97 \r
  98   Event convertNotificationToVESEvent(DeviceInform notification,\r
  99       NetConfServerDetails netconfServerDetails, String eNodeBName) {\r
 100     logger.debug("Converting Notification to VES pnfevent started");\r
 101     Parser parser = new Parser();\r
 102 \r
 103 \r
 104     Event regEvent = new Event();\r
 105     CommonEventHeader eventHeader = new CommonEventHeader();\r
 106 \r
 107     eventHeader.setDomain("pnfRegistration");\r
 108     eventHeader.setEventId(\r
 109         "PnfReg" + notification.getDeviceDetails().getDeviceId() + System.currentTimeMillis());\r
 110     eventHeader.setEventName("pnfReg_" + notification.getDeviceDetails().getProductClass() + "-"\r
 111         + config.getVendorName());\r
 112     eventHeader.setEventType(config.getPnfRegEventType());\r
 113     eventHeader.setPriority("High");\r
 114     EventUtil.populateEventHeaderFields(eventHeader, notification, eNodeBName, config);\r
 115     regEvent.setCommonEventHeader(eventHeader);\r
 116 \r
 117     PnfRegEventFields pnfRegistrationFields =\r
 118         parser.parseNotificationParams(notification.getParameters());\r
 119     populatePnfRegFeilds(netconfServerDetails, pnfRegistrationFields);\r
 120     pnfRegistrationFields.setModelNumber(notification.getDeviceDetails().getProductClass());\r
 121 \r
 122     regEvent.setPnfRegistrationFields(pnfRegistrationFields);\r
 123     logger.debug("Converting Notification to VES pnfevent completed");\r
 124     return regEvent;\r
 125   }\r
 126 \r
 127   Event convertNotificationToVESEventOnRestart(NetConfServerDetails netconfServerDetails) {\r
 128     logger.debug("Converting Notification to VES pnfevent started");\r
 129 \r
 130     Event regEvent = new Event();\r
 131     CommonEventHeader eventHeader = new CommonEventHeader();\r
 132 \r
 133     if (null == netconfServerDetails) {\r
 134       logger.error("netconf server details as received as null {}", netconfServerDetails);\r
 135       return null;\r
 136     }\r
 137     eventHeader.setDomain("pnfRegistration");\r
 138     eventHeader\r
 139         .setEventId("PnfReg" + netconfServerDetails.getDeviceId() + System.currentTimeMillis());\r
 140     eventHeader.setEventName(\r
 141         "pnfReg_" + netconfServerDetails.getDeviceId() + "-" + config.getVendorName());\r
 142     eventHeader.setEventType(config.getPnfRegEventType());\r
 143     eventHeader.setLastEpochMicrosec(System.currentTimeMillis());\r
 144 \r
 145     eventHeader.setPriority("High");\r
 146     eventHeader.setSequence(0);\r
 147 \r
 148     if (netconfServerDetails.getEnodeBName() == null) {\r
 149       eventHeader.setReportingEntityName(netconfServerDetails.getDeviceId());\r
 150       eventHeader.setReportingEntityId(netconfServerDetails.getDeviceId());\r
 151       eventHeader.setSourceId(netconfServerDetails.getDeviceId());\r
 152       eventHeader.setSourceName(netconfServerDetails.getDeviceId());\r
 153     } else {\r
 154       eventHeader.setReportingEntityName(netconfServerDetails.getEnodeBName());\r
 155       eventHeader.setSourceName(netconfServerDetails.getEnodeBName());\r
 156 \r
 157       eventHeader.setReportingEntityId(netconfServerDetails.getDeviceId());\r
 158       eventHeader.setSourceId(netconfServerDetails.getDeviceId());\r
 159     }\r
 160 \r
 161     eventHeader.setStartEpochMicrosec(System.currentTimeMillis()*1000);\r
 162     eventHeader.setVersion(config.getEventVersion());\r
 163     eventHeader.setNfNamingCode("");\r
 164     eventHeader.setNfcNamingCode("");\r
 165     eventHeader.setNfVendorName(config.getVendorName());\r
 166     eventHeader.setVesEventListenerVersion(config.getVesVersion());\r
 167     regEvent.setCommonEventHeader(eventHeader);\r
 168     PnfRegEventFields pnfRegistrationFields = new PnfRegEventFields();\r
 169     regEvent.setPnfRegistrationFields(\r
 170         populatePnfRegFeilds(netconfServerDetails, pnfRegistrationFields));\r
 171     logger.debug("Converting Notification to VES pnfevent completed");\r
 172     return regEvent;\r
 173   }\r
 174 \r
 175   private PnfRegEventFields populatePnfRegFeilds(NetConfServerDetails netconfServerDetails,\r
 176       PnfRegEventFields pnfRegistrationFields) {\r
 177 \r
 178     pnfRegistrationFields.setSerialNumber(netconfServerDetails.getDeviceId());\r
 179     pnfRegistrationFields.setPnfRegistrationFieldsVersion(config.getPnfFeildVersion());\r
 180     pnfRegistrationFields.setMacAddress(netconfServerDetails.getDeviceId());\r
 181     pnfRegistrationFields.setVendorName(config.getVendorName());\r
 182     pnfRegistrationFields.setSoftwareVersion(netconfServerDetails.getSwVersion());\r
 183     PnfRegEventAdditionalFeilds additionalFields = new PnfRegEventAdditionalFeilds();\r
 184 \r
 185     pnfRegistrationFields.setOamV4IpAddress(netconfServerDetails.getListenAddress());\r
 186     // TODO: since not supporting 1pv6 we are configuring empty value\r
 187     pnfRegistrationFields.setOamV6IpAddress("");\r
 188 \r
 189     pnfRegistrationFields.setManufactureDate("");\r
 190     pnfRegistrationFields.setUnitType(config.getUnitType());\r
 191     pnfRegistrationFields.setUnitFamily(config.getUnitFamily());\r
 192     pnfRegistrationFields.setLastServiceDate(new SimpleDateFormat("ddMMyyyy").format(new Date()));\r
 193     additionalFields.setOamPort(netconfServerDetails.getListenPort());\r
 194     additionalFields.setProtocol("SSH");\r
 195     additionalFields.setUsername(SSH_USERNAME);\r
 196     additionalFields.setPassword(SSH_PSSWORD);\r
 197     additionalFields.setReconnectOnChangedSchema(Boolean.FALSE.toString());\r
 198     additionalFields.setSleepfactor("1.5");\r
 199     additionalFields.setTcpOnly(Boolean.FALSE.toString());\r
 200     additionalFields.setConnectionTimeout("20000");\r
 201     additionalFields.setMaxConnectionAttempts("100");\r
 202     additionalFields.setBetweenAttemptsTimeout("2000");\r
 203     additionalFields.setKeepaliveDelay("120");\r
 204 \r
 205     pnfRegistrationFields.setAdditionalFields(additionalFields);\r
 206 \r
 207     return pnfRegistrationFields;\r
 208 \r
 209   }\r
 210 \r
 211 }\r