iOddlZddlmZmZmZddlZddlmZm Z m Z m Z m Z m Z mZmZmZmZmZddlmZddlmZddlmZddlmZddlmZGd d ejjZdS) N) ArrayCacheArrayCacheBySymbolByIdArrayCacheByTimestamp) BalancesIntNumOrder OrderBook OrderSide OrderTypeStrTickerTrade TradingFees)Client)List) ExchangeError)AuthenticationError)ArgumentsRequiredcFeZdZfdZifdZifdedefdZdefdZ ddifded e d e de e fd Z defd Zd ddifded e d e de efdZdefdZdefdZdifded e defdZdZdZdefdZdefdZdZdefdZdefdZdefdZdddifded e d e de efdZdddifded e d e de e fdZ difdede!de"de#de$def d Z%ddifd!edede!de"de$de$defd"Z&difd!edefd#Z'difdefd$Z(defd%Z)difd!ededefd&Z*dddifded e d e de efd'Z+d(Z,dddifded e d e de efd)Z-dddifded e d e de e fd*Z.defd+Z/difd,efd-Z0defd.Z1dddifd,ed e d e fd/Z2defd0Z3d ddifded e d e de efd1Z4dddifd,ed e d e fd2Z5defd3Z6ifde7fd4Z8ifd5Z9ifd6Z:defd7Z;d8Zdefd:Z?defd;Z@defd<ZAifd=ZBd>ZCifd?ZDifd@ZEdefdAZFdefdBZGdefdCZHifdDZIdefdEZJdefdFZKdefdGZLxZMS)Hbitvavoc ^|tt|iddddddddddddd dd dd dd dd dddddddddddddiddddddddddddddddddddddddd dd!dd"dd#dd$dd%iidd&d&d&d'd(S))NwsTcancelOrdersWsF fetchTradesWswatchOrderBook watchTrades watchTicker watchOHLCV watchOrders watchMyTradescancelAllOrdersWs cancelOrderWs createOrderWscreateStopLimitOrderWscreateStopMarketOrderWscreateStopOrderWs editOrderWsfetchBalanceWsfetchCurrenciesWSfetchDepositAddressWsfetchDepositsWsfetchDepositWithdrawFeesWsfetchMyTradesWs fetchOHLCVWsfetchOpenOrdersWs fetchOrderWsfetchOrderBookWs fetchOrdersWs fetchTickerWsfetchTickersWs fetchTimeWsfetchTradingFeesWsfetchWithdrawalsWs withdrawWsapizwss://ws.bitvavo.com/v2)supressMultipleWsRequestsError tradesLimit ordersLimit OHLCVLimit)hasurlsoptions) deep_extendsuperrdescribe)self __class__s V/var/www/html/crypto-bot/backend/venv/lib/python3.11/site-packages/ccxt/pro/bitvavo.pyrEzbitvavo.describes gt 4 4 = = ? ?"d" %" "!$ " t " t "d"t" "$T" " ")$"*4"$T" t!""!$#""$$T%"&('"("4)"*-d+","4-"./"0$T1"23"4#D5"6 7"8 9":!$;"<t=">%d?"@%dA"BdC""H3 38##" S/B /B / / / c.K|d{V||}|dz|dz}|jdd}d||dgdgd}|||}|||||d{VS)N@idr:r subscribenamemarketsactionchannels) load_marketsmarketrAextendwatch) rFrOsymbolparamsrU messageHashurlrequestmessages rH watch_publiczbitvavo.watch_publicEs!!!!!!!!!V$$Sj6$</ it$!!t     ++gv..ZZ[';GGGGGGGGGrIrXreturnc@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 ` ticker24hN)r^)rFrXrYs rH watch_tickerzbitvavo.watch_tickerXs2&&{FFCCCCCCCCCrIclientc||d}||dg}tdt|D]}}||}||d}||dd}|dz|z} |||} | d} | |j| <|| | ~|S)NeventdatarrU-rKrX) safe_string safe_valuerangelen safe_market parse_tickertickersresolve) rFrcr]rernirfmarketIdrUrZtickerrXs rH handle_tickerzbitvavo.handle_tickeras,  '22//'6266q#g,,'' 0 0A1:D''h77H%%hc::F#+0K&&tV44FH%F#)DL NN6; / / / /rINsincelimitc K|d{V||}|d||d{V}|jr|||}||||ddS)a get the list of most recent trades for a particular symbol :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 ` Ntrades timestampT)rTrXr^ newUpdatesgetLimitfilter_by_since_limit)rFrXrtrurYrws rH watch_tradeszbitvavo.watch_tradess!!!!!!!!!V$$((66BBBBBBBB ? 3OOFE22E))&% TRRRrIc||d}||dd}|d}d}|dz|z}|||}||j|} | +||jdd} t| } | || |j|<| | |dS)NrUrgrXrwrKr=r;) rhrl parse_traderirw safe_integerrBrappendro) rFrcr]rqrUrXrOrZtrade tradesArrayrus rH handle_tradezbitvavo.handle_trades##GX66!!(D#66!Sj8+   &11oodk6::  %%dlM4HHE$U++K5!!!) F{K00000rI1mcK|d{V||}|d}d}|d}||j||} |dz|zdz| z} |jdd} d d| g|gd gd } || |} || | | | 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 NrXcandlesrLrK_r:rrM)rOintervalrPrQrT) rTrUrh timeframesrArVrWryrzr{)rFrX timeframertrurYrUrOrqrrZr[r\r]ohlcvs rH watch_ohlcvzbitvavo.watch_ohlcvs;!!!!!!!!!V$$!$<##DOY JJSj8+c1H< it$!&!) (z   ++gv..jjk7KHHHHHHHH ? 2NN6511E))%q$GGGrIc||d}||d}||ddd}||}|||dSNrRresponse)rhri parse_ohlcvsbuild_message_hashro)rFrcr]rRrrrZs rHhandle_fetch_ohlcvzbitvavo.handle_fetch_ohlcvsr!!'844??7J77!!(D$==--f55 uk*****rIcd}||d}||dd}|d}||d}||}|dz|zdz|z} ||d} ||j|i|j|<||j||} | ;||jd d } t| } | |j||<td t| D]5} | | }| ||}| |6| | | dS) NrrUrgrXrrKrcandler?r;r) rhrlfind_timeframeriohlcvsrrBrrjrk parse_ohlcvrro)rFrcr]rOrqrUrXrrrZrstoredrurprparseds rH handle_ohlcvzbitvavo.handle_ohlcvsr$##GX66!!(D#66!##GZ88''11 Sj8+c1H< //'844"oodk62FF FV!4i@@ >%%dlL$GGE*511F-3DK  *q#g,,'' " "AQZF%%ff55F MM& ! ! ! !v{+++++rIcK|d{V||}|d}d}|dz|dz}|jdd}d||dgd gd }||||d|j||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 NrXbookrKrLr:rrMrNrQ)rZrOrXrqmethodrurY)rTrUrAhandle_order_book_subscriptionrVrWru) rFrXrurYrUrOrZr[r\ subscriptionr] orderbooks rHwatch_order_bookzbitvavo.watch_order_books!!!!!!!!!V$$!Sj6$</ it$!!t     't 9  ++gv..**S+w \ZZZZZZZZ    rIc||d}||d}|||dS)Nr) safe_floatstore)rFbooksidedeltapriceamounts rH handle_deltazbitvavo.handle_delta-sBq))**uf%%%%%rIc~tdt|D]}||||dS)Nr)rjrkr)rFrdeltasrps rH handle_deltaszbitvavo.handle_deltas2sHq#f++&& 3 3A   hq 2 2 2 2 3 3rIc||d}||dkrg||d||dg||d||dg||d<|S)Nnonceasksbids)rrri)rFrcr]rrs rHhandle_order_book_messagez!bitvavo.handle_order_book_message6s!!'733 9W% % %   y0$//'6SU2V2V W W W   y0$//'6SU2V2V W W W!&Ig rIc||d}||d}||dd}|d}|dz|dz}||j|}|dS|d||j|i} || d} | ed | d<| |j|<||jd i} || d |j} || |j ||| |j |dS| |||| ||dS) NrerUrgrXrKrLrwatchingOrderBookSnapshotTwatchOrderBookSnapshotdelay)rhrlri orderbooks subscriptionsrBr rateLimitrwatch_order_book_snapshotcacherrro) rFrcr]rerqrUrXrZrrrrBrs rHhandle_order_bookzbitvavo.handle_order_bookKsu  '22##GX66!!(D#66!ckF4L0 OODOV<<   F W  %??6+?bQQL(, Fa(b(b %(0<@ 894@$[1//$,8PRTUU))'7DNKK 5$"@&'S_``` O " "7 + + + + +  * *67I F F F NN9k 2 2 2 2 2rIc0K||d}||d}d}|dz|z}|jdd}||d} ||||| |||d{V} | S)NrYrqgetBookrKr:r)rRrU)rirhrArWrVru) rFrcr]rrYrqrOrZr[r\rs rHrz!bitvavo.watch_order_book_snapshotpsx88##L*==Sj8+ it$  **S+t{{7F7S7SU`bnoooooooo    rIc||d}|dS||d}||dd}d}|dz|z}|j|}|||} ||d| d<|| |j} tdt| D]!} | | } | || |"||j|<| ||dS)NrrUrgrrKrr) rirh safe_symbolrparse_order_bookrresetrrjrkrro) rFrcr]rrqrXrOrZrsnapshotmessagesrp messageItems rHhandle_order_book_snapshotz"bitvavo.handle_order_book_snapshot}s (??7J77   F##Hh77!!(D#66Sj8+ OF+ ((6:: --h@@!!!?q#h--(( K KA"1+K  * *6; J J J J"+y+.....rIc||d}||d}||jvr|j|=|i||j|<dS)NrXru)rhrr order_book)rFrcr]rrXrus rHrz&bitvavo.handle_order_book_subscriptionsc!!,99!!,88 T_ $ $'"&//"e"<"<rIcFd}tdt|D]}|||}||dd}|dz|z}||jvr@||j|} || d} | | ||| dS)NrrrgrKr)rjrkrhrrrir) rFrcr] marketIdsrOrprqrXrZrrs rHhandle_order_book_subscriptionsz'bitvavo.handle_order_book_subscriptionssq#i..)) : :A'' 155H%%hc::F*x/Kdo--#v/C[QQ x@@%F67L999 : :rIcK|t|jdz|d{V|d{V||}|d}|d}|jdd}d}d|z} d ||gd gd } ||| | | d{V} |jr| ||}| | |||d S) 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 ` Nz) watchOrders() requires a symbol argumentrXrLr:raccountorder:rMrNrQT rrLrT authenticaterUrArWryrzfilter_by_symbol_since_limit) rFrXrtrurYrUrqr[rOrZr\orderss rH watch_orderszbitvavo.watch_orderss; >#DG.Y$YZZ Z!!!!!!!!!!!!!!!!!!V$$!$<it$' !! (z  zz#{G[IIIIIIII ? 3OOFE22E00tTTTrIcK|t|jdz|d{V|d{V||}|d}|d}|jdd}d}d|z} d ||gd gd } ||| | | d{V} |jr| ||}| | |||d S) 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]{@link https://docs.ccxt.com/#/?id=ortradeder-structure Nz+ watchMyTrades() requires a symbol argumentrXrLr:rr myTrades:rMrNrQTr) rFrXrtrurYrUrqr[rOrZr\rws rHwatch_my_tradeszbitvavo.watch_my_tradess; >#DG.[$[\\ \!!!!!!!!!!!!!!!!!!V$$!$<it$!F* !! (z  zz#{G[IIIIIIII ? 3OOFE22E00tTTTrItypesiderrcK|d{V|d{V|||||||}|d|d{VS)aI create a trade order :see: https://docs.bitvavo.com/#tag/Orders/paths/~1order/post :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 currency you want to trade in units of base currency :param float price: the price at which the order is to be fullfilled, in units of the quote currency, ignored in market orders :param dict [params]: extra parameters specific to the bitvavo api endpoint :param str [params.timeInForce]: "GTC", "IOC", or "PO" :param float [params.stopPrice]: The price at which a trigger order is triggered at :param float [params.triggerPrice]: The price at which a trigger order is triggered at :param bool [params.postOnly]: If True, the order will only be posted to the order book and not executed immediately :param float [params.stopLossPrice]: The price at which a stop loss order is triggered at :param float [params.takeProfitPrice]: The price at which a take profit order is triggered at :param str [params.triggerType]: "price" :param str [params.triggerReference]: "lastTrade", "bestBid", "bestAsk", "midPrice" Only for stop orders: Use self to determine which parameter will trigger the order :param str [params.selfTradePrevention]: "decrementAndCancel", "cancelOldest", "cancelNewest", "cancelBoth" :param bool [params.disableMarketProtection]: don't cancel if the next fill price is 10% worse than the best fill price :param bool [params.responseRequired]: Set self to 'false' when only an acknowledgement of success or failure is required, self is faster. :returns dict: an `order structure ` NprivateCreateOrder)rTrcreate_order_request watch_request)rFrXrrrrrYr\s rHcreate_order_wszbitvavo.create_order_wss.!!!!!!!!!!!!!!!!!!++FD$vVV''(` NprivateUpdateOrder)rTredit_order_requestr) rFrLrXrrrrrYr\s rH edit_order_wszbitvavo.edit_order_wss!!!!!!!!!!!!!!!!!!))"fdD&%QWXX''(` NprivateCancelOrder)rTrcancelOrderRequestr)rFrLrXrYr\s rHcancel_order_wszbitvavo.cancel_order_ws's!!!!!!!!!!!!!!!!!!))"ff==''(` NrLrUprivateCancelOrders)rTrrUrrV)rFrXrYr\rUs rHcancel_all_orders_wszbitvavo.cancel_all_orders_ws5s!!!!!!!!!!!!!!!!!!  [[((F &t GH ''(=t{{7TZ?[?[\\\\\\\\\rIc||d}||d}||di}||d}||}||d|i}||||||}|||dSNrRrrrU)rhri parse_ordersrro) rFrcr]rRr firstRawOrderrqrrZs rHhandle_multiple_orderszbitvavo.handle_multiple_ordersFs!!'844??7J77!R88 ##M8<<""8,,--fx6JKK v{+++--fg>> v{+++++rIc@K|t|jdz|d{V|d{V||}||dd}|d|||d{VS)a :see: https://docs.bitvavo.com/#tag/General/paths/~1assets/get fetches information on an order made by the user :param str symbol: unified symbol of the market the order was made in :param dict [params]: extra parameters specific to the bitvavo api endpoint :returns dict: An `order structure ` Nz( fetchOrder() requires a symbol argumentrL)orderIdrUprivateGetOrder)rrLrTrrUrrV)rFrLrXrYrUr\s rHfetch_order_wszbitvavo.fetch_order_wsYs >#DG.X$XYY Y!!!!!!!!!!!!!!!!!!V$$Tl  ''(94;;wPV;W;WXXXXXXXXXrIc8K|t|jdz|d{V|d{V|||||}|d|d{V}|||||S)a2 :see: https://docs.bitvavo.com/#tag/Orders/paths/~1orders/get fetches 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]: extra parameters specific to the bitvavo api endpoint :returns Order[]: a list of `order structures ` Nz+ fetchOrdersWs() requires a symbol argumentprivateGetOrders)rrLrTrfetchOrdersRequestrr)rFrXrtrurYr\rs rHfetch_orders_wszbitvavo.fetch_orders_wsls >#DG.[$[\\ \!!!!!!!!!!!!!!!!!!))&%GG))*>  ..{;;;it$ZZ[';GGGGGGGGGrIcJK|d{V|d{Vi}d}| ||}|d|d<|d|||d{V}|||||S)a fetch all unfilled currently open orders :param str symbol: unified market symbol :param int [since]: the earliest time in ms to fetch open orders for :param int [limit]: the maximum number of open orders structures to retrieve :param dict [params]: extra parameters specific to the bitvavo api endpoint :returns Order[]: a list of `order structures ` NrLrUprivateGetOrdersOpen)rTrrUrrVr)rFrXrtrurYr\rUrs rHfetch_open_orders_wszbitvavo.fetch_open_orders_wss!!!!!!!!!!!!!!!!!!   [[((F &t GH ))*@$++gW]B^B^________00NNNrIc8K|t|jdz|d{V|d{V|||||}|d|d{V}|||||S)a :see: https://docs.bitvavo.com/#tag/Trades fetch all trades made by the user :param str symbol: unified market symbol :param int [since]: the earliest time in ms to fetch trades for :param int [limit]: the maximum number of trades structures to retrieve :param dict [params]: extra parameters specific to the bitvavo api endpoint :returns Trade[]: a list of `trade structures ` Nz- fetchMyTradesWs() requires a symbol argumentprivateGetTrades)rrLrTrfetchMyTradesRequestrr)rFrXrtrurYr\myTradess rHfetch_my_trades_wszbitvavo.fetch_my_trades_wss >#DG.]$]^^ ^!!!!!!!!!!!!!!!!!!++FE5&II++,>HHHHHHHH0065%PPPrIcD||d}||d}||di}||d}||ddd}||d|i}|||dSr)rhri parse_tradesrro) rFrcr]rRr firstRawTraderqrwrZs rHhandle_my_tradeszbitvavo.handle_my_tradess,!!'844??7J77!R88 ##M8<<""8T4>>--fx6JKK v{+++++rIcodec4K|||\}}|||d{V|d{V||||||}|d|d{VS)a make a withdrawal :param str code: unified currency code :param float amount: the amount to withdraw :param str address: the address to withdraw to :param str tag: :param dict [params]: extra parameters specific to the bitvavo api endpoint :returns dict: a `transaction structure ` NprivateWithdrawAssets)handle_withdraw_tag_and_params check_addressrTrwithdrawRequestr)rFrraddresstagrYr\s rH withdraw_wszbitvavo.withdraw_wss99#vFF V 7###!!!!!!!!!!!!!!!!!!&&tVWc6JJ''(?IIIIIIIIIrIc||d}|||}||d}||}|||dSr)rhrriparse_transactionro)rFrcr]rRrZrwithdraws rHhandle_withdrawzbitvavo.handle_withdrawsn!!'844--fg>> ??7J77))(33x-----rIcK|d{V|d{V|||||}|d|d{V}|||||S)a# :see: https://docs.bitvavo.com/#tag/Account/paths/~1withdrawalHistory/get fetch all withdrawals made from an account :param str code: unified currency code :param int [since]: the earliest time in ms to fetch withdrawals for :param int [limit]: the maximum number of withdrawals structures to retrieve :param dict [params]: extra parameters specific to the bitvavo api endpoint :returns dict[]: a list of `transaction structures ` NprivateGetWithdrawalHistory)rTrfetchWithdrawalsRequestrfilter_by_currency_since_limit)rFrrtrurYr\ withdrawss rHfetch_withdrawals_wszbitvavo.fetch_withdrawals_wss!!!!!!!!!!!!!!!!!!..tUE6JJ,,-JGTTTTTTTT 229dE5QQQrIc||d}|||}||d}||dddddi}|||dS)NrRrr withdrawalrhrriparse_transactionsro)rFrcr]rRrZr withdrawalss rHhandle_withdrawszbitvavo.handle_withdrawss| !!'844--fg>> ??7J77--hdD6S_J`aa {K00000rIcK|d{V||||||}d}|||d{V}||||ddS)a :see: https://docs.bitvavo.com/#tag/Market-Data/paths/~1{market}~1candles/get fetches 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 bitvavo api endpoint :returns int[][]: A list of candles ordered, open, high, low, close, volume N getCandlesrT)rTfetchOHLCVRequestrr{) rFrXrrtrurYr\rRrs rHfetch_ohlcv_wszbitvavo.fetch_ohlcv_wss!!!!!!!!!((E5&QQ((99999999))%q$GGGrIcK|d{V|d{V|||||}|d|d{V}|||||S)a :see: https://docs.bitvavo.com/#tag/Account/paths/~1depositHistory/get fetch all deposits made to an account :param str code: unified currency code :param int [since]: the earliest time in ms to fetch deposits for :param int [limit]: the maximum number of deposits structures to retrieve :param dict [params]: extra parameters specific to the bitvavo api endpoint :returns dict[]: a list of `transaction structures ` NprivateGetDepositHistory)rTrfetchDepositsRequestrr)rFrrtrurYr\depositss rHfetch_deposits_wszbitvavo.fetch_deposits_ws#s!!!!!!!!!!!!!!!!!!++D%GG++,FPPPPPPPP228T5%PPPrIc||d}|||}||d}||dddddi}|||dS)NrRrrdepositr)rFrcr]rRrZrr$s rHhandle_depositszbitvavo.handle_deposits3s| !!'844--fg>> ??7J77**8T4PYGZ[[x-----rIcK|d{V|d{V|d|d{VS)aW :see: https://docs.bitvavo.com/#tag/Account/paths/~1account/get fetch the trading fees for multiple markets :param dict [params]: extra parameters specific to the bitvavo api endpoint :returns dict: a dictionary of `fee structures ` indexed by market symbols NprivateGetAccountrTrrrFrYs rHfetch_trading_fees_wszbitvavo.fetch_trading_fees_wsIy!!!!!!!!!!!!!!!!!!''(;VDDDDDDDDDrIc>K|d|d{VS)a :see: https://docs.bitvavo.com/#tag/General/paths/~1markets/get retrieves data on all markets for bitvavo :param dict [params]: extra parameters specific to the exchange api endpoint :returns dict[]: an array of objects representing market data getMarketsN)rr,s rHfetch_markets_wszbitvavo.fetch_markets_wsTs0'' f=========rIcrK|d{V|d|d{VS)a :see: https://docs.bitvavo.com/#tag/General/paths/~1assets/get fetches all available currencies on an exchange :param dict [params]: extra parameters specific to the bitvavo api endpoint :returns dict: an associative dictionary of currencies N getAssets)rTrr,s rHfetch_currencies_wszbitvavo.fetch_currencies_ws]sT!!!!!!!!!'' V<<<<<<<<> ??7J77))(33 z;/////rIc||d}|||}||d}||}|||dSr)rhrriparse_trading_feesro)rFrcr]rRrZrfeess rHhandle_trading_feeszbitvavo.handle_trading_feessn!!'844--fg>> ??7J77&&x00t[)))))rIcK|d{V|d{V|d|d{VS)ay :see: https://docs.bitvavo.com/#tag/Account/paths/~1balance/get query for balance and get the amount of funds available for trading or funds locked in orders :param dict [params]: extra parameters specific to the bitvavo api endpoint :returns dict: a `balance structure ` NprivateGetBalancer+r,s rHfetch_balance_wszbitvavo.fetch_balance_wsr.rIc||dd}|||}||dg}||}|||dS)NrRr>r)rhrri parse_balancero)rFrcr]rRrZrbalances rHhandle_fetch_balancezbitvavo.handle_fetch_balancess!!'85HII--fg>> ??7J;;$$X..w ,,,,,rIc||d}||di}||}|||}|||dSr)rhri parse_orderrro)rFrcr]rRrorderrZs rHhandle_single_orderzbitvavo.handle_single_ordersp:!!'844??7J;;  **--fh?? uk*****rIc||d}||di}||}|||}|||dSr)rhri parse_marketsrro)rFrcr]rRrrPrZs rHhandle_marketszbitvavo.handle_marketssp(!!'844??7J;;$$X..--fh?? w ,,,,,rIc|j|j|j|j|jd}|||}|}| |||}|S)N)rrrrr)action_and_market_message_hash action_and_order_id_message_hashri)rFrRrYmethodsrrZs rHrzbitvavo.build_message_hashsc"&"E"&"G"&"G#D $ C   &11   &00KrIc||jdd}|sh||j|jdd}|<||j|}|!t |jdz|zdzdSdSdS)Nr<Fr:rz$ a similar request with messageHash z is already pending, you must wait for a response, or turn off self error by setting supressMultipleWsRequestsError in the options to True) safe_boolrBriclientsrAfuturesrrL)rFrZr<rcfutures rHrz)bitvavo.check_message_hash_does_not_exists)- Ffhm)n)n&- w__T\49U3CD3IJJF!EE%'2X(X[f(fjv)vwww  w w!!%%rIc:||dd}||zS)NrU)rh)rFrRrYrXs rHrLz&bitvavo.action_and_market_message_hashs#!!&(B77rIcj||d}|t|jdz||zS)Nrz; privateUpdateOrderMessageHash requires a orderId parameter)rhrrL)rFrRrYrs rHrMz(bitvavo.action_and_order_id_message_hash s=""6955 ?*g ghh hrIc||d}||dd}|d}d|z}|||}|j0||jdd}t ||_|j} | |||j|dS)NrUrgrXrr>r;) rhrlrErrrBrrro) rFrcr]rqrUrXrZrFrurs rH handle_orderzbitvavo.handle_orders,##GX66!!(D#66!'   &11 ; %%dlM4HHE077DK et{K00000rIcx||d}||dd}|d}d|z}|||}|j0||jdd}t ||_|j} | ||| |dS)NrUrgrXrr=r;) rhrlr~rrrBrrro) rFrcr]rqrUrXrZrrurs rHhandle_my_tradezbitvavo.handle_my_trade3s ##GX66!!(D#66!!F*   &11 = %%dlM4HHE&u--DMm 5!!!{K00000rIcN||di}d|ji}t|}t dt |D]E}||}|||}|#|||} |||| F|S)Nrrr)rirlistkeysrjrk) rFrcr]rrNnamesrprOrrs rHhandle_subscription_statusz"bitvavo.handle_subscription_statusOs"EE D8 ]''))**q#e**%% 6 6A8D__Wd33F!#}dCC vw 555rIc.K|jdd}||}d}||j|}||}t |}|dz|jzdz}|||||j tj } d} | |j | |d} | | |} |||| |d{V}||j|<|S)Nr:r authenticatedzGET/z /websocketr)rRkey signaturerx)rArcrir millisecondsstrversionhmacencodesecrethashlibsha256apiKeyrVrW) rFrYr[rcrZrSrxstringTimestampauthrcrRr\r]s rHrzbitvavo.authenticateesit$S!!% !5{CC >))++I!)nnO"V+dl:\ID $++d"3"3T[[5M5Mw~^^I#F {&& G kk'622G::c;MMMMMMMMF06F  - rIcd}||dd}|r|||dSt||}|||||jvr |j|=dSdS)NraF)rProrjsonrejectr)rFrcr]rZraerrors rHhandle_authentication_messagez%bitvavo.handle_authentication_message{s& wGG  6 NN7K 0 0 0 0 0' '(:(:;;E MM% - - -f222(55532rIc ||d}||d}||d}|||}d} ||||jdd||dd n/#t $r"}d}|||Yd}~nd}~wwxYw|s|||dSdS)Nrr errorCoderRFT)rhrr handle_errorsr[ Exceptionrq) rFrcr]rrrrRrZrejectedes rHhandle_error_messagezbitvavo.handle_error_messages  '22   44!!'844--fg>>  *   tUFJdE7TXZ^ _ _ _ _ * * *H MM![ ) ) ) ) ) ) ) ) * 0 MM'; / / / / / 0 0s"A?? B+ B&&B+c ||d}||||id|jd|jd|jd|jd|jd|jd|jd |j d |j d |j d |j d |j d|j d|j d|j d|j d|j |j|j|j|j|j|j|j|jd}||d}|||}|>||d}|||}||||dSdS|||dS)Nrr subscribedrrrrrarrFfillrrr>rrrrr)r*r"rrrr3rr0rerR)rhrzr_rrrrrsrsrXrZrGrCrr<r(rrrr8rrJri)rFrcr]rrrNrerrRs rHhandle_messagezbitvavo.handle_messagesX  '22    % %fg 6 6 6 $9 D*  t6  T&  d'  +   D>  T&  D(  !$":  !$":  !:  "4#>   ;  t7 !$":! " #D$?# $"&!9(,(<+/+@%)%9 $ 551-3   6  '22%00 >%%gx88F__Wf55F!vw'''''"! F67 # # # # #rI)N__name__ __module__ __qualname__rEr^rerrbrrsrrrr|rr\rrrr rrrrrrrrrr r rrr r floatrrrrrrrrrrrrr rrrr r%r(rr-r1r4r8r<rr?rCrGrJrrrLrMrXrZr_rrsrzr~ __classcell__)rGs@rHrrsa 0 0 0 0 0 d79HHHH&68DDDFDDDD!F!!!!F<@d[]SSSSSSbfglbmSSSS 16111148<$]ajl H H HC HWZ Hquvzq{ H H H HD+++++ %,6%,%,%,%,N@DB$!$!S$!$!S\$!$!$!$!L&&& 333*#3#3#3#3#3J ! ! !%/%/%/%/%/N=V==== :f : : : :04$UYbdUUUCUsUimnsitUUUUB37TX\egUUCUsURUUlpqvlwUUUUBpt|~GGCGyG G[`GilGDIGGGG8im{IKGGcG3GiGyGbeGuxGPUGGGG$<@ G G GS G G G G8>>>02====0f00006***&-/ E E8 E E E E-6----&!+&!+!+!+!+F-V----413    www=??A    16 1 1 1 1D1f11118,)+,6F6666&060000,R$VR$R$R$R$R$R$R$R$rIr)ccxt.async_supportccxt ccxt.async_support.base.ws.cacherrrrjccxt.base.typesrrrr r r r r rrr!ccxt.async_support.base.ws.clientrtypingrccxt.base.errorsrrr async_supportrrIrHrs& ffffffffffwwwwwwwwwwwwwwwwwwwwwwwwww444444******000000......e$e$e$e$e$d (e$e$e$e$e$rI