":h}ddlZddlmZmZddlZddlmZmZm Z m Z m Z m Z m Z mZmZmZddlmZddlmZddlmZddlmZddlmZGd d ej2j4Zy) N) ArrayCacheArrayCacheByTimestamp) AnyIntMarket OrderBookStringsTickerTickers FundingRate FundingRatesTrade)Client)List) ExchangeError)AuthenticationError) NotSupportedc eZdZdeffd ZdifdedefdZdifdedefdZifdede fd Z ifde ede fd Z ifdedefd Zd Zdifdedefd ZdefdZd'defdZdefdZd'dededefdZdddifdededede efdZdefdZddifdededede efdZ ddifde ededede efdZ!dZ"d'dZ#difdedede$fdZ%difde edede$fdZ&d Z'd!Z(d"Z)d#Z*defd$Z+defd%Z,d&Z-xZ.S)(coinbaseinternationalreturnc|jtt|idddddddddddddd d d d dd d d d dd dd dddd dd dd d d d d d d dddiddidddiddddddddd d!d"d#d$tiid%S)&NwsT watchTradeswatchTradesForSymbolswatchOrderBookwatchOrderBookForSymbols watchTicker watchBalanceF watchMyTrades watchOHLCVwatchOHLCVForSymbols watchOrderswatchOrdersForSymbolswatchPositions watchTickers createOrderWs editOrderWs cancelOrderWs)cancelOrdersWscancelAllOrdersWs fetchOrderWs fetchOrdersWsfetchBalanceWsfetchMyTradesWsz&wss://ws-md.international.coinbase.comzwss://ws-md.n5e2.coinbase.com)apitestchannelLEVEL1CANDLES_ONE_MINUTECANDLES_FIVE_MINUTESCANDLES_THIRTY_MINUTESCANDLES_ONE_HOURCANDLES_TWO_HOURSCANDLES_ONE_DAY)1m5m30m1h2h1d)r tradesLimit ordersLimit myTradesLimit timeframesexactzUnable to authenticate)hasurlsoptions exceptions) deep_extendsuperrdescriber)self __class__s X/var/www/html/turnos/venv/lib/python3.12/site-packages/ccxt/pro/coinbaseinternational.pyrKzcoinbaseinternational.describesw&;T K Mdt(!$  +D  t  d'u(!%  u!" #$#(%* %!&"'#(/6B9 x  $#!%.03,-+ ",.Ae7P 7 7 Nnamesymbolsc"K|jd{|jd}|}d}||j}t|}g}|dkDrY|j |} |j | } | }t dt| D]} |j|dz| | zn*|dk(r%|j|d}|dz|dz}|dg}|jdd} | t|jd zt|j} | |jzd z|jz}|j!|j#||j%|j&t(j*d }d |g| |j|j|d }|||d<|dkDr,|j-| ||j/|||d{S|j1| ||j/|||d{S7737 w)a @ignore subscribes to a websocket channel https://docs.cloud.coinbase.com/intx/docs/websocket-overview#subscribe :param str name: the name of the channel :param str[] [symbols]: unified market symbol :param dict [params]: extra parameters specific to the exchange API endpoint :returns dict: subscription to a websocket channel Nr::symbolidr/r( is not supported in sandbox environmentCBINTLMDbase64 SUBSCRIBE)typechannelstimekey passphrase signature product_ids) load_marketscheck_required_credentialsget_active_symbolslenmarket_symbols market_idsrangeappendmarketrFrrVstrnonceapiKeypasswordhmacencodebase64_to_binarysecrethashlibsha256watch_multipleextendwatch)rLrPrQparamsrj messageHash productIds symbolsLength messageHashes parsedSymbols marketIdsiurl timestampauthr` subscribes rNrzcoinbaseinternational.subscribeMs!!! '')  ?--/GG  1  //8M 6I"J1c-01 E$$TD[=3C%CD Ea [[,F+x(88K ,Jiit$ ;tww)SST T % 4;;&3dmmCIIdkk$/1F1Ft{{1SU\UcUcemn ;;--"   !'1Im $ 1 ,,S-YX^A_anoo oZZ[$++i2PR]^^^O "Lp^s4HHGHH +HH H H HcK|jd{|j|j|r |j}n|j |}g}g}t dt |D]O}|j||}|j|}|j||j|dz|zQ|jdd} | t|jdz|j|j} | |jzdz|j z} |j#|j%| |j'|j(t*j,d} d | ||g|j|j | d } |j/| ||j1| ||d{S77w) a @ignore subscribes to a websocket channel using watchMultiple https://docs.cloud.coinbase.com/intx/docs/websocket-overview#subscribe :param str name: the name of the channel :param string|str[] [symbols]: unified market symbol :param dict [params]: extra parameters specific to the exchange API endpoint :returns dict: subscription to a websocket channel NrrTr/rrWrXrYrZ)r[r]rar\r^r_r`)rbrcis_emptyrQrfrhre market_idrUrirFrrVnumber_to_stringsecondsrmrnrorprqrrrsrtrurv)rLrPrQrxr|rzrmarketIdrUrrrr`rs rNsubscribe_multiplez(coinbaseinternational.subscribe_multiples!!! '') == !llG))'2G  q#g,' 7A~~gaj1H[[*F   h '  v!5 6  7 iit$ ;tww)SST T))$,,.9 4;;&3dmmCIIdkk$/1F1Ft{{1SU\UcUcemn %;;--" ((mT[[TZ=[]jkkk9 "8ls"G GF(G ?GG G rUczK|jd{|jd|g|d{S7 7w)at watch the current funding rate https://docs.cloud.coinbase.com/intx/docs/websocket-channels#funding-channel :param str symbol: unified market symbol :param dict [params]: extra parameters specific to the exchange API endpoint :returns dict: a `funding rate structure ` NRISK)rbr)rLrUrxs rNwatch_funding_ratez(coinbaseinternational.watch_funding_rates;!!!^^FVHf=== "=s;7;9;;cK|jd{|jd||d{}|j|d}|jr i}|||<|S|j |j d|S7c7Jw)a watch the funding rate for multiple markets https://docs.cloud.coinbase.com/intx/docs/websocket-channels#funding-channel :param str[]|None symbols: list of unified market symbols :param dict [params]: extra parameters specific to the exchange API endpoint :returns dict: a dictionary of `funding rates structures `, indexe by market symbols NrrU)rbr safe_string newUpdatesfilter_by_array fundingRates)rLrQrx fundingRaterUresults rNwatch_funding_ratesz)coinbaseinternational.watch_funding_ratess!!! 33FGVLL !!+x8 ??F(F6NM##D$5$5xII "Ls A>A:A>A<A A><A>cK|jd{d}|j|ddd\}}|j||g|d{S797w)aW 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/intx/docs/websocket-channels#instruments-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 :param str [params.channel]: the channel to watch, 'LEVEL1' or 'INSTRUMENTS', default is 'LEVEL1' :returns dict: a `ticker structure ` Nrr1r2)rbhandle_option_and_paramsr)rLrUrxr1s rN watch_tickerz"coinbaseinternational.watch_tickers]!!!77 yZbc^^GfXv>>> "?s!AA4A A AAc|j}g}tdt|D]-}||}|j|}|ds|j |/|S)Nractive)rQrhremarketsri)rLrQoutputrrUrjs rNrdz(coinbaseinternational.get_active_symbolss\,,q#g,' &AQZF\\&)Fh f%  &  rOcK|jd{d}|j|ddd\}}|j|||d{}|jr i}|||d<|S|j |j d|S7m7;w)ad 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/intx/docs/websocket-channels#instruments-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 :param str [params.channel]: the channel to watch, 'LEVEL1' or 'INSTRUMENTS', default is 'INSTLEVEL1UMENTS' :returns dict: a `ticker structure ` Nr%r1r2rU)rbrrrrtickers)rLrQrxr1tickerrs rN watch_tickersz#coinbaseinternational.watch_tickerss!!!77PY[cd~~gw?? ??F'-F6(# $M##DLL(GDD "@s!BB3B B :BBclientc|j|}|j|d}|j|||j||dz|dzyNr1rTrU)parse_ws_instrumentrresolverLrmessagerr1s rNhandle_instrumentz'coinbaseinternational.handle_instrumentsP4))'2""7I6vw'vw~x0@@ArOrc b|j|d}|j|d}|jid|d|j||dd|j|d|ddd dd dd dd dd dddddddddddddddd|j |dd|j |dddS)N product_idr]inforU-rdatetimehighlowbid bidVolumeask askVolumevwapopencloselast previousClosechange percentagetotal_24_hour_quantitytotal24_hour_quantitytotal_24_hour_volumetotal24_hour_volume)average baseVolume quoteVolume)r safe_ticker safe_symbol parse8601 safe_string_2)rLrrjrrs rNrz)coinbaseinternational.parse_ws_instrumentsSl##FL9##FF3! F! d&&x=!  1!   ! D ! 4 !  4!  !  4!  !  D!  D!  T!  D!  T! d!! " $#! $,,V5MOfg--f6LNcd)!   rOc|j|}|j|d}|j|||j||dz|dzyr)parse_ws_tickerrrrs rN handle_tickerz#coinbaseinternational.handle_tickerisP2%%g.""7I6vw'vw~x0@@ArOrjc|j|d}|j|d}|jid|d|j||d|j|d|d|j |dd |j |d d |j |d d |j |dddddddddddddddddddddddS)Nr]rrrUrrr bid_pricerbid_qtyr ask_pricerask_qtyrrrrrrrrr)rrr)rrrr safe_number)rLrrjrrs rNrz%coinbaseinternational.parse_ws_tickersb##FF3##FL9! F! d&&x8!  1!   ! 4##FK8 ! ))&)< !  4##FK8!  ))&)<!  D!  4!  D!  T!  D!  d!  $! t!! " D#! $!)!   rOr:sincelimitclK|jd{|j|}|d}|j|jdi}|j |||}|j ||g|d{} |j r| j||}|j| ||ddS779w)a watches historical candlestick data containing the open, high, low, close price, and the volume of a market https://docs.cdp.coinbase.com/intx/docs/websocket-channels#candles-channel :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 NrUrCrT) rbrj safe_dictrGrrrgetLimitfilter_by_since_limit) rLrU timeframerrrxrjrGintervalohlcvs rN watch_ohlcvz!coinbaseinternational.watch_ohlcvs!!!V$!..|R@##GY BnnXx@@ ??NN651E))%q$GG " As"B4B0A!B48B298B42B4c|j|d}|j|d}|j|}|d}|j|}|j|j|i|j|<|j|j||8|j |j dd}t||j||<|j||} |j|dg} tdt| D]*} | | } |j| |} | j| ,|j| |dz|zy) Nr1rrU OHLCVLimitr3candlesrrT)r safe_marketfind_timeframe safe_valueohlcvs safe_integerrGr safe_listrhre parse_ohlcvrir)rLrrryrrjrUrrstoreddatartickparseds rN handle_ohlcvz"coinbaseinternational.handle_ohlcvs;&&&w : ##G\:!!(+!'' 4 "oodkk62F F ??4;;v. : B%%dllL$GE-B5-IDKK  *V$Y/~~gy"5q#d)$ "A7D%%dF3F MM& ! " v{T1F:;rOcHK|j|g|||d{S7w)a1 get the list of most recent trades for a particular symbol https://docs.cloud.coinbase.com/intx/docs/websocket-channels#match-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)watch_trades_for_symbols)rLrUrrrxs rN watch_tradesz"coinbaseinternational.watch_tradess'22F8UE6RRRRs " "cPK|jd{|j|dddd}|jd||d{}|jr6|j |d}|j |d}|j ||}|j|||ddS77]w)a 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 ` NFTMATCHrrUr)rbrfrrrrrr)rLrQrrrxtradesfirst tradeSymbols rNrz.coinbaseinternational.watch_trades_for_symbolss!!!%%gtUD$G..wHH ??NN61-E**5(;KOOK7E))&% TRR "Hs"B&B"/B&B$AB&$B&c|j|}|d}|j|d}||jvr7|j|jdd}t |}||j|<|j|}|j |||j|<|j|||j||dz|dz|S)NrUr1r@r3rT)parse_ws_traderrrrGrrir) rLrrtraderUr1rtradesArrayCache tradesArrays rN handle_tradez"coinbaseinternational.handle_trade s##G,x""7I6$++%%%dllM4HE)%0 "2DKK kk&) 5!) F{G,{GdNU8_$DErOcH|j|dd}|j|d}|j||j|dd|j|||j ||d|j |dd|j|d|j|dddd S) NrUrr]match_id agressor_side trade_price trade_qty) rrVorderrrrUr[side takerOrMakerpriceamountcostfee)rr safe_traderrsafe_string_lower)rLrrjrrs rNrz$coinbaseinternational.parse_ws_trade%s%%eX|D##E62""5*51 &&x8**5/B %%e];&&uk:   rOcFK|j|g||d{S7w)aI watches information on open orders with bid(buy) and ask(sell) prices, volumes and other data https://docs.cloud.coinbase.com/intx/docs/websocket-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 N)watch_order_book_for_symbols)rLrUrrxs rNwatch_order_bookz&coinbaseinternational.watch_order_bookDs%66xOOOOs !!cxK|jd{|jd||d{S77w)a watches information on open orders with bid(buy) and ask(sell) prices, volumes and other data https://docs.cloud.coinbase.com/intx/docs/websocket-channels#level2-channel :param str[] 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 NLEVEL2)rbr)rLrQrrxs rNrz2coinbaseinternational.watch_order_book_for_symbolsQs;!!!,,XwGGG "Gs:6:8::c|j|d}|j|d}|j|}|j|d}|j|d}||jvr<|j|jdd}|j i||j|<|j|} |dk(r,|j ||ddd } | j| || d <n%|j|d g} |j| | |j|d | d <|| d<|j|| d<| |j|<|j| |dz|zy)Nr[rr]r1watchOrderBookLimitr3SNAPSHOTbidsasksrUchangessequencerlrrrT) rr orderbooksrrG order_bookparse_order_bookresetr handle_deltasrr) rLrrr[rrUrr1r orderbookparsedSnapshotrs rNhandle_order_bookz'coinbaseinternational.handle_order_book_s[H0##G\:!!(+##GV4""7I6$//)%%dll4I4PE&*oob%&@DOOF #OOF+ : !227FD&RXYN OON +"(Ih nnWi+h/0{GdN[5J$JKrOc|j|d}|dk7ry|j|d}|j|d} |jdz|z|z}|j|jd|||j |jd||t |#t $r}|j|Yd}~y d}~wwxYw) Nr[REJECTFreasonr rDbroadT)rrVthrow_exactly_matched_exceptionrHthrow_broadly_matched_exceptionr Exceptionreject)rLrrr[r,errMsgfeedbackes rNhandle_error_messagez*coinbaseinternational.handle_error_messages0 8 !!'84!!'95 ww}v-6H  0 01I6S[ \  0 01I6S[ \) )  MM!   sA B C'B==Cc|j||ry|j|dd}|j|j|j|j |j |j|jd}|j|d}|dk(r|j|d}t||jddkDr|j|||j||}| |||yy) Nr1) SUBSCRIPTIONS INSTRUMENTSr2rrFUNDINGrr[errorrCANDLES) r6rr&rrrrr)rfindrr)rLrrr1methodsr[ errorMessagemethods rNhandle_messagez$coinbaseinternational.handle_messages  $ $VW 5 ""7Ir:!<<11((&&,,//&& 0 7?++GY?L - - << "R '   fg .'2   67 # rOr$)/__name__ __module__ __qualname__rrKrkr rrr rrr rr rrdr rrrdictrrobjectrrrlistrrrrrrrrrrrr rr&r)r6rC __classcell__)rMs@rNrrs_8 #8 t=A3_C3_'3_jFJRT(lS(l7(lT<> >s >+ >DFJcJ,J&68??F? 6:"E7EE*BB>M $M ^BFB<% f% f% % N8<$]ajlHHCHWZHquvzq{H."<6"@DB PS P PS\ PSW_a H$s) HC Hfo H8;t&46L&L86.$rOr)ccxt.async_supportccxt ccxt.async_support.base.ws.cacherrrsccxt.base.typesrrrrr r r r r r!ccxt.async_support.base.ws.clientrtypingrccxt.base.errorsrrr async_supportrr%rOrNrSsB Nsss4*0)w $D..DDw $rO