:j-dZddlZddlmZddlmZmZmZddlm Z m Z ddl m Z ddl mZdd lmZmZmZdd lmZed ZGd d eZy)z Status Data Collector for Monitor Package Pure data aggregation from monitoring sources without application dependencies. Simplified architecture focusing on monitoring data collection and caching. N) OrderedDict)AnyDictOptional)COLLECTOR_CACHE_TTL CacheConfig) SystemState) get_logger) CacheStatsIMonitorProvider SystemStatus)IStatusCollectorstateceZdZdZddeefdZddedefdZ defdZ de fd Z dd Z d edefd Zd ed eddfdZd eddfdZddZy)StatusCollectorz Simplified status data collector focusing on monitoring data aggregation. Removed application dependencies and complex field mapping logic. Implements IStatusCollectorWithMonitoring protocol for type safety. N monitoringc||_i|_i|_t|_t |_t|_tj|_ tjdy)zInitialize collector with monitoring data provider Args: monitoring: Monitoring component implementing MonitoringDataProvider interface zDStatusCollector initialized with simplified monitoring-only approachN)r_cache _cache_timesr_cache_access_orderr _cache_statsr _cache_ttlrDEFAULT_MAX_SIZE_cache_max_sizeloggerdebug)selfrs 6/root/.openclaw/workspace/harvester/state/collector.py__init__zStatusCollector.__init__ sR %') .0;F= &L-*;; [\refreshreturncZd}|se|j|rT|jxjdz c_|j|tj d|j |S|j}|j|||jxjdz c_ |S)zCollect and return unified system status from monitoring data Args: refresh: Force refresh of cached data if True Returns: SystemStatus: Complete system status aggregated from monitoring system_statusr zReturning cached system status) _is_cache_validrhits_update_access_orderrrr_collect_fresh_status _update_cachemisses)rr" cache_keystatuss rr-zStatusCollector.status2s$ 4// :    " "a ' "  % %i 0 LL9 :;;y) )++- 9f-   A%  r!ctt}tj|_|jstj d|S |jj }|jj}|j|_|j|j_ |j|j_ td|j|jz |jz |j_ |j|j_|j |j_|j"|j$_|j(|j$_|j*r|j*|_|j,r%|j,j/|j,t0j2|_tj d|jdt7|j,|S#t8$r#}tj;d|Yd}~|Sd}~wwxYw)z4Collect fresh system status from monitoring providerz No monitoring provider availablerz Fresh status collected - tasks: z , providers: z"Error collecting monitoring data: N)rtime timestamprrrsummarysnapshotruntime completedtasksfailedmaxpending throughput performance success_ratekeysresourcevalidlinkspipeline providersupdater RUNNINGrlen Exceptionerror)rr-r1r2es rr)z%StatusCollector._collect_fresh_statusLs99; LL; <M Coo--/G//1H%__FN%,%6%6FLL "")..FLL #&q'--':K:K*Kgnn*\#]FLL ,3,>,>F   ).5.B.BF   +$+LLFOO !$+MMFOO !  "*"3"3!!  ''(:(:;'..FL LL;GMM?-X[\d\n\nXoWpq r   C LL=aSA B B  CsGH H7H22H7cbt|j|j_|jS)zGet current cache statistics)rDrrsizers r cache_statszStatusCollector.cache_statsvs%!$T[[!1   r!c|jj|jj|jjt |_t jdy)zClear all cached datazStatusCollector cache clearedN)rclearrrr rrrrJs r clear_cachezStatusCollector.clear_cache{sM  !   &&(&L 45r!r,c||jvs||jvrytj|j|z }||jkS)z#Check if cached data is still validF)rrr/r)rr,ages rr&zStatusCollector._is_cache_validsH DKK '9DrjsC #&&@"#>># G Q<&Q