ei'ddlZddlmZmZmZddlZddlmZm Z m Z m Z m Z m Z mZmZmZmZmZmZmZmZmZmZddlmZddlmZddlmZddlmZddlmZGd d ej j!Z!dS) N) ArrayCacheArrayCacheBySymbolByIdArrayCacheByTimestamp)AnyBalancesBool CurrenciesIntNumOrder OrderBook OrderSide OrderTypeStrStringsTickerTickersTrade TradingFees)Client)List) ExchangeError)AuthenticationError)ArgumentsRequiredceZdZdeffd ZifdZifdefdZifdedefdZ difd e de fd Z d e fd Zdifd e de fd Zd e fdZdRdZddifdedededeefdZd e fdZdddifdededededeef dZd e fdZd e fdZdifdededefdZdZdZd e fdZd e fdZ dZ!d e fdZ"d e fd Z#d e fd!Z$dddifde%dededee&fd"Z'dddifde%dededeefd#Z(difded$e)d%e*d&e+d'e,de&f d(Z-ddifd)eded$e)d%e*d&e,d'e,de&fd*Z.difd)ede%fd+Z/difde%fd,Z0d e fd-Z1difd)ede%de&fd.Z2dddifde%dededee&fd/Z3d0Z4d1Z5dddifde%dededee&fd2Z6dddifde%dededeefd3Z7d e fd4Z8difd5ed&e+d6ed7e%fd8Z9d e fd9Z:dddifd5e%dedefd:Z;d e fd;Zd e fd>Z?ifde@fd?ZAifd@ZBifdeCfdAZDd e fdBZEdCZFifdeGfdDZHd e fdEZId e fdFZJd e fdGZKifdHZLifdIZMifdJZNd e fdKZOd e fdLZPd e fdMZQifdNZRd e fdOZSd e deTfdPZUd e fdQZVxZWS)Sbitvavoreturnc l|tt|iddddddddddddd dd dd dd dd dddddddddddddiddddddddddddddddddddddddd dd!dd"dd#dd$dd%did&dd'iidd(d(d(d)d*S)+NwsTcancelOrdersWsF fetchTradesWswatchOrderBook watchTrades watchTicker watchTickers watchBidsAsks 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 N/var/www/html/volatility/venv/lib/python3.11/site-packages/ccxt/pro/bitvavo.pyrMzbitvavo.describes*gt 4 4 = = ? ?$d$ %$ $!$ $ t $ t $$ $d$t$ $$T$ $ $)$$ *4!$"$T#$$$t%$&!$'$($T)$*(+$,"4-$.-e/$0"41$23$4$T5$67$8#E9$: ;$< =$>!%?$@uA$B%dC$D%dE$$FdG$$L3 38##" W1B 1B 1 1 1 c.K|d{V||}|dz|dz}|jdd}d||dgdgd}|||}|||||d{VS)N@idrBr subscribenamemarketsactionchannels) load_marketsmarketrIextendwatch) rNrWsymbolparamsr] messageHashurlrequestmessages rP watch_publiczbitvavo.watch_publicGs!!!!!!!!!V$$Sj6$</ it$!!t     ++gv..ZZ[';GGGGGGGGGrQ channelNamecK|d{V||}|g}g}tdt|D]8}|||}||d9|jdd} d||dgd} || |} || || |d{VS)NrrTrBrrUrVrY) r\market_symbolsrangelenr]appendrIr^watch_multiple) rN methodNamergsymbolsra messageHashesargsir]rcrdres rPwatch_public_multiplezbitvavo.watch_public_multipleZs!!!!!!!!!%%g..# q#g,,'' & &A[[,,F KKt % % % %it$!(#  ++gv..((mWmTTTTTTTTTrQr`c@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 https://docs.bitvavo.com/#tag/Market-data-subscription-WebSocket/paths/~1subscribeTicker24h/post :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)rf)rNr`ras rP watch_tickerzbitvavo.watch_tickeros2&&{FFCCCCCCCCCrQNrocK|d{V||dd}d}|||||d{V}||d|S)a  watches a price ticker, a statistical calculation with the information calculated over the past 24 hours for all markets of a specific list https://docs.bitvavo.com/#tag/Market-data-subscription-WebSocket/paths/~1subscribeTicker24h/post :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 ` NFrur`r\rirsfilter_by_arrayrNrorachanneltickerss rP watch_tickerszbitvavo.watch_tickers{s!!!!!!!!!%%gtU;;227GWfUUUUUUUU##GXw???rQclientc|||||d}||dg}g}tdt |D]}||}||d}||dd} |dz|z} ||| } | d} | |j| <|| | | | | ||dS)Neventdatarr]-rSr`) handle_bid_ask safe_string safe_valuerjrk safe_market parse_tickerr|rlresolve) rNr~rerr|resultrrrmarketIdr]rbtickerr`s rP handle_tickerzbitvavo.handle_tickers, FG,,,  '22//'6266q#g,,'' 0 0A1:D''h77H%%hc::F#+0K&&tV44FH%F#)DL MM& ! ! ! NN6; / / / /vu%%%%%rQcK|d{V||dd}d}|d|||d{V}||d|S)a watches best bid & ask for symbols https://docs.bitvavo.com/#tag/Market-data-subscription-WebSocket/paths/~1subscribeTicker24h/post :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 ` NFrubidaskr`rxrzs rPwatch_bids_askszbitvavo.watch_bids_askss!!!!!!!!!%%gtU;;228WgvVVVVVVVV##GXw???rQcld}||dg}g}tdt|D]d}||}||}|d} ||j| <|||dz| z} ||| e|||dS)Nrrrr`:)rrjrkparse_ws_bid_askbidsasksrlr) rNr~rerr|rrrrrr`rbs rPrzbitvavo.handle_bid_asks//'6266q#g,,'' 0 0A1:D**400FH%F$*DM& ! MM& ! ! !#+.K NN6; / / / /vu%%%%%rQc ||d}||dd}||d}||d}|||||||d||d||d||d|d |S) Nr]rr` timestampaskaskSizebidbidSize)r`rdatetimer askVolumer bidVolumeinfo)rr safe_integer safe_tickeriso8601 safe_number)rNrr]rr`rs rPrzbitvavo.parse_ws_bid_asks##FH55!!(D#66!!&(33%%fk:: " Y//##FE22))&)<<##FE22))&)<< ! !     rQsincelimitc 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 ` NtradesrT)r\r`rf newUpdatesgetLimitfilter_by_since_limit)rNr`rrrars rP watch_tradeszbitvavo.watch_tradess!!!!!!!!!V$$((66BBBBBBBB ? 3OOFE22E))&% TRRRrQc||d}||dd}|d}d}|dz|z}|||}||j|} | +||jdd} t| } | || |j|<| | |dS)Nr]rr`rrSrErC) rr parse_traderrrrJrrlr) rNr~rerr]r`rWrbtrade tradesArrayrs rP handle_tradezbitvavo.handle_trades##GX66!!(D#66!Sj8+   &11oodk6::  %%dlM4HHE$U++K5!!!) F{K00000rQ1m timeframecK|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 Nr`candlesrTrS_rBrrU)rWintervalrXrYrT) r\r]r timeframesrIr^r_rrr)rNr`rrrrar]rWrrrbrcrdreohlcvs rP watch_ohlcvzbitvavo.watch_ohlcv s;!!!!!!!!!V$$!$<##DOY JJSj8+c1H< it$!&!) (z   ++gv..jjk7KHHHHHHHH ? 2NN6511E))%q$GGGrQc||d}||ddd}||d}|||dSNresponse requestId)r parse_ohlcvsrr)rNr~rerrrbs rPhandle_fetch_ohlcvzbitvavo.handle_fetch_ohlcv+s_??7J77!!(D$==&&w << uk*****rQcd}||d}||dd}|d}||d}||}|dz|zdz|z} ||d} ||j|i|j|<||j||} | ;||jd d } t| } | |j||<td t| D]5} | | }| ||}| |6| | | dS) Nrr]rr`rrSrcandlerGrCr) rrfind_timeframerohlcvsrrJrrjrk parse_ohlcvrlr)rNr~rerWrr]r`rrrbrstoredrrrrparseds rP handle_ohlcvzbitvavo.handle_ohlcv:sr$##GX66!!(D#66!##GZ88''11 Sj8+c1H< //'844"oodk62FF FV!4i@@ >%%dlL$GGE*511F-3DK  *q#g,,'' " "AQZF%%ff55F MM& ! ! ! !v{+++++rQcK|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 Nr`bookrSrTrBrrUrVrY)rbrWr`rmethodrra)r\r]rIhandle_order_book_subscriptionr^r_r) rNr`rrar]rWrbrcrd subscriptionre orderbooks rPwatch_order_bookzbitvavo.watch_order_bookas!!!!!!!!!V$$!Sj6$</ it$!!t     't 9  ++gv..**S+w \ZZZZZZZZ    rQc||d}||d}|||dS)Nr) safe_floatstore)rNbooksidedeltapriceamounts rP handle_deltazbitvavo.handle_deltasBq))**uf%%%%%rQc~tdt|D]}||||dS)Nr)rjrkr)rNrdeltasrrs rP handle_deltaszbitvavo.handle_deltassHq#f++&& 3 3A   hq 2 2 2 2 3 3rQc||d}||dkrg||d||dg||d||dg||d<|S)Nnonceasksbids)rrr)rNr~rerrs rPhandle_order_book_messagez!bitvavo.handle_order_book_messages!!'733 9W% % %   y0$//'6SU2V2V W W W   y0$//'6SU2V2V W W W!&Ig rQc||d}||d}||dd}|d}|dz|dz}||j|}|dS|d||j|i} || d} | ed | d<| |j|<||jd i} || d |j} || |j ||| |j |dS| |||| ||dS) Nrr]rr`rSrTrwatchingOrderBookSnapshotTwatchOrderBookSnapshotdelay)rrr orderbooks subscriptionsrJr rateLimitrwatch_order_book_snapshotcacherlrr) rNr~rerrr]r`rbrrrrJrs rPhandle_order_bookzbitvavo.handle_order_booksu  '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 2rQc0K||d}||d}d}|dz|z}|jdd}||d} ||||| |||d{V} | S)NrargetBookrSrBr)rZr])rrrIr_r^r) rNr~rerrarrWrbrcrdrs rPrz!bitvavo.watch_order_book_snapshotsx88##L*==Sj8+ it$  **S+t{{7F7S7SU`bnoooooooo    rQc||d}|dS||d}||dd}d}|dz|z}|j|}|||} ||d| d<|| |j} tdt| D]!} | | } | || |"||j|<| ||dS)Nrr]rrrSrr) rr safe_symbolrparse_order_bookrresetrrjrkrr) rNr~rerrr`rWrbrsnapshotmessagesrr messageItems rPhandle_order_book_snapshotz"bitvavo.handle_order_book_snapshots (??7J77   F##Hh77!!(D#66Sj8+ OF+ ((6:: --h@@!!!?q#h--(( K KA"1+K  * *6; J J J J"+y+.....rQc||d}||d}||jvr|j|=|i||j|<dS)Nr`r)rrr order_book)rNr~rerr`rs rPrz&bitvavo.handle_order_book_subscriptionsc!!,99!!,88 T_ $ $'"&//"e"<"<rQcFd}tdt|D]}|||}||dd}|dz|z}||jvr@||j|} || d} | | ||| dS)NrrrrSr)rjrkrrrrr) rNr~re marketIdsrWrrrr`rbrrs rPhandle_order_book_subscriptionsz'bitvavo.handle_order_book_subscriptionssq#i..)) : :A'' 155H%%hc::F*x/Kdo--#v/C[QQ x@@%F67L999 : :rQcK|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 argumentr`rTrBraccountorder:rUrVrYT rrTr\ authenticater]rIr_rrfilter_by_symbol_since_limit) rNr`rrrar]rrcrWrbrdorderss rP watch_orderszbitvavo.watch_orderss; >#DG.Y$YZZ Z!!!!!!!!!!!!!!!!!!V$$!$<it$' !! (z  zz#{G[IIIIIIII ? 3OOFE22E00tTTTrQcK|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 ` Nz+ watchMyTrades() requires a symbol argumentr`rTrBrr myTrades:rUrVrYTr) rNr`rrrar]rrcrWrbrdrs rPwatch_my_tradeszbitvavo.watch_my_trades2s; >#DG.[$[\\ \!!!!!!!!!!!!!!!!!!V$$!$<it$!F* !! (z  zz#{G[IIIIIIII ? 3OOFE22E00tTTTrQtypesiderrcK|d{V|d{V|||||||}|d|d{VS)aB create a trade order 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 fulfilled, 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)r\rcreate_order_request watch_request)rNr`rrrrrards rPcreate_order_wszbitvavo.create_order_wsSs2!!!!!!!!!!!!!!!!!!++FD$vVV''(` NprivateUpdateOrder)r\redit_order_requestr) rNrTr`rrrrrards rP edit_order_wszbitvavo.edit_order_wsqs!!!!!!!!!!!!!!!!!!))"fdD&%QWXX''(` NprivateCancelOrder)r\rcancel_order_requestr)rNrTr`rards rPcancel_order_wszbitvavo.cancel_order_wss!!!!!!!!!!!!!!!!!!++B??''(` NrTr]privateCancelOrders)r\rr]rr^)rNr`rardr]s rPcancel_all_orders_wszbitvavo.cancel_all_orders_wss!!!!!!!!!!!!!!!!!!  [[((F &t GH ''(=t{{7TZ?[?[\\\\\\\\\rQc||d}||}||d}|||dSr) safe_list parse_ordersrr)rNr~rerrrbs rPhandle_multiple_orderszbitvavo.handle_multiple_orderss]>>':66""8,,&&w << v{+++++rQc@K|t|jdz|d{V|d{V||}||dd}|d|||d{VS)a https://docs.bitvavo.com/#tag/General/paths/~1assets/get fetches information on an order made by the user :param str id: the order id :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 argumentrT)orderIdr]privateGetOrder)rrTr\rr]rr^)rNrTr`rar]rds rPfetch_order_wszbitvavo.fetch_order_wss >#DG.X$XYY Y!!!!!!!!!!!!!!!!!!V$$Tl  ''(94;;wPV;W;WXXXXXXXXXrQc8K|t|jdz|d{V|d{V|||||}|d|d{V}|||||S)a, 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)rrTr\rfetchOrdersRequestrr)rNr`rrrardrs rPfetch_orders_wszbitvavo.fetch_orders_wss >#DG.[$[\\ \!!!!!!!!!!!!!!!!!!))&%GG))*` NrTr]privateGetOrdersOpen)r\rr]rr^r)rNr`rrrardr]rs rPfetch_open_orders_wszbitvavo.fetch_open_orders_wss!!!!!!!!!!!!!!!!!!   [[((F &t GH ))*@$++gW]B^B^________00NNNrQc8K|t|jdz|d{V|d{V|||||}|d|d{V}|||||S)a 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)rrTr\rfetchMyTradesRequestrr)rNr`rrrardmyTradess rPfetch_my_trades_wszbitvavo.fetch_my_trades_ws s >#DG.]$]^^ ^!!!!!!!!!!!!!!!!!!++FE5&II++,>HHHHHHHH0065%PPPrQc||d}||ddd}||d}|||dSr)r parse_tradesrr)rNr~rerrrbs rPhandle_my_tradeszbitvavo.handle_my_tradess_.>>':66""8T4>>&&w << v{+++++rQcodeaddresstagc4K|||\}}|||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_addressr\rwithdrawRequestr)rNr7rr8r9rards rP withdraw_wszbitvavo.withdraw_ws;s99#vFF V 7###!!!!!!!!!!!!!!!!!!&&tVWc6JJ''(?IIIIIIIIIrQc||d}||d}||}|||dSNrr)rrparse_transactionr)rNr~rerbrwithdraws rPhandle_withdrawzbitvavo.handle_withdrawLsY&&w << ??7J77))(33x-----rQcK|d{V|d{V|||||}|d|d{V}|||||S)a 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)r\rfetchWithdrawalsRequestrfilter_by_currency_since_limit)rNr7rrrard withdrawss rPfetch_withdrawals_wszbitvavo.fetch_withdrawals_ws^s!!!!!!!!!!!!!!!!!!..tUE6JJ,,-JGTTTTTTTT 229dE5QQQrQc||d}||d}||dddddi}|||dS)Nrrr withdrawal)rrparse_transactionsr)rNr~rerrb withdrawalss rPhandle_withdrawszbitvavo.handle_withdrawspsg$>>':66&&w << --hdD6S_J`aa {K00000rQcK|d{V||||||}d}|||d{V}||||ddS)a 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)r\fetchOHLCVRequestrr) rNr`rrrrardrZrs rPfetch_ohlcv_wszbitvavo.fetch_ohlcv_wss!!!!!!!!!((E5&QQ((99999999))%q$GGGrQcK|d{V|d{V|||||}|d|d{V}|||||S)a 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)r\rfetchDepositsRequestrrH)rNr7rrrarddepositss rPfetch_deposits_wszbitvavo.fetch_deposits_wss!!!!!!!!!!!!!!!!!!++D%GG++,FPPPPPPPP228T5%PPPrQc||d}||dddddi}||d}|||dS)Nrrdepositr)rrMrr)rNr~rerrWrbs rPhandle_depositszbitvavo.handle_depositssg ??7J77**8T4PYGZ[[&&w << x-----rQcK|d{V|d{V|d|d{VS)aQ 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 NprivateGetAccountr\rrrNras rPfetch_trading_fees_wszbitvavo.fetch_trading_fees_wsy!!!!!!!!!!!!!!!!!!''(;VDDDDDDDDDrQc>K|d|d{VS)a 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 rPfetch_markets_wszbitvavo.fetch_markets_wss0'' f=========rQcrK|d{V|d|d{VS)a 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)r\rr_s rPfetch_currencies_wszbitvavo.fetch_currencies_wssT!!!!!!!!!'' V<<<<<<<<` NprivateGetBalancer^r_s rPfetch_balance_wszbitvavo.fetch_balance_wsrarQc||d}||dg}||}|||dSrA)rr parse_balancer)rNr~rerbrbalances rPhandle_fetch_balancezbitvavo.handle_fetch_balances[&&w << ??7J;;$$X..w ,,,,,rQc||di}||}||d}|||dSr)r parse_orderrr)rNr~rerorderrbs rPhandle_single_orderzbitvavo.handle_single_order0s[:??7J;;  **&&w << uk*****rQc||di}||}||d}|||dSr)r parse_marketsrr)rNr~rerrXrbs rPhandle_marketszbitvavo.handle_marketsRs[(??7J;;$$X..&&w << w ,,,,,rQc|j|j|j|j|jd}|||}|}| |||}|S)N)rr rrr0)action_and_market_message_hash action_and_order_id_message_hashr)rNrZramethodsrrbs rPbuild_message_hashzbitvavo.build_message_hashksc"&"E"&"G"&"G#D $ C   &11   &00KrQc:||dd}||zS)Nr])r)rNrZrar`s rPrz&bitvavo.action_and_market_message_hashys#!!&(B77rQcj||d}|t|jdz||zS)Nrz; privateUpdateOrderMessageHash requires a orderId parameter)rrrT)rNrZrars rPrz(bitvavo.action_and_order_id_message_hash}s=""6955 ?*g ghh hrQc||d}||dd}|d}d|z}|||}|j0||jdd}t ||_|j} | |||j|dS)Nr]rr`rrFrC) rrrxrrrJrrlr) rNr~rerr]r`rbryrrs rP handle_orderzbitvavo.handle_orders,##GX66!!(D#66!'   &11 ; %%dlM4HHE077DK et{K00000rQcx||d}||dd}|d}d|z}|||}|j0||jdd}t ||_|j} | ||| |dS)Nr]rr`rrErC) rrrr2rrJrrlr) rNr~rerr]r`rbrrrs rPhandle_my_tradezbitvavo.handle_my_trades ##GX66!!(D#66!!F*   &11 = %%dlM4HHE&u--DMm 5!!!{K00000rQcN||di}d|ji}t|}t dt |D]E}||}|||}|#|||} |||| F|S)Nrrr)rrlistkeysrjrk) rNr~rerrnamesrrrWrrs rPhandle_subscription_statusz"bitvavo.handle_subscription_statuss"EE D8 ]''))**q#e**%% 6 6A8D__Wd33F!#}dCC vw 555rQc.K|jdd}||}d}||j|}||}t |}|dz|jzdz}|||||j tj } d} | |j | |d} | | |} |||| |d{V}||j|<|S)NrBr authenticatedzGET/z /websocketr)rZkey signaturer)rIr~rrr#r"versionhmacencodesecrethashlibsha256apiKeyr^r_) rNrarcr~rbfuturerstringTimestampauthrrZrdres rPrzbitvavo.authenticatesit$S!!% !5{CC >))++I!)nnO"V+dl:\ID $++d"3"3T[[5M5Mw~^^I#F {&& G kk'622G::c;MMMMMMMMF06F  - rQcd}||dd}|r|||dSt||}|||||jvr |j|=dSdS)NrF) safe_boolrrjsonrejectr)rNr~rerbrerrors rPhandle_authentication_messagez%bitvavo.handle_authentication_messages& wGG  6 NN7K 0 0 0 0 0' '(:(:;;E MM% - - -f222(55532rQc ||d}||d}||d}|||}||d|}d} ||||jdi||ii n/#t $r"} d}|| |Yd} ~ nd} ~ wwxYw|s|||dSdS)Nr errorCoderZrFrT)rrr handle_errorsrc Exceptionr) rNr~rerr7rZ buildMessagerbrejectedes rPhandle_error_messagezbitvavo.handle_error_messages   '22   44!!'844..vw?? &&w \JJ  *   tUFJBwPRTV W W W W * * *H MM![ ) ) ) ) ) ) ) ) *  MM'; / / /4ts3"B C B==Cc ||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)Nr subscribedrrrrrurryfillrr rqrrrrr-)r]rUrFr;r0rfrQrcrrZ)rrrrrrrrrrrrzrvrror[rOrDr6rkrr}r)rNr~rerrrrrZs rPhandle_messagezbitvavo.handle_message sX  '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 # # # # #rQ)N)X__name__ __module__ __qualname__rrMrfr"rsrrvrrr}rrrrrr rrrrrrrrr rrrrrrrrrrr rrrrfloatr rr rrrrrr)rr.r3r6r?rDrJrOrSrXr[rr`rdr rgrkrorrrrvrzr}rrrrrrrrrrr __classcell__)rOs@rPrrs 2 #2 2 2 2 2 2 h79HHHH&Y[UU3UUUU*68 D D DF D D D D6:"@@7@@@@@ $&F$&$&$&$&L8 > > >02 = =j = = = =0f00004***$-/ E E8 E E E E-6----$ +& + + + +D-V----213    =??A    16 1 1 1 1D1f11118,)+,6F6666&6t@R$VR$R$R$R$R$R$R$R$rQr)"ccxt.async_supportccxt ccxt.async_support.base.ws.cacherrrrccxt.base.typesrrrr r r r r rrrrrrrr!ccxt.async_support.base.ws.clientrtypingrccxt.base.errorsrrr async_supportrrQrPrs ffffffffffaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaa444444******000000......a$a$a$a$a$d (a$a$a$a$a$rQ