ig`UdZddlmZddlZddlZddlZddlZddlZddlZddl Z ddl Z ddl Z ddl Z ddl Z ddlZddlmZmZddlmZddlmZddlmZddlmZmZmZmZdd lmZmZdd lm Z dd l!m"Z"m#Z# ddl$Z$dd l$m%Z%n#e&$rdZ$dZ%YnwxYw ddl'Z'n #e&$rdZ'YnwxYw ddl(Z)dd l*m+Z+ddl,m-Z-m.Z.m/Z/m0Z0m1Z1m2Z2m3Z3m4Z4m5Z5m6Z6m7Z7m8Z8m9Z9m:Z:ddl;mm?Z?m@Z@ddlAmBZBddlCmDZEdZFn#e&$rdZFdZ)dZ?dZ@dZBdZEdZZd?Zd@ZdAdBdCdDdEZdFedG<dHdIdJdKdLZdFedM<dNZedOdPhZdQZdRdSdTZdUdVdTZdWZdXZdYZdZZd[Zd\Zd]Zd^Zd_Ze j^d`Ze j^dZe j^daZdbZhdcZeddGdedfZeddGdgdhZeddGdidjZeddGdkdlZeGdmdnZeGdodpZddtZddxZdd|Zdd}ZddZddZddZddZdddZdddZddZddZddZddZddZddZddZddZddZddZddZddZddZddZddZddZddZddZddZddZddZddZddZddZddZddZGddeMZddZddZddZdddÄZdddĄZddŜddʄZ ddlZn#e&ef$rdZYnwxYwdd̄ZѐddτZҐddЄZӐdd҄ZԐddӄZՐddԄZdd8d՜dd؄ZאddلZdS(a 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) - Persistent ACK emoji reaction on inbound messages - 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) ) annotationsN) dataclassfield)datetime)Path)SimpleNamespace)AnyDictListOptional) HTTPErrorURLError) urlencode)Requesturlopen)web)GetApplicationRequest)CreateFileRequestCreateFileRequestBodyCreateImageRequestCreateImageRequestBodyCreateMessageRequestCreateMessageRequestBodyGetChatRequestGetMessageRequestGetMessageResourceRequestP2ImMessageMessageReadV1ReplyMessageRequestReplyMessageRequestBodyUpdateMessageRequestUpdateMessageRequestBody) FEISHU_DOMAIN LARK_DOMAIN) CallBackCardP2CardActionTriggerResponse)EventDispatcherHandler)ClientTF)PlatformPlatformConfig) BasePlatformAdapter MessageEvent MessageType SendResultSUPPORTED_DOCUMENT_TYPEScache_document_from_bytescache_image_from_urlcache_audio_from_bytescache_image_from_bytes)acquire_scoped_lockrelease_scoped_lock)get_hermes_homez(^#{1,6}\s)|(^\s*[-*]\s)|(^\s*\d+\.\s)|(^\s*---+\s*$)|(```)|(`[^`\n]+`)|(\*\*[^*\n].+?\*\*)|(~~[^~\n].+?~~)|(.+?)|(\*[^*\n]+\*)|(\[[^\]]+\]\([^)]+\))|(^>\s)z\[([^\]]+)\]\(([^)]+)\)z @_user_\d+z [ \t]{2,}z,content format of the post type is incorrect>.bmp.png.webp.gif.jpg.jpeg>.aac.m4a.mp3.wav.flac.ogg.opus.webm>.3gp.mkv.avi.m4v.mov.mp4rCci|]\}}|| SrK).0extmimes @/home/agentuser/.hermes/hermes-agent/gateway/platforms/feishu.py rPsUUUysDsUUUmessagestreamrArB>rFrGrHrIpdfdocxlsppt)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_alwaysrcDict[str, str]_APPROVAL_CHOICE_MAPz Approved oncezApproved for sessionzApproved permanentlyDenied)r`rarbrc_APPROVAL_LABEL_MAPii{i[OKzhttps://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([\\`*_{}\[\]()#+\-!|>~])z\s+) titletextcontentlabelvaluenamesummarysubtitle description placeholderhint>tagurlhreflinktypetokenlocalechat_idopen_iduser_idfile_keymsg_typetemplateunion_id image_key message_type open_chat_id share_chat_id)frozenc6eZdZUded<dZded<dZded<dS)FeishuPostMediaRefstrr file_namefile resource_typeN)__name__ __module__ __qualname____annotations__rrrKrQrOrrs=MMMIMrQrceZdZUded<eeZded<eeZded<eeZded<d S) FeishuPostParseResultr text_contentdefault_factory List[str] image_keysList[FeishuPostMediaRef] media_refs mentioned_idsN) rrrrrlistrrrrKrQrOrr sx!E$777J7777+05+F+F+FJFFFF$uT:::M::::::rQrceZdZUded<ded<dZded<eeZded<eeZd ed <eeZ ded <d Z ded <ee Z ded<dS)FeishuNormalizedMessagerraw_typerrtpreferred_message_typerrrrrrplain relation_kindDict[str, Any]metadataN) rrrrrrrrrrrdictrrKrQrOrrsMMM"(((((!E$777J7777+05+F+F+FJFFFF$uT:::M:::: M    $uT:::H::::::rQrc^eZdZUded<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&<dS)'FeishuAdapterSettingsrapp_id app_secret domain_nameconnection_mode encrypt_keyverification_token group_policyzfrozenset[str]allowed_group_users bot_open_id bot_user_idbot_nameintdedup_cache_sizefloattext_batch_delay_secondstext_batch_split_delay_secondstext_batch_max_messagestext_batch_max_charsmedia_batch_delay_seconds webhook_host webhook_port webhook_pathr^ws_reconnect_noncer]ws_reconnect_intervalN Optional[int]ws_ping_intervalws_ping_timeoutadminsrdefault_group_policyrzDict[str, FeishuGroupRule] group_rules)rrrrrrrr frozensetrrrrrrKrQrOrrsKKKOOO''''MMM####))))    $$$$     !$$$$$&*****%)O))))&Y[[F(((( """"".3eD.I.I.IKIIIIIIrQrcbeZdZUdZded<eeZded<eeZded<dS) FeishuGroupRulezLPer-group policy rule for controlling which users may interact with the bot.rpolicyrset[str] allowlist blacklistN) rrr__doc__rrsetrrrKrQrOrr<s]VVKKK%444I4444%444I444444rQrcveZdZUeeZded<eeZded<eeZded<dS) FeishuBatchStaterzDict[str, MessageEvent]eventsDict[str, asyncio.Task]taskszDict[str, int]countsN) rrrrrrrrrrKrQrOrrEsl&+eD&A&A&AFAAAA%*U4%@%@%@E@@@@"U4888F888888rQrrtrreturnc8td|S)Nz\\\1)_MARKDOWN_SPECIAL_CHARS_REsub)rts rO_escape_markdown_textrQs % ) )'4 8 88rQrwr boolc"|dup |dkp|dkS)NTtruerKrws rO _to_booleanrUs D= 9EQJ 9%6/9rQstyleDict[str, Any] | NonekeycN|sdSt||SNF)rget)rrs rO_is_style_enabledrYs' u uyy~~ & &&rQctdgdtjd|D}d|dzz}|ds|drd|dn|}|||S)Nrc,g|]}t|SrK)len)rLruns rO z%_wrap_inline_code..`sDDDSCDDDrQz`+`r )maxrefindall startswithendswith)rtmax_runfencebodys rO_wrap_inline_coder_s1EDDBJud,C,CDDDEFFG 7Q; E//#.. N$--2D2D N;t;;;;$D "T "5 " ""rQlanguagecz|ddddS)N r )stripreplace)rs rO_sanitize_fence_languagerfs2 >>   # #D# . . 6 6tS A AArQelementrct|ddpd}|d}t|tr|nd}t |drt |St |}|sdSt |drd|d}t |drd|d}t |d rd |d }t |d rd |d }|S)Nrtrrcodeboldz**italic* underlinezz strikethroughz~~)rr isinstancerrrr)rrtr style_dictrendereds rO_render_text_elementrjs w{{62&&," - -D KK E$UD11;tJV,,' &&&$T**H rV,,%$$$$X..#"x???[11(''''_55%$$$$ OrQctt|ddpdp$t|ddpd}t|ddpdp$t|ddpddd}|drdnd}d|d||dS) Nrrlangrtru rz```)rrrrr)rrr trailing_newlines rO_render_code_block_elementrs' GKK B ' ' -2..T#gkk&"6M6M6SQS2T2TH GKK # # )r**Sc'++i2L2L2RPR.S.S gfd "]]400:rrd 8 8 8T 8#3 8 8 88rQclddlm}|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_markdownrrc|dd|ddS)Nrz ())groupr)ms rOz/_strip_markdown_to_plain_text..s7qwwqzz,R,RQWWQZZ=M=M=O=O,R,R,RrQz^>\s?r)flagsz ^\s*---+\s*$z---z ~~([^~\n]+)~~z\1z([\s\S]*?))gateway.platforms.helpersrr_MARKDOWN_LINK_RErr MULTILINE)rtrrs rO_strip_markdown_to_plain_textr%s988888 LL & &E  ! !"R"RTY Z ZE F8Rbl ; ; ;E F?E5 E E EE F#UE 2 2E F' 6 6E N5 ! !E LrQdefaultr min_valuercj t|}n#ttf$r|cYSwxYw||kr|n|S)zACoerce value to int with optional default and minimum constraint.)r TypeError ValueErrorrwr&r'parseds rO _coerce_intr-sQU z "y((66g5s ((c2t|||}||n|S)Nr&r')r-r+s rO_coerce_required_intr0s$ 9 E E EFn77&0rQruc@tjddd|dggiidS)Nrqrumd)r~rtF ensure_ascii)jsondumps)rus rO_build_markdown_post_payloadr7sL : $($+     rQpayloadct|}|sttSgggg}tt |dd}|r|||dgpgD]_}t|tstd fd|D}|r||`td |ptS)N)rrsrruc3<K|]}t|VdSN)_render_post_element)rLitemrrrs rO z,parse_feishu_post_payload..s3ffZ^(z:}UUffffffrQr)rrrr) _resolve_post_payloadrFALLBACK_POST_TEXT_normalize_feishu_textrrrappendrrjoin) r8resolvedpartsrsrowrow_textrrrs @@@rOparse_feishu_post_payloadrHsY$W--H F$2DEEEEJ+-J!ME "3x||GR'@'@#A#A#G#G#I#I J JE  U||Ir**0b###t$$  ) GGffffffbefff f f    # LL " " " YYu%%++--C1C#    rQct|}|r|St|tsiS|d}t |}|r|St |S)Npost)_to_post_payloadrrr_resolve_locale_payload)r8directwrappedwrapped_directs rOr?r?sm g & &F  gt $ $ kk&!!G,W55N "7 + ++rQct|}|r|St|tsiStD]*}t||}|r|cS+|D]}t|}|r|cSiSr;)rKrr_PREFERRED_LOCALESrvalues)r8rMr candidaterws rOrLrLs g & &F  gt $ $ !$W[[%5%566      !!$U++       IrQrSct|tsiS|d}t|tsiSt |ddpd|dS)Nrursr)rsru)rrrrr)rSrus rOrKrKsq i & & mmI&&G gt $ $ Y]]7B//5266  rQrrrrrcJ t|tr|St|tsdSt|dd}|dkrt |S|dkrt|dd}t|d|pd}|sdSt|}|r d|d|dn|S|d krimgimageraltz[Image: ]ro>raudiomediavideorrrs>r_rarrrr [Attachment: rp>emojiemotion emoji_type:z[Emoji]brr>hrdividerz --- r ru>pre code_block)rtrsruchildrenelementsrc3K|]}||V dSr;rK)rLparts rOr>z'_render_post_element..Ys'::TT:D::::::rQ)rrrrrlowerrrrBrrr_render_nested_postrC)rrrrr~rrv escaped_label mentioned_id display_namerr]rrr  nested_partsrrw extracteds rOr<r< s '3 gt $ $r gkk%$$ % % + + - - 3 3 5 5C f}}#G,,, czz7;;vr**++1133GKK--344::<< 2-e44 /3F+=++D++++F d{{  Ir** + + 1 1 3 3 77;;y"--..4466   /L ==   . . .  K,, - - 3 3 5 5 7;;vr**++1133 7;;vr**++1133   =IQ8(66888cQ  K4455;;==  )*44   i ( ( ('++fb))**0022Yc'++eR:P:P6Q6Q6W6W6Y6Y$'6 #    Y6 111w{{:r223399;;  K,, - - 3 3 5 5 47;;w++,,2244 47;;vr**++1133      "%'),0B)B)B##   09L+y++++nL """GKK++,,2244bGKK VXz&_render_nested_post..eP  ,T:z=YY        rQc3DK|]}t|}||VdSr;rzr{s rOr>z&_render_nested_post..or|rQr)rrrrrCrr<rR)rwrrrrMs ``` rOrrrr\s %,$U+++% xx            %  %eZ]SS  Mxx             2rQr raw_contentc t|pd}t|}|dkrAt |t t|ddpdS|dkr_t|}t ||jt|j t|j t|j dS|dkrt|ddpd}t t|ddpdp+t|ddpdpt}t ||tkr|ndd |r|gngd S|d vrNt|| }t|j}t |d|d krd nd|jr|gng|d|iS|dkrt%|S|dkrt'|S|dvrt)||St |dS)Nrrt)rrrJ)rrrrrrr\rr]photo)rrrrr>rr_r`)rr_documentplaceholder_text)rrrrrr merge_forward share_chat>card interactive)rrrq_load_feishu_payloadrrArrHrrrrrFALLBACK_IMAGE_TEXT_build_media_ref_from_payload_attachment_placeholderrr _normalize_merge_forward_message_normalize_share_chat_message_normalize_interactive_message) rr~normalized_typer8 parsed_postralt_text media_refr|s rOnormalize_feishu_messager}s,,"--3355;;==O";//G&  &$/GKK4K4K4Qr0R0RSS    &  /88 &$$1K233K233{899     '!! 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 MMrQc |rtj|ni}n#tj$rd|icYSwxYwt|tr|nd|iS)Nrtru)r5loadsJSONDecodeErrorrr)r~r,s rOrrso%,7?K(((R  %%% $$$$%-- F66Iv3FFs 11c t|d|d|dt|d}t|}g}|r||||ddd|pt}td|dt||d  S) Nrsrypreview)rsryrr{keysrYrr) entry_countrsrrrr) _first_non_empty_textr_find_first_text_collect_forward_entriesrBextendrCrFALLBACK_FORWARD_TEXTrr)r8rsentrieslinesrs rOrrs ! G I I'UVVV   E 'w//GE  U LL!99U##))++D/DL " !%!$W>>    rQc Bt|d|d|dt|d}t|d|d|d}g}|r|d |n|t|r|d |d |}t d |d ||d S)N chat_namerxrs)rrxrsrrrrz Shared chat: z Chat ID: rr)rrr)rrrrBFALLBACK_SHARE_CHAT_TEXTrCr)r8rshare_idrrs rOrrs,% K   F G'EFFF I % I N## O$$H E/ 0Y001111 -...- +++,,,99U##L "!"%I>>    rQct|dtr|dn|}tt ||dt |d}t |}t|}g}|r|||D]}||kr|||r+|dd |d |dd pt}t||d ||d  S) Nrrs)rsryrzrz Actions: z, r r)rsactionsr) rrrr_find_header_titler_collect_card_lines_collect_action_labelsrBrCrFALLBACK_INTERACTIVE_TEXTr) rr8 card_payloadrs body_linesrrliners rOrrsY*4W[[5H5H$*O*O\7;;v&&&U\L !<(( G,LMMM  E %\22J$\22GE  U 5== LL   7 57!3!35566699U3B3Z((..00M4ML "!# W55    rQc 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_listrecordsrurz- sender_namerYsenderrxrrrJrurtryr)rtruryrrsrz: )rrrrrrArrBrrrqrHrr _unique_lines) r8 candidatesrrwrr=rtr nested_typers rOrr s>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;;; ' ' '  ! !!rQcnt|d}d|D}td|DS)NF in_rich_blockc,g|]}t|SrK)rArLrs rOrz'_collect_card_lines..5s!AAA4(..AAArQcg|]}||SrKrKrs rOrz'_collect_card_lines..6s>>>4>$>>>rQ)_collect_text_segmentsr)r8r normalizeds rOrr3sD "7% @ @ @EAA5AAAJ >>:>>> ? ??rQc g}t|D]}t|tst|ddp|dd}|dvrzt|d|d|dt|d }|r| |t|S) Nr~rr>buttonpickeroverflow date_picker select_staticrtrxrw)rtrurxrwr) _walk_nodesrrrrrrqrrrBr)r8labelsr=r~rvs rOrr9sFG$$ ! !$%%  $((5"%%=&")=)=>>DDFFLLNN V V V % HHV   HHV   HHW   T(L M M M     ! MM%   rQrct|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)Nrr~rr> divnoteactionrcolumnlark_mdmarkdown column_set plain_textrr)rrrArrrrrrrq_SUPPORTED_CARD_TEXT_KEYSrBr_SKIP_TEXT_KEYS)rwrsegmentsr=r~next_in_rich_blockrrs rOrrLs%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 OrQrc8t|ddpd}t|d|d|d}|dvr|nd}t |||S) Nrrrrsrt>r_rarrb)rrrrr)r8rrreffective_types rOrrus7;;z2..4"55;;==H% K   G FI '47I&I&I]]vN x9Tb c c ccrQrc>t|}|rd|dntS)Nrcr^)rAFALLBACK_ATTACHMENT_TEXT)rnormalized_names rOrrs,,Y77O1@ ^ -? - - - -F^^rQct|tsdS|d}t|tsdS|d}t|trJt|d|d|dSt t |pdS)Nrheaderrsrurtrx)rrrrrAr)r8rrss rOrrs gt $ $r [[ " "F fd # #r JJw  E%a$UYYy%9%9599V;L;LeiiX^N_N_``` !#ekr"2"2 3 33rQrtuple[str, ...]ct|D]^}t|ts|D]C}||}t|trt |}|r|ccSD_dSNr)rrrrrrA)r8rnoderrwrs rOrrsG$$&&$%%   & &CHHSMME%%% &3E:: &%%%%%%  & 2rQc#Kt|tr2|V|D]}t|Ed{VdSt|tr|D]}t|Ed{VdSdSr;)rrrRrr)rwr=s rOrrs%) LLNN ) )D"4(( ( ( ( ( ( ( ( ( ) ) E4 ) ) )D"4(( ( ( ( ( ( ( ( ()) ) )rQrRc|D]m}t|trt|}|r|cS-|>t|ttfs"tt|}|r|cSndSr)rrrArr)rRrwrs rOrrs"" eS ! ! "/66J "!!!! "  z%$'F'F /E ;;J "!!!! 2rQctd|pd}|dddd}dd|dD}dd|dD}t d|}|S)Nrrrrrc3pK|]1}td|V2dS)rN)_WHITESPACE_RErrrs rOr>z)_normalize_feishu_text..s>^^$**355;;==^^^^^^rQc3K|]}||V dSr;rKrs rOr>z)_normalize_feishu_text..s'EEEEEEEEErQ)_MENTION_PLACEHOLDER_RErrrCsplit_MULTISPACE_REr)rtcleaneds rOrArAs%))#tzr::Goofd++33D$??Gii^^'--X\J]J]^^^^^GiiEEt)<)<EEEEEG  g..G ==??rQrct}g}|D]3}|r||vr ||||4|Sr;)raddrB)rseenuniquers rOrrs[UUDF tt||   d MrQ ws_clientadapterNonec  ddlmcm}tj}tj|||_|_|jj tdd dfd d fd }d fd }||j_ td| n#t$rYnwxYw |j_ td d tj|D}|D]}||r$|tj|ddi |n#t$rYnwxYw |n#t$rYnwxYwd_dS# |j_ td d tj|D}|D]}||r$|tj|ddi |n#t$rYnwxYw |n#t$rYnwxYwd_wxYw)zCRun the official Lark WS client in its own thread-local event loop.rN _configurerrc tdjtdjjtdjdSdS#t$r t ddYdSwxYw)N_reconnect_nonce_reconnect_interval_ping_intervalz4[Feishu] Failed to apply websocket runtime overridesTexc_info)setattr_ws_reconnect_nonce_ws_reconnect_interval_ws_ping_interval Exceptionloggerdebug)rrsrO_apply_runtime_ws_overrideszC_run_official_feishu_ws_client.._apply_runtime_ws_overridess ` I173N O O O I4g6T U U U(4 #3W5NOOOOO54 ` ` ` LLOZ^L _ _ _ _ _ _ `sA A&A:9A:argsr kwargscxKjd|vr j|d<jd|vr j|d<|i|d{VS)N ping_interval ping_timeout)r_ws_ping_timeout)rrroriginal_connects rO_connect_with_overridesz?_run_official_feishu_ws_client.._connect_with_overridesso  $ 0_F5R5R&-&?F? #  # /N&4P4P%,%=F> "%%t6v666666666rQconfcTtd|}|S)NzFFeishu _configure_with_overrides called but original_configure is None) RuntimeError)r resultroriginal_configures rO_configure_with_overrideszA_run_official_feishu_ws_client.._configure_with_overridess<  %ghh h##D))##%%% rQc:g|]}||SrKdonerLts rOrz2_run_official_feishu_ws_client..s%FFFQVVXXF1FFFrQreturn_exceptionsTrr)rr rr rr )r r rr )lark_oapi.ws.clientwsclientasyncionew_event_loopset_event_looploop_ws_thread_loop websocketsconnectgetattrrstartr all_taskscancelrun_until_completegatherstopclose) rrws_client_modulerr rpendingtaskrrr s `` @@@rO_run_official_feishu_ws_clientr.s`222222222  ! # #D 4    "G'2: L$??```````7777777+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'ctS)z0Check if Feishu/Lark dependencies are available.)FEISHU_AVAILABLErKrQrOcheck_feishu_requirementsr1 s rQceZdZdZdZdZdfd Zedd ZddZ ddZ ddZ ddZ d dZ ddZddZddZ d d d#Zd d%Z d dd*Zedd-Z ddd0Z ddd3Z ddd5Z ddd7Zddd8Z ddfd: Z ddfd< Zdd=Zdd>Zdd@ZddAZddBZ ddCZ!ddEZ"ddFZ#ddGZ$ddHZ%ddIZ&ddKZ'd dLZ(ed!dNZ)d"dPZ*d#dSZ+d$dUZ,ddVZ-d%dXZ.ddYZ/d&d[Z0d'd]Z1d(d^Z2d)daZ3d*dbZ4d+dfZ5d'dgZ6d,dhZ7d-diZ8ed.dlZ9d'dmZ:d/doZ;d/dpZ<d/dqZ=d0drZ>d1dwZ?ed2dzZ@ed3d}ZAed4dZBd5dZCd6dZDd7dZEd-dZFed.dZGd'dZHd/dZIed8dZJd/dZKd/dZLd9dZMd:dZNed;dZOddZRd?dZSed@dZTedAdZUedBdZVedCdZWedDdZXedEdZYedDdZZedFdZ[edGdZ\dHdZ]dIdZ^dIdZ_d(dZ`dJdZaedKdZbedLd„ZcdMdNdĄZddMdOdńZedPdȄZfdQdʄZgdd˄Zhdd̄Zidd̈́ZjdRd΄ZkdSdτZlddddќdTdӄZmdUdՄZnedVdքZoedWd؄ZpddٜdXd܄ZqdYd݄ZrddބZsdd߄ZtddZudZdZvdUdZwddZxed[dZyed\dZzed]dZ{ed^dZ|ed_dZ}ed`dZ~edadZed`dZedbdZedcdZedddZededZedfdZededZddZdgdZedhdZxZS(i FeishuAdapterzFeishu/Lark bot adapter.i@rZconfigr)ct|tj||jpi|_||jd|_d|_ d|_ d|_ d|_ d|_ d|_d|_i|_g|_t%dz |_t)j|_i|_i|_i|_i|_g|_t)j|_d|_d|_i|_i|_ g|_!i|_"i|_#d|_$tK|_&|j&j'|_(|j&j)|_*|j&j+|_,tK|_-|j-j'|_.|j-j)|_/i|_0tcj2d|_3|4dS)Nzfeishu_seen_message_ids.jsonFir)5super__init__r(FEISHU_load_settingsextra _settings_apply_settings_client _ws_client _ws_futurer _loop_webhook_runner _webhook_site_event_handler_seen_message_ids_seen_message_orderr5_dedup_state_path threadingLock _dedup_lock_sender_name_cache_webhook_rate_counts_webhook_anomaly_counts_card_action_tokens_pending_inbound_events_pending_inbound_lock_pending_drain_scheduled_pending_inbound_max_depth _chat_locks_sent_message_ids_to_chat_sent_message_id_order_chat_info_cache_message_text_cache_app_lock_identityr_text_batch_stater_pending_text_batchesr_pending_text_batch_tasksr_pending_text_batch_counts_media_batch_state_pending_media_batches_pending_media_batch_tasks_approval_state itertoolscount_approval_counter_load_seen_message_ids)selfr4 __class__s rOr7zFeishuAdapter.__init__s 111,,V\-?R@@ T^,,,&* )-48DH:> .2,0-135.0 !0!2!25S!S$>++@BBD!JL$57 35$%.^%5%5"(-%*.'469;&13#;==? 15!1!3!3%)%;%B")-)?)E&*.*@*G'"2"4"4&*&=&D#*.*A*G':<!*!3!3 ##%%%%%rQr:rrrc|di}i}t|tr|D]\}}t|tst t |ddtd|dgDtd|dgD|t |<|d g}td |D}t |d d }tdEid t |d ptj dd dt |dptj dd dt |dptj dddt |dptj dddtj dd dtj dd dtj dddtdtj d d  d!Dd"tj d#d d$tj d%d d&tj d'd d(td)ttj d*t t d+t#tj d,t t$d-t#tj d.d/d0td1ttj d2t t&d3td1ttj d4t t(d5t#tj d6t t*d7t |d7ptj d8t,d9t|d9p&tj d:t t.d;t |d;ptj dd?@dAt3|dAdBd1@dCt5|dCdd1@dDt5|dDdd1@d |d |d|S)FNrropenc3K|]F}t|#t|VGdSr;rrrLus rOr>z/FeishuAdapter._load_settings..XK!j!jQ[^_`[a[a[g[g[i[i!j#a&&,,..!j!j!j!j!j!jrQrc3K|]F}t|#t|VGdSr;rirjs rOr>z/FeishuAdapter._load_settings..YrlrQr)rrrrc3K|]F}t|#t|VGdSr;rirjs rOr>z/FeishuAdapter._load_settings..^sCPPaQP3q66<<>>PPPPPPrQrrr FEISHU_APP_IDrFEISHU_APP_SECRETrdomainr"rlrFEISHU_CONNECTION_MODE websocketrFEISHU_ENCRYPT_KEYrFEISHU_VERIFICATION_TOKENrFEISHU_GROUP_POLICYrc3fK|],}||V-dSr;rrLr=s rOr>z/FeishuAdapter._load_settings..msL**::<<* ******rQFEISHU_ALLOWED_USERS,rFEISHU_BOT_OPEN_IDrFEISHU_BOT_USER_IDrFEISHU_BOT_NAMEr HERMES_FEISHU_DEDUP_CACHE_SIZEr&HERMES_FEISHU_TEXT_BATCH_DELAY_SECONDSr,HERMES_FEISHU_TEXT_BATCH_SPLIT_DELAY_SECONDSz2.0rr%HERMES_FEISHU_TEXT_BATCH_MAX_MESSAGESr"HERMES_FEISHU_TEXT_BATCH_MAX_CHARSr'HERMES_FEISHU_MEDIA_BATCH_DELAY_SECONDSrFEISHU_WEBHOOK_HOSTrFEISHU_WEBHOOK_PORTrFEISHU_WEBHOOK_PATHrr^rr/rr]rrrK)rrrrrrrrqrrrosgetenvrrr_DEFAULT_DEDUP_CACHE_SIZEr!_DEFAULT_TEXT_BATCH_DELAY_SECONDS _DEFAULT_TEXT_BATCH_MAX_MESSAGES_DEFAULT_TEXT_BATCH_MAX_CHARS"_DEFAULT_MEDIA_BATCH_DELAY_SECONDS_DEFAULT_WEBHOOK_HOST_DEFAULT_WEBHOOK_PORT_DEFAULT_WEBHOOK_PATHr0r-)r:raw_group_rulesrrrule_cfg raw_adminsrrs rOr9zFeishuAdapter._load_settingsMs ))M26624 ot , , %4%:%:%<%<  !!(D11,;x||Hf==>>DDFFLLNN!!j!j(,,{TV:W:W!j!j!jjj!!j!j(,,{TV:W:W!j!j!jjj--- CLL))YYx,, PP:PPPPP #599-CR#H#HIIOOQQWWYY$8 8 8 uyy**Lbi.L.LMMSSUUU8 599\22Xbi@SUW6X6XYY__aaa8 EIIh//W29_h3W3WXX^^``ffhhh8   +,,` :RT_0`0`eggeeggg 8  "6;;AACCC8  "y)DbIIOOQQQ8 #8+FFLLNNTTVVV8 !***I&D]@^@^__``%8 ,&+ BCHiDjDjkk&&&-8 2,1 H%PP,,,38 8%(BIEsKkGlGlmmnn%%%98 @"%BIBCHeDfDfgghh"""A8 H', CSIkElElmm'''I8 N .))dRY7LNc-d-degggS8 T .))iRY7LcRgNhNh-i-iU8 \EIIn--h;PRg1h1hiiooqq)(_8 b 4EII>R4S4S]_klmmmmc8 d#7uyyAX7Y7Ycfrs"t"t"t"te8 f)3E)F)FPT`abbbbg8 h( 2C(D(Dd^_````i8 j6k8 l"6!5m8 n$ o8 8 rQsettingsrc|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|_6dSr;)7r_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_pathrrrrrrrr )rdrs rOr<zFeishuAdapter._apply_settingssD #.$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#!)!: ( 8rQr c tdStjjjjjfd fd j  j jjjS)Nc0d|S)Nim.message.reaction.created_v1_on_reaction_eventdatards rOr z4FeishuAdapter._build_event_handler..T445UW[\\rQc0d|S)Nim.message.reaction.deleted_v1rrs rOr z4FeishuAdapter._build_event_handler..rrQ)r&builderrr®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_recalledbuildrds`rO_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 UWW% rQrcKtstddS|jr|jstddS|jdvr"td|jdS |j|_tt|jd|j j i\}}|sqt|tr| dnd }d |rd |d nd zdz}td||d|ddStj|_|d {V|td|j|jdS#t,$r_}|d {Vd|}|d|dtd|dYd }~dSd }~wwxYw)zConnect to Feishu/Lark.z [Feishu] lark-oapi not installedFz3[Feishu] FEISHU_APP_ID or FEISHU_APP_SECRET not set>webhookrszT[Feishu] Unsupported FEISHU_CONNECTION_MODE=%s. Supported modes: websocket, webhook.platform)rpidNz@Another local Hermes gateway is already using this Feishu app_idz (PID z)..zI Stop the other gateway before starting a second Feishu websocket client.z [Feishu] %sfeishu_app_lock) retryablez"[Feishu] Connected in %s mode (%s)TzFeishu startup failed: feishu_connect_errorz[Feishu] Failed to connect: %sr)r0rerrorrrrrWr3_FEISHU_APP_LOCK_SCOPErrwrrr_set_fatal_errorrget_running_loopr@_connect_with_retry_mark_connectedinforr_release_app_lock)rdacquiredexisting owner_pidrRexcs rOr"zFeishuAdapter.connectsW  LL; < < <5| 4#3  LLN O O O5  (@ @ @ LLf%   5 &*lD #!4&'$dm&9:""" Hh  3=h3M3MWHLL///SW V1:C- ----Eab  ]G444%%&7E%RRRu 133DJ**,, , , , , , , ,  " " " KKSUYUf g g g4   ((** * * * * * * *555G  ! !"8'T ! R R R LL93L N N N55555  s!.cancel_all_tasks.. s%VVVqQVVXXVVVVrQz3[Feishu] Found %d pending tasks in websocket threadg?)rr%rrrr& call_laterr))rr-ws_thread_loops rOcancel_all_tasksz2FeishuAdapter.disconnect..cancel_all_tasks s}VVG$5n$E$EVVV RTWX]T^T^___!""DKKMMMM))#~/BCCCCCrQz;[Feishu] Waiting for websocket thread to exit (timeout=10s)g$@timeoutz([Feishu] Websocket thread exited cleanlyz@[Feishu] Websocket thread did not exit within 10s - may be stuckz5[Feishu] Websocket thread cancelled during disconnectz/[Feishu] Websocket thread exited with error: %sTrz[Feishu] Disconnectedr)_running_cancel_pending_tasksrZr^_reset_batch_buffers!_disable_websocket_auto_reconnect_stop_webhook_serverr  is_closedrrcall_soon_threadsafer?rwait_forshield TimeoutErrorwarningCancelledErrorrr@rC_persist_seen_message_idsr_mark_disconnectedr)rdr ws_futurerrs @rO disconnectzFeishuAdapter.disconnects (()GHHHHHHHHH(()HIIIIIIIII !!### ..000'')))))))))-  %n.F.F.H.H % LLW X X X D D D D D D  / /0@ A A AO   d Z[[[&w~i'@'@$OOOOOOOOOO GHHHH' c c cabbbbb) V V V TUUUUU d d d NPS^b cccccccc d# " &&((($$&&&&&&&&& !!! +,,,,,s%)A"E )G7(G! G*G  GrrcKd|D}|D]}||rtj|ddid{V|dS)Nc>g|]}|||SrKr)rLr-s rOrz7FeishuAdapter._cancel_pending_tasks..-s*OOODdO499;;O4OOOrQrT)rRr&rr(clear)rdrr,r-s rOrz#FeishuAdapter._cancel_pending_tasks,sOOELLNNOOO  D KKMMMM  C.'BTBB B B B B B B B rQc|j|j|jdSr;)rYrr[r]rs rOrz"FeishuAdapter._reset_batch_buffers4sG "((*** '--/// #))+++++rQc|jdS t|jddn#t$rYnwxYwd|_dS#d|_wxYw)N_auto_reconnectF)r>rrrs rOrz/FeishuAdapter._disable_websocket_auto_reconnect9sl ? " F # DO%6 > > > >    D #DOOOdDO " " " "s"; /;/; AcK|jdS |jd{Vd|_d|_dS#d|_d|_wxYwr;)rAcleanuprBrs rOrz"FeishuAdapter._stop_webhook_serverCsu   ' F &&..00 0 0 0 0 0 0 0#'D !%D   $(D !%D  % % % %s <A Nrrrureply_to Optional[str]rOptional[Dict[str, Any]]r-c K|jstddS||}|||j}d} |D]}||\} } ||| | ||d{V} n#t$r} | dks't t| st d||dtjdt|id ||d{V} Yd} ~ nd} ~ wwxYw| dkr|| st tt#| d d pd r]t d ||dtjdt|id ||d{V} | }||d S#t$rE} td| dtdt| cYd} ~ Sd} ~ wwxYw)zSend a Feishu message.F Not connectedsuccessrNrrr8rrrJzI[Feishu] Invalid post payload rejected by API; falling back to plain textrtr3msgrzJ[Feishu] Post payload rejected by API response; falling back to plain textz send failedz[Feishu] Send error: %sTr)r=r-format_messagetruncate_messageMAX_MESSAGE_LENGTH_build_outbound_payload_feishu_send_with_retryr_POST_CONTENT_INVALID_REsearchrrrr5r6r%_response_succeededr#_finalize_send_resultr) rdrrurr formattedchunks last_responsechunkrr8responsers rOsendzFeishuAdapter.sendPs| De?CCC C''00 &&y$2IJJ ( =" )" )$($@$@$G$G!'%)%A%A '!) '!)!) &B&&      HH!   6))1I1P1PQTUXQYQY1Z1Z)NN#nooo%)%A%A '!' $ F4QRW4X4X+Yhm n n n!)!) &B&&      HHHHHH && 44X>>'077GHeUW Xh&&8&8=U=\=\]c]i]omo=p=p&8qrrr $ ? ?# J0Mg0V0V'Wfklll!@!! $(#E#EQ[jw#E#x#x *1*;DLO._btns.#$0UCC$/:;WW rQwide_screen_modeTu ⚠️ Command Approval Requiredrrur~orangersrrz``` z ``` **Reason:** r0ru✅ Allow Oncerdprimaryu ✅ Sessionreu ✅ Alwaysrfu❌ Denyrcdanger)r~rr4rrnr3rrzsend_exec_approval failedr)r+rrz&[Feishu] send_exec_approval failed: %sr&)rvrr-rr.rrr)r=r-nextrbrr5r6rrrrr_rrrr)rdrr*r+r{r cmd_previewr3rr8rrrr2s @rOsend_exec_approvalz FeishuAdapter.send_exec_approvals:| De?CCC C6 =t566K47LL44G4G'%4%.500WK       .t4)KT`aa ( *#X;#X#X;#X#X ( D!1>9MM D0ABB D/?@@ DVX>> $  D.jE:::G!99&! :H//:UVVF~ #."("3"9r&55$[1 M = = = NNCS I I Ie3s88<<< < < < < < < =sC0D E8EEEchoicerYc|dkrdnd}t|d}ddi|d|dd |dkrd nd d d |d|d|dgdS)z3Build raw card JSON for a resolved approval action.rcu❌u✅Resolvedr4Trrr5redgreenr7rz **z** by r0r:)rjr)r?rYiconrvs rO_build_resolved_approval_cardz+FeishuAdapter._build_resolved_approval_cards&((uue#'' ;;)40(,%6%6u%6%6|LL%+v%5%5EE7 &"&CC5CC CC   rQ audio_pathcaptioncHK||||||dd{VS)z@Send audio to Feishu as a file attachment plus optional caption.r_r file_pathrrrGoutbound_message_typeN_send_uploaded_file_message)rdrrFrGrrrs rO send_voicezFeishuAdapter.send_voiceU55 ") 6         rQrJrcHK|||||||d{VS)z*Send a document/file attachment to Feishu.)rrJrrrGrNrL)rdrrJrGrrrrs rO send_documentzFeishuAdapter.send_documentsU55 6         rQ video_pathcHK||||||dd{VS)zSend a video file to Feishu.r`rINrL)rdrrRrGrrrs rO send_videozFeishuAdapter.send_video)rOrQ image_pathcrK|jstddStj|stdd|S ddl}t |d5}|} dddn #1swxYwY|| } tj || _ | t| } | | } tj|jjjjj| d{V} || d }|s|| d d S|r;||d |d}||d|||d{V}n6||dt1jd |id||d{V}||dS#t6$rF}t8d||dtdt=|cYd}~Sd}~wwxYw)z"Send a local image file to Feishu.FrrzImage file not found: rNrb image_typer\rzimage upload failedz%Feishu image upload missing image_keydefault_messageoverride_errorr[)r~rrG media_tagrJrr\r3zimage send failedz$[Feishu] Failed to send image %s: %sTr)r=r-rpathexistsiorgreadBytesIObasenamerx_build_image_upload_body_FEISHU_IMAGE_UPLOAD_TYPE_build_image_upload_requestrr r!r"r\create_extract_response_field_response_error_result_build_media_post_payloadrr5r6rrrrr)rdrrUrGrrr_iof image_bytes image_filerr$upload_responser post_payloadmessage_responsers rOsend_image_filezFeishuAdapter.send_image_file<s | De?CCC Cw~~j)) Ze3XJ3X3XYYY Y, =    j$'' '1ffhh  ' ' ' ' ' ' ' ' ' ' ' ' ' ' '[11J g..z::JO004 1D66t<   *.)E)E##(%% *F**$$$$$$  *.)E)E#$ J Y'?eTTT%% *F**$$$$$$ --.>@STT T = = = LL?S[_L ` ` `e3s88<<< < < < < < < =sJG&#B8 G&BG& B CG&BG&& H60;H1+H61H6c KdS)z2Feishu bot API does not expose a typing indicator.NrK)rdrrs rO send_typingzFeishuAdapter.send_typingys trQ 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)rrvrGrr)rrUrGrr)_download_remote_imagerrrr6 send_imagers) rdrrvrGrrrUrres rOryzFeishuAdapter.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.r9z animation.gif) default_extpreferred_nameNz,[Feishu] Failed to download animation %s: %sTr)rrzrGrrz[GIF downgraded to file] z[GIF downgraded to file])rrJrrGrr)_download_remote_documentrrrr6send_animationrQ) rdrrzrGrrrJrrdegraded_captionres rOrzFeishuAdapter.send_animationse )-)G)G".*H**$$$$$$ Iyy     LLGX[fjL k k k//+!! 0       FMlAAAARl''$ (         s!' BA B:BBczK||dd}|js|S|j|}|t|S ||}t j|jjjj j|d{V}|rt|dddurAt|dd}t|d d }t d ||||St|d d}tt|d dpd} |tt|ddp||| | pdd} | |j|<t| S#t"$r"t d|d|cYSwxYw)z5Return real chat metadata from Feishu when available.dm)rrxrNrcdSrrKrKrQrOr z-FeishuAdapter.get_chat_info..ErQFr unknownr zchat lookup failedz0[Feishu] Failed to get chat info for %s: [%s] %sr chat_typerrx)rrxrrz'[Feishu] Failed to get chat info for %sTr)r=rUrr_build_get_chat_requestrr r!r"chatr#rrrrrq_map_chat_typer) rdrfallbackcachedr$rr r r raw_chat_typers rO get_chat_infozFeishuAdapter.get_chat_infos   | O&**733  <<  227;;G$.t|/A/F/JGTTTTTTTTH JwxMMJJLLPUUUx;;h/CDDQSZ\`befff8VT22Dk2 > > D"EEKKMMSSUUM"GD&$77B7CC++M::)1T D .2D !' *::     NNDgX\N ] ] ]OOO sB'F&B'F)F:9F:c*|S)z/Feishu text messages are plain text by default.rxrdrus rOr zFeishuAdapter.format_messages}}rQrcP|j}||sG||}|r.tj|jdddStj| ||}| |j 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)targetrxdaemonN) r@_loop_accepts_callbacks_enqueue_pending_inbound_eventrGThread_drain_pending_inbound_eventsr$rrun_coroutine_threadsafe_handle_message_event_dataadd_done_callback_log_background_failure)rdrr start_drainerfutures rOrzFeishuAdapter._on_message_eventsz++D11  ??EEM  =9%''' F1  + +D 1 1      !=>>>>>rQcT|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. reventNrRrrrzA[Feishu] Pending-inbound queue full (%d); dropped oldest event %sTzI[Feishu] Queued inbound event for replay (loop not ready, queue depth=%d)) rOrrNrQpopr#rrrrrBrPr)rdrdroppedrrRrdepth should_starts rOrz,FeishuAdapter._enqueue_pending_inbound_events ' 5 54/00D4SSS6::1==+#GWd;;E%eY==G!$WWlB%G%G%T9!U!UJJ +++!*JJJ+ W3  ( / / 5 5 5455E#<?????rQc:tddS)Nz![Feishu] Message recalled by userrrs rOrz"FeishuAdapter._on_message_recalleds 899999rQ event_typecbt|dd}tt|ddpd}tt|ddpd}t|dd}tt|ddpd}d|vrd nd }td |||||j} |d vs6|t ks+|r)| 't t| d drdStj| ||| } | |j dS)z>Route user reactions on bot messages as synthetic text events.rNrr operator_type reaction_typerfcreatedaddedremovedz?[Feishu] Reaction %s on message %s (operator_type=%s, emoji=%s)>apprrcdSrrKrKrQrOr z2FeishuAdapter._on_reaction_event..surQ) r#rrrr@_FEISHU_ACK_EMOJIrrr_handle_reaction_eventrr) rdrrrrrreaction_type_objrfrrrs rOrz FeishuAdapter._on_reaction_eventsZgt,, b99?R@@ GE?B??E2FF #E?DAA!2L"EEKLL %33 M        z ^ + +.../|=GD+}}==??@@ F1  ' ' D 9 9      !=>>>>>rQc|j}||s1tdtrt ndSt |dd}t |dd}t |dipi}t |tr|dnd}|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 readyNrrrwr1)r action_valuer) r@rrrr%r#rrr_handle_approval_card_action_submit_on_loop_handle_card_action_event)rdrrrrrr1s rOrz%FeishuAdapter._on_card_action_triggersz++D11 Z NNW X X X4OY.000UY Ygt,,$//vw339r =G VZ=[=[e ((999ae  h445|bf4gg g T4#A#A$#G#GHHH & .4*,,,rQrcZ|duo'tt|dd S)zEReturn True when the adapter loop can accept thread-safe submissions.NrcdSrrKrKrQrOr z7FeishuAdapter._loop_accepts_callbacks..sPUrQrr#)rs rOrz%FeishuAdapter._loop_accepts_callbackss64Y-VWT; -V-V-X-X(Y(Y$YYrQcorocdtj||}||jdS)zISchedule background work on the adapter loop with shared failure logging.N)rrrr)rdrrrs rOrzFeishuAdapter._submit_on_loops11$==  !=>>>>>rQrrc|d}|1tdtrtndSt|dd}t |dd}t t |ddpd}||p|}||| |||tdSt} t8t} d | _ | || | _ | | _| S) zISchedule approval resolution and build the synchronous callback response.r2Nz2[Feishu] Card action missing approval_id, ignoringr1rcoperatorrrraw)r?rY)rrrr%rhr#r_get_cached_sender_namer_resolve_approvalr$rrErr) rdrrrr2r?rrrYrrs rOrz*FeishuAdapter._handle_approval_card_actions+"&&}55   LLM N N N4OY.000UY Y%)),*:*:?*K*KVTT5*d33gh 266<"==0099DW  T4#9#9+vy#Y#YZZZ & .4.00  #>>DDI::&T]:^^DI HMrQr2c^K|j|d}|std|dS ddlm}||d|}td||d||dS#t$r&}td|Yd}~dSd}~wwxYw)z8Pop approval state and unblock the waiting agent thread.Nz0[Feishu] Approval %s already resolved or unknownr)resolve_gateway_approvalr+zIFeishu button resolved %d approval(s) for session %s (choice=%s, user=%s)z9Failed to resolve gateway approval from Feishu button: %s) r_rrrtools.approvalrrrr)rdr2r?rYstaterrars rOrzFeishuAdapter._resolve_approval s$((d;;  LLK[ Y Y Y F [ ? ? ? ? ? ?,,U=-A6JJE KK[u]+VY      [ [ [ LLTVY Z Z Z Z Z Z Z Z Z [s.*srQrrrrrrrrrz5[Feishu] Failed to fetch message for reaction routingTrrrrfUNKNOWNrrrz reaction:rgrx Feishu Chat chat_infoevent_chat_typerY user_id_altrrrrrY thread_idrrtrsource raw_messager timestampzD[Feishu] Routing reaction %s:%s on bot message %s as synthetic event)r=r#r_build_get_message_requestrr r!r"rRrrqrrr_resolve_sender_profiler build_source_resolve_source_chat_typer+r,TEXTrnowr_handle_message_with_guards)rdrrrrr$rrr rrr chat_type_raw user_id_objrrfrsynthetic_textsender_profilerrsynthetic_events rOrz$FeishuAdapter._handle_reaction_eventsr|  Fgt,, b99?R@@   F 55jAAG$.t|/A/I/MwWWWWWWWWH #N78Y #N#N#P#P GHfd;;WdKKQrE#-%((C S(D11FgfmR@@FBGGMMOOKe##'#y"55;<.\s,wwwBcBhQvFvFv1FvFvFvrQTF)rrMr)rdrexpiredrrs @rO_is_card_action_duplicatez'FeishuAdapter._is_card_action_duplicateXsxikkwwww$":"@"@"B"Bwww , ,A(++ D, , ,4*- 'urQc Kt|dd}tt|ddpd}|r2||rtd|dSt|dd}tt|ddpd}t|dd}tt|d dpd}|r|std dSt|d d}tt|d dpd } t|dipi} d| } | r. | dt j| dz } n#t$rYnwxYwt|dd} | | d{V} | |d{V}| || dp|pd| |d| d| dd| d}t| tj|||ptt#jt'j}td| ||||d{VdS)zHRoute Feishu interactive card button clicks as synthetic COMMAND events.rNrrz1[Feishu] Dropping duplicate card action token: %scontextrrrzB[Feishu] Card action missing chat_id or operator open_id, droppingrr~rrwz/card rFr3)rrrrxrrrrrYrrrzB[Feishu] Routing card action %r from %s in %s as synthetic command)r#rrrrr5r6rrrrrrrr+r,COMMANDuuiduuid4rrrr)rdrrrrrrrr action_tagrrrrrrrs rOrz'FeishuAdapter._handle_card_action_eventdsgt,,GE7B//5266  T33E::  LLLe T T T F%D11gg~r::@bAA5*d33gh 266<"== g  LL] ^ ^ ^ F$//33?x@@ vw339r .*..   "TdjE&R&R&R"T"TT    $GTDQQQ #;;IFFFFFFFF,,W55555555 ""mmF++GwG-44yZa4bb"9-$[1&}5#  '$,1DJLL 1 1lnn      XZdfmovwww..???????????s6E E E  asyncio.Lockcx|j|}|tj}||j|<|S)zTReturn (creating if needed) the per-chat asyncio.Lock for serial message processing.)rRrrrH)rdrlocks rO_get_chat_lockzFeishuAdapter._get_chat_locks:##G,, <<>>D(,D W % rQr+cNK|jrt|jddpdnd}||}|4d{V|j}|r||d{V||d{Vdddd{VdS#1d{VswxYwYdS)aDispatch a single event through the agent pipeline with per-chat serialization and a persistent ACK emoji reaction before processing starts. - Per-chat lock: ensures messages in the same chat are processed one at a time (matches openclaw's createChatQueue serial queue behaviour). - ACK indicator: adds a CHECK reaction to the triggering message before handing off to the agent and leaves it in place as a receipt marker. rrN)rr#rr_add_ack_reactionhandle_message)rdrr chat_lockrs rOrz)FeishuAdapter._handle_message_with_guardss`AF T'%, 266<"RT''00  - - - - - - - -)J 9,,Z888888888%%e,, , , , , , , ,  - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -sAB B!Bc K|jr|sdS ddlm}m}|dt i}|| |}tj |jj j jj|d{V}|r<t!|ddr"t!|dd}t!|ddSt"d |t!|d dt!|d dn-#t&$r t"d |d YnwxYwdS)zGAdd a persistent ACK emoji reaction to signal the message was received.Nr)CreateMessageReactionRequest CreateMessageReactionRequestBodyrfrcdSrrKrKrQrOr z1FeishuAdapter._add_ack_reaction..srQr reaction_idz9[Feishu] Failed to add ack reaction to %s: code=%s msg=%sr r z)[Feishu] Failed to add ack reaction to %sTr)r=lark_oapi.api.im.v1r rrrrrrrrr r!r"message_reactionrhr#rrr)rdrr rrr$rrs rOr zFeishuAdapter._add_ack_reactions| : 4 c         188:: .?@AA  -4466J''d##  %.t|/A/R/Y[bccccccccH :GGHiGGII :x66t]D999 NNK&$//%..       c c c NNF ]aN b b b b b ctsDE;E'E;:E; remote_ipstatusc,tj}|j|}|W|\}}}||z tkrC|dz }|tzdkr!t d|||||z |||f|j|<dSd||f|j|<dS)zIncrement the anomaly counter for remote_ip and emit a WARNING every threshold hits. Mirrors openclaw's createWebhookAnomalyTracker: TTL 6 hours, log every 25 consecutive error responses from the same IP. NrrzY[Feishu] Webhook anomaly: %d consecutive error responses (%s) from %s over the last %.0fs)rrLr#_FEISHU_WEBHOOK_ANOMALY_TTL_SECONDS!_FEISHU_WEBHOOK_ANOMALY_THRESHOLDrr)rdrrrentryra _last_status first_seens rO_record_webhook_anomalyz%FeishuAdapter._record_webhook_anomalys ikk,00;;  .3 +E<Z"EEE <<AANN.!j( @@@rQrincomingc|j|jko9|j|jko)|j|jko|jj|jjkSr;)rr$r%rrrr=s rO_media_batch_is_compatiblez(FeishuAdapter._media_batch_is_compatibleU sY  !X%: : G,0LL G&(*@@ G)X_-FF  rQcK||}|j|}|!||j|<||dS|||s<||d{V||j|<||dS|j|j|j|j|j r%| |j |j |_ |j |_ |j r |j |_ ||dSr;) r<r]r_schedule_media_batch_flushr@_flush_media_batch_nowr"rr#rt_merge_captionrr)rdrrrs rOr.z"FeishuAdapter._enqueue_media_event^ sS##E**.22377  /4D ' ,  , ,S 1 1 1 F..x?? --c22 2 2 2 2 2 2 2/4D ' ,  , ,S 1 1 1 F""5#3444##E$5666 : K // uzJJHM"_   3"'"2H  ((-----rQrcH||j||jdSr;)_reschedule_batch_taskr^_flush_media_batchrdrs rOrBz)FeishuAdapter._schedule_media_batch_flushs s3 ##  +   #     rQcKtj} tj|jd{V||d{V|j||ur|j|ddSdS#|j||ur|j|dwwxYwr;)r current_taskrrrCr^rr)rdrrJs rOrGz FeishuAdapter._flush_media_batchz s+--  ?- ?@@ @ @ @ @ @ @ @--c22 2 2 2 2 2 2 2.22377<GG/33C>>>>>HGt.22377<GG/33C>>>>Hs :B :CcK|j|d}|sdStd|t |j||d{VdS)Nz6[Feishu] Flushing media batch %s with %d attachment(s))r]rrrrr"rrdrrs rOrCz$FeishuAdapter._flush_media_batch_now s+//T::  F D   ! !   ..u55555555555rQcbK||d}t||d{VS)Nr:r;rM)_guess_remote_extensionr0)rdrvrMs rOrxz$FeishuAdapter._download_remote_image sC**9f*EE))==========rQfile_urlr|r}tuple[str, str]c Kddlm}||std|ddddl}|dd4d{V}||dd d  d{V}|dddd{Vn#1d{VswxYwY||t|j d d ||}t|j |} | |fS)Nr) is_safe_urlz&Blocked unsafe URL (SSRF protection): Pg>@T)rfollow_redirectsz)Mozilla/5.0 (compatible; HermesAgent/1.0)z*/*)z User-AgentAcceptheaders Content-Typer) content_type default_namer|) tools.url_safetyrSr*httpx AsyncClientrraise_for_status_derive_remote_filenamerrXr/ru) rdrPr|r}rSr]rrfilename cached_paths rOr~z'FeishuAdapter._download_remote_document s 100000{8$$ WUhsPRsmUUVV V $$TD$II ( ( ( ( ( ( (V#ZZ"M#(H  % % ' ' ' ( ( ( ( ( ( ( ( ( ( ( ( ( ( ( ( ( ( ( ( ( ( ( ( ( ( (// X-11."EEFF'# 0   00@(KK H$$s5B B #B rr&ct|pddddj}|tt zt zttzvr|n|S)Nr?rr) rrsuffixrq_IMAGE_EXTENSIONS_AUDIO_EXTENSIONS_VIDEO_EXTENSIONSrr.)rr&rMs rOrOz%FeishuAdapter._guess_remote_extension soCI2$$S!,,Q/007==??/2CCFWWZ]^vZwZwwxxssF FrQrZr[cvt|pddddjp|}t|j}|s^t j|pddddpdp|}||}|S)Nrrdrr;)rrrxrerq mimetypesguess_extensionr)rPrZr[r|rSrMguesseds rOr`z%FeishuAdapter._derive_remote_filename s(.b//Q77:;;@PL 9oo$**,, 0/1C0J0J3PQ0R0RST0U0[0[0]0]0c0c0e0e0kikll{p{G$/g//IrQrwct|tr(tdid|DSt|tr d|DS|S)NcJi|] \}}|t|!SrKr3_namespace_from_mapping)rLrr=s rOrPz9FeishuAdapter._namespace_from_mapping.. s0%v%v%v[d[^`dc=+P+PQU+V+V%v%v%vrQcBg|]}t|SrKrprys rOrz9FeishuAdapter._namespace_from_mapping.. s&RRRDM99$??RRRrQrK)rrrrrrs rOrqz%FeishuAdapter._namespace_from_mapping sq eT " " x"ww%v%vhmhshshuhu%v%v%vww w eT " " SRRERRR R rQr$c Kt|ddpd}|jd|jd|}||sGtd|||dtjddSt|d ipi}t| d d pd  d d  }|rN|dkrHtd||||dtjddSt|dd}|S|tkrHtd||||dtjddS tj|t$d{V}n#tj$rPtdt$|||dtjddcYSt($r2||dtjddd d!cYSwxYwt-|tkrUtd"t-||||dtjddS t/j|d#}nK#t.jt6f$r2||dtjdd$d d!cYSwxYw| d%d&kr*tjd'| d'd iS|jr| d(pi} t| d)p| d)pd } | rt;j| |jsGtd*|||d+tjd,d-S|jrb| |j!|sGtd.|||d/tjd,d0S| d1rIt"d2||d3tjdd4d d!S|#|t| d(pi d5pd } |$|} | d6kr|%| n| d7kr|&| n| d8kr|'| np| d9kr|(| nT| d:vr|)| | n9| d;kr|*| nt+d<| pdtjd d=d S)>Nremoterrgz+[Feishu] Webhook rate limit exceeded for %s429izToo Many Requests)rrtrXrYrrjrapplication/jsonz=[Feishu] Webhook rejected: unexpected Content-Type %r from %s415izUnsupported Media Typecontent_lengthz2[Feishu] Webhook body too large (%d bytes) from %s413izRequest body too largerz6[Feishu] Webhook body read timed out after %ds from %s408izRequest Timeout400izfailed to read body)r r )rz6[Feishu] Webhook body exceeds limit (%d bytes) from %sutf-8z invalid jsonrurl_verification challengerrz=[Feishu] Webhook rejected: invalid verification token from %sz 401-tokenizInvalid verification tokenz4[Feishu] Webhook rejected: invalid signature from %sz401-sigzInvalid signatureencryptzL[Feishu] Encrypted webhook payloads are not supported by Hermes webhook modez 400-encryptedz,encrypted webhook payloads are not supportedrzim.message.receive_v1zim.message.message_read_v1zim.chat.member.bot.added_v1zim.chat.member.bot.deleted_v1)rrzcard.action.triggerz([Feishu] Ignoring webhook event type: %sok),r#rr_check_webhook_rate_limitrrrrResponserrrrrq_FEISHU_WEBHOOK_MAX_BODY_BYTESrrrb$_FEISHU_WEBHOOK_BODY_TIMEOUT_SECONDSrr json_responserr5rdecoderUnicodeDecodeErrorrhmaccompare_digestr_is_webhook_signature_validrXrrrqrrrrrrr) rdr$rrate_keyrXrZrx body_bytesr8rincoming_tokenrrs rO_handle_webhook_requestz%FeishuAdapter._handle_webhook_request sWh55B lEET%7EE)EE--h77 F NNH) T T T  ( (E : : :>> NNZ\hjs t t t  ( (E : : : > >I?0'LAM M rXrbytesc4t|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-signatureFr|r)errorsz3[Feishu] Signature verification raised an exceptionTr) rrrrhashlibsha256encode hexdigestrrrrr) rdrXrrnonce signaturebody_strrucomputeds rOrz)FeishuAdapter._is_webhook_signature_valid% s0 $>CCIrJJ GKK 6;;ArBB $6;;ArBB   Y 5 !(((CCH"HEH4+<HhHHG~gnnW&=&=>>HHJJH&x;; ;    LLNY]L ^ ^ ^55 s9A3C--&DDrctj|j|}|1|\}}|z tkr|tkrdS|dz|f|j|<dSt |jt krZfd|jD}|D] }|j|= ||jvrt |jt krdSdf|j|<dS)u*Return False when the composite rate_key has exceeded _FEISHU_WEBHOOK_RATE_LIMIT_MAX. The rate_key is composed as "{app_id}:{path}:{remote_ip}" — matching openclaw's key structure so the limit is scoped to a specific (account, endpoint, IP) triple rather than a bare IP, which causes fewer false-positive denials in multi-tenant setups. The tracking dict is capped at _FEISHU_WEBHOOK_RATE_MAX_KEYS entries to prevent unbounded memory growth. Stale (expired) entries are pruned when the cap is reached. NFrTc<g|]\}\}}|z tk|SrK)#_FEISHU_WEBHOOK_RATE_WINDOW_SECONDS)rLk_rrs rOrz;FeishuAdapter._check_webhook_rate_limit..P s; a!R8BBBBBBrQ)rrKrr_FEISHU_WEBHOOK_RATE_LIMIT_MAXr_FEISHU_WEBHOOK_RATE_MAX_KEYSr)rdrrra window_start stale_keysrrs @rOrz'FeishuAdapter._check_webhook_rate_limit: sikk)--h77  "' E<\!$GGG::: 57Only merge text events when reply/thread context is identical.)r$r%rrr?s rO_text_batch_is_compatiblez'FeishuAdapter._text_batch_is_compatiblej sC  (H,H H G&(*@@ G)X_-FF rQcK||}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.rNrr)rrrtrYr_last_chunk_lenr[_schedule_text_batch_flushr_flush_text_batch_nowrrrr) rdrr chunk_lenrexisting_count next_count appended_text next_texts rOr,z!FeishuAdapter._enqueue_text_events s)""5)) (b)) -11#66  $-E !.3D &s +34D +C 0  + +C 0 0 0 F--h>> ,,S11 1 1 1 1 1 1 1.3D &s +34D +C 0  + +C 0 0 0 F8<044S99GAHOww(91===aH4000<6-&& & & & & & & &,,S11 1 1 1 1 1 1 1-11#66,FF.223=====GFt-11#66,FF.223====Gs A>C:D cK|j|d}|j|d|sdStd|t |jpd||d{VdS)z,Dispatch the current text batch immediately.Nz*[Feishu] Flushing text batch %s (%d chars)r)rYrr[rrrrtrrLs rOrz#FeishuAdapter._flush_text_batch_now s*..sD99 '++C666  F 8    b ! !   ..u55555555555rQ-tuple[str, MessageType, List[str], List[str]]cbKt|ddpd}t|ddpd}tt|ddpd}td||t ||}|||d{V\}}|||}|j} |tj tj tj tj hvrHt|d kr5|jd vr,||d |d d{V} | r| } | |||fS) z?Extract text and cached media from a normalized Feishu message.rurrrz3[Feishu] Received raw message type=%s message_id=%srr~)rrNr>r_rr)r#rrrr"_download_feishu_message_resources _resolve_normalized_message_typerr,r3r4r2r1rr_maybe_extract_text_document) rdrRr~rrrr"r#r)rtinjecteds rOr&z&FeishuAdapter._extract_message_content smgy"55; 7NB77=2,;;ArBB  I8U_```-8Q\]]] (,(O(O!!)P) ) # # # # # #  K<>z!}kZ[n]]]]]]]]H \:{::rQrrtuple[List[str], List[str]]cKg}g}|jD]N}|||d{V\}}|r*||||O|jD]_}|||j|j|jd{V\}}|r*||||`||fS)N)rr)rrrfallback_filename)r_download_feishu_imagerBr!_download_feishu_message_resourcerrr) rdrrr"r#rrb media_typers rOrz0FeishuAdapter._download_feishu_message_resources s> !# !# #. / /I,0,G,G%#-H--'''''' #K /!!+..."":...#. / /I,0,R,R%"+'5"+"5 -S--'''''' #K  /!!+..."":...;&&rQrr,c|pd}|dr tjS|dr tjS|dr tjS|S)Nrimage/audio/video/)rqrr,r1r4r2)rr&rs rO_resolve_media_message_typez)FeishuAdapter._resolve_media_message_type sz &B--//   * * %$ $   * * %$ $   * * %$ $rQr#rcN|j}|dkr+||r|dndtjS|dkr+||r|dndtjS|dkr+||r|dndtjStjS)Nrrrr;r_r)rrr,r1r4r3r)rdrr# preferreds rOrz.FeishuAdapter._resolve_normalized_message_type s 5   33k4YKNNWYcnct3uu u   33k4YKNNWYcnct3uu u  " "33k4YKNNWYcncw3xx xrQrbcK|r|dsdS tj|tkrdSt |j}|dvr|dvrdSt |d}| |}d|d|S#ttf$r!t d |d YdSwxYw) Nztext/r>.md.txt> text/plain text/markdownr|encodingz [Content of z]: z7[Feishu] Failed to inject text document content from %sTr)rrr_getsize_MAX_TEXT_INJECT_BYTESrrerq read_text_display_name_from_cached_pathOSErrorrrr)rdrbrrMrurus rOrz*FeishuAdapter._maybe_extract_text_document% s  *"7"7"@"@ 2 w{++.DDDr{##*0022C/))j@_._._r;''1171CCG>>{KKL=,==G== =+,    NNTValpN q q q22 s(B7.B77?B77.C)(C)rc K|jr|sdS |||d}tj|jjjjj|d{V}|r|s=t d|t|ddt|dddS| |}|sdS| |d }t|d dp|d }|||d t }t!|| } ||||} | | fS#t&$r!t d|dYdSwxYw)Nrrr\rrrz+[Feishu] Failed to download image %s: %s %sr rr request failedrYrr:allowedrNr;z*[Feishu] Failed to cache image resource %sTr)r=_build_message_resource_requestrr r!r"message_resourcerrrrr#_read_binary_response_get_response_header_guess_extensionrfr2_normalize_media_type_default_image_media_typer) rdrrr$r raw_bytesrZrarMrbrs rOrz$FeishuAdapter._download_feishu_image5 s| : 6 ::%"%;G %.t|/A/R/VX_````````H 8#3#3#5#5 AHfi88He-=>>  v228<t d|||t|ddt|dd | |} | s||d } t|d dpd } | p|p|d |} || || } | dre|| | dt&}t)| |}td||| p||fcS|dks| drj|| | dt.}t1| |}td||| pd|dpdfcS| drJt5| js| d} t9| | }td||| fcSt5| js| t:vr| t:| } t9| | }td||| p|| fcS#t>$r"t d||d YwxYwdS)!Nr>r_r`rrz>[Feishu] Resource download failed for %s/%s via type=%s: %s %sr rr rrYrrrr;rr:rrNz,[Feishu] Cached message image resource at %sr_rrAz,[Feishu] Cached message audio resource at %sroggrrIz,[Feishu] Cached message video resource at %sz/[Feishu] Cached message document resource at %sz/[Feishu] Failed to cache message resource %s/%sTr)!r=rBrrr r!r"rrrrrr#rrr_guess_media_type_from_filenamerrrfr2rrrgr1lstriprrer/_DOCUMENT_MIME_TO_EXT_guess_document_media_typerr)rdrrrr request_types request_typer$rrrZresponse_filenamerarrMrbs rOrz/FeishuAdapter._download_feishu_message_resourceT s| : 6& . . .   ( ( ()< < L; >>)%".? ")!24RR $+Hk4$H$H$NB!,a0Aa EaEaW_EaEa!77  @@JJ8 ((22Z//,Xi/jjC"8"L"L"LKKK NP[\\\& (Yd6T6TUX6Y6YYYYY7**j.C.CH.M.M*//,Xi/jjC"8"L"L"LKKK NP[\\\&)Z7Z 3@XSX7Z7Z[[[[((223>>05&.#4#4#4";Ix"P"PKKK NP[\\\& 2222H~~,P?T1T1T"*O,A*,MOOH7 8LL  M{[[["Z%\43R3RS[3\3\]]]]   E!  vs4BLL(CLBLAL$A1L(MMrct|dd}|dSt|dr!t|St|S)NrrQgetvalue)r#hasattrrrrb)rfile_objs rOrz#FeishuAdapter._read_binary_response s`8VT22  3 8Z ( ( .**,,-- -X]]__%%%rQrxc \t|dd}t|dipi}t||||dpddddS)NrrXrrjrr)r#rrrqrr)rrxrrXs rOrz"FeishuAdapter._get_response_header sht,,#y"--37;;tW[[r%B%BCCIrJJPPQTVWXXYZ[aacciikkkrQrarrct|pdj}||vr|Stj|pddddpd}||vr|S|SNrrjrr)rrerqrkrlrr)rarZr&rrMrms rOrzFeishuAdapter._guess_extension s8>r"")//11 '>>J+\-?R,F,FsA,N,Nq,Q,W,W,Y,Y,_,_,a,a,geghh g  NrQc|pdddd}|p|Sr)rrrq)rZr&rs rOrz#FeishuAdapter._normalize_media_type sD"(b//Q77:@@BBHHJJ $W$rQct|pdj}tj|t j|pddpdS)Nrrzapplication/octet-stream)rrerqr.rrk guess_type)rarMs rOrz(FeishuAdapter._guess_document_media_type sQ8>r"")//11'+C1EhnRT1U1UVW1X1v\vwwwrQr_ctj|}|dd}t |dkr|dn|}t jdd|S)NrrrXz [^\w.\- ])rr_rdrrrr)r_rdrErus rOrz,FeishuAdapter._display_name_from_cached_path sY7##D))sA&&#&u::??uQxx vlC666rQctj|pddpd}|r|St|pdj}|t vrd|dS|tvrd|dS|tvrt |SdS)Nrrrrr) rkrrqrrerhrrgrfr3r)rarmrMs rOrz-FeishuAdapter._guess_media_type_from_filename s'B77:@bGGII  N8>r"")//11 # # #-CJJsOO-- - # # #-CJJsOO-- - # # # ::3?? ?rrQrc|pd}|dkrdSd|vsd|vsd|vrdS|dkrdSdS)Nrrrtopicthreadforumr)rrq)rrs rOrzFeishuAdapter._map_chat_type sm#)r002288::   4 j H $:$:g>S>S7  7trQrrct|dpd}|dvr|S|dkrdSdS)Nrr>rrrrr)rrrrq)rrrDs rOrz'FeishuAdapter._resolve_source_chat_type s^y}}V,,23399;;AACC ) ) )O e # #4wrQDict[str, Optional[str]]cKt|ddpd}t|ddpd}t|ddpd}|p|}||p|d{V}|||dS)Nrrr)rrYr)r#_resolve_sender_name_from_api)rdrrrr primary_idrus rOrz%FeishuAdapter._resolve_sender_profile s)Y55=)Y55=9j$77?4' !?? @VhWWWWWWWW !%#   rQc|sdS|j|}|dS|\}}tj|kr|S|j|ddS)z>Return a cached sender name only while its TTL is still valid.N)rJrrr)rdrrrx expire_ats rOrz%FeishuAdapter._get_cached_sender_name sl 4(,,Y77 >4 i 9;; " "K ##It444trQcK|r|jsdS|}|sdStj}||}||S ddlm}|drd}n|drd}nd}|| | }tj |jj jjj|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-#t.$r t0d|dYnwxYwdS)uFetch the sender's display name from the Feishu contact API with a 10-minute cache. ID-type detection mirrors openclaw: ou_ → open_id, on_ → union_id, else user_id. Failures are silently suppressed; the message pipeline must not block on name resolution. Nr)GetUserRequestou_ron_rrruserrxrunicknameen_namez-[Feishu] Failed to resolve sender name for %sTr)r=rrrlark_oapi.api.contact.v3r rrr user_id_typerrr contactv3rrrr#rr_FEISHU_SENDER_NAME_TTL_SECONDSrJrrr) rdrtrimmedr cached_namer id_typer$rrrxs rOrz+FeishuAdapter._resolve_sender_name_from_api sH    4//## 4ikk227;;  "  d ? ? ? ? ? ?!!%(( $###E** $$#$,,..66w??LLWUU[[]]G$.t|/C/F/K/OQXYYYYYYYYH 8#3#3#5#5 t78VT::FDIIDfd++246624T2224D11   4-- zz|| 8c7dD+G4K d d d LLH)^bL c c c c c dtsCG #B&G 'G54G5cK|jr|sdS||jvr |j|S ||}tj|jjjjj|d{V}|rt|dddurAt|dd}t|dd}t d|||dStt|d dd dpg}|r|d nd}t|d d}t|d dpd} t|ddpd} | | | } | |j|<| S#t$r!t d|dYdSwxYw)NrcdSrrKrKrQrOr z3FeishuAdapter._fetch_message_text..> rrQFr rr zmessage lookup failedz3[Feishu] Failed to fetch parent message %s: [%s] %srrrrrrru)rr~z*[Feishu] Failed to fetch parent message %sTr)r=rVrrr r!r"rRrr#rr_extract_text_from_raw_contentr) rdrr$rr r rparentrrr~rts rOr'z!FeishuAdapter._fetch_message_text6 s| : 4 1 1 1+J7 7 55jAAG$.t|/A/I/MwWWWWWWWWH JwxMMJJLLPUUUx;;h/FGGTV`bfhkllltGHfd;;WdKKQrE!&0U1XXDF66400Dvz266<"H!$ 266<"K66Va6bbD37D $Z 0K    NNG^bN c c c44 sB&E BE'F?Frr~ct||}|jr|jSt|jtr|jdnd}t |pdS)Nrr)rrrrrrrr)rdrr~rr|s rOrz,FeishuAdapter._extract_text_from_raw_contentO sy-8Q\]]]  " +* *EOPZPceiEjEjtj)--.@AAApt ;%%''/4/rQrMcn|pd}|dvrdSd|dpdS)Nr>r:r;z image/jpegrrjpeg)rqr)rMnormalized_exts rOrz'FeishuAdapter._default_image_media_typeV sI)**,, . . .<>--c22>>rQrc |dS#t$rtdYdSwxYw)Nz-[Feishu] Background inbound processing failed)rrr exception)rs rOrz%FeishuAdapter._log_background_failure] sV N MMOOOOO N N N   L M M M M M M Ns$AArct|dd}t|dd}||hdhz }|r|jr ||jzrdS|r|j|nd}|r|j}|j}|j} n#|jp|j}|j }t} |dkrdS|dkrdS|dkrdS|d krt|o||zS|d krt|o|| z St|o ||j zS) z)Per-group policy gate for non-DM traffic.rNrTdisabledFrg admin_onlyrr) r#rrrrrrrrrrr) rdrrsender_open_idsender_user_id sender_idsrulerrrs rO_allow_group_messagez"FeishuAdapter._allow_group_messageh sM It<< It<<$n5>  $, J,E 418Bt $$W---d  [FIII/E43EF1II Z  5 V  4 \ ! !5 [  ? Y(>@@ @ [  CJ,B'CDD DJKJ1J$JLLLrQcB|||sdSt|ddpd}d|vrdSt|ddpg}|r||Stt|ddpd| }|jr||jSdS) zCRequire an explicit @mention before group messages enter the agent.Frurz@_allTmentionsNrr)r*r#_message_mentions_botrr_post_mentions_bot)rdrRrrr~r,rs rOrz*FeishuAdapter._should_accept_group_message s((G<< 5gy"55; k ! !47J55;  8--h77 7- ."==C#     # E**:+CDD DurQr, List[Any]c>|D]}t|dd}t|dd}t|dd}t|ddpd}|jr||jkrdS|jr||jkrdS|jr||jkrdSdS) zJCheck whether any mention targets the configured or inferred bot identity.idNrrrxrTF)r#rrrr)rdr,mention mention_idmention_open_idmention_user_id mention_names rOr-z#FeishuAdapter._message_mentions_bot s  G $55J%j)TBBO%j)TBBO#GVT::@bGGIIL  _8I%I%Itt  _8I%I%Itt~ ,$."@"@tturQrcV|sdS|jr |j|vrdS|jr |j|vrdSdS)NFT)rr)rdrs rOr.z FeishuAdapter._post_mentions_bot sN 5   !2m!C!C4   !2m!C!C4urQcK|jsdSt|j|j|jfrdS ||jd}tj|jj j j j |d{V}|r| s3t|dd}|dkrtddStt|dddd}t|d dpd }|r ||_dSdS#t"$r td d YdSwxYw)zGBest-effort discovery of bot identity for precise group mention gating.Nrrrrr ixz[Feishu] Unable to hydrate bot identity from application info. Grant admin:app.info:readonly or application:application:self_manage so group @mention gating can resolve the bot name precisely.rrapp_namerz'[Feishu] Failed to hydrate bot identityTr)r=anyrrr_build_get_application_requestrrr  applicationv6rrr#rrrrr)rdr$rr rr:s rO_hydrate_bot_identityz#FeishuAdapter._hydrate_bot_identity s|  F !4#4dnE F F  F S99T[9\\G$.t|/G/J/V/Z\cddddddddH 8#3#3#5#5 x668##NNW '(FD995$GGCZ66<"CCEEH *!) * * S S S LLBTL R R R R R R SsBD AD&EEc, tj|jd}nK#t$rYdSt tjf$r&td|jdYdSwxYwt|tr| dini}tj tt|tr d|D}n6t|trd|D}ndSfd |Dt!fd d d|j}tt%||_fd |D|_dS) Nr|rz5[Feishu] Failed to load persisted dedup state from %sTr message_idsci|]E}t|#t|dFS)rrirys rOrPz8FeishuAdapter._load_seen_message_ids.. sE(k(k(kDY\]aYbYbYhYhYjYj(kT):):C(k(k(krQci|]>\}}t|t|.|t|?SrK)rrrr)rLrvs rOrPz8FeishuAdapter._load_seen_message_ids.. sFeeetq!JqRUDVDVe[\[b[b[d[deq%((eeerQcFi|]\}}|dksdks |z k||S)rrrK)rLmsg_idrrttls rOrPz8FeishuAdapter._load_seen_message_ids.. sD# # # %62SyyC1HHb3 B(6rQc|Sr;rK)rvalids rOr z6FeishuAdapter._load_seen_message_ids.. s qrQ)rreversec"i|] }|| SrKrK)rLrrIs rOrPz8FeishuAdapter._load_seen_message_ids.. s!B!B!B!!U1X!B!B!BrQ)r5rrFrFileNotFoundErrorrrrrrrrr_FEISHU_DEDUP_TTL_SECONDSrrsortedrreversedrErD)rdr8 seen_datar sorted_idsrrGrIs @@@rOrcz$FeishuAdapter._load_seen_message_ids s j!7!A!A7!A!S!STTGG     FF-.    NNRTXTjuyN z z z FF 7A$6O6OWGKK r222UW ikk' i & & (k(kI(k(k(kGG  4 ( ( eey/@/@eeeGG F# # # # # )0# # #  E'9'9'9'94HHHI`$J`I`a #'(<(<#=#= !B!B!B!Bz!B!B!Bs-3 A;7A;:A;c\ jjddjj d}dfd|Di}jt j|dddS#t$r&t d jd YdSwxYw) NT)parentsexist_okrAc>i|]}|jv |j|SrK)rD)rLrrds rOrPz;FeishuAdapter._persist_seen_message_ids.. s2&s&s&sWX\`\rWrWrq$*@*CWrWrWrrQFr3r|rz,[Feishu] Failed to persist dedup state to %sr) rFrmkdirrEr write_textr5r6rrr)rdrecentr8s` rOrz'FeishuAdapter._persist_seen_message_ids s r  " ) / /t / L L L-t/E.E.F.FGF$&s&s&s&sV&s&s&stG  " - -dju.U.U.U`g - h h h h h r r r NNI4KalpN q q q q q q rsA6A;;,B+*B+c<tj}t}|j5|j|}||dks ||z |kr ddddS||j|<|j|t|j|jkrR|j d}|j |dt|j|jkR|  ddddS#1swxYwYdS)NrTF) rrMrIrDrrErBrrrr)rdrrrGseen_atstales rOrzFeishuAdapter._is_duplicate s|ikk'    ,00<@RSS S = = = LL> 3Y]L ^ ^ ^e3s88<<< < < < < < < =sJ G A"D< G D  G D 2G B G H;HHHr8c VKt|pid}|r||||tt j}|||}tj|j j j j j |d{VS||||tt j}|d|}tj|j j j j j|d{VS)Nrrurreply_in_thread uuid_value receive_idrrurkr)rr_build_reply_message_bodyrrr_build_reply_message_requestrr r=r!r"rRreply_build_create_message_body_build_create_message_requestrh) rdrrr8rrrjrr$s rO_send_raw_messagezFeishuAdapter._send_raw_messageS s*B33K@@AA  V11! /tz||,, 2D 77$GGG *4.r serQr)rs rOrz!FeishuAdapter._response_succeededp s,HN!L9mm!L!L!N!NOOOrQ field_namect|sdSt|dd}|rt||dndS)Nr)r3rr#)rrvrs rOriz%FeishuAdapter._extract_response_fieldt sJ00:: 4x..26@wtZ...D@rQ)r\r[r\c|rtd||St|dd}t|d|}tdd|d||S)NF)rr raw_responser rr rWz] )r-r#)rdrr[r\r r s rOrjz$FeishuAdapter._response_error_result{ sk  Ze>PXYYY Yx33h77%/@4/@/@3/@/@xXXXXrQc||s|||Std||d|S)N)r[Tr)rrry)rrjr-ri)rdrr[s rOrz#FeishuAdapter._finalize_send_result sb''11 Z..x.YY Y33HlKK!    rQc  KttD]} |jdkr|d{Vn|d{VdS#t $r}d|_|d|_| d{V|tdz krd|z}t d|dzt||tj |d{VYd}~d}~wwxYwdS)NrsFrrz:[Feishu] Connect attempt %d/%d failed; retrying in %ds: %s)range_FEISHU_CONNECT_ATTEMPTSr_connect_websocket_connect_webhookrrrr?rrrrr)rdattemptr wait_secondss rOrz!FeishuAdapter._connect_with_retry si566 2 2G 2(K77113333333333//111111111 2 2 2 % 66888"&//1111111116::: G| PaK,  mL11111111111111 2 2 2sAA D'BC<<DcBKtstd|jdkrtnt}|||_||_|jtd|j }|| rtd| d{Vt|j |jtjj|j||_|dt(|j||_dS)Nz4websockets not installed; websocket mode unavailablerm$failed to build Feishu event handlerzadapter loop is not ready)rr log_level event_handlerrq)FEISHU_WEBSOCKET_AVAILABLErrr"r#_build_lark_clientr=rrCr@rr?FeishuWSClientrrrmLogLevelINFOr>run_in_executorr.r?)rdrqrs rOr~z FeishuAdapter._connect_websocket s) WUVV V"&"3v"="=;..v66 "7799   &EFF Fz <4>>++<:;; ;((*********(<'m(-    ..  * O    rQcKtstd|jdkrtnt}|||_||_|jtd| d{Vtj }|j |j|jtj||_|jd{Vtj|j|j|j|_|jd{VdS)Nz/aiohttp not installed; webhook mode unavailablermr)FEISHU_WEBHOOK_AVAILABLErrr"r#rr=rrCr?r Applicationrouteradd_postrr AppRunnerrAsetupTCPSiterrrBr$)rdrqrs rOrzFeishuAdapter._connect_webhook sJ' RPQQ Q"&"3v"="=;..v66 "7799   &EFF F((*********o D.0LMMM"}S11"((********* [)=t?QSWSeff &&(((((((((((rQrqc,tj|j|j|tj j  Sr;) rmr'rrrrrrqrrWARNINGr)rdrqs rOrz FeishuAdapter._build_lark_client s] K   ! ! VDL ! ! Z( ) ) VF^^ Yt}, - - UWW  rQc Kd}|}ttD]3} ||||||d{V} |rn|| sYt | dd} | t vr?t d|| |d}||||d|d{V} | cS#t$r} | }|dkr(t t| r|tdz krd|z} t d|dzt|| | tj | d{VYd} ~ -d} ~ wwxYw|ptd) Nrr uk[Feishu] Reply to %s failed (code %s — message withdrawn/missing); falling back to new message in chat %srJrrzC[Feishu] Send attempt %d/%d failed for chat %s; retrying in %ds: %szFeishu send failed)r|_FEISHU_SEND_ATTEMPTSrsrr#_FEISHU_REPLY_FALLBACK_CODESrrrrrrrrr) rdrrr8rr last_erroractive_reply_torrr rrs rOrz%FeishuAdapter._feishu_send_with_retry s+/ "233- 2- 2G, 2!%!7!7#%#,% "8""#4+C+CH+M+M"8VT::D;;;E+ # +/)-)?)?$+%-$+%)%- *@**$$$$$$  2 2 2 v%%*B*I*I#c((*S*S%3a777 G| YaK)  mL11111111111111 2 >L)=>>>sBB33 E =BEE cK|jsdS tt|jn4#t$r'}td|dYd}~nd}~wwxYwd|_dS#d|_wxYw)Nz'[Feishu] Failed to release app lock: %sTr)rWr4rrrr)rdrs rOrzFeishuAdapter._release_app_locks&  F +  68O P P P P Z Z Z NNDcTXN Y Y Y Y Y Y Y Y Z'+D # # #dD # * * * *s+(A% AAA%AA%% A.cdtvr8tj|St |S)Nrr)globalsrrrrrrs rOrz%FeishuAdapter._build_get_chat_request+sK wyy ( (!)++33G<<BBDD Dw////rQcdtvr8tj|St |S)Nrr)rrrrrrrs rOrz(FeishuAdapter._build_get_message_request1sK ')) + +$,..99*EEKKMM M*5555rQcdtvr^tj|||St|||S)Nr)rrr)rrrrrrrrrs rOrz-FeishuAdapter._build_message_resource_request7si &')) 3 3)133J''(##m$$  *xm\\\\rQrrcdtvrKtj||St ||S)Nrr9)rrrrrrrr9s rOr<z,FeishuAdapter._build_get_application_requestCsV "gii / /%-//d   f48888rQrjrkc*dtvrqtj||||St||||S)Nr)rurrjr) rrrrurrjrrrris rOrnz'FeishuAdapter._build_reply_message_bodyNs $ 1 1'/11!!(## 11j!!  +     rQrcdtvrKtj||St ||S)Nrr)rrrrrrrrs rOroz*FeishuAdapter._build_reply_message_request`sZ GII - -#+--J''l++   *<PPPPrQcdtvrKtj||St ||S)Nr!r)rr!rrrurrrs rOrz(FeishuAdapter._build_update_message_bodyksZ % 2 2(022(##!!   'BBBBrQcdtvrKtj||St ||S)Nr r)rr rrrrrrs rOrz+FeishuAdapter._build_update_message_requestvsZ !WYY . .$,..J''l++   *<PPPPrQrmc*dtvrqtj||||St||||S)Nr)rmrrur) rrrrmrrurrrrls rOrqz(FeishuAdapter._build_create_message_bodys % 2 2(022J''(##!!j!!  !     rQreceive_id_typecdtvrKtj||St ||S)Nrrr)rrrrrrrrs rOrrz+FeishuAdapter._build_create_message_requestsZ !WYY . .$,.. 11l++   \ZZZZrQrYr\cdtvrKtj||St ||S)NrrX)rrrrYr\rrrXs rOrez&FeishuAdapter._build_image_upload_bodysX #wyy 0 0&.00J''u   *EBBBBrQcdtvr8tj|St |S)Nrr)rrrrrrrs rOrgz)FeishuAdapter._build_image_upload_requestsK 799 , ,%-//<<\JJPPRR RL9999rQrbcdtvr^tj|||St|||S)Nrra)rrrrbrrrrras rOrdz%FeishuAdapter._build_file_upload_bodysg "gii / /%-//9%%9%%d  idSSSSrQcdtvr8tj|St |S)Nrr)rrrrrrrs rOrez(FeishuAdapter._build_file_upload_requestsK ')) + +$,..;;LIIOOQQ QL9999rQc t|Sr;)r7rs rO_build_post_payloadz!FeishuAdapter._build_post_payloads+G444rQr^rgctj||}|didg}||gtj|dS)NrqruFr3)r5rr setdefaultrBr6)rdrGr^r8rus rOrkz'FeishuAdapter._build_media_post_payloadsm*T55g>>??$$Wb11< * * *+C0&8 8 !V + ++V3 3'//rQ)r4r))r:rrr)rrrr)rr rrr)rrrr)NN) rrrurrrrrrr-)rrrrrurrr-)r)N) rrr*rr+rr{rrrrr-)r?rrYrrr)NNN) rrrFrrGrrrrrrr-)NNNN)rrrJrrGrrrrrrrrr-) rrrRrrGrrrrrrr-) rrrUrrGrrrrrrr-r;)rrrr) rrrvrrGrrrrrrr-) rrrzrrGrrrrrrr-)rrrrrurrr)rr rr)rr rr)rrrr)rrrr rr)rr rr )rr rr)rr rr rr)rr rrrr rr )r2r r?rrYrrr)rrrr)rrrr)rr+rr)rrrr)rrrrrr)rrrr) rr rRr rr rrrrrr)rr+rr)rr+rr)rr+r=r+rr)rrrr)rvrrr)rPrr|rr}rrrQ)rrr&rrr) rPrrZrr[rr|rrr)rwr rr )r$r rr )rXr rrrr)rrrr)rrrrrr rr)rRr rr)rrrrrr)rrr&r,rr,)rrr#rrr,)rbrrrrr)rrrrrrQ) rrrrrrrrrrQ)rr rr)rr rxrrr) rarrZrr&rrrrr)rZrr&rrr)rarrr)r_rrr)rrrr)rrrrrr)rr rr)rrrr)rrr~rrr)rMrrr)rr rr)r)rr rrrr)rRr rr rrrr)r,r/rr)rrrr)rrrr)rurrrQ)rrrJrrrrrrGrrrrKrrr-) rrrrr8rrrrrrr )rr rr)rr rvrrr )rr r[rr\rrr-)rr r[rrr-)rqr rr )rrrr )rrrr )rrrrrrrr )rrrrrr ) rurrrrjrrkrrr )rrrr rr )rrrurrr ) rmrrrrurrkrrr )rrrr rr )rYrr\r rr )rr rr )rbrrrrr rr )rGrr^rgrr)rJrr`rrrQ)rrrrr rr7 staticmethodr9r<rr"rrrrrrr(r>rErNrQrTrsruryrrr rrrrrrrrrrrrrrrrrrrrr rrrr(r-r<r@r.rBrGrCrxr~rOr`rqrrrrrr,rrFrrr&rrrrrrrrrrrrrrrrrrr'rrrr*rr-r.r?rcrrr rMrsrrirjrrr~rrrrrrrr<rnrorrrqrrrergrdrerrkrc __classcell__)res@rOr3r3s "" ,&,&,&,&,&,&\M M M \M ^9999:    0++++Z+-+-+-+-Z,,,, ####&&&&"#'-1 7=7=7=7=7=r====D/-1D=D=D=D=D=L   \ ,"&"&-1      ."&#'"&-1     0"&"&-1      ."&"&-1 ;=;=;=;=;=z"&"&-1        @"&"&-1        D####J????0!!!!FQ6Q6Q6Q6f    >MMMM11111111@@@@::::????@----6ZZZ\Z???? 0[[[[ 9@9@9@9@v    0@0@0@0@l----"    LCCCC4:::::7:7:7:7x6666    AAAA   \ ....*    ???? 6 6 6 6>>>>%%%%>FFF\F\\\;\;\;\;|*    L       \ $-$-$-$-L    ;;;\;>>>>, 6 6 6 6";;;;4''''>\      >LLLLd&&&\&lll\l \%%%\%xxx\x777\7    \ \\         ))))V20000???\? NNN\NMMMMM@&"SSSS:CCCC:rrrr(DDDD"&#'%+>=>=>=>=>=>=@SSSS:PPP\PAAA\A)- Y Y Y Y Y Y    22222    4))))     9?9?9?9?v++++000\0 666\6  ] ] ]\ ]999\9   \ "QQQ\QCCC\CQQQ\Q   \ "[[[\[CCC\C:::\:  T T T\ T:::\: 55557777 000\00000rQr3rqcNt|tdSNrl)_ONBOARD_ACCOUNTS_URLSrrqs rO_accounts_base_urlrs ! % %f.DX.N O OOrQcNt|tdSr)_ONBOARD_OPEN_URLSrrs rO_onboard_open_base_urlrs  ! !&*|t}t|d}t||ddi} t |t 5}t j| dcdddS#1swxYwYdS#t$rf}|}|rJ t j| dcYd}~S#tt j f$r|dwxYwd}~wwxYw)zPOST form-encoded data to the registration endpoint, return parsed JSON. The registration endpoint returns JSON even on 4xx (e.g. poll returns authorization_pending as a 400). We always parse the body regardless of HTTP status. r|rYz!application/x-www-form-urlencodedrrXrN) _REGISTRATION_PATHrrrr_ONBOARD_REQUEST_TIMEOUT_Sr5rrbrr r*r)rrrrreqresprrs rO_post_registrationrsy +) + +C T?? ! !' * *D #D>;^*_ ` ` `C  S"< = = = ;:diikk0099:: ; ; ; ; ; ; ; ; ; ; ; ; ; ; ; ; ; ; XXZZ  $ $z*"3"3G"<"<======== 45 $ $ $t# $ sTB,9B B,B##B,&B#'B,, D6D &C93D9DDDrlct|}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: Nrrrr)rqrresmethodss rO_init_registrationr ss "&))H X&'9 : :Cgg.//52Gg%% $! $ $   &%rQclt|}t|ddddd}|d}|std|dd }d |vr|d z }n|d z }|||d d |dpd|dpddS)zXStart the device-code flow. Returns device_code, qr_url, user_code, interval, expire_in.begin PersonalAgentrr)r archetype auth_methodrequest_user_info device_codez7Feishu / Lark registration did not return a device_codeverification_uri_completerrdz&from=hermes&tp=hermesz?from=hermes&tp=hermes user_codeinterval expire_inr[)rqr_urlrrrr)rqrrrrs rO_begin_registrationrs!&))H X$&& ((  C ''-((K VTUUU WW0" 5 5F f}}****"WW["--GGJ'',1WW[))0S   rQrrrrOptional[dict]ctj|z}|}d}d}tj|krt|} t|d|dd} n6#ttt jf$rtj|YowxYw|dz }|dkrtddd n|d zdkrtd dd | d pi} | d} | dkr|sd}d }| drO| dr:|dkrt| d| d|| ddS| dd} | dvr1|dkrtt d| dStj|tj|k|dkrtt d|dS)zPoll until the user scans the QR code, or timeout/denial. Returns dict with app_id, app_secret, domain, open_id on success. Returns None on failure. Frpollob_app)rrtprz# Fetching configuration results...rTendflushr user_info tenant_brandrm client_idrr)rrrqrr) access_denied expired_tokenz [Feishu onboard] Registration %sNz)[Feishu onboard] Poll timed out after %ds) rrrrrr5rrprintrrr) rrrrqdeadlinecurrent_domaindomain_switched poll_countrrrrrs rO_poll_registrationr2sJy{{Y&HNOJ )++ %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] )++ `A~~  NN> JJJ 4sA0B  B rctdS tj}|||d|ddS#t $rYdSwxYw)zDTry to render a QR code in the terminal. Returns True if successful.NFT)fit)invert) _qrcode_modQRCodeadd_datamake print_asciir)rqrs rO _render_qrrsu   ! ! C D d###t uusAA!! A/.A/rrcTtrt|||St|||S)zVerify 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. )r0_probe_bot_sdk_probe_bot_http)rrrqs rO probe_botrs0 :fj&999 6:v 6 66rQc@|dkrtnt}tj|||tj j  S)z9Build a lark Client for the given credentials and domain.rm) r#r"rmr'rrrrqrrrr)rrrq sdk_domains rO_build_onboard_clientr sk && 0 0mJ   J      4=( ) )  rQrc|ddkrdS|dp*|didpi}|d|ddS) z>Extract bot_name and bot_open_id from a /bot/v3/info response.r rNrrrr)rr)r)rrs rO_parse_bot_responser s xx1t ((5// BTXXfb1155e<< BCGGJ''wwy))  rQc  t|||}|dddd}ttj|jS#t $r&}td|Yd}~dSd}~wwxYw)z#Probe bot info using lark_oapi SDK.GET/open-apis/bot/v3/infoNT)methodrrryz%[Feishu onboard] SDK probe failed: %s) r r$r r5rrurrr)rrrqrrrs rOrrs &vz6BB~~(    #4:dl#;#;<<<  #>??I @ @ @ @ @ @ @ @ @ @ @ @ @ @ @!}}%:;;  4 / / /!9Tj!3!3G! > > > > > > > > > > > > > >#7+++ gx)= > =sCCCtttttsfAE"(:B." E".B22E"5B26E"0E":E< E"E  E"E E"""F*F%%F*initial_domaintimeout_secondsrrc t||S#ttttjf$r&}t d|Yd}~dSd}~wwxYw)aRun the Feishu / Lark scan-to-create QR registration flow. Returns on success:: { "app_id": str, "app_secret": str, "domain": "feishu" | "lark", "open_id": str | None, "bot_name": str | None, "bot_open_id": str | None, } Returns None on expected failures (network, auth denied, timeout). Unexpected errors (bugs, protocol regressions) propagate to the caller. rz([Feishu onboard] Registration failed: %sN)_qr_register_innerrrrr5rrr)rrrs rO qr_registerrsh*!Q`aaaa (GT-A BA3GGGttttts"AAActdddt|t|}tdt|d}t|rtd|n"td|d td tt |d |d t |d ||}|sdSt |d|d|d}|r1|d|d<|d|d<n d|d<d|d<|S)uIRun init → begin → poll → probe. Raises on network/protocol errors.z Connecting to Feishu / Lark...rTrz done.rz8 Scan the QR code above, or open this URL directly: z3 Open this URL in Feishu / Lark on your phone: rzH Tip: pip install qrcode to display a scannable QR code here next timerrr)rrrrqNrrrqrr)rrrrrminrr)rrrrrbot_infos rOrrsi  ,"DAAAA~&&&  / /E (OOO GGG 8_F&Z S6SSTTTT PfPPPQQQ XYYY GGG -(z"eK(/:: F t)6,+?AQRRH%%\\*55z ( ] ; ;}!z $} MrQ)rtrrr)rwr rr)rrrrrr)rrrr)rrrr)Nr)rwr r&rr'rrr)r)rwr r&rr'rrrr)r8r rr)r8r rr)rSr rr) rr rrrrrrrr) rwr rrrrrrrr)rrr~rrr)r~rrr)r8rrr)rrr8rrr)r8rrr)r8r rr)rwr rrrr)r8rrrrr)rrrr)r8r rr)r8r rrrr)rwr )rRr rr)rrrr)rr rr rrr)rqrrr)rrrrgrr)rl)rqrrr)rqrrr) rrrrrrrqrrr)rrrr)rrrrrqrrr)rrrrrqrrr )rrrr)rrrrrr)r __future__rrrrr`r5loggingrkrrrGrr dataclassesrrrpathlibrtypesrtypingr r r r urllib.errorr r urllib.parserurllib.requestrraiohttpr ImportErrorr! lark_oapirmlark_oapi.api.application.v6rrrrrrrrrrrrrrr r!lark_oapi.core.constr"r#5lark_oapi.event.callback.model.p2_card_action_triggerr$r%"lark_oapi.event.dispatcher_handlerr& lark_oapi.wsr'rr0rrgateway.configr(r)gateway.platforms.baser*r+r,r-r.r/r0r1r2gateway.statusr3r4hermes_constantsr5 getLoggerrrcompiler$r]r# _MENTION_REr IGNORECASErrfrgrhrrrfrrrrrr}rrrrrrrrrrrMrrrrrrrrrrhrrj_FEISHU_BOT_MSG_TRACK_SIZErrrrrrrr@rrrrrrQrrrrrrrrrrrrrrrrrrr%r-r0r7rHr?rLrKr<rrrrrrrrrrrrrrrrrrArr.r1r3rrrrrrqrcoderr)rrr r rrrrrKrQrOr>s2 "#"""""    ((((((((!!!!!!,,,,,,,,,,,,,,,,,,,,""""""++++++++NNNG CCCJJJ$BBBBBB @???????JIIIII555555 DL"&!NMKKK(t3"$.33333333                      DCCCCCCC,,,,,,  8 $ $ BJkLBJ9::bj'' L))%2:&UWYWdee GFFWWWMMMUU4R4L4R4T4TUUU%#"('!2"B"B"B       $($'!#$ $%(" #) )")!0&(#!$ $')$$&!&1#(/%   (( %$  '' !(y&&)9::+ , ' (2 +2*3) ('RZ(DEE$"*]33F## , $         $;;;;;;;; $;;;;;;;; $JJJJJJJJ< 5555555 5 9999999 99999::::'''' ####BBBB,9999$6666611111$> , , , ,$    L;L;L;L;^B3N3N3N3NlGGGG*8B#"#"#"#"L@@@@ !!!!&&&&&Rdddd____ 4 4 4 4    ))))    $<'<'<'<'~ L+0L+0L+0L+0L+0'L+0L+0L+0pVPPPPHHHH.      > DDDDDDN     YKKK    7777         F#8&&&&&&sI7 B B BBB! B!%AC..DD/O44 P?P