Update UNI

[unimgr.git] / impl / src / main / java / org / opendaylight / unimgr / command / UniUpdateCommand.java

diff --git a/impl/src/main/java/org/opendaylight/unimgr/command/UniUpdateCommand.java b/impl/src/main/java/org/opendaylight/unimgr/command/UniUpdateCommand.java
index 607625019b0ac767279445a7d2274bd540e146fa..c84744c8dc3fa1c9ed5d41d79cb578b20fc8e5c9 100644 (file)
--- a/impl/src/main/java/org/opendaylight/unimgr/command/UniUpdateCommand.java
+++ b/impl/src/main/java/org/opendaylight/unimgr/command/UniUpdateCommand.java
@@ -1,5 +1,5 @@
 /*
- * Copyright (c) 2015 CableLabs and others.  All rights reserved.
+ * Copyright (c) 2016 CableLabs and others.  All rights reserved.
  *
  * This program and the accompanying materials are made available under the
  * terms of the Eclipse Public License v1.0 which accompanies this distribution,
@@ -7,18 +7,24 @@
  */
 package org.opendaylight.unimgr.command;
 
-import java.util.List;
 import java.util.Map;
 import java.util.Map.Entry;
 
 import org.opendaylight.controller.md.sal.binding.api.DataBroker;
-import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.ovsdb.rev150105.OvsdbNodeAugmentation;
-import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.ovsdb.rev150105.ovsdb.node.attributes.ManagedNodeEntry;
+import org.opendaylight.controller.md.sal.common.api.data.LogicalDatastoreType;
+import org.opendaylight.unimgr.impl.UnimgrMapper;
+import org.opendaylight.unimgr.impl.UnimgrUtils;
+import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.ovsdb.rev150105.OvsdbNodeRef;
+import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.unimgr.rev151012.UniAugmentation;
+import org.opendaylight.yang.gen.v1.urn.tbd.params.xml.ns.yang.network.topology.rev131021.network.topology.topology.Node;
 import org.opendaylight.yangtools.yang.binding.DataObject;
 import org.opendaylight.yangtools.yang.binding.InstanceIdentifier;
 import org.slf4j.Logger;
 import org.slf4j.LoggerFactory;
 
+import com.google.common.base.Optional;
+import com.google.common.base.Preconditions;
+
 public class UniUpdateCommand extends AbstractUpdateCommand {
 
     private static final Logger LOG = LoggerFactory.getLogger(UniUpdateCommand.class);
@@ -31,27 +37,46 @@ public class UniUpdateCommand extends AbstractUpdateCommand {
 
     @Override
     public void execute() {
-        for (Entry<InstanceIdentifier<?>, DataObject> created : changes
-                .entrySet()) {
-            if (created.getValue() != null
-                    && created.getValue() instanceof OvsdbNodeAugmentation) {
-                OvsdbNodeAugmentation ovsdbNodeAugmentation = (OvsdbNodeAugmentation) created
-                        .getValue();
-                if (ovsdbNodeAugmentation != null) {
-                    LOG.trace("Received an OVSDB node create {}",
-                            ovsdbNodeAugmentation.getConnectionInfo()
-                                    .getRemoteIp().getIpv4Address().getValue());
-                    final List<ManagedNodeEntry> managedNodeEntries = ovsdbNodeAugmentation.getManagedNodeEntry();
-                    if (managedNodeEntries != null) {
-                        for (ManagedNodeEntry managedNodeEntry : managedNodeEntries) {
-                            LOG.trace("Received an update from an OVSDB node {}.", managedNodeEntry.getKey());
-                            // We received a node update from the southbound plugin
-                            // so we have to check if it belongs to the UNI
+        for (final Entry<InstanceIdentifier<?>, DataObject> updated : changes.entrySet()) {
+            if (updated.getValue() != null && updated.getValue() instanceof UniAugmentation) {
+                final UniAugmentation uni = (UniAugmentation) updated.getValue();
+                final InstanceIdentifier<?> uniIID = UnimgrMapper.getUniIid(dataBroker,
+                        uni.getIpAddress(), LogicalDatastoreType.OPERATIONAL);
+                final UniAugmentation uniAug = UnimgrUtils.getUni(dataBroker, LogicalDatastoreType.OPERATIONAL, uni.getIpAddress());
+                Preconditions.checkArgument(uniAug != null, "No UNI %s on OPERATION Topoligy",
+                        uni.getIpAddress().getIpv4Address().getValue());
+                Preconditions.checkArgument(uniAug.getIpAddress().getIpv4Address().getValue().equals(
+                        uni.getIpAddress().getIpv4Address().getValue()), "New IpAddress %s should be the same than %s",
+                        uniAug.getIpAddress().getIpv4Address().getValue(),
+                        uni.getIpAddress().getIpv4Address().getValue());
+                Node ovsdbNode;
+                if (uni.getOvsdbNodeRef() != null) {
+                    final OvsdbNodeRef ovsdbNodeRef = uni.getOvsdbNodeRef();
+                    final Optional<Node> ovsdbNodeIID = UnimgrUtils.readNode(dataBroker,
+                            LogicalDatastoreType.OPERATIONAL, ovsdbNodeRef.getValue());
+                    if(ovsdbNodeIID.isPresent()){
+                        ovsdbNode= ovsdbNodeIID.get();
+                    } else {
+                        final Optional<Node> optionalOvsdbNode = UnimgrUtils.findOvsdbNode(dataBroker, uni);
+                        if (optionalOvsdbNode.isPresent()) {
+                            ovsdbNode = optionalOvsdbNode.get();
+                        } else {
+                            ovsdbNode = UnimgrUtils.createOvsdbNode(dataBroker, uni);
                         }
                     }
+                    LOG.trace("UNI updated {}.", uni.getIpAddress().getIpv4Address());
+                } else {
+                    final Optional<Node> optionalOvsdbNode = UnimgrUtils.findOvsdbNode(dataBroker, uni);
+                    if (optionalOvsdbNode.isPresent()) {
+                        ovsdbNode = optionalOvsdbNode.get();
+                    } else {
+                        ovsdbNode = UnimgrUtils.createOvsdbNode(dataBroker, uni);
+                    }
                 }
+                UnimgrUtils.deleteNode(dataBroker, uniIID, LogicalDatastoreType.OPERATIONAL);
+                UnimgrUtils.updateUniNode(LogicalDatastoreType.OPERATIONAL, uniIID,
+                        uni, ovsdbNode, dataBroker);
             }
         }
     }
-
 }