- @Before
- public void setUp() throws Exception {
-// PceTestUtils.writeTopologyIntoDataStore(
-// dataBroker, dataStoreContext, "./topologyData/NW-simple-topology.xml");
- PceTestUtils.writeNetworkIntoDataStore(dataBroker, dataStoreContext, TransactionUtils.getNetworkForSpanLoss());
- networkTransaction = new NetworkTransactionImpl(new RequestProcessor(dataBroker));
- pceSendingPceRPCs = new PceSendingPceRPCs();
- pceSendingPceRPCs =
- new PceSendingPceRPCs(PceTestData.getPCE_test1_request_54(), networkTransaction);
+ @BeforeEach
+ void setUp() {
+ this.dataBroker = getNewDataBroker();
+ networkTransaction = new NetworkTransactionImpl(this.dataBroker);
+ PceTestUtils.writeNetworkInDataStore(this.dataBroker);
+ gnpyConsumer = new GnpyConsumerImpl(
+ "http://localhost:9998", "mylogin", "mypassword", getDataStoreContextUtil().getBindingDOMCodecServices());
+ pceSendingPceRPCs = new PceSendingPceRPCs(
+ PceTestData.getPCE_test1_request_54(), networkTransaction, gnpyConsumer, portMapping);
+ mapping = new MappingBuilder()
+ .setLogicalConnectionPoint("logicalConnectionPoint")
+ .setPortQual("xpdr-client")
+ .build();
+ NodeInfo info = new NodeInfoBuilder().setNodeType(NodeTypes.Xpdr).build();
+ Nodes node = new NodesBuilder().withKey(new NodesKey("node")).setNodeId("node").setNodeInfo(info).build();
+ lenient().when(portMapping.getMapping(anyString(), anyString())).thenReturn(mapping);
+ lenient().when(portMapping.getNode(anyString())).thenReturn(node);