JjӜ4 UdZddlmZddlZddlZddlZddlZddlZddl Z ddl Z ddl Z ddl Z ddl Z ddlZddlZddlZddlZddlmZddlmZmZddlmZddlmZddlmZdd lmZmZmZmZm Z m!Z!dd l"m#Z#m$Z$dd l%m&Z&dd l'm(Z(m)Z) ddl*Z*dd l*m+Z+n#e,$rdZ*dZ+YnwxYw ddl-Z-n #e,$rdZ-YnwxYw ddl.Z/ddl0m1Z1ddl2m3Z3m4Z4m5Z5m6Z6m7Z7m8Z8m9Z9m:Z:m;Z;mZ>m?Z?m@Z@ddlAmBZBmCZCddlDmEZEmFZFddlGmHZHddlImJZJmKZKddlLmMZMddlNmOZPdZQn#e,$rdZQdZ/dZJdZKdZMdZPdZEdZFYnwxYwe-duZRe*duZSddlTmUZUmVZVddlWmXZXmYZYmZZZm[Z[m\Z\m]Z]m^Z^m_Z_m`Z`maZaddlbmcZcmdZdddlemfZfddlgmhZhmiZimjZje jkelZmejndejoZpejndejoZqejndZrejnd Zsejnd!Ztejnd"Zuejnd#Zvejnd$ejwZxhd%Zyhd&Zzhd'Z{d(e]j|DZ}d)Z~d*Zd+d,hZhd-Zd.d/d/d0d0d1d1d2Zd3Zd4Zd4Zd5Zd6Zd7Zd8Zd9Zd:Zd;ZdZd?Zd@ZdAZdBZdCZdDZdEZdFZdGZdHdIdJdKdLZdMedN<dOdPdQdRdSZdMedT<dUZedVdWhZdXZdYZdZZdUZd[d\d]Zd^d_d]Zd`ZdaZdbZdcZddZdeZdfZdgZdhZejndiZejnd"ZedjZedkZejndlZdmZhdnZedoGdpdqZedoGdrdsZedoGdtduZedoGdvdwZedoGdxdyZedoGdzd{ZeGd|d}ZeGd~dZedZd dZd dZd dZddZddZd dZÐddZĐddZŐddZƐd dZǐdddZȐdddZɐddZʐddZddddZ̐ddZ͐ddZΐddZ dddZ dddZdedddZҐddZӐd dZԐd dZՐd!dZ֐d"dZאd#dZؐd#dZِd$dZڐd%dÄZېd&dńZܐd'dƄZݐd(dɄZސd)dʄZߐd*d̄Z dd+d̈́Zd,dτZd-d҄Zd.dԄZd/dքZd0dׄZd1dۄZd2d܄ZGd݄deXZd3dZd3dZd4dZd5d6dZd5d7dZddd8dZ ddlZn#e,ef$rdZYnwxYwd9dZd:dZd;dZddZd?dZd2dZd Zd>d ZdS(@u Feishu/Lark platform adapter. Supports: - WebSocket long connection and Webhook transport - Direct-message and group @mention-gated text receive/send - Inbound image/file/audio/media caching - Gateway allowlist integration via FEISHU_ALLOWED_USERS - Persistent dedup state across restarts - Per-chat serial message processing (matches openclaw createChatQueue) - Processing status reactions: Typing while working, removed on success, swapped for CrossMark on failure - Reaction events routed as synthetic text events (matches openclaw) - Interactive card button-click events routed as synthetic COMMAND events - Webhook anomaly tracking (matches openclaw createWebhookAnomalyTracker) - Verification token validation as second auth layer (matches openclaw) Feishu identity model --------------------- Feishu uses three user-ID tiers (official docs: https://open.feishu.cn/document/home/user-identity-introduction/introduction): open_id (ou_xxx) — **App-scoped**. The same person gets a different open_id under each Feishu app. Always available in event payloads without extra permissions. user_id (u_xxx) — **Tenant-scoped**. Stable within a company but requires the ``contact:user.employee_id:readonly`` scope. May not be present. union_id (on_xxx) — **Developer-scoped**. Same across all apps owned by one developer/ISV. Best cross-app stable ID. For bots specifically: app_id — The application's canonical credential identifier. bot open_id — Returned by ``/bot/v3/info``. This is the bot's own open_id *within its app context* and is what Feishu puts in ``mentions[].id.open_id`` when someone @-mentions the bot. Used for mention gating only. In single-bot mode (what Hermes currently supports), open_id works as a de-facto unique user identifier since there is only one app context. Session-key participant isolation prefers ``union_id`` (via user_id_alt) over ``open_id`` (via user_id) so that sessions stay stable if the same user is seen through different apps in the future. ) annotationsN) OrderedDict) dataclassfield)datetime)Path)SimpleNamespace)AnyDictListLiteralOptionalSequence) HTTPErrorURLError) urlencode)Requesturlopen)webGetApplicationRequestCreateFileRequestCreateFileRequestBodyCreateImageRequestCreateImageRequestBodyCreateMessageRequestCreateMessageRequestBodyGetChatRequestGetMessageRequestGetMessageResourceRequestP2ImMessageMessageReadV1ReplyMessageRequestReplyMessageRequestBodyUpdateMessageRequestUpdateMessageRequestBodyAccessTokenType HttpMethod FEISHU_DOMAIN LARK_DOMAIN BaseRequest CallBackCardP2CardActionTriggerResponseEventDispatcherHandlerClientTF)PlatformPlatformConfig) BasePlatformAdapter MessageEvent MessageTypeProcessingOutcome SendResultSUPPORTED_DOCUMENT_TYPEScache_document_from_bytescache_image_from_urlcache_audio_from_bytescache_image_from_bytes)acquire_scoped_lockrelease_scoped_lock)get_hermes_home)atomic_json_write env_floatenv_intz(^#{1,6}\s)|(^\s*[-*]\s)|(^\s*\d+\.\s)|(^\s*---+\s*$)|(```)|(`[^`\n]+`)|(\*\*[^*\n].+?\*\*)|(~~[^~\n].+?~~)|(.+?)|(\*[^*\n]+\*)|(\[[^\]]+\]\([^)]+\))|(^>\s)z^\|.*\|\n\|[-|: ]+\|z\[([^\]]+)\]\(([^)]+)\)z^```([^\n`]*)\s*$z^```\s*$z @_user_\d+z [ \t]{2,}z,content format of the post type is incorrect>.bmp.gif.jpg.png.jpeg.webp>.aac.m4a.mp3.ogg.wav.flac.opus.webm>.3gp.avi.m4v.mkv.mov.mp4rUci|]\}}|| Sr]).0extmimes F/home/rurouni/.hermes/hermes-agent/plugins/platforms/feishu/adapter.py rbsUUUysDsUUUmessagestreamrQrT>rWrXrZr[pdfdocxlsppt)z.pdfz.docz.docxz.xlsz.xlsxz.pptz.pptxiz feishu-app-idg333333?g?iz 127.0.0.1i="z/feishu/webhookiQXi<xii`Tioncesessionalwaysdeny) approve_onceapprove_sessionapprove_alwaysruDict[str, str]_APPROVAL_CHOICE_MAPz Approved oncezApproved for sessionzApproved permanentlyDenied)rrrsrtru_APPROVAL_LABEL_MAPii{i[Typing CrossMarkizhttps://accounts.feishu.cnzhttps://accounts.larksuite.com)feishularkzhttps://open.feishu.cnzhttps://open.larksuite.comz/oauth/v1/app/registration z[Rich text message]z[Merged forward message]z [Shared chat]z[Interactive message][Image] [Attachment])zh_cnen_usz([\\`*_{}\[\]()#+\-!|>~])u* .,;:!?、，。；：！？()[]{}<>"'`u .!?。！？z\s+) titletextcontentlabelvaluenamesummarysubtitle description placeholderhint>tagurlhreflinktypetokenlocalechat_idopen_iduser_idfile_keymsg_typetemplateunion_id image_key message_type open_chat_id share_chat_id)frozenc6eZdZUded<dZded<dZded<dS)FeishuPostMediaRefstrr file_namefile resource_typeN)__name__ __module__ __qualname____annotations__rrr]rcrarr9s=MMMIMrcrcHeZdZUdZded<dZded<dZded<dZded<d S) FeishuMentionRefrrrrFboolis_allis_selfN)rrrrrrrrr]rcrarr@sRDNNNNGFGrcrcBeZdZUdZded<dZded<dZded<d dZd S) _FeishuBotIdentityrrrrrreturnrc|r|jr ||jkS|r|jr ||jkSt|jo ||jkSN)rrrr)selfrrrs ramatchesz_FeishuBotIdentity.matchesNsZ  +t| +dl* *  +t| +dl* *DI4449#44rcN)rrrrrrrr)rrrrrrrrr]rcrarrHsYGGDNNNN555555rcrc^eZdZUded<eeZded<eeZded<dS) FeishuPostParseResultr text_contentdefault_factory List[str] image_keysList[FeishuPostMediaRef] media_refsN)rrrrrlistrrr]rcrarrYsZ!E$777J7777+05+F+F+FJFFFFFFrcrceZdZUded<ded<dZded<eeZded<eeZd ed <eeZ d ed <d Z ded<ee Z ded<dS)FeishuNormalizedMessagerraw_typerrpreferred_message_typerrrrrList[FeishuMentionRef]mentionsplain relation_kindDict[str, Any]metadataN) rrrrrrrrrrrdictrr]rcrarr`sMMM"(((((!E$777J7777+05+F+F+FJFFFF',uT'B'B'BHBBBB M    $uT:::H::::::rcrczeZdZUded<ded<ded<ded<ded<ded<ded<d ed <ded <ded <ded <ded<ded<ded<ded<ded<ded<ded<ded<ded<dZded<dZded<dZded<dZded <eZ d ed!<d"Z ded#<e e $Z d%ed&<d'Zded(<d)Zd*ed+<dS),FeishuAdapterSettingsrapp_id app_secret domain_nameconnection_mode encrypt_keyverification_token group_policyzfrozenset[str]allowed_group_users bot_open_id bot_user_idbot_nameintdedup_cache_sizefloattext_batch_delay_secondstext_batch_split_delay_secondstext_batch_max_messagestext_batch_max_charsmedia_batch_delay_seconds webhook_host webhook_port webhook_pathrpws_reconnect_noncerows_reconnect_intervalN Optional[int]ws_ping_intervalws_ping_timeoutadminsrdefault_group_policyrzDict[str, FeishuGroupRule] group_rulesnone allow_botsTrrequire_mention)rrrrrrrr frozensetrrrrrrrr]rcrarrlsKKKOOO''''MMM####))))    $$$$     !$$$$$&*****%)O))))&Y[[F(((( """"".3eD.I.I.IKIIIIJ O      rcrcpeZdZUdZded<eeZded<eeZded<dZ d ed <dS) FeishuGroupRulezLPer-group policy rule for controlling which users may interact with the bot.rpolicyrset[str] allowlist blacklistNzOptional[bool]r) rrr__doc__rrsetrrrr]rcrarrsnVVKKK%444I4444%444I4444&*O******rcrcveZdZUeeZded<eeZded<eeZded<dS) FeishuBatchStaterzDict[str, MessageEvent]eventsDict[str, asyncio.Task]taskszDict[str, int]countsN) rrrrrrrrrr]rcrarrsl&+eD&A&A&AFAAAA%*U4%@%@%@E@@@@"U4888F888888rcr) self_echoself_ids_unknown bots_disabledbot_not_mentionedgroup_policy_rejectedsenderr rrc(t|dddvS)N sender_typer>appbot)getattr)rs ra_is_bot_senderr s 6=" - - ??rcrc t|dd}|tStdt|ddt|ddt|ddfDS)N sender_idc3K|]}||V dSrr]r^vs ra z#_sender_identity..s>  rcrrr)r r)rsids ra_sender_identityrs &+t , ,C {{{  CD ) ) CD ) ) CT * *   rcrrc8td|S)Nz\\\1)_MARKDOWN_SPECIAL_CHARS_REsub)rs ra_escape_markdown_textrs % ) )'4 8 88rcrc"|dup |dkp|dkS)NTtruer]rs ra _to_booleanrs D= 9EQJ 9%6/9rcstyleDict[str, Any] | NonekeycN|sdSt||SNF)rget)rr!s ra_is_style_enabledr%s' u uyy~~ & &&rcctdgdtjd|D}d|dzz}|ds|drd|dn|}|||S)Nrc,g|]}t|Sr])len)r^runs ra z%_wrap_inline_code..sDDDSCDDDrcz`+`r )maxrefindall startswithendswith)rmax_runfencebodys ra_wrap_inline_coder5s1EDDBJud,C,CDDDEFFG 7Q; E//#.. N$--2D2D N;t;;;;$D "T "5 " ""rclanguagecz|ddddS)N r, )stripreplace)r6s ra_sanitize_fence_languager<s2 >>   # #D# . . 6 6tS A AArcelementrct|ddpd}|d}t|tr|nd}t |drt |St |}|sdSt |drd|d}t |drd|d}t |d rd |d }t |d rd |d }|S)Nrrrcodebold**italic* underlinezz strikethroughz~~)rr$ isinstancerr%r5r)r=rr style_dictrendereds ra_render_text_elementrIs w{{62&&," - -D KK E$UD11;tJV,,' &&&$T**H rV,,%$$$$X..#"x???[11(''''_55%$$$$ Orcctt|ddpdp$t|ddpd}t|ddpdp$t|ddpddd}|drdnd}d|d||dS) Nr6rlangrr r8```)r<rr$r;r1)r=r6r?trailing_newlines ra_render_code_block_elementrOs' GKK B ' ' -2..T#gkk&"6M6M6SQS2T2TH GKK # # )r**Sc'++i2L2L2RPR.S.S gfd "]]400:rrd 8 8 8T 8#3 8 8 88rcclddlm}|dd}td|}t jdd|t j}t jd d |t j}t jd d |}t jd d |}||}|S)aStrip markdown formatting to plain text for Feishu text fallbacks. Delegates common markdown stripping to the shared helper and adds Feishu-specific patterns (blockquotes, strikethrough, underline tags, horizontal rules, \r\n normalisation). r)strip_markdownrLr8c|dd|ddS)Nrz ())groupr:)ms raz/_strip_markdown_to_plain_text.. s7qwwqzz,R,RQWWQZZ=M=M=O=O,R,R,Rrcz^>\s?r)flagsz ^\s*---+\s*$z---z ~~([^~\n]+)~~z\1z([\s\S]*?))gateway.platforms.helpersrQr;_MARKDOWN_LINK_RErr. MULTILINE)rrQrs ra_strip_markdown_to_plain_textr\s988888 LL & &E  ! !"R"RTY Z ZE F8Rbl ; ; ;E F?E5 E E EE F#UE 2 2E F' 6 6E N5 ! !E Lrcdefaultr min_valuercj t|}n#ttf$r|cYSwxYw||kr|n|S)zACoerce value to int with optional default and minimum constraint.)r TypeError ValueErrorrr]r^parseds ra _coerce_intrdsQU z "y((66g5s ((c2t|||}||n|S)Nr]r^)rdrbs ra_coerce_required_intrgs$ 9 E E EFn77&0rcrcTt|}tjdd|iidSNrrF ensure_ascii)_build_markdown_post_rowsjsondumps)rrowss ra_build_markdown_post_payloadrp(s? $W - -D : 4     rcList[List[Dict[str, str]]]c|sdddggSd|vrd|dggSggd}d fd }|D]}|}t|rt|nt |}|r1|s ||| }|s |||pd|dggS) aFBuild Feishu post rows while isolating fenced code blocks. Feishu's `md` renderer can swallow trailing content when a fenced code block appears inside one large markdown element. Split the reply at real fence lines so prose before/after the code block remains visible while code stays in a dedicated row. mdrrrrMFrNonecsdSd}|rd|dggdS)Nr8rsrt)joinr:append)segmentcurrentros ra_flush_currentz1_build_markdown_post_rows.._flush_currentEsW  F))G$$ ==?? : KKw778 9 9 9rcrru) splitlinesr:r_MARKDOWN_FENCE_CLOSE_REmatch_MARKDOWN_FENCE_OPEN_RErx)r in_code_blockr{raw_line stripped_lineis_fencerzros @@rarlrl4sj -r**+,, Gw//011')DGM&&((!! ((  > $ * *= 9 9 9(..}==      !   NN8 $ $ $ --M  !   x    N  5T733455rc mentions_mappayloadr%Optional[Dict[str, FeishuMentionRef]]c~t|}|sttSggg}tt |dd}|r|||dgpgD]_}t|tstd fd|D}|r||`td |ptS)N)rrrrc3<K|]}t|VdSr)_render_post_element)r^itemrrrs rarz,parse_feishu_post_payload..zsE%T:z<PPrcr8)rrr) _resolve_post_payloadrFALLBACK_POST_TEXT_normalize_feishu_textrr$r:rxrFrrw) rrresolvedpartsrrowrow_textrrs ` @@raparse_feishu_post_payloadresi %W--H F$2DEEEEJ+-JE "3x||GR'@'@#A#A#G#G#I#I J JE  U||Ir**0b # ##t$$  ) GG      # LL " " " YYu%%++--C1C   rcct|}|r|St|tsiS|d}t |}|r|St |S)Npost)_to_post_payloadrFrr$_resolve_locale_payload)rdirectwrappedwrapped_directs rarrsm g & &F  gt $ $ kk&!!G,W55N "7 + ++rcct|}|r|St|tsiStD]*}t||}|r|cS+|D]}t|}|r|cSiSr)rrFr_PREFERRED_LOCALESr$values)rrr! candidaters rarrs g & &F  gt $ $ !$W[[%5%566      !!$U++       Ircrct|tsiS|d}t|tsiSt |ddpd|dS)Nrrr)rr)rFrr$rr)rrs rarrsq i & & mmI&&G gt $ $ Y]]7B//5266  rcrrrrc^ t|tr|St|tsdSt|dd}|dkrt |S|dkrt|dd}t|d|pd}|sdSt|}|r d|d|dn|S|d krt|d d}|d kr|d |vrtd |d <dS|pi|} | | j p| j pd} n7t|ddpd} dt| S|dvrt|dd} | r| |vr| | t|ddp4t|dd} | rd| dndS|dvr t|dd} t|ddpit|ddp4t|dd}| r+| t| ||dvr|nd|rd|dnd S|d!vrt|ddp4t|d"d}|rd#t|d#nd$S|d%krd&S|d'vrd(S|d)kr]t|ddpdp$t|d*dpd}|rt|ndS|d+vrt|Sg}d,D]>}t|||||}|r| |?d-d.|DS)/Nrrrar[z](rTatr@_allTr@alluser user_name@>imgimageraltz[Image: ]r>raudiomediavideorrr>rrrrrr [Attachment: r>emojiemotion emoji_type:z[Emoji]brr8>hrdividerz --- r?r>pre code_block)rrrchildrenelementsr,c3K|]}||V dSrr])r^parts rarz'_render_post_element..s'::TT:D::::::rc)rFrrr$r:lowerrIrrrrrxrr5rO_render_nested_postrw)r=rrrrrr escaped_labelrref display_namerrrrr? nested_partsr! extracteds rarrsa '3 gt $ $r gkk%$$ % % + + - - 3 3 5 5C f}}#G,,, czz7;;vr**++1133GKK--344::<< 2-e44 /3F+=++D++++F d{{'++i4455;;== ' ! !'G<,G,G(8(E(E(E W%6!r&&{33 ?8.P  ,T:z<XX        rcc3DK|]}t|}||VdSrrrs rarz&_render_nested_post..rrcr)rFrrrrwrrr)rrrrrs ``` rarrs %,$U+++% xx            %  %eZ\RR  Mxx             2rc)rr r raw_contentrOptional[Sequence[Any]]r c t|pd}t|}t ||}|dkrt|ddpd}d|vrd|vrt d|d<t|t||t| S|dkrnt||}t||j t|j t|jt| d St| } |d krt|d dpd} tt|ddpdp+t|d dpdpt|} t|| tkr| ndd | r| gngd | S|dvrOt!||} t#| j} t|d|dkrdnd| jr| gng|d| i| S|dkrt)|S|dkrt+|S|dvrt-||St|dS)NrrrTr)rrrrr)rrrrrrrrrphoto)rrrrrr>rrr)rrdocumentplaceholder_text)rrrrrrr merge_forward share_chat>card interactive)rr)rr:r_load_feishu_payload_build_mentions_mapr$rrrrrrrrrFALLBACK_IMAGE_TEXT_build_media_ref_from_payload_attachment_placeholderrr _normalize_merge_forward_message_normalize_share_chat_message_normalize_interactive_message)rrrr normalized_typerrr parsed_post mention_refsralt_text media_refrs ranormalize_feishu_messager&s&,,"--3355;;==O";//G&x55L&  7;;vr**0b11 d??wl::$4D$A$A$AL !&$/lCC,--//00    &  0lSSS &$$1K233K233,--//00      ++--..L'!! K44:;;AACC )  FB''-2 . . #7;;ub))/R00 #"     '$%-1D%D%D"#*&/7 {{R!!     4441'YYY -i.ABB &$.=.H.H77j&/&8@ {{b)(+6!    /))/888,&&,W555111-owGGG "O" M M MMrcc |rtj|ni}n#tj$rd|icYSwxYwt|tr|nd|iS)Nrr)rmloadsJSONDecodeErrorrFr)rrcs rarroso%,7?K(((R  %%% $$$$%-- F66Iv3FFs 11c t|d|d|dt|d}t|}g}|r||||ddd|pt}td|dt||d  S) Nrrpreview)rrrrkeysrkr8r) entry_countrrrrr) _first_non_empty_textr$_find_first_text_collect_forward_entriesrxextendrwr:FALLBACK_FORWARD_TEXTrr()rrentrieslinesrs rarrws ! G I I'UVVV   E 'w//GE  U LL!99U##))++D/DL " !%!$W>>    rcc Bt|d|d|dt|d}t|d|d|d}g}|r|d |n|t|r|d |d |}t d |d ||d S)N chat_namerr)rrrrrrrz Shared chat: z Chat ID: r8r)rrr)rr$rrxFALLBACK_SHARE_CHAT_TEXTrwr)rrshare_idrrs rarrs,% K   F G'EFFF I % I N## O$$H E/ 0Y001111 -...- +++,,,99U##L "!"%I>>    rcct|dtr|dn|}tt ||dt |d}t |}t|}g}|r|||D]}||kr|||r+|dd |d |dd pt}t||d ||d  S) Nrr)rrrrz Actions: , r8 r)ractionsr) rFr$rr_find_header_titler_collect_card_lines_collect_action_labelsrxrwr:FALLBACK_INTERACTIVE_TEXTr) rr card_payloadr body_linesrrliners rarrsY*4W[[5H5H$*O*O\7;;v&&&U\L !<(( G,LMMM  E %\22J$\22GE  U 5== LL   7 57!3!35566699U3B3Z((..00M4ML "!# W55    rcc g}dD]A}||}t|tr||Bg}|D]}t|ts9t t |pd}|r|d|Qt|d|d|d|d}t |ddp|d d }|d kr*t|d p|j } nnt|d |d |d|d t|d} t | } |r| r|d|d| | r|d| t|S)N)messagesitems message_listrecordsrrz- sender_namerrrrrrrrrr)rrrrrrz: )r$rFrrrrrrxrr:rrrr _unique_lines) r candidatesr!rrrrr nested_typer4s rarrs>JJ%% C   eT " " %   e $ $ $G(($%% )#djb//::D ,{D{{+++ & HH] # # HH[ ! ! HHX   HHV      $((>266R$((:r:R:RSSYY[[aacc & ,TXXi-@-@-HDIIVDD(  ###### ,^___ D&d++  (d ( NN000$00 1 1 1 1  ( NN;;; ' ' '  ! !!rccnt|d}d|D}td|DS)NF in_rich_blockc,g|]}t|Sr])rr^rs rar*z'_collect_card_lines..s!AAA4(..AAArccg|]}||Sr]r]rs rar*z'_collect_card_lines..s>>>4>$>>>rc)_collect_text_segmentsr )rr normalizeds rarrsD "7% @ @ @EAA5AAAJ >>:>>> ? ??rcc g}t|D]}t|tst|ddp|dd}|dvrzt|d|d|dt|d }|r| |t|S) Nrrr>buttonpickeroverflow date_picker select_staticrrr)rrrrr) _walk_nodesrFrrr$r:rrrrxr )rlabelsrrrs rarrsFG$$ ! !$%%  $((5"%%=&")=)=>>DDFFLLNN V V V % HHV   HHV   HHW   T(L M M M     ! MM%   rcrct|tr|rt|gngSt|tr-g}|D]&}|t ||'|St|t sgSt|ddp|dd }|p|dv}g}tD]T}||}t|tr(|r&t|}|r| |U| D]3\}}|tvr|t ||4|S)Nrrrr> divnoteactionrcolumnlark_mdmarkdown column_set plain_textrr)rFrrrrrrr$r:r_SUPPORTED_CARD_TEXT_KEYSrxr_SKIP_TEXT_KEYS)rrsegmentsrrnext_in_rich_blockr!rs rarrs%H2?G&u--..RG%  W WD OO24}UUU V V V V eT " " eiir"";eii&;&; < < B B D D J J L LC& # 2 +H(,,yy~~ dC  ,%7 ,/55J , +++[[]]XX T / ! ! .tCUVVVWWWW Orcrc8t|ddpd}t|d|d|d}|dvr|nd}t |||S) Nrrrrr>rrrr)rr$r:rr)rrrreffective_types rarr1s7;;z2..4"55;;==H% K   G FI '47I&I&I]]vN x9Tb c c ccrcrc>t|}|rd|dntS)Nrr)rFALLBACK_ATTACHMENT_TEXT)rnormalized_names rarr<s,,Y77O1@ ^ -? - - - -F^^rcct|tsdS|d}t|tsdS|d}t|trJt|d|d|dSt t |pdS)Nrheaderrrrr)rFrr$rrr)rr1rs rarrAs gt $ $r [[ " "F fd # #r JJw  E%a$UYYy%9%9599V;L;LeiiX^N_N_``` !#ekr"2"2 3 33rcrtuple[str, ...]ct|D]^}t|ts|D]C}||}t|trt |}|r|ccSD_dSNr)rrFrr$rr)rrnoder!rrs rarrMsG$$&&$%%   & &CHHSMME%%% &3E:: &%%%%%%  & 2rcc#Kt|tr2|V|D]}t|Ed{VdSt|tr|D]}t|Ed{VdSdSr)rFrrrr)rrs rarrZs%) LLNN ) )D"4(( ( ( ( ( ( ( ( ( ) ) E4 ) ) )D"4(( ( ( ( ( ( ( ( ()) ) )rcrc|D]m}t|trt|}|r|cS-|>t|ttfs"tt|}|r|cSndSr4)rFrrrr)rrrs rarrds"" eS ! ! "/66J "!!!! "  z%$'F'F /E ;;J "!!!! 2rccdfd }t||pd}|dd}|d d d d }d d |d D}d d |d D}t d|}|S)Nr're.Match[str]'rrc|d}pi|}|dS|jp|jpd}d|S)Nrr,rr)rUr$rr)rr!rrrs ra_subz$_normalize_feishu_text.._subzsSkk!nn!r&&s++ ;3x03;0&4zzrcrrrrLr8r9c3pK|]1}td|V2dS)r,N)_WHITESPACE_RErr:rs rarz)_normalize_feishu_text..s>^^$**355;;==^^^^^^rcc3K|]}||V dSrr]rs rarz)_normalize_feishu_text..s'EEEEEEEEErcr,)rr9rr)_MENTION_PLACEHOLDER_RErr;rwsplit_MULTISPACE_REr:)rrr;cleaneds ` rarrvs&))$ ;;Googv..Goofd++33D$??Gii^^'--X\J]J]^^^^^GiiEEt)<)<EEEEEG  g..G ==??rcrct}g}|D]3}|r||vr ||||4|Sr)raddrx)rseenuniquers rar r s[UUDF tt||   d Mrcmentiontuple[str, str]cft|dd}t|trHtt|ddpd}|dkr|dfS|dkrd|fSdS|dStt|ddpdtt|ddpdfS)Nidid_typerrrrr)r rFrr)rG mention_idrKs ra_extract_mention_idsrNs$--J*c""ggy"55;<<BBDD i  r> ! i  z> !vv GJ 2 . . 4"55 GJ 2 . . 4"55 rcDict[str, FeishuMentionRef]c pi}|pgD]}tt|ddpd}|s%|dkrtd||<?t|\}}tt|ddpd}t||||||||<|S) Nr!rrTrrrrr)rrr)rr rrNr:r)rr resultrGr!rrrs rarrs+-F>r   ''5"--344   '>>*$777F3K /8877FB//5266<<>>&KKtKLL   s MrcSequence[FeishuMentionRef]cg}t}|D]}|jr |j|j|jf}||vr#|||jr|dU|jr(||jpdd|jd||jpd|rdd|dndS) Nrunknownz (open_id=rTz [Mentioned: rrr)rrrrrrDrxrw)rrrEr signatures ra_build_mention_hintrWsED 0 0 ;  Zch7      : 0 LL [ 0 LLCH1 KKS[KKK L L L L LL.Y / / / /16 > -$))E** - - - -B>rccT|s|Sd|D}|s|S|} |D]V}||s|t|d}|r|dtvrA|}nn[ t|}|dkr/||dz tvr|dz}|dkr||dz tv|d|}||d}|D]F}||r/|dt| |z}nG|S)NcBg|]}|j d|jp|jpdS)rr)rrr)r^rs rar*z-_strip_edge_self_mentions..sF  ;/CH - -v//rcTrr)lstripr0r(_MENTION_BOUNDARY_CHARS_TRAILING_TERMINAL_PUNCTr1rstrip) rr self_names remainingnmafterir4tails ra_strip_edge_self_mentionsrds  J   I   B''++ c"gghh'E q)@@@ I E     NN!ee !a%(,DDD FA!ee !a%(,DDD!}}  B}}R    CGG8,3355<    rc ws_clientadapterruc  ddlmcm}tj}tj|||_|_|jj tdd dfd d fd }d fd }||j_ td| n#t$rYnwxYw |j_ td d tj|D}|D]}||r$|tj|ddi |n#t$rYnwxYw |n#t$rYnwxYwd_dS# |j_ td d tj|D}|D]}||r$|tj|ddi |n#t$rYnwxYw |n#t$rYnwxYwd_wxYw)zCRun the official Lark WS client in its own thread-local event loop.rN _configurerruc tdjtdjjtdjdSdS#t$r t ddYdSwxYw)N_reconnect_nonce_reconnect_interval_ping_intervalz4[Feishu] Failed to apply websocket runtime overridesTexc_info)setattr_ws_reconnect_nonce_ws_reconnect_interval_ws_ping_interval Exceptionloggerdebug)rfresra_apply_runtime_ws_overrideszC_run_official_feishu_ws_client.._apply_runtime_ws_overridess ` I173N O O O I4g6T U U U(4 #3W5NOOOOO54 ` ` ` LLOZ^L _ _ _ _ _ _ `sA A&A:9A:argsr kwargschjd|vr j|d<jd|vr j|d<|i|S)N ping_interval ping_timeout)rr_ws_ping_timeout)rwrxrforiginal_connects ra_connect_with_overridesz?_run_official_feishu_ws_client.._connect_with_overridessY  $ 0_F5R5R&-&?F? #  # /N&4P4P%,%=F> "0000rcconfcTtd|}|S)NzFFeishu _configure_with_overrides called but original_configure is None) RuntimeError)rrRrvoriginal_configures ra_configure_with_overrideszA_run_official_feishu_ws_client.._configure_with_overrides!s<  %ghh h##D))##%%% rcc:g|]}||Sr]doner^ts rar*z2_run_official_feishu_ws_client..4s%FFFQVVXXF1FFFrcreturn_exceptionsTr|)rwr rxr rr )rr rr )lark_oapi.ws.clientwsclientasyncionew_event_loopset_event_looploop_ws_thread_loop websocketsconnectr rostartrs all_taskscancelrun_until_completegatherstopclose) rerfws_client_modulerr~rpendingtaskrvrr}s `` @@@ra_run_official_feishu_ws_clientrs`222222222  ! # #D 4    "G'2: L$??```````1111111+B'% <)BCCC!!!'      /?#+  ) I|-? @ @ @FFg/55FFF  D KKMMMM  V  # #GNG$Tt$T$T U U U  IIKKKK    D   JJLLLL    D "&!/?#+  ) I|-? @ @ @FFg/55FFF  D KKMMMM  V  # #GNG$Tt$T$T U U U  IIKKKK    D   JJLLLL    D "&&&&&s B54F5 C?FCFE E$#E$(E== F  F A=I'H)(I') H63I'5H66I':II' II'I I'c\trdSd}ddlm}|d|tdS)zCheck if Feishu/Lark dependencies are available. Lazy-installs lark-oapi via ``tools.lazy_deps.ensure("platform.feishu")`` on first call if not present. Rebinds all module-level globals on success. Tc ,ddl}ddlm}ddlm}m}m}m}m}m }m }m } m } m } m} m} m}m}ddlm}m}ddlm}m}ddlm}ddlm}m}ddlm}dd lm }id |d |d |d |d|d|d|d|d|d| d| d| d| d| d|d|d|||||||||dd S)Nrrrr'r*r-r/r2r4rrrrrrrrrr r!r"r#r$r%r&r(T) r)r+r,r.r0r1r3FeishuWSClientFEISHU_AVAILABLE)! lark_oapilark_oapi.api.application.v6rlark_oapi.api.im.v1rrrrrrrr r!r"r#r$r%r&lark_oapi.corer(r)lark_oapi.core.constr+r,lark_oapi.core.modelr.5lark_oapi.event.callback.model.p2_card_action_triggerr0r1"lark_oapi.event.dispatcher_handlerr3 lark_oapi.wsr5)rrrrrrrrrr r!r"r#r$r%r&r(r)r+r,r.r0r1r3rs ra_importz*check_feishu_requirements.._importMs_    FFFFFF                                 ?>>>>>>>CCCCCCCC444444         NMMMMM999999 D #%:  !2  $%:  !"4  %&<   #$8  '(@  n  !2  ()B  '(@  "#6  &'>  #$8 '(@! " # $%*&&(+F&<, $5    rcr)ensure_and_bindzplatform.feishuF)prompt)rtools.lazy_depsrglobals)rrs racheck_feishu_requirementsrDsS t/ / / b0///// ?,gwyy O O OOrcc eZdZUdZdZdZdZdZded<dZ d8fd Z e d9dZ d:dZ d;dZddZd=dZd?d!Zd=d"Zd=d#Zd=d$Z d@dAd.Zdd/dBd2Z dCdDd7Ze dEd;Z dFdGd=Ze dHd@Ze dIdBZe dJdCZ dKdLdFZ dMdNdIZ! dKdOdKZ" dKdPdMZ#dQdRdNZ$ dKdSfdP Z% dKdTfdR Z&dUdSZ'dVdTZ(dWdVZ)dXdWZ*d=dXZ+dWdYZ,dYd[Z-dWd\Z.dWd]Z/dWd^Z0dWd_Z1dWd`Z2dWdaZ3dZdcZ4d[ddZ5e d\dfZ6d]dhZ7d^djZ8d_dmZ9d_dnZ:ddWdvZ?dcdxZ@dddzZAded{ZBdfd}ZCdgdZDdhdZEdidZFdddZGdjdZHdkdZIdldZJdQdmdZKdddndZLdddZMdodZNdpdZOe dqdZPdddZQdrdZRdrdZSdrdZTdsdZUdtdZVe dudZWe dvdZXe dwdZYdxdZZdydZ[dzdZ\dpdZ]e dqdZ^dddZ_drdZ`e d{dZadrdZbdrdZcd|dZdd}dZee d~dĄZfddDŽZgddɄZhdd˄ZiddτZje ddфZke ddӄZle ddׄZme dd؄Zne ddلZoe ddۄZpe dd܄Zqe ddބZre ddZsddddZtddZuddddZvddZwdidZxd%dddZye ddZze ddZ{ddZ|ddZ} dddddZ~ddZddZddZddZd=dZd=dZd=dZddZddZd%d%ddddZdd Ze dd Ze dd Zd%dddZddZd=dZd=dZd=dZddZddZd=dZe ddZe ddZe ddZe ddZe dd"Ze dd$Ze dd%Ze dd&Ze dd(Ze dd*Ze dd-Ze dd.Ze dd0Ze dd1ZdVd2Zdd5Ze dd7ZxZS( FeishuAdapterzFeishu/Lark bot adapter.T@rCHAT_LOCK_MAX_SIZErlconfigr7ct|tj||jpi|_||jd|_tj |_ d|_ d|_ d|_d|_d|_d|_d|_d|_d|_i|_g|_t/dz |_tj |_i|_i|_i|_i|_g|_tj |_d|_ d|_!tEj#|_$i|_%g|_&i|_'tG|_(d|_)tU|_+|j+j,|_-|j+j.|_/|j+j0|_1tU|_2|j2j,|_3|j2j.|_4i|_5tmj7d|_8i|_9tmj7d|_:tG|_;|<dS)NFzfeishu_seen_message_ids.jsonrr)=super__init__r6FEISHU_load_settingsextra _settings_apply_settings_client threadingLock_sdk_executor_lock _sdk_executor_sdk_executor_closing _ws_client _ws_futurer_loop_webhook_runner _webhook_site_event_handler_seen_message_ids_seen_message_orderrD_dedup_state_path _dedup_lock_sender_name_cache_webhook_rate_counts_webhook_anomaly_counts_card_action_tokens_pending_inbound_events_pending_inbound_lock_pending_drain_scheduled_pending_inbound_max_depth collectionsr _chat_locks_sent_message_ids_to_chat_sent_message_id_order_chat_info_cache_message_text_cache_app_lock_identityr_text_batch_stater_pending_text_batchesr_pending_text_batch_tasksr_pending_text_batch_counts_media_batch_state_pending_media_batches_pending_media_batch_tasks_approval_state itertoolscount_approval_counter_update_prompt_state_update_prompt_counter_pending_processing_reactions_load_seen_message_ids)rr __class__s rarzFeishuAdapter.__init__s* 111,,V\-?R@@ T^,,,&* #,."2"2NR&+")-48DH:> .2,0-135.0 !0!2!25S!S$>++@BBD!JL$57 35$%.^%5%5"(-%*.'ITI`IbIb9;&13#;=FQmm 15!1!3!3%)%;%B")-)?)E&*.*@*G'"2"4"4&*&=&D#*.*A*G':<!*!3!3?A!&/oa&8&8#GRmm* ##%%%%%rcrrrrc|di}i}t|tr|D]\}}t|tsd}d|vr"t |d}t t |ddd|dgDd|dgD| |t |<|d g}td |D}t |d d }tj dd} | dvrt d| d} tdMidt |dptj dd dt |dptj dd dt |dptj dddt |dptj dddt |dptj dd dt |dptj d d d!tj d"dd#td$tj d%d d&Dd'tj d(d d)tj d*d d+tj d,d d-t!d.t#d/t$d0t'd1t(d2t'd3d4d5t!d6t#d7t*d8t!d6t#d9t,d:t'd;t.dt3|d>p&tj d?t t4d@t |d@ptj dAt6pt6dBt9|dBdCdDEdFt9|dFdGd6EdHt;|dHdd6EdIt;|dIdd6Ed |d |d|dJ| dt |dtj dKdLS)NNrrropench|]D}t|#t|ESr]rr:r^us ra z/FeishuAdapter._load_settings..Aggg!X[\]X^X^XdXdXfXfgs1vv||~~gggrcrch|]D}t|#t|ESr]rrs rarz/FeishuAdapter._load_settings..rrcr)rrrrrc3K|]F}t|#t|VGdSrrrs rarz/FeishuAdapter._load_settings..sCPPaQP3q66<<>>PPPPPPrcrrFEISHU_ALLOW_BOTSr>allrrzS[Feishu] Unknown allow_bots=%r, falling back to 'none'. Valid: none, mentions, all.r FEISHU_APP_IDrFEISHU_APP_SECRETrdomainr+rrFEISHU_CONNECTION_MODE websocketrFEISHU_ENCRYPT_KEYrFEISHU_VERIFICATION_TOKENrFEISHU_GROUP_POLICYrc3fK|],}||V-dSrr:r^rs rarz/FeishuAdapter._load_settings..sL**::<<* ******rcFEISHU_ALLOWED_USERS,rFEISHU_BOT_OPEN_IDrFEISHU_BOT_USER_IDrFEISHU_BOT_NAMEr HERMES_FEISHU_DEDUP_CACHE_SIZEr&HERMES_FEISHU_TEXT_BATCH_DELAY_SECONDSr,HERMES_FEISHU_TEXT_BATCH_SPLIT_DELAY_SECONDSg@rr%HERMES_FEISHU_TEXT_BATCH_MAX_MESSAGESr"HERMES_FEISHU_TEXT_BATCH_MAX_CHARSr'HERMES_FEISHU_MEDIA_BATCH_DELAY_SECONDSrFEISHU_WEBHOOK_HOSTrFEISHU_WEBHOOK_PORTrFEISHU_WEBHOOK_PATHrrprrfrrorrrFEISHU_REQUIRE_MENTIONrr])r$rFrrrrrr:rrosgetenvrtwarningrr@r-rG_DEFAULT_DEDUP_CACHE_SIZErF!_DEFAULT_TEXT_BATCH_DELAY_SECONDS _DEFAULT_TEXT_BATCH_MAX_MESSAGES_DEFAULT_TEXT_BATCH_MAX_CHARS"_DEFAULT_MEDIA_BATCH_DELAY_SECONDS_DEFAULT_WEBHOOK_HOSTr_DEFAULT_WEBHOOK_PORT_DEFAULT_WEBHOOK_PATHrgrd) rraw_group_rulesrrrule_cfgper_chat_require_mention raw_adminsrrrs rarzFeishuAdapter._load_settingss^ ))M26624 ot , , %4%:%:%<%<  !!(D11<@($00/:8<>DDFFLLNNggx||KQS7T7Tgggggx||KQS7T7Tggg$< --- CLL))YYx,, PP:PPPPP #599-CR#H#HIIOOQQWWYYY2F;;AACCIIKK 8 8 8 NNe    J$> > > uyy**Lbi.L.LMMSSUUU> 599\22Xbi@SUW6X6XYY__aaa> EIIh//W29_h3W3WXX^^``ffhhh>   +,,` :RT_0`0`eggeeggg > EIIm44[ BVXZ8[8[\\bbddd>  # .//]29=XZ\3]3]  eggg> #8+FFLLNNTTVVV> !***I& " "6;;AACCC#> $ "6;;AACCC%> &Y0"55;;==='> (!8:STT)> 0&/8:[&&&1> 6,5>,,,7> <%(?Aabb%%%=> D"%<>[\\"""E> L'09;]'''M> R .))dRY7LNc-d-degggW> X .))iRY7LcRgNhNh-i-iY> `EIIn--h;PRg1h1hiiooqq)(c> f 4EII>R4S4S]_klmmmmg> h#7uyyAX7Y7Ycfrs"t"t"t"ti> j)3E)F)FPT`abbbbk> l( 2C(D(Dd^_````m> n6o> p"6!5q> r$ s> t"zu> v( +RY7OQW-X-XYYw> > rcsettingsruc|j|_|j|_|j|_|j|_|j|_ |j |_ |j |_ t|j|_t|j|_|jp|j |_|j|_|j|_|j|_|j|_|j|_|j|_ |j!|_"|j#|_$|j%|_&|j'|_(|j)|_*|j+|_,|j-|_.|j/|_0|j1|_2|j3|_4|j5|_6|j7|_8|j9|_:dSr);r_app_idr _app_secretr _domain_namer_connection_moder _encrypt_keyr_verification_tokenr _group_policyrr_allowed_group_usersr_adminsr_default_group_policyr _group_rulesr _bot_open_idr _bot_user_idr _bot_namer_dedup_cache_sizer_text_batch_delay_secondsr_text_batch_split_delay_secondsr_text_batch_max_messagesr_text_batch_max_charsr_media_batch_delay_secondsr _webhook_hostr _webhook_portr _webhook_pathrrprrqrrrrr|r _allow_botsr_require_mention)rr%s rarzFeishuAdapter._apply_settings8sZ #.$0 ( 8$0#+#> %2$'(D$E$E!8?++ %-%B%[hF["$0$0$0!*!)!:)1)J&/7/V,(0(H%%-%B"*2*L'%2%2%2#+#> &.&D#!)!: ( 8#. ( 8rcr ctdStjjjjjfd fd j  j jjjdjdjS)Nc0d|S)Nim.message.reaction.created_v1_on_reaction_eventdatars rarWz4FeishuAdapter._build_event_handler..bT445UW[\\rcc0d|S)Nim.message.reaction.deleted_v1rCrEs rarWz4FeishuAdapter._build_event_handler..erGrcdrive.notice.comment_add_v1vc.bot.meeting_invited_v1)r3builderr+r,®ister_p2_im_message_message_read_v1_on_message_read_event!register_p2_im_message_receive_v1_on_message_event*register_p2_im_message_reaction_created_v1*register_p2_im_message_reaction_deleted_v1register_p2_card_action_trigger_on_card_action_trigger'register_p2_im_chat_member_bot_added_v1_on_bot_added_to_chat)register_p2_im_chat_member_bot_deleted_v1_on_bot_removed_from_chat8register_p2_im_chat_access_event_bot_p2p_chat_entered_v1_on_p2p_chat_entered"register_p2_im_message_recalled_v1_on_message_recalledregister_p2_customized_event_on_drive_comment_event_on_meeting_invited_eventbuildrs`ra_build_event_handlerz"FeishuAdapter._build_event_handlerWs# ! )4 " *!(  4 3D4O P P . .t/E F F 7 7\\\\8 7\\\\- ,T-I J J 4 4T5O P P 6 6t7U V V E EdF_ ` ` / /0I J J ) )-,* )+.UWW5 rc%concurrent.futures.ThreadPoolExecutorcpt|dd}|tj}||_|5t|ddrt dt|dd}|t|ddr(t jdd }||_|cdddS#1swxYwYdS) uyReturn the adapter-owned executor for blocking Feishu SDK calls. Recreates the pool if it was never built or was shut down by an *external* teardown of the loop's default executor, so that can no longer permanently wedge sends (#10849). Refuses to resurrect once the adapter itself is closing — a real disconnect/shutdown stays shut. rNrFz9Feishu adapter is shutting down; SDK executor unavailabler _shutdownrzhermes-feishu-sdk) max_workersthread_name_prefix) r rrrr concurrentfuturesThreadPoolExecutorrrlockexecutors ra_get_sdk_executorzFeishuAdapter._get_sdk_executorwst1488 <>##D&*D #   t4e<< `"#^___t_d;;H78[%#H#H%-@@ "':A&."                  sA.B++B/2B/czKtj}|j||g|Rd{VS)z@Run a blocking Feishu SDK call on the adapter-owned thread pool.N)rget_running_looprun_in_executorrn)rfuncrwrs ra _run_blockingzFeishuAdapter._run_blockingsO')))T)$*@*@*B*BDP4PPPPPPPPPPrcc(t|dd}|dS|5d|_t|dd}d|_dddn #1swxYwY|dS |dddS#t$r|dYdSwxYw)zFStop the adapter-owned SDK executor without touching the loop default.rNTrF)waitcancel_futures)ru)r rrshutdownr`rks ra_shutdown_sdk_executorz$FeishuAdapter._shutdown_sdk_executorst1488 < F  & &)-D &t_d;;H!%D  & & & & & & & & & & & & & & &   F *   5  > > > > > * * *   5  ) ) ) ) ) ) *s# AA AA-- BBF) is_reconnectryrcxKd|_tstddS|jr|jstddS|jdvr"td|jdS|jdkr*|js#|jstddS |j|_ tt|j d|j j i \}}|sqt|tr|d nd }d |rd |dndzdz}td||d|ddSt%j|_|d {V|td|j|jdS#t2$r_}|d {Vd|}|d|dtd|dYd }~dSd }~wwxYw)zConnect to Feishu/Lark.Fz [Feishu] lark-oapi not installedz3[Feishu] FEISHU_APP_ID or FEISHU_APP_SECRET not set>webhookrzT[Feishu] Unsupported FEISHU_CONNECTION_MODE=%s. Supported modes: websocket, webhook.r{zO[Feishu] Webhook mode requires FEISHU_VERIFICATION_TOKEN or FEISHU_ENCRYPT_KEY.platformrpidNz@Another local Hermes gateway is already using this Feishu app_idz (PID z)..zI Stop the other gateway before starting a second Feishu websocket client.z [Feishu] %sfeishu_app_lock) retryablez"[Feishu] Connected in %s mode (%s)TzFeishu startup failed: feishu_connect_errorz[Feishu] Failed to connect: %srm)rrrterrorr'r(r*r,r+rrB_FEISHU_APP_LOCK_SCOPEr|rrFrr$_set_fatal_errorrrpr_connect_with_retry_mark_connectedinfor)rs_release_app_lock)rryacquiredexisting owner_pidrdexcs rarzFeishuAdapter.connects&+"  LL; < < <5| 4#3  LLN O O O5  (@ @ @ LLf%   5  I - -t7O -SWSd - LLa   5 &*lD #!4&'$dm&9:""" Hh  3=h3M3MWHLL///SW V1:C- ----Eab  ]G444%%&7E%RRRu 133DJ**,, , , , , , , ,  " " " KKSUYUf g g g4   ((** * * * * * * *555G  ! !"8'T ! R R R LL93L N N N55555  s!8B(G"A,G H9AH44H9cKd|_||jd{V||jd{V||j}|j||d{V| st|dr tj | }tjtj|dd{Vt dn^#tj$rt dYn3t($r'}t d|d Yd}~nd}~wwxYwI s5t d dfd }||j}| t dtjtj|dd{Vt dn#tj$rt dYn]tj$rt dYn3t($r'}t d|d Yd}~nd}~wwxYwd|_d|_d|_d|_|||d{V|t ddS)zDisconnect from Feishu/Lark.FN _disconnectg@timeoutz-[Feishu] Sent WebSocket CLOSE frame to Feishuu[Feishu] CLOSE frame not acknowledged within 5s — Feishu may briefly route messages to the stale connection until server-side timeoutz1[Feishu] Could not send WebSocket CLOSE frame: %sTrmz<[Feishu] Cancelling websocket thread tasks and stopping looprrucdtjD}tdt ||D]}|djdS)Nc:g|]}||Sr]rrs rar*zFFeishuAdapter.disconnect..cancel_all_tasks..s%VVVqQVVXXVVVVrcz3[Feishu] Found %d pending tasks in websocket threadg?)rrrtrur(r call_laterr)rrws_thread_loops racancel_all_tasksz2FeishuAdapter.disconnect..cancel_all_tasks s}VVG$5n$E$EVVV RTWX]T^T^___!""DKKMMMM))#~/BCCCCCrcz;[Feishu] Waiting for websocket thread to exit (timeout=10s)g$@z([Feishu] Websocket thread exited cleanlyz@[Feishu] Websocket thread did not exit within 10s - may be stuckz5[Feishu] Websocket thread cancelled during disconnectz/[Feishu] Websocket thread exited with error: %sz[Feishu] Disconnectedr|) _running_cancel_pending_tasksrr_reset_batch_buffersrr!_disable_websocket_auto_reconnect_stop_webhook_server is_closedhasattrrrun_coroutine_threadsaferwait_for wrap_futurertru TimeoutErrorrrscall_soon_threadsafershieldCancelledErrorrrrx_persist_seen_message_idsr_mark_disconnectedr)rrefuturerr ws_futurers @ra disconnectzFeishuAdapter.disconnects (()GHHHHHHHHH(()HIIIIIIIII !!###O - ..000'')))))))))  !*",,..+ =11+  9))++^&w':6'B'BCPPPPPPPPPP LMMMM'   ;     G!   %n.F.F.H.H % LLW X X X D D D D D D  / /0@ A A AO   d Z[[[&w~i'@'@$OOOOOOOOOO GHHHH' c c cabbbbb) V V V TUUUUU d d d NPS^b cccccccc d# " ##%%% &&((($$&&&&&&&&& !!! +,,,,,sDA/D44)F F(F  F'A"I )K5(K K(K  KrrcKd|D}|D]}||rtj|ddid{V|dS)Nc>g|]}|||Sr]r)r^rs rar*z7FeishuAdapter._cancel_pending_tasks../s*OOODdO499;;O4OOOrcrT)rrrrclear)rrrrs rarz#FeishuAdapter._cancel_pending_tasks.sOOELLNNOOO  D KKMMMM  C.'BTBB B B B B B B B rcc|j|j|jdSr)rrrrras rarz"FeishuAdapter._reset_batch_buffers6sG "((*** '--/// #))+++++rcc|jdS t|jddn#t$rYnwxYwd|_dS#d|_wxYw)N_auto_reconnectF)rrorsras rarz/FeishuAdapter._disable_websocket_auto_reconnect;sl ? " F # DO%6 > > > >    D #DOOOdDO " " " "s"; /;/; AcK|jdS |jd{Vd|_d|_dS#d|_d|_wxYwr)rcleanuprras rarz"FeishuAdapter._stop_webhook_serverEsu   ' F &&..00 0 0 0 0 0 0 0#'D !%D   $(D !%D  % % % %s <A Nrrrreply_to Optional[str]rOptional[Dict[str, Any]]r<c K|jstddS||}|||j}d} |D]}||\} } ||| | ||d{V} n#t$r} | dks't t| st d||dtjdt|id ||d{V} Yd} ~ nd} ~ wwxYw| dkr|| st tt#| d d pd r]t d ||dtjdt|id ||d{V} | }||d S#t$rE} td| dtdt| cYd} ~ Sd} ~ wwxYw)zSend a Feishu message.F Not connectedsuccessrNrrrrrrzI[Feishu] Invalid post payload rejected by API; falling back to plain textrrjmsgrzJ[Feishu] Post payload rejected by API response; falling back to plain textz send failedz[Feishu] Send error: %sTrm)rr<format_messagetruncate_messageMAX_MESSAGE_LENGTH_build_outbound_payload_feishu_send_with_retryrs_POST_CONTENT_INVALID_REsearchrrtrrmrnr\_response_succeededr _finalize_send_resultr) rrrrr formattedchunks last_responsechunkrrresponsers rasendzFeishuAdapter.sendRs| De?CCC C''00 &&y$2IJJ ( =" )" )$($@$@$G$G!'%)%A%A '!) '!)!) &B&&      HH!   6))1I1P1PQTUXQYQY1Z1Z)NN#nooo%)%A%A '!' $ F4QRW4X4X+Yhm n n n!)!) &B&&      HHHHHH && 44X>>'077GHeUW Xh&&8&8=U=\=\]c]i]omo=p=p&8qrrr $ ? ?# J0Mg0V0V'Wfklll!@!! $(#E#EQ[jw#E#x#x *.*<*._btns.#$0UCC$/:;WW rcwide_screen_modeTu ⚠️ Command Approval Requiredr&rrorangerrr$z``` z ``` **Reason:** rr!u✅ Allow Oncervprimaryu ✅ Sessionrwu ✅ Alwaysrxu❌ Denyrudangerrrrr1rrjrrzsend_exec_approval failedrrrrz&[Feishu] send_exec_approval failed: %sr])rrrrrrrr)rr<nextrr(rmrnrrrrrrsrtrr)rrrrrr cmd_previewrrrrrRrrs @rasend_exec_approvalz FeishuAdapter.send_exec_approvals:| De?CCC C6 =t566K47LL44G4G'%4%.500WK       .t4)KT`aa ( *#X;#X#X;#X#X ( D!1>9MM D0ABB D/?@@ DVX>> $  D.jE:::G!99&! :H//:UVVF~ #."("3"9r&55$[1 M = = = NNCS I I Ie3s88<<< < < < < < < =sC0D E8EEErr] prompt_idc |rd|dnd}dfd }d d id ddddd||dd|ddd|dddgdgdS)Nz Default: `r+rrranswerrrrcdd|d||ddS)Nrr&r)hermes_update_prompt_actionupdate_prompt_idrr])rrrrs rarz5FeishuAdapter._build_update_prompt_card.._btns3 ,?? 39(1  rcrTu⚕ Update Needs Your Inputr&rrrr$rr!u✓ Yesyru✗ Nonrrr)rrrrrrrrr])rr]r default_hintrs ` ra_build_update_prompt_cardz'FeishuAdapter._build_update_prompt_cards6=E222222       *40%B<XX$ #&/H,/H/HII#YY77XsH55      rcrcK|jstddS t|j}t j||||d}||d|d|d{V}||d } | j r|| j pd |d |j |<| S#t$rC} td | tdt| cYd} ~ Sd} ~ wwxYw) z6Send an interactive update prompt with Yes/No buttons.Frr)rr]rrjrNrzsend_update_prompt failedrrz&[Feishu] send_update_prompt failed: %s)rr<rrrmrnrrrrrrrsrtrr) rrrr]rrrrrrRrs rasend_update_promptz FeishuAdapter.send_update_prompts` | De?CCC C =T899Ij..fgYb.cc"G"99&! :H//:UVVF~ #."("3"9r&88))4 M = = = NNCS I I Ie3s88<<< < < < < < < =sBB00 C=:8C82C=8C=choicerc|dkrdnd}t|d}ddi|d|dd |dkrd nd d d |d|d|dgdS)z3Build raw card JSON for a resolved approval action.ru❌✅ResolvedrTr,r&rredgreenrr$z **z** by rr)r|r$)rriconrs ra_build_resolved_approval_cardz+FeishuAdapter._build_resolved_approval_card8s&((uue#'' ;;)40(,%6%6u%6%6|LL%+v%5%5EE7 &"&CC5CC CC   rcrc`|dk}|rdnd}ddi|rdndd|d d |rd nd d dd|ddgdS)NrYesNorTrrz Update prompt answered: r&rrrrr$zAnswered by **rArrr])rryesrs ra"_build_resolved_update_prompt_cardz0FeishuAdapter._build_resolved_update_prompt_cardKsm&$)4014(?%%a%aZ_%a%ajvww'*5GG #/M /M/M/MNN   rcctdz }|d}||||dS)Nz.update_responsez.tmp)rD with_suffix write_textr;)r response_pathtmp_paths ra_write_update_prompt_responsez+FeishuAdapter._write_update_prompt_responseZsT')),>>  ,,V44F###'''''rc audio_pathcaptioncHK||||||dd{VS)z@Send audio to Feishu as a file attachment plus optional caption.rr file_pathrrroutbound_message_typeN_send_uploaded_file_message)rrrrrrrxs ra send_voicezFeishuAdapter.send_voiceaU55 ") 6         rcrrcHK|||||||d{VS)z*Send a document/file attachment to Feishu.)rrrrrrNr)rrrrrrrrxs ra send_documentzFeishuAdapter.send_documenttsU55 6         rc video_pathcHK||||||dd{VS)zSend a video file to Feishu.rrNr)rrrrrrrxs ra send_videozFeishuAdapter.send_videorrc image_pathctK|jstddStj|stdd|S ddl}t |d5}|} dddn #1swxYwY|| } tj || _ | t| } | | } ||jjjjj| d{V} || d }|s|| d d S|r;||d |d}||d|||d{V}n6||dt/jd |id||d{V}||dS#t4$rF}t6d||dtdt;|cYd}~Sd}~wwxYw)z"Send a local image file to Feishu.FrrzImage file not found: rNrb image_typerrzimage upload failedz%Feishu image upload missing image_keydefault_messageoverride_errorr)rrr media_tagrrrrjzimage send failedz$[Feishu] Failed to send image %s: %sTrm)rr<rpathexistsiorreadBytesIObasenamer_build_image_upload_body_FEISHU_IMAGE_UPLOAD_TYPE_build_image_upload_requestrsrrrcreate_extract_response_field_response_error_result_build_media_post_payloadrrmrnrrsrtrr)rrr"rrrrx_iof image_bytes image_filer4rupload_responser post_payloadmessage_responsers rasend_image_filezFeishuAdapter.send_image_files | De?CCC Cw~~j)) Ze3XJ3X3XYYY Y, =    j$'' '1ffhh  ' ' ' ' ' ' ' ' ' ' ' ' ' ' '[11J g..z::JO004 1D66t<   *.)E)E##(%% *F**$$$$$$  *.)E)E#$ J Y'?eTTT%% *F**$$$$$$ --.>@STT T = = = LL?S[_L ` ` `e3s88<<< < < < < < < =sJG'#B8 G'BG' B CG'BG'' H71;H2,H72H7c KdS)z2Feishu bot API does not expose a typing indicator.Nr])rrrs ra send_typingzFeishuAdapter.send_typings trc image_urlcDK ||d{V}na#t$rT}td||dt |||||d{VcYd}~Sd}~wwxYw||||||d{VS)zJDownload a remote image then send it through the native Feishu image flow.Nz([Feishu] Failed to download image %s: %sTrm)rrCrrr)rr"rrr)_download_remote_imagersrtrr send_imager@) rrrCrrrr"rrs rarFzFeishuAdapter.send_images" #::9EEEEEEEEJJ    LLCYPS^bL c c c++#!! ,       ))! *         s! A?A A:4A?:A? animation_urlcdK ||ddd{V\}}na#t$rT}td||dt |||||d{VcYd}~Sd}~wwxYw|rd |nd } ||||| || d{VS) z@Feishu has no native GIF bubble; degrade to a downloadable file.rIz animation.gif) default_extpreferred_nameNz,[Feishu] Failed to download animation %s: %sTrm)rrGrrrz[GIF downgraded to file] z[GIF downgraded to file])rrrrrr)_download_remote_documentrsrtrrsend_animationr) rrrGrrrrrrdegraded_captionrs rarLzFeishuAdapter.send_animationse )-)G)G".*H**$$$$$$ Iyy     LLGX[fjL k k k//+!! 0       FMlAAAARl''$ (         s!' BA B:BBc|K||dd}|js|S|j|}|t|S ||}||jjjjj|d{V}|rt|dddurAt|dd}t|d d }t d ||||St|d d}tt|d dpd } |tt|ddp||| | pdd} | |j|<t| S#t $r"t d|d|cYSwxYw)z5Return real chat metadata from Feishu when available.dm)rrrNrcdSr#r]r]rcrarWz-FeishuAdapter.get_chat_info..+ ErcFr?rUrzchat lookup failedz0[Feishu] Failed to get chat info for %s: [%s] %srF chat_typerr)rrrrz'[Feishu] Failed to get chat info for %sTrm)rrr$r_build_get_chat_requestrsrrchatr rtrrr:r_map_chat_typers) rrfallbackcachedrrr?rrF raw_chat_typers ra get_chat_infozFeishuAdapter.get_chat_info s   | O&**733  <<  227;;G!// 0B0G0KWUUUUUUUUH JwxMMJJLLPUUUx;;h/CDDQSZ\`befff8VT22Dk2 > > D"EEKKMMSSUUM"GD&$77B7CC++M::)1T D .2D !' *::     NNDgX\N ] ] ]OOO sB(F'B'F)F;:F;c*|S)z/Feishu text messages are plain text by default.rrrs rarzFeishuAdapter.format_message? s}}rcrFc|j}||sG||}|r.tj|jdddS||||dS)aPNormalize Feishu inbound events into MessageEvent. Called by the lark_oapi SDK's event dispatcher on a background thread. If the adapter loop is not currently accepting callbacks (brief window during startup/restart or network-flap reconnect), the event is queued for replay instead of dropped. zfeishu-pending-inbound-drainerT)targetrdaemonN) r_loop_accepts_callbacks_enqueue_pending_inbound_eventrThread_drain_pending_inbound_eventsr_submit_on_loop_handle_message_event_data)rrFr start_drainers rarPzFeishuAdapter._on_message_eventG sz++D11  ??EEM  =9%''' F T4#B#B4#H#HIIIIIrccT|j5t|j|jkr|jd} t |dd}t |dd}t t |ddpd}n#t$rd}YnwxYwt d|j||j |t|j}|j }|rd |_ dddn #1swxYwYt d ||S) aAppend an event to the pending-inbound queue. Returns True if the caller should spawn a drainer thread (no drainer currently scheduled), False if a drainer is already running and will pick up the new event on its next pass. reventNrdrrrUzA[Feishu] Pending-inbound queue full (%d); dropped oldest event %sTzI[Feishu] Queued inbound event for replay (loop not ready, queue depth=%d)) rr(rrpopr rrsrtrrxrr)rrFdroppedrgrdrdepth should_starts rar`z,FeishuAdapter._enqueue_pending_inbound_event[ s ' 5 54/00D4SSS6::1==+#GWd;;E%eY==G!$WWlB%G%G%T9!U!UJJ +++!*JJJ+ W3  ( / / 5 5 5455E#< (tZ66 3=="%d&B"C"C4::<<<===============Y#h+ 6 605- 6 6 6 6 6 6 6 6 6 6 6 6 6 6 6 6 6 6gz//55#3== $ (@+ 6 605- 6 6 6 6 6 6 6 6 6 6 6 6 6 6 6 6sgL.A LAL"A# L B  B$'B$-$L)D: LD  L D  L E$# L5E  EE L$E((L+E(,AL G  L G$$L'G$()L I L,III LIL"I#L5.J/# L/J33L6J37LK33K7:K7LM#L7+ M7L; ;M>L; ?Mc bKt|dd}t|dd}t|dd}|r|rt|ddstddSt|dd}|r||rtd|dS|||}|td |dSt|d d }|||t|dd||t | d{VdS) zEShared inbound message handling for websocket and webhook transports.rgNrdrrzA[Feishu] Dropping malformed inbound event: missing message/senderrz2[Feishu] Dropping duplicate/missing message_id: %sz#[Feishu] dropping inbound event: %srRp2p)rFrdrrRris_bot)r rtru _is_duplicate_admit_process_inbound_messager )rrFrgrdrrreasonrRs rardz(FeishuAdapter._handle_message_event_data sjgt,,%D11$// f GFK,N,N  LL\ ] ] ] FWlD99  T// ;;  LLMz Z Z Z FVW--   LL> G G G FG[%88 ++fk488!!&)) ,           rcr"ct|dd}t|dd}t|ddpd}td|dS)z7Ignore read-receipt events that Hermes does not act on.rgNrdrrz([Feishu] Ignoring message_read event: %s)r rtru)rrFrgrdrs rarNz$FeishuAdapter._on_message_read_event sUgt,,%D11WlD99?R  ?LLLLLrcct|dd}tt|ddpd}td||j|ddS)z'Handle bot being added to a group chat.rgNrrz[Feishu] Bot added to chat: %sr rrtrrrhrrFrgrs rarVz#FeishuAdapter._on_bot_added_to_chat segt,,geY339r:: 4g>>> !!'400000rcct|dd}tt|ddpd}td||j|ddS)z+Handle bot being removed from a group chat.rgNrrz"[Feishu] Bot removed from chat: %srrs rarXz'FeishuAdapter._on_bot_removed_from_chat segt,,geY339r:: 8'BBB !!'400000rcc:tddS)Nz'[Feishu] User entered P2P chat with botrtrurrFs rarZz"FeishuAdapter._on_p2p_chat_entered s >?????rcc:tddS)Nz![Feishu] Message recalled by userrrs rar\z"FeishuAdapter._on_message_recalled s 899999rccddlm}|j}||stddS||||j||jdS)a%Handle drive document comment notification (drive.notice.comment_add_v1). Delegates to :mod:`gateway.platforms.feishu_comment` for parsing, logging, and reaction. Scheduling follows the same ``run_coroutine_threadsafe`` pattern used by ``_on_message_event``. r)handle_drive_comment_eventzB[Feishu] Dropping drive comment event before adapter loop is readyN) self_open_id) 'plugins.platforms.feishu.feishu_commentrrr_rtrrcrr2)rrFrrs rar^z%FeishuAdapter._on_drive_comment_event s WVVVVVz++D11  NN_ ` ` ` F   & &t|THY Z Z Z     rccddlm}|j}||stddS|||||dS)zJHandle VC bot meeting invitation notification (vc.bot.meeting_invited_v1).r)handle_meeting_invited_eventzC[Feishu] Dropping meeting invite event before adapter loop is readyN).plugins.platforms.feishu.feishu_meeting_inviterrr_rtrrc)rrFrrs rar_z'FeishuAdapter._on_meeting_invited_event ss______z++D11  NN` a a a F T#?#?d#K#KLLLLLrc event_typect|dd}tt|ddpd}tt|ddpd}t|dd}tt|ddpd}d|vrd nd }td |||||j} |d vs+|r)| 't t| d drdS|| |||dS)z>Route user reactions on bot messages as synthetic text events.rgNrr operator_type reaction_typercreatedaddedremovedz?[Feishu] Reaction %s on message %s (operator_type=%s, emoji=%s)>r r rcdSr#r]r]rcrarWz2FeishuAdapter._on_reaction_event..8 surc)r rrtrurrrc_handle_reaction_event) rrrFrgrrreaction_type_objrr!rs rarDz FeishuAdapter._on_reaction_event! s3gt,, b99?R@@ GE?B??E2FF #E?DAA!2L"EEKLL %33 M        z ^ + + ,|=GD+}}==??@@ F T4#>#>z4#P#PQQQQQrcc|j}||s1tdtrt ndSt |dd}t |dd}t |dipi}t |tr|dnd}t |tr|dnd}|r| |||S|r| |||S| || |tdSt S) apHandle card-action callback from the Feishu SDK (synchronous). For approval actions: parses the event once, returns the resolved card inline (the only reliable way to sync all clients), and schedules a lightweight async method to actually unblock the agent. For other card actions: delegates to ``_handle_card_action_event``. z:[Feishu] Dropping card action before adapter loop is readyNrgr!rrr)rg action_valuer) rr_rtrr1r rFrr$_handle_approval_card_action!_handle_update_prompt_card_actionrc_handle_card_action_event)rrFrrgr!rrupdate_prompt_actions rarTz%FeishuAdapter._on_card_action_trigger= spz++D11 Z NNW X X X4OY.000UY Ygt,,$//vw339r =G VZ=[=[e ((999ae ,-- 8L  : ; ; ;37   h445|bf4gg g  99):  T4#A#A$#G#GHHH & .4*,,,rcrcZ|duo'tt|dd S)zEReturn True when the adapter loop can accept thread-safe submissions.NrcdSr#r]r]rcrarWz7FeishuAdapter._loop_accepts_callbacks..e sPUrcrr )rs rar_z%FeishuAdapter._loop_accepts_callbacksb s64Y-VWT; -V-V-X-X(Y(Y$YYrccorocddlm}|||tdtj}|dS||jdS)zISchedule background work on the adapter loop with shared failure logging.r)safe_schedule_threadsafez4[Feishu] Failed to schedule background callback work)rt log_message log_levelNFT)agent.async_utilsrrtloggingWARNINGadd_done_callback_log_background_failure)rrrrrs rarczFeishuAdapter._submit_on_loopg sc>>>>>>)) $No     >5  !=>>>trcrct|pd}|sdSt|jt|jz}|sdSd|vp||vS)zBReturn whether this card-action operator may answer gated prompts.rFTrC)rr:rr/r.)rrr allowed_idss ra#_is_interactive_operator_authorizedz1FeishuAdapter._is_interactive_operator_authorizedu smB''--//  5$,''#d.G*H*HH  4k!>Z;%>>rcrgrc |d}|1tdtrtndS|j|}|s2td|trtndSt |dd}t |dd}tt |dd pd }t|tt |d d pd  } | | |d d d s4t d|pdtrtndStt t |dddd pd } t|d d pd } | r<| r:| | kr4t d|| | trtndS| |p|} t |dd} tt | dd pd }| || ||| ||strtndStdSt}t8t}d|_||| |_||_|S)zISchedule approval resolution and build the synchronous callback response.rNz2[Feishu] Card action missing approval_id, ignoring0[Feishu] Approval %s already resolved or unknownrruoperatorrrrrrrFrxz*[Feishu] Unauthorized approval click by %s contextrzE[Feishu] Approval callback chat mismatch for %s (expected=%s, got=%s))rrrrrraw)rr)r$rtrur1rrzr rr _allow_group_messager_get_cached_sender_namerc_resolve_approvalr0rrrFr)rrgrrrstaterrrrcallback_chat_idexpected_chat_idr chat_contextrrrs rarz*FeishuAdapter._handle_approval_card_action s"&&}55   LLM N N N4OY.000UY Y$((55 Z LLK[ Y Y Y4OY.000UY Y%)),*:*:?*K*KVTT5*d33gh 266<"==#GSS\^`AaAaAgeg=h=hiii ((EIIi4L4LUZ([[ Z NNGI_T_ ` ` `4OY.000UY Ywwui'F'FXZ[[a_abbuyyB77=2>>  Z 0 Z5EIY5Y5Y NNW      5PY.000UY Y0099DW ui66 glNB??E2FF##   " "'# #     Z5PY.000UY Y & .4.00  #>>DDI::&T]:^^DI HMrcc 8|d}|1tdtrtndS|j|}|s2td|trtndSt |ddpd}|dvr2td|trtndSt|d d}t t|d dpd}t|t t|d dpd } | | |d dds4t d|pdtrtndSt tt|ddddpd} t |d dpd} | r<| r:| | kr4t d|| | trtndS| |p|} | ||||| || strtndStdSt} t8t}d|_||| |_|| _| S)zNSchedule update prompt resolution and build the synchronous callback response.rNz7[Feishu] Card action missing update_prompt_id, ignoring5[Feishu] Update prompt %s already resolved or unknownrr>rrz8[Feishu] Card action has invalid update prompt answer=%rrrrrrFrz/[Feishu] Unauthorized update prompt click by %srrrzJ[Feishu] Update prompt callback chat mismatch for %s (expected=%s, got=%s)rrr)rr)r$rtrur1rrr:rr r rrrrc_resolve_update_promptr0rr rFr)rrgrrrrrrrrrrrrrs rarz/FeishuAdapter._handle_update_prompt_card_action s7 $$%788   LLR S S S4OY.000UY Y)--i88 Z LLPR[ \ \ \4OY.000UY Y\%%&CRHHNBOOUUWW]]__  # # LLSU[ \ \ \4OY.000UY Y5*d33gh 266<"==#GSS\^`AaAaAgeg=h=hiii ((EIIi4L4LUZ([[ Z NNLgNdYd e e e4OY.000UY Ywwui'F'FXZ[[a_abbuyyB77=2>>  Z 0 Z5EIY5Y5Y NN\      5PY.000UY Y0099DW ##   ' '( (     Z5PY.000UY Y & .4.00  #>>DDI??vYb?ccDI HMrcrrcK|j|}|std|dS||s td|pd|dSt |ddpd}|r'|r%||krtd|||dS|j|d}|std|dS d d lm }||d |} t d | |d ||dS#t$r&} t d | Yd} ~ dSd} ~ wwxYw)z8Pop approval state and unblock the waiting agent thread.rNz:[Feishu] Unauthorized approval click by %s for approval %srrrz8[Feishu] Approval %s chat mismatch (expected=%s, got=%s)z?[Feishu] Approval %s already resolved while validating callbackr)resolve_gateway_approvalrzIFeishu button resolved %d approval(s) for session %s (choice=%s, user=%s)z9Failed to resolve gateway approval from Feishu button: %s) rr$rtrurrrrhtools.approvalrrrsr) rrrrrrrrrrrs rarzFeishuAdapter._resolve_approval s$((55  LLK[ Y Y Y F77@@  NNWY`Yodoq| } } } FuyyB77=2>>   ,<,G,G NNJ-w    F$((d;;  LLZ\g h h h F [ ? ? ? ? ? ?,,U=-A6JJE KK[u]+VY      [ [ [ LLTVY Z Z Z Z Z Z Z Z Z [s:>   ,<,G,G NNO      F)--i>>  LL_aj k k k F L  . .v 6 6 6 KKSm$fi      L L L LLEs K K K K K K K K K Ls"8E F &FF c K|jsdSt|dd}tt|ddpd}|sdS ||}||jjjjj|d{V}|rt|ddsdStt|ddddpg}|r|d nd}|sdSt|d d} tt| d dpd|j krdStt|d dpd} tt|d dpd} | sdSn-#t$r t ddYdSwxYwt|dd} t|dd} tt| ddpd}d|vrdnd}d|d|}| | d{V}|| d{V}|| |dp| pd||| |d|dd|d }t#|t$j||||| t+j!}td"|||||d{VdS)#zVFetch the reacted-to message; if it was sent by this bot, emit a synthetic text event.NrgrrrcdSr#r]r]rcrarWz6FeishuAdapter._handle_reaction_event..L srcrFrrrrJrrRrwz5[Feishu] Failed to fetch message for reaction routingTrmrrrUNKNOWNrrrz reaction:rr Feishu Chat chat_infoevent_chat_typer user_id_altrrrRrr thread_idrrrsource raw_messagerchannel_prompt timestampzD[Feishu] Routing reaction %s:%s on bot message %s as synthetic event)rr r_build_get_message_requestrsrrrdr$r'rsrtru_resolve_sender_profilerY build_source_resolve_source_chat_typer9r:TEXT_resolve_channel_promptrnowr_handle_message_with_guards)rrrFrgrrrrrrr chat_type_raw user_id_objrrr!synthetic_textsender_profilerrsynthetic_events rarz$FeishuAdapter._handle_reaction_event? sz|  Fgt,, b99?R@@   F 55jAAG!// 0B0J0NPWXXXXXXXXH #N78Y #N#N#P#P GHfd;;WdKKQrE#-%((C S(D11F764,,233t|CC'#y"55;<. s,wwwBcBhQvFvFv1FvFvFvrcTF)rnrr)rrexpiredrrs @ra_is_card_action_duplicatez'FeishuAdapter._is_card_action_duplicate| sxikkwwww$":"@"@"B"Bwww , ,A(++ D, , ,4*- 'urcc FKt|dd}tt|ddpd}|r2||rtd|dSt|dd}tt|ddpd}t|dd}tt|d dpd}|r|std dSt|d d}tt|d dpd } t|dipi} d| } | r. | dt j| dz } n#t$rYnwxYwt|dd} | | d{V} | |d{V}| || dp|pd| |d| d| dd| d}t| tj|||ptt#j||t)j}td| ||||d{VdS)zHRoute Feishu interactive card button clicks as synthetic COMMAND events.rgNrrz1[Feishu] Dropping duplicate card action token: %srrrrzB[Feishu] Card action missing chat_id or operator open_id, droppingr!rrrz/card r,Frj)rrrrrrUrrrrrrzB[Feishu] Routing card action %r from %s in %s as synthetic command)r rrrtrurmrnrsr rrYrr$rr9r:COMMANDuuiduuid4rrrrr)rrFrgrrrrrr! action_tagrrrrrrrs rarz'FeishuAdapter._handle_card_action_event sgt,,GE7B//5266  T33E::  LLLe T T T F%D11gg~r::@bAA5*d33gh 266<"== g  LL] ^ ^ ^ F$//33?x@@ vw339r .*..   "TdjE&R&R&R"T"TT    $GTDQQQ #;;IFFFFFFFF,,W55555555 ""mmF++GwG-44yZa4bb"9-$[1&}5#  '$,1DJLL 1 177@@lnn     XZdfmovwww..???????????s6E E E  asyncio.Lockc |j|}||j||St|j|jkrd}t |jD]?}|j|s|j|d}n@|s9|jtt|jtj }||j|<|S)a}Return (creating if needed) the per-chat asyncio.Lock for serial message processing. Bounded with LRU eviction so a long-running gateway that sees many distinct chats does not grow ``_chat_locks`` without limit. Locks that are currently held are never evicted; if every entry is locked we fall back to dropping the least-recently-used one. NFT) rr$ move_to_endr(rrlockedrhriterrr)rrrlevictedr!s ra_get_chat_lockzFeishuAdapter._get_chat_lock s##G,,     ( ( 1 1 1K t D$; ; ;GD,--  ',3355$((---"GE C $$T$t/?*@*@%A%ABBB|~~$(! rcr9cK|jrt|jddpdnd}||}|4d{V||d{Vdddd{VdS#1d{VswxYwYdS)a$Dispatch a single event through the agent pipeline with per-chat serialization before handing the event off to the agent. Per-chat lock ensures messages in the same chat are processed one at a time (matches openclaw's createChatQueue serial queue behaviour). rrN)rr rhandle_message)rrgr chat_locks rarz)FeishuAdapter._handle_message_with_guards s*AF T'%, 266<"RT''00  - - - - - - - -%%e,, , , , , , , , - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -sA00 A:=A:cxtjdddvS)NFEISHU_REACTIONSr>0nofalse)rrr:rras ra_reactions_enabledz FeishuAdapter._reactions_enabled s3y+V44::<<BBDDL```rcrc K|jr|r|sdS ddlm}m}|d|i}|||}| |jj j j j |d{V}|r<t|ddr"t|dd}t|ddStd ||t|d dt|d dn.#t"$r!td ||d YnwxYwdS)zRReturn the reaction_id on success, else None. The id is needed later for deletion.Nr)CreateMessageReactionRequest CreateMessageReactionRequestBodyrrcdSr#r]r]rcrarWz-FeishuAdapter._add_reaction.. rcrF reaction_idz7[Feishu] Add reaction %s on %s rejected: code=%s msg=%sr?rz%[Feishu] Add reaction %s on %s raisedTrm)rrrrrLrr`rrrsrrmessage_reactionr5r rtrursr) rrrrrr4rrrFs ra _add_reactionzFeishuAdapter._add_reaction s| : Z 4!          188:: j9::  -4466J''d##  "// 0B0S0Z\cddddddddH :GGHiGGII :x66t]D999 LLI&$//%..         NN7       tsDE. rrcTz:[Feishu] Remove reaction %s on %s rejected: code=%s msg=%sr?rz([Feishu] Remove reaction %s on %s raisedrm)rrrrLrrr`rsrrrdeleter rtrursr)rrrrrrs ra_remove_reactionzFeishuAdapter._remove_reaction sj| : [ 5  H H H H H H,4466J''[))  "// 0B0S0Z\cddddddddH GGHiGGII t LLL&$//%..         NN:       usB#C36BB:NN  6..z;LMMMMMMMM   ) )* 5 5 5 '/ / /$$Z1IJJ J J J J J J J J J 0 /rc remote_ipstatusc,tj}|j|}|W|\}}}||z tkrC|dz }|tzdkr!t d|||||z |||f|j|<dSd||f|j|<dS)zIncrement the anomaly counter for remote_ip and emit a WARNING every threshold hits. Mirrors openclaw's createWebhookAnomalyTracker: TTL 6 hours, log every 25 consecutive error responses from the same IP. NrrzY[Feishu] Webhook anomaly: %d consecutive error responses (%s) from %s over the last %.0fs)rnrr$#_FEISHU_WEBHOOK_ANOMALY_TTL_SECONDS!_FEISHU_WEBHOOK_ANOMALY_THRESHOLDrtr)rrrrentryr _last_status first_seens ra_record_webhook_anomalyz%FeishuAdapter._record_webhook_anomaly^ s ikk,00;;  .3 +E<Z"EEE <<AANN.!j( : ""}`` in ``PlatformConfig.extra`` is honoured for Feishu chats instead of being silently ignored. r)resolve_channel_promptrNr)gateway.platforms.baser(r )rrr%r(_config_extras rarz%FeishuAdapter._resolve_channel_prompt sS BAAAAA$$//'4006B%%fgyAAArcrrdrrRrxcK||d{V\}}} } } |tjkr1t|| }|dr tj}|tjkr!|s| st d|dS|tjkrt| } | r |r| d|n| }t|ddpt|ddpd} t|ddp#t|ddpt|ddpd}|r| |d{Vnd}t|ddp#t|d dpt|d dpd }t d |d krdnd||j t|ddpd|rdnd||ddt|  t|ddpd}||d{V}|||d{V}|||dp|pd||||d |d| |d|}t'|||||| | ||||| pdt+j }||d{VdS)N/z*[Feishu] Ignoring empty text message id=%sz rroot_idr%upper_message_idrrrrz\[Feishu] Inbound %s message received: id=%s type=%s chat_id=%s sender=%s:%s text=%r media=%drwrOrUrrr rrorrrrrr)rrrRrrrrrx) rrrrr media_urls media_typesreply_to_message_id reply_to_textrr)_extract_message_contentr:rrdr0rrtrurWr _fetch_message_textrrr(rYrrr$rr9rrr_dispatch_inbound_event)rrFrdrrRrrxr inbound_typer0r1rrrr2r3sender_primaryrrrrrs rar{z&FeishuAdapter._process_inbound_message sGKFcFcdkFlFl@l@l@l@l@l@l=lJ X ;+ + +,T8<s rar<z'FeishuAdapter._should_batch_media_event sA   v"{'8+:K[Macnct&uu   rccddlm}||j|jjdd|jjdd}|d|jjS) Nrbuild_session_keygroup_sessions_per_userTthread_sessions_per_userFrGrHz:media:)gateway.sessionrFrrrr$rr)rrgrFrs ra_media_batch_keyzFeishuAdapter._media_batch_key s555555'' L$(K$5$9$9:SUY$Z$Z%)[%6%:%:;UW\%]%]   @@e&8&>@@@rcrincomingc|j|jko9|j|jko)|j|jko|jj|jjkSr)rr2r3rrrrLs ra_media_batch_is_compatiblez(FeishuAdapter._media_batch_is_compatible sY  !X%: : G,0LL G&(*@@ G)X_-FF  rccK||}|j|}|!||j|<||dS|||s<||d{V||j|<||dS|j|j|j|j|j r%| |j |j |_ |j |_ |j r |j |_ ||dSr) rKrr$_schedule_media_batch_flushrO_flush_media_batch_nowr0rr1r_merge_captionrr)rrgr!rs rar=z"FeishuAdapter._enqueue_media_event sS##E**.22377  /4D ' ,  , ,S 1 1 1 F..x?? --c22 2 2 2 2 2 2 2/4D ' ,  , ,S 1 1 1 F""5#3444##E$5666 : K // uzJJHM"_   3"'"2H  ((-----rcr!cH||j||jdSr)_reschedule_batch_taskr_flush_media_batchrr!s rarQz)FeishuAdapter._schedule_media_batch_flush s3 ##  +   #     rccKtj} tj|jd{V||d{V|j||ur|j|ddSdS#|j||ur|j|dwwxYwr)r current_taskror:rRrr$rh)rr!rYs rarVz FeishuAdapter._flush_media_batch! s+--  ?- ?@@ @ @ @ @ @ @ @--c22 2 2 2 2 2 2 2.22377<GG/33C>>>>>HGt.22377<GG/33C>>>>Hs :B :CcK|j|d}|sdStd|t |j||d{VdS)Nz6[Feishu] Flushing media batch %s with %d attachment(s))rrhrtrr(r0rrr!rgs rarRz$FeishuAdapter._flush_media_batch_now* s+//T::  F D   ! !   ..u55555555555rccbK||d}t||d{VS)NrJrr_)_guess_remote_extensionr?)rrCr_s rarEz$FeishuAdapter._download_remote_image5 sC**9f*EE))==========rcfile_urlrIrJrHcKddlm}||std|ddddl}|dd4d{V}||dd d  d{V}|t|jd d }|j } dddd{Vn#1d{VswxYwY| ||||} t| | } | | fS)Nr) is_safe_urlz&Blocked unsafe URL (SSRF protection): Pg>@T)rfollow_redirectsz)Mozilla/5.0 (compatible; HermesAgent/1.0)z*/*)z User-AgentAcceptheaders Content-Typer) content_type default_namerI) tools.url_safetyrarahttpx AsyncClientr$raise_for_statusrrfr_derive_remote_filenamer>) rr_rIrJrarkrrcontent_type_hdrr4filename cached_paths rarKz'FeishuAdapter._download_remote_document9 s 100000{8$$ WUhsPRsmUUVV V $$TD$II $ $ $ $ $ $ $V#ZZ"M#(H  % % ' ' ' #8#3#7#7#K#KLL #D $ $ $ $ $ $ $ $ $ $ $ $ $ $ $ $ $ $ $ $ $ $ $ $ $ $ $// )'# 0   0h?? H$$sA$C CCrct|pddddj}|tt zt zttzvr|n|S)Nr?rr) rr@suffixr_IMAGE_EXTENSIONS_AUDIO_EXTENSIONS_VIDEO_EXTENSIONSrr=)rr]r_s rar^z%FeishuAdapter._guess_remote_extension] soCI2$$S!,,Q/007==??/2CCFWWZ]^vZwZwwxxssF Frcrhricvt|pddddjp|}t|j}|s^t j|pddddpdp|}||}|S)Nrrsrr;)rr@rrtr mimetypesguess_extensionr:)r_rhrirIrr_guesseds rarnz%FeishuAdapter._derive_remote_filenameb s(.b//Q77:;;@PL 9oo$**,, 0/1C0J0J3PQ0R0RST0U0[0[0]0]0c0c0e0e0kikll{p{G$/g//Ircrct|tr(tdid|DSt|tr d|DS|S)NcJi|] \}}|t|!Sr]r_namespace_from_mapping)r^r!rs rarbz9FeishuAdapter._namespace_from_mapping..n s0%v%v%v[d[^`dc=+P+PQU+V+V%v%v%vrccBg|]}t|Sr]rrs rar*z9FeishuAdapter._namespace_from_mapping..p s&RRRDM99$??RRRrcr])rFrr rrrs rarz%FeishuAdapter._namespace_from_mappingk sq eT " " x"ww%v%vhmhshshuhu%v%v%vww w eT " " SRRERRR R rcrc: Kt|ddpd}|jd|jd|}||sGtd|||dtjddSt|d ipi}t| d d pd  d d  }|rN|dkrHtd||||dtjddSt|dd}|S|tkrHtd||||dtjddS tj|t$d{V}n#tj$rPtdt$|||dtjddcYSt($r2||dtjddd d!cYSwxYwt-|tkrUtd"t-||||dtjddS t/j|d#}nK#t.jt6f$r2||dtjdd$d d!cYSwxYw|jr| d%pi} t| d&p| d&pd } | rt;j| |jsGtd'|||d(tjd)d*S| d+d,kr*tjd-| d-d iS|jrb| |j!|sGtd.|||d/tjd)d0S| d1rIt"d2||d3tjdd4d d!S|#|t| d%pi d5pd } |$|} | d6kr|%| n| d7kr|&| n| d8kr|'| n| d9kr|(| n| d:vr|)| | nq| d;kr|*| nU| d| pdtjd d?d S)@NremoterUrz+[Feishu] Webhook rate limit exceeded for %s429izToo Many Requests)rrrfrgrryrapplication/jsonz=[Feishu] Webhook rejected: unexpected Content-Type %r from %s415izUnsupported Media Typecontent_lengthz2[Feishu] Webhook body too large (%d bytes) from %s413izRequest body too largerz6[Feishu] Webhook body read timed out after %ds from %s408izRequest Timeout400izfailed to read body)r?r)rz6[Feishu] Webhook body exceeds limit (%d bytes) from %sutf-8z invalid jsonr1rz=[Feishu] Webhook rejected: invalid verification token from %sz 401-tokenizInvalid verification tokenrurl_verification challengez4[Feishu] Webhook rejected: invalid signature from %sz401-sigzInvalid signatureencryptzL[Feishu] Encrypted webhook payloads are not supported by Hermes webhook modez 400-encryptedz,encrypted webhook payloads are not supportedrzim.message.receive_v1zim.message.message_read_v1zim.chat.member.bot.added_v1zim.chat.member.bot.deleted_v1>rBrIzcard.action.triggerrJrKz([Feishu] Ignoring webhook event type: %sok).r r'r=_check_webhook_rate_limitrtrr"rResponserr$r@r:r_FEISHU_WEBHOOK_MAX_BODY_BYTESrrr/$_FEISHU_WEBHOOK_BODY_TIMEOUT_SECONDSrrs json_responser(rmrdecoderUnicodeDecodeErrorr,hmaccompare_digestr+_is_webhook_signature_validrfrr$rrPrNrVrXrDrTr^r_ru) rrrrate_keyrfrhr body_bytesrr1incoming_tokenrrFs ra_handle_webhook_requestz%FeishuAdapter._handle_webhook_requests s"Wh55B lEET%7EE)EE--h77 F NNH) T T T  ( (E : : :>> NNZ\hjs t t t  ( (E : : : > >I?0'LAM M rfrbytesc4t|ddpd}t|ddpd}t|ddpd}|r|r|sdS |dd}|||j|}t j|d}tj ||S#t$r t d d YdSwxYw) aVerify Feishu webhook signature using timing-safe comparison. Feishu signature algorithm: SHA256(timestamp + nonce + encrypt_key + body_string) Headers checked: x-lark-request-timestamp, x-lark-request-nonce, x-lark-signature. zx-lark-request-timestamprzx-lark-request-noncezx-lark-signatureFrr;)errorsz3[Feishu] Signature verification raised an exceptionTrm) rr$rr+hashlibsha256encode hexdigestrrrsrtru) rrfrrnoncerVbody_strrcomputeds rarz)FeishuAdapter._is_webhook_signature_valid s0 $>CCIrJJ GKK 6;;ArBB $6;;ArBB   Y 5 !(((CCH"HEH4+<HhHHG~gnnW&=&=>>HHJJH&x;; ;    LLNY]L ^ ^ ^55 s9A3C--&DDrctj|j|}|1|\}}|z tkr|tkrdS|dz|f|j|<dSt |jt krzfd|jD}|D] }|j|= ||jvr?t |jt kr"t dt dSdf|j|<dS)u*Return False when the composite rate_key has exceeded _FEISHU_WEBHOOK_RATE_LIMIT_MAX. The rate_key is composed as "{app_id}:{path}:{remote_ip}" — matching openclaw's key structure so the limit is scoped to a specific (account, endpoint, IP) triple rather than a bare IP, which causes fewer false-positive denials in multi-tenant setups. The tracking dict is capped at _FEISHU_WEBHOOK_RATE_MAX_KEYS entries to prevent unbounded memory growth. Stale (expired) entries are pruned when the cap is reached. NFrTc<g|]\}\}}|z tk|Sr])#_FEISHU_WEBHOOK_RATE_WINDOW_SECONDS)r^k_rrs rar*z;FeishuAdapter._check_webhook_rate_limit..s; a!R8BBBBBBrcuQ[Feishu] Webhook rate-limit table at capacity (%d keys) — denying untracked key) rnrr$r_FEISHU_WEBHOOK_RATE_LIMIT_MAXr(_FEISHU_WEBHOOK_RATE_MAX_KEYSrrtr)rrrr window_start stale_keysrrs @rarz'FeishuAdapter._check_webhook_rate_limit s?ikk)--h77  "' E<\!$GGG::: 57Only merge text events when reply/thread context is identical.)r2r3rrrNs ra_text_batch_is_compatiblez'FeishuAdapter._text_batch_is_compatible#sC  (H,H H G&(*@@ G)X_-FF rccK||}t|jpd}|j|}|2||_||j|<d|j|<||dS|||sF| |d{V||j|<d|j|<||dS|j|d}|dz}|jpd}|jr|r |jd|n|jp|}||j kst||j krF| |d{V||j|<d|j|<||dS||_||_|j |_ |j r |j |_ ||j|<||dS)z=Debounce rapid Feishu text bursts into a single MessageEvent.rNrr8)rr(rrr$_last_chunk_lenr_schedule_text_batch_flushr_flush_text_batch_nowr8r9rr) rrgr! chunk_lenrexisting_count next_count appended_text next_texts rar;z!FeishuAdapter._enqueue_text_event,s)""5)) (b)) -11#66  $-E !.3D &s +34D +C 0  + +C 0 0 0 F--h>> ,,S11 1 1 1 1 1 1 1.3D &s +34D +C 0  + +C 0 0 0 F8<044S99GAHOww(91===aH4000<6-&& & & & & & & &,,S11 1 1 1 1 1 1 1-11#66,FF.223=====GFt-11#66,FF.223====Gs A>C:D cK|j|d}|j|d|sdStd|t |jpd||d{VdS)z,Dispatch the current text batch immediately.Nz*[Feishu] Flushing text batch %s (%d chars)r)rrhrrtrr(rrr[s rarz#FeishuAdapter._flush_text_batch_now{s*..sD99 '++C666  F 8    b ! !   ..u55555555555rcEtuple[str, MessageType, List[str], List[str], List[FeishuMentionRef]]c Kt|ddpd}t|ddpd}tt|ddpd}td||t ||t|dd|}|||d{V\}}|||}|j} |tj tj tj tj hvrHt|d kr5|jd vr,||d |d d{V} | r| } | |||t#|jfS) Nrrrrz3[Feishu] Received raw message type=%s message_id=%srrrrr )rrr>rrr)r rrtrr _bot_identity"_download_feishu_message_resources _resolve_normalized_message_typerr:rBrCrAr@r(r_maybe_extract_text_documentrr) rrdrrrrr0r1r7rinjecteds rar4z&FeishuAdapter._extract_message_contentsgy"55; 7NB77=2,;;ArBB  I8U_```-!#Wj$77""$$    )-(O(O!!)P) ) # # # # # #  K<>z!}kZ[n]]]]]]]]H \:{DAT !# !# #. / /I,0,G,G%#-H--'''''' #K /!!+..."":...#. / /I,0,R,R%"+'5"+"5 -S--'''''' #K  /!!+..."":...;&&rcrr:c|pd}|dr tjS|dr tjS|dr tjS|S)Nrimage/audio/video/)rr0r:r@rCrA)rr]rs ra_resolve_media_message_typez)FeishuAdapter._resolve_media_message_typesz &B--//   * * %$ $   * * %$ $   * * %$ $rcr1rcN|j}|dkr+||r|dndtjS|dkr+||r|dndtjS|dkr+||r|dndtjStjS)Nrrrrrr)rrr:r@rCrBr)rrr1 preferreds rarz.FeishuAdapter._resolve_normalized_message_types 5   33k4YKNNWYcnct3uu u   33k4YKNNWYcnct3uu u  " "33k4YKNNWYcncw3xx xrcrqcK|r|dsdS tj|tkrdSt |j}|dvr|dvrdSt |d}| |}d|d|S#ttf$r!t d |d YdSwxYw) Nztext/r>.md.txt> text/plain text/markdownrencodingz [Content of z]: z7[Feishu] Failed to inject text document content from %sTrm)r0rr,getsize_MAX_TEXT_INJECT_BYTESrrtr read_text_display_name_from_cached_pathOSErrorrrtr)rrqrr_rrs rarz*FeishuAdapter._maybe_extract_text_documents  *"7"7"@"@ 2 w{++.DDDr{##*0022C/))j@_._._r;''1171CCG>>{KKL=,==G== =+,    NNTValpN q q q22 s(B7.B77?B77.C)(C)rc K|jr|sdS |||d}||jjjjj|d{V}|r|s=t d|t|ddt|dddS| |}|sdS| |d }t|d dp|d }| ||d t }t|| } ||||} | | fS#t$$r!t d|dYdSwxYw)NrLrrrrz+[Feishu] Failed to download image %s: %s %sr?rUrrequest failedrgrrJallowedr]rz*[Feishu] Failed to cache image resource %sTrm)r_build_message_resource_requestrsrrmessage_resourcer$rrtrr _read_binary_response_get_response_header_guess_extensionrurA_normalize_media_type_default_image_media_typers) rrrrr raw_bytesrhrpr_rqrs rarz$FeishuAdapter._download_feishu_images| : 6 ::%"%;G "// 0B0S0WY`aaaaaaaaH 8#3#3#5#5 AHfi88He-=>>  v228<t d|||t|ddt|dd | |} | s| |d } t|d dpd } | p|p|d |} || || } | dre|| | dt$}t'| |}td||| p||fcS|dks| drj|| | dt,}t/| |}td||| pd|dpdfcS| drJt3| js| d} t7| | }td||| fcSt3| js| t8vr| t8| } t7| | }td||| p|| fcS#t<$r"td||d YwxYwdS)!NrL>rrrrz>[Feishu] Resource download failed for %s/%s via type=%s: %s %sr?rUrrrgrrrrrrJrr]z,[Feishu] Cached message image resource at %srrrQz,[Feishu] Cached message audio resource at %sroggrr[z,[Feishu] Cached message video resource at %sz/[Feishu] Cached message document resource at %sz/[Feishu] Failed to cache message resource %s/%sTrm) rrxrrsrrrr$rrtrur rrr_guess_media_type_from_filenamer0rrurArrrvr@rZrrtr>_DOCUMENT_MIME_TO_EXT_guess_document_media_typersr)rrrrr request_types request_typerrrrhresponse_filenamerprr_rqs rarz/FeishuAdapter._download_feishu_message_resources| : 6& . . .   ( ( ()< < L; >>)%".? "&!3!3DLO4F4W4[]d!e!eeeeeee x'7'7'9'9 LLX" $&)<<%1ABB  66x@@  #88>RR $+Hk4$H$H$NB!,a0Aa EaEaW_EaEa!77  @@JJ8 ((22Z//,Xi/jjC"8"L"L"LKKK NP[\\\& (Yd6T6TUX6Y6YYYYY7**j.C.CH.M.M*//,Xi/jjC"8"L"L"LKKK NP[\\\&)Z7Z 3@XSX7Z7Z[[[[((223>>05&.#4#4#4";Ix"P"PKKK NP[\\\& 2222H~~,P?T1T1T"*O,A*,MOOH7 8LL  M{[[["Z%\43R3RS[3\3\]]]]   E!  vs4B LL)CLBLAL%A1L(MMrct|dd}|dSt|dr!t|St|S)Nrrcgetvalue)r rrrr/)rfile_objs rarz#FeishuAdapter._read_binary_responsees`8VT22  3 8Z ( ( .**,,-- -X]]__%%%rcrc \t|dd}t|dipi}t||||dpddddS)Nrrfrryrr)r rr$rr@r:)rrrrfs rarz"FeishuAdapter._get_response_headernsht,,#y"--37;;tW[[r%B%BCCIrJJPPQTVWXXYZ[aacciikkkrcrprrct|pdj}||vr|Stj|pddddpd}||vr|S|SNrryrr)rrtrrzr{r@r:)rprhr]rr_r|s rarzFeishuAdapter._guess_extensionts8>r"")//11 '>>J+\-?R,F,FsA,N,Nq,Q,W,W,Y,Y,_,_,a,a,geghh g  Nrcc|pdddd}|p|Sr)r@r:r)rhr]rs rarz#FeishuAdapter._normalize_media_type~sD"(b//Q77:@@BBHHJJ $W$rcct|pdj}tj|t j|pddpdS)Nrrzapplication/octet-stream)rrtrr=r$rz guess_type)rpr_s rarz(FeishuAdapter._guess_document_media_typesQ8>r"")//11'+C1EhnRT1U1UVW1X1v\vwwwrcr,ctj|}|dd}t |dkr|dn|}t jdd|S)NrrSrjz [^\w.\- ])rr,r1r@r(r.r)r,r1rrs rarz,FeishuAdapter._display_name_from_cached_pathsY7##D))sA&&#&u::??uQxx vlC666rcctj|pddpd}|r|St|pdj}|t vrd|dS|tvrd|dS|tvrt |SdS)Nrrrrr) rzrrrrtrwrZrvrurr)rpr|r_s rarz-FeishuAdapter._guess_media_type_from_filenames'B77:@bGGII  N8>r"")//11 # # #-CJJsOO-- - # # #-CJJsOO-- - # # # ::3?? ?rrcrXc|pd}|dkrdSd|vsd|vsd|vrdS|dkrdSdS)NrrwrOtopicthreadforumrU)r:r)rXrs rarUzFeishuAdapter._map_chat_typesm#)r002288::   4 j H $:$:g>S>S7  7trcrrct|dpd}|dvr|S|dkrdSdS)Nrr>rrUrwrOrU)rr$r:r)rrrs rarz'FeishuAdapter._resolve_source_chat_types^y}}V,,23399;;AACC ) ) )O e # #4wrcDict[str, Optional[str]]cKt|ddpd}t|ddpd}t|ddpd}|p|}|r|n|p|}|||d{V}|||dS)uCMap Feishu's three-tier user IDs onto Hermes' SessionSource fields. Preference order for the primary ``user_id`` field: 1. user_id (tenant-scoped, most stable — requires permission scope) 2. open_id (app-scoped, always available — different per bot app) ``user_id_alt`` carries the union_id (developer-scoped, stable across all apps by the same developer). Session-key generation prefers user_id_alt when present, so participant isolation stays stable even if the primary ID is the app-scoped open_id. rNrrr)rrr)r _resolve_sender_name_from_api) rrrxrrr primary_idname_lookup_idrs rarz%FeishuAdapter._resolve_sender_profiles")Y55=)Y55=9j$77?4' $*H1Gx!?? 6@        "%#   rcc|sdS|j|}|dS|\}}tj|kr|S|j|ddS)z>Return a cached sender name only while its TTL is still valid.N)rr$rnrh)rrrWr expire_ats rarz%FeishuAdapter._get_cached_sender_namesl 4(,,Y77 >4 i 9;; " "K ##It444trccK|r|jsdS|}|sdStj}||}||pdS|rx||gd{V}|dS|t z}|D]\}} | |f|j|<|j|} | r | dpdndS ddl m } | drd} n| drd} nd} | || } ||jjjjj| d{V}|r|sdSt+t+|d dd d}t+|d dp2t+|d dp!t+|d dpt+|dd} | rAt-| t.r,| } | r| |t zf|j|<| Sn-#t0$r t2d|dYnwxYwdS)uBots divert to bot/basic_batch — contact API doesn't return bot names. Failures are silent so the pipeline never blocks on name resolution. Nr)GetUserRequestou_ron_rrrFrrrnicknameen_namez-[Feishu] Failed to resolve sender name for %sTrm)rr:rnr_fetch_bot_names_FEISHU_SENDER_NAME_TTL_SECONDSrrr$lark_oapi.api.contact.v3rr0rLr user_id_typer`rscontactv3rrr rFrrsrtru)rrrxtrimmedr cached_namenamesroidrhitrrKrrrs rarz+FeishuAdapter._resolve_sender_name_from_apis   4//## 4ikk227;;  "&$ &  5// ::::::::E}t==I"[[]] A A T04i/@',,)--g66C'*4CFNd 4 d ? ? ? ? ? ?!!%(( $###E** $$#$,,..66w??LLWUU[[]]G!// 0D0G0L0PRYZZZZZZZZH 8#3#3#5#5 t78VT::FDIIDfd++246624T2224D11   4-- zz|| 8c7dD+G4K d d d LLH)^bL c c c c c dtsCI B&I'I21I2bot_idsOptional[Dict[str, str]]c K|jr|sdS tjtjdd|Dtj h }| |jj |d{V}tt|dddd}|sdStj|}|ddkrdS|dpidpi}d |DS#t&$r!t(d |d YdSwxYw) Nz"/open-apis/bot/v3/bots/basic_batchcg|]}d|fS)r(r])r^r&s rar*z2FeishuAdapter._fetch_bot_names..s>>>s9c*>>>rcrrr?rrFbotsci|]>\}}||t|dpd?S)rr)rr$r:)r^r&rs rarbz2FeishuAdapter._fetch_bot_names..*sYCS&))/R006688rcz)[Feishu] Failed to fetch bot names for %sTrm)rr.rL http_methodr)GETuriqueries token_typesr(TENANTr`rsrr rmrr$rrsrtru)rr(reqresprrr,s rarzFeishuAdapter._fetch_bot_namess| 7 4 #%%Z^,,9::>>g>>>??o4566 ++DL,@#FFFFFFFFDgdE488)TJJG tj))G{{6""a''tKK''-2226::@bD!%      LLDgX\L ] ] ]44 sCE")-E"A E""'F  F cK|jr|sdS||jvr'|j||j|S ||}||jjjjj|d{V}|rt|dddurAt|dd}t|dd}t d|||dStt|d dd dpg}|r|d nd}t|d d}t|d dpd} t|ddpd} |rt|ddnd} | | | | } | |j|<t|jtkr8|jdt|jtk8| S#t $r!t d|dYdSwxYw)NrcdSr#r]r]rcrarWz3FeishuAdapter._fetch_message_text..<rQrcFr?rUrzmessage lookup failedz3[Feishu] Failed to fetch parent message %s: [%s] %srFrrr4rrrr)rrrr z*[Feishu] Failed to fetch parent message %sTrm)rrrrrsrrrdr$r rtr_extract_text_from_raw_contentr(_FEISHU_MESSAGE_TEXT_CACHE_SIZEr rs) rrrrr?rrparentr4rrparent_mentionsrs rar5z!FeishuAdapter._fetch_message_text3sS| : 4 1 1 1  $ 0 0 < < <+J7 7 55jAAG!// 0B0J0NPWXXXXXXXXH JwxMMJJLLPUUUx;;h/FGGTV`bfhkllltGHfd;;WdKKQrE!&0U1XXDF66400Dvz266<"H!$ 266<"KCISgfj$???tO66!'(7D 48D $Z 0d.//2QQQ(00e0<<<d.//2QQQK    NNG^bN c c c44 sB'G(C2G'HH)rrrrrct||||}|jr|jSt|jt r|jdnd}t|pdS)Nrr) rrrrFrrr$rr:)rrrrrrs rar8z,FeishuAdapter._extract_text_from_raw_contentTs.!#""$$     " +* *EOPZPceiEjEjtj)--.@AAApt ;%%''/4/rcr_cn|pd}|dvrdSd|dpdS)Nr>rJrLz image/jpegrrjpeg)rrZ)r_normalized_exts rarz'FeishuAdapter._default_image_media_typefsI)**,, . . .<>--c22>>rcrc |dS#t$rtdYdSwxYw)Nz-[Feishu] Background inbound processing failed)rRrsrt exception)rs rarz%FeishuAdapter._log_background_failuremsV N MMOOOOO N N N   L M M M M M M Ns$AArOptional[RejectReason]cBt|}td|j|jfD}t |}t |dddk}t |ddpd}|o||}|r||zrdS|r:|j} | dkr| dkrd S|r|sd S| dkr|s||sd S|stj d d d vrdStj dd d vrdS|j sdS|r ||j zsdSdS|t |dd||sdS|r||sdSdS)Nc3K|]}||V dSrr]rs rarz'FeishuAdapter._admit..zs(TT1RSTQTTTTTTrcrRrwrrrrrrrrFEISHU_ALLOW_ALL_USERS>1r rGATEWAY_ALLOW_ALL_USERSdm_policy_rejectedrrr)rrr2r3r r _require_mention_forr>_mentions_selfrrr:rr.r) rrrd sender_idsself_idsrxis_grouprrmodes rarzzFeishuAdapter._admitxs%f-- TT):D>DDFFJ^^^ty2B77==??EEGGK___t, t ,J1J$J ,++4(( FK . .)   ++*  +4#6#6w#?#? +**trccl|r|j|nd}|r|j|jS|jSr)r1r$rr?)rrrules rarIz"FeishuAdapter._require_mention_forsD18Bt $$W---d  (D(4' '$$rcct|dd}t|dd}||hdhz }|r|jr ||jzrdS|r|j|nd}|r|j}|j} |j} n#|jp|j}|j } t} |dkrdS|dkrdS|dkrdS|rdS|d krt|o|| zS|d krt|o|| z St|o ||j zS) z)Per-group policy gate for non-DM traffic.rNrTdisabledFr admin_onlyrr) r r/r1r$rrrr0r-r.rr) rrrrxsender_open_idsender_user_idrKrPrrrs rarz"FeishuAdapter._allow_group_messages^!It<< It<<$n5>  $, J,E 418Bt $$W---d  [FIII/E43EF1II Z  5 V  4 \ ! !5  4 [  ? Y(>@@ @ [  CJ,B'CDD DJKJ1J$JLLLrcc Jt|ddpd}d|vrdSt|ddpg}|r||rdStt|ddpd|t|dd|}||jS)NrrrTrrr)r _message_mentions_botrr_post_mentions_botr)rrdrrrs rarJzFeishuAdapter._mentions_selfsgy"55; k ! !47J55;  228<< 4- ."==C#Wj$77""$$    &&z':;;;rc List[Any]c|D]}t|dd}t|ddpd}t|ddpd}t|ddpd}|r|jr||jkrdS|r|jr||jkrdS|jr||jkrdSdS)NrJrrrrTF)r r:r2r3r4)rrrGrMmention_open_idmention_user_id mention_names rarWz#FeishuAdapter._message_mentions_bots   G $55J&z9dCCIrPPRRO&z9dCCIrPPRRO#GVT::@bGGIIL 4#4 "d&77744 4#4 "d&77744~ ,$."@"@tturcrc4td|DS)Nc3$K|] }|jV dSr)r)r^rVs rarz3FeishuAdapter._post_mentions_bot..s$//19//////rc)any)rrs rarXz FeishuAdapter._post_mentions_bots//h//////rcrcDt|j|j|jS)NrQ)rr2r3r4ras rarzFeishuAdapter._bot_identitys*!%%    rccK|jsdS tjtjdtj h }| |jj |d{V}tt|dddd}|rtj|}t!|pi}|dpd}|dpd}|r3|jr%|j|krt(d||_|r3|jr%|j|krt(d ||_n,#t0$rt(d d YnwxYw|jrdS ||jd }| |jjjjj|d{V} | r| s3t| dd} | dkrt(ddStt| dddd} t| ddpd} | r|js | |_dSdSdS#t0$r t(dd YdSwxYw)aPBest-effort discovery of bot identity for precise group mention gating and self-sent bot event filtering. Populates ``_bot_open_id`` and ``_bot_name`` from /open-apis/bot/v3/info (no extra scopes required beyond the tenant access token). The probe always runs when a client is available so stale env vars from app/bot migrations do not break group @mention gating. Falls back to the application info endpoint for ``_bot_name`` only when the first probe doesn't return it. If the probe fails, env-provided values are preserved. N/open-apis/bot/v3/inforrrrrz[[Feishu] FEISHU_BOT_OPEN_ID is stale; using /bot/v3/info open_id for group @mention gating.zf[Feishu] FEISHU_BOT_NAME differs from /bot/v3/info; using hydrated bot name for group @mention gating.z3[Feishu] /bot/v3/info probe failed during hydrationTrmrrrKr?ixz[Feishu] Unable to hydrate bot name from application info. Grant admin:app.info:readonly or application:application:self_manage so group @mention gating can resolve the bot name precisely.rFr app_namez9[Feishu] Failed to hydrate bot name from application info)rr.rLr.r)r/r0r2r(r3r`rsrr rmr_parse_bot_responser$r:r2rtrr4rrsru_build_get_application_requestr' applicationv6r) rr4r5rrrcrrrrr?r res ra_hydrate_bot_identityz#FeishuAdapter._hydrate_bot_identity s\|  F  #%%Z^,,-..o4566 ++DL,@#FFFFFFFFDgdE488)TJJG .*W--,W55;!::m44:AACC"JJz228b??AA0(T->'-I-Iy)0D%.~$.H*D*D E&.DN    LLE        >  F e99T[9\\G!// 0H0K0W0[]deeeeeeeeH 8#3#3#5#5 x668##NNW '(FD995$GGCZ66<"CCEEH * *!) * * * * e e e LLT_cL d d d d d d es,FF**&GG BK:AK&K?>K?c tj|jd}nK#t$rYdSt tjf$r&td|jdYdSwxYwt|tr| dini}tj tt|tr d|D}nt|trqi}|D]Y\}}t|t r|s/ t%|||<C#t&t(f$rYVwxYwndSfd|D t+ fd d d|j}tt/||_ fd |D|_dS) Nrrz5[Feishu] Failed to load persisted dedup state from %sTrm message_idsci|]E}t|#t|dFS)rmrrs rarbz8FeishuAdapter._load_seen_message_ids..hsE(k(k(kDY\]aYbYbYhYhYjYj(kT):):C(k(k(krccFi|]\}}|dksdks |z k||S)rmrr])r^msg_idrrttls rarbz8FeishuAdapter._load_seen_message_ids..vsD# # # %62SyyC1HHb3 B(6rcc|Srr])rvalids rarWz6FeishuAdapter._load_seen_message_ids..{s qrc)r!reversec"i|] }|| Sr]r])r^rrrs rarbz8FeishuAdapter._load_seen_message_ids..}s!B!B!B!!U1X!B!B!Brc)rmrrrFileNotFoundErrorrrrtrrFrr$rn_FEISHU_DEDUP_TTL_SECONDSrrrr:rr`rasortedr5reversedrr) rr seen_datarr!r sorted_idsrrprrs @@@rarz$FeishuAdapter._load_seen_message_ids[s. j!7!A!A7!A!S!STTGG     FF-.    NNRTXTjuyN z z z FF 7A$6O6OWGKK r222UW ikk' i & & (k(kI(k(k(kGG  4 ( ( G'oo//   U!#s++399;;#(<i|]}|jv |j|Sr])r)r^rrs rarbz;FeishuAdapter._persist_seen_message_ids..s2&s&s&sWX\`\rWrWrq$*@*CWrWrWrrc)indentz,[Feishu] Failed to persist dedup state to %srm) rr:mkdirrr5rErrtr)rrecentrs` rarz'FeishuAdapter._persist_seen_message_idss r  " ) / /t / L L L-t/E.E.F.FGF$&s&s&s&sV&s&s&stG d4gd K K K K K K r r r NNI4KalpN q q q q q q rsAA"",BBc<tj}t}|j5|j|}||dks ||z |kr ddddS||j|<|j|t|j|jkrR|j d}|j |dt|j|jkR|  ddddS#1swxYwYdS)NrTF) rnrvrrr$rrxr(r5rhr)rrrrpseen_atstales raryzFeishuAdapter._is_duplicates|ikk'    ,00<@RSS S = = = LL> 3Y]L ^ ^ ^e3s88<<< < < < < < < =sJ GA#D = G D  GD 2GB G H;HHHrc &K|}|s,|r*|dr|d}t|pid}|r||||tt j}|||} ||jj j j j | d{VS|pid} | rN| | ||tt j}|d|} n|} d} |dr|ddd} d } n|d rd } | | ||tt j}|| |} ||jj j j j| d{VS) Nrr2rrreply_in_thread uuid_value receive_idrrrrzfeishu_user_id:rrrrr)r$r_build_reply_message_bodyrrr_build_reply_message_requestrsrrrrdreply_build_create_message_body_build_create_message_requestr0r@r5) rrrrrreffective_reply_torr4r _thread_idrreceive_id_types ra_send_raw_messagezFeishuAdapter._send_raw_messages9&! Eh E8<< 3L3L E!).C!D!D B33K@@AA  W11! /tz||,, 2D 778JDQQG++DLO,>,F,LgVVVVVVVV V n"))+66  P22%!tz||,, 3D 88dKKGG J'O!!"344 ,$]]32215 "+##E** ,"+22%!tz||,, 3D 88$OOG'' (:(B(I7SSSSSSSSSrccTt|ot|ddS)NrcdSr#r]r]rcrarWz3FeishuAdapter._response_succeeded.. sercr)rs rarz!FeishuAdapter._response_succeededs,HN!L9mm!L!L!N!NOOOrc field_namect|sdSt|dd}|rt||dndS)NrF)rrr )rrrFs rar6z%FeishuAdapter._extract_response_field"sJ00:: 4x..26@wtZ...D@rc)r)r(r)c|rtd||St|dd}t|d|}tdd|d||S)NF)rr raw_responser?rUrrz] )r<r )rrr(r)r?rs rar7z$FeishuAdapter._response_error_result)sk  Ze>PXYYY Yx33h77%/@4/@/@3/@/@xXXXXrcc||s|||Std||d|S)N)r(Tr)rrr)rr7r<r6)rrr(s rarz#FeishuAdapter._finalize_send_result6sb''11 Z..x.YY Y33HlKK!    rcc  KttD]} |jdkr|d{Vn|d{VdS#t $r}d|_|d|_| d{V|tdz krd|z}t d|dzt||tj |d{VYd}~d}~wwxYwdS)NrFrrSz:[Feishu] Connect attempt %d/%d failed; retrying in %ds: %s)range_FEISHU_CONNECT_ATTEMPTSr*_connect_websocket_connect_webhookrsrrrrrtrrro)rattemptr wait_secondss rarz!FeishuAdapter._connect_with_retryCsi566 2 2G 2(K77113333333333//111111111 2 2 2 % 66888"&//1111111116::: G| PaK,  mL11111111111111 2 2 2sAA D'BC<<DcBKtstd|jdkrtnt}|||_||_|jtd|j }|| rtd| d{Vt|j |jtjj|j||_|dt(|j||_dS)Nz4websockets not installed; websocket mode unavailabler$failed to build Feishu event handlerzadapter loop is not ready)rrr event_handlerr)FEISHU_WEBSOCKET_AVAILABLErr)r+r,_build_lark_clientrrbrrrrjrr'r(rLogLevelINFOrrqrr)rrrs rarz FeishuAdapter._connect_websocket\s) WUVV V"&"3v"="=;..v66 "7799   &EFF Fz <4>>++<:;; ;((*********(<'m(-    ..  * O    rccKtstd|jdkrtnt}|||_||_|jtd| d{Vtj }|j |j|jtj||_|jd{Vtj|j|j|j|_|jd{VdS)Nz/aiohttp not installed; webhook mode unavailablerr)FEISHU_WEBHOOK_AVAILABLErr)r+r,rrrbrrjr Applicationrouteradd_postr=r AppRunnerrsetupTCPSiter;r<rr)rrr s rarzFeishuAdapter._connect_webhookvsJ' RPQQ Q"&"3v"="=;..v66 "7799   &EFF F((*********o D.0LMMM"}S11"((********* [)=t?QSWSeff &&(((((((((((rcrc,tj|j|j|tj j  Sr) rr5rLrr'rr(rrrrr`)rrs rarz FeishuAdapter._build_lark_clients] K   ! ! VDL ! ! Z( ) ) VF^^ Yt}, - - UWW  rcc \Kd}|}ttD]} ||||||d{V} |r|| st | dd} | t vr|pidr6td||pid| | cStd|| |d}||||d|d{V} | cS#t$r} | }|dkr(t t| r|tdz krd|z} td |dzt|| | tj| d{VYd} ~ zd} ~ wwxYw|ptd ) Nrr?ru[Feishu] Reply to %s failed in thread %s (code %s — message withdrawn/missing); skipping top-level fallback to avoid creating a new topicuk[Feishu] Reply to %s failed (code %s — message withdrawn/missing); falling back to new message in chat %srrrSzC[Feishu] Send attempt %d/%d failed for chat %s; retrying in %ds: %szFeishu send failed)r_FEISHU_SEND_ATTEMPTSrrr _FEISHU_REPLY_FALLBACK_CODESr$rtrrsrrrrror) rrrrrr last_erroractive_reply_torrr?rrs rarz%FeishuAdapter._feishu_send_with_retrysk+/ "2336 26 2G5 2!%!7!7#%#,% "8""#4+C+CH+M+M"8VT::D;;;$N// <<,"NN!\ /!)R 4 4[ A A $ $,OOOE+ # +/)-)?)?$+%-$+%)%- *@**$$$$$$  2 2 2 v%%*B*I*I#c((*S*S%3a777 G| YaK)  mL11111111111111 2 >L)=>>>s BD=AD F BFFcK|jsdS tt|jn4#t$r'}td|dYd}~nd}~wwxYwd|_dS#d|_wxYw)Nz'[Feishu] Failed to release app lock: %sTrm)rrCrrsrtr)rrs rarzFeishuAdapter._release_app_locks&  F +  68O P P P P Z Z Z NNDcTXN Y Y Y Y Y Y Y Y Z'+D # # #dD # * * * *s+(A% AAA%AA%% A.cdtvr8tj|St |S)Nrr)rrrLrr`r rs rarSz%FeishuAdapter._build_get_chat_requestsK wyy ( (!)++33G<<BBDD Dw////rccdtvr8tj|St |S)Nr r)rr rLrr`r rs rarz(FeishuAdapter._build_get_message_requestsK ')) + +$,..99*EEKKMM M*5555rccdtvr^tj|||St|||S)Nr!)rrr)rr!rLrrrr`r rs rarz-FeishuAdapter._build_message_resource_requestsi &')) 3 3)133J''(##m$$  *xm\\\\rcrrKcdtvrKtj||St ||S)Nrrd)rrrLrrKr`r rds rargz,FeishuAdapter._build_get_application_requestsV "gii / /%-//d   f48888rcrrc*dtvrqtj||||St||||S)Nr$)rrrr) rr$rLrrrrr`r rs rarz'FeishuAdapter._build_reply_message_bodys $ 1 1'/11!!(## 11j!!  +     rcrcdtvrKtj||St ||S)Nr#r)rr#rLrrr`r rs rarz*FeishuAdapter._build_reply_message_requestsZ GII - -#+--J''l++   *<PPPPrccdtvrKtj||St ||S)Nr&r)rr&rLrrr`r rs rarz(FeishuAdapter._build_update_message_body"sZ % 2 2(022(##!!   'BBBBrccdtvrKtj||St ||S)Nr%r)rr%rLrrr`r rs rarz+FeishuAdapter._build_update_message_request-sZ !WYY . .$,..J''l++   *<PPPPrcrc*dtvrqtj||||St||||S)Nr)rrrr) rrrLrrrrr`r rs rarz(FeishuAdapter._build_create_message_body8s % 2 2(022J''(##!!j!!  !     rcrcdtvrKtj||St ||S)Nrrr)rrrLrrr`r rs rarz+FeishuAdapter._build_create_message_requestJsZ !WYY . .$,.. 11l++   \ZZZZrcr&rcdtvrKtj||St ||S)Nrr%)rrrLr&rr`r r%s rar2z&FeishuAdapter._build_image_upload_bodyUsX #wyy 0 0&.00J''u   *EBBBBrccdtvr8tj|St |S)Nrr)rrrLrr`r rs rar4z)FeishuAdapter._build_image_upload_request`sK 799 , ,%-//<<\JJPPRR RL9999rcrcdtvr^tj|||St|||S)Nrr)rrrLrrrr`r rs rarz%FeishuAdapter._build_file_upload_bodyfsg "gii / /%-//9%%9%%d  idSSSSrccdtvr8tj|St |S)Nrr)rrrLrr`r rs rarz(FeishuAdapter._build_file_upload_requestrsK ')) + +$,..;;LIIOOQQ QL9999rcc t|Sr)rpr[s ra_build_post_payloadz!FeishuAdapter._build_post_payloadxs+G444rcr+ryctj||}|didg}||gtj|dSri)rmrr setdefaultrxrn)rrr+rrs rar8z'FeishuAdapter._build_media_post_payload{sm*T55g>>??$$Wb11< * * *+C0&8 8 !V + ++V3 3'//rc)rr7)rrrr)r%rrru)rr )rrcr|)ryrrr)rrrru)NN) rrrrrrrrrr<) rrrrrrrrrr<)rN) rrrrrrrrrrrr<)rrr]rrrrr)rrN) rrrrr]rrrrrrr<)rrrrrr)rrrrrr)rrrru)NNN) rrrrrrrrrrrr<)NNNN)rrrrrrrrrrrrrr<) rrrrrrrrrrrr<) rrr"rrrrrrrrr<r)rrrru) rrrCrrrrrrrrr<) rrrGrrrrrrrrr<)rrrrrrrr)rFr rru)rFr rr)rFr"rru)rrrFr rru)rFr rr )rr rr)rr rr rr)rrrr)rgr rrrr rr ) rr rrrrrrrrrru) rr rrrrrrrrrru)rrrr)rrrr)rgr9rrurr)rrrrrr)rrrrrr)rrrrrru)rrrr)rgr9rr;rru)rrrrrru)rrrru)rrr%r&rr&)rFr rdr rr rRrrrrxrrru)rgr9rr)rgr9rr)rr9rLr9rr)r!rrru)rCrrr)r_rrIrrJrrrH)rrr]rrr) r_rrhrrirrIrrr)rr rr )rr rr )rfr rrrr)rrrr)rrr!rrr rru)rdr rr)rrrrrr)rrr]r:rr:)rrr1rrr:)rqrrrrr)rrrrrrH) rrrrrrrrrrH)rr rr)rr rrrr) rprrhrr]rrrrr)rhrr]rrr)rprrr)r,rrr)rXrrr)rrrrrr)rr rxrrr)rrrr)rrrxrrr)r(rrr))rrrrrrrr)r_rrr)rr rru)rr rdr rrB)rrrr)r)rr rrrxrrr)rdr rr)rrYrr)rrrr)rr)rrrr)rrrrH)rrrrrrrrrrrrrrrr<) rrrrrrrrrrrr )rr rr)rr rrrr )rr r(rr)rrr<)rr r(rrr<)rr rr )rrrr )rrrr )rrrrrrrr )rrrKrrr ) rrrrrrrrrr )rrrr rr )rrrrrr ) rrrrrrrrrr )rrrr rr )r&rrr rr )rr rr )rrrrrr rr )rrr+ryrr)rrrrrrH)rrrrsupports_code_blockssplits_long_messagesrrrrr staticmethodrrrbrnrsrxrrrrrrrrrrrrr rrrr!r@rBrFrLrYrrPr`rbrdrNrVrXrZr\r^r_rDrTr_rcrrrrrrrrrrrrrrrrrr"r$rr{r6r<rKrOr=rQrVrRrErKr^rnrrrrrrr;rrUrrr4rrrrrrrrrrrrrrUrrrrrr5r8rrrzrIrrJrWrXrrjrrryrrrrr6r7rrrrrrrrSrrrgrrrrrrr2r4rrrr8r __classcell__)rs@rarrs""""""" <&<&<&<&<&<&|c c c \c J9999>    @0QQQ **** 5:333333jS-S-S-S-j,,,, ####&&&&"#'-1 7=7=7=7=7=~ !=!=!=!=!=!=J/-1D=D=D=D=D=L   \ B9;-1!=!=!=!=!=F   \ $    \  (((\("&"&-1      ."&#'"&-1     0"&"&-1      ."&"&-1 ;=;=;=;=;=z"&"&-1        @"&"&-1        D####JJJJJ(!!!!FM6M6M6M6^    :MMMM11111111@@@@::::    $MMMMRRRR8#-#-#-#-JZZZ\Z    ????6666p7777~$[$[$[$[$[$[X'L'L'L'L'L'LR;@;@;@;@z    1@1@1@1@n2 - - - - aaaa&&&&P<&&&&HHHHHHHHKKKK2CCCC4:::: B B B B B(P7P7P7P7P7P7d6666    AAAA   \ ....*    ???? 6 6 6 6>>>>"%"%"%"%HFFF\F\\b;b;b;b;H*''''Z       \ $-$-$-$-L    ;;;\;>>>>, 6 6 6 6"VVVV@''''>\      >LLLLd&&&\&lll\l \%%%\%xxx\x777\7    \ \\       B    " 555555n:L-1 000000$???\? NNN\N----^%%%%)M  )M)M)M)M)M)MZ<<<< .0000    HeHeHeHe\"C"C"C"CHrrrr( D D D D&"&#'%+>=>=>=>=>=>=@3T3T3T3TjPPP\PAAA\A)- Y Y Y Y Y Y    22222    4))))     B?B?B?B?H++++000\0 666\6  ] ] ]\ ]999\9   \ "QQQ\QCCC\CQQQ\Q   \ "[[[\[CCC\C:::\:  T T T\ T:::\: 55557777 000\00000rcrrcNt|tdSNr)_ONBOARD_ACCOUNTS_URLSr$rs ra_accounts_base_urlrs ! % %f.DX.N O OOrccNt|tdSr)_ONBOARD_OPEN_URLSr$rs ra_onboard_open_base_urlrs  ! !&*|t}t|d}t||ddi} t |t 5}t j| dcdddS#1swxYwYdS#t$rf}|}|rJ t j| dcYd}~S#tt j f$r|dwxYwd}~wwxYw)zPOST form-encoded data to the registration endpoint, return parsed JSON. The registration endpoint returns JSON even on 4xx (e.g. poll returns authorization_pending as a 400). We always parse the body regardless of HTTP status. rrgz!application/x-www-form-urlencodedrFrfrN) _REGISTRATION_PATHrrrr_ONBOARD_REQUEST_TIMEOUT_Srmrr/rrrar)rr4rrFr4r5rrs ra_post_registrationrsy +) + +C T?? ! !' * *D #D>;^*_ ` ` `C  S"< = = = ;:diikk0099:: ; ; ; ; ; ; ; ; ; ; ; ; ; ; ; ; ; ; XXZZ  $ $z*"3"3G"<"<======== 45 $ $ $t# $ sTB,9B B,B##B,&B#'B,, D6D &C93D9DDDrct|}t|ddi}|dpg}d|vrtd|dS)zcVerify the environment supports client_secret auth. Raises RuntimeError if not supported. r!initsupported_auth_methods client_secretzWFeishu / Lark registration environment does not support client_secret auth. Supported: Nrrr$r)rrresmethodss ra_init_registrationrss "&))H X&'9 : :Cgg.//52Gg%% $! $ $   &%rcclt|}t|ddddd}|d}|std|dd }d |vr|d z }n|d z }|||d d |dpd|dpddS)zXStart the device-code flow. Returns device_code, qr_url, user_code, interval, expire_in.begin PersonalAgentrr)r! archetype auth_methodrequest_user_info device_codez7Feishu / Lark registration did not return a device_codeverification_uri_completerrsz&from=hermes&tp=hermesz?from=hermes&tp=hermes user_codeinterval expire_inrm)rqr_urlrrr r)rrrrr s ra_begin_registrationr s!&))H X$&& ((  C ''-((K VTUUU WW0" 5 5F f}}****"WW["--GGJ'',1WW[))0S   rcrrrr Optional[dict]ctj|z}|}d}d}tj|krt|} t|d|dd} n6#tt t jf$rtj|YowxYw|dz }|dkrtddd n|d zdkrtd dd | d pi} | d} | dkr|sd}d }| drO| dr:|dkrt| d| d|| ddS| dd} | dvr1|dkrtt d| dStj|tj|k|dkrtt d|dS)zPoll until the user scans the QR code, or timeout/denial. Returns dict with app_id, app_secret, domain, open_id on success. Returns None on failure. Frpollob_app)r!rtprz# Fetching configuration results...rTendflushr user_info tenant_brandr client_idrr)rrrrr> access_denied expired_tokenz [Feishu onboard] Registration %sNz)[Feishu onboard] Poll timed out after %ds) rn monotonicrrrrrmrroprintr$rtr) rrr rdeadlinecurrent_domaindomain_switched poll_countrrrrrs ra_poll_registrationr sP~)+HNOJ .  X % %%n55 $X *00CC '4#78    Jx H  a ?? 7Rt L L L L L !^q #2T * * * *GGK((.B  }}^44 6 ! !/ !#N"O 77;   CGGO$<$< A~~k*!/2($==33  $$ 6 6 6A~~ NN=u E E E4 8] .  X % %`A~~  NN> JJJ 4sA0B  B rctdS tj}|||d|ddS#t $rYdSwxYw)zDTry to render a QR code in the terminal. Returns True if successful.NFT)fit)invert) _qrcode_modQRCodeadd_datamake print_asciirs)rqrs ra _render_qrr*6su   ! ! C D d###t uusAA!! A/.A/rrcTtrt|||St|||S)ucVerify bot connectivity via /open-apis/bot/v3/info. Uses lark_oapi SDK when available, falls back to raw HTTP otherwise. Returns {"bot_name": ..., "bot_open_id": ...} on success, None on failure. Note: ``bot_open_id`` here is the bot's app-scoped open_id — the same ID that Feishu puts in @mention payloads. It is NOT the app_id. )r_probe_bot_sdk_probe_bot_http)rrrs ra probe_botr.Ds0:fj&999 6:v 6 66rcc@|dkrtnt}tj|||tj j  S)z9Build a lark Client for the given credentials and domain.r) r,r+rr5rLrrrrrrr`)rrr sdk_domains ra_build_onboard_clientr1Rsk && 0 0mJ   J      4=( ) )  rcrFc8|ddkrdS|dp*|didpi}|dp|d|ddS) Nr?rr rFrerr)rr)r$)rFr s rarfrf_s xx1t ((5// BTXXfb1155e<< BCGGJ''>377:+>+>wwy))  rcc& t|||}tjtjdtj h }| |}tt|dddd}|dSttj|S#t $r&}t"d|Yd}~dSd}~wwxYw)z#Probe bot info using lark_oapi SDK.rcrNrz%[Feishu onboard] SDK probe failed: %s)r1r.rLr.r)r/r0r2r(r3r`rr rfrmrrsrtru)rrrrr4r5rrs rar,r,js&vz6BB   ! ! [ ( ( S) * * [/01 2 2 UWW ~~c""'$t44iFF ?4"4:g#6#6777  #>??I @ @ @ @ @ @ @ @ @ @ @ @ @ @ @!}}%:;;  4 / / /!9Tj!3!3G! > > > > > > > > > > > > > >#7+++ gx)= > =sCCCtttttsfAE"(:B." E".B22E"5B26E"0E":E< E"E  E"E E"""F*F%%F*initial_domaintimeout_secondsr?r@c t||S#ttttjf$r&}t d|Yd}~dSd}~wwxYw)aRun the Feishu / Lark scan-to-create QR registration flow. Returns on success:: { "app_id": str, "app_secret": str, "domain": "feishu" | "lark", "open_id": str | None, "bot_name": str | None, "bot_open_id": str | None, } Returns None on expected failures (network, auth denied, timeout). Unexpected errors (bugs, protocol regressions) propagate to the caller. r>z([Feishu onboard] Registration failed: %sN)_qr_register_innerrrrrmrrtr)r?r@rs ra qr_registerrCsh*!Q`aaaa (GT-A BA3GGGttttts"AAActdddt|t|}tdt|d}t|rtd|n"td|d td tt |d |d t |d ||}|sdSt |d|d|d}|r1|d|d<|d|d<n d|d<d|d<|S)uIRun init → begin → poll → probe. Raises on network/protocol errors.z Connecting to Feishu / Lark...rTrz done.r z8 Scan the QR code above, or open this URL directly: z3 Open this URL in Feishu / Lark on your phone: r8zH Tip: pip install qrcode to display a scannable QR code here next timerrr )rrr rNrrrrr)rrr r*r minr.r$)r?r@rr rRbot_infos rarBrBsi  ,"DAAAA~&&&  / /E (OOO GGG 8_F&Z S6SSTTTT PfPPPQQQ XYYY GGG -(z"eK(/:: F t)6,+?AQRRH%%\\*55z ( ] ; ;}!z $} Mrc>rIrJrKrLrM>rVrWrYrZr[>rOrPrQrRrSrT)r media_filesforce_documentc<KtsddiS|pg} t|}t|dd}|dkrtnt}|||_|rd|ind} d} |r1|||| d{V} | j s dd | j iS|D]:\} } tj | s dd | icStj | d } | t vr||| | d{V} n| t$vr||| | d{V} np| t(vr!| r||| | d{V} nF| t,vr||| | d{V} n||| | d{V} | j sdd | j icS<| dd iSdd|| jdS#t2$r}dd |icYd}~Sd}~wwxYw)a}Out-of-process Feishu/Lark delivery via the adapter's send pipeline. Implements the standalone_sender_fn contract so deliver=feishu cron jobs succeed when cron runs separately from the gateway. Builds a transient FeishuAdapter, hydrates its lark client, and sends text + native media (images, video, voice, documents). Replaces the legacy _send_feishu helper. rzJFeishu dependencies not installed. Run: pip install 'hermes-agent[feishu]'r)rrrNr}zFeishu send failed: zMedia file not found: rzFeishu media send failed: zANo deliverable text or media remained after processing MEDIA tagsT)rr|rr)rrr r+r,rrr:rrrrr,r-splitextr_MIGRATION_IMAGE_EXTSr@_MIGRATION_VIDEO_EXTSr!_MIGRATION_VOICE_EXTSr_MIGRATION_AUDIO_EXTSrrrs)pconfigrrdrrGrHrfrrr last_result media_pathis_voicer_es ra_standalone_sendrTs geff#K'5((g~x@@ "-"7"7[!44V<</8BK++d ==?? M ' Wg Q QQQQQQQK& M!K 8I!K!KLL$/ S S J7>>*-- H!F*!F!FGGGG'"":..q17799C+++$+$;$;GZZb$;$c$ccccccc ---$+$6$6w U]$6$^$^^^^^^^ ---(-$+$6$6w U]$6$^$^^^^^^^ ---$+$6$6w U]$6$^$^^^^^^^ $+$9$9':X`$9$a$aaaaaaa & S!Qk>O!Q!QRRRR S  `a a %0    55533344444445s7BH0/H D H,H4 H H HHHcddlm}m}ddlm}ddlm}m}m}m }m }m }m } |d|d} |d} | r| r|d|d d sd S|d d dgd} d } d }| dkr\ t} n<#t$r|dYd St$r}|d|Yd }~nd }~wwxYw| rd}n |d| s|d|d|dd }|s |dd S|dd}|s |dd S|dddgd}|dkrdnd}d } t!|||}|r&|d }|d!|pd"n |d#n%#t$r}|d$|Yd }~nd }~wwxYw|||d |d%} | d&}| d'}| d(d}| d)}| d }|d||d||d*||rd+}n@|d,d-d.gd}|dkrd/nd+}|d/kr!|d0|d1|d2|d3||r|d4||d5gd6d}|dkr/|d7d8|d9d:|d;|d<ns|dkr$|d7d=|d9d:|d>nI|d7d8|pd:}|d?|d d@d:}|d9||dA|dBdCdDgd}|dkr|dEdF|dGn|dEdH|dI|dJd }|r|dK||dL||dM|dN||dO||r|dP|d Sd S)QuInteractive setup for Feishu / Lark — scan-to-create or manual creds. Replaces the central _setup_feishu in hermes_cli/gateway.py and the static _PLATFORMS["feishu"] dict. CLI helpers are lazy-imported. r) get_env_valuesave_env_value) prompt_choice)r prompt_yes_no print_header print_info print_success print_warning print_error Feishu / Larkrrz$Feishu / Lark is already configured.zReconfigure Feishu / Lark?FNz+How would you like to set up Feishu / Lark?z@V-WYZ[[ %?? E V<     (01}}))+ i ' ' JH I I I Jf g g g Ji j j jN+_===2 0h001113   JQ/999-r222 +,,, ]^^^^ q/888-r222 ABBBB/999 2 F 0-%   '#r    -y999 ())) , B !  IA~~,f555 BCCCC,j999 *+++6KV[\\\L=,l;;; ;\;;<<<M2333J"&""###J"&""###' %8%%&&&&&''s79BC C)B<<CAF F'F""F'yaml_cfg feishu_cfg dict | Nonecd|vrHtjds4t|dtjd<dS)u+Translate config.yaml feishu: keys into FEISHU_* env vars. Implements the apply_yaml_config_fn contract (#24849). Mirrors the legacy feishu_cfg block from gateway/config.py::load_gateway_config() (allow_bots). Env vars take precedence over YAML. Returns None — flows through env. rrN)rrrrenviron)rtrus ra_apply_yaml_configrysJz!!")4G*H*H!*-j.F*G*G*M*M*O*O &' 4rcclt|dipi}t|dS)zFeishu is connected when app_id is configured. Mirrors the legacy _PLATFORM_CONNECTED_CHECKERS[Platform.FEISHU] = lambda cfg: bool(app_id).rr)r rr$)rrs ra _is_connectedr{s4 FGR ( ( .BE  (## $ $$rcc t|S)zDFactory wrapper that constructs FeishuAdapter from a PlatformConfig.)r)rs ra_build_adapterr}s   rcc|ddttttddgdtt dddt d d d d S)u:Plugin entry point — called by the Hermes plugin system.rr_rrz"pip install 'hermes-agent[feishu]'rrErcru🪽T)rradapter_factorycheck_fn is_connectedvalidate_config required_env install_hintsetup_fnapply_yaml_config_fnallowed_users_env allow_all_envcron_deliver_env_varstandalone_sender_fnmax_message_lengthrallow_update_commandN)register_platformr}rr{rsryrT)ctxs raregisterrsb &*"%%':;9"/0.2-!#rc)rr rr)rr rr)rrrr)rr rr)rr r!rrr)r6rrr)r=rrr)Nr)rr r]rr^rrr)r)rr r]rr^rrrr)rrrrq)rr rrrr)rr rr)rr rrr) r=r rrrrrrrr) rr rrrrrrrr) rrrrrrr rrr)rrrr)rrrr)rrrrrr)rrrr)rr rr)rr rrrr)rrrrrr)rrrr)rr rr)rr rr2rr)rr )rr rr)rrrrrr)rrrr)rGr rrH)rrr rrrO)rrSrr)rrrrSrr)rer rfr rrur)rrrr)rrr4ryrr)r)rrrru)rrrr) rrrrr rrrrr )rrrr)rrrrrrrr )rrrrrrrr )rFrrr )r?rr@rrr r|)rtrrurrrv(r __future__rrrconcurrent.futuresrhrrrrmrrzrr.rrnrr dataclassesrrrpathlibrtypesr typingr r r r rr urllib.errorrr urllib.parserurllib.requestrraiohttpr ImportErrorrrrrrrrrrrrrrr r!r"r#r$r%r&rr(r)rr+r,rr.rr0r1rr3rr5rrrrgateway.configr6r7r)r8r9r:r;r<r=r>r?r@rAgateway.statusrBrChermes_constantsrDutilsrErFrG getLoggerrrtcompiler[rrrZrr~ _MENTION_RErA IGNORECASErrurvrwrrr3rrrrrrrrrrrrrrrr rvrrrrrrrrrrzrr|_FEISHU_BOT_MSG_TRACK_SIZErrrrr r9rrrrrrrrrr.rrr?r[r\r=r'r(rrrrrrrr RejectReasonr rrrr%r5r<rIrOr\rdrgrprlrrrrrrrrrrrrrrrrrrrrrrr rNrrWrdrrrrrrrr r qrcoder$r`r*r.r1rfr,r-rCrBrKrLrNrMrTrsryr{r}rr]rcrarsi---^#"""""    ######((((((((!!!!!!????????????????,,,,,,,,""""""++++++++NNNG CCCJJJ&BBBBBB ;:::::::????????000000JIIIII555555 DL"&!NMKKK(t3"$.33333333                        DCCCCCCC,,,,,,7777777777  8 $ $ BJkL  RZ 7FFBJ9::$"*%9::%2:k22bj'' L))%2:&UWYWdee GFFWWWMMMUU4R4L4R4T4TUUU%#"('!2"B"B"B       $($'!#$ $%(" #) )")!0&(#!$ $')$$&!&1#(/%   (( %$  '' !(y&&)9:: (&*.&"%+ , ' (2 +2*3) ('RZ(DEE$"*]33#)$TUU$9%:;;F## , $         $ $ 5 5 5 5 5 5 5 5  $GGGGGGGG  $;;;;;;;; $!!!!!!!!!!!!!!!!H +++++++ + 9999999 9 @@@@    (9999::::'''' ####BBBB,9999$6666611111    .6.6.6.6h;?!!!!!!H , , , ,$     ;? M;M;M;M;M;h;? J)-0022 FNFNFNFNFNFNRGGGG*8B#"#"#"#"L@@@@ !!!!&&&&&Rdddd____ 4 4 4 4    ))))    (;?* (,????&****Z<'<'<'<'~;P;P;P;P|S80S80S80S80S80'S80S80S80~pPPPPHHHH.      > DDDDDDN     YKKK     7 7 7 7    *F#8&&&&nCBB@@@JJJ);5;5;5;5;5|f'f'f'f'R    %%%%!!! sI B B B $B))B32B37ADD&%D&T!! T-,T-