+Vj, UdZddlmZddlZddlZddlZddlZddlZddlm Z m Z m Z ddl m Z ddlmZmZmZmZmZejeZdZdZd Zd Zd Zd Zd ZdZdZdZ e!ee hZ"e!eee hZ#ede dediZ$dZ%dZ&dZ'dZ(dZ)dZ*dZ+dZ,dZ-dZ.e GddZ/e Gd d!Z0dd%Z1iZ2d&e3d'<dd)Z4dd+Z5dd.Z6dd/Z7dd1Z8dd2Z9dd3Z:dd6Z;dd:Z<ej=d;ej>Z?dd>Z@dd@ZAddBZBddDZCdEdFdGdHdIdJdKdLdMdNdOdLdPedQedOdRdSgdTdUdVZDd&e3dW<dEdXdYdHdZd[d\dHd7dId]dKid7gdTd^idZgdTdUdVZEd&e3d_<dEd`dadHd[dbdHdLdcdKdIddgdddIdedKdfgdfdTd^d[dgdHd7dIdhdKid7gdTd^dIdidKdjgdjdTdUdVZFd&e3dk<dNeddlddoZGddqZHdduZIddvZJdwdxddZKedddZLedddZMeedddZNddZOGddZPedddZQgdZRdS)u Persistent 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). Checklist mode (added 2026-05): when a goal is set, a Phase-A "decompose" call asks the judge to write an extremely detailed checklist of concrete completion criteria for that goal. On every subsequent turn (Phase B) the judge evaluates the agent's most recent output against EACH pending item and may flip pending → completed | impossible, or append new items it discovers along the way. The goal is done only when every checklist item is in a terminal status. This is much harsher than the freeform "is the goal done?" prompt and gives users a visible, verifiable progress surface via /subgoal. A bounded read_file tool loop lets the judge inspect the dumped conversation history when the snippet alone isn't enough to rule. 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``). - Stickiness: once an item is marked completed or impossible, only the user (via /subgoal undo) can flip it back. Judge updates that try to regress terminal items are silently ignored. - 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) dataclassfieldasdict)Path)AnyDictListOptionalTuplegN@ii}pending completed impossiblez[x]z[!]z[ ]judgeusera[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.u[Continuing toward your standing goal] Goal: {goal} Checklist progress ({done}/{total} done): {checklist} Work on the unchecked items above. Do not declare items done yourself — a judge marks them based on evidence in your output. If an item is genuinely impossible in this environment, explain why so the judge can mark it impossible. If you are blocked on a remaining item and need user input, say so clearly and stop.ulYou are a strict judge for an autonomous agent. Your first job, before judging anything, is to break the user's stated goal into an EXTREMELY DETAILED checklist of concrete, verifiable completion criteria. Each item must be specific enough that a third party reading the agent's output could decide unambiguously whether that item was achieved. Be exhaustive. Bias toward MORE items, not fewer. Include sub-items, edge cases, quality bars, deployment steps, verification checks, and anything the user would reasonably expect from a goal of this type. If the user said 'build me a website' you should be enumerating homepage exists, navigation links work, content is non-placeholder, mobile responsive, accessibility tags present, deployed somewhere publicly accessible, domain/URL is functional, etc. Better to over-specify and let a few items get marked impossible than to under-specify and let the agent declare victory early. Submit your checklist by calling the ``submit_checklist`` tool. Do not reply with prose or JSON in your message body — call the tool. The system will not see anything you write outside the tool call.zGoal: {goal} Produce the harshest, most detailed checklist of completion criteria you can. Aim for at least 5 items; more is better when warranted. Each item should be a single verifiable statement of fact about the finished work.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": ""}uYou are a strict judge evaluating an autonomous agent's progress on a user's goal that has a detailed checklist of completion criteria. For EACH currently-pending checklist item, decide whether the available evidence shows the item is satisfied. Be strict but not absurd. Default to leaving items pending UNLESS evidence is reasonably clear. Reasonable evidence includes: - The agent's most recent response describing or showing the work - Tool call results visible in the conversation history (file writes, command output, web requests, etc.) - A clear statement by the agent that the work was done, when supported by tool output earlier in the conversation Do NOT require the agent to re-prove items it has already established in earlier turns. If a tool call earlier in the conversation already wrote a file, you do not need fresh `ls` output every turn — once established, it's done. Flip pending → completed when the response or recent tool calls show the item is satisfied. Flip pending → impossible only when the work demonstrates the item cannot be achieved in this environment (NOT merely that the agent didn't try). Vague intentions ('I will do X next') do NOT count as completion. STICKINESS: items already marked completed or impossible are frozen. Do not include them in your updates. Only the user can revert them. TOOLS: - ``read_file(path, offset, limit)``: inspect the dumped conversation history file whose path is given in the user message. Use this when the snippet alone isn't enough to rule. Each call costs tokens, so only read when needed. - ``update_checklist(updates, new_items, reason)``: issue your verdict. Call this exactly once per turn when you are ready to rule. Calling it ENDS the evaluation. You MUST call one of these tools every turn. Do not reply with prose or JSON in your message body — the system will not see anything written outside tool calls. When you cite evidence, reference the agent's actual output specifically.uGoal: {goal} Current checklist (each item is numbered, 1-based — use these exact 1-based numbers as the ``index`` field in your updates): {checklist_block} Agent's most recent response (snippet): {response} Conversation history file (call read_file on this path if you need more context — pagination supported via offset/limit): {history_path} Evaluate each pending item. Cite specific evidence.zNGoal: {goal} Agent's most recent response: {response} Is the goal satisfied?ceZdZUdZded<eZded<eZded<dZ ded<d Z d ed <d Z d ed <ddZ e ddZd S) ChecklistItemz5One concrete completion criterion attached to a goal.strtextstatusadded_byfloatadded_atNzOptional[float] completed_at Optional[str]evidencereturnDict[str, Any]c t|SN)rselfs ./root/.hermes/hermes-agent/hermes_cli/goals.pyto_dictzChecklistItem.to_dictsd||data'ChecklistItem'c t|dd}|sd}t|dt}|t vrt}t|dt }|t tfvrt }||||t|ddpd|dt|dnd|d  S) Nrz (empty item)rrrrrr!)rrrrrr!) rgetstrip ITEM_PENDINGlowerVALID_ITEM_STATUSESADDED_BY_JUDGE ADDED_BY_USERr)clsr+rrrs r( from_dictzChecklistItem.from_dicts=488FB''((..00 "!DTXXh 5566<<>>DDFF , , ,!Ftxx N;;<<BBDDJJLL NM: : :%Hs488J44;<<88N++7d>*+++XXj))    r*)r"r#)r+r#r"r,)__name__ __module__ __qualname____doc____annotations__r1rr4rrrr!r) classmethodr7r*r(rrs?? IIIF"H""""H$(L(((("H""""   [   r*rc eZdZUdZded<dZded<dZded<eZded <d Z d ed <d Z d ed <dZ ded<dZ ded<dZ ded<dZded<eeZded<dZded<d%dZed&dZd'd Zd(d!Zdd"d)d$ZdS)* GoalStatez+Serializable goal state stored per session.rgoalactiverrint turns_used max_turnsrr created_at last_turn_atNr last_verdict last_reason paused_reasonconsecutive_parse_failures)default_factoryzList[ChecklistItem] checklistFbool decomposedr"cLt|}tj|dS)NF ensure_ascii)rjsondumps)r'r+s r(to_jsonzGoalState.to_json(s"d||z$U3333r*raw 'GoalState'ctj|}|dpg}g}t|trY|D]V}t|t r? |t|F#t$rYRwxYwW||dd|ddt|ddpdt|dtptt|d d pd t|d d pd |d |d |dt|ddpd|t|dd S)NrMrAr.rrBrDrrErFrrGrHrIrJrKrOF) rArrDrErFrGrHrIrJrKrMrO)rSloadsr/ isinstancelistdictappendrr7 ExceptionrCDEFAULT_MAX_TURNSrrN)r6rVr+ raw_checklistrMitems r( from_jsonzGoalState.from_json-sz#--3 )+ mT * * !% ! !dD))!!!(()@)@)F)FGGGG$!!! !! s&"%%88Hh//488L!449::$((;0ABBWFWXXTXXlC88?C@@txx<<CDD.11//((?33'*4884PRS+T+T+YXY'Z'ZDHH\599::    s-B  BBTuple[int, int, int, int]ct|j}td|jD}td|jD}||z |z }||||fS)z/Return (total, completed, impossible, pending).c3:K|]}|jtkdVdSN)rITEM_COMPLETED.0its r( z-GoalState.checklist_counts..Ms.RRbbi>6Q6Q6Q6Q6Q6QRRr*c3:K|]}|jtkdVdSrf)rITEM_IMPOSSIBLEris r(rlz-GoalState.checklist_counts..Ns.TTrryO7S7S7S7S7S7STTr*)lenrMsum)r'totalrrrs r(checklist_countszGoalState.checklist_countsJskDN##RRDNRRRRR TTT^TTTTT )#j0iW44r*cP|jsdStd|jDS)zITrue iff at least one item exists and every item is in a terminal status.Fc32K|]}|jtvVdSr%)rTERMINAL_ITEM_STATUSESris r(rlz)GoalState.all_terminal..Vs*PP229 66PPPPPPr*)rMallr&s r( all_terminalzGoalState.all_terminalRs0~ 5PPPPPPPPr*numberedrycb|jsdSg}t|jdD]y\}}t|jd}|r|d|nd|}|d|j}|jt kr|jr|d|jd z }||zd |S) Nz(empty)rg)startz[?]z. z  z (impossible: ) ) rM enumerate ITEM_MARKERSr/rrrnr!r]join)r'rylinesiramarkerprefixlines r(render_checklistzGoalState.render_checklistXs~ 9 q999  GAt!%%dk599F)1D%%V%%%}F}}F**ty**D{o--$--99999 LL    yyr*r"r)rVrr"rW)r"rcr"rN)ryrNr"r)r8r9r:r;r<rrDr_rErFrGrHrIrJrKrr[rMrOrUr=rbrrrwrr>r*r(r@r@ss55 IIIFJ&I&&&&JL"&L&&&&!%K%%%%#'M''''&'''''&+U4%@%@%@I@@@@J4444    [ 85555QQQQ 49         r*r@ session_idrr"c d|S)Nzgoal:r>)rs r( _meta_keyrks :  r*r# _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. rget_hermes_home) SessionDBz,GoalManager: SessionDB bootstrap failed (%s)Nz$GoalManager: SessionDB() raised (%s)) hermes_constantsr hermes_staterrr^loggerdebugrr/)rrhomeexccacheddbs r(_get_session_dbrrs444444******??$$%%  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) rget_metarr^rrr@rbwarning)rrrVrs r( load_goalrs 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)rset_metarrUr^rr)rrrrs r( save_goalrs    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)rrr)rrs r( clear_goalrs6 j ! !E }EL j%     r*Optional[Path]cJ ddlm}t|}n3#t$r&}td|Yd}~dSd}~wwxYw |dz }|dd|S#t$r&}td|Yd}~dSd}~wwxYw) zHReturn ``/goals`` (created on first use), or None on error.rrz*goals dump dir: get_hermes_home failed: %sNgoalsT)parentsexist_okz goals dump dir: mkdir failed: %s)rrrr^rrmkdir)rrrpaths r(_goals_dump_dirrs444444OO%%&&  A3GGGtttttg~ 4$ ///  7===ttttts, AA  AA22 B"<BB"cJtjdd|pd}|ddpdS)z7Make a session_id safe for use as a filename component.z[^A-Za-z0-9._-]+_unknownN)resub)rcleaneds r(_safe_session_filenamers.f(#z/FYGGG 4C4= %I%r*cPt}|dS|t|dz S)z8Where the dumped messages JSON for ``session_id`` lives.Nz.json)rr)rbases r(conversation_dump_pathrs4   D |t +J77>>> >>r*messagesList[Dict[str, Any]]c0|r|sdSt|}|dS t|dd5}tj||ddtdddn #1swxYwY|S#t $r&}t d|Yd}~dSd}~wwxYw) zHWrite ``messages`` to the goals/ dump file. Returns the path on success.Nwutf-8)encodingF)rRindentdefaultz#dump_conversation: write failed: %s)ropenrSdumprr^rr)rrrfhrs r(dump_conversationrs  Xt !* - -D |t$g . . . O" Ihq# N N N N O O O O O O O O O O O O O O O  :C@@@ttttts:A%A A%AA%A A%% B/BBrlimitrCcN|sdSt||kr|S|d|dzS)Nr.u… [truncated])ro)rrs r( _truncaters9 r 4yyE <+ ++r*z\{.*\}rVOptional[Dict[str, Any]]c|sdS|}|dr=|d}|d}|dkr ||dzd} tj|}nj#t $r]t |}|sYdS tj|d}n#t $rYYdSwxYwYnwxYwt|tr|ndS)zLBest-effort extraction of a single JSON object from a possibly-prosey reply.Nz````r~rgr) r0 startswithfindrSrYr^_JSON_OBJECT_REsearchgrouprZr\)rVrnlr+matchs r(_extract_json_objectrs! t 99;;D u!zz# YYt__ 88Q=D z$ &&t,, 44 :ekk!nn--DD   444  D dD)) 344t3s6,B&C(+'CC( C"C(!C""C('C(Tuple[bool, str, bool]c|sdSt|}|ddt|ddfS|d}t|tr)|dv}nt|}t |d pd }|sd }||dfS) aParse the freeform 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. )Fjudge returned empty responseTNFjudge reply was not JSON: Tdone)trueyes1rreasonr.no reason provided)rrr/rZrr0r2rN)rVr+done_valrrs r(_parse_judge_responsers <;;  $ $D |J9S#3F3FJJDPPxxH(C  ~~%%''+GGH~~ (##)r * * 0 0 2 2F &%  r*!Tuple[List[Dict[str, Any]], bool]c|sgdfSt|}|gdfS|d}t|tsgdfSg}|D]}t|trOt |dd}|r|d|ift|t r-|}|r|d|i|dfS)z?Parse a Phase-A decompose reply. Returns (items, parse_failed).TNrMrr.F)rr/rZr[r\rr0r])rVr+ raw_itemsoutrars r(_parse_decompose_responser5s 4x  $ $D |4x%%I i & &4x "C++ dD ! ! +txx++,,2244D + FD>*** c " " +::<*** :r*Tuple[Dict[str, Any], bool]c|sggdddfSt|}|ggdt|dddfS|dpg}|dpg}t|d pd pd }g}t |t r|D]}t |ts t|d }n#ttf$rYOwxYw|d z }t|dd  } | tvrt|dpd pd} | || | dg} t |t r|D]} t | trOt| dd } | r| d| ift | tr-| } | r| d| i|| |ddfS)zParse a Phase-B checklist eval reply. Returns (parsed, parse_failed). parsed = {"updates": [...], "new_items": [...], "reason": str} rupdates new_itemsrTNrrrrrr.rindexrgrr!rrr!rF)rrr/rr0rZr[r\rC TypeError ValueErrorr2rur])rVr+rrr norm_updatesupd idx_1basedidxrr!norm_newrkrs r(_parse_evaluate_responserLs aB:YZZ\```  $ $D |Nyc7J7JNN      hhy!!'RG%%+I (##)r * * 0 0 2 2 J6JFL'4  X X XCc4((  !!1!122 z*    q.C2..//5577==??F333377:..4"55;;==EH   #X V V W W W WH)T"" 4 4 4B"d## 4266&"--..44664OOVTN333B$$ 4xxzz4OOVTN333#(f M Mu TTs "C00DDfunction read_filezRead a portion of the dumped conversation history JSON file. Use this when the snippet alone isn't enough to rule. Returns lines from the file with 1-based line numbers. Pagination supported via offset and limit. Reads beyond a built-in cap are truncated.objectstringzXAbsolute path to the conversation history file. You were given this in the user message.)type descriptionintegerz+1-indexed starting line number (default 1).rg)rrrzMax lines to return (default z).)roffsetrr)r propertiesrequired)namer parametersrr_JUDGE_READ_FILE_TOOL_SCHEMAsubmit_checklistzSubmit the harsh, detailed completion-criteria checklist you decomposed the goal into. Each item is one verifiable completion criterion. Bias toward more items, not fewer.itemsarrayzList of checklist items. Each item is a single verifiable statement of fact about the finished work. Aim for at least 5 items; more is better when warranted.zThe completion-criterion text.)rrr#_JUDGE_SUBMIT_CHECKLIST_TOOL_SCHEMAupdate_checklistu[Issue your verdict on the current checklist. For each currently-pending item, decide whether the agent's most recent response (and conversation history if you read it) shows the item is satisfied. You may also append new items the original decomposition missed. Call this exactly once when you are ready to rule — calling it ends the evaluation.u Per-item rulings. Use the 1-based ``index`` shown in the checklist. ``status`` must be 'completed' (clear evidence the item is done) or 'impossible' (item cannot be achieved in this environment). Items already in a terminal status are frozen — do not include them.z1-based checklist index.)renumzkOne-sentence specific citation of why this item is done or impossible. Reference the agent's actual output.ruOptional: completion criteria the original decomposition missed. Stay strict — only add items that genuinely belong as completion criteria for this goal.zThe new criterion text.z9One-sentence overall rationale for this round of updates.r#_JUDGE_UPDATE_CHECKLIST_TOOL_SCHEMArr allowed_pathrrc |stjddiS t|}n0#t$r#}tjdd|icYd}~Sd}~wwxYw|G |}n#t$r|}YnwxYw||krtjdd|iS|stjdd|iS t dt|pd}t dtt|ptt}n-#ttf$rtjddicYSwxYw t|d d d 5}| }dddn #1swxYwYn0#t$r#}tjdd |icYd}~Sd}~wwxYwt|} |dz } t| |z| } || | } d| } t| t kr| dt dz} tjt#|| |t| | | kr| dznd| ddS)uBounded read of the dumped conversation file. Returns JSON-serializable text. Restricted to ``allowed_path`` when provided — the judge cannot use this tool to read arbitrary files. errorzpath is requiredzpath resolve failed: Nz@read_file is restricted to the conversation dump path. Allowed: zfile not found: rgz!offset and limit must be integersrrreplace)rerrorsz read failed: r.u" … [truncated by judge read cap])r total_linesrreturned next_offsetcontentFrQ)rSrTrresolver^existsmaxrCmin_JUDGE_READ_FILE_MAX_LINESrrr readlinesror_JUDGE_READ_FILE_MAX_CHARSr)rrrrtargetrallowedrrrqr{end slice_linesrs r(_judge_read_filer$-s[ 9z7$67888Dd##%% DDDz7$AC$A$ABCCCCCCCCD #"**,,GG # # #"GGG # W  :* '**  ==??Bz7$?v$?$?@AAAJQFKa(())As3uB(BCCE_``aa z "JJJz7$GHIIIIIJ< &# B B B #bLLNNE # # # # # # # # # # # # # # # <<<z7$9C$9$9:;;;;;;;;< JJE QJE eemU # #Cc "K ''+  C 3xx,,,---.1VV :F  $$"%++sQww4    s!< A)A$A)$A)/B BB#AD::'E$#E$(F(;F F(F  F(#F $F(( G2G GGTuple[Optional[Any], str]c ddlm}n3#t$r&}td|Yd}~dSd}~wwxYw |d\}}n3#t$r&}td|Yd}~dSd}~wwxYw||sdS||fS)z6Return (client, model) or (None, '') when unavailable.r)get_text_auxiliary_clientz.goal judge: auxiliary client import failed: %sN)Nr. goal_judgez0goal judge: get_text_auxiliary_client failed: %s)agent.auxiliary_clientr'r^rr)r'rclientmodels r(_get_judge_clientr,qsDDDDDDD  EsKKKxxxxx11,??   GMMMxxxxx~U~x 5=s' 949A A<A77A<msgr tool_namec t|ddpg}|D]v} t|ddp-t|tr|dndpd}t|ddp+t|tr|dnd}|t|ddp+t|tr|dnd}||krt|ddp+t|tr|dnd}t|tr, |rt j|ni}n,#t$ri}YnwxYwt|tr|}ni}|||d cS#t$rYtwxYwdS) zFind a tool call by name on a chat-completions message. Returns ``{"id", "name", "arguments": }`` or None. Robust to provider shims that return tool_calls as objects or dicts and arguments as JSON strings or already-parsed dicts. tool_callsNidtc-?rrr. arguments)r1rr3)getattrrZr\r/rrSrYr^) r-r.r0tctc_idfnfn_name fn_args_rawargss r(_extract_tool_callr;slD117RJ Bd++i 2t@T@T0^t Z^iciEZ..hTVX\I]I]3g266*3E3E3EcgBzb&$//cjQSUYFZFZ4bBFF6NNN`bG)##!"k488qT^_acgThTh=pRVVK=P=P=PnpK+s++ 6AI4:k222rDD DDDK.. "tDD D D D    H  4sDA>E=AE=AE=0E E= EE=E"E== F  F cg}t|ddpgD]f} t|ddp-t|tr|dndpd}t|ddp+t|tr|dnd}t|ddp+t|tr|dnd}t|ddp+t|tr|dnd}t|ts( t j|}n#t$rd }YnwxYw||d|pd|d d W#t$rYdwxYw|S) zyConvert a provider-shim tool_calls list into plain-dict form for inclusion in subsequent ``messages=[...]`` payloads.r0Nr1r2rrr.r3z{})rr3)r1rr) r4rZr\r/rrSrTr^r])r-rr5r6r7r8fn_argss r(_serialize_assistant_tool_callsr>s!#Cc<..4" Bd++i 2t@T@T0^t Z^iciEZ..hTVX\I]I]3g266*3E3E3EcgBb&$//cjQSUYFZFZ4bBFF6NNN`bGb+t44mPZ[]_cPdPd9l 9L9L9LjlGgs++ ##"j11GG ###"GGG# JJ"%,]II         H  Js6D E-&D;:E-; E E- E  !E-- E;:E;) max_tokensr*r+toolsforced_tool_namer timeoutrr@#Tuple[Optional[Any], Optional[str]]c  |rdd|id}nd}|ddg}d} |D]} |jj|||| d||dfcS#t$r} t | jd | } t |  t fd d Ds d| fcYd} ~ cSt d | | Yd} ~ d} ~ wwxYwd| pd fS)zCall the judge with a forced tool choice, falling back to ``auto`` if the provider rejects ``required`` / a specific function choice. Returns ``(response, error)``. On success, ``error`` is None. rrrrautoNr)r+rrA tool_choice temperaturer@rCz: c3 K|]}|vV dSr%r>)rjtokenr-s r(rlz/_call_judge_with_tool_choice..s7u|r*)rGz tool choicerz function call unsupportedz not supportedinvalid400z6goal judge: tool_choice=%r rejected (%s); falling backz all tool_choice fallbacks failed) chat completionscreater^rr8rr2anyrr) r*r+rrArBrCr@primary_choiceattemptslast_errchoicerr-s @r(_call_judge_with_tool_choicerVs}$$",6CS:TUU#):v>H"H ;*11!"%2      s)),5555Hc((..""C2 &X~%%%%%%%% LLQSY[^ _ _ _ HHHH  ?? ??s$'A CAC&C.CCrCrA*Tuple[List[Dict[str, Any]], Optional[str]]c  |sgdfSt\}}|gdfSdtddtt |ddg}t |||tgd |d \}}|"t d |gd |fS |j dj }n#t$rgdfcYSwxYwt|d }|t|ddpd} t| \} } | s| s-t dt | dgdfSt dt!| | dfS|ddpg} g} t%| t&r| D]} t%| t(rOt+| dd}|r| d|ift%| t*r-| }|r| d|i| st dgdfSt dt!| | dfS)zPhase-A: ask the judge to break the goal into a checklist via a forced ``submit_checklist`` tool call. Returns ``(items, error)``. On any failure, returns ``([], reason)`` so the caller can fall back to freeform mode. empty goalNauxiliary client unavailablesystemrolerrrrArr+rrArBrCr@z$goal decompose: API call failed (%s)zdecompose error: rzdecompose response malformedrr.zLgoal decompose: no submit_checklist tool call AND no parseable JSON (raw=%r)rz.decompose: judge did not call submit_checklistz;goal decompose: fell back to JSON-content parser (%d items)r3rrz:goal decompose: submit_checklist returned empty items listzdecompose: empty checklistz9goal decompose: produced %d checklist items via tool call)r0r,DECOMPOSE_SYSTEM_PROMPTDECOMPOSE_USER_PROMPT_TEMPLATEformatrrVr rinfochoicesmessager^r;r4rror/rZr[r\rr])rArCr*r+rresperrr-r5rr parse_failedrentryrs r(decompose_goalrls ::<< <%''MFE ~111&=>>5<<tT**=  H-23+ID# | :C@@@,s,,,,2l1o% 222111112 C!3 4 4B z#y"--37@@|  Hu H KK^'3''   GG G QSVW\S]S]^^^d{;##G,,2I"$E)T"" 1 1 1E%&& 1599VR001177991LL&$000E3'' 1{{}}1LL&$000 0 PQQQ/// KKKSQVZZXXX $;s*B==C C last_responseTuple[str, str, bool]c|sdS|sdSt\}}|dStt |dt |t } |jj|dtdd |dgd d | }nL#t$r?}t d |ddt|jdfcYd}~Sd}~wwxYw |jd jjpd}n#t$rd}YnwxYwt%|\} } } | rdnd} t d| t | d| | | fS)uLegacy freeform judge — kept for goals with no checklist. Returns ``(verdict, reason, parse_failed)`` where verdict is ``"done"``, ``"continue"``, or ``"skipped"``. )skippedrZFcontinuez$empty response (nothing to evaluate)FN)rrr[Fr`)rAresponser\r]rrr)r+rrHr@rCu@goal judge: API call failed (%s) — falling through to continuerr judge error: Fr.rz+goal judge (freeform): verdict=%s reason=%sx)r0r,&EVALUATE_USER_PROMPT_FREEFORM_TEMPLATErdr_JUDGE_RESPONSE_SNIPPET_CHARSrNrOrPEVALUATE_SYSTEM_PROMPT_FREEFORMr^rrerr8rfrgrr) rArmrCr*r+promptrhrrVrrrjverdicts r(judge_goal_freeformr{Bs ::<<.--    IHH%''MFE ~@@ 3 : : tT " "=*GHH;F G{&--!.MNNF33.    GGG VX[\\\?499+=??FFFFFFFGl1o%-3 "7s!;!;D&,,ff*G KK=w RXZ]H^H^___ FL ((s01B22 C;<4C60C;6C;?D D('D()rCmax_tool_calls history_pathr|c t\}}|ggdddfS|d}tt |jd|t |t |rt|nd }d td d |d g} tg} || d t|td t|nd } t| dzD]} | d kr| ntg} | d krdnd}t||| | ||d\}}|(t d|ggd|ddfcS |jd j}n#t($r ggdddfcYcSwxYwt+|d}|t-|d}t dt/|dpgt/|dpgt |ddd|dfcSt+|d}|| d kr|d}t3t|dd|dd|d t4|!}| d"t9|d#dpdt;|d$| d%|d&d|d'| dz} t9|d#dpd}|rzt?|\}}|sft d(t/|dpgt/|dpg|dfcSt d)| t |dggd*ddfcSggd+ddfS),abPhase-B: judge evaluates each pending checklist item via forced tool calls. The judge has two tools available: - ``read_file``: inspect the dumped conversation history - ``update_checklist``: issue the verdict (terminates the loop) ``tool_choice="required"`` forces one of them every iteration. We loop until ``update_checklist`` is called or ``max_tool_calls`` is exhausted. Returns ``(parsed, parse_failed)`` where parsed is ``{"updates": [...], "new_items": [...], "reason": str}``. Falls open on transport errors: empty updates/new_items, parse_failed=False. Nr[rFTrxr`u)(unavailable — judge from snippet only))rAchecklist_blockrsr}r\r]rrrr r?raz,goal judge (checklist): API call failed (%s)rtzjudge response malformedr3z9goal judge (checklist): updates=%d new_items=%d reason=%srrrr.rurrrrgrr assistantr)r^rr0toolr1)r^ tool_call_idrrzPgoal judge (checklist): fell back to JSON-content parser updates=%d new_items=%dusgoal judge (checklist): judge emitted neither read_file nor update_checklist (iteration=%d, content=%r) — bailingz#judge did not call update_checklistz)judge tool-loop exhausted without verdict) r,r'EVALUATE_USER_PROMPT_CHECKLIST_TEMPLATErdrrArwr EVALUATE_SYSTEM_PROMPT_CHECKLISTr insertrrrCrangerVrrerfrgr^r;_normalize_update_argsror/r$rr]r4r>r0r)rrmr}rCr|r*r+r user_promptrrA reads_left iteration loop_toolsforcedrhrir- update_tcparsedread_tcr: tool_resultrrjs r(evaluate_checklistrus,&''MFE ~R;YZZ\abb,,d,;;O9@@ uz4 ( ('=*GHH*6gS&&&**a a )1nnUU3V2W (2Q##D0 #   c < KKF L L L "!#3c33      ,q/)CC   R;UVV      's,>??  +Ik,BCCF KKKFJJy))/R00FJJ{++1r22&**Xr22C88     5= %S+66  :>>;'D*DHHVR(())xx!,,hhw(BCC) K OO#"3 266<"=cBB    OO ' #&     !OJ #y"--3 ==?? %#;G#D#D FL % . 9--344 ;//5266  u}$$$  F y#..   ?        A   sE""E98E9r:c|dpg}|dpg}t|dpdpd}g}t|tr|D]}t|t s t |d}n#ttf$rYOwxYwt|dd }|tvrt|dpdpd }| |d z ||d g} t|tr|D]} t| t rOt| d d} | r| d | ift| tr-| } | r| d | i|| |d S)u Validate and normalize the ``update_checklist`` tool arguments. Performs the same 1-based → 0-based conversion and terminal-status filter as ``_parse_evaluate_response``. Returns the canonical ``{updates, new_items, reason}`` shape callers expect. rrrr.rrrr!Nrgrrr) r/rr0rZr[r\rCrrr2rur]) r: raw_updatesraw_newrrrrrr!rrkrs r(rrsS((9%%+Khh{##)rG (##)r * * 0 0 2 2 J6JF)+L+t$$  Cc4((   !1!122 z*    2..//5577==??F333377:..4"55;;==EH   #a $!!     &(H'4  4 4 4B"d## 4266&"--..44664OOVTN333B$$ 4xxzz4OOVTN333#(f M MMs"B<<CCceZdZdZeddd Zd>d Z d?dZ d?dZ ddd@dZ dAdBdZ dddCdZdDdZdEd ZdFd#ZdGd&ZdHd'ZdDd(Zdddd)dId1Zddd2dJd5ZedKd7ZedLd9ZdMd;ZdS)N GoalManageru\Per-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. - ``add_subgoal(text)`` — user appends a checklist item. - ``mark_subgoal(index, status)`` — user flips an item (override). - ``remove_subgoal(index)`` — user deletes an item. - ``clear_checklist()`` — user wipes the checklist; next turn re-decomposes. - ``evaluate_after_turn(last_response, agent=None)`` — call the judge, update state, return a decision dict. - ``next_continuation_prompt()`` — the canonical user-role message to feed back into ``run_conversation``. )default_max_turnsrrrrCcr||_t|pt|_t ||_dSr%)rrCr_rr_state)r'rrs r(__init__zGoalManager.__init___s3$!$%6%K:K!L!L+4Z+@+@ r*r"rc|jSr%)rr&s r(rzGoalManager.statefs {r*rNc4|jduo|jjdkS)NrBrrr&s r( is_activezGoalManager.is_activejs{$&I4;+=+IIr*c0|jduo |jjdvS)N)rBpausedrr&s r(has_goalzGoalManager.has_goalms{$&U4;+=AU+UUr*c|j}| |jdvrdS|jd|jd}|\}}}}d}|r d||zd|d}|jdkrd ||d |jS|jd kr$|jr d |jnd}d |||d |jS|jdkrd||d |jSd|jd||d |jS)N)rz*No active goal. Set one with /goal ./z turnsr.z,  donerBu⊙ Goal (active, ): r — u⏸ Goal (paused, ru✓ Goal done (zGoal ()rrrDrErrrArJ) r'sturnscl_totalcl_donecl_imprcl_textextras r( status_linezGoalManager.status_linepsD K 9L00??<55!+555'('9'9';';$'61  >=7V+==h===G 8x  CCwCC16CC C 8x  12H-AO---bEJJwJJJ!&JJ J 8v  @U@G@@@@ @???E?7??qv???r*cf|jdS|jjsdS|jdS)z-Public helper for the /subgoal slash command.Nz(no active goal)u=(checklist empty — judge will populate it on the next turn)Trx)rrMrr&s r(rzGoalManager.render_checklists= ; %%{$ SRR{++T+:::r*N)rErArE Optional[int]r@c |pd}|stdt|dd|rt|n|jt jdgd}||_t|j||S)Nr.zgoal text is emptyrBrrF)rArrDrErFrGrMrO) r0rr@rCrtimerrr)r'rArErs r(setzGoalManager.sets !!## 3122 2(1Mc)nnnt7My{{     $/5))) r* user-pausedrc|jsdSd|j_||j_t|j|j|jS)Nr)rrrJrrr'rs r(pausezGoalManager.pausesA{ 4% $* !$/4;///{r*T) reset_budgetrc|jsdSd|j_d|j_|r d|j_t |j|j|jS)NrBr)rrrJrDrr)r'rs r(resumezGoalManager.resumesS{ 4% $( !  '%&DK "$/4;///{r*rcr|jdSd|j_t|j|jd|_dS)Nr)rrrrr&s r(clearzGoalManager.clears8 ;  F& $/4;/// r*c|jsdSd|j_d|j_||j_t |j|jdS)Nr)rrrHrIrrrs r( mark_donezGoalManager.mark_donesI{  F# #)  "( $/4;/////r*rrcN|jtd|pd}|stdt |t t tj}|jj |t|j |j|S)zEUser appends a new checklist item. Requires an active or paused goal.Nno active goalr.zsubgoal text is emptyrrrr) r RuntimeErrorr0rrr1r5rrMr]rr)r'rras r( add_subgoalzGoalManager.add_subgoals ; /00 0 !!## 6455 5"Y[[     $$T***$/4;/// r* index_1basedrct|jtd|pd}|tvr't dt td|t|dz }|dks|t|jj kr*tdt|jj d |jj |}||_ |tvr'tj |_|jsd |_nd|_t!|j|j|S) uUser overrides an item's status. ``status`` may be ``completed``, ``impossible``, or ``pending`` (the last only as an undo flow). Stickiness rules do NOT apply to user actions — the user is the only authority that can revert terminal items. Nrr.zstatus must be one of z; got rgrindex out of range (1..r}zmarked by user)rrr0r2r3rsortedrCrorM IndexErrorrrurrr!rr)r'rrrras r( mark_subgoalzGoalManager.mark_subgoals< ; /00 0,B%%''--// , , ,V0C)D)DVVFVV ,!# 77cS!67777G#dk.C*D*DGGG {$S) + + + $ D = 1 0 $D $/4;/// r*cb|jtdt|dz }|dks|t|jjkr*t dt|jjd|jj|}t|j|j|S)Nrrgrrr}) rrrCrorMrpoprr)r'rrremoveds r(remove_subgoalzGoalManager.remove_subgoals ; /00 0,!# 77cS!67777G#dk.C*D*DGGG +'++C00$/4;///r*c||jdSg|j_d|j_t|j|jdS)zIWipe the checklist and reset decomposed=False so the judge re-decomposes.NF)rrMrOrrr&s r(clear_checklistzGoalManager.clear_checklists= ;  F " !& $/4;/////r*)user_initiatedagentrrmrrrrOptional[List[Dict[str, Any]]]r#c |j}| |jdkr|r|jndddddddS|xjdz c_tj|_|jst |j\}}d |_d}|rtj} |D]=} |j t| d tt| >d |_ d t|d|_dt|d}t!|j|dd |d |j|dSt&d|d||_|||||\} } } | |_ | |_| r|xjdz c_nd|_| dkr(d|_t!|j|dddd| d| dS|jt.kr>d|_d|jd|_t!|j|dddd| d|jddS|j|jkrNd|_d|jd|jd|_t!|j|dddd| d |jd|jd!dSt!|j||\}}}}d}|r d"||zd|d#}dd |d| d$|jd|j|d%| dS)&uRun 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. ``messages`` is the agent's full conversation list for this session. When provided, it's dumped to ``/goals/.json`` so the Phase-B judge's read_file tool can inspect history. Optional — when missing, the judge runs from the snippet only. ``agent`` is a back-compat path — when ``messages`` is None we try to extract them from common AIAgent attribute names. Most callers should pass ``messages`` directly because AIAgent does not store the message list as a public instance attribute. 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" | "decompose" - ``reason``: str - ``message``: user-visible one-liner to print/send NrBFinactiverr.)rshould_continuecontinuation_promptrzrrgrgTrr decomposezdecomposed into z itemsu⊙ Goal checklist created (z) items). Use /subgoal to view or edit it.u>goal: decompose failed (%s) — falling back to freeform judgezdecompose failed: rrrru✓ Goal achieved: rz(judge model returned unparseable output z turns in a rowrru%⏸ 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 (rr}u⏸ Goal paused — zD turns used. Use /goal resume to keep going, or /goal clear to stop.rru↻ Continuing toward goal (r)rrrDrrGrOrlrArMr]rr1r4rHrorIrrnext_continuation_promptrre_evaluate_state_phase_brK&DEFAULT_MAX_CONSECUTIVE_PARSE_FAILURESrJrErr)r'rmrrrrrridecompose_messagenowrkrzrrjrrrrprogresss r(evaluate_after_turnzGoalManager.evaluate_after_turns@  =ELH44*/9%,,T#('+%*   A!Y[[ ;' 33JE3#E  "  ikk"EO**%!&v#/%3%( &1"$Is5zz$I$I$I!83u::888"$/5111&'++/+H+H+J+J*#/0  KKXZ] ^ ^ ^ :S : :E )-(D(D =)E) ) %%"  1  , , 1 , , ,/0E , f  !EL dou - - - #('+! 999    +/U U U#ELl5;[lll   dou - - -"#('+% 5E<\555 $  u . .#EL"aEr*r(rrJsJ(EVAAAAAAXJJJJVVVV@@@@$;;;;<@$.20000"@    0000 $37 e e e e e e X37 5-5-5-5-5-5-r   \ """\"L       r*rc&t|||S)u5Back-compat wrapper — defers to the freeform judge.rW)r{)rArmrCs r( judge_goalr.s t]G D D DDr*)rr@rrrr_DEFAULT_MAX_JUDGE_TOOL_CALLSr1rhrnrrur3rrrrr{rlrrr)rrr"r)r"r)rrr"r)rrrr@r"r)rrr"r)r"r)rrr"r)rrrrr"r)rrrrCr"r)rVrr"r)rVrr"r)rVrr"r)rVrr"r) rrrrCrrCrrr"r)r"r%)r-rr.rr"r)r-rr"r)r*rr+rrrrArrBr rCrr@rCr"rD)rArrCrr"rX)rArrmrrCrr"rn) rr@rmrr}rrCrr|rCr"r)r:r#r"r#)Sr; __future__rrSloggingosrr dataclassesrrrpathlibrtypingrr r r r getLoggerr8rr_DEFAULT_JUDGE_TIMEOUTrwrrrrr1rhrn frozensetrur3rr4r5rrrbrcrxrrrvrr@rrr<rrrrrrrrrcompileDOTALLrrrrrrr r r$r,r;r>rVrlr{rrrr__all__r>r*r(rsj***X#"""""  000000000033333333333333  8 $ $!%*+& !!# "NO#DEEi~ OPPEU%  P+,$H* C !8!L:(' # # # # # # #  # L M M M M M M M  M j     <* > > > >!!!!$&&&&????.,,,,"*Y 224444.6.2U2U2U2UL  %C&#P  &V8RVVV9 * /  ""%0%0%%%%R " G #* !)"(0/O%%' &,H  *! /    #7#7#####N " M$/!))2/I&& )1)4l(C'' )1%K))''$%D$C$C)  D$2 !)"(0/H%%' &,H  (%#^k99t;::y= = HHK7K7#KKKKb+#' <<<<<<H"BB0@0@0@0@0@0@l+PPPPPPn+ 0)0)0)0)0)0)p+6 ``````F*N*N*N*Nd` ` ` ` ` ` ` ` P+ EEEEEE   r*