߲j UdZddlZddlmZddlmZdZdZejZ eZ de d<d e d dfd Z d e d ee fd ZddZy)abBuilder-declared stable prefixes for Anthropic prompt caching. Skill/webhook/cron builders concatenate a large static scaffold with a small volatile tail into one user-message string. Only the builder knows where the tail begins, so it registers the stable prefix here and the cache planner places a breakpoint at that boundary. Re-parsing marker strings at request time is deliberately avoided: markers can legitimately appear inside skill bodies, and any delimiter heuristic then shrinks the cached prefix or absorbs volatile bytes. Process-local by design: any miss falls back to the whole-message policy. N) OrderedDict)Optional i@zOrderedDict[str, None] _prefixesprefixreturnc|syt5dt|<tj|tttkDr-tj dtttkDr-ttdkDrqt ttttkDrMtj dttdkDr%t ttttkDrMdddy#1swYyxYw)zARecord ``prefix`` as the stable scaffold of a just-built message.NF)last) _lockr move_to_endlen _MAX_ENTRIESpopitemsummap _MAX_CHARS)rs @/home/ubuntu/.hermes/hermes-agent/agent/prompt_cache_boundary.pyregister_stable_prefixrs  * &f%)n|+   5  ))n|+)nq SS))<%= %J   5  ))nq SS))<%= %J ***sA!C8,BC88Dcontentct5d}tD]M}|j|s|t|dj s2|t|t|kDsL|}O|tj ||cdddS#1swYyxYw)aaLongest registered *proper* prefix of ``content`` with a non-whitespace tail. The tail must be non-whitespace so the split never yields an empty text block (Anthropic rejects it with HTTP 400). A hit refreshes the entry's LRU position so a scaffold fired every minute by cron is not evicted by a burst of one-off skill invocations. N)r r startswithrstripr )rbestrs rfind_stable_prefixr's  " F""6*CKL)//1\S[3t9%<      ! !$ '   sBBBBB cbt5tjdddy#1swYyxYw)zTest isolation helper.N)r rclearrclear_stable_prefixesr Bs$ s%.)rN)__doc__ threading collectionsrtypingrrrLockr r__annotations__strrrr rrrr(sm #   &1m #3 *3 *4 * 6r