1"""
2Hyperliquid skill exports — read-only tools, sync via requests.
3 
4Bypasses the async client entirely. Uses direct POST to /info endpoint.
5Wallet address resolved via Fly OIDC → wallet-service.
6 
7Write operations (hl_order, hl_cancel, etc.) are NOT exported — they require
8the agent's signing pipeline. Use /chat/stream to invoke those from task scripts.
9 
10Usage in task scripts:
11    from core.skill_tools import hyperliquid
12    account = hyperliquid.hl_account()
13    mids = hyperliquid.hl_market()
14    candles = hyperliquid.hl_candles(coin="BTC", interval="1h", hours_back=24)
15"""
16import os
17import json
18import time
19import http.client
20import socket
21import requests
22 
23HL_API = os.environ.get("HYPERLIQUID_API_URL", "https://api.hyperliquid.xyz")
24FLY_API_SOCKET = "/.fly/api"
25WALLET_SERVICE_URL = os.environ.get("WALLET_SERVICE_URL", "https://wallet-service-dev.fly.dev")
26OIDC_AUDIENCE = os.environ.get("WALLET_OIDC_AUDIENCE", WALLET_SERVICE_URL)
27 
28_cached_address = None
29 
30 
31def _get_oidc_token():
32    """Get OIDC token from Fly unix socket."""
33    conn = http.client.HTTPConnection("localhost")
34    conn.sock = socket.socket(socket.AF_UNIX, socket.SOCK_STREAM)
35    conn.sock.connect(FLY_API_SOCKET)
36    body = json.dumps({"aud": OIDC_AUDIENCE}).encode()
37    conn.request("POST", "/v1/tokens/oidc", body=body,
38                 headers={"Host": "localhost", "Content-Type": "application/json"})
39    resp = conn.getresponse()
40    token = resp.read().decode().strip()
41    conn.close()
42    return token
43 
44 
45def _get_address():
46    """Get agent's EVM wallet address (cached)."""
47    global _cached_address
48    if _cached_address:
49        return _cached_address
50    if not os.path.exists(FLY_API_SOCKET):
51        raise RuntimeError("Not on Fly machine — wallet unavailable")
52    token = _get_oidc_token()
53    r = requests.get(f"{WALLET_SERVICE_URL}/agent/wallet",
54                     headers={"Authorization": f"Bearer {token}"}, timeout=15)
55    r.raise_for_status()
56    data = r.json()
57    for w in (data if isinstance(data, list) else data.get("wallets", [])):
58        if w.get("chain_type") == "ethereum":
59            _cached_address = w["wallet_address"]
60            return _cached_address
61    raise RuntimeError("No ethereum wallet found")
62 
63 
64def _info(req_type, **kwargs):
65    """POST to Hyperliquid /info endpoint."""
66    payload = {"type": req_type, **kwargs}
67    r = requests.post(f"{HL_API}/info", json=payload, timeout=15)
68    r.raise_for_status()
69    data = r.json()
70    if isinstance(data, dict) and data.get("status") == "err":
71        raise Exception(f"Hyperliquid error: {data.get('response', data)}")
72    return data
73 
74 
75# ── Exported read-only tools (names match SKILL.md) ──
76 
77 
78def hl_account(dex=None):
79    """Get perp account state: positions, margin, PnL."""
80    addr = _get_address()
81    if dex:
82        return _info("clearinghouseState", user=addr, dex=dex)
83    return _info("clearinghouseState", user=addr)
84 
85 
86def hl_balances():
87    """Get spot token balances."""
88    return _info("spotClearinghouseState", user=_get_address())
89 
90 
91def hl_open_orders():
92    """Get all open orders."""
93    return _info("openOrders", user=_get_address())
94 
95 
96def hl_market(dex=None):
97    """Get current mid prices for all assets."""
98    if dex:
99        return _info("allMids", dex=dex)
100    return _info("allMids")
101 
102 
103def hl_orderbook(coin):
104    """Get L2 orderbook snapshot for a coin."""
105    return _info("l2Book", coin=coin)
106 
107 
108def hl_fills():
109    """Get recent trade fills for this wallet."""
110    return _info("userFills", user=_get_address())
111 
112 
113def hl_candles(coin, interval="1h", hours_back=24, start=None, end=None):
114    """Get OHLCV candlestick data.
115    
116    Args:
117        coin: e.g. "BTC", "ETH"
118        interval: "1m","5m","15m","1h","4h","1d"
119        hours_back: lookback period in hours (default 24)
120        start/end: explicit timestamps in ms (override hours_back)
121    """
122    if end is None:
123        end = int(time.time() * 1000)
124    if start is None:
125        start = end - hours_back * 3600 * 1000
126    return _info("candleSnapshot", req={"coin": coin, "interval": interval, "startTime": start, "endTime": end})
127 
128 
129def hl_funding(coin, hours_back=24, start=None):
130    """Get historical funding rates for a coin.
131    
132    Args:
133        coin: e.g. "BTC"
134        hours_back: lookback in hours (default 24)
135        start: explicit start timestamp in ms (overrides hours_back)
136    """
137    if start is None:
138        start = int((time.time() - hours_back * 3600) * 1000)
139    return _info("fundingHistory", coin=coin, startTime=start)
140 
141 
142def hl_predicted_funding():
143    """Get predicted next funding rates for all assets."""
144    return _info("predictedFundings")
145 
146 
147def hl_order_status(oid):
148    """Look up a single order by oid."""
149    return _info("orderStatus", user=_get_address(), oid=oid)
150 
151 
152def hl_user_fees():
153    """Get user fee schedule."""
154    return _info("userFees", user=_get_address())
155