iznddlZddlmZmZmZddlmZmZm Z m Z m Z m Z ddl mZddlmZddlmZddlmZGdd ejjZdS) N) ArrayCacheArrayCacheBySymbolByIdArrayCacheByTimestamp)IntOrder OrderBookStrTickerTrade)Client)List) InvalidNonce)Precisec eZdZfdZd!dZdZifdedefdZde fd Z d d ifded e d e de e fd Zde fdZd"dZdd d ifded e d e de efdZde fdZde fdZifdZd ifded e defdZde fdZde fdZdZdZifdZd d d ifded e d e de efdZde fdZ d d d ifded e d e fdZ!de fdZ"de fd Z#xZ$S)#idexc|tt|dddddddddddiidddddiddd id d d d S)NTF)wswatchOrderBook watchTrades watchOHLCV watchTicker watchTickers watchOrderswatchTransactionsrz wss://websocket-matic.idex.io/v1)testapi maxRetries ') tradesLimit ordersLimit OHLCVLimitwatchOrderBookLimitorderBookSubscriptionstokenr!fetchOrderBookSnapshotMaxAttemptsfetchOrderBookSnapshotMaxDelay)hasurlsoptions) deep_extendsuperrdescribe)self __class__s S/var/www/html/crypto-bot/backend/venv/lib/python3.11/site-packages/ccxt/pro/idex.pyr/z idex.describesdD 1 1 : : < <"&#"# %#%)  <  $#"'+*, !#6827  #? ?    TcvK|jdd}d|gd}||||||d{VS)Nrr subscribe)method subscriptions)r+watch)r0subscribeObject messageHash subscriptionurlrequests r2r5zidex.subscribe2s\i%!   ZZ['; UUUUUUUUUr3cK|d{V}|jdd}d||gd}|||||d{VS)Nrrr5)r6r'r7) authenticater+r8)r0r9r:r'r<r=s r2subscribe_privatezidex.subscribe_private<s''))))))))i%!  ZZ[';GGGGGGGGGr3symbolreturncK|d{V||}d}||dgd}|dz|dz}|||||d{VS)a watches a price ticker, a statistical calculation with the information calculated over the past 24 hours for a specific market :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 ` Ntickersidnamemarkets:) load_marketsmarketr5extend)r0rAparamsrKrGr9r:s r2 watch_tickerzidex.watch_tickerHs!!!!!!!!!V$$t ~  Sj6$</ ^^DKK$H$H+VVVVVVVVVr3clientc||d}||d}||d}||}|dz|z}||d}||d} ||d} d} | | t j| | } |id|d |d ||d ||d d ||dd||dddd||dddddd||dd| d| ddd| d| dd||d||d|d } || |dS)!NtypedatamrItcPrA timestampdatetimehighhlowlbidb bidVolumeaska askVolumevwapopenocloselast previousClosechange percentageaveragevq) baseVolume quoteVolumeinfo) safe_string safe_value safe_symbol safe_integerr string_mul safe_tickeriso8601resolve) r0rOmessagerQrRmarketIdrAr:rWrfrjritickers r2 handle_tickerzidex.handle_tickerYsW"00w//##D#..!!(++Sj8+ %%dC00   s++%%dC00   "):'z::F!!# f# #   Y//#  D$$T3// # 4##D#.. # 4##D#.. #  #  4##D#..#  #  D#  D$$T3//#  U#  E#  T#  f# *!# " t## $**455++D#66)# # #   , v{+++++r3NsincelimitcPK|d{V||}|d}d}||dgd}|dz|dz}|||d{V} |jr| ||}|| ||ddS) 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 ` NrAtradesrErFrIrWT)rJrKr5 newUpdatesgetLimitfilter_by_since_limit) r0rAr}r~rMrKrGr9r:rs r2 watch_tradeszidex.watch_tradess!!!!!!!!!V$$!t ~  Sj6$</ ~~o{CCCCCCCC ? 3OOFE22E))&% TRRRr3c||d}||d}||d}|dz|z}||}t|j}t |} | dkr/||jd} t| |_|j} | || | |dS)NrQrRrSrIrr") rqrrparse_ws_tradelistrkeyslenrtr,rappendrx) r0rOryrQrRrzr:traderlengthr~rs r2 handle_tradezidex.handle_trades00w//##D#..Sj8+ ##D))DK$$&&''T Q;;%%dlMBBE077DK ev{+++++r3cR||d}||}||d}||d}||d}||d}||d} ||d} ||d||d d } ||d } ||| || ||dd| | |||| d S) NrSiprmQrTsrafcurrencycostr\) rprWrXrArEorderrQ takerOrMakersidepriceamountrfee)rqrsrt safe_traderw) r0rrKrzrArErrrrWrr takerOrMarkers r2rzidex.parse_ws_tradesF.##E3//!!(++   eS ) )  ,,!!%--s++%%eS11 s++((44$$UC00  ((44 " Y//)     r31mcK|d{V||}|d}d}||j||}||dg|d} |dz|dz} || | d{V} |jr| ||}|| ||ddS) 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 NrAcandlesrE)rGrHintervalrIrT)rJrKrq timeframesr5rrr) r0rA timeframer}r~rMrKrGrr9r:ohlcvs r2 watch_ohlcvzidex.watch_ohlcvs!!!!!!!!!V$$!##DOY JJt ~    Sj6$</ nn_kBBBBBBBB ? 2NN6511E))%q$GGGr3c t||d}||d}||d}|dz|z}||d||d||d||d||d ||d g}||}||d } || } ||j|i|j|<||j|| } | ;||jd d } t| } | |j|| <| || | |dS)NrQrRrSrIrrerZr\rUrlrr$r) rqrrrt safe_floatrsfind_timeframeohlcvsr,rrrx) r0rOryrQrRrzr:parsedrArrstoredr~s r2 handle_ohlcvzidex.handle_ohlcvs00w//##D#..Sj8+   dC ( ( OOD# & & OOD# & & OOD# & & OOD# & & OOD# & &  !!(++##D#..''11 "oodk62FF FV!4i@@ >%%dlL$GGE*511F-3DK  * fv{+++++r3c.||d}tdt|D]}||}||d}|dkr||d}tdt|D]}||} ||jdi} | | vrY|| } | |jvr|i} | |j| <||j || dSdS)Nr7rrG l2orderbookrHr&) rrrangerrqr,rs orderbookscounted_order_bookspawnfetch_order_book_snapshot) r0rOryr7rr;rGrHjrzr&rA orderbooks r2handle_subscribe_messagezidex.handle_subscribe_message)s4AA q#m,,--  A(+L##L&99D}$$//, BBq#g,,// S SA&qzH-1__T\Kceg-h-h*$(>>>!%!1!1(!;!; &$/ 9 9(,(?(?(C(CI6?DOF3 4#A66RRR%  r3cVK|j|}||}d|dz}|j|}|ds||d<d|d<||jdd}||jdd } ||d d } ||| d{V} ||jd } || d } || d }t|j}||j|dz }||d }||d }|duo|du}|r|| ddzkr|| dkr| | td t|jD]^}|j|}||d }||d }||dkr| |||_d|d<| ||dS|ddz|d<||dz }|d|k}|| k}|r&|r$||j|j||dS|sdt#|zdzndt#| zdz}t%|jdz|z|z#t($r&}d|d<|||Yd}~dSd}~wwxYw)Nz l2orderbook:rEfetchingOrderBookSnapshot startTimeTr(r r)r!r~rrRunonceF numAttemptsz in z attemptsz after z millisecondszC failed to synchronize WebSocket feed with the snapshot for symbol )rrKr7 millisecondsrtr,fetch_rest_order_book_saferrcacherresetrhandle_order_book_messagerxdelay rateLimitrstrrrE Exceptionreject)r0rOrArMrrKr:r; maxAttemptsmaxDelayr~snapshot firstBuffered firstData firstNoncer lastBufferedlastData lastNonce bothExistrryrRr timeElapsedmaxAttemptsValidtimeElapsedValidendpartes r2rzidex.fetch_order_book_snapshotGsOF+ V$$)F4L8 +K8 78 <(,(9(9(;(;L %48 01'' 6Y[]^^ $$T\3SUZ[[, *%%lGQ??E!<>I**9c::J))F??9?FQJGGL|V<#L #.#9 #K(8KJJt~t/MvW]^^^^^N^Qfs;'7'77+EEenqtu}q~q~e~BQfQG&tw1v'vy'CJ(JKKK * * *8=L4 5 MM![ ) ) ) ) ) ) ) ) ) *s'F.K8 A#K8/A K88 L(L##L(c$K|d{V||}d}||dgd}|dz|dz}dddd}|d |d <n||d <||||d{V} | S) a watches information on open orders with bid(buy) and ask(sell) prices, volumes and other data :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 NrrErFrIFr)rrrrr~)rJrKr5r~) r0rAr~rMrKrGr9r:r;rs r2watch_order_bookzidex.watch_order_books!!!!!!!!!V$$t ~  Sj6$</ ).  =$(L ! !$)L !..+|TTTTTTTT    r3c||d}||d}||}|j|}|d|j|dS||||dS)NrRrSr)rrrqrsrrrr)r0rOryrRrzrArs r2handle_order_bookzidex.handle_order_booksw//##D#..!!(++OF+ W  % O " "7 + + + + +  * *67I F F F F Fr3c*||d}||d}||d}|dz|z}||d}||d} ||d} ||d} ||d | ||d | ||d <| |d <|| |d <|||dS)NrQrRrSrIrrTr^rabidsasksrrWrX)rqrrrt handle_deltasrwrx) r0rOryrrQrRrzr:rrWrrs r2rzidex.handle_order_book_messages"00w//##D#..Sj8+ !!$,,%%dC00 tS))tS)) 9V,d333 9V,d333" '!* + $ Y 7 7 *y+.....r3c||d}||d}||d}||||dS)Nrr)rrtstore)r0booksidedeltarrcounts r2 handle_deltazidex.handle_deltasYq))**!!%++ufe,,,,,r3c~tdt|D]}||||dS)Nr)rrr)r0rdeltasrs r2rzidex.handle_deltassHq#f++&& 3 3A   hq 2 2 2 2 3 3r3cxK|}||jdd}||z dkrs|j|d}||||d{V}||jd<||d|jd<|jdS)NlastAuthenticatedTimeri)walletrr')secondsrtr, walletAddressuuidv1privateGetWsTokenrLrq)r0rMtimerr=responses r2r?zidex.authenticates||~~ $ 1 1$,@WYZ [ [ ' '# - -,G"33DKK4P4PQQQQQQQQH48DL0 1$($4$4Xw$G$GDL !|G$$r3cbK|d{Vd}d|i}|}|8||}||}|g|d<|dz|z}|||d{V} |jr| ||}|| ||ddS)a watches information on multiple orders made by the user :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 order structures to retrieve :param dict [params]: extra parameters specific to the exchange API endpoint :returns dict[]: a list of `order structures ` NordersrGrHrIrWT)rJrA market_idr@rrr) r0rAr}r~rMrGr9r:rzrs r2 watch_orderszidex.watch_orderss!!!!!!!!! D   [[((F~~f--H*2OI &*x/K--o{KKKKKKKK ? 3OOFE22E))&% TRRRr3c||d}||d}||d}||}||d}||dg}g} t dt |D]0} | ||| 1||d} ||d} ||d } ||d }||d }||d }||d |}||d}||}ddd}d}t dt | D]G} | | }|dd|d<|dd}tj |d||d<H||d}| id|d| ddd|d| |d|d|d| d| d | |ddddd| |ddd| |d| |d d||| d!}|j0||jd"d#}t!||_|j}|||d$z|z}||||||dS)%NrQrRrSrTFrrrrermzrlrXrrrrrWrprE clientOrderIdrXlastTradeTimestamprAr stopPrice triggerPricerrkfilled remaining)statusrrr#rrI)rqrrrsrtrrrrparse_order_statusr string_add safe_orderrw parse_numberrr,rrx)r0rOryrQrrzrArWfillsrrrEr orderTyperrrkr rawStatusrr lastTradestringLastTradeFeer parsedOrderr~rsymbolSpecificMessageHashs r2 handle_orderzidex.handle_ordersN0000##E3//!!(++%%eS11 sB//q#e**%% 9 9A MM$--eAh77 8 8 8 8   eS ) )s++$$UC00 !!%--!!%--""5#..  99$$UC00 ((33   q#f++&& N NAq I'.z:C O!*5!1&!9 !,S[:LMMCKK!..y+FFoo' G' "'  T'   '  Y// ' !"4 '  f'  I'  D'  T&&u--'  '  D'  d''//'  D'  t((11' d''//!' " #' $)' ' '   , ; %%dlM4HHE077DK k"""$(3J$9!v8999vt$$$$$r3codecK|d{Vd}d|i}|}||dz|z}|||d{V}|jr|||}||||dS)NbalancesrGrIrW)rJr@rrr) r0r r}r~rMrGr9r: transactionss r2watch_transactionszidex.watch_transactionsZs!!!!!!!!! D   *t+K!33O[QQQQQQQQ ? 7 ))$66E)),ukRRRr3cn||d}||d}||d}|dz|z}||}||d}id|ddd|d dd |d dd dd ddddddddddddddddddd} ||jvr3||jdd} t | |j|<|j|} | | || ||| |dS)NrQrRrarIwrprErraddress addressTo addressFromtagtagTotagFromrokupdatedtxidrWrXrtransactionsLimitr) rqrrsafe_currency_coderrtr,rrrx) r0rOryrQrR currencyIdr:r r transactionr~rs r2handle_transactionzidex.handle_transactionhs00w//%%dC00 Sj:- &&z22""4-- G $    d  w     4  4  T  t  d  D  t  D   ! " 4# &)))%%dl4GNNE&0&7&7D d #(. K(((|[111|T*****r3c||d}|j|j|j|j|j|j|jd}||vr||}|||dSdS)NrQ)rDrr7rrrr)rqr|rrrrr!r )r0rOryrQmethodsr6s r2handle_messagezidex.handle_messages00)'!:(1/'   7??T]F F67 # # # # # ?r3)T)N)%__name__ __module__ __qualname__r/r5r@rr rNr r|rr r rrrrrrrrrrrrrrr?r rrr rr!r$ __classcell__)r1s@r2rrsq     BVVVV H H H68WWWFWWWW"2,F2,2,2,2,h<@d[]SSSSSSbfglbmSSSS. ,6 , , , ,2 2 2 2 h8<$]ajlHHHCHWZHquvzq{HHHH4&,6&,&,&,&,Pv<FH6*6*6*6*p@DB!!S!!S\!!!!: G G G G G/////@--- 333)+ % % % %04$UYbdSSSCSsSimnsitSSSS2a%6a%a%a%a%F48dY]fh S SS S SSV S S S S)+)+)+)+)+V $V $ $ $ $ $ $ $ $r3r)ccxt.async_supportccxt ccxt.async_support.base.ws.cacherrrccxt.base.typesrrrr r r !ccxt.async_support.base.ws.clientr typingr ccxt.base.errorsrccxt.base.preciser async_supportrr3r2r3s ffffffffffEEEEEEEEEEEEEEEE444444))))))%%%%%%Q $Q $Q $Q $Q $4  "Q $Q $Q $Q $Q $r3