iWhddlmZddlmZddlZddlmZmZmZm Z m Z m Z m Z m Z mZmZmZmZmZmZmZmZmZddlmZddlmZddlmZddlmZdd lmZdd lmZdd lmZdd lm Z dd lm!Z!ddlm"Z"ddlm#Z#ddlm$Z$ddlm%Z%ddlm&Z&ddlm'Z'ddl(m)Z)ddl(m*Z*ddl+m,Z,GddeeZ-dS))Exchange) ImplicitAPIN)AccountBalances CurrenciesCurrencyIntMarketNumOrder OrderBook OrderSide OrderTypeStrStringsTickerTickersTrade Transaction)List) ExchangeError)AuthenticationError)PermissionDenied)ArgumentsRequired) BadRequest) BadSymbol)InsufficientFunds) InvalidOrder) OrderNotFound) NotSupported) NetworkError)ExchangeNotAvailable) OnMaintenance)RequestTimeout)TRUNCATE) TICK_SIZE)Precisec eZdZfdZifdZdifdefdZifdefdZdifde fd Z d Z ifd e e fd ZdAd e d efdZdifdeded efdZifded efdZdifded efdZdAd e d efdZdddifdede dedefdZdddifde dedefdZddifdededed e efdZdAd e d efdZdddifdededed e efdZifd e efdZ ifd e!fdZ"d e#fdZ$ifd e#fdZ%dddifde dedefd Z&difdede fd!Z'dddifde deded e e(fd"Z)dddifde deded e e(fd#Z*dddifde dedefd$Z+dddifde deded e e(fd%Z,dddifde dedefd&Z-d'Z.dAd e d e(fd(Z/ifded)e0fd*Z1difded+e2d,e3d-e0d.e4f d/Z5difdede fd0Z6difde fd1Z7difde fd2Z8dAd3Z9d4Z:dAd5e;fd6Zdddifd7e deded e e=fd9Z?dAd5e;d e=fd:Z@d;ZAdifd7ed-e0fd<ZBd=d>iddfd?ZCd@ZDxZES)Bhuobijpc|tt|iddddddgddd |jd d d d ddddddidddddddd dd dd dddddddddd dd d dd!d d"d d#d d$did%dd&dd'dd(d d)d d*dd+d d,d d-d d.d d/d d0dd1d d2dd3dd4dd5ddddd dddddddd6 d7d8d9d:d;dd?d@dAdB dCdDdEdEdEdEdEdFdGdHdIdJdKdLdMdNdNdOiidPdNdQdNdRdNdSdNdTdUdVdNdWdXdYdUdZdNd[dNd\dNd]dNd^dNd_dNd`dNdadNdbdNdNdNdNdNdNdNdNdUdUdNdNdc idddNdTdUdedUdfdNdgdNdhdNdidNdjdNdkdNdldNdmdNdndNdodNdpdNdqdNdrdNdsdNdNdNdUdUdtdudvdwdMdNdNdNdNdNdNdNdNdxidMdNdNdNdNdNdyiidzdXd{dXd|dNd}d~ddNddNddNddddddddddddNddNddNddXddXdNdNdNdNdtdNdNdidddNddNddddXddXddddXddddNddNddtddtddtddtddNddNddNdNdNdtddwddddMd d|d|ddidt dttdidtdtdtdtdtdtdtdtdtdtdtdtdtdtdtdtdtttttt t tt t tttd ddddddddddddddddddddidɜ ddddddddќiS)Nidr)namez Huobi Japan countriesJP rateLimitd userAgentchrome39 certifiedFversionv1hostnamezapi-cloud.bittrade.co.jpproThasCORSspotmarginswapfutureoptioncancelAllOrders cancelOrder cancelOrderscreateMarketBuyOrderWithCostcreateMarketOrderWithCostcreateMarketSellOrderWithCost createOrdercreateStopLimitOrdercreateStopMarketOrdercreateStopOrder fetchAccounts fetchBalancefetchClosedOrdersfetchCurrenciesfetchDepositAddressfetchDepositAddressesByNetwork fetchDepositsfetchFundingHistoryfetchFundingRatefetchFundingRateHistoryfetchFundingRatesfetchIndexOHLCV fetchMarketsfetchMarkOHLCV fetchMyTrades fetchOHLCVfetchOpenOrders fetchOrder) fetchOrderBook fetchOrdersfetchOrderTradesfetchPremiumIndexOHLCV fetchTicker fetchTickers fetchTime fetchTradesfetchTradingLimitsfetchWithdrawalswithdraw timeframes1min5min15min30min60min4hour1day1week1mon1year) 1m5m15m30m1h4h1d1w1M1yurlszchttps://user-images.githubusercontent.com/1294454/85734211-85755480-b705-11ea-8b35-0b7f1db33a2f.jpgzhttps://{hostname})marketpublicprivatev2Public v2Privatezhttps://www.huobi.co.jpz3https://www.huobi.co.jp/register/?invite_code=znnq3zhttps://api-doc.huobi.co.jpz#https://www.huobi.co.jp/support/fee)logoapiwwwreferraldocfeesrget)zreference/currenciesz market-statuszaccount/ledgerzaccount/withdraw/quotazaccount/withdraw/addresszaccount/deposit/addresszaccount/repaymentzreference/transact-fee-ratezaccount/asset-valuationg?z point/accountzsub-user/user-listzsub-user/user-statezsub-user/account-listzsub-user/deposit-addresszsub-user/query-depositz user/api-keyzuser/uidzalgo-orders/openingzalgo-orders/history) zalgo-orders/specificz c2c/offers c2c/offerzc2c/transactions c2c/repaymentz c2c/accountz etp/referencezetp/transactionszetp/transactionz etp/rebalancez etp/limitzaccount/transferzpoint/transferzsub-user/managementzsub-user/creationzsub-user/tradable-marketzsub-user/transferabilityzsub-user/api-key-generationzsub-user/api-key-modificationzsub-user/api-key-deletionzsub-user/deduct-modez algo-orderszalgo-orders/cancel-all-afterzalgo-orders/cancellationrzc2c/cancellationzc2c/cancel-all 2)rz c2c/transferz etp/creationzetp/redemptionzetp/{transactId}/cancelzetp/batch-cancel)rpost)z history/klinez detail/mergeddepthtradez history/tradedetailtickersetp)zcommon/symbolszcommon/currencyszcommon/timestampzcommon/exchangezsettings/currencyszaccount/accountszaccount/accounts/{id}/balancezaccount/accounts/{sub-uid}zaccount/historyzcross-margin/loan-infozmargin/loan-infozfee/fee-rate/getzorder/openOrdersg?z order/orderszorder/orders/{id}zorder/orders/{id}/matchresultszorder/orders/getClientOrderz order/historyzorder/matchresultszquery/deposit-withdrawzmargin/loan-orderszmargin/accounts/balance)zcross-margin/loan-orderszcross-margin/accounts/balancezpoints/actionsz points/orderszsubuser/aggregate-balancezstable-coin/exchange_ratezstable-coin/quotezfutures/transferzorder/batch-orderszorder/orders/placez$order/orders/submitCancelClientOrderz"order/orders/batchCancelOpenOrderszorder/orders/{id}/submitcancelzorder/orders/batchcancelzdw/withdraw/api/createzdw/withdraw-virtual/{id}/cancelzdw/transfer-in/marginzdw/transfer-out/marginz margin/orderszmargin/orders/{id}/repayzcross-margin/transfer-inzcross-margin/transfer-outzcross-margin/orders)zcross-margin/orders/{id}/repayzstable-coin/exchangezsubuser/transfer)rrr|r}r~rtrading0.002)feeSide tierBased percentagemakertaker precisionMode exceptions)zTcontract is restricted of closing positions on API. Please contact customer servicemaintainz bad-requestzbase-date-limit-errorzapi-not-support-temp-addrtimeoutzgateway-internal-errorz)account-frozen-balance-insufficient-errorzinvalid-amountz!order-limitorder-amount-min-errorz!order-limitorder-amount-max-errorz"order-marketorder-amount-min-errorz order-limitorder-price-min-errorz order-limitorder-price-max-errorzorder-holding-limit-failedz order-orderprice-precision-errorzorder-etp-nav-price-max-errorzorder-orderstate-errorzorder-queryorder-invalid) zorder-update-errorzapi-signature-check-failedzapi-signature-not-validzbase-record-invalidzbase-symbol-trade-disabledzbase-symbol-errorzsystem-maintenancezinvalid symbolzsymbol trade not open nowzinvalid-addresszbase-currency-chain-errorzdw-insufficient-balance)broadexactoptionsERC20erc20trc20hrc20algo)ETHTRXHRC20HECOHTALGOOMNIprivate_get_order_ordersfetch_open_orders_v1publicGetCommonSymbols"privateGetAccountAccountsIdBalanceprivatePostOrderOrdersPlacezen-US AA03022abc) defaultNetworknetworksfetchOrdersByStatesMethodfetchOpenOrdersMethod!createMarketBuyOrderRequiresPricefetchMarketsMethodfetchBalanceMethodcreateOrderMethodlanguagebrokercommonCurrenciesThemiszGame.comHitChainPentaz Super Bitcoinz Bitcoin File)GETGTCHITPNTSBTCBIFI) deep_extendsuperr)describe userAgents parse_numberr&r#rrr$r"rrrrr)self __class__s R/var/www/html/crypto-bot/backend/venv/lib/python3.11/site-packages/ccxt/huobijp.pyrzhuobijp.describe s gt 4 4 = = ? ?yB )yB MyB  $yB   yB 4 yB  yB  tyB  2yB  4yB  ...$. . % . % ."4.t../.,U.0.t.'.(. "5!." #..$%.&$T'.("4).*&u+.,1%-.. /.0&u1.2#E3.4*55.6$U7.8"59.:;.<!%=.> ?.@dA.B"4C.DdE..F#'#$(*/# $!#&*$( [...yB r   syB J }223 4!5 1Q4=  KyB f 01)*(!0!3A21  ,Q  6q 23(-a.q03A1!'#A .q!".q#$12&'%&,-)*'()*,-+,)*%&9<*A+Q)!.q  ,Q  3A 3A6q84Q/&q73A$Q +A!")!#$*+()()*+35,./?88t)*)*!"!")*"##$    *+,-,-+,./ *C75a*1  1!  +A +A+C',S9#6s(-a 1!!$-c%&23'(569:*+)*5756-.58*A*A-c-c  ?  =c 9#3C1!:1 0!"1"#$(%&3B'(3A)*4Q+,.q-.;<01,.3;88kNNgyB D $!&"&!..w77!..w77 EyB V YWyB X ly - !: ,Z 01A  ~  -.B @AR %l 8 8 9, 7  7  1, 7   4\! "-m# $/ % &+?2E/B+82;)2*7&/1:'11;/@?    &&YyB f ")""$#!".H)?59&>&J%B#,'gyB T  !! '&!!U yB yB y y y cX||}||dS)a fetches the current integer timestamp in milliseconds from the exchange server :param dict [params]: extra parameters specific to the exchange API endpoint :returns int: the current integer timestamp in milliseconds from the exchange server data)publicGetCommonTimestamp safe_integerrparamsresponses r fetch_timezhuobijp.fetch_time\s- 0088  6222rNsymbolsc|||j}i}tdt|D]6}||}||||||<7|S)Nr) load_marketsrrangelenfetch_trading_limits_by_id market_id)rrrresultisymbols rfetch_trading_limitszhuobijp.fetch_trading_limitses~  ?lGq#g,,'' ] ]AQZF!<activeonlinecontractlinearzprice-precisionzamount-precisionzvalue-precision)pricerr)rrsuperMaxz min-order-amtz max-order-amtrzmin-order-value)leveragerr r) inverserr contractSizeexpiryexpiryDatetimestrike optionTyperrcreatedr)rgetattrrrr!r+jsonr safe_stringsafe_currency_coder' string_gtrappendparse_precisionr)rrmethodrr numMarketsrrr|rrrrr leverageRatiosuperLeverageRatior;fees r fetch_marketszhuobijp.fetch_marketss 23(74((00B//(FB77\\ >>tw)TTW[W`W`ahWiWiijj jq#g,,''? ? AQZF%%fo>>F&&v/?@@G**622D++G44E$$VW55E ,,V5EsKKM!%!1!1&:WY\!]!] &}c::hg>OPbdg>h>hF-1U]]$##C(((ARARSZA[A[C MM4fw&4$*u,44 4 $ 4 & 474D444&44%4%45H,4 E!4"$#4$  $"&"!..t/C/CDDTDTU[]nDoDo/p/pqq"//0D0DTEUEUV\^pEqEq0r0rss --d.B.B4CSCSTZ\mCnCn.o.opp $0055#00??$($5$56H$I$I!! $//HH#//HH $# $//8IJJ#& g4444 4 4 4 j rr|c>|d|}||d}d}d}d}d}d|vrt|dtr9||dd}||dd}n,||d}||d}d|vrt|dtr9||dd}||dd}n,||d}||d}||d} ||d } ||d } ||d } |id |d |d||d||dd||dd|d|d|d|ddd| d | d| dddddddd| | |d|S)NtsbidrrbidSizeaskaskSizeopencloservolr timestampdatetimehighlow bidVolume askVolumevwaplast previousClosechangeraverage) baseVolume quoteVolumer) safe_symbolr isinstancelistr safe_tickeriso8601) rtickerr|rr,r%r0r'r1r)r*r7r8s r parse_tickerzhuobijp.parse_tickersD!!$//%%fd33   F??&-.. @&&ve}a88 ,,VE]A>> &&vu55 ,,VY?? F??&-.. @&&ve}a88 ,,VE]A>> &&vu55 ,,VY?? //  11%%fh77 &&vu55 ! f! !   Y//!  D$$VV44 ! 4##FE22 ! 3 !  !  3!  !  D!  D!  U!  E!  T!  d! $!! " t#! $%&)! ! ! * + rlimitcn|||}|ddd}||||}d|vr|ds-t |jdz||z||d}||d||d}| |||} ||d| d<| St|jd z||z) a fetches information on open orders with bid(buy) and ask(sell) prices, volumes and other data :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 r+step0)rrtickz+ fetchOrderBook() returned empty response: r$r4noncez2 fetchOrderBook() returned unrecognized response: ) rr|marketGetDepthrrr+rrrparse_order_bookr) rrr@rr|rrrCr,rs rfetch_order_bookzhuobijp.fetch_order_bookfsA V$$Tl  &&t{{7F'C'CDD, X  F# o*W WZ^ZcZcdlZmZm mnnn??8V44D))$d6G6GRV6W6WXXI**4CCF"//i@@F7OMDG&ZZ]a]f]fgo]p]ppqqqrc\|||}d|di}||||}||d|}||d}||d<|||d<|S)a fetches a price ticker, a statistical calculation with the information calculated over the past 24 hours for a specific market :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+rCr$r,r-)rr|marketGetDetailMergedrr?rr=)rrrr|rrr>r,s r fetch_tickerzhuobijp.fetch_tickers V$$ fTl --dkk'6.J.JKK*""8F#3V<<%%h55 '{!\\)44z rc8|||}||}||dg}||d}i}t dt |D]y}|||d}||} | d} | ||| } || d<| || d<| || <z| |d|S)a fetches price tickers for multiple markets, statistical information calculated over the past 24 hours for each market :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 ` rr$rrr,r-) rmarket_symbolsmarketGetTickersrrrrr safe_marketr?r=filter_by_array_tickers) rrrrrr,rrmarketIdr|rr>s r fetch_tickerszhuobijp.fetch_tickerss %%g..((00//(FB77%%h55 q#g,,'' $ $A'' H==H%%h//FH%F&&wqz6::F"+F; !%i!8!8F: #F6NN++FHgFFFrc||d}|||}||dd}||d}||d}||d}|%|d} | d}| d }||d } ||d } ||d d } t j| | } d}||d}|||d}||d}|B|t j|dr+|}|||d}|||d}||dd}||d|}| |||||| |||| | | | |d S)Nrr$ created-atzorder-id directionr-rrroler  filled-amountr filled-feesz fee-currencyz filled-pointsz0.0zfee-deduct-currencyrcurrencyztrade-idtradeIdr+) rr+rorderr,r-rside takerOrMakerr rrr!) rr9safe_integer_2split safe_string_2r' string_mulr string_eq safe_trader=)rrr|rPrr,r\r]r typePartsr^r rrr!feeCost feeCurrency filledPointsr[r+s r parse_tradezhuobijp.parse_trades1B##E844!!(F33''t\BB    33{33v..   3IQ.>un.U.UVV ''??  #W%6w%F%F&"55d6F6FuNc6d6dee  'C$$UJ BB   eT7 3 3" Y//(     rsincec|d|i}||||}||dd||S)a fetch all the trades made from a single order :param str id: order id :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 to retrieve :param dict [params]: extra parameters specific to the exchange API endpoint :returns dict[]: a list of `trade structures ` r+rN)r#privateGetOrderOrdersIdMatchresultsr parse_trades)rr+rrjr@rrrs rfetch_order_tradeszhuobijp.fetch_order_trades se  " ;;DKKQW` Nr+rsizez start-timer)rr|privateGetOrderMatchresultsrrm)rrrjr@rr|rrs rfetch_my_tradeszhuobijp.fetch_my_trades1s   [[((F &t GH   #GFO  $)GL !33DKK4P4PQQ  &!165%HHHric|||}d|di}|t|d|d<||||}||dg}g} t dt|D]p} ||| dg} t dt| D]3} || | |} | | 4q| | d} | | |d||S) a get the list of most recent trades for a particular symbol :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 ` rr+Nrprrr,) rr|rmarketGetHistoryTraderrrrrirsort_byfilter_by_symbol_since_limit)rrrjr@rr|rrrrrtradesjrs r fetch_tradeszhuobijp.fetch_tradesHsN V$$ fTl   !%..GFO--dkk'6.J.JKK2x44q#d))$$ % %A__T!Wfb99F1c&kk** % %((F;; e$$$$ %fk22009I5RWXXXrc ||d||d||d||d||d||dgS)Nr+r)r.r/r*r)safe_timestampr)rohlcvr|s r parse_ohlcvzhuobijp.parse_ohlcv{s   t , ,   UF + +   UF + +   UE * *   UG , ,   UH - -   rrqcz|||}|d||j||d}|t |d|d<||||}||dg} || ||||S)aQ fetches historical candlestick data containing the open, high, low, and close price, and the volume of a market :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 :param dict [params]: extra parameters specific to the exchange API endpoint :returns int[][]: A list of candles ordered, open, high, low, close, volume r+)rperiodNrtrpr) rr|rrfrmarketGetHistoryKliner safe_list parse_ohlcvs) rr timeframerjr@rr|rrrs r fetch_ohlcvzhuobijp.fetch_ohlcvs V$$Tl&&t 9MM    !%..GFO--dkk'6.J.JKK~~h33  vy%GGGrcd|||}|dS)a fetch all the accounts associated with a profile :param dict [params]: extra parameters specific to the exchange API endpoint :returns dict: a dictionary of `account structures ` indexed by the account type r)rprivateGetAccountAccountsrs rfetch_accountszhuobijp.fetch_accountss4 11&99rc~d|jdi}||||}||dg}i}t dt |D]L}||}||d}||} ||d} ||d} ||d} ||dd } ||d }| o | o | o|d ko| }||d }| | ||d }|| d||| | d||dd| |ddd| |dddd|d || <N|S)z fetches all available currencies on an exchange :param dict [params]: extra parameters specific to the exchange API endpoint :returns dict: an associative dictionary of currencies rrrr,zdeposit-enabledzwithdraw-enabledzcountry-disabledvisibleFrr z display-namezwithdraw-precisioncryptoNrzdeposit-min-amountzwithdraw-min-amount)rdepositre) r+coderr,rrrer!rrr) rpublicGetSettingsCurrencysrrrrr safe_boolrrrr)rrrr currenciesrrrZr+rdepositEnabledwithdrawEnabledcountryDisabledrrrr,rs rfetch_currencieszhuobijp.fetch_currenciess  Z0 224;;w3O3OPPR__Xvr:: q#j//**( ( A!!}H622B**2..D!__X7HIIN"ooh8JKKO"ooh8JKKOnnXy%@@G$$Xw77EssOsRZIZsds`sF##Hn==D))$*>*>t?O?OPXZn?o?o*p*pqqI  )+& )# $//:NOO#   $//:OPP#!!  !7F4LL: rc||ddg}d|i}tdt|D]}||}||d}||}d}||vr ||}n|}|ddkr||d|d <|dd kr||d|d <|||<||S) Nrr;rrrZrrbalancefreefrozenused)rrrrraccount safe_balance) rrbalancesrrr currencyIdrrs r parse_balancezhuobijp.parse_balances ??8F#3VR@@(#q#h--(( # #AqkG))':>>J**:66DGv~~ ,,,..v'))"&"2"27I"F"Fv(**"&"2"27I"F"F"F4LL  (((rc|||jd}d|jddi}t |||||}||S)a! query for balance and get the amount of funds available for trading or funds locked in orders :param dict [params]: extra parameters specific to the exchange API endpoint :returns dict: a `balance structure ` rr+r)r load_accountsraccountsrrr)rrrrrs r fetch_balancezhuobijp.fetch_balance/s  23 $-"4( )74((Wf)E)EFF!!(+++rcH|d|i}d}| ||}|d|d<||jdd}t |||||} || d|||S)Nstatesr+rrrr)rr|rrrr parse_orders) rrrrjr@rrr|rrs rfetch_orders_by_stateszhuobijp.fetch_orders_by_states>s  f   [[((F &t GH !!$,0KMghh(74((Wf)E)EFF$  &!165%HHHrc|d|i}||||}||d}||S)a? fetches information on an order made by the user :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 ` r+r)rprivateGetOrderOrdersIdr safe_dict parse_order)rr+rrrrr\s r fetch_orderzhuobijp.fetch_order\sl  " // GV0L0LMMx00&&&rc4|d||||S)a fetches information on multiple orders made by the user :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 ` zGpre-submitted,submitted,partial-filled,filled,partial-canceled,canceledrrrrjr@rs r fetch_orderszhuobijp.fetch_ordersks:**+tv|DFKMSTT Trcr||jdd}t||||||S)a fetch all unfilled currently open 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 ` rr)rrr)rrrjr@rrs rfetch_open_orderszhuobijp.fetch_open_ordersvs?!!$,0GI_``$wtV$$VUE6BBBrcf|t|jdz|d||||S)Nz/ fetchOpenOrdersV1() requires a symbol argumentz&pre-submitted,submitted,partial-filled)rr+rrs rrzhuobijp.fetch_open_orders_v1s> >#DG._$_`` `**+SU[]bdikqrrrrc4|d||||S)a fetches information on multiple closed orders made by the user :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 filled,partial-canceled,canceledrrs rfetch_closed_orderszhuobijp.fetch_closed_orderss$**+MvW\^ceklllrcr|i}d}| ||}|d|d<||d}|l|t dt |jD]5}|j|} | ddkr|| d}|n6||d<|||d<||d} || || } | | dg} | | |||S) Nr+r account-idrrr:rpr) rr|rrrrromitprivateGetOrderOpenOrdersrrr) rrrjr@rrr| accountIdrromittedrrs rfetch_open_orders_v2zhuobijp.fetch_open_orders_v2sM   [[((F &t GH $$V\::      1c$-0011  -*6?f,, $ 0 0$ ? ?I , )   #GFO))FL1111$++gw2O2OPP,~~h33  vue<<K'C E "  ]     Y//  !$   fX&  D  4    D  U    D  t D! " f# $-   . / rrc|||}|dst|jdzd|d<||dd|d|S)a create a market buy order by providing the symbol and cost :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 ` r:z9 createMarketBuyOrderWithCost() supports spot orders onlyFrr|buyN)rr|r r+ create_order)rrrrr|s r!create_market_buy_order_with_costz)huobijp.create_market_buy_order_with_costss V$$f~ ftw)ddee e6;23  5$fMMMrrr]rr c||||}|jdd|d|dz|zd}||dd} | M||jdi} || d} | |z|d<n| |d<| |ddg}|d kr|d krd} d } | |d d d \} }| |d}| |d}|| ||} n| rm|t|jdz||}||}| |t!j||} n| ||} | |d<n| |||d<|dks|dks|dks |dks|dkr||||d<|jd}t'|||||}||d}|id|d|ddddddddd|d|d |d|d|d!dd"dddd#dd$dddd%di|S)&a` create a trade 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 fullfilled, 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 ` rr+rU)rrrrrNrr|rTrErrz createOrder() requires the price argument for market buy orders to calculate the total cost to spend(amount * price), alternatively set the createMarketBuyOrderRequiresPrice option or param to False and pass the cost to spend in the amount argumentrr@iocz limit-makerz stop-limitzstop-limit-fokr rrrr,r-rrrrr]rrrxr!r6)rrr|rrarrruuidrhandle_option_and_paramsramount_to_precisionrr+number_to_stringr'rbprice_to_precisionrrr)rrrr]rr rr|rrrbrokerId quoteAmountrr amountString priceStringrrr+s rrzhuobijp.create_order+s  V$$-*40Tl3J%   **6?DUVV  __T\8R@@F''55H)1DIIKK)?G% & &)6G% &6O5F#GHH H  45==K04 -8<8U8UV\^knQSW9X9X 5 -v##FF33DYYvv..F"66vtDD 2 G=&tw2m(mnnn$(#8#8#@#@L"&"7"7">">K"&":":67CUVbdoCpCp"q"qKK"66vvFF +GH   $ 8 8 H HGH  7??demmt}/D/DP\H\H\`dhx`x`x#66vuEEGG 12(74((Wf)E)EFF   h / / H "      !$  d   f  D  D  U  f  d    D  d 4! " T# $ t%  & ' rc|d|i}||||ddS)a3 cancels an open order :param str id: order id :param str symbol: not used by huobijp cancelOrder() :param dict [params]: extra parameters specific to the exchange API endpoint :returns dict: An `order structure ` r+r)r+r)$privatePostOrderOrdersIdSubmitcancelrr)rr+rrrs r cancel_orderzhuobijp.cancel_orderzsS<` clientOrderIdszclient-order-idsNz order-ids)r safe_value_2r!privatePostOrderOrdersBatchcancelr)ridsrrrrrs r cancel_orderszhuobijp.cancel_orderss **63CEWXX6$46H#IJJ  !#&GK *8G& '99$++gv:V:VWWBrc|i}d}| ||}|d|d<||||}|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 ` Nr+r)rr|+privatePostOrderOrdersBatchCancelOpenOrdersr)rrrrr|rs rcancel_all_orderszhuobijp.cancel_all_ordersss    [[((F &t GH CCDKKPWY_D`D`aarc^||d|j|d|jS)Nrr)rrr)rrr! networkCodes rcurrency_to_precisionzhuobijp.currency_to_precisions,((a1F{1SUYUghhhrct|dz }||}|dkr |d|}i}||||S)Nrrr)rr)r networkIdlastCharacterIndex lastCharacter networksByIds r safe_networkzhuobijp.safe_networksV ^^a/!"45 C  !!$6"67I  iCCCrrZc||d}||d}||d}|||}|||}||d}||di}||d} || ||} || d} |||||| |dS) Naddress addressTagrZchainrr+network)rZrtagrr)r safe_currencyrrindex_by check_address) rdepositAddressrZrrrrrrr networkValuers rparse_deposit_addresszhuobijp.parse_deposit_addresss"">9==~|<<%%njAA %%j(;;&&z8<<$$^W== ??8Z<<}}Xt44 |Y JJ ""<;; 7###"    rrc0||dkrd}|d}|||}ddd}| |d|d<|||d<||||}||d |||S) 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 :returns dict[]: a list of `transaction structures ` Nr0rrrfromr+rZrprrrZprivateGetQueryDepositWithdrawrparse_transactionsrrrjr@rrZrrs rfetch_depositszhuobijp.fetch_depositss =ECKKE   }}T**H    "*4.GJ   #GFO66t{{7F7S7STT&&x'75%PPPrc0||dkrd}|d}|||}ddd}| |d|d<|||d<||||}||d |||S) a fetch all withdrawals made from an account :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 ` Nr0rerrr+rZrprrrs rfetch_withdrawalszhuobijp.fetch_withdrawals#s =ECKKE   }}T**H    "*4.GJ   #GFO66t{{7F7S7STT&&x'75%PPPrcF||d}|||d}||d}|dkrd}||d}|tj|}id|d||dd d ||d d |d ||d||dd||dddddd||dddddd|d||dd|d| ||dd||ddd|| |dddS)NrSrZrre withdrawalr!rr+rtxidztx-hashr,r-rrr addressTo addressFromrz address-tagtagTotagFromrrrupdatedz updated-at)rZrrate)commentinternalr!) rrrr' string_absrar=safe_string_upperrparse_transaction_statusr)r transactionrZr,rrrfs rparse_transactionzhuobijp.parse_transaction>s4V%%k<@@ &&t'7'7 Z'P'PQQ V44 :  D"";66  (11G K $$$[$??  D$$[)<<     Y//  t--k7CC   t'' Y??    4  4##K??  T  t  D  d&&{H==   d33D4D4D[RY4Z4Z[[! " t((lCC# $ ))'22)    rcTdddddddddddddddd}||||S)Nfailedpendingokr)unknown confirming confirmedsafeorphanrr reexaminerejectpassz wallet-rejectz confirm-errorrepealedzwallet-transferz pre-transferrrs rrz huobijp.parse_transaction_statussW #"""%% (%%  (&&999rc|||\}}|||||}|||dd}|||d<||jdi}||d} ||| | } | 9| dkr|d| z|d<n| |dz|d<| |d}| | ||} | | |S) a make a withdrawal :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 ` r+)rrrZNzaddr-tagrrrr) handle_withdraw_tag_and_paramsrrrZlowerrrrsafe_string_lowerrprivatePostDwWithdrawApiCreaterr) rrrrrrrZrrrrs rrezhuobijp.withdrawsS99#vFF V  7###==&& ,,..   ?"%GJ ??4<R@@((;;((7GDD  '!!#+D>G#;  #*Xd^#; YYvy11F66t{{7F7S7STT%%h999rr}rcBd}|dkr||z }n(|dks|dkr ||jz }n|dks|dkr|dz }|d|||zz }||||}|dks|dkrC|||d} d d |j| d } |d kr|| |} | | } | | } d ||j || g} | || ||jt jd}| d| d|izz } |d| zz }|d kr||}ddi}n"ddi}n|r|d| |zz }||jd|d|j i|z}||||dS)Nrr|r}r~rrv2T HmacSHA2562)SignatureMethodSignatureVersion AccessKeyId TimestampPOST base64& Signature?z Content-Typezapplication/jsonz!application/x-www-form-urlencodedrr6)urlrbodyheaders)r4implode_paramsrextract_paramscheck_required_credentialsymdhms millisecondsapiKeyrkeysort urlencodejoinr6hmacencodesecrethashlibsha256rr{)rpathrrrr?r>r=queryr,r requestSortedauthpayload signatures rsignz huobijp.signsj (?? 3JCCXoo3)#3#3 4< CCZSK%7%7 4KC sT((v6666 &$"5"5d";";<< )  sk11  + + - - - D$5$5$7$7==I#/$'#{& G ++gu55 LL11M>>-00DiiT BCCG $++g"6"6 DK8P8PRYR`bjkkI C$..+y)ABBB BD 3: Cyy''"$6 #$G 4sT^^F3333!!$)E"23"7  :   fdwOOOrc |dSd|vr||d} | dkr||d} |jdz|z} ||jd|| ||jd| | ||d} ||jd| | t | dS)Nrerrorzerr-code rrzerr-msg)rr+throw_broadly_matched_exceptionrthrow_exactly_matched_exceptionr)rhttpCodereasonr=rr?r>rrequestHeaders requestBodyrrfeedbackmessages r handle_errorszhuobijp.handle_errorss  4 x  %%h99F  ''*==7S=4/44T_W5MtU]^^^44T_W5MtU]^^^**8Y??44T_W5MwX`aaa#H---tr)N)F__name__ __module__ __qualname__rrrrstrrrrrrr r"rr?r r rGrJrrQrrirnrrrzr;r~rrrrrrrrrrr rrrrrrrfloatrrrr rrrrrrrrrr r rrrerTr` __classcell__)rs@rr)r)sz z z z z x !#33337;2  G    :<PPSPPPP.:>b  3    4xxx$&mm$v,mmmm^OO6OVOOOOb:>b,r,rs,r3,rY,r,r,r,r\02%%3%f%%%%N04BGGWG7GGGG.L L L 5L L L L \9=4^bkmGGSG#GSGX[GGGG"-1tRV_aIIcIICIIII.6:UW1Y1Y31Ys1Y#1Y\`af\g1Y1Y1Y1Yf   4    ,26DW[df H H# Hc HQT Hkoptku H H H HD%'  4=    ')]]Z]]]]~)))))&$& , ,( , , , ,<@daenpIISII[^IIII<26b ' 'c '3 ' ' ' '*.Dt\^ T T3 Tc T Tcghmcn T T T T/3TXac C C C3 Cc Chlmrhs C C C C26DW[dfss3scsQTssss 154VZce m m# mS mPS mjnotju m m m m26DW[df,=,=3,=c,=QT,=,=,=,=\:::PPP5PPPPdRT N N N5 N N N NgksuMM3MiMyMRWM`cMMMM^37r  s C    (04B111111f/32@iiiiDDD  h    8*.Dt\^QQ3QcQQcghsctQQQQ6-1tRV_aQQcQQCQfjkvfwQQQQ6L L xL ;L L L L \:::.?C2&:&:S&:%&:&:&:&:P&eBSW,P,P,P,P\rr)).ccxt.base.exchangerccxt.abstract.huobijprrLccxt.base.typesrrrrr r r r r rrrrrrrrtypingrccxt.base.errorsrrrrrrrrrr r!r"r#r$ccxt.base.decimal_to_precisionr%r&ccxt.base.preciser'r)rrros ('''''------qqqqqqqqqqqqqqqqqqqqqqqqqqqqqqqqqqqqqq******000000------......''''''&&&&&&......))))))******))))))))))))111111******++++++333333444444%%%%%%kkkkkh kkkkkr