+ jHj-LRt^RIHt^RIt^RIt^RIt^RIt^RIHtH t ^RI H t ^RI H t ^RIHt^RIHt]P$!R4tR R R R R R!R R!R R"RR#RR$/tR%RRlltRRR RRRR R/tRRltRRlt]P2!RR44t^tRRlt!RR4tR#)&a8Gateway slash commands that switch or tune the model route: /model, /codex-runtime, /reasoning, /fast, /personality. Split out of ``gateway/slash_commands.py``; bound onto ``GatewayRunner`` through ``GatewaySlashCommandsMixin``. Origin internals are imported lazily inside the bodies to avoid the import cycle. ) annotationsN)AnyOptionalt) MessageEvent)atomic_config_write)base_url_host_matchesz gateway.runfastonnormaloffautocold ultrafastc(V^8dQhRRRRRRRR/#) modelstrruntimedicttier Optional[str]returnbool)formats"A/home/ubuntu/.hermes/hermes-agent/gateway/slash_commands_model.py __annotate__r$s/jjjdj-jSWjcd^RIHpV!WPR4VPR4VR7RJ#)zThe turn's own gate (``run_turn.py::_resolve_turn_agent_config``): a tier /fast accepts must be one the session's next request actually carries, so proxies and other providers are refused.)resolve_fast_mode_overridesproviderbase_url)r"r#rN)hermes_cli.modelsr!get)rrrr!s&&& r_fast_route_supportsr&$s9> & J/'++j:QX\ ^ei jjrshowThideFcV^8dQhRR/#)rrrr)rs"rrr1s  - rc h^RIHpV!4pV'gR#Vwr#\R\RW#R7R7#)zRefuse a model switch when the gateway is running stale code: a first-time lazy import on a new code path can crash on a stale cached dependency. Scoped to the highest-risk trigger.)detect_code_skewNgateway.model.error_prefixzgateway.model.err_skew)boot_revdisk_reverror)gateway.code_skewr+r)r+skewr-r.s r_model_switch_skew_guardr31s83  D H $(8O rcV^8dQhRR/#rrNoner)rs"rrr@sJJ$Jrc\"^RIHp\P!W V4GRjxL R#L5i)zWrite-through a resolved /model switch to the profile config at ``config_path``, off the event loop (the route comparison can do cold-start disk I/O).)persist_model_selectionN)hermes_cli.model_switchr8asyncio to_thread)result config_pathr8s&& r_persist_model_switch_to_configr>@s"@   3[ IIIs !,*,c]tRt^Gt$RtR]R&R]R&R]R&R]R&R tR]R &R tR]R &R tR]R&R t R]R&Rt R]R&R t R]R&R t R]R&R t R]R&R tR]R&R tR]R&]P"!]R7tR]R&RRltRRltR tR #)!_ModelSwitchContextzWEverything a /model switch needs beyond the target: current route + persistence policy.r session_keyrsourcer=rpersist_globalFone_turnreasoning_effortNzOptional[dict]restore_snapshot current_model openroutercurrent_providerrroute_providercurrent_base_urlcurrent_api_key user_provs custom_provs)default_factorylistexcluded_provscV^8dQhRR/#r5r)rs"rr _ModelSwitchContext.__annotate__]sTrc ^RIHpV!VPR7pV'gR#VPR/4p\ V\ 4'dfVPRR4VnVPRVP4VnVPR4VnVPRR4Vn TPR 4Vn ^R I H pV!V4Vn VPR /4PR 4p\ V\4'd WPnR#R# \dTPR 4Tn Ldi;i \dR#i;i)zGFill the current route from ``config_path``; fail-open to the defaults._load_gateway_configr=NrdefaultrEr"r# providers)get_compatible_custom_providerscustom_providers model_catalogexcluded_providers) gateway.runrWr=r% isinstancerrHrJrKrLrNhermes_cli.configr[rO ExceptionrQrR)selfrWcfg model_cfgr[excls& r read_config_ModelSwitchContext.read_config]s!4 &43C3CDC,I)T**%.]]9b%A"(1 j$BWBW(X%&/mmJ&?#(1 j"(E%!ggk2DO @M$CC$H!77?B/334HID$%%&*#& @$'GG,>$?! @    s;EB#E D=E!E>EEE EEc V^8dQhRRRR/#)roverriderrr6r)rs"rrrTvsQQtQQrc dV'dVPRVP4VnVPRVP4VnVPRVP4VnVPRVP4VnVPRVP 4VnR#R#)z:A session /model override supersedes the configured route.rr"r#api_keyN)r%rHrJrKrLrM)rcrjs&&rapply_override"_ModelSwitchContext.apply_overridevs !)gt7I7I!JD $,LLT=R=R$SD !"*,,z4;N;N"OD $,LLT=R=R$SD !#+<< 4;O;O#PD r)rMrLrHrJrOrRrKrN)__name__ __module__ __qualname____firstlineno____doc____annotations__rDrFrGrHrJrKrLrMrNrO dataclassesfieldrQrRrgrm__static_attributes__rrrr@r@Gsa KHdc'+n+M3(c(%)NM(cOSJL#&,,TBNDB2QQrr@cV^8dQhRR/#)rrz list[str]r)rs"rrrs rc ,.pVEF pVR,'d \R4MRpVPRVR, RVR, RV R 24VR ,'doVR ,R \pR PR V44pVR,\ V4, pV^8d\RVR7MRpVPRV V 24M3VP R4'dVPRVR, R24VPR4EK V#)zIText-list body for ``/model`` with no args on platforms without a picker. is_currentzgateway.model.current_tagrEz**namez** `--provider slug`:modelsN, c3."TF pRV R2xK R#5ir}Nr).0ms& r 0_model_provider_listing_lines..s";UQqc8U total_modelsz gateway.model.more_models_suffix)countz api_urlz `)rappend_TEXT_LISTING_MODELSjoinlenr%)rZlinesptagshown model_strshiddenextras& r_model_provider_listing_linesrsE 01,a+,R r!F)OAfI;auAFG X;;hK 5!56E";U";;J~&U3FKQTU:A8G[]E LL2j\%1 2 UU9   LL3q|nA. / R Lrc]tRt^tRtRRltRRltRRltRR /R R lltR R /RRllt Rt RRlt RRlt RRlt RRltRRltRRltRRltRR ltR!R"R#R /R$R%lltRBR&R'lltR(R)ltR*R /R+R,lltRBR-R.lltR/R0ltR1R2ltR3R4ltR5R6ltRCR7R8lltR9R:ltR;R<ltRCR=R>lltR?R@lt RAt!R #)DGatewayModelCommandsMixinzUModel-route slash commands (/model, /codex-runtime, /reasoning, /fast, /personality).c V^8dQhRRRR/#)rctxr@ raw_inputrr)rs"rr&GatewayModelCommandsMixin.__annotate__s&36rc h"^RIHp^RIHp\ 4pV'dRV3#\ P !WbVPVPVPVPVPW1PVPR7 GRjxL pVP'gR\RVP R73#^RIHp \ P !WWP&WAPVR7GRjxL VR3#LpL \(d$p \*P-R T 4Rp ? TR3#Rp ? ii;i5i) zWResolve a /model switch off-loop. Returns ``(result, None)`` or ``(None, error_text)``.rV) switch_modelN) rrJrHrLrM is_globalexplicit_provideruser_providersr\r,r/)(enrich_model_switch_warnings_for_gateway)rArBr\load_gateway_configz/preflight-compression switch warning failed: %s)r_rWr9rr3r:r;rJrHrLrMrCrNrOsuccessr error_messagehermes_cli.context_switch_guardrrArbloggerdebug) rcrrrrBrWr skew_errorr<rexcs &&&&& r_perform_model_switch/GatewayModelCommandsMixin._perform_model_switchs 58-/ # #(( @T@T++c>R>R//3;M;M/ --   ~~~7v?S?STT T Q `##8$TcTc0@0@$8  t|'    Q LLJC P Pt| QsTB D2 C= D2#D2=7D4C?5D9D2?D D/ D*"D2*D//D2c$V^8dQhRRRRRR/#)rrr@pickerrrrr)rs"rrrs$6ISW\irc  VPVP4pVfR#VPVPVPVP VP VP\VRR4R7R# \dYp\PRT'dRMRT4\R\RTPYRPR 7R 7uRp?#Rp?ii;i) zIn-place swap on the cached agent; returns the error reply when it failed. The agent rolls back to the OLD model/client and re-raises; the commit (DB, override, eviction, config) is aborted so the next message doesn't rebuild a broken agent. Nruntime_capabilities) new_model new_providerrlr#api_mode capabilitiesz+%s model switch failed for cached agent: %sPickerzIn-placer,zgateway.model.err_switch_failed)rr0currentr/)_cached_agent_forrArrtarget_providerrlr#rgetattrrbrwarningrrH)rcr<rr cached_agentrs&&&& r_switch_cached_agent_model4GatewayModelCommandsMixin._switch_cached_agent_models --coo>     % % **9O9O6??$V-CTJ &   NN=6xWacf ,9AQAQY\fwfwx   sAA99 CA CCCc(V^8dQhRRRRRRRR/#)rrr@rDrrrrr)rs"rrrs2XX.XEIXSWX Xrc "^RIHp\VRR4pVeVPP V4GRjxL pV'g\VRR4'dRVnVP VPVPVPVPVPR7GRjxL \VR4'g/VnR V!VP"4 R V!VP4 R VP$;'g VP R V'dR MR R2 VP VP&&RVPRVPRVP(RVPRVPR\+VP,;'g/4R\+VP.;'g/4/VP0VP&&V'd(VP3VP&VP44M@V'g9\VR4'd'VP6P9VP&R4Rp VP:'d\=WP>4GRjxL VP:'dnV fjVPKV4fWVPPMVP&R4GRjxL VP0P9VP&R4MRV'gKVPPMVP&VP0VP&,4GRjxL VPOVP&4V #EL EL \d"p \PRT 4Rp ? ELRp ? ii;iEL( \dUp \PART 4\CR\ET 4;'g\GT 4PHR7p Rp ? ELRp ? ii;iEL5 \d.p \PART 4\CRT R7p Rp ? LRp ? ii;iL \d\PRRR7ELi;i5i) aPersist a committed switch: session DB, next-turn note, config write-through, override map. Returns the warning for a ``--global`` switch whose ``config.yaml`` write or stale-override cleanup failed (the switch then stays a session override), else ``None``. )format_model_for_display _session_dbNwas_auto_resetF)r"r#rz(Failed to persist model switch to DB: %s_pending_model_notesz$[Note: model was just switched from z to z via z. z-This override applies to the next turn only. rEz-Adjust your self-identification accordingly.]rr"rlr#rrequest_overridesr _pending_one_turn_model_restoresz"Failed to persist model switch: %s$gateway.model.err_config_not_updatedr/z4Failed to clear persisted session model override: %sz gateway.model.err_stale_overridez(Failed to persist session model overrideTexc_info)(r9rrasync_session_storeget_or_create_sessionrupdate_session_model session_idrrr#rrbrrhasattrrrHprovider_labelrArlrrr_session_model_overrides_claim_one_turn_restorerGrpoprCr>r=rrrtypero_channel_override_forset_model_override_evict_cached_agent) rcr<rrBrDrr_sess_db _sess_entryr global_errores &&&$$$ r_record_model_switch.GatewayModelCommandsMixin._record_model_switchs E45   N$($<$<$R$RSY$ZZ '+7G"O"O16K.33**F,<,PRS;  = !!#//2 V%%z63I3I9V\VdVd V__ f&>&>&D&D"!E D!O3?O6.Q3AP37P18P3<QMM N *NQN  QN O0A O+%Q+O00Q3O66 P.#P)$Q)P..Q1P33"QQQQrNc ,V^8dQhRRRRRRRRRR /#) rrr@rDrrrrrrr)rs"rrr.s68 8 .8 =A8 KO8 #8  8 rc `"^RIHp^RIHpHp\ RV!VP 4R7\ RVP;'g VPR7.p VPp /p Rp \P!\4;_uu_4V!4PR/4p \V \4'd&V PR 4e\!V R ,4p RRR4\V \4'g/p T!VP VPVP";'gVP$;'gR VP&;'gVP(;'gR T VP*T V PR 4;'gV PR4V PR 4V PR 4R7 GRjxL p V 'dV P-\ RV R R74V 'd;V P.'d)V P-\ RV P.R R74V 'd+V P-\ RV P14R74\3VP";'gR R4;'dRVP P549pV'g4V'gVP6R8XdV P-\ R44VP8'd'V P-\ RVP8R74\;VRR 4'dV P-RVP< 24VP>'d<Ve8V P-\ RVR74V P-\ R44MjVP>'dV P-\ R44M=V'dV P-\ R44MV P-\ R44R PAV 4# +'giELB;iELd5i)!zQConfirmation text with full metadata (display form shortens opaque Palantir IDs).rV)r$resolve_display_context_length_asynczgateway.model.switchedrzgateway.model.provider_label)r"Nrcontext_lengthrErYr"r#)r#rl model_infor\config_context_lengthconfigured_modelconfigured_providerconfigured_base_urlzgateway.model.context_label,)tokenszgateway.model.max_output_labelz gateway.model.capabilities_label)rz openrouter.aiclaudeanthropic_messagesz$gateway.model.prompt_caching_enabledzgateway.model.warning_prefix)r usage_noticeu⚠️ zgateway.model.session_only_hintzgateway.model.saved_globalzgateway.model.next_turn_only )!r_rWr9rrrrrrr contextlibsuppressrbr%r`rintr#rLrlrMrOr max_outputformat_capabilitiesr lowerrwarning_messagerrrCr)rcr<rrDrrrWrrrmire config_ctxctx_lenopenrouter_claudes&&&$$$ r_model_switch_confirmation4GatewayModelCommandsMixin._model_switch_confirmation.s 5j &.FvGWGW.X Y ,v7L7L7f7fPVPfPf g        + +,.227B?I)T**y}}=M/N/Z +;!<= ,)T**I<   f44__BB(<(<BBNN??c&9&9??RB --Z&]]95OOw9O ) j 9 ) j 9    LL8GA;P Q "--- LL;r}}UVFWY Z LL=BLbLbLde f !&//"7"7R I r rhZ`ZjZjZpZpZrNr ,CW0W LLAB C  ! ! ! LL96CYCYZ [ 6>2 . . LL76#6#6"78 9    ,": LL9<P Q LL<= >     LL78 9  LL9: ; LL<= >yyQ, + +  sB P. APA P.)P.=P.P.&&P. :P.P+ P.%P.:P. /P.P. %P.3P.;T>T^g,, E *51!0/, + *51!s$D'D(+D; D% ( D8 ;E c$V^8dQhRRRRRR/#rr)rs"rrrs)-_-_=P-_ei-_nq-_rc "V'dRM VPp^RIHpHpV!W4wrRp V eV'd\ R\ R4R7#^RIHp VP;'gRP4P4p V !V 4eT MRp \P!WhWV 4GRjxL VPWV4Rp VP'd \WP4GRjxL MGMFVP-WV4pVeV#VPWV4VP/WW5VR 7GRjxL p VP1WWTV R 7GRjxL pV 'dYVP;'dV RJ;'dVP3RV 4pTR\ V'dRMRV R7,, pM}VP'dlV'gd^RIHpTRTP9VP:V!VP<4VPVP;'dV RJR7,, pTV eR\ R4,,#R,#ELELn \ dVp\"P%RR R 7\ R \'T4;'g\)T4P*R7p Rp?ELRp?ii;iELELs5i)F)defer_local_model_picklocal_authority_liverENr,zgateway.model.err_once_localr/parse_reasoning_effortzFailed to persist model switchTrr)rBrDr)rDrragent.reasoning_effortrgateway.reasoning.set_globalgateway.reasoning.set_sessioneffort_platform_config_keyrCzgateway.model.local_next_turn)rD gateway.session_setting_commandsr%r&rrr(rFstriprr:r;r!rCr>r=rbrrrrrorrr_save_gateway_config_keyr_r/_apply_reasoning_selectionrAr)rcr<rrBrrDr%r& authoritylivelevelr(r-rrr0replysavedr/s&&&$$ rr5GatewayModelCommandsMixin._commit_model_switch_lockeds"5 a.t<   5Q?]=^__ ?**00b779??AF4V<HFbE##$:tUZ[ [ [  ' 'V <L!!!o9&//RRR"33FHE   ' 'V ?[/55f>Z>Z[`>ab 1  FNN## I  sIB9B$B"B$B9AB9B7 B9"B$$ B41B93B44B9c$V^8dQhRRRRRR/#)rr<rrr@rrr)rs"rrrs$- - !- (;- - rc aaaaa "^RIHp^RIHp\ SP SP SPSPSPSPRRRR7 pSPSP4pVeg\\V4RR4eORVVV3R llo R V V3R llpSPSSPVSP Wh4GRjxL 'dR#\#R SP;'g \#R 4V!SP 4R7R.p \$P&!V3R\(/VBGRjxL p V P+\-V 44V P1\#R44V P1\#R44V P1\#R44RP3V 4#LL \.dLpi;i5i)zP``/model`` with no args: interactive picker where supported, else the text list.)list_authenticated_providers) get_labelTF) rJrLrHrr\r^non_blocking_catalogsprobe_custom_providersprobe_current_custom_providerNrEc$V^8dQhRRRRRR/#)rmodel_idr provider_slugrr)rs"rrDGatewayModelCommandsMixin._model_listing_reply..__annotate__s& f fs f3 f3 frc<"SPSWSP4GRjxL wr#VeV#SPVSSPRR7GRjxL #L3L5i)NTr)rrBr)rSrTr<r0rr<rcs&& r_picker_switchFGatewayModelCommandsMixin._model_listing_reply.._picker_switchs_&*&@&@h_d_k_k&l l $ L!66vs5<<`d6eee!mfs!!AA.AAAAc(V^8dQhRRRRRRRR/#)r_chat_idrrSrTrr)rs"rrrUs0 I I3 I# IVY I^a Irc<"SfS!W4GRjxL #^RIHpV!S4;_uu_4S!W4GRjxL uuRRR4#L5L +'giR#;i5i)N_profile_runtime_scope)r_r])rZrSrTr]rW profile_homes&&& r_on_model_selectedJGatewayModelCommandsMixin._model_listing_reply.._on_model_selectedsR'!/!HHH>+L99!/!HH:9II:99s5A!A A! A A A  A! A  A  A!zgateway.model.current_labelgateway.shared.unknown_value)rr"rEr@z gateway.model.usage_switch_modelz#gateway.model.usage_switch_providerzgateway.model.usage_persistr)r9rMhermes_cli.providersrNrrJrLrHrNrOrR_delivery_adapter_forrBrrrIrArr:r;rextendrrbrr) rcr<rr^rMrNr=rHr_rrZrWs ffff @r_model_listing_reply.GatewayModelCommandsMixin._model_listing_replys I2 11CDXDX++CNN --#BTBT#'udh ,,SZZ8  74=:Mt#T#` f f I I,,UCJJZh}}}08I8I8n8nQOmMn%c&:&:;=>@B %//0LAYmAqAAI LL6yA B  Q9:; Q<=> Q456yy~ A   sUCGG G'G$G' G GG &A GG GGGGc$V^8dQhRRRRRR/#)rr<rrr@rztuple[bool, Optional[str]]r)rs"rrrs$! ! !! (;! #! rc aaa"^RIHpHp\P!TSP SP SP;'gSP;'gRSP;'gSP;'gRSPV!SPSP44R7GRjxL pVfR #RVVV3RllpSPVP P"4p\%RVP&VP(VR7p R SP+VR VP&WR 7GRjxL 3#L \dRpLi;iL5i) u-Selection-guard confirmation for the typed path (pickers confirm via their own UI). The unified registry (cost + data-policy guards) runs off-loop — pricing lookups may hit models.dev on a cache miss. Returns ``(fired, reply)``; the reply is None when the platform rendered confirm buttons itself. )combined_selection_warningselection_context_for_agentrE)r"r#rlrselection_contextNc V^8dQhRRRR/#)rchoicerrr)rs"rrLGatewayModelCommandsMixin._model_selection_guard_reply..__annotate__*s S S3 S3 Src<"VR8Xd+\RSP;'g \R4R7#SPSSSPR7GRjxL #L5i)cancelzgateway.model.switch_cancelledrar)rBN)rrHrrB)rmrr<rcs&r_on_cost_confirmPGatewayModelCommandsMixin._model_selection_guard_reply.._on_cost_confirm*sS!9ARARAwAwVWXvVwxx2263szz2RR RRs A2AAAzgateway.model.guard_confirm)titlemessageprefixTr)r<commandrsrthandler)FN)!hermes_cli.model_selection_guardsrirjr:r;rrr#rLrlrMrrrArb_typed_command_prefix_forrBrrrsrt_request_slash_confirm) rcr<rr<rirjrrq_prts f&ff r_model_selection_guard_reply6GatewayModelCommandsMixin._model_selection_guard_replys9  I#--*F,<,T>TUXUdUd>e"f G ?  S S  + +ELL,A,A B1PWP_P_hjk466 w7    '  G  sZEAEE2E6E<E=EAEE EEEEc V^8dQhRRRR/#rr<rrrr)rs"rrr6sBBB-Brc "VP4;_uu_4GRjxL VPV4GRjxL uuRRR4GRjxL #L/LL +GRjxL 'giR#;i5i)uHandle /model command — switch model. Taken under the switch lock BEFORE the first await so concurrent commands commit in issue order (see ``_model_switch_lock``).N)r_handle_model_command_locked)rcr<s&&r_handle_model_command/GatewayModelCommandsMixin._handle_model_command6sF**,,,::5AA-,,A-,,,sYA2AA2AAA A2 A A2AA2A/ A A/ 'A/ ) A2c V^8dQhRRRR/#rr)rs"rrr<s5`5` 5`5`rc "^RIHp^RIHpHpRp\ \ VRR4RR4'dVP VP4pV!VP4P44pVP'dRVP4^, 2#VP'd9\P!\4;_uu_4^RIHpV!4RRR4\$P&!VP(VP4GRjxL pVP+V4p \-T TT;'gTR , V!VP.VP0VP2VP4R 7VP2VP6VP2'dVP9V 4MRR 7p V P;4V P=VP>PAV /44VPB'g-VP4'gVPEWV4GRjxL #VPGWPBVP4V4GRjxL wrV eV #VPIWV 4GRjxL wrV 'dV#VPKWVRR 7GRjxL # +'giEL;iELLLgLGL!5i)  _hermes_home)parse_model_switch_argsresolve_persist_behaviorNrrF❌ )clear_provider_models_cache config.yaml)is_oncer)rArBr=rCrDrFrGr)&r_rr9rrrrrBget_command_argsr2errorserror_messages force_refreshrrrbr$rr:r;!_normalize_source_for_session_key_session_key_for_sourcer@r is_sessionrrrF _snapshot_session_model_overridergrmrr%targetrerr|r)rcr<rrrr^requestrrBrArr<r0 guard_fired guard_replys&& rr6GatewayModelCommandsMixin._handle_model_command_locked<sA,] 74402F N N@@NL)%*@*@*B*H*H*JK >>>'0021567 7  $$Y//I+-0 (()O)OQVQ]Q]^^226: !$%55F3!!7#5#5w")";";__$55SZSbSbSbTBB;Ohl- 0  488<<["MN~~~g&?&?&?225|LL L"88nngNgNgiopp   L)-)J)J5W])^#^  55f&Y^5___U0// _:Mp$_`sA?K+K."KJ(6KJ<$K:A#KA$KKK*J?+.KK!K;K<'K#K$K( J9 3 K?KKKKrArE generationc ,V^8dQhRRRRRRRRR R /#) rr<rlimitrrArr Optional[int]rr6r)rs"rrrus9OOOdO\_O0=OIMOrc paaaaSPeSPSP4MRp\VRR4pV'd&\V4'dV!VVVVV3RlSR7R#SP SP SSS44R# \ d\PRRR7R#i;i)aAfter a usage-window refusal's reply: offer the plan's recommended model as a button where the platform already has quick-choice buttons, else one line of text. Runs as the adapter's post-delivery callback, so the offer always lands under the reply (the reply is sent after this turn returns). The tap switches this session only (never the default) and re-sends the refused message, like /retry. No credits button in a chat: anyone in the room could spend the owner's credits, so the Portal is named instead. Hermes never switches on its own.Nregister_post_delivery_callbackc*<SPSSS4#N)_offer_usage_limit_switch)r<rrrcsrGGatewayModelCommandsMixin._schedule_usage_limit_offer..sd.L.LUTY[e.fr)rz#usage-limit offer scheduling failedTr) rBrcrcallable_track_background_taskrrbrr)rcr<rrArrHregistersfff$d r_schedule_usage_limit_offer5GatewayModelCommandsMixin._schedule_usage_limit_offerus OBG,,BZd00>`dGw(I4PHx11&f$.0  ' '(F(FueU_(` a O LL>L N Os BAB+"B"B54B5c(V^8dQhRRRRRRRR/#) rr<rrrrrrr6r)rs"rrrs0DD\D$D4ADMQDrc Faaaa "^RIHpVPR4;'g.Uu.uF6p\V\4'gKVPR4'gK4VNK8 ppSP pVfR#SP VP4pSPV4p SPV4o V'dV e\\V 4RR4eRVVVV 3Rllp VUu.uFrpR\VR,4R \R \VPR 4;'g VR,4\VPR 4;'gR 4R 7RR/NKt p pSPSS \R4V V R7GRjxL 'dR#V!W( R2RRR7p V eBV 'd8V PVP V SP#S4R7GRjxL R#R#R#uupiuupiLkL \$d\&P)RRR7R#i;i5i)r)limit_next_steps_from_payload suggestionsrNsend_choice_pickerc$V^8dQhRRRRRR/#rrZrvaluerr)rs"rrIGatewayModelCommandsMixin._offer_usage_limit_switch..__annotate__s&ggsg3g3grc<"Se$SPSS4'd \R4#SPSTSfRMSS3R7GRjxL #L5i)Nz&platform.discord.picker.choice_expired)offer)_usage_limit_offer_is_staler_accept_usage_limit_switch)rZrr<rrcrAs&&r _on_choiceGGatewayModelCommandsMixin._offer_usage_limit_switch.._on_choicesg!-$2R2RS^`j2k2k !IJJ!%!@!@uJ4FD[ZdLe"A"ggggsA*A A Arlabelz!gateway.usage_limit.switch_choicenoterE)rrrzFz gateway.usage_limit.picker_titlerschoiceson_choice_selectedT) model_command topup_commandportal)rCzusage-limit offer failedr)agent.plan_limitsrr%r`rrBryrrcrrrrr_try_send_choice_pickersendr_reply_metadatarbrr)rcr<rrrsrrBrurHrrtextrAsff&f @rr3GatewayModelCommandsMixin._offer_usage_limit_switchs C D',yy'?'E'E2'Eq'E*UVX\J]1bcbgbghobp11'EKq\\F~33FOODF008G66v>Kw2wtG}Nbdh7i7ugg;FG;FQ$S7_#Q'JRUVWV[V[\cVdVrVrhijqhrRs,/f 0C0C,D&F(%1;FG55{!4V2Wah+567770PUFVfjswxD"tll6>>4$BVBVW\B]l^^^(,"1rG7 _ D LL3dL C DsH!G8G*G*!G*'G89H!;AG8,G8,A$G/G/$$G8G4 G8H!G8/0G8G6 G8$H!* G86G88"HH!HH!c$V^8dQhRRRRRR/#)rrArrrrrr)rs"rrrs"sPTrc \VPV4PP4\V48g# \\ \ \3dR#i;i)z[True once the session has started a newer run than the refused one. Fails open (not stale).F)r_session_state persistentrun_generationAttributeErrorKeyError TypeError ValueError)rcrArs&&&rr5GatewayModelCommandsMixin._usage_limit_offer_is_stalesP t**;7BBQQRVYZdVee e)Z@  s9<AArc(V^8dQhRRRRRRRR/#)rr<rrSrrOptional[tuple[str, int]]rr)rs"rrrs*##l#c#0I#UX#rc Haaaa a"^RIHp\P!SPSP 4GRjxL pSP V4oRp\\SRR4RR4'dSPSP 4p\STT;'gTR, RR7o RV VVVV3R llpSPPS4pVfV!4GRjxL p M.^R IH p V !V4;_uu_4V!4GRjxL p RRR4SPPS4p V RJ;'d WJ;'dV PR 4R 8Hp V 'd"SPSPSV44X #ELLLL +'giL;i5i) zThe tap: switch this session to *model_id* on Nous, then re-send the refused message. ``offer`` is the refused turn's ``(session_key, run_generation)``.rNrrFr)rArBr=rCcV^8dQhRR/#)rrrr)rs"rrJGatewayModelCommandsMixin._accept_usage_limit_switch..__annotate__s b bs brc4<"SP4SPSPPS/44SP SSRSP 4GRjxL wrVeV#SP VSSP RR7GRjxL #L3L5i)nousNTr)rgrmrr%rrBr)r<r0rr<rSrcrAs r_switchEGatewayModelCommandsMixin._accept_usage_limit_switch.._switchs OO    t<<@@bQ R"&"<"$``)<``:AVZ`A`   ' '(H(HPU(V W =_$$(65se5F"FAF"AF"#F $F"? F F  F-F"= F"F"%$F" F" F F F"c$V^8dQhRRRRRR/#)rr<rrrrr6r)rs"rrrs( M M| MLe Mqu Mrc "^RIHpVPVP4pVeVeVP!V!'dR#VP \ RVPVPVPVPR74GRjxL R#L \d\PRRR7R#i;i5i)r) MessageTypeNz/retry)r message_typerB raw_messagechannel_promptz!usage-limit retry dispatch failedTr) gateway.platforms.eventrrcrBrhandle_messagerTEXTrrrbrr)rcr<rrrHs&&& rr5GatewayModelCommandsMixin._dispatch_usage_limit_retrys7,,U\\: ?u0T5U5UW\5]5]  M((K,<,R>R*TU U U M LL:C=B>>Cc V^8dQhRRRR/#rr<rrrr)rs"rrrsHHH#Hrc "^RIHpTPV'dVP4P 4MR4wr4V'dRRP V4,#^RIHpHpTPT!4Y3eTMRR 7pTP'dBTe>TP'd,TPTPTP 44TP'dR MR RTP& 2# \dp\RTR7uRp?#Rp?ii;i \d\"P%R R R 7Lni;i5i)zHandle /codex-runtime; a real change evicts the cached agent so the new api_mode applies on the next message (avoids prompt-cache invalidation mid-session).)codex_runtime_switchrEru ❌ ) load_config save_configz(gateway.codex_runtime.config_load_failedr/N)persist_callbackz7could not evict cached agent after codex-runtime changeTru✓u✗ ) hermes_clir parse_argsrr2rrarrrbrapplyrrequires_new_sessionrrrBrrrt) rcr<crs new_valuerrrrr<s && r_handle_codex_runtime_command7GatewayModelCommandsMixin._handle_codex_runtime_commands ;NNu5+A+A+C+I+I+KZ\] HMM&11 1 L B M9G\ bf  >>>i38S8S8S g(()E)Eell)ST">>>%u5Qv~~6FGG L?sK K L g Vae f gsfA E#D+/EE2*D&E.E D# DD#ED##E&"E E E  Ec V^8dQhRRRR/#rr)rs"rrrs&:&:|&:&:rc $"^RIHp^RIHpHpHpHpHpVP4P4pV!4p V!V 4p V'gV!V 4p \R4\R4.p V P4F6wrW8XdRMRpV P\RV V 2V!V4R74K8 V P\R 44R PV 4#V!W4wp pT!T 4'g\R\R4R7#T 'g \R4#\RT R7# \d/p ELi;i \d?R R PR T 44,p\RTP!4TR7u#i;i5i)uZHandle /personality — list or set a personality (hermes_cli.personality owns the state).rV)active_personality_nameavailable_personalitiesdescribe_personalitypersist_personalityresolve_personalityzgateway.personality.headerzgateway.personality.none_optionu ✓rEzgateway.personality.item)r{previewzgateway.personality.usagerz`none`, rc3."TF pRV R2xK R#5irr)rns& rrHGatewayModelCommandsMixin._handle_personality_command..s.OA1#Qxrzgateway.personality.unknown)r{ availablezgateway.personality.save_failedz$gateway.personality.err_config_writer/zgateway.personality.clearedzgateway.personality.set_to)r{)r_rWhermes_cli.personalityrrrrrrr2rbritemsrrrr)rcr<rWrrrrrargsr personalitiesrrr{promptmarker _new_promptrs&& r_handle_personality_command5GatewayModelCommandsMixin._handle_personality_commands}4  %%'--/ )+F07 -f5G34a8Y6Z[E - 3 3 5 #'? 0$x7HRfgmRno!6 LL67 899U# # \ 3D A D+ #4((6a@f>gh h23 3-D991 F  \"TYY.O.O%OOI2QZ[ [ \s_3FD0F BF! E, F:FF0 E=FEFAF  F F  Fc V^8dQhRRRR/#)rkey_pathrrrr)rs"rrr&src ^RIHp^RIHp^RIHpV!4R, pV!V4pVP R4EvrW#!V.VO5!V &\Wg4R# \d"p \PRY4Rp ? R #Rp ? ii;i) zXSave a dot-separated key to config.yaml (shared by /reasoning, /fast and their pickers).) _nested_dict)_gateway_config_home)read_user_config_rawr.Tz Failed to save config key %s: %sNF) gateway.slash_commandsrr_rrarsplitrrbrr0) rcrrrrrr= user_configparentsleafrs &&& rr32GatewayModelCommandsMixin._save_gateway_config_key&sx74:*,}<  .{;K%^^C0NW8=L /w / 5  9  LL;X I s2A B!A==Bc V^8dQhRRRR/#)rrArrr6r)rs"rrr6s..3.$.rc JVPW4VPV4R#)zTStore (or clear with None) the session reasoning override and drop the cached agent.N)_set_session_reasoning_overrider)rcrArs&&&r_set_reasoning_override1GatewayModelCommandsMixin._set_reasoning_override6s ,,[@   -rc ,V^8dQhRRRRRRRRRR/#)rrAr platform_keyrrCrrr)rs"rrr;s;%@%@%@.1%@:=%@OS%@ %@rc ^RIHpT;'gRP4P4p^RIHpV!W4p\ PV4pVe?WnVeWn VPRV R2V4V'dRMRp \WR 7#VR 8XdWV'd \R 4#VPVR4VP4VnVPV4\R 4#V!V4p V f\R VR7#WnV'd[VPRV4'd%TP!YeT MR4\RVR7#VP!W4\RVR7#VP!W4\RVR7#)zCApply a /reasoning argument (typed or picked) and return the reply.r'rElocal_live_for_routeNzdisplay.platforms.z.show_reasoningz gateway.reasoning.display_set_onz!gateway.reasoning.display_set_off)rresetz*gateway.reasoning.reset_global_unsupportedzgateway.reasoning.reset_donezgateway.reasoning.unknown_argargr)r*r,z(gateway.reasoning.set_global_save_failedr+)rr(r2rr1r'_REASONING_DISPLAY_TOGGLESr%_show_reasoningshow_reasoningr3rr _load_reasoning_config_reasoning_configrr!) rcrAr$rrCr(r'r6r'keyparseds &&&&& rr44GatewayModelCommandsMixin._apply_reasoning_selection;sr <"##%++-I#D6)--e4  #' &*#  ) ),>|nO*\^b c8<4BeCS0 0 G EFF  0 0d C%)%@%@%BD "  $ $[ 134 4'. >4%@ @!' ,,-EuMM,,[DT&Z^_7FF  ( ( =?N N $$[90??rc ,V^8dQhRRRRRRRRRR /#) rr<rrArrsrrQrrr)rs"rrrbs4!03R7P%R/4;'g/pRRR4VP%R4;'gVP%R4T ;'g+VP%R4;'gVP%R4V !RV/43oV f\AR4RupoM@V P%R4RJd\AR4RupoMV P%RR4oS!S.SO5!pSP'd \AR4M \AR4pS\!SR/4;'g/9pV'd \AR4M \AR4pRVVV3RllpSPCVS\AR VVVR!7R"RR#\AR$4R%SR8H/.VVV3R&lV4OR'R*4OVR(7GRjxL pV'dR#\AR)VVVR!7#ELD +'giEL;iL45i)+uIHandle /reasoning command — manage reasoning effort and display toggle.r.)VALID_REASONING_EFFORTSN) local_liver-TrrrE)rBrArr0)effort_display_labelrV)get_current_runtimerXr"rYzgateway.reasoning.level_defaultmediumenabledFz gateway.reasoning.level_disablednoner-zgateway.reasoning.display_onzgateway.reasoning.display_off_session_reasoning_overrideszgateway.reasoning.scope_sessionzgateway.reasoning.scope_globalc$V^8dQhRRRRRR/#rr)rs"rrIGatewayModelCommandsMixin._handle_reasoning_command..__annotate__s& U U US US Urc2<"SPSSV4#5ir)r4)rZrr$rcrAs&&r_on_reasoning_choiceQGatewayModelCommandsMixin._handle_reasoning_command.._on_reasoning_choices22; eT Tszgateway.reasoning.picker_title)r7scopedisplayrrzgateway.reasoning.choice_nonerzc3J<"TFpRVRS!V.SO5!RVS8H/xK R#5i)rrrzNr)rlv_routecurrent_effortr:s& rrFGatewayModelCommandsMixin._handle_reasoning_command..s753bB)=b)J6)JLZ\`nZno3s #c3J"TFpRVR\RV 24RR/xK R#5i)rrzgateway.reasoning.choice_rzFNr)rvs& rrrKs264aAw,EaS*I(JLZ_`4s!#rzgateway.reasoning.status)r(r'r()"r_r/rr8rr2_parse_reasoning_command_argsr:r;rrBr_load_show_reasoningr,r1r9rrr%!_resolve_session_reasoning_configr/rr4agent.reasoning_effortr:rWhermes_cli.codex_runtime_switchr;rrrbr=rr)rcr<r/r8raw_argsr rC_reasoning_sourcer9_live_session_modelrcrWr;_session_route _model_cfgr7 display_statehas_session_overriderErC picker_sentrIrJr:r$rAsf& @@@@@r_handle_reasoning_command3GatewayModelCommandsMixin._handle_reasoning_commandts4<))+113#AA(K#*"3"3D4Z4Z\a\h\h"ii223DE #88:?ell3 3E @#*52BD#IT#QD d6;AAr F F{ S Y YWY ^ ^_f g m mkm "&!G!G<<["H" ,ELL,A,AB 22; d2r r  # # @4G"4)CRHNNBSST_`ffdf   + +-$:J:JKOOPWY[\bb`bJ,   z * H HjnnZ.H  R RjnnY7 R R:>>';R * 5 6  :$%&G$H( !E> VVI % '$%&H$I6 !E>VVHh7N(A&AE=A=Q=Q=Q89WXYxWy *wt=[]_/`/f/fdfg8L34RSTtRu U U!88  4EXef&'1-L+M|]kou]uv535646  49    +5}]]yj0, + +*  sA,O4N85A3O)OOA O)AO/O'O/.N;O=OO0BO1*O O)A1OO O'O; O  Oc(V^8dQhRRRRRRRR/#)rrArrpersistrrr)rs"rrrs);;;S;4;\_;rc \PV4pVf\RVR7#VwrVpV'd \V4MVP4pWPn^RIHp V'dgVPRV4'dOV !W4eVPW4MVPVRRR7VPV4\RVR 7#VPW4VPV4\R VR 7#) z>Apply a /fast argument (typed or picked) and return the reply.Nzgateway.fast.unknown_argr)r&zagent.service_tierT)clearzgateway.fast.saved)rzgateway.fast.session_only) _FAST_SELECTIONSr%rupper _service_tierr1r'r3"_set_session_service_tier_overrider) rcrArr` selectionr saved_value label_keyrr's &&&& r_apply_fast_selection/GatewayModelCommandsMixin._apply_fast_selections$((/  /U; ;'0$9 )) u{{}!I t445I;WW#D6B77 J77 TQU7V  $ $[ 1)7 7 // B   -,E::rc V^8dQhRRRR/#rr)rs"rrrs1515 1515rc aaa"^RIHpHp^RIHpHpSP VP4P4P44wpo\P!SPVP4GRjxL pSPV4oSPSR7SnV!4p\P!SP"VSVR7GRjxL wr\'W4'g \)R4#TP+Wf4p^RIHp V !WP+R4V P+R 4V P+R 4R 7p VR 8XdV 'g\)R V R7#V'dVR8wdSP1SVSR7#V!SP 4p R\)R4R\)R4/P+W4pRVVV3RllpSP3TS\)RVR7.ROV 'dR MR!OUu.uFpRVR\)RV 24RV V8H/NK upVR7GRjxL pV'dR#\)RVR7#ELELk \$dT!T4/rEL~i;iuupiLA5i)"uHandle /fast — the CLI Priority Processing toggle; session-scoped unless ``--global`` (persists agent.service_tier, parity with /model).)FAST_ARG_ALIASESservice_tier_word)rW_resolve_gateway_modelN)rA)rBrArzgateway.fast.not_supported)ultrafast_offeredr"r#rl)r"r# access_tokenrz$gateway.fast.ultrafast_not_supportedrstatusr`r zgateway.fast.status_fastr zgateway.fast.status_normalc$V^8dQhRRRRRR/#rr)rs"rrDGatewayModelCommandsMixin._handle_fast_command..__annotate__s& Z ZC Z Z Zrc4<"SPSVSR7#5i)rt)rj)rZrrCrcrAs&&r_on_fast_choiceGGatewayModelCommandsMixin._handle_fast_command.._on_fast_choices--k5.-Y Yszgateway.fast.picker_title)moderrzgateway.fast.choice_rzrzgateway.fast.status)r r rr)rr)agent.fast_modernror_rWrprNrr2rr:r;rrBr_resolve_session_service_tierre_resolve_session_agent_runtimerbr&rr%agent.codex_service_tiersrqrjr)rcr<rnrorWrpr rBrrrrqrrzrsrxrMr\rCrAsf& @@r_handle_fast_command.GatewayModelCommandsMixin._handle_fast_commandsa HL $AA%BXBXBZB`B`BbBhBhBjkn(()O)OQVQ]Q]^^226: !??K?X*,  E#*#4#433FP[it$vvNE $E3312 2##D/?%ekk*6MX_XcXcdnXo3:;;y3IK ; y;5I I DH$--k4-X X !3!34!671EaCbcgghls Z Z!88  /f=dPYn_accA!Wa*>qc(B&C\SW[\S\]c /9    &V44O_ v E3K@"7 E.  stA=I.I3I.7'I I I %A9I.I.4B I.> I' I.*I,+ I.7I. I I$ I.#I$$ I.)rr/rer,r)F)"rorprqrrrsrrrrrrrr!rrIrer|rrrrrrrrrr3r!r4rr]rjrrwrrrrrs_@2Xt8 &*8 t eJO e   2,-_^$*- ^! FB 5`rObdO@DO(DB#LP#J M H,&:T . %@N$E^N;,1515rr)priorityr zgateway.fast.label_fast)Nr zgateway.fast.label_normal)rrN)rrN)rrNr)rs __future__rr:rruloggingtypingrr agent.i18nrrrrarutilsr getLoggerrrcr&r+r3r> dataclassr@rrrrrrrs# 01'   = ) ; 9 ; 8 " "1j%dD$ueT J 5Q5Q5Qr$l 5l 5r