fix: cherry-pick: Skip transactions older than the software version (#…

…13527) (#13563)

Signed-off-by: Matt Hess <matt.hess@swirldslabs.com>
Co-authored-by: Kim Rader <kim.rader@swirldslabs.com>

hedera-node/hedera-app/src/main/java/com/hedera/node/app/Hedera.java

@@ -1103,6 +1103,7 @@ private void initializeDagger(
         // Fully qualified so as to not confuse javadoc
         daggerApp = com.hedera.node.app.DaggerHederaInjectionComponent.builder()
                 .initTrigger(trigger)
+                .softwareVersion(version)
                 .configProvider(configProvider)
                 .configProviderImpl(configProvider)
                 .self(SelfNodeInfoImpl.of(nodeAddress, version))

hedera-node/hedera-app/src/main/java/com/hedera/node/app/HederaInjectionComponent.java

@@ -59,6 +59,7 @@
 import com.swirlds.platform.listeners.StateWriteToDiskCompleteListener;
 import com.swirlds.platform.system.InitTrigger;
 import com.swirlds.platform.system.Platform;
+import com.swirlds.platform.system.SoftwareVersion;
 import dagger.BindsInstance;
 import dagger.Component;
 import java.nio.charset.Charset;
@@ -175,6 +176,9 @@ interface Builder {
         @BindsInstance
         Builder genesisRecordsConsensusHook(GenesisRecordsConsensusHook genesisRecordsBuilder);
 
+        @BindsInstance
+        Builder softwareVersion(SoftwareVersion softwareVersion);
+
         HederaInjectionComponent build();
     }
 }

hedera-node/hedera-app/src/main/java/com/hedera/node/app/workflows/handle/HandleWorkflow.java

@@ -46,6 +46,7 @@
 import static com.hedera.node.app.workflows.prehandle.PreHandleResult.Status.PAYER_UNWILLING_OR_UNABLE_TO_PAY_SERVICE_FEE;
 import static com.hedera.node.app.workflows.prehandle.PreHandleResult.Status.PRE_HANDLE_FAILURE;
 import static com.hedera.node.app.workflows.prehandle.PreHandleResult.Status.SO_FAR_SO_GOOD;
+import static com.swirlds.platform.system.InitTrigger.EVENT_STREAM_RECOVERY;
 import static java.util.Collections.emptyMap;
 import static java.util.Collections.emptySet;
 import static java.util.Objects.requireNonNull;
@@ -122,7 +123,9 @@
 import com.hedera.pbj.runtime.io.buffer.Bytes;
 import com.swirlds.config.api.Configuration;
 import com.swirlds.platform.state.PlatformState;
+import com.swirlds.platform.system.InitTrigger;
 import com.swirlds.platform.system.Round;
+import com.swirlds.platform.system.SoftwareVersion;
 import com.swirlds.platform.system.events.ConsensusEvent;
 import com.swirlds.platform.system.transaction.ConsensusTransaction;
 import edu.umd.cs.findbugs.annotations.NonNull;
@@ -173,6 +176,9 @@ public class HandleWorkflow {
     private final HandleWorkflowMetrics handleWorkflowMetrics;
     private final ThrottleServiceManager throttleServiceManager;
     private final StoreMetricsService storeMetricsService;
+    private final TransactionChecker transactionChecker;
+    private final InitTrigger initTrigger;
+    private final SoftwareVersion softwareVersion;
 
     @Inject
     public HandleWorkflow(
@@ -200,7 +206,10 @@ public HandleWorkflow(
             @NonNull final CacheWarmer cacheWarmer,
             @NonNull final HandleWorkflowMetrics handleWorkflowMetrics,
             @NonNull final ThrottleServiceManager throttleServiceManager,
-            @NonNull final StoreMetricsService storeMetricsService) {
+            @NonNull final StoreMetricsService storeMetricsService,
+            @NonNull final TransactionChecker transactionChecker,
+            @NonNull final InitTrigger initTrigger,
+            @NonNull final SoftwareVersion softwareVersion) {
         this.networkInfo = requireNonNull(networkInfo, "networkInfo must not be null");
         this.preHandleWorkflow = requireNonNull(preHandleWorkflow, "preHandleWorkflow must not be null");
         this.dispatcher = requireNonNull(dispatcher, "dispatcher must not be null");
@@ -230,6 +239,9 @@ public HandleWorkflow(
         this.handleWorkflowMetrics = requireNonNull(handleWorkflowMetrics, "handleWorkflowMetrics must not be null");
         this.throttleServiceManager = requireNonNull(throttleServiceManager, "throttleServiceManager must not be null");
         this.storeMetricsService = requireNonNull(storeMetricsService, "storeMetricsService must not be null");
+        this.transactionChecker = requireNonNull(transactionChecker, "transactionChecker must not be null");
+        this.initTrigger = requireNonNull(initTrigger, "initTrigger must not be null");
+        this.softwareVersion = requireNonNull(softwareVersion, "softwareVersion must not be null");
     }
 
     /**
@@ -317,15 +329,52 @@ private void handleUserTransaction(
             @NonNull final ConsensusEvent platformEvent,
             @NonNull final NodeInfo creator,
             @NonNull final ConsensusTransaction platformTxn) {
+        final var recordListBuilder = new RecordListBuilder(consensusNow);
+        final var recordBuilder = recordListBuilder.userTransactionRecordBuilder();
+
+        // First, check if the transaction is submitted with a version prior to the deployed version. If so, set the
+        // status on the receipt to BUSY and return
+        if (this.initTrigger != EVENT_STREAM_RECOVERY
+                && softwareVersion.compareTo(platformEvent.getSoftwareVersion()) > 0) {
+            // Reparse the transaction (so we don't need to get the prehandle result)
+            final TransactionInfo transactionInfo;
+            try {
+                transactionInfo = transactionChecker.parseAndCheck(platformTxn.getApplicationPayload());
+            } catch (PreCheckException e) {
+                logger.error(
+                        "Bad old transaction (version {}) from creator {}",
+                        platformEvent.getSoftwareVersion(),
+                        creator,
+                        e);
+                // We don't care since we're checking a transaction with an older software version. We were going to
+                // skip the transaction handling anyway
+                return;
+            }
+
+            // Initialize record builder list
+            recordBuilder
+                    .transaction(transactionInfo.transaction())
+                    .transactionBytes(transactionInfo.signedBytes())
+                    .transactionID(transactionInfo.transactionID())
+                    .exchangeRate(exchangeRateManager.exchangeRates())
+                    .memo(transactionInfo.txBody().memo());
+
+            // Place a BUSY record in the cache
+            final var record = recordBuilder.status(ResponseCodeEnum.BUSY).build();
+            recordCache.add(creator.nodeId(), transactionInfo.payerID(), List.of(record));
+
+            return;
+        }
+
+        // (FUTURE) We actually want to consider exporting synthetic transactions on every
+        // first post-upgrade transaction, not just the first transaction after genesis.
         // Determine if this is the first transaction after startup. This needs to be determined BEFORE starting the
         // user transaction
         final var consTimeOfLastHandledTxn = blockRecordManager.consTimeOfLastHandledTxn();
         final var isFirstTransaction = !consTimeOfLastHandledTxn.isAfter(Instant.EPOCH);
 
-        // Setup record builder list
+        // Start the user transaction
         final boolean switchedBlocks = blockRecordManager.startUserTransaction(consensusNow, state, platformState);
-        final var recordListBuilder = new RecordListBuilder(consensusNow);
-        final var recordBuilder = recordListBuilder.userTransactionRecordBuilder();
 
         // Setup helpers
         final var configuration = configProvider.getConfiguration();

hedera-node/hedera-app/src/test/java/com/hedera/node/app/components/IngestComponentTest.java

@@ -107,6 +107,7 @@ void setUp() {
                 .servicesRegistry(Set::of)
                 .instantSource(InstantSource.system())
                 .genesisRecordsConsensusHook(mock(GenesisRecordsConsensusHook.class))
+                .softwareVersion(mock(HederaSoftwareVersion.class))
                 .build();
 
         final var state = new FakeHederaState();