E#iSSKrSSKJrJrJrJr SSKrSSKJ r J r J r J r J r JrJrJrJrJrJrJr SSKJr SSKJr SSKJr SSKJr SSKJr SS KJr SS KJr SS KJr SS KJ r SS KJ!r! "SS\RDRF5r#g)N) ArrayCacheArrayCacheBySymbolByIdArrayCacheBySymbolBySideArrayCacheByTimestamp) AnyBalancesBoolIntMarketOrder OrderBookPositionStrStringsTickerTrade)Client)List) ExchangeError)AuthenticationError)ArgumentsRequired) BadRequest) BadSymbol) NetworkError) InvalidNonce) ChecksumErrorc f^\rSrSrS\4U4SjjrSr04S\S\4Sjjr 04S\S\4Sjjr S\ 4S jr S S 04S\S \ S \ S\\4S jjr04S\S\4SjjrS\ 4SjrSS S 04S\S\S \ S \ S\\4 SjjrS04S\S\S\4SjjrS\ 4SjrS 04S\S \ S\4Sjjr04S\S\4SjjrS\ 4SjrSrSrSrS\ 4SjrS\ 4SjrS\ 4Sjr S S S 04S\!S \ S \ S\\4Sjjr"S 04Sjr#S S S 04S\!S \ S \ S\\$4S jjr%S\ 4S!jr&S>S"jr'S>S#jr(S S S 04S$\)S \ S \ S\\*4S%jjr+S&r,04S\-4S'jjr.S\ 4S(jr/S\ 4S)jr0S\ S*\14S+jr2S\ 4S,jr3S\ 4S-jr4S.r5S\ 4S/jr6S\ 4S0jr7S\ S\84S1jr9S\ 4S2jr:04S\ 4S3jjr;S>S4jr04S7\?S8\S9\4S:jjr@004S;jrA04S<jrBS=rCU=rD$)@htxreturnc>UR[[U]50SS_SS_SS_SS_SS_SS_S S_S S_S S_S S_S S_SS_SS_SS_SS_SS_SS_SSSSSSS.ESSSSSS.SSS.SSS.S.S S!S.SSS.S".S#.S$S%SS.S&S'S.S(S)S.S.S&S'S.S*S+S.S.S#.S,.00S-S-SS.SS/S0.S1S0S2S30S4.SS5[[ [[ [ [[S6.00S7.5$)8NwsT createOrderWsF editOrderWsfetchOpenOrdersWs fetchOrderWs cancelOrderWscancelOrdersWscancelAllOrdersWs fetchTradesWsfetchBalanceWswatchOrderBook watchOrders watchTickers watchTicker watchTradeswatchTradesForSymbols watchMyTrades) watchBalance watchOHLCV unwatchTicker unwatchOHLCV unwatchTradesunwatchOrderBookapizwss://{hostname}/wszwss://{hostname}/ws/v2zwss://{hostname}/feed)publicprivatefeedz!wss://api.hbdm.com/linear-swap-wsz+wss://api.hbdm.com/linear-swap-notification)r:r;zwss://api.hbdm.com/wszwss://api.hbdm.com/notification)linearinversezwss://api.hbdm.com/swap-wsz$wss://api.hbdm.com/swap-notification)r>r=)spotfutureswapzwss://api-aws.huobi.pro/wszwss://api-aws.huobi.pro/ws/v2z wss://api.hbdm.vn/linear-swap-wsz*wss://api.hbdm.vn/linear-swap-notificationzwss://api.hbdm.vn/wszwss://api.hbdm.vn/notificationzwss://api.hbdm.vn/swap-wsz#wss://api.hbdm.vn/swap-notification)r9zapi-aws) maxRetrieschecksumdepthgunzipnamemarket.{marketId}.detail) tradesLimit OHLCVLimitr9r,r"r/exact)z bad-request200220212001201120404007)hasurlsoptions exceptions) deep_extendsuperrdescriberrr)self __class__s F/home/james-whalen/.local/lib/python3.13/site-packages/ccxt/pro/htx.pyrZ htx.describes<c4 9 ;du$U      !%$U !%!$ttt (!" #$!%"!% $!%$(/4+@+C(?%/R/\+" /F/P," '/K/U," /R/\+" %! <+G+J(?%/Q/[+" /E/O," '/Q/[+" /J/T," %!$;8:<| $""# $ # d6 "'1 3 * ) ) * *  Ot> t t cURURURSS5S5nXRS'[U5$)N requestIdr)sum safe_integerrVstr)r[ras r] request_idhtx.request_ids;HHT..t||[!LaP $- [!9~r_symbolc# UR5IShvN URU5nUSnURURS05nUR USS5nUS:Xa!USS:wa[ UR S -5eURUS US 05nURUSUS 5nURXqUSU5IShvN $NN7f) a watches a price ticker, a statistical calculation with the information calculated over the past 24 hours for a specific market https://www.htx.com/en-us/opend/newApiPages/?id=7ec53561-7773-11ed-9966-0242ac110003 https://www.htx.com/en-us/opend/newApiPages/?id=28c33ab2-77ae-11ed-9966-0242ac110003 :param str symbol: unified symbol of the market to fetch the ticker for :param dict [params]: extra parameters specific to the exchange API endpoint :returns dict: a `ticker structure ` Nrhr/rIrJmarket.{marketId}.tickertyper?x watchTicker() with name market.{marketId}.ticker is only allowed for spot markets, use market.{marketId}.detail insteadmarketIdidr=) load_marketsmarket safe_dictrV safe_stringrrnimplode_paramsget_url_by_market_typesubscribe_public)r[rhparamsrprVtopic messageHashurls r] watch_tickerhtx.watch_tickers!!!V$!..}bA  &2LM . .6&>V3KTWW(bbc c))%*fTl1KL ))&.&:JK**3 T6RRR "Ss"CCB7CCCCcx# UR5IShvN URU5nSnURURS05nUR USS5nUS:Xa!USS:wa[ UR S -5eURUS US 05nURX7XB5IShvN $NN7f) a# unWatches a price ticker, a statistical calculation with the information calculated over the past 24 hours for all markets of a specific list https://www.htx.com/en-us/opend/newApiPages/?id=7ec53561-7773-11ed-9966-0242ac110003 https://www.htx.com/en-us/opend/newApiPages/?id=28c33ab2-77ae-11ed-9966-0242ac110003 :param str symbol: unified symbol of the market to fetch the ticker for :param dict [params]: extra parameters specific to the exchange API endpoint :returns dict: a `ticker structure ` Ntickerr/rIrJrjrkr?rlrmrn) rorprqrVrrrrnrsunsubscribe_publicr[rhrvrprwrVchannelsubMessageHashs r]un_watch_tickerhtx.un_watch_tickers!!!V$..}bA""7F4NO 0 0VF^v5MTWW(bbc c,,Wz6$<6PQ,,VUSSS "Ts"B:B6BB:1B82B:8B:clientcvURUS05nURUS5nURS5nURUS5nURU5nUR X75nURUS5n XS'UR U 5US'USn XR U 'URX5 U$) Ntickch.rbts timestampdatetimerh) safe_valuerrsplit safe_market parse_tickeriso8601tickersresolve) r[rmessagerrpartsrmrpr}rrhs r] handle_tickerhtx.handle_tickersBw3   gt , ##E1-!!(+""40OOGT2 '{!\\)4z!% Vv"r_NsincelimitcX# UR5IShvN URU5nUSnSUS-S-nURUSUS5nURXqUSU5IShvN nUR(aUR X5nUR XUSS 5$NN<7f) a get the list of most recent trades for a particular symbol https://www.htx.com/en-us/opend/newApiPages/?id=7ec53b69-7773-11ed-9966-0242ac110003 https://www.htx.com/en-us/opend/newApiPages/?id=28c33c21-77ae-11ed-9966-0242ac110003 https://www.htx.com/en-us/opend/newApiPages/?id=28c33cfe-77ae-11ed-9966-0242ac110003 :param str symbol: unified symbol of the market to fetch trades for :param int [since]: timestamp in ms of the earliest trade to fetch :param int [limit]: the maximum amount of trades to fetch :param dict [params]: extra parameters specific to the exchange API endpoint :returns dict[]: a list of `trade structures ` Nrhmarket.rnz .trade.detailrkr=rT)rorprtru newUpdatesgetLimitfilter_by_since_limit) r[rhrrrvrprxrytradess r] watch_tradeshtx.watch_tradess!!!V$!&,.@ ))&.&:JK,,S+tVTT ??OOF2E))& TRR " Us"B*B&AB*+B(,;B*(B*c*# UR5IShvN URU5nSnURURS05nUR USS5nUR USUS05nUR X7XB5IShvN $NxN7f)ax unWatches a price ticker, a statistical calculation with the information calculated over the past 24 hours for all markets of a specific list https://www.htx.com/en-us/opend/newApiPages/?id=7ec53b69-7773-11ed-9966-0242ac110003 https://www.htx.com/en-us/opend/newApiPages/?id=28c33c21-77ae-11ed-9966-0242ac110003 https://www.htx.com/en-us/opend/newApiPages/?id=28c33cfe-77ae-11ed-9966-0242ac110003 :param str symbol: unified symbol of the market to fetch the ticker for :param dict [params]: extra parameters specific to the exchange API endpoint :returns dict: a `ticker structure ` Nrr0rIzmarket.{marketId}.trade.detailrmrn)rorprqrVrrrsr~rs r]un_watch_tradeshtx.un_watch_tradess!!!V$..}bA""7F4TU,,Wz6$<6PQ,,VUSSS " Ts"BBA3B B BBc6URUS05nURUS05nURUS5nURS5nURUS5nURU5nUSn URURU 5n U c6UR UR SS5n [U 5n XRU '[S [U55H(n URXLU5n U RU 5 M* URX5 U$) NrdatarrrbrhrKrBr) rrrrrrrdrVrrangelen parse_tradeappendr)r[rrrrrrrmrprh tradesCacheritrades r] handle_tradeshtx.handle_tradess*w3tVR0   gt , ##E1-!!(+!oodkk6:  %%dllM4HE$U+K"-KK q#d)$A$$TWf5E   u %% {'r_1m timeframec# UR5IShvN URU5nUSnURURX"5nSUS-S-U-nUR USUS5n UR XUSU5IShvN n UR (aU RX5nURXUSS 5$NN<7f) a watches historical candlestick data containing the open, high, low, and close price, and the volume of a market https://www.htx.com/en-us/opend/newApiPages/?id=7ec53241-7773-11ed-9966-0242ac110003 https://www.htx.com/en-us/opend/newApiPages/?id=28c3346a-77ae-11ed-9966-0242ac110003 https://www.htx.com/en-us/opend/newApiPages/?id=28c33563-77ae-11ed-9966-0242ac110003 :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 Nrhrrn.kline.rkr=rT) rorprr timeframesrtrurrr) r[rhrrrrvrpintervalrxryohlcvs r] watch_ohlcvhtx.watch_ohlcvAs!!!V$!##DOOYJ&,.:XE ))&.&:JK++CdFSS ??NN61E))%q$GG " Ts"C CA3C  C ;C C c# UR5IShvN URU5nURURX"5nSUS-S-U-nSnUSU//US'UR XFXs5IShvN $NfN7f)a unWatches historical candlestick data containing the open, high, low, and close price, and the volume of a market https://www.htx.com/en-us/opend/newApiPages/?id=7ec53241-7773-11ed-9966-0242ac110003 https://www.htx.com/en-us/opend/newApiPages/?id=28c3346a-77ae-11ed-9966-0242ac110003 https://www.htx.com/en-us/opend/newApiPages/?id=28c33563-77ae-11ed-9966-0242ac110003 :param str symbol: unified symbol of the market :param str timeframe: the length of time each candle represents :param dict [params]: extra parameters specific to the exchange API endpoint :param dict [params.timezone]: if provided, kline intervals are interpreted in that timezone instead of UTC, example '+08:00' :returns int[][]: A list of candles ordered, open, high, low, close, volume NrrnrrrhsymbolsAndTimeframes)rorprrrr~)r[rhrrvrprrrws r]un_watch_ohlcvhtx.un_watch_ohlcv[s!!!V$##DOOYJ"VD\1I=H+1(+;Y*G)H%&,,VUSSS " Ts"BA=A!B8A?9B?BctURUS5nURS5nURUS5nURU5nUSnURUS5nURU5n UR UR U05UR U'UR UR UU 5n U c9UR URSS5n [U 5n XR UU 'UR US5n URX5n U RU 5 URX5 g) NrrrbrhrCrLrBr) rrrrfind_timeframerohlcvsrdrVr parse_ohlcvrr)r[rrrrrmrprhrrstoredrrparseds r] handle_ohlcvhtx.handle_ohlcvqs"  gt , ##E1-!!(+!##E1-''1 "oodkk62F FV!4i@ >%%dllL$GE*51F-3KK  *w/!!$/ fv"r_c# UR5IShvN URU5nUSn/SQnURURS05nUcUR USS5nUR X%5(d[ URS-5eSnUS(aS US -S -URU5-nO S US -S -URU5-S -nURUSUSSS5nURn US(dURU5nSUS'Sn URXXyU5IShvN n U R5$GN=N7f)a https://huobiapi.github.io/docs/dm/v1/en/#subscribe-market-depth-data https://huobiapi.github.io/docs/coin_margined_swap/v1/en/#subscribe-incremental-market-depth-data https://huobiapi.github.io/docs/usdt_swap/v1/en/#general-subscribe-incremental-market-depth-data watches information on open orders with bid(buy) and ask(sell) prices, volumes and other data :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 Nrh)rDir,rGrDz? watchOrderBook market accepts limits of 5, 20, 150 or 400 onlyr?rrn.mbp. .depth.size_ .high_freqrkr=FT incremental data_type)rorprqrVrdin_arrayrrnnumber_to_stringrthandle_order_book_subscriptionextendrur) r[rhrrvrp allowedLimitsrVrxrymethod orderbooks r]watch_order_bookhtx.watch_order_bookse!!!V$!) ../?D =%%gw#fTl2WE?EEc# UR5IShvN URU5nSnURURS05nUR USS5nSnUS(aSUS-S -UR U5-nO SUS-S -UR U5-S -nUS(dS US 'UR X7XB5IShvN $NN7f)a unsubscribe from the orderbook channel https://huobiapi.github.io/docs/dm/v1/en/#subscribe-market-depth-data https://huobiapi.github.io/docs/coin_margined_swap/v1/en/#subscribe-incremental-market-depth-data https://huobiapi.github.io/docs/usdt_swap/v1/en/#general-subscribe-incremental-market-depth-data :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 :param int [params.limit]: orderbook limit, default is None :returns dict: A dictionary of `order book structures ` indexed by market symbols Nrr,rGrDr?rrnrrrrr)rorprqrVrdrr~)r[rhrvrprwrVrGrs r]un_watch_order_bookhtx.un_watch_order_books!!!V$../?D!!'7C8 &>&5?$BWBWX]B^^N&5FI^I^_dIeehttNv"/F; ,,VUSSS "Ts"CCB5C C CCc.URUS5nURUS5nURUS5nURUS5nURUnURUS5n URn URU S05n UR X5n URU S5n URU S5nURU S 5nXS 'URUS 5nUUS'URUS 5nUR U U5nURUU5 UbX:aURS SS5nURUSS5nUU:aiXQR;aYURUS5nURSUU- 5nUUS'X1RU'URUURXU5 gg[URS-U-S-[U5-S-5eUR!U 5 [#S[%U 55HnUR'XU5 M /UlXRU'URX5 g![(a6nURU URU UR+UU5 SnAgSnAff=f)Nrhrxrn lastTimestamprrr prevSeqNumseqNumnoncerrr,rErC numAttemptsrbrBzC failed to synchronize WebSocket feed with the snapshot for symbol z in z attempts)rrrd orderbooksrcacheparse_order_book order_bookr handle_option subscriptionsrcdelaywatch_order_book_snapshotrrnreresetrrhandle_order_book_message Exceptionreject)r[rr subscriptionrhrxrnrrrmessages firstMessagesnapshotrsequencersnapshotTimestamp snapshotLimitsnapshotOrderBook maxAttemptsr delayTimeres r]handle_order_book_snapshothtx.handle_order_book_snapshots,!!,9&&|]C   gt ,)),H ) */I??7F3D H??8Q;L,,T:H??<8D((| $(HHT=CT3T$U 6A ]3s.q)*u%r_cd[S[U55HnURXU5 M g)Nr)rrr)r[rdeltasrs r] handle_deltashtx.handle_deltasCs)q#f+&A   hq 2'r_cURUS5nURS5nURUS5nURU5nUSnURUnURUS05n UR U S5n UR U S5n URU S5n UR U S 5n UR US 5nU S :Xa'UR XU5nURU5 XS 'U bLXS :aDURS SS5nU(a*[URS-URU5-5eUS=(a XS :HnUS=(a U S- US :HnU(dU(awURU S/5nURU S/5nURUSU5 URUSU5 U(aU OU US 'XS'URU5US'gg)Nrrrbrhrrreventversionrrrr,rFT r?contractasksbidsrr)rrrrrrrdrrrrrnorderbook_checksum_messager r)r[rrrrrmrprhrrrrr r rrrF spotConditonnonSpotConditionrrs r]rhtx.handle_order_book_messageGsF__Wd + ##E1-!!(+!OOF+ w3""42&&t\:   w/##D)4%%gt4 J ,,T9EH OOH %!(g   " w5G(G))*:JMH#DGGcMD4S4STZ4[$[\\f~L:79K+K !*-U7Q;)GBT3T +??44D??44D   y0$ 7   y0$ 7+7WIg %.k "$(LL$;Ij !,r_cnURUS5nURUS5nURUS5nURUS5nURS5nURUS5nURU5n XR;aTURUS5n U RS5n UR U S5n UR 0U 5URU 'URU n Uc"U ScU RRU5 gURX5 URX5 g) Nrrr rrbrC_r) rrrqr safe_symbolrrdrrrrr)r[rrrxrr rrrmrhsize sizePartsrrs r]handle_order_bookhtx.handle_order_books\&&w5 ~~gv.  w/   gt , ##E1-!!(+//)##E1-D 3I%%i3E&*oob%&@DOOF #OOF+ M ' 2 : OO " "7 +  * *6 ; NN9 2r_cURUS5nURU5nURUS5nUR0U5URU'US(aUR UR XU5 gg)Nrhrr?)rrrprdrrspawnr)r[rrrrhrprs r]r"htx.handle_order_book_subscriptionso!!,9V$!!,8"&//"e"< &> JJt55v U r_c# UR5 UR5IShvN SnSnSnSnSn Sn Sn Ub/URU5nUSnUSnUS(aSOSn USnOuURURSS 5nURUSU5nUR URS S S5n URUS U 5n UR USS /5nUS :XaVSn U cCUR URS S S5n URUS U 5n UR US 5nSU-S-U -nUn O>URX[Xt5n URU S5n URU S5nUS-S-nURXX[U5IShvN n UR(aU RX5nURXX#S5$GNN<7f)a  watches information on multiple trades made by the user https://www.htx.com/en-us/opend/newApiPages/?id=7ec53dd5-7773-11ed-9966-0242ac110003 :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 ` N*rhrkr=r> lowercaseId defaultTyper?subTypedefaultSubTyper2mode0ztrade.clearing##rrb:rT) check_required_credentialsrorprrrV safe_string_2omit"get_order_channel_and_message_hashsubscribe_privaterrfilter_by_symbol_since_limit)r[rhrrrvrkrmrprxrrr$r&channelAndMessageHashorderMessageHashs r]watch_my_tradeshtx.watch_my_tradess '')!!!   [[(FH%F&>D"("2h Gm,H##DLL-HD##FFD9D((yBRT\]G&&vy'BGYYv ':;F 6>D|))$,,QTU''=66208;cADHK!G$($K$KD[a$j !&&'URUSS5n U S:XaU S-OU n U nUb US U-- nUnXe/$U S -S -nXe/$US :Xa*U bU S -U R5-nUnXe/$U S -S -nXe/$Ub U S -U-nUnXe/$U S -S -nXe/$) N orderTypeordersr"baseIdr=margincross_crossrr!r@)rrrVr,lower) r[rkr$rprvrxrr5 marketCoder7prefix marginMode marginPrefixs r]r-&htx.get_order_channel_and_message_hash's $$T\\;I $$V[)D 6;/7=7IVM*002PT &,&8!t h ))&(GDJ1;w1F6H,VL&K%sZ// %"%%',s2%%X ! 3,7% %%!3,,%% % 3,3% %%!3,,%%r_c# UR5IShvN SnSnSnSnUb/URU5nUSnUSnUSnUS(aSOSnOuURURSS 5nURUSU5nUR URS S S5nURUS U5nUR USS /5nSn Sn US :XaS U-n U n O6UR XVXt5n URU S 5n URU S5n URXXVU5IShvN n UR(aU RX5nURXUSS5$GNMN=7f)a  watches information on multiple orders made by the user https://www.htx.com/en-us/opend/newApiPages/?id=7ec53c8f-7773-11ed-9966-0242ac110003 :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 :returns dict[]: a list of `order structures ` Nr!rhrkr"r=r>r#r?r$r%zorders#rrbrT) rorprrrVr+r,r-r.rrr) r[rhrrrvrkr$rpsuffixrxrr0r6s r] watch_ordershtx.watch_ordersKs!!!  [[(FH%F&>DM*F"("2h G##DLL-HD##FFD9D((yBRT\]G&&vy'BGYYv ':;F  6>(61K!G$($K$KD[a$j !&&'K"=Iy>La'%&& "--k4@ ,,[&A ,,[&A+!$$V\;LM ;; %%dllM4HE07DK{{ K(t{{K0)00vm7L1LbQ00B/77o8MrRt{{$67r_c<URUSS5nURUS5nURUSS5nURXR5nUR XR5nURUSS5nUR URUSS 55nURUS S 5n URUS S 5n URUSS5n UR US5n UR US5n UR US5nSnUb&UR US5nUURU5S.nUR US5nURUS5n/nU bU RS5nURUS5nUcUR US5nURUS5nUcUR US5nUR US5nUR0SU_SU _S U _SU_S URU5_S!U_S U_SU_SU_S"S_S#S_S$U_SU _S%U_S&U _S'S_S(U_UUUS).EU5$)*N lastActTimerorderCreateTimerFrhrOvolumerIrJr`order_id clientOrderIdclient_order_idrNrrLrkfee fee_assetcostcurrencytrade_avg_pricer-rborder_price_typer direction orderValuerRrnrrlastTradeTimestamp timeInForcepostOnlyrSrrPrQrt)rqaverager) safe_integer_2rdr+rrrWrrsafe_currency_coderrr] safe_orderr)r[rHrpr{createdrmrhrrJrnrorrPtypeSidefeeCostrq feeCurrencyIdavgPricera typeSidePartsrkrSrts r]rZhtx.parse_ws_order3sd"00 tL##E+<=%%e_hG!!(3!!(3##E;A((););E=RZ)[\   y* =**5/CTU ""5,@!!%3##E62""5%0   ,,UK@M 33MBC##E+<=OOE73   $NN3/M%%mQ7 <##E+=>D%%mQ7 <##E;7D|4 E "  ]     W-  !"4   f  f  D  4    D  U  f  f ! " D# $) * + r_cURSU5nUSnURUS5nURUS5nURUS5nURUS5nURUS5nURUS5n Sn U bU RS5n U S n U S n UR US 5n Sn U b U (aS OS n UR UUUR U5UUUU U U UUSSS. U5$)NrhtradeId tradePrice tradeVolumer` tradeTimerkrwrrb aggressortakermaker rRrrrhrnrHrk takerOrMakerrSrrrtrq)rrrrdrr safe_trader)r[rrprhrrrrHrrkrS typePartsrrs r]rVhtx.parse_order_trades%*!!$/!""5)4   5!!%7   2%%e[9 v.   3IQ7f)a https://www.huobi.com/en-in/opend/newApiPages/?id=8cb7de1c-77b5-11ed-9966-0242ac110003 https://www.huobi.com/en-in/opend/newApiPages/?id=8cb7df0f-77b5-11ed-9966-0242ac110003 https://www.huobi.com/en-in/opend/newApiPages/?id=28c34a7d-77ae-11ed-9966-0242ac110003 https://www.huobi.com/en-in/opend/newApiPages/?id=5d5156b5-77b6-11ed-9966-0242ac110003 watch all open positions. Note: huobi has one channel for each marginMode and type :param str[]|None symbols: list of unified market symbols @param since @param limit :param dict params: extra parameters specific to the exchange API endpoint :returns dict[]: a list of `position structure ` NrU::,rkr=r>watchPositionsr?r@r$r9T :positionszpositions_cross.*z positions.*F) rois_emptyget_market_from_symbolsjoinhandle_market_type_and_paramshandle_option_and_paramsmarket_symbolshandle_margin_mode_and_paramsrtr.rfilter_by_symbols_since_limit positions)r[rrrrvrprxrkr$r>isLinearryr newPositionss r]watch_positionshtx.watch_positionssz!!! }}W%%11':F'!22K  &>D"("2h G==>NPV_LDv~";;FDTV_ahiOG%%g. !??@PRXZab x'))$$? </+= *4*?%m!33G$Y_`` ?? 11$..2Ej2QSZchjopp5 ".as"EE C7EE clientPositionsclientMarginModePositionsr rawPositionsrrr rawPositionposition messageHashesrxr symbolsStringrrs r]handle_positionshtx.handle_positions=sHjj  '26!&*;!;W* >> !DN//$..#>  ""$DNN3 $(OOO$P! $ ,.F.HDNN3  +s#J/w;  %%gt4 q#l+,A&/K**;7H$-[ !#'<< #:HZ    ) LL " -00n9TU q#m,-A'*K%%d+E!!HM#))#.G,,\8WeTI==++y+6. |,%>?r_c# SnURSSU5up!SnURSSUS5up1URUSSS5nURUSS/5nUR 5IShvN SnSnSnUS:Xa:UR UR SSS 5nURUSU5nS U-nUnGOURUS 5n URUS 5n U bURU 5OSn U bURU 5OSn URUS S5nURU/SQ5nSn U nUS:Xa]U(a Sn U nU S-S-nOUS:XaU S-OU n U nUS:XaU bUSU S-- nUnO\U S-S-nOSU bU S-U S-nUnOBU S-S-nO9US:XaU bUSU S-- nUnO"U S-S-nOU bUSU S-- nUnOU S-S-nUUUS.nURXeX#X5IShvN $GNN7f)aS watch balance and get the amount of funds available for trading or funds locked in orders https://www.htx.com/en-us/opend/newApiPages/?id=7ec52e28-7773-11ed-9966-0242ac110003 https://www.htx.com/en-us/opend/newApiPages/?id=10000084-77b7-11ed-9966-0242ac110003 https://www.htx.com/en-us/opend/newApiPages/?id=8cb7dcca-77b5-11ed-9966-0242ac110003 https://www.htx.com/en-us/opend/newApiPages/?id=28c34995-77ae-11ed-9966-0242ac110003 :param dict [params]: extra parameters specific to the exchange API endpoint :returns dict: a `balance structure ` Nr3r=isUnifiedAccountunifiedFr?r&2zaccounts.update#rhrur8r9)rurhr8accountsaccounts_unifyrusdtr:rrnr!r@)rkr$r8) rhandle_sub_type_and_params safe_value_2r,ror+rVrrrprur.)r[rvrkr$rrxrr>r&rhrurp currencyCoder=subscriptionParamss r] watch_balancehtx.watch_balances99.$PVW 99.$PVX`a,,V5GTYZ6$6 #BC!!!  6>%%dllNFCPD##FFD9D1D8K!G%%fh7F'' ;H-3-?T[[(dF7?7K4==2RVL))&(GDJYYv'GHFF K("#-F"(K$slV3G4>3HVh.vF"(K!Z/!-'3+==K&1G'-slS&8G(3&,sl\$5G&GG*1K'-slS&8G!+3d);#;;K)G%slS0G%3#55K)G%slS0G $ ++G$QWlllK "Jms%A+G5-G0.E=G5+G3,G53G5c URUS5nURUS/5nURUSURUS55nXPRS'UR U5URS'X@RS'UbURUS5nUR U5nUR 5nURUS 5US 'URUS 5US 'XRU'URUR5UlURURU5 g[U5n U S :XagURUS 05n URUS5n U RS5n URU S 5n URURXS-5nUcEURU SS5nU SUR5-- n URURU 5nURUS5nURUS5nU S:XaURU S5nUR U5nURU S5nUR 5nURU S5US 'UUS'UURU'URUR5UlURURS5 GOUS:XGaURUS5nUS:XGaUS:XaSOSnURU U/5n[U5nUS :a[S [U55HnUUnURUSS 5nUR!U5nURUS5nUR#U5nURUS!US"5nUcMjUR 5nURUS#S$5US 'URUS5US'0nUUU'USnURU5URU'M GO[[S [U55HnUUnUR 5nURUS#S$5US 'URUS5US'URUSS5nUR U5nXRU'URUR5UlM O[S [U55HnUUnURUS5nUR U5nUR 5nURUS$5US 'URUS5US'XRU'URUR5UlM URURU 5 g)%Nrr changeTimerrrrRru availablefreebalancetotalrrwrz.* margin_assetrhrkr$r margin_frozenwithdraw_availableusedr=r8r9r@futures_contract_detailcontract_detailrFmargin_accountsettlecodemargin_balancemargin_available)rrrrdrrraccount safe_balancerrrrrr+r;rr safe_currency) r[rrrrr currencyIdrr dataLengthfirstrw splitTopicrxrrkr$ marginAsset marginFrozenunifiedAccountr8 fieldNamebalancesbalancesLengthrrrmrpruaccountsByCoderhisolatedBalances r]handle_balancehtx.handle_balances1f""7D1w3%%dL$:K:KGUY:Z[ $- [!#'<< #: Z # V  ))$ ;J**:6DllnG"..t[AGFO#//i@GG !(LL ,,T\\:DL NN4<< 1TJQOOD!R0E$$Wg6ES)J**:q9K,,V-A-A;^bPbcL# "//~xP sZ%5%5%777 #v/C/C[Q ##L&9D&&|Y?G((#..unE ..{;#//G !%)-)9)9%AU)Vv&)5v&%3 T"#00> t||-=>H$)),AW$>Bh>N 9UfI#uiDH%(]N%)!&q#h-!8A&.qkG'+'9'9'?Td'eH%)%5%5h%?F)-)9)9'>)RJ'+'9'9*'EH#'#3#3FHhvFV#WD $/*.,,.262D2DWN^`r2s262B2B7O2\797>t 4)/)97;7H7H7X V 4#"9(#1c$i0*.q'"&,,.*.*:*:?L\^p*q*.*:*:?O*\%)%7%7Ya%b #66zB-4 T*'+'8'8'F 1q#d),A"1gG!%!1!1'8!DJ22:>D"llnG&*&6&6w@R&SGFO&*&6&6w&PGFO)0LL&#'#4#4T\\#BDL- NN4<< 5r_c,URUS5nURURS5nURXC5nUb:UR US5nUb U"XU5 X1R;a URU SU;aUR X5 gg)Nrnrunsubbed)rrindex_byrrqrhandle_un_subscription)r[rrrnsubscriptionsByIdrrs r]handle_subscription_statushtx.handle_subscription_statuss"  gt , MM&*>*>E~~&7<  #__\8>,8JBOq#m,-A%(I&)G  % %fy A. &r_cU$Nr[rrs r]handle_system_statushtx.handle_system_statuss r_cURUSS5nURS5nURUS5nUS:XaURUS5nURURURURURUR UR S.nURXv5nUb U"X5 gURS5n URU SS5n U S :XaURX5 gU RS 5S:aURX5 gU S :XaURX5 gURUS 5n U S :XaURUSS5n U RS 5S:aURX5 U RS5S:aURX5 U RS5S:aURX5 ggg)NrrUrrrp)rGmbpdetailbbor}rkliner(ztrade.clearingzaccounts.updater6opnotifyrwrr) rrrrrrrrr[findrrhr) r[rrrrrk methodNamemethodsr privateParts privateTyperrws r]handle_subjecthtx.handle_subjects^__WdB / q) 8 ))%3J//--,,)),,++**G__W9F!v'xx} &&|Q; * *   1    - .! 3    0  ( "   f .    gt , >$$Wgr:Ezz(#q(!!&2zz)$)##F4zz+&!+%%f6, r_cd# URUS5nUbURSU05IShvN gURUS5nUS:XaCURUS5nURUS5nURSSU0S.5IShvN gURUS5nUS:Xa/URUS5nURSUS.5IShvN ggNNON ![aEn[ UR S -URU5-5n URU 5 SnAgSnAff=f7f) Npingpongactionrr)rrr)rrz pong failed ) rdsendrrrrrrnjsonr) r[rrr rrpingTsrrerrors r]r htx.ponghs+  $$Wf5Dkk64.111%%gx8Fw7**46kkVdF^"LMMM!!'40BV|**7D9kkv">???2 N @  ?!:TYYq\!IJE LL   szD0+CCCD0AC C CD0ACCCD0CCC D-(;D(#D0(D--D0c<URURX5 gr)rr rs r] handle_pinghtx.handle_pings 499f.r_cDURSnURU5 g)Nauth)futuresr)r[rrpromises r]handle_authenticatehtx.handle_authenticates*..( r_c URUS5nUS:XaURUS5nURURS5nURXT5nUb^URUS5nUR UR SSXpR U55 [UR U55egURUS S5n U b[U S :waUU S :waOURS -UR U5-n UR UR SSX5 [U 5eg![aZnURUS5n URX5 URX5 XAR;a URU SnAgSnAff=f![aen[U[5(a5URUS 5 S n XR;a URU SnAgURU5 SnAgSnAff=f)NrJrrnzerr-coder"rMrxFr200r'rrT)rrrrrthrow_exactly_matched_exceptionrWrrrrr+rn isinstancer) r[rrrJrnrr errorCoderrxrfeedbackrs r]handle_error_messagehtx.handle_error_messages@!!'84 W !!'40B $ f.B.BD I ??+<AL' ,,WjA 5889Nw9WYbdmdmnudvw' '(:;;!!'6:>  $%-dckww}tyy'99H %44T__T5J75SUYd#H---!5"&"2"2<"OKMM!1MM!(111"004 5 %a!455MM!V,#F!5!55"008 MM!$$ %s9.A D,>-F, F6AF  F HAG='G==HczURX5(Ga$SU;aURX5 gSU;aBURUS5nUS:XaURX5 gUS:XaURX5 gSU;a-USS:XaUR X5 gUR X5 gSU;arURUS5nUS:XaURX5 gUS:XaUR X5 gUS:XaURX5 gUS:XaUR X5 gSU;aURX5 ggg) Nrnrr subrrrr)r#rrrrrr )r[rrrrs r]handle_messagehtx.handle_messagesJ  $ $V 5 5Zw//@7"))'8<V#$$V5U?33FDw4=F*,,V=''8w%%gt4<$$V5<,,V=;33FD>''8   1!] 6r_cURc-URURSS5n[U5UlURnUR US5nUGb{UR US5nUbUUR U5nUR US5n U b.URU5 URURU5 ggUR US/5n UR US5n URU 5n [S[U 55H:n XnURX5nURX5nURU5 M< US-S -nURURU5 URS U S -S 5nURU S 5nURS U-S 5nUS-S -nURURU5 gg)NrKrBrrrhrrr)rrr"rUr7)myTradesrdrVrrrrparse_ws_traderrrprrrrr\r])r[rr extendParamsr cachedTradesrxrrrhrarmrprrr_ tradesHashgenericOrderHashrggenericTradesHashs r]r[htx.handle_my_trade0sh == %%dllM4HE259DM}} &&w5  "??7F3D,,T2))&(;% ''/NN4==+>& !OOGXrB ??7H=X.q#i.1A%LE"&"2"25"AK"&++k"HK '' 4 2)3.8 t}}j9 $/#6#6sVM=R7RTV#W "&"8"8"J#3#;#;C/.>um.TU  "(( >'C" Y/(   r_cURURSS5nSUR0nSnSnUS:XatU(aURSSUSSnO>U(aURSSUSSnOURSSUSSnUR Xv5nU$URSSUUn U(aU SOU S n U(aU SOU SnU$) Nr9hostnamer?r"r;r<r:r=r>)rrrVr9rUrs) r[rkr isPrivateisFeedr9r9 hostnameURLrybaseUrl subTypeUrls r]rthtx.get_url_by_market_typest||UE:$dmm4  6>"ii.t4S9&A)L "&))E"24"8"=f"Ef"MK"&))E"24"8"=f"Eh"OK%%kFZZ$++g2NP[jjjjsBB"B B"c# UR5nUUUS.nURX5n Sn US:XaSUS.n OSUUS.n US:Hn URX;S5n US:XaURSSOURSS n UU U S .nUR U5IShvN UR XURX5X5IShvN $N.N7f) Nrnrxrvr?r&)rr)rrwcidr=T hostnamesr)rkryr9)rfrrtrU authenticater)r[rrxrksubtypervrrarextendedSubsriptionrrryr9 authParamss r]r.htx.subscribe_private sOO% & #kk,K 6>G   G h&))$$?6:fn499[)&1499U`KablKm   +++ZZ$++g2NPWmmm ,ms$BC C)C C C  C c# URUS5nURUS5nURUS5nUbUbUc[URS-5eUR5 SnUR SU-S5nUR U5nUR U5nURURU5n U Gc+URUR5S5n Sn US :XaURS S U S .n OURS S U S.n URU 5n URU S5n SRSX6U /5n URUR!U 5UR!UR"5[$R&S5nSnUS :XaSURS S U US.nUSSS.nOSSURS S U US.nUR)5nUUUS.nUR+X%XU5 UIShvN $N7f)Nryr9rkz8 authenticate requires a url, hostname and type argumentrzwss://rUTr? HmacSHA256z2.1) accessKeysignatureMethodsignatureVersionrr) AccessKeyIdSignatureMethodSignatureVersion TimestampT GETbase64r9)authTyperRrSrTr signaturer)rvrr)rrkrUrVrWrX SignaturerG)rrrrnr*r\rreusableFuturerrymdhms millisecondsapiKeykeysort urlencoderhmacencodesecrethashlibsha256rfr)r[rvryr9rkrx relativePathrr@ authenticatedrsignatureParamsrpayloadr]r newParamsrars r]rJhtx.authenticate( svu-##FJ7/ ;(*dl#DGG.h$hi i '') {{8h#6; S!&&{3(<(>/48Dii EFG $++g"6 DKK8PRYR`R`bjkIGv~ %!%'3(-!*!* # (# !!#';;'3(+!*!*)I* "L JJs| L||sG1G:3G84G:)rr*r6rr)TFF)E__name__ __module__ __qualname____firstlineno__rrZrfrerrzrrrr rrrrrlistrrrr rrrrrr rrrrr2r-r rCrhrZrVrrrrrrrrdictrrr r rrr r#r'r[r+rtrur r~r.rJ__static_attributes__ __classcell__)r\s@r]rrsu #u n 68SSFS,9;TCTsT*-F-^<@d[]SSSSSbfglbmS09;TCTsT(%F%N?CQUdhqsHHH3H^aHx|~ByCH4BFbT3T3TUXT,!#6!#F@DB&!S&!&!S\&!P=?TT3T6C*C*J D& 3`<`>>'V'4' 6 v7Vv7p 2/&/!&!0@6@t@DP2VP2dEGZAfZAx@D(GKSUk `bkvkskSVk.SUikn>)+AAr_r)$ccxt.async_supportccxt ccxt.async_support.base.ws.cacherrrrrhccxt.base.typesrrr r r r r rrrrr!ccxt.async_support.base.ws.clientrtypingrccxt.base.errorsrrrrrrrr async_supportrrr_r]rs] AAuuuu4*0.'&))*S%$   S%r_