-
Performance
-
-
-
-
-
—
-
Max Drawdown
+
Pipeline
+
+
+
📡
+
data_agent
+
HL WS → TimescaleDB
+
+
+
🧠
+
signal_agent
+
candles → conviction
+
+
+
⚡
+
exec_agent
+
signals → HL orders
+
+
+
🛡️
+
risk_agent
+
circuit breakers
+
-
-
-
Place Order
-
+
+
+
+
+
Connect Hyperliquid Wallet
+
Enter your Hyperliquid wallet address to connect. Your wallet is read-only — orders are signed server-side using your configured API key.
+
+
-
-
-
-
+
+ Detected:
+
+
+
+
+
+
+
+
+
+
+
+
Settings
+
Trading configuration. The HL API key is set server-side by your administrator.
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
diff --git a/salior/hl_client.py b/salior/hl_client.py
new file mode 100644
index 0000000..fdff573
--- /dev/null
+++ b/salior/hl_client.py
@@ -0,0 +1,222 @@
+"""Hyperliquid API client — REST + WebSocket + order signing.
+
+Requires: pip install eth-account eth-keys msgpack websockets aiohttp
+"""
+from __future__ import annotations
+
+import asyncio
+import hashlib
+import time as time_module
+from datetime import datetime, timezone
+from typing import Any, Optional
+
+import httpx
+import msgpack
+import websockets
+
+from salior.core.config import config
+from salior.core.logging import setup_logging
+
+log = setup_logging()
+
+HL_API = "https://api.hyperliquid.xyz"
+
+
+class HyperliquidClient:
+ """Client for Hyperliquid REST API.
+
+ Handles:
+ - Account state (balances, positions, open orders)
+ - Order signing + submission (requires private key)
+ - Candle + trade data via WS
+ """
+
+ def __init__(self, private_key: Optional[str] = None) -> None:
+ self.private_key = private_key or config.hl_private_key
+ self._http = httpx.AsyncClient(timeout=15.0)
+
+ async def close(self) -> None:
+ await self._http.aclose()
+
+ # ─── Signing ────────────────────────────────────────────────────────────
+
+ def _sign_action(self, payload: dict) -> dict:
+ """Sign a HL order/cancel payload using secp256k1.
+
+ HL CLOB signing: msgpack(action) → SHA256 → secp256k1 sign.
+ Returns payload with added signature {r, s, v}.
+ """
+ if not self.private_key:
+ raise ValueError("HL private key not configured. Set HL_PRIVATE_KEY env var.")
+
+ try:
+ from eth_account import Account
+ from eth_keys import keys
+ from eth_utils import decode_hex
+ except ImportError as e:
+ raise RuntimeError(
+ "Missing dependencies for HL signing. Install: pip install eth-account eth-keys eth-utils"
+ ) from e
+
+ # msgpack encode (binary mode)
+ encoded = msgpack.packb(payload, use_bin_type=True)
+ digest = hashlib.sha256(encoded).digest()
+
+ # secp256k1 sign
+ pk_bytes = decode_hex(self.private_key) if self.private_key.startswith("0x") else bytes.fromhex(self.private_key)
+ private_key = keys.PrivateKey(pk_bytes)
+ signature = private_key.sign_msg_hash(digest)
+
+ return {
+ **payload,
+ "signature": {
+ "r": hex(signature.r),
+ "s": hex(signature.s),
+ "v": signature.v,
+ },
+ }
+
+ # ─── Account ───────────────────────────────────────────────────────────
+
+ async def get_account(self, address: str) -> dict:
+ """Get account info: balances, positions, open orders."""
+ payload = {"type": "account", "user": address}
+ resp = await self._http.post(f"{HL_API}/exchange", json=payload)
+ if resp.status_code == 200:
+ return resp.json()
+ return {"account": {"positions": [], "totalCollateral": 0}}
+
+ async def get_fills(self, address: str, start_time: int = 0) -> list[dict]:
+ """Get user fill history."""
+ payload = {"type": "fills", "user": address, "startTime": start_time}
+ resp = await self._http.post(f"{HL_API}/exchange", json=payload)
+ if resp.status_code == 200:
+ return resp.json().get("fills", [])
+ return []
+
+ async def get_open_orders(self, address: str) -> list[dict]:
+ """Get user's open orders for all coins."""
+ payload = {"type": "openOrders", "user": address}
+ resp = await self._http.post(f"{HL_API}/exchange", json=payload)
+ if resp.status_code == 200:
+ orders = resp.json()
+ # HL returns {orders: [...], successful: true}
+ return orders.get("orders", [])
+ return []
+
+ # ─── Orders ────────────────────────────────────────────────────────────
+
+ async def place_order(
+ self,
+ address: str,
+ coin: str,
+ side: str, # "Buy" | "Sell"
+ size: float,
+ price: float,
+ order_type: str = "Limit",
+ ) -> dict:
+ """Place a signed limit order via HL CLOB API."""
+ if not self.private_key:
+ raise ValueError("HL private key not configured")
+
+ ts = str(int(time_module.time() * 1000))
+
+ # Build order request payload
+ order_req = {
+ "asset": coin,
+ "user": address,
+ "side": side,
+ "type": order_type,
+ "size": str(size),
+ "price": str(price),
+ "fillOrKill": False,
+ "time": ts,
+ }
+
+ # Sign it
+ signed_order = self._sign_action(order_req)
+
+ # Submit
+ resp = await self._http.post(
+ f"{HL_API}/exchange",
+ json={"type": "order", **signed_order},
+ )
+
+ if resp.status_code == 200:
+ result = resp.json()
+ log.info("hl_order_result", coin=coin, side=side, result=result)
+ return result
+ return {"error": resp.text, "status_code": resp.status_code}
+
+ async def cancel_order(self, address: str, coin: str, order_id: str) -> dict:
+ """Cancel an open order."""
+ ts = str(int(time_module.time() * 1000))
+ cancel_req = {
+ "asset": coin,
+ "user": address,
+ "orderId": order_id,
+ "time": ts,
+ }
+
+ if self.private_key:
+ signed = self._sign_action(cancel_req)
+ else:
+ signed = cancel_req
+
+ resp = await self._http.post(
+ f"{HL_API}/exchange",
+ json={"type": "cancel", **signed},
+ )
+ if resp.status_code == 200:
+ return resp.json()
+ return {"error": resp.text}
+
+ # ─── Market data ────────────────────────────────────────────────────────
+
+ async def get_market_price(self, coin: str) -> Optional[float]:
+ """Get current mid-price for a coin."""
+ payload = {"type": "midPrice", "coin": coin}
+ resp = await self._http.post(f"{HL_API}/exchange", json=payload)
+ if resp.status_code == 200:
+ data = resp.json()
+ price = data.get("midPrice")
+ if price is not None:
+ return float(price)
+ return None
+
+ async def get_candles(self, coin: str, interval: str = "1m", limit: int = 100) -> list[dict]:
+ """Get recent candles."""
+ payload = {"type": "candleRecent", "coin": coin, "interval": interval}
+ resp = await self._http.post(f"{HL_API}/exchange", json=payload)
+ if resp.status_code == 200:
+ return resp.json().get("candle", {}).get("data", [])
+ return []
+
+ # ─── Wallet connect ──────────────────────────────────────────────────────
+
+ async def verify_address(self, address: str) -> dict:
+ """Check if an address has a HL account."""
+ try:
+ account = await self.get_account(address)
+ info = account.get("account", {})
+ has_balance = float(info.get("totalCollateral", 0) or 0) > 0 or len(info.get("positions", [])) > 0
+ return {
+ "address": address,
+ "connected": True, # HL is public-read, all addresses valid
+ "has_activity": has_balance,
+ "balance": info.get("totalCollateral", 0),
+ }
+ except Exception as e:
+ log.warning("hl_verify_failed", address=address, error=str(e))
+ return {"address": address, "connected": False}
+
+
+# Singleton for exec_agent use
+_client: Optional[HyperliquidClient] = None
+
+
+def get_hl_client() -> HyperliquidClient:
+ global _client
+ if _client is None:
+ _client = HyperliquidClient()
+ return _client