iOdZddlmZddlZddlZddlmZmZddlmZddl m Z d#d Z d$d Z d$dZ d$dZd$dZd$dZd$dZd$dZd$dZd%dZd$dZd$dZd$dZd$dZd&d Zd'd$d!Zed"krejedSdS)(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)Optionalts Optional[str]returnstrc|sdS tj|}n&#ttf$rt |cYSwxYw|j |tj}tj tj|z }t| }|dkr|dS|dkr|dzdS|dkr|dzdS|dzd S) Nnevertzinfo<zs agoizm agoiQzh agozd ago) r fromisoformat TypeError ValueErrorr rreplacerutcnowint total_seconds)rdtdeltasecss 7/home/piyush/.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  >>rcz ddlm}ddlm}|}|}|dd}|d}|dpd}|d d}|r|sd n|rd nd } td | td|tdt|td||d} | r9t|  rdnd} td| | | } | dzdkr| dkr| dzdn| d} td| td| dtd| d|}|stddSgggd}g}|D]q}|dd}||g||d r||d!rtd"t#|d#dD];}||g}td$|d%d&t#|<|r5td't#|d(d)|t'|dgd*+dd,}|rtd-|D]}t|d.}td$|d!d/d0|d1dd2d3|d4dd2d5|d6dd2d7|d8dd2d9| |dg}|rt'|d:d;<dd,}|r|dd1pddkrtd=|D]}t|d.}td$|d!d/d0|d1dd2d3|d4dd2d5|d6dd2d7|d8dd2d9| t'|d>+dd,}|rtd?|D]}t|d.}td$|d!d/d0|d1dd2d3|d4dd2d5|d6dd2d7|d8dd2d9| dS)@Nrcurator skill_usagepausedF last_run_atlast_run_summaryz(none) run_countENABLEDPAUSEDDISABLED curator: z runs: z last run: z last summary: last_report_pathz (missing)z last report: dhz interval: every z stale after: zd unusedz archive after: z no agent-created skills)activestalearchivedstater0pinnednamez agent-created skills: z total 10s z pinned (z): z, cZ|dp|dpdS)Nlast_activity_at created_atr,getrs rz_cmd_status..bs)aee.//L1553F3FL"keyz least recently active (top 5):r:40sz activity=activity_count3dz use= use_countz view= view_countz patches= patch_countz last_activity=c^|dpd|dpdfSNrFrr:r,r<r>s rr@z_cmd_status..{0155!1227a?Q9R9R9XVXYrAT)rCreversez most active (top 5):c^|dpd|dpdfSrLr<r>s rr@z_cmd_status..rMrAz least active (top 5):)agentr toolsr" load_state is_enabledr=printrrexistsget_interval_hoursget_stale_after_daysget_archive_after_daysagent_created_report setdefaultappendlenjoinsorted)argsr r"r3enabledr#last_runsummaryruns status_line_reportsuffix_ih_interval_labelrowsby_stater4r? state_namebucketr0last active_all most_active least_actives r _cmd_statusrq'sL!!!!!!    E  ""G YYx ' 'Fyy''Hii*++7xG 99[! $ $D V     #k # #$$$ %t % %&&& 2wx00 2 2333 (w ( ()))ii*++G6G}}++--?< 474F44555  $ $ & &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= ,, &* ,, 1rAc Rddlm}|stddSt t |dd}t t |dd}t t |ddp| }|rtd ntd dd}||||}|di}|r|r(td|dddnktd|ddd|ddd|ddd|dd|std|r!|rtdntddS) NrrzAcurator: disabled via config; enable with `curator.enabled: true`dry_runF background synchronousz7curator: running DRY-RUN (report only, no mutations)...zcurator: running review pass...msgr r Nonec$t|dSN)rT)rws r _on_summaryz_cmd_run.._on_summarys c rA) on_summaryrvrtauto_transitionszauto (preview): checkedu9 candidate skill(s) — no transitions applied in dry-runzauto: checked=z stale= marked_stalez archived=r2z 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.)rwr r rx)rPr rSrTboolgetattrrun_curator_reviewr=)r_r dryrurvr{resultautos r_cmd_runrs?      QRRRq wtY.. / /CgdL%8899Jwt]E::;;M:~K 1 GHHHH /000 ' '(F ::(" - -D    8488Iq#9#9888     <)Q!7!7<<.!44<< HHZ33<< $xx q99<<    X VWWW    [     [    1rAcZddlm}|dtddS)NrrTzcurator: pausedrPr set_pausedrTr_r s r _cmd_pausers< t  1rAcZddlm}|dtddS)NrrFzcurator: resumedrrs r _cmd_resumers< u  1rAcddlm}||jst d|jddS||jdt d|jddS) Nrr! curator: 'u`' is bundled or hub-installed — cannot pin (only agent-created skills participate in curation)rsTzcurator: pinned 'z ' (will bypass auto-transitions)rQr"is_agent_createdskillrT set_pinnedr_r"s r_cmd_pinrs!!!!!!  ' ' 3 3  B B B B   q4:t,,, Jdj J J JKKK 1rAcddlm}||jst d|jddS||jdt d|jddS) Nrr!rue' is bundled or hub-installed — there's nothing to unpin (curator only tracks agent-created skills)rsFzcurator: unpinned ''rrs r _cmd_unpinrs!!!!!!  ' ' 3 3  R R R R   q4:u--- - - - -... 1rAcxddlm}||j\}}t d||rdndS)Nrr!r*rs)rQr" restore_skillrrTr_r"okrws r _cmd_restorersR!!!!!!'' 33GB c  >11rAcddlm}||jdr"t d|jd|jddS||j\}}t d||rdndS) 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. rr!r4ru7' is pinned — unpin first with `hermes curator unpin `rsr*)rQr" get_recordrr=rT archive_skillrs r _cmd_archivers "!!!!!dj))--h77  3 3 3%)Z 3 3 3   q'' 33GB c  >11rArecorddict Optional[int]c|dp|d}|sdS tjt|}n#tt f$rYdSwxYw|j |tj }tdtj tj |z j S)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;Nrr) r=rrr rrrrrrmaxrdays)rrrs r _idle_daysrs & ' ' C6::l+C+CB t  #CGG , , z "tt y ZZx|Z , , q8< --28 9 99s!AA'&A'c8ddlm}t|dd}|dkr!td|dtjd St t|d d }t t|d d }g}|D]l}|d r|d|j kr7t|}|||krO| |d|fm|std|ddS| dtdt|d|d|D]\}}td|dd|d|rtddS|s tdt|d} n'#t"t$f$rtdYdSwxYw| d vrtd!dSd} g} |D]<\}} ||\} }| r| dz } %| ||f=td"| d#t|| r.td$| D]\}}td|d%|dSdS)&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. rr!rZrsz"curator: --days must be >= 1 (got ))filertFyesr4r3Nr5z6curator: nothing to prune (no unpinned skills idle >= zd)c|d S)Nrs)cs rr@z_cmd_prune..Fs 1Q4%rArBr*z skill(s) idle >= zd:r6rEz idle r.u (dry run — no changes made)z Archive z skill(s)? [y/N] z curator: abortedyrzcurator: abortedz curator: archived /z failures:z: )rQr"rrTsysstderrrrYr=STATE_ARCHIVEDrr[sortr\inputstriplowerEOFErrorKeyboardInterruptr)r_r"rrt skip_confirm candidatesr?idler5replyr2failures_rrws r _cmd_pruner'sG"!!!!! 4 $ $D axx :4:::LLLLq74E2233GeU3344LJ  - - / /-- 55??   55>>[7 7 7 !}} <4$;; 1V9d+,,,,  OtOOOPPPqOOO((( Ac*oo A A A A ABBB ,, d *4***4***++++ /000q  Is:IIIJJPPRRXXZZEE+,    & ' ' '11   $ $ $ % % %1HH))a++D11C  ) MHH OOT3K ( ( ( ( = = =C OO = =>>> k! & &ID# $t$$s$$ % % % %q 1sAG G-,G-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 snapshotrsreasonNmanual)ruEcurator: snapshot failed — check logs (backup disabled or IO error)z?curator: snapshot created at ~/.hermes/skills/.curator_backups/)rPrrSrTrsnapshot_skillsr5)r_rrsnaps r _cmd_backuprks%$$$$$  $ $ & &  G   q T8T * * 6hF  ) ) ) 8 8D | UVVVq WDI W WXXX 1rAcddlm}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:rszRollback 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 cancelledr cancelled)rr*ucurator: rollback failed — )rPrrrTsummarize_backups_resolve_backup list_backupsrepr_read_manifestr5r= isinstancerrrrrrrollback) r_rr target_pathrimanifestcronransrrwrs 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 Jcddlm}|}|stddS|D]}t|dS)z#List archived (recoverable) skills.rr!zcurator: no archived skills)rQr"list_archived_skill_namesrT)r_r"namesr5s r_cmd_list_archivedrsb!!!!!!  1 1 3 3E  +,,,q d 1rAparentargparse.ArgumentParserrxcfdd}|dd}|t|dd }|d d d d d|ddd d|ddd d|t |dd}|t |dd}|t|dd}|dd|t|dd}|dd|t|d d!}|dd|t|d"d#t|d$d%} | dd| t|d&d'} | d(td)d*+| d,d-d d./| ddd d0| t|d1d2} | d3d4d56| t|d7d8} | d9d d:/| d;d| d,d-d d?/| t d4S)@zAttach `curator` subcommands to *parent*. main.py calls this with the ArgumentParser returned by ``subparsers.add_parser("curator", ...)``. c<dfdS)Nrrs) print_help)ars rr@zregister_cli..s(9(9(;(;Q'?'BrA)funccurator_command)deststatusz#Show curator status and skill stats)helprunzTrigger a curator review nowz--syncz --synchronousrv store_truez@Wait for the LLM review pass to finish (default for manual runs))ractionrz --backgroundruzGStart the LLM review pass in a background thread and return immediatelyz --dry-runrtukReport 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 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))typedefaultrz-yz--yeszSkip the confirmation prompt)rrz,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--reasonNz;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_parserrq add_argumentrrrrrrrrrrrr) rsubsp_statusp_runp_pausep_resumep_pinp_unpin p_restore p_archivep_prunep_backup p_rollbacks ` r register_clirs  BBBBCCC  &7 8 8Dx.STTH {+++ OOE(FO G GE / l O \, V )L;  H%%%oog,MoNNG j)))x.GHHH {+++ OOE(^O _ _E w\222 H%%%oogOo<Standalone entry (also usable by hermes_cli.main fallthrough).zhermes curator)progrNr)argparseArgumentParserr parse_argsrrr)argvparserr_fns rcli_mainr@s~  $*: ; ; ;F   T " "D vt $ $B zq rr$xx}1  rA__main__)rr r r )r r)rrr r)rrr rxrz)__doc__ __future__rrrrrpathlibrtypingrrrqrrrrrrrrrrrrrr__name__exitrrArr"s#""""" ''''''''####(u u u u p1 1 1 1 h                  $::::&A A A A H    &F F F F R     f0f0f0f0R      z CHXXZZrA