i!ddlZddlmZmZddlZddlmZmZm Z m Z m Z m Z m Z mZddlmZddlmZddlmZddlmZddlmZdd lmZdd lmZGd d ejjZdS) N) ArrayCacheArrayCacheBySymbolById)IntOrder OrderBookStrStringsTickerTickersTrade)Client)List) ExchangeError)AuthenticationError)ArgumentsRequired) BadRequest) BadSymbolc ^eZdZfdZdZddifdZgdifdZifdedefdZ difd e de fd Z ddifded e d e deefd Zddifd eed e d e deefdZdddifded e d e deefdZdddifd e d e d e deefdZdddifd e d e d e deefdZdddifded e d e deefdZdifd eed e defdZdifded e defdZdefdZdefdZd$fd ZdZdefdZ d$dZ!defdZ"d$deffd Z#dZ$dZ%defd Z&defd!Z'defd"Z(defd#Z)xZ*S)% coinbaseproc|tt|dddddddddddddddddiddiddddd d S) NTF)ws watchOHLCVwatchOrderBookwatchOrderBookForSymbols watchTicker watchTickers watchTradeswatchTradesForSymbolswatchMyTradesForSymbols watchBalance watchStatus watchOrderswatchOrdersForSymbols watchMyTradesrzwss://ws-feed.pro.coinbase.comz2wss://ws-feed-public.sandbox.exchange.coinbase.com)apitest) tradesLimit ordersLimit myTradesLimit)hasurlsoptions) deep_extendsuperrdescribe)self __class__s Z/var/www/html/crypto-bot/backend/venv/lib/python3.11/site-packages/ccxt/pro/coinbasepro.pyr0zcoinbasepro.describesk4 8 8 A A C C#"&,0# $#)-+/ %$#)-!%$:N  $#!%3F F    c<|d}|}t|dz|z}|||||jtjd}||j ||j dS)Nz/users/self/verifyGETbase64) timestampkey signature passphrase) check_required_credentialsnoncestrhmacencodebase64_to_binarysecrethashlibsha256apiKeypassword)r1pathr=payloadr:s r3 authenticatezcoinbasepro.authenticate6s '')))# e**u$t+IIdkk'22D4I4I$+4V4VX_Xfhpqq ;"-    r4NctK|d{Vd}|}g}|>||}|d|dzz }||d|jdd}d|vr|dz}d||gd} || |} |||| |d{VS) N:idr%rr:? subscribetype product_idschannels) load_marketsmarketappendr,extendwatch) r1namesymbolmessageHashStartparamsrT messageHash productIdsurlrNrequests r3rNzcoinbasepro.subscribeCs!!!!!!!!!&   [[((F 3- -K   fTl + + +it$ & )C%  ++i00ZZ[';GGGGGGGGGr4cK|d{Vd}||}g}g}tdt|D][}||} || }||d||dz|dz\|jdd} d|vr| dz} d ||gd } || |} || || |d{VS) NrrLrKrYr%rr:rMrNrO) rSmarket_symbolsrangelenrTrUr,rVwatch_multiple) r1rXsymbolsrZr[rT messageHashesr]irYr^rNr_s r3subscribe_multiplezcoinbasepro.subscribe_multipleZsF!!!!!!!!!%%g..  q#g,,'' L LAQZF[[((F   fTl + + +  !1C!7&:J!J K K K Kit$ & )C%  ++i00((mWmTTTTTTTTTr4rYreturncFKd}|||||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)rN)r1rYr[rXs r3 watch_tickerzcoinbasepro.watch_tickerss7^^D&$?????????r4rec:K|d{Vt|}|dkrt|jdzd}d}|||||d{V}|jri}|||d<|S||jd|S)a3 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 arrayrkrY)rSrcrrLrh newUpdatesfilter_by_arraytickers)r1rer[ symbolsLengthchannelr\rkresults r3 watch_tickerszcoinbasepro.watch_tickers}s!!!!!!!!!G A  DG&XXYY Y ..wfUUUUUUUU ? F'-F6(# $M##DL(GDDDr4sincelimitcK|d{V||}d}|||||d{V}|jr|||}||||ddS) 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 ` Nmatchesr8T)rSrYrNrngetLimitfilter_by_since_limit)r1rYrurvr[rXtradess r3 watch_tradeszcoinbasepro.watch_tradess!!!!!!!!!V$$~~dFD&AAAAAAAA ? 3OOFE22E))&% TRRRr4cKt|}|dkrt|jdz|d{V||}d}|||||d{V}|jrB||d}||d} | | |}| |||ddS)rxrz> watchTradesForSymbols() requires a non-empty array of symbolsNryrYr8T) rcrrLrSrarhrn safe_value safe_stringrzr{) r1rerurvr[rqrXr|first tradeSymbols r3watch_trades_for_symbolsz$coinbasepro.watch_trades_for_symbolssG A  TW'gghh h!!!!!!!!!%%g....tWdFKKKKKKKK ? 8OOFA..E**5(;;KOOK77E))&% TRRRr4c 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]{@link https://docs.ccxt.com/#/?id=trade-structure Nz+ watchMyTrades() requires a symbol argumentusermyTradesr8T) rrLrSrYrIrNrVrnrzr{) r1rYrurvr[rXr\authenticationr|s r3watch_my_tradeszcoinbasepro.watch_my_tradess >#DG.[$[\\ \!!!!!!!!!V$$ **,,~~dFKVUcAdAdeeeeeeee ? 3OOFE22E))&% TRRRr4c 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]{@link https://docs.ccxt.com/#/?id=trade-structure NFrrrrYr8T) rarSrIrhrVrnrrrzr{) r1rerurvr[rXr\rr|rrs r3watch_my_trades_for_symbolsz'coinbasepro.watch_my_trades_for_symbolss%%gtU;;!!!!!!!!! **,,..tWk4;;W]_mKnKnoooooooo ? 8OOFA..E**5(;;KOOK77E))&% TRRRr4c 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 ` NFrordersrrYr8T) rSrarIrhrVrnrrrzr{) r1rerurvr[rXr\rrrrs r3watch_orders_for_symbolsz$coinbasepro.watch_orders_for_symbolss!!!!!!!!!%%gtU;; **,,..tWk4;;W]_mKnKnoooooooo ? 8OOFA..E**5(;;KOOK77E))&% TRRRr4c 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 symbolrrr8T) rrLrSrYrIrNrVrnrzr{) r1rYrurvr[rXr\rrs r3 watch_orderszcoinbasepro.watch_orderss >DG&HHII I!!!!!!!!!V$$ **,,~~dFKVUcAdAdeeeeeeee ? 3OOFE22E))&% TRRRr4c~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 symbolslevel2NrKr%rrNrO)r\re marketIdsrv) rcrrLrSra market_idsrbrUr,rVrIrdrv)r1rervr[rqrXrrfrgmarketIdr^rNr_ subscriptionr orderbooks r3watch_order_book_for_symbolsz(coinbasepro.watch_order_book_for_symbols sG A  TW'jjkk k!!!!!!!!!%%g..OOG,,  q-(( 8 8A |H  h!6 7 7 7 7it$$  ++i00"   **,,--c=$++gWeBfBfhuxDEEEEEEEE    r4cKd}|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 rNrYrKrLr%rrNrO)r\rYrrv)rSrTr,rVrIrWrv) r1rYrvr[rXrTr\r^rNr_rrrs r3watch_order_bookzcoinbasepro.watch_order_book3s#!!!!!!!!!V$$!Sj6$</ it$t    ++i00&t    **,,**S+t{{7N7[7[]hjvwwwwwwww    r4clientc~||d}|||}|d}d}|dz|z}||j|}|5||jdd} t | }||j|<||||||S)N product_idrYryrKr(r') rparse_ws_traderr| safe_integerr-rrUresolve) r1rmessagertraderYrPr\ tradesArrayr(s r3 handle_tradezcoinbasepro.handle_tradeUs##G\::  ''00E8_FD*x/K//$+v>>K""// mTRR (55 &1 F#   u % % % NN; 4 4 4r4c@||d}|||}d}|dz|z}|j}|2||jdd}t |}||_||||||S)NrrrKr*r')rrrrr-rrUr) r1rrrrrPr\rrvs r3handle_my_tradezcoinbasepro.handle_my_tradevs##G\::  ''00ED*x/K-K"))$,NN4U;; +   u % % % NN; 4 4 4r4ctt||}d}d}d|vrd}d|d<||d}n@d|d<||d}|d}|d d d |||d<|rd nd }||||d<||d}|d}d} |d|||d} | |z} || |d|d<|S)NFmaker_fee_rateTmaker takerOrMakertakertaker_fee_ratesidesellbuy)rrmaker_order_idtaker_order_idorderrYquotecost)ratercurrencyfee)r/r parse_trade safe_numberrrT) r1rrTparsedfeeRateisMaker currentSideidKey feeCurrencyfeeCostrr2s r3rzcoinbasepro.parse_ws_tradesWf{D))55e<< u $ $G%,F> "&&u.>??GG%,F> "&&u.>??G!.K!--//K))F6N%,A  1A**5%88wVH-..Wo  6N &W-@##FF33DWnG#  u  r4c:ddd}|||dS)Nclosedcanceled)filledropen)r)r1statusstatusess r3parse_ws_order_statusz!coinbasepro.parse_ws_order_statuss."  &&999r4c2|j}|2||jdd}t|}||_||d}||d}|d|z}||}||d} ||d} ||d} |j} || j|i} || | }||| | | }|B| |}| || | |dS||d }||d i}||d }|||krl|d kr| |}|d g|d <|d  ||d |d<d}d}|d }tdt|D]B}||}|||d}|||d}C|dkr||z |d<||d<|d2|dxx|dz cc<|d|d|dz |d<|dd|ddd|d<|ddE|dd7||dd|dd|dd<| || | |dS|dks|dkr||d |}| |}t#|}tdt|D]}||}|| ||||<| || | |dSdSdSdS)Nr)r'rPrzorders:order_idrrsequenceinfomatchr|r8lastTradeTimestamprramountaverager remainingrr)rrreceiveddone)rrr-rr safe_symbolrhashmap safe_value_2parse_ws_orderrUrrrbrcsumrVlistkeys)r1rr currentOrdersrvrPrr\rYorderId makerOrderId takerOrderIdrpreviousOrders previousOrderrr previousInfopreviousSequencer totalCost totalAmountr|rg tradeEntryrrrr9s r3 handle_orderzcoinbasepro.handle_ordersz^  %%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(,Jv)(333uXF333,X6B=J8=TWdemWn=n k :(/7(),1%L,D44M%0*%08D5QV3A.r4c b||d}||d}||d}||}||d}||d}||dd} ||d} || } ||d } || } ||d }||d }||d }d}| || |z }n|d kr d}| | |z }|id|d|d|d|d| d|| ddd |ddddd|d|ddddd| dddd||| dddS)Nr client_oidrrpricesizefundstimereason order_typeremaining_sizerPrrrrYrL clientOrderIdr8datetimer timeInForcepostOnly stopPrice triggerPricerrr)rrrrr|)rrr safe_number_2 parse8601r safe_orderiso8601)r1rrTrLrrrYrrrrr8rr orderTyperrPrs r3rzcoinbasepro.parse_ws_ordertsm   eZ 0 0(( == ##E<88!!(++v..  00##E67;;v..NN4(( !!%22++F33$$UL99 $$U,<== v..  Y%:i'FF Z  F!"VO  E f  "  ]     Y//   !$  I  4    D  U    D  f D! " t# $"-      r4c||d}|]||}|d}||j|<d|z}d|z}|||||||S)NrrYzticker:)r parse_tickerrpr)r1rrrrkrYr\ idMessageHashs r3 handle_tickerzcoinbasepro.handle_tickers(##G\::  &&w//FH%F#)DL #f,K%0M NN6; / / / NN6= 1 1 1r4c`||d}|)tt|||S||d}|||d}|||d}||d}|id|d|d||d ||d d ||d d ||dd||dd||dd||dddd||dd|d|dddddddd||dd|dS) NrPr-rrrYr8rhighhigh_24hlowlow_24hbidbest_bid bidVolume best_bid_sizeaskbest_ask askVolume best_ask_sizevwapropen_24hcloselast previousClosechange percentager volume_24h) baseVolume quoteVolumer)rr/rrrr safe_tickerr) r1rkrTrPrrYr8rr2s r3rzcoinbasepro.parse_tickers,,// <d++88HH H##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<@@)! ! !    r4c||d}||d}|||dS)Nr)rstore)r1booksidedeltarrs r3 handle_deltazcoinbasepro.handle_deltasF  **!!%++uf%%%%%r4c~tdt|D]}||||dS)Nr)rbrcr)r1rdeltasrgs r3 handle_deltaszcoinbasepro.handle_deltassHq#f++&& 3 3A   hq 2 2 2 2 3 3r4c||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)NrPrrrYrrKrvsnapshotasksbidsr8rl2updaterchanges)rrrr)r safe_marketr subscriptionsr order_book orderbooksrrrrbrcrrr)r1rrrPrrTrYrXr\rrvrr8r%sidesrgrr9rrrrs r3handle_order_bookzcoinbasepro.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% r4c|SN)r1rrs r3handle_subscription_statusz&coinbasepro.handle_subscription_status>s r4c||d}||d} |dkrtd|zt|jdz|z#t$r }||Yd}~dSd}~wwxYw)NrrzAuthentication FailedzAuthentication failed:  T)rrrrL Exceptionreject)r1rrerrMsgrerrors r3handle_error_messagez coinbasepro.handle_error_messageLs !!'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)NrP) r!r$rNrkrrrrr6rrrMr) rr,r0rrr7rcr^rrr)r1rrrPmethodslength authenticatedmethods r3handle_messagezcoinbasepro.handle_messagegs00..8()%'%.   VZ1$ 6A:.#5 $// >w 7((999%%fg66666%%fg66666  F67 # # # # #r4r.)+__name__ __module__ __qualname__r0rIrNrhr>r rlr r rtrrr r}rrrrrrrrrrr rrrrrrrrrrr,r0r7r= __classcell__)r2s@r3rrs     B    ,0$rHHHH.68$WYUUUU268@@@F@@@@6:"EE7EEEEE*<@d[]SSSSSSbfglbmSSSS"OSaenpSSd3iSS[^SuyzvASSSS,37TX\egSSCSsSRUSlpqvlwSSSS*DHVZimvxSSSPSScfS~BCH~ISSSS*AESWfjsuSSgSSS`cSz~@E{FSSSS*04$UYbdSSSCSsSimnsitSSSS*SW_a$!$!$s)$!C$!fo$!$!$!$!L@DB ! !S ! !S\ ! ! ! !D6B f    QQQQQQf:::S<6S<S<S<S2 2 62 2 2 2 2 2 h&&& 333=3=3=3=3=3~     66$V$$$$$$$$r4r)ccxt.async_supportccxt ccxt.async_support.base.ws.cacherrrCccxt.base.typesrrrrr r r r !ccxt.async_support.base.ws.clientr typingrccxt.base.errorsrrrrr async_supportrr/r4r3rJs2 OOOOOOOOWWWWWWWWWWWWWWWWWWWW444444******000000......''''''&&&&&&l $l $l $l $l $$$0l $l $l $l $l $r4