From 8de219f6b04458d40d4229c7ec2beda7e3f262b3 Mon Sep 17 00:00:00 2001 From: Zhuoyao Huang <10112215@zte.com.cn> Date: Sat, 23 Sep 2017 14:43:23 +0800 Subject: [PATCH] Yang decoder Change-Id: I4e264c33915969f883ebc3721e7020fb1256682c Issue-ID: SO-88 Signed-off-by: Zhuoyao Huang <10112215@zte.com.cn> description: It could help SO to use the restconf interface which is generated by yang-tools in SDN-C directly. --- common/pom.xml | 26 +++ .../yangDecoder/base/DataBrokerTestCustomizer.java | 121 ++++++++++ .../mso/yangDecoder/base/MockSchemaService.java | 42 ++++ .../mso/yangDecoder/base/TYangJsonXmlBase.java | 87 +++++++ .../mso/yangDecoder/base/TYangJsonXmlOSGIBase.java | 16 ++ .../api/ITransformJava2StringService.java | 27 +++ .../transform/api/NormalizedNodeVisitor.java | 6 + .../transform/impl/JsonParserStream.java | 24 ++ .../transform/impl/NormalizedNodeNavigator.java | 91 ++++++++ .../transform/impl/NormalizedNodePrinter.java | 93 ++++++++ .../transform/impl/NotificationAsContainer.java | 129 +++++++++++ .../transform/impl/TransformJava2JsonFactory.java | 63 +++++ .../impl/TransformJava2JsonServiceImpl.java | 93 ++++++++ .../transform/impl/TransformJava2XMLFactory.java | 64 ++++++ .../impl/TransformJava2XMLServiceImpl.java | 114 ++++++++++ .../impl/TransfromJava2StringFactory.java | 55 +++++ .../impl/XmlNormalizedNodeBodyReaderUmeImpl.java | 24 ++ .../impl/YangDataTransformJava2NNServiceImpl.java | 144 ++++++++++++ .../impl/YangDataTransformNN2JsonServiceImpl.java | 50 ++++ .../impl/YangDataTransformNN2XMLServiceImpl.java | 253 +++++++++++++++++++++ .../transform/impl/YangOdlNN2XMLImpl.java | 106 +++++++++ .../transform/impl/YangOdlNNC2XMLImpl.java | 64 ++++++ 22 files changed, 1692 insertions(+) create mode 100644 common/src/main/java/org/openecomp/mso/yangDecoder/base/DataBrokerTestCustomizer.java create mode 100644 common/src/main/java/org/openecomp/mso/yangDecoder/base/MockSchemaService.java create mode 100644 common/src/main/java/org/openecomp/mso/yangDecoder/base/TYangJsonXmlBase.java create mode 100644 common/src/main/java/org/openecomp/mso/yangDecoder/base/TYangJsonXmlOSGIBase.java create mode 100644 common/src/main/java/org/openecomp/mso/yangDecoder/transform/api/ITransformJava2StringService.java create mode 100644 common/src/main/java/org/openecomp/mso/yangDecoder/transform/api/NormalizedNodeVisitor.java create mode 100644 common/src/main/java/org/openecomp/mso/yangDecoder/transform/impl/JsonParserStream.java create mode 100644 common/src/main/java/org/openecomp/mso/yangDecoder/transform/impl/NormalizedNodeNavigator.java create mode 100644 common/src/main/java/org/openecomp/mso/yangDecoder/transform/impl/NormalizedNodePrinter.java create mode 100644 common/src/main/java/org/openecomp/mso/yangDecoder/transform/impl/NotificationAsContainer.java create mode 100644 common/src/main/java/org/openecomp/mso/yangDecoder/transform/impl/TransformJava2JsonFactory.java create mode 100644 common/src/main/java/org/openecomp/mso/yangDecoder/transform/impl/TransformJava2JsonServiceImpl.java create mode 100644 common/src/main/java/org/openecomp/mso/yangDecoder/transform/impl/TransformJava2XMLFactory.java create mode 100644 common/src/main/java/org/openecomp/mso/yangDecoder/transform/impl/TransformJava2XMLServiceImpl.java create mode 100644 common/src/main/java/org/openecomp/mso/yangDecoder/transform/impl/TransfromJava2StringFactory.java create mode 100644 common/src/main/java/org/openecomp/mso/yangDecoder/transform/impl/XmlNormalizedNodeBodyReaderUmeImpl.java create mode 100644 common/src/main/java/org/openecomp/mso/yangDecoder/transform/impl/YangDataTransformJava2NNServiceImpl.java create mode 100644 common/src/main/java/org/openecomp/mso/yangDecoder/transform/impl/YangDataTransformNN2JsonServiceImpl.java create mode 100644 common/src/main/java/org/openecomp/mso/yangDecoder/transform/impl/YangDataTransformNN2XMLServiceImpl.java create mode 100644 common/src/main/java/org/openecomp/mso/yangDecoder/transform/impl/YangOdlNN2XMLImpl.java create mode 100644 common/src/main/java/org/openecomp/mso/yangDecoder/transform/impl/YangOdlNNC2XMLImpl.java diff --git a/common/pom.xml b/common/pom.xml index 0a631cbcd7..4c756ae532 100644 --- a/common/pom.xml +++ b/common/pom.xml @@ -150,6 +150,32 @@ swagger-annotations_2.9.1 1.3.0 + + + org.opendaylight.yangtools + yang-data-codec-gson + 1.1.1-Carbon + + + org.opendaylight.mdsal + mdsal-binding-dom-adapter + 2.2.1-Carbon + + + org.opendaylight.mdsal + mdsal-dom-broker + 2.2.1-Carbon + + + org.opendaylight.netconf + sal-rest-connector + 1.5.1-Carbon + + + org.dom4j + dom4j + 2.0.0 + diff --git a/common/src/main/java/org/openecomp/mso/yangDecoder/base/DataBrokerTestCustomizer.java b/common/src/main/java/org/openecomp/mso/yangDecoder/base/DataBrokerTestCustomizer.java new file mode 100644 index 0000000000..f442372dcd --- /dev/null +++ b/common/src/main/java/org/openecomp/mso/yangDecoder/base/DataBrokerTestCustomizer.java @@ -0,0 +1,121 @@ +package org.openecomp.mso.yangDecoder.base; + +import com.google.common.collect.ImmutableMap; +import com.google.common.util.concurrent.ListeningExecutorService; +import com.google.common.util.concurrent.MoreExecutors; +import javassist.ClassPool; +import org.opendaylight.mdsal.binding.api.DataBroker; +import org.opendaylight.mdsal.binding.api.NotificationPublishService; +import org.opendaylight.mdsal.binding.api.NotificationService; +import org.opendaylight.mdsal.binding.dom.adapter.BindingDOMDataBrokerAdapter; +import org.opendaylight.mdsal.binding.dom.adapter.BindingDOMNotificationPublishServiceAdapter; +import org.opendaylight.mdsal.binding.dom.adapter.BindingDOMNotificationServiceAdapter; +import org.opendaylight.mdsal.binding.dom.adapter.BindingToNormalizedNodeCodec; +import org.opendaylight.mdsal.common.api.LogicalDatastoreType; +import org.opendaylight.mdsal.dom.api.DOMDataBroker; +import org.opendaylight.mdsal.dom.api.DOMSchemaService; +import org.opendaylight.mdsal.dom.broker.DOMNotificationRouter; +import org.opendaylight.mdsal.dom.broker.SerializedDOMDataBroker; +import org.opendaylight.mdsal.dom.spi.store.DOMStore; +import org.opendaylight.mdsal.dom.store.inmemory.InMemoryDOMDataStore; +import org.opendaylight.yangtools.binding.data.codec.gen.impl.DataObjectSerializerGenerator; +import org.opendaylight.yangtools.binding.data.codec.gen.impl.StreamWriterGenerator; +import org.opendaylight.yangtools.binding.data.codec.impl.BindingNormalizedNodeCodecRegistry; +import org.opendaylight.mdsal.binding.generator.impl.GeneratedClassLoadingStrategy; +import org.opendaylight.mdsal.binding.generator.util.JavassistUtils; +import org.opendaylight.yangtools.yang.model.api.SchemaContext; + +public class DataBrokerTestCustomizer { + + private DOMDataBroker domDataBroker; + private final DOMNotificationRouter domNotificationRouter; + private final MockSchemaService schemaService; + private ImmutableMap datastores; + private final BindingToNormalizedNodeCodec bindingToNormalized; + + public ImmutableMap createDatastores() { + return ImmutableMap.builder() + .put(LogicalDatastoreType.OPERATIONAL, createOperationalDatastore()) + .put(LogicalDatastoreType.CONFIGURATION,createConfigurationDatastore()) + .build(); + } + + public DataBrokerTestCustomizer() { + schemaService = new MockSchemaService(); + final ClassPool pool = ClassPool.getDefault(); + final DataObjectSerializerGenerator generator = StreamWriterGenerator.create(JavassistUtils.forClassPool(pool)); + final BindingNormalizedNodeCodecRegistry codecRegistry = new BindingNormalizedNodeCodecRegistry(generator); + final GeneratedClassLoadingStrategy loading = GeneratedClassLoadingStrategy.getTCCLClassLoadingStrategy(); + bindingToNormalized = new BindingToNormalizedNodeCodec(loading, codecRegistry); + schemaService.registerSchemaContextListener(bindingToNormalized); + domNotificationRouter = DOMNotificationRouter.create(16); + } + + public DOMStore createConfigurationDatastore() { + final InMemoryDOMDataStore store = new InMemoryDOMDataStore("CFG", MoreExecutors.sameThreadExecutor()); + schemaService.registerSchemaContextListener(store); + return store; + } + + public DOMStore createOperationalDatastore() { + final InMemoryDOMDataStore store = new InMemoryDOMDataStore("OPER", MoreExecutors.sameThreadExecutor()); + schemaService.registerSchemaContextListener(store); + return store; + } + + public DOMDataBroker createDOMDataBroker() { + return new SerializedDOMDataBroker(getDatastores(), getCommitCoordinatorExecutor()); + } + + public NotificationService createNotificationService() { + return new BindingDOMNotificationServiceAdapter(bindingToNormalized.getCodecRegistry(), domNotificationRouter); + } + + public NotificationPublishService createNotificationPublishService() { + return new BindingDOMNotificationPublishServiceAdapter(bindingToNormalized, domNotificationRouter); + } + + + public ListeningExecutorService getCommitCoordinatorExecutor() { + return MoreExecutors.sameThreadExecutor(); + } + + public DataBroker createDataBroker() { + return new BindingDOMDataBrokerAdapter(getDOMDataBroker(), bindingToNormalized); + } + + public BindingToNormalizedNodeCodec getBindingToNormalized() { + return bindingToNormalized; + } + + public DOMSchemaService getSchemaService() { + return schemaService; + } + + private DOMDataBroker getDOMDataBroker() { + if(domDataBroker == null) { + domDataBroker = createDOMDataBroker(); + } + return domDataBroker; + } + + private synchronized ImmutableMap getDatastores() { + if (datastores == null) { + datastores = createDatastores(); + } + return datastores; + } + + public void updateSchema(final SchemaContext ctx) { + schemaService.changeSchema(ctx); + } + + public DOMNotificationRouter getDomNotificationRouter() { + return domNotificationRouter; + } + public void close() + { + if(bindingToNormalized!=null)bindingToNormalized.close(); + if(domNotificationRouter!=null)domNotificationRouter.close(); + } +} diff --git a/common/src/main/java/org/openecomp/mso/yangDecoder/base/MockSchemaService.java b/common/src/main/java/org/openecomp/mso/yangDecoder/base/MockSchemaService.java new file mode 100644 index 0000000000..f869a3c600 --- /dev/null +++ b/common/src/main/java/org/openecomp/mso/yangDecoder/base/MockSchemaService.java @@ -0,0 +1,42 @@ +package org.openecomp.mso.yangDecoder.base; +import org.opendaylight.mdsal.dom.api.DOMSchemaService; +import org.opendaylight.yangtools.concepts.ListenerRegistration; +import org.opendaylight.yangtools.util.ListenerRegistry; +import org.opendaylight.yangtools.yang.model.api.SchemaContext; +import org.opendaylight.yangtools.yang.model.api.SchemaContextListener; +import org.opendaylight.yangtools.yang.model.api.SchemaContextProvider; + +public final class MockSchemaService implements DOMSchemaService, SchemaContextProvider { + + private SchemaContext schemaContext; + + ListenerRegistry listeners = ListenerRegistry.create(); + + @Override + public synchronized SchemaContext getGlobalContext() { + return schemaContext; + } + + @Override + public synchronized SchemaContext getSessionContext() { + return schemaContext; + } + + @Override + public ListenerRegistration registerSchemaContextListener( + final SchemaContextListener listener) { + return listeners.register(listener); + } + + @Override + public synchronized SchemaContext getSchemaContext() { + return schemaContext; + } + + public synchronized void changeSchema(final SchemaContext newContext) { + schemaContext = newContext; + for (ListenerRegistration listener : listeners) { + listener.getInstance().onGlobalContextUpdated(schemaContext); + } + } +} diff --git a/common/src/main/java/org/openecomp/mso/yangDecoder/base/TYangJsonXmlBase.java b/common/src/main/java/org/openecomp/mso/yangDecoder/base/TYangJsonXmlBase.java new file mode 100644 index 0000000000..5167d9de8d --- /dev/null +++ b/common/src/main/java/org/openecomp/mso/yangDecoder/base/TYangJsonXmlBase.java @@ -0,0 +1,87 @@ +package org.openecomp.mso.yangDecoder.base; + +import org.opendaylight.mdsal.binding.api.DataBroker; +import org.opendaylight.mdsal.dom.api.DOMDataBroker; +import org.opendaylight.mdsal.binding.generator.impl.ModuleInfoBackedContext; +import org.opendaylight.yangtools.yang.binding.YangModuleInfo; +import org.opendaylight.yangtools.yang.binding.util.BindingReflections; +import org.opendaylight.yangtools.yang.model.api.SchemaContext; + +import java.io.BufferedWriter; +import java.io.File; +import java.io.FileWriter; + +//-- + +public abstract class TYangJsonXmlBase { + + private Iterable moduleInfos; + protected SchemaContext schemaContext; +//---------- + private DataBrokerTestCustomizer testCustomizer; + private DataBroker dataBroker; + private DOMDataBroker domBroker; + + protected Iterable getModuleInfos() throws Exception { + return BindingReflections.loadModuleInfos(); + } + public static void writefile(String confname, String strx) + { + final String outd="outdir"; + File dir = new File(outd); + dir.mkdir(); + String fn = outd+File.separatorChar+confname; + try(FileWriter fw = new FileWriter(fn); BufferedWriter writer = new BufferedWriter(fw)) + { + // FileWriter fw = new FileWriter(fn); + // BufferedWriter writer = new BufferedWriter(fw); + writer.write(strx); + // writer.close(); + // fw.close(); + } + catch (Exception e) + { + } + } + + public final void setup() throws Exception { + moduleInfos = getModuleInfos(); + ModuleInfoBackedContext moduleContext = ModuleInfoBackedContext.create(); + moduleContext.addModuleInfos(moduleInfos); + schemaContext = moduleContext.tryToCreateSchemaContext().get(); + setupWithSchema(schemaContext); + } + + /** + * Setups test with Schema context. + * + * @param context schema context + */ + protected void setupWithSchema(SchemaContext context){ + testCustomizer = createDataBrokerTestCustomizer(); + dataBroker = testCustomizer.createDataBroker(); + domBroker = testCustomizer.createDOMDataBroker(); + testCustomizer.updateSchema(context); + setupWithDataBroker(dataBroker); + } + protected void setupWithDataBroker(final DataBroker dataBroker) { + // Intentionally left No-op, subclasses may customize it + } + + protected DataBrokerTestCustomizer createDataBrokerTestCustomizer() { + return new DataBrokerTestCustomizer(); + } + + public DataBroker getDataBroker() { + return dataBroker; + } + + public DOMDataBroker getDomBroker() { + return domBroker; + } + public void close() + { + //domBroker. + testCustomizer.close(); + } +} \ No newline at end of file diff --git a/common/src/main/java/org/openecomp/mso/yangDecoder/base/TYangJsonXmlOSGIBase.java b/common/src/main/java/org/openecomp/mso/yangDecoder/base/TYangJsonXmlOSGIBase.java new file mode 100644 index 0000000000..34d3735b08 --- /dev/null +++ b/common/src/main/java/org/openecomp/mso/yangDecoder/base/TYangJsonXmlOSGIBase.java @@ -0,0 +1,16 @@ +package org.openecomp.mso.yangDecoder.base; + +import org.openecomp.mso.yangDecoder.transform.api.ITransformJava2StringService; +import org.opendaylight.yangtools.binding.data.codec.api.BindingNormalizedNodeSerializer; + +public interface TYangJsonXmlOSGIBase { + + public abstract void init(BindingNormalizedNodeSerializer mappingService) + throws Exception; + + public abstract ITransformJava2StringService getJava2StringService( + String jsonorxml); + + public abstract void close(); + +} \ No newline at end of file diff --git a/common/src/main/java/org/openecomp/mso/yangDecoder/transform/api/ITransformJava2StringService.java b/common/src/main/java/org/openecomp/mso/yangDecoder/transform/api/ITransformJava2StringService.java new file mode 100644 index 0000000000..93e16772d3 --- /dev/null +++ b/common/src/main/java/org/openecomp/mso/yangDecoder/transform/api/ITransformJava2StringService.java @@ -0,0 +1,27 @@ +package org.openecomp.mso.yangDecoder.transform.api; + +import org.opendaylight.yangtools.yang.binding.DataObject; +import org.opendaylight.yangtools.yang.binding.InstanceIdentifier; +import org.opendaylight.yangtools.yang.binding.Notification; + +/** + * Created by Administrator on 2017/3/21. + */ +public interface ITransformJava2StringService { + //following function encode + + String transformContrainerDataObjectToString(InstanceIdentifier instanceIdentifier, String uriPath, T dataObject) + throws Exception; + + String transformNotificationToString(String uriPath, T notification) throws Exception; + + String transformRpcDataObjectToString(String uriPath, T dataObject) throws Exception; + + //following function decode + //for container + DataObject transformContrainerDataObjectFromString(String uriPath, String sxml, boolean ispost) throws Exception; + //notification + Notification transformNotificationFromString(String notficationName, String sxml) throws Exception; + //for rpc + DataObject transformRpcDataObjectFromString(String rpcName, String sxml) throws Exception; +} diff --git a/common/src/main/java/org/openecomp/mso/yangDecoder/transform/api/NormalizedNodeVisitor.java b/common/src/main/java/org/openecomp/mso/yangDecoder/transform/api/NormalizedNodeVisitor.java new file mode 100644 index 0000000000..2a893b0a9e --- /dev/null +++ b/common/src/main/java/org/openecomp/mso/yangDecoder/transform/api/NormalizedNodeVisitor.java @@ -0,0 +1,6 @@ +package org.openecomp.mso.yangDecoder.transform.api; +import org.opendaylight.yangtools.yang.data.api.schema.NormalizedNode; + +public interface NormalizedNodeVisitor { + void visitNode(int var1, String var2, NormalizedNode var3, boolean start); +} \ No newline at end of file diff --git a/common/src/main/java/org/openecomp/mso/yangDecoder/transform/impl/JsonParserStream.java b/common/src/main/java/org/openecomp/mso/yangDecoder/transform/impl/JsonParserStream.java new file mode 100644 index 0000000000..c9e4c1dbae --- /dev/null +++ b/common/src/main/java/org/openecomp/mso/yangDecoder/transform/impl/JsonParserStream.java @@ -0,0 +1,24 @@ +package org.openecomp.mso.yangDecoder.transform.impl; + +import com.google.common.base.Preconditions; +import org.opendaylight.yangtools.yang.data.util.RpcAsContainer; +import org.opendaylight.yangtools.yang.model.api.DataSchemaNode; +import org.opendaylight.yangtools.yang.model.api.NotificationDefinition; +import org.opendaylight.yangtools.yang.model.api.RpcDefinition; +import org.opendaylight.yangtools.yang.model.api.SchemaNode; + +/** + * Created by 10112215 on 2017/9/17. + */ +public class JsonParserStream { + public static DataSchemaNode getWrapSchemaNode(SchemaNode parentNode) { + if(parentNode instanceof RpcDefinition) { + return new RpcAsContainer((RpcDefinition)parentNode); + } else if(parentNode instanceof NotificationDefinition) { + return new NotificationAsContainer((NotificationDefinition)parentNode); + } else { + Preconditions.checkArgument(parentNode instanceof DataSchemaNode, "Instance of DataSchemaNode class awaited."); + return (DataSchemaNode)parentNode; + } + } +} diff --git a/common/src/main/java/org/openecomp/mso/yangDecoder/transform/impl/NormalizedNodeNavigator.java b/common/src/main/java/org/openecomp/mso/yangDecoder/transform/impl/NormalizedNodeNavigator.java new file mode 100644 index 0000000000..c585529cf2 --- /dev/null +++ b/common/src/main/java/org/openecomp/mso/yangDecoder/transform/impl/NormalizedNodeNavigator.java @@ -0,0 +1,91 @@ +package org.openecomp.mso.yangDecoder.transform.impl; + +import com.google.common.base.Preconditions; +import org.openecomp.mso.yangDecoder.transform.api.NormalizedNodeVisitor; +import org.opendaylight.yangtools.yang.data.api.schema.*; + +import java.util.Collection; +import java.util.Iterator; + +/** + * Created by 10036837 on 16-7-22. + */ +public class NormalizedNodeNavigator { + private final NormalizedNodeVisitor visitor; + + public NormalizedNodeNavigator(NormalizedNodeVisitor visitor) { + Preconditions.checkNotNull(visitor, "visitor should not be null"); + this.visitor = visitor; + } + + public void navigate(String parentPath, NormalizedNode normalizedNode) { + if (parentPath == null) { + parentPath = ""; + } + + this.navigateNormalizedNode(0, parentPath, normalizedNode); + + } + + private void navigateDataContainerNode(int level, String parentPath, DataContainerNode dataContainerNode) { + this.visitor.visitNode(level, parentPath, dataContainerNode, true); + String newParentPath = parentPath + "/" + dataContainerNode.getIdentifier().toString(); + Collection value = dataContainerNode.getValue(); + Iterator var6 = value.iterator(); + + while (var6.hasNext()) { + NormalizedNode node = (NormalizedNode) var6.next(); + if (node instanceof MixinNode && node instanceof NormalizedNodeContainer) { + this.navigateNormalizedNodeContainerMixin(level, newParentPath, (NormalizedNodeContainer) node); + } else { + this.navigateNormalizedNode(level, newParentPath, node); + } + } + this.visitor.visitNode(level, parentPath, dataContainerNode, false); + } + + private void navigateOrderedNodeContainer(int level, String parentPath, OrderedNodeContainer node) { + String newParentPath = parentPath + "/" + node.getIdentifier().toString(); + Collection value = node.getValue(); + Iterator var6 = value.iterator(); + + while (var6.hasNext()) { + NormalizedNode normalizedNode = (NormalizedNode) var6.next(); + if (normalizedNode instanceof OrderedNodeContainer) { + this.navigateOrderedNodeContainer(level, newParentPath, (OrderedNodeContainer) normalizedNode); + } else { + this.navigateNormalizedNode(level, newParentPath, normalizedNode); + } + } + + } + + private void navigateNormalizedNodeContainerMixin(int level, String parentPath, NormalizedNodeContainer node) { + + String newParentPath = parentPath + "/" + node.getIdentifier().toString(); + Collection value = node.getValue(); + Iterator var6 = value.iterator(); + + while (var6.hasNext()) { + NormalizedNode normalizedNode = (NormalizedNode) var6.next(); + if (normalizedNode instanceof MixinNode && normalizedNode instanceof NormalizedNodeContainer) { + this.navigateNormalizedNodeContainerMixin(level, newParentPath, (NormalizedNodeContainer) normalizedNode); + } else { + this.navigateNormalizedNode(level, newParentPath, normalizedNode); + } + } + + } + + private void navigateNormalizedNode(int level, String parentPath, NormalizedNode normalizedNode) { + if (normalizedNode instanceof DataContainerNode) { + DataContainerNode dataContainerNode = (DataContainerNode) normalizedNode; + this.navigateDataContainerNode(level+1, parentPath, dataContainerNode); + } else if (normalizedNode instanceof OrderedNodeContainer) { + this.navigateOrderedNodeContainer(level, parentPath, (OrderedNodeContainer) normalizedNode); + } else { + this.visitor.visitNode(level + 1, parentPath, normalizedNode, false); + } + + } +} diff --git a/common/src/main/java/org/openecomp/mso/yangDecoder/transform/impl/NormalizedNodePrinter.java b/common/src/main/java/org/openecomp/mso/yangDecoder/transform/impl/NormalizedNodePrinter.java new file mode 100644 index 0000000000..6b2c7dfbff --- /dev/null +++ b/common/src/main/java/org/openecomp/mso/yangDecoder/transform/impl/NormalizedNodePrinter.java @@ -0,0 +1,93 @@ +package org.openecomp.mso.yangDecoder.transform.impl; +import org.openecomp.mso.yangDecoder.transform.api.NormalizedNodeVisitor; +import org.opendaylight.yangtools.yang.common.QName; +import org.opendaylight.yangtools.yang.data.api.schema.LeafNode; +import org.opendaylight.yangtools.yang.data.api.schema.LeafSetEntryNode; +import org.opendaylight.yangtools.yang.data.api.schema.NormalizedNode; + + +/** + * Created by 10036837 on 16-7-21. + */ +public class NormalizedNodePrinter implements NormalizedNodeVisitor { + StringBuilder result; + private static final String CODES = "ABCDEFGHIJKLMNOPQRSTUVWXYZabcdefghijklmnopqrstuvwxyz0123456789+/="; + public NormalizedNodePrinter(StringBuilder result) { + this.result = result; + } + private final static String endl=System.getProperty("line.separator"); + public final static String getEndl(){ + return endl; + } + private static String spaces(int n) { + StringBuilder builder = new StringBuilder(); + for (int i = 0; i < n; i++) { + builder.append(' '); + } + return builder.toString(); + } + + @Override + public void visitNode(int level, String parentPath, NormalizedNode normalizedNode, boolean start) { + if(normalizedNode == null) + { + return; + } + if(normalizedNode.getNodeType() == null) + { + return; + } + + String localName = normalizedNode.getNodeType().getLocalName(); + if (normalizedNode instanceof LeafNode || normalizedNode instanceof LeafSetEntryNode) { + if(normalizedNode.getValue() instanceof byte[]){ + result.append(spaces((level-1) * 4) + "<" + localName + ">" + (normalizedNode.getValue() == null ? "" : base64Encode((byte[]) normalizedNode.getValue())) + ""+endl); + } + else { + String svalue=normalizedNode.getValue().toString(); + if(normalizedNode.getValue() instanceof QName){ + QName qn=(QName)normalizedNode.getValue(); + svalue= qn.getLocalName(); + } + result.append(spaces((level - 1) * 4) + "<" + localName + ">" + (normalizedNode.getValue() == null ? "" :svalue) + ""+endl); + } + } else { + if (start) { + if (level == 1) { + result.append(spaces((level-1) * 4) + "<" + localName + " xmlns=\"" + normalizedNode.getNodeType().getNamespace() + "\">"+endl); + } else { + result.append(spaces((level-1) * 4) + "<" + localName + ">"+endl); + } + } else { + result.append(spaces((level-1) * 4) + ""+endl); + } + } + } + private String base64Encode(byte[] in) { + StringBuilder out = new StringBuilder((in.length * 4) / 3); + int b; + for (int i = 0; i < in.length; i += 3) { + b = (in[i] & 0xFC) >> 2; + out.append(CODES.charAt(b)); + b = (in[i] & 0x03) << 4; + if (i + 1 < in.length) { + b |= (in[i + 1] & 0xF0) >> 4; + out.append(CODES.charAt(b)); + b = (in[i + 1] & 0x0F) << 2; + if (i + 2 < in.length) { + b |= (in[i + 2] & 0xC0) >> 6; + out.append(CODES.charAt(b)); + b = in[i + 2] & 0x3F; + out.append(CODES.charAt(b)); + } else { + out.append(CODES.charAt(b)); + out.append('='); + } + } else { + out.append(CODES.charAt(b)); + out.append("=="); + } + } + return out.toString(); + } +} \ No newline at end of file diff --git a/common/src/main/java/org/openecomp/mso/yangDecoder/transform/impl/NotificationAsContainer.java b/common/src/main/java/org/openecomp/mso/yangDecoder/transform/impl/NotificationAsContainer.java new file mode 100644 index 0000000000..31c894e6fb --- /dev/null +++ b/common/src/main/java/org/openecomp/mso/yangDecoder/transform/impl/NotificationAsContainer.java @@ -0,0 +1,129 @@ +package org.openecomp.mso.yangDecoder.transform.impl; + +import java.util.ArrayList; +import java.util.Collection; +import java.util.Collections; +import java.util.List; +import java.util.Set; +import org.opendaylight.yangtools.yang.common.QName; +import org.opendaylight.yangtools.yang.model.api.AugmentationSchema; +import org.opendaylight.yangtools.yang.model.api.ConstraintDefinition; +import org.opendaylight.yangtools.yang.model.api.ContainerSchemaNode; +import org.opendaylight.yangtools.yang.model.api.DataSchemaNode; +import org.opendaylight.yangtools.yang.model.api.GroupingDefinition; +import org.opendaylight.yangtools.yang.model.api.NotificationDefinition; +import org.opendaylight.yangtools.yang.model.api.SchemaPath; +import org.opendaylight.yangtools.yang.model.api.Status; +import org.opendaylight.yangtools.yang.model.api.TypeDefinition; +import org.opendaylight.yangtools.yang.model.api.UnknownSchemaNode; +import org.opendaylight.yangtools.yang.model.api.UsesNode; + +final class NotificationAsContainer implements ContainerSchemaNode { + private final NotificationDefinition delegate; + + public String getDescription() { + return this.delegate.getDescription(); + } + + public String getReference() { + return this.delegate.getReference(); + } + + public Set> getTypeDefinitions() { + return this.delegate.getTypeDefinitions(); + } + + public Set getGroupings() { + return this.delegate.getGroupings(); + } + + public Status getStatus() { + return this.delegate.getStatus(); + } + + public ContainerSchemaNode getInput() { + return null; + } + + public ContainerSchemaNode getOutput() { + return null; + } + + NotificationAsContainer(NotificationDefinition parentNode) { + this.delegate = parentNode; + } + + public QName getQName() { + return this.delegate.getQName(); + } + + public SchemaPath getPath() { + return this.delegate.getPath(); + } + + public List getUnknownSchemaNodes() { + return Collections.emptyList(); + } + + public DataSchemaNode getDataChildByName(QName name) { + return this.getDataChildByName(name.getLocalName()); + } + + public DataSchemaNode getDataChildByName(String name) { + byte var3 = -1; + switch(name.hashCode()) { + case -1005512447: + if(name.equals("output")) { + var3 = 1; + } + break; + case 100358090: + if(name.equals("input")) { + var3 = 0; + } + } + + switch(var3) { + case 0: + return null; + case 1: + return null; + default: + return null; + } + } + + public Set getUses() { + return Collections.emptySet(); + } + + public Set getAvailableAugmentations() { + return Collections.emptySet(); + } + + public boolean isPresenceContainer() { + return false; + } + + public Collection getChildNodes() { + ArrayList ret = new ArrayList(); + ret.addAll(this.delegate.getChildNodes()); + return ret; + } + + public boolean isAugmenting() { + return false; + } + + public boolean isAddedByUses() { + return false; + } + + public boolean isConfiguration() { + return false; + } + + public ConstraintDefinition getConstraints() { + return null; + } +} diff --git a/common/src/main/java/org/openecomp/mso/yangDecoder/transform/impl/TransformJava2JsonFactory.java b/common/src/main/java/org/openecomp/mso/yangDecoder/transform/impl/TransformJava2JsonFactory.java new file mode 100644 index 0000000000..647b3038bb --- /dev/null +++ b/common/src/main/java/org/openecomp/mso/yangDecoder/transform/impl/TransformJava2JsonFactory.java @@ -0,0 +1,63 @@ +package org.openecomp.mso.yangDecoder.transform.impl; + +import javassist.ClassPool; +import org.openecomp.mso.yangDecoder.base.TYangJsonXmlBase; +import org.opendaylight.mdsal.binding.api.DataBroker; +import org.opendaylight.mdsal.binding.dom.adapter.BindingToNormalizedNodeCodec; +import org.opendaylight.netconf.sal.restconf.impl.ControllerContext; +import org.opendaylight.yangtools.binding.data.codec.gen.impl.StreamWriterGenerator; +import org.opendaylight.yangtools.binding.data.codec.impl.BindingNormalizedNodeCodecRegistry; +import org.opendaylight.mdsal.binding.generator.impl.GeneratedClassLoadingStrategy; +import org.opendaylight.mdsal.binding.generator.impl.ModuleInfoBackedContext; +import org.opendaylight.mdsal.binding.generator.util.JavassistUtils; +import org.opendaylight.yangtools.yang.binding.YangModuleInfo; + +/** + * Created by 10112215 on 2017/3/26. + */ +public class TransformJava2JsonFactory extends TYangJsonXmlBase { + BindingToNormalizedNodeCodec mappingservice; + ModuleInfoBackedContext moduleInfoBackedContext; + protected final static ControllerContext controllerContext = ControllerContext.getInstance(); + + public TransformJava2JsonServiceImpl getJava2jsonService() { + if (java2jsonService == null) { + try { + setup2(); + } catch (Exception e) { + e.printStackTrace(); + return null; + } + } + return java2jsonService; + } + + TransformJava2JsonServiceImpl java2jsonService; + + @Override + protected void setupWithDataBroker(final DataBroker dataBroker) { + // Intentionally left No-op, subclasses may customize it + mappingservice = new BindingToNormalizedNodeCodec(GeneratedClassLoadingStrategy.getTCCLClassLoadingStrategy(), + new BindingNormalizedNodeCodecRegistry(StreamWriterGenerator.create(JavassistUtils.forClassPool(ClassPool.getDefault())))); + moduleInfoBackedContext = ModuleInfoBackedContext.create(); + // moduleInfoBackedContext.registerModuleInfo(BindingReflections.getModuleInfo(SncTunnels.class)); + + try { + for (YangModuleInfo yangModuleInfo : getModuleInfos()) { + moduleInfoBackedContext.registerModuleInfo(yangModuleInfo); + } + } catch (Exception e) { + e.printStackTrace(); + } + schemaContext = moduleInfoBackedContext.tryToCreateSchemaContext().get(); + mappingservice.onGlobalContextUpdated(schemaContext); + controllerContext.setSchemas(schemaContext); + + } + + public final void setup2() throws Exception { + super.setup(); + if(java2jsonService==null) + java2jsonService = new TransformJava2JsonServiceImpl(mappingservice, schemaContext); + } +} diff --git a/common/src/main/java/org/openecomp/mso/yangDecoder/transform/impl/TransformJava2JsonServiceImpl.java b/common/src/main/java/org/openecomp/mso/yangDecoder/transform/impl/TransformJava2JsonServiceImpl.java new file mode 100644 index 0000000000..2009cff7de --- /dev/null +++ b/common/src/main/java/org/openecomp/mso/yangDecoder/transform/impl/TransformJava2JsonServiceImpl.java @@ -0,0 +1,93 @@ +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.*; +import org.slf4j.Logger; +import org.slf4j.LoggerFactory; + +/** + * Created by Administrator on 2017/3/20. + */ +public class TransformJava2JsonServiceImpl implements ITransformJava2StringService { + private static final Logger LOG = LoggerFactory.getLogger(TransformJava2JsonServiceImpl.class); + BindingNormalizedNodeSerializer mappingservice; + SchemaContext schemaContext; + YangDataTransformNN2JsonServiceImpl nn2jsonService; + YangDataTransformJava2NNServiceImpl java2nnService; + public TransformJava2JsonServiceImpl(BindingNormalizedNodeSerializer mappingservice, SchemaContext schemaContext){ + this.mappingservice=mappingservice; + this.schemaContext=schemaContext; + nn2jsonService=new YangDataTransformNN2JsonServiceImpl(); + java2nnService=new YangDataTransformJava2NNServiceImpl(mappingservice); + } + @Override + public String transformContrainerDataObjectToString(InstanceIdentifier instanceIdentifier, String uriPath,T dataObject) throws Exception { + // TODO Auto-generated method stub + NormalizedNode nn = java2nnService.yangDataObjecttoNN(instanceIdentifier, dataObject); + NormalizedNodeContext nnc = java2nnService.yangNNtoNNC(nn, uriPath); + String sjson = nn2jsonService.transformNNCToString(nnc); + return sjson; + } + @Override + public String transformNotificationToString(String uriPath,T notification)throws Exception { + NormalizedNode nn = mappingservice.toNormalizedNodeNotification(notification); + NormalizedNodeContext nnc = java2nnService.yangNNtoNNC(nn, uriPath); + String sjson = nn2jsonService.transformNNCToString(nnc); + return sjson; + } + @Override + public String transformRpcDataObjectToString(String uriPath,T dataObject) throws Exception { + NormalizedNode nn = mappingservice.toNormalizedNodeRpcData(dataObject); + NormalizedNodeContext nnc = java2nnService.yangNNtoNNC(nn, uriPath); + String sjson = nn2jsonService.transformNNCToString(nnc); + return sjson; + } + @Override + public DataObject transformContrainerDataObjectFromString(String uriPath,String sjson,boolean ispost) throws Exception { + NormalizedNodeContext nnc= nn2jsonService.transformDataObjectNNCFromString(uriPath,sjson,ispost); + return java2nnService.yangDataObjectfromNNC(nnc); + } + @Override + public Notification transformNotificationFromString(String notficationName,String sjson) throws Exception { + final InstanceIdentifierContext iicontext = ControllerContext.getInstance().toInstanceIdentifier(notficationName); + NormalizedNodeContext nnc= nn2jsonService.transformNotficationNNCFromString(notficationName,sjson); + ContainerNode contn= (ContainerNode)nnc.getData(); + return mappingservice.fromNormalizedNodeNotification(iicontext.getSchemaNode().getPath(),contn); + } + @Override + public DataObject transformRpcDataObjectFromString(String rpcName,String sjson) throws Exception { + final InstanceIdentifierContext iicontext = ControllerContext.getInstance().toInstanceIdentifier(rpcName); + NormalizedNodeContext nnc= nn2jsonService.transformRPCNNCFromString(rpcName,sjson); + return java2nnService.yangRpcDatafromNN(iicontext,nnc.getData()); + /* ContainerNode contn= (ContainerNode)nnc.getData(); + DataSchemaNode schemaNode; + final SchemaNode schemaNode0 = iicontext.getSchemaNode(); + boolean isInput = false; + if (schemaNode0 instanceof RpcDefinition) { + if (contn.getNodeType().getLocalName().contains("output")) { + schemaNode = ((RpcDefinition) schemaNode0).getOutput(); + isInput = false; + } else { + schemaNode = ((RpcDefinition) schemaNode0).getInput(); + isInput = true; + } + + } else if (schemaNode0 instanceof DataSchemaNode) { + schemaNode = (DataSchemaNode) schemaNode0; + } else { + throw new IllegalStateException("Unknow SchemaNode"); + } + return mappingservice.fromNormalizedNodeRpcData(schemaNode.getPath(),contn); */ + //return mappingservice.toNormalizedNodeRpcData((DataContainer) nnc.getData()); + // return java2nnService.yangDataObjectfromNNC(nnc); + } +} diff --git a/common/src/main/java/org/openecomp/mso/yangDecoder/transform/impl/TransformJava2XMLFactory.java b/common/src/main/java/org/openecomp/mso/yangDecoder/transform/impl/TransformJava2XMLFactory.java new file mode 100644 index 0000000000..5e5511b5e7 --- /dev/null +++ b/common/src/main/java/org/openecomp/mso/yangDecoder/transform/impl/TransformJava2XMLFactory.java @@ -0,0 +1,64 @@ +package org.openecomp.mso.yangDecoder.transform.impl; + +import javassist.ClassPool; +import org.openecomp.mso.yangDecoder.base.TYangJsonXmlBase; +import org.opendaylight.mdsal.binding.api.DataBroker; +import org.opendaylight.mdsal.binding.dom.adapter.BindingToNormalizedNodeCodec; +import org.opendaylight.netconf.sal.restconf.impl.ControllerContext; +import org.opendaylight.yangtools.binding.data.codec.gen.impl.StreamWriterGenerator; +import org.opendaylight.yangtools.binding.data.codec.impl.BindingNormalizedNodeCodecRegistry; +import org.opendaylight.mdsal.binding.generator.impl.GeneratedClassLoadingStrategy; +import org.opendaylight.mdsal.binding.generator.impl.ModuleInfoBackedContext; +import org.opendaylight.mdsal.binding.generator.util.JavassistUtils; +import org.opendaylight.yangtools.yang.binding.YangModuleInfo; + +/** + * Created by 10112215 on 2017/3/26. + */ +public class TransformJava2XMLFactory extends TYangJsonXmlBase { + BindingToNormalizedNodeCodec mappingservice; + ModuleInfoBackedContext moduleInfoBackedContext; + protected final static ControllerContext controllerContext = ControllerContext.getInstance(); + + public TransformJava2XMLServiceImpl getJava2xmlService() { + if (java2xmlService == null) { + try { + setup2(); + } catch (Exception e) { + e.printStackTrace(); + return null; + } + } + return java2xmlService; + } + + TransformJava2XMLServiceImpl java2xmlService; + + @Override + protected void setupWithDataBroker(final DataBroker dataBroker) { + // Intentionally left No-op, subclasses may customize it + mappingservice = new BindingToNormalizedNodeCodec(GeneratedClassLoadingStrategy.getTCCLClassLoadingStrategy(), + new BindingNormalizedNodeCodecRegistry(StreamWriterGenerator.create(JavassistUtils.forClassPool(ClassPool.getDefault())))); + moduleInfoBackedContext = ModuleInfoBackedContext.create(); + // moduleInfoBackedContext.registerModuleInfo(BindingReflections.getModuleInfo(SncTunnels.class)); + try { + for (YangModuleInfo yangModuleInfo : getModuleInfos()) { + moduleInfoBackedContext.registerModuleInfo(yangModuleInfo); + } + } catch (Exception e) { + e.printStackTrace(); + } + schemaContext = moduleInfoBackedContext.tryToCreateSchemaContext().get(); + mappingservice.onGlobalContextUpdated(schemaContext); + controllerContext.setSchemas(schemaContext); + + } + + public final void setup2() throws Exception { + super.setup(); + if(java2xmlService==null) + java2xmlService = new TransformJava2XMLServiceImpl(mappingservice, schemaContext); + } + + +} 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 String transformContrainerDataObjectToString(InstanceIdentifier 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 String transformNotificationToString(String uriPath, T notification) + throws Exception { + NormalizedNode nn= mappingservice.toNormalizedNodeNotification(notification); + return yangODLnn2xml.yangNNtoXML(uriPath,nn); + } + @Override + public String transformRpcDataObjectToString(String uriPath, T dataObject) + throws Exception { + NormalizedNode nn=mappingservice.toNormalizedNodeRpcData(dataObject); + return yangODLnn2xml.yangNNtoXML(uriPath,nn); + } + //for container + public String transformContrainerDataObjectToString(InstanceIdentifier instanceIdentifier, T dataObject) { + // TODO Auto-generated method stub + NormalizedNode nn=java2nnService.yangDataObjecttoNN(instanceIdentifier,dataObject); + return nn2xmlService.transformNNToString(nn); + } + + public String transformNotificationToString(T notification) { + NormalizedNode nn= mappingservice.toNormalizedNodeNotification(notification); + return nn2xmlService.transformNNToString(nn); + } + + //for rpc + public 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, 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, 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 nnentry = nn2xmlService.transformRpcNNEntryfromString(sxml,iicontext); + ContainerNode rpc = (ContainerNode) nnentry.getValue(); + DataObject rpcdata= mappingservice.fromNormalizedNodeRpcData(nnentry.getKey().getPath(),rpc); + return rpcdata; + } +} diff --git a/common/src/main/java/org/openecomp/mso/yangDecoder/transform/impl/TransfromJava2StringFactory.java b/common/src/main/java/org/openecomp/mso/yangDecoder/transform/impl/TransfromJava2StringFactory.java new file mode 100644 index 0000000000..e5e5d65606 --- /dev/null +++ b/common/src/main/java/org/openecomp/mso/yangDecoder/transform/impl/TransfromJava2StringFactory.java @@ -0,0 +1,55 @@ +package org.openecomp.mso.yangDecoder.transform.impl; + +import org.dom4j.DocumentException; +import org.dom4j.DocumentHelper; +import org.openecomp.mso.yangDecoder.transform.api.ITransformJava2StringService; + +/** + * Created by 10112215 on 2017/3/24. + */ +public class TransfromJava2StringFactory { + + private static TransformJava2JsonServiceImpl java2jsonService = (new TransformJava2JsonFactory()).getJava2jsonService(); + + private static TransformJava2XMLServiceImpl java2XMLService/* = (new TransformJava2XMLFactory()).getJava2xmlService()*/; + + public static boolean isXML(String value) { + try { + DocumentHelper.parseText(value); + } catch (DocumentException e) { + return false; + } + return true; + } + + public static ITransformJava2StringService getJava2StringService(String input) throws Exception { + ITransformJava2StringService java2jsonService; + if (isXML(input)) { + java2jsonService = getJava2XMLService(); + } else { + java2jsonService = getJava2jsonService(); + } + return java2jsonService; + } + + public static void init() { + // do no shit for static initialization + } + + public static ITransformJava2StringService getJava2jsonService() throws Exception { + if (java2jsonService == null) { + TransformJava2JsonFactory transformJava2JsonFactory = new TransformJava2JsonFactory(); + java2jsonService = transformJava2JsonFactory.getJava2jsonService(); + } + return java2jsonService; + } + + public static ITransformJava2StringService getJava2XMLService() throws Exception { + if (java2XMLService == null) { + TransformJava2XMLFactory transformJava2XMLFactory = new TransformJava2XMLFactory(); + java2XMLService = transformJava2XMLFactory.getJava2xmlService(); + } + return java2XMLService; + } + +} diff --git a/common/src/main/java/org/openecomp/mso/yangDecoder/transform/impl/XmlNormalizedNodeBodyReaderUmeImpl.java b/common/src/main/java/org/openecomp/mso/yangDecoder/transform/impl/XmlNormalizedNodeBodyReaderUmeImpl.java new file mode 100644 index 0000000000..e1ebf95a06 --- /dev/null +++ b/common/src/main/java/org/openecomp/mso/yangDecoder/transform/impl/XmlNormalizedNodeBodyReaderUmeImpl.java @@ -0,0 +1,24 @@ +package org.openecomp.mso.yangDecoder.transform.impl; + +import org.opendaylight.netconf.sal.rest.impl.XmlNormalizedNodeBodyReader; +import org.opendaylight.netconf.sal.restconf.impl.InstanceIdentifierContext; + +public class XmlNormalizedNodeBodyReaderUmeImpl extends + XmlNormalizedNodeBodyReader { + InstanceIdentifierContext iic; + boolean ispost=false; + @Override + protected InstanceIdentifierContext getInstanceIdentifierContext() { + return iic; + } + @Override + protected boolean isPost() { + return ispost; + } + public void Set(InstanceIdentifierContext iic,boolean ispost) + { + this.iic=iic; + this.ispost=ispost; + } + +} diff --git a/common/src/main/java/org/openecomp/mso/yangDecoder/transform/impl/YangDataTransformJava2NNServiceImpl.java b/common/src/main/java/org/openecomp/mso/yangDecoder/transform/impl/YangDataTransformJava2NNServiceImpl.java new file mode 100644 index 0000000000..ba82aa5539 --- /dev/null +++ b/common/src/main/java/org/openecomp/mso/yangDecoder/transform/impl/YangDataTransformJava2NNServiceImpl.java @@ -0,0 +1,144 @@ +package org.openecomp.mso.yangDecoder.transform.impl; + +//import org.opendaylight.mdsal.binding.dom.adapter.BindingToNormalizedNodeCodec; + +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.netconf.sal.restconf.impl.WriterParameters; +import org.opendaylight.yangtools.binding.data.codec.api.BindingNormalizedNodeSerializer; +import org.opendaylight.yangtools.yang.binding.DataContainer; +import org.opendaylight.yangtools.yang.binding.DataObject; +import org.opendaylight.yangtools.yang.binding.InstanceIdentifier; +import org.opendaylight.yangtools.yang.data.api.YangInstanceIdentifier; +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.*; + +import java.util.Map; + +/** + * Created by Administrator on 2017/3/17. + */ +public class YangDataTransformJava2NNServiceImpl { + BindingNormalizedNodeSerializer mappingService; + public YangDataTransformJava2NNServiceImpl(BindingNormalizedNodeSerializer mappingService) + { + this.mappingService=mappingService; + } + public NormalizedNodeContext yangDataObjecttoNNC(InstanceIdentifier identifier, String uri, T dobj) + { + final InstanceIdentifierContext iiContext = ControllerContext.getInstance().toInstanceIdentifier(uri); + Map.Entry> temp = mappingService.toNormalizedNode(identifier, dobj); + WriterParameters.WriterParametersBuilder aa=new WriterParameters.WriterParametersBuilder(); + aa.setPrettyPrint(true); + return new NormalizedNodeContext( iiContext, temp.getValue() ,aa.build()); + } + public NormalizedNode yangDataObjecttoNN( InstanceIdentifier identifier,T dobj) { + Map.Entry> temp = mappingService.toNormalizedNode(identifier, dobj); + if (null == temp) { + return null; + } else { + return temp.getValue(); + } + } + public NormalizedNodeContext yangNNtoNNC(NormalizedNode nn, String uri){ + final InstanceIdentifierContext iiContext = ControllerContext.getInstance().toInstanceIdentifier(uri); + WriterParameters.WriterParametersBuilder aa=new WriterParameters.WriterParametersBuilder(); + aa.setPrettyPrint(true); + return new NormalizedNodeContext(iiContext, nn,aa.build()); + } + public T yangDataObjectfromNN(YangInstanceIdentifier identifier,NormalizedNode node) { + Map.Entry, DataObject> temp = mappingService.fromNormalizedNode(identifier, node); + if (null == temp) { + return null; + } else { + return (T) temp.getValue(); + } + } + public T yangDataObjectfromNNC(NormalizedNodeContext nnc) + { + return yangDataObjectfromNN(nnc.getInstanceIdentifierContext().getInstanceIdentifier(),nnc.getData()); + } + public ContainerNode yangRpcDatatoNN(final DataContainer rpcdata){ + return mappingService.toNormalizedNodeRpcData(rpcdata); + } + public DataObject yangRpcDatafromNN(SchemaPath path, final ContainerNode data) + { + return mappingService.fromNormalizedNodeRpcData(path,data); + } + public static DataSchemaNode findDataSchemaNode(String uriPath,String inputoroutput) + { + final InstanceIdentifierContext iicontext = ControllerContext.getInstance().toInstanceIdentifier(uriPath); + DataSchemaNode dsn=JsonParserStream.getWrapSchemaNode( iicontext.getSchemaNode()); + return dsn; + } + public static SchemaNode findSchemaNode(final InstanceIdentifierContext iicontext ,String inputoroutput) + { + SchemaNode schemaNode; + + final SchemaNode schemaNode0 = iicontext.getSchemaNode(); + if (schemaNode0 instanceof RpcDefinition) { + if (inputoroutput.contains("output")) { + schemaNode = ((RpcDefinition) schemaNode0).getOutput(); + } else { + schemaNode = ((RpcDefinition) schemaNode0).getInput(); + } + + } else if(schemaNode0 instanceof NotificationDefinition) + { + schemaNode=schemaNode0; + } + else if (schemaNode0 instanceof DataSchemaNode) { + schemaNode = schemaNode0; + } else { + throw new IllegalStateException("Unknow SchemaNode"); + } + return schemaNode; + } + + public static DataSchemaNode findRpcSchemaNode(final InstanceIdentifierContext iicontext,String inputoroutput) + { + DataSchemaNode schemaNode; + final SchemaNode schemaNode0 = iicontext.getSchemaNode(); + boolean isInput = false; + if (schemaNode0 instanceof RpcDefinition) { + if (inputoroutput.contains("output")) { + schemaNode = ((RpcDefinition) schemaNode0).getOutput(); + isInput = false; + } else { + schemaNode = ((RpcDefinition) schemaNode0).getInput(); + isInput = true; + } + + } else if (schemaNode0 instanceof DataSchemaNode) { + schemaNode = (DataSchemaNode) schemaNode0; + } else { + throw new IllegalStateException("Unknow SchemaNode"); + } + return schemaNode; + } + public DataObject yangRpcDatafromNN(final InstanceIdentifierContext iicontext , final NormalizedNode data) { + // final InstanceIdentifierContext iicontext = ControllerContext.getInstance().toInstanceIdentifier(uriPath); + ContainerNode contn= (ContainerNode)data; + DataSchemaNode schemaNode= findRpcSchemaNode(iicontext,contn.getNodeType().getLocalName());; + /* final SchemaNode schemaNode0 = iicontext.getSchemaNode(); + boolean isInput = false; + if (schemaNode0 instanceof RpcDefinition) { + if (contn.getNodeType().getLocalName().contains("output")) { + schemaNode = ((RpcDefinition) schemaNode0).getOutput(); + isInput = false; + } else { + schemaNode = ((RpcDefinition) schemaNode0).getInput(); + isInput = true; + } + + } else if (schemaNode0 instanceof DataSchemaNode) { + schemaNode = (DataSchemaNode) schemaNode0; + } else { + throw new IllegalStateException("Unknow SchemaNode"); + }*/ + SchemaPath path=schemaNode.getPath(); + return mappingService.fromNormalizedNodeRpcData(path,contn); + } +} diff --git a/common/src/main/java/org/openecomp/mso/yangDecoder/transform/impl/YangDataTransformNN2JsonServiceImpl.java b/common/src/main/java/org/openecomp/mso/yangDecoder/transform/impl/YangDataTransformNN2JsonServiceImpl.java new file mode 100644 index 0000000000..dba4a0dea5 --- /dev/null +++ b/common/src/main/java/org/openecomp/mso/yangDecoder/transform/impl/YangDataTransformNN2JsonServiceImpl.java @@ -0,0 +1,50 @@ +package org.openecomp.mso.yangDecoder.transform.impl; + +import com.google.common.base.Charsets; +import org.opendaylight.netconf.sal.rest.impl.JsonNormalizedNodeBodyReader; +import org.opendaylight.netconf.sal.rest.impl.NormalizedNodeJsonBodyWriter; +import org.opendaylight.netconf.sal.restconf.impl.NormalizedNodeContext; +import org.slf4j.Logger; +import org.slf4j.LoggerFactory; + +import javax.ws.rs.core.MediaType; +import java.io.ByteArrayInputStream; +import java.io.ByteArrayOutputStream; +import java.io.IOException; +import java.io.InputStream; +import java.lang.annotation.Annotation; + +/** + * Created by Administrator on 2017/3/17. + */ +public class YangDataTransformNN2JsonServiceImpl { + private static final Logger LOG = LoggerFactory.getLogger(YangDataTransformNN2JsonServiceImpl.class); + private static final Annotation[] EMPTY_ANNOTATIONS = new Annotation[0]; + + public NormalizedNodeContext transformNNCFromString(String uriPath,String jsonpayload,boolean isPost){ + + InputStream entityStream = new ByteArrayInputStream(jsonpayload.getBytes(Charsets.UTF_8)); + NormalizedNodeContext normalnodes3 = JsonNormalizedNodeBodyReader.readFrom(uriPath, entityStream, isPost); + return normalnodes3; + } + public String transformNNCToString(NormalizedNodeContext readData) throws IOException { + NormalizedNodeJsonBodyWriter writer = new NormalizedNodeJsonBodyWriter(); + ByteArrayOutputStream outputStream = new ByteArrayOutputStream(); + //readData.getWriterParameters().isPrettyPrint() + writer.writeTo(readData, NormalizedNodeContext.class, null, EMPTY_ANNOTATIONS, + MediaType.APPLICATION_JSON_TYPE, null, outputStream ); + return outputStream.toString(Charsets.UTF_8.name()); + } + public NormalizedNodeContext transformRPCNNCFromString(String uriPath,String jsonpayload) + { + return transformNNCFromString(uriPath,jsonpayload,true); + } + public NormalizedNodeContext transformDataObjectNNCFromString(String uriPath,String jsonpayload,boolean ispost) + { + return transformNNCFromString(uriPath,jsonpayload,ispost); + } + public NormalizedNodeContext transformNotficationNNCFromString(String uriPath,String jsonpayload) + { + return transformNNCFromString(uriPath,jsonpayload,true); + } +} diff --git a/common/src/main/java/org/openecomp/mso/yangDecoder/transform/impl/YangDataTransformNN2XMLServiceImpl.java b/common/src/main/java/org/openecomp/mso/yangDecoder/transform/impl/YangDataTransformNN2XMLServiceImpl.java new file mode 100644 index 0000000000..d147a803cc --- /dev/null +++ b/common/src/main/java/org/openecomp/mso/yangDecoder/transform/impl/YangDataTransformNN2XMLServiceImpl.java @@ -0,0 +1,253 @@ +package org.openecomp.mso.yangDecoder.transform.impl; + +import com.google.common.base.Charsets; +import com.google.common.base.Preconditions; +import com.google.common.collect.Lists; +import org.opendaylight.netconf.sal.restconf.impl.ControllerContext; +import org.opendaylight.netconf.sal.restconf.impl.InstanceIdentifierContext; +import org.opendaylight.yangtools.binding.data.codec.api.BindingNormalizedNodeSerializer; +import org.opendaylight.yangtools.yang.data.api.YangInstanceIdentifier; +import org.opendaylight.yangtools.yang.data.api.schema.NormalizedNode; +import org.opendaylight.yangtools.yang.data.impl.schema.transform.dom.DomUtils; +import org.opendaylight.yangtools.yang.data.impl.schema.transform.dom.parser.DomToNormalizedNodeParserFactory; +import org.opendaylight.yangtools.yang.model.api.*; +import org.slf4j.Logger; +import org.slf4j.LoggerFactory; +import org.w3c.dom.Document; +import org.w3c.dom.Element; +import org.xml.sax.SAXException; + +import javax.xml.parsers.DocumentBuilder; +import javax.xml.parsers.DocumentBuilderFactory; +import javax.xml.parsers.ParserConfigurationException; +import javax.xml.stream.XMLOutputFactory; +import java.io.ByteArrayInputStream; +import java.io.IOException; +import java.io.InputStream; +import java.util.AbstractMap.SimpleEntry; +import java.util.ArrayList; +import java.util.Collections; +import java.util.List; +import java.util.Map; + +import static org.openecomp.mso.yangDecoder.transform.impl.JsonParserStream.getWrapSchemaNode; + +public class YangDataTransformNN2XMLServiceImpl { + private static final XMLOutputFactory XML_FACTORY; + private static final DocumentBuilderFactory BUILDERFACTORY; + static { + XML_FACTORY = XMLOutputFactory.newFactory(); + XML_FACTORY.setProperty(XMLOutputFactory.IS_REPAIRING_NAMESPACES, false); + final DocumentBuilderFactory factory = DocumentBuilderFactory.newInstance(); + factory.setNamespaceAware(true); + factory.setCoalescing(true); + factory.setIgnoringElementContentWhitespace(true); + factory.setIgnoringComments(true); + BUILDERFACTORY = factory; + } + BindingNormalizedNodeSerializer mappingservice; + SchemaContext schemaContext; + private static final Logger LOG = LoggerFactory.getLogger(YangDataTransformNN2XMLServiceImpl.class); + + public YangDataTransformNN2XMLServiceImpl(BindingNormalizedNodeSerializer mappingservice, SchemaContext context ) { + + this.schemaContext = context; + this.mappingservice=mappingservice; + } + + public String transformNNToString(NormalizedNode nn) + { + StringBuilder stringBuilder = new StringBuilder(); + stringBuilder.append(YangOdlNNC2XMLImpl.getXMLHeader()); + new NormalizedNodeNavigator(new NormalizedNodePrinter(stringBuilder)).navigate(null, nn); + return stringBuilder.toString(); + } + + + public static DataSchemaNode getSchemaNodebyNs(final SchemaContext context, final String ns, final String childNodeName) { + for (Module module : context.getModules()) { + if (module.getNamespace().toString().equals(ns)) { + DataSchemaNode found = findChildNode(module.getChildNodes(), childNodeName); + Preconditions.checkState(found != null, "Unable to find %s", childNodeName); + return found; + } + } + throw new IllegalStateException("Unable to find child node " + childNodeName); + } + private static DataSchemaNode findChildNode(final Iterable children, final String name) { + List containers = Lists.newArrayList(); + + for (DataSchemaNode dataSchemaNode : children) { + if (dataSchemaNode.getQName().getLocalName().equals(name)) { + return dataSchemaNode; + } + if (dataSchemaNode instanceof DataNodeContainer) { + containers.add((DataNodeContainer) dataSchemaNode); + } else if (dataSchemaNode instanceof ChoiceSchemaNode) { + containers.addAll(((ChoiceSchemaNode) dataSchemaNode).getCases()); + } + } + + for (DataNodeContainer container : containers) { + DataSchemaNode retVal = findChildNode(container.getChildNodes(), name); + if (retVal != null) { + return retVal; + } + } + + return null; + } + public NormalizedNode transformNNFromString(String sxml) throws Exception { + InputStream in_nocode = new ByteArrayInputStream(sxml.getBytes(Charsets.UTF_8));//.getBytes("UTF-8") + //xml2nn + final Document docxml = readXmlToDocument(in_nocode); + Element element0 = docxml.getDocumentElement(); + String localname = element0.getNodeName(); + String ns = element0.getAttribute("xmlns"); + // final ContainerSchemaNode containerNodex = (ContainerSchemaNode)null; + final DataSchemaNode dsn=getSchemaNodebyNs(schemaContext, ns, localname); + //cn.getNodeType().getNamespace().toString(), cn.getNodeType().getLocalName()); + DomToNormalizedNodeParserFactory parserFactory =DomToNormalizedNodeParserFactory.getInstance(DomUtils.defaultValueCodecProvider(), schemaContext); + NormalizedNode parsed = null; + final List elements = Collections.singletonList(docxml.getDocumentElement()); + if (dsn instanceof ContainerSchemaNode) { + parsed= parserFactory.getContainerNodeParser().parse(elements, (ContainerSchemaNode)dsn); + }else if (dsn instanceof ListSchemaNode) { + final ListSchemaNode casted = (ListSchemaNode) dsn; + parsed=parserFactory.getMapEntryNodeParser().parse(elements, casted); + } + return parsed; + + } + + + + public NormalizedNode transformNotificationNNfromString(String sxml, final InstanceIdentifierContext iicontext) throws Exception + { + SchemaNode schemaNode = getWrapSchemaNode(iicontext.getSchemaNode()); + InputStream in_nocode = new ByteArrayInputStream(sxml.getBytes(Charsets.UTF_8));//.getBytes("UTF-8") + //xml2nn + final Document docxml = readXmlToDocument(in_nocode); + Element element0 = docxml.getDocumentElement(); + String localname = element0.getNodeName(); + String ns = element0.getAttribute("xmlns"); + // final ContainerSchemaNode containerNodex = (ContainerSchemaNode)null; + // final DataSchemaNode dsn=(DataSchemaNode)schemaNode;/*getSchemaNodebyNs(schemaContext, ns, localname);*/ + //cn.getNodeType().getNamespace().toString(), cn.getNodeType().getLocalName()); + DomToNormalizedNodeParserFactory parserFactory =DomToNormalizedNodeParserFactory.getInstance(DomUtils.defaultValueCodecProvider(), schemaContext); + NormalizedNode parsed = null; + final List elements = Collections.singletonList(docxml.getDocumentElement()); + if (schemaNode instanceof ContainerSchemaNode) { + parsed= parserFactory.getContainerNodeParser().parse(elements, (ContainerSchemaNode)schemaNode); + }else if (schemaNode instanceof ListSchemaNode) { + final ListSchemaNode casted = (ListSchemaNode) schemaNode; + parsed=parserFactory.getMapEntryNodeParser().parse(elements, casted); + } + return parsed; + } + public NormalizedNode transformNotificationStringtoNN(String sxml,String notficationName) throws Exception { + final InstanceIdentifierContext iicontext= ControllerContext.getInstance().toInstanceIdentifier(notficationName); + return transformNotificationNNfromString(sxml,iicontext); + } + public Map.Entry transformRpcNNEntryfromString(String sxml, final InstanceIdentifierContext iirpccontext) throws Exception{ + InputStream in_nocode = new ByteArrayInputStream(sxml.getBytes(Charsets.UTF_8));//.getBytes("UTF-8") + //xml2nn + final Document docxml = readXmlToDocument(in_nocode); + Element element0 = docxml.getDocumentElement(); + String localname = element0.getNodeName(); + String ns = element0.getAttribute("xmlns"); + DataSchemaNode schemaNode; + final SchemaNode schemaNode0 = iirpccontext.getSchemaNode(); + boolean isInput = false; + if (schemaNode0 instanceof RpcDefinition) { + if (docxml.getDocumentElement().getLocalName().contains("output")) { + schemaNode = ((RpcDefinition) schemaNode0).getOutput(); + isInput = false; + } else { + schemaNode = ((RpcDefinition) schemaNode0).getInput(); + isInput = true; + } + + } else if (docxml instanceof DataSchemaNode) { + schemaNode = (DataSchemaNode) docxml; + } else { + throw new IllegalStateException("Unknow SchemaNode"); + } + + final List iiToDataList = new ArrayList<>(); + InstanceIdentifierContext outIIContext; + // final ContainerSchemaNode containerNodex = (ContainerSchemaNode)null; + // final DataSchemaNode dsn=(DataSchemaNode)schemaNode;/*getSchemaNodebyNs(schemaContext, ns, localname);*/ + //cn.getNodeType().getNamespace().toString(), cn.getNodeType().getLocalName()); + DomToNormalizedNodeParserFactory parserFactory =DomToNormalizedNodeParserFactory.getInstance(DomUtils.defaultValueCodecProvider(), schemaContext); + NormalizedNode parsed = null; + final List elements = Collections.singletonList(docxml.getDocumentElement()); + if (schemaNode instanceof ContainerSchemaNode) { + parsed= parserFactory.getContainerNodeParser().parse(elements, (ContainerSchemaNode)schemaNode); + }else if (schemaNode instanceof ListSchemaNode) { + final ListSchemaNode casted = (ListSchemaNode) schemaNode; + parsed=parserFactory.getMapEntryNodeParser().parse(elements, casted); + } + return new SimpleEntry(schemaNode,parsed); + } + public NormalizedNode transformRpcNNfromString(String sxml, final InstanceIdentifierContext iirpccontext) throws Exception{ + + InputStream in_nocode = new ByteArrayInputStream(sxml.getBytes(Charsets.UTF_8));//.getBytes("UTF-8") + //xml2nn + final Document docxml = readXmlToDocument(in_nocode); + Element element0 = docxml.getDocumentElement(); + String localname = element0.getNodeName(); + String ns = element0.getAttribute("xmlns"); + DataSchemaNode schemaNode; + final SchemaNode schemaNode0 = iirpccontext.getSchemaNode(); + boolean isInput = false; + if (schemaNode0 instanceof RpcDefinition) { + if (docxml.getDocumentElement().getLocalName().contains("output")) { + schemaNode = ((RpcDefinition) schemaNode0).getOutput(); + isInput = false; + } else { + schemaNode = ((RpcDefinition) schemaNode0).getInput(); + isInput = true; + } + + } else if (docxml instanceof DataSchemaNode) { + schemaNode = (DataSchemaNode) docxml; + } else { + throw new IllegalStateException("Unknow SchemaNode"); + } + + final List iiToDataList = new ArrayList<>(); + InstanceIdentifierContext outIIContext; + // final ContainerSchemaNode containerNodex = (ContainerSchemaNode)null; + // final DataSchemaNode dsn=(DataSchemaNode)schemaNode;/*getSchemaNodebyNs(schemaContext, ns, localname);*/ + //cn.getNodeType().getNamespace().toString(), cn.getNodeType().getLocalName()); + DomToNormalizedNodeParserFactory parserFactory =DomToNormalizedNodeParserFactory.getInstance(DomUtils.defaultValueCodecProvider(), schemaContext); + NormalizedNode parsed = null; + final List elements = Collections.singletonList(docxml.getDocumentElement()); + if (schemaNode instanceof ContainerSchemaNode) { + parsed= parserFactory.getContainerNodeParser().parse(elements, (ContainerSchemaNode)schemaNode); + }else if (schemaNode instanceof ListSchemaNode) { + final ListSchemaNode casted = (ListSchemaNode) schemaNode; + parsed=parserFactory.getMapEntryNodeParser().parse(elements, casted); + } + return parsed; + } + public NormalizedNode transformRpcNNfromString(String sxml, String rpcName) throws Exception { + final InstanceIdentifierContext iicontext= ControllerContext.getInstance().toInstanceIdentifier(rpcName); + return this.transformRpcNNfromString(sxml,iicontext); + + } + public static Document readXmlToDocument(final InputStream xmlContent) throws IOException, SAXException { + final DocumentBuilder dBuilder; + try { + dBuilder = BUILDERFACTORY.newDocumentBuilder(); + } catch (final ParserConfigurationException e) { + throw new RuntimeException("Failed to parse XML document", e); + } + final Document doc = dBuilder.parse(xmlContent); + + doc.getDocumentElement().normalize(); + return doc; + } + +} diff --git a/common/src/main/java/org/openecomp/mso/yangDecoder/transform/impl/YangOdlNN2XMLImpl.java b/common/src/main/java/org/openecomp/mso/yangDecoder/transform/impl/YangOdlNN2XMLImpl.java new file mode 100644 index 0000000000..96cd840d44 --- /dev/null +++ b/common/src/main/java/org/openecomp/mso/yangDecoder/transform/impl/YangOdlNN2XMLImpl.java @@ -0,0 +1,106 @@ +package org.openecomp.mso.yangDecoder.transform.impl; + +import org.opendaylight.netconf.sal.restconf.impl.ControllerContext; +import org.opendaylight.netconf.sal.restconf.impl.InstanceIdentifierContext; +import org.opendaylight.yangtools.yang.data.api.schema.NormalizedNode; +import org.opendaylight.yangtools.yang.data.api.schema.stream.NormalizedNodeStreamWriter; +import org.opendaylight.yangtools.yang.data.api.schema.stream.NormalizedNodeWriter; +import org.opendaylight.yangtools.yang.data.impl.codec.xml.XMLStreamNormalizedNodeStreamWriter; +import org.opendaylight.yangtools.yang.data.impl.codec.xml.XmlDocumentUtils; +import org.opendaylight.yangtools.yang.model.api.SchemaContext; +import org.opendaylight.yangtools.yang.model.api.SchemaNode; +import org.opendaylight.yangtools.yang.model.api.SchemaPath; +import org.w3c.dom.Document; +import org.w3c.dom.Node; + +import javax.xml.stream.XMLOutputFactory; +import javax.xml.stream.XMLStreamException; +import javax.xml.stream.XMLStreamWriter; +import javax.xml.transform.*; +import javax.xml.transform.dom.DOMResult; +import javax.xml.transform.dom.DOMSource; +import javax.xml.transform.stream.StreamResult; +import java.io.IOException; +import java.io.StringWriter; + +/** + * Created by Administrator on 2017/3/21. + */ +public class YangOdlNN2XMLImpl { + private static final XMLOutputFactory XML_FACTORY; + static { + XML_FACTORY = XMLOutputFactory.newFactory(); + XML_FACTORY.setProperty(XMLOutputFactory.IS_REPAIRING_NAMESPACES, false); + } + SchemaContext schemaContext; + public YangOdlNN2XMLImpl(SchemaContext schemaContext){ + this.schemaContext=schemaContext; + } + //general for contain/listitem/rpc/notification + public String yangNNtoXML(String uriPath,NormalizedNode nn) throws Exception { + final InstanceIdentifierContext iicontext = ControllerContext.getInstance().toInstanceIdentifier(uriPath); + SchemaNode snode = YangDataTransformJava2NNServiceImpl.findSchemaNode(iicontext, nn.getNodeType().getLocalName()); + String strx = snode.toString(); + SchemaPath path = snode.getPath(); + int it=uriPath.lastIndexOf("/"); + if (strx.contains("container ")&&(it<0)) { + // path = SchemaPath.create(true); + } + String sxml =writeNormalizedNodetoXml(nn,path,schemaContext); + return sxml; + } + public static String writeNormalizedNodetoXml(final NormalizedNode cn, + final SchemaPath schemaPath, final SchemaContext schemaContext) + { + + String serializationResultXMLString = null; + try { + //nn2xml + final Document doc = XmlDocumentUtils.getDocument(); + final DOMResult serializationResult = new DOMResult(doc); + writeNormalizedNode(cn,serializationResult,schemaPath, schemaContext); + serializationResultXMLString = toString(serializationResult.getNode()); + } catch (IOException |XMLStreamException e) { + e.printStackTrace(); + } + return serializationResultXMLString; + } + public static void writeNormalizedNode(final NormalizedNode normalized, final DOMResult result, + final SchemaPath schemaPath, final SchemaContext context) throws IOException, XMLStreamException { + NormalizedNodeWriter normalizedNodeWriter = null; + NormalizedNodeStreamWriter normalizedNodeStreamWriter = null; + XMLStreamWriter writer = null; + try { + writer = XML_FACTORY.createXMLStreamWriter(result); + normalizedNodeStreamWriter = XMLStreamNormalizedNodeStreamWriter.create(writer, context, schemaPath); + normalizedNodeWriter = NormalizedNodeWriter.forStreamWriter(normalizedNodeStreamWriter); + + normalizedNodeWriter.write(normalized); + + normalizedNodeWriter.flush(); + } finally { + if (normalizedNodeWriter != null) { + normalizedNodeWriter.close(); + } + if (normalizedNodeStreamWriter != null) { + normalizedNodeStreamWriter.close(); + } + if (writer != null) { + writer.close(); + } + } + } + public static String toString(final Node xml) { + try { + final Transformer transformer = TransformerFactory.newInstance().newTransformer(); + transformer.setOutputProperty(OutputKeys.INDENT, "yes"); + transformer.setOutputProperty("{http://xml.apache.org/xslt}indent-amount", "4"); + final StreamResult result = new StreamResult(new StringWriter()); + final DOMSource source = new DOMSource(xml); + transformer.transform(source, result); + return result.getWriter().toString(); + } catch (IllegalArgumentException | TransformerFactoryConfigurationError | TransformerException e) { + throw new RuntimeException("Unable to serialize xml element " + xml, e); + } + } +} diff --git a/common/src/main/java/org/openecomp/mso/yangDecoder/transform/impl/YangOdlNNC2XMLImpl.java b/common/src/main/java/org/openecomp/mso/yangDecoder/transform/impl/YangOdlNNC2XMLImpl.java new file mode 100644 index 0000000000..8db6cd954c --- /dev/null +++ b/common/src/main/java/org/openecomp/mso/yangDecoder/transform/impl/YangOdlNNC2XMLImpl.java @@ -0,0 +1,64 @@ +package org.openecomp.mso.yangDecoder.transform.impl; + +import com.google.common.base.Charsets; +import org.opendaylight.netconf.sal.rest.impl.NormalizedNodeXmlBodyWriter; +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.netconf.sal.restconf.impl.WriterParameters; + +import javax.ws.rs.core.MediaType; +import java.io.ByteArrayInputStream; +import java.io.ByteArrayOutputStream; +import java.io.InputStream; +import java.io.OutputStream; +import java.lang.reflect.Field; + +public class YangOdlNNC2XMLImpl { + final static MediaType mediaType=getMediaType(); + static protected MediaType getMediaType() { + return new MediaType(MediaType.APPLICATION_XML, null); + } + static Field requestField=getprettyPrintField(); + + private static Field getprettyPrintField( ) + { + Field rf=null; + try { + rf = WriterParameters.class.getDeclaredField("prettyPrint"); + rf.setAccessible(true); + } catch (NoSuchFieldException | SecurityException e) { + // TODO Auto-generated catch block + e.printStackTrace(); + } + return rf; + } + public static String getXMLHeader() + { + return ""+NormalizedNodePrinter.getEndl(); + } + public static String toXML(final NormalizedNodeContext normalizedNodeContext) throws Exception + { + final NormalizedNodeXmlBodyWriter xmlBodyWriter = new NormalizedNodeXmlBodyWriter(); + final OutputStream output = new ByteArrayOutputStream(); + requestField.set(normalizedNodeContext.getWriterParameters(), true); + output.write(getXMLHeader().getBytes(Charsets.UTF_8)); + xmlBodyWriter.writeTo(normalizedNodeContext, null, null, null, + mediaType, null, output); + final String outputXML = output.toString(); + return outputXML; + } + + public static NormalizedNodeContext fromXML(String uriPath,final String xmlpayload,boolean ispost) throws Exception + { + final InstanceIdentifierContext iicontext = ControllerContext.getInstance().toInstanceIdentifier(uriPath); + InputStream inputStream = new ByteArrayInputStream(xmlpayload.getBytes(Charsets.UTF_8)); + XmlNormalizedNodeBodyReaderUmeImpl xmlBodyReader = new XmlNormalizedNodeBodyReaderUmeImpl(); + xmlBodyReader.Set(iicontext, ispost); +// final NormalizedNodeContext returnValue = xmlBodyReader.readFrom(iicontext, inputStream); + final NormalizedNodeContext returnValue = xmlBodyReader.readFrom(null, + null, null, mediaType, null, inputStream); + return returnValue; + } + +} -- 2.16.6