":hWddlZddlmZmZddlZddlmZmZm Z m Z m Z m Z m Z ddlmZddlmZddlmZddlmZddlmZGd d ej,j.Zy) N) ArrayCacheArrayCacheBySymbolById)AnyBalancesIntOrder OrderBookStrTrade)Client)List)AuthenticationError) BadRequest) BadSymbolc heZdZdeffd ZdifdededefdZde fdZ ddifded edede e fd Z de fd Zdddifded edede e fd Zdde fd Zdddifded edede efdZdde fdZifdefdZde fdZifdZifdZde fdZde fdZde fdZde fdZde ffd Zde ffd ZxZ S)hollaexreturnc|jtt|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 J/var/www/html/turnos/venv/lib/python3.12/site-packages/ccxt/pro/hollaex.pyr*zhollaex.describesgt = ? $!&#"&#$ %#). 8@ !   BK.8A(B ( ( NsymbollimitcK|jd{|j|}d|dz}|j||d{}|jS7G7w)a5 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_publicr0)r+r/r0paramsr4 messageHash orderbooks r-watch_order_bookzhollaex.watch_order_book>sd!!!V$'&,6 ++K@@   "As!A"A2A" A  A" A"clientc|j|d}|j|d}|j|}|d}|j|d}|j|d}|j|} |j ||| } d} ||j vr!|j | } | |j |<n |j |} | j| |dz|z} |j| | y)Nr/topicdata timestamp:) safe_string safe_market safe_value parse8601parse_order_book orderbooks order_bookresetresolve) r+r:messagemarketIdchannelr4r/r=r> timestampMssnapshotr8r7s r-handle_order_bookzhollaex.handle_order_bookOs,##GX6""7G4!!(+!w/$$T;7 nnY/ ((v{C $//)1I&/DOOF #/I OOH %mh. y+.r.sincecK|jd{|j|}|d}d|dz}|j||d{}|jr|j ||}|j |||ddS7o79w)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 ` Nr/ztrade:r2r>T)r3r4r5 newUpdatesgetLimitfilter_by_since_limit)r+r/rOr0r6r4r7tradess r- watch_tradeszhollaex.watch_tradesws!!!V$!#fTl2 ((f== ??OOFE2E))&% TRR ">s!B B7B B8B B c |j|d}|j|d}|j|}|d}|j|j|}|7|j |j dd}t |}||j|<|j|dg} |j| |} tdt| D]} |j| | |dz|z} |j|| |j||y)Nr<r/ tradesLimitr=rr?) r@rArBrT safe_integerr%r parse_tradesrangelenappendrH) r+r:rIrKrJr4r/storedr0r= parsedTradesjr7s r- handle_tradeszhollaex.handle_tradess ""7G4##GX6!!(+!f5 >%%dllM4HE&F"(DKK w3((v6 q#l+, +A MM,q/ * +mh. v{+vw'r.c*K|jd{d}d}|!|j|}|d}|d|dzz }|j||d{}|jr|j ||}|j ||||dS7x79w)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 usertrader/r?r2Tr3r4 watch_privaterQrRfilter_by_symbol_since_limit)r+r/rOr0r6r7r4rTs r-watch_my_tradeszhollaex.watch_my_tradess!!!!   [[(FH%F 3- -K))+v>> ??OOFE2E00tTT "?"BBABB8BBc|j|d}|j|d}t|}|dk(ry|j-|j |j dd}t ||_|j}i} tdt|D]I} || } |j| } |j| | d} |j| }|d}d| |<K|j|j|t| j}tdt|D]+} || }|d z|z}|j|j|-y) Nr<r=rrWrXr/r2Tr?)r@rBr\myTradesrYr%rr[ parse_trader]r4rHlistkeys)r+r:rI subscriptionrK rawTrades dataLengthr0r^ marketIdsitradeparsedr/r4rJrmr7s r-handle_my_tradeszhollaex.handle_my_tradessH.""7G4OOGV4 ^ ?  == %%dllM4HE&u-DM q#i.) 'AaLE%%e,F MM& !8_F[[(Fd|H"&Ih  ' t}}g.INN$%q#d)$ 7AAwH!C-(2K NN4==+ 6 7r.c*K|jd{d}d}|!|j|}|d}|d|dzz }|j||d{}|jr|j ||}|j ||||dS7x79w)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 ` Norderr/r?r2Trd)r+r/rOr0r6r7r4orderss r- watch_orderszhollaex.watch_orderss!!!   [[(FH%F 3- -K))+v>> ??OOFE2E00tTT "?rhc|j|d}|j|di}t|}|dk(ry|j-|j |j dd}t ||_|j}d} t|ts|g} n|} i} tdt| D]I} | | } |j| } |j| | d}|j|}|d}d| |<K|j|j|t| j}tdt|D]+} || }|d z|z}|j|j|-y) Nr<r=r ordersLimitrXr/r2Tr?)r@rBr\rxrYr%r isinstancerlr[ parse_orderr]r4rHrm)r+r:rIrnrKr=rpr0r^ rawOrdersrqrrrwrtr/r4rJrmr7s r- handle_orderzhollaex.handle_ordersdt""7G4w3Y ?  ;; %%dllM4HE07DK $%II q#i.) 'AaLE%%e,F MM& !8_F[[(Fd|H"&Ih  ' t{{G,INN$%q#d)$ 5AAwH!C-(2K NN4;; 4 5r.cFKd}|j||d{S7w)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)re)r+r6r7s r- watch_balancezhollaex.watch_balancejs& '' V<<<datetimer_ availablefreetotal)r@rBrlrmsafe_timestampbalanceiso8601r[r\splitsafe_currency_codeaccount safe_balancerH)r+r:rIr7r=rmr>rrkeyparts currencyIdcodersecond freeOrTotals r-handle_balancezhollaex.handle_balancevs]"&&w8 w/DIIK ''8 # V$- [!#'<< #: Z q#d)$ )Aq'CIIcNE))%3J**:6D-1T\\-Adll4( G%%eQ/F%+{%:&K#'#3#3D##>GK !(DLL  )((6 t||[1r.cK|jdd}d|gd}|j||}|j||||d{S7w)Nrr subscribeopargs)r$extendwatch)r+r7r6urlrequestrIs r-r5zhollaex.watch_publicsUiit$ M ++gv.ZZ[';GGGGsAA A A cK|j|j|jd}|[t|jt dz }|j |j|}t |}||jd<|jdd}d|z}|j|j||j|jtj}|j||d}|dz|j|z} d|gd } |j!| |} |j#| || |d{S7w) N ws-expiresrXrrzCONNECT/stream)zapi-keyz api-signaturez api-expires?rr)check_required_credentialsr@r%inttimeoutstrsumsecondsr$hmacencodesecrethashlibsha256apiKey urlencoderr) r+r7r6expiresrrauth signature authParams signedUrlrrIs r-rezhollaex.watch_privates% '')""4<<> ?4<<#d)35Ghht||~w7G'lG*1DLL &iit$$w.IIdkk$/T[[1I7>>Z {{&" #Iz ::  M ++gv.ZZ ;MMMMsEE EE c|j|d} |D|jdz|j|z}|j|jdd|||S#t $r }t |trYd}~yYd}~|Sd}~wwxYw)Nerror rr"F)rYr2jsonthrow_exactly_matched_exceptionr' Exceptionr|r)r+r:rIrfeedbackes r-handle_error_messagezhollaex.handle_error_messages !!'73  77S=499W+==44T__T5J75SUZ\de !012 sAA B%BBcR|j||sy|j|d}|dk(r|j||y|j|j|j |j |jd}|j|d}|j||}| |||yy)NrIpong)rsr8rwrrcr<) rr@ handle_pongrarNrrrurB)r+r:rIcontentmethodsr<methods r-handle_messagezhollaex.handle_messagesl((9 ""7I6 f    VW - ''//&&))..  1%0   67 # r.c ddiS)Nrr!)r+r:s r-r!z hollaex.ping5s f~r.c0|j|_|SN) millisecondslastPong)r+r:rIs r-rzhollaex.handle_pong9s++-r.cLd|jd<tt|||yNr)r%r)ron_errorr+r:rr,s r-rzhollaex.on_error="%) \" gt%fe4r.cLd|jd<tt|||yr)r%r)ron_closers r-rzhollaex.on_closeArr.r)!__name__ __module__ __qualname__rr*rrr r9r rNr r rUrar rgrurryrrrrr5rerrr!rrr __classcell__)r,s@r-rrs) #) V@DB!S!!S\!"&/&/P<@d[]SSSSSbfglbmS*(F(B37TX\egUCUsURUUlpqvlwU017v17f04$UYbdUUCUsUimnsitU0X56X5t*, = =#2V#2J68H79N4 6 f$Vf$P6&5v55v55r.r)ccxt.async_supportccxt ccxt.async_support.base.ws.cacherrrccxt.base.typesrrrrr r r !ccxt.async_support.base.ws.clientr typingr ccxt.base.errorsrrr async_supportrrr.r-rsB OLLL40'&r5d  ((r5r.