E#i&SSKrSSKJrJrJr SSKrSSKJrJ r J r J r J r J r JrJr SSKJr SSKJr SSKJr SSKJr SSKJr SS KJr "S S \R4R65rg) N) ArrayCacheArrayCacheBySymbolByIdArrayCacheByTimestamp)AnyBalancesIntOrder OrderBookStrTickerTrade)Client)List) ExchangeError)AuthenticationError) ChecksumError)Precisec ~^\rSrSrS\4U4Sjjr04Sjr04SjrSrSSS04S \ S \ S \ S \ S\ \ 4 S jjr S04S \ S \ 4SjjrS\4SjrSS04S \ S \ S \ S\ \4Sjjr04S \ 4SjjrSSS04S \S \ S \ S\ \4Sjjr04S \ S\4Sjjr04S \ 4Sjjr04S\4SjjrS\4SjrS,SjrS\4SjrS,SjrS04S \ S \ S\4SjjrS\4Sjr S\4Sjr!04S\"4Sjjr#S\4Sjr$S r%S\4S!jr&S\4S"jr'S\4S#jr(04S$jr)S\4S%jr*SSS04S \S \ S \ S\ \+4S&jjr,S\4S'jr-S(r.S,S)jr/S\4S*jr0S+r1U=r2$)-bitfinexreturnc>UR[[U]5SSSSSSSSSSSSSSS.SSSSS.00S S SS .S S .S.5$)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 K/home/james-whalen/.local/lib/python3.13/site-packages/ccxt/pro/bitfinex.pyr6bitfinex.describesh > @# %"&#).!% $"#!%!% $$(""C#@! $# $ 3!C ! ! c(# UR5IShvN URU5nUSnURSSSnURU5nUS-U-nSUUS.n UR XhUR X5USS 05IShvN n UR URSS 5n U (aTUS :XaNURUn U (a8U S(d.S URUS'URS S S.5IShvN U $NNN 7f)Nidr'rr(: subscribe)eventchannelsymbolr.FTbookconfi)r@flags) load_marketsmarketr2clientwatchr4 safe_boolr3 subscriptionssend) r7rArBparamsrGmarketIdurlrH messageHashrequestresultr.subs r9r?bitfinex.subscribe8s$!!!V$$<iit$X.S!mh.    zz#D4D4DW4UWbeoqvdwxx>>$,, DA F*&&{3C3z?@D$$[1*=kk### + "y s5DD A6D DA7DDDDDc# UR5IShvN URU5nUSnURSSSnURU5nUS-U-n SU-S-U-n SU-S-U-n UR UR U 5n SU S.n SU -nXR U'U /U /US U/S .nUR XzURX5X5IShvN $NN7f) Nr=r'rr(r> unsubscribe: unsubscriber@chanIdT messageHashessubMessageHashestopicrWsymbols)rFrGr2rH safe_stringrKrIr4)r7rAr]rBrMrGrNrOrHsubMessageHashrP unSubTopic channelIdrQ unSubChanMsg subscriptions r9 un_subscribebitfinex.un_subscribePs!!!V$$<iit$X.S! 31$w.4x? (5036? $$V%9%9:F " & 1 -;\*)]!/ 0x  ZZ$2B2B72SU`ooo- ",ps"C"CCC"C C" C"c# UR5IShvN UR5IShvN URSSSnURX!SS5IShvN $NLN6N7f)Nr'rr))rF authenticater2rI)r7rPrOs r9subscribe_privatebitfinex.subscribe_privateisb!!!!!!iit$Y/ZZ$::: "!:s1A)A#A)A%/A)A'A)%A)'A)1mNrB timeframesincelimitc# UR5IShvN URU5nUSnURURX"5nSnSU-S-US-n US-U-S-US-n SUU S.n URS S S n UR XUR X5U 5IShvN n UR(aU RX5nURXUS S 5$NN<7f)a 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 NrBcandlestrade:r>r=r?)r@rAkeyr'rr(rT) rFrGr_ timeframesr2rIr4 newUpdatesgetLimitfilter_by_since_limit)r7rBrmrnrorMrGintervalrArsrPrQrOohlcvs r9 watch_ohlcvbitfinex.watch_ohlcvos!!!V$!##DOOYJ!C'&,6mh.4vd|C    iit$X.jj43C3CG3TVabb ??NN61E))%q$GG# "cs"C-C)BC-.C+/;C-+C-c# UR5IShvN URU5nUSnURURX"5nSnUS-U-S-US-nSU-nURSSS n UR U 5n S U-S-US-n URU R U 5n S U S .n SU -nXzR U'U/U/S SU/S.nURXURX5X5IShvN $NN7f)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 NrBrqr>r=rVr'rr(zunsubscribe:trade:rWrXryTrZ) rFrGr_rtr2rHrKrIr4)r7rBrmrMrGrxrAr`rPrOrHsubIdrbrQrcrds r9un_watch_ohlcvbitfinex.un_watch_ohlcvs;!!!V$!##DOOYJ 31C7&,F$~5 iit$X.S!$x/#5t D$$V%9%95A " & 1 -;\*)]!/ 0x  ZZ$2B2B72SU`ooo1 "0ps"DDC&D=D>DDrHcURUS/5nSnURUS5n[U[5(aUnOU/nURUS5nURUS5nUR S5n URU S5n Un U R SS5n U R U S-S5n UR U 5n URU 5n U SnUS-U -S-U -nURURU05URU'URURUU 5nUc:URURS S 5n[U5nUURUU '[U5n[SU5H1nUUU- S- nURUU 5nURU5 M3 UR!UU5 g) NrhrrArsr>rrrB OHLCVLimitr/) safe_value isinstancelistr_splitreplace safe_marketfind_timeframeohlcvs safe_integerr3rlenrange parse_ohlcvappendresolve)r7rHmessagerddatarfirstrArskeyPartsrxrNrGrmrBrPstoredro ohlcvsLengthiryparseds r9 handle_ohlcvbitfinex.handle_ohlcvs\w2.a( eT " "FVF//, :|U399S>##Ha0##Hb1##HsNB7!!(+''1 !mh.4x? "oodkk62F FV!4i@ >%%dllL$GE*51F-3DKK  *6{ q,'A` tradesN timestampT)r?rurvrw)r7rBrnrorMrs r9 watch_tradesbitfinex.watch_tradessL~~h?? ??OOF2E))& TRR@sAA;AcD# URSSX5IShvN $N7f)a- 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 ` rNrer7rBrMs r9un_watch_tradesbitfinex.un_watch_trades "&&x6JJJJ   c # UR5IShvN SnUbURU5nUSUS-- nURU5IShvN nUR(aUR X5nUR XqX#S5$NsN;7f)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=TrFrGrjrurvfilter_by_symbol_since_limit)r7rBrnrorMrPrGrs r9watch_my_tradesbitfinex.watch_my_tradess!!!  [[(F 3- -K--k:: ??OOF2E00tTT " ;!BB 9BB :B BcB# URSX5IShvN $N7f)ah 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 r9 watch_tickerbitfinex.watch_ticker's^^Hf====s cD# URSSX5IShvN $N7f)aj 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 r9un_watch_tickerbitfinex.un_watch_ticker0rrcSnURUS5nURU5nUSnURU5nUS-US-n URc-UR UR SS5n [ U 5UlURn U RU5 XlURX5 URX5 g)NrrBr>r= tradesLimitr/) rparse_ws_traderGmyTradesrr3rrr) r7rHrrdnamertraderBrGrPro tradesArrays r9handle_my_tradebitfinex.handle_my_trade9s,w*##D)xV$Sj6$</ == %%dllM4HE259DMmm 5!# {){0r;cURUS5nURUS5nURU5nUS-U-nURURSS5nUSn URUR U 5n U c[ U5n XR U '[U5n U S:Xa^URUS/5n [U 5n [SU 5H/nX- S- nURXU5nU RU5 M1 OOURUS5nUS :XagURUS/5nURUU5nU RU5 URX5 g) NrArBr>rr/rrhrtu) rr_rrr3rrr safe_listrrrr)r7rHrrdrArNrGrPrrBr messageLengthrlengthrindexrtypers r9 handle_tradesbitfinex.handle_trades`sY>//, :##L(;!!(+mh. '' mTJ !f5 > ,F"(KK G A ^^GQ3F[F1f% Q,,V]FC f%& ##GQ/Dt|OOGQ3E((7F MM& !v+r;c[U5nUS:*nU(dURUS5OSnURXR5nU(aSOSnU(aSOSnU(aSOSnUSnURUS5n U b/U RS 5S :aS n OU RS 5S :aS n U(dURUS5OSn URUS5n UR X5n URX5n URX5nUR [ R"U55nSnUb [ R"US5(aSOSnURXR5nURUS5nSnUb(URUS5nURU5nUUS.nUR US5nSnUb US :XaSOSnURUU URU 5UU U U UUU USUS. U5$)Nrhrr=LIMITroMARKETrGr0buysell )costcurrencytakermaker) infordatetimerBr=orderr takerOrMakersidepriceamountrfee) rr_rfindr parse_numberr string_abs string_gt safe_symbolsafe_currency_code safe_tradeiso8601)r7rrG numFieldsisPublicrN createdKeypriceKey amountKeyrorderIdr=rr amountStringrrrBfeeValuer currencyIdcoderrs r9rbitfinex.parse_ws_tradesVJ >6>4##E1-T!!(3"Q  1a!Aq $<q)  yy!B&8$r)5=$""5!,D   eQ '%%e8   1''9 ""7#5#5l#CD  #--lC@@5fD!!(3##E1-  ))%4J**:6D  C!!%+  ',{7L" Y/(   r;cURUS5nURUS5nURU5nURU5nUR XF5nSn U S-U-n XR U'UR X5 g)NrhrBrr>)rr_rrparse_ws_tickertickersr) r7rHrrdrrNrGrBrrArPs r9 handle_tickerbitfinex.handle_tickers$!,##L(;!!(+!!(+%%f5mh. % Vv+r;cURSU5nUSnURUS5nURUS5nUR0SU_SS_SS_SURUS5_SURUS 5_S URUS 5_S URUS 5_SURUS5_SURUS5_SS_SS_SU_SU_SS_SU_SURUS5_SS_URUS5SUS.EU5$)NrBrrrrhighrlowrbidr bidVolumerhaskr askVolumervwapopencloselast previousClosechange percentageraverage) baseVolume quoteVolumer)rr_ safe_ticker)r7rrGrBrrs r9rbitfinex.parse_ws_tickers!!$/!*!!&!,! f! !  !  D$$VQ/ ! 4##FA. ! 4##FA. !  ))&!4!  4##FA.!  ))&!4!  D!  D!  T!  D!  T!  f! $**615!! " t#! $**615)! * + r;cl# Ub$US:waUS:wa[URS-5eURURS05nUR USS5nUR USS 5nUUS .nUbX'S 'UR S XR Xs55IShvN nUR5$N7f) 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-rrC)rr=rr3r_r?r4ro) r7rBrorMr3r,r-rQ orderbooks r9watch_order_bookbitfinex.watch_order_bookEs   %3,#DGG.f$fgg//$,,0@"E66   "EN..9I9I'9Z[[   \sBB4B2B4cURUS5nURU5nSnUS-U-nURUSS5nUS:Hn XPR;GaURUS5n U (a UR 0U 5URU'OUR 0U 5URU'URUn U (a}USn [ S [U 55H^n XnUS nUS :aU*OUnUS :aS OS nU UnURUS 5nURUS5nURUUU/5 M` OUSn [ S [U 55Hkn XnURUS 5nURUS5nURUS 5nUS :aU*OUnUS :aS OS nU UnURUUU/5 Mm X[S'URX5 gURUn USn URUnU (aURU S5nU S nUS :aU*OUnUS :aS OS nUUn[R"US 5(aUOS nURU S 5nURURU5URU5U/5 OURU S 5nURU S5nURU S 5n[R"US 5(a[R "U5OUn[R"US 5(aS OS nUUnURURU5URU5URU5/5 URX5 g)NrBrCr>r,r*R0rrhrrasksbidsr)r_r orderbooksrindexed_order_bookcounted_order_bookrr safe_float storeArray safe_numberrrrr string_lt string_neg)r7rHrrdrNrBrArPr,isRawrordeltasrdeltadelta2sizerbooksideidStringrrcounter orderbookItemdeltas2s r9handle_order_bookbitfinex.handle_order_book\sy6##L(;!!(+mh.  fd;//)%%lE:E*.*A*A"e*L'+/*A*A"e*L'/I q#f+.A"IE"1XF'-zF7D&,qj6vD(H#//q9H OOE15E''h(?@/!q#f+.A"IE!--eQ7F"..ua8G ,,UA6E'-zF7D&,qj6vD(H''g(>?/#)h  NN9 2/IQZF OOF3M((3 )$+aKxg")A+vF(.!(!2!25#!>!>C++FA6##T%6%6u%=t?P?PQW?XZb$cd))&!4**615((35<5F5Fvs5S5Sw))&1Y_!(!2!263!?!?vV(.##T%6%6u%=t?P?PQU?VX\XiXijqXr$st NN9 2r;cURUS5nURU5nSnUS-U-nURURU5nUcgSn /n USn USn URUSS5n U S :HnU(aS OS n[ S U 5HnURU U5nURU U5nUbLU R UR U UU55 U R UR U US 55 UcM{U R UR U UU55 U US nU R UR U*55 M SRU 5nURUS 5nURUS 5nUU:warURU URU URSSS 5nU(a=[URS-URU5-5nURUU5 ggg)NrBrCr>rrrr,r*rrrrhTrr. )r_rrrrrnumber_to_stringjoincrc32rrK handle_optionrr=orderbook_checksum_messagereject)r7rHrrdrNrBrArPrCdepth stringArrayrrr,r  idToCheckrrraski1payload localChecksumresponseChecksumr.errors r9handle_checksumbitfinex.handle_checksums##L(;!!(+mh. t7 <  F|F| fd;AA q%A//$*C//$*C""4#8#8a9K#LM""4#8#8a#DE""4#8#8a9K#LMQ ""4#8#8%#@A!((;' 7D1 ,,Wa8 } ,$$[1'))*:JMH%dggmd6U6UV\6]&]^ e[1 -r;c# UR5IShvN URUSS5nURUS5nSU-nURU5IShvN $NGN7f)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:)rFr_omitrj)r7rM balanceTyperPs r9 watch_balancebitfinex.watch_balancese!!!&&vxD 68, ;. ++K888 "9s"A"AAA"A A" A"cURUS5nSnUS:XaURUS5nOURUS5/n0n[S[U55HnXWnURUS5n UR U 5n UR U5n URUS5n URUR U 05n XU 'X-S'URU 5UR U 'SXl'M [UR55n[S[U55H+nXnSU-nURUR UU5 M- g)NrhrrrrTrA) rrrr_rparse_ws_balancebalance safe_balancerkeysr)r7rHrrd updateTyper updatedTypesr rawBalancerrrHrC oldBalance updatesKeysrrPs r9handle_balancebitfinex.handle_balancesD~__Wa0   ??7A.DOOGQ/0D q#d)$AJ))*a8J**:6D++J7G**:q9K{BGJ&t !(v (,(9(9*(EDLL %(,L %%<,,./ q#k*+A>D$t+K NN4<<-{ ;,r;cURUS5nURUS5nUR5nUbX4S'X$S'U$)Nrrfreetotal)r_account)r7rH totalBalanceavailableBalancerUs r9rGbitfinex.parse_ws_balanceCsN''3 ++GQ7,,.  '.FO'r;cU$N)r7rHrs r9handle_system_statusbitfinex.handle_system_statusWs r;cURUS5nSU-nURURU5nURURSU-5nURU URUS/5nURUS/5n[ S[ U55Hn Xyn Xn UR XU 5 M URU5 g)NrYrVr[r\rT)r_rK safe_dictrrrclean_unsubscription clean_cache) r7rHrrb unSubChannelr`rdr[r\rrPsubHashs r9handle_unsubscription_status%bitfinex.handle_unsubscription_statusbs$$Wh7 % 1 ))&*>*> M~~f&:&:N^<[\   .|_bI >>,8JBOq#m,-A'*K&)G  % %f{ C. &r;cnURUS5nX!RU'SSSSS.nURX@RUS55nSU;a'URUS5nS U-nX1RU'U$URUS 5nURU5n UbS U-S -U -n X1RU 'U$) NrYrryrr)rCrqrrrArsrVrBr>)r_rKr) r7rHrrbmappingsunifiedChannelrssubKeyIdrNrBr}s r9handle_subscription_status#bitfinex.handle_subscription_statusxs($$Wh7 *1Y'    ))(4D4DWi4XY G ""7E2C%+H-6  * '':H%%h/F)&7#=F.7$$U+r;c# URSSSnURU5nSnURU5nURURU5nUcUR 5nS[ U5-nURURU5URUR5[RS5n Sn URU UUU S.n URX5n URX$X5 UIShvN $N7f) Nr'rr) authenticatedAUTHhexauth)apiKeyauthSig authNonce authPayloadr@)r2rHreusableFuturerrK millisecondsstrhmacencodesecrethashlibsha384rqextendrI) r7rMrOrHrPfuturermnoncer8 signaturer@rQrs r9ribitfinex.authenticatesiit$Y/S!% &&{3(<(||sC=D?DDc$SnURUS5nUS:Xa.URURU5nURS5 g[ UR U55nUR Xc5 X1R;aURU gg)NrmstatusOKT)r_rfuturesrrjsonr3rK)r7rHrrPrr~r;s r9handle_authentication_message&bitfinex.handle_authentication_messages~% !!'84 T>__V^^[AF NN4 ' '(:;E MM% -222((53r;c # UR5IShvN SnUbURU5nUSUS-- nURU5IShvN nUR(aUR X5nUR XqX#S5$NsN;7f)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)r7rBrnrorMrPrGrs r9 watch_ordersbitfinex.watch_orderss!!!  [[(F 3- -K--k:: ??OOF2E00tTT " ;rcURUS/5nURUS5nURc-URURSS5n[ U5UlURn0nUS:Xa^[ U5n U S:Xag[S[ U55H2n XJn URU 5n U Sn SX'URU 5 M4 O+URU5n URU 5 U Sn SX'S nURURU5 [UR55n[S[ U55H?n Xn URU 5nUS -US -nURURU5 MA g) Nrrhr0r/osrrBTrr>r=)rr_rrr3rrrparse_ws_orderrrrrJrG)r7rHrrdr messageTyperor symbolIdssnapshotLengthrvaluerrBrrJrGrPs r9 handle_ordersbitfinex.handle_orderssqRw2.&&w2 ;; %%dllM4HE07DK $  YN"1c$i(,,U3)$( ! f% )((.F MM& !H%F $I t{{D)INN$%q#d)$AWF[[(F*vd|3K NN4;; 4 %r;c4SSSSS.nURX!U5$)Nrcanceledclosed)ACTIVECANCELEDEXECUTED PARTIALLY)r_)r7rstatusess r9parse_ws_order_statusbitfinex.parse_ws_order_status"s*"    &99r;cURUS5nURUS5nURUS5nURU5nURU5nURUS5nSn[R"US5(a[R "U5nSn[R "URUS55n URUS 5n U R S 5S :aS n OU R S 5S :aSn URUS5n U RS5n URU S5n URU 5nURUS5nURUSS5nURUS5nURURUS55nUR0SU_SU_SU_SU_SURU5_SS_SU_SU _SU_SU_S U_S!U_S"U_S#U_S$U _S%S_S&U_SSSS'.EU5$)(Nrrhrr rrrrrrrrorrG r-rrrrr= clientOrderIdrrlastTradeTimestamprBrrr stopPrice triggerPricerr remainingfilledr)rrr) r_rrrrrrrrsafe_integer_2 omit_zero safe_orderr)r7rrGr=rrNrBrrrrrawState stateParts trimmedStatusrrrrrs r9rbitfinex.parse_ws_order+sJ  eQ '((2 ##E1-!!(+!!&)!!%+   VS ) )''/FD&&t'7'7q'AB q) 99W  "D YYx 2 %D##E2.^^C( ((Q7 ++M:  +''q!4 ""5"-NN4#3#3E2#>?  E "  ]     Y/  !$   f  D  D  U    I  w  f   d! " f# $) * + r;c6URUS5n[U[5(GaUSS:XagURURU05nURUS5nURUS5nUR UR URURURS.nURURURURURURURS.nSn US:XaURX5n OURXvU5n U b U "XU5 ggURUS5n U bMURURUR UR"S .n URX5n U b U "X5 ggg) NrrhhbrA)rCcsrqrr)rouonocwurrrr@)r subscribed unsubscribedrp)r_rrrrKr*r<rrrrrPr safe_value_2r\rjrdr) r7rHrrbrdrAr publicMethodsprivateMethodsmethodr@methodss r9handle_messagebitfinex.handle_messages$$Wa0 4 gt $ $qzT!??6+?+?BOL&&|Y?G##GQ/D..**,,,,,, #M(((((((())))**$NFC>**=H!v 5"$$Wg6E  55"&"A"A$($E$E >> ! 8%6+&!r;)rrrZ)3__name__ __module__ __qualname____firstlineno__rr6r?rerjrwrrrrzr~rrr rrr rr rrrrrrrr rr*r<rrDrPrGr\rdrjrirr rrrrr__static_attributes__ __classcell__)r8s@r9rrs" #" H790ACp2; ?CQUdhqsHHH3H^aHx|~ByCH:BFb p3 p3 pDM,6M,^<@d[] S SS S Sbfglbm S9;KCK37TX\egUCUsURUUlpqvlwU&68>>F>9;KCKEG%1f%1N=,F=,~^@,F,8(T@DB!S!!S\!.Y3Y3v&2f&2P*, 9 9UrsH ffTTT4*0*%p,t!!**p,r;