/**
* Hyperliquid API Data Fetcher
* fetchHyperliquid, getAssetMetadata, getUserState functions
*
* Note: According to Hyperliquid API docs (https://hyperliquid.gitbook.io/hyperliquid-docs/for-developers/api):
* - Info endpoint (/info) does NOT require HTTP authentication - it's a public endpoint
* - API wallets are used for signing transactions (EIP-712 signatures), not HTTP auth headers
* - Exchange endpoint (/exchange) requires signed messages, not Bearer tokens
*/
import { getHyperliquidApiUrl } from '../config'
export async function fetchHyperliquid(endpoint: string, data: any): Promise<any> {
const HYPERLIQUID_API_URL = getHyperliquidApiUrl()
console.log(`🌐 Hyperliquid API URL: ${HYPERLIQUID_API_URL} (testnet=${process.env.HYPERLIQUID_TESTNET})`)
const url = new URL(endpoint, HYPERLIQUID_API_URL)
const postData = JSON.stringify(data)
const headers: Record<string, string> = {
'Content-Type': 'application/json'
}
// Note: Hyperliquid Info endpoint does NOT require HTTP authentication
// API wallets are used for signing transactions, not HTTP auth headers
// See: https://hyperliquid.gitbook.io/hyperliquid-docs/for-developers/api
try {
const response = await fetch(url.toString(), {
method: 'POST',
headers,
body: postData
})
if (!response.ok) {
const errorBody = await response.text()
console.error(`❌ Hyperliquid API Error ${response.status}:`, errorBody)
throw new Error(`HTTP error! status: ${response.status}, body: ${errorBody}`)
}
const result = await response.json()
return result
} catch (error: any) {
throw new Error(`Failed to fetch Hyperliquid data: ${error.message}`)
}
}
export async function getAssetMetadata(): Promise<any> {
try {
const result = await fetchHyperliquid('/info', { type: 'metaAndAssetCtxs' })
return result
} catch (error: any) {
console.error('Error fetching asset metadata:', error)
throw new Error(`Failed to fetch asset metadata: ${error.message}`)
}
}
export async function getUserState(
address: string,
retries: number = 3,
retryDelay: number = 1000
): Promise<any> {
let lastError: Error | null = null
for (let attempt = 1; attempt <= retries; attempt++) {
try {
// Info endpoint does NOT require authentication - it's a public endpoint
// According to Hyperliquid API docs: https://hyperliquid.gitbook.io/hyperliquid-docs/for-developers/api
const result = await fetchHyperliquid('/info', {
type: 'clearinghouseState',
user: address
})
return result
} catch (error: any) {
lastError = error
if (attempt < retries) {
const delay = retryDelay * attempt
await new Promise(resolve => setTimeout(resolve, delay))
}
}
}
throw lastError || new Error('Failed to fetch user state after retries')
}
/**
* Fetch real-time price for a specific asset
* OPTIMIZATION: Accept metadata as parameter to avoid duplicate API call
*/
export async function getRealTimePrice(asset: string, metadata?: any): Promise<number | null> {
try {
// OPTIMIZATION: Use provided metadata if available (avoid duplicate API call)
const hyperliquidMetadata = metadata || await getAssetMetadata()
let assetCtxs: any[] = []
let universe: any[] = []
if (Array.isArray(hyperliquidMetadata) && hyperliquidMetadata.length >= 2) {
const metaObj = hyperliquidMetadata[0]
if (metaObj && metaObj.universe) {
universe = metaObj.universe || []
}
assetCtxs = Array.isArray(hyperliquidMetadata[1]) ? hyperliquidMetadata[1] : []
} else if (hyperliquidMetadata && (hyperliquidMetadata as any).data) {
assetCtxs = (hyperliquidMetadata as any).data.assetCtxs || []
universe = (hyperliquidMetadata as any).data.universe || []
}
const universeIndex = universe.findIndex((item: any) => {
if (typeof item === 'string') return item === asset
return item.name === asset || item.symbol === asset
})
if (universeIndex >= 0 && universeIndex < assetCtxs.length) {
const assetCtx = assetCtxs[universeIndex]
return parseFloat(assetCtx.markPx || '0')
}
return null
} catch (error: any) {
if (process.env.VERBOSE_LOGGING === 'true') {
console.warn(`Failed to fetch real-time price for ${asset}: ${error.message}`)
}
return null
}
}
