eifddlZddlmZmZmZmZddlZddlZddl Z ddl m Z m Z m Z mZmZmZmZmZmZmZmZddlmZddlmZddlmZddlmZddlmZdd lmZGd d ejj Z dS) N) ArrayCacheArrayCacheBySymbolByIdArrayCacheBySymbolBySideArrayCacheByTimestamp) AnyBoolIntOrder OrderBookPositionStrStringsTickerTickersTrade)Client)List) ExchangeError)AuthenticationError)ArgumentsRequired) NetworkErrorc eZdZdeffd ZddifdedededeefdZ ddifdeedededeefd Z d e fd Z d/d Z difdededefd ZdifdeededefdZifdZd e fdZdZdZifdedefdZdifdedefdZd e fdZdddifdededededeef dZddifdeeededefdZd e fdZd/defdZdddifde dededeefdZ!dddifdedededee"fdZ#dddifde dededee$fdZ%d e fd Z&d e fd!Z'd/d e defd"Z(d#Z)d$Z*ifd%Z+d e de,fd&Z-d e fd'Z.d e fd(Z/d)Z0d e fd*Z1d e fd+Z2d e fd,Z3d e fd-Z4d e fd.Z5xZ6S)0apexreturnc|tt|dddddddddddddd dddddidd d did d d ddi|jdddS)NTF) ws watchTicker watchTickerswatchOrderBookwatchOrderBookForSymbols watchOrders watchTradeswatchTradesForSymbolswatchPositions watchMyTrades watchBalance watchOHLCVwatchOHLCVForSymbolsz;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_extendsuperrdescriber2)self __class__s K/var/www/html/volatility/venv/lib/python3.11/site-packages/ccxt/pro/apex.pyr:z apex.describesdD 1 1 : : < <# $"&,0##)."&!% %"(, V"V#X"Y#[ 0;z>#& "I(? (? ( ( ( NsymbolsincelimitcDK||g|||d{VS)aA 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)r;r?r@rAparamss r= watch_tradeszapex.watch_tradesAs622F8UE6RRRRRRRRRr>symbolsc2K|d{V||}t|}|dkrt|jdzt |}|jddddz|z}g}g} tdt|D]Y} || } | | } d| d z} | | d | z}| |Z| || ||d{V}|j rB| |d}||d }|||}||||d d S)a2 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 millisecondsr5rangemarketappend watch_topics newUpdates safe_value safe_stringgetLimitfilter_by_since_limit)r;rFr@rArD symbolsLength timeStampurltopics messageHashesir?rStopic messageHashtradesfirst tradeSymbols r=rCzapex.watch_trades_for_symbolsOs!!!!!!!!!%%g..G A  #DG.n$noo o))++,, it$X.>J q#g,,'' . .AQZF[[((F&6E MM% "V+K   - - - -((mVVLLLLLLLL ? 8OOFA..E**5(;;KOOK77E))&% TRRRr>clientc||di}||d}|}|d}||d}||dd}|d} ||j| } | 5||jdd} t| } | |j| <t|} td| D];} | | z d z }| |||}| |%%dlM4HHE&&F"(DK Vq&!! " "AQJNE((??F MM& ! ! ! !#f, v{+++++r>c||gd}||ddg}|||d}|d}||gd}||ddg}||ddg}||gd } |||||||dd|d|| ddd |S) N)r`rOvsr?)tT createdAtSsidepprice)qr}size) rOinforKdatetimer?ordertyper takerOrMakerramountcostfee) safe_string_nrosafe_integer_nsafe_string_lower_n safe_tradeiso8601) r;traderSrOrur?rKrrrs r=rqzapex.parse_ws_trades  '7'7'7 8 8%%ec8_==!!(FD99!''/F/F/FGG ''V}==""53.99##E+=+=+=>>" Y//     r>cBK||g||d{VS)aI 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)r;r?rArDs r=watch_order_bookzapex.watch_order_books466xOOOOOOOOOr>cK|d{Vt|}|dkrt|jdz||}t |}|jddddz|z}g}g}tdt|D]p} || } | | } |d}d t |zd z| d z} | | d | z} | | q| ||||d{V}| S) 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)rH orderBookz.H.rI orderbook:) rLrNrrOrMrPrQr5rRrSrTrUrA)r;rFrArDr[r\r]r^r_r`r?rSrarb orderbooks r=rz!apex.watch_order_book_for_symbolss}!!!!!!!!!G A  #DG.q$qrr r%%g..))++,, it$X.>J q#g,,'' . .AQZF[[((F}#e**,u4ve}DE MM% &/K   - - - -++COOOOOOOO    r>cxKd|d}|||}|||||d{VS)N subscribeopargs)extendwatch_multiple)r;r]r_r^rDrequestrss r=rUzapex.watch_topicssY  ++gv..((mWmTTTTTTTTTr>c||d}|dk}||di}||d}||dd}|d}||dd} ||jvr||j|<|j|} |r/|||| dd } | | n||d g} ||dg} | | d | | | d | | | d <| | | d <d|z}| |j|<| | |dS)Nrsnapshotrhr~r?tsMbP?baasksbidsrKrr) rX safe_dictrosafe_integer_product orderbooks order_bookparse_order_bookreset safe_list handle_deltasrrr)r;rfrsr isSnapshotrhrurSr?rKrrrrrbs r=handle_order_bookzapex.handle_order_booksD00j( ~~gvr22##D#..!!(D$77!--gtUCC $/))&*oo&7&7DOF #OF+  <,,T69c3OOH OOH % % % %>>$R00D>>$R00D   y0$ 7 7 7   y0$ 7 7 7%.Ik "$(LL$;$;Ij !'&0 "+y+.....r>c^||dd}||dS)Nrrm) parse_bid_ask storeArray)r;booksidedeltabidAsks r= handle_deltazapex.handle_delta0s3##E1a00F#####r>c~tdt|D]}||||dS)Nr)rRrNr)r;rdeltasr`s r=rzapex.handle_deltas4sHq#f++&& 3 3A   hq 2 2 2 2 3 3r>cXK|d{V||}|d}t|}|jddddz|z}d|z}d|d z}|g}|||g||d{VS) 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)rHticker:instrumentInfo.H.rI)rLrSrPrQr5rU) r;r?rDrSr\r]rbrar^s r= watch_tickerzapex.watch_ticker8s!!!!!!!!!V$$!))++,, it$X.>J&( (6%=8&&s[M66JJJJJJJJJr>c~K|d{V||dd}g}t|}|jddddz|z}g}t dt |D]Y}||}||} d| d z} || d |z} || Z| ||||d{V} |j ri} | | | d <| S| |j d |S) 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)rHrrrIrr?) rLrMrPrQr5rRrNrSrTrUrVfilter_by_arraytickers)r;rFrDr_r\r]r^r`r?rSrarbtickerresults r= watch_tickerszapex.watch_tickersLsh!!!!!!!!!%%gtU;; ))++,, it$X.>Jq#g,,'' . .AQZF[[((F,ve}c(||dd}||dd}||di}d}d}|dkr||}|d}n|dkr|d}t |} ||| d z } || dd} | d}||j|i} || d i} || |}||}||d d }||d <| ||d<||j|<d|z}| |j||dS)Nrarrhrr?rrirmrrrrKrr) rXr parse_tickerrnrNrorrrrrr)r;rfrsra updateTyperhr?rz topicParts topicLengthrurSr rawTickermergedrKrbs r= handle_tickerzapex.handle_tickerjs,  '266%%gvr:: ~~gvr22 * $ $&&t,,FH%FF 7 " "S))Jj//K'' K!ODDH%%hd;;FH%F^^DL&"==Fvvr::I[[D11F&&v..F--gtUCC '{!\\)44z% V&( t|F+[99999r>1m timeframecnKd|d<|||gg|||d{V}|||S)a watches historical candlestick data containing the open, high, low, and close price, and the volume of a market https://api-docs.pro.apex.exchange/#websocket-v3-for-omni-websocket-endpoint :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 r'callerMethodNameN)watch_ohlcv_for_symbols)r;r?rr@rArDrs r= watch_ohlcvzapex.watch_ohlcvsW&2!"33fi5H4I5RWY_````````f~i((r>symbolsAndTimeframesc@K|d{Vt|}|jddddz|z}g}g}t dt |D]} || } || d} || } | d} || dd } ||j| | }| d |zd z| z| d | d zdz| z| ||||d{V\}}}|j r| ||}| |||dd}||||S)a watches historical candlestick data containing the open, high, low, and close price, and the volume of a market https://api-docs.pro.apex.exchange/#websocket-v3-for-omni-websocket-endpoint :param str[][] symbolsAndTimeframes: array of arrays containing unified symbols and timeframes to fetch OHLCV data for, example [['BTC/USDT', '1m'], ['LTC/USDT', '5m']] :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 dict: A list of candles ordered, open, high, low, close, volume Nr,rr)rHrrIrm1zcandle.riohlcv::r?::T)rLrPrQr5rRrNrXrS timeframesrTrUrVrYrZcreate_ohlcv_object)r;rr@rArDr\r] rawHashesr_r`rh symbolStringrSunfiedTimeframe timeframeIdr?rrvfiltereds r=rzapex.watch_ohlcv_for_symbolss!!!!!!!!!))++,, it$X.>J  q#23344 X XA'*D++D!44L[[..F!%=L"..tQ<c||di}||d}|d}t|}||d}||}|||dz } |jddk} | rdnd} || dd| } | d} | |jvr i|j| <||j| vr9| |j d d }t||j| |<|j| |}td t|D]2}| ||}||3d | zd z|z}| ||g}|||dS)Nrhrarirmspotcontractr? OHLCVLimitrlrrr)rWrXrnrNfind_timeframer]findroohlcvsrpr6rrRparse_ws_ohlcvrTrr)r;rfrsrhrarrrrruisSpot marketTyperSr?rArvr`rzrb resolveDatas r= handle_ohlcvzapex.handle_ohlcvs.w33  '22[[%% *oo &&z155 '' 44 ##J a@@((2-%5VV: !!(D$ CC!$+%%"$DK T[000%%dlL$GGE-B5-I-IDK  *V$Y/q#d))$$ " "A((a11F MM& ! ! ! !&(4/); y&1 {K00000r>c ||d||d||d||d||d||ddgS)Nstartopenhighlowclosevolumeturnover)rp safe_number safe_number_2)r;ohlcvrSs r=rzapex.parse_ws_ohlcvs"   eW - -   UF + +   UF + +   UE * *   UG , ,   uh ; ;   r>cKd}|d{V|||}|d|zz }t|}|jddddz|z}||d{V|||gdg|d{V}|jr|||}| ||||dS) at 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*rHT rLr?rPrQr5 authenticaterUrVrYfilter_by_symbol_since_limit) r;r?r@rArDrbr\r]rcs r=watch_my_tradeszapex.watch_my_tradess! !!!!!!!!!  [[((F 3< 'K))++,, it$Y/-?)K$$$$$$$$$(({mj\6RRRRRRRR ? 3OOFE22E00tTTTr>cK|d{Vd}||s-||}dd|z}t |}|jddddz|z}d |z}||}||d{V| |||j } | 4| d d{V} | | |||d Sd g} | ||g| |d{V} |jr| S| | |||d S) 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*rH positionsfetchPositionsSnapshotT)rLis_emptyrMjoinrPrQr5rfrset_positions_cacherfuturefilter_by_symbols_since_limitrUrV) r;rFr@rArDrbr\r]rfcacherr^ newPositionss r=watch_positionszapex.watch_positions,s!!!!!!!!! }}W%% 3))'22G'!2!22K))++,, it$Y/-?)K!K/ S!!$$$$$$$$$   111 =#]]+CDDDDDDDDH55hPUW[\\ \!..s[M66RRRRRRRR ?  11%%PTUUUr>cK|d{Vd}|||}|d|zz }t|}|jddddz|z}||d{Vdg}|||g||d{V} |jr| ||}| | |||dS) 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*rHTr) r;r?r@rArDrbr\r]r^rs r= watch_orderszapex.watch_ordersMs"!!!!!!!!!  [[((F 3< 'K))++,, it$Y/-?)K$$$$$$$$$(({mVVLLLLLLLL ? 3OOFE22E00tTTTr>c<|j0||jdd}t||_|j}i}t dt |D]C}||}d}||}|d} d|| <||Dt| } t dt | D]#}d| |z} | || $d} | || dS)Nrkrlrr?Tz myTrades:r) rrpr6rrRrNrqrTlistkeysrr) r;rflistsrArcrFr`rawTraderzr?rcurrentMessageHashrbs r=handle_my_tradeszapex.handle_my_tradesgs"$ = %%dlM4HHE2599DMq#e**%% " "AQxHF((22FH%F"GFO MM& ! ! ! !GLLNN##q#d))$$ 7 7A!,tAw!6  NN6#5 6 6 6 6 v{+++++r>c8|j0||jdd}t||_|j}i}t dt |D]A}d}|||}|d}d||<||Bt| } t dt | D]#}d| |z} | || $d} | || dS)N ordersLimitrlrr?Tzorders:r) rrpr6rrRrN parse_orderrTrrrr) r;rfrrArrFr`rzr? symbolsArrayrrbs r= handle_orderzapex.handle_orders< ; %%dlM4HHE077DKq#e**%% " "AF%%eAh//FH%F"GFO MM& ! ! ! !GLLNN++ q#l++,, 7 7A!*\!_!<  NN6#5 6 6 6 6 v{+++++r>c|jdSd}||jvr3||||j||dSdS)Nr)rfuturesr spawnload_positions_snapshot)r;rfrFrbs r=r zapex.set_positions_cachesZ > % F. v~-- MM+ & & & JJt3V[ I I I I I.-r>cK|dg}tj|d{V}t|_|j}t dt |D]G}||}t dt |D]}||} ||  H||jvr:|j|} | || |ddSdS)Nrr) fetch_positionsasynciogatherrrrRrNrTr!rr) r;rfrbfetchFunctionspromisesrr`riipositionr s r=r#zapex.load_positions_snapshots    & & !8888888133q#h--(( ' 'A  IAs9~~.. ' '$R= X&&&& ' &. ( (^K0F NN5 ! ! ! NN5+ . . . . . ) (r>c\|jt|_|j}g}tdt|D]}||}||}||d}||||dkr:d|d<||d|d<||d|d<||||d} tdt| D]}| |} | d} | d} | d } | |d | d }| |s| || | |d dS) Nrrrlongshortz positions::rrmrr?Fr) rrrRrNparse_positionrXrTfind_message_hashesrnrr rr)r;rfrrrr` rawPositionr+rr_rbrt symbolsStringrFrs r=handle_positionszapex.handle_positionss. > !577DN q#e**%% ' 'A(K**;77H##Hf55D    ) ) )|trzz$*  X&&&#*  X&&&#'   X&&&&00GG q#m,,-- 7 7A'*K%%d++E!!HM#))#..G,,\8WeTTI==++ 7y+666|[11111r>c vK|t|}d}d}||z|z}||||||jtjd}d}| |} | |} | | j |} | Fddg|||j |j||d} dtj| gd} |||| || d{VS) Nz /ws/accountsGETbase64 authenticatedloginws_zk_accounts_v3)rr^ httpMethod requestPathapiKey passphraserK signaturer)check_required_credentialsrPrQhmacencodestring_to_base64secrethashlibsha256rfreusableFuturerW subscriptionsr<passwordjsondumpswatch)r;r]rDrK request_path http_method messageStringr>rbrfr r7rrss r=rzapex.authenticatesY '')))))++,, %  "[0<? IIdkk-88$++dF[F[\`\gFhFh:i:ikrky|DEE % S!!&&{33( > >||||||r>c||gd} ||dkr|jdz||z}||jd||||dd}||jd||t|||d}|w|su| |d}||d i}| |d } | d krtd |zt|jdz|zd S#t$rv} t| tr*d} | | | | |jvr|j| =n,| |d} | | | Yd} ~ dSd} ~ wwxYw)N)coderet_coderetCode0 exactretMsgret_msgbroadsuccessrrauthzAuthentication failed: Fr7reqIdT)rrOrIthrow_exactly_matched_exception exceptions safe_string_2throw_broadly_matched_exceptionrrWrXr Exception isinstancerejectrG) r;rfrsrPfeedbackmsgrYrWrrerrorrbs r=handle_error_messagezapex.handle_error_message.sX!!'+J+J+JKK DCKK7S=499W+=+==44T_W5MtU]^^^(((IFF44T_W5MsT\]]]#H---oogy99G"7"**7I>>//'9bAA%%gt44<<-.G'.QRRR'# (?@@@5   %!455 2-  e[111&"666,[9"..w@@  e[11144444 sD!D== F=A+F88F=c |||rdS||ddd}|j|j|j|j|j|j|j|j|j|j|j|j d }| ||}||||dSt| }tdt|D]@}||}|||dkr||} | ||dSA||d} | dkr|||dSdS)Nrarr) r9rdepthcandleklinerinstrumentInfor recentlyTradepongrZr2rr AUTH_RESP)rfr^handle_accountrrrr{ handle_ponghandle_authenticate handle_pingrWrrrRrNrrX) r;rfrsramethods exacMethodrr`keymethodrs r=handle_messagezapex.handle_messagews  $ $VW 5 5  F""7GT2>>!%!4/+'&("0'!/$,$   __We44  ! Jvw ' ' ' FGLLNN##q#d))$$  Aq'Czz$q'""a'' vw'''( 00 ;    $ $VW 5 5 5 5 5  r>c^|}||_t|gddS)Nr2rr)rQlastPongrP)r;rfr\s r=r2z apex.pings8%%'' #^^$   r>c@K|} |t|gddd{VdS#t$rM}t |jdz||z}||Yd}~dSd}~wwxYw)Nrmryz handlePing failed with error )rQsendrPr`rrOexception_messager)r;rfrsr\eres r=rmz apex.pongs%%''  ++I'7vFFGG G G G G G G G G G    +K!KdNdNdefNgNg!ghhE LL          s,A BABBcb||d||_|S)Nrm)rprQrzr;rfrss r=rpzapex.handle_pongs.++GVT=N=N=P=PQQr>c>||j||dSN)r"rmrs r=rrzapex.handle_pings  49fg.....r>cR||di}||dg}||||||dg}||||||dg}||||dSdS)Ncontentsfillsrr)rrrr3r)r;rfrsrrrrs r=rozapex.handle_accounts>>':r::x"55    ! !&% 0 0 0NN8["==   ! !&) 4 4 4(B77     ff - - - - -  r>c|||d}||d}d}|s|dkr1||j|}|dnTt |jdz||z}|||||jvr|j|=|S)NrYrRr7rTrT) rWrpr!rrrrOrIrbrG)r;rfrsrYrPrbr res r=rqzapex.handle_authenticates//'955  )44%  6daii__V^[AAF NN4 '#  '8J8J(JKKE MM% - - -f222(5r>c|Srrs r=handle_subscription_statuszapex.handle_subscription_statuss r>r)7__name__ __module__ __qualname__rr:rPr rrrErCrr{rqr rrrUrrrrrrrrrrrrrrr rr rr rrrr r#r3rrrfrwr2rmrprrrorqr __classcell__)r<s@r=rrs) #) ) ) ) ) ) V<@d[] S S SS S Sbfglbm S S S SOSaenp!S!Sd3i!S!S[^!SuyzvA!S!S!S!SF',F',',',',R$$$$L@DB P PS P PS\ P P P PSW_a!!$s)!C!fo!!!!@EGUUUU8/8/8/8/8/t$$$33368KKKFKKKK(6:"EE7EEEEE<-:F-:-:-:-:^?CQUdhqs))))3)^a)x|~ByC))))"aeswACEE$tCy/EZ]EmpEEEE@-16-1-1-1-1^  D    237TX\egUUCUsURUUlpqvlwUUUU48<$]ajlVVWVCVWZVquv~qVVVVB04$UYbdUUUCUsUimnsitUUUU4$,v$,$,$,$,L.,6.,.,.,.,`JJ&J7JJJJ///&626262p.0r)!ccxt.async_supportccxt ccxt.async_support.base.ws.cacherrrrr&rDrIccxt.base.typesrrr r r r r rrrr!ccxt.async_support.base.ws.clientrtypingrccxt.base.errorsrrrr async_supportrrr>r=rst AAAAAAAAAAAA llllllllllllllllllllllllll444444******000000......))))))ZZZZZ4  "ZZZZZr>