X-Git-Url: https://gerrit.o-ran-sc.org/r/gitweb?a=blobdiff_plain;ds=sidebyside;f=rapp-manager-application%2Fsrc%2Fmain%2Fjava%2Fcom%2Foransc%2Frappmanager%2Fservice%2FRappService.java;h=d704480d46c5c056c34d971e404e05b754170885;hb=HEAD;hp=9fddd4dd1304cea1670f391d85ffa0dc9c972b45;hpb=4e0f690867551e6ff679debcc7a1fa531aa4c8e7;p=nonrtric%2Fplt%2Frappmanager.git diff --git a/rapp-manager-application/src/main/java/com/oransc/rappmanager/service/RappService.java b/rapp-manager-application/src/main/java/com/oransc/rappmanager/service/RappService.java deleted file mode 100755 index 9fddd4d..0000000 --- a/rapp-manager-application/src/main/java/com/oransc/rappmanager/service/RappService.java +++ /dev/null @@ -1,146 +0,0 @@ -/*- - * ============LICENSE_START====================================================================== - * Copyright (C) 2023 Nordix Foundation. All rights reserved. - * Copyright (C) 2023 OpenInfra Foundation Europe. All rights reserved. - * =============================================================================================== - * Licensed under the Apache License, Version 2.0 (the "License"); - * you may not use this file except in compliance with the License. - * You may obtain a copy of the License at - * - * http://www.apache.org/licenses/LICENSE-2.0 - * - * Unless required by applicable law or agreed to in writing, software - * distributed under the License is distributed on an "AS IS" BASIS, - * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. - * See the License for the specific language governing permissions and - * limitations under the License. - * ============LICENSE_END======================================================================== - */ - -package com.oransc.rappmanager.service; - -import com.oransc.rappmanager.acm.service.AcmDeployer; -import com.oransc.rappmanager.dme.service.DmeDeployer; -import com.oransc.rappmanager.models.cache.RappCacheService; -import com.oransc.rappmanager.models.exception.RappHandlerException; -import com.oransc.rappmanager.models.rapp.Rapp; -import com.oransc.rappmanager.models.rapp.RappEvent; -import com.oransc.rappmanager.models.rapp.RappState; -import com.oransc.rappmanager.models.rappinstance.RappInstance; -import com.oransc.rappmanager.models.rappinstance.RappInstanceState; -import com.oransc.rappmanager.models.statemachine.RappInstanceStateMachine; -import com.oransc.rappmanager.sme.service.SmeDeployer; -import java.util.UUID; -import lombok.RequiredArgsConstructor; -import org.springframework.http.HttpStatus; -import org.springframework.http.ResponseEntity; -import org.springframework.stereotype.Service; - -@Service -@RequiredArgsConstructor -public class RappService { - - private final AcmDeployer acmDeployer; - private final SmeDeployer smeDeployer; - private final DmeDeployer dmeDeployer; - private final RappInstanceStateMachine rappInstanceStateMachine; - private final RappCacheService rappCacheService; - private static final String STATE_TRANSITION_NOT_PERMITTED = "State transition from %s to %s is not permitted."; - - public ResponseEntity primeRapp(Rapp rapp) { - if (rapp.getState().equals(RappState.COMMISSIONED)) { - rapp.setState(RappState.PRIMING); - rapp.setReason(null); - if (acmDeployer.primeRapp(rapp) && dmeDeployer.primeRapp(rapp)) { - rapp.setState(RappState.PRIMED); - return ResponseEntity.ok().build(); - } - rapp.setState(RappState.COMMISSIONED); - return ResponseEntity.status(HttpStatus.BAD_GATEWAY).build(); - } - throw new RappHandlerException(HttpStatus.BAD_REQUEST, - String.format(STATE_TRANSITION_NOT_PERMITTED, rapp.getState().name(), RappState.PRIMED.name())); - - } - - public ResponseEntity deprimeRapp(Rapp rapp) { - if (rapp.getState().equals(RappState.PRIMED) && rapp.getRappInstances().isEmpty()) { - rapp.setState(RappState.DEPRIMING); - rapp.setReason(null); - if (acmDeployer.deprimeRapp(rapp) && dmeDeployer.deprimeRapp(rapp)) { - rapp.setState(RappState.COMMISSIONED); - return ResponseEntity.ok().build(); - } - rapp.setState(RappState.PRIMED); - return ResponseEntity.status(HttpStatus.BAD_GATEWAY).build(); - } - if (!rapp.getRappInstances().isEmpty()) { - throw new RappHandlerException(HttpStatus.BAD_REQUEST, - "Unable to deprime as there are active rapp instances."); - } else { - throw new RappHandlerException(HttpStatus.BAD_REQUEST, - String.format(STATE_TRANSITION_NOT_PERMITTED, RappState.COMMISSIONED.name(), - rapp.getState().name())); - } - } - - public ResponseEntity deleteRapp(Rapp rApp) { - if (rApp.getRappInstances().isEmpty() && rApp.getState().equals(RappState.COMMISSIONED)) { - rappCacheService.deleteRapp(rApp); - return ResponseEntity.ok().build(); - } - if (!rApp.getRappInstances().isEmpty()) { - throw new RappHandlerException(HttpStatus.BAD_REQUEST, - String.format("Unable to delete %s as there are active rApp instances.", rApp.getName())); - } else { - throw new RappHandlerException(HttpStatus.BAD_REQUEST, - String.format("Unable to delete %s as the rApp is not in COMMISSIONED state.", rApp.getName())); - } - - } - - public ResponseEntity deployRappInstance(Rapp rapp, RappInstance rappInstance) { - if (rappInstance.getState().equals(RappInstanceState.UNDEPLOYED)) { - rappInstance.setReason(null); - rappInstanceStateMachine.sendRappInstanceEvent(rappInstance, RappEvent.DEPLOYING); - if (acmDeployer.deployRappInstance(rapp, rappInstance) && smeDeployer.deployRappInstance(rapp, - rappInstance)) { - return ResponseEntity.accepted().build(); - } - return ResponseEntity.status(HttpStatus.BAD_GATEWAY).build(); - } - throw new RappHandlerException(HttpStatus.BAD_REQUEST, - String.format("Unable to deploy rApp instance %s as it is not in UNDEPLOYED state", - rappInstance.getRappInstanceId())); - - } - - public ResponseEntity undeployRappInstance(Rapp rapp, RappInstance rappInstance) { - if (rappInstance.getState().equals(RappInstanceState.DEPLOYED)) { - rappInstance.setReason(null); - rappInstanceStateMachine.sendRappInstanceEvent(rappInstance, RappEvent.UNDEPLOYING); - if (acmDeployer.undeployRappInstance(rapp, rappInstance) && smeDeployer.undeployRappInstance(rapp, - rappInstance)) { - return ResponseEntity.accepted().build(); - } - return ResponseEntity.status(HttpStatus.BAD_GATEWAY).build(); - } - throw new RappHandlerException(HttpStatus.BAD_REQUEST, - String.format("Unable to undeploy rApp instance %s as it is not in DEPLOYED state", - rappInstance.getRappInstanceId())); - } - - public ResponseEntity deleteRappInstance(Rapp rApp, UUID rappInstanceId) { - if (rApp.getRappInstances().get(rappInstanceId).getState().equals(RappInstanceState.UNDEPLOYED)) { - rappInstanceStateMachine.deleteRappInstance(rApp.getRappInstances().get(rappInstanceId)); - rApp.getRappInstances().remove(rappInstanceId); - return ResponseEntity.noContent().build(); - } - throw new RappHandlerException(HttpStatus.BAD_REQUEST, - String.format("Unable to delete rApp instance %s as it is not in UNDEPLOYED state", rappInstanceId)); - } - - public void updateRappInstanceState(Rapp rapp, RappInstance rappInstance) { - acmDeployer.syncRappInstanceStatus(rapp.getCompositionId(), rappInstance); - } -}