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;
11 import static org.junit.jupiter.api.Assertions.assertFalse;
12 import static org.junit.jupiter.api.Assertions.assertNotNull;
13 import static org.junit.jupiter.api.Assertions.assertNull;
14 import static org.junit.jupiter.api.Assertions.fail;
16 import com.google.gson.stream.JsonReader;
17 import java.io.FileNotFoundException;
18 import java.io.FileReader;
19 import java.io.IOException;
20 import java.io.Reader;
22 import java.nio.charset.StandardCharsets;
24 import java.util.concurrent.ExecutionException;
25 import org.glassfish.grizzly.http.server.HttpServer;
26 import org.glassfish.jersey.grizzly2.httpserver.GrizzlyHttpServerFactory;
27 import org.glassfish.jersey.server.ResourceConfig;
28 import org.junit.jupiter.api.AfterAll;
29 import org.junit.jupiter.api.BeforeAll;
30 import org.junit.jupiter.api.BeforeEach;
31 import org.junit.jupiter.api.Test;
32 import org.opendaylight.mdsal.common.api.LogicalDatastoreType;
33 import org.opendaylight.transportpce.common.NetworkUtils;
34 import org.opendaylight.transportpce.common.network.NetworkTransactionImpl;
35 import org.opendaylight.transportpce.pce.constraints.PceConstraints;
36 import org.opendaylight.transportpce.pce.constraints.PceConstraintsCalc;
37 import org.opendaylight.transportpce.pce.gnpy.consumer.GnpyConsumer;
38 import org.opendaylight.transportpce.pce.gnpy.consumer.GnpyConsumerImpl;
39 import org.opendaylight.transportpce.pce.gnpy.consumer.GnpyStub;
40 import org.opendaylight.transportpce.pce.utils.JsonUtil;
41 import org.opendaylight.transportpce.pce.utils.PceTestData;
42 import org.opendaylight.transportpce.test.AbstractTest;
43 import org.opendaylight.yang.gen.v1.http.org.transportpce.b.c._interface.pathdescription.rev210705.path.description.AToZDirectionBuilder;
44 import org.opendaylight.yang.gen.v1.http.org.transportpce.b.c._interface.pathdescription.rev210705.path.description.ZToADirectionBuilder;
45 import org.opendaylight.yang.gen.v1.http.org.transportpce.b.c._interface.pathdescription.rev210705.path.description.atoz.direction.AToZ;
46 import org.opendaylight.yang.gen.v1.http.org.transportpce.b.c._interface.pathdescription.rev210705.path.description.atoz.direction.AToZBuilder;
47 import org.opendaylight.yang.gen.v1.http.org.transportpce.b.c._interface.pathdescription.rev210705.path.description.atoz.direction.AToZKey;
48 import org.opendaylight.yang.gen.v1.http.org.transportpce.b.c._interface.pathdescription.rev210705.path.description.ztoa.direction.ZToA;
49 import org.opendaylight.yang.gen.v1.http.org.transportpce.b.c._interface.pathdescription.rev210705.path.description.ztoa.direction.ZToABuilder;
50 import org.opendaylight.yang.gen.v1.http.org.transportpce.b.c._interface.pathdescription.rev210705.path.description.ztoa.direction.ZToAKey;
51 import org.opendaylight.yang.gen.v1.http.org.transportpce.b.c._interface.pathdescription.rev210705.pce.resource.Resource;
52 import org.opendaylight.yang.gen.v1.http.org.transportpce.b.c._interface.pathdescription.rev210705.pce.resource.ResourceBuilder;
53 import org.opendaylight.yang.gen.v1.http.org.transportpce.b.c._interface.pathdescription.rev210705.pce.resource.resource.resource.TerminationPoint;
54 import org.opendaylight.yang.gen.v1.http.org.transportpce.b.c._interface.pathdescription.rev210705.pce.resource.resource.resource.TerminationPointBuilder;
55 import org.opendaylight.yang.gen.v1.urn.ietf.params.xml.ns.yang.ietf.network.rev180226.NetworkId;
56 import org.opendaylight.yang.gen.v1.urn.ietf.params.xml.ns.yang.ietf.network.rev180226.Networks;
57 import org.opendaylight.yang.gen.v1.urn.ietf.params.xml.ns.yang.ietf.network.rev180226.networks.Network;
58 import org.opendaylight.yang.gen.v1.urn.ietf.params.xml.ns.yang.ietf.network.rev180226.networks.NetworkKey;
59 import org.opendaylight.yangtools.yang.binding.InstanceIdentifier;
60 import org.opendaylight.yangtools.yang.common.Uint32;
61 import org.slf4j.Logger;
62 import org.slf4j.LoggerFactory;
64 public class GnpyUtilitiesImplTest extends AbstractTest {
66 private static final Logger LOG = LoggerFactory.getLogger(GnpyUtilitiesImplTest.class);
67 private GnpyUtilitiesImpl gnpyUtilitiesImpl;
68 private NetworkTransactionImpl networkTransaction;
69 private static HttpServer httpServer;
70 private GnpyConsumer gnpyConsumer;
72 public GnpyUtilitiesImplTest() throws IOException {
73 networkTransaction = new NetworkTransactionImpl(getDataBroker());
74 JsonReader networkReader = null;
75 JsonReader topoReader = null;
78 // load openroadm-network
79 Reader gnpyNetwork = new FileReader("src/test/resources/gnpy/gnpy_network.json",
80 StandardCharsets.UTF_8);
82 networkReader = new JsonReader(gnpyNetwork);
83 Networks networks = (Networks) JsonUtil.getInstance().getDataObjectFromJson(networkReader, Networks.QNAME);
84 saveOpenRoadmNetwork(networks.getNetwork().values().iterator().next(), NetworkUtils.UNDERLAY_NETWORK_ID);
85 // load openroadm-topology
86 Reader gnpyTopo = new FileReader("src/test/resources/gnpy/gnpy_topology.json",
87 StandardCharsets.UTF_8);
88 topoReader = new JsonReader(gnpyTopo);
89 networks = (Networks) JsonUtil.getInstance().getDataObjectFromJson(topoReader, Networks.QNAME);
90 saveOpenRoadmNetwork(networks.getNetwork().values().iterator().next(), NetworkUtils.OVERLAY_NETWORK_ID);
91 } catch (FileNotFoundException | InterruptedException | ExecutionException e) {
92 LOG.error("Cannot init test ", e);
93 fail("Cannot init test ");
97 if (networkReader != null) {
98 networkReader.close();
100 if (topoReader != null) {
103 } catch (IOException e) {
104 LOG.warn("Cannot close reader ", e);
111 void initConsumer() {
112 gnpyConsumer = new GnpyConsumerImpl("http://localhost:9998", "mylogin", "mypassword",
113 getDataStoreContextUtil().getBindingDOMCodecServices());
118 // here we cannot use JerseyTest as we already extends AbstractTest
119 final ResourceConfig rc = new ResourceConfig(GnpyStub.class);
120 httpServer = GrizzlyHttpServerFactory.createHttpServer(URI.create("http://localhost:9998"), rc);
124 static void tearDown() {
125 httpServer.shutdownNow();
128 private void saveOpenRoadmNetwork(Network network, String networkId)
129 throws InterruptedException, ExecutionException {
130 InstanceIdentifier<Network> nwInstanceIdentifier = InstanceIdentifier.builder(Networks.class)
131 .child(Network.class, new NetworkKey(new NetworkId(networkId))).build();
132 networkTransaction.put(LogicalDatastoreType.CONFIGURATION, nwInstanceIdentifier, network);
133 networkTransaction.commit().get();
137 void askNewPathFromGnpyNullResultTest() throws Exception {
138 gnpyUtilitiesImpl = new GnpyUtilitiesImpl(networkTransaction,
139 PceTestData.getGnpyPCERequest("XPONDER-1", "XPONDER-2"),
141 assertNull(gnpyUtilitiesImpl.askNewPathFromGnpy(null), "No hard constraints should be available");
145 void askNewPathFromGnpyTest() throws Exception {
146 gnpyUtilitiesImpl = new GnpyUtilitiesImpl(networkTransaction,
147 PceTestData.getGnpyPCERequest("XPONDER-3", "XPONDER-4"),
149 PceConstraintsCalc constraints = new PceConstraintsCalc(PceTestData.getPCE_simpletopology_test1_request(),
151 PceConstraints pceHardConstraints = constraints.getPceHardConstraints();
152 assertNotNull(gnpyUtilitiesImpl.askNewPathFromGnpy(pceHardConstraints), "Hard constraints should be available");
156 void verifyComputationByGnpyTest() throws Exception {
158 AToZDirectionBuilder atoZDirectionBldr = buildAtZ();
160 ZToADirectionBuilder ztoADirectionBldr = buildZtoA();
162 gnpyUtilitiesImpl = new GnpyUtilitiesImpl(networkTransaction,
163 PceTestData.getGnpyPCERequest("XPONDER-1", "XPONDER-2"),
165 PceConstraintsCalc constraints = new PceConstraintsCalc(PceTestData.getPCE_simpletopology_test1_request(),
167 PceConstraints pceHardConstraints = constraints.getPceHardConstraints();
168 boolean result = gnpyUtilitiesImpl.verifyComputationByGnpy(atoZDirectionBldr.build(),
169 ztoADirectionBldr.build(),
171 assertFalse(result, "Gnpy Computation should be false");
174 private AToZDirectionBuilder buildAtZ() {
175 AToZKey clientKey = new AToZKey("key");
176 TerminationPoint stp = new TerminationPointBuilder()
177 .setTpId("tpName").setTpNodeId("xname")
179 Resource clientResource = new ResourceBuilder().setResource(stp).build();
180 AToZ firstResource = new AToZBuilder().setId("tpName").withKey(clientKey).setResource(clientResource).build();
181 return new AToZDirectionBuilder()
182 .setRate(Uint32.valueOf(100))
183 .setAToZ(Map.of(firstResource.key(),firstResource))
184 .setAToZWavelengthNumber(Uint32.valueOf(0));
187 private ZToADirectionBuilder buildZtoA() {
188 ZToAKey clientKey = new ZToAKey("key");
189 TerminationPoint stp = new TerminationPointBuilder()
190 .setTpId("tpName").setTpNodeId("xname")
192 Resource clientResource = new ResourceBuilder().setResource(stp).build();
193 ZToA firstResource = new ZToABuilder().setId("tpName").withKey(clientKey).setResource(clientResource).build();
194 return new ZToADirectionBuilder()
195 .setRate(Uint32.valueOf(100))
196 .setZToA(Map.of(firstResource.key(),firstResource))
197 .setZToAWavelengthNumber(Uint32.valueOf(0));