j!AdZddlZddlZddlZddlmZddlmZddlmZddl m Z m Z m Z m Z ddlmZej eZdZd Zej*d ej,Zd e ed efd ZddlmZmZddlmZde ed efdZ de ed efdZ!de d efdZ"de d e efdZ#de d 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_homeiizv^[\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 O/home/cube/projects/richard/.worktrees/nutricoach-v140-impl/gateway/delivery.py_is_silence_narrationr&s= }}H s8}r) "((2 33)Platform GatewayConfig) SessionSourcechat_idcP|y t|dkDS#ttf$rYywxYw)NFrint TypeError ValueError)rs r$_looks_like_telegram_private_chat_idr"8s57|a z "s %%valuecL|y t|y#ttf$rYywxYw)NFTr)r#s r_looks_like_intr%As0 } E  z "s ##resultcft|tr|jdduSt|ddduS)NsuccessFT) isinstancedictgetgetattr)r&s r_send_result_failedr-Ks4&$zz)$-- 69d +u 44rc~t|tr|jd}n t|dd}|r t |SdS)Nerror)r)r*r+r,strr&r/s r_send_result_errorr2Qs9&$ 7#.3u:(D(rcVt|}t|xrd|jvS)Nzthread not found)r2rlowerr1s r#_is_thread_not_found_delivery_errorr5Ys( v &E =, = >>rceZdZUdZeed<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 r=T)r8rr9r:)r8r:local)r8:rrN)r8rr9r;) rr4r8rr9rLOCALsplitrr!) clsr<r=target_stripped target_lowerparts platform_strrr9r8s rparsezDeliveryTarget.parseosI!,,.&,,. 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.r=r?r@)r:r8rrBrr9r#)selfs r to_stringzDeliveryTarget.to_strings >> ==HNN * <4>>:JK K <<mm))*!DLL>: :}}"""rN)__name__ __module__ __qualname____doc__r__annotations__rrr0r9r:rr; classmethodrrIrLrrr7r7^sy!GXc]!#Ix}#ItK00300(?00K[0000d #3 #rr7ceZdZdZddedeeeffdZ dde de e de e d e e d e ee efd ee eff d Z de de e d e e d e ee efd ee eff d Zde de d efdZd efdZde de d e ee efd ee effdZy)DeliveryRouterz Routes messages to appropriate destinations. Handles the logic of resolving delivery targets and dispatching messages to the right platform adapters. NconfigadapterscR||_|xsi|_tdz dz |_y)z Initialize the delivery router. Args: config: Gateway configuration adapters: Dict mapping platforms to their adapter instances cronoutputN)rWrXr output_dir)rKrWrXs r__init__zDeliveryRouter.__init__s*  B )+f4x?rr targetsjob_idjob_namemetadatar cVKi}|D]f} |jtjk(r|j||||}n|j |||d{}d|d||j <h|S7#t $r)} 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 NT)r(r&F)r(r/)r8rrB_deliver_local_deliver_to_platformrL Exceptionr0) rKr r^r_r`raresultsr<r&es rdeliverzDeliveryRouter.delivers*F ??hnn4!00&(HUF#'#<#'>?R'S&TUV  LL<x0 1 &nn. U r#d5'23/  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.rjrZr[Trl_z.txt)rrsrtr rvry)rKr r_rrout_dirrqs r_save_full_outputz DeliveryRouter._save_full_outputsbLLN++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)osgetenvrr4rr,rW)rKenvs r!_filter_silence_narration_enabledz0DeliveryRouter._filter_silence_narration_enabled$sLii9: ?99;$$&*DD DGDKK)CTJKKrr<cXK|jj|j}|s"td|jj|j s#td|jjdt |tkDrX|xsijdd}|j||}tjdt |||dtd|d z}|jrJt|r?tjd |jj|j |dd d d ddSt|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| dt/| } | |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<|j1|j ||xsdd{}t3|r|r| rt5|rt+|dd} | t-d| |j | d d{}|st-d| dt/||d<d |d<|j1|j ||xsdd{}t3|r/t-t7|xs|jjd |S7777Gw)!z(Deliver content to a messaging platform.zNo adapter configured for zNo chat ID for z deliveryr_unknownu4Cron output truncated (%d chars) — full output: %sNz' ... [truncated, full output saved to ]z6Dropped silence-narration outbound to %s (chat=%s): %r(Tsilence_narrationF)r(filtered delivereddirect_messages_topic_id!telegram_direct_messages_topic_idr9message_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)raz7Telegram adapter cannot refresh named private DM topics) force_createz-Failed to refresh Telegram private DM topic 'z delivery failed)rXr+r8r!r#rrMAX_PLATFORM_OUTPUTrloggerinfoTRUNCATED_VISIBLErrwarningr*r9rTELEGRAMr"r%r, RuntimeErrorr0sendr-r5r2)rKr<r raadapterr_ saved_path send_metadatais_named_telegram_private_topic!named_telegram_private_topic_namehas_explicit_direct_topictarget_thread_idrcreated_thread_id reply_anchorr&refreshed_thread_ids rrdz#DeliveryRouter._deliver_to_platform0s---##FOO49&//:O:O9PQR R~~v/D/D.EYOP P w<- -n"))(I>F//@J KKNPST[P\^h i**+=j\KL   1 1 38Mg8V NNH%%   /"  X^, */';?)   *m;H6-G & &// 8#4#4428H2'(8992 }42(}< 2 21 ,/4D1")'3Dd"K"*&P+:&..JZ*[$[!(&FGWFXXYZ$''8#9 -= k*FJ BC8#4#448H}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 o%\:]'esLG:N*<N!=CN*N$AN*N&A N* N(!AN*$N*&N*(N*rM)NNN)rNrOrPrQrrrr r]r0rr7rrhrcrrrrrdrTrrrVrVsS @} @Xs]8K @ !%"&-1 ((n%( ( 3- ( 4S>* ( c3h(T, ,  , 3- , 4S>* , c3h , \cd L4 L}}}4S>* } c3h }rrV)'rQloggingrrepathlibrr dataclassesrtypingrrrr hermes_cli.configr getLoggerrNrrrcompile IGNORECASErr0rrrWrrsessionrr"r%r-r2r5r7rVrTrrrs !,,-   8 $ RZZ2MM 48C= 4T 4,"(3-D8C=T555 )s)x})???  M#M# M#`~~r