id dZddlZddlZddlZddlZddlZddlmZddlm Z m Z ddl Z ej e ZehdZd#de ded efd Zd$d eded efd Zded dfdZdeddd dfdZddde eefde dede d df dZddddde eefde dedededzd df dZd%dede d e fdZd&d eded efd!Zd#d eded efd"ZdS)'z*Shared utility functions for hermes-agent.N)Path)AnyUnion>1onyestrueFvaluedefaultreturnc||St|tr|St|tr-|t vSt|S)zDCoerce bool-ish values using the project's shared truthy string set.) isinstanceboolstrstriplowerTRUTHY_STRINGS)r r s -/home/agentuser/.hermes/hermes-agent/utils.pyis_truthy_valuers` }% %7{{}}""$$66 ;;namecJttj||dS)zBReturn True when an environment variable is set to a truthy value.Fr rosgetenv)rr s renv_var_enabledrs! 29T733U C C CCrpathz int | Nonec |r+tj|jndS#t$rYdSwxYw)zBCapture the permission bits of *path* if it exists, else ``None``.N)existsstatS_IMODEst_modeOSError)rs r_preserve_file_moder&#sV48KKMMKt|DIIKK/000tK ttsAA AAmodec\|dS tj||dS#t$rYdSwxYw)aRe-apply *mode* to *path* after an atomic replace. ``tempfile.mkstemp`` creates files with 0o600 (owner-only). After ``os.replace`` swaps the temp file into place the target inherits those restrictive permissions, breaking Docker / NAS volume mounts that rely on broader permissions set by the user. Calling this right after ``os.replace`` restores the original permissions. N)rchmodr%)rr's r_restore_file_moder*+sM |  t      s  ++)indentdatar, dump_kwargsc t|}|jddt|}t jt |jd|jdd\}} tj |dd 5}tj ||f|d d || tj |d d d n #1swxYwYtj||t!||d S#t"$r( tj|n#t&$rYnwxYwwxYw) aWrite JSON data to a file atomically. Uses temp file + fsync + os.replace to ensure the target file is never left in a partially-written state. If the process crashes mid-write, the previous version of the file remains intact. Args: path: Target file path (will be created or overwritten). data: JSON-serializable data to write. indent: JSON indentation (default 2). **dump_kwargs: Additional keyword args forwarded to json.dump(), such as default=str for non-native types. Tparentsexist_ok._.tmpdirprefixsuffixwutf-8encodingF)r, ensure_asciiN)rparentmkdirr&tempfilemkstemprstemrfdopenjsondumpflushfsyncfilenoreplacer* BaseExceptionunlinkr%)rr-r,r. original_modefdtmp_pathfs ratomic_json_writerQ<s( ::DKdT222'--M#   49LB  Yr3 1 1 1 !Q I "         GGIII HQXXZZ  ! ! ! ! ! ! ! ! ! ! ! ! ! ! ! 8T"""4/////   Ih        D  sU1DAC% D%C))D,C)-(D E "D76E 7 EE EE )default_flow_style sort_keys extra_contentrRrSrTct|}|jddt|}t jt |jd|jdd\}} tj |dd 5}tj |||| |r| || tj|d d d n #1swxYwYtj||t#||d S#t$$r( tj|n#t($rYnwxYwwxYw) anWrite YAML data to a file atomically. Uses temp file + fsync + os.replace to ensure the target file is never left in a partially-written state. If the process crashes mid-write, the previous version of the file remains intact. Args: path: Target file path (will be created or overwritten). data: YAML-serializable data to write. default_flow_style: YAML flow style (default False). sort_keys: Whether to sort dict keys (default False). extra_content: Optional string to append after the YAML dump (e.g. commented-out sections for user reference). Tr0r3r4r5r6r:r;r<)rRrSN)rr?r@r&rArBrrCrrDyamlrFwriterGrHrIrJr*rKrLr%) rr-rRrSrTrMrNrOrPs ratomic_yaml_writerXqs, ::DKdT222'--M#   49LB  Yr3 1 1 1 !Q IdA2DPY Z Z Z Z ' &&& GGIII HQXXZZ  ! ! ! ! ! ! ! ! ! ! ! ! ! ! ! 8T"""4/////   Ih        D  sU1D0A*C>2 D0>DD0D(D00 E";EE" EE"EE"textct tj|S#tjttf$r|cYSwxYw)zParse JSON, returning *default* on any parse error. Replaces the ``try: json.loads(x) except (JSONDecodeError, TypeError)`` pattern duplicated across display.py, anthropic_adapter.py, auxiliary_client.py, and others. )rEloadsJSONDecodeError TypeError ValueError)rYr s rsafe_json_loadsr_sEz$  )Z 8s 77keyctj|d}|s|S t|S#tt f$r|cYSwxYw)z:Read an environment variable as an integer, with fallback.r)rrrintr^r])r`r raws renv_intrdse )C   " " $ $C 3xx  "s<AAcJttj|d|S)z*Read an environment variable as a boolean.rrr)r`r s renv_boolrfs! 29S"--w ? ? ??r)F)r)N)r)__doc__rEloggingrr"rApathlibrtypingrrrV getLogger__name__logger frozensetrrrrrr&r*rbrQrXr_rdrfrrrps00    8 $ $555663$DD#DDTDDDD d| T  $    * 222 T 2 2  2  2  2222r % $ 000 T 0 0 0  0 : 0 0000l  #  s     s3@@#@@@@@@@@r