1 files changed, 0 insertions, 265 deletions
diff --git a/sdnr/wt/devicemanager-onap/onf14/provider/src/main/java/org/onap/ccsdk/features/sdnr/wt/devicemanager/onf14/impl/equipment/Onf14DomEquipmentManager.java b/sdnr/wt/devicemanager-onap/onf14/provider/src/main/java/org/onap/ccsdk/features/sdnr/wt/devicemanager/onf14/impl/equipment/Onf14DomEquipmentManager.java
deleted file mode 100644
index 092ad4a8f..000000000
--- a/sdnr/wt/devicemanager-onap/onf14/provider/src/main/java/org/onap/ccsdk/features/sdnr/wt/devicemanager/onf14/impl/equipment/Onf14DomEquipmentManager.java
+++ /dev/null
@@ -1,265 +0,0 @@
-/*
- * ============LICENSE_START=======================================================
- * ONAP : ccsdk features
- * ================================================================================
- * Copyright (C) 2020 highstreet technologies GmbH Intellectual Property.
- * All rights reserved.
- * ================================================================================
- * Licensed under the Apache License, Version 2.0 (the "License");
- * you may not use this file except in compliance with the License.
- * You may obtain a copy of the License at
- *
- *     http://www.apache.org/licenses/LICENSE-2.0
- *
- * Unless required by applicable law or agreed to in writing, software
- * distributed under the License is distributed on an "AS IS" BASIS,
- * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
- * See the License for the specific language governing permissions and
- * limitations under the License.
- * ============LICENSE_END=========================================================
- *
- */
-package org.onap.ccsdk.features.sdnr.wt.devicemanager.onf14.impl.equipment;
-
-import java.util.ArrayList;
-import java.util.Collections;
-import java.util.Iterator;
-import java.util.List;
-import java.util.Map;
-import java.util.Objects;
-import java.util.Optional;
-import java.util.stream.Collectors;
-import org.eclipse.jdt.annotation.NonNull;
-import org.eclipse.jdt.annotation.Nullable;
-import org.onap.ccsdk.features.sdnr.wt.common.YangHelper;
-import org.onap.ccsdk.features.sdnr.wt.dataprovider.model.DataProvider;
-import org.onap.ccsdk.features.sdnr.wt.devicemanager.onf14.impl.dataprovider.Onf14ToInternalDataModel;
-import org.onap.ccsdk.features.sdnr.wt.netconfnodestateservice.NetconfDomAccessor;
-import org.opendaylight.mdsal.binding.dom.codec.api.BindingNormalizedNodeSerializer;
-import org.opendaylight.mdsal.common.api.LogicalDatastoreType;
-import org.opendaylight.yang.gen.v1.urn.onf.yang.core.model._1._4.rev191127.ControlConstruct;
-import org.opendaylight.yang.gen.v1.urn.onf.yang.core.model._1._4.rev191127.UniversalId;
-import org.opendaylight.yang.gen.v1.urn.onf.yang.core.model._1._4.rev191127.control.construct.Equipment;
-import org.opendaylight.yang.gen.v1.urn.onf.yang.core.model._1._4.rev191127.control.construct.EquipmentKey;
-import org.opendaylight.yang.gen.v1.urn.onf.yang.core.model._1._4.rev191127.equipment.ContainedHolder;
-import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.data.provider.rev201110.Inventory;
-import org.opendaylight.yangtools.util.UnmodifiableCollection;
-import org.opendaylight.yangtools.yang.binding.CodeHelpers;
-import org.opendaylight.yangtools.yang.binding.DataObject;
-import org.opendaylight.yangtools.yang.common.QName;
-import org.opendaylight.yangtools.yang.data.api.YangInstanceIdentifier;
-import org.opendaylight.yangtools.yang.data.api.YangInstanceIdentifier.InstanceIdentifierBuilder;
-import org.opendaylight.yangtools.yang.data.api.schema.LeafSetEntryNode;
-import org.opendaylight.yangtools.yang.data.api.schema.MapNode;
-import org.opendaylight.yangtools.yang.data.api.schema.NormalizedNode;
-import org.slf4j.Logger;
-import org.slf4j.LoggerFactory;
-
-public class Onf14DomEquipmentManager {
-
-
-    // constants
-    private static final Logger log = LoggerFactory.getLogger(Onf14DomEquipmentManager.class);
-    private static final int EQUIPMENTROOTLEVEL = 0;
-    // end of constants
-
-    // variables
-    private final NetconfDomAccessor netconfDomAccessor;
-    private final DataProvider databaseService;
-    private final Onf14ToInternalDataModel onf14Mapper;
-    // for storing the Equipment UUIDs that are inserted in the DB
-    private final List<UniversalId> equipmentUuidList;
-    // end of variables
-    private final BindingNormalizedNodeSerializer serializer;
-
-    // constructors
-    public Onf14DomEquipmentManager(NetconfDomAccessor netconfDomAccessor, DataProvider databaseService,
-            Onf14ToInternalDataModel onf14Mapper) {
-        super();
-        this.netconfDomAccessor = Objects.requireNonNull(netconfDomAccessor);
-        this.databaseService = Objects.requireNonNull(databaseService);
-        this.onf14Mapper = Objects.requireNonNull(onf14Mapper);
-        this.serializer = Objects.requireNonNull(netconfDomAccessor.getBindingNormalizedNodeSerializer());
-
-        this.equipmentUuidList = new ArrayList<>();
-    }
-    // end of constructors
-
-    // getters and setters
-    public List<UniversalId> getEquipmentUuidList() {
-        return equipmentUuidList;
-    }
-    // end of getters and setters
-
-    // private methods
-    private List<Inventory> collectEquipment(List<Inventory> list, Equipment currentEq, Equipment parentEq,
-            long treeLevel, Map<EquipmentKey, Equipment> equipmentMap, EquipmentKey equipmentKey) {
-        Objects.requireNonNull(list);
-        if (currentEq == null) {
-            log.info("Ignore empty equipment with key {}", equipmentKey);
-            return list;
-        }
-
-        // if the Equipment UUID is already in the list, it was already processed
-        // needed for solving possible circular dependencies
-        if (equipmentUuidList.contains(currentEq.getUuid())) {
-            log.debug("Not adding equipment with uuid {} because it was aleady added...",
-                    currentEq.getUuid().getValue());
-            return list;
-        }
-
-        // we add this to our internal list, such that we avoid circular dependencies
-        equipmentUuidList.add(currentEq.getUuid());
-        log.debug("Adding equipment with uuid {} to the database...", currentEq.getUuid().getValue());
-
-        // we add our current equipment to the database
-        list.add(onf14Mapper.getInternalEquipment(netconfDomAccessor.getNodeId(), currentEq, parentEq, treeLevel));
-
-        // we iterate the kids of our current equipment and add them to the database recursively
-        // the actual reference is here: /core-model:control-construct/equipment/contained-holder/occupying-fru
-        for (ContainedHolder holder : YangHelper.getCollection(currentEq.nonnullContainedHolder())) {
-            @Nullable
-            UniversalId occupyingFru = holder.getOccupyingFru();
-            if (occupyingFru != null) {
-                equipmentKey = new EquipmentKey(occupyingFru);
-                collectEquipment(list, equipmentMap.get(equipmentKey), currentEq, treeLevel + 1, equipmentMap,
-                        equipmentKey);
-            }
-        }
-        return list;
-    }
-    // end of private methods
-
-    // public methods
-    /**
-     * Set all equipment data from controlConstruct into database and into this manager.
-     *
-     * @param controlConstruct with complete device data
-     */
-    public void setEquipmentData(ControlConstruct controlConstruct) {
-        Objects.requireNonNull(controlConstruct);
-
-        // the top-level-equipment list contains the root objects of the Equipment Model
-        log.debug("Getting list of topLevelEquipment for mountpoint {}", netconfDomAccessor.getNodeId());
-        // adding all root Equipment objects to the DB
-        for (UniversalId uuid : CodeHelpers.nonnull(controlConstruct.getTopLevelEquipment())) {
-            log.debug("Got back topLevelEquipment with uuid {}", uuid.getValue());
-            EquipmentKey equipmentKey = new EquipmentKey(uuid);
-
-            // adding all root Equipment objects to the DB
-            Map<EquipmentKey, Equipment> equipmentMap = controlConstruct.nonnullEquipment();
-            // recursively adding the root equipment and all its children into the DB
-            List<Inventory> dbInventory = collectEquipment(new ArrayList<>(), equipmentMap.get(equipmentKey), null,
-                    EQUIPMENTROOTLEVEL, equipmentMap, equipmentKey);
-            this.databaseService.writeInventory(netconfDomAccessor.getNodeId().getValue(), dbInventory);
-        }
-    }
-
-    /**
-     * Experimental see section in {@link #Onf14DomNetworkElement.initialReadFromNetworkElement()}
-     * Read one equipment from device
-     *
-     * @param accessData to access device
-     * @param equipmentUuid uuid of equipment to be read
-     * @return Optional Equipment
-     */
-    public Optional<Equipment> readEquipmentInstance(NetconfDomAccessor accessData, UniversalId equipmentUuid) {
-
-        final Class<?> clazzPac = Equipment.class;
-
-        log.info("DBRead Get equipment for class {} from mountpoint {} for uuid {}", clazzPac.getSimpleName(),
-                accessData.getNodeId().getValue(), equipmentUuid.getValue());
-
-        InstanceIdentifierBuilder equipmentIIDBuilder =
-                YangInstanceIdentifier.builder().node(ControlConstruct.QNAME).node(Equipment.QNAME).nodeWithKey(
-                        Equipment.QNAME, QName.create(Equipment.QNAME, "uuid").intern(), equipmentUuid.getValue());
-
-        return accessData.readData(LogicalDatastoreType.CONFIGURATION, equipmentIIDBuilder.build(), Equipment.class);
-    }
-
-    /**
-     * Experimental see section in {@link #Onf14DomNetworkElement.initialReadFromNetworkElement()}
-     * Read one equipment list from device.
-     *
-     * @param accessData to access device
-     * @param equipmentUuid uuid of equipment to be read
-     * @return Optional Equipment
-     */
-    public List<DataObject> readEquipmentList(NetconfDomAccessor accessData) {
-        log.info("DBRead Get equipment-list for mountpoint {} ", accessData.getNodeId().getValue());
-
-        InstanceIdentifierBuilder equipmentIIDBuilder =
-                YangInstanceIdentifier.builder().node(ControlConstruct.QNAME).node(Equipment.QNAME);
-
-        InstanceIdentifierBuilder equipmentIIDBuilderOnly = YangInstanceIdentifier.builder().node(Equipment.QNAME);
-
-        Optional<NormalizedNode<?, ?>> oData =
-                accessData.readDataNode(LogicalDatastoreType.CONFIGURATION, equipmentIIDBuilder.build());
-        if (oData.isPresent()) {
-            NormalizedNode<?, ?> data = oData.get();
-
-            log.debug("convertNormalizedNode data identifier: {} data nodetype: {}", data.getIdentifier(),
-                    data.getNodeType());
-            final List<DataObject> mapEntries1 = ((MapNode) data).getValue().stream().map(mapEntryNode -> {
-                final YangInstanceIdentifier mapEntryPath =
-                        equipmentIIDBuilderOnly.build().node(mapEntryNode.getIdentifier());
-                return serializer.fromNormalizedNode(mapEntryPath, mapEntryNode).getValue();
-            }).collect(Collectors.toList());
-            return mapEntries1;
-        } else {
-            log.warn("Device does not provide any equipment");
-            return Collections.emptyList();
-        }
-    }
-
-    /**
-     * Experimental see section in {@link #Onf14DomNetworkElement.initialReadFromNetworkElement()}
-     * Read one equipment list from device
-     *
-     * @param accessData to access device
-     * @param equipmentUuid uuid of equipment to be read
-     * @return Optional Equipment
-     */
-    public void readTopLevelEquipment(NetconfDomAccessor accessData) {
-
-        log.info("DBRead Get top-level-equipment for mountpoint {}", accessData.getNodeId().getValue());
-
-        InstanceIdentifierBuilder equipmentIIDBuilder = YangInstanceIdentifier.builder().node(ControlConstruct.QNAME)
-                .node(QName.create(ControlConstruct.QNAME, "top-level-equipment"));
-
-        Optional<NormalizedNode<?, ?>> oData =
-                accessData.readDataNode(LogicalDatastoreType.CONFIGURATION, equipmentIIDBuilder.build());
-        log.info("Checking for existence of data");
-        if (oData.isPresent()) {
-            log.info("data exists");
-            NormalizedNode<?, ?> data = oData.get();
-            Object value = data.getValue();
-            log.info("DataNode: {} {}", data.getNodeType(), data.getIdentifier());
-            if (value != null) {
-                log.info("DataNode value: {} {}", value.getClass().getName(), value);
-                if (value instanceof UnmodifiableCollection) {
-                    @SuppressWarnings("unchecked")
-                    UnmodifiableCollection<LeafSetEntryNode<String>> topLevelEquipmentCollection =
-                            (UnmodifiableCollection<LeafSetEntryNode<String>>) value;
-                    @NonNull
-                    Iterator<LeafSetEntryNode<String>> it = topLevelEquipmentCollection.iterator();
-                    while (it.hasNext()) {
-                        LeafSetEntryNode<String> topLevelEquipmentUuid = it.next();
-                        if (topLevelEquipmentUuid != null) {
-                            log.info("LeafSetEntryNode: {} {} {}", topLevelEquipmentUuid.getValue(),
-                                    topLevelEquipmentUuid.getNodeType(),
-                                    topLevelEquipmentUuid.getValue().getClass().getName());
-                        }
-                    }
-                }
-            }
-        }
-    }
-    // end of public methods
-
-    // static methods
-    // end of static methods
-
-    // private classes
-    // end of private classes
-}