fix: added command option to skip acls (#54)

* fix: added command option to skip acls

* fix: added default for the skip argument in other command classes

* refactor: made --skip-acls a global arg

Author: Cinetik

src/main/java/com/devshawn/kafka/gitops/MainCommand.java

@@ -30,6 +30,9 @@ public class MainCommand implements Callable<Integer> {
     @Option(names = {"--no-delete"}, description = "Disable the ability to delete resources.")
     private boolean deleteDisabled = false;
 
+    @Option(names = {"--skip-acls"}, description = "Do not take ACL into account in the plan file.")
+    private boolean skipAcls = false;
+
     @Option(names = {"-h", "--help"}, usageHelp = true, description = "Display this help message.")
     private boolean helpRequested = false;
 
@@ -65,6 +68,10 @@ public boolean isDeleteDisabled() {
         return deleteDisabled;
     }
 
+    public boolean areAclsDisabled() {
+        return skipAcls;
+    }
+
     public static void main(String[] args) {
         int exitCode = new CommandLine(new MainCommand()).execute(args);
         System.exit(exitCode);

src/main/java/com/devshawn/kafka/gitops/StateManager.java

@@ -86,7 +86,9 @@ public DesiredPlan plan() {
     private DesiredPlan generatePlan() {
         DesiredState desiredState = getDesiredState();
         DesiredPlan.Builder desiredPlan = new DesiredPlan.Builder();
-        planManager.planAcls(desiredState, desiredPlan);
+        if (!managerConfig.isSkipAclsDisabled()) {
+            planManager.planAcls(desiredState, desiredPlan);
+        }
         planManager.planTopics(desiredState, desiredPlan);
         return desiredPlan.build();
     }

src/main/java/com/devshawn/kafka/gitops/cli/AccountCommand.java

@@ -45,6 +45,7 @@ private ManagerConfig generateStateManagerConfig() {
                 .setVerboseRequested(parent.isVerboseRequested())
                 .setDeleteDisabled(parent.isDeleteDisabled())
                 .setIncludeUnchangedEnabled(false)
+                .setSkipAclsDisabled(parent.areAclsDisabled())
                 .setStateFile(parent.getFile())
                 .build();
     }

src/main/java/com/devshawn/kafka/gitops/cli/ApplyCommand.java

@@ -54,6 +54,7 @@ private ManagerConfig generateStateManagerConfig() {
                 .setVerboseRequested(parent.isVerboseRequested())
                 .setDeleteDisabled(parent.isDeleteDisabled())
                 .setIncludeUnchangedEnabled(false)
+                .setSkipAclsDisabled(parent.areAclsDisabled())
                 .setStateFile(parent.getFile())
                 .setNullablePlanFile(planFile)
                 .build();

src/main/java/com/devshawn/kafka/gitops/cli/PlanCommand.java

@@ -59,6 +59,7 @@ private ManagerConfig generateStateManagerConfig() {
                 .setDeleteDisabled(parent.isDeleteDisabled())
                 .setIncludeUnchangedEnabled(includeUnchanged)
                 .setStateFile(parent.getFile())
+                .setSkipAclsDisabled(parent.areAclsDisabled())
                 .setNullablePlanFile(outputFile)
                 .build();
     }

src/main/java/com/devshawn/kafka/gitops/cli/ValidateCommand.java

@@ -37,6 +37,7 @@ private ManagerConfig generateStateManagerConfig() {
                 .setVerboseRequested(parent.isVerboseRequested())
                 .setDeleteDisabled(parent.isDeleteDisabled())
                 .setIncludeUnchangedEnabled(false)
+                .setSkipAclsDisabled(parent.areAclsDisabled())
                 .setStateFile(parent.getFile())
                 .build();
     }

src/main/java/com/devshawn/kafka/gitops/config/ManagerConfig.java

@@ -16,6 +16,8 @@ public interface ManagerConfig {
 
     boolean isIncludeUnchangedEnabled();
 
+    boolean isSkipAclsDisabled();
+
     File getStateFile();
 
     Optional<File> getPlanFile();