moved transactionDispatcher to MinaBaseLayer

Author: Raunaque97

packages/sequencer/src/protocol/baselayer/MinaBaseLayer.ts

@@ -42,8 +42,23 @@ export interface MinaBaseLayerConfig {
     | LocalMinaBaseLayerConfig
     | LightnetMinaBaseLayerConfig
     | RemoteMinaBaseLayerConfig;
+  /**
+   * Configuration for the L1 transaction dispatcher (polling + status checks).
+   * Defaults are applied internally.
+   */
+  transactionDispatcher?: {
+    pollIntervalMs?: number;
+    statusCheckIntervalMs?: number;
+    inclusionTimeoutMs?: number;
+  };
 }
 
+const DEFAULT_L1_TRANSACTION_DISPATCHER_CONFIG = {
+  pollIntervalMs: 5000,
+  statusCheckIntervalMs: 5000,
+  inclusionTimeoutMs: 10 * 60 * 1000,
+} as const;
+
 @sequencerModule()
 export class MinaBaseLayer
   extends SequencerModule<MinaBaseLayerConfig>
@@ -78,6 +93,13 @@ export class MinaBaseLayer
         useClass: MinaTransactionSender,
       },
 
+      L1TransactionDispatcherConfig: {
+        useValue: {
+          ...DEFAULT_L1_TRANSACTION_DISPATCHER_CONFIG,
+          ...(this.config.transactionDispatcher ?? {}),
+        },
+      },
+
       OutgoingMessageAdapter: {
         useClass: DefaultOutgoingMessageAdapter,
       },

packages/sequencer/src/settlement/transactions/L1TransactionDispatcher.ts

@@ -11,19 +11,14 @@ import { MinaSigner } from "../MinaSigner";
 import { L1TransactionRetryStrategy } from "./L1TransactionRetryStrategy";
 import { TxStatusWaiter } from "./TxStatusWaiter";
 import { checkZkappTransactionStatus } from "./ZkappTransactionStatus";
+import { MinaBaseLayer } from "../../protocol/baselayer/MinaBaseLayer";
 
 export interface DispatcherConfig {
   pollIntervalMs?: number;
   statusCheckIntervalMs?: number;
   inclusionTimeoutMs?: number;
 }
 
-const DEFAULT_CONFIG: Required<DispatcherConfig> = {
-  pollIntervalMs: 5000,
-  statusCheckIntervalMs: 5000,
-  inclusionTimeoutMs: 10 * 60 * 1000,
-};
-
 @injectable()
 export class L1TransactionDispatcher {
   private pollingTimeout?: NodeJS.Timeout;
@@ -41,22 +36,12 @@ export class L1TransactionDispatcher {
     private readonly retryStrategy: L1TransactionRetryStrategy,
     @inject("SettlementSigner") private readonly signer: MinaSigner,
     private readonly waiter: TxStatusWaiter,
-    private readonly dispatcherConfig: DispatcherConfig = {}
+    @inject("L1TransactionDispatcherConfig")
+    private readonly config: Required<DispatcherConfig>,
+    @inject("MinaBaseLayer")
+    private readonly baseLayer: MinaBaseLayer
   ) {}
 
-  private get config(): Required<DispatcherConfig> {
-    return {
-      pollIntervalMs:
-        this.dispatcherConfig.pollIntervalMs ?? DEFAULT_CONFIG.pollIntervalMs,
-      statusCheckIntervalMs:
-        this.dispatcherConfig.statusCheckIntervalMs ??
-        DEFAULT_CONFIG.statusCheckIntervalMs,
-      inclusionTimeoutMs:
-        this.dispatcherConfig.inclusionTimeoutMs ??
-        DEFAULT_CONFIG.inclusionTimeoutMs,
-    };
-  }
-
   public start() {
     this.startPolling();
   }
@@ -198,6 +183,15 @@ export class L1TransactionDispatcher {
       return;
     }
 
+    // don't check status on local chain
+    if (!this.baseLayer.isLocalBlockChain()) {
+      await this.pendingStorage.update(record.id, {
+        status: "included",
+      });
+      this.waiter.notifyIncluded(record.id, record.hash);
+      return;
+    }
+
     // Single status check (no long blocking loops)
     const result = await checkZkappTransactionStatus(record.hash);
     if (result.success) {

packages/sequencer/test/settlement/Settlement-only.ts

@@ -127,6 +127,7 @@ export const settlementOnlyTestFn = (
         FeeStrategy: {},
         SettlementModule: {},
         SequencerStartupModule: {},
+        L1TransactionRetryStrategy: {},
 
         TaskQueue: {
           simulatedDuration: 0,