Liquid Staking API for AI Agents

curl https://api.purpleflea.com/v1/liquid-staking/apy \
  -H 'Authorization: Bearer pf_live_your_key'

# Response
{
  "updated_at": "2026-03-06T09:00:00Z",
  "protocols": [
    { "id": "frax", "token": "frxETH", "apy_7d": 4.12, "apy_30d": 4.05 },
    { "id": "swell", "token": "swETH", "apy_7d": 3.92, "apy_30d": 3.88 },
    { "id": "lido", "token": "stETH", "apy_7d": 3.81, "apy_30d": 3.79 },
    { "id": "ankr", "token": "ankrETH", "apy_7d": 3.64, "apy_30d": 3.61 },
    { "id": "rocketpool", "token": "rETH", "apy_7d": 3.52, "apy_30d": 3.49 },
    { "id": "coinbase", "token": "cbETH", "apy_7d": 3.21, "apy_30d": 3.18 }
  ]
}

import requests
import time
from datetime import datetime

API_KEY = "pf_live_your_api_key"
BASE_URL = "https://api.purpleflea.com"
HEADERS = {"Authorization": f"Bearer {API_KEY}", "Content-Type": "application/json"}

ETH_RESERVE = 0.05           # Keep 0.05 ETH liquid for gas
STAKE_THRESHOLD = 0.1        # Stake when idle ETH > 0.1
REBALANCE_BPS = 20           # Rebalance if spread > 20bps APY

def get_best_protocol(protocols):
    """Return the protocol with highest 7-day APY."""
    return max(protocols, key=lambda p: p["apy_7d"])

def stake_idle_eth(balance, apys):
    """Stake ETH above reserve into highest-yield protocol."""
    idle_eth = balance["ETH"]
    if idle_eth <= (STAKE_THRESHOLD + ETH_RESERVE):
        return None

    stake_amount = idle_eth - ETH_RESERVE
    best = get_best_protocol(apys["protocols"])
    print(f"Staking {stake_amount:.4f} ETH via {best['id']} ({best['apy_7d']}% APY)")

    r = requests.post(f"{BASE_URL}/v1/liquid-staking/stake", headers=HEADERS, json={
        "protocol": best["id"],
        "amount_eth": str(stake_amount),
        "slippage_bps": 30
    })
    return r.json()

def check_rebalance(holdings, apys):
    """Check if we should swap to a higher-yield LST."""
    protocols = apys["protocols"]
    best = get_best_protocol(protocols)

    for holding in holdings:
        current_apy = next((p["apy_7d"] for p in protocols if p["id"] == holding["protocol"]), 0)
        spread_bps = (best["apy_7d"] - current_apy) * 100

        if spread_bps > REBALANCE_BPS and holding["protocol"] != best["id"]:
            print(f"Rebalancing {holding['token']} → {best['token']} (+{spread_bps:.0f}bps)")
            requests.post(f"{BASE_URL}/v1/liquid-staking/swap", headers=HEADERS, json={
                "from_lst": holding["token"],
                "to_lst": best["token"],
                "amount": holding["balance"],
                "max_slippage_bps": 50
            })

# Main agent loop
while True:
    ts = datetime.now().isoformat()
    print(f"[{ts}] Running liquid staking checks...")

    wallet = requests.get(f"{BASE_URL}/v1/wallet/balance", headers=HEADERS).json()
    apys = requests.get(f"{BASE_URL}/v1/liquid-staking/apy", headers=HEADERS).json()
    holdings = requests.get(f"{BASE_URL}/v1/liquid-staking/balance", headers=HEADERS).json()["holdings"]

    stake_idle_eth(wallet["balances"], apys)
    check_rebalance(holdings, apys)

    time.sleep(1800)  # Run every 30 minutes

{
  "tool": "liquid_stake_eth",
  "parameters": {
    "protocol": "lido",
    "amount_eth": "1.5",
    "slippage_bps": 30
  }
}
// Returns: { lst_received: "1.487", token: "stETH", tx_hash: "0xabc...", apy: 3.81 }