i="dZddlZddlmZddlmZddlmZddlmZm Z m Z m Z ddl m Z ejeZdZd Zd d lmZmZd d lmZeGd dZGddZdS)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_homeii)Platform GatewayConfig) SessionSourceceZdZUdZeed<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 platformNchat_id thread_idF is_origin is_explicittargetoriginreturnc|}|}|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 rT)rrrr)rrlocal)r:rr N)rrrr) striplowerrrrr LOCALsplitlen ValueError) clsrrtarget_stripped target_lowerparts platform_strrrrs 5/home/ubuntu/.hermes/hermes-agent/gateway/delivery.pyparsezDeliveryTarget.parse-s!,,..&,,.. 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.rrr)rrr rrrvalue)selfs r( to_stringzDeliveryTarget.to_string`s > 8 =HN * *7 < LDN Lm)KKDLKK4>KK K < ;m)::DL:: :}""N)__name__ __module__ __qualname____doc__r __annotations__rrstrrrboolr classmethodrr)r-r.r(rrs!GXc]!!!#Ix}###ItK0000300(?00K[000000[00d #3 # # # # # #r.rcdeZdZdZddedeeeffdZ 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 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)r;r<r output_dir)r,r;r<s r(__init__zDeliveryRouter.__init__us1  B )++f4x?r.contenttargetsjob_idjob_namemetadatarc`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)successresultF)rHerror)rr r_deliver_local_deliver_to_platformr- Exceptionr5) r,rBrCrDrErFresultsrrIes r(deliverzDeliveryRouter.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 $$"   r.ctjd}tdz dz }|dd||d|dz }|||S)z7Save full cron output to disk and return the file path.rRr>r?TrT_z.txt)rr[r\r r^ra)r,rBrDrZout_dirrYs r(_save_full_outputz DeliveryRouter._save_full_outputsxLNN++O<< !##f,x7 dT 222F44Y4444     r.rchK|j|j}|std|jj|jstd|jjdt |tkrm|pidd}|||}t dt |||dtd|d z}t|pi}|j rd |vr |j |d <||j||pd d{VS) z(Deliver content to a messaging platform.zNo adapter configured for zNo chat ID for z deliveryrDunknownu4Cron output truncated (%d chars) — full output: %sNz' ... [truncated, full output saved to ]r)rF)r<getrr"r+rr!MAX_PLATFORM_OUTPUTriloggerinfoTRUNCATED_VISIBLEdictrsend)r,rrBrFadapterrD saved_path send_metadatas r(rLz#DeliveryRouter._deliver_to_platformsa-##FO44 SQ&/:OQQRR R~ QOv/DOOOPP P w<<- - -n"))(I>>F//@@J KKNPST[P\P\^h i i i***+KjKKKL  X^,,   : = @ @)/)9M+ &\\&.'MDYUY\ZZZZZZZZZr.r/)NNN)r0r1r2r3r rr r rAr5rrrrPrKrrirLr8r.r(r:r:ms @ @} @Xs]8K @ @ @ @ !%"&-1 (((n%( ( 3- ( 4S>* ( c3h((((T, ,  , 3- , 4S>* , c3h , , , , \cd[[[4S>* [ c3h [[[[[[r.r:)r3loggingpathlibrr dataclassesrtypingrrrr hermes_cli.configr getLoggerr0rornrqr;r r sessionrrr:r8r.r(r~sQ!!!!!!,,,,,,,,,,,,------  8 $ $++++++++"""""" M#M#M#M#M#M#M# M#`Q[Q[Q[Q[Q[Q[Q[Q[Q[Q[r.