- ServiceDeleteInputBuilder serviceDeleteInputBuilder = new ServiceDeleteInputBuilder();
- serviceDeleteInputBuilder.setServiceName("service 1");
- serviceDeleteInputBuilder.setServiceHandlerHeader((new ServiceHandlerHeaderBuilder())
- .setRequestId("request1").build());
- ServiceDeleteOutput serviceDeleteOutput =
- this.rendererServiceOperations.serviceDelete(serviceDeleteInputBuilder.build()).get();
- Assert.assertEquals(ResponseCodes.RESPONSE_FAILED,
- serviceDeleteOutput.getConfigurationResponseCommon().getResponseCode());
- Mockito.verify(this.olmService, Mockito.times(2)).servicePowerTurndown(Mockito.any());
- Mockito.verify(this.crossConnect, Mockito.times(0)).deleteCrossConnect(Mockito.eq("node1"), Mockito.any());
- Mockito.verify(this.crossConnect, Mockito.times(0)).deleteCrossConnect(Mockito.eq("node2"), Mockito.any());
+ when(rpcService.getRpc(ServicePowerTurndown.class)).thenReturn(servicePowerTurndown);
+ when(servicePowerTurndown.invoke(any()))
+ .thenReturn(RpcResultBuilder.success((new ServicePowerTurndownOutputBuilder()).setResult("Success").build())
+ .buildFuture())
+ .thenReturn(RpcResultBuilder.success((new ServicePowerTurndownOutputBuilder()).setResult("Failed").build())
+ .buildFuture());
+ when(portMapping.getMapping(anyString(), anyString()))
+ .thenReturn(null);
+ ServiceDeleteOutput serviceDeleteOutput = this.rendererServiceOperations.serviceDelete(
+ new ServiceDeleteInputBuilder()
+ .setServiceName("service 1")
+ .setServiceHandlerHeader((new ServiceHandlerHeaderBuilder()).setRequestId("request1").build())
+ .build(),
+ new ServicesBuilder()
+ .setServiceName("service 1")
+ .setConnectionType(ConnectionType.Service)
+ .setServiceAEnd(new ServiceAEndBuilder()
+ .setServiceFormat(ServiceFormat.Ethernet)
+ .setServiceRate(Uint32.valueOf("100"))
+ .setTxDirection(Map.of(
+ new TxDirectionKey(Uint8.ZERO),
+ new TxDirectionBuilder()
+ .setIndex(Uint8.ZERO)
+ .setPort(new PortBuilder().setPortName("port-name").build())
+ .build()))
+ .setNodeId(new NodeIdType("optical-node1"))
+ .build())
+ .build())
+ .get();
+ assertEquals(ResponseCodes.RESPONSE_FAILED,
+ serviceDeleteOutput.getConfigurationResponseCommon().getResponseCode());
+ verify(servicePowerTurndown, times(2)).invoke(any());
+ verify(this.crossConnect, times(0)).deleteCrossConnect(eq("node1"), any(),eq(false));
+ verify(this.crossConnect, times(0)).deleteCrossConnect(eq("node2"), any(),eq(false));