6i;ddlZddlmZddlZddlZddlmZmZmZddl m Z ddl m Z ddl mZGd d eZd ZGd d ZGddeZGddeZGddeZGddeZy)N) itemgetter)OptionalDictCallable)get_loop)BinanceSocketManager)ThreadedApiManagercPeZdZefdefdZdZdZdZdZ e defdefdZ y ) DepthCache conv_typec||_i|_i|_d|_||_t j t|_y)zInitialise the DepthCache :param symbol: Symbol to create depth cache for :type symbol: string :param conv_type: Optional type to represent price, and amount, default is float. :type conv_type: function. N) symbol_bids_asks update_timerlogging getLogger__name___log)selfrrs S/var/www/app/trading-bot/venv/lib/python3.12/site-packages/binance/ws/depthcache.py__init__zDepthCache.__init__ s:   #,%%h/ c~|j|d|j|d<|ddk(r|j|d=yy)zFAdd a bid to the cache :param bid: :return: r r 0.00000000N)rr)rbids radd_bidzDepthCache.add_bidD"^^CF3 3q6 q6\ ! 3q6" "rc~|j|d|j|d<|ddk(r|j|d=yy)zGAdd an ask to the cache :param ask: :return: r rrN)rr)rasks radd_askzDepthCache.add_ask(r rcZtj|jd|jS)aGet the current bids :return: list of bids with price and quantity as conv_type .. code-block:: python [ [ 0.0001946, # Price 45.0 # Quantity ], [ 0.00019459, 2384.0 ], [ 0.00019158, 5219.0 ], [ 0.00019157, 1180.0 ], [ 0.00019082, 287.0 ] ] Treverser)r sort_depthrrrs rget_bidszDepthCache.get_bids3s$>$$TZZ$XXrcZtj|jd|jS)aGet the current asks :return: list of asks with price and quantity as conv_type. .. code-block:: python [ [ 0.0001955, # Price 57.0' # Quantity ], [ 0.00019699, 778.0 ], [ 0.000197, 64.0 ], [ 0.00019709, 1130.0 ], [ 0.0001971, 385.0 ] ] Fr%)r r'rrr(s rget_askszDepthCache.get_asksTs+>$$ JJ%  rFcbt|tr1|jDcgc]\}}||||g}}}nJt|tr#|Dcgc]\}}||||g}}}nt dt |t |td|}|Scc}}wcc}}w)zSort bids or asks by pricez$Unknown order book depth data type: r)keyr&) isinstancedictitemslist ValueErrortypesortedr)valsr&rpricequantitylsts rr'zDepthCache.sort_depthws dD !(,zz|#E85!9X#67Cd #RVWuhIe$i&9:WCWCDJ<PQ QSjmW=  Xs B%B+N) r __module__ __qualname__floatrrrr#r)r+ staticmethodr'rrr r sH5:0(0 # #YB! F!&e 8  rr icveZdZdZdeddefdeefdZdZ dZ dZ d Z d Z d Zd Zd ZdZdZdZdZy)BaseDepthCacheManager<N refresh_intervalc||_d|_|xs t|_||_||_d|_|xst|j|_||_ d|_ ||_ tjt|_y)aCreate a DepthCacheManager instance :param client: Binance API client :type client: binance.Client :param loop: :type loop: :param symbol: Symbol to create depth cache for :type symbol: string :param refresh_interval: Optional number of seconds between cache refresh, use 0 or None to disable :type refresh_interval: int :param bm: Optional BinanceSocketManager :type bm: BinanceSocketManager :param limit: Optional number of orders to get from orderbook :type limit: int :param conv_type: Optional type to represent price, and amount, default is float. :type conv_type: function. N)_client _depth_cacher_loop_symbol_limit_last_update_idr _bm_refresh_interval _conn_key _conv_typerrrr)rclientrlooprBbmlimitrs rrzBaseDepthCacheManager.__init__su:  'XZ   #;-dll;!1#%%h/ rcKtj|j|jd{|jj d{|S7(7wN)asynciogather _init_cache _start_socket_socket __aenter__r(s rrYz BaseDepthCacheManager.__aenter__sQnnT--/1C1C1EFFFll%%'''  G's!6A%A!!A%A#A%#A%cK|jjd|j|jj|i|d{y7w)Nz Exiting depth cache manager for )rdebugrGrX __aexit__)rargskwargss rr\zBaseDepthCacheManager.__aexit__sA :4<<.IJ$dll$$d5f555sAA A AcKd}|s| tj|jj|jd{}|j j d||j|d{}|s||S7@7 #t$r=}|j jd|jjdYd}~Jd}~wwxYww)N)timeoutzReceived message: zException recieving message: z (e) ) rTwait_forrXrecvTIMEOUTrr[ _depth_event Exceptionwarning __class__r)rdcreses rrbzBaseDepthCacheManager.recvs  2#,,T\\->->-@$,,WW "4SE :; ,,S11 X 2 _ !!$A!++BVBVAWW\"]^^ _sXCt ||||||||||_y)a Initialise the DepthCacheManager :param client: Binance API client :type client: binance.Client :param loop: asyncio loop :param symbol: Symbol to create depth cache for :type symbol: string :param refresh_interval: Optional number of seconds between cache refresh, use 0 or None to disable :type refresh_interval: int :param limit: Optional number of orders to get from orderbook :type limit: int :param conv_type: Optional type to represent price, and amount, default is float. :type conv_type: function. :param ws_interval: Optional interval for updates on websocket, default None. If not set, updates happen every second. Must be 0, None (1s) or 100 (100ms). :type ws_interval: int N)superr _ws_interval) rrNrrOrBrPrQr ws_intervalrgs rrzDepthCacheManager.__init__+s'8 /?UIV'rcKd|_g|_|jj|j|j d{}t |d{|j||jsJ|dD]}|jj||dD]}|jj||d|_|jD]}|j|d{g|_y777w)rlN)rrQrrr) rI_depth_message_bufferrDget_order_bookrGrHrrVr|rErr#rw)rrirr"ryrgs rrVzDepthCacheManager._init_cacheJs $%'"LL//t||4;;/WWg!### 3    v; +C    % %c * +v; +C    % %c * + #>2-- 3C--c2 2 2 3&("+X $ 3s7AD DD DBD 7D 8D D  D cfKt|ddsg|_t| d{y7w)rqrN)getattrrrrW)rrgs rrWzDepthCacheManager._start_socketis/ t4d;)+D &g#%%%s &1/1cd|jj|j|jS)N)interval)rJ depth_socketrGrr(s rrrzDepthCacheManager._get_socketss&xx$$T\\D(>&O!rrc*eZdZfdZdZdZxZS)FuturesDepthCacheManagerc`K|jd}t| |d{S7w)r{dataN)rrrw)rryrgs rrwz/FuturesDepthCacheManager._process_depth_messages,ggfoW3C8888s $.,.c |jsJ|jdg|j_|jdg|j_|jdxs|jd|j_y)Nrrrr)rErrrrrxs rr|z&FuturesDepthCacheManager._apply_orderssi    "%''#r"2"%''#r"2), (O8O%rcP|jj|j}|SrS)rJfutures_depth_socketrG)rsocks rrrz$FuturesDepthCacheManager._get_socketsxx,,T\\: r)rr9r:rwr|rrrrs@rrrs9PrrceZdZdZy)OptionsDepthCacheManagercL|jj|jSrS)rJoptions_depth_socketrGr(s rrrz$OptionsDepthCacheManager._get_socketsxx,,T\\::rN)rr9r:rrr=rrrrs;rrc eZdZ ddeedeedeeeefdedef fd Zdddefd e d ed efd Z ddded fd e d ed efdZ dddefd e d ed efdZ dddefd e d ed efdZ xZS)ThreadedDepthCacheManagerNapi_key api_secretrequests_paramstldtestnetc,t||||||yrS)rr)rrrrrrrgs rrz"ThreadedDepthCacheManager.__init__s *osGLrrAcallbackrreturnc ||js"tjd|js"|d|j||j||||d|} |j dzt |z} d|j | <|jjtj|j| | || S)Ng{Gz?)rNrrOrBrPrQrz@depthTr=) rDrnsleeprFlowerstr_socket_running call_soonrT create_taskstart_listener) r dcm_classrrrBrPrQrr^dcmpaths r_start_depth_cachez,ThreadedDepthCacheManager._start_depth_caches,, JJt ,,  <<-    ||~(3u:5%)T"    !4!4S$!I  rrc <|jt|||||||S)N)rrrrBrPrQrr)rr)rrrrBrPrQrrs rstart_depth_cachez+ThreadedDepthCacheManager.start_depth_caches4&&'-#'  rc :|jt||||||SN)rrrrBrPrQr)rrrrrrBrPrQrs rstart_futures_depth_socketz4ThreadedDepthCacheManager.start_futures_depth_socket1&&.-'  rc :|jt||||||Sr)rrrs rstart_options_depth_socketz4ThreadedDepthCacheManager.start_options_depth_socket rr)NNNcomF)rr9r:rrrboolrr;rrrrrrrs@rrrs&"&$(48 M#MSMM"$sCx.1 M  M  M   F      2      .      rr)roperatorrrTrntypingrrrhelpersrstreamsr threaded_streamr objectr rr?rrrrr=rrrs| ++)/xxv]]@m-m`40;4; c 2c r