feat: new legacy mongock-support module added (#728)

Author: osantana85

CLAUDE.md

@@ -130,7 +130,7 @@ This is a multi-module Gradle project using Kotlin DSL.
 
 **Core Modules** (`core/`):
 - `flamingock-core` - Core engine and orchestration logic
-- `flamingock-core-api` - Public API annotations (`@Change`, `@Execution`)
+- `flamingock-core-api` - Public API annotations (`@Change`, `@Apply`)
 - `flamingock-core-commons` - Shared internal utilities
 - `flamingock-processor` - Annotation processor for pipeline generation
 - `flamingock-graalvm` - GraalVM native image support

RECOVERY_EXAMPLE.md

@@ -7,13 +7,13 @@
 @Recovery(strategy = RecoveryStrategy.ALWAYS_RETRY)
 public class ExampleChangeWithRetry {
 
-    @Execution
-    public void execute() {
+    @Apply
+    public void apply() {
         // This change will be retried automatically if it fails
         System.out.println("Executing change that will be retried on failure");
     }
 
-    @RollbackExecution
+    @Rollback
     public void rollback() {
         System.out.println("Rolling back change");
     }
@@ -25,8 +25,8 @@ public class ExampleChangeWithRetry {
 @Recovery(strategy = RecoveryStrategy.MANUAL_INTERVENTION)  // This is the default
 public class ExampleChangeWithManualIntervention {
 
-    @Execution
-    public void execute() {
+    @Apply
+    public void apply() {
         // This change requires manual intervention if it fails (default behavior)
         System.out.println("Executing change requiring manual intervention on failure");
     }
@@ -38,8 +38,8 @@ public class ExampleChangeWithManualIntervention {
 // No @Recovery annotation = defaults to MANUAL_INTERVENTION
 public class ExampleChangeWithDefaultRecovery {
 
-    @Execution
-    public void execute() {
+    @Apply
+    public void apply() {
         // This change defaults to manual intervention
         System.out.println("Executing change with default recovery strategy");
     }

cloud/flamingock-cloud/src/test/java/io/flamingock/cloud/audit/HttpAuditWriterMapperTest.java

@@ -34,13 +34,13 @@ class HttpAuditWriterMapperTest {
     @Recovery(strategy = RecoveryStrategy.MANUAL_INTERVENTION)
     static class _001__TestManualInterventionChange {
         @Apply
-        public void execute() {}
+        public void apply() {}
     }
 
     @Change(id = "test-default", author = "aperezdieppa")
     static class _001__TestDefaultRecoveryChange {
         @Apply
-        public void execute() {}
+        public void apply() {}
     }
 
     @Test

cloud/flamingock-cloud/src/test/java/io/flamingock/core/cloud/CloudAuditPersistenceTest.java

@@ -82,15 +82,15 @@ static void beforeAll() {
                 "create-persons-table-from-template",
                 AuditEntryRequest.Status.APPLIED,
                 _001__CloudChange1.class.getName(),
-                "execution"
+                "apply"
         ));
         auditEntryExpectations.add(new
 
                 AuditEntryMatcher(
                 "create-persons-table-from-template-2",
                 AuditEntryRequest.Status.APPLIED,
                 _002__CloudChange2.class.getName(),
-                "execution"
+                "apply"
         ));
     }
 

cloud/flamingock-cloud/src/test/java/io/flamingock/core/cloud/CloudTransactionTest.java

@@ -75,15 +75,15 @@ static void beforeAll() {
                 "create-persons-table-from-template",
                 AuditEntryRequest.Status.APPLIED,
                 _001__CloudChange1.class.getName(),
-                "execution"
+                "apply"
         ));
         auditEntries.add(new
 
                 AuditEntryMatcher(
                 "create-persons-table-from-template-2",
                 AuditEntryRequest.Status.APPLIED,
                 _002__CloudChange2.class.getName(),
-                "execution"
+                "apply"
         ));
     }
 

cloud/flamingock-cloud/src/test/java/io/flamingock/core/cloud/changes/_001__CloudChange1.java

@@ -26,7 +26,7 @@ public class _001__CloudChange1 {
     public static final TaskExecutionChecker checker = new TaskExecutionChecker();
 
     @Apply
-    public void execution() {
+    public void apply() {
         checker.markExecution();
     }
 

cloud/flamingock-cloud/src/test/java/io/flamingock/core/cloud/changes/_002__CloudChange2.java

@@ -26,7 +26,7 @@ public class _002__CloudChange2 {
     public static final TaskExecutionChecker checker = new TaskExecutionChecker();
 
     @Apply
-    public void execution() {
+    public void apply() {
         checker.markExecution();
     }
 

cloud/flamingock-cloud/src/test/java/io/flamingock/core/utils/TaskExecutionChecker.java

@@ -47,22 +47,6 @@ public void markRollBackExecution() {
         history.add(TestTaskExecution.ROLLBACK_EXECUTION);
     }
 
-    public boolean isBeforeApplied() {
-        return history.contains(TestTaskExecution.BEFORE_EXECUTION);
-    }
-
-    public void markBeforeExecution() {
-        history.add(TestTaskExecution.BEFORE_EXECUTION);
-    }
-
-    public boolean isBeforeExecutionRolledBack() {
-        return history.contains(TestTaskExecution.ROLLBACK_BEFORE_EXECUTION);
-    }
-
-    public void markBeforeExecutionRollBack() {
-        history.add(TestTaskExecution.ROLLBACK_BEFORE_EXECUTION);
-    }
-
     public void checkOrderStrict(TestTaskExecution execution, TestTaskExecution... otherExecutions) {
         List<TestTaskExecution> allExecutions = new ArrayList<>();
         allExecutions.add(execution);

cloud/flamingock-cloud/src/test/java/io/flamingock/core/utils/TestTaskExecution.java

@@ -17,5 +17,5 @@
 
 public enum TestTaskExecution {
 
-    BEFORE_EXECUTION, ROLLBACK_BEFORE_EXECUTION, EXECUTION, ROLLBACK_EXECUTION
+    EXECUTION, ROLLBACK_EXECUTION
 }

community/flamingock-auditstore-couchbase/src/test/java/io/flamingock/community/couchbase/CouchbaseAuditStoreTest.java

@@ -26,7 +26,7 @@
 import io.flamingock.community.couchbase.changes.happyPath._003__insert_another_document;
 import io.flamingock.community.couchbase.driver.CouchbaseAuditStore;
 import io.flamingock.targetsystem.couchbase.CouchbaseTargetSystem;
-import io.flamingock.core.processor.util.Deserializer;
+import io.flamingock.internal.common.core.util.Deserializer;
 import io.flamingock.internal.common.core.audit.AuditEntry;
 import io.flamingock.internal.common.couchbase.CouchbaseCollectionHelper;
 import io.flamingock.internal.core.builder.FlamingockFactory;
@@ -139,7 +139,7 @@ void failedWithRollback() {
             mocked.when(Deserializer::readPreviewPipelineFromFile).thenReturn(PipelineTestHelper.getPreviewPipeline(
                     new Trio<>(io.flamingock.community.couchbase.changes.failedWithRollback._001__create_index.class, Collections.singletonList(Collection.class)),
                     new Trio<>(io.flamingock.community.couchbase.changes.failedWithRollback._002__insert_document.class, Collections.singletonList(Collection.class)),
-                    new Trio<>(io.flamingock.community.couchbase.changes.failedWithRollback._003__execution_with_exception.class, Collections.singletonList(Collection.class)))
+                    new Trio<>(io.flamingock.community.couchbase.changes.failedWithRollback._003__execution_with_exception.class, Collections.singletonList(Collection.class), Collections.singletonList(Collection.class)))
             );
 
             assertThrows(PipelineExecutionException.class, () -> {