eiddlZddlmZmZmZmZddlZddlm Z m Z m Z m Z m Z mZmZmZmZmZmZmZddlmZddlmZddlmZddlmZddlmZdd lmZdd lmZdd lmZdd lm Z dd l!m"Z"Gddej#j$Z$dS)N) ArrayCacheArrayCacheBySymbolByIdArrayCacheBySymbolBySideArrayCacheByTimestamp) AnyBalancesBoolIntOrder OrderBookPositionStrStringsTickerTickersTrade)Client)List) ExchangeError)AuthenticationError)ArgumentsRequired) BadRequest)RateLimitExceeded) ChecksumError)UnsubscribeError)Precisec eZdZdeffd ZdifdefdZifdedefdZ ifdedefdZ d ifd e de fd Z d efd ZdFdZd ifd e de fdZd efdZdFdZdd d ifdededededeef dZdifdededefdZd efdZdFdefdZd ifdededefdZifdedefdZifdededededef dZd ifd eededefd Zd efd!Z d eded"efd#Z!d$Z"d%Z#d d ifdedededee$fd&Z%d d ifd eedededee$fd'Z&ifdedefd(Z'd efd)Z(dFd*Z)d d d ifd e dededee*fd+Z+d efd,Z,dFd-Z-d d d ifde.dededee/fd.Z0d efd/Z1dFd0Z2d1Z3d d d ifde.dededee$fd2Z4d efd3Z5ifde6fd4Z7d efd5Z8ifd6Z9ifd7Z:ifd8Z;ifd9Zd ede?fd<Z@d efd=ZAd efd>ZBd efd?ZCd efd@ZDd efdAZEd efdBZFd efdCZGd efdDZHd efdEZIxZJS)Gbitgetreturnc|tt|iddddddddddddd dd dd dd dd ddddddddddddddddddddddddddddddid d d!d"d#d$d%d&d'd(d)d*d+d, d-didd.d/|jidt t t t t ttt t t t t t d0 id1id2S)3NwsT 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/privatez wss://ws.bitget.com/v3/ws/publicz!wss://ws.bitget.com/v3/ws/private)publicprivate utaPublic utaPrivatez#wss://wspap.bitget.com/v2/ws/publicz$wss://wspap.bitget.com/v2/ws/privatez#wss://wspap.bitget.com/v3/ws/publicz$wss://wspap.bitget.com/v3/ws/private)r!demo1m3m5m15m30m1H4H6H12H1D1W) r=r>r?r@rA1h4h6h12h1d1wignoreDuplicates) tradesLimit OHLCVLimit timeframesr3utaping) 30001300023000330004300053000630007300113001230013300143001530016)exactbroad)hasurlsoptions streaming exceptions) deep_extendsuperrdescriberSrrr)self __class__s M/var/www/html/volatility/venv/lib/python3.11/site-packages/ccxt/pro/bitget.pyrjzbitget.describesfd 3 3 < < > >du$U      !%$U d'!$+Dt t!"#$"&#)-"&+0"D#F%G&I #H#I%J&L   " $"     ' ). !+!4!+!4!4!2!2!4!4!4!+!4!+ !CUA UA U U U FrRcd}||d|\}}n,|ds|dr|||\}}nd}d}|||d|\}}|}|r|}||gS)NswapfutureSPOTinstType)handleProductTypeAndParamshandle_option_and_paramslower)rk methodNamemarketrRparamsrs instypeAuxs rm get_inst_typezbitget.get_inst_typeps >#>>tVLL HffVn &"2 #>>vvNN HffH !::6:z[cdd F  (~~''H&!!rnsymbolcnK|d{V||}|d}d|z}d}d}||ddd\}}|d|||\}}d|i}|rdnd }|rdnd } d ||<|d || <|||||d{VS) a watches a price ticker, a statistical calculation with the information calculated over the past 24 hours for a specific market https://www.bitget.com/api-doc/spot/websocket/public/Tickers-Channel https://www.bitget.com/api-doc/contract/websocket/public/Tickers-Channel https://www.bitget.com/api-doc/uta/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 :param boolean [params.uta]: set to True for the unified trading account(uta), defaults to False :returns dict: a `ticker structure ` Nr|ticker:r0rRFrstopicchannelinstIdtickerid) load_marketsrxrur{ watch_public) rkr|ryrx messageHashrsrRargstopicOrChannelsymbolOrInstIds rm watch_tickerzbitget.watch_tickers!!!!!!!!!V$$!&( 33FM5RWXX V--mVS&QQ&  %(6Y%(6h'^%d|^&&sKvFFFFFFFFFrncxK|d{V||ddd|d{VS)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 Nrr0)run_watch_channel)rkr|rys rmun_watch_tickerzbitget.un_watch_tickers[!!!!!!!!!**68X}V\]]]]]]]]]rnNsymbolscK|d{V||dd}||d}d}d}||ddd\}}|d|||\}}g}g}t dt |D]l}||} || } d|i} |rdnd} |rd nd } d | | <| d | | <|| |d | zm|||||d{V}|j ri}|||d <|S| |j d |S)a watches a price ticker, a statistical calculation with the information calculated over the past 24 hours for all markets of a specific list https://www.bitget.com/api-doc/spot/websocket/public/Tickers-Channel https://www.bitget.com/api-doc/contract/websocket/public/Tickers-Channel https://www.bitget.com/api-doc/uta/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 :param boolean [params.uta]: set to True for the unified trading account(uta), defaults to False :returns dict: a `ticker structure ` NFrr1rRrsrrr|rrrr~) rmarket_symbolsrxrur{rangelenappendwatch_public_multiple newUpdatesfilter_by_arraytickersrkrryrxrsrRtopics messageHashesir| marketInnerrrrrresults rm watch_tickerszbitget.watch_tickerss!!!!!!!!!%%gtU;;WQZ((33FNESXYY V--nfc6RR& q#g,,'' 5 5AQZF++f--KHD),:WWN),:XX(N#+D #.t#4D MM$     V!3 4 4 4 4223 vvVVVVVVVV ? F(/F78$ %M##DL(GDDDrnclientc|||||}|d}||j|<d|z}|||dS)Nr|r~)handle_bid_askparse_ws_tickerrresolverkrmessagerr|rs rm handle_tickerzbitget.handle_tickershp FG,,,%%g..!% V&( v{+++++rnc ||di}||dg}||di}||d}||d|}||d}|dkrdnd} ||d} ||d | } || |d| }||d d } ||d d } t j| d}|id|dd|d| |d||ddd||ddd||ddd||ddd||ddd ||d!d"d#dd$||d%d&d'| d(| d)dd*dd+|d,d||d-d.||d/d0|d1|S)2Nargdatartsrsspotcontractr|rlastPr lastPrice price24hPcnt change24h100 timestampdatetimehighhigh24h highPrice24hlowlow24h lowPrice24hbidbidPr bid1Price bidVolumebidSzbid1SizeaskaskPr ask1Price askVolumeaskSzask1Sizevwapopenopen24h openPrice24hcloselast previousClosechange percentageaverage baseVolume volume24h quoteVolume turnover24h)rrinfo) safe_value safe_integersafe_string_lower safe_string safe_market safe_string_2r string_mul safe_tickeriso8601)rkrrxrrr utaTimestamprrs marketType utaMarketIdmarketIdrchangeCoefficientchangePercentages rmrzbitget.parse_ws_tickers|oogub11w33q"--(($77 %%fdLAA ))#z:: (F 2 2VV &&sH55 ##FHkBB!!(FD*EE""68[AA ..v~{SS"-.?GG! fX&! !   Y//!  D&&vy.II ! 4%%fh FF ! 4%%fg{CC !  ++FGZHH!  4%%fg{CC!  ++FGZHH!  D!  D&&vy.II!  U!  E!  T!  d! *!! " t#! $,,V\;OO--fm]SS)! ! ! * + rncK|d{V||dd}||d}d}d}||ddd\}}|d|||\}}g}g}t dt |D]l}||} || } d|i} |rdnd } |rd nd } d | | <| d | | <|| |d| zm|||||d{V}|j ri}|||d <|S| |j d |S)a watches best bid & ask for symbols https://www.bitget.com/api-doc/spot/websocket/public/Tickers-Channel https://www.bitget.com/api-doc/contract/websocket/public/Tickers-Channel https://www.bitget.com/api-doc/uta/websocket/public/Tickers-Channel :param str[] symbols: unified symbol of the market to fetch the ticker for :param dict [params]: extra parameters specific to the exchange API endpoint :param boolean [params.uta]: set to True for the unified trading account(uta), defaults to False :returns dict: a `ticker structure ` NFrr1rRr2rsrrr|rrrbidask:) rrrxrur{rrrrrrbidsasksrs rmwatch_bids_askszbitget.watch_bids_askss!!!!!!!!!%%gtU;;WQZ((33FNESXYY V--ovsFSS& q#g,,'' 5 5AQZF++f--KHD),:WWN),:XX(N#+D #.t#4D MM$     V!3 4 4 4 4223 vvVVVVVVVV ? F(/F78$ %M##DM8WEEErnc||}|d}||j|<d|z}|||dS)Nr|r)parse_ws_bid_askrrrs rmrzbitget.handle_bid_asksO&&w//! & f&( v{+++++rnc ||di}||dg}||di}||d}||d|}||d}|dkrdnd} ||d} ||d | } || |d| }||d|||||d d ||d d ||dd||dd|d|S)Nrrrrrsrrr|rrrrrrrrr)r|rrrrrrr)rrrrrrrr) rkrrxrrrrrrsrrrs rmrzbitget.parse_ws_bid_asksroogub11w33q"--(($77 %%fdLAA ))#z:: (F 2 2VV &&sH55 ##FHkBB!!(FD*EEX&" Y//%%fg{CC++FGZHH%%fg{CC++FGZHH ! !     rnr= timeframesincelimitcK|d{V||}|d}||jd}|||}d} d} d} ||ddd\} }|d|| |\} }d| i} | r3d| d <|d | d<|| d <||dd i}d |z} nd|z| d<|d | d<d|zdz|z} || | | |d{V} |j r| ||}| | ||dd S)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 https://www.bitget.com/api-doc/uta/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 :param boolean [params.uta]: set to True for the unified trading account(uta), defaults to False :returns int[][]: A list of candles ordered, open, high, low, close, volume Nr|rQr+rRFrsklinerrintervalTkline:candlerrcandles::r) rrxrrerrur{extendrrgetLimitfilter_by_since_limit)rkr|rrrryrxrQrrrsrRrohlcvs rm watch_ohlcvzbitget.watch_ohlcvs !!!!!!!!!V$$!__T\<@@ ##J :: 33FL%QVWW V--lFCPP&    @#DM#D\DN'D [[%77F"V+KK&1DO#D\DN$y036?K''[$GGGGGGGG ? 2NN6511E))%q$GGGrncBK|d{V||jd}|||}d}d}|||}d}d} ||ddd} | d} |d|| |\}}d|i} | r:d}|| d <|d | d <|| d <||dd i}||d <||z} nd|z}|| d<|d | d<d|z} |||| d|d{VS)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 https://www.bitget.com/api-doc/uta/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 :param boolean [params.uta]: set to True for the unified trading account(uta), defaults to False :returns dict: A dictionary of `order book structures ` indexed by market symbols NrQr+rRFrrsrrrr|rTrrrr) r safe_dictrerrxrur{rr) rkr|rryrQrrrxrsrvaluesrRrs rmun_watch_ohlcvzbitget.un_watch_ohlcvs!!!!!!!!!^^DL,?? ##J ::  [[((F ..v|UERR1I--lFCPP&    0G#DM#D\DN'D [[%77F!)F: !F*KK)G%DO#D\DN$x/K**67KW]^^^^^^^^^rnc||di}||d}|dkrdnd}||dd}||dd|}|d}||j|i|j|<||dd} ||d } d} | d } | d d } nd } ||jd} || | } ||j|| }|;| |jdd}t|}||j|| <||dg}tdt|D]3}| |||}||4d}| rd|z}n d| zdz|z}|||dS)Nrrsrrrr|rrrFrTrQrPr<rrrrr)rrrrohlcvsrreplacerefind_timeframerrrrparse_ws_ohlcvrr)rkrrrrsrrrxr|rrisUtarQrstoredrrrparsedrs rm handle_ohlcvzbitget.handle_ohlcv3stoogub11))#z:: (F 2 2VV %%c8X>>!!(D$ CC!"oodk62FF F$$S)W==##C44  Ex44HHE__T\<@@ ''*== V!4i@@ >%%dlL$GGE*511F-3DK  *w33q#d))$$ " "A((a&99F MM& ! ! ! !  @"V+KK$y036?Kv{+++++rnc &|drdnd}||dd||dd||dd ||d d ||d d ||d|gS)Ninversestartrrrrrvolume)safe_integer_2 safe_number_2)rkrrx volumeIndexs rmrzbitget.parse_ws_ohlcvs2#9-5aaA   w 2 2   ufa 0 0   ufa 0 0   ueQ / /   ugq 1 1   uh < <   rncBK||g||d{VS)aJ 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 https://www.bitget.com/api-doc/uta/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 :param boolean [params.uta]: set to True for the unified trading account(uta), defaults to False :returns dict: A dictionary of `order book structures ` indexed by market symbols N)watch_order_book_for_symbols)rkr|rrys rmwatch_order_bookzbitget.watch_order_books466xOOOOOOOOOrnc(K|d{Vd}||d}|dks|dks |dks|dkr(||d}|t|z }|||dd |d{VS) a 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 https://www.bitget.com/api-doc/uta/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 :param boolean [params.uta]: set to True for the unified trading account(uta), defaults to False :returns dict: A dictionary of `order book structures ` indexed by market symbols Nbooksrr r 2 orderbookr-)rromitstrr)rkr|ryrrs rmun_watch_order_bookzbitget.un_watch_order_books!!!!!!!!!!!&'22 QJJEQJJERKKUb[[YYvw//F s5zz !G**67KIY[abbbbbbbbbrnrmessageHashTopicrwcK|d{V||}d|zdz|dz}d}d} |||dd\} }|||| |\}}d|i} | rY|| d<|d| d<||d d | d <||dd i}||d }n|| d <|d| d <|| || |d{VS)Nz unsubscribe:rr|rRFrsrrrr=Trr)rrxrur{rrrun_watch_public) rkr|rr rwryrxrrsrRrs rmrzbitget.un_watch_channelsP!!!!!!!!!V$$$'77#=x@PP 33FJuUU V--j&#vNN&    *#DM#D\DN#// DIID [[%77FYYvz22FF%DO#D\DN))#{D&IIIIIIIIIrncK|d{V||}d}d}|dks|dks |dks|dkr|t|z }d}g}g}d}||d d d\}}t d t |D]} || } || } d} |d | ||\} }d | i} |rd nd}|rdnd}|| |<| d| |<|| |d| z|rd|d <| ||||d{V}|r| S|S)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 https://www.bitget.com/api-doc/uta/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 :param boolean [params.uta]: set to True for the unified trading account(uta), defaults to False :returns dict: A dictionary of `order book structures ` indexed by market symbols NrTr r rrFr.rRrrsrrr|rr orderbook:) rrrrurrrxr{rrr)rkrrryrincrementalFeedrrrRrr|rxrsrrrrs rmrz#bitget.watch_order_book_for_symbolss!!!!!!!!!%%g.. QJJEQJJERKKUb[[ s5zz !G#O 33F>!!(D$ CC!"V+ w//tQ// %%lD99 !W, 4 0do--,,R00%8 *,'"of5O##L&#rBBD##L&#rBBD   v6 = = =   v6 = = =+4OK (*.,,y*A*AOJ '))*:JMMH))'8<< JJ ( ,V4 ,V4  __  __ ! q"AAA:~~$++JqM!,%>"#'#4#4\:#N#N %)999 JJt:FFKXXXF++IGGl"",..!Gl"",..!G"33L&)U\^effO OOO , , ,&/DOF #tv. <<<<` N)watch_trades_for_symbols)rkr|rrrys rm watch_tradeszbitget.watch_tradess622F8UE6RRRRRRRRRrncKt|}|dkrt|jdz|d{V||}d}||ddd\}}g}g}t dt|D]} || } || } d} |d| ||\} }d| i} |rdnd }|rd nd }|rd nd | |<| d| |<| | | d| z|r| |ddi}| ||||d{V}|j rB| |d}||d }|||}||||dd}|dddr-||}||d}|S|S)a7 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 https://www.bitget.com/api-doc/uta/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 :param boolean [params.uta]: set to True for the unified trading account(uta), defaults to False :returns dict[]: a list of `trade structures ` rz> watchTradesForSymbols() requires a non-empty array of symbolsNr4rRFrsrrr|r publicTradetradertrade:Trr3rN)rrrrrrurrxr{rrrrrrrrr3!remove_repeated_trades_from_arraysort_by)rkrrrry symbolsLengthrRrrrr|rxrsrrrtradesfirst tradeSymbolrfiltereds rmr[zbitget.watch_trades_for_symbolssgG A  #DG.n$noo o!!!!!!!!!%%g..33Fd |z}| | |dS) Nrrsrrrr|rOr<rrr r`)rrrrrdrrer safe_listrrparse_ws_traderr)rkrrrrsrrrxr|rrrlengthrindexrawTraderrs rm handle_tradeszbitget.handle_tradesseFoogub11))#z:: (F 2 2VV %%c8X>>!!(D$ CC!f55 >%%dlM4HHE&&F"(DK ~~gvr22Tq&!! " "AQJNEE{H((6::F MM& ! ! ! !' v{+++++rnc||dd}||d}||d}d}| |dkrdnd}n|dnd}|||dd|}||gd}||d g}||d } d} | W|| d } || } tj|| d d | d} | || |gd||dd|| ||d||d||dd||d| |gd| |gd| |gd| d |S)Nr|rposModecategoryrrrr)uTimecTimerTexecTime feeDetailrfeeCointotalFeefeecostcurrency)tradeIdrexecIdorderIdL orderTypesideS tradeScope)priceAvgprice execPriceP)sizerexecQtyv)amountr execValue) rrorderrrr|typer takerOrMakerrrr~r|) rrrsafe_integer_nrlrsafe_currency_coder string_abs safe_trade safe_string_nr) rkr_rxrrsrt defaultTyperryrer| feeCurrencyIdfeeCurrencyCodes rmrmzbitget.parse_ws_trade.s8~##E8X>>""5)44##E:66  )1V););**&KK)0)<**6K >%%fdD+FFF''/X/X/XYY NN5+r:: y!,,   ,,UI>>M"55mDDO*4+=+=eZQV+W+WXX+C$$U,F,F,FGG''y#>>" Y//X&$$UK88&&ufc:: ,,ULAA''/V/V/VWW((0V0V0VWW&&u.T.T.TUU    rnc<K|d{Vd}d}d}d}d} ||ddd\} }||}||s0||}|d|| |\}}| rd}|d z|z}d |i} | rd nd } | rd nd} | | | <| sd| d<n||ddi}|| ||| |d{V} |jr| S| | |||dS)a watch all open positions https://www.bitget.com/api-doc/contract/websocket/private/Positions-Channel https://www.bitget.com/api-doc/uta/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' :param boolean [params.uta]: set to True for the unified trading account(uta), defaults to False :returns dict[]: a list of `position structure ` Nr positions USDT-FUTURESr5rRFUTA :positionsrsrrpositiondefaultrT) rruris_emptyget_market_from_symbolsr{r watch_privaterfilter_by_symbols_since_limit)rkrrrryrxrsubscriptionHashrsrRrrr newPositionss rmwatch_positionszbitget.watch_positionss!!!!!!!!! &!33F !DN!!'844DN***0D0D'?'A'ADN8 $x(~~gvr::  q#l++,, # #A&q/K))+xJJH%%hdJGGF--k6BBH    ) ) ) LL " " " "00N9RSS q#m,,-- 7 7A'*K%%d++E!!HM#))#..G,,\8WeTTI==++ 7y+666|X %<=====rnc v||dd}||d}||ddd}||dd}|d krd nd }||gd }||d d} t j| d} d} ||d} |id|d||dd|||ddddd|d||ddd||ddd||ddd| | d||d d!d| d"| |d"d#||d$d%d&|d'|d(| |d)d||d*d+| |d,| |d-d| |d.| |d/d0S)1Nrr| marginModecrossisolated)crossedrrsholdMode hedge_modeTF) updatedTimerurv createdTime unrealizedPLR profitRater contractSizerrposIdrnotionalliquidationPriceliqPrice entryPrice openPriceAvgavgPrice unrealizedPnl unrealizedPL unrealisedPnlr contractstotalr markPricerholdSideposSidehedgedrrmaintenanceMarginkeepMarginRatemmr available marginSizeleverage marginRate)maintenanceMarginPercentage collateral initialMargininitialMarginPercentager marginRatio) rrget_supported_mappingrrr safe_position safe_symbolr parse_number safe_numberr) rkrrxr marginModeIdrhedgedIdrrpercentageDecimalrrs rmrzbitget.parse_ws_positionGsn%%h(CC'',?? // "? ?   %%h :FF"l22''2b2b2bcc  ..x,WW'(95AA   !.1L!!# H# $""8W55#  d&&xzJJ#   # * #  2 28=OQ[ \ \ #  $,,X~zRR#  T//./ZZ#  $++J77#  ++HgvFF#  L#  ))(K@@#  D&&xYGG#  f#  #  Y//!# " ## $,0+=+=hHXZ_+`+`**8[AA!--h EE'+((:>>++HlCC/# # #    rnczK|d{Vd}d}d}||\}}|rdnd}d} |-||}|d}|d}|dz|z}d} ||dd d \} }||d } d} |d||\} }d} |d||d \} }| d ks| dkr|d}| | d kr | |dz| z}n#| dkr|dz}n| dkr|dz}n | dkr|dz}d}| | d krd}n|d|| |\}}| d kr || dz|z} |r| dz} | d ks| dkr|nd}|rdnd}d}|d|\}}|d}|dz|z}|dkrd}nd}| rd}d}| dz|z} d|i}| rd nd!}|||<| s||d"<n| |d d#i}| | || ||d{V}|j r| ||}| ||||d#S)$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/spot/websocket/private/Plan-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 https://www.bitget.com/api-doc/uta/websocket/private/Order-Channel :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' :param boolean [params.uta]: set to True for the unified trading account(uta), defaults to False :returns dict[]: a list of `order structures ` N triggerOrderrz order:tradesr|rrr/rRF productTypelinearrmarginrrz:linearz COIN-FUTURESz:inversez USDC-FUTURESz :usdcfuturesrrz:stop orders-algoordersMARGINrorders-isolatedorders-crossedrrsrrrT)ris_trigger_orderrxrurhandle_market_type_and_paramshandle_sub_type_and_paramsr{handle_margin_mode_and_paramsrrrrfilter_by_symbol_since_limit)rkr|rrryrxr isTriggerrrrRrrsubTypersrrrrrrs rm watch_orderszbitget.watch_orderssZ.!!!!!!!!!  11&99 6)2@nn )  [[((FH%Fd|H%+f4K33FM5RWXX V&&v}== 99-QWXX f99-QWYabb FNNdh..V^ H  dfnn6>%+g5KK N * *% 1KK N * *% 2KK N * *%6K >dfnnHH#11-fUU Hf 6>>v1/#5>   :/'9 "fnn0@0@y#,:--( !?? vVV F  !H%+j8KZ''+*  HG+c1H<  %(6Y&^ 8#DNN[[%77F))#{!>D  -K7l3J '0A##dk(1>nnw  q#d))$$ ) )AGE))%8YOOH%%hdJGGF((77F MM& ! ! !H%F$(M& ! !M&&(())q#d))$$ 5 5A!WF*S069 ***#3h#>  ---#3k#A NN6#3 4 4 4 4v{+++  3 NN6> 2 2 2  4 NN6? 3 3 3  8 NN6#6 7 7 7 7 7 8 8rnc d|v}d|v}||d}|dkrd}|dkrd}||dd}|||}||d d }|d}||d d } ||d g} || d} || d} d} | S|| d}|tj| | |d} | |d}|du}d}|s| |d}n|r|r| |d}| | |gd}||d}||d}| ||dd}| ||dd}|dk}|dk}d}d}d}d}||dd}|r|rF||dd}||d d}||d!d}n||d }||}n|}|r |r|}|}n`|}n]||dd}nE||d d}||d"d}||d#d}tj ||}|id$|d|d%||d&d'||d(d)|d*||d+||d,d-d.|d/||d0d/d1dd|d|d|d2|d3|d4|d5|||| | dd6|S)7NrsloanTypertrTrrr|rvrstatus orderStatusryrr|rzr} triggerPricer executePrice)r fillPricerrr accBaseVolume cumExecQtynewSize cumExecValuerxbuybaseSizeqtyrfillTotalAmountrfillNotionalUsdrrr clientOrderId clientOidrrlastTradeTimestamprurr timeInForceforcepostOnlyrr~rfilled) remainingrr|rd)rrrrrrrrrrr omit_zerosafe_string_lower_n string_sub safe_orderrsafe_string_upper_2parse_ws_order_status)rkrrxisSpotisMarginrtrrr| rawStatusorderFeer| feeAmount feeObject feeCurrencyr isTriggerOrderrrrrr  newSizeValue isMarketOrderisBuy totalAmount filledAmountr~r totalFilledpartialFillAmounts rmrzbitget.parse_ws_ordersv 5(%'))%<< v  F x  H%%eXx@@!!(F33''w FF !&&uh FF ??5+r::ooh**$$S%00   **3 ::K))'*> &d2 <$$UG44EE  < <$$UN;;E>>$":":5BgBgBg"h"hiiv..{33t'9'9%R^'_'_`` ~~d&8&8 >&Z&Z[[ )    ((NN  P N"00 EJJ "00 lSS ))%1BNSS$($4$4UL$I$I!$0#4LL#.L N3&3 +&2 #'"4"4UIu"M"MKK --e\<PPL,,UFEBBK%%e->OOD&{K@@  E f  $""5)44  T--e[AA     Y//   !$"5"5eWm"T"T  D  433E7MRR    D  U  L  k  D x! " l# $#00;;+   , - rncBddddddd}||||S)Nrclosedcanceled)newlivepartially_filledr cancelled not_trigger)r)rkrstatusess rmr"zbitget.parse_ws_order_status|s: &#!   &&999rnclK|d{Vd}d}|%||}|d}|dz|z}d}|d||\}}d}d} ||ddd\} }| |dkrd }n|d|| |\}}| rd }d |z} d |i} | rd nd} d| | <| sd| d<n||ddi}|| || | |d{V} |jr| ||}| | |||dS)a watches trades made by the user https://www.bitget.com/api-doc/contract/websocket/private/Fill-Channel https://www.bitget.com/api-doc/uta/websocket/private/Fill-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 :param boolean [params.uta]: set to True for the unified trading account(uta), defaults to False :returns dict[]: a list of `trade structures ` NmyTradesr|rr*rRFrrrrzfill:rsrrfillrrT) rrxrrur{rrrrr)rkr|rrryrxrrrsrRrrrrds rmwatch_my_tradeszbitget.watch_my_tradess!!!!!!!!!  [[((FH%F%+f4K99/6SYZZ f33FOUTYZZ V >dfnnHH#11/63PVWW Hf  H"X-  %(6Y%^ 8&DNN[[%77F))#{ >AGE((//F MM& ! ! !H%F(3f(< % NN6#< = = = =v{+++++rncKd}||ddd\}}d}|dd|\}}d}|d|\}}d}d}|dks|dkrd}n|d }|s |d krd }nd }n|sd }||dd|\}}|rd}d|i}|rdnd}|||<|sd|d<n||ddi}d|z} ||| | ||d{VS)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 https://www.bitget.com/api-doc/uta/websocket/private/Account-Channel :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 :param boolean [params.uta]: set to True for the unified trading account(uta), defaults to False :returns dict: a `balance structure ` Nr)rRFaccountrprqrrraccount-isolatedaccount-crossedrrrsrrrrcoinTbalance:)rurrrrvr) rkryrRrrrsrrrrs rm watch_balancezbitget.watch_balance4s"33FNESXYY V99.$PVWW f !??PVWW F FNN 0 0%HH  #H 0++0GG/G H88Q[]eff&  H  %(6Y&^ 8$DLL[[%77F 8>>#3#33 ''[+tVTTTTTTTTTrnc||di}||d}||dg}tdt |D]>}||}|dkr3||dg}tdt |D]} || } || d} || } | |jvr |j| n| } || d}|| d}||tj ||| d <|| d | d <|| d | d <|| d| d<| |j| <E| |dd} || } | |jvr |j| n| } ||d}|.||d}tj ||| d <d|vrdnd }|||| d <||d| d<||d| d <| |j| <@| |j|_d|z}||j|dS)NrrsrrrRrFborrowdebtsdebtrfreelockedusedbalancer marginCoininterestmaxTransferOutequityfrozenrG)rrrrrrlrrrPrCr string_addr safe_balancer)rkrrrrsrr rawBalancecoinsjentry currencyIdcoderCrJrKrR freeQueryrs rmhandle_balancezbitget.handle_balancegsrnnWeR00))#z::w33q#d))$$ - -AaJ5  z62>>q#e**-- 1 1A!!HE!%!1!1%!@!@J22:>>D59T\5I5Idl400PTP\P\P^P^G!--eX>>F ,,UG<Nt>TU]>^&&t|]IuUU  =''j99HO++(o2M2MT\`oToTo=)E*62;?CC)E*628Nt>TU]>^&&t|]IuUU  =''j99HO++(o2M2MT\`oToTo=)E*62;?CC)E*628Nt>TU]>^&&t|]IuUU  k!^^Iq"==N'' CCHO++(o2M2MT\`oToTo?Bjdi&v.{;; RWHXY_H`aiHj  ++gv..((mWmTTTTTTTTTrncrK|||d}||}d}||}||j|}|t |}|dzdz}|| || |j tj d} d} | |j |j|| dgd} || |} |||| ||d{VS) Nrm authenticatedGETz /user/verifybase64login)apiKey passphrasersignrg)check_required_credentialsrrreusableFuturer subscriptionsrsecondshmacencodesecrethashlibsha256rzpasswordrrk) rkryrmrrrqrvrauth signature operationrnrs rm authenticatezbitget.authenticate s> '')))vu--S!!% &&{33( > >||||||rncK|r|jdddn|jddd}||jddd}|r]||d}|d krA|d kr;|d kr5|r|jdd d}n|jdd d}|d |id{Vd|gd} || |} |||| |d{VS)Nr6r!r:r8rarbFrsrcrdrer;rmrfrg)rdrjrerrrrk) rkrRrrrryrmrarsrnrs rmrzbitget.watch_private1 sF69`dit$\22ty?OPT?UV_?`&&t|]IuUU  >''j99HO++(o2M2MT\`oToTo>)E*62<@CC)E*629=C ---------F  ++gv..ZZ[';KLLLLLLLLLrncjd}||j|}|ddS)NrvT)rfuturesr)rkrrrrqs rmhandle_authenticatezbitget.handle_authenticateC s6& ==trncp||d} |dkr||d}|jdz||z}||jdd||||dd}||jdd ||t |d S#t$r_}t|tr*d }| ||||j vr|j |=n| |Yd}~d Sd}~wwxYw) NeventrPr]rMr!ramsgrrbFrvT) rrjsonthrow_exactly_matched_exceptionrgthrow_broadly_matched_exceptionr Exception isinstancerrOr) rkrrrr]feedbackrers rmhandle_error_messagezbitget.handle_error_messageK sV  '22 ''887S=499W+=+==44T_T5J75SUY[cddd&&wr::44T_T5J75SUXZbccc#H---5   !011 !-  a---&"666,[9 a   44444 sB2C D5AD00D5c$|||rdS||d}|dkr|||dS|dkr|||dS||d}|dkr|||dS|dkr|||dS|dkr|||dSid|jd|jd |jd |jd |j d |j d |j d|j d|j d|j d|j d|j d|j d|j d|j d|j }| |di}||ddd}| ||}| ||||ddkr| |||ddkr|||dSdS)Nrpongrryrfrprr_r^r=rrrrrrrCrrrDrErrrrrrrr)rr handle_pongrhandle_subscription_statushandle_un_subscription_statusrrqrArr_rrr safe_value_2findrK) rkrrcontentrmethodsrrmethods rmhandle_messagezbitget.handle_messaged sb  $ $VW 5 5  F""7I66 f     VW - - - F f     VW - - - F  '22 G    $ $VW 5 5 5 F K    + +FG < < < F M ! !  . .vw ? ? ? F d( T'  4-  D)  T&  d'   $+  4,  d/  t0  t*  -  .   3  t2 T&! $oogub11!!#y'2>>%00   F67 # # # ::h  1 $ $   fg . . . ::g  ! # #  " "67 3 3 3 3 3 $ #rncdS)NrS)rkrs rmrSz bitget.ping svrnc8||_|SN) millisecondslastPongrkrrs rmrzbitget.handle_pong s++--rnc|Srrrs rmrz!bitget.handle_subscription_status s rnc||di}||d}|dkrdnd}||d}||dd|}|d}d|dz} d|z} ||jvr|j|=| |jvr|j| =| |jvr|j| =t |jd z|z} | |jvr| | | | d | dS) Nrrsrrrr|zunsubscribe:orderbook:r$z orderbook T) rrrrr/rrrrrOr rkrrrrsrrrxr|rsubMessageHashrPs rm!handle_order_book_un_subscriptionz(bitget.handle_order_book_un_subscription s/nnWeR00))#z::"f,,vv:!!#x00!!&$d;;!.1AA %. T_ $ $' V1 1 1$^4 &. . .$[1 =!86!ABB V^ + + MM% 0 0 0t[)))))rnc||di}||d}|dkrdnd}||dd}||dd|}|d}d|dz} d|z} ||jvr|j|=| |jvr|j| =| |jvr|j| =t |jd z|z} | |jvr| | | | d | dS) Nrrsrrrr|zunsubscribe:trade:r`z trades T) rrrrrdrrrrrOrrs rmhandle_trades_un_subscriptionz$bitget.handle_trades_un_subscription s1nnWeR00))#z::"f,,vv:##C8<<!!&$d;;!*VH-== !F* T[  F# V1 1 1$^4 &. . .$[1 :!5!>?? V^ + + MM% 0 0 0t[)))))rnc||di}||d}|dkrdnd}||dd}||dd|}|d}d|dz} d|z} ||jvr|j|=| |jvr|j| =| |jvr|j| =t |jd z|z} | |jvr| | | | d | dS) Nrrsrrrr|zunsubscribe:ticker:r~z ticker T) rrrrrrrrrrOrrs rmhandle_ticker_un_subscriptionz$bitget.handle_ticker_un_subscription" s1nnWeR00))#z::"f,,vv:##C8<<!!&$d;;!+fX.>> "V+ T\ ! ! V$ V1 1 1$^4 &. . .$[1 :!5!>?? V^ + + MM% 0 0 0t[)))))rnc||di}||d}|dkrdnd}||dd}||dd}||d }d} |d } |d d }nd } ||jd} ||| } ||dd|} | d} d}d}| r d| z}d| z}nd| zdz| z}d| zdz| z}| |j vr| |j | vr|j | | =| |||dS)Nrrsrrrr|rrrFrrTrQzunsubscribe:kline:rzunsubscribe:candles:rr) rrrrrrrerrrclean_unsubscription)rkrrrrsrrrrrrQrrxr|rrs rmhandle_ohlcv_un_subscriptionz#bitget.handle_ohlcv_un_subscription9 snnWeR00))#z::"f,,vv:##C8<<$$S)W==##C44  Ex44HHE__T\<@@ ''*== !!&$d;;!   C.7K%.NN09>'622  wr::;Hq#h--(( C CA1+C((iAAG||G$$))66vwGGGG,,w''1,,',,}2M2MQR2R2R2267CCCCh''1,,2267CCCCh''1,,11&'BBBBg&&!++11&'BBBrnr)K__name__ __module__ __qualname__rrjboolr{rrrrrrrrrrrrrr rrrrrrr rrrrrKr7rWr2rr\r[rjrqrmr rrrrr rrrr"r>rArrHr_rr"rrrrr rrrSrrrrrrr __classcell__)rls@rmrrsV #V V V V V V p=B" " "T " " " "68GGGFGGGG<9; ^ ^C ^s ^ ^ ^ ^6:"'E'E7'E'E'E'E'ER=,F=,=,=,=,~@@@@D8vg>g>g>g>R] ] ] ] ~04$UYbdXUXUXUCXUsXUimnsitXUXUXUXUtB86B8B8B8B8Hvvvvp : : :37TX\eg-U-UC-Us-URU-Ulpqvlw-U-U-U-U^|,v|,|,|,|,|*,1U1U1U1U1U1Uf|2V|2|2|2|2|ACHHHH"DFHHHH"QS U U U U)+6TVMMMM$&6t2~4V~4~4~4~4@6&*****.*F****.*F****.#G6#G#G#G#GJ%F%%%%%%%%rnr)%ccxt.async_supportccxt ccxt.async_support.base.ws.cacherrrrrccxt.base.typesrrr r r r r rrrrr!ccxt.async_support.base.ws.clientrtypingrccxt.base.errorsrrrrrrrccxt.base.preciser async_supportrrrnrmrs AAAAAAAAAAAAvvvvvvvvvvvvvvvvvvvvvvvvvvvv444444******000000......''''''......******------%%%%%%m)m)m)m)m)T  &m)m)m)m)m)rn