eiddlZddlmZmZddlZddlmZmZm Z m Z m Z m Z m Z mZmZmZddlmZddlmZddlmZddlmZddlmZdd lmZdd lmZdd lmZGd d ejjZdS)N) ArrayCacheArrayCacheBySymbolById) AnyBoolIntOrder OrderBookStrStringsTickerTickersTrade)Client)List) ExchangeError)AuthenticationError)ArgumentsRequired) BadRequest) BadSymbol)Precisec |eZdZdeffd ZdZddifdZgdifdZifdede fdZ difd e de fd Z ddifded ed edeefd Zddifd eed ed edeefdZdddifded ed edeefdZddifd eed ed edeefdZddifd eed ed edeefdZdddifded ed edeefdZdifd eed edefdZdifded edefdZdefdZdefdZd$fd ZdZ defdZ!d$dZ"defdZ#d$de ffd Z$dZ%dZ&defd Z'defd!Z(dede)fd"Z*defd#Z+xZ,S)%coinbaseexchangereturnc|tt|dddddddddddddddddiddiddddd d S) 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 W/var/www/html/volatility/venv/lib/python3.11/site-packages/ccxt/pro/coinbaseexchange.pyr4zcoinbaseexchange.describes&6 = = F F H H#"&,0# $#)-+/ %$#)-!%$?N  $#!%3K K    c<|d}|}t|dz|z}|||||jtjd}||j ||j dS)Nz/users/self/verifyGETbase64) timestampkey signature passphrase) check_required_credentialsnoncestrhmacencodebase64_to_binarysecrethashlibsha256apiKeypassword)r5pathrApayloadr>s r7 authenticatezcoinbaseexchange.authenticate7s '')))# e**u$t+IIdkk'22D4I4I$+4V4VX_Xfhpqq ;"-    r8NctK|d{Vd}|}g}|>||}|d|dzz }||d|jdd}d|vr|dz}d||gd} || |} |||| |d{VS) N:idr)rr>? subscribetype product_idschannels) load_marketsmarketappendr0extendwatch) r5namesymbolmessageHashStartparamsrX messageHash productIdsurlrRrequests r7rRzcoinbaseexchange.subscribeDs!!!!!!!!!&   [[((F 3- -K   fTl + + +it$ & )C%  ++i00ZZ[';GGGGGGGGGr8cK|d{Vd}||}g}g}tdt|D][}||} || }||d||dz|dz\|jdd} d|vr| dz} d ||gd } || |} || || |d{VS) NrrPrOr]r)rr>rQrRrS) rWmarket_symbolsrangelenrXrYr0rZwatch_multiple) r5r\symbolsr^r_rX messageHashesrair]rbrRrcs r7subscribe_multiplez#coinbaseexchange.subscribe_multiple[sF!!!!!!!!!%%g..  q#g,,'' L LAQZF[[((F   fTl + + +  !1C!7&:J!J K K K Kit$ & )C%  ++i00((mWmTTTTTTTTTr8r]cFKd}|||||d{VS)a 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)rR)r5r]r_r\s r7 watch_tickerzcoinbaseexchange.watch_tickerts7^^D&$?????????r8ric:K|d{Vt|}|dkrt|jdzd}d}|||||d{V}|jri}|||d<|S||jd|S)a1 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 arrayrnr])rWrgrrPrl newUpdatesfilter_by_arraytickers)r5rir_ symbolsLengthchannelr`rnresults r7 watch_tickerszcoinbaseexchange.watch_tickers~s!!!!!!!!!G A  DG&XXYY Y ..wfUUUUUUUU ? F'-F6(# $M##DL(GDDDr8sincelimitcK|d{V||}d}|||||d{V}|jr|||}||||ddS)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)rWr]rRrqgetLimitfilter_by_since_limit)r5r]rxryr_r\tradess r7 watch_tradeszcoinbaseexchange.watch_tradess!!!!!!!!!V$$~~dFD&AAAAAAAA ? 3OOFE22E))&% TRRRr8cKt|}|dkrt|jdz|d{V||}d}|||||d{V}|jrB||d}||d} | | |}| |||ddS)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 symbolsNr{r]r<T) rgrrPrWrerlrq safe_value safe_stringr|r}) r5rirxryr_rtr\r~first tradeSymbols r7watch_trades_for_symbolsz)coinbaseexchange.watch_trades_for_symbolssG A  TW'gghh h!!!!!!!!!%%g....tWdFKKKKKKKK ? 8OOFA..E**5(;;KOOK77E))&% TRRRr8c K|t|jdz|d{V||}d}d}|}|||||||d{V}|jr|||}| |||ddS)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) rrPrWr]rMrRrZrqr|r}) r5r]rxryr_r\r`authenticationr~s r7watch_my_tradesz coinbaseexchange.watch_my_tradess >#DG.[$[\\ \!!!!!!!!!V$$ **,,~~dFKVUcAdAdeeeeeeee ? 3OOFE22E))&% TRRRr8c K||dd}|d{Vd}d}|}|||||||d{V}|jrB||d} || d} || |}| |||ddS) 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) rerWrMrlrZrqrrr|r}) r5rirxryr_r\r`rr~rrs r7watch_my_trades_for_symbolsz,coinbaseexchange.watch_my_trades_for_symbolss%%gtU;;!!!!!!!!! **,,..tWk4;;W]_mKnKnoooooooo ? 8OOFA..E**5(;;KOOK77E))&% TRRRr8c K|d{V||dd}d}d}|}|||||||d{V}|jrB||d} || d} || |}| |||ddS) a watches information on multiple orders made by the user :param str[] symbols: unified symbol of the market to fetch orders for :param int [since]: the earliest time in ms to fetch orders 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 `order structures ` NFrordersrr]r<T) rWrerMrlrZrqrrr|r}) r5rirxryr_r\r`rrrrs r7watch_orders_for_symbolsz)coinbaseexchange.watch_orders_for_symbolss!!!!!!!!!%%gtU;; **,,..tWk4;;W]_mKnKnoooooooo ? 8OOFA..E**5(;;KOOK77E))&% TRRRr8c K|t|jdz|d{V||}d}d}|}|||||||d{V}|jr|||}| |||ddS)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) rrPrWr]rMrRrZrqr|r}) r5r]rxryr_r\r`rrs r7 watch_orderszcoinbaseexchange.watch_orderss >DG&HHII I!!!!!!!!!V$$ **,,~~dFKVUcAdAdeeeeeeee ? 3OOFE22E))&% TRRRr8c~Kt|}|dkrt|jdzd}|d{V||}||}g}t d|D]%}||} ||dz| z&|jdd} d||gd } | | |} ||||d } | }| | || | ||| d{V}| S) 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 symbolslevel2NrOr)rrRrS)r`ri marketIdsry) rgrrPrWre market_idsrfrYr0rZrMrhry)r5riryr_rtr\rrjrkmarketIdrbrRrc subscriptionr orderbooks r7watch_order_book_for_symbolsz-coinbaseexchange.watch_order_book_for_symbolssG A  TW'jjkk k!!!!!!!!!%%g..OOG,,  q-(( 8 8A |H  h!6 7 7 7 7it$$  ++i00"   **,,--c=$++gWeBfBfhuxDEEEEEEEE    r8cKd}|d{V||}|d}|dz|dz}|jdd}d|dg|gd }|||} |||d|d } |} ||||| | || d{V} | S) 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]rOrPr)rrRrS)r`r]rry)rWrXr0rZrMr[ry) r5r]ryr_r\rXr`rbrRrcrrrs r7watch_order_bookz!coinbaseexchange.watch_order_book4s#!!!!!!!!!V$$!Sj6$</ it$t    ++i00&t    **,,**S+t{{7N7[7[]hjvwwwwwwww    r8clientc~||d}|||}|d}d}|dz|z}||j|}|5||jdd} t | }||j|<||||||S)N product_idr]r{rOr,r+) rparse_ws_traderr~ safe_integerr1rrYresolve) r5rmessagertrader]rTr` tradesArrayr,s r7 handle_tradezcoinbaseexchange.handle_tradeVs##G\::  ''00E8_FD*x/K//$+v>>K""// mTRR (55 &1 F#   u % % % NN; 4 4 4r8c@||d}|||}d}|dz|z}|j}|2||jdd}t |}||_||||||S)NrrrOr.r+)rrrrr1rrYr) r5rrrrrTr`rrys r7handle_my_tradez coinbaseexchange.handle_my_tradews##G\::  ''00ED*x/K-K"))$,NN4U;; +   u % % % NN; 4 4 4r8cttt||}d}d}d|vrd}d|d<||d}n@d|d<||d}|d}|d d d |||d<|rd nd }||||d<||d}|d}d} |d-|+||d} t j| |} |||| |d|d<|S)NFmaker_fee_rateTmaker takerOrMakertakertaker_fee_ratesidesellbuy)rrmaker_order_idtaker_order_idorderr]quotecost)ratercurrencyfee)r3r parse_traderrXr string_mul parse_number) r5rrXparsedfeeRateisMaker currentSideidKey feeCurrencyfeeCostrr6s r7rzcoinbaseexchange.parse_ws_trades}f'..::5AA u $ $G%,F> "&&u.>??GG%,F> "&&u.>??G!.K!--//K))F6N%,A  1A**5%88wVH-..Wo  6N &W-@##FF33D(w77G%%g..%%g..#  u  r8c:ddd}|||dS)Nclosedcanceled)filledropen)r)r5statusstatusess r7parse_ws_order_statusz&coinbaseexchange.parse_ws_order_statuss."  &&999r8c  |j}|2||jdd}t|}||_||d}||d}|d|z}||}||d} ||d} ||d} |j} || j|i} || | }||| | | }|B| |}| || | |dS||d }||d i}||d }|||kr|d kr| |}|d g|d <|d  ||d |d<d}d}|d }tdt|D]8}||}||dd}||dd}9tj|ds+|tj|||d<|||d<||d}||tj|||d|d<|dS|tj||d||d|d<|dd|ddd|d<|dd|dd||dd|dd|dd<||d}||d}|tj||d||d|dd<| || | |dS|dks|dkr||d |}| |}t1|}tdt|D]}||}|| ||||<| || | |dSdSdSdS)Nr-r+rTrzorders:order_idrrsequenceinfomatchr~r<lastTradeTimestamp0rramountaverager remainingrr)rrreceiveddone)rrr1rr safe_symbolrhashmap safe_value_2parse_ws_orderrYrrrfrgr string_eqr string_div string_add string_subsum safe_dictrZlistkeys) r5rr currentOrdersryrTrr`r]orderId makerOrderId takerOrderIdrpreviousOrders previousOrderrr previousInfopreviousSequencer totalCost totalAmountr~rk tradeEntrypreviousOrderFilledpreviousOrderFeetradeFeerrrr=s r7 handle_orderzcoinbaseexchange.handle_orders^  %%dlM4HHE2599M'DK00##G\::  #h.K%%h//F&&w ;;G++G5EFFL++G5EFFL[F!__V^VRHHN OONGDDM$ $ 1 1.,P\ ] ] $,,W55 f%%%v{33333,,WjAA#}fbII #'#4#4\:#N#N $,(=M2M2Mw $ 3 3G < <(2:68M(3%h/66u===>CK>P &:;$' &) !.x!8!&q#f++!6!6VVA)/J(,(8(8VS(Q(QI*.*:*::xQT*U*UKK&0cBBu7;7H7HI[\egrIsIs7t7tM)4040A0A)0L0L f-.2.>.>}h.W.W+.:6:6G6GHZ[nptqAqABGIQqRqRISIS7T7TM(3,X6B=A=N=NwOabfbrbrtACKcLcLNRN^N^_lnvNwNwPxPx>y>y k :(/7(),1%L,D44M%0*%08D5QV>  E f  "  ]     Y//   !$  I  4    D  U    D  d''// D! " t# $''//**955-      r8c||d}|]||}|d}||j|<d|z}d|z}|||||||S)Nrr]zticker:)r parse_tickerrsr)r5rrrrnr]r` idMessageHashs r7 handle_tickerzcoinbaseexchange.handle_tickers(##G\::  &&w//FH%F#)DL #f,K%0M NN6; / / / NN6= 1 1 1r8c`||d}|)tt|||S||d}|||d}|||d}||d}|id|d|d||d ||d d ||d d ||dd||dd||dd||dddd||dd|d|dddddddd||dd|dS) NrTr-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) r5rnrXrTrr]r<rr6s r7rzcoinbaseexchange.parse_tickers-,// <)400==ffMM M##FL99!!(FC88NN4#3#3FF#C#CDD 00! f! !   Y//!  D$$VZ88 ! 4##FI66 ! 4##FJ77 !  ))&/BB!  4##FJ77!  ))&/BB!  D!  D$$VZ88!  T!  D!  T!  d! $!! " t#! $**6<@@)! ! !    r8c||d}||d}|||dS)Nr)rstore)r5booksidedeltarrs r7 handle_deltazcoinbaseexchange.handle_deltasF  **!!%++uf%%%%%r8c~tdt|D]}||||dS)Nr)rfrgr))r5r'deltasrks r7 handle_deltaszcoinbaseexchange.handle_deltassHq#f++&& 3 3A   hq 2 2 2 2 3 3r8c||d}||d}||dd}|d}d}|dz|z}||j|i} || d} |dkr|i| |j|<|j|} || d ||d g|| d ||d gd| d <d| d <|| d<|| |dS|d kr%|j|} | ||d} ||dg} d d d}tdt| D]}| |}||d}|||}| |d}| |d}| |}| ||| | d <|| | d <|| |dSdS)NrTrr r]rrOrysnapshotasksbidsr<rl2updaterchanges)rrrr%)r safe_marketr subscriptionsr order_book orderbooksr,rrrfrgrr&r)r5rrrTrrXr]r\r`rryrr<r2sidesrkrr=rrrr's r7handle_order_bookz"coinbaseexchange.handle_order_books400##G\::!!(D#66!Sj8+ v';["MM !!,88 :  &*oob%&@&@DOF #/I   y0$//'6SU2V2V W W W   y0$//'6SU2V2V W W W%)Ik "$(Ij !"(Ih  NN9k 2 2 2 2 2 Z  /It'7'7'H'HIIIoogy"==GE1c'll++ . . &&vq11''s33((33))&!44$T?uf----%.Ik "$(LL$;$;Ij ! NN9k 2 2 2 2 2% r8c|SN)r5rrs r7handle_subscription_statusz+coinbaseexchange.handle_subscription_statusCs r8c||d}||d} |dkrtd|zt|jdz|z#t$r }||Yd}~dSd}~wwxYw)NrrzAuthentication FailedzAuthentication failed:  T)rrrrP Exceptionreject)r5rrerrMsgrerrors r7handle_error_messagez%coinbaseexchange.handle_error_messageQs !!'955!!'844 000)*Cf*LMMM#DGcMF$:;;;    MM% 44444 s2A B *BB c ||d}|j|j|j|j|j|j|j|j|jd }t |jdz }|j|dz dk}|||}|P|dkrH|r.| |||||dS| ||dSdS|||dS)NrT) r.r1rRrnrrrrrCrr%rQr) rr9r=r rrDrgrbrrr)r5rrrTmethodslength authenticatedmethods r7handle_messagezcoinbaseexchange.handle_messagels00..8()%'%.   VZ1$ 6A:.#5 $// >w 7((999%%fg66666%%fg66666  F67 # # # # #r8r;)-__name__ __module__ __qualname__rr4rMrRrlrBr ror r rwrrrrrr rrrrrr rrrrrrrrrr rr)r,r9r=rrDrJ __classcell__)r6s@r7rrs #      B    ,0$rHHHH.68$WYUUUU268@@@F@@@@6:"EE7EEEEE*<@d[]SSSSSSbfglbmSSSS"OSaenpSSd3iSS[^SuyzvASSSS,37TX\egSSCSsSRUSlpqvlwSSSS*RVdhqsSScS3S^aSx|~CyDSSSS*OSaenpSSd3iSS[^SuyzvASSSS*04$UYbdSSSCSsSimnsitSSSS*SW_a$!$!$s)$!C$!fo$!$!$!$!L@DB ! !S ! !S\ ! ! ! !D6B f    QQQQQQf:::W<6W<W<W<W2 2 62 2 2 2 2 2 h&&& 333=3=3=3=3=3~     6t6$V$$$$$$$$r8r)ccxt.async_supportccxt ccxt.async_support.base.ws.cacherrrGccxt.base.typesrrrrr r r r r r!ccxt.async_support.base.ws.clientrtypingrccxt.base.errorsrrrrrccxt.base.preciser async_supportrr<r8r7rXsP OOOOOOOObbbbbbbbbbbbbbbbbbbbbbbb444444******000000......''''''&&&&&&%%%%%%p $p $p $p $p $t):p $p $p $p $p $r8