i4;dZddlmZddlZddlZddlmZmZddlmZdd Z dd Z dd Z ddZ ddZ ddZddZddZddZddZddZdddZedkrejedSdS)u0CLI subcommand: `hermes curator `. Thin shell around agent/curator.py and tools/skill_usage.py. Renders a status table, triggers a run, pauses/resumes, and pins/unpins skills. This module intentionally has no side effects at import time — main.py wires the argparse subparsers on demand. ) annotationsN)datetimetimezone)Optionalts Optional[str]returnstrc|sdS tj|}n&#ttf$rt |cYSwxYw|j |tj}tj tj|z }t| }|dkr|dS|dkr|dzdS|dkr|dzdS|dzd S) Nnever)tzinfo<zs agoizm agoiQzh agozd ago) r fromisoformat TypeError ValueErrorr r replacerutcnowint total_seconds)rdtdeltasecss 7/home/ubuntu/.hermes/hermes-agent/hermes_cli/curator.py_fmt_tsrs w  #B ' ' z "2ww y ZZx|Z , , L & & +E u""$$ % %D byy~~~ d{{"*#### e||$,%%%%em " " ""s  >>rc, ddlm}ddlm}|}|}|dd}|d}|dpd}|d d}|r|sd n|rd nd } td | td|tdt|td||d} | rtd| | } | dzdkr| dkr| dzdn| d} td| td| dtd| d| } | stddSgggd}g}| D]q}|dd}| |g||dr||drtd t| d!dD];}||g}td"|d#d$t|<|r5td%t|d&d'|t#|dgd()dd*}|rtd+|D]}t|d,}td"|dd-d.|d/dd0d1|d2dd0d3|d4dd0d5|d6dd0d7| |dg}|rt#|d8d9:dd*}|r|dd/pddkrtd;|D]}t|d,}td"|dd-d.|d/dd0d1|d2dd0d3|d4dd0d5|d6dd0d7| t#|d<)dd*}|rtd=|D]}t|d,}td"|dd-d.|d/dd0d1|d2dd0d3|d4dd0d5|d6dd0d7| dS)>Nrcurator skill_usagepausedF last_run_atlast_run_summaryz(none) run_countENABLEDPAUSEDDISABLED curator: z runs: z last run: z last summary: last_report_pathz last report: dhz interval: every z stale after: zd unusedz archive after: z no agent-created skills)activestalearchivedstater-pinnednamez agent-created skills: z totalz 10s z pinned (z): z, cZ|dp|dpdS)Nlast_activity_at created_atgetrs rz_cmd_status..`s)aee.//L1553F3FL")keyz least recently active (top 5):r640sz activity=activity_count3dz use= use_countz view= view_countz patches= patch_countz last_activity=c^|dpd|dpdfSNrBrr6r8r9r;s rr=z_cmd_status..y0155!1227a?Q9R9R9XVXYr>T)r?reversez most active (top 5):c^|dpd|dpdfSrHr9r;s rr=z_cmd_status..rIr>z least active (top 5):)agentrtoolsr load_state is_enabledr:printrget_interval_hoursget_stale_after_daysget_archive_after_daysagent_created_report setdefaultappendlenjoinsorted)argsrr r0enabledr!last_runsummaryruns status_line_report_ih_interval_labelrowsby_stater1r< state_namebucketr-last active_all most_active least_actives r _cmd_statusrk&s'!!!!!!    E  ""G YYx ' 'Fyy''Hii*++7xG 99[! $ $D V     #k # #$$$ %t % %&&& 2wx00 2 2333 (w ( ()))ii*++G. ,7,,---  $ $ & &C8q==SBYY3"9YYY 6_ 6 6777 Gw;;== G G GHHH Iw==?? I I IJJJ  + + - -D  )***qrr::H F %%UU7H-- J++221555 55?? % MM!F) $ $ $ 6SYY 6 6 6777533 j"-- 1:111CKK112222 @ >3v;;>>499V+<+<>>???  Xr"" L L qb F  0111  A155!34455D (QvY&((EE"2A66=((uu[!,,3((lA..5((55229 (( "& ((    h++J" YY    1"   KN../?@@EAJJ * + + +  quu%78899,6*,, !&6 : :A,,55a007,,EE,229,, !uu]A66= ,, &* ,, YY    1"    + , , ,!  quu%78899,6*,, !&6 : :A,,55a007,,EE,229,, !uu]A66= ,, &* ,, 1r>c ddlm}|stddSt t |dd}|rtdntddd }||t |j|}|di}|r|r(td|dddnktd|ddd|ddd|ddd|dd|jstd|rtddS)NrrzAcurator: disabled via config; enable with `curator.enabled: true`dry_runFz7curator: running DRY-RUN (report only, no mutations)...zcurator: running review pass...msgr r Nonec$t|dSN)rP)ros r _on_summaryz_cmd_run.._on_summarys c r>) on_summary synchronousrnauto_transitionszauto (preview): checkedu9 candidate skill(s) — no transitions applied in dry-runzauto: checked=z stale= marked_stalez archived=r/z reactivated= reactivateduFllm pass running in background — check `hermes curator status` laterzdry-run: no changes applied. When the report lands, read it with `hermes curator status` and run `hermes curator run` (no flag) to apply.)ror r rp) rLrrOrPboolgetattrrun_curator_reviewrur:)rZrdryrsresultautos r_cmd_runrs      QRRRq wtY.. / /C 1 GHHHH /000 ' ')**(F ::(" - -D    8488Iq#9#9888     <)Q!7!7<<.!44<< HHZ33<< $xx q99<<     X VWWW    W    1r>cZddlm}|dtddS)NrrTzcurator: pausedrLr set_pausedrPrZrs r _cmd_pausers< t  1r>cZddlm}|dtddS)NrrFzcurator: resumedrrs r _cmd_resumers< u  1r>cddlm}||jst d|jddS||jdt d|jddS) Nrr curator: 'u`' is bundled or hub-installed — cannot pin (only agent-created skills participate in curation)rmTzcurator: pinned 'z ' (will bypass auto-transitions)rMr is_agent_createdskillrP set_pinnedrZr s r_cmd_pinrs!!!!!!  ' ' 3 3  B B B B   q4:t,,, Jdj J J JKKK 1r>cddlm}||jst d|jddS||jdt d|jddS) Nrrrue' is bundled or hub-installed — there's nothing to unpin (curator only tracks agent-created skills)rmFzcurator: unpinned ''rrs r _cmd_unpinrs!!!!!!  ' ' 3 3  R R R R   q4:u--- - - - -... 1r>cxddlm}||j\}}t d||rdndS)Nrrr(rm)rMr restore_skillrrP)rZr okros r _cmd_restorersR!!!!!!'' 33GB c  >11r>cddlm}|stddSt |ddpd}||}|td dStd |jdS) zuTake a manual snapshot of the skills tree. Same mechanism as the automatic pre-run snapshot, just user-initiated.rcurator_backupzacurator: backups are disabled via config (`curator.backup.enabled: false`); re-enable to snapshotrmreasonNmanual)ruEcurator: snapshot failed — check logs (backup disabled or IO error)z?curator: snapshot created at ~/.hermes/skills/.curator_backups/)rLrrOrPr{snapshot_skillsr2)rZrrsnaps r _cmd_backuprs%$$$$$  $ $ & &  G   q T8T * * 6hF  ) ) ) 8 8D | UVVVq WDI W WXXX 1r>cddlm}t|ddr#t|dSt|dd}||}||}|stdnWtd|rd t|znd d td t|d S||}td|j |rtd| ddtd| ddtd| dd| dpi}t|trf| dr(td| dddn)| dd}td|dtdt|ddsq td }n'#t t"f$rtd!Yd SwxYw|d"vrtd#d S||j $\} } } | rtd%| dStd&| d S)'a7Restore the skills tree from a snapshot. Defaults to newest. ``--list`` prints available snapshots and exits. ``--id `` picks a specific one. Without ``-y``, prompts for confirmation. A safety snapshot of the current tree is always taken first, so rollbacks are themselves undoable. rrlistF backup_idNzhcurator: no snapshots exist yet. Take one with `hermes curator backup` or wait for the next curator run.zcurator: no snapshot matching zid z your query.z Available:rmzRollback target: z reason: r?z created_at: r7z skill files: skill_files cron_jobs backed_upz cron jobs: jobs_countz. (will be restored for skill-link fields only)z not capturedz cron jobs: not in snapshot ()a This will replace the current ~/.hermes/skills/ tree (a safety snapshot of the current state is taken first so this is undoable). Cron jobs that still exist will have their skills/skill fields restored from the snapshot; all other cron fields are left alone.yeszProceed? [y/N] z cancelled)yr cancelled)rr(ucurator: rollback failed — )rLrr{rPsummarize_backups_resolve_backup list_backupsrepr_read_manifestr2r: isinstancedictinputstriplowerEOFErrorKeyboardInterruptrollback) rZrr target_pathrcmanifestcronransrro_s r _cmd_rollbackr s}%$$$$$tVU## n..00111qk400I 00;;K**,, 6 L     M.7I54 ??**\MMM    ,    .2244 5 5 5q,,[99H 0k. 0 0111 D = Xs ; ;==>>> A \3 ? ?AABBB B ]C @ @BBCCC||K((.B dD ! ! Dxx $$ DEdhh|Q&?&?EEE (N;;BBBBCCC  L 4 & & )**002288::CC+,    - 11  l " " +   1((;3C(DDJBQ  #   q /# / /000 1s63I** J Jparentargparse.ArgumentParserrpcfdd}|dd}|t|dd }|d d d d d|ddd d|t |dd}|t |dd}|t|dd}|dd|t|dd}|dd|t|dd}|dd|t|dd } | d!d"d#$| t|d%d&} | d'd d()| d*d+d"d,-| d.d/d d0)| td"S)1zAttach `curator` subcommands to *parent*. main.py calls this with the ArgumentParser returned by ``subparsers.add_parser("curator", ...)``. c<dfdS)Nrrm) print_help)ars rr=zregister_cli..^s(9(9(;(;Q'?'Br>)funccurator_command)deststatusz#Show curator status and skill stats)helprunzTrigger a curator review nowz--syncz --synchronousru store_truezCWait for the LLM review pass to finish (default: background thread))ractionrz --dry-runrnukReport only — no state changes, no archives, no consolidation (use this to preview what curator would do)pausezPause the curator until resumedresumezResume a paused curatorpinz4Pin a skill so the curator never auto-transitions itrz Skill nameunpinz Unpin a skillrestorezRestore an archived skillbackupzoTake a manual tar.gz snapshot of ~/.hermes/skills/ (curator also does this automatically before every real run)z--reasonNz;Free-text label stored in manifest.json (default: 'manual'))defaultrrzJRestore ~/.hermes/skills/ from a curator snapshot (defaults to the newest)z--listz3List available snapshots and exit without restoring)rrz--idrz6Snapshot id to restore (see `--list`); default: newest)rrrz-yz--yeszSkip confirmation prompt) set_defaultsadd_subparsers add_parserrk add_argumentrrrrrrrr) rsubsp_statusp_runp_pausep_resumep_pinp_unpin p_restorep_backup p_rollbacks ` r register_clirXs1  BBBBCCC  &7 8 8Dx.STTH {+++ OOE(FO G GE / l R )L;  H%%%oog,MoNNG j)))x.GHHH {+++ OOE(^O _ _E w\222 H%%%oogOo<ctjd}t|||}t |dd}||dSt ||pdS)z>Standalone entry (also usable by hermes_cli.main fallthrough).zhermes curator)progrNr)argparseArgumentParserr parse_argsr{rr)argvparserrZfns rcli_mainrs~  $*: ; ; ;F   T " "D vt $ $B zq rr$xx}1  r>__main__)rrr r )r r)rrr rprr)__doc__ __future__rrsysrrtypingrrrkrrrrrrrrrr__name__exitr>rrs#""""" ''''''''####(t t t t n) ) ) ) X                      &F F F F ZF0F0F0F0R      z CHXXZZr>