E#i}SSKrSSKJrJr SSKrSSKJrJrJ r J r J r J r J r JrJrJrJr SSKJr SSKJr SSKJr SSKJr SSKJr "S S \R4R65rg) N) ArrayCacheArrayCacheByTimestamp) AnyBoolIntMarket OrderBookStringsTickerTickers FundingRate FundingRatesTrade)Client)List) ExchangeError)AuthenticationError) NotSupportedc B^\rSrSrS\4U4SjjrS04S\S\4SjjrS04S\S\4Sjjr 04S \S\ 4S jjr 04S\ \S\ 4S jjr04S \S\4S jjrS rS04S\S\4SjjrS\4SjrS*S\4SjjrS\4SjrS*S\S\S\4SjjrSSS04S \S\S\S\S\ \4 SjjrS\4SjrSS04S \S\S\S\ \ 4Sjjr!SS04S\ \S\S\S\ \ 4Sjjr"Sr#S*Sjr$S04S \S\S\%4S jjr&S04S\ \S\S\%4S!jjr'S"r(S#r)S$r*S%r+S\4S&jr,S\S\-4S'jr.S(r/S)r0U=r1$)+coinbaseinternationalreturnc>UR[[U]50SS_SS_SS_SS_SS_SS_SS _S S _S S_S S _S S _SS _SS _SS_SS _SS _SS _S S S S S S S.ESS0SS0S.SS0SSSSSSSSS S!.S".S#S$[00S%.5$)&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/home/james-whalen/.local/lib/python3.13/site-packages/ccxt/pro/coinbaseinternational.pyrMcoinbaseinternational.describesw&;T K Mdt(!$  +D  t  d'u(!%  u!" #$#(%* %!&"'#(/6B9 x  $#!%.03,-+ ",.Ae7P 7 7 Nnamesymbolsc*# UR5IShvN UR5 SnUnSnUcUR5n[U5n/nUS:aZUR U5n UR U 5n U n[ S[U 55Hn URUS-X-5 M O+US:Xa%URUS5nUS-US-nUS/nURSSn U c[URS -5e[UR55n XR-S -UR-nUR!UR#U5UR%UR&5[(R*S 5nS U/U URURUS .nUbUUS'US:a+UR-XUR/UU5U5IShvN $UR1XUR/UU5U5IShvN $GNN2N 7f)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_idsrangeappendmarketrHrrYstrnonceapiKeypasswordhmacencodebase64_to_binarysecrethashlibsha256watch_multipleextendwatch)rNrSrTparamsrm messageHash productIds symbolsLength messageHashes parsedSymbols marketIdsiurl timestampauthrc subscribes rPrcoinbaseinternational.subscribeMs !!! '')  ?--/GG  1  //8M 6I"J1c-01$$TD[=3C%CD2a [[,F+x(88K ,Jiit$ ;tww)SST T % ;;&3dmmCIIdkk$/1F1Ft{{1SU\UcUcemn ;;--"   !'1Im $ 1 ,,SYX^A_anoo oZZ$++i2PR]^^^O "Lp^s4HH GHH*HHHHHc# UR5IShvN UR5 URU5(a URnOUR U5n/n/n[ S[ U55HOnURX&5nURU5nURU5 URUS-U-5 MQ URSSn U c[URS-5eURUR55n XR-S-UR -n UR#UR%U 5UR'UR(5[*R,S5n S U UU/URUR U S .n UR/XUR1X5U5IShvN $GNN7f) 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 NrrWr1rrZr[r\r])r^r`rdr_rarbrc)rerfis_emptyrTrirkrh market_idrXrlrHrrYnumber_to_stringsecondsrprqrrrsrtrurvrwrxry)rNrSrTr{rr}rmarketIdrXrrrrcrs rPsubscribe_multiple(coinbaseinternational.subscribe_multiples!!! '') == ! !llG))'2G  q#g,'A~~gj1H[[*F   h '  v!5 6 ( iit$ ;tww)SST T))$,,.9 ;;&3dmmCIIdkk$/1F1Ft{{1SU\UcUcemn %;;--" ((T[[=[]jkkk9 "8ls"G GF,G G G  G rXcz# UR5IShvN URSU/U5IShvN $N N7f)aD 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)rer)rNrXr{s rPwatch_funding_rate(coinbaseinternational.watch_funding_rates9!!!^^FVHf=== "=s;7;9;;c# UR5IShvN URSX5IShvN nURUS5nUR(a0nX5U'U$UR UR SU5$NfNN7f)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 NrrX)rer safe_string newUpdatesfilter_by_array fundingRates)rNrTr{ fundingRaterXresults rPwatch_funding_rates)coinbaseinternational.watch_funding_ratess{!!! 33FGLL !!+x8 ??F(6NM##D$5$5xII "Ls BA=BA?A B?Bc# UR5IShvN SnURUSSS5up2URX1/U5IShvN $N7N7f)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/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)rehandle_option_and_paramsr)rNrXr{r3s rP watch_ticker"coinbaseinternational.watch_tickersW!!!77 yZbc^^GXv>>> "?s!AA2A A AAcURn/n[S[U55H3nXnURUnUS(dM"UR U5 M5 U$)Nractive)rTrkrhmarketsrl)rNrToutputrrXrms rPrg(coinbaseinternational.get_active_symbolssX,,q#g,'AZF\\&)Fh f% (  rRc# UR5IShvN SnURUSSS5up2URX1U5IShvN nUR(a 0nXEUS'U$UR UR SU5$NoN?7f)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/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'r3r4rX)rerrrrtickers)rNrTr{r3tickerrs rP watch_tickers#coinbaseinternational.watch_tickerss!!!77PY[cd~~g?? ??F'-6(# $M##DLL(GDD "@s!B B1B B >B B clientcURU5nURUS5nURX45 URX4S-US-5 gNr3rWrX)parse_ws_instrumentrresolverNrmessagerr3s rPhandle_instrument'coinbaseinternational.handle_instrumentsL4))'2""7I6v'v~x0@@ArRrc `URUS5nURUS5nUR0SU_SURX2S5_SURU5_SU_SS_S S_S S_S S_S S_S S_SS_SS_SS_SS_SS_SS_SS_SUR USS5UR USS5S.E5$)N product_idr`inforX-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)rNrrmrrs rPr)coinbaseinternational.parse_ws_instrumentsQl##FL9##FF3! F! d&&x=!  1!   ! D ! 4 !  4!  !  4!  !  D!  D!  T!  D!  T! d!! " $#! $,,V5MOfg--f6LNcd)!   rRcURU5nURUS5nURX45 URX4S-US-5 gr)parse_ws_tickerrrrs rP handle_ticker#coinbaseinternational.handle_tickerisL2%%g.""7I6v'v~x0@@ArRrmcURUS5nURUS5nUR0SU_SURXB5_SURU5_SU_SUR US5_S UR US 5_S UR US 5_S UR US5_SS_SS_SS_SS_SS_SS_SS_SS_SS_SSSS.E5$)Nr`rrrXrrr bid_pricerbid_qtyr ask_pricerask_qtyrrrrrrrrr)rrr)rrrr safe_number)rNrrmrrs rPr%coinbaseinternational.parse_ws_tickers`##FF3##FL9! F! d&&x8!  1!   ! 4##FK8 ! ))&)< !  4##FK8!  ))&)<!  D!  4!  D!  T!  D!  d!  $! t!! " D#! $!)!   rRr< timeframesincelimitcn# UR5IShvN URU5nUSnURURS05nUR XrU5nUR X/U5IShvN n UR (aU RX5nURXUSS5$NN<7f)aZ 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 NrXrErT) rerm safe_dictrIrrrgetLimitfilter_by_since_limit) rNrXrrrr{rmrIintervalohlcvs rP watch_ohlcv!coinbaseinternational.watch_ohlcvs!!!V$!..|R@##G BnnXx@@ ??NN61E))%q$GG " As"B5B1AB56B37;B53B5cURUS5nURUS5nURU5nUSnURU5nURURU05URU'URURUU5c8UR UR SS5n[U5URUU'URUUn URUS/5n [S[U 55H)n Xn URX5n U RU 5 M+ URXS-U-5 g) Nr3rrX OHLCVLimitr5candlesrrW)r safe_marketfind_timeframe safe_valueohlcvs safe_integerrIr safe_listrkrh parse_ohlcvrlr)rNrrr|rrmrXrrstoreddatartickparseds rP handle_ohlcv"coinbaseinternational.handle_ohlcvs0&&&w : ##G\:!!(+!'' 4 "oodkk62F F ??4;;v. : B%%dllL$GE-B5-IDKK  *V$Y/~~gy"5q#d)$A7D%%d3F MM& !% vT1F:;rRcF# URU/X#U5IShvN $N7f)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)rNrXrrr{s rP watch_trades"coinbaseinternational.watch_tradess$22F8U6RRRRs !!cT# UR5IShvN URUSSSS5nURSX5IShvN nUR(a5UR US5nUR US5nUR Xs5nURXRUSS5$NN`7f)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 ` NFTMATCHrrXr)rerirrrrrr)rNrTrrr{tradesfirst tradeSymbols rPr.coinbaseinternational.watch_trades_for_symbolss!!!%%gtUD$G..wHH ??NN61-E**5(;KOOK7E))& TRR "Hs"B(B$.B(B&AB(&B(cURU5nUSnURUS5nX@R;a6URURSS5n[ U5nXpRU'URUnUR U5 XRU'URX5 URXS-US-5 U$)NrXr3rBr5rW)parse_ws_traderrrrIrrlr) rNrrtraderXr3rtradesArrayCache tradesArrays rP handle_trade"coinbaseinternational.handle_trade s##G,x""7I6++%%%dllM4HE)%0 "2KK kk&) 5!) F{,{dNU8_$DErRcFURUSS5nURUS5nURUURUS5SURU5UUR X25SUR US5SURUS5URUS5SSS. 5$) NrXrr`match_id agressor_side trade_price trade_qty) rrYorderrrrXr^side takerOrMakerpriceamountcostfee)rr safe_traderrsafe_string_lower)rNrrmrrs rPr$coinbaseinternational.parse_ws_trade%s%%eX|D##E62""5*51 &&x8**5/B %%e];&&uk:   rRcD# URU/X#5IShvN $N7f)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 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)rNrXrr{s rPwatch_order_book&coinbaseinternational.watch_order_bookDs"66xOOOOs   cv# UR5IShvN URSX5IShvN $NN7f)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)rer)rNrTrr{s rPr2coinbaseinternational.watch_order_book_for_symbolsQs7!!!,,XwGGG "Gs959799cURUS5nURUS5nURU5nURUS5nURUS5nXPR;a<URURSS5nUR 0U5URU'URUn US:Xa*UR X%SSS 5n U RU 5 XYS 'O$URUS /5n URX5 URUS 5U S 'XiS'URU5U S'XRU'URXS-U-5 g)Nr^rr`r3watchOrderBookLimitr5SNAPSHOTbidsasksrXchangessequencerorrrW) rr orderbooksrrI order_bookparse_order_bookresetr handle_deltasrr) rNrrr^rrXrr3r orderbookparsedSnapshotr$s rPhandle_order_book'coinbaseinternational.handle_order_book_sMH0##G\:!!(+##GV4""7I6//)%%dll4I4PE&*oob%&@DOOF #OOF+ : !227D&RXYN OON +"(h nnWi+h/0{dN[5J$JKrRcURUS5nUS:wagURUS5nURUS5nURS-U-U-nURURSXF5 UR URSXF5 [ U5e![ anURU5 SnAg SnAff=f) Nr^REJECTFreasonr rFbroadT)rrYthrow_exactly_matched_exceptionrJthrow_broadly_matched_exceptionr Exceptionreject)rNrrr^rGerrMsgfeedbackes rPhandle_error_message*coinbaseinternational.handle_error_messages0 8 !!'84!!'95 ww}v-6H  0 01I6 \  0 01I6 \) )  MM!   sAB C'B==CcURX5(agURUSS5nURURURUR UR URURS.nURUS5nUS:XaURUS5n[U5eURS5S:aURX5 URXC5nUb U"X5 gg) Nr3) SUBSCRIPTIONS INSTRUMENTSr4rrFUNDINGrr^errorrCANDLES) rQrr?rrrr-rCrfindrr)rNrrr3methodsr^ errorMessagemethods rPhandle_message$coinbaseinternational.handle_messages  $ $V 5 5 ""7Ir:!<<11((&&,,//&& 0 7?++GY?L - - << "R '   f .2   6 # rRr>r=)2__name__ __module__ __qualname____firstlineno__rrMrnr rrr rrrrr rrgr rrrdictrrobjectrrrlistrrrrrrrr rrr-r7r*r?rCrrQr___static_attributes__ __classcell__)rOs@rPrrs}8 #8 t=A3_C3_'3_jFJRT(lS(l7(lT<> >s >+ >DFJcJ,J&68??F? 6:"E7EE*BB>M $M ^BFB<% f% f% % N?CQUdhqsHHH3H^aHx|~ByCH."<6"@DB PS P PS\ PSW_a H$s) HC Hfo H8;t&46L&L86t.$$rRr)ccxt.async_supportccxt ccxt.async_support.base.ws.cacherrrvccxt.base.typesrrrrr r r r r rr!ccxt.async_support.base.ws.clientrtypingrccxt.base.errorsrrr async_supportrr>rRrPrrsE Nyyyy4*0)w $D..DDw $rR