E#iSSKrSSKJrJrJrJr SSKJrJ r J r J r J r J r JrJrJrJrJrJr SSKJr SSKJr SSKJr "SS\R4R65rg) N) ArrayCacheArrayCacheBySymbolByIdArrayCacheBySymbolBySideArrayCacheByTimestamp) AnyBalancesIntMarketOrder OrderBookPositionStrStringsTickerTickersTrade)Client)List) NotSupportedc^\rSrSrS\4U4SjjrS\4SjrSrSr SS04S \ S \ S \ S \ S \ \ 4 Sjjr SS004S\ S \ S \ S \ S\ S \ S \ \ S\4Sjjr04S\ S\4Sjjr04S\ S\4SjjrS04S \S\4SjjrS04S \S\4SjjrSSS04S\ S\ S\S\S\ \4 SjjrS04S\ S\ S\ \4SjjrSS04S\ S\S\S\ \4Sjjr04S\ S\ \4SjjrS04S\ S\S\4Sjjr04S\ S\4S jjrSSS04S\ S\S\S\ \!4S!jjr"SSS04S\ S\S\S\ \4S"jjr#04S\$4S#jjr%SSS04S \S\S\S\ \&4S$jjr'S%\(4S&jr)S'r*S(r+S%\(S)\,4S*jr-S%\(S)\,4S+jr.S%\(S)\,4S,jr/S%\(S)\,4S-jr0S%\(S)\,4S.jr1S=S/\,S \ 4S0jjr2S=S1\,S \ 4S2jjr3S%\(S)\,4S3jr4S%\(S)\,4S4jr5S%\(S)\,4S5jr6S%\(4S6jr7S%\(4S7jr8S8r9S%\(S9\,4S:jr:S%\(S)\,4S;jr;Sxtreturnc>UR[[U]50SS_SS_SS_SS_SS_SS_SS_S S_S S_S S_S S_S S_SS_SS_SS_SS_SSSSS.00SSSSS0SS0SSSS.S.SURS.SS .5$)!NwsT watchOHLCV unWatchOHLCVwatchOrderBookunWatchOrderBook watchTicker unWatchTicker watchTickersunWatchTickers watchTrades unWatchTradeswatchTradesForSymbolsF watchBalance watchOrders watchMyTradeswatchPositionsapizwss://stream.xt.comzwss://fstream.xt.com/ws)spotcontractmethodtickertickersswap)typefetchPositionsSnapshotawaitPositionsSnapshot) tradesLimit ordersLimit OHLCVLimitr r"r*i N) keepAliveping)hasurlsoptions streamingtoken) deep_extendsuperrdescriber:)self __class__s E/home/james-whalen/.local/lib/python3.13/site-packages/ccxt/pro/xt.pyrB xt.describesRb$ 8 :dd!$  #D  t  !$t (t  !$!& 5$= $#"h i!#.2.2#"# _0= 0 0 isContractc# UR5 U(aSOSnURSSUnU(dUS-nURU5nURURS5nUcU(a8UR 5IShvN nURUS5URS'OIUR 5IShvN nURUS5nURUS 5URS'URS$N|NF7f) 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)rCrH tradeTypeurlrMr?responserJs rEget_listen_keyxt.get_listen_keyCs '')",J& iit$Y/ "CS!  !5!5w? =!%!O!O!QQ150@0@80T$$W-!%!>(;040@0@0W$$W-##G,,3R?s%BD  D 7D DAD D cURUS5nURUS5nURUSS5nX5S- :ag[S[ U55H#nX&nURUSS5nX:dM!Us $ [ U5$)Nnonceriu) safe_integer safe_valuesafe_integer_2rangelen) rC orderbookcacherY firstDeltafirstDeltaNoncerZdelta deltaNonces rEget_cache_indexxt.get_cache_indexrs!!)W5__UA. --j#sC Q& &q#e*%AHE,,UC=J" & 5zrGcURUSS5US'URUS/5nURUS/5nUSnUSn[S[U55H<nXGnUR US5n UR US 5n UR X5 M> [S[U55H<nX7n UR U S5n UR U S 5n UR X5 M> g) NrZr[rYabbidsasksrr\)r` safe_listrarb safe_numberstore) rCrcrgobAsksobBidsrnrorZbidpricequantityasks rE handle_deltaxt.handle_deltas!00SA 'sB/sB/  q#f+&A)C$$S!,E''Q/H JJu ' ' q#f+&A)C$$S!,E''Q/H JJu ' 'rGNnameaccess methodNamemarketsymbolsc# US:HnSnURX4U5upUS:gn URUR55U-n U (aSOSU S.n U(aRU (d#U/U S'URU 5IShvN U S'O.URU 5IShvN n US -U -n U /U S'OU/U S'U (aS OSnUS -U-nUbUS -S R U5-nUR X5nUnU (a U(aS OSnSU 0nUR SSUS-U-nURUUUUU5IShvN $NNN7f)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-::,userr~rr+r/handle_market_type_and_paramsnumber_to_string millisecondsrVjoinextendr<watch)rCr{r|r}r~rr privateAccessr3rHrrrparamrS messageHashrequesttail subscriptionrTs rEr xt.subscribest )+ 99*fU fn  " "4#4#4#6 7$ >%/k[  '+f (#/3/B/B:/N)N +&"&"5"5j"AA s Y.',g (##'&Ih ",J& TkI-  %,sxx/@@K++i0 *6D " iit$Y/#5<ZZ['; UUU'*OA"Vs7A9E;E<EEB"E;E<EEErtopicc # US:Hn Sn URXFU5upU S:gn URUR55U-n U (aSOSU S.nU (aRU (d#U/US'URU 5IShvN US'O.URU 5IShvN nUS -U-nU/US'OU/US'U (aS OSnUS -U-nUbUS -S R U5-nUR X5nUnU (a U (aS OSnUR SSUS-U-nSU U/U/UUS.nURUXR UU5XR UU 55IShvN $NNN7f)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 rNr, UNSUBSCRIBE unsubscriberrrrr-rrrr~r+rrT)rrsubMessageHashes messageHashesrrr)rCrr{r|r}rr~rrsubscriptionParamsrr3rHrrrrrSsubMessageHashrrrTrs rE un_subscribext.un_subscribes&)+ 99*fU fn  " "4#4#4#6 7$ >'1m}  )- H%151D1DZ1P+P K("&"5"5j"AA s Y.). H%%)FK !",J& y0  +d2SXXg5FFN++k2 *6Diit$Y/#5<!/ 0)]  ZZ[++gv2NP[]h]hiuxJ^KLL L1,QA,Ls7A9E+;E%<E+E'CE+ E)!E+'E+)E+symbolc:# UR5IShvN URU5nURURS5nUR USS5nUR USU5nUS-US-nUR USSUSU5IShvN $NN7f)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 ` Nr r/r0rrpublic) load_marketsr~rRr=rNr)rCrrr~r= defaultMethodr/r{s rE watch_tickerxt.watch_tickers!!!V$..}=(((HE !!&(MB|fTl*^^D(M64QWXXX " Ys"BBA;BBBBc D# UR5IShvN URU5nURURS5nUR USS5nUR USU5nUS-US-nSU-nUR XSSXSSU5IShvN $NN7f) 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/r0rr unsubscribe::r)rr~rRr=rNr) rCrrr~r=rr/r{rs rEun_watch_tickerxt.un_watch_tickers!!!V$..?(((HE !!&(MB|fTl*%, &&{(OUblprxyyy "zs"B BBB BB B c# UR5IShvN URURS5nURUSS5nURUSU5nUR U5nSnUbUR US5nUR USSXaU5IShvN nUR(aU$URURSU5$NN67f)az 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/r1rrr) rrRr=rNmarket_symbolsr~r newUpdatesfilter_by_arrayr1)rCrrr=rr{r~r1s rE watch_tickersxt.watch_tickers(s!!!..~>(((IF -@%%g.  [[,FtX~vX^__ ??N##DLL(GDD "`s"CCBCC 5CCc # UR5IShvN URURS5nURUSS5nURUSU5nUb[ UR S-5eSU-nUR XeSSSSX5IShvN nUR(aU$URURS U5$NN67f) 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/r1zc unWatchTickers() does not support symbols argument, unsubscribtion is for all tickers at once onlyrrr0r) rrRr=rNrrrrrr1)rCrrr=rr{rr1s rEun_watch_tickersxt.un_watch_tickersBs!!!../?@(((IF -@  tww*O OP P%, ))+XGWYacgipyy ??N##DLL(GDD "zs"CC A?CC 5C C1m timeframesincelimitc(# UR5IShvN URU5nSUS-S-U-nURUSSUSU5IShvN nUR(aUR X5nUR XUSS5$NwN<7f) aj 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@rrrrrTrr~rrgetLimitfilter_by_since_limit) rCrrrrrr~r{ohlcvs rE watch_ohlcvxt.watch_ohlcv[s!!!V$&,&,y8nnT8\64QWXX ??NN61E))%q$GG "Ys!BB` Ntrade@rrr$ timestampr)rCrrrrr~r{tradess rE watch_tradesxt.watch_tradess!!!V$&,&~~dHmVTSYZZ ??OOF2E))& LL "[s!B B6B  B :B  B c # UR5IShvN URU5nSUS-nSU-nURXTSSSUSU5IShvN $NAN7f)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%trader)rCrrr~r{rs rEun_watch_tradesxt.un_watch_tradessn!!!V$&,&%, &&{(OU\^dfjlrsss "ts!AA` indexed by market symbols Nlevels depth_update@rdepth@rrr)rr~rNomitrr)rCrrrr~rr{rcs rEwatch_order_bookxt.watch_order_books!!!V$!!&(368,-  fTl*S069D..x9I6SWY_``    "as"BBA+BBBBc &# UR5IShvN URU5nURUS5nURUS5nSUS-nUbSUS-S-U-nSU-nUR XeSS S USU5IShvN $NvN7f) 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 Nrrrrrrrrdepth)rr~rNrr)rCrrr~rr{rs rEun_watch_order_bookxt.un_watch_order_books!!!V$!!&(368,-  fTl*S069D%, &&{(DVX_agimouvvv "ws"BB A1BB BBc# UR5IShvN SnSnUbURU5nURUSSUSU5IShvN nUR(aUR X5nUR XrUS5$NoN;7f)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 ` Norderrr(rr)rCrrrrr{r~orderss rE watch_ordersxt.watch_orderss!!!  [[(F~~dI}fdTZ[[ ??OOF2E))& LL " \!B B5B  B :B B c# UR5IShvN SnSnUbURU5nURUSSUSU5IShvN nUR(aUR X5nUR XrUS5$NoN;7f)a 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 ` Nrrr)rr)rCrrrrr{r~rs rEwatch_my_tradesxt.watch_my_tradess!!!  [[(F~~dIPTV\]] ??OOF2E))& LL " ^rc# UR5IShvN SnURUSSSSU5IShvN $N$N7f)aH 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 ` Nbalancerr')rr)rCrr{s rE watch_balancext.watch_balance sC!!!^^D)^T4QWXXX "Xs?;?=??cR# UR5IShvN URSSSS-S-nURU5nURU5 UR SSS 5nUR SS S 5nUR n U(aIU(aBUR U 5(a,URS5IShvN n URXX#S 5$S n URU S SSSU5IShvN n UR(aU $URXX#S 5$GN N`N/7f) 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*r4Tr5positionr) rr<rMset_positions_cache handle_option positionsis_emptyfuturefilter_by_symbols_since_limitrr) rCrrrrrTrMr4r5rdsnapshotr{ newPositionss rEwatch_positionsxt.watch_positionss#!!!iit$Z036?S!   (!%!3!34DF^`d!e!%!3!34DF^`d!e !&<uAUAU#]]+CDDH55hW[\ \!^^D)=MtUY[abb ?? 11%%PTUU "Ecs4D'D B+D'D#2D'5D%6+D'#D'%D'rMcURc[5UlURSS5nU(a@SnX1R;a.UR U5 UR UR X5 ggg)Nr*r4)rrrfuturesrspawnload_positions_snapshot)rCrMr4rs rErxt.set_positions_cache3sg >> !57DN!%!3!34DF^!_ !2K>>1 k* 477M2 "rGct# URS5IShvN n[5UlURn[S[ U55H3nX5nUR USS5nUS:dM"UR U5 M5 URUnURU5 URUS5 gN7f)Nr contractsposition::contract) fetch_positionsrrrarbrqappendrresolve) rCrMrrrdrZrrrs rErxt.load_positions_snapshot=s..t44 13q#i.)A |H((;BI1} X& *  ,uu235sB8B6AB8.A B8cURc[5UlURnURUS05nURU5nUR U5 UR US5n[ S[U55HlnXgnURS5n U Sn U RS5n URU/SU S5n URU 5(aM[URX5 Mn URU/S5 g) Ndatarrrr\rrF) rrrRparse_positionrfind_message_hashesrarbsplitrrr) rCrMmessagerdrrrrZrparts symbolsStringrrs rEhandle_positionxt.handle_positionKs> >> !57DN~~gvr2&&t, X009MN q#m,-A'*K%%d+E!!HM#))#.G,,hZ7ERI==++y6. z#78rGr c4URUS5nURUS5nUbpURUS5nUSLnURU5nUSnXpRU'URUS5n U(aSOSn U S-U -n UR X{5 U$) Nrscvreventr,r-r)rRrN parse_tickerr1r) rCrMr rmarketIdrisSpotr0rrmessageHashTailrs rE handle_tickerxt.handle_ticker{sz~~gv.##D#.  !!$-Bt^F&&t,FH%F#)LL $$Wg6E(.fJO$,8K NN6 /rGcURUS/5nURUS5nURUSS5nUbSOSn/n[S[ U55H<nX8n UR U 5n U Sn XR U 'URU 5 M> URUS5S -U-n URXS -5n [S[ U 55HnXnURS 5nUS nURS 5nURUSU5n[UR55n[ U5nUS:dMmURUU5 M URUR U 5 U$) Nrrraqr,r-rrrr)rprR safe_string_2rarbrr1rrNrr rlistkeysr)rCrMr r firstTickerspotTestrS newTickersrZ tickerDatar0rmessageHashStartrrr r rr1tickersSymbols numTickerss rEhandle_tickersxt.handle_tickersstH~~gvr2nnT1- %%k4>'3F*  q#d)$AJ&&z2FH%F#)LL   f % %  ++GW=DyP00D9PQ q#m,-A'*K%%d+E!!HM#))#.G**:xIG!',,.1N^,JA~w 4. t||%56rGcfURUS05nURUS5nUGbURUS5nSU;aSOSnURUSSU5nUSnURX75n URURU05URU'UR URUU5n U c9UR URSS 5n [U 5n XRUU'U RU 5 URUS 5n U S -U-n URX5 U$) NrrrZqr,r-rr8r.rr) rRrN safe_market parse_ohlcvohlcvsr_r^r=rrr)rCrMr rrrrSr~rparsedstoredrrrs rE handle_ohlcvxt.handle_ohlcv$s+L~~gvr2##D#.  ((s3I#&$;ZI%%hdIFFH%F%%d3F"&..fb"IDKK __T[[%8)DF~))$,, dK.u517 F#I. MM& !$$Wg6E$,2K NN6 /rGcURUS5nURUS5nUbURU5nURUS5nUbSOSnUR USSU5nUSn URUS5n UR UR U 5n U c6URURSS 5n [U 5n XR U 'U RU5 U S -U-n URX5 U$) NrrrZr,r-rrr6r.r) rRsafe_string_lower parse_traderNr*r_rr^r=rrr)rCrMr rrrrZrSr~rr tradesArrayr6rs rE handle_tradext.handle_trade^s>~~gv.))$4  $$T*E  s+A#$=zI%%hdIFFH%F$$Wg6E//$++v>K""// mTR (5 &1 F#   u %$,2K NN; 4rGcVURUS5nURUS5nUGbURUS5nURS5nURUS5nSU;aSOSnURUSSU5nUS n UR US 5n UR US 5n US -U-n XR ;aNURUR U 05n URU S 5nUR0U5UR U 'UR U nURUS5nUcg[UR5nURSSS5nUU:XaURURXU 5 URRU5 gU b\USn[S[U 55H>nU UnUR!US5nUR!US5nUR#UU5 M@ U b\USn[S[U 55H>nU UnUR!US5nUR!US5nUR#UU5 M@ URUS5nUR%USS5US'UUS'UR'U5US'XS 'UR)X5 gg)Nrrrrrfur-r,rrlrmrrrYr snapshotDelayror\rntrZr[rdatetime)rRrNr r*rp orderbooksrOr^ order_bookrbrdrrload_order_bookrrarqrrr`iso8601r)rCrMr rrr splitEventrSr~rrsrtrrrrcrY cacheLengthr9rorZrxrvrwrnrurs rEhandle_order_bookxt.handle_order_booksx~~gv.##D#.  $$Wg6ES)J$$Z3E'+t| &I%%hdIFFH%F^^D#.F^^D#.F$,2Koo-#~~f.B.BKQST )),@*.//"e*D'/I%%i9E}!)//2 $ 2 23C_VX Y -/JJt33V&Q&&t,! (q#f+.A )C ,,S!4E#//Q7HJJuh/ / ! (q#f+.A )C ,,S!4E#//Q7HJJuh/ / ))$4I!%!4!4T3!DIg %.Ik "$(LL$;Ij !"(h  NN9 2U rGrcURUS5nSU;aSOSnURX2SU5nURUS5nURUSUURU5USURUSS5UR URUSS 55UR US S 5SUR US 5URUS 5SSUR US5SS.S. U5$)Nrrr-r,r;rZorderIdststatesd orderSidervorigQtyf)currencycostrate) inforrr<rrr3side takerOrMakerrvamountrNfee)rNr* safe_trader@parse_order_statusr2rq)rCrr~rrSrs rEparse_ws_order_tradext.parse_ws_order_tradesB##E3/#+u#4J6 !!(D)D$$UC0 " Y/X&%%eS)<++D,<,.>udG.TU ((45 6 7 rGczURnUc-URURS5n[U5nX0lUR US05nUR USS5nUbUSU;aSOSnUR USSU5nURXX5n URU 5 URUSU-5 U$)Nr7rrrr-r,zorder::) rr^r=rrRrr*rrrr) rCrMr rrrrrSr~r-s rE handle_orderxt.handle_ordersV >%%dllMBE+E2F Kw3%%eS(;  '/5'8 vI%%hdIFF((7F MM& ! NN69y#8 9rGcURUS05nURUSS5nURU5nUR5nUR US5US'UR US5US'URUSS 5US 'X`R U'UR UR 5UlSU;aS OS nURUR S U-5 g)NrccoinavailableBalancefreerLusedrm walletBalancetotalr-r,z balance::)rRrsafe_currency_codeaccountrNr safe_balancer)rCrMr r currencyIdcoderrSs rEhandle_balancext.handle_balancesF~~gvr2''c6: &&z2,,.**41CD**45--dCI$ T((6 #)T>J t||[9%<=rGcVURUS05nURnUc.URURSS5n[ U5nX@lUR U5nUR US5nURU5 US(aSOSnURUSU-5 g)Nrr6r.rr-r,ztrade::) rRmyTradesr^r=rr3r~rr) rCrMr rr.r parsedTrader~rSs rEhandle_my_tradesxt.handle_my_tradessF~~gvr2 >%%dllM4HE+E2F"M&&t, [23 k""("4J& vy945rGc :URUS5nUS:XaUR5 gUbURUS5nURURURURURUR UR UR URURS. nURXT5nUS:Xa7URUS5nSU;dSU;a URnO URnUb U"X5 ggURX5 g) Nrpongr) rr depth_updater0 agg_tickerr1 agg_tickersrrrrroirF)rNonPongr/rCrr&rrur r_rRrr5handle_subscription_status)rCrMr rrmethodsr/rs rEhandle_messagext.handle_messages   '2 F? MMO  $$Wg6E**// $ 6 6,,"00..#22..** 00 G__W4F~~gv6DLi4&7!22F!..F!v'"  + +F >,8JBOq#m,-A%(I&)G  % %fy A. &rGcURUS5nUS:XdUS:Xa!SURS'URS5 gURU5 g)Nmsginvalid_listen_keyz token expirer?T)rNrOrVreject)rCrMr rs rEhandle_error_messagext.handle_error_messageSsSw. ' 'SN-B,0F  )    %  grG)rrrr)N)>__name__ __module__ __qualname____firstlineno__rrBboolrVrirystrr rrrrrrrrrrr rrrrrrr rrrr rrrrr rrrrr dictrr&r/r5rCrWrrrurrrr:rrr__static_attributes__ __classcell__)rDs@rErrse1 #1 f--t--^ (&Y]swAC/VC/V/V#/Vv/Vgklogp/Vbz~UYbdy{7Lc7L7Lc7LWZ7Lcf7Lpv7LIMNQIR7L@C7Lr68YYFY*9;zCzvz,6:"E7EE49=REgEGE2?CQUdhqsHHH3H^aHx|~ByCH,BFbs3s3sUYZ^U_s&<@d[]MMSMMbfglbmM*9;tCttE{t"@DB!S!!S\!2=?ww9w004$UYbdMMCMsMimnsitM.37TX\egMCMsMRUMlpqvlwM.*, Y Y8<$]ajlVWVCVWZVquv~qV8N&N 4.9`IFITIV\V\d\|868D8t060D0dh3h3h3T7$77rJDJ&JX868D8t->V->d->^-6v-6-6^=V=<6"'V'4' 6 D  rGr)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_supportrrGrErsE AAxxxx4)R    RrG