E#iSSKrSSKJrJrJr SSKJrJrJ r J r J r J r J r JrJrJrJr SSKJr SSKJr SSKJr SSKJr "SS \R2R45rg) N) ArrayCacheArrayCacheBySymbolByIdArrayCacheByTimestamp) AnyBalancesBoolIntOrder OrderBookStrStringsTickerTickersTrade)Client)List) ExchangeError)ArgumentsRequiredc ^\rSrSrS\4U4Sjjr04Sjr04SjrSr0S4Sjr 0S4S \ 4S jjr 0S4S jr 0S4S \ 4S jjr 04S \S\4Sjjr04S \S\4SjjrS04S\S\4SjjrS\4SjrS04S\S\4SjjrS04S\S\4SjjrS\4SjrS?SjrSSS04S \S\S\S\S\\4 SjjrS04S \S\S\\4SjjrS\4Sjr SS04S \S\S\S\\!4S jjr"SS04S\\S\S\S\\!4S!jjr#04S\\S\4S"jjr$04S \S\4S#jjr%S\4S$jr&S04S \S\S\'4S%jjr(04S \S\4S&jjr)S04S\\S\S\'4S'jjr*04S\\S\4S(jjr+S\4S)jr,S*r-S+r.S,r/S\4S-jr0S\4S.jr1S\4S/jr2SSS04S \3S\S\S\\44S0jjr5S1r6S?S2jr7S\4S3jr8SSS04S \3S\S\S\\!4S4jjr9S\4S5jr:S?S6jr;04S\<4S7jjr=S\4S8jr>S\4S9jr?S\4S:jr@S\4S;jrAS\S\B4S<jrCS\4S=jrDS>rEU=rF$)@kucoinreturnc >UR[[U]50SS_SS_SS_SS_SS_SS_S S_S S_S S_S S_S S_SS_SS_SS_SS_SS_SS_SSSSSSSS.ESSS0SSSS.SS0S.SUR0S .5$)!NwsT createOrderWsF editOrderWsfetchOpenOrdersWs fetchOrderWs cancelOrderWscancelOrdersWscancelAllOrdersWs watchBidsAskswatchOrderBook watchOrders watchMyTrades watchTickers watchTicker watchTradeswatchTradesForSymbolswatchOrderBookForSymbols) watchBalance watchOHLCV unWatchTicker unWatchOHLCVunWatchOrderBook unWatchTradesunWatchhTradesForSymbolsnamezmarket/snapshot/market/level2) snapshotDelaysnapshotMaxRetriesmethodr9/spotMarket/tradeOrders) tradesLimitr'r#r%ping)hasoptions streaming) deep_extendsuperrdescriber<)self __class__s I/home/james-whalen/.local/lib/python3.13/site-packages/ccxt/pro/kucoin.pyrBkucoin.describesTfd < >du$U      !%$U !$t tt (!"+D#$!%"!% $$(!%,016 $- &'*+.# 7" $ S/A / / c# U(aSOSnURURS05nURXC5nUb UIShvN $URURX5XC'X@RS'XCnUIShvN $N>N7f)Nprivatepublicurls) safe_valuer>spawnnegotiate_helper)rCprivateChannelparams connectIdrKfutures rE negotiatekucoin.negotiateCs!/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) NrIrJdatainstanceServersr pingIntervalendpointtoken?)rZrOrQrK) privatePostBulletPrivatepublicPostBulletPublicrL safe_integer safe_string urlencodeclient keepAlive Exceptionr>reject)rCrOrPresponserQrVrWfirstInstanceServerrXrYrZresultraerRs rErNkucoin.negotiate_helperQsJ!/IX ' 0!%!>!>v!FF&"&!)rCrks rE request_idkucoin.request_id~s7HHT..t||[!LaP $- [!rGNc# [UR55nUSUSS.nURXt5nURU5n X9R;aX9RU'UR XXU5IShvN $N7f)N subscribeTidtypetopicre)strrnextendra subscriptionswatch) rCurl messageHashsubscriptionHashrP subscriptionrkrequestmessageras rErqkucoin.subscribesz)* %   ++g.S! $8$88.>  +ZZ'\ZZZZsA6A?8A=9A?r}cH# URX/X4/XV5IShvN $N7fN)un_subscribe_multiple)rCrzr{rur|rPr}s rE un_subscribekucoin.un_subscribes&//]EK]_etttts " "cF# [UR55nUSUSS.nURX5n URU5n [ S[ U55H&n XKn XR ;dMXR U'M( URXXU5IShvN $N7f)NrqTrrrrvrnrwrarangelenrxwatch_multiple rCrz messageHashesrusubscriptionHashesrPr}rkr~rrair|s rEsubscribe_multiplekucoin.subscribe_multiples)*    ++g.S!q#012A14 $(<(<<2B$$Y/3((WZfggggsA,B!2(B!BB!cT# [UR55nUSUSS.nURX5n UbXvU'URU5n [ S[ U55H&n XKn XR ;dMXR U'M( URXXU5IShvN $N7f)N unsubscribeTrrrrrs rErkucoin.un_subscribe_multiples)* !   ++g.  #&/ #S!q#012A14 $(<(<<2B$$Y/3((WZfggggsA3B(9(B(!B&"B(symbolc$# UR5IShvN URU5nUSnURS5IShvN nURUSSS5upVUS-US-nS U-nUR XHXv5IShvN $NsNFN7f) 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/spot-trading/public-channels/market-snapshot :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 ` NrFr'r9/market/snapshot:rsticker:) load_marketsmarketrShandle_option_and_paramsrq) rCrrPrrzr9queryrur{s rE watch_tickerkucoin.watch_tickers!!!V$!NN5))55fmXWij  vd|+&( ^^CeCCC "*Ds3BB .BB ?BBB BBcJ# UR5IShvN URU5nUSnURS5IShvN nSnURUSSS5upRUS-US-nS U-nS U-nU/U/S S U/S .n UR XGXhX)5IShvN $NNYN7f)a unWatches 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/spot-trading/public-channels/market-snapshot :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 ` NrFr'r9rrrszunsubscribe:ticker:rtradesTrsubMessageHashesrursymbols)rrrSrr) rCrrPrrzr9rur{subMessageHashr}s rEun_watch_tickerkucoin.un_watch_tickers!!!V$!NN5))66v}hXjk vd|++f4 "V+)]!/ 0x  &&sPVeee! "*fs4B#B.B#BAB#B!B#B#!B#rc# UR5IShvN URU5nSnSnURUSSS5upB/n/nUb_[S[ U55HFnXnUR SU-5 UR U5n UR US-U S -5 MH URS 5IShvN n Sn Uc3US -n URXX5IShvN n UR(aU $O_URU5n US-S RU 5-nURXXU5IShvN n UR(a 0nXU S 'U$URURS U5$GNcNNND7f)a* https://www.kucoin.com/docs/websocket/spot-trading/public-channels/ticker 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 :param str [params.method]: either '/market/snapshot' or '/market/ticker' default is '/market/ticker' :returns dict: a `ticker structure ` Ntickersr&r9z/market/tickerrrrrsFz:all,r)rmarket_symbolsrrrappendrrSrq newUpdates market_idsjoinrfilter_by_arrayr)rCrrPr{r9rtopicsrrrrzrallTopic marketIds symbolsTopicnewDicts rE watch_tickerskucoin.watch_tickerss!!!%%g. 66v~xYij   1c'l+ $$Y%78V, fslVD\9: , NN5)) ?H NN3XNNG0I!C<#((9*==L 33C ^deeG "-4)*##DLL(GDD9 "*O fsGFE9B)FE<#F$E>%AF;F<>F<F>FFracURUS5nSnUbRURS5nURUS5nSnUS:XaURUS5nOUnURXtS5nURUS05nURUSU5n UR X5n U Sn XR U 'S U -n UR X5 0n XU 'UR U S 5 g) Nrurrlallsubject-rVrrr)r_split safe_marketrL parse_tickerrresolve)rCrarrurpartsfirstmarketIdrV rawTickertickerrr{ allTickerss rE handle_tickerkucoin.handle_tickersn  '2  KK$E$$UA.EH~++GY? %%h` r"z/spotMarket/level1:Nr)watch_multi_helperrrbidsasks)rCrrPrrs rEwatch_bids_askskucoin.watch_bids_asks\s]..@UW^gg ??G(.F8$ %N##DMM8WEE hsAA>A channelNamect# UR5IShvN URUSSSS5n[U5nUS:a[URS-U-S-5e/n[ S[U55H/nX7nUR U5n URSU S-5 M1 URS5IShvN n URU5n S RU 5n [UR55n U S X,-SS .nURX5nURXX5IShvN $GNNvN 7f) NFTd z#() accepts a maximum of 100 symbolsrbidask@rrrqrr)rrrrrsrrrrSrrrvrnrwr)rC methodNamerrrPlengthrrrrrzrjoinedrkr~rs rErkucoin.watch_multi_helperms0!!!%%gtUD%HW C<#DGGcMJ$>Af$fg g q#g,'AZF[[(F  VH-=!= >(NN5))OOG, )$)*  )   ++g.((WTTT+ "*Us5D8D1B&D8=D4>A.D8,D6-D84D86D8cxURU5nUSnX0RU'SU-nURX55 g)Nrr)parse_ws_bid_askrr)rCrar parsedTickerrr{s rEhandle_bid_askkucoin.handle_bid_asks@,,W5 h' , f&( |1rGc URUS5nURS5nUSnURXR5nURUS5nURUS05nUR US/5nUR US/5n UR US5n UR UU URU 5URUS 5URUS5URU S 5URU S5US .U5$) NrurrlrrVasksbids timestampr)rrdatetimeask askVolumebid bidVolumeinfo) r_rr safe_dict safe_listr^ safe_tickeriso8601 safe_number) rCrrrurrrrVrrrs rErkucoin.parse_ws_bid_asks  1 C 8!!(3!!&(3~~ffb1nnT62.nnT62.%%dK8 " Y/##C+))#q1##C+))#q1 !    rG1m timeframesincelimitc# UR5IShvN URS5IShvN nURU5nUSnURURX"5nSUS-S-U-n SU-S-U-n UR XjX5IShvN n UR (aU RX5nURXUS S 5$NNN>7f) a] watches historical candlestick data containing the open, high, low, and close price, and the volume of a market https://www.kucoin.com/docs/websocket/spot-trading/public-channels/klines :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 NFr/market/candles:rs_candles:rrT) rrSrr_ timeframesrqrgetLimitfilter_by_since_limit) rCrrrrrPrzrperiodrur{ohlcvs rE watch_ohlcvkucoin.watch_ohlcvs!!!NN5))V$!!!$//9H"VD\1C7&@ 6)C/); nnSuEE ??NN61E))%q$GG ") Fs2CCCCA$CC;CCCcp# UR5IShvN URS5IShvN nURU5nUSnURURX"5nSUS-S-U-nSU-S-U-nS U-S-U-n U/U /S S U/S .n UR XHXxX:5IShvN $NNN7f) a unWatches historical candlestick data containing the open, high, low, and close price, and the volume of a market https://www.kucoin.com/docs/websocket/spot-trading/public-channels/klines :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 NFrrrsrzunsubscribe:candles:rrrTr)rrSrr_rr) rCrrrPrzrrrur{rr}s rEun_watch_ohlcvkucoin.un_watch_ohlcvs!!!NN5))V$!!!$//9H"VD\1C7&@,v5;iG #f,s2Y>)]!/ 0x  &&sVbbb ")cs2B6B0B6B2A;B6+B4,B62B64B6cURUS05nURUS5nURUS/5nURUS5nURS5nURUS5nURU5n UR U5n U Sn SU -S-U -n URUR U 05UR U 'URUR U U 5n U c9UR URS S 5n[U5n XR U U 'URXZ5nU RU5 URX5 g) NrVrcandlesrurrlrr OHLCVLimitr2) rLr_rfind_timeframerohlcvsr^r>r parse_ohlcvrr)rCrarrVrrrurintervalrrrr{storedrrs rE handle_ohlcvkucoin.handle_ohlcvsB*w3##D(3//$ 26  '2 C ##E1-''1 !!(+! 6)C/); "oodkk62F FV!4i@ >%%dllL$GE*51F-3KK  *  1 ev+rGcF# URU/X#U5IShvN $N7f)a get the list of most recent trades for a particular symbol https://www.kucoin.com/docs/websocket/spot-trading/public-channels/match-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)rCrrrrPs rE watch_tradeskucoin.watch_tradess$22F8U6RRRRs !!c# [U5nUS:Xa[URS-5eUR5IShvN UR U5nUR U5nUR S5IShvN n/n/n SSRU5-n [S[U55H3n Xn URSU -5 Xkn U RSU -5 M5 URXxXU5IShvN nUR(a6URUS5nURUS5nURUU5nURXUS S 5$GNNNd7f) a get the list of most recent trades for a particular symbol https://www.kucoin.com/docs/websocket/spot-trading/public-channels/match-execution-data :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/market/match:rtrades:rrT)rrrsrrrrSrrrrrrLr_rr)rCrrrrP symbolsLengthrrzrrrurrrrr tradeSymbols rErkucoin.watch_trades_for_symbolssPG A #DGG.n$no o!!!%%g.OOG, NN5))  388I#66q#g,'AZF  V!3 4 |H  % %&6&A B ( ..s5^dee ??OOFA.E**5(;KOOK7E))& TRR# "*fs6=E E:E :E;A>E 9E:A E E E c# UR5IShvN URUSS5nURU5nURS5IShvN n/n/nSSR U5-n[ S[ U55H/nXn URSU -5 URSU -5 M1 UUSS US .n URXEXuX*5IShvN $NNN7f) a. unWatches trades stream https://www.kucoin.com/docs/websocket/spot-trading/public-channels/match-execution-data :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 rTr) rrrrSrrrrr) rCrrPrrzrrrurrr}s rEun_watch_trades_for_symbols"kucoin.un_watch_trades_for_symbols>s!!!%%gtU;OOG, NN5))  388I#66q#g,'AZF  !6!? @  % %i&&8 9( + 2  //EZ`ooo% "*ps4C!C` N)rrCrrPs rEun_watch_tradeskucoin.un_watch_trades\s"55vhGGGG   cNURUS05nURU5nUSnSU-nURURU5nUc6URURSS5n[ U5nXpRU'UR U5 URXv5 g)NrVrr r;r2)rL parse_traderr^r>rrr) rCrarrVtraderr{rrs rE handle_tradekucoin.handle_tradehs(w3  &x&( f5 >%%dllM4HE&F"(KK  ev+rGcD# URU/X#5IShvN $N7f)a https://www.kucoin.com/docs/websocket/spot-trading/public-channels/level1-bbo-market-data https://www.kucoin.com/docs/websocket/spot-trading/public-channels/level2-market-data https://www.kucoin.com/docs/websocket/spot-trading/public-channels/level2-5-best-ask-bid-orders https://www.kucoin.com/docs/websocket/spot-trading/public-channels/level2-50-best-ask-bid-orders 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 :param str [params.method]: either '/market/level2' or '/spotMarket/level2Depth5' or '/spotMarket/level2Depth50' default is '/market/level2' :returns dict: A dictionary of `order book structures ` indexed by market symbols N)watch_order_book_for_symbols)rCrrrPs rEwatch_order_bookkucoin.watch_order_books"<66xOOOOrcD# URU/U5IShvN $N7f)a~ https://www.kucoin.com/docs/websocket/spot-trading/public-channels/level1-bbo-market-data https://www.kucoin.com/docs/websocket/spot-trading/public-channels/level2-market-data https://www.kucoin.com/docs/websocket/spot-trading/public-channels/level2-5-best-ask-bid-orders https://www.kucoin.com/docs/websocket/spot-trading/public-channels/level2-50-best-ask-bid-orders unWatches 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 dict [params]: extra parameters specific to the exchange API endpoint :param str [params.method]: either '/market/level2' or '/spotMarket/level2Depth5' or '/spotMarket/level2Depth50' default is '/market/level2' :returns dict: A dictionary of `order book structures ` indexed by market symbols N)un_watch_order_book_for_symbolsrs rEun_watch_order_bookkucoin.un_watch_order_books"996(FKKKKrc4# [U5nUS:Xa[URS-5eUb0US:wa*US:wa$US:waUS:wa[URS-5eUR 5IShvN UR U5nUR U5nURS 5IShvN nSnURUS S S 5upsUS:XdUS:XaS [U5-nUS-SRU5-n/n /n [S[U55H6n Xn U RSU -5 X[n U RUS-U -5 M8 0nUS :XaURUUS.nURXiXX>5IShvN nUR5$GNNN7f)a https://www.kucoin.com/docs/websocket/spot-trading/public-channels/level1-bbo-market-data https://www.kucoin.com/docs/websocket/spot-trading/public-channels/level2-market-data https://www.kucoin.com/docs/websocket/spot-trading/public-channels/level2-5-best-ask-bid-orders https://www.kucoin.com/docs/websocket/spot-trading/public-channels/level2-50-best-ask-bid-orders watches information on open orders with bid(buy) and ask(sell) prices, volumes and other 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 :param str [params.method]: either '/market/level2' or '/spotMarket/level2Depth5' or '/spotMarket/level2Depth50' default is '/market/level2' :returns dict: A dictionary of `order book structures ` indexed by market symbols rzA watchOrderBookForSymbols() requires a non-empty array of symbolsNr2r4z? watchOrderBook 'limit' argument must be None, 5, 20, 50 or 100Fr#r9r6/spotMarket/level2Depthrr orderbook:)r9rr)rrrsrrrrrSrrvrrrhandle_order_book_subscriptionrr)rCrrrPr rrzr9rurrrrrr} orderbooks rEr#kucoin.watch_order_book_for_symbolssG A #DGG.q$qr r   %3,Ub[uPQz#DGG.o$opp!!!%%g.OOG, NN5))66v?OQY[kl QJERK.U;F sxx 22 q#g,'AZF  !6 7 |H  % %fslX&= > (  % %=="L 11#eagvv   1 "*(ws7A0F2F3:F-F.CF<F=FFFcx# URUS5nURUS5nUR5IShvN URUSS5nUR U5nUR S5IShvN nSnUR USSS5upbUS:XdUS:XaS [U5-nUS -S RU5-n/n/n [S [U55H/n Xn URS U -5 U RSU -5 M1 UUSSU S.n URXXXxX,5IShvN $NNN7f)aa https://www.kucoin.com/docs/websocket/spot-trading/public-channels/level1-bbo-market-data https://www.kucoin.com/docs/websocket/spot-trading/public-channels/level2-market-data https://www.kucoin.com/docs/websocket/spot-trading/public-channels/level2-5-best-ask-bid-orders https://www.kucoin.com/docs/websocket/spot-trading/public-channels/level2-50-best-ask-bid-orders 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 :param str [params.method]: either '/market/level2' or '/spotMarket/level2Depth5' or '/spotMarket/level2Depth50' default is '/market/level2' :returns dict: A dictionary of `order book structures ` indexed by market symbols rNFr#r9r6r4r'r(rrrzunsubscribe:orderbook:r)Tr+)rrrrur) r^omitrrrrSrrvrrrrr) rCrrPrrrzr9rurrrrr}s rEr"&kucoin.un_watch_order_book_for_symbolssQ!!&'267+!!!%%gtU;OOG, NN5))66v?OQY[kl QJERK.U;F sxx 22 q#g,'AZF  !9F!B C  % %lV&; <( + 2  //EZ`ooo- "*&ps48D:D4%>%@ A # q#m"45A'*C-2,9OST9T'-';';C'@  6 )),@ $ 2 23C_VW X -/JJt33V&RWY[\&&t," $//&148tv. nX&nURUS5nURUS5n XHS- :dM5XI:dM<Us $ [U5$)Nrr2 sequenceStartrlr3)rLr^rr) rCr+r9 firstDeltar2firstDeltaStartrdelta deltaStartrCs rEget_cache_indexkucoin.get_cache_indexcs__UA. !!)W5++JH Q& &q#e*%AHE**5/BJ(( >Ha'e.> & 5zrGcPURUSS5nURUSU5US'X1S'URU5US'URUSU5nURUS/5nURUS/5nUSnUSnUR Xu5 UR X5 g) Ntimerr3r2rchangesrr)r8r^rrLhandle_bid_asks) rCr+rMrrSrr storedBids storedAskss rEr?kucoin.handle_deltaqs''v{C !..umYO '!*+ $ Y 7 *//%E:w3w3v& v&  Z. Z.rGc[S[U55H'nURX#5nURU5 M) g)Nr)rr parse_bid_ask storeArray)rCbookSidebidAsksrbidAsks rErTkucoin.handle_bid_asks~s7q#g,'A'' 3F    '(rGc4URUS5nURUS5nUc2URUS5nUR0U5URU'g[ S[ U55H&nXWnUR0U5URU'M( g)Nrrrr)r^rLr_r6r5rr)rCrarr}rrrrs rEr*%kucoin.handle_order_book_subscriptions!!,8//, : ?%%lH=F&*oob%&@DOOF #1c'l+ *.//"e*D',rGcURUS5nX1R;agURURU5nURURU5nURU URUS5nUb U"XU5 URUSS5nU(anUR US/5nUR US/5n [ S[ U55Hn Xn Xn URXU 5 M URU5 gg)Nrsr9rFrrr) r_rxrL safe_boolrrrclean_unsubscription clean_cache) rCrarrsr|r}r9isUnSubrrrr{subHashs rEhandle_subscription_status!kucoin.handle_subscription_statuss   gt ,*** ++F,@,@"Ev';';=MN   $x8   6L 1..}eD  NN<"MM#~~l` NstoptriggerTz/spotMarket/advancedOrdersr:rOordersrr) r safe_value_2r.rSrrqrwrrfilter_by_symbol_since_limit) rCrrrrPrprzrur~r{rrqs rE watch_orderskucoin.watch_orderss!!!##FFI>6FI#67NN4((07,=V d   [[(FH%F%+f4K~~c{{7?[\\ ??OOF2E00tTT! ")]s4C1C+?C1C-AC11C/2:C1-C1/C1c:SSSSSSSS.nURX!U5$)Nopenclosedcanceled triggered)rwfilledmatchupdaterycancel TRIGGERED)r_)rCstatusstatusess rEparse_ws_order_statuskucoin.parse_ws_order_statuss3" $ &99rGc URUS5nURU5nURUSS5nURUS5nURXb5nURUS5nUR US5nUSL=(a USLn US:Xa U (aS nUR 0S U_SUS_S URUS 5_S URUS5_SU_SUR U5_SS_SURUS5_SS_SS_SURUS5_SURUSS5_SU_SU_SURUS5_SS_SS_URUS5SUSSS.EU5$)Nrt orderTime createdAtr stopPricetriggerSuccessTrzryrrsorderId clientOrderId clientOidrrlastTradeTimestamp orderType timeInForcepostOnlysideprice orderPrice triggerPriceamountsizecostaverage filledSize)r{ remainingrfeer) r_rr8rrL safe_orderrsafe_string_lower safe_string_2) rCorderrrawTyperrrrr triggerFails rEparse_ws_orderkucoin.parse_ws_ordersL""5&1++G4''{KH ##E84!!(3''{; 0@A%T1Sd8R k !{F E fX&  $""5)4  T--e[A     Y/   !$  D**5+>  4    D**5&9  T''w E    L  d&&uf5 D! " t# $&&ul;- . / rGcSnURUS5nURUS5nUbURX5 URU5nURUS5nURUS5nURUS5n U SLn URc=UR UR SS5n [U 5Ul[U 5UlU (a URO URn URU RU05n URX5nUbUS S :XaS US 'U RU5 URX5 US -U-nURX5 g) NrqrVtradeIdrrsr ordersLimitr2rrxr) rLr_handle_my_traderrqr^r>r triggerOrdershashmaprr)rCrarr{rVrparsedrrrisTriggerOrderr cachedOrdersrqrsymbolSpecificMessageHashs rE handle_orderkucoin.handle_order.sS* w/""43     1$$T*!!&(3""640v~> &d2 ;; %%dllM4HE07DK!7!>D -;t)) !5!5vrB0  X(*#+x F#|1$/#$5$>!|?rGc # UR5IShvN URS5IShvN nSnURUSSS5updSS0nSnUb!URU5n U SnUS -U S-nUR XXX`R Xt55IShvN n UR (aU RX5nURXX#S5$NNN=7f) a watches information on multiple trades made by the user https://www.kucoin.com/docs/websocket/spot-trading/private-channels/private-order-change :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 :param str [params.method]: '/spotMarket/tradeOrders' or '/spot/tradeFills' default is '/spotMarket/tradeOrders' :returns dict[]: a list of `trade structures ` NTr%r9r:rOmyTradesrr) rrSrrrqrwrrrs) rCrrrrPrzrur~r{rrs rEwatch_my_tradeskucoin.watch_my_trades]s!!!NN4((55foxYrs  d !  [[(FH%F%+fX.>>K~~c{{7?[\\ ??OOF2E00tTT "(]s2CCCCA*CC:CCCcURc-URURSS5n[U5UlUR US5nUR U5nURnUR U5 SnURURU5 US-US-nURURU5 g)Nr;r2rVrrr)rr^r>rrparse_ws_traderr) rCrarrrVrrr{rs rErkucoin.handle_my_trade{s: == %%dllM4HE259DM~~gv.$$T*== t}}k2$/#$5x8H$H!t}}&?@rGczURUS5nURX2S5nUSnURUS5nURUS5nURUS5nURUS5nURUS5n Uc$URUS5nURUS 5n URUS 5n URUS S S 5n USn URUS5n URUS5nURUU UR U 5UUU UURUS5UUU SUU U S.S. U5$)Nrrrrr matchPrice matchSizerrrtsrRgư>quotefeeRater liquidity)rratecurrency) rrrrrsrrt takerOrMakerrrrrr)r_rsafe_integer_product_2 safe_trader)rCrrrrrtrrrrrr feeCurrencyrfeeCosts rErkucoin.parse_ws_tradesnR##E84!!(C8!{3v.""5)4   5!!%5 =$$UG4E%%eV4F   2//tVXN Wo ""5)4""5%0" Y/ ,,UK@' $ % rGc # UR5IShvN URS5IShvN nSnSS0nSnURX%X0RXA55IShvN $NNN7N7f)aZ watch balance and get the amount of funds available for trading or funds locked in orders https://www.kucoin.com/docs/websocket/spot-trading/private-channels/account-balance-change :param dict [params]: extra parameters specific to the exchange API endpoint :returns dict: a `balance structure ` NTz/account/balancerObalance)rrSrqrw)rCrPrzrur~r{s rE watch_balancekucoin.watch_balancesm!!!NN4((" d  ^^Ce[[=YZZZ "( [s1A+A%A+A'0A+ A)!A+'A+)A+cURUS05nSnURUS5nURUS5nSnUb#URS5nURUS5nURURSSS 5n URURS 5n URXS 5n XR ;a0UR U 'X0R U S 'UR US 5n XR U S 'URU 5UR U S'URU5n UR5nURUS5US'URUS5US'URUS5US'XR U U 'URUR U 5UR U 'X:Xa URUR U U5 gg)NrVrr relationEvent.rr+ defaultTyperaccountsByTyperrRrr availablefreeholdusedtotal) rLr_rrr>rr^rsafe_currency_codeaccount safe_balancer)rCrarrVr{ currencyIdrrequestAccountTyperelationEventParts selectedTyper uniformTypercoders rEhandle_balancekucoin.handle_balances0w3 %%dJ7 ((? !  $!.!4!4S!9 !%!1!12Da!H ))$,, W^_ 7GH&&~7S ||+(*DLL %,0 [!&)%%dF3 1: [!+.04 Y0G [!*-&&z2,,.**4=**48++D':*1 [!$'$($5$5dll;6O$P [!  & NN4<< 4k B 'rGc URUS5nUS:XaURX5 gURUS5nURURURURURURUR UR URURURS. nURXT5nUb U"X5 gg)Nruz/market/ticker:allr) level1r1ztrade.l2updatez trade.tickerztrade.snapshotz trade.l3matchztrade.candles.updatezaccount.balance orderChange stopOrderz/spot/tradeFills) r_rrrFrrrrrrL)rCrarrurmethodsr9s rEhandle_subjectkucoin.handle_subject7s"  '2 ( (   v / ""7I6)),,"44 .."00!..$($5$5#22,,** $ 4 4  2   6 # rGc>[UR55nUSS.$)Nr<)rsrt)rvrn)rCrarss rEr< kucoin.ping^s%" #  rGc.UR5Ulgr) millisecondslastPongrks rE handle_pongkucoin.handle_ponghs++-rGc URUSS5nUS:Xa5SnURRS5S:aSnSURSU'UR S SURS0X2005 g ) NrVztoken is expiredrJzconnectId=privaterrIrKrlF)r_rzr<r> handle_errors)rCrarrVrts rEhandle_error_messagekucoin.handle_error_messagelsw4 % %Dzz23q8 )-DLL  & 1b&**b"dRLrGcURUS5nURURURURUR S.nUR XC5nUb U"X5 gg)Nrt)welcomeackrpongerror)r_rlrgrrrrL)rCrarrtrr9s rEhandle_messagekucoin.handle_message~sm00022**$$..  /   6 # rG)rrqrr)G__name__ __module__ __qualname____firstlineno__rrBrSrNrnrqdictrrrrvrrrr rrrrrrrrr rr:rrrrrrrrrr rr#rr"rFrOr?rTr*rgrlr r rtrrrrrrrrrrr<rrrr__static_attributes__ __classcell__)rDs@rErrsb0 #0 d68 =?+Z JLZ^ [TVlpueiu^`nrh acy}hrvh$68DDFD&9;fCfvf86:"'E7'E'ERL.FL.\8rsB ffllll4*.{$T   & &{$rG