Add flatten executor and logger

bom/pom.xml

@@ -8,7 +8,7 @@
     <parent>
         <groupId>com.optum.sourcehawk</groupId>
         <artifactId>sourcehawk</artifactId>
-        <version>0.4.0-SNAPSHOT</version>
+        <version>0.4.1-SNAPSHOT</version>
     </parent>
 
     <artifactId>sourcehawk-bom</artifactId>

configuration/pom.xml

@@ -8,7 +8,7 @@
     <parent>
         <groupId>com.optum.sourcehawk</groupId>
         <artifactId>sourcehawk</artifactId>
-        <version>0.4.0-SNAPSHOT</version>
+        <version>0.4.1-SNAPSHOT</version>
     </parent>
 
     <artifactId>sourcehawk-configuration</artifactId>

core/pom.xml

@@ -8,7 +8,7 @@
     <parent>
         <groupId>com.optum.sourcehawk</groupId>
         <artifactId>sourcehawk</artifactId>
-        <version>0.4.0-SNAPSHOT</version>
+        <version>0.4.1-SNAPSHOT</version>
         <relativePath>../pom.xml</relativePath>
     </parent>
 

core/src/main/java/com/optum/sourcehawk/core/scan/FlattenConfigResult.java

@@ -1,5 +1,6 @@
 package com.optum.sourcehawk.core.scan;
 
+import com.optum.sourcehawk.core.utils.StringUtils;
 import lombok.Builder;
 import lombok.NonNull;
 import lombok.Value;
