eiddlZddlmZmZmZmZddlZddlm Z m Z m Z m Z m Z mZmZmZmZmZmZmZmZddlmZddlmZddlmZddlmZddlmZGd d ejjZdS) N) ArrayCacheArrayCacheBySymbolByIdArrayCacheBySymbolBySideArrayCacheByTimestamp) AnyBalancesIntMarketOrder OrderBookPositionStrStringsTickerTickers FundingRateTrade)Client)List) ExchangeError)ArgumentsRequired) NotSupportedc @eZdZdeffd ZdZdefdZddifdede d e de e fd Z ddifd e ede d e de e fd Z defd Zd4dede fdZdifded e defdZdifd e ed e defdZdefdZifdedefdZdifd edefdZdefdZd4dedefdZdifd edefdZdefdZd4dZdddifdedede d e de ef dZ ddifde e ede d e fdZ!defdZ"ifde#fd Z$defd!Z%d"Z&dddifde'de d e de e(fd#Z)ddifd e ede d e de e(fd$Z*defd%Z+d4dede(fd&Z,dddifd ede d e de e-fd'Z.defd(Z/d4dede-fd)Z0ifdede1fd*Z2defd+Z3difd,e4d-ed.ed/e efd0Z5d1Z6defd2Z7ifd3Z8xZ9S)5blofinreturnc|tt|dddddddddddddddddddddiiddd d diid dd d did did|jdddS)NTF)wswatchFundingRatewatchFundingRates watchTradeswatchTradesForSymbolswatchOrderBookwatchOrderBookForSymbols watchTicker watchTickers watchBidsAsks watchOHLCVwatchOHLCVForSymbols watchOrderswatchOrdersForSymbolswatchPositionsrswapz"wss://openapi.blofin.com/ws/publicz#wss://openapi.blofin.com/ws/private)publicprivatez/wss://demo-trading-openapi.blofin.com/ws/publicz0wss://demo-trading-openapi.blofin.com/ws/private)apitestchannelbooks) defaultType tradesLimitr"r#ia)ping keepAlive)hasurlsoptions streaming) deep_extendsuperrdescriber6)self __class__s M/var/www/html/volatility/venv/lib/python3.11/site-packages/ccxt/pro/blofin.pyr>zblofin.describesfd 3 3 < < > >$(%*#)-"&,0# $!%"(,#)-"&&&J'L!!&W'Y!!& &# w#w-   "c5A 5A 5 5 5 cdS)Nr6)r?clients rAr6z blofin.pingKsvrBrEc8||_dSN) millisecondslastPong)r?rEmessages rA handle_pongzblofin.handle_pongNs++--rBNsymbolsincelimitcNKd|d<||g|||d{VS)a get the list of most recent trades for a particular symbol https://docs.blofin.com/index.html#ws-trades-channel :param str symbol: 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 ` r callerMethodNameN)watch_trades_for_symbols)r?rLrMrNparamss rA watch_tradeszblofin.watch_tradesTsA&3!"22F8UE6RRRRRRRRRrBsymbolschK|d{V|ddd||d{V}|jrB||d}||d}|||}||||dd}||dS)a get the list of most recent trades for a list of symbols https://docs.blofin.com/index.html#ws-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 ` NTtradesr!rrL timestamp) load_marketswatch_multiple_wrapper newUpdates safe_dict safe_stringgetLimitfilter_by_since_limitsort_by) r?rTrMrNrRrV firstMarket firstSymbolresults rArQzblofin.watch_trades_for_symbolscs!!!!!!!!!224CZ\cekllllllll ? 8..33K**;AAKOOK77E++FE5+tTT||FK000rBc&||d}||d}||d}|dStdt |D]}||}||}|d} ||j| } | 5||j dd} t| } | |j| <| ||dz| z} | | | dS) Nargr2datarrLr5r1:) r[r\ safe_listrangelenparse_ws_trade safe_valuerV safe_integerr:rappendresolve) r?rErJrd channelNamereirawTradetraderLstoredrN messageHashs rA handle_tradeszblofin.handle_tradesxsnnWe,,&&sI66 ~~gv.. < Fq#d))$$ 0 0AAwH''11E8_F__T[&99F~))$, tLL#E**&, F# MM% %+f4K NN6; / / / / 0 0rBmarketc.|||SrG) parse_trade)r?rrrvs rArjzblofin.parse_ws_tradev...rBcLKd|d<||g||d{VS)a4 watches information on open orders with bid(buy) and ask(sell) prices, volumes and other data https://docs.blofin.com/index.html#ws-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 r"rPN)watch_order_book_for_symbols)r?rLrNrRs rAwatch_order_bookzblofin.watch_order_books?&6!"66xOOOOOOOOOrBcdK|d{Vd}||dd\}}d}|||dd\}}|dkr#t|jdz|zdz|zdz|d ||||d{V}|S) a watches information on open orders with bid(buy) and ask(sell) prices, volumes and other data https://docs.blofin.com/index.html#ws-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 str [params.depth]: the type of order book to subscribe to, default is 'depth/increase100', also accepts 'depth5' or 'depth20' or depth50 :returns dict: A dictionary of `order book structures ` indexed by market symbols NrPr#r2r3 z() at self moment z is not supported, coming soonT)rXhandle_param_stringhandle_option_and_paramsridrYrN)r?rTrNrRrPro orderbooks rAr{z#blofin.watch_order_book_for_symbolss!!!!!!!!!#'#;#;FDVXr#s#s & ";;FDTV_ahii V ' ! !tw}/??BVVYddhH HII I55dKIY[bdjkkkkkkkk    rBc||d}||d}||d}||d}||}|d}|dz|z} ||jvr||j|<|j|} ||d} ||d} | d krF|||| } ||d | d <| | n||d g}||d g}| | d || | d || | d<| | | d<| |j|<| | | dS)Nrdr2reinstIdrLrftsactionsnapshotseqIdnonceasksbidsrWdatetime) r[r\ safe_market orderbooks order_bookrlparse_order_bookresetrghandle_deltas_with_keysiso8601rn)r?rErJrdroremarketIdrvrLrtrrWrorderBookSnapshotrrs rAhandle_order_bookzblofin.handle_order_books"nnWe,,&&sI66 ~~gv..##C22!!(++!!C'&0 $/))&*oo&7&7DOF #OF+ %%dD11 !!'844 Z   $ 5 5dFI N N )-):):4)I)I g & OO- . . . .>>$33D>>$33D  ( (6):D A A A  ( (6):D A A A%.Ik "$(LL$;$;Ij !"+y+.....rBcKd|d<||}|d}||g|d{V}||S)a watches a price ticker, a statistical calculation with the information calculated over the past 24 hours for a specific market https://docs.blofin.com/index.html#ws-tickers-channel :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 ` r$rPrLN)rv watch_tickers)r?rLrRrvrbs rA watch_tickerzblofin.watch_tickersa&3!"V$$!))6(F;;;;;;;;f~rBcK|t|jdz|ddd||d{V}|jri}|||d<|S||jd|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://docs.blofin.com/index.html#ws-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 :returns dict: a `ticker structure ` Nz* watchTickers() requires a list of symbolsTtickersr%rL)rrrYrZfilter_by_arrayr)r?rTrRtickerrs rArzblofin.watch_tickerss ?tw)UUVV V224NT[]cdddddddd ? G(.GF8$ %N##DL(GDDDrBc|||||d}||d}||d}t dt |D]X}|||}|d}|dz|z} ||j|<||j|| YdS)Nrdr2rerrLrf) handle_bid_askr[r\rgrhriparse_ws_tickerrrn) r?rErJrdrorerprrLrts rA handle_tickerzblofin.handle_ticker s FG,,,nnWe,,&&sI66 ~~gv..q#d))$$ > >A))$q'22FH%F%+f4K#)DL NN4</ = = = =  > >rBc.|||SrG) parse_ticker)r?rrvs rArzblofin.parse_ws_ticker&s  000rBc&K|d{V||dd}||d}d}d}|d||\}}||jdd|d}g}g}t dt|D]Y} ||| } |d | d z||| d d Z| |} | ||| | ||d{V} |j ri} | | | d <| S| |jd |S) au watches best bid & ask for symbols https://docs.blofin.com/index.html#ws-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 :returns dict: a `ticker structure ` NFrrr&r/rr-bidask:rLrr2r)rXmarket_symbolsrvhandle_market_type_and_paramsimplode_hostnamer9rhrirmget_subscription_requestwatch_multipler<rZrbidsasks)r?rTrRr`r2 marketTypeurl messageHashesargsrprvrequestrrs rAwatch_bids_askszblofin.watch_bids_asks)s!!!!!!!!!%%gtU;;kk'!*--  !??Q\^dee F##DIe$4T$::$Fx$PQQ q#g,,''  A[[,,F  VH-=!= > > > KK" ,    //55**3 t?O?OPWY_?`?`bopppppppp ? G(.GF8$ %N##DM8WEEErBc||d}tdt|D]J}|||}|d}d|z}||j|<|||KdS)NrerrLr)rgrhriparse_ws_bid_askrrn)r?rErJrerprrLrts rArzblofin.handle_bid_askKs~~gv..q#d))$$ 0 0A**4733FH%F#f,K$*DM& ! NN6; / / / /  0 0rBc ||d}|||d}||d}||d}|||||||d||d||d||d|d |S) Nr-rLraskPriceaskSizebidPricebidSize)rLrWrask askVolumebid bidVolumeinfo)r\rrl safe_tickerr)r?rrvrrLrWs rArzblofin.parse_ws_bid_askTs##FH55!!(FC88!!&(33%%fd33 " Y//##FJ77))&)<<##FJ77))&)<< ! !     rB1m timeframecnKd|d<|||gg|||d{V}|||S)aQ watches historical candlestick data containing the open, high, low, and close price, and the volume of a market :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 r'rPN)watch_ohlcv_for_symbols)r?rLrrMrNrRrbs rA watch_ohlcvzblofin.watch_ohlcvdsW&2!"33fi5H4I5RWY_````````f~i((rBsymbolsAndTimeframescKt|}|dkst|dtst|jdz|d{V|ddd||d{V\}}}|jr|||}| |||dd} | ||| S)a watches historical candlestick data containing the open, high, low, and close price, and the volume of a market https://docs.blofin.com/index.html#ws-candlesticks-channel :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 rzu watchOHLCVForSymbols() requires a an array of symbols and timeframes, like [['BTC/USDT', '1m'], ['LTC/USDT', '5m']]NTcandler() ri isinstancelistrrrXrYrZr]r^create_ohlcv_object) r?rrMrNrR symbolsLengthrLrcandlesfiltereds rArzblofin.watch_ohlcv_for_symbolsrs(011 A  Z0DQ0G%N%N #DG/f%fgg g!!!!!!!!!+/+F+FtXWmpDFL,M,M&M&M&M&M&M&M" 7 ? 4$$VU33E--gueQMM'' 8DDDrBc<||d}||d}||d}||d}||}|d}|dd} || } ||j|i|j|<||j|| } | ;||j dd } t| } | |j|| <td t|D]5} || }| ||}| |6|| | g}d| zd z|z}|||dS) Nrdr2rerrLr OHLCVLimitr1rrf)r[r\rgrreplacefind_timeframeohlcvsrkrlr:rrhri parse_ohlcvrmrn)r?rErJrdrorerrvrLintervalunifiedTimeframersrNrprparsed resolveDatarts rA handle_ohlcvzblofin.handle_ohlcvsnnWe,,&&sI66 ~~gv..##C22!!(++!&&x44..x88"nnT[&"EE FV!46FGG >%%dlL$GGE*511F4:DK  0 1q#d))$$ " "A!WF%%ff55F MM& ! ! ! !/8 )C/&8 {K00000rBcK|d{V|d{Vd}|dd|\}}|dkrt|jdz|dz}ddi}||g}||jdd |d }|||| |||d{VS) a_ query for balance and get the amount of funds available for trading or funds locked in orders https://docs.blofin.com/index.html#ws-account-channel :param dict [params]: extra parameters specific to the exchange API endpoint :returns dict: a `balance structure ` N watchBalancespotz5 watchBalance() is not supported for spot markets yet:balancer2accountr/rr.) rX authenticaterrrrrr9watchr<)r?rRrrtsubrrs rA watch_balancezblofin.watch_balances%!!!!!!!!!!!!!!!!!! !??PTV\]] F   tw)``aa a :- y //66##DIe$4T$::$Fy$QRRZZ[$2B2B7F2S2SU`aaaaaaaaarBcd}||jvr i|j|<|||j|<|dz}||j||dS)Nr,r)balanceparse_ws_balancern)r?rErJrrts rAhandle_balancezblofin.handle_balancesg dl**')DL $#'#8#8#A#A Z  :- t|J/=====rBc,||SrG) parse_balance)r?rJs rArzblofin.parse_ws_balances!!'***rBcZKd|d<||gng}|||||d{VS)a watches information on multiple orders made by the user https://docs.blofin.com/index.html#ws-order-channel https://docs.blofin.com/index.html#ws-algo-orders-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]: set to True for trigger orders :returns dict[]: a list of [order structures]{@link https://docs.ccxt.com/?id=order-structure r)rPN)watch_orders_for_symbols)r?rLrMrNrR symbolsArrays rA watch_orderszblofin.watch_orderssO&3!"$*$6xxR 22<vVVVVVVVVVrBcK|d{V|d{V||dd}||ddg}|rdnd}|d|d||d{V}|jrB||d}||d } || |}| |||d d S) a watches information on multiple orders made by the user across multiple symbols https://docs.blofin.com/index.html#ws-order-channel https://docs.blofin.com/index.html#ws-algo-orders-channel :param str[] symbols: :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]: set to True for trigger orders :returns dict[]: a list of [order structures]{@link https://docs.ccxt.com/?id=order-structure Nstoptrigger orders-algoordersFr*rrLrWT) rrX safe_value_2omitrYrZrkr\r]r^) r?rTrMrNrRrr2rfirst tradeSymbols rArzblofin.watch_orders_for_symbolss!!!!!!!!!!!!!!!!!!##FFI>>6FI#677#*8--225'CZ\cekllllllll ? 8OOFA..E**5(;;KOOK77E))&% TRRRrBc|j0||jdd}t||_|j}||d}||d}||d}tdt|D]n}| ||} | d} |dz| z} | | | || | ||odS) N ordersLimitr1rdr2rerrLrf) rrlr:rr[r\rgrhriparse_ws_orderrmrn) r?rErJrNrrdrorerporderrLrts rA handle_orderszblofin.handle_orderss  ; %%dlM4HHE077DKnnWe,,&&sI66 ~~gv..q#d))$$ 0 0A''Q00E8_F%+f4K MM% NN6; / / / NN6; / / / /  0 0rBc.|||SrG) parse_order)r?rrvs rArzblofin.parse_ws_orderryrBcK|d{V|d{V|ddd||d{V}|jr|S||j|||S)a  https://docs.blofin.com/index.html#ws-positions-channel watch all open positions :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 :returns dict[]: a list of `position structure ` NF positionsr+)rrXrYrZfilter_by_symbols_since_limitr)r?rTrMrNrR newPositionss rAwatch_positionszblofin.watch_positionss!!!!!!!!!!!!!!!!!!!88 M]_fhnoooooooo ?  11$.'5RWXXXrBc|jt|_|j}||d}||d}||d}g}t dt |D]k}|||} || || |dz| dz} | | | ldS)Nrdr2rerrfrL) rrr[r\rgrhriparse_ws_positionrmrn) r?rErJcacherdrorerrppositionrts rAhandle_positionszblofin.handle_positions1s > !577DNnnWe,,&&sI66 ~~gv.. q#d))$$ 2 2A--d1g66H    ) ) ) LL " " "%+hx.@@K NN8[ 1 1 1 1  2 2rBc.|||SrG)parse_position)r?rrvs rArzblofin.parse_ws_positionHs""8V444rBcK|d{V||}d}|d||\}}d|dz}d|dd}||g}||jdd |d }|||||||d{VS) a` watch the current funding rate https://docs.blofin.com/index.html#ws-funding-rate-channel :param str symbol: unified market symbol :param dict [params]: extra parameters specific to the exchange API endpoint :returns dict: a `funding rate structure ` Nr fundingRate:rL funding-raterrr/rr-)rXrvrrrr9rr<) r?rLrRrvrrt requestParamsrrs rAwatch_funding_ratezblofin.watch_funding_rateKs!!!!!!!!!V$$ !??@RTZ\bcc F$vh'77 %Tl  //@@##DIe$4T$::$Fx$PQQZZ[$2B2B7F2S2SU`aaaaaaaaarBc||dg}||di}||}|d}||j|<d|z}|||dS)NrerrLr )rgr[parse_funding_rate fundingRatesrn)r?rErJrer fundingRaterLrts rAhandle_funding_ratezblofin.handle_funding_ratebs| ~~gvr22tQ++--e44 X&$/&!$v- {K00000rBisPublicrorPrc(K|d{V||d|\}}|dk}|r||dn|}||ddd}d}||d} | || }d} ||||\} }| dkr#t|jdz|zdz| zdzg} g} |g}t|} | dkrtdt|D]}||}d}|}|rG||}||}|d }||j ||}||z }n||}||d d }| || |d z|d zn,| d|i| || |gdrd|ig} || }|rdnd}||jdd| |}||| |||| d{VS)NrPrrTr,r~z() does not support z markets yetrrrfrLr2)rrrr-r.r/r)rXrget_list_from_object_valuesrr\rvrrrrirh timeframesrmin_arrayrrr9rr<)r?rrorPrrRisOHLCVrTr`rarrawSubscriptionsrrrpcurrentrvr2tfArraytfrtopicrprivateOrPublicrs rArYzblofin.watch_multiple_wrapperzs!!!!!!!!!#'#;#;FDVXh#i#i &(*GN`$22<CCCT`%%gtT4@@ &&w22  "++k22K !??@PR]_eff F   tw}/??BXX[eehvvww w ?GG 1  1c'll++ G G!!*%2![[11F*1oG B#//RHHHx'GG![[11F&$Tl!''...$$Ws]VH5E%EFFFF# G&  # #Y $< = = =   - - - ==&L&L&L M M :!*K 89 //0@AA&.=((I##DIe$4T$::$F$WXX((mT=M=MgW]=^=^`mnnnnnnnnnrBc d|dS)N subscribeoprrD)r?rs rArzblofin.get_subscription_requests   rBc |j|j|j|j|j|j|j|j|j|jd }d}|dkr| |d}n| |d}|dkrdS|dkr2| |j d}| ddS|dkr-t|jd z||z||d }| |d }| ||}|s!|d d kr|d }|r|||dSdS)N) pongrVr3rrrrrrr r&eventr"loginauthenticate_hashTerrorz error: rdr2rr)rKrurrrrrrrrkr\futuresrnrrjsonr[find) r?rErJmethodsmethodr'futurerdros rAhandle_messagezblofin.handle_messages $(+)'*(-. 4    f  __Wf55FF$$Wg66E ##'!!9LMMt$$$'!!#DGj$8499W;M;M$MNNN..%00C**3 ::K__Wk::F +k..x88A== *  $ F67 # # # # # $ $rBcRK||}d}t|}d|z}d|zdz|z}||||||jtj}d|j |j |||dgd}d} | |j d d | d } | | |||||d{VdS) Nr)n_z/users/self/verifyGETrr()apiKey passphraserWrsignr#r,r/rr.)check_required_credentialsrHstrstring_to_base64hmacencodesecrethashlibsha256r4passwordrr9rr<) r?rRrHrtrWrauth signaturerrrs rArzblofin.authenticates? '')))((** )  %% y +i7"r6rrKr8r rrrSrQrur rjr r|r{rrrrrrrrrrrrrrrrrrrrr rrrrr rrrrrrboolrYrr1r __classcell__)r@s@rArrs6 #6 6 6 6 6 6 p.&.... <@d[] S S SS S Sbfglbm S S S SOSaenp11d3i11[^1uyzvA1111*0F0000>//F/e////@DB P PS P PS\ P P P PSW_a!!$s)!C!fo!!!!.)/)/)/)/)/V68F 6:"EE7EEEEE&>F>>>>211f111118V>>>> +++04$UYbdWWWCWsWimnsitWWWW$OSaenpSSd3iSS[^SuyzvASSSS40F00002//F/e////8<$]ajlYYWYCYWZYquv~qYYYY&2v2222.55&5H5555<>bbsb+bbbb.1&11110CLN1o1oT1o1o_b1orvwzr{1o1o1o1of   /$V/$/$/$/$b)+[[[[[[[[rBr) ccxt.async_supportccxt ccxt.async_support.base.ws.cacherrrrr=ccxt.base.typesrrr r r r r rrrrrr!ccxt.async_support.base.ws.clientrtypingrccxt.base.errorsrrr async_supportrrDrBrArOs AAAAAAAAAAAAFFFFFFFFFFFFFFFFFFFFFFFFFFFFFF444444******......))))))i [i [i [i [i [T  &i [i [i [i [i [rB