epj 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-YnwxYwdZ.dZ/dZ0dZ1dZ2dZ3dZ4dZ5dZ6dZ7dZ8dZ9dZ:dZ;dZdZ?dZ@dZAdZBdZCdZDdZEdZFdZGejHZIe-duZJe*duZKddlLmMZMmNZNddlOmPZPmQZQmRZRmSZSmTZTmUZUmVZVmWZWmXZXmYZYddlZm[Z[m\Z\ddl]m^Z^ddl_m`Z`maZambZbddlcmdZeddlcmfZgd dZhe jiejZkejldejmZnejldejmZoejldZpejldZqejldZrejldZsejldZtejldejuZvhdZwhd Zxhd!Zyd"eUjzDZ{d#Z|d$Z}d%d&hZ~hd'Zd(d)d)d*d*d+d+d,Zd-Zd.Zd.Zd/Zd0Zd1Zd2Zd3Zd4Zd5Zd6Zd7Zd8Zd9Zd:Zd;ZdZd?Zd@ZdAZdBdCdDdEdFZdGedH<dIdJdKdLdMZdGedN<d dUZdVZedWdXhZdYZdZZd[ZdVZd\d]d^Zd_d`d^ZdaZdbZdcZddZdeZdfZdgZdhZdiZejldjZejldZedkZedlZejldmZdnZhdoZedpqGdrdsZedpqGdtduZedpqGdvdwZedpqGdxdyZedpqGdzd{ZedpqGd|d}ZeGd~dZeGddZedZd dZddZddZddZddZddZddZÐddZĐddZŐddZƐdddZǐdddZȐddZɐddZddddZːddZ̐ddZ͐ddZ d ddZ d ddZdedddZѐd dZҐd!dZӐd!dZԐd"dZՐd#dZ֐d$dZאd$dZؐd%dZِd&d„Zڐd'dĄZېd(dńZܐd)dȄZݐd*dɄZސd+d˄Z d d,d̄Zd-d΄Zd.dфZd/dӄZd0dՄZd1dքZd2dڄZd3dۄZd3d܄ZGd݄dePZd4dZd4dZd5dZd6d7dZd6d8dZddd9dZ ddlZn#e,ef$rdZYnwxYwd:dZd;dZddZd>dZhdZhdZhdZd%d&hZdddddZd?dZd@dZd3dZd Zd?d ZdS(Au 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)webF)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_int)UnscopedSecretError) get_secretcz t||}n$#t$rtj|}YnwxYw||n|S)aScope-aware credential read with the default-profile startup fallback. Secondary profiles construct their adapters under a profile secret scope -- the scope is authoritative and a scoped miss returns ``default`` (no cross-profile borrow from ``os.environ``, which may hold another profile's value). The DEFAULT profile's adapter constructs and sends *unscoped* under multiplexing, where a bare ``get_secret`` would raise ``UnscopedSecretError`` and crash this path; there ``os.environ`` is that profile's own value, so fall back to it. Same pattern as the Slack ``SLACK_APP_TOKEN`` read (#59739) and ``gateway/platforms/whatsapp_common.py::_get_wsecret``. )_scoped_get_secret_UnscopedSecretErrorosgetenv)namedefaultvals F/home/thesage/.hermes/hermes-agent/plugins/platforms/feishu/adapter.py_get_scoped_secretr3sR w// ioo/33w.s 44z(^\|.*\|\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.mp4rAci|]\}}|| SrI).0extmimes r2 rMsUUUysDsUUUmessagestreamr=r@>rCrDrFrGpdfdocxlsppt)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_alwaysr`Dict[str, str]_APPROVAL_CHOICE_MAPz Approved oncezApproved for sessionzApproved permanentlyDenied)r]r^r_r`_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)rhribodyexcs r2!_read_limited_feishu_webhook_bodyrxs_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+) titletextrolabelvaluer/summarysubtitle description placeholderhint>tagurlhreflinktypetokenlocalechat_idopen_iduser_idfile_keymsg_typetemplateunion_id image_key message_type open_chat_id share_chat_idT)frozenc6eZdZUded<dZded<dZded<dS)FeishuPostMediaRefstrr file_namefile resource_typeN)__name__ __module__ __qualname____annotations__rrrIrNr2rras=MMMIMrNrcHeZdZUdZded<dZded<dZded<dZded<d S) FeishuMentionRefrrr/rFboolis_allis_selfN)rrrr/rrrrrIrNr2rrhsRDNNNNGFGrNrcBeZdZUdZded<dZded<dZded<d dZd S) _FeishuBotIdentityrrrrr/rkrc|r|jr ||jkS|r|jr ||jkSt|jo ||jkSN)rrrr/)selfrrr/s r2matchesz_FeishuBotIdentity.matchesvsZ  +t| +dl* *  +t| +dl* *DI4449#44rNN)rrrrr/rrkr)rrrrrrr/rrIrNr2rrpsYGGDNNNN555555rNrc^eZdZUded<eeZded<eeZded<dS) FeishuPostParseResultr text_contentdefault_factory List[str] image_keysList[FeishuPostMediaRef] media_refsN)rrrrrlistrrrIrNr2rrsZ!E$777J7777+05+F+F+FJFFFFFFrNrceZdZUded<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) rrrrrrrrrrrdictrrIrNr2rrsMMM"(((((!E$777J7777+05+F+F+FJFFFF',uT'B'B'BHBBBB M    $uT:::H::::::rNrczeZdZUded<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_namerjdedup_cache_sizefloattext_batch_delay_secondstext_batch_split_delay_secondstext_batch_max_messagestext_batch_max_charsmedia_batch_delay_seconds webhook_host webhook_port webhook_pathr[ws_reconnect_noncerZws_reconnect_intervalN Optional[int]ws_ping_intervalws_ping_timeoutadminsrdefault_group_policyrzDict[str, FeishuGroupRule] group_rulesnone allow_botsTrrequire_mention)rrrrrrrr frozensetrrrrrrrrIrNr2rrsKKKOOO''''MMM####))))    $$$$     !$$$$$&*****%)O))))&Y[[F(((( """"".3eD.I.I.IKIIIIJ O      rNrcpeZdZUdZded<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__rrsetrrrrIrNr2rrsnVVKKK%444I4444%444I4444&*O******rNrcveZdZUeeZded<eeZded<eeZded<dS) FeishuBatchStaterzDict[str, MessageEvent]eventsDict[str, asyncio.Task]taskszDict[str, int]countsN) rrrrrrrrrrIrNr2rrsl&+eD&A&A&AFAAAA%*U4%@%@%@E@@@@"U4888F888888rNr) self_echoself_ids_unknown bots_disabledbot_not_mentionedgroup_policy_rejectedsenderrc(t|dddvS)N sender_typer>appbot)getattr)rs r2_is_bot_senderrs 6=" - - ??rNrc t|dd}|tStdt|ddt|ddt|ddfDS)N sender_idc3K|]}||V dSrrIrJvs r2 z#_sender_identity..s>  rNrrr)rr)rsids r2_sender_identityr s &+t , ,C {{{  CD ) ) CD ) ) CT * *   rNrrc8td|S)Nz\\\1)_MARKDOWN_SPECIAL_CHARS_REsub)rs r2_escape_markdown_textrs % ) )'4 8 88rNrc"|dup |dkp|dkS)NTrntruerIrs r2 _to_booleanrs D= 9EQJ 9%6/9rNstyleDict[str, Any] | NonekeycN|sdSt||SNF)rget)rrs r2_is_style_enabledrs' u uyy~~ & &&rNctdgdtjd|D}d|dzz}|ds|drd|dn|}|||S)Nrc,g|]}t|SrI)rt)rJruns r2 z%_wrap_inline_code..sDDDSCDDDrNz`+`rn )maxrefindall startswithendswith)rmax_runfencervs r2_wrap_inline_coder*s1EDDBJud,C,CDDDEFFG 7Q; E//#.. N$--2D2D N;t;;;;$D "T "5 " ""rNlanguagecz|ddddS)N r" )stripreplace)r+s r2_sanitize_fence_languager1s2 >>   # #D# . . 6 6tS A AArNelementrct|ddpd}|d}t|tr|nd}t |drt |St |}|sdSt |drd|d}t |drd|d}t |d rd |d }t |d rd |d }|S)Nrrrcodebold**italic* underlinezz strikethroughz~~)rr isinstancerrr*r)r2rr style_dictrendereds r2_render_text_elementr> s w{{62&&," - -D KK E$UD11;tJV,,' &&&$T**H rV,,%$$$$X..#"x???[11(''''_55%$$$$ OrNctt|ddpdp$t|ddpd}t|ddpdp$t|ddpddd}|drdnd}d|d||dS) Nr+rlangrro r-```)r1rrr0r')r2r+r4trailing_newlines r2_render_code_block_elementrD s' GKK B ' ' -2..T#gkk&"6M6M6SQS2T2TH GKK # # )r**Sc'++i2L2L2RPR.S.S gfd "]]400:rrd 8 8 8T 8#3 8 8 88rNclddlm}|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_markdownrAr-c|dd|ddS)Nrnz ())groupr/)ms r2z/_strip_markdown_to_plain_text..4s7qwwqzz,R,RQWWQZZ=M=M=O=O,R,R,RrNz^>\s?r)flagsz ^\s*---+\s*$z---z ~~([^~\n]+)~~z\1z([\s\S]*?))gateway.platforms.helpersrFr0_MARKDOWN_LINK_RErr$ MULTILINE)rrFrs r2_strip_markdown_to_plain_textrQ+s988888 LL & &E  ! !"R"RTY Z ZE F8Rbl ; ; ;E F?E5 E E EE F#UE 2 2E F' 6 6E N5 ! !E LrNr0r min_valuecj t|}n#ttf$r|cYSwxYw||kr|n|S)zACoerce value to int with optional default and minimum constraint.)rj TypeErrorrurr0rRparseds r2 _coerce_intrW=sQU z "y((66g5s ((c2t|||}||n|S)Nr0rR)rWrUs r2_coerce_required_intrZFs$ 9 E E EFn77&0rNrocTt|}tjdd|iidSNrroF ensure_ascii)_build_markdown_post_rowsjsondumps)rorowss r2_build_markdown_post_payloadrcPs? $W - -D : 4     rNList[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. mdrrrrBFrkNonecsdSd}|rd|dggdS)Nr-rfrg)joinr/append)segmentcurrentrbs r2_flush_currentz1_build_markdown_post_rows.._flush_currentmsW  F))G$$ ==?? : KKw778 9 9 9rNrkrh) splitlinesr/r_MARKDOWN_FENCE_CLOSE_REmatch_MARKDOWN_FENCE_OPEN_RErk)ro in_code_blockrnraw_line stripped_lineis_fencermrbs @@r2r_r_\sj -r**+,, Gw//011')DGM&&((!! ((  > $ * *= 9 9 9(..}==      !   NN8 $ $ $ --M  !   x    N  5T733455rN mentions_mappayloadry%Optional[Dict[str, FeishuMentionRef]]c~t|}|sttSggg}tt |dd}|r|||dgpgD]_}t|tstd fd|D}|r||`td |ptS)N)rrrroc3<K|]}t|VdSr)_render_post_element)rJitemrrrys r2r z,parse_feishu_post_payload..sE%T:z<PPrNr-)rrr) _resolve_post_payloadrFALLBACK_POST_TEXT_normalize_feishu_textrrr/rkr;rrj) rzryresolvedpartsrrowrow_textrrs ` @@r2parse_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   rNct|}|r|St|tsiS|d}t |}|r|St |S)Npost)_to_post_payloadr;rr_resolve_locale_payload)rzdirectwrappedwrapped_directs r2rrsm g & &F  gt $ $ kk&!!G,W55N "7 + ++rNct|}|r|St|tsiStD]*}t||}|r|cS+|D]}t|}|r|cSiSr)rr;r_PREFERRED_LOCALESrvalues)rzrr candidaters r2rrs g & &F  gt $ $ !$W[[%5%566      !!$U++       IrNrct|tsiS|d}t|tsiSt |ddpd|dS)Nrorr)rro)r;rrrr)rros r2rrsq i & & mmI&&G gt $ $ Y]]7B//5266  rNrrrrc^ 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](rIatr@_allTr@alluser user_name@>imgimageraltz[Image: ]r~>raudiomediavideorrr>rrrrrr [Attachment: r>emojiemotion emoji_type:z[Emoji]brr->hrdividerz --- r4ro>pre code_block)rrrochildrenelementsr"c3K|]}||V dSrrI)rJparts r2r z'_render_post_element..*s'::TT:D::::::rN)r;rrrr/lowerr>rrr/rrkrr*rD_render_nested_postrj)r2rrryrrr escaped_labelrref display_namerrrrr4 nested_partsr extracteds r2r~r~sa '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.6P  ,T:z<XX        rNc3DK|]}t|}||VdSrrrs r2r z&_render_nested_post..@rrNr)r;rrrrjrr~r)rrrryrs ``` r2rr-s %,$U+++% xx            %  %eZ\RR  Mxx             2rN)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)rrrrrx)rrrrrrrrrphoto)rrrrrr>rrr)rrdocumentplaceholder_text)rrrrrrr merge_forward share_chat>card interactive)rr)rr/r_load_feishu_payload_build_mentions_maprrrrrrrrrrFALLBACK_IMAGE_TEXT_build_media_ref_from_payload_attachment_placeholderrr _normalize_merge_forward_message_normalize_share_chat_message_normalize_interactive_message)rrrrnormalized_typerzryr parsed_post mention_refsralt_text media_refrs r2normalize_feishu_messagerNs&,,"--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 MMrNc |rtj|ni}n#tj$rd|icYSwxYwt|tr|nd|iS)Nrro)r`loadsJSONDecodeErrorr;r)rrVs r2rrso%,7?K(((R  %%% $$$$%-- F66Iv3FFs 11c t|d|d|dt|d}t|}g}|r||||ddd|pt}td|dt||d  S) Nrrpreview)rrrrkeysrVr-r) entry_countrrrrr) _first_non_empty_textr_find_first_text_collect_forward_entriesrkextendrjr/FALLBACK_FORWARD_TEXTrrt)rzrentrieslinesrs r2rrs ! G I I'UVVV   E 'w//GE  U LL!99U##))++D/DL " !%!$W>>    rNc Bt|d|d|dt|d}t|d|d|d}g}|r|d |n|t|r|d |d |}t d |d ||d S)N chat_namer/r)rr/rrrrrz Shared chat: z Chat ID: r-r)rrr)rrrrkFALLBACK_SHARE_CHAT_TEXTrjr)rzrshare_idrrs r2rrs,% K   F G'EFFF I % I N## O$$H E/ 0Y001111 -...- +++,,,99U##L "!"%I>>    rNct|dtr|dn|}tt ||dt |d}t |}t|}g}|r|||D]}||kr|||r+|dd |d |dd pt}t||d ||d  S) Nrr)rrrrz Actions: , r- r)ractionsr) r;rrr_find_header_titler_collect_card_lines_collect_action_labelsrkrjr/FALLBACK_INTERACTIVE_TEXTr) rrz card_payloadr body_linesrrliners r2rrsY*4W[[5H5H$*O*O\7;;v&&&U\L !<(( G,LMMM  E %\22J$\22GE  U 5== LL   7 57!3!35566699U3B3Z((..00M4ML "!# W55    rNc 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_listrecordsrorz- sender_namerrr/rrrrorrr)rrorrrrz: )rr;rrrrrrkrr/rrrr _unique_lines) rz candidatesrrrrrr nested_typervs r2rrs>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;;; ' ' '  ! !!rNcnt|d}d|D}td|DS)NF in_rich_blockc,g|]}t|SrI)rrJrs r2r z'_collect_card_lines..s!AAA4(..AAArNcg|]}||SrIrIrs r2r z'_collect_card_lines..s>>>4>$>>>rN)_collect_text_segmentsr)rzr normalizeds r2rrsD "7% @ @ @EAA5AAAJ >>:>>> ? ??rNc g}t|D]}t|tst|ddp|dd}|dvrzt|d|d|dt|d }|r| |t|S) Nrrr>buttonpickeroverflow date_picker select_staticrr/r)rror/rr) _walk_nodesr;rrrr/rrrrkr)rzlabelsrrrs r2rrsFG$$ ! !$%%  $((5"%%=&")=)=>>DDFFLLNN V V V % HHV   HHV   HHW   T(L M M M     ! MM%   rNrct|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)r;rrrrrrrr/r_SUPPORTED_CARD_TEXT_KEYSrkr_SKIP_TEXT_KEYS)rrsegmentsrrnext_in_rich_blockrrs r2rr0s%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 OrNrc8t|ddpd}t|d|d|d}|dvr|nd}t |||S) Nrrrrr>rrrr)rrr/rr)rzrrreffective_types r2rrYs7;;z2..4"55;;==H% K   G FI '47I&I&I]]vN x9Tb c c ccrNrc>t|}|rd|dntS)Nrr)rFALLBACK_ATTACHMENT_TEXT)rnormalized_names r2rrds,,Y77O1@ ^ -? - - - -F^^rNct|tsdS|d}t|tsdS|d}t|trJt|d|d|dSt t |pdS)Nrheaderrrorr/)r;rrrrr)rzr$rs r2rris gt $ $r [[ " "F fd # #r JJw  E%a$UYYy%9%9599V;L;LeiiX^N_N_``` !#ekr"2"2 3 33rNrtuple[str, ...]ct|D]^}t|ts|D]C}||}t|trt |}|r|ccSD_dSNr)rr;rrrr)rzrnoderrrs r2rrusG$$&&$%%   & &CHHSMME%%% &3E:: &%%%%%%  & 2rNc#Kt|tr2|V|D]}t|Ed{VdSt|tr|D]}t|Ed{VdSdSr)r;rrrr)rrs r2rrs%) LLNN ) )D"4(( ( ( ( ( ( ( ( ( ) ) E4 ) ) )D"4(( ( ( ( ( ( ( ( ()) ) )rNrc|D]m}t|trt|}|r|cS-|>t|ttfs"tt|}|r|cSndSr')r;rrrr)rrrs r2rrs"" eS ! ! "/66J "!!!! "  z%$'F'F /E ;;J "!!!! 2rNcdfd }t||pd}|dd}|d d d d }d d |d D}d d |d D}t d|}|S)Nrr're.Match[str]'rkrc|d}pi|}|dS|jp|jpd}d|S)Nrr"rr)rJrr/r)rrrrr/rys r2_subz$_normalize_feishu_text.._subsSkk!nn!r&&s++ ;3x03;0&4zzrNrrrrAr-r.c3pK|]1}td|V2dS)r"N)_WHITESPACE_RErr/rs r2r z)_normalize_feishu_text..s>^^$**355;;==^^^^^^rNc3K|]}||V dSrrIrs r2r z)_normalize_feishu_text..s'EEEEEEEEErNr")rrr,rkr)_MENTION_PLACEHOLDER_RErr0rjsplit_MULTISPACE_REr/)rryr.cleaneds ` r2rrs&))$ ;;Googv..Goofd++33D$??Gii^^'--X\J]J]^^^^^GiiEEt)<)<EEEEEG  g..G ==??rNrct}g}|D]3}|r||vr ||||4|Sr)raddrk)rseenuniquers r2rrs[UUDF tt||   d MrNmentiontuple[str, str]cft|dd}t|trHtt|ddpd}|dkr|dfS|dkrd|fSdS|dStt|ddpdtt|ddpdfS)Nidid_typerrrrr)rr;rr)r: mention_idr>s r2_extract_mention_idsrAs$--J*c""ggy"55;<<BBDD i  r> ! i  z> !vv GJ 2 . . 4"55 GJ 2 . . 4"55 rNDict[str, FeishuMentionRef]c pi}|pgD]}tt|ddpd}|s%|dkrtd||<?t|\}}tt|ddpd}t||||||||<|S) NrrrTrr/rrr/)r/rr)rrrrAr/r)rrresultr:rrrr/s r2rrs+-F>r   ''5"--344   '>>*$777F3K /8877FB//5266<<>>&KKtKLL   s MrNSequence[FeishuMentionRef]cg}t}|D]}|jr |j|j|jf}||vr#|||jr|dU|jr(||jpdd|jd||jpd|rdd|dndS) Nrunknownz (open_id=rIz [Mentioned: rrr)rrrrr/r7rkrj)rrr8r signatures r2_build_mention_hintrJsED 0 0 ;  Zch7      : 0 LL [ 0 LLCH1 KKS[KKK L L L L LL.Y / / / /16 > -$))E** - - - -B>rNcT|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)rr/r)rJrs r2r z-_strip_edge_self_mentions.. sF  ;/CH - -v//rNTrrn)lstripr&rt_MENTION_BOUNDARY_CHARS_TRAILING_TERMINAL_PUNCTr'rstrip) rr self_names remainingnmafterirvtails r2_strip_edge_self_mentionsrWs  J   I   B''++ c"gghh'E q)@@@ I E     NN!ee !a%(,DDD FA!ee !a%(,DDD!}}  B}}R    CGG8,3355<    rN ws_clientadapterrhc  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 _configurerkrhc 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)rYrXsr2_apply_runtime_ws_overrideszC_run_official_feishu_ws_client.._apply_runtime_ws_overrides9s ` 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)re_ws_ping_timeout)rjrkrYoriginal_connects r2_connect_with_overridesz?_run_official_feishu_ws_client.._connect_with_overridesBsY  $ 0_F5R5R&-&?F? #  # /N&4P4P%,%=F> "0000rNconfcTtd|}|S)NzFFeishu _configure_with_overrides called but original_configure is None) RuntimeError)rrrErioriginal_configures r2_configure_with_overrideszA_run_official_feishu_ws_client.._configure_with_overridesIs<  %ghh h##D))##%%% rNc:g|]}||SrIdonerJts r2r z2_run_official_feishu_ws_client..\s%FFFQVVXXF1FFFrNreturn_exceptionsTro)rjr rkr rkr )rrr rkr )lark_oapi.ws.clientwsclientrqnew_event_loopset_event_looploop_ws_thread_loop websocketsconnectrrbstartrf all_taskscancelrun_until_completegatherstopclose) rXrYws_client_modulerrqrvpendingtaskrirurps `` @@@r2_run_official_feishu_ws_clientr-s`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(trdSt5tr ddddS ddl}ddlm}ddlm}m}m}m }m }m }m }m } m} m} m} m} m}m}ddlm}m}ddlm}m}ddlm}dd lm}m}dd lm }dd l!m"}n#tF$rYdddd SwxYwtI%id |d|d|d|d|d|d|d|d|d| d| d| d| d| d|d|d|||||||||dd  ddddS#1swxYwYdS)zDImport and bind the Feishu SDK after an explicit connection request.TNr)GetApplicationRequest)CreateFileRequestCreateFileRequestBodyCreateImageRequestCreateImageRequestBodyCreateMessageRequestCreateMessageRequestBodyGetChatRequestGetMessageRequestGetMessageResourceRequestP2ImMessageMessageReadV1ReplyMessageRequestReplyMessageRequestBodyUpdateMessageRequestUpdateMessageRequestBody)AccessTokenType HttpMethod) FEISHU_DOMAIN LARK_DOMAIN) BaseRequest) CallBackCardP2CardActionTriggerResponse)EventDispatcherHandler)ClientFr|rrrrrrrrrrrrrrrr) rrrrrrrFeishuWSClientFEISHU_AVAILABLE)&r_lark_import_lock lark_oapilark_oapi.api.application.v6rlark_oapi.api.im.v1rrrrrrrrrrrrrrlark_oapi.corerrlark_oapi.core.constrrlark_oapi.core.modelr5lark_oapi.event.callback.model.p2_card_action_triggerrr"lark_oapi.event.dispatcher_handlerr lark_oapi.wsr ImportErrorglobalsupdate)r|rrrrrrrrrrrrrrrrrrrrrrrrs r2_load_lark_oapirlswt 66  66666666  $ $ $ $ J J J J J J                                 C B B B B B B B G G G G G G G G 8 8 8 8 8 8         R Q Q Q Q Q = = = = = = =   166666666.    D #%:  !2  $%:  !"4  %&<   #$8  '(@  n  !2  ()B  '(@  "#6  &'>  #$8 '(@! " # $%*&&(+F&<, $5      8m666666666666666666s6 DAA=<D= BDBA$DD D cbtrdSddlm} |dddS#t$rYdSwxYw)zCEnsure Feishu dependencies are installed without importing the SDK.Trensurezplatform.feishuF)prompt)rtools.lazy_depsrrfrs r2check_feishu_requirementsrsct&&&&&& ////t uus ..c$ eZdZUdZdZdZdZdZded<dZ dFfd Z e dGdZ dHdZ dIdZdJdZdZdKdZdddLdZdKdZdMd!ZdKd"ZdKd#ZdKd$Z dNdOd.Zdd/dPd2Zd3Zd4Zd5Zd6Z dQdRd>Ze dSdBZ dTdUdCZ e dVdFZ!e dWdHZ"e dXdIZ# dYdZdLZ$ d[d\dOZ% dYd]dQZ& dYd^dSZ'd_d`dTZ( dYdafdV Z) dYdbfdX Z*dcdYZ+dddZZ,ded\Z-dfd]Z.dKd^Z/ded_Z0dgdaZ1dedbZ2dedcZ3deddZ4dedeZ5dedfZ6dedgZ7dhdiZ8didjZ9e djdlZ:dkdnZ;dldpZ<dmdsZ=dmdtZ>d3d3dudndwZ?d3d3dudodxZ@dhdyZAdpd{ZBded|ZCdqd~ZDdrdZEdsdZFdtdZGdudZHdvdZIdwdZJdrdZKdxdZLdydZMdzdZNd_d{dZOddd|dZPdrdZQd}dZRd~dZSe ddZTdrdZUddZVddZWddZXddZYddZZe ddZ[e ddZ\e ddZ]ddZ^ddZ_ddZ`d~dZae ddZbdrdZcddZde ddZeddZfddZgddÄZhddDŽZie ddʄZjdd̈́ZkddτZlddфZmddՄZne ddׄZoe ddلZpe dd݄Zqe ddބZre dd߄Zse ddZte ddZue ddZve ddZwddddZxddZyddddZzddZ{dwdZ|d%dddZ}e ddZ~e ddZddZddZ dddddZddZddZddZddZdKdZdKdZdKdZdd Zdd dd Ze dd Zd%d%ddddZddZddZe ddZe ddZd%dddZddZdKdZdKdZdKd Zdd"Zdd#ZdKd$Ze dd%Ze dd&Ze dd'Ze dd*Ze dd-Ze dd/Ze dd0Ze dd1Ze dd3Ze dd5Ze dd8Ze dd9Ze d:d;dd>Ze dd?Zddd@ZddCZe ddEZxZS( FeishuAdapterzFeishu/Lark bot adapter.T@rjCHAT_LOCK_MAX_SIZErWconfigrct|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.jsonrrn)=super__init__rFEISHU_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_orderr$_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 r2rzFeishuAdapter.__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* ##%%%%%rNrrrkrct|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 |dptdd dt |dptj dddt |dptj dddt |dptdd dt |dptd 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;t0dt5|d>p&tj d?t t6d@t |d@ptj dAt8pt8dBt;|dBdCdDEdFt;|dFdGd6EdHt=|dHdd6EdIt=|dIdd6Ed |d |d|dJ| dt |dtj dKdLS)NNrrropench|]D}t|#t|ESrIrr/rJus r2 z/FeishuAdapter._load_settings..Aggg!X[\]X^X^XdXdXfXfgs1vv||~~gggrNrch|]D}t|#t|ESrIrrs r2rz/FeishuAdapter._load_settings..rrNr)rrrrrc3K|]F}t|#t|VGdSrrrs r2r z/FeishuAdapter._load_settings..sCPPaQP3q66<<>>PPPPPPrNrrFEISHU_ALLOW_BOTSr>allrrzS[Feishu] Unknown allow_bots=%r, falling back to 'none'. Valid: none, mentions, all.r FEISHU_APP_IDrFEISHU_APP_SECRETrdomainrr{rFEISHU_CONNECTION_MODE websocketrFEISHU_ENCRYPT_KEYrFEISHU_VERIFICATION_TOKENrFEISHU_GROUP_POLICYrc3fK|],}||V-dSrr/rJrs r2r z/FeishuAdapter._load_settings..:sL**::<<* ******rNFEISHU_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@rrn%HERMES_FEISHU_TEXT_BATCH_MAX_MESSAGESr"HERMES_FEISHU_TEXT_BATCH_MAX_CHARSr'HERMES_FEISHU_MEDIA_BATCH_DELAY_SECONDSrFEISHU_WEBHOOK_HOSTrFEISHU_WEBHOOK_PORTrFEISHU_WEBHOOK_PATHrr[rrYrrZrrrFEISHU_REQUIRE_MENTIONrrI)rr;rrrrrr/rrr-r.rgwarningrr3r3r#r'_DEFAULT_DEDUP_CACHE_SIZEr&!_DEFAULT_TEXT_BATCH_DELAY_SECONDS _DEFAULT_TEXT_BATCH_MAX_MESSAGES_DEFAULT_TEXT_BATCH_MAX_CHARS"_DEFAULT_MEDIA_BATCH_DELAY_SECONDS_DEFAULT_WEBHOOK_HOSTrj_DEFAULT_WEBHOOK_PORT_DEFAULT_WEBHOOK_PATHrZrW) rraw_group_rulesrrrule_cfgper_chat_require_mention raw_adminsrrrs r2rzFeishuAdapter._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\22a6HI\^`6a6abbhhjjj> EIIh//W29_h3W3WXX^^``ffhhh>   +,,` :RT_0`0`eggeeggg > EIIm44d8JK_ac8d8deekkmmm>  # .//f3EFace3f3f  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> > rNsettingsrhc|j|_|j|_|j|_|j|_|j|_ |j |_ |j |_ t|j|_t|j|_|jp|j |_|j|_|j|_|j|_|j|_|j|_|j|_ |j!|_"|j#|_$|j%|_&|j'|_(|j)|_*|j+|_,|j-|_.|j/|_0|j1|_2|j3|_4|j5|_6|j7|_8|j9|_:dSr);r_app_idr _app_secretr _domain_namer_connection_moder _encrypt_keyr_verification_tokenr _group_policyrr_allowed_group_usersr_adminsr_default_group_policyr _group_rulesr _bot_open_idr _bot_user_idr _bot_namer_dedup_cache_sizer_text_batch_delay_secondsr_text_batch_split_delay_secondsr_text_batch_max_messagesr_text_batch_max_charsr_media_batch_delay_secondsr _webhook_hostr _webhook_portr _webhook_pathrrcrrdrrerror _allow_botsr_require_mention)rr1s r2rzFeishuAdapter._apply_settingsnsZ #.$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#. ( 8rNr ctdStjjjjfd fd j  j jjjdjdjS)Nc0d|S)Nim.message.reaction.created_v1_on_reaction_eventdatars r2rLz4FeishuAdapter._build_event_handler..T445UW[\\rNc0d|S)Nim.message.reaction.deleted_v1rOrQs r2rLz4FeishuAdapter._build_event_handler..rSrNdrive.notice.comment_add_v1vc.bot.meeting_invited_v1)rbuilderr7r8®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`r2_build_event_handlerz"FeishuAdapter._build_event_handlers& ! )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 rN%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 _shutdownr}zhermes-feishu-sdk) max_workersthread_name_prefix) rrrrrt concurrentfuturesThreadPoolExecutorrrlockexecutors r2_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)rqget_running_looprun_in_executorrz)rfuncrjrs r2 _run_blockingzFeishuAdapter._run_blockingsO')))T)$*@*@*B*BDP4PPPPPPPPPPrNc(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)rrrshutdownrTrws r2_shutdown_sdk_executorz$FeishuAdapter._shutdown_sdk_executorst1488 < F  & &)-D &t_d;;H!%D  & & & & & & & & & & & & & & &   F *   5  > > > > > * * *   5  ) ) ) ) ) ) *s# AA AA-- BBF) is_reconnectrrcKd|_|jr|jstddS|jdvr"td|jdS|jdkr*|js#|jstddStj td{VstddS |j|_ tt|j d |jji \}}|sqt!|t"r|d nd}d |rd |dndzdz}td||d|ddStj|_|d{V|td|j|jdS#t4$r_}|d{Vd|}|d|dtd|dYd}~dSd}~wwxYw)zConnect to Feishu/Lark.Fz3[Feishu] FEISHU_APP_ID or FEISHU_APP_SECRET not set>webhookr zT[Feishu] Unsupported FEISHU_CONNECTION_MODE=%s. Supported modes: websocket, webhook.rzO[Feishu] Webhook mode requires FEISHU_VERIFICATION_TOKEN or FEISHU_ENCRYPT_KEY.Nz [Feishu] lark-oapi not installedplatformrpidz@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: %sr`)rr3r4rgerrorr6r8r7rq to_threadrrr"_FEISHU_APP_LOCK_SCOPErrr;rr_set_fatal_errorr|r_connect_with_retry_mark_connectedinfor5rf_release_app_lock)rracquiredexisting owner_pidrOrws r2rzFeishuAdapter.connects&+"| 4#3  LLN O O O5  (@ @ @ LLf%   5  I - -t7O -SWSd - LLa   5&77777777  LL; < < <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!B(G(:A,G(( I2AI  IcKd|_||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: %sTr`z<[Feishu] Cancelling websocket thread tasks and stopping looprkrhcdtjD}tdt ||D]}|djdS)Nc:g|]}||SrIrxrzs r2r zFFeishuAdapter.disconnect..cancel_all_tasks..Ds%VVVqQVVXXVVVVrNz3[Feishu] Found %d pending tasks in websocket threadg?)rqrrgrhrtr call_laterr)rrws_thread_loops r2cancel_all_tasksz2FeishuAdapter.disconnect..cancel_all_tasksCs}VVG$5n$E$EVVV RTWX]T^T^___!""DKKMMMM))#~/BCCCCCrNz;[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] Disconnectedro) _running_cancel_pending_tasksrr_reset_batch_buffersrr!_disable_websocket_auto_reconnect_stop_webhook_server is_closedhasattrrqrun_coroutine_threadsaferwait_for wrap_futurergrh TimeoutErrorr$rfcall_soon_threadsafershieldCancelledErrorrrr_persist_seen_message_idsr_mark_disconnectedr)rrXfuturerwr ws_futurers @r2 disconnectzFeishuAdapter.disconnects (()GHHHHHHHHH(()HIIIIIIIII !!###O - ..000'')))))))))  !*",,..+ =11+  9))++^&w':6'B'BCPPPPPPPPPP LMMMM'   ;     G!   %n.F.F.H.H % LLW X X X D D D D D D  / /0@ A A AO   d Z[[[&w~i'@'@$OOOOOOOOOO GHHHH' c c cabbbbb) V V V TUUUUU d d d NPS^b cccccccc d# " ##%%% &&((($$&&&&&&&&& !!! +,,,,,sDA/D44)F F(F  F'A"I )K5(K K(K  KrrcKd|D}|D]}||rtj|ddid{V|dS)Nc>g|]}|||SrIrx)rJrs r2r z7FeishuAdapter._cancel_pending_tasks..es*OOODdO499;;O4OOOrNr|T)rrrqrclear)rrrrs r2rz#FeishuAdapter._cancel_pending_tasksdsOOELLNNOOO  D KKMMMM  C.'BTBB B B B B B B B rNc|j|j|jdSr)rrrrrms r2rz"FeishuAdapter._reset_batch_bufferslsG "((*** '--/// #))+++++rNc|jdS t|jddn#t$rYnwxYwd|_dS#d|_wxYw)N_auto_reconnectF)rrbrfrms r2rz/FeishuAdapter._disable_websocket_auto_reconnectqsl ? " F # DO%6 > > > >    D #DOOOdDO " " " "s"; /;/; AcK|jdS |jd{Vd|_d|_dS#d|_d|_wxYwr)rcleanuprrms r2rz"FeishuAdapter._stop_webhook_server{su   ' F &&..00 0 0 0 0 0 0 0#'D !%D   $(D !%D  % % % %s <A Nrrroreply_to Optional[str]rOptional[Dict[str, Any]]rc 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_postrrrzrrrzI[Feishu] Invalid post payload rejected by API; falling back to plain textrr]msgrzJ[Feishu] Post payload rejected by API response; falling back to plain textz send failedz[Feishu] Send error: %sTr`)rrformat_messagetruncate_messageMAX_MESSAGE_LENGTHr_MARKDOWN_HINT_REsearch_build_outbound_payload_feishu_send_with_retryrf_POST_CONTENT_INVALID_RErrgr$r`rarQ_response_succeededr_finalize_send_resultr)rrrorr formattedchunksr last_responsechunkrrzresponserws r2sendzFeishuAdapter.sends| 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 *.*<*._btn s.#$0UCC$/:;WW rNu✅ Allow Onceraprimaryu ✅ Sessionrbu ✅ Alwaysrcu❌ Denyr`dangerwide_screen_modeTu ⚠️ Command Approval Requiredrrororangerrrrrrrrr$rr]rNrzsend_exec_approval failedrrrrz&[Feishu] send_exec_approval failed: %sr0)rrrrrrrkr)rrnextrrk_format_exec_approvalr`rarrrrrrfrgr$r)rrrrrrrrrrrrrzrrErwrs @r2send_exec_approvalz FeishuAdapter.send_exec_approvals`| De?CCC C6 =t566K       t,niHHIG IM IttM3DEEFFF"INN44 6F#G#GHHH NN44 FH== > > >-t4)KT`aa ( *#'#=#=g{T`#a#a (#*  D$jE:::G!99&! :H//:UVVF~ #."("3"9r&55$[1 M = = = NNCS I I Ie3s88<<< < < < < < < =sD!D?? F  8FF F rr0 prompt_idc |rd|dnd}dfd }d d id ddddd||dd|ddd|dddgdgdS)Nz Default: `r!rrranswerrrkrcdd|d||ddS)Nr rr)hermes_update_prompt_actionupdate_prompt_idrrI)rrrrs r2rz5FeishuAdapter._build_update_prompt_card.._btnBs3 ,?? 39(1  rNrTu⚕ Update Needs Your Inputrrrrrrru✓ Yesyru✗ Nonrrr)rrrrrrrkrrI)rr0r default_hintrs ` r2_build_update_prompt_cardz'FeishuAdapter._build_update_prompt_card>s6=E222222       *40%B<XX$ #&/H,/H/HII#YY77XsH55      rNcK|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)rr0rr]rNrzsend_update_prompt failedrrz&[Feishu] send_update_prompt failed: %s)rrrrr`rar rrrrrrfrgr$r) rrrr0rrrrzrrErws r2send_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.r`❌✅ResolvedrTr"rrredgreenrrz **z** by rr)rgr)rriconrs r2_build_resolved_approval_cardz+FeishuAdapter._build_resolved_approval_cards&((uue#'' ;;)40(,%6%6u%6%6|LL%+v%5%5EE7 &"&CC5CC CC   rNrc`|dk}|rdnd}ddi|rdndd|d d |rd nd d dd|ddgdS)Nr YesNorTrrz Update prompt answered: rrrrrrzAnswered by **r6rrrI)rryesrs r2"_build_resolved_update_prompt_cardz0FeishuAdapter._build_resolved_update_prompt_cardsm&$)4014(?%%a%aZ_%a%ajvww'*5GG #/M /M/M/MNN   rNctdz }|d}||d||dS)Nz.update_responsez.tmputf-8encoding)r$ with_suffix write_textr0)r response_pathtmp_paths r2_write_update_prompt_responsez+FeishuAdapter._write_update_prompt_responsesY')),>>  ,,V44FW555'''''rN 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'rrrks r2 send_voicezFeishuAdapter.send_voiceU55 ") 6         rNr*rcHK|||||||d{VS)z*Send a document/file attachment to Feishu.)rr*rrr'rNr,)rrr*r'rrrrks r2 send_documentzFeishuAdapter.send_documentsU55 6         rN video_pathcHK||||||dd{VS)zSend a video file to Feishu.rr)Nr,)rrr2r'rrrks r2 send_videozFeishuAdapter.send_videor/rN 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_tagrrrr]zimage send failedz$[Feishu] Failed to send image %s: %sTr`)rrr-pathexistsiorreadBytesIObasenamer/_build_image_upload_body_FEISHU_IMAGE_UPLOAD_TYPE_build_image_upload_requestrrrrcreate_extract_response_field_response_error_result_build_media_post_payloadrr`rarrfrgrr)rrr5r'rrrk_iof image_bytes image_filervrhupload_responser post_payloadmessage_responserws r2send_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.NrI)rrrs r2 send_typingzFeishuAdapter.send_typing" s trN 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: %sTr`)rrVr'rr)rr5r'rr)_download_remote_imagerfrgrr send_imagerS) rrrVr'rrr5rwrs r2rYzFeishuAdapter.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.r5z animation.gif) default_extpreferred_nameNz,[Feishu] Failed to download animation %s: %sTr`)rrZr'rrz[GIF downgraded to file] z[GIF downgraded to file])rr*rr'rr)_download_remote_documentrfrgrrsend_animationr1) rrrZr'rrr*rrwdegraded_captionrs r2r_zFeishuAdapter.send_animationB 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)rr/rNrcdSrrIrIrNr2rLz-FeishuAdapter.get_chat_info..u ErNFr4rHrzchat lookup failedz0[Feishu] Failed to get chat info for %s: [%s] %srR chat_typerr/)rr/rrz'[Feishu] Failed to get chat info for %sTr`)rrrr_build_get_chat_requestrrrchatrrgr$rr/r_map_chat_typerf) rrfallbackcachedrhrr4rrR raw_chat_typers r2 get_chat_infozFeishuAdapter.get_chat_infod 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.rrros r2rzFeishuAdapter.format_message s}}rNrRc|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)targetr/daemonN) r_loop_accepts_callbacks_enqueue_pending_inbound_eventrThread_drain_pending_inbound_eventsr_submit_on_loop_handle_message_event_data)rrRr start_drainers r2r\zFeishuAdapter._on_message_event sz++D11  ??EEM  =9%''' F T4#B#B4#H#HIIIIIrNcT|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. reventNrOrrrHzA[Feishu] Pending-inbound queue full (%d); dropped oldest event %sTzI[Feishu] Queued inbound event for replay (loop not ready, queue depth=%d)) rrtrrpoprrrfrgrrkrr$)rrRdroppedrzrOrdepth should_starts r2rsz,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.rzNrOrrzA[Feishu] Dropping malformed inbound event: missing message/senderrz2[Feishu] Dropping duplicate/missing message_id: %sz#[Feishu] dropping inbound event: %srep2p)rRrOrreris_bot)rrgrh _is_duplicate_admit_process_inbound_messager)rrRrzrOrrreasonres r2rwz(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!!&)) ,           rNrct|dd}t|dd}t|ddpd}td|dS)z7Ignore read-receipt events that Hermes does not act on.rzNrOrrz([Feishu] Ignoring message_read event: %s)rrgrh)rrRrzrOrs r2rZz$FeishuAdapter._on_message_read_event4 sUgt,,%D11WlD99?R  ?LLLLLrNct|dd}tt|ddpd}td||j|ddS)z'Handle bot being added to a group chat.rzNrrz[Feishu] Bot added to chat: %srrrgrrr{rrRrzrs r2rbz#FeishuAdapter._on_bot_added_to_chat; segt,,geY339r:: 4g>>> !!'400000rNct|dd}tt|ddpd}td||j|ddS)z+Handle bot being removed from a group chat.rzNrrz"[Feishu] Bot removed from chat: %srrs r2rdz'FeishuAdapter._on_bot_removed_from_chatB segt,,geY339r:: 8'BBB !!'400000rNc:tddS)Nz'[Feishu] User entered P2P chat with botrgrhrrRs r2rfz"FeishuAdapter._on_p2p_chat_enteredI s >?????rNc:tddS)Nz![Feishu] Message recalled by userrrs r2rhz"FeishuAdapter._on_message_recalledL s 899999rNcddlm}|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_commentrrrrrgr$rvrr>)rrRrrs r2rjz%FeishuAdapter._on_drive_comment_eventO s WVVVVVz++D11  NN_ ` ` ` F   & &t|THY Z Z Z     rNcddlm}|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_inviterrrrrgr$rv)rrRrrs r2rkz'FeishuAdapter._on_meeting_invited_eventa ss______z++D11  NN` a a a F T#?#?d#K#KLLLLLrN 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.rzNrr operator_type reaction_typercreatedaddedremovedz?[Feishu] Reaction %s on message %s (operator_type=%s, emoji=%s)>rrrcdSrrIrIrNr2rLz2FeishuAdapter._on_reaction_event.. surN)rrrgrhrrrv_handle_reaction_event) rrrRrzrrreaction_type_objrrrs r2rPz FeishuAdapter._on_reaction_eventk s3gt,, b99?R@@ GE?B??E2FF #E?DAA!2L"EEKLL %33 M        z ^ + + ,|=GD+}}==??@@ F T4#>#>z4#P#PQQQQQrNc|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 readyNrzrrrr)rz action_valuer) rrrrgr$rrr;rr_handle_approval_card_action!_handle_update_prompt_card_actionrv_handle_card_action_event)rrRrrzrrrupdate_prompt_actions r2r`z%FeishuAdapter._on_card_action_trigger spz++D11 Z NNW X X X4OY.000UY Ygt,,$//vw339r =G VZ=[=[e ((999ae ,-- 8L  : ; ; ;37   h445|bf4gg g  99):  T4#A#A$#G#GHHH & .4*,,,rNrcZ|duo'tt|dd S)zEReturn True when the adapter loop can accept thread-safe submissions.NrcdSrrIrIrNr2rLz7FeishuAdapter._loop_accepts_callbacks.. sPUrNrr)rs r2rrz%FeishuAdapter._loop_accepts_callbacks s64Y-VWT; -V-V-X-X(Y(Y$YYrNcorocddlm}|||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)rg log_message log_levelNFT)agent.async_utilsrrgloggingWARNINGadd_done_callback_log_background_failure)rrrrrs r2rvzFeishuAdapter._submit_on_loop sc>>>>>>)) $No     >5  !=>>>trNrct|pd}|sdSt|jt|jz}|sdSd|vp||vS)zBReturn whether this card-action operator may answer gated prompts.rFTr8)rr/rr;r:)rrr allowed_idss r2#_is_interactive_operator_authorizedz1FeishuAdapter._is_interactive_operator_authorized smB''--//  5$,''#d.G*H*HH  4k!>Z;%>>rNrzrc |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 unknownrr`operatorrrrrrrFrz*[Feishu] Unauthorized approval click by %s contextrzE[Feishu] Approval callback chat mismatch for %s (expected=%s, got=%s))rrrrrraw)rr)rrgrhrrrerrr _allow_group_messager$_get_cached_sender_namerv_resolve_approvalrrrrRr)rrzrrrstaterrrrcallback_chat_idexpected_chat_idr chat_contextrrrs r2rz*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 HMrNc 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>r r z8[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)rrgrhrrrr/rrr rr$rrv_resolve_update_promptrrrrRr)rrzrrrrrrrrrrrrrs r2rz/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 HMrNrrcK|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)r`uk⌛ That approval had already expired — the command was not run (it timed out or was resolved elsewhere).z'[Feishu] expired-approval notice failedTr`z9Failed to resolve gateway approval from Feishu button: %s)rrrgrhrr$rr{tools.approvalrrrrfr) rrrrrrrrrr_chatrws r2rzFeishuAdapter._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) rrrgrhr rr$rr{r%rrfr) rrrrrrrrrrws r2rz$FeishuAdapter._resolve_update_promptp 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.NrzrrrcdSrrIrIrNr2rLz6FeishuAdapter._handle_reaction_event.. srNrRrrrr=rrerz5[Feishu] Failed to fetch message for reaction routingTr`rrrUNKNOWNrrrz reaction:rr/ Feishu Chat chat_infoevent_chat_typer user_id_altrrrerr thread_idrrrsource raw_messagerchannel_prompt timestampzD[Feishu] Routing reaction %s:%s on bot message %s as synthetic event)rrr_build_get_message_requestrrrrOrr3rfrgrh_resolve_sender_profilerl build_source_resolve_source_chat_typerrTEXT_resolve_channel_promptrnowr_handle_message_with_guards)rrrRrzrrhrrrrr chat_type_raw user_id_objrrrsynthetic_textsender_profilerrsynthetic_events r2rz$FeishuAdapter._handle_reaction_event sz|  Fgt,, b99?R@@   F 55jAAG!// 0B0J0NPWXXXXXXXXH #N78Y #N#N#P#P GHfd;;WdKKQrE#-%((C S(D11F764,,233t|CC'#y"55;<. s,wwwBcBhQvFvFv1FvFvFvrNTF)rrr)rrexpiredr{rs @r2_is_card_action_duplicatez'FeishuAdapter._is_card_action_duplicate sxikkwwww$":"@"@"B"Bwww , ,A(++ D, , ,4*- 'urNc 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.rzNrrz1[Feishu] Dropping duplicate card action token: %srrrrzB[Feishu] Card action missing chat_id or operator open_id, droppingrrr rz/card r"Fr])rrrr/rrJrrrrrrzB[Feishu] Routing card action %r from %s in %s as synthetic command)rrrrgrhr`rarfr rrlrrrrrCOMMANDuuiduuid4rrrrr)rrRrzrrrrrr action_tagrrrrrrrs r2rz'FeishuAdapter._handle_card_action_event sgt,,GE7B//5266  T33E::  LLLe T T T F%D11gg~r::@bAA5*d33gh 266<"== g  LL] ^ ^ ^ F$//33?x@@ vw339r .*..   "TdjE&R&R&R"T"TT    $GTDQQQ #;;IFFFFFFFF,,W55555555 ""mmF++GwG-44yZa4bb"9-$[1&}5#  '$,1DJLL 1 177@@lnn     XZdfmovwww..???????????s6E E E  asyncio.Lockc |j|}||j||St|j|jkrd}t |jD]?}|j|s|j|d}n@|s9|jtt|jtj }||j|<|S)a}Return (creating if needed) the per-chat asyncio.Lock for serial message processing. Bounded with LRU eviction so a long-running gateway that sees many distinct chats does not grow ``_chat_locks`` without limit. Locks that are currently held are never evicted; if every entry is locked we fall back to dropping the least-recently-used one. NFT) rr move_to_endrtrrlockedr{riterrqr)rrrxevictedrs r2_get_chat_lockzFeishuAdapter._get_chat_lock s##G,,     ( ( 1 1 1K t D$; ; ;GD,--  ',3355$((---"GE C $$T$t/?*@*@%A%ABBB|~~$(! rNrcK|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)rrzr chat_locks r2rz)FeishuAdapter._handle_message_with_guards2 s*AF T'%, 266<"RT''00  - - - - - - - -%%e,, , , , , , , , - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -sA00 A:=A:cxtjdddvS)NFEISHU_REACTIONSr>0nofalse)r-r.r/rrms r2_reactions_enabledz FeishuAdapter._reactions_enabledB s3y+V44::<<BBDDL```rNrc 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 CreateMessageReactionRequestBodyrrcdSrrIrIrNr2rLz-FeishuAdapter._add_reaction..Z rNrR reaction_idz7[Feishu] Add reaction %s on %s rejected: code=%s msg=%sr4rz%[Feishu] Add reaction %s on %s raisedTr`)rrrrrXrrlrrrrrmessage_reactionrHrrgrhrfr$) rrrrrrvrhrrRs r2 _add_reactionzFeishuAdapter._add_reactionE s| : Z 4!          188:: j9::  -4466J''d##  "// 0B0S0Z\cddddddddH :GGHiGGII :x66t]D999 LLI&$//%..         NN7       tsDE.y rrNTz:[Feishu] Remove reaction %s on %s rejected: code=%s msg=%sr4rz([Feishu] Remove reaction %s on %s raisedr`)rrrrXrrrlrrrrdeleterrgrhrfr$)rrrrrhrs r2_remove_reactionzFeishuAdapter._remove_reactionm 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 /rN 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. NrnrzY[Feishu] Webhook anomaly: %d consecutive error responses (%s) from %s over the last %.0fs)rrr#_FEISHU_WEBHOOK_ANOMALY_TTL_SECONDS!_FEISHU_WEBHOOK_ANOMALY_THRESHOLDrgr$)rr.r/rentryr _last_status first_seens r2_record_webhook_anomalyz%FeishuAdapter._record_webhook_anomaly s ikk,00;;  .3 +E<Z"EEE <<AANN.!j( : ""}`` in ``PlatformConfig.extra`` is honoured for Feishu chats instead of being silently ignored. r)resolve_channel_promptrNr)gateway.platforms.baser<r)rrr9r<_config_extras r2rz%FeishuAdapter._resolve_channel_prompt sS BAAAAA$$//'4006B%%fgyAAArNrrOrrercK||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_idr9upper_message_idrrrrz\[Feishu] Inbound %s message received: id=%s type=%s chat_id=%s sender=%s:%s text=%r media=%drrbrJrrrrrZrr/rrrr)rrrerrrrr) rrrrr media_urls media_typesreply_to_message_id reply_to_textrr)_extract_message_contentrrrWr&rrgrhrJr_fetch_message_textrrrtrlrrrrrrrr_dispatch_inbound_event)rrRrOrrerrr inbound_typerDrErrrrFrGsender_primaryrrrrrs r2rz&FeishuAdapter._process_inbound_message sGKFcFcdkFlFl@l@l@l@l@l@l=lJ X ;+ + +,T8<@@@rNrincomingc|j|jko9|j|jko)|j|jko|jj|jjkSr)rrFrGrrrr_s r2_media_batch_is_compatiblez(FeishuAdapter._media_batch_is_compatibleV sY  !X%: : G,0LL G&(*@@ G)X_-FF  rNcK||}|j|}|!||j|<||dS|||s<||d{V||j|<||dS|j|j|j|j|j r%| |j |j |_ |j |_ |j r |j |_ ||dSr) r^rr_schedule_media_batch_flushrb_flush_media_batch_nowrDrrEr_merge_captionrr)rrzrrs r2rQz"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  ((-----rNrcH||j||jdSr)_reschedule_batch_taskr_flush_media_batchrrs r2rdz)FeishuAdapter._schedule_media_batch_flusht s3 ##  +   #     rNcKtj} tj|jd{V||d{V|j||ur|j|ddSdS#|j||ur|j|dwwxYwr)rq current_taskrrFrerrr{)rrrls r2riz FeishuAdapter._flush_media_batch{ s+--  ?- ?@@ @ @ @ @ @ @ @--c22 2 2 2 2 2 2 2.22377<GG/33C>>>>>HGt.22377<GG/33C>>>>Hs :B :CcK|j|d}|sdStd|t |j||d{VdS)Nz6[Feishu] Flushing media batch %s with %d attachment(s))rr{rgrrtrDrrrrzs r2rez$FeishuAdapter._flush_media_batch_now s+//T::  F D   ! !   ..u55555555555rNcbK||d}t||d{VS)Nr6rrK)_guess_remote_extensionr)rrVrKs r2rXz$FeishuAdapter._download_remote_image sC**9f*EE))==========rNfile_urlr\r]r;cKddlm}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_namer\) r=rttools.url_safetyrurvrurraise_for_statusrr|ro_derive_remote_filenamer) rrrr\r]rtrurvrrcontent_type_hdrrvfilename cached_paths r2r^z'FeishuAdapter._download_remote_document 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?rnr) rr3suffixr_IMAGE_EXTENSIONS_AUDIO_EXTENSIONS_VIDEO_EXTENSIONSrr)rr0rKs r2rqz%FeishuAdapter._guess_remote_extension soCI2$$S!,,Q/007==??/2CCFWWZ]^vZwZwwxxssF FrNr~rcvt|pddddjp|}t|j}|s^t j|pddddpdp|}||}|S)Nrrrnr;)rr3r/rr mimetypesguess_extensionr/)rrr~rr\rrKguesseds r2rz%FeishuAdapter._derive_remote_filename s(.b//Q77:;;@PL 9oo$**,, 0/1C0J0J3PQ0R0RST0U0[0[0]0]0c0c0e0e0kikll{p{G$/g//IrNrct|tr(tdid|DSt|tr d|DS|S)NcJi|] \}}|t|!SrIr_namespace_from_mapping)rJrrs r2rMz9FeishuAdapter._namespace_from_mapping.. s0%v%v%v[d[^`dc=+P+PQU+V+V%v%v%vrNcBg|]}t|SrIrrs r2r z9FeishuAdapter._namespace_from_mapping.. s&RRRDM99$??RRRrNrI)r;rr rrrs r2rz%FeishuAdapter._namespace_from_mapping sq eT " " x"ww%v%vhmhshshuhu%v%v%vww w eT " " SRRERRR R rNrhcN 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)@NremoterHrz+[Feishu] Webhook rate limit exceeded for %s429izToo Many Requests)r/rr|r}rrrapplication/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)r4r)r/rz 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>rNrUzcard.action.triggerrVrWz([Feishu] Ignoring webhook event type: %sok)/rr3rI_check_webhook_rate_limitrgr$r6rResponserrr3r/r_FEISHU_WEBHOOK_MAX_BODY_BYTESrqrrx$_FEISHU_WEBHOOK_BODY_TIMEOUT_SECONDSrurrf json_responser`rdecoderUnicodeDecodeErrorr8hmaccompare_digestencoder7_is_webhook_signature_validr|rr8rr\rZrbrdrPr`rjrkrh) rrhr.rate_keyr|r~r body_bytesrzr$incoming_tokenrrRs r2_handle_webhook_requestz%FeishuAdapter._handle_webhook_request sGWh55B lEET%7EE)EE--h77 F NNH) T T T  ( (E : : :>> NNZ\hjs t t t  ( (E : : : > >>AMMr|rrlc|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-signatureFrr0)errorsz3[Feishu] Signature verification raised an exceptionTr`) rrrr7hashlibsha256r hexdigestrrrfrgrh) rr|rrnoncerIbody_strrocomputeds r2rz)FeishuAdapter._is_webhook_signature_valid;sH $>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. NFrnTc<g|]\}\}}|z tk|SrI)#_FEISHU_WEBHOOK_RATE_WINDOW_SECONDS)rJk_r~rs r2r z;FeishuAdapter._check_webhook_rate_limit..hs; a!R8BBBBBBrNuQ[Feishu] Webhook rate-limit table at capacity (%d keys) — denying untracked key) rrrr_FEISHU_WEBHOOK_RATE_LIMIT_MAXrt_FEISHU_WEBHOOK_RATE_MAX_KEYSrrgr$)rrr3r window_start stale_keysrrs @r2rz'FeishuAdapter._check_webhook_rate_limitRs?ikk)--h77  "' E<\!$GGG::: 57Only merge text events when reply/thread context is identical.)rFrGrrras r2_text_batch_is_compatiblez'FeishuAdapter._text_batch_is_compatiblesC  (H,H H G&(*@@ G)X_-FF rNcK||}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.rNrnr-)rrtrrr_last_chunk_lenr_schedule_text_batch_flushr_flush_text_batch_nowrDrErr) rrzr chunk_lenrexisting_count next_count appended_text next_texts r2rOz!FeishuAdapter._enqueue_text_events)""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)rr{rrgrrtrrrns r2rz#FeishuAdapter._flush_text_batch_nows*..sD99 '++C666  F 8    b ! !   ..u55555555555rNEtuple[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) Nrorrrz3[Feishu] Received raw message type=%s message_id=%srrrrr)rrrn>rrr)rrrgrr _bot_identity"_download_feishu_message_resources _resolve_normalized_message_typerrrVrWrUrTrtr_maybe_extract_text_documentrr) rrOrrrrrDrErKrinjecteds r2rHz&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  /!!+..."":...;&&rNrrc|pd}|dr tjS|dr tjS|dr tjS|S)Nrimage/audio/video/)rr&rrTrWrU)rr0rs r2_resolve_media_message_typez)FeishuAdapter._resolve_media_message_type2sz &B--//   * * %$ $   * * %$ $   * * %$ $rNrErc|j}|dkr+||r|dndtjS|dkr tjS|dkr+||r|dndtjStjS)Nrrrrrr)rrrrTVOICErVr)rrrE preferreds r2rz.FeishuAdapter._resolve_normalized_message_type=s 5   33k4YKNNWYcnct3uu u   $ $  " "33k4YKNNWYcncw3xx xrNrcK|r|dsdS tj|tkrdSt |j}|dvr|dvrdSt |d}| |}d|d|S#ttf$r!t d |d YdSwxYw) Nztext/r>.md.txt> text/plain text/markdownrrz [Content of z]: z7[Feishu] Failed to inject text document content from %sTr`)r&r-r?getsize_MAX_TEXT_INJECT_BYTESrrr read_text_display_name_from_cached_pathOSErrorrrgr$)rrrrKrors r2rz*FeishuAdapter._maybe_extract_text_documentSs  *"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)Nr?rrrrz+[Feishu] Failed to download image %s: %s %sr4rHrrequest failedr}rr6allowedrprz*[Feishu] Failed to cache image resource %sTr`)r_build_message_resource_requestrrrmessage_resourcerrrgr$r_read_binary_response_get_response_header_guess_extensionrr!_normalize_media_type_default_image_media_typerf) rrrrhr raw_bytesr~rrKrrs r2rz$FeishuAdapter._download_feishu_imagecs| : 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)!Nr?>rrrrz>[Feishu] Resource download failed for %s/%s via type=%s: %s %sr4rHrrr}rrrrrr6rrpz,[Feishu] Cached message image resource at %srrr=z,[Feishu] Cached message audio resource at %sroggrrGz,[Feishu] Cached message video resource at %sz/[Feishu] Cached message document resource at %sz/[Feishu] Failed to cache message resource %s/%sTr`) rrkrrrrrrrrgrhrrrr_guess_media_type_from_filenamer&rrr!rrrr rMrrr_DOCUMENT_MIME_TO_EXT_guess_document_media_typerfr$)rrrrr request_types request_typerhrr r~response_filenamerrrKrs r2rz/FeishuAdapter._download_feishu_message_resources| : 6& . . .   ( ( ()< < L; >>)%".? "&!3!3DLO4F4W4[]d!e!eeeeeee x'7'7'9'9 LLX" $&)<<%1ABB  66x@@  #88>RR $+Hk4$H$H$NB!,a0Aa EaEaW_EaEa!77  @@JJ8 ((22Z//,Xi/jjC"8"L"L"LKKK NP[\\\& (Yd6T6TUX6Y6YYYYY7**j.C.CH.M.M*//,Xi/jjC"8"L"L"LKKK NP[\\\&)Z7Z 3@XSX7Z7Z[[[[((223>>05&.#4#4#4";Ix"P"PKKK NP[\\\& 2222H~~,P?T1T1T"*O,A*,MOOH7 8LL  M{[[["Z%\43R3RS[3\3\]]]]   E!  vs4B LL)CLBLAL%A1L(MMrct|dd}|dSt|dr!t|St|S)NrrNgetvalue)rrrlrrB)rfile_objs r2rz#FeishuAdapter._read_binary_responses`8VT22  3 8Z ( ( .**,,-- -X]]__%%%rNr/c \t|dd}t|dipi}t||||dpddddS)Nrr|rrrnr)rrrrr3r/)rr/rr|s r2rz"FeishuAdapter._get_response_headersht,,#y"--37;;tW[[r%B%BCCIrJJPPQTVWXXYZ[aacciikkkrNrrrct|pdj}||vr|Stj|pddddpd}||vr|S|SNrrrnr)rrrrrr3r/)rr~r0rrKrs r2rzFeishuAdapter._guess_extensions8>r"")//11 '>>J+\-?R,F,FsA,N,Nq,Q,W,W,Y,Y,_,_,a,a,geghh g  NrNc|pdddd}|p|Sr)r3r/r)r~r0rs r2rz#FeishuAdapter._normalize_media_typesD"(b//Q77:@@BBHHJJ $W$rNct|pdj}tj|t j|pddpdS)Nrrzapplication/octet-stream)rrrrrr guess_type)rrKs r2rz(FeishuAdapter._guess_document_media_typesQ8>r"")//11'+C1EhnRT1U1UVW1X1v\vwwwrNr?ctj|}|dd}t |dkr|dn|}t jdd|S)NrrHrUz [^\w.\- ])r-r?rDr3rtr$r)r?rDrrs r2rz,FeishuAdapter._display_name_from_cached_pathsY7##D))sA&&#&u::??uQxx vlC666rNctj|pddpd}|r|St|pdj}|t vrd|dS|tvrd|dS|tvrt |SdS)Nrrrrr) rrrrrrrMrrrr)rrrKs r2r z-FeishuAdapter._guess_media_type_from_filenames'B77:@bGGII  N8>r"")//11 # # #-CJJsOO-- - # # #-CJJsOO-- - # # # ::3?? ?rrNrkc|pd}|dkrdSd|vsd|vsd|vrdS|dkrdSdS)NrrrbtopicthreadforumrJ)r/r)rkrs r2rhzFeishuAdapter._map_chat_type sm#)r002288::   4 j H $:$:g>S>S7  7trNrrct|dpd}|dvr|S|dkrdSdS)Nrr>r rJrrbrJ)rrr/r)rrrs r2rz'FeishuAdapter._resolve_source_chat_types^y}}V,,23399;;AACC ) ) )O e # #4wrNDict[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 r2rz%FeishuAdapter._resolve_sender_profile s")Y55=)Y55=9j$77?4' $*H1Gx!?? 6@        "%#   rNc|sdS|j|}|dS|\}}tj|kr|S|j|ddS)z>Return a cached sender name only while its TTL is still valid.N)rrrr{)rrrjr/ expire_ats r2rz%FeishuAdapter._get_cached_sender_nameAsl 4(,,Y77 >4 i 9;; " "K ##It444trNcK|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_rrrRrr/rnicknameen_namez-[Feishu] Failed to resolve sender name for %sTr`)rr/rr_fetch_bot_names_FEISHU_SENDER_NAME_TTL_SECONDSrrrlark_oapi.api.contact.v3r*r&rXr user_id_typerlrcontactv3rrrr;rrfrgrh)rrrtrimmedr cached_namenamesr(oidr/hitr*r>rhrrs r2r$z+FeishuAdapter._resolve_sender_name_from_apiNs   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 ttjdd|Dtj h }| |jj |d{V}tt|dddd}|sdStj|}|ddkrdS|dpidpi}d |DS#t&$r!t(d |d YdSwxYw) Nz"/open-apis/bot/v3/bots/basic_batchcg|]}d|fS)r:rI)rJr8s r2r z2FeishuAdapter._fetch_bot_names..s>>>s9c*>>>rNrror4rrRbotsci|]>\}}||t|dpd?S)r/r)rrr/)rJr8rs r2rMz2FeishuAdapter._fetch_bot_names..sYCS&))/R006688rNz)[Feishu] Failed to fetch bot names for %sTr`)rrrX http_methodrGETuriqueries token_typesrTENANTrlrrhrr`rrrrfrgrh)rr:reqresprorzr>s r2r/zFeishuAdapter._fetch_bot_namess| 7 4 ##%%Z^,,9::>>g>>>??o4566 ++DL,@#FFFFFFFFDgdE488)TJJG tj))G{{6""a''tKK''-2226::@bD!%      LLDgX\L ] ] ]44 sCE(/-E(A E(('FFcK|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)NrcdSrrIrIrNr2rLz3FeishuAdapter._fetch_message_text..rdrNFr4rHrzmessage lookup failedz3[Feishu] Failed to fetch parent message %s: [%s] %srRrrrvrrror)rrrrz*[Feishu] Failed to fetch parent message %sTr`)rrrrrrrrOrrrgr$_extract_text_from_raw_contentrt_FEISHU_MESSAGE_TEXT_CACHE_SIZEr rf) rrrhrr4rrparentrvrrparent_mentionsrs r2rIz!FeishuAdapter._fetch_message_textsS| : 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) rrrr;rrrrr/)rrrrrrs r2rJz,FeishuAdapter._extract_text_from_raw_contents.!#""$$     " +* *EOPZPceiEjEjtj)--.@AAApt ;%%''/4/rNrKcn|pd}|dvrdSd|dpdS)Nr>r6r8z image/jpegrrjpeg)rrM)rKnormalized_exts r2rz'FeishuAdapter._default_image_media_typesI)**,, . . .<>--c22>>rNrc |dS#t$rtdYdSwxYw)Nz-[Feishu] Background inbound processing failed)rErfrg exception)rs r2rz%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 dSrrIr s r2r z'FeishuAdapter._admit..s(TT1RSTQTTTTTTrNrerrrrrrrrrFEISHU_ALLOW_ALL_USERS>1rrGATEWAY_ALLOW_ALL_USERSdm_policy_rejectedrrr)r rr>r?rr_require_mention_forrJ_mentions_selfr-r.r/rr:r) rrrO sender_idsself_idsris_grouprrmodes r2rzFeishuAdapter._admits%f-- TT):D>DDFFJ^^^ty2B77==??EEGGK___t, t ,J1J$J ,++4(( FK . .)   ++*  +4#6#6w#?#? +**trNcl|r|j|nd}|r|j|jS|jSr)r=rrrK)rrrules r2r[z"FeishuAdapter._require_mention_forsD18Bt $$W---d  (D(4' '$$rNct|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) rr;r=rrrrr<r9r:rr) rrrrsender_open_idsender_user_idr]rbrrrs r2rz"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$JLLLrNc Jt|ddpd}d|vrdSt|ddpg}|r||rdStt|ddpd|t|dd|}||jS)NrorrTrrr)r_message_mentions_botrr_post_mentions_botr)rrOrrrs r2r\zFeishuAdapter._mentions_selfKsgy"55; k ! !47J55;  228<< 4- ."==C#Wj$77""$$    &&z':;;;rN List[Any]c|D]}t|dd}t|ddpd}t|ddpd}t|ddpd}|r|jr||jkrdS|r|jr||jkrdS|jr||jkrdSdS)Nr=rrrr/TF)rr/r>r?r@)rrr:r@mention_open_idmention_user_id mention_names r2riz#FeishuAdapter._message_mentions_bot[s   G $55J&z9dCCIrPPRRO&z9dCCIrPPRRO#GVT::@bGGIIL 4#4 "d&77744 4#4 "d&77744~ ,$."@"@tturNrc4td|DS)Nc3$K|] }|jV dSr)r)rJrKs r2r z3FeishuAdapter._post_mentions_bot..ss$//19//////rN)any)rrs r2rjz FeishuAdapter._post_mentions_botrs//h//////rNrcDt|j|j|jS)NrD)rr>r?r@rms r2rzFeishuAdapter._bot_identityus*!%%    rNcK|jsdS ttjdtj 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/inforrorrrz[[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 hydrationTr`rrr@r4ixz[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.rRrapp_namez9[Feishu] Failed to hydrate bot name from application info)rrrXr@rrArBrDrrErlrrhrr`r_parse_bot_responserr/r>rgr$r@rrfrh_build_get_application_requestr3 applicationv6r) rrFrGrorzrVrrrhrr4rrws r2_hydrate_bot_identityz#FeishuAdapter._hydrate_bot_identity|s_|  F  ##%%Z^,,-..o4566 ++DL,@#FFFFFFFFDgdE488)TJJG .*W--,W55;!::m44:AACC"JJz228b??AA0(T->'-I-Iy)0D%.~$.H*D*D E&.DN    LLE        >  F e99T[9\\G!// 0H0K0W0[]deeeeeeeeH 8#3#3#5#5 x668##NNW '(FD995$GGCZ66<"CCEEH * *!) * * * * e e e LLT_cL d d d d d d es,F"F00&GG&BKAK&LLc 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 %sTr` message_idsci|]E}t|#t|dFS)rrrs r2rMz8FeishuAdapter._load_seen_message_ids..sE(k(k(kDY\]aYbYbYhYhYjYj(kT):):C(k(k(krNcFi|]\}}|dksdks |z k||S)rrrI)rJmsg_idrrttls r2rMz8FeishuAdapter._load_seen_message_ids..sD# # # %62SyyC1HHb3 B(6rNc|SrrI)rvalids r2rLz6FeishuAdapter._load_seen_message_ids..s qrN)rreversec"i|] }|| SrIrI)rJrrs r2rMz8FeishuAdapter._load_seen_message_ids..s!B!B!B!!U1X!B!B!BrN)r`rrrFileNotFoundErrorrrrgr$r;rrr_FEISHU_DEDUP_TTL_SECONDSrrrr/rrTrusortedrAreversedrr) rrz seen_datarrr sorted_idsrrrs @@@r2rz$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|SrI)r)rJrrs r2rMz;FeishuAdapter._persist_seen_message_ids..s2&s&s&sWX\`\rWrWrq$*@*CWrWrWrrN)indentz,[Feishu] Failed to persist dedup state to %sr`) rrLmkdirrrAr%rrgr$)rrecentrzs` r2rz'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) rrrrrrrkrtrAr{r)rrrrseen_atstales r2rzFeishuAdapter._is_duplicates|ikk'    ,00<7 D>;D>;C>D>> E  E r)r'rr+r+cK|jstddStj|stdd|S|ptj|}|||\} } d} | dkr||} t|d5} | | || | } | | }| |jj j jj|d{V}dddn #1swxYwY||d }|s||d d S|r=d||d}||d|||||d{V}n||| t)jd |id||d{V}||s5t/|dddkr| dkr|pidr|pid}|s0||pidd{V}|rPt4d||| t)jd |id||d{V}||sPt4d||| t)jd |idddd{V}||dS#t<$rF}t4d||dtdtA|cYd}~Sd}~wwxYw)NFrrzFile not found: )r*requested_message_typeropusr7 file_typerrdurationrzfile upload failedz#Feishu file upload missing file_keyr:r)rrrrr=rr]r4iRrrrFz0[Feishu] Audio: retrying via reply API in threadz;[Feishu] Audio send failed in thread, retrying with chat_idzfile send failedz#[Feishu] Failed to send file %s: %sTr`)!rrr-r?r@rD_resolve_outbound_file_routingrr_build_file_upload_body_build_file_upload_requestrrrrrHrIrJrrKr`rarrr_fetch_last_message_in_threadrgrr$rrfrr)rrr*rrr'rr+rupload_file_typeresolved_message_type duration_msrrvrhrPrr>rR thread_msg_idrws r2r-z)FeishuAdapter._send_uploaded_file_messageBs | De?CCC Cw~~i(( Se3Qi3Q3QRRR R ?BG$4$4Y$?$? 262U2U"#83V3 3 //K =K6))"99)DD i&& d(33.*!( 4 99$??(,(:(:4@RSS S = = = LL> 3Y]L ^ ^ ^e3s88<<< < < < < < < =sJ -L87A$D' L8'D++L8.D+/2L8"GL88 N;N=NNrcK|jr|sdS ddlm}|d|d}tj |jj j j j |d{V}|rft|ddrLtt|ddd d}|r*t|dkrt|dd dSn3#t $r&}t"d ||Yd}~nd}~wwxYwdS) z>Fetch the last message_id in a thread for reply-based routing.Nr)ListMessageRequestrrnrcdSrrIrIrNr2rLz=FeishuAdapter._fetch_last_message_in_thread..rrNrRrrz6[Feishu] Failed to fetch last message in thread %s: %s)rrrrXcontainer_id_type container_idrrlrqrrrrOrrrtrfrgrh)rrrrhrrrws r2rz+FeishuAdapter._fetch_last_message_in_threadsn| 9 4 c > > > > > >"**,,""8,,i((1 %.t|/A/I/NPWXXXXXXXXH AGGHiGGII A&$ ? ?$OOASZZ!^^"58\4@@@ c c c LLQS\^a b b b b b b b b ctsDD ED<<Erzc &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) NrrFrorreply_in_thread uuid_value receive_idrrorrzfeishu_user_id:rrnrr+r)rr_build_reply_message_bodyrrr_build_reply_message_requestrrrrrOreply_build_create_message_body_build_create_message_requestr&r3rH) rrrrzrreffective_reply_torrvrh _thread_idrreceive_id_types r2_send_raw_messagezFeishuAdapter._send_raw_messages9&! Eh E8<< 3L3L E!).C!D!D B33K@@AA  W11! /tz||,, 2D 778JDQQG++DLO,>,F,LgVVVVVVVV V n"))+66  P22%!tz||,, 3D 88dKKGG J'O!!"344 ,$]]32215 "+##E** ,"+22%!tz||,, 3D 88$OOG'' (:(B(I7SSSSSSSSSrNcTt|ot|ddS)NrcdSrrIrIrNr2rLz3FeishuAdapter._response_succeeded..serNr)rs r2rz!FeishuAdapter._response_succeededs,HN!L9mm!L!L!N!NOOOrN field_namect|sdSt|dd}|rt||dndS)NrR)rrr)rrrRs r2rIz%FeishuAdapter._extract_response_fieldsJ00:: 4x..26@wtZ...D@rN)r<r;r<c|rtd||St|dd}t|d|}tdd|d||S)NF)rr raw_responser4rHrrz] )rr)rrr;r<r4rs r2rJz$FeishuAdapter._response_error_resultsk  Ze>PXYYY Yx33h77%/@4/@/@3/@/@xXXXXrNc||s|||Std||d|S)N)r;Tr)rrr)rrJrrI)rrr;s r2rz#FeishuAdapter._finalize_send_resultsb''11 Z..x.YY Y33HlKK!    rNc  KttD]} |jdkr|d{Vn|d{VdS#t $r}d|_|d|_| d{V|tdz krd|z}t d|dzt||tj |d{VYd}~d}~wwxYwdS)Nr FrnrHz:[Feishu] Connect attempt %d/%d failed; retrying in %ds: %s)r_FEISHU_CONNECT_ATTEMPTSr6_connect_websocket_connect_webhookrfrrrrrgr$rqr)rattemptrw wait_secondss r2rz!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_AVAILABLErtr5rr_build_lark_clientrrnrrrr|rr3r4r|LogLevelINFOrr}rr)rr rs r2rz FeishuAdapter._connect_websocket-s&) WUVV V"&"3v"="=;..v66 "7799   &EFF Fz <4>>++<:;; ;((*********(<'m(- %+    ..  * O    rNcKtstd|jdkrtnt}|||_||_|jtd| d{Vtj t}|j |j|jtj||_|jd{Vtj|j|j|j|_|jd{VdS)Nz/aiohttp not installed; webhook mode unavailabler|r)client_max_size)FEISHU_WEBHOOK_AVAILABLErtr5rrrrrnrr|r Applicationrrouteradd_postrIr AppRunnerrsetupTCPSiterGrHrr)rr rs r2rzFeishuAdapter._connect_webhookMsR' RPQQ Q"&"3v"="=;..v66 "7799   &EFF F((*********o.LMMM D.0LMMM"}S11"((********* [)=t?QSWSeff &&(((((((((((rNr c,tj|j|j|tj j  Sr) r|rrXrr3rr4r rrrrl)rr s r2rz FeishuAdapter._build_lark_client`s] K   ! ! VDL ! ! Z( ) ) VF^^ Yt}, - - UWW  rNc \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 ) Nrr4ru[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 %srrnrHzC[Feishu] Send attempt %d/%d failed for chat %s; retrying in %ds: %szFeishu send failed)r_FEISHU_SEND_ATTEMPTSrrr_FEISHU_REPLY_FALLBACK_CODESrrgr$rfrrrrqrrt) rrrrzrr last_erroractive_reply_torrr4rwrs r2rz%FeishuAdapter._feishu_send_with_retryjsk+/ "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: %sTr`)rr#rrfrgr$)rrws r2rzFeishuAdapter._release_app_locks&  F +  68O P P P P Z Z Z NNDcTXN Y Y Y Y Y Y Y Y Z'+D # # #dD # * * * *s+(A% AAA%AA%% A.ct>t|St |S)Nr)rrXrrlr rs r2rfz%FeishuAdapter._build_get_chat_requestsE  %!))++33G<<BBDD Dw////rNct>t|St |S)Nr)rrXrrlr rs r2rz(FeishuAdapter._build_get_message_requestsE  ($,,..99*EEKKMM M*5555rNctdt|||St |||S)N)rrr)rrXrrrrlr rs r2rz-FeishuAdapter._build_message_resource_requestsc $ 0)1133J''(##m$$  *xm\\\\rNrr@ctQt||St ||S)Nrv)rrXrr@rlr rvs r2ryz,FeishuAdapter._build_get_application_requestsP ,%--//d   f48888rNrrc$twt||||St||||S)N)rorrr)rrXrorrrrlr rs r2rz'FeishuAdapter._build_reply_message_bodys~ " .'//11!!(## 11j!!  +     rNrctQt||St ||SNr)rrXrrrlr rs r2rz*FeishuAdapter._build_reply_message_requestsT  *#++--J''l++   *<PPPPrNctQt||St ||S)Nr)rrXrrorlr rs r2rz(FeishuAdapter._build_update_message_bodysT # /(0022(##!!   'BBBBrNctQt||St ||Sr)rrXrrrlr rs r2rz+FeishuAdapter._build_update_message_requestsT  +$,,..J''l++   *<PPPPrNrc$twt||||St||||S)N)rrror)rrXrrrorrlr rs r2rz(FeishuAdapter._build_create_message_bodys~ # /(0022J''(##!!j!!  !     rNrctQt||St ||S)Nrr)rrXrrrlr rs r2rz+FeishuAdapter._build_create_message_request$sT  +$,,.. 11l++   \ZZZZrNr9rctQt||St ||S)Nr8)rrXr9rrlr r8s r2rEz&FeishuAdapter._build_image_upload_body/sR ! -&..00J''u   *EBBBBrNct>t|St |SNr)rrXrrlr rs r2rGz)FeishuAdapter._build_image_upload_request:sE  )%--//<<\JJPPRR RL9999rNr)rrrc8tt|||}|dkr||}|St||||S)Nrr)rrXrrrrrlr )rrrrrXs r2rz%FeishuAdapter._build_file_upload_body@s ,%--//9%%9%%d  !||!**844==?? "id]effffrNct>t|St |Sr)rrXrrlr rs r2rz(FeishuAdapter._build_file_upload_requestNsE  ($,,..;;LIIOOQQ QL9999rNc t|Sr)rcrns r2_build_post_payloadz!FeishuAdapter._build_post_payloadTs+G444rNr>rdctj||}|didg}||gtj|dSr\)r`rr setdefaultrkra)rr'r>rzros r2rKz'FeishuAdapter._build_media_post_payloadWsm*T55g>>??$$Wb11< * * *+C0&8 8 !V + ++V3 3'//rN)rr)rrrkr)r1rrkrh)rkr )rkroro)rrrkr)rrrkrh)NN) rrrorrrrrrkr) rrrrrorrrrkr)rNTTF)rrrrrrrrrrrrrrrrrkr)rrr0rrrjrkr)rrN) rrrrr0rrrrrrkr)rrrrrkr)rrrrrkr)rrrkrh)NNN) rrr&rr'rrrrrrkr)NNNN)rrr*rr'rrrrrrrrkr) rrr2rr'rrrrrrkr) rrr5rr'rrrrrrkrr)rrrkrh) rrrVrr'rrrrrrkr) rrrZrr'rrrrrrkr)rrrkrrorrkr)rRr rkrh)rRr rkr)rRrrkrh)rrrRr rkrh)rRr rkr )rr rkr)rr rr rkr)rrrkr)rzr rrrr rkr ) rr rrrrrrrrrkrh) rr rrrrrrrrrkrh)rrrkr)rrrkr)rzrrkrhrkr)rrrrrkr)rrrrrkr)rrrrrkrh)rrrkr)rzrr(rrkrh)r.rr/rrkrh)r.rrkrh)rrr9r:rkr:)rRr rOr rr rerrrrrrkrh)rzrrkr)rzrrkr)rrr_rrkr)rrrkrh)rVrrkr)rrrr\rr]rrkr;)rrr0rrkr) rrrr~rrrr\rrkr)rr rkr )rhr rkr )r|r rrlrkr)rrrkr)rrrrrr rkrh)rOr rkr)rrrrrkr)rrr0rrkr)rrrErrkr)rrrrrkr)rrrrrkr;) rrrrrrrrrkr;)rr rkrl)rr r/rrkr) rrr~rr0rrrrkr)r~rr0rrkr)rrrkr)r?rrkr)rkrrkr)rrrrrkr)rr rrrkr")rrrkr)rrrrrkr)r:rrkr;)rrrrrrrkr)rKrrkr)rr rkrh)rr rOr rkrT)rrrkr)r)rr rrrrrkr)rOr rkr)rrkrkr)rrrkr)rkr)rrrkr)rorrrrkr;)r*rrkrj)rrr*rrrrrr'rrrr+rrkr)rrrkr) rrrrrzrrrrrrkr )rr rkr)rr rrrkr )rr r;rr<rrkr)rr r;rrkr)r r rkr )rrrkr )rrrkr )rrrrrrrkr )rrr@rrkr ) rorrrrrrrrkr )rrrr rkr )rrrorrkr ) rrrrrorrrrkr )rrrr rkr )r9rrr rkr )rr rkr ) rrrrrr rrjrkr )r'rr>rdrkr)r*rrrrkr;)rrrrsupports_code_blockssplits_long_messagesrrrrr staticmethodrrrnrzrrrrrrrrrr _EA_HEADER_EA_REASON_LABEL_EA_SMART_DENY_LINE_EA_CMD_BUDGETrr rrrr%r.r1r4rSrUrYr_rlrr\rsrurwrZrbrdrfrhrjrkrPr`rrrvrrrrrrrrrrrrrr"r$r'r-r6r8rrrJrPr^rbrQrdrirerXr^rqrrrrrrrrOrrhrrrHrrrrrrrrrrrrr rhrrrr$r/rIrJrrrr[rr\rirjrr|rrrrrr-rrrrIrJrrrrrrrrfrrryrrrrrrrErGrrrrKr __classcell__)rs@r2rrs)""""""" <&<&<&<&<&<&|c c c \c J9999>    @0QQQ **** 5:333333jS-S-S-S-j,,,, ####&&&&"#'-1 A=A=A=A=A=R !=!=!=!=!=!=JJ%bN/-1 $"" G=G=G=G=G=R   \ 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*49DDDDDD&   \ R"&#'%+`=`=`=`=`=`=D,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:::\: ^_ g g g g g\ g:::\: 55557777 000\00000rNrr cNt|tdSNr{)_ONBOARD_ACCOUNTS_URLSrr s r2_accounts_base_urlr}s ! % %f.DX.N O OOrNcNt|tdSr)_ONBOARD_OPEN_URLSrrs r2_onboard_open_base_urlr!s  ! !&*|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. rr}z!application/x-www-form-urlencodedrRr|rN) _REGISTRATION_PATHrrrr_ONBOARD_REQUEST_TIMEOUT_Sr`rrBrrrur)r"rvrrRrFrGrwrs r2_post_registrationr'sy +) + +C T?? ! !' * *D #D>;^*_ ` ` `C  S"< = = = ;:diikk0099:: ; ; ; ; ; ; ; ; ; ; ; ; ; ; ; ; ; ; XXZZ  $ $z*"3"3G"<"<======== 45 $ $ $t# $ sTB,9B B,B##B,&B#'B,, D6D &C93D9DDDr{ct|}t|ddi}|dpg}d|vrtd|dS)zcVerify the environment supports client_secret auth. Raises RuntimeError if not supported. rinitsupported_auth_methods client_secretzWFeishu / Lark registration environment does not support client_secret auth. Supported: Nrr'rrt)r r"resmethodss r2_init_registrationr/ss "&))H X&'9 : :Cgg.//52Gg%% $! $ $   &%rNclt|}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_inrX)r6qr_urlr8r9r;r,)r r"r-r6r<s r2_begin_registrationr=s!&))H X$&& ((  C ''-((K VTUUU WW0" 5 5F f}}****"WW["--GGJ'',1WW[))0S   rNrr6r9r;Optional[dict]ctj|z}|}d}d}tj|krt|} t|d|dd} n6#tt t jf$rtj|YowxYw|dz }|dkrtddd n|d zdkrtd dd | d pi} | d} | dkr|sd}d }| drO| dr:|dkrt| d| d|| ddS| dd} | dvr1|dkrtt d| dStj|tj|k|dkrtt d|dS)zPoll until the user scans the QR code, or timeout/denial. Returns dict with app_id, app_secret, domain, open_id on success. Returns None on failure. Frpollob_app)rr6tprnz# Fetching configuration results...rTendflushrr user_info tenant_brandr| client_idr+r)rrr rr> access_denied expired_tokenz [Feishu onboard] Registration %sNz)[Feishu onboard] Poll timed out after %ds) r monotonicrr'rrr`rrprintrrgr$) r6r9r;r deadlinecurrent_domaindomain_switched poll_countr"r-rFrGrs r2_poll_registrationrQsP~)+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_asciirf)rqrs r2 _render_qrr[su   ! ! C D d###t uusAA!! A/.A/rrcbtrt|||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)rrr s r2 probe_botr_ s6:fj&999 6:v 6 66rNc@|dkrtnt}tj|||tj j  S)z9Build a lark Client for the given credentials and domain.r|) rrr|rrXrrr rrrrl)rrr  sdk_domains r2_build_onboard_clientrb1sk && 0 0mJ   J      4=( ) )  rNrRc8|ddkrdS|dp*|didpi}|dp|d|ddS) Nr4rrrRrwrr)rr)r)rRrs r2rxrx>s xx1t ((5// BTXXfb1155e<< BCGGJ''>377:+>+>wwy))  rNc2 t|||}ttjdtj h }| |}tt|dddd}|dSttj|S#t $r&}t"d|Yd}~dSd}~wwxYw)z#Probe bot info using lark_oapi SDK.rurNroz%[Feishu onboard] SDK probe failed: %s)rbrrXr@rrArBrDrrErlrhrrxr`rrfrgrh)rrr rrFrGrorws r2r]r]Is&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_secondsrprqc 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. roz([Feishu onboard] Registration failed: %sN)_qr_register_innerrtrrr`rrgr$)rprqrws r2 qr_registerrtsh*!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...rTrCz done.r<z8 Scan the QR code above, or open this URL directly: z3 Open this URL in Feishu / Lark on your phone: r-zH Tip: pip install qrcode to display a scannable QR code here next timer6r9r;)r6r9r;r Nrrr rr)rLr/r=r[rQminr_r)rprqr1r<rEbot_infos r2rsrssi  ,"DAAAA~&&&  / /E (OOO GGG 8_F&Z S6SSTTTT PfPPPQQQ XYYY GGG -(z"eK(/:: F t)6,+?AQRRH%%\\*55z ( ] ; ;}!z $} MrN>r5r6r7r8r9>rBrCrErFrGrA>r;r<r=r>r?r@)r media_filesforce_documentclKtjtd{VsddiS|pg} t|}t |dd}|dkrt nt }|||_|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| t0vr||| | d{V} n||| | d{V} | j sdd | j icS<| dd iSdd|| jdS#t6$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. NrzPFeishu dependencies not installed. Run `hermes setup` to install Feishu support.r5r{r|rrzFeishu send failed: zMedia file not found: rnzFeishu media send failed: zANo deliverable text or media remained after processing MEDIA tagsT)rrrr)rqrrrrrrrrr/rrrr-r?r@splitextr_MIGRATION_IMAGE_EXTSrS_MIGRATION_VIDEO_EXTSr4_MIGRATION_VOICE_EXTSr._MIGRATION_AUDIO_EXTSr1rrf)pconfigrrOrrxryrYrr r last_result media_pathis_voicerKes r2_standalone_sendrs5 "?33 3 3 3 3 3 3mkll#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    55533344444445s7BH/H8D HH H H3"H.(H3.H3c8ddlm}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 / Larkr r z$Feishu / Lark is already configured.zReconfigure Feishu / Lark?FNz+How would you like to set up Feishu / Lark?z@V-WYZ[[ %?? E V<     (01}}))+ i ' ' JH I I I Jf g g g Ji j j jN+_===2 0h001113   JQ/999-r222 +,,, ]^^^^ q/888-r222 ABBBB/999 2 F 0-%   '#r    -y999 ())) , B !  IA~~,f555 BCCCC,j999 *+++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)r-r.rrenviron)rrs r2_apply_yaml_configrsJz!!")4G*H*H!*-j.F*G*G*M*M*O*O &' 4rNclt|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)rrr)rrs r2 _is_connectedrs4 FGR ( ( .BE  (## $ $$rNc t|S)zDFactory wrapper that constructs FeishuAdapter from a PlatformConfig.)r)rs r2_build_adapterrs   rNc|ddttttddgdtt dddt d d d d S)u:Plugin entry point — called by the Hermes plugin system.r{rr r z-Run `hermes setup` to install Feishu support.rrWrru🪽T)r/radapter_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_platformrrrrrr)ctxs r2registerrsb &*"%%':;D"/0.2-!#rNr)rhr rirjrkrl)rr rkr)rr rkr)rrrkr)rr rkr)rrrrrkr)r+rrkr)r2rrkr)Nr)rr r0rrRrjrkr)r)rr r0rjrRrjrkrjr)rorrkrd)rzr ryr{rkr)rzr rkr)rr rkr) r2r rrrrryr{rkr) rr rrrrryr{rkr) rrrrrrrrrkr)rrrkr)rzrrkr)rrrzrrkr)rzrrkr)rzr rkr)rr rrrkr)rzrrrrkr)rrrkr)rzr rkr)rzr rr%rkr)rr )rr rkr)rrryr{rkr)rrrkr)r:r rkr;)rrrrrkrB)rrFrkr)rrrrFrkr)rXr rYr rkrhr)r rrkr)r"rrvrdrkr)r{)r rrkrh)r rrkr) r6rr9rjr;rjr rrkr>)rrrkr)rrrrr rrkr>)rrrrr rrkr )rRrrkr>)rprrqrjrkr>ro)rrrrrkr(r __future__rrqrconcurrent.futuresrtrrrr`rrr-r$rrrr dataclassesrrrpathlibrtypesr typingr r r r rr urllib.errorrr urllib.parserurllib.requestrraiohttprrrr|rrrrrrrrrrrrrrrrrrrrrrrrrrrrrgateway.configrrr=rrrrrrrrr r!gateway.statusr"r#hermes_constantsr$utilsr%r&r'agent.secret_scoper(r,r)r+r3 getLoggerrrgcompilerPr_MARKDOWN_TABLE_RErOrsrq _MENTION_REr4 IGNORECASErrrrrr rFrr r rrrrrr&r'r(r)r%r*r+r,rr0rrrrrr2r1rrerrgrx_FEISHU_BOT_MSG_TRACK_SIZErrr&r+rrKrr r%r&rrrrrr!rrr2rNrOr0rrrrrrrrrr RejectReasonrr rrrr*r1r>rDrQrWrZrcr_rrrrr~rrrrrrrrrrrrrrrrrrrArrJrWrrrrrr!r'r/r=rQqrcoderUrTr[r_rbrxr]r^rtrsr|r}rr~rrrrrrrIrNr2rs---^#"""""    ######((((((((!!!!!!????????????????,,,,,,,,""""""++++++++NNNG CCCJJJ         ""IN$$'t3"$.33333333                        DCCCCCCC,,,,,,7777777777JJJJJJ??????////(  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<'<'<'<'~;;;;|    y:0y:0y:0y:0y:0'y:0y:0y:0JvPPPPHHHH.      > DDDDDDN     YKKK    7777"    *F#8&&&&nCBBIIIJJJ);5;5;5;5;5|m'm'm'm'`    %%%%!!! s6 B B B $B))B32B3T TT