eiWddlZddlmZmZddlZddlmZmZm Z m Z m Z m Z m Z mZddlmZddlmZddlmZddlmZddlmZGd d ejjZdS) N) ArrayCacheArrayCacheBySymbolById)AnyBalancesBoolIntOrder OrderBookStrTrade)Client)List)AuthenticationError) BadRequest) BadSymbolc ~eZdZdeffd ZdifdededefdZde fdZ ddifded edede e fd Z de fd Zdddifded edede e fd Zdde fd Zdddifded edede efdZdde fdZifdefdZde fdZifdZifdZde defdZde fdZde fdZde fdZde ffd Zde ffd Z xZ!S)hollaexreturnc|tt|ddddddddddd ddiddidiidd |jidd t t d iid S) NTF) ws watchBalance watchMyTrades watchOHLCVwatchOrderBook watchOrders watchTicker watchTickers watchTradeswatchTradesForSymbolsrzwss://api.hollaex.com/streamz$wss://api.sandbox.hollaex.com/stream)apitest)rrpingexact)z&Bearer or HMAC authentication requiredzError: wrong input)hasurlsoptions streaming exceptions) deep_extendsuperrdescriber"rr)self __class__s N/var/www/html/volatility/venv/lib/python3.11/site-packages/ccxt/pro/hollaex.pyr+zhollaex.describesgt 4 4 = = ? ? $!&#"&#$ %#).  8@ !   BK.8A(B (B ( ( ( NsymbollimitcK|d{V||}d|dz}|||d{V}|S)a3 watches information on open orders with bid(buy) and ask(sell) prices, volumes and other data https://apidocs.hollaex.com/#sending-receiving-messages :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 Nz orderbook:id) load_marketsmarket watch_publicr1)r,r0r1paramsr5 messageHash orderbooks r.watch_order_bookzhollaex.watch_order_book>s!!!!!!!!!V$$'&,6 ++K@@@@@@@@    r/clientc||d}||d}||}|d}||d}||d}||} |||| } d} ||jvr || } | |j|<n"|j|} | | |dz|z} || | dS)Nr0topicdata timestamp:) safe_string safe_market safe_value parse8601parse_order_book orderbooks order_bookresetresolve) r,r;messagemarketIdchannelr5r0r>r? timestampMssnapshotr9r8s r.handle_order_bookzhollaex.handle_order_bookOs,##GX66""7G44!!(++!w//$$T;77 nnY// ((v{CC $/))11I&/DOF # #/I OOH % % %mh. y+.....r/sincec.K|d{V||}|d}d|dz}|||d{V}|jr|||}||||ddS)a get the list of most recent trades for a particular symbol https://apidocs.hollaex.com/#sending-receiving-messages :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 ` Nr0ztrade:r3r?T)r4r5r6 newUpdatesgetLimitfilter_by_since_limit)r,r0rPr1r7r5r8tradess r. watch_tradeszhollaex.watch_tradesws!!!!!!!!!V$$!#fTl2 ((f======== ? 3OOFE22E))&% TRRRr/ct||d}||d}||}|d}||j|}|5||jdd}t |}||j|<||dg} || |} tdt| D]} | | | |dz|z} | || | ||dS)Nr=r0 tradesLimitr>rr@) rArBrCrU safe_integerr&r parse_tradesrangelenappendrI) r,r;rJrLrKr5r0storedr1r> parsedTradesjr8s r. handle_tradeszhollaex.handle_tradess7 ""7G44##GX66!!(++!f55 >%%dlM4HHE&&F"(DK w33((v66 q#l++,, + +A MM,q/ * * * *mh. v{+++vw'''''r/c@K|d{Vd}d}|+||}|d}|d|dzz }|||d{V}|jr|||}|||||dS)a, watches information on multiple trades made by the user https://apidocs.hollaex.com/#sending-receiving-messages :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 usertrader0r@r3Tr4r5 watch_privaterRrSfilter_by_symbol_since_limit)r,r0rPr1r7r8r5rUs r.watch_my_tradeszhollaex.watch_my_tradess!!!!!!!!!!   [[((FH%F 3- -K))+v>>>>>>>> ? 3OOFE22E00tTTTr/c||d}||d}t|}|dkrdS|j0||jdd}t ||_|j}i} tdt|D]^} || } || } | | | d} | | }|d}d| |<_| |j|t| }tdt|D]-} || }|d z|z}| |j|.dS) Nr=r>rrXrYr0r3Tr@)rArCr]myTradesrZr&rr\ parse_trader^r5rIlistkeys)r,r;rJ subscriptionrL rawTrades dataLengthr1r_ marketIdsitradeparsedr0r5rKrmr8s r.handle_my_tradeszhollaex.handle_my_tradess.""7G44OOGV44 ^^ ?? F = %%dlM4HHE&u--DM q#i..)) ' 'AaLE%%e,,F MM& ! ! !8_F[[((Fd|H"&Ih  t}g...INN$$%%q#d))$$ 7 7AAwH!C-(2K NN4=+ 6 6 6 6 7 7r/c@K|d{Vd}d}|+||}|d}|d|dzz }|||d{V}|jr|||}|||||dS)a, watches information on multiple orders made by the user https://apidocs.hollaex.com/#sending-receiving-messages :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 ` Norderr0r@r3Tre)r,r0rPr1r7r8r5orderss r. watch_orderszhollaex.watch_orderss!!!!!!!!!   [[((FH%F 3- -K))+v>>>>>>>> ? 3OOFE22E00tTTTr/cN||d}||di}t|}|dkrdS|j0||jdd}t ||_|j}d} t|ts|g} n|} i} tdt| D]^} | | } | | } | | | d}| |}|d}d| |<_| |j|t| }tdt|D]-} || }|d z|z}| |j|.dS) Nr=r>r ordersLimitrYr0r3Tr@)rArCr]rxrZr&r isinstancerlr\ parse_orderr^r5rIrm)r,r;rJrnrLr>rpr1r_ rawOrdersrqrrrwrtr0r5rKrmr8s r. handle_orderzhollaex.handle_orderst""7G44w33YY ?? F ; %%dlM4HHE077DK $%% III q#i..)) ' 'AaLE%%e,,F MM& ! ! !8_F[[((Fd|H"&Ih  t{G,,,INN$$%%q#d))$$ 5 5AAwH!C-(2K NN4; 4 4 4 4 5 5r/cBKd}|||d{VS)a] watch balance and get the amount of funds available for trading or funds locked in orders https://apidocs.hollaex.com/#sending-receiving-messages :param dict [params]: extra parameters specific to the exchange API endpoint :returns dict: a `balance structure ` walletN)rf)r,r7r8s r. watch_balancezhollaex.watch_balancejs5 '' V<<<<<<<<timeinfor?datetimer_ availablefreetotal)rArCrlrmsafe_timestampbalanceiso8601r\r]splitsafe_currency_codeaccount safe_balancerI)r,r;rJr8r>rmr?rrkeyparts currencyIdcodersecond freeOrTotals r.handle_balancezhollaex.handle_balancevs"&&w88 w//DIIKK  ''88 # V$- [!#'<< #:#: Z q#d))$$ ) )Aq'CIIcNNE))%33J**:66D-1T\-A-Adl4(( G%%eQ//F%+{%:%:&&K#'#3#3D##>#>GK !(DL  ((66 t|[11111r/cK|jdd}d|gd}|||}|||||d{VS)Nr r subscribeopargs)r%extendwatch)r,r8r7urlrequestrJs r.r6zhollaex.watch_publicsjit$ M  ++gv..ZZ[';GGGGGGGGGr/cK|||jd}|et|jt dz }|||}t |}||jd<|jdd}d|z}| | || |j tj }|j||d}|dz||z} d|gd } || |} || || |d{VS) N ws-expiresrYr rzCONNECT/stream)zapi-keyz api-signaturez api-expires?rr)check_required_credentialsrAr&inttimeoutstrsumsecondsr%hmacencodesecrethashlibsha256apiKey urlencoderr) r,r8r7expiresrrauth signature authParams signedUrlrrJs r.rfzhollaex.watch_privatesT '')))""4<>> ?4<#d))355Ghht||~~w77G'llG*1DL &it$$w.IIdkk$//T[1I1I7>ZZ {&"  #Iz : ::  M  ++gv..ZZ ;MMMMMMMMMr/c.||d} |H|jdz||z}||jdd||n2#t $r%}t |trYd}~dSYd}~nd}~wwxYw|S)Nerror rr#F)rZr3jsonthrow_exactly_matched_exceptionr( Exceptionr|r)r,r;rJrfeedbackes r.handle_error_messagezhollaex.handle_error_messages !!'733  7S=499W+=+==44T_T5J75SUZ\deee   !011 uuuuu      sA A## B-B  BcX|||sdS||d}|dkr|||dS|j|j|j|j|jd}||d}|||}||||dSdS)NrJpong)rsr9rwrrdr=) rrA handle_pongrbrOrrrurC)r,r;rJcontentmethodsr=methods r.handle_messagezhollaex.handle_messagesl((99  F""7I66 f     VW - - - F'/&).   11%00   F67 # # # # #  r/c ddiS)Nrr")r,r;s r.r"z hollaex.ping5s f~r/c8||_|SN) millisecondslastPong)r,r;rJs r.rzhollaex.handle_pong9s++--r/cnd|jd<tt|||dSNr)r&r*ron_errorr,r;rr-s r.rzhollaex.on_error=5%) \" gt%%fe44444r/cnd|jd<tt|||dSr)r&r*ron_closers r.rzhollaex.on_closeArr/r)"__name__ __module__ __qualname__rr+rrr r:r rOrr rVrbr rhrur ryrrrrr6rfrrrr"rrr __classcell__)r-s@r.rrs0) #) ) ) ) ) ) V@DB!!S!!S\!!!!"&/&/&/&/&/P<@d[]SSSSSSbfglbmSSSS*(F((((B37TX\egUUCUsURUUlpqvlwUUUU01717v17171717f04$UYbdUUUCUsUimnsitUUUU0X5X56X5X5X5X5t*, = = = = = =#2V#2#2#2#2J68HHHH79NNNN4 6 t    f$Vf$f$f$f$P6&5v5555555v5555555555r/r)ccxt.async_supportccxt ccxt.async_support.base.ws.cacherrrccxt.base.typesrrrrr r r r !ccxt.async_support.base.ws.clientr typingrccxt.base.errorsrrr async_supportrrr/r.rs OOOOOOOORRRRRRRRRRRRRRRRRRRR444444000000''''''&&&&&&r5r5r5r5r5d (r5r5r5r5r5r/