`gjZdZddlZddlZddlZddlmZddlmZddlmZddl m Z m Z m Z m Z ddlmZej eZdZej(d ej*Zd 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)y) 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|sy|j}|rt|dkDryttj |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 C/root/.hermes/venv/lib/python3.12/site-packages/gateway/delivery.py_is_silence_narrationr+s= }}H s8}r) "((2 33)Platform GatewayConfig) SessionSource)DeadTargetRegistrychat_idcP|y t|dkDS#ttf$rYywxYw)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. Frint TypeError ValueError)rs r#looks_like_telegram_private_chat_idr#>s77|a z "s %%valuecL|y t|y#ttf$rYywxYw)NFTr)r$s r_looks_like_intr&Ns0 } E  z "s ##resultcft|tr|jdduSt|ddduS)NsuccessFT) isinstancedictgetgetattr)r's r_send_result_failedr.Xs4&$zz)$-- 69d +u 44rc~t|tr|jd}n t|dd}|r t |SdS)Nerrorr*r+r,r-strr'r0s r_send_result_errorr4^s9&$ 7#.3u:(D(rcVt|}t|xrd|jvS)Nzthread not found)r4rlowerr3s r#_is_thread_not_found_delivery_errorr7fs( v &E =, = >>rc~t|tr|jd}n t|dd}|r t |SdS)zFReturn the machine-readable error_kind from a SendResult/dict, if any. error_kindNr1)r'kinds r_send_result_error_kindr;ks9&$zz,'v|T23t9&$&r error_textc|sy ddlm}m}|d|}t j |sy|dk(r ||sy|S#t$rYywxYw)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_ P t ;D  0 0 6  {#:j#Q K s> A  A ceZdZUdZeed<dZeeed<dZ eeed<dZ e ed<dZ e ed<e dd ed eed dfd Zd efd Zy)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|j}|j}|dk(rD|r*||j|j|jdS|t j dS|dk(r|t j Sd|vrg|jdd}|d j}t|d kDr|d nd }t|dkDr|dnd } t |} || ||d S t |} || S#t$r|t j cYSwxYw#t$r|t j cYSwxYw) 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.parsesI!,,.&,,. 8 ##__"NN$.." HNNdCC 7 "/ / / !#))#q1E 8>>+L"%e*q.eAhdG$'JNaI 4#L1Hg`dee  0 -H) ) 4HNN33 4 0/ / 0s$D2D, D)(D), EEcz|jry|jtjk(ry|jr>|j r2|jj d|jd|j S|jr%|jj d|jS|jj S)zConvert back to string format.rLrNrO)rIrGrrQrrHr$)selfs r to_stringzDeliveryTarget.to_strings >> ==HNN * <4>>:JK K <<mm))*!DLL>: :}}"""r)N)__name__ __module__ __qualname____doc__r__annotations__rrr2rHrIrrJ classmethodrrXr[rrrFrFsy!GXc]!#Ix}#ItK00300(?00K[0000d #3 #rrFc"eZdZdZ 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 effdZy)DeliveryRouterz Routes messages to appropriate destinations. Handles the logic of resolving delivery targets and dispatching messages to the right platform adapters. Nconfigadapters dead_targetscx||_|xsi|_tdz dz |_|xs t |_y)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__s;  B )+f4x?(@,>,@rr targetsjob_idjob_namemetadatar c vKi}|D]h}|jtjk7r|jr|jj |jj |jrMtjd|jj |jdddd||j< |jtjk(r|j||||}nl|j|||d{}|jrEt|s:|jj|jj |jd|d||j<k|S7p#t$r} |jtjk7ro|jrctt!| } | rM|jj#|jj |j| d t!| dd  dt!| d ||j<Yd} ~ *d} ~ wwxYww) 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.delivers*0 F8>>1NN%%--foo.C.CV^^T 2OO))6>> %,F/((*+  ??hnn4!00&(HUF#'#<#s1v FI ))33"OO116>>&/[3q6$3<.#A4 % V/((*+ sEB9H9'>?R'S&TUV  LL<x0 1 &nn. 4 U r#d5'23 4  R U R Wtyy/0 $"  rctjjd}tdz dz }|j dd||d|dz }|j ||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_outputosbLLN++O< !#f,x7 dT 2F81YKt44   rctjd}| |jjdvSt t |j ddS)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_NARRATION)1trueyesonfilter_silence_narrationT)osgetenvrr6rr-re)rZenvs r!_filter_silence_narration_enabledz0DeliveryRouter._filter_silence_narration_enabledxsLii9: ?99;$$&*DD DGDKK)CTJKKrrKcK|jj|j}|s"td|jj|j s#td|jjd|xsijdd}d}t |tkDr |j||}t|dd r#|rtjd t ||n^||j||}d |d }td tt |z } tjdt |||d| |z}|jrJt!|r?tjd|jj|j |ddddd dSt#|xsi} d } d} |j$r=d| vxsd| v} |j$}|jt&j(k(xr4t+|j xrt-| xrd| vxr d| vxr| } | r^|} t|dd}| t/d||j |d{}|st/d|dt1|}|| d<d| d<nt|jt&j(k(rHt+|j r3d| vr/d| vr+| s)| jd}| t/d|| d<d| d<nd| vr d| vr| s|| d<|j3|j || xsd d{}t5|r| r| rt7|rt|dd}| t/d!||j | d"d{}|st/d#| dt1|| d<d| d<|j3|j || xsd d{}t5|r/t/t9|xs|jjd$|S#t$r,}tjdt |||Yd}~zd}~wwxYw7777w)%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--##FOO49&//:O:O9PQR R~~v/D/D.EYOP P.b%%h :%) w<- -  !33GVD w 6>KK2G j%!%!7!7!HJDZLPQRa!4s6{!BC JL*"(7+f4  1 1 38Mg8V NNH%%   /"  X^, */';?)   *m;H6-G & &// 8#4#4427G2'(8992 }42(}< 2 21 ,/4D1")'3Dd"K"*&P+:&..JZ*[$[!(&FGWFXXYZ$''8#9 -= k*FJ BC8#4#447G}4'}<1 -001OP '&J.> k*DH @AM16IQ^6^hA-= k*||FNNGmF[W[|\\ v &/57?")'3Dd"K"*&Q-<NN5!%-'# +&GHiGjjkl.11D-E k*FJ BC&||FNNGmNc_c|dd"6*"#5f#=#kFOODYDYCZZjAkll E ;L&# V%\:]'eswB#Q&P8F%QP:CQ"P=#AQ3Q4A QQAQ P7 !P2,Q2P77Q=QQQ)NN)NNN)r\r]r^r_rrrr rrrlr2rrFrryrrrrrzrbrrrdrdssOS>BA}AXs]8KA'(:;A(!%"&-1 IIn%I I 3- I 4S>* I c3hIV, ,  , 3- , 4S>* , c3h , \cd L4 Leee4S>* e c3h errd)*r_loggingrrepathlibrr dataclassesrtypingrrrr hermes_cli.configr getLoggerr\rwrcompile IGNORECASErr2rrrerrsessionrrgrr#r&r.r4r7r;rDrFrdrbrrrsH !,,-   8 $ RZZ2MM 48C= 4T 4,", # 4  8C=T555 )s)x})??? 'C'HSM'x}#2 M#M# M#`KKr