feat: propagate sourceFile field value from template based changes to audit entries (#865)

Author: osantana85

community/flamingock-auditstore-couchbase/src/test/java/io/flamingock/store/couchbase/PipelineTestHelper.java

@@ -87,6 +87,7 @@ public static FlamingockMetadata getPreviewPipeline(String stageName, Trio<Class
                             changeInfo.getOrder(),
                             changeInfo.getAuthor(),
                             trio.getFirst().getName(),
+                            null,
                             PreviewConstructor.getDefault(),
                             new PreviewMethod("apply", getParameterTypes(trio.getSecond())),
                             rollback,

community/flamingock-auditstore-dynamodb/src/test/java/io/flamingock/store/dynamodb/PipelineTestHelper.java

@@ -88,6 +88,7 @@ public static PreviewPipeline getPreviewPipeline(String stageName, Trio<Class<?>
                             changeInfo.getOrder(),
                             changeInfo.getAuthor(),
                             trio.getFirst().getName(),
+                            null,
                             PreviewConstructor.getDefault(),
                             new PreviewMethod("apply", getParameterTypes(trio.getSecond())),
                             rollback,

community/flamingock-auditstore-dynamodb/src/test/java/io/flamingock/store/dynamodb/internal/entities/AuditEntryEntityTest.java

@@ -58,6 +58,7 @@ void shouldConvertToAndFromAuditEntryWithTxType() {
         assertEquals(original.getTaskId(), converted.getTaskId());
         assertEquals(original.getAuthor(), converted.getAuthor());
         assertEquals(original.getState(), converted.getState());
+        assertEquals(original.getSourceFile(), converted.getSourceFile());
     }
 
     @Test
@@ -129,6 +130,7 @@ void shouldConvertToAndFromAuditEntryWithTargetSystemId() {
         assertEquals(original.getTaskId(), converted.getTaskId());
         assertEquals(original.getAuthor(), converted.getAuthor());
         assertEquals(original.getState(), converted.getState());
+        assertEquals(original.getSourceFile(), converted.getSourceFile());
     }
 
     @Test

community/flamingock-auditstore-sql/src/test/java/io/flamingock/store/sql/PipelineTestHelper.java

@@ -87,6 +87,7 @@ public static FlamingockMetadata getPreviewPipeline(String stageName, Trio<Class
                             changeInfo.getOrder(),
                             changeInfo.getAuthor(),
                             trio.getFirst().getName(),
+                            null,
                             PreviewConstructor.getDefault(),
                             new PreviewMethod("apply", getParameterTypes(trio.getSecond())),
                             rollback,

core/flamingock-core-commons/src/main/java/io/flamingock/internal/common/core/preview/AbstractPreviewTask.java

@@ -36,13 +36,14 @@ public AbstractPreviewTask(String id,
                                String order,
                                String author,
                                String source,
+                               String sourceFile,
                                boolean runAlways,
                                Boolean transactional,
                                boolean system,
                                TargetSystemDescriptor targetSystem,
                                RecoveryDescriptor recovery,
                                boolean legacy) {
-        super(id, order, author, source, runAlways, transactional, system, targetSystem, recovery, legacy);
+        super(id, order, author, source, sourceFile, runAlways, transactional, system, targetSystem, recovery, legacy);
     }
 
     @Override

core/flamingock-core-commons/src/main/java/io/flamingock/internal/common/core/preview/CodePreviewChange.java

@@ -36,6 +36,7 @@ public CodePreviewChange(String id,
                              String order,
                              String author,
                              String sourceClassPath,
+                             String sourceFile,
                              PreviewConstructor previewConstructor,
                              PreviewMethod applyPreviewMethod,
                              PreviewMethod rollbackPreviewMethod,
@@ -45,7 +46,7 @@ public CodePreviewChange(String id,
                              TargetSystemDescriptor targetSystem,
                              RecoveryDescriptor recovery,
                              boolean legacy) {
-        super(id, order, author, sourceClassPath, runAlways, transactional, system, targetSystem, recovery, legacy);
+        super(id, order, author, sourceClassPath, sourceFile, runAlways, transactional, system, targetSystem, recovery, legacy);
         this.previewConstructor = previewConstructor;
         this.applyPreviewMethod = applyPreviewMethod;
         this.rollbackPreviewMethod = rollbackPreviewMethod;

core/flamingock-core-commons/src/main/java/io/flamingock/internal/common/core/preview/TemplatePreviewChange.java

@@ -48,7 +48,7 @@ public TemplatePreviewChange(String fileName,
                                  Object steps,
                                  TargetSystemDescriptor targetSystem,
                                  RecoveryDescriptor recovery) {
-        super(id, order, author, templateName, runAlways, transactional, system, targetSystem, recovery, false);
+        super(id, order, author, templateName, fileName, runAlways, transactional, system, targetSystem, recovery, false);
         this.fileName = fileName;
         this.profiles = profiles;
         this.configuration = configuration;

core/flamingock-core-commons/src/main/java/io/flamingock/internal/common/core/preview/builder/CodePreviewTaskBuilder.java

@@ -171,6 +171,7 @@ private CodePreviewChange getCodePreviewChange() {
                 order,
                 author,
                 sourceClassPath,
+                null,
                 constructor,
                 applyMethod,
                 rollbackMethod,

core/flamingock-core-commons/src/main/java/io/flamingock/internal/common/core/task/AbstractTaskDescriptor.java

@@ -29,6 +29,8 @@ public abstract class AbstractTaskDescriptor implements TaskDescriptor {
 
     protected String source;
 
+    protected String sourceFile;
+
     protected boolean runAlways;
 
     protected Boolean transactionalFlag;
@@ -47,6 +49,7 @@ public AbstractTaskDescriptor(String id,
                                   String order,
                                   String author,
                                   String source,
+                                  String sourceFile,
                                   boolean runAlways,
                                   Boolean transactionalFlag,
                                   boolean system,
@@ -57,6 +60,7 @@ public AbstractTaskDescriptor(String id,
         this.order = order;
         this.author = author;
         this.source = source;
+        this.sourceFile = sourceFile;
         this.runAlways = runAlways;
         this.transactionalFlag = transactionalFlag;
         this.system = system;
@@ -85,6 +89,11 @@ public String getSource() {
         return source;
     }
 
+    @Override
+    public String getSourceFile() {
+        return sourceFile;
+    }
+
     @Override
     public boolean isRunAlways() {
         return runAlways;
@@ -131,6 +140,10 @@ public void setSource(String source) {
         this.source = source;
     }
 
+    public void setSourceFile(String sourceFile) {
+        this.sourceFile = sourceFile;
+    }
+
     public void setRunAlways(boolean runAlways) {
         this.runAlways = runAlways;
     }
@@ -174,6 +187,7 @@ public int hashCode() {
     public String toString() {
         return new StringJoiner(", ", AbstractTaskDescriptor.class.getSimpleName() + "[", "]")
                 .add("source=" + source)
+                .add("sourceFile=" + sourceFile)
                 .add("sourceClass=" + getSource())
                 .add("sourceName='" + getSource() + "'")
                 .add("id='" + getId() + "'")

core/flamingock-core-commons/src/main/java/io/flamingock/internal/common/core/task/TaskDescriptor.java

@@ -32,6 +32,8 @@ public interface TaskDescriptor extends Comparable<TaskDescriptor> {
 
     String getSource();
 
+    String getSourceFile();
+
     Optional<String> getOrder();
 
     TargetSystemDescriptor getTargetSystem();