Fluid Vault¶

Field	Value
Module	`almanak.connectors.fluid_vault`
Protocol kind	Lending
Aliases	N/A

Supported Chains And Intents¶

Chain	Family	Supported Intents
Arbitrum	EVM	`BORROW`, `REPAY`, `SUPPLY`, `WITHDRAW`
Base	EVM	`BORROW`, `REPAY`, `SUPPLY`, `WITHDRAW`

API Reference¶

almanak.connectors.fluid_vault ¶

Fluid vault (NFT-CDP) connector — thin second manifest over the fluid package.

Phase 3 (VIB-5031, ADR r2 Q0): Fluid vault borrow positions are NFT-CDPs driven by a single signed-delta operate() entrypoint per vault, with market_id (the vault address) REQUIRED — while the shipped Phase-2 fToken surface (protocol="fluid" / "fluid_lending") REJECTS any market_id. One protocol key cannot demand and forbid market_id simultaneously, so vault lending is its own connector registration: protocol="fluid_vault", one codebase (all implementation modules live in almanak.connectors.fluid), two manifests.

Scope (Checkpoint-1): arbitrum + base, type-1 vaults only. Position keys: lending:{chain}:fluid_vault:{wallet}:{vault}:{asset} (vault lowercased; the nftId is metadata in extracted_data_json, never a key segment).

Example

from decimal import Decimal

from almanak.framework.intents import BorrowIntent

intent = BorrowIntent( protocol="fluid_vault", market_id="0xeAbBfca72F8a8bf14C4ac59e69ECB2eB69F0811C", # arbitrum vault id 1 collateral_token="ETH", collateral_amount=Decimal("1"), borrow_token="USDC", borrow_amount=Decimal("500"), chain="arbitrum", )

FluidVaultCompiler ¶

Bases: BaseLendingCompiler

Compile fluid_vault SUPPLY / BORROW / REPAY / WITHDRAW / DELEVERAGE.

DELEVERAGE routes to :meth:compile_repay via the :class:BaseLendingCompiler dispatch (framework convention: a deleverage is a repay with risk context).

FluidVaultSDK ¶

FluidVaultSDK(
    chain: str,
    rpc_url: str | None = None,
    gateway_client: GatewayClient | None = None,
)

Low-level Fluid vault (NFT-CDP) protocol SDK.

All reads go through the VaultResolver with typed-ABI decoding; writes are offline calldata builders for the vault's operate() entrypoint.

参数：

名称	类型	描述	默认
`chain`	`str`	Chain name (one of `FLUID_ADDRESSES`).	必需
`rpc_url`	`str \| None`	DEPRECATED — direct RPC URL for ad-hoc scripts/tests only.	`None`
`gateway_client`	`GatewayClient \| None`	Gateway client routing all eth_call traffic through the gateway's RpcService. Preferred for production code paths.	`None`

get_vault_entire_data ¶

get_vault_entire_data(vault: str) -> FluidVaultData

VaultResolver.getVaultEntireData(vault) — 97-word typed decode.

position_by_nft_id ¶

position_by_nft_id(
    nft_id: int,
) -> tuple[FluidVaultPosition, FluidVaultData]

VaultResolver.positionByNftId(nftId) — (12 + 97)-word typed decode.

positions_by_user ¶

positions_by_user(wallet: str) -> list[FluidVaultPosition]

VaultResolver.positionsByUser(wallet) — every position with its vault.

The two returned arrays are index-aligned (position i ↔ its vault's data at i — verification report D1), so each position carries its lowercased vault address. No pagination exists; cost is bounded by the one-NFT-per-(wallet,vault) invariant.

resolve_user_nft_for_vault ¶

resolve_user_nft_for_vault(
    wallet: str, vault: str
) -> int | None

Resolve the wallet's nftId on vault fresh from chain state.

The VIB-5010 answer: chain is the source of truth — persisted nftIds are never load-bearing. Returns None when the wallet holds no position NFT on the vault (the measured "no position" answer — distinct from a read failure, which RAISES FluidSDKError so the compiler fails closed instead of minting a duplicate position).

If the wallet somehow holds MULTIPLE NFTs on one vault (user acted outside the SDK), selection is deterministic: lowest nftId wins, with a warning — the others stay invisible by design (ADR §1.1).

encode_operate_calldata ¶

encode_operate_calldata(
    nft_id: int, col_delta: int, debt_delta: int, to: str
) -> str

ABI-encode operate(nftId, newCol, newDebt, to) calldata.

Signed deltas: positive = deposit/borrow, negative = withdraw/repay, INT256_MIN = the protocol max sentinel (full withdraw/repay).

build_operate_tx ¶

build_operate_tx(
    vault: str,
    nft_id: int,
    col_delta: int,
    debt_delta: int,
    to: str,
    value: int = 0,
) -> dict[str, Any]

Build an operate() transaction for a Fluid type-1 vault.

参数：

名称	类型	描述	默认
`vault`	`str`	Vault contract address (the per-market operate target).	必需
`nft_id`	`int`	Position NFT id (0 mints a new position).	必需
`col_delta`	`int`	Signed collateral delta (raw units; INT256_MIN = all).	必需
`debt_delta`	`int`	Signed debt delta (raw units; INT256_MIN = full repay).	必需
`to`	`str`	Recipient of withdrawn collateral / borrowed debt.	必需
`value`	`int`	msg.value — MUST equal `col_delta` for native-collateral deposits; 0 for every ERC-20 leg.	`0`

getattr ¶

__getattr__(name: str) -> Any

PEP 562 lazy attribute access (no registration side effects here).