i\ ddlZddlmZmZmZmZddlZddlm Z m Z m Z m Z m Z mZmZmZmZmZddlmZddlmZddlmZddlmZddlmZGd d ejjZdS) N) ArrayCacheArrayCacheBySymbolByIdArrayCacheBySymbolBySideArrayCacheByTimestamp) BalancesIntOrder OrderBookPositionStrStringsTickerTickersTrade)Client)List) ExchangeError)AuthenticationError)RateLimitExceededc ^eZdZfdZifdedefdZdifdedefdZ de fd Z ifde fd Z de fd Zde fd Zddifded ededeefdZifdZde fdZdddifded ededeefdZdZdddifded ededeefdZde fdZdddifded ededeefdZde fdZdifdededefdZ difdeededefdZ!ddifdeed ededeefdZ"dddifded ededee#fdZ$de fdZ%ifdZ&de fdZ'de fd Z(de fd!Z)de fd"Z*de fd#Z+xZ,S)$bitmexc|tt|ddddddddddddd ddiddiddddd did tid id S) NT) ws watchBalance watchMyTrades watchOHLCVwatchOrderBookwatchOrderBookForSymbols watchOrders watchPostions watchTicker watchTickers watchTradeswatchTradesForSymbolsrz$wss://ws.testnet.bitmex.com/realtimezwss://ws.bitmex.com/realtime)testapi orderBookL2)watchOrderBookLevel tradesLimit OHLCVLimitzRate limit exceeded)exactbroad)hasurlsoptions exceptions) deep_extendsuperrdescriber)self __class__s U/var/www/html/crypto-bot/backend/venv/lib/python3.11/site-packages/ccxt/pro/bitmex.pyr4zbitmex.describesfd 3 3 < < > > $!%""&,0#!%# $#)-   @8 (5#" ./@?(A (A ( ( ( symbolreturncK|d{V||}||g|d{V}||S)a 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 ` N) load_marketsr9 watch_tickers)r5r9paramstickerss r7 watch_tickerzbitmex.watch_ticker>sp!!!!!!!!!V$$**F8V<<<<<<<<vr8NsymbolscK|d{V||dd}d}|jdd}g}g}|{tdt |D]\}||}||} |dz| dz} || d |z} || ]n*|||d d |d } ||||| ||d{V} |j ri}| || d <|S| |j d |S)a watches a price ticker, a statistical calculation with the information calculated over the past 24 hours for all markets of a specific list :param str[] symbols: 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 ` NT instrumentr&rr:idticker: alltickers subscribeopargsr9) r<market_symbolsr/rangelenmarketappendwatch_multipleextend newUpdatesfilter_by_arrayr?)r5rAr>nameurl messageHashesrawSubscriptionsir9rO subscription messageHashrequesttickerresults r7r=zbitmex.watch_tickersJs!!!!!!!!!%%gtT::it$   1c'll++ 2 2 V,,#czF4L8  '' 555'&0 $$[1111  2  # #D ) ) )   . . .$  **3 t{{7TZ?[?[]mnnnnnnnn ? F'-F6(# $M##DL(GDDDr8clientc||dg}i}tdt|D]}||}||d}||}||jvr|i|j|<||} ||j|| } | ||<| |j|<d|z} || | || d|S)Ndatarr9rFrG) safe_listrMrN safe_string safe_symbolr? parse_tickerr2resolve) r5r_messagerar?rYupdatemarketIdr9 updatedTickerfullParsedTickerr[s r7 handle_tickerzbitmex.handle_tickermsF~~gvr22q#d))$$ ; ;A!WF''99H%%h//Fdl**'+'8'8'<'< V$ --f55M#// V0DmTT .GFO#3DL #f,K NN+[ 9 9 9 NN+\ : : : :r8cK|d{V|d{Vd}|jdd}d|gd}|||||||d{VS)a 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 :returns dict: a `balance structure ` Nmarginr&rrHrI)r< authenticater/watchrR)r5r>r[rVr\s r7 watch_balancezbitmex.watch_balanceas !!!!!!!!!!!!!!!!!! it$   ZZ[$++gv2N2NP[\\\\\\\\\r8c||d}||}||j||_||d}||j|dS)Nratable) safe_value parse_balancerRbalancercrf)r5r_rgrarvr[s r7handle_balancezbitmex.handle_balancesssFw//$$T**{{4<99 &&w88 t|[11111r8cd}||dg}||d}t|}t dt |D]}||}||} | d} |dz| z} |||| } ||j| } | 5| |j dd}t|} | |j| <t dt | D]}| | || | | dS)Ntraderar9rrDr*r()rtgroup_bylistkeysrMrN safe_market parse_tradestrades safe_integerr0rrPrf)r5r_rgrsradataByMarketIds marketIdsrYrirOr9r[rstoredlimitjs r7 handle_tradeszbitmex.handle_tradess]xw33--h77--//00 q#i..)) 0 0A |H%%h//FH%F#+.K&&x'@&IIF__T[&99F~))$, tLL#E**&, F#1c&kk** ) ) fQi(((( NN6; / / / / 0 0r8sincercDK||g|||d{VS)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 dict[]: a list of `trade structures ` N)watch_trades_for_symbols)r5r9rrr>s r7 watch_tradeszbitmex.watch_trades+s622F8UE6RRRRRRRRRr8cPK|jdd}||}d}||}||j|}|||}dt|z}|| || |j tj } d|j || gd} || |} |||| ||d{VS)Nr&r authenticatedz GET/realtimeauthKeyExpiresrI)r/r_futurert subscriptionscheck_required_credentials millisecondsstrhmacencodesecrethashlibsha256apiKeyrRrp) r5r>rVr_r[rr timestamppayload signaturer\rgs r7rozbitmex.authenticate6sit$S!!% {++( > >||||||r8c6||dd}d}|r2||j|}|ddSt ||}|||||jvr |j|=dSdS)NsuccessFrT) safe_boolrtfuturesrfrjsonrejectr)r5r_rgrr[rerrors r7handle_authentication_messagez$bitmex.handle_authentication_messageMsw 5AA %  6__V^[AAF NN4 ' '(:(:;;E MM% - - -f222(55532r8cK|d{V|d{Vd}d}||sdd|z}|jdd}d|gd }|||||d{V} |jr| S||j|||d S) ag :see: https://www.bitmex.com/app/wsAPI watch all open positions :param str[]|None symbols: list of unified market symbols :param dict params: extra parameters specific to the exchange API endpoint :returns dict[]: a list of `position structure ` Nposition positions::,r&rrHrIT) r<rois_emptyjoinr/rprSfilter_by_symbols_since_limitr) r5rArrr>subscriptionHashr[rVr\ newPositionss r7watch_positionszbitmex.watch_positionsZs !!!!!!!!!!!!!!!!!!%! }}W%% 3'!2!22Kit$    "ZZ['CSTTTTTTTT ?  11$.'5RWY]^^^r8c|jt|_|j}||dg}g}tdt |D]I}||}||}||||J||d} tdt | D]}| |} | d} | d} | d} | |d| d}| |s| || | |d dS) Nrarz positions::rrr9Fr) rrrtrMrNparse_positionrPfind_message_hashessplitrTrrf)r5r_rgcache rawPositionsrrY rawPositionrrWr[parts symbolsStringrArs r7handle_positionszbitmex.handle_positionstslj > !577DNw;;  q#l++,, # #A&q/K**;77H    ) ) ) LL " " " "00GG q#m,,-- 7 7A'*K%%d++E!!HM#))#..G,,\8WeTTI==++ 7y+666|[11111r8cK|d{V|d{Vd}|}|}|||}|d|zz }|jdd}d|gd} |||| |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 ` NorderrDr&rrHrITr<ror9r/rprSgetLimitfilter_by_symbol_since_limit) r5r9rrr>rUrr[rVr\orderss r7 watch_orderszbitmex.watch_orderss!!!!!!!!!!!!!!!!!!  [[((F 3< 'Kit$    zz#{G=MNNNNNNNN ? 3OOFE22E00tTTTr8c8||dg}d}t|}|dkrh|j0||jdd}t ||_|j}i}t d|D]} || } || d} ||j| } | } | | | d| } | | }| ||d}d ||<| |j|t|}t dt|D]-} || }| |j|d z|z,dSdS) Nrarr ordersLimitr(orderIDinfor9TrD)rtrNrrr0rrMrchashmaprR parse_orderrPrfr{r|)r5r_rgrar[ dataLengthrrrArY currentOrderorderId previousOrderrawOrderrr9r|s r7 handle_orderszbitmex.handle_orders;slw33 YY >>{"))$, tLL4U;; [FG1j)) ' '#Aw **<CC $ H H ' ,#{{=+@,OOH((22 e$$$x"& NN4; 4 4 4 ''D1c$ii(( H Hat{K#,=,FGGGG+ >& H Hr8cK|d{V|d{Vd}|}|}|||}|d|zz }|jdd}d|gd} |||| |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 N executionrDr&rrHrITr) r5r9rrr>rUrr[rVr\rs r7watch_my_tradeszbitmex.watch_my_tradess!!!!!!!!!!!!!!!!!!  [[((F 3< 'Kit$    zz#{G=MNNNNNNNN ? 3OOFE22E00tTTTr8c||d}||dg}||d}||dg}||}|j0||jdd}t||_|j} i} tdt|D],} || } | d} | | | | | <-t|}|dkr| | |t| }tdt|D]$}| | |d z||z%dS) NrsraexecTyperr*r(rr9rD)rcrtrzr~myTradesrr0rrMrNrPrfr{r|)r5r_rgr[radataByExecType rawTradesrrrrArryr9 numTradesr|rYs r7handle_my_tradeszbitmex.handle_my_trades st&&w88 w33tZ88OONGR@@ ""9-- = %%dlM4HHE2599DMq#f++&& $ $A1IE8_F MM% #GFOOKK q== NN6; / / /GLLNN##q#d))$$ @ @A NN6;#4tAw#> ? ? ? ? @ @r8cBK||g||d{VS)a 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 N)watch_order_book_for_symbols)r5r9rr>s r7watch_order_bookzbitmex.watch_order_bookYs466xOOOOOOOOOr8cKd}|||jdd}n)|dkrd}n |dkrd}nt|jdz|d{V||}g}g}t d t|D]_}||}||} |d z| d z} | | |d z|z} | | `|j d d } d|d} | | || | ||d{V}| S)a watches information on open orders with bid(buy) and ask(sell) prices, volumes and other data :param str[] symbols: unified array of symbols :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 Nr)r'orderBookL2_25 orderBookL10zK watchOrderBookForSymbols limit argument must be None(L2), 25(L2) or 10(L3)rrDrEr&rrHrI)rcr0rrEr<rLrMrNrOrPr/rQr2r)r5rArr>rstopicsrWrYr9rOtopicr[rVr\ orderbooks r7rz#bitmex.watch_order_book_for_symbolscs =$$T\3H-XXEE b[[$EE b[["EE*w wxx x!!!!!!!!!%%g.. q#g,,'' . .AQZF[[((FCK&,.E MM% #+.K   - - - -it$  --c=$BRBRSZ\bBcBcekllllllll    r8cK|d{V||dd}d}g}g}tdt|D]_}||} || } |dz| dz} || |dz| z} || `|jdd} d |d }|| |||||d{V}|j rB| |d}| |d }| ||}| |||d d S)a get the list of most recent trades for a list of symbols :param str[] symbols: 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 ` NFryrrDrEr&rrHrIr9rT)r<rLrMrNrOrPr/rQr2rSrtrcrfilter_by_since_limit)r5rArrr>rsrrWrYr9rOrr[rVr\rfirst tradeSymbols r7rzbitmex.watch_trades_for_symbolss!!!!!!!!!%%gtU;; q#g,,'' . .AQZF[[((FCK&,.E MM% #+.K   - - - -it$  **3 t?O?OPWY_?`?`bhiiiiiiii ? 8OOFA..E**5(;;KOOK77E))&% TRRRr81mcK|d{V||}|d}d||j||z}|dz|dz}|jdd} d|gd } || ||| ||d{V} |jr| ||}| | ||d d S) aQ 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 Nr9tradeBinrDrEr&rrHrIrT) r<rOrc timeframesr/rprRrSrr) r5r9 timeframerrr>rOrsr[rVr\ohlcvs r7 watch_ohlcvzbitmex.watch_ohlcvs!!!!!!!!!V$$!T--doy)TTTckF4L0 it$   jjk4;;w3O3OQ\]]]]]]]] ? 2NN6511E))%q$GGGr8c ||d}|dd}||}||}||dg}i}t dt |D]m} || } || d} || } | d} |dz| dz}||| d |d zz d| | d | | d | | d | | dg}||j | i|j | <||j | |}|;| |j dd }t|}||j | |<|||||<ot|}t dt |D]&} || }||||'dS)Nrsrrarr9rDrErr(highlowclosevolumer+)rcreplacefind_timeframeparse_timeframertrMrNr} parse8601 safe_floatohlcvsrr0rrPr{r|rf)r5r_rgrsintervalrdurationcandlesresultsrYcandlerirOr9r[r^rrrWs r7 handle_ohlcvzbitmex.handle_ohlcvsKD  '22==R00''11 '' 22//'6266q#g,,'' * *AQZF''99H%%h//FH%F#+t 4Kt// DDEESWW//..0011 F#'//$+vr"J"JDK __T[%8)DDF~))$, dKK.u5517 F#I. MM& ! ! !#)GK W\\^^,, q#m,,-- > >A'*K NN7;/ = = = = > >r8cK|d{Vd}|jdd}|||d{VS)N heartbeatr&r)r<r/rp)r5r>eventrVs r7watch_heartbeatzbitmex.watch_heartbeat&sf!!!!!!!!!it$ZZU+++++++++r8c ||d}||d}||dg}|dkr||di}||d}||}|d} |dkr||j| <nI|dkr|id |j| <n$|d kr|id |j| <|j| } | | d<t d t |D]} ||| d } || ||| d} ||| d}||| d}|dkrdnd}| |}| | | |||| d}| || d<|| d<|dz| z}| | |dSi}t d t |D]Z} ||| d}||vrd ||<| |d||<||}|d} |j| } | || d } |dkrd n0|| ||| dd} ||| d}||| d}|dkrdnd}| |}| | | |||| d}| || d<|| d<\t|}t d t |D]R} || }||}|d} |dz| z}|j| } | | |SdS)Nactionrsrapartialfilterr9r'rr orderBook10rrpricesizerEsideBuybidsasksrdatetimerDrdelete0)rcrtr}indexed_order_book orderbooksrMrNrconvertFromRawQuantitystorerrfsum safe_numberr{r|)r5r_rgrrsrarrirOr9rrYrr rEr booksiderr[numUpdatesByMarketIdrs r7handle_order_bookzbitmex.handle_order_book,sd!!'844  '22w33 Y  __Wh;;Fvx88H%%h//FH%F %%*.*A*A*C*C''****.*A*A"b*I*I''-''*.*A*A"b*I*I'/I"(Ih 1c$ii(( 1 1Q992264;K;KDQRGU[;\;\]]%%d1gt44''Q88"&%--vvf$T?udB///++DG[AA)-)A)A +&(0 *%%#+.K NN9k 2 2 2 2 2#% 1c$ii(( 1 1??47H== $88856(215:NPQ1R1R$X.))(33) OF3 ((a'::#x//qqd6Q6QRXZ^ZjZjkopqkrtz|[A[A7B7B%%d1gt44''Q88"&%--vvf$T?udB///++DG[AA)-)A)A +&(0 *%%1668899I1c)nn-- 7 7$Q<))(33)#ckF2  OF3 y+6666  7 7r8c|SNr5r_rgs r7handle_system_statuszbitmex.handle_system_statuss r8c|Srrrs r7handle_subscription_statusz!bitmex.handle_subscription_statuss r8c||d}|||di}||dg}t|}|dkrn|d}|jdd}|||} d} | t |} n|| |} || |dSdS) Nrr\rKrrr-FT)rcrtrNr1find_broadly_matched_keyrr) r5r_rgrr\rKnumArgsr[r-broadKey exceptions r7handle_error_messagezbitmex.handle_error_messages"  '22  oogy"==G??7FB77D$iiG{{"1g -g688FF # -e 4 4II /h 6 6I i555utr8c|||r||d}|j|j|j|j|j|j|j|j|j|j|j|j|j d }| ||}|M| |di}| |d}|dkr| ||dSdS|||dSdS)Nrs) r'rrrCry tradeBin1m tradeBin5m tradeBin1h tradeBin1drrrnrr\rJr) r&rcrrlrrrrrwrrtr)r5r_rgrsmethodsmethodr\rJs r7handle_messagezbitmex.handle_messages"F  $ $VW 5 5 ($$Wg66E#5"&"8#5"0+"/"/"/"/+!2- 1G__We44F~//'9bAA__Wd33)))66vwGGGGG*)vw'''''1 ( (r8)-__name__ __module__ __qualname__r4rrr@r rr=rrlrrqrwrrrrrrorr rrr r rrrrr rrrr{rrrrrr r&r. __classcell__)r6s@r7rrs) ) ) ) ) V68   F    6:"!E!E7!E!E!E!E!EFrFrrrrh*,]]]]]]$g2Vg2g2g2g2RM0FM0M0M0M0^<@d[] S S SS S Sbfglbm S S S S)+. 6F 6 6 6 68<$]ajl__W_C_WZ_quv~q____4h2h2h2T04$UYbdUUUCUsUimnsitUUUU:oHFoHoHoHoHb37TX\egUUCUsURUUlpqvlwUUUU:N@vN@N@N@N@`@DBPPSPPS\PPPPSW_a"!"!$s)"!C"!fo"!"!"!"!HOSaenpSSd3iSS[^SuyzvASSSSB8<$]ajlHHHCHWZHquvzq{HHHH6a>6a>a>a>a>F,.,,,, k7k7k7k7k7Z6 !6!!!!F;(V;(;(;(;(;(;(;(;(r8r)ccxt.async_supportccxt ccxt.async_support.base.ws.cacherrrrrccxt.base.typesrrr r r r r rrr!ccxt.async_support.base.ws.clientrtypingrccxt.base.errorsrrr async_supportrrr8r7r;sJ AAAAAAAAAAAAkkkkkkkkkkkkkkkkkkkkkkkk444444******000000......@(@(@(@(@(T  &@(@(@(@(@(r8