":h)wddlZddlmZddlZddlmZmZmZm Z m Z m Z m Z m Z mZddlmZddlmZddlmZGddej(j*Zy) N)ArrayCacheBySymbolById) AnyIntOrder OrderBookStrStringsTickerTickersTrade)List) ExchangeError)ArgumentsRequiredc eZdZdeffd ZdifdedefdZdifdededefdZ ded e efd Z ifd ede fd Z difdedefd ZdZd dZddifd ededede efdZddifde ededede efdZdddifd ededede efdZdifd ededefdZdifde ededefdZdZdZd dZdZdZ dZ!dZ"dZ#dZ$xZ%S)!coinbasereturnc |jtt|iddddddddddddd dd dd dd dd ddddddddddddddddddddiiddddddddS)NwsTcancelAllOrdersWsFcancelOrdersWs cancelOrderWs createOrderWs editOrderWsfetchBalanceWsfetchOpenOrdersWs fetchOrderWs fetchTradesWs watchBalance watchMyTrades watchOHLCVwatchOrderBookwatchOrderBookForSymbols watchOrders watchTicker) watchTickers watchTradeswatchTradesForSymbolsapiz$wss://advanced-trade-ws.coinbase.combidsasks)bidoffer) tradesLimit ordersLimit myTradesLimitsides)hasurlsoptions) deep_extendsuperrdescribe)self __class__s K/var/www/html/turnos/venv/lib/python3.12/site-packages/ccxt/pro/coinbase.pyr7zcoinbase.describes5h > @d#U!%      u !%$U  e!$+D t!"t#$!%#)-).@ $#!%!# 9%C % % Nname isPrivatecK|jd{d}|}g}t|tr<|j|}|j |} | }|dzdj |z}n!||j |}|dz|z}|dg}|jdd} d||d} |r"|j| |j||} |j| || |d{S77w) a @ignore subscribes to a websocket channel https://docs.cloud.coinbase.com/advanced-trade-api/docs/ws-overview#subscribe :param str name: the name of the channel :param boolean isPrivate: whether the channel is private or not :param str [symbol]: unified market symbol :param dict [params]: extra parameters specific to the exchange API endpoint :returns dict: subscription to a websocket channel N::,idr(r subscribetype product_idschannel) load_markets isinstancelistmarket_symbols market_idsjoinmarketr3extendcreate_ws_authwatch) r8r<r=symbolparamsrM messageHash productIdssymbols marketIdsurlrBs r:rBzcoinbase.subscribe9s!!!  fd #))&1G0I"J%,sxx/??K  [[(F+.K ,Jiit$%   It/B/B4/TUIZZ[)[III1 "0Js"C*C&C C*!C("C*(C*rUcK|jd{g}g}|j|dd}tdt|D]E}||}|j |} | d} |j | |j |dz|zG|j dd} d||d } |r"|j| |j||} |j| || |d{S77w) a @ignore subscribes to a websocket channel https://docs.cloud.coinbase.com/advanced-trade-api/docs/ws-overview#subscribe :param str name: the name of the channel :param boolean isPrivate: whether the channel is private or not :param str[] [symbols]: unified market symbol :param dict [params]: extra parameters specific to the exchange API endpoint :returns dict: subscription to a websocket channel NFrrAr?r(rrBrC) rGrJrangelenrMappendr3rNrOwatch_multiple) r8r<r=rUrRrT messageHashesirQrMmarketIdrWrBs r:subscribe_multiplezcoinbase.subscribe_multiple`s!!!  %%gtU;q#g,' 7AQZF[[(Fd|H   h '  v!5 6  7 iit$%  It/B/B4/TUI((mY VVV% "$Ws"C+C'C C+"C)#C+)C+rTc|i}|j|j}|j|jj ddk\xs|j j d}||zdj|z}|sb|j|d<||d<|j|j||j|j tj|d<|S|jj drt|jdz|j|jd }|j!|jd d}|j} ||d z| kr/|j#| } | |jd <| |jd <|j|jd |d <|S) Nzorganizations/rz -----BEGINr@api_key timestamp signaturezV apiKey should contain the name(eg: organizations/3b910e93....) and not the public keywsTokenwsTokenTimestampxjwt)number_to_stringsecondscheck_required_credentialsapiKeyfindsecret startswithrLhmacencodehashlibsha256rrA safe_stringr4 safe_integercreate_auth_token) r8r<rTrBrc isCloudAPiKeyauth currentTokentokenTimestamprjtokens r:rOzcoinbase.create_ws_auths ))$,,.9  '')))*:;q@kdkkF\F\]iFj 4#((:"66#';;Ii %.Ik "%)YYt{{4/@$++dkkBZ\c\j\j%kIk "{{%%l3'3K)KLL++DLL)DL!..t||=OQRSNllnG#~';g'E..w7*/ Y'3: /0#// iHIe r;rQcJKd}|j|d||d{S7w)a watches a price ticker, a statistical calculation with the information calculated over the past 24 hours for a specific market https://docs.cloud.coinbase.com/advanced-trade-api/docs/ws-channels#ticker-channel :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 ` tickerFN)rB)r8rQrRr<s r: watch_tickerzcoinbase.watch_tickers(^^D%@@@@s #!#cK| |j}d}|j|d||d{}|jri}|d}|||<|S|jS7*w)a watches a price ticker, a statistical calculation with the information calculated over the past 24 hours for a specific market https://docs.cloud.coinbase.com/advanced-trade-api/docs/ws-channels#ticker-batch-channel :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 ` N ticker_batchFrQ)rUr` newUpdatestickers)r8rUrRr<r}rrQs r: watch_tickerszcoinbase.watch_tickerssh ?llG..tUGVLL ??GH%F$GFON|| Ms(AA+Ac>|j|d}|j|dg}|j|d}|j|}g}tdt |D]}||} |j| dg} tdt | D]} | | } |j| d} | |j | }||d<||d<|d}||j |<|j||d z|z}|j|||j|||y) NrFeventsrcrr product_iddatetimerQr?) rt safe_list parse8601rYrZparse_ws_tickerrr[resolvetry_resolve_usdc)r8clientmessagerFrrrc newTickersr^ tickersObjrjr} wsMarketIdresultrQrSs r:handle_tickerszcoinbase.handle_tickerss=t""7I626##G[9NN8,  q#f+& CAJnnZB?G1c'l+ C !--flC %--f5&/{#%-z")'- V$!!&)%nv5 v{3%%fk6B C Cr;c "|j|d}d}|j|d}|jid|d|j||dd|d|j |d|j|d d |j|d d |j|d d|j|dd|j|dd|j|dddddd|d|ddddd|j|dd|j|dddS)NrpriceinforQ-rcrhigh high_24_hlowlow_24_hr,best_bid bidVolumebest_bid_quantityaskbest_ask askVolumebest_ask_quantityvwapopencloselast previousClosechange percentageprice_percent_chg_24_h volume_24_h)average baseVolume quoteVolume)rt safe_number safe_ticker safe_symboliso8601)r8r}rMr_rcrs r:rzcoinbase.parse_ws_ticker,s&##FL9 0! F! d&&x=!  !   Y/ ! D$$V[9 ! 4##FJ7 !  4##FJ7!  ))&2EF!  4##FJ7!  ))&2EF!  D!  D!  T!  D!  T! d!! " $**63KL#! $**6=A)!   r;sincelimitcK|jd{|j|}d}|j|d||d{}|jr|j ||}|j |||ddS7f79w)a@ get the list of most recent trades for a particular symbol https://docs.cloud.coinbase.com/advanced-trade-api/docs/ws-channels#market-trades-channel :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 market_tradesFrcT)rGrQrBrgetLimitfilter_by_since_limit)r8rQrrrRr<tradess r: watch_tradeszcoinbase.watch_tradesYs!!!V$~~dE66BB ??OOFE2E))&% TRR "Cs!BA=.BA?8B?Bc,K|jd{d}|j|d||d{}|jr6|j|d}|j |d}|j ||}|j |||ddS7y7]w)aC get the list of most recent trades for a particular symbol https://docs.cloud.coinbase.com/advanced-trade-api/docs/ws-channels#market-trades-channel :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 ` NrFrrQrcT)rGr`r safe_dictrtrr) r8rUrrrRr<rfirst tradeSymbols r:watch_trades_for_symbolsz!coinbase.watch_trades_for_symbolsms!!!..tUGVLL ??NN61-E**5(;KOOK7E))&% TRR "Ls BBBBABBcK|jd{d}|j|d||d{}|jr|j||}|j |||ddS7U79w)aI watches information on multiple orders made by the user https://docs.cloud.coinbase.com/advanced-trade-api/docs/ws-channels#user-channel :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 ` NuserTrc)rGrBrrr)r8rQrrrRr<orderss r: watch_orderszcoinbase.watch_ordersso!!!~~dD&&AA ??OOFE2E))&% TRR "AsA0A,A0A.8A0.A0cK|jd{d}|j|}|d}|j|d||d{}|jS7H7w)aP watches information on open orders with bid(buy) and ask(sell) prices, volumes and other data https://docs.cloud.coinbase.com/advanced-trade-api/docs/ws-channels#level2-channel :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 Nlevel2rQF)rGrMrBr)r8rQrrRr<rM orderbooks r:watch_order_bookzcoinbase.watch_order_booksg!!!V$!..uffEE   "Fs!A#A3A# A! A#!A#cK|jd{d}|j|d||d{}|jS727w)a3 watches information on open orders with bid(buy) and ask(sell) prices, volumes and other data https://docs.cloud.coinbase.com/advanced-trade-api/docs/ws-channels#level2-channel :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 NrF)rGr`r)r8rUrrRr<rs r:watch_order_book_for_symbolsz%coinbase.watch_order_book_for_symbolssN!!!11$wOO    "OsA A A A A  A c|j|d}|j|d}|j|d}|j|d}|j|d}|j |}d|z} |j|j |} | 7|j |jdd} t| } | |j |<tdt|D]X} || } |j| d}tdt|D]'}|| }| j|j|)Z|j| | |j|| | y)Nrrrrzmarket_trades::r.r))r safe_valuerrtrrrur4rrYrZr[ parse_traderr)r8rrreventrtrader_rQrS tradesArrayr.r^ currentEvent currentTradesritems r: handle_tradezcoinbase.handle_tradesM02*x0vq)##E<8!!(+'&0 oodkk6:  ++DLL-NK0=K"-DKK q#f+& ;A!!9L NN<BM1c-01 ;$Q'""4#3#3D#9: ; ; {K0 fk;?r;c|j|d}g}|j-|j|jdd}t ||_t dt |D]}||}|j|d}t dt |D]\} || } |j| } |j} |j| d} | |vr|j| | j| ^t dt |D]V}||} |j| }d|z}|j|j||j|||jX|j|jdy) Nrr/r)rrrzuser::r) rrrur4rrYrZparse_ws_orderrtr[rrr)r8rrrrVrr^rresponseOrdersr responseOrderparsed cachedOrdersr_rQrSs r: handle_orderzcoinbase.handle_ordersk:2 ;; %%dllM4HE07DKq#f+& ,A1IE!^^E8r&s< C\\\*.r $t!!**r $r;