`gjadZddlmZddlZddlZddlmZmZddlmZddl m Z ddZ ddZ dd Z dd Zdd Zdd Zdd ZddZddZddZddZddZddZddZddZddZdddZedk(rej:eyy)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)Path)Optionalc|sy tj|}|j |j tj}tjtj|z }t|j}|dkr|dS|dkr|dzdS|dkr|dzdS|dzd S#ttf$rt |cYSwxYw) Nnevertzinfo<zs agoizm agoiQzh agozd ago) r fromisoformat TypeError ValueErrorstrr replacerutcnowint total_seconds)tsdtdeltasecss E/root/.hermes/venv/lib/python3.12/site-packages/hermes_cli/curator.py_fmt_tsrs   # #B ' yy ZZx||Z , LL & +E u""$ %D byu~ d{"*U## e|$,u%%em_E "" z "2wsB11C Cc ddlm}ddlm}|j }|j }|j dd}|j d}|j dxsd}|j d d}|r|sd n|rd nd } td | td|tdt|d|vr6|j^} } td| | D]} td| ntd||j d} | r-t| jrdnd}td| ||j}|dzdk(r |dk\r|dzdn|d}td|td|jdtd|jdtd|jrdnd |jrdnd!|j!}|s td"ygggd#}g}|D][}|j d$d%}|j#|gj%||j d&sH|j%|d']td(t'|d)d#D]/}|j |g}td*|d+d,t'|1|r)td-t'|d.d/j)|t+|j d%gd01dd2}|rtd3|D]}t|j d4}td*|d'd5d6|j d7dd8d9|j d:dd8d;|j ddd8d?| |j d%g}|rdt+|d@dABdd2}|r|dj d7xsddkDrtdC|D]}t|j d4}td*|d'd5d6|j d7dd8d9|j d:dd8d;|j ddd8d?| t+|dD1dd2}|rtdE|D]}t|j d4}td*|d'd5d6|j d7dd8d9|j d:dd8d;|j ddd8d?| y)FNrcurator skill_usagepausedF last_run_atlast_run_summaryz(none) run_countENABLEDPAUSEDDISABLED curator: z runs: z last run:  z last summary: z last_report_pathz (missing)z last report: dhz interval: every z stale after: zd unusedz archive after: z consolidate: onoffz$ (prune-only; LLM merge pass opt-in)z no agent-created skills)activestalearchivedstater1pinnednamez agent-created skills: z total 10s z pinned (z): z, cR|jdxs|jdxsdS)Nlast_activity_at created_atr+getrs rz_cmd_status..os#aee./L1553FL"keyz least recently active (top 5):r;40sz activity=activity_count3dz use= use_countz view= view_countz patches= patch_countz last_activity=cV|jdxsd|jdxsdfSNrGrr;r+r=r?s rrAz_cmd_status..*155!127a?Q9R9XVXYrBTrDreversez most active (top 5):cV|jdxsd|jdxsdfSrMr=r?s rrAz_cmd_status..rNrBz least active (top 5):)agentrtoolsr load_state is_enabledr>printr splitlinesrexistsget_interval_hoursget_stale_after_daysget_archive_after_daysget_consolidateagent_created_report setdefaultappendlenjoinsorted)argsrr r4enabledr!last_runsummaryruns status_linefirstrestline_reportsuffix_ih_interval_labelrowsby_stater5r@ state_namebucketr1last active_all most_active least_actives r _cmd_statusrx's!    E  "G YYx 'Fyy'Hii*+7xG 99[! $DV   Ik] #$ tf %& wx01 23 w))+  "5'*+ /D &tf- . / "7),-ii*+GG}++-< "7)F845  $ $ &C8q=SBY3"9+QuAY $_$5 67 w;;=>h GH w==?@ IJ W%<%<%>TEJ((*20V W Y  + + -D  )*rr:H F %UU7H- J+2215 55? MM!F) $ %  $SYKv 6753 j"- :c"!CK=123 3v;-s499V+<*=>?  Xr" L q F 01 A155!345D QvYsO$EE"2A6r:;uu[!,R01lA.r23552267!!% (  "h+J Y  1  KN../?@EAJ * + quu%78963( !&6 :2>?55a045EE,2267 uu]A6r:;%%)F ,  Y  1   + ,! quu%78963( !&6 :2>?55a045EE,2267 uu]A6r:;%%)F ,  rBc ddlm}|js tdyt t |dd}t t |dd}t t |ddxs| }t t |d drd nd}|r td n td ||j s td dd}|j||||}|jdi}|ry|r td|jdddnWtd|jddd|jddd|jddd|jdd|s td|r|r tdytdy)NrrzAcurator: disabled via config; enable with `curator.enabled: true`dry_runF background synchronous consolidateTz7curator: running DRY-RUN (report only, no mutations)...zcurator: running review pass...ucurator: consolidation is off — running prune-only (deterministic stale/archive). Pass --consolidate or set `curator.consolidate: true` to enable the LLM merge pass.ct|yN)rV)msgs r _on_summaryz_cmd_run.._on_summarys  c rB) on_summaryr}r{r~auto_transitionszauto (preview): checkedu9 candidate skill(s) — no transitions applied in dry-runzauto: checked=z stale= marked_stalez archived=r3z reactivated= reactivateduFllm pass running in background — check `hermes curator status` laterzzdry-run: no changes applied. Read the report with `hermes curator status` and run `hermes curator run` (no flag) to apply.zdry-run: no changes applied. When the report lands, read it with `hermes curator status` and run `hermes curator run` (no flag) to apply.)rrreturnNone) rRrrUrVboolgetattrr\run_curator_reviewr>) rcrdryr|r}r~rresultautos r_cmd_runrs     QR wtY. /CgdL%89Jwt]E:;M:~Kwt]EBC$K  GH /07#:#:#<  H  ' ' (F ::(" -D  "488Iq#9":;88   )Q!7 89.!456 HHZ345#xx q9:<   VW  [  [  rBcHddlm}|jdtdy)NrrTzcurator: pausedrRr set_pausedrVrcrs r _cmd_pausers t  rBcHddlm}|jdtdy)NrrFzcurator: resumedrrs r _cmd_resumers u  rBcddlm}|j|jst d|jdy|j |jdt d|jdy) Nrr curator: 'u`' is bundled or hub-installed — cannot pin (only agent-created skills participate in curation)rzTzcurator: pinned 'z ' (will bypass auto-transitions)rSr is_agent_createdskillrV set_pinnedrcr s r_cmd_pinrsi!  ' ' 3  %B B 4::t, djj\)I JK rBcddlm}|j|jst d|jdy|j |jdt d|jdy) Nrrrue' is bundled or hub-installed — there's nothing to unpin (curator only tracks agent-created skills)rzFzcurator: unpinned ''rrs r _cmd_unpinrsh!  ' ' 3  %R R 4::u-  |1 -. rBcrddlm}|j|j\}}t d||rdSdS)Nrrr(rz)rSr restore_skillrrVrcr okrs r _cmd_restorers9!'' 3GB IcU 1rBcddlm}|j|jj dr't d|jd|jdy|j |j\}}t d||rdSdS) zManually archive an agent-created skill. Refuses if pinned. The auto-curator archives stale skills on its own schedule; this verb is for the user who wants to archive *now* without waiting for a run. rrr5ru7' is pinned — unpin first with `hermes curator unpin `rzr()rSr get_recordrr>rV archive_skillrs r _cmd_archivers "djj)--h7  %%%)ZZL 3 '' 3GB IcU 1rBc|jdxs|jd}|sy tjt|}|j |jtj}tdtjtj|z jS#tt f$rYywxYw)uDays since the skill's last activity (view / use / patch). Falls back to ``created_at`` so a skill that was authored but never used can still be pruned — otherwise never-touched skills would be immortal. Returns None only when both fields are missing or unparseable. r;r<Nr r) r>rr rrrr rrrmaxrdays)recordrrs r _idle_daysr,s & ' C6::l+CB   # #CG , yy ZZx||Z , q8<< -288 99 z "sB--B?>B?cRddlm}t|dd}|dkr td|dtj y t t|d d }t t|d d }g}|jD]\}|jd r|jd|jk(r4t|}|||krG|j|d|f^|std|dy|jdtdt|d|d|D]\}}td|dd|d|r tdy|sE tdt|djj!} | dvr td yd} g} |D]4\}} |j'|\} }| r| dz } "| j||f6td!| d"t|| r'td#| D]\}}td|d$|yy#t"t$f$rtdYywxYw)%aBulk-archive agent-created skills idle for >= N days. Pinned skills are exempt. Already-archived skills are skipped. Default ``--days 90`` matches a conservative read of the curator's own archive threshold; adjust with ``--days``. Use ``--dry-run`` to preview. rrrZrzz"curator: --days must be >= 1 (got ))filer{Fyesr5r4r6z6curator: nothing to prune (no unpinned skills idle >= zd)c|d S)Nrz)cs rrAz_cmd_prune..^s 1Q4%rBrCr(z skill(s) idle >= zd:r7rFz idle r-u (dry run — no changes made)z Archive z skill(s)? [y/N] z curator: aborted>yrzcurator: abortedz curator: archived /z failures:z: )rSr rrVsysstderrrr]r>STATE_ARCHIVEDrr_sortr`inputstriplowerEOFErrorKeyboardInterruptr)rcr rr{ skip_confirm candidatesr@idler6replyr3failures_rrs r _cmd_pruner?s`" 4 $D ax 24&:L74E23GeU34LJ  - - /- 55?  55>[77 7 !} <4$; 1V9d+,-  FtfBOPOOO( Ic*o&&8b AB , d 4*F4&*+, /0  Js:&77HIJPPRXXZE  $ $ %HH)a++D1C MH OOT3K ( )  !C O+< => k! &ID# BtfBse$ % & -+,  & ' s4H H&%H&cddlm}|js tdyt |ddxsd}|j |}| td ytd |j y) 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 snapshotrzreasonNmanual)ruEcurator: snapshot failed — check logs (backup disabled or IO error)z?curator: snapshot created at ~/.hermes/skills/.curator_backups/)rRrrUrVrsnapshot_skillsr6)rcrrsnaps r _cmd_backuprst%  $ $ &  G  T8T * 6hF  ) ) ) 8D | UV KDII; WX rBcddlm}t|ddrt|j yt|dd}|j |}|b|j }|s tdy td|rd t|znd d td t|j y |j|}td|j|rtd|jddtd|jddtd|jdd|jdxsi}t|trR|jdr td|jdddn!|jdd}td|dtdt|dds8 td jj}|d"vr td#y |j%|j$\} } } | rtd%| ytd&| y #t t"f$rtd!Yy wxYw)'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:rzzRollback target: z reason: r?z created_at: r<z 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 (ra 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.rzProceed? [y/N] z cancelled>rr cancelled)rr(ucurator: rollback failed — )rRrrrVsummarize_backups_resolve_backup list_backupsrepr_read_manifestr6r> isinstancedictrrrrrrollback) rcrr target_pathrpmanifestcronransrrrs r _cmd_rollbackrsa%tVU# n..01k40I 00;K**, L  0.754 ?*\J!M  ,  .224 5,,[9H k../ 01  Xs ;<=>  \3 ?@AB  ]C @ABC||K(.B dD !xx $%dhh|Q&?%@ADE (N;8BC  L 4 & )*00288:C l " + ((;3C3C(DJBQ  #  )# /0 +,  -  s'H<<IIcpddlm}|j}|s tdy|D] }t|y)z#List archived (recoverable) skills.rrzcurator: no archived skills)rSr list_archived_skill_namesrV)rcr namesr6s r_cmd_list_archivedrs;!  1 1 3E  +, d  rBc6ddl}ddlm}|j}t |dd}|r$|Dcgc]}|j d|k(s|}}t |dd}|dk(r|j d n.|d k(r|j d d n|j dd t |ddrt|j|ddy|s tdydddd}|D]:}|j |j ddddz||j dd<<tdt|d|dd|dd|dd ttddd dd!d"dd#d$dd%d$dd&d'dd(d$d) |D]}t|j d*}td|ddd+d d|j ddd"d|j d,dd-d|j d.dd-d|j d/dd0d|j d1dd-d|ycc}w)2u Show usage telemetry for ALL skills, with provenance. Unlike `status` (curator-scoped to agent-created candidates), this lists every skill on disk — bundled built-ins and hub-installed included — so you can see how often each is actually used regardless of curation. rNr provenanceractivityr6c |dS)Nr6rr?s rrAz_cmd_usage..s & rBrCrecentc,|jdxsdS)Nr;r+r=r?s rrAz_cmd_usage..s&8 9 ?RrBTrOc&|jddS)NrGrr=r?s rrAz_cmd_usage..s&6 :rBjsonFr)indent ensure_asciizcurator: no skills foundrRbundledhubrRrzzskills: z total (agent=z bundled=rz hub=rrr7rrForigin8susez>4sviewpatchz>5sactz last_activityr;(rIz>4drJrKz>5drG) rrSr usage_reportrr>rrVdumpsr`r) rc_jsonr rp prov_filterr@sort_keycountsrts r _cmd_usager sn!  # # %D$ d3KFa155#6+#EFFtVZ0H6 ) * X  ? N :D ItVU# ekk$quk=>  ()Qq 1F _/5zz!%% g:VXY/Z]^/^quu\7+,_ 3t9+/"*VI->,?vfUm_TU W G WSMHR= +Rs|2gc]"U3K P  quu/01 63B$Buu\7+B/ruu[!$S)uu\1%c*"uu]A&s+2uu%q)#.bf      WGs HHcbjfdjd}|jdd}|jt|jdd }|j d d d d |j dddd|j ddd|jt |jdd}|j ddddd|j dddd |j d!d"dd#|j d$d%dd&|jt |jd'd(}|jt|jd)d*}|jt|jd+d,}|j d-d.|jt|jd/d0}|j d-d.|jt|jd1d2} | j d-d.| jt|jd3d4jt|jd5d6} | j d-d.| jt|jd7d8} | j d9td:d;<| j d=d>dd?| j d!d"dd@| jt|jdAdB} | j dCddDE| jt |jdFdG} | j dHddI| j dJdKddLM| j d=d>ddN| jt"y)OzAttach `curator` subcommands to *parent*. main.py calls this with the ArgumentParser returned by ``subparsers.add_parser("curator", ...)``. c.jdfdS)Nrrz) print_help)aparents rrAzregister_cli..1s(9(9(;Q'?'BrB)funccurator_command)deststatusz#Show curator status and skill stats)helpusagezJShow usage telemetry for ALL skills (built-in, hub, agent) with provenancez--sort)rrr6rzlSort order: activity (most-used first, default), recent (most-recently-active first), or name (alphabetical))choicesdefaultrz --provenancerNzOnly show skills of this originz--json store_truez/Emit the full report as JSON instead of a table)actionrrunzTrigger a curator review nowz--syncz --synchronousr}z@Wait for the LLM review pass to finish (default for manual runs))rrrz --backgroundr|zGStart the LLM review pass in a background thread and return immediatelyz --dry-runr{ukReport only — no state changes, no archives, no consolidation (use this to preview what curator would do)z --consolidater~zForce the LLM umbrella-building consolidation pass on for this run, overriding the config default (off). Without this flag the run is prune-only unless `curator.consolidate: true` is set.pausezPause the curator until resumedresumezResume a paused curatorpinz4Pin a skill so the curator never auto-transitions itrz Skill nameunpinz Unpin a skillrestorezRestore an archived skillz list-archivedzList archived skillsarchivezBManually archive a skill (move to .archive/, excluded from prompt)prunezABulk-archive agent-created skills idle for >= N days (default 90)z--daysrz5Archive skills idle for at least N days (default: 90))typerrz-yz--yeszSkip the confirmation promptz,Show what would be archived without doing itbackupzoTake a manual tar.gz snapshot of ~/.hermes/skills/ (curator also does this automatically before every real run)z--reasonz;Free-text label stored in manifest.json (default: 'manual'))rrrzJRestore ~/.hermes/skills/ from a curator snapshot (defaults to the newest)z--listz3List available snapshots and exit without restoringz--idrz6Snapshot id to restore (see `--list`); default: newest)rrrzSkip confirmation prompt) set_defaultsadd_subparsers add_parserrx add_argumentr rrrrrrrrrrrr)rsubsp_statusp_usagep_runp_pausep_resumep_pinp_unpin p_restore p_archivep_prunep_backup p_rollbacks` r register_clir5+s)  BC  &7 8Dx.STH {+oo YG 8*D   ;T .  > j) OOE(FO GE / l O \, V )L;  mLL  H%oog,MoNG j)x.GHH {+ OOE(^O _E w\2 H%oogOoStandalone entry (also usable by hermes_cli.main fallthrough).zhermes curator)progrNr)argparseArgumentParserr5 parse_argsrr r)argvparserrcfns rcli_mainr>s`  $ $*: ;F   T "D vt $B z r$x}1 rB__main__)rz Optional[str]rr)rr)rrrz Optional[int])rzargparse.ArgumentParserrrr)__doc__ __future__rr8rrrpathlibrtypingrrrxrrrrrrrrrrrrr r5r>__name__exitrrBrrFs# '#(B J< ~      $:&A H &F R  9 @0D  z CHHXZrB