Stack ETH Staking Yield
with Restaking Rewards

# Purple Flea Wallet API — query LRT token balances import requests API_KEY = "pf_live_your_api_key" WALLET_ID = "wallet_abc123" # ERC-20 contract addresses for major LRTs LRT_TOKENS = { "eETH": "0x35fA164735182de50811E8e2E824cFb9B6118ac2", "weETH": "0xCd5fE23C85820F7B72D0926FC9b05b43E359b7ee", "ezETH": "0xbf5495Efe5DB9ce00f80364C8B423567e58d2110", "rsETH": "0xA1290d69c65A6Fe4DF752f95823fae25cB99e5A7", "swETH": "0xf951E335afb289353dc249e82926178EaC7DEd78", } def get_lrt_balances(wallet_id: str) -> dict: resp = requests.get( f"https://api.purpleflea.com/v1/wallets/{wallet_id}/tokens", headers={"Authorization": f"Bearer {API_KEY}"}, params={"chain": "ethereum", "addresses": ",".join(LRT_TOKENS.values())} ) resp.raise_for_status() return { name: resp.json()["tokens"].get(addr, {}).get("balance", "0") for name, addr in LRT_TOKENS.items() } balances = get_lrt_balances(WALLET_ID) for token, bal in balances.items(): print(f"{token}: {bal}")

""" RestakingAgent — autonomous ETH restaking manager Uses Purple Flea Wallet API for custody and transaction signing. """ import asyncio, time, logging from dataclasses import dataclass, field from typing import Dict, Optional import requests logging.basicConfig(level=logging.INFO) log = logging.getLogger("RestakingAgent") # ── Configuration ─────────────────────────────────────────────── @dataclass class RestakingConfig: api_key: str wallet_id: str target_allocations: Dict[str, float] = field(default_factory=lambda: { "eETH": 0.35, # 35% — largest, most liquid "ezETH": 0.25, # 25% — multi-protocol exposure "rsETH": 0.20, # 20% — lower fee "swETH": 0.10, # 10% — swell pearls farm "WETH": 0.10, # 10% — dry powder / gas reserve }) rebalance_threshold: float = 0.05 # 5% drift before rebalance check_interval_secs: int = 3600 # check every hour compound_interval_secs: int = 86400 # compound daily base_url: str = "https://api.purpleflea.com/v1" # ── Points tracking ───────────────────────────────────────────── @dataclass class PointsSnapshot: timestamp: int eigenlayer_points: float symbiotic_points: float karak_xp: float etherfi_loyalty: float renzo_ezpoints: float def total_estimated_usd(self, token_prices: Dict[str, float]) -> float: # rough conversion: EL points ~0.01 EIGEN, EIGEN ~$2.50 el_est = self.eigenlayer_points * 0.01 * token_prices.get("EIGEN", 2.5) rz_est = self.renzo_ezpoints * 0.005 * token_prices.get("REZ", 0.04) return el_est + rz_est # ── Main Agent ────────────────────────────────────────────────── class RestakingAgent: def __init__(self, config: RestakingConfig): self.cfg = config self.session = requests.Session() self.session.headers["Authorization"] = f"Bearer {config.api_key}" self.points_history: list[PointsSnapshot] = [] self.last_compound = 0 # ── Wallet helpers ─────────────────────────────────────────── def get_balances(self) -> Dict[str, float]: r = self.session.get(f"{self.cfg.base_url}/wallets/{self.cfg.wallet_id}/tokens", params={"chain": "ethereum"}) r.raise_for_status() return {t["symbol"]: float(t["balance"]) for t in r.json()["tokens"]} def get_eth_price(self) -> float: r = self.session.get(f"{self.cfg.base_url}/prices/ETH") return float(r.json()["usd"]) def sign_and_send_tx(self, to: str, data: str, value_wei: int = 0) -> str: r = self.session.post(f"{self.cfg.base_url}/wallets/{self.cfg.wallet_id}/send", json={"chain": "ethereum", "to": to, "data": data, "value": str(value_wei)}) r.raise_for_status() tx_hash = r.json()["txHash"] log.info(f"TX submitted: {tx_hash}") return tx_hash # ── Points aggregation ─────────────────────────────────────── def fetch_points(self) -> PointsSnapshot: # Query each protocol's points API wallet_addr = self.session.get( f"{self.cfg.base_url}/wallets/{self.cfg.wallet_id}" ).json()["address"] el_r = requests.get(f"https://api.eigenlayer.xyz/v1/points/{wallet_addr}") ef_r = requests.get(f"https://api.ether.fi/points/{wallet_addr}") rz_r = requests.get(f"https://api.renzoprotocol.com/points/{wallet_addr}") return PointsSnapshot( timestamp = int(time.time()), eigenlayer_points= float(el_r.json().get("points", 0)), symbiotic_points = 0, # query symbiotic subgraph separately karak_xp = 0, # query karak API separately etherfi_loyalty = float(ef_r.json().get("loyalty_points", 0)), renzo_ezpoints = float(rz_r.json().get("ez_points", 0)), ) # ── Rebalancing logic ──────────────────────────────────────── def check_and_rebalance(self) -> bool: balances = self.get_balances() eth_price = self.get_eth_price() total_usd = sum(v * eth_price for v in balances.values()) if total_usd < 10: log.info("Portfolio too small to rebalance") return False current_allocs = {k: (v * eth_price / total_usd) for k, v in balances.items()} rebalance_needed = False for token, target in self.cfg.target_allocations.items(): current = current_allocs.get(token, 0) drift = abs(current - target) if drift > self.cfg.rebalance_threshold: log.info(f"Drift detected: {token} {current:.2%} vs target {target:.2%}") rebalance_needed = True if rebalance_needed: log.info("Initiating rebalance via 1inch / Purple Flea swap API") # Implement swap logic via purpleflea swap endpoint or direct DEX return rebalance_needed # ── Main loop ──────────────────────────────────────────────── async def run(self): log.info("RestakingAgent started") while True: try: snap = self.fetch_points() self.points_history.append(snap) log.info(f"EigenLayer: {snap.eigenlayer_points:.1f} pts | " f"ether.fi: {snap.etherfi_loyalty:.1f} pts | " f"Renzo: {snap.renzo_ezpoints:.1f} pts") self.check_and_rebalance() now = int(time.time()) if now - self.last_compound > self.cfg.compound_interval_secs: log.info("Running daily compound cycle") # Harvest any claimable rewards and re-deposit self.last_compound = now except Exception as e: log.error(f"Agent error: {e}") await asyncio.sleep(self.cfg.check_interval_secs) # ── Entry point ────────────────────────────────────────────── if __name__ == "__main__": cfg = RestakingConfig( api_key = "pf_live_your_api_key", wallet_id = "wallet_abc123", ) agent = RestakingAgent(cfg) asyncio.run(agent.run())