iddlZddlmZmZddlZddlmZmZm Z m Z m Z m Z m Z mZmZmZddlmZddlmZddlmZddlmZddlmZdd lmZGd d ejjZdS) N) ArrayCacheArrayCacheBySymbolById) BalancesIntOrder OrderBookPositionStrStringsTickerTickersTrade)Client)List) ExchangeError)AuthenticationError)ArgumentsRequired)Precisec eZdZfdZifdZdifdeededefdZ ifdedeefd Z ifded efd Z ifd ede fd Z difdedefdZdifdedefdZdddifd edededeefdZddifdeedededeefdZdifd ededefdZdddifdedededeefdZdZd2dZdddifd edededeefdZdddifd edededeefdZifdefdZde fdZ!d2dZ"d2dZ#de fdZ$de fdZ%d2d Z&de fd!Z'de fd"Z(d2d#Z)de fd$Z*de fd%Z+de fd&Z,de fd'Z-d2d(Z.ddifd)ed*edefd+Z/d3d,ed-ed efd.Z0de fd/Z1d0Z2de fd1Z3xZ4S)4 krakenfuturesc |tt|iddddddddddddd dd dd dd dd dddddddddddddddddddddiddiddddddddidddidS)NwsTcancelAllOrdersWsFcancelOrdersWs cancelOrderWs createOrderWs editOrderWsfetchBalanceWsfetchOpenOrdersWs fetchOrderWs fetchTradesWs watchOHLCVwatchOrderBookwatchOrderBookForSymbols watchTicker watchTickers watchBidsAsks watchTrades)watchTradesForSymbols watchBalance watchOrders watchMyTradeswatchPositionszwss://futures.kraken.com/ws/v1z#wss://demo-futures.kraken.com/ws/v1)apitestdtype) tradesLimit ordersLimit OHLCVLimitconnectionLimit requestLimit fetchBalance keepAlivei0u)hasurlsoptions streaming) deep_extendsuperrdescribe)self __class__s \/var/www/html/crypto-bot/backend/venv/lib/python3.11/site-packages/ccxt/pro/krakenfutures.pyr@zkrakenfutures.describesmT : : C C E Ed#U!%      u !%$U e!$+Dt  !"t#$*. $#!%"&/6:?  $#"#& #D!  UY/H /H / / / cPK||jdd}d}||}||j|}|Hd|jd}|||}|||||d{V}||j|<|S)z * @ignore authenticates the user to access private web socket channels :see: https://docs.futures.kraken.com/#websocket-api-public-feeds-challenge :returns dict: response from exchange r.r challengeN)eventapi_key)check_required_credentialsr;client safe_value subscriptionsapiKeyextendwatch)rAparamsurl messageHashrJfuturerequestmessages rC authenticatezkrakenfutures.authenticateFs ''))) it$! S!!!5{CC >$;Gkk'622G::c;MMMMMMMMF06F  - rDNsymbolslimitreturncpK|dd|d|i|d{V}|S)a* watches information on open orders with bid(buy) and ask(sell) prices, volumes and other data :see: https://docs.futures.kraken.com/#websocket-api-public-feeds-challenge :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 :returns dict: A dictionary of `order book structures ` indexed by market symbols orderbookbookrXN)watch_multi_helperrX)rArWrXrPr[s rCwatch_order_book_for_symbolsz*krakenfutures.watch_order_book_for_symbols`sM11+vwQXZ_P`bhiiiiiiii    rDnamecK|d{V|jdd}d|d}g}|}|g}tdt|D]2}||} ||| 3t|} | dkr)||d} |dz| d z}||d <|||} |||| |d{VS) * * @ignore Connects to a websocket channel :param str name: name of the channel :param str[] symbols: CCXT market symbols :param dict [params]: extra parameters specific to the krakenfutures api :returns dict: data from the websocket stream Nr.r subscribe)rGfeedr:symbol product_ids) load_marketsr;rangelenappend market_idmarketrNrO) rAr_rWrPrQrb marketIdsrRirflengthrmrTs rCsubscribe_publiczkrakenfutures.subscribe_publicls4!!!!!!!!!it$     ?Gq#g,,'' 5 5AQZF   T^^F33 4 4 4 4W Q;;[[1..F%+fX.>>K#, - ++i00ZZ[';GGGGGGGGGrDrRcBK|d{V|d{V|jdd}d||j|jd|jdd}|||}|||||d{VS)raNr.rrbrFsignedChallenge)rGrcrHoriginal_challengesigned_challenge)rhrVr;rMr<rNrO)rAr_rRrPrQrbrTs rCsubscribe_privatezkrakenfutures.subscribe_privates!!!!!!!!!!!!!!!!!!it$ {"&,{"; $ -> ?   ++i00ZZ[';GGGGGGGGGrDrfcK|d{V||}||g|d{V}||S) watches a price ticker, a statistical calculation with the information calculated over the past 24 hours for a specific market :see: https://docs.futures.kraken.com/#websocket-api-public-feeds-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)rhrf watch_tickers)rArfrPtickerss rC watch_tickerzkrakenfutures.watch_tickersp!!!!!!!!!V$$**F8V<<<<<<<<vrDc K|d{V||dd}|dd|d|d{V}|jri}|||d<|S||jd|S)rxNFtickerrf)rhmarket_symbolsr] newUpdatesfilter_by_arrayrzrArWrPr}results rCryzkrakenfutures.watch_tickerss!!!!!!!!!%%gtU;;..x7DRXYYYYYYYY ? F'-F6(# $M##DL(GDDDrDcK|dd|d|d{V}|jri}|||d<|S||jd|S)a :see: https://docs.futures.kraken.com/#websocket-api-public-feeds-ticker-lite watches 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 ` bidask ticker_liteNrf)r]rrbidsasksrs rCwatch_bids_askszkrakenfutures.watch_bids_asksst..xQUW]^^^^^^^^ ? F'-F6(# $M##DM8WEEErDsincecDK||g|||d{VS)a, get the list of most recent trades for a particular symbol :see: https://docs.futures.kraken.com/#websocket-api-public-feeds-trade :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 ` N)watch_trades_for_symbols)rArfrrXrPs rC watch_tradeszkrakenfutures.watch_tradess622F8UE6RRRRRRRRRrDcK|dd|d|d{V}|jrB||d}||d}|||}||||ddS)a- :see: https://docs.futures.kraken.com/#websocket-api-public-feeds-trade get the list of most recent trades for a list of symbols :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 ` tradeNrrf timestampT)r]r safe_list safe_stringgetLimitfilter_by_since_limit)rArWrrXrPtradesfirst tradeSymbols rCrz&krakenfutures.watch_trades_for_symbolss..w$PVWWWWWWWW ? 8NN61--E**5(;;KOOK77E))&% TRRRrDcBK||g||d{VS)a8 watches information on open orders with bid(buy) and ask(sell) prices, volumes and other data :see: https://docs.futures.kraken.com/#websocket-api-public-feeds-book :param str symbol: unified symbol of the market to fetch the order book for :param int [limit]: not used by krakenfutures watchOrderBook :param dict [params]: extra parameters specific to the exchange API endpoint :returns dict: A dictionary of `order book structures ` indexed by market symbols N)r^)rArfrXrPs rCwatch_order_bookzkrakenfutures.watch_order_books466xOOOOOOOOOrDcTK|d{Vd}||}||sdd|z}d|z}|d||d{V}|jr|S||j|||dS)a :see: https://docs.futures.kraken.com/#websocket-api-private-feeds-open-positions watch all open positions :param str[]|None symbols: list of unified market symbols :param dict params: extra parameters specific to the exchange API endpoint :returns dict[]: a list of `position structure ` N::, positionsopen_positionsT)rhr~is_emptyjoinrvrfilter_by_symbols_since_limitr)rArWrrXrPrR newPositionss rCwatch_positionszkrakenfutures.watch_positionss!!!!!!!!! %%g..}}W%% 3'!2!22K!K/ !334DkSYZZZZZZZZ ?  11$.'5RWY]^^^rDc@|jt|_|j}||dg}g}tdt |D]|}||}||}||d} | |d<|| |d<||||}| |d} tdt | D]}| |} | d} | d} | d}| |d |d }| |s| || | |ddS) Nrrrdatetimez positions::rrdrrfF)rrrKrirjparse_ws_position safe_integeriso8601rkfind_message_hashessplitrrresolve)rArJrUcache rawPositionsrro rawPositionpositionr messageHashesrRparts symbolsStringrWrs rChandle_positionszkrakenfutures.handle_positionss6 > !355DNw R@@  q#l++,, # #A&q/K--k::H))';??I$-H[ !#'<< #:#:HZ    ) ) ) LL " " " "00GG q#m,,-- 7 7A'*K%%d++E!!HM#))#..G,,\8WeTTI==++ 7y+666|[11111rDc ||d}d}||d}|dkrdnd}|id|ddd ||d dd dd ||d d||dd||dd||dd|t j||ddd||dd|d|ddddd||ddd||dddddS) N instrumentbothbalancerlongshortinfoidrfnotional marginModeliquidationPriceliquidation_threshold entryPrice entry_price unrealizedPnlpnl percentagereturn_on_equity contracts contractSize markPrice mark_pricesidehedgedrrmaintenanceMarginmaintenance_margininitial_margin)maintenanceMarginPercentage collateral initialMargininitialMarginPercentageleverage marginRatio)r safe_number safe_position safe_symbol parse_numberr string_absnumber_to_string)rArrmmarketIdrrrs rCrzkrakenfutures.parse_ws_position;s&##Hl;;""8Y77!A++vvG!!# H# $#  d&&x00#   # $ #  0 0;R S S #  $**8]CC#  T--h>>#  $**85GHH#  **7+=d>S>ST[>\>\+]+]^^#  D#  ))(LAA#  D#  f#  # !# " !1!1(` N open_ordersordersrerfrTrhrmrvrrr) rArfrrXrPr_rRrmrs rC watch_orderszkrakenfutures.watch_ordersls!!!!!!!!!  [[((F 3!11 1K--dKHHHHHHHH ? 3OOFE22E))&% TRRRrDc2K|d{Vd}d}|#||}|d|dzz }||||d{V}|jr|||}||||ddS)a= watches information on multiple trades made by the user :see: https://docs.futures.kraken.com/#websocket-api-private-feeds-fills :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 `trade structures ` NfillsmyTradesrerfrTr) rArfrrXrPr_rRrmrs rCwatch_my_tradeszkrakenfutures.watch_my_tradess!!!!!!!!!  [[((F 3!11 1K--dKHHHHHHHH ? 3OOFE22E))&% TRRRrDcK|d{Vd}|}d}||dd\}}|+|dkr|dkrt|jdz|d|zz }||||d{VS) a watches information on multiple orders made by the user :see: https://docs.futures.kraken.com/#websocket-api-private-feeds-balances :param str symbol: not used by krakenfutures watchBalance :param int [since]: not used by krakenfutures watchBalance :param int [limit]: not used by krakenfutures watchBalance :param dict [params]: extra parameters specific to the exchange API endpoint :param str [params.account]: can be either 'futures' or 'flex_futures' :returns dict} a object of wallet types each with a balance structure {@link https://docs.ccxt.com/#/?id=balance-structure: Nbalancesr*accountfutures flex_futuresz@ watchBalance account must be either 'futures' or 'flex_futures're)rhhandle_option_and_paramsrrrv)rArPr_rRrs rC watch_balancezkrakenfutures.watch_balances!!!!!!!!! 77PYZZ  )##>(A(A'2x(xyyy 3= (K++D+vFFFFFFFFFrDrJc||d}||d}|K||}|d}|dd|}||j|3||jdd}t||j|<|j|} |dkrt||dg} t| } td | D]<} | d z | z } | | }| |}| |=n*| |}| || | |dSdS) Nrc product_idrfrr3r0trade_snapshotrrrd) rrmget_message_hashrrrr<rrjriparse_ws_traderkr)rArJrUchannelrrmrfrRr3 tradesArrayrrproindexitemrs rC handle_tradezkrakenfutures.handle_tradesJ""7F33##G\::  [[**FH%F//vFFK~~dk622:"// mTRR &0&=&= F#+f-K***2>>Vq&))..A"QJNE!%=D //55E&&u---- . ++G44""5))) NN; 4 4 4 4 4' rDc||d}|||}||d}||||d||d|||d||d||dd||d||d ddddd d |S) Nrtimeuidrfr2rtakerpriceqtyratecostcurrency rrrfrrorderr2r takerOrMakerramountrfee)r safe_marketr safe_trader)rArrmrrs rCrzkrakenfutures.parse_ws_trades ##E<88!!(F33%%eV44 ""5%00&&vx88" Y//$$UF33$$UF33#%%eW55&&ue44   $ % rDc`||d}||d}||||d||||||||d||d||d||d||d||d dd||d ||d d d |S)N tradeTimerftradeIdorderIdr2r matchRoler tradeAmounttradeFee feeCurrencyrr)rrrrrsafe_string_lower)rArrmrrs rCparse_ws_order_tradez"krakenfutures.parse_ws_order_trades6:%%e[99 ##E844""5)44&&x88" Y//%%eY77**5&99$$UF33 ,,UK@@%%eW55&&um<<(( ;; ,,UMBB  $ % rDc |j}|1||jd}t|}||_||d}|||d}d}||}||d} ||j|i} || | } ||d} | | dkr^||} | | | ||| ||dz|znB| |}| d g| d <| d  ||d | d <d }d }| d }td t|D]f}||}tj|||d}tj|||d}gtj|d rtj||| d<|| d<| d|| d}tj|||d| d<| d1tj|| d|| d<| d(dd ||ddd| d<| ddn|dd`|| dd}||dd}tj||| dd<| || | ||dz|z| ||n||d}|rtd t|D]n}||}|d|dkrR||ddi||<| |d| |d|dzno|S)Nr4rrrorder_idreasonedited_by_userrerrlastTradeTimestamp0rrraveragefilled remainingrrr is_cancelrstatuscanceledorders:rf)rrr<rrKrrhashmapparse_ws_orderrkrrrirjr string_addr string_gt string_div string_sub safe_orderrN)rArJrUrrXrrrRrfr previousOrders previousOrderrparsedr totalCost totalAmountrro currentTradestringOrderFilledstringOrderCoststringTradeCostisCancel currentOrders rC handle_orderzkrakenfutures.handle_orderAsJ >%%dlMBBE+E22F DK11  ''|<S>ST`agTh>i>i j jI")"4[$BWBWXdemXnBoBo"p"pKK$[#66Z/6/A)[/Y/YM),(1 f% *6(,(=(=mH>U(V(V%.5.@ARTXTiTijopxjyTzTz.{.{M(+$X.:5<5GH]H]^klt^uHvHvyJ6K6K k2 '/ $ #$($9$9%,z:R$S$S,,M%( "%(0<5>,U33 { q#f++&& ( (A1IE((//FH%F"GFO    ' ' ' 'T[!! A:: NN4; 1 1 1 ''D1c$ii(( 9 9a'&0 t{K8888 : 9 9rDc ||d}|}d}|||d}|durd}||d}||d}||d}|id|d |||d ||d d dd |d||ddd||dddddd|dkrdndd||dd||dd||dd||ddddd||d d|dddd!dd"S)#NrrT cancelledrr directionrrfrr clientOrderIdrrrr2 timeInForcepostOnlyrrbuysellr limit_price stopPrice stop_price triggerPricerrrrrr)rrrrr)rKrrr#rr) rArrm isCancelled unparsedOrderrrrr7s rCrzkrakenfutures.parse_ws_orders7Nooe[99    " OOE7;;Md""$##M<@@$$]F;; %%m[AA  E d&&x88  $""=*==  T     Y//   !$  D$$]F;;  4    i1nnEE6  T%%m]CC  ))-FF  D,,]LII  d&&}e<< D! " t# $&&}h??  5      rDc||d}|V||}|d}||j|<|dd|}|||dSdS)Nrrfr})rparse_ws_tickerrzrrrArJrUrr}rfrRs rC handle_tickerzkrakenfutures.handle_ticker]s@##G\::  ))'22FH%F#)DL //$GGK NN6; / / / / / rDc||d}|V||}|d}||j|<|dd|}|||dSdS)Nrrfr)rrDrrrrEs rChandle_bid_askzkrakenfutures.handle_bid_asks"##G\::  ))'22FH%F$*DM& !//$GGK NN6; / / / / / rDc ||d}|||}|d}|||d}||d}|id|d|d|d||ddd dd ||d d ||d d ||d d||dddddd|d|ddd||dddd||d||ddS)NrrflastTimelastrrrhighlowbid bidVolumebid_sizeask askVolumeask_sizevwapopenclose previousClosechangervolume volumeQuote)r baseVolume quoteVolume)rr parse8601 safe_tickerr)rAr}rmrrfrrKs rCrDzkrakenfutures.parse_ws_tickersb##FL99!!(F33!NN4#3#3FJ#G#GHH //! F! f!  !   Y// ! D ! 4 !  4##FE22!  ))&*==!  4##FE22!  ))&*==!  D!  D!  T!  D!  T! d&&vx88!! " $#! $**68<<++FMBB)! ! !    rDc||d}||}|d}|dd|}||j|i}||d}||d} |i||j|<|j|} ||d} ||d} tdt| D]T} | | }| |d }| |d }| d}| ||Utdt| D]T} | | }| |d }| |d }| d}| ||U| | d<| | | d <|| d<|| |dS) Nrrfr[rXrbidsasksrrrr)rrr safe_dictrLr order_book orderbooksrrirjrstorerr)rArJrUrrmrfrR subscriptionrXrr[r`rarorNrrbidsSiderQasksSides rChandle_order_book_snapshotz(krakenfutures.handle_order_book_snapshots<##G\::!!(++!++KvFF ~~f&:KLL !!,88%%g{;; "&//"e"<"<OF+ ~~gv..~~gv..q#d))$$ ' 'Aq'C$$S'22E""3..C (H NN5# & & & &q#d))$$ ' 'Aq'C$$S'22E""3..C (H NN5# & & & &!* + $ Y 7 7 *$ (y+.....rDcP||d}||}|d}|dd|}|j|}||d}||d} ||d} ||d} |dkr|d } | | | n|d } | | | | |d<|| |d <|||dS) Nrrfr[rrrrr<rar`r) rrrrdrrrerr)rArJrUrrmrfrRr[rrrrrar`s rChandle_order_bookzkrakenfutures.handle_order_book%s/##G\::!!(++!++KvFF OF+ 00  '22w..%%g{;; 6>>V$D JJuc " " " "V$D JJuc " " "!* + $ Y 7 7 *y+.....rDc||d}||d}||d}d}||d}|t|}||||d} t dt |D]Q} || } || } |} | || | d<| | | <R| |j d <| |j d |j d <| | ||}t|}||||d}t dt |D]} || } | | }|} ||| }| |d }||} | |d | d <| |d | d<| |d| d<i||<| ||| <||j d<| |j d|j d<| |j d|dz|^||di}t|}||||d}t dt |D]} || } ||| }|| } |} | |d | d <| |d| d<| |d| d<| || <||j d<| |j d|j d<| |j d|dz| |j |dS)Nholdingrrrr)rrrrtotalcashunit availablefreerusedrmargin currenciescollateral_valuequantityflex)rKrr1r2rrirjsafe_currency_coderrr safe_balancerr)rArJrUrmr flexFuturesrRr holdingKeys holdingResultrokeycode newAccount futuresKeys futuresResultrfrS currencyIdflexFutureCurrenciesflexFuturesKeysflexFuturesResult flexFutures rChandle_balancezkrakenfutures.handle_balanceDsBd//'955//'955oog~>>  %%g{;;  w||~~..K& LL33M 1c+..// 1 1!!n..s33!\\^^ &*&6&6w&D&D 7#&0 d###0DL #'#4#4T\&5I#J#JDL NN=+ 6 6 6  w||~~..K& LL33M 1c+..// 9 9!!n))#..!\\^^ #66!--ff== ..z::%)%5%5fk%J%J 6"%)%5%5f>N%O%O 6"&*&6&6vy&I&I 7#(* f%.8 f%d++%2DL "%)%6%6t|H7M%N%NDL " NN4<1;3J K K K  "#'??; b#Q#Q "#7#<#<#>#>??O& LL33!!  1c/2233 5 5%a(!__-A3GG ..s33!\\^^ %)%5%5j+%N%N 6"%)%5%5jBT%U%U 6"&*&6&6z:&N&N 7#*4!$''#4DL #'#4#4T\&5I#J#JDL NN4</~1M N N Nt|[11111rDc\||dg}|j}|2||jdd}t |}||_i}t dt |D]?}||}||} d|| d<|| @t| } t dt | D]%}| |} d| z} | || &| |ddS) Nrr3r0rTrfz myTrades:r) rKrrr<rrirjparse_ws_my_traderkr1r2r) rArJrUrstoredrX tradeSymbolsror parsedTradetradeSymbolKeysrfrRs rChandle_my_tradeszkrakenfutures.handle_my_tradess54'266 >%%dlM4HHE+E22F"DM q#f++&& ' 'A1IE0077K26LX. / MM+ & & & &|002233q#o..// 0 0A$Q'F%.K NN6; / / / /vz*****rDc||d}||d}|||}||d}||d}||||d|||||d||d||d|rdnd ||d ||d ||d d||||d ddd S)Nrrr; fee_currencyfill_idrfrr2r< fill_typerrfee_paid)rrr) rrrrrfrr2rrrrrr)rrrrKrrry)rArrmrrisBuy feeCurrencyIds rCrzkrakenfutures.parse_ws_my_tradeDse&%%eV44 ##E<88!!(F33u--((?? ""5)44" Y//&&vx88%%eZ88$$UF33".EE ,,UK@@%%eW55&&ue44 33MBB(( ;;     rD unifiedName channelNamec K|d{V||dddd}g}tdt|D]E}|||d|||F||}d||d} |jdd} | | || | |||d{VS)NFTrrb)rGrcrgr.r) rhr~rirjrkrrf market_idsr;watch_multiplerN) rArrrWsubscriptionArgsrPrrornrTrQs rCr]z krakenfutures.watch_multi_helperps!!!!!!!!!%%gtUD%HH q#g,,'' d dA  !6!6{D$++V]^_V`JaJa!b!b c c c cOOG,,  $   it$((mT[[RX=Y=Y[hjz{{{{{{{{{rDunifiedElementNamesubChannelNamecF|du}|}|s|dz }n|d|zz }||d|zz }|S)Nsre#)rArrrf withSymbolrRs rCrzkrakenfutures.get_message_hashsP4' (  ( 3 KK 3< 'K  % 3/ /KrDc||d} t|jdz|z#t$r }||Yd}~dSd}~wwxYw)NrU )rrr Exceptionreject)rArJrUerrMsgerrors rChandle_error_messagez"krakenfutures.handle_error_messagesz!!'955 !#  677 7 ! ! ! MM%  !s2 AAAc&||d}|dkr|||dS|dkr|||dS|dkr||_dS|||d}|j|j|j|j|j|j |j |j |j |j |j |j |j |j |jd}|||}||||dSdSdS)NrGrFalertpongrc)r}rrrr\ book_snapshotopen_orders_verboseopen_orders_verbose_snapshotrfills_snapshotropen_orders_snapshotrbalances_snapshotr)rhandle_authenticater millisecondslastPongrFrHrrkrir/r4rrrrK)rArJrUrGrcmethodsmethods rChandle_messagezkrakenfutures.handle_messagesG  '22 K    $ $VW 5 5 5 5 5 g    % %fg 6 6 6 6 6 f__"//11FOOO ]##GV44D,#2*"&"3.!%!@'+'8040J."&"7#0(,(B /%)%8"&"7!G$__Wd33F!vw'''''-]*"!rDc8||d}d}|dkr||d}|||dd}||j}|||t jd}||jd<||jd<| ||nTt|j d z| |z} | | |||jvr|j|=|S) z * @ignore :see: https://docs.futures.kraken.com/#websocket-api-websocket-api-introduction-sign-challenge-challenge rGrFrrUsha256binarybase64rsr)rKhashencodebase64_to_binarysecrethmachashlibsha512r<rrrjsonrrL) rArJrUrGrRrFhashedChallenge base64Secret signaturers rCrz!krakenfutures.handle_authenticates11! G  ;;I"ii I(>(>(SSO00==L /<QYZZI(1DL %.7DL* + NN7K 0 0 0 0'#  '8J8J(JKKE MM% - - -f222(5rD)N)NN)5__name__ __module__ __qualname__r@rVrstrrrr^rqrvr r{r r ryrr rrrrr rrrrrrrrrrrrr/r4rrFrHrDrirkrrrr]rrrr __classcell__)rBs@rCrrs0 0 0 0 0 d)+4SW_a ! !$s) !C !fo ! ! ! !LNHH3HcHHHH<KMHHCHcHHHH,68   F    6:"EE7EEEEE"8Q2VQ2Q2Q2Q2f++v++++++++Z* * * * X_cuyCE||C|c|T[||||  3  \_     !6 ! ! ! !(((@&rDr)ccxt.async_supportccxt ccxt.async_support.base.ws.cacherrrccxt.base.typesrrrrr r r r r r!ccxt.async_support.base.ws.clientrtypingrccxt.base.errorsrrrccxt.base.preciser async_supportrrrDrCrs, OOOOOOOOkkkkkkkkkkkkkkkkkkkkkkkk444444******000000......%%%%%%BBBBBD&4BBBBBrD