test(fast-inbox): stub streaming inbox methods in sequencer and validator suites (A-1384)

Streaming is now the only consumption path, so the sequencer checkpoint job resolves
the parent Inbox bucket from a world-state fork and every block proposal carries a
bucket reference. Stub getInboxBucketByTotalMsgCount and the fork tree info in the
sequencer unit suites, and attach the consumed bucket reference (plus a non-zero L1
genesis time) in the validator integration suite so proposals pass the streaming
acceptance checks.

Author: spalladino

yarn-project/sequencer-client/src/sequencer/checkpoint_proposal_job.timing.test.ts

@@ -16,6 +16,7 @@ import type {
   BlockBuilderOptions,
   MerkleTreeWriteOperations,
   ResolvedSequencerConfig,
+  TreeInfo,
   WorldStateSynchronizer,
 } from '@aztec/stdlib/interfaces/server';
 import type { L1ToL2MessageSource } from '@aztec/stdlib/messaging';
@@ -448,10 +449,22 @@ describe('CheckpointProposalJob Timing Tests', () => {
     const mockFork = mock<MerkleTreeWriteOperations>({
       [Symbol.asyncDispose]: jest.fn().mockReturnValue(Promise.resolve()) as () => Promise<void>,
     });
+    // AZIP-22 streaming inbox: the checkpoint job resolves the parent Inbox bucket from the fork's
+    // L1-to-L2 tree leaf count. Default to an empty tree so it starts at the genesis bucket.
+    mockFork.getTreeInfo.mockResolvedValue({ size: 0n } as TreeInfo);
     worldState.fork.mockResolvedValue(mockFork);
 
     l1ToL2MessageSource = mock<L1ToL2MessageSource>();
     l1ToL2MessageSource.getL1ToL2Messages.mockResolvedValue(Array(4).fill(Fr.ZERO));
+    l1ToL2MessageSource.getInboxBucketByTotalMsgCount.mockResolvedValue({
+      seq: 0n,
+      inboxRollingHash: Fr.ZERO,
+      totalMsgCount: 0n,
+      timestamp: 0n,
+      msgCount: 0,
+      lastMessageIndex: 0n,
+      isOpen: false,
+    });
 
     l2BlockSource = mock<L2BlockSource>();
     l2BlockSource.getCheckpointsData.mockResolvedValue([]);

yarn-project/sequencer-client/src/sequencer/sequencer.test.ts

@@ -35,7 +35,9 @@ import type { ChainConfig } from '@aztec/stdlib/config';
 import type { L1RollupConstants } from '@aztec/stdlib/epoch-helpers';
 import { GasFees } from '@aztec/stdlib/gas';
 import {
+  type MerkleTreeWriteOperations,
   type SequencerConfig,
+  type TreeInfo,
   WorldStateRunningState,
   type WorldStateSyncStatus,
   type WorldStateSynchronizer,
@@ -166,6 +168,8 @@ describe('sequencer', () => {
       expect.any(Checkpoint),
       attestationsAndSigners,
       getSignatures()[0].signature,
+      // AZIP-22 streaming inbox: the checkpoint job passes the parent bucket hint (genesis => 0n).
+      0n,
       expect.objectContaining({
         txTimeoutAt: expect.any(Date),
       }),
@@ -285,6 +289,13 @@ describe('sequencer', () => {
         },
       } satisfies WorldStateSynchronizerStatus),
     });
+    // AZIP-22 streaming inbox: the checkpoint job forks world state and resolves the parent Inbox bucket
+    // from the fork's L1-to-L2 tree leaf count. Default to an empty tree so it starts at the genesis bucket.
+    const mockFork = mock<MerkleTreeWriteOperations>({
+      [Symbol.asyncDispose]: jest.fn().mockReturnValue(Promise.resolve()) as () => Promise<void>,
+    });
+    mockFork.getTreeInfo.mockResolvedValue({ size: 0n } as TreeInfo);
+    worldState.fork.mockResolvedValue(mockFork);
 
     // Create fake CheckpointsBuilder and CheckpointBuilder
     // Uses blockProvider to return the current `block` variable (set per-test)
@@ -355,6 +366,15 @@ describe('sequencer', () => {
         },
       }),
     });
