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

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

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

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

`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

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

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

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

Returns an iterator over the token reserves.

Add a solution to be returned by the mock solver.

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

Create a builder for the setup process.

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.

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

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

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

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

A solution solving the [`ab_order`].

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

Call the /solve endpoint.

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

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

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

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.

Solves a raw JSON auction.

Create a Web3 instance with a label for observability.

Get the metrics instance.

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

Start the api service in a background tasks. Wait until the service is responsive.