jx6VdZddlZddlmZddlmZddlmZddlmZm Z m Z m Z ddl m Z ejeZdZd Zd d lmZmZd d lmZd e edefdZde edefdZde defdZde de efdZde defdZeGddZGddZ 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_homeii)Platform GatewayConfig) SessionSourcechat_idreturncb|dS t|dkS#ttf$rYdSwxYw)NFrint TypeError ValueError)rs //usr/local/lib/hermes-agent/gateway/delivery.py$_looks_like_telegram_private_chat_idrsIu7||a z "uus ..valuec^|dS t|dS#ttf$rYdSwxYw)NFTr)rs r_looks_like_intr%sH }u E t z "uus ,,resultct|tr|dduSt|ddduS)NsuccessFT) isinstancedictgetgetattr)rs r_send_result_failedr"/sB&$.zz)$$-- 69d + +u 44ct|tr|d}nt|dd}|rt |ndS)Nerror)rrr r!strrr%s r_send_result_errorr(5sM&$/ 7##.. (3u:::D(r#cjt|}t|od|vS)Nzthread not found)r(boollowerr's r#_is_thread_not_found_delivery_errorr,=s0 v & &E =, = > >>r#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 platformNr thread_idF is_origin is_explicittargetoriginrc|}|}|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 r4T)r/rr0r1)r/r1local)r/:rr N)r/rr0r2) stripr+r/rr0r LOCALsplitlenr) clsr3r4target_stripped target_lowerparts platform_strrr0r/s rparsezDeliveryTarget.parseSs!,,..&,,.. 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.r4r6r7)r1r/r r:rr0r)selfs r to_stringzDeliveryTarget.to_strings > 8 =HN * *7 < LDN Lm)KKDLKK4>KK K < ;m)::DL:: :}""r#N)__name__ __module__ __qualname____doc__r __annotations__rrr&r0r1r*r2 classmethodrrBrEr#rr.r.Bs!GXc]!!!#Ix}###ItK0000300(?00K[000000[00d #3 # # # # # #r#r.cdeZdZdZddedeeeffdZ 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)rPrQr output_dir)rDrPrQs r__init__zDeliveryRouter.__init__s1  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)rrF)rr%)r/r r:_deliver_local_deliver_to_platformrE Exceptionr&) rDrWrXrYrZr[resultsr3res 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 $$"   r#ctjd}tdz dz }|dd||d|dz }|||S)z7Save full cron output to disk and return the file path.rdrSrTTrf_z.txt)rrmrnr rprs)rDrWrYrlout_dirrks r_save_full_outputz DeliveryRouter._save_full_outputsxLNN++O<< !##f,x7 dT 222F44Y4444     r#r3cK|j|j}|std|jj|jstd|jjdt |tkrm|pidd}|||}t dt |||dtd|d z}t|pi}d }d} |j r2d |vpd |v} |j } |jtjko.t!|jot#|  o d |vod|vo| }|rj| } t%|dd} | t'd| |j| d{V} | st'd| dt)| } | |d <d|d<ns|jtjkrOt!|jr;d |vr7d|vr3| s1|d}|t'd| |d <d|d<nd |vr d|vr| s| |d <||j||pdd{V}t-|r|r| rt/|rt%|dd} | t'd| |j| dd{V}|st'd| dt)||d <d|d<||j||pdd{V}t-|r+t't1|p|jjd|S)z(Deliver content to a messaging platform.zNo adapter configured for zNo chat ID for z deliveryrYunknownu4Cron output truncated (%d chars) — full output: %sNz' ... [truncated, full output saved to ]Fdirect_messages_topic_id!telegram_direct_messages_topic_idr0message_thread_idensure_dm_topicz6Telegram adapter cannot create named private DM topicsz,Failed to create Telegram private DM topic ''T"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)r[z7Telegram adapter cannot refresh named private DM topics) force_createz-Failed to refresh Telegram private DM topic 'z delivery failed)rQr r/rrrr<MAX_PLATFORM_OUTPUTr{loggerinfoTRUNCATED_VISIBLErr0r TELEGRAMrrr! RuntimeErrorr&sendr"r,r()rDr3rWr[adapterrY saved_path send_metadatais_named_telegram_private_topic!named_telegram_private_topic_namehas_explicit_direct_topictarget_thread_idrcreated_thread_id reply_anchorrrefreshed_thread_ids rr^z#DeliveryRouter._deliver_to_platforms-##FO44 SQ&/:OQQRR R~ QOv/DOOOPP P w<<- - -n"))(I>>F//@@J KKNPST[P\P\^h i i i***+KjKKKL  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 , , , , \cdhhh4S>* h c3h hhhhhhr#rO)!rJloggingpathlibrr dataclassesrtypingrrrr hermes_cli.configr getLoggerrGrrrrPr r sessionrr&r*rrr"r(r,r.rOrMr#rrs!!!!!!,,,,,,,,,,,,------  8 $ $++++++++""""""(3-D8C=T555555 )s)x}))))??????  M#M#M#M#M#M#M# M#`]]]]]]]]]]r#