ei;ddlZddlmZmZmZddlZddlmZm Z m Z m Z m Z m Z mZmZmZmZmZddlmZddlmZddlmZddlmZddlmZGd d ejjZdS) N) ArrayCacheArrayCacheBySymbolByIdArrayCacheByTimestamp) AnyBalancesIntOrder OrderBookStrStringsTickerTickers FundingRateTrade)Client)List)AuthenticationError)ArgumentsRequired) NotSupportedc `eZdZdeffd ZifdedefdZdefdZ difde de fd Z defd Z d?d Zdifde de fd Zdefd Zd?dZifdZifdZifdZifdZdddifdededededeef dZdefdZd?defdZdifdededefdZdefdZdZdefdZ dZ!dZ"ddifdedededee#fd Z$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,Z3ifdede4fd-Z5ifdedefd.Z6defd/Z7ifdedefd0Z8difde defd1Z9difde defd2Z:difdededefd3Z;ifdedefd4Zifd8Z?ifd9Z@defd:ZAdefd;ZBdefd<ZCdefd=ZDdefd>ZExZFS)@mexcreturncN|tt|iddddddddddddd dd dd dd dd ddddddddddddddddddddddddd dddddiiddddddddd d!d"d#d$ d%d&d'dd(|jd)d*id+S),NwsTcancelAllOrdersWsFcancelOrdersWs cancelOrderWs createOrderWs editOrderWsfetchBalanceWsfetchOpenOrdersWs fetchOrderWs fetchTradesWs watchBalancewatchFundingRatewatchFundingRates watchMyTrades watchOHLCVwatchOrderBook watchOrders) watchTicker watchTickers watchBidsAsks watchTradeswatchTradesForSymbols unWatchTickerunWatchTickersunWatchBidsAsks unWatchOHLCVunWatchOrderBook unWatchTradesapizwss://wbs-api.mexc.com/wszwss://contract.mexc.com/edge)spotswapOMin1Min5Min15Min30Min60Hour4Hour8Day1Week1Month1) 1m5m15m30m1h4h8h1d1w1M) snapshotDelaysnapshotMaxRetries)listenKeyRefreshRatedecompressBinary timeframesr) listenKeyi@)ping keepAlive)hasurlsoptions streaming exceptions) deep_extendsuperrdescriberV)self __class__s K/var/www/html/volatility/venv/lib/python3.11/site-packages/ccxt/pro/mexc.pyr_z mexc.describesdD 1 1 : : < <d#U!%      u !%$U #D$U d !$!"t#$ $ $!%#).!%"&#' $$(!%9> ; >)0$)! ""!!! !"  &(*+##"). !CC? C? C C C symbolc.K|d{V||}d|dz}|dr(d|dz}||||d{VSd}d|di}|||||d{VS)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:rdr7-spot@public.aggre.bookTicker.v3.api.pb@100ms@idz sub.ticker) load_marketsmarketwatch_spot_publicwatch_swap_publicr`rdparamsrj messageHashchannel requestParamss rb watch_tickerzmexc.watch_tickerYs!!!!!!!!!V$$&"22 &> ]Et TG//fMMMMMMMM M"G&,#M//mU[\\\\\\\\ \rcclientc|||||gd}||dd}||dd}||}|d}d}|dr4|||}||d<|||d<n|||}||j|<d |z} | || dS) N)ddatapublicAggreBookTickersrdtsendTimer7 timestampdatetimerf) handle_bid_ask safe_dict_n safe_string_2safe_integer_2 safe_marketparse_ws_tickeriso8601 parse_tickertickersresolve) r`rsmessage rawTickermarketIdr{rjrdtickerros rb handle_tickerzmexc.handle_tickerssH FG,,,$$W.T.T.TUU %%gsH==''jAA !!(++! &> :)))V<` Nrr,r7r6rr8+ watchTickers does not support spot marketsz sub.tickersmethodrnrrd)rimarket_symbols safe_stringrjhandle_market_type_and_paramsrYrrhappendwatch_multipleextend newUpdatesfilter_by_arrayr) r`rrn messageHashes firstSymbolrjtypeisSpoturlrequestrresults rb watch_tickerszmexc.watch_tickerss!!!!!!!!!%%gt44 &&w22   "[[--F99.&RXYY f&.17\dit$V,,di>Nt>TU[>\  +tw)VVWW W8!.GH  "GH    * * ***3 t{{7TZ?[?[]jkkkkkkkk  do F'-F6(# $M##DL(GDDDrcc||dd}||dd}||d}||}|d}|du}|r|n|d} d} | r| nd} | dz} g} t d t |D]|}||}d}| r|||}n||}|d }||j|<| |d |z}| ||}| | | dS) Nrvrucrxr7zspot:rrrdrf) safe_list_2rr startswithrangelenrrrrr)r`rsrrvrprrjchannelStartsWithSpotmarketIdIsUndefinedr spotPrefixmessageHashPrefixtopicrientryrrdros rbhandle_tickerszmexc.handle_tickersssz55""7C44##GS11!!(++ ' 2 26 : :&$.*=Q&&6&> *08JJb!H,q#d))$$ 0 0AGEF 2--eV<<**511H%F#)DL MM& ! ! !#f,K NN6; / / / /vu%%%%%rcc ||d}||d}||d}|id|d|||d|d||ddd ||d d ||d d |d|d||ddd||ddd||ddd||ddddddddd||dd||d ||d!d"|S)#Nrxrypinfordr{r|openhighhlowlcloselastbidbbidPrice bidVolumeB bidQuantityaskaaskPrice askVolumeA askQuantityvwap previousClosechange percentagetrvq)average baseVolume quoteVolume)r safe_integer safe_ticker safe_symbolr safe_number safe_number_2)r`rrjrr{prices rbrzmexc.parse_ws_ticker^sB##FC00%%fc22   --! F! d&&x88!  !   Y// ! D ! D$$VS11 !  4##FC00!  U!  E!  4%%fc:>>!  ++FCGG!  4%%fc:>>!  ++FCGG!  D!  T! d!! " $**6488#! $**6377++FC88)! ! ! * + rccHK|d{V||dddd}d}|t|jdz||}|d|d|\}}|dk}|st |jdzg}g}tdt|D][}|r9| ||} | d | d z| d ||z\|j d d d} d|d} | | || | ||d{V} |jri} | | | d<| S||jd|S)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-rr7' watchBidsAsks only support spot marketrgrhbidask:r6r SUBSCRIPTIONrrnrd)rirrrhmarkets_for_symbolsrrrrrjrrYrrrrbidsasks)r`rrn marketTypemarketsrrtopicsrrjrrrrs rbwatch_bids_askszmexc.watch_bids_askss!!!!!!!!!%%gtT5$GG ?#DG.X$XYY Y**733!??QXYZQ[]cdd Fv% Ttw)RRSS S q#g,,'' 9 9A ^WQZ00 MPVW[P\\]]]  WQZ!7 8 8 8 8it$V,$  **3 t{{7TZ?[?[]jkkkkkkkk ? G(.GF8$ %N##DM8WEEErcc||}||d}|dS||j|<d|z}|||dS)Nrdr)parse_ws_bid_askrrr)r`rsr parsedTickerrdros rbr}zmexc.handle_bid_asksf,,W55 !!,99 > F , f&( |[11111rcc ||d}||d}|||}||d}||d}|||||||d||d||d||d|d |S) Nrurxrdryrrrr)rdr{r|rrrrr) safe_dictrrrrrr)r`rrjrvrrdr{s rbrzmexc.parse_ws_bid_asks~~fc**##FC00!!(F33!!&(33%%fc22 " Y//##D#..))$44##D#..))$44 ! !     rccK||dd}||dg}|jddd}|rdnd}||gd}|||||||d{VS) N unsubscribedFr6rr7UNSUBSCRIPTIONrr) safe_boolomitrYwatchr)r`rprornrrrrs rbrkzmexc.watch_spot_publics~~fneDD 6N#344it$V,&2G!!i  ZZ[$++gv2N2NP[\\\\\\\\\rccK|||d{V}|jddddz|z}d|gd}|||||||d{VS)Nr6rr7 ?listenKey=rr)check_required_credentials authenticaterYrr)r`rprornrUrrs rbwatch_spot_privatezmexc.watch_spot_privates '')))++G44444444 it$V,} ^4vd|CcIKWG00+vNNNNNNNNEE!G ,'##M00+}V\]]]]]]]]E ? 2NN6511E))%q$GGGrccPd}d}d}d|vr|||d}||di}||d}|||jd}||||}n||ddi}||d|} | | dd}||jdi} ||| }| |d d} || } | d}|| | }d |zd z|z} ||j |i|j |<||j ||}|;| |jd d }t|}||j ||<| |||| dS)NpublicSpotKlinerdr rTrurvkrrxrr OHLCVLimit)rdrrfind_timeframerZparse_ws_ohlcvr safe_value_2r rohlcvsrrrr)r`rsrparsedrdrrvrrurawOhlcvrTrrjrostoredrs rb handle_ohlcvzmexc.handle_ohlcv9sB  ' '[[!1!1'8!D!DEEF>>'+%%dlL$GGE*511F-3DK  * fv{+++++rcc t||dd}|/||ds|||dd}||dd||dd||d d ||d d ||d d|gS)Nrvolumer7rry windowStarto openingPricer highestPricer lowestPricer closingPrice)rrsafe_timestamp_2)r`rrjr s rbrzmexc.parse_ws_ohlcvsX##E399  )G)G fn''sC88F  ! !%m < <   uc> : :   uc> : :   uc= 9 9   uc> : :    rccK|d{V||}|d}d|z}d}|drLd}||ddd\}}d|zd z|d z}||||d{V}n*d }d|d i} |||| |d{V}|S) a https://www.mexc.com/api-docs/spot-v3/websocket-market-streams#trade-streams 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 :param str [params.frequency]: the frequency of the order book updates, default is '10ms', can be '100ms' or '10ms :returns dict: A dictionary of `order book structures ` indexed by market symbols Nrd orderbook:r7r) frequency100ms"spot@public.aggre.depth.v3.api.pb@r rhz sub.depth)rirjhandle_option_and_paramsrkrlr) r`rdrrnrjro orderbookr*rprqs rbwatch_order_bookzmexc.watch_order_books !!!!!!!!!V$$!"V+  &> bI $ = =fFVXcel m m Iv:YFLvVZ|[G"44Wk6RRRRRRRRII!G&,#M#44Wk=Z`aaaaaaaaI   rcc||d}|d}||d}||}|i|j|<dS)Nmsgr )rsplitr order_book orderbooks)r`rsrr1partsrrds rbhandle_order_book_subscriptionz#mexc.handle_order_book_subscriptionsnw.. ###E1--!!(++"&//""5"5rccR||d}||d}||gd}||dz krdStdt |D],}||}||gd}||kr|cS-t |S)Nnoncerrversion fromVersion)rr safe_integer_nrr) r`r.cacher9 firstDeltafirstDeltaNoncerdelta deltaNonces rbget_cache_indexzmexc.get_cache_indexs!!)W55__UA.. --j:Y:Y:YZZ ?Q& & &2q#e**%%  A!HE,,U4S4S4STTJU""#5zzrcc||gd}||dd}||}d|z}||j|}||d}||jvr||j|<|j|} || d} d} | lt| j } | dd d } | | kr| |j ||||i| j |dS || |||gd }|| d <||| d <n7#t"$r*}|j|=|||d} Yd}~nd}~wwxYw| rdS|| |dS)N)rurvpublicAggreDepthsrxrdr)rr9Fr)rPrN)rytsrzr{r|T)r~rrr  subscriptionsrr5r4rrA handle_optionspawnload_order_bookr handle_deltar@r Exceptionrejectr)r`rsrrvrrdro subscriptionrstoredOrderBookr9 shouldReturn cacheLengthrPr{es rbhandle_order_bookzmexc.handle_order_booksF)K)K)KLL%%gsH==!!(++"V+ v';[II !!,88$/))&*oo&7&7DOF #/&1!!/7;; =o344K ../?RTUUMm++ 4/feUWXXX  ! ( ( . . . F   ot 4 4 4++G5L5L5LMMI+4OK (*.,,y*A*AOJ ' '   $[1 MM![ ) ) )LLLLLL    F 44444s4A F F4 F//F4c4tdt|D]y}||}t|tr||5||dd}||dd}|||zdS)Nrrrrquantity)rr isinstancelist storeArray safe_float_2store)r`booksidebidasksrbidaskramounts rbhandle_bookside_deltazmexc.handle_bookside_deltaksq#g,,'' . .AQZF&$'' .##F++++))&#w??**63 CCuf---- . .rccP||d}||gd}||krdS||d<||dg}||dg}|d}|d}||||||dS)Nr9r:asksbids)rr@ safe_listrb) r`r.rD existingNoncerErdre asksOrderSide bidsOrderSides rbrNzmexc.handle_delta{s)))W== ((0O0O0OPP  % % F' '~~eVR00~~eVR00!&) !&)  ""=$777 ""=$77777rccK|d{V||}|d}d|z}d}|dr)d|dz}||||d{V}n*d}d|di} |||| |d{V}|jr|||}||||dd S) a https://www.mexc.com/api-docs/spot-v3/websocket-market-streams#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 ` Nrdtrades:r7(spot@public.aggre.deals.v3.api.pb@100ms@rhzsub.dealr{T)rirjrkrlrr r) r`rdrrrnrjrotradesrprqs rb watch_tradeszmexc.watch_tradess!!!!!!!!!V$$!&(  &> _@6$<OG11';OOOOOOOOFF G&,#M 11'; W]^^^^^^^^F ? 3OOFE22E))&% TRRRrcc||dd}||}|d}d|z}||j|}|5||jdd}t |}||j|<||ddg} || dd | g} | | |d g} td t| D]Z} d} |d r| | | |} n| | | |} || [|||dS) Nrxrdrk tradesLimitrrupublicAggreDealsdeals dealsListrvrr7)rrr rmrrZrr~rrfrrparse_ws_trade parse_traderr) r`rsrrrjrdrorrrurmj parsedTrades rb handle_tradeszmexc.handle_tradesssf%%gsH==!!(++!&( f55 >%%dlM4HHE&&F"(DK    Ws,>&? @ @!!!WkA3?? 9^^GVR88Fq#f++&& ' 'AKf~ B"11&)VDD "..vay&AA MM+ & & & &v{+++++rccK|d{Vd}d}|%||}|d}|dz|z}d}|d||\}}d}|dkr d} || ||d{V}n|||d{V}|jr|||}|||||dS) a https://www.mexc.com/api-docs/spot-v3/websocket-user-data-streams#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 ` NmyTradesrdrr'r7zspot@private.deals.v3.api.pbTrirjrrrrr filter_by_symbol_since_limit) r`rdrrrnrorjrrmrps rbwatch_my_tradeszmexc.watch_my_tradess%!!!!!!!!!   [[((FH%F%+f4K99/6SYZZ f 6>>4G227KPPPPPPPPFF22;GGGGGGGGF ? 3OOFE22E00tTTTrccFd}||gd}||d}||dd|}||}|d} d} |dr|||} n|||} |j} | 2||jdd} t| } | |_| | | | ||dz| z} | | | dS) Nrz)rurv privateDealsrdrxr7rprr) r~rrrrtrurzrrZrrr)r`rsrrQrorvfuturesMarketIdrrjrdtradermrsymbolSpecificMessageHashs rbhandle_my_tradezmexc.handle_my_trades8F! )F)F)FGG**4::%%gsHoNN!!(++! &> 3''f55EE$$T622E >%%dlM4HHE+E22F"DM ev{+++$/#$5$>!v899999rcc||dd}||dd}|||d}d}||dd}||dd}||d d }|d krd nd }||d} ||dd} ||dd} |||||dd||||d|d|| rdnd||||d| || dd |S)NTtimerytradeIdrrrrXS tradeType1buysellmn feeAmountN feeCurrencyrorderIdmakertakerra)costcurrency) rrhorderr{r|rdrside takerOrMakerrrarfee)rrr safe_traderrrsafe_currency_code) r`rrjr{r priceString amountStringrawSiderisMakerr feeCurrencyIds rbrtzmexc.parse_ws_tradeJsd''sF;; $$UC;;  ))%55IG((W== ))%jAA $$UC== Cuuf##E3//&&uc;?? **5#}EE ''sI>>" Y//&&tV44(/=GGg "$$UH55! 33MBB  " # rccK|d{Vd}d}|%||}|d}|dz|z}d}|d||\}}d}|dkr d} || ||d{V}n|||d{V}|jr|||}|||||dS) a https://www.mexc.com/api-docs/spot-v3/websocket-user-data-streams#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 ` Nordersrdrr*r7zspot@private.orders.v3.api.pbTr{) r`rdrrrnrorjrrrps rb watch_orderszmexc.watch_orderss%!!!!!!!!!   [[((FH%F%+f4K99-QWXX f 6>>5G227KPPPPPPPPFF22;GGGGGGGGF ? 3OOFE22E00tTTTrccFd}||gd}||d}||dd|}||}|d}d} |dr|||} n|||} |j} | 2||jdd} t| } | |_| | | | ||dz|z} | | | dS) Nr)rurv privateOrdersrdrxr7 ordersLimitrr) r~rrrparse_ws_order parse_orderrrrZrrr) r`rsrrorvrrrjrdrrrrs rb handle_orderzmexc.handle_orders8R )G)G)GHH**4::%%gsHoNN!!(++! &> 4((v66FF%%dF33F >%%dlM4HHE+E22F DK fv{+++$/#$5$>!v899999rcc ||d}||d}||dd}||d}d}||d}||dd}|id||dd ||d d |d ||d dd|||d|d|d||d||d|dkrdndd||dd||ddd||ddd||dd||dd||dd||d||d |d|d!|S)"N createTimerstatusstate orderTyper)rrrh clientOrderIdclientIdr{r|lastTradeTimestamprdr timeInForcerrrrr stopPrice triggerPricePravgPricerarXrfilledcumulativeQuantityremainQuantity) remainingrrmr) rrr safe_orderrparse_ws_order_statusrparse_ws_order_typeparse_ws_time_in_force) r`rrjr{rrrrrs rbrzmexc.parse_ws_ordersH%%e\:: {33##E8W=={33&&uc22  "'C $""5$// T--eZ@@     Y//  !$  d00@@   d&&tV44  D,,T22  466t<<  dckkEE  T%%eW55  ++E>3GG  D..uncJJ  t''z::  d&&uj99 D$$UH55! " d&&u.BCC# $))%1ABB+   , - rcc Jddddddddddd }||||S)Nrclosedcanceledrejected) 0r2345NEWCANCELEDEXECUTEDFAILEDr)r`rrjstatusess rbrzmexc.parse_ws_order_statussF"     &&999rcc Dddddddddd}|||S)Nrrjrrrrr100101102r)r`rtypess rbrzmexc.parse_ws_order_types>   t,,,rcc Dddddddddd}|||S)NGTCPOIOCFOKrr)r`rtimeInForceIdss rbrzmexc.parse_ws_time_in_forces>  <<` Nr$balance:r7spot@private.account.v3.api.pb)rirrr)r`rnrrorps rb watch_balancezmexc.watch_balances!!!!!!!!!99.$PVWW f 4' 6>>6G00+vNNNNNNNN N00fEEEEEEEE Ercc&||d}|dkrdnd}d|z}||ddg}||dd }||d |}||jvr i|j|<||j|d <||j|d <|||j|d <||ddg} || } |} ||dd| d<||ddg| d<| |j|| <| |j||j|<| |j||dS)Nrprr7r8rrvprivateAccountrIrrrr{r|r vcoinName balanceAmountavailableBalancefree frozenBalance frozenAmountused) rr~rbalancer safe_string_nraccountr safe_balancer) r`rsrrprrorvfuturesTimestampr{ currencyIdcoders rbhandle_balancezmexc.handle_balancesF""7I66!%EEEvvF 4' &2B)CDD..wlKK''f6FGG  $$!#DL %) T6"*3 T;')-i)@)@ T:&''z;.GHH &&z22,,..,,T?DVWW,,TO^3TUU#* T4 !..t|D/ABB Tt|D);77777rccK|d{V||}d|dz}d}d|di}|||||d{VS)af watch the current funding rate https://www.mexc.com/api-docs/futures/websocket-api#funding-rate :param str symbol: unified market symbol :param dict [params]: extra parameters specific to the exchange API endpoint :returns dict: a `funding rate structure ` N fundingRate:rdzsub.funding.raterh)rirjrlrms rbwatch_funding_ratezmexc.watch_funding_rates!!!!!!!!!V$$$vh'77 $ fTl ++G[-QWXXXXXXXXXrccTK|d{V||}d|dz}d}d}d|di}|jddd}|||||||}|||gdS) a~ unWatches the current funding rate for a symbol https://www.mexc.com/api-docs/futures/websocket-api#funding-rate :param str symbol: unified symbol of the market :param dict [params]: extra parameters specific to the exchange API endpoint :returns dict: a `funding rate structure ` Nunsubscribe:fundingRate:rdzunsub.funding.raterhr6rr8)rirjrYrlrshandle_unsubscriptions r`rdrnrjrorrprqrss rbun_watch_funding_ratezmexc.un_watch_funding_rates!!!!!!!!!V$$06(3CC & fTl it$V, w ]FKKKS!! ##F[M:::trcc||di}||}|d}||j|<d|z}|||dS)Nrvrdr)rparse_funding_rate fundingRatesr)r`rsrrv fundingRaterdros rbhandle_funding_ratezmexc.handle_funding_ratesg~~gvr22--d33 X&$/&!$v- {K00000rccK|d{V||}d|dz}d}d}|drAd|dz}|jddd}d |d <||||n=d }d|di}|jddd }|||||||}|||gdS) 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:rdr7rgrhr6rTrz unsub.tickerr8rirjrYrkrlrsrrs rbun_watch_tickerzmexc.un_watch_ticker3s!!!!!!!!!!V$$+fX.>>  &> PEt TG)E"4(0C%)F> "  " "7K @ @ @ @$G&,#M)E"4(0C  " "7K O O OS!! ##F[M:::trccK|d{V||d}g}||d}d}|||}d}|d||\}}|dk}|r|jdddn|jddd}i} |rt |jdzd | d <i| d <|d | |} | ||| | ||| | |dS) 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,r7r6rr8rz unsub.tickersrrnzunsubscribe:ticker) rirrrjrrYrrhrrsrrr) r`rrnrrrjrrrrrss rbun_watch_tickerszmexc.un_watch_tickersOsu!!!!!!!!!%%gt44 &&w22   "[[--F99.&RXYY f&.17\dit$V,,di>Nt>TU[>\  7tw)VVWW W8!0GH  "GH   !5 6 6 6S!! C GV0L0Lm\\\ ##FM:::trcc2K|d{V||dddd}d}|t|jdz||}|d|d|\}}|dk}|st |jdzg}g}tdt|D][}|r9| ||} | d | d z| d ||z\|j d d d} d|d} | | } | | ||| |||| |dS)a7 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-rr7rrgrhunsubscribe:bidask:r6rrr)rirrrhrrrrrrjrrYrsrrr) r`rrnrrrrrrrjrrrss rbun_watch_bids_askszmexc.un_watch_bids_askss!!!!!!!!!%%gtT5$GG ?#DG.X$XYY Y**733!??QXYZQ[]cdd Fv% Ttw)RRSS S q#g,,'' E EA ^WQZ00 MPVW[P\\]]]  !6!C D D D Dit$V,&  S!! C GV0L0Lm\\\ ##FM:::trcchK|d{V||}|d}||jdi}|||}d|zdz|z}d}|drG|jddd}d |d zd z|z} d |d <|| ||n>|jddd}d} |d |d} || || |||} | | |gdS)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 NrdrTzunsubscribe:candles:rr7r6rrrhr Trr8z unsub.kliner ) rirjr rZrrYrkrlrsr) r`rdrrnrjrTrrorrprqrss rbun_watch_ohlcvzmexc.un_watch_ohlcvsg!!!!!!!!!V$$!__T\<DD &&z9== ,v5;iG  &> P)E"4(0C4vd|CcIKWG%)F> "  " "7K @ @ @ @)E"4(0C#G ,'##M  " "7K O O OS!! ##F[M:::trcc0K|d{V||}|d}d|z}d}|drd|jddd}d}||ddd \}}d |zd z|d z}d |d<||||n=|jddd}d}d|d i}|||||||} || |gdS)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 :param str [params.frequency]: the frequency of the order book updates, default is '10ms', can be '100ms' or '10ms :returns dict: A dictionary of `order book structures ` indexed by market symbols Nrdunsubscribe:orderbook:r7r6rr)r*r+r,r rhTrr8z unsub.depth)rirjrYr-rkrlrsr) r`rdrnrjrorr*rprqrss rbun_watch_order_bookzmexc.un_watch_order_booksR!!!!!!!!!V$$!.7  &> P)E"4(0CI $ = =fFVXcel m m Iv:YFLvVZ|[G%)F> "  " "7K @ @ @ @)E"4(0C#G&,#M  " "7K O O OS!! ##F[M:::trccK|d{V||}|d}d|z}d}|drA|jddd}d|dz}d |d <||||n=|jddd }d }d|di}|||||||}|||gdS) 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 ` Nrdunsubscribe:trades:r7r6rrlrhTrr8z unsub.dealrrs rbun_watch_tradeszmexc.un_watch_tradess!!!!!!!!!!V$$!+f4  &> P)E"4(0C@6$<OG%)F> "  " "7K @ @ @ @)E"4(0C"G&,#M  " "7K O O OS!! ##F[M:::trcrc*tdt|D]s}||}|dd}|||||ddkr|dd}|ddkrUt |j}tdt|D]}|j||=||jvr|j|=|ddkr)|dd}||jvr|j|=)|d dkrm| d } | | d }t| d kr|d | | d zz }||j vr|j |=|ddkr)|dd}||j vr|j |=|ddkr)|dd}||j vr|j |=3|ddkr'|dd}||jvr|j|=udS)Nrz unsubscribe:rrr unsubscriber`rcandlesrr2rOr.r rmr rr)rrreplaceclean_unsubscriptionfindrZrkeysrr3rrr5rmr) r`rsrrrosubMessageHashrdrrv splitHashess rbrzmexc.handle_unsubscriptionssq#m,,--# 2# 2A'*K(00DDN  % %fnk J J J))Q..$,,-BBGG;;}--22"4<#4#4#6#677G"1c'll3355 L445t|++ V,!!(++q00$,,-BBGGT]** f-!!),,11)//44 ))+q99{##a''cD$4$4[!$D$DDDFT[(( F+!!+..!33$,,-ErJJT_,,/!!(++q00$,,-BBGGT[(( F+!!-00A55$,,-GLLT...)&1G# 2# 2rcc0K||jd}||S||d{V}||d}||jd<||jdd}|||j|||S)NrUrRr9)rrZspotPrivatePostUserDataStreamrdelaykeep_alive_listen_key)r`subscriptionHashrnrUresponserRs rbrzmexc.authenticate,s$$T\;??   ;;FCCCCCCCC $$X{;; $- [!#00?UW^__ ')CYPVWWWrccK|dSd|i} ||||d{V||jdd}|||j||dS#t $rf}|jddddz|z}||}d|jd<| ||j |=Yd}~dSd}~wwxYw)NrUrRr9r6rr7r) spotPrivatePutUserDataStreamrrrZrrrOrYrsrPclients)r`rUrnrrRerrorrrss rbrzmexc.keep_alive_listen_key=s   F   "33DKK4P4PQQ Q Q Q Q Q Q Q#'#4#4T\CY[b#c#c JJ+T-GTZ [ [ [ [ [ " " ")E"4(0=@9LC[[%%F(,DL % MM%  S!!!!!!!  "sA(A66 C&AC!!C&c8||_|SN)rlastPong)r`rsrs rb handle_pongzmexc.handle_pongNs++--rccf||dd}|dkr|||dS|ddkr`|d}||d}|j|jd}|||}||||dSdSdS)Nr1rPONGr r?r>)public.increase.depth.v3.apipublic.aggre.depth.v3.api.pb)rr%rr3r7r )r`rsrr1r6rpmethodsrs rbhandle_subscription_statuszmexc.handle_subscription_statusRswr22 &==   VW - - - - - XXc]]R  IIcNNE&&ua00G040S040SG__Wg66F!vw''''' "!rcc||d}|d}||d}|dkr|||n|dkr|||n|dkr|||ns|dkr|||nV|dkr|||n9|d kr|||n|d kr|||d S) Nrpr r>zpublic.kline.v3.api.pbzpublic.aggre.deals.v3.api.pbz!public.aggre.bookTicker.v3.api.pbr)zprivate.account.v3.api.pbzprivate.deals.v3.api.pbzprivate.orders.v3.api.pbT) rr3rrxrrVrrr)r`rsrrp channelParts channelIds rbhandle_protobuf_messagezmexc.handle_protobuf_messagehsD&""7I66}}S)) $$\155 0 0 0   fg . . . . 8 8 8   vw / / / / = = =   vw / / / / 8 8 8  " "67 3 3 3 3 5 5 5    0 0 0 0 3 3 3   1 1 1 1 4 4 4   fg . . .trccrt|tr4|dkr.t|jdz}||dS||r-||}|||dSd|vr|||dS| |d}d}|| |d}n+| d}| |d}id|j d |j d |j d |j d |j d |j d|jd|j d|jd|jd|jd|jd|jd|jd|jd|jd|j|j|jd}||vr||}|||dSdS)NzInvalid listen keyz invalid listen keyr1rrpr r>zpublic.deals.v3.apiz push.dealzpublic.kline.v3.apiz push.klinezpublic.bookTicker.v3.apizpublic.miniTicker.v3.apizpublic.miniTickers.v3.apiz push.tickerz push.tickersr(z push.depthzprivate.orders.v3.apizpush.personal.orderzprivate.account.v3.apizpush.personal.assetzprivate.deals.v3.apizpush.personal.order.deal)pongzpush.funding.rate)rYrrrhrPis_binary_messagedecode_proto_msgr/r+rr3rxrrrrVrrrr%r) r`rsrr!rrpr6r*rs rbhandle_messagezmexc.handle_messagesf gs # # ...+DG6K,KLL e$$$  ! !' * * ++G44G  ( ( 9 9 9 F G    + +FG < < < F   Wc * * 9&&w ::GGGGCLLE&&ua00G !4#5 +  "4#4  $+  '(:  '(:   ()<  4-  D/  +D,B  $0  $T%6  "4#4  %d&9  "4#6 #D$8! " '(<# $$!%!9'   * g  W%F F67 # # # # #  rcc ddiS)NrrV)r`rss rbrVz mexc.pings &!!rcr#)G__name__ __module__ __qualname__rr_rr rrrrr rrrrrr}rrkrrlrrrrZrrrr r/r7rFrVrbrNrrnrxr r}rrtr rrrrrrrrrrrrrrrrrr r rrrr%r+r/r4rV __classcell__)ras@rbrrsD #D D D D D D L68]]]F]]]]4S,FS,S,S,S,j6:">E>E7>E>E>E>E>E@T&VT&T&T&T&l9999v8DDDD$?CQUdhqs H H H H3 H^a Hx|~ByC H H H HD\,6\,\,\,\,|8 8 D8 8 8 8 t@DB!!S!!S\!!!!>6V6666   a5a5a5a5a5F... 8 8 8<@d[]SSSSSSbfglbmSSSS>G,FG,G,G,G,R37TX\egUUCUsURUUlpqvlwUUUU@6:6:f6:6:6:6:pOOOOb04$UYbdUUUCUsUimnsitUUUUB\:6\:\:\:\:|eeeeN : : : : - - - = = =*,FFFFFF&58V58585858n<>YYsY+YYYY&?A#S01&1111(9;Cs89=R66g6C6666p;?r   c    DBFb33UXB=?3>9;Cs:$2V$2DI$2$2$2$2L;="=?"""""&(((((,$f$$$$L+$V+$+$+$+$Z"6""""""""rcr)ccxt.async_supportccxt ccxt.async_support.base.ws.cacherrrrccxt.base.typesrrrr r r r r rrr!ccxt.async_support.base.ws.clientrtypingrccxt.base.errorsrrr async_supportrr6rcrbrCs& ffffffffffssssssssssssssssssssssssss444444000000......))))))k"k"k"k"k"4  "k"k"k"k"k"rc