Code Review / netconf.git / blobdiff
? search:
summary | shortlog | log | commit | commitdiff | review | tree
raw | inline | side by side
Remove unused exceptions
[netconf.git] / netconf / mdsal-netconf-yang-library / src / main / java / org / opendaylight / netconf / mdsal / yang / library / SchemaServiceToMdsalWriter.java
diff --git a/netconf/mdsal-netconf-yang-library/src/main/java/org/opendaylight/netconf/mdsal/yang/library/SchemaServiceToMdsalWriter.java b/netconf/mdsal-netconf-yang-library/src/main/java/org/opendaylight/netconf/mdsal/yang/library/SchemaServiceToMdsalWriter.java
index d0d383a2bb0dbfe28f2d59ef3cf94f4dc2aa163b..5fe60f91ff9c3d2201dea3d21dd68884fe5d60ed 100644 (file)
--- a/netconf/mdsal-netconf-yang-library/src/main/java/org/opendaylight/netconf/mdsal/yang/library/SchemaServiceToMdsalWriter.java
+++ b/netconf/mdsal-netconf-yang-library/src/main/java/org/opendaylight/netconf/mdsal/yang/library/SchemaServiceToMdsalWriter.java
@@ -5,31 +5,27 @@
  * terms of the Eclipse Public License v1.0 which accompanies this distribution,
  * and is available at http://www.eclipse.org/legal/epl-v10.html
  */
-
 package org.opendaylight.netconf.mdsal.yang.library;
 
-import com.google.common.collect.Lists;
 import com.google.common.util.concurrent.FutureCallback;
-import com.google.common.util.concurrent.Futures;
 import com.google.common.util.concurrent.MoreExecutors;
 import java.util.List;
 import java.util.Set;
 import java.util.concurrent.atomic.AtomicInteger;
-import javax.annotation.Nullable;
+import java.util.stream.Collectors;
 import org.opendaylight.controller.md.sal.binding.api.DataBroker;
 import org.opendaylight.controller.md.sal.binding.api.WriteTransaction;
 import org.opendaylight.controller.md.sal.common.api.data.LogicalDatastoreType;
-import org.opendaylight.controller.sal.core.api.model.SchemaService;
+import org.opendaylight.mdsal.common.api.CommitInfo;
+import org.opendaylight.mdsal.dom.api.DOMSchemaService;
 import org.opendaylight.yang.gen.v1.urn.ietf.params.xml.ns.yang.ietf.inet.types.rev130715.Uri;
-import org.opendaylight.yang.gen.v1.urn.ietf.params.xml.ns.yang.ietf.yang.library.rev160409.ModulesState;
-import org.opendaylight.yang.gen.v1.urn.ietf.params.xml.ns.yang.ietf.yang.library.rev160409.ModulesStateBuilder;
-import org.opendaylight.yang.gen.v1.urn.ietf.params.xml.ns.yang.ietf.yang.library.rev160409.OptionalRevision;
-import org.opendaylight.yang.gen.v1.urn.ietf.params.xml.ns.yang.ietf.yang.library.rev160409.module.list.Module.ConformanceType;
-import org.opendaylight.yang.gen.v1.urn.ietf.params.xml.ns.yang.ietf.yang.library.rev160409.module.list.ModuleBuilder;
-import org.opendaylight.yang.gen.v1.urn.ietf.params.xml.ns.yang.ietf.yang.library.rev160409.module.list.module.Submodules;
-import org.opendaylight.yang.gen.v1.urn.ietf.params.xml.ns.yang.ietf.yang.library.rev160409.module.list.module.SubmodulesBuilder;
-import org.opendaylight.yang.gen.v1.urn.ietf.params.xml.ns.yang.ietf.yang.library.rev160409.module.list.module.submodules.Submodule;
-import org.opendaylight.yang.gen.v1.urn.ietf.params.xml.ns.yang.ietf.yang.library.rev160409.module.list.module.submodules.SubmoduleBuilder;
+import org.opendaylight.yang.gen.v1.urn.ietf.params.xml.ns.yang.ietf.yang.library.rev160621.ModulesState;
+import org.opendaylight.yang.gen.v1.urn.ietf.params.xml.ns.yang.ietf.yang.library.rev160621.ModulesStateBuilder;
+import org.opendaylight.yang.gen.v1.urn.ietf.params.xml.ns.yang.ietf.yang.library.rev160621.RevisionUtils;
+import org.opendaylight.yang.gen.v1.urn.ietf.params.xml.ns.yang.ietf.yang.library.rev160621.module.list.Module.ConformanceType;
+import org.opendaylight.yang.gen.v1.urn.ietf.params.xml.ns.yang.ietf.yang.library.rev160621.module.list.ModuleBuilder;
+import org.opendaylight.yang.gen.v1.urn.ietf.params.xml.ns.yang.ietf.yang.library.rev160621.module.list.module.Submodule;
+import org.opendaylight.yang.gen.v1.urn.ietf.params.xml.ns.yang.ietf.yang.library.rev160621.module.list.module.SubmoduleBuilder;
 import org.opendaylight.yang.gen.v1.urn.ietf.params.xml.ns.yang.ietf.yang.types.rev130715.YangIdentifier;
 import org.opendaylight.yangtools.yang.binding.InstanceIdentifier;
 import org.opendaylight.yangtools.yang.model.api.Module;
