(GjZdZddlZddlZddlZddlmZddlmZddlmZddl m Z m Z m Z m Z ddlmZejeZdZejd ejZd e ed efd Zd dlmZmZd dlmZd dlm Z de ed efdZ!de ed efdZ"de d efdZ#de d e efdZ$de d efdZ%de d e efdZ&de ed e efdZ'eGddZ(GddZ)dS) u0 Delivery routing for cron job outputs and agent responses. Routes messages to the appropriate destination based on: - Explicit targets (e.g., "telegram:123456789") - Platform home channels (e.g., "telegram" → home channel) - Origin (back to where the job was created) - Local (always saved to files) N)Path)datetime) dataclass)DictListOptionalAny)get_hermes_homeizv^[\s*_~`]*\(?\s*(silent|silence|no\s+response|no\s+reply)\s*\.?\)?[\s*_~`]*$|^[\s*_~`]*[\U0001F507\.\u2026]+[\s*_~`]*$contentreturnc|sdS|}|rt|dkrdStt|S)uReturn True when ``content`` is *only* a silence-narration token. Length-guarded (real messages are longer) and anchored to the whole string so legitimate prose like "The deployment ran silently" or "Silence is golden — here is the plan..." is never flagged. F@)striplenbool_SILENCE_NARRATIONmatch)r strippeds 6/home/rurouni/.hermes/hermes-agent/gateway/delivery.py_is_silence_narrationr+sX u}}H s8}}r))u "((22 3 33)Platform GatewayConfig) SessionSource)DeadTargetRegistrychat_idcb|dS t|dkS#ttf$rYdSwxYw)uuTrue when ``chat_id`` is a positive int — Telegram's private-chat shape. Telegram private chats use positive chat IDs; groups/channels/supergroups use negative IDs. This is the single source of truth for that heuristic, reused by the handoff seed path in ``gateway/run.py`` so handoff-created DM topics key the same way as inbound DM-topic messages. NFrint TypeError ValueError)rs r#looks_like_telegram_private_chat_idr#>sKu7||a z "uus ..valuec^|dS t|dS#ttf$rYdSwxYw)NFTr)r$s r_looks_like_intr&NsH }u E t z "uus ,,resultct|tr|dduSt|ddduS)NsuccessFT) isinstancedictgetgetattr)r's r_send_result_failedr.XsB&$.zz)$$-- 69d + +u 44rct|tr|d}nt|dd}|rt |ndS)Nerrorr*r+r,r-strr'r0s r_send_result_errorr4^sM&$/ 7##.. (3u:::D(rcjt|}t|od|vS)Nzthread not found)r4rlowerr3s r#_is_thread_not_found_delivery_errorr7fs0 v & &E =, = > >>rct|tr|d}nt|dd}|rt |ndS)zFReturn the machine-readable error_kind from a SendResult/dict, if any. error_kindNr1)r'kinds r_send_result_error_kindr;ksM&$3zz,''v|T22 &3t999$&r error_textc|sdS ddlm}m}n#t$rYdSwxYw|d|}t j|sdS|dkr||sdS|S)a3Best-effort dead-target classification from a raised error's text. ``_deliver_to_platform`` raises (it does not return a SendResult) on a hard failure, so the ``deliver()`` loop only has the exception string. Reuse the platform-neutral classifier to recover the error_kind from that text. Nr)classify_send_erroris_chat_level_not_found)r< not_found)platforms.baser>r? Exceptionris_dead_error_kind)r<r>r?r:s r_classify_dead_from_error_textrDts tPPPPPPPPP tt  t ; ; ;D  0 6 6t  {#:#:j#Q#Q#Qt Ks  ceZdZUdZeed<dZeeed<dZ eeed<dZ e ed<dZ e ed<e dd ed eed dfd Zd efd ZdS)DeliveryTargetu A single delivery target. Represents where a message should be sent: - "origin" → back to source - "local" → save to local files - "telegram" → Telegram home channel - "telegram:123456" → specific Telegram chat platformNr thread_idF is_origin is_explicittargetoriginr c|}|}|dkr7|r||j|j|jdS|t jdS|dkr|t jSd|vr|dd}|d }t|d kr|d nd }t|dkr|dnd } t |} || ||d S#t$r|t jcYSwxYw t |} || S#t$r|t jcYSwxYw) u Parse a delivery target string. Formats: - "origin" → back to source - "local" → local files only - "telegram" → Telegram home channel - "telegram:123456" → specific Telegram chat rLT)rGrrHrI)rGrIlocal)rG:rrN)rGrrHrJ) rr6rGrrHrLOCALsplitrr") clsrKrLtarget_stripped target_lowerparts platform_strrrHrGs rparsezDeliveryTarget.parses!,,..&,,.. 8 # # Ds#_"N$." sHNdCCCC 7 " "3/// / / ! !#))#q11E 8>>++L"%e**q..eAhhdG$'JJNNaI 4#L11sHg`deeee 4 4 4sHN333333 4  0 --H3))) ) 0 0 03/// / / / 0s$1D D21D26E E43E4c|jrdS|jtjkrdS|jr%|jr|jjd|jd|jS|jr|jjd|jS|jjS)zConvert back to string format.rLrNrO)rIrGrrQrrHr$)selfs r to_stringzDeliveryTarget.to_strings > 8 =HN * *7 < LDN Lm)KKDLKK4>KK K < ;m)::DL:: :}""r)N)__name__ __module__ __qualname____doc__r__annotations__rrr2rHrIrrJ classmethodrrXr[rrrFrFs!GXc]!!!#Ix}###ItK0000300(?00K[000000[00d #3 # # # # # #rrFceZdZdZ ddedeeefdee fdZ dde de e d ee d ee d eee efd ee eff d Zde d ee d ee d eee efd ee eff dZde d e d efdZd efdZde de d eee efd ee effdZdS)DeliveryRouterz Routes messages to appropriate destinations. Handles the logic of resolving delivery targets and dispatching messages to the right platform adapters. Nconfigadapters dead_targetsc||_|pi|_tdz dz |_|p t |_dS)aS Initialize the delivery router. Args: config: Gateway configuration adapters: Dict mapping platforms to their adapter instances dead_targets: Optional shared registry of confirmed-unreachable targets. When omitted, a profile-local registry is created. cronoutputN)rerfr output_dirrrg)rZrerfrgs r__init__zDeliveryRouter.__init__sG  B )++f4x?(@,>,@,@rr targetsjob_idjob_namemetadatar c Ki}|D]}|jtjkrx|jrq|j|jj|jrGtd|jj|jdddd|| < |jtjkr| ||||}n]| |||d{V}|jr9t|s*|j |jj|jd|d|| <8#t$r} |jtjkrk|jrdtt!| } | rF|j|jj|j| d t!| dd  dt!| d || <Yd} ~ d} ~ wwxYw|S) a Deliver content to all specified targets. Args: content: The message/output to deliver targets: List of delivery targets job_id: Optional job ID (for cron jobs) job_name: Optional job name metadata: Additional metadata to include Returns: Dict with delivery results per target zHSkipping delivery to known-dead target %s:%s (send to it again to clear)F dead_targetz'target previously confirmed unreachable)r)skippedr0NT)r)r'z: x)reason)r)r0)rGrrQrrgis_deadr$loggerinfor[_deliver_local_deliver_to_platformr.clearrBrDr2 mark_dead) rZr rmrnrorpresultsrKr'e dead_kinds rdeliverzDeliveryRouter.deliversK*0 0 F8>11N2%--fo.CV^TT2 2O)6> %,F//((**+  ?hn44!00&(HUUFF#'#<#s1vv F FI )33"O16>&/#A#A3q66$3$<#A#A4 % VV//((**++++++ sB%D?? G; B'G66G;ctjd}|r|j|z |dz }n|jdz |dz }|jddg}|r|d|n|d|d|d tjd |r|d ||r5|D] \}} |d |d | !|d|d|d|||d |t||dS)zSave content to local files. %Y%m%d_%H%M%Sz.mdmiscTparentsexist_okz# z# Delivery Outputz**Timestamp:** z%Y-%m-%d %H:%M:%Sz **Job ID:** z**z:** z--- )path timestamp) rnowstrftimerkparentmkdirappenditems write_textjoinr2) rZr rnrorpr output_pathlineskeyr$s rryzDeliveryRouter._deliver_localAsLNN++O<<  G/F2 5F5F5FFKK/F2 5F5F5FFK   ===  . LLh ) ) ) ) LL, - - - R Ux|~~'>'>?R'S'SUUVVV  2 LL000 1 1 1  4&nn.. 4 4 U 2#225223333 R U R Wtyy//000 $$"   rctjd}tdz dz }|dd||d|dz }|||S)z7Save full cron output to disk and return the file path.rrirjTr_z.txt)rrrr rr)rZr rnrout_dirrs r_save_full_outputz DeliveryRouter._save_full_outputosxLNN++O<< !##f,x7 dT 222F44Y4444     rctjd}|(|dvSt t |jddS)zWhether the outbound silence-narration filter is active. ``HERMES_FILTER_SILENCE_NARRATION`` env var overrides config when set; otherwise the ``gateway.filter_silence_narration`` config flag wins (default True). HERMES_FILTER_SILENCE_NARRATIONN)1trueyesonfilter_silence_narrationT)osgetenvrr6rr-re)rZenvs r!_filter_silence_narration_enabledz0DeliveryRouter._filter_silence_narration_enabledxsVi9:: ?99;;$$&&*DD DGDK)CTJJKKKrrKcK|j|j}|std|jj|jstd|jjd|pidd}d}t |tkr |||}nA#t$r4}t dt |||Yd}~nd}~wwxYwt|dd r,|r)t d t ||ny||||}d |d }td tt |z } t dt |||d| |z}|rIt!|r:t d|jj|j|ddddd dSt#|pi} d } d} |jr2d| vpd| v} |j}|jt&jko.t+|jot-| o d| vod| vo| } | rj|} t|dd}|t/d||j|d{V}|st/d|dt1|}|| d<d| d<ns|jt&jkrOt+|jr;d| vr7d| vr3| s1| d}|t/d|| d<d| d<nd| vr d| vr| s|| d<||j|| pd d{V}t5|r| r| rt7|rt|dd}|t/d!||j| d"d{V}|st/d#| dt1|| d<d| d<||j|| pd d{V}t5|r+t/t9|p|jjd$|S)%z(Deliver content to a messaging platform.zNo adapter configured for zNo chat ID for z deliveryrnunknownNuaAudit save failed for cron output (%d chars, job=%s): %s — delivery proceeds without audit copysplits_long_messagesFuQCron output preserved for chunking adapter (%d chars) — full output saved to %sz' ... [truncated, full output saved to ]ru4Cron output truncated (%d chars) — full output: %sz6Dropped silence-narration outbound to %s (chat=%s): %r(Tsilence_narration)r)filtered delivereddirect_messages_topic_id!telegram_direct_messages_topic_idrHmessage_thread_idensure_dm_topicz6Telegram adapter cannot create named private DM topicsz,Failed to create Telegram private DM topic ''"telegram_dm_topic_created_for_sendtelegram_reply_to_message_idzyTelegram private DM topic delivery requires telegram_reply_to_message_id; send to the bare chat or provide a reply anchor telegram_dm_topic_reply_fallback)rpz7Telegram adapter cannot refresh named private DM topics) force_createz-Failed to refresh Telegram private DM topic 'z delivery failed)rfr,rGr"r$rrMAX_PLATFORM_OUTPUTrOSErrorrwwarningr-rxmaxrrr+rHrTELEGRAMr#r& RuntimeErrorr2sendr.r7r4)rZrKr rpadapterrn saved_pathexcfootervisible send_metadatais_named_telegram_private_topic!named_telegram_private_topic_namehas_explicit_direct_topictarget_thread_idrcreated_thread_id reply_anchorr'refreshed_thread_ids rrzz#DeliveryRouter._deliver_to_platforms -##FO44 SQ&/:OQQRR R~ QOv/DOOOPP P.b%%h ::%) w<<- - -  !33GVDD    ;LL&# w 6>> 5KK2G j%!%!7!7!H!HJRZRRRa!4s6{{!BCC JLL*"(7(+f4  1 1 3 3 8Mg8V8V  NNH%     /"  X^,, */';?)  1 >*m;H6-G & &/ 8#4427GG2'(89992 }42(}< 2 21 ,/# >4D1")'3Dd"K"K"*&P+:/&.JZ*[*[$[$[$[$[$[$[!(&ZGWZZZ$''8#9#9 -= k*FJ BCC8#4447GG5}44'}<<1= -001OPP '&J.> k*DH @AAM116IQ^6^6^hA6^-= k*||FNGmF[W[|\\\\\\\\ v & & m/ e5 e8?? e #*'3Dd"K"K"*&Q-BAA}AXs]8KA'(:;AAAA(!%"&-1 IIIn%I I 3- I 4S>* I c3hIIIIV, ,  , 3- , 4S>* , c3h , , , , \cd L4 L L L Leee4S>* e c3h eeeeeerrd)*r_loggingrrepathlibrr dataclassesrtypingrrrr hermes_cli.configr getLoggerr\rwrcompile IGNORECASErr2rrrerrsessionrrgrr#r&r.r4r7r;rDrFrdrbrrrs !!!!!!,,,,,,,,,,,,------  8 $ $ RZ2M 48C= 4T 4 4 4 4,+++++++"""""",,,,,, # 4     8C=T555555 )s)x}))))?????? 'C'HSM''''x}#2 M#M#M#M#M#M#M# M#`KKKKKKKKKKr