":hddlZddlmZmZmZmZddlmZm Z m Z m Z m Z m Z mZmZmZmZmZmZddlmZddlmZGddej0j2Zy)N) ArrayCacheArrayCacheBySymbolByIdArrayCacheBySymbolBySideArrayCacheByTimestamp) AnyBalancesIntMarketOrder OrderBookPositionStrStringsTickerTickersTrade)Client)Listc deZdZdeffd ZdefdZdZdZddifde d e d e d e d e e f d Z ifde de fdZdifd edefdZdddifde dedede efdZddifde dedede efdZdifde dedefdZdddifdededede efdZdddifdededede efdZifdefdZdddifd ededede efdZ de!fdZ"dZ#dZ$de!de%fd Z&de!de%fd!Z'de!de%fd"Z(de!de%fd#Z)de!de%fd$Z*d/d%e%d e fd&Z+d/d'e%d e fd(Z,de!de%fd)Z-de!de%fd*Z.de!de%fd+Z/de!fd,Z0de!fd-Z1de!de%fd.Z2xZ3S)0xtreturnc|jtt|dddddddddddd dddddiid d d d d id d id ddddd|jdddS)NTF) ws watchOHLCVwatchOrderBook watchTicker watchTickers watchTradeswatchTradesForSymbols watchBalance watchOrders watchMyTradeswatchPositionsapirzwss://stream.xt.comzwss://fstream.xt.com/ws)spotcontractmethodtickertickersswap)typefetchPositionsSnapshotawaitPositionsSnapshot) tradesLimit ordersLimit OHLCVLimitrrr#i N) keepAliveping)hasurlsoptions streamingtoken) deep_extendsuperrdescriber3)self __class__s E/var/www/html/turnos/venv/lib/python3.12/site-packages/ccxt/pro/xt.pyr;z xt.describesb$ 8 :""&# $#). $#!%"&  5$= $#"h i!#.2.2#"# U+= + + isContractcK|j|rdnd}|jdd|}|s|dz}|j|}|j|jd}||r8|j d{}|j|d|jd<nI|j d{}|j|d}|j|d |jd<|jdS7|7Fw) 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/privater8Nresult accessToken)check_required_credentialsr5client safe_string subscriptions)privateLinearGetFutureUserV1UserListenKeyprivateSpotPostWsToken safe_dict)r<r@ tradeTypeurlrEr8responserBs r>get_listen_keyzxt.get_listen_key=s '')",J& iit$Y/ "CS!  !5!5w? =!%!O!O!QQ150@0@80T$$W-!%!>(;040@0@0W$$W-##G,,3R?s%A7C:9C6:7C:1C82AC:8C:c|j|d}|j|d}|j|dd}||dz krytdt |D]#}||}|j|dd}||k\s!|cSt |S)Nnonceriu) safe_integer safe_valuesafe_integer_2rangelen) r< orderbookcacherP firstDeltafirstDeltaNoncerQdelta deltaNonces r>get_cache_indexzxt.get_cache_indexls!!)W5__UA. --j#sC ?Q& &q#e*% A!HE,,UC=JU"   5zr?c|j|dd|d<|j|dg}|j|dg}|d}|d}tdt|D]=}||}|j |d} |j |d } |j | | ?tdt|D]=}||} |j | d} |j | d } |j | | ?y) NrQrRrPabbidsasksrrS)rW safe_listrXrY safe_numberstore) r<rZr^obAsksobBidsrdrerQbidpricequantityasks r> handle_deltazxt.handle_deltazs!00SA 'sB/sB/  q#f+& (A)C$$S!,E''Q/H JJuh '  ( q#f+& (A)C$$S!,E''Q/H JJuh '  (r?Nnameaccess methodNamemarketsymbolscJK|dk(}d}|j|||\}}|dk7} | rdnd|j|j|zd} |rM| s#|g| d<|j| d{| d<n.|j| d{} |d z| z} | g| d<n|g| d<| rd nd} |d z| z}||d zd j |z}|j | |}|}| r|rd nd}|j dd| dz|z}|j||||d{S777w)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 subscribe)r(idparams listenKey@r&::,userrsr$r/)handle_market_type_and_paramsnumber_to_string millisecondsrNjoinextendr5watch)r<rprqrrrsrtrz privateAccessr,r@rxr{paramrK messageHashrequesttailrLs r>rxz xt.subscribesh )+ 99*ffU ffn %/k[''(9(9(;` Nrr(r)r|rypublic) load_marketsrsrJr6rFrx)r<rrzrsr6 defaultMethodr(rps r> watch_tickerzxt.watch_tickers!!!V$..}=(((HE !!&(MB|fTl*^^D(M64QWXXX " Ys"BBA;BBBBcK|jd{|j|jd}|j|dd}|j|d|}d}||j |d}|j |dd|||d{}|j r|S|j|jd|S771w)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 ` Nrr(r*rrr) rrJr6rFrsrx newUpdatesfilter_by_arrayr*)r<rtrzr6rrprsr*s r> watch_tickerszxt.watch_tickerss!!!..~>(((IF -@  [[,FtX~vwX^__ ??N##DLL(GDD "`s"CB>A7CC0CC1msincelimitc"K|jd{|j|}d|dzdz|z}|j|dd|d|d{}|jr|j ||}|j |||ddS7t79w) 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 Nzkline@ryr~rrrTrrsrxrgetLimitfilter_by_since_limit) r<r timeframerrrzrsrpohlcvs r> watch_ohlcvzxt.watch_ohlcvs!!!V$&,&,y8nnT8\64QWXX ??NN651E))%q$GG "Ys!BB ` Nztrade@ryrr timestampr)r<rrrrzrsrptradess r> watch_tradeszxt.watch_tradess!!!V$&,&~~dHmVTSYZZ ??OOFE2E))&% LL "[s!BB6B B7BBc8K|jd{|j|}|j|d}|j|d}d|dz}|d|dzdz|z}|j |dd|d|d{}|j S77w) 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 Nlevelsz depth_update@ryzdepth@r~rr)rrsrFomitrxr)r<rrrzrsrrprZs r>watch_order_bookzxt.watch_order_books!!!V$!!&(368,-  fTl*S069D..x9I6SWY_``    "as"BBA*BBBBcK|jd{d}d}||j|}|j|dd|d|d{}|jr|j ||}|j |||dS7k78w)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 ` Norderrvr!rr)r<rrrrzrprsorderss r> watch_orderszxt.watch_orders,s!!!  [[(F~~dI}fdTZ[[ ??OOFE2E))&% LL " \!BB4B B 7BBcK|jd{d}d}||j|}|j|dd|d|d{}|jr|j ||}|j |||dS7k78w)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 ` Ntradervr"rr)r<rrrrzrprsrs r>watch_my_tradeszxt.watch_my_tradesCs!!!  [[(F~~dIPTV\]] ??OOFE2E))&% LL " ^rcK|jd{d}|j|dddd|d{S7$7w)ax 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 ` Nbalancervr )rrx)r<rzrps r> watch_balancezxt.watch_balanceZsE!!!^^D)^T4QWXXX "Xs?;?=??c0K|jd{|jddddzdz}|j|}|j||j ddd }|j dd d }|j } |rA|r?|j | r.|jdd{} |j| |||d Sd } |j| d ddd|d{} |jr| S|j| |||d S77^7+w) 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#r-Tr.positionrv) rr5rEset_positions_cache handle_option positionsis_emptyfuturefilter_by_symbols_since_limitrxr) r<rtrrrzrLrEr-r.r[snapshotrp newPositionss r>watch_positionszxt.watch_positionshs,!!!iit$Z036?S!   (!%!3!34DF^`d!e!%!3!34DF^`d!e !&<uAU#]]+CDDH55hPUW[\ \!^^D)=MtUY[abb ?? 11%%PTUU "Ecs4DDBD3D44D(D)(DDDrEc|jt|_|jdd}|r@d}||jvr/|j ||j |j ||yyy)Nr#r-)rrrfuturesrspawnload_positions_snapshot)r<rEr-rs r>rzxt.set_positions_cachesk >> !57DN!%!3!34DF^!_ !2K6>>1 k* 477M2 "r?cnK|jdd{}t|_|j}tdt |D]1}||}|j |dd}|dkDs!|j |3|j|}|j||j|dy7w)Nr contractsposition::contract) fetch_positionsrrrXrYrgappendrresolve) r<rErrr[rQrrrs r>rzxt.load_positions_snapshots..t44 13q#i.) 'A |H((;BI1} X&  '  ,uu235sB5B3AB5-AB5c|jt|_|j}|j|di}|j|}|j ||j |d}t dt|D]g}||}|jd} | d} | jd} |j|gd| d} |j| rV|j| |i|j|gdy) Ndatarrr}rSr~rF) rrrJparse_positionrfind_message_hashesrXrYsplitrrr) r<rEmessager[rr messageHashesrQrparts symbolsStringrtrs r>handle_positionzxt.handle_positions> >> !57DN~~gvr2&&t, X009MN q#m,- 7A'*K%%d+E!!HM#))#.G,,hZ7ERI==+y+6 7 z#78r?rc,|j|d}|j|d}|m|j|d}|du}|j|}|d}||j|<|j|d} |rdnd} | dz| z} |j || |S) Nrscvreventr%r&r})rJrF parse_tickerr*r) r<rErrmarketIdrisSpotr)rrmessageHashTailrs r> handle_tickerzxt.handle_tickersz~~gv.##D#.  !!$-Bt^F&&t,FH%F#)DLL $$Wg6E(.fJO$,8K NN6; /r?c|j|dg}|j|d}|j|dd}|dnd}g}tdt |D]=}||} |j | } | d} | |j | <|j| ?|j|dd z|z} |j|| d z} tdt | D]}}| |}|jd }|d }|jd }|j|d|}t|j}t |}|dkDsl|j|||j|j | |S) Nrrraqr%r&rtopicr}r~)rfrJ safe_string_2rXrYrr*rrFrrrlistkeysr)r<rErr firstTickerspotTestrK newTickersrQ tickerDatar)rmessageHashStartrrrrrtr*tickersSymbols numTickerss r>handle_tickerszxt.handle_tickerssH~~gvr2nnT1- %%k4>'3F*  q#d)$ &AaJ&&z2FH%F#)DLL   f %  &  ++GW=DyP009ID9PQ q#m,- 5A'*K%%d+E!!HM#))#.G**:xIG!',,.1N^,JA~w 4 5 t||%56r?cd|j|di}|j|d}||j|d}d|vrdnd}|j|dd|}|d}|j||} |j|j|i|j|<|j |j||} | :|j |jdd } t| } | |j||<| j| |j|d } | d z|z} |j| | |S) NrrrQqr%r&rr1r'rr}) rJrF safe_market parse_ohlcvohlcvsrVrUr6rrr)r<rErrrrrKrsrparsedstoredrrrs r> handle_ohlcvzxt.handle_ohlcvus1L~~gvr2##D#.  ((s3I#&$;ZI%%hdIFFH%F%%dF3F"&..fb"IDKK __T[[%8)DF~))$,, dK.u517 F#I. MM& !$$Wg6E$,2K NN6; /r?c|j|d}|j|d}||j|}|j|d}|dnd}|j |dd|}|d} |j|d} |j |j | } | 7|j|jdd } t| } | |j | <| j|| d z|z} |j| | |S) NrrrQr%r&rrr/r'r}) rJsafe_string_lower parse_traderFrrVrrUr6rrr)r<rErrrrrQrKrsrr tradesArrayr/rs r> handle_tradezxt.handle_trades>~~gv.))$4  $$T*E  s+A#$=zI%%hdIFFH%F$$Wg6E//$++v>K""// mTR (5 &1 F#   u %$,2K NN; 4r?cD|j|d}|j|d}|y|j|d}|jd}|j|d}d|vrdnd}|j|dd|}|d } |j |d } |j |d } |d z|z} | |j vrN|j|j | i} |j| d }|ji||j | <|j | }|j|d}|gt|j}|jddd}||k(r|j|j|| | |jj|y| Z|d}tdt| D]=}| |}|j!|d}|j!|d}|j#||?| Z|d}tdt| D]=}| |}|j!|d}|j!|d}|j#||?|j|d}|j%|dd|d<||d<|j'||d<| |d <|j)|| yy)Nrrrr~rfur&r%rrbrcr}rrPr snapshotDelayrerSrdtrQrRrdatetime)rJrFrrrf orderbooksrGrU order_bookrYr[rrload_order_bookrrXrgrhrWiso8601r)r<rErrrr splitEventrKrsrrirjr subscriptionrrZrP cacheLengthrrerQrnrlrmrdrkrs r>handle_order_bookzxt.handle_order_booksx~~gv.##D#.  $$Wg6ES)J$$Z3E'+t| &I%%hdIFFH%F^^D#.F^^D#.F$,2Kdoo-#~~f.B.BKQST )),@*.//"e*D'/I%%i9E}!)//2 $ 2 23C_VX Y -/JJt33V[&Q&&t,! (q#f+.0A )C ,,S!4E#//Q7HJJuh/ 0 ! (q#f+.0A )C ,,S!4E#//Q7HJJuh/ 0 ))$4I!%!4!4T3!DIg %.Ik "$(LL$;Ij !"(Ih  NN9k 2U r?rc|j|d}d|vrdnd}|j||d|}|j|d}|j|d||j||d|j|dd|j |j|dd |j |d d d|j |d |j|d dd|j |dddd |S)Nrrr&r%rrQorderIdststatesd orderSiderlorigQtyf)currencycostrate) inforyrrrrr,side takerOrMakerrlamountrfee)rFr safe_traderparse_order_statusrrg)r<rrsrrKrs r>parse_ws_order_tradezxt.parse_ws_order_tradeKsB##E3/#+u#4J6 !!(FD)D$$UC0 " Y/X&%%eS)<++D,<,parse_ws_orderzxt.parse_ws_ordersV%%eS(;#+u#4J6 !!(FD)D''t\B  E $$$UC;  T//t_M     Y/  !$   fX&  F6N  4    D,,UD+F  T''sG<      $ d((i@! " d((mD# $))%6))%zB--d.>.>udG.TU ((45 6 7 r?cv|j}|.|j|jd}t|}||_|j |di}|j |dd}|Td|vrdnd}|j |dd|}|j||} |j| |j|d|z|S)Nr0rrrr&r%zorder::) rrUr6rrJrrr1rr) r<rErrrrrrKrsrs r> handle_orderzxt.handle_ordersV >%%dllMBE+E2F DKw3%%eS(;  '/5'8 vI%%hdIFF((7F MM& ! NN69y#8 9r?c|j|di}|j|dd}|j|}|j}|j |d|d<|j |d|d<|j|dd |d <||j |<|j |j |_d|vrd nd }|j|j d |zy)NrccoinavailableBalancefreer usedrc walletBalancetotalr&r%z balance::)rJrsafe_currency_codeaccountrFr safe_balancer)r<rErr currencyIdcoder=rKs r>handle_balancezxt.handle_balance sF~~gvr2''c6: &&z2,,.**41CD**45--dCI$ T((6 #)T>J t||[9%<=r?cL|j|di}|j}|/|j|jdd}t |}||_|j |}|j |d}|j||drdnd}|j|d|zy)Nrr/r'rr&r%ztrade::) rJmyTradesrUr6rrrsrr) r<rErrrr parsedTradersrKs r>handle_my_tradeszxt.handle_my_trades9sF~~gvr2 >%%dllM4HE+E2F"DM&&t, [23 k""("4J& vy945r?c  |j|d}|dk(r|jy||j|d}|j|j|j|j|j|j |j |j |j|jd }|j||}|dk(r3|j|d}d|vsd|vr |j}n |j}| |||yyy) Nrpongr) klinedepth depth_updater) agg_tickerr* agg_tickersrrrrroir) rFonPongrrrrrAr3rrVrJrEr)r<rErrrmethodsr(rs r>handle_messagezxt.handle_messagehs  '2 F? MMO  $$Wg6E**// $ 6 6,,"00..#22..** 00 G__We4F~~gv6DLi4&7!22F!..F!vw'"+r?c.|j|_y)Nr3)rlastPong)r<rEs r>r3zxt.pings++-r?c|j|d}|dk(s|dk(r!d|jd<|jdy|j|y)Nmsginvalid_listen_keyz token expirer8T)rFrGrNreject)r<rErrTs r>handle_error_messagezxt.handle_error_messagesSw. ' 'SN-B,0F  )    %  gr?)N)4__name__ __module__ __qualname__rr;boolrNr`rostrr rrxrrrrrr rrrrr rrr rrrrr rrrrrdictrrrrrrr1r3rArErPr3rW __classcell__)r=s@r>rr s, #, \--t--^ (&Y]swAC+HC+H+H#+Hv+Hgklogp+HZ68YYFY*6:"E7EE28<$]ajlHHCHWZHquvzq{H,<@d[]MMSMMbfglbmM*@DB!S!!S\!204$UYbdMMCMsMimnsitM.37TX\egMCMsMRUMlpqvlwM.*, Y Y8<$]ajlVWVCVWZVquv~qV8N&N 4.9`IFITIV\V\d\|868D8t060D0dh3h3h3T7$77rJDJ&JX868D8t->V->d->^-6v-6-6^(V(86 6 D r?r)ccxt.async_supportccxt ccxt.async_support.base.ws.cacherrrrccxt.base.typesrrr r r r r rrrrr!ccxt.async_support.base.ws.clientrtypingr async_supportrr?r>rgsB AAxxxx4H    Hr?