":hddlZddlmZmZmZmZddlZddlZddl Z ddl m Z m Z m Z mZmZmZmZmZmZmZddlmZddlmZddlmZddlmZddlmZGd d ej:j<Zy) N) ArrayCacheArrayCacheBySymbolByIdArrayCacheBySymbolBySideArrayCacheByTimestamp) AnyIntOrder OrderBookPositionStrStringsTickerTickersTrade)Client)List) ExchangeError)AuthenticationError)ArgumentsRequiredc eZdZdeffd ZddifdedededeefdZ ddifdeedededeefd Z d e fd Z d,d Z difdededefd ZdifdeededefdZifdZd e fdZdZdZifdedefdZdifdedefdZd e fdZdddifdedededeefdZddifdeeededefdZd e fdZd,defdZdddifde dededeefdZ!dddifdedededee"fdZ#dddifde dededee$fdZ%d e fdZ&d e fd Z'd,d e defd!Z(d"Z)d#Z*ifd$Z+d e fd%Z,d e fd&Z-d e fd'Z.d e fd(Z/d e fd)Z0d e fd*Z1d e fd+Z2xZ3S)-apexreturnc|jtt|dddddddddddd dddddidd d did d d ddi|jdddS)NTF) ws watchTicker watchTickerswatchOrderBook watchOrders watchTradeswatchTradesForSymbolswatchPositions watchMyTrades watchBalance watchOHLCVz;https://omni.apex.exchange/assets/logo_content-CY9uyFbz.svgrz2wss://quote.omni.apex.exchange/realtime_public?v=2z3wss://quote.omni.apex.exchange/realtime_private?v=2)publicprivatez5wss://qa-quote.omni.apex.exchange/realtime_public?v=2z6wss://qa-quote.omni.apex.exchange/realtime_private?v=2zhttps://apex.exchange/z"https://api-docs.pro.apex.exchangez`https://apex-pro.gitbook.io/apex-pro/apex-omni-live-now/trading-perpetual-contracts/trading-feesz https://omni.apex.exchange/trade)logoapitestwwwdocfeesreferraliPF)ping keepAlive)hasurlsoptions streaming) deep_extendsuperrdescriber.)self __class__s G/var/www/html/turnos/venv/lib/python3.12/site-packages/ccxt/pro/apex.pyr6z apex.describesdD : <# $"&##)."&!% %" V"V#X"Y#[ 0;z>#& "E&? & & NsymbolsincelimitcHK|j|g|||d{S7w)aC watches information on multiple trades made in a market https://api-docs.pro.apex.exchange/#websocket-v3-for-omni-websocket-endpoint :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 ` N)watch_trades_for_symbols)r7r;r<r=paramss r9 watch_tradeszapex.watch_trades>s'22F8UE6RRRRs " "symbolscK|jd{|j|}t|}|dk(rt|jdzt |j }|jddddz|z}g}g} tdt|D]G} || } |j| } d| d z} |j| d | z}| j|I|j|| ||d{}|jr6|j|d}|j|d }|j||}|j!|||d d S7H7^w)a4 get the list of most recent trades for a list of symbols https://api-docs.pro.apex.exchange/#websocket-v3-for-omni-websocket-endpoint :param str[] symbols: 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 ` Nrz> watchTradesForSymbols() requires a non-empty array of symbolsr(rr% ×tamp=zrecentlyTrade.H.id2trade:r; timestampT) load_marketsmarket_symbolslenridstr millisecondsr1rangemarketappend watch_topics newUpdates safe_value safe_stringgetLimitfilter_by_since_limit)r7rBr<r=r@ symbolsLength timeStampurltopics messageHashesir;rOtopic messageHashtradesfirst tradeSymbols r9r?zapex.watch_trades_for_symbolsLsk!!!%%g.G A #DGG.n$no o))+, iit$X.>J q#g,' .AQZF[[(F&6E MM% "V+K   -  .((mVVLL ??OOFA.E**5(;KOOK7E))&% TRR+ " Ms#E#EC+E#E!AE#!E#clientc |j|di}|j|d}|}|jd}|j|d}|j|dd}|d} |j|j| } | 7|j |j dd} t| } | |j| <tdt|D](} |j|| |} | j| *d | z}|j| |y) Ndatar].r; tradesLimitrrF) rSrTsplit safe_marketr_ safe_integerr2rrNrJparse_ws_traderPresolve)r7rbmessagerdr]r_partsmarketIdrOr;storedr=jparsedr^s r9 handle_tradeszapex.handle_tradesos (w3  '2 C ##E1-!!(D$7!f5 >%%dllM4HE&F"(DKK q#f+& "A((F;F MM& ! "$f, v{+r:c|j|gd}|j|ddg}|j||d}|d}|j|gd}|j|ddg}|j|ddg}|j|gd } |j ||||j ||dd|d|| ddd |S) N)r\rKvsr;)tT createdAtSsidepprice)qrvsize) rKinforGdatetimer;ordertyper| takerOrMakerr~amountcostfee) safe_string_nrjsafe_integer_nsafe_string_lower_n safe_tradeiso8601) r7traderOrKrpr;rGr|r~rs r9rlzapex.parse_ws_trades  '7 8%%ec8_=!!(FD9!''/FG ''V}=""53.9##E+=>" Y/    r:cFK|j|g||d{S7w)aK watches information on open orders with bid(buy) and ask(sell) prices, volumes and other data https://api-docs.pro.apex.exchange/#websocket-v3-for-omni-websocket-endpoint :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 N)watch_order_book_for_symbols)r7r;r=r@s r9watch_order_bookzapex.watch_order_books%66xOOOOs !!cbK|jd{t|}|dk(rt|jdz|j |}t |j }|jddddz|z}g}g}tdt|D]Z} || } |j| } |d}d t |zd z| d z} |j| d | z} |j| \|j||||d{}|jS77w) a. watches information on open orders with bid(buy) and ask(sell) prices, volumes and other data https://api-docs.pro.apex.exchange/#websocket-v3-for-omni-websocket-endpoint :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 NrzA watchOrderBookForSymbols() requires a non-empty array of symbolsr(rr%rD orderBookz.H.rE orderbook:) rHrJrrKrIrLrMr1rNrOrPrQr=)r7rBr=r@rWrXrYrZr[r\r;rOr]r^ orderbooks r9rz!apex.watch_order_book_for_symbolss>!!!G A #DGG.q$qr r%%g.))+, iit$X.>J q#g,' .AQZF[[(F}#e*,u4ve}DE MM% &/K   - .++COO   ' "$Ps"D/D*C>D/D-D/-D/ctKd|d}|j||}|j||||d{S7w)N subscribeopargs)extendwatch_multiple)r7rYr[rZr@requestrns r9rQzapex.watch_topicssB ++gv.((mWmTTTTs /868c|j|d}|dk(}|j|di}|j|d}|j|dd}|d}|j|dd} ||jvr|j |j|<|j|} |r'|j ||| dd } | j| ni|j|d g} |j|dg} |j| d | |j| d | | | d <|j| | d <d|z}| |j|<|j| |y)Nrsnapshotrdrwr;tsMbP?baasksbidsrGrr) rT safe_dictrjsafe_integer_product orderbooks order_bookparse_order_bookreset safe_list handle_deltasrrm)r7rbrnr isSnapshotrdrprOr;rGrrrrr^s r9handle_order_bookzapex.handle_order_books^D0j( ~~gvr2##D#.!!(D$7!--gtUC $//)&*oo&7DOOF #OOF+ ,,T69c3OH OOH %>>$R0D>>$R0D   y0$ 7   y0$ 7%.Ik "$(LL$;Ij !'&0 "+y+.r:cL|j|dd}|j|y)Nr) parse_bid_ask storeArray)r7booksidedeltabidAsks r9 handle_deltazapex.handle_delta*s$##E1a0F#r:cbtdt|D]}|j|||y)Nr)rNrJr)r7rdeltasr\s r9rzapex.handle_deltas.s0q#f+& 3A   hq 2 3r:c0K|jd{|j|}|d}t|j}|jddddz|z}d|z}d|d z}|g}|j ||g||d{S7{7w) a watches a price ticker, a statistical calculation with the information calculated over the past 24 hours for a specific market https://api-docs.pro.apex.exchange/#websocket-v3-for-omni-websocket-endpoint :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 ` Nr;r(rr%rDticker:instrumentInfo.H.rE)rHrOrLrMr1rQ) r7r;r@rOrXrYr^r]rZs r9 watch_tickerzapex.watch_ticker2s!!!V$!))+, iit$X.>J&( (6%=8&&s[M66JJJ "Ks"BBA6B BBBc8K|jd{|j|dd}g}t|j}|jddddz|z}g}t dt |D]G}||}|j|} d| d z} |j| d |z} |j| I|j||||d{} |jr i} | | | d <| S|j|jd |S77;w) a watches a price ticker, a statistical calculation with the information calculated over the past 24 hours for all markets of a specific list https://api-docs.pro.apex.exchange/#websocket-v3-for-omni-websocket-endpoint :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 ` NFr(rr%rDrrrErr;) rHrIrLrMr1rNrJrOrPrQrRfilter_by_arraytickers)r7rBr@r[rXrYrZr\r;rOr]r^tickerresults r9 watch_tickerszapex.watch_tickersFs0!!!%%gtU; ))+, iit$X.>Jq#g,' .AQZF[[(F,ve}J  q#234 TA'*D++D!4L[[.F!%=L"..tQE)E'AE)'E)cD|j|di}|j|d}|jd}t|}|j|d}|j |}|j||dz } |j j ddkD} | rdnd} |j| dd| } | d} |j|j| }|i|j| <|j||8|j|jd d }t||j| |<|j| |}td t|D]'}|j||}|j|)d | zd z|z}| ||g}|j||y)Nrdr]rerspotcontractr; OHLCVLimitrhrrr)rSrTrirJfind_timeframerYfindrjohlcvsrkr2rrNparse_ws_ohlcvrPrm)r7rbrnrdr]rrrrrpisSpot marketTyperOr;ohlcvsByTimeframer=rqr\rsr^ resolveDatas r9 handle_ohlcvzapex.handle_ohlcvs.w3  '2[[% *o &&z15 '' 4 ##J a@(2-%V: !!(D$ C! OODKK@  $"$DKK  ??,i 8 @%%dllL$GE-B5-IDKK  *V$Y/q#d)$ "A((a1F MM& ! " &(4/); y&1 {K0r:c |j|d|j|d|j|d|j|d|j|d|j|ddgS)Nstartopenhighlowclosevolumeturnover)rk safe_number safe_number_2)r7ohlcvrOs r9rzapex.parse_ws_ohlcvsp"   eW -   UF +   UF +   UE *   UG ,   uh ;   r:cKd}|jd{||j|}|d|zz }t|j}|jddddz|z}|j |d{|j ||gdg|d{}|jr|j||}|j||||dS77W7;w) av watches information on multiple trades made by the user https://api-docs.pro.apex.exchange/#private-websocket :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 boolean [params.unifiedMargin]: use unified margin account :returns dict[]: a list of `order structures ` myTradesN:r(rr&rDT rHr;rLrMr1 authenticaterQrRrUfilter_by_symbol_since_limit) r7r;r<r=r@r^rXrYr_s r9watch_my_tradeszapex.watch_my_trades s! !!!  [[(F 3< 'K))+, iit$Y/-?)K$$$(({mj\6RR ??OOFE2E00tTT " %Rs4CCA'CCCC8CCCcK|jd{d}|j|s%|j|}ddj|z}t |j }|j ddddz|z}d |z}|j|}|j|d{|j|||j} | .|jd d{} |j| |||d Sd g} |j||g| |d{} |jr| S|j| |||d S7177a7.w) a https://api-docs.pro.apex.exchange/#private-websocket watch all open positions :param str[] [symbols]: list of unified market symbols :param int [since]: the earliest time in ms to fetch positions for :param int [limit]: the maximum number of positions to retrieve :param dict params: extra parameters specific to the exchange API endpoint :returns dict[]: a list of `position structure ` Nrr,r(rr&rD positionsfetchPositionsSnapshotT)rHis_emptyrIjoinrLrMr1rbrset_positions_cacherfuturefilter_by_symbols_since_limitrQrR) r7rBr<r=r@r^rXrYrbcacherrZ newPositionss r9watch_positionszapex.watch_positions's\!!! }}W%))'2G'!22K))+, iit$Y/-?)K!K/ S!$$$   1 =#]]+CDDH55hPUW[\ \!..s[M66RR ?? 11%%PTUU' " %ESsFEEBE1E 28E*E +4EE (E E EEcK|jd{d}||j|}|d|zz }t|j}|jddddz|z}|j |d{dg}|j ||g||d{} |jr| j||}|j| |||dS77Y7;w) a, watches information on multiple orders made by the user https://api-docs.pro.apex.exchange/#private-websocket :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 :returns dict[]: a list of `order structures ` Nordersrr(rr&rDTr) r7r;r<r=r@r^rXrYrZr s r9 watch_orderszapex.watch_ordersHs!!!  [[(F 3< 'K))+, iit$Y/-?)K$$$(({mVVLL ??OOFE2E00tTT " %Ls4CCA)CCC C!8CCCc|j-|j|jdd}t||_|j}i}t dt |D]5}||}d}|j |}|d} d|| <|j|7t|j} t dt | D]}d| |z} |j|| d} |j|| y)Nrgrhrr;Tz myTrades:r) rrkr2rrNrJrlrPlistkeysrm) r7rblistsr=r_rBr\rawTradersr;rcurrentMessageHashr^s r9handle_my_tradeszapex.handle_my_tradesbs$ == %%dllM4HE259DMq#e*% "AQxHF((2FH%F"GFO MM& !  "GLLN#q#d)$ 7A!,tAw!6  NN6#5 6 7! v{+r:c|j-|j|jdd}t||_|j}i}t dt |D]3}d}|j ||}|d}d||<|j|5t|j} t dt | D]}d| |z} |j|| d} |j|| y)N ordersLimitrhrr;Tzorders:r ) r rkr2rrNrJ parse_orderrPrrrm) r7rbrr=r rBr\rsr; symbolsArrayrr^s r9 handle_orderzapex.handle_orders< ;; %%dllM4HE07DKq#e*% "AF%%eAh/FH%F"GFO MM& !  " GLLN+ q#l+, 7A!*\!_!<  NN6#5 6 7 v{+r:c|jyd}||jvr/|j||j|j||yy)Nr)rfuturesrspawnload_positions_snapshot)r7rbrBr^s r9rzapex.set_positions_cachesG >> % . v~~- MM+ & JJt33V[ I.r:cK|jdg}tj|d{}t|_|j}t dt |D]7}||}t dt |D]}||} |j| 9|j|} | j||j|dy7w)Nrr) fetch_positionsasynciogatherrrrNrJrPrrm) r7rbr^fetchFunctionspromisesr r\riipositionrs r9rzapex.load_positions_snapshots   & !8813q#h-( 'A  IAs9~. '$R= X& ' '  ,uuk*9s(CC B"Cc|jt|_|j}g}tdt|D]}||}|j |}|j |d}|j |||dk(r2d|d<|j |d|d<|j |d|d<u|j ||j|d} tdt| D]f}| |} | jd} | d} | jd } |j|d | d }|j|rU|j|| h|j|d y) Nrr|rlongshortz positions::rrrr;Fr) rrrNrJparse_positionrTrPfind_message_hashesrirrrm)r7rbrr r r\ rawPositionr&r|r[r^ro symbolsStringrBrs r9handle_positionszapex.handle_positionssn. >> !57DN q#e*% 'A(K**;7H##Hf5D    )|trz$*  X&#*  X&#'  X&# '$00G q#m,- 7A'*K%%d+E!!HM#))#.G,,\8WeTI==+y+6 7 |[1r:c \K|jt|j}d}d}||z|z}|j|j ||j |j |j tjd}d}|j|} | j|} |j| j|} | Mddg|||j|j||d} dtj | gd} |j#||| || d{S7w) Nz /ws/accountsGETbase64 authenticatedloginws_zk_accounts_v3)rrZ httpMethod requestPathapiKey passphraserG signaturer)check_required_credentialsrLrMhmacencodestring_to_base64secrethashlibsha256rbrrS subscriptionsr7passwordjsondumpswatch)r7rYr@rG request_path http_method messageStringr9r^rbrr2rrns r9rzapex.authenticate s' '')))+, %  "[0<? IIdkk-8$++dF[F[\`\g\gFh:ikrkyky|DE % S!{+(<(||sD#D,%D*&D,c$|j|gd} ||dk7r|jdz|j|z}|j|jd|||j |dd}|j |jd||t||j|d}|g|se|j|d}|j|d i}|j|d } | d k(rtd |zt|jdz|zy #t$rn} t| tr0d} |j| | | |jvr2|j| =n$|j|d} |j| | Yd} ~ yd} ~ wwxYw)N)coderet_coderetCode0 exactretMsgret_msgbroadsuccessrrauthzAuthentication failed: Fr2reqIdT)rrKrCthrow_exactly_matched_exception exceptions safe_string_2throw_broadly_matched_exceptionrrSrTr Exception isinstancerejectrA) r7rbrnrJfeedbackmsgrSrQrrerrorr^s r9handle_error_messagezapex.handle_error_message(sX!!'+JK DCK77S=499W+==44T__W5MtU]^(((IF44T__W5MsT\]#H--oogy9G"7**7I>//'9bA%%gt4<-.G'.QRR'# (?@@ %!45-  e[1&"6"66,,[9"..w@  e[1 sDD F!A$F  Fc |j||ry|j|ddd}|j|j|j|j|j|j |j |j |j |j|jd }|j||}| |||yt|j}tdt|D].}||}|j||dk\s ||} | ||y|j|d} | dk(r|j||yy)Nr]rr) r4rdepthcandleklinerinstrumentInfor recentlyTradepongrTrr AUTH_RESP)r`rXhandle_accountrrrrt handle_ponghandle_authenticaterSrrrNrJrrT) r7rbrnr]methods exacMethodrr\keymethodrs r9handle_messagezapex.handle_messageqsI  $ $VW 5 ""7GT2>!%!4!4//++''&&(("00''!//$$,,  __We4  ! vw ' GLLN#q#d)$ Aq'Czz$q'"a' vw'  0 ;   $ $VW 5 r:c@t|j}|gddS)Nr.)rr)rLrM)r7rbrXs r9r.z apex.pings'))+, K  r:c4|j|d|_|S)Nrg)rklastPongr7rbrns r9rjzapex.handle_pongs++GV<r:c|j|di}|j|dg}||j|||j|dg}||j|||j|dg}||j ||yy)Ncontentsfillsrr )rrrr.r)r7rbrnrvrwrr s r9rizapex.handle_accounts>>':r:x"5    ! !&% 0NN8["=   ! !&) 4(B7     ff - r:cl|j|d}|j|d}d}|s|dk(r/|j|j|}|jd|St |j dz|j |z}|j||||jvr |j|=|S)NrSrLr2rTrN) rSrkrrmrrKrCr\rA)r7rbrnrSrJr^rr_s r9rkzapex.handle_authenticates//'95  )4% dai__V^^[AF NN4  (#  '8J(JKE MM% -f222((5r:c|SNrts r9handle_subscription_statuszapex.handle_subscription_statuss r:rz)4__name__ __module__ __qualname__rr6rLrrrrAr?rrtrlr rrrQrrrrrr rrrrrrrrr rr r r rrrrrr.rr`rpr.rjrirkr| __classcell__)r8s@r9rrs1' #' R<@d[] S SS S Sbfglbm SOSaenp!Sd3i!S!S[^!SuyzvA!SF$,F$,L$L@DB PS P PS\ PSW_a!$s)!C!fo!@EGU8/8/t$368KKFK(6:"E7EE<-:F-:^8<$]ajl))C)WZ)quvzq{)"aeswACE$tCy/EZ]EmpE@.16.1` D 237TX\egUCUsURUUlpqvlwU48<$]ajlVWVCVWZVquv~qVB04$UYbdUUCUsUimnsitU4$,v$,L.,6.,`J&J7J+$62p.0rsQ AA fff4*0.E4   " "Er: