Closes the channel if not already closed.

Resolves the active conductor source from CLI flag and config. Precedence: hand-configured `conductors` list > CLI `--conductor-rpc` flag > `discover

Returns a reference to the configuration.

Returns the number of connected peers.

Creates the next attributes, transforming a [`SingleBatch`] into [`BasePayloadAttributes`]. This sets `no_tx_pool` and appends the batched txs to the

Calculate the data gas for posting the transaction on L1. Calldata costs 16 gas per byte after compression. Prior to fjord, calldata costs 16 gas per

Computes the EIP-712 domain separator for this token. Domain: `(name, version, chainId, verifyingContract)` — the canonical EIP-712 shape. `version`

Drain every currently claimable TEE job by claiming it under a long lease, so each test starts from a known-empty TEE queue. Holding the jobs `CLAIMED

Queue a [`Log`] as a signed synthetic L1 event transaction in the next mined block. The harness does not execute L1 contracts, so event helpers creat

Returns `Ok(())` when the feature is activated.

Returns an iterator over values for entries whose position is strictly greater than `cutoff`. Uses binary search — O(log n) — relying on the ordering

Returns rolling fee estimates aggregated across the most recent blocks in the cache. For each resource, computes estimates per-block and takes the me

Returns an iterator over L1 blocks matching the given filter.

Returns the current finalized head.

Returns transactions with their associated logs from only the latest flashblock (delta), filtered to include only transactions where at least one log

Gets a mutable account by index.

Returns the current 2D nonce for `account` at `nonce_key`. # Errors - [`INonceManager::ProtocolNonceNotSupported`] — `nonce_key` is `0`, the protocol

Get the range ELF.

Helper function to get the appropriate receipt based on requested type.

Get a proof session by backend session ID

Get all sessions for a proof request

Returns a transaction by its hash.

Initialize the CLI styles, returning a [`Styles`] instance.

Decodes calldata and executes the matching `IB20Asset` or inherited `IB20` operation.

Insert a new task into the running map and push it onto the ready queue.

Inserts a block header and corresponding account proof. The consensus header is wrapped in an RPC header with the hash computed from [`ConsensusHeade

Converts the [`BaseSpecId`] into a [`SpecId`].

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

The 4-byte selector for `L1OriginTooOld()`.

Returns the number of elements in the set.

Loads the L1 chain configuration. If a file path is set, loads the configuration from the JSON file. Otherwise, falls back to the built-in Ethereum L

Sets the maximum priority fee per gas for the transaction.

Re-executes a block and meters execution time, state root calculation time, and total time. Takes a provider, the chain spec, and the block to meter.

Force-mine a block on Anvil so receipts are committed before queries.

Block on the next external event using a biased `tokio::select!`. Admin commands are handled inline in the loop — only non-admin events are returned

Return the block number.

Compute a trie root of the collection of items with a custom encoder.

Returns the current L1 origin block being processed by the pipeline.

Canonical Solidity packing of `ActorConfig`.

Returns the parent block the payload will be build on.

ORs `features` into the current paused bitmask.

Returns the payer authentication payload.

Peeks at the next [`AttributesWithParent`] from the pipeline.

Returns the pending admin staged for `policy_id`, or `address(0)` if none. Returns `address(0)` without reverting for malformed policy IDs (type byte

Finds the next game after the anchor game and advances the anchor root if it is ready.

Decodes an EVM log entry emitted by the system config contract and applies it as a [`SystemConfig`] change. Parse log data for: ```text event Config

Serializes the payload to JSON and broadcasts it to all connected subscribers. The entry is stored in the ring buffer first, keyed by `(block_number,

Builds a minimal [`TransactionReceipt`] with the given status and hash.

Appends a key-value row.

Runs the broadcast loop until cancellation or error.

Run a fallible future until ctrl-c is pressed.

Returns every enclave whose signer is currently valid on-chain, in config order. Best-effort across enclaves: RPC errors for individual signers are l

Signs, sends, and waits for a successful transaction receipt against `to`.

Records transactions accepted by the submission RPC.

Returns the sequence number for the info transaction

Activates or updates the given upgrade condition in-place.

Sets the mempool inclusion deadline from wall-clock time.