+ endSignal.await();
+ RpcResult<ServiceDeleteOutput> serviceDeleteOutput = serviceDeleteOutputF.get();
+ Assert.assertEquals("200", serviceDeleteOutput.getResult().getConfigurationResponseCommon().getResponseCode());
+ Assert.assertEquals(
+ "ack", serviceDeleteOutput.getResult().getConfigurationResponseCommon().getAckFinalIndicator());
+ Assert.assertEquals(
+ "message", serviceDeleteOutput.getResult().getConfigurationResponseCommon().getResponseMessage());
+ Assert.assertNull(serviceDeleteOutput.getResult().getConfigurationResponseCommon().getRequestId());
+ }
+
+ @Test
+ public void createCreateServiceReplyWithServiceCreatInputWithSdncRequestHeader()
+ throws ExecutionException, InterruptedException {
+ ServiceCreateInput input =
+ new ServiceCreateInputBuilder()
+ .setSdncRequestHeader(new SdncRequestHeaderBuilder().setRequestId("12").build()).build();
+ ListenableFuture<RpcResult<ServiceCreateOutput>> serviceCreatOutputF =
+ ModelMappingUtils.createCreateServiceReply(input, "ack", "message", "200");
+ serviceCreatOutputF.addListener(new Runnable() {
+ @Override
+ public void run() {
+ callbackRan = true;
+ endSignal.countDown();
+ }
+ }, executorService);
+
+ endSignal.await();
+ RpcResult<ServiceCreateOutput> serviceCreatOutput = serviceCreatOutputF.get();
+ Assert.assertEquals("200", serviceCreatOutput.getResult().getConfigurationResponseCommon().getResponseCode());
+ Assert.assertEquals(
+ "ack", serviceCreatOutput.getResult().getConfigurationResponseCommon().getAckFinalIndicator());
+ Assert.assertEquals(
+ "message", serviceCreatOutput.getResult().getConfigurationResponseCommon().getResponseMessage());
+ Assert.assertEquals("12", serviceCreatOutput.getResult().getConfigurationResponseCommon().getRequestId());
+ }
+
+ @Test
+ public void createCreateServiceReplyWithServiceCreatInputWithoutSdncRequestHeader()
+ throws ExecutionException, InterruptedException {
+ ServiceCreateInput input = new ServiceCreateInputBuilder().build();
+ ListenableFuture<RpcResult<ServiceCreateOutput>> serviceCreatOutputF =
+ ModelMappingUtils.createCreateServiceReply(input, "ack", "message", "200");
+ serviceCreatOutputF.addListener(new Runnable() {
+ @Override
+ public void run() {
+ callbackRan = true;
+ endSignal.countDown();
+ }
+ }, executorService);
+
+ endSignal.await();
+ RpcResult<ServiceCreateOutput> serviceCreatOutput = serviceCreatOutputF.get();
+ Assert.assertEquals("200", serviceCreatOutput.getResult().getConfigurationResponseCommon().getResponseCode());
+ Assert.assertEquals(
+ "ack", serviceCreatOutput.getResult().getConfigurationResponseCommon().getAckFinalIndicator());
+ Assert.assertEquals(
+ "message", serviceCreatOutput.getResult().getConfigurationResponseCommon().getResponseMessage());
+ Assert.assertNull(serviceCreatOutput.getResult().getConfigurationResponseCommon().getRequestId());
+ }
+
+ @Test
+ public void createCreateServiceReplyWithTempServiceCreatInputWithSdncRequestHeader()
+ throws ExecutionException, InterruptedException {
+ TempServiceCreateInput input =
+ new TempServiceCreateInputBuilder()
+ .setSdncRequestHeader(new SdncRequestHeaderBuilder().setRequestId("12").build()).build();
+ ListenableFuture<RpcResult<TempServiceCreateOutput>> serviceCreatOutputF =
+ ModelMappingUtils.createCreateServiceReply(input, "ack", "message", "200");
+ serviceCreatOutputF.addListener(new Runnable() {
+ @Override
+ public void run() {
+ callbackRan = true;
+ endSignal.countDown();
+ }
+ }, executorService);
+
+ endSignal.await();
+ RpcResult<TempServiceCreateOutput> serviceCreatOutput = serviceCreatOutputF.get();
+ Assert.assertEquals("200", serviceCreatOutput.getResult().getConfigurationResponseCommon().getResponseCode());
+ Assert.assertEquals(
+ "ack", serviceCreatOutput.getResult().getConfigurationResponseCommon().getAckFinalIndicator());
+ Assert.assertEquals(
+ "message", serviceCreatOutput.getResult().getConfigurationResponseCommon().getResponseMessage());
+ Assert.assertEquals("12", serviceCreatOutput.getResult().getConfigurationResponseCommon().getRequestId());
+ }
+
+ @Test
+ public void createCreateServiceReplyWithTempServiceCreatInputWithoutSdncRequestHeader()
+ throws ExecutionException, InterruptedException {
+ TempServiceCreateInput input = new TempServiceCreateInputBuilder().build();
+ ListenableFuture<RpcResult<TempServiceCreateOutput>> serviceCreatOutputF =
+ ModelMappingUtils.createCreateServiceReply(input, "ack", "message", "200");
+ serviceCreatOutputF.addListener(new Runnable() {
+ @Override
+ public void run() {
+ callbackRan = true;
+ endSignal.countDown();
+ }
+ }, executorService);
+
+ endSignal.await();
+ RpcResult<TempServiceCreateOutput> serviceCreatOutput = serviceCreatOutputF.get();
+ Assert.assertEquals("200", serviceCreatOutput.getResult().getConfigurationResponseCommon().getResponseCode());
+ Assert.assertEquals(
+ "ack", serviceCreatOutput.getResult().getConfigurationResponseCommon().getAckFinalIndicator());
+ Assert.assertEquals(
+ "message", serviceCreatOutput.getResult().getConfigurationResponseCommon().getResponseMessage());
+ Assert.assertNull(serviceCreatOutput.getResult().getConfigurationResponseCommon().getRequestId());
+ }
+
+ @Test
+ public void createCreateServiceReplyWithServiceFeasibilityCheckInputWithSdncRequestHeader()
+ throws ExecutionException, InterruptedException {
+ ServiceFeasibilityCheckInput input =
+ new ServiceFeasibilityCheckInputBuilder()
+ .setSdncRequestHeader(new SdncRequestHeaderBuilder().setRequestId("12").build()).build();
+ ListenableFuture<RpcResult<ServiceFeasibilityCheckOutput>> serviceCreatOutputF =
+ ModelMappingUtils.createCreateServiceReply(input, "ack", "message", "200");
+ serviceCreatOutputF.addListener(new Runnable() {
+ @Override
+ public void run() {
+ callbackRan = true;
+ endSignal.countDown();
+ }
+ }, executorService);
+
+ endSignal.await();
+ RpcResult<ServiceFeasibilityCheckOutput> serviceCreatOutput = serviceCreatOutputF.get();
+ Assert.assertEquals("200", serviceCreatOutput.getResult().getConfigurationResponseCommon().getResponseCode());
+ Assert.assertEquals(
+ "ack", serviceCreatOutput.getResult().getConfigurationResponseCommon().getAckFinalIndicator());
+ Assert.assertEquals(
+ "message", serviceCreatOutput.getResult().getConfigurationResponseCommon().getResponseMessage());
+ Assert.assertEquals("12", serviceCreatOutput.getResult().getConfigurationResponseCommon().getRequestId());
+ }
+
+ @Test
+ public void createCreateServiceReplyWithServiceFeasibilityCheckInputWithoutSdncRequestHeader()
+ throws ExecutionException, InterruptedException {
+ ServiceFeasibilityCheckInput input = new ServiceFeasibilityCheckInputBuilder().build();
+ ListenableFuture<RpcResult<ServiceFeasibilityCheckOutput>> serviceCreatOutputF =
+ ModelMappingUtils.createCreateServiceReply(input, "ack", "message", "200");
+ serviceCreatOutputF.addListener(new Runnable() {
+ @Override
+ public void run() {
+ callbackRan = true;
+ endSignal.countDown();
+ }
+ }, executorService);
+
+ endSignal.await();
+ RpcResult<ServiceFeasibilityCheckOutput> serviceCreatOutput = serviceCreatOutputF.get();
+ Assert.assertEquals("200", serviceCreatOutput.getResult().getConfigurationResponseCommon().getResponseCode());
+ Assert.assertEquals(
+ "ack", serviceCreatOutput.getResult().getConfigurationResponseCommon().getAckFinalIndicator());
+ Assert.assertEquals(
+ "message", serviceCreatOutput.getResult().getConfigurationResponseCommon().getResponseMessage());
+ Assert.assertNull(serviceCreatOutput.getResult().getConfigurationResponseCommon().getRequestId());
+ }
+
+ @Test
+ public void testCreateRestoreServiceReply() throws ExecutionException, InterruptedException {
+ ListenableFuture<RpcResult<ServiceRestorationOutput>> serviceRestorationOutputF =
+ ModelMappingUtils.createRestoreServiceReply("message", RpcStatus.Failed);
+ serviceRestorationOutputF.addListener(new Runnable() {
+ @Override
+ public void run() {
+ callbackRan = true;
+ endSignal.countDown();
+ }
+ }, executorService);
+
+ endSignal.await();
+ RpcResult<ServiceRestorationOutput> serviceRestorationOutput = serviceRestorationOutputF.get();
+ Assert.assertEquals("message", serviceRestorationOutput.getResult().getStatusMessage());
+ }