ei45dZddlZddlZddlZddlmZddlmZddlm Z m Z ddl m Z m Z daejZdZd Zd Zd ed dfd Zd,dZd,dZeGddejZddddddZdddddddde ede ede ede ede eded efdZd,d ZGd!d"eZdd#d$ej d%ed&ed'eded(ej!d)e ejd dfd*Z"d+Z#dS)-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_dS)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 0/home/div/.hermes/hermes-agent/hermes_logging.pyset_session_contextrHs #-cdt_dS)z,Clear the session ID for the current thread.Nrrrclear_session_contextrQs"&rctjtddrdSfd}d|_tj|dS)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_injectorFNcb|i|}ttdd}|rd|dnd|_|S)Nrz [])getattrr session_tag)argskwargsrecordsidcurrent_factorys r_session_record_factoryz@_install_session_record_factory.._session_record_factoryksG $1&11& d;;,/7[#[[[[R rT)logginggetLogRecordFactoryr$r setLogRecordFactory)r+r*s @r_install_session_record_factoryr/Zsi133O :EBB 8<4  788888rcReZdZdZdeeddffd 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. prefixesrNcptt||_dSN)super__init__tuple _prefixes)selfr2 __class__s rr6z_ComponentFilter.__init__s* xrr(c@|j|jSr4)name startswithr8)r9r(s rfilterz_ComponentFilter.filters{%%dn555r) __name__ __module__ __qualname____doc__rstrr6r, LogRecordboolr> __classcell__r:s@rr1r1~s~ )#)4))))))6W.6466666666rr1)gateway)agent run_agent model_tools batch_runner)tools) hermes_clicli)cron)rHrIrMrOrP) hermes_home log_level max_size_mb backup_countmodeforcerQrRrSrTrUrVc tr|s|p t}|dz S|p t}|dz }|ddt\}} } |p|pd} t t | t j} |p| pddzdz} |p| pd}dd lm }t j }t||d z | | ||t t||d z t j d d|t |dkrIt||dz t jdd|tttd|jt jks |j| kr|| t&D]3}t j |t j 4da|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)_logging_initializedrmkdir_read_logging_configupperr$r,r\ agent.redactr` getLogger_add_rotating_handler _LOG_FORMATWARNINGr1COMPONENT_PREFIXESraNOTSETsetLevel_NOISY_LOGGERS)rQrRrSrTrUrVhomelog_dir cfg_level cfg_max_size cfg_backup level_namerarbbackupsr`rootr<s r setup_loggingr{s)TE/o//f}  +/++DVmG MM$M...+?*@*@'I|Z2y2F99;;J GZ 6 6E1 1T9D@I-j-AG0/////    D +$$[11  ,o!$$[11  y  m #,%((55'(:9(EFF     zW^##tzE'9'9 e::$((9999 Nrcddlm}tj}|jD]E}t |tjr)t |tst|ddrdSFtj}| tj | |tdd|_ |||jtj kr| tj t D]3}tj| tj4tjd  tjdS) 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)rjr`r,rkhandlers isinstance StreamHandlerrr$rqDEBUG setFormatter_LOG_FORMAT_VERBOSEr} addHandlerrarrrnr\)r`rzhhandlerr<s rsetup_verbose_loggingrs` 0/////    D] a. / /  1FY8Z8Z q+U33 #%%G W]### ++,?TTTUUU"GOOG zGM!! gm$$$::$((9999 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. cdddlm}||_tj|i|dS)Nr) is_managed)hermes_cli.configr_managedr5r6)r9r&r'rr:s rr6z$_ManagedRotatingFileHandler.__init__5sD000000"  $)&)))))rcp|jr. tj|jddS#t$rYdSwxYwdS)Ni)roschmod baseFilenameOSError)r9s r_chmod_if_managedz-_ManagedRotatingFileHandler._chmod_if_managed:sX =  *E22222      s % 33cpt}||Sr4)r5_openr)r9streamr:s rrz!_ManagedRotatingFileHandler._openAs+     rcpt|dSr4)r5 doRolloverr)r9r:s rrz&_ManagedRotatingFileHandler.doRolloverFs1       r) r?r@rArBr6rrrrFrGs@rrr+s*****  !!!!!!!!!rr)reloggerpathrarbrcrec|}|jD]N}t|tr7t t |dd|krdSO|jddtt|||d} | || ||| || | dS)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$parentrgrrCrqr addFilterr) rrrarbrTrcreresolvedexistingrs rrlrlKs&||~~HO x!4 5 5 WX~r::;;CCEEQQ FFKdT222) D I<G U ###*%%% grc ddl}t}|rt|dd5}||pi}dddn #1swxYwY|di}t |tr>|d|d|d fSn#t$rYnwxYwd S) 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 rrhrhrs1   %''      k3999 .QnnQ''-2 . . . . . . . . . . . . . . .ggi,,G'4(( KK((KK ..KK//       s58CA CA""C%A"&A+C C C )rN)$rBr,r threadinglogging.handlersrpathlibrtypingrrhermes_constantsrrrflocalrrmrrrrCrrr/Filterr1rointrEr{rrLogger Formatterrlrhrrrrs2 000000%%%%%%%%======== #9?$$ O [,-C-D----''''9999: !!! 6 6 6 6 6w~ 6 6 6$ B   #'#!%"&hhh$h}h# h 3- h 3- h h hhhhV;;;;H!!!!!"5!!!P,0$$$ N$ $  $  $  $ $($ $$$$Nr