+ i-Rt^RIt^RIHt^RIHt^RIHt^RIHtH t H t H t H t ^RI Ht]P!]4tRtRt^R IHtHt^R IHt]!R R 44t!R R4tRRRlltRRRlltR#)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)DictListOptionalAnyUnion)get_hermes_homeii)Platform GatewayConfig) SessionSourcecra]tRt^toRtRtRtRtRt] R V3RlRll4t V3RlRlt V3Rlt R t VtR#) 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 NFc:<V^8dQhRS[RS[S[,RR/#)targetoriginreturnr)strrr )format __classdict__s"-/home/ubuntu/hermes-agent/gateway/delivery.py __annotate__DeliveryTarget.__annotate__.s(.0.03.0(?.0K[.0c VP4P4pVR8XdKV'd+V!VPVPVPRR7#V!\ P RR7#VR8XdV!\ P R7#RV9diVPR^4pV^,p\V4^8d V^,MRp\V4^8d V^,MRp\ V4pV!WuVRR 7#\ V4pV!VR7# \dT!\ P R7u#i;i \dT!\ P R7u#i;i) 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)platformchat_id thread_id is_origin)rr localr:N)rrr is_explicit) striplowerrrrr LOCALsplitlen ValueError)clsrrparts platform_strrrrs&&& rparseDeliveryTarget.parse-s8%%' X #__"NN$.." HNNdCC W / / &=LLa(E 8L"%e*q.eAhdG$'JNaI 4#L1H`dee  0'H) ) 4HNN33 4 0/ / 0s$'D>D:"D76D7:"EEc <V^8dQhRS[/#)rr)r)rrs"rrr^s # #3 #rc VP'dR#VP\P8XdR#VP'dEVP 'd3VPP RVP RVP 2#VP'd&VPP RVP 2#VPP #)zConvert back to string format.rr!r#)r rr r'rrvalue)selfs&r to_stringDeliveryTarget.to_string^s >>> ==HNN * <<4>>:JK K <<<mm))*!DLL>: :}}"""rcv<V^8dQh/S[;R&S[S[,;R&S[S[,;R&S[;R&S[;R&#)rrrrr r$)r rrbool)rrs"rrrsNc]!}#rN)__name__ __module__ __qualname____firstlineno____doc__rrr r$ classmethodr.r4__annotate_func____static_attributes____classdictcell__rs@rrrsJ"G#IIK.0.0.0` # #Errca]tRt^ktoRtRV3RlRlltRV3RlRlltRV3RlRlltV3R lR ltV3R lR lt V3R lRlt Rt Vt R#)DeliveryRouterz Routes messages to appropriate destinations. Handles the logic of resolving delivery targets and dispatching messages to the right platform adapters. Nc<<V^8dQhRS[RS[S[S[3,/#)rconfigadapters)r rr r)rrs"rrDeliveryRouter.__annotate__ss( @ @} @Xs]8K @rc nWnT;'g/Vn\4R, R, VnR#)z Initialize the delivery router. Args: config: Gateway configuration adapters: Dict mapping platforms to their adapter instances cronoutputN)rGrHr output_dir)r3rGrHs&&&r__init__DeliveryRouter.__init__ss*  B )+f4x?rcr<V^8dQhRS[S[S[S[,3,RS[S[,RS[S[,/#)rdeliverrr)r rrrr r)rrs"rrrIs@--sDI~&-'- n  -rc \V\4'dV.p.p\4pVFp\P WR4pVP faVP \P8wdBVPPVP 4pV'dVP VnMKVP VP VP3pW9gKVPV4VPV4K VPP'dC\PRR3p W9d*VP\\PR74V#)a Resolve delivery specification to concrete targets. Args: deliver: Delivery spec - "origin", "telegram", ["local", "discord"], etc. origin: The source where the request originated (for "origin" target) Returns: List of resolved delivery targets Nr") isinstancersetrr.rrr r'rGget_home_channelraddappendalways_log_local) r3rQrtargetsseen_platforms target_strrhomekey local_keys &&& rresolve_targetsDeliveryRouter.resolve_targetss gs # #iG!J#))*=F~~%&//X^^*K{{33FOOD%)\\FN??FNNF4D4DEC(""3'v&!"& ;; ' ' '!t4I.~x~~FGrc<V^8dQhRS[RS[S[,RS[S[,RS[S[,RS[S[S[S[3,,RS[S[S[3,/#)rcontentrYjob_idjob_namemetadatar)rrrrrr)rrs"rrrIsi(((n%( ( 3- ( 4S>* ( c3h(rc ^"/pVFfpVP\P8XdVPWWE4pMVP WqV4GRjxL pRRRV/WgP 4&Kh V#L \ d+p RRR\T 4/YgP 4&Rp ? KRp ? ii;i5i)a0 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 NsuccessTresultFerror)rr r'_deliver_local_deliver_to_platformr4 Exceptionr) r3rbrYrcrdreresultsrrhes &&&&&& rrQDeliveryRouter.delivers*F ??hnn4!00(UF#'#<#* , c3h , rc \P!4PR4pV'dVPV, V R2, pMVPR, V R2, pVPP RRR7.pV'dVP RV 24MVP R4VP R4VP R \P!4PR 4 24V'dVP R V 24V'd1VP4FwrVP R V R V 24K VP R4VP R4VP R4VP V4VPRPV44R\V4RV/#)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--- path timestamp) rnowstrftimerMparentmkdirrWitems write_textjoinr) r3rbrcrdrerz output_pathlinesr]r2s &&&&& rrjDeliveryRouter._deliver_localsnLLN++O< //F2 {#5FFK//F2 {#5FFK   =  LL2hZ ) LL, - R x||~'>'>?R'S&TUV  LL<x0 1 &nn.  r#d5'23/  R U R Wtyy/0 C $   rc,<V^8dQhRS[RS[RS[/#)rrbrcr)rr)rrs"rrrIs"cdrc \P!4PR4p\4R, R, pVP RRR7WB RV R2, pVP V4V#)z7Save full cron output to disk and return the file path.rrrKrLTrt_z.txt)rr{r|r r~r)r3rbrcrzout_dirrys&&& r_save_full_output DeliveryRouter._save_full_outputs`LLN++O< !#f,x7 dT 281YKt44   rc n<V^8dQhRS[RS[RS[S[S[S[3,,RS[S[S[3,/#)rrrbrer)rrrrr)rrs"rrrIsN[[[[4S>* [ c3h [rc "VPPVP4pV'g#\RVPP 24hVP 'g$\RVPP R24h\ V4\8dbT;'g/PRR4pVPW%4p\PR\ V4V4VR\RV R 2,p\T;'g/4pVP'dR V9dVPVR &TPVP Y';'gRR 7GRjxL #L5i) z(Deliver content to a messaging platform.zNo adapter configured for zNo chat ID for z deliveryrcunknownu4Cron output truncated (%d chars) — full output: %sNz' ... [truncated, full output saved to ]r)re)rHgetrr*r2rr)MAX_PLATFORM_OUTPUTrloggerinfoTRUNCATED_VISIBLEdictrsend)r3rrbreadapterrc saved_path send_metadatas&&&& rrk#DeliveryRouter._deliver_to_platforms6--##FOO49&//:O:O9PQR R~~~v/D/D.EYOP P w<- -nn"))(I>F//@J KKNPST[P\^h i**+=j\KL  X^^,     = @)/)9)9M+ &\\&..'DYDYUY\ZZZZs1A!E*$?E*$A%E* E*#4E* E*#E($E*)rHrGrMr9)NNN) r:r;r<r=r>rNr_rQrjrrkrArBrCs@rrErEksM @ @--^((T, , \[[rrEc V^8dQhR\\\\\,3,,R\\,R\R\\\\,3,/#)rrQrdefaultr)rr rrr )rs"rrr.sT   eCcN+ ,  ] #   3S > rcV'gV#V#)zM Normalize a delivery specification. If None or empty, returns the default. r8)rQrrs&&&rparse_deliver_specr.s  NrctV^8dQhR\R\\,R\\\ 3,/#)rrGrr)r rr rrr)rs"rrr=s3"" " ] #" #s(^"rcXVP4pRRRRVRJ/RRRRR//pVF[pVPV4pRVPP4 R 2RRR V'dVP 4MR/W4P&K] RV'dVP 4MRR VR VP /#) z Build context for the unified cronjob tool to understand delivery options. This is passed to the tool so it can validate and explain delivery targets. r descriptionz"Back to where this job was created availableNr!zSave to local files onlyTz home channel home_channeloptionsrX)get_connected_platformsrUr2titleto_dictrX)rGr connectedrrr\s&& rbuild_delivery_context_for_toolr=s..0I  ? t+   5  G&&x0 hnn2245]C  dDLLN#  f&.."$7F33 r)Nrr9)r>loggingpathlibrr dataclassesrtypingrrrrr hermes_cli.configr getLoggerr:rrrrGr r sessionr rrErrr8rrrs~!33-   8 $+" K#K# K#\@[@[F ""r