iddlZddlmZmZmZddlmZmZm Z m Z m Z m Z m Z mZmZddlmZddlmZddlmZddlmZddlmZdd lmZdd lmZdd lmZdd lmZGd dejjZdS)N) ArrayCacheArrayCacheBySymbolByIdArrayCacheByTimestamp) BalancesIntOrder OrderBookStrStringsTickerTickersTrade)Client)List) ExchangeError)AuthenticationError) BadRequest) NotSupported)ExchangeNotAvailable)RequestTimeout)Precisec eZdZfdZdZdefdZd#dZifdefdZ defd Z defd Z d#d Z defd Z ifd edefdZdifdedefdZddifd edededeefdZdifd ededefdZdddifd edededeefdZdddifd edededeefdZdZdZdefdZdddifd e dededee!fdZ"defdZ#d#dZ$dZ%defdZ&defd Z'defd!Z(ifd"Z)xZ*S)$coinexc0|tt|ddddddddddd dddddiidd d d d d ddddddddd dgddgddddidtt t tttdid S)!NTF) ws watchBalance watchTicker watchTickers watchTrades watchMyTrades watchOrderswatchOrderBook watchOHLCV fetchOHLCVWsapirzwss://socket.coinex.com/zwss://perpetual.coinex.com/)spotswap<i,iiii i@8i`TiiQii: ) 1m3m5m15m30m1h2h4h6h12h1d3d1wr&) 2r:)1010z0.1z0.01r=)limits defaultLimit aggregationsdefaultAggregation)watchOHLCVWarning timeframesaccountr"codes)r<23456)hasurlsoptions streaming exceptions) deep_extendsuperrdescriberrrrrr)self __class__s U/var/www/html/crypto-bot/backend/venv/lib/python3.11/site-packages/ccxt/pro/coinex.pyrRzcoinex.describesfd 3 3 < < > > $# $#!&#"&" $   : =&*   "-oo$&$C$C$C*- ##%2#&-%',  a:A :A : : : cz|||jddd}||jd<|S)N requestIdr)sum safe_integerrM)rSrXs rU request_idzcoinex.request_idSs;HHT..t|[!LLaPP $- [!rVclientc||jd}||dg}||di}t|}g}t dt |D]w}||} || } || dd|} || dd|} | | | } | |j | <| | x| |d}t dt |D]}||}| d}|d}| d}||d|}t|}t |}|dkr|||||d dS) N defaultTypeparamsr tickers::z::rY,symboltickers) safe_stringrM safe_valuelistkeysrangelen safe_symbol safe_marketparse_ws_tickerrdappendfind_message_hashessplitfilter_by_arrayresolve)rSr]messager_r` rawTickersrh newTickersimarketId rawTickerrcmarket parsedTicker messageHashes messageHashparts symbolsStringsymbolsrdtickersSymbols numTickerss rU handle_tickerzcoinex.handle_tickerXsd&&t|]CC (B77__VQ33 JOO%%&& q#d))$$ , ,AAwH"8,I%%hdKHHF%%hdKHHF// 6BBL#/DL   l + + + +00EE q#m,,-- 5 5A'*K%%d++E!!HM#))#..G**:xIIG!',,..11N^,,JA~~w 444z9-----rVNc j||jd}|id|d|d|ddddd||dd||dddd||d d dd ||d d dd||dd||dd||ddddddddd||d||d|d|S)Nr_rc timestampdatetimehighlowbid bidVolume buy_totalask askVolume sell_totalvwapopencloselast previousClosechange percentageaveragevolumedeal) baseVolume quoteVolumeinfo)rerM safe_tickerrk)rStickerryr_s rUrmzcoinex.parse_ws_tickersP&&t|]CC ! d&&tVT;GG! !  !  D$$VV44 ! 4##FE22 ! 4 !  ))&+>>!  4!  ))&,??!  D!  D$$VV44!  T%%fg66!  D$$VV44!  T!  d! $!! " t#! $**68<<++FF;;)! ! ! * + rVreturncK|d{V||d{Vd}d}|dd|\}}|jdd|}t |j}d||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 ` Nbalancerr%rzasset.subscribemethodr`id) load_markets authenticatehandle_market_type_and_paramsrLrgcurrencies_by_idrhr\rPwatch)rSr`r|typeurl currencies subscriberequests rU watch_balancezcoinex.watch_balances  !!!!!!!!!''''''''' 99.$PVWW fit$T*$/446677 ' //##  ""9f55ZZ[';GGGGGGGGGrVcj||dg}||di}||jd<t|}t dt |D]}||}||}|||d} |||d} |} | | d<| | d<| |j|<| |j|_d} | |j| dS) Nr`rr availablefrozenfreeusedr) rfrrgrhrirjsafe_currency_codererD safe_balancerr) rSr]rsr`firstrrv currencyIdcoderrrDr|s rUhandle_balancezcoinex.handle_balances#(B772..$ V%**,,'' q#j//** ; ;A#AJ**:66D((z):KHHI%%eJ&7BBFllnnG'GFO$GFO!(DL ,,T\::DLL t|[11111rVc||dg}||d}||dg}||jd}||dd|}|d}d|z} ||j|} | 5||jdd} t | } | |j|<tdt|D]5} || } | | |}| |6| |j|<| |j|| dS) Nr`rrYr_rctrades: tradesLimit) rfrerMrltradesr[rrirjparse_ws_tradernrr)rSr]rsr`rwrr_ryrcr|storedlimitrvtradeparseds rU handle_tradeszcoinex.handle_tradessR"(B77##FA..B//&&t|]CC !!(D$ DD!&( f55 >%%dlM4HHE&&F"(DK q#f++&& " "A1IE((77F MM& ! ! ! !$ Ft{6*K88888rVc||d}||jd}|||d|||||d|d|dd||dd||d||dddd |S)Ntimer_rrpriceamount) rrrrrcorderrside takerOrMakerrrcostfee)safe_timestamprerM safe_tradeiso8601rk)rSrryrr_s rUrzcoinex.parse_ws_trade=s''v66 &&t|]CC ""5$//" Y//&&tVT;GG$$UF33 %%eW55&&uh77    rVc||ddg}d}||d}||}||||dSt |j}t|}|dkrEi|jd<||j dd} t| } | |jdd<|jdd} tdt|D]} || } | |  || |dS) Nr`resultohlcvrrunknown OHLCVLimitr) safe_value_2re parse_ohlcvsrrrgohlcvsrhrjr[rMrrirn)rSr]rscandlesr|rrrh keysLengthrrrrvcandles rU handle_ohlcvzcoinex.handle_ohlcvYsCF##GXxDD   gt , ,""7++ > NN6; / / / FDK$$&&''YY ??%'DK "%%dlL$GGE*511F06DK "9 - I&y1q#f++&& ! !AAYF LL uk*****rVrcclK||g|d{V}|||S)a :see: https://viabtc.github.io/coinex_api_en_doc/spot/#docsspot004_websocket007_state_subscribe 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 ` N) watch_tickersrf)rSrcr`rds rU watch_tickerzcoinex.watch_tickersE**F8V<<<<<<<<w///rVrcK|d{V||}d}|dd|\}}|jdd|}d}|dd|z}d|gd }|||}|||||d{V}|jr|S| |j d |S) a :see: https://viabtc.github.io/coinex_api_en_doc/spot/#docsspot004_websocket007_state_subscribe watches 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 dictionary of `ticker structures ` Nrr%rrdrarbzstate.subscriberrr`rc) rmarket_symbolsrrLjoinr\rPr newUpdatesrqrd) rSrr`rrr|rrrus rUrzcoinex.watch_tickerss !!!!!!!!!%%g..99.$PVWW fit$T*  %(9(99K'//##  ""9f55::c;MMMMMMMM ?  ##DL(GDDDrVsincerc(K|d{V||}d}|d||\}}|jdd|}d|z}d} ||jdg} | |dd | |d } | |jd<|| |} | ||| | d{V} | | ||d d S) a :see: https://viabtc.github.io/coinex_api_en_doc/spot/#docsspot004_websocket012_deal_subcribe :see: https://viabtc.github.io/coinex_api_en_doc/futures/#docsfutures002_websocket019_deal_subcribe 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 ` Nrr%rrrwatchTradesSubscriptionsrzdeals.subscriberrT) rryrrLrfrMrnr\rPrfilter_by_since_limit)rSrcrrr`ryrrr|subscriptionHashsubscribedSymbolsrsrrs rU watch_tradeszcoinex.watch_tradess@!!!!!!!!!V$$99-QWXX fit$T*&( # OODL:TVXYY  ...''//##   4E /0""7F33zz#{G=MNNNNNNNN))&% TRRRrVc.K|d{V||}|d}d}|d||\}}|jdd|}d}|dz|z}||jdi} || dg} ||| d d }||| s-t|jd zd | z| | d d} || dg} | |d| } || | s-t|jdzd | z| |d}||jdi}|d|| dg||<d| t|d}||jd<||||d}|||}||||||d{V}|S)a :see: https://viabtc.github.io/coinex_api_en_doc/spot/#docsspot004_websocket017_depth_subscribe_multi :see: https://viabtc.github.io/coinex_api_en_doc/futures/#docsfutures002_websocket011_depth_subscribe_multi 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 Nrcr"r%r orderbook:r>r?r:z' watchOrderBook() limit must be one of z, rAr=r@ aggregationz- watchOrderBook() aggregation must be one of watchOrderBookSubscriptionsrTzdepth.subscribe_multirsha256)rryrrLrfrMin_arrayrrrreomitr\rgvalueshashencodejsonrPrr)rSrcrr`ryrrnamer|rMr>rAr@rrrrrrs rUwatch_order_bookzcoinex.watch_order_books!!!!!!!!!V$$!99:JFTZ[[ fit$T*Sj6) //$,0@"EE(B77 =OOG^R@@E}}UF++ htw)RRUYU^U^_eUfUffgg g!--g7KSQQwCC &&v}>PQQ }}[,77 ttw)XX[_[d[deq[r[rrss s6=11&*oodlDace&f&f#/5d|UKQU.V#F+-//##6==??@@  7R 2399T[[;V1W1W%X%XZbcc""9f55**S+w@PRYZZZZZZZZ    rVr*c K|d{V||}|d}d}|d||\}}|dkrt|jdz|jdd|}d} ||jd d } ||j |i} || d i} || | } | | d}| | d }| r%| #||ks||krt|jd z||jdi}d| |d| ||gd}||d}|||}||| || |d{V}|jr|||}||||dS)a :see: https://viabtc.github.io/coinex_api_en_doc/futures/#docsfutures002_websocket023_kline_subscribe 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 Nrcr#r'zP watchOHLCV() is only supported for swap markets. Try using fetchOHLCV() insteadr%rrrBT subscriptions timeframez watchOHLCV() can only watch one symbol and timeframe at a time. To supress self warning set watchOHLCVWarning to False in optionsrCzkline.subscriberr)rcrr)rryrrrrL safe_boolrMrfclientsrerr\r[rPrrgetLimitr)rSrcrrrr`ryrrr|rBr] clientSubexistingSubscription subSymbol subTimeframerCr subscriptionrrs rU watch_ohlcvzcoinex.watch_ohlcvsQ!!!!!!!!!V$$!99,PVWW f 6>>tw){{|| |it$T*  NN4<9LdSSsB77OOFOR@@ #y+FF$$%98DD ''( > >   /7 > > >(1 W %,5 [ )+/<< +B+B Z (&6DOF #tv. <<<< ''z::H%fh77D(88GF..!1!1%!E!EFF   ,,UKQQM 33MBBC E $$$UJ==  T--e[AA   Y//    !$"5"5e=M"N"N   fX&  D  4    D  T%%eW55  ))%>>  D,,ULAA  f f! " # $0088-   . / rVc:ddd}||||S)Npendingok)r=r<)re)rSr4statusess rUrMzcoinex.parse_ws_order_statuss.  &&999rVc||d}|-t|jdz||z||d}|j|j|j|j|j |j |j d}|||}||||dS| ||dS)Nerror r)z state.updatez asset.updatez deals.updatez depth.updatez order.updatez kline.updatezorder.update_stop) rfrrrrerrrr$r-rhandle_subscription_status)rSr]rsrWrhandlershandlers rUhandle_messagezcoinex.handle_messages11  #  %0@0@ @AA A!!'844 . / . 2 . -!%!3  //(F33   GFG $ $ $ F ''88888rVcd}d}||j|}|d||j|}|d|S)Nauthenticated:spotauthenticated:swapT)rffuturesrr)rSr]rsmessageHashSpotmessageHashSwap spotFuture swapFuturess rUhandle_authentication_messagez$coinex.handle_authentication_messagesg/.__V^_EE 4   oofnoFF D!!!rVcL||d}||j|}|p||d}|dkr|||dS||j|}||d|j|=dSdS)Nrr rT)r[rfrrerr`rr)rSr]rsrr futureIndexr s rUrYz!coinex.handle_subscription_statuss   w - -v';R@@  #**<BBKg%%!!&'222__V^[AAF!t$$$$R((( $ #rVcdKd}|dd|\}}|jdd|}||}|}|dk}d}d}|r|n|} || } ||j| } |dkr| | d{VS|} | |d} d|jzd z| |zd z|j z}| | |d }d |j| |g| d }||| || | d|j| <| d{VS| | d{VS|} | |d} d|jzdz| |zd z|j z}| | |dd}d |j||g| d }||| || | d|j| <| d{VS)Nrr%rr&r^r_rz access_id=z&tonce=z &secret_key=md5z server.signrTz ×tamp=rhex)rrLr] millisecondsr rfrr\apiKeynumber_to_stringsecretrrupperrlower)rSr`rrr]risSpotspotMessageHashswapMessageHashr|r  authenticatedrXrsignDatarrs rUrzcoinex.authenticates99.$PVWW fit$T*S!!  ""&...)/Doo_ {++(>(#||||||#))I)I$dk1I=@U@UVZ@[@[[^llosozzH99T[[22E::D'KJJLL  G JJsK)Y G G G04F  -<<<<<< (#||||||#))I)I$dk1MADDYDYZ^D_D__bppsws~~H99T[[22HeDDD'KJJLL  G JJsK)Y G G G04F  -<<<<<< rV)N)+__name__ __module__ __qualname__rRr\rrrmrrrrrrstrr rr r rrrrrr rrgrr rrr$r rr(r-r+rMr\rerYr __classcell__)rTs@rUrrs; ; ; ; ; z J.FJ.J.J.J.X>>>>@*,HHHHHH*2V2222@"9F"9"9"9"9H86+66+6+6+6+p68 0 0 0F 0 0 0 06:"EE7EEEEE6<@d[]SSSSSSbfglbmSSSS<@DB)!)!S)!)!S\)!)!)!)!V8<$]ajl.C.C.CC.CWZ.Cquvzq{.C.C.C.C`;?T`dmo(C(C3(Cs(CZ](Ctxy}t~(C(C(C(CT$$$3335=5=5=5=5=n04$UYbdUUUCUsUimnsitUUUU0b1Fb1b1b1b1HZZZZx:::9V9999(F( ) ) ) ) ))+7 7 7 7 7 7 7 7 rVr)ccxt.async_supportccxt ccxt.async_support.base.ws.cacherrrccxt.base.typesrrrr r r r r r!ccxt.async_support.base.ws.clientrtypingrccxt.base.errorsrrrrrrccxt.base.preciser async_supportrrVrUrsY ffffffffffaaaaaaaaaaaaaaaaaaaaaa444444******000000''''''))))))111111++++++%%%%%%P P P P P T  &P P P P P rV