Real World Asset API for AI Agents

curl https://api.purpleflea.com/v1/rwa/list \
  -H 'Authorization: Bearer pf_live_your_key'

# Response (truncated)
{
  "products": [
    {
      "id": "uscc",
      "name": "Superstate US Cash Corp Bonds",
      "token": "USCC",
      "issuer": "Superstate",
      "apy_7d": 5.41,
      "underlying": "US Treasuries + Corp Bonds",
      "min_investment_usdc": 100,
      "redemption_type": "T+0",
      "kyc_required": true,
      "chain": "ethereum"
    },
    {
      "id": "usdm",
      "name": "Mountain Protocol USDM",
      "token": "USDM",
      "apy_7d": 5.03,
      "redemption_type": "instant",
      "kyc_required": false
    }
  ]
}

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"}

USDC_RESERVE = 100       # Keep $100 USDC liquid for operations
INVEST_THRESHOLD = 50   # Invest when idle USDC > $50 above reserve
REBALANCE_BPS = 25      # Rebalance if better product has 25bps higher APY

def get_best_rwa(products):
    """Return the highest-APY product accessible without extra KYC."""
    accessible = [p for p in products if p.get("access_granted", False)]
    if not accessible:
        accessible = [p for p in products if not p["kyc_required"]]
    return max(accessible, key=lambda p: p["apy_7d"]) if accessible else None

def allocate_idle_usdc(usdc_balance, products):
    """Buy RWA with idle USDC above reserve."""
    idle = usdc_balance - USDC_RESERVE
    if idle < INVEST_THRESHOLD:
        return None

    best = get_best_rwa(products)
    if not best:
        print("No accessible RWA products — check KYC status")
        return None

    print(f"Allocating ${idle:.2f} USDC to {best['token']} ({best['apy_7d']}% APY)")
    r = requests.post(f"{BASE_URL}/v1/rwa/buy", headers=HEADERS, json={
        "product_id": best["id"],
        "amount_usdc": str(idle)
    })
    result = r.json()
    print(f"Purchased {result['tokens_received']} {best['token']} | tx: {result['tx_hash'][:12]}...")
    return result

def check_rebalance(positions, products):
    """Rebalance to higher-yield RWA if spread exceeds threshold."""
    best = get_best_rwa(products)
    if not best:
        return

    for pos in positions:
        current_product = next((p for p in products if p["id"] == pos["product_id"]), None)
        if not current_product or current_product["id"] == best["id"]:
            continue

        spread_bps = (best["apy_7d"] - current_product["apy_7d"]) * 100
        if spread_bps > REBALANCE_BPS:
            print(f"Rebalancing {current_product['token']} → {best['token']} (+{spread_bps:.0f}bps)")
            # Sell current position
            sell = requests.post(f"{BASE_URL}/v1/rwa/sell", headers=HEADERS, json={
                "product_id": pos["product_id"], "amount": "all"
            }).json()
            usdc_received = float(sell["usdc_received"])
            # Buy better product
            requests.post(f"{BASE_URL}/v1/rwa/buy", headers=HEADERS, json={
                "product_id": best["id"], "amount_usdc": str(usdc_received)
            })

def log_yield_report():
    """Print daily yield summary."""
    yield_data = requests.get(f"{BASE_URL}/v1/rwa/yield", headers=HEADERS).json()
    print(f"Daily yield earned: ${yield_data['daily_yield_usd']:.4f}")
    print(f"Total yield to date: ${yield_data['total_yield_usd']:.4f}")
    print(f"Projected annual yield: ${yield_data['projected_annual_usd']:.2f}")

# Main agent loop
while True:
    print(f"[{datetime.now().isoformat()}] RWA treasury check")
    products = requests.get(f"{BASE_URL}/v1/rwa/list", headers=HEADERS).json()["products"]
    wallet = requests.get(f"{BASE_URL}/v1/wallet/balance", headers=HEADERS).json()
    positions = requests.get(f"{BASE_URL}/v1/rwa/position", headers=HEADERS).json()["positions"]

    allocate_idle_usdc(wallet["balances"]["USDC"], products)
    check_rebalance(positions, products)
    log_yield_report()
    time.sleep(3600)  # Run every hour

{
  "tool": "rwa_buy",
  "parameters": {
    "product_id": "usyc",
    "amount_usdc": "500"
  }
}
// Returns:
{
  "tokens_received": "498.43",
  "token": "USYC",
  "current_apy": 5.21,
  "tx_hash": "0xdef456...",
  "daily_yield_usd": "0.071"
}