ir(ddlmZddlmZddlZddlmZmZmZm Z m Z m Z m Z m Z mZmZmZmZmZmZmZmZmZmZmZmZmZmZddlmZddlmZddlm Z ddlm!Z!dd lm"Z"dd lm#Z#dd lm$Z$dd lm%Z%dd lm&Z&ddl'm(Z(ddl)m*Z*GddeeZ+dS))Exchange) ImplicitAPIN)BalancesCurrencyIntLeverage Leverages MarginModeMarketNumOrder OrderBook OrderRequest OrderSide OrderTypePositionStrStringsTickerTickersTradeTradingFeeInterface Transaction TransferEntry)List) ExchangeError)AuthenticationError)ArgumentsRequired) BadRequest)InsufficientFunds) InvalidOrder)RateLimitExceeded)ExchangeNotAvailable) TICK_SIZE)Precisec eZdZfdZifdeefdZdefdZdifdede de fdZ dJd ede fd Z ifdede fd Zdifd edefd ZdJd edefdZddifdede de deefdZdJd edefdZdddifdede de deefdZdddifdede de fdZdJd efdZifdefdZdZdZdZdJd edefdZ ifde!fdZ"difdede#de$de%de&f d Z'd!Z(dJd ede)fd"Z*difdede#de$de%de&de)f d#Z+ddifdede#de$de&de&f d$Z,difd%edefd&Z-ifd'ee.dee)fd(Z/dddifdede de dee)fd)Z0dddifdede de deefd*Z1dddifd+ede de dee2fd,Z3dddifd+ede de dee2fd-Z4dddifd+ede de fd.Z5dJd/e6de2fd0Z7d1Z8d2Z9dJd/e6fd3Z:d4Z;difdefd5ZdJd/e6fd9Z?ifdede@fd:ZAdifd eedee@fd;ZBdJd efd<ZCdifd eedeDfd=ZEifdedeFfd>ZGdJdeFfd?ZHdifd@e defdAZIdifdede$de)fdBZJdddifdede de dee)fdCZKifdedeLfdDZMdJdeLfdEZNdFZOdGdHiddfdIZPxZQS)Kblofinc|tt|iddddddgddd d d id dd dddddddddddddddddddddddddddddddiddd dd!dd"dd#dd$dd%dd&dd'dd(dd)dd*dd+dd,dd-dd.dd/did0dd1dd2dd3dd4dd5dd6dd7dd8dd9dd:dd;d<d=dd>dd?dd@ddAdidBddCddDddEddFddGddHddIddJddKddLddMddNddOddPddQddRdidSddTddUddVddWddXddYddZdd[dd\dd]dd^dd_dd`ddaddbddcdiddddeddfddgddhddiddjddkddlddmddnddoddpddqddrddsddtddddddddddddu dvdwdxdydzd{d|d}d~dddddddddddddidddddddddddddddddiddddddddddddddddddddddddd dddd|d|ddiddddddidt dt dtdt dt dt dtdt dt dt dt dt dtdtdtdtdtidtdtdtdtdtdtdtdtdtdtdtdtdtdtdtdtdttttt t t ttdÜttdĜdŜddtidtdiddʓdddd͜dddiddddѓddddd՜ddddddٜdUdvdyd|dddyd|dddۜidSddid_ddidddddOdgdddGddidWddidddiddiddidddddddddS)Nidr'nameBloFin countriesUSversionv1 rateLimitdhasCORSspotFmarginswapTfutureoption addMargin borrowMargincancelAllOrders cancelOrder cancelOrderscloseAllPositions closePositioncreateDepositAddresscreateMarketBuyOrderWithCostcreateMarketSellOrderWithCost createOrder createOrders$createOrderWithTakeProfitAndStopLosscreatePostOnlyOrdercreateReduceOnlyOrdercreateStopLimitOrdercreateStopLossOrdercreateStopMarketOrdercreateStopOrdercreateTakeProfitOrder editOrder fetchAccounts fetchBalance fetchBidsAsksfetchBorrowInterestfetchBorrowRateHistoriesfetchBorrowRateHistoryfetchCanceledOrdersfetchClosedOrderfetchClosedOrdersfetchCrossBorrowRatefetchCrossBorrowRatesfetchCurrencies fetchDepositfetchDepositAddressfetchDepositAddressesfetchDepositAddressesByNetwork fetchDepositsfetchDepositsWithdrawalsfetchDepositWithdrawFeeemulatedfetchDepositWithdrawFeesfetchFundingHistoryfetchFundingRatefetchFundingRateHistoryfetchFundingRates fetchGreeksfetchIndexOHLCVfetchIsolatedBorrowRatefetchIsolatedBorrowRatesfetchL3OrderBook fetchLedgerfetchLedgerEntry fetchLeveragefetchLeveragesfetchLeverageTiersfetchMarginModefetchMarginModesfetchMarketLeverageTiers fetchMarketsfetchMarkOHLCVfetchMySettlementHistory fetchMyTrades fetchOHLCVfetchOpenInterestfetchOpenInterestHistoryfetchOpenOrderfetchOpenOrders fetchOrderfetchOrderBookfetchOrderBooks fetchOrdersfetchOrderTradesfetchPermissions fetchPositionfetchPositionsfetchPositionsForSymbolfetchPositionsRiskfetchPremiumIndexOHLCVfetchSettlementHistory fetchStatus fetchTicker fetchTickers fetchTime fetchTradesfetchTradingFeefetchTradingFeesfetchTradingLimitsfetchTransactionFeefetchTransactionFeesfetchTransactions fetchTransferfetchTransfersfetchUnderlyingAssetsfetchVolatilityHistoryfetchWithdrawalfetchWithdrawals) fetchWithdrawalWhitelist reduceMarginrepayCrossMargin setLeverage setMargin setMarginModesetPositionModesignIntransferwithdraw timeframes1m3m5m15m30m1H2H4H6H12H1D1W1M3M)rrrrr1h2h4h6h12h1d1wrrhostnamezwww.blofin.comurlszQhttps://github.com/ccxt/ccxt/assets/43336371/255a7b29-341f-4d20-8342-fbfae4932807restzhttps://openapi.blofin.comz0https://blofin.com/register?referral_code=jBd8U1g?)urldiscountzhttps://www.blofin.comzhttps://blofin.com/docs)logoapireferralwwwdocrget)zmarket/instrumentszmarket/tickersz market/booksz market/tradeszmarket/candleszmarket/mark-pricezmarket/funding-ratezmarket/funding-rate-history)zasset/balancesztrade/orders-pendingztrade/fills-historyzasset/deposit-historyzasset/withdrawal-historyz asset/billszaccount/balancezaccount/positionszaccount/leverage-infozaccount/margin-modezaccount/batch-leverage-infoztrade/orders-tpsl-pendingztrade/orders-historyztrade/orders-tpsl-history) z trade/orderztrade/cancel-orderzaccount/set-leverageztrade/batch-ordersztrade/order-tpslztrade/cancel-batch-ordersztrade/cancel-tpslztrade/close-positionzasset/transfer)rpost)publicprivatefeesz0.00060z0.00020)takermakerrequiredCredentials)apiKeysecretpassword exceptions400401500404405406429152001152002152003152004152005152006152007152008152009150003150004542102002102005102014102015102022102037102038102039102040102047102048102049102050102051102052)102053102054102055102064102065102068103013z1Order failed. Insufficient USDT margin in account)zInternal Server Errorz server error)exactbroadhttpExceptions precisionModeoptionsbrokerIdec6dd3a7dd982d0baccountsByTypefutures)r6r7 accountsById sandboxModedefaultNetworkERC20defaultNetworksBTCTRC20)ETHrUSDTnetworksBitcoinBSC)rBEP20rr 8H)rr8hr5MrrrtimezoneUTCmethodprivateGetAccountPositionsprivatePostTradeOrder!createMarketBuyOrderRequiresPrice defaultTypeprivateGetAssetBillsprivateGetTradeOrdersPending!privatePostTradeCancelBatchOrdersprivateGetTradeOrdersHistory)rpwdSPOTSWAP)r4r6rr )rTrVr exchangeType) deep_extendsuperr'describe parse_numberrrrr"r!r r#r$)self __class__s _/var/www/html/crypto-bot/backend/venv/lib/python3.11/site-packages/ccxt/async_support/blofin.pyr$zblofin.describesq fd 3 3 < < > >JA (JA HJA  $JA  t JA  JA qqq%q q % q % qUqq"5qtqq$Uq q'q/q 0!q"t#qq$%q&7'q(&u)q*(+q,'-q.&t/q0(1q2"53q4(5q6U7q8 9q:;q< =q>&u?q@+EAqB)%CqD&uEqqqF#EGqH$UIqJ'KqL(MqN"5OqPQqR&uSqT(UqV1%WqX YqZ+E[q\*:]q^+E_q`&taqb#Dcqd*4eqf$Ugqqqhuiqj"5kql*5mqn+Eoqp#Eqqrtsqt#Duqv wqx!$yqz%e{q|"4}q~#Eq@+EAqBCqD!%EqF+EGqH IqqqJdKqL$UMqN+EOqP!$QqR"4SqTdUqV!$WqX"5YqZu[q\#D]q^#D_q` aqb!$cqd*5eqf%egqh)%iqj)%kqqqlumqntoqpqqrUsqttuqv"5wqx#Eyqz%e{q|&u}q~'q@$UAqB CqD!%EqF(GqH)%IqJ"5KqL#DMqqN-2 %$)#"!&#( !aqqq JA p qJA P (QJA R k8N $00  SJA j ./*+())**+-./078   +,01/01245'(+,-.12/078560156"()./01./,-56-.01*+  #**kJA @ !..y99!..y99AJA L " $$MJA V +:+.+=+: + : + : +,+j+j+j+j+j+l+l+l+ l!+"l#++$l%+&<'+(l)+*l++,l-+.l/+0l1+2l3+4l5+6l7+8l9+:l;+<l=+>l?+@lA+BlC+DlE++F+**(((+IZU+++Z.B$8[11WJA z +{JA @ YAJA B H.H %'##H v! HuH!'H"" #$$H $"$$ !H,+ """""""" # # --HDEHL!:#MHR6SHT4UUHVWHXvYHZ4 [H`"<$aHfA!gHn<(<& !% #""" !!EHHHCJA J J J returncK||d{V}||dg}||S)a  retrieves data on all markets for blofin :see: https://blofin.com/docs#get-instruments :param dict [params]: extra parameters specific to the exchange API endpoint :returns dict[]: an array of objects representing market data Ndata)publicGetMarketInstruments safe_list parse_markets)r&paramsresponser,s r( fetch_marketszblofin.fetch_marketsfsV88@@@@@@@@~~h33!!$'''r)cH||d}||d}|dk}|dk}|dk}|dk}|p|}||d} ||d} ||d} || } || } || }| d z|z}|r|d z| z}d}d}d}||d }||j|d i}||d }||d}||dd}t j|d}||ddk}|id|d|d| d|d| d| d| d| d|d|d|d|ot j |dd|d|d|d |d|||r| | knd|r| | knd|r||dnd||||| |d ||d!| |d"| d| |d#||d$dd#ddd#ddd#d%|d& S)'NinstIdinstTyper4r7r6r8 baseCurrency quoteCurrency/:tickSizetradingrr maxLeverage1001stateliver)symbolbasequotebaseIdquoteIdsettlesettleIdtyper5active contractValuelistTimelotSize)amountprice)minmaxminSize)leveragerMrNcost) contractlinearinverse contractSizeexpiryexpiryDatetimestrike optionTypecreated precisionlimitsinfo) safe_stringsafe_string_lowersafe_currency_code safe_dict_2r safe_numberr% string_maxsafe_market_structure string_gt safe_integerr%)r&marketr)rHr4r7r6r8rTrDrErGrFrBrCrArX strikePricer[r:rrrr<isActives r( parse_marketzblofin.parse_marketqs   fh / /%%fj99("(">6!!&.99""6?;;##FO<<((22&&v..''00e#  +c\F*F  ##FJ77 4B??  w//  w//&&v}eDD (c:: $$VW55?))2+ "2+ f2+  D2+  U 2+ f 2+ w 2+  f2+  2+  D2+  D2+  f2+  dD 1+s C C2+  D2+  f2+  h2+ U!2+ " U#2+ $!/7Aw(**T/7A(**TIQ[D,,V_EEEW[$!$((<<**69==**844  ,,S11,,[99  ++FI>>    $c2+ 2+ 2+ 2 2 2 r)NrAlimitcK|d{V||}d|di}|dn|}|||d<||||d{V}||dg}||di}||d} |||| S) a( fetches information on open orders with bid(buy) and ask(sell) prices, volumes and other data :see: https://blofin.com/docs#get-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 Nr4r)2sizer,rts) load_marketsripublicGetMarketBooksextendr. safe_dictrhparse_order_book) r&rArmr0rirequestr1r,first timestamps r(fetch_order_bookzblofin.fetch_order_books!!!!!!!!!V$$ fTl }5  #GFO224;;w3O3OPPPPPPPP,~~h33tQ++%%eT22 $$UFI>>>r)ric:||d}||d}|||d}|d}||d}||d}||dd}|r||d nd} ||d } ||d } ||d } |id|d |d||d| d| d||dd||dd||dd||dddd|d|d|dddddddd| | |d |S)!Nrqr4-rAlastopen24hr4FvolCurrency24hvol24hhigh24hlow24hrydatetimehighlowbidbidPrice bidVolumebidSizeaskaskPrice askVolumeaskSizevwapopenclose previousClosechange percentageaverage) baseVolume quoteVolumer_)rhr` safe_market safe_bool safe_tickeriso8601) r&tickerrirymarketIdrAr}rr4rrrrs r( parse_tickerzblofin.parse_tickers;%%fd33 ##FH55!!(FC88!// 22~~ffe44DHRd&&v/?@@@d %%fh77  22vx00! f! !   Y//!  D ! 3 ! 4##FJ77 !  ))&)<<!  4##FJ77!  ))&)<<!  D!  D!  T!  D!  T!  d! $!! " t#! $%&)! ! ! * + r)c^K|d{V||}d|di}||||d{V}||dg}||di}|||S)a fetches a price ticker, a statistical calculation with the information calculated over the past 24 hours for a specific market :see: https://blofin.com/docs#get-tickers :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 ` Nr4r)r,r)rrripublicGetMarketTickersrtr.rur)r&rAr0rirwr1r,rxs r( fetch_tickerzblofin.fetch_tickers!!!!!!!!!V$$ fTl 44T[[&5Q5QRRRRRRRR~~h33tQ++  ///r)symbolscK|d{V||}||d{V}||dg}|||S)a fetches price tickers for multiple markets, statistical information calculated over the past 24 hours for each market :see: https://blofin.com/docs#get-tickers :param str[] [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 ` Nr,)rrmarket_symbolsrr. parse_tickers)r&rr0r1tickerss r( fetch_tickerszblofin.fetch_tickers!s!!!!!!!!!%%g..44V<<<<<<<<..6266!!'7333r)c0||d}||d}|||d}|d}||d}||dd}||dd }||d } ||d } ||d } d} | | |d d} |||||||| dd| ||d| d |S)NtradeIdr4r|rArqrN fillPricerpfillSizesideorderIdfeerFrScurrency) r_ryrrAr)orderrH takerOrMakerrrNrMrSr)r`rrh safe_string_2 safe_trader) r&traderir)rrAryrNrMrrfeeCostrs r( parse_tradezblofin.parse_trade/sM4  eY / /##E844!!(FC88!%%eT22 ""5';??##E6:>>v..""5)44""5%00  "8,C" Y//     r)sincec K|d{Vd}||dd\}}|r#|d||||dddd d{VS||}d|d i}d}|||d <d} ||dd d \} }| d kr/||||d{V}||d g} || |||S)a get the list of most recent trades for a particular symbol :see: https://blofin.com/docs#get-trades :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 :param boolean [params.paginate]: *only applies to publicGetMarketHistoryTrades* default False, when True will automatically paginate by calling self endpoint multiple times :returns Trade[]: a list of `trade structures ` NFrpaginaterafterr1r4r)rmrpublicGetMarketTradesr,)rrhandle_option_and_paramsfetch_paginated_call_cursorrirrtr. parse_trades) r&rArrmr0rrirwr1rr,s r( fetch_tradeszblofin.fetch_tradesis|!!!!!!!!!88PZ[[&  F99-QVX]_egpry{BEFFFFFFFF FV$$ fTl   $GG 66v}hXopp , , ,!77 GV8T8TUUUUUUUUH~~h33  vue<<` 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) :returns dict[]: a list of `funding rate structures ` Nz5 fetchFundingRateHistory() requires a symbol argumentFrerrr4r)rrbeforermr, fundingTimerA fundingRate)r_rArryrry)rr)rrrrrirP!publicGetMarketFundingRateHistoryrtr.rangelenrhappendrdrsort_byfilter_by_symbol_since_limit)r&rArrmr0rrirwr1ratesr,iraterysorteds r(fetch_funding_rate_historyz!blofin.fetch_funding_rate_historys >#DG.e$eff f!!!!!!!!!88AZ\fgg&  @@@AZ\bdikprvx~ V$$ fTl    #EAIq 1 1GH   $GG ?? GU[@\@\]]]]]]]]~~h33q#d))$$  A7D))$ >>I LL *#//mDD& LL33     e[11009I5RWXXXr)c||d}||d}|||}||d}||d}id|d|ddddd |d d dd dd dd||dd|d||d|d|d||ddddddS)NnextFundingTimer4nextFundingRaterr_rA markPrice indexPrice interestRate0estimatedSettlePriceryrrfundingTimestampfundingDatetimenextFundingTimestampnextFundingDatetimepreviousFundingRatepreviousFundingTimestamppreviousFundingDatetime)rhr` safe_symbolrdr%r)r&rTrinextFundingRateTimestamprrArrs r(parse_funding_ratezblofin.parse_funding_ratesz$(#4#4X?P#Q#Q ##Hh77!!(F33**85FGG''-@@  H f    $  D--c22  #D       4++HmDD     t||K88    #$<  "4<<0H#I#I  "4 '! " &t#  r)cK|d{V||}|dst|jdzd|di}||||d{V}||dg}||di}|||S)aT fetch the current funding rate :see: https://blofin.com/docs#get-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 ` Nr6z2 fetchFundingRate() is only valid for swap marketsr4r)r,r) rrrirr)publicGetMarketFundingRatertr.rur)r&rAr0rirwr1r,entrys r(fetch_funding_ratezblofin.fetch_funding_rates!!!!!!!!!V$$f~ `*^ ^__ _ fTl 88Wf9U9UVVVVVVVV"~~h33tQ++&&uf555r)cZ|r||S||SN)parse_funding_balanceparse_trading_balance)r&rHr1s r(parse_balance_by_typezblofin.parse_balance_by_type6s2  8--h77 7--h77 7r)cd|i}||di}||d}||dg}tdt |D]}||}||d}||} |} ||d} ||d} | | 3||d | d <||d | d <n | | d <| | d <| || <||d<|||d<| |S)Nr_r,rqdetailsrrequity availableavailableEquityfreefrozenusedtotalryr) rurhr.rrr`rbaccountr safe_balance) r&r1resultr,ryrrbalance currencyIdcodereqavailEqs r(rzblofin.parse_trading_balance<sd8(#~~h33%%dD11 ..y"55q#g,,'' # #AajG))':>>J**:66DllnnG!!'844B&&w <>J**:66DllnnG#//CCGG "..w DDGFO"..wAAGFO"F4LL  (((r)c $||d||tj||dd|tj||dddddS)NrmakerUrtakerU)r_rArrr tierBased)rr%r% string_negr)r&rris r(parse_trading_feezblofin.parse_trading_fees&&tV44&&w'9$:L:LSRY[c:d:d'e'eff&&w'9$:L:LSRY[c:d:d'e'eff   r)cK|d{V||dd}||ddg}i}d}|h||jdi}||||}||d<||||d{V}n/||||d{V}| ||S)a' query for balance and get the amount of funds available for trading or funds locked in orders :see: https://blofin.com/docs#get-balance :see: https://blofin.com/docs#get-futures-account-balance :param dict [params]: extra parameters specific to the exchange API endpoint :param str [params.accountType]: the type of account to fetch the balance for, either 'funding' or 'futures' or 'copy_trading' or 'earn' :returns dict: a `balance structure ` N accountTyperHr) rrrrrurr`privateGetAssetBalancesrtprivateGetAccountBalancer)r&r0rrwr1rparsedAccountTypes r( fetch_balancezblofin.fetch_balances&!!!!!!!!!((GG 6M6#:;;   "nnT\3CRHHG $ 0 0+{ S S %6GM "!99$++gv:V:VWWWWWWWWHH!::4;;wPV;W;WXXXXXXXXH))+x@@@r)rHrrMrNc V||}|d|||||||jddd}d} |d|d\} }| |d<||dd } |d k} ||dg}| d kp|d k} | o| } | s| rd |d <n||||d<d}|| |dk|\}}|rd|d<||d}||d}||ddg}|du}|du}|s|r|r`| |dd}||||d<||dd}||||d<|r`| |dd}||||d<||dd}||||d<| ||S)Nr)rr)r4r orderTyperprrCcross marginMode timeInForceGTCriIOCiocrrNF post_onlyrHstopLoss takeProfit triggerPrice stopPriceslTriggerPrice-1 slOrderPricetpTriggerPrice tpOrderPrice) riamount_to_precisionr`rhandle_margin_mode_and_paramsrprice_to_precisionhandle_post_onlyrurrt)r&rArHrrMrNr0rirwrr isMarketOrderr marketIOCpostOnlyr!r" isStopLoss isTakeProfitr%r'r(tpPrices r(create_order_requestzblofin.create_order_requestsV$$Tl,,VV<<((zCUVV    !?? vW^__ F * &&v}eDD ( 6M?33e#7"*s  FI F#+GK #66vuEEGG 00 @SU[\\&  *)GFO>>&*55^^FL99 6J #=>>T) !-  S S X!%!3!3Hnk!Z!Z,0,C,CFN,[,[()#//'4HH *.*A*A&,*W*W' S!%!3!3JP[!\!\,0,C,CFN,[,[()**:wEE*.*A*A&'*R*R'{{7F+++r)cBddddddd}||||S)Ncanceledrclosed)r6 order_failedr@partially_filledfilled effectiver`r&statusstatusess r(parse_order_statuszblofin.parse_order_statuss:"& &!   &&999r)c ||dd}||d}||d}||d}||d}||d}d} d} |dkrd } d }n|d krd } d }n |d krd} d }||d} || |}|| |d} ||d} ||dd}||d}|||d}||d}||d}||dd}||d}t j|| }d}|*t j||}t j||}d}|Xt j |}||dd}| |}| ||d}||d}|t|dkrd}| |d }| |d!}| |d"}| |d#}||d$} | d%k}!|id&|d'|d|d(|d)||d*|d+|d,| d-|d.| d/| d|d|d0|d1|d2|d3||||| d||d|!d4 |S)5NtpslIdr createTime updateTimefillTimerrr TrmfokFOKrrr4r| filledSizepxrN averagePricer?rrprRr>rWfeeCcyr r clientOrderIdrr%r'r(r) reduceOnlytruer_r)ryrlastTradeTimestamplastUpdateTimestamprArHrr0stopLossTriggerPricetakeProfitTriggerPrice stopLossPricetakeProfitPrice) rrSrMr: remainingr>rtradesrM)rrhr`rrr@r% string_mul string_div string_absrbr%rrd safe_orderr)"r&rrir)ryrPrOrrHr0rrrAr:rNrr> feeCostStringrMrRrW baseAmountrSr feeCostSigned feeCurrencyIdfeeCurrencyCoderLrQrSrRrT reduceOnlyRawrMs" r( parse_orderzblofin.parse_orders?>  x ; ;%%e\:: "//|DD!..ujAAv..{33 ;  HDD U]]KDD U]]KD##E844!!(F33!!(FC88!!%66""5$88""5.99(()9)9%)I)IJJ((66 !!%00##E:s;;''?? ' f==   %gz::D%dH55D  $#.}==M ,,UHfEEM"55mDDO))-88+C((@@  %C ,>,>,B,B M#//7GHH((?? !%!1!1%9I!J!J**5.AA(( == #v-  E "  ]     Y//  !"4   "#6  f  D  ;    D  U  #$8  %&< ]! " # $$5   6 7 r)cK|d{V||}||dd}||d}d} ||ddd\} }||ddu} ||ddu} | p| } d} |s| d ks| r6|||||||}||d{V} n5|||||||}| |d{V} | | d g}| |d }| ||}||d <||d <|S)aP create a trade order :see: https://blofin.com/docs#place-order :see: https://blofin.com/docs#place-tpsl-order :param str symbol: unified symbol of the market to create an order in :param str type: 'market' or 'limit' or 'post_only' or 'ioc' or 'fok' :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 :param bool [params.reduceOnly]: a mark to reduce the position size for margin, swap and future orders :param bool [params.postOnly]: True to place a post only order :param str [params.marginMode]: 'cross' or 'isolated', default is 'cross' :param float [params.stopLossPrice]: stop loss trigger price(will use privatePostTradeOrderTpsl) :param float [params.takeProfitPrice]: take profit trigger price(will use privatePostTradeOrderTpsl) :param str [param.positionSide]: *stopLossPrice/takeProfitPrice orders only* 'long' or 'short' or 'net' default is 'net' :param str [params.clientOrderId]: a unique id for the order :param dict [params.takeProfit]: *takeProfit object in params* containing the triggerPrice at which the attached take profit order will be triggered :param float [params.takeProfit.triggerPrice]: take profit trigger price :param float [params.takeProfit.price]: take profit order price(if not provided the order will be a market order) :param dict [params.stopLoss]: *stopLoss object in params* containing the triggerPrice at which the attached stop loss order will be triggered :param float [params.stopLoss.triggerPrice]: stop loss trigger price :param float [params.stopLoss.price]: stop loss order price(if not provided the order will be a market order) :returns dict: an `order structure ` NtpslFrCrrrSrTprivatePostTradeOrderTpslr,rrHr) rrrirrrr`create_tpsl_order_requestrdr4rr.rura)r&rArHrrMrNr0rircrisStopLossPriceDefinedisTakeProfitPriceDefined isType2Orderr1 tpslRequestrwr,rxrs r( create_orderzblofin.create_orderVs4!!!!!!!!!V$$~~ffe4466**66v}hXopp!%!1!1&/!J!JRV!V#'#3#3F||| | d<|dkrd| d<n|||| d<| | d<||d d g}|| |S)N positionSidenetr)rr)r4rrlrrprrisolatedzX createTpslOrder() requires a marginMode parameter that must be either cross or isolatedrSrTr%rir&r'r(r)) rir`rr*rr)r,rrt) r&rArHrrMrNr0rirlrwrrSrTs r(rez blofin.create_tpsl_order_requestsV$$''FF Tl(((zCUVV     "66vvFFGFO%%flGDD  Z:%=%=TW(BBCC C((AA **63DEE  $(,(?(? (V(VG$ %x*.''*.*A*A&%*P*P''  ((,(?(?(X(XG$ %x*.''*.*A*A&%*P*P' * 6O5F#GHH{{7F+++r)r)cK|t|jdz|d{V||}d|di}||gdd}||d}|||d<n'|st ||d<nt ||d <||gd }|r6||g||d{V} | | d } | S| | ||d{V} | | d g} | | d } | | |S) a cancels an open order :see: https://blofin.com/docs#cancel-order :see: https://blofin.com/docs#cancel-tpsl-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 :param boolean [params.trigger]: True if cancelling a trigger/conditional order/tp sl orders :returns dict: An `order structure ` Nz) cancelOrder() requires a symbol argumentr4r)stoptriggerrcFrLrrB)rrLrqrrrcrr,)rr)rrri safe_bool_nr`strr cancel_ordersruprivatePostTradeCancelOrderrtr.ra)r&r)rAr0rirw isTriggerrLquery tpslResponserxr1r,rs r( cancel_orderzblofin.cancel_orders >#DG.Y$YZZ Z!!!!!!!!!V$$ fTl $$V-H-H-H%PP ((AA  $'4GO $ $ ,%(WW ""$'GG! &"Y"Y"YZZ  !%!3!3RD&&!I!IIIIIIILNN<33EL99$++gu:U:UVVVVVVVV~~h33tQ''v...r)ordersc K|d{Vg}tdt|D]}||}||d}||d}||d}||d} ||d} ||di} || |} ||||| | | } || | |d{V}| |d g}| |S) as create a list of trade orders :see: https://blofin.com/docs#place-multiple-orders :param Array orders: list of orders to create, each object should contain the parameters required by createOrder, namely symbol, type, side, amount, price and params :returns dict: an `order structure ` NrrArHrrMrNr0r,) rrrrr` safe_valuerurtr4rprivatePostTradeBatchOrdersr. parse_orders)r&r{r0ordersRequestsrrawOrderrrHrrMrN orderParamsextendedParams orderRequestr1r,s r( create_orderszblofin.create_orderssj!!!!!!!!!q#f++&& 0 0AayH''(;;H##Hf55D##Hf55D__Xx88FOOHg66E..8R@@K![[f==N44XtT6SXZhiiL  ! !, / / / /99.IIIIIIII~~h33  &&&r)cK|d{Vd}||dd\}}|r|d||||d{VSi}d}| ||}|d|d<|||d<||gdd}d} ||dd d \} }||gd } d} |s| d kr0|||| d{V} n/|||| d{V} | | d g} | | |||S)ay Fetch orders that are still open :see: https://blofin.com/docs#get-active-orders :see: https://blofin.com/docs#get-active-tpsl-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 :param bool [params.stop]: True if fetching trigger or conditional orders :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 ` NFr|rr)r4rmrqrrrcTPSLrrrrqrrrcr privateGetTradeOrdersTpslPendingr,) rrrfetch_paginated_call_dynamicrirsrrrtrr.r r&rArrmr0rrwriisStoprrxr1r,s r(fetch_open_orderszblofin.fetch_open_orderss!!!!!!!!!88ART^__&  l::;LfV[]bdjkkkkkkkk k   [[((F &t GH   $GG !!&*M*M*MuUU66v?PRZ\z{{ &"O"O"OPP  \f BBB!BB4;;wX]C^C^________HH!>>t{{7TY?Z?Z[[[[[[[[H~~h33  vue<<` NFrwrr)r4endrmr,) rrrrrihandle_until_optionprivateGetTradeFillsHistoryrtr.r) r&rArrmr0rrwrir1r,s r(fetch_my_tradeszblofin.fetch_my_trades sF!!!!!!!!!88R\]]&  j::?FTY[`bhiiiiiiii i   [[((F &t GH 225'6JJ  $GG 99$++gv:V:VWWWWWWWW~~h33  vue<<` NFr^rr)rrrrrmrr,) rrrrrrPrprivateGetAssetDepositHistoryrtr.parse_transactions r&rrrmr0rrwrr1r,s r(fetch_depositszblofin.fetch_deposits(sg!!!!!!!!!88R\]]&  h::?DRWY^`fgggggggg g   }}T**H"*4.GJ    #EAIq 1 1GH   $GG 227GVLL;;DKKQW` NFrrr)rrrrrmrr,) rrrrrrPr privateGetAssetWithdrawalHistoryrtr.rrs r(fetch_withdrawalszblofin.fetch_withdrawalsHsi!!!!!!!!!88ASU_``&  k::;MtUZ\acijjjjjjjj j   }}T**H"*4.GJ    #EAIq 1 1GH   $GG 227GVLL>>t{{7TZ?[?[\\\\\\\\~~h33&&tXueVLLLr)cK|d{Vd}||dd\}}|r|d||||d{VSi}|||d<d}| ||}|d|d<|d||\}}d}||||d{V}||d g} || |||S) a fetch the history of changes, actions done by the user or operations that altered balance of the user :see: https://blofin.com/docs#get-funds-transfer-history :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 str [params.marginMode]: 'cross' or 'isolated' :param int [params.until]: the latest time in ms to fetch entries 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 dict: a `ledger structure ` NFrlrrmr)rrr,) rrrrrrrrtr. parse_ledgerrs r( fetch_ledgerzblofin.fetch_ledgerhsK!!!!!!!!!88PZ[[&  f::=$PUW\^deeeeeeee e   $GG   }}T**H"*4.GJ 225'6JJ224;;w3O3OPPPPPPPP~~h33  x>>>r)rc$d}d}||d}||d}||d}|}||d} |d}|}n|}d}||d} || } ||d} |||d } ||d }||d }||d }||}||d }id|d|d| d| ddddd|d|ddd| d| d| d|ddd|d|d||dd||ddS)N withdrawId depositIdaddresstag withdrawaldepositrrMr?txIdrq feeCurrencyrr_r)network addressFrom addressTotagFromtagTor>rHupdatedtxidryr)rrS)internalcommentr)r`rbrdparse_transaction_statusrhr)r& transactionrrHr) withdrawalIdrrrrrrrMr>rryr^feeCoders r(parse_transactionzblofin.parse_transactionsPH '' \BB $$[+>> $$[)<<   e44  #DBBBD%%k:>> &&z22!!+x88..t/?/? W/U/UVV V44%%k488 ((mDD ))-88"";66 K "    f  t  4     w  t  U  5  f  D  t  D ! "  Y//# $#)    r)c>ddddd}||||S)Npendingokfailed)rr>23r<r=s r(rzblofin.parse_transaction_statuss4    &&999r)c Ldddddddddddd }||||S)Nrrrebater) r>rr4567891011r<)r&rHtypess r(parse_ledger_entry_typezblofin.parse_ledger_entry_typesI   tT222r)c  ||d}||d}||d}||d}|||d}|||d|}||d} || } ||d} d } ||| || ||||| || d S) N transferIdclientId fromAccount toAccountrHrrMrqr) r)r_ryrrrrHrrMrr>)r`rrbr%rhr) r&itemrr) referenceIdrrrHr amountStringrMryr>s r(parse_ledger_entryzblofin.parse_ledger_entrys   dL 1 1&&tZ88 &&t];; $$T;77 ++D,<,> !Jr)cK|t|jdz|d{V||}g}||jdi}||dd}||d|}|||d} |||d} | |gd} | rd }| ||}| Dtd t| D]&} | | | |d d 'td t|D]M} | r%| || |d d )| || |d d NnDtd t| D]&} | |d | | d'd} |d kr| |d{V} n||d{V} || dg}|||dd|S)a cancel multiple orders :see: https://blofin.com/docs#cancel-multiple-orders :param str[] ids: order ids :param str symbol: unified market symbol :param dict [params]: extra parameters specific to the exchange API endpoint :param boolean [params.trigger]: whether the order is a stop/trigger order :returns dict: an list of `order structures ` Nz* cancelOrders() requires a symbol argumentr=rrrLrBrpprivatePostTradeCancelTpslrr))rBr4)rr4)r4rLr,)rr)rrrirurr`rr}rsrrrrrr.r)r&rrAr0rirwr defaultMethodrclientOrderIdstpslIdsrqrr1 ordersDatas r(ruzblofin.cancel_orderss >#DG.Z$Z[[ [!!!!!!!!!V$$..~rBB(((<_`` !!&(MBB(P(PQQ..!B!BCC(C(C(CDD  21F  !..%%C"q#g,,//ANN")!*"(,$$1c#hh''   NN"%a&"(,$$ NN#&q6"(,$$ 1c.1122  $Tl%3A%6   1 1 1!<` Nrr))rrMrrr,) rrrrurr`currency_to_precisionprivatePostAssetTransferrtparse_transfer) r&rrMrrr0rrfromIdtoIdrwr1r,s r(rzblofin.transferRs!!!!!!!!!==&& 6FKK!!.+{KK 9EE 00v>>!    66t{{7F7S7STTTTTTTT~~h33""4222r)c F||d}||dddddddd S)Nr) r_r)ryrrrMrrr>r<)r&rrr)s r(rzblofin.parse_transferlsA   h 5 5   r)cdK|d{V||}d|di}||||d{V}||dg}||d}|dS|||S)a fetch data on a single open contract trade position :see: https://blofin.com/docs#get-positions :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.instType]: MARGIN, SWAP, FUTURES, OPTION :returns dict: a `position structure ` Nr4r)r,r)rrrirrtr.ruparse_position)r&rAr0rirwr1r,positions r(fetch_positionzblofin.fetch_positionzs!!!!!!!!!V$$ fTl 88Wf9U9UVVVVVVVV~~h33>>$**  4""8V444r)c"K|d{V||}||d{V}||dg}||}||d|dS)a fetch data on a single open contract trade position :see: https://blofin.com/docs#get-positions :param str[] [symbols]: list of unified market symbols :param dict [params]: extra parameters specific to the exchange API endpoint :param str [params.instType]: MARGIN, SWAP, FUTURES, OPTION :returns dict: a `position structure ` Nr,rAF)rrrrr.parse_positionsfilter_by_array_positions)r&rr0r1r,rs r(fetch_positionszblofin.fetch_positionss!!!!!!!!!%%g..88@@@@@@@@~~h33%%d++--fhOOOr)c||d}|||}|d}||d}tj|}||d}|dk}||} |8|dkr2tj|drd}ntj|drd}nd}||d } || } ||d } ||d } |d r(tj tj || | } || }||d }d}||d}||d}||d}d}d}|dkr,||d}tj ||}n1|dkr+tj d|}||d}||d}||}tj || }|*|tj || d}n|tj || }d}|tj tj ||dd}||d}||d}|tj |d}| |d}|tj ||d}| id|ddd|d|d |d|d ||d||d!|d"| d | d || d#dd$|d%|d&|d'||d|||||||||||ddd( S))Nr4rA positionsrlrmrlongshortrWr notionalUsdrVrrJ unrealizedPnlrRr initialMarginrnr>r5maintenanceMarginrz0.00005liquidationPriceunrealizedPnlRatior=rDr_r)notional entryPricer contracts lastPricerhedgedryr) rPrmaintenanceMarginPercentage collateralrinitialMarginPercentagerR marginRatiorSrT)r`rr%rYr%rg string_ltrdnumber_to_stringrXrW string_addrh safe_positionr) r&rrirrApos contractsAbsrrrrWcontractSizeStringmarkPriceStringnotionalStringrrinitialMarginStringentryPriceStringunrealizedPnlStringleverageStringrcollateralStringmaintenanceMarginStringr!maintenanceMarginPercentageStringrounderrrpercentageStringrryrs r(rzblofin.parse_positions5##Hh77!!(F33!x55)#.. .99%%l33 ?u}}$S#.. !DD&sC00 "DDD''?? !22<@@**8[AA))(MBB )  w$/0B?VXf,g,g) " *&*&7&78JK^`npq8r8r&s&s # # (")"45Ln"]"] &*&7&78J7K]^BILJLJLOQR9S9S'T'T#++H6HII++H6JKK&&w'9:JE'R'RSS %%h == ''(:;RTdfg(h(hii !!# H# $#  f#   # * #  0 #  $++,<==#  T../BCC#  *#  #  L#  **?;;#  #  D#  f# !# "  Y//## $$(!2+F++,<==!../BCC'+'8'89P'Q'Q)).99&!#7# # #    r)cK|d{V|t|jdzd}|d|\}}|||dd}|dkr|dkrt |jdz||}d}td t|D]?}||}| |}|d kr|d z|d z}4||d z}@||d }| | ||d{V} | | d g} | | |dS)a fetch the set leverage for all contract markets :see: https://docs.blofin.com/index.html#get-multiple-leverage :param str[] symbols: a list of unified market symbols, required on blofin :param dict [params]: extra parameters specific to the exchange API endpoint :param str [params.marginMode]: 'cross' or 'isolated' :returns dict: a list of `leverage structures ` Nz- fetchLeverages() requires a symbols argumentrorrrnzW fetchLeverages() requires a marginMode parameter that must be either cross or isolatedrrr)r4rr,r4)rrrr)r+r`rrrrri"privateGetAccountBatchLeverageInfortr.parse_leverages) r&rr0rinstIdsrr entryMarketrwr1 leveragess r(fetch_leverageszblofin.fetch_leveragess!!!!!!!!! ?#DG.]$]^^ ^ !??@PRXYY F  ))&,HHJ ' ! ! j(@(@TW(AABB B%%g..q#g,,'' 6 6AAJE++e,,K1uu!C-+d*;;!K$55$  @@WV\A]A]^^^^^^^^NN8VR88 ##IwAAAr)cK|d{Vd}|d|\}}|||dd}|dkr|dkrt|jdz||}|d|d}||||d{V}||d i}| ||S) a fetch the set leverage for a market :see: https://docs.blofin.com/index.html#get-leverage :param str symbol: unified market symbol :param dict [params]: extra parameters specific to the exchange API endpoint :param str [params.marginMode]: 'cross' or 'isolated' :returns dict: a `leverage structure ` NrnrrrnzV fetchLeverage() requires a marginMode parameter that must be either cross or isolatedr)rr,) rrr+r`rr)riprivateGetAccountLeverageInfortruparse_leverage)r&rAr0rrirwr1r,s r(fetch_leveragezblofin.fetch_leverage s'!!!!!!!!! !??QWXX F  ))&,HHJ ' ! ! j(@(@TW'AA AV$$Tl$  ;;DKKQW#DG.Y$YZZ Z qLLhnnTW'\\]] ]!!!!!!!!!V$$ !?? vW^__ F ' ! ! j(@(@TW'}}~~ ~ $Tl   ;;DKKQW` NrLr?rr)rr,)rrrir`r+privatePostTradeClosePositionrtru) r&rArr0rirLrrwr1s r(close_positionzblofin.close_positionms !!!!!!!!!V$$((AA  !??QWY`aa FTl$    $'4GO $;;DKKQW` NFrVrr)r4rmbeginrr|rrr privateGetTradeOrdersTpslHistoryr,) rrrrrirsrr+rtrr.rrs r(fetch_closed_orderszblofin.fetch_closed_orderss!!!!!!!!!88ATV`aa&  n::;NPVX]_dflmmmmmmmm m   [[((F &t GH   $GG   $GG !!&*M*M*MuUU66v?PRZ\z{{ &"O"O"OPP  \"DDD!BB4;;wX]C^C^________HH!>>t{{7TY?Z?Z[[[[[[[[H~~h33  vue<<` Nr,)rrriprivateGetAccountMarginModeruparse_margin_mode)r&rAr0rir1r,s r(fetch_margin_modezblofin.fetch_margin_modes!!!!!!!!!V$$99&AAAAAAAA~~h33%%dF333r)cB||d||ddS)NrAr)r_rArr<)r&rris r(r/zblofin.parse_margin_modes/X&**:|DD   r)c |dS||d} ||d} |jdz|z} | {| dkru||jd| | ||jd| | ||jd| | t | ||d} || d}||d}||d}|l|dkrf||jd|| ||jd|| ||jd|| dS) Nrmsg rrrr,r)r`r)throw_exactly_matched_exceptionrthrow_broadly_matched_exceptionrr.ru)r&httpCodereasonrrheadersbodyr1requestHeaders requestBodyrmessagefeedbackr,rx insideMsg insideCodes r( handle_errorszblofin.handle_errorss  4&11""8U337S=4'    0 01I7T\ ] ] ]  0 01I4QY Z Z Z  0 01I7T\ ] ] ])) )~~h//tQ''$$UE22 %%eV44  !jC&7&7  0 01I:W_ ` ` `  0 01I9V^ _ _ _  0 01I9V^ _ _ _tr)rGETcd|jzdz|||z}||||}||jdd|z} |dkr2||s| d||zz } n0|dkr)|t| } |j |j | | d}d } |d kr8||s"d||z} | | z } || z }n1||s| |}|} d |d <||z| z| z| z} |||| ||jt$j}||d <| |||dS)Nz/api/r8rrr?r)z ACCESS-KEYzACCESS-PASSPHRASEzACCESS-TIMESTAMPz ACCESS-NONCErrBzapplication/jsonz Content-Typez ACCESS-SIGN)rrr:r9)r.implode_paramsrextract_paramsimplode_hostnameris_empty urlencodecheck_required_credentialsrt millisecondsrrjsonstring_to_base64hmacencoderhashlibsha256)r&pathrrr0r9r:rwrxrry sign_bodyurlencodedQueryauth signatures r(signz blofin.signsDL(3.1D1DT61R1RR &$"5"5d";";<<##DIe$4V$<==G (??=='' 3sT^^E2222 I    + + - - -D--//00I"k%)]$- ) G I}}U++/&)DNN5,A,A&AO?*C.G}}U++%99U++D $I*<'V#i/);iGD--dii D8I8I4;;W[WbKcKceles.t.tuuI%.GM "fdwOOOr)r)R__name__ __module__ __qualname__r$rr r2rlrtrrrzrrrrrrrrrlistrrrrrrrrrrrrrrrfloatr r4r@r rarjrerzrrrrrrrrrrrrrrrurrrrrrrr rrrrr%r(r,r r0r/rArW __classcell__)r's@r(r'r's K K K K K Z *, ( (V ( ( ( (M fM M M M ^@DB*?*?S*?*?S\*?*?*?*?X!!6!V!!!!F68000F0000$6:" 4 47 4 4 4 4 488858888t<@d[]===S==bfglbm====<   4    .8<$]ajl!H!H!HC!HWZ!Hquvzq{!H!H!H!HF>BPTcgpr(Y(Ys(Y#(Y]`(Y(Y(Y(YT% % 6% % % % N<>"6"6s"6"6"6"6H888 1)1)1)f)))<   V  ?R     *,AAAAAA0os{}),),3),i),y),Z_),hk),),),),V : : :nnn5nnnn`mqy{///I/Y/X]/fi/AF////bfjx|FH,,,9,I,_b,ru,,,,@9=R#/#/S#/##/#/#/#/JFH''$|*<'DQVK''''059tZ^gi$=$=c$=$=TW$=nrsxny$=$=$=$=L37TX\eg==C=s=RU=lpqvlw====<04$UYbdMMMCMsMimnyizMMMM@37TX\egMMCMsMRUMlpq|l}MMMM@.2SW`b??s?#?S????@R R xR ;R R R R h:::333       2   6:"7I7Is7I7I7I7Irac33333C3TW3gt33334        8:5535h5555*:>bPPT#YPTRZ^PPPP O O vO O O O b:>b.B.BT#Y.BY.B.B.B.B`8:"1"13"1h"1"1"1"1H   x     ?C23<CGr0030i0V[0000<7;\`ik&=&=&=3&=VY&=ptuzp{&=&=&=&=P;=44c44444.  J    @&eBSWPPPPPPPPr)r'), ccxt.async_support.base.exchangerccxt.abstract.blofinrrPccxt.base.typesrrrrr r r r r rrrrrrrrrrrrrtypingrccxt.base.errorsrrrrr r!r"r#ccxt.base.decimal_to_precisionr$ccxt.base.preciser%r'r)r(rfsd 655555,,,,,,yyyyyyyyyyyyyyyyyyyyyyyyyyyyyyyyyyyyyyyyyyyyyyyy******000000......''''''......))))))......111111444444%%%%%%yPyPyPyPyPX{yPyPyPyPyPr)