X-Git-Url: https://gerrit.o-ran-sc.org/r/gitweb?a=blobdiff_plain;f=netconf-server%2Fsrc%2Fmain%2Fjava%2Forg%2Fcommscope%2Ftr069adapter%2Fnetconf%2Frpc%2FSPAObjectOperation.java;h=bbba531b6889d3553304b29265a7a7d20ff05af5;hb=bfb65ab24d6ce7db221c5f52689a8efd8873fb1a;hp=c614d7facfb5053c8e183867dfd401c56abd1158;hpb=76744e810f35c84ecbd1d9998e361052466e9483;p=oam%2Ftr069-adapter.git

diff --git a/netconf-server/src/main/java/org/commscope/tr069adapter/netconf/rpc/SPAObjectOperation.java b/netconf-server/src/main/java/org/commscope/tr069adapter/netconf/rpc/SPAObjectOperation.java
index c614d7f..bbba531 100644
--- a/netconf-server/src/main/java/org/commscope/tr069adapter/netconf/rpc/SPAObjectOperation.java
+++ b/netconf-server/src/main/java/org/commscope/tr069adapter/netconf/rpc/SPAObjectOperation.java
@@ -18,165 +18,14 @@
 
 package org.commscope.tr069adapter.netconf.rpc;
 
-import java.io.StringReader;
-
-import javax.xml.XMLConstants;
-import javax.xml.parsers.DocumentBuilder;
-import javax.xml.parsers.DocumentBuilderFactory;
-
-import org.commscope.tr069adapter.mapper.model.ErrorCodeDetails;
-import org.commscope.tr069adapter.mapper.model.NetConfResponse;
-import org.commscope.tr069adapter.netconf.boot.NetConfServiceBooter;
-import org.commscope.tr069adapter.netconf.config.NetConfServerProperties;
-import org.opendaylight.netconf.api.DocumentedException;
-import org.opendaylight.netconf.api.DocumentedException.ErrorSeverity;
-import org.opendaylight.netconf.api.DocumentedException.ErrorTag;
-import org.opendaylight.netconf.api.DocumentedException.ErrorType;
-import org.opendaylight.netconf.api.xml.XmlElement;
-import org.opendaylight.netconf.api.xml.XmlNetconfConstants;
-import org.opendaylight.netconf.mapping.api.HandlingPriority;
-import org.opendaylight.netconf.mapping.api.NetconfOperation;
-import org.opendaylight.netconf.mapping.api.NetconfOperationChainedExecution;
-import org.slf4j.Logger;
-import org.slf4j.LoggerFactory;
-import org.w3c.dom.Document;
-import org.w3c.dom.Element;
-import org.w3c.dom.Node;
-import org.xml.sax.InputSource;
-
-public class SPAObjectOperation implements NetconfOperation {
-  private static final Logger logger = LoggerFactory.getLogger(SPAObjectOperation.class);
-  public static final String OP_NAMESPACE = "urn:tr069rpc:1.0";
-  public static final String OP_NAME = "set-parameter-attributes";
-
-  private String deviceID;
-  private String swVersion;
-  private String hwVersion;
+public class SPAObjectOperation extends GenericOperation {
 
   public SPAObjectOperation(String deviceID, String swVersion, String hwVersion) {
     this.deviceID = deviceID;
     this.swVersion = swVersion;
     this.hwVersion = hwVersion;
+    setOpString("spaobject");
+    setOpNamespace("urn:tr069rpc:1.0");
+    setOpName("set-parameter-attributes");
   }
-
-  @Override
-  public HandlingPriority canHandle(final Document message) throws DocumentedException {
-    OperationNameAndNamespace operationNameAndNamespace = null;
-    operationNameAndNamespace = new OperationNameAndNamespace(message);
-    return canHandle(operationNameAndNamespace.getOperationName(),
-        operationNameAndNamespace.getNamespace());
-  }
-
-  @Override
-  public Document handle(Document requestMessage,
-      NetconfOperationChainedExecution subsequentOperation) throws DocumentedException {
-    logger.debug("spaObject rpc is received in netconfserver");
-
-    final XmlElement requestElement = XmlElement.fromDomDocument(requestMessage);
-
-    final String msgId = requestElement.getAttribute(XmlNetconfConstants.MESSAGE_ID);
-    final Element element =
-        requestMessage.createElementNS(XmlNetconfConstants.URN_IETF_PARAMS_XML_NS_NETCONF_BASE_1_0,
-            XmlNetconfConstants.RPC_REPLY_KEY);
-    element.setAttribute("xmlns:ns1", getOperationNamespace());
-    element.setAttribute("message-id", msgId);
-
-    String requestXml = XmlUtility.convertDocumentToString(requestElement);
-    logger.debug("spaObject rpc requestXml= {}", requestXml);
-
-
-    NetConfServerProperties config =
-        NetConfServiceBooter.getApplicationContext().getBean(NetConfServerProperties.class);
-
-    final String baseUrl = config.getMapperPath() + "/spaobject";
-    NetConfResponse restResponse =
-        XmlUtility.invokeMapperCall(baseUrl, requestXml, deviceID, swVersion, hwVersion);
-    Document document = null;
-
-    ErrorCodeDetails errorCode = restResponse.getErrorCode();
-    if (errorCode != null && errorCode.getFaultCode() != null
-        && !errorCode.getFaultCode().equalsIgnoreCase("0")) {
-      logger.error("Error recevied : {}", errorCode);
-      throw new DocumentedException(errorCode.getErrorMessage(),
-          ErrorType.from(errorCode.getErrorType()), ErrorTag.from(errorCode.getErrorTag()),
-          ErrorSeverity.from(errorCode.getErrorSeverity()));
-    } else if (restResponse.getNetconfResponseXml() != null) {
-      logger.debug("spaobject rpc response received from mapper: {}",
-          restResponse.getNetconfResponseXml());
-      DocumentBuilderFactory factory = DocumentBuilderFactory.newInstance();
-      factory.setAttribute(XMLConstants.ACCESS_EXTERNAL_DTD, "");
-      factory.setAttribute(XMLConstants.ACCESS_EXTERNAL_SCHEMA, "");
-      DocumentBuilder builder;
-      try {
-        Node child = requestMessage.createElement(XmlNetconfConstants.OK);
-        element.appendChild(child);
-        String xmlStr = XmlUtility.convertDocumentToString(element);
-        try {
-          builder = factory.newDocumentBuilder();
-          document = builder.parse(new InputSource(new StringReader(xmlStr)));
-        } catch (Exception e) {
-          logger.error("Error while converting String to element: {}", e.getMessage());
-          throw new DocumentedException("Operation Aborted", ErrorType.from("application"),
-              ErrorTag.from("operation-failed"), ErrorSeverity.from("ERROR"));
-        }
-      } catch (Exception e) {
-        logger.error("Error while contruscting the response: {}", e.getMessage());
-        throw new DocumentedException("Operation Aborted", ErrorType.from("application"),
-            ErrorTag.from("operation-failed"), ErrorSeverity.from("ERROR"));
-      }
-    }
-
-    return document;
-  }
-
-  protected HandlingPriority canHandle(final String operationName,
-      final String operationNamespace) {
-    return operationName.equals(getOperationName())
-        && operationNamespace.equals(getOperationNamespace())
-            ? HandlingPriority.HANDLE_WITH_DEFAULT_PRIORITY.increasePriority(1100)
-            : HandlingPriority.CANNOT_HANDLE;
-  }
-
-  public static final class OperationNameAndNamespace {
-    private final String operationName;
-    private final String namespace;
-
-    private final XmlElement operationElement;
-
-    public OperationNameAndNamespace(final Document message) throws DocumentedException {
-      XmlElement requestElement = null;
-      requestElement = getRequestElementWithCheck(message);
-      operationElement = requestElement.getOnlyChildElement();
-      operationName = operationElement.getName();
-      namespace = operationElement.getNamespace();
-    }
-
-    public String getOperationName() {
-      return operationName;
-    }
-
-    public String getNamespace() {
-      return namespace;
-    }
-
-    public XmlElement getOperationElement() {
-      return operationElement;
-    }
-
-  }
-
-  protected static XmlElement getRequestElementWithCheck(final Document message)
-      throws DocumentedException {
-    return XmlElement.fromDomElementWithExpected(message.getDocumentElement(),
-        XmlNetconfConstants.RPC_KEY, XmlNetconfConstants.URN_IETF_PARAMS_XML_NS_NETCONF_BASE_1_0);
-  }
-
-  protected String getOperationNamespace() {
-    return OP_NAMESPACE;
-  }
-
-  protected String getOperationName() {
-    return OP_NAME;
-  }
-
 }