X-Git-Url: https://gerrit.onap.org/r/gitweb?a=blobdiff_plain;f=sdnr%2Fwt%2Fdevicemanager%2Fprovider%2Fsrc%2Fmain%2Fjava%2Forg%2Fonap%2Fccsdk%2Ffeatures%2Fsdnr%2Fwt%2Fdevicemanager%2Fbase%2Fnetconf%2FONFCoreNetworkElementFactory.java;h=3455f1681d351d59f18b8d57d7d42ed8391d6b83;hb=8404b495de1770617d745ab488116714e9d2d06d;hp=2921401bc34106e982b88de0db30c18fde597b2c;hpb=159de601758f7cedcef9359da471f182dcf73781;p=ccsdk%2Ffeatures.git

diff --git a/sdnr/wt/devicemanager/provider/src/main/java/org/onap/ccsdk/features/sdnr/wt/devicemanager/base/netconf/ONFCoreNetworkElementFactory.java b/sdnr/wt/devicemanager/provider/src/main/java/org/onap/ccsdk/features/sdnr/wt/devicemanager/base/netconf/ONFCoreNetworkElementFactory.java
index 2921401bc..3455f1681 100644
--- a/sdnr/wt/devicemanager/provider/src/main/java/org/onap/ccsdk/features/sdnr/wt/devicemanager/base/netconf/ONFCoreNetworkElementFactory.java
+++ b/sdnr/wt/devicemanager/provider/src/main/java/org/onap/ccsdk/features/sdnr/wt/devicemanager/base/netconf/ONFCoreNetworkElementFactory.java
@@ -21,6 +21,10 @@ import com.google.common.base.Optional;
 import javax.annotation.Nonnull;
 import javax.annotation.Nullable;
 import org.onap.ccsdk.features.sdnr.wt.devicemanager.base.netconf.container.Capabilities;
+import org.onap.ccsdk.features.sdnr.wt.devicemanager.base.netconf.wrapperc.OnfMicrowaveModel;
+import org.onap.ccsdk.features.sdnr.wt.devicemanager.base.netconf.wrapperc.WrapperMicrowaveModelRev170324;
+import org.onap.ccsdk.features.sdnr.wt.devicemanager.base.netconf.wrapperc.WrapperMicrowaveModelRev180907;
+import org.onap.ccsdk.features.sdnr.wt.devicemanager.base.netconf.wrapperc.WrapperMicrowaveModelRev181010;
 import org.onap.ccsdk.features.sdnr.wt.devicemanager.base.toggleAlarmFilter.NotificationDelayService;
 import org.onap.ccsdk.features.sdnr.wt.devicemanager.impl.ProviderClient;
 import org.onap.ccsdk.features.sdnr.wt.devicemanager.impl.database.service.HtDatabaseEventsService;
@@ -31,6 +35,7 @@ import org.opendaylight.controller.md.sal.binding.api.DataBroker;
 import org.opendaylight.controller.md.sal.binding.api.ReadOnlyTransaction;
 import org.opendaylight.controller.md.sal.common.api.data.LogicalDatastoreType;
 import org.opendaylight.controller.md.sal.common.api.data.ReadFailedException;
+import org.opendaylight.yang.gen.v1.urn.onf.params.xml.ns.yang.core.model.rev170320.NetworkElement;
 import org.opendaylight.yang.gen.v1.urn.opendaylight.netconf.node.topology.rev150114.NetconfNode;
 import org.opendaylight.yang.gen.v1.urn.opendaylight.netconf.node.topology.rev150114.NetconfNodeConnectionStatus.ConnectionStatus;
 import org.opendaylight.yang.gen.v1.urn.tbd.params.xml.ns.yang.network.topology.rev131021.network.topology.topology.Node;
@@ -66,7 +71,7 @@ public class ONFCoreNetworkElementFactory {
                     if (csts == ConnectionStatus.Connected) {
                         Capabilities capabilities = Capabilities.getAvailableCapabilities(nnode);
                         LOG.info("Mountpoint {} capabilities {}", mountPointNodeName, capabilities);
-                        res = ONFCoreNetworkElement12.build(mountPointNodeName, capabilities, mountpointDataBroker,
+                        res = build(mountPointNodeName, capabilities, mountpointDataBroker,
                                 webSocketService, databaseService, dcaeProvider, aotsmClient, maintenanceService,
                                 notificationDelayService);
                         LOG.info("ONFCoreNetworkElementRepresentation12 value is not null? " + (res != null));
@@ -78,14 +83,57 @@ public class ONFCoreNetworkElementFactory {
             LOG.warn("Can not generate specific NE Version representation. ", e);
         }
         if (res == null) {
-            res = new ONFCoreEmpty(mountPointNodeName);
+            res = new ONFCoreNetworkElementEmpty(mountPointNodeName);
         }
         LOG.info("Mointpoint {} started as {}", mountPointNodeName, res.getClass().getSimpleName());
         return res;
     }
 
     public static @Nonnull ONFCoreNetworkElementRepresentation getEmpty(String mountPointNodeName) {
-    	return new ONFCoreEmpty(mountPointNodeName);
+    	return new ONFCoreNetworkElementEmpty(mountPointNodeName);
+    }
+
+    /**
+     * Check capabilities are matching the this specific implementation and create network element
+     * representation if so.
+     *
+     * @param mountPointNodeName as String
+     * @param capabilities of the specific network element
+     * @param netconfNodeDataBroker for the network element specific data
+     * @param webSocketService to forward event notifications
+     * @param databaseService to access the database
+     * @param dcaeProvider to forward problem / change notifications
+     * @return created Object if conditions are OK or null if not.
+     */
+    private static @Nullable ONFCoreNetworkElementRepresentation build(String mountPointNodeName, Capabilities capabilities,
+            DataBroker netconfNodeDataBroker, WebSocketServiceClient webSocketService,
+            HtDatabaseEventsService databaseService, ProviderClient dcaeProvider, @Nullable ProviderClient aotsmClient,
+            MaintenanceService maintenanceService,
+            NotificationDelayService<ProblemNotificationXml> notificationDelayService) {
+
+        if (capabilities.isSupportingNamespaceAndRevision(NetworkElement.QNAME)) {
+            OnfMicrowaveModel onfMicrowaveModel = null;
+
+            if (capabilities.isSupportingNamespaceAndRevision(WrapperMicrowaveModelRev170324.QNAME)) {
+                onfMicrowaveModel = new WrapperMicrowaveModelRev170324();
+            } else if (capabilities.isSupportingNamespaceAndRevision(WrapperMicrowaveModelRev180907.QNAME)) {
+                onfMicrowaveModel = new WrapperMicrowaveModelRev180907();
+            } else if (capabilities.isSupportingNamespaceAndRevision(WrapperMicrowaveModelRev181010.QNAME)) {
+                onfMicrowaveModel = new WrapperMicrowaveModelRev181010();
+            }
+
+            if (onfMicrowaveModel != null) {
+                return new ONFCoreNetworkElement12Microwave(mountPointNodeName, capabilities, netconfNodeDataBroker,
+                        webSocketService, databaseService, dcaeProvider, aotsmClient, maintenanceService,
+                        notificationDelayService, onfMicrowaveModel);
+            } else {
+            	return new ONFCoreNetworkElement12(mountPointNodeName, capabilities, netconfNodeDataBroker,
+                        webSocketService, databaseService, dcaeProvider, aotsmClient, maintenanceService,
+                        notificationDelayService);
+            }
+        }
+        return null;
+
     }
 
 }