":h8ddlZddlmZmZmZmZddlZddlZddl m Z m Z m Z m Z mZmZmZmZmZmZmZmZmZmZmZddlmZddlmZddlmZddlmZddlm Z dd lm!Z!Gd d ejDjFZ#y) N) ArrayCacheArrayCacheBySymbolByIdArrayCacheBySymbolBySideArrayCacheByTimestamp)AnyBalancesInt LiquidationNumOrder OrderBook OrderSide OrderTypePositionStrStringsTickerTickersTrade)Client)List) ExchangeError)AuthenticationError)ArgumentsRequired) BadRequestc eZdZdeffd 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 defdZdefdZdifdedefdZdSdZdddifde dededeefdZddifdeee dedefd Z ifdeee defd!Z!difde defd"Z"defd#Z#dSdefd$Z$difde dede%fd%Z&difdee dede%fd&Z'ifdedefd'Z(ifde defd(Z)defd)Z*d*Z+d+Z,ddifde dededee-fd,Z.ddifdee dededee-fd-Z/ifdedefd.Z0ifde defd/Z1defd0Z2dSd1Z3d2Z4dddifdedededee-fd3Z5difdedefd4Z6defd5Z7dddifdedededee8fd6Z9dSdedefd7Z:d8Z;d9Zdefd;Z?dSd<Z@dddifdedededeeAfd=ZBdifdedefd>ZCdefd?ZDdefd@ZEdSdAZFifdeGfdBZHdefdCZIdSdDZJifdEZKiifdFe dGe dee dHee dIee f dJZLifdKZMdefdLZNdefdMZOdefdNZPdefdOZQdefdPZRdefdQZSdefdRZTxZUS)Tbybitreturnc|jtt|iddddddddddddd dd dd dd dd dddddddddddddddddddddddd dddddddddddddd idd!d"d#d$d%d&d'dd&d(d)dd iddddddd*d+dd*d,d-dd id.d/d0iddd1d2gd3id4d5d6d7d8d9d:d;dd?d@dAdB id4dCdDdEdFdGdHdIdJdKdLdMdNdOdB idP|jdQdRdSS)TNwsT createOrderWs editOrderWsfetchOpenOrdersWsF fetchOrderWs cancelOrderWscancelOrdersWscancelAllOrdersWs fetchTradesWsfetchBalanceWs watchBalance watchBidsAskswatchLiquidationswatchLiquidationsForSymbolswatchMyLiquidationswatchMyLiquidationsForSymbols 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/v1zwss://stream.bybit.com/v5/trade)r;contractusdctrade)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)r;r<r>r=z*wss://stream-testnet.{hostname}/v5/privatez/wss://stream-testnet.{hostname}/spot/private/v3z$L'R&P&P #,P.W%)M$Z%F$($T'Z&X&X #,X._%)U$b%N$($L'R&P&P #,U.\%)R$_%K$ O:zI /3.2# &("!"""$$""""$"""#$!!!!##"###$!!!#?0d "UN@ N N c~|j|j|jddd}||jd<|S)N requestIdr)sum safe_integerrp)rurzs rw request_idzbybit.request_ids9HHT..t||[!LaP $- [!rxNFsymbolmethodcK|rdnd}d}d}d}d} |jdd} ||j|} | ddk(}| d}nK|j|d|\}}|j|jd} |j |dd| } | dk(}|d k(}|rV|j d{} |j| d d } |j| d d }|r | s |s | |d } nH| |d} n?|r | |d } n4|dk(s|dk(r"d}|j|| |d\}}| ||} n| |d} |j| } | S7w)NrErDrFr settleUSDCtype defaultSettler;rFr{rBrAswapfuturer>r=) romarkethandle_market_type_and_params safe_stringrp safe_string_2isUnifiedEnabled safe_boolhandle_sub_type_and_paramsimplode_hostname)rur isPrivaterparams accessibility isUsdcSettledisSpotrrurlrr?isUnifiedMarginisUnifiedAccountsubTypes rwget_url_by_market_typezbybit.get_url_by_market_types%. H  iit$  [[(F"8,6M&>D==fdFSLD& ,,T\\?KM ..vxR_`M*f4M&.  1133G"nnWa?O#~~gq%@ _=M-(0-(4-(0&.dh&6"&"A"A&&RXZb"c-(1-(2##C( %4sB'E)D>*BEc.|j|gd}|S)N)rrrr unifiedMargin)omit)rurs rw clean_paramszbybit.clean_paramss6#bc rxrsideamountpricec K|jd{|j||||||d}|jdddd}|j|d{t |j } d| |gt |j t |jdd d } |j|| | | dd{S77t7w) 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 ` NTrFr rErC order.create recvWindowzX-BAPI-TIMESTAMPzX-BAPI-RECV-WINDOWopreqIdargsheader) load_marketscreate_order_requestro authenticatestrr~ millisecondsrpwatch) rurrrrrr orderRequestrrzrequests rwcreate_order_wszbybit.create_order_wss@!!!00tVUTZ\`a iit$Y/8$$$)*  %((9(9(;$<&)$,,|*D&E  ZZYDIII! " %J5CCACCA-C C CCCidc K|jd{|j|||||||}|jdddd} |j| d{t |j } d| |gt |j t |jddd } |j| | | | d d{S77t7w) 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 ` NrFr rErC order.amendrrrT) redit_order_requestrorrr~rrpr) rurrrrrrrrrrzrs rw edit_order_wszbybit.edit_order_wss4!!!..r64vuV\] iit$Y/8$$$)* %((9(9(;$<&)$,,|*D&E  ZZYDIII! " %JrcK|jd{|j|||}|jdddd}|j|d{t |j }d|vr|d=d||gt |j t |jdd d }|j||||d d{S77{7w) 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 ` NrFr rErC orderFilter order.cancelrrrT) rcancel_order_requestrorrr~rrpr)rurrrrrrzrs rwcancel_order_wszbybit.cancel_order_ws3s!!!00VVD iit$Y/8$$$)* L (]+ %((9(9(;$<&)$,,|*D&E  ZZYDIII% " %Js5CCACCA4CCCCCcK|jd{|j|}|d}d|z}|j|dd|d{}|j|}|j |j di}|j |dd}|ds|dk7rt|jd z|d |d zz }|g}|j||g||d{S777w) 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:Fr6rIrJr;z> watchTicker() only supports name tickers for contract markets.r) rrrr safe_valuerprrr watch_topics) rurrr messageHashrrptopictopicss rw watch_tickerzbybit.watch_tickerUs!!!V$!&( //}fUU""6*//$,, rB  &)<f~%9"4TWW'ggh h vd|##&&s[M66JJJ "VKs4C&C 6C& C"B C&C$C&"C&$C&symbolscK|jd{|j|dd}g}|j|ddd|d{}|j|}|j |j di}|j |dd}|j|}g}tdt|D]5} || } |j|dz| z|jd|| z7|j||||d{} |jr i} | | | d <| S|j|jd |S7+77>w) a8 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 ` NFrr7rIrJrrr)rmarket_symbolsrrrrpr market_idsrangelenappendr newUpdatesfilter_by_arrayrJ) rurr messageHashesrrpr marketIdsrimarketIdtickerresults rw watch_tickerszbybit.watch_tickersnsT!!!%%gtU; // E>SYZZ""6*//$,,C  &)<OOG, q#i.) 9A |H MM%#+0 1  WQZ!7 8 9((mVVLL ??F'-F6(# $M##DLL(GDD% "[Ms4EE3E E B` NFr7rIrJrrrzunsubscribe:ticker:r) rrrrprrrrrrun_watch_topics) rurrrprrsubMessageHashesrrrrrrs rwun_watch_tickerszbybit.un_watch_tickerss3!!!%%gtU;//$,,C  &)< OOG, q#i.) AA |HQZF MM%#+0 1  # #I$6 7  !6!? @  A // E>SYZZ))#x-Qacikqrrr "[rs4DDCD2D3DDDDDcxK|jd{|j|g|d{S77w)rN)rr)rurrs rwun_watch_tickerzbybit.un_watch_tickers;!!!**G9f=== "=:6:8::clientc|j|dd}|j|dd}|j|di}|j|ddu}|rdnd}d}d} |dk(r|j|} | d }n|d k(r|jd } t | } |j| | d z } |j | dd|} | d }|j|j |i}|j|d i}|j||}|j|} |j|d}|| d<|j|| d<| |j |<d|z}|j|j ||y)Nrrdata usdIndexPricer;rAsnapshotrdeltarr{infots timestampdatetimer) r safe_dict parse_tickersplitr safe_marketrJextendr}iso8601resolve)rurmessager updateTyperrrrparsed topicParts topicLengthrrr rawTickermergedrrs rw handle_tickerzbybit.handle_tickersf  '26%%gvr: ~~gvr2!!$8DvZ * $&&t,FH%F 7 "S)Jj/K'' K!ODH%%hdDAFH%F^^DLL&"=Fvvr:I[[D1F&&v.F%%gt4 '{!\\)4z% V&( t||F+[9rxcK|jd{|j|dd}g}|j|ddd|d{}|j|}|j |}g}t dt |D]4}||}d|z} |j| |jd||z6|j||||d{} |jr| S|j|jd|S7773w)a watches best bid & ask for symbols https://bybit-exchange.github.io/docs/v5/websocket/public/orderbook :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+z orderbook.1.bidask:r) rrrrrrrrrrrbidsasks) rurrrrrrrrrrs rwwatch_bids_askszbybit.watch_bids_asksFs!!!%%gtU; // E?TZ[[""6*OOG, q#i.) 9A |H"X-E MM%  WQZ!7 8  9 ((mVVLL ??M##DMM8WEE "\Ms4D D3D  D B D D 0D D  D c |j|d}|j|j|dd}|j|j|dd}|j|dg}|j|dg}|j |d||j ||j |d|j |d|j |d|j |d|d|S)Nrbidsrasksrr{)rrrask askVolumebid bidVolumer)r}sort_by aggregate safe_list safe_tickerr safe_number)ru orderbookrrrrbestBidbestAsks rwparse_ws_bid_askzbybit.parse_ws_bid_askas%%i= ||DNN9V+<=qA||DNN9V+<=qA..q"-..q"-X&" Y/##GQ/))'15##GQ/))'15 !    rxrRsincelimitcfKd|d<|j||gg|||d{}|||S7 w)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 r1callerMethodNameN)watch_ohlcv_for_symbols)rur timeframer rrrs rw watch_ohlcvzbybit.watch_ohlcvrsK&2!"33fi5H4I5RWY_``f~i((as 1/ 1symbolsAndTimeframescK|jd{|j|d}|j|dddd}|d}|j|dd|d{}g} g} t dt |D]} || } |j | d} |j| }|d} |j | d}|j |j||}| jd|zd z|d z| jd | zd z|z|j|| | |d{\}}}|jr|j||}|j|||dd}|j|||S7d77Tw) 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 NrFTr2rr{kline.rrohlcv::::)rget_list_from_object_valuesrrrrrrrQrrrgetLimitfilter_by_since_limitcreate_ohlcv_object)rurr rrr marketSymbols firstSymbolr rawHashesrrr symbolStringrunfiedTimeframe timeframeIdrrstoredfiltereds rwrzbybit.watch_ohlcv_for_symbolss!!!223GK++GT5$M #A& // UDZ\bcc  q#234 TA'*D++D!4L[[.F!(+L"..tQ7O**4??O_]K   X 3c9F4LH I  \!9D!@?!R S T+/*;*;CPY[a*b$b! 6 ??OOFE2E--feUAtL'' 8DD) "d%cs6FE:AFE=C F+F,AF=FFc K|jd{|j|d}|j|dddd}|d}|j|dd|d{}g}g}g} t dt |D]} || } |j | d} |j| } | d} |j | d}|j |j||}|jd|zd z| d z|jd | zd z|z| jd | zd z|zd|i}|j|d|| ||||d{S7>77 w)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 NrFTr2rr{rrrrrzunsubscribe::ohlcv::rohlcv) rrrrrrrrrQrr)rurrrrrrrrrrrr rr!r" subExtensions rwun_watch_ohlcv_for_symbolsz bybit.un_watch_ohlcv_for_symbolss!!!223GK++GT5$M #A& // UDZ\bcc  q#234 aA'*D++D!4L[[.F!(+L"..tQ7O**4??O_]K   X 3c9F4LH I  # #I $` indexed by market symbols N)watch_order_book_for_symbols)rurrrs rwwatch_order_bookzbybit.watch_order_book"s%66xOOOOs !!cK|jd{t|}|dk(rt|jdz|j |}|j |ddd|d{}|j |}|j|d}||drdnd}|d rd }n|dsS|d r"|d k7rp|d k7rkt|jd z|d k7rN|dk7rI|dk7rD|dk7r?t|jdz|d k7r"|dk7r|dk7rt|jdzg}g}tdt|D]S} || } |j| } dt|zdz| z} |j| d| z} |j| U|j||||d{}|jS77Z7w)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 symbolsFr3r;2r=dzM watchOrderBookForSymbols() can only use limit 25 and 100 for option markets.r{z^ watchOrderBookForSymbols() can only use limit 1, 50, 200 and 500 for swap and future markets.zN watchOrderBookForSymbols() can only use limit 1,50, and 200 for spot markets. orderbook.r orderbook:)rrrrrrrrrr market_idrrrr)rurrr symbolsLengthrrrrrrrrrr s rwrAz"bybit.watch_order_book_for_symbols/s !!!G A #DGG.q$qr r%%g.// ECSU[\\""6*WQZ( =!&>BEh&>(# %3,(4C*CDDqju{#EUXL$TWW0P&PQQQJUb[u|$TWW/%AA q#g,' .AQZF~~f-H 3u:-3h>E MM% &/K   -  .++COO   C " ]6Ps5G GAG .G/EG 0G 1G G  G c K|jd{|j|dd}d}|j|d}||j|d}n|j |d}|drdnd}|t |z }g}g}g}t dt|D]^} || } |j | } | d } |d z| z} |jd | z|jd | z|j| `|j|ddd |d{}|j|d|||||d{S7&7&7 w)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 NFrIrrr;rDrErrzunsubscribe:orderbook:rJr3r ) rrr}rrrrrrrr)rurrchannelr firstMarketrrrrrrrrrs rwun_watch_order_book_for_symbolsz%bybit.un_watch_order_book_for_symbols]sh!!!%%gtU;!!&'2  YYvw/F++gaj1K%f-B3E3u: q#g,' !AQZF[[(Fd|HcMH,E  !9F!B C  # #L6$9 : MM%  !// ECSU[\\))#{G]Tdflntuuu- "*]us4ED<DED?E7E8E?EEcxK|jd{|j|g|d{S77w)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)rrPrurrs rwun_watch_order_bookzbybit.un_watch_order_books;!!!996(FKKK "Krc|j|d}|jdd}|jjddk\}|j|d}|dk(}|j |di}|j|d } |rdnd } |j | dd| } | d } |j |d } | |jvr|j|j| <|j| }|r'|j|| | d d}|j|ni|j|dg}|j|d g}|j|d||j|d|| |d<|j| |d<d| z}||j| <|j|||dk(rK|j|j| | }i}||| <||j | <|j|d| zyy)Nrrr{r;rrrrsrArrbarrrrrJr_r)rrrr0rrr} orderbooks order_bookparse_order_bookresetr handle_deltasrrr r)rurrrrrr isSnapshotrrr3rrrr rrrrbidask newBidsAskss rwhandle_order_bookzbybit.handle_order_booksD  '2 C #(A-0j( ~~gvr2##D#.%V: !!(D$ C!%%gt4 $//)&*oo&7DOOF #OOF+ ,,T69c3OH OOH %>>$R0D>>$R0D   y0$ 7   y0$ 7%.Ik "$(LL$;Ij !'&0 "+y+. C<**4??6+BFKF "K"(K $*DMM& ! NN; F(: ; rxcL|j|dd}|j|y)Nrr{) parse_bid_ask storeArray)rubooksiderbidAsks rw handle_deltazbybit.handle_deltas$##E1a0F#rxcbtdt|D]}|j|||y)Nr)rrrf)rurddeltasrs rwr\zbybit.handle_deltass0q#f+& 3A   hq 2 3rxcHK|j|g|||d{S7w)a6 watches information on multiple trades made in a market 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 ` N)watch_trades_for_symbols)rurr rrs rw watch_tradeszbybit.watch_tradess'22F8UE6RRRRs " "cK|jd{|j|}t|}|dk(rt|jdz|j |}|j |ddd|d{}g}g}tdt|D]G} || } |j| } d| dz} |j| d| z} |j| I|j||||d{}|jr6|j|d}|j|d }|j||}|j|||d d S7D77`w) 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 symbolsFr8 publicTrade.rtrade:rrT)rrrrrrrrrrrrrrrr)rurr rrrLrrrrrrrrtradesfirst tradeSymbols rwrjzbybit.watch_trades_for_symbolssk!!!%%g.G A #DGG.n$no o""6*// E=RXYY q#g,' .AQZF[[(F"VD\1E MM% "V+K   -  .((mVVLL ??OOFA.E**5(;KOOK7E))&% TRR+ " ZMs6E!EA(E!?EA>E!>E?AE!E!E!c K|jd{|j|ddd}|j|ddd|d{}g}g}g}tdt |D][}||}|j |} d| dz} |j | d|z} |j | |j d |z]|j|d |||||d{S777w) 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 NFTrunWatchTradesForSymbolsrmrzunsubscribe:trade:rnro)rrrrrrrr) rurrrrrrrrrrrs rwun_watch_trades_for_symbolsz!bybit.un_watch_trades_for_symbols s !!!%%gtUDA// EC\^dee q#g,' 7AQZF[[(F"VD\1E MM% .7K   -  # #Hv$5 6 7))#x-Qacikqrrr "ess4C,C&2C, C( BC,!C*"C,(C,*C,cxK|jd{|j|g|d{S77w)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)rrtrRs rwun_watch_tradeszbybit.un_watch_trades%s;!!!55vhGGG "Grcj|j|di}|j|d}|}|jd}|jj ddk\}|rdnd}|j|d} |j | dd|} | d} |j|j | } | 7|j|jd d } t| } | |j | <tdt|D](}|j||| }| j|*d | z}|j| |y) Nrrrr;rrAr{r tradesLimitr.rn)rrrrr0rror}rprrrparse_ws_traderr)rurrrrropartsrr3rrrr#rjrrs rw handle_tradeszbybit.handle_trades2s,(w3  '2 C (A- &VZ ##E1-!!(D$ C!f5 >%%dllM4HE&F"(DKK q#f+& "A((F;F MM& ! "$f, v{+rxc|j|gd}d|v}|rdnd}||d}|j|d}|j||d|}|d}|j|dd }|j |d } d} |j |d } | | rd nd } n| } |j|d} |j |dd} |j|d}|j||||j|||d| | | | ddd |S)N)rTvBTrAr;rrUrtr~Smbuysellpqro) rrrrrorderrr takerOrMakerrrcostfee) safe_string_nrrsafe_integer_2safe_string_lowerrr safe_trader)rurCrr isContractr3rrrrrrrrorderIds rwryzbybit.parse_ws_tradeZs=@   7em #-Z6  J##E3/!!(FD*E!''sC8 %%eS1 OOE3 ' <56DL  ,##E34""5#." Y/(   rxcX|jddk\ry|jddk\ryy)Nr;rz v5/privater?rB)r0)rurs rwget_private_typezbybit.get_private_types- 88F q  XXl #q (rxcKd}d}|jd{||j|}|d|zz }|j|d||d{}|j|d{dddd }|j ||j |} |j ||g| g|d{} |jr| j||}|j| |||dS7777=w) a watches information on multiple trades made by the user 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 ` r0myTradesN:T ticketInfo executionuser.openapi.perp.trader;r?rB rrrrrrrrrfilter_by_symbol_since_limit) rurr rrrrr topicByMarketrros rwwatch_my_tradeszbybit.watch_my_tradess! !!!  [[(F 3< 'K//ffMM$$$ "-  t/D/DS/IJ(({meWfMM ??OOFE2E00tTT "N$NsFC/C'6C/C)C/*C++AC//C-08C/)C/+C/-C/c Kd}d}d}|jd{||j|}|d|zz }|j|d||d{}|j|d{ddd d }|j ||j |}|j |dg|g|g|g|d{S77h7Q7 w) a unWatches information on multiple trades made by the user https://bybit-exchange.github.io/docs/v5/websocket/private/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 :returns dict[]: a list of `order structures ` r0zunsubscribe:myTradesrNrTrrrrrrrrrrr) rurrrrsubHashrrrs rwun_watch_my_tradeszbybit.un_watch_my_tradess!, !!!  [[(F sV| #G//ffMM$$$ "-  t/D/DS/IJ))#z2 }wiZ_Y`bhiii "N$jsFCB:6CB<C,B>-AC5C6C<C>CCc"|j|d}|dk(}|j|dg}t|ts|j|dg}|j-|j |j dd}t||_|j}i}|jddg} td t|D]o} || } d} |r|j| } n7|j| d d } |j| | sD|j| } | d }d ||<|j| qt|j}td t|D]} d|| z}|j!||d}|j!||y)Nrrrrrxr.r0rMrexecTyperrTz myTrades:r)rr isinstancelistrr}rpr handle_optionrrryin_array parse_traderkeysr)rurrrr;rrrorrMrrawTraderrrrcurrentMessageHashrs rwhandle_my_tradeszbybit.handle_my_tradess~  '2 $w3$%??426D == %%dllM4HE259DM,,_>OQSTq#d)$ "AAwHF,,X6 ++Hj"E}}X?))(3H%F"GFO MM& ! "GLLN#q#d)$ 7A!,tAw!6  NN6#5 6 7! v{+rxcK|jd{d}d}|j|s%|j|}ddj|z}|j |d}|j |d||d{}d|z}|j |} |j|d{|j| ||j} |jdd d} |jdd d} | r2| r0| .| jd d{} |j| |||dSd g}|j||g||d{}|jr|S|j| |||dS7W777c70w) 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 ` Nr9rr,rT positionsrKrLposition)ris_emptyrjoinrrrrset_positions_cacherrrfilter_by_symbols_since_limitrr)rurr rrrrrrrcacherKrLrr newPositionss rwwatch_positionszbybit.watch_positionsBs!!!! }}W%))'2G'!22K&&w2 // T66RR!K/ S!$$$   1!%!3!34DF^`d!e!%!3!34DF^`d!e !&<#]]+CDDH55hPUW[\ \!..s[M66RR ?? 11%%PTUU- "S % ESsYE8E-A'E8>E0?.E8-E2.A"E8E44E8E6(E80E82E84E86E8c|jy|jddd}|r@d}||jvr/|j||j |j ||yyt |_y)Nr9rKT)rrfuturesrspawnload_positions_snapshotr)rurrrKrs rwrzbybit.set_positions_cachefsn >> % !%!3!34DF^`d!e !2K6>>1 k* 477M267DNrxcK|jdddd|jddddg}tj|d{}t|_|j}t dt |D]7}||}t dt |D]}||} |j| 9|j|} | j||j|dy7w)Nrr>)rrr<rr) fetch_positionsasynciogatherrrrrrrr) rurrfetchFunctionspromisesrrriirrs rwrzbybit.load_positions_snapshotrs  8'L M  9'M N !8813q#h-( 'A  IAs9~. '$R= X& ' '  ,uuj)9sAC&C$B"C&c|jt|_|j}g}|j|dg}tdt |D]}||}|j |}|j |d} |j|| | dk(r2d|d<|j|d|d<|j|d|d<u|j||j|d} tdt | D]f}| |} | jd} | d } | jd }|j|d |d }|j|rU|j|| h|j|d y)Nrrrrlongshortz positions::rr{rrFr) rrrrrparse_positionrrfind_message_hashesrrrr)rurrrr rawPositionsr rawPositionrrrrrz symbolsStringrrs rwhandle_positionszbybit.handle_positionssP >> !57DN w; q#l+, 'A&q/K**;7H##Hf5D    )|trz$*  X&#*  X&#'  X&# '$00G q#m,- 7A'*K%%d+E!!HM#))#.G,,\8WeTI==+y+6 7 |[1rxcK|jd{|j|}|d}|j|dd|d{}|j|}d}|j |ddd\}}d|z}|dz|d z} |j ||g| g|d{} |j r| S|j|j|g||d S7776w) a watch the public liquidations of a trading pair https://bybit-exchange.github.io/docs/v5/websocket/public/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,r liquidationliquidations::rrT) rrrrhandle_option_and_paramsrrr liquidations) rurr rrrrrrrnewLiquidations rwwatch_liquidationszbybit.watch_liquidationss!!!V$!//?RTZ[[""6*66v?RT\^kl&/  vd|+#00{meWfUU ??! !11$2C2CfXuV[]abb "\ Vs4CC1CC AC C!3CCCct|dtr|j|dg}tdt |D]}||}|j |d}|j |ddd}|d}|j||} |j|j|} | (|j|jdd} t| } | j| | |j|<|j| gd |j| gd |zy|j|di}|j |d}|j |ddd}|d}|j||} |j|j|} | (|j|jdd} t| } | j| | |j|<|j| gd |j| gd |zy) NrrrUrrArliquidationsLimitr.rr)rrrrrrrparse_ws_liquidationrrr}rprrrr) rurrrawLiquidationsrrawLiquidationrrrrrrs rwhandle_liquidationzbybit.handle_liquidations< gfot ,"nnWfbAO1c/23 I!0!3++NC@))(D"jI)"77O #t/@/@&I ' --dll.GH I"^^GVR@N''AH%%hb*EFH%F33NFKK??4+<+` Nr5ordersrTr stopOrderuser.openapi.perp.orderrr) rurr rrrrrtopicsByMarketrrs rw watch_orderszbybit.watch_ordersHs !!!  [[(F 3< 'K//ffMM$$$k*y./  1F1Fs1KL(({mVVLL ??OOFE2E00tTT# " N$MsFC2C*:C2C,C2*C.+AC22C038C2,C2.C20C2c K|jd{d}d}d}||j|}|d|zz }|j|d||d{}|j|d{ddgdgd gd }|j ||j |}|j |dg|g|g||d{S77k7T7 w) 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 ` Nr5zunsubscribe:ordersrrTrrrrr) rurrrrrrrrs rwun_watch_orderszbybit.un_watch_ordersgs!!!*   [[(F sV| #G//ffMM$$$k*y./  1F1Fs1KL))#xk]WIW]_efff "N$gsFCB=  7c> ,,UC8M"55mDO+C~~d&6&6un&MN  E "  T//sMJ     Y/  !"4   f  D  ;    D  U    L  t//|D T--eZ@! " $//%># $''z:1 2 3 rxcK|jd{d}d}d}|jdd|\}}d}|jdd|\}}|jd{}|j |dd}|j |dd}|j dd||d{} |j | d{dd d } |r|d k(r|d z }n|d z }|s|s|dk(r|dz }n|d z }|r|dk(r|dz }n|dk(r|d z }n|d z }|j| |j| g} |j| |g| |d{S737777 w)ai 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*balancesrFr{ToutboundAccountInfowallet)r;r?r<z :contractz:unifiedr;z:spotr>) rrrrrrrrrr) rurrrrrr?rrrrrs rw watch_balancezbybit.watch_balances!!! 99.$PVW f99.$PVW--//..!U;>>'1e<//dFFKK$$$)  )#{* z) '7v~w& {* v~w& h&:-K;.K//-1F1Fs1KLM&&s[M66JJJM "0L$6KsZEE A E"E #AE$E%E=E>BEEE EEEEc 0|ji|_d}|j|d}d}g}d}|dk(rYd}|j|dg}tdt|D]*} |j|| dg} |j || },|}|dk(rw|j|di}tdt|D]J} |j|di} |j | d }|j ||j| d g}L|}tdt|D]} |j || |||j|j|i|j|<||j|d <|j|d } | |j|d <|j| |j|d<|j|j||j|<d|z}|j|j||y||jd <|j|d } | |jd <|j| |jd<|j|j|_d}|j|j|y)Nbalancerr&r;rrBr' accountTypecoinrrrrz balances:r%) r*rrr array_concatrparse_ws_balancer}r safe_balancer) rurrrrr rawBalancesaccountrrr+rrs rwhandle_balancezbybit.handle_balances^ << DL 1  ) )G??7FB7D1c$i( @OODGS"5"// Q?  @D H ??7FB7D1c$i( bq"500G"// T__VU[]_=`a  bDq#k*+ ;A  ! !+a.' : ;  t||W5=(* W%,0DLL !& )))'48I1:DLL !+ .04 Y0GDLL !* -$($5$5dll76K$LDLL !%/K NN4<<0+ >#'DLL ))'48I(1DLL %'+||I'>DLL $,,T\\:DL$K NN4<< 5rxc|j}|j|dd}|j|}|j|gd|d<|j|dd|d<|j |d|d <|>|j |j |i|j |<||j ||<y||j |<y) NrWr-)availableToWithdrawrfreer5r6llockedused walletBalancetotal)r2rrrrrr*)rur*r,r2 currencyIdcodes rwr/zbybit.parse_ws_balanceys4,,.''f= &&z2,,W6qr,,Wc8D++G_E  "t||[9A,. [).5DLL %d +!(DLL rxcKd|j|d}|j||}|j||||d{S7w)N subscriberreq_idrr~rwatch_multiple)rurrrrrrs rwrzbybit.watch_topicssLoo'  ++gv.((mWmTTTTs>AAArrrrc K|j} d| |d} | ||||d} |j| |} |j||| ||j| |d{S7w)N unsubscriber@)rrrrrrB) rurrrrrrrr'rr subscriptionrs rwrzbybit.un_watch_topicss{!  * 0  ++gv.((mWmUYU`U`amo{U|}}}}sAA"A A"c K|jd}|j|}|j|}|j|j|}||j dz}|j |}d} | |z} |j|j| |j|jtjd} d|j|| gd} |j| |} |j||| ||d{S7w)N authenticatedi'z GET/realtimehexauth)rr)check_required_credentialsrrr subscriptionsrnumber_to_stringhmacencodesecrethashlibsha256apiKeyrr)rurrrrrrH expiresIntexpirespathrJ signaturerrs rwrzbybit.authenticates '')% S!{+(<(D $++d"3T[[5Mw~~_deIKK)G kk'62G JJsK+ >||sDDD Dc$|j|gd} ||dk7r|jdz|j|z}|j|jd|||j |dd}|j |jd||t||j|d}|g|se|j|d}|j|d i}|j|d } | d k(rtd |zt|jdz|zy #t$rn} t| tr0d} |j| | | |jvr2|j| =n$|j|d} |j| | Yd} ~ yd} ~ wwxYw)N)r=ret_coderetCoder exactretMsgret_msgbroadsuccessrrrJzAuthentication failed: FrHrT)rrjsonthrow_exactly_matched_exception exceptionsrthrow_broadly_matched_exceptionrrrr ExceptionrrejectrL) rurrr=feedbackmsgr`r^rrerrorrs rwhandle_error_messagezbybit.handle_error_messagesX!!'+JK DCK77S=499W+==44T__W5MtU]^(((IF44T__W5MsT\]#H--oogy9G"7**7I>//'9bA%%gt4<-.G'.QRR'# (?@@ %!45-  e[1&"6"66,,[9"..w@  e[1 sDD F!A$F  Fc|j||ry|j|d}|dk(r|j||y|j|d}||j||y|j|d}|dk(r|j ||y|j |ddd}id|j d |jd |jd |jd |jd |jd|jd|j d|jd|jd|jd|jd|jd|jd|jd|jd|j|j|j|j|j |j"d}|j%||}| |||yt'|j)} t+dt-| D].} | | } |j/| | dk\s || } | ||y|j|d} | dk(r|j!||yy)Nr^pongeventsubrrrr klinerrrrC publicTradedepthr'r&rrrrrallLiquidation)rrrrJrErr AUTH_RESP)rjr handle_pongr}handle_subscription_statusrr`r6rrr|r3rrrrhandle_authenticatehandle_un_subscriberrrrrr0)rurrr^rlrmrmethods exacMethodrrkeyrrs rwhandle_messagezbybit.handle_message s  $ $VW 5 ""7I6 f    VW -   &1     VW -   '2 E>  + +FG < ""7GT2> // T&&  T&&  **  d((  T''   4--  T++  d))  "4#6#6  ..  $//  &t'<'<  --  422 d55! " D$$# $!00// 00,,33- 0__We4  ! vw ' GLLN#q#d)$ Aq'Czz$q'"a' vw'  0 ;   $ $VW 5 rxc(|jddS)Nrl)rAr)r~)rurs rwrlz bybit.pingT soo'  rxc4|j|d|_|S)Nrl)r}lastPongrurrs rwrtzbybit.handle_pongZ s++GV<rxcl|j|d}|j|d}d}|s|dk(r/|j|j|}|jd|St |j dz|j |z}|j||||jvr |j|=|S)Nr`rZrHrTr[) rr}rrrrrarfrL)rurrr`r=rrris rwrvzbybit.handle_authenticateh s //'95  )4% dai__V^^[AF NN4  (#  '8J(JKE MM% -f222((5rxc|SNrs rwruz bybit.handle_subscription_status s rxc|j|d}t|jj}t dt |D]}||}||jvr|j ds)|j|}|j|d}||k7rP|j|dg} |j|dg} t dt | D]} | | } | | } |j|| | !|j||S)NrArrErrr) rrrLrrr startswithrclean_unsubscription clean_cache)rurrrrrrrFsubIdrrr{ unsubHashrs rwrwzbybit.handle_un_subscribe s  (3F((--/0q#d)$ /Aq'K6#7#77%%m4%33K@ ((t<E> $|_b Q #'>>,@RTV#W q#m"45JA -a 0I.q1G--fgyIJ  .! /"rxr)V__name__ __module__ __qualname__rrtr~rrrrrrfloatr rrrrrrrrrrrrrr r rrrrr(r*r6r2r rBrArPrSr`rfr\rrkrjrtrvr|ryrrrrrrrrrr rrrr rrrrrrr(r3r/rrrrjr{rlrtrvrurw __classcell__)rvs@rwrrs9O #O b :>^bkm$3$X[$Lpt|~0JC0Jy0J 0J[`0Jil0Jdim{IK*Jc*J3*Ji*Jy*Jbe*Jux*JX<@ J JS JD68KKFK26:"E7EE>9=RsgsCs8:< >S > >M:FM:^837rgCgcg8+f+4m,6m,^AF*,/K/Kbw6Vw6r%)NEGUUWfh~~S~49~]abe]f~z~@C{D~".0,G6GR96V96v 6 & &:" & rxr)$ccxt.async_supportccxt ccxt.async_support.base.ws.cacherrrrrrQccxt.base.typesrrr r r r r rrrrrrrr!ccxt.async_support.base.ws.clientrtypingrccxt.base.errorsrrrr async_supportrrrxrwrsf AAYYYYY4*0.'c&D   $ $c&rx