[fix]: [CDS-14581]: Revert ExceptionMessageSanitizer changes (#30625)

Author: yogesh-chauhan

260-delegate/src/main/java/io/harness/delegate/app/resource/HealthResource.java

@@ -1,10 +1,3 @@
-/*
- * Copyright 2022 Harness Inc. All rights reserved.
- * Use of this source code is governed by the PolyForm Free Trial 1.0.0 license
- * that can be found in the licenses directory at the root of this repository, also available at
- * https://polyformproject.org/wp-content/uploads/2020/05/PolyForm-Free-Trial-1.0.0.txt.
- */
-
 package io.harness.delegate.app.resource;
 
 import static io.harness.annotations.dev.HarnessTeam.DEL;
@@ -54,4 +47,4 @@ public ResponseDTO<String> get() throws Exception {
     }
     throw new HealthException(check.getMessage(), check.getError());
   }
-}
+}

260-delegate/src/main/java/software/wings/delegatetasks/azure/common/ArtifactDownloaderService.java

@@ -1,10 +1,3 @@
-/*
- * Copyright 2022 Harness Inc. All rights reserved.
- * Use of this source code is governed by the PolyForm Free Trial 1.0.0 license
- * that can be found in the licenses directory at the root of this repository, also available at
- * https://polyformproject.org/wp-content/uploads/2020/05/PolyForm-Free-Trial-1.0.0.txt.
- */
-
 package software.wings.delegatetasks.azure.common;
 
 import static io.harness.annotations.dev.HarnessTeam.CDP;

260-delegate/src/main/java/software/wings/delegatetasks/azure/common/ArtifactDownloaderServiceLogWrapper.java

@@ -1,10 +1,3 @@
-/*
- * Copyright 2022 Harness Inc. All rights reserved.
- * Use of this source code is governed by the PolyForm Free Trial 1.0.0 license
- * that can be found in the licenses directory at the root of this repository, also available at
- * https://polyformproject.org/wp-content/uploads/2020/05/PolyForm-Free-Trial-1.0.0.txt.
- */
-
 package software.wings.delegatetasks.azure.common;
 
 import static io.harness.annotations.dev.HarnessTeam.CDP;

260-delegate/src/main/java/software/wings/delegatetasks/azure/common/AutoCloseableWorkingDirectory.java

@@ -1,10 +1,3 @@
-/*
- * Copyright 2022 Harness Inc. All rights reserved.
- * Use of this source code is governed by the PolyForm Free Trial 1.0.0 license
- * that can be found in the licenses directory at the root of this repository, also available at
- * https://polyformproject.org/wp-content/uploads/2020/05/PolyForm-Free-Trial-1.0.0.txt.
- */
-
 package software.wings.delegatetasks.azure.common;
 
 import static io.harness.azure.model.AzureConstants.UNIX_SEPARATOR;

260-delegate/src/main/java/software/wings/delegatetasks/azure/common/AzureContainerRegistryService.java

@@ -1,10 +1,3 @@
-/*
- * Copyright 2022 Harness Inc. All rights reserved.
- * Use of this source code is governed by the PolyForm Free Trial 1.0.0 license
- * that can be found in the licenses directory at the root of this repository, also available at
- * https://polyformproject.org/wp-content/uploads/2020/05/PolyForm-Free-Trial-1.0.0.txt.
- */
-
 package software.wings.delegatetasks.azure.common;
 
 import static io.harness.annotations.dev.HarnessTeam.CDP;

260-delegate/src/main/java/software/wings/delegatetasks/azure/common/context/ArtifactDownloaderContext.java

@@ -1,10 +1,3 @@
-/*
- * Copyright 2022 Harness Inc. All rights reserved.
- * Use of this source code is governed by the PolyForm Free Trial 1.0.0 license
- * that can be found in the licenses directory at the root of this repository, also available at
- * https://polyformproject.org/wp-content/uploads/2020/05/PolyForm-Free-Trial-1.0.0.txt.
- */
-
 package software.wings.delegatetasks.azure.common.context;
 
 import static io.harness.annotations.dev.HarnessTeam.CDP;

