eiddlZddlmZmZmZddlmZmZm Z m Z m Z m Z m Z mZmZmZmZmZmZmZmZddlmZddlmZddlmZGddejjZdS) N) ArrayCacheArrayCacheBySymbolByIdArrayCacheByTimestamp)AnyBoolIntMarketNumOrder OrderBook OrderRequest OrderSide OrderTypeStrStringsTickerTickersTrade)Client)List) NotSupportedc zeZdZdeffd ZifdeefdZdifdede de d e d e f d Z ddifd edededed e d e f d ZdifdeedefdZdifd edefdZdifdededefdZifdedefdZdZifdedefdZdifdedefdZdifdedefdZdddifdedededeefdZdifdedefdZde fdZ!d?de"defdZ#de fd Z$ddifdedededeefd!Z%ifdedefd"Z&de fd#Z'd?d$e(de"defd%Z)d&ddifded'edededee*f d(Z+d&ifded'edefd)Z,de fd*Z-de d+e(fd,Z.dddifdedededee/fd-Z0difdedefd.Z1de fd/Z2de de3fd0Z4de d1e(fd2Z5de d1e(fd3Z6de d1e(fd4Z7de d1e(fd5Z8de d1e(fd6Z9de d1e(fd7Z:de fd8Z;de fd9Zde fd<Z?d=e(de(fd>Z@xZAS)@ hyperliquidreturnc *|tt|idddddddddddddd d dd dd dd ddddddddd dd dddddddddddiidddiidi|jddddiiidS)NwsT cancelOrderWscancelOrdersWs createOrderWscreateOrdersWs editOrderWs watchBalanceF watchMyTrades watchOHLCVwatchOrderBook watchOrders watchTicker watchTickers watchTradeswatchTradesForSymbols watchPositionunWatchOrderBook)unWatchTickers unWatchTrades unWatchOHLCVunWatchMyTrades unWatchOrderspubliczwss://api.hyperliquid.xyz/wsz$wss://api.hyperliquid-testnet.xyz/ws)apitesti N)ping keepAliveexact)hasurlsoptions streaming exceptions) deep_extendsuperrdescriber5)self __class__s R/var/www/html/volatility/venv/lib/python3.11/site-packages/ccxt/pro/hyperliquid.pyr?zhyperliquid.describesk4 8 8 A A C Cd!$   !$  t  d!$ttt(  !"#D#$#'!% $#'!%-4 "@  "H   " W1F 1F 1 1 1 orderscK|d{V|jddd}|||}||}||di}||d}|||||d{V}||di} || di} || d g} || dS) a create a list of trade orders using WebSocket post request https://hyperliquid.gitbook.io/hyperliquid-docs/for-developers/api/exchange-endpoint#place-an-order :param Array orders: list of orders to create, each object should contain the parameters required by createOrder, namely symbol, type, side, amount, price and params :param dict [params]: extra parameters specific to the exchange API endpoint :returns dict: an `order structure ` Nr3rr2request requestIdresponsedatastatuses) load_marketsr9createOrdersRequestwrap_as_post_action safe_dict safe_stringwatch safe_list parse_orders) r@rDparamsurl ordersRequestwrappedrFrGrH responseOjbrIrJs rBcreate_orders_wszhyperliquid.create_orders_wsDs!!!!!!!!!it$X.00@@ **=99..)R88$$Wk:: CGYGGGGGGGGnnXz2>> ~~k6266>>$ B77  4000rCNsymboltypesideamountpricec K|d{V|d||||||\}}||g|d{V} t| } | dkr|iS| d} | S)a; create a trade order using WebSocket post request https://hyperliquid.gitbook.io/hyperliquid-docs/for-developers/api/exchange-endpoint#place-an-order :param str symbol: unified symbol of the market to create an order in :param str type: 'market' or 'limit' :param str side: 'buy' or 'sell' :param float amount: how much of currency you want to trade in units of base currency :param float [price]: the price at which the order is to be fulfilled, in units of the quote currency, ignored in market orders :param dict [params]: extra parameters specific to the exchange API endpoint :param str [params.timeInForce]: 'Gtc', 'Ioc', 'Alo' :param bool [params.postOnly]: True or False whether the order is post-only :param bool [params.reduceOnly]: True or False whether the order is reduce-only :param float [params.triggerPrice]: The price at which a trigger order is triggered at :param str [params.clientOrderId]: client order id,(optional 128 bit hex string e.g. 0x1234567890abcdef1234567890abcdef) :param str [params.slippage]: the slippage for market order :param str [params.vaultAddress]: the vault address for order :returns dict: an `order structure ` Nr)rKparseCreateEditOrderArgsrXlen safe_order) r@rYrZr[r\r]rSorder globalParamsrD ordersLength parsedOrders rBcreate_order_wszhyperliquid.create_order_wsZs*!!!!!!!!!";;D&$PTV\^cekll|,,eWlCCCCCCCC6{{ 1  ??2&& &Qi rCidc K|d{V||}|jddd} ||||||||\} } || g| } || } || di}|| d}|| |||d{V}||di}||di}| |d g}||d i}| ||}|S) a edit a trade order https://hyperliquid.gitbook.io/hyperliquid-docs/for-developers/api/exchange-endpoint#modify-multiple-orders :param str id: cancel order id :param str symbol: unified symbol of the market to create an order in :param str type: 'market' or 'limit' :param str side: 'buy' or 'sell' :param float amount: how much of currency you want to trade in units of base currency :param float [price]: the price at which the order is to be fulfilled, in units of the quote currency, ignored in market orders :param dict [params]: extra parameters specific to the exchange API endpoint :param str [params.timeInForce]: 'Gtc', 'Ioc', 'Alo' :param bool [params.postOnly]: True or False whether the order is post-only :param bool [params.reduceOnly]: True or False whether the order is reduce-only :param float [params.triggerPrice]: The price at which a trigger order is triggered at :param str [params.clientOrderId]: client order id,(optional 128 bit hex string e.g. 0x1234567890abcdef1234567890abcdef) :param str [params.vaultAddress]: the vault address for order :returns dict: an `order structure ` Nr3rr2rFrGrHrIrJr) rKmarketr9r_editOrdersRequestrMrNrOrPrQ parse_order)r@rgrYrZr[r\r]rSrirTrbrc postRequestrVrFrGrHresponseObject dataObjectrJfirstres rB edit_order_wszhyperliquid.edit_order_wsysf*!!!!!!!!!V$$it$X.";;BdTZ\acijj|,,eWlCC **;77..)R88$$Wk:: CGYGGGGGGGG*bAA^^NFB?? >>*j"==xB//&&uf55 rCidscK||d{V||||}|jddd}||}||di}||d}|||||d{V} || di} || di} || d g} g} td t| D]5}| |}| | ||d 6| S) a cancel multiple orders using WebSocket post request https://hyperliquid.gitbook.io/hyperliquid-docs/for-developers/api/websocket/post-requests :param str[] ids: list of order ids to cancel :param str symbol: unified symbol of the market the orders were made in :param dict [params]: extra parameters specific to the exchange API endpoint :param str[] [params.clientOrderId]: list of client order ids to cancel instead of order ids :param str [params.vaultAddress]: the vault address for order cancellation :returns dict[]: a list of `order structures ` Nr3rr2rFrGrHrIrJr)infostatus) check_required_credentialsrKcancelOrdersRequestr9rMrNrOrPrQranger`appendra)r@rqrYrSrFrTrV wsRequestrGrH responseObjrIrJrDirts rBcancel_orders_wszhyperliquid.cancel_orders_wss '')))!!!!!!!!!**3??it$X.**733NN7Ir:: $$Wk:: CIyIIIIIIIInnXz2>> ~~k6266>>$ B77q#h--((  Aa[F MM$// ++     rCcnK||g||d{V}||dS)az cancel a single order using WebSocket post request https://hyperliquid.gitbook.io/hyperliquid-docs/for-developers/api/websocket/post-requests :param str id: order id to cancel :param str symbol: unified symbol of the market the order was made in :param dict [params]: extra parameters specific to the exchange API endpoint :param str [params.clientOrderId]: client order id to cancel instead of order id :param str [params.vaultAddress]: the vault address for order cancellation :returns dict: an `order structure ` Nr)r|rN)r@rgrYrSrDs rBcancel_order_wszhyperliquid.cancel_order_wssG,,bT66BBBBBBBB~~fa(((rClimitc|K|d{V||}|d}d|z}|jddd}dd|d r|d n|d d d }|||}|||||d{V} | S)aV watches information on open orders with bid(buy) and ask(sell) prices, volumes and other data https://hyperliquid.gitbook.io/hyperliquid-docs/for-developers/api/websocket/subscriptions :param str symbol: unified symbol of the market to fetch the order book for :param int [limit]: the maximum amount of order book entries to return :param dict [params]: extra parameters specific to the exchange API endpoint :returns dict: A dictionary of `order book structures ` indexed by market symbols NrY orderbook:r3rr2 subscribel2BookswapbaseNamergrZcoinmethod subscription)rKrir9extendrPr) r@rYrrSri messageHashrTrFmessage orderbooks rBwatch_order_bookzhyperliquid.watch_order_books!!!!!!!!!V$$!"V+ it$X.! .4VnNz**&,  ++gv..**S+w LLLLLLLL    rCcK|d{V||}|d}d|z}d|z}|jddd}t|}|dd |d r|d n|d d d}|||} |||| |d{VS)a  unWatches information on open orders with bid(buy) and ask(sell) prices, volumes and other data https://hyperliquid.gitbook.io/hyperliquid-docs/for-developers/api/websocket/subscriptions :param str symbol: unified symbol of the market to fetch the order book for :param dict [params]: extra parameters specific to the exchange API endpoint :returns dict: A dictionary of `order book structures ` indexed by market symbols NrYr unsubscribe:r3rr2 unsubscriberrrrgr)rgrr)rKrir9strnoncerrP) r@rYrSrisubMessageHashrrTrgrFrs rBun_watch_order_bookzhyperliquid.un_watch_order_books!!!!!!!!!V$$!%.$~5 it$X.   # .4VnNz**&,  ++gv..ZZ[';GGGGGGGGGrCc |||di}||d}||}||}|d}||dg}||dg||dgd} ||d} || || d d d d } ||jvr|| } | |j|<|j|} | | d |z}| | |dS)NrIrrYlevelsr)bidsaskstimerrpxszr) rNrOcoinToMarketIdrirQ safe_integerparse_order_book orderbooks order_bookresetresolve)r@clientrentryrmarketIdrirYrawDatarI timestampsnapshotobrrs rBhandle_order_bookzhyperliquid.handle_order_booksG4w33v..&&t,,X&&!.."55NN7Ar22NN7Ar22  %%eV44 ((vy&&RVX\]]$/))**B&(DOF #OF+ !!!"V+ y+.....rCcK||}|d}|||did}|r||d|i}||g|d{V}||S)aG https://hyperliquid.gitbook.io/hyperliquid-docs/for-developers/api/websocket/subscriptions watches a price ticker, a statistical calculation with the information calculated over the past 24 hours for a specific market :param str symbol: unified symbol of the market to fetch the ticker for :param dict [params]: extra parameters specific to the exchange API endpoint :param str [params.channel]: 'webData2' or 'allMids', default is 'webData2' :returns dict: a `ticker structure ` rYrsdexN)rirOrNr watch_tickers)r@rYrSridexNametickerss rB watch_tickerzhyperliquid.watch_ticker5sV$$!""4>>&&"#E#EuMM  ;[[%)9::F**F8V<<<<<<<<vrCsymbolscK|d{V||dd}d}|jddd}d}||dd |\}}d |d d d }||d}||d}|D||} ||| did} | | }|1||d}d|z}d|dd<||dd<|||| |||d{V} |j r| | d|S|j S)a watches a price ticker, a statistical calculation with the information calculated over the past 24 hours for all markets of a specific list https://hyperliquid.gitbook.io/hyperliquid-docs/for-developers/api/websocket/subscriptions :param str[] symbols: unified symbol of the market to fetch the ticker for :param dict [params]: extra parameters specific to the exchange API endpoint :param str [params.channel]: 'webData2' or 'allMids', default is 'webData2' :param str [params.dex]: for for hip3 tokens subscription, eg: 'xyz' or 'flx`, if symbols are provided we will infer it from the first symbol's market :returns dict: a `ticker structure ` NTrr3rr2webData2r(channelr*0x0000000000000000000000000000000000000000rZuserrrrrsztickers:allMidsrrZrY) rKmarket_symbolsr9handle_option_and_paramsrOrirNomitrPr newUpdatesfilter_by_array_tickersr) r@rrSrrTrrF defaultDex firstSymbolrirrs rBrzhyperliquid.watch_tickersIs!!!!!!!!!%%gtT:: it$X.77PY[bcc!D  %%fe44 &&w22  "[[--F&&t~~ffb'I'I5QQG"$  !YYvu--F$z1K.7GN #F +-7GN #E * 3 T[[&5Q5QS^________ ? L//7KK K|rCcVK|d{V||dd}d}d}||dd|\}}d|z}|jdd d }d |d d d}|||||||d{VS)aY unWatches a price ticker, a statistical calculation with the information calculated over the past 24 hours for all markets of a specific list https://hyperliquid.gitbook.io/hyperliquid-docs/for-developers/api/websocket/subscriptions :param str[] symbols: unified symbol of the market to fetch the ticker for :param dict [params]: extra parameters specific to the exchange API endpoint :param str [params.channel]: 'webData2' or 'allMids', default is 'webData2' :returns dict: a `ticker structure ` NTrrr-rrr3rr2rrrr)rKrrr9rPr)r@rrSrrrrTrFs rBun_watch_tickerszhyperliquid.un_watch_tickersss!!!!!!!!!%%gtT::"77@PR[]dee$~5 it$X.#D  ZZ[$++gv2N2NP[\\\\\\\\\rCsincecKd}|d|\}}|d{Vd}|||}|d|zz }|jddd}dd |d d }|||} |||| |d{V} |jr| ||}|| |||d S) a watches information on multiple trades made by the user https://hyperliquid.gitbook.io/hyperliquid-docs/for-developers/api/websocket/subscriptions :param str symbol: unified market symbol of the market orders were made in :param int [since]: the earliest time in ms to fetch orders for :param int [limit]: the maximum number of order structures to retrieve :param dict [params]: extra parameters specific to the exchange API endpoint :param str [params.user]: user address, will default to self.walletAddress if not provided :returns dict[]: a list of `order structures ` Nr#myTrades:r3rr2r userFillsrrT) handlePublicAddressrKrYr9rrPrgetLimitfilter_by_symbol_since_limit) r@rYrrrS userAddressrrTrFrtradess rBwatch_my_tradeszhyperliquid.watch_my_tradess! "66OO V!!!!!!!!!  [[((F 3< 'Kit$X.!##  ++gv..zz#{G[IIIIIIII ? 3OOFE22E00tTTTrCcPK|d{V|t|jdzd}|d|\}}d}|jddd}dd |d d }|||}|||||d{VS) a unWatches information on multiple trades made by the user https://hyperliquid.gitbook.io/hyperliquid-docs/for-developers/api/websocket/subscriptions :param str symbol: unified market symbol of the market orders were made in :param dict [params]: extra parameters specific to the exchange API endpoint :param str [params.user]: user address, will default to self.walletAddress if not provided :returns dict[]: a list of `order structures ` NzR unWatchMyTrades does not support a symbol argument, unWatch from all markets onlyr0zunsubscribe:myTradesr3rr2rrrr)rKrrgrr9rrP)r@rYrSrrrTrFrs rBun_watch_my_tradeszhyperliquid.un_watch_my_tradess!!!!!!!!!  tw)}}~~ ~ "667H&QQ V, it$X.###  ++gv..ZZ[';GGGGGGGGGrCrc ||d}|dkr#||di}||di}|t|}t dt |D]u}||}||} || ddd} | d} |d| ||i| } | |j | <vd } ||d }|| d |zz } | |j | d S||di}| |d g}g}t dt |D]}||}||d}||} || ddd} | d} ||| } | | | |j | <||di}| |dg}| |dg}t dt |D]}||||i|||i}||d}||} || ddd} | d} ||| } | |j | <| | ||d}| |d d S)NrrrImidsrrrYr]rrrT spotAssetCtxsrspotmetauniverse assetCtxsname)rOrNlistkeysrwr`r safe_marketparse_ws_ticker safe_numberrrrQrxrindex_by)r@rrrrIrrr{rrrirYtickerr dexMessager spotAssets parsedTickers assetObjectrrrrrs rBhandle_ws_tickerszhyperliquid.handle_ws_tickersswz""7I66 i  >>'6266D>>$33DDIIKK((q#d)),,22A7D#22488H!--hdFKKF#H-F!11!1!1$!=!=3F,2DL((' !--dE:: )3#33Kt|[999t..&"55^^G_bAA  q#j//** * *A$Q-K##K88D**400H%%hdFCCFH%F))+v>>F   ( ( (#)DL ~~gvr22>>$ B77NN7K<< q#h--(( ) )A;;xB//y!R00D##D&11D**400H%%hdFCCFH%F))$77F#)DL   ( ( ( (-- x88w ***trCric.|||SN) parse_ticker)r@ rawTickerris rBrzhyperliquid.parse_ws_ticker?s  F333rCc||di}|j0||jdd}t ||_|j}i}||dg}t |}|dkrdStdt |D]A} || } || } | d} d|| <| | Bt| } tdt | D]#} d| | z}| ||$d }| ||dS) NrI tradesLimitfillsrrYTz myTrades:r) rNrrr:rrQr`rwparse_ws_traderxrrr)r@rrrrrrrI dataLengthr{rawTradeparsedrYrcurrentMessageHashrs rBhandle_my_tradeszhyperliquid.handle_my_tradesBs`:w33 = %%dlM4HHE2599DM~~eWb11YY ?? Fq#d))$$ " "AAwH((22FH%F"GFO MM& ! ! ! !GLLNN##q#d))$$ 7 7A!,tAw!6  NN6#5 6 6 6 6 v{+++++rCcK|d{V||}|d}d|z}|jddd}dd|d r|d n|d d d }|||} |||| |d{V} |jr| ||}|| ||ddS)aO watches information on multiple trades made in a market https://hyperliquid.gitbook.io/hyperliquid-docs/for-developers/api/websocket/subscriptions :param str symbol: unified market symbol of the market trades were made in :param int [since]: the earliest time in ms to fetch trades for :param int [limit]: the maximum number of trade structures to retrieve :param dict [params]: extra parameters specific to the exchange API endpoint :returns dict[]: a list of `trade structures ` NrYtrade:r3rr2rrrrrgrrrTrKrir9rrPrrfilter_by_since_limit) r@rYrrrSrirrTrFrrs rB watch_tradeszhyperliquid.watch_tradesws!!!!!!!!!V$$!' it$X.! .4VnNz**&,  ++gv..zz#{G[IIIIIIII ? 3OOFE22E))&% TRRRrCc^K|d{V||}|d}d|z}d|z}|jddd}dd |d r|d n|d d d}|||}|||||d{VS)a unWatches information on multiple trades made in a market https://hyperliquid.gitbook.io/hyperliquid-docs/for-developers/api/websocket/subscriptions :param str symbol: unified market symbol of the market trades were made in :param dict [params]: extra parameters specific to the exchange API endpoint :returns dict[]: a list of `trade structures ` NrYrrr3rr2rrrrrgrrrKrir9rrP) r@rYrSrirrrTrFrs rBun_watch_tradeszhyperliquid.un_watch_tradess!!!!!!!!!V$$!!F*$~5 it$X.# .4VnNz**&,  ++gv..ZZ[';GGGGGGGGGrCc~||dg}||di}||d}||}||}|d}||jvr5||jdd} t| } | |j|<|j|} tdt|D]B} ||| } | | }| |Cd|z}| | |dS)NrIrrrYrrr)rQrNrOrrirrr:rrwr`rrxr)r@rrrrorrrirYrstoredrr{rItraders rB handle_tradeszhyperliquid.handle_tradess:"w33ua,,v..&&t,,X&&!$+%%%%dlM4HHE&&F"(DK V$q#e**%% ! !A>>%++D''--E MM% ' v{+++++rCrcP||d}||d}||d}||d}||}||d}|d}||d} ||d} | | dkrd nd } ||d } ||||||| ||d d| d||d| d dd |S)NrrrrrYtidr[AsellbuyfeeoidUSDC)costcurrency) rsrdatetimerYrgrbrZr[ takerOrMakerr]r\rr)rrOrr safe_tradeiso8601) r@rrirr]r\rrrYrgr[rs rBrzhyperliquid.parse_ws_tradesQD%%eV44   --!!%..v..&&t,,!!(D11!   eU + +v..  "ckk66Due,," Y//%%eU33 V44    rC1m timeframecK|d{V||}|d}|jddd}dd|dr|d n|d |d d }d |zdz|z} |||} ||| | | d{V} |jr| ||}|| ||ddS)a watches historical candlestick data containing the open, high, low, close price, and the volume of a market https://hyperliquid.gitbook.io/hyperliquid-docs/for-developers/api/websocket/subscriptions :param str symbol: unified symbol of the market to fetch OHLCV data for :param str timeframe: the length of time each candle represents :param int [since]: timestamp in ms of the earliest candle to fetch :param int [limit]: the maximum amount of candles to fetch :param dict [params]: extra parameters specific to the exchange API endpoint :returns int[][]: A list of candles ordered, open, high, low, close, volume NrYr3rr2rcandlerrrgrZrintervalrcandles:rrTr) r@rYrrrrSrirTrFrrohlcvs rB watch_ohlcvzhyperliquid.watch_ohlcvs!!!!!!!!!!V$$!it$X.! .4VnNz**&,%  !9,s2V; ++gv..jjk7KHHHHHHHH ? 2NN6511E))%q$GGGrCclK|d{V||}|d}|jddd}dd|dr|d n|d |d d }d |zdz|z}d|z}|||} |||| |d{VS)a# watches historical candlestick data containing the open, high, low, close price, and the volume of a market https://hyperliquid.gitbook.io/hyperliquid-docs/for-developers/api/websocket/subscriptions :param str symbol: unified symbol of the market to fetch OHLCV data for :param str timeframe: the length of time each candle represents :param dict [params]: extra parameters specific to the exchange API endpoint :returns int[][]: A list of candles ordered, open, high, low, close, volume NrYr3rr2rrrrrgrrrrrr) r@rYrrSrirTrFr messagehashrs rBun_watch_ohlcvzhyperliquid.un_watch_ohlcv0s!!!!!!!!!V$$!it$X.# .4VnNz**&,%  $i/#5>$~5 ++gv..ZZ[';GGGGGGGGGrCcV||di}||d}||}||}||d}||jvr i|j|<||j|vr;||jdd}t|} | |j||<|j||} ||} | | d|zdz|z} | | | dS)NrIsr{ OHLCVLimitrrr) rNrOr safe_symbolohlcvsrr:r parse_ohlcvrxr) r@rrrIbaserrYrrrrrrs rB handle_ohlcvzhyperliquid.handle_ohlcvLs/$~~gvr22c**&&t,,!!(++$$T3// $+%%"$DK T[000%%dlL$GGE*511F-3DK  * F#I.!!$'' V 9,s2V; uk*****rCrc||d}||d}||d}||d}|||dS)NrIrgrHpayload)rNrOr)r@rrrIrgrHr#s rBhandle_ws_postzhyperliquid.handle_ws_postosl~~gv..   dD ) )>>$ 33..955w#####rCcK|d{Vd}|d|\}}d}d}|%||}|d}|dz|z}|jddd}d d |d d } || |} |||| |d{V} |jr| ||}|| |||d S)a watches information on multiple orders made by the user https://hyperliquid.gitbook.io/hyperliquid-docs/for-developers/api/websocket/subscriptions :param str symbol: unified market symbol of the market orders were made in :param int [since]: the earliest time in ms to fetch orders for :param int [limit]: the maximum number of order structures to retrieve :param dict [params]: extra parameters specific to the exchange API endpoint :param str [params.user]: user address, will default to self.walletAddress if not provided :returns dict[]: a list of `order structures ` Nr&rbrYrr3rr2r orderUpdatesrrT) rKrrir9rrPrrr) r@rYrrrSrrirrTrFrrDs rB watch_orderszhyperliquid.watch_orderss1!!!!!!!!! "66}fMM V  [[((FH%F%+f4Kit$X.!&#  ++gv..zz#{G[IIIIIIII ? 3OOFE22E00tTTTrCcPK|d{V|t|jdzd}|jddd}d}|d|\}}dd |d d }|||}|||||d{VS) a unWatches information on multiple orders made by the user https://hyperliquid.gitbook.io/hyperliquid-docs/for-developers/api/websocket/subscriptions :param str symbol: unified market symbol of the market orders were made in :param dict [params]: extra parameters specific to the exchange API endpoint :param str [params.user]: user address, will default to self.walletAddress if not provided :returns dict[]: a list of `order structures ` NzR unWatchOrders() does not support a symbol argument, unWatch from all markets onlyzunsubscribe:orderr3rr2r1rr&rr)rKrrgr9rrrP)r@rYrSrrTrrFrs rBun_watch_orderszhyperliquid.un_watch_orderss!!!!!!!!!  tw)}}~~ ~) it$X. "66OO V#&#  ++gv..ZZ[';GGGGGGGGGrCc||dg}|j0||jdd}t ||_t |}|dkrdS|j}d}i}t dt |D]O} || } || } || | | d} d|| <Pt| } t dt | D](} | | } |dz| z}| ||)| ||dS) NrI ordersLimitrrrbrYTr) rQrDrr:rr`rwrkrxrOrrr)r@rrrIrrrr marketSymbolsr{rawOrderrbrYrinnerMessageHashs rB handle_orderzhyperliquid.handle_orderse*~~gvr22 ; %%dlM4HHE077DKYY ?? F  q#d))$$ ) )AAwH$$X..E MM% %%eX66F$(M& ! !M&&(())q#d))$$ 5 5A!WF*S069  NN6#3 4 4 4 4v{+++++rCc ||dd}|dkr;||dd}|jdz|z}||dS||di}||d}|||d}||di}||d i} || d } | >| d kr8|jdz|| z}|||dS|| d } | dkr8|jdz|| z} || |dS |d dddi|| | ii n.#t $r!} || |Yd} ~ dSd} ~ wwxYwdS)NrerrorrI TrgrHr#rtokrZrF)rOrgrejectrNjson handle_errors Exception)r@rrrret_msgerrorMsgrIrgrHr#rtrZr2es rBhandle_error_messagez hyperliquid.handle_error_messages<""7Ir:: g  &&w;;Gw}w.H MM( # # #4~~gvr22   gt , , :!!$--B>>$ B77..9b99!!'844  &D..w}tyy'9'99H MM(B ' ' '400 7??GcMDIIg$6$66E MM% $ $ $4    q"b"b$))G2D2DgrSU V V V V    MM!R 44444 us70F(( G2GGrc||d}||}||}d|z}d|z}||||||jvr |j|=dSdS)Nrrr)rOrrclean_unsubscriptionrr@rrrrrYrrs rB handle_order_book_unsubscriptionz,hyperliquid.handle_order_book_unsubscription&s f55&&t,,!!(++%.$~5  !!&.+FFF T_ $ $''' % $rCc||d}||}||}d|z}d|z}||||||jvr |j|=dSdS)Nrrr)rOrrr>rr?s rBhandle_trades_unsubscriptionz(hyperliquid.handle_trades_unsubscription8s f55&&t,,!!(++!F*$~5  !!&.+FFF T[  F### ! rCcd}d|z}||||t|j}t dt |D]}|j||=dS)Nrrr)r>rrrrwr`)r@rrrrrr{s rBhandle_tickers_unsubscriptionz)hyperliquid.handle_tickers_unsubscriptionCs~"$~5  !!&.+FFFt|((**++q#g,,'' ) )A WQZ(( ) )rCc~||d}||}||}||d}||}d|zdz|z}d|z} |||| ||jvr||j|vr|j||=dSdSdS)Nrrrrr)rOrrfind_timeframer>r) r@rrrrrYrrrrs rBhandle_ohlcv_unsubscriptionz'hyperliquid.handle_ohlcv_unsubscriptionLs f55&&t,,!!(++##L*==''11 #i/#5>$~5  !!&.+FFF T[ DK///K' 222 ! //rCcvd}d|z}||||dddi}||dS)NrbrTtopicrDr> clean_cacher@rrsubHash unSubHashtopicStructures rBhandle_order_unsubscriptionz'hyperliquid.handle_order_unsubscriptionYsS"W,  !!&'9dCCC X  (((((rCcvd}d|z}||||dddi}||dS)NrrTrIrJrLs rBhandle_my_trades_unsubscriptionz+hyperliquid.handle_my_trades_unsubscriptionbsS"W,  !!&'9dCCC Z  (((((rCc2||di}||d}|dkr||di}||d}|dkr|||dS|dkr|||dS|dkr|||dS|d kr|||dS|d kr|||dS|d kr|||dSdSdS) NrIrrrrZrrrrr&r)rNrOr@rBrDrGrPrR)r@rrrIrrrZs rBhandle_subscription_responsez(hyperliquid.handle_subscription_responseks]2~~gvr22!!$11 ] " ">>$CCL##L&99Dx55flKKKKK!!11&,GGGGG##226<HHHHH!!00FFFFF''00FFFFF$$44V\JJJJJ # "%$rCc ,|||rdS||dd}|j|j|j|j|j|j|j|j|j |j d }| ||}||||dSt| }tdt|D]@}||}|||dkr||} | ||dSAdS)Nrr1) pongrrrr&rrrpostsubscriptionResponser)r<rO handle_pongrrr!r/rrr$rT safe_valuerrrwr`find) r@rrrImethods exacMethodrr{keyrs rBhandle_messagezhyperliquid.handle_messages;  $ $VW 5 5  F  )R88$(,' -..-'$($E   __We44  ! Jvw ' ' ' FGLLNN##q#d))$$  Aq'Czz$q'""a'' vw'''(  rCc ddiS)Nrr5)r@rs rBr5zhyperliquid.pings f  rCcb||d||_|S)NrV)r millisecondslastPong)r@rrs rBrYzhyperliquid.handle_pongs. ++GVT=N=N=P=PQQrCcz|||jddd}||jd<|S)NrGrr)sumrr:)r@rGs rB request_idzhyperliquid.request_ids;HHT..t|[!LLaPP $- [!rCrFcB|}|d|d|dddS)NrWaction)rZr#)rrgrF)rGrF)rg)r@rFrGs rBrMzhyperliquid.wrap_as_post_actionsCOO%% " $&   rCr)B__name__ __module__ __qualname__rr?rr rXrrrfloatr rfrprr|r~rr rrrrrrrrrrrrrrr rrrrrdictrrrrr!r$r r'r)r/rr<r@rBrDrGrPrRrTr_r5rYrgrM __classcell__)rAs@rBrrs^2 #2 2 2 2 2 2 hIK11T,-?1111,pt|~Cy [`il>]aos|~$$c$3$c$$VY$il$$$$LDHPR$s)SB<@)))S)))) @DB!!S!!S\!!!!6=?HHH3HHHH8,/,/,/\68F(6:"((7(((((T9=R]]g]C]]]]637TX\eg U UC Us URU Ulpqvlw U U U UD6:"HHsHHHHH8qqqqqf444644443,v3,3,3,3,j<@d[]SSSSSSbfglbmSSSS<9;HHCHsHHHH4!,F!,!,!,!,F<<D<&<E<<<<|?CQUdhqsHHHH3H^aHx|~ByCHHHH@BFbHH3H3HUXHHHH8!+6!+!+!+!+F$V$d$$$$ 04$UYbd"U"U"UC"Us"Uimnsit"U"U"U"UH37rHHCHcHHHH8*,6*,*,*,*,X969t9999v(v(T(((($ $6 $ $ $ $ $)F)$)))) 3& 3 3 3 3 3)&))))))f)D)))))K6)K)K)K)KV(V((((T 6    &E  4  D         rCr)ccxt.async_supportccxt ccxt.async_support.base.ws.cacherrrccxt.base.typesrrrr r r r r rrrrrrr!ccxt.async_support.base.ws.clientrtypingrccxt.base.errorsr async_supportrrarCrBrxsw ffffffffffTTTTTTTTTTTTTTTTTTTTTTTTTTTTTTTTTT444444))))))Q Q Q Q Q $$0Q Q Q Q Q rC