ei)ddlZddlmZmZmZddlmZmZm Z m Z m Z m Z m Z mZmZmZddlmZddlmZddlmZGddejjZdS) N) ArrayCacheArrayCacheBySymbolByIdArrayCacheBySymbolBySide) AnyBalancesIntOrder OrderBookPositionStrStringsTickerTrade)Client)List) ExchangeErrorc eZdZdeffd ZdZdefdZdefdZiifde de defd Z iifde d e defd Z d d ifd e de de de efdZdefdZifd e defdZdefdZd ifd e de defdZdefdZdZd d d ifd ede de de efdZdefdZd d d ifd ede de de efdZdefdZifdefdZdefdZ d d d ifde!de de de e"fdZ#defdZ$defd Z%defd!Z&xZ'S)"bullishreturnc|tt|ddddddddddd ddddiddd did dd iii|jd d dS)NTF) ws watchTicker watchTickerswatchOrderBook watchOrders watchTradeswatchPositions watchMyTrades watchBalance watchOHLCVrzwss://api.exchange.bullish.comz:wss://api.exchange.bullish.com/trading-api/v1/private-data)publicprivatez"wss://api.simnext.bullish-test.comz>wss://api.simnext.bullish-test.com/trading-api/v1/private-data)apitestcookiesi)ping keepAlive)hasurlsoptions streaming) deep_extendsuperrdescriber&)self __class__s N/var/www/html/volatility/venv/lib/python3.11/site-packages/ccxt/pro/bullish.pyr.zbullish.describesgt 4 4 = = ? ?# %"&##"&!% $#  "B#_"F#c  r  "A$B $B $ $ $ cz|||jddd}||jd<|S)N requestIdr)sum safe_integerr*)r/r4s r1 request_idzbullish.request_id7s;HHT..t|[!LLaPP $- [!r2clientcTt|}dddi|dS)N2.0command keepalivePingjsonrpctypemethodparamsid)strr8)r/r9rCs r1r&z bullish.ping<s9"" # #%    r2c8||_|S)N) millisecondslastPong)r/r9messages r1 handle_pongzbullish.handle_pongHs++--r2url messageHashcKt|}ddd||d}|jddd|z}|||||||d{VS)Nr;r< subscriber>r#rr!)rDr8r)watchr,)r/rJrKrequestrBrCrHfullUrls r1 watch_publiczbullish.watch_publicWs "" # #!   )E"4(2S8ZZd6F6FwPV6W6WYdeeeeeeeeer2 subscribeHashcNK|jddd}|d{V}d|i}||jdd<t|}ddd||d } ||||| ||d{V} | S) Nr#rr" JWT_COOKIEr%r;r<rMr>)r) handleTokenr*rDr8rNr,) r/rKrRrOrBrJtokenr%rCrHresults r1 watch_privatezbullish.watch_privatecsit$Y/&&(((((((( % )0 T9% "" # #!   zz#{D4D4DWf4U4UWdeeeeeeee r2Nsymbolsincelimitc<K|d{V||}d|dz}d}d|dd}|||||d{V} |jr| ||}|| ||dd S) a` get the list of most recent trades for a particular symbol https://api.exchange.bullish.com/docs/api/rest/trading-api/v2/#overview--unified-anonymous-trades-websocket-unauthenticated :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 ` Ntrades::rYz"/trading-api/v1/market-data/tradesanonymousTradesrCtopicrY timestampT) load_marketsmarketrQ newUpdatesgetLimitfilter_by_since_limit) r/rYrZr[rBrcrKrJrOtradess r1 watch_tradeszbullish.watch_tradesus!!!!!!!!!V$$ 6(#33 2&Tl  ((k7FKKKKKKKK ? 3OOFE22E))&% TRRRr2cp||di}||d}||}||}||dg}|||}||jvr5||jdd} t| } | |j|<|j|} tdt|D]} | || | |j|<d|dz} | | | dS)NdatarYrg tradesLimitrr]) safe_dict safe_string safe_symbolrc safe_list parse_tradesrgr7r*rrangelenappendresolve)r/r9rHrjmarketIdrYrc rawTradesrgr[tradesArrayCache tradesArrayirKs r1 handle_tradeszbullish.handle_tradess72~~gvr22##D(33!!(++V$$NN4266 ""9f55$+%%%%dlM4HHE)%00 "2DK k&) q#f++&& * *A   vay ) ) ) )) F 6(#33 {K00000r2cK|d{V||}|d}|jddddz|dz}d|z}|||||d{VS) a watches a price ticker, a statistical calculation with the information calculated over the past 24 hours for a specific market https://api.exchange.bullish.com/docs/api/rest/trading-api/v2/#overview--anonymous-market-data-price-tick-unauthenticated :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 ` NrYr#rr!z!/trading-api/v1/market-data/tick/rCticker::)rbrcr)rN)r/rYrBrcrJrKs r1 watch_tickerzbullish.watch_tickers!!!!!!!!!V$$!it$X.1TTW]^bWcc 6) ZZ[&+FFFFFFFFFr2c0||dd}||di}||d}||}|d}d}|dkr|||}ne|dkr_||j|i} || di} || |} || |}||j|<d|z} ||j|| dS) Nr@rjrYsnapshotupdateinfor})rnrm safe_market parse_tickertickersextendru) r/r9rH updateTyperjrvrcrYparsedticker rawTickermergedrKs r1 handle_tickerzbullish.handle_tickers Z%%gvr:: ~~gvr22##D(33!!(++! * $ $&&tV44FF 8 # #^^DL&"==Fvvr::I[[D11F&&vv66F% V 6) t|F+[99999r2cK|d{V||}d}d|dz}d|dd}|||||d{V}|S)an watches information on open orders with bid(buy) and ask(sell) prices, volumes and other data https://api.exchange.bullish.com/docs/api/rest/trading-api/v2/#overview--multi-orderbook-websocket-unauthenticated :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 Nz%/trading-api/v1/market-data/orderbook orderbook::rY l2OrderbookrCr_)rbrcrQr[) r/rYr[rBrcrJrKrO orderbooks r1watch_order_bookzbullish.watch_order_books!!!!!!!!!V$$5#fX&66 "Tl  ++CgvNNNNNNNN    r2c||di}||d}||}d|z}||d}||jvr||j|<|j|}|||dg} |||dg} | | d} || ||} ||dg} t| d kr+t| d z }|| || d <| | ||j|<| ||dS) NrjrYrrabidsasks)rrsequenceNumberRangerr5nonce) rmrnror7 orderbooks order_bookseparate_bids_or_asksrpparse_order_bookrsresetru)r/r9rHrjrvrYrKrarrrrrr lastIndexs r1handle_order_bookzbullish.handle_order_books.~~gvr22##D(33!!(++#f, %%dK88 $/))&*oo&7&7DOF #OF+ ))$..vr*J*JKK))$..vr*J*JKK  &&xCC"nnT3H"MM " # #a ' '/0014I"//0CYOOF7O"+y+.....r2cg}tdt|D]R}|dzdkr |||}|||dz}|||gS|S)Nrr5)rrrsrnrt)r/entryrWrzpriceamounts r1rzbullish.separate_bids_or_asksKsq#e**%% + +A1uzz$$UA..E%%eQU33F MM5&/ * * * * r2cK|d{Vd}|}|||}|dz|z}ddi}||d}|||d<||d}|||||d{V} |jr| ||}|| |||dS)a watches information on multiple orders made by the user https://api.exchange.bullish.com/docs/api/rest/trading-api/v2/#overview--private-data-websocket-authenticated :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 :param str [params.tradingAccountId]: the trading account id to fetch entries for :returns dict[]: a list of `order structures ` Norders::r`tradingAccountIdT)rbrYrnomitrXrdrefilter_by_symbol_since_limit) r/rYrZr[rBrRrKrOrrs r1 watch_orderszbullish.watch_ordersXs !!!!!!!!! #  [[((F%,v5K X  ++F4FGG  '*:G& 'YYv'9::F))+}gvVVVVVVVV ? 3OOFE22E00tTTTr2cX||d}g}|dkr-||di}||n||dg}t |dkr1|j0||jdd}t||_|j}i}tdt |D]O} || } | | } || || d} d|| <Pd } | || t| }tdt |D]/} || }| d z|z}| |j|.dSdS) Nr@rrjr ordersLimitrlrYTrr)rnrmrtrprsrr7r*rrr parse_orderrulistkeys)r/r9rHr@ rawOrdersrjr[rsymbolsrzrawOrder parsedOrderrYrKr hashSymbolsymbolMessageHashs r1 handle_orderszbullish.handle_orderswsZ00 8  >>'6266D   T " " " "w;;I y>>A  {"))$, tLL4U;; [FG1c)nn-- ' '$Q<"..x88  k***))+x@@"&"K NN6; / / / ''D1c$ii(( ? ?!!W $/$$6$C!t{,=>>>>%   ? ?r2cK|d{Vd}|}|||}|d|zz }ddi}||d}|||d<||d}|||||d{V} |jr| ||}|| ||ddS) a watches information on multiple trades made by the user https://api.exchange.bullish.com/docs/api/rest/trading-api/v2/#overview--private-data-websocket-authenticated :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 :param str [params.tradingAccountId]: the trading account id to fetch entries for :returns dict[]: a list of `trade structures ` NmyTradesrr`rgrraT)rbrYrnrrXrdrerf) r/rYrZr[rBrRrKrOrrgs r1watch_my_tradeszbullish.watch_my_tradess !!!!!!!!!" #  [[((F 4&= (K X  ++F4FGG  '*:G& 'YYv'9::F))+}gvVVVVVVVV ? 3OOFE22E))&% TRRRr2cX||d}g}|dkr-||di}||n||dg}t |dkr1|j0||jdd}t||_|j}i}tdt |D]O} || } | | } || || d} d|| <Pd } | || t| }tdt |D]/} || }| d z|z}| |j|.dSdS) Nr@rrjrrkrlrYTrr)rnrmrtrprsrr7r*rrr parse_traderurr)r/r9rHr@rwrjr[rgrrzrawTrade parsedTraderYrKrrrs r1handle_my_tradeszbullish.handle_my_tradessL00 8  >>'6266D   T " " " "w;;I y>>A  }$))$, tLL 6u = = ]FG1c)nn-- ' '$Q<"..x88  k***))+x@@"&$K NN6; / / / ''D1c$ii(( A A!!W $/$$6$C!t}.?@@@@%   A Ar2cK|d{Vddi}d}||d}|#||d}||d<|d|zz }|||||d{VS)a watch balance and get the amount of funds available for trading or funds locked in orders https://api.exchange.bullish.com/docs/api/rest/trading-api/v2/#overview--private-data-websocket-authenticated :param dict [params]: extra parameters specific to the exchange API endpoint :param str [params.tradingAccountId]: the trading account id to fetch entries for :returns dict: a `balance structure ` Nr` assetAccountsbalancerr)rbrnrrX)r/rBrOrKrs r1 watch_balancezbullish.watch_balances!!!!!!!!! _  ++F4FGG  'YYv'9::F*:G& ' 4"22 2K'' ['6RRRRRRRRRr2c2||d}||jvr i|j|<||d}|dkr5||dg}|||j|<n||di}||d}|}||d|d<||d|d <||}||j||<||j|d <||j||j|<d } d |z} ||j|| ||j|| | zdS) Nrr@rrj assetSymbolavailableQuantitytotallockedQuantityusedrrr) rnrrp parse_balancermaccountsafe_currency_code safe_balanceru) r/r9rHr messageTyperjassetIdrcoderKtradingAccountIdHashs r1handle_balancezbullish.handle_balance5sT ++G5GHH DL00-/DL) *&&w77 * $ $>>'6266D-1-?-?-E-EDL) * *>>'6266D&&t];;GllnnG#//6IJJGG "..t5EFFGFO**733D3:DL) *4 05->t|L\?]-^-^DL) * #&66t|$45{CCCt|$45{EY7YZZZZZr2rcTK|d{Vd}|}||s0||}|dd|zz }ddi}|||||d{V}|jr|S|||||dS)a@ https://api.exchange.bullish.com/docs/api/rest/trading-api/v2/#overview--private-data-websocket-authenticated watch all open positions :param str[] [symbols]: list of unified market symbols :param int [since]: the earliest time in ms to fetch positions for :param int [limit]: the maximum number of positions to retrieve :param dict params: extra parameters specific to the exchange API endpoint :returns dict[]: a list of `position structure ` N positionsr,r`derivativesPositionsV2T)rbis_emptymarket_symbolsjoinrXrdfilter_by_symbols_since_limit) r/rrZr[rBrRrKrOrs r1watch_positionszbullish.watch_positionsus!!!!!!!!!# # }}W%% 4))'22G 4#((7"3"33 3K - ,,[-RXYYYYYYYY ?  11)WeUTXYYYr2cp||d}g}|dkr-||di}||n||dg}|jt |_|j}g}t dt|D]I}||} || } || || J| |d} t dt| D]}| |} | d} | d}| d}| |d |d }| |s| || | |d dS) Nr@rrjrz positions::rr5rrYFr)rnrmrtrprrrrrsparse_positionfind_message_hashessplitfilter_by_arrayrru)r/r9rHr rawPositionsrjr newPositionsrz rawPositionposition messageHashesrKparts symbolsStringrsymbolPositionss r1handle_positionszbullish.handle_positionss&&w77  ( " ">>'6266D    % % % %>>'62>>L > !577DNN  q#l++,, * *A&q/K**;77H   X & & &    ) ) ) )00GG q#m,,-- = =A'*K%%d++E!!HM#))#..G"22<7TYZZO==11 = <<<y+.....r2c||di}|jdz||z} ||d}||d}||jd||||jd||t|#t$r }| |Yd}~dSd}~wwxYw)Nrj errorCode errorCodeNameexactbroad) rmrCjsonrnthrow_exactly_matched_exception exceptionsthrow_broadly_matched_exceptionr Exceptionreject)r/r9rHrjfeedbackrres r1handle_error_messagezbullish.handle_error_messages~~gvr227S=499T??2 (({;;I ,,T?CCM  0 01I9V^ _ _ _  0 01I=Zb c c c)) )    MM!          sA?B88 C"CC"cb||d}||d}|6||d}|dkr|||dSdS||dkr||||dkr||||dkr||||dkr||||d kr||||d kr||||d kr| ||dSdSdS) NdataTyperWrHzKeep alive pongV1TAAnonymousTradeUpdateV1TATickerResponse V1TALevel2 V1TAOrder V1TATradeV1TAAssetAccountV1TAErrorResponse) rnrmrIr{rrrrrr)r/r9rHrrWresponses r1handle_messagezbullish.handle_messages|##GZ8822  '' ::H,,,  11111-,  !555""67333///""67333<''&&vw777;&&""67333;&&%%fg666---##FG444...))&':::::" !/.r2)(__name__ __module__ __qualname__rr.r8rr&rIrDrQrXrrrrhr{rr~rr rrrr r rrrrrrrr r rrrr __classcell__)r0s@r1rrs% #% % % % % % N  6      &    FHPR f fc f fWZ f f f fQS[]s3be$<@d[]SSSSSSbfglbmSSSS2(1F(1(1(1(1T68GGGFGGGG"<:F<:<:<:<:|@DB!!S!!S\!!!!,,/,/,/,/,/\   04$UYbdUUUCUsUimnsitUUUU>F?FF?F?F?F?P37TX\egSSCSsSRUSlpqvlwSSSS>?Av?A?A?A?AB*,SSSSSS,>[V>[>[>[>[@8<$]ajlZZWZCZWZZquv~qZZZZ4/v////>6.;V;;;;;;;;r2r)ccxt.async_supportccxt ccxt.async_support.base.ws.cacherrrccxt.base.typesrrrr r r r r rr!ccxt.async_support.base.ws.clientrtypingrccxt.base.errorsr async_supportrr2r1rs iiiiiiiiiigggggggggggggggggggggggg444444******L ;L ;L ;L ;L ;d (L ;L ;L ;L ;L ;r2