Bj4dZddlZddlZddlZddlmZddlmZddlm Z m Z ddl m Z m Z daejZdZd Zd Zd ed dfd Zd,dZd,dZeGddej0ZddddddZdddddddde ede ede ede ede eded efdZd,d ZGd!d"eZdd#d$ej@d%ed&ed'eded(ejBd)e ej0d dfd*Z"d+Z#y)-u!Centralized logging setup for Hermes Agent. Provides a single ``setup_logging()`` entry point that both the CLI and gateway call early in their startup path. All log files live under ``~/.hermes/logs/`` (profile-aware via ``get_hermes_home()``). Log files produced: agent.log — INFO+, all agent/tool/session activity (the main log) errors.log — WARNING+, errors and warnings only (quick triage) gateway.log — INFO+, gateway-only events (created when mode="gateway") All files use ``RotatingFileHandler`` with ``RedactingFormatter`` so secrets are never written to disk. Component separation: gateway.log only receives records from ``gateway.*`` loggers — platform adapters, session management, slash commands, delivery. agent.log remains the catch-all (everything goes there). Session context: Call ``set_session_context(session_id)`` at the start of a conversation and ``clear_session_context()`` when done. All log lines emitted on that thread will include ``[session_id]`` for filtering/correlation. N)RotatingFileHandler)Path)OptionalSequence)get_config_pathget_hermes_homeFz>%(asctime)s %(levelname)s%(session_tag)s %(name)s: %(message)szC%(asctime)s - %(name)s - %(levelname)s%(session_tag)s - %(message)s)openaizopenai._base_clienthttpxhttpcoreasynciohpackz hpack.hpackgrpcmodalurllib3zurllib3.connectionpool websocketscharset_normalizer markdown_it session_idreturnc|t_y)zSet the session ID for the current thread. All subsequent log records on this thread will include ``[session_id]`` in the formatted output. Call at the start of ``run_conversation()``. N_session_contextr)rs 3/home/ubuntu/.hermes/hermes-agent/hermes_logging.pyset_session_contextrHs #-cdt_y)z,Clear the session ID for the current thread.Nrrrclear_session_contextrQs "&rctjtddryfd}d|_tj|y)ubReplace the global LogRecord factory with one that adds ``session_tag``. Unlike a ``logging.Filter`` on a handler or logger, the record factory runs for EVERY record in the process — including records that propagate from child loggers and records handled by third-party handlers. This guarantees ``%(session_tag)s`` is always available in format strings, eliminating the KeyError that would occur if a handler used our format without having a ``_SessionFilter`` attached. Idempotent — checks for a marker attribute to avoid double-wrapping if the module is reloaded. _hermes_session_injectorFNcf|i|}ttdd}|r d|d|_|Sd|_|S)Nrz [])getattrr session_tag)argskwargsrecordsidcurrent_factorys r_session_record_factoryz@_install_session_record_factory.._session_record_factoryksG $1&1& d;,/r#a[ 68 rT)logginggetLogRecordFactoryr$r setLogRecordFactory)r+r*s @r_install_session_record_factoryr/ZsB113O :EB 8<4  78rcVeZdZdZdeeddffd Zdejde fdZ xZ S)_ComponentFilterzOnly pass records whose logger name starts with one of *prefixes*. Used to route gateway-specific records to ``gateway.log`` while keeping ``agent.log`` as the catch-all. prefixesrNcBt|t||_yN)super__init__tuple _prefixes)selfr2 __class__s rr6z_ComponentFilter.__init__s xrr(cL|jj|jSr4)name startswithr8)r9r(s rfilterz_ComponentFilter.filters{{%%dnn55r) __name__ __module__ __qualname____doc__rstrr6r, LogRecordboolr> __classcell__r:s@rr1r1~s8 )#)4)6W..646rr1)gateway)agent run_agent model_tools batch_runner)tools) hermes_clicli)cron)rHrIrMrOrP) hermes_home log_level max_size_mb backup_countmodeforcerQrRrSrTrUrVc h|xs t}|dz }|jddt\}} } |xs|xsdj} t t | t j } |xs| xsddzdz} |xs| xsd}dd lm}t j}t||d z | | ||t t||d z t jd d|t |dk(r=t||dz t j dd|tttdtr|s|S|j t j"k(s|j | kDr|j%| t&D]4}t j|j%t j6da|S)uConfigure the Hermes logging subsystem. Safe to call multiple times — the second call is a no-op unless *force* is ``True``. Parameters ---------- hermes_home Override for the Hermes home directory. Falls back to ``get_hermes_home()`` (profile-aware). log_level Minimum level for the ``agent.log`` file handler. Accepts any standard Python level name (``"DEBUG"``, ``"INFO"``, ``"WARNING"``). Defaults to ``"INFO"`` or the value from config.yaml ``logging.level``. max_size_mb Maximum size of each log file in megabytes before rotation. Defaults to 5 or the value from config.yaml ``logging.max_size_mb``. backup_count Number of rotated backup files to keep. Defaults to 3 or the value from config.yaml ``logging.backup_count``. mode Caller context: ``"cli"``, ``"gateway"``, ``"cron"``. When ``"gateway"``, an additional ``gateway.log`` file is created that receives only gateway-component records. force Re-run setup even if it has already been called. Returns ------- Path The ``logs/`` directory where files are written. logsTparentsexist_okINFOirRedactingFormatterz agent.log)level max_bytesrT formatterz errors.logi rHz gateway.logiP)rarbrTrc log_filter)rmkdir_read_logging_configupperr$r,r\ agent.redactr` getLogger_add_rotating_handler _LOG_FORMATWARNINGr1COMPONENT_PREFIXES_logging_initializedraNOTSETsetLevel_NOISY_LOGGERS)rQrRrSrTrUrVhomelog_dir cfg_level cfg_max_size cfg_backup level_namerarbbackupsr`rootr<s r setup_loggingr{sT  +/+DVmG MM$M.+?*@'I|Z2y2F99;J GZ 6E1 1T9D@I-j-AG0    D +$[1  ,oo!$[1  y  m #,,%(5'(:9(EF E zzW^^#tzzE'9 e:$((9:  Nrcddlm}tj}|jD]=}t |tj st |tr/t|dds=ytj }|jtj|j|tdd|_ |j||jtjkDr|jtjt D]4}tj|jtj"6tjd jtj$y) zEnable DEBUG-level console logging for ``--verbose`` / ``-v`` mode. Called by ``AIAgent.__init__()`` when ``verbose_logging=True``. rr__hermes_verboseFNz%H:%M:%S)datefmtTz rex-deploy)rir`r,rjhandlers isinstance StreamHandlerrr$rqDEBUG setFormatter_LOG_FORMAT_VERBOSEr} addHandlerrarrrmr\)r`rzhhandlerr<s rsetup_verbose_loggingrs 0    D]] a.. / 1FY8Zq+U3 ##%G W]]# +,?TU"GOOG zzGMM! gmm$:$((9: l#,,W\\:rc<eZdZdZfdZdZfdZfdZxZS)_ManagedRotatingFileHandleruRotatingFileHandler that ensures group-writable perms in managed mode. In managed mode (NixOS), the stateDir uses setgid (2770) so new files inherit the hermes group. However, both _open() (initial creation) and doRollover() create files via open(), which uses the process umask — typically 0022, producing 0644. This subclass applies chmod 0660 after both operations so the gateway and interactive users can share log files. cHddlm}||_t||i|y)Nr) is_managed)hermes_cli.configr_managedr5r6)r9r&r'rr:s rr6z$_ManagedRotatingFileHandler.__init__4s!0"   $)&)rc~|jr" tj|jdyy#t$rYywxYw)Ni)roschmod baseFilenameOSError)r9s r_chmod_if_managedz-_ManagedRotatingFileHandler._chmod_if_managed9s; == **E2   s 0 <<cDt|}|j|Sr4)r5_openr)r9streamr:s rrz!_ManagedRotatingFileHandler._open@s   rcBt||jyr4)r5 doRolloverr)r9r:s rrz&_ManagedRotatingFileHandler.doRolloverEs   r) r?r@rArBr6rrrrFrGs@rrr*s!*  !!rr)reloggerpathrarbrcrec|j}|jD]<}t|tst t |ddj|k(s<y|j jddtt|||d} | j|| j||| j||j| y)aAdd a ``RotatingFileHandler`` to *logger*, skipping if one already exists for the same resolved file path (idempotent). Parameters ---------- log_filter Optional filter to attach to the handler (e.g. ``_ComponentFilter`` for gateway.log). rr#NTrYutf-8)maxBytes backupCountencoding)resolverrrrr$parentrfrrCrqr addFilterr) rrrarbrTrcreresolvedexistingrs rrkrkJs&||~HOO x!4 5WX~r:;CCEQ   KKdT2) D I<G U #*% grcx ddl}t}|jrt|dd5}|j |xsi}dddj di}t |tr2|j d|j d|j d fSy #1swY^xYw#t$rYy wxYw) uBest-effort read of ``logging.*`` from config.yaml. Returns ``(level, max_size_mb, backup_count)`` — any may be ``None``. rNrr)rr,rarSrT)NNN) yamlrexistsopen safe_loadgetrdict Exception)r config_pathfcfglog_cfgs rrgrgqs  %'    k39 .QnnQ'-2 .ggi,G'4(KK(KK .KK/  . .    s),B-B!AB-!B*&B-- B98B9)rN)$rBr,r threadinglogging.handlersrpathlibrtypingrrhermes_constantsrrrolocalrrlrrrrCrrr/Filterr1rnintrEr{rrLogger Formatterrkrgrrrrs2 0%= #9??$ O [,-C-D-'9: ! 6w~~ 6$ B   #'#!%"&g$g}g# g 3- g 3- g g gT;H!"5!P,0$ NN$ $  $  $  $  $($ $Nr