":hddlZddlmZmZddlZddlmZmZm Z m Z m Z m Z m Z mZmZddlmZddlmZddlmZddlmZddlmZdd lmZdd lmZGd d ej4j6Zy) N) ArrayCacheArrayCacheBySymbolById) AnyIntOrder OrderBookStrStringsTickerTickersTrade)Client)List) ExchangeError)AuthenticationError)ArgumentsRequired) BadRequest) BadSymbolc 4eZdZdeffd ZdZddifdZgdifdZifdede fdZ difd e de fd Z ddifded ed edeefd Zddifd eed ed edeefdZdddifded ed edeefdZdddifd e d ed edeefdZdddifd e d ed edeefdZdddifded ed edeefdZdifd eed edefdZdifded edefdZdefdZdefdZd$fd ZdZ defdZ!d$dZ"defdZ#d$de ffd Z$dZ%dZ&defd Z'defd!Z(defd"Z)defd#Z*xZ+S)%coinbaseexchangereturnc|jtt|dddddddddddddddddiddiddddd d S) NTF)ws watchOHLCVwatchOrderBookwatchOrderBookForSymbols watchTicker watchTickers watchTradeswatchTradesForSymbolswatchMyTradesForSymbols watchBalance watchStatus watchOrderswatchOrdersForSymbols watchMyTradesrz#wss://ws-feed.exchange.coinbase.comz2wss://ws-feed-public.sandbox.exchange.coinbase.com)apitest) tradesLimit ordersLimit myTradesLimit)hasurlsoptions) deep_extendsuperrdescribe)self __class__s S/var/www/html/turnos/venv/lib/python3.12/site-packages/ccxt/pro/coinbaseexchange.pyr2zcoinbaseexchange.describes&6 F H#"&,0# $#)-+/ %$#)-!%$?N  $#!%3K   c2|jd}|j}t|dz|z}|j|j ||j |j tjd}||j||jdS)Nz/users/self/verifyGETbase64) timestampkey signature passphrase) check_required_credentialsnoncestrhmacencodebase64_to_binarysecrethashlibsha256apiKeypassword)r3pathr?payloadr<s r5 authenticatezcoinbaseexchange.authenticate6s '')# e*u$t+IIdkk'2D4I4I$++4VX_XfXfhpq ;;"--   r6NcRK|jd{d}|}g}|0|j|}|d|dzz }|j|d|jdd}d|vr|dz}d||gd} |j | |} |j ||| |d{S77w) N:idr'rr<? subscribetype product_idschannels) load_marketsmarketappendr.extendwatch) r3namesymbolmessageHashStartparamsrV messageHash productIdsurlrPrequests r5rPzcoinbaseexchange.subscribeCs!!!&   [[(F 3- -K   fTl +iit$ & )C% ++i0ZZ[';GGG) "(Hs"B'B#BB'B%B'%B'cK|jd{d}|j|}g}g}tdt|D]F}||} |j | }|j |d|j |dz|dzH|j dd} d|vr| dz} d ||gd } |j| |} |j| || |d{S77w) NrrNrMr[r'rr<rOrPrQ) rUmarket_symbolsrangelenrVrWr.rXwatch_multiple) r3rZsymbolsr\r]rV messageHashesr_ir[r`rPras r5subscribe_multiplez#coinbaseexchange.subscribe_multipleZs !!!%%g.  q#g,' LAQZF[[(F   fTl +  !1C!7&:J!J K  L iit$ & )C% ++i0((mWmTTT- ",Us"C$C CC$C"C$"C$r[cJKd}|j||||d{S7w)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 ` tickerN)rP)r3r[r]rZs r5 watch_tickerzcoinbaseexchange.watch_tickerss(^^D&$????s #!#rgc<K|jd{t|}|dk(rt|jdzd}d}|j ||||d{}|j r i}|||d<|S|j |jd|S77;w)a3 watches a price ticker, a statistical calculation with the information calculated over the past 24 hours for all markets of a specific list :param str[] [symbols]: unified symbol of the market to fetch the ticker for :param dict [params]: extra parameters specific to the exchange API endpoint :param str [params.channel]: the channel to subscribe to, tickers by default. Can be tickers, sprd-tickers, index-tickers, block-tickers :returns dict: a `ticker structure ` Nrz0 watchTickers requires a non-empty symbols arrayrlr[)rUrerrNrj newUpdatesfilter_by_arraytickers)r3rgr] symbolsLengthchannelr^rlresults r5 watch_tickerszcoinbaseexchange.watch_tickers}s!!!G A DGG&XXY Y ..wfUU ??F'-F6(# $M##DLL(GDD " Vs"BBABB:BBsincelimitcK|jd{|j|}d}|j||||d{}|jr|j ||}|j |||ddS7f79w)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 ` Nmatchesr:T)rUr[rProgetLimitfilter_by_since_limit)r3r[rvrwr]rZtradess r5 watch_tradeszcoinbaseexchange.watch_tradess!!!V$~~dFD&AA ??OOFE2E))&% TRR "Bs!BA=.BA?8B?BcKt|}|dk(rt|jdz|jd{|j |}d}|j ||||d{}|j r6|j|d}|j|d} |j| |}|j|||ddS77]w)a get the list of most recent trades for a particular symbol :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 ` rz> watchTradesForSymbols() requires a non-empty array of symbolsNryr[r:T) rerrNrUrcrjro safe_value safe_stringrzr{) r3rgrvrwr]rrrZr|first tradeSymbols r5watch_trades_for_symbolsz)coinbaseexchange.watch_trades_for_symbolssG A TWW'ggh h!!!%%g...tWdFKK ??OOFA.E**5(;KOOK7E))&% TRR "Ls"` Nz+ watchMyTrades() requires a symbol argumentusermyTradesr:T) rrNrUr[rKrPrXrorzr{) r3r[rvrwr]rZr^authenticationr|s r5watch_my_tradesz coinbaseexchange.watch_my_tradess >#DGG.[$[\ \!!!V$ **,~~dFKVUcAdee ??OOFE2E))&% TRR " f".B=B9AB=B;8B=;B=c K|j|dd}|jd{d}d}|j}|j||||j ||d{}|j r6|j |d} |j| d} |j| |}|j|||ddS77]w) a watches information on multiple trades made by the user :param str[] symbols: unified symbol of the market to fetch trades for :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 ` NFrrrr[r:T) rcrUrKrjrXrorrrzr{) r3rgrvrwr]rZr^rr|rrs r5watch_my_trades_for_symbolsz,coinbaseexchange.watch_my_trades_for_symbolss%%gtU;!!! **,..tWk4;;W]_mKnoo ??OOFA.E**5(;KOOK7E))&% TRR "ps"'C C?C )C*AC C c K|jd{|j|dd}d}d}|j}|j||||j ||d{}|j r6|j |d} |j| d} |j| |}|j|||ddS77]w) a watches information on multiple orders made by the user :param str[] symbols: unified symbol of the market to fetch orders for :param int [since]: the earliest time in ms to fetch orders 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 `order structures ` NFrordersrr[r:T) rUrcrKrjrXrorrrzr{) r3rgrvrwr]rZr^rrrrs r5watch_orders_for_symbolsz)coinbaseexchange.watch_orders_for_symbolss!!!%%gtU; **,..tWk4;;W]_mKnoo ??OOFA.E**5(;KOOK7E))&% TRR " ps#C CAC )C*AC C c ~K|t|jdz|jd{|j|}d}d}|j }|j ||||j ||d{}|jr|j||}|j|||ddS779w)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 watchMyTrades requires a symbolrrr:T) rrNrUr[rKrPrXrorzr{) r3r[rvrwr]rZr^rrs r5 watch_orderszcoinbaseexchange.watch_orderss >DGG&HHI I!!!V$ **,~~dFKVUcAdee ??OOFE2E))&% TRR " frc6Kt|}|dk(rt|jdzd}|jd{|j |}|j |}g}t d|D]}||} |j|dz| z |jdd} d||gd } |j| |} ||||d } |j}|j| ||j| ||| d{}|jS77w) a watches information on open orders with bid(buy) and ask(sell) prices, volumes and other data :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 rzA watchOrderBookForSymbols() requires a non-empty array of symbolslevel2NrMr'rrPrQ)r^rg marketIdsrw) rerrNrUrc market_idsrdrWr.rXrKrfrw)r3rgrwr]rrrZrrhrimarketIdr`rPra subscriptionr orderbooks r5watch_order_book_for_symbolsz-coinbaseexchange.watch_order_book_for_symbols sIG A TWW'jjk k!!!%%g.OOG,  q-( 8A |H  h!6 7 8iit$$ ++i0"  **,--c=$++gWeBfhuxDEE   1 ".Es$>DDB?DDDDcKd}|jd{|j|}|d}|dz|dz}|jdd}d|dg|gd }|j||} |||d|d } |j } |j |||j| | || d{} | j S77w) 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 rNr[rMrNr'rrPrQ)r^r[rrw)rUrVr.rXrKrYrw) r3r[rwr]rZrVr^r`rPrarrrs r5watch_order_bookz!coinbaseexchange.watch_order_book3s!!!V$!Sj6$</ iit$t   ++i0&t   **,**S+t{{7N7[]hjvww   / ",xs"CCBC/C0CCclientc^|j|d}||j|}|d}d}|dz|z}|j|j|}|7|j |j dd} t | }||j|<|j||j|||S)N product_idr[ryrMr*r)) rparse_ws_traderr| safe_integerr/rrWresolve) r3rmessagertrader[rRr^ tradesArrayr*s r5 handle_tradezcoinbaseexchange.handle_tradeUs##G\:  ''0E8_FD*x/K//$++v>K""// mTR (5 &1 F#   u % NN; 4r6c$|j|d}|{|j|}d}|dz|z}|j}|/|j|jdd}t |}||_|j ||j|||S)NrrrMr,r))rrrrr/rrWr) r3rrrrrRr^rrws r5handle_my_tradez coinbaseexchange.handle_my_tradevs##G\:  ''0ED*x/K--K"))$,,N4U; +   u % NN; 4r6ctt| |}d}d}d|vrd}d|d<|j|d}n5d|d<|j|d}|d}|j d d d |||d<|rd nd }|j |||d<|j |d}|d}d} |d||j|d} | |z} || |d|d<|S)NFmaker_fee_rateTmaker takerOrMakertakertaker_fee_ratesidesellbuy)rrmaker_order_idtaker_order_idorderr[quotecost)ratercurrencyfee)r1r parse_trade safe_numberrrV) r3rrVparsedfeeRateisMaker currentSideidKey feeCurrencyfeeCostrr4s r5rzcoinbaseexchange.parse_ws_trades#f':5A u $G%,F> "&&u.>?G%,F> "&&u.>?G!.K!--/K)F6N%, 1A**5%8wVH-.Wo  6N &W-@##FF3DWnG# u  r6c2ddd}|j||dS)Nclosedcanceled)filledropen)r)r3statusstatusess r5parse_ws_order_statusz&coinbaseexchange.parse_ws_order_statuss&" &&99r6c|j}|/|j|jdd}t|}||_|j |d}|j |d}|d|z}|j |}|j |d} |j |d} |j |d} |j} |j | j|i} |j | | }||j| | | }|5|j|}| j||j| |y|j|d }|j |d i}|j|d }|||kDr|d k(r.|j|}|d g|d <|d j||d |d<d}d}|d }tdt|D]1}||}|j||d}|j||d}3|dkDr||z |d<||d<|d#|dxx|dz cc<|d|d|dz |d<|dd|ddd|d<|dd,|dd$|j|dd|dd|dd<| j||j| |y|dk(s|dk(r|j!|d |}|j|}t#|j%}tdt|D]}||}||||||<| j||j| |yyyy)Nr+r)rRrzorders:order_idrrsequenceinfomatchr|r:lastTradeTimestamprramountaverager remainingrr)rrreceiveddone)rrr/rr safe_symbolrhashmap safe_value_2parse_ws_orderrWrrrdresumrXlistkeys)r3rr currentOrdersrwrRrr^r[orderId makerOrderId takerOrderIdrpreviousOrders previousOrderrr previousInfopreviousSequencer totalCost totalAmountr|ri tradeEntryrrrr;s r5 handle_orderzcoinbaseexchange.handle_orders^  %%dllM4HE259M'DK0##G\:  #h.K%%h/F&&w ;G++G5EFL++G5EFL[[F!__V^^VRHN OONGDM$ $ 1 1.,P\ ] $,,W5 f%v{3,,WjA#}fbI #'#4#4\:#N $,(=M2Mw $ 3 3G <(2:68M(3%h/66u=>CK>P &:;$% &' !.x!8!&q#f+!6VA)/J(,Jv)(3uXF3,X6B=J8=TWdemWn=n k :(/7(),1%L,D4M%0*%08D5QVs r6c|j|d}|j|d} |dk(rtd|zt|jdz|z#t$r}|j |Yd}~yd}~wwxYw)NrrzAuthentication FailedzAuthentication failed:  T)rrrrN Exceptionreject)r3rrerrMsgrerrors r5handle_error_messagez%coinbaseexchange.handle_error_messageLs~ !!'95!!'84 00)*Cf*LMM#DGGcMF$:;;  MM%  s.A A8A33A8c |j|d}|j|j|j|j|j|j|j|j|j d }t |jdz }|j|dz dk(}|j||}|@|dk(r:|r%|j|||j ||y|j||yy|||y)NrR) r"r%rPrlrrrrr7rrrOr) rr-r1rrr8rer`rrr)r3rrrRmethodslength authenticatedmethods r5handle_messagezcoinbaseexchange.handle_messagegs0....88(())%%''%%..  VZZ1$ 6A:.#5 $/ >w ((9%%fg6%%fg6  67 #r6r/),__name__ __module__ __qualname__rr2rKrPrjr@r rmr r rurrr r}rr rrrrrrrrrrrrrrrrrrr r-r1r8r> __classcell__)r4s@r5rrs # B  ,0$rH.68$WYU268@@F@6:"E7EE*<@d[]SSSSSbfglbmS"OSaenpSd3iSS[^SuyzvAS,37TX\egSCSsSRUSlpqvlwS*DHVZimvxSSPSScfS~BCH~IS*AESWfjsuSgSSS`cSz~@E{FS*04$UYbdSSCSsSimnsitS*SW_a$!$s)$!C$!fo$!L@DB !S ! !S\ !D6B f Qf:S<6S2 62 h& 3=3=3~  66$V$r6r)ccxt.async_supportccxt ccxt.async_support.base.ws.cacherrrEccxt.base.typesrrrrr r r r r !ccxt.async_support.base.ws.clientrtypingrccxt.base.errorsrrrrr async_supportrr0r6r5rKsH O\\\4*0.'&l $t))::l $r6