i7ddlZddlmZmZmZddlZddlmZm Z m Z m Z m Z m Z mZddlmZddlmZddlmZGddejjZdS) N) ArrayCacheArrayCacheBySymbolByIdArrayCacheByTimestamp)BalancesIntOrder OrderBookStrTickerTrade)Client)List)AuthenticationErrorc &eZdZfdZifdedefdZdefdZd,dZ ifd Z ifd Z ifd Z ifd Z d ddifdedededeefdZdefdZd,defdZdifdededefdZdefdZdZdefdZdZdZddifdedededeefdZdefdZdddifdedededeefdZd,defdZ d,dZ!dddifdedededee"fdZ#defdZ$d,d Z%d,d!Z&d"Z'd#Z(ifde)fd$Z*defd%Z+ifd&Z,ifd'Z-defd(Z.defd)Z/defd*Z0d+Z1xZ2S)-mexcc8|tt|iddddddddddddd dd dd dd dd dddddddddddddddidddddiidddddddd d!d"d#d$ d%d&d'dd(|jd)d*id+S),NwsTcancelAllOrdersWsFcancelOrdersWs cancelOrderWs createOrderWs editOrderWsfetchBalanceWsfetchOpenOrdersWs fetchOrderWs fetchTradesWs watchBalance watchMyTrades watchOHLCVwatchOrderBook watchOrders watchTicker watchTickers watchTradesapizwss://wbs.mexc.com/wszwss://contract.mexc.com/ws)spotswapOMin1Min5Min15Min30Min60Hour4Hour8Day1Week1Month1) 1m5m15m30m1h4h8h1d1w1M) snapshotDelaysnapshotMaxRetries)listenKeyRefreshRate timeframesr listenKeyi')ping keepAlive)hasurlsoptions streaming exceptions) deep_extendsuperrdescriberD)self __class__s S/var/www/html/crypto-bot/backend/venv/lib/python3.11/site-packages/ccxt/pro/mexc.pyrMz mexc.describesdD 1 1 : : < <d#U!%      u !%$U  d!$t t!"#$t%* 7 <)0! ""!!! !"  &(*+##"', "m8? 8? 8 8 8 symbolreturnc.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 :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 ` Nticker:rRr&zspot@public.bookTicker.v3.api@idz sub.ticker) load_marketsmarketwatch_spot_publicwatch_swap_public)rNrRparamsrX messageHashchannel requestParamss rP watch_tickerzmexc.watch_tickerLs!!!!!!!!!V$$&"22 &> ]6EG//fMMMMMMMM M"G&,M//mU[\\\\\\\\ \rQclientc||dd}||dd}||d}||}|d}d}|dr4|||}||d<|||d<n|||}||j|<d |z} ||| dS) NddatasrRtr& timestampdatetimerU) safe_value_2 safe_string_2 safe_integer safe_marketparse_ws_tickeriso8601 parse_tickertickersresolve) rNr`message rawTickermarketIdrfrXrRtickerr\s rP handle_tickerzmexc.handle_ticker`s%%gsF;; %%gsH==%%gs33 !!(++! &> :)))V< ^1F4L@3FTG00+vNNNNNNNNEE!G ,'M00+}V\]]]]]]]]E ? 2NN6511E))%q$GGGrQc||ddi}||d|}||dd}||jdi}|||}||dd}||} | d} d | zd z|z} ||| } ||j| i|j| <||j| |} | ;||jd d }t|} | |j| |<| | | | | dS) NrbrckirrBrdrRrr OHLCVLimit) rhrrirHfind_timeframerkparse_ws_ohlcvohlcvsrjrappendrp)rNr`rqrbrawOhlcvrrBrrsrXrRr\parsedstoredrs rP handle_ohlcvzmexc.handle_ohlcvss^   gsFB 7 7??1c1--((3 CC __T\<DD '' Z@@ %%gsH==!!(++! 6)C/); $$Xv66"oodk62FF FV!4i@@ >%%dlL$GGE*511F-3DK  * fv{+++++rQc ||d||d||d||d||d||ddgS)Nreohlcvq)safe_timestampr safe_number_2)rNrrXs rPrzmexc.parse_ws_ohlcv-sD   s + +   UC ( (   UC ( (   UC ( (   UC ( (   uc3 / /   rQc`K|d{V||}|d}d|z}d}|dr)d|dz}||||d{V}n*d}d|di}|||||d{V}|S)aD :see: https://mxcdevelop.github.io/apidocs/spot_v3_en/#diff-depth-stream 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 NrR orderbook:r&z"spot@public.increase.depth.v3.api@rVz sub.depth)rWrXrYrZr) rNrRrr[rXr\ orderbookr]r^s rPwatch_order_bookzmexc.watch_order_bookWs!!!!!!!!!V$$!"V+  &> b:VD\IG"44Wk6RRRRRRRRII!G&,M#44Wk=Z`aaaaaaaaI   rQc||d}|d}||d}||}|i|j|<dS)Nmsgr)rsplitr order_book orderbooks)rNr`rqrpartsrsrRs rPhandle_order_book_subscriptionz#mexc.handle_order_book_subscriptionpsnw.. ###E1--!!(++"&//""5"5rQcN||d}||d}||dd}||dz krdStdt |D]+}||}||dd}||kr|cS,t |S)Nnoncerrversion)rjrsafe_integer_2rangelen) rNrcacher firstDeltafirstDeltaNoncerdelta deltaNonces rPget_cache_indexzmexc.get_cache_indexzs!!)W55__UA.. --j#yII ?Q& & &2q#e**%%  A!HE,,UCCCJU""#5zzrQc||dd}||dd}||}d|z}||j|}||d}|dur'd|j|<|i|j|<|j|} || d } | lt| j } | d d d } | | kr| |j ||||i| j |dS || |||d d} | | d<|| | d<n5#t"$r(}|j|=|||Yd}~nd}~wwxYw|| |dS)NrbrcrdrRrrTrrr r?r=retsrfrg)rhrirr subscriptionsrjcounted_order_bookrrr handle_optionspawnload_order_bookr handle_deltarrm Exceptionrejectrp)rNr`rqrcrsrRr\ subscriptionrstoredOrderBookr cacheLengthr?rfes rPhandle_order_bookzmexc.handle_order_booksX  #v66%%gsH==!!(++"V+ v';[II !!,88 4  12F  -&*&=&=b&A&ADOF #/&1!!/7;; =o344K ../?RTUUMm++ 4/feUWXXX  ! ( ( . . . F *   ot 4 4 4++GS$??I+4OK (*.,,y*A*AOJ ' ' * * *$[1 MM![ ) ) ) ) ) ) ) ) *  44444s7A F F4 F//F4c0tdt|D]w}||}t|tr||5||d}||d}|||xdS)Nrpr)rr isinstancelist storeArray safe_floatstore)rNbooksidebidasksrbidaskpriceamounts rPhandle_bookside_deltazmexc.handle_bookside_deltasq#g,,'' . .AQZF&$'' .##F++++4455uf---- . .rQcN||d}||dd}||krdS||d<||dg}||dg}|d}|d}||||||dS)Nrrrasksbids)rjrrr) rNrr existingNoncerr r  asksOrderSide bidsOrderSides rPrzmexc.handle_deltas)))W== ((Y??  % % F' 'ufb11ufb11!&) !&)  ""=$777 ""=$77777rQcK|d{V||}|d}d|z}d}|dr)d|dz}||||d{V}n*d}d|di} |||| |d{V}|jr|||}||||dd S) a) :see: https://mxcdevelop.github.io/apidocs/spot_v3_en/#trade-streams 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 ` NrRtrades:r&zspot@public.deals.v3.api@rVzsub.dealrfT)rWrXrYrZrrr) rNrRrrr[rXr\tradesr]r^s rP watch_tradeszmexc.watch_tradess!!!!!!!!!V$$!&(  &> _1F4L@G11';OOOOOOOOFF G&,M 11'; W]^^^^^^^^F ? 3OOFE22E))&% TRRRrQc||dd}||}|d}d|z}||j|}|5||jdd}t |}||j|<||dd} || d| g} td t| D]Z} d} |d r| | | |} n| | | |} | | [| ||dS) NrdrRr tradesLimitrrbrcdealsrr&)rirkrrrjrHrrhrrparse_ws_trade parse_traderrp) rNr`rqrsrXrRr\rrrbrj parsedTrades rP handle_tradeszmexc.handle_trades sQ@%%gsH==!!(++!&( f55 >%%dlM4HHE&&F"(DK    gsF 3 3GaS11q#f++&& ' 'AKf~ B"11&)VDD "..vay&AA MM+ & & & &v{+++++rQcK|d{Vd}d}|%||}|d}|dz|z}d}|d||\}}d}|dkr d} || ||d{V}n|||d{V}|jr|||}|||||dS) aB :see: https://mxcdevelop.github.io/apidocs/spot_v3_en/#spot-account-deals 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]{@link https://docs.ccxt.com/#/?id=trade-structure NmyTradesrRrrr&zspot@private.deals.v3.apiT)rWrXhandle_market_type_and_paramsrrrrfilter_by_symbol_since_limit) rNrRrrr[r\rXtyperr]s rPwatch_my_tradeszmexc.watch_my_tradesAs%!!!!!!!!!   [[((FH%F%+f4K99/6SYZZ f 6>>1G227KPPPPPPPPFF22;GGGGGGGGF ? 3OOFE22E00tTTTrQcBd}||dd}||d}||d|}||}|d} d} |dr|||} n|||} |j} | 2||jdd} t| } | |_| | | | ||d z| z} | | | dS) NrrbrcrRrdr&rrr) rhrrkrrrrjrHrrrp)rNr`rqrr\rcfuturesMarketIdrsrXrRtraderrsymbolSpecificMessageHashs rPhandle_my_tradezmexc.handle_my_trade^s0&!   #v66**4::##GS/BB!!(++! &> 3''f55EE$$T622E >%%dlM4HHE+E22F"DM ev{+++$/#$5$>!v899999rQc||d}||d}|||d}d}||d}||d}||d}|dkrdnd}||d } |||||d ||||d|d|| rd nd ||ddd |S)NTrerrS1buysellmrmakertaker) rrVorderrfrgrRrside takerOrMakerrrcostfee)rjr safe_tradermr) rNr#rXrftradeId priceString amountStringrawSider0isMakers rPrzmexc.parse_ws_trades4,%%eS11 ""5#..  ))%55IG&&uc22 ''s33 ""5#.. Cuuf##E3//%%eS11" Y//&&tV44(/=GGg "    rQcK|d{V||d}d}d}|%||}|d}|dz|z}d}|d||\}}d}|dkr#|dz} || ||d{V}n|||d{V}|jr|||}|||||d S) a :see: https://mxcdevelop.github.io/apidocs/spot_v3_en/#spot-account-orders :see: https://mxcdevelop.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 ` NrordersrRrr!r&z@private.orders.v3.apiT) rWomitrXrrrrrr) rNrRrrr[r\rXrr;r]s rP watch_orderszmexc.watch_orderss>!!!!!!!!!66**   [[((FH%F%+f4K99-QWXX f 6>>55G227KPPPPPPPPFF22;GGGGGGGGF ? 3OOFE22E00tTTTrQcBd}||dd}||d}||d|}||}|d}d} |dr|||} n|||} |j} | 2||jdd} t| } | |_| | | | ||d z|z} | | | dS) Nr;rbrcrRrdr& ordersLimitrr) rhrrkparse_ws_order parse_orderr;rjrHrrrp) rNr`rqr\rcr"rsrXrRrr;rr$s rP handle_orderzmexc.handle_orders1D   #v66**4::##GS/BB!!(++! &> 4((v66FF%%dF33F >%%dlM4HHE+E22F DK fv{+++$/#$5$>!v899999rQc||d}||d}||d}||d}d}||d}||dd}|id||dd ||d d |d ||d dd|||d|d|d||d||d|dkrdndd||dddd||dd||dd||dd||d d!||d"||d#|d|d$|S)%NOr(rdrN)currencyr2rVr clientOrderIdrrfrglastTradeTimestampstatusrRr timeInForcer0r)r*r+rr stopPrice triggerPricePraprrr2rfilledcvV) remainingr3rr) rjr safe_orderrmparse_ws_order_statusrparse_ws_order_typeparse_ws_time_in_forcer) rNr/rXrfr0rIrr3 feeCurrencys rPr@zmexc.parse_ws_order-svf%%eS11 s++!!%--s++&&uc22  "'C $""5#.. T--eS99     Y//  !$  d00@@   d&&tV44  D,,T22  466t<<  dckkEE  T%%eS11    D,,UC88  t''t44  d&&uc22 D$$UC00! " d&&ud33# $))%55+   , - rQc Jddddddddddd }||||S)Nrwclosedcanceledrejected) r)23456NEWCANCELEDEXECUTEDFAILEDr)rNrIrXstatusess rPrTzmexc.parse_ws_order_statussF"     &&999rQc@ddddddd}|||S)NrrXr)r\r]r^r_100re)rNrtypess rPrUzmexc.parse_ws_order_types8   t,,,rQc@ddddddd}|||S)NGTCPOIOCFOKrhre)rNrJtimeInForceIdss rPrVzmexc.parse_ws_time_in_forces8    <<` Nrbalance:r&zspot@private.account.v3.api)rWrrr)rNr[rr\r]s rP watch_balancezmexc.watch_balances!!!!!!!!!99.$PVWW f 4' 6>>3G00+vNNNNNNNN N00fEEEEEEEE ErQc||d}|dnd}d|z}||dd}||d}||d|}||jvr i|j|<||j|d<||j|d <|||j|d <||d d } || } |} ||d d| d<||dd| d<| |j|| <||j||j|<| |j||dS)Nrr'r&rrrbrcrrrfrgrrFfavailableBalancefreer frozenBalanceused) rrhrjbalancermrisafe_currency_codeaccount safe_balancerp) rNr`rqrrr\rcfuturesTimestamprf currencyIdcoder|s rPhandle_balancezmexc.handle_balances@   Wc * *)vv& 4'   #v66,,Wd;;%%dC1ABB  $$!#DL %) T6"*3 T;')-i)@)@ T:&''c:>> &&z22,,..,,T38JKK,,T3HH#* T4 !..t|D/ABB Tt|D);77777rQc0K||jd}||S||d{V}||d}||jd<||jdd}|||j|||S)NrCrAr()rrHspotPrivatePostUserDataStreamrjdelaykeep_alive_listen_key)rNsubscriptionHashr[rCresponserAs rPrzmexc.authenticates$$T\;??   ;;FCCCCCCCC $$X{;; $- [!#00?UW^__ ')CYPVWWWrQcK|dSd|i} ||||d{V||jdd}|||j||dS#t $rf}|jddddz|z}||}d|jd<| ||j |=Yd}~dSd}~wwxYw)NrCrAr(r%rr&r) spotPrivatePutUserDataStreamrrjrHrrrrGr`rclients)rNrCr[rrAerrorrr`s rPrzmexc.keep_alive_listen_keys   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)rNr`rqs rP handle_pongzmexc.handle_pongs++--rQcX||d}|dkr|||dS|ddkrZ|d}||d}d|ji}|||}||||dSdSdS)NrPONGrrrpublic.increase.depth.v3.api)rrfindrrr)rNr`rqrrr]methodsrs rPhandle_subscription_statuszmexc.handle_subscription_statussw.. &==   VW - - - - - XXc]]R  IIcNNE&&ua00G.0SG__Wg66F!vw''''' "!rQcvt|tr4|dkr,t|jdz}||dSd|vr|||dS||d}d}|||d}n+|d}||d}|j|j|j |j |j |j |j |j |j |j |j |j |j|j|jd}||vr||}|||dSdS) NzInvalid listen keyz invalid listen keyrrr]rr)zpublic.deals.v3.apiz push.dealzpublic.kline.v3.apiz push.klinezpublic.bookTicker.v3.apiz push.tickerrz push.depthzprivate.orders.v3.apizpush.personal.orderzprivate.account.v3.apizpush.personal.assetzprivate.deals.v3.apizpush.personal.order.dealpong)rrrrVrrrrrrrurrBrr%r) rNr`rqrrr]rrrs rPhandle_messagezmexc.handle_message(si gs # # ...+DG6K,KLL e$$$ F G    + +FG < < < F   Wc * * 9&&w ::GGGGCLLE&&ua00G#'#5+#'#4+(,(:-,0,B0%)%6#'#4&*&9#'#6$($8(,(<$  " g  W%F F67 # # # # #  rQc ddiS)NrrD)rNr`s rPrDz mexc.pingMs &!!rQr)3__name__ __module__ __qualname__rMrr r_r rurlrYrrZrrrrrrrr rrrrrrr rrr r r%rrr=rBr@rTrUrVrrsrrrrrrrD __classcell__)rOs@rPrrs9 9 9 9 9 v68]]]F]]]](,F,,,,<@DFYYYYEGYYYYSUHHHH<>DDDD$8<$]ajlHHHCHWZHquvzq{HHHH@@,6@,@,@,@,D( ( D( ( ( ( T@DB!!S!!S\!!!!26V6666   H5H5H5H5H5T... 8 8 8<@d[]SSSSSSbfglbmSSSS82,F2,2,2,2,h37TX\egUUCUsURUUlpqvlwUUUU:&:&:f&:&:&:&:P....`04$UYbdUUUCUsUimnsitUUUU@U:6U:U:U:U:nTTTTl : : : : - - - = = =*,FFFFFF"28V28282828h;="=?"""""&(((((*#$V#$#$#$#$J"""""""rQr)ccxt.async_supportccxt ccxt.async_support.base.ws.cacherrrrccxt.base.typesrrrr r r r !ccxt.async_support.base.ws.clientr typingrccxt.base.errorsr async_supportrrrQrPrs ffffffffffOOOOOOOOOOOOOOOOOO444444000000"""""4  """"""rQ