.cjH 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<dd[Zd\Zed]d^hZd_Zd`ZdaZd\ZdbdcddZdedfddZdgZdhZdiZdjZdkZdlZdmZdnZdoZejndpZejnd"ZedqZedrZejndsZdtZhduZedvGdwdxZedvGdydzZedvGd{d|ZedvGd}d~ZedvGddZedvGddZeGddZeGddZedZddZddZddZddZddZÐddZĐddZŐddZƐddZǐddZȐdddZɐdddZʐddZːddZddddZ͐ddZΐddZϐddZ d d!dZ d d"dZdedd#dZӐd$dZԐd%dZՐd%dZ֐d&dZאd'dZؐd(d„Zِd(dÄZڐd)dńZېd*dDŽZܐd+dɄZݐd,dʄZސd-d̈́Zߐd.d΄Zd/dЄZ d d0dфZd1dӄZd2dքZd3d؄Zd4dڄZd5dۄZd6d߄Zd7dZGddeXZd8dZd8dZd9dZd:d;dZd:ddZd?dZd@dZdAdZd?dZd?dZdd?ddBdZdBdZhdZhdZhdZd+d,hZdddddZdCdZdDd Zd7d Zd ZdCdZdS(Eu 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(^\|.*\|\s*\n\|[-:|\s]+\|)|(^#{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 B/home/ice/.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_MAPrequestr max_bytesintreturnbytescK |j|dzd{V}n##tj$r}|j}Yd}~nd}~wwxYwt ||krt d|S)z8Read at most ``max_bytes`` from an aiohttp request body.Nzpayload too large)content readexactlyasyncioIncompleteReadErrorpartiallen ValueError)r}r~bodyexcs ra!_read_limited_feishu_webhook_bodyrs_00Q????????  &{ 4yy9,--- Ks#(AAAii{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+) titletextrlabelvaluenamesummarysubtitle 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]rcrarrSs=MMMIMrcrcHeZdZUdZded<dZded<dZded<dZded<d S) FeishuMentionRefrrrrFboolis_allis_selfN)rrrrrrrrr]rcrarrZsRDNNNNGFGrcrcBeZdZUdZded<dZded<dZded<d dZd S) _FeishuBotIdentityrrrrrrrc|r|jr ||jkS|r|jr ||jkSt|jo ||jkSN)rrrr)selfrrrs ramatchesz_FeishuBotIdentity.matcheshsZ  +t| +dl* *  +t| +dl* *DI4449#44rcN)rrrrrrrr)rrrrrrrrr]rcrarrbsYGGDNNNN555555rcrc^eZdZUded<eeZded<eeZded<dS) FeishuPostParseResultr text_contentdefault_factory List[str] image_keysList[FeishuPostMediaRef] media_refsN)rrrrrlistrrr]rcrarrssZ!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]rcrarrzsMMM"(((((!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_namerdedup_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]rcrarrsKKKOOO''''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) rrrrrr rrrr]rcrar r sl&+eD&A&A&AFAAAA%*U4%@%@%@E@@@@"U4888F888888rcr ) self_echoself_ids_unknown bots_disabledbot_not_mentionedgroup_policy_rejectedsenderrc(t|dddvS)N sender_typer>appbot)getattr)rs ra_is_bot_senderrs 6=" - - ??rcrc t|dd}|tStdt|ddt|ddt|ddfDS)N sender_idc3K|]}||V dSrr]r^vs ra z#_sender_identity..s>  rcrrr)rr)rsids ra_sender_identityr#s &+t , ,C {{{  CD ) ) CD ) ) CT * *   rcrrc8td|S)Nz\\\1)_MARKDOWN_SPECIAL_CHARS_REsub)rs ra_escape_markdown_textr's % ) )'4 8 88rcrc"|dup |dkp|dkS)NTrtruer]rs ra _to_booleanr+s D= 9EQJ 9%6/9rcstyleDict[str, Any] | NonekeycN|sdSt||SNF)r+get)r,r.s ra_is_style_enabledr2s' u uyy~~ & &&rcctdgdtjd|D}d|dzz}|ds|drd|dn|}|||S)Nrc,g|]}t|Sr])r)r^runs ra z%_wrap_inline_code..sDDDSCDDDrcz`+`r )maxrefindall startswithendswith)rmax_runfencers ra_wrap_inline_coder@s1EDDBJud,C,CDDDEFFG 7Q; E//#.. N$--2D2D N;t;;;;$D "T "5 " ""rclanguagecz|ddddS)N r8 )stripreplace)rAs ra_sanitize_fence_languagerGs2 >>   # #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)Nrrr,codebold**italic* underlinezz strikethroughz~~)rr1 isinstancerr2r@r')rHrr, style_dictrendereds ra_render_text_elementrTs 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) NrArlangrr rC```)rGrr1rFr=)rHrArJtrailing_newlines ra_render_code_block_elementrZs' 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_markdownrWrCc|dd|ddS)Nrz ())grouprE)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.helpersr\rF_MARKDOWN_LINK_REr&r: MULTILINE)rr\rs ra_strip_markdown_to_plain_textrgs988888 LL & &E  ! !"R"RTY Z ZE F8Rbl ; ; ;E F?E5 E E EE F#UE 2 2E F' 6 6E N5 ! !E Lrcdefaultr min_valuecj t|}n#ttf$r|cYSwxYw||kr|n|S)zACoerce value to int with optional default and minimum constraint.)r TypeErrorrrrhriparseds ra _coerce_intrn/sQU z "y((66g5s ((c2t|||}||n|S)Nrhri)rnrls ra_coerce_required_intrq8s$ 9 E E EFn77&0rcrcTt|}tjdd|iidSNrrF ensure_ascii)_build_markdown_post_rowsjsondumps)rrowss ra_build_markdown_post_payloadrzBs? $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. mdrrrrXFrNonecsdSd}|rd|dggdS)NrCr}r~)joinrEappend)segmentcurrentrys ra_flush_currentz1_build_markdown_post_rows.._flush_current_sW  F))G$$ ==?? : KKw778 9 9 9rcrr) splitlinesrEr_MARKDOWN_FENCE_CLOSE_REmatch_MARKDOWN_FENCE_OPEN_REr)r in_code_blockrraw_line stripped_lineis_fencerrys @@rarvrvNsj -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 rar!z,parse_feishu_post_payload..sE%T:z<PPrcrC)rrr) _resolve_post_payloadrFALLBACK_POST_TEXT_normalize_feishu_textrr1rErrQrr) rrresolvedpartsrrowrow_textrrs ` @@raparse_feishu_post_payloadrsi %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_payloadrQrr1_resolve_locale_payload)rdirectwrappedwrapped_directs rarrsm g & &F  gt $ $ kk&!!G,W55N "7 + ++rcct|}|r|St|tsiStD]*}t||}|r|cS+|D]}t|}|r|cSiSr)rrQr_PREFERRED_LOCALESr1values)rrr. candidaters rarrs g & &F  gt $ $ !$W[[%5%566      !!$U++       Ircrct|tsiS|d}t|tsiSt |ddpd|dS)Nrrr)rr)rQrr1rr)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](r_atr@_allTr@alluser user_name@>imgimageraltz[Image: ]r>raudiomediavideorrr>rrrrrr [Attachment: r>emojiemotion emoji_type:z[Emoji]brrC>hrdividerz --- rJr>pre code_block)rrrchildrenelementsr8c3K|]}||V dSrr])r^parts rar!z'_render_post_element..s'::TT:D::::::rc)rQrrr1rElowerrTr'rrrrrr@rZ_render_nested_postr)rHrrrrrr escaped_labelrref display_namerrrrrJ 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 rar!z&_render_nested_post..2rrcr)rQrr'rrrrr)rrrrrs ``` rarrs %,$U+++% xx            %  %eZ\RR  Mxx             2rc)rrr raw_contentrOptional[Sequence[Any]]rc 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)rrEr_load_feishu_payload_build_mentions_mapr1rrrrrrrrrFALLBACK_IMAGE_TEXT_build_media_ref_from_payload_attachment_placeholderrr _normalize_merge_forward_message_normalize_share_chat_message_normalize_interactive_message)rrrrnormalized_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)rwloadsJSONDecodeErrorrQr)rrms rarrso%,7?K(((R  %%% $$$$%-- F66Iv3FFs 11c t|d|d|dt|d}t|}g}|r||||ddd|pt}td|dt||d  S) Nrrpreview)rrrrkeysrkrCr) entry_countrrrrr) _first_non_empty_textr1_find_first_text_collect_forward_entriesrextendrrEFALLBACK_FORWARD_TEXTrr)rrentrieslinesrs rarrs ! 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: rCr)rrr)rr1rrFALLBACK_SHARE_CHAT_TEXTrr)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: , rC r)ractionsr) rQr1rr_find_header_titler_collect_card_lines_collect_action_labelsrrrEFALLBACK_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: )r1rQrrrrrrrrErrrr _unique_lines) r candidatesr.rrrrr nested_typers 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 rar6z'_collect_card_lines.. s!AAA4(..AAArccg|]}||Sr]r]rs rar6z'_collect_card_lines.. s>>>4>$>>>rc)_collect_text_segmentsr)rr normalizeds rar r  sD "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_nodesrQrrr1rErrrrr)rlabelsrrrs rar r sFG$$ ! !$%%  $((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> divnoteactionr!columnlark_mdmarkdown column_set plain_textr$r%)rQrrrrrrr1rEr_SUPPORTED_CARD_TEXT_KEYSrr_SKIP_TEXT_KEYS)rrsegmentsrrnext_in_rich_blockr.rs rarr"s%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)rr1rErr)rrrreffective_types rarrKs7;;z2..4"55;;==H% K   G FI '47I&I&I]]vN x9Tb c c ccrcrc>t|}|rd|dntS)Nrr)rFALLBACK_ATTACHMENT_TEXT)rnormalized_names rarrVs,,Y77O1@ ^ -? - - - -F^^rcct|tsdS|d}t|tsdS|d}t|trJt|d|d|dSt t |pdS)Nrheaderrrrr)rQrr1rrr)rr;rs rarr[s 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)r&rQrr1rr)rrnoder.rrs rarrgsG$$&&$%%   & &CHHSMME%%% &3E:: &%%%%%%  & 2rcc#Kt|tr2|V|D]}t|Ed{VdSt|tr|D]}t|Ed{VdSdSr)rQrrr&r)rrs rar&r&ts%) LLNN ) )D"4(( ( ( ( ( ( ( ( ( ) ) E4 ) ) )D"4(( ( ( ( ( ( ( ( ()) ) )rcrc|D]m}t|trt|}|r|cS-|>t|ttfs"tt|}|r|cSndSr>)rQrrrr)rrrs rarr~s"" 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)Nrr8rr)r`r1rr)rr.rrrs ra_subz$_normalize_feishu_text.._subsSkk!nn!r&&s++ ;3x03;0&4zzrcrrrrWrCrDc3pK|]1}td|V2dS)r8N)_WHITESPACE_REr&rErs rar!z)_normalize_feishu_text..s>^^$**355;;==^^^^^^rcc3K|]}||V dSrr]rs rar!z)_normalize_feishu_text..s'EEEEEEEEErcr8)rrCrr)_MENTION_PLACEHOLDER_REr&rFrsplit_MULTISPACE_RErE)rrrEcleaneds ` rarrs&))$ ;;Googv..Goofd++33D$??Gii^^'--X\J]J]^^^^^GiiEEt)<)<EEEEEG  g..G ==??rcrct}g}|D]3}|r||vr ||||4|Sr)r addr)rseenuniquers rarrs[UUDF tt||   d Mrcmentiontuple[str, str]cft|dd}t|trHtt|ddpd}|dkr|dfS|dkrd|fSdS|dStt|ddpdtt|ddpdfS)Nidid_typerrrrr)rrQrr)rQ mention_idrUs ra_extract_mention_idsrXs$--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)rrrrXrEr)rrresultrQr.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=r_z [Mentioned: rrr)r rrrrrNrr)rrrOr signatures ra_build_mention_hintrasED 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 rar6z-_strip_edge_self_mentions..sF  ;/CH - -v//rcTrr)lstripr<r_MENTION_BOUNDARY_CHARS_TRAILING_TERMINAL_PUNCTr=rstrip) rr self_names remainingnmafterirtails ra_strip_edge_self_mentionsrns  J   I   B''++ c"gghh'E q)@@@ I E     NN!ee !a%(,DDD FA!ee !a%(,DDD!}}  B}}R    CGG8,3355<    rc ws_clientadapterrc  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 _configurerrc 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)rprosra_apply_runtime_ws_overrideszC_run_official_feishu_ws_client.._apply_runtime_ws_overrides+s ` 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)r|_ws_ping_timeout)rrrporiginal_connects ra_connect_with_overridesz?_run_official_feishu_ws_client.._connect_with_overrides4sY  $ 0_F5R5R&-&?F? #  # /N&4P4P%,%=F> "0000rcconfcTtd|}|S)NzFFeishu _configure_with_overrides called but original_configure is None) RuntimeError)rr\roriginal_configures ra_configure_with_overrideszA_run_official_feishu_ws_client.._configure_with_overrides;s<  %ghh h##D))##%%% rcc:g|]}||Sr]doner^ts rar6z2_run_official_feishu_ws_client..Ns%FFFQVVXXF1FFFrcreturn_exceptionsTr)rr rr rr )rr rr )lark_oapi.ws.clientwsclientrnew_event_loopset_event_looploop_ws_thread_loop websocketsconnectrrystartr} all_taskscancelrun_until_completegatherstopclose) rorpws_client_modulerrrpendingtaskrrrs `` @@@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.._importgs_    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_requirementsr^sS t/ / / b0///// ?,gwyy O O OOrcc eZdZUdZdZdZdZdZded<dZ d=fd Z e d>dZ d?dZ d@dZdAdZdZdBdZdddCdZdBdZdDd!ZdBd"ZdBd#ZdBd$Z dEdFd.Zdd/dGd2Z dHdId:Ze dJd>Z dKdLd@Ze dMdCZe dNdEZe dOdFZ dPdQdIZ dRdSdLZ! dPdTdNZ" dPdUdPZ#dVdWdQZ$ dPdXfdS Z% dPdYfdU Z&dZdVZ'd[dWZ(d\dYZ)d]dZZ*dBd[Z+d\d\Z,d^d^Z-d\d_Z.d\d`Z/d\daZ0d\dbZ1d\dcZ2d\ddZ3d_dfZ4d`dgZ5e dadiZ6dbdkZ7dcdmZ8dddpZ9dddqZ:d?d?drdedtZ;d?d?drdfduZ<d_dvZ=dgdxZ>d\dyZ?dhd{Z@did}ZAdjd~ZBdkdZCdldZDdmdZEdndZFdidZGdodZHdpdZIdqdZJdVdrdZKdddsdZLdidZMdtdZNdudZOe dvdZPdidZQdwdZRdwdZSdwdZTdxdZUdydZVe dzdZWe d{dZXe d|dZYd}dZZd~dZ[ddZ\dudZ]e dvdZ^didZ_dwdZ`e ddZadwdZbdwdZcddZdddĄZee ddDŽZfddʄZgdd̄Zhdd΄Zidd҄Zje ddԄZke ddքZle ddڄZme ddۄZne dd܄Zoe ddބZpe dd߄Zqe ddZre ddZsddddZtddZuddddZvddZwdndZxd%dddZye ddZze ddZ{ddZ|ddZ} dddddZ~ddZddZddZddZdBdZdBdZdBdZddZdddd Zd%d%d d dd ZddZe ddZe ddZd%dddZddZdBdZdBdZdBdZddZddZdBdZe ddZe dd Ze dd!Ze dd$Ze dd'Ze dd)Ze dd*Ze dd+Ze dd-Ze dd/Ze dd2Ze dd3Ze dd5Ze dd6Zd[d7Zdd:Ze dd<ZxZS( 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]rrEr^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 rar!z/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-dSrrEr^rs rar!z/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_PATHrrprrprrorrrFEISHU_REQUIRE_MENTIONr)r])r1rQrrr+rrrErrosgetenvr~warningrrJr9rG_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_PATHrqrn) 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> > rcsettingsrc|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_policyr r_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_pathrrzrr{rr|rrr _allow_botsr_require_mention)rr.s rarzFeishuAdapter._apply_settingsRsZ #.$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 rarbz4FeishuAdapter._build_event_handler..|T445UW[\\rcc0d|S)Nim.message.reaction.deleted_v1rLrNs rarbz4FeishuAdapter._build_event_handler..rPrcdrive.notice.comment_add_v1vc.bot.meeting_invited_v1)r3builderr4r5®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_handlerqs# ! )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) rrrrr concurrentfuturesThreadPoolExecutorrrlockexecutors ra_get_sdk_executorzFeishuAdapter._get_sdk_executorst1488 <>##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_executorrw)rfuncrrs 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)r~)rrrshutdownrkrts ra_shutdown_sdk_executorz$FeishuAdapter._shutdown_sdk_executorst1488 < F  & &)-D &t_d;;H!%D  & & & & & & & & & & & & & & &   F *   5  > > > > > * * *   5  ) ) ) ) ) ) *s# AA AA-- BBF) is_reconnectrrcxKd|_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.rzO[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: %srw)rrr~errorr0r1r3r5r4rrB_FEISHU_APP_LOCK_SCOPErrrQrr1_set_fatal_errorrryr_connect_with_retry_mark_connectedinfor2r}_release_app_lock)rracquiredexisting owner_pidrdrs 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: %sTrwz<[Feishu] Cancelling websocket thread tasks and stopping looprrcdtjD}tdt ||D]}|djdS)Nc:g|]}||Sr]rrs rar6zFFeishuAdapter.disconnect..cancel_all_tasks..(s%VVVqQVVXXVVVVrcz3[Feishu] Found %d pending tasks in websocket threadg?)rrr~rrr 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_futurer~r TimeoutErrorr!r}call_soon_threadsafershieldCancelledErrorrrr_persist_seen_message_idsr_mark_disconnectedr)rrofuturerr 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  Krr cKd|D}|D]}||rtj|ddid{V|dS)Nc>g|]}|||Sr]r)r^rs rar6z7FeishuAdapter._cancel_pending_tasks..Is*OOODdO499;;O4OOOrcrT)rrrrclear)rrrrs rarz#FeishuAdapter._cancel_pending_tasksHsOOELLNNOOO  D KKMMMM  C.'BTBB B B B B B B B rcc|j|j|jdSr)rrrrrjs rarz"FeishuAdapter._reset_batch_buffersPsG "((*** '--/// #))+++++rcc|jdS t|jddn#t$rYnwxYwd|_dS#d|_wxYw)N_auto_reconnectF)rryr}rjs rarz/FeishuAdapter._disable_websocket_auto_reconnectUsl ? " F # DO%6 > > > >    D #DOOOdDO " " " "s"; /;/; AcK|jdS |jd{Vd|_d|_dS#d|_d|_wxYwr)rcleanuprrjs rarz"FeishuAdapter._stop_webhook_server_su   ' 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}t t |}d} |D]} || |\} } | || | ||d{V} n#t$r} | dks'tt| std| |d tjd t#| id ||d{V} Yd} ~ nd} ~ wwxYw| dkr|| sttt'| d d pd r]td | |d tjd t#| id ||d{V} | }||dS#t$rE} td| dtdt| cYd} ~ Sd} ~ wwxYw)zSend a Feishu message.F Not connectedsuccessrN prefer_postrrrrrrzI[Feishu] Invalid post payload rejected by API; falling back to plain textrrtmsgrzJ[Feishu] Post payload rejected by API response; falling back to plain textz send failedz[Feishu] Send error: %sTrw)rr<format_messagetruncate_messageMAX_MESSAGE_LENGTHr_MARKDOWN_HINT_REsearch_build_outbound_payload_feishu_send_with_retryr}_POST_CONTENT_INVALID_RErr~r!rwrxrg_response_succeededr_finalize_send_resultr)rrrrr formattedchunksr last_responsechunkrrresponsers rasendzFeishuAdapter.sendls| De?CCC C''00 &&y$2IJJ,33I>>??  * =$ )$ )$($@$@{%A%%!'%)%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 rcu✅ Allow Oncervprimaryu ✅ Sessionrwu ✅ Alwaysrxu❌ DenyrudangerzD **Smart DENY:** owner override applies to this one operation only.rwide_screen_modeTu ⚠️ Command Approval Requiredr0rrorangerrr.z``` z ``` **Reason:** rr+rrrr;rrtrrzsend_exec_approval failedrrrz&[Feishu] send_exec_approval failed: %srh)rrrrrrrr)rr<nextrrrrwrxrrrrrr}r~r!r)rrrrrrrrr cmd_previewrr scope_noterrrr\rrs @rasend_exec_approvalz FeishuAdapter.send_exec_approvals| De?CCC C8 =t566K47LL44G4G'%4%.500WK       t,niHHIG IM IttM3DEEFFF"INN44 6F#G#GHHH NN44 FH== > > >eqyaawyJ-t4)KT`aa ( *#d;#d#d;#dXb#d#d (#*  D$jE:::G!99&! :H//:UVVF~ #."("3"9r&55$[1 M = = = NNCS I I Ie3s88<<< < < < < < < =sD._btn!s3 ,?? 39(1  rcrTu⚕ Update Needs Your Inputr0rrrr.rr+u✓ Yesyru✗ Nonrrr)rrrrrrrrr])rrhr 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)rrhrrtrNrzsend_update_prompt failedrrz&[Feishu] send_update_prompt failed: %s)rr<rrrwrxr rrrrrr}r~r!r) rrrrhrrrrrr\rs rasend_update_promptz FeishuAdapter.send_update_prompt>s` | 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❌✅ResolvedrTr8r0rredgreenrr.z **z** by rr)r|r1)r riconrs ra_build_resolved_approval_cardz+FeishuAdapter._build_resolved_approval_cardas&((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: r0rrrrr.zAnswered by **rLrrr])rryesrs ra"_build_resolved_update_prompt_cardz0FeishuAdapter._build_resolved_update_prompt_cardtsm&$)4014(?%%a%aZ_%a%ajvww'*5GG #/M /M/M/MNN   rcctdz }|d}||||dS)Nz.update_responsez.tmp)rD with_suffix write_textrF)r response_pathtmp_paths ra_write_update_prompt_responsez+FeishuAdapter._write_update_prompt_responsesT')),>>  ,,V44F###'''''rc audio_pathcaptioncHK||||||dd{VS)z@Send audio to Feishu as a file attachment plus optional caption.rr file_pathrrr"outbound_message_typeN_send_uploaded_file_message)rrr!r"rrrs ra send_voicezFeishuAdapter.send_voiceU55 ") 6         rcr%rcHK|||||||d{VS)z*Send a document/file attachment to Feishu.)rr%rrr"rNr')rrr%r"rrrrs ra send_documentzFeishuAdapter.send_documentsU55 6         rc video_pathcHK||||||dd{VS)zSend a video file to Feishu.rr$Nr')rrr-r"rrrs ra send_videozFeishuAdapter.send_videor*rc 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_tagrrrrtzimage send failedz$[Feishu] Failed to send image %s: %sTrw)rr<rpathexistsiorreadBytesIObasenamer_build_image_upload_body_FEISHU_IMAGE_UPLOAD_TYPE_build_image_upload_requestr|rrrcreate_extract_response_field_response_error_result_build_media_post_payloadrrwrxrr}r~rr)rrr0r"rrr_iof image_bytes image_filerr}upload_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_typing s 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: %sTrw)rrQr"rr)rr0r"rr)_download_remote_imager}r~rr send_imagerN) rrrQr"rrr0rrs rarTzFeishuAdapter.send_image s" #::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: %sTrw)rrUr"rrz[GIF downgraded to file] z[GIF downgraded to file])rr%rr"rr)_download_remote_documentr}r~rrsend_animationr,) rrrUr"rrr%rrdegraded_captionrs rarZzFeishuAdapter.send_animation! se )-)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)rrrNrcdSr0r]r]rcrarbz-FeishuAdapter.get_chat_info..T ErcFrJr_rzchat lookup failedz0[Feishu] Failed to get chat info for %s: [%s] %srO chat_typerr)rrrrz'[Feishu] Failed to get chat info for %sTrw)rrr1r_build_get_chat_requestr|rrchatrr~r!rrEr_map_chat_typer}) rrfallbackcachedr}rrJrrO raw_chat_typers ra get_chat_infozFeishuAdapter.get_chat_infoC 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.r rrs rarzFeishuAdapter.format_messageh s}}rcrOc|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)rrOr start_drainers rarYzFeishuAdapter._on_message_eventp 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. reventNrdrrr_zA[Feishu] Pending-inbound queue full (%d); dropped oldest event %sTzI[Feishu] Queued inbound event for replay (loop not ready, queue depth=%d)) rrrrpoprrr}r~rrrr!)rrOdroppedrurdrdepth should_starts rarnz,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.ruNrdrrzA[Feishu] Dropping malformed inbound event: missing message/senderrz2[Feishu] Dropping duplicate/missing message_id: %sz#[Feishu] dropping inbound event: %sr`p2p)rOrdrr`ris_bot)rr~r _is_duplicate_admit_process_inbound_messager)rrOrurdrrreasonr`s rarrz(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.ruNrdrrz([Feishu] Ignoring message_read event: %s)rr~r)rrOrurdrs rarWz$FeishuAdapter._on_message_read_event sUgt,,%D11WlD99?R  ?LLLLLrcct|dd}tt|ddpd}td||j|ddS)z'Handle bot being added to a group chat.ruNrrz[Feishu] Bot added to chat: %srrr~rrrvrrOrurs rar_z#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.ruNrrz"[Feishu] Bot removed from chat: %srrs raraz'FeishuAdapter._on_bot_removed_from_chat! segt,,geY339r:: 8'BBB !!'400000rcc:tddS)Nz'[Feishu] User entered P2P chat with botr~rrrOs rarcz"FeishuAdapter._on_p2p_chat_entered( s >?????rcc:tddS)Nz![Feishu] Message recalled by userrrs rarez"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_commentrrrmr~r!rqrr;)rrOrrs rargz%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_inviterrrmr~r!rq)rrOrrs rarhz'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.ruNrr operator_type reaction_typercreatedaddedremovedz?[Feishu] Reaction %s on message %s (operator_type=%s, emoji=%s)>rrrcdSr0r]r]rcrarbz2FeishuAdapter._on_reaction_event..a surc)rrr~rrrrq_handle_reaction_event) rrrOrurrreaction_type_objrr+rs rarMz FeishuAdapter._on_reaction_eventJ 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 readyNrur+rrr)ru action_valuer) rrmr~r!r1rrQrr1_handle_approval_card_action!_handle_update_prompt_card_actionrq_handle_card_action_event)rrOrrur+rrupdate_prompt_actions rar]z%FeishuAdapter._on_card_action_triggerf 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.NrcdSr0r]r]rcrarbz7FeishuAdapter._loop_accepts_callbacks.. sPUrcrr)rs rarmz%FeishuAdapter._loop_accepts_callbacks 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)r~ log_message log_levelNFT)agent.async_utilsrr~loggingWARNINGadd_done_callback_log_background_failure)rrrrrs rarqzFeishuAdapter._submit_on_loop sc>>>>>>)) $No     >5  !=>>>trcrct|pd}|sdSt|jt|jz}|sdSd|vp||vS)zBReturn whether this card-action operator may answer gated prompts.rFTrN)rrEr r8r7)rrr allowed_idss ra#_is_interactive_operator_authorizedz1FeishuAdapter._is_interactive_operator_authorized smB''--//  5$,''#d.G*H*HH  4k!>Z;%>>rcrurc |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 unknownrruoperatorrrrrrrFrz*[Feishu] Unauthorized approval click by %s contextrzE[Feishu] Approval callback chat mismatch for %s (expected=%s, got=%s))rr rrrraw)r r)r1r~rr1rrzrrr _allow_group_messager!_get_cached_sender_namerq_resolve_approvalr0rrrOr)rrurrrstater rrrcallback_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)r1r~rr1rrrErrr rr!rrq_resolve_update_promptr0rrrOr)rrurrrrrrrrrrrrrs 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 ||| s{|d krwt |ddp|pd} | rP | | dd{VdS#t$r tddYdSwxYwdSdSdS#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)ruuk⌛ That approval had already expired — the command was not run (it timed out or was resolved elsewhere).z'[Feishu] expired-approval notice failedTrwz9Failed to resolve gateway approval from Feishu button: %s)rr1r~rrr!rrvtools.approvalrrrr}r) rrr rrrrrrr_chatrs 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    _Vv-- EIIi44EE2FF__"ii!T %___ %NY] ^^^^^^_ _ _--__ [ [ [ LLTVY Z Z Z Z Z Z Z Z Z [s7:A-F9(F&F0,F9/F00F99 G)G$$G)cK|j|}|std|dS|r[t |d}|||dddstd||dSt|ddpd}|r'|r%||krtd |||dS|j|d}|std |dS | |t d |d ||dS#t$r&} t d | Yd} ~ dSd} ~ wwxYw)z@Persist an update prompt answer for the detached update process.rNrrrFrz=[Feishu] Unauthorized update prompt click by %s for prompt %sz=[Feishu] Update prompt %s chat mismatch (expected=%s, got=%s)zD[Feishu] Update prompt %s already resolved while validating callbackzAFeishu update prompt resolved for session %s (answer=%s, user=%s)rz*Failed to resolve Feishu update prompt: %s) rr1r~rr rr!rrvr rr}r) rrrrrrrrrrs rarz$FeishuAdapter._resolve_update_promptO s)--i88  LLPR[ \ \ \ F  'DDDI,,Y )R8P8PY^,__ ^`girsssuyyB77=2>>   ,<,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.NrurrrcdSr0r]r]rcrarbz6FeishuAdapter._handle_reaction_event.. srcrOrrrrTrr`rz5[Feishu] Failed to fetch message for reaction routingTrwrrrUNKNOWNrrrz reaction:rr Feishu Chat chat_infoevent_chat_typer user_id_altrrr`rr thread_idrrrsource raw_messagerchannel_prompt timestampzD[Feishu] Routing reaction %s:%s on bot message %s as synthetic event)rrr_build_get_message_requestr|rrrdr1r0r}r~r_resolve_sender_profilerg build_source_resolve_source_chat_typer9r:TEXT_resolve_channel_promptrnowr_handle_message_with_guards)rrrOrurr}rrrrr chat_type_raw user_id_objrrr+synthetic_textsender_profilerrsynthetic_events rarz$FeishuAdapter._handle_reaction_eventx sz|  Fgt,, b99?R@@   F 55jAAG!// 0B0J0NPWXXXXXXXXH #N78Y #N#N#P#P GHfd;;WdKKQrE#-%((C S(D11F764,,233t|CC'#y"55;<. s,wwwBcBhQvFvFv1FvFvFvrcTF)r|rr)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.ruNrrz1[Feishu] Dropping duplicate card action token: %srrrrzB[Feishu] Card action missing chat_id or operator open_id, droppingr+rr!rz/card r8Frt)rrrrrr`rrrrrrzB[Feishu] Routing card action %r from %s in %s as synthetic command)rrrr~rrwrxr}r rrgrr1rr9r:COMMANDuuiduuid4rrrrr)rrOrurrrrrr+ 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) rr1 move_to_endrrrlockedrvriterrr)rrruevictedr.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)rrrhandle_message)rrur chat_locks rarz)FeishuAdapter._handle_message_with_guards s*AF T'%, 266<"RT''00  - - - - - - - -%%e,, , , , , , , , - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -sA00 A:=A:cxtjdddvS)NFEISHU_REACTIONSr)>0nofalse)rr rErrjs 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 CreateMessageReactionRequestBodyrrcdSr0r]r]rcrarbz-FeishuAdapter._add_reaction..9 rcrO reaction_idz7[Feishu] Add reaction %s on %s rejected: code=%s msg=%srJrz%[Feishu] Add reaction %s on %s raisedTrw)rrr r rUrrirrr|rrmessage_reactionrCrr~rr}r!) rrrr r rr}rrOs ra _add_reactionzFeishuAdapter._add_reaction$ s| : Z 4!          188:: j9::  -4466J''d##  "// 0B0S0Z\cddddddddH :GGHiGGII :x66t]D999 LLI&$//%..         NN7       tsDE.X rrcTz:[Feishu] Remove reaction %s on %s rejected: code=%s msg=%srJrz([Feishu] Remove reaction %s on %s raisedrw)rrrrUrrrir|rrrdeleterr~rr}r!)rrrrr}rs ra_remove_reactionzFeishuAdapter._remove_reactionL 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)r|rr1#_FEISHU_WEBHOOK_ANOMALY_TTL_SECONDS!_FEISHU_WEBHOOK_ANOMALY_THRESHOLDr~r!)rr)r*rentryr _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.baser7r)rrr4r7_config_extras rarz%FeishuAdapter._resolve_channel_prompt sS BAAAAA$$//'4006B%%fgyAAArcrrdrr`rcK||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_idr4upper_message_idrrrrz\[Feishu] Inbound %s message received: id=%s type=%s chat_id=%s sender=%s:%s text=%r media=%drr]r`rrrrrorrrrrr)rrr`rrrrr) rrrrr media_urls media_typesreply_to_message_id reply_to_textrr)_extract_message_contentr:rrnr<rr~rrar_fetch_message_textrrrrgrrr1rr9rrr_dispatch_inbound_event)rrOrdrr`rrr inbound_typer?r@rrrrArBsender_primaryrrrrrs rarz&FeishuAdapter._process_inbound_message sGKFcFcdkFlFl@l@l@l@l@l@l=lJ X ;+ + +,T8<@@@rcrincomingc|j|jko9|j|jko)|j|jko|jj|jjkSr)rrArBrrrrZs ra_media_batch_is_compatiblez(FeishuAdapter._media_batch_is_compatible5 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) rYrr1_schedule_media_batch_flushr]_flush_media_batch_nowr?rr@r_merge_captionrr)rrur.rs rarLz"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 rar_z)FeishuAdapter._schedule_media_batch_flushS s3 ##  +   #     rccKtj} tj|jd{V||d{V|j||ur|j|ddSdS#|j||ur|j|dwwxYwr)r current_taskr}rCr`rr1rv)rr.rgs rardz FeishuAdapter._flush_media_batchZ 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))rrvr~rrr?rrr.rus rar`z$FeishuAdapter._flush_media_batch_nowc s+//T::  F D   ! !   ..u55555555555rccbK||d}t||d{VS)NrJrr_)_guess_remote_extensionr?)rrQr_s rarSz$FeishuAdapter._download_remote_imagen sC**9f*EE))==========rcfile_urlrWrXrRcKddlm}ddlm}m}||st d|dd|ddd|gi 4d{V }||d d d  d{V}|t|j dd} |j } dddd{Vn#1d{VswxYwY| || ||} t| | } | | fS)Nr)_ssrf_redirect_guard)create_ssrf_safe_async_client is_safe_urlz&Blocked unsafe URL (SSRF protection): Pg>@Tr)rfollow_redirects event_hooksz)Mozilla/5.0 (compatible; HermesAgent/1.0)z*/*)z User-AgentAcceptheaders Content-Typer) content_type default_namerW) r8rotools.url_safetyrprqrr1raise_for_statusrrwr_derive_remote_filenamer>) rrmrWrXrorprqrrcontent_type_hdrrfilename cached_paths rarYz'FeishuAdapter._download_remote_documentr s @?????OOOOOOOO{8$$ WUhsPRsmUUVV V00!#&:%;<    $ $ $ $ $ $ $ $#ZZ"M#(H  % % ' ' ' #8#3#7#7#K#KLL #D# $ $ $ $ $ $ $ $ $ $ $ $ $ $ $ $ $ $ $ $ $ $ $ $ $ $ $$// )'# 0   0h?? H$$sA$C CCrct|pddddj}|tt zt zttzvr|n|S)Nr?rr) rrJsuffixr_IMAGE_EXTENSIONS_AUDIO_EXTENSIONS_VIDEO_EXTENSIONSr r=)rrhr_s rarlz%FeishuAdapter._guess_remote_extension soCI2$$S!,,Q/007==??/2CCFWWZ]^vZwZwwxxssF Frcryrzcvt|pddddjp|}t|j}|s^t j|pddddpdp|}||}|S)Nrrrr;)rrJrrr mimetypesguess_extensionrE)rmryrzrWrr_guesseds rar}z%FeishuAdapter._derive_remote_filename 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.. s0%v%v%v[d[^`dc=+P+PQU+V+V%v%v%vrccBg|]}t|Sr]rrs rar6z9FeishuAdapter._namespace_from_mapping.. s&RRRDM99$??RRRrcr])rQrr rrr*s rarz%FeishuAdapter._namespace_from_mapping sq eT " " x"ww%v%vhmhshshuhu%v%v%vww w eT " " SRRERRR R rcr}cN Kt|ddpd}|jd|jd|}||sGtd|||dtjddSt|d ipi}t| d d pd  d d  }|rN|dkrHtd||||dtjddSt|dd}|S|tkrHtd||||dtjddS tjt#|tt$d{V}n#t&$rJtd|||dtjddcYStj$rPtdt$|||dtjddcYSt*$r2||dtjdd d!d"cYSwxYw t/j|d#}nK#t.jt6f$r2||dtjdd$d!d"cYSwxYw|jr| d%pi} t| d&p| d&pd } | r>t;j| |jsGtd'|||d(tjd)d*S| d+d,kr*tjd-| d-d iS|j rb|!|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)@Nremoter_rz+[Feishu] Webhook rate limit exceeded for %s429izToo Many Requests)r*rrwrxrrrapplication/jsonz=[Feishu] Webhook rejected: unexpected Content-Type %r from %s415izUnsupported Media Typecontent_lengthz2[Feishu] Webhook body too large (%d bytes) from %s413izRequest body too largerz+[Feishu] Webhook body exceeds limit from %sz6[Feishu] Webhook body read timed out after %ds from %s408izRequest Timeout400izfailed to read body)rJr)r*utf-8z invalid jsonr;rz=[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>rKrRzcard.action.triggerrSrTz([Feishu] Ignoring webhook event type: %sok)/rr0rF_check_webhook_rate_limitr~r!r1rResponserr1rJrEr_FEISHU_WEBHOOK_MAX_BODY_BYTESrrr$_FEISHU_WEBHOOK_BODY_TIMEOUT_SECONDSrrr} json_responserwrdecoderUnicodeDecodeErrorr5hmaccompare_digestencoder4_is_webhook_signature_validrwrr3rrYrWr_rarMr]rgrhr) rr}r)rate_keyrwryr body_bytesrr;incoming_tokenrrOs ra_handle_webhook_requestz%FeishuAdapter._handle_webhook_request sGWh55B lEET%7EE)EE--h77 F NNH) T T T  ( (E : : :>> NNZ\hjs t t t  ( (E : : : > >>AMMrwrrc|t|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-signatureFrrF)errorsz3[Feishu] Signature verification raised an exceptionTrw) rr1rr4hashlibsha256r hexdigestrrr}r~r) rrwrrnoncer`body_strrcomputeds rarz)FeishuAdapter._is_webhook_signature_validsH $>CCIrJJ GKK 6;;ArBB $6;;ArBB   Y 5 !(((CCH"HEH4+<HhHHG~gnnW&=&=>>HHJJH&x'8'8):J:J:L:LMM M    LLNY]L ^ ^ ^55 s9BD&D;:D;rctj|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 rar6z;FeishuAdapter._check_webhook_rate_limit..Gs; a!R8BBBBBBrcuQ[Feishu] Webhook rate-limit table at capacity (%d keys) — denying untracked key) r|rr1r_FEISHU_WEBHOOK_RATE_LIMIT_MAXr_FEISHU_WEBHOOK_RATE_MAX_KEYSrr~r!)rrr.r window_start stale_keysrrs @rarz'FeishuAdapter._check_webhook_rate_limit1s?ikk)--h77  "' E<\!$GGG::: 57Only merge text events when reply/thread context is identical.)rArBrrr\s ra_text_batch_is_compatiblez'FeishuAdapter._text_batch_is_compatibleisC  (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.rNrrC)rrrrr1_last_chunk_lenr_schedule_text_batch_flushr_flush_text_batch_nowrArBrr) rrur. chunk_lenrexisting_count next_count appended_text next_texts rarJz!FeishuAdapter._enqueue_text_eventrs)""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)rrvrr~rrrrris rarz#FeishuAdapter._flush_text_batch_nows*..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)rrr~rr _bot_identity"_download_feishu_message_resources _resolve_normalized_message_typerr:rQrRrPrOrr_maybe_extract_text_documentrr) rrdrrrrr?r@rFrinjecteds rarCz&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/)rr<r:rOrRrP)rrhrs ra_resolve_media_message_typez)FeishuAdapter._resolve_media_message_typesz &B--//   * * %$ $   * * %$ $   * * %$ $rcr@rcN|j}|dkr+||r|dndtjS|dkr+||r|dndtjS|dkr+||r|dndtjStjS)Nrrrrrr)rrr:rOrRrQr)rrr@ preferreds rarz.FeishuAdapter._resolve_normalized_message_types 5   33k4YKNNWYcnct3uu u   33k4YKNNWYcnct3uu u  " "33k4YKNNWYcncw3xx xrcrcK|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 %sTrw)r<rr:getsize_MAX_TEXT_INJECT_BYTESrrr read_text_display_name_from_cached_pathOSErrorrr~r!)rrrr_rrs rarz*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}||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)NrVrrrrz+[Feishu] Failed to download image %s: %s %srJr_rrequest failedrxrrJallowedrkrz*[Feishu] Failed to cache image resource %sTrw)r_build_message_resource_requestr|rrmessage_resourcer1rr~r!r_read_binary_response_get_response_header_guess_extensionrrA_normalize_media_type_default_image_media_typer}) rrrr}r raw_bytesryrr_rrs rarz$FeishuAdapter._download_feishu_image:s| : 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)!NrV>rrrrz>[Feishu] Resource download failed for %s/%s via type=%s: %s %srJr_rrrxrrrrrrJrrkz,[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/%sTrw) rrrr|rrrr1rr~rrrrr_guess_media_type_from_filenamer<rrrArrrr@rdrrr>_DOCUMENT_MIME_TO_EXT_guess_document_media_typer}r!)rrrrr request_types request_typer}rrryresponse_filenamerrr_rs rarz/FeishuAdapter._download_feishu_message_resourceYs| : 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)rrrrr=)rfile_objs rarz#FeishuAdapter._read_binary_responses`8VT22  3 8Z ( ( .**,,-- -X]]__%%%rcrc \t|dd}t|dipi}t||||dpddddS)Nrrwrrrr)rrr1rrJrE)rrrrws rarz"FeishuAdapter._get_response_headersht,,#y"--37;;tW[[r%B%BCCIrJJPPQTVWXXYZ[aacciikkkrcrrrct|pdj}||vr|Stj|pddddpd}||vr|S|SNrrrr)rrrrrrJrE)rryrhrr_rs rarzFeishuAdapter._guess_extensions8>r"")//11 '>>J+\-?R,F,FsA,N,Nq,Q,W,W,Y,Y,_,_,a,a,geghh g  Nrcc|pdddd}|p|Sr)rJrEr)ryrhrs rarz#FeishuAdapter._normalize_media_typesD"(b//Q77:@@BBHHJJ $W$rcct|pdj}tj|t j|pddpdS)Nrrzapplication/octet-stream)rrrr=r1r guess_type)rr_s rar z(FeishuAdapter._guess_document_media_typesQ8>r"")//11'+C1EhnRT1U1UVW1X1v\vwwwrcr:ctj|}|dd}t |dkr|dn|}t jdd|S)Nrr^rjz [^\w.\- ])rr:r?rJrr:r&)r:r?rrs rarz,FeishuAdapter._display_name_from_cached_pathsY7##D))sA&&#&u::??uQxx vlC666rcctj|pddpd}|r|St|pdj}|t vrd|dS|tvrd|dS|tvrt |SdS)Nrrrrr) rrrrrrrdrrrr)rrr_s rar z-FeishuAdapter._guess_media_type_from_filenames'B77:@bGGII  N8>r"")//11 # # #-CJJsOO-- - # # #-CJJsOO-- - # # # ::3?? ?rrcrfc|pd}|dkrdSd|vsd|vsd|vrdS|dkrdSdS)Nrrr]topicthreadforumr`)rEr)rfrs rarczFeishuAdapter._map_chat_typesm#)r002288::   4 j H $:$:g>S>S7  7trcrrct|dpd}|dvr|S|dkrdSdS)Nrr>rr`rr]r`)rr1rEr)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) rrrrrr 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)rr1r|rv)rrrer 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_rrrOrrrnicknameen_namez-[Feishu] Failed to resolve sender name for %sTrw)rrEr|r_fetch_bot_names_FEISHU_SENDER_NAME_TTL_SECONDSrrr1lark_oapi.api.contact.v3r'r<rUr user_id_typerir|contactv3rrrrQrr}r~r)rrrtrimmedr cached_namenamesr%oidrhitr'rUr}rrs rar!z+FeishuAdapter._resolve_sender_name_from_api%s   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)r7r])r^r5s rar6z2FeishuAdapter._fetch_bot_names..ds>>>s9c*>>>rcrrrJrrObotsci|]>\}}||t|dpd?S)rr)rr1rE)r^r5rs rarbz2FeishuAdapter._fetch_bot_names..psYCS&))/R006688rcz)[Feishu] Failed to fetch bot names for %sTrw)rr.rU http_methodr)GETuriqueries token_typesr(TENANTrir|r}rrwrr1rr}r~r)rr7reqresprrr;s rar,zFeishuAdapter._fetch_bot_names\s| 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)NrcdSr0r]r]rcrarbz3FeishuAdapter._fetch_message_text..r_rcFrJr_rzmessage lookup failedz3[Feishu] Failed to fetch parent message %s: [%s] %srOrrrrrrr)rrrrz*[Feishu] Failed to fetch parent message %sTrw)rrrrr|rrrdr1rr~r!_extract_text_from_raw_contentr_FEISHU_MESSAGE_TEXT_CACHE_SIZErr}) rrr}rrJrrparentrrrparent_mentionsrs rarDz!FeishuAdapter._fetch_message_textysS| : 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) rrrrQrrr1rrE)rrrrrrs rarGz,FeishuAdapter._extract_text_from_raw_contents.!#""$$     " +* *EOPZPceiEjEjtj)--.@AAApt ;%%''/4/rcr_cn|pd}|dvrdSd|dpdS)Nr>rJrLz image/jpegrrjpeg)rrd)r_normalized_exts rarz'FeishuAdapter._default_image_media_typesI)**,, . . .<>--c22>>rcrc |dS#t$rtdYdSwxYw)Nz-[Feishu] Background inbound processing failed)r\r}r~ exception)rs rarz%FeishuAdapter._log_background_failuresV 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 rar!z'FeishuAdapter._admit..s(TT1RSTQTTTTTTrcr`rrrrrrrrrFEISHU_ALLOW_ALL_USERS>1rr)GATEWAY_ALLOW_ALL_USERSdm_policy_rejectedrrr)r#rr;r<rr_require_mention_forrG_mentions_selfrr rErr7r) rrrd sender_idsself_idsris_grouprrmodes rarzFeishuAdapter._admits%f-- TT):D>DDFFJ^^^ty2B77==??EEGGK___t, t ,J1J$J ,++4(( FK . .)   ++*  +4#6#6w#?#? +**trccl|r|j|nd}|r|j|jS|jSr)r:r1rrH)rrrules rarXz"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) rr8r:r1rrrr9r6r7r r) rrrrsender_open_idsender_user_idrZr_rrrs 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 rarYzFeishuAdapter._mentions_self"sgy"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)NrTrrrrTF)rrEr;r<r=)rrrQrWmention_open_idmention_user_id mention_names rarfz#FeishuAdapter._message_mentions_bot2s   G $55J&z9dCCIrPPRRO&z9dCCIrPPRRO#GVT::@bGGIIL 4#4 "d&77744 4#4 "d&77744~ ,$."@"@tturcrc4td|DS)Nc3$K|] }|jV dSr)r)r^ras rar!z3FeishuAdapter._post_mentions_bot..Js$//19//////rc)any)rrs rargz FeishuAdapter._post_mentions_botIs//h//////rcrcDt|j|j|jS)Nr[)rr;r<r=rjs rarzFeishuAdapter._bot_identityLs*!%%    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 hydrationTrwrrrVrJixz[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.rOrapp_namez9[Feishu] Failed to hydrate bot name from application info)rr.rUr=r)r>r?rAr(rBrir|r}rrwr_parse_bot_responser1rEr;r~r!r=rr}r_build_get_application_requestr0 applicationv6r) rrCrDrrrmrrr}rrJrrts ra_hydrate_bot_identityz#FeishuAdapter._hydrate_bot_identitySs\|  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 %sTrw message_idsci|]E}t|#t|dFS)r{rrs rarbz8FeishuAdapter._load_seen_message_ids..sE(k(k(kDY\]aYbYbYhYhYjYj(kT):):C(k(k(krccFi|]\}}|dksdks |z k||S)r{rr])r^msg_idrrttls rarbz8FeishuAdapter._load_seen_message_ids..sD# # # %62SyyC1HHb3 B(6rcc|Srr])rvalids rarbz6FeishuAdapter._load_seen_message_ids..s qrc)r.reversec"i|] }|| Sr]r])r^rrs rarbz8FeishuAdapter._load_seen_message_ids..s!B!B!B!!U1X!B!B!Brc)rwrrrFileNotFoundErrorrrr~r!rQrr1r|_FEISHU_DEDUP_TTL_SECONDSrrrrErrkrsortedr>reversedrr) rr seen_datarr.r sorted_idsrrrs @@@rarz$FeishuAdapter._load_seen_message_idss. 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 %srw) rrImkdirrr>rErr~r!)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) r|rrrr1rrrr>rvr)rrrrseen_atstales rarzFeishuAdapter._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) NrrArrreply_in_thread uuid_value receive_idrrrrzfeishu_user_id:rrrr(r)r1r_build_reply_message_bodyrrr_build_reply_message_requestr|rrrrdreply_build_create_message_body_build_create_message_requestr<rJrC) rrrrrreffective_reply_torrr} _thread_idrreceive_id_types ra_send_raw_messagezFeishuAdapter._send_raw_message6s9&! 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)NrcdSr0r]r]rcrarbz3FeishuAdapter._response_succeeded..msercr)rs rarz!FeishuAdapter._response_succeededks,HN!L9mm!L!L!N!NOOOrc field_namect|sdSt|dd}|rt||dndS)NrO)rrr)rrrOs rarDz%FeishuAdapter._extract_response_fieldosJ00:: 4x..26@wtZ...D@rc)r7r6r7c|rtd||St|dd}t|d|}tdd|d||S)NF)rr raw_responserJr_rrz] )r<r)rrr6r7rJrs rarEz$FeishuAdapter._response_error_resultvsk  Ze>PXYYY Yx33h77%/@4/@/@3/@/@xXXXXrcc||s|||Std||d|S)N)r6Tr)rrr)rrEr<rD)rrr6s rarz#FeishuAdapter._finalize_send_resultsb''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)NrFrr^z:[Feishu] Connect attempt %d/%d failed; retrying in %ds: %s)range_FEISHU_CONNECT_ATTEMPTSr3_connect_websocket_connect_webhookr}rrrrr~r!rr})rattemptr wait_secondss rarz!FeishuAdapter._connect_with_retrysi566 2 2G 2(K77113333333333//111111111 2 2 2 % 66888"&//1111111116::: G| PaK,  mL11111111111111 2 2 2sAA D'BC<<DcFKtstd|jdkrtnt}|||_||_|jtd|j }|| rtd| d{Vt|j |jtjj|j|dg|_|dt(|j||_dS)Nz4websockets not installed; websocket mode unavailabler$failed to build Feishu event handlerzadapter loop is not readychannel)rrr event_handlerr extra_ua_tags)FEISHU_WEBSOCKET_AVAILABLErr2r+r,_build_lark_clientrrkrrrryrr0r1rLogLevelINFOrrzrr)rrrs rarz FeishuAdapter._connect_websockets&) WUVV V"&"3v"="=;..v66 "7799   &EFF Fz <4>>++<:;; ;((*********(<'m(- %+    ..  * O    rccKtstd|jdkrtnt}|||_||_|jtd| d{Vtj t}|j |j|jtj||_|jd{Vtj|j|j|j|_|jd{VdS)Nz/aiohttp not installed; webhook mode unavailablerr)client_max_size)FEISHU_WEBHOOK_AVAILABLErr2r+r,rrrkrryr Applicationrrouteradd_postrFr AppRunnerrsetupTCPSiterDrErr)rrrs rarzFeishuAdapter._connect_webhooksR' RPQQ Q"&"3v"="=;..v66 "7799   &EFF F((*********o.LMMM D.0LMMM"}S11"((********* [)=t?QSWSeff &&(((((((((((rcrc,tj|j|j|tj j  Sr) rr5rUrr0rr1rrrrri)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 ) NrrJru[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 %srrr^zC[Feishu] Send attempt %d/%d failed for chat %s; retrying in %ds: %szFeishu send failed)r_FEISHU_SEND_ATTEMPTSrrr_FEISHU_REPLY_FALLBACK_CODESr1r~r!r}rrrrr}r) rrrrrr last_erroractive_reply_torrrJrrs 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: %sTrw)rrCrr}r~r!)rrs rarzFeishuAdapter._release_app_lock*s&  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)rrrUrrir rs raraz%FeishuAdapter._build_get_chat_request8sK wyy ( (!)++33G<<BBDD Dw////rccdtvr8tj|St |S)Nr r)rr rUrrir rs rarz(FeishuAdapter._build_get_message_request>sK ')) + +$,..99*EEKKMM M*5555rccdtvr^tj|||St|||S)Nr!)rrr)rr!rUrrrrir rs rarz-FeishuAdapter._build_message_resource_requestDsi &')) 3 3)133J''(##m$$  *xm\\\\rcrrVcdtvrKtj||St ||S)Nrrs)rrrUrrVrir rss rarvz,FeishuAdapter._build_get_application_requestPsV "gii / /%-//d   f48888rcrrc*dtvrqtj||||St||||S)Nr$)rrrr) rr$rUrrrrrir rs rarz'FeishuAdapter._build_reply_message_body[s $ 1 1'/11!!(## 11j!!  +     rcrcdtvrKtj||St ||S)Nr#r)rr#rUrrrir rs rarz*FeishuAdapter._build_reply_message_requestmsZ GII - -#+--J''l++   *<PPPPrccdtvrKtj||St ||S)Nr&r)rr&rUrrrir rs rarz(FeishuAdapter._build_update_message_bodyxsZ % 2 2(022(##!!   'BBBBrccdtvrKtj||St ||S)Nr%r)rr%rUrrrir rs rarz+FeishuAdapter._build_update_message_requestsZ !WYY . .$,..J''l++   *<PPPPrcrc*dtvrqtj||||St||||S)Nr)rrrr) rrrUrrrrrir rs rarz(FeishuAdapter._build_create_message_bodys % 2 2(022J''(##!!j!!  !     rcrcdtvrKtj||St ||S)Nrrr)rrrUrrrir rs rarz+FeishuAdapter._build_create_message_requestsZ !WYY . .$,.. 11l++   \ZZZZrcr4rcdtvrKtj||St ||S)Nrr3)rrrUr4rrir r3s rar@z&FeishuAdapter._build_image_upload_bodysX #wyy 0 0&.00J''u   *EBBBBrccdtvr8tj|St |S)Nrr)rrrUrrir rs rarBz)FeishuAdapter._build_image_upload_requestsK 799 , ,%-//<<\JJPPRR RL9999rcrcdtvr^tj|||St|||S)Nrr)rrrUrrrrir rs rarz%FeishuAdapter._build_file_upload_bodysg "gii / /%-//9%%9%%d  idSSSSrccdtvr8tj|St |S)Nrr)rrrUrrir rs rarz(FeishuAdapter._build_file_upload_requestsK ')) + +$,..;;LIIOOQQ QL9999rcc t|Sr)rzris ra_build_post_payloadz!FeishuAdapter._build_post_payloads+G444rcr9ryctj||}|didg}||gtj|dSrs)rwrr setdefaultrrx)rr"r9rrs rarFz'FeishuAdapter._build_media_post_payloadsm*T55g>>??$$Wb11< * * *+C0&8 8 !V + ++V3 3'//rc)rr7)rrrr)r.rrr)rr )rrlr)rrrr)rr rr)NN) rrrrrrrrrr<) rrrrrrrrrr<)rNTTF)rrrrrrrrrrrrrrrrrr<)rrrhrrrrr)rrN) rrrrrhrrrrrrr<)r rrrrr)rrrrrr)rrrr)NNN) rrr!rr"rrrrrrr<)NNNN)rrr%rr"rrrrrrrrr<) rrr-rr"rrrrrrr<) rrr0rr"rrrrrrr<r)rrrr) rrrQrr"rrrrrrr<) rrrUrr"rrrrrrr<)rrrrrrrr)rOr rr)rOr rr)rOr"rr)rrrOr rr)rOr rr )rr rr)rr rr rr)rrrr)rur rrrr rr ) rr r rrrrrrrrr) rr rrrrrrrrrr)rrrr)rrrr)rur9rrrr)rrrrrr)rrrrrr)rrrrrr)rrrr)rur9r#r;rr)r)rr*rrr)r)rrr)rrr4r5rr5)rOr rdr rr r`rrrrrrr)rur9rr)rur9rr)rr9rZr9rr)r.rrr)rQrrr)rmrrWrrXrrrR)rrrhrrr) rmrryrrzrrWrrr)rr rr )r}r rr )rwr rrrr)rrrr)rr r.rrr rr)rdr rr)rrrrrr)rrrhr:rr:)rrr@rrr:)rrrrrr)rrrrrrR) rrrrrrrrrrR)rr rr)rr rrrr) rrryrrhrrrrr)ryrrhrrr)rrrr)r:rrr)rfrrr)rrrrrr)rr rrrr)rrrr)rrrrrr)r7rrr8)rrrrrrrr)r_rrr)rr rr)rr rdr rrQ)rrrr)r)rr rrrrrr)rdr rr)rrhrr)rrrr)rr)rrrr)rrrrrrR)rrr%rrrrrr"rrrr&rrr<) rrrrrrrrrrrr )rr rr)rr rrrr )rr r6rr7rrr<)rr r6rrr<)rr rr )rrrr )rrrr )rrrrrrrr )rrrVrrr ) rrrrrrrrrr )rrrr rr )rrrrrr ) rrrrrrrrrr )rrrr rr )r4rrr rr )rr rr )rrrrrr rr )r"rr9ryrr)r%rrrrrR)rrrrsupports_code_blockssplits_long_messagesrrrrr staticmethodrrrkrwr|rrrrrrrrrrr r rrr r)r,r/rNrPrTrZrgrrYrnrprrrWr_rarcrergrhrMr]rmrqrrrrrrrrrrr rrrrr"r(r1r3rrrErKrYr]rLr_rdr`rSrYrlr}rrrrrrrJrrcrrrCrrrrrrrrrrr rr rcrrrr!r,rDrGrrrrXrrYrfrgrryrrrrr(rrrDrErrrrrrrrarrrvrrrrrrr@rBrrrrFr __classcell__)rs@rarrs""""""" <&<&<&<&<&<&|c c c \c J9999>    @0QQQ **** 5:333333jS-S-S-S-j,,,, ####&&&&"#'-1 A=A=A=A=A=R !=!=!=!=!=!=J/-1 $"" I=I=I=I=I=V   \ B9;-1!=!=!=!=!=F   \ $    \  (((\("&"&-1      ."&#'"&-1     0"&"&-1      ."&"&-1 ;=;=;=;=;=z"&"&-1        @"&"&-1        D####JJJJJ(!!!!FM6M6M6M6^    :MMMM11111111@@@@::::    $MMMMRRRR8#-#-#-#-JZZZ\Z    ????6666p7777~4[4[4[4[4[4[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>>>>&%&%&%&%PFFF\F\\h;h;h;h;T.''''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*49DDDDDD4"&#'%+>=>=>=>=>=>=@3T3T3T3TjPPP\PAAA\A)- Y Y Y Y Y Y    22222    @))))&    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_URLSr1rs ra_accounts_base_urlrs ! % %f.DX.N O OOrccNt|tdSr)_ONBOARD_OPEN_URLSr1rs 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. rrxz!application/x-www-form-urlencodedrOrwrN) _REGISTRATION_PATHrrrr_ONBOARD_REQUEST_TIMEOUT_Srwrr=rrrr)rrrrOrCrDrrs 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: Nrrr1r)rrresmethodss ra_init_registrationr ss "&))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 PersonalAgentr r)r+ archetype auth_methodrequest_user_info device_codez7Feishu / Lark registration did not return a device_codeverification_uri_completerrz&from=hermes&tp=hermesz?from=hermes&tp=hermes user_codeinterval expire_inrm)rqr_urlrrrr )rrr rrs ra_begin_registrationr%s!&))H X$&& ((  C ''-((K VTUUU WW0" 5 5F f}}****"WW["--GGJ'',1WW[))0S   rcrrrrOptional[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_idr r)rrrrr> access_denied expired_tokenz [Feishu onboard] Registration %sNz)[Feishu onboard] Poll timed out after %ds) r| monotonicrrrrrwrr}printr1r~r!) rrrrdeadlinecurrent_domaindomain_switched poll_countrr r%r&rs ra_poll_registrationr0?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_asciir})rqrs ra _render_qrr:su   ! ! 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>s0:fj&999 6:v 6 66rcc@|dkrtnt}tj|||tj j  S)z9Build a lark Client for the given credentials and domain.r) r,r+rr5rUrrrrrrri)rrr sdk_domains ra_build_onboard_clientrAsk && 0 0mJ   J      4=( ) )  rcrOc8|ddkrdS|dp*|didpi}|dp|d|ddS) NrJrrrOrtrr)rr)r1)rOrs rarurus 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.rrrNrz%[Feishu onboard] SDK probe failed: %s)rAr.rUr=r)r>r?rAr(rBrir}rrurwrr}r~r)rrrrrCrDrrs rar<r<s&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_secondsrOrPc 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. rNz([Feishu onboard] Registration failed: %sN)_qr_register_innerrrrrwrr~r!)rOrPrs ra qr_registerrSsh*!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...rTr!z done.rz8 Scan the QR code above, or open this URL directly: z3 Open this URL in Feishu / Lark on your phone: rCzH Tip: pip install qrcode to display a scannable QR code here next timerrr)rrrrNrrrrr)r+r rr:r0minr>r1)rOrPrrr\bot_infos rarRrRsi  ,"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. rzPFeishu dependencies not installed. Run `hermes setup` to install Feishu support.r2rrrNrzFeishu send failed: zMedia file not found: rzFeishu media send failed: zANo deliverable text or media remained after processing MEDIA tagsT)rrrr)rrrr+r,rrrErrrrr:r;splitextr_MIGRATION_IMAGE_EXTSrN_MIGRATION_VIDEO_EXTSr/_MIGRATION_VOICE_EXTSr)_MIGRATION_AUDIO_EXTSr,rr})pconfigrrdrrWrXrprrr last_result media_pathis_voicer_es ra_standalone_sendrdOs mkll#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 HHHc8ddlm}m}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|dJ|dKd }|r|dL||dM|n|dLr |dN|dO|dP||dQ||r|dR|d Sd S)SuInteractive 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_valueremove_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?zr1rFrE)rfrgrhrirrjrkrlrmrnroexisting_app_idexisting_secret method_idx credentialsused_qrrrr domain_idxrrrVrrmode_idx access_idx default_allowr group_idx home_channels rainteractive_setuprsT RQQQQQQQQQ......L!!!#mO44O#m$788O? <===}95AA  F5 J ;  JKGQ <%--KK     M: ; ; ; FF < < < M:S:: ; ; ; ; ; ; ; ; <  SGG JQ R R R   \]]] XYYY5111  MS T T T FVL4888   MW X X X F"]8.>@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 *+++J "6KV[\\\bbddL0,l;;; ;\;;<<<<  1 2 2 0 J. / / /M2333J"&""###J"&""###' %8%%&&&&&''s7;B C" 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)rr rrenviron)rrs ra_apply_yaml_configr=sJz!!")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)rrr1)rrs ra _is_connectedrIs4 FGR ( ( .BE  (## $ $$rcc t|S)zDFactory wrapper that constructs FeishuAdapter from a PlatformConfig.)r)rs ra_build_adapterrPs   rcc|ddttttddgdtt dddt d d d d S)u:Plugin entry point — called by the Hermes plugin system.rrprrz-Run `hermes setup` to install Feishu support.rrTrtru🪽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_platformrrrrrrd)ctxs raregisterrUsb &*"%%':;D"/0.2-!#rc)r}r r~rrr)rr rr)rr rr)rrrr)rr rr)r,r-r.rrr)rArrr)rHrrr)Nr)rr rhrrirrr)r)rr rhrrirrrr)rrrr{)rr rrrr)rr rr)rr rrr) rHr rrrrrrrr) rr rrrrrrrr) rrrrrrrrrr)rrrr)rrrr)rrrrrr)rrrr)rr rr)rr rrrr)rrrrrr)rrrr)rr rr)rr rr<rr)rr )rr rr)rrrrrr)rrrr)rQr rrR)rrrrrrY)rr]rr)rrrr]rr)ror rpr rrr)rrrr)rrrryrr)r)rrrr)rrrr) rrrrrrrrrr)rrrr)rrrrrrrr)rrrrrrrr )rOrrr)rOrrPrrrr)rrrrrr(r __future__rrrconcurrent.futuresrqrrrrwrrrr:rr|rr dataclassesrrrpathlibrtypesr typingr r r r rr urllib.errorrr urllib.parserurllib.requestrraiohttpr ImportErrorrrrrrrrrrrrrrr r!r"r#r$r%r&rr(r)rr+r,rr.rr0r1rr3rr5rrrrgateway.configr6r7r8r8r9r:r;r<r=r>r?r@rAgateway.statusrBrChermes_constantsrDutilsrErFrG getLoggerrr~compilerfr_MARKDOWN_TABLE_RErerr _MENTION_RErK IGNORECASErrrrrr rArrrrrrrrr#r$r%r&r"r'r(r)rr-rrrrrr-r,rrzrr|r_FEISHU_BOT_MSG_TRACK_SIZErrr!r&rrHrrrrrrrr rr8rr%rIrerfrGr1r2rrrrrrrr  RejectReasonrr#r'r+r2r@rGrTrZrgrnrqrzrvrrrrrrrrrrrrr r rrrrrr&rrrrXrrarnrrrrrrr rr0qrcoder4rkr:r>rArur<r=rSrRr[r\r^r]rdrrrrrr]rcrars~---^#"""""    ######((((((((!!!!!!????????????????,,,,,,,,""""""++++++++NNNG CCCJJJ&BBBBBB ;:::::::????????000000JIIIII555555 DL"&!NMKKK(t3"$.33333333                        DCCCCCCC,,,,,,7777777777  8 $ $ BJ L!& 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|O90O90O90O90O90'O90O90O90vrPPPPHHHH.      > DDDDDDN     YKKK     7 7 7 7    *F#8&&&&nCBB@@@JJJ);5;5;5;5;5|m'm'm'm'`    %%%%!!! sI B B B $B))B32B37ADD&%D&!T&& T21T2