i4dddlZddlmZddlZddlmZmZmZm Z m Z m Z m Z m Z ddlmZddlmZddlmZGddejjZdS) N)ArrayCacheBySymbolById)IntOrder OrderBookStrStringsTickerTickersTrade)List) ExchangeError)ArgumentsRequiredc eZdZfdZdifdZifdedefdZdifdede fdZ d Z dd Z ddifded e d e deefd Zdddifded e d e deefdZdifded e defdZdZdZddZdZdZdZdZxZS)coinbasec |tt|iddddddddddddd dd dd dd dd dddddddddddddddidddiiddddddddS)NwsTcancelAllOrdersWsFcancelOrdersWs cancelOrderWs createOrderWs editOrderWsfetchBalanceWsfetchOpenOrdersWs fetchOrderWs fetchTradesWs watchBalance watchMyTrades watchOHLCVwatchOrderBook watchOrders watchTicker watchTickers watchTradesapiz$wss://advanced-trade-ws.coinbase.combidsasks)bidoffer) tradesLimit ordersLimit myTradesLimitsides)hasurlsoptions) deep_extendsuperrdescribe)self __class__s W/var/www/html/crypto-bot/backend/venv/lib/python3.11/site-packages/ccxt/pro/coinbase.pyr3zcoinbase.describesWh 5 5 > > @ @d#U!%      u !%$U  e!$t t!"#$t%*@ $#!%!# 5#C #C # # # NcDK|d{V|d}|}g}t|trH||}||}|}|dzd|z}n.|,||}|dz|dz}|dg}|jdd} | | } |j ddkp|j d } | |zd|z} d ||d } | s_|j | d <| | d <||| ||j t"j| d<n|j d rt'|jdz||jd}||jdd}| }| |dz|kr)||}||jd<||jd<||jd| d<|| || |d{VS)a * @ignore subscribes to a websocket channel :see: https://docs.cloud.coinbase.com/advanced-trade-api/docs/ws-overview#subscribe :param str name: the name of the channel :param string|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$rzorganizations/rz -----BEGIN subscribe)type product_idschannelapi_key timestamp signaturezV apiKey should contain the name(eg: organizations/3b910e93....) and not the public keywsTokenwsTokenTimestampxjwt) load_marketscheck_required_credentials isinstancelistmarket_symbols market_idsjoinmarketr/number_to_stringsecondsapiKeyfindsecret startswithhmacencodehashlibsha256rr; safe_stringr0 safe_integercreate_auth_tokenwatch)r4namesymbolparamsrN messageHash productIdssymbols marketIdsurlrA isCloudAPiKeyauthr< currentTokentokenTimestamprPtokens r6r<zcoinbase.subscribe7s!!!!!!!!! '')))  fd # # ())&11G00I"J%,sxx/?/??KK  [[((F+t 4K ,Jit$))$,,..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 ZZ[)[IIIIIIIIIr7r^returncDKd}||||d{VS)a watches a price ticker, a statistical calculation with the information calculated over the past 24 hours for a specific market :see: 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 ` tickerN)r<)r4r^r_r]s r6 watch_tickerzcoinbase.watch_tickerms5^^D&&999999999r7rbcvK||j}d}||||d{V}|jr|S|jS)a watches a price ticker, a statistical calculation with the information calculated over the past 24 hours for a specific market :see: 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_batch)rbr< newUpdatestickers)r4rbr_r]rqs r6 watch_tickerszcoinbase.watch_tickersxsW ?lGtWf======== ? N|r7c.||d}||dg}g}tdt|D]}||}||dg}tdt|D]} || } || } | d} | |j| <|| d} |dz| z}|| || ||dr|| |d z| |d }tdt|D]}||}| d}|d }| d }| |d|}| |sD||||dr|||d z|S) Nr?eventsrrqr^ product_idr9USDCzticker_batch::r:) rY safe_valuerangelenparse_ws_tickerrqappendresolveendswithfind_message_hashessplitfilter_by_arrayis_empty)r4clientmessager?rt newTickersi tickersObjrqjrlresultr^ wsMarketIdr` messageHashesparts symbolsStringrbs r6handle_tickerszcoinbase.handle_tickerss(|""7I66(B77 q#f++&& > >AJooj)R@@G1c'll++ > > --f55)'- V$!--flCC %nz9 !!&)))v{333''..>NN6;+<=== >009IJJ q#m,,-- ? ?A'*K%%d++E!!HM#))#..G**:xIIG==)) ?w 444''..?NN7K#,=>>>r7c ||d}d}||d}|id|d|||dd|d||d||d d ||d d ||d d||dd||dd||dddddd|d|ddddd||dd||dddS)Nrupriceinfor^-rAdatetimehigh high_24_hlowlow_24_hr(best_bid bidVolumebest_bid_quantityaskbest_ask askVolumebest_ask_quantityvwapopencloselast previousClosechange percentageprice_percent_chg_24_h volume_24_h)average baseVolume quoteVolume)rY safe_number safe_ticker safe_symboliso8601)r4rlrNmarketIdrArs r6r|zcoinbase.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)! ! !    r7sincelimitcK|d{V||}d}||||d{V}|jr|||}||||ddS)aD get the list of most recent trades for a particular symbol :see: 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_tradesrAT)rGr^r<rpgetLimitfilter_by_since_limit)r4r^rrr_r]tradess r6 watch_tradeszcoinbase.watch_tradess!!!!!!!!!V$$~~dFF;;;;;;;; ? 3OOFE22E))&% TRRRr7cK|d{Vd}||||d{V}|jr|||}||||ddS)aM watches information on multiple orders made by the user :see: 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 ` NuserrAT)rGr<rprr)r4r^rrr_r]orderss r6 watch_orderszcoinbase.watch_orders#s!!!!!!!!!~~dFF;;;;;;;; ? 3OOFE22E))&% TRRRr7cK|d{Vd}||}|d}||||d{V}|S)aT watches information on open orders with bid(buy) and ask(sell) prices, volumes and other data :see: 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 Nlevel2r^)rGrNr<r)r4r^rr_r]rN orderbooks r6watch_order_bookzcoinbase.watch_order_book4s!!!!!!!!!V$$!..vv>>>>>>>>    r7c^||d}||d}||d}||d}||d}d|z}||} ||j| } | 5||jdd} t | } | |j| <tdt|D]p} || } || d}tdt|D]2}|| }| | |3q| | || dr| | |d z|S) Nrtrrruzmarket_trades::r*r%rvrw) ryrYrrrZr0rrzr{r} parse_trader~r)r4rrrteventrtraderr`r^ tradesArrayr*r currentEvent currentTradesritems r6 handle_tradezcoinbase.handle_tradeDs0(33**11**##E<88'(2 !!(++oodk6::  ++DL-NNK0==K"-DK q#f++&& ; ;A!!9L OOL(CCM1c-0011 ; ;$Q'""4#3#3D#9#9:::: ; {K000   U # # ; NN; c(9 : : :r7c\||d}g}|j0||jdd}t ||_t dt |D]}||}||d}t dt |D]j} || } || } |j} || d} | |vr| | | | kt dt |D]]}||} d| z}| |j|| dr| |j|d z^| |jd |S) Nrtr+r%rrruzuser::rvrwr) ryrrZr0rrzr{parse_ws_orderrYr}r~r)r4rrrtrcrrrresponseOrdersr responseOrderparsed cachedOrdersrr`s r6 handle_orderzcoinbase.handle_orderss:(33 ; %%dlM4HHE077DKq#f++&& , ,A1IE!__UH==N1c.1122 , , .q 1 ,,];;#{ ++M<HH I--$$X...##F++++ ,q#i..)) ? ?A |H"X-K NN4; 4 4 4##E** ?t{K#,=>>>t{F+++r7c ||d}||d}||d}||d}|||}|id|d||dd|d|d ||d |d dd ||d ddddd||dddddddddddd||d||d||d||d||d||ddddS)Norder_idclient_order_idrutimerr^r; clientOrderIdrArlastTradeTimestampr= order_type timeInForcepostOnlysider stopPrice triggerPriceamountcostr avg_pricecumulative_quantityleaves_quantitystatus total_feesquote)rcurrency)filled remainingrfeer)rY safe_market safe_order parse8601safe_string_lower)r4orderrNr;rrrs r6rzcoinbase.parse_ws_orders   eZ 0 0((0ABB ##E<88##E622!!(F33 E d&&vx88  "  ]  11     !$  D$$UL99  4    D$$UF33  T    D  d D! " t''{;;# $&&u.CDD))%1BCC,,UH==**5,?? ,,VW==3      r7cXtdt|D]}||}||d}||jd|}||d}||d}||} | ||dS)Nrrr- price_level new_quantity)rzr{rYr0rstore) r4rupdatesrrsideIdrrr orderbookSides r6handle_order_book_helperz!coinbase.handle_order_book_helpersq#g,,'' / /AAJE%%eV44F##DL$96BBD$$UM::E%%e^<rs CCCCCCWWWWWWWWWWWWWWWWWWWW******......o o o o o t!*o o o o o r7