iTcddlZddlmZddlZddlmZmZmZm Z m Z m Z ddl m Z ddlmZddlmZddlmZddlmZGd d ejjZdS) N) ArrayCache)IntMarket OrderBookStringsTickerTrade)Client)List) ExchangeError)AuthenticationError) NotSupportedc eZdZfdZdifdedefdZdifdedefdZifdedifd Zifde edifd Z ifdede fd Z d e fd Zd"defdZd e fdZd"dedede fdZddifdededede efdZddifde ededede efdZdZd"dZdifdededefdZdifde ededefdZdZdZdZ dZ!d e fdZ"d e fd Z#d!Z$xZ%S)#coinbaseinternationalc *|tt|idddddddddddddd d d d d d d d d dd dd dd dd dd dd d d d d d d dddiddidddiddddddtiidS)NwsT watchTradeswatchTradesForSymbolswatchOrderBookwatchOrderBookForSymbols watchTicker watchBalanceF watchMyTrades watchOHLCVwatchOHLCVForSymbols watchOrderswatchOrdersForSymbolswatchPositions watchTickers createOrderWs editOrderWs cancelOrderWs)cancelOrdersWscancelAllOrdersWs fetchOrderWs fetchOrdersWsfetchBalanceWsfetchMyTradesWsz&wss://ws-md.international.coinbase.comzwss://ws-md.n5e2.coinbase.com)apitestchannelLEVEL1)r tradesLimit ordersLimit myTradesLimitexactzUnable to authenticate)hasurlsoptions exceptions) deep_extendsuperrdescriber )self __class__s d/var/www/html/crypto-bot/backend/venv/lib/python3.11/site-packages/ccxt/pro/coinbaseinternational.pyr8zcoinbaseinternational.describes&;T B B K K M Mdt(!$  +D  t  e'u(!%  u!" #$#(%* %!&"'#(/6B9 x  $#!% ,.AU/P /P / / / NnamesymbolscbK|d}|}g}||j}t|}|dkrH||}||} | }|dzd|z}n8|dkr2||d}|dz|dz}|dg}|jdd } | t|j d zt| } | |j zd z|j z} ||| ||jt$jd } d ||g| |j |j | d}|| |||||d{VS)a * @ignore subscribes to a websocket channel :see: https://docs.cloud.coinbase.com/intx/docs/websocket-overview#subscribe :param str name: the name of the channel :param str[] [symbols]: unified market symbol :param dict [params]: extra parameters specific to the exchange API endpoint :returns dict: subscription to a websocket channel N::,rsymbolidr)r( is not supported in sandbox environmentCBINTLMDbase64 SUBSCRIBE)type product_idschannelstimekey passphrase signature)check_required_credentialsr>lenmarket_symbols market_idsjoinmarketr3rrDstrnonceapiKeypasswordhmacencodebase64_to_binarysecrethashlibsha256watchextend)r9r=r>paramsrU messageHash productIds symbolsLength parsedSymbols marketIdsurl timestampauthrO subscribes r;rkzcoinbaseinternational.subscribeEs '')))  ?lGG 1   //88M 66I"J%,sxx /F/FFKK a  [[,,F+x(88K ,Jit$ ;tw)SSTT T %% 4;&3dmCIIdkk$//1F1Ft{1S1SU\Ucemnn %;-"  ZZ[$++i2P2PR]^^^^^^^^^r<cK|||r|j}n||}g}g}t dt |D]b}|||}||}||||dz|zc|j dd} | t|j dz| | } | |jzdz|jz} ||| ||jt(jd} d | ||g|j|j| d } || ||| ||d{VS) a * @ignore subscribes to a websocket channel using watchMultiple :see: https://docs.cloud.coinbase.com/intx/docs/websocket-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 rrAr)rNrErFrGrH)rIrLrJrKrMrNrO)rPis_emptyr>rRrangerQ market_idrCappendr3rrDnumber_to_stringsecondsrXrYrZr[r\r]r^r_watch_multiplera)r9r=r>rb messageHashesrdimarketIdrCrhrirjrOrks r;subscribe_multiplez(coinbaseinternational.subscribe_multipleps ''))) == ! ! 3lGG))'22G  q#g,,'' 7 7A~~gaj11H[[**F   h ' ' '  v!5 6 6 6 6it$ ;tw)SSTT T))$,,..99 4;&3dmCIIdkk$//1F1Ft{1S1SU\Ucemnn %;-"  ((mT[[TZ=[=[]jkkkkkkkkkr<rCreturncBK|d|g|d{VS)ax watch the current funding rate :see: https://docs.cloud.coinbase.com/intx/docs/websocket-channels#funding-channel :param str symbol: unified market symbol :param dict [params]: extra parameters specific to the exchange API endpoint :returns dict: a `funding rate structure ` RISKN)rk)r9rCrbs r;watch_funding_ratez(coinbaseinternational.watch_funding_rates2^^FVHf=========r<c@K|d||d{VS)a watch the funding rate for multiple markets :see: https://docs.cloud.coinbase.com/intx/docs/websocket-channels#funding-channel :param str[]|None symbols: list of unified market symbols :param dict [params]: extra parameters specific to the exchange API endpoint :returns dict: a dictionary of `funding rates structures `, indexe by market symbols rzN)rw)r9r>rbs r;watch_funding_ratesz)coinbaseinternational.watch_funding_ratess2,,VWfEEEEEEEEEr<c|Kd}||ddd\}}|||g|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/intx/docs/websocket-channels#instruments-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 ` Nrr+r,)handle_option_and_paramsrk)r9rCrbr+s r; watch_tickerz"coinbaseinternational.watch_tickersU77 yZbcc^^GfXv>>>>>>>>>r<clientc||}||d}||||||dz|dzdSNr+rArC)parse_ws_instrument safe_stringresolver9rmessagetickerr+s r;handle_instrumentz'coinbaseinternational.handle_instrumentsh4))'22""7I66vw'''vw~x0@@AAAAAr<rc ||d}||d}|id|d|||dd||d|ddd dd dd dd dd dddddddddddddddd||d||ddS)N product_idrLinforC-ridatetimehighlowbid bidVolumeask askVolumevwapopencloselast previousClosechange percentagetotal_24_hour_quantitytotal_24_hour_volume)average baseVolume quoteVolume)r safe_ticker safe_symbol parse8601)r9rrUrvrs r;rz)coinbaseinternational.parse_ws_instrumentsm6##FL99##FF33! F! d&&x==!  11!   ! D ! 4 !  4!  !  4!  !  D!  D!  T!  D!  T! d!! " $#! $**63KLL++F4JKK)! ! !    r<c||}||d}||||||dz|dzdSr)parse_ws_tickerrrrs r; handle_tickerz#coinbaseinternational.handle_ticker sh2%%g..""7I66vw'''vw~x0@@AAAAAr<rUc||d}||d}|id|d|||d||d|d||dd ||d d ||d d ||dddddddddddddddddddddddS)NrLrrrCrirr bid_pricerbid_qtyr ask_pricerask_qtyrrrrrrrrr)rrr)rrrr safe_number)r9rrUrrvs r;rz%coinbaseinternational.parse_ws_ticker(s##FF33##FL99! F! d&&x88!  11!   ! 4##FK88 ! ))&)<< !  4##FK88!  ))&)<<!  D!  4!  D!  T!  D!  d!  $! t!! " D#! $!)! ! !    r<sincelimitcDK||g|||d{VS)a5 get the list of most recent trades for a particular symbol :see: https://docs.cloud.coinbase.com/intx/docs/websocket-channels#match-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)watch_trades_for_symbols)r9rCrrrbs r; watch_tradesz"coinbaseinternational.watch_tradesOs622F8UE6RRRRRRRRRr<cjK|d{V||dddd}|d||d{V}|jrB||d}||d}|||}||||ddS)a get the list of most recent trades for a list of symbols :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 ` NFTMATCHrrCri) load_marketsrRrw newUpdates safe_dictrgetLimitfilter_by_since_limit)r9r>rrrbtradesfirst tradeSymbols r;rz.coinbaseinternational.watch_trades_for_symbols[s!!!!!!!!!%%gtUD$GG..wHHHHHHHH ? 8NN61--E**5(;;KOOK77E))&% TRRRr<c||}|d}||d}||jvr5||jdd}t |}||j|<|j|}||||j|<||||||dz|dz|S)NrCr+r.r-rA)parse_ws_traderr safe_integerr4rrpr) r9rrtraderCr+rtradesArrayCache tradesArrays r; handle_tradez"coinbaseinternational.handle_tradems##G,,x""7I66$+%%%%dlM4HHE)%00 "2DK k&) 5!!!) F{G,,,{GdNU8_$DEEEr<c||dd}||d}||||dd||||||d||dd||d||dddd S) NrCrrLmatch_id agressor_side trade_price trade_qty) rrDorderrirrCrIside takerOrMakerpriceamountcostfee) safe_string_2r safe_traderrsafe_string_lower)r9rrUrvrs r;rz$coinbaseinternational.parse_ws_trades%%eX|DD##E622""5*5511 &&x88**5/BB %%e];;&&uk::     r<cBK||g||d{VS)M watches information on open orders with bid(buy) and ask(sell) prices, volumes and other data :see: https://docs.cloud.coinbase.com/intx/docs/websocket-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 N)watch_order_book_for_symbols)r9rCrrbs r;watch_order_bookz&coinbaseinternational.watch_order_books466xOOOOOOOOOr<ctK|d{V|d||d{VS)rNLEVEL2)rrw)r9r>rrbs r;rz2coinbaseinternational.watch_order_book_for_symbolssV!!!!!!!!!,,XwGGGGGGGGGr<c||d}||d}||}||d}||d}||jvr:||jdd}|i||j|<|j|} |dkr4|||ddd } | | || d <n-||d g} | | | ||d | d <|| d<| || d<| |j|<| | |dz|zdS)NrIrrLr+watchOrderBookLimitr-SNAPSHOTbidsasksrCchangessequencerWrrirA) rr orderbooksrr4 order_bookparse_order_bookreset safe_list handle_deltasrr) r9rrrIrvrCrr+r orderbookparsedSnapshotrs r;handle_order_bookz'coinbaseinternational.handle_order_booksH00##G\::!!(++##GV44""7I66$/))%%dl4I4PPE&*oob%&@&@DOF #OF+ :  !227FD&RXYYN OON + + +"(Ih  nnWi<>>s>">>>>DFFFcF"FFFF68 ? ? ?F ? ? ? ?BBBBB>2 2 $2 2 2 2 hBFBBBB<% % f% f% % % % % N<@d[] S S SS S Sbfglbm S S S SOSaenpSSd3iSS[^SuyzvASSSS$8    >@DB P PS P PS\ P P P PSW_a H H$s) HC Hfo H H H H8;8;8;t&&&4446L&LLLL66.$$$$$$$r<r)ccxt.async_supportccxt ccxt.async_support.base.ws.cacherr^ccxt.base.typesrrrrrr !ccxt.async_support.base.ws.clientr typingr ccxt.base.errorsr r r async_supportrrr<r;r!s 777777JJJJJJJJJJJJJJJJ444444******000000))))))T $T $T $T $T $D.DT $T $T $T $T $r<