- private List<NodeIdPair> getAToZTpList(AToZDirection atoZDirection) {
- Collection<AToZ> atozList = atoZDirection.nonnullAToZ().values();
- return atozList.stream()
- .filter(aToZ -> {
- if ((aToZ.getResource() == null) || (aToZ.getResource().getResource() == null)) {
- LOG.warn("Resource of AToZ node {} is null! Skipping this node!", aToZ.getId());
- return false;
- }
- return aToZ.getResource().getResource() instanceof TerminationPoint;
- }).map(aToZ -> {
- TerminationPoint tp = (TerminationPoint) aToZ.getResource().getResource();
- if ((tp == null) || (tp.getTpNodeId() == null) || (tp.getTpId() == null)
- || tp.getTpId().isEmpty()) {
- LOG.warn("Termination point in AToZ node {} contains nulls! Skipping this node!", aToZ.getId());
- return null;
- }
- return new NodeIdPair(tp.getTpNodeId(), tp.getTpId());
- }).collect(Collectors.toList());
- }
-
- private List<NodeIdPair> getZToATpList(ZToADirection ztoADirection) {
- Collection<ZToA> ztoaList = ztoADirection.nonnullZToA().values();
- return ztoaList.stream()
- .filter(zToA -> {
- if ((zToA.getResource() == null) || (zToA.getResource().getResource() == null)) {
- LOG.warn("Resource of ZToA node {} is null! Skipping this node!", zToA.getId());
- return false;
- }
- return zToA.getResource().getResource() instanceof TerminationPoint;
- }).map(zToA -> {
- TerminationPoint tp = (TerminationPoint) zToA.getResource().getResource();
- if ((tp == null) || (tp.getTpNodeId() == null) || (tp.getTpId() == null)
- || tp.getTpId().isEmpty()) {
- LOG.warn("Termination point in ZToA node {} contains nulls! Skipping this node!", zToA.getId());
- return null;
- }
- return new NodeIdPair(tp.getTpNodeId(), tp.getTpId());
- }).collect(Collectors.toList());
- }
-
- private InstanceIdentifier<Node1> createNode1IID(String nodeId) {
- return InstanceIdentifier
- .builder(Networks.class)
- .child(Network.class, new NetworkKey(new NetworkId(NetworkUtils.OVERLAY_NETWORK_ID)))
- .child(org.opendaylight.yang.gen.v1.urn.ietf.params.xml.ns.yang.ietf.network.rev180226
- .networks.network.Node.class, new NodeKey(new NodeId(nodeId)))
- .augmentation(Node1.class).build();
- }
-
- private InstanceIdentifier<org.opendaylight.yang.gen.v1.http.org.openroadm.common.network.rev200529
- .Node1> createNode2IID(String nodeId) {
- return InstanceIdentifier
- .builder(Networks.class)
- .child(Network.class, new NetworkKey(new NetworkId(NetworkUtils.OVERLAY_NETWORK_ID)))
- .child(org.opendaylight.yang.gen.v1.urn.ietf.params.xml.ns.yang.ietf.network.rev180226
- .networks.network.Node.class, new NodeKey(new NodeId(nodeId)))
- .augmentation(org.opendaylight.yang.gen.v1.http.org.openroadm.common.network.rev200529.Node1.class)
- .build();
- }
-
- private Optional<Node1> getNode1FromDatastore(String nodeId) {
- InstanceIdentifier<Node1>
- nodeIID = createNode1IID(nodeId);
- Optional<Node1> nodeOpt;