ihddlZddlmZmZmZddlZddlmZm Z m Z m Z m Z m Z mZddlmZddlmZddlmZddlmZGdd ejjZdS) N) ArrayCacheArrayCacheBySymbolByIdArrayCacheByTimestamp)BalancesIntOrder OrderBookStrTickerTrade)Client)List)AuthenticationError)Precisec eZdZfdZdZd%dZd%dZd%dZdZd%dZ d%d Z d e fd Z ifd e fd ZdZd e fdZd e fdZifded efdZddifdededed eefdZdifdeded efdZdddifdededed eefdZd%dZd%dZd e fdZdddifde deded eefdZ!d e fdZ"dddifde deded ee#fdZ$d e fdZ%d%d Z&d e fd!Z'd e fd"Z(ifd#Z)ifd$Z*xZ+S)&phemexc|tt|ddddddddddddd ddiddidddd d d id S) NTF) ws watchTicker watchTickers watchTrades watchMyTrades watchOrderswatchOrderBook watchOHLCVwatchPositionswatchOrderBookForSymbolswatchTradesForSymbolswatchOHLCVForSymbolsrzwss://testnet-api.phemex.com/wszwss://ws.phemex.com)testapi) tradesLimit OHLCVLimit keepAlivei')hasurlsoptions streaming) deep_extendsuperrdescribe)self __class__s U/var/www/html/crypto-bot/backend/venv/lib/python3.11/site-packages/ccxt/pro/phemex.pyr,zphemex.describesfd 3 3 < < > ># %#!%#"&""&,1).(-";/  $" U9A A    c|dSt|}||j||_|t |SN)rsumdecimalsreducestr)r-enscaleprecises r/from_enzphemex.from_en4sL :4"++88G$4e<<7||r0Ncb|||S||||dS)N priceScaler: safe_integer)r-epmarkets r/from_epzphemex.from_ep<4 JFNI||B 1 1&, G GHHHr0cb|||S||||dS)N valueScaler=)r-evr@s r/from_evzphemex.from_evArBr0cb|||S||||dS)N ratioScaler=)r-err@s r/from_erzphemex.from_erFrBr0cz|||jddd}||jd<|S)N requestIdr)r3r>r()r-rLs r/ request_idzphemex.request_idKs;HHT..t|[!LLaPP $- [!r0c ||d}|||}|d}||dd}|||d|}||}||||d|}||||d|} d} d} d} ||||d|} || }| ||tj|| } |tj tj || d} |tj tjtj || d d } id|d|d | |d ||||d |d ||||d |ddddddddddd|d|d|ddd| d| d| | ||d}|S)Nsymbol timestampư>closeturnovervolumeopen21100datetimehighlowbid bidVolumeask askVolumevwaplast previousClosechange percentageaverage baseVolume quoteVolumeinfo) safe_string safe_marketsafe_integer_productrA parse_numberrF omit_zeror string_sub string_div string_add string_muliso8601)r-tickerr@marketIdrPrQ lastStringrbrirhrdrerf openStringrVresults r/parse_swap_tickerzphemex.parse_swap_tickerPsD"##FH55!!(F33!--fk8LL \\$"2"267"C"CVLL   ,,'' T5E5Efj5Y5Y[a(b(bcc &&t||D4D4DVX4V4VX^'_'_``  ^^DLL1A1A&&1Q1QSY$Z$Z[[   ,,  ")?&&w'9*j'Q'QRRF''(:7;MjZd;e;egj(k(kllG**7+=g>PQXQcdnpzQ{Q{~A?B?BDI,J,JKKJ f    Y//  D%%dll43C3CFF3S3SU[&\&\]]  4$$T\\$2B2B652Q2QSY%Z%Z[[  4     4    D  D  T  D  T  f *! " w# $%&)   , r0c \||d}|||}|d}|||d|}||}||||d|}||||d|}d} d} d} ||||d|} || } | ||t j|| } |t jt j || d} |t j t jt j|| dd } id|d dd dd ||||d |d||||d|ddddddddddd| d|d|ddd| d| d| |||d}|S)NrrPrMrWrXrYrQrZr[r\r]r^r_r`rarVrSrbrcrdrerfrg) rkrlrArnrFrorrprqrrrs)r-rur@rvrPrwrbrirhrdrerfrxrVrys r/parse_perpetual_tickerzphemex.parse_perpetual_tickers"##FA..!!(F33!\\$"2"261"="=vFF   ,,'' T5E5Efa5P5PRX(Y(YZZ &&t||D4D4DVQ4O4OQW'X'XYY  ^^DLL1A1A&!1L1Lf$U$UVV   ,,  ")?&&w'9*j'Q'QRRF''(:7;MjZd;e;egj(k(kllG**7+=g>PQXQcdnpzQ{Q{~A?B?BDI,J,JKKJ f     D%%dll43C3CFA3N3NPV&W&WXX  4$$T\\$2B2B612M2Mv%V%VWW  4     4    D  D  T  D  T  f *! " w# $%&)   , r0clientcg}d|vr?||d}|||nd|vr?||d}|||nid|vre||dg}t dt |D]0}||||1t dt |D]k}||}|d}d|z}||dd} | |d<|| |d <||j |<| ||ldS) N market24hspot_market24hdatarrPticker:rQrRrZ) safe_valueappendrz parse_tickerrangelenrrmrttickersresolve) r-rmessagerrurirP messageHashrQs r/ handle_tickerzphemex.handle_tickersX ' ! !__Wk::F NN411&99 : : : :  ( (__W.>??F NN4,,V44 5 5 5 5 w  ??7FB77D1c$ii(( E Et::47CCDDDDq#g,,'' 0 0AQZFH%F#f,K11';QQI"+F; !%i!8!8F: #)DL NN6; / / / / 0 0r0returncK|d{Vd}|dd|\}}||ddk}d}|rd|zn||z}||||d{VS)a :see: https://github.com/phemex/phemex-api-docs/blob/master/Public-Hedged-Perpetual-API.md#subscribe-account-order-position-aop :see: https://github.com/phemex/phemex-api-docs/blob/master/Public-Contract-API-en.md#subscribe-account-order-position-aop :see: https://github.com/phemex/phemex-api-docs/blob/master/Public-Spot-API-en.md#subscribe-wallet-order-messages watch 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 :param str [params.settle]: set to USDT to use hedged perpetual api :returns dict: a `balance structure ` N watchBalancesettleUSDT:balance perpetual) load_marketshandle_market_type_and_paramsrksubscribe_private)r-paramstypeusePerpetualApirs r/ watch_balancezphemex.watch_balance$s!!!!!!!!!99.$PVWW f**68<<F 3BZkK//{HZ ++D+vFFFFFFFFFr0c||jd<tdt|D]}}||}||d}||}||j|i}||dd} |} ||d} | p||d} | B||d} | |d d }tj | |} | | | } ||d }|-| |d d }| || }| | d<|| d<| |j|<| |j|_|dz}||j|dS)NrjrcurrencyrDtotalUsedBalanceRvtotalUsedBalanceEvlockedTradingBalanceEvlockedWithdrawEvlockedWithdrawRvaccountBalanceRvaccountBalanceEv balanceEvusedtotalr)balancerrrksafe_currency_coder currenciesr>account safe_string_2rrrr: safe_balancer)r-rrrrr currencyIdcoderr8rrusedEvrrrtotalEvrs r/handle_balancezphemex.handle_balance6sV ' Vq#g,,'' ; ;AajG))':>>J**:66DtbAAH%%h a@@EllnnG##G-ABBD|))'3GHH>-1-=-=gG_-`-`*'+'9'9'CUWi'j'j$$/0FHXYYF||FE22$$W.@AAE},,W6H+VV We44"GFO$GG !(DL ,,T\::DLLZ' t|[11111r0c"d}||d}||}|d}|dz|z}||j|}|5||jdd} t | }||j|<||ddg} || |} tdt| D]} | | | | ||dS) NtraderP:r#r"tradestrades_pr) rkrlrrr>r(r safe_value_2 parse_tradesrrrr) r-rrnamervr@rPrstoredlimitrparsedrs r/ handle_tradeszphemex.handle_trades|s6##GX66!!(++!Sj6) f55 >%%dlM4HHE&&F"(DK ""7Hj"EE""6622q#f++&& % %A MM&) $ $ $ $v{+++++r0c||d}||}|d}||ddg}||dg}||d}||} | d| zdz|z} |||} ||j|i|j|<||j|| } | ;||jdd } t| } | |j|| <tdt| D]}| |}| | | | | dSdS) NrPklinekline_prrMkline:rr$r")rkrlrrfind_timeframe parse_ohlcvsohlcvsr>r(rrrrr)r-rrrvr@rPcandlesfirstinterval timeframerrrrrcandles r/ handle_ohlcvzphemex.handle_ohlcvs@##GX66!!(++!##GWiDDB//##E1--''11  "Y.4v=K&&w77F"&//$+vr"J"JDK __T[%8)DDF~))$, dKK.u5517 F#I.1c&kk** & & f%%%% NN6; / / / / / ! r0rPcK|d{V||}|d}|d}|ddk}d}|r|rdnd}|jd d }|}|d z} d |z} | |gd } || |} ||| | | d{VS)a :see: https://github.com/phemex/phemex-api-docs/blob/master/Public-Hedged-Perpetual-API.md#subscribe-24-hours-ticker :see: https://github.com/phemex/phemex-api-docs/blob/master/Public-Contract-API-en.md#subscribe-24-hours-ticker :see: https://github.com/phemex/phemex-api-docs/blob/master/Public-Spot-API-en.md#subscribe-24-hours-ticker watches 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 ` NrPswaprrrperp_market24h_pack_prr!r .subscribermethodidr)rr@r'rNr*watch) r-rPrr@isSwap settleIsUSDTrurlrLsubscriptionHashr subscriberequests r/ watch_tickerzphemex.watch_tickers !!!!!!!!!V$$!h'61   L.:K** Dit$OO%% ,.&( &  ""9f55ZZ[';KLLLLLLLLLr0sincercK|d{V||}|d}|jdd}|}|d}|ddk} |r| rdnd } d |z} | d z} | ||d gd } || |}||| || d{V}|jr|||}||||ddS)a' :see: https://github.com/phemex/phemex-api-docs/blob/master/Public-Hedged-Perpetual-API.md#subscribe-trade :see: https://github.com/phemex/phemex-api-docs/blob/master/Public-Contract-API-en.md#subscribe-trade :see: https://github.com/phemex/phemex-api-docs/blob/master/Public-Spot-API-en.md#subscribe-trade 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 dict[]: a list of `trade structures ` NrPr!rrrrtrade_prztrade:rrrrQT) rr@r'rNr*r newUpdatesgetLimitfilter_by_since_limit)r-rPrrrr@rrLrrrrrrrrs r/ watch_tradeszphemex.watch_tradess=!!!!!!!!!V$$!it$OO%% h'61 #B Byy7'  $t   ""9f55zz#{G[IIIIIIII ? 3OOFE22E))&% TRRRr0cK|d{V||}|d}|jdd}|}|d}|ddk}|r|rdnd } d |z} | d z} | ||d gd } || |} ||| | | d{V}|S)a :see: https://github.com/phemex/phemex-api-docs/blob/master/Public-Spot-API-en.md#subscribe-orderbook :see: https://github.com/phemex/phemex-api-docs/blob/master/Public-Hedged-Perpetual-API.md#subscribe-orderbook-for-new-model :see: https://github.com/phemex/phemex-api-docs/blob/master/Public-Contract-API-en.md#subscribe-30-levels-orderbook :see: https://github.com/phemex/phemex-api-docs/blob/master/Public-Contract-API-en.md#subscribe-full-orderbook watches 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 NrPr!rrrr orderbook_p orderbookz orderbook:rrr)rr@r'rNr*rr)r-rPrrr@rrLrrrrrrrrs r/watch_order_bookzphemex.watch_order_books!!!!!!!!!V$$!it$OO%% h'61 !'JLJ}}{"V+  $t   ""9f55**S+w LLLLLLLL    r01mc<K|d{V||}|d}|jdd}|}|d} |ddk} | r| rdnd } d |zd z|z} | d z} | ||d ||j|gd}|||}||| || d{V}|jr| ||}| |||ddS)a :see: https://github.com/phemex/phemex-api-docs/blob/master/Public-Hedged-Perpetual-API.md#subscribe-kline :see: https://github.com/phemex/phemex-api-docs/blob/master/Public-Contract-API-en.md#subscribe-kline :see: https://github.com/phemex/phemex-api-docs/blob/master/Public-Spot-API-en.md#subscribe-kline watches 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 NrPr!rrrrrrrrrrrrT) rr@r'rNr> timeframesr*rrrr)r-rPrrrrr@rrLrrrrrrrohlcvs r/ watch_ohlcvzphemex.watch_ohlcv>s\!!!!!!!!!V$$!it$OO%% h'61 #B Byy7*S069  $t !!$/9==  ""9f55jjk7KHHHHHHHH ? 2NN6511E))%q$GGGr0c`||dd|}||dS)NrrM)custom_parse_bid_ask storeArray)r-booksidedeltar@bidAsks r/custom_handle_deltazphemex.custom_handle_deltacs5**5!Q??F#####r0ctdt|D]}||||| dS)Nr)rrr)r-rdeltasr@rs r/custom_handle_deltaszphemex.custom_handle_deltasgsNq#f++&& B BA  $ $Xvay& A A A A B Br0c ||d}||}|d}||d}||d}d}|dz|z} ||d} ||dd} |d krq||d d i} || || d d dd|} | | d<|| |}||j|<||| dS| |j|}|||d d i}| |d g}| |d g}| |d ||| |d ||| |d<| |d<| | |d<||j|<||| dSdS)NrPrdepthrrsequencerQrRsnapshotbookrbidsasksrrMnoncerZ) rkrlr>rmrcustom_parse_order_book order_book orderbooksrrrrt)r-rrrvr@rPrrrrrrQrrrchangesrrs r/handle_order_bookzphemex.handle_order_bookksX##GX66!!(++!00!!'733Sj6) !!':66--g{HMM :  $$WfmRHHD33D&)VU[]^`acijjH %HW %88I&/DOF # NN9k 2 2 2 2 2@@I$++GV]BOOw;;w;;)))F*;T6JJJ)))F*;T6JJJ%* '")2 +&(, Y(?(? *%*3'y+66666%$r0cK|d{Vd}d}d}|N||}|d}||dz}|ddkr||}d|d<|d||\}}|&||d}|dkr|dzn||z}||||d{V} |jr| ||}|| |||dS) a watches information on multiple trades made by the user :param str symbol: unified market symbol of the market trades were made in :param int [since]: the earliest time in ms to fetch trades for :param int [limit]: the maximum number of trade structures to retrieve :param dict [params]: extra parameters specific to the exchange API endpoint :returns dict[]: a list of [trade structures]{@link https://docs.ccxt.com/#/?id=trade-structure Nztrades:rPrrrrT rr@extendrrkrrrfilter_by_symbol_since_limit) r-rPrrrr@rrrrs r/watch_my_tradeszphemex.watch_my_tradessN!!!!!!!!!  [[((FH%F%x(88Kh6))V,,#)x 99/6SYZZ f >%%fh77F:@F:J:J;44R]`dRdK--dKHHHHHHHH ? 3OOFE22E00tTTTr0cd}t|}|dkrdS|j}|+||jdd}t |}i}d}t dt|D]} || } || d} || } || } | | | d}|| ddkrdn| d }d ||<t| }t dt|D](} || } |d z| z}| ||)|d z|z}| ||dS) Nrrr#r"rPrrrrTr) rmyTradesr>r(rrrkrl parse_traderlistkeysr)r-rrchannel tradesLength cachedTradesr marketIdsrrrawTradervr@rrPrhashrs r/handle_my_tradeszphemex.handle_my_tradess|7|| 1   F}  %%dlM4HHE1%88L q#g,,'' % %AqzH''(;;H%%h//F%%h//F    ' ' 'H%F|'-h'76'A'A{{v $If  INN$$%%q#d))$$ / /A!WFS=6)D NN< . . . .md* |[11111r0cK|d{Vd}d}d}|N||}|d}||dz}|ddkr||}d|d<|d||\}}||ddk}| |r|dzn||z}||||d{V} |jr| ||}|| |||dS) a watches 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 dict[]: a list of `order structures ` Norders:rPrrrrTr ) r-rPrrrrr@r isUSDTSettledorderss r/ watch_orderszphemex.watch_ordersMsM!!!!!!!!!   [[((FH%F%x(88Kh6))V,,#)x 99-QWXX f((::fD >:Gb;44{]aOaK--dKHHHHHHHH ? 3OOFE22E00tTTTr0cjg}g}d|vsd|vsd|vr||dg}||dg}|||}t|}|dkrdS||dg}tdt|D]4} || } || } || 5ntdt|D]g} || } || d} | | dkr|| || } || h|||| |j dd}i}|j t||_ d}|j }tdt|D][} || }|||d }| |}||d d k}|rd n|d }d||<\t|}tdt|D](} d|| z}||j |)d|z}||j |dS)NclosedfillsrVractionCancel ordersLimitr"rPrrrrTr)r array_concatrr parse_orderrrkparse_ws_swap_orderrr>r(rrr@rrr)r-rrr parsedOrdersrrVr ordersLengthrrawOrder parsedOrderupdater!rrrrrrPr@isUsdtrcurrentMessageHashrs r/ handle_orderszphemex.handle_ordersjs~   W%7%7Vw=N=N__Wh;;F??7FB77D&&tV44Fv;;Lq  __Wgr::F1c&kk** 1 1!!9"..x88 ##K0000 1 1c'll++ 1 1 ))&(;;&Vx-?-?MM&)))"66v>> ##K0000 ff---!!$, tDD ; 077DKq#l++,, % %A!!_F MM& ! ! !H%F[[((F|)V3&,@{{&. $If  INN$$%%q#d))$$ < rErCs r/r&zphemex.parse_ws_swap_order8s#v  eY / /(( ::  %C ,>,>,B,B M##E844!!(F33!(()9)9%)M)MNN%%eV44""4#3#3E9#E#EFF   4<<@P@PQVXa@b@bdj3k3kll!!%44!!%22$$UK88 --e^XNN |T\\$BRBRSXZfBgBgio5p5pqq!66u>NPXYY  " "!% ..t/?/?}/U/UVV $$UH55 4' E "  ]   Y//    !"4   f  D  ;    D  U    I  f f! " # $-   . / r0c||d}||jvr'|j|}|j|=|dur|||dS||dd}d|vsd|vs|ddkr|||dSd |vsd |vr|||dSd |vsd |vr|||dSd |vsd|vr|||dSd|vsd|vr.||ddi}|||d|vsd|vsd|vr@d|vrdnd}d|vrd}| |gdg}| |||dSdS)NrTrrrrrrrrrrrrorders_paccounts accounts_pwalletsrspotr)rVrWrX) rk subscriptionsfindrrrrrr. safe_value_nr) r-rrrr methodNamerrrVs r/handle_messagezphemex.handle_messages @  gt , , % % %)"-F$R(T!!vw'''%%gx<< 7 " "(8G(C(CYpIqIquvIvIv   vw / / / F'!!zW'<'<   vw / / / F  i7&:&:   fg . . . F]g%=%=  " "67 3 3 3 F   Z7%:%:&&w*bIIF   vv . . . ' ! !|w'>'>IQXDXDX(G3366&Dw&&"((2W2W2WY[\\H   fh 7 7 7 7 7 EYDXr0cJ||d}||d}d}|dkr|||dSt|jdz||z}|||||jvr |j|=dSdS)NryrK authenticatedsuccess )rrkrrrjsonrejectrZ)r-rrryrKrerrors r/handle_authenticatezphemex.handle_authenticate`s(33!!&(33% Y   NN7K 0 0 0 0 0'#  '8J8J(JKKE MM% - - -f222(55532r0cK|d{V|d{V|jdd}|}||dddk}||d}d}|dkrd}|rd }||gd }|||}|||||d{VS) Nr!rrrTrz aop.subscriberYz wo.subscribezaop_p.subscribe)rrr)r authenticater'secondsromitr r) r-rrrrrLrrrs r/rzphemex.subscribe_privateus !!!!!!!!!!!!!!!!!!it$LLNN "==G 68,,! 6>>$G  ('G   ++gv..ZZ['7CCCCCCCCCr0cK||jdd}||}|}d}||j|}| ||jdd}||z}|j t|z} | | | | |j tj} d} | d|j | |g|d} t|} || |}||jvr|j|j| <|||||d{V}||j|<|S) Nr!rr`expiresxz user.authAPI)rrr)check_required_credentialsr'rrNrrZr>r(riapiKeyr6hmacencodesecrethashlibsha256r rfr)r-rrrrLrfuture expiryDelta expirationpayload signaturerrrrs r/rhzphemex.authenticatesy '')))it$S!!OO%% % !5{CC >++DL)SIIK+5JkC OO3G $++g"6"6 DK8P8PRYR`aaI F  $+y*EG #9~~ kk'622G6#7779=9Q$%56::c;MMMMMMMMF06F  - r0r2),__name__ __module__ __qualname__r,r:rArFrJrNrzrr rrrrrrr6r rrrr rr rrrrrrr r rrrr.r&r^rfrrh __classcell__)r.s@r/rrs2      DIIII IIII IIII  8888t7777r_0F_0_0_0_0B*,GGGGGG$D2D2D2L),F),),),),V30630303030j68MMMFMMMM<<@d[]!S!S!SS!S!Sbfglbm!S!S!S!SF@DB!!S!!S\!!!!B8<$]ajl#H#H#HC#HWZ#Hquvzq{#H#H#H#HJ$$$$BBBBH7H7H7H7H7T37TX\egUUCUsURUUlpqvlwUUUU:y2vy2y2y2y2v04$UYbdUUUCUsUimnsitUUUU:L1FL1L1L1L1\hhhhT|8V|8|8|8|8|6&6666*ACDDDD()+r0r)ccxt.async_supportccxt ccxt.async_support.base.ws.cacherrrrtccxt.base.typesrrrr r r r !ccxt.async_support.base.ws.clientr typingrccxt.base.errorsrccxt.base.preciser async_supportrr0r/rs ffffffffffOOOOOOOOOOOOOOOOOO444444000000%%%%%%QQQQQT  &QQQQQr0