+    l1ToL2MessageSource.getInboxBucketByTotalMsgCount.mockResolvedValue({
+      seq: 0n,
+      inboxRollingHash: Fr.ZERO,
+      totalMsgCount: 0n,
+      timestamp: 0n,
+      msgCount: 0,
+      lastMessageIndex: 0n,
+      isOpen: false,
+    });
 
     validatorClient = mock<ValidatorClient>();
     validatorClient.collectAttestations.mockImplementation(() => Promise.resolve(getCheckpointAttestations()));
@@ -839,6 +859,8 @@ describe('sequencer', () => {
           expect.any(Checkpoint),
           attestationsAndSigners,
           getSignatures()[0].signature,
+          // AZIP-22 streaming inbox: the checkpoint job passes the parent bucket hint (genesis => 0n).
+          0n,
           expect.objectContaining({
             txTimeoutAt: expect.any(Date),
           }),

yarn-project/validator-client/src/validator.integration.test.ts

@@ -26,7 +26,7 @@ import { CheckpointReexecutionTracker, L1PublishedData, PublishedCheckpoint } fr
 import { type L1RollupConstants, getTimestampForSlot } from '@aztec/stdlib/epoch-helpers';
 import { Gas, GasFees } from '@aztec/stdlib/gas';
 import { tryStop } from '@aztec/stdlib/interfaces/server';
-import { computeInHashFromL1ToL2Messages } from '@aztec/stdlib/messaging';
+import { InboxBucketRef, computeInHashFromL1ToL2Messages } from '@aztec/stdlib/messaging';
 import { type BlockProposal, CheckpointProposal } from '@aztec/stdlib/p2p';
 import { mockTx } from '@aztec/stdlib/testing';
 import { BlockHeader, type CheckpointGlobalVariables, Tx } from '@aztec/stdlib/tx';
@@ -48,7 +48,9 @@ jest.setTimeout(60_000);
 describe('ValidatorClient Integration', () => {
   // Constants for L1
   const l1Constants: L1RollupConstants = {
-    l1GenesisTime: 0n,
+    // Non-zero genesis time so the slot-1 validation clock is well past INBOX_LAG_SECONDS; otherwise the streaming
+    // Inbox acceptance check rejects even a genesis-timestamp (0) bucket as `bucket_too_new` (AZIP-22 Fast Inbox).
+    l1GenesisTime: 1_700_000_000n,
     slotDuration: 24,
     epochDuration: 16,
     ethereumSlotDuration: 12,
@@ -255,6 +257,14 @@ describe('ValidatorClient Integration', () => {
       minValidTxs: 0,
     });
 
+    // Resolve the Inbox bucket this block consumed through (keyed by its cumulative L1-to-L2 leaf count) and attach
+    // the reference, mirroring the sequencer's block-building loop which carries a bucketRef on every proposal
+    // (AZIP-22 Fast Inbox). Without it the validator's streaming acceptance check rejects the proposal as
+    // `bucket_unknown`. A block that consumed nothing resolves to the genesis (or reused parent) bucket.
+    const blockTotal = BigInt(block.header.state.l1ToL2MessageTree.nextAvailableLeafIndex);
+    const bucket = await proposer.archiver.getInboxBucketByTotalMsgCount(blockTotal);
+    const bucketRef = bucket ? InboxBucketRef.fromBucket(bucket) : undefined;
+
     const proposal = await proposer.validator.createBlockProposal(
       block.header,
       cpNumber,
@@ -264,6 +274,7 @@ describe('ValidatorClient Integration', () => {
       usedTxs,
       proposerSigner.address,
       {},
+      bucketRef,
     );
 
     logger.warn(`Built block proposal for block ${blockNumber}`, { ...block.toBlockInfo() });