eiqddlZddlmZmZmZddlmZmZm Z m Z m Z m Z m Z mZmZmZmZmZddlmZddlmZddlmZddlmZGdd ejjZdS) N) ArrayCacheArrayCacheBySymbolByIdArrayCacheByTimestamp) AnyBoolIntMarketOrder OrderBookPositionStrStringsTickerTickersTrade)Client)List) ExchangeError)ArgumentsRequiredc eZdZdeffd ZidfdZidfdZdedeede fd Z ifd ede fd Z ifd edefd Z d ifdedefdZd ifdedefdZdefdZd@de dede fdZd ifdedefdZd ifdedefdZdefdZd@dZdd d ifd edededeefdZdifd ededefdZd d ifd eeededefd!Zifd eeedefd"Zdefd#Z d@defd$Z!d d ifd edededee"fd%Z#ifd edefd&Z$d d ifdeedededee"fd'Z%ifdeedefd(Z&defd)Z'd@d*Z(d ifd edede)fd+Z*d ifdeedede)fd,Z+ifd edefd-Z,ifdeedefd.Z-defd/Z.d0Z/d1Z0d2Z1d d d ifd e2dededee3fd3Z4d ifd e2defd4Z5defd5Z6d@d6Z7d@d7Z8d8e2fd9Z9d d d ifdedededee:fd:Z;d ifdedeefd;Zdefd>Z?dede@fd?ZAxZBS)Abackpackreturnc "|tt|iddddddddddddd dd dd dd dd dddddddddddddddddddddddddddiidii|jdddS)NwsT watchBalanceF watchBidsAsks watchMyTrades watchOHLCVwatchOHLCVForSymbolswatchOrderBookwatchOrderBookForSymbols watchOrderswatchPositions watchTicker watchTickers watchTradeswatchTradesForSymbolsunwatchBidsAsks unwatchOHLCVunwatchOHLCVForSymbols)unwatchOrderBookunwatchOrderBookForSymbols unwatchTickerunwatchTickers unWatchTradesunWatchTradesForSymbols unWatchOrdersunWatchPositionsapizwss://ws.backpack.exchange)publicprivate timeframesi)ping keepAlive)hasurlsoptions streaming) deep_extendsuperrdescriber7)self __class__s O/var/www/html/volatility/venv/lib/python3.11/site-packages/ccxt/pro/backpack.pyr?zbackpack.describes{h 5 5 > > @ @d    d  ' !$+Dt!$tt("4 !")$#$%).2!%"&!%+/!%$(38">#?  #Q,C ,C , , , Fc K|d{V|jddd}|rdnd}||d}|||}|r||||dS|||||d{VS)Nr3rr4 UNSUBSCRIBE SUBSCRIBE)methodparams) load_marketsr:r=handle_unsubscriptionswatch_multiple) r@topics messageHashesrHunwatchurlrGrequestmessages rB watch_publiczbackpack.watch_public@s!!!!!!!!!it$X."):{  ""7F33    ' ']G D D D4((mWmTTTTTTTTTrCcK||jddd}d}t|}|rdnd}||jddd } d |zd zd z|zd z| z} ||j} || dd} | | | | d} |||j | || gd}| ||}|r| |||dS|||||d{VS)Nr3rr5 subscriberErF recvWindowzX-Window5000z instruction=&z timestamp=z&window=r ed25519)rGrH signature)check_required_credentialsr:strnonce safe_string_2r;base64_to_binarysecret array_sliceeddsaencodeapiKeyr=rJrK)r@rLrMrHrNrO instructiontsrGrUpayload secretBytesseedrZrPrQs rB watch_privatezbackpack.watch_privateNsk '')))it$Y/!   "):{'' lJPVWW  ;.4|CbH:UXbb++DK88  Q33JJt{{733T9EE +y"jA   ""7F33    ' ']G D D D4((mWmTTTTTTTTTrCrOrMrQc||}|||||tdt|D]}||}|dd}|||||ddkr(|dd}||jvr|j|=y|ddkr(|dd}||jvr|j|=|ddkri| d } | | d }| | d } ||j vr| |j |vr|j || =<|d dkr)|d d}||j vr|j |=~|ddkr)|dd}||j vr|j |=|ddkr|dkrZ|j} t| } tdt| D]} | | }|j|=9|dd}||jvr|j|=b|ddkr|dkrZ|j} t| } tdt| D]} | | }|j|=|dd}||jvr|j|=dS)Nrz unsubscribe:tickerunsubscribe:ticker:bidaskunsubscribe:bidask:candles: orderbookunsubscribe:orderbook:tradesunsubscribe:trades:ordersunsubscribe:ordersunsubscribe:orders: positionsunsubscribe:positionsunsubscribe:positions:)clientrKrangelenreplaceclean_unsubscriptionfindtickersbidsaskssplit safe_stringohlcvs orderbooksrwrylistkeysr|)r@rOrMrQri messageHashsubMessageHashsymbol splitHashes timeframecacherjs rBrJzbackpack.handle_unsubscriptionsdsS!! CGGGq#m,,--0 30 3A'*K(00DDN  % %fnk J J J))Q..$,,-BBGGT\)) V,!!(++q00$,,-BBGGT]** f-!!),,11)//44 ))+q99 ,,[!<< T[(( DK$777 K/ :!!+..!33$,,-ErJJT_,,/!!(++q00$,,-BBGGT[(( F+!!(++q00"666 KE --D"1c$ii0000!%a K//0)001FKKF,, K/!!+..!33"999 NE --D"1c$ii0033!%a N6223)001I2NNF// N62a0 30 3rCrcK|d{V||}|d}d|dz}d|z}||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://docs.backpack.exchange/#tag/Streams/Public/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.idticker:)rImarketrRr@rrHrtopicrs rB watch_tickerzbackpack.watch_tickers!!!!!!!!!V$$!-$v- &&w vFFFFFFFFFrCc@K||g|d{VS)a unWatches a price ticker, a statistical calculation with the information calculated over the past 24 hours for a specific market https://docs.backpack.exchange/#tag/Streams/Public/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)un_watch_tickersr@rrHs rBun_watch_tickerzbackpack.un_watch_tickers2**F8V<<<<<<<<` NFrrrr) rImarket_symbolsrr market_idappendrRfilter_by_arrayr)r@rrHrMrLrrmarketIds rB watch_tickerszbackpack.watch_tickerss!!!!!!!!!%%gtU;; q#g,,'' 0 0AQZF~~f--H  V!3 4 4 4 MM)h. / / / / v>>>>>>>>>##DL(GDDDrCcK|d{V||dd}g}g}tdt|D]O}||}||}|d|z|d|zP||||dd{VS)rNFrrrnTrIrrrrrrRr@rrHrLrMrrrs rBrzbackpack.un_watch_tickerss!!!!!!!!!%%gtU;; q#g,,'' A AAQZF~~f--H MM)h. / / /  !6!? @ @ @ @&&v}fdKKKKKKKKKrCrc,||di}||d}||}|||}|||}d|z}||j|<|||dS)Ndatasr) safe_dictr safe_market safe_symbolparse_ws_tickerrresolve) r@rrQrmrrr parsedTickerrs rB handle_tickerzbackpack.handle_tickers$44##FC00!!(++!!(F33++FF;; $v- + V|[11111rCrmrc||d}||dz }||d}|||}|||}||d}||d}|id|d|d||d ||d d ||d d dddddddddd|d|d|dddddddd||d||d|d|S)NErcor timestampdatetimehighhlowlbid bidVolumeask askVolumevwapopencloselast previousClosechange percentageaveragevV) baseVolume quoteVolumeinfo) safe_integer parse_to_intrrr safe_tickeriso8601 safe_number) r@rmr microsecondsrrrrrs rBrzbackpack.parse_ws_tickers((55 %%lT&9:: ##FC00!!(F33!!(F33,,,,! f! !   Y//!  D$$VS11 ! 4##FC00 ! 4 !  !  4!  !  D!  D!  T!  D!  T!  d! $!! " t#! $**6377++FC88)! ! ! * + rCcK|d{V||dd}g}g}tdt|D]O}||}||}|d|z|d|zP||||d{V||jd|S)a~ watches best bid & ask for symbols https://docs.backpack.exchange/#tag/Streams/Public/Book-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 ` NFr bookTicker.bidask:r) rIrrrrrrRrrrs rBwatch_bids_askszbackpack.watch_bids_asks)s!!!!!!!!!%%gtU;; q#g,,'' 5 5AQZF~~f--H MM-(2 3 3 3  V!3 4 4 4 4 v>>>>>>>>>##DM8WEEErCcK|d{V||dd}g}g}tdt|D]O}||}||}|d|z|d|zP||||dd{VS)a7 unWatches 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 ` NFrrrpTrrs rBun_watch_bids_askszbackpack.un_watch_bids_asks?s!!!!!!!!!%%gtU;; q#g,,'' A AAQZF~~f--H MM-(2 3 3 3  !6!? @ @ @ @&&v}fdKKKKKKKKKrCc,||di}||d}||}|||}|||}d|z}||j|<|||dS)Nrrr)rrrrparse_ws_bid_askrr) r@rrQrrrr parsedBidAskrs rBhandle_bid_askzbackpack.handle_bid_askQs ~~gvr22##D#..!!(++!!(F33,,T6:: $v- , f|[11111rCc ||d}|||}||d}||d}||dz }||d}||d}||d} ||d} |||||||| | |d |S) NrrrraAbB)rrrrrrrr)rrrrrr) r@rmrrrrrrrrrs rBrzbackpack.parse_ws_bid_askjs##FC00!!(F33!!&(33((55 %%lT&9:: vs++$$VS11 vs++$$VS11 " Y//"" ! !     rC1msincelimitcdK|||gg|||d{V}|||S)a watches historical candlestick data containing the open, high, low, close price, and the volume of a market https://docs.backpack.exchange/#tag/Streams/Public/K-Line :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 N)watch_ohlcv_for_symbols)r@rrrrrHresults rB watch_ohlcvzbackpack.watch_ohlcvsL33fi5H4I5RWY_````````f~i((rCrcDK|||gg|d{VS)a watches historical candlestick data containing the open, high, low, and close price, and the volume of a market https://docs.backpack.exchange/#tag/Streams/Public/K-Line :param str symbol: unified symbol of the market to fetch OHLCV data for :param str timeframe: the length of time each candle represents :param dict [params]: extra parameters specific to the exchange API endpoint :returns int[][]: A list of candles ordered, open, high, low, close, volume N)un_watch_ohlcv_for_symbols)r@rrrHs rBun_watch_ohlcvzbackpack.un_watch_ohlcvs844vy6I5JFSSSSSSSSSrCsymbolsAndTimeframescFKt|}|dkst|dtst|jdz|d{Vg}g}t dt|D]}||} || d} || } || d} ||j | | } | d| zdz| dz| d| d zd z| 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://docs.backpack.exchange/#tag/Streams/Public/K-Line :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 int[][]: A list of candles ordered, open, high, low, close, volume rz_ watchOHLCVForSymbols() requires a an array of symbols and timeframes, like ['ETH/USDC', '1m']Nkline..rcandles:rrrT)r isinstancerrrrIrrrr6rrR newUpdatesgetLimitfilter_by_since_limitcreate_ohlcv_object)r@rrrrH symbolsLengthrLrMrsymbolAndTimeframerrtfintervalrrrqfiltereds rBrz backpack.watch_ohlcv_for_symbolss011 A  Z0DQ0G%N%N #DG/P%PQQ Q!!!!!!!!! q#23344 Q QA!5a!8 ''(:A>>H[[**F!!"4a88B''R@@H MM(X-3fTlB C C C  fX.>!>!Dx!O P P P P+/+<+>H[[**F!!"4a88B''R@@H MM(X-3fTlB C C C  !7&:J!JS!PS[![ \ \ \ \&&v}fdKKKKKKKKKrCc||di}||d}||}|d}||d}|d}||d} ||jvr i|j|<| |j|vr;||jdd} t| } | |j|| <|j|| } ||} | | d |zd z| z}| || | g|dS) Nrrrstreamrr OHLCVLimitrrrr) rrrrrrr;rparse_ws_ohlcvrr)r@rrQrrrrrpartsrrstoredohlcvparsedrs rB handle_ohlcvzbackpack.handle_ohlcvsQ(~~gvr22##D#..X&&!!!'844 S!!$$UA.. $+%%"$DK T[000%%dlL$GGE*511F-3DK  * F#I.$$T** V 6)C/);  51;?????rCc (|||d||d||d||d||d||dgS)NTrrrrr) parse8601rr)r@r rs rBrzbackpack.parse_ws_ohlcv s$ NN4++E377 8 8   UC ( (   UC ( (   UC ( (   UC ( (   UC ( (   rCcDK||g|||d{VS)a! watches information on multiple trades made in a market https://docs.backpack.exchange/#tag/Streams/Public/Trade :param str symbol: unified symbol of the market to fetch the ticker for :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 `ticker structure ` N)watch_trades_for_symbols)r@rrrrHs rB watch_tradeszbackpack.watch_trades$s622F8UE6RRRRRRRRRrCc@K||g|d{VS)aw unWatches from the stream channel https://docs.backpack.exchange/#tag/Streams/Public/Trade :param str symbol: unified symbol of the market to fetch trades for :param dict [params]: extra parameters specific to the exchange API endpoint :returns dict[]: a list of `trade structures ` N)un_watch_trades_for_symbolsrs rBun_watch_tradeszbackpack.un_watch_trades2s255vhGGGGGGGGGrCcK|d{V||}t|}|dkrt|jdzg}g}t dt|D]O}||} || } |d| z|d| zP||||d{V} |j rB| | d} | | d} | | |}| | ||dd}||dS) a  watches information on multiple trades made in a market https://docs.backpack.exchange/#tag/Streams/Public/Trade :param str[] symbols: unified symbol of the market to fetch trades for :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 `ticker structure ` Nrz> watchTradesForSymbols() requires a non-empty array of symbolstrade.trades:rrT)rIrrrrrrrrRr safe_valuerrrsort_by)r@rrrrHrrLrMrrrrwfirst tradeSymbolrs rBrz!backpack.watch_trades_for_symbols>s~!!!!!!!!!%%g..G A  #DG.n$noo o q#g,,'' 5 5AQZF~~f--H MM(X- . . .  V!3 4 4 4 4((GGGGGGGG ? 8OOFA..E**5(;;KOOK77E++FE5+tTT||FK000rCcK|d{V||}t|}|dkrt|jdzg}g}t dt|D]O}||}||}|d|z|d|zP||||dd{VS)az unWatches from the stream channel https://docs.backpack.exchange/#tag/Streams/Public/Trade :param str[] symbols: unified symbol of the market to fetch trades for :param dict [params]: extra parameters specific to the exchange API endpoint :returns dict[]: a list of `trade structures ` Nrz@ unWatchTradesForSymbols() requires a non-empty array of symbolsrrxT) rIrrrrrrrrR) r@rrHrrLrMrrrs rBrz$backpack.un_watch_trades_for_symbols^s!!!!!!!!!%%g..G A  #DG.p$pqq q q#g,,'' A AAQZF~~f--H MM(X- . . .  !6!? @ @ @ @&&v}fdKKKKKKKKKrCc||di}||d}||}|d}||jvr5||jdd}t |}||j|<|j|} |||} | | d|z} | | | | | ddS)Nrrr tradesLimitrrrw) rrrrwrr;rparse_ws_traderr) r@rrQrrrrrrrtraders rB handle_tradeszbackpack.handle_tradesvs$~~gvr22##D#..X&&!$+%%%%dlM4HHE&&F"(DK  F###D&11 U&( uk***uh'''''rCch||d}||dz }||d}||d}|||}||d}|rdnd}|rdnd } ||d } ||d } d} |dkr||d } n||d } |||||||d| d|| | | ddddd |S)Nrrtrmsellbuymakertakerpqrrrcurrencycost) rrrrrordertypeside takerOrMakerpriceamountr-fee)rrrr safe_bool safe_trader) r@r rrrrrisMakerr0r1r2r3orderIds rBrzbackpack.parse_ws_tradesm((44 %%lT&9::   eS ) )##E3//!!(F33..,, +vve")6www   ,,!!%-- 5==&&uc22GG&&uc22G" Y//X&(   " # rCcBK||g||d{VS)a4 watches information on open orders with bid(buy) and ask(sell) prices, volumes and other data https://docs.backpack.exchange/#tag/Streams/Public/Depth :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)r@rrrHs rBwatch_order_bookzbackpack.watch_order_books466xOOOOOOOOOrCcK|d{V||dd}||}g}g}tdt |D]D}||}|d|z||} d| z} || E||||d{V} | S)a https://docs.backpack.exchange/#tag/Streams/Public/Depth watches information on open orders with bid(buy) and ask(sell) prices, volumes and other data :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 str [params.method]: either '/market/level2' or '/spotMarket/level2Depth5' or '/spotMarket/level2Depth50' default is '/market/level2' :returns dict: A dictionary of `order book structures ` indexed by market symbols NFr orderbook:depth.)rIr market_idsrrrrRr) r@rrrH marketIdsrMrLrrrrrus rBr:z%backpack.watch_order_book_for_symbolss!!!!!!!!!%%gtU;;OOG,,  q#g,,'' ! !AQZF  !6 7 7 7 |Hx'E MM% ++FM6JJJJJJJJ    rCc@K||g|d{VS)a unWatches information on open orders with bid(buy) and ask(sell) prices, volumes and other data :param str symbol: unified array of symbols :param dict [params]: extra parameters specific to the exchange API endpoint :returns dict: A dictionary of `order book structures ` indexed by market symbols N)un_watch_order_book_for_symbolsrs rBun_watch_order_bookzbackpack.un_watch_order_books2996(FKKKKKKKKKrCcK|d{V||dd}||}g}g}tdt |D]D}||}|d|z||}d|z} || E||||dd{VS)a unWatches information on open orders with bid(buy) and ask(sell) prices, volumes and other data :param str[] symbols: unified array of symbols :param dict [params]: extra parameters specific to the exchange API endpoint :param str [params.method]: either '/market/level2' or '/spotMarket/level2Depth5' or '/spotMarket/level2Depth50' default is '/market/level2' :returns dict: A dictionary of `order book structures ` indexed by market symbols NFrrvr>T)rIrr?rrrrR) r@rrHr@rMrLrrrrs rBrBz(backpack.un_watch_order_book_for_symbolss!!!!!!!!!%%gtU;;OOG,,  q#g,,'' ! !AQZF  !9F!B C C C |Hx'E MM% &&v}fdKKKKKKKKKrCc||di}||d}||}||jvr||j|<|j|}||d}||d}d|z} |lt |j} |ddd} | | kr| |j || |di|j |dS||krdS| ||| || dS) Nrrr]ur=r snapshotDelay )rrrr order_bookrrr handle_optionspawnload_order_bookr handle_deltar) r@rrQrrrstoredOrderBookr] deltaNoncer cacheLengthrGs rBhandle_order_bookzbackpack.handle_order_book s[&~~gvr22##D#..!!(++$/))&*oo&7&7DOF #/&1!!/7;;&&tS11 "V+ =o344K!../?RTUUMm++ 4/fdTVWWW  ! ( ( . . . F Z   F /4000 44444rCc|||ddz }||d<|||d<||d|d<||dg}||dg}|d }|d }||||||dS) Nr rrrrFr]rrbidsasks)rrr safe_listhandle_bid_asks)r@rudeltarrSrT storedBids storedAskss rBrMzbackpack.handle_delta7s%%d&7&7s&C&Cd&JKK !* + $ Y 7 7 *!..uc:: '~~eS"--~~eS"--v& v&  Z... Z.....rCctdt|D]2}|||}||3dS)Nr)rr parse_bid_ask storeArray)r@bookSidebidAsksrbidAsks rBrVzbackpack.handle_bid_asksCsYq#g,,'' ( (A'' 33F    ' ' ' ' ( (rCc||d}||d}||d}||dz krdStdt|D]I}||}||d}||d} ||dz kr || kr|cSJt|S)Nrr]UrrF)rrrr) r@rur firstDeltar]firstDeltaStartrrW deltaStartdeltaEnds rBget_cache_indexzbackpack.get_cache_indexHs^^E1-- !!)W55++J<< ?Q& & &2q#e**%%  A!HE**5#66J((44Ha''eh.>.>5zzrCcRK|d{Vd}|||}|d}d}d}|d|dz}d|z}||g|g|d{V}|jr|||}|||||dS) a7 watches information on multiple orders made by the user https://docs.backpack.exchange/#tag/Streams/Private/Order-update :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 ` Nraccount.orderUpdateryaccount.orderUpdate.rzorders:T)rIrrjrrfilter_by_symbol_since_limit) r@rrrrHrrrrys rB watch_orderszbackpack.watch_ordersXs!!!!!!!!!  [[((FH%F%  *VD\9E#f,K))5'K=&IIIIIIII ? 3OOFE22E00tTTTrCcK|d{Vd}|||}|d}d}d}|d|dz}d|z}||g|g|dd{VS) a unWatches information on multiple orders made by the user https://docs.backpack.exchange/#tag/Streams/Private/Order-update :param str [symbol]: unified market symbol of the market orders were made in :param dict [params]: extra parameters specific to the exchange API endpoint :returns dict[]: a list of `order structures ` Nrrirzrjrr{T)rIrrjrs rBun_watch_orderszbackpack.un_watch_ordersss!!!!!!!!!  [[((FH%F%*  *VD\9E/&8K''+MMMMMMMMMrCcd}||di}||d}||}|d}|||}|j} | 2||jdd} t| } | |_| || | ||dz|z} | | | dS)Nryrrr ordersLimitrrr) rrrparse_ws_orderryrr;rrr) r@rrQrrrrrr ryrsymbolSpecificMessageHashs rB handle_orderzbackpack.handle_orders2 ~~gvr22##D#..!!(++!$$T622 >%%dlM4HHE+E22F DK fv{+++$/#$5$>!v899999rCc||d}||d}||d}||dz }|||d|}||d}|||}|d} ||d} ||d } |||d } ||d } ||d }||d }||d}||d}d}||d}||dd}|id|d|d|d| |ddd|d| d| d| d| d| ddd|ddd|d |d!|d|d|d"|S)#NrrrrXrrrfSr)Pr*ZrNr+r clientOrderIdrrlastTradeTimestampstatusr/ timeInForcer0r2 stopPrice triggerPricerr3r-filled) remainingr4rwr) rrrparse_ws_order_statusrsafe_string_lowerparse_ws_order_sider safe_orderr)r@r.rrr{rrr}rrr/r~r0r2rr3r-rr4 feeCurrencys rBrqzbackpack.parse_ws_orders6  eS ) )((44 ((44 %%lT&9:: ++D,<,` Nrz positions:account.positionUpdate.r|account.positionUpdateT) rIrrrrrrjrfilter_by_symbols_since_limitr|) r@rrrrHrMrLrrr|s rBwatch_positionszbackpack.watch_positionssB!!!!!!!!!%%g..   1c'll++ R R $$%6%?@@@ 7$..:P:PPQQQQ R   - - - MM2 3 3 3,,V]FKKKKKKKK ?  11$.'5RWY]^^^rCcK|d{V||}g}g}|ltdt|D]M}||}|d|z|d||zNn*|d|d||||dd{VS)a unWatches from the stream channel https://docs.backpack.exchange/#tag/Streams/Private/Position-update :param str[] [symbols]: list of unified market symbols to watch positions for :param dict params: extra parameters specific to the exchange API endpoint :returns dict[]: a list of `position structure ` Nrr~rr}rT)rIrrrrrrj)r@rrHrMrLrrs rBun_watch_positionszbackpack.un_watch_positions,s!!!!!!!!!%%g..   1c'll++ R R $$%BV%KLLL 7$..:P:PPQQQQ R  !8 9 9 9 MM2 3 3 3'' vtLLLLLLLLLrCcd}||di}|jt|_|j}||}||d}||dz }||d<|||d<|||dz|dz} ||g|||g| dS) Nr|rrrrrrrr) rr|rparse_ws_positionrrrrr) r@rrQrrrparsedPositionrrrrs rBhandle_positionszbackpack.handle_positionsDs0" ~~gvr22 > !355DN//55((s33 %%lT&9:: &/{#%)\\)%<%<z" ^$$$$/#$5x8P$P!'555')BCCCCCrCc ||d}||d}|||}|d}||d}||d}||d}||d} ||d} ||d } ||d } ||d } d }d }| dkrd}| d}d}||d}||dz }||d}||d}|id|d|d|d|ddd|d|d| d| ddd| ddd| d |d!|d"|d#||d|dd|ddd$S)%Nrrrnrrr)rxQMr*Flongrshortrrr$rvrrnotional marginModeliquidationPrice entryPrice realizedPnl unrealizedPnlr contracts contractSize markPricer0hedgedrr)maintenanceMarginmaintenanceMarginPercentage collateral initialMargininitialMarginPercentageleverage marginRatio)rrrrr safe_positionr)r@positionrrrrrrrr unrealisedPnlrr netQuantityrr0rrrrs rBrzbackpack.parse_ws_positionks*  h , ,##Hc22!!(F33!##Hc22++Hc::%%h44 &&x55 ((377 $$Xs33 $$Xs33 &&x55  ??D  FD((377 %%lT&9:: &*&6&6x&E&E#"&"2"28S"A"A!!# H# "#  f#   # $ #  0 #  *#  ;#  ]#  $#  #  D#  #  D#  f# !# "  Y//## $"&+F!'>1# # #    rCc|||sdS||d}||d}|dkr|||dS|dkr|||dS|dkr|||dS|dkr|||dS|dkr|||dS|dks*|d ks$|d ks|d ks|d ks|d ks |dks|dkr|||dS|dks|dks |dks|dkr| ||dSdS)Nrerm bookTickerkliner depth orderAccepted orderUpdate orderFillorderCancelled orderExpired orderModified triggerPlaced triggerFailedpositionAdjustedpositionOpenedpositionClosedpositionUpdated) handle_error_messagerrrrr r!rQrsr)r@rrQrevents rBhandle_messagezbackpack.handle_messages!((99  F~~gv..  s++ H     vw / / / / / l " "    0 0 0 0 0 g     fg . . . . . g     vw / / / / / g    " "67 3 3 3 3 3 o % %-)?)?5KCWCW[`dt[t[tx}BPyPyPTY]lTlTlpuyHpHpHLQUdLdLd   fg . . . . . ( ( (E5E,E,ERbIbIbfkpAgAgA  ! !&' 2 2 2 2 2gAgArCc"||di}||d} |0||d}t|jdz|zdS#t $r}||Yd}~nd}~wwxYwdS)NerrorcoderQ T)rrrrr Exceptionreject)r@rrQrrmsgrs rBrzbackpack.handle_error_messagesw44  // &&ui88#DGcMC$78884    MM!         ts2A## B -BB )N)C__name__ __module__ __qualname__rr?rRrjr\rdictrJrrrrrrrrrr rrrrrrrrrrrr rrrrrrr!rr r;r:rCrBrQrMrVrgr r rlrnrsrqrrr rrrrrrr __classcell__)rAs@rBrrs- #- - - - - - ^@B5 U U U UACEUUUU,33#33d3i33RV33333333j68GGGFGGGG"9; = =C =s = = = =6:"EE7EEEEE,9=RLLgLCLLLL*2F22226++d+F+f++++Z8rs fffffffffftttttttttttttttttttttttttttt444444******......JJJJJt!*JJJJJrC