i}VddlmZddlmZddlZddlmZmZmZm Z m Z m Z m Z m Z mZmZmZmZmZmZmZmZddlmZddlmZddlmZddlmZdd lmZdd lmZdd lmZdd lmZdd lm Z ddl!m"Z"ddl#m$Z$GddeeZ%dS))Exchange) ImplicitAPIN)Balances CurrenciesCurrencyIntMarketOrder OrderSide OrderTypePositionStrStringsTickerTickersTrade Transaction TransferEntry)List)Any) ExchangeError)AuthenticationError)PermissionDenied)ArgumentsRequired) BadRequest) InvalidOrder)DuplicateOrderId) TICK_SIZE)Precisec eZdZfdZifdefdZdedefdZifdZdZdddifd e d e d e fd Z dDd e fdZ dDd e fdZifdefdZdZifdZifdZifdZifd ededefdZdddifded e d e deefdZifd efdZdDd e fdZdifdedeefdZdddifde d e d e deefdZdddifde d e d e deefdZ d Z!dDd!e"defd"Z#dDd e de$fd#Z%ifdee fd$Z&de fd%Z'ifde(fd&Z)d'Z*difdede+fd(Z,ifd ede-fd)Z.dDd*e/d e de-fd+Z0ifde1fd,Z2de1fd-Z3ifdeded.ed/ede4f d0Z5difd ed1e6d2e7ded3ef d4Z8dDd e de9fd5Z:d6Z;d7Zddifd8ed ed1e6d2e7ded3ef d;Z?difd8ed e fd<Z@dddifd e d e d e dee9fd=ZAdddifd e d e d e fd>ZBdifdedefd?ZCd@ZDgdAiddfdBZEdCZFxZGS)Ecoinbaseinternationalc |tt|iddddddgddd dd d d d d|jddddididdddddddddddddddddddddd dd!dd"dd#dd$dd%did&dd'dd(dd)dd*dd+dd,dd-dd.dd/dd0dd1dd2dd3dd4dd5dd6did7dd8dd9dd:dd;dddd?dd@ddAddBddCddDddEddFddGdidHddIddJddKddLddMddNddOddPddQddRddSddTddUddVddWddXddddddddddddddY dZd[d\d]id\d^id_d`gdagdbdcddddddedfd dggdhigdigdjdkdlgdmdkgdndoidpdq|dr|dsdd|dt|drg|du|drg|dv|dwg|dx|dwg|dy|dzg|d{|d|gg|dt|dsg|du|d}g|dv|d~g|dx|dg|dy|dg|d{|dtggddidt dittttttttttd ddddddddddddddbddidddddddddiS)Nidr!namezCoinbase International countriesUS certifiedTpro rateLimitdversionv1 userAgentchromeheadersz CB-VERSIONz 2018-05-30hasCORSspotmarginswapfutureoptionF addMargincancelAllOrders cancelOrder cancelOrderscloseAllPositions closePositioncreateDepositAddresscreateLimitBuyOrdercreateLimitSellOrdercreateMarketBuyOrdercreateMarketBuyOrderWithCostcreateMarketOrderWithCostcreateMarketSellOrdercreateMarketSellOrderWithCost createOrdercreatePostOnlyOrdercreateReduceOnlyOrdercreateStopLimitOrdercreateStopMarketOrdercreateStopOrder editOrder fetchAccounts fetchBalance fetchBidsAsksfetchBorrowRateHistoriesfetchBorrowRateHistoryfetchCanceledOrdersfetchClosedOrdersfetchCrossBorrowRatefetchCrossBorrowRatesfetchCurrencies fetchDepositsfetchFundingHistoryfetchFundingRatefetchFundingRateHistoryfetchFundingRatesfetchIndexOHLCVfetchIsolatedBorrowRatefetchIsolatedBorrowRatesfetchL2OrderBook fetchLedger fetchLeveragefetchLeverageTiersfetchMarginAdjustmentHistoryfetchMarginMode fetchMarketsfetchMarkOHLCV fetchMyBuys fetchMySells fetchMyTrades fetchOHLCVfetchOpenInterestHistoryfetchOpenOrders fetchOrderfetchOrderBook fetchOrders fetchPositionfetchPositionModefetchPositionsfetchPositionsRiskfetchPremiumIndexOHLCV fetchTicker) fetchTickers fetchTime fetchTradesfetchTradingFeefetchTradingFeesfetchWithdrawals reduceMargin setLeverage setMargin setMarginModesetPositionModewithdrawurlszQhttps://github.com/ccxt/ccxt/assets/43336371/866ae638-6ab5-4ebf-ab2c-cdcce9545625restz*https://api.international.coinbase.com/apiz!https://api-n5e1.coinbase.com/apiz"https://international.coinbase.comz)https://docs.cloud.coinbase.com/intx/docszlhttps://help.coinbase.com/en/international-exchange/trading-deposits-withdrawals/international-exchange-fees)logoapitestwwwdocfeesreferralrequiredCredentials)apiKeysecretpasswordrget)assetszassets/{assets}zassets/{asset}/networks instrumentszinstruments/{instrument}zinstruments/{instrument}/quotez instruments/{instrument}/fundingr)orders orders/{id} portfoliosportfolios/{portfolio}zportfolios/{portfolio}/detailzportfolios/{portfolio}/summaryzportfolios/{portfolio}/balancesz'portfolios/{portfolio}/balances/{asset}z portfolios/{portfolio}/positionsz-portfolios/{portfolio}/positions/{instrument}zportfolios/fillszportfolios/{portfolio}/fills transfersztransfers/{transfer_uuid}) rrzportfolios/marginzportfolios/transferztransfers/withdrawztransfers/addressz transfers/create-counterparty-idz"transfers/validate-counterparty-idztransfers/withdraw/counterpartyrrr)rpostputdelete)publicprivatertradingz0.004z0.002010000005000000z0.00351000000050000000z0.003 250000000z0.0025z0.0016z0.001z0.0008z0.0005)takermaker)rr tierBased percentagetiers precisionMode exceptions) DUPLICATE_CLIENT_ORDER_IDzOrder rejectedzmarket orders must be IoCztif is requiredzInvalid replace order request Unauthorizedzinvalid result_limitzis a required fieldz Not Foundzip not allowed)exactbroad timeframes ONE_MINUTE FIVE_MINUTEFIFTEEN_MINUTE THIRTY_MINUTEONE_HOURTWO_HOURSIX_HOURONE_DAY)1m5m15m30m1h2h6h1doptionsnfqkvdjpmethodv1PrivatePostTransfersWithdrawETHARBITRUMAVAXOPTIMISMMATICSOLBTC)ethereumarbitrum avacchainoptimismpolygonsolanabitcoin)brokerId portfolior networksById) deep_extendsuperr!describe userAgents parse_numberrrrrrr)self __class__s n/var/www/html/crypto-bot/backend/venv/lib/python3.11/site-packages/ccxt/async_support/coinbaseinternational.pyrzcoinbaseinternational.describes&;T B B K K M MmP )mP ,mP  $mP   mP 4 mP  mP  tmP  2mP  lmP  QQQ$Q Q $ Q % QUQ"4QtQQ$UQ Q'Q&tQ'Q '!Q"/#QQ$,U%Q&('Q(0)Q*t+Q,&t-Q.(/Q0'1Q2(3Q4"45Q6T7Q8 9Q:;Q< =Q>+E?Q@)%AQB&uCQD$UEQQQF'GQH(IQJ"4KQL MQN&uOQP#EQQR*4SQT$UUQV"5WQX*5YQZ+E[Q\#E]Q^u_Q` aQb%ecQd/eQf"5gQQQhiQj!%kQltmQnoQp qQresQt+EuQv"4wQxdyQz!%{Q|u}Q~ Q@$UAQB!$CQD%eEQF)%GQHtIQQJ!%"$#($)$( %$!!&#( aQQQmP | kH?<?C}mP ^ " $$_mP h         ! ! !*4  %)#A$ $ 224imP R !..w77!..w77!%"&"..s33T5F5Fw5O5OP!..y994;L;LW;U;UV!..y994;L;LX;V;VW!..z::D!& *!' *&#$!! {mP mP m m m methodNamecKd}|||d\}}| |dkr||gS||jd}| |dkr||gS|d{V}t dt |D]]}||}||di}||dr&||d} | |jd<| |gcS^t|j dz|zdz) Nrrrinfo is_default portfolio_id z]() requires a portfolio parameter or set the default portfolio with self.options["portfolio"]) handle_option_and_params safe_stringrfetch_accountsrangelen safe_dict safe_boolrr#) rrparamsrdefaultPortfolioaccountsiaccountr portfolioIds rhandle_portfolio_and_paramsz1coinbaseinternational.handle_portfolio_and_params sQ  99&*kZZ 6  ! Rv& &++DL+FF  (/?2/E/E$f- -,,........q#h--(( - -AqkG>>'6266D~~dL11 -"..t^DD ,7 [)#V,,,, - # :>]!]^^ ^r currencyCodecKd}|||d\}}|||d{V|j|d}||dd}|P||rt |jdz|zdz||}|d}n|||}||gS)Nnetwork_arn_idnetworks networkCodenetworkz5 createDepositAddress network not found for currency z# please specify networkId in paramsr#) rload_currency_networks currencies safe_string_2is_emptyrr#find_default_networknetwork_code_to_id)rrrr networkIdrrdefaultNetworks rhandle_network_id_and_paramsz2coinbaseinternational.handle_network_id_and_paramss  99&*N^__ 6  --l;; ; ; ; ; ; ; ;|4Z@H(( JJG==**_$TW/f%fiu%uy^&^___!%!:!:8!D!D*40  33G\JJ 6""rcK|d{V||d{V}|||S)aj fetch all the accounts associated with a profile :see: https://docs.cloud.coinbase.com/intx/reference/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) load_marketsv1PrivateGetPortfoliosparse_accountsrrresponses rrz$coinbaseinternational.fetch_accounts,si!!!!!!!!!44V<<<<<<<<$""8V444rc:||dddd|dS)Nrportfolio_uuid)r#typecoder)r)rrs r parse_accountz#coinbaseinternational.parse_accountHs2"$$Wn>NOO    rNsymbolsincelimitc K|t|jdz|d{Vd}||dd\}}d}||ddd\}}d}|r!|d||||||d{VS||}|||d d z } |d ||d d | |zd } ||| d<|| | |d{V} | | dg} | | |||S)a fetches historical funding rate prices :see: https://docs.cloud.coinbase.com/intx/reference/getinstrumentfunding :param str symbol: unified symbol of the market to fetch the funding rate history for :param int [since]: timestamp in ms of the earliest funding rate to fetch :param int [limit]: the maximum amount of `funding rate structures ` to fetch :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) Nz5 fetchFundingRateHistory() requires a symbol argumentFrYpaginatemaxEntriesPerRequestr* ccxtPageKeyr#offset result_offset) instrumentr result_limitresults) rr#rr fetch_paginated_call_incrementalmarket safe_integersafe_integer_2'v1PublicGetInstrumentsInstrumentFundingextend safe_listparse_funding_rate_histories) rr r r rrrpageKeyrpagerequestrrawRatess rfetch_funding_rate_historyz0coinbaseinternational.fetch_funding_rate_history_s >#DG.e$eff f!!!!!!!!!88AZ\fgg&#'+'D'DVMfh~AD(E(E$f  W>>?XZ`bginpvxBVWWWWWWWW WV$$  !44q8 ,!00?TX[oTopp    &+GN #EEdkkRY[aFbFbcccccccc$>>(Ir::0065%PPPrrc.|||SN)parse_funding_rate)rrrs rparse_funding_rate_historyz0coinbaseinternational.parse_funding_rate_historys&&tV444rc^||dd}id|d|d|d||dddddd dd ||d |d ||d d||d|ddddddddddddS)N event_timetimerr  markPrice mark_price indexPrice interestRateestimatedSettlePrice timestampdatetime fundingRate funding_ratefundingTimestampfundingDatetimenextFundingRatenextFundingTimestampnextFundingDatetimepreviousFundingRatepreviousFundingTimestamppreviousFundingDatetime)r safe_symbol safe_number parse8601)rcontractrr6s rr'z(coinbaseinternational.parse_funding_rates5,,X|VLL H d&&tV44  ))(LAA  $  D  #D   88    4++HnEE   ? ?    t  #D  "4  "4 '! " &t#  rr c&K|d{Vd}||ddd\}}d}|d|d{V\}}d|i}|dkrG||}|d|d<d}||d|d{V\}}||d<t |||||d{V}||d } ||d d } || | |d S) a create a currency deposit address :see: https://docs.cloud.coinbase.com/intx/reference/createaddress :see: https://docs.cloud.coinbase.com/intx/reference/createcounterpartyid :param str code: unified currency code of the currency for the deposit address :param dict [params]: extra parameters specific to the exchange API endpoint :param str [params.network_arn_id]: Identifies the blockchain network(e.g., networks/ethereum-mainnet/assets/313ef8a9-ae5a-5f2f-8a56-572c0e2a4d5a) if not provided will pick default :param str [params.network]: unified network code to identify the blockchain network :returns dict: an `address structure ` Nr=rv1PrivatePostTransfersAddressrr#assetrdestination_tagaddresscounterparty_id)currencytagrEr) rrrrGrgetattrrrr) rr rrrr"rGrrrHrEs rcreate_deposit_addressz,coinbaseinternational.create_deposit_addresss!!!!!!!!!66v?UW_bABB "&"B"BCY[a"b"bbbbbbb 6   4 4 4}}T**H'~GG I&*&G&GNdfl&m&m m m m m m m Iv(1G$ %.v..t{{7F/K/KLLLLLLLLx):;;$$Xy:KLL    rc||}tdt|D]5}||d}||dd}|dur ||cS6|dS)NrrrFT)to_arrayrrr)rr networksArrayrrrs rrz*coinbaseinternational.find_default_networks h// q#m,,-- ( (A #F+DlEBBJT!!$Q''''"QrcK||}||d}|dSd|di}||d{V}dS)NrrCr#)rGrv1PublicGetAssetsAssetNetworks)rr rrGrr" rawNetworkss rrz,coinbaseinternational.load_currency_networkssp==&&>>(J77   F Xd^ !??HHHHHHHH rci}tdt|D]<}|||||}|||d<=|S)Nrr)rrr parse_network)rrrresultrrs rparse_networksz$coinbaseinternational.parse_networkssbq#h--(( 1 1Akk$"4"4Xa["A"A6JJG)0F79% & & rc||d}||}||d}|||||d|||gdd|ddddd||d||dddddd d S) N asset_namer display_name) network_namerWrrmin_withdrawal_amtmax_withdrawal_amtminmaxrdeposit) rr#r$ractiver_r precisionfeelimits)rsafe_currency_code safe_networknetwork_id_to_code safe_string_nr>)rrr currencyIdrrs rrRz#coinbaseinternational.parse_networks %%g|<< ..z:: $$W.>??   $$Wn==..t/A/A'K}K}K}@B0C0CEQRR ++G5IJJ++G5IJJ    " "    ramountreturncKd}|d|d{V\}}|t|jdz||d}||||d{VS)a Either adds or reduces margin in order to set the margin to a specific value :see: https://docs.cloud.coinbase.com/intx/reference/setportfoliomarginoverride :param str symbol: unified market symbol of the market to set margin in :param float amount: the amount to set the margin to :param dict [params]: parameters specific to the exchange API endpoint :returns dict: A `margin structure ` Nr}z9 setMargin() only allows setting margin to full portfolio)rmargin_override)rrr#v1PrivatePostPortfoliosMarginr)rr rirrr"s r set_marginz coinbaseinternational.set_margin(s "&"B"B;PV"W"WWWWWWW 6  TW'bbcc c"%  77 GV8T8TUUUUUUUUUrc .K|d{Vd}||dd\}}d}||ddd\}}d}|r!|d||||||d{VS|||ddz }d||d d||zi} |||| d <|t |d} | | d <d} ||dd \} }| | | d <d} ||dd \} }| || | d<||| |d{V} | | dg}| |S)a fetch history of deposits and withdrawals :see: https://docs.cloud.coinbase.com/intx/reference/gettransfers :param str [code]: unified currency code for the currency of the deposit/withdrawals, default is None :param int [since]: timestamp in ms of the earliest deposit/withdrawal, default is None :param int [limit]: max number of deposit/withdrawals to return, default is None :param dict [params]: extra parameters specific to the exchange API endpoint :param str [params.portfolios]: Identifies the portfolios by UUID(e.g., 892e8c7c-e979-4cad-b61b-55a197932cf1) or portfolio ID(e.g., 5189861793641175). Can provide single or multiple portfolios to filter by or fetches transfers for all portfolios if none are provided. :param int [params.until]: Only find transfers updated before self time. Use timestamp format :param str [params.status]: The current status of transfer. Possible values: [PROCESSED, NEW, FAILED, STARTED] :param str [params.type]: The type of transfer Possible values: [DEPOSIT, WITHDRAW, REBATE, STIPEND, INTERNAL, FUNDING] :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 list of `transaction structures ` NfetchDepositsWithdrawalsrrr*rrrr time_fromrruntiltime_tor) rrrrriso8601r\v1PrivateGetTransfersrrparse_transactions)rr r r rrrr r!r"newLimitrrrrrawTransactionss rfetch_deposits_withdrawalsz0coinbaseinternational.fetch_deposits_withdrawals;s4!!!!!!!!!88A[]ghh&#'+'D'DVMgiBE(F(F$f  V>>?Y[_afhmouw~AUVVVVVVVV V  !44q8 T00?TX[oTopp   #'<<#6#6GK  5#H&.GN # !::6C]_kll F  !$.GL !55f>XZabb v  !%e!4!4GI 33DKK4P4PQQQQQQQQ6..9bAA&&777rc^K|d{V||}d}|d|d{V\}}|||d}||||d{V}||S)a :see: https://docs.cloud.coinbase.com/intx/reference/getportfolioposition fetch data on an open position :param str symbol: unified market symbol of the market the position is held in :param dict [params]: extra parameters specific to the exchange API endpoint :returns dict: a `position structure ` Nro)rr)rr r market_id2v1PrivateGetPortfoliosPortfolioPositionsInstrumentrparse_position)rr rrr"positions rfetch_positionz$coinbaseinternational.fetch_positions!!!!!!!!!V$$ "&"B"B?TZ"["[[[[[[[ 6"..00  PPQUQ\Q\]dflQmQmnnnnnnnn ""8,,,rc ||d}||d}|||d}d}tj|drd}tjd|}|id|d ||d d|dd dd ||d d dddd||dd|d||d||dddddddddddd||ddddddddS)Nr net_size-longrshortz-1rr# entryPricer,r-notional collateral unrealizedPnlunrealized_pnlside contracts contractSizer1r2hedgedmaintenanceMarginmaintenanceMarginPercentage initialMarginim_contribution)initialMarginPercentageleverageliquidationPrice marginRatio marginModer)r safe_marketr string_le string_mul safe_positionr>r)rr~rmarketIdquantityrs rr}z$coinbaseinternational.parse_positions ##Hh77##Hj99!!(FC88  Xs + + :D)$99H!!# H# $""8T22#  fX&#  $ # ))(LAA #  #  $#  T--h8HII#  D#  **844#  D,,V^DD#  #  #  d#  # *4!# " T--h8IJJ## $(, $/# # #    rsymbolscK|d{Vd}|d|d{V\}}d|i}||||d{V}||}||r|S||}||d|dS)a :see: https://docs.cloud.coinbase.com/intx/reference/getportfoliopositions fetch all open positions :param str[] [symbols]: list of unified market symbols :param dict [params]: extra parameters specific to the exchange API endpoint :param str [method]: method name to call, "positionRisk", "account" or "option", default is "positionRisk" :returns dict[]: a list of `position structure ` Nrqrr F)rr(v1PrivateGetPortfoliosPortfolioPositionsrparse_positionsrmarket_symbolsfilter_by_array_positions)rrrrr"r positionss rfetch_positionsz%coinbaseinternational.fetch_positionss!!!!!!!!! "&"B"BCSU["\"\\\\\\\ 6  FFt{{SZ\bGcGcdddddddd$((22 == ! !  %%g..--i7ERRRrcK|d{Vd|d<|||||d{VS)a fetch all withdrawals made from an account :see: https://docs.cloud.coinbase.com/intx/reference/gettransfers :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 :param str [params.portfolios]: Identifies the portfolios by UUID(e.g., 892e8c7c-e979-4cad-b61b-55a197932cf1) or portfolio ID(e.g., 5189861793641175). Can provide single or multiple portfolios to filter by or fetches transfers for all portfolios if none are provided. :param int [params.until]: Only find transfers updated before self time. Use timestamp format :param str [params.status]: The current status of transfer. Possible values: [PROCESSED, NEW, FAILED, STARTED] :param str [params.type]: The type of transfer Possible values: [DEPOSIT, WITHDRAW, REBATE, STIPEND, INTERNAL, FUNDING] :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 list of `transaction structures ` NWITHDRAWrrryrr r r rs rfetch_withdrawalsz'coinbaseinternational.fetch_withdrawalssa!!!!!!!!!#v44T5%PPPPPPPPPrcK|d{Vd|d<|||||d{VS)a* fetch all deposits made to an account :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 :param str [params.portfolios]: Identifies the portfolios by UUID(e.g., 892e8c7c-e979-4cad-b61b-55a197932cf1) or portfolio ID(e.g., 5189861793641175). Can provide single or multiple portfolios to filter by or fetches transfers for all portfolios if none are provided. :param int [params.until]: Only find transfers updated before self time. Use timestamp format :param str [params.status]: The current status of transfer. Possible values: [PROCESSED, NEW, FAILED, STARTED] :param str [params.type]: The type of transfer Possible values: [DEPOSIT, WITHDRAW, REBATE, STIPEND, INTERNAL, FUNDING] :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 list of `transaction structures ` NDEPOSITrrrs rfetch_depositsz$coinbaseinternational.fetch_depositssa!!!!!!!!!"v44T5%PPPPPPPPPrc>ddddd}||||S)Nokpendingcanceled) PROCESSEDNEWSTARTEDFAILEDrrstatusstatusess rparse_transaction_statusz.coinbaseinternational.parse_transaction_status s4     &&999rrGc ||d}||di}||dd||gddg}||di}||dd||gdd g}id |d ||d d ||dd||d|d|||dddd|d|ddddddd||dd||dd|||d|d|||dd||d ddd!iS)"N updated_atfrom_portfolio from_addressfrom_cb_account)r#uuidr$from_counterparty_id to_address to_cb_accountto_counterparty_idrr# transfer_uuidtxidtransaction_uuidr1r2rrXrE addressTo addressFromrHtagTotagFromrresourcerirGrCrupdatedrbcostrG)rrrgr?rfr>rdr)r transactionrGr2 fromPorfolior toPorfoliors rparse_transactionz'coinbaseinternational.parse_transaction)s ##K>>~~k3CRHH ((~GXZ^ZlZlmy|R|R|R[S[SUk7lmm ^^K1A2FF &&{\?TXTfTfgqtJtJtJUKUKMa5bcc  K $"";@@  D$$[2DEE  11    t..t/?/? ^/\/\]]   t    ;  4  T  t  D$$[*==  d&&{H==  //0@0@g0V0VX`aa d33D4D4D[RZ4[4[\\! " t~~h//# $  %   rc4||d}||d}||||dd||d||||||d||dd||d||dd||d |||d d d S) Nr r*fill_idexec_idorder_idr fill_pricefill_qtyrb fee_assetr) rr#orderr1r2r rr takerOrMakerpricerirrb)r safe_traderr?r=safe_string_lowerr>rd)rtraderrr2s r parse_tradez!coinbaseinternational.parse_tradeLsB##E844##E<88$$UIyAA%%eZ8811 &&x88**5&99 %%e\::&&uj99((66 33D4D4DUK4X4XYY     rcfK||d{V}||S)a0 :see: https://docs.cloud.coinbase.com/intx/reference/getinstruments retrieves data on all markets for coinbaseinternational :param dict [params]: extra parameters specific to the exchange API endpoint :returns dict[]: an array of objects representing market data N)v1PublicGetInstruments parse_marketsrs r fetch_marketsz#coinbaseinternational.fetch_marketssD44V<<<<<<<<d!!(+++rcl||d}||d}||d}||d}|dk}|j}|dz|z}d} |s |} |d|zz }id|d |d|d |d |d | r| ndd |d|d| r| ndd|rdndd|ddd| ddddd||ddkd| |rdn| |k|rdn| |k|dd|dd|rdnddddd||d||d||dd d||d!d"d|rdn||d#d"ddd"||d$dd"d%|dd& S)'Nr base_asset_namequote_asset_namerSPOT/:r# lowercaseIdbasequotesettlebaseIdquoteIdsettleIdr2r4r3Fr5r6r` trading_stateTRADINGr@rrrrbase_incrementquote_increment)rirrbase_imfr[position_limit_qtymin_notional_value)rrirr) linearinverserrrexpiryexpiryDatetimestrike optionTyperarcrcreated)rrlowerr>) rrrrrtypeIdisSpotrr rs r parse_marketz"coinbaseinternational.parse_markets^##FH55!!&*;<<""6+=>>!!&&11F"y#' $H cGm #F4 (4 8>>++4  f4  F 4 W 4 (4hh 4  f4  w4  H6$4  f0FF&4  F4  e4  J4  e4  e4 d&&v??9L!4 " F #4 $%?dd8w+>%@ttH,?)_W-)_W-$*1DD"**63CDD))&2CDD((1BCC ++FJ??  #)]44t/?/?H\/]/]    ++F4HII$g4 4 4 4 rcK||d{V}i}tdt|D](}|||}|||d<)|S)a fetches all available currencies on an exchange :see: https://docs.cloud.coinbase.com/intx/reference/getassets :param dict [params]: extra parameters specific to the exchange API endpoint :returns dict: an associative dictionary of currencies Nrr )v1PublicGetAssetsrrparse_currency)rrrrSrrGs rfetch_currenciesz&coinbaseinternational.fetch_currencies-s 11&99999999 q#j//** 0 0A**:a=99H'/F8F# $ $ rc ||d}||}||d}|||d||dkddddd|jd S)NrVrACTIVE) r#r$r rarr`r_rrrbrrc)rrdrc)rrGr#r statusIds rrz$coinbaseinternational.parse_currencyHs{  h 5 5&&r**##Hh778+k   rcK|d{V||}||d{V}i}tdt |D]x}||}||d}||}||di} || | |||<y| |d|dS)a fetches price tickers for multiple markets, statistical information calculated over the past 24 hours for each market :see: https://docs.cloud.coinbase.com/intx/reference/getinstruments :param str[]|None symbols: unified symbols of the markets to fetch the ticker for, all market tickers are returned if not assigned :param dict [params]: extra parameters specific to the exchange API endpoint :returns dict: a dictionary of `ticker structures ` Nrr rT) rrrrrrr=r parse_tickerrfilter_by_array) rrrrtickersrrrr rs r fetch_tickersz#coinbaseinternational.fetch_tickerses!!!!!!!!!%%g.. 77???????? q#k**++ S SA$QJ'' H==H%%h//FNN:w;;E"//t7G7G7Q7QRRGFOO##GXwEEErcK|d{V||}d||i}||||d{V}|||S)a fetches a price ticker, a statistical calculation with the information calculated over the past 24 hours for a specific market :see: https://docs.cloud.coinbase.com/intx/reference/getinstrumentquote :param str symbol: unified symbol of the market to fetch the ticker for :param dict [params]: extra parameters specific to the exchange API endpoint :returns dict: a `ticker structure ` Nr)rrr{%v1PublicGetInstrumentsInstrumentQuoterr )rr rrr"tickers r fetch_tickerz"coinbaseinternational.fetch_tickerys!!!!!!!!!V$$ $..00 AA$++gW]B^B^________  000rrc||d}|id|d|d|d||d|d||dd||dd ||d d ||d d dddddddddddddddddddddS)Nr1rr r2bidbest_bid_price bidVolume best_bid_sizeaskbest_ask_price askVolume best_ask_sizehighlowopencloselastchangeraveragevwap) baseVolume quoteVolume previousClose)r safe_tickerr=r?r>)rrrr2s rr z"coinbaseinternational.parse_tickersv$##FK88! F! d&&tV44!  11!   ! 4##F,<== ! ))&/BB !  4##F,<==!  ))&/BB!  D!  4!  D!  T!  D!  d!  $! t!! " D#! $!)! ! !    rc K|d{Vd}|d|d{V\}}d|i}||||d{V}||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/intx/reference/getportfoliobalances :param dict [params]: extra parameters specific to the exchange API endpoint :param boolean [params.v3]: default False, set True to use v3 api endpoint :returns dict: a `balance structure ` NrMr)rr'v1PrivateGetPortfoliosPortfolioBalancesr parse_balance)rrrr"balancess r fetch_balancez#coinbaseinternational.fetch_balances!!!!!!!!! "&"B"B>SY"Z"ZZZZZZZ 6  EEdkkRY[aFbFbcccccccc$!!(+++rcpd|i}tdt|D]}||}||d}||}|}||d|d<||d|d<|||<||S)NrrrVrtotalholdused)rrrrdr safe_balance)rrrSr rawBalancerhr rs rr+z#coinbaseinternational.parse_balances" H q#h--(( # #A!!J))*lCCJ**:66DllnnG#// JGGGG "..z6BBGFO"F4LL  (((r fromAccount toAccountc (K|d{V||}|d|||d}||||d{V}||d} |ddd||||| rdndd S)a4 Transfer an amount of asset from one portfolio to another. :see: https://docs.cloud.coinbase.com/intx/reference/createportfolioassettransfer :param str code: unified currency code :param float amount: amount to transfer :param str fromAccount: account to transfer from :param str toAccount: account to transfer to :param dict [params]: extra parameters specific to the exchange API endpoint :returns dict: a `transfer structure ` Nr#)rCammountfromtosuccessrfailed) rr#r1r2rGrir4r5r)rrGv1PrivatePostPortfoliosTransferrr) rr rir4r5rrGr"rr:s rtransferzcoinbaseinternational.transfers!!!!!!!!!==&&d^    ==dkk'SY>Z>Z[[[[[[[[..955&"%3dd8   rrrrcK|d{V||}|}||gd} ||jdd} | dz|z} | dd} | ||d||d |d } | |d krd }nd }| | d<|| d<|d kr|t|j dz|| d<d} | d|d{V\} }| | | d<| |dd}| |dd}|dkr"||dkrt|j dzd}n|dn|}||| d<|| d<| |gd}||| |d{V}|||S)a create a trade order :see: https://docs.cloud.coinbase.com/intx/reference/createorder :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 bool [params.postOnly]: True or False :param str [params.tif]: 'GTC', 'IOC', 'GTD' default is 'GTC' for limit orders and 'IOC' for market orders :param str [params.expire_time]: The expiration time required for orders with the time in force set to GTT. Must not go beyond 30 days of the current time. Uses ISO-8601 format(e.g., 2023-03-16T23:59:53Z) :param str [params.stp_mode]: Possible values: [NONE, AGGRESSING, BOTH] Specifies the behavior for self match handling. None disables the functionality, new cancels the newest order, and both cancels both orders. :returns dict: an `order structure ` N) triggerPrice stopPrice stop_pricerrrrr#r )client_order_idrrsizer  STOP_LIMITSTOPrArz@createOrder() requires a price parameter for a limit order typesrrErpostOnly post_onlytif timeInForceMARKETIOCz6createOrder() market orders must have tif set to "IOC"GTC)rCuserrGrJ)rrupper safe_number_nrrramount_to_precisionrr#r safe_bool_2romitv1PrivatePostOrdersr parse_order)rr rrrirrrrr@clientOrderIdprefix clientOrderIdr"rrGrIrs r create_orderz"coinbaseinternational.create_ordersl&!!!!!!!!!V$$&&v/Z/Z/Z[[ "..t|ZTT+c1DIIKK? %ad+ ,JJLL ,,,VH-=vFF     w%$-GL !  7??}"47-o#oppp$GG  "&"B"B=RX"Y"YYYYYYY 6  #,GK ##FJ DD   >> X  3%<<"47-e#efffCCK%%cC  #+GK 6#Y#Y#YZZ11$++gv2N2NOOOOOOOO0&111rc ||d}||d}d}|d|i}||dd}|id|d||dd ||d d ||d |d dd|||d|||dd||dddd||dd||dd||dd||dd||dd||dd||dd||d|||d|dd|S) Nr rbr submit_timer*rr#rrWrCr1r2lastTradeTimestamprrJrIrGrrr@rAr?rirDfilledexec_qty remaining leaves_qty avg_price order_status)rr#rrbtrades) rr>r safe_orderr?r=parse_order_typerparse_order_status)rrrrfeeCostrbr2s rrUz!coinbaseinternational.parse_orderiso0##E844""5%00  C%%e]LII E $""5*55  T--e5FGG  11    !$   d&&x88  D))$*:*:5&*I*IJJ  4++E599    D**5&99  T%%eW55  ))%>>  D,,ULAA  d&&uf55 d&&uj99! " ))%>># $''{;;--d.>.>un.U.UVV-   . / rc Jddddddddddd }||||S)Nrclosedrrejectedexpired) rPARTIAL_FILLEDFILLEDCANCELEDREPLACEDPENDING_CANCELREJECTED PENDING_NEWEXPIREDPENDING_REPLACErrs rrez(coinbaseinternational.parse_order_statussF$""$"! %   &&999rcN|dkrdSddddd}||||S)NUNKNOWN_ORDER_TYPErr )rKLIMITrFrEr)rrtypess rrdz&coinbaseinternational.parse_order_typesE ' ' '4!    tT222rr#cBK|d{Vd}|d|d{V\}}||d}d}|||}||||d{V}|||S)a cancels an open order :see: https://docs.cloud.coinbase.com/intx/reference/cancelorder :param str id: order id :param str symbol: not used by coinbaseinternational cancelOrder() :param dict [params]: extra parameters specific to the exchange API endpoint :returns dict: An `order structure ` Nr9)rr#)rrrv1PrivateDeleteOrdersIdrrU)rr#r rrr"rrs r cancel_orderz"coinbaseinternational.cancel_orders!!!!!!!!! "&"B"B=RX"Y"YYYYYYY 6"    [[((F33DKK4P4PQQQQQQQQ0///rcVK|d{Vd}|d|d{V\}}d|i}d}|r ||}|d|d<||||d{V}|||S)ab cancel all open orders :param str symbol: unified market symbol, only orders in the market of self symbol are cancelled when symbol is not None :param dict [params]: extra parameters specific to the exchange API endpoint :returns dict[]: a list of `order structures ` Nr8rr#r)rrrv1PrivateDeleteOrdersr parse_orders)rr rrr"rrs rcancel_all_ordersz'coinbaseinternational.cancel_all_orderss!!!!!!!!! "&"B"BCTV\"]"]]]]]]] 6    1[[((F$*4LGL !11$++gv2N2NOOOOOOOO  000rcZK|d{V||}d|i} d} |d|d{V\} }| | | d<||||| d<||||| d<||gd} | | | d<||d d } | t|jd z| | d <| | | |d{V} | | |S) a  edit a trade order :see: https://docs.cloud.coinbase.com/intx/reference/modifyorder :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 str params['clientOrderId']: client order id :returns dict: an `order structure ` Nr#rKrrDr)r@rAr?rArCrWz/ editOrder() requires a clientOrderId parameter) rrrrQprice_to_precisionrPrrr#v1PrivatePutOrdersIdrrU)rr#r rrrirrrr"rr@rWrs r edit_orderz coinbaseinternational.edit_orders!!!!!!!!!V$$ "  "&"B"B;PV"W"WWWWWWW 6  #,GK  "66vvFFGFO  #66vuEEGG &&v/Z/Z/Z[[  $-GL !**63DoVV  TW'XXYY Y%2!"// GV0L0LMMMMMMMMv...rcBK|d{Vd}|||}d}|d|d{V\}}||d}||||d{V}|||S)a fetches information on an order made by the user :see: https://docs.cloud.coinbase.com/intx/reference/modifyorder :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 ` Nrl)r#r)rrrv1PrivateGetOrdersIdrrU)rr#r rrrr"rs r fetch_orderz!coinbaseinternational.fetch_order"s!!!!!!!!!  [[((F "&"B"B` NrkFrrr*rrrr)rrrz' fetchOpenOrders() maximum limit is 100r ref_datetimer)rrrrrrrrr#rtv1PrivateGetOrdersrrr})rr r r rrrrr r!r"rr rawOrderss rfetch_open_ordersz'coinbaseinternational.fetch_open_ordersQs3!!!!!!!!! "&"B"BCTV\"]"]]]]]]] 688ART^__&#'+'D'DVM^`vx{'|'|$f  O>>?PRXZ_afhnpwzNOOOOOOOO O  !44q8"!00?TX[oTopp    +[[((F$*GL !  s{{ +T!TUUU&+GN #  &*ll5&9&9GN #00Wf1M1MNNNNNNNNFNN8Y;;   FE5AAArc bK|d{Vd}||dd\}}d}d}||ddd\}}|r!|d||||||d{VSd}|||}|||ddz } d ||d d | |zi} |"|dkrt |jd z|| d <|||| d <| |ddg} | 0| |ddg}|| | d<| | | |d{V} | | dg} || |||S)a^ fetch all trades made by the user :see: https://docs.cloud.coinbase.com/intx/reference/getmultiportfoliofills :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 ` NFrhrrrr*rrrz^ fetchMyTrades() maximum limit is 100. Consider setting paginate to True to fetch more trades.rrqrrtillrr)rrrrrrrr#rtrgrSv1PrivateGetPortfoliosFillsrr parse_trades)rr r r rrr rrr!r"rrrrbs rfetch_my_tradesz%coinbaseinternational.fetch_my_tradessH!!!!!!!!!88R\]]&#'+'D'DV_^tvy'z'z$f  M>>PVX]_dflnuxLMMMMMMMM M  [[((F  !44q8 T00?TX[oTopp   s{{ ,L"LMMM&+GN #  #'<<#6#6GK ""6GV+<==  YYv'899F&*ll5&9&9GN #99$++gv:V:VWWWWWWWWR)R88  >>>rc dK|||\}}|||d{V||}d}|d|d{V\}}d}||ddd\}}d} ||d|d{V\} }|d|d|||d| |d} t||| | |d{V} | | |S)a make a withdrawal :see: https://docs.cloud.coinbase.com/intx/reference/withdraw :see: https://docs.cloud.coinbase.com/intx/reference/counterpartywithdraw :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 :param boolean [params.add_network_fee_to_total]: if True, deducts network fee from the portfolio, otherwise deduct fee from the withdrawal :param str [params.network_arn_id]: Identifies the blockchain network(e.g., networks/ethereum-mainnet/assets/313ef8a9-ae5a-5f2f-8a56-572c0e2a4d5a) :param str [params.nonce]: a unique integer representing the withdrawal request :returns dict: a `transaction structure ` Nrrrsendr#)rrrCrErirGrnonce) handle_withdraw_tag_and_params check_addressrrGrrrrrIrr) rr rirErHrrGrrrr"rs rrzcoinbaseinternational.withdrawsy99#vFF V 7###!!!!!!!!!==&& "&"B"B:v"V"VVVVVVV 666vz8Uuvv "&"C"CD*V\"]"]]]]]]] 6"d^ 'ZZ\\   /v..t{{7F/K/KLLLLLLLL %%h999rc||d}||d}||d}||d}||d}||d}||d}|||dk}|||dk}||d} |o|} |d| ||d||d ||d | ||||d ||d ||d |d||d |ddd S)Nrr_rcr]rr#rr$rr`rbrar\r[r^) rr#r$rr`r_rrbrarc)rrr>r) rrwithdrawEnableddepositEnabledrcr withdrawMaxr_ depositMaxr isEnableds rrez"coinbaseinternational.safe_networks..*==;;22>>&*55&&x77 ..33%%gu55  "{'>*QO  !j&<(1nN$$Wd33 $7 FO$$Wf55'';;nnWh BB%'##GU33))';?? ++He<<&  ++GU;;%     rGETc|d}|ddk}d|zdz|||z} ||||} d| z} |dks|dkr| r| d|| zz } |jd d | z} |r|t |} d }|dkr| r|| }|}| |z| z|z}| | || |j tjd }| ||j|jd }| |||dS)Nrrrrz/apirDELETE?rrrbase64)zCB-ACCESS-TIMESTAMPzCB-ACCESS-SIGNzCB-ACCESS-PASSPHRASEz CB-ACCESS-KEY)urlrbodyr/)implode_paramsrSextract_paramsurlencode_with_array_repeatrcheck_required_credentialsstrrjsonhmacencodebase64_to_binaryrhashlibsha256rr)rpathrrrr/rr+signedfullPathquery savedPathrrpayloadauth signatures rsignzcoinbaseinternational.sign=sa&Q9$=3&)<)I-7D $++d"3"3T5J5J4;5W5WY`YgiqrrI',"+(, !% G fdwOOOrc |dS|jdz|z} ||d} | S||jd| | ||jd| | t | dS)Nrtitlerr)r#rthrow_exactly_matched_exceptionrthrow_broadly_matched_exceptionr) rr reasonrrr/rrrequestHeaders requestBodyfeedbackerrMsgs r handle_errorsz#coinbaseinternational.handle_errorsYs  47S=4'!!(G44    0 01I6S[ \ \ \  0 01I6S[ \ \ \)) )trr&)H__name__ __module__ __qualname__rrrrrr rrr$r r(r'rJrrrTrRfloatrrnrrryrr}rr rrrrrrrrrrrrrrrrrobjectr rr-r+rr=r r rXr rUrerdrzr~rrrrrrerr __classcell__)rs@rr!r!s n n n n n `IK^^C^^^^$#s#PS####"+-55558   .>BPTcgpr/Q/Qs/Q#/Q]`/Q/Q/Q/Qb55v5555  6    <>@. . . . . . `   9;IIII/1-/' ' ' ' RCEVVsVEVVVVV&<@daenpD8D8SD8D8[^D8uy{FvGD8D8D8D8L8: - -3 - - - -D/ / v/ / / / b8%S%S%S%SN37TX\egQQCQsQRUQlpq|l}QQQQ&04$UYbdQQQCQsQimnyizQQQQ$:::! ! x! ;! ! ! ! F4 4 4 54 4 4 4 l*,9,9,V 9,9,9,9,vn fn n n n `-/:6   :6:"FF7FFFFF(68111F1111 ( ( 6( 6( V( ( ( ( T*, , , , , , ,D))))):ac  3  C TW gt    Bos{}T2T2T2IT2YT2X]T2fkT2T2T2T2l77757777r : : : 3 3 39=R+0+0S+0#+0+0+0+0Z5911c1111(hl}AJL#/#/3#/#/9#/I#/_d#/ty#/#/#/#/J8rs 655555;;;;;;qqqqqqqqqqqqqqqqqqqqqqqqqqqqqqqqqqqq******000000------......''''''))))))------444444%%%%%%QQQQQHkQQQQQr