E#i-SSKrSSKJr SSKrSSKJrJrJrJ r J r J r J r J r Jr SSKJr SSKJr SSKJr "SS\R(R*5rg) N)ArrayCacheBySymbolById) AnyIntOrder OrderBookStrStringsTickerTickersTrade)List) ExchangeError)ArgumentsRequiredc ^\rSrSrS\4U4SjjrS04S\S\4SjjrS+S\S\S\4S jjr S04S\S\S \ 4S jjr S04S\S\S\S \ 4S jjr S\S \ \4Sjr04S\S\4Sjjr04S\S\4SjjrS04S \ S\4SjjrS04S \ S\4SjjrSrS+SjrSS04S\S\S\S\ \4Sjjr04S\S\4SjjrSS04S \ \S\S\S\ \4Sjjr04S \ \S\4SjjrSSS04S\S\S\S\ \4SjjrS04S\S\4Sjjr S04S\S\S\!4Sjjr"04S\S\4Sjjr#S04S \ \S\S\!4S jjr$S!r%S"r&S+S#jr'S$r(S%r)S&r*S'r+S(r,S)r-S*r.U=r/$),coinbasereturnc >UR[[U]50SS_SS_SS_SS_SS_SS_S S_S S_S S_S S_S S_SS_SS_SS_SS_SS_SS_SSSSSSSSS.ESSS00SSSSSS.S.S.5$)NwsTcancelAllOrdersWsFcancelOrdersWs cancelOrderWs createOrderWs editOrderWsfetchBalanceWsfetchOpenOrdersWs fetchOrderWs fetchTradesWs watchBalance watchMyTrades watchOHLCVwatchOrderBookwatchOrderBookForSymbols watchOrders watchTicker) watchTickers watchTradeswatchTradesForSymbols unWatchTickerunWatchTickers unWatchTrades unWatchOrdersunWatchTradesForSymbolsapiz$wss://advanced-trade-ws.coinbase.combidsasks)bidoffer) tradesLimit ordersLimit myTradesLimitsides)hasurlsoptions) deep_extendsuperrdescribe)self __class__s K/home/james-whalen/.local/lib/python3.13/site-packages/ccxt/pro/coinbase.pyr=coinbase.describesEh > @d#U!%      u !%$U  e!$+D t!"t#$!%#)-!%"&!%!%+/38@ $#!%!# C*C * * Nname isPrivatec# UR5IShvN SnUn/n[U[5(a<URU5nUR U5n U nUS-SR U5-nO"UbUR U5nUS-U-nUS/nURSSn SUUS.n U(a URXRX55n URXX5IShvN $NN7f) 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_idsjoinmarketr9extendcreate_ws_authwatch) r>rCrDsymbolparamsrT messageHash productIdssymbols marketIdsurlrIs r@rIcoinbase.subscribe>s!!!  fd # #))&1G0I"J%,sxx/??K  [[(F+.K ,Jiit$%   I/B/B4/TUIZZ)III1 "0Js"C1C-CC1(C/)C1/C1topicc6# UR5IShvN URURSS5(a[URS-5eSURS'SnUnSU-n/n[ U[ 5(aSURU5n URU 5n U nUS-SRU5-nUS-SRU5-nO*Ub'URU5nUS-U-nUS-U-nUS /nURS S n S UUS .n U/U/USU/S.n U(a URXRX(55n XRS'URXXU 5IShvN nSURS'SURS'U$GN~N'7f)a @ignore unSubscribes to a websocket channel https://docs.cloud.coinbase.com/advanced-trade-api/docs/ws-overview#subscribe :param str topic: unified topic :param str name: the name of the channel :param boolean isPrivate: whether the channel is private or not :param str [symbol]: unified market symbol :returns dict: subscription to a websocket channel NunSubscriptionPendingFX another unSubscription is pending, coinbase does not support concurrent unSubscriptionsT unsubscribe:rFrGrHr.r unsubscriberJ messageHashessubMessageHashesr`rer\unSubscription)rN safe_boolr:rrHrOrPrQrRrSrTr9rUrVrW)r>r`rCrDrXrTwatchMessageHashunWatchMessageHashr[r\r]r^message subscriptionress r@ un_subscribecoinbase.un_subscribees!!! >>$,,(? G G+E!EF F04 ,-+d2 fd # #))&1G0I"J/$6&9II !3d!:SXXf=M!M   [[(F#d{V3 !3d!:V!C  ,Jiit$"%  11!1 2x   kk'+>+>t+PQG)5 %&JJsUabb05 ,-)- %& O "Hcs"FFEF/F0%FFr\c# UR5IShvN /n/nURUSS5n[S[U55HEnX7nUR U5n U Sn UR U 5 UR US-U-5 MG UR SSn SUUS .n U(a URXRX55n URXX5IShvN $NN7f) 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 NFrrHrFr.rrIrJ) rNrQrangelenrTappendr9rUrVwatch_multiple) r>rCrDr\rYr[rgirXrTmarketIdr^rIs r@subscribe_multiplecoinbase.subscribe_multiples!!!  %%gtU;q#g,'AZF[[(Fd|H   h '  v!5 6 ( iit$%  I/B/B4/TUI((YVVV% "$Ws"C-C)C C-$C+%C-+C-c# URURSS5(a[URS-5eSURS'UR 5IShvN /n/n/nUR USS5n[ S[U55H_n XIn URU 5n U Sn URU 5 URUS-U -5 URS U-S-U -5 Ma URS S n S UUS .nU(a URXRX&55nUUUSUS.nXRS'URXXU5IShvN nSURS'SURS'U$GN&N'7f)a @ignore unsubscribes to a websocket channel https://docs.cloud.coinbase.com/advanced-trade-api/docs/ws-overview#subscribe :param str topic: unified topic :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 rbFrcTNrrHrFrdr.rrerJrfri)rjr:rrHrNrQrsrtrTrur9rUrVrv)r>r`rCrDr\rYr[watchMessageHashesunWatchMessageHashesrwrXrTrxr^rmrnros r@un_subscribe_multiplecoinbase.un_subscribe_multiples >>$,,(? G G+E!EF F04 ,-!!! !%%gtU;q#g,'AZF[[(Fd|H   h '  % %dTkF&: ; ' '(=(Dv(M N (iit$!%  kk'+>+>t+PQG1 2  *6 %&''7bnoo05 ,-)- %& ? "8ps%AF F DF  F!%F F r[c0nURUR55nUR5 URR S5S:=(d UR R S5nXA-SRU5-nU(daURUS'XCS'URURU5URUR 5[R5US'U$URR S5(a[URS-5eURURS 5nUR!URS S5nUR5n Ub US -U :a-UR#U 5n XRS 'XRS 'URURS 5US 'U$) Nzorganizations/rz -----BEGINrGapi_key timestamp signaturezV apiKey should contain the name(eg: organizations/3b910e93....) and not the public keywsTokenwsTokenTimestampxjwt)number_to_stringsecondscheck_required_credentialsapiKeyfindsecret startswithrShmacencodehashlibsha256rrH safe_stringr: safe_integercreate_auth_token) r>rCr[rIr isCloudAPiKeyauth currentTokentokenTimestamprtokens r@rVcoinbase.create_ws_auths ))$,,.9  '')))*:;q@kdkkF\F\]iFj #((:"66#';;Ii %.k "%)YYt{{4/@$++dkkBZ\c\j\j%kIk "{{%%l33'3K)KLL++DLL)DL!..t||=OQRSNllnG#~';g'E..w7*/ Y'3: /0#// iHIe rBrXc|# UR5IShvN SnURUSX5IShvN $N!N7f)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 ` NtickerF)rNrIr>rXrYrCs r@ watch_tickercoinbase.watch_tickers<!!!^^D%@@@ "@s<8<:<<c~# UR5IShvN SnURSUSU5IShvN $N"N7f)a^ stops watching a price ticker 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 ` NrFrNrprs r@un_watch_tickercoinbase.un_watch_tickers@!!!&&xufEEE "E=9=;==c# UR5IShvN Uc URnSnURUSX5IShvN nUR(a 0nUSnXEU'U$UR$NZN07f)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_batchFrX)rNr\ry newUpdatestickers)r>r\rYrCrrrXs r@ watch_tickerscoinbase.watch_tickers"sz!!! ?llG..tUGLL ??GH%F$FON|| "Ms!A5A1+A5A3/A53A5c# UR5IShvN Uc URnURSSSU5IShvN $N/N7f)aW stop watching 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 ` NrrF)rNr\r~)r>r\rYs r@un_watch_tickerscoinbase.un_watch_tickers8sM!!! ?llG//.%QXYYY "Zs!A A*A AA A c@URUS5nURUS/5nURUS5nURU5n/n[S[ U55HnXHn URU S/5n [S[ U 55Hn Xn URU S5n U cMUR U 5nXnS'X^S'USnXR U'URU5 US -U-nURUU5 URUUU5 M M g) NrMeventsrrr product_iddatetimerXrF) r safe_list parse8601rsrtparse_ws_tickerrruresolvetry_resolve_usdc)r>clientrmrMrrr newTickersrw tickersObjrjr wsMarketIdresultrXrZs r@handle_tickerscoinbase.handle_tickersGs%t""7I626##G[9NN8,  q#f+&AJnnZB?G1c'l+ !--flC %--f5&/{#%-z")'- V$!!&)%nv5 v{3%%fk6B,'rBc  URUS5nSnURUS5nUR0SU_SURX2S5_SU_SUR U5_SURUS 5_S URUS 5_S URUS 5_SURUS5_SURUS5_SURUS5_SS_SS_SU_SU_SS_SS_SURUS5_SURUS5SS.E5$)NrpriceinforX-rrhigh high_24_hlowlow_24_hr2best_bid bidVolumebest_bid_quantityaskbest_ask askVolumebest_ask_quantityvwapopencloselast previousClosechange percentageprice_percent_chg_24_h volume_24_h)average baseVolume quoteVolume)r safe_number safe_ticker safe_symboliso8601)r>rrTrxrrs r@rcoinbase.parse_ws_tickers&##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)!   rBsincelimitc # UR5IShvN URU5nSnURUSX5IShvN nUR(aUR X5nUR XbUSS5$NhN<7f)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_tradesFrT)rNrXrIrgetLimitfilter_by_since_limit)r>rXrrrYrCtradess r@ watch_tradescoinbase.watch_tradessx!!!V$~~dE6BB ??OOF2E))& TRR "Cs!BA?-BB;BBc~# UR5IShvN SnURSUSU5IShvN $N"N7f)a stops watching 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 dict [params]: extra parameters specific to the exchange API endpoint :returns dict[]: a list of `trade structures ` NrrFrrs r@un_watch_tradescoinbase.un_watch_tradess@!!!&&xufEEE "Erc0# UR5IShvN SnURUSX5IShvN nUR(a5URUS5nUR US5nUR X5nUR XbUSS5$N{N`7f)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[] 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 ` NrFrrXrT)rNryr safe_dictrrr) r>r\rrrYrCrfirst tradeSymbols r@watch_trades_for_symbols!coinbase.watch_trades_for_symbolss!!!..tUGLL ??NN61-E**5(;KOOK7E))& TRR "Ls BBBBABBc~# UR5IShvN SnURSUSX5IShvN $N"N7f)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[] symbols: unified symbol of the market to fetch trades for :param dict [params]: extra parameters specific to the exchange API endpoint :returns dict[]: a list of `trade structures ` NrrF)rNr~)r>r\rYrCs r@un_watch_trades_for_symbols$coinbase.un_watch_trades_for_symbolss@!!!//$wWWW "Wrc# UR5IShvN SnURUSX5IShvN nUR(aURX5nUR XbUSS5$NWN<7f)a  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 ` NuserTr)rNrIrrr)r>rXrrrYrCorderss r@ watch_orderscoinbase.watch_orders*sg!!!~~dD&AA ??OOF2E))& TRR "AsA2A.A2A0;A20A2c# UR5IShvN SnURSUSURU55IShvN $N1N7f)a stops watching 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 dict [params]: extra parameters specific to the exchange API endpoint :returns dict[]: a list of `order structures ` NrrT)rNrprXrs r@un_watch_orderscoinbase.un_watch_orders=sI!!!&&xtT[[=PQQQ "Qs!A A,A A A  A c# UR5IShvN SnURU5nUSnURUSX5IShvN nUR5$NGN7f)a 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 Nlevel2rXF)rNrTrIr)r>rXrrYrCrT orderbooks r@watch_order_bookcoinbase.watch_order_bookKsc!!!V$!..ufEE   "Fs!A"A2A" A  A" A"c# UR5IShvN URU5nSnURSUSU5IShvN $N3N7f)a stops watching 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 dict [params]: extra parameters specific to the exchange API endpoint :returns dict: A dictionary of `order book structures ` indexed by market symbols NrrF)rNrXrprs r@un_watch_order_bookcoinbase.un_watch_order_book]sQ!!!V$&&{D%HHH "Is!AA .AA A Ac# UR5IShvN SnURUSX5IShvN nUR5$N1N7f)a 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)rNryr)r>r\rrYrCrs r@watch_order_book_for_symbols%coinbase.watch_order_book_for_symbolslsJ!!!11$wOO    "OsA AA A A  A cURUS5nURUS5nURUS5nURUS5nURUS5nUR U5nSU-n URUR U5n U c6UR URSS5n [U 5n XR U'[S[U55HYn X<n URU S5n[S[U55H'nXnU RURU55 M) M[ URX5 URXU 5 g)Nrrrrzmarket_trades::r4r/)r safe_valuerrrrrr:rrsrtru parse_traderr)r>rrmreventrtraderxrXrZ tradesArrayr4rw currentEvent currentTradesritems r@ handle_tradecoinbase.handle_trade|s902*x0vq)##E<8!!(+'&0 oodkk6:  ++DLL-NK0=K"-KK q#f+&A!9L NN<BM1c-01$'""4#3#3D#9:2' {0 f;?rBcURUS5n/nURc-URURSS5n[ U5Ul[ S[ U55HnX6nURUS5n[ S[ U55H]n Xn URU 5n URn URU S5n X;aURU 5 U RU 5 M_ M [ S[ U55HUnXFn URU 5nSU-nURURU5 URXUR5 MW URURS5 g) Nrr5r/rrrzuser::r) rrrr:rrsrtparse_ws_orderrrurrr)r>rrmrr]rrwr responseOrdersr responseOrderparsed cachedOrdersrxrXrZs r@ handle_ordercoinbase.handle_ordersP:2 ;; %%dllM4HE07DKq#f+&AIE!^^E8orderrTrHr!rxrr)s r@rcoinbase.parse_ws_orders"   eZ 0((0AB ##E<8%%eV_E!!(3$$UL9  E d&&vx8  "  ]  1     !$  D$$UL9  4    D&&uflC  T%%e];    I  d&&u.CD DNN4#3#3E>#JK! " t''{;# $&&u.CD))%1BC,,UH=**5,? ,,VW=3   rBc[S[U55HqnX#nURUS5nURURSU5nUR US5nUR US5nXn U R Xx5 Ms g)Nrr&r7 price_level new_quantity)rsrtrr:rstore) r>rupdatesrwr sideIdr&rr+ orderbookSides r@handle_order_book_helper!coinbase.handle_order_book_helpersq#g,'AJE%%eV4F##DLL$96BD$$UM:E%%e^rrmrrrwr rCrxrTrXrZrnrrKrs r@handle_order_bookcoinbase.handle_order_books]:2##G[9q#f+&AIEnnUIr:G''|rrZrs r@rcoinbase.try_resolve_usdcQs:    ' ';+?+?+G+G NN6#4 5,HrBcURUS/5nURUS05nSU;n[USR55n[ U5nU(aUS:XaUR UR S05nURUS/5n URUS/5n [S[ U 55Hn Xn Xn URXU 5 M URU5 U$)NrrrJrirgrh) rr rPkeysrtrr:rsclean_unsubscription clean_cache)r>rrmr firstEventisUnsubsubKeys subKeysLength unSubObjectrgrhrwrZsubHashs r@handle_subscription_status#coinbase.handle_subscription_statusUs*26__VQ3 "j0z/2779:G })..7GLK NN;LM#~~k;MrR 1c-01+. *-))&;G2   [ )rBcU$N)r>rrms r@handle_heartbeatscoinbase.handle_heartbeatszs "rBctURUS5nURURURURURUR UR S.nURUS5nUS:XaURUS5n[U5eURXC5nU(a U"X5 gg)NrM)rJrrrrl2_data heartbeatsrKerrorrm) rr]rrrrMrbrr )r>rrmrMmethodsrK errorMessagemethods r@handle_messagecoinbase.handle_messages""7I6!<<)) //!..%%--00 0 7?++GY?L - -2  6 # rB)rr`)0__name__ __module__ __qualname____firstlineno__rr=strboolrIrpr ryr~r rVr rrr rrrrrr rrrrrrrrrrrrrrrrFrMrr]rbrk__static_attributes__ __classcell__)r?s@r@rrs+ #+ ZBFb%JC%JD%JN443444lW[ceWSWTWGWBfjrt00C0D0[b0d3DI068 A AF A9; FC Fv F6:"7,9=R Zg ZC ZoCb+ Z<@d[]SSSSSbfglbmS(9; FC Fs FOSaenpSd3iSS[^SuyzvAS*LN Xc XRU X04$UYbdSSCSsSimnsitS&37r RC Rc R@DB!S!!S\!$=? I I3 ISW_a!$s)!C!fo! +@Z3,j0 d/5Bn6#J&$$rBr)ccxt.async_supportccxt ccxt.async_support.base.ws.cacherrccxt.base.typesrrrrrr r r r typingr ccxt.base.errorsrr async_supportrrarBr@r|s< C\\\*.O$t!!**O$rB