eiUddlZddlmZmZmZmZddlZddlZddl m Z m Z m Z m Z mZmZmZmZmZmZmZmZmZmZmZmZddlmZddlmZddlmZddlm Z ddlm!Z!dd lm"Z"dd lm#Z#Gd d ej$j%Z%dS) N) ArrayCacheArrayCacheBySymbolByIdArrayCacheBySymbolBySideArrayCacheByTimestamp)AnyBalancesBoolInt LiquidationNumOrder OrderBook OrderSide OrderTypePositionStrStringsTickerTickersTrade)Client)List) ExchangeError)AuthenticationError)ArgumentsRequired) BadRequest) NotSupportedc DeZdZdeffd ZdZdddifdedefdZd Zdifde d e d e d e d e f dZddifde de d e d e d e d e f dZdifde defdZifde defdZdifdedefdZdifdedefdZifde defdZdefdZdifdedefdZdTdZdddifde de dededeef dZddifd eee dedefd!Z ifd eee defd"Z!difde de defd#Z"defd$Z#dTdefd%Z$difde dede%fd&Z&difdee dede%fd'Z'ifdee defd(Z(ifde defd)Z)defd*Z*d+Z+d,Z,ddifde dededee-fd-Z.ddifdee dededee-fd.Z/ifdee defd/Z0ifde defd0Z1defd1Z2dTd2Z3d3Z4dddifdedededee-fd4Z5difdedefd5Z6defd6Z7dddifdedededee8fd7Z9dTdedefd8Z:d9Z;d:Zfd<Z?defd=Z@dTd>ZAdddifdedededeeBfd?ZCdifdedefd@ZDdefdAZEdefdBZFifdeGfdCZHdefdDZIdTdEZJifdFZKiifdGe dHe dedIee dJee f dKZLifdLZMdedeNfdMZOdefdNZPdefdOZQdefdPZRdefdQZSdefdRZTdefdSZUxZVS)UbybitreturncD|tt|iddddddddddddd dd dd dd dd dddddddddddddiddddddddddddddddddddddddd dd!dd"dd#dd$dddddd%dd&d'd(d)d*d+d,d-d+d.d/d0d1idd2d3d4d5d6d7d8d-d7d9d:d0d1idd&d'd(d)d*d;dd0d1id?d@dAidddBdCgdDidEdFdGdHdIdJdKdLdMdNdOdPdQdRdS idEdTdUdVdWdXdYdZd[d\d]d^d_d`dS ida|jdbdcddS)eNwsT createOrderWs editOrderWsfetchOpenOrdersWsF fetchOrderWs cancelOrderWscancelOrdersWscancelAllOrdersWs fetchTradesWsfetchBalanceWs watchBalance watchBidsAskswatchLiquidationswatchLiquidationsForSymbolswatchMyLiquidationswatchMyLiquidationsForSymbols watchMyTrades watchOHLCVwatchOHLCVForSymbolswatchOrderBookwatchOrderBookForSymbols watchOrders watchTicker watchTickers watchTradeswatchPositionswatchTradesForSymbols unWatchTickerunWatchTickers unWatchOHLCVunWatchOHLCVForSymbolsunWatchOrderBookunWatchOrderBookForSymbols unWatchTrades)unWatchTradesForSymbolsunWatchMyTrades unWatchOrdersunWatchPositionsz&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/v1zwss://stream.bybit.com/v5/trade)rHcontractusdctrade)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)rHrIrKrJz*wss://stream-testnet.{hostname}/v5/privatez/wss://stream-testnet.{hostname}/spot/private/v3zDD==fdFSSLD& ,,T\?KKM ..vxR_``M*f4M&.  3 1133333333G"nnWa??O#~~gq%@@  5_ 5=M 5-(0-(4 3-(0&..dh&6&6"&"A"A&&RXZb"c"c-(1-(2##C(( rc6||gd}|S)N)rrrr unifiedMargin)omit)rrs r clean_paramszbybit.clean_paramss!6#b#b#bcc rrsideamountpricec K|d{V|||||||d}|jdddd}||d{Vt |} d| |gt |t |jdd d } ||| | | dd{VS) a create a trade order https://bybit-exchange.github.io/docs/v5/order/create-order https://bybit-exchange.github.io/docs/v5/websocket/trade/guideline#createamendcancel-order :param str symbol: unified symbol of the market to create an order in :param str type: 'market' or 'limit' :param str side: 'buy' or 'sell' :param float amount: how much of currency you want to trade in units of base currency :param float [price]: the price at which the order is to be fulfilled, in units of the quote currency, ignored in market orders :param dict [params]: extra parameters specific to the exchange API endpoint :param str [params.timeInForce]: "GTC", "IOC", "FOK" :param bool [params.postOnly]: True or False whether the order is post-only :param bool [params.reduceOnly]: True or False whether the order is reduce-only :param str [params.positionIdx]: *contracts only* 0 for one-way mode, 1 buy side of hedged mode, 2 sell side of hedged mode :param boolean [params.isLeverage]: *unified spot only* False then spot trading True then margin trading :param str [params.tpslMode]: *contract only* 'full' or 'partial' :param str [params.mmp]: *option only* market maker protection :param str [params.triggerDirection]: *contract only* the direction for trigger orders, 'above' or 'below' :param float [params.triggerPrice]: The price at which a trigger order is triggered at :param float [params.stopLossPrice]: The price at which a stop loss order is triggered at :param float [params.takeProfitPrice]: The price at which a take profit order is triggered at :param dict [params.takeProfit]: *takeProfit object in params* containing the triggerPrice at which the attached take profit order will be triggered :param float [params.takeProfit.triggerPrice]: take profit trigger price :param dict [params.stopLoss]: *stopLoss object in params* containing the triggerPrice at which the attached stop loss order will be triggered :param float [params.stopLoss.triggerPrice]: stop loss trigger price :param str [params.trailingAmount]: the quote amount to trail away from the current market price :param str [params.trailingTriggerPrice]: the price to trigger a trailing order, default uses the price argument :returns dict: an `order structure ` NTrSr"rRrP order.create recvWindowzX-BAPI-TIMESTAMPzX-BAPI-RECV-WINDOWopreqIdargsheader) load_marketscreate_order_requestr| authenticatestrr millisecondsr}watch) rrrrrrr orderRequestrrrequests rcreate_order_wszbybit.create_order_wss#@!!!!!!!!!00tVUTZ\`aa it$Y/8$$$$$$$$$))**  %((9(9(;(;$<$<&)$,|*D&E&E   ZZYDIIIIIIIIIridc K|d{V||||||||}|jdddd} || d{Vt |} d| |gt |t |jddd } || | | | d d{VS) a edit a trade order https://bybit-exchange.github.io/docs/v5/order/amend-order https://bybit-exchange.github.io/docs/v5/websocket/trade/guideline#createamendcancel-order :param str id: cancel order id :param str symbol: unified symbol of the market to create an order in :param str type: 'market' or 'limit' :param str side: 'buy' or 'sell' :param float amount: how much of currency you want to trade in units of base currency :param float price: the price at which the order is to be fulfilled, in units of the quote currency, ignored in market orders :param dict [params]: extra parameters specific to the exchange API endpoint :param float [params.triggerPrice]: The price that a trigger order is triggered at :param float [params.stopLossPrice]: The price that a stop loss order is triggered at :param float [params.takeProfitPrice]: The price that a take profit order is triggered at :param dict [params.takeProfit]: *takeProfit object in params* containing the triggerPrice that the attached take profit order will be triggered :param float [params.takeProfit.triggerPrice]: take profit trigger price :param dict [params.stopLoss]: *stopLoss object in params* containing the triggerPrice that the attached stop loss order will be triggered :param float [params.stopLoss.triggerPrice]: stop loss trigger price :param str [params.triggerBy]: 'IndexPrice', 'MarkPrice' or 'LastPrice', default is 'LastPrice', required if no initial value for triggerPrice :param str [params.slTriggerBy]: 'IndexPrice', 'MarkPrice' or 'LastPrice', default is 'LastPrice', required if no initial value for stopLoss :param str [params.tpTriggerby]: 'IndexPrice', 'MarkPrice' or 'LastPrice', default is 'LastPrice', required if no initial value for takeProfit :returns dict: an `order structure ` NrSr"rRrP order.amendrrrT) redit_order_requestr|rrrrr}r) rrrrrrrrrrrrs r edit_order_wszbybit.edit_order_wss!4!!!!!!!!!..r64vuV\]] it$Y/8$$$$$$$$$))** %((9(9(;(;$<$<&)$,|*D&E&E   ZZYDIIIIIIIIIrc K|d{V|t|jdz||||}|jdddd}||d{Vt |}d|vr|d=d||gt |t |j d d d }| ||||d d{VS) a cancels an open order https://bybit-exchange.github.io/docs/v5/order/cancel-order https://bybit-exchange.github.io/docs/v5/websocket/trade/guideline#createamendcancel-order :param str id: order id :param str symbol: unified symbol of the market the order was made in :param dict [params]: extra parameters specific to the exchange API endpoint :param boolean [params.trigger]: *spot only* whether the order is a trigger order :param str [params.orderFilter]: *spot only* 'Order' or 'StopOrder' or 'tpslOrder' :returns dict: An `order structure ` Nz+ cancelOrderWs() requires a symbol argumentrSr"rRrP orderFilter order.cancelrrrT) rrrcancel_order_requestr|rrrrr}r)rrrrrrrrs rcancel_order_wszbybit.cancel_order_wsAsF!!!!!!!!! >#DG.[$[\\ \00VVDD it$Y/8$$$$$$$$$))** L ( (]+ %((9(9(;(;$<$<&)$,|*D&E&E   ZZYDIIIIIIIIIrcK|d{V||}|d}d|z}||dd|d{V}||}||jdi}||dd}|ds|dkrt|jd z|d |d zz }|g}| ||g||d{VS) a& watches a price ticker, a statistical calculation with the information calculated over the past 24 hours for a specific market https://bybit-exchange.github.io/docs/v5/websocket/public/ticker 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 ` Nrticker:Fr8rVrWrHz> watchTicker() only supports name tickers for contract markets.r) rrrr safe_valuer}rrr watch_topics) rrrr messageHashrr}topictopicss r watch_tickerzbybit.watch_tickeres2!!!!!!!!!V$$!&( //}fUUUUUUUU""6**//$, rBB  &)<<f~ i%9"4"4TW'gghh h vd|##&&s[M66JJJJJJJJJrsymbolscK|d{V||dd}g}||ddd|d{V}||}||jdi}||dd}||}g}tdt|D]C} || } | |dz| z| d|| zD| ||||d{V} |j ri} | | | d <| S| |jd |S) a6 watches a price ticker, a statistical calculation with the information calculated over the past 24 hours for all markets of a specific list https://bybit-exchange.github.io/docs/v5/websocket/public/ticker 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 ` NFrr9rVrWrrr)rmarket_symbolsrrrr}r market_idsrangelenappendr newUpdatesfilter_by_arrayrW) rrr messageHashesrr}r marketIdsrimarketIdtickerresults r watch_tickerszbybit.watch_tickers~s!!!!!!!!!%%gtU;; // E>SYZZZZZZZZ""6**//$,CC  &)<<OOG,, q#i..)) 9 9A |H MM%#+0 1 1 1  WQZ!7 8 8 8 8((mVVLLLLLLLL ? F'-F6(# $M##DL(GDDDrc K|d{V||dd}||jdi}||dd}g}g}||}g}t dt|D]]} || } || } ||dz| z|d| z|d | z^| |ddd|d{V} | | d |||||d{VS) a unWatches a price ticker https://bybit-exchange.github.io/docs/v5/websocket/public/ticker 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 ` NFr9rVrWrrrzunsubscribe:ticker:r) rrrr}rrrrrrun_watch_topics) rrrr}rrsubMessageHashesrrrrrrs run_watch_tickerszbybit.un_watch_tickerss{!!!!!!!!!%%gtU;;//$,CC  &)<< OOG,, q#i..)) A AA |HQZF MM%#+0 1 1 1  # #I$6 7 7 7  !6!? @ @ @ @// E>SYZZZZZZZZ))#x-QacikqrrrrrrrrrrctK|d{V||g|d{VS)a unWatches a price ticker https://bybit-exchange.github.io/docs/v5/websocket/public/ticker 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 ` N)rrrrrs run_watch_tickerzbybit.un_watch_tickersV!!!!!!!!!**F8V<<<<<<<<` NFrr-z orderbook.1.bidask:r) rrrrrrrrrrrbidsasks) rrrrrrrrrrrs rwatch_bids_askszbybit.watch_bids_asksVsY!!!!!!!!!%%gtU;; // E?TZ[[[[[[[[""6**OOG,, q#i..)) 9 9A |H"X-E MM%  WQZ!7 8 8 8 8((mVVLLLLLLLL ? M##DM8WEEErc V||d}|||dd}|||dd}||dg}||dg}||d|||||d||d||d||d|d|S)Nrbidsrasksrr)rrrask askVolumebid bidVolumer)rsort_by aggregate safe_list safe_tickerr safe_number)r orderbookrrr r bestBidbestAsks rparse_ws_bid_askzbybit.parse_ws_bid_askqs%%i== ||DNN9V+<==qAA||DNN9V+<==qAA..q"--..q"--X&" Y//##GQ//))'155##GQ//))'155 ! !     rr_ timeframesincelimitcnKd|d<|||gg|||d{V}|||S)a watches historical candlestick data containing the open, high, low, and close price, and the volume of a market https://bybit-exchange.github.io/docs/v5/websocket/public/kline 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 r3callerMethodNameN)watch_ohlcv_for_symbols)rrrrrrrs r watch_ohlcvzbybit.watch_ohlcvsW&2!"33fi5H4I5RWY_````````f~i((rsymbolsAndTimeframeschK|d{V||d}||dddd}|d}||dd|d{V}g} g} t dt |D]} || } || d} || }|d} || d}||j||}| d|zd z|d z| d | zd z|z| || | |d{V\}}}|j r| ||}| |||dd}||||S) a watches historical candlestick data containing the open, high, low, and close price, and the volume of a market https://bybit-exchange.github.io/docs/v5/websocket/public/kline https://bybit-exchange.github.io/docs/v5/websocket/public/etp-kline :param str[][] symbolsAndTimeframes: array of arrays containing unified symbols and timeframes to fetch OHLCV data for, example [['BTC/USDT', '1m'], ['LTC/USDT', '5m']] :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 dict: A list of candles ordered, open, high, low, close, volume NrFTr4rrkline.rrohlcv::::)rget_list_from_object_valuesrrrrrrr^rrrgetLimitfilter_by_since_limitcreate_ohlcv_object)rr!rrrr marketSymbols firstSymbolr rawHashesrrr symbolStringrunfiedTimeframe timeframeIdrrstoredfiltereds rrzbybit.watch_ohlcv_for_symbolss!!!!!!!!!223GKK++GT5$MM #A& // UDZ\bcccccccc  q#23344 T TA'*D++D!44L[[..F!(+L"..tQ77O**4?O_]]K   X 3c9F4LH I I I  \!9D!@?!R S S S S*.*;*;CPY[a*b*b$b$b$b$b$b$b! 6 ? 3OOFE22E--feUAtLL'' 8DDDrc K|d{V||d}||dddd}|d}||dd|d{V}g}g}g} t dt |D]} || } || d} || } | d} || d}||j||}| d|zd z| d z| d | zd z|z| d | zd z|zd|i}| |d|| ||||d{VS)ap unWatches historical candlestick data containing the open, high, low, and close price, and the volume of a market https://bybit-exchange.github.io/docs/v5/websocket/public/kline https://bybit-exchange.github.io/docs/v5/websocket/public/etp-kline :param str[][] symbolsAndTimeframes: array of arrays containing unified symbols and timeframes to fetch OHLCV data for, example [['BTC/USDT', '1m'], ['LTC/USDT', '5m']] :param dict [params]: extra parameters specific to the exchange API endpoint :returns dict: A list of candles ordered, open, high, low, close, volume NrFTr4rrr#rrr$r%zunsubscribe::ohlcv::r!ohlcv) rr&rrrrrrr^rr)rr!rrr*r+rr,rrrrr-rr.r/ subExtensions run_watch_ohlcv_for_symbolsz bybit.un_watch_ohlcv_for_symbolss!!!!!!!!!223GKK++GT5$MM #A& // UDZ\bcccccccc  q#23344 a aA'*D++D!44L[[..F!(+L"..tQ77O**4?O_]]K   X 3c9F4LH I I I  # #I $` indexed by market symbols N)watch_order_book_for_symbols)rrrrs rwatch_order_bookzbybit.watch_order_book2s466xOOOOOOOOOrcK|d{Vt|}|dkrt|jdz||}||ddd|d{V}||}||d}| d}|drd}nxgd d dggd d }|||d d }| ||s9t|jdz|d zdz| |zg} g} tdt|D]f} || } | | } dt|zdz| z}| |d| z}| |g||| | |d{V}|S)a# watches information on open orders with bid(buy) and ask(sell) prices, volumes and other data 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 symbolsFr52rJd)rrQr;)rHrJdefaultrrUz! watchOrderBookForSymbols(): for z markets limit can be one of: orderbook.r orderbook:)rrrrrrrr safe_list_2in_arrayrjsonr market_idrrrr)rrrr symbolsLengthrrlimitsselectedLimitsrrrrrrrrs rrNz"bybit.watch_order_book_for_symbols?so!!!!!!!!!G A  #DG.q$qrr r%%g..// ECSU[\\\\\\\\""6**WQZ(( =Eh +**s)---F "--ffVniPPN==77 ` +N!NQWX^Q_!_cC"CFJFOFOP^F_F_"_``` q#g,,'' . .AQZF~~f--H 3u::-3h>E MM% &/K   - - - -++COOOOOOOO    rc K|d{V||dd}d}||d}|||d}n'||d}|drdnd}|t |z }g}g}g}t dt|D]t} || } || } | d } |d z| z} |d | z|d | z|| u| |ddd |d{V}| |d|||||d{VS)a unsubscribe from the orderbook channel https://bybit-exchange.github.io/docs/v5/websocket/public/orderbook :param str[] symbols: unified symbol of the market to unwatch the trades for :param dict [params]: extra parameters specific to the exchange API endpoint :param int [params.limit]: orderbook limit, default is None :returns dict: A dictionary of `order book structures ` indexed by market symbols NFrVrrrHrQirrzunsubscribe:orderbook:rWr5r) rrrrrrrrrrr)rrrchannelr firstMarketrrrrrrrrrs run_watch_order_book_for_symbolsz%bybit.un_watch_order_book_for_symbolsks!!!!!!!!!%%gtU;;!!&'22  YYvw//FF++gaj11K%f-6BB3E3u:: q#g,,'' ! !AQZF[[((Fd|HcMH,E  !9F!B C C C  # #L6$9 : : : MM% // ECSU[\\\\\\\\))#{G]TdflntuuuuuuuuurctK|d{V||g|d{VS)a unsubscribe from the orderbook channel https://bybit-exchange.github.io/docs/v5/websocket/public/orderbook :param str symbol: symbol of the market to unwatch the trades for :param dict [params]: extra parameters specific to the exchange API endpoint :param int [params.limit]: orderbook limit, default is None :returns dict: A dictionary of `order book structures ` indexed by market symbols N)rrbrs run_watch_order_bookzbybit.un_watch_order_booksV!!!!!!!!!996(FKKKKKKKKKrct||d}|dd}|jddk}||d}|dk}||di}||d } |rdnd } || dd| } | d } ||d } | |jvr||j| <|j| }| |d <|r/| || | d d}| |n| |dg}| |d g}| |d|| |d|| |d<| | |d<d| z}||j| <||||dkrM||j| | }i}||| <||j| <||d| zdSdS)NrrrrHrrrrsrNrrbar r rrrWrlr)rrrr=rrr orderbooks order_bookparse_order_bookresetr handle_deltasrrrr)rrrrrrr isSnapshotrrr@rrrrrr r rbidask newBidsAskss rhandle_order_bookzbybit.handle_order_booksXD  '22 C  #((A-00j( ~~gvr22##D#..%5VV: !!(D$ CC!%%gt44 $/))&*oo&7&7DOF #OF+ $ (  <,,T69c3OOH OOH % % % %>>$R00D>>$R00D   y0$ 7 7 7   y0$ 7 7 7%.Ik "$(LL$;$;Ij !'&0 "+y+... C<<**4?6+BFKKF "K"(K $*DM& ! NN; F(: ; ; ; ; ; ` N)watch_trades_for_symbols)rrrrrs r watch_tradeszbybit.watch_tradess622F8UE6RRRRRRRRRrc$K|d{V||}t|}|dkrt|jdz||}||ddd|d{V}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 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: publicTrade.rtrade:rrT)rrrrrrrrrrrrrrr'r()rrrrrr\rrrrrrrrtradesfirst tradeSymbols rr{zbybit.watch_trades_for_symbolss!!!!!!!!!%%g..G A  #DG.n$noo o""6**// E=RXYYYYYYYY q#g,,'' . .AQZF[[((F"VD\1E MM% "V+K   - - - -((mVVLLLLLLLL ? 8OOFA..E**5(;;KOOK77E))&% TRRRrc K|d{V||ddd}||ddd|d{V}g}g}g}tdt |D]q}||}||} d| dz} || d|z} || |d |zr||d |||||d{VS) a] unsubscribe from the trades channel https://bybit-exchange.github.io/docs/v5/websocket/public/trade :param str[] symbols: unified symbol of the market to unwatch the trades for :param dict [params]: extra parameters specific to the exchange API endpoint :returns any: status of the unwatch request NFTrrDr~rzunsubscribe:trade:rr)rrrrrrrr) rrrrrrrrrrrrs run_watch_trades_for_symbolsz!bybit.un_watch_trades_for_symbolssN!!!!!!!!!%%gtUDAA// EC\^deeeeeeee q#g,,'' 7 7AQZF[[((F"VD\1E MM% .7K   - - -  # #Hv$5 6 6 6 6))#x-QacikqrrrrrrrrrrctK|d{V||g|d{VS)aZ unsubscribe from the trades channel https://bybit-exchange.github.io/docs/v5/websocket/public/trade :param str symbol: unified symbol of the market to unwatch the trades for :param dict [params]: extra parameters specific to the exchange API endpoint :returns any: status of the unwatch request N)rrrs run_watch_tradeszbybit.un_watch_trades4sV!!!!!!!!!55vhGGGGGGGGGrc||di}||d}|}|d}|jddk}|rdnd}||d} || dd|} | d} ||j| } | 5||jd d } t| } | |j| <tdt|D]3}| ||| }| |4d | z}|| |dS) NrrrrHrrNrr tradesLimitr;r)rrrrr=rrrr}rrrparse_ws_traderr)rrrrrrpartsrr@rrrr0rjrrs r handle_tradeszbybit.handle_tradesAs_(w33  '22 C  ((A- &7VVZ ##E1--!!(D$ CC!f55 >%%dlM4HHE&&F"(DK q#f++&& " "A((F;;F MM& ! ! ! !#f, v{+++++rcZ||gd}d|v}|rdnd}||d}||d}|||d|}|d}||dd }||d } d} ||d } | | rd nd } n| } ||d} ||dd} ||d}||||||||d| | | | ddd |S)N)rTvBTrNrHrrfrtrSmbuysellpqro) rrrrrorderrr takerOrMakerrrcostfee) safe_string_nrrsafe_integer_2safe_string_lowerrr safe_trader)rrPrr isContractr@rrrrrrrrorderIds rrzbybit.parse_ws_tradeisu@   7 7em #-9ZZ6  J##E3//!!(FD*EE!''sC88 %%eS11 OOE3 ' ' <)556DDL  ,,##E344""5#.." Y//(    rcr|ddkrdS|ddkrdSdS)NrHrz v5/privaterLrO)r=)rrs rget_private_typezbybit.get_private_types? 88F  q 6 XXl # #q ( (96rc>Kd}d}|d{V|||}|d|zz }||d||d{V}||d{Vdddd }||||} d } ||dd d \} }| rd } |||g| g|d{V} |jr| ||}| | |||dS) a watches information on multiple trades made by the user https://bybit-exchange.github.io/docs/v5/websocket/private/execution https://bybit-exchange.github.io/docs/v5/websocket/private/fast-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 :param boolean [params.executionFast]: use fast execution :returns dict[]: a list of `order structures ` r2myTradesN:T ticketInfo executionuser.openapi.perp.traderHrLrOF executionFastexecution.fast) rrrrrrhandle_option_and_paramsrrr'filter_by_symbol_since_limit) rrrrrrrr topicByMarketrrrs rwatch_my_tradeszbybit.watch_my_tradess~! !!!!!!!!!  [[((F 3< 'K//ffMMMMMMMM$$$$$$$$$ "-   t/D/DS/I/IJJ $ = =foWfhm n n v  %$E(({meWfMMMMMMMM ? 3OOFE22E00tTTTrc Kd}d}d}|d{V|t|jdz||d||d{V}||d{Vddd d }||||}d } ||dd d \} }| rd }||dg|g|g|g|d{VS)a unWatches information on multiple trades made by the user https://bybit-exchange.github.io/docs/v5/websocket/private/execution https://bybit-exchange.github.io/docs/v5/websocket/private/fast-execution :param str symbol: unified market symbol of the market orders were made in :param dict [params]: extra parameters specific to the exchange API endpoint :param boolean [params.unifiedMargin]: use unified margin account :param boolean [params.executionFast]: use fast execution :returns dict[]: a list of `order structures ` r2zunsubscribe:myTradesrNzV unWatchMyTrades() does not support a symbol parameter, you must unwatch all my tradesTrrrrFrr) rrrrrrrrr) rrrrrsubHashrrrrs run_watch_my_tradeszbybit.un_watch_my_tradess\!, !!!!!!!!!  tw*B BCC C//ffMMMMMMMM$$$$$$$$$ "-   t/D/DS/I/IJJ $ = =foWfhm n n v  %$E))#z2 }wiZ_Y`bhiiiiiiiiirc||d}|dk}|dk}||dg}t|ts||dg}|j0||jdd}t||_|j}i} |dd g} td t|D]} || } d} |r|s| | } nG|| d d }|rd }| || sX| | } | d}d| |<|| t| }td t|D]#} d|| z}|||$d}|||dS)Nrrrrrrr;r2rZrexecTyperrrTz myTrades:r)rr isinstancelistrrr}r handle_optionrrrrY parse_traderkeysr)rrrrrHrrrrrrZrrawTraderrrrcurrentMessageHashrs rhandle_my_tradeszbybit.handle_my_tradessj  '22 $!11 w33$%% 7??4266D = %%dlM4HHE2599DM,,_>OQSTTq#d))$$ " "AAwHF 4M 4,,X66 ++Hj"EE '&H}}X??))(33H%F"GFO MM& ! ! ! !GLLNN##q#d))$$ 7 7A!,tAw!6  NN6#5 6 6 6 6 v{+++++rc*K|d{Vd}d}||s-||}dd|z}||d}||d||d{V}d|z}||} ||d{V|| ||j } | dd d} | dd d} | r8| r6| 4| d d{V} | | |||dSd g}| ||g||d{V}|jr|S| | |||dS) a https://bybit-exchange.github.io/docs/v5/websocket/private/position watch all open positions :param str[] [symbols]: list of unified market symbols :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 ` Nr;rr%,rT positionsrXrYposition)ris_emptyrjoinrrrrset_positions_cacherrrfilter_by_symbols_since_limitrr)rrrrrrrr+rrcacherXrYrr newPositionss rwatch_positionszbybit.watch_positionsus!!!!!!!!!! }}W%% 3))'22G'!2!22K&&w22 // T66RRRRRRRR!K/ S!!$$$$$$$$$   111!%!3!34DF^`d!e!e!%!3!34DF^`d!e!e ! ]&< ]#]]+CDDDDDDDDH55hPUW[\\ \!..s[M66RRRRRRRR ?  11%%PTUUUrc|jdS|ddd}|r@d}||jvr3||||j||dSdSt |_dS)Nr;rXT)rrfuturesrspawnload_positions_snapshotr)rrrrXrs rrzbybit.set_positions_caches > % F!%!3!34DF^`d!e!e ! 82K6>11 k*** 47MMMMM21677DNNNrcK|dddd|ddddg}tj|d{V}t|_|j}t dt |D]G}||}t dt |D]}||} ||  H||jvr:|j|} | || |ddSdS)NrrK)rrrIrr) fetch_positionsasynciogatherrrrrrrr) rrrfetchFunctionspromisesrrriirrs rrzbybit.load_positions_snapshots2  8'L'L M M  9'M'M N N !8888888133q#h--(( ' 'A  IAs9~~.. ' '$R= X&&&& ' &. ( (^K0F NN5 ! ! ! NN5* - - - - - ) (rc|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%rrrFr) rrrrrparse_positionrrfind_message_hashesrrrr)rrrrr rawPositionsr rawPositionrrrrr symbolsStringrrs rhandle_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|[11111rc \K|d{Vd}d}d}||st|jdz|dd||d{V}||d{Vdg}||d||g|g||d{VS)aE unWatches all open positions https://bybit-exchange.github.io/docs/v5/websocket/private/position :param str[] [symbols]: list of unified market symbols :param dict [params]: extra parameters specific to the exchange API endpoint :returns dict: status of the unwatch request Nr;zunsubscribe:positionsrzT unWatchPositions() does not support a symbol parameter, you must unwatch all ordersTr)rrrrrrr)rrrrrrrrs run_watch_positionszbybit.un_watch_positionss!!!!!!!!!!- }}W%% Atw)AA A//dFFKKKKKKKK$$$$$$$$$))#{Gk]U\T]_egmnnnnnnnnnrcK|d{V||}|d}||dd|d{V}||}d}||ddd\}}d|z}|dz|d z} |||g| g|d{V} |jr| S||j|g||d S) a watch the public liquidations of a trading pair https://bybit-exchange.github.io/docs/v5/websocket/public/all-liquidation :param str symbol: unified CCXT market symbol :param int [since]: the earliest time in ms to fetch liquidations for :param int [limit]: the maximum number of liquidation structures to retrieve :param dict [params]: exchange specific parameters for the bitmex api endpoint :param str [params.method]: exchange specific method, supported: liquidation, allLiquidation :returns dict: an array of `liquidation structures ` NrFr.rallLiquidationliquidations::rrT) rrrrrrrr liquidations) rrrrrrrrrrnewLiquidations rwatch_liquidationszbybit.watch_liquidationss*!!!!!!!!!V$$!//?RTZ[[[[[[[[""6**66v?RT\^noo&/  vd|+#00{meWfUUUUUUUU ? "! !11$2CfXuV[]abbbrc.t|dtr||dg}tdt |D]}||}||d}||ddd}|d}|||} |j0| |j dd} t| |_|j} | | | | gd | | gd |zdS||di}||d}||ddd}|d}|||} |j0| |j dd} t| |_|j} | | | | gd | | gd |zdS) NrrrfrrNrliquidationsLimitr;rr)rrrrrrrparse_ws_liquidationrrr}rrrr) rrrrawLiquidationsrrawLiquidationrrr liquidationrrs rhandle_liquidationzbybit.handle_liquidation3s"< gfot , , E"nnWfbAAO1c/2233 I I!0!3++NC@@))(D"jII)"77OO $, --dl.GHHHH I I"^^GVR@@N''AAH%%hb*EEFH%F33NFKKK ())$,8KTRR$.u$5$5!%E LL % % % NNK=. 9 9 9 NNK=*:V*C D D D D Drc||dd}|||dd}||dd}|||d||dd||d ||d d ||d d dd|||d S)NrrfrrN updatedTimersizer contractSizerrrr) rr contractsrrr baseValue quoteValuerr)rrrsafe_liquidation safe_number_2rrr)rrrrrs rrzbybit.parse_ws_liquidationns$%%k8SAA!!(FB CC'' ]CHH $$X&++KEE ,,V^DD'' WcBB**;DD" Y// & &   rcK|d{Vd}d}|||}|d|zz }||d||d{V}||d{Vddgdgdgd }||||} |||g| |d{V} |jr| ||}| | |||dS) a5 watches information on multiple orders made by the user 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 ` Nr7ordersrTr stopOrderuser.openapi.perp.orderr) rrrrrrrrr'r) rrrrrrrrtopicsByMarketrrs r watch_orderszbybit.watch_orderssT!!!!!!!!!  [[((F 3< 'K//ffMMMMMMMM$$$$$$$$$k*y./   1F1Fs1K1KLL(({mVVLLLLLLLL ? 3OOFE22E00tTTTrc K|d{Vd}d}d}|t|jdz||d||d{V}||d{Vddgdgd gd }||||}||dg|g|g||d{VS) a unWatches information on multiple orders made by the user https://bybit-exchange.github.io/docs/v5/websocket/private/order :param str symbol: unified market symbol of the market orders were made in :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 ` Nr7zunsubscribe:ordersrzQ unWatchOrders() does not support a symbol parameter, you must unwatch all ordersTrrrr)rrrrrrrr) rrrrrrrrrs run_watch_orderszbybit.un_watch_orderss"!!!!!!!!!*   tw)||}} }//ffMMMMMMMM$$$$$$$$$k*y./   1F1Fs1K1KLL))#xk]WIW]_efffffffffrc||d}||d}||}|||dS)Nrr)rr parse_orderr)rrrrrrs rhandle_order_wszbybit.handle_order_wssY*&&w88 ~~gv..  &&uk*****rc|j0||jdd}t||_|j}||dg}||di}||d}|dk}|s||d|}i} t dt|D]?} ||| } | d} d | | <| | @t| } t dt| D]#} d | | z}| ||$d }| ||dS) N ordersLimitr;rrcategoryrHrrTzorders:r) rrr}rrrrrrrrrr)rrrrr rawOrdersrrrrrrr symbolsArrayrrs r handle_orderzbybit.handle_ordersh ; %%dlM4HHE077DKOOGVR88  1b11##E:66V# H 8YGGIq#i..)) " "A%%il33F H%F"GFO MM& ! ! ! !GLLNN++ q#l++,, 7 7A!*\!_!<  NN6#5 6 6 6 6 v{+++++rcK|d{Vd}d}d}|dd|\}}d}|dd|\}}|d{V}||dd}||dd}|dd||d{V} || 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)ag watch balance and get the amount of funds available for trading or funds locked in orders 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,balancesrFrToutboundAccountInfowallet)rHrLrIz :contractz:unifiedrHz:spotrK) rrrrrrrrrr) rrrrrrrLrrrrrs r watch_balancezbybit.watch_balanceTs!!!!!!!!! 99.$PVWW f99.$PVWW--////////..!U;;>>'1e<<//dFFKKKKKKKK$$$$$$$$$)    *)##{* z)  +'7 +v~~w& {*  /v~~w& h&&:-KK;.K//-1F1Fs1K1KLLM&&s[M66JJJJJJJJJrc |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)Nbalancerr rHrrBr  accountTypecoinrrrrz balances:r) r rrr array_concatrparse_ws_balancerr safe_balancer) rrrrrr rawBalancesaccountrrrrrs rhandle_balancezbybit.handle_balances^ < 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 5rc|}||dd}||}||gd|d<||dd|d<||d|d <|7||j| i|j|<||j||<dS||j|<dS) Nrhr)availableToWithdrawffreerrllockedused walletBalancetotal)rrsafe_currency_coderrrr )rr rr currencyIdcodes rrzbybit.parse_ws_balance>s4,,..''f== &&z22,,W6q6q6qrr,,Wc8DD++G_EE  "t|[99A,. [).5DL %d + + +!(DL   rcKd||d}|||}|||||d{VS)N subscriberreq_idrrrwatch_multiple)rrrrrrrs rrzbybit.watch_topicsesfoo''   ++gv..((mWmTTTTTTTTTrrrrrc K|} d| |d} | ||||d} || |} |||| ||| |d{VS)N unsubscriber%)rrrrrr') rrrrrrrrr4rr subscriptionrs rrzbybit.un_watch_topicsns!!   * 0   ++gv..((mWmUYU`U`amo{U|U|}}}}}}}}}rcFK|d}||}||}||j|}||dz}||}d} | |z} ||| ||j tj d} d|j || gd} | | |} |||| ||d{VS)N authenticatedi'z GET/realtimehexauth)rr)check_required_credentialsrreusableFuturer subscriptionsrnumber_to_stringhmacencodesecrethashlibsha256apiKeyrr)rrrrrrr- expiresIntexpirespathr/ signaturerrs rrzbybit.authenticates$ '')))% S!!&&{33(D $++d"3"3T[[5M5Mw~_deeIK)G kk'622G JJsK+ > > >||||||rc||gd} ||dkr|jdz||z}||jd||||dd}||jd||t|||d}|w|su| |d}||d i}| |d } | d krtd |zt|jdz|zd S#t$rv} t| tr*d} | | | | |jvr|j| =n,| |d} | | | Yd} ~ dSd} ~ wwxYw)N)r"ret_coderetCode0 exactretMsgret_msgbroadsuccessrrr/zAuthentication failed: Fr-rT)rrrZthrow_exactly_matched_exception exceptionsrthrow_broadly_matched_exceptionrrrr Exceptionrrejectr2) rrrr"feedbackmsgrGrErrerrorrs rhandle_error_messagezbybit.handle_error_messagesX!!'+J+J+JKK DCKK7S=499W+=+==44T_W5MtU]^^^(((IFF44T_W5MsT\]]]#H---oogy99G"7"**7I>>//'9bAA%%gt44<<-.G'.QRRR'# (?@@@5   %!455 2-  e[111&"666,[9"..w@@  e[11144444 sD!D== F=A+F88F=c||ddd}|||rdS||d}|dks|dkr|||dS||d}||||dS||d}|dks|dkr|||dSid |jd |jd |jd |jd |j d|j d|j d|jd|j d|j d|j d|j d|j d|j d|j d|jd|j|j|j|j|j|j|jd}|||}||||dSt'|} t+dt-| D]@} | | } || | dkr|| } | ||dSA||d} | dkr|||dSdS)NrrrrEpongeventsubr$rklinerrrrP publicTradedepthr r rrrrrrr)rRrrrr/r*rr AUTH_RESP)rrPr handle_pongrhandle_subscription_statusrqrCrrrrrrrrhandle_authenticatehandle_un_subscriberrrrrr=)rrrrrErRrSmethods exacMethodrrkeyrrs rhandle_messagezbybit.handle_messages"""7GT2>>  $ $VW 5 5  F""7I66 v  5F??   VW - - - F  &11     VW - - - F  '22 E>>e{22  + +FG < < < F / T&  T&  *  d(  T'   4-  T+  d)  "4#6  .  d3  $/  &t'<  - 42! " d5# $$ 0/ 0,3/   2__We44  ! Jvw ' ' ' FGLLNN##q#d))$$  Aq'Czz$q'""a'' vw'''( 00 ;    $ $VW 5 5 5 5 5  rc0|ddS)Nry)r&r)r)rrs rryz bybit.ping s!oo''   rcb||d||_|S)NrR)rrlastPongrrrs rrYzbybit.handle_pong s.&++GVT=N=N=P=PQQrc|||d}||d}d}|s|dkr1||j|}|dnTt |jdz||z}|||||jvr|j|=|S)NrGr@r-rTrB) rrrrrrrZrLr2)rrrrGr"rrrOs rr[zbybit.handle_authenticate6 s.//'955  )44%  6daii__V^[AAF NN4 '#  '8J8J(JKKE MM% - - -f222(5rc|SNrds rrZz bybit.handle_subscription_statusZ s rc||d}t|j}t dt |D]}||}||jvr|dr|j|}||d}||krS||dg} ||dg} t dt | D]<} | | } | | } | dkp | dkp| d k}||| | |=| ||S) Nr&rr*rrrrrr) rrr2rrr startswithrclean_unsubscription clean_cache)rrrrrrrr+subIdrrr unsubHashr usePrefixs rr\zbybit.handle_un_subscribek sm  (33F(--//00q#d))$$ / /Aq'K6#777%%m44 /%3K@ ((t<<E>> $|_b Q Q #'>>,@RTV#W#W q#m"4"455UUA -a 0I.q1G!(H!4 l'Z:O lU\`kUkI--fgy)TTTT  ...rrg)W__name__ __module__ __qualname__rrrrrrrrrfloatr rrrrrrrrrrrrr rr rrr rr5r7rCr?rrOrNrbrdrqrwrmrr|r{rrrrrrrrrrrrrrr rrrr rrrrrr rrrrrr rPr`ryrYr[rZr\ __classcell__)rs@rrrsH Z #Z Z Z Z Z Z x:>^bkm$$3$X[$$$$Lpt|~0J0JC0Jy0J 0J[`0Jil0J0J0J0Jdim{IK*J*Jc*J3*Ji*Jy*Jbe*Jux*J*J*J*JX<@"J"J"JS"J"J"J"JH68KKKFKKKK26:"EE7EEEEE>9=RssgsCssss89; = =C =s = = = =M:FM:M:M:M:^837rggCgcgggg6+f++++4n,6n,n,n,n,`*,/K/K/K/K/K/Kbw6Vw6w6w6w6r%)%)%)%)NEGUUUUSUdf~~~S~7~[_`c[d~x|~AyB~~~~".0,G6GtGGGGR:6V:6:6:6:6x 6    &,"&""""H"!&!!!!!!!!rr)&ccxt.async_supportccxt ccxt.async_support.base.ws.cacherrrrrr7ccxt.base.typesrrr r r r r rrrrrrrrr!ccxt.async_support.base.ws.clientrtypingrccxt.base.errorsrrrrr async_supportrrhrrr}s AAAAAAAAAAAA____________________________________444444******000000......''''''))))))x%x%x%x%x%D  $x%x%x%x%x%r