iUddlZddlmZmZddlZddlmZmZm Z m Z m Z m Z ddl mZddlmZddlmZddlmZddlmZGd d ejjZdS) N) ArrayCacheArrayCacheBySymbolById)BalancesIntOrder OrderBookStrTrade)Client)List)AuthenticationError) BadRequest) BadSymbolc feZdZfdZdifdededefdZdefdZ ddifded edede e fd Z defd Z dddifded edede e fd Zddefd Zdddifded edede efdZddefdZifdefdZdefdZifdZifdZdefdZdefdZdZdefdZdefdZdefdZxZS)hollaexc |tt|dddddddddd ddiddidiidd |jidd t t d iid S) NTF) ws watchBalance watchMyTrades watchOHLCVwatchOrderBook watchOrders watchTicker watchTickers watchTradesrzwss://api.hollaex.com/streamz$wss://api.sandbox.hollaex.com/stream)apitest)rrpingexact)z&Bearer or HMAC authentication requiredzError: wrong input)hasurlsoptions streaming exceptions) deep_extendsuperrdescriberrr)self __class__s V/var/www/html/crypto-bot/backend/venv/lib/python3.11/site-packages/ccxt/pro/hollaex.pyr'zhollaex.describesgt 4 4 = = ? ? $!&#"&#$ %#  8@ !   BK.8?'B 'B ' ' ' NsymbollimitreturncK|d{V||}d|dz}|||d{V}|S)a watches information on open orders with bid(buy) and ask(sell) prices, volumes and other data :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_publicr-)r(r,r-paramsr2 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)Nr,topicdata timestamp:) safe_string safe_market safe_value parse8601parse_order_book orderbooks order_bookresetresolve) r(r8messagemarketIdchannelr2r,r;r< timestampMssnapshotr6r5s r*handle_order_bookzhollaex.handle_order_bookKs,##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 :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:r0r<T)r1r2r3 newUpdatesgetLimitfilter_by_since_limit)r(r,rMr-r4r2r5tradess r* watch_tradeszhollaex.watch_tradesss!!!!!!!!!V$$!#fTl2 ((f======== ? 3OOFE22E))&% TRRRr+ct||d}||d}||}|d}||j|}|5||jdd}t |}||j|<||dg} || |} tdt| D]} | | | |dz|z} | || | ||dS)Nr:r, tradesLimitr;rr=) r>r?r@rR safe_integerr"r parse_tradesrangelenappendrF) r(r8rGrIrHr2r,storedr-r; parsedTradesjr5s 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 :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]{@link https://docs.ccxt.com/#/?id=trade-structure N usertrader,r=r0Tr1r2 watch_privaterOrPfilter_by_symbol_since_limit)r(r,rMr-r4r5r2rRs 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;rrUrVr,r0Tr=)r>r@rZmyTradesrWr"rrY parse_trader[r2rFlistkeys)r(r8rG subscriptionrI rawTrades dataLengthr-r\ marketIdsitradeparsedr,r2rHrjr5s 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 :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=r0Trb)r(r,rMr-r4r5r2orderss 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 ordersLimitrVr,r0Tr=)r>r@rZrurWr"r isinstancerirY parse_orderr[r2rFrj)r(r8rGrkrIr;rmr-r\ rawOrdersrnrortrqr,r2rHrjr5s 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 :param dict [params]: extra parameters specific to the exchange API endpoint :returns dict: a `balance structure ` walletN)rc)r(r4r5s r* watch_balancezhollaex.watch_balance]s5  '' V<<<<<<<<r@rirjsafe_timestampbalanceiso8601rYrZsplitsafe_currency_codeaccount safe_balancerF)r(r8rGr5r;rjr<rokeyparts currencyIdcodersecond freeOrTotals r*handle_balancezhollaex.handle_balancefs"&&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)Nrr subscribeopargs)r!extendwatch)r(r5r4urlrequestrGs r*r3zhollaex.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-expiresrVrrzCONNECT/stream)zapi-keyz api-signaturez api-expires?rr)check_required_credentialsr>r"inttimeoutstrsumsecondsr!hmacencodesecrethashlibsha256apiKey urlencoderr) r(r5r4expiresrrauth signature authParams signedUrlrrGs r*rczhollaex.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 rrF)rWr0jsonthrow_exactly_matched_exceptionr$ Exceptionryr )r(r8rGrfeedbackes 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)NrGpong)rpr6rtr~rar:) rr> handle_pongr_rLr|rrrr@)r(r8rGcontentmethodsr:methods r*handle_messagezhollaex.handle_messagesl((99  F""7I66 f     VW - - - F'/&).   11%00   F67 # # # # #  r+c ddiS)Nrr)r(r8s r*rz hollaex.ping%s f~r+c8||_|SN) millisecondslastPong)r(r8rGs r*rzhollaex.handle_pong)s++--r+cFd|jd<|||dSNr)r"on_errorr(r8rs r*rzhollaex.on_error-(%) \" fe$$$$$r+cFd|jd<|||dSr)r"on_closers r*rzhollaex.on_close1rr+r) __name__ __module__ __qualname__r'rrrr7r rLr r rSr_r rerrrrvr|rrrr3rcrrrrrr __classcell__)r)s@r*rrs( ( ( ( ( T@DB ! !S ! !S\ ! ! ! !&/&/&/&/&/P<@d[]SSSSSSbfglbmSSSS$(F((((B37TX\egUUCUsURUUlpqvlwUUUU*1717v17171717f04$UYbdUUUCUsUimnsitUUUU*X5X56X5X5X5X5t*,======#2V#2#2#2#2J68HHHH79NNNN4 6    f$Vf$f$f$f$P&%v%%%%%v%%%%%%%%r+r)ccxt.async_supportccxt ccxt.async_support.base.ws.cacherrrccxt.base.typesrrrrr r !ccxt.async_support.base.ws.clientr typingr ccxt.base.errorsr rr async_supportrrr+r*rs OOOOOOOOGGGGGGGGGGGGGGGG444444000000''''''&&&&&&b%b%b%b%b%d (b%b%b%b%b%r+