diff options
Diffstat (limited to 'common/src/main/java/org/openecomp/mso/yangDecoder/transform/impl/TransformJava2XMLServiceImpl.java')
-rw-r--r-- | common/src/main/java/org/openecomp/mso/yangDecoder/transform/impl/TransformJava2XMLServiceImpl.java | 114 |
1 files changed, 114 insertions, 0 deletions
diff --git a/common/src/main/java/org/openecomp/mso/yangDecoder/transform/impl/TransformJava2XMLServiceImpl.java b/common/src/main/java/org/openecomp/mso/yangDecoder/transform/impl/TransformJava2XMLServiceImpl.java new file mode 100644 index 0000000000..2ee7b5cfab --- /dev/null +++ b/common/src/main/java/org/openecomp/mso/yangDecoder/transform/impl/TransformJava2XMLServiceImpl.java @@ -0,0 +1,114 @@ +package org.openecomp.mso.yangDecoder.transform.impl; + +import org.openecomp.mso.yangDecoder.transform.api.ITransformJava2StringService; +import org.opendaylight.netconf.sal.restconf.impl.ControllerContext; +import org.opendaylight.netconf.sal.restconf.impl.InstanceIdentifierContext; +import org.opendaylight.netconf.sal.restconf.impl.NormalizedNodeContext; +import org.opendaylight.yangtools.binding.data.codec.api.BindingNormalizedNodeSerializer; +import org.opendaylight.yangtools.yang.binding.DataObject; +import org.opendaylight.yangtools.yang.binding.InstanceIdentifier; +import org.opendaylight.yangtools.yang.binding.Notification; +import org.opendaylight.yangtools.yang.data.api.schema.ContainerNode; +import org.opendaylight.yangtools.yang.data.api.schema.NormalizedNode; +import org.opendaylight.yangtools.yang.model.api.DataSchemaNode; +import org.opendaylight.yangtools.yang.model.api.SchemaContext; +import org.opendaylight.yangtools.yang.model.api.SchemaNode; +import org.slf4j.Logger; +import org.slf4j.LoggerFactory; + +import java.util.Map; + +/** + * Created by Administrator on 2017/3/20. + */ +public class TransformJava2XMLServiceImpl implements ITransformJava2StringService { + private static final Logger LOG = LoggerFactory.getLogger(TransformJava2XMLServiceImpl.class); + BindingNormalizedNodeSerializer mappingservice; + SchemaContext schemaContext; + YangDataTransformJava2NNServiceImpl java2nnService; + YangDataTransformNN2XMLServiceImpl nn2xmlService; + YangOdlNN2XMLImpl yangODLnn2xml; + public TransformJava2XMLServiceImpl(BindingNormalizedNodeSerializer mappingService, SchemaContext schemaContext){ + this.mappingservice=mappingService; + this.schemaContext=schemaContext; + java2nnService=new YangDataTransformJava2NNServiceImpl(mappingService); + nn2xmlService=new YangDataTransformNN2XMLServiceImpl(mappingService,schemaContext); + yangODLnn2xml=new YangOdlNN2XMLImpl(schemaContext); + } + @Override + public <T extends DataObject> String transformContrainerDataObjectToString(InstanceIdentifier<T> instanceIdentifier, String uriPath, T dataObject) + throws Exception { + // TODO Auto-generated method stub + NormalizedNode nn=java2nnService.yangDataObjecttoNN(instanceIdentifier,dataObject); + return yangODLnn2xml.yangNNtoXML(uriPath,nn); + } + @Override + public <T extends Notification> String transformNotificationToString(String uriPath, T notification) + throws Exception { + NormalizedNode nn= mappingservice.toNormalizedNodeNotification(notification); + return yangODLnn2xml.yangNNtoXML(uriPath,nn); + } + @Override + public <T extends DataObject> String transformRpcDataObjectToString(String uriPath, T dataObject) + throws Exception { + NormalizedNode nn=mappingservice.toNormalizedNodeRpcData(dataObject); + return yangODLnn2xml.yangNNtoXML(uriPath,nn); + } + //for container + public <T extends DataObject> String transformContrainerDataObjectToString(InstanceIdentifier<T> instanceIdentifier, T dataObject) { + // TODO Auto-generated method stub + NormalizedNode nn=java2nnService.yangDataObjecttoNN(instanceIdentifier,dataObject); + return nn2xmlService.transformNNToString(nn); + } + + public <T extends Notification> String transformNotificationToString(T notification) { + NormalizedNode nn= mappingservice.toNormalizedNodeNotification(notification); + return nn2xmlService.transformNNToString(nn); + } + + //for rpc + public <T extends DataObject> String transformRpcDataObjectToString(T dataObject) { + NormalizedNode nn=mappingservice.toNormalizedNodeRpcData(dataObject); + return nn2xmlService.transformNNToString(nn); + } + + //for container + @Override + public DataObject transformContrainerDataObjectFromString(String uriPath, String sxml,boolean ispost) throws Exception { + // TODO Auto-generated method stub + if(ispost) + { + NormalizedNodeContext nnc=YangOdlNNC2XMLImpl.fromXML(uriPath,sxml, ispost); + final InstanceIdentifierContext<?> iicontext=nnc.getInstanceIdentifierContext(); + Map.Entry<InstanceIdentifier<?>, DataObject> temp = mappingservice.fromNormalizedNode(iicontext.getInstanceIdentifier(),nnc.getData()); + return (DataObject)temp.getValue(); + } + final InstanceIdentifierContext<?> iicontext = ControllerContext.getInstance().toInstanceIdentifier(uriPath); + NormalizedNode nn =nn2xmlService.transformNNFromString(sxml); + Map.Entry<InstanceIdentifier<?>, DataObject> temp = mappingservice.fromNormalizedNode(iicontext.getInstanceIdentifier(),nn); + if (null == temp) { + return null; + } else { + return temp.getValue(); + } + } + @Override + public Notification transformNotificationFromString(String notficationName, String sxml) throws Exception { + + final InstanceIdentifierContext<?> iicontext = ControllerContext.getInstance().toInstanceIdentifier(notficationName); + NormalizedNode nn = nn2xmlService.transformNotificationStringtoNN(sxml, notficationName); + ContainerNode noti = (ContainerNode) nn; + SchemaNode snode=iicontext.getSchemaNode() ; + Notification obj = mappingservice.fromNormalizedNodeNotification(snode.getPath(), noti); + return obj; + } + //for rpc + @Override + public DataObject transformRpcDataObjectFromString(String rpcName, String sxml) throws Exception { + final InstanceIdentifierContext<?> iicontext = ControllerContext.getInstance().toInstanceIdentifier(rpcName); + Map.Entry<DataSchemaNode, NormalizedNode> nnentry = nn2xmlService.transformRpcNNEntryfromString(sxml,iicontext); + ContainerNode rpc = (ContainerNode) nnentry.getValue(); + DataObject rpcdata= mappingservice.fromNormalizedNodeRpcData(nnentry.getKey().getPath(),rpc); + return rpcdata; + } +} |