[axon-system-plugin] Add test for CommitCommandFixturesLineRunner

Author: clickout

axon-system-plugin/src/main/java/ai/stapi/axonsystemplugin/commandpersisting/CommitCommandFixturesLineRunner.java

@@ -21,17 +21,22 @@ public CommitCommandFixturesLineRunner(
   }
 
   @Override
-  public void run(String... args) throws Exception {
+  public void run(String... args) {
+    var outputDirectoryPath = getOutputDirectoryPath(args);
+    this.commandGateway.sendAndWait(new CommitCommandFixtures(outputDirectoryPath));
+    var exitCode = SpringApplication.exit(this.applicationContext, () -> 0);
+    System.exit(exitCode);
+  }
+
+  public static String getOutputDirectoryPath(String... args) {
     if (args.length == 0) {
       throw new RuntimeException("Please specify path where to commit persisted commands as command line argument.");
     }
     var path = Arrays.stream(args)
         .filter(arg -> arg.startsWith("_outputPath:"))
         .map(arg -> arg.replace("_outputPath:", ""))
         .findFirst();
-    
-    this.commandGateway.sendAndWait(new CommitCommandFixtures(path.orElse(args[0])));
-    var exitCode = SpringApplication.exit(this.applicationContext, () -> 0);
-    System.exit(exitCode);
+
+    return path.orElse(args[0]);
   }
 }

axon-system-plugin/src/test/java/ai/stapi/axonsystemplugin/commandpersisting/CommitCommandFixturesLineRunnerTest.java

@@ -0,0 +1,52 @@
+package ai.stapi.axonsystemplugin.commandpersisting;
+
+import ai.stapi.axonsystem.commandpersisting.CommandMessageStore;
+import ai.stapi.axonsystemplugin.exampleimplmentation.CreateNewExampleNodeCommand;
+import ai.stapi.identity.UniversallyUniqueIdentifier;
+import ai.stapi.test.domain.DomainTestCase;
+import org.jetbrains.annotations.NotNull;
+import org.junit.jupiter.api.Assertions;
+import org.junit.jupiter.api.BeforeEach;
+import org.junit.jupiter.api.Test;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.test.context.ActiveProfiles;
+
+
+@ActiveProfiles("dev")
+class CommitCommandFixturesLineRunnerTest extends DomainTestCase {
+    
+    private final CommandMessageStore commandMessageStore;
+
+    public CommitCommandFixturesLineRunnerTest(
+        @Autowired CommandMessageStore commandMessageStore
+    ) {
+        this.commandMessageStore = commandMessageStore;
+    }
+
+    @BeforeEach
+    void before() {
+        this.commandMessageStore.wipeAll();
+    }
+
+    @Test
+    public void itWorks() {
+        this.givenCommandIsDispatched(
+            new CreateNewExampleNodeCommand(
+                UniversallyUniqueIdentifier.randomUUID(),
+                "ExampleNodeType",
+                "Example Name"
+            )
+        );
+
+        var actualPath = this.getActualOutputDirectoryPath();
+        var actualOutputPath = CommitCommandFixturesLineRunner.getOutputDirectoryPath(
+                String.format("_outputPath:%s", actualPath)
+        );
+        Assertions.assertEquals(actualPath, actualOutputPath);
+    }
+
+    @NotNull
+    private String getActualOutputDirectoryPath() {
+        return this.getLocationFilePath() + "/output";
+    }
+}