V.jSZddlZddlZddlZddlZddlZddlmZddlmZddlmZddl m Z ddl m Z m Z mZmZmZddlZddlmZdd lmZdd lmZdd lmZdd lmZdd lmZddlmZdZ GddeZ!Gdde"eZ#GddZ$Gdde$Z%GddZ&GddeZ'y)N)sleep)Enum)random)gaierror)OptionalListDictCallableAny)ConnectionClosedError) AsyncClient) FuturesType)BinanceWebsocketUnableToConnect) ContractType)get_loop)ThreadedApiManageri,ceZdZdZdZdZdZy)WSListenerState Initialising Streaming ReconnectingExitingN)__name__ __module__ __qualname__ INITIALISING STREAMING RECONNECTINGEXITINGQC:\xampp\htdocs\tradingbinance\backend\.venv\Lib\site-packages\binance/streams.pyrrs!LI!LGr"rc eZdZdZdZdZdZdZy)BinanceSocketTypeSpot USD_M_FuturesCoin_M_FuturesVanilla_OptionsAccountN)rrrSPOT USD_M_FUTURESCOIN_M_FUTURESOPTIONSACCOUNTr!r"r#r%r% s D#M%NGGr"r%c eZdZdZdZdZdZdZdZ dde de e d e d e fd Z d Z d ZdZdZdZdZdZdZdZdZdZdedefdZdZdZdZy)ReconnectingWebsocket<皙? dNurlpathprefix is_binarycFt|_tjt|_||_||_||_||_ d|_ ||_ d|_ d|_ d|_tj |_t%j&|_d|_y)Nr)r_looplogging getLoggerr_log_path_url _exit_coro_prefix _reconnects _is_binary_conn_socketwsrrws_stateasyncioQueue_queue_handle_read_loop)selfr7r8r9r: exit_coros r#__init__zReconnectingWebsocket.__init__0sZ %%h/   # #  8<'44 mmo !%r"cBK|jd{|S7wN)connectrNs r# __aenter__z ReconnectingWebsocket.__aenter__Bslln  s cK|jr#|j|jd{tj|_|j r|j j |jr;t|jdr%|jj|||d{d|_|js4|jjd|jd{yy77N7 w)NprotocolzCANCEL read_loop)rBr@rr rIrHfail_connectionrFhasattr __aexit__rMr?error_kill_read_loop)rNexc_typeexc_valexc_tbs r#rZzReconnectingWebsocket.__aexit__Fs ??//$**- - -'// 77 GG # # % ::'$**j9**&&x&A A A%% IIOO. /&&( ( (& . B )s5+DC<BD/C>0AD5D6D>DDctK|jd{|jsJ|j|jz|jz}t j |d|_ |j jd{|_tj|_ d|_ |jd{|js>|jj!t"j$|j'|_yy77#|jd{7YyxYw7sw)Nr4) close_timeoutr)_before_connectr@rArCrHrSrFrU _reconnectrrrIrD_after_connectrMr<call_soon_threadsaferJ create_task _read_loop)rNws_urls r#rSzReconnectingWebsocket.connectSs""$$$zzzT\\)DJJ6ZZc:   JJ1133DG(11 !!###%%%)ZZ%D%DWEXEXZ^ZiZiZk%lD "& % 4 //# # #  $sSD8DAD8,D D D/D8D6AD8DD3+D.,D31D8cKtj|_|jr!t dd{|jr yy7wNr4)rr rIrMrrTs r#r\z%ReconnectingWebsocket._kill_read_loopds7'// $$*  $$ s0AAAAc KywrRr!rTs r#rbz%ReconnectingWebsocket._before_connecti  c KywrRr!rTs r#rdz$ReconnectingWebsocket._after_connectlrlrmc|jr tj|} t j |S#ttf$rYywxYw#t$r!|jjd|YywxYw)Nzerror parsing evt json:) rEgzip decompress ValueErrorOSErrorjsonloadsr?debug)rNevts r#_handle_messagez%ReconnectingWebsocket._handle_messageoss ?? ooc* ::c? "(    IIOO5cU; < s 9AA  A 'A87A8cRK |jtjk(r6|jd{|jtjk(r6|jtjk(r7|j j d|jd|jn|jjtjjjk(rtjdd{|jjtjjjk(r|j!d{n |jtj"k(r|jsJtj$|jj'|j(d{}|j+|}|r|j,j/|j0kr$|j,j3|d{nU|j j d|j0d|j,j3ddd d{t4yd|_!d|_"y7W77>77v7(#tj6$r,|j j d |j(d Y^tj8$r(}|j j d |Yd}~d}~wtj:$r)}|j j d |dYd}~d}~wt<$r)}|j j d|dYd}~d}~wt>$r*}|j j d|dYd}~.d}~wt4$r*}|j j d|dYd}~]d}~wt@$r*}|j j d|dYd}~d}~wwxYw#d|_!d|_"wxYww)Nz _read_loop z break for r4timeoutzQueue overflow z. Message not filledr[z"Queue overflow. Message not filledemno message in  secondszcancelled error zincomplete read error ()zconnection close error (z DNS Error (z!BinanceWebsocketUnableToConnect (zUnknown exception (r)#rIrr_run_reconnectr r?rvr@rHstaterWStateCLOSINGrJrCLOSEDrcrwait_forrecvTIMEOUTrxrLqsizeMAX_QUEUE_SIZEputr TimeoutErrorCancelledErrorIncompleteReadErrorr r ExceptionrMrD)rNresr}s r#rgz ReconnectingWebsocket._read_loop{s20 !+--?+G+GG"11333--?+G+GG}}(?(?? +djj\T]]O(\]"++*;*;*C*CC%mmC000 "++*;*;*B*BB"oo////*C*CC#www$+$4$4TWW\\^T\\$ZZ"2237#{{002T5H5HH&*kkooc&: : : $ /$BUBUAVVj0k l&*kkoo)0)M7"'#!#!#'F E5\&*D " D Y4 10[!;!# ++MIIOOnT\\N($KL--IIOO&6qc$:;22DIIOO&=aS$BCC,EIIOO&>qc$CDD8IIOOk!A$6776IIOO&Gs!$LM IIOO&9!A$>?&*D " D s9P'P0JJ !JAJ+P-AJJJPAJJA.JJAJ!J"AJ1J2 J<P>P' JJJJJJ+>AQAQ+Q*RS)*, --/ / /,,. IIOO01D1D0EYO P++//4#  2 1! & 0  sGDDBDD D7D8ADD DDDDc(Kd}|sE tj|jj|jd{}|sE|S7 #tj $r,|j jd|jdYEwxYww)Nrzrr)rJrrLgetrrr?rv)rNrs r#rzReconnectingWebsocket.recvs} I#,,T[[__-> UU  V'' I .h GH Is@BB Battemptsreturncld|z}ttt|j|dz zdzS)Nr )roundrminMAX_RECONNECT_SECONDS)rNrexpos r#rz)ReconnectingWebsocket._get_reconnect_waits3H}VXD$>$>q IIAMNNr"cK|jr8|jr,|jjdddd{d|_|xjdz c_y7!w)Nr )rHrFrZrDrTs r#rz&ReconnectingWebsocket.before_reconnectsL 77tzz**&&tT48 8 8DG A 9s9AA"Acd|jjdtj|_y)Nz!No message received, reconnecting)r?rvrrrIrTs r#_no_message_received_reconnectz4ReconnectingWebsocket._no_message_received_reconnects  ;<'44 r"c6Ktj|_ywrR)rrrIrTs r#rcz ReconnectingWebsocket._reconnects'44 s)Nws/FN)rrrrrMIN_RECONNECT_WAITrNO_MESSAGE_RECONNECT_TIMEOUTrstrrboolrPrUrZrSr\rbrdrxrgrrrintrrrrcr!r"r#r1r1(sNG#% Nmq&&&sm&-> r"cK|jsy|jr!|jjd|_t||i|d{y7wrR)r@rcancelrrZ)rNargskwargsrs r#rZzKeepAliveWebsocket.__aexit__sGzz  ;; KK   DKg0000sA AAAcdK|js|jd{|_yy7 wrR)r@_get_listen_keyrTs r#rbz"KeepAliveWebsocket._before_connects(zz#3355DJ5s 0. 0c,K|jywrR)_start_socket_timerrTs r#rdz!KeepAliveWebsocket._after_connects   "scbjjjfd_y)NcJtjjSrR)rJrf_keepalive_socketrTsr#z8KeepAliveWebsocket._start_socket_timer..sG''(>(>(@Ar")r< call_laterrrrTs`r#rz&KeepAliveWebsocket._start_socket_timers%jj++    A  r"cK|jdk(r$|jjd{}|S|jdk(r$|jjd{}|S|jdk(r$|jj d{}|S|jdk(r$|jj d{}|S|jj |jd{}|S777l7;7w)Nusermarginfutures coin_futures)rrstream_get_listen_keymargin_stream_get_listen_keyfutures_stream_get_listen_key"futures_coin_stream_get_listen_key%isolated_margin_stream_get_listen_keyrN listen_keys r#rz"KeepAliveWebsocket._get_listen_keys   6 )#||AACCJ ! !X -#||HHJJJ ! !Y .#||IIKKJ   ! !^ 3#||NNPPJ $||QQRVRfRfggJDJKPhsW-DC>2D"D#2DD2DD .D7D8DDDDDcK |jd{}||jk7r<|jjd||_|j d{nG|jjd|j dk(r.|j j|jd{n|j dk(r.|j j|jd{n|j dk(r.|j j|jd{nu|j dk(r.|j j|jd{n8|j j|j |jd{|jy77b7 777[7$#t$rY-wxYw#|jwxYww)Nzlisten key changed: reconnectzlisten key same: keepaliverrrr)rr@r?rvrcrrstream_keepalivemargin_stream_keepalivefutures_stream_keepalivefutures_coin_stream_keepalive isolated_margin_stream_keepaliverrrs r#rz$KeepAliveWebsocket._keepalive_sockets '#3355JTZZ'  ?@' oo'''  <=''61,,77 CCC))X5,,>>tzzJJJ))Y6,,?? KKK))^;,,DDTZZPPP,,GGH\H\^b^h^hiii  $ $ &+6(DJKPj     $ $ &sG4GF?AG G!AG9G:ZdefdAZ?defdBZ@dedCefdDZAdefdEZBej@fdefdFZCdPdedefdGZDdHZEy)QBinanceSocketManagerzwss://stream.binance.{}:9443/zwss://testnet.binance.vision/zwss://fstream.binance.{}/zwss://stream.binancefuture.com/zwss://dstream.binance.{}/z wss://dstream.binancefuture.com/zwss://vstream.binance.{}/zwss://testnetws.binanceops.{}/51020rc&|jj|j|_|jj|j|_|jj|j|_|j j|j|_|j j|j|_i|_t|_ ||_ ||_ |jj|_ y)zInitialise the BinanceSocketManager :param client: Binance API client :type client: binance.AsyncClient N) STREAM_URLformattld FSTREAM_URL DSTREAM_URL VSTREAM_URLVSTREAM_TESTNET_URL_connsrr<rrtestnet)rNrrs r#rPzBinanceSocketManager.__init__7s//00<++226::>++226::>++226::>#'#;#;#B#B6::#N  Z  )||++ r"N stream_urlcV|r|S|j}|jr |j}|SrR)rrSTREAM_TESTNET_URLrNrs r#_get_stream_urlz$BinanceSocketManager._get_stream_urlKs,  __ <<00Jr"rFr8r9r: socket_typercd|}|jvr0t|j||fd|j|<j|S)N_c0jd|S)Nr) _exit_socket)prNrs r#rz2BinanceSocketManager._get_socket..]sD$5$5 Qqc6J$Kr")r8r7r9rOr:)rr1r)rNr8rr9r:rconn_ids` ` r# _get_socketz BinanceSocketManager._get_socketSs_!M4&) $++ %#8((4K# $DKK {{7##r"c tjd|}||jvrLt|j|j ||||j ||j|j|<|j|S)Nr)rr7rr9rOr:r)r%r/rrrrrr)rNr8rr9r:rs r#_get_account_socketz(BinanceSocketManager._get_account_socketcs{'../q7 $++ %#5||((4#++#!//$DKK {{7##r" futures_typectj}|tjk(r%|j}|j r1|j }n$|j}|j r |j}|j||||S)N)r) r%r,rUSD_MrrFSTREAM_TESTNET_URLrDSTREAM_TESTNET_URLr)rNr8rr9rrs r#_get_futures_socketz(BinanceSocketManager._get_futures_sockettso):)H)H ;,, ,))J||!55 ))J||!55 j&kRRr"c|j}|jr |j}|j|||dtj S)NT)r:r)rrrrr%r.)rNr8r9rs r#_get_options_socketz(BinanceSocketManager._get_options_socketsB%% <<11Jj&DVgVoVoppr"cBK|j|d{y7wrR) _stop_socket)rNr8s r#rz!BinanceSocketManager._exit_sockets%%%s symboldepthintervalc|jdz}|r |dk7r||}|r|dvr |d|d}n td|j|S)a Start a websocket for symbol market depth returning either a diff or a partial book https://github.com/binance-exchange/binance-official-api-docs/blob/master/web-socket-streams.md#partial-book-depth-streams :param symbol: required :type symbol: str :param depth: optional Number of depth entries to return, default None. If passed returns a partial book instead of a diff :type depth: str :param interval: optional interval for updates, default None. If not set, updates happen every second. Must be 0, None (1s) or 100 (100ms) :type interval: int :returns: connection key string if successful, False otherwise Partial Message Format .. code-block:: python { "lastUpdateId": 160, # Last update ID "bids": [ # Bids to be updated [ "0.0024", # price level to be updated "10", # quantity [] # ignore ] ], "asks": [ # Asks to be updated [ "0.0026", # price level to be updated "100", # quantity [] # ignore ] ] } Diff Message Format .. code-block:: python { "e": "depthUpdate", # Event type "E": 123456789, # Event time "s": "BNBBTC", # Symbol "U": 157, # First update ID in event "u": 160, # Final update ID in event "b": [ # Bids to be updated [ "0.0024", # price level to be updated "10", # quantity [] # ignore ] ], "a": [ # Asks to be updated [ "0.0026", # price level to be updated "100", # quantity [] # ignore ] ] } @depth1)rr6@mszAWebsocket interval value not allowed. Allowed values are [0, 100])lowerrrr)rNrrr socket_names r# depth_socketz!BinanceSocketManager.depth_socketsf@llnx/ Uc\(M%1K 8#!, Qxj;  !dee ,,r"cN|jd|}|j|S)aWStart a websocket for symbol kline data https://github.com/binance-exchange/binance-official-api-docs/blob/master/web-socket-streams.md#klinecandlestick-streams :param symbol: required :type symbol: str :param interval: Kline interval, default KLINE_INTERVAL_1MINUTE :type interval: str :returns: connection key string if successful, False otherwise Message Format .. code-block:: python { "e": "kline", # event type "E": 1499404907056, # event time "s": "ETHBTC", # symbol "k": { "t": 1499404860000, # start time of this bar "T": 1499404919999, # end time of this bar "s": "ETHBTC", # symbol "i": "1m", # interval "f": 77462, # first trade id "L": 77465, # last trade id "o": "0.10278577", # open "c": "0.10278645", # close "h": "0.10278712", # high "l": "0.10278518", # low "v": "17.47929838", # volume "n": 4, # number of trades "x": false, # whether this bar is final "q": "1.79662878", # quote volume "V": "2.34879839", # volume of active buy "Q": "0.24142166", # quote volume of active buy "B": "13279784.01349473" # can be ignored } } @kline_)r r)rNrrr8s r# kline_socketz!BinanceSocketManager.kline_sockets-R,,.! 3%%r" contract_typecn|jd|jd|}|j|d|S)aStart a websocket for symbol kline data for the perpeual futures stream https://binance-docs.github.io/apidocs/futures/en/#continuous-contract-kline-candlestick-streams :param symbol: required :type symbol: str :param interval: Kline interval, default KLINE_INTERVAL_1MINUTE :type interval: str :param futures_type: use USD-M or COIN-M futures default USD-M :param contract_type: use PERPETUAL or CURRENT_QUARTER or NEXT_QUARTER default PERPETUAL :returns: connection key string if successful, False otherwise Message Format .. code-block:: python { "e":"continuous_kline", // Event type "E":1607443058651, // Event time "ps":"BTCUSDT", // Pair "ct":"PERPETUAL" // Contract type "k":{ "t":1607443020000, // Kline start time "T":1607443079999, // Kline close time "i":"1m", // Interval "f":116467658886, // First trade ID "L":116468012423, // Last trade ID "o":"18787.00", // Open price "c":"18804.04", // Close price "h":"18804.04", // High price "l":"18786.54", // Low price "v":"197.664", // volume "n": 543, // Number of trades "x":false, // Is this kline closed? "q":"3715253.19494", // Quote asset volume "V":"184.769", // Taker buy volume "Q":"3472925.84746", //Taker buy quote asset volume "B":"0" // Ignore } } _@continuousKline_ rz@continuousKline_rr9r)r valuer)rNrrrrr8s r#kline_futures_socketz)BinanceSocketManager.kline_futures_socketsB^,,.!=#6#6"77H S''U'VVr" update_timec,|jd|dS)aStart a miniticker websocket for all trades This is not in the official Binance api docs, but this is what feeds the right column on a ticker page on Binance. :param update_time: time between callbacks in milliseconds, must be 1000 or greater :type update_time: int :returns: connection key string if successful, False otherwise Message Format .. code-block:: python [ { 'e': '24hrMiniTicker', # Event type 'E': 1515906156273, # Event time 's': 'QTUMETH', # Symbol 'c': '0.03836900', # close 'o': '0.03953500', # open 'h': '0.04400000', # high 'l': '0.03756000', # low 'v': '147435.80000000', # volume 'q': '5903.84338533' # quote volume } ] z!miniTicker@arr@r r)rNrs r#miniticker_socketz&BinanceSocketManager.miniticker_socket1s<"2;-r BCCr"cF|j|jdzS)aStart a websocket for symbol trade data https://github.com/binance-exchange/binance-official-api-docs/blob/master/web-socket-streams.md#trade-streams :param symbol: required :type symbol: str :returns: connection key string if successful, False otherwise Message Format .. code-block:: python { "e": "trade", # Event type "E": 123456789, # Event time "s": "BNBBTC", # Symbol "t": 12345, # Trade ID "p": "0.001", # Price "q": "100", # Quantity "b": 88, # Buyer order Id "a": 50, # Seller order Id "T": 123456785, # Trade time "m": true, # Is the buyer the market maker? "M": true # Ignore. } @traderr rNrs r# trade_socketz!BinanceSocketManager.trade_socketQs <  9::r"cF|j|jdzS)aStart a websocket for symbol trade data https://github.com/binance-exchange/binance-official-api-docs/blob/master/web-socket-streams.md#aggregate-trade-streams :param symbol: required :type symbol: str :returns: connection key string if successful, False otherwise Message Format .. code-block:: python { "e": "aggTrade", # event type "E": 1499405254326, # event time "s": "ETHBTC", # symbol "a": 70232, # aggregated tradeid "p": "0.10281118", # price "q": "8.15632997", # quantity "f": 77489, # first breakdown trade id "l": 77489, # last breakdown trade id "T": 1499405254324, # trade time "m": false, # whether buyer is a maker "M": true # can be ignored } @aggTraderrs r#aggtrade_socketz$BinanceSocketManager.aggtrade_socketqs :  <==r"cJ|j|jdz|S)aPStart a websocket for aggregate symbol trade data for the futures stream :param symbol: required :param futures_type: use USD-M or COIN-M futures default USD-M :returns: connection key string if successful, False otherwise Message Format .. code-block:: python { "e": "aggTrade", // Event type "E": 123456789, // Event time "s": "BTCUSDT", // Symbol "a": 5933014, // Aggregate trade ID "p": "0.001", // Price "q": "100", // Quantity "f": 100, // First trade ID "l": 105, // Last trade ID "T": 123456785, // Trade time "m": true, // Is the buyer the market maker? } r rrr rNrrs r#aggtrade_futures_socketz,BinanceSocketManager.aggtrade_futures_sockets&4'' (DS_'``r"cF|j|jdzS)a Start a websocket for a symbol's miniTicker data https://binance-docs.github.io/apidocs/spot/en/#individual-symbol-mini-ticker-stream :param symbol: required :type symbol: str :returns: connection key string if successful, False otherwise Message Format .. code-block:: python { "e": "24hrMiniTicker", // Event type "E": 123456789, // Event time "s": "BNBBTC", // Symbol "c": "0.0025", // Close price "o": "0.0010", // Open price "h": "0.0025", // High price "l": "0.0010", // Low price "v": "10000", // Total traded base asset volume "q": "18" // Total traded quote asset volume } z @miniTickerrrs r#symbol_miniticker_socketz-BinanceSocketManager.symbol_miniticker_sockets 6  >??r"cF|j|jdzS)aStart a websocket for a symbol's ticker data https://github.com/binance-exchange/binance-official-api-docs/blob/master/web-socket-streams.md#individual-symbol-ticker-streams :param symbol: required :type symbol: str :returns: connection key string if successful, False otherwise Message Format .. code-block:: python { "e": "24hrTicker", # Event type "E": 123456789, # Event time "s": "BNBBTC", # Symbol "p": "0.0015", # Price change "P": "250.00", # Price change percent "w": "0.0018", # Weighted average price "x": "0.0009", # Previous day's close price "c": "0.0025", # Current day's close price "Q": "10", # Close trade's quantity "b": "0.0024", # Best bid price "B": "10", # Bid bid quantity "a": "0.0026", # Best ask price "A": "100", # Best ask quantity "o": "0.0010", # Open price "h": "0.0025", # High price "l": "0.0010", # Low price "v": "10000", # Total traded base asset volume "q": "18", # Total traded quote asset volume "O": 0, # Statistics open time "C": 86400000, # Statistics close time "F": 0, # First trade ID "L": 18150, # Last trade Id "n": 18151 # Total number of trades } @tickerrrs r#symbol_ticker_socketz)BinanceSocketManager.symbol_ticker_sockets!R  :;;r"c$|jdS)a"Start a websocket for all ticker data By default all markets are included in an array. https://github.com/binance-exchange/binance-official-api-docs/blob/master/web-socket-streams.md#all-market-tickers-stream :param coro: callback function to handle messages :type coro: function :returns: connection key string if successful, False otherwise Message Format .. code-block:: python [ { 'F': 278610, 'o': '0.07393000', 's': 'BCCBTC', 'C': 1509622420916, 'b': '0.07800800', 'l': '0.07160300', 'h': '0.08199900', 'L': 287722, 'P': '6.694', 'Q': '0.10000000', 'q': '1202.67106335', 'p': '0.00494900', 'O': 1509536020916, 'a': '0.07887800', 'n': 9113, 'B': '1.00000000', 'c': '0.07887900', 'x': '0.07399600', 'w': '0.07639068', 'A': '2.41900000', 'v': '15743.68900000' } ] z !ticker@arrrrTs r# ticker_socketz"BinanceSocketManager.ticker_socketsT ..r"Tfastcr|rdnd}|j|j|ztjS)aPStart a websocket for a symbol's futures mark price https://binance-docs.github.io/apidocs/delivery/en/#index-price-stream :param symbol: required :param fast: use faster or 1s default :returns: connection key string if successful, False otherwise Message Format .. code-block:: python { "e": "indexPriceUpdate", // Event type "E": 1591261236000, // Event time "i": "BTCUSD", // Pair "p": "9636.57860000", // Index Price } z@indexPrice@1sz @indexPricer#)rr rCOIN_M)rNrr. stream_names r#index_price_socketz'BinanceSocketManager.index_price_socket s6 +/&M '' (DS^SeSe'ffr"cb|j|jdzt|z|S)aqSubscribe to a futures depth data stream https://binance-docs.github.io/apidocs/futures/en/#partial-book-depth-streams :param symbol: required :type symbol: str :param depth: optional Number of depth entries to return, default 10. :type depth: str :param futures_type: use USD-M or COIN-M futures default USD-M rr#)rr r)rNrrrs r#futures_depth_socketz)BinanceSocketManager.futures_depth_socket3s/'' (ACJ(N]i'jjr"cV|rdnd}|j|j|z|S)aStart a websocket for a symbol's futures mark price https://binance-docs.github.io/apidocs/futures/en/#mark-price-stream :param symbol: required :param fast: use faster or 1s default :param futures_type: use USD-M or COIN-M futures default USD-M :returns: connection key string if successful, False otherwise Message Format .. code-block:: python { "e": "markPriceUpdate", // Event type "E": 1562305380000, // Event time "s": "BTCUSDT", // Symbol "p": "11185.87786614", // Mark price "r": "0.00030000", // Funding rate "T": 1562306400000 // Next funding time } z @markPrice@1sz @markPricer#r$)rNrr.rr1s r#symbol_mark_price_socketz-BinanceSocketManager.symbol_mark_price_socket@s/$*.o< '' (DS_'``r"c4|rdnd}|j||S)aiStart a websocket for all futures mark price data By default all symbols are included in an array. https://binance-docs.github.io/apidocs/futures/en/#mark-price-stream-for-all-market :param fast: use faster or 1s default :param futures_type: use USD-M or COIN-M futures default USD-M :returns: connection key string if successful, False otherwise Message Format .. code-block:: python [ { "e": "markPriceUpdate", // Event type "E": 1562305380000, // Event time "s": "BTCUSDT", // Symbol "p": "11185.87786614", // Mark price "r": "0.00030000", // Funding rate "T": 1562306400000 // Next funding time } ] z!markPrice@arr@1sz!markPrice@arrr#r)rNr.rr1s r#all_mark_price_socketz*BinanceSocketManager.all_mark_price_socketUs%*.2)7G '' ,'OOr"cJ|j|jdz|S)aStart a websocket for a symbol's ticker data By default all markets are included in an array. https://binance-docs.github.io/apidocs/futures/en/#individual-symbol-book-ticker-streams :param symbol: required :param futures_type: use USD-M or COIN-M futures default USD-M :returns: connection key string if successful, False otherwise .. code-block:: python [ { "u":400900217, // order book updateId "s":"BNBUSDT", // symbol "b":"25.35190000", // best bid price "B":"31.21000000", // best bid qty "a":"25.36520000", // best ask price "A":"40.66000000" // best ask qty } ] @bookTickerr#r$r%s r#symbol_ticker_futures_socketz1BinanceSocketManager.symbol_ticker_futures_socketms&&'' (FUa'bbr"cJ|j|jdz|S)aiStart a futures websocket for a single symbol's ticker data https://binance-docs.github.io/apidocs/futures/en/#individual-symbol-ticker-streams :param symbol: required :type symbol: str :param futures_type: use USD-M or COIN-M futures default USD-M :returns: connection key string if successful, False otherwise .. code-block:: python { "e": "24hrTicker", // Event type "E": 123456789, // Event time "s": "BTCUSDT", // Symbol "p": "0.0015", // Price change } r*r#r$r%s r#'individual_symbol_ticker_futures_socketz??r"c$|jdS)aStart a websocket for the best bid or ask's price or quantity for all symbols. https://github.com/binance-exchange/binance-official-api-docs/blob/master/web-socket-streams.md#all-book-tickers-stream :returns: connection key string if successful, False otherwise Message Format .. code-block:: python { // Same as @bookTicker payload } r@rrTs r#book_ticker_socketz'BinanceSocketManager.book_ticker_sockets  ..r"streamscPddj|}|j|dS)atStart a multiplexed socket using a list of socket names. User stream sockets can not be included. Symbols in socket name must be lowercase i.e bnbbtc@aggTrade, neobtc@ticker Combined stream events are wrapped as follows: {"stream":"","data":} https://github.com/binance-exchange/binance-official-api-docs/blob/master/web-socket-streams.md :param streams: list of stream names in lower case :type streams: list :returns: connection key string if successful, False otherwise Message Format - see Binance API docs for all types streams=/stream?r9)joinr)rNrFr8s r#multiplex_socketz%BinanceSocketManager.multiplex_sockets0$#((7+,-Y77r"cdj|Dcgc]}|jc}}d|}|j|dScc}w)afStart a multiplexed socket using a list of socket names. User stream sockets can not be included. Symbols in socket name must be lowercase i.e bnbbtc@aggTrade, neobtc@ticker Combined stream events are wrapped as follows: {"stream":"","data":} https://binance-docs.github.io/apidocs/voptions/en/#account-and-trading-interface :param streams: list of stream names in lower case :type streams: list :returns: connection key string if successful, False otherwise Message Format - see Binance API docs for all types rIrHrJrK)rLr r)rNrFsr1 stream_paths r#options_multiplex_socketz-BinanceSocketManager.options_multiplex_socketsN$hh7;7a 7;<   . '' I'FF ","data":} https://github.com/binance-exchange/binance-official-api-docs/blob/master/web-socket-streams.md :param streams: list of stream names in lower case :param futures_type: use USD-M or COIN-M futures default USD-M :returns: connection key string if successful, False otherwise Message Format - see Binance API docs for all types rHrIrJr)rLr)rNrFrr8s r#futures_multiplex_socketz-BinanceSocketManager.futures_multiplex_sockets2$#((7+,-''Y\'ZZr"cp|j}|jr |j}|jd|S)a\Start a websocket for user data https://github.com/binance-exchange/binance-official-api-docs/blob/master/user-data-stream.md https://binance-docs.github.io/apidocs/spot/en/#listen-key-spot :returns: connection key string if successful, False otherwise Message Format - see Binance API docs for all types rrrrrrrs r# user_socketz BinanceSocketManager.user_sockets5__ <<00J'':'FFr"cp|j}|jr |j}|jd|S)a Start a websocket for coin futures user data https://binance-docs.github.io/apidocs/futures/en/#user-data-streams :returns: connection key string if successful, False otherwise Message Format - see Binanace API docs for all types rrUrrrrrs r#futures_user_socketz(BinanceSocketManager.futures_user_socket$s7%% <<11J'' j'IIr"cp|j}|jr |j}|jd|S)aStart a websocket for cross-margin data https://binance-docs.github.io/apidocs/spot/en/#listen-key-margin :returns: connection key string if successful, False otherwise Message Format - see Binance API docs for all types rrUrVrs r# margin_socketz"BinanceSocketManager.margin_socket3s5__ <<00J''Z'HHr"cp|j}|jr |j}|jd|S)a Start a websocket for futures data https://binance-docs.github.io/apidocs/futures/en/#websocket-market-streams :returns: connection key string if successful, False otherwise Message Format - see Binance API docs for all types rrUrYrs r#futures_socketz#BinanceSocketManager.futures_socketAs7%% <<11J'' j'IIr"cp|j}|jr |j}|jd|S)aStart a websocket for coin futures data https://binance-docs.github.io/apidocs/delivery/en/#websocket-market-streams :returns: connection key string if successful, False otherwise Message Format - see Binance API docs for all types rrU)rrrrrs r#coin_futures_socketz(BinanceSocketManager.coin_futures_socketOs7%% <<11J'':'NNr"cp|j}|jr |j}|j||S)apStart a websocket for isolated margin data https://binance-docs.github.io/apidocs/spot/en/#listen-key-isolated-margin :param symbol: required - symbol for the isolated margin account :type symbol: str :returns: connection key string if successful, False otherwise Message Format - see Binance API docs for all types rUrV)rNrrs r#isolated_margin_socketz+BinanceSocketManager.isolated_margin_socket]s5__ <<00J'':'FFr"cF|j|jdzS)zSubscribe to a 24 hour ticker info stream https://binance-docs.github.io/apidocs/voptions/en/#market-streams-payload-24-hour-ticker :param symbol: required :type symbol: str r*rr rs r#options_ticker_socketz*BinanceSocketManager.options_ticker_socketns '' (BCCr"expiration_datecL|j|jdz|zS)a,Subscribe to a 24 hour ticker info stream https://binance-docs.github.io/apidocs/voptions/en/#24-hour-ticker-by-underlying-asset-and-expiration-data :param symbol: required :type symbol: str :param expiration_date : required :type expiration_date: str z@ticker@rd)rNrrfs r##options_ticker_by_expiration_socketz8BinanceSocketManager.options_ticker_by_expiration_socketxs%'' (Co(UVVr"cF|j|jdzS)zSubscribe to a latest completed trades stream https://binance-docs.github.io/apidocs/voptions/en/#market-streams-payload-latest-completed-trades :param symbol: required :type symbol: str rrdrs r#options_recent_trades_socketz1BinanceSocketManager.options_recent_trades_sockets '' (ABBr"cL|j|jdz|zS)a)Subscribe to a candlestick data stream https://binance-docs.github.io/apidocs/voptions/en/#market-streams-payload-candle :param symbol: required :type symbol: str :param interval: Kline interval, default KLINE_INTERVAL_1MINUTE :type interval: str rrd)rNrrs r#options_kline_socketz)BinanceSocketManager.options_kline_sockets%'' (BX(MNNr"c^|j|jdzt|zS)a%Subscribe to a depth data stream https://binance-docs.github.io/apidocs/voptions/en/#market-streams-payload-depth :param symbol: required :type symbol: str :param depth: optional Number of depth entries to return, default 10. :type depth: str r)rr r)rNrrs r#options_depth_socketz)BinanceSocketManager.options_depth_sockets)'' (ACJ(NOOr"cDK||jvry|j|=yw)zStop a websocket given the connection key :param conn_key: Socket connection key :type conn_key: string :returns: None N)r)rNconn_keys r#rz!BinanceSocketManager._stop_sockets# 4;; &  [[ "s rR)NrF)zstream?streams=)rNNiTr)FrrrrrrrrrrrWEBSOCKET_DEPTH_5WEBSOCKET_DEPTH_10WEBSOCKET_DEPTH_20rrrPrrrr%r+rr1rrrrrrrr KLINE_INTERVAL_1MINUTErrr PERPETUALrrrr!r&r(r+r-r2r4r6r9r<r>rArCrErrMrQrSrWrZr\r^r`rbrerhrjrlrnrr!r"r#rr)s0J8-K;-K<-K:9J,{,((3-6:bg):)?)?$$%-c]$CF$[_$&$ $"ch$$%-c]$CF$[_$" S S; SPS SqqSq &s&H-3H-x}H-xX[}H-T2=1S1S*&3*&X:E9[9[9D9J9J;G;Q;Q0W30W+60W,80WdDSD@;3;@>c>>P[O`O`acaa8@s@:)<3)BP[PaPa k3 ks kBFcnctctasa$aU`a*26S^SdSdP$P[P0U`TeTec3ckc*`k_p_p_c_Q\_"EPDUDURkR,@@4/$8S 8*GS G,XcWhWh[S [[* G J I J OGSG"DCDW#WPSWC3C:E9[9[ O3 O P3 Ps P $r"rceZdZ d;deedeedeeeefdededeeeeff fd ZdZ dd e de d efdZd e ded efdZd e ded efdZej$fd e deded efdZd e ded efdZd e ded efdZd e d efdZd?d e ded ed efd!Zdej$fd e ded eded ef d"Zdej$fd e d eded efd#Zej$fd e deded efd$Z ej$fd e deded efd%Z!ej$fd e ded efd&Z"d e ded efd'Z#d e d efd(Z$d e d)e%ed efd*Z&d e d)e%ed efd+Z'ej$fd e d)e%eded efd,Z(d e d efd-Z)d e d efd.Z*d e d efd/Z+d e d efd0Z,d e d efd1Z-d e ded efd2Z.d e ded efd3Z/d e ded4ed efd5Z0d e ded efd6Z1ejfd e ded efd7Z2d@d e deded efd9Z3d8ej$fd e deded efd:Z4xZ5S)AThreadedWebsocketManagerapi_key api_secretrequests_paramsrrsession_paramsc<t|||||||d|_yrR)rrP_bsm)rNr|r}r~rrrrs r#rPz!ThreadedWebsocketManager.__init__s# *osG^\48 r"c^K|jsJt|j|_yw)N)r)rrrrTs r#_before_socket_listener_startz6ThreadedWebsocketManager._before_socket_listener_starts"|||( = s+-callbackr paramsr8rcN|js"tjd|js"t|j|di|}|xs |j}d|j |<|j jtj|j||||S)Nr4Tr!) rtimergetattrr@_socket_runningr<rerJrfstart_listener)rNrr rr8socket socket_paths r#_start_async_socketz,ThreadedWebsocketManager._start_async_sockets)) JJsO))0K0:6:/6<< ,0[) ''(;(;T=P=PQWYdfn=opr"rrrc2|j|d|||dS)Nr )rrrrr rr)rNrrrrs r#start_depth_socketz+ThreadedWebsocketManager.start_depth_sockets0''& $(  r"c0|j|d||dS)NrrrrrrNrrrs r#start_kline_socketz+ThreadedWebsocketManager.start_kline_sockets+''& $(  r"rrc 4|j|d||||dS)Nr)rrrrrr)rNrrrrrs r#start_kline_futures_socketz3ThreadedWebsocketManager.start_kline_futures_sockets3''. $ ,!. (  r"rc.|j|dd|iS)Nrrrr)rNrrs r#start_miniticker_socketz0ThreadedWebsocketManager.start_miniticker_sockets*''+{(  r"c.|j|dd|iS)NrrrrrNrrs r#start_trade_socketz+ThreadedWebsocketManager.start_trade_sockets*''&&(  r"c.|j|dd|iS)Nr!rrrrs r#start_aggtrade_socketz.ThreadedWebsocketManager.start_aggtrade_sockets*'')&(  r"c0|j|d||dS)Nr&rrrrrNrrrs r#start_aggtrade_futures_socketz6ThreadedWebsocketManager.start_aggtrade_futures_socket s-''1 ,(  r"c.|j|dd|iS)Nr(rrrrs r#start_symbol_miniticker_socketz7ThreadedWebsocketManager.start_symbol_miniticker_sockets*''2&(  r"c.|j|dd|iS)Nr+rrrrs r#start_symbol_ticker_socketz3ThreadedWebsocketManager.start_symbol_ticker_socket!s*''.&(  r"c*|j|diS)Nr-rrrNrs r#start_ticker_socketz,ThreadedWebsocketManager.start_ticker_socket*#'''(  r"Tr.c0|j|d||dS)Nr2)rr.rr)rNrrr.s r#start_index_price_socketz1ThreadedWebsocketManager.start_index_price_socket1s+'', (  r"c2|j|d|||dS)Nr6)rr.rrr)rNrrr.rs r#start_symbol_mark_price_socketz7ThreadedWebsocketManager.start_symbol_mark_price_socket;s0''2  ,(  r"c0|j|d||dS)Nr9)r.rrr)rNrr.rs r#start_all_mark_price_socketz4ThreadedWebsocketManager.start_all_mark_price_socketHs-''/ ,(  r"c0|j|d||dS)Nr<rrrrs r#"start_symbol_ticker_futures_socketz;ThreadedWebsocketManager.start_symbol_ticker_futures_socketTs-''6 ,(  r"c0|j|d||dS)Nr>rrrrs r#-start_individual_symbol_ticker_futures_socketzFThreadedWebsocketManager.start_individual_symbol_ticker_futures_socket`s-''A ,(  r"c.|j|dd|iS)NrArrr)rNrrs r#start_all_ticker_futures_socketz8ThreadedWebsocketManager.start_all_ticker_futures_socketls*''3 (  r"c.|j|dd|iS)NrCrrrrs r#start_symbol_book_ticker_socketz8ThreadedWebsocketManager.start_symbol_book_ticker_socketus*''3&(  r"c*|j|diS)NrErrrs r#start_book_ticker_socketz1ThreadedWebsocketManager.start_book_ticker_socket~s#'',(  r"rFc.|j|dd|iS)NrMrFrrrNrrFs r#start_multiplex_socketz/ThreadedWebsocketManager.start_multiplex_sockets*''*7(  r"c.|j|dd|iS)NrQrFrrrs r#start_options_multiplex_socketz7ThreadedWebsocketManager.start_options_multiplex_sockets*''27(  r"c0|j|d||dS)NrS)rFrrr)rNrrFrs r#start_futures_multiplex_socketz7ThreadedWebsocketManager.start_futures_multiplex_sockets-''2" ,(  r"c*|j|diS)NrWrrrs r#start_user_socketz*ThreadedWebsocketManager.start_user_sockets#''%(  r"c*|j|diS)NrZrrrs r#start_futures_user_socketz2ThreadedWebsocketManager.start_futures_user_socket#''-(  r"c*|j|diS)Nr\rrrs r#start_margin_socketz,ThreadedWebsocketManager.start_margin_socketrr"c*|j|diS)Nr^rrrs r#start_futures_socketz-ThreadedWebsocketManager.start_futures_sockets#''((  r"c*|j|diS)Nr`rrrs r#start_coin_futures_socketz2ThreadedWebsocketManager.start_coin_futures_socketrr"c.|j|dd|iS)Nrbrrrrs r#start_isolated_margin_socketz5ThreadedWebsocketManager.start_isolated_margin_sockets*''0&(  r"c.|j|dd|iS)Nrerrrrs r#start_options_ticker_socketz4ThreadedWebsocketManager.start_options_ticker_sockets*''/&(  r"rfc0|j|d||dS)Nrh)rrfrr)rNrrrfs r#)start_options_ticker_by_expiration_socketzBThreadedWebsocketManager.start_options_ticker_by_expiration_sockets+''= #2(  r"c.|j|dd|iS)Nrjrrrrs r#"start_options_recent_trades_socketz;ThreadedWebsocketManager.start_options_recent_trades_sockets*''6&(  r"c0|j|d||dS)Nrlrrrrs r#start_options_kline_socketz3ThreadedWebsocketManager.start_options_kline_sockets-''. $(  r"rc0|j|d||dS)Nrn)rrrr)rNrrrs r#start_options_depth_socketz3ThreadedWebsocketManager.start_options_depth_sockets+''. (  r"c2|j|d|||dS)Nr4)rrrrr)rNrrrrs r#start_futures_depth_socketz3ThreadedWebsocketManager.start_futures_depth_sockets.''.  ,(  r")NNNcomFNrRrqrrrsrt)6rrrrrr r rrPrr rrrrrxrrrrryrrrrrrrrrrrrrrrrrrrrrrrrrrrrrrrrrrs@r#r{r{sDJNEJJN9}99A#9!$sCx.19?B9908S#X/G9> cg   /2 <@cN RZ[^R_   gk     *-  6>sm  V^_bVc    LWKmKm 8 S ru -8,N,N?J?P?PAMAWAW  8  S  1<  3?  ]`    s VY  8 S S  h   LWK\K\     *-  =H     x  QT  8 S S  H    3 d ^a =A^i^o^o     *-  59  P[    04Q\QbQb     (,  CN    LWK\K\     *-  =H    LWK\K\     *-  =H    _j^o^o  P[ tw   # RU   c  x $s) PS  x $s) X[ S^RcRc     +/9  DO     ( s  ( s  H   X #  ( s  X s s  H c c  ( TW jm ru  8 S UX 9D8Z8Z     *-     8 S QT `c X\juj{j{  8  S  QT  AD  r"r{)(rJrprtr=rrenumrrrrtypingrrr r r websocketsrHwebsockets.exceptionsr rrenumsr exceptionsrrhelpersrthreaded_streamrrrrr%r1rrr{r!r"r#rs  6677/dTu5u5pF'.F'RF$F$RX 1X r"