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.

Spawns a new background task that streams state override updates into the return [`SimulationOverrides`] instance.

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

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

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.

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

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

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.

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.

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

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

A solution solving the [`ab_order`].

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

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

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.

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

Solves a raw JSON auction.

Create a Web3 instance with a label for observability.

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.

Finds full app data for an order that only has the contract app data hash. The full app data can be located in the database or on IPFS.