DeFi 链上交易 (Python 绑定)¶

from axon_quant.defi import (
    # 基础类型
    Chain, EvmConfig, DefiOrder,
    # EVM
    ProviderConfig, EvmProvider, LocalSigner,
    # ERC-20 / DEX / Multicall
    Erc20Client, V3Quoter, V3Router, Multicall,
    # Bridge / MEV
    BridgeConfig, BridgeManager, MevShareConfig, MevShareClient,
    # 工厂函数
    evm_provider, local_signer, erc20_client,
    # 异常
    DefiError,
)
import asyncio

async def main():
    # 1) 真实 RPC 客户端
    provider = evm_provider(Chain.Ethereum, "https://eth.llamarpc.com")
    cid = await provider.chain_id()           # 1
    bn  = await provider.block_number()       # 20_xxx_xxx

    # 2) 真链 ERC-20 查询:查 USDC 余额
    usdc = erc20_client("0xA0b86991c6218b36c1d19D4a2e9Eb0cE3606eB48", provider)
    print("USDC decimals:", await usdc.decimals())  # 6(预设元信息)
    bal = await usdc.balance_of("0xd8dA6BF26964aF9D7eEd9e03E53415D37aA96045")  # vitalik

    # 3) 批量查 100 个 holder 余额(Multicall3,1 次 RPC)
    mc = Multicall(provider, Chain.Ethereum)
    holders = ["0xd8dA6BF26964aF9D7eEd9e03E53415D37aA96045", "0x..."]
    bals = await mc.balance_of_batch(
        "0xA0b86991c6218b36c1d19D4a2e9Eb0cE3606eB48",  # USDC
        holders,
    )

    # 4) Uniswap V3 真链 quote
    quoter = V3Quoter(provider, Chain.Ethereum)
    amount_out = await quoter.quote_exact_input_single(
        "0xA0b86991c6218b36c1d19D4a2e9Eb0cE3606eB48",  # USDC
        "0xC02aaA39b223FE8D0A0e5C4F27eAD9083C756Cc2",  # WETH
        "1000000",  # 1 USDC(6 decimals)
        3000,       # 0.3% fee tier
    )
    print(f"Quote: 1 USDC → {amount_out} wei WETH")

asyncio.run(main())

from axon_quant.defi import evm_provider, Chain, ProviderConfig

# 工厂函数(最简)
provider = evm_provider(Chain.Ethereum, "https://eth.llamarpc.com")
print(provider.rpc_url)         # "https://eth.llamarpc.com"

# 显式构造(更多控制)
config = ProviderConfig.for_chain(Chain.Arbitrum, "https://arb.public-rpc.com")
provider = EvmProvider(config)
print(provider.rpc_url, config.timeout_ms, config.max_retries)

from axon_quant.defi import local_signer, Chain

# 工厂函数
signer = local_signer("0x" + "ab" * 32, Chain.Ethereum)
print(signer.address)        # 0x...
n0 = signer.next_nonce       # 0
n1 = signer.next_nonce       # 1

from axon_quant.defi import erc20_client, evm_provider, Chain

provider = evm_provider(Chain.Ethereum, "https://eth.llamarpc.com")
usdc = erc20_client("0xA0b86991c6218b36c1d19D4a2e9Eb0cE3606eB48", provider)

# 元信息(USDC / USDT / DAI / WETH 走预设,无需 RPC)
print(usdc.info.symbol)       # "USDC"
print(usdc.info.decimals)     # 6

# 真链 RPC 查询
symbol  = await usdc.symbol()                # 走 RPC(未知 token)
decimals = await usdc.decimals()             # 走 RPC
balance = await usdc.balance_of(holder_addr)  # wei 单位(string)

from axon_quant.defi import Multicall, evm_provider, Chain

provider = evm_provider(Chain.Ethereum, "https://eth.llamarpc.com")
mc = Multicall(provider, Chain.Ethereum)

