Pmj+hUdZddlmZddlmZmZddlmZgdZdZ dZ dZ id d d d d d ddddddddddddddddddd d!d"d#d$d%d&d'Z d(e d)<d*Zd+Zd,e d-<ed hZeGd.d/ZdQd4ZdRd9ZGd:d;ZdSd>ZdTdBZdUdEZe dFdVdJZdKdLdWdOZdPS)XuTPer-turn accounting for the interactive CLI. Two display-only pieces live here: * :class:`TurnSummaryCollector` — a tiny observer that rides the existing ``tool_progress_callback`` feed (``tool.completed`` events already carry the tool name and its raw result) and tallies what a turn actually did. It holds **no** agent-loop state: the display layer already sees every tool call, so nothing new is threaded through the conversation loop. * :func:`format_turn_summary` — a pure formatter that turns a tally plus a wall-clock duration into one dim line, e.g.:: ⋯ 12.4s · edited 2 files +18 -3 · read 4 files · ran 3 commands Ported from Claude Code's post-turn accounting line ("Edited 1 file +6 -2, read 1 file … Worked for 10s"). :func:`format_token_flow` is the spinner-side counterpart: a cumulative token readout appended to the live elapsed timer (``↓ 1.2k tok``). Everything in this module is pure/side-effect free apart from the collector's own counters, which makes it directly unit-testable without a terminal, an agent, or a network call. ) annotations) dataclassfield)Any)TurnSummaryCollector TurnTallyformat_turn_summaryformat_token_flowformat_elapsedu⋯g@ write_file)editedfilefilespatch read_file)readrr web_extract)rpagepagesterminal)rancommandcommands execute_code)rscriptscripts search_files)searchedpathpaths web_search)zsearched the webtimetimessession_search)zsearched sessionsr#r$browser_navigate)browsedrr skill_view)rskillskills skill_manage)updatedr)r* skills_list)z listed skillsr#r$todo)r,z task listz task lists delegate_task) delegatedtasktasksmemory)r,r3memorieszdict[str, tuple[str, str, str]] _VERB_GROUPSr)rrrztuple[str, ...]_VERB_PRIORITYceZdZUdZeeZded<dZded<dZ ded<dZ ded <d Z d ed <e ddZ dS)rz@What a single turn did, as observed from the tool-progress feed.)default_factoryzdict[str, dict[str, int]]verbsrint other_tools lines_added lines_removedFboolhas_line_deltasreturncvtd|jD}||jzS)Nc3XK|]%}t|V&dSN)sumvalues).0nounss 8/home/thesage/.hermes/hermes-agent/agent/turn_summary.py z(TurnTally.total_tools..is2KKec%,,..))KKKKKK)rDr9rEr;)selfcounteds rH total_toolszTurnTally.total_toolsgs:KKtz7H7H7J7JKKKKK)))rJN)r@r:)__name__ __module__ __qualname____doc__rdictr9__annotations__r;r<r=r?propertyrMrJrHrrXsJJ(-uT'B'B'BEBBBBKKM"O!!!! ***X***rJrdiffstrr@tuple[int, int]cdx}}|D]b}|ds|dr-|dr|dz }H|dr|dz }c||fS)zCount added/removed lines in unified-diff text. File headers (``+++``/``---``) are excluded so a one-line edit does not read as three additions. rz+++z---+-) splitlines startswith)rVaddedremovedlines rH_count_diff_linesrbms EG!! ??5 ! ! T__U%;%;   ??3    QJEE __S ! !  qLG '>rJ tool_nameresultrtuple[int, int] | Nonec|tvrdS|}t|trY|}|dsdS ddl}||d}n#t$rYdSwxYwt|tsdS| d}t|tr|sdSt|\}}|dkr|dkrdS||fS)uPull (added, removed) from a tool result, or None when unavailable. Only tools that already report a diff in their result payload are inspected — we never shell out to git and never re-read files to synthesise a delta. N{rF)strictrV) _DIFF_RESULT_TOOLS isinstancerWstripr^jsonloads ExceptionrRgetrb)rcrdpayloadtextrlrVr_r`s rH_extract_line_deltasrr~s***tG'3 }}s## 4  KKK jjej44GG   44  gt $ $t ;;v  D dC  t&t,,NE7 zzgllt '>sA++ A98A9cReZdZdZddZddZdddddZeddZddZ dS)raAccumulate per-turn tool tallies from the tool-progress feed. Wired into the CLI's existing ``_on_tool_progress`` handler: the display layer already receives every ``tool.completed`` event with the tool name and raw result, so no agent-loop bookkeeping is added. r@Nonec,t|_dSrCr_tallyrKs rH__init__zTurnSummaryCollector.__init__skk rJc,t|_dS)z+Start a fresh turn (drops any prior tally).Nrvrxs rHbeginzTurnSummaryCollector.beginskk rJNF)rdis_errorrc str | Nonerdrr|r>c|r|rdS|drdSt|}||jxjdz c_dS|\}}}|jj|i}||ddz||<|tkrOt||} | ?| \} } |jxj | z c_ |jxj | z c_ d|j_ dSdSdS)zRecord one completed tool call. Failed calls are skipped: a summary claiming "edited 2 files" when one write was denied would be exactly the over-claim the file-mutation verifier exists to catch. N_r[rT) r^r5rorwr;r9 setdefault _EDIT_VERBrrr<r=r?) rKrcrdr|groupverb _singularpluralrGdeltasr_r`s rH record_toolz TurnSummaryCollector.record_tools H  F    $ $  F  ++ = K # #q ( # # F"'i !,,T266 &!,,q0f :  ))V<r@rt)r@r)rrr@rW) rNrOrPrQryr{rrTrrrUrJrHrrs"""""""" "3"3"3"3"3"3HXAAAAAArJrsecondsrc|dkrd}|dkr|ddSttt|d\}}|d|ddS)z?Format a wall-clock duration compactly (``12.4s`` / ``2m05s``).rg<.1fsm02d)divmodr:round)rminutesrests rHr r sf{{||     3uW~~..33MGT # # # # # ##rJcountr: plural_nounc|dkri|}|dr|dddz}n?|dr |dd}n|dr |dd }d |S|d |S) zz"_ordered_verbs..s% < < .s":::Q!>"9"9q"9"9"9rJ)listr9keysr6)rseenrankeds` rH_ordered_verbsrsU    "" # #D < < < < < < .s,WWW}vuQVWE6**WWWrJrz, z +z -zcalled toolsrrZz moreu · )rrr9itemsjoinrr?r<r=appendr;rrM_MIN_TOOLLESS_SECONDSlenr SUMMARY_PREFIX) rrrsegmentsrrGpartssegmenthiddenpiecess rHr r s } Hu%%!! D!WW WWW  ..DIIe,,.. :  %"7  FE-FF1DFF FG     LJ*U->"H"HJJKKK )Q..?EZ3Z3ZraCMML88X-M\M*.?&.?.?.?-@@_-- . 9F   &++f"5"5 55rJu↓)arrow output_tokensrc t|}n#ttf$rYdSwxYw|dkrdS|dkr|d|dS|dkr |d|dz ddS|d|dz dd S) uRender cumulative turn tokens for the live spinner (``↓ 1.2k tok``). Returns ``""`` for a non-positive count so the spinner shows nothing rather than a misleading ``↓ 0 tok`` before the first API response lands. rrirz toki@Brzk tokzM tok)r: TypeError ValueError)rrrs rHr r &s M"" z "rr zzr t||%%%%%%% y11%$,11111 2 2ei' 2 2 2 22s ''N)rVrWr@rX)rcrWrdrr@re)rrr@rW)rr:rrWr@rW)rrr@r)rrrrrr:r@rW)rrrrWr@rW)rQ __future__r dataclassesrrtypingr__all__rr _MAX_SEGMENTSr5rSrr6 frozensetrirrbrrrr rrr r rUrJrHrs2#"""""((((((((    1-1 (1*1, 1 . 1 0 11171<141-12151 2131  /!1 ( #<;;;;Yy)) ******* *("""""J9A9A9A9A9A9A9A9Ax$$$$ $ $ $ $& $6$6$6$6$6$6N;@33333333rJ