/* * Copyright © 2018 Orange Systems, Inc. and others. All rights reserved. * * This program and the accompanying materials are made available under the * terms of the Eclipse Public License v1.0 which accompanies this distribution, * and is available at http://www.eclipse.org/legal/epl-v10.html */ package org.opendaylight.transportpce.renderer.utils; import java.util.ArrayList; import java.util.Arrays; import java.util.Collections; import java.util.List; import org.opendaylight.yang.gen.v1.http.org.opendaylight.transportpce.renderer.device.rev170228.RendererRollbackInput; import org.opendaylight.yang.gen.v1.http.org.opendaylight.transportpce.renderer.device.rev170228.RendererRollbackInputBuilder; import org.opendaylight.yang.gen.v1.http.org.opendaylight.transportpce.renderer.device.rev170228.ServicePathInput; import org.opendaylight.yang.gen.v1.http.org.opendaylight.transportpce.renderer.device.rev170228.ServicePathInputBuilder; import org.opendaylight.yang.gen.v1.http.org.opendaylight.transportpce.renderer.rev171017.ServiceImplementationRequestInput; import org.opendaylight.yang.gen.v1.http.org.opendaylight.transportpce.renderer.rev171017.ServiceImplementationRequestInputBuilder; import org.opendaylight.yang.gen.v1.http.org.opendaylight.transportpce.renderer.rev171017.service.implementation.request.input.PathDescription; import org.opendaylight.yang.gen.v1.http.org.opendaylight.transportpce.renderer.rev171017.service.implementation.request.input.PathDescriptionBuilder; import org.opendaylight.yang.gen.v1.http.org.opendaylight.transportpce.renderer.rev171017.service.implementation.request.input.ServiceAEndBuilder; import org.opendaylight.yang.gen.v1.http.org.opendaylight.transportpce.renderer.rev171017.service.implementation.request.input.ServiceZEndBuilder; import org.opendaylight.yang.gen.v1.http.org.openroadm.common.service.types.rev161014.ServiceFormat; import org.opendaylight.yang.gen.v1.http.org.openroadm.common.service.types.rev161014.service.port.PortBuilder; import org.opendaylight.yang.gen.v1.http.org.transportpce.b.c._interface.pathdescription.rev171017.path.description.AToZDirection; import org.opendaylight.yang.gen.v1.http.org.transportpce.b.c._interface.pathdescription.rev171017.path.description.AToZDirectionBuilder; import org.opendaylight.yang.gen.v1.http.org.transportpce.b.c._interface.pathdescription.rev171017.path.description.ZToADirection; import org.opendaylight.yang.gen.v1.http.org.transportpce.b.c._interface.pathdescription.rev171017.path.description.ZToADirectionBuilder; import org.opendaylight.yang.gen.v1.http.org.transportpce.b.c._interface.pathdescription.rev171017.path.description.atoz.direction.AToZ; import org.opendaylight.yang.gen.v1.http.org.transportpce.b.c._interface.pathdescription.rev171017.path.description.atoz.direction.AToZBuilder; import org.opendaylight.yang.gen.v1.http.org.transportpce.b.c._interface.pathdescription.rev171017.path.description.atoz.direction.AToZKey; import org.opendaylight.yang.gen.v1.http.org.transportpce.b.c._interface.pathdescription.rev171017.path.description.ztoa.direction.ZToA; import org.opendaylight.yang.gen.v1.http.org.transportpce.b.c._interface.pathdescription.rev171017.path.description.ztoa.direction.ZToABuilder; import org.opendaylight.yang.gen.v1.http.org.transportpce.b.c._interface.pathdescription.rev171017.path.description.ztoa.direction.ZToAKey; import org.opendaylight.yang.gen.v1.http.org.transportpce.b.c._interface.pathdescription.rev171017.pce.resource.ResourceBuilder; import org.opendaylight.yang.gen.v1.http.org.transportpce.b.c._interface.pathdescription.rev171017.pce.resource.resource.resource.Link; import org.opendaylight.yang.gen.v1.http.org.transportpce.b.c._interface.pathdescription.rev171017.pce.resource.resource.resource.LinkBuilder; import org.opendaylight.yang.gen.v1.http.org.transportpce.b.c._interface.pathdescription.rev171017.pce.resource.resource.resource.NodeBuilder; import org.opendaylight.yang.gen.v1.http.org.transportpce.b.c._interface.pathdescription.rev171017.pce.resource.resource.resource.TerminationPoint; import org.opendaylight.yang.gen.v1.http.org.transportpce.b.c._interface.pathdescription.rev171017.pce.resource.resource.resource.TerminationPointBuilder; import org.opendaylight.yang.gen.v1.http.org.transportpce.b.c._interface.service.types.rev171016.service.endpoint.sp.RxDirectionBuilder; import org.opendaylight.yang.gen.v1.http.org.transportpce.b.c._interface.service.types.rev171016.service.endpoint.sp.TxDirectionBuilder; import org.opendaylight.yang.gen.v1.http.org.transportpce.b.c._interface.service.types.rev171016.service.handler.header.ServiceHandlerHeaderBuilder; import org.opendaylight.yang.gen.v1.http.org.transportpce.common.types.rev170907.olm.renderer.input.Nodes; import org.opendaylight.yang.gen.v1.http.org.transportpce.common.types.rev170907.olm.renderer.input.NodesBuilder; import org.opendaylight.yang.gen.v1.http.org.transportpce.common.types.rev170907.olm.renderer.input.NodesKey; public final class ServiceDataUtils { private ServiceDataUtils() { } public static Nodes createNode(String nodeId, String srcTp, String dstTp) { return new NodesBuilder().setNodeId(nodeId).withKey(new NodesKey(nodeId)).setSrcTp(srcTp) .setDestTp(dstTp).build(); } public static ServicePathInput buildServicePathInputs(List nodes) { ServicePathInputBuilder servicePathInputBuilder = new ServicePathInputBuilder(); servicePathInputBuilder.setNodes(nodes); servicePathInputBuilder.setServiceName("Service 1").setWaveNumber(20L); return servicePathInputBuilder.build(); } public static ServicePathInput buildServicePathInputs() { ServicePathInputBuilder servicePathInputBuilder = new ServicePathInputBuilder(); List nodes = new ArrayList<>(); nodes.add(ServiceDataUtils.createNode("node1", "src", "dst")); servicePathInputBuilder.setNodes(nodes); servicePathInputBuilder.setServiceName("Service 1").setWaveNumber(20L); return servicePathInputBuilder.build(); } public static RendererRollbackInput buildRendererRollbackInput() { RendererRollbackInputBuilder rendererRollbackInputBuilder = new RendererRollbackInputBuilder(); rendererRollbackInputBuilder.setNodeInterface(new ArrayList<>()); return rendererRollbackInputBuilder.build(); } public static ServiceImplementationRequestInput buildServiceImplementationRequestInputTerminationPointResource( String tpId) { ServiceImplementationRequestInputBuilder builder = new ServiceImplementationRequestInputBuilder() .setServiceName("service 1").setPathDescription(createPathDescriptionTerminationPointResource(tpId)) .setServiceHandlerHeader(new ServiceHandlerHeaderBuilder().setRequestId("Request 1").build()) .setServiceAEnd(getServiceAEndBuild(tpId).build()) .setServiceZEnd(getServiceZEndBuild(tpId).build()); return builder.build(); } /*public static ServiceImplementationRequestInput buildServiceImplementationRequestInputInvalidResource() { ServiceImplementationRequestInputBuilder builder = new ServiceImplementationRequestInputBuilder() .setServiceName("service 1").setPathDescription(createPathDescriptionInvalidResource()) .setServiceHandlerHeader(new ServiceHandlerHeaderBuilder().setRequestId("Request 1").build()) .setServiceAEnd(getServiceAEndBuild().build()) .setServiceZEnd(getServiceZEndBuild().build()); return builder.build(); } public static ServiceImplementationRequestInput buildServiceImplementationRequestInputLinkResource() { ServiceImplementationRequestInputBuilder builder = new ServiceImplementationRequestInputBuilder() .setServiceName("service 1").setPathDescription(createPathDescriptionLinkResource()) .setServiceHandlerHeader(new ServiceHandlerHeaderBuilder().setRequestId("Request 1").build()) .setServiceAEnd(getServiceAEndBuild().build()) .setServiceZEnd(getServiceZEndBuild().build()); return builder.build(); }*/ private static PathDescription createPathDescriptionInvalidResource() { List atoZList = new ArrayList(); org.opendaylight.yang.gen.v1.http.org.transportpce.b.c._interface.pathdescription.rev171017.pce.resource .resource.resource.NodeBuilder nodesBuilder = new NodeBuilder(); org.opendaylight.yang.gen.v1.http.org.transportpce.b.c._interface.pathdescription.rev171017.pce.resource .resource.resource.Node node1 = nodesBuilder.setNodeId("XPONDER-1-2").build(); org.opendaylight.yang.gen.v1.http.org.transportpce.b.c._interface.pathdescription.rev171017.pce.resource .resource.resource.Node node2 = nodesBuilder.setNodeId("XPONDER-1-2").build(); AToZ atoZ = new AToZBuilder().setId("1").withKey(new AToZKey("1")).setResource(new ResourceBuilder() .setResource(node1).build()).build(); AToZ atoZ2 = new AToZBuilder().setId("1").withKey(new AToZKey("1")).setResource(new ResourceBuilder() .setResource(node2).build()).build(); atoZList.add(atoZ); atoZList.add(atoZ2); AToZDirection atozDirection = new AToZDirectionBuilder() .setRate(20L) .setAToZWavelengthNumber(20L) .setAToZ(atoZList) .build(); List ztoAList = new ArrayList(); ZToA ztoA = new ZToABuilder().setId("1").withKey(new ZToAKey("1")).setResource(new ResourceBuilder() .setResource(node1).build()).build(); ZToA ztoA2 = new ZToABuilder().setId("1").withKey(new ZToAKey("1")).setResource(new ResourceBuilder() .setResource(node2).build()).build(); ztoAList.add(ztoA); ztoAList.add(ztoA2); ZToADirection ztoaDirection = new ZToADirectionBuilder() .setRate(20L) .setZToAWavelengthNumber(20L) .setZToA(ztoAList) .build(); PathDescriptionBuilder builder = new PathDescriptionBuilder() .setAToZDirection(atozDirection) .setZToADirection(ztoaDirection); return builder.build(); } public static PathDescription createPathDescriptionTerminationPointResource(String tpId) { List atoZList = new ArrayList(); TerminationPointBuilder terminationPointBuilder = new TerminationPointBuilder(); List nodeIds = Arrays.asList("XPONDER-1-2", "XPONDER-2-3"); Integer atozId = 1; for (String nodeId : nodeIds) { for (String otherNodeId : nodeIds) { TerminationPoint terminationPoint = terminationPointBuilder.setTpNodeId(nodeId + '-' + tpId) .setTpId(tpId).build(); AToZ atoZ = new AToZBuilder().setId(atozId.toString()) .withKey(new AToZKey(atozId.toString())).setResource(new ResourceBuilder() .setResource(terminationPoint).build()).build(); atozId++; atoZList.add(atoZ); } } AToZDirection atozDirection = new AToZDirectionBuilder() .setRate(20L) .setAToZWavelengthNumber(20L) .setAToZ(atoZList) .build(); Collections.reverse(nodeIds); List ztoAList = new ArrayList(); Integer ztoaId = 1; for (String nodeId : nodeIds) { for (String otherNodeId : nodeIds) { TerminationPoint terminationPoint = terminationPointBuilder.setTpNodeId(nodeId + '-' + tpId) .setTpId(tpId).build(); ZToA ztoA = new ZToABuilder().setId(ztoaId.toString()) .withKey(new ZToAKey(ztoaId.toString())).setResource(new ResourceBuilder() .setResource(terminationPoint).build()).build(); ztoaId++; ztoAList.add(ztoA); } } ZToADirection ztoaDirection = new ZToADirectionBuilder() .setRate(20L) .setZToAWavelengthNumber(20L) .setZToA(ztoAList) .build(); PathDescriptionBuilder builder = new PathDescriptionBuilder() .setAToZDirection(atozDirection) .setZToADirection(ztoaDirection); return builder.build(); } private static PathDescription createPathDescriptionLinkResource() { List atoZList = new ArrayList(); Link link1 = new LinkBuilder().setLinkId("link 1").build(); Link link2 = new LinkBuilder().setLinkId("link 2").build(); AToZ atoZ = new AToZBuilder().setId("1").withKey(new AToZKey("1")).setResource(new ResourceBuilder() .setResource(link1).build()).build(); AToZ atoZ2 = new AToZBuilder().setId("1").withKey(new AToZKey("1")).setResource(new ResourceBuilder() .setResource(link2).build()).build(); atoZList.add(atoZ); atoZList.add(atoZ2); AToZDirection atozDirection = new AToZDirectionBuilder() .setRate(20L) .setAToZWavelengthNumber(20L) .setAToZ(atoZList) .build(); List ztoAList = new ArrayList(); ZToA ztoA = new ZToABuilder().setId("1").withKey(new ZToAKey("1")).setResource(new ResourceBuilder() .setResource(link1).build()).build(); ZToA ztoA2 = new ZToABuilder().setId("1").withKey(new ZToAKey("1")).setResource(new ResourceBuilder() .setResource(link2).build()).build(); ztoAList.add(ztoA); ztoAList.add(ztoA2); ZToADirection ztoaDirection = new ZToADirectionBuilder() .setRate(20L) .setZToAWavelengthNumber(20L) .setZToA(ztoAList) .build(); PathDescriptionBuilder builder = new PathDescriptionBuilder() .setAToZDirection(atozDirection) .setZToADirection(ztoaDirection); return builder.build(); } public static ServiceAEndBuilder getServiceAEndBuild(String tpId) { return new ServiceAEndBuilder() .setClli("clli").setServiceFormat(ServiceFormat.OC).setServiceRate((long) 1).setNodeId("XPONDER-1-2-" + tpId) .setTxDirection( new TxDirectionBuilder() .setPort(new PortBuilder().setPortDeviceName("device name").setPortName("port name") .setPortRack("port rack").setPortShelf("port shelf").setPortSlot("port slot") .setPortSubSlot("port subslot").setPortType("port type").build()) .build()) .setRxDirection( new RxDirectionBuilder() .setPort(new PortBuilder().setPortDeviceName("device name").setPortName("port name") .setPortRack("port rack").setPortShelf("port shelf").setPortSlot("port slot") .setPortSubSlot("port subslot").setPortType("port type").build()) .build()); } public static ServiceZEndBuilder getServiceZEndBuild(String tpId) { return new ServiceZEndBuilder() .setClli("clli").setServiceFormat(ServiceFormat.OC).setServiceRate((long) 1).setNodeId("XPONDER-2-3-" + tpId) .setTxDirection( new TxDirectionBuilder() .setPort(new PortBuilder().setPortDeviceName("device name").setPortName("port name") .setPortRack("port rack").setPortShelf("port shelf").setPortSlot("port slot") .setPortSubSlot("port subslot").setPortType("port type").build()) .build()) .setRxDirection( new RxDirectionBuilder() .setPort(new PortBuilder().setPortDeviceName("device name").setPortName("port name") .setPortRack("port rack").setPortShelf("port shelf").setPortSlot("port slot") .setPortSubSlot("port subslot").setPortType("port type").build()) .build()); } }