i4uddlZddlmZmZmZddlmZmZm Z m Z m Z m Z m Z mZmZddlmZddlmZddlmZddlmZGdd ejjZdS) N) ArrayCacheArrayCacheBySymbolByIdArrayCacheByTimestamp) BalancesIntOrder OrderBookStrStringsTickerTickersTrade)Client)List) ExchangeError) NotSupportedc eZdZfdZifdefdZdefdZd$dZifde de fd Z difd e de fd Zdefd Zd$d Zddifde dededeefdZdefdZdddifdedededeefdZdddifde dededeefdZdefdZd$defdZdifde dedefdZdZdZdefdZ dddifdedededee!fdZ"defdZ#d$dZ$defdZ%defdZ&defd Z'defd!Z(defd"Z)ifd#Z*xZ+S)%wazirxc |tt|dddddddddd dddiiiiidddd iiid S) NT) ws watchBalance watchTicker watchTickers watchTrades watchMyTrades watchOrderswatchOrderBook watchOHLCVapirzwss://stream.wazirx.com/streamprivatepostcreate_auth_token)hasurlsoptions streaming exceptionsr) deep_extendsuperrdescribe)self __class__s U/var/www/html/crypto-bot/backend/venv/lib/python3.11/site-packages/ccxt/pro/wazirx.pyr+zwazirx.describesfd 3 3 < < > > $# $#!%#"&"  : +Q/A A    returncK|d{V||d{V}d}|jdd}ddg|d}|||}|||||d{VS)aS watch balance and get the amount of funds available for trading or funds locked in orders :see: https://docs.wazirx.com/#account-update :param dict [params]: extra parameters specific to the exchange API endpoint :returns dict: a `balance structure ` Nbalancerr subscribeoutboundAccountPositioneventstreamsauth_key) load_markets authenticater%r)watch)r,paramstoken messageHashurlr3requests r. watch_balancezwazirx.watch_balance2s!!!!!!!!!''//////// it$ 12  ""9f55ZZ[';GGGGGGGGGr/clientc||di}||dg}||d}||jd<||jd<|||jd<t dt |D]}||}||d}||} ||d } ||d } |} | | d <| | d <| |j| <| |j|_d } | |j| dS)NdataBEinfo timestampdatetimerablfreeusedr2) safe_value safe_integerr2iso8601rangelen safe_stringsafe_currency_codeaccount safe_balanceresolve)r,rBmessagerDbalancesrHir2 currencyIdcode availablelockedrVr>s r.handle_balancezwazirx.handle_balanceEsS"w33??4b11%%dC00 ' V$- [!#'<< #:#: Z q#h--(( ) )AqkG))'377J**:66D((#66I%%gs33FllnnG'GFO$GFO!(DL  ((66  t|[11111r/Nc||d}||d}|||}||d}||d}||ddu}d}||||dd}|||d|||||d ||d gd||d |rd nd ||d||dd|d |S)NrFsfUmT)costcurrencyratetsymboloSmakertakerpq) idrGrHrIrjordertypeside takerOrMakerpriceamountrffee)rPrT safe_marketrOrU safe_traderQ safe_string_n) r,trademarketrHmarketIdfeeCost feeCurrencyIdisMakerrxs r.parse_ws_tradezwazirx.parse_ws_tradejsm>%%eS11 ##E3//!!(F33""5#..((44 //%--5   33MBBC ""5#.." Y//X&''u55$$UC00'.;GGG%%eS11&&uc22    r/rjcK|d{V||}|jdd}d|dz}d}d}d|gd }|||} |||| |d{VS) a watches a price ticker, a statistical calculation with the information calculated over the past 24 hours for a specific market :see: 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 ` Nrrticker:rjtickers !ticker@arrr3r6r7)r9r}r%r)r;) r,rjr<r}r?r> subscribeHashstreamr3r@s r. watch_tickerzwazirx.watch_tickers!!!!!!!!!V$$it$&"22 ! # x  ""9f55ZZ['=IIIIIIIIIr/symbolsc6K|d{V||}|jdd}d}d}d|gd}|||}|||||d{V}||d|d S) a watches a price ticker, a statistical calculation with the information calculated over the past 24 hours for all markets of a specific list :see: 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 ` Nrrrrr3rrjF)r9market_symbolsr%r)r;filter_by_array) r,rr<r?r>rr3r@rs r. watch_tickerszwazirx.watch_tickerss!!!!!!!!!%%g..it$ # x  ""9f55 3 WkJJJJJJJJ##GXwFFFr/c>||dg}tdt|D]L}||}||}|d}||j|<d|z}|||M||jddS)NrDrrjrr)rOrRrSparse_ws_tickerrrX) r,rBrYrDr[ticker parsedTickerrjr>s r. handle_tickerzwazirx.handle_tickers.w33q#d))$$ 6 6A!WF//77L!(+F#/DL #f,K NN< 5 5 5 5t|Y/////r/c^||d}||d}|id|||d|d||d||dd||d d ||d d dd ||dddddd||dddd||d ddddddddd||d|d|S)NrbrFrjrHrIhighhlowrLbidrK bidVolumeaskrJ askVolumevwapopenrkcloselast previousClosechange percentageaveragerp) baseVolume quoteVolumerG)rTrP safe_ticker safe_symbolrQ safe_number)r,rr}r~rHs r.rzwazirx.parse_ws_tickers"##FC00%%fc22 ! d&&x88! !   Y//!  D$$VS11 ! 4##FC00 ! 4##FC00 !  !  4##FC00!  !  D!  D$$VS11!  T!  D$$VS11!  T!  d! $!! " t#! $++FC88)! ! ! * + r/sincelimitcK|d{V||}|d}|ddz}|jdd}d|gd}|||} |||| |d{V} |jr| ||}|| ||d d S) a get the list of most recent trades for a particular symbol :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 ` Nrjrq@tradesrrr3rrHT)r9r}r%extendr; newUpdatesgetLimitfilter_by_since_limit) r,rjrrr<r}r>r?rYr@tradess r. watch_tradeszwazirx.watch_tradess!!!!!!!!!V$$!TlY. it$ #}  ++gv..zz#{G[IIIIIIII ? 3OOFE22E))&% TRRRr/c||di}||dg}||d}|d}||d}||}|||} ||j| } | 5||jdd} t| } | |j| <tdt|D]3} | || |} | | 4| | |dS)NrDrr@r tradesLimit)rOrTsplitryrrrPr&rrRrSrappendrX)r,rBrYrD rawTradesr>rr~r}rjrrr[ parsedTrades r. handle_tradeszwazirx.handle_trades3sF&w33OOD(B77 &&w99 !!#&&##E1--!!(++!!(F33f55 >%%dlM4HHE&&F"(DK q#i..)) ' 'A--ilFCCK MM+ & & & &v{+++++r/cK|d{V||d{V}|||}|d}|jdd}d}ddg|d} || |} |||| |d{V} |jr| ||}|| |||d S) a watch trades by user :see: 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 ` NrjrrmyTradesr3ownTrader5T) r9r:r}r%r)r;rrfilter_by_symbol_since_limit) r,rjrrr<r=r}r?r>rYr@rs r.watch_my_tradeszwazirx.watch_my_tradesWs!!!!!!!!!''////////  [[((FH%Fit$  "|   ""7F33zz#{G[IIIIIIII ? 3OOFE22E00tTTTr/1mcK|d{V||}|d}|jdd}d|zdz|z}|ddz|z} d | gd } || |} |||| |d{V} |jr| ||}|| ||d d S) aQ watches historical candlestick data containing the open, high, low, and close price, and the volume of a market :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 Nrjrrohlcv::rqz@kline_r3rrT)r9r}r%r)r;rrr) r,rj timeframerrr<r}r?r>rrYr@ohlcvs r. watch_ohlcvzwazirx.watch_ohlcvss !!!!!!!!!V$$!it$'#- 9  )I5 x  ""7F33jjk7KHHHHHHHH ? 2NN6511E))%q$GGGr/c~||di}||d}||}|||}||d}||j|i|j|<||j||}|;||jdd} t| }||j||<|||} | | d|zdz|z} | || dS)NrDrbr[ OHLCVLimitrrr) rOrTryrohlcvsrPr&rparse_ws_ohlcvrrX) r,rBrYrDr~r}rjrstoredrparsedr>s r. handle_ohlcvzwazirx.handle_ohlcvs4$w33##D#..!!(++!!(F33$$T3// "oodk62FF FV!4i@@ >%%dlL$GGE*511F-3DK  *$$T622 f'#- 9 v{+++++r/c ||d||d||d||d||d||dgS)NrirkcrrLv)rPr)r,rr}s r.rzwazirx.parse_ws_ohlcvs   eS ) )   UC ( (   UC ( (   UC ( (   UC ( (   UC ( (   r/cVK|d{V||}|d}|jdd}d|z}|ddz}d|gd }|||} |||| |d{V} | S) a' watches information on open orders with bid(buy) and ask(sell) prices, volumes and other data :see: 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 Nrjrr orderbook:rq@depthr3r)r9r}r%r)r;r) r,rjrr<r}r?r>rr3r@ orderbooks r.watch_order_bookzwazirx.watch_order_books!!!!!!!!!V$$!it$"V+ ( x  ""9f55**S+w LLLLLLLL    r/c^||dd}||dS)Nrr#) parse_bid_ask storeArray)r,booksidedeltabidAsks r. handle_deltazwazirx.handle_deltas3##E1a00F#####r/c~tdt|D]}||||dS)Nr)rRrSr)r,rdeltasr[s r. handle_deltaszwazirx.handle_deltassHq#f++&& 3 3A   hq 2 2 2 2 3 3r/c||di}||d}||d}||}|d}d|z}||j|} | 9||||dd} || } | |j|<n||dg} ||dg} || d| || d | || d <|| d <||| d <| |j|<| |j||dS) NrDrFrbrjrrKrJasksbidsnoncerHrI) rOrPrTry orderbooksparse_order_book order_bookrrQrX)r,rBrYrDrHr~r}rjr>currentOrderBooksnapshot orderBookrrs r.handle_order_bookzwazirx.handle_order_books} w33%%dC00 ##D#..!!(++!"V+ ??4?FCC  #,,T69c3OOH11I&/DOF # #??4b11D??4b11D   /7 > > >   /7 > > >(1 W %,5 [ )+/<< +B+B Z (&6DOF #tv. <<<<rYr?r@rs r. watch_orderszwazirx.watch_orders s!!!!!!!!!  [[((FH%F''////////  %   it$""7F33zz#{G['RRRRRRRR ? 3OOFE22E00tTTTr/c||di}||}|j0||jdd}t ||_|j}||d}||j||d|dzz }||j|dS)NrD ordersLimitrrrrj)rOparse_ws_orderrrPr&rrrX)r,rBrYrr parsedOrderrrr>s r. handle_orderzwazirx.handle_orders(44))%00 ; %%dlM4HHE077DK k""" t{K000s[222 t{K00000r/c ||d}||d}||d}||}|id|d||dd||dd ||d |d dd |d d ||drdndddddd||dd||dddddd||dddd||dd||d||ddd|S) NOrbXrGrqr[ clientOrderIdrrIrHlastTradeTimestamprjrsrerr} timeInForcepostOnlyrtrkrvro stopPrice triggerPricerwVfilled remainingrpr)rfrstatusrxr)rPrTry safe_orderrQrOparse_order_status)r,rrr}rHr~rs r.rzwazirx.parse_ws_order?s"%%eS11 ##E3//!!%--!!(++ E $""5#..  T--eS99   Y//    !$   fX&  tuc::HGG  4    D$$UC00  T%%eS11    D  d&&uc22 d! " ))%55# $''s33--f55-   . / r/c>||di}d}d}|j3||jdd}t |}||_n|j}||}|||||dS)NrDrrr)rOrrPr&rrrrX)r,rBrYr|r>rrrs r.handle_my_tradeszwazirx.handle_my_tradesms.44  = %%dlM4HHE-e44H$DMM}H))%00  $$$x-----r/c|SNr,rBrYs r.handle_connectedzwazirx.handle_connecteds r/c|Srr r s r.handle_subscribedzwazirx.handle_subscribeds r/c\t|jdz||z)N )rrqjsonr s r. handle_errorzwazirx.handle_errors) DGcMDIIg,>,>>???r/c||d}|dkr|||dS||d}|j|j|jd}|||}||||dS||dd}|j|j|j|j|j |j |j d}t| } tdt| D];} || | |r|| | } | ||dSnow subscriptionr!s r.r:zwazirx.authenticatesit$S!!% !!v';[II ##L)<<  3==!%!@!@!B!BBBBBBBL&)D,=,=lL^,_,_bf,f&fL #1=F  - j999r/r),__name__ __module__ __qualname__r+rrArr`rstrr rr r rrrrrrrrr rrrrrr rrrrrrrrrr r rrr: __classcell__)r-s@r.rrs     B*,HHHHHH&#2V#2#2#2#2J::::x68JJJFJJJJ*6:"GG7GGGGG*0F0000B((((T<@d[]SSSSSSbfglbmSSSS0",F",",",",H37TX\egUUCUsURUUlpqvlwUUUU88<$]ajlHHHCHWZHquvzq{HHHH4 ,6 , , , ,D  D    0@DB!!S!!S\!!!!.$$$333$=$=$=$=$=L04$UYbdUUUCUsUimnsitUUUU&161111@,,,,\".v".".".".H v         @6@@@@$pVppppB)+::::::::r/r)ccxt.async_supportccxt ccxt.async_support.base.ws.cacherrrccxt.base.typesrrrr r r r r r!ccxt.async_support.base.ws.clientrtypingrccxt.base.errorsrr async_supportrr r/r.r5s ffffffffffaaaaaaaaaaaaaaaaaaaaaa444444******))))))] :] :] :] :] :T  &] :] :] :] :] :r/