-/*\r
- * ============LICENSE_START========================================================================\r
- * ONAP : tr-069-adapter\r
- * =================================================================================================\r
- * Copyright (C) 2020 CommScope Inc Intellectual Property.\r
- * =================================================================================================\r
- * This tr-069-adapter software file is distributed by CommScope Inc under the Apache License,\r
- * Version 2.0 (the "License"); you may not use this file except in compliance with the License. You\r
- * may obtain a copy of the License at\r
- *\r
- * http://www.apache.org/licenses/LICENSE-2.0\r
- *\r
- * This file is distributed on an "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND,\r
- * either express or implied. See the License for the specific language governing permissions and\r
- * limitations under the License.\r
- * ===============LICENSE_END=======================================================================\r
- */\r
-\r
-package org.commscope.tr069adapter.mapper.netconf;\r
-\r
-import java.io.StringWriter;\r
-import java.text.SimpleDateFormat;\r
-import java.util.ArrayList;\r
-import java.util.Date;\r
-import java.util.HashMap;\r
-import java.util.List;\r
-import java.util.Map;\r
-import java.util.StringTokenizer;\r
-import javax.xml.parsers.DocumentBuilder;\r
-import javax.xml.parsers.DocumentBuilderFactory;\r
-import javax.xml.parsers.ParserConfigurationException;\r
-import javax.xml.transform.Transformer;\r
-import javax.xml.transform.TransformerFactory;\r
-import javax.xml.transform.dom.DOMSource;\r
-import javax.xml.transform.stream.StreamResult;\r
-import org.commscope.tr069adapter.acs.common.DeviceInform;\r
-import org.commscope.tr069adapter.acs.common.ParameterDTO;\r
-import org.commscope.tr069adapter.mapper.MOMetaData;\r
-import org.commscope.tr069adapter.mapper.MapperConfigProperties;\r
-import org.commscope.tr069adapter.mapper.model.NetConfNotificationDTO;\r
-import org.commscope.tr069adapter.mapper.util.MOMetaDataUtil;\r
-import org.slf4j.Logger;\r
-import org.slf4j.LoggerFactory;\r
-import org.springframework.beans.factory.annotation.Autowired;\r
-import org.springframework.http.ResponseEntity;\r
-import org.springframework.stereotype.Component;\r
-import org.springframework.web.client.RestTemplate;\r
-import org.w3c.dom.Document;\r
-import org.w3c.dom.Element;\r
-\r
-@Component\r
-public class NetConfNotificationSender {\r
-\r
- private static final Logger LOG = LoggerFactory.getLogger(NetConfNotificationSender.class);\r
- private static final String BOOLEAN_TRUE_VALUE = "1";\r
- private static final String BOOLEAN_FALSE_VALUE = "0";\r
- private static final String BOOLEAN_DATA_TYPE = "boolean";\r
- public static final String NOTIFICATION_ELEMENT_NAME = "notification";\r
- public static final String EVENT_TIME = "eventTime";\r
- private static final String INDEX_STR = "index";\r
- private static final String INDEX_REGEX = "[0-9]{1,}";\r
-\r
-\r
- @Autowired\r
- MapperConfigProperties config;\r
-\r
- @Autowired\r
- MOMetaDataUtil metaDataUtil;\r
-\r
- @Autowired\r
- RestTemplate restTemplate;\r
-\r
- public ResponseEntity sendNotification(DeviceInform deviceInform) {\r
- ResponseEntity response = null;\r
- final String uri = getUri();\r
- LOG.debug("Posting notification to netconf server {}", uri);\r
-\r
- try {\r
- LOG.debug("deviceInform : {} {}", deviceInform.getInformTypeList(),\r
- deviceInform.getParameters());\r
- List<ParameterDTO> parameters = new ArrayList<>();\r
- for (ParameterDTO parameterDTO : deviceInform.getParameters()) {\r
- parameters.add(parameterDTO);\r
- }\r
-\r
- convertTR069ToNetConfParams(parameters, deviceInform.getDeviceDetails().getSoftwareVersion(),\r
- deviceInform.getDeviceDetails().getHardwareVersion());\r
-\r
- String nameSpace = metaDataUtil.getMetaDataByTR69Name(deviceInform.getInformType().toString(),\r
- deviceInform.getDeviceDetails().getSoftwareVersion(),\r
- deviceInform.getDeviceDetails().getHardwareVersion()).getURI();\r
-\r
- String notificationXml =\r
- getNetconfResponseXML(parameters, deviceInform.getInformType().toString(), nameSpace);\r
- NetConfNotificationDTO netConfDTO = new NetConfNotificationDTO(\r
- deviceInform.getDeviceDetails().getDeviceId(), notificationXml);\r
-\r
- LOG.debug("Posting notification to netconf server");\r
- response = restTemplate.postForObject(uri, netConfDTO, ResponseEntity.class);\r
- LOG.debug("Posting notification to netconf server completed ");\r
- } catch (Exception e) {\r
- LOG.error("Exception while sending the notification.", e);\r
- }\r
- return response;\r
- }\r
-\r
- public ResponseEntity sendCustomNotification(String deviceId, List<ParameterDTO> parameters,\r
- String nameSpace) {\r
- ResponseEntity response = null;\r
- final String uri = getUri();\r
- LOG.debug("Posting custom notification to netconf server " + uri);\r
- try {\r
- String notificationXml = getNetconfResponseXML(parameters, null, nameSpace);\r
- NetConfNotificationDTO netConfDTO = new NetConfNotificationDTO(deviceId, notificationXml);\r
-\r
- response = restTemplate.postForObject(uri, netConfDTO, ResponseEntity.class);\r
- LOG.debug("Posting custom notification to netconf server sucessfull");\r
- } catch (Exception e) {\r
- LOG.error("Exception while sending the custom notification.", e.toString());\r
- }\r
- return response;\r
- }\r
-\r
- private void convertTR069ToNetConfParams(List<ParameterDTO> parameters, String swVersion,\r
- String hwVersion) {\r
- List<ParameterDTO> removeList = new ArrayList<>();\r
- if (null != parameters) {\r
- for (ParameterDTO param : parameters) {\r
- if (param.getParamValue() == null || param.getParamValue().trim().length() <= 0) {\r
- removeList.add(param);\r
- continue;\r
- }\r
- handleBooleanParameters(param, swVersion, hwVersion);\r
- if (null != param.getParamName()) {\r
- String netConfMOName = metaDataUtil\r
- .getNetconfNameByTR69NameWithIndexes(param.getParamName(), swVersion, hwVersion);\r
- if (null != netConfMOName)\r
- param.setParamName(netConfMOName);\r
- else\r
- removeList.add(param); // unknown parameter found.\r
- }\r
- }\r
- parameters.removeAll(removeList);\r
- }\r
- }\r
-\r
- private void handleBooleanParameters(ParameterDTO param, String swVersion, String hwVersion) {\r
- MOMetaData metaData =\r
- metaDataUtil.getMetaDataByTR69Name(param.getParamName(), swVersion, hwVersion);\r
- if (null != metaData && BOOLEAN_DATA_TYPE.equalsIgnoreCase(metaData.getDataType())) {\r
- if (BOOLEAN_TRUE_VALUE.equalsIgnoreCase(param.getParamValue().trim())) {\r
- param.setParamValue(Boolean.TRUE.toString());\r
- } else if (BOOLEAN_FALSE_VALUE.equalsIgnoreCase(param.getParamValue().trim())) {\r
- param.setParamValue(Boolean.FALSE.toString());\r
- }\r
- }\r
- }\r
-\r
- private String getUri() {\r
- return config.getNbiNotificationUri();\r
- }\r
-\r
- private static String getNetconfResponseXML(List<ParameterDTO> parameters,\r
- String notificationType, String nameSpace) {\r
- if (parameters == null || parameters.isEmpty()) {\r
- LOG.debug("There are no parameters found in the response.");\r
- return null;\r
- }\r
-\r
- String result = null;\r
- try {\r
- DocumentBuilderFactory docFactory = DocumentBuilderFactory.newInstance();\r
- DocumentBuilder docBuilder = docFactory.newDocumentBuilder();\r
- Document doc = docBuilder.newDocument();\r
-\r
- Map<String, Element> parentNodeMap = new HashMap<>();\r
- Element dataNode = null; // root of all nodes\r
-\r
- for (ParameterDTO paramDto : parameters) {\r
- String paramName = paramDto.getParamName();\r
- String paramValue = paramDto.getParamValue();\r
- StringTokenizer tokenizer = new StringTokenizer(paramName, ".");\r
- String parentNodeName = null;\r
- String parentNodeKey = null;\r
- Element parentNode = null;\r
- while (tokenizer.hasMoreElements()) {\r
- String nodeName = (String) tokenizer.nextElement();\r
- if (null == parentNodeName) { // construct first node or\r
- // Device node\r
- parentNodeName = nodeName;\r
- parentNodeKey = nodeName;\r
- // check if the node already exists in parentNodeMap\r
- parentNode = parentNodeMap.get(parentNodeKey);\r
- if (null == dataNode) {\r
- dataNode = parentNode;\r
- }\r
- continue;\r
- } else if (nodeName.matches(INDEX_REGEX)) { // construct\r
- // tabular and\r
- // index nodes\r
-\r
- // get parent tabular node from parent MAP\r
- parentNodeKey = parentNodeKey + "." + nodeName;\r
- Element node = parentNodeMap.get(parentNodeKey);\r
-\r
- // create a tabular parent node if doesn't exit in MAP\r
- if (null == node) {\r
- node = doc.createElement(parentNodeName);\r
- parentNodeMap.put(parentNodeKey, node);\r
-\r
- // update current tabular parent node.\r
- if (null != parentNode)\r
- parentNode.appendChild(node);\r
- else\r
- parentNode = node;\r
-\r
- // prepare and add index node to tabular parent node\r
- Element indexNode = doc.createElement(INDEX_STR);\r
- indexNode.setTextContent(nodeName);\r
- node.appendChild(indexNode);\r
- }\r
- parentNode = node; // move parent to child\r
- parentNodeName = nodeName;\r
- } else if (parentNodeName.matches(INDEX_REGEX)) { // move to\r
- // next\r
- // node\r
- // if\r
- // tabular\r
- // attribute\r
- // is\r
- // found\r
- parentNodeKey = parentNodeKey + "." + nodeName;\r
- parentNodeName = nodeName;\r
- } else {\r
- // construct intermediate nodes\r
- Element node = parentNodeMap.get(parentNodeKey);\r
- if (null == node) {\r
- if (null == dataNode) {\r
- node = doc.createElementNS(nameSpace, parentNodeName);\r
- dataNode = node;\r
- } else {\r
- node = doc.createElement(parentNodeName);\r
- }\r
- parentNodeMap.put(parentNodeKey, node);\r
- if (null != parentNode)\r
- parentNode.appendChild(node);\r
- }\r
- parentNodeKey = parentNodeKey + "." + nodeName;\r
- parentNodeName = nodeName;\r
- parentNode = node;\r
- }\r
- }\r
- // construct leaf node\r
- Element leafNode = doc.createElement(parentNodeName);\r
- leafNode.setTextContent(paramValue);\r
- parentNode.appendChild(leafNode);\r
- }\r
-\r
- if (null != dataNode) {\r
- final Element element = doc.createElement(NOTIFICATION_ELEMENT_NAME);\r
- final Element eventTime = doc.createElement(EVENT_TIME);\r
- eventTime\r
- .setTextContent(new SimpleDateFormat("yyyy-MM-dd'T'HH:mm:ssXXX").format(new Date()));\r
- element.appendChild(element.getOwnerDocument().importNode(eventTime, true));\r
-\r
- if (notificationType != null) {\r
- final Element evtTypeElement = doc.createElementNS(nameSpace, notificationType);\r
- evtTypeElement.appendChild(dataNode);\r
- element.appendChild(element.getOwnerDocument().importNode(evtTypeElement, true));\r
- } else {\r
- element.appendChild(element.getOwnerDocument().importNode(dataNode, true));\r
- }\r
-\r
- result = convertDocumentToString(element);\r
- }\r
- } catch (ParserConfigurationException pce) {\r
- LOG.error("Exception while converting the notification: {}", pce.getMessage());\r
- }\r
-\r
- return result;\r
- }\r
-\r
- public static String convertDocumentToString(Element element) {\r
- String strxml = null;\r
- try {\r
- TransformerFactory transformerFactory = TransformerFactory.newInstance();\r
- Transformer transformer = transformerFactory.newTransformer();\r
- DOMSource source = new DOMSource(element);\r
- StreamResult result = new StreamResult(new StringWriter());\r
- transformer.transform(source, result);\r
- strxml = result.getWriter().toString();\r
- } catch (Exception e) {\r
- LOG.error("Error while converting Element to String" + e);\r
- }\r
- LOG.debug("Converted XML is : {}", strxml);\r
- return strxml;\r
- }\r
-}\r
+/*
+ * ============LICENSE_START========================================================================
+ * ONAP : tr-069-adapter
+ * =================================================================================================
+ * Copyright (C) 2020 CommScope Inc Intellectual Property.
+ * =================================================================================================
+ * This tr-069-adapter software file is distributed by CommScope Inc under the Apache License,
+ * Version 2.0 (the "License"); you may not use this file except in compliance with the License. You
+ * may obtain a copy of the License at
+ *
+ * http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * This file is distributed on an "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND,
+ * either express or implied. See the License for the specific language governing permissions and
+ * limitations under the License.
+ * ===============LICENSE_END=======================================================================
+ */
+
+package org.commscope.tr069adapter.mapper.netconf;
+
+import java.io.StringWriter;
+import java.text.SimpleDateFormat;
+import java.util.ArrayList;
+import java.util.Date;
+import java.util.HashMap;
+import java.util.List;
+import java.util.Map;
+import java.util.StringTokenizer;
+
+import javax.xml.XMLConstants;
+import javax.xml.parsers.DocumentBuilder;
+import javax.xml.parsers.DocumentBuilderFactory;
+import javax.xml.parsers.ParserConfigurationException;
+import javax.xml.transform.Transformer;
+import javax.xml.transform.TransformerFactory;
+import javax.xml.transform.dom.DOMSource;
+import javax.xml.transform.stream.StreamResult;
+
+import org.commscope.tr069adapter.acs.common.DeviceInform;
+import org.commscope.tr069adapter.acs.common.ParameterDTO;
+import org.commscope.tr069adapter.acs.common.inform.TransferCompleteInform;
+import org.commscope.tr069adapter.mapper.MOMetaData;
+import org.commscope.tr069adapter.mapper.MapperConfigProperties;
+import org.commscope.tr069adapter.mapper.model.NetConfNotificationDTO;
+import org.commscope.tr069adapter.mapper.util.MOMetaDataUtil;
+import org.slf4j.Logger;
+import org.slf4j.LoggerFactory;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.http.ResponseEntity;
+import org.springframework.stereotype.Component;
+import org.springframework.web.client.RestTemplate;
+import org.w3c.dom.Document;
+import org.w3c.dom.Element;
+
+@Component
+public class NetConfNotificationSender {
+
+ private static final Logger LOG = LoggerFactory.getLogger(NetConfNotificationSender.class);
+ private static final String BOOLEAN_TRUE_VALUE = "1";
+ private static final String BOOLEAN_FALSE_VALUE = "0";
+ private static final String BOOLEAN_DATA_TYPE = "boolean";
+ public static final String NOTIFICATION_ELEMENT_NAME = "notification";
+ public static final String EVENT_TIME = "eventTime";
+ private static final String INDEX_STR = "index";
+ private static final String INDEX_REGEX = "[0-9]{1,}";
+
+
+ @Autowired
+ MapperConfigProperties config;
+
+ @Autowired
+ MOMetaDataUtil metaDataUtil;
+
+ @Autowired
+ RestTemplate restTemplate;
+
+ public ResponseEntity sendNotification(DeviceInform deviceInform) {
+ ResponseEntity response = null;
+ final String uri = getUri();
+ LOG.debug("Posting notification to netconf server {}", uri);
+
+ try {
+ LOG.debug("deviceInform : {} {}", deviceInform.getInformTypeList(),
+ deviceInform.getParameters());
+ List<ParameterDTO> parameters = new ArrayList<>();
+ for (ParameterDTO parameterDTO : deviceInform.getParameters()) {
+ if (!parameterDTO.getParamName().equalsIgnoreCase("Device.DeviceInfo.SerialNumber"))
+ parameters.add(parameterDTO);
+ }
+ parameters.add(new ParameterDTO("Device.DeviceInfo.SerialNumber",
+ deviceInform.getDeviceDetails().getDeviceId()));
+
+ convertTR069ToNetConfParams(parameters, deviceInform.getDeviceDetails().getSoftwareVersion(),
+ deviceInform.getDeviceDetails().getHardwareVersion());
+
+ String nameSpace = metaDataUtil.getMetaDataByTR69Name(deviceInform.getInformType().toString(),
+ deviceInform.getDeviceDetails().getSoftwareVersion(),
+ deviceInform.getDeviceDetails().getHardwareVersion()).getURI();
+
+ String notificationXml =
+ getNetconfResponseXML(parameters, deviceInform.getInformType().toString(), nameSpace);
+ NetConfNotificationDTO netConfDTO = new NetConfNotificationDTO(
+ deviceInform.getDeviceDetails().getDeviceId(), notificationXml);
+
+ LOG.debug("Posting notification to netconf server");
+ response = restTemplate.postForObject(uri, netConfDTO, ResponseEntity.class);
+ LOG.debug("Posting notification to netconf server completed ");
+ } catch (Exception e) {
+ LOG.error("Exception while sending the notification.", e);
+ }
+ return response;
+ }
+
+ public ResponseEntity sendTransferCompleteNotification(TransferCompleteInform tcInform) {
+ ResponseEntity response = null;
+ final String uri = getUri();
+ LOG.debug("Posting notification to netconf server {}", uri);
+
+ try {
+ // LOG.debug("deviceInform : {} {}", tcInform.getInformTypeList(),
+ // tcInform.getParameters());
+ // List<ParameterDTO> parameters = new ArrayList<>();
+ // for (ParameterDTO parameterDTO : tcInform.getParameters()) {
+ // parameters.add(parameterDTO);
+ // }
+
+ List<ParameterDTO> parameters = new ArrayList<>();
+ parameters.add(new ParameterDTO("command-key", tcInform.getCommandKey()));
+ parameters.add(new ParameterDTO("fault-code", String.valueOf(tcInform.getFaultCode())));
+ parameters.add(new ParameterDTO("fault-string", tcInform.getFaultString()));
+ parameters.add(new ParameterDTO("start-time", tcInform.getStartTime()));
+ parameters.add(new ParameterDTO("complete-time", tcInform.getCompleteTime()));
+
+ String nameSpace = metaDataUtil.getMetaDataByTR69Name(tcInform.getInformType().toString(),
+ tcInform.getDeviceDetails().getSoftwareVersion(),
+ tcInform.getDeviceDetails().getHardwareVersion()).getURI();
+
+ String notificationXml =
+ getNetConfReposneXMLForTC(parameters, tcInform.getInformType().toString(), nameSpace);
+ NetConfNotificationDTO netConfDTO =
+ new NetConfNotificationDTO(tcInform.getDeviceDetails().getDeviceId(), notificationXml);
+
+ LOG.debug("Posting notification to netconf server");
+ response = restTemplate.postForObject(uri, netConfDTO, ResponseEntity.class);
+ LOG.debug("Posting notification to netconf server completed ");
+ } catch (Exception e) {
+ LOG.error("Exception while sending the notification.", e);
+ }
+ return response;
+ }
+
+ public ResponseEntity sendCustomNotification(String deviceId, List<ParameterDTO> parameters,
+ String nameSpace) {
+ ResponseEntity response = null;
+ final String uri = getUri();
+ LOG.debug("Posting custom notification to netconf server {}", uri);
+ try {
+ String notificationXml = getNetconfResponseXML(parameters, null, nameSpace);
+ NetConfNotificationDTO netConfDTO = new NetConfNotificationDTO(deviceId, notificationXml);
+
+ response = restTemplate.postForObject(uri, netConfDTO, ResponseEntity.class);
+ LOG.debug("Posting custom notification to netconf server sucessfull");
+ } catch (Exception e) {
+ LOG.error("Exception while sending the custom notification.", e);
+ }
+ return response;
+ }
+
+ private void convertTR069ToNetConfParams(List<ParameterDTO> parameters, String swVersion,
+ String hwVersion) {
+ List<ParameterDTO> removeList = new ArrayList<>();
+ if (null != parameters) {
+ for (ParameterDTO param : parameters) {
+ if (param.getParamValue() == null || param.getParamValue().trim().length() <= 0) {
+ removeList.add(param);
+ continue;
+ }
+ handleBooleanParameters(param, swVersion, hwVersion);
+ if (null != param.getParamName()) {
+ String netConfMOName = metaDataUtil
+ .getNetconfNameByTR69NameWithIndexes(param.getParamName(), swVersion, hwVersion);
+ if (null != netConfMOName)
+ param.setParamName(netConfMOName);
+ else
+ removeList.add(param); // unknown parameter found.
+ }
+ }
+ parameters.removeAll(removeList);
+ }
+ }
+
+ private void handleBooleanParameters(ParameterDTO param, String swVersion, String hwVersion) {
+ MOMetaData metaData =
+ metaDataUtil.getMetaDataByTR69Name(param.getParamName(), swVersion, hwVersion);
+ if (null != metaData && BOOLEAN_DATA_TYPE.equalsIgnoreCase(metaData.getDataType())) {
+ if (BOOLEAN_TRUE_VALUE.equalsIgnoreCase(param.getParamValue().trim())) {
+ param.setParamValue(Boolean.TRUE.toString());
+ } else if (BOOLEAN_FALSE_VALUE.equalsIgnoreCase(param.getParamValue().trim())) {
+ param.setParamValue(Boolean.FALSE.toString());
+ }
+ }
+ }
+
+ private String getUri() {
+ return config.getNbiNotificationUri();
+ }
+
+ private static String getNetconfResponseXML(List<ParameterDTO> parameters,
+ String notificationType, String nameSpace) {
+ if (parameters == null || parameters.isEmpty()) {
+ LOG.debug("There are no parameters found in the response.");
+ return null;
+ }
+
+ String result = null;
+ try {
+ DocumentBuilderFactory docFactory = DocumentBuilderFactory.newInstance();
+ docFactory.setAttribute(XMLConstants.ACCESS_EXTERNAL_DTD, "");
+ docFactory.setAttribute(XMLConstants.ACCESS_EXTERNAL_SCHEMA, "");
+ DocumentBuilder docBuilder = docFactory.newDocumentBuilder();
+ Document doc = docBuilder.newDocument();
+
+ Map<String, Element> parentNodeMap = new HashMap<>();
+ Element dataNode = null; // root of all nodes
+
+ for (ParameterDTO paramDto : parameters) {
+ String paramName = paramDto.getParamName();
+ String paramValue = paramDto.getParamValue();
+ StringTokenizer tokenizer = new StringTokenizer(paramName, ".");
+ String parentNodeName = null;
+ String parentNodeKey = null;
+ Element parentNode = null;
+ while (tokenizer.hasMoreElements()) {
+ String nodeName = (String) tokenizer.nextElement();
+ if (null == parentNodeName) { // construct first node or
+ // Device node
+ parentNodeName = nodeName;
+ parentNodeKey = nodeName;
+ // check if the node already exists in parentNodeMap
+ parentNode = parentNodeMap.get(parentNodeKey);
+ if (null == dataNode) {
+ dataNode = parentNode;
+ }
+ continue;
+ } else if (nodeName.matches(INDEX_REGEX)) { // construct
+ // tabular and
+ // index nodes
+
+ // get parent tabular node from parent MAP
+ StringBuilder bld = new StringBuilder();
+ bld.append(parentNodeKey);
+ bld.append(".");
+ bld.append(nodeName);
+ parentNodeKey = bld.toString();
+ Element node = parentNodeMap.get(parentNodeKey);
+
+ // create a tabular parent node if doesn't exit in MAP
+ if (null == node) {
+ node = doc.createElement(parentNodeName);
+ parentNodeMap.put(parentNodeKey, node);
+
+ // update current tabular parent node.
+ if (null != parentNode)
+ parentNode.appendChild(node);
+ else
+ parentNode = node;
+
+ // prepare and add index node to tabular parent node
+ Element indexNode = doc.createElement(INDEX_STR);
+ indexNode.setTextContent(nodeName);
+ node.appendChild(indexNode);
+ }
+ parentNode = node; // move parent to child
+ parentNodeName = nodeName;
+ } else if (parentNodeName.matches(INDEX_REGEX)) { // move to
+ // next
+ // node
+ // if
+ // tabular
+ // attribute
+ // is
+ // found
+ StringBuilder bld = new StringBuilder();
+ bld.append(parentNodeKey);
+ bld.append(".");
+ bld.append(nodeName);
+ parentNodeKey = bld.toString();
+ parentNodeName = nodeName;
+ } else {
+ // construct intermediate nodes
+ Element node = parentNodeMap.get(parentNodeKey);
+ if (null == node) {
+ if (null == dataNode) {
+ node = doc.createElementNS(nameSpace, parentNodeName);
+ dataNode = node;
+ } else {
+ node = doc.createElement(parentNodeName);
+ }
+ parentNodeMap.put(parentNodeKey, node);
+ if (null != parentNode)
+ parentNode.appendChild(node);
+ }
+ StringBuilder bld = new StringBuilder();
+ bld.append(parentNodeKey);
+ bld.append(".");
+ bld.append(nodeName);
+ parentNodeKey = bld.toString();
+ parentNodeName = nodeName;
+ parentNode = node;
+ }
+ }
+ // construct leaf node
+ Element leafNode = doc.createElement(parentNodeName);
+ leafNode.setTextContent(paramValue);
+ if (null != parentNode)
+ parentNode.appendChild(leafNode);
+ }
+
+ if (null != dataNode) {
+ final Element element = doc.createElement(NOTIFICATION_ELEMENT_NAME);
+ final Element eventTime = doc.createElement(EVENT_TIME);
+ eventTime
+ .setTextContent(new SimpleDateFormat("yyyy-MM-dd'T'HH:mm:ssXXX").format(new Date()));
+ element.appendChild(element.getOwnerDocument().importNode(eventTime, true));
+
+ if (notificationType != null) {
+ final Element evtTypeElement = doc.createElementNS(nameSpace, notificationType);
+ evtTypeElement.appendChild(dataNode);
+ element.appendChild(element.getOwnerDocument().importNode(evtTypeElement, true));
+ } else {
+ element.appendChild(element.getOwnerDocument().importNode(dataNode, true));
+ }
+
+ result = convertDocumentToString(element);
+ }
+ } catch (ParserConfigurationException pce) {
+ LOG.error("Exception while converting the notification: {}", pce.getMessage());
+ }
+
+ return result;
+ }
+
+ private static String getNetConfReposneXMLForTC(List<ParameterDTO> parameters,
+ String notificationType, String nameSpace) {
+ String result = null;
+ try {
+ DocumentBuilderFactory docFactory = DocumentBuilderFactory.newInstance();
+ docFactory.setAttribute(XMLConstants.ACCESS_EXTERNAL_DTD, "");
+ docFactory.setAttribute(XMLConstants.ACCESS_EXTERNAL_SCHEMA, "");
+ DocumentBuilder docBuilder = docFactory.newDocumentBuilder();
+ Document doc = docBuilder.newDocument();
+ final Element element = doc.createElement(NOTIFICATION_ELEMENT_NAME);
+ final Element eventTime = doc.createElement(EVENT_TIME);
+ eventTime.setTextContent(new SimpleDateFormat("yyyy-MM-dd'T'HH:mm:ssXXX").format(new Date()));
+ element.appendChild(element.getOwnerDocument().importNode(eventTime, true));
+
+ final Element evtTypeElement = doc.createElementNS(nameSpace, notificationType);
+
+ for (ParameterDTO paramDto : parameters) {
+ final Element paramNode = doc.createElement(paramDto.getParamName());
+ paramNode.setTextContent(paramDto.getParamValue());
+ evtTypeElement.appendChild(paramNode);
+ }
+ element.appendChild(element.getOwnerDocument().importNode(evtTypeElement, true));
+ result = convertDocumentToString(element);
+ } catch (Exception e) {
+ LOG.error("Exception in getNetConfReposneXMLForTC: {}", e.getMessage());
+ }
+ return result;
+ }
+
+ public static String convertDocumentToString(Element element) {
+ String strxml = null;
+ try {
+ TransformerFactory transformerFactory = TransformerFactory.newInstance();
+ transformerFactory.setAttribute(XMLConstants.ACCESS_EXTERNAL_DTD, "");
+ transformerFactory.setAttribute(XMLConstants.ACCESS_EXTERNAL_STYLESHEET, "");
+ Transformer transformer = transformerFactory.newTransformer();
+ DOMSource source = new DOMSource(element);
+ StreamResult result = new StreamResult(new StringWriter());
+ transformer.transform(source, result);
+ strxml = result.getWriter().toString();
+ } catch (Exception e) {
+ LOG.error("Error while converting Element to String", e);
+ }
+ LOG.debug("Converted XML is : {}", strxml);
+ return strxml;
+ }
+}
Code Review / oam / tr069-adapter.git / blobdiff