eiddlZddlmZmZmZddlmZmZm Z m Z m Z m Z m Z mZmZmZmZddlmZddlmZddlmZddlmZddlmZdd lmZGd d ejjZdS) N) ArrayCacheArrayCacheBySymbolByIdArrayCacheByTimestamp) AnyBalancesBoolIntOrder OrderBookStrStringsTickerTickersTrade)Client)List)AuthenticationError)ArgumentsRequired) BadRequest)Precisec &eZdZdeffd Zdddifdededededeef d Z d e fd Z difdedede fd Z d e fd ZdZdZifdedefdZdifdedefdZd e fdZddifdedededeefdZd e fdZdddifdedededeefdZd*d e fdZd*dZdddifdedededeefdZd*d e fdZ d*dZ!dZ"ifde#fdZ$d e fdZ%gifdZ&d ifd!Z'gifd"Z(ifd#Z)d e fd$Z*d e de+fd%Z,d e fd&Z-d e fd'Z.d e fd(Z/d e fd)Z0xZ1S)+whitebitreturnc |tt|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_extendsuperrdescriber:rr)self __class__s O/var/www/html/volatility/venv/lib/python3.11/site-packages/ccxt/pro/whitebit.pyrGzwhitebit.describesh 5 5 > > @ @ $!%""&## $#).  5 ! !!!"  $Q#" '''0  K/C /C / / / r/Nsymbol timeframesincelimitcK|d{V||}|d}||jdi}|||}|d} d|z} | |g} d} || | | |d{V} |jr| ||}|| ||ddS) 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 NrLr9idcandles:candles_subscriberT) load_marketsmarket safe_valuerB safe_integer watch_public newUpdatesgetLimitfilter_by_since_limit)rHrLrMrNrOparamsrUr9intervalmarketId messageHash reqParamsmethodohlcvs rJ watch_ohlcvzwhitebit.watch_ohlcvEs!!!!!!!!!V$$!__T\<DD $$Z;;$< !6) x( $'' VYOOOOOOOO ? 2NN6511E))%q$GGGrKclientcV||dg}tdt|D]}||}||d}||}|d}d|z} |||} ||jvr i|j|<d|j|vr;||jdd} t| } | |j|d<|j|d} | | | | | |S) Nr\rrLrRunknown OHLCVLimit) rVrangelen safe_string safe_market parse_ohlcvohlcvsrWrBrappendresolve)rHrdmessager\idatar^rUrLr_parsedrOstoredrbs rJ handle_ohlcvzwhitebit.handle_ohlcvds3&(B77q#f++&& / /A!9D''a00H%%h//FH%F)F2K%%dF33Fdk))&( F#V!444))$, dKK.u5517 F#I.K' 2E LL NN5+ . . . .rKcK|d{V||}|d}d|dz}d}||jdi}||dd}||d|} ||d}|d || d g} |||| |d{V} | S) a4 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:rLdepth_subscriberr80rQT)rTrUrVrBrlomitrXrO) rHrLrOr\rUr_rarBdefaultPriceIntervalr8r` orderbooks rJwatch_order_bookzwhitebit.watch_order_books !!!!!!!!!V$$ =E'&*:: "//$,0@"EE#//#NN((BVWW 6?33 4L     ++KFSSSSSSSS    rKc||dg}||d}||d}||}|d}||d}||d} ||jvr|} | |j|<|j|} | | d<|| | d<|r,|||} | | nf||dg} ||d g}| | d| | | d |d |z}| | |dS) Nr\rrL timestampdatetimeasksbidsrz) rVrlrmsafe_timestamp orderbooks order_bookiso8601parse_order_bookreset handle_deltasrq)rHrdrrr\ isSnapshotr^rUrLrtrobrsnapshotrrr_s rJhandle_order_bookzwhitebit.handle_order_booksL(B77__VQ// ##FA..!!(++!vq))''k:: $/))""B&(DOF #OF+ !* + $ Y 7 7 *  8,,T6::H OOH % % % %??444D??444D   y0$ 7 7 7   y0$ 7 7 7'&0 y+.....rKc||d}||d}|||dS)Nrr) safe_floatstore)rHbooksidedeltapriceamounts rJ handle_deltazwhitebit.handle_deltasBq))**uf%%%%%rKc~tdt|D]}||||dS)Nr)rjrkr)rHrdeltasrss rJrzwhitebit.handle_deltassHq#f++&& 3 3A   hq 2 2 2 2 3 3rKcK|d{V||}|d}d}d|z}||||d|d{VS)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 ` NrLmarket_subscribeticker:F)rTrUwatch_multiple_subscription)rHrLr\rUrar_s rJ watch_tickerzwhitebit.watch_tickers!!!!!!!!!V$$!#&( 55k66SXZ`aaaaaaaaarKsymbolscRK|d{V||dd}d}|jdd}|}g}g}t dt |D]V}|||} |d| dz|| d W|||d } |||| | ||d{V| |j d|S) 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%rrrrLrQrQrar\) rTmarket_symbolsrAnoncerjrkrUrpwatch_multipleextendfilter_by_arraytickers) rHrr\raurlrQ messageHashesargsrsrUrequests rJ watch_tickerszwhitebit.watch_tickerssG!!!!!!!!!%%gtU;;#it$ ZZ\\ q#g,,'' & &A[[,,F  VH-=!= > > > KKt % % % %   !!#}dkk'66R6RTabbbbbbbbb##DL(GDDDrKcl||dg}||d}||d}|d}||di}d|z}|||} | |j|<|| |t |j} tdt| D]R} | | } | ddkr/| |dkr|| | S|S)Nr\rrLrrr) rVrlrm parse_tickerrrqlistfutureskeysrjrkfind) rHrdrrrr^rUrL rawTickerr_tickerrrscurrentMessageHashs rJ handle_tickerzwhitebit.handle_ticker s9(//'8R88##GQ//!!(D11!OOGQ33 $v- ""9f55% Vv{+++V^002233 q#m,,-- ; ;A!.q!1 !&&y11Q66;M;R;RSY;Z;Z^_;_;_v'9:::rKc,K|d{V||}|d}d|z}d}||||d|d{V}|jr|||}||||ddS)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 ` NrLtrades:trades_subscribeFrT)rTrUrrYrZr[ rHrLrNrOr\rUr_ratradess rJ watch_tradeszwhitebit.watch_tradesOs!!!!!!!!!V$$!$v- #77 VVUZ\bcccccccc ? 3OOFE22E))&% TRRRrKcP||dg}||d}||}|d}||j|}|5||jdd}t |}||j|<||dg} || |} tdt| D]} | | | d|dz} | || dS)Nr\rrL tradesLimitrirr) rVrlrmrrWrBr parse_tradesrjrkrprq) rHrdrrr\r^rUrLrvrOrt parsedTradesjr_s rJ handle_tradeszwhitebit.handle_tradesfs$2(B77##FA..!!(++!f55 >%%dlM4HHE&&F"(DK vq"--((v66 q#l++,, + +A MM,q/ * * * *&"22 v{+++++rKcK|t|jdz|d{V|d{V||}|d}d|z}d}||||d|d{V}|jr|||}|||||dS)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 argumentrL myTrades:deals_subscribeT rrQrT authenticaterUrrYrZfilter_by_symbol_since_limitrs rJwatch_my_tradeszwhitebit.watch_my_tradess >#DG.[$[\\ \!!!!!!!!!!!!!!!!!!V$$!!F* "77 VVUY[abbbbbbbb ? 3OOFE22E00tTTTrKcH||d}|j0||jdd}t ||_|j}||}|||d}d|z} ||| dS)Nr\rrirLr)rVmyTradesrWrBrparse_ws_traderprq) rHrdrr subscriptiontraderOrvrurLr_s rJhandle_my_tradeszwhitebit.handle_my_tradess"22 = %%dlM4HHE&u--DM$$U++ f!!F* v{+++++rKc||d}||d}||d}||d}||d}||d}|||}d} ||d} | | |dd } |||||||d |ddd||d| d |S) NrrrquotecostcurrencyrL) rQinforrrLordertypeside takerOrMakerrrrfee)rlrrm safe_trader) rHrrUorderIdrrQrrr^rfeeCosts rJrzwhitebit.parse_ws_trades,""5!,,''q11   eQ ' '  **!!%++##E1--!!(F33""5!,,  "7OC" Y//X&     rKcK|t|jdz|d{V|d{V||}|d}d|z}d}||||d|d{V}|jr|||}|||||dS)a0 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 argumentrLorders:ordersPending_subscribeFTrrs rJ watch_orderszwhitebit.watch_orderss >#DG.Y$YZZ Z!!!!!!!!!!!!!!!!!!V$$!&( *77 VVUZ\bcccccccc ? 3OOFE22E00tTTTrKc||dg}||d}|j0||jdd}t ||_|j}||d}|||d|i} || | d} d| z} ||j| dS) Nr\r ordersLimitrirstatusrLr) rVordersrWrBrparse_ws_orderrrprq) rHrdrrrr\rtrOrvrrurLr_s rJ handle_orderzwhitebit.handle_orders6(B77vq)) ; %%dlM4HHE077DK""61--$$T[[&7I%J%JKK f!&( t{K00000rKc ||d}||d}|||}||d}|||d}||d}||d}||d} ||d} ||d } || } d} d}| dkr||d} d }n,||d }||d } ||d }||d}|d}||d}|dkrdnd}||d}d}||||dd}d}|dks|dkrd}ntj|d rd}nd}| id|d|d|d|d|d| |d|d | d dd!dd|d|d"| d#| d | d$| d%d||||dd&|S)'NrrUrQclient_order_idr deal_stock deal_moneyactivation_pricerr|leftrctimemtimerLrrsellbuydeal_feerrropenclosedcanceledr clientOrderIdrrlastTradeTimestamp timeInForcepostOnly stopPrice triggerPriceraverage)filled remainingrrr) rWrlrm omit_zeroparse_ws_order_typer parse_numberr string_equals safe_orderr)rHrrUrr^rQrrrrrrawTyperrrrrrLrawSiderdealFeer unifiedStatuss rJrzwhitebit.parse_ws_order0sF.""5(33##E844!!(F33   eT * *t'7'7?P'Q'QRR   00!!%66|44$$U,>?? ""5&11''00 8  %%e\::FII((77I%%eX66F''w77 !00@@!##E622!Q,,vvU""5*55  ))'22"7OC aKKVq[["MM$Y44 + ( *  E f  "  ]     Y//   !"4  D  4    D  U    I  f D! " t# $"#-   . / rKc Hdddddddddd }||||S)NrOrU) r<r=2023r>5r?810)rl)rHrstatusess rJrzwhitebit.parse_ws_order_typesC   &&999rKc,K|d{Vd}|dd|\}}d}d}|dkrd}|dz }nd}|dz }t|j}|||||d{VS)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)rThandle_market_type_and_paramsr currenciesr watch_private)rHr\rr_rars rJ watch_balancezwhitebit.watch_balances!!!!!!!!!99.$PVWW f  6>>,F 6 !KK.F 8 #K$/..0011 '' VZPPPPPPPPPrKc||d}||d}||d}||jd<t|}||d}|||}||} |} ||d| d<||d| d<| |j| <||j|_d } |d dkr| d z } n| d z } | |j| dS) Nrar\rr availablefreefreezeusedrSpotrr) rlrVbalancerrsafe_currency_codeaccount safe_balancerrq) rHrdrrrart balanceDictr currencyId rawBalancecoder(r_s rJhandle_balancezwhitebit.handle_balancesM!!'844w11oodA.. * VK$$&&''__T1-- __[*== &&z22,,..**:{CC**:x@@$ T((66  ;;v  ! # # 6 !KK 8 #Kt|[11111rKcK|jdd}|}|||d}|||}|||||d{VSNr%rr)rArrwatch rHr_rar`r\rrQrrrs rJrXzwhitebit.watch_publicsxit$ ZZ\\   ++gv..ZZ[';GGGGGGGGGrKFcLK|d{V|jdd}|}||j|}d} g} |gi} ||} | d} d| | <| g} |r| g} ||| d} || |}|||||| d{VS||j|i} d}||} | d} | | | d}|sd| | <d}|r|||| || d{VSg}t| }|r|g}|||d}||jvr|j|=|||||| d{VS)Nr%rrQTrF) rTrArrVclientsrUrr1 subscriptions safe_boolrr)rHr_rarLisNestedr\rrQrdr marketIdsrrUr^rrhasSymbolSubscription isSubscribed marketIdsNew resubRequests rJrz$whitebit.watch_multiple_subscriptions'!!!!!!!!!it$ ZZ\\s33 >!#L[[((Fd|H%)L "! I (&K  #G kk'622GCgv|TTTTTTTT T??6+?LLL$( ![[((Fd|H>>,%HHL .)- X&(-%$ ^!ZZ['6<XXXXXXXXX " #L$5$5$7$788 2$0>L$*&& V111,V4!ZZ[,P\]]]]]]]]]rKc$K||d{V|jdd}|}|||d}|||}|||||d{VSr0)check_required_credentialsrrArrr1r2s rJrzwhitebit.watch_private s '')))!!!!!!!!!it$ ZZ\\   ++gv..ZZ[';GGGGGGGGGrKcLK||jdd}d}||}|d}||j|}||d{V}||d}|} | d|dgd} | |j d} | ||| || d{Vn4#t$r'} |j|=| | Yd} ~ nd} ~ wwxYw|d{VS) Nr%r authenticatedwebsocket_token authorizepublicr)rQra) r>rArdreusableFuturerVr5"v4PrivatePostProfileWebsocketTokenrlrhandle_authenticater1 Exceptionreject) rHr\rr_rdfuturer@ authTokentokenrQrres rJrzwhitebit.authenticates} '')))it$% S!!&&77(  + +FGR @ @ @ F!/!/ 2"/$($5%)%6"&"5$($7 1   22%00   F67 # # # # #  rKc8|j}t|}tdt |D]S}||}|durE||d}|-||kr'||d} | | ||dSTdS)NrTrQra)r5rvaluesrjrkrWrV) rHrdrrrQsubsrhrsrsubIdras rJrcz#whitebit.handle_subscription_status}s#dkkmm$$q#f++&&  A!!9L4'')),==%ERKK!__\8DDF)vw///  rKc8||_|SN) millisecondslastPong)rHrdrrs rJrbzwhitebit.handle_pongs++--rKcddgdS)Nrr:r)rHrds rJr:z whitebit.pings   rKrl)2__name__ __module__ __qualname__rrGstrr rrrcrrwr rrrrrrr rrrrrrr rrrr rrrrrrr.rXrrrrFrrUrfrcrbr: __classcell__)rIs@rJrrs0 #0 0 0 0 0 0 d?CQUdhqsHHHH3H^aHx|~ByCHHHH>&6&&&&P@DB!!S!!S\!!!!<</</</</</|&&& 33368bbbFbbbb$6:"EE7EEEEE:-F----^<@d[]SSSSSSbfglbmSSSS.',F',',',',R37TX\egUUCUsURUUlpqvlwUUUU2,,v,,,,8))))V04$UYbdUUUCUsUimnsitUUUU2&1&16&1&1&1&1PUUUUn : : :*,QQQQQQ2!2V!2!2!2!2FAC2 H H H HW\df/^/^/^/^bBDB H H H H)+!!!!F&6t, $V $ $ $ $D     & 6        rKr)ccxt.async_supportccxt ccxt.async_support.base.ws.cacherrrccxt.base.typesrrrr r r r r rrr!ccxt.async_support.base.ws.clientrtypingrccxt.base.errorsrrrccxt.base.preciser async_supportrrprKrJrs/ ffffffffffllllllllllllllllllllllllll444444000000......''''''%%%%%%D D D D D t!*D D D D D rK