ei,ddlZddlmZddlZddlmZmZmZm Z m Z m Z m Z m Z mZddlmZddlmZddlmZGddejjZdS) N)ArrayCacheBySymbolById) AnyIntOrder OrderBookStrStringsTickerTickersTrade)List) ExchangeError)ArgumentsRequiredc neZdZdeffd ZdifdedefdZd)dededefdZdifdeded e fd Z difdededed e fd Z ded e efd Z ifdedefdZifdedefdZdifd e defdZdifd e defdZdZd)dZddifdededede efdZifdedefdZddifd e ededede efdZifd e edefdZdddifdededede efdZdifdedefdZdifdedede fdZ!ifdedefdZ"difd e edede fdZ#d Z$d!Z%d)d"Z&d#Z'd$Z(d%Z)d&Z*d'Z+d(Z,xZ-S)*coinbasereturnc |tt|iddddddddddddd dd dd dd dd dddddddddddddddddddddddddiiddddddddS)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 O/var/www/html/volatility/venv/lib/python3.11/site-packages/ccxt/pro/coinbase.pyr<zcoinbase.describesph 5 5 > > @ @d#U!%      u !%$U  e!$+D t!"t#$!%#)-!%"&!%!%+/38@ $#!%!# C*C *C * * * Nname isPrivatecK|d{Vd}|}g}t|trH||}||} | }|dzd|z}n(|&||}|dz|z}|dg}|jdd} d||d} |r*|| | ||} | | || |d{VS) 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_idsjoinmarketr8extendcreate_ws_authwatch) r=rArBsymbolparamsrR messageHash productIdssymbols marketIdsurlrGs r?rGzcoinbase.subscribe>sA!!!!!!!!!  fd # # ())&11G00I"J%,sxx/?/??KK  [[((F+.K ,Jit$%    V It/B/B4/T/TUUIZZ[)[IIIIIIIIIr@topicc8K|d{V||jddrt|jdzd|jd<d}|}d|z}g}t |t rc||} || } | }|dzd |z}|dzd |z}n0|.| |}|dz|z}|dz|z}|d g}|j d d } d ||d } |g|g|d|gd} |r*| | | ||} | |jd<|| || || d{V}d|jd<d|jd<|S)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:rDrErFr-r unsubscriberH messageHashessubMessageHashesr]rbrZunSubscription)rL safe_boolr9rrFrMrNrOrPrQrRr8rSrTrU)r=r]rArBrVrRwatchMessageHashunWatchMessageHashrYrZr[r\message subscriptionress r? un_subscribezcoinbase.un_subscribees!!!!!!!!!! >>$,(? G G F+E!EFF F04 ,-+d2 fd # # ())&11G00I"J/$6&9I9II !3d!:SXXf=M=M!M    [[((F#d{V3 !3d!:V!C  ,Jit$"%   11!1 2x     Rkk'4+>+>tZ+P+PQQG)5 %&JJs$6ASUabbbbbbbb05 ,-)- %& r@rZc K|d{Vg}g}||dd}tdt|D]W}||}||} | d} || ||dz|zX|jdd} d||d } |r*|| |||} | | || |d{VS) 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 NFrrFrDr-rrGrH) rLrOrangelenrRappendr8rSrTwatch_multiple) r=rArBrZrWrYrdirVrRmarketIdr\rGs r?subscribe_multiplezcoinbase.subscribe_multiplesC!!!!!!!!!  %%gtU;;q#g,,'' 7 7AQZF[[((Fd|H   h ' ' '  v!5 6 6 6 6it$%   V It/B/B4/T/TUUI((mY VVVVVVVVVr@c,K||jddrt|jdzd|jd<|d{Vg}g}g}||dd}t dt|D]u} || } || } | d} | | | |dz| z| d |zdz| zv|j d d } d ||d }|r*| || ||}|||d|d}||jd<| | ||||d{V}d|jd<d|jd<|S)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 r_Fr`TNrrFrDrar-rrbrHrcrf)rgr9rrFrLrOrorprRrqr8rSrTrr)r=r]rArBrZrWrYwatchMessageHashesunWatchMessageHashesrsrVrRrtr\rjrkrls r?un_subscribe_multiplezcoinbase.un_subscribe_multiples  >>$,(? G G F+E!EFF F04 ,-!!!!!!!!! !%%gtU;;q#g,,'' O OAQZF[[((Fd|H   h ' ' '  % %dTkF&: ; ; ; ' '(=(Dv(M N N N Nit$!%    Rkk'4+>+>tZ+P+PQQG1 2   *6 %&''-A7L`bnoooooooo05 ,-)- %& r@rYci}||}||jddkp|jd}||zd|z}|s_|j|d<||d<|| || |jtj |d<n|jdrt|j dz||jd }||jd d}|} | |d z| kr)|| } | |jd <| |jd <||jd |d <|S) Nzorganizations/rz -----BEGINrEapi_key timestamp signaturezV apiKey should contain the name(eg: organizations/3b910e93....) and not the public keywsTokenwsTokenTimestampxjwt)number_to_stringsecondscheck_required_credentialsapiKeyfindsecret startswithrQhmacencodehashlibsha256rrF safe_stringr9 safe_integercreate_auth_token) r=rArYrGr| isCloudAPiKeyauth currentTokentokenTimestamprtokens r?rTzcoinbase.create_ws_auths ))$,,..99  '')))))*:;;q@kdkF\F\]iFjFj 4#((:"6"66 I#';Ii %.Ik "%)YYt{{4/@/@$++dkBZBZ\c\j%k%kIk " "{%%l33 L'3K)KLLL++DL)DDL!..t|=OQRSSNllnnG#~';g'E'E..w77*/ Y'3: /0#// iHHIe r@rVczK|d{Vd}||d||d{VS)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)rLrGr=rVrWrAs r? watch_tickerzcoinbase.watch_tickers[!!!!!!!!!^^D%@@@@@@@@@r@czK|d{Vd}|d|d|d{VS)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 ` NrFrLrmrs r?un_watch_tickerzcoinbase.un_watch_tickers]!!!!!!!!!&&xufEEEEEEEEEr@cK|d{V||j}d}||d||d{V}|jri}|d}|||<|S|jS)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_batchFrV)rLrZru newUpdatestickers)r=rZrWrArrrVs r? watch_tickerszcoinbase.watch_tickers"s!!!!!!!!! ?lG..tUGVLLLLLLLL ? GH%F$GFON|r@cK|d{V||j}|ddd|d{VS)a 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)rLrZry)r=rZrWs r?un_watch_tickerszcoinbase.un_watch_tickers8se!!!!!!!!! ?lG//.%QXYYYYYYYYYr@c||d}||dg}||d}||}g}tdt |D]}||} || dg} tdt | D]} | | } || d} | #|| }||d<||d<|d}||j|<|||d z|z}|||| |||dS) NrKeventsr|rr product_iddatetimerVrD) r safe_list parse8601rorpparse_ws_tickerrrqresolvetry_resolve_usdc)r=clientrjrKrrr| newTickersrs tickersObjrjr wsMarketIdresultrVrXs r?handle_tickerszcoinbase.handle_tickersGst""7I66266##G[99NN8,,  q#f++&& C CAJnnZB??G1c'll++ C C !--flCC %--f55&/{#%-z")'- V$!!&)))%nv5 v{333%%fk6BBBB C C Cr@c ||d}d}||d}|id|d|||dd|d||d||d d ||d d ||d d||dd||dd||dddddd|d|ddddd||dd||dddS)NrpriceinforV-r|rhigh high_24_hlowlow_24_hr1best_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=rrRrtr|rs r?rzcoinbase.parse_ws_tickers&##FL99 00! F! d&&x==!  !   Y// ! D$$V[99 ! 4##FJ77 !  4##FJ77!  ))&2EFF!  4##FJ77!  ))&2EFF!  D!  D!  T!  D!  T! d!! " $**63KLL#! $**6=AA)! ! !    r@sincelimitcK|d{V||}d}||d||d{V}|jr|||}||||ddS)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_tradesFr|T)rLrVrGrgetLimitfilter_by_since_limit)r=rVrrrWrAtradess r? watch_tradeszcoinbase.watch_tradess!!!!!!!!!V$$~~dE66BBBBBBBB ? 3OOFE22E))&% TRRRr@czK|d{Vd}|d|d|d{VS)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_tradeszcoinbase.un_watch_tradess]!!!!!!!!!&&xufEEEEEEEEEr@c>K|d{Vd}||d||d{V}|jrB||d}||d}|||}||||ddS)aA 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 ` NrFrrVr|T)rLrur safe_dictrrr) r=rZrrrWrArfirst tradeSymbols r?watch_trades_for_symbolsz!coinbase.watch_trades_for_symbolss!!!!!!!!!..tUGVLLLLLLLL ? 8NN61--E**5(;;KOOK77E))&% TRRRr@c|K|d{Vd}|d|d||d{VS)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)rLry)r=rZrWrAs r?un_watch_trades_for_symbolsz$coinbase.un_watch_trades_for_symbolss`!!!!!!!!!//$wPVWWWWWWWWWr@cK|d{Vd}||d||d{V}|jr|||}||||ddS)aG 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|)rLrGrrr)r=rVrrrWrAorderss r? watch_orderszcoinbase.watch_orders*s!!!!!!!!!~~dD&&AAAAAAAA ? 3OOFE22E))&% TRRRr@cK|d{Vd}|d|d||d{VS)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)rLrmrVrs r?un_watch_orderszcoinbase.un_watch_orders=si!!!!!!!!!&&xtT[[=P=PQQQQQQQQQr@cK|d{Vd}||}|d}||d||d{V}|S)aN 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 Nlevel2rVF)rLrRrGr)r=rVrrWrArR orderbooks r?watch_order_bookzcoinbase.watch_order_bookKs!!!!!!!!!V$$!..uffEEEEEEEE    r@cK|d{V||}d}|d|d|d{VS)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)rLrVrmrs r?un_watch_order_bookzcoinbase.un_watch_order_book]sn!!!!!!!!!V$$&&{D%HHHHHHHHHr@cK|d{Vd}||d||d{V}|S)a1 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)rLrur)r=rZrrWrArs r?watch_order_book_for_symbolsz%coinbase.watch_order_book_for_symbolslsl!!!!!!!!!11$wOOOOOOOO    r@c0||d}||d}||d}||d}||d}||}d|z} ||j|} | 5||jdd} t| } | |j|<tdt|D]p} || } || d}tdt|D]2}|| }| | |3q| | | ||| | dS)Nrrrrzmarket_trades::r3r.)r safe_valuerrrrrr9rrorprq parse_traderr)r=rrjreventrtradertrVrX tradesArrayr3rs currentEvent currentTradesritems r? handle_tradezcoinbase.handle_trade|s022**x00vq))##E<88!!(++'&0 oodk6::  ++DL-NNK0==K"-DK q#f++&& ; ;A!!9L NN<BBM1c-0011 ; ;$Q'""4#3#3D#9#9:::: ; {K000 fk;?????r@cX||d}g}|j0||jdd}t ||_t dt |D]}||}||d}t dt |D]j} || } || } |j} || d} | |vr| | | | kt dt |D][}||} | | }d|z}| |j|| |||j\| |jddS) Nrr4r.rrrzuser::r) rrrr9rrorpparse_ws_orderrrqrrr)r=rrjrr[rrsrresponseOrdersr responseOrderparsed cachedOrdersrtrVrXs r? handle_orderzcoinbase.handle_orders:22 ; %%dlM4HHE077DKq#f++&& , ,A1IE!^^E8<#J#JKK! " t''{;;# $&&u.CDD))%1BCC--d.>.>uh.O.OPP**5,?? ,,VW==3      r@cXtdt|D]}||}||d}||jd|}||d}||d}||} | ||dS)Nrr r6 price_level new_quantity)rorprr9rstore) r=rupdatesrsrsideIdr rr orderbookSides r?handle_order_book_helperz!coinbase.handle_order_book_helpersq#g,,'' / /AAJE%%eV44F##DL$96BBD$$UM::E%%e^<s@r?rrs&+ #+ + + + + + ZBFb%J%JC%JD%J%J%J%JN4443444444lW[ceWWSWTWGWWWWBfjrt000C0D0[b0000d3DI068 A A AF A A A A9; F FC Fv F F F F6:"7,9=R Z Zg ZC Z Z Z ZoCoCoCb+ + + + Z<@d[]SSSSSSbfglbmSSSS(9; F FC Fs F F F FOSaenpSSd3iSS[^SuyzvASSSS*LN X Xc XRU X X X X04$UYbdSSSCSsSimnsitSSSS&37r R RC Rc R R R R@DB!!S!!S\!!!!$=? I I I3 I I I ISW_a!!$s)!C!fo!!!! +@+@+@Z3,3,3,j0 0 0 0 d///5B5B5Bn666###J&$$$$$$$r@r)ccxt.async_supportccxt ccxt.async_support.base.ws.cacherrccxt.base.typesrrrrrr r r r typingr ccxt.base.errorsrr async_supportrrDr@r?r[s CCCCCC\\\\\\\\\\\\\\\\\\\\\\******......O$O$O$O$O$t!*O$O$O$O$O$r@