":h-fddlZddlmZmZmZddlmZmZm Z m Z m Z m Z m Z mZmZmZmZmZmZddlmZddlmZddlmZddlmZddlmZdd lmZdd lmZdd lmZdd lmZdd lm Z ddlm!Z!ddlm"Z"ddlm#Z#ddlm$Z$ddlm%Z%ddlm&Z&ddl'm(Z(GddejRjTZ*y)N) ArrayCacheArrayCacheBySymbolByIdArrayCacheByTimestamp) AnyBalancesIntNumOrder OrderBook OrderSide OrderTypeStrStringsTickerTickersTrade)Client)List) ExchangeError)AuthenticationError)PermissionDenied)AccountSuspended)ArgumentsRequired) BadRequest) BadSymbol)InsufficientFunds) InvalidOrder) OrderNotFound) NotSupported)RateLimitExceeded)ExchangeNotAvailable) ChecksumError)PreciseceZdZdeffd Zdifdededededed ef d Zdifdede d e de d ede f d Z d Zddifdedede d e ded ede fdZdifdeedefdZdifdedede fdZdZdifdefdZdZdZdefdZdefdZdZifdZifdedefdZdifdede fdZ!difdede fdZ"defd Z#dEd!Z$ddifded"e%d#e%dee&fd$Z'ddifdeed"e%d#e%dee&fd%Z(difded#e%de)fd&Z*difdeed#e%de)fd'Z+d(ddifded"e%d#e%dee,fd)Z-d*iffd+ Z.ifd,Z/defd-Z0defd.Z1d/Z2dEd0Z3defd1Z4ifd2Z5dddifded"e%d#e%fd3Z6dddifded"e%d#e%dee&fd4Z7dEdefd5Z8dEd6Z9dddifded"e%d#e%dee fd7Z:dEdefd8Z;dEd9Zfd=Z?defd>Z@dFd?ed@edefdAZAdefdBZBdefdCZCdefdDZDxZES)Gkrakenreturnc<|jtt|iddddddddddddddd dd dd dd dd dddddddddddddddddddiidddiddidddtiidtdt d td!td"td#t d$td%td&td'td(td)td*td+td,t d-td.tid/td0td1td2td3td4td5td6td7td8td9td:td;tdtd?tttttttttttd@ dAidBS)CNwsT watchBalance watchMyTrades watchOHLCVwatchOrderBookwatchOrderBookForSymbols watchOrders watchTicker watchTickers watchBidsAsks watchTradeswatchTradesForSymbols createOrderWs editOrderWs cancelOrderWscancelOrdersWscancelAllOrdersWsapizwss://ws.kraken.comzwss://ws-auth.kraken.comzwss://ws-auth.kraken.com/v2zwss://beta-ws.kraken.comzwss://beta-ws-auth.kraken.com)publicprivate privateV2betaz beta-privatechecksum) tradesLimit OHLCVLimit ordersLimitsymbolsByOrderIdr,zEvent(s) not foundzAlready subscribedz'Currency pair not in ISO 4217-A3 formatzMalformed requestzPair field must be an arrayz1Pair field unsupported for self subscription typezPair(s) not foundz*Subscription book depth must be an integerz Subscription depth not supportedz$Subscription field must be an objectzSubscription name invalidz%Subscription object unsupported fieldz-Subscription ohlc interval must be an integerz(Subscription ohlc interval not supportedz#Subscription ohlc requires intervalzEAccount:Invalid permissionsz EAuth:Account temporary disabledzEAuth:Account unconfirmedzEAuth:Rate limit exceededzEAuth:Too many requestsz+EDatabase: Internal error(to be deprecated)z EGeneral:Internal error[:]zEGeneral:Invalid argumentsz$EOrder:Cannot open opposing positionzEOrder:Cannot open positionz2EOrder:Insufficient funds(insufficient user funds)z[EOrder:Insufficient margin(exchange does not have sufficient funds to allow margin trading)zEOrder:Invalid pricez EOrder:Margin allowance exceededzEOrder:Margin level too lowzaEOrder:Margin position size exceeded(client would exceed the maximum position size for self pair)z,EOrder:Order minimum not met(volume too low)zEOrder:Orders limit exceededzEOrder:Positions limit exceededzEOrder:Rate limit exceeded) z&EOrder:Scheduled orders limit exceededzEOrder:Unknown positionzEOrder:Unknown orderzEOrder:Invalid orderzEService:Deadline elapsedz#EService:Market in cancel_only modez"EService:Market in limit_only modez!EService:Market in post_only modezEService:UnavailablezETrade:Invalid request)exactbroad)hasurlsoptions exceptions) deep_extendsuperr%describerrrrrr rrrrr!r)self __class__s I/var/www/html/turnos/venv/lib/python3.12/site-packages/ccxt/pro/kraken.pyrLzkraken.describes8fd < >d d  !$  +D tt t( t  !$!"$T#,"7#=%B :(G   $"#$&# ,j-,j-A9-,Z-6z - LZ - ,Y -Ej-;J-? -4Z-@-H-CJ->z-78H- ;G ?-@7 A-B:J=I0D2>&*b9^^FL"= ))(NC++JG"..xA $ 0 0W E)5-T9((A **63DE,D8!0!<))&2BC**63DE"..v7LM#//8NO .d :!0!<%8%D"&:$&F#!!&(B7R`Rlv(=(=n(MMswTcTo)>)>)O Ovz\o\{FT-B-BCV-W$WCG!^r^~Vd.C.CDX.Y%YFJ"48SEZa _ $ =J37!-000GK&5@!/2YYv m'DEF#'=AVZpuOSn02!*-#535!-0#EPGH%m4\BHLH]H]^b^u^uv|M_NIOGH%m4_E'ERGH%m4\BHLH]H]^b^u^uv|O_PIQGH%m4_E&2EVGH%m4\BFJF[F[\`\s\stz}P]QGRGH%m4]C*6EXGH%m4\BFJF[F[\`\s\stz}R]SGTGH%m4]C6J +EF%)?'=A=R=RSWSjSjkqtATB>CGH%j1':#:K),7:E),7=A=R=RSWSjSjkqtCTD>EGH%j1':#:M),7:G),7&*@D^b}>G!*-l;#)>BX6EGH%l3,AEAVAVWkAl)*5g>AEAVAVWlAm)*5g>=FGH%&896KGH%l31AEAVAVWpAq)*5g>AEAVAVWqAr)*5g> } $#5"477.B$BCC#'='9=9N9NtOfOfgmo|O}9~GH%o69=9N9NtOfOfgmo~O:AGH%o6&*@D^b}:C!"67#)>BX,=A=R=RSg=h)/:=A=R=RSh=i)/:` Nr9r(r< add_orderrR)rtrr`rRtokenrQrYreq_idr4) load_markets authenticater[rG request_idr{amount_to_precisionrwatchextend) rMrRrSrrUrVrYrr[url requestId messageHashrTs rOcreate_order_wszkraken.create_order_wss!!!''))V$iit$[1OO%  !"!2243K3KFTZ3[\ *    //wX^`egmnZZ[$++gv2NP[\\\% ")"]s2C%CC%C!B+C%C#C%!C%#C%c|j|di}|j|}|j|dd}|j||y)Nresultreqidr)r parse_order safe_value_2resolve)rMclientmessagerorderrs rOhandle_create_edit_orderzkraken.handle_create_edit_ordersH626  (''(C uk*rPrzc K|jd{|jd{}|jddd} |j} | } d||j |j |||d| d} |j d||| |||\} }|j| | |j| || d{S777w) a edit a trade order https://docs.kraken.com/api/docs/websocket-v2/amend_order :param str id: order id :param str symbol: unified symbol of the market to create an order in :param str type: 'market' or 'limit' :param str side: 'buy' or 'sell' :param float amount: how much of the currency you want to trade in units of the base currency :param float [price]: the price at which the order is to be fulfilled, in units of the quote currency, ignored in market orders :param dict [params]: extra parameters specific to the exchange API endpoint :returns dict: an `order structure ` Nr9r(r< amend_order)order_idr`rrr5) rrrGrr{rrrr) rMrzrRrSrrUrVrYrrrrrTs rO edit_order_wszkraken.edit_order_ws>s!!!''))iit$[1OO%  #!2243K3KFTZ3[\   // vtWV\^ceklZZ[$++gv2NP[\\\ ")]s2CC CC BCC C C CidscbK|t|jdz|jd{|jd{}|jddd}|j }|}d||d|d}|j |||j|||d{S7x7b7w) a https://docs.kraken.com/api/docs/websocket-v1/cancelorder cancel multiple orders :param str[] ids: order ids :param str [symbol]: unified market symbol, default is None :param dict [params]: extra parameters specific to the exchange API endpoint :returns dict: an list of `order structures ` NzK cancelOrdersWs() does not support cancelling orders for a specific symbol.r9r(r< cancel_orderrrrrrzrrrGrrr) rMrrRrYrrrrrTs rOcancel_orders_wszkraken.cancel_orders_ws^s  tww)vvw w!!!''))iit$[1OO%  $  ZZ[$++gv2NP[\\\ ")]s4.B/B)B/B+ AB/$B-%B/+B/-B/cdK|t|jdz|jd{|jd{}|jddd}|j }|}d|g|d|d}|j |||j|||d{S7y7c7w) a https://docs.kraken.com/api/docs/websocket-v1/cancelorder cancels an open order :param str id: order id :param str [symbol]: unified symbol of the market the order was made in :param dict [params]: extra parameters specific to the exchange API endpoint :returns dict: An `order structure ` NzJ cancelOrderWs() does not support cancelling orders for a specific symbol.r9r(r<rrrr) rMrzrRrYrrrrrTs rOcancel_order_wszkraken.cancel_order_wszs  tww)uuv v!!!''))iit$[1OO%  $D  ZZ[$++gv2NP[\\\ ")]s4.B0B*B0B, AB0%B.&B0,B0.B0cL|j|d}|j||yNr safe_valuerrMrrreqIds rOhandle_cancel_orderzkraken.handle_cancel_order"2w&rPc`K|t|jdz|jd{|jd{}|jddd}|j }|}dd|i|d}|j |||j|||d{S7w7a7w) a https://docs.kraken.com/api/docs/websocket-v1/cancelall cancel all open orders :param str [symbol]: unified market symbol, only orders in the market of self symbol are cancelled when symbol is not None :param dict [params]: extra parameters specific to the exchange API endpoint :returns dict[]: a list of `order structures ` NzM cancelAllOrdersWs() does not support cancelling orders in a specific market.r9r(r< cancel_allrrr)rMrRrYrrrrrTs rOcancel_all_orders_wszkraken.cancel_all_orders_wss  tww)xxy y!!!''))iit$[1OO%  "  ZZ[$++gv2NP[\\\ ")]s4.B.B(B.B* AB.#B,$B.*B.,B.cL|j|d}|j||yrrrs rOhandle_cancel_all_orderszkraken.handle_cancel_all_ordersrrPc|d}|j|jd|}|d}|jdd|}|d}|j|dd} d} |j|dd} | | t j | | } |j|d d} |j id|d dd dd |j|d dd|j|ddd|j|ddd|j|ddd|j|ddd|j|ddd| d|j|ddd| d| dddddddd| | |d } | |j|<|j| |y)!NmarketsByWsNamerRtickerprvc timestampdatetimehighhlowlbidb bidVolumeaska askVolumevwapopenocloselast previousClosechange percentageaverage) baseVolume quoteVolumeinfo) rrHget_message_hashr~r# string_mul safe_tickertickersr)rMrr subscriptionwsNamer[rRrrrrrrrs rO handle_tickerzkraken.handle_tickers4&.?!@&I!++HdFC s Q/ %%fSk15  !d&6!,,Z>Ks Q/!!# f# #  #  D$$VC[!4 # 4##F3K3 # 4##F3K3 #  ))&+q9#  4##F3K3#  ))&+q9#  D#  D$$VC[!4#  T#  D#  T#  d# $!# " t## $%&)#  , & Vv{+rPrc.|j|d}|j|d}|j|jd|}|d}|j|d|}|j|j|} | 7|j |jdd} t | } | |j|<|j|dg} |j| |} tdt| D]} | j| | |j| |y) NrrrrRr@r>rr) r~rrHrtrades safe_integerr parse_tradesrangelenappendr)rMrrrrnamer[rRrstoredrXrparsedis rO handle_tradeszkraken.handle_tradess!!'1-+.?!@&I!++D$? f5 >%%dllM4HE&F"(DKK !R0""662q#f+& %A MM&) $ %v{+rPc |j|di}|j|d}|j|d}|j|d}|j|jd|}|d} |j |} |j | } | L|j|d} |dz| zdz|z} |j | d}|| z}|j|d z}||j | d |j | d|j | d |j | d |j | d g}|j|j| i|j| <|j|j| | }|:|j|jdd }t|}||j| | <|j||j|| yy)NrintervalrrrrRr:r>rrA) rrr~rHfind_timeframeparse_timeframe safe_float parse_to_intohlcvsrrr)rMrrrrrrrr[rR timeframedurationcandlerrtsrrrXs rO handle_ohlcvzkraken.handle_ohlcv#s&|^R@$$T:6f-!!'1-.?!@&I!''1 '' 2  __Wa0F*y036?K2I  !I""9t#34B***** F#'//$++vr"JDKK __T[[%8)DF~))$,, dK.u517 F#I. MM& ! NN6; /+ !rPc~|j|j|jddd}||jd<|S)Nrrr)sumrrH)rMrs rOrzkraken.request_idUs8**4<<!DaH % W rPcXK|jd{|j|}|j|dd}|dz|z}|jddd}|j }d||gd|id } |j | |} |j ||| |d{S77w) Nrwsnamerr9r(r: subscribereventrpairr)rr[rrGrrJr) rMrrRrYr[rrrrrrTs rO watch_publiczkraken.watch_public[s!!!V$:Sj6) iit$X.OO%    ""9f5ZZ[';GGG# ""Hs"B*B&B B*!B("B*(B*cK|jd{|j|}|j|g|d{}||S757 w)a watches a price ticker, a statistical calculation with the information calculated over the past 24 hours for a specific market https://docs.kraken.com/api/docs/websocket-v1/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)rrR watch_tickers)rMrRrYrs rO watch_tickerzkraken.watch_tickerosR!!!V$**F8V<<v "` NFrrR)rmarket_symbolswatch_multi_helper newUpdatesfilter_by_arrayrrMrrYrrs rOrzkraken.watch_tickers~s!!!%%gtU;..x7DRXYY ??F'-F6(# $M##DLL(GDD "Y!BB/BB:BBc K|jd{|j|dd}|jdd|d|d{}|jr i}|||d<|S|j |j d|S7i7;w)av https://docs.kraken.com/api/docs/websocket-v1/spread 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 ` NFbidaskspreadrR)rrr r!r"bidsasksr#s rOwatch_bids_askszkraken.watch_bids_askss!!!%%gtU;..x7DRXYY ??F'-F6(# $M##DMM8WEE "Yr$c|j|}|d}||j|<|jdd|}|j||y)NrRr&)parse_ws_bid_askr(rr)rMrrr parsedTickerrRrs rOhandle_bid_askzkraken.handle_bid_asksN,,W5 h' , f++HdFC |[1rPc |j|dg}|j|d}|j|jd|}|j|d}|j |j |ddz}|j |||j||j|d|j|d|j|d|j|d|d |S) NrrrrRrr>rr)rRrrrrrrr) safe_listr~rrHr rriso8601)rMrr[datamarketIdrRrs rOr+zkraken.parse_ws_bid_asks~~fa,##FA..?!@(K!!&(3%%d&7&7a&@ADH " Y/##D!,))$2##D!,))$2 !    rPsincerXcHK|j|g|||d{S7w)a get the list of most recent trades for a particular symbol https://docs.kraken.com/api/docs/websocket-v1/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_symbolsrMrRr3rXrYs rO watch_tradeszkraken.watch_tradess'22F8UE6RRRR " "cK|jdd|d|d{}|jr6|j|d}|j|d}|j ||}|j |||ddS7[w)a https://docs.kraken.com/api/docs/websocket-v1/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 ` tradeNrrRrT)r r!r/r~getLimitfilter_by_since_limit)rMrr3rXrYrfirst tradeSymbols rOr5zkraken.watch_trades_for_symbolss|..w$PVWW ??NN61-E**5(;KOOK7E))&% TRR XsA9A7AA9cFK|j|g||d{S7w)a0 watches information on open orders with bid(buy) and ask(sell) prices, volumes and other data https://docs.kraken.com/api/docs/websocket-v1/book :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 N)watch_order_book_for_symbols)rMrRrXrYs rOwatch_order_bookzkraken.watch_order_books%66xOOOOs !!c Ki}|4|j|gdrd|i|d<nt|jdz|jdd|d|i|j ||d{}|j S7w) a watches information on open orders with bid(buy) and ask(sell) prices, volumes and other data https://docs.kraken.com/api/docs/websocket-v1/book :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 N) dir>depthrzF watchOrderBook accepts limit values of 10, 25, 100, 500 and 1000 only orderbookbookrX)in_arrayrrzr rrX)rMrrXrYrTrGs rOr@z#kraken.watch_order_book_for_symbolss  }}U$<=U+'#477-u#uvv11+vwQXZ_P`bfbmbmnuw}b~   @sA#A<%A:&A<1mc K|jd{d}|j|}|d}|j|dd}|dz|zdz|z} |jddd } |j } d | |g||j|j ||d d } |j | |} |j| | | | d{}|jr|j||}|j|||d dS779w)a watches historical candlestick data containing the open, high, low, and close price, and the volume of a market https://docs.kraken.com/api/docs/websocket-v1/ohlc :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 NohlcrRrrrr9r(r:r)rrrrT) rr[rrGr timeframesrJrr!r;r<)rMrRr r3rXrYrr[rrrrrrTohlcvs rO watch_ohlcvzkraken.watch_ohlcvs!!!!V$!:Sj9,s2V; iit$X.OO%   OODOOY R  ""9f5jjk7KHH ??NN651E))%q$GG/ "(Is"DDB3D D 8DDFcKtt| ||d{}|j|jd}||ri}t dt |jD]}|j|}|j|}|dr9|j|di}|j|d} | dddz| ddz} ||| <_|j|di}|j|d} ||| <||jd<|S7w) Nrrdarkpoolraltnamer/r) rKr%rrrHrrrmarketsr~) rMreloadrYrTrrrRr[rrRrrNs rOrzkraken.load_markets4sfd8HH//$,,8IJ  # O1c$,,/0 5af-*%??662>D"..tY?G$Qq\C/'!"+=F.4OF+??662>D!--dH=F.4OF+ 5/>DLL* +#IsC?C=C"C?cK|jd{d}|jddd}|j||d{S757w)N heartbeatr9r(r:)rrGr)rMrYrrs rOwatch_heartbeatzkraken.watch_heartbeatHsT!!!iit$X.ZZU+++ ",s!AA 0AAAAcL|j|d}|j||y)Nr)r~r)rMrrrs rOhandle_heartbeatzkraken.handle_heartbeatNs$   '2w&rPct|}||dz }||dz }|jd}|j|dd}|j|jd|} | d} d} |j dd| } d|dvr|j i||j| <|j| } d d d }t|j}td t|D]:}||}||}| |}|j|d|g}|j||| } <| | d<| | d <|j| | d<|j| | y|j| } d}d}d}|dk(rX|j|ddg}|j|ddg}|j|dd}|j|dd|}nI|j|dd}d|dvr|j|ddg}n|j|ddg}| d }| d }d}|%|j||| } |j|d }|%|j||| } |j|d }| j|jddd}|r|j!|d }|j!|d}|jd}|jd}t|dd z } t|dd z }!g}"|td dD]D}|j#||d | |j#||d|!z}#|"j%|#Ftd dD]D}|j#||d | |j#||d|!z}#|"j%|#Fdj'|"}$|j)|$d}%|%|k7rWt+|j,dz|j/| z}&|j0| =|j| =|j3|&| y| | d<| | d <|j| | d<|j| | y)Nrr-rCrrRrGasasksbids)r]bsrrrrrrrr,r?T.rkF )rsplitrrrHr order_book orderbookslistkeysrcustom_handle_deltasr0rrX handle_optionr~ format_numberrjoincrc32r"rzorderbook_checksum_message subscriptionsreject)'rMrrr messageLengthrbookDepthStringpartsrFr[rRrrrGsidesrgrkeyrbooksidedeltasrrr storedAsks storedBidsexampler? priceString amountString priceParts amountParts priceLength amountLength payloadArray formattedpayload localChecksumerrors' rOhandle_order_bookzkraken.handle_order_bookWsRG *+!-!"34%%c*!!%B/.?!@&I! ++KvF 71: &*oob%&@DOOF #/IE %D1c$i( S1gSz$T?S"= 55h R  S #)Ih %.Ik "$(LL$;Ij ! NN9k 2/IAAA!OOGAJR8OOGAJR8%%gaj#6%%gaj#q9%%gaj#6'!*$ C2Q6 ! ="1b\7$($6$6z!}Q7G$UX\XjXjkuvwkxyzk{~JYK%K $++I67#1b\7$($6$6z!}Q7G$UX\XjXjkuvwkxyzk{~JYK%K $++I67'',/ $ 7E :  A%)$''C-$:Y:YZ`:a*abE,,[9/MM%5"(Ih %.Ik "$(LL$;Ij ! NN9k 2rPc|j|}|jd}|j|d}|j|dd}|j|d}||z}d} || dk(r| dz } || dk(r| dkDr|| dS|S)Nrarrrk0)rrcr~ljust) rMnlength stringNumberrrintegerdecimalspaddedDecimalsjoinedrs rOrjzkraken.format_numbers,,Q/ ""3'""5!,##E1b1!4>) Qi3 FAQi3 q5!": MrPc tdt|D]q}||}|j|d}|j|d}|r|nd}t||j t |ddz}|j ||s|S)Nrrrr>)rr parse_numbermaxr floatstore) rMrurvrjdeltarVrU oldTimestamps rOrhzkraken.custom_handle_deltassq#f+& *A1IE%%eAh/E&&uQx0F(19qLL$*;*;E%(OdL2>F  / g66HsABB8BcK|jd{|jd{}|}|}||j|}|d|zz }|jddd} |j } d| ||dd} |j | |} |j | || |d{} |jr| j||}|j| |||S777:w)Nrr9r(r;r)rr)rrr) rrrRrGrrJrr!r;filter_by_symbol_since_limit)rMrrRr3rXrYrsubscriptionHashrrrrrTrs rO watch_privatezkraken.watch_private s!!!''))  [[(F 3< 'Kiit$Y/OO%   ""9f5zz#{G=MNN ??OOFE2E00NN+ ")"Os2C&C C&C"A:C&)C$*7C&"C&$C&cHK|jd||||d{S7w)a. watches information on multiple trades made by the user https://docs.kraken.com/api/docs/websocket-v1/owntrades :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 ` ownTradesNrr6s rOwatch_my_tradeszkraken.watch_my_trades8s''' VUE6RRRRr8c|j|dg}t|}|dkDrh|j-|j|jdd}t ||_|j}i}t dt|D]} |j|| i} t| j} t dt| D]J} | | } | | }|j|jd| i|}|j||d}d||<Ld}|j|j|t|j}t dt|D])} |dz|| z}|j|j|+yy) Nrr@r>rzrRTrr) rrmyTradesrrHrrrfrgparse_ws_traderrr)rMrrr allTradesallTradesLengthrXrrrrrrrzr:rrRrrgrs rOhandle_my_tradeszkraken.handle_my_tradesFsvNOOGQ3 i. Q }}$))$,, tL *5 1 ]]FG1c)n- +Ar:6;;=)q#c(++AQB"2JE!00dBZ1OPFMM&)#H-F&*GFO + +D NN4==$ / 'D1c$i( ;"Sj472 t}}k: ;' rPc|j|d}|j|jd||}d}|j|d}|j|dd}|j |d}|j|d}|j|d} |j |d } |j |d } d} d} d |vrd}||d }|j |d |d } ||d}| | | | z} |||||j ||| |d| | | | d S)Nrr ordertxidrzpostxidtimerS ordertyperVvolfeerm)r_currencyrR) rzrrrrrRrSr takerOrMakerrVrUr_r)r~rrH safe_string_2safe_timestampr r0)rMr:r[rrRorderIdrzrrrSrVrUr_rrs rOrzkraken.parse_ws_tradesRB!!%0.?!@&&Q""5+6   tY 7''v6 v.{3w/. E>H!!'?u5$C  H%F  !v~" Y/   rPcHK|jd||||d{S7w)a/ https://docs.kraken.com/api/docs/websocket-v1/openorders 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 orde structures to retrieve :param dict [params]: maximum number of orderic to the exchange API endpoint :returns dict[]: a list of `order structures ` openOrdersNrr6s rO watch_orderszkraken.watch_orderss''' feUFSSSSr8c|j|dg}t|}|dkDr.|j|jdd}|jt ||_|j}i}t dt|D]U} |j|| i} t| j} t dt| D] } | | } | | }|j|}| |d<d}|j|jdi}|d|d}||| <||jd<n|j|| }|j|j|}|j|| }|}|.|j|d|d}|j|}| |d<t|}||k(r||d}|d|vr||d=|j|d||<Xd }|j|j|t|j}t dt|D])} |d z|| z}|j|j|+yy) NrrBr>rzrCrRrTrr)rrrrHordersrrrfrgparse_ws_orderr~hashmaprrr)rMrrr allOrdersallOrdersLengthrXrrrrrrrzrrrRrCpreviousOrders previousOrdernewOrder newRawOrderrr=rrgrs rO handle_orderszkraken.handle_orderssa\OOGQ3 i. Q %%dllM4HE{{"4U; [[FG1c)n- +Ar:6;;=)q#c(++AQB"2JE!007F#%F4L!F'+t||EWY['\$h'3!'!1/5(,;K %78!%!1!12BB!G%)__V^^V%LN$(OONB$GM%H$0&*kk-2GRXIY&Z #'#6#6{#C)+ [FM,A &q  ;*:: 0t =MM(+&*GFO5+ +< D NN4;; - 'D1c$i( 9"Sj472 t{{K8 9O rPc F|j|di}|j|d}d}d}d}d}d} |k|jd} |j| d}|j| d} |j| d}|j| d}|j| d}|j|d |}|j|d |}|j|d |}|j|jd ||}d} |j |d } |j|d| } |j|d} d}|j|d}|j|d|}|t j |dr|j|d}|t j |dr|j|d|}|j|dd}|^|d} d|vrU|d}|j|d}|dd}|jddk\r |d|d<n|jddk\r|d|d<|j|j|d}|j|d}|$|j|d }|j|d}|j|d!}|j|d"}d}||j||ddd|i}|j|d#}|jid|d$|d%|d&| d'|j| d(dd|d| d |d)dd*dd+|d|d,|d-|d|d.| | |d||d/S)0NdescrrrbrrrrrrSrrropentmrvol_execr_rVz0.0price2 avg_pricerRroflags)r_ratefciqrmrfcibbasestatusrztxiduserrefr stoppricer]rrrlastTradeTimestamprprr stopPricercrU)filledr remainingrr)rr~rcrHrr# string_eqrfindparse_order_statusr safe_number safe_orderr0)rMrr[ descriptionorderDescriptionrrSrrVrUrrrRrrrr_rflagsfeeCostrrzrr] rawTradesrrs rOrzkraken.parse_ws_orderYs@ooeWb9 ++KA  '$**3/E##E1-D%%eQ/F%%eQ/F##E1-D$$UA.E VT: [$?!!+vv>.?!@&&Q''x8 !!%7!!%4v.  gu= Mw00>$$[(;E Mw00>$$UGU;E$$UKA  H%F~h**5%8# ::f%*&,WoC OZZ'1,&,VnC O(()9)9%)JK   eT * :??5&1D!!$*B(( : OOE84   &&y&$wPRmTF$$UK8  " ]  E     Y/  !$   f  f  D  4    D  U    I D! " f# $-   rP unifiedName channelNamec lK|jd{|j|dddd}g}tdt|D]6}|j |j |d|j ||8|j|}g} tdt|D]+}|j||dd} | j | -d|j| d|id} |jd d d } |j| ||j| |||d{S77w) NFTrrrrrrr9r(r:) rrrrrrrRmarkets_for_symbolsr~rrGwatch_multiplerJ) rMrrrsubscriptionArgsrY messageHashesrrT wsMarketIds wsMarketIdrTrs rOr zkraken.watch_multi_helpersV!!!%%gtUD%H q#g,' dA  !6!6{D$++V]^_V`Ja!b c d**73 q#g,' +A))'!*V*` Nbalancesr9r(r<r)channelr)rQrrY)rrrGrrJr)rMrYrrrrrrTs rO watch_balancezkraken.watch_balances!!!'')) iit$[1OO% !% ""9f5ZZ[';GGG ")Hs2BBBBAB B BBBc2|j|dg}d|i}tdt|D]W}|j||d}|j |}|j }|j||d} | |d<|||<Yd} |j |} |j|j| i} |j| | } |j | |j| <|j|d}|j|j| |y) Nr1rrassetbalancetotalspotr) r/rrr~safe_currency_codeaccount safe_balancerrrJr)rMrrr1rr currencyIdcodereqrSr oldBalance newBalancers rOhandle_balancezkraken.handle_balances,~~gvr2(q#d)$ #A))$q'7;J**:6DllnG!!$q'95B!GG "F4L  ###F+__T\\4< %%j': !..z: T""7I6t||D)73rPunifiedElementNamesubChannelNamecF|du}|}|s|dz }n|d|zz }||d|zz }|S)Ns@#r)rMrrrR withSymbolrs rOrzkraken.get_message_hash sI4' (  3 K 3< 'K  % 3/ /KrPcL|j|d}|||j|<yy)N channelID)r~rn)rMrr channelIds rOhandle_subscription_statusz!kraken.handle_subscription_status-s10$$Wk:  .5F  + !rPc|j|dd}|g|j|dd}|R|jdd}|j||}d}| t |}n |||}|j ||yy) N errorMessagerrrr(rEFT)rrrIfind_broadly_matched_keyrro)rMrrr rrEbroadKey exceptions rOhandle_error_messagezkraken.handle_error_messageMs())'>7K  #))'7HEI$-g688 M # -l ;I /h =I i3rPct|tr|j|d}|j|j|i}|j|di}t |}|j||dz }|j|d}|j |j|j|j|j|j|jd} |j| ||} | | |||yy|j|d} | +d|ji} |j| | } | | |||j||r|j!|dd } |j"|j$|j&|j(|j(|j*|j,d } |j| | } | | ||yyy) Nrrrr)rHrLrr'r:rrrrrrQ)rW systemStatussubscriptionStatusrrrr) isinstancerfr~rrnrrrrr-rrrrrrrrZrr rrr) rMrrr rrrprrmethodsrQrrs rOhandle_messagezkraken.handle_messageps gt $((!4I??6+?+?BOL??<DDLM**7MA4EFK##D&1D..)),,--++"00!22 G&&wkBF!vw 5"&&w :G" 3 3!':%67+((9**7GXF!%!6!6$($=$=*.*I*I!%!>!>#'#@#@$($<$<"&"?"?!%8%67+&:rPr)NN)F__name__ __module__ __qualname__rrLstrdictr rr r rr rrrrrrrrrrrrrrrrrrrrrr)r-r+rrr7r5r rAr@rfrOrrXrZrrjrhrrrrrrrrrr rrrrr rr __classcell__)rNs@rOr%r%sc #c Jnrz|w!sw!Cw!sw!Tw![^w!gjw!rpt|~ ]C ]y ] ][` ]il ]DI ]D+@im{IK]c]3]i]y]be]ux]PU]@DHPR]$s)]S]8<@]]S]u]8' 8;v>;@H T04$UYbd T TC Ts Timnsit Ty9Fy9vm ^_cuyCEACAcAT[A0*,HH2%4V%4N 3  \_ 66@!6!F,,V,,rPr%)+ccxt.async_supportccxt ccxt.async_support.base.ws.cacherrrccxt.base.typesrrrr r r r r rrrrr!ccxt.async_support.base.ws.clientrtypingrccxt.base.errorsrrrrrrrrrrrr r!r"ccxt.base.preciser# async_supportr%rrPrOr&su ffBBBB4*0--.'&.)*).1*%@,T   & &@,rP