`gj!!dZddlmZddlZddlZddlZddlmZmZm Z m Z d dZ ddZ ddZ dZdd Zdd Zdd Zed k(rej&eyy)aClassify candidate items by urgency/importance and emit only the urgent ones. The proactive-monitor pattern: a fetch step (a watcher script, an inbox dump, a feed) produces a list of candidate items; this script scores each with a cheap LLM and prints ONLY the items at or above a threshold. Below-threshold runs print nothing, so a cron job wrapping this stays silent unless something actually matters -- the classic urgency-monitor pattern (fetch -> classify urgency -> surface only what's above the bar). Design choices: * Uses Hermes' auxiliary client with task="monitor", so the classifier model is configured once in config.yaml (auxiliary.monitor.{provider,model}) and can be a cheap fast model independent of the main chat model. * Reads items as JSON (a list of objects) from stdin or --input-file. * One LLM call scores the whole batch (cheap, single round-trip) and returns structured scores; we filter locally. * Empty result -> empty stdout -> the cron job's [SILENT]/empty-stdout path suppresses delivery. No spam on quiet intervals. Usage (standalone): cat items.json | python classify_items.py --threshold 7 --criteria "Urgent if it needs a reply today or is from my manager/family" Usage (wired to a watcher via cron, agent mode): Ask the agent: "Every 10 minutes, run watch_http_json.py for my inbox feed, pipe its JSON into classify_items.py with my urgency criteria, and deliver whatever it prints. Stay silent if it prints nothing." Item schema (flexible): each item is an object; the classifier sees the whole object. A "title"/"subject"/"summary"/"text" field helps it judge. An "id" field (any of id/guid/message_id/url) is echoed back so duplicates can be deduped upstream. ) annotationsN)AnyDictListOptionalc6t|dtjiy)Nfile)printsysstderr)argss N/root/.hermes/venv/lib/python3.12/site-packages/cron/scripts/classify_items.py_eprintr,s 4!cjj!cd}|r't|d5}|j}dddntjj}|j }|sgS t j |}ttr't|jdtr|dS|gSt|tr!|Dcgc]}t|ts|c}Stdtjdy#1swYxYw#t j$r-}td|tjdYd}~d}~wwxYwcc}w)Nzutf-8)encodingz)classify_items: input is not valid JSON: itemsz6classify_items: expected a JSON list or {items: [...]})openreadr stdinstripjsonloadsJSONDecodeErrorrexit isinstancedictgetlist) input_filerawfdataexs r _load_itemsr(0s C *w / 1&&(C  iinn ))+C  zz#$ dhhw' .= v $7a:a#677 DEHHQK)     ;A3?@  8s/C=D ?E E =D E #EE cZdD]"}|j|}|st|cSd|S)N)idguid message_idurllinkzitem-)r str)itemindexkeyvals r_item_idr4Js8:hhsm s8O5'?raYou are an urgency classifier for a proactive assistant. You will be given a numbered list of items and the user's importance criteria. Score EACH item from 0 (ignore entirely) to 10 (interrupt the user now). Return ONLY a JSON array, one object per item, in the same order: [{"index": , "score": , "reason": ""}]. No prose, no markdown fences. Be conservative: most items should score low. Only score high when the item clearly meets the user's criteria.c d|ddg}t|D]O\}}dDcic] }||vr|||}}|s|}|jd|dtj|ddd Q|jd dj |Scc}w) NzUSER IMPORTANCE CRITERIA:  zITEMS:)titlesubjectsummarytextbodyfromsenderr-[z] F) ensure_asciiizG Return the JSON array of scores now (one object per item, same order).) enumerateappendrdumpsjoin)rcriterialinesir0kviews r _build_promptrI]s*8*B 7 BEU# M4^ Dy tAwJ  D q2djjEB5DIJKL M LLR 99U  sBc|xsdj}|jdr*|jd}d|vr|jddd} tj|}i}t|trN|D]I}t|ts|jd }t|ts6d|cxkr|ksBnE|||<K|S#tj $r|j d}|jd}|dk\rJ||kDrE tj|||dz}n7#tj $rtd icYcYSwxYwtd icYSYwxYw) Nrz````r6r>]rz1classify_items: could not parse classifier outputz1classify_items: classifier returned no JSON arrayr1)r startswithsplitrrrfindrfindrrr!rr int) contentn_itemsr:arrstartendoutobjidxs r _parse_scoresr[osQ Mr "D uzz# 4<::dA&q)Djj&(C#t Cc4('''"C#s#S(:7(:C   J+     #jjo A:#+ jjecAg!67'' KL   G HI  s6C?ED$#E$ E EE  EEc tjd}|jddd|jdtdd |jd dd |jdddgdd|j }t |j }|sy ddlm}t||j} |dd|dgdd}|jdjj}t!|t"s|r t#|nd}t%|t'|}g} t)|D]n\} } |j+| } t!| t,r| j+dnd} t!| tsK| |j.k\s[| j1| | | fp| sy|j2dk(rg| D cgc]6\} } } t5| | | j+d| j+d d| d!8}} } } t7t9j:|d"d#$yg}| D]\} } } | j+d%xs2| j+d&xs| j+d'xs t5| | }| j+d(xs| j+d)xsd}| j+d d}d*| j+dd+|}|r|d,|z }|r |d-|d.z }|j1|t7d/j=|y#t$r}td|Yd}~yd}~wwxYw#t$r}td|Yd}~yd}~wwxYwcc} } } w)0Nz1Classify items by urgency; emit only urgent ones.) descriptionz --criteriaTz#Plain-language importance criteria.)requiredhelpz --thresholdz+Minimum score (0-10) to surface. Default 7.)typedefaultr_z --input-filez0Read items JSON from this file instead of stdin.)rbr_z--formatr:rz!Output format for surfaced items.)choicesrbr_r)call_llmz0classify_items: cannot import auxiliary client: monitoruser)rolerSi)taskmessages max_tokens temperaturerz(classify_items: classifier call failed: scorereason)r*rnror0Fr)r?indentr7r8r9r-r.z## [z/10] r6z __z )argparseArgumentParser add_argumentrR parse_argsr(r"agent.auxiliary_clientrd ExceptionrrIrDrcmessagerSrr/r[lenr@r r thresholdrAformatr4r rrBrC)parserr rrdr&promptresprSscoressurfacedrFr0srnrXblocksr7r-roblocks rmainrsK  $ $1d eF  t:_`  CAno ;mn  VV,*%w7E2cU#3vha( MM%  ! fkk&!" } B1#FG  :1#>? & s7K75AL2;L?7 LLL L<$L77L<__main__)r rreturnNone)r"z Optional[str]rList[Dict[str, Any]])r0zDict[str, Any]r1rRrr/)rrrDr/rr/)rSr/rTrRrzDict[int, Dict[str, Any]])rrR)__doc__ __future__rrrrr typingrrrrrr(r4_CLASSIFY_INSTRUCTIONSrIr[r__name__rrrrsj D# ,,"4G$BN b z CHHTVr