j!AdZddlZddlZddlZddlmZddlmZddlmZddl m Z m Z m Z m Z ddlmZejeZdZd Zejd ejZd e ed efd ZddlmZmZddlmZde ed efdZ de ed efdZ!de d efdZ"de d e efdZ#de d 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_homeiizv^[\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 5/home/ubuntu/.hermes/hermes-agent/gateway/delivery.py_is_silence_narrationr&sX u}}H s8}}r))u "((22 3 33)Platform GatewayConfig) SessionSourcechat_idcb|dS t|dkS#ttf$rYdSwxYw)NFrint TypeError ValueError)rs r$_looks_like_telegram_private_chat_idr"8sIu7||a z "uus ..valuec^|dS t|dS#ttf$rYdSwxYw)NFTr)r#s r_looks_like_intr%AsH }u E t z "uus ,,resultct|tr|dduSt|ddduS)NsuccessFT) isinstancedictgetgetattr)r&s r_send_result_failedr-KsB&$.zz)$$-- 69d + +u 44rct|tr|d}nt|dd}|rt |ndS)Nerror)r)r*r+r,strr&r/s r_send_result_errorr2QsM&$/ 7##.. (3u:::D(rcjt|}t|od|vS)Nzthread not found)r2rlowerr1s r#_is_thread_not_found_delivery_errorr5Ys0 v & &E =, = > >>rceZdZUdZeed<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 r=T)r8rr9r:)r8r:local)r8:rrN)r8rr9r;) rr4r8rr9rLOCALsplitrr!) clsr<r=target_stripped target_lowerparts platform_strrr9r8s rparsezDeliveryTarget.parseos!,,..&,,.. 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.r=r?r@)r:r8rrBrr9r#)selfs r to_stringzDeliveryTarget.to_strings > 8 =HN * *7 < LDN Lm)KKDLKK4>KK K < ;m)::DL:: :}""rN)__name__ __module__ __qualname____doc__r__annotations__rrr0r9r:rr; classmethodrrIrLrrr7r7^s!GXc]!!!#Ix}###ItK0000300(?00K[000000[00d #3 # # # # # #rr7cpeZdZdZddedeeeffdZ 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 effdZdS)DeliveryRouterz Routes messages to appropriate destinations. Handles the logic of resolving delivery targets and dispatching messages to the right platform adapters. NconfigadapterscX||_|pi|_tdz dz |_dS)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__s1  B )++f4x?rr targetsjob_idjob_namemetadatar c`Ki}|D]} |jtjkr|||||}n||||d{V}d|d||<i#t $r1} 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 NT)r(r&F)r(r/)r8rrB_deliver_local_deliver_to_platformrL Exceptionr0) rKr r^r_r`raresultsr<r&es rdeliverzDeliveryRouter.delivers*  F ?hn44!00&(HUUFF#'#<#'>?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.rjrZr[Trl_z.txt)rrsrtr rvry)rKr r_rrout_dirrqs r_save_full_outputz DeliveryRouter._save_full_outputsxLNN++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)osgetenvrr4rr,rW)rKenvs r!_filter_silence_narration_enabledz0DeliveryRouter._filter_silence_narration_enabled$sVi9:: ?99;;$$&&*DD DGDK)CTJJKKKrr<cHK|j|j}|std|jj|jstd|jjdt |tkrm|pidd}|||}t dt |||dtd|d z}| rIt|r:td |jj|j|dd d d ddSt|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| dt/| } | |d<d |d<ns|jt"jkrOt'|jr;d|vr7d|vr3| s1|d}|t-d| |d<d |d<nd|vr d|vr| s| |d<||j||pdd{V}t3|r|r| rt5|rt+|dd} | t-d| |j| d d{V}|st-d| dt/||d<d |d<||j||pdd{V}t3|r+t-t7|p|jjd |S)!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#-##FO44 SQ&/:OQQRR R~ QOv/DOOOPP P w<<- - -n"))(I>>F//@@J KKNPST[P\P\^h i i i***+KjKKKL   1 1 3 3 8Mg8V8V  NNH%     /"  X^,, */';?)  1 >*m;H6-G & &/ 8#4428HH2'(89992 }42(}< 2 21 ,/# >4D1")'3Dd"K"K"*&P+:/&.JZ*[*[$[$[$[$[$[$[!(&ZGWZZZ$''8#9#9 -= k*FJ BCC8#4448HH5}44'}<<1= -001OPP '&J.> k*DH @AAM116IQ^6^6^hA6^-= k*||FNGmF[W[|\\\\\\\\ v & & m/ e5 e8?? e #*'3Dd"K"K"*&Q-* ( c3h((((T, ,  , 3- , 4S>* , c3h , , , , \cd L4 L L L L}}}4S>* } c3h }}}}}}rrV)'rQloggingrrepathlibrr dataclassesrtypingrrrr hermes_cli.configr getLoggerrNrrrcompile IGNORECASErr0rrrWrrsessionrr"r%r-r2r5r7rVrTrrrsW !!!!!!,,,,,,,,,,,,------  8 $ $ RZ2M 48C= 4T 4 4 4 4,+++++++""""""(3-D8C=T555555 )s)x}))))??????  M#M#M#M#M#M#M# M#`~~~~~~~~~~r