package com.oransc.rappmanager.sme.service;
-import com.fasterxml.jackson.core.JsonProcessingException;
import com.fasterxml.jackson.core.type.TypeReference;
import com.fasterxml.jackson.databind.ObjectMapper;
import com.oransc.rappmanager.models.RappDeployer;
@Override
public boolean deployRappInstance(Rapp rapp, RappInstance rappInstance) {
logger.debug("Deploying SME functions for RappInstance {}", rappInstance.getRappInstanceId());
- try {
- boolean deployState =
- createProviderDomain(rapp, rappInstance) && createPublishApi(rapp, rappInstance) && createInvoker(
- rapp, rappInstance);
- if (deployState) {
- rappInstanceStateMachine.sendRappInstanceEvent(rappInstance, RappEvent.SMEDEPLOYED);
- } else {
- rappInstance.setReason("Unable to deploy SME");
- rappInstanceStateMachine.sendRappInstanceEvent(rappInstance, RappEvent.SMEDEPLOYFAILED);
- }
- return deployState;
- } catch (JsonProcessingException e) {
- logger.warn("Failed to deploy SME functions for Rapp {}", rapp.getName(), e);
+ if (createProviderDomain(rapp, rappInstance) && createPublishApi(rapp, rappInstance) && createInvoker(rapp,
+ rappInstance)) {
+ rappInstanceStateMachine.sendRappInstanceEvent(rappInstance, RappEvent.SMEDEPLOYED);
+ return true;
}
rappInstanceStateMachine.sendRappInstanceEvent(rappInstance, RappEvent.SMEDEPLOYFAILED);
rappInstance.setReason("Unable to deploy SME");
return true;
}
- boolean createProviderDomain(Rapp rapp, RappInstance rappInstance) throws JsonProcessingException {
+ boolean createProviderDomain(Rapp rapp, RappInstance rappInstance) {
logger.debug("Creating provider domain for Rapp {}", rapp.getName());
try {
String providerDomainPayload =
}
- boolean createPublishApi(Rapp rapp, RappInstance rappInstance) throws JsonProcessingException {
+ boolean createPublishApi(Rapp rapp, RappInstance rappInstance) {
logger.debug("Creating publish api for Rapp {}", rapp.getName());
try {
String providerApiPayload =
publishServiceDefaultApiClient.deleteApfIdServiceApisServiceApiId(serviceApiId, apfId);
}
- boolean createInvoker(Rapp rapp, RappInstance rappInstance) throws JsonProcessingException {
+ boolean createInvoker(Rapp rapp, RappInstance rappInstance) {
logger.debug("Creating provider domain for Rapp {}", rapp.getName());
try {
String invokerPayload = rappCsarConfigurationHandler.getSmeInvokerPayload(rapp, rappInstance.getSme());
import com.fasterxml.jackson.core.JsonProcessingException;
import com.fasterxml.jackson.databind.ObjectMapper;
-import com.oransc.rappmanager.models.rapp.Rapp;
+import com.oransc.rappmanager.models.cache.RappCacheService;
import com.oransc.rappmanager.models.csar.RappCsarConfigurationHandler;
+import com.oransc.rappmanager.models.rapp.Rapp;
+import com.oransc.rappmanager.models.rapp.RappState;
import com.oransc.rappmanager.models.rappinstance.RappInstance;
import com.oransc.rappmanager.models.rappinstance.RappSMEInstance;
-import com.oransc.rappmanager.models.rapp.RappState;
-import com.oransc.rappmanager.models.cache.RappCacheService;
import com.oransc.rappmanager.models.statemachine.RappInstanceStateMachine;
import com.oransc.rappmanager.models.statemachine.RappInstanceStateMachineConfig;
import com.oransc.rappmanager.sme.configuration.SmeConfiguration;
}
@Test
- void testCreateInvokerFailure() throws Exception {
+ void testCreateInvokerFailure() {
UUID rappId = UUID.randomUUID();
Rapp rapp =
Rapp.builder().rappId(rappId).name("").packageName(validRappFile).packageLocation(validCsarFileLocation)
assertFalse(undeployRapp);
}
+ @Test
+ void testPrimingAndDeprimingDoesNothing() {
+ assertTrue(smeDeployer.primeRapp(null));
+ assertTrue(smeDeployer.deprimeRapp(null));
+ }
+
RappInstance getRappInstance() {
RappSMEInstance rappSMEInstance = new RappSMEInstance();
rappSMEInstance.setInvokers("invoker-app1");