Tdjf |dZddlZddlZddlZddlmZddlmZddlmZddl m Z m Z m Z m Z ddlmZejeZdZejd ejZd e ed efd Zd dlmZmZmZd dlmZd dl m!Z!edGddZ"dedede e ee fd e e"fdZ#de ed efdZ$de ed efdZ%de d efdZ&de d e efdZ'de d efd Z(de d e efd!Z)d"e ed e efd#Z*eGd$d%Z+Gd&d'Z,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/thesage/.hermes/hermes-agent/gateway/delivery.py_is_silence_narrationr+sX u}}H s8}}r))u "((22 3 33)Platform GatewayConfigPlatformConfig) SessionSource)DeadTargetRegistryT)frozenc eZdZUdZeed<eeed<eed<e de fdZ dede d e d ee e efdef d Zd S) DeliveryTransportz:Resolved live transport for one logical delivery platform.adapterconfigtransport_platformr c,|jtjkSN)r#rRELAYselfs ris_relayzDeliveryTransport.is_relayFs&(.88rlogical_platformchat_idr metadatacK|jr$|j||||d{VS|j|||d{VS)zBSend through this transport while preserving the logical platform.r,N)r)r!send_for_platformsend)r(r*r+r r,s rr0zDeliveryTransport.sendJs = 77 ! 8  \&&w(&KKKKKKKKKrN)__name__ __module__ __qualname____doc__r __annotations__rrrpropertyrr)strrr0rrr r >sDD LLL ^ $$$$     9$999X9L"LL L 4S>* L LLLLLLrr platformr"adaptersc|pi}||}|j|}|||jrt|||S|tj}|jtj}t |dd}|?||jr6t|r'||rt||tjSdS)adResolve a logical platform to its live delivery transport. A concrete native adapter always wins. Relay is eligible only when its authenticated transport explicitly advertises that it fronts the logical platform, which keeps restart-time delivery independent of per-chat caches without letting Relay hijack unrelated platform targets. N)r!r"r#fronts_platform)get platformsenabledr rr&getattrcallable) r9r"r: live_adaptersnative native_configrelay relay_configr<s rresolve_delivery_transportrG\s NM   x ( (F$((22M}4 8M4  '      hn - -E#''77Le%6==O   !\%9 ! _ % %" OH % %"!'~    4rr+cb|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)r+s r#looks_like_telegram_private_chat_idrMsKu7||a z "uus ..valuec^|dS t|dS#ttf$rYdSwxYw)NFTrI)rNs r_looks_like_intrPsH }u E t z "uus ,,resultct|tr|dduSt|ddduS)NsuccessFT) isinstancedictr=r@)rQs r_send_result_failedrVsB&$.zz)$$-- 69d + +u 44rct|tr|d}nt|dd}|rt |ndS)NerrorrTrUr=r@r7rQrXs r_send_result_errorr[sM&$/ 7##.. (3u:::D(rcjt|}t|od|vS)Nzthread not found)r[rlowerrZs r#_is_thread_not_found_delivery_errorr^s0 v & &E =, = > >>rct|tr|d}nt|dd}|rt |ndS)zFReturn the machine-readable error_kind from a SendResult/dict, if any. error_kindNrY)rQkinds r_send_result_error_kindrbsM&$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)rc not_found)platforms.basererf Exceptionris_dead_error_kind)rcrerfras r_classify_dead_from_error_textrks 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 r9Nr+ 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 rrT)r9r+rnro)r9rolocal)r9:rrN)r9r+rnrp) rr]r9r+rnrLOCALsplitrrL) clsrqrrtarget_stripped target_lowerparts platform_strr+rnr9s 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.rrrtru)ror9rrwr+rnrNr's r to_stringzDeliveryTarget.to_strings > 8 =HN * *7 < LDN Lm)KKDLKK4>KK K < ;m)::DL:: :}""rr%)r1r2r3r4rr5r+rr7rnrorrp classmethodrr~rr8rrrmrms!GXc]!!!#Ix}###ItK0000300(?00K[000000[00d #3 # # # # # #rrmceZdZdZ 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. Nr"r: 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)r"r:r output_dirrr)r(r"r:rs r__init__zDeliveryRouter.__init__.sG  B )++f4x?(@,>,@,@rr targetsjob_idjob_namer,r 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)rSskippedrXNT)rSrQz: x)reason)rSrX)r9rrwr+ris_deadrNloggerinfor_deliver_local_deliver_to_platformrVclearrirkr7 mark_dead) r(r rrrr,resultsrqrQe dead_kinds rdeliverzDeliveryRouter.deliver>sK*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 |dt||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--- utf-8encoding)path timestamp) rnowstrftimerparentmkdirappenditems write_textjoinr7) r(r rrr,r output_pathlineskeyrNs rrzDeliveryRouter._deliver_localsLNN++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//'BBB $$"   rctjd}tdz dz }|dd||d|dz }||d |S) z7Save full cron output to disk and return the file path.rrrTr_z.txtrr)rrrr rr)r(r rrout_dirrs r_save_full_outputz DeliveryRouter._save_full_outputs|LNN++O<< !##f,x7 dT 222F44Y4444 '222 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)osgetenvrr]rr@r")r(envs r!_filter_silence_narration_enabledz0DeliveryRouter._filter_silence_narration_enabledsVi9:: ?99;;$$&&*DD DGDK)CTJJKKKrrqc Kt|j|j|j}|t d|jj|j}|jst d|jjd|pidd}d}t|tkr | ||}nA#t$r4}tdt|||Yd}~nd}~wwxYwt|dd r,|r)td t||ny|| ||}d |d } t#d tt| z } tdt|||d| | z}|rIt'|r:td|jj|j|ddddd dSt)|pi} |jrS|j|j} | 2| j|jkr"| jr | j| d<| jr | j| d<d } d}|jr2d| vpd| v}|j}|jt4jko.t9|jot;| o d| vod| vo| } | rj|}t|dd}|t=d||j|d{V}|st=d|dt?|}|| d<d| d<ns|jt4jkrOt9|jr;d| vr7d| vr3|s1| d}|t=d || d<d| d!<nd| vr d| vr|s|| d<| |j|j|| pd"d{V}tC|r| r|rtE|rt|dd}|t=d#||j|d$d{V}|st=d%|dt?|| d<d| d<| |j|j|| pd"d{V}tC|r+t=tG|p|jjd&|S)'z(Deliver content to a messaging platform.NzNo adapter configured for zNo chat ID for z deliveryrunknownuaAudit 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)rSfiltered delivereduser_idscope_iddirect_messages_topic_id!telegram_direct_messages_topic_idrnmessage_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_fallbackr.z7Telegram adapter cannot refresh named private DM topics) force_createz-Failed to refresh Telegram private DM topic 'z delivery failed)$rGr9r"r:rLrNr!r+r=rMAX_PLATFORM_OUTPUTrOSErrorrwarningr@rmaxrrrUr)get_home_channelrrrnrTELEGRAMrMrP RuntimeErrorr7r0rVr^r[)r(rqr r, transportr!r saved_pathexcfootervisible send_metadatahomeis_named_telegram_private_topic!named_telegram_private_topic_namehas_explicit_direct_topictarget_thread_idrcreated_thread_id reply_anchorrQrefreshed_thread_ids rrz#DeliveryRouter._deliver_to_platforms/v T][[  Q&/: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^,,   >;//@@DDLFN$B$B<04 M*-*/';?)  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* ~~ O N "*d &         v & & m/ 5 8??  #*'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 Lvvv4S>* v c3h vvvvvvrr)-r4loggingrrepathlibrr dataclassesrtypingrrrr hermes_cli.configr getLoggerr1rrcompile IGNORECASErr7rrr"rrrsessionrrrr rGrMrPrVr[r^rbrkrmrr8rrrsR !!!!!!,,,,,,,,,,,,------  8 $ $ RZ2M 48C= 4T 4 4 4 4<;;;;;;;;;"""""",,,,,, $LLLLLLLL:'' 'tHcM*+' ''''T # 4     8C=T555555 )s)x}))))?????? 'C'HSM''''x}#2 M#M#M#M#M#M#M# M#`\\\\\\\\\\r