i[hUdZddlmZddlZddlZddlZddlZddlmZm Z ddl m Z m Z m Z mZejeZdZdZdZd Zd Zd Zd ZeGd dZd/dZiZded<d0dZd1dZd2dZd3dZ d4d Z!ej"d!ej#Z$d5d$Z%ed%d6d+Z&Gd,d-Z'gd.Z(dS)7unPersistent 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<dZded<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_reasonconsecutive_parse_failuresreturncHtjt|dS)NF) ensure_ascii)jsondumpsrselfs 5/home/piyush/.hermes/hermes-agent/hermes_cli/goals.pyto_jsonzGoalState.to_jsonpsz&,,U;;;;raw 'GoalState'ctj|}||dd|ddt|ddpdt|dtptt |dd pd t |d d pd |d |d |d t|ddpd S)Nrrrrrrrrrrrrr) rrrrrrrrrr)r!loadsgetrDEFAULT_MAX_TURNSr)clsr(datas r% from_jsonzGoalState.from_jsonssz#s&"%%88Hh//488L!449::$((;0ABBWFWXXTXXlC88?C@@txx<<CDD.11//((?33'*4884PRS+T+T+YXY'Z'Z    r'rr)r(rrr))__name__ __module__ __qualname____doc____annotations__rrr.rrrrrrrr& classmethodr1r'r%r r as55 IIIFJ&I&&&&JL"&L&&&&!%K%%%%#'M''''&'''''<<<<    [    r'r session_idrrc d|S)Nzgoal:r9)r:s 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_constantsrA hermes_staterBr Exceptionloggerdebugr>r-)rArBhomeexccacheddbs r%_get_session_dbrLs444444******??$$%%  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) rLget_metar<rErFrGr r1warning)r:rKr(rIs r% load_goalrQs 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)rLset_metar<r&rErFrG)r:rRrKrIs r% save_goalrVs    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)rQrrV)r:rRs r% clear_goalrYs6 j ! !E }EL j%     r'textlimitrcN|sdSt||kr|S|d|dzS)Nr+u… [truncated])len)rZr[s r% _truncater^s9 r 4yyE <+ ++r'z\{.*?\}r(Tuple[bool, str, bool]cl|sdS|}|dr=|d}|d}|dkr ||dzd}d} tj|}ng#t $rZt |}|r; tj|d}n#t $rd}YnwxYwYnwxYwt|tsd d t|d d fS| d }t|tr)|dv}nt|}t| dpd}|sd}||d fS)aParse the judge's reply. Fail-open to ``(False, "", parse_failed)``. Returns ``(done, reason, parse_failed)``. ``parse_failed`` is True when the judge returned output that couldn't be interpreted as the expected JSON verdict (empty body, prose, malformed JSON). Callers use that flag to auto-pause after N consecutive parse failures so a weak judge model doesn't silently burn the turn budget. )Fzjudge returned empty responseTz```` NrFzjudge reply was not JSON: Tdone)trueyes1rfreasonr+zno reason provided)strip startswithfindr!r,rE_JSON_OBJECT_REsearchgroup isinstancedictr^r-rlowerbool)r(rZnlr0matchdone_valrfrjs r%_parse_judge_responserxs <;; 99;;D u!zz# YYt__ 88Q=D&*D z$ &&t,,   z%++a..11      dD ! !QJ9S#3F3FJJDPPxxH(C  ~~%%''+GGH~~ (##)r * * 0 0 2 2F &%  s6.B&C'*'CC' C!C' C!!C'&C')timeoutr last_responseryrTuple[str, str, bool]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|}nL#t$r?}td|ddt|jdfcYd}~Sd}~wwxYw |jdjjpd} n#t$rd} YnwxYwt)| \} } } | rdnd} td| t| d| | | fS)uAsk the auxiliary model whether the goal is satisfied. Returns ``(verdict, reason, parse_failed)`` where verdict is ``"done"``, ``"continue"``, or ``"skipped"`` (when the judge couldn't be reached). ``parse_failed`` is True only when the judge call succeeded but its output was unusable (empty or non-JSON). API/transport errors return False — they are transient and should fail-open silently. Callers use this flag to auto-pause after N consecutive parse failures (see ``DEFAULT_MAX_CONSECUTIVE_PARSE_FAILURES``). This is deliberately fail-open: any error returns ``("continue", "...", False)`` so a broken judge doesn't wedge progress — the turn budget and the consecutive-parse-failures auto-pause are the backstops. )skippedz empty goalF)continuez$empty response (nothing to evaluate)Fr)get_text_auxiliary_clientz.goal judge: auxiliary client import failed: %sN)r~zauxiliary client unavailableF goal_judgez0goal judge: get_text_auxiliary_client failed: %s)r~zno auxiliary client configuredFi)rresponsesystem)rolecontentuserre)modelmessages temperature max_tokensryu@goal judge: API call failed (%s) — falling through to continuer~z judge error: Fr+rfz goal judge: verdict=%s reason=%sx)rkagent.auxiliary_clientrrErFrGJUDGE_USER_PROMPT_TEMPLATEformatr^_JUDGE_RESPONSE_SNIPPET_CHARSchat completionscreateJUDGE_SYSTEM_PROMPTinfotyper3choicesmessagerrx)rrzryrrIclientrpromptrespr(rfrj parse_failedverdicts r% judge_goalrs* ::<<.--    IHHADDDDDDD AAA EsKKK@@@@@@AA11,??  AAA GMMM@@@@@@A~U~BB ' . . tT " "=*GHH/F G{&--!.ABBF33.    GGG VX[\\\?499+=??FFFFFFFGl1o%-3 "7s!;!;D&,,ff*G KK2GYvs=S=STTT FL ((s\5 A%A  A%)A88 B(B##B(/1D!! E*+4E%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_turnsr:rrrcr||_t|pt|_t ||_dSN)r:rr.rrQ_state)r$r:rs r%__init__zGoalManager.__init__ys3$!$%6%K:K!L!L+4Z+@+@ r'rrMc|jSr)rr#s r%rRzGoalManager.states {r'rtc4|jduo|jjdkS)Nrrrr#s r% is_activezGoalManager.is_actives{$&I4;+=+IIr'c0|jduo |jjdvS)N)rpausedrr#s r%has_goalzGoalManager.has_goals{$&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)rXz*No active goal. Set one with /goal ./z turnsru⊙ Goal (active, ): ru — r+u⏸ Goal (paused, rfu✓ Goal done (zGoal (z, )rrrrrr)r$sturnsextras r% status_linezGoalManager.status_lines 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) rk ValueErrorr rrtimerrVr:)r$rrrRs r%setzGoalManager.sets !!## 3122 2(1Mc)nnnt7My{{     $/5))) r' user-pausedrjc|jsdSd|j_||j_t|j|j|jS)Nr)rrrrVr:r$rjs r%pausezGoalManager.pausesA{ 4% $* !$/4;///{r'T) reset_budgetrc|jsdSd|j_d|j_|r d|j_t |j|j|jS)Nrr)rrrrrVr:)r$rs r%resumezGoalManager.resumesS{ 4% $( !  '%&DK "$/4;///{r'rScr|jdSd|j_t|j|jd|_dS)NrX)rrrVr:r#s r%clearzGoalManager.clears8 ;  F& $/4;/// r'c|jsdSd|j_d|j_||j_t |j|jdS)Nrf)rrrrrVr:rs r% mark_donezGoalManager.mark_donesI{  F# #)  "( $/4;/////r')user_initiatedrzrr=c Z|j}| |jdkr|r|jndddddddS|xjdz c_tj|_t |j|\}}}||_||_|r|xj dz c_ nd |_ |d kr(d |_t|j |d ddd |d |dS|j tkr>d |_d |j d|_ t|j |d ddd|d|j ddS|j|jkrNd |_d|jd|jd|_ t|j |d ddd|d|jd|jddSt|j |dd|d|d|jd|jd|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_promptrrjrrdrrfu✓ Goal achieved: rz(judge model returned unparseable output z turns in a rowr~u%⏸ Goal paused — the judge model (z turns) isn't returning the required JSON verdict. Route the judge to a stricter model in ~/.hermes/config.yaml: auxiliary: goal_judge: provider: openrouter model: google/gemini-3-flash-preview Then /goal resume to continue.zturn budget exhausted (r)u⏸ Goal paused — zD turns used. Use /goal resume to keep going, or /goal clear to stop.Tu↻ Continuing toward goal (r)rrrrrrrrrrrVr:&DEFAULT_MAX_CONSECUTIVE_PARSE_FAILURESrrnext_continuation_prompt)r$rzrrRrrjrs r%evaluate_after_turnzGoalManager.evaluate_after_turns{(  =ELH44*/9%,,T#('+%*   A!Y[[(25:}(M(M%$"  1  , , 1 , , ,/0E , f  !EL dou - - - #('+! 999    +/U U U#ELl5;[lll   dou - - -"#('+% 5E<\555 $  u . .#EL"aEr7rLrQrVrYr^compileDOTALLrnrxrr__all__r9r'r%rs::#"""""  ))))))))------------  8 $ $ $*+&P I"          N     <* > > > >!!!!,,,,"*Z33....j+ F)F)F)F)F)F)\]J]J]J]J]J]J]J]J@   r'