":hddlZddlmZmZddlZddlmZmZm Z m Z m Z m Z m Z mZmZmZddlmZddlmZddlmZddlmZddlmZdd lmZdd lmZdd lmZdd lmZGd dej:j<Zy)N) ArrayCacheArrayCacheBySymbolById) AnyBalancesIntOrder OrderBookStrStringsTickerTickersTrade)Client)List) ExchangeError)AuthenticationError) BadRequest) NotSupported)RateLimitExceeded)ExchangeNotAvailable)RequestTimeoutc 4eZdZdeffd ZdZdefdZd/dZifde fdZ defd Z d/d Z dddifd e d ed edeefdZdefdZdefdZd/dZifd edefdZdifdedefdZddifd ed ed edeefdZddifdeed ed edeefdZdifdeed edefdZdifd ed edefdZdZ dZ!defdZ"dddifd e d ed edee#fdZ$defdZ%d/dZ&dZ'difdedefd Z(defd!Z)d/d"Z*defd#Z+d$e,d%ed&ed'ed(e-d)ef d*Z.defd+Z/defd,Z0d-efd.Z1xZ2S)0coinexreturnc|jtt|dddddddddddddd dddddiid did d d d dddddddddd dgddgddddiidtd t d!t d"t d#td$td%td&td'td(t d)t d*t d+td,td-td.tid/d0S)1NTF) ws watchBalance watchBidsAsks watchTicker watchTickers watchTradeswatchTradesForSymbols watchMyTrades watchOrderswatchOrderBookwatchOrderBookForSymbols watchOHLCV fetchOHLCVWsapirz wss://socket.coinex.com/v2/spot/z#wss://socket.coinex.com/v2/futures/)spotswapgunzip<i,iiii i@8i`TiiQii: ) 1m3m5m15m30m1h2h4h6h12h1d3d1wr*) 2r?)10001001010z0.1z0.01z0.001z0.0001z0.00001z0.000001z 0.0000001z 0.00000001z 0.000000001z 0.0000000001z 0.00000000001rD)limits defaultLimit aggregationsdefaultAggregation)r timeframesaccountr%20001200022100121002230012300224001240023000130002310013100233001330023400134002)exactbroad)hasurlsoptions streaming exceptions) deep_extendsuperrdescriberrrrrrr)self __class__s I/var/www/html/turnos/venv/lib/python3.12/site-packages/ccxt/pro/coinex.pyrdzcoinex.describesfd < > $!%# $#)-!%#"&,0# %  B Ed   "-$&%H*- #)6Z\00  ^  . ]1Z\00^.] 1!$'kJA J J c~|j|j|jddd}||jd<|S)N requestIdr)sum safe_integerr_)rerjs rg request_idzcoinex.request_idds9HHT..t||[!LaP $- [!rhclientc|j|jd}|j|di}|j|dg}g}t dt |D]s}||}|j|d} |j | dd|} |j| dd|} |j|| } | |j| <|j| u|j|d} t dt | D]}}| |}|jd}|d}|jd }|j|d |}t|j}t |}|dkDsl|j!|||j!|d y) N defaultTypedata state_listrmarket tickers::z::rk,symboltickers) safe_stringr_ safe_dict safe_listrangelen safe_symbol safe_marketparse_ws_tickerrxappendfind_message_hashessplitfilter_by_arraylistkeysresolve)reromessagerqrr rawTickers newTickersientrymarketIdrwrt parsedTicker messageHashes messageHashparts symbolsStringsymbolsrxtickersSymbols numTickerss rg handle_tickerzcoinex.handle_tickerisp&&t||]C ~~gvr2^^D,;  q#j/* ,AqME''x8H%%hdKHF%%hdKHF//v>L#/DLL   l + ,00E q#m,- 5A'*K%%d+E!!HM#))#.G**:xIG!',,.1N^,JA~w 4 5 z9-rhNc 8|j|jd}|j|d}|jid|j||d|ddddd|j|dd|j|dddd |j|d d dd |j|d ddd|j|dd|j|dd|j|ddddddddd|j|d|j|d|d|S)Nrqrtrw timestampdatetimehighlowbid bidVolume volume_buyask askVolume volume_sellvwapopencloselast previousClosechange percentageaveragevolumevalue) baseVolume quoteVolumeinfo)ryr_ safe_tickerr~)retickerrtrqrs rgrzcoinex.parse_ws_tickersP&&t||]C ##FH5! d&&x{K! !  !  D$$VV4 ! 4##FE2 ! 4 !  ))&,?!  4!  ))&-@!  D!  D$$VV4!  T%%fg6!  D$$VV4!  T!  d! $!! " t#! $**68<++FG<)! * + rhcK|jd{d}|jdd|d\}}|j|d{|jdd|}|j |j dd}|j |d}t|j}|g}d }|dk(r|d z }n|d z }d d |i|jd}|j||} |j||| |d{S777w)a watch balance and get the amount of funds available for trading or funds locked in orders https://docs.coinex.com/api/v2/assets/balance/ws/spot_balance https://docs.coinex.com/api/v2/assets/balance/ws/futures_balance :param dict [params]: extra parameters specific to the exchange API endpoint :returns dict: a `balance structure ` Nrr*r)ractiveTidbalances:spot:swapzbalance.subscribeccy_listmethodparamsr) load_marketshandle_market_type_and_params authenticater^ filter_bycurrencies_by_idindex_byrrrnrbwatch) rertypeurlactiveCurrenciesactiveCurrenciesById currenciesr subscriberequests rg watch_balancezcoinex.watch_balances+!!!99.$PVX^_ f%%%iit$T*>>$*?*?4P#}}-=tD.3356  J 6> 7 "K 7 "K)!:.//# ""9f5ZZ[';GGG- " &&Hs4D D1D D B6D ?DD D D c0|ji|_|j|di}|j|dg}|d}|j|d}|j |d}|du}|du} d} d} g} |r0d} t dt |D]} |j| |} | } | r0d} t dt |D]} |j| |} | } t dt | D]} | | }|j|| d}| |j|j| i|j| <| |j| d<|j|j| |j| <d | z}|j|j| |yy) Nrr balance_listr updated_atunrealized_pnlr*r+rz balances:) balancerzr{rmryr|r} array_concatparse_ws_balance safe_value safe_balancer)rerorrrr firstEntryupdated unrealizedPnlisSpotisSwaprrJ rawBalancesrrrs rghandle_balancezcoinex.handle_balancesP << DL~~gvr2>>$;a[ ##J =((5EF %t+ G1c(m, G"// XF  GD G1c(m, G"// XF  GDq#k*+ 2ANE  ! !% 1 2  t||W5=(* W%,0DLL !& )$($5$5dll76K$LDLL !%/K NN4<<0+ > rhc\|j}|j|d}|j|}|j|d|d<|j|d|d<|>|j|j|i|j|<||j||<y||j|<y)Nccy availablefreefrozenused)rJrysafe_currency_coderr)rer accountTyperJ currencyIdcodes rgrzcoinex.parse_ws_balancegs0,,.%%gu5 &&z2**7K@**7H=  "t||[9A,. [).5DLL %d +!(DLL rhrwsincelimitc^K|jd{d}||j|}|d}d}|jd||d\}}|j|d{|jdd|}g}d} || d|zz } |j |d n|dk(r| d z } n| d z } d d |i|j d} |j| |} |j|| | | d{} |jr| j||}|j| |||dS777<w)aj watches information on multiple trades made by the user https://docs.coinex.com/api/v2/spot/deal/ws/user-deals https://docs.coinex.com/api/v2/futures/deal/ws/user-deals :param str [symbol]: unified symbol of the market the trades were made in :param int [since]: the earliest time in ms to watch trades :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 ` Nrwr#r*r)rmyTrades:rrrzuser_deals.subscribe market_listrT) rrtrrr^rrnrbr newUpdatesgetLimitfilter_by_symbol_since_limit) rerwrrrrtrrsubscribedSymbolsrrrtradess rgwatch_my_tradeszcoinex.watch_my_tradess`!!!  [[(FH%F99/6SY[ab f%%%iit$T*   3< 'K  $ $VD\ 2v~w& w& ,$&78//#  ""7F3zz#{G[II ??OOFE2E00tTT9 " &$Js5D-D&A D-"D)#B D-.D+/8D-)D-+D-cl|j|di}|j|d}|jjddkD}|rdnd}|j |dd|}|d}d|z} d|dz} |j |j |} | 7|j|jd d } t| } | |j |<|j||} | j| | |j |<|j|j || |j|j || y) Nrrrtr*r+rwz myTrades:r tradesLimit) rzryrfindrrrrmr_rparse_ws_traderr)rerorrrrrrqrtrwrmessageWithTypestoredrparseds rghandle_my_tradeszcoinex.handle_my_tradess#(~~gvr2##D(3(2- &fF !!(D$ D!!F* %v6f5 >%%dllM4HE&F"(DKK $$T62 f$ Ft{{6*O<t{{6*K8rhc|j|di}|j|dg}|j|d}|jj ddkD}|rdnd}|j |dd|}|d} d| z} |j |j| } | 7|j|jd d } t| } | |j| <td t|D]*} || }|j||}| j|,| |j| <|j|j| | y) Nrr deal_listrtr*rr+rwtrades:rrr)rzr{ryrrrrrrmr_rr|r}rrr)rerorrrrrrrqrtrwrrrrtraders rg handle_tradeszcoinex.handle_tradess6P~~gvr2k26##D(3(2- &fF !!(D$ D!&( f5 >%%dllM4HE&F"(DKK q#f+& "A1IE((7F MM& ! "% Ft{{6*K8rhcf|j|d}d|v}|rdnd}|j|d}|j||d|}i}|j|j|d}|*|j|d|d} |j | |d }|j |j|d |||j ||j||d||j|d d|j|d |j|d |j|d|j|dd|d |S)N created_at margin_marketr*r+rtfeefee_ccyquotecurrencycostdeal_idorder_idsiderolepriceamount) rrrrrworderrr  takerOrMakerr r rr)rmryr omit_zeror safe_tradeiso8601r~) rerrtrrrqrrfeeCost feeCurrencyIds rgrzcoinex.parse_ws_tradesTL%%e\: !U* &fF ##E84!!(FD+F..!1!1%!?@   ,,UIvgOM 33MBC""5)4" Y/&&x{K%%eZ8$$UF3 ,,UF;%%eW5&&uh7   rhcK|jd{|j|}|j|g|d{}||dS787w)a watches a price ticker, a statistical calculation with the information calculated over the past 24 hours for a specific market https://docs.coinex.com/api/v2/spot/market/ws/market https://docs.coinex.com/api/v2/futures/market/ws/market-state :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 ` Nrw)rrt watch_tickers)rerwrrtrxs rg watch_tickerzcoinex.watch_ticker\sX!!!V$**F8V<<vh'(( "` Nrrurwrxr r)rz all@tickerzstate.subscriberr)r market_idsr|r}rtrrr^rnwatch_multiplerbrrrx)rerr marketIdsrtrsymbolsDefinedrrwrrsubscriptionHashesrresults rgrzcoinex.watch_tickerslsP!!!OOG,  !- 1c'l+ E V,$$[6(3C%CD E   +99.&RXY fiit$T**^'$i0//# **3 t?O?OPY[a?bdvww ??M##DLL(GDD1 "*x"D1D,C%D1<D/=0D1/D1cRKd|d<|j|g|||d{S7w)ag get the list of most recent trades for a particular symbol https://docs.coinex.com/api/v2/spot/market/ws/market-deals https://docs.coinex.com/api/v2/futures/market/ws/market-deals :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 ` r!callerMethodNameN)watch_trades_for_symbols)rerwrrrs rg watch_tradeszcoinex.watch_tradess2&3!"22F8UE6RRRRs '%'cK|jd{g}g}d}d}|j|dd\}}|du} | r\tdt|D]C} || } |j | }|j |d|j d|dzEn|j dd} |j |||\} }|jd d | } dg}d d |i|jd }|j| ||j|||d{}|jr|S|j|||ddS7+7*w)ad watch the most recent trades for a list of symbols https://docs.coinex.com/api/v2/spot/market/ws/market-deals https://docs.coinex.com/api/v2/futures/market/ws/market-deals :param str[] symbols: unified symbols of the markets 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 ` Nr!r"rrrrwrr)rzdeals.subscriberrrT) rhandle_param_stringr|r}rtrrr^rnrrbrfilter_by_since_limit)rerrrrrrrtr!rrrwrrrrrs rgr"zcoinex.watch_trades_for_symbolss~!!! #'#;#;FDVXo#p &!- 1c'l+ C V,!((6$$Y1A%AB  C   *99:JFTZ[ fiit$T*&Z'$&78//# **3 t?O?OPY[a?bdvww ??M))&% TRR7 "0xs"EEDEE(EEcK|jd{i}g}d}d}d}|j|dd\}}|j|d|\}}|j|jdi} |j | dg} ||j | dd}|j|| s*t|jdzd j| z|j| d d } |j | d g} |j|d | } |j| | s*t|jdzd j| z|j|d }|du}|rTtdt|D];}||}|j|}|j!d|dz|d|| dg||<=n|j!dt#|j%}dd|i|j'd}|j)|j+|j-|d}|j.dd|}|j1|||j3|||d{}|j4r|S|j7S7l7%w)aa watches information on open orders with bid(buy) and ask(sell) prices, volumes and other data https://docs.coinex.com/api/v2/spot/market/ws/market-depth https://docs.coinex.com/api/v2/futures/market/ws/market-depth :param str[] symbols: unified array of symbols :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 Nr!r&r%rErFr?z1 watchOrderBookForSymbols() limit must be one of z, rHrDrG aggregationz7 watchOrderBookForSymbols() aggregation must be one of rz orderbook:rwrT orderbookzdepth.subscriberrsha256r)r)rr%rrzr_r{rmin_arrayrrjoinryomitr|r}rtrrvaluesrnhashencodejsonr^rrbrr)rerrrwatchOrderBookSubscriptionsrrtrr!r_rErHrGr(rrrw marketListrrr orderbookss rgwatch_order_book_for_symbolsz#coinex.watch_order_book_for_symbolss!!!,.# #'#;#;FDVXr#s &99:JDRXY f../?D26 =%%g~rBE}}UF+tww)\\_c_h_hio_ppq q!--g7KSQ~~g~rB &&v}>PQ }}[,7tww)bbeieneno{e||} }6=1!- 1c'l+ _ V,$$\F84D%DE7=d|UKY]6^+F3  _   -5<<>? '$j1//# "YYt{{499=X3Y'Z\deiit$T*..sM4CSCST]_eCfhz{{ ?? !!Q "J|s"JJIJJ #JJcPKd|d<|j|g||d{S7w)a~ watches information on open orders with bid(buy) and ask(sell) prices, volumes and other data https://docs.coinex.com/api/v2/spot/market/ws/market-depth https://docs.coinex.com/api/v2/futures/market/ws/market-depth :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 r%r!N)r5)rerwrrs rgwatch_order_bookzcoinex.watch_order_books0&6!"66xOOOOs &$&cL|j|dd}|j|y)Nrrk) parse_bid_ask storeArray)rebooksidedeltabidAsks rg handle_deltazcoinex.handle_deltas$##E1a0F#rhcbtdt|D]}|j|||y)Nr)r|r}r>)rer;deltasrs rg handle_deltaszcoinex.handle_deltass0q#f+& 3A   hq 2 3rhcZ|j|jd}|j|di}|j|di}|j|d}|j|dd|}|d}d} | dz|z} |j |d} |j |j |} |j|d d } | rU|j||| }| |j||j |<n|j |}|j|n}|j|d g}|j|d g}|j| d ||j| d || | d <| | d<|j| | d<| |j |<|j|j || y)Nrqrrdepthrtrwr)rris_fullFasksbidsnoncerr)ryr_rzrrmrr4 safe_boolparse_order_book order_bookresetr{rArr)rerorrqrrrCrrtrwnamerrcurrentOrderBook fullOrderBooksnapshotr)rErFs rghandle_order_bookzcoinex.handle_order_books8&&t||]C ~~gvr2tWb1##D(3!!(D$ D!Sj6) %%e\: ??4??FCtY> ,,UFIFH'*.//(*C' OOF3 )>>%4D>>%4D   /7 >   /7 >(1 W %,5 [ )+/<< +B Z (&6DOOF #tv. ` Ntriggerstopordersrwr$r*rrrrzstop.subscribezorder.subscriberrr)rT) r safe_bool_2r-rtrrrnr^rbrrrr)rerwrrrrRrrtr3rrrrrrTs rg watch_orderszcoinex.watch_ordersRs!!!""69f=6Iv#67   [[(FH%F99-QWY_` f%%%   ,J 3< 'KJv~w& w&  %F&F$j1//#  iit$T*""7F3zz#{G['RR ??OOFE2E00tTTI " &,Ss5EE A6E EBEE8EEEc|j|di}|j|ddi}|j|}|d}|j|}|j-|j |j dd}t||_|j} | j|d} | dz|d z} |j|j| | d|zz } |j|j| y) NrrrrSrw ordersLimitrrTrr) rz safe_dict_2parse_ws_orderrtrTrmr_rrr) rerorrrr parsedOrderrwrtrrTrrs rg handle_orderszcoinex.handle_orderssj~~gvr2  w;))%0 X&V$ ;; %%dllM4HE07DK k" %+fVn<t{{O4sV|# t{{K0rhc |j|d}|j|d}|j|d}d|v}|rdnd}|j||d|}d}|j|j |dd} | *|j|d |d } |j | | d }|j id |d |j |ddd|j|dd|j|d|d|j|dd|dd|j|dddddd|j|dd|j|dd|j|dd|j|dd|j|dd |j |d!d"d#|j |d$d%dd|j||dd&|S)'Nrrtstatusrr*r+r quote_ccy_feerrrrrr stop_id clientOrderId client_idrrlastTradeTimestamprrwr timeInForcepostOnlyr r  stopPrice trigger_price triggerPricer filled filled_amount fill_value remainingunfilled_amount unfill_amount)rrr^rr) rmryrr safe_string_2r safe_orderrparse_ws_order_status) rerrtrrr^rrqrrrs rgrZzcoinex.parse_ws_order sfr%%e\: ##E84!!%2!U* &fF !!(FD+F..!3!3E5/!RS   ,,UIvgOM 33MBC E $$$UJ B  T--e[A   Y/    !$"3"3E<"H   fX&  D$$UF3  4    D$$UF3  T%%eW5  ))%A  D,,UOD  d&&uh7 d((N! " ++E3DoV# $008- . / rhc4dddd}|j|||S)Nrcanceled)active_success active_failcancel)ry)rer^statusess rgrqzcoinex.parse_ws_order_statuss)$%   &&99rhcfK|jd{|j|}g}d}|du}|rHtdt|D]/}||}|j |}|j d|dz1n|j dd} |j d||\} }|jdd| } d g} d d |i|jd } |j| ||j| || d{} |jr| S|j|jd|S772w) a watches best bid & ask for symbols https://docs.coinex.com/api/v2/spot/market/ws/market-bbo https://docs.coinex.com/api/v2/futures/market/ws/market-bbo :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 ` Nr bidsasks:rwbidsasksrr)rz all@bidsasksz bbo.subscriberr)rrr|r}rtrrr^rnrrbrrrz)rerrrrrtrrrwrrrrrs rgwatch_bids_askszcoinex.watch_bids_askssQ!!!OOG,  !- 1c'l+ E V,$$[6(3C%CD E   ,99/6SYZ fiit$T*,-%$i0//# **3 t?O?OPY[a?bdvww ??M##DMM8WEE1 "*xrc|j|di}|j|}|d}||j|<d|z}|j||y)Nrrrwry)rzparse_ws_bid_askrzr)rerorrrrrwrs rghandle_bid_askzcoinex.handle_bid_asksV~~gvr2,,T2 h' , f!F* |[1rhc |j|jd}|j|d}|j||d|}|j|d}|j |j ||d|||j ||j|d|j|d|j|d|j|d|d|S) Nrqrtrbest_ask_price best_ask_sizebest_bid_price best_bid_size)rwrrrrrrr)ryr_rrmrr~r safe_number)rerrtrqrrs rgr}zcoinex.parse_ws_bid_asks&&t||]C ##FH5!!(FD+F%%fl; &&x{K" Y/##F,<=))&/B##F,<=))&/B !    rhc |j|d}|j|d}|2|jdd|j|d|j||dd |j|j |j |j|j|j|j|jd}|j||}| |||y|j||y)Nrr)z state.updatezbalance.updatez deals.updatezuser_deals.updatez depth.updatez order.updatez stop.updatez bbo.update) ry handle_errorsrr1rrrrrPr\r~rhandle_subscription_status)rerorrerrorhandlershandlers rghandle_messagezcoinex.handle_messages!!'84  )4     tT6::vtTYYuEUW^`dfj k .."11 ..!%!6!6 22 ..----  //(F3   FG $  ''8rhrreasonrrheadersbodyc @|y|j|d} | duxr| dk7} |j|d} | duxr| dk7} | s| r]|jdz|z}|j|jd| ||j |jd| |t |y)NrokrrD r[r\)safe_string_lowerryrthrow_exactly_matched_exceptionrathrow_broadly_matched_exceptionr)rerrrrrrresponserequestHeaders requestBodyrisErrorMessage errorCode isErrorCodefeedbacks rgrzcoinex.handle_errorss   ((9=!-DGtO$$Xv6  ,D93C .ww}t+H  0 01I9V^ _  0 01I7T\ ]) )rhcP|j|d}|j|d}d}|dk(s|dk(r.|j|j|}|j dyt |j |}|j||||jvr|j|=yy)Nrr authenticatedrrDT) rryrfuturesrrr1reject subscriptions)rerorr^rrfuturers rghandle_authentication_messagez$coinex.handle_authentication_messages$'';$$Wf5 % dN S 0__V^^[AF NN4 ' '(:;E MM% -f222((53rhc|j|d}|j|j|}|O|j|d}|j|j|}||j d|j|=yy)NrrT)rmrrryrr)rerorr subscription futureIndexrs rgrz!coinex.handle_subscription_status.s{   w -v';';R@  #**<BK__V^^[AF!t$$$R( $rhrchK|jdd|}|j|}|j}t|}d}|j |}|j |j |}| |d{S|j} | |d} |j|j||j|jtjd} | d|j| j|dd} |j||| | | d |j |<|d{S77w) Nr)rr)rrhexz server.sign) access_id signed_strr)rrrT)r^ro millisecondsstrrrrrnhmacr0secrethashlibr*apiKeylowerr) rerrrotimerrrrrjrrrs rgrzcoinex.authenticate8s"iit$T*S!  "I % {+(<(>[`a#![["jjl!  3 WiC,0[)|% $s%A8D2:D.;B.D2)D0*D20D2)N)3__name__ __module__ __qualname__rrdrnrrrrrrrr rrrrrrrrr rr r rr#r"r r5r7r>rArPrrVr\rZrqr{r~r}rintdictrrrr __classcell__)rfs@rgrrsK #K Z O.FO.b?B*, H HDH?VH?T")H37TX\eg)UC)Us)URU)Ulpqvlw)UV%9v%9N:9F:9xAF68))F) 6:"#E7#E#EJ<@d[]SSSSSbfglbmS OSaenp(Sd3i(S(S[^(SuyzvA(STSW_a4"$s)4"C4"fo4"l@DB PS P PS\ P$38=8=t04$UYbd2U2UC2Us2Uimnsit2UhC1FC1J~@:8rsN Offf4*0').1+~T   & &~rh