X-Git-Url: https://gerrit.o-ran-sc.org/r/gitweb?a=blobdiff_plain;f=webapp-backend%2Fsrc%2Fmain%2Fjava%2Forg%2Foransc%2Fric%2Fportal%2Fdashboard%2Fconfig%2FAppManagerMockConfiguration.java;h=ef1e9d5d1aef1f1499ee3176a5a747f2084b1eb5;hb=fa50e55b6e8977ad0a6a28096fe58fb54924ca2b;hp=d97884d7386bac5794682925555c3970a4f3fe90;hpb=4d3a7c62ddcab6abc5ca45e6cabc90258025a768;p=portal%2Fric-dashboard.git diff --git a/webapp-backend/src/main/java/org/oransc/ric/portal/dashboard/config/AppManagerMockConfiguration.java b/webapp-backend/src/main/java/org/oransc/ric/portal/dashboard/config/AppManagerMockConfiguration.java index d97884d7..ef1e9d5d 100644 --- a/webapp-backend/src/main/java/org/oransc/ric/portal/dashboard/config/AppManagerMockConfiguration.java +++ b/webapp-backend/src/main/java/org/oransc/ric/portal/dashboard/config/AppManagerMockConfiguration.java @@ -60,6 +60,9 @@ public class AppManagerMockConfiguration { private final AllDeployableXapps availXapps; private final AllDeployedXapps deployedXapps; private final AllXappConfig allXappConfigs; + private final SubscriptionResponse subRes; + // Simulate remote method delay for UI testing + private final int delayMs = 500; public AppManagerMockConfiguration() { logger.info("Configuring mock xApp Manager"); @@ -79,6 +82,7 @@ public class AppManagerMockConfiguration { .status(XappInstance.StatusEnum.RUNNING)); deployedXapps.add(xapp); } + subRes = new SubscriptionResponse().eventType(SubscriptionResponse.EventTypeEnum.ALL).id("subid").version(1); } @Bean @@ -100,19 +104,61 @@ public class AppManagerMockConfiguration { when(mockClient.getStatusCode()).thenReturn(HttpStatus.OK); XappApi mockApi = mock(XappApi.class); when(mockApi.getApiClient()).thenReturn(mockClient); - when(mockApi.getAllXappConfig()).thenReturn(allXappConfigs); - when(mockApi.createXappConfig(any(XAppConfig.class))).thenReturn(allXappConfigs.get(0)); - when(mockApi.modifyXappConfig(any(XAppConfig.class))).thenReturn(allXappConfigs.get(0)); - doAnswer(i -> null).when(mockApi).deleteXappConfig(any(ConfigMetadata.class)); - when(mockApi.deployXapp(any(XAppInfo.class))).thenReturn(deployedXapps.get(0)); - when(mockApi.listAllXapps()).thenReturn(availXapps); - when(mockApi.getAllXapps()).thenReturn(deployedXapps); - when(mockApi.getXappByName(any(String.class))).thenReturn(deployedXapps.get(0)); - doAnswer(i -> null).when(mockApi).undeployXapp(any(String.class)); - SubscriptionResponse subRes = new SubscriptionResponse().eventType(SubscriptionResponse.EventTypeEnum.ALL) - .id("subid").version(1); - when(mockApi.addSubscription(any(SubscriptionRequest.class))).thenReturn(subRes); - doAnswer(i -> null).when(mockApi).deleteSubscription(any(String.class)); + doAnswer(inv -> { + logger.debug("getAllXappConfig sleeping {}", delayMs); + Thread.sleep(delayMs); + return allXappConfigs; + }).when(mockApi).getAllXappConfig(); + doAnswer(inv -> { + logger.debug("createXappConfig sleeping {}", delayMs); + Thread.sleep(delayMs); + return allXappConfigs.get(0); + }).when(mockApi).createXappConfig(any(XAppConfig.class)); + doAnswer(inv -> { + logger.debug("modifyXappConfig sleeping {}", delayMs); + Thread.sleep(delayMs); + return allXappConfigs.get(0); + }).when(mockApi).modifyXappConfig(any(XAppConfig.class)); + doAnswer(inv -> { + logger.debug("deleteXappConfig sleeping {}", delayMs); + Thread.sleep(delayMs); + return null; + }).when(mockApi).deleteXappConfig(any(ConfigMetadata.class)); + doAnswer(inv -> { + logger.debug("deployXapp of {} sleeping {}", inv.getArgument(0), delayMs); + Thread.sleep(delayMs); + return deployedXapps.get(0); + }).when(mockApi).deployXapp(any(XAppInfo.class)); + doAnswer(inv -> { + logger.debug("listAllXapps sleeping {}", delayMs); + Thread.sleep(delayMs); + return availXapps; + }).when(mockApi).listAllXapps(); + doAnswer(inv -> { + logger.debug("getAllXapps sleeping {}", delayMs); + Thread.sleep(delayMs); + return deployedXapps; + }).when(mockApi).getAllXapps(); + doAnswer(inv -> { + logger.debug("getXappByName of {} sleeping {}", inv.getArgument(0), delayMs); + Thread.sleep(delayMs); + return deployedXapps.get(0); + }).when(mockApi).getXappByName(any(String.class)); + doAnswer(inv -> { + logger.debug("undeployXapp of {} sleeping {}", inv.getArgument(0), delayMs); + Thread.sleep(delayMs); + return null; + }).when(mockApi).undeployXapp(any(String.class)); + doAnswer(inv -> { + logger.debug("addSubscription sleeping {}", delayMs); + Thread.sleep(delayMs); + return subRes; + }).when(mockApi).addSubscription(any(SubscriptionRequest.class)); + doAnswer(inv -> { + logger.debug("deleteSubscription sleeping {}", delayMs); + Thread.sleep(delayMs); + return null; + }).when(mockApi).deleteSubscription(any(String.class)); return mockApi; }