":hddlZddlmZmZmZddlmZmZm Z m Z m Z m Z m Z mZmZmZddlmZddlmZddlmZddlmZddlmZdd lmZGd d ej6j8Zy) N) ArrayCacheArrayCacheBySymbolByIdArrayCacheByTimestamp) AnyBalancesIntOrder OrderBookStrStringsTickerTickersTrade)Client)List)AuthenticationError)ArgumentsRequired) BadRequest)Precisec eZdZdeffd ZdddifdedededeefdZ d e fd Z difdedede fd Z d e fd Zd ZdZifdedefdZdifdedefdZd e fdZddifdedededeefdZd e fdZdddifdedededeefdZd)d e fdZd)dZdddifdedededeefdZd)d e fdZ d)dZ!dZ"ifde#fdZ$d e fdZ%gifdZ&difd Z'gifd!Z(ifd"Z)d e fd#Z*d e fd$Z+d e fd%Z,d e fd&Z-d e fd'Z.d e fd(Z/xZ0S)*whitebitreturnc|jtt|ddddddddddd dddiiddd d d d d ddd ddidd|jiddt t t t diidS)NTF) ws watchBalance watchMyTrades watchOHLCVwatchOrderBook watchOrders watchTicker watchTickers watchTradeswatchTradesForSymbolsapirzwss://api.whitebit.com/ws6030090018003600144002880086400604800) 1m5m15m30m1h4h8h1d1w priceIntervalr) timeframesrpingexact)1246)hasurlsoptions streaming exceptions) deep_extendsuperrdescriber9rr)self __class__s K/var/www/html/turnos/venv/lib/python3.12/site-packages/ccxt/pro/whitebit.pyrFzwhitebit.describesh > @ $!%""&## $#). 5 ! !!!" $Q#" '''0  K/C / / r.NsymbolsincelimitcK|jd{|j|}|d}|j|jdi}|j ||}|d} d|z} | |g} d} |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://docs.whitebit.com/public/websocket/#kline :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 NrKr8idcandles:candles_subscriberT) load_marketsmarket safe_valuerA safe_integer watch_public newUpdatesgetLimitfilter_by_since_limit)rGrK timeframerLrMparamsrSr8intervalmarketId messageHash reqParamsmethodohlcvs rI watch_ohlcvzwhitebit.watch_ohlcvEs!!!V$!__T\\<D $$Z;$< !6) x( $'' VYOO ??NN651E))%q$GG! "Ps"CB?A0CC8CCclientc"|j|dg}tdt|D]}||}|j|d}|j |}|d}d|z} |j ||} ||j vri|j |<d|j |vr:|j|jdd} t| } | |j |d<|j |d} | j| |j| | |S) Nr[rrKrPunknown OHLCVLimit) rTrangelen safe_string safe_market parse_ohlcvohlcvsrUrArappendresolve)rGrcmessager[idatar]rSrKr^parsedrMstoredras rI handle_ohlcvzwhitebit.handle_ohlcvds&(B7q#f+& /A!9D''a0H%%h/FH%F)F2K%%dF3Fdkk)&( F#V!44))$,, dK.u517 F#I.KK' 2E LL NN5+ .# /$rJcK|jd{|j|}|d}d|dz}d}|j|jdi}|j |dd}|j |d|} |j |d}|d || d g} |j ||| |d{} | jS77w) a6 watches information on open orders with bid(buy) and ask(sell) prices, volumes and other data https://docs.whitebit.com/public/websocket/#market-depth :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 orderbook:rKdepth_subscriberr70rOT)rRrSrTrArkomitrVrM) rGrKrMr[rSr^r`rAdefaultPriceIntervalr7r_ orderbooks rIwatch_order_bookzwhitebit.watch_order_books!!!V$ =E'&*:: "//$,,0@"E#//#N((BVW 6?3 4L     ++KFSS   # " Ts"CCBC/C0CCc|j|dg}|j|d}|j|d}|j|}|d}|j|d}|j|d} ||jvr|j } | |j|<|j|} | | d<|j | | d<|r$|j||} | j| nP|j|dg} |j|d g}|j| d| |j| d |d |z}|j| |y) Nr[rrK timestampdatetimeasksbidsry) rTrkrlsafe_timestamp orderbooks order_bookiso8601parse_order_bookreset handle_deltasrp)rGrcrqr[ isSnapshotr]rSrKrsrobr~snapshotrrr^s rIhandle_order_bookzwhitebit.handle_order_booksML(B7__VQ/ ##FA.!!(+!vq)''k: $//)"B&(DOOF #OOF+ !* + $ Y 7 * ,,T6:H OOH %??44D??44D   y0$ 7   y0$ 7'&0 y+.rJcp|j|d}|j|d}|j||y)Nrr) safe_floatstore)rGbooksidedeltapriceamounts rI handle_deltazwhitebit.handle_deltas0q)*uf%rJcbtdt|D]}|j|||y)Nr)rirjr)rGrdeltasrrs rIrzwhitebit.handle_deltass0q#f+& 3A   hq 2 3rJcK|jd{|j|}|d}d}d|z}|j|||d|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://docs.whitebit.com/public/websocket/#market-statistics :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 ` NrKmarket_subscribeticker:F)rRrSwatch_multiple_subscription)rGrKr[rSr`r^s rI watch_tickerzwhitebit.watch_tickersk!!!V$!#&( 55k66SXZ`aaa " bs!AA9AAAAsymbolscK|jd{|j|dd}d}|jdd}|j}g}g}t dt |D]A}|j ||} |jd| dz|j| d C|||d } |j|||j| ||d{|j|jd|S77#w) 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://docs.whitebit.com/public/websocket/#market-statistics :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 ` NFrr$rrrrKrOrOr`r[) rRmarket_symbolsr@noncerirjrSrowatch_multipleextendfilter_by_arraytickers) rGrr[r`urlrO messageHashesargsrrrSrequests rI watch_tickerszwhitebit.watch_tickerss!!!%%gtU;#iit$ ZZ\ q#g,' &A[[,F  VH-=!= > KKt % &   !!#}dkk'66RTabbb##DLL(GDD# " cs"DC>CDD"DDc|j|dg}|j|d}|j|d}|d}|j|di}d|z}|j||} | |j|<|j | |t |jj} tdt| D]C} | | } | jddk\s| j|dk\s2|j | | E|S)Nr[rrKrrr) rTrkrl parse_tickerrrplistfutureskeysrirjfind) rGrcrqrr]rSrK rawTickerr^tickerrrrcurrentMessageHashs rI handle_tickerzwhitebit.handle_ticker s (//'8R8##GQ/!!(D1!OOGQ3 $v- ""9f5% Vv{+V^^0023 q#m,- ;A!.q!1 !&&y1Q6;M;R;RSY;Z^_;_v'9: ;rJcK|jd{|j|}|d}d|z}d}|j|||d|d{}|jr|j ||}|j |||ddS7q79w)a  get the list of most recent trades for a particular symbol https://docs.whitebit.com/public/websocket/#market-trades :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 ` NrKtrades:trades_subscribeFrT)rRrSrrWrXrY rGrKrLrMr[rSr^r`tradess rI watch_tradeszwhitebit.watch_tradesOs!!!V$!$v- #77 VVUZ\bcc ??OOFE2E))&% TRR " ds!B B9B B 8B  B c|j|dg}|j|d}|j|}|d}|j|j|}|7|j |j dd}t |}||j|<|j|dg} |j| |} tdt| D]} |j| | d|dz} |j|| y)Nr[rrK tradesLimitrhrr) rTrkrlrrUrAr parse_tradesrirjrorp) rGrcrqr[r]rSrKrurMrs parsedTradesjr^s rI handle_tradeszwhitebit.handle_tradesfs2(B7##FA.!!(+!f5 >%%dllM4HE&F"(DKK vq"-((v6 q#l+, +A MM,q/ * +&"22 v{+rJcK|t|jdz|jd{|jd{|j |}|d}d|z}d}|j |||d|d{}|j r|j||}|j||||dS77s7;w)a watches trades made by the user https://docs.whitebit.com/private/websocket/#deals :param str symbol: unified market symbol :param int [since]: the earliest time in ms to fetch trades for :param int [limit]: the maximum number of trades structures to retrieve :param dict [params]: extra parameters specific to the exchange API endpoint :returns dict[]: a list of `trade structures ` Nz+ watchMyTrades() requires a symbol argumentrK myTrades:deals_subscribeT rrOrR authenticaterSrrWrXfilter_by_symbol_since_limitrs rIwatch_my_tradeszwhitebit.watch_my_tradess >#DGG.[$[\ \!!!!!!V$!!F* "77 VVUY[abb ??OOFE2E00tTT "! c3.CB:CB< 9CB>8C<C>Cc.|j|d}|j-|j|jdd}t ||_|j}|j |}|j ||d}d|z} |j|| y)Nr[rrhrKr)rTmyTradesrUrArparse_ws_traderorp) rGrcrq subscriptiontraderMrurtrKr^s rIhandle_my_tradeszwhitebit.handle_my_tradess"2 == %%dllM4HE&u-DM$$U+ f!!F* v{+rJc|j|d}|j|d}|j|d}|j|d}|j|d}|j|d}|j||}d} |j|d} | | |dd } |j||||j ||d |ddd||d| d |S) NrrrquotecostcurrencyrK) rOinforrrKordertypeside takerOrMakerrrrfee)rkrrl safe_trader) rGrrSorderIdrrOrrr]rfeeCosts rIrzwhitebit.parse_ws_trades""5!,''q1   eQ '  *!!%+##E1-!!(F3""5!,  "7OC" Y/X&    rJcK|t|jdz|jd{|jd{|j |}|d}d|z}d}|j |||d|d{}|j r|j||}|j||||dS77s7;w)a2 watches information on multiple orders made by the user https://docs.whitebit.com/private/websocket/#orders-pending :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 ` Nz) watchOrders() requires a symbol argumentrKorders:ordersPending_subscribeFTrrs rI watch_orderszwhitebit.watch_orderss >#DGG.Y$YZ Z!!!!!!V$!&( *77 VVUZ\bcc ??OOFE2E00tTT "! drc|j|dg}|j|d}|j-|j|jdd}t ||_|j}|j|d}|j |j |d|i} |j| | d} d| z} |j|j| y) Nr[r ordersLimitrhrstatusrKr) rTordersrUrArparse_ws_orderrrorp) rGrcrqrr[rsrMrurrtrKr^s rI handle_orderzwhitebit.handle_orders6(B7vq) ;; %%dllM4HE07DK""61-$$T[[&7I%JK f!&( t{{K0rJc |j|d}|j|d}|j||}|j|d}|j|j|d}|j|d}|j|d}|j|d} |j|d} |j|d } |j | } d} d}| dk(r|j|d} d }n$|j|d }|j|d } |j |d }|j |d}|d}|j|d}|dk(rdnd}|j|d}d}||j ||dd}d}|dk(s|dk(rd}ntj|d rd}nd}|jid|d|d|d|d|d|j|d|d | d dd!dd|d|d"| d#| d | d$| d%d||||dd&|S)'NrrSrOclient_order_idr deal_stock deal_moneyactivation_pricerr{leftrctimemtimerKrrsellbuydeal_feerrropenclosedcanceledr clientOrderIdrrlastTradeTimestamp timeInForcepostOnly stopPrice triggerPriceraverage)filled remainingrrr) rUrkrl omit_zeroparse_ws_order_typer parse_numberr string_equals safe_orderr)rGrrSrr]rOrrrrrrawTyperrrrrrKrawSiderdealFeer unifiedStatuss rIrzwhitebit.parse_ws_order0s.""5(3##E84!!(F3   eT *t'7'7?P'QR   0!!%6|4$$U,>? ""5&1''0 8 %%e\:FI((7I%%eX6F''w7 !00@!##E62!Q,vU""5*5  ))'2"7OC aKVq["M$$Y4 ( *  E f  "  ]     Y/   !"4  D  4    D  U    I  f D! " t# $"#- . / rJc @dddddddddd }|j|||S)NrMrS) r;r<2023r=5r>810)rk)rGrstatusess rIrzwhitebit.parse_ws_order_types;  &&99rJc K|jd{d}|jdd|\}}d}d}|dk(rd}|dz }nd}|dz }t|jj }|j ||||d{S7s7w)a  watch balance and get the amount of funds available for trading or funds locked in orders https://docs.whitebit.com/private/websocket/#balance-spot https://docs.whitebit.com/private/websocket/#balance-margin :param dict [params]: extra parameters specific to the exchange API endpoint :param str [params.type]: spot or contract if not provided self.options['defaultType'] is used :returns dict: a `balance structure ` Nrwallet:spotbalanceSpot_subscribebalanceMargin_subscribemargin)rRhandle_market_type_and_paramsr currenciesr watch_private)rGr[rr^r`rs rI watch_balancezwhitebit.watch_balances!!!99.$PVW f  6>,F 6 !K.F 8 #K$//..01 '' VZPPP "Qs"BB A.BB B Bcv|j|d}|j|d}|j|d}||jd<t|j }|j|d}|j||}|j |} |j } |j|d| d<|j|d| d<| |j| <|j|j|_d } |jd dk\r| d z } n| d z } |j|j| y) Nr`r[rr availablefreefreezeusedrSpotrr) rkrTbalancerrsafe_currency_codeaccount safe_balancerrp) rGrcrqr`rs balanceDictr currencyId rawBalancecoder(r^s rIhandle_balancezwhitebit.handle_balances!!'84w1oodA. * VK$$&'__T1- __[*= &&z2,,.**:{C**:x@$ T((6  ;;v ! # 6 !K 8 #Kt||[1rJcK|jdd}|j}|||d}|j||}|j||||d{S7wNr$rr)r@rrwatch rGr^r`r_r[rrOrrqs rIrVzwhitebit.watch_publicsaiit$ ZZ\  ++gv.ZZ[';GGGGsAAAAFc$K|jd{|jdd}|j}|j|j|}d} g} |Zi} |j |} | d} d| | <| g} |r| g} ||| d} |j | |}|j||||| d{S|j|j|i} d}|j |} | d} |j| | d}|sd| | <d}|r|j||| || d{Sg}t| j}|r|g}|||d}||jvr |j|=|j||||| d{S7q77g7 w)Nr$rrOTrF) rRr@rrTclientsrSrr1 subscriptions safe_boolrr)rGr^r`rKisNestedr[rrOrcr marketIdsrrSr]rqhasSymbolSubscription isSubscribed marketIdsNew resubRequests rIrz$whitebit.watch_multiple_subscriptions!!!iit$ ZZ\s3 >!#L[[(Fd|H%)L "! I&K  #G kk'62GCgv|TT T??6+?+?LL$( ![[(Fd|H>>,%HL)- X&(-%$!ZZ['6<XXX " #L$5$5$78 $0>L$*& V111,,V4!ZZ[,P\]]]] "(UY^sHFFBF4F 5A/F$F %AFFF F FFcK|j|jd{|jdd}|j}|||d}|j ||}|j ||||d{S7Z7wr0)check_required_credentialsrr@rrr1r2s rIrzwhitebit.watch_private s '')!!!iit$ ZZ\  ++gv.ZZ[';GGG "Hs"$BBAB<B=BBc8K|j|jdd}d}|j|}|jd}|j |j |}|o|j d{}|j|d}|j} | d|dgd} | |jd} |j||| || d{|d{S7e7#t$r(} |j |=|j| Yd} ~ :d} ~ wwxYw7<w) Nr$r authenticatedwebsocket_token authorizepublicr)rOr`) r>r@rcfuturerTr5"v4PrivatePostProfileWebsocketTokenrkrhandle_authenticater1 Exceptionreject) rGr[rr^rcrDr@ authTokentokenrOrres rIrzwhitebit.authenticates( '')iit$% S!/(<(  + +FGR @ !//!// 22"//$($5$5%)%6%6"&"5"5$($7$7 11  2%0   67 # rJc |j}t|j}tdt |D]F}||}|dus |j |d}|"||k(s(|j |d} | =| ||yy)NrTrOr`)r5rvaluesrirjrUrT) rGrcrqrOsubsrgrrrsubIdr`s rIrbz#whitebit.handle_subscription_status}s##dkkm$q#f+& A!!9L4')),=%ERK!__\8DF)vw/ rJc0|j|_|SN) millisecondslastPong)rGrcrqs rIrazwhitebit.handle_pongs++-rJcddgdS)Nrr9r)rGrcs rIr9z whitebit.pings  rJrk)1__name__ __module__ __qualname__rrFstrrrrrbrrvr rrrrr rr rrrrrrr rrrr rrrrrrr.rVrrrrFrTrerbrar9 __classcell__)rHs@rIrrs`0 #0 d8<$]ajlHHCHWZHquvzq{H>&6&P@DB!S!!S\!<</</|& 368bbFb$6:"E7EE:-F-^<@d[]SSSSSbfglbmS.',F',R37TX\egUCUsURUUlpqvlwU2,v,8)V04$UYbdUUCUsUimnsitU2&16&1PUn :*,QQ2!2V!2FAC2 HW\df/^bBDB H)+!F&6, $V $D  & 6 rJr)ccxt.async_supportccxt ccxt.async_support.base.ws.cacherrrccxt.base.typesrrrr r r r r rr!ccxt.async_support.base.ws.clientrtypingrccxt.base.errorsrrrccxt.base.preciser async_supportrrorJrIr~sE fffff40.'%D t!!**D rJ