+ jHj YRt^RIHt^RIt^RIt^RIt^RIt^RIt^RI H t ^RI H t H t Ht^RIHt^RIHtHt^RIHt]P,!R4t!R R 4tR#) uPlugin-triggered gateway turns (``PluginContext.inject_message``): the process-wide injector this runner publishes, the thread-safe scheduler, and the dispatch through the adapter message path. Two targets: an existing session (``session_key``; route and session id pinned from the store) or a messaging chat (``origin``) whose session is created — or continued — through the normal session path in the calling plugin's OWN profile. The origin path never chooses a profile: the gateway's routing for that chat through that profile's adapter must already land in the plugin's profile, so a human follow-up in the same chat keys into the same session.) annotationsN)Path)AnyMappingOptional)Platform) MessageEvent MessageType) SessionSourcez gateway.runc ]tRt^tRRltRRltRRRRRRR R R R /R RlltRRltR*RRlltRRlt RRlt RRlt RRlt RR/RRllt RRltRR ltR!R"ltR#R$ltR%R&ltR'R(ltR)tR#)+GatewayPluginInjectionMixincV^8dQhRR/#returnNone)formats"A/home/ubuntu/.hermes/hermes-agent/gateway/run_plugin_injection.py __annotate__(GatewayPluginInjectionMixin.__annotate__sTT$Tc 6^RIHpV!WP4R#)zBPublish this live gateway's plugin message scheduler process-wide.)publish_gateway_message_hostN)hermes_cli.pluginsr"_schedule_plugin_message_injection)selfrs& r _install_plugin_message_injector.__annotate__bs g gd grc"<VP4'dR#\ PRSS4R# \P\PP3dR#\ d\ PRSSRR7R#i;i)Nz-Plugin message injection failed: plugin=%s %sTr;z5Plugin message injection was not routed: plugin=%s %s)resultasyncioCancelledError concurrentfutures Exceptionr=warning) completedr-targets&r _log_resultSGatewayPluginInjectionMixin._schedule_plugin_message_injection.._log_resultbs ##%%& NNRT]_e f **J,>,>,M,MN  NPY[alpq s5/B'B0B B) gateway.runr2getattr is_closedgatewayr5resolverouteadmit_plugin_origin_source_plugin_origin_admissibleplatformvaluechat_id!_dispatch_plugin_origin_injection_plugin_session_key_admissible"_dispatch_plugin_message_injectionrDget_running_loop RuntimeError create_taskrHcloser=rI_background_tasksaddadd_done_callbackdiscardloggingWARNING)rr+r-r$r%r&r'r(r2loopr5resolvedcoror: current_loopfuturerLrKs&$d$$$$$ @rr>GatewayPluginInjectionMixin._schedule_plugin_message_injection'sC 9t_d3tZ//4<4>>CSCS  5,44T^gI\5^H 1 12/BF(..tehee[deD  //[d/eF~T%C%CFNW&D&Y&Yv445Qv~~6FGF99dm9nD66{gp6qq }-F::'I[f;D "335L   ))$/  " " & &v .  $ $T%;%;%C%C D-67c!//F~ g g   -A L   KVZ[ s$G0H0 H?H2H98H9cV^8dQhRR/#)rrr0r)rs"rrrpsZZTZrc P\VRR4;'d\VRR4'*#)r4F _draining)rO)rs&r_plugin_injection_accepting7GatewayPluginInjectionMixin._plugin_injection_acceptingps&tZ/YYkSX8Y4YYrc V^8dQhRRRR/#)rr:r homer/r)rs"rrrssccmc>crc \\VRR4RR4RJd\P!4#^RIHpT!T;'gVP V44#)uaMultiplex: enter the source's profile runtime scope (or *home*'s, when the owner is known) around ``handle_message`` so the background task it spawns — the turn AND the reply send after the handler returns — inherits that profile's home and secrets (this coroutine runs from the default loop context, not from the profile adapter's own intake task).configNmultiplex_profilesFT)_async_profile_runtime_scope)rO contextlib nullcontextrNrw _resolve_profile_home_for_source)rr:rsrws&&& r_plugin_injection_scope3GatewayPluginInjectionMixin._plugin_injection_scopessQ 74402F NVZ Z))+ +<+D,a,aD4Y4YZ`4abbrc(V^8dQhRRRRRRRR/#)rr:r r-r,rKrr0r)rs"rrr}s+  = PS ]` ei rc VPVRR7pT'g\PRY#4T# \d\PRY#RR7R#i;i)aCurrent gateway authorization for the route the injected turn will run as. Host-side plugin code is trusted to ask, never to widen access: a stored or supplied route must pass today's allowlists / pairing / allow-all, and adapter-time grants (Discord roles) do not count.F)allow_adapter_delegationzAPlugin message injection authorization check failed: plugin=%s %sTr;zNPlugin message injection denied by current gateway authorization: plugin=%s %s)_is_user_authorized_for_sourcerHr=rI)rr:r-rK authorizeds&&$$ r_plugin_injection_authorized8GatewayPluginInjectionMixin._plugin_injection_authorized}sg <:...``) under multiplexing, and to the one served profile of a standalone gateway; it must be the plugin's own, as on the origin path. A caller with no plugin home is left to dispatch, as before.NTrurvF)profile_from_session_keyziPlugin message injection refused: plugin=%s session=%s belongs to profile %s, not the plugin's profile %s)_served_profile_for_homerOhermes_state_keysrr=rI)rr$r&r-profileownerrs&&$$ rr;GatewayPluginInjectionMixin._plugin_messaging_session_ownedsy  // <  7744+HJ^`e#fjn#n B,[9E  5#3-.7e Vrc(V^8dQhRRRRRRRR/#)rr:r r$r,r&r/r-r)rs"rrrs*M]k),rc ^RIHpVe V!W4MRpVe&VPPVP4MRpVeVP V8XdV#\ PRWBV4R#)aA local session's own source passes no chat allowlist, so the plugin's profile boundary is the only check: the session authority registered for the plugin's immutable home must hold the live session under this key. Its ``LiveSession``, or ``None`` (logged). Never resolved through the source's profile, whose fallback is the ambient scope (a default-profile local source carries none, so under beta's scope it would read as beta's).authority_for_homeNzrPlugin message injection refused: plugin=%s session=%s is not a live local session of the plugin's profile home %s)gateway.session_authoritiesrsessionsgetrYrSr=rI)rr:r$r&r-r authoritylives&&&$$ rr1GatewayPluginInjectionMixin._plugin_local_sessionsm C=H=T&t9Z^ 9B9Ny!!%%fnn5TX   k 9K23<; Xrc ,V^8dQhRRRRRRRRRR/#) rr$r,r+r-r&r/rr0r)rs"rrrs4++!+,/+GatewayPluginInjectionMixin._dispatch_plugin_message_injections//11..DD[QQ =ELL08X8X8Z8Z; 5 5e <= ??hnn ,>>vV]KV?XX X33Kdm3nn00W_`k_lUm0nn,,V4 ?//777!99[EUEU:66H# 877 ((;+;+;FUY&+& 3Ld);8LeN^N^,d*   87  U E$4$4 KRX868   8777s7HG-+H&AH;G0B: B>% C2B<3C:B><C>C C C C  Cc V^8dQhRRRR/#)rrsr/rr.r)rs"rrrs[[^[ [rc aaVfR#^RIHpHoS!V4o\\VRR4RR4'd1^RIHpV!VP 4p\TT3R lT4R4#S!V!44S8wdR#\VR R4;'gVP4# \d\PRRR 7R#i;i) zName of the profile this gateway serves at *home* (a plugin manager's immutable home), or ``None`` when this gateway does not serve it.N)get_routing_process_hermes_homehermes_home_keyrurvF)_multiplex_profile_homesz8Plugin message injection: served-profile set unavailableTr;c3J<"TFwrS!V4S8XgKVxK R#5iNr).0name served_homerkeys& r GGatewayPluginInjectionMixin._served_profile_for_home..s$ev"3$Q\A]adAdvs# #_primary_profile_name) hermes_constantsrrrOrNrrurHr=rInext_active_profile_name)rrsrrservedrrs&& @@rr4GatewayPluginInjectionMixin._served_profile_for_homes <Ud# 74402F N N < 1$++>evegkl l :< = Dt4d;ZZt?X?X?ZZ  Ydhi sB "CCc(V^8dQhRRRRRRRR/#) rr%zMapping[str, Any]r&r/r-r,rzOptional[SessionSource]r)rs"rrr s,$$'$9G$TW$ $rc aRV3RllpVPV4pVf V!RV4#\V4pVPRR4pV'dWu8wd V!RWu4#\P!V4pTPP RTP 2p TPT4PTP4p T fT!R TPPT4#\P!T 4TnTP!T4p T f T!R T 4#T P"T8wdT!R YP"T4#T# \ \ \3dp T!RT 4uRp ? #Rp ? ii;i) aAThe canonicalized source for a plugin-supplied *origin*, or ``None`` (logged) when the plugin may not start a turn there: its profile is not served, the origin is malformed or names another profile, that profile has no live adapter for the platform, or the gateway's own routing for the chat lands in a different profile.c$V^8dQhRRRRRR/#)rreasonr,argsrrrr)rs"rrGGatewayPluginInjectionMixin._plugin_origin_source..__annotate__s& f fC f f frcH<\P!RV,S.VO5!R#)z,Plugin message injection refused: plugin=%s N)r=rI)rrr-s&*r_refuseBGatewayPluginInjectionMixin._plugin_origin_source.._refuses NNIFRT] e`d erNz1its profile home %s is not served by this gatewayrzRorigin names profile %r; plugins may only start sessions in their own profile (%s)zinvalid origin (%s)r9z&no connected %s adapter for profile %sz.origin %s does not resolve to a served profilez;origin %s routes to profile %s, not the plugin's profile %s)rdictpopr from_dictKeyError TypeError ValueErrorrWrXrY_adapters_for_profilerweakrefref_transport_adapter_ref _canonicalizeruntime_profile) rr%r&r-rrfields requestedr:excwhereridentitys &&$d rrU1GatewayPluginInjectionMixin._plugin_origin_source sm f f// < ?NP[\ \fJJy$/ -o$/ / 7",,V4F??(()6>>*:;,,W599&//J ?CV__EZEZ\cd d)0 G(<%%%f-  KUS S  # #w .X ":":GE E !)Z0 70#6 6 7sEE.E)#E.)E.c(V^8dQhRRRRRRRR/#) rr:r r&r/r-r,rr0r)rs"rrr0s* ~jmrvrc $^RIHp^RIHpVe V!W4MRpVfR#VPP VP V44pVe V!Wg4eR#\PRW1PPVP4R#)aKUnder the session authority a plugin turn borrows the connector provenance of a human message already committed in that chat, and the gateway never mints it for a chat the platform did not deliver: refuse such an origin here, so the plugin gets ``False`` instead of a ``True`` for a turn the dispatch then drops. Dispatch rechecks.r)committed_route_envelopeNTzPlugin message injection refused: plugin=%s origin=%s/%s has no human message admitted yet; a plugin can continue a chat, not open oneF) rrgateway.session_automationrrr_session_key_for_sourcer=rIrWrXrY)rr:r&r-rrrrs&&$$ rrV5GatewayPluginInjectionMixin._plugin_origin_admissible0s CG=H=T&t9Z^  ""889U9UV\9]^  !9)!K!WIJSUdUdUjUj~~ 'rc(V^8dQhRRRRRRRR/#)rr:r r+r,r-rr0r)rs"rrrBs,''&'14'AD' 'rc "RVPP RVP 2pVP4'gR#VP V4pVf\ P RV4R#VPWVR7'gR#VPV4pVPV4;_uu_4GRjxL ^RI H pV!V4eVPPV4GRjxL pVf*\ P RW44RRR4GRjxL R#VPWQWhPW#R 7GRjxL uuRRR4GRjxL #VP!\#V\$P&VR RR VR R R V/R74GRjxL RRR4GRjxL \ P)RW4V4R #ELLLLLsL8L* +GRjxL 'giLA;i5i)zStart (or continue) the session at a plugin-supplied origin through the adapter's normal message path: ``get_or_create_session`` creates it, the reply goes back to that chat.r8r9FNzBPlugin message injection: adapter for %s went away before dispatchractive_authorityz]Plugin message injection refused: plugin=%s %s has no session under the session authority yetrTrrrrz>2BC//11,,V4 ? NN_ag h00U[0\\226: //777 D%1#66LL[YY=NN$?@IS 877"99IYIY#:::877((;+;+;FUY&+' 3Ld); *  87.  RT]grs18 Z 8:8 8777sB5G$7F98G$;/G*F<+G G$F>G$!G=G>G G$GG$7G G G G$GG$<G>G$GG$GG$G! G G! G! G$c 0V^8dQhRRRRRRRRRRRR /#) rr:r r$r,rr+r-rzOptional[bool]r)rs"rrrks>,>AOR]` rc "^RIHpV!V4pVfR#^RIp ^RIp ^RIHp V P RWcV P4P.R R7p \V\PVRRV RVR V/R 7p VPWV 4GRjxL \P!R YcT4R#L T d-p\PR YcTP4Rp?R#Rp?ii;i5i)acUnder a session authority, commit the plugin turn into the session's durable FIFO as a trusted producer admission (the heartbeat / completion seam) instead of running it on the in-process lane beside an admitted turn. ``None`` means no authority serves this scope and the caller keeps the standalone adapter path; a refused admission is ``False``, logged.rN)RuntimeStoreErrorplugin) separatorsTFrr)rrr:rr message_idrzTPlugin message injection refused by the session authority: plugin=%s session=%s (%s)zEPlugin message injection admitted: plugin=%s session=%s session_id=%s),:)rrjsonuuidhermes_state_runtimerdumpsuuid4hexrr radmit_automationr=rIrr)rrr:r$rr+r-rrrrrreventrs&&&$$$$ rr3GatewayPluginInjectionMixin._admit_plugin_injectionks A$T*  :::xAQAQR_i:j{'7'7QU"'H+[:NPZ[   ,,WXF F F  [J 8 G   NNq$3:: ? sBA5C#8B- B+B-C#+B--C 4!CC#C  C#rr)__name__ __module__ __qualname____firstlineno__rr"rrpr{rr[rrr\rrrUrVrZr__static_attributes__rrrr r sT 3 GLPG.2GRVGG;=GRZc  o$ +_c+Z T[&$L$'Rrr )__doc__ __future__rrDconcurrent.futuresrFrxrerpathlibrtypingrrrgateway.configrgateway.platforms.eventrr gateway.sessionr getLoggerr=r rrrrsL:#))#=)   = )nnr