":h ddlZddlmZmZmZddlZddlmZm Z m Z m Z m Z m Z mZmZmZmZddlmZddlmZddlmZddlmZddlmZGd d ej4j6Zy) N) ArrayCacheArrayCacheBySymbolByIdArrayCacheByTimestamp) AnyBalancesIntOrder OrderBookStrStringsTickerTickersTrade)Client)List)AuthenticationError)ArgumentsRequired) NotSupportedc eZdZdeffd ZifdedefdZdefdZ difde de fd Z defd Z d:d Zdifde de fd Zdefd Zd:dZifdZifdZifdZifdZdddifdedededeefdZdefdZd:defdZdifdededefdZdefdZdZdefdZ dZ!dZ"ddifdedededee#fdZ$defd Z%dddifde&dededee#fd!Z'd:defd"Z(d:d#Z)dddifde&dededee*fd$Z+defd%Z,d:d&Z-d:d'Z.d(Z/d)Z0ifde1fd*Z2defd+Z3ifdedefd,Z4difde defd-Z5difde defd.Z6difdedefd/Z7ifdedefd0Z8ifdedefd1Z9ded2eefd3Z:ifd4Z;ifd5Zdefd8Z?defd9Z@xZAS);mexcreturnc |jtt|iddddddddddddd dd dd dd dd ddddddddddddddddddddddd dddddiidddddddd d!d"d#d$ d%d&d'dd(|jd)d*id+S),NwsTcancelAllOrdersWsFcancelOrdersWs cancelOrderWs createOrderWs editOrderWsfetchBalanceWsfetchOpenOrdersWs fetchOrderWs fetchTradesWs watchBalance watchMyTrades watchOHLCVwatchOrderBook watchOrders watchTicker watchTickers) watchBidsAsks watchTradeswatchTradesForSymbols unWatchTickerunWatchTickersunWatchBidsAsks unWatchOHLCVunWatchOrderBook unWatchTradesapizwss://wbs.mexc.com/wszwss://contract.mexc.com/edge)spotswapOMin1Min5Min15Min30Min60Hour4Hour8Day1Week1Month1) 1m5m15m30m1h4h8h1d1w1M) snapshotDelaysnapshotMaxRetries)listenKeyRefreshRate timeframesr& listenKeyi@)ping keepAlive)hasurlsoptions streaming exceptions) deep_extendsuperrdescriberR)self __class__s G/var/www/html/turnos/venv/lib/python3.12/site-packages/ccxt/pro/mexc.pyr[z mexc.describesdD : <d#U!%      u !%$U  d!$t t!"#$"&#).!%"&#' $$(!%5: 7 >)0! ""!!! !" &(*+#"', !}@? @ @ symbolcbK|jd{|j|}d|dz}|drKd}|j|dd\}}d}|r d|d zd z}nd |d z}|j|||d{Sd }d|d i}|j ||||d{S77+7w) a watches a price ticker, a statistical calculation with the information calculated over the past 24 hours for a specific market https://mexcdevelop.github.io/apidocs/spot_v3_en/#individual-symbol-book-ticker-streams https://mexcdevelop.github.io/apidocs/contract_v1_en/#public-channels https://mexcdevelop.github.io/apidocs/spot_v3_en/#miniticker :param str symbol: unified symbol of the market to fetch the ticker for :param dict [params]: extra parameters specific to the exchange API endpoint :param boolean [params.miniTicker]: set to True for using the miniTicker endpoint :returns dict: a `ticker structure ` Nticker:r`r4Fr( miniTickerspot@public.miniTicker.v3.api@id@UTC+8spot@public.bookTicker.v3.api@z sub.ticker) load_marketsmarkethandle_option_and_paramswatch_spot_publicwatch_swap_public)r\r`paramsri messageHashrcchannel requestParamss r^ watch_tickerzmexc.watch_tickerVs!!!V$&"22 &>J!%!>!>v}Vb!c JG:VD\IHT:VD\I//fMM M"G&,#M//mU[\\ \# "N ]s4B/B)A(B/?B+$B/$B-%B/+B/-B/clientc|j|||j|dd}|j|dd}|j|d}|j |}|d}d}|dr,|j ||}||d<|j ||d<n|j||}||j|<d |z} |j|| y) Nddatasr`tr4 timestampdatetimerb) handle_bid_ask safe_dict_2 safe_string_2 safe_integer safe_marketparse_ws_tickeriso8601 parse_tickertickersresolve) r\rrmessage rawTickermarketIdrxrir`tickerrns r^ handle_tickerzmexc.handle_tickervsH FG,$$Wc6: %%gsH=%%gs3 !!(+! &>)))Vw)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://mexcdevelop.github.io/apidocs/spot_v3_en/#individual-symbol-book-ticker-streams https://mexcdevelop.github.io/apidocs/contract_v1_en/#public-channels https://mexcdevelop.github.io/apidocs/spot_v3_en/#minitickers :param str[] symbols: unified symbol of the market to fetch the ticker for :param dict [params]: extra parameters specific to the exchange API endpoint :param boolean [params.miniTicker]: set to True for using the miniTicker endpoint :returns dict: a `ticker structure ` Nrr)r4r3rr5FrcB watchTickers required symbols argument for the bookTicker channelrbrg$spot@public.miniTickers.v3.api@UTC+8z spot:ticker SUBSCRIPTIONmethodrmz sub.tickersrr`)rhmarket_symbols safe_stringrihandle_market_type_and_paramsrUrjrre market_idsrangelenappendwatch_multipleextend newUpdatesfilter_by_arrayr)r\rrm messageHashes firstSymbolritypeisSpoturlrequestrctopics marketIdsirrorresults r^ watch_tickerszmexc.watch_tickerssT!!!%%gt4 &&w2   "[[-F99.&RXY f&.17diit$V,dii>Nt>TU[>\ J!%!>!>v~Wc!d JF?+DGG6z,z{{ OOG4 q#i.1+A(|H!((WQZ)?@>IGMM'* +  DE?!((7"1c'l3E%,,Y-CDE .GH  &GH  -GH  "GH    ***3 t{{7TZ?[]jkk dooF'-F6(# $M##DLL(GDDW "Lls"HHGHH *0Jb!H,q#d)$ 0AGEF--eV<**51H%F#)DLL MM& !#f,K NN6; / 0 vu%r_c b|j|d}|j|d}|j|d}|jid|d|j||d|d|j |ddd |j |d d |j |d d |d|d|j |dd|j |dd|j |dd|j |dddddddd|j |dd|j |d|j |dd|S)Nrvrwpinfor`rxryopenhighhlowlcloselastbidb bidVolumeBaska askVolumeAvwap previousClosechange percentagetrvq)average baseVolume quoteVolume)rr} safe_ticker safe_symbolr safe_number)r\rrirrxprices r^rzmexc.parse_ws_ticker[s8##FC0%%fc2   -! F! d&&x8!  !   Y/ ! D ! D$$VS1 !  4##FC0!  U!  E!  4##FC0!  ))&#6!  4##FC0!  ))&#6!  D!  T! d!! " $**648#! $**637++FC8)! * + r_cK|jd{|j|dddd}d}|t|jdz|j |}|j d|d|\}}|dk(}|st |jdzg}g}tdt|D]F}|r+|j||} |jd | d z|jd ||zH|jd d d} d|d} |j| ||j| ||d{} |jr i} | | | d<| S|j|j d|S7\7<w)a https://mexcdevelop.github.io/apidocs/spot_v3_en/#individual-symbol-book-ticker-streams watches best bid & ask for symbols :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 ` NTF( watchBidsAsks required symbols argumentr*rr4' watchBidsAsks only support spot marketrgrebidask:r3rrrrmr`)rhrrremarkets_for_symbolsrrrrrirrUrrrrbidsasks)r\rrm marketTypemarketsrrrrrirrrrs r^watch_bids_askszmexc.watch_bids_askss!!!%%gtT5$G ?#DGG.X$XY Y**73!??QXYZQ[]cd Fv%tww)RRS S q#g,' 9AWQZ0 >MN  WQZ!7 8  9 iit$V,$ **3 t{{7TZ?[]jkk ??G(.GF8$ %N##DMM8WEE7 ",ls"E7E2D!E78E59:E75E7c|j|}|j|d}|y||j|<d|z}|j||y)Nr`r)parse_ws_bid_askrrr)r\rrr parsedTickerr`rns r^rzzmexc.handle_bid_asksT,,W5 !!,9 >  , f&( |[1r_c |j|d}|j|d}|j||}|j|d}|j|d}|j |||j ||j |d|j |d|j |d|j |d|d |S) Nrtrvr`rwrrrr)r`rxryrrrrr) safe_dictrr~r}rrr)r\rrirurr`rxs r^rzmexc.parse_ws_bid_asks~~fc*##FC0!!(F3!!&(3%%fc2 " Y/##D#.))$4##D#.))$4 !    r_cK|j|dd}|j|dg}|jddd}|rdnd}||gd}|j|||j |||d{S7w) N unsubscribedFr3rr4UNSUBSCRIPTIONrr) safe_boolomitrUwatchr)r\rornrmrrrrs r^rkzmexc.watch_spot_publics~~fneD 6N#34iit$V,&2!i ZZ[$++gv2NP[\\\\sA/A81A62A8cK|j|j|d{}|jddddz|z}d|gd}|j|||j |||d{S7Q7w)Nr3rr4 ?listenKey=rr)check_required_credentials authenticaterUrr)r\rornrmrQrrs r^watch_spot_privatezmexc.watch_spot_privates '')++G44 iit$V,}1F4L@3FTG00+vNNE!G ,'#M00+}V\]]E ??NN651E))%q$GG' "O^s4C;C5A?C;C7&C;=C9>8C;7C;9C;c|j|ddi}|j|d|}|j|dd}|j|jdi}|j ||}|j|dd}|j |} | d} d | zd z|z} |j || } |j|j| i|j| <|j|j| |} | :|j|jd d }t|} | |j| |<| j| |j| | y) NrtrukrrrPrvr`rr OHLCVLimit) safe_value_2rr|rVfind_timeframer~parse_ws_ohlcvohlcvsr}rrr)r\rrrrtrawOhlcvr rPrrrir`rnparsedstoredrs r^ handle_ohlcvzmexc.handle_ohlcv1sI^   gsFB 7??1c1-((3 C __T\\<D '' Z@ %%gsH=!!(+! 6)C/); $$Xv6"oodkk62F FV!4i@ >%%dllL$GE*51F-3DKK  * fv{+r_c |j|d|j|d|j|d|j|d|j|d|j|ddgS)Nrworrrrr)safe_timestampr safe_number_2)r\r ris r^rzmexc.parse_ws_ohlcvssqD   s +   UC (   UC (   UC (   UC (   uc3 /   r_cZK|jd{|j|}|d}d|z}d}|dr3d|dz}|j|||d{}|j Sd}d|di}|j||||d{}|j S77K7w)a https://mexcdevelop.github.io/apidocs/spot_v3_en/#diff-depth-stream https://mexcdevelop.github.io/apidocs/contract_v1_en/#public-channels 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 Nr` orderbook:r4"spot@public.increase.depth.v3.api@rez sub.depth)rhrirkrlr) r\r`rrmrirn orderbookrorps r^watch_order_bookzmexc.watch_order_books!!!V$!"V+  &>:VD\IG"44Wk6RRI  "G&,#M#44Wk=Z`aaI   "S bs4B+B%AB+B'4B+B)B+'B+)B+c|j|d}|jd}|j|d}|j|}|ji|j|<y)Nmsgr)rsplitr order_book orderbooks)r\rrrr"partsrr`s r^handle_order_book_subscriptionz#mexc.handle_order_book_subscriptions\w. ###E1-!!(+"&//""5r_c|j|d}|j|d}|j|dd}||dz krytdt |D]#}||}|j|dd}||k\s!|cSt |S)Nnoncerrversion)r}rsafe_integer_2rr) r\rcacher* firstDeltafirstDeltaNoncerdelta deltaNonces r^get_cache_indexzmexc.get_cache_indexs!!)W5__UA. --j#yI ?Q& &q#e*% A!HE,,UCCJU"   5zr_cR|j|dd}|j|dd}|j|}d|z}|j|j|}|j |d}||j vr|j|j |<|j |} |j | d} | it| j} |jdd d } | | k(r |j|j||||i| jj|y |j| ||j|d d } | | d <|j!| | d<|j'| |y#t"$r)}|j|=|j%||Yd}~@d}~wwxYw)Nrtrurvr`rrr*r&rMrKrwtsrxry)rr|rr subscriptionsr}r&r%rr0 handle_optionspawnload_order_bookr handle_deltar/r Exceptionrejectr)r\rrrrurr`rn subscriptionrstoredOrderBookr* cacheLengthrMrxes r^handle_order_bookzmexc.handle_order_booksX  #v6%%gsH=!!(+"V+ v';';[I !!,8$//)&*oo&7DOOF #//&1!!/7; =o334K ../?RTUMm+ 4//feUWX  ! ! ( ( .  *   ot 4++GS$?I+4OK (*.,,y*AOJ '  4 *$$[1 MM![ ) ) *s#>E44 F&=F!!F&ctdt|D]_}||}t|tr|j |*|j |d}|j |d}|j ||ay)Nrrr)rr isinstancelist storeArray safe_floatstore)r\booksidebidasksrbidaskramounts r^handle_bookside_deltazmexc.handle_bookside_deltasmq#g,' .AQZF&$'##F+45uf- .r_c |j|d}|j|dd}||kry||d<|j|dg}|j|dg}|d}|d}|j|||j||y)Nr*r+r,asksbids)r}r/ safe_listrN) r\rr3 existingNoncer4rPrQ asksOrderSide bidsOrderSides r^r<zmexc.handle_delta(s)))W= ((Y?  % ' '~~eVR0~~eVR0!&) !&)  ""=$7 ""=$7r_cK|jd{|j|}|d}d|z}d}|dr$d|dz}|j|||d{}n%d}d|di} |j||| |d{}|jr|j ||}|j |||dd S77_7;w) at https://mexcdevelop.github.io/apidocs/spot_v3_en/#trade-streams https://mexcdevelop.github.io/apidocs/contract_v1_en/#public-channels 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 ` Nr`trades:r4spot@public.deals.v3.api@rezsub.dealrxT)rhrirkrlrrr) r\r`rrrmrirntradesrorps r^ watch_tradeszmexc.watch_trades7s!!!V$!&(  &>1F4L@G11';OOF G&,#M 11'; W]^^F ??OOFE2E))&% TRR! "P _s4B?B9AB?B;%B?B=8B?;B?=B?c6|j|dd}|j|}|d}d|z}|j|j|}|7|j |j dd}t |}||j|<|j|dd} |j| d| g} td t| D]E} d} |d r|j| | |} n|j| | |} |j| G|j||y) Nrvr`rW tradesLimitrrtrudealsrr4)r|r~rrYr}rVrrrrparse_ws_trade parse_traderr) r\rrrrrir`rnrrrtrYj parsedTrades r^ handle_tradeszmexc.handle_tradesVs@%%gsH=!!(+!&( f5 >%%dllM4HE&F"(DKK    gsF 3GaS1q#f+& 'AKf~"11&)VD "..vay&A MM+ &  ' v{+r_cK|jd{d}d}||j|}|d}|dz|z}d}|jd||\}}d}|dk(rd} |j| ||d{}n|j ||d{}|j r|j ||}|j||||dS77T7;w) a https://mexcdevelop.github.io/apidocs/spot_v3_en/#spot-account-deals https://mexcdevelop.github.io/apidocs/contract_v1_en/#private-channels watches information on multiple trades made by the user :param str symbol: unified market symbol of the market trades were made in :param int [since]: the earliest time in ms to fetch trades for :param int [limit]: the maximum number of trade structures to retrieve :param dict [params]: extra parameters specific to the exchange API endpoint :returns dict[]: a list of `trade structures ` NmyTradesr`rr$r4zspot@private.deals.v3.apiT)rhrirrrrrfilter_by_symbol_since_limit) r\r`rrrmrnrirrYros r^watch_my_tradeszmexc.watch_my_tradess!!!   [[(FH%F%+f4K99/6SYZ f 6>1G227KPPF22;GGF ??OOFE2E00tTT# "QGs4CC AC6C 7CC 8C C Ccd}|j|dd}|j|d}|j|d|}|j|}|d} d} |dr|j||} n|j ||} |j } | /|j |jdd} t| } | |_| j| |j| ||d z| z} |j| | y) Nrdrtrur`rvr4r\rr) rrr~r^r_rdr}rVrrr)r\rrrr?rnrufuturesMarketIdrrir`traderYrsymbolSpecificMessageHashs r^handle_my_tradezmexc.handle_my_trades&!   #v6**4:##GS/B!!(+! &>''f5E$$T62E >%%dllM4HE+E2F"DM ev{+$/#$5$>!v89r_c*|j|d}|j|d}||j|d}d}|j|d}|j|d}|j|d}|dk(rdnd}|j|d } |j|d } |j|d } |j|||j|d ||j ||j d|d|| rd nd||d| |j | dd |S)NTrwrrS1buysellmnNrmakertaker)costcurrency) rreorderrxryr`rside takerOrMakerrrMrwfee)r}rr safe_traderrsafe_currency_code) r\ririrxtradeId priceString amountStringrawSiderzisMaker feeAmount feeCurrencyIds r^r^zmexc.parse_ws_trades;J%%eS1 ""5#.  ))%5IG&&uc2 ''s3 ""5#. Cuf##E3/$$UC0 ((4 %%eS1" Y/&&tV4(/Gg "! 33MB " # r_cK|jd{|j|d}d}d}||j|}|d}|dz|z}d}|jd||\}}d}|dk(r!|dz} |j | ||d{}n|j ||d{}|j r|j||}|j||||d S77T7;w) a https://mexcdevelop.github.io/apidocs/spot_v3_en/#spot-account-orders https://mexcdevelop.github.io/apidocs/spot_v3_en/#margin-account-orders 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 :param str|None params['type']: the type of orders to retrieve, can be 'spot' or 'margin' :returns dict[]: a list of `order structures ` Nrordersr`rr'r4z@private.orders.v3.apiT) rhrrirrrrrre) r\r`rrrmrnrirrros r^ watch_orderszmexc.watch_orderss!!!66*   [[(FH%F%+f4K99-QWX f 6>55G227KPPF22;GGF ??OOFE2E00tTT% "QGs4C$CA4C$ C  C$&C"'8C$ C$"C$cd}|j|dd}|j|d}|j|d|}|j|}|d}d} |dr|j||} n|j ||} |j } | /|j |jdd} t| } | |_| j| |j| ||d z|z} |j| | y) Nrrtrur`rvr4 ordersLimitrr) rrr~parse_ws_order parse_orderrr}rVrrr) r\rrrrnrurhrrir`rrrrjs r^ handle_orderzmexc.handle_order8sD   #v6**4:##GS/B!!(+! &>((v6F%%dF3F >%%dllM4HE+E2F DK fv{+$/#$5$>!v89r_c(|j|d}|j|d}|j|d}|j|d}d}|j|d}||dd}|jid|j|dd |j|d d |d |j|d dd|j ||d|j d|d|j |d|j|d|dk(rdndd|j|dddd|j|dd|j|dd|j|dd|j|d d!|j|d"|j|d#|d|d$|S)%NOrnrvrrt)rxrwrer clientOrderIdrrxrylastTradeTimestampstatusr`r timeInForcerzrorprqrr stopPrice triggerPricePraprMrrwrfilledcvV) remainingr|rYr) r}r safe_orderrparse_ws_order_statusrparse_ws_order_typeparse_ws_time_in_forcer) r\ryrirxrzrrr| feeCurrencys r^rzmexc.parse_ws_orders%f%%eS1 s+!!%-s+&&uc2  "'C $""5#. T--eS9     Y/  !$  d00@   d&&tV4  D,,T2  466t<  dckE  T%%eS1    D,,UC8  t''t4  d&&uc2 D$$UC0! " d&&ud3# $))%5+ , - r_c @dddddddddd }|j|||S)Nrclosedcanceledrejected) ro2345NEWCANCELEDEXECUTEDFAILEDr)r\rristatusess r^rzmexc.parse_ws_order_statuss;"    &&99r_c8ddddddd}|j||S)Nrrirorrrr100r)r\rtypess r^rzmexc.parse_ws_order_types0  t,,r_c8ddddddd}|j||S)NGTCPOIOCFOKrr)r\rtimeInForceIdss r^rzmexc.parse_ws_time_in_forces0   <` Nr#balance:r4zspot@private.account.v3.api)rhrrr)r\rmrrnros r^ watch_balancezmexc.watch_balance s!!!99.$PVW f 4' 6>3G00+vNN N00fEE E " OEs3A:A4>A:A6A:/A80A:6A:8A:c|j|d}|dnd}d|z}|j|dd}|j|d}|j|d|}||jvri|j|<||j|d<||j|d <|j ||j|d <|j |d d } |j | } |j} |j |d d| d<|j |dd| d<| |j|| <|j|j||j|<|j|j||y)Nrr5r4rrtrur7rrxryrrxfavailableBalancefreer frozenBalanceused) rrr}balancerr|r~account safe_balancer) r\rrrrrrnrufuturesTimestamprx currencyIdcoders r^handle_balancezmexc.handle_balancesp@   Wc *)v& 4'   #v6,,Wd;%%dC1AB  $!#DLL %) T6"*3 T;')-i)@ T:&''c:> &&z2,,.,,T38JK,,T3H#* T4 !..t||D/AB Tt||D);7r_cK|jd{|j|}d|dz}d}d}|dr\d}|j|dd\}}|r d|d zd z}nd |d z}|jd d d}d|d<|j |||n2d}d|d i}|jd d d}|j |||||j |} |j| |gy7٭w)a unWatches a price ticker, a statistical calculation with the information calculated over the past 24 hours for all markets of a specific list :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 ` Nunsubscribe:ticker:r`r4Fr(rcrdrerfrgr3rTrz unsub.tickerr5)rhrirjrUrkrlrrhandle_unsubscriptions) r\r`rmrirnrrorcrprrs r^un_watch_tickerzmexc.un_watch_tickerPs*!!!V$+fX.>>  &>J!%!>!>v}Vb!c J:VD\IHT:VD\I))E"4(0C%)F> "  " "7K @$G&,#M))E"4(0C  " "7K OS! ##F[M:1 "sC2C0CC2cK|jd{|j|d}g}|j|d}d}||j|}d}|j d||\}}|dk(}|r|j dddn|j ddd}i} |rd} |j |dd \} }g} | sx|t|jd z|j|} tdt| D]4} | | }|jd || zd |z}| j|6nV| jd ||jdn1tdt|D]} |jd || zd| d<| | d<nd| d<i| d<|jd|j|}|j|||j| |||j!||y7w)a unWatches a price ticker, a statistical calculation with the information calculated over the past 24 hours for all markets of a specific list :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 ` Nrr)r4r3rr5Frcrrrgrzunsubscribe:spot:tickerrrrmz unsub.tickerszunsubscribe:ticker)rhrrrirrUrjrrerrrrrrrrr)r\rrmrrrirrrrrcrrrrrorrs r^un_watch_tickerszmexc.un_watch_tickersqs/!!!%%gt4 &&w2   "[[-F99.&RXY f&.17diit$V,dii>Nt>TU[>\ J!%!>!>v~Wc!d JF?+DGG6z,z{{ OOG4 q#i.1+A(|H!(()>)KL>IGMM'* +  DE?!(()BC"1c'l3Q%,,-BWQZ-OPQ 0GH  &GH  /GH  "GH   !5 6S! C GV0Lm\ ##FM:S "sG>G;G%G>cK|jd{|j|dddd}d}|t|jdz|j |}|j d|d|\}}|dk(}|st |jdzg}g}tdt|D]F}|r+|j||} |jd | d z|jd ||zH|jd d d} d|d} |j| } |j| ||j| |||j| |y7Cw)a9 unWatches best bid & ask for symbols :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 ` NTFrr*rr4rrgreunsubscribe:bidask:r3rrr)rhrrrerrrrrrirrUrrrrr) r\rrmrrrrrrrirrrrs r^un_watch_bids_askszmexc.un_watch_bids_askss{!!!%%gtT5$G ?#DGG.X$XY Y**73!??QXYZQ[]cd Fv%tww)RRS S q#g,' EAWQZ0 >MN  !6!C D  E iit$V,& S! C GV0Lm\ ##FM:3 "sEEEEcK|jd{|j|}|d}|j|jdi}|j ||}d|zdz|z}d}|dr<|j ddd}d |d zd z|z} d |d <|j | ||n3|j ddd}d} |d |d} |j| || ||j|} |j| |gy7w)aJ unWatches 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 dict [params]: extra parameters specific to the exchange API endpoint :param dict [params.timezone]: if provided, kline intervals are interpreted in that timezone instead of UTC, example '+08:00' :returns int[][]: A list of candles ordered, open, high, low, close, volume Nr`rPzunsubscribe:candles:rr4r3rrrerTrr5z unsub.kliner) rhrirrVrrUrkrlrrr) r\r`rrmrirPr rnrrorprrs r^un_watch_ohlcvzmexc.un_watch_ohlcvs2!!!V$!__T\\<D &&z9= ,v5;iG  &>))E"4(0C1F4L@3FTG%)F> "  " "7K @))E"4(0C#G ,'#M  " "7K OS! ##F[M:- "sDDC0DcK|jd{|j|}|d}d|z}d}|dr6|jddd}d|dz}d |d <|j|||n2|jddd }d }d|di}|j |||||j |}|j ||gy7w) a unWatches information on open orders with bid(buy) and ask(sell) prices, volumes and other data :param str symbol: unified array of symbols :param dict [params]: extra parameters specific to the exchange API endpoint :returns dict: A dictionary of `order book structures ` indexed by market symbols Nr`unsubscribe:orderbook:r4r3rrreTrr5z unsub.depthrhrirUrkrlrrr r\r`rmrirnrrorprrs r^un_watch_order_bookzmexc.un_watch_order_books!!!V$!.7  &>))E"4(0C:VD\IG%)F> "  " "7K @))E"4(0C#G&,#M  " "7K OS! ##F[M:' "C C B4C cK|jd{|j|}|d}d|z}d}|dr6|jddd}d|dz}d |d <|j|||n2|jddd }d }d|di}|j |||||j |}|j ||gy7w) a unsubscribes from the trades channel :param str symbol: unified symbol of the market to fetch trades for :param dict [params]: extra parameters specific to the exchange API endpoint :param str [params.name]: the name of the method to call, 'trade' or 'aggTrade', default is 'trade' :returns dict[]: a list of `trade structures ` Nr`unsubscribe:trades:r4r3rrXreTrr5z unsub.dealrrs r^un_watch_tradeszmexc.un_watch_tradess!!!V$!+f4  &>))E"4(0C1F4L@G%)F> "  " "7K @))E"4(0C"G&,#M  " "7K OS! ##F[M:' "rrcptdt|D]}||}|jdd}|j||||j ddk\r|jdd}|j ddk\rNt |j j}tdt|D]}|j ||=||j vs|j |=|j ddk\r1|jdd}||jvs |j|=|j d dk\rh|jd } |j| d }t| d kDr|d |j| d zz }||jvs|j|=|j ddk\r1|jdd}||jvs|j|=|j ddk\s|jdd}||jvs|j|= y)Nrz unsubscribe:rrr unsubscriberLrcandlesrr#rLrrrYr)rrreplaceclean_unsubscriptionfindrFrkeysrr$rrr&rY) r\rrrrrnsubMessageHashr`rr` splitHashess r^rzmexc.handle_unsubscriptionss q#m,- ,A'*K(00DN  % %fnk J)Q.$,,-BBG;;}-2"4<<#4#4#67G"1c'l35 LL45t||+ V,!!(+q0$,,-BBGT]]* f-!!),1)//4 ))+q9{#a'cD$4$4[!$DDDFT[[( F+!!+.!3$,,-ErJT__,/!!(+q0$,,-BBGT[[( F+? ,r_c<K|j|jd}||S|j|d{}|j|d}||jd<|j|jdd}|j ||j |||S7bw)NrQrOr6)rrVspotPrivatePostUserDataStreamr}delaykeep_alive_listen_key)r\subscriptionHashrmrQresponserOs r^rzmexc.authenticateAs$$T\\;?   ;;FCC $$X{; $- [!#00?UW^_ ')C)CYPVWDs5BBA#BcK|yd|i} |j|j||d{|j|jdd}|j ||j ||y7@#t $rc}|jddddz|z}|j|}d|jd<|j||j|=Yd}~yd}~wwxYww)NrQrOr6r3rr4r) spotPrivatePutUserDataStreamrr}rVrrr=rUrrr>clients)r\rQrmrrOerrorrrrs r^rzmexc.keep_alive_listen_keyRs      "33DKK4PQ Q Q#'#4#4T\\CY[b#c JJ+T-G-GTZ [ R "))E"4(0=@9LC[[%F(,DLL % MM%  S!  "s?C!$A2A0?A2/C!0A22 C;ACC!CC!c0|j|_|SN)rlastPong)r\rrrs r^ handle_pongzmexc.handle_pongcs++-r_c"|j|dd}|dk(r|j||y|jddkDrP|jd}|j|d}d|ji}|j ||}| |||yyy)Nr"rPONGrr.r-public.increase.depth.v3.api)rrrr$r(r)r\rrrr"r'romethodsrs r^handle_subscription_statuszmexc.handle_subscription_statusgswr2 &=   VW - XXc]R IIcNE&&ua0G.0S0SG__Wg6F!vw'" r_cHt|tr/|dk(r)t|jdz}|j |yd|vr|j ||y|j |d}d}||j |d}n#|jd}|j |d}id|jd |jd |jd |jd |jd |jd|jd|jd|jd|jd|jd|jd|jd|jd|jd|jd|jd|j i}||vr||}|||yy)NzInvalid listen keyz invalid listen keyr"rrorr-zpublic.deals.v3.apiz push.dealzpublic.kline.v3.apiz push.klinezpublic.bookTicker.v3.apizpublic.miniTicker.v3.apizpublic.miniTickers.v3.apiz push.tickerz push.tickersrz push.depthzprivate.orders.v3.apizpush.personal.orderzprivate.account.v3.apizpush.personal.assetzprivate.deals.v3.apizpush.personal.order.dealpong)rErrrer>rrr$rbrrrrCrrrkr) r\rrrrrror'rrs r^handle_messagezmexc.handle_message|s  gs #..+DGG6K,KL e$  G   + +FG <    Wc * 9&&w :GGGCLE&&ua0G !4#5#5 ++  "4#4#4  $++  '(:(:  '(:(:   ()<)<  4--  D//  +D,B,B  $00  $T%6%6  "4#4#4  %d&9&9  "4#6#6 #D$8$8! " '(<(<# $ D$$% ( g W%F 67 # r_c ddiS)NrrR)r\rrs r^rRz mexc.pings &!!r_r)B__name__ __module__ __qualname__rr[rr rqrrr rrrrrrzrrkrrlrrrrFr rrr r r(r5rCrNr<rrZrbr rfrkr^r rrrrrrrrrrrrrrrrrrrrrrR __classcell__)r]s@r^rrsA #A F68]]F]@S,FS,j6:"8E78E8EtT&VT&l4l8D$8<$]ajl H HC HWZ Hquvzq{ HD@,6@,D( D( T@DB!S!!S\!86V6 E5E5N. 8<@d[]SSSSSbfglbmS>2,F2,h37TX\egUCUsURUUlpqvlwU@&:f&:PBH04$UYbd U UC Us Uimnsit UDU:6U:nTl : - =*,FF&28V28h9;CsB9=R0g0C0d;?r  c D;?r3cB=?389;Cs: ,V ,DI ,D;="=?""&((*&$V&$P"6"r_r)ccxt.async_supportccxt ccxt.async_support.base.ws.cacherrrrccxt.base.typesrrrr r r r r rr!ccxt.async_support.base.ws.clientrtypingrccxt.base.errorsrrr async_supportrrr_r^r sE fffff40.)T"4   " "T"r_