+jLdZddlZddlZddlZddlZddlmZmZmZddl m Z m Z m Z ddl mZmZmZmZmZddlmZmZmZddlmZmZmZdd lmZmZejeZ Gd d Z!dd l m"Z#gZ$e%Z&e#j'D]5\Z(Z)e)e&vr,e$*e(e)fe&+e)6[&dS) u6 LightClaw inbound message handler — processes incoming message:private events, downloads/decodes file attachments, and dispatches MessageEvents. Mirrors: src/inbound.ts + src/media.ts (processFiles inline in inbound.ts). Attachment pipeline (aligned 1:1 with TS inbound.ts L106-172): for each file: ① source detection - file.bytes is a data URL → parse_data_url → (buf, mime) - file.uri is a cloud URI → download_file_from_server(buf, ctype) - neither → skip with warn ② save to local media dir (size/format check) ③ warm upload to /drive/save: - data-URL source: POST /drive/save (server-side content review), failures are logged and ignored - uri source: skip upload (already on server) ★ The resulting public URL is ONLY logged — the URL pushed into `public_urls` is ALWAYS `localfile://`. This is intentional and mirrors TS behaviour precisely. The real delivery path back to the client is the on-demand file:download signal handshake (see download_handler.py), not the inbound public URL. ④ record `{name, mimeType, url: localfile://...}` into adapter._inbound_attachments[chat_id] for history persistence. N)ListOptionalTuple) MessageEvent MessageTypeget_image_cache_dir) CHANNEL_KEYDEFAULT_AGENT_IDEVENT_MESSAGE_PRIVATELOCALFILE_SCHEMEMEDIA_MAX_BYTES)download_file_from_serverget_file_download_urlupload_file_to_server)format_file_sizeguess_mime_by_extparse_data_url)resolve_effective_api_keyset_session_api_keyc eZdZdZdeddfdZdedededee ee eeffd Z d e d ed edefd Z dedede e fdZdeddfdZdeddfdZdS) InboundMixinaE Mixin providing inbound message handling, file processing, and history/sessions stub responses. Mirrors: inbound.ts (handleIncomingMessage) + media.ts (processFiles) Requires (set by LightClawAdapter): self._bot_client_id: str self._api_keys: list[str] self._api_base_url: str self._session: aiohttp.ClientSession self._inbound_attachments: Dict[str, list] self.build_source(...) self.handle_message(event) self._fire_and_forget(event, data) self._generate_msg_id() or generate_msg_id() datareturnNc K|dd}|dd}|dd}|dd}|dpg}|dpt}||jkrd S|r|dkrd S|r|s|sd Std |||||pdd d t |||j|<|tkrd td |d|}n d td |}t|} t|| |j |} | r3| t||dd| ||||j|d |j|d ||j|<|j|t-|di|d t-|di|d ||} | t||dd| |td|| ||d|||tkr|nd } |||| d {V\} }}d }|r*t-|dd pi}||pd }t5|pd|zt6j| || ||}||d {Vd S)zn Handle a message:private inbound event. Mirrors: handleIncomingMessage in inbound.ts fromcontentmsgIdkindtextfilesagentIdNzO[lightclaw] Incoming: from=%s msgId=%s kind=%s agentId=%s content='%s' files=%d< agent:main::dm:: sender_id typing_stop)r msg_idagent_id_pending_file_paths_delivered_paths typing_startz2[lightclaw] typing_start sent: to=%s roundMsgId=%sdm)chat_id chat_typeuser_id user_name thread_id_agent_prompts)r! message_typesource message_id media_urls media_typeschannel_prompt)getr _bot_client_idstriploggerinfolen_incoming_agent_idsr rr _round_ids_fire_and_forgetr _build_message_clear_round_id_last_round_idpop_round_usage_emitted_round_reply_to_usage_trackersnapshot_baselinegetattr_get_or_create_round_id build_source_process_filesrrTEXThandle_message)selfrsenderrr+r r"r, session_key effective_key old_round round_msg_idr8r:r;attachment_desc agent_prompt agent_promptsevents ;/home/agentuser/.hermes/plugins/lightclawbot/src/inbound.py_handle_incoming_messagez%InboundMixin._handle_incoming_messageQs 88FB''88Ir**88GR((88FF++88G$$*88I&&:*: T( ( ( F  DFNN F GMMOO U  F ] FD(W]CRC,@#e**   ,4 ( ' ' 'L LLLL(LLKKA AAAAK1FCCC K777O''//    ! !%##FB]+4x$II    V$$$ --- !%%fd333'-V$ --f555+R0044VTBBB("--11&$???33F;;   !   '3h  H H    H&R^___"" #+.>">">hhD#   :>9L9L 6=: : 4 4 4 4 4 4 0 K   ?#D*:DAAGRM(,,X66>$L-R?2$)!#'   !!%(((((((((((r"rUapi_keyc Kg}g}g}d}|D]} |dpd} |dpd} d} d} |dr=t|d} | r | \} }|p| } ntd | |d rhd } t |d ||j d{V\} }}|r|dkr|} nP#t $r&}td | |Yd}~d}~wwxYwtd| "| &t| tkr1td| tt| o| | | | }| || | | sp t|||j d{V\}}t d||n2#t $r%}td|Yd}~nd}~wwxYwt|}| | | |dtt| }| dr |d| d|dz }n|d| d|d|dz }t d|| tt| #t $r:}td|d|Yd}~ d}~wwxYw|rOt!|dd}t#|t$r)||g||||fS)aM Ingest `files[]` from an inbound `message:private` payload. Returns (local_paths, mime_types, description_text). * local_paths / mime_types: parallel arrays passed to the agent via `MessageEvent.media_urls / media_types`. These point to on-disk copies and are what vision/audio tools actually read. * description_text: trailing block appended to the user text so small models that don't inspect `media_urls` still know files were attached (TS `attachmentDescription`). Side effects: - Warm-uploads data-URL files to /drive/save for server-side content review (failures are logged, never fatal). - Populates self._inbound_attachments[sender] with `{name, mimeType, url=localfile://...}` entries for history. rnamefilemimeTypezapplication/octet-streamNFbytesz1[lightclaw] file %s: malformed data URL, skippinguriTrasessionz1[lightclaw] file %s: download from uri failed: %sz7[lightclaw] file %s has neither bytes nor uri, skippingz7[lightclaw] file %s exceeds %d bytes (got %d), skippingu*[lightclaw] inbound warm upload: %s → %sz4[lightclaw] inbound warm upload failed (ignored): %s)rcreurl)zimage/zaudio/u 用户发送了文件: z ()u [用户发送了文件: u)，已保存到: ]z#[lightclaw] file saved: %s (%s, %s)z-[lightclaw] file processing failed for %s: %s_inbound_attachments)r=rr@warningr_session ExceptionrBr_save_media_bufferappendrrAr r startswithrN isinstancedict setdefaultextend)rTr"rUra local_paths local_typesctx_attachmentsdescfrcmimebuf is_uri_sourceparsed parsed_mime_ctypeexc saved_pathwarm_url upload_err local_urisize_strinbounds r^rQzInboundMixin._process_filess,$& #% &(f f Ae uuV}}.uuZ((F,F'+ % 55>>+AgJ77F!+1([*2dOQU!UU5\\$(M !.GeHgt}///)))))) Q!)U.H%H%H#(D$!!!O #! !NNQSW;s88o--NNQos3xx"44S$EE "":...""4((( %  ,A&---'''''' 8 H&%R& 0=== && d9((,CHH55??#788KKKKKKKDD7T77X77)3777D 9&6s3xx&@&@    CEE&MM3   Gd$:DAAG'4(( G""62..55oFFFK--sBKK-1CK D)D K DK/K3AKrNr@rArBrE)rTrrr r rrr3r,rrrVr sessions_dirr+s r^_handle_history_requestz$InboundMixin._handle_history_requests cbbbbbbbbbbb111111((62&& 'T%888 F88I&&:*:!!(SHHZ..  ' ' 'M MMMM8MMKKB BBBBK''  D/4 0 0    t_d;;   & X{L#h--   !"" 4 -!%"" 7 7      r`cKddlm}m}ddlm}|t |dd}|}|||d||ddS)uxReturn all sessions from sessions.json index. Mirrors: handlers.ts → EVENT_SESSIONS_REQUEST handler. r )EVENT_SESSIONS_RESPONSEr) list_sessionsrN requestId)rsessionsr)rrrrrrNrEr=)rTrrrrrr+s r^_handle_sessions_requestz%InboundMixin._handle_sessions_requests EDDDDDDD****** =!E!EFF "" 5+..!8 8      r`)__name__ __module__ __qualname____doc__rur_listrrrrQrfrqrrrrr`r^rr;s>*i)4i)Di)i)i)i)^I.I.#&I.14I. tCy$s)S( )I.I.I.I.^#&36 >SXe_(0 $0 40 0 0 0 d 4 D      r`r) _MIME_MAP),rbase64loggingrrtypingrrrgateway.platforms.baserrrrr r r r r file_storagerrrmediarrrtenancyrr getLoggerrr@rr_FORWARD_MIME_MAPrset _seen_mimesitems_ext_mrraddrr`r^rs@  ((((((((((QQQQQQQQQQ GFFFFFFFFFCCCCCCCC  8 $ $H H H H H H H H b 322222cee '!'))HD" ##T2J///KKr`