:j(<dZddlmZddlmZmZmZGddZy)a  Configuration Validator This module provides comprehensive validation for configuration objects. It ensures configuration completeness, correctness, and consistency. Key Features: - Type validation - Business rule validation - Dependency checking - Error reporting )List)ConfigLoadBalanceStrategy TaskConfigceZdZdZdZdeddfdZdeddfdZdeddfdZdeddfd Z deddfd Z d e ddfd Z deddfd Z deddfdZdeddfdZy)ConfigValidatorz1Configuration validator with comprehensive checkscg|_y)z"Initialize configuration validatorN)errors)selfs 7/root/.openclaw/workspace/harvester/config/validator.py__init__zConfigValidator.__init__s !# configreturnNc|jj|j||j||j ||j ||j ||j||j||jr0ddjd|jDz}t|y)zValidate complete configuration Args: config: Configuration object to validate Raises: ValueError: If validation fails z!Configuration validation failed:  c3&K|] }d| yw)z- N).0errors r z+ConfigValidator.validate..>sHoZ_2eWHosN) r clear_validate_global_config_validate_pipeline_config_validate_monitoring_config_validate_tasks_config_validate_worker_manager_config_validate_rate_limits_validate_display_configjoin ValueError)r r error_msgs r validatezConfigValidator.validates  $$V, &&v. ((0 ##F+ ,,V4 ""6* %%f- ;;,> KK  V W   ': : KK  !@AUAU@VW X(( KK  I J  - - 1 KK  J K 2rc|j}hd}|D]}||jvr|jjd|n1|j|dkr|jjd|d||jvr|jjd||j|dks|jjd|dy) zhValidate pipeline configuration section Args: config: Configuration object >checkgathersearchinspectz Missing thread count for stage: rzThread count for z must be positivezMissing queue size for stage: zQueue size for N)pipelinethreadsr r( queue_sizes)r rr5required_stagesstages r rz)ConfigValidator._validate_pipeline_config^s ??B$ OEH,,, ""%EeW#MN!!%(A- ""%6ug=N#OPH000 ""%CE7#KL%%e,1 ""_UG;L#MN Orc|j}|jdkr|jjdd|jcxkrdksn|jjd|j dkr|jjd|j dkr|jjd|jdkr|jjdyy) zjValidate monitoring configuration section Args: config: Configuration object rz+Monitoring update interval must be positiverz'Error threshold must be between 0 and 1z$Queue threshold must be non-negativez!Memory threshold must be positivez#Response threshold must be positiveN) monitoringupdate_intervalr r(error_thresholdqueue_thresholdmemory_thresholdresponse_threshold)r rr;s r rz+ConfigValidator._validate_monitoring_configts &&  % % * KK  L MZ//414 KK  H I  % % ) KK  E F  & &! + KK  B C  ( (A - KK  D E .rc|js|jjd|jDcgc]}|js|}}|s|jjd|jDcgc]}|js|j}}t |t t |k7r|jjd|jD]}|j|ycc}wcc}w)zeValidate tasks configuration section Args: config: Configuration object z$At least one task must be configuredz!At least one task must be enabledzTask names must be uniqueN)tasksr r(enablednamelenset_validate_task)r rtask enabled_tasks task_namess r rz&ConfigValidator._validate_tasks_configs || KK  E F*0,,G$$,,G G KK  B C-3LLIDDLLdiiI I z?c#j/2 2 KK  : ;LL &D    % &H JsC9C99C> C>rHc|jsy|js|jjd|js(|jjd|j|j j r?|j js)|jjd|jd |jj|js)|jjd|jyt|jD]\}}|jjs.|jjd|d zd |j|jrW|jjrn|jjd |d zd |jy#t$r6}|jjd|jd|Yd}~#d}~wwxYw) zjValidate individual task configuration Args: task: Task configuration object NzTask name cannot be emptyz(Provider type cannot be empty for task: zTask z( storage.plan requires storage.directoryz stage validation failed: z*At least one condition required for task: z#Key pattern required for condition rz in task: z3Either query or key_pattern required for condition )rCrDr r( provider_typestorageplan directorystagesr$r" conditions enumeratepatterns key_patternquery)r rHei conditions r rGzConfigValidator._validate_tasks || yy KK  : ;!! KK  !I$))U V <<  T\\%;%; KK  tyyk1YZ [ Q KK "  KK  !KDII;W X!*$// : y 9 ))55KK&&)LQqSEQ[\`\e\e[f'gh y/A/A/M/MKK&&)\]^_`]`\aaklplulukv'wx  y Q KK  tyyk1KA3O P P Qs?G H +G<<Hc|j}|jdkr|jjd|j|jkr|jjd|j dkr|jjd|j dkr|jjdd|jcxkrdksn|jjdd|jcxkrdksn|jjd|j|jk\r|jjd y y ) zfValidate worker manager configuration Args: config: Configuration object rz-Worker manager min_workers must be at least 1z1Worker manager max_workers must be >= min_workersrz5Worker manager target_queue_size must be non-negativez3Worker manager adjustment_interval must be positivez9Worker manager scale_up_threshold must be between 0 and 1z;Worker manager scale_down_threshold must be between 0 and 1z@Worker manager scale_down_threshold must be < scale_up_thresholdN) worker min_workersr r( max_workerstarget_queue_sizeadjustment_intervalscale_up_thresholdscale_down_threshold)r rworker_managers r rz/ConfigValidator._validate_worker_manager_configs    % % ) KK  N O  % %(B(B B KK  R S  + +a / KK  V W  - - 2 KK  T UN5599 KK  Z [N77;!; KK  \ ]  . ..2S2S S KK  a b Trch|jjD]\}}|jdkr|jj d||j dkr|jj d|d|j cxkrdkrvn|jj d|y)zcValidate rate limits configuration Args: config: Configuration object rz+Base rate must be positive for rate limit: z-Burst limit must be positive for rate limit: rz7Backoff factor must be between 0 and 1 for rate limit: N) ratelimitsitems base_rater r( burst_limitbackoff_factor)r rrD rate_limits r rz%ConfigValidator._validate_rate_limitss !' 1 1 7 7 9 e D*##q( ""%PQUPV#WX%%* ""%RSWRX#YZ 115A5 ""%\]a\b#cd erc|js|jjdy|jjs|jjdy|jjj D]h\}}|s|jjd|(|j D]-\}}d|d|d}|j dkr|jj|d n[|j d kr|jj|d n-|j d kDr|jj|d |j dkr|jj|dn-|j dkDr|jj|d|jjr|jj|d0ky)zkValidate display configuration Args: config: Configuration object to validate z Display configuration is missingNz)Display contexts configuration is missingz)No display modes configured for context: zDisplay config [.]rz: width must be positive(z(: width should be at least 40 charactersz(: width should not exceed 200 charactersz': max_alerts_per_level must be positivez+: max_alerts_per_level should not exceed 20z: title cannot be empty) displayr r(contextsrdwidthmax_alerts_per_leveltitlestrip)r r context_name context_modes mode_name mode_configprefixs r r z(ConfigValidator._validate_display_configs ~~ KK  A B ~~&& KK  J K ,2>>+B+B+H+H+J K 'L-  ""%N|n#]^*7*=*=*? K& ;+L>9+QG$$)KK&&&1I'JK &&+KK&&&1Y'Z[ &&,KK&&&1Y'Z[33q8KK&&&1X'YZ 55:KK&&&1\']^#((..0KK&&&1H'IJ' K  Kr)__name__ __module__ __qualname____doc__rrr$rrrrrrGrrr rrr r r s;$#(v#($#(JLfLL:OO4O,F&FTF.&V&&,"y:"y$"yHcfcc:eFete 'Kv'K$'Krr N)r}typingrschemasrrrr rrr rs# <<DKDKr