Initialize the Prometheus metrics recorder and run a callback to initialize subsystem-specific metrics if metrics are enabled.

Adds a transaction hash to the cache.

Builds the common L2, factory, and verifier mocks for an invalid-game scenario: starting=10, `l2_block=20`, interval=5, checkpoints at 15 and 20 with

Returns `true` if [`Canyon`](BaseUpgrade::Canyon) is active at given block timestamp.

Returns `true` if the compressed output is empty.

Returns true if jovian is active for the payload.

Returns true only when at least one node was targeted and every RPC succeeded.

Returns an L2 builder provider with Base network.

Return the L2 genesis [`L2BlockInfo`] anchored to the L1 genesis block. Convenience method eliminating the repeated 10-line construction used in reor

Returns the reserved nonce value.

Advances a pending proof through its lifecycle. - **`AwaitingProof`** — polls prover service: - `Succeeded` → transitions to `ReadyToSubmit` and fall

The gossip topics accepted for new blocks

Returns transactions in sequencer order.

A minimal valid `AttestationDocument` for M-02 unit tests.

Verifies the certificate chain and returns accumulated cert digests paired with expiry timestamps. Skips verification of the first `trusted_prefix_le

Sets the L1 chain ID.

Sets the EIP-1559 max fee per gas.

Set the transactions for the flashblock.

Reset the pipeline to a new L1 origin and L2 safe head after a reorg. Sends a [`ResetSignal`] to the pipeline, resets all head pointers, clears all p

Add a frame to the channel. ## Takes - `frame`: The frame to add to the channel - `l1_inclusion_block`: The block that the frame was included in ##

Adds an RPC hook that will run when RPC modules are configured.

Returns the operation as a string for metrics labels.

Atomically claim a task by transitioning it from CREATED to PENDING. Returns true if the task was successfully claimed (was in CREATED state). Returns

Atomically claim a task by transitioning it from CREATED to PENDING. Returns true if the task was successfully claimed (was in CREATED state). Returns

Builds the common L2 provider, factory, and output roots shared by most invalid-game test scenarios. Layout: starting=10, `l2_block=20`, interval=5, c

Return the block at `number`, or `None` if it has not been mined yet.

Helper function to convert `BlockId` to a string key for `HashMap` storage. This is necessary because `BlockId` doesn't implement Hash.

Convert an [`L1Block`] reference to a [`BlockInfo`].

Builds a [`BaseTransactionValidator`] against a Cobalt-activated mainnet chain spec with no accounts seeded. EIP-8130 admission is fork-gated on Cobal

Returns the channel timeout for the given timestamp.

Computes the counterfactual CREATE2 address for a created account. Mirrors `computeAddress`.

Atomically create or replay a proof request for the worker API queue.

Builds a factory and verifier pair where each game has the given `bond_recipient` and `zk_prover`. All games are `IN_PROGRESS` (status 0) unless overr

Returns the balance for an address in pending state.

Returns the state overrides for the pending state.

Inserts a value into the cache.

65-byte `r || s || v` signature over `hash`, `v` in `{27, 28}`.

Returns the update kind.

Creates `amount` tokens at `to`. Enforces supply cap. Emits `Transfer(0x0, to, amount)`.

Returns the next valid batch upon the given safe head. Also returns the boolean that indicates if the batch is the last block in the batch.

Parses opcode and precompile name strings into a [`MeteredOpcodes`] filter. Recognizes EVM opcode names (e.g., `SSTORE`, `CALL`), fixed precompile na

Record (insert or update) the backend session for this job.

Records a transaction that landed in a polled block. Gas and revert status are unknown at landing time and stay at their defaults until [`Self::apply

Clears the cached nonce, forcing a fresh chain fetch on the next call to [`next_nonce`](Self::next_nonce). # Caution Unless [`with_pending_tag`](Sel

65-byte `r || s || v` signature over `hash`, `v` in `{27, 28}`, low-s.

Exposes the chain specification.

Read a storage value from the latest committed state. Accepts the slot as a `U256` for convenience (converted to `B256` internally). Returns `U256::Z

Runs one collector tick. Returns `true` when the pipeline should drop stale recovery caches and reload state from chain immediately. `dispatched_thr

Truncate the chain to retain only blocks `0..=number`. Use this after an L1 reorg to remove orphaned blocks from the shared view before pushing repla

Sends a transaction and returns `true` if it succeeded, `false` if it reverted.

Records that a transaction with the given hash has been observed onchain.

Returns [`OpTxType`] of the receipt.

Sets an explicit nonce instead of fetching it from the provider.

Sets the transfer value in wei.

Activates the feature.

Activates an activation-registry feature.

Returns the block hash for the [`L1BlockInfoTx`].

Helper to create a [`BlockInfo`] for testing.

Return the block at `number` as a [`BlockInfo`]. Shorthand for `block_info_from(miner.block_by_number(number).expect(...))`. # Panics Panics if `nu

Builds the [`TransactionReceiptFields`] object.

Initialize exex with config