2 * Copyright © 2020 Orange Labs, Inc. and others. All rights reserved.
4 * This program and the accompanying materials are made available under the
5 * terms of the Eclipse Public License v1.0 which accompanies this distribution,
6 * and is available at http://www.eclipse.org/legal/epl-v10.html
8 package org.opendaylight.transportpce.pce.gnpy;
10 import static org.junit.Assert.assertNotNull;
11 import static org.junit.Assert.assertNull;
12 import static org.junit.Assert.fail;
14 import com.google.gson.stream.JsonReader;
15 import java.io.FileNotFoundException;
16 import java.io.FileReader;
17 import java.io.IOException;
18 import java.io.Reader;
20 import java.nio.charset.StandardCharsets;
22 import java.util.concurrent.ExecutionException;
23 import org.glassfish.grizzly.http.server.HttpServer;
24 import org.glassfish.jersey.grizzly2.httpserver.GrizzlyHttpServerFactory;
25 import org.glassfish.jersey.server.ResourceConfig;
26 import org.junit.AfterClass;
27 import org.junit.Assert;
28 import org.junit.BeforeClass;
29 import org.junit.Test;
30 import org.opendaylight.mdsal.binding.api.WriteTransaction;
31 import org.opendaylight.mdsal.common.api.LogicalDatastoreType;
32 import org.opendaylight.transportpce.common.NetworkUtils;
33 import org.opendaylight.transportpce.common.network.NetworkTransactionImpl;
34 import org.opendaylight.transportpce.common.network.RequestProcessor;
35 import org.opendaylight.transportpce.pce.constraints.PceConstraints;
36 import org.opendaylight.transportpce.pce.constraints.PceConstraintsCalc;
37 import org.opendaylight.transportpce.pce.utils.JsonUtil;
38 import org.opendaylight.transportpce.pce.utils.PceTestData;
39 import org.opendaylight.transportpce.test.AbstractTest;
40 import org.opendaylight.yang.gen.v1.http.org.transportpce.b.c._interface.pathdescription.rev200629.path.description.AToZDirectionBuilder;
41 import org.opendaylight.yang.gen.v1.http.org.transportpce.b.c._interface.pathdescription.rev200629.path.description.ZToADirectionBuilder;
42 import org.opendaylight.yang.gen.v1.http.org.transportpce.b.c._interface.pathdescription.rev200629.path.description.atoz.direction.AToZ;
43 import org.opendaylight.yang.gen.v1.http.org.transportpce.b.c._interface.pathdescription.rev200629.path.description.atoz.direction.AToZBuilder;
44 import org.opendaylight.yang.gen.v1.http.org.transportpce.b.c._interface.pathdescription.rev200629.path.description.atoz.direction.AToZKey;
45 import org.opendaylight.yang.gen.v1.http.org.transportpce.b.c._interface.pathdescription.rev200629.path.description.ztoa.direction.ZToA;
46 import org.opendaylight.yang.gen.v1.http.org.transportpce.b.c._interface.pathdescription.rev200629.path.description.ztoa.direction.ZToABuilder;
47 import org.opendaylight.yang.gen.v1.http.org.transportpce.b.c._interface.pathdescription.rev200629.path.description.ztoa.direction.ZToAKey;
48 import org.opendaylight.yang.gen.v1.http.org.transportpce.b.c._interface.pathdescription.rev200629.pce.resource.Resource;
49 import org.opendaylight.yang.gen.v1.http.org.transportpce.b.c._interface.pathdescription.rev200629.pce.resource.ResourceBuilder;
50 import org.opendaylight.yang.gen.v1.http.org.transportpce.b.c._interface.pathdescription.rev200629.pce.resource.resource.resource.TerminationPoint;
51 import org.opendaylight.yang.gen.v1.http.org.transportpce.b.c._interface.pathdescription.rev200629.pce.resource.resource.resource.TerminationPointBuilder;
52 import org.opendaylight.yang.gen.v1.urn.ietf.params.xml.ns.yang.ietf.network.rev180226.NetworkId;
53 import org.opendaylight.yang.gen.v1.urn.ietf.params.xml.ns.yang.ietf.network.rev180226.Networks;
54 import org.opendaylight.yang.gen.v1.urn.ietf.params.xml.ns.yang.ietf.network.rev180226.networks.Network;
55 import org.opendaylight.yang.gen.v1.urn.ietf.params.xml.ns.yang.ietf.network.rev180226.networks.NetworkKey;
56 import org.opendaylight.yangtools.yang.binding.InstanceIdentifier;
57 import org.opendaylight.yangtools.yang.common.QName;
58 import org.opendaylight.yangtools.yang.common.Uint32;
59 import org.slf4j.Logger;
60 import org.slf4j.LoggerFactory;
62 public class GnpyUtilitiesImplTest extends AbstractTest {
64 private static final Logger LOG = LoggerFactory.getLogger(GnpyUtilitiesImplTest.class);
65 private GnpyUtilitiesImpl gnpyUtilitiesImpl;
66 private NetworkTransactionImpl networkTransaction;
67 private static HttpServer httpServer;
69 public GnpyUtilitiesImplTest() throws IOException {
70 networkTransaction = new NetworkTransactionImpl(new RequestProcessor(this.getDataBroker()));
71 JsonReader networkReader = null;
72 JsonReader topoReader = null;
75 // load openroadm-network
76 Reader gnpyNetwork = new FileReader("src/test/resources/gnpy/gnpy_network.json",
77 StandardCharsets.UTF_8);
79 networkReader = new JsonReader(gnpyNetwork);
80 Networks networks = (Networks) JsonUtil.getInstance().getDataObjectFromJson(networkReader,
81 QName.create("urn:ietf:params:xml:ns:yang:ietf-network", "2018-02-26", "networks"));
82 saveOpenRoadmNetwork(networks.getNetwork().values().iterator().next(), NetworkUtils.UNDERLAY_NETWORK_ID);
83 // load openroadm-topology
84 Reader gnpyTopo = new FileReader("src/test/resources/gnpy/gnpy_topology.json",
85 StandardCharsets.UTF_8);
86 topoReader = new JsonReader(gnpyTopo);
87 networks = (Networks) JsonUtil.getInstance().getDataObjectFromJson(topoReader,
88 QName.create("urn:ietf:params:xml:ns:yang:ietf-network", "2018-02-26", "networks"));
89 saveOpenRoadmNetwork(networks.getNetwork().values().iterator().next(), NetworkUtils.OVERLAY_NETWORK_ID);
90 } catch (FileNotFoundException | InterruptedException | ExecutionException e) {
91 LOG.error("Cannot init test ", e);
92 fail("Cannot init test ");
96 if (networkReader != null) {
97 networkReader.close();
99 if (topoReader != null) {
102 } catch (IOException e) {
103 LOG.warn("Cannot close reader ", e);
110 public static void init() {
111 // here we cannot use JerseyTest as we already extends AbstractTest
112 final ResourceConfig rc = new ResourceConfig(GnpyStub.class);
113 httpServer = GrizzlyHttpServerFactory.createHttpServer(URI.create("http://127.0.0.1:8008"), rc);
117 public static void tearDown() {
118 httpServer.shutdownNow();
121 private void saveOpenRoadmNetwork(Network network, String networkId)
122 throws InterruptedException, ExecutionException {
123 InstanceIdentifier<Network> nwInstanceIdentifier = InstanceIdentifier.builder(Networks.class)
124 .child(Network.class, new NetworkKey(new NetworkId(networkId))).build();
125 WriteTransaction dataWriteTransaction = this.getDataBroker().newWriteOnlyTransaction();
126 dataWriteTransaction.put(LogicalDatastoreType.CONFIGURATION, nwInstanceIdentifier, network);
127 dataWriteTransaction.commit().get();
131 public void askNewPathFromGnpyNullResultTest() throws Exception {
132 gnpyUtilitiesImpl = new GnpyUtilitiesImpl(networkTransaction,
133 PceTestData.getGnpyPCERequest("XPONDER-1", "XPONDER-2"),
134 JsonUtil.getInstance().getBindingDOMCodecServices());
135 assertNull("No hard constraints should be available", gnpyUtilitiesImpl.askNewPathFromGnpy(null));
140 public void askNewPathFromGnpyTest() throws Exception {
141 gnpyUtilitiesImpl = new GnpyUtilitiesImpl(networkTransaction,
142 PceTestData.getGnpyPCERequest("XPONDER-3", "XPONDER-4"),
143 JsonUtil.getInstance().getBindingDOMCodecServices());
144 PceConstraintsCalc constraints = new PceConstraintsCalc(PceTestData.getPCE_simpletopology_test1_request(),
146 PceConstraints pceHardConstraints = constraints.getPceHardConstraints();
147 assertNotNull("Hard constraints should be available", gnpyUtilitiesImpl.askNewPathFromGnpy(pceHardConstraints));
153 public void verifyComputationByGnpyTest() throws Exception {
155 AToZDirectionBuilder atoZDirectionBldr = buildAtZ();
157 ZToADirectionBuilder ztoADirectionBldr = buildZtoA();
159 gnpyUtilitiesImpl = new GnpyUtilitiesImpl(networkTransaction,
160 PceTestData.getGnpyPCERequest("XPONDER-1", "XPONDER-2"),
161 JsonUtil.getInstance().getBindingDOMCodecServices());
162 PceConstraintsCalc constraints = new PceConstraintsCalc(PceTestData.getPCE_simpletopology_test1_request(),
164 PceConstraints pceHardConstraints = constraints.getPceHardConstraints();
165 boolean result = gnpyUtilitiesImpl.verifyComputationByGnpy(atoZDirectionBldr.build(),
166 ztoADirectionBldr.build(),
168 Assert.assertFalse("Gnpy Computation should be false",result);
171 private AToZDirectionBuilder buildAtZ() {
172 AToZKey clientKey = new AToZKey("key");
173 TerminationPoint stp = new TerminationPointBuilder()
174 .setTpId("tpName").setTpNodeId("xname")
176 Resource clientResource = new ResourceBuilder().setResource(stp).build();
177 AToZ firstResource = new AToZBuilder().setId("tpName").withKey(clientKey).setResource(clientResource).build();
179 return new AToZDirectionBuilder()
180 .setRate(Uint32.valueOf(100))
181 .setAToZ(Map.of(firstResource.key(),firstResource))
182 .setAToZWavelengthNumber(Uint32.valueOf(0));
186 private ZToADirectionBuilder buildZtoA() {
187 ZToAKey clientKey = new ZToAKey("key");
188 TerminationPoint stp = new TerminationPointBuilder()
189 .setTpId("tpName").setTpNodeId("xname")
191 Resource clientResource = new ResourceBuilder().setResource(stp).build();
192 ZToA firstResource = new ZToABuilder().setId("tpName").withKey(clientKey).setResource(clientResource).build();
193 return new ZToADirectionBuilder()
194 .setRate(Uint32.valueOf(100))
195 .setZToA(Map.of(firstResource.key(),firstResource))
196 .setZToAWavelengthNumber(Uint32.valueOf(0));