":hddlZddlmZmZmZddlmZmZm Z m Z m Z m Z m Z mZmZmZmZddlmZddlmZddlmZddlmZGdd ej2j4Zy) N) ArrayCacheArrayCacheBySymbolByIdArrayCacheByTimestamp) AnyBalancesIntOrder OrderBookPositionStrStringsTickerTickersTrade)Client)List) ExchangeError)ArgumentsRequiredc 4eZdZdeffd ZifdZifdZdZifdZifdZ idfd e fd Z ifd e de fd Zdifd edefdZdefdZdifd edefdZdifde d efdZdefdZd>dZdifd edefdZdZded e fdZdZdefdZddifd e dedede e!fdZ"ddifd e e dedede e!fdZ#ifd e defdZ$ifd e e defd Z%defd!Z&d"ddifd e dedede e'fd#Z(defd$Z)difd e dede*fd%Z+difd e e dede*fd&Z,ifd e defd'Z-ifd e e defd(Z.d)Z/d*Z0defd+Z1d,Z2defd-Z3dddifd ededede e4fd.Z5d/Z6d>d0Z7defd1Z8ifde9fd2Z:defd3Z;defd4Zd>d7e d efd8Z?defd9Z@defd:ZAdefd;ZBdefd<ZCdefd=ZDxZES)? kucoinfuturesreturnc|jtt|iddddddddddddd dd dd dd dd dddddddddddddddiddddddddddddd d! d"d#d$d%d&d'd(ddd)d*d+|jid,S)-NwsTwatchLiquidationsFwatchLiquidatinsForSymbolswatchMyLiquidationswatchMyLiquidationsForSymbols watchTicker watchTickers watchBidsAsks watchTrades watchOHLCVwatchOrderBook watchOrders watchBalance watchPositionwatchPositionswatchPositionForSymbolswatchTradesForSymbolswatchOrderBookForSymbols1min5min15min30min1hour2hour4hour8hour12hour1day1week1month) 1m3m5m15m30m1h2h4h8h12h1d1w1Mfuturemargin)swapcross) snapshotDelaysnapshotMaxRetries)fetchPositionSnapshotawaitPositionSnapshot) timeframesaccountsByType tradesLimitr#r&ping)hasoptions streaming) deep_extendsuperrdescriberR)self __class__s P/var/www/html/turnos/venv/lib/python3.12/site-packages/ccxt/pro/kucoinfutures.pyrXzkucoinfutures.describestmT C Ed#U-e&t  0  t  td!$t !% *5!"(#$+D%,!  ""!!!!# !" %% # $%'*+# .2-1"E&V yBH B B cK|rdnd}|j|jdi}|j||}| |d{S|j|j||||<||jd<||}|d{S7B7w)Nprivatepublicurls) safe_valuerTspawnnegotiate_helper)rYprivateChannelparams connectIdr`spawanedrDs r[ negotiatezkucoinfutures.negotiateVs!/IX t||VR8??43  !> !**T%:%:NFSY# Vi|"s"=BB=B=B>BBcKd}|rdnd} |r|j|d{}n|j|d{}|j|di}|j|dg}|j|d}|j|d}|j |d} |j |d} | d z|j | ||d z} |j | } || _| S77#t$rJ} |j|jd |}|j| |jd |=Yd} ~ yd} ~ wwxYww) Nr^r_datainstanceServersr pingIntervalendpointtoken?)rnrdrfr`) futuresPrivatePostBulletPrivatefuturesPublicPostBulletPublicra safe_integer safe_string urlencodeclient keepAlive ExceptionrTreject)rYrdreresponserfrjrkfirstInstanceServerrlrmrnresultruerDs r[rczkucoinfutures.negotiate_helperdsN!/IX ' 0!%!E!Ef!MM&"&!C!CF!KK??8VR8D"ood4ErJO"&///1"E ,,-@.QL''(;ZHH$$T73E^dnn"0&6'F [[(F+F MCN&L 0__T\\&%99EF MM!  V$Y/  0sP D>C(C$C(C&B&C(#D>$C(&C(( D;1AD61D>6D;;D>c~|j|j|jddd}||jd<|S)N requestIdr)sumrrrT)rYr~s r[ request_idzkucoinfutures.request_ids9HHT..t||[!LaP $- [!r\cKt|j}|d|dd}|j||}d|i} || }n|j| |}|j|||||d{S7w)N subscribeTidtypetopicryr)strrextendwatch) rYurl messageHashsubscriptionHash subscriptionrer~requestmessagesubscriptionRequests r[rzkucoinfutures.subscribes)* %   ++gv. )%   .L;;':LILZZ[';K\ZZZZsA&A/(A-)A/cKt|j}|d|dd}|j|||j||||d{S7w)NrTr)rrwatch_multipler) rYr messageHashesrsubscriptionHashessubscriptionArgsrer~rs r[subscribe_multiplez kucoinfutures.subscribe_multiplese)*    ((mT[[RX=Y[moAA AAsA A A ANrcVKt|j}|d|dd}|j||} ||||<|j|} t dt |D]%} || } | | j vs| | j |<'|j||| ||d{S7w)N unsubscribeTrr)rrrrurangelen subscriptionsr) rYrrrrrerr~rrruirs r[un_subscribe_multiplez#kucoinfutures.un_subscribe_multiples)* !   ++gv.  #&/L #S!q#012 CA1!4 $(<(<<2B$$Y/ C((mWFXZfggggsA6B)9)B)"B'#B)symbolcK|jd{|j|}|d}d|d<|j|g|d{}||S7?7 w)a watches a price ticker, a statistical calculation with the information calculated over the past 24 hours for a specific market https://www.kucoin.com/docs/websocket/futures-trading/public-channels/get-ticker :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 ` NrrcallerMethodName) load_marketsmarket watch_tickers)rYrrertickerss r[ watch_tickerzkucoinfutures.watch_tickersi!!!V$!%2!"**F8V<<v "=s!AA5A A AAsymbolscK|jd{|jdd||d{}|jr i}|||d<|S|j|jd|S7U7;w)a watches a price ticker, a statistical calculation with the information calculated over the past 24 hours for all markets of a specific list :param str[] symbols: 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 ` Nrz/contractMarket/ticker:r)rwatch_multi_request newUpdatesfilter_by_arrayrrYrretickerrs r[rzkucoinfutures.watch_tickerssx!!!//@Y[bdjkk ??G(.GF8$ %N##DLL(GDD "ksA0A,A0A.:A0.A0ruc|j|di}|j|d}|j|dd}|j||}||j|d<|j ||j d|dy)Nrjr-r)ra safe_market parse_tickerrresolveget_message_hash)rYrurrjmarketIdrrs r[ handle_tickerzkucoinfutures.handle_tickers,w3??42!!(D#6""40)/ VH%&vt44Xvh?OPQr\cK|jdd||d{}|jr i}|||d<|S|j|jd|S79w)a https://www.kucoin.com/docs/websocket/futures-trading/public-channels/get-ticker-v2 watches best bid & ask for symbols :param str[] symbols: 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 ` r z/contractMarket/tickerV2:Nr)rrrbidsasksrs r[watch_bids_askszkucoinfutures.watch_bids_askssc//A\^egmnn ??G(.GF8$ %N##DMM8WEE osAA:A channelNamecK|jd{|j|d|\}}|dk(}|j|dddd}t|}|dkDrt |j dz|zdzg}t dt|D]B}||} |j| } |rd nd } |j|j| | d D|jdd{} |j|} d j| }t|j}|d ||zdd}d|i}|j| ||j!||||d{S7N7}7 w)Nrr FTd z#() accepts a maximum of 100 symbolsrbidaskrr,rrr)rhandle_param_stringmarket_symbolsrrrrrappendrrh market_idsjoinrrrr)rY methodNamerrre isBidsAskslengthrrrrprefixr marketIdsjoinedr~rrs r[rz!kucoinfutures.watch_multi_requests!!!!55f>PR\] F O3 %%gtUD%HW C<#DGGcMJ$>Af$fg g q#g,' RAQZF[[(F!+XF  !6!6vvh?O!P Q  R NN5))OOG, )$)*  6)   ) ((mT[[RX=Y[hjvwww5 "*xs5E+E$CE+)E'*A5E+E) E+'E+)E+c|j|}|d}||j|<|j||jd|y)Nrr)parse_ws_bid_askrrr)rYrur parsedTickerrs r[handle_bid_askzkucoinfutures.handle_bid_ask/sG",,W5 h' , f|T%:%:8V%LMr\c |j|di}|j|d}|j||}|j|d}|j|dd}|j |||j ||j |d|j |d|j |d|j |d|d |S) Nrjrtsư> bestAskPrice bestAskSize bestBidPrice bestBidSize)r timestampdatetimeask askVolumebid bidVolumeinfo) safe_dictrsrsafe_integer_product safe_tickeriso8601 safe_number)rYrrrjrrrs r[rzkucoinfutures.parse_ws_bid_askEs~~ffb1##D(3!!(F3!!&(3--dD(C " Y/##D.9))$ >##D.9))$ > !    r\c PK|t|jdz|jd{|jdd{}|j |}d|dz}ddi}d|dz}|j |}|j |||jd d d} |jd d d} |j|} | r"| r | |jd |zd{} | S|j|||d|j||d{S77777 w) av watch open positions for a specific symbol https://docs.kucoin.com/futures/#position-change-events :param str|None symbol: unified market symbol :param dict params: extra parameters specific to the exchange API endpoint :returns dict: a `position structure ` Nz+ watchPosition() requires a symbol argumentTz/contract/position:rrd position:rr&rMrNfetchPositionSnapshot:) rrrrhrruset_position_cache handle_optionget_current_positionrDrr) rYrrerrrrrrurMrNcurrentPositionsnapshots r[watch_positionzkucoinfutures.watch_positionVs; >#DGG.[$[\ \!!!NN4((V$%t 4 d "F8$44 S! / $ 2 2?D[]a b $ 2 2?D[]a b33F; %:?V#]]+Cf+LMMHO^^CeT4;;wX^C_```! "(N`sF.D&DD& D  B D&*D"+.D&D$D& D&"D&$D&c|jy|jj}|j||i}t|j }|j|dSNr) positionshashmapralistvalues)rYrcache symbolCachers r[rz"kucoinfutures.get_current_positiontsT >> !&&ooeVR8 k((*+vq))r\c|jddd}|rDd|z}||jvr0|j||j|j|||yyy)Nr&rMFr)rfuturesrDrbload_position_snapshot)rYrurrMrs r[rz kucoinfutures.set_position_cache|s` $ 2 2?D[]b c 2V;K6>>1 k* 466 VT2 !r\cK|j|d{}t|_|j}|j||j|}|j ||j |d|zy7fw)Nr)fetch_positionrrrrr)rYrurrpositionrrDs r[rz$kucoinfutures.load_position_snapshotsj,,V44/1 X ,uxv!565sBA>A'Bc|j|dd}|jd}|j|d}|j|dd}|j}|j |}d|z} |j |di} |j | } t| j} tdt| D]} | | }| || |=|j|| }|j||j|| y)Nr:rrrjr)rssplit safe_symbolrrraparse_positionrkeysrrrrr)rYrurrpartsrrrrrrj newPositionrrkeyrs r[handle_positionzkucoinfutures.handle_positionsz  '26 C ##E1-!!(D"533F;!F* w3))$/ K$$&'q#d)$ %Aq'C3'$ %;; < Xx-r\sincelimitcHK|j|g|||d{S7w)a get the list of most recent trades for a particular symbol https://docs.kucoin.com/futures/#execution-data :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 ` N)watch_trades_for_symbols)rYrrrres r[ watch_tradeszkucoinfutures.watch_tradess'22F8UE6RRRRs " "cKt|}|dk(rt|jdz|jd{|j |}|j dd{}|j |}|j |}ddj|z}g} g} tdt|D]4} || } || } | jd| z| jd| z6|j|| || d|d{}|jr6|j|d}|j|d}|j||}|j|||d d S7*77aw) a get the list of most recent trades for a particular symbol :param str[] symbols: :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 ` rz> watchTradesForSymbols() requires a non-empty array of symbolsNF/contractMarket/execution:rtrades:rrT)rrrrrrhrrrrrrrarsgetLimitfilter_by_since_limit)rYrrrre symbolsLengthrrrrrrrrtradesfirst tradeSymbols r[rz&kucoinfutures.watch_trades_for_symbols svG A #DGG.n$no o!!!%%g.NN5))%%g.OOG, ,sxx /BB q#g,' OAQZF |H  V!3 4  % %&BX&M N  O ..sM5J\^bdjkk ??OOFA.E**5(;KOOK7E))&% TRR% ")ls5` N)un_watch_trades_for_symbolsrYrres r[un_watch_tradeszkucoinfutures.un_watch_trades+s#55vhGGGG   cK|jd{|j|dd}|jdd{}|j|}|j|}ddj |z}g}g}t dt |D]/}||} |jd| z|jd| z1||dd |d } |j|||||| d{S777w) a! get the list of most recent trades for a particular symbol :param str[] symbols: :param dict [params]: extra parameters specific to the exchange API endpoint :returns dict[]: a list of `trade structures ` NFr rrzunsubscribe:trades:r rT)rsubMessageHashesrrr) rrrhrrrrrr) rYrrerrrrrrrrs r[rz)kucoinfutures.un_watch_trades_for_symbols7s!!!%%gtU;NN5))%%g.OOG, ,sxx /BB q#g,' :AQZF  !6!? @  % %i&&8 9 : + 2  //]E=Z`bnooo' ")"ps4C4C.+C4C0B&C4)C2*C40C42C4cR|j|di}|j|}|d}|j|j|}|7|j|jdd}t |}||j|<|j |d|z}|j|||S)NrjrrQrHr )ra parse_traderrrrTrrr) rYrurrjtraderrrrs r[ handle_tradezkucoinfutures.handle_tradeSs*w3  &xf5 >%%dllM4HE&F"(DKK  e&( v{+r\r7cK|jd{|j|}|jdd{}|j|}|j |j d}|j |||} d|zdz| z} d|zdz|z} |j|| | d|d{} |jr| j||}|j| ||ddS777;w) a https://www.kucoin.com/docs/websocket/futures-trading/public-channels/klines watches historical candlestick data containing the open, high, low, and close price, and the volume of a market :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 NFrOz/contractMarket/limitCandle:_ohlcv::rT) rrrh market_idrrTrsrrr r ) rYr timeframerrrerrrO timeframeIdrrohlcvs r[ watch_ohlcvzkucoinfutures.watch_ohlcvus!!!V$NN5))>>&)^^DLL,? &&z9iH .9C?+M&(3.: nnS+udFKK ??NN651E))%q$GG ") Ls4C1C+)C1C-A2C13C/48C1-C1/C1c |j|d}|jd}|j|d}|j|d}|j|jd}|j ||}|j|d} |j | } d| zdz|z} |j |d} |j| d |j| d|j| d |j| d |j| d |j| d g} |j|j| i|j| <||j| vr8|j|jdd}t||j| |<|j| |}|j| |j|| y)NrrrrjrOrrcandlesrrJ OHLCVLimitrH) rsrrrTfind_timeframer safe_listrrrohlcvsrrr)rYrurrrr!rjrOr rrrr"parsedrstoreds r[ handle_ohlcvzkucoinfutures.handle_ohlcvs*  '2 C &&ua0 ~~gv.^^DLL,? '' Z@ ##D(3!!(+&(3.: tY/   eQ '   UA &   UA &   UA &   UA &   UA &  #nnT[[&"E FT[[00%%dllL$GE-B5-IDKK  *V$Y/ fv{+r\cFK|j|g||d{S7w)a watches information on open orders with bid(buy) and ask(sell) prices, volumes and other data 1. After receiving the websocket Level 2 data flow, cache the data. 2. Initiate a REST request to get the snapshot data of Level 2 order book. 3. Playback the cached Level 2 data flow. 4. Apply the new Level 2 data flow to the local snapshot to ensure that the sequence of the new Level 2 update lines up with the sequence of the previous Level 2 data. Discard all the message prior to that sequence, and then playback the change to snapshot. 5. Update the level2 full data based on sequence according to the size. If the price is 0, ignore the messages and update the sequence. If the size=0, update the sequence and remove the price of which the size is 0 out of level 2. For other cases, please update the price. 6. If the sequence of the newly pushed message does not line up to the sequence of the last message, you could pull through REST Level 2 message request to get the updated messages. Please note that the difference between the start and end parameters cannot exceed 500. https://docs.kucoin.com/futures/#level-2-market-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 N)watch_order_book_for_symbols)rYrrres r[watch_order_bookzkucoinfutures.watch_order_books%"66xOOOOs !!cKt|}|dk(rt|jdz|"|dk7r|dk7rt|jdz|j d{|j |}|j |}|jdd{}dd j|z}d |i}g} g} tdt|D]4} || } || } | jd | z| jd| z6|j|| || ||d{}|jS777w) a watches information on open orders with bid(buy) and ask(sell) prices, volumes and other data https://docs.kucoin.com/futures/#level-2-market-data :param str[] symbols: unified array of symbols :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 rzA watchOrderBookForSymbols() requires a non-empty array of symbolsNrIrz8 watchOrderBook 'limit' argument must be None, 20 or 100F/contractMarket/level2:rr orderbook:) rrrrrrrrhrrrrr)rYrrrer rrrrrrrrr orderbooks r[r1z*kucoinfutures.watch_order_book_for_symbolssZG A #DGG.q$qr r   %3,#DGG.h$hii!!!%%g.OOG, NN5)))CHHY,?? U"   q#g,' LAQZF |H  !6 7  % %&?(&J K  L 11#}eM_aqsyzz   ! "*{s7A D>"D8#:D>D:BD>#D<$D>:D><D>cDK|j|g|d{S7w)a unWatches information on open orders with bid(buy) and ask(sell) prices, volumes and other data https://docs.kucoin.com/futures/#level-2-market-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 :returns dict: A dictionary of `order book structures ` indexed by market symbols N)un_watch_order_book_for_symbolsrs r[un_watch_order_bookz!kucoinfutures.un_watch_order_books#996(FKKKKrcK|jd{|j|}|j|}|jdd{}ddj |z}g}g}t dt |D]/}||} |jd| z|jd| z1||dd |d } |j|||||| d{S777w) a unWatches information on open orders with bid(buy) and ask(sell) prices, volumes and other data :param str[] symbols: unified array of symbols :param dict [params]: extra parameters specific to the exchange API endpoint :returns dict: A dictionary of `order book structures ` indexed by market symbols NFr4rrzunsubscribe:orderbook:r5Tr6)rrrrr) rrrrhrrrrr) rYrrerrrrrrrrs r[r8z-kucoinfutures.un_watch_order_book_for_symbolss!!!%%g.OOG, NN5)))CHHY,?? q#g,' =AQZF  !9F!B C  % %lV&; < = + 2  //]E=Z`bnooo% "*ps4C!C:C!CBC!CC!C!C!c|j|d|d<|j|d}||d<|j||d<|j|di}|jd}|j |d}|j |d}|j |d }|d k(rd nd } ||g} | d k(r|d } | j | y|d } | j | y) Nsequencenoncerrchangerrrr&buybidsasks)rrrrarrrs storeArray) rYr6deltarr> splitChangepricesidequantityrvalue storedBids storedAskss r[ handle_deltazkucoinfutures.handle_deltas!..ujA '%%e[9 !* + $ Y 7 *"5ll3'   a0 Q/##K3%-vf! 6>"6*J  ! !% ("6*J  ! !% (r\cbtdt|D]}|j|||yr)rrrK)rYbooksidedeltasrs r[ handle_deltaszkucoinfutures.handle_deltas.s0q#f+& 3A   hq 2 3r\c|j|d}|j|d}|jd}|j|d}|j|dd}d|z}||jvrN|j |j |i} |j| d} |ji| |j|<|j|} |j| d} |j|d } | .t| j}|jd}|j|d}|j|d }t|j j}d}td t|D]A}||}|j|d k\s|j|d k\s2|j |}n|j|d} |jd d d }||k(r |j!|j"|||| i| jj%|y| | k\ry|j'| ||j)| |y)Nrjrrrrr5rr=r<rr#rK)rarsrr orderbooksrrrr order_bookrrrrrfindrrbload_order_bookrrKr)rYrurrjr topicPartsrrrrrstoredOrderBookr=deltaEnd cacheLength topicPartsNew topicSymbol topicChannelrrrrrKs r[handle_order_bookzkucoinfutures.handle_order_book2s4 w/  '2[[% ##J2!!(D#6"V+ $//)#~~f.B.BE2N %%&6@E&*oob%&@DOOF #//&1!!/7;$$T:6 =o334K!KK,M**=!` NTz/contractMarket/tradeOrdersrdordersrr)rrhrrrrr filter_by_symbol_since_limit) rYrrrrerrrrrrjs r[ watch_orderszkucoinfutures.watch_orderss!!!NN4((- d   [[(FH%F%+f4K~~c;tT[[QXZ`Eabb ??OOFE2E00tTT "(cs2CB<CB>ACC8C>CCc8dddddd}|j|||S)Nopenclosedcanceled)rnfilledmatchupdaterp)rs)rYstatusstatusess r[parse_ws_order_statusz#kucoinfutures.parse_ws_order_statuss/"  &&99r\cr|j|d}|j|d}|j|d}|j|d}|j|d}|j|d}|j|d} |j| } |j|dd } |j|d } |j | |}|d } |j|d }|j id |d | d |d|d| d|j | ddd|ddddd |d|ddd|ddddd|d| ddd|S)NorderId clientOid orderTyperE filledSizesizer orderTimerrrFrr clientOrderIdrrlastTradeTimestamp timeInForcepostOnly stopPriceamountcostaveragerq) remainingrtfeer)rssafe_string_lowerrvrr safe_orderr)rYorderrrr~rzrErqrrawTypertrrrrFs r[parse_ws_orderzkucoinfutures.parse_ws_orders$  eY /(( < **5+>   0!!%6!!%0""5&1++G4--e[(K ##E84!!(F3!%%eV4 E f  "  ]     Y/   !$  I  4    D  U    f  D t! " f# $+ , - r\cvd}|j|d}|j|}|j|d}|j|d}||j-|j |j dd}t ||_|j} |j| j|i} |j| |} | &|j| d} | | |d<| dd k(rd |d<| j||j|j||d z|z} |j|j| yy) Nrjrjrr ordersLimitrHrrtror) rarrsrjrrrTrrrr)rYrurrrjr-rrxr cachedOrdersrjrrsymbolSpecificMessageHashs r[ handle_orderzkucoinfutures.handle_orders4 w/$$T*!!&(3""640  {{"))$,, tL4U; ;;L__\%9%962FFOOFG4E  OOE;? (*3F;'?h.'/F8$    ' NN4;; 4(3c(9F(B % NN4;;(A B# r\c K|jd{|jdd{}d}ddi}d|ji}d}|j|||||j ||d{S7`7I7w)a_ watch balance and get the amount of funds available for trading or funds locked in orders https://docs.kucoin.com/futures/#account-balance-events :param dict [params]: extra parameters specific to the exchange API endpoint :returns dict: a `balance structure ` NTz/contractAccount/walletrdmethodbalance)rrhhandle_balance_subscriptionrr)rYrerrrrrs r[ watch_balancezkucoinfutures.watch_balances!!!NN4(() d  d66  ^^Ce\4;;W^`fKghhh "(is2A=A7A=A9AA=2A;3A=9A=;A=c|j|di}||jd<|j|d}|j|}|j }|j|d|d<|j|d|d<||j|<|j |j|_|j |jdy) NrjrcurrencyavailableBalancefree holdBalanceusedr)rarrssafe_currency_codeaccount safe_balancer)rYrurrj currencyIdcoders r[handle_balancezkucoinfutures.handle_balance s"w3# V%%dJ7 &&z2,,.**41CD**4?$ T((6 t||Y/r\c>|j|j||yre)rbfetch_balance_snapshot)rYrurrs r[rz)kucoinfutures.handle_balance_subscription's 4..@r\c2K|jd{|jd}|j|jddd}d|i}|j |d{}t |j }tdt|D]=}||} | dk7s| dk7s| d k7s| d k7s | d k7s&| d k7s,|| |j| <?|j|d i|jd <|j|j|y77w) Nrr% defaultTyperFrrrrtotalrrr) rcheck_required_credentials safe_string_2rT fetch_balancerrrrrrar) rYrurr selectedTypererrrrs r[rz$kucoinfutures.fetch_balance_snapshot*s!!! '') ))$,, W]^ L ++F33DHMMO$q#d)$ 4A7Dv~$&.TW_Q\I\aeisasx|AGyG%-d^ T" 4 $xD Vt||[1_ "4sGDDA D#D$?D$D*D0D6D<DADDc \|j|d}|j|j|j|j|j |j |j|j|j|j|jd }|j||}| |||yy)Nsubject) level2rz candle.sticktickerV2zavailableBalance.changerr orderChange orderUpdatedzposition.changezposition.settlementzposition.adjustRiskLimit) rsr]rr/rrrrrra)rYrurrmethodsrs r[handle_subjectzkucoinfutures.handle_subject\s""7I6,,(( --++'+':':&&,, --#33#'#7#7(,(<(<  '2   67 # r\ elementNamec ||dz|zS|dzS)N@zs@allrf)rYrrs r[rzkucoinfutures.get_message_hash{s#  $v- -( (r\c>t|j}|ddS)NrR)rr)rr)rYrurs r[rRzkucoinfutures.pings%" #  r\c0|j|_|Sre) millisecondslastPongrgs r[ handle_pongzkucoinfutures.handle_pongs++-r\c |j|dd}|dk(r4d}|jjddk\rd}d|jd|<|j dd|jdd||dd y) Nrjrztoken is expiredr_zconnectId=privaterr^r`)rsrrTrT handle_errors)rYrurrjrs r[handle_error_messagez"kucoinfutures.handle_error_messagesw4 % %Dzz23q8 )-DLL  & 4vzz4tWdTXYr\c|j|d}||jvry|j|j|}|j|j|}|j|=|j|d}| |||||j|dd}|ro|j |dg}|j |dg} t dt |D]} || } | | } |j|| | !|j|yy)NrrrFrrr) rsrra safe_boolr+rrclean_unsubscription clean_cache) rYrurrrrrisUnSubrrrrsubHashs r[handle_subscription_statusz(kucoinfutures.handle_subscription_statuss  gt ,f*** ++F,@,@"Ev';';=MN   $x8   67L 1..}eD  NN<"MM#~~l)C)) 6 & Z6Z"++4 $V $r\r)ccxt.async_supportccxt ccxt.async_support.base.ws.cacherrrccxt.base.typesrrrr r r r r rrr!ccxt.async_support.base.ws.clientrtypingrccxt.base.errorsrr async_supportrrfr\r[rsB ffpppp4*.y$D&&44y$r\