`gjU4dZddlmZddlZddlZddlZddlZddlZddlm Z ddl m Z m Z m Z ejeZe ej$ZdZddZddZdd Zdd Zdd Zdd Zdd ZddZGddZy)uCron scheduler provider plugin discovery. Scans two directories for cron scheduler provider plugins: 1. Bundled providers: ``plugins/cron_providers//`` (shipped with hermes-agent) 2. User-installed providers: ``$HERMES_HOME/plugins//`` Each subdirectory must contain ``__init__.py`` with a class implementing the ``CronScheduler`` ABC (``cron/scheduler_provider.py``). On name collisions, bundled providers take precedence. This is a near-verbatim clone of ``plugins/memory/__init__.py`` — the same discovery/loader machinery, retargeted at ``CronScheduler``. The built-in ``InProcessCronScheduler`` is NOT discovered here: it is core (lives in ``cron/scheduler_provider.py``) so the fallback can never be accidentally removed. Only NON-default providers (e.g. "chronos") live under this directory. Only ONE provider can be active at a time, selected via ``cron.provider`` in config.yaml (empty = built-in). See ``cron.scheduler_provider.resolve_cron_scheduler``. Usage: from plugins.cron_providers import discover_cron_schedulers, load_cron_scheduler available = discover_cron_schedulers() # [(name, desc, available), ...] provider = load_cron_scheduler("chronos") # CronScheduler instance ) annotationsN)Path)ListOptionalTuple_hermes_user_cronc|tjvrytjj |dd}||_tj j|tj|<y)uRegister an empty package shell in sys.modules. User-installed providers import as ``_hermes_user_cron.``, a dotted name whose parents exist nowhere on disk. Unless those parents are present in ``sys.modules``, any relative import inside the plugin (``from . import config``) fails with ``ModuleNotFoundError: No module named '_hermes_user_cron'`` — the same reason the loader already registers ``plugins`` and ``plugins.cron_providers`` for bundled providers. NT) is_package)sysmodules importlib machinery ModuleSpecsubmodule_search_locationsutilmodule_from_spec)namesearch_locationsspecs R/root/.hermes/venv/lib/python3.12/site-packages/plugins/cron_providers/__init__.py_register_synthetic_packager/sU s{{    ) )$ ) FD&6D#!77=CKKcj ddlm}|dz }|jr|SdS#t$rYywxYw)z8Return ``$HERMES_HOME/plugins/`` or None if unavailable.r)get_hermes_homepluginsN)hermes_constantsris_dir Exception)rds r_get_user_plugins_dirr Es<4   )HHJq(D( s!&& 22c|dz }|jsy |jddd}d|vxsd|vS#t$rYywxYw) uHeuristic: does *path* look like a cron scheduler provider plugin? Checks for ``register_cron_scheduler`` or ``CronScheduler`` in the ``__init__.py`` source. Cheap text scan — no import needed. __init__.pyFreplace)errorsNi register_cron_scheduler CronScheduler)exists read_textr)path init_filesources r_is_cron_provider_dirr,Osc }$I    $$I$6u=(F2Oo6OO s7 AAct}g}tjrttj D]z}|jr|j j dr/|dz jsC|j|j |j|j |f|t}|rt|j D]f}|jr|j j dr/|j |vr>t|sJ|j|j |fh|S)zYield ``(name, path)`` for all discovered provider directories. Scans bundled first, then user-installed. Bundled takes precedence on name collisions (first-seen wins via ``seen`` set). )_.r") set_CRON_PLUGINS_DIRrsortediterdirr startswithr'addappendr r,)seendirschilduser_dirs r_iter_provider_dirsr;_s D#%D!-5578 -E<<>UZZ%:%::%FM)113 HHUZZ KKU+ ,  -%&HH,,./ -E<<>UZZ%:%::%FzzT!(/ KKU+ , - Krct|z }|jr|dz jr|St}|r"||z }|jr t |r|Sy)z^Resolve a provider name to its directory. Checks bundled first, then user-installed. r"N)r1rr'r r,)rbundledr:users rfind_provider_dirr?sZ  $&G~~W}4<<>$&H$ ;;=248K rcg}tD]\}}d}|dz }|jrB ddl}t|d5}|j |xsi}dddj dd}d} t|} | r| j}nd }|j|||f|S#1swYVxYw#t $rYRwxYw#t $rd }Y@wxYw) uKScan bundled and user-installed directories for available providers. Returns list of (name, description, is_available) tuples. May be empty — the built-in is core, not discovered here, so a fresh checkout with no bundled non-default provider returns []. Bundled providers take precedence on name collisions. z plugin.yamlrNz utf-8-sig)encoding descriptionTF) r;r'yamlopen safe_loadgetr_load_provider_from_dir is_availabler6) resultsrr9desc yaml_filerDfmeta availableproviders rdiscover_cron_schedulersrQsG*,0 eM)     )k:3a>>!,2D3xx r2   .u5H$113 !  dI./104 N'33   I s:B3B'B3/ C'B0 ,B33 B?>B? CCct|}|stjd|y t|}|r|Stj d|y#t $r!}tj d||Yd}~yd}~wwxYw)a-Load and return a CronScheduler instance by name. Checks both bundled (``plugins/cron_providers//``) and user-installed (``$HERMES_HOME/plugins//``) directories. Bundled takes precedence on name collisions. Returns None if the provider is not found or fails to load. z7Cron provider '%s' not found in bundled or user pluginsNz8Cron provider '%s' loaded but no provider instance foundz%Failed to load cron provider '%s': %s)r?loggerdebugrHwarningr)r provider_dirrPes rload_cron_schedulerrXsr%T*L  NPTU*<8 OQSWX >aHsA A A6A11A6c* |j}t|jvxs|jtk(}|rd|n td|}|dz }|j syt jj|}|t|ddr|}ndD]}|t jvsttj}|dk(r |j}|dz } | j sVtjj|t| t|g} | stjj!| } | t j|< | j"j%| |st)tgtjj|t|t|g} | sytjj!| }|t j|<g} |j+d D]} | jdk(r| j,}|d|}|t jvs9tjj|t| }|setjj!|}|t j|< |j"j%|| j/||f | j"j%||j7dd \}}t jj|} | t9| ||| D]\}}t9|||t;|d r5t=} |j?||j@r |j@S ddl!m"}tG|D];}t||d}tI|tJs!tM||s.||us3 |cSy#t&$rYHwxYw#t&$r"}t0j3d ||Yd}~d}~wwxYw#t&$rA}t0j3d ||t jj5|dYd}~yd}~wwxYw#t&$r"}t0j3d||Yd}~d}~wwxYw#t&$rYwxYw)uImport a provider module and extract the CronScheduler instance. The module must have either: - A register(ctx) function (plugin-style) — we simulate a ctx - A top-level class that extends CronScheduler — we instantiate it zplugins.cron_providers.r/r"N__file__)rzplugins.cron_providersr)rz*.pyzFailed to load submodule %s: %szFailed to exec_module %s: %sregisterzregister() failed for %s: %sr)r&)'rr1parentsparent_USER_NAMESPACEr'r r rGgetattrrrZr rspec_from_file_locationstrrloader exec_modulerrglobstemr6rSrTpoprsplitsetattrhasattr_ProviderCollectorr\rPcron.scheduler_providerr&dir isinstancetype issubclass)rVr _is_bundled module_namer*cachedmodr^ parent_path parent_initr parent_modloaded_submodulessub_filesub_name full_sub_namesub_specsub_modrW parent_name child_name collectorr& attr_nameattrs rrHrHs;   D$|';';;g|?R?RVg?gK6A+D62/IZZ[\`[aGbK},I    [[__[ )F gfj$?< !FS[[("8n33 Y&"-"4"4K)M9 %%'$>>AAK 047 4D3EBD%.^^%D%DT%J .8 F+! KK33J? !* ' <~~55 Y(+L(9':6 nn--d3#& K %))&1 ZH}} -}}H*m1XJ7MCKK/$>>AA!3x='nn==hGG18CKK .Z 33G<)00(G1DE Z$  KK # #C (#."4"4S!"< Z[[__[1  ! J C 0!2 , Hg C7 + ,sJ&(  B LL #!! )))" 6X sIt, tT "z$ 'F - v  ] )! !J%Z %F WXYYZ   LL7a H KKOOK . , B LL7q A A B  slO .OP (QR OO P%PP Q7QQ R Q==R RRc4eZdZdZdZdZdZdZdZdZ y) rkz@Fake plugin context that captures register_cron_scheduler calls.cd|_yNrP)selfs r__init__z_ProviderCollector.__init__Ss  rc||_yrr)rrPs rr%z*_ProviderCollector.register_cron_schedulerVs   rcyrrargskwargss r register_toolz _ProviderCollector.register_toolZ rcyrrrs r register_hookz _ProviderCollector.register_hook]rrcyrrrs rregister_memory_providerz+_ProviderCollector.register_memory_provider`rrcyrrrs rregister_cli_commandz'_ProviderCollector.register_cli_commandcrrN) __name__ __module__ __qualname____doc__rr%rrrrrrrrkrkPs#J!    rrk)rrbrz List[str]returnNone)rOptional[Path])r)rrbool)rzList[Tuple[str, Path]])rrbrr)rzList[Tuple[str, str, bool]])rrbrOptional['CronScheduler'])rVrrr)r __future__rr importlib.machineryimportlib.utilloggingr pathlibrtypingrrr getLoggerrrSrZr^r1r_rr r,r;r?rQrXrHrkrrrrs6# ((   8 $N))&>,  D,$N2vr  r