iMdUdZddlmZddlZddlZddlZddlZddlmZm Z ddl m Z m Z m Z mZejeZdZdZdZd Zd Zd ZeGd d Zd.dZiZded<d/dZd0dZd1dZd2dZd3dZ ej!d ej"Z#d4d#Z$ed$d5d*Z%Gd+d,Z&gd-Z'dS)6unPersistent session goals — the Ralph loop for Hermes. A goal is a free-form user objective that stays active across turns. After each turn completes, a small judge call asks an auxiliary model "is this goal satisfied by the assistant's last response?". If not, Hermes feeds a continuation prompt back into the same session and keeps working until the goal is done, turn budget is exhausted, the user pauses/clears it, or the user sends a new message (which takes priority and pauses the goal loop). State is persisted in SessionDB's ``state_meta`` table keyed by ``goal:`` so ``/resume`` picks it up. Design notes / invariants: - The continuation prompt is just a normal user message appended to the session via ``run_conversation``. No system-prompt mutation, no toolset swap — prompt caching stays intact. - Judge failures are fail-OPEN: ``continue``. A broken judge must not wedge progress; the turn budget is the backstop. - When a real user message arrives mid-loop it preempts the continuation prompt and also pauses the goal loop for that turn (we still re-judge after, so if the user's message happens to complete the goal the judge will say ``done``). - This module has zero hard dependency on ``cli.HermesCLI`` or the gateway runner — both wire the same ``GoalManager`` in. Nothing in this module touches the agent's system prompt or toolset. ) annotationsN) dataclassasdict)AnyDictOptionalTupleg>@ia[Continuing toward your standing goal] Goal: {goal} Continue working toward this goal. Take the next concrete step. If you believe the goal is complete, state so explicitly and stop. If you are blocked and need input from the user, say so clearly and stop.uYou are a strict judge evaluating whether an autonomous agent has achieved a user's stated goal. You receive the goal text and the agent's most recent response. Your only job is to decide whether the goal is fully satisfied based on that response. A goal is DONE only when: - The response explicitly confirms the goal was completed, OR - The response clearly shows the final deliverable was produced, OR - The response explains the goal is unachievable / blocked / needs user input (treat this as DONE with reason describing the block). Otherwise the goal is NOT done — CONTINUE. Reply ONLY with a single JSON object on one line: {"done": , "reason": ""}zNGoal: {goal} Agent's most recent response: {response} Is the goal satisfied?ceZdZUdZded<dZded<dZded<eZded <d Z d ed <d Z d ed <dZ ded<dZ ded<dZ ded<ddZeddZdS) GoalStatez+Serializable goal state stored per session.strgoalactivestatusrint turns_used max_turnsfloat created_at last_turn_atN Optional[str] last_verdict last_reason paused_reasonreturncHtjt|dS)NF) ensure_ascii)jsondumpsrselfs 5/home/ubuntu/.hermes/hermes-agent/hermes_cli/goals.pyto_jsonzGoalState.to_jsongsz&,,U;;;;raw 'GoalState'c @tj|}||dd|ddt|ddpdt|dtptt |dd pd t |d d pd |d |d |d  S)Nrrrrrrrrrrrr) rrrrrrrrr)rloadsgetrDEFAULT_MAX_TURNSr)clsr&datas r# from_jsonzGoalState.from_jsonjsz#s&"%%88Hh//488L!449::$((;0ABBWFWXXTXXlC88?C@@txx<<CDD.11//((?33    r%rr )r&r rr')__name__ __module__ __qualname____doc____annotations__rrr,rrrrrrr$ classmethodr/r%r#r r Ys55 IIIFJ&I&&&&JL"&L&&&&!%K%%%%#'M''''<<<<    [    r%r session_idr rc d|S)Nzgoal:r7)r8s r# _meta_keyr:s :  r%Dict[str, Any] _DB_CACHE Optional[Any]c ddlm}ddlm}t |}n3#t $r&}t d|Yd}~dSd}~wwxYwt |}||S |}n3#t $r&}t d|Yd}~dSd}~wwxYw|t|<|S)aReturn a SessionDB instance for the current HERMES_HOME. SessionDB has no built-in singleton, but opening a new connection per /goal call would thrash the file. We cache one instance per ``hermes_home`` path so profile switches still pick up the right DB. Defensive against import/instantiation failures so tests and non-standard launchers can still use the GoalManager. r)get_hermes_home) SessionDBz,GoalManager: SessionDB bootstrap failed (%s)Nz$GoalManager: SessionDB() raised (%s)) hermes_constantsr? hermes_stater@r Exceptionloggerdebugr<r+)r?r@homeexccacheddbs r#_get_session_dbrJs444444******??$$%%  CSIIIttttt]]4 F   Y[[  ;SAAAtttttIdO Is,#& AAA8 B B3 B..B3Optional[GoalState]c|sdSt}|dS |t|}n3#t$r&}td|Yd}~dSd}~wwxYw|sdS t |S#t$r'}td||Yd}~dSd}~wwxYw)z4Load the goal for a session, or None if none exists.Nz GoalManager: get_meta failed: %sz3GoalManager: could not parse stored goal for %s: %s) rJget_metar:rCrDrEr r/warning)r8rIr&rGs r# load_goalrOs t   B ztkk)J//00  7===ttttt t""3''' LjZ]^^^ttttts-"; A+A&&A+3B B>B99B>stateNonec|sdSt}|dS |t||dS#t$r&}t d|Yd}~dSd}~wwxYw)z5Persist a goal to SessionDB. No-op if DB unavailable.Nz GoalManager: set_meta failed: %s)rJset_metar:r$rCrDrE)r8rPrIrGs r# save_goalrTs    B z> Ij))5==??;;;;; >>> 7=========>s5A A?A::A?cZt|}|dSd|_t||dS)zDMark a goal cleared in the DB (preserved for audit, status=cleared).Ncleared)rOrrT)r8rPs r# clear_goalrWs6 j ! !E }EL j%     r%textlimitrcN|sdSt||kr|S|d|dzS)Nr)u… [truncated])len)rXrYs r# _truncater\s9 r 4yyE <+ ++r%z\{.*?\}r&Tuple[bool, str]ch|sdS|}|dr=|d}|d}|dkr ||dzd}d} tj|}ng#t $rZt |}|r; tj|d}n#t $rd}YnwxYwYnwxYwt|tsd d t|d fS| d }t|tr)|d v}nt|}t| dpd}|sd}||fS)zdParse the judge's reply. Fail-open to ``(False, "")``. Returns ``(done, reason)``. )Fzjudge returned empty responsez```` NrFzjudge reply was not JSON: done)trueyes1rdreasonr)zno reason provided)strip startswithfindrr*rC_JSON_OBJECT_REsearchgroup isinstancedictr\r+r lowerbool)r&rXnlr.matchdone_valrdrhs r#_parse_judge_responservs 655 99;;D u!zz# YYt__ 88Q=D&*D z$ &&t,,   z%++a..11      dD ! !KJ9S#3F3FJJJJxxH(C  ~~%%''+GGH~~ (##)r * * 0 0 2 2F &% <s6.B&C'*'CC' C!C' C!!C'&C')timeoutr last_responserwrTuple[str, str]c|sdS|sdS ddlm}n3#t$r&}td|Yd}~dSd}~wwxYw |d\}}n3#t$r&}td |Yd}~dSd}~wwxYw||sd St t|d t|t } |j j |d tdd|dgdd|}nK#t$r>}td|ddt|jfcYd}~Sd}~wwxYw |jdjjpd} n#t$rd} YnwxYwt)| \} } | rdnd} td| t| d| | fS)ukAsk the auxiliary model whether the goal is satisfied. Returns ``(verdict, reason)`` where verdict is ``"done"``, ``"continue"``, or ``"skipped"`` (when the judge couldn't be reached). This is deliberately fail-open: any error returns ``("continue", "...")`` so a broken judge doesn't wedge progress — the turn budget is the backstop. )skippedz empty goal)continuez$empty response (nothing to evaluate)r)get_text_auxiliary_clientz.goal judge: auxiliary client import failed: %sN)r|zauxiliary client unavailable goal_judgez0goal judge: get_text_auxiliary_client failed: %s)r|zno auxiliary client configuredi)rresponsesystem)rolecontentuserrc)modelmessages temperature max_tokensrwu@goal judge: API call failed (%s) — falling through to continuer|z judge error: r)rdz goal judge: verdict=%s reason=%sx)riagent.auxiliary_clientr}rCrDrEJUDGE_USER_PROMPT_TEMPLATEformatr\_JUDGE_RESPONSE_SNIPPET_CHARSchat completionscreateJUDGE_SYSTEM_PROMPTinfotyper1choicesmessagerrv) rrxrwr}rGclientrpromptrespr&rdrhverdicts r# judge_goalr s ::<<'&&    BAA:DDDDDDD ::: EsKKK999999::11,??  ::: GMMM999999:~U~;; ' . . tT " "=*GHH/F @{&--!.ABBF33.    @@@ VX[\\\?499+=?????????@l1o%-3 )--LD&,ff*G KK2GYvs=S=STTT F?s\5 A%A  A%)A88 B(B##B(/1D!! E)+3E$E)$E)-F FFceZdZdZedd'dZed(d Zd)d Zd)d Z d*dZ ddd+dZ d,d-dZ ddd.dZ d/dZd0dZdd d1d$Zd2d&ZdS)3 GoalManagerufPer-session goal state + continuation decisions. The CLI and gateway each hold one ``GoalManager`` per live session. Methods: - ``set(goal)`` — start a new standing goal. - ``clear()`` — remove the active goal. - ``pause()`` / ``resume()`` — explicit user controls. - ``status()`` — printable one-liner. - ``evaluate_after_turn(last_response)`` — call the judge, update state, and return a decision dict the caller uses to drive the next turn. - ``next_continuation_prompt()`` — the canonical user-role message to feed back into ``run_conversation``. )default_max_turnsr8r rrcr||_t|pt|_t ||_dSN)r8rr,rrO_state)r"r8rs r#__init__zGoalManager.__init__es3$!$%6%K:K!L!L+4Z+@+@ r%rrKc|jSr)rr!s r#rPzGoalManager.statels {r%rrc4|jduo|jjdkS)Nrrrr!s r# is_activezGoalManager.is_activeps{$&I4;+=+IIr%c0|jduo |jjdvS)N)rpausedrr!s r#has_goalzGoalManager.has_goalss{$&U4;+=AU+UUr%c2|j}| |jdvrdS|jd|jd}|jdkr d|d|jS|jdkr"|jr d |jnd }d ||d|jS|jd kr d |d|jSd|jd|d|jS)N)rVz*No active goal. Set one with /goal ./z turnsru⊙ Goal (active, ): ru — r)u⏸ Goal (paused, rdu✓ Goal done (zGoal (z, )rrrrrr)r"sturnsextras r# status_linezGoalManager.status_linevs K 9L00??<55!+555 8x  :::!&:: : 8x  12H-AO---bEAAuAAAA A 8v  7U77qv77 7666E66af666r%N)rrr Optional[int]r c|pd}|stdt|dd|rt|n|jt jd}||_t|j||S)Nr)zgoal text is emptyrrr)rrrrrr) ri ValueErrorr rrtimerrTr8)r"rrrPs r#setzGoalManager.sets !!## 3122 2(1Mc)nnnt7My{{     $/5))) r% user-pausedrhc|jsdSd|j_||j_t|j|j|jS)Nr)rrrrTr8r"rhs r#pausezGoalManager.pausesA{ 4% $* !$/4;///{r%T) reset_budgetrc|jsdSd|j_d|j_|r d|j_t |j|j|jS)Nrr)rrrrrTr8)r"rs r#resumezGoalManager.resumesS{ 4% $( !  '%&DK "$/4;///{r%rQcr|jdSd|j_t|j|jd|_dS)NrV)rrrTr8r!s r#clearzGoalManager.clears8 ;  F& $/4;/// r%c|jsdSd|j_d|j_||j_t |j|jdS)Nrd)rrrrrTr8rs r# mark_donezGoalManager.mark_donesI{  F# #)  "( $/4;/////r%)user_initiatedrxrr;c |j}| |jdkr|r|jndddddddS|xjdz c_tj|_t |j|\}}||_||_|d kr(d |_t|j |d ddd |d |dS|j|j krNd |_d |jd |j d|_ t|j |d ddd|d|jd |j ddSt|j |dd| d|d|jd |j d|dS)uvRun the judge and update state. Return a decision dict. ``user_initiated`` distinguishes a real user prompt (True) from a continuation prompt we fed ourselves (False). Both increment ``turns_used`` because both consume model budget. Decision keys: - ``status``: current goal status after update - ``should_continue``: bool — caller should fire another turn - ``continuation_prompt``: str or None - ``verdict``: "done" | "continue" | "skipped" | "inactive" - ``reason``: str - ``message``: user-visible one-liner to print/send NrFinactivezno active goalr))rshould_continuecontinuation_promptrrhrrbrdu✓ Goal achieved: rzturn budget exhausted (r)r|u⏸ Goal paused — zD turns used. Use /goal resume to keep going, or /goal clear to stop.Tu↻ Continuing toward goal (r)rrrrrrrrrrTr8rrnext_continuation_prompt)r"rxrrPrrhs r#evaluate_after_turnzGoalManager.evaluate_after_turns(  =ELH44*/9%,,T#('+%*   A!Y[[$UZ??$" f  !EL dou - - - #('+! 999    u . .#EL"aErs2:#"""""  ))))))))------------  8 $ $ $P I"          J     <* > > > >!!!!,,,,"*Z33****b+ @@@@@@PwJwJwJwJwJwJwJwJt   r%