@@ -37,7 +38,7 @@ public class FlattenConfigResult implements Serializable {
     @NonNull
     @Builder.Default
     @SuppressWarnings("squid:S1948") // Lombok generates private modifier
-            String formattedMessage = "Flatten successful";
+    String formattedMessage = "Flatten successful";
 
 
     /**
@@ -55,7 +56,7 @@ public static FlattenConfigResult success(final byte[] content) {
      * @return the flatten result
      */
     public static FlattenConfigResult error(final String message) {
-        return new FlattenConfigResult(null, true, message);
+        return new FlattenConfigResult(null, true, StringUtils.defaultString(message, "No error message provided"));
     }
 
 

distributions/debian/pom.xml

@@ -8,7 +8,7 @@
     <parent>
         <groupId>com.optum.sourcehawk</groupId>
         <artifactId>sourcehawk-dist</artifactId>
-        <version>0.4.0-SNAPSHOT</version>
+        <version>0.4.1-SNAPSHOT</version>
         <relativePath>../pom.xml</relativePath>
     </parent>
 

distributions/docker/pom.xml

@@ -8,7 +8,7 @@
     <parent>
         <groupId>com.optum.sourcehawk</groupId>
         <artifactId>sourcehawk-dist</artifactId>
-        <version>0.4.0-SNAPSHOT</version>
+        <version>0.4.1-SNAPSHOT</version>
         <relativePath>../pom.xml</relativePath>
     </parent>
 

distributions/linux/pom.xml

@@ -8,7 +8,7 @@
     <parent>
         <groupId>com.optum.sourcehawk</groupId>
         <artifactId>sourcehawk-dist</artifactId>
-        <version>0.4.0-SNAPSHOT</version>
+        <version>0.4.1-SNAPSHOT</version>
         <relativePath>../pom.xml</relativePath>
     </parent>
 

distributions/pom.xml

@@ -8,7 +8,7 @@
     <parent>
         <groupId>com.optum.sourcehawk</groupId>
         <artifactId>sourcehawk</artifactId>
-        <version>0.4.0-SNAPSHOT</version>
+        <version>0.4.1-SNAPSHOT</version>
         <relativePath>../pom.xml</relativePath>
     </parent>
 

distributions/rpm/pom.xml

@@ -8,7 +8,7 @@
     <parent>
         <artifactId>sourcehawk-dist</artifactId>
         <groupId>com.optum.sourcehawk</groupId>
-        <version>0.4.0-SNAPSHOT</version>
+        <version>0.4.1-SNAPSHOT</version>
     </parent>
 
     <artifactId>sourcehawk-dist-rpm</artifactId>

enforcer/core/pom.xml

@@ -8,7 +8,7 @@
     <parent>
         <groupId>com.optum.sourcehawk</groupId>
         <artifactId>sourcehawk-enforcer</artifactId>
-        <version>0.4.0-SNAPSHOT</version>
+        <version>0.4.1-SNAPSHOT</version>
         <relativePath>../pom.xml</relativePath>
     </parent>
 

enforcer/file/aot/pom.xml

@@ -8,7 +8,7 @@
     <parent>
         <groupId>com.optum.sourcehawk</groupId>
         <artifactId>sourcehawk-enforcer-file</artifactId>
-        <version>0.4.0-SNAPSHOT</version>
+        <version>0.4.1-SNAPSHOT</version>
         <relativePath>../pom.xml</relativePath>
     </parent>
 

enforcer/file/common/pom.xml

@@ -8,7 +8,7 @@
     <parent>
         <groupId>com.optum.sourcehawk</groupId>
         <artifactId>sourcehawk-enforcer-file</artifactId>
-        <version>0.4.0-SNAPSHOT</version>
+        <version>0.4.1-SNAPSHOT</version>
         <relativePath>../pom.xml</relativePath>
     </parent>
 

enforcer/file/core/pom.xml

@@ -8,7 +8,7 @@
     <parent>
         <groupId>com.optum.sourcehawk</groupId>
         <artifactId>sourcehawk-enforcer-file</artifactId>
-        <version>0.4.0-SNAPSHOT</version>
+        <version>0.4.1-SNAPSHOT</version>
         <relativePath>../pom.xml</relativePath>
     </parent>
 

enforcer/file/docker/pom.xml

@@ -8,7 +8,7 @@
     <parent>
         <groupId>com.optum.sourcehawk</groupId>
         <artifactId>sourcehawk-enforcer-file</artifactId>
-        <version>0.4.0-SNAPSHOT</version>
+        <version>0.4.1-SNAPSHOT</version>
         <relativePath>../pom.xml</relativePath>
     </parent>
 

enforcer/file/maven/pom.xml

@@ -8,7 +8,7 @@
     <parent>
         <groupId>com.optum.sourcehawk</groupId>
         <artifactId>sourcehawk-enforcer-file</artifactId>
-        <version>0.4.0-SNAPSHOT</version>
+        <version>0.4.1-SNAPSHOT</version>
         <relativePath>../pom.xml</relativePath>
     </parent>
 

enforcer/file/pom.xml

@@ -8,7 +8,7 @@
     <parent>
         <groupId>com.optum.sourcehawk</groupId>
         <artifactId>sourcehawk-enforcer</artifactId>
-        <version>0.4.0-SNAPSHOT</version>
+        <version>0.4.1-SNAPSHOT</version>
         <relativePath>../pom.xml</relativePath>
     </parent>
 

enforcer/file/registry/pom.xml

@@ -8,7 +8,7 @@
     <parent>
         <groupId>com.optum.sourcehawk</groupId>
         <artifactId>sourcehawk-enforcer-file</artifactId>
-        <version>0.4.0-SNAPSHOT</version>
+        <version>0.4.1-SNAPSHOT</version>
         <relativePath>../pom.xml</relativePath>
     </parent>
 

enforcer/pom.xml

@@ -8,7 +8,7 @@
     <parent>
         <groupId>com.optum.sourcehawk</groupId>
         <artifactId>sourcehawk</artifactId>
-        <version>0.4.0-SNAPSHOT</version>
+        <version>0.4.1-SNAPSHOT</version>
         <relativePath>../pom.xml</relativePath>
     </parent>
 

exec/pom.xml

@@ -8,7 +8,7 @@
     <parent>
         <groupId>com.optum.sourcehawk</groupId>
         <artifactId>sourcehawk</artifactId>
-        <version>0.4.0-SNAPSHOT</version>
+        <version>0.4.1-SNAPSHOT</version>
         <relativePath>../pom.xml</relativePath>
     </parent>
 

exec/src/main/java/com/optum/sourcehawk/exec/FlattenConfigCommand.java

@@ -1,18 +1,13 @@
 package com.optum.sourcehawk.exec;
 
-import com.fasterxml.jackson.databind.ObjectWriter;
-import com.optum.sourcehawk.configuration.SourcehawkConfiguration;
 import com.optum.sourcehawk.core.constants.SourcehawkConstants;
-import com.optum.sourcehawk.core.repository.LocalRepositoryFileWriter;
 import com.optum.sourcehawk.core.scan.FlattenConfigResult;
 import com.optum.sourcehawk.core.utils.StringUtils;
 import lombok.extern.slf4j.Slf4j;
 import lombok.val;
 import picocli.CommandLine;
 
-import java.io.IOException;
 import java.nio.file.Path;
-import java.nio.file.Paths;
 import java.util.concurrent.Callable;
 
 /**
@@ -29,9 +24,6 @@
 )
 class FlattenConfigCommand implements Callable<Integer> {
 
-    private static final ObjectWriter WRITER_WITH_DEFAULT_PRETTY_PRINTER = Sourcehawk.YAML_FORMATTER.writerWithDefaultPrettyPrinter();
-    private static final String SOURCEHAWK_FLATTENED_YML = "sourcehawk-flattened.yml";
-
     static final String COMMAND_NAME = "flatten-config";
 
     @CommandLine.Option(
@@ -70,9 +62,7 @@ public Integer call() {
             return CommandLine.ExitCode.SOFTWARE;
         }
         try {
-            flattenResult = ConfigurationReader.readConfiguration(Paths.get("."), configurationFileLocation)
-                    .map(sourcehawkConfiguration -> executeFlatten(configurationFileLocation, sourcehawkConfiguration))
-                    .orElseGet(() -> FlattenConfigResult.error(String.format("Configuration file %s not found or invalid", configurationFileLocation)));
+            flattenResult = FlattenConfigExecutor.flatten(configurationFileLocation);
         } catch (final Exception e) {
             flattenResult = FlattenConfigResult.error(e.getMessage());
         }
@@ -82,7 +72,7 @@ public Integer call() {
             return CommandLine.ExitCode.SOFTWARE;
         }
 
-        outputResults(flattenResult, output);
+        FlattenConfigResultLogger.log(flattenResult, output);
 
         return CommandLine.ExitCode.OK;
     }
@@ -98,80 +88,4 @@ private String getConfigurationFileLocation() {
         }
         return configurationFileLocation;
     }
-
-    /**
-     * Execute the flatten iterating over all configuration locations and aggregate the results
-     *
-     * @param configurationFileLocation the configuration location
-     * @param sourcehawkConfiguration   the flattened configuration object
-     * @return the aggregated flatten result
-     */
-    private static FlattenConfigResult executeFlatten(final String configurationFileLocation,
-                                                      final SourcehawkConfiguration sourcehawkConfiguration) {
-        byte[] content;
-        try {
-            content = WRITER_WITH_DEFAULT_PRETTY_PRINTER.writeValueAsBytes(sourcehawkConfiguration);
-        } catch (IOException e) {
-            return handleException(configurationFileLocation, e);
-        }
-
-        return FlattenConfigResult.success(content);
-    }
-
-    /**
-     * Handle exceptions from Serialization
-     *
-     * @param configurationFileLocation the configuration location
-     * @param e                         the exception
-     * @return an error flatten result
-     */
-    private static FlattenConfigResult handleException(final String configurationFileLocation, final IOException e) {
-        val message = String.format("Error flattening sourcehawk configuration at %s with error: %s", configurationFileLocation, e.getMessage());
-        return FlattenConfigResult.error(message);
-    }
-
-    /**
-     * Log the result of the flatten which will either output to a file or console based on params
-     *
-     * @param flattenResult      the flatten result
-     * @param repositoryFilePath the repository file path
-     */
-    void outputResults(final FlattenConfigResult flattenResult,
-                       final Path repositoryFilePath) {
-        if (repositoryFilePath == null || StringUtils.isBlankOrEmpty(repositoryFilePath.toString())) {
-            handleDryRunOutput(flattenResult);
-        } else {
-            handleFileSystemOutput(flattenResult, repositoryFilePath);
-        }
-    }
-
-    /**
-     * Log the result of the flatten to the file system
-     *
-     * @param flattenResult      the flatten result
-     * @param repositoryFilePath the repository file path
-     */
-    private static void handleFileSystemOutput(final FlattenConfigResult flattenResult, final Path repositoryFilePath) {
-        try {
-            val writerPath = StringUtils.defaultString(repositoryFilePath.toString(), SOURCEHAWK_FLATTENED_YML);
-            LocalRepositoryFileWriter.writer().write(writerPath, flattenResult.getContent());
-            Sourcehawk.CONSOLE_RAW_LOGGER.info(flattenResult.getFormattedMessage());
-            Sourcehawk.CONSOLE_RAW_LOGGER.info("Output to {}", writerPath);
-        } catch (IOException e) {
-            Sourcehawk.CONSOLE_RAW_LOGGER.error("Could not flatten file due to {}", e.getMessage());
-        }
-    }
-
-    /**
-     * Log the result of the flatten to the console
-     *
-     * @param flattenResult the flatten result
-     */
-    private static void handleDryRunOutput(final FlattenConfigResult flattenResult) {
-        if (flattenResult != null && flattenResult.getContent() != null) {
-            Sourcehawk.CONSOLE_RAW_LOGGER.info(new String(flattenResult.getContent()));
-        } else {
-            Sourcehawk.CONSOLE_RAW_LOGGER.error("No flattened file produced!");
-        }
-    }
 }