260-delegate/src/main/java/software/wings/delegatetasks/azure/common/validator/ArtifactTypeSubset.java

@@ -1,10 +1,3 @@
-/*
- * Copyright 2022 Harness Inc. All rights reserved.
- * Use of this source code is governed by the PolyForm Free Trial 1.0.0 license
- * that can be found in the licenses directory at the root of this repository, also available at
- * https://polyformproject.org/wp-content/uploads/2020/05/PolyForm-Free-Trial-1.0.0.txt.
- */
-
 package software.wings.delegatetasks.azure.common.validator;
 
 import static java.lang.annotation.ElementType.ANNOTATION_TYPE;

260-delegate/src/main/java/software/wings/delegatetasks/azure/common/validator/ArtifactTypeSubsetValidator.java

@@ -1,10 +1,3 @@
-/*
- * Copyright 2022 Harness Inc. All rights reserved.
- * Use of this source code is governed by the PolyForm Free Trial 1.0.0 license
- * that can be found in the licenses directory at the root of this repository, also available at
- * https://polyformproject.org/wp-content/uploads/2020/05/PolyForm-Free-Trial-1.0.0.txt.
- */
-
 package software.wings.delegatetasks.azure.common.validator;
 
 import software.wings.utils.ArtifactType;

260-delegate/src/main/java/software/wings/delegatetasks/helm/HelmValuesFetchTask.java

@@ -31,11 +31,9 @@
 import io.harness.delegate.task.AbstractDelegateRunnableTask;
 import io.harness.delegate.task.TaskParameters;
 import io.harness.logging.CommandExecutionStatus;
-import io.harness.secret.SecretSanitizerThreadLocal;
 
 import software.wings.beans.command.ExecutionLogCallback;
 import software.wings.delegatetasks.DelegateLogService;
-import software.wings.delegatetasks.ExceptionMessageSanitizer;
 import software.wings.helpers.ext.helm.request.HelmChartConfigParams;
 import software.wings.helpers.ext.helm.request.HelmValuesFetchTaskParameters;
 import software.wings.helpers.ext.helm.response.HelmValuesFetchTaskResponse;
@@ -59,7 +57,6 @@ public class HelmValuesFetchTask extends AbstractDelegateRunnableTask {
   public HelmValuesFetchTask(DelegateTaskPackage delegateTaskPackage, ILogStreamingTaskClient logStreamingTaskClient,
       Consumer<DelegateTaskResponse> consumer, BooleanSupplier preExecute) {
     super(delegateTaskPackage, logStreamingTaskClient, consumer, preExecute);
-    SecretSanitizerThreadLocal.addAll(delegateTaskPackage.getSecrets());
   }
 
   @Override
@@ -92,13 +89,12 @@ public HelmValuesFetchTaskResponse run(TaskParameters parameters) {
           .mapK8sValuesLocationToContent(mapK8sValuesLocationToContent)
           .build();
     } catch (Exception e) {
-      Exception sanitizedException = ExceptionMessageSanitizer.sanitizeException(e);
-      log.error("HelmValuesFetchTask execution failed with exception ", sanitizedException);
-      executionLogCallback.saveExecutionLog(sanitizedException.getMessage(), ERROR, CommandExecutionStatus.FAILURE);
+      log.error("HelmValuesFetchTask execution failed with exception ", e);
+      executionLogCallback.saveExecutionLog(e.getMessage(), ERROR, CommandExecutionStatus.FAILURE);
 
       return HelmValuesFetchTaskResponse.builder()
           .commandExecutionStatus(FAILURE)
-          .errorMessage("Execution failed with Exception: " + sanitizedException.getMessage())
+          .errorMessage("Execution failed with Exception: " + e.getMessage())
           .build();
     }
   }

260-delegate/src/main/java/software/wings/delegatetasks/k8s/K8sTask.java

@@ -29,9 +29,7 @@
 import io.harness.k8s.K8sGlobalConfigService;
 import io.harness.k8s.model.K8sDelegateTaskParams;
 import io.harness.logging.CommandExecutionStatus;
