`gj$dZddlmZddlZddlZddlZddlZddlZddlZddl m Z ddl m Z m Z mZmZddlmZddlmZddlmZej.eZej5d z Zed z Zej:Zd Ze hd Z!d Z"dZ#dZ$ddZ%ddZ&ddZ'd dZ(d!dZ)d!dZ* d"dZ+d#dZ,d$dZ-d%dZ.ddd&dZ/d'dZ0y)(uSuggested cron jobs — proposed automations the user accepts with one tap. A *suggestion* is a ready-to-run cron job spec that Hermes surfaces to the user, who accepts it (creates the real cron job) or dismisses it (latched so it is never re-offered). This is the single surface every automation proposal flows through, regardless of where it came from: * ``catalog`` — a curated starter automation (daily briefing, important-mail monitor, weekly digest, ...). * ``blueprint`` — the user installed a skill that carries a ``blueprint:`` block (see ``tools/blueprints.py``); installing it registers a suggestion instead of auto-scheduling. * ``usage`` — the background self-improvement review noticed a recurring ask that a scheduled job would serve. * ``integration`` — the user connected an account (Gmail, GitHub, ...) and the obvious automations for that surface are offered. Accepting a suggestion just calls the existing ``cron.jobs.create_job`` with the stored ``job_spec`` — there is NO second job engine. Suggestions never auto-create jobs; acceptance is always explicit (consent-first). Dismissed suggestions latch by a stable ``dedup_key`` so the same proposal is not re-offered after the user says no. Storage mirrors ``cron/jobs.py``: ``~/.hermes/cron/suggestions.json``, atomic writes, an in-process lock, and 0600 perms. ) annotationsN)Path)AnyDictListOptional)get_hermes_home)now)atomic_replacecronzsuggestions.json>usagecatalog blueprint integrationpendingaccepted dismissedcP tj|dy#t$rYywxYw)Ni)oschmodOSError)paths C/root/.hermes/venv/lib/python3.12/site-packages/cron/suggestions.py _secure_filerAs'  u    s  %%c2tjddy)NT)parentsexist_ok)CRON_DIRmkdirr _ensure_dirr#Hs NN4$N/r"ctjsdgiS ttdd5}tj|}dddttr!t|jdtr|St|trd|iStjddgiS#1swYgxYw#tj t f$r$}tjd|dgicYd}~Sd}~wwxYw)N suggestionsrutf-8encodingz0suggestions.json unreadable (%s); starting emptyz*suggestions.json malformed; starting empty) SUGGESTIONS_FILEexistsopenjsonloadJSONDecodeErrorrloggerwarning isinstancedictgetlist)fdataes r _load_rawr9Ls  " " $r""# "C' : a99Qz!add_suggestion..sY!aeeHo6XAYs''z)Suggestion backlog full (%d); dropping %r )idtitle descriptionsourcejob_specrZrU created_at) VALID_SOURCES ValueErrorstrip_suggestions_lockr9r4_STATUS_DISMISSED_STATUS_ACCEPTEDrVsum MAX_PENDINGr0infouuiduuid4hexrHrIappendrQ) rarbrcrdrZr%existing pending_countrecords radd_suggestionrv}sw$]"6vjABB ;;=  1;<< koomR8 $ H||K(I5<<).?AQ-RR<<)_<  Y{YY K ' KKC[RW X$**,""3B'[[]&,,. "*%%-113   6"+;s+4F=F$F=F8FB FF&ct}|D]}|jd|k(s|cS|jrP|Dcgc]}|jdtk(s|}}t |dz }d|cxkrt |kr||S|D]7}|jddj |j k(s5|cSycc}w)zDResolve a suggestion by id, 1-based pending index, or title (exact).r`rUr\rraN)rSr4isdigitrVintlenlower)refr%rWridxs rget_suggestionrs"$K  55;# H {{})PQUU8_-O1PP#hl  "c'l "3<  # 55"  # # % 4H Qs CCct5tjdg}d}|D]:}|jd|k(s||d<tj |d<d}n|r t ||cdddS#1swYyxYw)Nr%Fr`rU resolved_atT)rir9r4rHrIrQ) suggestion_idrUr%changedrWs r _set_statusrs  koomR8  AuuT{m+$( #.=#:#:#<-     k "   s6A;3A;;BcDt|}|syt|dtS)uFDismiss a suggestion (latched — never re-offered for its dedup_key).Fr`)rrrj)r}rWs rdismiss_suggestionrs$sA  qw 1 22r")originct|}|r|jdtk7ryddlm}t |jdxsi}| d|vr||d<|di|}t |dt|S) a]Accept a suggestion: create the real cron job from its ``job_spec``. Returns the created cron job dict, or None if the suggestion isn't found / not pending. The job_spec is passed straight to ``cron.jobs.create_job``; an ``origin`` (platform/chat) is merged so "origin" delivery routes back to the chat where the user accepted. rUNr) create_jobrdrr`r!)rr4rV cron.jobsrr3rrk)r}rrWrspecjobs raccept_suggestionrsu sA h?2$ j!'R (D hd2X  t C$)* Jr"ct5tjdg}|Dcgc]}|jdtk7s|}}t |t |z }|r t ||cdddScc}w#1swYyxYw)aqDrop accepted/dismissed records from disk. Returns the count removed. Pending suggestions and the dedup memory of dismissed ones are the only things that matter long-term, but dismissed records must be RETAINED for their dedup_key (so they aren't re-offered). This only prunes ACCEPTED records, which have served their purpose once the job exists. r%rUN)rir9r4rkr{rQ)r%rWkeptremoveds rclear_resolvedrsy koomR8 &Na!%%/=M*MNNk"SY.  dO Ns"A>A9A9'A>9A>>B)rrreturnNone)rr)rDict[str, Any])r%List[Dict[str, Any]]rr)rr) rarDrbrDrcrDrdrrZrDrOptional[Dict[str, Any]])r}rDrr)rrDrUrDrbool)r}rDrr)r}rDrrrr)rrz)1__doc__ __future__rr-loggingrrB threadingropathlibrtypingrrrrhermes_constantsr hermes_timer rHutilsr getLogger__name__r0resolverr*Lockrirm frozensetrfrVrkrjrr#r9rQrSrXrvrrrrrr!r"rrs6#   ,,,*   8 $   $ $ & /00#INN$ JK  0",. Q 4 44  4  4  44n( 3GK.r"