sj5tdZddlZddlZddlZddlmZmZddlmZm Z m Z m Z ddl m Z ejeZde de efdZde efd ZeGd d ZGd d ZeZdS)a Platform Adapter Registry Allows platform adapters (built-in and plugin) to self-register so the gateway can discover and instantiate them without hardcoded if/elif chains. Built-in adapters continue to use the existing if/elif in _create_adapter() for now. Plugin adapters register here via PluginContext.register_platform() and are looked up first -- if nothing is found the gateway falls through to the legacy code path. Usage (plugin side): from gateway.platform_registry import platform_registry, PlatformEntry platform_registry.register(PlatformEntry( name="irc", label="IRC", adapter_factory=lambda cfg: IRCAdapter(cfg), check_fn=check_requirements, validate_config=lambda cfg: bool(cfg.extra.get("server")), required_env=["IRC_SERVER"], install_hint="pip install irc", )) Usage (gateway side): adapter = platform_registry.create_adapter("irc", platform_config) N) dataclassfield)Any AwaitableCallableOptionalhermes_home_keycallbackreturncj ddlm}||S#ttf$rYdSwxYw)zBInfer a plugin profile from code registered outside PluginContext.r)registryN)tools.registryrplugin_scope_for_callable ImportErrorAttributeError)r tool_registrys =/home/agent/.hermes/hermes-agent/gateway/platform_registry.py_plugin_scope_from_callabler*sT<<<<<<66x@@@  (tts 22c tjdjddpd}n#t$rYdSwxYwt t ddd|iS)N__name___Caller __module__)sys _getframe f_globalsget Exceptionrtype) module_names r_caller_plugin_scoper$4sxmA&&044ZDDJ tt & Y\;788  s/2 AAc$eZdZUdZeed<eed<eegefed<egefed<dZ e eegefed<dZ e egefed<dZ e eegefed <e e Zeed <d Zeed <dZe egdfed<dZeed<d Zeed<d Zeed<d Zeed<dZeed<dZeed<dZeed<dZeed<d Zeed<dZe ege efed<dZe eeege efed<d Zeed<dZ e eege e!ee effed <dZ"e eegeezfed!<dZ#e eeeeegefed"<dZ$e ed#e%efed$<dS)% PlatformEntryz3Metadata and factory for a single platform adapter.namelabeladapter_factorycheck_fnNvalidate_configensure_deps_fn is_connected)default_factory required_envr install_hintsetup_fnpluginsource plugin_nameallowed_users_env allow_all_envrmax_message_lengthFpii_safeu🔌emojiTallow_update_command platform_hintenv_enablement_fnapply_yaml_config_fncron_deliver_env_varparse_target_ref_fnvalidate_target_ref_fnsend_message_handler.standalone_sender_fn)&rr __qualname____doc__str__annotations__rrboolr+rr,r-rlistr/r0r1r3r4r5r6r7intr8r9r:r;r<dictr=r>r?tupler@rArBrrrr&r&>s== III JJJ seSj))))r4x    8Return the concrete and deferred state for *name* without resolving it. This host-facing snapshot lets the plugin ledger restore a deferred platform loader that a concrete registration displaced, without importing the displaced adapter as a side effect of taking the snapshot. N)rSrhr rYr])r_r'rerlrmris rsnapshot_registrationz&PlatformRegistry.snapshot_registration@s Z - - $ 0 0 7 7 GX\\$''F{{4  (V^/33UDMBB{{4  (V^/33UDMBB;;t$$f, - - - - - - - - - - - - - - - - - -sB*B??CCcurrentpreviousc0|j5||d\}}||}||}||f} |||j| }|||j| }||f} | d|dup| d|du } | s ddddS|\} } | ||dn| ||<| ||dn| ||<| |jvr|j| |j| d|:|s|j |d|s|j |d ddddS#1swxYwYdS)atRestore a platform registration if its full state is still current. The identity checks protect a later registration from being removed while still allowing an unloaded override to reveal the registration it displaced. Both concrete entries and deferred loaders are part of the state because bundled platform plugins load lazily. TrcNrF) rSrhr rYr]rkrXr\addrUrW)r_r'rqrrrerlrmentryriload_key current_state is_currentprevious_entryprevious_loaders rrestore_registrationz%PlatformRegistry.restore_registrationVsCZ" "  $ 0 0t 0 D D GXKK%%E\\$''Ft}H}/33H==}/33H=="FOMa  26 #71:5J " " " " " " " " "/7 +NO% D$'''' . & T4((((!04>))(,,X666  " & &x 6 6 6 :(,,UD999;)--eT:::E" " " " " " " " " " " " " " " " " " sB-F B > GX&-JJN&&z22E!H}W!4!4!dD11}D4G4G**:66%}D4G4G++D$77%}!3!))+0x(39&x02;2E2G2G%h/ }-        0 )--h779;N;P;PPPP?                       B  JJLLL MM$ - - - F  FHHHH    NN;             (D,D D )1& J$($4$4Z$@$@!%>G++H,,7=D*84""8T222&**8T:::%))(D999(00:::                   (D,D D )1& J$($4$4Z$@$@!%>G++H,,7=D*84""8T222&**8T:::%))(D999(00:::                   . MM$ - - - - - . .sDFA FF F> G K G;G61K6G;;KB:K  KKN1B:N% N1%N) )N1,N) -N1cZ|j5||f|jvcdddS#1swxYwYdS)z@Return whether ownership teardown cancelled an in-flight loader.N)rSr\)r_r'res ris_deferred_load_cancelledz+PlatformRegistry.is_deferred_load_cancelledsZ = =4=D$<< = = = = = = = = = = = = = = = = = =s $$c|}|j5||\}}t|}t|j}|jD]8\}}||kr||!|||9 dddn #1swxYwYt|D]}|||t|D]}|||dS)aFRun every pending deferred loader. Used by the iterate-all accessors (``all_entries``/``plugin_entries``), which are only called by paths that genuinely need every adapter: gateway startup, ``hermes setup``/``gateway status``, channel directory. CLI chat never iterates the full set. N) rbrSrhr[rVrXrusortedr)r_rrTscoped_deferred scoped_names global_namesinflight_scoper's r _resolve_allzPlatformRegistry._resolve_allsf--// Z + +(,(8(8(F(F %Ho//Lt~..L(, + +$!\11 $$T****#+ $$T***  +  + + + + + + + + + + + + + + +<(( . .D MM$ - - - -<(( . .D MM$ - - - - . .sA > GX)TW__@P@P T4(((!++dD11=A(,,\4@@@B)--lDAAA = = = = = = = = N  tT * * *=$$T400< = = = = = = = = = = = = = = = = = =sB4D  7D  DDc|}|j5||\}}||vo+||vp'||jvo||jvp||f|jvp d|f|jv}dddn #1swxYwY|r||||j5||\}}||p|j|cdddS#1swxYwYdS)z!Look up a platform entry by name.N)rbrSrhrTrVrXrr )r_r'rerlrm needs_resolverVs rr zPlatformRegistry.get)s&&(( Z   $ 0 0 7 7 GX / 2 -H$$.2H24=DN22$<4>1                  ' MM$ & & & Z @ @!%!1!1%!8!8 GY;;t$$? (9(9$(?(? @ @ @ @ @ @ @ @ @ @ @ @ @ @ @ @ @ @s%A A11A58A5AC//C36C3cV||j5t|j}||j|it| cdddS#1swxYwYdS)z'Return all registered platform entries.N) rrSrJrTupdaterUr rbrHvalues)r_rls r all_entrieszPlatformRegistry.all_entries:s  Z * *4=))G NN4/33D4J4J4L4LbQQ R R R(()) * * * * * * * * * * * * * * * * * *sA5BB"%B"cf|d|DS)z/Return only plugin-registered platform entries.c(g|]}|jdk |S)r2)r3).0rs r z3PlatformRegistry.plugin_entries..Es$FFFaX1E1E1E1E1ErL)rrr^s rplugin_entrieszPlatformRegistry.plugin_entriesBs4 FF4++--FFFFrLcX|j5|}||\}}||z|jz|jz cdddS#1swxYwYdS)axReturn concrete and deferred platform names without loading adapters. Mirrors ``is_registered()``'s scope semantics: names registered under the current profile scope AND process-global names both count. Plugin platforms register deferred loaders under a profile scope, so reading only the global maps would miss every plugin platform. N)rSrbrhkeysrTrV)r_rerlrms rregistered_namesz!PlatformRegistry.registered_namesGsZ  **,,E $ 0 0 7 7 GX --//"-$$&&'.%%''(                   sB BB#&B#c|j5|}||\}}||vp+||vp'||jvp||jvp||f|jvp d|f|jv cdddS#1swxYwYdSrP)rSrbrhrTrVrX)r_r'rerlrms r is_registeredzPlatformRegistry.is_registeredYs Z  **,,E $ 0 0 7 7 GX28#24=(24>)24=DN2 2 $<4>1                    sAA22A69A6configc||}|dSd} t|}n8#t$r+}td|j|Yd}~nd}~wwxYw|s|j}td|j t|}n:#t$r-}td|j|d}Yd}~nd}~wwxYw|s7|j r d|j dnd}td |j|dS|j r | |s"td |jdSn9#t$r,}td |j|Yd}~dSd}~wwxYw | |}|S#t$r.}t d |j|d Yd}~dSd}~wwxYw)ahCreate an adapter instance for the given platform name. Returns None if: - No entry registered for *name* - check_fn() returns False and deps can't be installed (no ensure_deps_fn, or ensure_deps_fn() returned False) - validate_config() returns False (misconfigured) - The factory raises an exception NFz!Platform '%s' check_fn raised: %su<Platform '%s' dependencies missing — attempting install...z+Platform '%s' dependency install raised: %sz ()rz$Platform '%s' requirements not met%sz&Platform '%s' config validation failedz)Platform '%s' config validation error: %sz.Failed to create adapter for platform '%s': %sTr~) r rGr*r!rrr(r,rr0r+r)error)r_r'rrvdeps_okrhintadapters rcreate_adapterzPlatformRegistry.create_adapterjs =4 5>>++,,GG    NN3U[!          5/; KKN     u335566   AK     161CK-*----D NN6     4  , ,,V44 NN@  4     ?K ttttt   ++F33GN    LL@      44444 s]!? A4 !A//A4!!C C: #C55C:>5E66 F,!F''F,0G G?#G::G?)r NrP) rrrCrDr` staticmethodrErbrrGrKrJr&rrhrnrpr|rrrrrr rHrrr[rrrrrrLrrNrNs B!s!!!\!    }   tC&'c8BH3E.E)FF G     2 $ $$$$T"$ } $  $$$$8 $ ----} - x &"d(1C(DD E ----8 $ 1111x ."d(9K0LLM1/(2t8:L1MMN 1 } 1 1111fI.I.SI.#I.$I.I.I.I.^ $ ====} =  ====....: $ [[[[} [  [[[[B?C===s=hsm=t===="@@ 7@@@@"*T-0****G] 3GGGG #c($#$"L3LL LLLLLLrLrN)rDloggingrrQ dataclassesrrtypingrrrrhermes_constantsr getLoggerrrrErr$r&rNplatform_registryrrLrrsa< ((((((((555555555555,,,,,,  8 $ $(x}hsm fJfJfJfJfJfJfJ fJRNNNNNNNNd%$&&rL