i_ddlZddlmZmZddlZddlmZmZm Z m Z m Z m Z ddl mZddlmZddlmZGddejjZdS) N) ArrayCacheArrayCacheBySymbolById)BalancesInt OrderBookStrTickerTrade)Client)List) NotSupportedc JeZdZfdZdZifdefdZdefdZdZ dZ ifd e de fd Z defd Zd d ifd e d ededeefdZdefdZd d d ifd ed ededeefdZdefdZd ifd e dedefdZdefdZdZdZdefdZdefdZdefdZdefdZifdZ xZ!S)exmoc |tt|dddddddddd dddddd iiiiid S) NTF) ws watchBalance watchTicker watchTickers watchTrades watchMyTrades watchOrderswatchOrderBook watchOHLCVapirz#wss://ws-api.exmo.com:443/v1/publicz$wss://ws-api.exmo.com:443/v1/privatez+wss://ws-api.exmo.com:443/v1/margin/private)publicspotmargin)hasurlsoptions streaming exceptions) deep_extendsuperrdescribe)self __class__s S/var/www/html/crypto-bot/backend/venv/lib/python3.11/site-packages/ccxt/pro/exmo.pyr%z exmo.describesdD 1 1 : : < < $# %#!%$"&#  "G F"O3? ?    cz|||jddd}||jd<|S)N requestIdr)sum safe_integerr )r&r+s r( request_idzexmo.request_id/s;HHT..t|[!LLaPP $- [!r)returncNK||d{V|dd|\}}d|z}|jdd|}d|dzg|d}|||}||||||d{VS) a watch balance and get the amount of funds available for trading or funds locked in orders :param dict [params]: extra parameters specific to the exchange API endpoint :returns dict: a `balance structure ` Nrbalance:rr subscribez/walletmethodtopicsid) authenticatehandle_market_type_and_paramsrr/r#watch)r&paramstypequery messageHashurlr3requests r( watch_balancezexmo.watch_balance4s '''''''''88vVV e 4' it$T*!i'(//##  ""9e44ZZ[';PPPPPPPPPr)clientc6||d}|d}||d}|dkr||n|dkr||d|z}||j|dS)Ntopic/rrrr2) safe_stringsplitparse_spot_balanceparse_margin_balanceresolvebalance)r&rBmessagerDpartsr<r>s r(handle_balancezexmo.handle_balanceFsh  '22 C  q)) 6>>  # #G , , , , X    % %g . . . 4' t|[11111r)cx||d}||d}||jd<|dkr||di}||di}t|}t dt |D]o}||}||} |} |||| d<|||| d <| |j| <pn|d kr{||d }||} |} ||d | d<||d| d <| |j| <| |j|_dS) NeventdatainfosnapshotbalancesreservedrfreeusedupdatecurrencyrK) rF safe_valuerKlistkeysrangelensafe_currency_codeaccount safe_balance) r&rLrPrQrTrU currenciesi currencyIdcoder`s r(rHzexmo.parse_spot_balances  '22w//# V J  tZ<||d}||jd<t|}t dt |D]}||}||}|||}|}||d|d<||d|d<||d|d<||j|<| |j|_dS)NrQrRrrVrWrKtotal) rZrKr[r\r]r^r_r`rFra) r&rLrQrbrcrdrewalletr`s r(rIzexmo.parse_margin_balancesw//# V$))++&& q#j//** ; ;A#AJ**:66D__T:66FllnnG"..vv>>GFO"..vv>>GFO#// BBGG !(DL ,,T\::DLL ; ;r)symbolc^K|d{V||}|d}|jddd}d|z}dd|d zg|d }|||}||||||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 ` Nrirrrticker:r3z spot/ticker:r7r4) load_marketsmarketrr/r#r:)r&rir;rmr?r>rLr@s r( watch_tickerzexmo.watch_tickers!!!!!!!!!V$$!it$X.&( !-//##   ""7F33ZZ[';PPPPPPPPPr)c||d}|d}||d}||}||di}||}|||} d|z} | |j|<|| | dS)NrD:r,rQrk)rFrG safe_symbolrZ safe_market parse_tickertickersrJ) r&rBrLrD topicPartsmarketIdritickerrm parsedTickerr>s r( handle_tickerzexmo.handle_tickers(  '22[[%% ##J22!!(++&"55!!(++((88 &( + V|[11111r)NsincelimitcK|d{V||}|d}|jddd}d|z}dd|d zg|d }|||} |||| || d{V} || ||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 ` Nrirrrtrades:r3z spot/trades:r7r4 timestampT)rlrmrr/r#r:filter_by_since_limit) r&rirzr{r;rmr?r>rLr@tradess r( watch_tradeszexmo.watch_tradess!!!!!!!!!V$$!it$X.&( !-//##   ""7F33zz#{G['RRRRRRRR))&% TRRRr)c||d}|d}||d}||}||}||dg}d|z} ||j|} | 5||jdd} t| } | |j|<tdt|D]5} || } | | |}| |6| |j|<| |j|| dS) NrDrpr,rQr} tradesLimitr)rFrGrqrrrZrr.r rr]r^ parse_tradeappendrJ)r&rBrLrDrMrvrirmrr>storedr{rctradeparseds r( handle_tradeszexmo.handle_tradessO   '22 C  ##E1--!!(++!!(++&"55&( f55 >%%dlM4HHE&&F"(DK q#f++&& " "A1IE%%eV44F MM& ! ! ! !$ Ft{6*K88888r)cK|d{V||d{V|dd|\}}|jdd|}d}|d|z}n(||} | d}d| dz}d|dzg|d } || |} |||| || d{V} || |||d S) a get the list of trades associated with the user :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 ` Nrrr myTrades:rir3z /user_tradesr4T) rlr8r9rrmr/r#r:filter_by_symbol_since_limit) r&rirzr{r;r<r=r?r>rmrLr@rs r(watch_my_tradeszexmo.watch_my_trades8sM!!!!!!!!!'''''''''88$PVWW eit$T* >%,KK[[((FH%F%x(88K!~%//##   ""7E22zz#{G['RRRRRRRR00tTTTr)cv||d}|d}||d}d|z}||d}g}d} |j3||jdd} t | } | |_n|j} |dkr||d g}n |d kr||d i} | g}||} i} tdt| D]*}| |}| |d | |d <+t| }tdt|D]%}||}d|z}| | |&| | |dS) NrDrErrrPrrrSrQrXTri)rFrGmyTradesr.r rrZ parse_tradesr]r^rr[r\rJ)r&rBrLrDrMr<r>rP rawTradesrr{rawTradersymbolsjr symbolKeysrcrisymbolSpecificMessageHashs r(handle_my_tradeszexmo.handle_my_tradesWst  '22 C  q))!D(   '22  = %%dlM4HHE-e44H$DMM}H J  < ? ? ? ?x-----r)cK|d{V||}|d}|jddd}d|z}||d}d|d |d zgd }|||}|||||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 Nrirrr orderbook: aggregationr3zspot/order_book_updates:r7)r5r7r6)rlrmromitr/r#r:r{) r&rir{r;rmr?r>r3r@ orderbooks r(watch_order_bookzexmo.watch_order_books!!!!!!!!!V$$!it$X."V+ 6=11!//##*VD\9  ""9f55**S+w LLLLLLLL    r)cV||d}|d}||d}||}||di}d|z}||d} ||j|} | |i} | |j|<||d} | dkr/|||| d d } | | n||d g} ||d g}| | d | | | d || | d <| | | d<| | |dS)NrDrpr,rQrtsrPrSbidaskasksbidsr~datetime) rFrGrqrZr. orderbooks order_bookparse_order_bookreset handle_deltasiso8601rJ)r&rBrLrDrMrvri orderBookr>r~rrPrSrrs r(handle_order_bookzexmo.handle_order_booksD  '22 C  ##E1--!!(++OOGVR88 "V+ %%gt44 OODOV<<  ++I&/DOF #  '22 J  ,,Y 5RWXXH OOH % % % %??9eR88D??9eR88D   y0$ 7 7 7   y0$ 7 7 7%.Ik "$(LL$;$;Ij !y+.....r)c^||dd}||dS)Nrr,) parse_bid_ask storeArray)r&booksidedeltabidAsks r( handle_deltazexmo.handle_deltas3##E1a00F#####r)c~tdt|D]}||||dS)Nr)r]r^r)r&rdeltasrcs r(rzexmo.handle_deltassHq#f++&& 3 3A   hq 2 2 2 2 3 3r)c Z||d}|j|j|jd}|||}||||dS|dks|dkr||d}||d}||d}|j|j|j|j|j|j|j |j |j d } || |} | | ||dSt|j d z| |z) NrP) logged_inrR subscribedrXrSrDrpr) z spot/tickerz spot/walletz margin/walletzmargin/walletsz spot/tradesz margin/tradeszspot/order_book_updateszspot/user_tradeszmargin/user_tradesz" received an unsupported message: )rFhandle_authentication_message handle_infohandle_subscribedrZrGryrNrrrr r7json) r&rBrLrPevents eventHandlerrDrMchannelhandlershandlers r(handle_messagezexmo.handle_message s]   '22;$0   vu55  # L ) ) ) F X  5J#6#6$$Wg66E  C((**5!44#'#5#'#6%)%8&*&9#'#5%)%7/3/E)-(=*.*?  //(G<<&GFG,,,F47%IIDIIV]L^L^^___r)c|SNr&rBrLs r(rzexmo.handle_subscribed=s r)c|Srrrs r(rzexmo.handle_infoGs r)c6d}|||dS)N authenticated)rJ)r&rBrLr>s r(rz"exmo.handle_authentication_messageSs#& w ,,,,,r)cKd}|dd|\}}|jdd|}||}||j|}||}||} |jt|z} | | | | |j tjd} d| |j| |d} || |} |||| |d{V}||j|<|S)Nrr8rrbase64login)r5r7api_keysignnonce)r9rrBrZ subscriptions millisecondscheck_required_credentialsr/apiKeystrhmacencodesecrethashlibsha512extendr:)r&r;r>r<r=r?rBfuturetimer+signDatarr@rLs r(r8zexmo.authenticate`sM% 88vVV eit$T*S!!!5{CC >$$&&D  + + - - -))I{SYY.H99T[[22DKK 4L4Lgn^fggD!; Gkk'511G::c;MMMMMMMMF06F  - r))"__name__ __module__ __qualname__r%r/rrAr rNrHrIrr rnryrr r rrrrrrrrrrrrrrr8 __classcell__)r's@r(rrs     < *,QQQQQQ$<2V<2<2<2<2|$7$7$7L;;;:68QQQFQQQQ,2F2222><@d[]SSSSSSbfglbmSSSS2!9F!9!9!9!9F37TX\egUUCUsURUUlpqvlwUUUU>W.vW.W.W.W.r@DB!!S!!S\!!!!28/8/8/8/8/t$$$3330`V0`0`0`0`d &     -F - - - -)+r)r)ccxt.async_supportccxt ccxt.async_support.base.ws.cacherrrccxt.base.typesrrrrr r !ccxt.async_support.base.ws.clientr typingr ccxt.base.errorsr async_supportrrr)r(rs OOOOOOOOHHHHHHHHHHHHHHHH444444))))))g g g g g 4  "g g g g g r)