ei-ddlZddlmZmZddlZddlmZmZm Z m Z m Z m Z m Z mZmZmZmZmZddlmZddlmZddlmZddlmZddlmZdd lmZGd d ejjZdS) N) ArrayCacheArrayCacheBySymbolById) AnyBalancesBoolIntOrder OrderBookPositionStrStringsTickerTickersTrade)Client)List) ExchangeError)AuthenticationError)ArgumentsRequired)Precisec eZdZdeffd ZifdZdifdeedede fdZ ifdedeefd Z ifded efd Z ifd ede fd ZdifdedefdZdifdedefdZddifd edededeefdZddifdeedededeefdZdifd edede fdZdddifdedededeefdZdZd2dZdddifd edededeefdZdddifd edededeefdZifdefdZ de!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+Z0d3d,ed-ed efd.Z1de!de2fd/Z3d0Z4de!fd1Z5xZ6S)4 krakenfuturesreturnc |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 T/var/www/html/volatility/venv/lib/python3.11/site-packages/ccxt/pro/krakenfutures.pyrCzkrakenfutures.describesmT : : C C E Ed#U!%      u !%$U e!$+Dt  !"t#$*. $#!%"&/6:?  $#"#& #D!  UY/H /H / / / cfK||jdd}d}||}||}||j|}|8d|jd}|||}||||||d{VS)z @ignore authenticates the user to access private web socket channels https://docs.futures.kraken.com/#websocket-api-public-feeds-challenge :returns dict: response from exchange r1r challengeN)eventapi_key) check_required_credentialsr>clientreusableFuture safe_value subscriptionsapiKeyextendwatch) rDparamsurl messageHashrMfuture authenticatedrequestmessages rF authenticatezkrakenfutures.authenticateFs ''))) it$! S!!&&{33( > >||||||rGNsymbolslimitcpK|dd|d|i|d{V}|S)a$ watches information on open orders with bid(buy) and ask(sell) prices, volumes and other data 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 orderbookbookr]N)watch_multi_helperr])rDr\r]rTr_s rFwatch_order_book_for_symbolsz*krakenfutures.watch_order_book_for_symbolsbsM11+vwQXZ_P`bhiiiiiiii    rGnamecK|d{V|jdd}d|d}g}|}|g}tdt|D]2}||} ||| 3t|} | dkr)||d} |dz| d z}||d <|||} |||| |d{VS) a  @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 Nr1r subscribe)rJfeedr:symbol product_ids) load_marketsr>rangelenappend market_idmarketrRrS) rDrcr\rTrUre marketIdsrVirilengthrprYs rFsubscribe_publiczkrakenfutures.subscribe_publicps4!!!!!!!!!it$     ?Gq#g,,'' 5 5AQZF   T^^F33 4 4 4 4W Q;;[[1..F%+fX.>>K#, - ++i00ZZ[';GGGGGGGGGrGrVcBK|d{V|d{V|jdd}d||j|jd|jdd}|||}|||||d{VS)a0 @ignore Connects to a websocket channel :param str name: name of the channel :param str messageHash: unique identifier for the message :param dict [params]: extra parameters specific to the krakenfutures api :returns dict: data from the websocket stream Nr1rrerIsignedChallenge)rJrfrKoriginal_challengesigned_challenge)rkr[r>rQr?rRrS)rDrcrVrTrUrerYs rFsubscribe_privatezkrakenfutures.subscribe_privates!!!!!!!!!!!!!!!!!!it$ {"&,{"; $ -> ?   ++i00ZZ[';GGGGGGGGGrGricK|d{V||}||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.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)rkri watch_tickers)rDrirTtickerss rF watch_tickerzkrakenfutures.watch_tickersp!!!!!!!!!V$$**F8V<<<<<<<<vrGc K|d{V||dd}|dd|d|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 a specific market https://docs.futures.kraken.com/#websocket-api-public-feeds-ticker :param str[] symbols: unified symbols of the markets to fetch the ticker for :param dict [params]: extra parameters specific to the exchange API endpoint :returns dict: a `ticker structure ` NFtickerri)rkmarket_symbolsra newUpdatesfilter_by_arrayr|rDr\rTrresults rFr{zkrakenfutures.watch_tickerss!!!!!!!!!%%gtU;;..x7DRXYYYYYYYY ? F'-F6(# $M##DL(GDDDrGcK|dd|d|d{V}|jri}|||d<|S||jd|S)a 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_liteNri)rarrbidsasksrs rFwatch_bids_askszkrakenfutures.watch_bids_asksst..xQUW]^^^^^^^^ ? F'-F6(# $M##DM8WEEErGsincecDK||g|||d{VS)a& get the list of most recent trades for a particular symbol 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)rDrirr]rTs rF watch_tradeszkrakenfutures.watch_tradess622F8UE6RRRRRRRRRrGcK|dd|d|d{V}|jrB||d}||d}|||}||||ddS)a' 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 ` tradeNrri timestampT)rar safe_list safe_stringgetLimitfilter_by_since_limit)rDr\rr]rTtradesfirst tradeSymbols rFrz&krakenfutures.watch_trades_for_symbolss..w$PVWWWWWWWW ? 8NN61--E**5(;;KOOK77E))&% TRRRrGcBK||g||d{VS)a2 watches information on open orders with bid(buy) and ask(sell) prices, volumes and other data 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)rb)rDrir]rTs rFwatch_order_bookzkrakenfutures.watch_order_books466xOOOOOOOOOrGcTK|d{Vd}||}||sdd|z}d|z}|d||d{V}|jr|S||j|||dS)a 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 since @param limit :param dict params: extra parameters specific to the exchange API endpoint :returns dict[]: a list of `position structure ` N::, positionsopen_positionsT)rkris_emptyjoinryrfilter_by_symbols_since_limitr)rDr\rr]rTrV newPositionss rFwatch_positionszkrakenfutures.watch_positionss!!!!!!!!! %%g..}}W%% 3'!2!22K!K/ !334DkSYZZZZZZZZ ?  11$.'5RWY]^^^rGc@|jt|_|j}||dg}g}tdt |D]|}||}||}||d} | |d<|| |d<||||}| |d} tdt | D]}| |} | d} | d} | d}| |d |d }| |s| || | |ddS) Nrrrdatetimez positions::rrgrriF)rrrOrlrmparse_ws_position safe_integeriso8601rnfind_message_hashessplitrrresolve)rDrMrZcache rawPositionsrrr rawPositionpositionr messageHashesrVparts symbolsStringr\rs rFhandle_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|[11111rGc ||d}d}||d}d}tj|drd}ntj|drd}|id|ddd ||d dd dd ||d d||dd||dd||dd|tj|ddd||dd|d|ddddd||ddd||dddddS) N instrumentbothbalance0longshortinfoidrinotional marginModeliquidationPriceliquidation_threshold entryPrice entry_price unrealizedPnlpnl percentagereturn_on_equity contracts contractSize markPrice mark_pricesidehedgedrrmaintenanceMarginmaintenance_margininitial_margin)maintenanceMarginPercentage collateral initialMargininitialMarginPercentageleverage marginRatio) rr string_gt string_lt safe_position safe_symbol safe_number parse_number string_abs)rDrrpmarketIdr balanceStringrs rFrzkrakenfutures.parse_ws_positionOs&##Hl;;((9==   ]C 0 0 DD  }c 2 2 D!!# H# $#  d&&x00#   # $ #  0 0;R S S #  $**8]CC#  T--h>>#  $**85GHH#  **7+=m+L+LMM#  D#  ))(LAA#  D#  f#  # !# " !1!1(` N open_ordersordersrhrirTrkrpryrrr) rDrirr]rTrcrVrprs rF watch_orderszkrakenfutures.watch_orderss!!!!!!!!!  [[((F 3!11 1K--dKHHHHHHHH ? 3OOFE22E))&% TRRRrGc2K|d{Vd}d}|#||}|d|dzz }||||d{V}|jr|||}||||ddS)a7 watches information on multiple trades made by the user 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 ` NfillsmyTradesrhrirTr) rDrirr]rTrcrVrprs rFwatch_my_tradeszkrakenfutures.watch_my_tradess!!!!!!!!!  [[((F 3!11 1K--dKHHHHHHHH ? 3OOFE22E))&% TRRRrGcK|d{Vd}|}d}||dd\}}|+|dkr|dkrt|jdz|d|zz }||||d{VS) a watches information on the user's account balance https://docs.futures.kraken.com/#websocket-api-private-feeds-balances :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'rh)rkhandle_option_and_paramsrrry)rDrTrcrVrs rF watch_balancezkrakenfutures.watch_balances!!!!!!!!! 77PYZZ  )##>(A(A'2x(xyyy 3= (K++D+vFFFFFFFFFrGrMc||d}||d}|K||}|d}|dd|}||j|3||jdd}t||j|<|j|} |dkrt||dg} t| } td | D]<} | d z | z } | | }| |}| |=n*| |}| || | |dSdS) Nrf product_idrirr6r3trade_snapshotrrrg) rrpget_message_hashrrrr?rrmrlparse_ws_tradernr)rDrMrZchannelrrprirVr6 tradesArrayrrsrrindexitemrs rF 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' rGc||d}|||}||d}||||d||d|||d||d||dd||d||d ddddd d |S) Nrtimeuidrir5rtakerpriceqtyratecostcurrency rrrirrorderr5r takerOrMakerramountrfee)r safe_marketr safe_trader)rDrrprrs rFrzkrakenfutures.parse_ws_trades ##E<88!!(F33%%eV44 ""5%00&&vx88" Y//$$UF33$$UF33#%%eW55&&ue44   $ % rGc`||d}||d}||||d||||||||d||d||d||d||d||d dd||d ||d d d |S)N tradeTimeritradeIdorderIdr5r matchRoler tradeAmounttradeFee feeCurrencyrr)rrr rrsafe_string_lower)rDrrprrs rFparse_ws_order_tradez"krakenfutures.parse_ws_order_trade)s6:%%e[99 ##E844""5)44&&x88" Y//%%eY77**5&99$$UF33 ,,UK@@%%eW55&&um<<(( ;; ,,UMBB  $ % rGc |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)Nr7rrrorder_idreasonedited_by_userrhrrlastTradeTimestamprrrraveragefilled remainingrrr is_cancelrstatuscanceledorders:ri)rrr?rrOrrhashmapparse_ws_orderrnrrrlrmr string_addnumber_to_stringr string_div string_sub safe_orderrR)rDrMrZrr]rrrVrirpreviousOrders previousOrderrparsedr totalCost totalAmountrrr currentTradestringOrderFilledstringOrderCoststringTradeCostisCancel currentOrders rF handle_orderzkrakenfutures.handle_order\sJ >%%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 9rGc ||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 directionrrirr clientOrderIdrrrr5 timeInForcepostOnlyrrbuysellr limit_price stopPrice stop_price triggerPricerrrrrr)rrrrr)rOrrr'rr) rDrrp isCancelled unparsedOrderrrrr;s rFr"zkrakenfutures.parse_ws_order*s7Nooe[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      rGc||d}|V||}|d}||j|<|dd|}|||dSdS)Nrrir)rparse_ws_tickerr|rrrDrMrZrrrirVs rF handle_tickerzkrakenfutures.handle_tickerxs@##G\::  ))'22FH%F#)DL //$GGK NN6; / / / / / rGc||d}|V||}|d}||j|<|dd|}|||dSdS)Nrrir)rrHrrrrIs rFhandle_bid_askzkrakenfutures.handle_bid_asks"##G\::  ))'22FH%F$*DM& !//$GGK NN6; / / / / / rGc ||d}|||}|d}|||d}||d}|id|d|d|d||ddd dd ||d d ||d d ||d d||dddddd|d|ddd||dddd||d||d||d||ddS)NrrilastTimelastrrrhighlowbid bidVolumebid_sizeask askVolumeask_sizevwapopenclose previousClosechangervolume volumeQuoterr)r baseVolume quoteVolumer indexPrice)rr  parse8601 safe_tickerr)rDrrprrirrOs rFrHzkrakenfutures.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))&+>>**67;;-! ! !    rGc||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) Nrrir_r]rbidsasksrrrr)rr r safe_dictrPr order_book orderbooksrrlrmrstorerr)rDrMrZrrprirV subscriptionr]rr_rerfrrrRrrbidsSiderUasksSides rFhandle_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+.....rGcP||d}||}|d}|dd|}|j|}||d}||d} ||d} ||d} |dkr|d } | | | n|d } | | | | |d<|| |d <|||dS) Nrrir_rrrrr@rfrer) rr rrirrrjrr)rDrMrZrrprirVr_rrrrrfres rFhandle_order_bookzkrakenfutures.handle_order_bookBs/##G\::!!(++!++KvFF OF+ 00  '22w..%%g{;; 6>>V$D JJuc " " " "V$D JJuc " " "!* + $ Y 7 7 *y+.....rGc||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)rOrr5r6rrlrmsafe_currency_coderrr safe_balancerr)rDrMrZrrr flexFuturesrVr holdingKeys holdingResultrrkeycode newAccount futuresKeys futuresResultrirW currencyIdflexFutureCurrenciesflexFuturesKeysflexFuturesResult flexFutures rFhandle_balancezkrakenfutures.handle_balanceasBd//'955//'955oog~>>  %%g{;;  w||~~..K& LL33##M 1c+..// 1 1!!n..s33!\\^^ &*&6&6w&D&D 7#&0 d###0DL #'#4#4T\&5I#J#JDL NN=+ 6 6 6  w||~~..K& LL33##M 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|[11111rGc\||dg}|j}|2||jdd}t |}||_i}t dt |D]?}||}||} d|| d<|| @t| } t dt | D]%}| |} d| z} | || &| |ddS) Nrr6r3rTriz myTrades:r) rOrrr?rrlrmparse_ws_my_tradernr5r6r) rDrMrZrstoredr] tradeSymbolsrrr parsedTradetradeSymbolKeysrirVs rFhandle_my_tradeszkrakenfutures.handle_my_trades4s54'266 >%%dlM4HHE+E22F"DM q#f++&& ' 'A1IE0077K26LX. / MM+ & & & &|002233q#o..// 0 0A$Q'F%.K NN6; / / / /vz*****rGc||d}||d}|||}||d}||d}||||d|||||d||d||d|rdnd ||d ||d ||d d||||d ddd S)Nrrr? fee_currencyfill_idrirr5r@ fill_typerrfee_paid)rrr) rrrrrirr5rrrrrr)rrr rOr rr~)rDrrprrisBuy feeCurrencyIds rFrzkrakenfutures.parse_ws_my_tradease&%%eV44 ##E<88!!(F33u--((?? ""5)44" Y//&&vx88%%eZ88$$UF33".EE ,,UK@@%%eW55&&ue44 33MBB(( ;;     rG unifiedName channelNamec K|d{V||dddd}g}tdt|D]E}|||d|||F||}d||d} |jdd} | | || | |||d{VS)NFTrre)rJrfrjr1r) rkrrlrmrnrri market_idsr>watch_multiplerR) rDrrr\subscriptionArgsrTrrrrqrYrUs rFraz krakenfutures.watch_multi_helpers!!!!!!!!!%%gtUD%HH q#g,,'' d dA  !6!6{D$++V]^_V`JaJa!b!b c c c cOOG,,  $   it$((mT[[RX=Y=Y[hjz{{{{{{{{{rGunifiedElementNamesubChannelNamecF|du}|}|s|dz }n|d|zz }||d|zz }|S)Nsrh#)rDrrri withSymbolrVs rFrzkrakenfutures.get_message_hashsP4' (  ( 3 KK 3< 'K  % 3/ /KrGc||d} t|jdz|z#t$r }||Yd}~dSd}~wwxYw)NrZ F)rrr Exceptionreject)rDrMrZerrMsgerrors rFhandle_error_messagez"krakenfutures.handle_error_messagesu!!'955 #  677 7    MM% 55555 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)NrJrIalertpongrf)rrrrr` book_snapshotopen_orders_verboseopen_orders_verbose_snapshotrfills_snapshotropen_orders_snapshotrbalances_snapshotr)rhandle_authenticater millisecondslastPongrJrLrrprnr3r8rrrrO)rDrMrZrJrfmethodsmethods rFhandle_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'''''-]*"!rGcl||d}d}|dkr||d}|||dd}||j}|||t jd}||jd<||jd<||j |} | d nTt|j d z| |z} || |||jvr|j|=|S) z} @ignore https://docs.futures.kraken.com/#websocket-api-websocket-api-introduction-sign-challenge-challenge rJrIrrZsha256binarybase64rvTr)rOhashencodebase64_to_binarysecrethmachashlibsha512r?rrrrjsonrrP) rDrMrZrJrVrIhashedChallenge base64Secret signaturerWrs rFrz!krakenfutures.handle_authenticates#11! G  ;;I"ii I(>(>(SSO00==L /<QYZZI(1DL %.7DL* +__V^[AAF NN4 '#  '8J8J(JKKE MM% - - -f222(5rG)N)NN)7__name__ __module__ __qualname__rrCr[rstrrr rbrtryrr}r rr{rr rrrrr rrrr rrrrrrrrr3r8r"rJrLrHrnrprrrrarrrrr __classcell__)rEs@rFrrs0 #0 0 0 0 0 0 d)+8SW_a ! !$s) !C !fo ! ! ! !LNHH3HcHHHH<KMHHCHcHHHH,68   F    6:"EE7EEEEE&8Q2VQ2Q2Q2Q2f++v++++++++Z* * * * X_cuyCE||C|c|T[||||  3  \_     6 t    (((@&rGr)ccxt.async_supportccxt ccxt.async_support.base.ws.cacherrrccxt.base.typesrrrrr r r r r rrr!ccxt.async_support.base.ws.clientrtypingrccxt.base.errorsrrrccxt.base.preciser async_supportrrrGrFrs8 OOOOOOOOvvvvvvvvvvvvvvvvvvvvvvvvvvvv444444******000000......%%%%%%aaaaaD&4aaaaarG