߲jdZddlmZddlZddlZddlmZddlmZddl m Z m Z m Z dZ dZGd d eeZdd Zdd Zdd ZddZdddd ddZy)a1Shared session activity observation contract: timestamp + bounded description/provenance, observation only (notification, timeout, kill and retry policy live elsewhere). Provenance is a small closed enum of *noun* sources; the default agent clock stamps ``unknown`` unless a writer passes ``provenance=``.) annotationsN)suppress)Enum)AnyMappingOptionalxgN@c$eZdZdZdZdZdZdZdZy)ActivityProvenancez3Where a durable/in-memory activity stamp came from.unknownzagent.compressionzagent.compression_timeoutzagent.compression_cooldownzagent.compression_turnholdN) __name__ __module__ __qualname____doc__UNKNOWNAGENT_COMPRESSIONAGENT_COMPRESSION_TIMEOUTAGENT_COMPRESSION_COOLDOWNAGENT_COMPRESSION_TURNHOLD;/home/ubuntu/.hermes/hermes-agent/agent/session_activity.pyr r s$=G, ;!=!=rr cp|xsdj}t|tkr|S|dtdz dzS)z?Clamp free-form activity text to the shared description budget.Nu…)striplenACTIVITY_DESCRIPTION_MAX) descriptiontexts rbound_activity_descriptionr!!sA  2 $ $ &Dt9 884jdCaE]`aEa>bej>jjrct|tr|S t|xsdjS#t$rtjcYSwxYw)zBReturn a known provenance, or ``UNKNOWN`` when unset/unrecognized.r) isinstancer r ValueErrorr) provenances rnormalize_activity_provenancer&'sL*01*!:#3":":"<== *!)))*s1A  A c t|}|tjk\rd|Sd|d|S#ttf$rtj}YAwxYw)a3``iteration N/M`` for user-facing status lines, or ``iteration N`` when the cap is unbounded. ``AIAgent.max_iterations`` defaults to ``sys.maxsize`` (unlimited), so printing the pair verbatim shows ``iteration 3/9223372036854775807`` in busy acks, heartbeats and timeout diagnostics (#102806). z iteration /)int TypeErrorr$sysmaxsize)api_call_countmax_iterationscaps rformat_iteration_progressr01s` .! ckkN+,, 'q .. z "kks -AAcZtt5d|_dddy#1swYyxYw)zClear the persist rate-limit so the next stamp writes through (terminal compression labels must not stick on mid-compress text).gN)r Exception#_session_activity_last_persist_mono)agents r%reset_session_activity_persist_windowr5@s' ) 8471888s!*)last_activity_provenancenowextrac | t|nd}t||ntj}t|}t|j}||||t ||z dnd||||d|xsiS)zABuild the shared activity snapshot (plus optional caller extras).Nr)last_activity_atlast_activity_descriptionr6seconds_since_activitylast_activity_tslast_activity_descrr%)floattimer!r&valueround) r:r;r6r7r8whenclockdescprovs rbuild_activity_snapshotrGFs'7&B5! "D #diik :E %&? @D ()A B H HD %)$(<@rSsf# )) 37/ >d >k * /8DH)- % -A    ' r