Extract the pool address from an ID. This takes advantage that the first 20 bytes of the ID is the address of the pool. For example the GNO-BAL pool

Returns a pool by ID or none if no such pool exists.

Collects the unique set of token addresses from all `PoolCreated` events emitted by `factory` in `logs`.

Unique emitter addresses for the per-pool events (`Initialize`/`Swap`/`Mint`/`Burn`). Feeds the DB lookup that filters out foreign emitters before `co

Returns all pools containing both tokens from `TokenPair`

Given a collection of `TokenPair`, returns all pools containing at least one of the pairs.

Observe that postprocessing (encoding & merging) of solutions is about to start.

Configures all the state overrides that are needed to mock the given trade (approval, sell_token balance, helper contract at solver address, allow lis

Installs a panic handler that executes [`handler`] plus whatever panic handler was already set up. This can be useful to make absolutely sure to clean

Returns the price of a token relative to the native token. I.e., the price of the native token is 1 and the price of a token T is represented as how m

Calculate price improvement over quote. Returns 0 if there's no improvement (instead of error).

The price of the estimate denominated in buy token. The resulting price is how many units of buy_token are bought for one unit of sell_token (buy_amo

Convert a token amount to ETH using this price. Formula: `amount * price / 10^18`

The uniform price vector this settlement proposes. Deprecated: only emitted on the `/solve` response so that autopilots running the previous code can

Probes whether `token` is an Aave v3 aToken and returns its `(pool, underlying)` pair. Accepts the token iff the pool registers it as the aToken for i

Traverses the call stack and pushes relevant calls to `events`. Introspection of the `settle()` call gets forwarded to [`process_settle_frame`].

This function expects to get the [`CallFrame`] of the `settle()` call to be passed in. Since we are only interested in a relatively high level report

Computed protocol fee in surplus token.

Protocol fee is defined by a fee policy attached to the order.

Protocol fee is defined by a fee policy attached to the order.

Calculate a single protocol fee based on policy type.

Returns the protocol fee denominated in the sell token.

Protocol fees are defined by fee policies attached to the order. Denominated in SURPLUS token

Calculate total protocol fees for an order. Returns the total fee in the surplus token.

Enqueues the event to be sent to the event bus in a background task.

Reads messages off the in-memory queue and hands the publish ack future off to [`await_acks`].

Queries on-chain refund status for a single order. Returns `None` if the status query fails. Marks orders as `Invalid` if the owner cannot receive ET

Generate a quote for this order. This calls `/solve` on the solver with a "fake" auction which contains a single order, and then determines the quote

Quote an order using a UniswapV2 pool unless it already has concrete amounts. This determines the buy and sell amount of the order in the auction.

Create a request for the driver /quote endpoint.

Use limit orders for quoting instead of market orders

Observe the result of quoting an auction.

Observe that the quoting process is about to start.

Ray-division: `(a * RAY + b/2) / b`, round-half-up. Matches Aave's `WadRayMath.rayDiv` bit-for-bit so the scaled amount we write into storage equals t

Read persisted watermark for resuming after reconnect.

The address which will receive the output of this order. If a custom receiver address was specified by the user explicitly, return that address. Other

Turns 0x OrderRecord into liquidity which solvers can use.

Recovers the owner and signature from a `JitOrder`.

Adjusts the next fill amount that should be tried. Always halves the last tried amount.

`None` (existing entry preserved) when `fetch_all` is uncertain — no positive confirmation and at least one backend failed.

Comes from `_onRegularSwap(true, ...)`: https://etherscan.io/address/0xf9ac7B9dF2b3454E841110CcE5550bD5AC6f875F#code#F2#L270

Comes from `_onRegularSwap(false, ...)`: https://etherscan.io/address/0xf9ac7B9dF2b3454E841110CcE5550bD5AC6f875F#code#F2#L270

Returns the minimum surplus for the specified token amount.

Releases the leader lock if it was held Should be called after breaking out of run loop (for example: due to shutdown)

All pool token pairs that could be used along a path candidate for these token pairs.

Scales the `maker_amount` according to how much of the partially fillable amount was already used.

Spawns a background task that replaces the current auction in the DB with the new one.

Replaces the `old_order` with `validated_new_order` in the database (cancels the old one and inserts the new one), but not before performing some vali

The balance required to ensure settlement execution with the given gas parameters.

Whether a submitted settlement whose receipt is missing should be cancelled. We cancel only when the re-simulation reverts and the signer's pending no

A signature check requires setup when there are interactions to be taken into account or when the balance override is set. Interactions require setup

This method returns an iterator over the stable pool reserves while filtering out the BPT token for the pool (i.e. the pool address). This is used bec

Re-simulate all proposed solutions on every new block and drop any that start reverting. Returns once every solution has reverted; otherwise runs fore

Resolve the program against `account_keys`, keeping the instruction only if that program is the settlement or SolFlow program. The `accounts` field ke

Extracts the bytes of the response up to some size limit. Returns an error if the byte limit was exceeded.