diff options
author | FrancescoFioraEst <francesco.fiora@est.tech> | 2023-09-29 15:29:55 +0100 |
---|---|---|
committer | Francesco Fiora <francesco.fiora@est.tech> | 2023-10-02 16:47:37 +0000 |
commit | a70a907e2ad4f49c4807b1914e69b97f7573561e (patch) | |
tree | 4024b2a5785129aed25eeacdec22b15e5b5a2027 /participant/participant-impl/participant-impl-kubernetes/src | |
parent | c706398593f184301d38bd6cba86566da60bece6 (diff) |
Fix Sonar Issues for clamp/acm
Issue-ID: POLICY-4834
Change-Id: I4489dc66e9b20c8264ec88593f0b5d89d62f1ef8
Signed-off-by: FrancescoFioraEst <francesco.fiora@est.tech>
Diffstat (limited to 'participant/participant-impl/participant-impl-kubernetes/src')
3 files changed, 19 insertions, 16 deletions
diff --git a/participant/participant-impl/participant-impl-kubernetes/src/main/java/org/onap/policy/clamp/acm/participant/kubernetes/helm/HelmClient.java b/participant/participant-impl/participant-impl-kubernetes/src/main/java/org/onap/policy/clamp/acm/participant/kubernetes/helm/HelmClient.java index a05dfbc5f..8aca5245f 100644..100755 --- a/participant/participant-impl/participant-impl-kubernetes/src/main/java/org/onap/policy/clamp/acm/participant/kubernetes/helm/HelmClient.java +++ b/participant/participant-impl/participant-impl-kubernetes/src/main/java/org/onap/policy/clamp/acm/participant/kubernetes/helm/HelmClient.java @@ -1,6 +1,6 @@ /*- * ========================LICENSE_START================================= - * Copyright (C) 2021-2022 Nordix Foundation. All rights reserved. + * Copyright (C) 2021-2023 Nordix Foundation. All rights reserved. * ====================================================================== * Modifications Copyright (C) 2021 AT&T Intellectual Property. All rights reserved. * ====================================================================== @@ -26,7 +26,6 @@ import java.lang.invoke.MethodHandles; import java.nio.charset.StandardCharsets; import java.util.ArrayList; import java.util.List; -import java.util.Map; import org.apache.commons.io.IOUtils; import org.apache.commons.lang3.StringUtils; import org.onap.policy.clamp.acm.participant.kubernetes.exception.ServiceException; @@ -49,6 +48,9 @@ public class HelmClient { private static final Logger logger = LoggerFactory.getLogger(MethodHandles.lookup().lookupClass()); private static final String PATH_DELIMITER = "/"; + public static final String COMMAND_SH = "/bin/sh"; + private static final String COMMAND_HELM = "/usr/local/bin/helm"; + public static final String COMMAND_KUBECTL = "/usr/local/bin/kubectl"; /** * Install a chart. @@ -193,7 +195,7 @@ public class HelmClient { // @formatter:off List<String> helmArguments = new ArrayList<>( List.of( - "helm", + COMMAND_HELM, "repo", "add", repo.getRepoName(), repo.getAddress() )); @@ -206,7 +208,7 @@ public class HelmClient { private boolean verifyHelmRepoAlreadyExist(HelmRepository repo) { try { logger.debug("Verify the repo already exist in helm repositories"); - List<String> helmArguments = List.of("sh", "-c", "helm repo list | grep " + repo.getRepoName()); + var helmArguments = List.of(COMMAND_SH, "-c", COMMAND_HELM + " repo list | grep " + repo.getRepoName()); String response = executeCommand(new ProcessBuilder().command(helmArguments)); if (StringUtils.isEmpty(response)) { return false; @@ -219,7 +221,7 @@ public class HelmClient { } private ProcessBuilder prepareVerifyNamespaceCommand(String namespace) { - List<String> helmArguments = List.of("sh", "-c", "kubectl get ns | grep " + namespace); + var helmArguments = List.of(COMMAND_SH, "-c", COMMAND_KUBECTL + " get ns | grep " + namespace); return new ProcessBuilder().command(helmArguments); } @@ -228,7 +230,7 @@ public class HelmClient { // @formatter:off List<String> helmArguments = new ArrayList<>( List.of( - "helm", + COMMAND_HELM, "install", chart.getReleaseName(), chart.getRepository().getRepoName() + "/" + chart.getChartId().getName(), "--version", chart.getChartId().getVersion(), @@ -245,7 +247,7 @@ public class HelmClient { } if (chart.getOverrideParams() != null) { - for (Map.Entry<String, String> entry : chart.getOverrideParams().entrySet()) { + for (var entry : chart.getOverrideParams().entrySet()) { helmArguments.addAll(List.of("--set", entry.getKey() + "=" + entry.getValue())); } } @@ -253,23 +255,23 @@ public class HelmClient { } private ProcessBuilder prepareUnInstallCommand(ChartInfo chart) { - return new ProcessBuilder("helm", "delete", chart.getReleaseName(), "--namespace", + return new ProcessBuilder(COMMAND_HELM, "delete", chart.getReleaseName(), "--namespace", chart.getNamespace()); } private ProcessBuilder prepareCreateNamespaceCommand(String namespace) { - return new ProcessBuilder().command("kubectl", "create", "namespace", namespace); + return new ProcessBuilder().command(COMMAND_KUBECTL, "create", "namespace", namespace); } private ProcessBuilder helmRepoVerifyCommand(String chartName) { - return new ProcessBuilder().command("sh", "-c", "helm search repo | grep " + chartName); + return new ProcessBuilder().command(COMMAND_SH, "-c", COMMAND_HELM + " search repo | grep " + chartName); } private boolean updateHelmRepo() { try { logger.info("Updating local helm repositories before verifying the chart"); - executeCommand(new ProcessBuilder().command("helm", "repo", "update")); + executeCommand(new ProcessBuilder().command(COMMAND_HELM, "repo", "update")); logger.debug("Helm repositories updated successfully"); } catch (ServiceException e) { logger.error("Failed to update the helm repo: ", e); diff --git a/participant/participant-impl/participant-impl-kubernetes/src/main/java/org/onap/policy/clamp/acm/participant/kubernetes/helm/PodStatusValidator.java b/participant/participant-impl/participant-impl-kubernetes/src/main/java/org/onap/policy/clamp/acm/participant/kubernetes/helm/PodStatusValidator.java index 0a1424134..6c9656b78 100644..100755 --- a/participant/participant-impl/participant-impl-kubernetes/src/main/java/org/onap/policy/clamp/acm/participant/kubernetes/helm/PodStatusValidator.java +++ b/participant/participant-impl/participant-impl-kubernetes/src/main/java/org/onap/policy/clamp/acm/participant/kubernetes/helm/PodStatusValidator.java @@ -1,6 +1,6 @@ /*- * ========================LICENSE_START================================= - * Copyright (C) 2021-2022 Nordix Foundation. All rights reserved. + * Copyright (C) 2021-2023 Nordix Foundation. 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. @@ -101,8 +101,9 @@ public class PodStatusValidator { } private ProcessBuilder verifyPodStatusCommand(ChartInfo chart) { - String cmd = "kubectl get pods --namespace " + chart.getNamespace() + " | grep " + getPodName(); - return new ProcessBuilder("sh", "-c", cmd); + String cmd = HelmClient.COMMAND_KUBECTL + + " get pods --namespace " + chart.getNamespace() + " | grep " + getPodName(); + return new ProcessBuilder(HelmClient.COMMAND_SH, "-c", cmd); } private String getPodName() { diff --git a/participant/participant-impl/participant-impl-kubernetes/src/test/java/org/onap/policy/clamp/acm/participant/kubernetes/utils/CommonActuatorController.java b/participant/participant-impl/participant-impl-kubernetes/src/test/java/org/onap/policy/clamp/acm/participant/kubernetes/utils/CommonActuatorController.java index 2176478f0..4487dbe07 100755 --- a/participant/participant-impl/participant-impl-kubernetes/src/test/java/org/onap/policy/clamp/acm/participant/kubernetes/utils/CommonActuatorController.java +++ b/participant/participant-impl/participant-impl-kubernetes/src/test/java/org/onap/policy/clamp/acm/participant/kubernetes/utils/CommonActuatorController.java @@ -1,6 +1,6 @@ /*- * ============LICENSE_START======================================================= - * Copyright (C) 2021-2022 Nordix Foundation. + * Copyright (C) 2021-2023 Nordix Foundation. * ================================================================================ * Licensed under the Apache License, Version 2.0 (the "License"); * you may not use this file except in compliance with the License. @@ -20,7 +20,7 @@ package org.onap.policy.clamp.acm.participant.kubernetes.utils; -import static org.junit.Assert.assertEquals; +import static org.junit.jupiter.api.Assertions.assertEquals; import jakarta.ws.rs.client.ClientBuilder; import jakarta.ws.rs.client.Invocation; |