@@ -50,11 +46,11 @@ public class SchemaServiceToMdsalWriter implements SchemaContextListener, AutoCl
     private static final InstanceIdentifier<ModulesState> MODULES_STATE_INSTANCE_IDENTIFIER =
             InstanceIdentifier.create(ModulesState.class);
 
-    private final SchemaService schemaService;
+    private final DOMSchemaService schemaService;
     private final AtomicInteger moduleSetId;
     private final DataBroker dataBroker;
 
-    public SchemaServiceToMdsalWriter(final SchemaService schemaService,
+    public SchemaServiceToMdsalWriter(final DOMSchemaService schemaService,
                                       final DataBroker dataBroker) {
         this.schemaService = schemaService;
         this.dataBroker = dataBroker;
@@ -62,7 +58,7 @@ public class SchemaServiceToMdsalWriter implements SchemaContextListener, AutoCl
     }
 
     @Override
-    public void close() throws Exception {
+    public void close() {
         // TODO Delete modules-state from operational data store
     }
 
@@ -82,9 +78,9 @@ public class SchemaServiceToMdsalWriter implements SchemaContextListener, AutoCl
                 MODULES_STATE_INSTANCE_IDENTIFIER, newModuleState);
 
         LOG.debug("Trying to write new module-state: {}", newModuleState);
-        Futures.addCallback(tx.submit(), new FutureCallback<Void>() {
+        tx.commit().addCallback(new FutureCallback<CommitInfo>() {
             @Override
-            public void onSuccess(@Nullable final Void result) {
+            public void onSuccess(final CommitInfo result) {
                 LOG.debug("Modules state updated successfully");
             }
 
@@ -96,43 +92,29 @@ public class SchemaServiceToMdsalWriter implements SchemaContextListener, AutoCl
     }
 
     private ModulesState createModuleStateFromModules(final Set<Module> modules) {
-        final ModulesStateBuilder modulesStateBuilder = new ModulesStateBuilder();
-        final List<org.opendaylight.yang.gen.v1.urn.ietf.params.xml.ns.yang.ietf.yang.library.rev160409.module.list
-                .Module> moduleList =
-                Lists.newArrayList();
-
-        for (final Module module : modules) {
-            moduleList.add(createModuleEntryFromModule(module));
-        }
-
-        return modulesStateBuilder.setModule(moduleList).setModuleSetId(String.valueOf(moduleSetId.getAndIncrement()))
+        return new ModulesStateBuilder()
+                .setModule(modules.stream().map(this::createModuleEntryFromModule).collect(Collectors.toList()))
+                .setModuleSetId(String.valueOf(moduleSetId.getAndIncrement()))
                 .build();
     }
 
-    private org.opendaylight.yang.gen.v1.urn.ietf.params.xml.ns.yang.ietf.yang.library.rev160409.module.list.Module
+    private org.opendaylight.yang.gen.v1.urn.ietf.params.xml.ns.yang.ietf.yang.library.rev160621.module.list.Module
         createModuleEntryFromModule(final Module module) {
-        final ModuleBuilder moduleBuilder = new ModuleBuilder();
-
-        // TODO Conformance type is always set to Implement value, but it should it really be like this?
-        // TODO Add also deviations and features lists to module entries
-        moduleBuilder.setName(new YangIdentifier(module.getName()))
-                .setRevision(new OptionalRevision(module.getQNameModule().getFormattedRevision()))
+        return new ModuleBuilder()
+                .setName(new YangIdentifier(module.getName()))
+                .setRevision(RevisionUtils.fromYangCommon(module.getQNameModule().getRevision()))
                 .setNamespace(new Uri(module.getNamespace().toString()))
+                // FIXME: Conformance type is always set to Implement value, but it should it really be like this?
                 .setConformanceType(ConformanceType.Implement)
-                .setSubmodules(createSubmodulesForModule(module));
-
-        return moduleBuilder.build();
+                .setSubmodule(createSubmodulesForModule(module))
+                // FIXME: Add also deviations and features lists to module entries
+                .build();
     }
 
-    private Submodules createSubmodulesForModule(final Module module) {
-        final List<Submodule> submodulesList = Lists.newArrayList();
-        for (final Module subModule : module.getSubmodules()) {
-            final SubmoduleBuilder subModuleEntryBuilder = new SubmoduleBuilder();
-            subModuleEntryBuilder.setName(new YangIdentifier(subModule.getName()))
-                    .setRevision(new OptionalRevision(subModule.getQNameModule().getFormattedRevision()));
-            submodulesList.add(subModuleEntryBuilder.build());
-        }
-
-        return new SubmodulesBuilder().setSubmodule(submodulesList).build();
+    private static List<Submodule> createSubmodulesForModule(final Module module) {
+        return module.getSubmodules().stream().map(subModule -> new SubmoduleBuilder()
+            .setName(new YangIdentifier(subModule.getName()))
+            .setRevision(RevisionUtils.fromYangCommon(subModule.getQNameModule().getRevision()))
+            .build()).collect(Collectors.toList());
     }
 }
Netconf