Ki1E!|dZddlZddlZddlZddlZddlmZddlmZm Z m Z m Z ej deeejjddlmZmZmZmZmZmZmZmZmZgdZhdZded efd Zd e e eeffd Zd e eefd efd ZdHde ede ed e efdZ ddde ede!d e efdZ"d e eefd e eeffdZ# dIdede ede ede ede ede e$de ede!de ede e ede ede ed e ed!e ed"ed ef d#Z% dJdedede ede e$de ede ede ed e ed"ed efd$Z&dKde!d"ed efd%Z'dLded"ed efd&Z(d'd(d)d*d+d,d*d-d,d*d.d,d*d/d,d*d0d,d1d2d,d*d3d,d*d4d,d*d5d,d*d6d,d7d8d,d*d9d,d:d;d*idd,d?dgd@dAZ)d e!fdBZ*dCZ+ddDl,m-Z-e-j.d'd'e)dEe*dFGdS)Mz Cron job management tools for Hermes Agent. Expose a single compressed action-oriented tool to avoid schema/context bloat. Compatibility wrappers remain for direct Python callers and legacy tests. N)Path)AnyDictListOptional) create_jobget_job list_jobsparse_schedule pause_job remove_job resume_job trigger_job update_job) )zJignore\s+(?:\w+\s+)*(?:previous|all|above|prior)\s+(?:\w+\s+)*instructionsprompt_injection)zdo\s+not\s+tell\s+the\s+userdeception_hide)zsystem\s+prompt\s+overridesys_prompt_override)z ​‌‍‪‫‬‭‮⁠promptreturnctD]}||vrdt|ddcStD]-\}}tj||tjrd|dcS.dS)zUScan a cron prompt for critical threats. Returns error string if blocked, else empty.z-Blocked: prompt contains invisible unicode U+04Xz (possible injection).z(Blocked: prompt matches threat pattern 'zD'. Cron prompts must not contain injection or exfiltration payloads.)_CRON_INVISIBLE_CHARSord_CRON_THREAT_PATTERNSresearch IGNORECASE)r&charpatternpids 0/home/ubuntu/hermes-agent/tools/cronjob_tools.py_scan_cron_promptr57s%ii 6>>h3t99hhhh h h h -HH  9Wfbm 4 4 HHcHHH H H H H 2ctjd}tjd}|r-|r+||tjdtjddSdS)NHERMES_SESSION_PLATFORMHERMES_SESSION_CHAT_IDHERMES_SESSION_CHAT_NAMEHERMES_SESSION_THREAD_ID)platformchat_id chat_name thread_id)osgetenv)origin_platformorigin_chat_ids r4_origin_from_envrDBsii 9::OY788N > '%#=>>#=>>    4r6jobc|dpid}|dpidd}|dS|dkr |dkrdndS|r|d |n|d S) Nrepeattimes completedrforeveroncez1/1/z times)get)rErHrIs r4_repeat_displayrOOs WWX   $" ) )' 2 2E""(b--k1==I }y zz"avvU2%. Di ! !% ! ! !u4D4D4DDr6skillskillsc||r|gng}n(t|tr|g}nt|}g}|D]@}t|pd}|r||vr||A|S)Nr*) isinstancestrliststripappend)rPrQ raw_items normalizeditemtexts r4_canonical_skillsr\Ys ~$,UGG" FC !H LL J$$4:2$$&&  $D **   d # # # r6Fstrip_trailing_slashvaluer^c|dSt|}|r|d}|pdS)NrM)rTrVrstrip)r_r^r[s r4_normalize_optional_job_valuerbjsF }t u::    D {{3 <4r6c |dd}t|d|d}id|dd|dd|r|dndd|d t|d kr |dd d zn|d |d d |d d|dd|ddt|d|ddd|dd|dd|dd|ddd|d|ddrdndd|dd|diS)Nr&r*rPrQjob_ididnamerprompt_previewdz...modelproviderbase_urlscheduleschedule_displayrGdeliverlocal next_run_at last_run_at last_statusenabledTstate scheduledpaused paused_at paused_reason)rNr\lenrO)rEr&rQs r4 _format_jobrzts  WWXr " "F swww//1B1B C CF #d) F   f.$  &   #f++2C2C&#,..   !!   CGGJ''  CGGJ''  CGG.//  /#&&  3779g..  sww}--  sww}--  sww}--  3779d++  D1I1I"W++xXX! " SWW[))# $ 11%  r6actionrdrlrfrGrninclude_disabledrirjrkreasontask_idc\ ~ |pd}|dkr]|stjddddSt || }|s|stjddddS|r*t |}|rtjd|ddSt |pd||||t|t| t| t| d  }tjd |d |d | d| dg|dt|| dd|dt|d|d dd dS|dkrAdt|D}tjd t||ddS|stjdd|dddSt|}|stjdd|dddS|dkrot|}|stjdd |dddStjd d|d d!||d | dd"d#dS|d$kr7t!|| %}tjd t|d&dS|d'kr5t#|}tjd t|d&dS|d(vr5t%|}tjd t|d&dS|d)kri}|/t |}|rtjd|ddS||d+<|||d <|||d<| |$t || }||d<|r|d,nd*|d<| t| |d-<| t| |d.<| t| d |d/<|8|d,krd*n|}t'| d0pi}||d1<||d0<|Pt)|}||d2<| d3||d<| d4d5kr d6|d4<d |d7<|stjdd8ddSt+||}tjd t|d&dStjdd9|dddS#t,$r0}tjdt/|ddcYd*}~Sd*}~wwxYw):z!Unified cron job management tool.r*createFzschedule is required for create)successerror)indentz3create requires either prompt or at least one skillTr]) r&rlrfrGrnoriginrQrirjrkrerfrPrQrmrnrorpz Cron job 'z ' created.) rrdrfrPrQrlrGrnrprEmessagerUc,g|]}t|S)rz).0rEs r4 zcronjob..s ]]]K$$]]]r6)r|)rcountjobszjob_id is required for action ''z Job with ID 'z8' not found. Use cronjob(action='list') to inspect jobs.removezFailed to remove job 'z ' removed.)rerfrl)rr removed_jobpause)r})rrEresume>runrun_nowtriggerupdateNr&rrirjrkrGrHrldisplayrtrvrurszNo updates provided.zUnknown cron action ')rVlowerjsondumpsr\r5rrDrbrNrOrzr ryr r r rrdictr r ExceptionrT)r{rdr&rlrfrGrnr|rPrQrirjrkr}r~rYcanonical_skills scan_errorrErremovedupdatedupdatesnormalized_repeat repeat_stateparsed_schedulees r4cronjobrs$ @Il))++1133  ! ! lze>_"`"`ijkkkk0??  @"2 @ze>s"t"t}~ Y.v66 Y:%*&M&MVWXXXX|!'))'3E::6x@@6xVZ[[[   C:#!$iK WWW--!ggh33 #$6 7-c22"wwy'::#&}#5&s++CCKCCC   "   ]] K[0\0\0\]]]D:$TDQQZ[\\\ \ v:%:i\f:i:i:ijjstuuu ufoo :!,|F,|,|,|}}   ! ! ((G mze>`W]>`>`>`"a"ajkllll:#CCKCCC$ #F $'GG,>$?$?$$      v666G:${77K7KLLUVWWW W  ! ! ((G:${77K7KLLUVWWW W 6 6 6!&))G:${77K7KLLUVWWW W  ! !&(G!.v66 Y:%*&M&MVWXXXX$*!"&"%, "!U%6#4UF#C#C $4!:J#T#3A#6#6PT  #@#G#G #&CH&M&M ##&CHcg&h&h&h #!,2aKKDDV!#CGGH$5$5$;<< (9 W%$0!#"0":":&5 #.=.A.A)X.V.V*+777##x//'2GG$)-GI& aze>T"U"U^_```` 11G:${77K7KLLUVWWW Wze6Wf6W6W6WXXabcccc IIIzec!ff==aHHHHHHHHHIs|A S1 ,S1:+S1&C(S1AS1S15-S1#3S1AS1DS15S1S11 T+;%T& T+&T+c 4td||||||||| S)Nr) r{r&rlrfrGrnrirjrkr~r) r&rlrfrGrnrirjrkr~s r4schedule_cronjobr(s9      r6c&td||S)NrU)r{r|r~r)r|r~s r4 list_cronjobsrAs &3CW U U UUr6c&td||S)Nr)r{rdr~r)rdr~s r4remove_cronjobrEs (67 C C CCr6rubManage scheduled cron jobs with a single compressed tool. Use action='create' to schedule a new job from a prompt or one or more skills. Use action='list' to inspect jobs. Use action='update', 'pause', 'resume', 'remove', or 'run' to manage an existing job. Jobs run in a fresh session with no current-chat context, so prompts must be self-contained. If skill or skills are provided on create, the future cron run loads those skills in order, then follows the prompt as the task instruction. On update, passing skills=[] clears attached skills. NOTE: The agent's final response is auto-delivered to the target. Put the primary user-facing content in the final response. Cron jobs run autonomously with no user present — they cannot ask questions or request clarification. Important safety rule: cron-run sessions should not recursively schedule more cron jobs.objectstringz8One of: create, list, update, pause, resume, remove, run)type descriptionz+Required for update/pause/resume/remove/runzFor create: the full self-contained prompt. If skill or skills are also provided, this becomes the task instruction paired with those skills.zCFor create/update: '30m', 'every 2h', '0 9 * * *', or ISO timestampzOptional human-friendly nameintegerzTOptional repeat count. Omit for defaults (once for one-shot, forever for recurring).a;Delivery target: origin, local, telegram, discord, slack, whatsapp, signal, matrix, mattermost, homeassistant, dingtalk, feishu, wecom, email, sms, or platform:chat_id or platform:chat_id:thread_id for Telegram topics. Examples: 'origin', 'local', 'telegram', 'telegram:-1001234567890:17585', 'discord:#engineering'z;Optional per-job model override used when the cron job runszJOptional per-job provider override used when resolving runtime credentialszEOptional per-job base URL override paired with provider/model routingbooleanz'For list: include paused/completed jobszCOptional single skill name to load before executing the cron promptarrayrzOptional ordered list of skills to load before executing the cron prompt. On update, pass an empty array to clear attached skills.)ritemsrzOptional pause reason)r{rdr&rlrfrGrnrirjrkr|rPrQr})r propertiesrequired)rfr parameterscttjdp'tjdptjdS)z Check if cronjob tools can be used. Available in interactive CLI mode and gateway/messaging platforms. The cron system is internal (JSON file-based scheduler ticked by the gateway), so no external crontab executable is required. HERMES_INTERACTIVEHERMES_GATEWAY_SESSIONHERMES_EXEC_ASK)boolr@rArr6r4check_cronjob_requirementsrsJ  &'' ( 9- . . ( 9& ' '  r6ctgS)z/Return tool definitions for cronjob management.)CRONJOB_SCHEMArr6r4get_cronjob_tool_definitionsrs  r6)registryc |t|dd|d|d|d|d|d|d|d d |d |d |d |d|d|d|dS)Nr{r*rdr&rlrfrGrnr|FrPrQrirjrkr}r~)r{rdr&rlrfrGrnr|rPrQrirjrkr}r~)rrN)argskws r4rswxx"%%xx!!xx!!*%% XXf  xx!!##"4e<<hhwxx!!hhw*%%*%%xx!!y!!   r6u⏰)rftoolsetschemahandlercheck_fnemoji)NN)NNNNNNFNNNNNNN)NNNNNNN)FN)N)/__doc__rr@r.syspathlibrtypingrrrrpathinsertrT__file__parent cron.jobsrr r r r r rrrr-r+r5rDrOr\rrbrzintrrrrrrrtools.registryrregisterrr6r4rsz ,,,,,,,,,,,,33ttH~~,344555                      $    cc (4S>2    Ec3hECEEEE  Xc] 8C= TXY\T]    "Y^#QUbjknboT#s(^S#X6! " !""&"" TITI TI SMTI SMTIsm TI 3- TI SM TIc]TITI C=TI T#Y TI C=TIsmTIsmTI SMTITI  !TITITITI| !""  3- SM  c]  C= smsm 2VVDV3V#VVVVDD3DDDDDD \ !Y !L ! o !d != "u ! ] !\ !k !f "H!! !d   (+ d !6m: : vJ{>>#PPf D     $#####     "( -r6