i%ddlZddlmZmZmZmZddlZddlZddl m Z m Z m Z m Z mZmZmZmZmZmZddlmZddlmZddlmZddlmZddlmZdd lmZGd d ejjZdS) N) ArrayCacheArrayCacheBySymbolByIdArrayCacheBySymbolBySideArrayCacheByTimestamp) BalancesIntOrder OrderBookPositionStrStringsTickerTickersTrade)Client)List) ExchangeError)AuthenticationError)ArgumentsRequired) BadRequestc eZdZfdZdZdddifdedefdZdZifded e fd Z difd e d e fd Z d efdZdddifdededed eefdZd efdZd3d efdZdifdeded efdZdifd eeded efdZd efdZdZdZddifdededed eefdZddifd eededed eefdZd efdZd3dZ dZ!dddifdededed eefdZ"d efd Z#dddifd e deded ee$fd!Z%d3d ed e fd"Z&d#Z'd$Z(dddifdededed ee)fd%Z*d efd&Z+d3d'Z,ifd e-fd(Z.d efd)Z/d3d*Z0ifd+Z1ifd,Z2d efd-Z3d efd.Z4d/Z5d efd0Z6d efd1Z7d efd2Z8xZ9S)4bybitc|tt|iddddddddddddd dd dd dd dd ddddddddddddddddddddddddddddddddidd d!d"d#d$d%d&dd%d'ddid(d)d*iddd+d,d-d.d/d0d1d2d3d4d5d6d7d8d9d: id,d;dd?d@dAdBdCdDdEdFdGd: idH|jdIdJdKS)LNwsT createOrderWsF editOrderWsfetchOpenOrdersWs fetchOrderWs cancelOrderWscancelOrdersWscancelAllOrdersWs fetchTradesWsfetchBalanceWs watchBalance watchMyTrades watchOHLCVwatchOHLCVForSymbolswatchOrderBookwatchOrderBookForSymbols watchOrders) watchTicker watchTickers watchTradeswatchPositionswatchTradesForSymbolsz&wss://stream.{hostname}/v5/public/spotz)wss://stream.{hostname}/v5/public/inversez(wss://stream.{hostname}/v5/public/optionz(wss://stream.{hostname}/v5/public/linear)spotinverseoptionlinearz"wss://stream.{hostname}/v5/privatez'wss://stream.{hostname}/spot/private/v3)unified nonUnifiedz4wss://stream.{hostname}/trade/option/usdc/private/v1)r0contractusdc)publicprivatez.wss://stream-testnet.{hostname}/v5/public/spotz1wss://stream-testnet.{hostname}/v5/public/inversez0wss://stream-testnet.{hostname}/v5/public/linearz0wss://stream-testnet.{hostname}/v5/public/option)r0r1r3r2z*wss://stream-testnet.{hostname}/v5/privatez/wss://stream-testnet.{hostname}/spot/private/v3zDD==fdFSSLD& ,,T\?KKM ..vxR_``M*f4M&.  31>c#m$V,,SEWXbEcCC 3-(0"&"A"A&&RXZb"c"c-(1-(2##C(( rgc6||gd}|S)N)rsrrqrt unifiedMargin)omit)rdr}s rf clean_paramszbybit.clean_paramss!6#b#b#bcc rgreturncK|d{V||}|d}d|z}||dd|}||}||jdi}||dd}|ds|dkrt|jd z|d |d zz }|g}| ||g||d{VS) a2 watches a price ticker, a statistical calculation with the information calculated over the past 24 hours for a specific market :see: https://bybit-exchange.github.io/docs/v5/websocket/public/ticker :see: https://bybit-exchange.github.io/docs/v5/websocket/public/etp-ticker :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 ` Nrnticker:Fr+r<r=r0z> watchTicker() only supports name tickers for contract markets.id) load_marketsrvrr safe_valuer_rxrr watch_topics) rdrnr}rv messageHashrr_topictopicss rf watch_tickerzbybit.watch_tickers !!!!!!!!!V$$!&( ))&%OO""6**//$, rBB  &)<<f~ i%9"4"4TW'gghh h vd|##&&s[M66JJJJJJJJJrgsymbolscK|d{V||dd}g}||ddd|}||}||jdi}||dd}||}g}tdt|D]C} || } | |dz| z| d|| zD| ||||d{V} |j ri} | | | d <| S| |jd |S) aB watches a price ticker, a statistical calculation with the information calculated over the past 24 hours for all markets of a specific list :see: https://bybit-exchange.github.io/docs/v5/websocket/public/ticker :see: https://bybit-exchange.github.io/docs/v5/websocket/public/etp-ticker :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,r<r=rrrn)rmarket_symbolsrrrr_rx market_idsrangelenappendr newUpdatesfilter_by_arrayr=) rdrr} messageHashesrr_r marketIdsrimarketIdtickerresults rf watch_tickerszbybit.watch_tickerss!!!!!!!!!%%gtU;; ))'!*e^VTT""6**//$,CC  &)<<OOG,, q#i..)) 9 9A |H MM%#+0 1 1 1  WQZ!7 8 8 8 8((mVVLLLLLLLL ? F'-F6(# $M##DL(GDDDrgclientcd||dd}||dd}||di}||ddu}|rdnd}d}d} |dkr||} | d }n|d kr|d } t | } || | d z } || dd|} | d }||j|i}||d i}|||}||} ||d}|| d<| || d<| |j|<d|z}| |j||dS)Nrrsdata usdIndexPricer0r6snapshotrndeltarrjinfots timestampdatetimer) rx safe_dict parse_tickersplitr safe_marketr=extendrliso8601resolve)rdrmessager updateTyperrrsrnparsed topicParts topicLengthrrvr rawTickermergedrrs rf handle_tickerzbybit.handle_tickersf  '266%%gvr:: ~~gvr22!!$88D/vvZ * $ $&&t,,FH%FF 7 " "S))Jj//K'' K!ODDH%%hdDAAFH%F^^DL&"==Fvvr::I[[D11F&&v..F%%gt44 '{!\\)44z% V&( t|F+[99999rgrAsincelimitcK|d{V||}|d}||dd|}||}d}||j||} d| zdz|dzg} d| zd z|z} ||| g| |d{V}|jr|||}| |||d d S) a watches historical candlestick data containing the open, high, low, and close price, and the volume of a market :see: https://bybit-exchange.github.io/docs/v5/websocket/public/kline :see: https://bybit-exchange.github.io/docs/v5/websocket/public/etp-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 NrnFr&zkline.rrkline::rT) rrvrrrxr@rrgetLimitfilter_by_since_limit) rdrn timeframerrr}rvrohlcv timeframeIdrrs rf watch_ohlcvzbybit.watch_ohlcvrs&!!!!!!!!!V$$!))&%vNN""6**&&t 9MM [(3.=>#k1C7&@ ''k]FFKKKKKKKK ? 2NN6511E))%q$GGGrgc||di}||d}|d}t|}||d}||}|||dz } |jddk} | rdnd} || dd| } | d} ||j| }| i|j| <|||}|;| |j d d }t|}||j| |<td t|D]2}| ||}||3d |zd z| z}|||dS)Nrrrrjr0r6rn OHLCVLimitrrr)rrxrrfind_timeframerfindrohlcvsrlr_rrparse_ws_ohlcvrr)rdrrrrrrrrrr marketTypervrnohlcvsByTimeframestoredrrrrs rf handle_ohlcvzbybit.handle_ohlcvs.w33  '22[[%% *oo &&z155 '' 44 ##J a@@((2-%5VV: !!(D$ CC! OODK@@  $"$DK !2I>> >%%dlL$GGE*511F-3DK  *q#d))$$ " "A((a11F MM& ! ! ! !#k1C7&@ v{+++++rgc ||d||d||d||d||d||ddgS)Nstartopenhighlowclosevolumeturnover)rl safe_number safe_number_2)rdrrvs rfrzbybit.parse_ws_ohlcvs"   eW - -   UF + +   UF + +   UE * *   UG , ,   uh ; ;   rgcBK||g||d{VS)aF watches information on open orders with bid(buy) and ask(sell) prices, volumes and other data :see: https://bybit-exchange.github.io/docs/v5/websocket/public/orderbook :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)watch_order_book_for_symbols)rdrnrr}s rfwatch_order_bookzbybit.watch_order_books466xOOOOOOOOOrgcXK|d{Vt|}|dkrt|jdz||}||ddd|}||}||d}| |drdnd}n7|ds/|d kr)|dkr#|d kr|dkrt|jd zg}g}tdt|D]f} || } | | } d t|zd z| z} | | d| z} | | g| ||||d{V}|S)a) watches information on open orders with bid(buy) and ask(sell) prices, volumes and other data :see: https://bybit-exchange.github.io/docs/v5/websocket/public/orderbook :param str[] symbols: unified array of symbols :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 NrzA watchOrderBookForSymbols() requires a non-empty array of symbolsFr(r02irjzB watchOrderBookForSymbols() can only use limit 1, 50, 200 and 500.z orderbook.r orderbook:)rrrrrrrrvrr market_idstrrrr)rdrrr} symbolsLengthrrvrrrrnrrr orderbooks rfrz"bybit.watch_order_book_for_symbolss!!!!!!!!!G A  #DG.q$qrr r%%g..))'!*e=MvVV""6**WQZ(( =!&>3BBEE&> uQJJUb[[u||%SV,,$TW/s%sttt q#g,,'' . .AQZF~~f--H 3u::-3h>E MM% &/K   - - - -++COOOOOOOO    rgc`|jddk}||d}|dk}||di}||d}|rdnd}||dd|} | d} ||d } ||j| } | |} |r/||| | d d } | | n||d g}||d g}| | d || | d || | d<| | | d<d| z}| |j| <| | |dS)Nr0rrsrrsr6rnrbaasksbidsrrr) rrrxrrrl orderbooks order_bookparse_order_bookreset handle_deltasrr)rdrrrrs isSnapshotrrrrvrnrrrrrrs rfhandle_order_bookzbybit.handle_order_booksD((A-00j( w33##D#..%5VV: !!(D$ CC!%%gt44 OODOV<<  ))I  <,,T69c3OOH OOH % % % %??4b11D??4b11D   y0$ 7 7 7   y0$ 7 7 7%.Ik "$(LL$;$;Ij !'&0 "+y+.....rgc^||dd}||dS)Nrrj) parse_bid_ask storeArray)rdbooksiderbidAsks rf handle_deltazbybit.handle_delta@s3##E1a00F#####rgc~tdt|D]}||||dS)Nr)rrr)rdrdeltasrs rfrzbybit.handle_deltasDsHq#f++&& 3 3A   hq 2 2 2 2 3 3rgcDK||g|||d{VS)a> watches information on multiple trades made in a market :see: https://bybit-exchange.github.io/docs/v5/websocket/public/trade :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)watch_trades_for_symbols)rdrnrrr}s rf watch_tradeszbybit.watch_tradesHs622F8UE6RRRRRRRRRrgcK|d{V||}t|}|dkrt|jdz||}||ddd|}g}g}tdt|D]Y} || } || } d| dz} | | d| z} | | Z| ||||d{V}|j rB| |d}| |d }|||}||||d d S) a+ get the list of most recent trades for a list of symbols :see: https://bybit-exchange.github.io/docs/v5/websocket/public/trade :param str[] symbols: 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 ` Nrz> watchTradesForSymbols() requires a non-empty array of symbolsFr-z publicTrade.rtrade:rnrT)rrrrrrrrrvrrrrrxrr)rdrrrr}rrrrrrnrvrrtradesfirst tradeSymbols rfrzbybit.watch_trades_for_symbolsTs!!!!!!!!!%%g..G A  #DG.n$noo o""6**))'!*e]FSS q#g,,'' . .AQZF[[((F"VD\1E MM% "V+K   - - - -((mVVLLLLLLLL ? 8OOFA..E**5(;;KOOK77E))&% TRRRrgc||di}||d}|}|d}|jddk}|rdnd}||d} || dd|} | d} ||j| } | 5||jd d } t| } | |j| <tdt|D]3}| ||| }| |4d | z}|| |dS) Nrrrr0rr6rjrn tradesLimitrr)rrxrrrrrrlr_rrrparse_ws_traderr)rdrrrrrpartsrrrrvrnrrjrrs rf handle_tradeszbybit.handle_tradesus_(w33  '22 C  ((A- &7VVZ ##E1--!!(D$ CC!f55 >%%dlM4HHE&&F"(DK q#f++&& " "A((F;;F MM& ! ! ! !#f, v{+++++rgcZ||gd}d|v}|rdnd}||d}||d}|||d|}|d}||dd }||d } d} ||d } | | rd nd } n| } ||d} ||dd} ||d}||||||||d| | | | ddd |S)N)rTvBTr6r0rsrrntrSmbuysellpqro) rrrrrnorderrsside takerOrMakerpriceamountcostfee) safe_string_nrxrsafe_integer_2safe_string_lowerrry safe_trader)rdtradervr isContractrrrnrrrrrrorderIds rfr zbybit.parse_ws_tradesu@   7 7em #-9ZZ6  J##E3//!!(FD*EE!''sC88 %%eS11 OOE3 ' ' <)556DDL  ,,##E344""5#.." Y//(    rgcr|ddkrdS|ddkrdSdS)Nr0rz v5/privater4r7)r)rdrs rfget_private_typezbybit.get_private_types? 88F  q 6 XXl # #q ( (96rgcKd}d}|d{V|||}|d|zz }||d||}||d{Vdddd }||||} |||g| g|d{V} |jr| ||}| | |||dS) a watches information on multiple trades made by the user :see: https://bybit-exchange.github.io/docs/v5/websocket/private/execution :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 :param boolean [params.unifiedMargin]: use unified margin account :returns dict[]: a list of [order structures]{@link https://docs.ccxt.com/#/?id=order-structure r%myTradesNrT ticketInfo executionuser.openapi.perp.trader0r4r7 rrnr authenticaterr(rrrfilter_by_symbol_since_limit) rdrnrrr}rorr topicByMarketrrs rfwatch_my_tradeszbybit.watch_my_tradess:! !!!!!!!!!  [[((F 3< 'K))&$GG$$$$$$$$$ "-   t/D/DS/I/IJJ(({meWfMMMMMMMM ? 3OOFE22E00tTTTrgc*||d}|dk}||dg}t|ts||dg}|j0||jdd}t||_|j}i}tdt|D][} || } d} |r| | } n| | } | d} d || <| | \t| } tdt| D]#} d | | z}|||$d }|||dS) Nrr+rrrrrrnTz myTrades:r*)rxr isinstancelistr*rlr_rrrr  parse_traderkeysr)rdrrrr0rrrrrrawTraderrnr8currentMessageHashrs rfhandle_my_tradeszbybit.handle_my_tradess~  '22 $w33$%% 7??4266D = %%dlM4HHE2599DMq#d))$$ " "AAwHF 4,,X66))(33H%F"GFO MM& ! ! ! !GLLNN##q#d))$$ 7 7A!,tAw!6  NN6#5 6 6 6 6 v{+++++rgcK|d{Vd}d}||s-||}dd|z}||d}||d||}d|z}||} ||d{V|| ||j } | dd d} | dd d} | r8| r6| 4| d d{V} | | |||dSd g}|||g||d{V}|jr|S| | |||dS) a :see: https://bybit-exchange.github.io/docs/v5/websocket/private/position watch all open positions :param str[] [symbols]: list of unified market symbols :param dict params: extra parameters specific to the exchange API endpoint :returns dict[]: a list of `position structure ` Nr.r::,rT positionsr>r?position)ris_emptyrjoinrxrrr0set_positions_cacher? handle_option safe_boolfuturefilter_by_symbols_since_limitrr)rdrrrr}ror firstSymbolrrcacher>r?rr newPositionss rfwatch_positionszbybit.watch_positionsbs!!!!!!!!!! }}W%% 3))'22G'!2!22K&&w22 ))+tVVLL!K/ S!!$$$$$$$$$   111!%!3!34DF^`d!e!e!%0@BZ\`!a!a ! ]&< ]#]]+CDDDDDDDDH55hPUW[\\ \!..s[M66RRRRRRRR ?  11%%PTUUUrgc|jdS|ddd}|r@d}||jvr3||||j||dSdSt |_dS)Nr.r>T)r?rDfuturesrFspawnload_positions_snapshotr)rdrrr>rs rfrCzbybit.set_positions_caches > % F!%!3!34DF^`d!e!e ! 82K6>11 k*** 47MMMMM21677DNNNrgcK|dddd|ddddg}tj|d{V}t|_|j}t dt |D]G}||}t dt |D]}||} ||  H|j|} | || |ddS)Nrur3)rsrr1rr@) fetch_positionsasynciogatherrr?rrrrMr) rdrrfetchFunctionspromisesrIrr?iir@rFs rfrOzbybit.load_positions_snapshots  8'L'L M M  9'M'M N N !8888888133q#h--(( ' 'A  IAs9~~.. ' '$R= X&&&& ' ,uuj)))))rgc|jt|_|j}g}||dg}tdt |D]}||}||}||d} ||| | dkr:d|d<||d|d<||d|d<||||d} tdt | D]}| |} | d} | d } | d }| |d |d }| |s| || | |d dS)Nrrrrlongshortz positions::r=rjr>rnFr?) r?rrrrparse_positionrxrfind_message_hashesrrrAr)rdrrrIrJ rawPositionsr rawPositionr@rrrr  symbolsStringrr?s rfhandle_positionszbybit.handle_positionssP > !577DN w;; q#l++,, ' 'A&q/K**;77H##Hf55D    ) ) )|trzz$*  X&&&#*  X&&&#'   X&&&&00GG q#m,,-- 7 7A'*K%%d++E!!HM#))#..G,,\8WeTTI==++ 7y+666|[11111rgcK|d{Vd}d}|||}|d|zz }||d||}||d{Vddgdgdgd }||||} |||g| |d{V} |jr| ||}| | |||dS) a? watches information on multiple orders made by the user :see: https://bybit-exchange.github.io/docs/v5/websocket/private/order :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]{@link https://docs.ccxt.com/#/?id=order-structure Nr*ordersrTr stopOrderzuser.openapi.perp.orderr.r/) rdrnrrr}rorrtopicsByMarketrras rf watch_orderszbybit.watch_orderssB!!!!!!!!!  [[((F 3< 'K))&$GG$$$$$$$$$k*y./   1F1Fs1K1KLL(({mVVLLLLLLLL ? 3OOFE22E00tTTTrgc:|j0||jdd}t||_|j}||dg}||di}||d}|dk}|s||d|}i} t dt|D]_} d} |r||| } n| || } | d} d | | <| | `t| } t dt| D]#} d | | z}| ||$d }| ||dS) N ordersLimitrrrcategoryr0rrnTzorders:ra)rarlr_rrrxrrparse_ws_spot_order parse_orderrr6r8r)rdrrrra rawOrdersrrgrrrrrn symbolsArrayr:rs rf handle_orderzbybit.handle_ordersh ; %%dlM4HHE077DKOOGVR88  1b11##E:66V# H 8YGGIq#i..)) " "AF 811)A,??)))A,77H%F"GFO MM& ! ! ! !GLLNN++ q#l++,, 7 7A!*\!_!<  NN6#5 6 6 6 6 v{+++++rgc v||dd}||dd}|||dd}||dd}||dd }|d krd}||d d }|||d d} ||dd} ||dd} ||dd} d} ||dd}||dd}||ddkrd}|dkr | dkr|} n||dd} d}||dd}|6|d kr0||d }||}||d!}|||d"}| id#|d$|d%||d&d'd(|d)| |d*| d|d+|d| d,dd| d |d-|d"|d.||d/d0||d1d2| |d2| |||d3|d| |d4|S)5Nrr&rrnr0O createdTimerr0z cumExecQtyX orderStatusrrE updatedTimef timeInForceZ cumExecValuer orderTypervrrorderQtyqtyn cumExecFeeN)rcurrency triggerPricerr clientOrderIdc orderLinkIdrrlastTradeTimestamprspostOnly stopPricetakeProfitPrice takeProfit stopLossPricestopLoss reduceOnlyavgPrice)rraveragefilled remainingstatusr) ry safe_symbolr!parse_order_statussafe_string_lower_2rrxsafe_currency_code omit_zero safe_orderrr)rdrrvrrrnrrrrrrrxrrrsrfeeCost feeCurrencyIdfeeCurrencyCoders rfrhzbybit.parse_ws_spot_orderwsR  sI 6 6%%eS(;;!!(FD&AA''sMBB ""5#w77 C<<E##E3 ==((););E3 )V)VWW''sF;;!//sMJJ((]CC !!%n==''sK@@  499X#6#6!#;#;D 8   FF''z5AAF$$UC>>  7c>> ,,UC88M"55mDDO+C~~d&6&6un&M&MNN  E "  T//sMJJ     Y//  !"4   f  D  ;    D  U    L  t//|DD T--eZ@@! " $//%>># $''z::1   2 3 rgcK|d{Vd}d}d}|dd|\}}d}|dd|\}}|d{V}||dd}||dd}|dd||} || d{Vdd d } |r|d kr|d z }n|d z }|s|s|dkr|dz }n|d z }|r|dkr|dz }n|dkr|d z }n|d z }|| || g} | | |g| |d{VS)am watch balance and get the amount of funds available for trading or funds locked in orders :see: https://bybit-exchange.github.io/docs/v5/websocket/private/wallet :param dict [params]: extra parameters specific to the exchange API endpoint :returns dict: a `balance structure ` Nr$balancesrFrjToutboundAccountInfowallet)r0r4r1z :contractz:unifiedr0z:spotr3) rrwrzisUnifiedEnabledrErr0rr(r) rdr}rorrsrr4isUnifiedMarginisUnifiedAccountrr2rs rf watch_balancezbybit.watch_balances!!!!!!!!! 99.$PVWW f99.$PVWW--////////..!U;;>>'1e<<))$ffEE$$$$$$$$$)    *)##{* z)  +'7 +v~~w& {*  /v~~w& h&&:-KK;.K//-1F1Fs1K1KLLM&&s[M66JJJJJJJJJrgc |ji|_d}||d}d}g}d}|dkrnd}||dg}tdt|D]5} ||| dg} ||| }6|}|dkr||di}tdt|D]Z} ||di} || d }|||| d g}[|}tdt|D]} ||| ||||j| i|j|<||j|d <||d } | |j|d <|| |j|d<| |j||j|<d|z}| |j||dS||jd <||d } | |jd <|| |jd<| |j|_d}| |j|dS)Nbalancerrr0rrBr accountTypecoinrrrrz balances:r) rrrr array_concatr"parse_ws_balancerlr safe_balancer) rdrrrrr rawBalancesaccountrrrrrs rfhandle_balancezbybit.handle_balance)s^ < DL 11  ) ) )G??7FB77D1c$ii(( @ @OODGS"55"// Q?? D H  ??7FB77D1c$ii(( b bq"5500GG"// T__VU[]_=`=`aa Dq#k**++ ; ;A  ! !+a.' : : : :  t|W55=(* W%,0DL !& )))'488I1:DL !+ .04 Y0G0GDL !* -$($5$5dl76K$L$LDL !%/K NN4<0+ > > > > >#'DL ))'488I(1DL %'+||I'>'>DL $,,T\::DL$K NN4< 5 5 5 5 5rgc|}||dd}||}||gd|d<||dd|d<||d|d <|7||j| i|j|<||j||<dS||j|<dS) Nrr)availableToWithdrawrwfreerrllockedused walletBalancetotal)rryrr rxrr)rdrrr currencyIdcodes rfrzbybit.parse_ws_balances4,,..''f== &&z22,,W6q6q6qrr,,Wc8DD++G_EE  "t|[99A,. [).5DL %d + + +!(DL   rgcKd||d}|||}|||||d{VS)N subscribe)opreq_idargs)rmrwatch_multiple)rdrrrr}requestrs rfrzbybit.watch_topics sfoo''   ++gv..((mWfMMMMMMMMMrgcFK|d}||}||}||j|}||dz}||}d} | |z} ||| ||j tj d} d|j || gd} | | |} |||| ||d{VS)N authenticatedi'z GET/realtimehexauth)rr)check_required_credentialsrrFr subscriptions millisecondsnumber_to_stringhmacencodesecrethashlibsha256apiKeyrwatch)rdrr}rrrFr expiresIntexpirespathr signaturerrs rfr0zbybit.authenticates" '')))% S!!{++(D $++d"3"3T[[5M5Mw~_deeIK)G kk'622G JJsK+ > > >||||||rgc||dd} |B|jdz||z}||jd||||d}|w|su||d}||di}||d}|d krtd |zt|jdz|zd S#t$r_} t| tr*d } | | | | |j vr|j | =n| | Yd} ~ d Sd} ~ wwxYw)Nrret_code exactsuccessret_msgrrrzAuthentication failed: FrT) ryrjsonthrow_exactly_matched_exception exceptionsrrxrr Exceptionr5rejectr) rdrrrfeedbackrrrrerrorrs rfhandle_error_messagezbybit.handle_error_message(s~4!!'6:>> 7S=499W+=+==44T_W5MtU]^^^oogy99G"7"**7I>>//'9bAA%%gt44<<-.G'.QRRR'# (?@@@5   %!455 %-  e[111&"666,[9 e$$$44444 sCC.. E8AEEch|||rdS||d}|dkr|||dS||d}||||dS||d}|dkr|||dS||d}|dkr|||dS||dd}|j|j|j|j|j|j |j |j|j |j |j |j |j |j d}| ||} | | ||dSt|} t!d t#| D]@} | | } || | d kr|| } | ||dSA||d }|d ks|d kr|||dSdS) Nrpongreventsubrr)rklinerrbrr$ publicTradedepthrrr,r+r-r@rrsr AUTH_RESP)rrx handle_pongrlhandle_subscription_statusrrrlrr rr;r_rr6r8rrrhandle_authenticate)rdrrrrrrrmethods exacMethodr8rkeyrorss rfhandle_messagezbybit.handle_message[sx  $ $VW 5 5  F""7I66 f     VW - - - F  &11     VW - - - F   gt , , <<   VW - - - F  '22 E>>  + +FG < < < F  '266/&&*('-+)#'#6./'+'<-   __We44  ! Jvw ' ' ' FGLLNN##q#d))$$  Aq'Czz$q'""a'' vw'''( 00 &LLdk11  $ $VW 5 5 5 5 521rgc0|ddS)Nr[)rr)rm)rdrs rfr[z bybit.pings!oo''   rgc<||d|_|S)Nr)rllastPongrdrrs rfrzbybit.handle_pongs ++GV<<rgcD||d}d}|r1||j|}|dnTt|jdz||z}|||||jvr|j|=|S)NrrTr)rrMrrrrrr)rdrrrrrFrs rfrzbybit.handle_authenticates//'955%  6__V^[AAF NN4 '#  '8J8J(JKKE MM% - - -f222(5rgc|SNrs rfrz bybit.handle_subscription_statuss rgr):__name__ __module__ __qualname__rcrmr rrrrrr rrrrrrr6rrrr rrrrrrrrr r r(r3r;r rKrCrOr_r rdrlrhrrrrrr0rrr[rrr __classcell__)res@rfrrs!o o o o o b 485X\egSRU@68KKKFKKKK.6:"EE7EEEEE:M:FM:M:M:M:^8<$]ajlHHHCHWZHquvzq{HHHH4.,6.,.,.,.,`  D    2@DB P PS P PS\ P P P PSW_a"!"!$s)"!C"!fo"!"!"!"!H:/:/:/:/:/x$$$333<@d[] S S SS S Sbfglbm S S S SOSaenpSSd3iSS[^SuyzvASSSSB&,F&,&,&,&,PBBBBH37TX\egUUCUsURUUlpqvlwUUUUrse AAAAAAAAAAAAkkkkkkkkkkkkkkkkkkkkkkkk444444******000000......''''''wwwwwD  $wwwwwrg