+ boolean isXponderInput, TerminationPoint xpdrTp, TerminationPoint rdmTp) {
+ if (xpdrTp == null || rdmTp == null) {
+ return null;
+ }
+ //update tp of nodes
+ TerminationPointBuilder xpdrTpBldr = new TerminationPointBuilder(xpdrTp);
+ if (xpdrTpBldr.augmentation(TerminationPoint1.class) != null) {
+ LOG.warn("Rewritting tail-equipment-id {} on tp {} of node {}", xpdrTpBldr
+ .augmentation(TerminationPoint1.class).getXpdrNetworkAttributes().getTailEquipmentId(), srcTp, srcNode);
+ }
+ TerminationPoint1Builder tp1Bldr = new TerminationPoint1Builder();
+ if (isXponderInput) {
+ tp1Bldr.setXpdrNetworkAttributes(new XpdrNetworkAttributesBuilder()
+ .setTailEquipmentId(srcNode + "--" + srcTp).build());
+ } else {
+ tp1Bldr.setXpdrNetworkAttributes(new XpdrNetworkAttributesBuilder()
+ .setTailEquipmentId(destNode + "--" + destTp).build());
+ }
+ xpdrTpBldr.addAugmentation(tp1Bldr.build());
+ TerminationPoint newXpdrTp = xpdrTpBldr.build();
+ org.opendaylight.yang.gen.v1.urn.ietf.params.xml.ns.yang.ietf.network.topology.rev180226.Node1 node1 =
+ new Node1Builder().setTerminationPoint(ImmutableMap.of(newXpdrTp.key(),newXpdrTp)).build();
+ NodeBuilder nodeBldr = new NodeBuilder().addAugmentation(node1);
+ if (isXponderInput) {
+ nodeBldr.setNodeId(new NodeId(destNode));
+ } else {
+ nodeBldr.setNodeId(new NodeId(srcNode));
+ }
+
+ Link1Builder lnk2bldr
+ = new Link1Builder()
+ .setLinkType(isXponderInput ? OpenroadmLinkType.XPONDERINPUT : OpenroadmLinkType.XPONDEROUTPUT)
+ .setOppositeLink(LinkIdUtil.getOppositeLinkId(srcNode, srcTp, destNode, destTp));
+ // If both TPs of the Xpdr2Rdm link are inService --> link inService. Otherwise outOfService
+ if (State.InService.equals(xpdrTp.augmentation(org.opendaylight.yang.gen.v1.http
+ .org.openroadm.common.network.rev211210.TerminationPoint1.class).getOperationalState())
+ && State.InService.equals(rdmTp.augmentation(org.opendaylight.yang.gen.v1.http
+ .org.openroadm.common.network.rev211210.TerminationPoint1.class).getOperationalState())) {
+ lnk2bldr.setOperationalState(State.InService).setAdministrativeState(AdminStates.InService);
+ } else {
+ lnk2bldr.setOperationalState(State.OutOfService).setAdministrativeState(AdminStates.OutOfService);
+ }
+ LinkBuilder linkBuilder = TopologyUtils.createLink(srcNode, destNode, srcTp, destTp, null)
+ .addAugmentation(lnk2bldr.build());
+
+ LOG.info("Creating Link with id {}", linkBuilder.getLinkId());
+ Link link = linkBuilder.build();
+ Network1Builder nwBldr1 = new Network1Builder().setLink(ImmutableMap.of(link.key(),link));
+