chore: Implemented migration with Turtle framework (#18902)

Signed-off-by: Michael Heinrichs <[email protected]>

Author: netopyr

platform-sdk/consensus-otter-tests/src/test/java/org/hiero/otter/test/BirthRoundMigrationTest.java

@@ -1,6 +1,8 @@
 // SPDX-License-Identifier: Apache-2.0
 package org.hiero.otter.test;
 
+import static org.hiero.otter.fixtures.turtle.TurtleNodeConfiguration.SOFTWARE_VERSION;
+
 import java.time.Duration;
 import org.hiero.consensus.config.EventConfig_;
 import org.hiero.otter.fixtures.Network;
@@ -15,6 +17,9 @@ class BirthRoundMigrationTest {
     private static final Duration THIRTY_SECONDS = Duration.ofSeconds(30L);
     private static final Duration ONE_MINUTE = Duration.ofMinutes(1L);
 
+    private static final String OLD_VERSION = "1.0.0";
+    private static final String NEW_VERSION = "1.0.1";
+
     @OtterTest
     @Disabled
     void testBirthRoundMigration(TestEnvironment env) throws InterruptedException {
@@ -23,6 +28,9 @@ void testBirthRoundMigration(TestEnvironment env) throws InterruptedException {
 
         // Setup simulation
         network.addNodes(4);
+        for (final Node node : network.getNodes()) {
+            node.getConfiguration().set(SOFTWARE_VERSION, OLD_VERSION);
+        }
         network.start(ONE_MINUTE);
         env.generator().start();
 
@@ -35,7 +43,9 @@ void testBirthRoundMigration(TestEnvironment env) throws InterruptedException {
 
         // update the configuration
         for (final Node node : network.getNodes()) {
-            node.getConfiguration().set(EventConfig_.USE_BIRTH_ROUND_ANCIENT_THRESHOLD, true);
+            node.getConfiguration()
+                    .set(EventConfig_.USE_BIRTH_ROUND_ANCIENT_THRESHOLD, true)
+                    .set(SOFTWARE_VERSION, NEW_VERSION);
         }
 
         // restart the network

platform-sdk/consensus-otter-tests/src/testFixtures/java/module-info.java

@@ -5,6 +5,7 @@
     requires transitive com.swirlds.platform.core;
     requires transitive org.apache.logging.log4j.core;
     requires transitive org.junit.jupiter.api;
+    requires com.hedera.node.config;
     requires com.hedera.node.hapi;
     requires com.hedera.pbj.runtime;
     requires com.swirlds.base.test.fixtures;

platform-sdk/consensus-otter-tests/src/testFixtures/java/org/hiero/otter/fixtures/NodeConfiguration.java

@@ -17,4 +17,13 @@ public interface NodeConfiguration<T extends NodeConfiguration> {
      * @return this {@code NodeConfiguration} instance for method chaining
      */
     T set(@NonNull String key, boolean value);
+
+    /**
+     * Updates a single property of the configuration.
+     *
+     * @param key the key of the property
+     * @param value the value of the property
+     * @return this {@code NodeConfiguration} instance for method chaining
+     */
+    T set(@NonNull String key, @NonNull String value);
 }

platform-sdk/consensus-otter-tests/src/testFixtures/java/org/hiero/otter/fixtures/turtle/TurtleApp.java

@@ -23,6 +23,7 @@
 import org.hiero.consensus.model.hashgraph.Round;
 import org.hiero.consensus.model.transaction.ScopedSystemTransaction;
 
+@SuppressWarnings("removal")
 public enum TurtleApp implements ConsensusStateEventHandler<TurtleTestingToolState> {
     INSTANCE;
 

platform-sdk/consensus-otter-tests/src/testFixtures/java/org/hiero/otter/fixtures/turtle/TurtleNode.java

@@ -59,8 +59,12 @@
  *
  * <p>This class implements the {@link Node} interface and provides methods to control the state of the node.
  */
+@SuppressWarnings("removal")
 public class TurtleNode implements Node, TurtleTimeManager.TimeTickReceiver {
 
+    private static final SemanticVersion DEFAULT_VERSION =
+            SemanticVersion.newBuilder().major(1).build();
+
     public static final String THREAD_CONTEXT_NODE_ID = "nodeId";
     private static final Logger log = LogManager.getLogger(TurtleNode.class);
 
@@ -294,7 +298,8 @@ private void doStartNode() {
         model = WiringModelBuilder.create(platformContext.getMetrics(), time)
                 .withDeterministicModeEnabled(true)
                 .build();
-        final SemanticVersion version = SemanticVersion.newBuilder().major(1).build();
+        final SemanticVersion version = currentConfiguration.getValue(
+                TurtleNodeConfiguration.SOFTWARE_VERSION, SemanticVersion.class, DEFAULT_VERSION);
         final PlatformStateFacade platformStateFacade = new PlatformStateFacade();
         MerkleDb.resetDefaultInstancePath();
         final Metrics metrics = getMetricsProvider().createPlatformMetrics(selfId);

platform-sdk/consensus-otter-tests/src/testFixtures/java/org/hiero/otter/fixtures/turtle/TurtleNodeConfiguration.java

@@ -3,12 +3,15 @@
 
 import static java.util.Objects.requireNonNull;
 
+import com.hedera.hapi.node.base.SemanticVersion;
+import com.hedera.node.config.converter.SemanticVersionConverter;
 import com.swirlds.common.config.StateCommonConfig_;
 import com.swirlds.common.io.config.FileSystemManagerConfig_;
 import com.swirlds.config.api.Configuration;
 import com.swirlds.config.extensions.sources.SimpleConfigSource;
 import com.swirlds.config.extensions.test.fixtures.TestConfigBuilder;
 import com.swirlds.platform.config.BasicConfig_;
+import com.swirlds.platform.event.preconsensus.PcesConfig_;
 import com.swirlds.platform.wiring.PlatformSchedulersConfig_;
 import edu.umd.cs.findbugs.annotations.NonNull;
 import java.nio.file.Path;
@@ -21,6 +24,8 @@
  */
 public class TurtleNodeConfiguration implements NodeConfiguration<TurtleNodeConfiguration> {
 
+    public static final String SOFTWARE_VERSION = "turtle.software.version";
+
     private final Map<String, String> overriddenProperties = new HashMap<>();
     private final Path outputDirectory;
 
@@ -50,16 +55,28 @@ Configuration createConfiguration() {
      */
     @Override
     @NonNull
-    public TurtleNodeConfiguration set(@NonNull String key, boolean value) {
+    public TurtleNodeConfiguration set(@NonNull final String key, final boolean value) {
         overriddenProperties.put(key, Boolean.toString(value));
         return this;
     }
 
+    /**
+     * {@inheritDoc}
+     */
+    @Override
+    @NonNull
+    public TurtleNodeConfiguration set(@NonNull final String key, @NonNull final String value) {
+        overriddenProperties.put(key, value);
+        return this;
+    }
+
     private TestConfigBuilder createBasicConfigBuilder() {
         return new TestConfigBuilder()
+                .withConverter(SemanticVersion.class, new SemanticVersionConverter())
                 .withValue(PlatformSchedulersConfig_.CONSENSUS_EVENT_STREAM, "NO_OP")
-                .withValue(BasicConfig_.JVM_PAUSE_DETECTOR_SLEEP_MS, "0")
+                .withValue(BasicConfig_.JVM_PAUSE_DETECTOR_SLEEP_MS, 0)
                 .withValue(StateCommonConfig_.SAVED_STATE_DIRECTORY, outputDirectory.toString())
-                .withValue(FileSystemManagerConfig_.ROOT_PATH, outputDirectory.toString());
+                .withValue(FileSystemManagerConfig_.ROOT_PATH, outputDirectory.toString())
+                .withValue(PcesConfig_.LIMIT_REPLAY_FREQUENCY, false);
     }
 }

platform-sdk/consensus-otter-tests/src/testFixtures/java/org/hiero/otter/fixtures/turtle/TurtleTestEnvironment.java

@@ -1,6 +1,8 @@
 // SPDX-License-Identifier: Apache-2.0
 package org.hiero.otter.fixtures.turtle;
 
+import static com.swirlds.platform.test.fixtures.state.FakeConsensusStateEventHandler.registerMerkleStateRootClassIds;
+
 import com.swirlds.base.test.fixtures.time.FakeTime;
 import com.swirlds.common.io.utility.FileUtils;
 import com.swirlds.common.test.fixtures.Randotron;
@@ -82,6 +84,7 @@ public TurtleTestEnvironment() {
             final ConstructableRegistry registry = ConstructableRegistry.getInstance();
             registry.registerConstructables("org.hiero");
             registry.registerConstructables("com.swirlds");
+            registerMerkleStateRootClassIds();
         } catch (final ConstructableRegistryException e) {
             throw new RuntimeException(e);
         }

platform-sdk/swirlds-component-framework/src/main/java/com/swirlds/component/framework/model/internal/deterministic/DeterministicHeartbeatScheduler.java

@@ -35,8 +35,8 @@ public class DeterministicHeartbeatScheduler extends AbstractHeartbeatScheduler
      * Constructor.
      *
      * @param model the wiring model containing this heartbeat scheduler
-     * @param time  provides wall clock time
-     * @param name  the name of the heartbeat scheduler
+     * @param time provides wall clock time
+     * @param name the name of the heartbeat scheduler
      */
     public DeterministicHeartbeatScheduler(
             @NonNull final TraceableWiringModel model, @NonNull final Time time, @NonNull final String name) {