E#iSSKrSSKJrJrJr SSKJrJrJ r J r J r J r J r JrJrJrJrJr SSKJr SSKJr SSKJr SSKJr "SS \R4R65rg) N) ArrayCacheArrayCacheBySymbolByIdArrayCacheByTimestamp) AnyBalancesBoolIntOrder OrderBookPositionStrStringsTickerTickersTrade)Client)List) ExchangeError)ArgumentsRequiredc ^\rSrSrS\4U4Sjjr04Sjr04SjrSr04Sjr 04Sjr 0S 4S \ 4S jjr 04S \ S\4S jjrS 04S\S\4SjjrS\4SjrS 04S\S\4SjjrS 04S\ S\4SjjrS\4SjrSASjrS 04S \S\4SjjrSrS\S \ 4SjrSrS\4SjrS S 04S \ S\ S\ S\!\"4Sjjr#S S 04S\!\ S\ S\ S\!\"4Sjjr$04S \ S\4S jjr%04S\!\ S\4S!jjr&S\4S"jr'S#S S 04S \ S$\ S\ S\ S\!\(4 S%jjr)S\4S&jr*S 04S \ S\ S\+4S'jjr,S 04S\!\ S\ S\+4S(jjr-04S \ S\4S)jjr.04S\!\ S\4S*jjr/S+r0S,r1S\4S-jr2S.r3S\4S/jr4S S S 04S \S\ S\ S\!\54S0jjr6S1r7SAS2jr8S\4S3jr904S\:4S4jjr;S\4S5jrS\4S8jr?SAS9\ S \4S:jjr@S\4S;jrAS\4S<jrBS\S\C4S=jrDS\4S>jrES\4S?jrFS@rGU=rH$)B kucoinfuturesreturnc>UR[[U]50SS_SS_SS_SS_SS_SS_S S_S S_S S_S S_S S_SS_SS_SS_SS_SS_SS_SS0ESSSSSSSSSSSSS S!. S"S#S$.S%S&S'S(.SSS).S*.S+UR0S,.5$)-NwsTwatchLiquidationsFwatchLiquidatinsForSymbolswatchMyLiquidationswatchMyLiquidationsForSymbols watchTicker watchTickers watchBidsAsks watchTrades watchOHLCVwatchOrderBook watchOrders watchBalance watchPositionwatchPositionswatchPositionForSymbolswatchTradesForSymbolswatchOrderBookForSymbols1min5min15min30min1hour2hour4hour8hour12hour1day1week1month) 1m3m5m15m30m1h2h4h8h12h1d1w1Mfuturemargin)swapcross) snapshotDelaysnapshotMaxRetries)fetchPositionSnapshotawaitPositionSnapshot) timeframesaccountsByType tradesLimitr%r(ping)hasoptions streaming) deep_extendsuperrdescriberT)self __class__s P/home/james-whalen/.local/lib/python3.13/site-packages/ccxt/pro/kucoinfutures.pyrZkucoinfutures.describestmT C Ed#U-e&t  0  t  td!$t !% *5!"(#$+D%,!  ""!!!!# !" %% # $%'*+# .2-1"E&V yBH B B c# U(aSOSnURURS05nURXC5nUb UIShvN $URURX5XC'X@RS'XCnUIShvN $N>N7f)Nprivatepublicurls) safe_valuerVspawnnegotiate_helper)r[privateChannelparams connectIdrcrFs r] negotiatekucoinfutures.negotiateVs!/IX t||VR81  < **T%:%:NS# V| s$ABB9B>B?BBc# SnU(aSOSnU(aURU5IShvN nOURU5IShvN nURUS05nURUS/5nURUS5nURUS5nUR US5n UR US5n U S -UR U UUS .5-n UR U 5n XlU $NN![aJn URURS U5nURU 5 URS U Sn A gSn A ff=f7f) NrarbdatainstanceServersr pingIntervalendpointtoken?)rqrgrirc) futuresPrivatePostBulletPrivatefuturesPublicPostBulletPublicrd safe_integer safe_string urlencodeclient keepAlive ExceptionrVreject)r[rgrhresponserirmrnfirstInstanceServerrorprqresultrxerFs r]rfkucoinfutures.negotiate_helperdsJ!/IX ' 0!%!E!Ef!MM&"&!C!CF!KK??8VR8D"ood4ErJO"&///1"E ,,-@.QL''(;ZHH$$T73E^dnn"0&6'F [[(F+ MCN&L 0__T\\&%99EF MM!  V$Y/  0sREC1C-C1C/B%C1,E-C1/C11 E;AE;EEEc|URURURSS5S5nXRS'U$)N requestIdr)sumrurV)r[rs r] request_idkucoinfutures.request_ids7HHT..t||[!LaP $- [!r_c# [UR55nUSUSS.nURXu5nSU0n UcU nOURX5nURXXU5IShvN $N7f)N subscribeTidtypetopicr|r)strrextendwatch) r[url messageHashsubscriptionHash subscriptionrhrrequestmessagesubscriptionRequests r]rkucoinfutures.subscribes{)* %   ++g. )%   .L;;':ILZZ'\ZZZZsA#A,%A*&A,c# [UR55nUSUSS.nURXURX5XE5IShvN $N7f)NrTr)rrwatch_multipler) r[r messageHashesrsubscriptionHashessubscriptionArgsrhrrs r]subscribe_multiple kucoinfutures.subscribe_multiples\)*    ((T[[=Y[mAA AAsAAA  ANrcT# [UR55nUSUSS.nURX5n UbXvU'URU5n [ S[ U55H&n XKn XR ;dMXR U'M( URXXU5IShvN $N7f)N unsubscribeTrr)rrrrxrangelen subscriptionsr) r[rrrrrhrrrrrxirs r]un_subscribe_multiple#kucoinfutures.un_subscribe_multiples)* !   ++g.  #&/ #S!q#012A14 $(<(<<2B$$Y/3((WZfggggsA3B(9(B(!B&"B(symbolc# UR5IShvN URU5nUSnSUS'URU/U5IShvN nXA$N>N 7f)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 ` Nrr callerMethodName) load_marketsmarket watch_tickers)r[rrhrtickerss r] watch_tickerkucoinfutures.watch_tickerse!!!V$!%2!"**F8V<< "=s!AA5A A AAsymbolsc# UR5IShvN URSSX5IShvN nUR(a 0nX4US'U$URURSU5$NXN?7f)ax 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 ` Nr!z/contractMarket/ticker:r)rwatch_multi_request newUpdatesfilter_by_arrayrr[rrhtickerrs r]rkucoinfutures.watch_tickerssq!!!//@Y[bkk ??G(.F8$ %N##DLL(GDD "ksA3A/A3A1>A31A3rxcURUS05nURUS5nURUSS5nURX55nX`RUS'UR X`R SUS55 g)Nrmr-r)rd safe_market parse_tickerrresolveget_message_hash)r[rxrrmmarketIdrrs r] handle_tickerkucoinfutures.handle_tickersy,w3??42!!(D#6""40)/ VH%&v44Xvh?OPQr_c# URSSX5IShvN nUR(a 0nX4US'U$URURSU5$N=7f)ae 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_askskucoinfutures.watch_bids_askss]//A\^enn ??G(.F8$ %N##DMM8WEE osAA>A channelNamec# UR5IShvN URUSU5upUS:HnURUSSSS5n[U5nUS:a[ UR S-U-S-5e/n[ S[U55HFnX8n URU 5n U(aS OS n URURXS 55 MH URS5IShvN n URU5n S RU 5n[UR55nUS X.-SS.nSU0nURXUR!UU5UU5IShvN $GNQN{N 7f)Nrr"FTd z#() accepts a maximum of 100 symbolsrbidaskrr,rrr)rhandle_param_stringmarket_symbolsrrrrrappendrrj market_idsjoinrrrr)r[ methodNamerrrh isBidsAskslengthrrrrprefixr marketIdsjoinedrrrs r]r!kucoinfutures.watch_multi_requestst!!!!55f>PR\]  O3 %%gtUD%HW C<#DGGcMJ$>Af$fg g q#g,'AZF[[(F!+XF  !6!6vh?O!P Q ( NN5))OOG, )$)*  )   ) ((T[[RX=Y[hjvwww5 "*xs5E.E'CE..E*/A3E."E,#E.*E.,E.cURU5nUSnX0RU'URX0RSU55 g)Nrr)parse_ws_bid_askrrr)r[rxr parsedTickerrs r]handle_bid_askkucoinfutures.handle_bid_ask/sC",,W5 h' , f|%:%:8V%LMr_c URUS05nURUS5nURXB5nURUS5nURUSS5nUR UUUR U5UR US5UR US5UR US5UR US5US .U5$) Nrmrtsư> bestAskPrice bestAskSize bestBidPrice bestBidSize)r timestampdatetimeask askVolumebid bidVolumeinfo) safe_dictrvrsafe_integer_product safe_tickeriso8601 safe_number)r[rrrmrrrs r]rkucoinfutures.parse_ws_bid_askEs~~ffb1##D(3!!(3!!&(3--dD(C " Y/##D.9))$ >##D.9))$ > !    r_c b# Uc[URS-5eUR5IShvN URS5IShvN nUR U5nSUS-nSS0nSUS-nUR U5nUR X5 URS S S5n URS S S5n URU5n U (a(U (a!U cURS U-5IShvN n U $URX7USURXb55IShvN $NNN5N 7f) aF 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:rrg position:rr(rOrPfetchPositionSnapshot:) rrrrjrrxset_position_cache handle_optionget_current_positionrFrr) r[rrhrrrrrrxrOrPcurrentPositionsnapshots r]watch_positionkucoinfutures.watch_positionVs0 >#DGG.[$[\ \!!!NN4((V$%t 4 d "F8$44 S! / $ 2 2?D[]a b $ 2 2?D[]a b33F; %:?V#]]+Cf+LMMHO^^CeT4;;wC_```! "(N`sF/D/D'D/ D) B*D/5D+6,D/"D-#D/)D/+D/-D/cURcgURRnURX!05n[UR 55nURUS5$Nr) positionshashmaprdlistvalues)r[rcache symbolCachers r]r"kucoinfutures.get_current_positiontsR >> !&&ooeR8 k((*+vq))r_cURSSS5nU(aDSU-nXAR;a/URU5 URURXU5 ggg)Nr(rOFr)rfuturesrFreload_position_snapshot)r[rxrrOrs r]r kucoinfutures.set_position_cache|s\ $ 2 2?D[]b c 2V;K>>1 k* 466VT2 !r_c# URU5IShvN n[5UlURnURU5 URUnUR U5 UR USU-5 gNf7f)Nr)fetch_positionrrrrr)r[rxrrpositionrrFs r]r$kucoinfutures.load_position_snapshotsi,,V44/1 X ,uxv!565sBA>A'Bc URUSS5nURS5nURUS5nURUSS5nURnUR U5nSU-n UR US05n UR U 5n [U R55n [S[U 55Hn XnXbMX M URX5nURU5 URX5 g)Nr:rrrmr)rvsplit safe_symbolrrrdparse_positionrkeysrrrrr)r[rxrrpartsrrrrrrm newPositionrrkeyr s r]handle_positionkucoinfutures.handle_positionsz  '26 C ##E1-!!(D"533F;!F* w3))$/ K$$&'q#d)$A'C'$%;;< Xx-r_sincelimitcF# URU/X#U5IShvN $N7f)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)r[rrrrhs r] watch_tradeskucoinfutures.watch_tradess$22F8U6RRRRs !!c# [U5nUS:Xa[URS-5eUR5IShvN UR U5nUR S5IShvN nUR U5nUR U5nSSRU5-n/n /n [S[U55H3n Xn X{n U RSU -5 U RSU -5 M5 URXjXSU5IShvN nUR(a6URUS5nURUS5nURUU5nURXUS S 5$GN,GNNe7f) av 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)rrrrrrjrrrrrrrdrvgetLimitfilter_by_since_limit)r[rrrrh symbolsLengthrrrrrrrrtradesfirst tradeSymbols r]r&kucoinfutures.watch_trades_for_symbols saG A #DGG.n$no o!!!%%g.NN5))%%g.OOG, ,sxx /BB q#g,'AZF |H  V!3 4  % %&BX&M N ( ..s5^bdjkk ??OOFA.E**5(;KOOK7E))& TRR% ")ls6=E3E+)E3)E.*B!E3 E1 A E3.E31E3cD# URU/U5IShvN $N7f)a6 unWatches trades stream https://docs.kucoin.com/futures/#execution-data :param str symbol: unified symbol of the market to fetch trades for :param dict [params]: extra parameters specific to the exchange API endpoint :returns dict[]: a list of `trade structures ` N)un_watch_trades_for_symbolsr[rrhs r]un_watch_tradeskucoinfutures.un_watch_trades+s"55vhGGGG   c# UR5IShvN URUSS5nURS5IShvN nURU5nURU5nSSR U5-n/n/n[ S[ U55H/nXn URSU -5 URSU -5 M1 UUSS US .n URX7XWX*5IShvN $NNN7f) z 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 ` NFrrrzunsubscribe:trades:rr#T)rsubMessageHashesrrr) rrrjrrrrrr) r[rrhrrrrrrrrs r]r()kucoinfutures.un_watch_trades_for_symbols7s!!!%%gtU;NN5))%%g.OOG, ,sxx /BB q#g,'AZF  !6!? @  % %i&&8 9( + 2  //EZ`ooo' ")"ps4C2C,+C2C.B$C2'C0(C2.C20C2cPURUS05nURU5nUSnURURU5nUc6URURSS5n[ U5nX`RU'UR U5 SU-nURXh5 U$)NrmrrSrJr)rd parse_trader#rurVrrr) r[rxrrmtraderr#rrs r] handle_tradekucoinfutures.handle_tradeSs*w3  &xf5 >%%dllM4HE&F"(KK  e&( v+r_r9 timeframec# UR5IShvN URU5nURS5IShvN nURU5nUR UR S5nUR XU5n SU-S-U -n SU-S-U-n URXkU SU5IShvN n UR(aU RX5nURXUSS5$NNN>7f) 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 NFrQz/contractMarket/limitCandle:_ohlcv::rT) rrrj market_idrrVrvrrr r!) r[rr5rrrhrrrQ timeframeIdrrohlcvs r] watch_ohlcvkucoinfutures.watch_ohlcvus!!!V$NN5))>>&)^^DLL,? &&ziH .9C?+M&(3.: nnSudFKK ??NN61E))%q$GG ") Ls4C2C,)C2C.A0C21C02;C2.C20C2c URUS5nURS5nURUS5nURUS5nURURS5nUR XW5nURUS5n UR U 5n SU -S-U-n UR US5n URU S 5URU S5URU S 5URU S 5URU S 5URU S 5/n URURU 05URU 'XRU ;a8URURSS5n[U5URU U'URU UnURU 5 URX5 g)Nrr7rrmrQrr8candlesrrL OHLCVLimitrJ) rvrrrVfind_timeframer safe_listrurohlcvsrrr)r[rxrrrr:rmrQr5rrrr;parsedrstoreds r] handle_ohlcvkucoinfutures.handle_ohlcvs*  '2 C &&ua0 ~~gv.^^DLL,? '' @ ##D(3!!(+&(3.: tY/   eQ '   UA &   UA &   UA &   UA &   UA &  #nnT[[&"E F[[00%%dllL$GE-B5-IDKK  *V$Y/ fv+r_cD# URU/X#5IShvN $N7f)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)r[rrrhs r]watch_order_bookkucoinfutures.watch_order_books""66xOOOOr,c# [U5nUS:Xa[URS-5eUb$US:waUS:wa[URS-5eUR 5IShvN UR U5nUR U5nURS5IShvN nSS RU5-nS U0n/n /n [S[U55H3n Xn X[n U RS U -5 U RSU -5 M5 URXjXyX5IShvN nUR5$NNN7f) 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 symbolsNrKrz8 watchOrderBook 'limit' argument must be None, 20 or 100F/contractMarket/level2:rr orderbook:) rrrrrrrrjrrrrr)r[rrrhr"rrrrrrrrr orderbooks r]rL*kucoinfutures.watch_order_book_for_symbolssDG A #DGG.q$qr r   %3,#DGG.h$hii!!!%%g.OOG, NN5)))CHHY,?? U"   q#g,'AZF |H  !6 7  % %&?(&J K ( 11#eaqzz   ! "*{s7A$D?&D9':D?!D;"BD?$D=%D?;D?=D?cD# URU/U5IShvN $N7f)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_symbolsr)s r]un_watch_order_book!kucoinfutures.un_watch_order_books"996(FKKKKr,c# UR5IShvN URU5nURU5nURS5IShvN nSSR U5-n/n/n[ S[ U55H/nXn URSU -5 URSU -5 M1 UUSS US .n URXGXWX*5IShvN $NNN7f) aa 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 NFrPrrzunsubscribe:orderbook:rQTrR)rrrrr.) rrrrjrrrrr) r[rrhrrrrrrrrs r]rU-kucoinfutures.un_watch_order_book_for_symbolss!!!%%g.OOG, NN5)))CHHY,?? q#g,'AZF  !9F!B C  % %lV&; <( + 2  //EZ`ooo% "*ps4CC:CCBCCCCCcURUS5US'URUS5nX1S'URU5US'URUS05nURS5nUR US5nUR US5nUR US 5nUS :XaS OS n Xh/n U S :XaUS n U R U 5 gUS n U R U 5 g) Nsequencenoncerrchangerrrr@buybidsasks)rurrdrrrv storeArray) r[rRdeltarr] splitChangepricesidequantityrvalue storedBids storedAskss r] handle_deltakucoinfutures.handle_deltas!..ujA '%%e[9 !*+ $ Y 7 *"5ll3'   a0 Q/##K3%-vf! 6>"6*J  ! !% ("6*J  ! !% (r_cd[S[U55HnURXU5 M gr)rrrj)r[booksidedeltasrs r] handle_deltaskucoinfutures.handle_deltas.s)q#f+&A   hq 2'r_cURUS5nURUS5nURS5nURUS5nURUSS5nSU-nXpR;aNUR UR U05n URU S5n UR0U 5URU'URUn URU S5n URUS 5n U Gc2[U R5nURS5nURUS5nURUS 5n[UR R55nSn[S [U55HEnUUnURU5S :dMURU5S :dM6UR Un O URUS5n URS S S 5nUU:XaUR!UR"XXz05 U RR%U5 gX:agUR'X5 UR)X5 g)Nrmrr rrrQrr\r[rr%rM)rdrvrr orderbooksrrru order_bookrrrrrfindrreload_order_bookrrjr)r[rxrrmr topicPartsrrrrrstoredOrderBookr\deltaEnd cacheLength topicPartsNew topicSymbol topicChannelrrrrrMs r]handle_order_bookkucoinfutures.handle_order_book2s# w/  '2[[% ##J2!!(D#6"V+ //)#~~f.B.BE2N %%&6@E&*oob%&@DOOF #//&1!!/7;$$T:6 =o334K!KK,M**=!` NTz/contractMarket/tradeOrdersrgordersrr )rrjrrrrr filter_by_symbol_since_limit) r[rrrrhrrrrrrs r] watch_orderskucoinfutures.watch_orderss!!!NN4((- d   [[(FH%F%+f4K~~ctT[[QXEabb ??OOF2E00tTT "(cs2CB=CB?ACC:C?CCc6SSSSSS.nURX!U5$)Nopenclosedcanceled)rfilledmatchupdater)rv)r[statusstatusess r]parse_ws_order_status#kucoinfutures.parse_ws_order_statuss-"  &99r_cpURUS5nURUS5nURUS5nURUS5nURUS5nURUS5nURUS5n URU 5n URUSS 5n URUS 5n UR X5nUS n URUS 5nUR 0S U_S U _S U_SU_SU _SUR U 5_SS_SU_SS_SS_S U_SU_SS_SU_SS_SS_SU_SU SSS.EU5$)NorderId clientOid orderTyperd filledSizesizer orderTimerrrerr clientOrderIdrrlastTradeTimestamp timeInForcepostOnly stopPriceamountcostaverager) remainingrfeer#)rvsafe_string_lowerrrr safe_orderr)r[orderrrrrrdrrrawTyperrrrres r]parse_ws_orderkucoinfutures.parse_ws_orders$  eY /(( < **5+>   0!!%6!!%0""5&1++G4--e[(K ##E84!!(3!%%eV4 E f  "  ]     Y/   !$  I  4    D  U    f  D t! " f# $+ , - r_c|SnURUS5nURU5nURUS5nURUS5nUbURc-UR UR SS5n[ U5UlURn URU RU05n URX5n U b'URU S5n U bXS'U SS :XaS US'U RU5 URURU5 US -U-n URURU 5 gg) Nrrmrr ordersLimitrJrrrr ) rdrrvrrurVrrrr)r[rxrrrmrGrrr cachedOrdersrrrsymbolSpecificMessageHashs r] handle_orderkucoinfutures.handle_orders0 w/$$T*!!&(3""640  {{"))$,, tL4U; ;;L__\%9%962FFOOF4E  OOE;? (*3;'?h.'/F8$    ' NN4;; 4(3c(9F(B % NN4;;(A B# r_c # UR5IShvN URS5IShvN nSnSS0nSUR0nSnURX&X5UR XA55IShvN $N]NFN7f)a7 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/walletrgmethodbalance)rrjhandle_balance_subscriptionrr)r[rhrrrrrs r] watch_balancekucoinfutures.watch_balances!!!NN4(() d  d66  ^^Ce4;;W^Kghhh "(is1A:A4A:A6?A:/A80A:6A:8A:cURUS05nX0RS'URUS5nURU5nUR 5nURUS5US'URUS5US'X`RU'UR UR5UlUR URS5 g) NrmrcurrencyavailableBalancefree holdBalanceusedr)rdrrvsafe_currency_codeaccount safe_balancer)r[rxrrm currencyIdcoders r]handle_balancekucoinfutures.handle_balance s"w3# V%%dJ7 &&z2,,.**41CD**4?$ T((6 t||Y/r_c<URURX5 gr)refetch_balance_snapshot)r[rxrrs r]r)kucoinfutures.handle_balance_subscription's 4..@r_cL# UR5IShvN UR5 SnURURSSS5nSU0nUR U5IShvN n[ UR 55n[S[U55HHnXxn U S:wdMU S:wdMU S :wdMU S :wdM'U S :wdM/U S :wdM7XiURU 'MJ URUS 05URS 'URURU5 gGN N7f) Nrr' defaultTyperHrrrrtotalrrr) rcheck_required_credentials safe_string_2rV fetch_balancerrrrrrdr) r[rxrr selectedTyperhrrrrs r]r$kucoinfutures.fetch_balance_snapshot*s!!! '') ))$,, W]^ L ++F33DHMMO$q#d)$A7Dv~$&.TW_Q\I\aeisasx|AGyG%-^ T"% $xD Vt||[1_ "4sGD$DA D$#D"$=D$%D$-D$5D$=D$D$ AD$"D$c ZURUS5nURURURURUR UR URURURURURS. nURXC5nUb U"X5 gg)Nsubject) level2rz candle.sticktickerV2zavailableBalance.changer orderChange orderUpdatedzposition.changezposition.settlementzposition.adjustRiskLimit) rvr~rrIrrr3rrrd)r[rxrrmethodsrs r]handle_subjectkucoinfutures.handle_subject\s""7I6,,(( --++'+':':&&,, --#33#'#7#7(,(<(<  2   6 # r_ elementNamec"UbUS-U-$US-$)N@zs@allr)r[rrs r]rkucoinfutures.get_message_hash{s#  $v- -( (r_c>[UR55nUSS.$)NrT)rr)rr)r[rxrs r]rTkucoinfutures.pings%" #  r_c0UR5UlU$r) millisecondslastPongrs r] handle_pongkucoinfutures.handle_pongs++-r_c URUSS5nUS:Xa5SnURRS5S:aSnSURSU'UR S SURS0X2005 g ) Nrmr ztoken is expiredrbzconnectId=privaterrarcrT)rvrrurV handle_errors)r[rxrrmrs r]handle_error_message"kucoinfutures.handle_error_messagesw4 % %Dzz23q8 )-DLL  & 1b&**b"dRLr_cURUS5nX1R;agURURU5nURURU5nURU URUS5nUb U"XU5 URUSS5nU(anUR US/5nUR US/5n [ S[ U55Hn Xn Xn URXU 5 M URU5 gg)NrrrFrr.r) rvrrd safe_boolrErrclean_unsubscription clean_cache) r[rxrrrrrisUnSubrr.rrsubHashs r]handle_subscription_status(kucoinfutures.handle_subscription_statuss   gt ,*** ++F,@,@"Ev';';=MN   $x8   6L 1..}eD  NN<"MM#~~l)C)) 6 & 6t$++4 $V $ $r_r)ccxt.async_supportccxt ccxt.async_support.base.ws.cacherrrccxt.base.typesrrrr r r r r rrrr!ccxt.async_support.base.ws.clientrtypingrccxt.base.errorsrr async_supportrrr_r]rsB ffvvvv4*.z$D&&44z$r_