E#iSSKrSSKJrJr SSKrSSKJrJrJ r J r J r J r J r JrJrJr SSKJr SSKJr SSKJr SSKJr SSKJr SS KJr SS KJr "S S \R6R85rg) N) ArrayCacheArrayCacheBySymbolById) AnyBoolIntOrder OrderBookStrStringsTickerTickersTrade)Client)List) ExchangeError)AuthenticationError)ArgumentsRequired) BadRequest) BadSymbolc ^\rSrSrS\4U4SjjrSrSS04Sjr/S04Sjr04S\ S\ 4S jjr S04S \ S\ 4S jjrSS04S\ S \S \S\\4SjjrSS04S \\ S \S \S\\4SjjrSSS04S\S \S \S\\4SjjrSS04S \\ S \S \S\\4SjjrSS04S \\ S \S \S\\4SjjrSSS04S\S \S \S\\4SjjrS04S \\ S \S\4SjjrS04S\ S \S\4SjjrS\4SjrS\4SjrS&U4Sjjr Sr!S\4Sjr"S&Sjr#S\4Sjr$S&S\ 4U4Sjjjr%Sr&S r'S\4S!jr(S\4S"jr)S\S\*4S#jr+S\4S$jr,S%r-U=r.$)'coinbaseexchangereturnc>UR[[U]5SSSSSSSSSSSSSSS.SS0SS0S.SSSS .S .5$) 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/home/james-whalen/.local/lib/python3.13/site-packages/ccxt/pro/coinbaseexchange.pyr4coinbaseexchange.describes&6 F H#"&,0# $#)-+/ %$#)-!%$?N  $#!%3K   c2UR5 SnUR5n[U5S-U-nURUR U5UR UR 5[RS5nUURUURS.$)Nz/users/self/verifyGETbase64) timestampkey signature passphrase) check_required_credentialsnoncestrhmacencodebase64_to_binarysecrethashlibsha256apiKeypassword)r5pathrBpayloadr?s r7 authenticatecoinbaseexchange.authenticate6s '')# e*u$t+IIdkk'2D4I4I$++4VX_XfXfhpq ;;"--   r9NcR# UR5IShvN SnUn/nUb0URU5nUSUS-- nURUS5 URSSnSU;aUS-nSUU/S.n UR X5n UR XX5IShvN $NN7f) N:idr)rr?? subscribetype product_idschannels) load_marketsmarketappendr0extendwatch) r5namesymbolmessageHashStartparamsrZ messageHash productIdsurlrTrequests r7rTcoinbaseexchange.subscribeCs!!!&   [[(F 3- -K   fTl +iit$ & )C% ++i0ZZ'GGG) "(Hs"B'B#BB'B%B'%B'c# UR5IShvN SnURU5n/n/n[S[U55HFnX(n UR U 5nUR US5 UR US-US-5 MH UR SSn SU;aU S-n S UU/S .n URX5n URXX5IShvN $NN7f) NrrRrQr_r)rr?rSrTrU) rYmarket_symbolsrangelenrZr[r0r\watch_multiple) r5r^symbolsr`rarZ messageHashesrcir_rdrTres r7subscribe_multiple#coinbaseexchange.subscribe_multipleZs!!!%%g.  q#g,'AZF[[(F   fTl +  !1C!7&:J!J K ( iit$ & )C% ++i0((WTTT- ",Us"C$C CC$C"C$"C$r_cF# SnURX1X25IShvN $N7f)ah 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)rT)r5r_rar^s r7 watch_tickercoinbaseexchange.watch_tickerss#^^D$????s !!rlcB# UR5IShvN [U5nUS:Xa[URS-5eSnSnUR XAXR5IShvN nUR (a 0nXgUS'U$UR URSU5$NN?7f)a 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 arrayrrr_)rYrjrrRro newUpdatesfilter_by_arraytickers)r5rlra symbolsLengthchannelrbrrresults r7 watch_tickerscoinbaseexchange.watch_tickers}s!!!G A DGG&XXY Y ..wUU ??F'-6(# $M##DLL(GDD " Vs"BBABB>BBsincelimitc# UR5IShvN URU5nSnURXQXT5IShvN nUR(aUR X5nUR XbUSS5$NgN<7f)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)rYr_rTrvgetLimitfilter_by_since_limit)r5r_r~rrar^tradess r7 watch_tradescoinbaseexchange.watch_tradessv!!!V$~~dDAA ??OOF2E))& TRR "Bs!BA>,BB;BBc# [U5nUS:Xa[URS-5eUR5IShvN UR U5nSnUR XaXd5IShvN nUR (a5URUS5nURUS5n URX5nURXrUSS5$NN`7f)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 symbolsNrr_r=T) rjrrRrYrhrorv safe_value safe_stringrr) r5rlr~rraryr^rfirst tradeSymbols r7watch_trades_for_symbols)coinbaseexchange.watch_trades_for_symbolssG A TWW'ggh h!!!%%g...tdKK ??OOFA.E**5(;KOOK7E))& TRR "Ls#=CC ,C,C -AC Cc # Uc[URS-5eUR5IShvN URU5nSnSnUR 5nUR XQX`R XG55IShvN nUR(aURX5nURXUSS5$NN<7f)a watches information on multiple trades made by the user :param str symbol: unified market symbol of the market trades were made in :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 ` Nz+ watchMyTrades() requires a symbol argumentusermyTradesr=T) rrRrYr_rNrTr\rvrr) r5r_r~rrar^rbauthenticationrs r7watch_my_trades coinbaseexchange.watch_my_tradess >#DGG.[$[\ \!!!V$ **,~~dKVAdee ??OOF2E))& TRR " f"/B>B:A B>?B<;B><B>c # URUSS5nUR5IShvN SnSnUR5nURXQX`R XG55IShvN nUR (a5UR US5n URU S5n URX5nURXUSS5$NN`7f) 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) rhrYrNror\rvrrrr) r5rlr~rrar^rbrrrrs r7watch_my_trades_for_symbols,coinbaseexchange.watch_my_trades_for_symbolss%%gtU;!!! **,..tk;;W]Knoo ??OOFA.E**5(;KOOK7E))& TRR "ps"'C C` NFrordersrr_r=T) rYrhrNror\rvrrrr) r5rlr~rrar^rbrrrrs r7watch_orders_for_symbols)coinbaseexchange.watch_orders_for_symbolss!!!%%gtU; **,..tk;;W]Knoo ??OOFA.E**5(;KOOK7E))& TRR " ps#C CAC &C'AC C c # Uc[URS-5eUR5IShvN URU5nSnSnUR 5nUR XQX`R XG55IShvN nUR(aURX5nURXUSS5$NN<7f)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) rrRrYr_rNrTr\rvrr) r5r_r~rrar^rbrrs r7 watch_orderscoinbaseexchange.watch_orderss >DGG&HHI I!!!V$ **,~~dKVAdee ??OOF2E))& TRR " frc2# [U5nUS:Xa[URS-5eSnUR5IShvN UR U5nUR U5n/n[ SU5HnXhn URUS-U -5 M URSSn SUU/S .n URX5n UUUUS .n UR5nURXURX5X}5IShvN nUR5$NN7f) 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 symbolslevel2NrQr)rrTrU)rbrl marketIdsr) rjrrRrYrh market_idsrir[r0r\rNrkr)r5rlrraryr^rrmrnmarketIdrdrTre subscriptionr orderbooks r7watch_order_book_for_symbols-coinbaseexchange.watch_order_book_for_symbols s2G A TWW'jjk k!!!%%g.OOG,  q-(A |H  h!6 7)iit$$ ++i0"  **,--c$++gBfhuEE   1 ".Es$?DDBD?DDc# SnUR5IShvN URU5nUSnUS-US-nURSSnSUS/U/S .nURX5n UUUSUS .n UR 5n UR XvURX5Xj5IShvN n U R 5$NN7f) 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_rQrRr)rrTrU)rbr_rr)rYrZr0r\rNr]r) r5r_rrar^rZrbrdrTrerrrs r7watch_order_book!coinbaseexchange.watch_order_book3s!!!V$!Sj6$</ iit$t   ++i0&t   **,**St{{77[]hww   / ",xs"CCBC+C,CCclientc^URUS5nUbURU5nUSnSnUS-U-nURURU5nUc6UR UR SS5n [ U 5nXRU'URU5 URX5 U$)N product_idr_rrQr,r+) rparse_ws_traderr safe_integerr1rr[resolve) r5rmessagertrader_rVrb tradesArrayr,s r7 handle_tradecoinbaseexchange.handle_tradeUs##G\:  ''0E8_FD*x/K//$++v>K""// mTR (5 &1 F#   u % NN; 4r9c$URUS5nUbzURU5nSnUS-U-nURnUc.URURSS5n[ U5nXplUR U5 URXv5 U$)NrrrQr.r+)rrrrr1rr[r) r5rrrrrVrbrrs r7handle_my_trade coinbaseexchange.handle_my_tradevs##G\:  ''0ED*x/K--K"))$,,N4U; +   u % NN; 4r9c>[[U] U5nSnSnSU;aSnSUS'URUS5nO4SUS'URUS5nUSnUR S S S .Xf5US'U(aS OS nUR X5US'UR US5nUSnSn USbUbURUS5n X-n UU US.US'U$)NFmaker_fee_rateTmaker takerOrMakertakertaker_fee_ratesidesellbuy)rrmaker_order_idtaker_order_idorderr_quotecost)ratercurrencyfee)r3r parse_trade safe_numberrrZ) r5rrZparsedfeeRateisMaker currentSideidKey feeCurrencyfeeCostrr6s r7rcoinbaseexchange.parse_ws_tradesf':5A u $G%,F> "&&u.>?G%,F> "&&u.>?G!.K!--/)F6N%, 1A**58wVH-.Wo  6N &W-@##FF3DnG# u  r9c0SSS.nURX!S5$)Nclosedcanceled)filledropen)r)r5statusstatusess r7parse_ws_order_status&coinbaseexchange.parse_ws_order_statuss$" &99r9cURnUc.URURSS5n[U5nX0lUR US5nUR US5nUGbSU-nUR U5nUR US5n UR US5n UR US5n URn UR U RU05n UR X5nUcURXU 5nUc4URU5nU RU5 URX5 gURUS 5nUR US 05nURUS 5nUbUU:GaUS :XGa6URU5nUS c/US 'US RU5 US US'SnSnUS n[S[U55H2nUUnURUUS5nURUUS5nM4 US:aUU- US'UUS'USb$US==US- ss'USbUSUS- US'UScSUSSS.US'USSb-USSb$URUSSUSS5USS'U RU5 URX5 gUS:XdUS:XaUR!US U5nURU5n[#UR%55n[S[U55HnUUnUUcMUUUU'M U RU5 URX5 gggg)Nr-r+rVrzorders:order_idrrsequenceinfomatchrr=lastTradeTimestamprramountaverager remainingrr)rrreceiveddone)rrr1rr safe_symbolrhashmap safe_value_2parse_ws_orderr[rrrirjsumr\listkeys)r5rr currentOrdersrrVrrbr_orderId makerOrderId takerOrderIdrpreviousOrders previousOrderrr previousInfopreviousSequencer totalCost totalAmountrrn tradeEntryrrrr>s r7 handle_ordercoinbaseexchange.handle_orders^  %%dllM4HE259M'K0##G\:  #h.K%%h/F&&w ;G++G5EFL++G5EFL[[F!__V^^VRHN OONDM$ $ 1 1.P\ ] $,,W5 f%v3,,WjA#}fbI #'#4#4\:#N $,(=M2Mw $ 3 3G <(2:68M(3%h/66u=>CK>P &:;$% &' !.x!8!&q#f+!6A)/J(,Jv)(3uXF3,X6B=J8=TWdemWn=n k :(/7(),1%L,D4M%0*%08D5QVURUS5nUc[[U]X5$URUS5nUR XBS5nUR URUS55nURUS5nUR 0SU_SU_SURU5_S URUS 5_S URUS 5_S URUS5_SURUS5_SURUS5_SURUS5_SS_SURUS5_SU_SU_SS_SS_SS_SS_URUS5SUS.E5$) NrVr-rrr_r=rhighhigh_24hlowlow_24hbidbest_bid bidVolume best_bid_sizeaskbest_ask askVolume best_ask_sizevwapropen_24hcloselast previousClosechange percentager volume_24h) baseVolume quoteVolumer)rr3rrrr  safe_tickerr) r5rrrZrVrr_r=r'r6s r7rcoinbaseexchange.parse_tickers,/ <)4=fM M##FL9!!(C8NN4#3#3FF#CD 0! f! !   Y/!  D$$VZ8 ! 4##FI6 ! 4##FJ7 !  ))&/B!  4##FJ7!  ))&/B!  D!  D$$VZ8!  T!  D!  T!  d! $!! " t#! $**6<@)!   r9cnURUS5nURUS5nURX45 g)Nr)rstore)r5booksidedeltarrs r7 handle_deltacoinbaseexchange.handle_deltas2  *!!%+u%r9cd[S[U55HnURXU5 M g)Nr)rirjr5)r5r3deltasrns r7 handle_deltascoinbaseexchange.handle_deltass)q#f+&A   hq 2'r9cURUS5nURUS5nURUSS5nUSnSnUS-U-nURURU05n UR U S5n US:XaUR 0U 5UR U'UR Un URU S URUS /55 URU S URUS /55 SU S 'SU S 'XkS'URX5 gUS :XaUR Un URURUS55n URUS/5n S S S.n[S[U 55HfnXnURUS5nURUU5nURUS5nURUS5nU UnURUU5 Mh XS 'URU 5U S 'URX5 gg)NrVrrr_rrQrsnapshotasksbidsr=rl2updaterchanges)rrrr1)r safe_marketr subscriptionsr order_book orderbooksr9rr rirjrr2r)r5rrrVrrZr_r^rbrrrr=r@sidesrnr)r>rrrr3s r7handle_order_book"coinbaseexchange.handle_order_books40##G\:!!(D#6!Sj8+ v';';["M !!,8 : &*oob%&@DOOF #/I   y0$//'6SU2V W   y0$//'6SU2V W%)Ik "$(Ij !"(h  NN9 2 Z /It'7'7'HIIoogy"=GE1c'l+ &&vq1''s3((3))&!4$T?uf-,&/k "$(LL$;Ij ! NN9 2% r9cU$N)r5rrs r7handle_subscription_status+coinbaseexchange.handle_subscription_status>s r9cURUS5nURUS5nUS:Xa[SU-5e[URS-U-5e![anUR U5 SnAgSnAff=f)NrrzAuthentication FailedzAuthentication failed:  T)rrrrR Exceptionreject)r5rrerrMsgrerrors r7handle_error_message%coinbaseexchange.handle_error_messageLs~ !!'95!!'84 00)*Cf*LMM#DGGcMF$:;;  MM%  s/A A:A55A:c  URUS5nURURURURURURURURUR S. n[ UR5S- nURUS- S:HnURXC5nUcCUS:Xa<U(a#URX5 UR X5 gURX5 ggU"X5 g)NrV) r<r?rTrrrrr)rrSrr1rSr) rrGrLrrrTrjrdrrr)r5rrrVmethodslength authenticatedmethods r7handle_messagecoinbaseexchange.handle_messagegs0....88(())%%''%%..  VZZ1$ 6A:.#5 / >w ((9%%f6%%f6  6 #r9)rrrJ)/__name__ __module__ __qualname____firstlineno__rr4rNrTrorCr rsr r r|rrrrrr rrrrrr rrrrrrrrrrrr5r9rGrLrrTr[__static_attributes__ __classcell__)r6s@r7rrs # B  ,0$rH.68$WYU268@@F@6:"E7EE*<@d[]SSSSSbfglbmS"OSaenpSd3iSS[^SuyzvAS,37TX\egSCSsSRUSlpqvlwS*RVdhqsScS3S^aSx|~CyDS*OSaenpSd3iSS[^SuyzvAS*04$UYbdSSCSsSimnsitS*SW_a$!$s)$!C$!fo$!L@DB !S ! !S\ !D6B f Qf:S<6S2 62 2 h& 3=3=3~  6t6$V$$r9r)ccxt.async_supportccxt ccxt.async_support.base.ws.cacherrrHccxt.base.typesrrrrr r r r r r!ccxt.async_support.base.ws.clientrtypingrccxt.base.errorsrrrrr async_supportrrKr9r7rksH Obbb4*0.'&l $t))::l $r9