i~0ddlmZddlmZddlZddlmZmZmZm Z m Z m Z m Z m Z mZmZmZmZmZmZmZmZmZmZddlmZddlmZddlmZddlmZdd lmZdd lmZdd lm Z dd lm!Z!dd lm"Z"ddlm#Z#ddlm$Z$ddl%m&Z&ddl'm(Z(GddeeZ)dS))Exchange) ImplicitAPIN)AccountBalances CurrenciesCurrencyIntMarketMarketInterfaceNumOrder OrderBook OrderSide OrderTypeStrStringsTickerTickersTrade Transaction)List) ExchangeError)AuthenticationError)PermissionDenied)ArgumentsRequired) BadRequest) InvalidOrder) OrderNotFound) NotSupported)RateLimitExceeded) InvalidNonce) TICK_SIZE)Precisec eZdZfdZifdZifdeefdZifdeefdZifdeefdZ ifdeefdZ dZ ifd e fd Z d d d ifd ed edefdZd d d ifd ed edefdZd d d ifd ed edefdZd d d ifd ed ededeefdZd d d ifd ed ededeefdZdZd^dedefdZd^dedefdZifdeefdZifdZifdZdefdZ defdZ!ifdZ"ifde#fdZ$d ifd e%de&fd!Z'd ifd e%fd"Z(d ifd e%fd#Z)ifd e de*fd$Z+ifd e fd%Z,ifd e fd&Z-d^dede*fd'Z.ifd(Z/ifde0fd)Z1d d d ifd ed edefd*Z2d+Z3d,Z4d^defd-Z5ifd.Z6d ifdefd/Z7d d ifd edefd0Z8ifd e d1e9fd2Z:d ifd e d3e;d4ed^dede?fd8Z@d9ZAd:ZBd;ZCd ifdZEd d ifddd?dd@ddAddBddCddDddEddFddGdidHddIddJddKddLddMddNddOddPddQddRddSddTddUddVddWddXddddddddddddddddYdZd[d\d]id^d_d`gdadbgdcdddedddfdgdhdididididididididjiidkdidldidmdidndidodidpdidqdidrdidsdidtdidudidvdidwdidxdidydidzdid{dididid|didididididididididididididid}didid~dididdddhddiiiddddddddddddddddddddddddddddddddddddddddddddddddddddddd ddidddddddd|d|ddd|d|dg|d|dg|d|dg|d|dg|d|dg|d|dg|d|dg|d|dg|d|dgg |d|dg|d|dg|d|dg|d|dg|d|dg|d|dg|d|dg|d|dg|d|dgg ddidt didtdtdtdtdtdtdtdtdtdtdtdtdtdtdtdtdttttttdȜttdɜdʜddddddddddԜdddiddgdڢddiddgddgdddddddddddddiS)Nidr%nameCoinbase countriesUSproT rateLimit"versionv2 userAgentchromeheadersz CB-VERSIONz 2018-05-30hasCORSspotmarginFswapfutureoption addMargin cancelOrder cancelOrderscloseAllPositions closePositioncreateDepositAddresscreateLimitBuyOrdercreateLimitSellOrdercreateMarketBuyOrdercreateMarketBuyOrderWithCostcreateMarketOrderWithCostcreateMarketSellOrdercreateMarketSellOrderWithCost createOrdercreatePostOnlyOrdercreateReduceOnlyOrdercreateStopLimitOrdercreateStopMarketOrdercreateStopOrderdeposit editOrder fetchAccounts fetchBalance fetchBidsAsksfetchBorrowRateHistoriesfetchBorrowRateHistoryfetchCanceledOrdersfetchClosedOrdersfetchCrossBorrowRatefetchCrossBorrowRatesfetchCurrencies fetchDepositfetchDepositAddressemulatedfetchDepositAddressesfetchDepositAddressesByNetwork fetchDepositsfetchFundingHistoryfetchFundingRatefetchFundingRateHistoryfetchFundingRatesfetchIndexOHLCVfetchIsolatedBorrowRatefetchIsolatedBorrowRatesfetchL2OrderBook fetchLedger fetchLeveragefetchLeverageTiersfetchMarginMode fetchMarketsfetchMarkOHLCV fetchMyBuys fetchMySells fetchMyTrades fetchOHLCVfetchOpenInterestHistoryfetchOpenOrders fetchOrderfetchOrderBook fetchOrders fetchPositionfetchPositionModefetchPositions)fetchPositionsRiskfetchPremiumIndexOHLCV fetchTicker fetchTickers fetchTime fetchTradesfetchTradingFeefetchTradingFeesfetchWithdrawals reduceMargin setLeverage setMarginModesetPositionModewithdrawurlszchttps://user-images.githubusercontent.com/1294454/40811661-b6eceae2-653a-11e8-829e-10bfadb078cf.jpgrestzhttps://api.coinbase.comzhttps://www.coinbase.comz&https://developers.coinbase.com/api/v2z?https://docs.cloud.coinbase.com/advanced-trade-api/docs/welcomezYhttps://support.coinbase.com/customer/portal/articles/2109597-buy-sell-bank-transfer-feesz&https://www.coinbase.com/advanced-feesz6https://www.coinbase.com/join/58cbe25a355148797479dbd2)logoapiwwwdocfeesreferralrequiredCredentials)apiKeysecretrgetg333333%@) currencieszcurrencies/cryptotimezexchange-rateszusers/{user_id}zprices/{symbol}/buyzprices/{symbol}/sellzprices/{symbol}/spotaccountsaccounts/{account_id}accounts/{account_id}/addressesz,accounts/{account_id}/addresses/{address_id}z9accounts/{account_id}/addresses/{address_id}/transactions"accounts/{account_id}/transactions3accounts/{account_id}/transactions/{transaction_id}accounts/{account_id}/buysz#accounts/{account_id}/buys/{buy_id}accounts/{account_id}/sellsz%accounts/{account_id}/sells/{sell_id}accounts/{account_id}/depositsz+accounts/{account_id}/deposits/{deposit_id}!accounts/{account_id}/withdrawalsz1accounts/{account_id}/withdrawals/{withdrawal_id}zpayment-methodsz#payment-methods/{payment_method_id})userz user/auth)rzaccounts/{account_id}/primaryrrz > @ @YC *YC JYC  $YC  4 YC  YC  tYC  2YC  lYC SSS%S S % S % SUStSS$US S'S&tS'S'S /!S",U#SS$(%S&0'S(t)S*&t+S,(-S.'/S0(1S2"43S445S6T7S8 9S:;S< =S>+E?S@)%ASB&tCSD$TESSSF'GSH(ISJ"4KSLMSN&zOSP(QSR1$SST USV&uWSX#EYSZ*5[S\$U]S^"5_S`*5aSb+EcSd#EeSftgSSSh iSj%ekSl"5mSnoSp!%qSrtsStuSv wSxdySz+E{S|"4}S~dS@!$ASBtCSD ESF$UGSH!$ISSJ',*/# $!##($)$( %$!&#( eSSS!YC H }62<U p<UIYC h "$$iYC p *.15$(.2/3374848    & 3T >t KD   XY]   A$  RSW 9$ B4 :4 DT =d J4 @ PQU  .t! "B4# $%))-'   ,)-=A?CBF\`Z^:>JN;?LP>BRVAEX\!!"6:$(   .2SW##U. . <<~,a   0! ? @ @   Ea   1!  >q Fq Ea 5a 5a 56=>8945?@78BC=>78?@!! DQ FG45##[1 1  88}wwqYC ` !..w77!..w77!%"&"..s33T5F5Fw5O5OP!..w779J9J79S9ST!..w779J9J89T9TU!..x88$:K:KG:T:TU!..y994;L;LX;V;VW!..z::D$m' &}  01D  56I 23F=>Q'(;+,?45H$%8$%8$%8$%8  !"*+<#$.;7A)3)9(2-22>=J3cYC ^ "#'&     _ YC r !s YC x " H H Ht$ *' ($6: 0. 0!2 6.(-7y YC YC Y Y Y cV||jdd}||d|}||d}d}|dkr-||}||di}n||}||ddS)a fetches the current integer timestamp in milliseconds from the exchange server :see: https://docs.cloud.coinbase.com/sign-in-with-coinbase/docs/api-time#http-request :param dict [params]: extra parameters specific to the exchange API endpoint :param str [params.method]: 'v2PublicGetTime' or 'v3PublicGetBrokerageTime' default is 'v2PublicGetTime' :returns int: the current integer timestamp in milliseconds from the exchange server r~rmethodNdataepoch epochSeconds) safe_stringromitr safe_dictv3PublicGetBrokerageTimesafe_timestamp_2)rparams defaultMethodr responses r  fetch_timezcoinbase.fetch_timews(({DUVV !!&(MBB68,, & & &++F33H~~h;;HH44V<` indexed by the account type rPr)rrfetch_accounts_v3fetch_accounts_v2rrr s r fetch_accountszcoinbase.fetch_accountssR!!$,ARSS & & &))&11 1%%f---r c T|d}||dd\}}|r|dddd|dddd Sddi}||||}||dg}||d i}||d}||dg}t|} | d z } ||| } ||d kr || d<| || <| ||S) NFrPpaginatenext_starting_afterstarting_afterdlimitr  paginationr) load_marketshandle_option_and_paramsfetch_paginated_call_cursorrextend safe_listrrlenparse_accounts) rrr requestrr r%cursorrlength lastIndexlasts r rzcoinbase.fetch_accounts_v2se 88R\]]&  S33OT4QUW]_twGIMORSS S S ,,T[[&-I-IJJZ~~h33^^HlB?? !!*.CDD>>(FB77XQJ ~~h 22  Vr\\*0D& '"&HY ""4000r c |d}||dd\}}|r|dddd|dddd Sddi}||||}||dg}t |}|dz }|||}||d} | | d kr | |d<|||<| ||S) NFrPr r/r#r$rrr&) r'r(r)v3PrivateGetBrokerageAccountsr*r+r,rrr-) rrr r.rrr0r1r2r/s r rzcoinbase.fetch_accounts_v3s" 88R\]]&  ~33OT4QUW]_giqswy|}} } S 55dkk'66R6RSS>>>(J;;XQJ ~~h 22!!(H55  Vr\\#DN"&HY ""8V444r c6||}||dg}g}tdt|D]L}||}|||d||dd|dM|S)as fetch all the portfolios :see: https://docs.cloud.coinbase.com/advanced-trade-api/reference/retailbrokerageapi_getportfolios :param dict [params]: extra parameters specific to the exchange API endpoint :returns dict: a dictionary of `account structures ` indexed by the account type portfoliosruuidtypeNr'r8codeinfo)v3PrivateGetBrokeragePortfoliosr+ranger,appendr)rrrr6resulti portfolios r fetch_portfolioszcoinbase.fetch_portfolioss77??^^HlB?? q#j//**  A"1 I MM&&y&99((F;;!       r c||d}||d}||di}||d|}||d}||d}|d}||dd|||d n||||d S) Nactivecurrencyr:r(r8 r'r7rr9) safe_boolrrsplit safe_string_2safe_string_lowersafe_currency_code) raccountrD currencyIdV3rE currencyIdtypeV3typeV2partss r  parse_accountzcoinbase.parse_account/sp22''<< >>':r::%%h EE !!'622!!'622 S!!$$WdF;;9?9KD**5!444RX++J77    r r:cN||d}||d}|h|tdt |jD]1}|j|}|d|kr|ddkr |d}n2|t |jdzd|i}|| ||}| |d i}||d } ||d } || | |d S) a create a currency deposit address :see: https://docs.cloud.coinbase.com/sign-in-with-coinbase/docs/api-addresses#create-address :param str code: unified currency code of the currency for the deposit address :param dict [params]: extra parameters specific to the exchange API endpoint :returns dict: an `address structure ` account_idNrr:r8rr'zs createDepositAddress() could not find the account with matching currency code, specify an `account_id` extra paramr destination_tagaddress)rEtagrVr;) rr load_accountsr=r,rrr''v2PrivatePostAccountsAccountIdAddressesr*r) rr:r accountIdr@rLr.rr rWrVs r create_deposit_addresszcoinbase.create_deposit_addressusX$$V\:: 6<00      1c$-0011  -*6?d**wv(/J/J ' IE  +`!`aa a ) ?? GU[@\@\]]J~~h33t%677""433    r Nsymbolsincer$c|||}|||ddg}||||}||dd||S)a! * @ignore fetch sells :see: https://docs.cloud.coinbase.com/sign-in-with-coinbase/docs/api-sells#list-sells :param str symbol: not used by coinbase fetchMySells() :param int [since]: timestamp in ms of the earliest sell, default is None :param int [limit]: max number of sells to return, default is None :param dict [params]: extra parameters specific to the exchange API endpoint :returns dict: a `list of order structures ` rTrZr N)prepare_account_requestr'r"v2PrivateGetAccountsAccountIdSellsr* parse_trades)rr\r]r$rr.querysellss r fetch_my_sellszcoinbase.fetch_my_sellss..uf==  &<"=>>77 GU8S8STT  veUCCCr c|||}|||ddg}||||}||dd||S)a * @ignore fetch buys :see: https://docs.cloud.coinbase.com/sign-in-with-coinbase/docs/api-buys#list-buys :param str symbol: not used by coinbase fetchMyBuys() :param int [since]: timestamp in ms of the earliest buy, default is None :param int [limit]: max number of buys to return, default is None :param dict [params]: extra parameters specific to the exchange API endpoint :returns dict: a list of `order structures ` rTrZr N)r_r'r!v2PrivateGetAccountsAccountIdBuysr*ra)rr\r]r$rr.rbbuyss r  fetch_my_buyszcoinbase.fetch_my_buyss..uf==  &<"=>>55dkk'56Q6QRR  ftUEBBBr cd}||||\}}|t|||||}||dd||S)Nr )*prepare_account_request_with_currency_coder'getattrr*parse_transactions)rr r:r]r$rr.rs r fetch_transactions_with_methodz'coinbase.fetch_transactions_with_methods|II$PUW]^^ (74((Wf)E)EFF&&x'7ueLLLr c4|d||||S)a< fetch all withdrawals made from an account :see: https://docs.cloud.coinbase.com/sign-in-with-coinbase/docs/api-withdrawals#list-withdrawals :param str code: unified currency code :param int [since]: the earliest time in ms to fetch withdrawals for :param int [limit]: the maximum number of withdrawals structures to retrieve :param dict [params]: extra parameters specific to the exchange API endpoint :returns dict[]: a list of `transaction structures ` (v2PrivateGetAccountsAccountIdWithdrawalsrmrr:r]r$rs r fetch_withdrawalszcoinbase.fetch_withdrawalss%223]_cejlqsyzzzr c4|d||||S)a+ fetch all deposits made to an account :see: https://docs.cloud.coinbase.com/sign-in-with-coinbase/docs/api-deposits#list-deposits :param str code: unified currency code :param int [since]: the earliest time in ms to fetch deposits for :param int [limit]: the maximum number of deposits structures to retrieve :param dict [params]: extra parameters specific to the exchange API endpoint :returns dict[]: a list of `transaction structures ` %v2PrivateGetAccountsAccountIdDepositsrprqs r fetch_depositszcoinbase.fetch_depositss%223Z\`bginpvwwwr c<dddd}||||S)Npendingokcanceled)created completedryrrstatusstatusess r parse_transaction_statusz!coinbase.parse_transaction_statuss1 "   &&999r rEct||d}d}d}|dkrF||di}||di}||di}n.||di}||di}|||d}|||d }|rd nd }||d } ||d } ||d } ||d} ||di} || d}id|d | d| d|| d| ddd|d|ddddddddd||dd||dd || |d|d|||dd||d|| diS)Nr8sendnetworktransaction_amounttransaction_feesubtotalfeer~ committedrxrwr'rE created_attorVr;txid timestampdatetime addressTo addressFromrWtagTotagFromresourceamountupdated updated_atcostrE)rrrrG parse8601 safe_numberrK)r transactionrEtransactionTypeamountAndCurrencyObject feeObjectrr~rr'rN feeCurrencyIdrtoObject toAddresss r parse_transactionzcoinbase.parse_transactionsf**;??"& f $ $nn[)R@@G&*nnW>RTV&W&W #w0A2FFII&*nn[*b&Q&Q #{E2>>I..t/?/? X/V/VWW >{K@@I&5TTIF   k4 0 0%%&=zJJ ((J?? ##K>>>>+tR88$$Xy99  K "  B  11    t   y    4  4  T  t  D$$[*==  d&&'>II  // HEE f! " t~~d&6&6{L&Q&QRR# $ ((H== 33MBB%   r marketcd}||di}||di}||di}||di}||d}|||d}| |d}nb||d} ||d} | 4| 2|| } || } | d z| z}||d } ||d }d}||d }| r|}t j||}||d }||d|}||d|}d}d}||t j||}n|}||t j||}n|}||d}||d| |}| | ||d}| |gd}| |dd}| |d}| |||dd||d||||d|dkrdn||dkrdn|||||||dd S)Ntotalrrr product_id-r\rE/ size_in_quotepricesize commissionquote)r trade_timerrsideliquidity_indicatorr'trade_idorder_idunknown_order_sideunknown_liquidity_indicatorr) r;r'orderrrr\r8r takerOrMakerrrrr)rr safe_marketrKrGr# string_div string_mulrr safe_string_nsafe_string_lower_2rJ safe_traderIr)rtraderr\ totalObject amountObjectsubtotalObjectrmarketIdbaseIdquoteIdbaser sizeInQuotev3Pricev3Costv3Amount v3FeeCost amountString costString priceStringrrfeeCostrrrs r  parse_tradezcoinbase.parse_tradesF|nnUGR88 ~~eXr:: z2>>NN5%44 ##E<88!!(FC88  H%FF%%lJ??F&&{J??G")<..v66//88e+nnUO<< ""5'22##E622  =F)(G<r)rrrrrr dataByIdrbaseIdsr?r@rrr8j quoteCurrencyrrs r rzcoinbase.fetch_markets_v21s33F;;^^HlB?? x"EE ~~j&"55==t,,t~~mVRHH'SUVVuzz||$$q#g,,''9 9 AQZF**622D$0066xDxq#d)),,33A$(GM"..}dCCG 33G<parse_spot_marketparse_contract_market)rrspotUnresolvedPromisesunresolvedContractPromisesepromisescontractPromisesr6rexpiringFuturesperpetualFutures expiringFees perpetualFeesfeeTierexpiringFeeTierperpetualFeeTierr r?r@ futureData perpetualDatas r rzcoinbase.fetch_markets_v3vs  . .v 6 6  8 8 @ @" &(" ,224;;vX`Ga3b3bcc224;;vX`{FHGHG4H4HII<R>RSS * & &  , , ,)+ & & & & & & ,) "9   " " "!       "~~h2..~~h2....)91bAA>>*:ArBB~~&62>> '7B?? (..z266..z2FF>>-RHH~~dJ33q#d))$$ D DA MM$00a'BB C C C C^^OZDD q#j//** V VA MM$44Z]OTT U U U U'7RHH q#m,,-- Z ZA MM$44]15EGWXX Y Y Y Y s0B,C C1%C,,C19C<< DD  Dc||d}||d}||d}||}||}||d}||d} ||jdg} |id|d|d z|zd |d |d dd |d|ddd|d|dkddddddddd| ddddd||| rdn||d||| rdn||dddddd||d| |dd d!ddd"||d#||d$d"ddd"||d%||d&d"d'd|d( S))Nrbase_currency_idquote_currency_idrtrading_disabledrr'r\rrrrrrrr8r6r7r8Fr9r:rDrrgh㈵>taker_fee_rategmaker_fee_ratebase_incrementprice_incrementquote_incrementrr base_min_size base_max_sizequote_min_sizequote_max_sizer rrrrrrrrrrrzr;) rrKrJrGr+rsafe_market_structurein_arrayr safe_number_2) rrrr'rrrr marketTypetradingDisabledrs r rzcoinbase.parse_spot_markets@  fl 3 3!!&*<==""6+>??&&v..''00++FNCC ..1CDDnnT\="EE ))2+ "2+ dSj5(2+  D2+  U 2+ d 2+ f 2+  w2+  2+  J2+  Z6)2+  d2+  E2+  e2+  e2+  /)2+ !2+ " d#2+ $ $ b+ > >oWWDDTDTU\^nDoDo MM"k::kSS@P@PQXZj@k@k "**63CDD++F4EGXYY    ++FODD++FODD    ++F4DEE++F4DEE$c2+ 2+ 2+ 2 2 2 r c||d}||di}||d}||d}||d}||}|dk} ||d} ||d} || } || } ||d }| d z| z}d}| r d }|d z| z}n#d }|d z| zdz||z}||d}||d}|r|n|d}|r|n|d}|id|d|d| d| d| d| d| d| d|ddddd | d | ddd | d!d"d#d"d|||||dd||d$| |d%d&d'ddd(||d)||d*d(ddd(||d+||d,d(d-d|d. S)/Nrfuture_product_detailsr contract_sizecontract_expiryrcontract_root_unitr is_disabledrr8:r9rrrz0.06z0.04r'r\rrrrrrr8r6Fr7r:rDrTrrrrrrrrrrrr) rrrrrKrGyymmddrrr)rrrr'futureProductDetailscontractExpiryTypercontractExpireexpireTimestampisSwaprrrrrr\r8 takerFeeRate makerFeeRaterrs r rzcoinbase.parse_contract_marketsl  fl 3 3#~~f6NPRSS!--.BDZ[[''(@QRR..88$ 3!!"68LMM""6+>??&&v..''00..??e#  ODc\E)FFDc\E)C/$++o2N2NNF''1ABB ''1ABB ,K $2C2CF2K2K ,K $2C2CF2K2K))2+ "2+ f2+  D2+  U 2+ e 2+ f 2+  w2+  2+  D2+  E2+  e2+  F2+  &j2+  e2+  /)2+ !2+ " d#2+ $(%,**63CDD++F4EGXYY    ++FODD++FODD    ++F4DEE++F4DEE$c2+ 2+ 2+ 2 2 2 r c||jdi}||d}||dd}|}| ||z |kr||||g}|}||di}||di} ||dg} || dg} ||} ||| | | | |d|jd<||jdiS) NrYrrrrr )rrr) rr safe_integer millisecondsv2PublicGetCurrenciesv2PublicGetCurrenciesCryptor+v2PublicGetExchangeRatesr* array_concat) rrrrrnowrpromisesResult fiatResponsecryptoResponsefiatData cryptoDatars r rz$coinbase.fetch_currencies_from_cachesc../@"EE%%g{;; ##GY==!!  C)Ow#>#>**6220088H&N>>.!R@@L"^^NArBBN~~lFB??HCCJ 99&AAM.2kk'"//*EE!. DD//DL* + ~~dl,=rBBBr cf||}||dg}i}i}i}tdt|D] }||}||d} ||dd} || } ||d} | |jd| <| |jd| <|| | | d nd ||dd d d d d | |d d dd d ddd || <| | } | || <| || <| ||jd|jd<| ||jd|jd<|S)a fetches all available currencies on an exchange :see: https://docs.cloud.coinbase.com/sign-in-with-coinbase/docs/api-currencies#get-fiat-currencies :see: https://docs.cloud.coinbase.com/sign-in-with-coinbase/docs/api-exchange-rates#get-exchange-rates :param dict [params]: extra parameters specific to the exchange API endpoint :returns dict: an associative dictionary of currencies rrasset_idr'r:r(r networksByIdNrrTrr)rr) r;r'r:r8r(rDrNrrrr) rr+r=r,rrIrKlowerrrr*)rrrrr?rr>r@rEassetIdr'r:r( lowerCaseNames r fetch_currencieszcoinbase.fetch_currenciess33F;;^^HlB?? L q#j//**! 3! 3A!!}H&&x<` r}r)rrfetch_tickers_v3fetch_tickers_v2)rrCrr s r  fetch_tickerszcoinbase.fetch_tickersVsV!!$,@PQQ % % %((&99 9$$Wf555r c|||}i}||||}||di}||di}||d}i}t |} d} tdt| D]P} | | } | | z|z} | | d| }|d}| || |||<Q| |d|S)Nr rrErrr\) r'market_symbolsr4r*rrrrr=r,r parse_tickerfilter_by_array_tickers)rrCrr.rr rrr?r delimiterr@rrrr\s r rFzcoinbase.fetch_tickers_v2dsB %%g.. 00Wf1M1MNN~~h33tWb11""444uzz||$$ q#g,,'' F FAQZF )G3H%%hi@@FH%F!..uV}fEEF6NN++FHgFFFr c*|||}i}||||d<||||}||dg}i}t dt|D]X}||}||d} | | dd} | d} | || || <Y| |d|S)N product_idsrrrrr\) r'rI market_idsrr*r+r=r,rrrJrK) rrCrr.rr r?r@entryrrr\s r rEzcoinbase.fetch_tickers_v3s %%g..  %)__W%=%=GM "55dkk'66R6RSSL~~h B77q#d))$$ > >AGE''|<` r|r)rrfetch_ticker_v3fetch_ticker_v2)rr\rr s r  fetch_tickerzcoinbase.fetch_tickersT!!$, OO _ $ $''77 7##FF333r cH|||}|d|di|}||}||}||}||di}||di} ||di} || d|| d||dd} || |S)Nr\r'r r)bidaskr) r'rr*v2PublicGetPricesSymbolSpotv2PublicGetPricesSymbolBuyv2PublicGetPricesSymbolSellrrrJ) rr\rrr.r6rWrVspotDataaskDatabidData bidAskLasts r rSzcoinbase.fetch_ticker_v2s& V$$++ fTl //88--g66..w77>>$33..fb11..fb11##GX66##GX66%%h99    V444r c|||}|ddd}||||}||dg}||d|}||d|d<||d|d <|S) Nr'r)rr$tradesrbest_bidrVbest_askrW)r'r,v3PrivateGetBrokerageProductsProductIdTickerr*r+rJr)rr\rrr.rr tickers r rRzcoinbase.fetch_ticker_v3s V$$ ,  DDT[[QXZ`EaEabb&~~h"55""47F33((:>>u ((:>>u  r c>||d}||d}d}d}d|vr||dg}||dg}||dd}||dd}||dd}||dd}||d} ||d} ||d } |id || |d || d | d|d|d | ddddd|d|ddddd| ddddd||ddddd|d|S)NrVrWbidsasksrrrrrr\rrr2highlow bidVolume askVolumevwapopenclose previousClosechangerprice_percentage_change_24haverage) baseVolume quoteVolumer;)rr+r safe_ticker safe_symbolr) rrdrrVrWrjrkrfrgrr2rs r rJzcoinbase.parse_tickersBbvu--vu--  f  >>&&"55D>>&&"55D""47G44C((a&99I""47G44C((a&99I##FL9900##FF33! d&&x88! 11!  !  3 ! 3 ! D !  D!  4!  !  !  D!  D!  T!  T!  d! $**63PQQ!! " t#! $)! ! ! * + r c||ddg}||d|jd}||d|jd}d|i}tdt |D]\}||}||d} || |r||d} | || d} || } || d } | }||| }|| }||d <| |d <n>&&$,z2JKK^^FFDL4NOO (#q#h--((& +& +AqkG##GV44D}}T8,,# +w ::$!%!1!1%!D!DJ22:>>D ,,UH==E D"nnVT::G"&,,..*.+0((*1*NPU+V+V(#*F4LtZ00 + NN74GHH ~~gv66(T-=!%!1!1)Z!H!HJ22:>>D++D'::D++Iw??D#.tT::E"nnVT::G"&,,..*.*.+0((*1*NPU+V+V(#*F4L  (((r c^|i}d}||dd}||dg}d}|dd|\}}||jdd}|dkr*||||}ne|s|dkr/d|d<||||}n.d |d<| |||}||d <| ||S) a query for balance and get the amount of funds available for trading or funds locked in orders :see: https://docs.cloud.coinbase.com/advanced-trade-api/reference/retailbrokerageapi_getaccounts :see: https://docs.cloud.coinbase.com/sign-in-with-coinbase/docs/api-accounts#list-accounts :see: https://docs.cloud.coinbase.com/advanced-trade-api/reference/retailbrokerageapi_getfcmbalancesummary :param dict [params]: extra parameters specific to the exchange API endpoint :param boolean [params.v3]: default False, set True to use v3 api endpoint :param dict [params.type]: "spot"(default) or "swap" or "future" :returns dict: a `balance structure ` NrFrQr4r9r$r#r8) r'rGrhandle_market_type_and_paramsrr&v3PrivateGetBrokerageCfmBalanceSummaryr*r4rr)rrr.risV3rr s r  fetch_balancezcoinbase.fetch_balancesD ~~fdE226D6** !??PTV\]] F!!$,@_``  ! !BB4;;wX^C_C_``HH O"AAA"GG 99$++gv:V:VWWHH"GG 00Wf1M1MNNHP$v((6:::r c ~|d}||dd\}}|r|d||||dddd Sd}|||}d}||||\}}||||}||d|||} t| } | d kr| S| d z } | | | } | |d i} | | d}||d kr || d<| | | <| S) ar fetch the history of changes, actions done by the user or operations that altered balance of the user :see: https://docs.cloud.coinbase.com/sign-in-with-coinbase/docs/api-transactions#list-transactions :param str code: unified currency code, default is None :param int [since]: timestamp in ms of the earliest ledger entry, default is None :param int [limit]: max number of ledger entrys to return, default is None :param dict [params]: extra parameters specific to the exchange API endpoint :param boolean [params.paginate]: default False, when True will automatically paginate by calling self endpoint multiple times. See in the docs all the [availble parameters](https://github.com/ccxt/ccxt/wiki/Manual#pagination-params) :returns dict: a `ledger structure ` Frhr r!r"Nr#r rrr%r&) r'r(r)rErj)v2PrivateGetAccountsAccountIdTransactionsr* parse_ledgerr,rr)rr:r]r$rr rEr.rledgerr0r1r2r%r/s r  fetch_ledgerzcoinbase.fetch_ledgers 88PZ[[&  S33M4PUW]_twGIMORSS S  }}T**HII$PUW]^^AA$++gW]B^B^__""8F#3XueLLV Q;;MQJ ~~fi00^^HlB?? !!*.CDD  Vr\\*0D& ' $F9  r c8ddi}||||S)Nr{rxr|)rr~typess r parse_ledger_entry_statusz"coinbase.parse_ledger_entry_status6s(  vv666r c Hdddddddddd }||||S)Nrr) buysell fiat_depositfiat_withdrawalexchange_depositexchange_withdrawalr pro_depositpro_withdrawalr|rr8rs r parse_ledger_entry_typez coinbase.parse_ledger_entry_type<sC), -#0!(+   tT222r c.||di}||d}d}tj|drd}tj|}nd}||d}|||}d}||di} || d} | G|| d} || |} || d} | | d}|||d }||d }|||d }| ||d }||d }d}|2| d}t|}|dkr|d}|||| |||dd||| |dd||dS)NrroutinrErrrrr'r8r~ resource_pathrr)r;r'rr directionrL referenceIdreferenceAccountr8rErbeforeafterr~r)rrr# string_lt string_negrKrrrrrHr,iso8601r)ritemrE amountInforrrNr:r networkInfofeeInforfeeCurrencyCode feeAmountrr'r8r~pathrZrQnumPartss r parse_ledger_entryzcoinbase.parse_ledger_entryJs6h^^D(B77 !!*h77  VS ) ) I'//FFI%%j*== &&z8<<nnT9b99 ...?@@   ,,WjAAM"55mXNNO(((;;I!+CNN4#3#3D,#G#GHH   dD ) )++D,<,??  |'3o)oppp,,T6::I #DG.w$wz~$~ )   $GG   r rc|||}|dst|jdzd|d<||dd|d|S)a create a market buy order by providing the symbol and cost :see: https://docs.cloud.coinbase.com/advanced-trade-api/reference/retailbrokerageapi_postorder :param str symbol: unified symbol of the market to create an order in :param float cost: how much you want to trade in units of the quote currency :param dict [params]: extra parameters specific to the exchange API endpoint :returns dict: an `order structure ` r6z9 createMarketBuyOrderWithCost() supports spot orders onlyFrrrN)r'rrr' create_order)rr\rrrs r !create_market_buy_order_with_costz*coinbase.create_market_buy_order_with_cost ss V$$f~ ftw)ddee e6;23  5$fMMMr r8rrrc |||}||jdd}|dz|z|d|d} ||gd} ||d} ||d} | d u} | d u}| d u}||d }|d krd n||d dd}||d}||d}|dkr | r| |dkrdnd}|dks|d|t|j dzd| ||| ||| || ||di| d<nd| ||| ||| || |di| d<n|s|rd }|r#| |dkrdnd}| || }n"| |dkrdnd}| || }d| ||| ||||di| d<n|dks|O|t|j dzd| ||| ||||di| d<n|dkr4d | ||| ||d!i| d<nrd"| ||| |||d#i| d<n=| s|s|rt|j d$z|d%r|dkrd }d }||d&d'd \}}||d(}||d(}||||}n|ro|t#|j d)z||}||}t'j||}|||}n|||}d*d+|ii| d<nd*d,| ||ii| d<||d-}||d.krd/| d0<n |d1krd2| d0<||gd3}||d4d5d}d }|rX||d4d5g}|| d6} ||| |}n)||| |}||d7}|d ur||d8}||d9} ||d:}!|S||jd;| |!||jd<| |!t|!||d=i}"||"|S)>a create a trade order :see: https://docs.cloud.coinbase.com/advanced-trade-api/reference/retailbrokerageapi_postorder :param str symbol: unified symbol of the market to create an order in :param str type: 'market' or 'limit' :param str side: 'buy' or 'sell' :param float amount: how much you want to trade in units of the base currency, quote currency for 'market' 'buy' orders :param float [price]: the price to fulfill the order, in units of the quote currency, ignored in market orders :param dict [params]: extra parameters specific to the exchange API endpoint :param float [params.stopPrice]: price to trigger stop orders :param float [params.triggerPrice]: price to trigger stop orders :param float [params.stopLossPrice]: price to trigger stop-loss orders :param float [params.takeProfitPrice]: price to trigger take-profit orders :param bool [params.postOnly]: True or False :param str [params.timeInForce]: 'GTC', 'IOC', 'GTD' or 'PO' :param str [params.stop_direction]: 'UNKNOWN_STOP_DIRECTION', 'STOP_DIRECTION_STOP_UP', 'STOP_DIRECTION_STOP_DOWN' the direction the stopPrice is triggered from :param str [params.end_time]: '2023-05-25T17:01:05.092Z' for 'GTD' orders :param float [params.cost]: *spot market buy only* the quote quantity that can be used alternative for the amount :param boolean [params.preview]: default to False, wether to use the test/preview endpoint or not :param float [params.leverage]: default to 1, the leverage to use for the order :param str [params.marginMode]: 'cross' or 'isolated' :param str [params.retail_portfolio_id]: portfolio uid :param boolean [params.is_max]: Used in conjunction with tradable_balance to indicate the user wants to use their entire tradable balance :param str [params.tradable_balance]: amount of tradable balance :returns dict: an `order structure ` rrrr')client_order_idrr) stopPrice stop_price triggerPrice stopLossPricetakeProfitPriceN timeInForcePOTpostOnly post_onlyFend_timestop_directionr$rSTOP_DIRECTION_STOP_DOWNSTOP_DIRECTION_STOP_UPGTDz= createOrder() requires an end_time parameter for a GTD orderstop_limit_stop_limit_gtd) base_size limit_pricerrrorder_configurationstop_limit_stop_limit_gtc)rrrrlimit_limit_gtd)rrrrIOC sor_limit_ioc)rrlimit_limit_gtc)rrrz3 createOrder() only stop limit orders are supportedr6rHrra  createOrder() requires a price argument for market buy orders on spot markets to calculate the total amount to spend(amount * price), alternatively set the createMarketBuyOrderRequiresPrice option or param to False and pass the cost to spend in the amount argumentmarket_market_ioc quote_sizer marginModeisolatedISOLATED margin_typecrossCROSS) rrrrrr stopDirectionr clientOrderIdrrrrpreviewtestrsuccesserror_responseerrormessagerrsuccess_response)r'rrrr7upper safe_number_nr safe_bool_2rr'amount_to_precisionprice_to_precisionrr(rcost_to_precisionrnumber_to_stringr#r#v3PrivatePostBrokerageOrdersPreviewr*v3PrivatePostBrokerageOrdersrGrthrow_exactly_matched_exceptionrthrow_broadly_matched_exception parse_order)#rr\r8rrrrrr'r.rrrisStop isStopLoss isTakeProfitrrendTimerrrrrrr costRequestrrrr errorResponse errorTitle errorMessager s# r rzcoinbase.create_order s6 V$$   dlJ ? ?!Cx$))++5 ,JJLL   &&v/Z/Z/Z[[ ((AA **63DEE$&"$. &d2 &&v}== '4//44d6F6Fvz[fhm6n6n""6:66((1ABB 7??D  (CG5==$>$>WoM5((g.A+DG6u,uvvv3)-)A)A&&)Q)Q+/+B+B65+Q+Q*.*A*A&)*T*T.;(/ 666G1224)-)A)A&&)Q)Q+/+B+B65+Q+Q*.*A*A&)*T*T.; 666G122, |, # T$,EIU]](@(@Ys #'#:#:6=#Q#QLL$,GKu}}(B(B[s #'#:#:6?#S#SL/%)%=%=ff%M%M'+'>'>vu'M'M&2*7 222-.. 5((g.A+DG6u,uvvv))-)A)A&&)Q)Q+/+B+B65+Q+Q(/)1 ,,6G122!E))')-)A)A&&)Q)Q+/+B+B65+Q+Q**6G122*)-)A)A&&)Q)Q+/+B+B65+Q+Q)1,,6G122 d d| d"47-b#bcccf~ 45==481<@>"46GHH>>"46GHH>>"4oFF~~&8:UVV ~~&8:UVV NN#57JKK D(]hd.B]X\H\t+JT1I  >F#!%!!$$V];;E%%fk::F~~fk::HH  >*6*BJ$$Z??E%%j+>>F~~j+>>H++J EELL%%i==F##E>::$$UL99   !(: /K E $""5*55  T--e5FGG  11    !$   f  D))$*:*:5,*O*OPP  433D4D4DUO4\4\]]    D**5&99  U    L  f d&&um<.>uh.O.OPP(( =='3   4 5 r cBddddddd}||||S)Nrmclosedry)OPENFILLED CANCELLEDEXPIREDFAILEDUNKNOWN_ORDER_STATUSr|r}s r rzcoinbase.parse_order_status s:#! $(   &&999r cN|dkrdSddddd}||||S)NUNKNOWN_ORDER_TYPErr$)MARKETLIMITSTOP STOP_LIMITr|rs r rzcoinbase.parse_order_type sE ' ' '4!    tT222r c@dddddd}||||S)NGTCrrFOK)GOOD_UNTIL_CANCELLEDGOOD_UNTIL_DATE_TIMEIMMEDIATE_OR_CANCEL FILL_OR_KILLUNKNOWN_TIME_IN_FORCEr|)rr timeInForcess r rzcoinbase.parse_time_in_force s7$)$)#(!%)    k;GGGr r'c|||g||}||diS)a cancels an open order :see: https://docs.cloud.coinbase.com/advanced-trade-api/reference/retailbrokerageapi_cancelorders :param str id: order id :param str symbol: not used by coinbase cancelOrder() :param dict [params]: extra parameters specific to the exchange API endpoint :returns dict: An `order structure ` r)r' cancel_ordersr)rr'r\rorderss r  cancel_orderzcoinbase.cancel_order% sE ##RD&&99~~fa,,,r c|d}|||}d|i}||||}||dg}t dt |D]9}|||d} | durt|j dz:| ||S)a cancel multiple orders :see: https://docs.cloud.coinbase.com/advanced-trade-api/reference/retailbrokerageapi_cancelorders :param str[] ids: order ids :param str symbol: not used by coinbase cancelOrders() :param dict [params]: extra parameters specific to the exchange API endpoint :returns dict: a list of `order structures ` N order_idsresultsrrTz? cancelOrders() has failed, check your arguments and parameters) r'r'v3PrivatePostBrokerageOrdersBatchCancelr*r+r=r,rGrr' parse_orders) ridsr\rrr.rr+r@rs r r*zcoinbase.cancel_orders2 s   [[((F  ?? GU[@\@\]])R88q#f++&& n nAnnVAY ::Gd"" +l!lmmm#  000r c|||}d|i} ||||| d<||||| d<||ddd} d} | rB||ddg}||| |} n)||| |} | | |S)aV edit a trade order :see: https://docs.cloud.coinbase.com/advanced-trade-api/reference/retailbrokerageapi_editorder :param str id: cancel order id :param str symbol: unified symbol of the market to create an order in :param str type: 'market' or 'limit' :param str side: 'buy' or 'sell' :param float amount: how much of currency you want to trade in units of base currency :param float [price]: the price at which the order is to be fullfilled, in units of the base currency, ignored in market orders :param dict [params]: extra parameters specific to the exchange API endpoint :param boolean [params.preview]: default to False, wether to use the test/preview endpoint or not :returns dict: an `order structure ` rNrrrrF) r'rrrrr'v3PrivatePostBrokerageOrdersEditPreviewr* v3PrivatePostBrokerageOrdersEditr) rr'r\r8rrrrrr.rrs r  edit_orderzcoinbase.edit_orderU s V$$    "66vvFFGFO  #66vuEEGG ""69feDD  [YYv 6':;;FCCDKKPWY_D`D`aaHH<` Nrr)r'r,v3PrivateGetBrokerageOrdersHistoricalOrderIdr*rr)rr'r\rrr.rrs r  fetch_orderzcoinbase.fetch_order~ s   [[((F  DDT[[QXZ`EaEabbPx"55v...r r#c |d}||dd\}}|r|d||||dddd Sd}|||}i}| |d|d<|||d <||||d <||d d g}|0||d d g}|||d <||||} | | dg} | | d} | | d} | | dkr | | d<| | d<| | |||S)a fetches information on multiple orders made by the user :see: https://docs.cloud.coinbase.com/advanced-trade-api/reference/retailbrokerageapi_gethistoricalorders :param str symbol: unified market symbol that the orders were made in :param int [since]: the earliest time in ms to fetch orders :param int [limit]: the maximum number of order structures to retrieve :param dict [params]: extra parameters specific to the exchange API endpoint :param int [params.until]: the latest time in ms to fetch trades for :param boolean [params.paginate]: default False, when True will automatically paginate by calling self endpoint multiple times. See in the docs all the [availble parameters](https://github.com/ccxt/ccxt/wiki/Manual#pagination-params) :returns Order[]: a list of `order structures ` Frvr r/Nr/r'rr$ start_dateuntiltillend_dater+rr&) r'r(r)rrsafe_integer_nr*v3PrivateGetBrokerageOrdersHistoricalBatchr*r+rrr1) rr\r]r$rr rr.r<rr+firstr/s r  fetch_orderszcoinbase.fetch_orders s 88PZ[[&  A33M65RWY_aiksuy{AA A  [[((F  $*4LGL !  $GG   $(LL$7$7GL !##FWf,=>>  YYv'899F"&,,u"5"5GJ BB4;;wX^C_C_``V(B77vq))!!(H55  Vr\\$E(OF1I  >>>r c|d}|||}d|i}| |d|d<|d}||d<||||d<||ddg}|0||ddg}|||d <||||} || d g} || d } | | d } | | d kr | | d <| | d <| | |||S)N order_statusr'rr#r$r;r<r=r>r+rr/r&) r'rrr?rr@r*r+rrr1) rr~r\r]r$rrr.r<rr+rAr/s r fetch_orders_by_statuszcoinbase.fetch_orders_by_status sl   [[((F F   $*4LGL ! =E   $(LL$7$7GL !##FWf,=>>  YYv'899F"&,,u"5"5GJ BB4;;wX^C_C_``V(B77vq))!!(H55  Vr\\$E(OF1I  >>>r c |d}||dd\}}|r|d||||dddd S|d||||S)a fetches information on all currently open orders :see: https://docs.cloud.coinbase.com/advanced-trade-api/reference/retailbrokerageapi_gethistoricalorders :param str symbol: unified market symbol of the orders :param int [since]: timestamp in ms of the earliest order, default is None :param int [limit]: the maximum number of open order structures to retrieve :param dict [params]: extra parameters specific to the exchange API endpoint :param boolean [params.paginate]: default False, when True will automatically paginate by calling self endpoint multiple times. See in the docs all the [availble parameters](https://github.com/ccxt/ccxt/wiki/Manual#pagination-params) :param int [params.until]: the latest time in ms to fetch trades for :returns Order[]: a list of `order structures ` Frsr r/Nr#rr'r(r)rErr\r]r$rr s r fetch_open_orderszcoinbase.fetch_open_ordersQ s 88ART^__&  D334EvuV[]cemowy}@CDD D**665%PPPr c |d}||dd\}}|r|d||||dddd S|d||||S)a fetches information on multiple closed orders made by the user :see: https://docs.cloud.coinbase.com/advanced-trade-api/reference/retailbrokerageapi_gethistoricalorders :param str symbol: unified market symbol of the orders :param int [since]: timestamp in ms of the earliest order, default is None :param int [limit]: the maximum number of closed order structures to retrieve :param dict [params]: extra parameters specific to the exchange API endpoint :param boolean [params.paginate]: default False, when True will automatically paginate by calling self endpoint multiple times. See in the docs all the [availble parameters](https://github.com/ccxt/ccxt/wiki/Manual#pagination-params) :param int [params.until]: the latest time in ms to fetch trades for :returns Order[]: a list of `order structures ` FrVr r/Nr#rrGrHs r fetch_closed_orderszcoinbase.fetch_closed_ordersd s 88ATV`aa&  F334GQVX]_egoqy{BEFF F**8VUE6RRRr c4|d||||S)ae fetches information on multiple canceled orders made by the user :see: https://docs.cloud.coinbase.com/advanced-trade-api/reference/retailbrokerageapi_gethistoricalorders :param str symbol: unified market symbol of the orders :param int [since]: timestamp in ms of the earliest order, default is None :param int [limit]: the maximum number of canceled order structures to retrieve :param dict [params]: extra parameters specific to the exchange API endpoint :returns dict: a list of `order structures ` r)rE)rr\r]r$rs r fetch_canceled_orderszcoinbase.fetch_canceled_ordersw s **;ufUUUr rc |d}||nt||}d}||ddd\}}|r|d||||||dz S||}|d||j||d} ||gd } ||d d g}| |} || z} d} |,| | |d z } nCt| }tj|t| } | | d <| | }| "tj| t| }|| d<||| |}||dg}||||||S)a fetches historical candlestick data containing the open, high, low, and close price, and the volume of a market :see: https://docs.cloud.coinbase.com/advanced-trade-api/reference/retailbrokerageapi_getcandles :param str symbol: unified symbol of the market to fetch OHLCV data for :param str timeframe: the length of time each candle represents :param int [since]: timestamp in ms of the earliest candle to fetch :param int [limit]: the maximum amount of candles to fetch, not used by coinbase :param dict [params]: extra parameters specific to the exchange API endpoint :param int [params.until]: the latest time in ms to fetch trades for :param boolean [params.paginate]: default False, when True will automatically paginate by calling self endpoint multiple times. See in the docs all the [availble parameters](https://github.com/ccxt/ccxt/wiki/Manual#pagination-params) :returns int[][]: A list of candles ordered, open, high, low, close, volume i,NFrqr rr')r granularity)r<r=endr<r=r/startrPcandles)r'rr("fetch_paginated_call_deterministicrrrr?rparse_timeframer parse_to_intstrsecondsr# string_subr-v3PrivateGetBrokerageProductsProductIdCandlesr*r+ parse_ohlcvs)rr\ timeframer]r$rmaxLimitr rr.r<durationrequestedDuration sinceStringr6 endStringrrRs r  fetch_ohlcvzcoinbase.fetch_ohlcv s "]UH1E1E88z[`aa&  @::<QVX]_hjprz}~r~ V$$ ,++DOY RR  ##F,D,D,DEE6GV#455'' 22!H,  //0A0A%$,0O0OPPKKdllnn%%C!,S#6G2H2HIIK&))%00 =*;` rr'Nr/rQr$rr<rPzI fetchTrades() requires a `until` parameter when you use `since` argumentr`) r'rrrUrr(rr'rcr*r+ra) rr\r]r$rrr.r<rr`s r  fetch_tradeszcoinbase.fetch_trades sD V$$ &,   #44T5F5Fut|5T5TUUGG   "5$//GG 55fmWUU v  !2243D3DUT\3R3RSSGENN  #DG.y$yzz zDDT[[QXZ`EaEabb"(B77  >>>r c |d}||dd\}}|r|d||||dddd Sd}|||}i}| |d|d<|||d <||||d <||d d g}|0||d d g}|||d <||||} | | dg} | | d} | | d} | | dkr | | d<| | d<| | |||S)aq fetch all trades made by the user :see: https://docs.cloud.coinbase.com/advanced-trade-api/reference/retailbrokerageapi_getfills :param str symbol: unified market symbol of the trades :param int [since]: timestamp in ms of the earliest order, default is None :param int [limit]: the maximum number of trade structures to fetch :param dict [params]: extra parameters specific to the exchange API endpoint :param int [params.until]: the latest time in ms to fetch trades for :param boolean [params.paginate]: default False, when True will automatically paginate by calling self endpoint multiple times. See in the docs all the [availble parameters](https://github.com/ccxt/ccxt/wiki/Manual#pagination-params) :returns Trade[]: a list of `trade structures ` Frpr r/Nr#r'rr$start_sequence_timestampr<r=end_sequence_timestampfillsrr&) r'r(r)rrr?r*v3PrivateGetBrokerageOrdersHistoricalFillsr*r+rrra) rr\r]r$rr rr.r<rr`rAr/s r fetch_my_tradeszcoinbase.fetch_my_trades s 88R\]]&  B33OVUTY[ackmuw{~ABB B  [[((F  $*4LGL !  $GG   26,,u2E2EG. /##FWf,=>>  YYv'899F04 U0C0CG, -BB4;;wX^C_C_``0'266vq))!!(H55  Vr\\$E(OF1I  >>>r c |||}d|di}|||d<||||}||di}||d}||} |||| ddd d S) a` fetches information on open orders with bid(buy) and ask(sell) prices, volumes and other data :see: https://docs.cloud.coinbase.com/advanced-trade-api/reference/retailbrokerageapi_getproductbook :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 rr'Nr$ pricebookrrfrgrr)r'r v3PrivateGetBrokerageProductBookr*rrrparse_order_book) rr\r$rrr.rr rrs r fetch_order_bookzcoinbase.fetch_order_book@ s V$$ &,   $GG 88Wf9U9UVV*~~h R88f--NN4(( $$T69ffgW]^^^r c8|||}i}||||d<||||}||dg}|||S)a fetches the bid and ask price and volume for multiple markets :see: https://docs.cloud.coinbase.com/advanced-trade-api/reference/retailbrokerageapi_getbestbidask :param str[] [symbols]: unified symbols of the markets to fetch the bids and asks for, all markets are returned if not assigned :param dict [params]: extra parameters specific to the exchange API endpoint :returns dict: a dictionary of `ticker structures ` NrN pricebooks)r'rIrOv3PrivateGetBrokerageBestBidAskr*r+ parse_tickers)rrCrr.rtickerss r fetch_bids_askszcoinbase.fetch_bids_asksj s %%g..  %)__W%=%=GM "77 GV8T8TUU...<<<!!'7333r c~|||\}}|||||}||dd}||ddg}|K|t |jdz|||}|t|jdz|z|d|||dd}|||d <| | ||} | | d i} | | |S) a make a withdrawal :see: https://docs.cloud.coinbase.com/sign-in-with-coinbase/docs/api-transactions#send-money :param str code: unified currency code :param float amount: the amount to withdraw :param str address: the address to withdraw to :param str [tag]: an optional tag for the withdrawal :param dict [params]: extra parameters specific to the exchange API endpoint :returns dict: a `transaction structure ` rTrZNzV withdraw() requires an account_id(or accountId) parameter OR a currency code argumentz* withdraw() could not find account id for rr')rTr8rrrErUr )handle_withdraw_tag_and_params check_addressr'rErIrrr'rr*v2PrivatePostAccountsAccountIdTransactionsr*rr) rr:rrVrWrrErZr.rr s r rzcoinbase.withdraw sk99#vFF V 7### ==&&&&v|[II 6L+#>??  |'3K)KLLL,,T6::I #DG.Z$Z]a$abbb#     ?),G% &BB4;;wX^C_C_``j~~h33%%dH555r cn|||}d}||d\}}||||}||dg}||dd}||dS)a fetch the deposit address for a currency associated with self account :see: https://docs.cloud.coinbase.com/exchange/reference/exchangerestapi_postcoinbaseaccountaddresses :param str code: unified currency code :param dict [params]: extra parameters specific to the exchange API endpoint :returns dict: an `address structure ` Nr:r Fr)r'rErj&v2PrivateGetAccountsAccountIdAddressesr*r+parse_deposit_addressesr)rr:rrEr.rr addressStructuress r "fetch_deposit_addresses_by_networkz+coinbase.fetch_deposit_addresses_by_network s ==&&II(SYJZ[[>>t{{7TZ?[?[\\p~~h33 88tUKK}}. :::r c||d}||||d}|d|}||d}|d}||d}||d} ||||||| d|||dS) NrVr address_labelrFr address_inforU)r;rErVrWr)rr|rKrHrnetwork_id_to_code) rdepositAddressrErV networkIdr: addressLabelsplitAddressLabelr addressInfos r parse_deposit_addresszcoinbase.parse_deposit_address1sX"">9== 7###$$^Y?? &&tX66''HH (..s33##$5q99nn^^DD "//(CC##K1BCC..y$??    r c$|||dd}||ddg}|K|t|jdz|||}|t |jdz|z|||||d}| | ||}| |di}| |S)ag make a deposit :see: https://docs.cloud.coinbase.com/sign-in-with-coinbase/docs/api-deposits#deposit-funds :param str code: unified currency code :param float amount: the amount to deposit :param str id: the payment method id to be used for the deposit, can be retrieved from v2PrivateGetPaymentMethods :param dict [params]: extra parameters specific to the exchange API endpoint :param str [params.accountId]: the id of the account to deposit into :returns dict: a `transaction structure ` rTrZNzU deposit() requires an account_id(or accountId) parameter OR a currency code argumentz) deposit() could not find account id for )rTrrEpayment_methodr ) r'rIrrr'rrrr&v2PrivatePostAccountsAccountIdDepositsr*rr) rr:rr'rrZr.rr s r rNzcoinbase.depositms* &&v|[II 6L+#>??  |'3J)JKKK,,T6::I #DG.Y$Y\`$`aaa#++F33     >>t{{7TZ?[?[\\J~~h33%%d+++r c|||dd}||ddg}|K|t|jdz|||}|t |jdz|z||d}||||}| |di}| |S)a4 fetch information on a deposit, fiat only, for crypto transactions use fetchLedger :see: https://docs.cloud.coinbase.com/sign-in-with-coinbase/docs/api-deposits#show-deposit :param str id: deposit id :param str [code]: unified currency code :param dict [params]: extra parameters specific to the exchange API endpoint :param str [params.accountId]: the id of the account that the funds were deposited into :returns dict: a `transaction structure ` rTrZNzZ fetchDeposit() requires an account_id(or accountId) parameter OR a currency code argumentz. fetchDeposit() could not find account id for )rT deposit_idr ) r'rIrrr'rr.v2PrivateGetAccountsAccountIdDepositsDepositIdr*rr)rr'r:rrZr.rr s r  fetch_depositzcoinbase.fetch_deposits &&v|[II 6L+#>??  |'3O)OPPP,,T6::I #DG.^$^ae$efff#  FFt{{SZ\bGcGcddJ~~h33%%d+++r c|||}|dst|jdz||dd}||d}d|di}|t |jdz||d<||||}| |d i}| |S) a *futures only* closes open positions for a market :see: https://coinbase-api.github.io/docs/#/en-us/swapV2/trade-api.html#One-Click%20Close%20All%20Positions :param str symbol: Unified CCXT market symbol :param str [side]: not used by coinbase :param dict [params]: extra parameters specific to the coinbase api endpoint * @param {str} params.clientOrderId *mandatory* the client order id of the position to close :param float [params.size]: the size of the position to close, optional :returns dict: an `order structure ` r9z3 closePosition() only supported for futures marketsrrrr'Nz3 closePosition() requires a clientOrderId parameterr) r'rrr'rIrr)v3PrivatePostBrokerageOrdersClosePositionr*rr) rr\rrrrr.rrs r close_positionzcoinbase.close_positions V$$h `tw)^^__ _**63DoVV 6?33 &,   #DG.c$cdd d%2!"AA$++gW]B^B^__x);R@@&&&r c$|||}d}|||d}d}|d||\}}d}|dkr||}nbd}||dd\}}|t |jdzd|i}|| ||}| |dg}| ||S) aU fetch all open positions :see: https://docs.cloud.coinbase.com/advanced-trade-api/reference/retailbrokerageapi_getfcmpositions :see: https://docs.cloud.coinbase.com/advanced-trade-api/reference/retailbrokerageapi_getintxpositions :param str[] [symbols]: list of unified market symbols :param dict [params]: extra parameters specific to the exchange API endpoint :param str [params.portfolio]: the portfolio UUID to fetch positions for :returns dict[]: a list of `position structure ` Nrryr9rAz fetchPositions() requires a "portfolio" value in params(eg: dbcb91e7-2bc9-515), or set.options["portfolio"]. You can get a list of portfolios with fetchPortfolios()portfolio_uuid positions) r'rIrr!v3PrivateGetBrokerageCfmPositionsr(rr'/v3PrivateGetBrokerageIntxPositionsPortfolioUuidr*r+parse_positions) rrCrrr8rrAr.rs r fetch_positionszcoinbase.fetch_positions s: %%g..  [[,,F99:JFTZ[[ f 8  ==fEEHHI $ = =fFVXc d d Iv '3Z)Z[[[ )GKKDKKX_agLhLhiiHNN8["== ##Iw777r cN|||}d}|dr]||d}|t|jdzd|i}||||}nid}||dd\}}|t|jdz|d|d }||||}| |d i} | | |S) aT fetch data on a single open contract trade position :see: https://docs.cloud.coinbase.com/advanced-trade-api/reference/retailbrokerageapi_getintxposition :see: https://docs.cloud.coinbase.com/advanced-trade-api/reference/retailbrokerageapi_getfcmposition :param str symbol: unified market symbol of the market the position is held in, default is None :param dict [params]: extra parameters specific to the exchange API endpoint :param str [params.product_id]: *futures only* the product id of the position to fetch, required for futures markets only :param str [params.portfolio]: *perpetual/swaps only* the portfolio UUID to fetch the position for, required for perpetual/swaps markets only :returns dict: a `position structure ` Nr9rz2 fetchPosition() requires a "product_id" in paramsryrAz fetchPosition() requires a "portfolio" value in params(eg: dbcb91e7-2bc9-515), or set.options["portfolio"]. You can get a list of portfolios with fetchPortfolios()r')r\rposition) r'rrrr'*v3PrivateGetBrokerageCfmPositionsProductIdr*r(5v3PrivateGetBrokerageIntxPositionsPortfolioUuidSymbolrparse_position) rr\rrr productId futureRequestrAr.rs r fetch_positionzcoinbase.fetch_position)sU V$$ (  p((>>I '2f(fgggiMFFt{{S`bhGiGijjHHI $ = =fFVXc d d Iv '3Y)YZZZ ,"+GQQRVR]R]^egmRnRnooH>>(J;;""8V444r c||dd}|||}||d}d}| |dkrdnd}||di}||d}|d krd nd }||d i} ||d i} || d} ||di} ||di} |id|d||dd|||d||dd|d| d|| dd|| dddddd||dd|dddddd |d!dd"ddddd|| d#dd||d$dddd% S)&Nr\r&rMARGIN_TYPE_CROSSrrposition_notional position_sidePOSITION_SIDE_LONGlongshortunrealized_pnlliquidation_pricer|rlportfolio_summaryr;r'rnotionalrliquidationPrice entryPrice unrealizedPnl realizedPnlr contractsnet_sizer markPrice lastPricerhedgedr collateralr) rlastUpdateTimestampmaintenanceMarginmaintenanceMarginPercentager initialMargininitialMarginPercentager marginRatiorr)rrrr safe_positionrv)rrrr rawMarginrnotionalObject positionSiderunrealizedPNLObjectliquidationPriceObjectr vwapObject summaryObjects r rzcoinbase.parse_positionLst##Hh;;!!(F33$$X}==   %.2E%E%EJJ2ErJJ''/BB &*>>>vvW"nnX7GLL!%:Mr!R!R++,BGLL^^Hfb99 x1DbII !!# H# $""8\::#  d&&x88#  ((AA # * #  0 #  $**:w??#  T--.A7KK#  4#  $#  ))(J??#  F>2#  #  #  D# d!# " ## $#'!%+/**=,GG!'+((:>>!#9# # #    r rWr urlc `d}|A|dz|ddz}|d}|dkr |d|}|d}dgd||d z|j|d }|||d <||||jd d |j|dd}|S)NrFzhttps://r&?rretail_rest_api_proxyzcoinbase-cloudx)audissnbfexpsubiaturisha256FES256)kidnoncealg)replacefind random_bytesrjwtencoder) rrWr rrquesPosrr.tokens r create_auth_tokenzcoinbase.create_auth_tokens ?3,Z!C'$*=*=dF*K*KK &$"5"5d";";<< U?? JC$"B"B5"I"IIIiv&1 A 0 ,,T\?KKM"& (&3##4 D$C$CE$J$J4 &/$*&<##//111,,..U??'#yy//"&C C#sT^^E-B-B'BBG "&!1!12B!C!Cq!H sdkNdNdeqNrNr  !{--l;;T/;S1STTT&!227FCHHE*3e*;''&)$,,..&9&9O*V3i?'ID $ $++d*;*;T[[=U=UW^We f fI)-*3/>(: G #.%8$6U??0#yy//fdwOOOr c H|dS|jdz|z} ||d} | i||d} ||jd| | ||jd| | t | ||d} | t| trt| }|dkr|| dd} || dd } | S||jd| | ||jd| | t | |j d }d |vr/|s-t |jd z| |zdS) NrFrerror_descriptionrrerrorsrr'rrr z$ failed due to a malformed response ) r'rrrrrr+ isinstancerr,rr)rr:reasonrr r3rrrequestHeaders requestBodyfeedback errorCoderr numErrors advancedTrades r  handle_errorszcoinbase.handle_errors;s  47S=4'$$Xw77  ++H6IJJL  0 01I9V^ _ _ _  0 01Ib(_(_s(_3(_Y(_(_(_(_T26b%4%4w%4%4%4%4N?C2V6V6SV6%V6V6V6V6pDFF;F;sF;F;F;F;P: : h: : : : xAC@,@,C@,@,C@,@,@,@,D26b=,=,=,3=,=,=,=,~=A''S' 'PU''''626b88w8888@24!5!5S!5!5!5!5FE E vE E E E Ncs0 b$TNPNPNPNP`&&&&&&&r r%)*ccxt.base.exchangerccxt.abstract.coinbaserrccxt.base.typesrrrrr r r r r rrrrrrrrrtypingrccxt.base.errorsrrrrrrrrr r!ccxt.base.decimal_to_precisionr"ccxt.base.preciser#r%r r rsX ('''''......BBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBB******000000------......''''''))))))******))))))......))))))444444%%%%%%HAHAHAHAHAxHAHAHAHAHAr