eiJ~ddlZddlmZmZddlZddlmZmZm Z m Z m Z m Z m Z mZmZmZmZddlmZddlmZddlmZddlmZddlmZdd lmZGd d ejjZdS) N) ArrayCacheArrayCacheByTimestamp) AnyBoolIntMarket OrderBookStringsTickerTickers FundingRate FundingRatesTrade)Client)List) ExchangeError)AuthenticationError)ArgumentsRequired) NotSupportedc eZdZdeffd ZdifdedefdZdifdedefdZifdede fd Z difdede fd Z ifdede fd Zd Zdifdedefd ZdefdZd(defdZdefdZd(dedede fdZdddifdededededeef dZdefdZddifdedededeefdZ ddifdeedededeefdZ!dZ"d(dZ#difdedede$fdZ%difdeedede$fd Z&d!Z'd"Z(d#Z)d$Z*defd%Z+dede,fd&Z-d'Z.xZ/S))coinbaseinternationalreturnc:|tt|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 \/var/www/html/volatility/venv/lib/python3.11/site-packages/ccxt/pro/coinbaseinternational.pyrMzcoinbaseinternational.describes&;T B B K K M Mdt(!$  +D  t  d'u(!%  u!" #$#(%* %!&"'#(/6B9 x  $#!%.03,-+ ",.Ae7P 7P 7 7 7 Nnamesymbolsc|K|d{V|d}|}d}||}t|}g}|dkrn||} || } | }t dt| D]#} ||dz| | z$n8|dkr2||d}|dz|dz}|dg}|j dd} | t|j d zt| } | |jzd z|jz}|||||jt(jd }d |g| |j|j|d }|||d<|dkr2|| |||||d{VS|| |||||d{VS)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::symbolidr1r( is not supported in sandbox environmentCBINTLMDbase64 SUBSCRIBE)typechannelstimekey passphrase signature product_ids) load_marketscheck_required_credentialsget_active_symbolslenmarket_symbols market_idsrangeappendmarketrHrrXstrnonceapiKeypasswordhmacencodebase64_to_binarysecrethashlibsha256watch_multipleextendwatch)rNrRrSparamsrl messageHash productIds symbolsLength messageHashes parsedSymbols marketIdsiurl timestampauthrb subscribes rPrzcoinbaseinternational.subscribeNs|!!!!!!!!! '')))  ?--//GG  1   //88M 66I"J1c-0011 E E$$TD[=3C%CDDDD Ea  [[,,F+x(88K ,Jit$ ;tw)SSTT T %% 4;&3dmCIIdkk$//1F1Ft{1S1SU\Ucemnn ;-"    !'1Im $ 1  ,,S-YX^A_A_anoooooooo oZZ[$++i2P2PR]^^^^^^^^^rQcK|d{V|||r|j}n||}g}g}t dt |D]b}|||}||}| || |dz|zc|j dd} | t|j dz| |} | |jzdz|jz} ||| ||jt*jd} d | ||g|j|j| d } || ||| ||d{VS) 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 NrrVr1rrYrZr[r\)r]r_rcr^r`rarb)rdreis_emptyrSrhrjrg market_idrWrkrHrrXnumber_to_stringsecondsrorprqrrrsrtrurvrwrx)rNrRrSrzr~r|rmarketIdrWrrrrbrs rPsubscribe_multiplez(coinbaseinternational.subscribe_multiples!!!!!!!!! ''))) == ! ! 3lGG))'22G  q#g,,'' 7 7A~~gaj11H[[**F   h ' ' '  v!5 6 6 6 6it$ ;tw)SSTT T))$,,..99 4;&3dmCIIdkk$//1F1Ft{1S1SU\Ucemnn %;-"  ((mT[[TZ=[=[]jkkkkkkkkkrQrWcvK|d{V|d|g|d{VS)ar 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)rdr)rNrWrzs rPwatch_funding_ratez(coinbaseinternational.watch_funding_ratesV!!!!!!!!!^^FVHf=========rQc*K|t|jdz|d{V|d||d{V}||d}|jr i}|||<|S||jd|S)a watch the funding rate for multiple markets https://docs.cloud.coinbase.com/intx/docs/websocket-channels#funding-channel :param str[] symbols: a 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 Nz1 watchFundingRates() requires an array of symbolsrrW)rrXrdr safe_string newUpdatesfilter_by_array fundingRates)rNrSrz fundingRaterWresults rPwatch_funding_ratesz)coinbaseinternational.watch_funding_ratess ?#DG.a$abb b!!!!!!!!! 33FGVLLLLLLLL !!+x88 ? F(F6NM##D$5xIIIrQcK|d{Vd}||ddd\}}|||g|d{VS)aU 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 ` Nrr3r4)rdhandle_option_and_paramsr)rNrWrzr3s rP watch_tickerz"coinbaseinternational.watch_tickersy!!!!!!!!!77 yZbcc^^GfXv>>>>>>>>>rQc|j}g}tdt|D]4}||}|j|}|dr||5|S)Nractive)rSrjrgmarketsrk)rNrSoutputrrWrls rPrfz(coinbaseinternational.get_active_symbolssg,q#g,,'' & &AQZF\&)Fh & f%%% rQcK|d{Vd}||ddd\}}||||d{V}|jri}|||d<|S||jd|S)ab 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'r3r4rW)rdrrrrtickers)rNrSrzr3tickerrs rP watch_tickersz#coinbaseinternational.watch_tickerss!!!!!!!!!77PY[cdd~~gw???????? ? F'-F6(# $M##DL(GDDDrQclientc||}||d}||||||dz|dzdSNr3rVrW)parse_ws_instrumentrresolverNrmessagerr3s rPhandle_instrumentz'coinbaseinternational.handle_instrumentsh4))'22""7I66vw'''vw~x0@@AAAAArQrc ||d}||d}|id|d|||dd||d|ddd dd dd dd dd dddddddddddddddd||dd||dddS)N product_idr_inforW-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)rNrrlrrs rPrz)coinbaseinternational.parse_ws_instrumentstl##FL99##FF33! F! d&&x==!  11!   ! D ! 4 !  4!  !  4!  !  D!  D!  T!  D!  T! d!! " $#! $,,V5MOfgg--f6LNcdd)! ! !    rQc||}||d}||||||dz|dzdSr)parse_ws_tickerrrrs rP handle_tickerz#coinbaseinternational.handle_tickerlsh2%%g..""7I66vw'''vw~x0@@AAAAArQrlc||d}||d}|id|d|||d||d|d||dd ||d d ||d d ||dddddddddddddddddddddddS)Nr_rrrWrrr bid_pricerbid_qtyr ask_pricerask_qtyrrrrrrrrr)rrr)rrrr safe_number)rNrrlrrs rPrz%coinbaseinternational.parse_ws_tickers##FF33##FL99! F! d&&x88!  11!   ! 4##FK88 ! ))&)<< !  4##FK88!  ))&)<<!  D!  4!  D!  T!  D!  d!  $! t!! " D#! $!)! ! !    rQr< timeframesincelimitcK|d{V||}|d}||jdi}||||}|||g|d{V} |jr| ||}|| ||ddS)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 NrWrErT) rdrl safe_dictrIrrrgetLimitfilter_by_since_limit) rNrWrrrrzrlrIintervalohlcvs rP watch_ohlcvz!coinbaseinternational.watch_ohlcvs!!!!!!!!!V$$!..|R@@##GY BBnnXx@@@@@@@@ ? 2NN6511E))%q$GGGrQc||d}||d}||}|d}||}||j|i|j|<||j||9||jdd}t||j||<|j||} ||dg} tdt| D]5} | | } | | |} | | 6| | |dz|zdS) Nr3rrW OHLCVLimitr5candlesrrV)r safe_marketfind_timeframe safe_valueohlcvs safe_integerrIr safe_listrjrg parse_ohlcvrkr)rNrrr{rrlrWrrstoreddatartickparseds rP handle_ohlcvz"coinbaseinternational.handle_ohlcvse&&&w :: ##G\::!!(++!'' 44 "oodk62FF F ??4;v. : : B%%dlL$GGE-B5-I-IDK  *V$Y/~~gy"55q#d))$$ " "A7D%%dF33F MM& ! ! ! !v{T1F:;;;;;rQcDK||g|||d{VS)a/ 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)rNrWrrrzs rP watch_tradesz"coinbaseinternational.watch_tradess622F8UE6RRRRRRRRRrQcjK|d{V||dddd}|d||d{V}|jrB||d}||d}|||}||||ddS)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 ` NFTMATCHrrWr)rdrhrrrrrr)rNrSrrrztradesfirst tradeSymbols rPrz.coinbaseinternational.watch_trades_for_symbolss!!!!!!!!!%%gtUD$GG..wHHHHHHHH ? 8NN61--E**5(;;KOOK77E))&% TRRRrQc||}|d}||d}||jvr5||jdd}t |}||j|<|j|}||||j|<||||||dz|dz|S)NrWr3rBr5rV)parse_ws_traderrrrIrrkr) rNrrtraderWr3rtradesArrayCache tradesArrays rP handle_tradez"coinbaseinternational.handle_trade s##G,,x""7I66$+%%%%dlM4HHE)%00 "2DK k&) 5!!!) F{G,,,{GdNU8_$DEEErQc||dd}||d}||||dd||||||d||dd||d||dddd S) NrWrr_match_id agressor_side trade_price trade_qty) rrXorderrrrWr]side takerOrMakerpriceamountcostfee)rr safe_traderrsafe_string_lower)rNrrlrrs rPrz$coinbaseinternational.parse_ws_trade(s%%eX|DD##E622""5*5511 &&x88**5/BB %%e];;&&uk::     rQcBK||g||d{VS)aG 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)rNrWrrzs rPwatch_order_bookz&coinbaseinternational.watch_order_bookGs466xOOOOOOOOOrQctK|d{V|d||d{VS)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)rdr)rNrSrrzs rPrz2coinbaseinternational.watch_order_book_for_symbolsTsV!!!!!!!!!,,XwGGGGGGGGGrQc||d}||d}||}||d}||d}||jvr:||jdd}|i||j|<|j|} |dkr4|||ddd } | | || d <n-||d g} | | | ||d | d <|| d<| || d<| |j|<| | |dz|zdS)Nr]rr_r3watchOrderBookLimitr5SNAPSHOTbidsasksrWchangessequencernrrrV) rr orderbooksrrI order_bookparse_order_bookresetr handle_deltasrr) rNrrr]rrWrr3r orderbookparsedSnapshotrs rPhandle_order_bookz'coinbaseinternational.handle_order_bookbsH00##G\::!!(++##GV44""7I66$/))%%dl4I4PPE&*oob%&@&@DOF #OF+ :  !227FD&RXYYN OON + + +"(Ih  nnWi<+h/0{GdN[5J$JKKKKKrQc||d}|dkrdS||d}||d} |jdz|z|z}||jd||||jd||t |#t $r}||Yd}~nd}~wwxYwd S) Nr]REJECTFreasonr rFbroadT)rrXthrow_exactly_matched_exceptionrJthrow_broadly_matched_exceptionr Exceptionreject)rNrrr]r.errMsgfeedbackes rPhandle_error_messagez*coinbaseinternational.handle_error_messages00 8  5!!'844!!'955 w}v-6H  0 01I6S[ \ \ \  0 01I6S[ \ \ \)) )    MM!         ts A#B// C9CCc|||rdS||dd}|j|j|j|j|j|j|jd}||d}|dkr%||d}t|| ddkr| ||| ||}||||dSdS) Nr3) SUBSCRIPTIONS INSTRUMENTSr4rr FUNDINGrr]errorrCANDLES) r8rr(rrrrr+rfindrr)rNrrr3methodsr] errorMessagemethods rPhandle_messagez$coinbaseinternational.handle_messages  $ $VW 5 5  F""7Ir::!<1(&,/&  00 7??++GY??L -- - << " "R ' '   fg . . .'22   F67 # # # # #  rQr&)0__name__ __module__ __qualname__rrMrmr rrr rrrr rrfr rrrdictrrobjectrrrrlistrrrrrrrr rrrr"rr(r+rr8rE __classcell__)rOs@rPrrs8 #8 8 8 8 8 8 t=A3_3_C3_'3_3_3_3_jFJRT(l(lS(l7(l(l(l(lT<> > >s >+ > > > ><@JJJ|JJJJ*68???F???? 6:"EE7EEEEE*BBBBB>M M $M M M M ^BFBBBB<% % f% f% % % % % N?CQUdhqsHHHH3H^aHx|~ByCHHHH."<6"<"<"<"@DB P PS P PS\ P P P PSW_a H H$s) HC Hfo H H H H8;8;8;t&&&4446L&LLLL86t.$$$$$$$rQr)ccxt.async_supportccxt ccxt.async_support.base.ws.cacherrruccxt.base.typesrrrrr r r r r rr!ccxt.async_support.base.ws.clientrtypingrccxt.base.errorsrrrr async_supportrr'rQrPrUs2 NNNNNNNNyyyyyyyyyyyyyyyyyyyyyyyyyy444444******000000......))))))y $y $y $y $y $D.Dy $y $y $y $y $rQ