i8ddlmZddlmZddlZddlZddlmZmZm Z m Z m Z m Z m Z mZmZmZmZmZmZmZmZmZmZmZddlmZddlmZddlmZddlmZdd lmZdd lm Z dd 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 crK||jdd}||d|}||d}d}|dkr3||d{V}||di}n||d{V}||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_timexs(({DUVV !!&(MBB68,, & & &!11&99999999H~~h;;HH!::6BBBBBBBBH$$XwGGGr returncK||jdd}|dkr||d{VS||d{VS)a fetch all the accounts associated with a profile :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 :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 dictionary of `account structures ` indexed by the account type rPrN)rrfetch_accounts_v3fetch_accounts_v2rrr s r fetch_accountszcoinbase.fetch_accountssz!!$,ARSS & & &//77777777 7++F333333333r c |K|d{Vd}||dd\}}|r#|dddd|dddd d{VSddi}||||d{V}||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_v2s!!!!!!!!!88R\]]&  Y99/4QUW[]cez}MOSUXYYYYYYYY Y S 224;;w3O3OPPPPPPPPZ~~h33^^HlB?? !!*.CDD>>(FB77XQJ ~~h 22  Vr\\*0D& '"&HY ""4000r c K|d{Vd}||dd\}}|r#|dddd|dddd d{VSddi}||||d{V}||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\]]&  D99/4QUW[]cemowy}@CDDDDDDDD D S ;;DKKQW>>(J;;XQJ ~~h 22!!(H55  Vr\\#DN"&HY ""8V444r cFK||d{V}||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 N portfoliosruuidtyper'r8codeinfo)v3PrivateGetBrokeragePortfoliosr+ranger,appendr)rrrr6resulti portfolios r fetch_portfolioszcoinbase.fetch_portfolioss==fEEEEEEEE^^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_account0sp22''<< >>':r::%%h EE !!'622!!'622 S!!$$WdF;;9?9KD**5!444RX++J77    r r:cjK||d}||d}|n|d{Vtdt |jD]1}|j|}|d|kr|ddkr |d}n2|t |jdzd|i}|| ||d{V}| |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_addressvs$$V\:: 6<00  $$&& & & & & & & &1c$-0011  -*6?d**wv(/J/J ' IE  +`!`aa a ) EEdkkRY[aFbFbccccccccJ~~h33t%677""433    r Nsymbolsincer$c0K|||}|d{V||ddg}||||d{V}||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 ` NrTrZr )prepare_account_requestr'r"v2PrivateGetAccountsAccountIdSellsr* parse_trades)rr\r]r$rr.querysellss r fetch_my_sellszcoinbase.fetch_my_sellss..uf==!!!!!!!!! &<"=>>==dkk'SX>Y>YZZZZZZZZ  veUCCCr c0K|||}|d{V||ddg}||||d{V}||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 ` NrTrZr )r_r'r!v2PrivateGetAccountsAccountIdBuysr*ra)rr\r]r$rr.rbbuyss r  fetch_my_buyszcoinbase.fetch_my_buyss..uf==!!!!!!!!! &<"=>>;;DKKQV` (v2PrivateGetAccountsAccountIdWithdrawalsNrmrr:r]r$rs r fetch_withdrawalszcoinbase.fetch_withdrawalssV889ceikprwyAAAAAAAA Ar cDK|d||||d{VS)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 ` %v2PrivateGetAccountsAccountIdDepositsNrprqs r fetch_depositszcoinbase.fetch_depositss;889`bfhmotv|}}}}}}}}}r 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_v22s99&AAAAAAAA^^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_v3ws  . .v 6 6  8 8 @ @" &(" ,224;;vX`Ga3b3bcc224;;vX`{FHGHG4H4HII<R>RSS * & &  , , ,)+ & & & & & & , )?@@@@@@@ "%,^5O%PPPPPPP   " " "!       "~~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 C3'C..C3 D"" D8,D33D8c||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) rrr r'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)rrr r'futureProductDetailscontractExpiryTypercontractExpireexpireTimestampisSwaprrrrr r\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 cK||jdi}||d}||dd}|}| ||z |kr||||g}t j|d{V}||di}||di} ||dg} || dg} | |d{V} | || | | | |d|jd<||jdiS) NrYrrrrr )rrr) rr safe_integer millisecondsv2PublicGetCurrenciesv2PublicGetCurrenciesCryptorrr+v2PublicGetExchangeRatesr* array_concat) rrrrrnowrpromisesResult fiatResponsecryptoResponsefiatData cryptoDatars r rz$coinbase.fetch_currencies_from_caches../@"EE%%g{;; ##GY==!!  C)Ow#>#>**6220088H$+>8#<<<<<<>.!R@@L"^^NArBBN~~lFB??HCCJ"&"?"?"G"GGGGGGGM.2kk'"//*EE!. DD//DL* + ~~dl,=rBBBr cvK||d{V}||dg}i}i}i}tdt|D] }||}||d} ||dd} || } ||d} | |jd| <| |jd | <|| | | d nd ||dd dddd| |d ddddddd || <| | } | || <| || <| ||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 Nrrasset_idr'r:r(r networksByIdrrTrr)rr) r;r'r:r8r(rDrNrrrr) rr+r=r,rrIrKlowerrrr*)rrrrr?rr@r@rEassetIdr'r:r( lowerCaseNames r fetch_currencieszcoinbase.fetch_currenciess99&AAAAAAAA^^HlB?? L q#j//**! 3! 3A!!}H&&x<` r}rN)rrfetch_tickers_v3fetch_tickers_v2)rrErr s r  fetch_tickerszcoinbase.fetch_tickersWs~!!$,@PQQ % % %..w???????? ?**7F;;;;;;;;;r cK|d{V||}i}||||d{V}||di}||di}||d}i}t |} d} tdt| D]P} | | } | | z|z} | | d| }|d}| || |||<Q| |d|S)Nr rrErrr\) r'market_symbolsr6r*rrrrr=r,r parse_tickerfilter_by_array_tickers)rrErr.rr rrr?r delimiterr@rrrr\s r rHzcoinbase.fetch_tickers_v2esj!!!!!!!!!%%g.. 66t{{7F7S7STTTTTTTT~~h33tWb11""444uzz||$$ q#g,,'' F FAQZF )G3H%%hi@@FH%F!..uV}fEEF6NN++FHgFFFr cFK|d{V||}i}||||d<||||d{V}||dg}i}t dt|D]X}||}||d} | | dd} | d} | || || <Y| |d|S)N product_idsrrrrr\) r'rK market_idsrr*r+r=r,rrrLrM) rrErr.rr r?r@entryrrr\s r rGzcoinbase.fetch_tickers_v3s@!!!!!!!!!%%g..  %)__W%=%=GM ";;DKKQW >AGE''|<` r|rN)rrfetch_ticker_v3fetch_ticker_v2)rr\rr s r  fetch_tickerzcoinbase.fetch_tickers|!!$, OO _ $ $--ff======== =))&&999999999r c|K|d{V||}|d|di|}||d{V}||d{V}||d{V}||di}||di} ||di} || d|| d||dd} || |S)Nr\r'r r)bidaskr) r'rr*v2PublicGetPricesSymbolSpotv2PublicGetPricesSymbolBuyv2PublicGetPricesSymbolSellrrrL) rr\rrr.r6rYrXspotDataaskDatabidData bidAskLasts r rUzcoinbase.fetch_ticker_v2sr!!!!!!!!!V$$++ fTl 55g>>>>>>>>33G<<<<<<<<44W========>>$33..fb11..fb11##GX66##GX66%%h99    V444r cK|d{V||}|ddd}||||d{V}||dg}||d|}||d|d<||d|d <|S) Nr'r)rr$tradesrbest_bidrXbest_askrY)r'r,v3PrivateGetBrokerageProductsProductIdTickerr*r+rLr)rr\rrr.rr tickers r rTzcoinbase.fetch_ticker_v3s!!!!!!!!!V$$ ,  JJ4;;W^`fKgKghhhhhhhh&~~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)NrXrYbidsasksrrrrrr\rrr2highlow bidVolume askVolumevwapopenclose previousClosechangerprice_percentage_change_24haverage) baseVolume quoteVolumer;)rr+r safe_ticker safe_symbolr) rrfrrXrYrlrmrhrirr2rs r rLzcoinbase.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 cK|d{Vi}d}||dd}||dg}d}|dd|\}}||jdd}|dkr0||||d{V}nq|s|dkr5d|d<||||d{V}n4d |d<| |||d{V}||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_balances!!!!!!!!!~~fdE226D6** !??PTV\]] F!!$,@_``  ! !!HHU\^dIeIeffffffffHH U"AAA"GG !?? GU[@\@\]]]]]]]]HH"GG !66t{{7F7S7STTTTTTTTHP$v((6:::r c K|d{Vd}||dd\}}|r#|d||||dddd d{VSd}|||}d}||||d{V\}}||||d{V}||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 ` NFrhr r!r"r#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[[&  Y99-uV[]cez}MOSUXYYYYYYYY Y  }}T**H $ O OPTV[]c d dddddddGG T[]cHdHdeeeeeeee""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_status7s(  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_entryKs6h^^D(B77 !!*h77  VS ) ) I'//FFI%%j*== &&z8<<nnT9b99 ...?@@   ,,WjAAM"55mXNNO(((;;I!+CNN4#3#3D,#G#GHH   dD ) )++D,<,??  |'3o)oppp"224@@@@@@@@I #DG.w$wz~$~ )   $GG   r rcK|d{V||}|dst|jdzd|d<||dd|d|d{VS)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 ` Nr6z9 createMarketBuyOrderWithCost() supports spot orders onlyFrrr)r'rrr' create_order)rr\rrrs r !create_market_buy_order_with_costz*coinbase.create_market_buy_order_with_cost s!!!!!!!!!V$$f~ ftw)ddee e6;23&&vxdFSSSSSSSSSr r8rrrc K|d{V||}||jdd}|dz|z|d|d} ||gd} ||d} ||d } | du} | du}| du}||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}|r^||d4d5g}|| d6} ||| |d{V}n/||| |d{V}||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 ` Nrrrr')client_order_idrr) stopPrice stop_price triggerPrice stopLossPricetakeProfitPrice 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<@>t{{7TZ?[?[\\\\\\\\HL..955 $   NN85EFFM))-AAJ++M9EEL(44T_W5Mz[ghhh44T_W5Mz[ghhh#L111~~h(:B??f---r c ||d}|||d}|||}||di}||d}||d}||d}||d} ||d} ||d } |dup|dup|du} | dup| du} d}d}d}d}| rQd}||}n||}n|}||d }||d }||d }nw| r_| | n| }||d }||d }||d }||d }n|| d }||d}||d}d}| ||d}|id|d||dd||dd||d|ddd|d|||dd|||dd|d| |dd |d!|d"|d#|d$||d%d&dd||d'| ||d(||d|d)dd*|S)+Nrrrrrrrrrrrrr created_time total_feesrr;r'rrrrrlastTradeTimestampr\r8 order_typer time_in_forcerrrrrrfilled filled_size remainingaverage_filled_pricer~r)rrtr~rrb) rrxrrrG safe_orderrparse_order_typeparse_time_in_forcerJparse_order_status)rrrrr\orderConfigurationlimitGTClimitGTDlimitIOC stopLimitGTC stopLimitGTD marketIOCisLimitrrrrrtarget stopTargetr totalFees currencyFees r rzcoinbase.parse_order s/~##E<88!!(FC88  [[((F!^^E3H"MM>>"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)Nroclosedry)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'cK|d{V||g||d{V}||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 ` Nr)r' cancel_ordersr)rr'r\rorderss r  cancel_orderzcoinbase.cancel_order& sm!!!!!!!!!))2$????????~~fa,,,r cK|d{Vd}|||}d|i}||||d{V}||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_orders3 s!!!!!!!!!  [[((F  EEdkkRY[aFbFbcccccccc)R88q#f++&& n nAnnVAY ::Gd"" +l!lmmm#  000r c*K|d{V||}d|i} ||||| d<||||| d<||ddd} d} | rH||ddg}||| |d{V} n/||| |d{V} | | |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 ` NrrrrrF) r'rrrrr'v3PrivatePostBrokerageOrdersEditPreviewr* v3PrivatePostBrokerageOrdersEditr) rr'r\r8rrrrrr.rrs r  edit_orderzcoinbase.edit_orderV sL!!!!!!!!!V$$    "66vvFFGFO  #66vuEEGG ""69feDD  aYYv 6':;;F!II$++V]_eJfJfggggggggHH!BB4;;wX^C_C_````````H&111r c,K|d{Vd}|||}d|i}||||d{V}||di}|||S)a fetches information on an order made by the user :see: https://docs.cloud.coinbase.com/advanced-trade-api/reference/retailbrokerageapi_gethistoricalorder :param str id: the order id :param str symbol: unified market symbol that the order was made in :param dict [params]: extra parameters specific to the exchange API endpoint :returns dict: An `order structure ` Nrr)r'r,v3PrivateGetBrokerageOrdersHistoricalOrderIdr*rr)rr'r\rrr.rrs r  fetch_orderzcoinbase.fetch_order s!!!!!!!!!  [[((F  JJ4;;W^`fKgKghhhhhhhhPx"55v...r r#c K|d{Vd}||dd\}}|r#|d||||dddd d{VSd}|||}i}| |d|d<|||d <||||d <||d d g}|0||d d g}|||d <||||d{V} | | 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 ` NFrvr r/r1r'rr$ start_dateuntiltillend_dater-rr&) r'r(r)rrsafe_integer_nr*v3PrivateGetBrokerageOrdersHistoricalBatchr*r+rrr3) rr\r]r$rr rr.r>rr-firstr/s r  fetch_orderszcoinbase.fetch_orders s!!!!!!!!!88PZ[[&  G99-QVX]_egoqy{BFGGGGGGGG G  [[((F  $*4LGL !  $GG   $(LL$7$7GL !##FWf,=>>  YYv'899F"&,,u"5"5GJ HHU\^dIeIeffffffffV(B77vq))!!(H55  Vr\\$E(OF1I  >>>r cK|d{Vd}|||}d|i}| |d|d<|d}||d<||||d<||ddg}|0||ddg}|||d <||||d{V} || d g} || d } | | d } | | d kr | | d <| | d <| | |||S)N order_statusr'rr#r$r=r>r?r@r-rr/r&) r'rrrArrBr*r+rrr3) rr~r\r]r$rrr.r>rr-rCr/s r fetch_orders_by_statuszcoinbase.fetch_orders_by_status s!!!!!!!!!  [[((F F   $*4LGL ! =E   $(LL$7$7GL !##FWf,=>>  YYv'899F"&,,u"5"5GJ HHU\^dIeIeffffffffV(B77vq))!!(H55  Vr\\$E(OF1I  >>>r c K|d{Vd}||dd\}}|r#|d||||dddd d{VS|d||||d{VS)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 ` NFrsr r/r#rr'r(r)rGrr\r]r$rr s r fetch_open_orderszcoinbase.fetch_open_ordersR s!!!!!!!!!88ART^__&  J99:KVUZ\aciksu}@DFIJJJJJJJJ J00vVVVVVVVVVr c K|d{Vd}||dd\}}|r#|d||||dddd d{VS|d||||d{VS)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 ` NFrVr r/r#rrIrJs r fetch_closed_orderszcoinbase.fetch_closed_orderse s!!!!!!!!!88ATV`aa&  L99:MvW\^cekmuwBFHKLLLLLLLL L0065%QWXXXXXXXXXr cDK|d||||d{VS)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 ` rN)rG)rr\r]r$rs r fetch_canceled_orderszcoinbase.fetch_canceled_ordersx s700feUTZ[[[[[[[[[r rc K|d{Vd}||nt||}d}||ddd\}}|r$|d||||||dz d{VS||}|d||j||d} ||gd } ||d d g}| |} || z} d} |,| | |d z } nCt| }tj|t| } | | d <| | }| "tj| t| }|| d<||| |d{V}||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 Ni,Frqr rr')r granularity)r>r?endr>r?r1startrRcandles)r'rr("fetch_paginated_call_deterministicrrrrArparse_timeframer parse_to_intstrsecondsr# string_subr-v3PrivateGetBrokerageProductsProductIdCandlesr*r+ parse_ohlcvs)rr\ timeframer]r$rmaxLimitr rr.r>durationrequestedDuration sinceStringr8 endStringrrTs r  fetch_ohlcvzcoinbase.fetch_ohlcv sx!!!!!!!!!"]UH1E1E88z[`aa&  F@@vW\^cenpvyADEyEFFFFFFFF FV$$ ,++DOY RR  ##F,D,D,DEE6GV#455'' 22!H,  //0A0A%$,0O0OPPKKdllnn%%C!,S#6G2H2HIIK&))%00 =*;` Nrr'r1rSr$rr>rRzI fetchTrades() requires a `until` parameter when you use `since` argumentrb) r'rrrWrr(rr'rer*r+ra) rr\r]r$rrr.r>rrbs r  fetch_tradeszcoinbase.fetch_trades sl!!!!!!!!!V$$ &,   #44T5F5Fut|5T5TUUGG   "5$//GG 55fmWUU v  !2243D3DUT\3R3RSSGENN  #DG.y$yzz zJJ4;;W^`fKgKghhhhhhhh"(B77  >>>r c K|d{Vd}||dd\}}|r#|d||||dddd d{VSd}|||}i}| |d|d<|||d <||||d <||d d g}|0||d d g}|||d <||||d{V} | | 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 ` NFrpr r/r#r'rr$start_sequence_timestampr>r?end_sequence_timestampfillsrr&) r'r(r)rrrAr*v3PrivateGetBrokerageOrdersHistoricalFillsr*r+rrra) rr\r]r$rr rr.r>rrbrCr/s r fetch_my_tradeszcoinbase.fetch_my_trades s!!!!!!!!!88R\]]&  H99/6SXZ_agiqs{~BDGHHHHHHHH H  [[((F  $*4LGL !  $GG   26,,u2E2EG. /##FWf,=>>  YYv'899F04 U0C0CG, -HHU\^dIeIeffffffff0'266vq))!!(H55  Vr\\$E(OF1I  >>>r c K|d{V||}d|di}|||d<||||d{V}||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 Nrr'r$ pricebookrrhrirr)r'r v3PrivateGetBrokerageProductBookr*rrrparse_order_book) rr\r$rrr.rr rrs r fetch_order_bookzcoinbase.fetch_order_bookA s!!!!!!!!!V$$ &,   $GG >>t{{7TZ?[?[\\\\\\\\*~~h R88f--NN4(( $$T69ffgW]^^^r cTK|d{V||}i}||||d<||||d{V}||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 ` NrP pricebooks)r'rKrQv3PrivateGetBrokerageBestBidAskr*r+ parse_tickers)rrErr.rtickerss r fetch_bids_askszcoinbase.fetch_bids_asksk s!!!!!!!!!%%g..  %)__W%=%=GM "==dkk'SY>Z>Z[[[[[[[[...<<<!!'7333r cK|||\}}|||d{V||}||dd}||ddg}|Q|t |jdz|||d{V}|t|jdz|z|d|||dd}|||d <| | ||d{V} | | 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 ` NrTrZzV 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 s99#vFF V 7###!!!!!!!!!==&&&&v|[II 6L+#>??  |'3K)KLLL"224@@@@@@@@I #DG.Z$Z]a$abbb#     ?),G% &HHU\^dIeIeffffffffj~~h33%%dH555r cK|d{V||}d}||dd{V\}}||||d{V}||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!!!!!!!!!==&& $ O OPXY_P` a aaaaaaaDDT[[QXZ`EaEabbbbbbbbp~~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_address2sX"">9== 7###$$^Y?? &&tX66''HH (..s33##$5q99nn^^DD "//(CC##K1BCC..y$??    r cLK|d{V||dd}||ddg}|Q|t|jdz|||d{V}|t |jdz|z|||||d}| | ||d{V}| |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 ` NrTrZzU 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.depositnse!!!!!!!!!&&v|[II 6L+#>??  |'3J)JKKK"224@@@@@@@@I #DG.Y$Y\`$`aaa#++F33     DDT[[QXZ`EaEabbbbbbbbJ~~h33%%d+++r cK|d{V||dd}||ddg}|Q|t|jdz|||d{V}|t |jdz|z||d}||||d{V}| |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 ` NrTrZzZ 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_depositsI!!!!!!!!!&&v|[II 6L+#>??  |'3O)OPPP"224@@@@@@@@I #DG.^$^ae$efff#  LLT[[Y`bhMiMijjjjjjjjJ~~h33%%d+++r cK|d{V||}|dst|jdz||dd}||d}d|di}|t |jdz||d<||||d{V}| |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 ` Nr9z3 closePosition() only supported for futures marketsrrrr'z3 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!"GG T[]cHdHdeeeeeeeex);R@@&&&r cLK|d{V||}d}|||d}d}|d||\}}d}|dkr||d{V}nhd}||dd\}}|t |jdzd|i}|| ||d{V}| |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'rKrr!v3PrivateGetBrokerageCfmPositionsr(rr'/v3PrivateGetBrokerageIntxPositionsPortfolioUuidr*r+parse_positions) rrErrr8rrAr.rs r fetch_positionszcoinbase.fetch_positions sw!!!!!!!!!%%g..  [[,,F99:JFTZ[[ f 8  !CCFKKKKKKKKHHI $ = =fFVXc d d Iv '3Z)Z[[[ )G"QQRVR]R]^egmRnRnooooooooHNN8["== ##Iw777r cvK|d{V||}d}|drc||d}|t|jdzd|i}||||d{V}nod}||dd\}}|t|jdz|d|d }||||d{V}| |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*s!!!!!!!!!V$$ (  v((>>I '2f(fgggiM"LLT[[YfhnMoMoppppppppHHI $ = =fFVXc d d Iv '3Y)YZZZ ,"+G"WWX\XcXcdkmsXtXtuuuuuuuuH>>(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~rnportfolio_summaryr;r'rnotionalrliquidationPrice entryPrice unrealizedPnl realizedPnlr contractsnet_sizer markPrice lastPricerhedgedr collateralr) rlastUpdateTimestampmaintenanceMarginmaintenanceMarginPercentager initialMargininitialMarginPercentager marginRatiorr)rrrr safe_positionrx)rrrr rawMarginrnotionalObject positionSiderunrealizedPNLObjectliquidationPriceObjectr vwapObject summaryObjects r rzcoinbase.parse_positionMst##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 rYr 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) rrYr 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 01I@C C C C C C J26DW[dfDD3DcDQTDDDD$154VZceCC#CSCPSCCCC$HLZ^mqz|MMMTWMgjMMMM37TX\eg A AC As ARU Alpq|l} A A A A04$UYbd ~ ~ ~C ~s ~imnyiz ~ ~ ~ ~:::] ] x] ;] ] ] ] ~{ { { 5{ { { { z*, 3 3V 3 3 3 3-/CCCCJ-/;;;;zZ OZ Z Z Z x@ @ @ @ @ D8:+C+C+C+CZ-/VV:VVVVp6:" < <7 < < < < <9=RGGgGGGGB9=R4G4Gg4G4G4G4Gl68:::F:::: 9;55C555589;C@tt6tVttttl57,),),),)\*,c;c;c;c;c;c;J.2SW`b$$s$#$S$$$$L777 3 3 3n n n n n n ` 2448  S    LP^bkm!!S!X[!!!! XZTTcTTTTT mqy{Q.Q.Q.IQ.YQ.X]Q.fiQ.Q.Q.Q.fBBB5BBBBH : : : 3 3 3HHH9=R - -S -# - - - -6:"!1!1s!1!1!1!1Ffjx|FH'2'23'2'29'2I'2_b'2ru'2'2'2'2R8rsa 655555......BBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBB******000000------......''''''))))))******))))))......))))))444444%%%%%%HAHAHAHAHAxHAHAHAHAHAr