idZddlZddlmZmZddlmZmZmZej e Z eGddZ GddZ e ZdS) 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)AnyCallableOptionalceZdZUdZeed<eed<eegefed<egefed<dZ e eegefed<dZ e eegefed<e e Ze ed <d Zeed <dZe egdfed <dZeed<d Zeed<d Zeed<d Zeed<dZeed<dZeed<dZeed<dZeed<d Zeed<dS) PlatformEntryz3Metadata and factory for a single platform adapter.namelabeladapter_factorycheck_fnNvalidate_config is_connected)default_factory required_env install_hintsetup_fnpluginsource plugin_nameallowed_users_env allow_all_envrmax_message_lengthFpii_safeu🔌emojiTallow_update_command platform_hint)__name__ __module__ __qualname____doc__str__annotations__rrboolrrrrlistrrrrrrrrintrrrr>/home/ubuntu/.hermes/hermes-agent/gateway/platform_registry.pyr r &s== III JJJ seSj))))r4x    8|j|j}td|j|j|j||j|j<td|j|jdS)zRegister a platform adapter entry. If an entry with the same name exists, it is replaced (last writer wins -- this lets plugins override built-in adapters if desired). z,Platform '%s' re-registered (was %s, now %s)z$Registered platform adapter: %s (%s)N)r r1loggerinfordebug)r3r5prevs r*registerzPlatformRegistry.register|sz : & &=,D KK>       %* ej! ;UZVVVVVr)r c<|j|dduS)z5Remove a platform entry. Returns True if it existed.N)r1popr3r s r* unregisterzPlatformRegistry.unregisters}  t,,D88r)c6|j|S)z!Look up a platform entry by name.)r1getr>s r*rAzPlatformRegistry.gets}  &&&r)cNt|jS)z'Return all registered platform entries.)r&r1valuesr2s r* all_entrieszPlatformRegistry.all_entriessDM((**+++r)cHd|jDS)z/Return only plugin-registered platform entries.c(g|]}|jdk |S)r)r).0es r* z3PlatformRegistry.plugin_entries..s$JJJaQX5I5I5I5I5Ir))r1rCr2s r*plugin_entrieszPlatformRegistry.plugin_entriess$JJ4=//11JJJJr)c||jvSr/r0r>s r* is_registeredzPlatformRegistry.is_registeredst}$$r)configcl|j|}|dS|s7|jr d|jdnd}td|j|dS|jr ||s"td|jdSn9#t$r,}td|j|Yd}~dSd}~wwxYw | |}|S#t$r.}t d|j|d Yd}~dSd}~wwxYw) aCreate an adapter instance for the given platform name. Returns None if: - No entry registered for *name* - check_fn() returns False (missing deps) - validate_config() returns False (misconfigured) - The factory raises an exception Nz ()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': %sT)exc_info) r1rAr rr7warningr r Exceptionr error)r3r rMr5hintrHadapters r*create_adapterzPlatformRegistry.create_adapters !!$'' =4~~ 161CK-*----D NN6     4  , ,,V44 NN@  4     ?K ttttt   ++F33GN    LL@      44444 s025B** C 4!CC $C;; D3#D..D3)r-N)rr r!r"r4r r;r#r%r?rrAr&rDrJrLrrVr(r)r*r,r,rs7 5555WmWWWWW"9s9t9999'' 7'''',T-0,,,,K] 3KKKK%#%$%%%%0300 000000r)r,)r"logging dataclassesrrtypingrrr getLoggerrr7r r,platform_registryr(r)r*r\s<((((((((**********  8 $ $ HHHHHHH HV^^^^^^^^D%$&&r)