PL j7 UdZddlmZddlZddlZddlZddlZddlZddlZddl Z ddl Z ddl Z ddl Z ddl Z ddlZddlmZddlmZmZddlmZddlmZddlmZdd lmZmZmZmZmZmZdd 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-ddl.m/Z/ddl0m1Z1m2Z2m3Z3m4Z4m5Z5m6Z6m7Z7m8Z8m9Z9m:Z:m;Z;mZ>ddl?m@Z@mAZAddlBmCZCmDZDddlEmFZFddlGmHZHmIZIddlJmKZKddlLmMZNdZOn#e*$rdZOdZ-dZHdZIdZKdZNdZCdZDYnwxYwe+duZPe(duZQddlRmSZSmTZTddlUmVZVmWZWmXZXmYZYmZZZm[Z[m\Z\m]Z]m^Z^m_Z_ddl`maZambZbddlcmdZdddlemfZfejgehZie jjde jkZle jjde jkZme jjdZne jjd Zoe jjd!Zpe jjd"Zqe jjd#Zre jjd$e jsZthd%Zuhd&Zvhd'Zwd(e[jxDZyd)Zzd*Z{d+d,hZ|hd-Z}d.d/d/d0d0d1d1d2Z~d3Zd4Zd4Zd5Zd6Zd7Zd8Zd9Zd:Zd;ZdZd?Zd@ZdAZdBZdCZdDZdEZdFZdGZdHdIdJdKdLZdMedN<dOdPdQdRdSZdMedT<dUZedVdWhZdXZdYZdZZd[d\d]Zd^d_d]Zd`ZdaZdbZdcZddZdeZdfZdgZdhZe jjdiZe jjd"ZedjZedkZe jjdlZdmZhdnZedoGdpdqZedoGdrdsZedoGdtduZedoGdvdwZedoGdxdyZedoGdzd{ZeGd|d}ZeGd~dZedZddZddZddZddZddZddZddZddZddZddZdddZÐdddZĐd dZŐd dZddd dZǐd dZȐd dZɐd dZ dddZ dddZdedddZ͐ddZΐddZϐddZАddZѐddZҐddZӐddZԐddZՐddÄZ֐ddńZאddƄZؐddɄZِddʄZڐdd̄Z ddd̈́ZܐddτZݐd d҄Zސd!dԄZߐd"dքZd#dׄZd$dۄZd%d܄ZGd݄deVZd&dZd&dZd'dZd(d)dZd(d*dZddd+dZ ddlZn#e*ef$rdZYnwxYwd,dZd-dZd.dZd/dZd-dZd-dZdd?dd0dZd0dZdS(1u 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_writez(^#{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.png.webp.gif.jpg.jpeg>.aac.m4a.mp3.wav.flac.ogg.opus.webm>.3gp.mkv.avi.m4v.mov.mp4rSci|]\}}|| Sr[).0extmimes r`sUUUysDsUUUmessagestreamrQrR>rVrWrXrYpdfdocxlsppt)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_alwaysrsDict[str, str]_APPROVAL_CHOICE_MAPz Approved oncezApproved for sessionzApproved permanentlyDenied)rprqrrrs_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[rar_rr6s=MMMIMrarcHeZdZUdZded<dZded<dZded<dZded<d S) FeishuMentionRefrrrrFboolis_allis_selfN)rrrrrrrrr[rar_rr=sRDNNNNGFGrarcBeZdZUdZded<dZded<dZded<d dZd S) _FeishuBotIdentityrrrrrreturnrc|r|jr ||jkS|r|jr ||jkSt|jo ||jkSN)rrrr)selfrrrs r_matchesz_FeishuBotIdentity.matchesKsZ  +t| +dl* *  +t| +dl* *DI4449#44raN)rrrrrrrr)rrrrrrrrr[rar_rrEsYGGDNNNN555555rarc^eZdZUded<eeZded<eeZded<dS) FeishuPostParseResultr text_contentdefault_factory List[str] image_keysList[FeishuPostMediaRef] media_refsN)rrrrrlistrrr[rar_rrVsZ!E$777J7777+05+F+F+FJFFFFFFrarceZdZUded<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[rar_rr]sMMM"(((((!E$777J7777+05+F+F+FJFFFF',uT'B'B'BHBBBB M    $uT:::H::::::rarczeZdZUded<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_pathrnws_reconnect_noncermws_reconnect_intervalN Optional[int]ws_ping_intervalws_ping_timeoutadminsrdefault_group_policyrzDict[str, FeishuGroupRule] group_rulesnone allow_botsTrrequire_mention)rrrrrrrr frozensetrrrrrrrr[rar_rrisKKKOOO''''MMM####))))    $$$$     !$$$$$&*****%)O))))&Y[[F(((( """"".3eD.I.I.IKIIIIJ O      rarcpeZdZUdZded<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[rar_rrsnVVKKK%444I4444%444I4444&*O******rarcveZdZUeeZded<eeZded<eeZded<dS) FeishuBatchStaterzDict[str, MessageEvent]eventsDict[str, asyncio.Task]taskszDict[str, int]countsN) rrrrrrrrrr[rar_rrsl&+eD&A&A&AFAAAA%*U4%@%@%@E@@@@"U4888F888888rar) self_echoself_ids_unknown bots_disabledbot_not_mentionedgroup_policy_rejectedsenderr rrc(t|dddvS)N sender_typer>appbot)getattr)rs r__is_bot_senderr s 6=" - - ??rarc t|dd}|tStdt|ddt|ddt|ddfDS)N sender_idc3K|]}||V dSrr[r\vs r_ z#_sender_identity..s>  rarrr)r r)rsids r__sender_identityrs &+t , ,C {{{  CD ) ) CD ) ) CT * *   rarrc8td|S)Nz\\\1)_MARKDOWN_SPECIAL_CHARS_REsub)rs r__escape_markdown_textrs % ) )'4 8 88rarc"|dup |dkp|dkS)NTtruer[rs r_ _to_booleanrs D= 9EQJ 9%6/9rastyleDict[str, Any] | NonekeycN|sdSt||SNF)rget)rrs r__is_style_enabledr#s' u uyy~~ & &&ractdgdtjd|D}d|dzz}|ds|drd|dn|}|||S)Nrc,g|]}t|Sr[)len)r\runs r_ z%_wrap_inline_code..sDDDSCDDDraz`+`r )maxrefindall startswithendswith)rmax_runfencebodys r__wrap_inline_coder3s1EDDBJud,C,CDDDEFFG 7Q; E//#.. N$--2D2D N;t;;;;$D "T "5 " ""ralanguagecz|ddddS)N r* )stripreplace)r4s r__sanitize_fence_languager:s2 >>   # #D# . . 6 6tS A AAraelementrct|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#r3r)r;rr style_dictrendereds r__render_text_elementrGs w{{62&&," - -D KK E$UD11;tJV,,' &&&$T**H rV,,%$$$$X..#"x???[11(''''_55%$$$$ Oractt|ddpdp$t|ddpd}t|ddpdp$t|ddpddd}|drdnd}d|d||dS) Nr4rlangrr r6```)r:rr"r9r/)r;r4r=trailing_newlines r__render_code_block_elementrMs' GKK B ' ' -2..T#gkk&"6M6M6SQS2T2TH GKK # # )r**Sc'++i2L2L2RPR.S.S gfd "]]400:rrd 8 8 8T 8#3 8 8 88raclddlm}|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_markdownrJr6c|dd|ddS)Nrz ())groupr8)ms r_z/_strip_markdown_to_plain_text.. s7qwwqzz,R,RQWWQZZ=M=M=O=O,R,R,Rraz^>\s?r)flagsz ^\s*---+\s*$z---z ~~([^~\n]+)~~z\1z([\s\S]*?))gateway.platforms.helpersrOr9_MARKDOWN_LINK_RErr, MULTILINE)rrOrs r__strip_markdown_to_plain_textrZs988888 LL & &E  ! !"R"RTY Z ZE F8Rbl ; ; ;E F?E5 E E EE F#UE 2 2E F' 6 6E N5 ! !E Lradefaultr 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 r_ _coerce_intrbsQU z "y((66g5s ((c2t|||}||n|S)Nr[r\)rbr`s r__coerce_required_intres$ 9 E E EFn77&0rarcTt|}tjdd|iidSNrrF ensure_ascii)_build_markdown_post_rowsjsondumps)rrowss r__build_markdown_post_payloadrn%s? $W - -D : 4     raList[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. mdrrrrKFrNonecsdSd}|rd|dggdS)Nr6rqrr)joinr8append)segmentcurrentrms r__flush_currentz1_build_markdown_post_rows.._flush_currentBsW  F))G$$ ==?? : KKw778 9 9 9rarrs) splitlinesr8r_MARKDOWN_FENCE_CLOSE_REmatch_MARKDOWN_FENCE_OPEN_RErv)r in_code_blockryraw_line stripped_lineis_fencerxrms @@r_rjrj1sj -r**+,, Gw//011')DGM&&((!! ((  > $ * *= 9 9 9(..}==      !   NN8 $ $ $ --M  !   x    N  5T733455ra 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 r_rz,parse_feishu_post_payload..wsE%T:z<PPrar6)rrr) _resolve_post_payloadrFALLBACK_POST_TEXT_normalize_feishu_textrr"r8rvrDrru) rrresolvedpartsrrowrow_textrrs ` @@r_parse_feishu_post_payloadrbsi %W--H F$2DEEEEJ+-JE "3x||GR'@'@#A#A#G#G#I#I J JE  U||Ir**0b # ##t$$  ) GG      # LL " " " YYu%%++--C1C   ract|}|r|St|tsiS|d}t |}|r|St |S)Npost)_to_post_payloadrDrr"_resolve_locale_payload)rdirectwrappedwrapped_directs r_rrsm g & &F  gt $ $ kk&!!G,W55N "7 + ++ract|}|r|St|tsiStD]*}t||}|r|cS+|D]}t|}|r|cSiSr)rrDr_PREFERRED_LOCALESr"values)rrr candidaters r_rrs g & &F  gt $ $ !$W[[%5%566      !!$U++       Irarct|tsiS|d}t|tsiSt |ddpd|dS)Nrrr)rr)rDrr"rr)rrs r_rrsq i & & mmI&&G gt $ $ Y]]7B//5266  rarrrrc^ 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](rRatr@_allTr@alluser user_name@>imgimageraltz[Image: ]r>raudiomediavideorrr>rrrrrr [Attachment: r>emojiemotion emoji_type:z[Emoji]brr6>hrdividerz --- r=r>pre code_block)rrrchildrenelementsr*c3K|]}||V dSrr[)r\parts r_rz'_render_post_element..s'::TT:D::::::ra)rDrrr"r8lowerrGrrrrrvrr3rM_render_nested_postru)r;rrrrrr escaped_labelrref display_namerrrrr= nested_partsr extracteds r_rrsa '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        rac3DK|]}t|}||VdSrrrs r_rz&_render_nested_post..rrar)rDrrrrurrr)rrrrrs ``` r_rrs %,$U+++% xx            %  %eZ\RR  Mxx             2ra)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)rr8r_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 r_normalize_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 MMrac |rtj|ni}n#tj$rd|icYSwxYwt|tr|nd|iS)Nrr)rkloadsJSONDecodeErrorrDr)rras r_rrlso%,7?K(((R  %%% $$$$%-- F66Iv3FFs 11c t|d|d|dt|d}t|}g}|r||||ddd|pt}td|dt||d  S) Nrrpreview)rrrrkeysrir6r) entry_countrrrrr) _first_non_empty_textr"_find_first_text_collect_forward_entriesrvextendrur8FALLBACK_FORWARD_TEXTrr&)rrentrieslinesrs r_rrts ! G I I'UVVV   E 'w//GE  U LL!99U##))++D/DL " !%!$W>>    rac 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: r6r)rrr)rr"rrvFALLBACK_SHARE_CHAT_TEXTrur)rrshare_idrrs r_rrs,% K   F G'EFFF I % I N## O$$H E/ 0Y001111 -...- +++,,,99U##L "!"%I>>    ract|dtr|dn|}tt ||dt |d}t |}t|}g}|r|||D]}||kr|||r+|dd |d |dd pt}t||d ||d  S) Nrr)rrrrz Actions: , r6 r)ractionsr) rDr"rr_find_header_titler_collect_card_lines_collect_action_labelsrvrur8FALLBACK_INTERACTIVE_TEXTr) rr card_payloadr body_linesrrliners r_rrsY*4W[[5H5H$*O*O\7;;v&&&U\L !<(( G,LMMM  E %\22J$\22GE  U 5== LL   7 57!3!35566699U3B3Z((..00M4ML "!# W55    rac 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"rDrrrrrrvrr8rrrr _unique_lines) r candidatesrrrrrr nested_typer2s r_rrs>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;;; ' ' '  ! !!racnt|d}d|D}td|DS)NF in_rich_blockc,g|]}t|Sr[)rr\rs r_r(z'_collect_card_lines..s!AAA4(..AAAracg|]}||Sr[r[rs r_r(z'_collect_card_lines..s>>>4>$>>>ra)_collect_text_segmentsr )rr normalizeds r_rrsD "7% @ @ @EAA5AAAJ >>:>>> ? ??rac g}t|D]}t|tst|ddp|dd}|dvrzt|d|d|dt|d }|r| |t|S) Nrrr>buttonpickeroverflow date_picker select_staticrrr)rrrrr) _walk_nodesrDrrr"r8rrrrvr )rlabelsrrrs r_rrsFG$$ ! !$%%  $((5"%%=&")=)=>>DDFFLLNN V V V % HHV   HHV   HHW   T(L M M M     ! MM%   rarct|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)Nr rrr> divnoteactionrcolumnlark_mdmarkdown column_set plain_textrr)rDrrrrrrr"r8r_SUPPORTED_CARD_TEXT_KEYSrvr_SKIP_TEXT_KEYS)rrsegmentsrrnext_in_rich_blockrrs r_rrs%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 Orarc8t|ddpd}t|d|d|d}|dvr|nd}t |||S) Nrrrrr>rrrr)rr"r8rr)rrrreffective_types r_rr.s7;;z2..4"55;;==H% K   G FI '47I&I&I]]vN x9Tb c c ccrarc>t|}|rd|dntS)Nrr)rFALLBACK_ATTACHMENT_TEXT)rnormalized_names r_rr9s,,Y77O1@ ^ -? - - - -F^^ract|tsdS|d}t|tsdS|d}t|trJt|d|d|dSt t |pdS)Nrheaderrrrr)rDrr"rrr)rr/rs r_rr>s gt $ $r [[ " "F fd # #r JJw  E%a$UYYy%9%9599V;L;LeiiX^N_N_``` !#ekr"2"2 3 33rartuple[str, ...]ct|D]^}t|ts|D]C}||}t|trt |}|r|ccSD_dSNr)rrDrr"rr)rrnoderrrs r_rrJsG$$&&$%%   & &CHHSMME%%% &3E:: &%%%%%%  & 2rac#Kt|tr2|V|D]}t|Ed{VdSt|tr|D]}t|Ed{VdSdSr)rDrrrr)rrs r_rrWs%) LLNN ) )D"4(( ( ( ( ( ( ( ( ( ) ) E4 ) ) )D"4(( ( ( ( ( ( ( ( ()) ) )rarc|D]m}t|trt|}|r|cS-|>t|ttfs"tt|}|r|cSndSr2)rDrrrr)rrrs r_rras"" eS ! ! "/66J "!!!! "  z%$'F'F /E ;;J "!!!! 2racdfd }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)rSr"rr)r}rrrrs r__subz$_normalize_feishu_text.._subwsSkk!nn!r&&s++ ;3x03;0&4zzrarrrrJr6r7c3pK|]1}td|V2dS)r*N)_WHITESPACE_RErr8rs r_rz)_normalize_feishu_text..s>^^$**355;;==^^^^^^rac3K|]}||V dSrr[rs r_rz)_normalize_feishu_text..s'EEEEEEEEErar*)r}r7rr)_MENTION_PLACEHOLDER_RErr9rusplit_MULTISPACE_REr8)rrr9cleaneds ` r_rrss&))$ ;;Googv..Goofd++33D$??Gii^^'--X\J]J]^^^^^GiiEEt)<)<EEEEEG  g..G ==??rarct}g}|D]3}|r||vr ||||4|Sr)raddrv)rseenuniquers r_r r s[UUDF tt||   d Mramentiontuple[str, str]cft|dd}t|trHtt|ddpd}|dkr|dfS|dkrd|fSdS|dStt|ddpdtt|ddpdfS)Nidid_typerrrrr)r rDrr)rE mention_idrIs r__extract_mention_idsrLs$--J*c""ggy"55;<<BBDD i  r> ! i  z> !vv GJ 2 . . 4"55 GJ 2 . . 4"55 raDict[str, FeishuMentionRef]c pi}|pgD]}tt|ddpd}|s%|dkrtd||<?t|\}}tt|ddpd}t||||||||<|S) NrrrTrrrrr)rrr)rr rrLr8r)rr resultrErrrrs r_rrs+-F>r   ''5"--344   '>>*$777F3K /8877FB//5266<<>>&KKtKLL   s MraSequence[FeishuMentionRef]cg}t}|D]}|jr |j|j|jf}||vr#|||jr|dU|jr(||jpdd|jd||jpd|rdd|dndS) Nrunknownz (open_id=rRz [Mentioned: rrr)rrrrrrBrvru)rrrCr signatures r__build_mention_hintrUsED 0 0 ;  Zch7      : 0 LL [ 0 LLCH1 KKS[KKK L L L L LL.Y / / / /16 > -$))E** - - - -B>racT|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 r_r(z-_strip_edge_self_mentions..sF  ;/CH - -v//raTrr)lstripr.r&_MENTION_BOUNDARY_CHARS_TRAILING_TERMINAL_PUNCTr/rstrip) rr self_names remainingnmafterir2tails r__strip_edge_self_mentionsrbs  J   I   B''++ c"gghh'E q)@@@ I E     NN!ee !a%(,DDD FA!ee !a%(,DDD!}}  B}}R    CGG8,3355<    ra ws_clientadapterrsc  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 _configurerrsc 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)rdrcsr__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)rp_ws_ping_timeout)rurvrdoriginal_connects r__connect_with_overridesz?_run_official_feishu_ws_client.._connect_with_overridessY  $ 0_F5R5R&-&?F? #  # /N&4P4P%,%=F> "0000raconfcTtd|}|S)NzFFeishu _configure_with_overrides called but original_configure is None) RuntimeError)r}rPrtoriginal_configures r__configure_with_overrideszA_run_official_feishu_ws_client.._configure_with_overridess<  %ghh h##D))##%%% rac:g|]}||Sr[doner\ts r_r(z2_run_official_feishu_ws_client..1s%FFFQVVXXF1FFFrareturn_exceptionsTrz)rur rvr rr )r}r rr )lark_oapi.ws.clientwsclientasyncionew_event_loopset_event_looploop_ws_thread_loop websocketsconnectr rmstartrq all_taskscancelrun_until_completegatherstopclose) rcrdws_client_modulerr|rpendingtaskrtrr{s `` @@@r__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/r2r4r~rrrrrrrrr 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)r~rrrrrrrrr r!r"r#r$r%r&r(r)r+r,r.r0r1r3rs r__importz*check_feishu_requirements.._importJs_    FFFFFF                                 ?>>>>>>>CCCCCCCC444444         NMMMMM999999 D #%:  !2  $%:  !"4  %&<   #$8  '(@  n  !2  ()B  '(@  "#6  &'>  #$8 '(@! " # $%*&&(+F&<, $5    rar)ensure_and_bindzplatform.feishuF)prompt)rtools.lazy_depsrglobals)rrs r_check_feishu_requirementsrAsS t/ / / b0///// ?,gwyy O O OOracX eZdZdZdZdZd*fd Zed+d Zd,dZ d-dZ d.dZ d/dZ d0dZ d/dZd/dZd/dZ d1d2d#Zd$d%d3d(Z d4d5d-Zed6d2Z d7d8d4Zed9d7Zed:d9Zed;d:Z d<d=d=Z d>d?d@Z d<d@dBZ d<dAdDZdBdCdEZ d<dDfdG Z d<dEfdI ZdFdJZ dGdKZ!dHdMZ"dIdNZ#d/dOZ$dHdPZ%dJdRZ&dHdSZ'dHdTZ(dHdUZ)dHdVZ*dHdWZ+dKdYZ,dLdZZ-edMd\Z.dNd^Z/dOd`Z0dPdcZ1dPddZ2dQdfZ3dRdgZ4dKdhZ5dSdjZ6dHdkZ7dTdmZ8dUdoZ9d.dpZ:dVdrZ;dWdtZ<dXduZ=dYdvZ>dUdwZ?dZdzZ@d[d}ZAd\d~ZBd$dd]dZCdUdZDd^dZEd_dZFed`dZGdUdZHdadZIdadZJdadZKdbdZLdcdZMedddZNededZOedfdZPdgdZQdhdZRdidZSd_dZTed`dZUdUdZVdadZWedjdZXdadZYdadZZdkdZ[dldZ\edmdZ]dndZ^dodZ_dpdZ`dqdZaedrdÄZbedsdńZcedtdɄZdedudʄZeedvd˄Zfedwd̈́Zgedvd΄ZhedxdЄZiedydӄZjd$ddzdՄZkd{dքZld$dd|dׄZmd}dڄZndYdۄZoddܜd~dZpeddZqeddZrddZsddZt dd$dddZuddZvddZwddZxddZyd/dZzd/dZ{d/dZ|ddZ}ddZ~ddddddZddZeddZeddZddddZddZd/dZd/dZd/dZdd Zdd Zd/d Zedd Zedd ZeddZeddZeddZeddZeddZeddZeddZeddZeddZedd Zedd"Zedd#ZdGd$Zdd'Zedd)ZxZS( FeishuAdapterzFeishu/Lark bot adapter.i@rjconfigr7cht|tj||jpi|_||jd|_d|_ d|_ d|_ d|_ d|_ d|_d|_i|_g|_t%dz |_t)j|_i|_i|_i|_i|_g|_t)j|_d|_d|_i|_i|_ g|_!i|_"i|_#d|_$tK|_&|j&j'|_(|j&j)|_*|j&j+|_,tK|_-|j-j'|_.|j-j)|_/i|_0tcj2d|_3i|_4tcj2d|_5tm|_7|8dS)Nzfeishu_seen_message_ids.jsonFir)9super__init__r6FEISHU_load_settingsextra _settings_apply_settings_client _ws_client _ws_futurer_loop_webhook_runner _webhook_site_event_handler_seen_message_ids_seen_message_orderrD_dedup_state_path threadingLock _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 _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_counterr_pending_processing_reactions_load_seen_message_ids)rr __class__s r_rzFeishuAdapter.__init__s 111,,V\-?R@@ T^,,,&* )-48DH:> .2,0-135.0 !0!2!25S!S$>++@BBD!JL$57 35$%.^%5%5"(-%*.'469;&13#;==? 15!1!3!3%)%;%B")-)?)E&*.*@*G'"2"4"4&*&=&D#*.*A*G':<!*!3!3?A!&/oa&8&8#GRmm* ##%%%%%rarrrrcd|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 dddtj dd dtj 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#tj d/t t$d0t'tj d1t t(d2t'tj d3d4d5t!d6t#tj d7t t*d8t!d6t#tj d9t t,d:t'tj d;t t.dt#|d>p&tj d?t t2d@t |d@ptj dAt4pt4dBt7|dBdCdDEdFt7|dFdGd6EdHt9|dHdd6EdIt9|dIdd6Ed |d |d|dJ| dt |dtj dKdLS)NNrrropench|]D}t|#t|ESr[rr8r\us r_ z/FeishuAdapter._load_settings..Aggg!X[\]X^X^XdXdXfXfgs1vv||~~gggrarch|]D}t|#t|ESr[rrs r_rz/FeishuAdapter._load_settings..rrar)rrrrrc3K|]F}t|#t|VGdSrrrs r_rz/FeishuAdapter._load_settings..sCPPaQP3q66<<>>PPPPPPrarrFEISHU_ALLOW_BOTSr>allrrzS[Feishu] Unknown allow_bots=%r, falling back to 'none'. Valid: none, mentions, all.r FEISHU_APP_IDrFEISHU_APP_SECRETrdomainr+r}rFEISHU_CONNECTION_MODE websocketrFEISHU_ENCRYPT_KEYrFEISHU_VERIFICATION_TOKENrFEISHU_GROUP_POLICYrc3fK|],}||V-dSrr8r\rs r_rz/FeishuAdapter._load_settings..sL**::<<* ******raFEISHU_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_SECONDSz2.0rr%HERMES_FEISHU_TEXT_BATCH_MAX_MESSAGESr"HERMES_FEISHU_TEXT_BATCH_MAX_CHARSr'HERMES_FEISHU_MEDIA_BATCH_DELAY_SECONDSrFEISHU_WEBHOOK_HOSTrFEISHU_WEBHOOK_PORTrFEISHU_WEBHOOK_PATHrrnrrdrrmrrrFEISHU_REQUIRE_MENTIONrr[)r"rDrrrrrr8rrosgetenvrrwarningrr>r+r_DEFAULT_DEDUP_CACHE_SIZEr!_DEFAULT_TEXT_BATCH_DELAY_SECONDS _DEFAULT_TEXT_BATCH_MAX_MESSAGES_DEFAULT_TEXT_BATCH_MAX_CHARS"_DEFAULT_MEDIA_BATCH_DELAY_SECONDS_DEFAULT_WEBHOOK_HOST_DEFAULT_WEBHOOK_PORT_DEFAULT_WEBHOOK_PATHrerb) rraw_group_rulesrrrule_cfgper_chat_require_mention raw_adminsrrrs r_rzFeishuAdapter._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 <  "6;;AACCC<  "y)DbIIOOQQQ< #8+FFLLNNTTVVV< !***I&D]@^@^__``%< ,&+ BCHiDjDjkk&&&-< 2,1 H%PP,,,3< 8%(BIEsKkGlGlmmnn%%%9< @"%BIBCHeDfDfgghh"""A< H', CSIkElElmm'''I< N .))dRY7LNc-d-degggS< T .))iRY7LcRgNhNh-i-iU< \EIIn--h;PRg1h1hiiooqq)(_< b 4EII>R4S4S]_klmmmmc< d#7uyyAX7Y7Ycfrs"t"t"t"te< f)3E)F)FPT`abbbbg< h( 2C(D(Dd^_````i< j6k< l"6!5m< n$ o< p"zq< r( +RY7OQW-X-XYYs< < rasettingsrsc|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_pathrrnrrorrprrzr _allow_botsr_require_mention)rrs r_rzFeishuAdapter._apply_settings$sZ #.$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#. ( 8rar cRtdStjjjjjfd fd j  j jjjdjS)Nc0d|S)Nim.message.reaction.created_v1_on_reaction_eventdatars r_rUz4FeishuAdapter._build_event_handler..NT445UW[\\rac0d|S)Nim.message.reaction.deleted_v1r:r<s r_rUz4FeishuAdapter._build_event_handler..Qr>radrive.notice.comment_add_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_eventbuildrs`r__build_event_handlerz"FeishuAdapter._build_event_handlerCs ! )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 ) )-,UWW- rarcKtstddS|jr|jstddS|jdvr"td|jdS |j|_tt|jd|j j i\}}|sqt|tr| dnd }d |rd |d nd zdz}td||d|ddStj|_|d {V|td|j|jdS#t,$r_}|d {Vd|}|d|dtd|dYd }~dSd }~wwxYw)zConnect to Feishu/Lark.z [Feishu] lark-oapi not installedFz3[Feishu] FEISHU_APP_ID or FEISHU_APP_SECRET not set>webhookrzT[Feishu] Unsupported FEISHU_CONNECTION_MODE=%s. Supported modes: websocket, webhook.platform)rpidNz@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: %srk)rrrerrorrrr!rrB_FEISHU_APP_LOCK_SCOPErZrrDrr"_set_fatal_errorrget_running_loopr_connect_with_retry_mark_connectedinfor rq_release_app_lock)racquiredexisting owner_pidrbexcs r_rzFeishuAdapter.connect_sW  LL; < < <5| 4#3  LLN O O O5  (@ @ @ LLf%   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!.cancel_all_tasks..s%VVVqQVVXXVVVVraz3[Feishu] Found %d pending tasks in websocket threadg?)rrrrrsr&r call_laterr)rrws_thread_loops r_cancel_all_tasksz2FeishuAdapter.disconnect..cancel_all_taskss}VVG$5n$E$EVVV RTWX]T^T^___!""DKKMMMM))#~/BCCCCCraz;[Feishu] Waiting for websocket thread to exit (timeout=10s)g$@timeoutz([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: %sTrkz[Feishu] Disconnectedrz)_running_cancel_pending_tasksrr_reset_batch_buffers!_disable_websocket_auto_reconnect_stop_webhook_serverr is_closedrrrscall_soon_threadsaferrwait_forshield TimeoutErrorrCancelledErrorrqrr_persist_seen_message_idsrg_mark_disconnectedrf)rrq ws_futurerkrps @r_ disconnectzFeishuAdapter.disconnects (()GHHHHHHHHH(()HIIIIIIIII !!### ..000'')))))))))-  %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# " &&((($$&&&&&&&&& !!! +,,,,,s%)A"E )G7(G! G*G  GrrcKd|D}|D]}||rtj|ddid{V|dS)Nc>g|]}|||Sr[r)r\rs r_r(z7FeishuAdapter._cancel_pending_tasks..s*OOODdO499;;O4OOOrarT)rrrrclear)rrrrs r_ruz#FeishuAdapter._cancel_pending_taskssOOELLNNOOO  D KKMMMM  C.'BTBB B B B B B B B rac|j|j|jdSr)rrrrrVs r_rvz"FeishuAdapter._reset_batch_bufferssG "((*** '--/// #))+++++rac|jdS t|jddn#t$rYnwxYwd|_dS#d|_wxYw)N_auto_reconnectF)rrmrqrVs r_rwz/FeishuAdapter._disable_websocket_auto_reconnectsl ? " F # DO%6 > > > >    D #DOOOdDO " " " "s"; /;/; AcK|jdS |jd{Vd|_d|_dS#d|_d|_wxYwr)rcleanuprrVs r_rxz"FeishuAdapter._stop_webhook_serversu   ' 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 connectedsuccessr`NrrrrrrzI[Feishu] Invalid post payload rejected by API; falling back to plain textrrhmsgrzJ[Feishu] Post payload rejected by API response; falling back to plain textz send failedz[Feishu] Send error: %sTrk)rr<format_messagetruncate_messageMAX_MESSAGE_LENGTH_build_outbound_payload_feishu_send_with_retryrq_POST_CONTENT_INVALID_REsearchrrrrrkrlrZ_response_succeededr _finalize_send_resultr`) rrrrr formattedchunks last_responsechunkrrresponserks r_sendzFeishuAdapter.sends| 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 *1*;DLO;G?9H?Hdangerous commandcommand session_keyrc  K|jstddS t|j t |dkr |dddzn|}d.d/ fd }ddiddddddd|d|dd|ddd|dd|d d!|d"d#d$gd%gd&}t j|d'} ||d(| d|)d{V} || d*} | j r|| j pd+|d,|j <| S#t$rC} td-| tdt| cYd} ~ Sd} ~ wwxYw)0aSend an interactive card with approval buttons. The buttons carry ``hermes_action`` in their value dict so that ``_handle_card_action_event`` can intercept them and call ``resolve_gateway_approval()`` to unblock the waiting agent thread. Frri Nz...r[rr action_namebtn_typerrcdd|d||ddS)Nrr$rr) hermes_action approval_idrrrrr[)rrrrs r__btnz.FeishuAdapter.send_exec_approval.._btnKs.#$0UCC$/:;WW rawide_screen_modeTu ⚠️ Command Approval Requiredr$rrorangerrr"z``` z ``` **Reason:** rru✅ Allow Oncertprimaryu ✅ Sessionruu ✅ Alwaysrvu❌ Denyrsdangerrrrr/rrhrrzsend_exec_approval failedrrrrz&[Feishu] send_exec_approval failed: %sr[)rrrrrrrr)rr<nextrr&rkrlrrrrrrqrrrr)rrrrrr cmd_previewrrrrrPrkrs @r_send_exec_approvalz FeishuAdapter.send_exec_approval9s:| 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_idrc |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 r_rz5FeishuAdapter._build_update_prompt_card.._btns3 ,?? 39(1  rarTu⚕ Update Needs Your Inputr$rrrr"rru✓ Yesyru✗ Nonrrr)rrrrrrrrr[)rr[r default_hintrs ` r__build_update_prompt_cardz'FeishuAdapter._build_update_prompt_cards6=E222222       *40%B<XX$ #&/H,/H/HII#YY77XsH55      rarcK|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[rrhrNrzsend_update_prompt failedrrz&[Feishu] send_update_prompt failed: %s)rr<rrrkrlrrrrrrrqrrrr) rrrr[rrrrrrPrks r_send_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.rs❌✅ResolvedrTr*r$rredgreenrr"z **z** by rr)rzr")rriconrs r__build_resolved_approval_cardz+FeishuAdapter._build_resolved_approval_cards&((uue#'' ;;)40(,%6%6u%6%6|LL%+v%5%5EE7 &"&CC5CC CC   rarc`|dk}|rdnd}ddi|rdndd|d d |rd nd d dd|ddgdS)NrYesNorTrrz Update prompt answered: r$rrrrr"zAnswered by **r?rrr[)rryesrs r_"_build_resolved_update_prompt_cardz0FeishuAdapter._build_resolved_update_prompt_cardsm&$)4014(?%%a%aZ_%a%ajvww'*5GG #/M /M/M/MNN   ractdz }|d}||||dS)Nz.update_responsez.tmp)rD with_suffix write_textr9)r response_pathtmp_paths r__write_update_prompt_responsez+FeishuAdapter._write_update_prompt_responsesT')),>>  ,,V44F###'''''ra 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)rrrrrrrvs r_ send_voicezFeishuAdapter.send_voiceU55 ") 6         rarrcHK|||||||d{VS)z*Send a document/file attachment to Feishu.)rrrrrrNr)rrrrrrrrvs r_ send_documentzFeishuAdapter.send_documentsU55 6         ra video_pathcHK||||||dd{VS)zSend a video file to Feishu.rrNr)rrrrrrrvs r_ send_videozFeishuAdapter.send_videorra image_pathcrK|jstddStj|stdd|S ddl}t |d5}|} dddn #1swxYwY|| } tj || _ | t| } | | } tj|jjjjj| d{V} || d }|s|| d d S|r;||d |d}||d|||d{V}n6||dt1jd |id||d{V}||dS#t6$rF}t8d||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_tagrrrrhzimage send failedz$[Feishu] Failed to send image %s: %sTrk)rr<r pathexistsiorreadBytesIObasenamer_build_image_upload_body_FEISHU_IMAGE_UPLOAD_TYPE_build_image_upload_requestrrrrrcreate_extract_response_field_response_error_result_build_media_post_payloadrrkrlrrqrrr`r)rrrrrrrv_iof image_bytes image_filer2rupload_responser post_payloadmessage_responserks r_send_image_filezFeishuAdapter.send_image_file&s | 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&& H60;H1+H61H6c KdS)z2Feishu bot API does not expose a typing indicator.Nr[)rrrs r_ send_typingzFeishuAdapter.send_typingcs tra 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: %sTrk)rrrrr)rrrrr)_download_remote_imagerqrrr`r send_imager) rrrrrrrrkrs r_r zFeishuAdapter.send_imagegs" #::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: %sTrk)rr!rrrz[GIF downgraded to file] z[GIF downgraded to file])rrrrrr)_download_remote_documentrqrrr`rsend_animationr) rrr!rrrrrrkdegraded_captionrs r_r&zFeishuAdapter.send_animationse )-)G)G".*H**$$$$$$ Iyy     LLGX[fjL k k k//+!! 0       FMlAAAARl''$ (         s!' BA B:BBczK||dd}|js|S|j|}|t|S ||}t j|jjjj j|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[rar_rUz-FeishuAdapter.get_chat_info..EraFr=rSrzchat lookup failedz0[Feishu] Failed to get chat info for %s: [%s] %sr= chat_typerr)rrrrz'[Feishu] Failed to get chat info for %sTrk)rrr"r_build_get_chat_requestrrrrchatr rrrrr8r_map_chat_typerq) rrfallbackcachedrrr=rr= raw_chat_typerfs r_ get_chat_infozFeishuAdapter.get_chat_infos   | O&**733  <<  227;;G$.t|/A/F/JGTTTTTTTTH JwxMMJJLLPUUUx;;h/CDDQSZ\`befff8VT22Dk2 > > D"EEKKMMSSUUM"GD&$77B7CC++M::)1T D .2D !' *::     NNDgX\N ] ] ]OOO sB'F&B'F)F:9F:c*|S)z/Feishu text messages are plain text by default.rrrs r_rzFeishuAdapter.format_messages}}rar=c|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)rr=r start_drainers r_rFzFeishuAdapter._on_message_eventsz++D11  ??EEM  =9%''' F T4#B#B4#H#HIIIIIracT|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. reventNrbrrrSzA[Feishu] Pending-inbound queue full (%d); dropped oldest event %sTzI[Feishu] Queued inbound event for replay (loop not ready, queue depth=%d)) rr&rrpopr rrqrrr`rvrr)rr=droppedrArbrdepth should_starts r_r:z,FeishuAdapter._enqueue_pending_inbound_events ' 5 54/00D4SSS6::1==+#GWd;;E%eY==G!$WWlB%G%G%T9!U!UJJ +++!*JJJ+ W3  ( / / 5 5 5455E#<rvrfr`timesleep) r poll_intervalmax_wait_secondswaitedrCrbatch dispatchedrequeuerAs r_r<z+FeishuAdapter._drain_pending_inbound_events s  B 6> (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.rANrbrr zA[Feishu] Dropping malformed inbound event: missing message/senderrz2[Feishu] Dropping duplicate/missing message_id: %sz#[Feishu] dropping inbound event: %sr,p2p)r=rbr r,ris_bot)r rrrs _is_duplicate_admit_process_inbound_messager )rr=rArbrrreasonr,s r_r>z(FeishuAdapter._handle_message_event_dataX sjgt,,%D11$// f GFK,N,N  LL\ ] ] ] FWlD99  T// ;;  LLMz Z Z Z FVW--   LL> G G G FG[%88 ++fk488!!&)) ,           rar"ct|dd}t|dd}t|ddpd}td|dS)z7Ignore read-receipt events that Hermes does not act on.rANrbrrz([Feishu] Ignoring message_read event: %s)r rrrs)rr=rArbrs r_rDz$FeishuAdapter._on_message_read_eventu sUgt,,%D11WlD99?R  ?LLLLLract|dd}tt|ddpd}td||j|ddS)z'Handle bot being added to a group chat.rANrrz[Feishu] Bot added to chat: %sr rrrrfrrBrr=rArs r_rLz#FeishuAdapter._on_bot_added_to_chat| segt,,geY339r:: 4g>>> !!'400000ract|dd}tt|ddpd}td||j|ddS)z+Handle bot being removed from a group chat.rANrrz"[Feishu] Bot removed from chat: %srYrZs r_rNz'FeishuAdapter._on_bot_removed_from_chat segt,,geY339r:: 8'BBB !!'400000rac:tddS)Nz'[Feishu] User entered P2P chat with botrrrsrr=s r_rPz"FeishuAdapter._on_p2p_chat_entered s >?????rac:tddS)Nz![Feishu] Message recalled by userr]r^s r_rRz"FeishuAdapter._on_message_recalled s 899999racddlm}|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) gateway.platforms.feishu_commentrarr9rrrr=rr))rr=rars r_rTz%FeishuAdapter._on_drive_comment_event s POOOOOz++D11  NN_ ` ` ` F   & &t|THY Z Z Z     ra 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.rANrr operator_type reaction_typercreatedaddedremovedz?[Feishu] Reaction %s on message %s (operator_type=%s, emoji=%s)>rr rycdSr!r[r[rar_rUz2FeishuAdapter._on_reaction_event.. sura)r rrrrsrrr=_handle_reaction_event) rrdr=rArrfreaction_type_objrrrs r_r;z FeishuAdapter._on_reaction_event s3gt,, b99?R@@ GE?B??E2FF #E?DAA!2L"EEKLL %33 M        z ^ + + ,|=GD+}}==??@@ F T4#>#>z4#P#PQQQQQrac|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 readyNrArrrr)rA action_valuer) rr9rrrr1r rDrr"_handle_approval_card_action!_handle_update_prompt_card_actionr=_handle_card_action_event)rr=rrArrorupdate_prompt_actions r_rJz%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*,,,rarcZ|duo'tt|dd S)zEReturn True when the adapter loop can accept thread-safe submissions.NrycdSr!r[r[rar_rUz7FeishuAdapter._loop_accepts_callbacks.. sPUrarr )rs r_r9z%FeishuAdapter._loop_accepts_callbacks s64Y-VWT; -V-V-X-X(Y(Y$YYracorocddlm}|||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)rr log_message log_levelNFT)agent.async_utilsryrrloggingWARNINGadd_done_callback_log_background_failure)rrrwryfutures r_r=zFeishuAdapter._submit_on_loop sc>>>>>>)) $No     >5  !=>>>trarct|pd}|sdSt|jt|jz}|sdSd|vp||vS)zBReturn whether this card-action operator may answer gated prompts.rFTrA)rr8rr&r%)rrr allowed_idss r_#_is_interactive_operator_authorizedz1FeishuAdapter._is_interactive_operator_authorized smB''--//  5$,''#d.G*H*HH  4k!>Z;%>>rarAroc|d}|1tdtrtndSt|dd}t |dd}t t |ddpd}||p|}||| |||strtndStdSt} t8t} d | _ | || | _ | | _| S) zISchedule approval resolution and build the synchronous callback response.rNz2[Feishu] Card action missing approval_id, ignoringrrsoperatorrrraw)rr)r"rrrsr1rxr r_get_cached_sender_namer=_resolve_approvalr0rrr=r) rrArorrrrrrrrs r_rpz*FeishuAdapter._handle_approval_card_action sG"&&}55   LLM N N N4OY.000UY Y%)),*:*:?*K*KVTT5*d33gh 266<"==0099DW ##D$*@*@fV_*`*`aa Z4OY.000UY Y & .4.00  #>>DDI::&T]:^^DI HMrac\|d}|1tdtrtndS||jvr2td|trtndSt |ddpd}|dvr2td|trtndSt|d d}t t|d dpd}| |s4t d |pd 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=%rrrz/[Feishu] Unauthorized update prompt click by %s r)rr)r"rrrsr1rrr8rr rrrr=_resolve_update_promptr0rrr=r) rrArorrrrrrrrs r_rqz/FeishuAdapter._handle_update_prompt_card_action s  $$%788   LLR S S S4OY.000UY Y D5 5 5 LLPR[ \ \ \4OY.000UY Y\%%&CRHHNBOOUUWW]]__  # # LLSU[ \ \ \4OY.000UY Y5*d33gh 266<"==77@@ Z NNLgNdYd e e e4OY.000UY Y0099DW ##D$*E*EiQWYb*c*cdd Z4OY.000UY Y & .4.00  #>>DDI??vYb?ccDI HMrarc^K|j|d}|std|dS ddlm}||d|}td||d||dS#t$r&}td|Yd}~dSd}~wwxYw)z8Pop approval state and unblock the waiting agent thread.Nz0[Feishu] Approval %s already resolved or unknownr)resolve_gateway_approvalrzIFeishu button resolved %d approval(s) for session %s (choice=%s, user=%s)z9Failed to resolve gateway approval from Feishu button: %s) rrBrrrstools.approvalrrfrqr`)rrrrstaterrrks r_rzFeishuAdapter._resolve_approval< s$((d;;  LLK[ Y Y Y F [ ? ? ? ? ? ?,,U=-A6JJE KK[u]+VY      [ [ [ LLTVY Z Z Z Z Z Z Z Z Z [s>  LLPR[ \ \ \ F L  . .v 6 6 6 KKSm$fi      L L L LLEs K K K K K K K K K Ls8A88 B(B##B(c K|jsdSt|dd}tt|ddpd}|sdS ||}t j|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.NrArrrcdSr!r[r[rar_rUz6FeishuAdapter._handle_reaction_event..h srar=rrrrHrr,rQz5[Feishu] Failed to fetch message for reaction routingTrkrrgrUNKNOWNrhrirjz reaction:rr Feishu Chat chat_infoevent_chat_typer user_id_altrrr,rr thread_idrrrsource raw_messager timestampzD[Feishu] Routing reaction %s:%s on bot message %s as synthetic event)rr r_build_get_message_requestrrrrrbr"rrqrrrs_resolve_sender_profiler3 build_source_resolve_source_chat_typer9r:TEXTrnowrf_handle_message_with_guards)rrdr=rArrrrrrr chat_type_raw user_id_objrmrrsynthetic_textsender_profilerrsynthetic_events r_rlz$FeishuAdapter._handle_reaction_event[ se|  Fgt,, b99?R@@   F 55jAAG$.t|/A/I/MwWWWWWWWWH #N78Y #N#N#P#P GHfd;;WdKKQrE#-%((C S(D11F764,,233t|CC'#y"55;<. s,wwwBcBhQvFvFv1FvFvFvraTF)rHrr)rrexpiredrrs @r__is_card_action_duplicatez'FeishuAdapter._is_card_action_duplicate sxikkwwww$":"@"@"B"Bwww , ,A(++ D, , ,4*- 'urac Kt|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#jt'j}td| ||||d{VdS)zHRoute Feishu interactive card button clicks as synthetic COMMAND events.rANrrz1[Feishu] Dropping duplicate card action token: %scontextrrrzB[Feishu] Card action missing chat_id or operator open_id, droppingrrrrz/card r*Frh)rrrrrrSrrrrrrzB[Feishu] Routing card action %r from %s in %s as synthetic command)r rrrrrsrkrlrqr rr3rr"rr9r:COMMANDuuiduuid4rrrfr)rr=rArrrrrr action_tagrorr rrrrs r_rrz'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 1lnn      XZdfmovwww..???????????s6E E E  asyncio.Lockcx|j|}|tj}||j|<|S)zTReturn (creating if needed) the per-chat asyncio.Lock for serial message processing.)rr"rr)rrlocks r__get_chat_lockzFeishuAdapter._get_chat_lock s:##G,, <<>>D(,D W % rar9cK|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)rrAr chat_locks r_rz)FeishuAdapter._handle_message_with_guards s*AF T'%, 266<"RT''00  - - - - - - - -%%e,, , , , , , , , - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -sA00 A:=A:cxtjdddvS)NFEISHU_REACTIONSr>0nofalse)r rr8rrVs r__reactions_enabledz FeishuAdapter._reactions_enabled s3y+V44::<<BBDDL```rarc K|jr|r|sdS ddlm}m}|d|i}|||}tj |jj j j j|d{V}|r<t|ddr"t|dd}t|ddSt d ||t|d dt|d dn.#t$$r!t d ||d YnwxYwdS)zRReturn the reaction_id on success, else None. The id is needed later for deletion.Nr)CreateMessageReactionRequest CreateMessageReactionRequestBodyrrcdSr!r[r[rar_rUz-FeishuAdapter._add_reaction.. rar= reaction_idz7[Feishu] Add reaction %s on %s rejected: code=%s msg=%sr=rz%[Feishu] Add reaction %s on %s raisedTrk)rrrrrBrgrUrrrrrrmessage_reactionrr rrrsrqr) rrrrrr2rrr=s r_ _add_reactionzFeishuAdapter._add_reaction s| : Z 4!          188:: j9::  -4466J''d##  %.t|/A/R/Y[bccccccccH :GGHiGGII :x66t]D999 LLI&$//%..         NN7       tsDE.( rraTz:[Feishu] Remove reaction %s on %s rejected: code=%s msg=%sr=rz([Feishu] Remove reaction %s on %s raisedrk)rrrrBrrrUrrrrrdeleter rrrsrqr)rrrrrrs r__remove_reactionzFeishuAdapter._remove_reaction sg| : [ 5  H H H H H H,4466J''[))  %.t|/A/R/Y[bccccccccH GGHiGGII t LLL&$//%..         NN:       usB"C25BB:NN  6..z;LMMMMMMMM   ) )* 5 5 5 '/ / /$$Z1IJJ J J J J J J J J J 0 /ra 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)rHrr"#_FEISHU_WEBHOOK_ANOMALY_TTL_SECONDS!_FEISHU_WEBHOOK_ANOMALY_THRESHOLDrrr)rrrrentryr _last_status first_seens r__record_webhook_anomalyz%FeishuAdapter._record_webhook_anomalyg s ikk,00;;  .3 +E<Z"EEE <<AANN.!j( @@@rariincomingc|j|jko9|j|jko)|j|jko|jj|jjkSr)rrrrrrirs r__media_batch_is_compatiblez(FeishuAdapter._media_batch_is_compatible sY  !X%: : G,0LL G&(*@@ G)X_-FF  racK||}|j|}|!||j|<||dS|||s<||d{V||j|<||dS|j|j|j|j|j r%| |j |j |_ |j |_ |j r |j |_ ||dSr) rrr"_schedule_media_batch_flushr_flush_media_batch_nowrrrr_merge_captionrr)rrArris r_rz"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  ((-----rarcH||j||jdSr)_reschedule_batch_taskr_flush_media_batchrrs r_rz)FeishuAdapter._schedule_media_batch_flush s3 ##  +   #     racKtj} tj|jd{V||d{V|j||ur|j|ddSdS#|j||ur|j|dwwxYwr)r current_taskrIr1rrr"rB)rrrs r_rz 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))rrBrrrfr&rrrrrAs r_rz$FeishuAdapter._flush_media_batch_now& s+//T::  F D   ! !   ..u55555555555racbK||d}t||d{VS)NrJrr])_guess_remote_extensionr?)rrr]s r_rz$FeishuAdapter._download_remote_image1 sC**9f*EE))==========rafile_urlr#r$rFcKddlm}||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)rsfollow_redirectsz)Mozilla/5.0 (compatible; HermesAgent/1.0)z*/*)z User-AgentAcceptheaders Content-Typer) content_type default_namer#) tools.url_safetyr'r_httpx AsyncClientr"raise_for_statusrr,r_derive_remote_filenamer>) rr%r#r$r'r1rrcontent_type_hdrr2filename cached_paths r_r%z'FeishuAdapter._download_remote_document5 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 r_r$z%FeishuAdapter._guess_remote_extensionY soCI2$$S!,,Q/007==??/2CCFWWZ]^vZwZwwxxssF Frar.r/cvt|pddddjp|}t|j}|s^t j|pddddpdp|}||}|S)Nrr9rr;)rr>rr:r mimetypesguess_extensionr8)r%r.r/r#rr]guesseds r_r4z%FeishuAdapter._derive_remote_filename^ s(.b//Q77:;;@PL 9oo$**,, 0/1C0J0J3PQ0R0RST0U0[0[0]0]0c0c0e0e0kikll{p{G$/g//Irarct|tr(tdid|DSt|tr d|DS|S)NcJi|] \}}|t|!Sr[r_namespace_from_mapping)r\rrs r_r`z9FeishuAdapter._namespace_from_mapping..j s0%v%v%v[d[^`dc=+P+PQU+V+V%v%v%vracBg|]}t|Sr[rErs r_r(z9FeishuAdapter._namespace_from_mapping..l s&RRRDM99$??RRRrar[)rDrr rrrs r_rFz%FeishuAdapter._namespace_from_mappingg sq eT " " x"ww%v%vhmhshshuhu%v%v%vww w eT " " SRRERRR R rarc 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| d%d&kr*tjd'| d'd iS|jr| d(pi} t| d)p| d)pd } | rt;j| |jsGtd*|||d+tjd,d-S|jrb| |j!|sGtd.|||d/tjd,d0S| d1rIt"d2||d3tjdd4d d!S|#|t| d(pi d5pd } |$|} | d6kr|%| n| d7kr|&| n| d8kr|'| n| d9kr|(| np| d:vr|)| | nU| d;kr|*| n9| dd S)?NremoterSrz+[Feishu] Webhook rate limit exceeded for %s429izToo Many Requests)rrr,r-rr?rapplication/jsonz=[Feishu] Webhook rejected: unexpected Content-Type %r from %s415izUnsupported Media Typecontent_lengthz2[Feishu] Webhook body too large (%d bytes) from %s413izRequest body too largerrz6[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 jsonrurl_verification challenger/rz=[Feishu] Webhook rejected: invalid verification token from %sz 401-tokenizInvalid verification tokenz4[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 supportedrdzim.message.receive_v1zim.message.message_read_v1zim.chat.member.bot.added_v1zim.chat.member.bot.deleted_v1>r9r@zcard.action.triggerrAz([Feishu] Ignoring webhook event type: %sok)-r rr4_check_webhook_rate_limitrrrrrResponserr"r>r8r_FEISHU_WEBHOOK_MAX_BODY_BYTESrr{r $_FEISHU_WEBHOOK_BODY_TIMEOUT_SECONDSr}rq json_responser&rkrdecoderUnicodeDecodeErrorr#hmaccompare_digestr"_is_webhook_signature_validr,r`rrFrFrDrLrNr;rJrTrs) rrrrate_keyr,r.rM body_bytesrr/incoming_tokenrdr=s r__handle_webhook_requestz%FeishuAdapter._handle_webhook_requesto sWh55B lEET%7EE)EE--h77 F NNH) T T T  ( (E : : :>> NNZ\hjs t t t  ( (E : : : > >I?0'LAM M r,rabytesc4t|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-signatureFrQr9)errorsz3[Feishu] Signature verification raised an exceptionTrk) rr"r[r"hashlibsha256encode hexdigestr]r^rqrrrs) rr,rarnoncerTbody_strrcomputeds r_r_z)FeishuAdapter._is_webhook_signature_valid s0 $>CCIrJJ GKK 6;;ArBB $6;;ArBB   Y 5 !(((CCH"HEH4+<HhHHG~gnnW&=&=>>HHJJH&x;; ;    LLNY]L ^ ^ ^55 s9A3C--&DDr`ctj|j|}|1|\}}|z tkr|tkrdS|dz|f|j|<dSt |jt krZfd|jD}|D] }|j|= ||jvrt |jt krdSdf|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 r_r(z;FeishuAdapter._check_webhook_rate_limit.. s; a!R8BBBBBBra)rHrr"rp_FEISHU_WEBHOOK_RATE_LIMIT_MAXr&_FEISHU_WEBHOOK_RATE_MAX_KEYSr)rr`rr window_start stale_keysrqrs @r_rVz'FeishuAdapter._check_webhook_rate_limit sikk)--h77  "' E<\!$GGG::: 57Only merge text events when reply/thread context is identical.)rrrrrs r__text_batch_is_compatiblez'FeishuAdapter._text_batch_is_compatible sC  (H,H H G&(*@@ G)X_-FF racK||}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.rNrr6)rxr&rrr"_last_chunk_lenr_schedule_text_batch_flushrz_flush_text_batch_nowr/r0rr) rrAr chunk_lenriexisting_count next_count appended_text next_texts r_rz!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)rrBrrrrfr&rrr!s r_r~z#FeishuAdapter._flush_text_batch_nowl s*..sD99 '++C666  F 8    b ! !   ..u55555555555raEtuple[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 rrrrfr _bot_identity"_download_feishu_message_resources _resolve_normalized_message_typerr:rr rrr&r_maybe_extract_text_documentrr) rrbrrrrrrrrinjecteds r_rz&FeishuAdapter._extract_message_content} sgy"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  /!!+..."":...;&&rarr:c|pd}|dr tjS|dr tjS|dr tjS|S)Nrimage/audio/video/)rr.r:rr r)rr[rs r__resolve_media_message_typez)FeishuAdapter._resolve_media_message_type sz &B--//   * * %$ $   * * %$ $   * * %$ $rarrcN|j}|dkr+||r|dndtjS|dkr+||r|dndtjS|dkr+||r|dndtjStjS)Nrrrrrr)rrr:rr rr)rrr preferreds r_rz.FeishuAdapter._resolve_normalized_message_type s 5   33k4YKNNWYcnct3uu u   33k4YKNNWYcnct3uu u  " "33k4YKNNWYcncw3xx xrar7cK|r|dsdS tj|tkrdSt |j}|dvr|dvrdSt |d}| |}d|d|S#ttf$r!t d |d YdSwxYw) Nztext/r>.md.txt> text/plain text/markdownrQencodingz [Content of z]: z7[Feishu] Failed to inject text document content from %sTrk)r.r rgetsize_MAX_TEXT_INJECT_BYTESrr:r read_text_display_name_from_cached_pathOSErrorr\rrr)rr7rr]rrs r_rz*FeishuAdapter._maybe_extract_text_document s  *"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}tj|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)NrJrrrrz+[Feishu] Failed to download image %s: %s %sr=rSrrequest failedr-rrJallowedr#rz*[Feishu] Failed to cache image resource %sTrk)r_build_message_resource_requestrrrrmessage_resourcer"rrrrr _read_binary_response_get_response_header_guess_extensionr;rA_normalize_media_type_default_image_media_typerq) rrrrr raw_bytesr.r6r]r7rs r_rz$FeishuAdapter._download_feishu_image s| : 6 ::%"%;G %.t|/A/R/VX_````````H 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.}t1| |}td||| pd|dpdfcS| drJt5| js| d} t9| | }td||| fcSt5| js| t:vr| t:| } t9| | }td||| p|| fcS#t>$r"t d||d YwxYwdS)!NrJ>rrrrz>[Feishu] Resource download failed for %s/%s via type=%s: %s %sr=rSrrr-rrrrrrrJrr#z,[Feishu] Cached message image resource at %srrrQz,[Feishu] Cached message audio resource at %sr\oggrrYz,[Feishu] Cached message video resource at %sz/[Feishu] Cached message document resource at %sz/[Feishu] Failed to cache message resource %s/%sTrk)!rrvrrrrrrr"rrrrsr rrr_guess_media_type_from_filenamer.rr;rArfrr<r@rXrr:r>_DOCUMENT_MIME_TO_EXT_guess_document_media_typerqr)rrrrr request_types request_typerrrr.response_filenamer6rr]r7s r_rz/FeishuAdapter._download_feishu_message_resources| : 6& . . .   ( ( ()< < L; >>)%".? ")!24RR $+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!  vs4BLL(CLBLAL$A1L(MMrct|dd}|dSt|dr!t|St|S)Nrragetvalue)r hasattrrdrr )rfile_objs r_rz#FeishuAdapter._read_binary_responseVs`8VT22  3 8Z ( ( .**,,-- -X]]__%%%rarc \t|dd}t|dipi}t||||dpddddS)Nrr,rr?rr)r rr"rr>r8)rrrr,s r_rz"FeishuAdapter._get_response_header_sht,,#y"--37;;tW[[r%B%BCCIrJJPPQTVWXXYZ[aacciikkkrar6rrct|pdj}||vr|Stj|pddddpd}||vr|S|SNrr?rr)rr:rr@rAr>r8)r6r.r[rr]rBs r_rzFeishuAdapter._guess_extensiones8>r"")//11 '>>J+\-?R,F,FsA,N,Nq,Q,W,W,Y,Y,_,_,a,a,geghh g  Nrac|pdddd}|p|Sr)r>r8r)r.r[rs r_rz#FeishuAdapter._normalize_media_typeosD"(b//Q77:@@BBHHJJ $W$ract|pdj}tj|t j|pddpdS)Nrrzapplication/octet-stream)rr:rr=r"r@ guess_type)r6r]s r_rz(FeishuAdapter._guess_document_media_typetsQ8>r"")//11'+C1EhnRT1U1UVW1X1v\vwwwrarctj|}|dd}t |dkr|dn|}t jdd|S)NrrrQrhz [^\w.\- ])r rr r>r&r,r)rr rrs r_rz,FeishuAdapter._display_name_from_cached_pathysY7##D))sA&&#&u::??uQxx vlC666ractj|pddpd}|r|St|pdj}|t vrd|dS|tvrd|dS|tvrt |SdS)Nrrrr\r) r@rrrr:r=rXr<r;rr)r6rBr]s r_rz-FeishuAdapter._guess_media_type_from_filenames'B77:@bGGII  N8>r"")//11 # # #-CJJsOO-- - # # #-CJJsOO-- - # # # ::3?? ?rrar2c|pd}|dkrdSd|vsd|vsd|vrdS|dkrdSdS)NrrQr)topicthreadforumrS)r8r)r2rs r_r/zFeishuAdapter._map_chat_typesm#)r002288::   4 j H $:$:g>S>S7  7trarrct|dpd}|dvr|S|dkrdSdS)Nrr>rrSrQr)rS)rr"r8r)rrrs r_rz'FeishuAdapter._resolve_source_chat_types^y}}V,,23399;;AACC ) ) )O e # #4wraDict[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) rr rRrrr primary_idname_lookup_idrs r_rz%FeishuAdapter._resolve_sender_profiles")Y55=)Y55=9j$77?4' $*H1Gx!?? 6@        "%#   rac|sdS|j|}|dS|\}}tj|kr|S|j|ddS)z>Return a cached sender name only while its TTL is still valid.N)rr"rHrB)rr r1r expire_ats r_rz%FeishuAdapter._get_cached_sender_namesl 4(,,Y77 >4 i 9;; " "K ##It444tracK|r|jsdS|}|sdStj}||}||pdS|rx||gd{V}|dS|t z}|D]\}} | |f|j|<|j|} | r | dpdndS ddl m } | drd} n| drd} nd} | || } t!j|jjjjj| d{V}|r|sdSt-t-|d dd d}t-|d dp2t-|d dp!t-|d dpt-|dd} | rAt/| t0r,| } | r| |t zf|j|<| Sn-#t2$r t4d|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_rrr=rrrnicknameen_namez-[Feishu] Failed to resolve sender name for %sTrk)rr8rHr_fetch_bot_names_FEISHU_SENDER_NAME_TTL_SECONDSrrr"lark_oapi.api.contact.v3rr.rBr user_id_typerUrrcontactv3rrr rDrrqrrrs)rr rRtrimmedr cached_namenamesroidrhitrrIrrrs r_rz+FeishuAdapter._resolve_sender_name_from_apis   4//## 4ikk227;;  "&$ &  5// ::::::::E}t==I"[[]] A A T04i/@',,)--g66C'*4CFNd 4 d ? ? ? ? ? ?!!%(( $###E** $$#$,,..66w??LLWUU[[]]G$.t|/C/F/K/OQXYYYYYYYYH 8#3#3#5#5 t78VT::FDIIDfd++246624T2224D11   4-- zz|| 8c7dD+G4K d d d LLH)^bL c c c c c dtsCIB&I'I10I1bot_idsOptional[Dict[str, str]]cK|jr|sdS tjtjdd|Dtj h }tj |jj|d{V}tt|dddd}|sdSt!j|}|ddkrdS|dpidpi}d |DS#t($r!t*d |d YdSwxYw) Nz"/open-apis/bot/v3/bots/basic_batchcg|]}d|fS)rr[)r\rs r_r(z2FeishuAdapter._fetch_bot_names..s>>>s9c*>>>rarrr=rr=botsci|]>\}}||t|dpd?S)rr)rr"r8)r\rrfs r_r`z2FeishuAdapter._fetch_bot_names..sYCS&))/R006688raz)[Feishu] Failed to fetch bot names for %sTrk)rr.rB http_methodr)GETuriqueries token_typesr(TENANTrUrrrr rkrr"rrqrrrs)rrreqresprrrs r_rzFeishuAdapter._fetch_bot_namess| 7 4 #%%Z^,,9::>>g>>>??o4566 !*4<+?EEEEEEEEDgdE488)TJJG tj))G{{6""a''tKK''-2226::@bD!%      LLDgX\L ] ] ]44 sCE!(-E!A E!!'F  F c2K|jr|sdS||jvr |j|S ||}tj|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|<| S#t$r!t d|dYdSwxYw)NrcdSr!r[r[rar_rUz3FeishuAdapter._fetch_message_text..,r+raFr=rSrzmessage lookup failedz3[Feishu] Failed to fetch parent message %s: [%s] %sr=rrr2rrrr)rrrz*[Feishu] Failed to fetch parent message %sTrk)rrrrrrrrbr"r rrr_extract_text_from_raw_contentrq) rrrrr=rrparentr2rrparent_mentionsrs r_rz!FeishuAdapter._fetch_message_text$s| : 4 1 1 1+J7 7 55jAAG$.t|/A/I/MwWWWWWWWWH JwxMMJJLLPUUUx;;h/FGGTV`bfhkllltGHfd;;WdKKQrE!&0U1XXDF66400Dvz266<"H!$ 266<"KCISgfj$???tO66!'(7D 48D $Z 0K    NNG^bN c c c44 sB&E+ BE++'FF)rrrrrct||||}|jr|jSt|jt r|jdnd}t|pdS)Nrr) rrrrDrrr"rr8)rrrrrrs r_rz,FeishuAdapter._extract_text_from_raw_contentBs.!#""$$     " +* *EOPZPceiEjEjtj)--.@AAApt ;%%''/4/rar]cn|pd}|dvrdSd|dpdS)Nr>rJrKz image/jpegrr\jpeg)rrX)r]normalized_exts r_rz'FeishuAdapter._default_image_media_typeTsI)**,, . . .<>--c22>>rarc |dS#t$rtdYdSwxYw)Nz-[Feishu] Background inbound processing failed)rPrqrr exception)rs r_rz%FeishuAdapter._log_background_failure[sV N MMOOOOO N N N   L M M M M M M Ns$AArOptional[RejectReason]c t|}td|j|jfD}t |}t |dddk}t |ddpd}|o||}|r||zrdS|r:|j} | dkr| dkrd S|r|sd S| dkr|s||sd S|sdS| t |d d|| sdS|r||sdSdS)Nc3K|]}||V dSrr[rs r_rz'FeishuAdapter._admit..hs(TT1RSTQTTTTTTrar,rQrrrrrrrrr rr) rrr)r*r r _require_mention_forr5_mentions_self_allow_group_message) rrrb sender_idsself_idsrRis_grouprrmodes r_rTzFeishuAdapter._admitfsx%f-- TT):D  $, J,E 418Bt $$W---d  [FIII/E43EF1II Z  5 V  4 \ ! !5  4 [  ? Y(>@@ @ [  CJ,B'CDD DJKJ1J$JLLLrac Jt|ddpd}d|vrdSt|ddpg}|r||rdStt|ddpd|t|dd|}||jS)NrrrTrrr)r _message_mentions_botrr_post_mentions_botr)rrbrrrs r_r zFeishuAdapter._mentions_selfsgy"55; k ! !47J55;  228<< 4- ."==C#Wj$77""$$    &&z':;;;ra List[Any]c|D]}t|dd}t|ddpd}t|ddpd}t|ddpd}|r|jr||jkrdS|r|jr||jkrdS|jr||jkrdSdS)NrHrrrrTF)r r8r)r*r+)rrrErKmention_open_idmention_user_id mention_names r_rz#FeishuAdapter._message_mentions_bots   G $55J&z9dCCIrPPRRO&z9dCCIrPPRRO#GVT::@bGGIIL 4#4 "d&77744 4#4 "d&77744~ ,$."@"@tturarc4td|DS)Nc3$K|] }|jV dSr)r)r\rTs r_rz3FeishuAdapter._post_mentions_bot..s$//19//////ra)any)rrs r_rz FeishuAdapter._post_mentions_bots//h//////rarcDt|j|j|jS)NrO)rr)r*r+rVs r_rzFeishuAdapter._bot_identitys*!%%    racK|jsdS tjtjdtj h }tj |jj |d{V}tt|dddd}|rtj|}t#|pi}|dpd}|dpd}|r3|jr%|j|krt*d||_|r3|jr%|j|krt*d ||_n,#t2$rt*d d YnwxYw|jrdS ||jd }tj |jjjjj|d{V} | r| s3t| dd} | dkrt*ddStt| dddd} t| ddpd} | r|js | |_dSdSdS#t2$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 hydrationTrkrrrIr=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.r=rapp_namez9[Feishu] Failed to hydrate bot name from application info) rr.rBrr)rrrr(rrUrrrr rkr_parse_bot_responser"r8r)rrrr+rfrqrs_build_get_application_requestr applicationv6r) rrrrrrarrrrr=rr(s r__hydrate_bot_identityz#FeishuAdapter._hydrate_bot_identitysV|  F  #%%Z^,,-..o4566 !*4<+?EEEEEEEEDgdE488)TJJG .*W--,W55;!::m44:AACC"JJz228b??AA0(T->'-I-Iy)0D%.~$.H*D*D E&.DN    LLE        >  F e99T[9\\G$.t|/G/J/V/Z\cddddddddH 8#3#3#5#5 x668##NNW '(FD995$GGCZ66<"CCEEH * *!) * * * * e e e LLT_cL d d d d d d es,FF))&GGBK8AK&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) NrQrz5[Feishu] Failed to load persisted dedup state from %sTrk message_idsci|]E}t|#t|dFS)rGrrs r_r`z8FeishuAdapter._load_seen_message_ids..KsE(k(k(kDY\]aYbYbYhYhYjYj(kT):):C(k(k(kracFi|]\}}|dksdks |z k||S)rGrr[)r\msg_idrrttls r_r`z8FeishuAdapter._load_seen_message_ids..YsD# # # %62SyyC1HHb3 B(6rac|Srr[)rqvalids r_rUz6FeishuAdapter._load_seen_message_ids..^s qra)rreversec"i|] }|| Sr[r[)r\rqr5s r_r`z8FeishuAdapter._load_seen_message_ids..`s!B!B!B!!U1X!B!B!Bra)rkrrrFileNotFoundErrorrrrrrrDrr"rH_FEISHU_DEDUP_TTL_SECONDSrrrr8rr^r_sortedr,reversedrr) rr seen_datarrr sorted_idsrr3r5s @@@r_rz$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\rqrs r_r`z;FeishuAdapter._persist_seen_message_ids..gs2&s&s&sWX\`\rWrWrq$*@*CWrWrWrra)indentz,[Feishu] Failed to persist dedup state to %srk) rrmkdirrr,rErrrr)rrecentrs` r_rz'FeishuAdapter._persist_seen_message_idsbs 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) rHr9rrr"rrvr&r,rBr)rrrr3seen_atstales r_rSzFeishuAdapter._is_duplicatels|ikk'    ,00<@RSS S = = = LL> 3Y]L ^ ^ ^e3s88<<< < < < < < < =sJ G A"D< G D  G D 2G B G H;HHHrc K|}|s,|r*|dr|d}t|pid}|r||||tt j}|||} tj|j j j j j | d{VS|pid} | rN|| ||tt j}|d|} ng||||tt j}|drd} nd} || |} tj|j j j j j| d{VS)Nrrrrreply_in_thread uuid_value receive_idrrrXrrr)r"r_build_reply_message_bodyrrr_build_reply_message_requestrrrrrrbreply_build_create_message_body_build_create_message_requestr.r) rrrrrreffective_reply_torWr2r _thread_idreceive_id_types r__send_raw_messagezFeishuAdapter._send_raw_messages&! Eh E8<< 3L3L E!).C!D!D B33K@@AA  V11! /tz||,, 2D 778JDQQG *4.serarv)rs r_rz!FeishuAdapter._response_succeededs,HN!L9mm!L!L!N!NOOOra field_namect|sdSt|dd}|rt||dndS)Nr=)rrr )rrfr=s r_rz%FeishuAdapter._extract_response_fieldsJ00:: 4x..26@wtZ...D@ra)rrrc|rtd||St|dd}t|d|}tdd|d||S)NF)rr` raw_responser=rSrrz] )r<r )rrrrr=rs r_rz$FeishuAdapter._response_error_result sk  Ze>PXYYY Yx33h77%/@4/@/@3/@/@xXXXXrac||s|||Std||d|S)N)rTr)rrri)rrr<r)rrrs r_rz#FeishuAdapter._finalize_send_resultsb''11 Z..x.YY Y33HlKK!    rac  KttD]} |jdkr|d{Vn|d{VdS#t $r}d|_|d|_| d{V|tdz krd|z}t d|dzt||tj |d{VYd}~d}~wwxYwdS)NrFrrQz:[Feishu] Connect attempt %d/%d failed; retrying in %ds: %s)range_FEISHU_CONNECT_ATTEMPTSr!_connect_websocket_connect_webhookrqrtrwrrxrrrrrI)rattemptrk wait_secondss r_rdz!FeishuAdapter._connect_with_retry#si566 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_clientrrWrrryr-rrrr~LogLevelINFOrrun_in_executorrr)rrrs r_rnz FeishuAdapter._connect_websocket<s) WUVV V"&"3v"="=;..v66 "7799   &EFF Fz <4>>++<:;; ;((*********(<'m(-    ..  * O    racKtstd|jdkrtnt}|||_||_|jtd| d{Vtj }|j |j|jtj||_|jd{Vtj|j|j|j|_|jd{VdS)Nz/aiohttp not installed; webhook mode unavailabler~rs)FEISHU_WEBHOOK_AVAILABLErr r+r,rvrrWrr-r Applicationrouteradd_postr4rc AppRunnerrsetupTCPSiter2r3rr)rrrs r_rozFeishuAdapter._connect_webhookVsJ' RPQQ Q"&"3v"="=;..v66 "7799   &EFF F((*********o D.0LMMM"}S11"((********* [)=t?QSWSeff &&(((((((((((rarc,tj|j|j|tj j  Sr) r~r5rBrrrrrr{rwr~rU)rrs r_rvz FeishuAdapter._build_lark_clientfs] K   ! ! VDL ! ! Z( ) ) VF^^ Yt}, - - UWW  rac \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 %srrrQzC[Feishu] Send attempt %d/%d failed for chat %s; retrying in %ds: %szFeishu send failed)rl_FEISHU_SEND_ATTEMPTSrcrr _FEISHU_REPLY_FALLBACK_CODESr"rrrrqrrrrrIr) rrrrrr last_erroractive_reply_torprr=rkrqs r_rz%FeishuAdapter._feishu_send_with_retrypsk+/ "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: %sTrk)rrCrarqrrr)rrks r_rgzFeishuAdapter._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)rrrBrrUr rs r_r-z%FeishuAdapter._build_get_chat_requestsK wyy ( (!)++33G<<BBDD Dw////racdtvr8tj|St |S)Nr r)rr rBrrUr rs r_rz(FeishuAdapter._build_get_message_requestsK ')) + +$,..99*EEKKMM M*5555racdtvr^tj|||St|||S)Nr!)rrr)rr!rBrrrrUr rs r_rz-FeishuAdapter._build_message_resource_requestsi &')) 3 3)133J''(##m$$  *xm\\\\rarrIcdtvrKtj||St ||S)Nrr')rrrBrrIrUr r's r_r*z,FeishuAdapter._build_get_application_requestsV "gii / /%-//d   f48888rarWrXc*dtvrqtj||||St||||S)Nr$)rrrWr) rr$rBrrrWrrUr rVs r_r[z'FeishuAdapter._build_reply_message_bodys $ 1 1'/11!!(## 11j!!  +     rarcdtvrKtj||St ||S)Nr#r)rr#rBrrrUr rs r_r\z*FeishuAdapter._build_reply_message_requestsZ GII - -#+--J''l++   *<PPPPracdtvrKtj||St ||S)Nr&r)rr&rBrrrUr rs r_rz(FeishuAdapter._build_update_message_bodysZ % 2 2(022(##!!   'BBBBracdtvrKtj||St ||S)Nr%r)rr%rBrrrUr rs r_rz+FeishuAdapter._build_update_message_request sZ !WYY . .$,..J''l++   *<PPPPrarZc*dtvrqtj||||St||||S)Nr)rZrrr) rrrBrZrrrrUr rYs r_r^z(FeishuAdapter._build_create_message_bodys % 2 2(022J''(##!!j!!  !     rarbcdtvrKtj||St ||S)Nrrbr)rrrBrbrrUr rs r_r_z+FeishuAdapter._build_create_message_request*sZ !WYY . .$,.. 11l++   \ZZZZrarrcdtvrKtj||St ||S)Nrr)rrrBrrrUr rs r_r z&FeishuAdapter._build_image_upload_body5sX #wyy 0 0&.00J''u   *EBBBBracdtvr8tj|St |S)Nrr)rrrBrrUr rs r_rz)FeishuAdapter._build_image_upload_request@sK 799 , ,%-//<<\JJPPRR RL9999rarOcdtvr^tj|||St|||S)NrrN)rrrBrOrrrUr rNs r_rQz%FeishuAdapter._build_file_upload_bodyFsg "gii / /%-//9%%9%%d  idSSSSracdtvr8tj|St |S)Nrr)rrrBrrUr rs r_rRz(FeishuAdapter._build_file_upload_requestRsK ')) + +$,..;;LIIOOQQ QL9999rac t|Sr)rnr5s r__build_post_payloadz!FeishuAdapter._build_post_payloadXs+G444rarrwctj||}|didg}||gtj|dSrg)rkrr setdefaultrvrl)rrrrrs r_rz'FeishuAdapter._build_media_post_payload[sm*T55g>>??$$Wb11< * * *+C0&8 8 !V + ++V3 3'//ra)rr7)rrrr)rrrrs)rr rrrz)rrrrs)NN) rrrrrrrrrr<) rrrrrrrrrr<)rN) rrrrrrrrrrrr<)rrr[rrrrr)rrN) rrrrr[rrrrrrr<)rrrrrr)rrrrrr)rrrrs)NNN) rrrrrrrrrrrr<)NNNN)rrrrrrrrrrrrrr<) rrrrrrrrrrrr<) rrrrrrrrrrrr<r)rrrrs) rrrrrrrrrrrr<) rrr!rrrrrrrrr<)rrrrrrrr)r=r rrs)r=r rr)r=r"rrs)rdrr=r rrs)r=r rr )rr rr)rr rwr rr)rrrr)rAr rorrr rr )rr rrrrrrs)rr rrrrrrs)rrrr)rrrr)rAr9rrs)rrrrrr)rrrrrr)rrrrrrs)rrrr)rAr9rr;rrs)rrrrrrs)rrrrs)r=r rbr r r r,rrrrRrrrs)rAr9rr)rAr9rr)rir9rr9rr)rrrrs)rrrr)r%rr#rr$rrrF)rrr[rrr) r%rr.rr/rr#rrr)rr rr )rr rr )r,r rardrr)r`rrr)rrrrrr rrs)rbr rr)rrrrrr)rrr[r:rr:)rrrrrr:)r7rrrrr)rrrrrrF) rrrrrrrrrrF)rr rrd)rr rrrr) r6rr.rr[rrrrr)r.rr[rrr)r6rrr)rrrr)r2rrr)rrrrrr)r r rRrrr)r rrr)r rrRrrr)rrrr)rrrrrrrr)r]rrr)rr rrs)rr rbr rr)rrrr)r)r r rrrRrrr)rbr rr)rrrr)rrrr)rr)rrrr)rrrrF)rrrrrrrrrrrrrrrr<) rrrrrrrrrrrr )rr rr)rr rfrrr )rr rrrrrr<)rr rrrr<)rr rr )rrrr )rrrr )rrrrrrrr )rrrIrrr ) rrrrrWrrXrrr )rrrr rr )rrrrrr ) rZrrrrrrXrrr )rbrrr rr )rrrr rr )rr rr )rOrrrrr rr )rrrrwrr)rrrMrrrF)rrrrrrr staticmethodrrrWrrrurvrwrxrrrrrrrrrrrrrr r&r3rrFr:r<r>rDrLrNrPrRrTr;rJr9r=rrprqrrrlrrrrrrrrrrrrrrrUrrrrrrrrrr%r$r4rFrcr_rVrxrzrr}rrr~rrrrrrrrrrrrrrr/rrrrrrrrrrTr r r rrrr-rrrSrrrcrrrrrdrnrorvrrgr-rrr*r[r\rrr^r_r rrQrRrrrP __classcell__)rs@r_rrs"" 2&2&2&2&2&2&ha a a \a F9999>    8++++Z+-+-+-+-Z,,,, ####&&&&"#'-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@@@@::::    $RRRR8#-#-#-#-JZZZ\Z    ????2!!!!F[[[[ L L L L:@:@:@:@x    0@0@0@0@l - - - - aaaa&&&&P<&&&&HHHHHHHHKKKK2CCCC4:::: O7O7O7O7O7O7b6666    AAAA   \ ....*    ???? 6 6 6 6>>>>"%"%"%"%HFFF\F\\^;^;^;^;@*    L       \ $-$-$-$-L    ;;;\;>>>>, 6 6 6 6"VVVV@''''>\      >LLLLd&&&\&lll\l \%%%\%xxx\x777\7    \ \\       B    " 555555n:F-1 000000$???\? NNN\N""""H%%%%)M  )M)M)M)M)M)MZ<<<< .0000    HeHeHeHe\"C"C"C"CHrrrr( D D D D&"&#'%+>=>=>=>=>=>=@0S0S0S0SdPPP\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\00000rarrcNt|tdSNr})_ONBOARD_ACCOUNTS_URLSr"rs r__accounts_base_urlrs ! % %f.DX.N O OOracNt|tdSr)_ONBOARD_OPEN_URLSr"rs r__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. rQr-z!application/x-www-form-urlencodedr=r,rrN) _REGISTRATION_PATHrrirr_ONBOARD_REQUEST_TIMEOUT_Srkrr r[rr_r)rr2rr=rrrkras r__post_registrationrsy +) + +C T?? ! !' * *D #D>;^*_ ` ` `C  S"< = = = ;:diikk0099:: ; ; ; ; ; ; ; ; ; ; ; ; ; ; ; ; ; ; XXZZ  $ $z*"3"3G"<"<======== 45 $ $ $t# $ sTB,9B B,B##B,&B#'B,, D6D &C93D9DDDr}ct|}t|ddi}|dpg}d|vrtd|dS)zcVerify the environment supports client_secret auth. Raises RuntimeError if not supported. rinitsupported_auth_methods client_secretzWFeishu / Lark registration environment does not support client_secret auth. Supported: Nrrr"r)rrresmethodss r__init_registrationrss "&))H X&'9 : :Cgg.//52Gg%% $! $ $   &%raclt|}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_completerr9z&from=hermes&tp=hermesz?from=hermes&tp=hermes user_codeinterval expire_inrk)rqr_urlrrrr)rrrrrs r__begin_registrationrs!&))H X$&& ((  C ''-((K VTUUU WW0" 5 5F f}}****"WW["--GGJ'',1WW[))0S   rarrrrOptional[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)rrtprz# 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) rH monotonicrrrrrkrrIprintr"rrr) rrrrdeadlinecurrent_domaindomain_switched poll_countrrrrr`s r__poll_registrationrsP~)+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_asciirq)rqrs r_ _render_qrrsu   ! ! 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 r_ probe_botr$s0:fj&999 6:v 6 66rac@|dkrtnt}tj|||tj j  S)z9Build a lark Client for the given credentials and domain.r~) r,r+r~r5rBrrrr{rwr~rU)rrr sdk_domains r__build_onboard_clientr2sk && 0 0mJ   J      4=( ) )  rar=c8|ddkrdS|dp*|didpi}|dp|d|ddS) Nr=rr r=r(rr)rr)r")r=r s r_r)r)?s xx1t ((5// BTXXfb1155e<< BCGGJ''>377:+>+>wwy))  rac& t|||}tjtjdtj h }| |}tt|dddd}|dSttj|S#t $r&}t"d|Yd}~dSd}~wwxYw)z#Probe bot info using lark_oapi SDK.r&rNrz%[Feishu onboard] SDK probe failed: %s)rr.rBrr)rrrr(rrUrr r)rkrrqrrrs)rrrrrrrrks r_rrJs&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_secondsrrc 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. rz([Feishu onboard] Registration failed: %sN)_qr_register_innerrrrrkrrrr)rrrks r_ qr_registerrsh*!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.rz8 Scan the QR code above, or open this URL directly: z3 Open this URL in Feishu / Lark on your phone: r6zH Tip: pip install qrcode to display a scannable QR code here next timerrr)rrrrNrrrrr)rrrrrminrr")rrrrrPbot_infos r_rrsi  ,"DAAAA~&&&  / /E (OOO GGG 8_F&Z S6SSTTTT PfPPPQQQ XYYY GGG -(z"eK(/:: F t)6,+?AQRRH%%\\*55z ( ] ; ;}!z $} Mra)rr rr)rr rr)rrrr)rr rr)rrrrrr)r4rrr)r;rrr)Nr)rr r[rr\rrr)r)rr r[rr\rrrr)rrrro)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 rr0rr)rr )rr rr)rrrrrr)rrrr)rEr rrF)rrr rrrM)rrQrr)rrrrQrr)rcr rdr rrsr)rrrr)rrr2rwrr)r})rrrrs)rrrr) rrrrrrrrrr)rrrr)rrrrrrrr)rrrrrrrr )r=rrr)rrrrrr)r __future__rrrgr]rrkr}r@r r,rrHr collectionsr dataclassesrrrpathlibrtypesr typingr r r r rr urllib.errorrr urllib.parserurllib.requestrraiohttpr ImportErrorrrr~rrrrrrrrrrr r!r"r#r$r%r&rr(r)rr+r,rr.rr0r1rr3rr5rrrur{gateway.configr6r7gateway.platforms.baser8r9r:r;r<r=r>r?r@rAgateway.statusrBrChermes_constantsrDutilsrE getLoggerrrrcompilerYrJrIrXr~r| _MENTION_REr? IGNORECASErr;r<r=rrr rrrrrrmrrarrrrrrrrr9rrXrprsrtrYrrrrxrrz_FEISHU_BOT_MSG_TRACK_SIZErrrrrrrrrrrrrrr,rrr=rYrZr;r%r&rrrrrrrr RejectReasonr rrrr#r3r:rGrMrZrbrernrjrrrrrrrrrrrrrrrrrrrrrrr rLrrUrbrrrrrrrrrqrcoderr^rrrr)rrrrr[rar_r s---^#"""""    ######((((((((!!!!!!????????????????,,,,,,,,""""""++++++++NNNG CCCJJJ&BBBBBB ;:::::::????????000000JIIIII555555 DL"&!NMKKK(t3"$.33333333                        DCCCCCCC,,,,,,######  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|v30v30v30v30v30'v30v30v30DhPPPPHHHH.      > DDDDDDN     YKKK     7 7 7 7    *F#8&&&&&&sI B BBB!!B+*B+/ADDD T TT