eiddlZddlmZmZmZddlZddlmZm Z m Z m Z m Z m Z mZmZddlmZddlmZddlmZddlmZddlmZdd lmZGd d ejjZdS) N) ArrayCacheArrayCacheBySymbolByIdArrayCacheByTimestamp)AnyBalancesIntOrder OrderBookStrTickerTrade)Client)List) ExchangeError)AuthenticationError) ChecksumError)Precisec :eZdZdeffd ZifdZifdZdZdddifded ed e d e de e f d Z difded efd Z defdZddifded e d e de efdZifdefdZdddifded e d e de efdZifdedefdZifdefdZifdefdZdefdZd*dZdefdZd*dZdifded e defdZdefdZdefdZ ifde!fdZ"defdZ#dZ$defd Z%defd!Z&defd"Z'ifd#Z(defd$Z)dddifded e d e de e*fd%Z+defd&Z,d'Z-d*d(Z.defd)Z/xZ0S)+bitfinexreturnc|tt|ddddddddddddddddddddiid d dd d d dS)NTF)ws watchTicker watchTickerswatchOrderBook watchTradeswatchTradesForSymbols watchMyTrades watchBalance watchOHLCV watchOrders unWatchTicker unWatchTrades unWatchOHLCVunWatchOrderBookapirzwss://api-pub.bitfinex.com/ws/2zwss://api.bitfinex.com/ws/2)publicprivateP0F0)precfreqchecksum)r ordersLimit)hasurlsoptions) deep_extendsuperrdescribe)self __class__s O/var/www/html/volatility/venv/lib/python3.11/site-packages/ccxt/pro/bitfinex.pyr5zbitfinex.describesh 5 5 > > @ @# %"&#).!% $"#!%!% $$(""C#@! $## $ 3!C !C ! ! ! c,K|d{V||}|d}|jddd}||}|dz|z}d||d} ||||| ||dd id{V} ||jdd } | rK|d krE|j|} | r6| ds.d |j|d<| d d dd{V| S)Nidr&rr': subscribe)eventchannelsymbolr-FTbookconfi)r>flags) load_marketsmarketr1clientwatchr3 safe_boolr2 subscriptionssend) r6r?r@paramsrEmarketIdurlrF messageHashrequestresultr-subs r8r=zbitfinex.subscribe8sy!!!!!!!!!V$$$<it$X.S!!mh.     zz#{D4D4DWf4U4UWbeoqvdwxxxxxxxx>>$, DAA  F**&{3C 3z? @D$[1*=kk#### r9cK|d{V||}|d}|jddd}||}|dz|z} d|zdz|z} d|zdz|z} ||j| } d| d} d| z}| |j|<| g| g|d |gd }||| || || |d{VS) Nr;r&rr'r< unsubscribe: unsubscriber>chanIdT messageHashessubMessageHashestopicrTsymbols)rDrEr1rF safe_stringrIrGr3)r6r?rZr@rKrErLrMrFsubMessageHashrN unSubTopic channelIdrO unSubChanMsg subscriptions r8 un_subscribezbitfinex.un_subscribePsF!!!!!!!!!V$$$<it$X.S!! 31$w.4x? (5036? $$V%9:FF "  & 1 -;\*)]!/ 0x   ZZ[$2B2B7F2S2SU`bnooooooooor9cK|d{V|d{V|jddd}|||ddd{VS)Nr&rr()rD authenticater1rG)r6rNrMs r8subscribe_privatezbitfinex.subscribe_privateis!!!!!!!!!!!!!!!!!!it$Y/ZZ[$:::::::::r91mNr@ timeframesincelimitcK|d{V||}|d}||j||}d}d|zdz|dz} |dz|zdz|dz} d|| d} |jd d d } || | || || d{V} |jr| ||}| | ||d d 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 Nr@candlestrade:r<r;r=)r>r?keyr&rr'rT) rDrEr\ timeframesr1rGr3 newUpdatesgetLimitfilter_by_since_limit)r6r@rhrirjrKrEintervalr?rnrNrOrMohlcvs r8 watch_ohlcvzbitfinex.watch_ohlcvos9!!!!!!!!!V$$!##DOY JJ!C'&,6mh.4vd|C     it$X.jjk43C3CGV3T3TVabbbbbbbb ? 2NN6511E))%q$GGGr9c:K|d{V||}|d}||j||}d}|dz|zdz|dz}d|z}|jddd } || } d |zdz|dz} || j| } d | d } d| z}|| j|<|g|gd d|gd}|| ||| |||d{VS)a unWatches 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 dict [params]: extra parameters specific to the exchange API endpoint :returns bool: True if successfully unsubscribed, False otherwise Nr@rlr<r;rSr&rr'zunsubscribe:trade:rTrUrtTrW) rDrEr\ror1rFrIrGr3)r6r@rhrKrErsr?r]rNrMrFsubIdr_rOr`ras r8un_watch_ohlcvzbitfinex.un_watch_ohlcvso!!!!!!!!!V$$!##DOY JJ 31C7&,F$~5 it$X.S!!$x/#5t D$$V%95AA "  & 1 -;\*)]!/ 0x   ZZ[$2B2B7F2S2SU`bnooooooooor9rFc||dg}d}||d}t|tr|}n|g}||d}||d}|d} || d} |} | dd} | | dzd} || } || } | d}|dz| zdz| z}||j|i|j|<||j|| }|;| |j d d }t|}||j|| <t|}td|D];}|||z dz }||| }||<|||dS) Nrdrr?rnr<rmr@ OHLCVLimitr.) safe_value isinstancelistr\splitreplace safe_marketfind_timeframeohlcvs safe_integerr2rlenrange parse_ohlcvappendresolve)r6rFmessageradatarfirstr?rnkeyPartsrsrLrErhr@rNstoredrj ohlcvsLengthirtparseds r8 handle_ohlcvzbitfinex.handle_ohlcvs \w2..a(( eT " " FFVF//, ::|U3399S>>##Ha00##Hb11##HsNB77!!(++''11 !mh.4x? "oodk62FF FV!4i@@ >%%dlL$GGE*511F-3DK  *6{{ q,'' " "A` tradesN timestampT)r=rprqrr)r6r@rirjrKrs r8 watch_tradeszbitfinex.watch_tradessh~~h???????? ? 3OOFE22E))&% TRRRr9cBK|dd||d{VS)aS unWatches the list of most recent trades for a particular symbol :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 ` rNrbr6r@rKs r8un_watch_tradeszbitfinex.un_watch_trades 4&&x66JJJJJJJJJr9c*K|d{Vd}|#||}|d|dzz }||d{V}|jr|||}|||||dS)a watches information on multiple trades made by the user :param str symbol: unified market symbol of the market trades were made in :param int [since]: the earliest time in ms to fetch trades for :param int [limit]: the maximum number of trade structures to retrieve :param dict [params]: extra parameters specific to the exchange API endpoint :returns dict[]: a list of `trade structures ` NmyTrader<r;TrDrErfrprqfilter_by_symbol_since_limit)r6r@rirjrKrNrErs r8watch_my_tradeszbitfinex.watch_my_tradess!!!!!!!!!  [[((F 3- -K--k:::::::: ? 3OOFE22E00tTTTr9c@K|d||d{VS)a watches a price ticker, a statistical calculation with the information calculated over the past 24 hours for a specific market :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 ` tickerN)r=rs r8 watch_tickerzbitfinex.watch_ticker's0^^Hff=========r9cBK|dd||d{VS)a unWatches a price ticker, a statistical calculation with the information calculated over the past 24 hours for a specific market :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 ` rNrrs r8un_watch_tickerzbitfinex.un_watch_ticker0rr9cd}||d}||}|d}||}|dz|dz} |j0||jdd} t | |_|j} | || |_|| ||| | dS)Nrr@r<r; tradesLimitr.) r|parse_ws_traderEmyTradesrr2rrr) r6rFrranamertrader@rErNrj tradesArrays r8handle_my_tradezbitfinex.handle_my_trade9s,w**##D))xV$$Sj6$</ = %%dlM4HHE2599DMm 5!!!# {D))){K00000r9cH||d}||d}||}|dz|z}||jdd}|d} ||j| } | t |} | |j| <t|} | dkrs||dg} t| } td| D];}| |z dz }| | ||}| |//, ::##L(;;!!(++mh. '' mTJJ !f55 > ,,F"(DK G A  ^^GQ33F[[F1f%% & & Q,,VE]FCC f%%%% & ##GQ//Dt||OOGQ33E((77F MM& ! ! !v{+++++r9c@t|}|dk}|s||dnd}|||}|rdnd}|rdnd}|rdnd}|d}||d} | 7| d d krd } n| d d krd } |s||dnd} ||d} |||} |||} |||}|t j|}d}|t j|drdnd}| ||}||d}d}|0||d}| |}||d}||d}d}| |d krdnd}| || | | || | | ||| |d|d |S)Nrdrr;LIMITrjMARKETrEr0buysell )costcurrencytakermaker) infordatetimer@r;orderr takerOrMakersidepriceamountrfee) rr\rfindr parse_numberr string_abs string_gt safe_symbolsafe_currency_code safe_tradeiso8601)r6rrE numFieldsisPublicrL createdKeypriceKey amountKeyrorderIdr;rr amountStringrrr@feeValuer currencyIdcoderrs r8rzbitfinex.parse_ws_tradesVJJ >6>I4##E1---T!!(F33")QQ  '11a!(AAq $<q))  yy!!B&&8$$r))5=H$""5!,,,D   eQ ' '%%eZ88   11''y99 ""7#5l#C#CDD  #-lC@@L55fD!!(F33##E1--  ))%44J**:66D  C!!%++  ',{{77L" Y//(    r9c2||d}||d}||}||}|||}d} | dz|z} ||j|<||| dS)Nrdr@rr<)r|r\rrparse_ws_tickertickersr) r6rFrrarrLrEr@rr?rNs r8 handle_tickerzbitfinex.handle_tickers$!,,##L(;;!!(++!!(++%%ff55mh. % Vv{+++++r9ct|d|}|d}||d}||d}|id|ddddd||dd||d d ||d d ||d d||dd||dddddd|d|ddd|d||ddd||dd|d|S)Nr@rrrrhighrlowrbidr bidVolumerdaskr askVolumervwapopencloselast previousClosechange percentageraverage) baseVolume quoteVolumer)rr\ safe_ticker)r6rrEr@rrs r8rzbitfinex.parse_ws_tickers!!$//!**!!&!,,! f! !  !  D$$VQ// ! 4##FA.. ! 4##FA.. !  ))&!44!  4##FA..!  ))&!44!  D!  D!  T!  D!  T!  f! $**6155!! " t#! $**6155)! ! ! * + r9cK|#|dkr|dkrt|jdz||jdi}||dd}||dd }||d }|||d <|d ||||d{V}|S) a watches information on open orders with bid(buy) and ask(sell) prices, volumes and other data :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 Ndz6 watchOrderBook limit argument must be None, 25 or 100rr+r)r,r*)r+r,rrA)rr;r|r2r\r=r3rj) r6r@rjrKr2r+r,rO orderbooks r8watch_order_bookzbitfinex.watch_order_bookEs   %3,,#DG.f$fggg//$,0@"EE6666    "GEN..9I9I'SY9Z9Z[[[[[[[[    r9c||d}||}d}|dz|z}||dd}|dk} ||jvr||d} | r|i| |j|<n|i| |j|<|j|} | r|d} t d t| D]s} | | }|d }|d kr| n|}|d krd nd }| |}||d }||d}| |||gtn|d} t d t| D]} | | }| |d }| |d}| |d }|d kr| n|}|d krd nd }| |}| |||g|| d<| | |dS|j|} |d} |j|}| r|| d}| d }|d kr| n|}|d krd nd }||}tj |d r|nd }|| d }| |||||gn|| d }|| d}|| d }tj|d rtj|n|}tj|d rd nd }||}| ||||||g| | |dS)Nr@rAr<r+r)R0rrdrrasksbidsr)r\r orderbooksrindexed_order_bookcounted_order_bookrr safe_float storeArray safe_numberrrrr string_lt string_neg)r6rFrrarLr@r?rNr+isRawrjrdeltasrdeltadelta2sizerbooksideidStringrrcounter orderbookItemdeltas2s r8handle_order_bookzbitfinex.handle_order_book\sD6##L(;;!!(++mh.  fd;;$/))%%lE::E M*.*A*A"e*L*L''+/*A*A"e*L*L'/I @ q#f++..AAA"1IE"1XF'-zzF77D&,qjj66vD(H#//q99H OOE155E''h(?@@@@A!q#f++..@@A"1IE!--eQ77F"..ua88G ,,UA66E'-zzF77D&,qjj66vD(H''g(>????"(Ih  NN9k 2 2 2 2 2/IQZF OF3M u((33 )$+aKKxxg")A++vvF(.!(!25#!>!>GC++FA66##T%6%6u%=%=t?P?PQW?X?XZb$cdddd))&!44**6155((335<5Fvs5S5S_w)&111Y_!(!263!?!?KvvV(.##T%6%6u%=%=t?P?PQU?V?VX\XiXijqXrXr$sttt NN9k 2 2 2 2 2r9c||d}||}d}|dz|z}||j|}|dSd} g} |d} |d} ||dd} | d k}|rd nd }t d | D]}|| |}|| |}|h| || ||| || |d |k| || ||| |d }| || d| }||d }| |d }||krn|j |=|j|=| ddd }|rGt|j dz||z}|||dSdSdS)Nr@rAr<rrrr+r)rrrrdTrr- )r\rr|rrrnumber_to_stringjoincrc32rrI handle_optionrr;orderbook_checksum_messagereject)r6rFrrarLr@r?rNrAdepth stringArrayrrr+r  idToCheckrrraski1payload localChecksumresponseChecksumr-errors r8handle_checksumzbitfinex.handle_checksumsp##L(;;!!(++mh. t77 < F F|F| fd;;%AAA q% B BA//$**C//$**C""4#8#8a9K#L#LMMM""4#8#8a#D#DEEE""4#8#8a9K#L#LMMMQ ""4#8#8%#@#@AAA((;'' 7D11 ,,Wa88 } , ,$[1'))*:JMMH 2%dgmd6U6UV\6]6]&]^^ e[11111 - , 2 2r9cK|d{V||dd}||d}d|z}||d{VS)a watch balance and get the amount of funds available for trading or funds locked in orders :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 :returns dict: a `balance structure ` Nwalletexchangebalance:)rDr\omitrf)r6rK balanceTyperNs r8 watch_balancezbitfinex.watch_balances!!!!!!!!!&&vxDD 68,, ;. ++K888888888r9c ||d}d}|dkr||d}n||dg}i}tdt|D]}||}||d} || } ||} ||d} ||j| i} | | | <|| d<|| |j| <d|| <t| }tdt|D]0}||}d|z}| |j||1dS)NrdrrrrTr*) r|rrr\rparse_ws_balancebalance safe_balancer~keysr)r6rFrra updateTyper updatedTypesr rawBalancerrr0r, oldBalance updatesKeysrrNs r8handle_balancezbitfinex.handle_balances~__Wa00    ??7A..DDOOGQ//0D q#d))$$ - -AaJ))*a88J**:66D++J77G**:q99K{BGGJ&Jt !(Jv (,(9(9*(E(EDL %(,L % %<,,..// q#k**++ < D$t+K NN4<-{ ; ; ; ; < MM~~f&:N^<[\\   .|_bII >>,8JBOOq#m,,-- D DA'*K&q)G  % %fg{ C C C C &&&tr9c||d}||j|<ddddd}||||d}d|vr&||d}d |z}||j|<nB||d }||} |d |zd z| z} ||j| <|S) NrVrrtrr)rArlrrr?rnrSr@r<)r\rIr) r6rFrr_mappingsunifiedChannelrnsubKeyIdrLr@rws r8handle_subscription_statusz#bitfinex.handle_subscription_statusxs($$Wh77 *1Y'     ))(D4D4DWi4X4XYY G  ""7E22C%+H-6F  * *''::H%%h//F)&7#=F.7$U+r9c:K|jddd}||}d}||}||j|}||}dt |z}|||||j tj d} d} |j | ||| d} | | |} |||| ||d{VS) Nr&rr( authenticatedAUTHhexauth)apiKeyauthSig authNonce authPayloadr>)r1rFreusableFuturer|rI millisecondsstrhmacencodesecrethashlibsha384rTextendrG) r6rKrMrFrNfuturerPnoncer" signaturer>rOrs r8rezbitfinex.authenticatesit$Y/S!!% &&{33( > >||||||r9c<d}||d}|dkr2||j|}|ddSt ||}|||||jvr |j|=dSdS)NrPstatusOKT)r\r|futuresrrjsonrrI)r6rFrrNrerar%s r8handle_authentication_messagez&bitfinex.handle_authentication_messages% !!'844 T>>__V^[AAF NN4 ' '(:(:;;E MM% - - -f222(55532r9c*K|d{Vd}|#||}|d|dzz }||d{V}|jr|||}|||||dS)a watches information on multiple orders made by the user :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 ` Nordersr<r;Tr)r6r@rirjrKrNrErks r8 watch_orderszbitfinex.watch_orderss!!!!!!!!!  [[((F 3- -K--k:::::::: ? 3OOFE22E00tTTTr9c||dg}||d}|j0||jdd}t ||_|j}i}|dkrwt |} | dkrdStdt |D]A} || } || } | d} d|| <| | Bn7||} | | | d} d|| <d }| |j|t| }tdt |D]H} || } | | }|d z|d z}| |j|IdS) Nrrdr/r.osrr@Trkr<r;)r|r\rkrr2rrrparse_ws_orderrrr~r2rE)r6rFrrar messageTyperjrk symbolIdssnapshotLengthrvaluerr@rr2rErNs r8 handle_orderszbitfinex.handle_orderssRw2..&&w22 ; %%dlM4HHE077DK $   YYN""1c$ii(( & &Q,,U33)$( &! f%%%%  &((..F MM& ! ! !H%F $If t{D)))INN$$%%q#d))$$ 5 5A!WF[[((F*vd|3K NN4; 4 4 4 4  5 5r9c>ddddd}||||S)Nrcanceledclosed)ACTIVECANCELEDEXECUTED PARTIALLY)r\)r6restatusess r8parse_ws_order_statuszbitfinex.parse_ws_order_status"s4"     &&999r9c||d}||d}||d}||}||}||d}d}tj|drtj|}d}tj||d} ||d } | d d krd } n| d d krd} ||d} | d} || d} || }||d}| |dd}||d}| ||d}| id|d|d|d|d| |ddd|d| d|d|d |d!|d"|d#|d$| d%dd&|dddd'|S)(NrrdrrrrrrrrrrjrrE rrrrr; clientOrderIdrrlastTradeTimestampr@rrr stopPrice triggerPricerr remainingfilledre)rrr) r\rrrr rrrr}safe_integer_2 omit_zero safe_orderr)r6rrEr;rrLr@rrrrrawState stateParts trimmedStatusrerrrrs r8rozbitfinex.parse_ws_order+sJ  eQ ' '((22 ##E1--!!(++!!&))!!%++  VS ) ) '//FD&t'7'7q'A'ABB q)) 99W   " "DD YYx 2 % %D##E2..^^C(( ((Q77 ++M::  ++''q!44 ""5"--NN4#3#3E2#>#>??  E "  ]     Y//  !$   f  D  D  U    I  w  f   d! " f# $)   * + r9c||d}t|tr|ddkrdS||j|i}||d}||d}|j|j|j|j|j d}|j |j |j |j |j |j |j d}d} |dkr|||} n| |||} | | |||dSdS||d} | A|j|j|j|jd } || | } | | ||dSdSdS) Nrrdhbr?)rAcsrlrr)rnouonocwurrrr>)r subscribed unsubscribedrS)r\r}r~r|rIrr&rrrrtr8r safe_value_2rBrNrIri) r6rFrr_rar?r publicMethodsprivateMethodsmethodr>methodss r8handle_messagezbitfinex.handle_messages$$Wa00 4 gt $ $( ,qzT!!??6+?BOOL&&|Y??G##GQ//D.*,,, ##M(((())*$$NFC>>**=$HH!vw 55555"!$$Wg66E  5"&"A$($E > !! %88%F67+++++! &%r9r@)1__name__ __module__ __qualname__rr5r=rbrfrZrrr~rurxrrr rrr rr rrrrrrrr rrr&rr-r8r/rBrIrNrerir rlrtr}ror __classcell__)r7s@r8rrs " #" " " " " " H790ACpppp2;;; ?CQUdhqsHHHH3H^aHx|~ByCHHHH:BFb p p3 p3 p p p pDM,6M,M,M,M,^<@d[] S S SS S Sbfglbm S S S S9;KKCKKKK37TX\egUUCUsURUUlpqvlwUUUU&68>>>F>>>>9;KKCKKKKEG%1%1f%1%1%1%1N=,F=,=,=,=,~^^^^@,F,,,,8((((T@DB!!S!!S\!!!!.Y3Y3Y3Y3Y3v&2f&2&2&2&2P*, 9 9 9 9 9 9Urs& ffffffffffTTTTTTTTTTTTTTTTTTTT444444******000000******%%%%%%p,p,p,p,p,t!*p,p,p,p,p,r9