o hk@s\ddlmZddlmZmZmZmZmZmZm Z m Z m Z m Z ddl mZGdddeZdS))API) AnyCallableCloidListMetaOptionalSpotMetaSpotMetaAndAssetCtxs Subscriptioncast)WebsocketManagercseZdZ      drdeedeedeedeedeeedee f fd d Z ded e d e fd dZ ddZdsdeded e fddZded e fddZdsdeded e fddZdsdeded e fddZdsded e fddZded e fddZ dtded e d!ee d"eed e f d#d$Zdsded efd%d&Zd e fd'd(Zd e fd)d*Zd efd+d,Zd efd-d.Zdud/ed0e d1ee d e fd2d3Zdud4ed0e d1ee d e fd5d6Zd/ed e fd7d8Zd/ed9ed0e d1e d e f d:d;Zded e fdd?Z!ded e fd@dAZ"ded e fdBdCZ#d4ed e fdDdEZ$d4edFe d e fdGdHZ%d4edIe&d e fdJdKZ'd4ed e fdLdMZ(d4ed e fdNdOZ)dPed e fdQdRZ*d e fdSdTZ+d4ed e fdUdVZ,dud4ed0e d1ee d e fdWdXZ-d4ed e fdYdZZ.d4ed e fd[d\Z/d4ed e fd]d^Z0d4ed e fd_d`Z1d4ed e fdadbZ2d4ed e fdcddZ3d4ed e fdedfZ4dge5d dfdhdiZ6dge5dje7e gdfd e fdkdlZ8dge5dme d efdndoZ9d/ed e fdpdqZ:Z;S)vInfoNFbase_urlskip_wsmeta spot_meta perp_dexstimeoutcst||d|_|st|j|_|j|dur|}i|_i|_i|_ |dD]H}|dd}||j|d<|d|j|d<|d\} } |d| } |d| } | d|j |<| dd| d} | |jvrt|d|j| <q,dd i}|durdg}nt | d dD]\}}d |d||d<q|D]!}||}|dkr|dur| |d q|j |d }| ||qdS) Nuniverseindexi'nametokens szDecimals/ri)dex)super__init__ ws_managerr rstartr coin_to_asset name_to_coinasset_to_sz_decimals enumerater set_perp_metar)selfrrrrrr spot_infoassetbasequote base_info quote_inforperp_dex_to_offsetiperp_dexoffset fresh_meta __class__]/var/www/html/HyperOracle/crypto_trader/venv/lib/python3.10/site-packages/hyperliquid/info.pyrsD          z Info.__init__r1returncCsPt|dD]\}}||7}||j|d<|d|j|d<|d|j|<qdS)Nrrr)r%r"r#r$)r'rr1r) asset_infor5r5r6r&Gs zInfo.set_perp_metacCs |jdur td|jdS)Nz7Cannot call disconnect_websocket since skip_ws was used)r RuntimeErrorstopr'r5r5r6disconnect_websocketNs zInfo.disconnect_websocketraddressrcC|dd||dS)aRetrieve trading details about a user. POST /info Args: address (str): Onchain address in 42-character hexadecimal format; e.g. 0x0000000000000000000000000000000000000000. Returns: { assetPositions: [ { position: { coin: str, entryPx: Optional[float string] leverage: { type: "cross" | "isolated", value: int, rawUsd: float string # only if type is "isolated" }, liquidationPx: Optional[float string] marginUsed: float string, positionValue: float string, returnOnEquity: float string, szi: float string, unrealizedPnl: float string }, type: "oneWay" } ], crossMarginSummary: MarginSummary, marginSummary: MarginSummary, withdrawable: float string, } where MarginSummary is { accountValue: float string, totalMarginUsed: float string, totalNtlPos: float string, totalRawUsd: float string, } /infoclearinghouseStatetypeuserrpostr'r=rr5r5r6 user_stateTs*zInfo.user_statecC|dd|dS)Nr?spotClearinghouseStaterBrCrDr'r=r5r5r6spot_user_statezInfo.spot_user_statecCr>)aRetrieve a user's open orders. POST /info Args: address (str): Onchain address in 42-character hexadecimal format; e.g. 0x0000000000000000000000000000000000000000. Returns: [ { coin: str, limitPx: float string, oid: int, side: "A" | "B", sz: float string, timestamp: int } ] r? openOrdersrArDrFr5r5r6 open_ordersszInfo.open_orderscCr>)aRetrieve a user's open orders with additional frontend info. POST /info Args: address (str): Onchain address in 42-character hexadecimal format; e.g. 0x0000000000000000000000000000000000000000. Returns: [ { children: [ dict of frontend orders ] coin: str, isPositionTpsl: bool, isTrigger: bool, limitPx: float string, oid: int, orderType: str, origSz: float string, reduceOnly: bool, side: "A" | "B", sz: float string, tif: str, timestamp: int, triggerCondition: str, triggerPx: float str } ] r?frontendOpenOrdersrArDrFr5r5r6frontend_open_ordersszInfo.frontend_open_orderscCrH)zRetrieve all mids for all actively traded coins. POST /info Returns: { ATOM: float string, BTC: float string, any other coins which are trading: float string } r?allMidsrBrrDr'rr5r5r6all_mids z Info.all_midscCrH)aRetrieve a given user's fills. POST /info Args: address (str): Onchain address in 42-character hexadecimal format; e.g. 0x0000000000000000000000000000000000000000. Returns: [ { closedPnl: float string, coin: str, crossed: bool, dir: str, hash: str, oid: int, px: float string, side: str, startPosition: float string, sz: float string, time: int }, ... ] r? userFillsrJrDrKr5r5r6 user_fillsszInfo.user_fills start_timeend_timeaggregate_by_timec Cs|dd||||dS)aRetrieve a given user's fills by time. POST /info Args: address (str): Onchain address in 42-character hexadecimal format; e.g. 0x0000000000000000000000000000000000000000. start_time (int): Unix timestamp in milliseconds end_time (Optional[int]): Unix timestamp in milliseconds aggregate_by_time (Optional[bool]): When true, partial fills are combined when a crossing order gets filled by multiple different resting orders. Resting orders filled by multiple crossing orders will not be aggregated. Returns: [ { closedPnl: float string, coin: str, crossed: bool, dir: str, hash: str, oid: int, px: float string, side: str, startPosition: float string, sz: float string, time: int }, ... ] r?userFillsByTime)rBrC startTimeendTimeaggregateByTimerD)r'r=rYrZr[r5r5r6user_fills_by_times zInfo.user_fills_by_timecCstt|dd|dS)a(Retrieve exchange perp metadata POST /info Returns: { universe: [ { name: str, szDecimals: int }, ... ] } r?rrS)r rrErTr5r5r6rsz Info.metacC|dddiS)aRetrieve exchange MetaAndAssetCtxs POST /info Returns: [ { universe: [ { 'name': str, 'szDecimals': int 'maxLeverage': int, 'onlyIsolated': bool, }, ... ] }, [ { "dayNtlVlm": float string, "funding": float string, "impactPxs": Optional([float string, float string]), "markPx": Optional(float string), "midPx": Optional(float string), "openInterest": float string, "oraclePx": float string, "premium": Optional(float string), "prevDayPx": float string }, ... ] r?rBmetaAndAssetCtxsrDr;r5r5r6meta_and_asset_ctxs!s!zInfo.meta_and_asset_ctxscCra)Nr?rBperpDexsrDr;r5r5r6rDzInfo.perp_dexscCtt|dddiS)aRetrieve exchange spot metadata POST /info Returns: { universe: [ { tokens: [int, int], name: str, index: int, isCanonical: bool }, ... ], tokens: [ { name: str, szDecimals: int, weiDecimals: int, index: int, tokenId: str, isCanonical: bool }, ... ] } r?rBspotMeta)r r rEr;r5r5r6rGszInfo.spot_metacCrf)aRetrieve exchange spot asset contexts POST /info Returns: [ { universe: [ { tokens: [int, int], name: str, index: int, isCanonical: bool }, ... ], tokens: [ { name: str, szDecimals: int, weiDecimals: int, index: int, tokenId: str, isCanonical: bool }, ... ] }, [ { dayNtlVlm: float string, markPx: float string, midPx: Optional(float string), prevDayPx: float string, circulatingSupply: float string, coin: str } ... ] ] r?rBspotMetaAndAssetCtxs)r r rEr;r5r5r6spot_meta_and_asset_ctxsfs(zInfo.spot_meta_and_asset_ctxsrr]r^cCs<|j|}|dur|dd|||dS|dd||dS)a Retrieve funding history for a given coin POST /info Args: name (str): Coin to retrieve funding history for. startTime (int): Unix timestamp in milliseconds. endTime (int): Unix timestamp in milliseconds. Returns: [ { coin: str, fundingRate: float string, premium: float string, time: int }, ... ] Nr?fundingHistory)rBcoinr]r^)rBrkr]r#rE)r'rr]r^rkr5r5r6funding_historys zInfo.funding_historyrCcCs2|dur|dd|||dS|dd||dS)aRetrieve a user's funding history POST /info Args: user (str): Address of the user in 42-character hexadecimal format. startTime (int): Start time in milliseconds, inclusive. endTime (int, optional): End time in milliseconds, inclusive. Defaults to current time. Returns: List[Dict]: A list of funding history records, where each record contains: - user (str): User address. - type (str): Type of the record, e.g., "userFunding". - startTime (int): Unix timestamp of the start time in milliseconds. - endTime (int): Unix timestamp of the end time in milliseconds. Nr? userFundingrBrCr]r^)rBrCr]rDr'rCr]r^r5r5r6user_funding_historyszInfo.user_funding_historycCs|dd|j|dS)a0Retrieve L2 snapshot for a given coin POST /info Args: name (str): Coin to retrieve L2 snapshot for. Returns: { coin: str, levels: [ [ { n: int, px: float string, sz: float string }, ... ], ... ], time: int } r?l2Book)rBrk)rEr#r'rr5r5r6 l2_snapshotszInfo.l2_snapshotintervalcCs&|j||||d}|dd|dS)aRetrieve candles snapshot for a given coin POST /info Args: name (str): Coin to retrieve candles snapshot for. interval (str): Candlestick interval. startTime (int): Unix timestamp in milliseconds. endTime (int): Unix timestamp in milliseconds. Returns: [ { T: int, c: float string, h: float string, i: str, l: float string, n: int, o: float string, s: string, t: int, v: float string }, ... ] )rkrur]r^r?candleSnapshot)rBreqrl)r'rrur]r^rwr5r5r6candles_snapshotszInfo.candles_snapshotcCrH)aRetrieve the volume of trading activity associated with a user. POST /info Args: address (str): Onchain address in 42-character hexadecimal format; e.g. 0x0000000000000000000000000000000000000000. Returns: { activeReferralDiscount: float string, dailyUserVlm: [ { date: str, exchange: str, userAdd: float string, userCross: float string }, ], feeSchedule: { add: float string, cross: float string, referralDiscount: float string, tiers: { mm: [ { add: float string, makerFractionCutoff: float string }, ], vip: [ { add: float string, cross: float string, ntlCutoff: float string }, ] } }, userAddRate: float string, userCrossRate: float string } r?userFeesrJrDrKr5r5r6 user_feess)zInfo.user_feescCrH)aRetrieve the staking summary associated with a user. POST /info Args: address (str): Onchain address in 42-character hexadecimal format; e.g. 0x0000000000000000000000000000000000000000. Returns: { delegated: float string, undelegated: float string, totalPendingWithdrawal: float string, nPendingWithdrawals: int } r?delegatorSummaryrJrDrKr5r5r6user_staking_summary#szInfo.user_staking_summarycCrH)aRetrieve the user's staking delegations. POST /info Args: address (str): Onchain address in 42-character hexadecimal format; e.g. 0x0000000000000000000000000000000000000000. Returns: [ { validator: string, amount: float string, lockedUntilTimestamp: int }, ] r? delegationsrJrDrKr5r5r6user_staking_delegations3zInfo.user_staking_delegationscCrH)aRetrieve the historic staking rewards associated with a user. POST /info Args: address (str): Onchain address in 42-character hexadecimal format; e.g. 0x0000000000000000000000000000000000000000. Returns: [ { time: int, source: string, totalAmount: float string }, ] r?delegatorRewardsrJrDrKr5r5r6user_staking_rewardsDrzInfo.user_staking_rewardscCrH)adRetrieve comprehensive staking history for a user. POST /info Args: user (str): Onchain address in 42-character hexadecimal format. Returns: Comprehensive staking history including delegation and undelegation events with timestamps, transaction hashes, and detailed delta information. r?delegatorHistoryrJrDr'rCr5r5r6delegator_historyUrVzInfo.delegator_historyoidcCr>Nr? orderStatus)rBrCrrD)r'rCrr5r5r6query_order_by_oidcszInfo.query_order_by_oidcloidcCs|dd||dSr)rEto_raw)r'rCrr5r5r6query_order_by_cloidfszInfo.query_order_by_cloidcCrH)Nr?referralrJrDrr5r5r6query_referral_stateirMzInfo.query_referral_statecCrH)Nr? subAccountsrJrDrr5r5r6query_sub_accountslrMzInfo.query_sub_accountsmulti_sig_usercCrH)Nr?userToMultiSigSignersrJrD)r'rr5r5r6query_user_to_multi_sig_signersorMz$Info.query_user_to_multi_sig_signerscCra)Nr?rBperpDeployAuctionStatusrDr;r5r5r6 query_perp_deploy_auction_statusrrez%Info.query_perp_deploy_auction_statuscCrH)a|Retrieve a user's historical orders. POST /info Args: user (str): Onchain address in 42-character hexadecimal format; e.g. 0x0000000000000000000000000000000000000000. Returns: Returns at most 2000 most recent historical orders with their current status and detailed order information. r?historicalOrdersrJrDrr5r5r6historical_ordersus zInfo.historical_orderscCs|dd|||dS)aRetrieve non-funding ledger updates for a user. POST /info Args: user (str): Onchain address in 42-character hexadecimal format. startTime (int): Start time in milliseconds (epoch timestamp). endTime (Optional[int]): End time in milliseconds (epoch timestamp). Returns: Comprehensive ledger updates including deposits, withdrawals, transfers, liquidations, and other account activities excluding funding payments. r?userNonFundingLedgerUpdatesrorDrpr5r5r6user_non_funding_ledger_updatess z$Info.user_non_funding_ledger_updatescCrH)a^Retrieve comprehensive portfolio performance data. POST /info Args: user (str): Onchain address in 42-character hexadecimal format. Returns: Comprehensive portfolio performance data across different time periods, including account value history, PnL history, and volume metrics. r? portfoliorJrDrr5r5r6rrVzInfo.portfoliocCrH)aRetrieve a user's TWAP slice fills. POST /info Args: user (str): Onchain address in 42-character hexadecimal format. Returns: Returns at most 2000 most recent TWAP slice fills with detailed execution information. r?userTwapSliceFillsrJrDrr5r5r6user_twap_slice_fillsrVzInfo.user_twap_slice_fillscCrH)aaRetrieve user's equity positions across all vaults. POST /info Args: user (str): Onchain address in 42-character hexadecimal format. Returns: Detailed information about user's equity positions across all vaults including current values, profit/loss metrics, and withdrawal details. r?userVaultEquitiesrJrDrr5r5r6user_vault_equitiesrVzInfo.user_vault_equitiescCrH)a\Retrieve the role and account type information for a user. POST /info Args: user (str): Onchain address in 42-character hexadecimal format. Returns: Role and account type information including account structure, permissions, and relationships within the Hyperliquid ecosystem. r?userRolerJrDrr5r5r6 user_rolerVzInfo.user_rolecCrH)a]Retrieve user's API rate limit configuration and usage. POST /info Args: user (str): Onchain address in 42-character hexadecimal format. Returns: Detailed information about user's API rate limit configuration and current usage for managing API usage and avoiding rate limiting. r? userRateLimitrJrDrr5r5r6user_rate_limitrVzInfo.user_rate_limitcCrH)Nr?spotDeployStaterJrDrr5r5r6 query_spot_deploy_auction_statusrMz%Info.query_spot_deploy_auction_statuscCrH)aRetrieve extra agents associated with a user. POST /info Args: user (str): Onchain address in 42-character hexadecimal format; e.g. 0x0000000000000000000000000000000000000000. Returns: [ { "name": str, "address": str, "validUntil": int }, ... ] r? extraAgentsrJrDrr5r5r6 extra_agentsszInfo.extra_agents subscriptioncCsV|ddks|ddks|ddks|ddks|ddkr)|j|d|d<dSdS)NrBrrtradescandlebboactiveAssetCtxrk)r#)r'rr5r5r6_remap_coin_subscriptions     zInfo._remap_coin_subscriptioncallbackcC*|||jdurtd|j||S)Nz,Cannot call subscribe since skip_ws was used)rr r9 subscribe)r'rrr5r5r6r  zInfo.subscribesubscription_idcCr)Nz.Cannot call unsubscribe since skip_ws was used)rr r9 unsubscribe)r'rrr5r5r6rrzInfo.unsubscribecCs|j|j|SN)r"r#rsr5r5r6 name_to_asset rezInfo.name_to_asset)NFNNNN)r)NFr)<__name__ __module__ __qualname__rstrboolrr rfloatrintrr&r<rGrLrOrQrUrXr`rrcrrr rirmrqrtrxrzr|r~rrrrrrrrrrrrrrrrrrr rrrrr __classcell__r5r5r3r6rs  5,! +# * +  rN)hyperliquid.apirhyperliquid.utils.typesrrrrrrr r r r hyperliquid.websocket_managerr rr5r5r5r6s 0