":hQddlZddlmZmZmZddlmZmZm Z m Z m Z m Z m Z mZmZmZddlmZddlmZddlmZddlmZGdd ej0j2Zy) N) ArrayCacheArrayCacheBySymbolByIdArrayCacheByTimestamp) AnyBalancesIntOrder OrderBookStrStringsTickerTickersTrade)Client)List) ExchangeError)ArgumentsRequiredc eZdZdeffd ZifdZifdZdZidfdZidfdZ idfd e fd Z ifd e de fd Zdifd edefdZdefdZdifd edefdZdifde d efdZdefdZd9dZdddifd e dededeefdZdefdZddifd e dededeefdZddifd ee dededeefdZifd ee defdZ ifd e defdZ!defdZ"difd e dede#fd Z$ifd e defd!Z%difd ee dede#fd"Z&ifd ee defd#Z'defd$Z(d%Z)d&Z*d'Z+defd(Z,defd)Z-defd*Z.dddifd e/dededee0fd+Z1d,Z2d9d-Z3defd.Z4dddifd e/dededeefd/Z5defd0Z6d9d1Z7ifde8fd2Z9defd3Z:defd4Z;defd5Zdefd8Z?xZ@S):kucoinreturnc |jtt|iddddddddddddd dd dd dd dd dddddddddddddddddddiddddddidd|jid S)!NwsT createOrderWsF editOrderWsfetchOpenOrdersWs fetchOrderWs cancelOrderWscancelOrdersWscancelAllOrdersWs watchBidsAskswatchOrderBook watchOrders watchMyTrades watchTickers watchTicker watchTradeswatchTradesForSymbolswatchOrderBookForSymbols) watchBalance watchOHLCVnamezmarket/snapshot/market/level2) snapshotDelaysnapshotMaxRetriesmethodr2/spotMarket/tradeOrders) tradesLimitr%r!r#ping)hasoptions streaming) deep_extendsuperrdescriber5)self __class__s I/var/www/html/turnos/venv/lib/python3.12/site-packages/ccxt/pro/kucoin.pyr;zkucoin.describesEfd < >du$U      !%$U !$t tt (!"+D#$!%"', $- &'*+.# 7" $ I*A * * cK|rdnd}|j|jdi}|j||}| |d{S|j|j||||<||jd<||}|d{S7B7w)Nprivatepublicurls) safe_valuer7spawnnegotiate_helper)r<privateChannelparams connectIdrCspawanedfutures r> negotiatezkucoin.negotiate>s!/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) NrArBdatainstanceServersr pingIntervalendpointtoken?)rRrGrIrC) privatePostBulletPrivatepublicPostBulletPublicrD safe_integer safe_string urlencodeclient keepAlive Exceptionr7reject)r<rGrHresponserIrNrOfirstInstanceServerrPrQrRresultrYerKs r>rFzkucoin.negotiate_helperLsN!/IX ' 0!%!>!>v!FF&"&!C(C$C(C&B&C(#D>$C(&C(( D;1AD61D>6D;;D>c~|j|j|jddd}||jd<|S)N requestIdr)sumrVr7)r<rbs r> request_idzkucoin.request_idys9HHT..t||[!LaP $- [!r?NcKt|j}|d|dd}|j||}|j|} || jvr|| j|<|j |||||d{S7w)N subscribeTidtypetopicr])strreextendrY subscriptionswatch) r<url messageHashsubscriptionHashrH subscriptionrbrequestmessagerYs r>rgzkucoin.subscribe~s)* %   ++gv.S! F$8$88.>F  +ZZ[';K\ZZZZsA9B;B<BcHKt|j}|d|dd}|j||} |j|} t dt |D]%} || } | | j vs| | j |<'|j||| ||d{S7w)NrgTrhrrlrermrYrangelenrnwatch_multiple r<rp messageHashesrksubscriptionHashesrHrsrbrtrurYirrs r>subscribe_multiplezkucoin.subscribe_multiples)*    ++gv.S!q#012 CA1!4 $(<(<<2B$$Y/ C((mWFXZfggggsA/B"2)B"B B"rscVKt|j}|d|dd}|j||} ||||<|j|} t dt |D]%} || } | | j vs| | j |<'|j||| ||d{S7w)N unsubscribeTrhrrwr{s r>un_subscribe_multiplezkucoin.un_subscribe_multiples)* !   ++gv.  #&/L #S!q#012 CA1!4 $(<(<<2B$$Y/ C((mWFXZfggggsA6B)9)B)"B'#B)symbolc*K|jd{|j|}|d}|jdd{}|j|ddd\}}|dz|dz}d |z}|j ||||d{S7v7I7w) 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%r2z/market/snapshot:riticker:) load_marketsmarketrLhandle_option_and_paramsrg) r<rrHrrpr2queryrkrqs r> watch_tickerzkucoin.watch_tickers!!!V$!NN5))55fmXWij  vd|+&( ^^CeUCCC "*Ds4BB .BBABB BBBsymbolscK|jd{|j|}d}d}|j|ddd\}}g}g}|^tdt |D]F}||}|j d|z|j |} |j |dz| d zH|jd d{} d} |/|d z} |j| || |d{} |jr_| S|j|} |dzd j| z}|j| ||||d{} |jr i}| || d <|S|j|jd |S7[777@w)ab 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$r2z/market/tickerrrrriFz:all,r)rmarket_symbolsrrxryappendrrLrg newUpdates market_idsjoinrfilter_by_arrayr)r<rrHrqr2r|topicsr~rrrprallTopic marketIds symbolsTopicnewDicts r> watch_tickerszkucoin.watch_tickerss!!!%%g. 66v~xYij   1c'l+ ; $$Y%78V, fslVD\9:  ; NN5)) ?H NN3 XvNNG0I!C<#((9*==L 33C V\^deeG "-4)*##DLL(GDD9 "*O fsGE:E1B(E:?E4$E:$E6%AE:7E88:E:4E:6E:8E:rYc|j|d}d}|R|jd}|j|d}d}|dk(r|j|d}n|}|j||d}|j|di}|j|d|} |j | |} | d} | |j | <d | z} |j | | i} | | | <|j | d y) Nrkrrcallsubject-rNrrr)rWsplit safe_marketrD parse_tickerrresolve)r<rYrurkrpartsfirstmarketIdrN rawTickertickerrrq allTickerss r> handle_tickerzkucoin.handle_tickersn  '2  KK$E$$UA.EH~++GY? %%h` r z/spotMarket/level1:Nr)watch_multi_helperrrbidsasks)r<rrHrrs r>watch_bids_askszkucoin.watch_bids_asks8sc..@UW^`fgg ??G(.GF8$ %N##DMM8WEE hsAA:A channelNamecxK|jd{|j|dddd}t|}|dkDrt|jdz|zdzg}t dt|D]/}||}|j |} |jd| dz1|jdd{} |j|} d j| } t|j} | d || zdd }|j||}|j| |||d{S77z7 w) NFTd z#() accepts a maximum of 100 symbolsrbidask@rrrgrh)rrryrrirxrrrLrrrlrermrz)r< methodNamerrrHlengthr|r~rrrprjoinedrbrtrus r>rzkucoin.watch_multi_helperIsB!!!%%gtUD%HW C<#DGGcMJ$>Af$fg g q#g,' ?AQZF[[(F  VH-=!= > ?NN5))OOG, )$)*  6)   ++gv.((mWmTTT+ "*Us5D:D3B$D:;D6handle_bid_askzkucoin.handle_bid_askasD,,W5 h' , f&( |[1r?c |j|d}|jd}|d}|j||}|j|d}|j|di}|j |dg}|j |dg} |j |d} |j || |j| |j|d |j|d|j| d |j| d|d |S) NrkrrcrrNasksbids timestampr)rrdatetimeask askVolumebid bidVolumeinfo) rWrr safe_dict safe_listrV safe_tickeriso8601 safe_number) r<rrrkrrrrNrrrs r>rzkucoin.parse_ws_bid_askvs   1 C 8!!(F3!!&(3~~ffb1nnT62.nnT62.%%dK8 " Y/##C+))#q1##C+))#q1 !    r?1msincelimitcK|jd{|jdd{}|j|}|d}|j|j||}d|dzdz|z} d|zdz|z} |j || | |d{} |j r| j||}|j| ||d d S777;w) 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 NFrz/market/candles:ri_candles:rrT) rrLrrW timeframesrgrgetLimitfilter_by_since_limit) r<r timeframerrrHrprperiodrkrqohlcvs r> watch_ohlcvzkucoin.watch_ohlcvs!!!NN5))V$!!!$//9iH"VD\1C7&@ 6)C/); nnS+ufEE ??NN651E))%q$GG ") Fs2CCCCA'CC8CCCc|j|di}|j|d}|j|dg}|j|d}|jd}|j|d}|j|} |j |} | d} d| zdz| z} |j|j | i|j | <|j|j | | } | :|j |jd d }t|} | |j | | <|j|| }| j||j| | y) NrNrcandlesrkrrcrr OHLCVLimitr+) rDrWrfind_timeframerohlcvsrVr7r parse_ohlcvrr)r<rYrurNrrrkrintervalrrrrqstoredrrs r> handle_ohlcvzkucoin.handle_ohlcvsH*w3##D(3//$ 26  '2 C ##E1-''1 !!(+! 6)C/); "oodkk62F FV!4i@ >%%dllL$GE*51F-3DKK  *  &1 ev{+r?cHK|j|g|||d{S7w)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)r<rrrrHs r> watch_tradeszkucoin.watch_tradess'22F8UE6RRRRs " "cKt|}|dk(rt|jdz|jd{|j |}|j |}|j dd{}g}g} ddj|z} tdt|D]4} || } |jd| z|| } | jd| z6|j||| | |d{}|jr6|j|d}|j|d}|j||}|j|||d d S777`w) 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)ryrrirrrrLrrxrrrrDrWrr)r<rrrrH symbolsLengthrrpr|r}rkr~rrtradesr tradeSymbols r>rzkucoin.watch_trades_for_symbolsseG A #DGG.n$no o!!!%%g.OOG, NN5))  388I#66q#g,' CAQZF  V!3 4 |H  % %&6&A B  C ..sM5J\^dee ??OOFA.E**5(;KOOK7E))&% TRR# "*fs5` NFrrrzunsubscribe:trades:rrT)r|subMessageHashesrkrr) rrrrLrrxryrr) r<rrHrrpr|r}rkr~rrss r>un_watch_trades_for_symbolsz"kucoin.un_watch_trades_for_symbolss!!!%%gtU;OOG, NN5))  388I#66q#g,' :AQZF  !6!? @  % %i&&8 9 : + 2  //]E=Z`bnooo% "*ps4C#C` N)rr<rrHs r>un_watch_tradeszkucoin.un_watch_tradess#55vhGGGG   cP|j|di}|j|}|d}d|z}|j|j|}|7|j|jdd}t |}||j|<|j ||j||y)NrNrrr4r+)rD parse_traderrVr7rrr) r<rYrurNtraderrqrrs r> handle_tradezkucoin.handle_trade(s(w3  &x&( f5 >%%dllM4HE&F"(DKK  ev{+r?cFK|j|g||d{S7w)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)r<rrrHs r>watch_order_bookzkucoin.watch_order_bookHs%<66xOOOOs !!cDK|j|g|d{S7w)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 r>un_watch_order_bookzkucoin.un_watch_order_bookhs#996(FKKKKrc*Kt|}|dk(rt|jdz|,|dk7r'|dk7r"|dk7r|dk7rt|jdz|j d{|j |}|j |}|jd d{}d}|j|d d d \}}|dk(s|dk(rd t|z}|dzdj|z}g} g} tdt|D]7} || } | jd| z|| } | j|dz| z9i}|d k(r|j||d}|j|| || ||d{}|jS7 77w)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 symbolsNr2r-z? watchOrderBook 'limit' argument must be None, 5, 20, 50 or 100Fr!r2r//spotMarket/level2Depthrr orderbook:)r2rr)ryrrirrrrrLrrlrrxrhandle_order_book_subscriptionrr)r<rrrHrrrpr2rkr|r}r~rrrs orderbooks r>rz#kucoin.watch_order_book_for_symbolsxsG A #DGG.q$qr r   %3,Ub[uPQz#DGG.o$opp!!!%%g.OOG, NN5))66v?OQY[kl QJERK.U;F sxx 22 q#g,' ?AQZF  !6 7 |H  % %fslX&= >  ?  % %=="L 11#}eM_agiuvv   1 "*(ws7A*F,F -:F'F(CF7F8FFFczK|j|d}|j|d}|jd{|j|dd}|j |}|j dd{}d}|j |ddd\}}|dk(s|dk(rd t|z}|d zd j|z}g}g} td t|D]/} || } |jd | z| jd| z1||dd| d} |j|||||| d{S777w)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[] 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!r2r/r-rrrrrzunsubscribe:orderbook:rTr)r|rrrkr) rVomitrrrrLrrlrrxryrr) r<rrHrrrpr2rkr|r}r~rrss r>rz&kucoin.un_watch_order_book_for_symbolssd!!&'267+!!!%%gtU;OOG, NN5))66v?OQY[kl QJERK.U;F sxx 22 q#g,' =AQZF  !9F!B C  % %lV&; < = + 2  //]E=Z`bnooo- "*&ps48D;D5handle_order_bookzkucoin.handle_order_booksqRw/""7I6  '2[[% &&z15 '' A6 ##D(K@!!(D#6"V+ h doo-*.//*;' OOF3 !06DOOF #H -doo-*.//*;'/I%%i9E**4 LH}!)//2 $V%9%9%>%>%@ A # q#m"45A'*C-2,9OST9T'-';';C'@   )),@ $ 2 23C_VW X -/JJt33V[&RWY[\&&t,(" $//&148tv. get_cache_indexzkucoin.get_cache_index#s__UA. !!)W5++JH ?Q& &q#e*% A!HE**5/BJ(( >Ha'eh.>   5zr?cV|j|dd}|j|d||d<||d<|j||d<|j|d|}|j|dg}|j|dg}|d}|d}|j |||j ||y) Ntimerrrrchangesrr)r rVrrDhandle_bid_asks) r<rrrr$rr storedBids storedAskss r>rzkucoin.handle_delta1s''v{C !..umYO '!* + $ Y 7 *//%E:w3w3v& v&  Z. Z.r?ctdt|D]'}|j||}|j|)y)Nr)rxry parse_bid_ask storeArray)r<bookSidebidAsksr~bidAsks r>r%zkucoin.handle_bid_asks>s>q#g,' (A'' 3F    ' (r?c0|j|d}|j|d}|2|j|d}|ji||j|<yt dt |D]&}||}|ji||j|<(y)Nrrrr)rVrDrWr rrxry)r<rYrursrrrr~s r>rz%kucoin.handle_order_book_subscriptionCs!!,8//, : ?%%lH=F&*oob%&@DOOF #1c'l+ E *.//"e*D' Er?c|j|d}||jvry|j|j|}|j|j|}|j|=|j|d}| |||||j|dd}|ro|j |dg}|j |dg} t dt |D]} || } | | } |j|| | !|j|yy)Nrir2rFr|rr) rWrnrD safe_boolrrxryclean_unsubscription clean_cache) r<rYrurirrrsr2isUnSubr|rr~rqsubHashs r>handle_subscription_statusz!kucoin.handle_subscription_statusRs  gt ,f*** ++F,@,@"Ev';';=MN   $x8   67L 1..}eD  NN<"MM#~~lhandle_system_statuszkucoin.handle_system_statusls r?c K|jd{|j|dd}|j|ddg}|jdd{}|rdnd}ddi}d} ||j |} | d }| d z|z} |j || ||j ||d{} |jr| j||}|j| |||dS777;w) a watches information on multiple orders made by the user https://www.kucoin.com/docs/websocket/spot-trading/private-channels/private-order-change https://www.kucoin.com/docs/websocket/spot-trading/private-channels/stop-order-event :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 :param boolean [params.trigger]: trigger orders are watched if True :returns dict[]: a list of `order structures ` NstoptriggerTz/spotMarket/advancedOrdersr3rGordersrr) r safe_value_2rrLrrgrmrrfilter_by_symbol_since_limit) r<rrrrHr=rprkrtrqrr>s r> watch_orderszkucoin.watch_ordersys!!!##FFI>6FI#67NN4((07,=V d   [[(FH%F%+f4K~~c;t{{7TZ?[\\ ??OOFE2E00tTT! ")]s4C,C&?C,C(AC,.C*/8C,(C,*C,c<dddddddd}|j|||S)Nopenclosedcanceled triggered)rCfilledmatchupdaterEcancel TRIGGERED)rW)r<statusstatusess r>parse_ws_order_statuszkucoin.parse_ws_order_statuss5" $ &&99r?c |j|d}|j|}|j|dd}|j|d}|j||}|j|d}|j |d}|duxr|du} |dk(r| rd }|j id |d|dd |j|d d |j|dd|d|j |ddd|j|dddddd|j|dd|j|ddd|d|d|j|ddddd|j|dd|ddd|S)Nrj orderTime createdAtr stopPricetriggerSuccessTrFrErriorderId clientOrderId clientOidrrlastTradeTimestamp orderType timeInForcepostOnlysideprice orderPrice triggerPriceamountsizecostaverage filledSize)rG remainingrLfeer) rWrNr rrD safe_orderrsafe_string_lower safe_string_2) r<orderrrawTyperLrrr^rS triggerFails r>parse_ws_orderzkucoin.parse_ws_orders L""5&1++G4''{KH ##E84!!(F3''{; 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;- . / r?cd}|j|d}|j|d}||j|||j|}|j|d}|j|d}|j|d} | du} |j=|j |j dd} t| |_t| |_| r |jn |j} |j| j|i} |j| |}| |d d k(rd |d <| j||j| ||d z|z}|j| |y) Nr>rNtradeIdrrir^ ordersLimitr+rLrDr) rDrWhandle_my_traderlr>rVr7r triggerOrdershashmaprr)r<rYrurqrNrnparsedrrTr^isTriggerOrderr cachedOrdersr>risymbolSpecificMessageHashs r> handle_orderzkucoin.handle_orders\* w/""43     1$$T*!!&(3""640v~> &d2 ;; %%dllM4HE07DK!7!>D -;t)) !5!5vrB0  X(*#+x F#|[1$/#$5$>!|%>?r?c K|jd{|jdd{}d}|j|ddd\}}ddi}d}|!|j|} | d}|d z| dz}|j ||||j ||d{} |j r| j||}|j| |||dS777;w) 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#r2r3rGmyTradesrr) rrLrrrgrmrrr@) r<rrrrHrprkrtrqrrs r>watch_my_tradeszkucoin.watch_my_tradess!!!NN4((55foxYrs v d !  [[(FH%F%+fX.>>K~~c;t{{7TZ?[\\ ??OOFE2E00tTT "(]s2CCCCA-CC8CCCc|j-|j|jdd}t||_|j |d}|j |}|j}|j |d}|j|j||dz|dz}|j|j|y)Nr4r+rNryrr)ryrVr7rrparse_ws_traderr) r<rYrurrNrsryrqrvs r>rpzkucoin.handle_my_trade;s: == %%dllM4HE259DM~~gv.$$T*== t}}k2$/#$5x8H$H!t}}&?@r?cz|j|d}|j||d}|d}|j|d}|j|d}|j|d}|j|d}|j|d} |$|j|d}|j|d } |j|d } |j|d d d } |d} |j|d} |j|d}|j|| |j | ||| ||j|d||| d|| | dd |S)NrrrXr[rn matchPrice matchSizer\r`rTtsr#gư>quotefeeRatere liquidity)raratecurrency) rrrrririrj takerOrMakerr[r\r_rare)rWrsafe_integer_product_2 safe_trader)r<rrrrrjr[rnr\r_rir feeCurrencyrfeeCosts r>r|zkucoin.parse_ws_tradedspR##E84!!(FC8!{3v.""5)4   5!!%5 =$$UG4E%%eV4F   2//tVXN Wo ""5)4""5%0" Y/ ,,UK@' $ % r?c K|jd{|jdd{}d}ddi}d}|j||||j||d{S7Q7:7w)a 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/balancerGbalance)rrLrgrm)r<rHrprkrtrqs r> watch_balancezkucoin.watch_balancesw!!!NN4((" d  ^^CeT[[RX=YZZZ "( [s1A.A(A.A*3A.#A,$A.*A.,A.c|j|di}d}|j|d}|j|d}d}|#|jd}|j|d}|j|jddd } |j|jd } |j| |d } | |j vri|j | <||j | d <|j |d } | |j | d <|j| |j | d<|j|} |j}|j|d|d<|j|d|d<|j|d|d<||j | | <|j|j | |j | <| | k(r |j|j | |yy)NrNrr relationEvent.rr) defaultTyperaccountsByTyperr#rr availablefreeholdusedtotal) rDrWrrhr7rrVrsafe_currency_codeaccount safe_balancer)r<rYrurNrq currencyIdrrequestAccountTyperelationEventParts selectedTyper uniformTypercoders r>handle_balancezkucoin.handle_balances0w3 %%dJ7 ((? !  $!.!4!4S!9 !%!1!12Da!H ))$,, W^_ 7GH&&~7I7S t||+(*DLL %,0 [!&)%%dF3 1: [!+.04 Y0G [!*-&&z2,,.**4=**48++D':*1 [!$'$($5$5dll;6O$P [! , & NN4<< 4k B 'r?c |j|d}|dk(r|j||y|j|d}|j|j|j|j|j|j|j |j |j|j|jd }|j||}| |||yy)Nrkz/market/ticker:allr) level1rztrade.l2updatez trade.tickerztrade.snapshotz trade.l3matchztrade.candles.updatezaccount.balance orderChange stopOrderz/spot/tradeFills) rWrrrrrrrwrprD)r<rYrurkrmethodsr2s r>handle_subjectzkucoin.handle_subjects"  '2 ( (   vw / ""7I6)),,"44 .."00!..$($5$5#22,,** $ 4 4  '2   67 # r?c>t|j}|ddS)Nr5)rirj)rlre)r<rYris r>r5z kucoin.pings%" #  r?c.|j|_yr7) millisecondslastPongr9s r> handle_pongzkucoin.handle_pong(s++-r?c |j|dd}|dk(r4d}|jjddk\rd}d|jd|<|j dd|jdd||dd y) NrNztoken is expiredrBzconnectId=privaterrArC)rWrprr7 handle_errors)r<rYrurNrjs r>handle_error_messagezkucoin.handle_error_message,sw4 % %Dzz23q8 )-DLL  & 4vzz4tWdTXYr?c|j|d}|j|j|j|j|j d}|j ||}| |||yy)Nrj)welcomeackrupongerror)rWr:r5rrrrD)r<rYrurjrr2s r>handle_messagezkucoin.handle_message=sq00022**$$..  $/   67 # r?r7)A__name__ __module__ __qualname__rr;rLrFrergrdictrrlr rr rrrrrrrrrrr rrrrrrrrr rrrrrr!rr%rr5r:r r rArNrlrwrzrpr|rrrrr5rrr __classcell__)r=s@r>rrs+ #+ Z68 =?+Z JLZ^ [^`nrh acy}hrvh$68DDFD&6:"'E7'E'ERL.FL.\8rs? fffff4*.z$T   & &z$r?