# 100 个 holder 余额 1 次 RPC
holders = ["0x" + format(i, "040x") for i in range(100)]
bals = await mc.balance_of_batch(
    "0xA0b86991c6218b36c1d19D4a2e9Eb0cE3606eB48",  # USDC
    holders,
)
# bals: list of 100 strings(wei 单位)

from axon_quant.defi import V3Quoter, evm_provider, Chain

provider = evm_provider(Chain.Ethereum, "https://eth.llamarpc.com")
quoter = V3Quoter(provider, Chain.Ethereum)
print(quoter.address)  # 0x61fFE014bA17989E743c5F6cB21bF9697530B56e

# 4 个 fee tier 都可报价
for fee in [100, 500, 3000, 10000]:
    out = await quoter.quote_exact_input_single(
        "0xA0b86991c6218b36c1d19D4a2e9Eb0cE3606eB48",  # USDC
        "0xC02aaA39b223FE8D0A0e5C4F27eAD9083C756Cc2",  # WETH
        "1000000",   # 1 USDC
        fee,         # 0.01% / 0.05% / 0.3% / 1%
    )
    print(f"fee={fee}bps: 1 USDC → {out} wei WETH")

# 0.3.0 收口起已可读取 router 地址
from axon_quant.defi import V3Router, evm_provider, Chain

provider = evm_provider(Chain.Ethereum, "https://eth.llamarpc.com")
router = V3Router(provider, Chain.Ethereum)
print(router.address)  # 0x68b3465833fb72A70ecDF485E0e4C7bD8665Fc45

from axon_quant.defi import BridgeConfig, BridgeManager, Chain

cfg = BridgeConfig.default()
print(cfg.endpoint)                   # 0x1a44076050125825900e736c501f859c50fE728c
print(cfg.supported_chains)           # [1, 42161, 10, 137]

mgr = BridgeManager(cfg)
print(mgr.is_supported(Chain.Ethereum))   # True
print(mgr.is_supported(Chain.Arbitrum))   # True
print(mgr.is_supported(Chain.Optimism))   # True
print(mgr.is_supported(Chain.Polygon))    # True

fee = await mgr.estimate_fee(
    provider,
    {
        "dst_eid": 30110,             # Arbitrum mainnet EID
        "receiver": "0xd8dA6BF26964aF9D7eEd9e03E53415D37aA96045",
        "message": b"hello",          # 或 0x hex string
        "options": b"",
        "pay_in_lz_token": False,
    },
)
# 返回 native fee 字符串(U256 wei)

signer = local_signer("0x" + "ab" * 32, Chain.Ethereum)
tx_hash, block_number, status, gas_used = await mgr.bridge_tokens(
    signer,
    provider,
    Chain.Arbitrum,
    {
        "dst_eid": 30110,
        "receiver": "0xd8dA6BF26964aF9D7eEd9e03E53415D37aA96045",
        "message": b"hello",
        "options": b"",
        "pay_in_lz_token": False,
    },
)
# tx_hash: "0x..."
# block_number: 20_xxx_xxx
# status: True(1) / False(0)
# gas_used: 21_000 ~ 数百万

from axon_quant.defi import MevShareConfig, MevShareClient

# 默认配置(public Flashbots relay)
cfg = MevShareConfig.default()
print(cfg.rpc_url)           # https://relay.flashbots.net
print(cfg.max_wait_secs)      # 60

# 自定义(生产环境)
cfg = MevShareConfig.new(
    "https://relay.flashbots.net",
    "0x" + "ab" * 32,         # 签名私钥(用于 X-Flashbots-Signature)
)

client = MevShareClient(cfg)

# 提交 signed tx(0x 前缀 hex)
signed_tx_hex = "0x02f86c0180..."  # 任意已签名交易
bundle_hash = await client.submit_transaction(signed_tx_hex)
# 返回 "0x..."(Flashbots bundleHash,真值)

from axon_quant.defi import DefiError

try:
    bal = await usdc.balance_of(invalid_addr)
except DefiError as e:
    print(f"DeFi 错误: {e}")
except Exception as e:
    print(f"其他错误: {e}")