-import io.harness.secret.SecretSanitizerThreadLocal;
 
-import software.wings.delegatetasks.ExceptionMessageSanitizer;
 import software.wings.delegatetasks.k8s.taskhandler.K8sTaskHandler;
 import software.wings.helpers.ext.container.ContainerDeploymentDelegateHelper;
 import software.wings.helpers.ext.k8s.request.K8sTaskParameters;
@@ -56,7 +54,6 @@ public class K8sTask extends AbstractDelegateRunnableTask {
   public K8sTask(DelegateTaskPackage delegateTaskPackage, ILogStreamingTaskClient logStreamingTaskClient,
       Consumer<DelegateTaskResponse> consumer, BooleanSupplier preExecute) {
     super(delegateTaskPackage, logStreamingTaskClient, consumer, preExecute);
-    SecretSanitizerThreadLocal.addAll(delegateTaskPackage.getSecrets());
   }
 
   @Override
@@ -75,12 +72,11 @@ public K8sTaskExecutionResponse run(TaskParameters parameters) {
         return k8sCommandTaskTypeToTaskHandlerMap.get(k8sTaskParameters.getCommandType().name())
             .executeTask(k8sTaskParameters, null);
       } catch (Exception ex) {
-        Exception sanitizedException = ExceptionMessageSanitizer.sanitizeException(ex);
         log.error("Exception in processing K8s task [{}]",
-            k8sTaskParameters.getCommandName() + ":" + k8sTaskParameters.getCommandType(), sanitizedException);
+            k8sTaskParameters.getCommandName() + ":" + k8sTaskParameters.getCommandType(), ex);
         return K8sTaskExecutionResponse.builder()
             .commandExecutionStatus(CommandExecutionStatus.FAILURE)
-            .errorMessage(ExceptionUtils.getMessage(sanitizedException))
+            .errorMessage(ExceptionUtils.getMessage(ex))
             .build();
       }
     } else {
@@ -118,12 +114,11 @@ public K8sTaskExecutionResponse run(TaskParameters parameters) {
         return k8sCommandTaskTypeToTaskHandlerMap.get(k8sTaskParameters.getCommandType().name())
             .executeTask(k8sTaskParameters, k8SDelegateTaskParams);
       } catch (Exception ex) {
-        Exception sanitizedException = ExceptionMessageSanitizer.sanitizeException(ex);
         log.error("Exception in processing K8s task [{}]",
-            k8sTaskParameters.getCommandName() + ":" + k8sTaskParameters.getCommandType(), sanitizedException);
+            k8sTaskParameters.getCommandName() + ":" + k8sTaskParameters.getCommandType(), ex);
         return K8sTaskExecutionResponse.builder()
             .commandExecutionStatus(CommandExecutionStatus.FAILURE)
-            .errorMessage(ExceptionUtils.getMessage(sanitizedException))
+            .errorMessage(ExceptionUtils.getMessage(ex))
             .build();
       } finally {
         cleanup(workingDirectory);
@@ -136,7 +131,7 @@ private void logK8sVersion(K8sTaskParameters k8sTaskParameters, K8sDelegateTaskP
       k8sCommandTaskTypeToTaskHandlerMap.get(K8sTaskType.VERSION.name())
           .executeTask(k8sTaskParameters, k8sDelegateTaskParams);
     } catch (Exception ex) {
-      log.error("Error fetching K8s Server Version: ", ExceptionMessageSanitizer.sanitizeException(ex));
+      log.error("Error fetching K8s Server Version: ", ex);
     }
   }
 
@@ -145,7 +140,7 @@ private void cleanup(String workingDirectory) {
       log.warn("Cleaning up directory " + workingDirectory);
       deleteDirectoryAndItsContentIfExists(workingDirectory);
     } catch (Exception ex) {
-      log.warn("Exception in directory cleanup.", ExceptionMessageSanitizer.sanitizeException(ex));
+      log.warn("Exception in directory cleanup.", ex);
     }
   }
 }