":hvddlZddlmZmZmZddlmZmZm Z m Z m Z m Z m Z mZmZmZddlmZddlmZddlmZddlmZGdd ej0j2Zy) N) ArrayCacheArrayCacheBySymbolByIdArrayCacheByTimestamp) AnyBalancesIntOrder OrderBookStrStringsTickerTickersTrade)Client)List) ExchangeError) NotSupportedc eZdZdeffd ZifdefdZdefdZd$dZ ifde de fd Z difd e defd Zdefd Zd$d Zddifde dededeefdZdefdZdddifdedededeefdZdddifde dededeefdZdefdZd$defdZdifde dedefdZdZdZ defdZ!dddifdedededee"fdZ#defdZ$d$dZ%defdZ&defdZ'defd Z(defd!Z)defd"Z*ifd#Z+xZ,S)%wazirxreturnc|jtt|ddddddddddd dddiiiiiddd d iiid S) NTF) ws watchBalance watchTicker watchTickers watchTradeswatchTradesForSymbols watchMyTrades watchOrderswatchOrderBook watchOHLCVapirzwss://stream.wazirx.com/streamprivatepostcreate_auth_token)hasurlsoptions streaming exceptionsr") deep_extendsuperrdescribe)self __class__s I/var/www/html/turnos/venv/lib/python3.12/site-packages/ccxt/pro/wazirx.pyr.zwazirx.describesfd < > $# $#).!%#"&" : +Q1A   c K|jd{|j|d{}d}|jdd}ddg|d}|j||}|j ||||d{S7f7O7w)aO watch balance and get the amount of funds available for trading or funds locked in orders https://docs.wazirx.com/#account-update :param dict [params]: extra parameters specific to the exchange API endpoint :returns dict: a `balance structure ` Nbalancer"r subscribeoutboundAccountPositioneventstreamsauth_key) load_markets authenticater(r,watch)r/paramstoken messageHashurlr5requests r1 watch_balancezwazirx.watch_balance3s!!!''// iit$ 12 ""9f5ZZ[';GGG "/Hs2BA=BA?AB8B9B?BBclientc|j|di}|j|dg}|j|d}||jd<||jd<|j||jd<t dt |D]w}||}|j |d}|j|} |j |d } |j |d } |j} | | d <| | d <| |j| <y|j|j|_d } |j|j| y)NdataBEinfo timestampdatetimerablfreeusedr4) safe_value safe_integerr4iso8601rangelen safe_stringsafe_currency_codeaccount safe_balanceresolve)r/rDmessagerFbalancesrJir4 currencyIdcode availablelockedrXr@s r1handle_balancezwazirx.handle_balanceHs0"w3??4b1%%dC0 ' V$- [!#'<< #: Z q#h-( )AqkG))'37J**:6D((#6I%%gs3FllnG'GFO$GFO!(DLL  )((6  t||[1r2Nc|j|d}|j|d}|j||}|j|d}|j|d}|j|ddu}d}|||j |dd}|j |j|d|||j ||d |j|d gd|j|d |rd nd |j|d|j|dd|d |S)NrHsfUmT)costcurrencyratetsymboloSmakertakerpq) idrIrJrKrlordertypeside takerOrMakerpriceamountrhfee)rRrV safe_marketrQrW safe_traderS safe_string_n) r/trademarketrJmarketIdfeeCost feeCurrencyIdisMakerrzs r1parse_ws_tradezwazirx.parse_ws_tradems2>%%eS1 ##E3/!!(F3""5#.((4 //%-5   33MBC ""5#." Y/X&''u5$$UC0'.GG%%eS1&&uc2   r2rlcK|jd{|j|}|jdd}d|dz}d}d}d|gd }|j||} |j ||| |d{S7g7w) a watches a price ticker, a statistical calculation with the information calculated over the past 24 hours for a specific market https://docs.wazirx.com/#all-market-tickers-stream :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 ` Nr"rticker:rltickers !ticker@arrr5r8r9)r;rr(r,r=) r/rlr>rrAr@ subscribeHashstreamr5rBs r1 watch_tickerzwazirx.watch_tickers!!!V$iit$&"22 ! # x ""9f5ZZ['=III "Js"BA>A"B9B:BBsymbolsc K|jd{|j|}|jdd}d}d}d|gd}|j||}|j ||||d{}|j |d|d S7s7w) a watches a price ticker, a statistical calculation with the information calculated over the past 24 hours for all markets of a specific list https://docs.wazirx.com/#all-market-tickers-stream :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 ` Nr"rrrr5rrlF)r;market_symbolsr(r,r=filter_by_array) r/rr>rAr@rr5rBrs r1 watch_tickerszwazirx.watch_tickerss!!!%%g.iit$ # x ""9f5 3 WkJJ##GXwFF "Ks"BB AB1B 2B Bc|j|dg}tdt|D]C}||}|j|}|d}||j|<d|z}|j ||E|j |jdy)NrFrrlrr)rQrTrUparse_ws_tickerrrZ) r/rDr[rFr]ticker parsedTickerrlr@s r1 handle_tickerzwazirx.handle_tickers.w3q#d)$ 6A!WF//7L!(+F#/DLL #f,K NN< 5  6 t||Y/r2c|j|d}|j|d}|jid|j||d|d|j |d|j|dd|j|d d |j |d d dd |j |dddddd|j|dddd|j|d ddddddddd|j|d|d|S)NrdrHrlrJrKhighhlowrNbidrM bidVolumeaskrL askVolumevwapopenrmcloselast previousClosechange percentageaveragerr) baseVolume quoteVolumerI)rVrR safe_ticker safe_symbolrS safe_number)r/rrrrJs r1rzwazirx.parse_ws_tickers"##FC0%%fc2 ! d&&x8! !   Y/!  D$$VS1 ! 4##FC0 ! 4##FC0 !  !  4##FC0!  !  D!  D$$VS1!  T!  D$$VS1!  T!  d! $!! " t#! $++FC8)! * + r2sincelimitcpK|jd{|j|}|d}|ddz}|jdd}d|gd}|j||} |j ||| |d{} |j r| j ||}|j| ||d d S779w) a  get the list of most recent trades for a particular symbol https://docs.wazirx.com/#trade-streams :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 ` Nrlrs@tradesr"rr5rrJT)r;rr(extendr= newUpdatesgetLimitfilter_by_since_limit) r/rlrrr>rr@rAr[rBtradess r1 watch_tradeszwazirx.watch_trades"s!!!V$!TlY. iit$ #} ++gv.zz#{G[II ??OOFE2E))&% TRR "Js"B6B2A#B6:B4;8B64B6cN|j|di}|j|dg}|j|d}|jd}|j|d}|j|}|j ||} |j|j | } | 7|j |jdd} t| } | |j | <tdt|D](} |j|| |} | j| *|j| |y)NrFrr@r tradesLimit)rQrVsplitr{rrrRr)rrTrUrappendrZ)r/rDr[rF rawTradesr@rrrrlrrr] parsedTrades r1 handle_tradeszwazirx.handle_trades=s&w3OOD(B7 &&w9 !!#&##E1-!!(+!!(F3f5 >%%dllM4HE&F"(DKK q#i.) 'A--ilFCK MM+ & ' v{+r2cK|jd{|j|d{}||j|}|d}|jdd}d}ddg|d} |j | |} |j ||| |d{} |j r| j||}|j| |||d S777;w) a watch trades by user https://docs.wazirx.com/#trade-update :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 ` Nrlr"rmyTradesr5ownTrader7T) r;r<rr(r,r=rrfilter_by_symbol_since_limit) r/rlrrr>r?rrAr@r[rBrs r1watch_my_tradeszwazirx.watch_my_tradesas!!!''//  [[(FH%Fiit$  "|  ""7F3zz#{G[II ??OOFE2E00tTT! "/Js2CCCC A CC 8C C C1mcK|jd{|j|}|d}|jdd}d|zdz|z}|ddz|z} d | gd } |j| |} |j ||| |d{} |j r| j ||}|j| ||d d S779w) a watches historical candlestick data containing the open, high, low, and close price, and the volume of a market https://docs.wazirx.com/#kline-candlestick-stream :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 Nrlr"rohlcv::rsz@kline_r5rrT)r;rr(r,r=rrr) r/rl timeframerrr>rrAr@rr[rBohlcvs r1 watch_ohlcvzwazirx.watch_ohlcvs!!!V$!iit$'#- 9  )I5 x ""7F3jjk7KHH ??NN651E))%q$GG "Is"CCA1CC 8CCcB|j|di}|j|d}|j|}|j||}|j|d}|j|j|i|j|<|j|j||}|:|j |j dd} t| }||j||<|j||} |j| d|zdz|z} |j|| y)NrFrdr] OHLCVLimitrrr) rQrVr{rohlcvsrRr)rparse_ws_ohlcvrrZ) r/rDr[rFrrrlrstoredrparsedr@s r1 handle_ohlcvzwazirx.handle_ohlcvs$w3##D#.!!(+!!(F3$$T3/ "oodkk62F FV!4i@ >%%dllL$GE*51F-3DKK  *$$T62 f'#- 9 v{+r2c |j|d|j|d|j|d|j|d|j|d|j|dgS)NrkrmcrrNv)rRr)r/rrs r1rzwazirx.parse_ws_ohlcvsn   eS )   UC (   UC (   UC (   UC (   UC (   r2c4K|jd{|j|}|d}|jdd}d|z}|ddz}d|gd }|j||} |j ||| |d{} | j S7}7w) a# watches information on open orders with bid(buy) and ask(sell) prices, volumes and other data https://docs.wazirx.com/#depth-stream :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 :returns dict: A dictionary of `order book structures ` indexed by market symbols Nrlr"r orderbook:rs@depthr5r)r;rr(r,r=r) r/rlrr>rrAr@rr5rB orderbooks r1watch_order_bookzwazirx.watch_order_books!!!V$!iit$"V+ ( x ""9f5**S+w LL    "Ms"BBA(B?BBBcL|j|dd}|j|y)Nrr&) parse_bid_ask storeArray)r/booksidedeltabidAsks r1 handle_deltazwazirx.handle_deltas$##E1a0F#r2cbtdt|D]}|j|||y)Nr)rTrUr)r/rdeltasr]s r1 handle_deltaszwazirx.handle_deltass0q#f+& 3A   hq 2 3r2c|j|di}|j|d}|j|d}|j|}|d}d|z}||jvr4|j |||dd} |j | |j|<n|j|} |j|dg} |j|dg} |j| d| |j| d | || d <|| d <|j|| d <| |j|<|j|j||y) NrFrHrdrlrrMrLasksbidsnoncerJrK) rQrRrVr{ orderbooksparse_order_book order_book safe_listrrSrZ) r/rDr[rFrJrrrlr@snapshotrrrs r1handle_order_bookzwazirx.handle_order_booksA w3%%dC0 ##D#.!!(+!"V+ $//),,T69c3OH&*ooh&?DOOF #/I>>$R0D>>$R0D   y0$ 7   y0$ 7!*Ig %.Ik "$(LL$;Ij !&/DOOF #tv. rr?r@r[rArBrs r1 watch_orderszwazirx.watch_orderss!!!  [[(FH%F''//  %  iit$""7F3zz#{G['RR ??OOFE2E00tTT! "0Ss4CC 0CC A CC 8C C Cc|j|di}|j|}|j-|j|jdd}t ||_|j}|j |d}|j|j||d|dzz }|j|j|y)NrF ordersLimitrrrrl)rQparse_ws_orderrrRr)rrrZ)r/rDr[rt parsedOrderrrr@s r1 handle_orderzwazirx.handle_order0s(4))%0 ;; %%dllM4HE07DK k" t{{K0s[222 t{{K0r2c t|j|d}|j|d}|j|d}|j|}|jid|d|j|dd|j|dd |j |d |d dd |d d |j |drdndddddd|j|dd|j|dddddd|j|dddd|j|dd|j|d|j |ddd|S) NOrdXrIrsr] clientOrderIdrrKrJlastTradeTimestamprlrurgrr timeInForcepostOnlyrvrmrxrq stopPrice triggerPriceryVfilled remainingrrr)rhrstatusrzr)rRrVr{ safe_orderrSrQparse_order_status)r/rtrrJrrs r1rzwazirx.parse_ws_orderPs"%%eS1 ##E3/!!%-!!(+ E $""5#.  T--eS9   Y/    !$   fX&  tuc:G  4    D$$UC0  T%%eS1    D  d&&uc2 d! " ))%5# $''s3--f5- . / r2c*|j|di}d}d}|j0|j|jdd}t |}||_n |j}|j |}|j ||j||y)NrFrrr)rQrrRr)rrrrZ)r/rDr[r~r@rrrs r1handle_my_tradeszwazirx.handle_my_trades~s.4  == %%dllM4HE-e4H$DM}}H))%0  $x-r2c|SNr/rDr[s r1handle_connectedzwazirx.handle_connecteds r2c|Sr r r s r1handle_subscribedzwazirx.handle_subscribeds r2cVt|jdz|j|z)N )rrsjsonr s r1 handle_errorzwazirx.handle_errors% DGGcMDIIg,>>??r2c|j|d}|dk(r|j||y|j|d}|j|j|jd}|j ||}| |||y|j|dd}|j |j |j|j|j|j|jd}t|j} tdt| D].} |j!| | d kD} | s|| | } | ||yt#|j$d z|j'|z) Nrerrorr8)r connected subscribedr)z ticker@arrrz@klinerr6rrrz2 self message type is not supported yet. Message: )rVrr rrQrrrrrbrrlistkeysrTrUfindrrsr) r/rDr[rr8 eventHandlers eventHandlerrstreamHandlersr9r]streamContainshandlers r1handle_messagezwazirx.handle_messageso!!'84 W    fg .   '2&&..00 }e<  #  ) !!'8R8,,,,''))'+':':,,-- ~**,-q#g,' A#[[4r9N(4(   477%YY\`\e\efm\nnoor2cK|jdd}|j|}d}|j}|j|j|}|j |d}|||kDrB|j d{}||j |ddzz|d<||j|<|j|dS7@w)Nr"r authenticatedexpirestimeout_durationrr:)r(rD millisecondsrQ subscriptionsrRprivatePostCreateAuthTokenrV)r/r>rArDr@now subscriptionr$s r1r<zwazirx.authenticatesiit$S!% !v';';[I ##L)<  3=!%!@!@!BBL&)D,=,=lL^,_bf,f&fL #1=F  - j99CsA>CCACr )-__name__ __module__ __qualname__rr.rrCrrbrstrr rr rrrrrrrrrr rrrrrr rrrrr rrrrr rrr!r< __classcell__)r0s@r1rrs)  #  D*,HH*#2V#2J:x68JJFJ.6:"G7GG.0F0B(T<@d[]SSSSSbfglbmS6",F",H37TX\egUCUsURUUlpqvlwU<8<$]ajlHHCHWZHquvzq{H: ,6 ,D D 0@DB!S!!S\!2$3$=$=L04$UYbdUUCUsUimnsitU&161@,\".v".H v   @6@$ pV pD)+:r2r)ccxt.async_supportccxt ccxt.async_support.base.ws.cacherrrccxt.base.typesrrrr r r r r rr!ccxt.async_support.base.ws.clientrtypingrccxt.base.errorsrr async_supportrr r2r1r8s? fffff4*)o :T   & &o :r2