exec/src/main/java/com/optum/sourcehawk/exec/FlattenConfigExecutor.java

@@ -0,0 +1,71 @@
+package com.optum.sourcehawk.exec;
+
+import com.fasterxml.jackson.databind.ObjectWriter;
+import com.optum.sourcehawk.configuration.SourcehawkConfiguration;
+import com.optum.sourcehawk.core.scan.FlattenConfigResult;
+import com.optum.sourcehawk.core.utils.StringUtils;
+import lombok.AccessLevel;
+import lombok.NoArgsConstructor;
+import lombok.extern.slf4j.Slf4j;
+import lombok.val;
+
+import java.io.IOException;
+import java.nio.file.Paths;
+
+/**
+ * Entry point for executing Sourcehawk flatten command
+ *
+ * @author Christian Oestreich
+ */
+@Slf4j
+@NoArgsConstructor(access = AccessLevel.PRIVATE)
+public final class FlattenConfigExecutor {
+
+    private static final ObjectWriter WRITER_WITH_DEFAULT_PRETTY_PRINTER = Sourcehawk.YAML_FORMATTER.writerWithDefaultPrettyPrinter();
+
+    /**
+     * Run the flatten config based on the provided configuration file location
+     *
+     * @param configurationFileLocation the sourcehawk configuration location
+     * @return the flatten config result
+     */
+    public static FlattenConfigResult flatten(final String configurationFileLocation) {
+        if (StringUtils.isBlankOrEmpty(configurationFileLocation)) {
+            return FlattenConfigResult.error(String.format("Configuration file %s not found or invalid", configurationFileLocation));
+        }
+        return ConfigurationReader.readConfiguration(Paths.get("."), configurationFileLocation)
+                .map(sourcehawkConfiguration -> executeFlatten(configurationFileLocation, sourcehawkConfiguration))
+                .orElseGet(() -> FlattenConfigResult.error(String.format("Configuration file %s not found or invalid", configurationFileLocation)));
+    }
+
+    /**
+     * Execute the flatten iterating over all configuration locations and aggregate the results
+     *
+     * @param configurationFileLocation the configuration location
+     * @param sourcehawkConfiguration   the flattened configuration object
+     * @return the aggregated flatten result
+     */
+    private static FlattenConfigResult executeFlatten(final String configurationFileLocation,
+                                                      final SourcehawkConfiguration sourcehawkConfiguration) {
+        byte[] content;
+        try {
+            content = WRITER_WITH_DEFAULT_PRETTY_PRINTER.writeValueAsBytes(sourcehawkConfiguration);
+        } catch (IOException e) {
+            return handleException(configurationFileLocation, e);
+        }
+
+        return FlattenConfigResult.success(content);
+    }
+
+    /**
+     * Handle exceptions from Serialization
+     *
+     * @param configurationFileLocation the configuration location
+     * @param e                         the exception
+     * @return an error flatten result
+     */
+    private static FlattenConfigResult handleException(final String configurationFileLocation, final IOException e) {
+        val message = String.format("Error flattening sourcehawk configuration at %s with error: %s", configurationFileLocation, e.getMessage());
+        return FlattenConfigResult.error(message);
+    }
+}