!:hNddlmZddlmZddlZddlmZmZmZm Z m Z m Z m Z m Z mZmZmZmZmZmZmZmZmZmZmZddlmZddlmZddlmZddlmZdd lmZdd l m!Z!dd l"m#Z#Gd d eeZ$y))Exchange) ImplicitAPIN)AnyBalancesCurrencyIntMarketNumOrder OrderBook OrderSide OrderTypePositionStrStringsTicker FundingRateTradeTradingFeeInterface TransactionMarketInterface)List) ExchangeError)ArgumentsRequired) OrderNotFound) OnMaintenance) TICK_SIZE)Precisec eZdZdeffd ZdZd@dededededef fd Z ifde efd Z de fd Z ifde fd Zdifd ededefdZdAdededefdZifd edefdZdAdededefdZddifd ededede efdZifd edefdZdifd ededededef dZ difded efdZ!defd Z"dAd!edede#fd"Z$ddd#ifd ededede e#fd$Z%ddd#ifd ededede e#fd%Z&ddd#ifd ededede e#fd&Z'difded efd'Z(dddifd ededefd(Z)difd)e*de e+fd*Z,difd+eded,ede-fd-Z.dddifd+ededede e-fd.Z/dddifd+ededede e-fd/Z0d0Z1d1Z2dAd2ed3e3de-fd4Z4ifd ede5fd5Z6dAdede5fd6Z7d7d8iddfd9Z8d+e9d:ed;edef d?Z:xZ;S)BbitflyerreturncN|jtt|dddgdddidddd d d d dd ddd dddd dd dd dddd dd dd dd dd dd idd dddddd dd d d d!d d"d d#d d$d d%d d&d d'd d(d d)d d*d d+d,d-id.d/d0d1gd2igd3gd4d5d6d7|j d8|j d8d9it d d d dd d d dd d d d d:d d d d d d d d;dd dd d @&"""%" " $ " % ""4"t"t""$Z" "#D"*5"$U" "5!""#"$ %"&":'"(j)"*!$+",t-".$U/"0!$1"2t3"4t5"6"47"8#E9": ;"<!%=">#D?"@EA"BDC"Hj4.D   (+.`!..w7!..w7 ' %&+(-,0,1).+06:#'#'"&#' ( #($)$)27+0/4#()$,%)&+!$$(%)*. &',#($)*. #',!$#($)*. (',!$$(%)#($)*.$',!$$(,0%)#($)*. *#'AAF## ##OKZ-iyC y y c |dd}|dd}|dd}ddddd d d d d dddd }|j||}|j|dz|zdz|zdzS)Nr 010203040506070809101112) JANFEBMARAPRMAYJUNJULAUGSEPOCTNOVDEC-z T00:00:00Z) safe_string parse8601)rexpiryday monthNameyearmonthsmonths rparse_expiry_datezbitflyer.parse_expiry_datesQqk1QK a{    3~~dSj5036<|KLLrNmarketIdmarket delimiter marketTypec0tt| |||dS)Nr')rr safe_market)rrrrrrs rrzbitflyer.safe_marketsXt069fUUrcf|j|}|j|}|j|}|j||}|j||}g}t dt |D]>}||}|j |d} | jd} |j |d} | dk(} | dk(} | xr| }d}d}d}d}d}|r%|j | d}|j | d }n| r'd }|j | d }|j | d }n| r|j |d }|!| dd }| d d}| dd}|j|}na|jd}|j |d}|dd}|dd}| j|}|j |d }|j|}d}|j|}|j|}|dz|z}|jdd}|jdd}| xs| }|r'd}d}d}|dz|z}| r|dz|j|z}|jid| d|d|d|d|d|d |d!dd"|d|d#d$d | d| d%d$d&d'd(|d)|rdnd'|rdnd$||d||j|ddddd*ddd+ddd+ddd+ddd+d,d|d- A|S).a retrieves data on all markets for bitflyer https://lightning.bitflyer.com/docs?lang=en#market-list :param dict [params]: extra parameters specific to the exchange API endpoint :returns dict[]: an array of objects representing market data r product_code_ market_typeFXFuturesr'Nr)raliasir*/rprrrqgJPY:rrsymbolbasequotesettlebaseIdquoteIdsettleIdtyper(Fr+activeTcontractr)amountprice)minmax)rrrcost) rrrrq contractSizerexpiryDatetimestrike optionType precisionlimitscreatedinfo)publicGetGetmarketspublicGetGetmarketsUsapublicGetGetmarketsEu array_concatrangelenrsplitrsafe_currency_coderyymmddappendiso8601)rparams jp_markets us_markets eu_marketsmarketsresultirr currenciesrr)r*r'rrrrrr expiryDate splitAlias currencyIdssplitIdrrrrrrqrs r fetch_marketszbitflyer.fetch_marketss--f5 "008 //7 ##J ;##GZ8q#g,'g AQZF!!&.9B#J))&-@J$&D I-F8*F DDFFGF))*a8**:q9))*a8**:q9((9= !WF 1gG!#BCJ!33J?F!&S!1J"&"2"2:q"AK(2.F)"#.G hh{3G!%!1!1'1!=J!33J?F**62D++G4ECZ%'FIIi(1EIIi(1E~vH#.#c\DKK,??F MM2b2&22 2 & 2 & 272D222%22&2%2$2 H!2"$$D#2$$(4U $ "&,,v"6""! $#! $# $# $#$ c22 kg P rc.d|i}tdt|D]i}||}|j|d}|j|}|j }|j|d|d<|j|d|d<|||<k|j |S)Nrr currency_codertotal availablefree)rrrraccount safe_balance)rresponserr balance currencyIdcoders r parse_balancezbitflyer.parse_balances)q#h-( #AqkG))'?CJ**:6DllnG#//BGG "..w DGFO"F4L #  ((rcf|j|j|}|j|S)aq query for balance and get the amount of funds available for trading or funds locked in orders https://lightning.bitflyer.com/docs?lang=en#get-account-asset-balance :param dict [params]: extra parameters specific to the exchange API endpoint :returns dict: a `balance structure ` ) load_marketsprivateGetGetbalancer)rrrs r fetch_balancezbitflyer.fetch_balances3 ,,V4(!!(++rrrc |j|j|}d|di}|j|j||}|j ||ddddddS) a4 fetches information on open orders with bid(buy) and ask(sell) prices, volumes and other data https://lightning.bitflyer.com/docs?lang=en#order-book :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 rrrNbidsasksrsize)rrpublicGetGetboardextendparse_order_book)rrrrrrequest orderbooks rfetch_order_bookzbitflyer.fetch_order_booksp V$ F4L **4;;w+GH $$Yx0@$PVX_aghhrtickerc|jd|}|j|j|d}|j|d}|jid|d|d|j |ddddd|j|dd dd |j|d d dd dddd|d|dddddddd|j|dd|d|S)N timestampltprdatetimehighlowbidbest_bid bidVolumeaskbest_ask askVolumevwapopencloselast previousClosechange percentageaveragevolume_by_product) baseVolume quoteVolumer) safe_symbolrr safe_tickerr)rr*rrr,r:s r parse_tickerzbitflyer.parse_tickersg!!$/NN4#3#3FK#HI .! f! !   Y/!  D ! 4 ! 4##FJ7 !  !  4##FJ7!  !  D!  D!  T!  D!  T!  d! $!! " t#! $**63FG)! * + rc|j|j|}d|di}|j|j||}|j ||S)a fetches a price ticker, a statistical calculation with the information calculated over the past 24 hours for a specific market https://lightning.bitflyer.com/docs?lang=en#ticker :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 ` rr)rrpublicGetGettickerr%rDrrrrr'rs r fetch_tickerzbitflyer.fetch_tickers^ V$ F4L **4;;w+GH  622rtradec|j|d}|t|dkrd}d}||dz}||vr||}||j|d}|j|j|d}|j|d}|j|d}|j|d} |j d|}|j | |||j ||d |d|d||ddd |S) Nsider_child_order_acceptance_idchild_order_acceptance_id exec_daterr#rr) rrr,r.rorderrrK takerOrMakerrrrfee)safe_string_lowerrrrr safe_trader) rrIrrKrOidInnerr, priceString amountStringrs r parse_tradezbitflyer.parse_trades6%%eV4  4y1}  99G%g =$$U,GHENN4#3#3E;#GH &&ug6 ''v6   eT *!!$/" Y/X&  "   rsincec|j|j|}d|di}|||d<|j|j||}|j ||||S)a# get the list of most recent trades for a particular symbol https://lightning.bitflyer.com/docs?lang=en#list-executions :param str symbol: unified symbol of the market to fetch trades for :param int [since]: timestamp in ms of the earliest trade to fetch :param int [limit]: the maximum amount of trades to fetch :param dict [params]: extra parameters specific to the exchange API endpoint :returns Trade[]: a list of `trade structures ` rrcount)rrpublicGetGetexecutionsr% parse_tradesrrrXrrrr'rs r fetch_tradeszbitflyer.fetch_trades(st V$ F4L   $GG ..t{{7F/KL  65%@@rc|j|j|}d|di}|j|j||}|j |d}||d||dddS)a] fetch the trading fees for a market https://lightning.bitflyer.com/docs?lang=en#get-trading-commission :param str symbol: unified market symbol :param dict [params]: extra parameters specific to the exchange API endpoint :returns dict: a `fee structure ` rrcommission_raterN)rrrqrrr= tierBased)rrprivateGetGettradingcommissionr% safe_number)rrrrr'rrQs rfetch_trading_feezbitflyer.fetch_trading_feeKs V$ F4L 66t{{7F7ST x):;X&   rrrKrrc|j|j||j|j||d}|j|j ||}|j |d} |j | |dS)a create a trade order https://lightning.bitflyer.com/docs?lang=en#send-a-new-order :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 fulfilled, in units of the quote currency, ignored in market orders :param dict [params]: extra parameters specific to the exchange API endpoint :returns dict: an `order structure ` )rchild_order_typerKrr#rM)rr)r market_idupperprivatePostSendchildorderr%r safe_order) rrrrKrrrr'rrs r create_orderzbitflyer.create_orderjs  NN62 $ JJL  // GV0LM   f&A B   rrc|t|jdz|j|j||d}|j |j ||}|j d|iS)a cancels an open order https://lightning.bitflyer.com/docs?lang=en#cancel-order :param str id: order id :param str symbol: unified symbol of the market the order was made in :param dict [params]: extra parameters specific to the exchange API endpoint :returns dict: An `order structure ` z) cancelOrder() requires a symbol argument)rrMr)rrrrgprivatePostCancelchildorderr%rj)rrrrr'rs r cancel_orderzbitflyer.cancel_ordersz >#DGG.Y$YZ Z  NN62)+ 33DKK4PQ H   rstatusc8dddddd}|j|||S)Nr8closedcanceled)ACTIVE COMPLETEDCANCELEDEXPIREDREJECTEDrrrostatusess rparse_order_statuszbitflyer.parse_order_statuss/!"!"  &&99rrOc|j|j|d}|j|d}|j|d}|j|d}|j|d}|j|j|d}|j|d} |j|d} |j|d } |j | |} d} |j |d }||ddd } |j|d }|j id |ddd|d|d|j|ddd|d| d| ddddd| d|ddddd|d||| ddd|S)Nchild_order_daterr# executed_sizeoutstanding_sizechild_order_staterfrKrtotal_commission)rcurrencyraterMr clientOrderIdrr,r.lastTradeTimestamprorrr~postOnlyrxrrfilled) remainingrQr>trades)rrr{rRrBrcrjr)rrOrr,rrrrrorrKrrrQfeeCostrs r parse_orderzbitflyer.parse_ordersNN4#3#3E;M#NO   0!!%0!!%9$$U,>? (()9)9%AT)UV%%e-?@%%eV4##E>:!!(F3""5*<=   C   e%@ A " T  E     Y/  !$   f  f  D  4    D  U  D  D f! " f# $#+ , - rrc |t|jdz|j|j|}|d|d}|j |j ||}|j ||||}||j|d|}|S)a/ fetches information on multiple orders made by the user https://lightning.bitflyer.com/docs?lang=en#list-orders :param str symbol: unified market symbol of the market orders were made in :param int [since]: the earliest time in ms to fetch orders for :param int [limit]: the maximum number of order structures to retrieve :param dict [params]: extra parameters specific to the exchange API endpoint :returns Order[]: a list of `order structures ` z) fetchOrders() requires a symbol argumentr)rrZr)rrrrprivateGetGetchildordersr% parse_orders filter_by) rrrXrrrr'rorderss r fetch_orderszbitflyer.fetch_orderss >#DGG.Y$YZ Z V$"4L 00Wf1MN""8VUEB  ^^FHf=F rc Rddi}|j||||j||S)a  fetch all unfilled currently open orders https://lightning.bitflyer.com/docs?lang=en#list-orders :param str symbol: unified market symbol :param int [since]: the earliest time in ms to fetch open orders for :param int [limit]: the maximum number of open orders structures to retrieve :param dict [params]: extra parameters specific to the exchange API endpoint :returns Order[]: a list of `order structures ` rrsrr%rrrXrrr's rfetch_open_orderszbitflyer.fetch_open_orderss4    t{{7F7STTrc Rddi}|j||||j||S)a6 fetches information on multiple closed orders made by the user https://lightning.bitflyer.com/docs?lang=en#list-orders :param str symbol: unified market symbol of the market orders were made in :param int [since]: the earliest time in ms to fetch orders for :param int [limit]: the maximum number of order structures to retrieve :param dict [params]: extra parameters specific to the exchange API endpoint :returns Order[]: a list of `order structures ` rrtrrs rfetch_closed_orderszbitflyer.fetch_closed_orderss4    t{{7F7STTrc|t|jdz|j|}|j|d}||vr||St |jdz|z)a fetches information on an order made by the user https://lightning.bitflyer.com/docs?lang=en#list-orders :param str id: the order id :param str symbol: unified symbol of the market the order was made in :param dict [params]: extra parameters specific to the exchange API endpoint :returns dict: An `order structure ` z( fetchOrder() requires a symbol argumentrz No order found with id )rrrindex_byr)rrrrr ordersByIds r fetch_orderzbitflyer.fetch_ordersj >#DGG.X$XY Y""6*]]640  b> !DGG&@@2EFFrc|t|jdz|j|j|}d|di}|||d<|j |j ||}|j ||||S)a fetch all trades made by the user https://lightning.bitflyer.com/docs?lang=en#list-executions :param str symbol: unified market symbol :param int [since]: the earliest time in ms to fetch trades for :param int [limit]: the maximum number of trades structures to retrieve :param dict [params]: extra parameters specific to the exchange API endpoint :returns Trade[]: a list of `trade structures ` z+ fetchMyTrades() requires a symbol argumentrrrZ)rrrrprivateGetGetexecutionsr%r\r]s rfetch_my_tradeszbitflyer.fetch_my_trades's >#DGG.[$[\ \ V$ F4L   $GG // GV0LM  65%@@rsymbolsc|t|jdz|jd|j|i}|j |j ||}|S)au fetch all open positions https://lightning.bitflyer.com/docs?lang=en#get-open-interest-summary :param str[] symbols: list of unified market symbols :param dict [params]: extra parameters specific to the exchange API endpoint :returns dict[]: a list of `position structure ` zO fetchPositions() requires a `symbols` argument, exactly one symbol in an arrayr)rrr market_idsprivateGetGetpositionsr%)rrrr'rs rfetch_positionszbitflyer.fetch_positionsMsi ?#DGG.$A A  DOOG4 ..t{{7F/KL&rraddressc6|j||j|dk7r(|dk7r#|dk7rt|jdz|zdz|j |}|d|d}|j |j ||}|j||S)a make a withdrawal https://lightning.bitflyer.com/docs?lang=en#withdrawing-funds :param str code: unified currency code :param float amount: the amount to withdraw :param str address: the address to withdraw to :param str tag: :param dict [params]: extra parameters specific to the exchange API endpoint :returns dict: a `transaction structure ` rUSDEURz( allows withdrawing JPY, USD, EUR only, z is not supportedr)rr) check_addressrrrrprivatePostWithdrawr%parse_transaction) rrrrtagrrr'rs rrGzbitflyer.withdrawrs 7#  5=TU]tu}*T TW[ [^q qr r==&%d^  ++DKK,HI %%h99rc|jd}i}||j|}|||d<|j|j||}|j ||||S)a fetch all deposits made to an account https://lightning.bitflyer.com/docs?lang=en#get-crypto-assets-deposit-history :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 ` NrZ)rrprivateGetGetcoininsr%parse_transactionsrrrXrrrr'rs rfetch_depositszbitflyer.fetch_depositssr   }}T*H  $GG ,,T[[&-IJ&&x5%HHrc|jd}i}||j|}|||d<|j|j||}|j ||||S)a. fetch all withdrawals made from an account https://lightning.bitflyer.com/docs?lang=en#get-crypto-assets-transaction-history :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 ` NrZ)rrprivateGetGetcoinoutsr%rrs rfetch_withdrawalszbitflyer.fetch_withdrawalssr   }}T*H  $GG --dkk'6.JK"&&x5%HHrc2ddd}|j|||SNpendingok)PENDINGrtrxrys rparse_deposit_statuszbitflyer.parse_deposit_status&  &&99rc2ddd}|j|||Srrxrys rparse_withdrawal_statusz bitflyer.parse_withdrawal_statusrr transactionrc|j|dd}|j|d}|j|d}|j||}|j|j|d}|j |d}|j|d} |j|d} d} d} d} d |vr`d } |j | } |j|d }|j|d }||j tj||d } nd } |j| } id|d|d| d|d|j|ddd|d|ddddddddd| d|d|d| dddd| dS)Nr message_idrr event_datertx_hashrorQ withdrawaladditional_fee)rrdepositrtxidr,r.network addressTo addressFromrtagTotagFromrrupdated)commentinternalrQ) safe_string_2rrrrcrrr string_addrr)rrrrrrrr,rtxId rawStatusrrorQr additionalFees rrzbitflyer.parse_transactionsH   T< @""; :%%k?C &&z8<NN4#3#3K#NO !!+x8 Y7$$[(;  K D11)->w?Q?QRY[h?i-jkCD..y9F K "  D     Y/  t   w    4  4  T  t  D  f   f! " t# $)  rc|j|j|}d|di}|j|j||}|j ||S)aX fetch the current funding rate https://lightning.bitflyer.com/docs#funding-rate :param str symbol: unified market symbol :param dict [params]: extra parameters specific to the exchange API endpoint :returns dict: a `funding rate structure ` rr)rrpublicGetGetfundingrater%parse_funding_raterGs rfetch_funding_ratezbitflyer.fetch_funding_rate8s` V$ F4L // GV0LM&&x88rc|j|d}|j|}id|d|j|dddddddddddd dd dd dd dd |j|dd|d|j|ddddddddiS)Nnext_funding_rate_settledaterr markPrice indexPrice interestRateestimatedSettlePricer,r. fundingRatefundingTimestampfundingDatetimenextFundingRatecurrent_funding_ratenextFundingTimestampnextFundingDatetimepreviousFundingRatepreviousFundingTimestamppreviousFundingDatetimeinterval)rrrcr)rrrrrs rrzbitflyer.parse_funding_ratePs,#..x9WX#~~.AB H d&&vx8    $  D  #D       4    t  t//:PQ  #$8  "4<<0D#E  "4 '! " &t# $ %  rrnGETcHd|jzdz}|dk(r|dz }||z }|dk(r|r|d|j|zz }|j|jdd}||z} |dk(r|j t |j } dj| ||g} |r|dk7r|j|}| |z } |j| |j|j| |j|jtjd d }| |||d S) Nrrozme/r?rJrHzapplication/json)z ACCESS-KEYzACCESS-TIMESTAMPz ACCESS-SIGNz Content-Type)urlmethodbodyheaders)r urlencodeimplode_hostnamercheck_required_credentialsstrnoncejoinjsonapiKeyhmacencodesecrethashlibsha256) rpathrJrrrrr'baseUrlrrauths rsignz bitflyer.signns& $s* )  u G4 U?3!777'' %(8(@A )   + + - %E77E6734DU?99V,DDLD"kk$)#yyT):DKK bisi3iYi&46602333f3$99v99v6:UW!A3!As!A#!A\`af\g!AF57  ;N >gksu 3 i y RW `c <37r s C 4::**v**X*.Ds[]3cbfglbm4/3TW`bUU3UcUgklqgrU"154VYbdU#USUPSUimnsitU"26bGcG3G&-1tRV_a$Ac$A$AC$AL26b#w#T(^#JDHPR:S:%:#:Wb:>*.Dt\^"I3"Ic"I"Icghsct"IH-1tRV_a$Ic$I$IC$Ifjkvfw$IL::M TM XM Q\M ^6899K90 6 [ <&eBSWP4 # s  c TX `c rr )%ccxt.base.exchangerccxt.abstract.bitflyerrrccxt.base.typesrrrrr r r r r rrrrrrrrrrtypingrccxt.base.errorsrrrrccxt.base.decimal_to_precisionrccxt.base.preciserr rrrsY (.UUUUUU*.**4%xr