ei ddlZddlmZmZmZmZddlmZm Z m Z m Z m Z m Z mZmZmZmZmZmZddlmZddlmZddlmZGddejjZdS) N) ArrayCacheArrayCacheBySymbolByIdArrayCacheBySymbolBySideArrayCacheByTimestamp) AnyBalancesIntMarketOrder OrderBookPositionStrStringsTickerTickersTrade)Client)List) NotSupportedcdeZdZdeffd ZdefdZdZdZddifde d e d e d e d e e f d Z ddiifde de d e d e de d e d e e defdZ ifde defdZifde defdZdifd edefdZdifd edefdZdddifde de dedede ef dZdifde de de efdZddifde dedede efdZifde de efdZdifde dedefdZifde defdZdddifdededede e fd Z!dddifdededede efd!Z"ifde#fd"Z$dddifd ededede e%fd#Z&d$e'fd%Z(d&Z)d'Z*d$e'd(e+fd)Z,d$e'd(e+fd*Z-d$e'd(e+fd+Z.d$e'd(e+fd,Z/d$e'd(e+fd-Z0d;d.e+d e fd/Z1d;d0e+d e fd1Z2d$e'd(e+fd2Z3d$e'd(e+fd3Z4d$e'd(e+fd4Z5d$e'fd5Z6d$e'fd6Z7d7Z8d$e'd8e+fd9Z9d$e'd(e+fd:Z:xZ;S)<xtreturnc"|tt|iddddddddddddddd dd dd dd dd ddddddddddddddiidddddiddidddddd|jddd S)!NwsT watchOHLCV unWatchOHLCVwatchOrderBookunWatchOrderBook watchTicker unWatchTicker watchTickersunWatchTickers watchTrades unWatchTradeswatchTradesForSymbolsF watchBalance watchOrders watchMyTradeswatchPositionsapizwss://stream.xt.comzwss://fstream.xt.com/ws)spotcontractmethodtickertickersswap)typefetchPositionsSnapshotawaitPositionsSnapshot) tradesLimit ordersLimit OHLCVLimitrr!r)i N) keepAliveping)hasurlsoptions streamingtoken) deep_extendsuperrdescriber9)self __class__s I/var/www/html/volatility/venv/lib/python3.11/site-packages/ccxt/pro/xt.pyrAz xt.describesxb$ 8 8 : :dd!$  #D  t  !$t (t  !$!& 5$= $#"h i!#.2.2##"# _0= 0= 0 0 0 isContractc K||rdnd}|jdd|}|s|dz}||}||jd}||r9|d{V}||d|jd<nN|d{V}||d}||d |jd<|jdS) a @ignore required for private endpoints :param str isContract: True for contract trades https://doc.xt.com/#websocket_privategetToken https://doc.xt.com/#futures_user_websocket_v2base :returns str: listen key / access token r,r+r*rz/privater>Nresult accessToken)check_required_credentialsr;client safe_string subscriptions)privateLinearGetFutureUserV1UserListenKeyprivateSpotPostWsToken safe_dict)rBrF tradeTypeurlrKr>responserHs rDget_listen_keyzxt.get_listen_keyCs/ '')))",8JJ& it$Y/ # "CS!!  !5w?? = X!%!O!O!Q!QQQQQQQ150@0@80T0T$W--!%!!>>>>>>>(;;040@0@0W0W$W-#G,,rEcN||d}||d}||dd}||dz krdStdt |D]+}||}||dd}||kr|cS,t |S)Nnonceriu) safe_integer safe_valuesafe_integer_2rangelen) rB orderbookcacherV firstDeltafirstDeltaNoncerWdelta deltaNonces rDget_cache_indexzxt.get_cache_indexrs!!)W55__UA.. --j#sCC ?Q& & &2q#e**%%  A!HE,,UC==JU""#5zzrEc^||dd|d<||dg}||dg}|d}|d}tdt|D]L}||}||d} ||d } || | Mtdt|D]L}||} || d} || d } || | MdS) NrWrXrVabbidsasksrrY)r] safe_listr^r_ safe_numberstore) rBr`rdobAsksobBidsrjrkrWbidpricequantityasks rD handle_deltazxt.handle_deltas8!00SAA 'sB//sB//  q#f++&& ( (A)C$$S!,,E''Q//H JJuh ' ' ' 'q#f++&& ( (A)C$$S!,,E''Q//H JJuh ' ' ' '  ( (rENnameaccess methodNamemarketsymbolscK|dk}d}||||\}}|dk} |||z} | rdnd| d} |rQ| s%|g| d<|| d{V| d<n0|| d{V} |d z| z} | g| d<n|g| d<| rd nd}|d z|z}||d zd |z}|| |}|}| r|rd nd}d| i}|jdd|dz|z}||||||d{VS)a) @ignore Connects to a websocket channel https://doc.xt.com/#websocket_privaterequestFormat https://doc.xt.com/#futures_market_websocket_v2base :param str name: name of the channel :param str access: public or private :param str methodName: the name of the CCXT class method :param dict [market]: CCXT market :param str[] [symbols]: unified market symbols :param dict params: extra parameters specific to the xt api :returns dict: data from the websocket stream privateNr+ SUBSCRIBE subscriber.idparams listenKey@r,::,userryrr*r/)handle_market_type_and_paramsnumber_to_string millisecondsrTjoinextendr;watch)rBrvrwrxryrzr privateAccessr2rFrr~rparamrQ messageHashrequesttail subscriptionrRs rDr~z xt.subscribes )+ 99*ffUU ffn  " "4#4#4#6#6 7 7$ >%/@kk[    ) .'+f (#/3/B/B:/N/N)N)N)N)N)N)N +&&"&"5"5j"A"AAAAAAA s Y.',g (###'&Ih ",8JJ& TkI-  %,sxx/@/@@K++i00  9*866D " it$Y/#5<ZZ['; UUUUUUUUUrErtopicc K|dk} d} ||||\} }| dk} |||z} | rdnd| d}| rQ| s%|g|d<|| d{V|d<n0|| d{V}|d z|z}|g|d<n|g|d<| rd nd}|d z|z}|||}|}| r| rd nd }|jdd|dz|z}d| |g|g||d}|| d}|||d<|| d} |||||||||| d{VS)a @ignore Connects to a websocket channel https://doc.xt.com/#websocket_privaterequestFormat https://doc.xt.com/#futures_market_websocket_v2base :param str messageHash: the message hash of the subscription :param str name: name of the channel :param str access: public or private :param str methodName: the name of the CCXT class method :param str topic: topic of the subscription :param dict [market]: CCXT market :param str[] [symbols]: unified market symbols :param dict params: extra parameters specific to the xt api :param dict subscriptionParams: extra parameters specific to the subscription :returns dict: data from the websocket stream r|Nr+ UNSUBSCRIBE unsubscriberrrrr,rrryr*rrT)rrsubMessageHashes messageHashesrzrsymbolsAndTimeframes) rrrrTrr;rlomitr)rBrrvrwrxrryrzrsubscriptionParamsrr2rFrrrrrQsubMessageHashrrrRrrs rD un_subscribezxt.un_subscribesT&)+ 99*ffUU ffn  " "4#4#4#6#6 7 7$ >'1Dmm}    + 0)- H%151D1DZ1P1P+P+P+P+P+P+P K(("&"5"5j"A"AAAAAAA s Y.). H%%%)FK !",8JJ& y0++k622  9*866Dit$Y/#5<!/ 0)]    $~~.@BXYY  +3GL/ 0!%+=?U!V!V ZZ[$++gv2N2NP[]a]h]hiuxJ^K^KLLLLLLLL LrEsymbolcRK|d{V||}||jd}||dd}||d|}|dz|dz}||dd|d|d{VS)a watches a price ticker, a statistical calculation with the information calculated over the past 24 hours for a specific market https://doc.xt.com/#websocket_publictickerRealTime https://doc.xt.com/#futures_market_websocket_v2tickerRealTime https://doc.xt.com/#futures_market_websocket_v2aggTickerRealTime :param str symbol: unified symbol of the market to fetch the ticker for :param dict params: extra parameters specific to the xt api endpoint :param str [params.method]: 'agg_ticker'(contract only) or 'ticker', default = 'ticker' - the endpoint that will be streamed :returns dict: a `ticker structure ` Nrr.r/rrpublic) load_marketsryrPr<rLr~)rBrrryr< defaultMethodr.rvs rD watch_tickerzxt.watch_tickers!!!!!!!!!V$$..}==(((HEE !!&(MBB|fTl*^^D(M64QWXXXXXXXXXrEc `K|d{V||}||jd}||dd}||d|}|dz|dz}d|z}|||dd||d|d{VS) a stops watching a price ticker, a statistical calculation with the information calculated over the past 24 hours for a specific market https://doc.xt.com/#websocket_publictickerRealTime https://doc.xt.com/#futures_market_websocket_v2tickerRealTime https://doc.xt.com/#futures_market_websocket_v2aggTickerRealTime :param str symbol: unified symbol of the market to fetch the ticker for :param dict params: extra parameters specific to the xt api endpoint :param str [params.method]: 'agg_ticker'(contract only) or 'ticker', default = 'ticker' - the endpoint that will be streamed :returns dict: a `ticker structure ` Nr r.r/rr unsubscribe::r)rryrPr<rLr) rBrrryr<rr.rvrs rDun_watch_tickerzxt.un_watch_tickers!!!!!!!!!V$$..??(((HEE !!&(MBB|fTl*%, &&{D(OUbdjlprxyyyyyyyyyrEcK|d{V||jd}||dd}||d|}d}|||d}||dd|||d{V}|jr|S||jd|S)a watches a price ticker, a statistical calculation with the information calculated over the past 24 hours for a specific market https://doc.xt.com/#websocket_publicallTicker https://doc.xt.com/#futures_market_websocket_v2allTicker https://doc.xt.com/#futures_market_websocket_v2allAggTicker :param str [symbols]: unified market symbols :param dict params: extra parameters specific to the xt api endpoint :param str [params.method]: 'agg_tickers'(contract only) or 'tickers', default = 'tickers' - the endpoint that will be streamed :returns dict: a `ticker structure ` Nr!r.r0rrr) rrPr<rLryr~ newUpdatesfilter_by_arrayr0)rBrzrr<rrvryr0s rD watch_tickerszxt.watch_tickers*s!!!!!!!!!..~>>(((IFF -@@  [[,,FtX~vwX^________ ? N##DL(GDDDrEc K|d{V||jd}||dd}||d|}|t |jdzd|z}|||dddd||d{V}|jr|S||j d |S) a stops watching a price ticker, a statistical calculation with the information calculated over the past 24 hours for a specific market https://doc.xt.com/#websocket_publicallTicker https://doc.xt.com/#futures_market_websocket_v2allTicker https://doc.xt.com/#futures_market_websocket_v2allAggTicker :param str [symbols]: unified market symbols :param dict params: extra parameters specific to the xt api endpoint :param str [params.method]: 'agg_tickers'(contract only) or 'tickers', default = 'tickers' - the endpoint that will be streamed :returns dict: a `ticker structure ` Nr"r.r0zc unWatchTickers() does not support symbols argument, unsubscribtion is for all tickers at once onlyrrr/r) rrPr<rLrrrrrr0)rBrzrr<rrvrr0s rDun_watch_tickerszxt.un_watch_tickersCs!!!!!!!!!../?@@(((IFF -@@  tw*O OPP P%, ))+tXGWYacgiprxyyyyyyyy ? N##DL(GDDDrE1m timeframesincelimitc2K|d{V||}d|dzdz|z}||dd|d|d{V}|jr|||}||||ddS) a watches historical candlestick data containing the open, high, low, and close price, and the volume of a market https://doc.xt.com/#websocket_publicsymbolKline https://doc.xt.com/#futures_market_websocket_v2symbolKline :param str symbol: unified symbol of the market to fetch OHLCV data for :param str timeframe: 1m, 3m, 5m, 15m, 30m, 1h, 2h, 4h, 6h, 8h, 12h, 1d, 3d, 1w, or 1M :param int [since]: not used by xt watchOHLCV :param int [limit]: not used by xt watchOHLCV :param dict params: extra parameters specific to the xt api endpoint :returns int[][]: A list of candles ordered, open, high, low, close, volume Nkline@rrrrrTrryr~rgetLimitfilter_by_since_limit) rBrrrrrryrvohlcvs rD watch_ohlcvzxt.watch_ohlcv\s!!!!!!!!!V$$&,&,y8nnT8\64QWXXXXXXXX ? 2NN6511E))%q$GGGrEc K|d{V||}d|dzdz|z}d|z}|d|gg}|||ddd ||g|d |i d{VS) aU stops watching historical candlestick data containing the open, high, low, and close price, and the volume of a market https://doc.xt.com/#websocket_publicsymbolKline https://doc.xt.com/#futures_market_websocket_v2symbolKline :param str symbol: unified symbol of the market to fetch OHLCV data for :param str timeframe: 1m, 3m, 5m, 15m, 30m, 1h, 2h, 4h, 6h, 8h, 12h, 1d, 3d, 1w, or 1M :param dict params: extra parameters specific to the xt api endpoint :returns int[][]: A list of candles ordered, open, high, low, close, volume Nrrrrrrrrrrryr)rBrrrryrvrrs rDun_watch_ohlcvzxt.un_watch_ohlcvrs!!!!!!!!!V$$&,&,y8%, !'!19 =>&&{D(NT[]cflemouyOQexfgggggggg grEc$K|d{V||}d|dz}||dd|d|d{V}|jr|||}||||dS)a` get the list of most recent trades for a particular symbol https://doc.xt.com/#websocket_publicdealRecord https://doc.xt.com/#futures_market_websocket_v2dealRecord :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 xt api endpoint :returns dict[]: a list of `trade structures ` Ntrade@rrr# timestampr)rBrrrrryrvtradess rD watch_tradeszxt.watch_tradess!!!!!!!!!V$$&,&~~dHmVTSYZZZZZZZZ ? 3OOFE22E))&% LLLrEc K|d{V||}d|dz}d|z}|||ddd||g|d{VS)a stops watching the list of most recent trades for a particular symbol https://doc.xt.com/#websocket_publicdealRecord https://doc.xt.com/#futures_market_websocket_v2dealRecord :param str symbol: unified symbol of the market to fetch trades for :param dict params: extra parameters specific to the xt api endpoint :returns dict[]: a list of `trade structures ` Nrrrrr$rr)rBrrryrvrs rDun_watch_tradeszxt.un_watch_tradess!!!!!!!!!V$$&,&%, &&{D(OU]_ehngoqwxxxxxxxxxrEc`K|d{V||}||d}||d}d|dz}|d|dzdz|z}||dd|d|d{V}|S) a watches information on open orders with bid(buy) and ask(sell) prices, volumes and other data https://doc.xt.com/#websocket_publiclimitDepth https://doc.xt.com/#websocket_publicincreDepth https://doc.xt.com/#futures_market_websocket_v2limitDepth https://doc.xt.com/#futures_market_websocket_v2increDepth :param str symbol: unified symbol of the market to fetch the order book for :param int [limit]: not used by xt watchOrderBook :param dict params: extra parameters specific to the xt api endpoint :param int [params.levels]: 5, 10, 20, or 50 :returns dict: A dictionary of `order book structures ` indexed by market symbols Nlevels depth_update@rdepth@rrr)rryrLrr~r)rBrrrryrrvr`s rDwatch_order_bookzxt.watch_order_books!!!!!!!!!V$$!!&(3368,,-  fTl*S069D..x9I6SWY_````````    rEc HK|d{V||}||d}||d}d|dz}|d|dzdz|z}d|z}|||dd d ||g|d{VS) a stops watching information on open orders with bid(buy) and ask(sell) prices, volumes and other data https://doc.xt.com/#websocket_publiclimitDepth https://doc.xt.com/#websocket_publicincreDepth https://doc.xt.com/#futures_market_websocket_v2limitDepth https://doc.xt.com/#futures_market_websocket_v2increDepth :param str symbol: unified symbol of the market to fetch the order book for :param dict params: extra parameters specific to the xt api endpoint :param int [params.levels]: 5, 10, 20, or 50 :returns dict: A dictionary of `order book structures ` indexed by market symbols Nrrrrrrrrr`)rryrLrr)rBrrryrrvrs rDun_watch_order_bookzxt.un_watch_order_books!!!!!!!!!V$$!!&(3368,,-  fTl*S069D%, &&{D(DVXcekntmuw}~~~~~~~~~rEcK|d{Vd}d}|||}||dd|d|d{V}|jr|||}||||dS)a- watches information on multiple orders made by the user https://doc.xt.com/#websocket_privateorderChange https://doc.xt.com/#futures_user_websocket_v2order :param str [symbol]: unified market symbol :param int [since]: not used by xt watchOrders :param int [limit]: the maximum number of orders to return :param dict params: extra parameters specific to the xt api endpoint :returns dict[]: a list of `order structures ` Norderr|r'rr)rBrrrrrvryorderss rD watch_orderszxt.watch_orderss!!!!!!!!!  [[((F~~dI}fdTZ[[[[[[[[ ? 3OOFE22E))&% LLLrEcK|d{Vd}d}|||}||dd|d|d{V}|jr|||}||||dS)aZ watches information on multiple trades made by the user https://doc.xt.com/#websocket_privateorderDeal https://doc.xt.com/#futures_user_websocket_v2trade :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 orde structures to retrieve :param dict params: extra parameters specific to the kucoin api endpoint :returns dict[]: a list of `trade structures ` Ntrader|r(rr)rBrrrrrvryrs rDwatch_my_tradeszxt.watch_my_tradess!!!!!!!!!  [[((F~~dIPTV\]]]]]]]] ? 3OOFE22E))&% LLLrEc~K|d{Vd}||dddd|d{VS)av watches information on multiple orders made by the user https://doc.xt.com/#websocket_privatebalanceChange https://doc.xt.com/#futures_user_websocket_v2balance :param dict params: extra parameters specific to the xt api endpoint :returns dict[]: a list of `balance structures ` Nbalancer|r&)rr~)rBrrvs rD watch_balancezxt.watch_balance s`!!!!!!!!!^^D)^T4QWXXXXXXXXXrEcXK|d{V|jddddzdz}||}|||ddd }|dd d }|j} |rK|rI|| r4|dd{V} || |||d Sd } | | d ddd|d{V} |j r| S|| |||d S) a https://doc.xt.com/#futures_user_websocket_v2position watch all open positions :param str[]|None symbols: list of unified market symbols :param number [since]: since timestamp :param number [limit]: limit :param dict params: extra parameters specific to the exchange API endpoint :returns dict[]: a list of `position structure ` Nr*rr,rrr)r3Tr4positionr|) rr;rKset_positions_cache handle_option positionsis_emptyfuturefilter_by_symbols_since_limitr~r) rBrzrrrrRrKr3r4rasnapshotrv newPositionss rDwatch_positionszxt.watch_positionssx!!!!!!!!!it$Z036?S!!   (((!%!3!34DF^`d!e!e!%!3!34DF^`d!e!e ! ]&< ]uAUAU ]#]]+CDDDDDDDDH55hPUW[\\ \!^^D)=MtUY[abbbbbbbb ?  11%%PTUUUrErKc|jt|_|dd}|r>d}||jvr5||||j||dSdSdS)Nr)r3)rrrfuturesrspawnload_positions_snapshot)rBrKr3rs rDrzxt.set_positions_cache4s > !577DN!%!3!34DF^!_!_ ! N2K6>11 k*** 47MMMMM  N N11rEcK|dd{V}t|_|j}tdt |D]<}||}||dd}|dkr||=||jvr:|j|}||||ddSdS)Nr contractsposition::contract) fetch_positionsrrr^r_rmappendrresolve) rBrKrrrarWrrrs rDrzxt.load_positions_snapshot>s..t44444444 133q#i..)) ' 'A |H((;BBI1}} X&&& &. ( (^K0F NN5 ! ! ! NN5"6 7 7 7 7 7 ) (rEc`|jt|_|j}||di}||}||||d}t dt|D]}||}|d} | d} | d} | |gd| d} | | s| | || |gddS) NdatarrrrYrrF) rrrPparse_positionrfind_message_hashesr^r_splitrrr) rBrKmessagerarrrrWrparts symbolsStringrzrs rDhandle_positionzxt.handle_positionMs+> > !577DN~~gvr22&&t,, X009MNN q#m,,-- 7 7A'*K%%d++E!!HM#))#..G,,hZ7ERRI==++ 7y+666z#788888rErcX||d}||d}|{||d}|du}||}|d}||j|<||d} |rdnd} | dz| z} ||| |S) Nrscvreventr+r,r)rPrL parse_tickerr0r) rBrKrrmarketIdrisSpotr/rrmessageHashTailrs rD handle_tickerzxt.handle_ticker}sz~~gv..##D#..  !!$--Bt^F&&t,,FH%F#)DL $$Wg66E(.>ffJO$,8K NN6; / / /rEc||dg}||d}||dd}|dnd}g}tdt |D]F}||} || } | d} | |j| <|| G||dd z|z} | || d z} tdt | D]}| |}| d }|d }| d }| |d|}t| }t |}|dkr|||||j| |S) Nrrraqr+r,rrrr)rlrP safe_string_2r^r_rr0rrLrrrlistkeysr)rBrKrr firstTickerspotTestrQ newTickersrW tickerDatar/rmessageHashStartrrrrrzr0tickersSymbols numTickerss rDhandle_tickerszxt.handle_tickerssH~~gvr22nnT1-- %%k4>>'3FF*  q#d))$$ & &AaJ&&z22FH%F#)DL   f % % % %++GW==DyP009ID9PQQ q#m,,-- 5 5A'*K%%d++E!!HM#))#..G**:xIIG!',,..11N^,,JA~~w 444t|%5666rEc||di}||d}|||d}d|vrdnd}||dd|}|d}|||} ||j|i|j|<||j||} | ;||jdd } t| } | |j||<| | ||d } | d z|z} | | | |S) NrrrWqr+r,rr7r-rr) rPrL safe_market parse_ohlcvohlcvsr\r[r<rrr)rBrKrrrrrQryrparsedstoredrrrs rD handle_ohlcvzxt.handle_ohlcv&sUL~~gvr22##D#..  ((s33I#&$;;ZI%%hdIFFFH%F%%dF33F"&..fb"I"IDK __T[%8)DDF~))$, dKK.u5517 F#I. MM& ! ! !$$Wg66E$,2K NN6; / / /rEc:||d}||d}|||}||d}|dnd}||dd|}|d} ||d} ||j| } | 5||jdd } t| } | |j| <| || d z|z} | | | |S) NrrrWr+r,rrr5r-r) rPsafe_string_lower parse_traderLr r\rr[r<rrr)rBrKrrrrrWrQryrr tradesArrayr5rs rD handle_tradezxt.handle_trade`s'>~~gv..))$44  $$T**E  s++A#$=zI%%hdIFFFH%F$$Wg66E//$+v>>K""// mTRR (55 &1 F#   u % % %$,2K NN; 4 4 4rEc||d}||d}|||d}|d}||d}d|vrdnd}||dd|}|d } ||d } ||d } |d z|z} | |jvrP||j| i} || d }|i||j| <|j| }||d}|jt|j }| ddd}||kr| |j || | |j |dS| r|d}tdt| D]L}| |}||d}||d}|||M| r|d}tdt| D]L}| |}||d}||d}|||M||d}||dd|d<||d<|||d<| |d <||| dSdS)Nrrrrrfur,r+rrhrirrrVr snapshotDelayrkrYrjtrWrXrdatetime)rPrLrr rl orderbooksrMr[ order_bookr_rarrload_order_bookrr^rmrnr]iso8601r)rBrKrrrr splitEventrQryrrorprrrr`rV cacheLengthrrkrWrtrrrsrjrqrs rDhandle_order_bookzxt.handle_order_books*x~~gv..##D#..  $$Wg66ES))J$$Z33E'+t|| &I%%hdIFFFH%F^^D#..F^^D#..F$,2Kdo--#~~f.BKQSTT )),@@*.//"e*D*D'/I%%i99E}!)/22 $ 2 23C_VX Y Y -//JJt3V[&QQQ&&t,,,! (q#f++..00A )C ,,S!44E#//Q77HJJuh////! (q#f++..00A )C ,,S!44E#//Q77HJJuh////))$44I!%!4!4T3!D!DIg %.Ik "$(LL$;$;Ij !"(Ih  NN9k 2 2 2 2 2U rErc8||d}d|vrdnd}|||d|}||d}||d||||d||dd|||dd ||d d d||d ||d dd||dddd |S)Nrrr,r+rrWorderIdststatesd orderSiderrorigQtyf)currencycostrate) inforrrrrr2side takerOrMakerrramountr,fee)rLr  safe_traderparse_order_statusrrm)rBrryrrQrs rDparse_ws_order_tradezxt.parse_ws_order_trades<B##E3//#+u#4#4JJ6 !!(FD)DD$$UC00 " Y//X&%%eS)<<++D,<,.>udG.T.TUU ((445   6 7 rEc|j}|1||jd}t|}||_||di}||dd}|dd|vrdnd}||dd|}|||} || | |d|z|S)Nr6rrrr,r+zorder::) rr[r<rrPrr rOrr) rBrKrrrrrrQryrs rD handle_orderzxt.handle_ordersV >%%dlMBBE+E22F DKw33%%eS(;;  '/5'8'8 vI%%hdIFFF((77F MM& ! ! ! NN69y#8 9 9 9rEc||di}||dd}||}|}||d|d<||d|d<||dd |d <||j|<||j|_d|vrd nd }||jd |zdS)NrccoinavailableBalancefreer*usedri walletBalancetotalr,r+z balance::)rPrsafe_currency_codeaccountrLr safe_balancer)rBrKrr currencyIdcoder[rQs rDhandle_balancezxt.handle_balancesF~~gvr22''c6:: &&z22,,..**41CDD**455--dCII$ T((66 #)T>>JJ t|[9%<=====rEc~||di}|j}|2||jdd}t |}||_||}||d}|||drdnd}||d|zdS)Nrr5r-rr,r+ztrade::) rPmyTradesr[r<rrryrr) rBrKrrrr parsedTraderyrQs rDhandle_my_tradeszxt.handle_my_tradessF~~gvr22 >%%dlM4HHE+E22F"DM&&t,, [233 k""""("4@JJ& vy9455555rEc ||d}|dkr|dS|||d}|j|j|j|j|j|j|j|j|j|jd }| ||}|dkr-| |d}d|vsd|vr|j }n|j }||||dSdS| ||dS) Nrpongr) klinedepth depth_updater/ agg_tickerr0 agg_tickersrrrrroir$)rLonPongrr"rrr_rQrr\rPrcrhandle_subscription_status)rBrKrrrmethodsr.rs rDhandle_messagezxt.handle_messages0  '22 F?? MMOOOOO  $$Wg66E*/ $ 6,"0.#2.* 0  G__We44F~~gv66DLLi4&7&7!2FF!.F!vw'''''"!  + +FG < < < < EE >>>*;RDDL..}eLLK B++FLAAArErc||dg}||dg}tdt|D])}||}||}||||*||dS)Nrrr)rlr^r_clean_unsubscription clean_cache)rBrKrrrj unsubHashsubHashs rDruzxt.handle_un_subscriptionUs|_bII >>,8JBOOq#m,,-- B BA%a(I&q)G  % %fgy A A A A &&&&&rEc||d}|dks|dkr!d|jd<|ddS||dS)Nmsginvalid_listen_keyz token expirer>T)rLrMrTreject)rBrKrr~s rDhandle_error_messagezxt.handle_error_message^smw.. ' ' 'SN-B-B,0F  )    % % % F grE)N)<__name__ __module__ __qualname__rrAboolrTrfrustrr rr~rrrrrrrrr rrrrrrr rrrr rrrrr rrrrrdictrrrrr"r5rOrQr_rcror9rmrur __classcell__)rCs@rDrrsM1 #1 1 1 1 1 1 f--t--------^   (((&Y]swAC/V/VC/V/V#/Vv/Vgklogp/V/V/V/Vbz~UYbdy{9L9Lc9L9Lc9LWZ9Lcf9Lpv9LIMNQIR9L@C9L9L9L9Lv68YYYFYYYY*9;zzCzvzzzz,6:"EE7EEEEE29=REEgEGEEEE2?CQUdhqsHHHH3H^aHx|~ByCHHHH,BFbgg3g3gUYZ^U_gggg&<@d[]MMMSMMbfglbmMMMM*9;yyCytE{yyyy"@DB!!S!!S\!!!!2=?9004$UYbdMMMCMsMimnsitMMMM.37TX\egMMCMsMRUMlpqvlwMMMM.*, Y Y Y Y Y Y8<$]ajlVVWVCVWZVquv~qVVVV8N&NNNN 8 8 8.9.9.9`IFITIIIIV\V\d\\\\|868D8888t060D0000dh3h3h3h3h3h3T77$77777rJJDJ&JJJJX868D8888t->V->d->->->->^-6v-6-6-6-6-6^=V====<64'V'4'''' 6 D        rEr)ccxt.async_supportccxt ccxt.async_support.base.ws.cacherrrrccxt.base.typesrrr r r r r rrrrr!ccxt.async_support.base.ws.clientrtypingrccxt.base.errorsr async_supportrrErDrs) AAAAAAAAAAAAxxxxxxxxxxxxxxxxxxxxxxxxxxxx444444))))))]]]]]  ]]]]]rE