5i;SSKrSSKJr SSKrSSKrSSKJrJrJr SSK J r SSK J r SSK Jr "S S \5rS r"S S 5r"SS\5r"SS\5r"SS\5r"SS\5rg)N) itemgetter)OptionalDictCallable)get_loop)BinanceSocketManager)ThreadedApiManagerc`\rSrSr\4S\4SjjrSrSrSr Sr \ S\4S\4S jj5r S r g ) DepthCache conv_typecXl0Ul0UlSUlX l[ R "[5Ulg)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 c/var/www/html/BTCUSD/btcusdt_trading_app/venv/lib/python3.13/site-packages/binance/ws/depthcache.py__init__DepthCache.__init__ s6   #,%%h/ cURUS5URUS'USS:XaURUS gg)z.Add a bid to the cache :param bid: :return: r r 0.00000000N)rr)rbids radd_bidDepthCache.add_bidD"^^CF3 3q6 q6\ ! 3q6" "rcURUS5URUS'USS:XaURUS gg)z/Add an ask to the cache :param ask: :return: r rrN)rr)rasks radd_askDepthCache.add_ask(r#rcT[RURSURS9$)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_bidsDepthCache.get_bids3s$>$$TZZ$XXrcT[RURSURS9$)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_asksDepthCache.get_asksTs+>$$ JJ%  rFcx[U[5(a3UR5VVs/sHup4U"U5U"U5/PM nnnOQ[U[5(a%UVVs/sHup4U"U5U"U5/PM nnnO[ S[ U535e[ U[S5US9nU$s snnfs snnf)zSort bids or asks by pricez$Unknown order book depth data type: r)keyr*) isinstancedictitemslist ValueErrortypesortedr)valsr*rpricequantitylsts rr+DepthCache.sort_depthws dD ! !(,zz|'3OE5!9X#67'3 Cd # #RVWRVuIe$i&9:RVCWCCDJ<PQ QSjmW=  Xs B0#B6)rrrrrrN)r __module__ __qualname____firstlineno__floatrrr!r&r-r0 staticmethodr+__static_attributes__rrr r sH5:0(0 # #YB! F!&e 8  rr ic\rSrSrSrS\SS\4S\\4Sjjr Sr Sr S r S r S rS rS rSrSrSrSrSrSrg)BaseDepthCacheManager<N refresh_intervalcXlSUlU=(d [5UlX lX`lSUlU=(d [UR5UlX@l SUl Xpl [R"[5Ulg)aGCreate 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)rclientrlooprLbmlimitrs rrBaseDepthCacheManager.__init__sk:  'XZ   #;-dll;!1#%%h/ rc# [R"UR5UR55IShvN URR 5IShvN U$N(N7fN)asynciogather _init_cache _start_socket_socket __aenter__r,s rrd BaseDepthCacheManager.__aenter__sOnnT--/1C1C1EFFFll%%'''  G's!7A&A"!A&A$A&$A&c# URRSUR35 URR"U0UD6IShvN gN7f)Nz Exiting depth cache manager for )rdebugrQrc __aexit__)rargskwargss rrhBaseDepthCacheManager.__aexit__s> :4<<.IJll$$d5f555sAA A Ac# SnU(d[R"URR5URS9IShvN nUR R SU35 URU5IShvN nU(dMU$NFN![a=nUR RSURRS35 SnANQSnAff=f7f)N)timeoutzReceived message: zException recieving message: z (e) ) r_wait_forrcrecvTIMEOUTrrg _depth_event Exceptionwarning __class__r)rdcreses rroBaseDepthCacheManager.recvs  2#,,T\\->->-@$,,WW "4SE :; ,,S11" X 2 _ !!$A!++BVBVAWW\"]^^ _sX C:BB"B*C>B? C CBC C3CCCCc&# URRSUR35 [URURS9UlUR (a1[[R"55UR -Ul gg7f);Initialise the depth cache calling REST endpoint :return: zInitialising depth cache for )rN) rrgrQr rWrOrUinttime _refresh_timer,s rra!BaseDepthCacheManager._init_cachesh 7 ~FG&t||tO  ! !!$TYY[!1D4J4J!JD  "sBBc6# UR5Ulg7f)'Start the depth cache socket :return: N) _get_socketrcr,s rrb#BaseDepthCacheManager._start_sockets '') sc[er^)NotImplementedErrorr,s rr!BaseDepthCacheManager._get_sockets!!rc# URRSU35 U(dgSU;a)USS:Xa URRSU35 U$URU5IShvN $N7f)z,Handle a depth event :param msg: :return: zReceived depth event: Nrwerrorz'Error in depth event restarting cache: )rrgr_process_depth_messagermsgs rrq"BaseDepthCacheManager._depth_eventsk 067 #:#c(g- IIOOEcUK LJ005555sA*A3,A1-A3c# URU5 URnUR(aD[[R"55UR :aUR 5IShvN U$N7f)KProcess a depth event message. :param msg: Depth event message. :return: N) _apply_ordersrOrUr{r|r}rarrrvs rr,BaseDepthCacheManager._process_depth_messagesa 3  ! !c$))+&69K9K&K""$ $ $  %sA.A90A71A9cUR(deURS/5URS/5-HnURRU5 M URS/5URS/5-HnURRU5 M URS5=(d URS5URlg)NbbidsaasksE lastUpdateId)rOgetr!r&r)rrr r%s rr#BaseDepthCacheManager._apply_orders s    773#cggfb&99C    % %c *:773#cggfb&99C    % %c *:), (O8O%rcUR$)z9Get the current depth cache :return: DepthCache object rOr,s rget_depth_cache%BaseDepthCacheManager.get_depth_caches    rc# SUlg7f)z1Close the open socket for this manager :return: Nrr,s rcloseBaseDepthCacheManager.closes !s cUR$)z Get the symbol :return: symbol )rQr,s r get_symbol BaseDepthCacheManager.get_symbol"s ||r) rTrNrVrWrOrSrRrrPrUr}rcrQ)rr@rArBrpDEFAULT_REFRESHrCrr{rrdrhrorarbrrqrrrrrrErFrrrHrHsjG *9 '0 #3- '0R 6  K*"6&(P!!rrHcj^\rSrSrSSSS\S4S\\4U4SjjjrU4SjrU4Sjr Sr S r S r U=r $) DepthCacheManageri*NirLc 6>[T U]XX4XVU5 Xlg)aInitialise 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) rrXrrYrLrZr[r ws_intervalrts rrDepthCacheManager.__init__+s8 IV'rc,># SUl/UlURRURUR S9IShvN n[ TU]5IShvN URU5 UR(deUSHnURRU5 M USHnURRU5 M USUlURHnURU5IShvN M /UlgNNN7f)rzN)rr[rrr) rS_depth_message_bufferrNget_order_bookrQrRrrarrOr!r&r)rrvr r%rrts rraDepthCacheManager._init_cacheJs $%'"LL//t||4;;/WWg!### 3    v;C    % %c *v;C    % %c * #>2--C--c2 2 2.&("+X $ 3s7ADDDDB#D=D>DDDcp># [USS5(d/Ul[TU] 5IShvN gN7f)rrN)getattrrrrb)rrts rrbDepthCacheManager._start_socketis1 t4d;;)+D &g#%%%s +646c^URRURURS9$)N)interval)rT depth_socketrQrr,s rrDepthCacheManager._get_socketss&xx$$T\\D(>&O!!rrc4^\rSrSrU4SjrSrSrSrU=r$)FuturesDepthCacheManageric`># URS5n[TU] U5IShvN $N7f)rdataN)rrr)rrrts rr/FuturesDepthCacheManager._process_depth_messages+ggfoW3C8888s $.,.cUR(deURS/5URlURS/5URlURS5=(d URS5URlg)Nrrrr)rOrrrrrs rr&FuturesDepthCacheManager._apply_orderssi    "%''#r"2"%''#r"2), (O8O%rcPURRUR5nU$r^)rTfutures_depth_socketrQ)rsocks rr$FuturesDepthCacheManager._get_socketsxx,,T\\: rrF) rr@rArBrrrrErrs@rrrs9Prrc\rSrSrSrSrg)OptionsDepthCacheManagericLURRUR5$r^)rToptions_depth_socketrQr,s rr$OptionsDepthCacheManager._get_socketsxx,,T\\::rrFN)rr@rArBrrErFrrrrs;rrc ^\rSrSrSS\\S\\S\\\\4S\S\4 U4SjjjrSSS \ 4S \ S \S \4S jjr SSS \ S4S \ S \S \4Sjjr SSS \ 4S \ S \S \4Sjjr SSS \ 4S \ S \S \4SjjrSrU=r$)ThreadedDepthCacheManageriNapi_key api_secretrequests_paramstldtestnetc(>[TU]XX4U5 gr^)rr)rrrrrrrts rr"ThreadedDepthCacheManager.__init__s oGLrrKcallbackrreturnc UR(d)[R"S5 UR(dM)U"SURUURUUUUS.UD6n UR 5S-[ U5-n SUR U 'URR[RURXU55 U $)Ng{Gz?)rXrrYrLrZr[rz@depthTrF) rNr|sleeprPlowerstr_socket_running call_soonr_ create_taskstart_listener) r dcm_classrrrLrZr[rrjdcmpaths r_start_depth_cache,ThreadedDepthCacheManager._start_depth_caches,, JJt ,,,  <<-    ||~(3u:5%)T"    !4!4S!I  rrc 6UR[UUUUUUUS9$)N)rrrrLrZr[rr)rr)rrrrLrZr[rrs rstart_depth_cache+ThreadedDepthCacheManager.start_depth_caches4&&'-#'  rc 4UR[UUUUUUS9$N)rrrrLrZr[r)rrrrrrLrZr[rs rstart_futures_depth_socket4ThreadedDepthCacheManager.start_futures_depth_socket1&&.-'  rc 4UR[UUUUUUS9$r)rrrs rstart_options_depth_socket4ThreadedDepthCacheManager.start_options_depth_socket rrrF)NNNcomF)rr@rArBrrrboolrrCrrrrrrErrs@rrrs1"&$(48 M#MSMM"$sCx.1 M  M  MM   F      2      .       rr)roperatorrr_r|typingrrrhelpersrstreamsr threaded_streamr objectr rrHrrrrrFrrrs| ++)/xxv]]@m-m`40;4; c 2c r