iSWddlZddlmZmZddlZddlmZmZm Z m Z m Z ddl m Z ddlmZddlmZGddejjZdS) N) ArrayCacheArrayCacheByTimestamp)BalancesInt OrderBookTickerTrade)Client)List)Precisec @eZdZfdZdZdefdZdefdZdefdZddZ defd Z dd Z defd Z d Z ifd ZifdZifdefdZifdedefdZddifdedededeefdZdifdededefdZdddifdedededeefdZdZdefdZdefdZxZ S) currencycomc|tt|dddddddddddiidddd d d d d dddd d|jdddS)NTF)ws watchBalance watchTicker watchTickers watchTradeswatchOrderBook watchOHLCVapirz.wss://api-adapter.backend.currency.com/connectM1M3M5M15M30H1H4D1W1) 1m3m5m15m30m1h4h1d1w) tradesLimit OHLCVLimit timeframesi N)ping keepAlive)hasurlsoptions streaming) deep_extendsuperrdescriber.)self __class__s Z/var/www/html/crypto-bot/backend/venv/lib/python3.11/site-packages/ccxt/pro/currencycom.pyr6zcurrencycom.describesk4 8 8 A A C C $# %#"&#  J $"     & " C'F 'F ' ' ' cPt|}d|idS)Nr. destination correlationIdpayload)str request_id)r7client requestIds r9r.zcurrencycom.ping;s1))** !&   r:rBc8||_|SN) millisecondslastPong)r7rBmessages r9 handle_pongzcurrencycom.handle_pongDs++--r:c$||d}||}||j||_||d}||j|||jvr |j|=dSdS)Nr? messageHash) safe_value parse_balanceextendbalance safe_stringresolve subscriptions)r7rBrH subscriptionr?rOrKs r9handle_balancezcurrencycom.handle_balanceHsF//'955$$W--{{4<99 &&|]CC t|[111 &. . .$[111 / .r:c\d}||d}||dg}tdt|D]^}|||}|d} ||j| <|dz| z} ||| | |jvr|j| =_dS)N/api/v1/ticker/24hrr?tickersrsymbol:)rLrangelen parse_tickerrWrQrR) r7rBrHrSr=r?rWitickerrXrKs r9 handle_tickerzcurrencycom.handle_tickerss:, //'955//'9b99q#g,,'' 6 6A&&wqz22FH%F#)DL %+f4K NN6; / / /f222(5 6 6r:NcZ||d}||dd}||d}||d}||d}|t j||}||} ||} ||d} ||d} ||d} | rd nd }|||||| | dd|| | |dd S) NrX/tspricesizeidorderIdbuyerbuysell) info timestampdatetimerXreordertype takerOrMakersidercamountcostfee)rP safe_symbol safe_integer parse_numberr string_mulrLiso8601)r7trademarketmarketIdrXrk priceString amountStringrrrcrqrerfrgrps r9 handle_tradezcurrencycom.handle_tradesB##E844!!(D#66%%eT22 &&ug66 ''v66   !3K!N!NOO!!+..""<00   eT * *""5)44w//)uu6" Y//    r:cz||d}||}|d}d}|dz|z}||j|}|5||jdd} t | }||j|<|||||dS)Nr?rXtrades.subscriberYr+r)rLr~tradesrur2rappendrQ) r7rBrHr?parsedrXr=rKstoredlimits r9 handle_tradeszcurrencycom.handle_tradess"//'955""7++!( !C'&0 f55 >%%dlM4HHE&&F"(DK  fv{+++++r:c||jd|}t|}t dt |D]}||}|||kr|cSdS)Nr-r)rLr2listkeysrZr[)r7 timeframedefaultTimeframesr-rr]keys r9find_timeframezcurrencycom.find_timeframes{__T\%%dlL$GGE*511F-3DK  * fv{+++++r:cz|||jddd}||jd<|S)Nr>r)sumrur2)r7reqids r9rAzcurrencycom.request_ids:**4<!LLaPP(- _% r:cK|d{V||}|d}|dz|z}|jdd}t|}|||d|dgid|}||||d} |||||| d{VS) NrXrYrrsymbolsrer<rKrX load_marketsrzr1r@rAr4rNwatch) r7r=rXparamsrzrKurlrCrequestrSs r9 watch_publiczcurrencycom.watch_publics !!!!!!!!!V$$!!C'&0 it$))** ""&&F4L>$ $  {{7&- -   ZZ['; UUUUUUUUUr:czK|d{Vd}|jdd}t|}||jd}|||}||||d|}| | || |j tj |dd<||d|i} |||||| d{VS) N/api/v1/accountrr)rkapiKeyr<r? signaturerK)rr1r@rArFr urlencodekeysortr4hmacencodesecrethashlibsha256rNr) r7r=rrKrrCr?authrrSs r9 watch_privatezcurrencycom.watch_private0sQ!!!!!!!!!' it$))** **,,k  ~~dll73344""&&$ $    +/))DKK4E4Et{{SWS^G_G_ahao*p*p ;'{{7 ;-   ZZ['; UUUUUUUUUr:returncrK|d{V|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 ` Nr)rr)r7rs r9 watch_balancezcurrencycom.watch_balanceEsU !!!!!!!!!''(96BBBBBBBBBr:rXcK|d{V||}|d}d}|dz|z}|jdd}t|}|||d|did|}||||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 ` NrXrVrYrrrer<rr) r7rXrrzr=rKrrCrrSs r9 watch_tickerzcurrencycom.watch_tickerNs!!!!!!!!!V$$!+ !C'&0 it$))** ""&&&,$ $  {{7&- -   ZZ['; UUUUUUUUUr:sincerc K|d{V||}|d||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 ` NrrkT)rrXr newUpdatesgetLimitfilter_by_since_limit)r7rXrrrrs r9 watch_tradeszcurrencycom.watch_tradesis!!!!!!!!!V$$(();VVLLLLLLLL ? 3OOFE22E))&% TRRRr:cK|d{V||}|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 NdepthMarketData.subscribe)rrXrr)r7rXrr orderbooks r9watch_order_bookzcurrencycom.watch_order_bookysx!!!!!!!!!V$$++,GQWXXXXXXXX    r:r"cK|d{V||}d}|dz|z}||jd}|d||gid} ||||| |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 NrrYr- intervals)r=r?rT) rrXrLr2rrNrrr) r7rXrrrrr=rKr-rohlcvs r9 watch_ohlcvzcurrencycom.watch_ohlcvs!!!!!!!!!V$$0 !C')3 __T\<@@ &y)  '' VT[[RX=Y=YZZZZZZZZ ? 2NN6511E))%q$GGGr:ct|}tdt|D]B}||}||}|t |t |CdS)Nr)rrrZr[storefloat)r7booksidedeltaspricesr]rcrqs r9 handle_deltaszcurrencycom.handle_deltassufkkmm$$q#f++&& 8 8A1IEE]F NN5<<v 7 7 7 7 8 8r:c||di}||di}||d}||dd}d}|dz|z}||d} ||j|} | |} | || || d||d i} ||d i} || d | || d | | |j|<| | |dS) Nr?datarXrarrYrb)rXrkrlbidofrbidsasks) rLrPrtru orderbooks order_bookresetrxrrQ) r7rBrHr?rr{rXr=rKrkrrrs r9handle_order_bookzcurrencycom.handle_order_booksj//'9b99w33##GX66!!(D#661 !C'&0 %%dD11 OODOV<<  ))I" Y//     tUB//tUB// 9V,d333 9V,d333"+y+.....r:c*||d}|||jd}||d}|||}|V|dkrP||d}|8|j|jd}|||} | dS| |||dS||d} | A|j|j|j|j d}||| } | | ||dSdSdS)Nr>statusOKr=)rVr)zmarketdepth.eventzinternal.tradez ohlc.eventr.) rPindex_byrRrLr_rTrrrrI) r7rBrHrCsubscriptionsByIdrrSsubscriptionDestinationmethodsmethodr=s r9handle_messagezcurrencycom.handle_messages^^$$Wo>>  $ f.BO T T %%gx88F??+>.2.>.>|].[.[+.:373E/3/B##"&:Q!R!R!>"F"F67LAAA"F&&w >>  "%)%;"&"4"/( G __Wk::F!vw''''' # ""!r:rE)!__name__ __module__ __qualname__r6r.r rIrTr_r~rrrrArrrrr@rrrr r rrrrrrrr __classcell__)r8s@r9rrs( ( ( ( ( T   &)2V)2)2)2)2V'6F'6'6'6'6R' ' ' ' R,F,,,,>(,6(,(,(,(,T >@VVVV(79VVVV**,CCCCCC68VVVFVVVV6<@d[]SSSSSSbfglbmSSSS @DB ! !S ! !S\ ! ! ! !8<$]ajlHHHCHWZHquvzq{HHHH8888 / / / / /DL(VL(L(L(L(L(L(L(L(r:r)ccxt.async_supportccxt ccxt.async_support.base.ws.cacherrrccxt.base.typesrrrrr !ccxt.async_support.base.ws.clientr typingr ccxt.base.preciser async_supportrr:r9rs NNNNNNNNCCCCCCCCCCCCCC444444%%%%%%H(H(H(H(H($$0H(H(H(H(H(r: