:j^@dZddlmZddlmZddlmZddlmZddl m Z m Z m Z ddl mZed Zd e d e d efd Zd e d e d efdZGddZy)z Status Display Engine for Monitor Package This module provides unified rendering for all status display needs. It replaces the scattered display logic throughout the system. )List) get_config)DisplayContextConfig) get_logger) AlertLevel DisplayMode StatusContext) SystemStatusstatecontextmodereturnc  t}|jjj|ji}|j|j}|r|r|jd|j |jd|j |jd|j|jd|j|jd|j|jd|j|jd|jd}td i|S|St||fi|S#t$r/}tj!d |t||fi|cYd }~Sd }~wwxYw) z4Get display configuration from unified config systemtitle show_workers show_alertsshow_performanceshow_newline_prefixwidthmax_alerts_per_levelrrrrrrrz$Config load failed, using defaults: N)rdisplaycontextsgetvaluerrrrrrrr_get_default_config Exceptionloggerdebug)r r overridesconfigcontext_configs mode_config config_dictes 4/root/.openclaw/workspace/harvester/state/display.pyget_display_configr)sB? ..1155gmmRH%))$**5 ']]7K4E4EF$-MM.+BZBZ$[#,== @W@W#X(1 6H+JfJf(g+4==9NP[PoPo+p&]]7K4E4EF,5MM:PR]RrRr,s ,:k::""'wB B B ? ;A3?@"7D>I>>?s*D#D5&D5( D55 E->$E("E-(E-c tjdtjdtjdtjdtj di}|j |d|tjtjfv|tjtjfv|tjtjfv|tjtjfvddd }i||}td i|S) z Get default configuration valuesz System StatuszTask Manager StatuszPipeline MonitoringzApplication StatuszPipeline StatusStatusPrr) r SYSTEM TASK_MANAGER MONITORING APPLICATIONMAINrr COMPACTSUMMARYDETAILEDr)r rr"titlesdefaults final_configs r(rr6s o""$9  "7!!#7- FGX.[%8%8+:M:M$NN 4 4k6L6LMM [%9%9;;Q;Q$RR# (<(T>T'UU !H-h,),L  /, //c eZdZdZdededededdf dZdededdfd Z dededdfd Z dededdfd Z dededdfd Z dededededdf d Z deddfdZdededeefdZdedeefdZdedeefdZdedeefdZdededeefdZy)StatusDisplayEnginezx Unified display engine that renders SystemStatus in various formats. Replaces all scattered display logic. statusr rr#rNc |tjk(r|j||y|tjk(r|j ||y|tj k(r|j ||y|tjk(r|j||||y|j||y#t$r3}tjd||j|Yd}~yd}~wwxYw)zMain rendering entry pointzDisplay rendering failed: N)r r3_render_compactr4_render_summaryr0_render_monitoringr5_render_detailed_render_standardrr error_render_fallback)selfr<r rr#r's r(renderzStatusDisplayEngine.renderUs *{***$$VV4,,,$$VV4///''7---%%fgtVD%%ff5 * LL5aS9 :  ! !& ) ) *s.%B/%B/%B/4'B/B// C+8)C&&C+c g}|j}|jd|z|j|jd|d|jd|z|jr=|jj }|jd|d|j dd|jry|jjD]\\}}|j}|j|dd |d |jjd d |jjd ^|jd|z|D]} tj| y)z!Render compact single-line format=^zQueues: | Runtime: .1fs>10 [z ]: valid=z>3z, links=>4N)rappendrhas_pipeline_datapipeline queue_sizeruntimehas_provider_data providersitems abbreviationsresourcevalidlinksr info) rEr<r#linesrsizenameproviderabbrevlines r(r>z#StatusDisplayEngine._render_compactjsN  S5[!  QugPI.0 S5[!  # # %??--/D LL8D6fnnS5IK L  # # %"("2"2"8"8": h!//1 Cj6(+%..44R89%..44R8:   S5[! D KK  r9c g}|j}|jd|z|j|jd|d|jd|z|jd|jjjd|j dd|j jdkDrX|jd |j jd |j jd |j jd d |jjdkDr@|jd|jjd|jjd|j}|r<|Dcgc]}|j}}|jddj||jd|z|D]}tj!|ycc}w)zRender brief summary formatrHrIrJzState: rKrLrMrzTasks: /z (.1%z success)zKeys: z valid,  totalzActive Providers: z, N)rrQrr rrUtaskstotal completed success_raterZr[active_providersr`joinr r]) rEr<r#r^rrlpprovider_namesrcs r(r?z#StatusDisplayEngine._render_summarys  S5[!  QugPI.0 S5[!  wv||11779:,v~~VYFZZ[\] <<   ! LL&,,0016<<3E3E2FfV\\MfMfgjLkktu  ?? 1 $ LL6&//"7"7!8AVAV@WW]^ _"224 .>?aff?N? LL-dii.G-HI J S5[! D KK   @s=G&c,g}|j}|jd|z|j|jd|d|jd|z|jr6|j |j |||jd|zn%|jd|jd|z|j r!|j |j|n|jd|jrM|jjdkDr4|jd|z|j |j||jrE|jr5|jd|z|j |j|||jd|z|D]M}|jr*|j!drt"j%d|z9t"j%|Oy ) z!Render standard multi-line formatrHrIrJ-No pipeline data availableNo provider data availabler N)rrQrrRextend_format_pipeline_sectionrV_format_provider_sectionr performance throughput_format_performance_sectionr has_alerts_format_alerts_sectionr startswithr r]rEr<r#r^rrcs r(rBz$StatusDisplayEngine._render_standards  S5[!  QugPI.0 S5[!  # # % LL66vvF G LLu % LL5 6 LLu %  # # % LL66v> ? LL5 6  " "v'9'9'D'Dq'H LLu % LL99&A B   &"3"3"5 LLu % LL44VVD E S5[! "D))dooc.B D4K( D!  "r9c g}|j}|jd|z|j|jd|d|jd|z|jd|jdd|jj dd|jj d|jr[|jd |jjd |jjd |jjd |jd |z|jr5|j|j|||jd |z|j!r |j|j#||j%r5|jd |z|j|j'|||jd|z|D]}t(j+|y)z7Render monitoring-specific format with performance datarHrIrJ Runtime: rLzs | Throughput: z tasks/sec | Success: rfz Workers: rez active | Queues: rgrqN)rrQrrUrxryrkrworkeractiverirSrTrRrurvrV#_format_provider_monitoring_sectionr{r|r r]r~s r(r@z&StatusDisplayEngine._render_monitorings  S5[!  QugPI.0 S5[!  s+,!--88=>**77< >    LLFMM0016==3F3F2GH!??5578@   S5[!  # # % LL66vvF G LLu %  # # % LLAA&I J     LLu % LL44VVD E S5[! D KK  r9c t|||jddd|j|j}|j ||g}|j}|j d|z|j d|j d|j rdnd|j d|jjd |j d t|j|jjd kDr)|j d |jjd |j d |z|D]}tj|y)z+Render detailed format with all informationT)rrrrrrrqzSystem Health:z Overall Status: HealthyzIssues Detected Error Rate: rfz Critical Alerts: rz Worker Utilization: rHN)r)rrrrBrQhealthyrx error_ratelencritical_alertsrri utilizationr r]) rEr<r rr#detailed_configr^rrcs r(rAz$StatusDisplayEngine._render_detaileds= -  ,,! & : :,,   fo6  S5[! %& )v~~7G)M^)_`a ~f&8&8&C&CC%HIJ *3v/E/E/G+H*IJK ==   " LL1&--2K2KC1PQ R S5[! D KK  r9c d}d|zdd|dd|zd|jjd|jdd d t|jd|zg}|D]}t j |y ) z1Render fallback display when main rendering fails<rHr+rIrJzSystem State: rrLz secondsz Providers: N)r rrUrrWr r])rEr<rr^rcs r(rDz$StatusDisplayEngine._render_fallback)s %K%y! %KV\\//0 1s+8 4#f../0 1 %K  D KK  r9c g}|jjs|jd|S|jrB|jddddddddddddd d |jd |jz|jjj D]\}}|r|st jd |d |&|j}|j}|j}|j} |jr%|j|dd|dd|dd|dd| d |j|d d|dd|dd||S)z.Format pipeline section with table-like layoutrrStage<10 | Queue<8 ProcessedErrorsWorkersrqz+Ignore inviliad stage metrics data, stage: z , metrics: rNz: queue=z<4z , processed=<6z , errors=) rSstagesrQrrrXr r!rTtotal_processed total_errorsworkers) rEr<r#r^r`metricsrT processederrorsrs r(rvz,StatusDisplayEngine._format_pipeline_section9so%% LL5 6L    LLGC=GB8z ] | Valid: rPz | Rate: z>5.1fz % | Links: z>5z | API: rf)rWrXrYrZrkrQr[r\)rEr<r^r`rarbrks r(rz7StatusDisplayEngine._format_provider_monitoring_sectionrs$..446 ND(++-F#,,99C?L LL*Bvbk*"++11"56%e,-"++11"56 --c2 4   r9c*dd|jjddd|jjdd|jjdg}|jjdkDr*|j d |jjdd |S) z"Format performance metrics sectionzPerformance Metrics:z Throughput: z.2fz tasks/secz Success Rate: rfrrz Avg Response Time: rM)rxryrkravg_response_timerQ)rEr<r^s r(rzz/StatusDisplayEngine._format_performance_sections #V//::3?z Jv11>>sC DV//::3? @      / /! 3 LL01C1C1U1UVY0ZZ[\ ] r9cdg}|jDcgc]"}|jtjk(s!|$}}|jDcgc]"}|jtjk(s!|$}}|jDcgc]"}|jtj k(s!|$}}|jDcgc]"}|jtj k(s!|$}}|j} td| dz } |rF|jdt|d|d| D] } |jd| j"|rF|jdt|d|d| D] } |jd| j"|rF|jdt|d|d| D] } |jd| j"|rF|jd t|d|d| D] } |jd| j"|s|s|s|s|jd |Scc}wcc}wcc}wcc}w) zFormat alerts sectionzAlerts:rz CRITICAL (z):Nz - z ERROR (z WARNING (z INFO (z No alerts) alertslevelrCRITICALERRORWARNINGINFOrmaxrQrmessage) rEr<r#r^ar error_alertswarning_alerts info_alerts max_alertsmax_infoalerts r(r|z*StatusDisplayEngine._format_alerts_sections"%;'-mmVqww*BUBU7U1VV#)==PaAGGz?O?O4OP P%+]]TaggASAS6S!TT"(--NQ177joo3MqN N00 q*q.)  LL<O(<'=R@ A(*5 7 vemm_56 7  LL9S%6$7r: ;%kz2 7 vemm_56 7  LL;s>':&;2> ?' 4 7 vemm_56 7  LL8C $4#5R8 9$Yh/ 7 vemm_56 7 <>[ LL ' AWPTNs."H6H6 "H;,H;"I#I7"II)__name__ __module__ __qualname____doc__r r r rrFr>r?rBr@rArDrstrrvrwrrzr|rr9r(r;r;Osr *"*-:*BM*Wk* **ll|S 4,4PS9$ , 49 %\%CW%\`ad\e%r9r;N)rtypingrr#rconfig.schemasr tools.loggerrenumsrr r modelsr r r)rr;rr9r(rsn/#99 G ? ?[?Rf?@00k0Sg02hhr9