2 * ============LICENSE_START=======================================================
3 * ONAP : ccsdk features
4 * ================================================================================
5 * Copyright (C) 2020 highstreet technologies GmbH Intellectual Property.
7 * ================================================================================
8 * Licensed under the Apache License, Version 2.0 (the "License");
9 * you may not use this file except in compliance with the License.
10 * You may obtain a copy of the License at
12 * http://www.apache.org/licenses/LICENSE-2.0
14 * Unless required by applicable law or agreed to in writing, software
15 * distributed under the License is distributed on an "AS IS" BASIS,
16 * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
17 * See the License for the specific language governing permissions and
18 * limitations under the License.
19 * ============LICENSE_END=========================================================
22 package org.onap.ccsdk.features.sdnr.wt.devicemanager.onf14.dom.impl.equipment;
24 import java.util.ArrayList;
25 import java.util.Collection;
26 import java.util.Iterator;
27 import java.util.List;
28 import java.util.Objects;
29 import java.util.Optional;
30 import org.onap.ccsdk.features.sdnr.wt.dataprovider.model.DataProvider;
31 import org.onap.ccsdk.features.sdnr.wt.devicemanager.onf14.dom.impl.dataprovider.Onf14DomToInternalDataModel;
32 import org.onap.ccsdk.features.sdnr.wt.devicemanager.onf14.dom.impl.util.Onf14DMDOMUtility;
33 import org.onap.ccsdk.features.sdnr.wt.devicemanager.onf14.dom.impl.yangspecs.CoreModel14;
34 import org.onap.ccsdk.features.sdnr.wt.netconfnodestateservice.NetconfDomAccessor;
35 import org.opendaylight.mdsal.common.api.LogicalDatastoreType;
36 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.data.provider.rev201110.Inventory;
37 import org.opendaylight.yangtools.yang.common.QName;
38 import org.opendaylight.yangtools.yang.data.api.YangInstanceIdentifier;
39 import org.opendaylight.yangtools.yang.data.api.YangInstanceIdentifier.InstanceIdentifierBuilder;
40 import org.opendaylight.yangtools.yang.data.api.YangInstanceIdentifier.NodeIdentifier;
41 import org.opendaylight.yangtools.yang.data.api.schema.LeafSetEntryNode;
42 import org.opendaylight.yangtools.yang.data.api.schema.MapEntryNode;
43 import org.opendaylight.yangtools.yang.data.api.schema.MapNode;
44 import org.opendaylight.yangtools.yang.data.api.schema.NormalizedNode;
45 import org.slf4j.Logger;
46 import org.slf4j.LoggerFactory;
48 public class Onf14DomEquipmentManager {
50 private static final Logger log = LoggerFactory.getLogger(Onf14DomEquipmentManager.class);
51 private static final int EQUIPMENTROOTLEVEL = 0;
53 private final NetconfDomAccessor netconfDomAccessor;
54 private final DataProvider databaseService;
55 private final Onf14DomToInternalDataModel onf14Mapper;
56 private final List<String> equipmentUuidList;
57 private final CoreModel14 qNames;
59 public Onf14DomEquipmentManager(NetconfDomAccessor netconfDomAccessor, DataProvider databaseService,
60 Onf14DomToInternalDataModel onf14Mapper, CoreModel14 qNames) {
62 this.netconfDomAccessor = Objects.requireNonNull(netconfDomAccessor);
63 this.databaseService = Objects.requireNonNull(databaseService);
64 this.onf14Mapper = Objects.requireNonNull(onf14Mapper);
66 this.equipmentUuidList = new ArrayList<>();
70 public List<String> getEquipmentUuidList() {
71 return equipmentUuidList;
75 * Set all equipment data from controlConstruct into database and into this manager.
77 * @param controlConstruct with complete device data
79 public void setEquipmentData(NormalizedNode controlConstruct) {
80 Objects.requireNonNull(controlConstruct);
82 // the top-level-equipment list contains the root objects of the Equipment Model
83 log.debug("Iterating through the list of topLevelEquipment for mountpoint {}", netconfDomAccessor.getNodeId());
84 // adding all root Equipment objects to the DB
85 List<Inventory> inventoryList = new ArrayList<>();
86 for (String uuid : getTopLevelEquipment(controlConstruct)) {
87 Optional<NormalizedNode> equipment = readEquipmentInstance(netconfDomAccessor, uuid);
88 MapEntryNode equipmentEntry = (MapEntryNode) equipment.get();
89 if (equipmentEntry != null) {
90 collectEquipment(inventoryList, equipmentEntry, null, EQUIPMENTROOTLEVEL);
93 this.databaseService.writeInventory(netconfDomAccessor.getNodeId().getValue(), inventoryList);
97 private List<String> getTopLevelEquipment(NormalizedNode transformedInput) {
98 List<String> topLvlEqptList = new ArrayList<>();
99 Collection<?> topLevelEqptListColl = (Collection<?>) transformedInput.body();
100 Iterator<?> childEntryItr = topLevelEqptListColl.iterator();
101 while (childEntryItr.hasNext()) {
102 LeafSetEntryNode<?> childEntryNode = (LeafSetEntryNode<?>) childEntryItr.next();
103 topLvlEqptList.add((String) childEntryNode.body());
105 return topLvlEqptList;
109 * @param accessData to access device
110 * @param equipmentUuid uuid of equipment to be read
111 * @return Optional Equipment
113 private Optional<NormalizedNode> readEquipmentInstance(NetconfDomAccessor accessData, String equipmentUuid) {
115 log.debug("DBRead Get equipment from mountpoint {} for uuid {}", accessData.getNodeId().getValue(),
118 InstanceIdentifierBuilder equipmentIIDBuilder =
119 YangInstanceIdentifier.builder().node(qNames.getQName("control-construct"))
120 .node(qNames.getQName("equipment")).nodeWithKey(qNames.getQName("equipment"),
121 QName.create(qNames.getQName("equipment"), "uuid").intern(), equipmentUuid);
123 return accessData.readDataNode(LogicalDatastoreType.CONFIGURATION, equipmentIIDBuilder.build());
126 private List<Inventory> collectEquipment(List<Inventory> list, MapEntryNode currentEq, MapEntryNode parentEq,
129 // if the Equipment UUID is already in the list, it was already processed
130 // needed for solving possible circular dependencies
131 if (equipmentUuidList.contains(Onf14DMDOMUtility.getUuidFromEquipment(currentEq, qNames.getQName("uuid")))) {
132 log.debug("Not adding equipment with uuid {} because it was aleady added...",
133 Onf14DMDOMUtility.getUuidFromEquipment(currentEq, qNames.getQName("uuid")));
137 // we add this to our internal list, such that we avoid circular dependencies
138 equipmentUuidList.add(Onf14DMDOMUtility.getUuidFromEquipment(currentEq, qNames.getQName("uuid")));
139 log.debug("Adding equipment with uuid {} to the database...",
140 Onf14DMDOMUtility.getUuidFromEquipment(currentEq, qNames.getQName("uuid")));
142 // we add our current equipment to the database
143 list.add(onf14Mapper.getInternalEquipment(netconfDomAccessor.getNodeId(), currentEq, parentEq, treeLevel,
146 // we iterate the kids of our current equipment and add them to the database
148 // the actual reference is here:
149 // /core-model:control-construct/equipment/contained-holder/occupying-fru
151 MapNode containedHolderMap =
152 (MapNode) currentEq.childByArg(new NodeIdentifier(qNames.getQName("contained-holder")));
153 if (containedHolderMap != null) {
154 Collection<MapEntryNode> containedHolderCollection = containedHolderMap.body();
155 for (MapEntryNode holder : containedHolderCollection) {
156 String occupyingFru = Onf14DMDOMUtility.getLeafValue(holder,
157 qNames.getQName("occupying-fru")/*Onf14DevicemanagerQNames.CORE_MODEL_CC_EQPT_OCCUPYING_FRU*/);
159 if (occupyingFru != null) {
160 Optional<NormalizedNode> childEq = readEquipmentInstance(netconfDomAccessor, occupyingFru);
161 if (childEq.isPresent()) {
162 // current becomes parent and tree level increases by 1
163 collectEquipment(list, (MapEntryNode) childEq.get(), currentEq, treeLevel + 1);