ie!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)clsrrparts platform_strrrrs 8/home/agentuser/.hermes/hermes-agent/gateway/delivery.pyparsezDeliveryTarget.parse-s%%'' X   Ds#_"N$." sHNdCCCC W  3/// / &==LLa((E 8L"%e**q..eAhhdG$'JJNNaI 4#L11sHg`deeee 4 4 4sHN333333 4  0''H3))) ) 0 0 03/// / / / 0s$C;; DD"D== E E c|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}###ItK.0.03.0(?.0K[.0.0.0[.0` #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)r9r:r output_dir)r*r9r:s r&__init__zDeliveryRouter.__init__ss1  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)rFerror)rr r_deliver_local_deliver_to_platformr+ Exceptionr3) r*r@rArBrCrDresultsrrGes r&deliverzDeliveryRouter.delivers*  F ?hn44!00&(HUUFF#'#<#parentmkdirappenditems write_textjoinr3) r*r@rBrCrDrX output_pathlineskeyr)s r&rIzDeliveryRouter._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//000 $$"   r,ctjd}tdz dz }|dd||d|dz }|||S)z7Save full cron output to disk and return the file path.rPr<r=TrR_z.txt)rrYrZr r\r_)r*r@rBrXout_dirrWs 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 deliveryrBunknownu4Cron output truncated (%d chars) — full output: %sNz' ... [truncated, full output saved to ]r)rD)r:getrr"r)rr!MAX_PLATFORM_OUTPUTrgloggerinfoTRUNCATED_VISIBLEdictrsend)r*rr@rDadapterrB saved_path send_metadatas r&rJz#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)r.r/r0r1r rr r r?r3rrrrNrIrrgrJr6r,r&r8r8ks @ @} @Xs]8K @ @ @ @ !%"&-1 (((n%( ( 3- ( 4S>* ( c3h((((T, ,  , 3- , 4S>* , c3h , , , , \cd[[[4S>* [ c3h [[[[[[r,r8)r1loggingpathlibrr dataclassesrtypingrrrr hermes_cli.configr getLoggerr.rmrlror9r r sessionrrr8r6r,r&r|sQ!!!!!!,,,,,,,,,,,,------  8 $ $++++++++"""""" K#K#K#K#K#K#K# K#\Q[Q[Q[Q[Q[Q[Q[Q[Q[Q[r,