":h`ddlZddlmZmZmZmZddlZddlm Z m Z m Z m Z m Z mZmZmZmZmZmZddlmZddlmZddlmZddlmZddlmZdd lmZdd lmZdd lmZdd lmZdd l m!Z!GddejDjFZ#y)N) ArrayCacheArrayCacheBySymbolByIdArrayCacheBySymbolBySideArrayCacheByTimestamp) AnyBalancesIntOrder OrderBookPositionStrStringsTickerTickersTrade)Client)List) ExchangeError)AuthenticationError)ArgumentsRequired) BadRequest)RateLimitExceeded) ChecksumError)UnsubscribeError)Precisec eZdZdeffd ZifdZifdedefdZifdedefdZ difde de fd Z d e fd ZdBd Zdifde de fd Zd e fdZdBdZdddifdedededeefdZdifdedefdZd e fdZdBdefdZdifdededefdZifdedefdZifdedededefdZdifdeededefdZd e fdZd e dedefdZ d Z!d!Z"ddifdedededee#fd"Z$ddifdeedededee#fd#Z%ifdedefd$Z&d e fd%Z'dBd&Z(dddifde dededee)fd'Z*d e fd(Z+dBd)Z,dddifde-dededee.fd*Z/d e fd+Z0dBd,Z1d-Z2dddifde-dededee#fd.Z3d e fd/Z4ifde5fd0Z6d e fd1Z7ifd2Z8ifd3Z9ifd4Z:ifd5Z;ifd6Zd e fd9Z?d e fd:Z@d e fd;ZAd e fd<ZBd e fd=ZCd e fd>ZDd e fd?ZEd e fd@ZFd e fdAZGxZHS)Cbitgetreturnc|jtt|iddddddddddddd dd dd dd dd ddddddddddddddddddddddddddidddddd d!d"d#d$d%d&d' d(did)did*d+|jidt t t t t ttt t t t t t d, id-id.S)/NwsT createOrderWsF editOrderWsfetchOpenOrdersWs fetchOrderWs cancelOrderWscancelOrdersWscancelAllOrdersWs watchBalance watchMyTrades watchOHLCVwatchOHLCVForSymbolswatchOrderBookwatchOrderBookForSymbols watchOrders watchTicker watchTickers) watchBidsAsks watchTradeswatchTradesForSymbolswatchPositionsapiz wss://ws.bitget.com/v2/ws/publicz!wss://ws.bitget.com/v2/ws/private)publicprivatez#wss://wspap.bitget.com/v2/ws/publicz$wss://wspap.bitget.com/v2/ws/private)r demo1m5m15m30m1H4H6H12H1D1W) r:r;r<r=1h4h6h12h1d1wchecksumignoreDuplicates) tradesLimit OHLCVLimit timeframesr,r2ping) 30001300023000330004300053000630007300113001230013300143001530016)exactbroad)hasurlsoptions streaming exceptions) deep_extendsuperrdescriberOrrr)self __class__s I/var/www/html/turnos/venv/lib/python3.12/site-packages/ccxt/pro/bitget.pyrfzbitget.describesfd < >du$U      !%$U d'!$+Dt t!"#$"&#)-"&+0"D#F #H#I   $"    #' '0 !+!4!+!4!4!2!2!4!4!4!+!4!+ !}RA R R cd}||jd|\}}n"|ds|dr|j||\}}nd}d}|j|dd|\}}|}||gS)NswapfutureSPOT getInstTypeinstType)handleProductTypeAndParamshandle_option_and_params)rgmarketparamsrp instypeAuxs ri get_inst_typezbitget.get_inst_typems >#>>tVL HfVn&"2#>>vvN HfH !::6=R\^fg F&!!rjsymbolcK|jd{|j|}|d}d|z}d}|j||\}}|d|dd}|j|||d{S7Z7w)a0 watches a price ticker, a statistical calculation with the information calculated over the past 24 hours for a specific market https://www.bitget.com/api-doc/spot/websocket/public/Tickers-Channel https://www.bitget.com/api-doc/contract/websocket/public/Tickers-Channel :param str symbol: unified symbol of the market to watch the ticker for :param dict [params]: extra parameters specific to the exchange API endpoint :returns dict: a `ticker structure ` Nrwticker:tickeridrpchannelinstId) load_marketsrsrv watch_public)rgrwrtrs messageHashrpargss ri watch_tickerzbitget.watch_tickerzs!!!V$!&( --ff=& Tl  &&{D&AAA "Bs"A5A1AA5,A3-A53A5czK|jd{|j|dd|d{S7 7w)a unsubscribe from the ticker channel https://www.bitget.com/api-doc/spot/websocket/public/Tickers-Channel https://www.bitget.com/api-doc/contract/websocket/public/Tickers-Channel :param str symbol: unified symbol of the market to unwatch the ticker for :param dict [params]: extra parameters specific to the exchange API endpoint :returns any: status of the unwatch request Nrzrun_watch_channelrgrwrts riun_watch_tickerzbitget.un_watch_tickers=!!!**68XvNNN "N;7;9;;Nsymbolsc"K|jd{|j|dd}|j|d}d}|j||\}}g}g}t dt |D]F}||}|j|} |d| dd} |j | |j d|zH|j|||d{} |jr i} | | | d<| S|j|jd|S77;w) aA watches a price ticker, a statistical calculation with the information calculated over the past 24 hours for all markets of a specific list https://www.bitget.com/api-doc/spot/websocket/public/Tickers-Channel https://www.bitget.com/api-doc/contract/websocket/public/Tickers-Channel :param str[] symbols: unified symbol of the market to watch the tickers for :param dict [params]: extra parameters specific to the exchange API endpoint :returns dict: a `ticker structure ` NFrrzr{r|ryrw) rmarket_symbolsrsrvrangelenappendwatch_public_multiple newUpdatesfilter_by_arraytickers rgrrtrsrptopics messageHashesirw marketInnerrrresults ri watch_tickerszbitget.watch_tickerss+!!!%%gtU;WQZ(--ff=& q#g,' 5AQZF++f-K$#%d+D MM$   V!3 4 522=&&QQ ??F(/F78$ %M##DLL(GDD- ""R"DD B:DD :D Dclientc|j|||j|}|d}||j|<d|z}|j||y)Nrwry)handle_bid_askparse_ws_tickerrresolvergrmessagerzrwrs ri handle_tickerzbitget.handle_tickersT> FG,%%g.!% V&( v{+rjch|j|di}|j|dg}|j|di}|j|d}|j|d}|dk(rdnd}|j|d } |j| |d|}|j|d } |j|d } t j | d } |j id |d d|d|j|d|j|dd|j|dd|j|dd|j|dd|j|dd|j|dddd|j|dd| d | d!dd"dd#| d$d|j|d%|j|d&|d'|S)(Nargdatartsrprnspotcontractr~lastPr change24h100rw timestampdatetimehighhigh24hlowlow24hbidbidPr bidVolumebidSzaskaskPr askVolumeaskSzvwapopenopen24hcloselast previousClosechange percentageaverage baseVolume quoteVolume)rrinfo) safe_value safe_integer safe_string safe_marketr string_mul safe_tickeriso8601) rgrrsrrrzrrp marketTypemarketIdr changeDecimalrs rirzbitget.parse_ws_tickersCNoogub1w3q"-%%fd3 ##C4 (F 2V ##FH5!!(FD*E  2((= ##M59! fX&! !   Y/!  D$$VY7 ! 4##FH5 ! 4##FG4 !  ))&':!  4##FG4!  ))&':!  D!  D$$VY7!  U!  E!  T!  d! &!! " t#! $**6<@++FMB)! * + rjc"K|jd{|j|dd}|j|d}d}|j||\}}g}g}t dt |D]F}||}|j|} |d| dd} |j | |j d|zH|j|||d{} |jr i} | | | d<| S|j|jd|S77;w) a https://www.bitget.com/api-doc/spot/websocket/public/Tickers-Channel https://www.bitget.com/api-doc/contract/websocket/public/Tickers-Channel watches best bid & ask for symbols :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 ` NFrrzr{r|bidask:rw) rrrsrvrrrrrrbidsasksrs riwatch_bids_askszbitget.watch_bids_asksRs+!!!%%gtU;WQZ(--ff=& q#g,' 5AQZF++f-K$#%d+D MM$   V!3 4 522=&&QQ ??F(/F78$ %M##DMM8WEE- ""Rrc||j|}|d}||j|<d|z}|j||y)Nrwr)parse_ws_bid_askrrrs rirzbitget.handle_bid_askusB&&w/! & f&( v{+rjc |j|di}|j|dg}|j|di}|j|d}|j|d}|dk(rdnd}|j|d } |j| |d|}|j |d ||j ||j|d |j|d |j|d |j|d|d|S)Nrrrrrprnrrr~rwrrrr)rwrrrrrrr)rrrrrr) rgrrsrrrzrrprrs rirzbitget.parse_ws_bid_ask|s oogub1w3q"-%%fd3 ##C4 (F 2V ##FH5!!(FD*EX&" Y/##FG4))&':##FG4))&': !    rjr:sincelimitcK|jd{|j|}|d}|j|jd}|j ||}d|zdz|z} d} |j ||\} }| d|z|dd} |j | | |d{} |jr| j||}|j| ||d d S779w) a watches historical candlestick data containing the open, high, low, close price, and the volume of a market https://www.bitget.com/api-doc/spot/websocket/public/Candlesticks-Channel https://www.bitget.com/api-doc/contract/websocket/public/Candlesticks-Channel :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 NrwrNcandles::candler{r|rT) rrsrrarrvrrgetLimitfilter_by_since_limit) rgrw timeframerrrtrsrNintervalrrprohlcvs ri watch_ohlcvzbitget.watch_ohlcvs!!!V$!__T\\<@ ##J : 9,s2V; --ff=& (*Tl  '' T6BB ??NN651E))%q$GG! "Cs"CCB C#C$8CCcK|jd{|j|jd}|j||}d|z}|j ||d|z|d{S7V7w)a^ unsubscribe from the ohlcv channel https://www.bitget.com/api-doc/spot/websocket/public/Candlesticks-Channel https://www.bitget.com/api-doc/contract/websocket/public/Candlesticks-Channel :param str symbol: unified symbol of the market to unwatch the ohlcv for :param str [timeframe]: the period for the ratio, default is 1 minute :param dict [params]: extra parameters specific to the exchange API endpoint :returns dict: A dictionary of `order book structures ` indexed by market symbols NrNrr)r safe_dictrarr)rgrwrrtrNrr}s riun_watch_ohlcvzbitget.un_watch_ohlcvsv!!!^^DLL,? ##J :X%**67J%%dllL$GE*51F-3DKK  *w3q#d)$ "A((a&9F MM& ! "!9,s2V; v{+rjc |drdnd}|j|d|j|d|j|d|j|d|j|d|j||gS) Ninverser)r safe_number)rgrrs volumeIndexs rirzbitget.parse_ws_ohlcvs|#9-aA   eQ '   UA &   UA &   UA &   UA &   UK 0   rjcFK|j|g||d{S7w)a watches information on open orders with bid(buy) and ask(sell) prices, volumes and other data https://www.bitget.com/api-doc/spot/websocket/public/Depth-Channel https://www.bitget.com/api-doc/contract/websocket/public/Order-Book-Channel :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)rgrwrrts riwatch_order_bookzbitget.watch_order_books%66xOOOOs !!cK|jd{d}|j|d}|dk(s |dk(s|dk(r |j|d}|t|z }|j ||d|d{S7c7w)aR unsubscribe from the orderbook channel https://www.bitget.com/api-doc/spot/websocket/public/Depth-Channel https://www.bitget.com/api-doc/contract/websocket/public/Order-Book-Channel :param str symbol: unified symbol of the market to fetch the order book 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 Nbooksrrr orderbook)rromitstrr)rgrwrtr}rs riun_watch_order_bookzbitget.un_watch_order_book s!!!!!&'2 QJEQJERKYYvw/F s5z !G**67KPPP " Qs"A>A:AA>5A<6A><A>r}messageHashTopiccK|jd{|j|}d|zdz|dz}d}|j||\}}|||dd}|j|||d{S7^7w)Nz unsubscribe:rrwr{r|)rrsrvun_watch_public) rgrwr}rrtrsrrprs rirzbitget.un_watch_channel4s!!!V$$'77#=x@PP --ff=& Tl  ))+tVDDD "Es"A9A5AA90A71A97A9cK|jd{|j|}d}d}|dk(s |dk(s|dk(r|t|z }d}g}g}tdt |D]]}||} |j | } d} |j | |\} }| || d d } |j| |jd | z_|j|||d{} |r| jS| S77w) aw watches information on open orders with bid(buy) and ask(sell) prices, volumes and other data https://www.bitget.com/api-doc/spot/websocket/public/Depth-Channel https://www.bitget.com/api-doc/contract/websocket/public/Order-Book-Channel :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 NrTrrrFrr{r| orderbook:) rrrrrrsrvrrr)rgrrrtr}incrementalFeedrrrrwrsrprrs rirz#bitget.watch_order_book_for_symbolsAs!!!!%%g. QJEQJERK s5z !G#O q#g,' 8AQZF[[(FH#11&&A Hf$" ,D MM$   !6 7 844]FFSS ??$ $ 3 "*Ts"C;C7CC;C9C;9C;c|j|d}|j|d}|j|d}|dk(rdnd}|j|d}|j|dd|}|d} d | z} |j|d } |j| d } |j| d } |d k(}|r| |jvr%|j i}| |d<||j| <|j| }|j| dg}|j| dg}|j |d||j |d|| |d<|j| |d<|jddd}|j|ddk(}|sF|rC|d}|d}t|}t|}g}td dD]u}||kr4|j||dd |j||dd||ksB|j||dd |j||ddwdj|}|j|d}|j| d}||k7rc|j|j|| | y|j!i}|j#| | | }|j%|||j| <|j'|j| | y)Nrr}rprnrrr~rwrrrrrasksbidsrrr,rJTactionsnapshotrrr)rrrr orderbookscounted_order_book handle_deltasr handle_optionrrrjoincrc32spawnhandle_check_sum_error order_bookparse_order_bookresetr) rgrrrr}rprrrsrwrr rawOrderBookrincrementalBookobstoredOrderBookr r rJ isSnapshot storedAsks storedBids asksLength bidsLength payloadArrayrpayloadcalculatedChecksumresponseChecksumrparsedOrderbooks rihandle_order_bookzbitget.handle_order_bookhs >oogu-""3 2##C4 (F 2V ##C2!!(D$ C!"V+ w/tQ/ %%lD9 !W, doo-,,R0%8 *,'"oof5O??<"#'#4#4\:#N %)99 JJt::FFKX+I"33L&)TO OOO ,&/DOOF #tv. ` N)watch_trades_for_symbols)rgrwrrrts ri watch_tradeszbitget.watch_tradess'22F8UE6RRRRs " "cKt|}|dk(rt|jdz|jd{|j |}g}g}t dt|D]]}||} |j | } d} |j| |\} }| d| dd} |j| |jd| z_|j|||d{} |jr6|j| d}|j|d}| j||}|j| ||d d }|jd d d r%|j!|}|j#|d }|S|S7;7w) a get the list of most recent trades for a particular symbol https://www.bitget.com/api-doc/spot/websocket/public/Trades-Channel https://www.bitget.com/api-doc/contract/websocket/public/New-Trades-Channel :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 ` rz> watchTradesForSymbols() requires a non-empty array of symbolsNtrader{r|trade:rwrTr2rK)rrr{rrrrsrvrrrrrrrr!remove_repeated_trades_from_arraysort_by)rgrrrrt symbolsLengthrrrrwrsrprtradesfirst tradeSymbolrfiltereds rir9zbitget.watch_trades_for_symbolssG A #DGG.n$no o!!!%%g. q#g,' 4AQZF[[(FH#11&&A Hf$" ,D MM$   F!2 3 411-PP ??OOFA.E**5(;KOOK7E++FE5+tT   m-? F==fEH||Hk:HO 5 " Qs#E9B$E>#E<$BE><E>czK|jd{|j|dd|d{S7 7w)a unsubscribe from the trades channel https://www.bitget.com/api-doc/spot/websocket/public/Trades-Channel https://www.bitget.com/api-doc/contract/websocket/public/New-Trades-Channel :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 Nr<rrs riun_watch_tradeszbitget.un_watch_trades s=!!!**67GVLLL "LrcL|j|di}|j|d}|dk(rdnd}|j|d}|j|dd|}|d}|j|j|} | 7|j |j dd } t | } | |j|<|j|d g} t| } td | D]2} | | z d z }| |}|j||}| j|4d |z}|j| |y)Nrrprnrrr~rwrLr9rrrr=) rrrrArrar safe_listrrparse_ws_traderr)rgrrrrprrrsrwrrrlengthrindexrawTraderrs ri handle_tradeszbitget.handle_tradess0"oogub1##C4 (F 2V ##C2!!(D$ C!f5 >%%dllM4HE&F"(DKK ~~gvr2Tq&! "AQJNEE{H((6:F MM& !  " ' v{+rjc|j|dd}|j|d}|dnd}||j|dd|}|j|gd}|j |dg}|j |d}d} |K|j|d } |j | } tj|j|d | d } |j||j|d |j|d ||j||d|j|d|j|d|j|d|j|dd|j|dd|j|dd| d |S)Nrwr~posModerr)uTimecTimer feeDetailrfeeCointotalFeecostcurrencytradeIdorderId orderTypeside tradeScopepriceAvgpricesizeramountr) rr{orderrrrwtyper[ takerOrMakerr^r`rVfee) safe_string_2rrsafe_integer_nrHrsafe_currency_coder string_abs safe_trader) rgr<rsr~rO defaultTyperrRrBrd feeCurrencyIdfeeCurrencyCodes rirIzbitget.parse_ws_tradeAst##E8X>""5)4%,%8jv >%%fdD+FF''/GH NN5+r: y!,   ,,UI>M"55mDO**4+;+;E:+NO+C""5)4%%eY7" Y/X&$$UK8$$UF3 ,,ULA''z7C(( E&&uh F   rjc|K|jd{d}d}d}d}|j|}|j|s&|j|}|j ||\}}|dz|z}|ddd} |j ||| |d{} |j r| S|j| |||dS77)w) a watch all open positions https://www.bitget.com/api-doc/contract/websocket/private/Positions-Channel :param str[]|None 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 :param str [params.instType]: one of 'USDT-FUTURES', 'USDC-FUTURES', 'COIN-FUTURES', 'SUSDT-FUTURES', 'SUSDC-FUTURES' or 'SCOIN-FUTURES', default is 'USDT-FUTURES' :returns dict[]: a list of `position structure ` Nr positions USDT-FUTURES :positionsdefaultr|T)rris_emptyget_market_from_symbolsrv watch_privaterfilter_by_symbols_since_limit) rgrrrrtrsrsubscriptionHashrpr newPositionss riwatch_positionszbitget.watch_positionss!!! &!%%g.}}W%11':F#11&&A Hf- ;  "  "// =MtU[\\ ?? 11,PUW[\\% "]s"B<B8A9B<B:(B<:B<cx|j|di}|j|dd}|ji|_|j|d}||jvs|dk(rt|j|<|j|}|j|dg}g}t dt |D]a} || } |j| d} |j | ddd } |j| | } |j| |j| c|j||d z}t dt |D]f} || }|jd }|d }|jd }|j|d|d}|j|rU|j||h|j||dzy)Nrrprr rrrr~rz :positions::z::r,rwFrp)rrrnrrrrparse_ws_positionrfind_message_hashessplitrrrr)rgrrrrpr cache rawPositionsrwr rawPositionrrspositionrrparts symbolsStringrrns rihandle_positionszbitget.handle_positionssLoogub1##CR8 >> !DN!!'84DNN**0D'?'ADNN8 $x(w;  q#l+, #A&q/K'' X>H%%hdJGF--k6BH    ) LL "  #00N9RS q#m,- 7A'*K%%d+E!!HM#))#.G,,\8WeTI==+y+6 7 |X %<=rjc L|j|d}|j|d}|j|ddd}|j|d}|dk(rdnd }|j|d d }|j|d } tj| d } d} ||d} |j id|d|j|dd|j ||ddddd|d|j|dd|j|dd|j|dd|j| d|j|dd| ddd|j|dd |d!|d"|j|d#d|j|d$ddd|j|d%|j|d&d'S)(Nr~ marginModecrossisolated)crossedrrO hedge_modeTFrPrQ unrealizedPLRr contractSizerr{posIdrwrnotionalliquidationPrice entryPrice openPriceAvg unrealizedPnl unrealizedPLr contractstotal markPricer[holdSidehedgedrrmaintenanceMarginkeepMarginRateleverage marginRate)maintenanceMarginPercentage collateral initialMargininitialMarginPercentager marginRatio) rget_supported_mappingsafe_integer_2rr safe_position safe_symbolr parse_numberr) rgrrsr marginModeIdrhedgedIdrrpercentageDecimalrrs rir{zbitget.parse_ws_positionsK4##Hh7'',? // "?  ##Hi8"l2'''7C  ,,XG''(95A   !.1L!!# H# $""8W5#  d&&xzJ#   # * #  0 0;M N #  $**8^D#  T--hG#  $++J7#  ))(G<#  L#  #  D$$Xz:#  f#  #  Y/!# " ## $,0+;+;HFV+W!'+((:>++HlC/#   rjcK|jd{d}d}d}|j|\}}|rdnd}d} |#|j|}|d}|d}|dz|z}|j|d} d} |j d ||\} }d} |j d ||d \} }| d k(s| d k(r|d }| | d k7r | |dz| z}n | dk(r|dz}n| dk(r|dz}n | dk(r|dz}d} || d k(rd} n|j ||\} }| d k(r || dz|z} |r| dz} | d k(s| d k(r|nd }|rdnd}d}|jd |\}}|d} |dz|z}|dk(rd}nd}| dz| z} | ||d}|j|| ||d{}|jr|j||}|j||||dS77:w)a watches information on multiple orders made by the user https://www.bitget.com/api-doc/spot/websocket/private/Order-Channel https://www.bitget.com/api-doc/contract/websocket/private/Order-Channel https://www.bitget.com/api-doc/contract/websocket/private/Plan-Order-Channel https://www.bitget.com/api-doc/margin/cross/websocket/private/Cross-Orders https://www.bitget.com/api-doc/margin/isolated/websocket/private/Isolate-Orders :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.trigger]: *contract only* set to True for watching trigger orders :param str [params.marginMode]: 'isolated' or 'cross' for watching spot margin orders] :param str [params.type]: 'spot', 'swap' :param str [params.subType]: 'linear', 'inverse' :returns dict[]: a list of `order structures ` N triggerOrderraz order:tradesrwr{r productTyper.linearrmarginrqroz:linear COIN-FUTURESz:inverse USDC-FUTURESz :usdcfuturesrnz:stop orders-algoordersMARGINrorders-isolatedorders-crossedr|T) ris_trigger_orderrsrhandle_market_type_and_paramshandle_sub_type_and_paramsrvhandle_margin_mode_and_paramsrtrrfilter_by_symbol_since_limit)rgrwrrrtrsr isTriggerrrvrrbsubTyperpr~r}rrrs ri watch_orderszbitget.watch_orders@su(!!!  11&9 6)2n )  [[(FH%Fd|H%+f4K&&v}= 99-QWX f99-QWYab FNdh.V^ H  dfn6>%+g5K N *% 1K N *% 2K N *%6K >dfnH#11&&A Hf 6>v1/#5>  /'9 "fn0@y#,-( !?? vV F  !H%+j8KZ'+*+c1H<   ))+7GvVV ??OOFE2E00tTTq "jWs"F?F:E+F?F=8F?=F?cB|j|di}|j|d}|j|d}|j|d}d}|dk(rd}n |dk(rd}nd}|d k(}|d k(} |d k(} |j|d g} |j=|j |j d d} t | |_t | |_|dk(xs|dk(} | r |jn |j}| rdnd}i}tdt| D][}| |}|j|d|}|j|dd|}|j||}|j||d}d||<]t|j}tdt|D]6}||}|dz|z}|dk(r|dz}n |dk(r|dz}|j||8|j|||r|j|d| r|j|d| r|j|dyy)Nrr}rpr~rnrrrrorrr ordersLimitr9r ordersAlgorrarrwTrrz:crossrz :isolatedz order:linearz order:inversezorder:usdcfutures)rrrrrrar triggerOrdersrrrparse_ws_orderrlistkeysr)rgrrrr}rp argInstIdr isLinearSwap isInverseSwap isUSDCFuturesrrrrr marketSymbolsrrarrsrrwrinnerMessageHashs ri handle_orderzbitget.handle_ordersXFnnWeR0""3 2##C4$$S(3  v J  !J#J N2 !^3 !^3 w3 ;; %%dllM4HE07DK!7!>D  -K7l3J '0##dkk(1nw  q#d)$ )AGE''xCH%%hdJGF((7F MM& !H%F$(M& ! )M&&()q#d)$ 5A!WF*S069 **#3h#> --#3k#A NN6#3 4 5 v{+  NN6> 2  NN6? 3  NN6#6 7 rjcbd|v}d|v}|j|d}|j||}|j|d}|d}|j|d}|j|dg} |j| d} |j| d } d} | H|j| d } |j t j | |j| d } |j|d }|du}d}|s|j|d }n|r|r|j|d}|j|j|dd}|j|d}|j|d}|j|j|d}|j|j|d}|dk(}|dk(}d}d}d}d}|j|d}|rq|r7|j|d}|j|d}|j|d}nn|j|d}||}n|}|r |r|}|}nL|}nI|j|d}n6|j|d}|j|d}|j|d}t j||}|jid|d|d|j|dd|j|d d!|d"|j|d#|j|d$d%|d&|j|d'd(dd|d |d |d)|d*|d+|d,|||j|| dd-|S).NrOloanTyper~rQrwstatusrRrrdrSrU triggerPricer^ executePricer] fillPricer[rZ accBaseVolumenewSizersbuybaseSizerfillTotalAmountr_fillNotionalUsdrr{rY clientOrderId clientOidrrlastTradeTimestamprPrb timeInForceforcepostOnlyr`rVrfilled) remainingrrdrA)rrrrrrrhrgr omit_zerore string_sub safe_orderrsafe_string_upperparse_ws_order_status)rgrarsisSpotisMarginrrrw rawStatusorderFeerd feeAmount feeObject feeCurrencyrisTriggerOrderr^avgPricer[rbr newSizeValue isMarketOrderisBuy totalAmount filledAmountrVr totalFilledpartialFillAmounts rirzbitget.parse_ws_ordersl 5(%'##E84!!(F3%%eW5 !$$UH5 ??5+r:ooh*$$S%0   **3 :K))'*<* &d2$$UG4E $$UN;E>>$"4"4UJ "TUv.{3t'7'7'OP ~~d&6&6ui&HI )    &&uo> "..ujA "..ulC ''/@A$($4$4UL$I!$0#4L#.L &3 +&2 #'"2"25)"DK ++E<@L**5&9K##E+<=D&&{K@  E f  $""5)4  T--e[A     Y/   !$"3"3E7"C  D  411%A    D  U  L  k  D x! " l# $#00;+ , - rjc8dddddd}|j|||S)Nrclosedcanceled)livepartially_filledr cancelled not_trigger)r)rgrstatusess rirzbitget.parse_ws_order_statuss/ &#!  &&99rjcK|jd{d}d}||j|}|d}|dz|z}d}|jd||\}}d}||dk(rd}n|j||\}}d|z} |d d d } |j || | |d{} |j r| j ||}|j| |||d S779w) a watches trades made by the user https://www.bitget.com/api-doc/contract/websocket/private/Order-Channel :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 ` NmyTradesrwrr)rrnzfill:fillrqr|T)rrsrrvrtrrr) rgrwrrrtrsrrbrprvrrAs riwatch_my_tradeszbitget.watch_my_tradess!!!  [[(FH%F%+f4K99/6SYZ f >dfnH#11&&A Hf"X-   ))+7GvVV ??OOFE2E00tTT/ "(Ws"CCBCC8CCc|j-|j|jdd}t||_|j}|j |dg}t |}d}t d|D]E}||} |j| } |j| | d} d| z} |j|| G|j||y)NrLr9rrrrwz myTrades:) rrrarrHrrrIrr) rgrrrrrrJrrr<rrwsymbolSpecificMessageHashs rihandle_my_tradeszbitget.handle_my_tradessP == %%dllM4HE&u-DM~~gvr2T q&! >AGE((/F MM& !H%F(3f(< % NN6#< =  > v{+rjcHKd}|jdd|\}}d}|jd|\}}d}d}|dk(s|dk(rd}n| d}|dk(rd }nd }nd }|j|dd |\}}||d d}d|jz}|j ||||d{S7w)a watch balance and get the amount of funds available for trading or funds locked in orders https://www.bitget.com/api-doc/spot/websocket/private/Account-Channel https://www.bitget.com/api-doc/contract/websocket/private/Account-Channel https://www.bitget.com/api-doc/margin/cross/websocket/private/Margin-Cross-Account-Assets https://www.bitget.com/api-doc/margin/isolated/websocket/private/Margin-isolated-account-assets :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 :param str [params.instType]: one of 'SPOT', 'MARGIN', 'USDT-FUTURES', 'USDC-FUTURES', 'COIN-FUTURES', 'SUSDT-FUTURES', 'SUSDC-FUTURES' or 'SCOIN-FUTURES' :param str [params.marginMode]: 'isolated' or 'cross' for watching spot margin balances :returns dict: a `balance structure ` Nr(accountrlrmrorraccount-isolatedaccount-crossedrnrprq)rpr}coinbalance:)rrrrlowerrt)rgrtrbrrpr}rrs ri watch_balancezbitget.watch_balance6s99.$PVW f !??PVW F FN 0%H  #HZ',+H88Q[]ef&   !8>>#33 '' [$OOOOsBB"B B"c|j|dg}tdt|D]}||}|j|dd}|j |}||j vr|j |n|j }|j|d} | +|j|d} tj| | |d<d|vrdnd } |j|| |d <|j|d |d <|j|d |d<||j |<|j|j |_|j|d} |j| d} d| z}|j|j |y)Nrrr marginCoinborrowinterestdebtmaxTransferOut availablefreeequityrfrozenusedrrpr ) rrrrergbalancerrr string_add safe_balancesafe_string_lowerr)rgrrrr rawBalance currencyIdcoderrr freeQueryrrprs rihandle_balancezbitget.handle_balance^svvw3q#d)$ )AaJ++J MJ**:6D-1T\\-Adll4( G%%j(;F!++J C")"4"4VX"F-=-K(R]I"..z9EGFO#// HEGG "..z8DGFO!(DLL  )((6 oogu-))#z: 8+ t||[1rjcLK|jddd}|j|jddd}|r6|j|d}|dk7r|d k7r|d k7r|jdd d}d |gd }|j ||}|j ||||d{S7w)Nr5r r6 sandboxModesandboxFrp SCOIN-FUTURES SUSDT-FUTURES SUSDC-FUTURESr8 subscribeoprr` safe_bool_2rarextendwatch rgrrrturlr!rprequestrs rirzbitget.watch_publicsiit$X.&&t||]IuU ''j9HO+(o2MT\`oToii&v.x8F ++gv.ZZ[';GGGGBB$B"B$cLK|jddd}|j|jddd}|r6|j|d}|dk7r|d k7r|d k7r|jdd d}d |gd }|j ||}|j ||||d{S7w)Nr5r r6r!r"Frpr#r$r%r8 unsubscriber'r)r-s rirzbitget.un_watch_publicsiit$X.&&t||]IuU ''j9HO+(o2MT\`oToii&v.x8F ++gv.ZZ[';GGGGr0cpK|jddd}|j|jddd}|rI|j|di}|j |d}|d k7r|d k7r|d k7r|jdd d}d |d}|j ||} |j ||| |d{S7w)Nr5r r6r!r"Frrpr#r$r%r8r&r')r`r*rarrr+watch_multiple) rgr argsArrayrtr.r!argsArrayFirstrpr/rs rirzbitget.watch_public_multiplesiit$X.&&t||]IuU !^^Iq"=N'' CHO+(o2MT\`oToii&v.x8 ++gv.((mWmTTTTsB-B6/B40B6cNK|j|j|d}|j|}d}|j|}|j |j |}|t |j}|dzdz}|j|j||j|jtjd} d} | |j|j|| dgd} |j| |} |j!||| ||d{S7w) Nr. authenticatedGETz /user/verifybase64login)apiKey passphrasersignr')check_required_credentialsrrrmr subscriptionsrsecondshmacencodesecrethashlibsha256r<passwordr+r,) rgrtr.rrrmr8rauth signature operationr/rs ri authenticatezbitget.authenticates  '')vu-S!% {+(<(||sDD%D#D%cK|jddd}|j|jddd}|r6|j|d}|dk7r|d k7r|d k7r|jdd d}|j d |id{d |gd}|j ||} |j ||| |d{S787w)Nr5r r7r!r"Frpr#r$r%r8r.r&r')r`r*rarrKr+r,) rgrrvrrtr.r!rpr/rs rirtzbitget.watch_privatesiit$Y/&&t||]IuU ''j9HO+(o2MT\`oToii&v.y9 ---F ++gv.ZZ[';KLLL . Ms$BCB=3C8B?9C?Ccbd}|j|j|}|jdy)Nr8T)rfuturesr)rgrrrrms rihandle_authenticatezbitget.handle_authenticates)& =trjc0|j|d} |dk(r|j|d}|jdz|j|z}|j|jdd|||j|dd}|j |jdd ||t |y #t$r[}t|tr0d }|j||||jvr|j|=n|j|Yd}~y d}~wwxYw) Neventr.rr+r r]msgrr^Fr8T) rr{jsonthrow_exactly_matched_exceptionrcthrow_broadly_matched_exceptionr Exception isinstancerr-r@) rgrrrQrfeedbackrRers rihandle_error_messagezbitget.handle_error_message s  '2 ''877S=499W+==44T__T5J75SUY[cd&&wr:44T__T5J75SUXZbc#H-- !01-  a-&"6"66,,[9 a  sBB11 D:ADDc |j||ry|j|d}|dk(r|j||y|dk(r|j||y|j|d}|dk(r|j||y|dk(r|j ||y|dk(r|j ||y|j |j|j|j|j|j|j|j|j|j|j|jd }|j|di}|j|d d }|j||}| ||||jd d k\r|j|||jd d k\r|j||yy)NrpongrQr;r&r2) rzr<rrrrrrrrnrrrr}rrrr)rZr handle_pongrOhandle_subscription_statushandle_un_subscription_statusrrMrrrrrfindrr)) rgrrcontentrQmethodsrtopicmethods rihandle_messagezbitget.handle_message$s\  $ $VW 5 ""7I6 f    VW -  f    VW -   '2 G   $ $VW 5  K   + +FG <  M !  . .vw ? ((''))''++,,"//#00**.. $ 3 3#22  oogub1Y3%0   67 # ::h 1 $   fg . ::g ! #  " "67 3 $rjcy)NrO)rgrs rirOz bitget.ping}srjc0|j|_|SN) millisecondslastPongrgrrs rir]zbitget.handle_pongs++-rjc|Srirgrls rir^z!bitget.handle_subscription_statuss rjc|j|di}|j|d}|dk(rdnd}|j|d}|j|dd|}|d}d|dz} d|z} ||jvr |j|=| |j vr |j | =| |j vr |j | =t |jd z|z} |j| | |jd | y) Nrrprrr~rwzunsubscribe:orderbook:rz orderbook T) rrrrrr@rr{r-r rgrrrrprbr~rsrwrsubMessageHashr.s ri!handle_order_book_un_subscriptionz(bitget.handle_order_book_un_subscriptionsnnWeR0))#z:"f,v:!!#x0!!&$d;!.1AA %. T__ $' V11 1$$^4 &.. .$$[1 =!86!AB e^,t[)rjc|j|di}|j|d}|dk(rdnd}|j|d}|j|dd|}|d}d|dz} d|z} ||jvr |j|=| |j vr |j | =| |j vr |j | =t |jd z|z} |j| | |jd | y) Nrrprrr~rwzunsubscribe:trade:r=z trades T) rrrrrAr@rr{r-rros rihandle_trades_un_subscriptionz$bitget.handle_trades_un_subscriptionsnnWeR0))#z:"f,v:!!#x0!!&$d;!*VH-== !F* T[[  F# V11 1$$^4 &.. .$$[1 :!5!>? e^,t[)rjc|j|di}|j|d}|dk(rdnd}|j|d}|j|dd|}|d}d|dz} d|z} ||jvr |j|=| |j vr |j | =| |j vr |j | =t |jd z|z} |j| | |jd | y) Nrrprrr~rwzunsubscribe:ticker:ryz ticker T) rrrrrr@rr{r-rros rihandle_ticker_un_subscriptionz$bitget.handle_ticker_un_subscriptionsnnWeR0))#z:"f,v:!!#x0!!&$d;!+fX.>> "V+ T\\ ! V$ V11 1$$^4 &.. .$$[1 :!5!>? e^,t[)rjc|j|di}|j|d}|dk(rdnd}|j|d}|j|d}|jdd}|j |j d } |j || } |j|dd|} | d } d | zd z| d z} d | zd z| z}| |jvr!| |j| vr|j| | =|j||| y)Nrrprrr~r}rrrNrwzunsubscribe:candles:rr) rrrrrrarrrclean_unsubscription)rgrrrrprbr~r}rrNrrsrwrrps rihandle_ohlcv_un_subscriptionz#bitget.handle_ohlcv_un_subscriptionsnnWeR0))#z:"f,v:!!#x0""3 2??8R0__T\\<@ ''*= !!&$d;!,y83>AQQ #i/#5> T[[ DKK//KK' 2 !!&.+Frjc|j|d}||j|dig}tdt|D]}||}|j |d}|dk(r|j ||2|dk(r|j ||J|dk(r|j||b|jdst|j|||S) Nrrrr}rr<rzr) rHrrrrrqrsru startswithrx)rgrrargsListrrr}s rir_z$bitget.handle_un_subscription_statuss(>>'62  wr:;Hq#h-( CA1+C&&sI6G'!66vwGG#2267CH$2267C##H-11&'B Crjri)I__name__ __module__ __qualname__rrfrvrrrrrrrrrrrrrr rrrrrrr rrrrr)rr5rrr:r9rFrMrIr rxrr{r r rrrrrrrr rrrrrKrtrOrZrerOr]r^rqrsrurxr_ __classcell__)rhs@rirrszS #S j,. "68BBFB09; OC Os O6:"!E7!E!EF$,F$,LgR8v@>D@ D04$UYbdLULUCLUsLUimnsitLU\Q86Q8fL\:37TX\eg#UC#Us#URU#Ulpqvlw#UJV,vV,p*,&P&PPN2VN2`<> H?A HLN U)+6OQ M&62W4VW4r6&**,*F*,*F*,G6G*#F#rjr)$ccxt.async_supportccxt ccxt.async_support.base.ws.cacherrrrrEccxt.base.typesrrr r r r r rrrr!ccxt.async_support.base.ws.clientrtypingrccxt.base.errorsrrrrrrrccxt.base.preciser async_supportrrgrjrirs] AApppp4*0.'.*-%qT   & &qrj