.cjQ^UdZddlmZddlZddlZddlZddlmZddlm Z dZ dZ dd d d d d gZ d e d<d dd Zde d<dZde d<dFdZdGdZdGdZdHdZdIdZdJd ZdHd!ZdHd"ZdKd$ZdLdMd'Zd(d)dNd-ZdOd.ZdPd1ZdQd3ZdRd4ZdRd5ZdSd7Z dTdUd9Z!dVd;Z"dUd<Z#dWdXd?Z$dYdBZ%dWdZdDZ&d[dEZ'dS)\z:Mixture-of-Agents configuration and slash-command helpers.) annotationsN)deepcopy)Any__HERMES_MOA_TURN_V1__defaultz openai-codexzgpt-5.5providermodel openrouterzdeepseek/deepseek-v4-prozlist[dict[str, str]]DEFAULT_MOA_REFERENCE_MODELSzanthropic/claude-opus-4.8zdict[str, str]DEFAULT_MOA_AGGREGATOR float | NoneDEFAULT_MOA_REFERENCE_TIMEOUTreturnlist[dict[str, Any]]c>dttDS)Ncg|] }i|ddi S)enabledT).0slots 7/home/ice/.hermes/hermes-agent/hermes_cli/moa_config.py z-_default_reference_models..s( Y Y Y$ %t %Y % % Y Y Y)rr rrr_default_reference_modelsrs Y Y(;W2X2X Y Y YYrvaluercf||dkrdS t|S#ttf$rYdSwxYw)uFCoerce to a float, or None when unset/blank/invalid. Used for optional sampling params (reference_temperature / aggregator_temperature) where None means 'don't send the parameter — provider default applies', matching how a single-model Hermes agent never sends temperature unless explicitly configured. N)float TypeError ValueError)rs r_coerce_float_or_noner"sN } tU|| z "tts 00c||dkst|trtS t|}n#tt f$r tcYSwxYwt j|r|dkrtS|S)uReturn a finite positive advisor timeout, or None to inherit. ``None`` (the default) means "no per-preset override": the reference fan-out inherits the ``auxiliary.moa_reference.timeout`` config value (900s by default) via ``call_llm``'s own resolution, exactly like every other auxiliary task. An explicit finite positive per-preset value is honored as-is — no artificial cap, since long-thinking advisor models legitimately run far beyond five minutes. Nrr) isinstanceboolrrr r!mathisfinite)rtimeouts r_coerce_reference_timeoutr)/s } z%'>'> ,,-,, z "---,,,,- = ! !-W\\,, Ns6AAstrc|t|pd}|dvr|ndS)zENormalize failed-advisor disclosure policy; unknown values fail loud.loud>r,silentr*striplower)rpolicys r!_coerce_degraded_reference_policyr2Ds@ & ! ! ' ' ) ) / / 1 1F11166v=rintc||dkr|S t|S#ttf$r; tt|cYS#ttf$r|cYcYSwxYwwxYw)Nrr3r r!r)rrs r _coerce_intr6Js } 5zz z " uU||$$ $ $ $:&   NNNNN s,A'A A' A#A'"A##A' int | Nonec||dkrdS t|}nN#ttf$r: tt|}n#ttf$rYYdSwxYwYnwxYw|dkr|ndS)uCoerce to a positive int, or None when unset/blank/invalid/non-positive. Used for optional caps (e.g. reference_max_tokens) where None means 'no cap' — the safe default that preserves prior uncapped behavior. Nrrr5)rns r_coerce_int_or_noner:Vs  } t JJ z " E%LL!!AA:&   444  A A114s2A'A  A' A!A' A!!A'&A'ct|trt|dpd}|dkr8t |dd}|dkrd|S|dkrd nd S|}t|pd}|d vr|S|drR|d \}}}|r"t |dnd}|dkrd|S|dkrd Sd S) upNormalize the fan-out cadence; unknown values fall back to default. Canonical values are the strings ``per_iteration``, ``user_turn``, and ``every_n:`` (N >= 2). The ``every_n`` cadence also accepts the mapping form ``{mode: every_n, n: N}`` from hand-edited YAML and normalizes it to the canonical string, so the rest of the pipeline (presets, flattened view, runtime) only ever sees one shape. ``every_n:1`` semantically means "run every iteration" and collapses to ``per_iteration``; anything unparseable falls back to ``user_turn`` (the default — cheapest cadence; see #67199). moderevery_nr9rzevery_n: per_iteration user_turn>rAr@:) r$dictr*getr/r0r6 startswith partition)rr<r9_seprests r_coerce_fanoutrJhsL% 599V$$*++113399;; 9  EIIcNNA..AAvv%!~~%&'1ff??+ = u{   ! ! # # ) ) + +D ---  y!!#~~c** 3,/ 6K a ( ( (Q 66!a>> ! 66"? ;rc|durdS||durdSt|}|dvr|S|dvrdSdS)uNormalize ``moa.privacy_filter`` to '' (off), 'display', or 'full'. - ``''`` (empty string): filter off — the default. ``false``/``None``/ unknown values land here so a hand-edited config degrades to prior behavior (tolerant-read contract). - ``'display'``: redact user-visible surfaces only — the reference blocks shown in the UI and the saved MoA trace records. The aggregator still sees raw advisor text, so answer quality is unaffected. - ``'full'``: additionally redact the advisor text injected into the aggregator prompt (issue #59959's literal ask). A hand-edited boolean ``true`` maps here because the issue framed the toggle as "redact before passing to the aggregator". TfullNFr>rLdisplay>1onyestruer.)rr<s rcoerce_privacy_filterrRsn }}v }r u::     # # % %D """  )))v 2r str | Nonecddlm}||durdS||}|dS|ddurdS|dS) zIReturn a canonical per-slot reasoning effort, or None when unset/invalid.r)parse_reasoning_effortNTrFnoneeffort)hermes_constantsrUrD)rrUparseds r_clean_reasoning_effortrZsn777777 } t # #E * *F ~t zz)%%v ::h  rTr%c||St|tr|St|tr4|}|dvrdS|dvrdS|St|S)N>0noofffalseF>rNrOrPrQT)r$r%r*r/r0)rrtexts r _coerce_boolras }% %{{}}""$$ . . .5 - - -4 ;;rFinclude_enabledrrcdict[str, Any] | NonecJt|tsdSt|dpd}t|dpd}|r|sdS|dkrdS||d}t |d}|r||d<t|d}|||d<|r&t|dd |d<|S) Nr rr moarreasoning_effort max_tokensrT) r$rCr*rDr/r0rZr:ra)rrcr r cleanrWslot_mts r _clean_slotrks0 dD ! !t488J''-2..4466H !!'R ( ( . . 0 0E 5t ~~5  t)1EBBE $TXX.@%A%A B BF +$* ! "$((<"8"899G%lC'(;(;TBBi Lrcdt|tsdSt|dpd}t|dpd}|s|sdS|sdS|sd|dS|d krd Sd S) a/Return a human-readable problem for a slot ``_clean_slot`` would drop. None means the slot is complete and valid. Mirrors ``_clean_slot`` exactly so the write-boundary validator (``validate_moa_payload``) and the tolerant runtime normalizer can never disagree about what is acceptable. z-must be an object with 'provider' and 'model'r rr zprovider and model are requiredzprovider is requiredzmodel is required (provider 'z' has no model selected)rfzMthe Mixture of Agents provider cannot be used inside a preset (recursive MoA)N)r$rCr*rDr/r0)rr r s r _slot_problemrms dD ! !?>>488J''-2..4466H !!'R ( ( . . 0 0E 1E100 &%% RQxQQQQ~~5  ^^ 4rraw list[str]c dt|tsdgS|d}t|tr|r|}n t|i}g}|D]G\}}t |pdpd}t|ts|d|dZ|d}t|tst|tr|gng}d}t|D]=\} } t| } | r"|d|d | d zd | 8|d z }>|s|d|d t|d } | r|d|d| I|S)ueReturn the problems ``normalize_moa_config`` would silently paper over. ``normalize_moa_config`` is deliberately tolerant: at *read* time a hand-edited config must degrade to defaults rather than crash the agent. That same tolerance at *write* time is a corruption engine — a client that sends a half-filled slot gets its whole preset silently replaced with the hardcoded defaults (#64156). API write paths call this first and reject invalid payloads loudly instead of saving something the user never chose. Returns a list of human-readable problems; empty means safe to save. zMoA config must be an objectpresetsrz (unnamed)zpreset 'z': must be an objectreference_modelsrz ' reference r?z: z.': needs at least one complete reference model aggregatorz' aggregator: ) r$rCrDDEFAULT_MOA_PRESET_NAMEitemsr*r/appendlist enumeraterm) rn presets_rawrqproblemsnamepresetlabelrefs complete_refsindexrissue agg_issues rvalidate_moa_payloadrs c4 0.//'')$$K+t$$11"-+C0H II fDJB%%''6;&$''  OOBuBBB C C C zz,--$%% <'d33;D66D $T?? # #KE4!$''E # R5 R Reai R R5 R RSSSS"  ^ OO\u\\\ ] ] ]!&**\":":;;  I OOGuGGIGG H H H Ordict[str, Any]c btttddtdddddd S)Nr,rAT) rrrsreference_temperatureaggregator_temperaturereference_timeoutdegraded_reference_policyrhreference_max_tokensfanoutr)rrr rrrr_default_presetr(s@577566"&"&:%+ $   rc$t|tsi}|d}t|tr4 t j|}n#tjtf$rg}YnwxYwt|tst|tr|gng}d|D}d|D}|st}t|dptt}t|dd||t|dt|dt|d t!|d t#|d d t%|d t'|dd S)Nrrc0g|]}t|dS)Trb)rkritems rrz%_normalize_preset..Is% I I IKd 3 3 3 I I Ircg|]}||SNrrs rrz%_normalize_preset..Js 6 6 6TT%5D%5%5%5rrsrTrrrrrhrrr) rrrrsrrrrrhrr)r$rCrDr*jsonloadsJSONDecodeErrorr!rwrrkrr rar"r)r2r6r:rJ)rnraw_refsr~rss r_normalize_presetr9s c4 ww)**H(C   z(++HH$j1   HHH  h % %D",Hd!;!;CH:: I I I I ID 6 6T 6 6 6D +(**SWW\2233Wx@V7W7WJ  2 2D99  !6sww?V7W7W!X!X"7@X8Y8Y"Z"Z6sww?R7S7STT%F GG/ 0 0& & "#'',"7"7>>!4CGG%?@@vl344!'(?!@"()A"B#$78%+,G%H\* & +A B B**X{33)$08H0I0IJJ%  rconfigcnt|}t|dS)Nrq)rrwkeys)rcfgs rlist_moa_presetsrs- v & &C I##%% & &&rr{c\t|}t|p|dpt}|d|}|5ddlm}d|dpd}|d|d|d t|S) Nrrqr)MoAPresetNotFoundErrorz, z(none)z MoA preset 'z$' was not found. Available presets: z. Run `hermes moa list`.) rr*rDrtr/ agent.errorsrjoinr)rr{r preset_namer|r availables rresolve_moa_presetrs v & &CdRcgg&677R;RSSYY[[K ^   , ,F ~777777IIc)n--9 $$ 3; 3 3 3 3 3    F  rr`ct|pd}|sdSt|}|d|}||ddsdS|S)aReturn the preset name iff ``text`` exactly matches an *enabled* preset. Used by the no-explicit-provider switch path (PATH B in ``hermes_cli/model_switch.py``) to recognize a bare ``/model `` that the user typed without the ``moa:`` prefix. This is an *implicit* match, so it must honor the per-preset ``enabled`` opt-out: a user who set ``enabled: false`` to disable a preset must not have a plain model switch whose name happens to collide with that preset key silently pivot the session onto the MoA virtual provider (issue #55187). Explicit selection via ``--provider moa`` / the model picker does not go through here, so a disabled preset is still reachable when the user explicitly asks for it. rNrqrT)r*r/rrD)rr`wantedrr|s rexact_moa_preset_namersq__ " " $ $F t v & &C ^   ' 'F ~VZZ 488~t Mrct|}t|pd}|r||dvrt|||d<|S)Nrrqr)rr*r/KeyError)rr{rris rset_active_moa_presetrs[ v & &C  OO ! ! # #E c)n,,uoo C Jrpromptr|ct|pdt|pi|d}tjt j|dddd}t|S)zBEncode a /moa one-shot turn for frontends that can only send text.r)rr),rBF) separators ensure_asciiutf-8ascii) r*rbase64urlsafe_b64encoderdumpsencodedecodeMOA_MARKER_PREFIX)rrr|payloadencodeds rencode_moa_turnrsfl##$V\r6::G& 7zFFFMMgVV fWoo  * * **rmessage!tuple[str, dict[str, Any] | None]ct|tr|ts|dfS|t td} t jtj | d d}n#t$r|dfcYSwxYwt| dpd}|t| dpifS)z%Decode a hidden /moa one-shot marker.Nrrrrr)r$r*rErlenr/rrrurlsafe_b64decoderr ExceptionrDr)rrrrs rdecode_moa_turnrs gs # #7+=+=>O+P+P}c+,,--.4466G*V5gnnW6M6MNNUUV]^^__ } X&&," - -F $W[[%:%:%@bAA AAs#A B00CC user_promptc&t|||S)z>Build the hidden one-shot payload used by TUI/gateway routing.)r|)r)rrr|s rbuild_moa_turn_promptrs ;v > > >>rcdS)NzUsage: /moa (runs one prompt through the default MoA preset, then restores your model; pick a preset from the model picker to switch for the session)rrrr moa_usagers m mr)rr)rrrr)rrrr*)rrrr3rr3)rrrr7)rrrrS)T)rrrr%rr%)rrrcr%rrd)rrrrS)rnrrro)rr)rnrrr)rrrror)rrr{rSrr)rrr`r*rrS)NN)rr*rrr|rSrr*)rrrr)rr*rrr|rSrr*)rr*)(__doc__ __future__rrrr&copyrtypingrrrtr __annotations__r rrr"r)r2r6r:rJrRrZrarkrmrrrrrrrrrrrrrrrrs@@@"""""" ,# )44(BCC6  (** /32222ZZZZ     *>>>>        $    F4          7<>,....b"8888v3333l''''     . + + + + + B B B B????? mmmmmmr