eiddlZddlmZmZmZddlZddlmZm Z m Z m Z m Z m Z mZmZmZmZmZmZmZddlmZddlmZddlmZddlmZddlmZGd d ejjZdS) N) ArrayCacheArrayCacheBySymbolByIdArrayCacheByTimestamp) AnyBalancesIntNumOrder OrderBook OrderSide OrderTypeStrStringsTickerTickersTrade)Client)List) ExchangeError)AuthenticationError) NotSupportedc eZdZdeffd ZdZdifdededefdZdifded e fd Z ifdefd Z difd ed e de fd ZdefdZdZdZifd edefdZdifdedefdZdefdZd9dZdifdedefdZdefdZd9dZddifd ede d e deefdZdefdZdddifde de d e fdZ!d9dZ"dddifd ed ede d e dee#f d!Z$defd"Z%d9de#fd#Z&dddifd e de d e dee'fd$Z(defd%Z)defd&Z*d9d'Z+d9d(Z,ifde-fd)Z.difd ed*e/d+e0d,e1d-e2de'f d.Z3difd/ed e de'fd0Z4difd e dee'fd1Z5dddifd e de d e dee'fd2Z6defd3Z7defd4Z8defd5Z9defd6Z:defd7Z;defd8Z<xZ=S):hitbtcreturnc|tt|ddddddddddddddddddddiddd did d d d id d id did didddddddddddd ddidS)NTF)ws watchTicker watchTickers watchBidsAsks watchTradeswatchTradesForSymbolswatchOrderBook watchBalance watchOrders watchOHLCV watchMyTrades createOrderWs cancelOrderWsfetchOpenOrdersWscancelAllOrdersWsrz$wss://api.hitbtc.com/api/3/ws/publicz%wss://api.hitbtc.com/api/3/ws/trading)publicprivatez)wss://api.demo.hitbtc.com/api/3/ws/publicz*wss://api.demo.hitbtc.com/api/3/ws/trading)apitestmethodzticker/{speed}zorderbook/top/{speed}orderbook/full) tradesLimitrrrr"M1M3M5M15M30H1H4D1D71M) 1m3m5m15m30m1h4h1d1wr< keepAlivei)hasurlsoptions timeframes streaming) deep_extendsuperrdescribe)self __class__s M/var/www/html/volatility/venv/lib/python3.11/site-packages/ccxt/pro/hitbtc.pyrNzhitbtc.describes,fd 3 3 < < > ># $!%#)."& $#"!&!%!%%)%)&"H#J"M#O   $. .!5".#   Tw>A >A > > > c8K||jddd}d}||}||}||j|}||}||| |||j tj d}dd|j ||d d }||||||d{VS) z @ignore authenticates the user to access private web socket channels https://api.hitbtc.com/#socket-authentication :returns dict: response from exchange r-rr, authenticatedNhexloginHS256)typeapi_key timestamp signature)r0params)check_required_credentialsrHclientreusableFuture safe_value subscriptions millisecondshmacencodenumber_to_stringsecrethashlibsha256apiKeywatch) rOurl messageHashr^futurerTrZr[requests rQ authenticatezhitbtc.authenticateTs. '')))it$Y/% S!!&&{33( > >$||||||rRNnamemessageHashPrefixsymbolscK|d{V||}|ddk}|jddd}g}|D|sBt dt |D]#}||dz||z$n||d||d } || |} | ||| |d{VS) a @ignore :param str name: websocket endpoint name :param str messageHashPrefix: prefix for the message hash :param str[] [symbols]: unified CCXT symbol(s) :param dict [params]: extra parameters specific to the hitbtc api Nbatchrr-rr+:: subscribe)r0idch) load_marketsmarket_symbolsfindrHrangelenappendnonceextendwatch_multiple) rOrprqrrr\isBatchrk messageHashesirvrns rQsubscribe_publiczhitbtc.subscribe_publics=!!!!!!!!!%%g..))G$$)it$X.  w 1c'll++ L L$$%6%= %JKKKK L  !2 3 3 3!**,,  ++i00((mWmTTTTTTTTTrRsymbolcvK|d{V|d{V|jddd}|d}||d}||dz|z}|||d}|||||d{VS) z @ignore :param str name: websocket endpoint name :param str [symbol]: unified CCXT symbol :param dict [params]: extra parameters specific to the hitbtc api Nr-rr, _subscriberrur0r\rw)ryrorHsplit safe_stringrrj)rOrprr\rk splitNamerlrvs rQsubscribe_privatezhitbtc.subscribe_privates!!!!!!!!!!!!!!!!!!it$Y/JJ|,, &&y!44  %,v5K**,,  ZZ[)[IIIIIIIIIrRc*K|d{V|d{V|jddd}t|}|||d}|||||d{VS)z @ignore :param str name: websocket endpoint name :param dict [params]: extra parameters specific to the hitbtc api Nr-rr,r)ryrorHstrrrj)rOrpr\rkrlrvs rQ trade_requestzhitbtc.trade_requests !!!!!!!!!!!!!!!!!!it$Y/$**,,''   ZZ[)[IIIIIIIIIrRlimitc K||jd}||dd}||dd|}||dd}||dd}|dkrd |zd z|zd z}n|d krd |zd z|zd z}||} dd| dgii} ||d|g|| |d{V} | S)a% watches information on open orders with bid(buy) and ask(sell) prices, volumes and other data https://api.hitbtc.com/#subscribe-to-full-order-book https://api.hitbtc.com/#subscribe-to-partial-order-book https://api.hitbtc.com/#subscribe-to-partial-order-book-in-batches https://api.hitbtc.com/#subscribe-to-top-of-book https://api.hitbtc.com/#subscribe-to-top-of-book-in-batches :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 :param str [params.method]: 'orderbook/full', 'orderbook/{depth}/{speed}', 'orderbook/{depth}/{speed}/batch' :param int [params.depth]: 5 , 10, or 20(default) :param int [params.speed]: 100(default), 500, or 1000 :returns dict: A dictionary of `order book structures ` indexed by market symbols r"r0r1 defaultMethoddepth20100zorderbook/{depth}/{speed}z orderbook/D/mszorderbook/{depth}/{speed}/batchzms/batchr\rrrw orderbooksN)r`rIr safe_string_2marketrrLr) rOrrr\rIrrprspeedrrn orderbooks rQwatch_order_bookzhitbtc.watch_order_booksE$//$,0@AA(((  //lVHdN^N^_fhnNoNopppppppp    rRr^cH||d}||d}|r|n|}|rdnd}t|}tdt |D]}||} || } | d} || } d| z} | |jvrP||j| i}||d}| i||j| <|j| }|| d}|| d}|dkr/| | | |d d }| |nf| | d g}| | d g}| |d || |d |||d <|||d<||d<| |d<||j| <||| dS)Nsnapshotupdaterrz orderbooks::rtsbaasksbidsrZdatetimer) safe_dictlistkeysr|r} safe_marketrra safe_integer order_bookparse_order_bookreset safe_list handle_deltasiso8601resolve)rOr^messagerrdatarX marketIdsrmarketIdrritemrl subscriptionrrrZrparsedSnapshotrrs rQhandle_order_bookzhitbtc.handle_order_books<0>>':6622#/xx%3zz8%% q#i..)) 3 3A |H%%h//FH%F>D(61Kdo--#~~f.BKQSTT )),@@*.//"e*D*D'/I))$44I%%dC00Ez!!!%!6!6tVYPSUX!Y!Y////~~dC44~~dC44""9V#4d;;;""9V#4d;;;%.Ik "$(LL$;$;Ij !!&Ig "(Ih &/DOF # NN9k 2 2 2 25 3 3rRc||d}||d}|||dS)Nr) safe_numberstore)rObooksidedeltapriceamounts rQ handle_deltazhitbtc.handle_delta sF  **!!%++uf%%%%%rRc~tdt|D]}||||dS)Nr)r|r}r)rOrdeltasrs rQrzhitbtc.handle_deltas%sHq#f++&& 3 3A   hq 2 2 2 2 3 3rRclK||g|d{V}|||S)a watches a price ticker, a statistical calculation with the information calculated over the past 24 hours for a specific market https://api.hitbtc.com/#subscribe-to-ticker https://api.hitbtc.com/#subscribe-to-ticker-in-batches https://api.hitbtc.com/#subscribe-to-mini-ticker https://api.hitbtc.com/#subscribe-to-mini-ticker-in-batches :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.method]: 'ticker/{speed}'(default), or 'ticker/price/{speed}' :param str [params.speed]: '1s'(default), or '3s' :returns dict: a `ticker structure ` N) watch_tickersr`)rOrr\tickers rQ watch_tickerzhitbtc.watch_ticker)sE))6(F;;;;;;;;vv...rRc NK|d{V||}||jd}||dd}||dd|}||dd}||d|i}||ddg}g}||dnPtd t|D]2} | || } || 3d d |ii} | |d || | |d{V} |jr$t| t si} | | | d <| S|| d |S)a: watches a price ticker, a statistical calculation with the information calculated over the past 24 hours for a specific market :param str[] [symbols]: :param dict params: extra parameters specific to the exchange API endpoint :param str params['method']: 'ticker/{speed}' ,'ticker/price/{speed}', 'ticker/{speed}/batch'(default), or 'ticker/{speed}/price/batch'' :param str params['speed']: '1s'(default), or '3s' :returns dict: a `ticker structure ` Nrr0zticker/{speed}/batchrr1s*rr\rrtickersr)ryrzr`rIrrimplode_paramsomitr~r|r} market_idrrL newUpdates isinstancerfilter_by_array)rOrrr\rIrr0rrprrrrn newTickersrs rQrzhitbtc.watch_tickers;s!!!!!!!!!%%g..//$, >>(((>'!*55  **** 9   00y'4K[K[\cekKlKlmmmmmmmm ? j$//  "0: 8,-##J'BBBrRc||di}t|}g}d}tdt |D]}||}||} | d} |||| } | |j| <|| |dz| z} | | | | ||dS)Nrrrrru) r`rrr|r}rparse_ws_tickerrr~r rOr^rrrresulttopicrrrrrrls rQ handle_tickerzhitbtc.handle_ticker`sNw33%% q#i..)) 0 0A |H%%h//FH%F))$x.&AAF#)DL MM& ! ! !$,/K NN6; / / / /vu%%%%%rRc||d}|d|}||d}|id|d|d||d||dd||d d ||d d ||d d||dd||dddd||dd|d|dddddddd||d||d|d|S)NrcrrZrhighhlowlbidr bidVolumeBaskr askVolumeAvwapopenocloselast previousClosechange percentageaveragevq) baseVolume quoteVolumeinfo)r safe_symbolr safe_tickerr)rOrrrZrrs rQrzhitbtc.parse_ws_tickers:%%fc22 !!$//,,! f! !   Y//!  D$$VS11 ! 4##FC00 ! 4##FC00 !  ))&#66!  4##FC00!  ))&#66!  D!  D$$VS11!  T!  D!  T!  d! $!! " t#! $**6377++FC88)! ! ! * + rRc K|d{V||dd}||jd}||dd}||dd|}||dd}||d|i}||ddg}||}d d |ii} | |d || | |d{V} |j r$t| tsi} | | | d <| S|| d |S) a! watches best bid & ask for symbols https://api.hitbtc.com/#subscribe-to-top-of-book :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.method]: 'orderbook/top/{speed}' or 'orderbook/top/{speed}/batch(default)' :param str [params.speed]: '100ms'(default) or '500ms' or '1000ms' :returns dict: a `ticker structure ` NFrr0zorderbook/top/{speed}/batchrr100msr\rrbidaskr)ryrzr`rIrrrr market_idsrrLrrrr) rOrrr\rIrr0rrprrnrrs rQwatch_bids_askszhitbtc.watch_bids_askss!!!!!!!!!%%gtU;;//$,@@(((6BBF$*DM& ! MM& ! ! !$,/K NN6; / / / /vu%%%%%rRc >||d}||d|||||d||d||d||d|d|S)Nrrrrrr)rrZrrrrrr)rrrr)rOrrrZs rQrzhitbtc.parse_ws_bid_ask s%%fc22 X&" Y//##FC00))&#66##FC00))&#66 ! !     rRsincec `K|d{V||}dd|dgii}|||d<d}||d|g|||d{V}|jr|||}||||dS)a get the list of most recent trades for a particular symbol https://api.hitbtc.com/#subscribe-to-trades :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 ` Nr\rrrwrtradesrZ)ryrrrLrgetLimitfilter_by_since_limit) rOrrrr\rrnrprs rQ watch_tradeszhitbtc.watch_tradess!!!!!!!!!V$$ F4L>   $GG ,,T8fXtGWGWX_agGhGhiiiiiiii ? 3OOFE22E))&% LLLrRc||ddi}t|}tdt |D]}||}||}||jdd}|d} ||j | } | t|} | |j | <| |||} tdt | D]} | | | d| z} | | | |S)Nrrrr2r/rztrades::) safe_value_2rrr|r}rrrIr`rrparse_ws_tradesr~r)rOr^rrrrrrr2rstoredrjrls rQ handle_tradeszhitbtc.handle_trades5s;P  *hCC%% q#i..)) 0 0A |H%%h//F++DL-NNKH%F__T[&99F~#K00&, F#))$x.&AAF1c&kk** ) ) fQi(((($v-K NN6; / / / /rRrc||}g}tdt|D]G}||||||}||H||dd}||d} ||| ||S)NrrZrwr) to_arrayr|r}rparse_ws_trader~ sort_by_2rfilter_by_symbol_since_limit) rOrrrrr\rrtraders rQr zhitbtc.parse_ws_tradesosv&&q#f++&& ! !AKK 3 3F1Iv F FOOE MM%  T::!!&(3300NNNrRcd||d}||||dd|||||dd||dd||d||dddd |S)Nrrrrpr rrworderrZrrrXside takerOrMakerrrcostfee)r safe_traderr)rOrrrZs rQrzhitbtc.parse_ws_tradeys%%eS11 ""5#.." Y//&&vx88$$UC00 %%eS11&&uc22    rRr= timeframec vK||j||}d|z}||}dd|dgii} | || dd<||d|g|| |d{V} |jr| ||}|| ||dS) u watches historical candlestick data containing the open, high, low, and close price, and the volume of a market https://api.hitbtc.com/#subscribe-to-candles :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]: not used by hitbtc watchOHLCV :param int [limit]: 0 – 1000, default value = 0(no history returned) :param dict [params]: extra parameters specific to the exchange API endpoint :returns int[][]: A list of candles ordered, open, high, low, close, volume zcandles/r\rrrwNrcandlesr)rrJrrrLrrr) rOrrrrr\periodrprrnohlcvs rQ watch_ohlcvzhitbtc.watch_ohlcvs!!$/9iHHF"V$$ F4L>   ).GH g &++D)fXtGWGWX_agGhGhiiiiiiii ? 2NN6511E))%qAAArRc||ddi}t|}||d}|d}||d}||}t dt|D]} || } || } | d} | |j | i|j | <| |j | |} | ;| |j dd }t|} | |j | |<||| | }t dt|D]}| ||d | z}|| ||S) Nrrrxrrrr OHLCVLimitr/z candles::)r rrrrfind_timeframer|r}rr`ohlcvsrrIrparse_ws_ohlcvsr~r)rOr^rrrchannel splitChannelr!rrrrrr rr'r rls rQ handle_ohlcvzhitbtc.handle_ohlcvsD  *hCC%% ""7D11}}S)) !!,22''// q#i..)) 0 0A |H%%h//FH%F"&//$+vr"J"JDK __T[%8)DDF~))$, dKK.u5517 F#I.))$x.&AAF1c&kk** ) ) fQi((((%.K NN6; / / / /rRc ||d||d||d||d||d||dgS)Nrrrrrr)rr)rOr"rs rQparse_ws_ohlcvzhitbtc.parse_ws_ohlcvs   eS ) )   UC ( (   UC ( (   UC ( (   UC ( (   UC ( (   rRc~K|d{Vd}d}|||}|d||\}}||ddddd}||||d{V}|jr|||}||||dS)a| watches information on multiple orders made by the user https://api.hitbtc.com/#subscribe-to-reports https://api.hitbtc.com/#subscribe-to-reports-2 https://api.hitbtc.com/#subscribe-to-reports-3 :param str [symbol]: unified CCXT market symbol :param int [since]: timestamp in ms of the earliest order to fetch :param int [limit]: the maximum amount of orders to fetch :param dict [params]: extra parameters specific to the exchange API endpoint :returns dict[]: a list of `order structures ` Nr$spot_subscribemargin_subscribefutures_subscribe)spotmarginswaprmrZ)ryrhandle_market_type_and_paramsget_supported_mappingrrrr) rOrrrr\ marketTyperrporderss rQ watch_orderszhitbtc.watch_orderss!!!!!!!!!   [[((F!?? vW]^^ F))*$(') 7 7    --dFFCCCCCCCC ? 3OOFE22E))&% LLLrRcx|j/||jd}t||_||dg}t |t r@tdt|D]!}||}| |||"n| ||||S)N ordersLimitr\r) r8rrIrr`rrr|r}handle_order_helper)rOr^rrrrrs rQ handle_orderzhitbtc.handle_orders| ; %%dlMBBE077DKw"55 dD ! ! <1c$ii(( A AQ((%@@@@ A  $ $VWd ; ; ;rRc|j}||dd}||d}|d}||d}||} ||} || ||||||dz| zdS)N instrumentrr0_orderrru)r8safe_string_lower_2rrr parse_orderr~r) rOr^rrr8rr0 splitMethodrlrparseds rQr<zhitbtc.handle_order_helpergs++E<JJ!!'844ll8,, &&{A66 !!(++!!%(( fv{+++v{T1F:;;;;;rRc||d}||d}||||d||d||||||d||d||d||d||dd||d ddd d |S) N created_atrtrade_idrwr trade_taker trade_pricetrade_quantity trade_fee)rcurrencyrater)rrrrr)rOrrrZrs rQparse_ws_order_tradezhitbtc.parse_ws_order_tradess6%%e\:: ##E844""5*55%%eT22" Y//&&x88$$UF33 ,,UMBB%%e];;&&u.>??(( <<   $ % rRc||d}||d}|||}||d}d}||||}|g}||d}||d} d} | dkr|| } n||} |id|d||dd ||d d |d ||d dd|dd||dd||dd||dd||dd||dd||dd||ddddddd| d|dd|S)NrFrrGstatus report_typecanceledrrw clientOrderIdclient_order_idrZrlastTradeTimestamprrquantityrXr timeInForce time_in_forcepostOnly post_only reduceOnly reduce_onlyfilled remainingr)rPrrr)rrrNparse_order_status safe_orderrsafe_string_upperr`) rOrrrZrtradeIdrr rawStatusrQ parsedStatuss rQparse_ws_orderzhitbtc.parse_ws_orders6$$UL99 ##E844!!(F33""5*55  --eV<` Nr#spot_balance_subscribefutures_balance_subscribe)r2r4rmmodebatches)ryr5r6rrrr)rOr\rXrprirns rQ watch_balancezhitbtc.watch_balances!!!!!!!!!99.$PVWW f))$,/11 1     ::66** D ++D$ GV8T8TUUUUUUUUUrRrXrrrc K|d{V||}d}d} |d||\} }d} |d|\} }||| ||||| |\}}|||}| dkr|d|d{VS| dks| |d|d{VS|d|d{VS)a  create a trade order https://api.hitbtc.com/#create-new-spot-order https://api.hitbtc.com/#create-margin-order https://api.hitbtc.com/#create-futures-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.marginMode]: 'cross' or 'isolated' only 'isolated' is supported for spot-margin, swap supports both, default is 'cross' :param bool [params.margin]: True for creating a margin order :param float [params.triggerPrice]: The price at which a trigger order is triggered at :param bool [params.postOnly]: if True, the order will only be posted to the order book and not executed immediately :param str [params.timeInForce]: "GTC", "IOC", "FOK", "Day", "GTD" :returns dict: an `order structure ` N createOrderr4futures_new_orderr3margin_new_orderspot_new_order)ryrr5handle_margin_mode_and_paramscreate_order_requestrr) rOrrXrrrr\rrnr7 marginModes rQcreate_order_wszhitbtc.create_order_wssU*!!!!!!!!!V$$ !?? vW]^^ F !?? vVV F33FJdTZ\acmouvv++gv..   ++,?IIIIIIII IH$$**@++,>HHHHHHHH H++,` NrTr(r4futures_cancel_orderr3margin_cancel_orderspot_cancel_order)ryrr5rqrr) rOrwrr\rrnr7rsquerys rQcancel_order_wszhitbtc.cancel_order_ws(s=!!!!!!!!! r   [[((F !??QWY_`` F >>PVWW E++gu--   ++,BGLLLLLLLL LH$$**@++,A7KKKKKKKK K++,?IIIIIIII IrRcK|d{Vd}|||}d}|d||\}}d}|d|\}}|dkr|d|d{VS|dks|t |jdz|d|d{VS)am https://api.hitbtc.com/#cancel-spot-orders https://api.hitbtc.com/#cancel-futures-order-3 cancel all open orders :param str symbol: unified market symbol, only orders in the market of self symbol are cancelled when symbol is not None :param dict [params]: extra parameters specific to the exchange API endpoint :param str [params.marginMode]: 'cross' or 'isolated' only 'isolated' is supported :param bool [params.margin]: True for canceling margin orders :returns dict[]: a list of `order structures ` Nr*r4futures_cancel_ordersr3z5 cancelAllOrdersWs is not supported for margin ordersspot_cancel_orders)ryrr5rqrrrw)rOrr\rr7rss rQcancel_all_orders_wszhitbtc.cancel_all_orders_wsIs!!!!!!!!!  [[((F !??@SU[]cdd F !??@SU[\\ F   ++,CVLLLLLLLL LH$$**@tw)``aa a++,@&IIIIIIII IrRcK|d{Vd}i}| ||}|d|d<d}|d||\}}d}|d|\}}|dkr|d|d{VS|dks||d|d{VS|d |d{VS) a https://api.hitbtc.com/#get-active-futures-orders-2 https://api.hitbtc.com/#get-margin-orders https://api.hitbtc.com/#get-active-spot-orders fetch all unfilled currently open orders :param str symbol: unified market symbol :param int [since]: the earliest time in ms to fetch open orders for :param int [limit]: the maximum number of open orders structures to retrieve :param dict [params]: extra parameters specific to the exchange API endpoint :param str [params.marginMode]: 'cross' or 'isolated' only 'isolated' is supported :param bool [params.margin]: True for fetching open margin orders :returns Order[]: a list of `order structures ` Nrwrr)r4futures_get_ordersr3margin_get_ordersspot_get_orders)ryrr5rqr) rOrrrr\rrnr7rss rQfetch_open_orders_wszhitbtc.fetch_open_orders_wses6 !!!!!!!!!  [[((F &t GH  !??@SU[]cdd F !??@SU[\\ F   ++,@'JJJJJJJJ JH$$**@++,?IIIIIIII I++,=wGGGGGGGG GrRc||d}||d}||}||j||_||j|dS)Nr0r\)rr` parse_balancerLbalancer)rOr^rrlr\rs rQhandle_balancezhitbtc.handle_balancest &&w99 (33$$V,,'' g>> t|[11111rRc|SN)rOr^rs rQhandle_notificationzhitbtc.handle_notifications rRc||d}||di}t|trig}t dt |D]2}|||}||3|||n+||}||||S)Nrwrr) rr`rrr|r}rer~r)rOr^rrlr parsedOrdersr parsedOrders rQhandle_order_requestzhitbtc.handle_order_requests8&&w55 (B77 fd # # 5L1c&kk** 1 1"11&)<< ##K0000 NN< 5 5 5 5--f55K NN; 4 4 4rRc~|||rdS||dd}||d}||d}|dkr ||d}||dkrd}|j|j|j|j|j|j |j |j |j |j |j |j |j d }| ||}||||dSdS| |d }||d } | | |||d urd |vr| ||t|trH| |di} t!|} | dksd | vr| ||dSdSdS)Nrxr0rrrrtop orderbook/top) r rrrr spot_order spot_orders margin_order margin_orders futures_orderfutures_orders spot_balancefutures_balancerrTTrw) handle_errorrrrr+rrrrr=rr`rhandle_authenticaterrr}) rOr^rr)r*channel2methodsr0rrSfirst arrayLengths rQhandle_messagezhitbtc.handle_messages   VW - -  F$$WdH==  "==--L&&|Q77G+%%++L!<<'H,=,=-G,,,!3!%!4"/#0 $ 1!%!2!%!2"&"3 $ 3#'#6G__Wg66F!vw'''''"!__Wh77F ,,V5FGGM())&':::$((999&$'' ?266!&kk 1$$*;u*D*D--fg>>>>>  ? ?+E*DrRcD||d}d}|r1||j|}|dnTt|jdz||z}|||||jvr|j|=|S)NrrTT )r`futuresrrrwjsonrejectra)rOr^rsuccessrlrmerrors rQrzhitbtc.handle_authenticates//'844%  6__V^[AAF NN4 '#  '8J8J(JKKE MM% - - -f222(5rRc||d}|& ||d}||d}||d}|jdz|z}||jd||||jd||t |#t$rv}t|tr*d} | || | |j vr|j | =n,||d } | || Yd}~d Sd}~wwxYwdS) Nrcoder descriptionrexactbroadrTrwT) r`rrwthrow_exactly_matched_exception exceptionsthrow_broadly_matched_exceptionr Exceptionrrrra) rOr^rrr errorMessagerfeedbackerlrws rQrzhitbtc.handle_error s_11   uf55#//yAA "..umDD 7S=;644T_W5MtU]^^^44T_W5M|]efff#H---   a!455)"1KMM![111"f&:::"0=))'488BMM!R(((ttttt tsB"B== D=A+D88D=r)>__name__ __module__ __qualname__rrNrorrrrrrrr rrrrrrrrrrrrrrrrrrobjectr rrr#r+r-r r9r=r<rNrerrkr r floatr rtrzr~rrrrrrr __classcell__)rPs@rQrrs? #? ? ? ? ? ? B---^\`hjUU3U3UQXUUUU4@DBJJCJJJJJ*57JJJJJJ"@DB"!"!S"!"!S\"!"!"!"!H7373737373r&&& 33368///F////$6:"#C#C7#C#C#C#C#CJ4&F4&4&4&4&l5555n8H6HHHHT <& < < < <////b@@@@D*,VVVVVV:pt|~#G#GC#Gy#G #G[`#Gil#GDI#G#G#G#GJ<@JJJSJuJJJJB8rs ffffffffffBBBBBBBBBBBBBBBBBBBBBBBBBBBBBB444444******000000))))))XXXXXT  &XXXXXrR