":hddlZddlmZmZmZmZddlmZm Z m Z m Z m Z m Z mZmZmZmZmZmZddlmZddlmZGddej0j2Zy)N) ArrayCacheArrayCacheBySymbolByIdArrayCacheBySymbolBySideArrayCacheByTimestamp) AnyBalancesBoolIntMarketOrder OrderBookPositionStrStringsTickerTrade)Client)Listc *eZdZdeffd ZifdededefdZdZdZ d d d ifd ed e d e de e fdZ defdZd*dede fdZifd edefdZdefdZd d ifd ed e d e de efdZdefdZd ifd ed e defdZdefdZd d d ifd ed e d e de efdZdefdZd*dededefdZd d d ifd ed e d e de efdZ ifdefdZ!d*defdZ"d d d ifde#d e d e de e$fd Z%defd!Z&d*dede$fd"Z'ifde(fd#Z)defd$Z*d%Z+defd&Z,ifd'Z-ifd(Z.defd)Z/xZ0S)+hashkeyreturnc|jtt|ddddddddddd dddddd d did id dddd dddidS)NTF) ws watchBalance watchMyTrades watchOHLCVwatchOrderBook watchOrders watchTicker watchTradeswatchTradesForSymbolswatchPositionsapiz(wss://stream-glb.hashkey.com/quote/ws/v1z&wss://stream-glb.hashkey.com/api/v1/ws)publicprivaterz/wss://stream-glb.sim.hashkeydev.com/quote/ws/v1z-wss://stream-glb.sim.hashkeydev.com/api/v1/ws)rtest6)fetchBalanceSnapshotawaitBalanceSnapshot)listenKeyRefreshRate listenKeyr keepAlivei')hasurlsoptions streaming) deep_extendsuperrdescribe)self __class__s J/var/www/html/turnos/venv/lib/python3.12/site-packages/ccxt/pro/hashkey.pyr3zhashkey.describesgt = ? $!%""&###)."' "L#K &W'V  )0!,0,1!UG&B & & markettopic messageHashcK|d|dd}|jddd}|j|||j|||d{S7w)Nidsub)symbolr9eventr#rr$)r.watchr1)r4r8r9r:paramsrequesturls r6 wath_publiczhashkey.wath_public8s]Tl  iit$X.ZZ[$2B2B7F2SU`aaaasAAA  AcK|jd{}|j|}|j||d|d{S717wN) authenticateget_private_urlr@)r4r:r+rCs r6 watch_privatezhashkey.watch_privateAsH++-- ""9-ZZ[$ DDD.Ds!A A,A A A  A c8|jddddz|zS)Nr#rr%/)r.)r4r+s r6rHzhashkey.get_private_urlFs%yy%i036BBr71mNr>sincelimitcfK|jd{|j|}|d}|j|j||}d|z}d|zdz|z} |j ||| |d{} |j r| j ||}|j| ||ddS779w)a watches historical candlestick data containing the open, high, low, and close price, and the volume of a market https://hashkeyglobal-apidoc.readme.io/reference/websocket-api#public-stream :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 :param bool [params.binary]: True or False - default False :returns int[][]: A list of candles ordered, open, high, low, close, volume Nr>kline_ohlcv::rT) load_marketsr8 safe_string timeframesrD newUpdatesgetLimitfilter_by_since_limit) r4r> timeframerMrNrAr8intervalr9r:ohlcvs r6 watch_ohlcvzhashkey.watch_ohlcvIs!!!V$!##DOOY J8#'#- 9 &&vuk6JJ ??NN651E))%q$GG " Ks"B1B-AB15B/68B1/B1clientc|j|d}|j|}|j||}||jvri|j|<|j |d}|j|d}|j |}||j|vr8|j |jdd} t| |j||<|j|dg} |j||} tdt| D]8} |j | | i} |j| |}| j|:d|zd z|z}|j| |y) Nr>rA klineType OHLCVLimitdatarrQrR)rT safe_market safe_symbolohlcvs safe_dictfind_timeframe safe_integerr/r safe_listrangelenparse_ws_ohlcvappendresolve)r4r]messagemarketIdr8r>rAr_rYrNrbstoredicandleparsedr:s r6 handle_ohlcvzhashkey.handle_ohlcvbsX6##GX6!!(+!!(F3$++%"$DKK 2$$V[9 '' 2 T[[00%%dllL$GE-B5-IDKK  *~~gvr2V$Y/q#d)$ "A^^D!R0F((8F MM& ! "'#- 9 v{+r7c |j|d|j|d|j|d|j|d|j|d|j|dgS)Ntohlcv)rh safe_number)r4r[r8s r6rlzhashkey.parse_ws_ohlcvsn   eS )   UC (   UC (   UC (   UC (   UC (   r7cK|jd{|j|}|d}d}d|z}|j||||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://hashkeyglobal-apidoc.readme.io/reference/websocket-api#public-stream :param str symbol: unified symbol of the market to fetch the ticker for :param dict [params]: extra parameters specific to the exchange API endpoint :param bool [params.binary]: True or False - default False :returns dict: a `ticker structure ` Nr> realtimesticker:)rSr8rD)r4r>rAr8r9r:s r6 watch_tickerzhashkey.watch_tickersg!!!V$!&( %%fe[&III " Js!AA8AAAAc|j|dg}|j|j|d}|d}d|z}||j|<|j |j||y)Nrbrr>r)ri parse_tickerrftickersrn)r4r]rorbtickerr>r:s r6 handle_tickerzhashkey.handle_tickersj:~~gvr2""4>>$#:;!&( % Vt||F+[9r7cK|jd{|j|}|d}d}d|z}|j||||d{}|jr|j ||}|j |||ddS7p79w)a watches information on multiple trades made in a market https://hashkeyglobal-apidoc.readme.io/reference/websocket-api#public-stream :param str symbol: unified market symbol of the market trades were made in :param int [since]: the earliest time in ms to fetch orders for :param int [limit]: the maximum number of trade structures to retrieve :param dict [params]: extra parameters specific to the exchange API endpoint :param bool [params.binary]: True or False - default False :returns dict[]: a list of `trade structures ` Nr>tradetrades: timestampT)rSr8rDrVrWrX) r4r>rMrNrAr8r9r:tradess r6 watch_tradeszhashkey.watch_tradess!!!V$!&( ''{FKK ??OOFE2E))&% TRR " Ls!B B8B B 8B  B c|j|d}|j|}|d}||jvr5|j|jdd}t ||j|<|j|}|j |d}|a|j|d}tdt|D]7} |j|| } |j| |} |j| 9d|z} |j|| y)Nr> tradesLimitrarbrwrr)rTrcrrhr/rrisort_byrjrkrfparse_ws_tradermrn) r4r]rorpr8r>rNrqrbrrrrtr:s r6 handle_tradeszhashkey.handle_tradess2##GX6!!(+!$++%%%dllM4HE",U"3DKK V$~~gv.  <<c*D1c$i( &tQ/,,UF; f% &%v- v{+r7cK|jd{|j|}|d}d}d|z}|j||||d{}|jS7M7w)aK watches information on open orders with bid(buy) and ask(sell) prices, volumes and other data https://hashkeyglobal-apidoc.readme.io/reference/websocket-api#public-stream :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 Nr>depth orderbook:)rSr8rDrN)r4r>rNrAr8r9r: orderbooks r6watch_order_bookzhashkey.watch_order_bookss!!!V$!"V+ **65+vNN   " Os!A(A$8A(A&A(&A(c|j|d}|j|}d|z}||jvr|ji|j|<|j|}|j |dg}|j |d}|j |d} |j||| dd} |j| |j |d|d <||j|<|j||y) Nr>rrbrrwbar<nonce) rTrd orderbooks order_bookrirfrhparse_order_bookresetrn) r4r]rorpr>r:rrb dataEntryrsnapshots r6handle_order_bookzhashkey.handle_order_book1s<##GX6!!(+"V+ $//)&*oob&9DOOF #OOF+ ~~gvr2NN4+ %%i5 ((FIsCP!!..w= '"+y+.r7cK|jd{d}||j|}|dz|z}|j|d{}|jr|j ||}|j ||||dS7m79w)aD watches information on multiple orders made by the user https://hashkeyglobal-apidoc.readme.io/reference/websocket-api#private-stream :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 ` NordersrRT)rSr>rIrVrWfilter_by_symbol_since_limit)r4r>rMrNrAr:rs r6 watch_orderszhashkey.watch_orders^s!!!  [[(F%+f4K))+66 ??OOFE2E00tTT " 7!BB5B B 8BBc8|j-|j|jdd}t||_|j |}|j}|j |d}|j |||d}|dz|z}|j ||y)N ordersLimitrarr>rR)rrhr/rparse_ws_orderrmrn) r4r]rorNrtrr:r>symbolSpecificMessageHashs r6 handle_orderzhashkey.handle_ordertsH ;; %%dllM4HE07DK$$W- f v{+!$/#$5$>!v89r7orderc$|j|d}|j||}|j|d}|j|d}d}|j |\}}|j |j|d}|j|d}d} |j ||\}}} |drd}|jid|j|dd |j|d d |j|d |d dddd|j|j|dd|dd|d|d|d|j|dd|j|dd|j|j|dd|j|dd|j|dddddd|j|j|d d|j|j|d!|j|j|d"d#|| |d$ |S)%NsOSrxfcontractr<rr clientOrderIdr{datetimerlastTradeTimestamplastUpdateTimestampstatusXr>type timeInForcesidepricepaverageVamountqfilledz remainingr stopPriceZNn)currencyr) triggerPricetakeProfitPrice stopLossPricecostrfee reduceOnlypostOnlyinfo) rTrcrhsafe_string_lowerparseOrderSideAndReduceOnlyparseOrderType$parseOrderTypeTimeInForceAndPostOnly safe_orderiso8601parse_order_status omit_zerosafe_currency_code) r4rr8rprrrrrrs r6rzhashkey.parse_ws_orders##E3/!!(F3%%eS1 %%eS1 ;;DAj""4#3#3E3#?@&&uc2 &*&O&OPTVa&b#k8 * D $""5#. T--eS9   Y/    !$  "4   d--d.>.>uc.JK  fX&  D  ;  D  T%%eS1  t''s3  dnnT%5%5eS%AB  d&&uc2 ))%5! " # $!#!NN4#3#3E3#?@ 33D4D4DUC4PQ..)9)9%)EF% ; < = r7cK|jd{d}||j|}|d|zz }|j|d{}|jr|j ||}|j |||ddS7m79w)aD watches information on multiple trades made by the user https://hashkeyglobal-apidoc.readme.io/reference/websocket-api#private-stream :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 ` NmyTradesrRrT)rSr>rIrVrWrX)r4r>rMrNrAr:rs r6watch_my_tradeszhashkey.watch_my_tradess!!!  [[(F 3< 'K))+66 ??OOFE2E))&% TRR " 7rcF|j-|j|jdd}t||_|j}|j |}|j |||_d}|j |||d}|dz|z} |j || y)Nrrarr>rR)rrhr/rrrmrn) r4r]ro subscriptionrN tradesArrayrtr:r>rs r6handle_my_tradezhashkey.handle_my_trades" == %%dllM4HE259DMmm $$W-6"#  {K0!$/#$5$>!{$=>r7c|j|d}|j||}|j|d}|j|d}d}||rd}nd}|j |j |dd||j ||d|j|d |j|d |j|d d|d|j|d d|d |S)Nrrwmmakertakerr|Tr>rrrrx) r<rrr>rrrr takerOrMakerrrrr)rTrcrh safe_bool safe_trade safe_string_2rr)r4rr8rprisMakerrs r6rzhashkey.parse_ws_trades6##E3/!!(F3%%eS1 ..,  & & $$UC5" Y/X&**5#6%%eS1&&uc2(%%eS1   r7symbolscK|jd{|jd{}|j|}d}g}||j|n6t dt |D]}||} |j|dz| z |j |} |j| |d|d{} |jr| S|j|j|||dS7775w)a7 https://hashkeyglobal-apidoc.readme.io/reference/websocket-api#private-stream watch all open positions :param str[] [symbols]: list of unified market symbols to watch positions for :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 ` N positionsrrRT) rSrGmarket_symbolsrmrjrkrHwatch_multiplerVfilter_by_symbols_since_limitr) r4rrMrNrAr+r: messageHashesrrr>rCrs r6watch_positionszhashkey.watch_positions:s!!!++-- %%g.!  ?   -1c'l+ A $$[3%6%?@ A""9---c=$ VV ?? 11$..'5RWY]^^ "-Ws2C2C,C2C.B C2:C0;2C2.C20C2c|jt|_|j}|j|}|j|d}|j |||d}|j ||dz|zy)Nrr>rR)rrparse_ws_positionrmrn)r4r]rorrtr:r>s r6handle_positionzhashkey.handle_positionWst, >> !57DNNN ''0 ! v{+!v{S069:r7c|j|d}|j|}|j|d}|jid|dddd|d|j |d|j |dd dd |j |d d |j |d d|j|dd|j |dd|j |dddd|j |dddd|j |dd|j |ddd|j |dd|j |dddddddd|d S)!NrEr>r<rr contractsP contractSizerrnotionalpvleverager| unrealizedPnlup realizedPnlr collateral entryPricer markPriceliquidationPricer marginModemthedgedTmmr) maintenanceMarginmaintenanceMarginPercentage initialMargininitialMarginPercentage marginRatior lastPricerr percentager)rTrcrh safe_positionrr}r)r4positionr8rprs r6rzhashkey.parse_ws_positionws##Hc2!!(+%%h4 !!# fX&# $#  #   Y/ # ))(C8 # D #  D**8S9#  ((48#  ))(C8#  T--h=#  4++Hc:#  $#  $**8S9#  #   0 03 ?# $004@!# " d## $"&!1!1(D!A+/!--h<'+#'!#9#   r7c$K|jd{}|jd{d}|jdd||\}}d|z}|j|}|j |}|j |||d}d}|j |jddd\}}|j |jddd\}}|r|r|j|d zd{|j||d|d{S777$7 w) a watch balance and get the amount of funds available for trading or funds locked in orders https://hashkeyglobal-apidoc.readme.io/reference/websocket-api#private-stream :param dict [params]: extra parameters specific to the exchange API endpoint :param str [params.type]: 'spot' or 'swap' - the type of the market to watch balance for(default 'spot') :returns dict: a `balance structure ` Nspotrbalance:r(Tr)Fz:fetchBalanceSnapshot) rGrShandle_market_type_and_paramsrHr]set_balance_cachehandle_option_and_paramsr/futurer@) r4rAr+rr:rCr]r(r)s r6 watch_balancezhashkey.watch_balances,++-- !!!99.$PVX\] f 4' ""9-S! vt[9##'+'D'DT\\Sacy{(A$f'+'D'DT\\Sacy|A(B$f $8--'> >? ? ?ZZ[$ DDD.! @DsDDDDD B8D'D (DDD D DDc,||jvry|j|jd}|j|dd}|rE|dzdz}||jvr/|j ||j |j|||i|j|<y)Nrr(TrR) subscriptionsrfr/rfuturesrspawnload_balance_snapshotbalance)r4r]r subscribeHashr/rr:s r6rzhashkey.set_balance_caches F00 0 ..~>>>'+A4H *'==K6>>1 k* 455v{DQ Tr7c<K|jd|id{}|j||j|j|i|j|<|j|}|j |j |j|d|zy7w)Nrr) fetch_balanceextend safe_valuer!rrn)r4r]r:rresponsers r6r zhashkey.load_balance_snapshots++VTN;;![[4??4<**=#>#* T4 !..t||D/AB T 4' t||D);7r7c<K|j|jd}||S|j|d{}|j|d}||jd<|j|jdd}|j ||j |||S7bw)Nr+r*r')rTr/privatePostApiV1UserDataStreamrhdelaykeep_alive_listen_key)r4rAr+r'r*s r6rGzhashkey.authenticates$$T\\;?   <#8V#8J)+ =?""1V1r7r)ccxt.async_supportccxt ccxt.async_support.base.ws.cacherrrrccxt.base.typesrrr r r r r rrrrr!ccxt.async_support.base.ws.clientrtypingr async_supportrr7r6rXsB AAuuuu4U 1d  ((U 1r7