eie[ddlZddlmZmZddlmZmZmZm Z m Z m Z ddl m Z ddlmZddlmZGddejjZdS) N) ArrayCacheArrayCacheByTimestamp)AnyBoolInt OrderBookTickerTrade)Client)List) ExchangeErrorc neZdZdeffd ZdZifdedefdZde fdZ ddifded e d e de e fd Zde fd Zd ddifdeded e d e de ef dZde fdZdifded e defdZde fdZdZdZdZde fdZde fdZde fdZde fdZde fdZde fdZdZde fdZ de de!fdZ"de fdZ#xZ$S) bittradereturnc |tt|dddddddddddddddiiid d dd did d S) NTF)wswatchOrderBook watchTickers watchTicker watchTradeswatchTradesForSymbols watchBalance watchOHLCVapirzwss://{hostname}/wszwss://{hostname}/ws/v2)publicprivategunzip) tradesLimit OHLCVLimitrr)hasurlsoptions) deep_extendsuperrdescribe)self __class__s O/var/www/html/volatility/venv/lib/python3.11/site-packages/ccxt/pro/bittrade.pyr&zbittrade.describesh 5 5 > > @ @"& %##). %"  &;'?    $"d +C C    c||||jddd}||jd<|t |S)N requestIdr)lock_idsum safe_integerr# unlock_idstr)r'r,s r) request_idzbittrade.request_id0s^ HHT..t|[!LLaPP $- [! 9~~r*symbolcK|d{V||}|d}d|dzdz}||jdd}d|ji}||jdd|d |}|}||d } ||||d } |||| | ||| d{VS) 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 ` Nr4market.idz.detailrhostnamerrsubr7r7 messageHashr4params) load_marketsmarket safe_stringr#r8implode_paramsr"r3watchextend) r'r4r=r?r<rr8urlr,request subscriptions r) watch_tickerzbittrade.watch_ticker7s#!!!!!!!!!V$$!&,.: t|UE::$dm4!!$)E"24"8"=h"GRROO%%    &   ZZ[$++gv2N2NP[]ijjjjjjjjjr*clientc||di}||d}|d}||d}||}|||}||d} | |d<|| |d<|d} ||j| <||||S) Ntickch.r-ts timestampdatetimer4) safe_valuer@split safe_market parse_tickeriso8601tickersresolve) r'rHmessagerJrKpartsmarketIdr?tickerrNr4s r) handle_tickerzbittrade.handle_tickerSs$w33   gt , , ##E1--!!(++""400OOGT22 '{!\\)44z!% Vvr"""r*NsincelimitcRK|d{V||}|d}d|dzdz}||jdd}d|ji}||jdd|d |} |} || d } | |||d } || || | ||| d{V} |j r| ||}| | ||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 dict[]: a list of `trade structures ` Nr4r6r7z .trade.detailrr8rrr9r;rNT) r>r?r@r#r8rAr"r3rBrC newUpdatesgetLimitfilter_by_since_limit)r'r4r\r]r=r?r<rr8rDr,rErFtradess r) watch_tradeszbittrade.watch_tradesss[!!!!!!!!!V$$!&,.@ t|UE::$dm4!!$)E"24"8"=h"GRROO%%    &   zz#{DKK4P4PR]_kllllllll ? 3OOFE22E))&% TRRRr*c||di}||di}||d}|d}||d}||}|d} ||j| } | 5||jdd} t| } | |j| <td t|D]3} | || |} | | 4| | ||S) NrJdatarKrLr-r4rrr) rPr@rQrRrbr0r#rrangelen parse_tradeappendrV)r'rHrWrJrerKrXrYr?r4 tradesCacher]itrades r) handle_tradeszbittrade.handle_tradess9*w33tVR00   gt , , ##E1--!!(++!oodk6::  %%dlM4HHE$U++K"-DK q#d))$$ & &A$$T!Wf55E   u % % % %{B'''r*1m timeframecK|d{V||}|d}||j||}d|dzdz|z}||jdd} d|ji} ||jdd| d | } |} || d } | ||||d }| | || | |||d{V}|j r| ||}| |||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 Nr4r6r7z.kline.rr8rrr9)r7r<r4ror=rT)r>r?r@ timeframesr#r8rAr"r3rBrCr_r`ra)r'r4ror\r]r=r?intervalr<rr8rDr,rErFohlcvs r) watch_ohlcvzbittrade.watch_ohlcvs|!!!!!!!!!V$$!##DOY JJ&,.:XE t|UE::$dm4!!$)E"24"8"=h"GRROO%%    &"   jjk4;;w3O3OQ\^jkkkkkkkk ? 2NN6511E))%q$GGGr*c||d}|d}||d}||}|d}||d}||} ||j|i|j|<||j|| } | ;||jdd} t| } | |j|| <||d} | | |} | | | | |dS) NrKrLr-r4r rrJ) r@rQrRfind_timeframerPohlcvsr0r#r parse_ohlcvrirV)r'rHrWrKrXrYr?r4rrrostoredr]rJparseds r) handle_ohlcvzbittrade.handle_ohlcvsJ"  gt , , ##E1--!!(++!##E1--''11 "oodk62FF FV!4i@@ >%%dlL$GGE*511F-3DK  *w//!!$// fvr"""""r*cK||dkrt|jdz|d{V||}|d}|dn|}d|dzdzt |z}||jdd}d |ji}||j dd |d |}| } || d } | |||||j d } | ||| | ||| d{V} | S)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 Nz( watchOrderBook accepts limit = 150 onlyr4r6r7z.mbp.rr8rrr9r7r<r4r]r=method)r r7r>r?r2r@r#r8rAr"r3handle_order_book_subscriptionrBrCr]) r'r4r]r=r?r<rr8rDr,rErF orderbooks r)watch_order_bookzbittrade.watch_order_booksw  ESLL*T TUU U!!!!!!!!!V$$! E&,.83u::E t|UE::$dm4!!$)E"24"8"=h"GRROO%%    &9   **S+t{{7F7S7SU`bnoooooooo    r*c||d}||d}|j|}||d}|||}||d|d<|||j} tdt| D]} | || | | ||j|<| ||dS)Nr4r<reseqNumnoncer) r@ orderbooksrPparse_order_bookr0resetcacherfrghandle_order_book_messagerV) r'rHrWrFr4r<rresnapshotmessagesrks r)handle_order_book_snapshotz#bittrade.handle_order_book_snapshot$s*!!,99&&|]CC OF+ w//((v66 --dH==!!!?q#h--(( K KA  * *68A; J J J J"+y+.....r*cK||d} ||d}||d}||d}||jdd}d|ji} ||jdd|d| } |} || d } | |||||jd } | | | | | | d{V}| S#t$r(}|j |=| ||Yd}~nd}~wwxYwdS) Nr<r4r]r=rr8rr)reqr7r)r@r0rPr#r8rAr"r3rrBr] Exception subscriptionsreject)r'rHrWrFr<r4r]r=rr8rDr,rEsnapshotSubscriptionres r)watch_order_book_snapshotz"bittrade.watch_order_book_snapshotGs&&|]CC  *%%lH==F%%lG<>C($-8H%%di&6t&EE'8"==  #__\8<||j||dSr)rrrs r) handle_pingzbittrade.handle_ping s  49fg.....r*cD||d}|dkr||d}||jd}|||}|||d} ||jd|||nj#t$r]}||d} ||| |||||jvr|j|=Yd}~nd}~wwxYwdS|S)Nstatuserrorr7zerr-codeexactr<F) r@rrrPthrow_exactly_matched_exception exceptionsjsonrr) r'rHrWrr7rrF errorCoderr<s r)handle_error_messagezbittrade.handle_error_messages=!!'844 W  !!'400B $ f.BD I I ??+5B44 D>ADDcJ|||r||d|||dS||d|||dS||d|||dSdSdS)Nr7rKr)rr@rrrrs r)handle_messagezbittrade.handle_message*s  $ $VW 5 5 2..://@@@@@!!'400<##FG44444!!'622>  11111% 2 2"?>r*)%__name__ __module__ __qualname__rr&r3r2r rGr r[rr r rcrmlistrtr|rrrrrrrrrrrrrrrrr __classcell__)r(s@r)rrs( #      @68kkkFkkkk8F@<@d[]SSSSSSbfglbmSSSSB%F%%%%N?CQUdhqs!H!H!H!H3!H^a!Hx|~ByC!H!H!H!HF!#6!#!#!#!#F@DB!!!!S!!!!S\!!!!!!!!F!/!/!/!/!/F>&&& 333!!!!!F!3!3!3!3!3FRVRRRR* 6    #(V#(#(#(#(JHHH /&////6t82V22222222r*r)ccxt.async_supportccxt ccxt.async_support.base.ws.cacherrccxt.base.typesrrrrr r !ccxt.async_support.base.ws.clientr typingr ccxt.base.errorsr async_supportrrr*r)rs NNNNNNNNDDDDDDDDDDDDDDDD444444******o2o2o2o2o2t!*o2o2o2o2o2r*