Expect the /solve endpoint to have returned a 200 OK response.

Bind to the configured address, returning the listener and the actual bound address (which differs from `addr` when binding to port 0).

The first address is always the lower one. The addresses are never equal.

Connect to a Yellowstone gRPC endpoint. `endpoint` decides TLS by scheme: `https` endpoints get TLS with the system's native root certificates (the t

Testing* function that takes a closure and runs it on a local testing node and database. Before each test, it creates a snapshot of the current state

The current time in the same unit as `valid_to` for orders in the smart contract.

Generate next `N` accounts with the given initial balance.

Generate next `N` accounts with the given initial balance and authenticate them as solvers.

Deploy `N` tokens with WETH Uniswap pools.

Repeatedly evaluates condition until it returns a truthy value (true, Some(true), Result(true)) or the timeout is reached. If condition evaluates to t

Converts the value into Wei, the smallest unit of Ethereum.

Create an [`Order`]. If the response status code is not `201`, return the status and the body.

Acquire a submission slot. Prefers the direct solver EOA slot (cheaper, no forwarding). Falls back to a delegated EIP-7702 account when the direct slo

Returns an iterator over the token reserves.

`Some(true)` as soon as any backend confirms a ban — a failure elsewhere must not mask a positive hit. `None` means no confirmation and at least one f

Add a new order to be solved as part of the test. This order will be passed to /solve when [`Test::solve`] is called and it will be anticipated by the

Add a solution to be returned by the mock solver.

Create a builder for the setup process.

Starts a basic version of the protocol with a single baseline solver.

Used to determine if `token` is among the pair.

Create the test: set up onchain contracts and pools, start a mock HTTP server for the solver and start the HTTP server for the driver.

Get the global instance of the metric storage registry. # Implementation notice If global metrics registry was not configured with [`setup_registry`

Add a uniswap pool with the specified reserves. Tokens are identified by their symbols. Every order will be solved through one of the pools.

Kebab-case slug used in URLs and per-network configs (pool-indexer API routes, DB database names, etc). Stable — other services parse it.

An example order which sells token "A" for token "B".

A solution solving the [`ab_order`].

Race the enabled mempools concurrently; first success wins. Pending submission futures are dropped at that point and every other mempool is recorded a

A pool between tokens "A" and "B".

Retrieve an [`Order`]. If the respons status is not `200`, return the status and the body.

Call the /solve endpoint.

Total time spent in downstream `write`/`flush` calls so far.

Creates an configuration where any `validTo` is accepted.

Returns the `Metadata` for the given tokens. Note that the result will not contain data for tokens that encountered errors while fetching the data.

Submit an [`model::quote::OrderQuote`]. If the response status is not `200`, return the status and the body.

Create a Web3 instance with a label for observability.

An empty solution has no trades which is allowed to capture surplus and a score of 0.

Solves a raw JSON auction.

If a task produces a result which indicates rate limiting is required future requests will get dropped for some time. Every successive response like t

Get the metrics instance.

Records the gap `head` opened over the block seen before it. Repeats of the same head, and blocks arriving out of order, carry no gap to learn from an