eikddlZddlmZmZmZddlmZmZm Z m Z m Z m Z m Z mZmZmZmZmZddlmZddlmZddlmZddlmZddlmZGd d ejjZdS) N) ArrayCacheArrayCacheBySymbolByIdArrayCacheByTimestamp) AnyBalancesBoolIntOrder OrderBookPositionStrStringsTickerTickersTrade)Client)List) ExchangeError)ArgumentsRequired)Precisec $eZdZdeffd ZdifdZifdZdZidfdZidfd e fd Z idfd Z idfd e fd Z ifd e defdZifd e defdZdifdedefdZdefdZdefdZdifdedefdZdifde defdZdefdZdJdZdddifd e de dededeef dZdifd e de deefdZdefd Z ddifd e dededee!fd!Z"ddifdee dededee!fd"Z#ifdee defd#Z$ifd e defd$Z%defd%Z&difd e dede'fd&Z(ifd e defd'Z)difdee dede'fd(Z*ifdee defd)Z+defd*Z,d+Z-d,Z.d-Z/defd.Z0defd/Z1defd0Z2dddifd e3dededee4fd1Z5d2Z6d3Z7dJd4Z8defd5Z9dddifd e3dededee!fd6Z:d7Z;defd8Zfd:Z?defd;Z@d<ZAdefd=ZBdifd e3deCfd>ZDd?ZEded e fd@ZFdAZGdefdBZHdefdCZIdefdDZJdefdEZKdedeLfdFZMdefdGZNdJdHe d e3fdIZOxZPS)Kkucoinreturnc:|tt|iddddddddddddd dd dd dd dd ddddddddddddddddddddddd dddidddddddiddddddd d!|jid"S)#NwsT createOrderWsF editOrderWsfetchOpenOrdersWs fetchOrderWs cancelOrderWscancelOrdersWscancelAllOrdersWs watchBidsAskswatchOrderBook watchOrders watchPositionwatchPositions watchMyTrades watchTickers watchTicker watchTrades) watchTradesForSymbolswatchOrderBookForSymbols watchBalance watchOHLCV unWatchTicker unWatchOHLCVunWatchOrderBook unWatchTradesunWatchhTradesForSymbols spotMethod/market/snapshot/market/level2/contractMarket/level2) snapshotDelaysnapshotMaxRetriesr6contractMethod/spotMarket/tradeOrders)fetchBalanceSnapshotawaitBalanceSnapshot)fetchPositionSnapshotawaitPositionSnapshot) tradesLimitr*r$r(r.r&ping)hasoptions streaming) deep_extendsuperrdescriberE)self __class__s M/var/www/html/volatility/venv/lib/python3.11/site-packages/ccxt/pro/kucoin.pyrKzkucoin.describesfd 3 3 < < > >du$U      !%$U !$t !%  t!"t#$*.,0 $"!% $$(!%,05: $ "4 &'*+"2&> ##!";"-1,0!! .2-1""%6 i:A :A : : : Fc K|rdnd}|r|dz }||jdi}|||}||d{VS||j|||||<||jd<||}|d{VS)NprivatepublicFuturesurls) safe_dictrG safe_valuespawnnegotiate_helper)rLprivateChannelisFuturesMethodparams connectIdrTfutures rN negotiatezkucoin.negotiateOs!/=IIX  #  "I~~dlFB77y11  <<<<<< **T%:NIW]^^Y# Vi||||||rOcNKd} |dkr||d{V}n_|dkr||d{V}n=|dkr||d{V}n||d{V}||di}||dg}||d}||d}||d} ||d } | d z|| ||d z} | | } || _ | S#t$rN} | |j d |}|| |j d |=Yd} ~ nd} ~ wwxYwdS) NrQrRprivateFuturesdatainstanceServersr pingIntervalendpointtoken?)rerYr\rT)privatePostBulletPrivatepublicPostBulletPublicfuturesPrivatePostBulletPrivatefuturesPublicPostBulletPublicrU safe_list safe_integer safe_string urlencodeclient keepAlive ExceptionrVrGreject)rLrYr\r[responserarbfirstInstanceServerrcrdreresultroer]s rNrXzkucoin.negotiate_helper_s+ 0I%%!%!>!>v!F!FFFFFFF$h&&!%!>(FB77D"nnT3DbIIO"&..!"D"D ,,-@.QQL''(;ZHHH$$T733E^dnn"0&66''F [[((F+F M 0 0 0__T\&%99EEF MM!    V$Y////// 0tsEE F"AFF"c||||jddd}||jd<||S)N requestIdr)lock_idsumrlrG unlock_id)rLrxs rN request_idzkucoin.request_idsX HHT..t|[!LLaPP $- [! rONcKt|}|d|dd}|||}||} || jvr || j|<||||||d{VS)N subscribeTidtypetopicrs)strr}extendro subscriptionswatch) rLurl messageHashsubscriptionHashr[ subscriptionrxrequestmessageros rNrzkucoin.subscribes))** %    ++gv..S!! F$888.>F  +ZZ[';K\ZZZZZZZZZrOrcJK|||g||g||d{VSN)un_subscribe_multiple)rLrrrrr[rs rN un_subscribezkucoin.un_subscribes>//k]EL\K]_egstttttttttrOc`Kt|}|d|dd}|||} ||} t dt |D]} || } | | jvr | | j|<|||| ||d{VS)NrTrrrr}rrorangelenrwatch_multiple rLr messageHashesrsubscriptionHashesr[rrxrrroirs rNsubscribe_multiplezkucoin.subscribe_multiples))**     ++gv..S!!q#01122 C CA1!4 $(<<<2B$Y/((mWFXZfgggggggggrOcnKt|}|d|dd}|||} ||||<||} t dt |D]} || } | | jvr | | j|<|||| ||d{VS)N unsubscribeTrrrrs rNrzkucoin.un_subscribe_multiples))** !    ++gv..  #&/L #S!!q#01122 C CA1!4 $(<<<2B$Y/((mWFXZfgggggggggrOsymbolcbK|d{V||}|d}|d}|d|d{V}d}|rd}n||dd|\}}|d z|d z}d |z}|||||d{VS) 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-new/3470063w0 https://www.kucoin.com/docs-new/3470081w0 :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 ` NrcontractFr7/contractMarket/tickerr*r6:rticker:) load_marketsmarketr^handle_option_and_paramsr) rLrr[rrZrmethodrrs rN watch_tickerzkucoin.watch_tickers!!!!!!!!!V$$! ,NN5/::::::::#  h-FF!::6=R^`fggNFF vd|+&( ^^CeVDDDDDDDDDrOcK|d{V||}|d}|d}|d|d{V}d}|rd}n||dd|\}}|d z|d z}d |z}d |z} ||g| |gd d|gd} ||||| || d{VS)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-new/3470063w0 https://www.kucoin.com/docs-new/3470081w0 :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 ` NrrFr7rr*r6rrzunsubscribe:ticker:rtickerTrsubMessageHashesrrsymbols)rrr^rr) rLrr[rrZrrrrsubMessageHashrs rNun_watch_tickerzkucoin.un_watch_tickers-!!!!!!!!!V$$! ,NN5/::::::::#  h-FF!::6=R^`fggNFF vd|++f4 "V+ *51!/ 7x   &&sKPVXdeeeeeeeeerOrcK|d{V||ddd}||}d}|d||\}}|dko|dk}|r|t |jdz|zdzd}d }|rd }n||dd d |\}}g}g} |vtd t|D]X} || } | d| z| | } | |dz| dzY| d|d{V} d}|-|dz}| | |||d{V}|j r|Sne||}|dzd|z}|| ||| |d{V}|j ri}|||d<|S||jd|S)a https://www.kucoin.com/docs-new/3470063w0 https://www.kucoin.com/docs-new/3470064w0 https://www.kucoin.com/docs-new/3470081w0 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]: *spot markets only* either '/market/snapshot' or '/market/ticker' default is '/market/ticker' :returns dict: a `ticker structure ` NTr)spotmarginz/ watchTickers() requires a list of symbols for z marketstickersz/market/tickerrrr6rrrrFz:all,r)rmarket_symbolsget_market_from_symbolshandle_market_type_and_paramsrrhandle_option_and_params_2rrappendrr^r newUpdates market_idsjoinrfilter_by_arrayr)rLrr[ firstMarket marketTyperZrrrtopicsrrrrrallTopic marketIds symbolsTopicnewDicts rN watch_tickerszkucoin.watch_tickerss!!!!!!!!!%%gtT4@@227;;  !??P[]cdd F%/MjH6L  {w#DG._$_bl$loy$yzz z !  u-FF!<>#//CCHH$H))(FC@@>>'6266DtVT::I&&y&99FH%F#)DL #f,K NN6; / / /!J!'Jv  NN:y 1 1 1 1 1  ' ' 8 8 8 8 8rOc||di}||d}||dd}|||}||j|d<d|dz}|||dS)Nrarrr)rUrmrrrr)rLrorrarrrrs rNrzkucoin.handle_contract_tickers,~~gvr22##D(33!!(D#66""400)/ VH%&&"22 v{+++++rOcRK|d{V||dddd}||}|d}d}|rd}|d|||d{V}|jri}|||d<|S||jd|S) a https://www.kucoin.com/docs-new/3470067w0 https://www.kucoin.com/docs-new/3470080w0 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 ` NFTrz/spotMarket/level1:z/contractMarket/tickerV2:r#r)rrrwatch_multi_helperrrbidsasks)rLrr[rrZ channelNamerrs rNwatch_bids_askszkucoin.watch_bids_askss!!!!!!!!!%%gtUD%HH227;; %j1+  65K.. WV\]]]]]]]] ? G(.GF8$ %N##DM8WEEErOrcK|d{V||dddd}t|}|dkrt|jdz|zdzg}t dt|D]=}||}||} |d| dz>|dd{V} | |} d | } t| } | d || zdd }| ||}|| |||d{VS) NFTd z#() accepts a maximum of 100 symbolsrbidask@rrrr)rrrrrrrrr^rrrr}rr)rL methodNamerrr[lengthrrrrrrjoinedrxrrs rNrzkucoin.watch_multi_helpers!!!!!!!!!%%gtUD%HHW C<<#DGcMJ$>Af$fgg g q#g,,'' ? ?AQZF[[((F  VH-=!= > > > >NN5))))))))OOG,, )$$))**  6)    ++gv..((mWmTTTTTTTTTrOc||}|d}||j|<d|z}|||dS)Nrr)parse_ws_bid_askrr)rLror parsedTickerrrs rNhandle_bid_askzkucoin.handle_bid_asksQ:,,W55 h' , f&( |[11111rOc ||d}|ddkr&|d}|d}|||}||d}||di}||dg}||d g} ||d } ||| || | |d| |d| | d| | d|d |S||di}||d}|||}||d}| |d d } ||| || | |d| |d| |d| |d|d |S)Nrrrrryrraasksbids timestamp)rrdatetimeask askVolumebid bidVolumeinfotsư> bestAskPrice bestAskSize bestBidPrice bestBidSize) rmrrrrUrkrl safe_tickeriso8601 safe_numbersafe_integer_product) rLrrrrrrrarrrs rNrzkucoin.parse_ws_bid_asksJ  11 ::& ' '! + +KK$$EQxH%%h77F%%fh77F>>&&"55D..vr22C..vr22C))$ <>&&"55D''h77H%%h77F%%fh77F11$hGGI## & LL33''n==!--dMBB''n==!--dMBB % %   rO1m timeframesincelimitcK|d{V||}|d}|d}|d|d{V}||j||} d} |rd} | |dzdz| z} d |zd z|z} ||| | |d{V} |jr| ||}|| ||d d S) a watches historical candlestick data containing the open, high, low, and close price, and the volume of a market https://www.kucoin.com/docs-new/3470071w0 https://www.kucoin.com/docs-new/3470086w0 :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 NrrF/market/candles:/contractMarket/limitCandle:r_candles:rrT) rrr^rm timeframesrrgetLimitfilter_by_since_limit)rLrrrrr[rrZrperiodrrrohlcvs rN watch_ohlcvzkucoin.watch_ohlcv7s/!!!!!!!!!V$$! ,NN5/::::::::!!$/9iHH(  98KfTl*S069 6)C/); nnS+ufEEEEEEEE ? 2NN6511E))%q$GGGrOcK|d{V||}|d}|d}|d|d{V}d}|rd}||j||}||dzdz|z} d |zd z|z} d |zd z|z} ||g} | | g| | gd d |g| gd} ||| | | || d{VS)a* unWatches historical candlestick data containing the open, high, low, and close price, and the volume of a market https://www.kucoin.com/docs-new/3470071w0 https://www.kucoin.com/docs-new/3470086w0 :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 NrrFrrrrzunsubscribe:candles:rrr T)rrrrrsymbolsAndTimeframes)rrr^rmrr)rLrrr[rrZrrrrrrsymbolAndTimeframers rNun_watch_ohlcvzkucoin.un_watch_ohlcvUsN!!!!!!!!!V$$! ,NN5/::::::::(  98K!!$/9iHHfTl*S069,v5;iG #f,s2Y>$i0 *51!/ 7x%7$8   &&sK VUabbbbbbbbbrOc "||di}||d}||dg}||d}|d}||d}||} ||} | d} d| zdz| z} ||j| i|j| <||j| | } | ;||j d d }t|} | |j| | <| d d k}|rd nd}| |d | |d| |d| |d| |d| ||g}| ||| | dS)Nrarcandlesrrryrr OHLCVLimitr5rrr8r9)rUrmrkrfind_timeframerrVohlcvsrlrGrrsafe_timestamprrr)rLrorrarrrrintervalrrrrstoredrisContractMarketbaseVolumeIndexparseds rN handle_ohlcvzkucoin.handle_ohlcv{sR~~gvr22##D(33..y"55  '22 C  ##E1--''11 !!(++! 6)C/); "oodk62FF FV!4i@@ >%%dlL$GGE*511F-3DK  *!JJ'788A=/6!!Q    + +   Wa ( (   Wa ( (   Wa ( (   Wa ( (   Wo 6 6    fv{+++++rOcDK||g|||d{VS)a@ get the list of most recent trades for a particular symbol https://www.kucoin.com/docs-new/3470072w0 https://www.kucoin.com/docs-new/3470084w0 :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)rLrrrr[s rN watch_tradeszkucoin.watch_tradess622F8UE6RRRRRRRRRrOcdKt|}|dkrt|jdz|d{V||ddd}||}|d}||}|d|d{V} g} g} d} |rd} | d |z} tdt|D]B}||}| d |z||}| | |zC| | | | | |d{V}|j rB| |d}||d }|||}||||d dS) a get the list of most recent trades for a particular symbol https://www.kucoin.com/docs-new/3470072w0 https://www.kucoin.com/docs-new/3470084w0 :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 symbolsNFTr/market/match:/contractMarket/execution:rtrades:rr)rrrrrrrr^rrrrrrVrmrr)rLrrrr[ symbolsLengthrrZrrrrrrrrrtradesr tradeSymbols rNrzkucoin.watch_trades_for_symbolssG A  #DG.n$noo o!!!!!!!!!%%gtUDAA227;; %j1OOG,, NN5/:::::::: &  76Kchhy111q#g,,'' > >AQZF  V!3 4 4 4 |H  % %kH&< = = = =..sM5J\^deeeeeeee ? 8OOFA..E**5(;;KOOK77E))&% TRRRrOcK|d{V||ddd}||}||}|d}|d|d{V}g}g}d} |rd} | d|z} t dt|D]:} || } |d | z|d | z;|| || ||d d|d } | ||| ||| d{VS) a` unWatches trades stream https://www.kucoin.com/docs-new/3470072w0 https://www.kucoin.com/docs-new/3470084w0 :param str symbols: :param dict [params]: extra parameters specific to the exchange API endpoint :returns dict[]: a list of `trade structures ` NFTrr"r#rrzunsubscribe:trades:r$r&r) rrrrr^rrrrr)rLrr[rrrZrrrrrrrrs rNun_watch_trades_for_symbolsz"kucoin.un_watch_trades_for_symbolss!!!!!!!!!%%gtUDAAOOG,, 227;; %j1NN5/:::::::: &  76Kchhy111q#g,,'' : :AQZF  !6!? @ @ @  % %i&&8 9 9 9 9 U###!!%(((* 2   //]E=Z`bnooooooooorOc@K||g|d{VS)a unWatches trades stream https://www.kucoin.com/docs-new/3470072w0 https://www.kucoin.com/docs-new/3470084w0 :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)r)rLrr[s rNun_watch_tradeszkucoin.un_watch_trades"s255vhGGGGGGGGGrOc||di}||d}||}|||}|d}d|z}||jvr5||jdd} t| } | |j|<|j|} | || | |dS)Nrarr$rDr5) rUrmr parse_trader&rlrGrrr) rLrorrarrtraderrrrcaches rN handle_tradezkucoin.handle_trade/s(~~gvr22##D(33!!(++  v..x&( $+%%%%dlM4HHE&&F"(DK  F# Uuk*****rOcBK||g||d{VS)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)rLrrr[s rNwatch_order_bookzkucoin.watch_order_bookQs4<66xOOOOOOOOOrOc@K||g|d{VS)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_symbolsr+s rNun_watch_order_bookzkucoin.un_watch_order_bookqs2996(FKKKKKKKKKrOc$Kt|}|dkrt|jdz|/|dkr)|dkr#|dkr|dkrt|jdz|d{V||}||}||}|d }|d |d{V}|rd nd } |rd nd} | |d| d| \} }| ddkr%|dks|dkr|sd} | dt|zz } | dzd |z} g} g} tdt|D]E}||}| d|z||}| | dz|zFi}| d ks| d kr |j||d}||| | | ||d{V}|S)au https://www.kucoin.com/docs-new/3470069w0 # spot level 5 https://www.kucoin.com/docs-new/3470070w0 # spot level 50 https://www.kucoin.com/docs-new/3470068w0 # spot incremental https://www.kucoin.com/docs-new/3470083w0 # futures level 5 https://www.kucoin.com/docs-new/3470097w0 # futures level 50 https://www.kucoin.com/docs-new/3470082w0 # futures incremental 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 :returns dict: A dictionary of `order book structures ` indexed by market symbols rzA watchOrderBookForSymbols() requires a non-empty array of symbolsNr2r8z? watchOrderBook 'limit' argument must be None, 5, 20, 50 or 100rFr;r:r>r6r$rDepth/spotMarket/level2rr orderbook:)rrr)rrrrrrrrr^rrrrrrhandle_order_book_subscriptionrr)rLrrr[r%rrrZrr optionNamerrrrrrr orderbooks rNr3z#kucoin.watch_order_book_for_symbolss G A  #DG.q$qrr r   %3,,Ub[[uPQzz#DG.o$oppp!!!!!!!!!%%g..OOG,, 227;; %j1NN5/::::::::-<R))BR)8J%%l 88AQS]_giopp ;;w  2 % %  &21F'CJJ.. sxx 222 q#g,,'' ? ?AQZF  !6 7 7 7 |H  % %fslX&= > > > > & & &F6N,N,N="L 11#}eM_agiuvvvvvvvv    rOcK||d}||d}|d{V||ddd}||}||}|d}|d|d{V}|rdnd}|rdnd } ||d | d |\}}|d d kr%|dks|dkr|sd}|d t|zz }|dzd |z} g} g} tdt|D]:} || }| d|z| d|z;| | | | | |dd| d}||| | | ||d{VS)aP https://www.kucoin.com/docs-new/3470069w0 # spot level 5 https://www.kucoin.com/docs-new/3470070w0 # spot level 50 https://www.kucoin.com/docs-new/3470068w0 # spot incremental https://www.kucoin.com/docs-new/3470083w0 # futures level 5 https://www.kucoin.com/docs-new/3470097w0 # futures level 50 https://www.kucoin.com/docs-new/3470082w0 # futures incremental 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' or '/contractMarket/level2' or '/contractMarket/level2Depth5' or '/contractMarket/level2Depth50' default is '/market/level2' for spot and '/contractMarket/level2' for futures :returns dict: A dictionary of `order book structures ` indexed by market symbols rNFTrr;r:r>r6r$rr;r<r8r:r=rrrzunsubscribe:orderbook:r>rA)rrrrr)rlomitrrrrr^rrrrrrrr)rLrr[rrrrZrrr@rrrrrrs rNr6z&kucoin.un_watch_order_book_for_symbolssJ !!&'2267++!!!!!!!!!%%gtUDAAOOG,, 227;; %j1NN5/::::::::-<R))BR)8J%%l 88AQS]_giopp ;;w  2 % %  &21F'CJJ.. sxx 222 q#g,,'' = =AQZF  !9F!B C C C  % %lV&; < < < < U###!!%(((* 2   //]E=Z`bnooooooooorOc||d}||d}|d}||d}||d}||d|}||dd} d| z} |d dkrY| |jvr||j| <n!|j| } | | |j| d<n}| |jvr||j| <|j| } || d } | |d d } | t| j }t|j }d}tdt|D]K}||}||dkr(||dkr|j |}nL||d }|ddd}||kr||j|| | |i| j |dS| | krdS||j| |||j| | dS)Nrarrryrrrr>r;nonce sequenceEndrrr$r<r8)rUrmr safe_symbolr orderbooks order_bookresetrlsafe_integer_2rr0listrkeysr handle_optionrWload_order_bookr handle_deltar)rLrorrar topicParts topicSymbol topicChannelrrrrArEdeltaEnd cacheLengthrrrkeyrr<s rNhandle_order_bookzkucoin.handle_order_booksR~~gv..  '22[[%% &&z155 '' A66 ##D(K@@!!(D#66"V+ ::g  ! # #do--*.//*;*;'' OF3 !!!06DOF #H - -do--*.//*;*;'/I%%i99E**4 LLH}!)/22 $V%9%>%>%@%@ A A # q#m"4"455A'*C--22,9O9OST9T9T'-';C'@ )),@@ $ 2 23C_VW X X -//JJt3V[&RWY[\\\&&t,,,("" $/&14888tv. <<<<.>5zzrOc||dd}||dd||d<||d<|||d<||d}|d}|d }||d }||d }||d } ||d } | dkrdnd } || g} | dkr|| dS|| dS||d|} || dg}|| d g}||||||dS)NtimerrFrZrErchangerrrrryrbuychanges) rKrrmrr storeArrayrUrkhandle_bid_asks)rLrAr]rrb storedBids storedAsks splitChangepricesidequantityrvaluerdrrs rNrPzkucoin.handle_deltaMs''v{CC !00 zS\]] '!* + $ Y 7 7 *!!%22v& v&   ,,s++K$$[!44E##K33D'' Q77H"emm66&DH%Ev~~%%e,,,,,%%e,,,,,nnUIu==G>>'6266D>>'6266D  T 2 2 2  T 2 2 2 2 2rOctdt|D]2}|||}||3dSNr)rr parse_bid_askre)rLbookSidebidAsksrbidAsks rNrfzkucoin.handle_bid_askshsYq#g,,'' ( (A'' 33F    ' ' ' ' ( (rOcZ||d}||d}|6||d}|i||j|<dSt dt |D](}||}|i||j|<)dS)Nrrrr)rlrkrmrIrHrr)rLrorrrrrrs rNr?z%kucoin.handle_order_book_subscriptionms!!,88..y99 ?%%lH==F&*oob%&@&@DOF # # #1c'll++ E E *.//"e*D*D'' E ErOcX||d}||jvrdS||j|}||j|}|j|=||d}| ||||||dd}|r||dg}||dg} t dt |D])} || } | | } ||| | *||dSdS)NrrrFrrr) rmrrV safe_boolrkrrclean_unsubscription clean_cache) rLrorrrrrisUnSubrrrrsubHashs rNhandle_subscription_statusz!kucoin.handle_subscription_status|sT  gt , ,f*** F++F,@"EEv';=MNN   $x88   F67L 1 1 1..}eDD  + NN<"MMM#~~l` Nstoptriggerordersrrr%rrT/spotMarket/advancedOrdersr?/contractMarket/advancedOrders/contractMarket/tradeOrdersrY) r safe_bool_2rCrrr^get_orders_message_hash_suffixrrrrfilter_by_symbol_since_limit)rLrrrr[rrrrrZrrsuffixrrs rN watch_orderszkucoin.watch_orderss"!!!!!!!!!""669==6FI#677  [[((FH%F%+f4K !?? vW]^^ F&&0NzX7MNN49999999907V,,=V  c8?b44EbE >88??F 6 !K d ~~c;t{{7TZ?[?[\\\\\\\\ ? 3OOFE22E00tTTTrOcDd}|dkr|dz }n|dkrd}n|dkrd}|S)N-spotrz-triggerr -contractrz-contract-triggerr}rLrrs rNrz%kucoin.get_orders_message_hash_suffixsH 0 0 0 j FF 3 3 3 FF 6 6 6(F rOcDdddddddd}||||S)Nopenclosedcanceled triggered)rfilledmatchupdatercancel TRIGGERED)rm)rLstatusstatusess rNparse_ws_order_statuszkucoin.parse_ws_order_statuss=" $  &&999rOc ||d}||}||dd}||d}|||}|dr||dd}||d}||d}|d uo|du} |d kr| rd }|id |d|dd ||dd||dd|d||ddd||dddddd||dd| |ddd|d|d||ddddd||dd|ddd |S)!Nr orderTime createdAtrrr stopPricetriggerSuccessTrrrrorderId clientOrderId clientOidrrlastTradeTimestamp orderType timeInForcepostOnlyrkrj orderPrice triggerPriceamountsizecostaverage filledSize)r remainingrfeer&) rmrrKrrrv safe_orderrsafe_string_lower safe_string_2) rLorderrrawTyperrrrr triggerFails rNparse_ws_orderzkucoin.parse_ws_ordersp@""5&11++G44''{KHH ##E844!!(F33 *  P11%hOOI''{;; /?@@%T1Sd8R k ! !{ !F E fX&  $""5)44  T--e[AA     Y//   !$  D**5+>>  4    D**5&99  T''w EE    L  d&&uf55 D! " t# $&&ul;;-   . / rOcz||d}||d}||||||}||d}||d}||d}|du} |jD||jdd} t| |_t| |_| r|jn|j} | | j |i} | | |} | | dd krd |d<| |d }||d }| |}||z}| | ||d z|z}| | |dS) NratradeIdrrr ordersLimitr5rrrrr)rUrmhandle_my_traderrrlrGr triggerOrdersrVhashmaprrr)rLrorrarrrrrisTriggerOrderr cachedOrdersrrrrrtypeSpecificMessageHashsymbolSpecificMessageHashs rN handle_orderzkucoin.handle_orderJs*~~gv..""433     1 1 1$$T**!!&(33""6400''?? &d2 ; %%dlM4HHE077DK!7!>!>D -;Lt)) !5vrBB00  X(**#+x F###   '2244U;;"-"6|%<===$/#$5$>!|%>?????rOc K|d{Vd}d}|+||}|d}|dz|dz}d}|d||\}}|dko|dk}|d|d{V} |rd nd } |rd nd } ||d| d | \} }ddi} ||| } || z }|| || || |d{V}|jr| ||}| ||||dS)a watches information on multiple trades made by the user on spot https://www.kucoin.com/docs-new/3470074w0 https://www.kucoin.com/docs-new/3470090w0 :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' or '/contractMarket/tradeOrders', default is '/spotMarket/tradeOrders' :returns dict[]: a list of `trade structures ` NmyTradesrrr(rrTrr?r>r6rrY) rrrr^r!get_my_trades_message_hash_suffixrrrrr)rLrrrr[rrrrZrrr@rrr&s rNwatch_my_tradeszkucoin.watch_my_trades|s!!!!!!!!!   [[((FH%F%+fX.>>K !??QWY_`` F&&0NzX7MNN4999999991@_--F_)8J%%l 77Q[]eglmm v d  >;;EBBF 6 !K~~c;t{{7TZ?[?[\\\\\\\\ ? 3OOFE22E00tTTTrOc@d}|ddkrd}|S)Nrrrr)rrs rNrz(kucoin.get_my_trades_message_hash_suffixs) ::& ' '1 , , F rOc|j0||jdd}t||_||d}||}|j}||d}||d}||} || z} | |j| |dz|dz} | |j| dS)NrDr5rarrrr) rrlrGrrUparse_ws_traderrmrr) rLrorrrarrrrrrrs rNrzkucoin.handle_my_trades: = %%dlM4HHE2599DM~~gv..$$T**=   '2277>>"-"6t}&=>>>$/#$5x8H$H!t}&?@@@@@rOc||d}|||d}|d}||d}||d}||d}||d}||d} |,||d}||d } ||d } ||d d d } |d} ||d} ||d}||| || ||| |||d||| d|| | dd |S)Nrrrrkr matchPrice matchSizerjrrrrarquotefeeRater liquidity)rratecurrency) rrrrrrr takerOrMakerrkrjrrr)rmrsafe_integer_product_2 safe_trader)rLr/rrrrrkrrjrrr feeCurrencyrfeeCosts rNrzkucoin.parse_ws_tradesR##E844!!(FC88!{33v..""5)44   55!!%55 =$$UG44E%%eV44F   22//tVXNN Wo ""5)44""5%00" Y// ,,UK@@'  $ % rOcK|d{V||jdd}||d|}||d}||jdi}||||}|dk}|d|d{V}||}|||||jd} || d d } || d d} | r | r| |d zd{V|d z} t| } |rdnd}| d|ddd}| ||}||j vr ||j | <||| ||d{VS)a watch balance and get the amount of funds available for trading or funds locked in orders https://www.kucoin.com/docs-new/3470075w0 # spot balance https://www.kucoin.com/docs-new/3470092w0 # contract balance :param dict [params]: extra parameters specific to the exchange API endpoint :param str [params.type]: 'spot' or 'swap'(default is 'spot') :returns dict: a `balance structure ` N defaultTyperraccountsByTyperTr.r@FrA:fetchBalanceSnapshot:balance/contractAccount/walletz/account/balancer)rrrrsrY)rrmrGrCrUr^roset_balance_cachervr]rr}rrr)rLr[rrr uniformTyperZrrorGr@rArrxrrrs rN watch_balancezkucoin.watch_balance#s!!!!!!!!!&&t|]FKK  <<66** 6FKK&&~tTBB &*4NN499999999S!! v{333..~>>#~~g7MuUU#~~g7MtTT  G$8 G-- .E EFF F F F F F F F!J. ))** 8G_44M_%"   ++gv.. F$888.>F  +ZZ['4@@@@@@@@@rOc2||jvr ||jvrdS||jd}||dd}|rD|dz}||jvr4||||j|||dSdSi|j|<dS)Nr.r@Fr) rbalancerUrGrvfuturesr]rWload_balance_snapshot)rLrorrGr@rs rNrzkucoin.set_balance_cacheLs F( ( (tt|/C/C F..~>>#~~g7MuUU  $!88K6>11 k*** 45v{DQQQQQ21"$DL   rOcXKd|i}||d{V}||||j|i|j|<||jvrG|j|}|||j||dzdSdS)Nrr) fetch_balancerrVrrr)rLrorrr[rsr]s rNrzkucoin.load_balance_snapshotYs D ++F33333333![[4??4> NN4+;+;DBU+V+VWW  (%d,=>>D,,T;@RSS++D'::*1 [!$'$($5$5dl;6O$P$P [!!J. t|K0+>>>>>rOc K|t|jdz|d{V|dd{V}||}d|dz}ddi}d|dz}||}||||d d d} |d d d} ||} | r$| r"| | d |zd{V} | S| |||| ||d{VS) ah watch open positions for a specific symbol https://www.kucoin.com/docs-new/3470093w0 :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:rrY position:rr&rBrCfetchPositionSnapshot:) rrrr^rroset_position_cacherNget_current_positionr]rr) rLrr[rrrrrrorBrCcurrentPositionsnapshots rNwatch_positionzkucoin.watch_positions >#DG.[$[\\ \!!!!!!!!!NN4((((((((V$$%t 4 d "F8$44 S!! /// $ 2 2?D[]a b b $ 2 2?D[]a b b33F;;  %: ?V#]]+Cf+LMMMMMMMMHO^^CeT[[RX=Y=YZZZZZZZZZrOc|jdS|jj}|||i}t|}||dSro) positionsrrVrLvalues)rLrr0 symbolCachers rNrzkucoin.get_current_positions[ > !4&ooeVR88 k((**++vq)))rOc|ddd}|rBd|z}||jvr6||||j|||dSdSdS)Nr&rBFr)rNrr]rWload_position_snapshot)rLrorrBrs rNrzkucoin.set_position_caches $ 2 2?D[]b c c  U2V;K6>11 k*** 46 VTTTTT  U U11rOc*K||d{V}t|_|j}||||jvr=|j|}||||d|zdSdS)Nr)fetch_positionrrrrr)rLrorrpositionr0r]s rNr zkucoin.load_position_snapshots,,V44444444/11 X &. ( (^K0F NN5 ! ! ! NN8[6%9 : : : : : ) (rOc|||dd}|d}||d}||dd}|j}||}d|z} ||di} || } t| } tdt| D]} | | }| || |=| || }| || || dS)Nrrryrrar)rmrrGrrrUparse_positionrLrMrrrrr)rLrorrrrrr0rrra newPositionrMrrVr s rNhandle_positionzkucoin.handle_positions9z  '266 C  ##E1--!!(D"5533F;;!F* ~~gvr22))$// K$$&&''q#d))$$ % %Aq'C3'$;; << Xx-----rOc<||d}|dkr|||dS||d}id|jd|jd|jd|jd|jd |jd |jd |jd |jd |jd|jd|jd|jd|jd|jd|jd|j|j|j|j |j |j d}| ||}||||dSdS)Nrz/market/ticker:allrlevel1level2ztrade.l2updatez trade.tickerztrade.snapshotz trade.l3matchztrade.candles.updatezaccount.balance orderChange stopOrderz/spot/tradeFillsrtickerV2z candle.stickr orderUpdatedsymbolOrderChange)zavailableBalance.changezwalletBalance.changezposition.changezposition.settlementzposition.adjustRiskLimit) rmrrrWr1rrrrrrV)rLrorrrmethodsrs rNhandle_subjectzkucoin.handle_subjectqs"  '22 ( ( (   vw / / / F""7I66 d) d,  d4  D.  d0  T.   #D$5  t2  4,  *   4  d(  +  D- T&! " D-# $ !2% &(,':$($7#3#'#7(,(r;s# ffffffffffvvvvvvvvvvvvvvvvvvvvvvvvvvvv444444******......%%%%%%H)H)H)H)H)T  &H)H)H)H)H)rO