From: FrancescoFioraEst Date: Tue, 21 Oct 2025 12:10:15 +0000 (+0100) Subject: Remove useless code from intermediary X-Git-Url: https://gerrit.onap.org/r/gitweb?a=commitdiff_plain;h=00441190174d95f98cea7fd2449ee3777c13188b;p=policy%2Fclamp.git Remove useless code from intermediary Remove useless update due the sync message. Remove useless validation. Issue-ID: POLICY-5469 Change-Id: Ie4b01ff540037e0b232c2218407bc8c301d9bfd8 Signed-off-by: FrancescoFioraEst --- diff --git a/participant/participant-intermediary/src/main/java/org/onap/policy/clamp/acm/participant/intermediary/handler/AutomationCompositionHandler.java b/participant/participant-intermediary/src/main/java/org/onap/policy/clamp/acm/participant/intermediary/handler/AutomationCompositionHandler.java index 3572945a3..0b076e56b 100644 --- a/participant/participant-intermediary/src/main/java/org/onap/policy/clamp/acm/participant/intermediary/handler/AutomationCompositionHandler.java +++ b/participant/participant-intermediary/src/main/java/org/onap/policy/clamp/acm/participant/intermediary/handler/AutomationCompositionHandler.java @@ -70,10 +70,6 @@ public class AutomationCompositionHandler { * @param stateChangeMsg the state change message */ public void handleAutomationCompositionStateChange(AutomationCompositionStateChange stateChangeMsg) { - if (stateChangeMsg.getAutomationCompositionId() == null) { - return; - } - var automationComposition = cacheProvider.getAutomationComposition(stateChangeMsg.getAutomationCompositionId()); if (automationComposition == null) { @@ -291,10 +287,6 @@ public class AutomationCompositionHandler { * @param migrationMsg the AutomationCompositionMigration */ public void handleAutomationCompositionMigration(AutomationCompositionMigration migrationMsg) { - if (migrationMsg.getAutomationCompositionId() == null || migrationMsg.getCompositionTargetId() == null) { - return; - } - var automationComposition = cacheProvider.getAutomationComposition(migrationMsg.getAutomationCompositionId()); if (automationComposition == null) { LOGGER.debug("Automation composition {} does not use this participant", diff --git a/participant/participant-intermediary/src/main/java/org/onap/policy/clamp/acm/participant/intermediary/handler/AutomationCompositionOutHandler.java b/participant/participant-intermediary/src/main/java/org/onap/policy/clamp/acm/participant/intermediary/handler/AutomationCompositionOutHandler.java index 32b8c8a78..30b52bd0f 100644 --- a/participant/participant-intermediary/src/main/java/org/onap/policy/clamp/acm/participant/intermediary/handler/AutomationCompositionOutHandler.java +++ b/participant/participant-intermediary/src/main/java/org/onap/policy/clamp/acm/participant/intermediary/handler/AutomationCompositionOutHandler.java @@ -160,12 +160,16 @@ public class AutomationCompositionOutHandler { } if (!SubState.NONE.equals(element.getSubState())) { - handleSubState(automationComposition, element, stateChangeResult); + if (!StateChangeResult.FAILED.equals(stateChangeResult)) { + element.setSubState(SubState.NONE); + } } else if (deployState != null) { - handleDeployState(automationComposition, element, deployState, stateChangeResult); + element.setDeployState(deployState); + element.setLockState( + DeployState.DEPLOYED.equals(element.getDeployState()) ? LockState.LOCKED : LockState.NONE); } if (lockState != null) { - handleLockState(automationComposition, element, lockState, stateChangeResult); + element.setLockState(lockState); } var acStateChangeAck = createAutomationCompositionDeployAck(); @@ -210,59 +214,6 @@ public class AutomationCompositionOutHandler { return acStateChangeAck; } - private void handleDeployState(AutomationComposition automationComposition, AutomationCompositionElement element, - DeployState deployState, StateChangeResult stateChangeResult) { - element.setDeployState(deployState); - element.setLockState(DeployState.DEPLOYED.equals(element.getDeployState()) ? LockState.LOCKED : LockState.NONE); - if (StateChangeResult.FAILED.equals(stateChangeResult)) { - return; - } - var checkOpt = automationComposition.getElements().values().stream() - .filter(acElement -> !deployState.equals(acElement.getDeployState())).findAny(); - if (checkOpt.isEmpty()) { - if (DeployState.DEPLOYED.equals(automationComposition.getDeployState()) - && automationComposition.getCompositionTargetId() != null) { - // migration scenario - automationComposition.setCompositionId(automationComposition.getCompositionTargetId()); - automationComposition.setCompositionTargetId(null); - } - automationComposition.setDeployState(deployState); - automationComposition.setLockState(element.getLockState()); - automationComposition.setSubState(SubState.NONE); - - if (DeployState.DELETED.equals(deployState)) { - cacheProvider.removeAutomationComposition(automationComposition.getInstanceId()); - } - } - } - - private void handleLockState(AutomationComposition automationComposition, AutomationCompositionElement element, - LockState lockState, StateChangeResult stateChangeResult) { - element.setLockState(lockState); - if (StateChangeResult.FAILED.equals(stateChangeResult)) { - return; - } - var checkOpt = automationComposition.getElements().values().stream() - .filter(acElement -> !lockState.equals(acElement.getLockState())).findAny(); - if (checkOpt.isEmpty()) { - automationComposition.setLockState(lockState); - automationComposition.setSubState(SubState.NONE); - } - } - - private void handleSubState(AutomationComposition automationComposition, AutomationCompositionElement element, - StateChangeResult stateChangeResult) { - if (StateChangeResult.FAILED.equals(stateChangeResult)) { - return; - } - element.setSubState(SubState.NONE); - var checkOpt = automationComposition.getElements().values().stream() - .filter(acElement -> !SubState.NONE.equals(acElement.getSubState())).findAny(); - if (checkOpt.isEmpty()) { - automationComposition.setSubState(SubState.NONE); - } - } - /** * Send Ac Element Info. * diff --git a/participant/participant-intermediary/src/test/java/org/onap/policy/clamp/acm/participant/intermediary/handler/AutomationCompositionOutHandlerTest.java b/participant/participant-intermediary/src/test/java/org/onap/policy/clamp/acm/participant/intermediary/handler/AutomationCompositionOutHandlerTest.java index e65f7bb05..7726391e4 100644 --- a/participant/participant-intermediary/src/test/java/org/onap/policy/clamp/acm/participant/intermediary/handler/AutomationCompositionOutHandlerTest.java +++ b/participant/participant-intermediary/src/test/java/org/onap/policy/clamp/acm/participant/intermediary/handler/AutomationCompositionOutHandlerTest.java @@ -201,7 +201,6 @@ class AutomationCompositionOutHandlerTest { } verify(publisher, times(automationComposition.getElements().size())) .sendAutomationCompositionAck(any(AutomationCompositionDeployAck.class)); - verify(cacheProvider).removeAutomationComposition(automationComposition.getInstanceId()); } @Test @@ -347,7 +346,6 @@ class AutomationCompositionOutHandlerTest { } verify(publisher, times(automationComposition.getElements().size())) .sendAutomationCompositionAck(any(AutomationCompositionDeployAck.class)); - assertEquals(compositionTarget, automationComposition.getCompositionId()); } @Test