
    i                   j
   U d Z ddlmZ ddlZddlZddlZddlZddlZddlZddl	Z	ddl
Z
ddlZddlZddlZddlZddlmZ ddlmZmZ ddlmZ ddlmZ ddlmZ dd	lmZmZmZmZmZmZ dd
l m!Z!m"Z" ddl#m$Z$ ddl%m&Z&m'Z' 	 ddl(Z(ddl(m)Z) n# e*$ r dZ(dZ)Y nw xY w	 ddl+Z+n# e*$ r dZ+Y nw xY w	 ddl,Z-ddl.m/Z/ ddl0m1Z1m2Z2m3Z3m4Z4m5Z5m6Z6m7Z7m8Z8m9Z9m:Z:m;Z;m<Z<m=Z=m>Z> ddl?m@Z@mAZA ddlBmCZCmDZD ddlEmFZF ddlGmHZHmIZI ddlJmKZK ddlLmMZN dZOn# e*$ r dZOdZ-dZHdZIdZKdZNdZCdZDY nw xY we+duZPe(duZQddlRmSZSmTZT ddlUmVZVmWZWmXZXmYZYmZZZm[Z[m\Z\m]Z]m^Z^m_Z_ ddl`maZambZb ddlcmdZd ddlemfZf  ejg        eh          Zi ejj        dejk                  Zl ejj        d          Zm ejj        d          Zn ejj        d           Zo ejj        d!          Zp ejj        d"          Zq ejj        d#ejr                  Zsh d$Zth d%Zuh d&Zvd'  e[jw                    D             Zxd(Zyd)Zzd*d+hZ{h d,Z|d-d.d.d/d/d0d0d1Z}d2Z~d3Zd3Zd4Zd5Zd6Zd7Zd8Zd9Zd:Zd;Zd<Zd=Zd>Zd?Zd@ZdAZdBZdCZdDZdEZdFZdGdHdIdJdKZdLedM<   dNdOdPdQdRZdLedS<   dTZ edUdVh          ZdWZdXZdYZdZd[d\Zd]d^d\Zd_Zd`ZdaZdbZdcZddZdeZdfZdgZ ejj        dh          Z ejj        d!          Z edi          Z edj          Z ejj        dk          ZdlZh dmZ edn           G do dp                      Z edn           G dq dr                      Z edn           G ds dt                      Z edn           G du dv                      Z edn           G dw dx                      Z edn           G dy dz                      Ze G d{ d|                      Ze G d} d~                      Zed         ZddZddZddZd dZddZddZddZddZddZddZdddZdddZÐddZĐd	dZddd
dZƐddZǐddZȐddZ	 dddZ	 dddZd e            dddZ̐ddZ͐ddZΐddZϐddZАddZѐddZҐddZӐddZԐddZՐddĄZ֐ddńZאddȄZؐddɄZِdd˄Z	 ddd̄Zېdd΄ZܐddфZݐd dӄZސd!dՄZߐd"dքZd#dڄZd$dۄZ G d܄ deV          Zd%d߄Zd%dZd&dZd'd(dZd'd)dZddd*dZ	 ddlZn# e*ef$ r dZY nw xY wd+dZd,dZd-dZd.dZd,dZd,dZdd>dd/dZd/dZdS (0  u  
Feishu/Lark platform adapter.

Supports:
- WebSocket long connection and Webhook transport
- Direct-message and group @mention-gated text receive/send
- Inbound image/file/audio/media caching
- Gateway allowlist integration via FEISHU_ALLOWED_USERS
- Persistent dedup state across restarts
- Per-chat serial message processing (matches openclaw createChatQueue)
- Processing status reactions: Typing while working, removed on success,
  swapped for CrossMark on failure
- Reaction events routed as synthetic text events (matches openclaw)
- Interactive card button-click events routed as synthetic COMMAND events
- Webhook anomaly tracking (matches openclaw createWebhookAnomalyTracker)
- Verification token validation as second auth layer (matches openclaw)

Feishu identity model
---------------------
Feishu uses three user-ID tiers (official docs:
https://open.feishu.cn/document/home/user-identity-introduction/introduction):

  open_id  (ou_xxx)  — **App-scoped**.  The same person gets a different
                        open_id under each Feishu app.  Always available in
                        event payloads without extra permissions.
  user_id  (u_xxx)   — **Tenant-scoped**.  Stable within a company but
                        requires the ``contact:user.employee_id:readonly``
                        scope.  May not be present.
  union_id (on_xxx)  — **Developer-scoped**.  Same across all apps owned by
                        one developer/ISV.  Best cross-app stable ID.

For bots specifically:

  app_id              — The application's canonical credential identifier.
  bot open_id         — Returned by ``/bot/v3/info``.  This is the bot's own
                        open_id *within its app context* and is what Feishu
                        puts in ``mentions[].id.open_id`` when someone
                        @-mentions the bot.  Used for mention gating only.

In single-bot mode (what Hermes currently supports), open_id works as a
de-facto unique user identifier since there is only one app context.

Session-key participant isolation prefers ``union_id`` (via user_id_alt)
over ``open_id`` (via user_id) so that sessions stay stable if the same
user is seen through different apps in the future.
    )annotationsN)OrderedDict)	dataclassfield)datetime)Path)SimpleNamespace)AnyDictListLiteralOptionalSequence)	HTTPErrorURLError)	urlencode)Requesturlopen)web)GetApplicationRequest)CreateFileRequestCreateFileRequestBodyCreateImageRequestCreateImageRequestBodyCreateMessageRequestCreateMessageRequestBodyGetChatRequestGetMessageRequestGetMessageResourceRequestP2ImMessageMessageReadV1ReplyMessageRequestReplyMessageRequestBodyUpdateMessageRequestUpdateMessageRequestBody)AccessTokenType
HttpMethod)FEISHU_DOMAINLARK_DOMAIN)BaseRequest)CallBackCardP2CardActionTriggerResponse)EventDispatcherHandler)ClientTF)PlatformPlatformConfig)
BasePlatformAdapterMessageEventMessageTypeProcessingOutcome
SendResultSUPPORTED_DOCUMENT_TYPEScache_document_from_bytescache_image_from_urlcache_audio_from_bytescache_image_from_bytes)acquire_scoped_lockrelease_scoped_lock)get_hermes_home)atomic_json_writez(^#{1,6}\s)|(^\s*[-*]\s)|(^\s*\d+\.\s)|(^\s*---+\s*$)|(```)|(`[^`\n]+`)|(\*\*[^*\n].+?\*\*)|(~~[^~\n].+?~~)|(<u>.+?</u>)|(\*[^*\n]+\*)|(\[[^\]]+\]\([^)]+\))|(^>\s)z\[([^\]]+)\]\(([^)]+)\)z^```([^\n`]*)\s*$z^```\s*$z
@_user_\d+z	[ \t]{2,}z,content format of the post type is incorrect>   .bmp.png.webp.gif.jpg.jpeg>   .aac.m4a.mp3.wav.flac.ogg.opus.webm>   .3gp.mkv.avi.m4v.mov.mp4rK   c                    i | ]\  }}||	S  rS   ).0extmimes      =/home/ubuntu/.hermes/hermes-agent/gateway/platforms/feishu.py
<dictcomp>rX      s    UUUysDsUUU    messagestreamrI   rJ   >   rN   rO   rP   rQ   pdfdocxlsppt)z.pdfz.docz.docxz.xlsz.xlsxz.pptz.pptxi     zfeishu-app-idg333333?     g?i   z	127.0.0.1i="  z/feishu/webhookiQ X  i   <   x   i         i`T  i  oncesessionalwaysdeny)approve_onceapprove_sessionapprove_alwaysrk   Dict[str, str]_APPROVAL_CHOICE_MAPzApproved oncezApproved for sessionzApproved permanentlyDenied)rh   ri   rj   rk   _APPROVAL_LABEL_MAPi   i{ i[ Typing	CrossMarki   zhttps://accounts.feishu.cnzhttps://accounts.larksuite.com)feishularkzhttps://open.feishu.cnzhttps://open.larksuite.comz/oauth/v1/app/registration
   z[Rich text message]z[Merged forward message]z[Shared chat]z[Interactive message][Image][Attachment])zh_cnen_usz([\\`*_{}\[\]()#+\-!|>~])u*    	
.,;:!?、，。；：！？()[]{}<>"'`u    	
.!?。！？z\s+)titletextcontentlabelvaluenamesummarysubtitledescriptionplaceholderhint>   tagurlhreflinktypetokenlocalechat_idopen_iduser_idfile_keymsg_typetemplateunion_id	image_keymessage_typeopen_chat_idshare_chat_id)frozenc                  6    e Zd ZU ded<   dZded<   dZded<   dS )FeishuPostMediaRefstrr    	file_namefileresource_typeN)__name__
__module____qualname____annotations__r   r   rS   rY   rW   r   r   3  s=         MMMIMrY   r   c                  H    e Zd ZU dZded<   dZded<   dZded<   dZded<   d	S )
FeishuMentionRefr   r   r   r   Fboolis_allis_selfN)r   r   r   r   r   r   r   r   rS   rY   rW   r   r   :  sR         DNNNNGFGrY   r   c                  B    e Zd ZU dZded<   dZded<   dZded<   d
dZd	S )_FeishuBotIdentityr   r   r   r   r   returnr   c                   |r| j         r|| j         k    S |r| j        r|| j        k    S t          | j                  o
|| j        k    S N)r   r   r   r   )selfr   r   r   s       rW   matchesz_FeishuBotIdentity.matchesH  sZ      	+t| 	+dl** 	+t| 	+dl**DI4449#44rY   N)r   r   r   r   r   r   r   r   )r   r   r   r   r   r   r   r   rS   rY   rW   r   r   B  sY         GGDNNNN5 5 5 5 5 5rY   r   c                  ^    e Zd ZU ded<    ee          Zded<    ee          Zded<   dS )	FeishuPostParseResultr   text_contentdefault_factory	List[str]
image_keysList[FeishuPostMediaRef]
media_refsN)r   r   r   r   r   listr   r   rS   rY   rW   r   r   S  sZ         !E$777J7777+05+F+F+FJFFFFFFrY   r   c                      e Zd ZU ded<   ded<   dZded<    ee          Zded<    ee          Zd	ed
<    ee          Z	ded<   dZ
ded<    ee          Zded<   dS )FeishuNormalizedMessager   raw_typer   r}   preferred_message_typer   r   r   r   r   List[FeishuMentionRef]mentionsplainrelation_kindDict[str, Any]metadataN)r   r   r   r   r   r   r   r   r   r   r   dictr   rS   rY   rW   r   r   Z  s         MMM"(((((!E$777J7777+05+F+F+FJFFFF',uT'B'B'BHBBBB M    $uT:::H::::::rY   r   c                  z   e Zd ZU ded<   ded<   ded<   ded<   ded<   ded<   ded<   d	ed
<   ded<   ded<   ded<   ded<   ded<   ded<   ded<   ded<   ded<   ded<   ded<   ded<   dZded<   dZded<   dZded<   dZded <    e            Z	d	ed!<   d"Z
ded#<    ee$          Zd%ed&<   d'Zded(<   d)Zd*ed+<   dS ),FeishuAdapterSettingsr   app_id
app_secretdomain_nameconnection_modeencrypt_keyverification_tokengroup_policyzfrozenset[str]allowed_group_usersbot_open_idbot_user_idbot_nameintdedup_cache_sizefloattext_batch_delay_secondstext_batch_split_delay_secondstext_batch_max_messagestext_batch_max_charsmedia_batch_delay_secondswebhook_hostwebhook_portwebhook_pathrf   ws_reconnect_noncere   ws_reconnect_intervalNOptional[int]ws_ping_intervalws_ping_timeoutadminsr   default_group_policyr   zDict[str, FeishuGroupRule]group_rulesnone
allow_botsTr   require_mention)r   r   r   r   r   r   r   r   	frozensetr   r   r   r   r   r   r   rS   rY   rW   r   r   f  s        KKKOOO'''' MMM####))))    $$$$     !$$$$$&*****%)O))))&Y[[F(((( """"".3eD.I.I.IKIIIIJ O      rY   r   c                  p    e Zd ZU dZded<    ee          Zded<    ee          Zded<   dZ	d	ed
<   dS )FeishuGroupRulezLPer-group policy rule for controlling which users may interact with the bot.r   policyr   set[str]	allowlist	blacklistNzOptional[bool]r   )
r   r   r   __doc__r   r   setr   r   r   rS   rY   rW   r   r     sn         VVKKK%444I4444%444I4444&*O******rY   r   c                  v    e Zd ZU  ee          Zded<    ee          Zded<    ee          Zded<   dS )	FeishuBatchStater   zDict[str, MessageEvent]eventsDict[str, asyncio.Task]taskszDict[str, int]countsN)	r   r   r   r   r   r   r   r   r   rS   rY   rW   r   r     sl         &+eD&A&A&AFAAAA%*U4%@%@%@E@@@@"U4888F888888rY   r   )	self_echoself_ids_unknownbots_disabledbot_not_mentionedgroup_policy_rejectedsenderr
   r   r   c                (    t          | dd          dv S )Nsender_typer   )botapp)getattr)r   s    rW   _is_bot_senderr    s    6="--??rY   r   c           
         t          | dd           }|t                      S t          d t          |dd           t          |dd           t          |dd           fD                       S )N	sender_idc              3     K   | ]}||V  	d S r   rS   rT   vs     rW   	<genexpr>z#_sender_identity.<locals>.<genexpr>  s>        
 	     rY   r   r   r   )r  r   )r   sids     rW   _sender_identityr    s    
&+t
,
,C
{{{  CD))CD))CT**
     rY   r}   r   c                8    t                               d|           S )Nz\\\1)_MARKDOWN_SPECIAL_CHARS_REsub)r}   s    rW   _escape_markdown_textr    s    %))'4888rY   r   c                "    | du p| dk    p| dk    S )NT   truerS   r   s    rW   _to_booleanr    s    D=9EQJ9%6/9rY   styleDict[str, Any] | Nonekeyc                N    | sdS t          |                     |                    S NF)r  get)r  r  s     rW   _is_style_enabledr    s'     uuyy~~&&&rY   c                    t          dgd t          j        d|           D                       }d|dz   z  }|                     d          s|                     d          rd|  dn| }| | | S )Nr   c                ,    g | ]}t          |          S rS   )len)rT   runs     rW   
<listcomp>z%_wrap_inline_code.<locals>.<listcomp>  s    DDDSCDDDrY   z`+`r   )maxrefindall
startswithendswith)r}   max_runfencebodys       rW   _wrap_inline_coder+    s    1EDDBJud,C,CDDDEFFG7Q;E//#..N$--2D2DN;t;;;;$D"T"5"""rY   languagec                z    |                                                      dd                              dd          S )N
r"  )stripreplace)r,  s    rW   _sanitize_fence_languager2    s2    >>##D#..66tSAAArY   elementr   c                   t          |                     dd          pd          }|                     d          }t          |t                    r|nd }t	          |d          rt          |          S t          |          }|sdS t	          |d          rd| d}t	          |d          rd| d}t	          |d	          rd
| d}t	          |d          rd| d}|S )Nr}   r   r  codeboldz**italic*	underlinez<u>z</u>strikethroughz~~)r   r  
isinstancer   r  r+  r  )r3  r}   r  
style_dictrendereds        rW   _render_text_elementr>    s   w{{62&&,"--DKK  E$UD11;tJV,, ' &&&$T**H rV,, %$$$$X.. #"x???[11 (''''_55 %$$$$OrY   c                   t          t          |                     dd          pd          p$t          |                     dd          pd                    }t          |                     dd          pd          p$t          |                     dd          pd                              dd          }|                    d          rdnd}d| d| | dS )	Nr,  r   langr}   r~   
r.  ```)r2  r   r  r1  r'  )r3  r,  r5  trailing_newlines       rW   _render_code_block_elementrD    s    'GKK
B''-2..T#gkk&"6M6M6SQS2T2T H 	GKK##)r**Sc'++i2L2L2RPR.S.Sgfd 	 "]]400:rrd888T8#38888rY   c                l   ddl m} |                     dd          }t                              d |          }t          j        dd|t
          j                  }t          j        d	d
|t
          j                  }t          j        dd|          }t          j        dd|          } ||          }|S )a  Strip 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_markdownrA  r.  c                    |                      d           d|                      d                                           dS )Nr  z (   ))groupr0  )ms    rW   <lambda>z/_strip_markdown_to_plain_text.<locals>.<lambda>  s7    qwwqzz,R,RQWWQZZ=M=M=O=O,R,R,R rY   z^>\s?r   )flagsz^\s*---+\s*$z---z~~([^~\n]+)~~z\1z<u>([\s\S]*?)</u>)gateway.platforms.helpersrF  r1  _MARKDOWN_LINK_REr  r$  	MULTILINE)r}   rF  r   s      rW   _strip_markdown_to_plain_textrQ    s     988888LL&&E!!"R"RTYZZEF8Rbl;;;EF?E5EEEEF#UE22EF'66EN5!!ELrY   defaultr   	min_valuer   c                j    	 t          |           }n# t          t          f$ r |cY S w xY w||k    r|n|S )zACoerce value to int with optional default and minimum constraint.)r   	TypeError
ValueErrorr   rR  rS  parseds       rW   _coerce_intrY    sQ    Uz"   y((66g5s    ((c                2    t          | ||          }||n|S )NrR  rS  )rY  rW  s       rW   _coerce_required_intr\    s$    9EEEFn77&0rY   r~   c                T    t          |           }t          j        dd|iid          S Nrz   r~   Fensure_ascii)_build_markdown_post_rowsjsondumps)r~   rowss     rW   _build_markdown_post_payloadre  "  s?    $W--D:4	

    rY   List[List[Dict[str, str]]]c                   | sdddggS d| vrd| dggS g g d}d	fd}|                                  D ]}|                                }t          |rt                              |          nt
                              |                    }|r1|s
 |                                 |           | }|s
 |                                 |            |             pd| dggS )
aF  Build 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.
    mdr   r   r}   rB  Fr   Nonec                     sd S d                               } |                                 r                    d| dg           g d S )Nr.  rh  ri  )joinr0  append)segmentcurrentrd  s    rW   _flush_currentz1_build_markdown_post_rows.<locals>._flush_current?  sW     	F))G$$==?? 	:KKw778999rY   r   rj  )
splitlinesr0  r   _MARKDOWN_FENCE_CLOSE_REmatch_MARKDOWN_FENCE_OPEN_RErm  )r~   in_code_blockrp  raw_linestripped_lineis_fencero  rd  s         @@rW   ra  ra  .  sj     -r**+,,Gw//011')DGM       &&(( ! ! ((>$**=999(..}==
 
  	  !   NN8$$$ --M  !   x    N5T733455rY   mentions_mappayloadr{  %Optional[Dict[str, FeishuMentionRef]]c               ~   t          |           }|st          t                    S g g g }t          t	          |                    dd                                                              }|r|                    |           |                    dg           pg D ]_}t          |t                    st          d
                    fd|D                                 }|r|                    |           `t          d
                    |                                          pt                    S )N)r   r|   r   r~   c              3  <   K   | ]}t          |          V  d S r   )_render_post_element)rT   itemr   r   r{  s     rW   r	  z,parse_feishu_post_payload.<locals>.<genexpr>t  sE         %T:z<PP     rY   r.  )r   r   r   )_resolve_post_payloadr   FALLBACK_POST_TEXT_normalize_feishu_textr   r  r0  rm  r;  r   rl  )	r|  r{  resolvedpartsr|   rowrow_textr   r   s	    `     @@rW   parse_feishu_post_payloadr  _  si   
 %W--H F$2DEEEEJ+-JE"3x||GR'@'@#A#A#G#G#I#IJJE U||Ir**0b 
# 
##t$$ 	)GG          
 
  	#LL""" YYu%%++--C1C   rY   c                    t          |           }|r|S t          | t                    si S |                     d          }t	          |          }|r|S t	          |           S )Npost)_to_post_payloadr;  r   r  _resolve_locale_payload)r|  directwrappedwrapped_directs       rW   r  r    sm    g&&F gt$$ 	kk&!!G,W55N "7+++rY   c                   t          |           }|r|S t          | t                    si S t          D ]*}t          |                     |                    }|r|c S +|                                 D ]}t          |          }|r|c S i S r   )r  r;  r   _PREFERRED_LOCALESr  values)r|  r  r  	candidater   s        rW   r  r    s    g&&F gt$$ 	!  $W[[%5%566	 		!!  $U++	 		IrY   r  c                    t          | t                    si S |                     d          }t          |t                    si S t	          |                     dd          pd          |dS )Nr~   r|   r   )r|   r~   )r;  r   r  r   r   )r  r~   s     rW   r  r    sq    i&& 	mmI&&Ggt$$ 	Y]]7B//5266  rY   r   r   r   r   c                ^
   t          | t                    r| S t          | t                    sdS t          |                     dd                                                                                    }|dk    rt          |           S |dk    rt          |                     dd                                                    }t          |                     d|          pd                                          }|sdS t          |          }|r	d| d| dn|S |d	k    rt          |                     d
d                                                    }|dk    r|d|vrt          d          |d<   dS |pi                     |          }	|	|	j	        p|	j
        pd}
n7t          |                     dd                                                    pd}
dt          |
           S |dv rt          |                     dd                                                    }|r||vr|                    |           t          |                     dd                                                    p4t          |                     dd                                                    }|rd| dndS |dv rt          |                     dd                                                    }t          |                     dd                                                    pit          |                     dd                                                    p4t          |                     dd                                                    }|r+|                    t          |||dv r|nd                     |rd| dnd S |d!v rt          |                     dd                                                    p4t          |                     d"d                                                    }|rd#t          |           d#nd$S |d%k    rd&S |d'v rd(S |d)k    r]t          |                     dd          pd          p$t          |                     d*d          pd          }|rt          |          ndS |d+v rt          |           S g }d,D ]>}t          |                     |          |||          }|r|                    |           ?d-                    d. |D                       S )/Nr   r   r}   ar   [z](rI  atr   @_allTr   @alluser	user_name@>   imgimager   altz[Image: ]rx   >   r   audiomediavideor   r   r|   >   r  r  r   r   r   r   [Attachment: ry   >   emojiemotion
emoji_type:z[Emoji]brr.  >   hrdividerz

---

r5  r~   >   pre
code_block)r}   r|   r~   childrenelementsr"  c              3     K   | ]}||V  	d S r   rS   )rT   parts     rW   r	  z'_render_post_element.<locals>.<genexpr>  s'      ::TT:D::::::rY   )r;  r   r   r  r0  lowerr>  r  r   r   r   rm  r   r+  rD  _render_nested_postrl  )r3  r   r   r{  r   r   r   escaped_labelr   refdisplay_namer   r  r   r   r5  nested_partsr  	extracteds                      rW   r  r    sa    '3 gt$$ r
gkk%$$
%
%
+
+
-
-
3
3
5
5C
f}}#G,,,
czz7;;vr**++1133GKK--344::<< 	2-e44/3F+=++D++++F
d{{ '++i4455;;=='!! 'G<,G,G(8(E(E(EW%6!r&&{33?8<s{<fLLw{{;;;<<BBDDNL8(66888
K4455;;==	 	)*44i((('++fb))**0022Yc'++eR:P:P6Q6Q6W6W6Y6Y$'6 #    Y6
111w{{:r223399;;K,,--3355 47;;w++,,224447;;vr**++1133 	
  	"%'),0B)B)B##     09L+y++++nL
"""GKK++,,2244bGKKVX<Y<Y8Z8Z8`8`8b8b6;J2(//2222J
d{{t
}
f}}7;;vr**0b11ZSYPR9S9S9YWY5Z5Z*.6 &&&B6
###)'222 LC + +'C(8(8*jR^__	 	+	***88::\::::::rY   c                   t          | t                    rt          |           S t          | t                    r#d                    fd| D                       S t          | t
                    rKt          |           }|r|S d                    fd|                                 D                       S dS )Nr"  c              3  D   K   | ]}t          |          }||V  d S r   r  rT   r  r  r   r   r{  s      rW   r	  z&_render_nested_post.<locals>.<genexpr>  P       
 
,T:z<XX	

 
 
 
 
 
rY   c              3  D   K   | ]}t          |          }||V  d S r   r  r  s      rW   r	  z&_render_nested_post.<locals>.<genexpr>  r  rY   r   )r;  r   r  r   rl  r   r  r  )r   r   r   r{  r  s    ``` rW   r  r    s    % ,$U+++% 
xx 
 
 
 
 
 

 
 
 
 
 	
 % 	
%eZ\RR 	Mxx 
 
 
 
 
 

 
 
 
 
 	
 2rY   )r   r   r   raw_contentr   Optional[Sequence[Any]]r   c           
        t          | pd                                                                          }t          |          }t	          ||          }|dk    rt          |                    dd          pd          }d|v rd|vrt          d          |d<   t          |t          ||          t          |
                                                    S |dk    rnt          ||          }t          ||j        t          |j                  t          |j                  t          |
                                          d	          S t          |
                                          }	|d
k    rt          |                    dd          pd                                          }
t          t          |                    dd          pd          p+t          |                    dd          pd          pt          |          }t          ||t          k    r|ndd|
r|
gng d
|	          S |dv rOt!          ||          }t#          |j                  }t          |d|dk    rdnd|j        r|gng |d|i|	          S |dk    rt)          |          S |dk    rt+          |          S |dv rt-          ||          S t          |d          S )Nr   r}   r  Tr  )r   r   r   r  rz  )r   r   r   r   r   r   r  r   r  photo)r   r   r   r   r   r   >   r   r  r  )r   r  documentplaceholder_text)r   r   r   r   r   r   r   merge_forward
share_chat>   cardinteractive)r   r   )r   r0  r  _load_feishu_payload_build_mentions_mapr  r   r   r  r   r  r  r   r   r   FALLBACK_IMAGE_TEXT_build_media_ref_from_payload_attachment_placeholderr   r    _normalize_merge_forward_message_normalize_share_chat_message_normalize_interactive_message)r   r  r   r   normalized_typer|  r{  r}   parsed_postmention_refsr   alt_text	media_refr   s                 rW   normalize_feishu_messager     s&    ,,"--3355;;==O";//G&x55L&  7;;vr**0b11 d??wl::$4D$A$A$AL!&$/lCC,--//00
 
 
 	

 &   0lSSS&$$1K233K233,--//00 
 
 
 	
 ++--..L'!!K44:;;AACC	)FB''-2.. #7;;ub))/R00#"	
 
 '$%-1D%D%D"#*&/7	{{R!!
 
 
 	
 4441'YYY	-i.ABB&$.=.H.H77j&/&8@	{{b)(+6!
 
 
 	
 /))/888,&&,W555111-owGGG"O"MMMMrY   c                    	 | rt          j        |           ni }n# t           j        $ r d| icY S w xY wt          |t                    r|nd|iS )Nr}   r~   )rb  loadsJSONDecodeErrorr;  r   )r  rX  s     rW   r  r  i  so    %,7?K(((R % % %$$$$%--F66Iv3FFs    11c           	        t          |                     d          |                     d          |                     d          t          | d                    }t          |           }g }|r|                    |           |                    |d d                    d                    |                                          pt          }t          d|dt          |          |d	
          S )Nr|   r   preview)r|   r   r  r   keysra   r.  r  )entry_countr|   r   r   r   r   )_first_non_empty_textr  _find_first_text_collect_forward_entriesrm  extendrl  r0  FALLBACK_FORWARD_TEXTr   r  )r|  r|   entrieslinesr   s        rW   r  r  q  s    !GII'UVVV	 E 'w//GE U	LL!99U##))++D/DL" !%!$W>>	   rY   c           	     B   t          |                     d          |                     d          |                     d          t          | d                    }t          |                     d          |                     d          |                     d                    }g }|r|                    d	|            n|                    t                     |r|                    d
|            d                    |          }t          d|d||d          S )N	chat_namer   r|   )r  r   r|   r  r   r   r   zShared chat: z	Chat ID: r.  r  )r   r  r  )r  r  r  rm  FALLBACK_SHARE_CHAT_TEXTrl  r   )r|  r  share_idr  r   s        rW   r  r    s,   %K  FG'EFFF	 I %IN##O$$ H
 E /0Y001111-... -+++,,,99U##L"!"%I>>	   rY   c                   t          |                    d          t                    r|                    d          n|}t          t	          |          |                    d          t          |d                    }t          |          }t          |          }g }|r|                    |           |D ]}||k    r|                    |           |r+|                    dd	                    |                      d	                    |d d                   
                                pt          }t          | |d	||d
          S )Nr  r|   )r|   r   r   r  z	Actions: , r.     r  )r|   actionsr  )r;  r  r   r  _find_header_titler  _collect_card_lines_collect_action_labelsrm  rl  r0  FALLBACK_INTERACTIVE_TEXTr   )	r   r|  card_payloadr|   
body_linesr  r  liner   s	            rW   r  r    sY   *4W[[5H5H$*O*O\7;;v&&&U\L!<((G,LMMM E
 %\22J$\22GE U  5==LL 757!3!35566699U3B3Z((..00M4ML"!# W55	   rY   c                   g }dD ]A}|                      |          }t          |t                    r|                    |           Bg }|D ]}t          |t                    s9t          t          |pd                    }|r|                    d|            Qt          |                     d          |                     d          |                     d          |                     d                    }t          |                     dd          p|                     d	d                    	                                
                                }|d
k    r*t          |                     d          p|          j        }	nnt          |                     d          |                     d          |                     d          |                     d          t          |d                    }	t          |	          }	|r|	r|                    d| d|	            |	r|                    d|	            t          |          S )N)messagesitemsmessage_listrecordsr~   r   z- sender_namer  r   r   r   r   r  r~   r}   r   r  )r}   r~   r   r  r|   r  z: )r  r;  r   r  r   r  r   rm  r  r0  r  r  r   r  _unique_lines)
r|  
candidatesr  r   r  r  r}   r   nested_typer*  s
             rW   r  r    s>   JJ % %C  eT"" 	%e$$$G ( ($%% 	)#djb//::D ,{D{{+++&HH]##HH[!!HHXHHV	
 
 $((>266R$((:r:R:RSSYY[[aacc&  ,TXXi-@-@-HDIIVDD(  ###### ,^___ D &d++ 	(d 	(NN000$001111 	(NN;;;'''!!!rY   c                n    t          | d          }d |D             }t          d |D                       S )NFin_rich_blockc                ,    g | ]}t          |          S rS   )r  rT   r  s     rW   r   z'_collect_card_lines.<locals>.<listcomp>  s!    AAA4(..AAArY   c                    g | ]}||S rS   rS   r  s     rW   r   z'_collect_card_lines.<locals>.<listcomp>  s    >>>4>$>>>rY   )_collect_text_segmentsr   )r|  r  
normalizeds      rW   r  r    sD    "7%@@@EAA5AAAJ>>:>>>???rY   c           
        g }t          |           D ]}t          |t                    st          |                    dd          p|                    dd                                                                                    }|dvrzt          |                    d          |                    d          |                    d          t          |d	                    }|r|	                    |           t          |          S )
Nr   r   r   >   buttonpickeroverflowdate_pickerselect_staticr}   r   r   )r}   r~   r   r   r  )_walk_nodesr;  r   r   r  r0  r  r  r  rm  r   )r|  labelsr  r   r   s        rW   r  r    s    FG$$ ! !$%% 	$((5"%%=&")=)=>>DDFFLLNNVVV%HHVHHVHHWT(LMMM	
 
  	!MM%      rY   r  c                  t          | t                    r|rt          |           gng S t          | t                    r-g }| D ]&}|                    t          ||                     '|S t          | t                    sg S t          |                     dd          p|                     dd                                                    	                                }|p|dv }g }t          D ]T}|                     |          }t          |t                    r(|r&t          |          }|r|                    |           U|                                 D ]3\  }}|t          v r|                    t          ||                     4|S )Nr  r   r   r   >   divnoteactionr  columnlark_mdmarkdown
column_set
plain_textr  r  )r;  r   r  r   r  r	  r   r  r0  r  _SUPPORTED_CARD_TEXT_KEYSrm  r  _SKIP_TEXT_KEYS)r   r  segmentsr  r   next_in_rich_blockr  r
  s           rW   r	  r	    s   % H2?G&u--..RG%   	W 	WDOO24}UUUVVVVeT"" 	
eiir"";eii&;&;
<
<
B
B
D
D
J
J
L
LC& # 2 + H( , ,yy~~dC   	,%7 	,/55J ,
+++[[]] X X	T/!!.tCUVVVWWWWOrY   r   c               8   t          |                     dd          pd                                          }t          |                     d          |                     d          |                     d                    }|dv r|nd}t	          |||          S )	Nr   r   r   r|   r}   >   r  r  r   r  )r   r  r0  r  r   )r|  r   r   r   effective_types        rW   r  r  +  s    7;;z2..4"55;;==H%K  GF I
 '47I&I&I]]vNx9TbccccrY   r   c                >    t          |           }|rd| dnt          S )Nr  r  )r  FALLBACK_ATTACHMENT_TEXT)r   normalized_names     rW   r  r  6  s,    ,Y77O1@^-?----F^^rY   c                   t          | t                    sdS |                     d          }t          |t                    sdS |                    d          }t          |t                    rJt          |                    d          |                    d          |                    d                    S t	          t          |pd                    S )Nr   headerr|   r~   r}   r   )r;  r   r  r  r  r   )r|  r&  r|   s      rW   r  r  ;  s    gt$$ r[[""Ffd## rJJwE% a$UYYy%9%9599V;L;LeiiX^N_N_```!#ekr"2"2333rY   r  tuple[str, ...]c                   t          |           D ]^}t          |t                    s|D ]C}|                    |          }t          |t                    rt          |          }|r|c c S D_dS Nr   )r  r;  r   r  r   r  )r|  r  noder  r   r
  s         rW   r  r  G  s    G$$ & &$%% 	 	& 	&CHHSMME%%% &3E::
 &%%%%%%	& 2rY   c              #     K   t          | t                    r2| V  |                                 D ]}t          |          E d {V  d S t          | t                    r| D ]}t          |          E d {V  d S d S r   )r;  r   r  r  r   )r   r  s     rW   r  r  T  s      % )LLNN 	) 	)D"4((((((((((	) 	)	E4	 	  ) 	) 	)D"4(((((((((() )	) 	)rY   r  c                     | D ]m}t          |t                    rt          |          }|r|c S -|>t          |t          t          f          s"t          t          |                    }|r|c S ndS r)  )r;  r   r  r   r   )r  r   r
  s      rW   r  r  ^  s     " "eS!! 	"/66J "!!!!"z%$'F'F/E

;;J "!!!!2rY   c                   dfd}t                               || pd          }|                    dd          }|                    d	d
                              dd
          }d
                    d |                    d
          D                       }d
                    d |                    d
          D                       }t
                              d|          }|                                S )Nrt  're.Match[str]'r   r   c                    |                      d          }pi                     |          }|dS |j        p|j        pd}d| S )Nr   r"  r  r  )rJ  r  r   r   )rt  r  r  r   r{  s       rW   _subz$_normalize_feishu_text.<locals>._subt  sS    kk!nn!r&&s++;3x03;0&4zzrY   r   r  r  rA  r.  r/  c              3  p   K   | ]1}t                               d |                                          V  2dS )r"  N)_WHITESPACE_REr  r0  r  s     rW   r	  z)_normalize_feishu_text.<locals>.<genexpr>  s>      ^^$**355;;==^^^^^^rY   c              3     K   | ]}||V  	d S r   rS   r  s     rW   r	  z)_normalize_feishu_text.<locals>.<genexpr>  s'      EEEEEEEEErY   r"  )rt  r.  r   r   )_MENTION_PLACEHOLDER_REr  r1  rl  split_MULTISPACE_REr0  )r}   r{  r0  cleaneds    `  rW   r  r  p  s          &))$
;;Googv..Goofd++33D$??Gii^^'--X\J]J]^^^^^GiiEEt)<)<EEEEEG  g..G==??rY   r  c                    t                      }g }| D ]3}|r||v r	|                    |           |                    |           4|S r   )r   addrm  )r  seenuniquer  s       rW   r   r     s[    UUDF   	tt||dMrY   mentiontuple[str, str]c                f   t          | dd           }t          |t                    rHt          t          | dd          pd                                          }|dk    r|dfS |dk    rd|fS dS |dS t          t          |dd          pd          t          t          |dd          pd          fS )Nidid_typer   r   r   r   r   )r  r;  r   r  )r<  
mention_idr@  s      rW   _extract_mention_idsrC    s     $--J*c"" ggy"55;<<BBDDir>!iz>!vvGJ	2..4"55GJ	2..4"55 rY   Dict[str, FeishuMentionRef]c           
     p   i }| pg D ]}t          t          |dd          pd          }|s%|dk    rt          d          ||<   ?t          |          \  }}t          t          |dd          pd                                          }t          |||                    |||                    ||<   |S )	Nr  r   r  Tr  r   r   r   r   )r   r   r   )r   r  r   rC  r0  r   )r   r   resultr<  r  r   r   r   s           rW   r  r    s     +-F>r 
 
''5"--344 	'>>*$777F3K/8877FB//5266<<>>&KKtKLL
 
 
s
 MrY   Sequence[FeishuMentionRef]c                   g }t                      }| D ]}|j        r
|j        |j        |j        f}||v r#|                    |           |j        r|                    d           U|j        r(|                    |j        pd d|j         d           |                    |j        pd           |rdd                    |           dndS )	Nr  unknownz
 (open_id=rI  z[Mentioned: r  r  r   )r   r   r   r   r   r9  rm  rl  )r   r  r:  r  	signatures        rW   _build_mention_hintrL    s    ED 0 0; 	Zch7	: 	0LL    [ 	0LLCH1	KKS[KKKLLLLLL.Y////16>-$))E**----B>rY   c                T   | s| S d |D             }|s| S |                                  }	 |D ]V}|                    |          s|t          |          d          }|r|d         t          vrA|                                 } nn[	 t          |          }|dk    r/||dz
           t          v r|dz  }|dk    r||dz
           t          v |d |         }||d          }|D ]F}|                    |          r/|d t          |                                                    |z   } nG|S )Nc                B    g | ]}|j         	d |j        p|j        pd S )r  r  )r   r   r   )rT   r  s     rW   r   z-_strip_edge_self_mentions.<locals>.<listcomp>  sF       ;/CH--v//  rY   Tr   r  )lstripr&  r  _MENTION_BOUNDARY_CHARS_TRAILING_TERMINAL_PUNCTr'  rstrip)	r}   r   
self_names	remainingnmafterir*  tails	            rW   _strip_edge_self_mentionsrY    s        J
  I
 		 		B''++ c"gghh'E q)@@@IE
	NN!ee	!a%(,DDDFA !ee	!a%(,DDD!}} 	 	B}}R    CGG8,3355<	 rY   	ws_clientadapterrj  c           	        	
 ddl mc m} t          j                    }t          j        |           ||_        |_        |j        j	        
t           dd          	d fdd
fd
}d	fd}||j        _	        	t           d|                         	                                   n# t          $ r Y nw xY w
|j        _	        	t           d	           d t          j        |          D             }|D ]}|                                 |r$|                    t          j        |ddi           	 |                                 n# t          $ r Y nw xY w	 |                                 n# t          $ r Y nw xY wd_        dS # 
|j        _	        	t           d	           d t          j        |          D             }|D ]}|                                 |r$|                    t          j        |ddi           	 |                                 n# t          $ r Y nw xY w	 |                                 n# t          $ r Y nw xY wd_        w xY w)zCRun the official Lark WS client in its own thread-local event loop.r   N
_configurer   rj  c                     	 t          d j                   t          d j                    j        t          d j                   d S d S # t          $ r  t
                              dd           Y d S w xY w)N_reconnect_nonce_reconnect_interval_ping_intervalz4[Feishu] Failed to apply websocket runtime overridesTexc_info)setattr_ws_reconnect_nonce_ws_reconnect_interval_ws_ping_interval	Exceptionloggerdebug)r[  rZ  s   rW   _apply_runtime_ws_overrideszC_run_official_feishu_ws_client.<locals>._apply_runtime_ws_overrides  s    	`I173NOOOI4g6TUUU(4	#3W5NOOOOO 54 	` 	` 	`LLOZ^L______	`s   A	A &A:9A:argsr
   kwargsc                 x   K   j         d|vr
j         |d<   j        d|vr
j        |d<    | i | d {V S )Nping_intervalping_timeout)rg  _ws_ping_timeout)rl  rm  r[  original_connects     rW   _connect_with_overridesz?_run_official_feishu_ws_client.<locals>._connect_with_overrides  so      $0_F5R5R&-&?F?##/N&4P4P%,%=F>"%%t6v666666666rY   confc                T    t          d           |           }              |S )NzFFeishu _configure_with_overrides called but original_configure is None)RuntimeError)rt  rG  rk  original_configures     rW   _configure_with_overrideszA_run_official_feishu_ws_client.<locals>._configure_with_overrides  s<    %ghhh##D))##%%%rY   c                :    g | ]}|                                 |S rS   donerT   ts     rW   r   z2_run_official_feishu_ws_client.<locals>.<listcomp>.  s%    FFFQVVXXF1FFFrY   return_exceptionsTrq  )rl  r
   rm  r
   r   r
   )rt  r
   r   r
   )lark_oapi.ws.clientwsclientasyncionew_event_loopset_event_looploop_ws_thread_loop
websocketsconnectr  rd  startrh  	all_taskscancelrun_until_completegatherstopclose)rZ  r[  ws_client_moduler  rs  rx  pendingtaskrk  rw  rr  s   ``      @@@rW   _run_official_feishu_ws_clientr    s`   222222222!##D4    "G'2: L$??` ` ` ` ` ` `7 7 7 7 7 7 7       +B'%	<)BCCC!!!'    /?#+)I|-?@@@FFg/55FFF 	 	DKKMMMM 	V##GNG$Tt$T$TUUU	IIKKKK 	 	 	D		JJLLLL 	 	 	D	"&! /?#+)I|-?@@@FFg/55FFF 	 	DKKMMMM 	V##GNG$Tt$T$TUUU	IIKKKK 	 	 	D		JJLLLL 	 	 	D	"&&&&&s    B5 4F 5
C?F CF E 
E$#E$(E= =
F
	F
A=I'H)(I')
H63I'5H66I':II'
II'II'c                     t           S )z0Check if Feishu/Lark dependencies are available.)FEISHU_AVAILABLErS   rY   rW   check_feishu_requirementsr  >  s    rY   c                      e Zd ZdZdZdZd fdZedd            Zd dZ	d!dZ
d"dZd#dZd$dZd#dZd#dZd#dZ	 	 d%d&d#Zd$d%d'd(Z	 	 d(d)d-Zed*d0            Z	 	 	 d+d,d3Z	 	 	 	 d-d.d6Z	 	 	 d+d/d8Z	 	 	 d+d0d:Zd1d2d;Z	 	 	 d+d3 fd=Z	 	 	 d+d4 fd?Zd5d@Zd6dAZd7dCZd8dDZd#dEZ d7dFZ!d9dHZ"d7dIZ#d7dJZ$d7dKZ%d7dLZ&d7dMZ'd:dOZ(d;dPZ)ed<dR            Z*d=dTZ+d>dWZ,d?dYZ-d:dZZ.d@d\Z/d7d]Z0dAd_Z1dBdaZ2d"dbZ3dCddZ4dDdfZ5dEdgZ6dFdhZ7dBdiZ8dGdlZ9dHdoZ:dIdpZ;d$dqdJdvZ<dBdwZ=dKdxZ>dLdyZ?edMd|            Z@dBd}ZAdNdZBdNdZCdNdZDdOdZEdPdZFedQd            ZGedRd            ZHedSd            ZIdTdZJdUdZKdVdZLdLdZMedMd            ZNdBdZOdNdZPedWd            ZQdNdZRdNdZSdXdZTdYdZUedZd            ZVd[dZWd\dZXd]dZYd^dZZed_d            Z[ed`d            Z\edad            Z]edbd            Z^edcd            Z_eddd            Z`edcd            ZaededÄ            ZbedfdƄ            Zcd$dqdgdȄZddhdɄZed$dqdidʄZfdjd̈́ZgdFd΄ZhddϜdkdԄZiedldք            Zjedmd؄            ZkdndۄZldod܄Zm	 dpd$dqdqdބZndrd߄ZodsdZpdtdZqdudZrd#dZsd#dZtd#dZudvdZvdwdZwdddddxdZxdydZyedzd            Zzed{d            Z{ddd|dZ|d}dZ}d#dZ~d#dZd#dZd~dZdydZd#dZedd             Zedd            Zedd            Zedd            Zedd            Zedd
            Zedd            Zedd            Zedd            Zedd            Zedd            Zedd            Zedd            Zedd            Zd6dZddZedd            Z xZS (  FeishuAdapterzFeishu/Lark bot adapter.i@  rb   configr/   c                (   t                                          |t          j                   |                     |j        pi           | _        |                     | j                   d | _        d | _	        d | _
        d | _        d | _        d | _        d | _        d | _        i | _        g | _        t%                      dz  | _        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 | _0        tc          j2        d          | _3        ti                      | _5        | 6                                 d S )Nzfeishu_seen_message_ids.jsonFi  r  )7super__init__r.   FEISHU_load_settingsextra	_settings_apply_settings_client
_ws_client
_ws_futurer  _loop_webhook_runner_webhook_site_event_handler_seen_message_ids_seen_message_orderr<   _dedup_state_path	threadingLock_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	itertoolscount_approval_counterr   _pending_processing_reactions_load_seen_message_ids)r   r  	__class__s     rW   r  zFeishuAdapter.__init__P  s   111,,V\-?R@@T^,,,&*)-48DH:>
.2,0-135.0 !0!2!25S!S$>++@BBD!JL$57  35$%.^%5%5"(-%*.'469;&13#;==? 15!1!3!3%)%;%B")-)?)E&*.*@*G'"2"4"4&*&=&D#*.*A*G':<!*!3!3 GRmm*##%%%%%rY   r  r   r   r   c                   |                      di           }i }t          |t                    r|                                D ]\  }}t          |t                    sd }d|v r"t	          |                     d                    }t          t          |                     dd                                                                                    t          d |                     dg           D                       t          d |                     dg           D                       |	          |t          |          <   |                      d
g           }t          d |D                       }t          |                      dd                                                                                    }t          j        dd                                                                          }	|	dvrt                              d|	           d}	t          dMi dt          |                      d          pt          j        dd                                                    dt          |                      d          pt          j        dd                                                    dt          |                      d          pt          j        dd                                                                                    dt          |                      d          pt          j        dd                                                                                    dt          j        dd                                          dt          j        d d                                          d!t          j        d"d                                                                          d#t          d$ t          j        d%d                              d&          D                       d't          j        d(d                                          d)t          j        d*d                                          d+t          j        d,d                                          d-t#          d.t%          t          j        d/t          t&                                                  d0t)          t          j        d1t          t*                                        d2t)          t          j        d3d4                    d5t#          d6t%          t          j        d7t          t,                                                  d8t#          d6t%          t          j        d9t          t.                                                  d:t)          t          j        d;t          t0                                        d<t          |                      d<          pt          j        d=t2                                                              d>t%          |                      d>          p&t          j        d?t          t4                                        d@t          |                      d@          pt          j        dAt6                                                              pt6          dBt9          |                      dB          dCdDE          dFt9          |                      dF          dGd6E          dHt;          |                      dH          d d6E          dIt;          |                      dI          d d6E          d
|d|d|dJ|	dt	          |                      dt          j        dKdL                              S )NNr   r   r   openc              3     K   | ]F}t          |                                          #t          |                                          V  Gd S r   r   r0  rT   us     rW   r	  z/FeishuAdapter._load_settings.<locals>.<genexpr>  K      !j!jQ[^_`[a[a[g[g[i[i!j#a&&,,..!j!j!j!j!j!jrY   r   c              3     K   | ]F}t          |                                          #t          |                                          V  Gd S r   r  r  s     rW   r	  z/FeishuAdapter._load_settings.<locals>.<genexpr>  r  rY   r   )r   r   r   r   r   c              3     K   | ]F}t          |                                          #t          |                                          V  Gd S r   r  r  s     rW   r	  z/FeishuAdapter._load_settings.<locals>.<genexpr>  sC      PPaQP3q66<<>>PPPPPPrY   r   r   FEISHU_ALLOW_BOTSr   )r   r   allzS[Feishu] Unknown allow_bots=%r, falling back to 'none'. Valid: none, mentions, all.r   FEISHU_APP_IDr   FEISHU_APP_SECRETr   domainr'   ru   r   FEISHU_CONNECTION_MODE	websocketr   FEISHU_ENCRYPT_KEYr   FEISHU_VERIFICATION_TOKENr   FEISHU_GROUP_POLICYr   c              3  f   K   | ],}|                                 |                                 V  -d S r   r0  rT   r  s     rW   r	  z/FeishuAdapter._load_settings.<locals>.<genexpr>  sL       * *::<<*

* * * * * *rY   FEISHU_ALLOWED_USERS,r   FEISHU_BOT_OPEN_IDr   FEISHU_BOT_USER_IDr   FEISHU_BOT_NAMEr       HERMES_FEISHU_DEDUP_CACHE_SIZEr   &HERMES_FEISHU_TEXT_BATCH_DELAY_SECONDSr   ,HERMES_FEISHU_TEXT_BATCH_SPLIT_DELAY_SECONDSz2.0r   r  %HERMES_FEISHU_TEXT_BATCH_MAX_MESSAGESr   "HERMES_FEISHU_TEXT_BATCH_MAX_CHARSr   'HERMES_FEISHU_MEDIA_BATCH_DELAY_SECONDSr   FEISHU_WEBHOOK_HOSTr   FEISHU_WEBHOOK_PORTr   FEISHU_WEBHOOK_PATHr   rf   r   r[  r   re   r   r   r   FEISHU_REQUIRE_MENTIONr  rS   )r  r;  r   r  r  r   r   r0  r  r   r   osgetenvri  warningr   r5  r#  r   _DEFAULT_DEDUP_CACHE_SIZEr   !_DEFAULT_TEXT_BATCH_DELAY_SECONDS _DEFAULT_TEXT_BATCH_MAX_MESSAGES_DEFAULT_TEXT_BATCH_MAX_CHARS"_DEFAULT_MEDIA_BATCH_DELAY_SECONDS_DEFAULT_WEBHOOK_HOST_DEFAULT_WEBHOOK_PORT_DEFAULT_WEBHOOK_PATHr\  rY  )
r  raw_group_rulesr   r   rule_cfgper_chat_require_mention
raw_adminsr   r   r   s
             rW   r  zFeishuAdapter._load_settings  s     ))M26624ot,, 	%4%:%:%<%<  !!(D11  <@($00/:8<<HY;Z;Z/[/[,,;x||Hf==>>DDFFLLNN!!j!j(,,{TV:W:W!j!j!jjj!!j!j(,,{TV:W:W!j!j!jjj$<	- - -CLL)) YYx,,
PP:PPPPP  #599-CR#H#HIIOOQQWWYY Y2F;;AACCIIKK
888NNe    J$ <
 <
 <
uyy**Lbi.L.LMMSSUUU<
599\22Xbi@SUW6X6XYY__aaa<
 EIIh//W29_h3W3WXX^^``ffhhh<
  		+,,`	:RT_0`0` eggeeggg<
 	"6;;AACCC<
  "y)DbIIOOQQQ<
 #8+FFLLNNTTVVV<
 !* * *I&<bAAGGLL* * * ! ! !<
 	"6;;AACCC<
  	"6;;AACCC!<
" Y0"55;;===#<
$ !BI>D]@^@^__``  %<
, &+	BCHiDjDjkk& & &-<
2 ,1	H%PP, , ,3<
8 %(BIEsKkGlGlmmnn% % %9<
@ "%BIBCHeDfDfgghh" " "A<
H ',	CSIkElElmm' ' 'I<
N 		.))dRY7LNc-d-d egggS<
T 		.))iRY7LcRgNhNh-i-i  U<
\ EIIn--h;PRg1h1hiiooqq )(_<
b  4EII>R4S4S]_klmmmmc<
d #7uyyAX7Y7Ycfrs"t"t"t"te<
f )3E)F)FPT`abbbbg<
h (		2C(D(Dd^_````i<
j 6k<
l "6!5m<
n $o<
p "zq<
r (		+RY7OQW-X-XYY  s<
 <	
rY   settingsrj  c                    |j         | _        |j        | _        |j        | _        |j        | _        |j        | _	        |j
        | _        |j        | _        t          |j                  | _        t          |j                  | _        |j        p|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        | _:        d S r   );r   _app_idr   _app_secretr   _domain_namer   _connection_moder   _encrypt_keyr   _verification_tokenr   _group_policyr   r   _allowed_group_usersr   _adminsr   _default_group_policyr   _group_rulesr   _bot_open_idr   _bot_user_idr   	_bot_namer   _dedup_cache_sizer   _text_batch_delay_secondsr   _text_batch_split_delay_secondsr   _text_batch_max_messagesr   _text_batch_max_charsr   _media_batch_delay_secondsr   _webhook_hostr   _webhook_portr   _webhook_pathr   re  r   rf  r   rg  r   rq  r   _allow_botsr   _require_mention)r   r   s     rW   r  zFeishuAdapter._apply_settings  sZ   #.$0 ( 8$0#+#> %2$'(D$E$E!8?++%-%B%[hF["$0$0$0!*!)!:)1)J&/7/V,(0(H%%-%B"*2*L'%2%2%2#+#> &.&D#!)!: ( 8#. ( 8rY   r
   c                R    t           d S t          j         j         j                                       j                                       j                                       fd          	                     fd          
                     j                                       j                                       j                                       j                                       j                                      d j                                                  S )Nc                0                         d|           S )Nim.message.reaction.created_v1_on_reaction_eventdatar   s    rW   rL  z4FeishuAdapter._build_event_handler.<locals>.<lambda>      T445UW[\\ rY   c                0                         d|           S )Nim.message.reaction.deleted_v1r  r   s    rW   rL  z4FeishuAdapter._build_event_handler.<locals>.<lambda>  r"  rY   drive.notice.comment_add_v1)r,   builderr  r  &register_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_v1register_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_recalledregister_p2_customized_event_on_drive_comment_eventbuildr   s   `rW   _build_event_handlerz"FeishuAdapter._build_event_handler  s   !)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-	
rY   r   c                   K   t           st                              d           dS | j        r| j        st                              d           dS | j        dvr"t                              d| j                   dS 	 | j        | _        t          t          | j        d| j	        j
        i          \  }}|sqt          |t                    r|                    d          nd	}d
|rd| dndz   dz   }t                              d|           |                     d|d           dS t          j                    | _        |                                  d	{V  |                                  t                              d| j        | j                   dS # t,          $ r_}|                                  d	{V  d| }|                     d|d           t                              d|d           Y d	}~dS d	}~ww xY w)zConnect to Feishu/Lark.z [Feishu] lark-oapi not installedFz3[Feishu] FEISHU_APP_ID or FEISHU_APP_SECRET not set>   webhookr  zT[Feishu] Unsupported FEISHU_CONNECTION_MODE=%s. Supported modes: websocket, webhook.platform)r   pidNz@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] %sfeishu_app_lock)	retryablez"[Feishu] Connected in %s mode (%s)TzFeishu startup failed: feishu_connect_errorz[Feishu] Failed to connect: %srb  )r  ri  errorr  r  r  r  r:   _FEISHU_APP_LOCK_SCOPEr>  r   r;  r   r  _set_fatal_errorr  get_running_loopr  _connect_with_retry_mark_connectedinfor  rh  _release_app_lock)r   acquiredexisting	owner_pidrZ   excs         rW   r  zFeishuAdapter.connect   sW      	LL;<<<5| 	4#3 	LLNOOO5 (@@@LLf%   5	&*lD#!4&'$dm&9:" " "Hh
  	3=h3M3MWHLL///SW	V1:C-	----Eab 
 ]G444%%&7E%RRRu 133DJ**,,,,,,,,,  """KK<d>SUYUfggg4 	 	 	((*********555G!!"8'T!RRRLL93LNNN55555	s!   <B(F &A,F 
G=AG88G=c                  K   d| _         |                     | j                   d{V  |                     | j                   d{V  |                                  |                                  |                                  d{V  | j        I                                s5t          
                    d           dfd}                    |           | j        }|	 t          
                    d           t          j        t          j        |          d	           d{V  t          
                    d
           n# t          j        $ r t                              d           Y n]t          j        $ r t          
                    d           Y n3t&          $ r'}t          
                    d|d           Y d}~nd}~ww xY wd| _        d| _        d| _        d| _        |                                  |                                  d{V  |                                  t                              d           dS )zDisconnect from Feishu/Lark.FNz<[Feishu] Cancelling websocket thread tasks and stopping loopr   rj  c                     d t          j                  D             } t                              dt	          |                      | D ]}|                                                     dj                   d S )Nc                :    g | ]}|                                 |S rS   rz  r|  s     rW   r   zFFeishuAdapter.disconnect.<locals>.cancel_all_tasks.<locals>.<listcomp>[  s%    VVVqQVVXXVVVVrY   z3[Feishu] Found %d pending tasks in websocket threadg?)r  r  ri  rj  r  r  
call_laterr  )r   r  ws_thread_loops     rW   cancel_all_tasksz2FeishuAdapter.disconnect.<locals>.cancel_all_tasksZ  s}    VVG$5n$E$EVVVRTWX]T^T^___! " "DKKMMMM))#~/BCCCCCrY   z;[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: %sTrb  z[Feishu] Disconnectedrq  )_running_cancel_pending_tasksr  r  _reset_batch_buffers!_disable_websocket_auto_reconnect_stop_webhook_serverr  	is_closedri  rj  call_soon_threadsafer  r  wait_forshieldTimeoutErrorr  CancelledErrorrh  r  r  _persist_seen_message_idsrK  _mark_disconnectedrJ  )r   rU  	ws_futurerO  rT  s       @rW   
disconnectzFeishuAdapter.disconnectM  s     (()GHHHHHHHHH(()HIIIIIIIII!!###..000'')))))))))-%n.F.F.H.H%LLWXXXD D D D D D //0@AAAO	 	dZ[[[&w~i'@'@$OOOOOOOOOOGHHHH' c c cabbbbb) V V VTUUUUU d d dNPS^bccccccccd #
"&&((($$&&&&&&&&&!!!+,,,,,s%   )A"E )G7(G!	G*GGr   r   c                   K   d |                                 D             }|D ]}|                                 |rt          j        |ddi d {V  |                                 d S )Nc                >    g | ]}||                                 |S rS   rz  )rT   r  s     rW   r   z7FeishuAdapter._cancel_pending_tasks.<locals>.<listcomp>{  s*    OOODdO499;;O4OOOrY   r~  T)r  r  r  r  clear)r   r   r  r  s       rW   rY  z#FeishuAdapter._cancel_pending_tasksz  s      OOELLNNOOO 	 	DKKMMMM 	C.'BTBBBBBBBBBrY   c                    | j                                          | j                                         | j                                         d S r   )r  ri  r  r  r:  s    rW   rZ  z"FeishuAdapter._reset_batch_buffers  sG    "((***'--///#))+++++rY   c                    | j         d S 	 t          | j         dd           n# t          $ r Y nw xY wd | _         d S # d | _         w xY w)N_auto_reconnectF)r  rd  rh  r:  s    rW   r[  z/FeishuAdapter._disable_websocket_auto_reconnect  sl    ?"F	#DO%6>>>> 	 	 	D	 #DOOOdDO""""s   " ; 
/; /; 	Ac                   K   | j         d S 	 | j                                          d {V  d | _         d | _        d S # d | _         d | _        w xY wr   )r  cleanupr  r:  s    rW   r\  z"FeishuAdapter._stop_webhook_server  su      'F	&&..000000000#'D !%D $(D !%D%%%%s	   < ANr   r   r~   reply_toOptional[str]r   Optional[Dict[str, Any]]r4   c                  K   | j         st          dd          S |                     |          }|                     || j                  }d}	 |D ]}|                     |          \  }	}
	 |                     ||	|
||           d{V }n# t          $ r}|	dk    s't          	                    t          |                    s t                              d           |                     |dt          j        dt          |          id	          ||           d{V }Y d}~nd}~ww xY w|	dk    r|                     |          st          	                    t          t#          |d
d          pd                    r]t                              d           |                     |dt          j        dt          |          id	          ||           d{V }|}|                     |d          S # t          $ rE}t                              d|d           t          dt          |                    cY d}~S d}~ww xY w)zSend a Feishu message.FNot connectedsuccessrD  Nr   r   r|  ro  r   r  zI[Feishu] Invalid post payload rejected by API; falling back to plain textr}   r_  msgr   zJ[Feishu] Post payload rejected by API response; falling back to plain textzsend failedz[Feishu] Send error: %sTrb  )r  r4   format_messagetruncate_messageMAX_MESSAGE_LENGTH_build_outbound_payload_feishu_send_with_retryrh  _POST_CONTENT_INVALID_REsearchr   ri  r  rb  rc  rQ  _response_succeededr  _finalize_send_resultrD  )r   r   r~   ro  r   	formattedchunkslast_responsechunkr   r|  responserO  s                rW   sendzFeishuAdapter.send  s      | 	De?CCCC''00	&&y$2IJJ(	= ") ")$($@$@$G$G!'%)%A%A '!) '!)!) &B & &            HH ! 
 
 
6))1I1P1PQTUXQYQY1Z1Z)NN#nooo%)%A%A '!' $
F4QRW4X4X+Yhm n n n!)!) &B & &            HHHHHH	
 && 44X>> '077GHeUW<X<X<^\^8_8_`` ' NN#oppp%)%A%A '!' $
F4QRW4X4X+Yhm n n n!)!) &B & &            H !)--m]KKK 	= 	= 	=LL2C$LGGGe3s88<<<<<<<<<	=sJ   G9 , BG9 
D,BD'"G9 'D,,CG9 9
I:I=IIF)finalize
message_idr  c          	       K   | j         st          dd          S |                     |          }	 |                     |          \  }}|                     ||          }|                     ||          }t          j        | j         j        j	        j
        j        |           d{V }	|                     |	d          }
|
j        s|dk    rt                              |
j        pd	          rt"                              d
           |                     dt'          j        dt+          |          id                    }|                     ||          }t          j        | j         j        j	        j
        j        |           d{V }|                     |d          }
|
j        r||
_        |
S # t.          $ rF}t"                              d||d           t          dt1          |                    cY d}~S d}~ww xY w)z0Edit a previously sent Feishu text/post message.Frs  rt  r   r~   r  request_bodyNzupdate failedr  r   zP[Feishu] Invalid post update payload rejected by API; falling back to plain textr}   r_  z&[Feishu] Failed to edit message %s: %sTrb  )r  r4   rx  r{  _build_update_message_body_build_update_message_requestr  	to_threadimv1rZ   updater  ru  r}  r~  rD  ri  r  rb  rc  rQ  r  rh  r   )r   r   r  r~   r  r   r|  r*  requestr  rG  fallback_bodyfallback_requestfallback_responserO  s                  rW   edit_messagezFeishuAdapter.edit_message  s3      | 	De?CCCC%%g..	= $ < <W E EHg22Hg2VVD88J]a8bbG$.t|/A/I/PRYZZZZZZZZH///JJF> Xh&&8&8=U=\=\]c]i]omo=p=p&8qrrr $ ? ?# J0Mg0V0V'Wfklll !@ ! ! $(#E#EQ[jw#E#x#x *1*;DLO<N<V<]_o*p*p$p$p$p$p$p$p!334EWW~ /$.!M 	= 	= 	=LLA:s]aLbbbe3s88<<<<<<<<<	=s   FF4 4
H>;G?9H?Hdangerous commandcommandsession_keyr   c                  K   | j         st          dd          S 	 t          | j                  t	          |          dk    r|dd         dz   n|}d.d/fd}ddiddddddd| d| dd |ddd           |dd           |d d!           |d"d#d$          gd%gd&}t          j        |d'          }	|                     |d(|	d|)           d{V }
|                     |
d*          }|j	        r||j
        pd+|d,| j        <   |S # t          $ rC}t                              d-|           t          dt          |                    cY d}~S d}~ww xY w)0a  Send an interactive card with approval buttons.

        The buttons carry ``hermes_action`` in their value dict so that
        ``_handle_card_action_event`` can intercept them and call
        ``resolve_gateway_approval()`` to unblock the waiting agent thread.
        Frs  rt  i  Nz...rR  r   r   action_namebtn_typer   r   c                    dd| d||ddS )Nr  r  r   r~   )hermes_actionapproval_id)r   r}   r   r   rS   )r   r  r  r  s      rW   _btnz.FeishuAdapter.send_exec_approval.<locals>._btn  s.    #$0UCC$/:;WW	  rY   wide_screen_modeTu    ⚠️ Command Approval Requiredr  r~   r   oranger|   r   r  z```
z
```
**Reason:** r  r  u   ✅ Allow Oncerl   primaryu   ✅ Sessionrm   u
   ✅ Alwaysrn   u   ❌ Denyrk   danger)r   r  r  r&  r  r_  r  rv  zsend_exec_approval failedr   )r  r  r   z&[Feishu] send_exec_approval failed: %srR  )r   r   r  r   r  r   r   r   )r  r4   nextr  r  rb  rc  r|  r  ru  r  r  rh  ri  r  r   )r   r   r  r  r   r   cmd_previewr  r  r|  r  rG  rO  r  s                @rW   send_exec_approvalz FeishuAdapter.send_exec_approval  s:      | 	De?CCCC6	=t566K47LL44G4G'%4%.500WK       .t4)KT`aa (   *#X;#X#X;#X#X 
  ( D!1>9MM D0ABB D/?@@ DVX>>	$  D. jE:::G!99&! :        H //:UVVF~ #."("3"9r&5 5$[1
 M 	= 	= 	=NNCSIIIe3s88<<<<<<<<<	=s   C0D 
E8EEEchoicer  c                    | dk    rdnd}t                               | d          }ddi| d| dd	| dk    rd
nddd| d| d| dgdS )z3Build raw card JSON for a resolved approval action.rk   u   ❌u   ✅Resolvedr  Tr"  r  r  redgreenr  r  z **z** by r  r  )rr   r  )r  r  iconr   s       rW   _build_resolved_approval_cardz+FeishuAdapter._build_resolved_approval_card@  s     &((uue#''
;;)40(,%6%6u%6%6|LL%+v%5%5EE7  &"&CC5CC	CC 
 
 	
rY   
audio_pathcaptionc                H   K   |                      |||||d           d{V S )z@Send audio to Feishu as a file attachment plus optional caption.r  r   	file_pathro  r   r  outbound_message_typeN_send_uploaded_file_message)r   r   r  r  ro  r   rm  s          rW   
send_voicezFeishuAdapter.send_voiceS  U       55 ") 6 
 
 
 
 
 
 
 
 	
rY   r  r   c                H   K   |                      ||||||           d{V S )z*Send a document/file attachment to Feishu.)r   r  ro  r   r  r   Nr  )r   r   r  r  r   ro  r   rm  s           rW   send_documentzFeishuAdapter.send_documentf  sU       55 6 
 
 
 
 
 
 
 
 	
rY   
video_pathc                H   K   |                      |||||d           d{V S )zSend a video file to Feishu.r  r  Nr  )r   r   r  r  ro  r   rm  s          rW   
send_videozFeishuAdapter.send_videoz  r  rY   
image_pathc                r  K   | j         st          dd          S t          j                            |          st          dd|           S 	 ddl}t          |d          5 }|                                }	ddd           n# 1 swxY w Y   |                    |	          }
t          j        	                    |          |
_
        |                     t          |
          }|                     |          }t          j        | j         j        j        j        j        |           d{V }|                     |d	          }|s|                     |d
d          S |r;|                     |d|d          }|                     |d|||           d{V }n6|                     |dt1          j        d	|id          ||           d{V }|                     |d          S # t6          $ rF}t8                              d||d           t          dt=          |                    cY d}~S d}~ww xY w)z"Send a local image file to Feishu.Frs  rt  zImage file not found: r   Nrb
image_typer  r   zimage upload failedz%Feishu image upload missing image_keydefault_messageoverride_errorr  )r   r   r  	media_tagr  rv  r  r_  zimage send failedz$[Feishu] Failed to send image %s: %sTrb  )r  r4   r  pathexistsior  readBytesIObasenamer   _build_image_upload_body_FEISHU_IMAGE_UPLOAD_TYPE_build_image_upload_requestr  r  r  r  r  create_extract_response_field_response_error_result_build_media_post_payloadr|  rb  rc  r  rh  ri  rD  r   )r   r   r  r  ro  r   rm  _iofimage_bytes
image_filer*  r  upload_responser   post_payloadmessage_responserO  s                     rW   send_image_filezFeishuAdapter.send_image_file  s	      | 	De?CCCCw~~j)) 	Ze3XJ3X3XYYYY,	=j$'' '1ffhh' ' ' ' ' ' ' ' ' ' ' ' ' ' ' [11J g..z::JO004  1  D 66t<<G$+$5dlo6H6N6UW^$_$_______O44_kRRI 22#$9#J 3     #==#&+)DD  >     *.)E)E##(%% *F * * $ $ $ $ $ $   *.)E)E#$ JY'?eTTT%% *F * * $ $ $ $ $ $  --.>@STTT 	= 	= 	=LL?S[_L```e3s88<<<<<<<<<	=sJ   G& #B8G& BG& BCG& BG& &
H60;H1+H61H6c                
   K   dS )z2Feishu bot API does not expose a typing indicator.NrS   )r   r   r   s      rW   send_typingzFeishuAdapter.send_typing  s      trY   	image_urlc                D  K   	 |                      |           d{V }na# t          $ rT}t                              d||d           t	                                          |||||           d{V cY d}~S d}~ww xY w|                     |||||           d{V S )zJDownload a remote image then send it through the native Feishu image flow.Nz([Feishu] Failed to download image %s: %sTrb  )r   r  r  ro  r   )r   r  r  ro  r   )_download_remote_imagerh  ri  rD  r  
send_imager  )	r   r   r  r  ro  r   r  rO  r  s	           rW   r  zFeishuAdapter.send_image  s"     
	#::9EEEEEEEEJJ 	 	 	LLCYPS^bLccc++#!! ,              	 ))! * 
 
 
 
 
 
 
 
 	
s   ! 
A?A	A:4A?:A?animation_urlc                d  K   	 |                      |dd           d{V \  }}na# t          $ rT}t                              d||d           t	                                          |||||           d{V cY d}~S d}~ww xY w|rd	| nd
}	|                     ||||	||           d{V S )z@Feishu has no native GIF bubble; degrade to a downloadable file.rA   zanimation.gif)default_extpreferred_nameNz,[Feishu] Failed to download animation %s: %sTrb  )r   r  r  ro  r   z[GIF downgraded to file]
z[GIF downgraded to file])r   r  r   r  ro  r   )_download_remote_documentrh  ri  rD  r  send_animationr  )r   r   r  r  ro  r   r  r   rO  degraded_captionr  s             rW   r  zFeishuAdapter.send_animation  se     	)-)G)G". *H * * $ $ $ $ $ $ Iyy
  	 	 	LLGX[fjLkkk//+!! 0              	 FMlAAAARl''$ ( 
 
 
 
 
 
 
 
 	
s   !' 
BA	B :B Bc                z  K   ||dd}| j         s|S | j                            |          }|t          |          S 	 |                     |          }t          j        | j         j        j        j	        j        |           d{V }|r t          |dd                       du rAt          |dd          }t          |d	d
          }t                              d|||           |S t          |dd          }t          t          |dd          pd                                                                          }	|t          t          |dd          p|          |                     |	          |	pdd}
|
| j        |<   t          |
          S # t"          $ r" t                              d|d           |cY S w xY w)z5Return real chat metadata from Feishu when available.dm)r   r   r   Nru  c                     dS r  rS   rS   rY   rW   rL  z-FeishuAdapter.get_chat_info.<locals>.<lambda>      E rY   Fr5  rJ  rw  zchat lookup failedz0[Feishu] Failed to get chat info for %s: [%s] %sr!  	chat_typer   r   )r   r   r   r   z'[Feishu] Failed to get chat info for %sTrb  )r  r  r  r   _build_get_chat_requestr  r  r  r  chatr  ri  r  r   r0  r  _map_chat_typerh  )r   r   fallbackcachedr  r  r5  rw  r!  raw_chat_typerJ  s              rW   get_chat_infozFeishuAdapter.get_chat_info  s      
 

 | 	O&**733<<	227;;G$.t|/A/F/JGTTTTTTTTH  JwxMMJJLLPUUUx;;h/CDDQSZ\`befff8VT22Dk2 > > D"EEKKMMSSUUM"GD&$77B7CC++M::)1T	 D .2D!'*:: 	 	 	NNDgX\N]]]OOO	s   B'F &B'F )F:9F:c                *    |                                 S )z/Feishu text messages are plain text by default.r  r   r~   s     rW   rx  zFeishuAdapter.format_message1  s    }}rY   r!  c                P   | j         }|                     |          sG|                     |          }|r.t          j        | j        dd                                           dS t          j        | 	                    |          |          }|
                    | j                   dS )aP  Normalize 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.
        zfeishu-pending-inbound-drainerT)targetr   daemonN)r  _loop_accepts_callbacks_enqueue_pending_inbound_eventr  Thread_drain_pending_inbound_eventsr  r  run_coroutine_threadsafe_handle_message_event_dataadd_done_callback_log_background_failure)r   r!  r  start_drainerfutures        rW   r*  zFeishuAdapter._on_message_event9  s     z++D11 	 ??EEM  =9   %'''F1++D11
 
 	  !=>>>>>rY   c                T   | j         5  t          | j                  | j        k    r| j                            d          }	 t          |dd          }t          |dd          }t          t          |dd          pd          }n# t          $ r d}Y nw xY wt          	                    d| j        |           | j        
                    |           t          | j                  }| j         }|rd	| _        ddd           n# 1 swxY w Y   t                              d
|           |S )a  Append 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.
        r   eventNrZ   r  r   rJ  zA[Feishu] Pending-inbound queue full (%d); dropped oldest event %sTzI[Feishu] Queued inbound event for replay (loop not ready, queue depth=%d))r  r  r  r  popr  r   rh  ri  rD  rm  r  r  )r   r!  droppedr  rZ   r  depthshould_starts           rW   r  z,FeishuAdapter._enqueue_pending_inbound_eventQ  s    ' 	5 	54/00D4SSS 6::1==+#GWd;;E%eY==G!$WWlB%G%G%T9!U!UJJ  + + +!*JJJ+W3  
 (//555455E#<<L 504-+	5 	5 	5 	5 	5 	5 	5 	5 	5 	5 	5 	5 	5 	5 	5, 	W	
 	
 	
 s7   8DABDBDBA#DD	Dc                   d}d}d}	 	 t          | dd          s| j        5  t          | j                  }| j                                         ddd           n# 1 swxY w Y   |rt
                              d|           	 | j        5  d| _        ddd           dS # 1 swxY w Y   dS | j        }| 	                    |          r| j        5  | j        dd         }| j                                         ddd           n# 1 swxY w Y   |s^| j        5  | j        s5	 ddd           | j        5  d| _        ddd           dS # 1 swxY w Y   dS 	 ddd           n# 1 swxY w Y   id	}g }|D ]o}		 t          j        |                     |	          |          }
|
                    | j                   |d
z  }K# t          $ r |                    |	           Y lw xY w|r+| j        5  || j        dd	<   ddd           n# 1 swxY w Y   |rt
                              d|           |s\| j        5  | j        s5	 ddd           | j        5  d| _        ddd           dS # 1 swxY w Y   dS 	 ddd           n# 1 swxY w Y   ||k    r| j        5  t          | j                  }| j                                         ddd           n# 1 swxY w Y   t
                              d||           	 | j        5  d| _        ddd           dS # 1 swxY w Y   dS t'          j        |           ||z  };# | j        5  d| _        ddd           w # 1 swxY w Y   w xY w)aU  Replay queued inbound events once the adapter loop is ready.

        Runs in a dedicated daemon thread. Polls ``_running`` and
        ``_loop_accepts_callbacks`` until events can be dispatched or the
        adapter shuts down. A single drainer handles the entire queue;
        concurrent ``_on_message_event`` calls just append.
        g      ?g      ^@        TrX  Nz;[Feishu] Dropped %d queued inbound event(s) during shutdownFr   r  z,[Feishu] Replayed %d queued inbound event(s)zO[Feishu] Adapter loop unavailable for %.0fs; dropped %d queued inbound event(s))r  r  r  r  ri  ri  r  r  r  r  r  r  r  r  r  rv  rm  rJ  rD  timesleep)r   poll_intervalmax_wait_secondswaitedr  r  batch
dispatchedrequeuer  futs              rW   r  z+FeishuAdapter._drain_pending_inbound_eventst  s=     F	6B(tZ66  3 = ="%d&B"C"C4::<<<= = = = = = = = = = = = = = =  Y#   p + 6 605-6 6 6 6 6 6 6 6 6 6 6 6 6 6 6 6 6 6o z//55 '3 = = $ <QQQ ?4::<<<= = = = = = = = = = = = = = = ! !!7 ' '#'#? ' &' ' ' ' ' '` + 6 605-6 6 6 6 6 6 6 6 6 6 6 6 6 6 6 6 6 6_'' ' ' ' ' ' ' ' ' ' ' ' ' ' ' !!"J)+G!& 2 2
2")"B $ ? ? F F $# #C  11$2NOOO&!OJJ+ 2 2 2 $NN5111112  G!7 G G?FD8!<G G G G G G G G G G G G G G G! J&   # ' "7 ' '#'#? ' &' ' ' ' ' '& + 6 605-6 6 6 6 6 6 6 6 6 6 6 6 6 6 6 6 6 6%'' ' ' ' ' ' ' ' ' ' ' ' ' ' ' ---3 = ="%d&B"C"C4::<<<= = = = = = = = = = = = = = = LL=(	    + 6 605-6 6 6 6 6 6 6 6 6 6 6 6 6 6 6 6 6 6 
=)))-'EB(H + 6 605-6 6 6 6 6 6 6 6 6 6 6 6 6 6 6 6s  M .AM AM "A# M B  B$'B$-$M )D:M D

M D
M 	E$#M 5E

EEM $E((M +E(,M :AGM G$!M #G$$M 0H	=M 	HM H)M :	JM I**I.1I.8M JM JM .KM KM K M LL #L )M M,M M, M$$M,'M$(M,c           
     b  K   t          |dd          }t          |dd          }t          |dd          }|r|rt          |dd          st                              d           dS t          |dd          }|r|                     |          rt                              d|           dS |                     ||          }|t                              d	|           dS t          |d
d          }|                     ||t          |dd          ||t          |                     d{V  dS )zEShared inbound message handling for websocket and webhook transports.r  NrZ   r   r  zA[Feishu] Dropping malformed inbound event: missing message/senderr  z2[Feishu] Dropping duplicate/missing message_id: %sz#[Feishu] dropping inbound event: %sr  p2p)r!  rZ   r  r  r  is_bot)r  ri  rj  _is_duplicate_admit_process_inbound_messager  )r   r!  r  rZ   r   r  reasonr  s           rW   r  z(FeishuAdapter._handle_message_event_data  sj     gt,,%D11$// 	f 	GFK,N,N 	LL\]]]FWlD99
 	T//
;; 	LLMzZZZFVW--LL>GGGFG[%88	++fk488!!&)) , 
 
 	
 	
 	
 	
 	
 	
 	
 	
 	
rY   r    c                    t          |dd          }t          |dd          }t          |dd          pd}t                              d|           dS )z7Ignore read-receipt events that Hermes does not act on.r  NrZ   r  r   z([Feishu] Ignoring message_read event: %s)r  ri  rj  )r   r!  r  rZ   r  s        rW   r(  z$FeishuAdapter._on_message_read_event  sU    gt,,%D11WlD99?R
?LLLLLrY   c                    t          |dd          }t          t          |dd          pd          }t                              d|           | j                            |d           dS )z'Handle bot being added to a group chat.r  Nr   r   z[Feishu] Bot added to chat: %sr  r   ri  rJ  r  r  r   r!  r  r   s       rW   r0  z#FeishuAdapter._on_bot_added_to_chat  se    gt,,geY339r::4g>>>!!'400000rY   c                    t          |dd          }t          t          |dd          pd          }t                              d|           | j                            |d           dS )z+Handle bot being removed from a group chat.r  Nr   r   z"[Feishu] Bot removed from chat: %sr%  r&  s       rW   r2  z'FeishuAdapter._on_bot_removed_from_chat  se    gt,,geY339r::8'BBB!!'400000rY   c                :    t                               d           d S )Nz'[Feishu] User entered P2P chat with botri  rj  r   r!  s     rW   r4  z"FeishuAdapter._on_p2p_chat_entered  s    >?????rY   c                :    t                               d           d S )Nz![Feishu] Message recalled by userr)  r*  s     rW   r6  z"FeishuAdapter._on_message_recalled  s    899999rY   c                   ddl m} | j        }|                     |          st                              d           dS t          j         || j        || j	                  |          }|
                    | j                   dS )a%  Handle drive document comment notification (drive.notice.comment_add_v1).

        Delegates to :mod:`gateway.platforms.feishu_comment` for parsing,
        logging, and reaction.  Scheduling follows the same
        ``run_coroutine_threadsafe`` pattern used by ``_on_message_event``.
        r   )handle_drive_comment_eventzB[Feishu] Dropping drive comment event before adapter loop is readyN)self_open_id) gateway.platforms.feishu_commentr-  r  r  ri  r  r  r  r  r  r  r  )r   r!  r-  r  r
  s        rW   r8  z%FeishuAdapter._on_drive_comment_event  s     	POOOOOz++D11 	NN_```F1&&t|THYZZZ
 
 	  !=>>>>>rY   
event_typec                L   t          |dd          }t          t          |dd          pd          }t          t          |dd          pd          }t          |dd          }t          t          |dd          pd          }d|v rd	nd
}t                              d||||           | j        }	|dv s+|r)|	't           t          |	dd                                 rdS t          j        |                     ||          |	          }
|
	                    | j
                   dS )z>Route user reactions on bot messages as synthetic text events.r  Nr  r   operator_typereaction_typer  createdaddedremovedz?[Feishu] Reaction %s on message %s (operator_type=%s, emoji=%s)>   r  r   r]  c                     dS r  rS   rS   rY   rW   rL  z2FeishuAdapter._on_reaction_event.<locals>.<lambda>)	  s    u rY   )r  r   ri  rj  r  r   r  r  _handle_reaction_eventr  r  )r   r0  r!  r  r  r2  reaction_type_objr  r  r  r
  s              rW   r  z FeishuAdapter._on_reaction_event	  sN   gt,,b99?R@@
GE?B??E2FF#E?DAA!2L"EEKLL
%33M	
 	
 	
 z^++ ,|=GD+}}==??@@  F1''
D99
 
 	  !=>>>>>rY   c                   | j         }|                     |          s1t                              d           t          rt	                      ndS t          |dd          }t          |dd          }t          |di           pi }t          |t                    r|                    d          nd}|r| 	                    |||          S | 
                    ||                     |                     t          dS t	                      S )ap  Handle 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 readyNr  r  r   r  )r  action_valuer  )r  r  ri  r  r+   r  r;  r   r  _handle_approval_card_action_submit_on_loop_handle_card_action_event)r   r!  r  r  r  r;  r  s          rW   r.  z%FeishuAdapter._on_card_action_trigger2	  s    z++D11 	ZNNWXXX4OY.000UYYgt,,$//vw339r=GVZ=[=[e((999ae 	h445|bf4gggT4#A#A$#G#GHHH&.4*,,,rY   r  c                Z    | duo't           t          | dd                                  S )zEReturn True when the adapter loop can accept thread-safe submissions.Nr]  c                     dS r  rS   rS   rY   rW   rL  z7FeishuAdapter._loop_accepts_callbacks.<locals>.<lambda>P	  s    PU rY   r   r  )r  s    rW   r  z%FeishuAdapter._loop_accepts_callbacksM	  s6     4Y-VWT;-V-V-X-X(Y(Y$YYrY   coroc                d    t          j        ||          }|                    | j                   dS )zISchedule background work on the adapter loop with shared failure logging.N)r  r  r  r  )r   r  rB  r
  s       rW   r=  zFeishuAdapter._submit_on_loopR	  s1    1$==  !=>>>>>rY   r  r;  c                  |                     d          }|1t                              d           t          rt                      ndS t                               |                     d          d          }t          |dd          }t          t          |dd          pd          }|                     |          p|}|                     || 	                    |||                     t          dS t                      }	t          8t                      }
d	|
_        |                     ||
          |
_        |
|	_        |	S )zISchedule approval resolution and build the synchronous callback response.r  Nz2[Feishu] Card action missing approval_id, ignoringr  rk   operatorr   r   raw)r  r  )r  ri  rj  r+   rp   r  r   _get_cached_sender_namer=  _resolve_approvalr*   r   r  r!  r  )r   r  r;  r  r  r  rE  r   r  r  r  s              rW   r<  z*FeishuAdapter._handle_approval_card_actionW	  s+   "&&}55LLMNNN4OY.000UYY%)),*:*:?*K*KVTT5*d33gh	266<"==0099DW	T4#9#9+vy#Y#YZZZ&.4.00#>>DDI::&T]:^^DI HMrY   r  c                ^  K   | j                             |d          }|st                              d|           dS 	 ddlm}  ||d         |          }t                              d||d         ||           dS # t          $ r&}t                              d|           Y d}~dS d}~ww xY w)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  r  ri  rj  tools.approvalrJ  rJ  rh  rD  )r   r  r  r  staterJ  r  rO  s           rW   rH  zFeishuAdapter._resolve_approvalo	  s      $((d;; 	LLK[YYYF	[??????,,U=-A6JJEKK[u]+VY      	[ 	[ 	[LLTVYZZZZZZZZZ	[s   <A< <
B,B''B,c           
       K   | j         sdS t          |dd          }t          t          |dd          pd          }|sdS 	 |                     |          }t	          j        | j         j        j        j        j	        |           d{V }|r t          |dd                       sdS t          t          |dd          dd          pg }|r|d	         nd}|sdS t          |d
d          }	t          t          |	dd          pd          | j
        k    rdS t          t          |dd          pd          }
t          t          |dd          pd          }|
sdS n-# t          $ r  t                              dd           Y dS w xY wt          |dd          }t          |dd          }t          t          |dd          pd          }d|v rdnd}d| d| }|                     |           d{V }|                     |
           d{V }|                     |
|	                    d          p|
pd|                     ||          |d         |d         d|d                    }t%          |t&          j        |||t+          j                    !          }t                              d"|||           |                     |           d{V  dS )#zVFetch the reacted-to message; if it was sent by this bot, emit a synthetic text event.Nr  r  r   ru  c                     dS r  rS   rS   rY   rW   rL  z6FeishuAdapter._handle_reaction_event.<locals>.<lambda>	  s     rY   r!  r  r   r   r?  r   r  r  z5[Feishu] Failed to fetch message for reaction routingTrb  r   r3  r  UNKNOWNr4  r5  r6  z	reaction:r  r   Feishu Chat	chat_infoevent_chat_typer  user_id_altr   r  r  r   r  	thread_idrT  r}   r   sourceraw_messager  	timestampzD[Feishu] Routing reaction %s:%s on bot message %s as synthetic event)r  r  r   _build_get_message_requestr  r  r  r  rZ   r  r  rh  ri  rj  _resolve_sender_profiler  build_source_resolve_source_chat_typer1   r2   TEXTr   nowrJ  _handle_message_with_guards)r   r0  r!  r  r  r  r  r  rw  r   r   chat_type_rawuser_id_objr9  r  r  synthetic_textsender_profilerR  rX  synthetic_events                        rW   r8  z$FeishuAdapter._handle_reaction_event	  se     | 	Fgt,,b99?R@@
 	F	55jAAG$.t|/A/I/MwWWWWWWWWH #N78Y#N#N#P#P GHfd;;WdKKQrE#-%((C  S(D11F764,,233t|CC'#y"55;<<G[% @ @ IEJJM  	 	 	LLP[_L```FF	 eY55#E?DAA!2L"EERSS
%33:V::j::#;;KHHHHHHHH,,W55555555	""mmF++GwG-44yZg4hh"9-$[1&}5 # 
 
 '$)!lnn
 
 
 	Z\bdnpz{{{..???????????s&   A%E )0E :E AE &FFr   c                    t          j                     fd| j                                        D             }|D ]
}| j        |= || j        v rdS | j        |<   dS )zTReturn True if this card action token was already processed within the dedup window.c                6    g | ]\  }}|z
  t           k    |S rS   )%_FEISHU_CARD_ACTION_DEDUP_TTL_SECONDS)rT   r}  tsr`  s      rW   r   z;FeishuAdapter._is_card_action_duplicate.<locals>.<listcomp>	  s,    wwwBcBhQvFvFv1FvFvFvrY   TF)r  r  r  )r   r   expiredr}  r`  s       @rW   _is_card_action_duplicatez'FeishuAdapter._is_card_action_duplicate	  sx    ikkwwww$":"@"@"B"Bwww 	, 	,A(++D,,,4*- 'urY   c           
       K   t          |dd          }t          t          |dd          pd          }|r2|                     |          rt                              d|           dS t          |dd          }t          t          |dd          pd          }t          |dd          }t          t          |d	d          pd          }|r|st                              d
           dS t          |dd          }t          t          |dd          pd          }	t          |di           pi }
d|	 }|
r.	 |dt          j        |
d           z  }n# t          $ r Y nw xY wt          |dd          }| 	                    |           d{V }| 
                    |           d{V }|                     ||                    d          p|pd|                     |d          |d         |d         d|d                   }t          |t          j        |||pt          t#          j                              t'          j                              }t                              d|	||           |                     |           d{V  dS )zHRoute Feishu interactive card button clicks as synthetic COMMAND events.r  Nr   r   z1[Feishu] Dropping duplicate card action token: %scontextr   rE  r   zB[Feishu] Card action missing chat_id or operator open_id, droppingr  r   r  r   z/card r"  Fr_  )r   r   r   r   rP  rJ  rQ  r   r  rT  rU  rW  zB[Feishu] Routing card action %r from %s in %s as synthetic command)r  r   rl  ri  rj  rb  rc  rh  r	   r\  r  r]  r  r^  r1   r2   COMMANDuuiduuid4r   r`  rJ  ra  )r   r!  r  r   rn  r   rE  r   r  
action_tagr;  rd  r  re  rR  rX  rf  s                    rW   r>  z'FeishuAdapter._handle_card_action_event	  s     gt,,GE7B//5266 	T33E:: 	LLLeTTTF%D11gg~r::@bAA5*d33gh	266<"== 	g 	LL]^^^F$//33?x@@
vw339r.*.. 	"TdjE&R&R&R"T"TT    $GTDQQQ	#;;IFFFFFFFF,,W55555555	""mmF++GwG-44yZa4bb"9-$[1&}5 # 
 
 '$,1DJLL 1 1lnn
 
 
 	XZdfmovwww..???????????s   6E 
E E asyncio.Lockc                x    | j                             |          }|t          j                    }|| j         |<   |S )zTReturn (creating if needed) the per-chat asyncio.Lock for serial message processing.)r  r  r  r  )r   r   locks      rW   _get_chat_lockzFeishuAdapter._get_chat_lock	  s:    ##G,,<<>>D(,DW%rY   r1   c                  K   |j         rt          |j         dd          pdnd}|                     |          }|4 d{V  |                     |           d{V  ddd          d{V  dS # 1 d{V swxY w Y   dS )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).
        r   r   N)rX  r  rv  handle_message)r   r  r   	chat_locks       rW   ra  z)FeishuAdapter._handle_message_with_guards
  s*      AFT'%,	266<"RT''00	 	- 	- 	- 	- 	- 	- 	- 	-%%e,,,,,,,,,	- 	- 	- 	- 	- 	- 	- 	- 	- 	- 	- 	- 	- 	- 	- 	- 	- 	- 	- 	- 	- 	- 	- 	- 	- 	- 	- 	- 	- 	-s   A00
A:=A:c                x    t          j        dd                                                                          dvS )NFEISHU_REACTIONSr  )false0no)r  r  r0  r  r:  s    rW   _reactions_enabledz FeishuAdapter._reactions_enabled
  s3    y+V44::<<BBDDL```rY   r  c                  K   | j         r|r|sdS 	 ddlm}m} |                                                    d|i                                          }|                                                    |                              |                                          }t          j
        | j         j        j        j        j        |           d{V }|r< t          |dd                       r"t          |dd          }t          |dd          S t                               d	||t          |d
d          t          |dd                     n.# t$          $ r! t                               d||d           Y nw xY wdS )zRReturn the reaction_id on success, else None. The id is needed later for deletion.Nr   )CreateMessageReactionRequest CreateMessageReactionRequestBodyr  ru  c                     dS r  rS   rS   rY   rW   rL  z-FeishuAdapter._add_reaction.<locals>.<lambda>-
       rY   r!  reaction_idz7[Feishu] Add reaction %s on %s rejected: code=%s msg=%sr5  rw  z%[Feishu] Add reaction %s on %s raisedTrb  )r  lark_oapi.api.im.v1r  r  r&  r3  r9  r  r  r  r  r  r  message_reactionr  r  ri  rj  rh  r  )	r   r  r  r  r  r*  r  r  r!  s	            rW   _add_reactionzFeishuAdapter._add_reaction
  s     | 	: 	Z 	4!	       
 188::j9::  -4466J''d##	  %.t|/A/R/Y[bccccccccH :GGHiGGII :x66t]D999LLI&$//%..     	 	 	NN7	      	 ts   D E <E (E:9E:r  c                D  K   | j         r|r|sdS 	 ddlm} |                                                    |                              |                                          }t          j        | j         j	        j
        j        j        |           d {V }|r t          |dd                       rdS t                              d||t          |dd           t          |d	d                      n.# t           $ r! t                              d
||d           Y nw xY wdS )NFr   )DeleteMessageReactionRequestru  c                     dS r  rS   rS   rY   rW   rL  z0FeishuAdapter._remove_reaction.<locals>.<lambda>L
  r  rY   Tz:[Feishu] Remove reaction %s on %s rejected: code=%s msg=%sr5  rw  z([Feishu] Remove reaction %s on %s raisedrb  )r  r  r  r&  r  r  r9  r  r  r  r  r  deleter  ri  rj  rh  r  )r   r  r  r  r  r  s         rW   _remove_reactionzFeishuAdapter._remove_reaction@
  sg     | 	: 	[ 	5	HHHHHH,4466J''[))	  %.t|/A/R/Y[bccccccccH GGHiGGII tLLL&$//%..     	 	 	NN:	      	 us   B"C2 5<C2 2(DDc                    | j         }|||<   |                    |           t          |          t          k    r0|                    d           t          |          t          k    .d S d S )NF)last)r  move_to_endr  &_FEISHU_PROCESSING_REACTION_CACHE_SIZEpopitem)r   r  r  caches       rW   _remember_processing_reactionz+FeishuAdapter._remember_processing_reaction^
  sn    2'j*%%%%jjAAAMMuM%%% %jjAAAAAAArY   c                8    | j                             |d           S r   )r  r  )r   r  s     rW   _pop_processing_reactionz&FeishuAdapter._pop_processing_reactione
  s    155j$GGGrY   c                   K   |                                  sd S |j        }|r	|| j        v rd S |                     |t                     d {V }|r|                     ||           d S d S r   )r  r  r  r  _FEISHU_REACTION_IN_PROGRESSr  )r   r  r  r  s       rW   on_processing_startz!FeishuAdapter.on_processing_starth
  s      &&(( 	F%
 	Z4+MMMF ..z;WXXXXXXXX 	H..z;GGGGG	H 	HrY   outcomer3   c                L  K   |                                  sd S |j        }|sd S | j                            |          }|r3|                     ||           d {V sd S |                     |           |t          j        u r#|                     |t                     d {V  d S d S r   )
r  r  r  r  r  r  r3   FAILUREr  _FEISHU_REACTION_FAILURE)r   r  r  r  start_reaction_ids        rW   on_processing_completez$FeishuAdapter.on_processing_completer
  s       &&(( 	F%
 	F >BB:NN 	6..z;LMMMMMMMM  ))*555'///$$Z1IJJJJJJJJJJJ 0/rY   	remote_ipstatusc                ,   t          j                     }| j                            |          }|W|\  }}}||z
  t          k     rC|dz  }|t          z  dk    r!t
                              d|||||z
             |||f| j        |<   dS d||f| j        |<   dS )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.
        Nr  r   zY[Feishu] Webhook anomaly: %d consecutive error responses (%s) from %s over the last %.0fs)r  r  r  #_FEISHU_WEBHOOK_ANOMALY_TTL_SECONDS!_FEISHU_WEBHOOK_ANOMALY_THRESHOLDri  r  )r   r  r  r`  entryr  _last_status
first_seens           rW   _record_webhook_anomalyz%FeishuAdapter._record_webhook_anomaly
  s     ikk,00;;.3+E<Z"EEE
<<AANN.!j(   <A&*:U,Y734fc2B$Y///rY   c                <    | j                             |d           dS )zCReset the anomaly counter for remote_ip after a successful request.N)r  r  )r   r  s     rW   _clear_webhook_anomalyz$FeishuAdapter._clear_webhook_anomaly
  s!    $((D99999rY   r  rZ   r  r  r  c               "  K   |                      |           d {V \  }}}	}
}|t          j        k    r1t          ||          }|                    d          rt          j        }|t          j        k    r!|s|	st                              d|           d S |t          j        k    rt          |          }|r|r| d| n|}t          |dd           pt          |dd           pd }|r| 
                    |           d {V nd }t          |dd           p#t          |dd           pt          |dd           pd	}t                              d
|dk    rdnd||j        t          |dd          pd|rdnd||d d         t          |	          	  	         t          |dd          pd}|                     |           d {V }|                     ||           d {V }|                     ||                    d          p|pd|                     ||          |d         |d         t          |dd           pd |d         |          }t'          ||||||	|
||t)          j                    
  
        }|                     |           d {V  d S )N/z*[Feishu] Ignoring empty text message id=%sz

	parent_idupper_message_idr   r   r   z	<unknown>z\[Feishu] Inbound %s message received: id=%s type=%s chat_id=%s sender=%s:%s text=%r media=%dr  r  rJ  r   r   r   r  re   r  r   rP  rQ  r  rV  rT  )r   r  r  r   r  rV  rT  r  )
r}   r   rX  rY  r  
media_urlsmedia_typesreply_to_message_idreply_to_textrZ  )_extract_message_contentr2   r_  rY  r&  ro  ri  rj  rL  r  _fetch_message_textrJ  r   r  r  r\  r]  r  r^  r1   r   r`  _dispatch_inbound_event)r   r!  rZ   r  r  r  r  r}   inbound_typer  r  r   r   r  r  sender_primaryr   rR  re  rX  r
  s                        rW   r!  z&FeishuAdapter._process_inbound_message
  sO      GKFcFcdkFlFl@l@l@l@l@l@l=lJX;+++,T8<<Ds## 3*2 ;+++D++LLEzRRRF;...&x00D =.2<$**D*** G[$// w 2D99 	
 Pcld667JKKKKKKKKKhl Iy$// y)T22y*d33 	 	 	j&&DDGGY++1r'EE#J
OO
	
 
	
 
	
 '9b117R,,W55555555	#;;If;UUUUUUUU""mmF++GwG-44yZc4dd"9-$[1g{D99AT&}5 # 	
 	
 "%!!# 3'lnn
 
 

 **:66666666666rY   c                0  K   |j         t          j        k    r1|                                s|                     |           d{V  dS |                     |          r|                     |           d{V  dS |                     |           d{V  dS )zHApply Feishu-specific burst protection before entering the base adapter.N)r   r2   r_  
is_command_enqueue_text_event_should_batch_media_event_enqueue_media_eventra  r   r  s     rW   r  z%FeishuAdapter._dispatch_inbound_event
  s      !111%:J:J:L:L1**5111111111F))%00 	++E222222222F..u55555555555rY   c                    t          |j        o4|j        t          j        t          j        t          j        t          j        hv           S r   )r   r  r   r2   PHOTOVIDEODOCUMENTAUDIOr  s     rW   r  z'FeishuAdapter._should_batch_media_event
  sA     v"{'8+:K[Macnct&uu
 
 	
rY   c                    ddl m}  ||j        | j        j                            dd          | j        j                            dd                    }| d|j        j         S )	Nr   build_session_keygroup_sessions_per_userTthread_sessions_per_userFr  r  z:media:)gateway.sessionr  rX  r  r  r  r   r   )r   r  r  r  s       rW   _media_batch_keyzFeishuAdapter._media_batch_key  s    555555''L$(K$5$9$9:SUY$Z$Z%)[%6%:%:;UW\%]%]
 
 

 @@e&8&>@@@rY   rM  incomingc                    | j         |j         k    o9| j        |j        k    o)| j        |j        k    o| j        j        |j        j        k    S r   )r   r  r  rX  rV  rM  r  s     rW   _media_batch_is_compatiblez(FeishuAdapter._media_batch_is_compatible  sY     !X%:: G,0LLG&(*@@G )X_-FF		
rY   c                  K   |                      |          }| j                            |          }|!|| j        |<   |                     |           d S |                     ||          s<|                     |           d {V  || j        |<   |                     |           d S |j                            |j                   |j                            |j                   |j	        r%| 
                    |j	        |j	                  |_	        |j        |_        |j        r|j        |_        |                     |           d S r   )r  r  r  _schedule_media_batch_flushr  _flush_media_batch_nowr  r  r  r}   _merge_captionrZ  r  )r   r  r  rM  s       rW   r  z"FeishuAdapter._enqueue_media_event#  sS     ##E**.22377/4D',,,S111F..x?? 	--c222222222/4D',,,S111F""5#3444##E$5666: 	K //uzJJHM"_ 	3"'"2H((-----rY   r  c                H    |                      | j        || j                   d S r   )_reschedule_batch_taskr  _flush_media_batchr   r  s     rW   r  z)FeishuAdapter._schedule_media_batch_flush8  s3    ##+#	
 	
 	
 	
 	
rY   c                  K   t          j                    }	 t          j        | j                   d {V  |                     |           d {V  | j                            |          |u r| j                            |d            d S d S # | j                            |          |u r| j                            |d            w w xY wr   )r  current_taskr  r  r  r  r  r  )r   r  r  s      rW   r  z FeishuAdapter._flush_media_batch?  s      +--	?- ?@@@@@@@@@--c222222222.22377<GG/33C>>>>> HGt.22377<GG/33C>>>> Hs   :B :Cc                   K   | j                             |d           }|sd S t                              d|t	          |j                             |                     |           d {V  d S )Nz6[Feishu] Flushing media batch %s with %d attachment(s))r  r  ri  rJ  r  r  ra  r   r  r  s      rW   r  z$FeishuAdapter._flush_media_batch_nowH  s      +//T:: 	FD !!	
 	
 	

 ..u55555555555rY   c                b   K   |                      |d          }t          ||           d {V S )NrB   r  rU   )_guess_remote_extensionr7   )r   r  rU   s      rW   r  z$FeishuAdapter._download_remote_imageS  sC      **9f*EE))==========rY   file_urlr  r  r=  c                 K   ddl m}  ||          st          d|d d                    dd l}|                    dd          4 d {V }|                    |dd	d
           d {V }|                                 t          |j                            dd                    }|j	        }	d d d           d {V  n# 1 d {V swxY w Y   | 
                    ||||          }
t          |	|
          }||
fS )Nr   )is_safe_urlz&Blocked unsafe URL (SSRF protection): P   g      >@T)rW  follow_redirectsz)Mozilla/5.0 (compatible; HermesAgent/1.0)z*/*)z
User-AgentAcceptheadersContent-Typer   )content_typedefault_namer  )tools.url_safetyr  rV  httpxAsyncClientr  raise_for_statusr   r  r~   _derive_remote_filenamer6   )r   r  r  r  r  r  r  r  content_type_hdrr*  filenamecached_paths               rW   r  z'FeishuAdapter._download_remote_documentW  s      	100000{8$$ 	WUhsPRsmUUVVV$$TD$II 	$ 	$ 	$ 	$ 	$ 	$ 	$V#ZZ"M#  (        H %%'''  #8#3#7#7#K#KLL#D	$ 	$ 	$ 	$ 	$ 	$ 	$ 	$ 	$ 	$ 	$ 	$ 	$ 	$ 	$ 	$ 	$ 	$ 	$ 	$ 	$ 	$ 	$ 	$ 	$ 	$ 	$ //)'#	 0 
 
 0h??H$$s   A$C
CCr   rR  c                   t          | pd                    dd          d                   j                                        }|t          t
          z  t          z  t          t                    z  v r|n|S )Nr   ?r  r   )	r   r5  suffixr  _IMAGE_EXTENSIONS_AUDIO_EXTENSIONS_VIDEO_EXTENSIONSr   r5   )r   rR  rU   s      rW   r  z%FeishuAdapter._guess_remote_extension{  so    CI2$$S!,,Q/007==??/2CCFWWZ]^vZwZwwxxss  F  	FrY   r  r  c               v   t          | pd                    dd          d                   j        p|}t          |          j                                        }|s^t          j        |pd                    dd          d                                                                         pd          p|}| | }|S )Nr   r  r  r   ;)r   r5  r   r  r  	mimetypesguess_extensionr0  )r  r  r  r  r  rU   guesseds          rW   r  z%FeishuAdapter._derive_remote_filename  s    (.b//Q77:;;@PL	9oo$**,, 	0/1C0J0J3PQ0R0RST0U0[0[0]0]0c0c0e0e0kikll{p{G$/g//IrY   r   c                    t          | t                    r(t          di d |                                 D             S t          | t                    rd | D             S | S )Nc                J    i | ] \  }}|t                               |          !S rS   r  _namespace_from_mapping)rT   r  r  s      rW   rX   z9FeishuAdapter._namespace_from_mapping.<locals>.<dictcomp>  s0    %v%v%v[d[^`dc=+P+PQU+V+V%v%v%vrY   c                B    g | ]}t                               |          S rS   r  r  s     rW   r   z9FeishuAdapter._namespace_from_mapping.<locals>.<listcomp>  s&    RRRDM99$??RRRrY   rS   )r;  r   r	   r  r   r  s    rW   r   z%FeishuAdapter._namespace_from_mapping  sq    eT"" 	x"ww%v%vhmhshshuhu%v%v%vwwweT"" 	SRRERRRRrY   r  c                  K   t          |dd           pd}| j         d| j         d| }|                     |          sGt                              d|           |                     |d           t          j        dd          S t          |d	i           pi }t          |
                    d
d          pd                              d          d                                                                         }|rN|dk    rHt                              d||           |                     |d           t          j        dd          S t          |dd           }|S|t          k    rHt                              d||           |                     |d           t          j        dd          S 	 t          j        |                                t$                     d {V }n# t          j        $ rP t                              dt$          |           |                     |d           t          j        dd          cY S t(          $ r2 |                     |d           t          j        ddd d!          cY S w xY wt-          |          t          k    rUt                              d"t-          |          |           |                     |d           t          j        dd          S 	 t/          j        |                    d#                    }nK# t.          j        t6          f$ r2 |                     |d           t          j        dd$d d!          cY S w xY w|
                    d%          d&k    r*t          j        d'|
                    d'd          i          S | j        r|
                    d(          pi }	t          |	
                    d)          p|
                    d)          pd          }
|
rt;          j        |
| j                  sGt                              d*|           |                     |d+           t          j        d,d-          S | j        rb|                      |j!        |          sGt                              d.|           |                     |d/           t          j        d,d0          S |
                    d1          rIt          "                    d2           |                     |d3           t          j        dd4d d!          S | #                    |           t          |
                    d(          pi 
                    d5          pd          }| $                    |          }|d6k    r| %                    |           n|d7k    r| &                    |           n|d8k    r| '                    |           n|d9k    r| (                    |           np|d:v r| )                    ||           nU|d;k    r| *                    |           n9|d<k    r| +                    |           nt          ,                    d=|pd           t          j        dd>d           S )?NremoterJ  r  z+[Feishu] Webhook rate limit exceeded for %s429i  zToo Many Requests)r  r}   r  r  r   r  r   application/jsonz=[Feishu] Webhook rejected: unexpected Content-Type %r from %s415i  zUnsupported Media Typecontent_lengthz2[Feishu] Webhook body too large (%d bytes) from %s413i  zRequest body too largerV  z6[Feishu] Webhook body read timed out after %ds from %s408i  zRequest Timeout400i  zfailed to read body)r5  rw  )r  z6[Feishu] Webhook body exceeds limit (%d bytes) from %sutf-8zinvalid jsonr   url_verification	challenger&  r   z=[Feishu] Webhook rejected: invalid verification token from %sz	401-tokeni  zInvalid verification tokenz4[Feishu] Webhook rejected: invalid signature from %sz401-sigzInvalid signatureencryptzL[Feishu] Encrypted webhook payloads are not supported by Hermes webhook modez400-encryptedz,encrypted webhook payloads are not supportedr0  zim.message.receive_v1zim.message.message_read_v1zim.chat.member.bot.added_v1zim.chat.member.bot.deleted_v1)r  r$  zcard.action.triggerr%  z([Feishu] Ignoring webhook event type: %sok)-r  r  r  _check_webhook_rate_limitri  r  r  r   Responser   r  r5  r0  r  _FEISHU_WEBHOOK_MAX_BODY_BYTESr  r_  r  $_FEISHU_WEBHOOK_BODY_TIMEOUT_SECONDSra  rh  json_responser  rb  r  decoder  UnicodeDecodeErrorr  hmaccompare_digestr  _is_webhook_signature_validr  rD  r  r   r*  r(  r0  r2  r  r.  r8  rj  )r   r  r  rate_keyr  r  r  
body_bytesr|  r&  incoming_tokenr0  r!  s                rW   _handle_webhook_requestz%FeishuAdapter._handle_webhook_request  s     Wh55B	 lEET%7EE)EE--h77 	FNNH)TTT((E:::<s1DEEEE '9b117R7;;~r::@bAAGGLLQOUUWW]]__ 	KL,>>>NNZ\hjsttt((E:::<s1IJJJJ !*:DAA%.;Y*Y*YNNOQ_ajkkk((E:::<s1IJJJJ	^&-&6<' ' ' ! ! ! ! ! !JJ # 	D 	D 	DNNSUy  |E  F  F  F((E:::<s1BCCCCCC 	^ 	^ 	^((E:::$c:O%P%PY\]]]]]]	^ z??;;;NNSUXYcUdUdfoppp((E:::<s1IJJJJ	Wj!2!27!;!;<<GG$&89 	W 	W 	W((E:::$c.%I%IRUVVVVVV	W ;;v"444$k7;;{B3O3O%PQQQ # 	S[[**0bF G!4!4!RG8L8L!RPRSSN! S)<^TMe)f)f S^`ijjj,,YDDD|35QRRRR  	FT%E%EgoWa%b%b 	FNNQS\]]]((I>>><s1DEEEE;;y!! 	wLLghhh((ODDD$c:h%i%iruvvvv##I...'++h//52::<HHNBOO
++G44000""4((((777''----888&&t,,,,:::**40000___##J5555000((....888((....LLCZE\S\]]] !D!9!9:::s,   23G& &AI?8I?>I?0'L AM M r  r  bytesc                4   t          |                    dd          pd          }t          |                    dd          pd          }t          |                    dd          pd          }|r|r|sdS 	 |                    dd          }| | | j         | }t	          j        |                    d                                                    }t          j	        ||          S # t          $ r  t                              d	d
           Y dS w xY w)a  Verify 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.
        zx-lark-request-timestampr   zx-lark-request-noncezx-lark-signatureFr  r1  )errorsz3[Feishu] Signature verification raised an exceptionTrb  )r   r  r  r  hashlibsha256encode	hexdigestr  r  rh  ri  rj  )	r   r  r  rZ  noncerK  body_strr~   computeds	            rW   r  z)FeishuAdapter._is_webhook_signature_valid  s0    $>CCIrJJ	GKK 6;;ArBB$6;;ArBB	 	 	Y 	5	!(((CCH"HEH4+<HhHHG~gnnW&=&=>>HHJJH&x;;; 	 	 	LLNY]L^^^55	s   9A3C- -&DDr  c                   t          j                     | j                            |          }|1|\  }}|z
  t          k     r|t          k    rdS |dz   |f| j        |<   dS t          | j                  t          k    rZfd| j                                        D             }|D ]
}| j        |= || j        vrt          | j                  t          k    rdS df| j        |<   dS )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.
        NFr  Tc                <    g | ]\  }\  }}|z
  t           k    |S rS   )#_FEISHU_WEBHOOK_RATE_WINDOW_SECONDS)rT   k_r  r`  s       rW   r   z;FeishuAdapter._check_webhook_rate_limit.<locals>.<listcomp>  s;        a!R8BBB BBBrY   )r  r  r  r*  _FEISHU_WEBHOOK_RATE_LIMIT_MAXr  _FEISHU_WEBHOOK_RATE_MAX_KEYSr  )r   r  r  r  window_start
stale_keysr+  r`  s          @rW   r  z'FeishuAdapter._check_webhook_rate_limit  s    ikk)--h77"'E<\!$GGG::: 57<qy,6O)(3tt())-JJJ   $($=$C$C$E$E  J   1 1-a00t888SAZ=[=[_|=|=|t/0#h!(+trY   c                    ddl m}  ||j        | j        j                            dd          | j        j                            dd                    S )z?Return the session-scoped key used for Feishu text aggregation.r   r  r  Tr  Fr  )r  r  rX  r  r  r  )r   r  r  s      rW   _text_batch_keyzFeishuAdapter._text_batch_key,  sg    555555  L$(K$5$9$9:SUY$Z$Z%)[%6%:%:;UW\%]%]
 
 
 	
rY   c                v    | j         |j         k    o)| j        |j        k    o| j        j        |j        j        k    S )z>Only merge text events when reply/thread context is identical.)r  r  rX  rV  r  s     rW   _text_batch_is_compatiblez'FeishuAdapter._text_batch_is_compatible6  sC     (H,HH G&(*@@G)X_-FF	
rY   c                  K   |                      |          }t          |j        pd          }| j                            |          }|2||_        || j        |<   d| j        |<   |                     |           dS |                     ||          sF| 	                    |           d{V  || j        |<   d| j        |<   |                     |           dS | j                            |d          }|dz   }|j        pd}|j        r|r|j         d| n|j        p|}|| j
        k    st          |          | j        k    rF| 	                    |           d{V  || j        |<   d| j        |<   |                     |           dS ||_        ||_        |j        |_        |j        r|j        |_        || j        |<   |                     |           dS )z=Debounce rapid Feishu text bursts into a single MessageEvent.r   Nr  r.  )r2  r  r}   r  r  _last_chunk_lenr  _schedule_text_batch_flushr4  _flush_text_batch_nowr  r  rZ  r  )	r   r  r  	chunk_lenrM  existing_count
next_countappended_text	next_texts	            rW   r  z!FeishuAdapter._enqueue_text_event?  s)     ""5))
(b))	-11#66$-E!.3D&s+34D+C0++C000F--h>> 	,,S111111111.3D&s+34D+C0++C000F8<<S!DD#a'

(b;C=  A]  Ax}77777aianar	555Y$Jd9d9d,,S111111111.3D&s+34D+C0++C000F!#, "_ 	3"'"2H/9','',,,,,rY   c                H    |                      | j        || j                   dS )z9Reset the debounce timer for a pending Feishu text batch.N)r  r  _flush_text_batchr  s     rW   r7  z(FeishuAdapter._schedule_text_batch_flushe  s3    ##*"	
 	
 	
 	
 	
rY   task_mapflush_fnc                    |                      |          }|r(|                                s|                                 t          j         ||                    | |<   d S r   )r  r{  r  r  create_task)r@  r  rA  
prior_tasks       rW   r  z$FeishuAdapter._reschedule_batch_taskm  s`     \\#&&
 	 joo// 	 +HHSMM::rY   c                  K   t          j                    }	 | j                            |          }|rt	          |dd          nd}|| j        k    r| j        }n| j        }t          j        |           d{V  | 	                    |           d{V  | j
                            |          |u r| j
                            |d           dS dS # | j
                            |          |u r| j
                            |d           w w xY w)zFlush a pending text batch after the quiet period.

        Uses a longer delay when the latest chunk is near Feishu's ~4096-char
        split point, since a continuation chunk is almost certain.
        r6  r   N)r  r  r  r  r  _SPLIT_THRESHOLDr  r  r  r8  r  r  )r   r  r  r  last_lendelays         rW   r?  zFeishuAdapter._flush_text_batchx  s<      +--	> 044S99GAHOww(91===aH4000<6-&&&&&&&&&,,S111111111-11#66,FF.223===== GFt-11#66,FF.223==== Gs   A>C :D
c                  K   | j                             |d          }| j                            |d           |sdS t                              d|t          |j        pd                     |                     |           d{V  dS )z,Dispatch the current text batch immediately.Nz*[Feishu] Flushing text batch %s (%d chars)r   )r  r  r  ri  rJ  r  r}   ra  r  s      rW   r8  z#FeishuAdapter._flush_text_batch_now  s      *..sD99'++C666 	F8
 b!!	
 	
 	

 ..u55555555555rY   Etuple[str, MessageType, List[str], List[str], List[FeishuMentionRef]]c           	       K   t          |dd          pd}t          |dd          pd}t          t          |dd          pd          }t                              d||           t	          ||t          |dd           |                                           }|                     ||           d {V \  }}|                     ||          }|j        }	|t          j
        t          j        t          j        t          j        hv rHt          |          d	k    r5|j        d
v r,|                     |d         |d                    d {V }
|
r|
}	|	|||t#          |j                  fS )Nr~   r   r   r  z3[Feishu] Received raw message type=%s message_id=%sr   r   r  r   r   )r  r
  r  >   r  r  r   )r  r   ri  rJ  r  _bot_identity"_download_feishu_message_resources _resolve_normalized_message_typer   r2   r  r  r  r  r  r   _maybe_extract_text_documentr   r   )r   rZ   r  r   r  r
  r  r  r  r}   injecteds              rW   r  z&FeishuAdapter._extract_message_content  s      gy"55;7NB77=2,;;ArBB
I8U_```-!#Wj$77""$$	
 
 

 )-(O(O!! )P )
 )
 #
 #
 #
 #
 #
 #

K <<ZUU& [1;3DkFWYdYjkkkJ1$$15JJJ!>>z!}kZ[n]]]]]]]]H  \:{DAT<U<UUUrY   r
  r   tuple[List[str], List[str]]c                 K   g }g }|j         D ]N}|                     ||           d {V \  }}|r*|                    |           |                    |           O|j        D ]_}|                     ||j        |j        |j                   d {V \  }}|r*|                    |           |                    |           `||fS )N)r  r   )r  r   r   fallback_filename)r   _download_feishu_imagerm  r   !_download_feishu_message_resourcer   r   r   )	r   r  r
  r  r  r   r  
media_typer  s	            rW   rN  z0FeishuAdapter._download_feishu_message_resources  s>      !#
!##. 	/ 	/I,0,G,G%# -H - - ' ' ' ' ' '#K  /!!+..."":...#. 		/ 		/I,0,R,R%"+'5"+"5	 -S - - ' ' ' ' ' '#K  /!!+..."":...;&&rY   rW  r2   c                   | pd                                 }|                    d          rt          j        S |                    d          rt          j        S |                    d          rt          j        S |S )Nr   image/audio/video/)r  r&  r2   r  r  r  )rW  rR  r
  s      rW   _resolve_media_message_typez)FeishuAdapter._resolve_media_message_type  sz     &B--//
  ** 	%$$  ** 	%$$  ** 	%$$rY   r  r   c                N   |j         }|dk    r+|                     |r|d         ndt          j                  S |dk    r+|                     |r|d         ndt          j                  S |dk    r+|                     |r|d         ndt          j                  S t          j        S )Nr  r   r   r  r  r  )r   r\  r2   r  r  r  r_  )r   r
  r  	preferreds       rW   rO  z.FeishuAdapter._resolve_normalized_message_type  s    
 5	33k4YKNNWYcnct3uuu33k4YKNNWYcnct3uuu
""33k4YKNNWYcncw3xxxrY   r  c                  K   |r|                     d          sdS 	 t          j                            |          t          k    rdS t          |          j                                        }|dvr|dvrdS t          |                              d          }| 	                    |          }d| d| S # t          t          f$ r! t                              d	|d
           Y dS w xY w)Nztext/r   >   .md.txt>   
text/plaintext/markdownr  encodingz[Content of z]:
z7[Feishu] Failed to inject text document content from %sTrb  )r&  r  r  getsize_MAX_TEXT_INJECT_BYTESr   r  r  	read_text_display_name_from_cached_pathOSErrorr  ri  r  )r   r  rW  rU   r~   r  s         rW   rP  z*FeishuAdapter._maybe_extract_text_document  s      	*"7"7"@"@ 	2	w{++.DDDr{##*0022C/))j@_._._r;''1171CCG>>{KKL=,==G===+, 	 	 	NNTValpNqqq22	s   (B7 .B7 7?B7 7.C)(C)r   c          
       K   | j         r|sdS 	 |                     ||d          }t          j        | j         j        j        j        j        |           d {V }|r|                                s=t          
                    d|t          |dd          t          |dd                     dS |                     |          }|sdS |                     |d	          }t          |d
d           p| d}|                     ||dt                    }t!          ||          }	|                     ||                     |                    }
|	|
fS # t&          $ r! t          
                    d|d           Y dS w xY w)NrA  r  r  r   r   z+[Feishu] Failed to download image %s: %s %sr5  rJ  rw  request failedr  r   rB   allowedr  r  z*[Feishu] Failed to cache image resource %sTrb  )r  _build_message_resource_requestr  r  r  r  message_resourcer  ru  ri  r  r  _read_binary_response_get_response_header_guess_extensionr  r9   _normalize_media_type_default_image_media_typerh  )r   r  r   r  r  	raw_bytesr  r  rU   r  rW  s              rW   rU  z$FeishuAdapter._download_feishu_image  s     | 	: 	6	::%"% ;  G
 %.t|/A/R/VX_````````H 8#3#3#5#5 AHfi88He-=>>	   v228<<I v44X~NNLxd;;Q)?Q?Q?QH'',Pa'bbC0DDDK33L$JhJhilJmJm3nnJ
** 	 	 	NNG]aNbbb66	s   BE .E BE 'E;:E;r   r   rT  c                 K   | j         r|sdS |g}|dv r|                    d           |D ]}	 |                     |||          }t          j        | j         j        j        j        j        |           d {V }|r|	                                s>t                              d|||t          |dd          t          |dd	                     |                     |          }	|	s|                     |d
          }
t          |dd           pd}|p|p| d| }|                     |
|                     |                    }|                    d          re|                     ||
dt&                    }t)          |	|          }t                              d|           ||p|                     |          fc S |dk    s|                    d          rj|                     ||
dt.                    }t1          |	|          }t                              d|           ||pd|                    d          pd fc S |                    d          rJt5          |          j        s| d}t9          |	|          }t                              d|           ||fc S t5          |          j        s|t:          v r| t:          |          }t9          |	|          }t                              d|           ||p|                     |          fc S # t>          $ r" t                               d||d            Y w xY wdS )!NrA  >   r  r  r   rl  z>[Feishu] Resource download failed for %s/%s via type=%s: %s %sr5  rJ  rw  rm  r  r   r   r,  r  rY  rB   rn  r  z,[Feishu] Cached message image resource at %sr  rZ  rI   z,[Feishu] Cached message audio resource at %sr@  oggr[  rQ   z,[Feishu] Cached message video resource at %sz/[Feishu] Cached message document resource at %sz/[Feishu] Failed to cache message resource %s/%sTrb  )!r  rm  rp  r  r  r  r  rq  r  ru  ri  rj  r  rr  rs  ru  _guess_media_type_from_filenamer&  rt  r  r9   rJ  rv  r  r8   rO  r   r  r6   _DOCUMENT_MIME_TO_EXT_guess_document_media_typerh  r  )r   r  r   r   rT  request_typesrequest_typer  r  rw  r  response_filenamer  rW  rU   r  s                   rW   rV  z/FeishuAdapter._download_feishu_message_resource&  s      | 	: 	6&...  ((() <	 <	L;>>)%". ?  
 ")!24<?3E3V3Z\c!d!ddddddd 	x'7'7'9'9 	LLX" $&)<<%1ABB    66x@@	  #88>RR$+Hk4$H$H$NB!,a0AaEaEaW_EaEa!77  @@JJ 8  

 ((22 Z//,Xi/jjC"8"L"L"LKKK NP[\\\&
(Yd6T6TUX6Y6YYYYY7**j.C.CH.M.M*//,Xi/jjC"8"L"L"LKKK NP[\\\&)Z7Z

3@XSX7Z7Z[[[[((22 3>>0 5&.#4#4#4";Ix"P"PKKK NP[\\\&
2222H~~, P?T1T1T"*O,A*,MOOH7	8LLM{[[["Z%\43R3RS[3\3\]]]]   E!	       vs4   BLL(CL BLAL$A1L(MMr  c                    t          | dd           }|dS t          |d          r!t          |                                          S t          |                                          S )Nr   rY   getvalue)r  hasattrr  r  r  )r  file_objs     rW   rr  z#FeishuAdapter._read_binary_responsex  s`    8VT2238Z(( 	.**,,---X]]__%%%rY   r   c           	     \   t          | dd           }t          |di           pi }t          |                    ||                    |                                d                    pd                              dd          d                                                                         S )NrF  r  r   r  r  r   )r  r   r  r  r5  r0  )r  r   rF  r  s       rW   rs  z"FeishuAdapter._get_response_header  s    ht,,#y"--37;;tW[[r%B%BCCIrJJPPQTVWXXYZ[aacciikkkrY   r  ro  r   c                  t          | pd          j                                        }||v r|S t          j        |pd                    dd          d                                                                         pd          }||v r|S |S Nr   r  r  r   )r   r  r  r  r  r5  r0  )r  r  rR  ro  rU   r  s         rW   rt  zFeishuAdapter._guess_extension  s    8>r"")//11'>>J+\-?R,F,FsA,N,Nq,Q,W,W,Y,Y,_,_,a,a,geghhgNrY   c                   | pd                     dd          d                                                                         }|p|S r  )r5  r0  r  )r  rR  r
  s      rW   ru  z#FeishuAdapter._normalize_media_type  sD    "(b//Q77:@@BBHHJJ
$W$rY   c                    t          | pd          j                                        }t          j        |t          j        | pd          d         pd          S )Nr   r   zapplication/octet-stream)r   r  r  r5   r  r  
guess_type)r  rU   s     rW   r|  z(FeishuAdapter._guess_document_media_type  sQ    8>r"")//11'+C1EhnRT1U1UVW1X1v\vwwwrY   r  c                    t           j                            |           }|                    dd          }t	          |          dk    r|d         n|}t          j        dd|          S )Nr,  rH  r`   z	[^\w.\- ])r  r  r  r5  r  r$  r  )r  r  r  r  s       rW   ri  z,FeishuAdapter._display_name_from_cached_path  sY    7##D))sA&&#&u::??uQxxvlC666rY   c                   t          j        | pd          d         pd                                }|r|S t          | pd          j                                        }|t
          v rd|                    d           S |t          v rd|                    d           S |t          v rt          
                    |          S dS )Nr   r   r[  r@  rZ  )r  r  r  r   r  r  rO  r  r  r  rv  )r  r  rU   s      rW   rz  z-FeishuAdapter._guess_media_type_from_filename  s    'B77:@bGGII 	N8>r"")//11###-CJJsOO---###-CJJsOO---### ::3???rrY   r  c                    | pd                                                                 }|dk    rdS d|v sd|v sd|v rdS |dk    rdS dS )Nr   r  r  topicthreadforumrJ  )r0  r  )r  r
  s     rW   r  zFeishuAdapter._map_chat_type  sm    #)r002288::
4j  H
$:$:g>S>S7  7trY   rR  rS  c                    t          |                     d          pd                                                                          }|dv r|S |dk    rdS dS )Nr   r   >   r  rJ  r  r  rJ  )r   r  r0  r  )rR  rS  r  s      rW   r^  z'FeishuAdapter._resolve_source_chat_type  s^    y}}V,,23399;;AACC)))Oe##4wrY   Dict[str, Optional[str]]c                  K   t          |dd          pd}t          |dd          pd}t          |dd          pd}|p|}|r|n|p|}|                     ||           d{V }|||dS )uC  Map 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.
        r   Nr   r   r  )r   r  rT  )r  _resolve_sender_name_from_api)	r   r  r  r   r   r   
primary_idname_lookup_idr  s	            rW   r\  z%FeishuAdapter._resolve_sender_profile  s      " )Y55=)Y55=9j$77?4'
$*H1Gx!??6 @ 
 
 
 
 
 
 
 
 "%#
 
 	
rY   c                    |sdS | j                             |          }|dS |\  }}t          j                    |k     r|S | j                             |d           dS )z>Return a cached sender name only while its TTL is still valid.N)r  r  r  r  )r   r  r  r   	expire_ats        rW   rG  z%FeishuAdapter._get_cached_sender_name  sl     	4(,,Y77>4 i9;;""K##It444trY   c                 K   |r| j         sdS |                                }|sdS t          j                    }|                     |          }||pdS |rx|                     |g           d{V }|dS |t
          z   }|                                D ]\  }}	|	|f| j        |<   | j                            |          }
|
r
|
d         pdndS 	 ddl	m
} |                    d          rd}n|                    d          rd}nd}|                                                    |                              |                                          }t!          j        | j         j        j        j        j        |           d{V }|r|                                sdS t-          t-          |d	d          d
d          }t-          |dd          p2t-          |dd          p!t-          |dd          pt-          |dd          }	|	rAt/          |	t0                    r,|	                                }	|	r|	|t
          z   f| j        |<   |	S n-# t2          $ r  t4                              d|d           Y nw xY wdS )u   Bots divert to bot/basic_batch — contact API doesn't return bot names.
        Failures are silent so the pipeline never blocks on name resolution.
        Nr   )GetUserRequestou_r   on_r   r   r!  r  r   r  nicknameen_namez-[Feishu] Failed to resolve sender name for %sTrb  )r  r0  r  rG  _fetch_bot_names_FEISHU_SENDER_NAME_TTL_SECONDSr  r  r  lark_oapi.api.contact.v3r  r&  r&  r   user_id_typer9  r  r  contactv3r  ru  r  r;  r   rh  ri  rj  )r   r  r  trimmedr`  cached_namenamesr  oidr   hitr  r@  r  r  r  s                   rW   r  z+FeishuAdapter._resolve_sender_name_from_api  s       	 	4//## 	4ikk227;;"&$& 	5//	::::::::E}t==I"[[]] A A	T04i/@',,)--g66C'*4CFNd4	d??????!!%(( $###E** $$#$,,..66w??LLWUU[[]]G$.t|/C/F/K/OQXYYYYYYYYH 8#3#3#5#5 t78VT::FDIIDfd++ 246624T222 4D11	    
4--  zz||  8<cDc>c7dD+G4K 	d 	d 	dLLH)^bLccccc	dts   CI B&I 'I10I1bot_idsOptional[Dict[str, str]]c                  K   | j         r|sd S 	 t          j                                        t          j                                      d                              d |D                                           t          j
        h                                          }t          j        | j         j        |           d {V }t          t          |dd           dd           }|sd S t!          j        |          }|                    d          dk    rd S |                    d          pi                     d          pi }d	 |                                D             S # t(          $ r! t*                              d
|d           Y d S w xY w)Nz"/open-apis/bot/v3/bots/basic_batchc                    g | ]}d |fS )r  rS   )rT   r  s     rW   r   z2FeishuAdapter._fetch_bot_names.<locals>.<listcomp>1  s    >>>s9c*>>>rY   rF  r~   r5  r   r!  botsc                    i | ]>\  }}||t          |                    d           pd                                          ?S )r   r   )r   r  r0  )rT   r  rJ  s      rW   rX   z2FeishuAdapter._fetch_bot_names.<locals>.<dictcomp>=  sY       CS&))/R006688  rY   z)[Feishu] Failed to fetch bot names for %sTrb  )r  r)   r&  http_methodr&   GETuriqueriestoken_typesr%   TENANTr9  r  r  r  r  rb  r  r  r  rh  ri  rj  )r   r  reqrespr~   r|  r  s          rW   r  zFeishuAdapter._fetch_bot_names)  s     | 	7 	4	#%%Z^,,9::>>g>>>??o4566  !*4<+?EEEEEEEEDgdE488)TJJG tj))G{{6""a''tKK''-2226::@bD !%   
  	 	 	LLDgX\L]]]44	s   CE! (-E! A	E! !'FFc                2  K   | j         r|sd S || j        v r| j        |         S 	 |                     |          }t          j        | j         j        j        j        j        |           d {V }|r t          |dd                       du rAt          |dd          }t          |dd          }t                              d|||           d S t          t          |d	d           d
d           pg }|r|d         nd }t          |dd           }t          |dd          pd}	t          |dd          pd}
|rt          |dd           nd }|                     |	|
|          }|| j        |<   |S # t          $ r! t                              d|d           Y d S w xY w)Nru  c                     dS r  rS   rS   rY   rW   rL  z3FeishuAdapter._fetch_message_text.<locals>.<lambda>N  r  rY   Fr5  rJ  rw  zmessage lookup failedz3[Feishu] Failed to fetch parent message %s: [%s] %sr!  r  r   r*  r   r   r~   r   )r   r  r   z*[Feishu] Failed to fetch parent message %sTrb  )r  r  r[  r  r  r  r  rZ   r  r  ri  r  _extract_text_from_raw_contentrh  )r   r  r  r  r5  rw  r  parentr*  r   r  parent_mentionsr}   s                rW   r  z!FeishuAdapter._fetch_message_textF  s     | 	: 	4111+J77	55jAAG$.t|/A/I/MwWWWWWWWWH JwxMMJJLLPUUUx;;h/FGGTV`bfhkllltGHfd;;WdKKQrE!&0U1XXDF66400Dvz266<"H!$	266<"KCISgfj$???tO66!'( 7  D
 48D$Z0K 	 	 	NNG^bNccc44	s   B&E+ BE+ +'FF)r   r   r  r   r  c                  t          ||||                                           }|j        r|j        S t          |j        t
                    r|j                            d          nd }t          |                                          pd S )NrL  r  )	r  rM  r   r;  r   r   r  r   r0  )r   r   r  r   r
  r   s         rW   r  z,FeishuAdapter._extract_text_from_raw_contentd  s     .!#""$$	
 
 

 " 	+**EOPZPceiEjEjtj)--.@AAApt;%%''/4/rY   rU   c                n    | pd                                 }|dv rdS d|                    d          pd S )Nr   >   rB   rC   z
image/jpegrY  r@  jpeg)r  rO  )rU   normalized_exts     rW   rv  z'FeishuAdapter._default_image_media_typev  sI    )**,,...<>--c22<f>>>rY   r
  c                    	 |                                   d S # t          $ r t                              d           Y d S w xY w)Nz-[Feishu] Background inbound processing failed)rG  rh  ri  	exception)r
  s    rW   r  z%FeishuAdapter._log_background_failure}  sV    	NMMOOOOO 	N 	N 	NLMMMMMM	Ns    $A A r   Optional[RejectReason]c                    t          |          }t          d | j        | j        fD                       }t	          |          }t          |dd          dk    }t          |dd          pd}|o|                     |          }|r||z  rdS |r:| j        }	|	dk    r|	dk    rd	S |r|sd
S |	dk    r|s|                     |          sdS |sd S | 	                    t          |dd           ||          sdS |r|                     |          sdS d S )Nc              3     K   | ]}||V  	d S r   rS   r  s     rW   r	  z'FeishuAdapter._admit.<locals>.<genexpr>  s(      TT1RSTQTTTTTTrY   r  r  r   r   r   r   r  r   r   r   r  r  r   )
r  r   r  r  r  r  _require_mention_forr  _mentions_self_allow_group_message)
r   r   rZ   
sender_idsself_idsr  is_groupr   r   modes
             rW   r   zFeishuAdapter._admit  sx   %f--
TT):D<M(NTTTTT''7K775@'9b117R"It'@'@'I'I  	
X- 	; 
	+#Dz!!demm& *: *)) z!!/!$BUBUV]B^B^!** 	4((FK.. ) 
 
 	+ +* 	+4#6#6w#?#? 	+**trY   c                l    |r| j                             |          nd }|r|j        |j        S | j        S r   )r  r  r   r  )r   r   rules      rW   r  z"FeishuAdapter._require_mention_for  sD    18Bt $$W---d 	(D(4''$$rY   r   c                  t          |dd          }t          |dd          }||hdhz
  }|r| j        r|| j        z  rdS |r| j                            |          nd}|r|j        }|j        }	|j        }
n#| j        p| j        }| j	        }	t                      }
|dk    rdS |dk    rdS |dk    rdS |rdS |d	k    rt          |o||	z            S |d
k    rt          |o||
z             S t          |o	|| j	        z            S )z)Per-group policy gate for non-DM traffic.r   Nr   TdisabledFr  
admin_onlyr   r   )r  r
  r  r  r   r   r   r  r  r	  r   r   )r   r  r   r  sender_open_idsender_user_idr  r  r   r   r   s              rW   r  z"FeishuAdapter._allow_group_message  s^    !It<< It<<$n5>
 	$, 	J,E 	418Bt $$W---d 	[FIII/E43EF1II Z5V4\!!5 	4[  
?
Y(>@@@[  
CJ,B'CDDDJKJ1J$JLLLrY   c           	     J   t          |dd          pd}d|v rdS t          |dd           pg }|r|                     |          rdS t          t          |dd          pd|t          |dd           |                                           }|                     |j                  S )Nr~   r   r  Tr   r   rL  )r  _message_mentions_botr  rM  _post_mentions_botr   )r   rZ   r  r   r
  s        rW   r  zFeishuAdapter._mentions_self  s    gy"55;k!!47J55; 	228<< 	4- ."==C#Wj$77""$$	
 
 

 &&z':;;;rY   	List[Any]c                   |D ]}t          |dd           }t          |dd           pd                                }t          |dd           pd                                }t          |dd           pd                                }|r| j        r|| j        k    r dS |r| j        r|| j        k    r dS | j        r|| j        k    r dS dS )Nr?  r   r   r   r   TF)r  r0  r  r  r  )r   r   r<  rB  mention_open_idmention_user_idmention_names          rW   r  z#FeishuAdapter._message_mentions_bot  s      	 	G $55J&z9dCCIrPPRRO&z9dCCIrPPRRO#GVT::@bGGIIL 4#4 "d&77744 4#4 "d&77744~ ,$."@"@tturY   r   c                4    t          d |D                       S )Nc              3  $   K   | ]}|j         V  d S r   )r   )rT   rK  s     rW   r	  z3FeishuAdapter._post_mentions_bot.<locals>.<genexpr>	  s$      //19//////rY   )any)r   r   s     rW   r  z FeishuAdapter._post_mentions_bot  s    //h//////rY   r   c                D    t          | j        | j        | j                  S )NrF  )r   r  r  r  r:  s    rW   rM  zFeishuAdapter._bot_identity  s*    !%%
 
 
 	
rY   c                  K   | j         sdS | j        r	| j        rdS | j        r| j        s	 t          j                                        t          j                                      d          	                    t          j        h                                          }t          j        | j         j        |           d{V }t!          t!          |dd          dd          }|rt#          j        |          }t'          |          pi }|                    d          pd                                }|                    d          pd                                }|r| j        s|| _        |r| j        s|| _        n,# t,          $ r t.                              dd	
           Y nw xY w| j        rdS 	 |                     | j        d          }t          j        | j         j        j        j        j        |           d{V }	|	r|	                                s3t!          |	dd          }
|
dk    rt.                              d           dS t!          t!          |	dd          dd          }t!          |dd          pd                                }|r| j        s|| _        dS dS dS # t,          $ r  t.                              dd	
           Y dS w xY w)uG  Best-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). Falls back to
        the application info endpoint for ``_bot_name`` only when the first probe
        doesn't return it. Each field is hydrated independently — a value already
        supplied via env vars (FEISHU_BOT_OPEN_ID / FEISHU_BOT_USER_ID /
        FEISHU_BOT_NAME) is preserved and skips its probe.
        N/open-apis/bot/v3/inforF  r~   r   r   r   z3[Feishu] /bot/v3/info probe failed during hydrationTrb  r{   r   r@  r5  ixz[Feishu] Unable to hydrate bot name from application info. Grant admin:app.info:readonly or application:application:self_manage so group @mention gating can resolve the bot name precisely.r!  r  app_namez9[Feishu] Failed to hydrate bot name from application info)r  r  r  r)   r&  r  r&   r  r  r  r%   r  r9  r  r  r  r  rb  r  _parse_bot_responser  r0  rh  ri  rj  _build_get_application_requestr  applicationv6ru  r  )r   r  r  r~   r|  rX  r   r   r  r  r5  r  r  s                rW   _hydrate_bot_identityz#FeishuAdapter._hydrate_bot_identity  s3      | 	F 	 	 F
   	 	')) [00S122 [/"8!9::UWW  %.t|/CSIIIIIIII!'$t"<"<iNN 2"j11G099?RF%zz-88>BEEGGG &

: 6 6 <"CCEEH 4t'8 4,3) 2 2)1   I!       > 	F	e99T[9\\G$.t|/G/J/V/Z\cddddddddH 8#3#3#5#5 x668##NNW  
 '(FD995$GGCZ66<"CCEEH * *!)* * * * 	e 	e 	eLLT_cLdddddd	es,   EE> >&F'&F'4BJ( AJ( (&KKc                ,   	 t          j        | j                            d                    }nK# t          $ r Y d S t
          t           j        f$ r& t                              d| j        d           Y d S w xY wt          |t                    r|                    di           ni }t          j                    t          t          |t                    rd |D             }n6t          |t                    rd |                                D             }nd S fd	|                                D             t!          fd
d          d | j                 }t          t%          |                    | _        fd|D             | _        d S )Nr  rd  z5[Feishu] Failed to load persisted dedup state from %sTrb  message_idsc                    i | ]E}t          |                                          #t          |                                          d FS )r  r  r  s     rW   rX   z8FeishuAdapter._load_seen_message_ids.<locals>.<dictcomp>j  sE    (k(k(kDY\]aYbYbYhYhYjYj(kT):):C(k(k(krY   c                    i | ]>\  }}t          |t                    |                                .|t          |          ?S rS   )r;  r   r0  r   )rT   r+  r  s      rW   rX   z8FeishuAdapter._load_seen_message_ids.<locals>.<dictcomp>l  sF    eeetq!JqRUDVDVe[\[b[b[d[deq%((eeerY   c                F    i | ]\  }}|d k    sdk    s	|z
  k     ||S )r  r   rS   )rT   msg_idrj  r`  ttls      rW   rX   z8FeishuAdapter._load_seen_message_ids.<locals>.<dictcomp>q  sD     #
 #
 #
%62SyyC1HHb3 B(6rY   c                    |          S r   rS   )r+  valids    rW   rL  z6FeishuAdapter._load_seen_message_ids.<locals>.<lambda>v  s    q rY   )r  reversec                "    i | ]}||         S rS   rS   )rT   r+  r  s     rW   rX   z8FeishuAdapter._load_seen_message_ids.<locals>.<dictcomp>x  s    !B!B!B!!U1X!B!B!BrY   )rb  r  r  rh  FileNotFoundErrorrj  r  ri  r  r;  r   r  r  _FEISHU_DEDUP_TTL_SECONDSr   r  sortedr  reversedr  r  )r   r|  	seen_datar  
sorted_idsr`  r  r  s        @@@rW   r  z$FeishuAdapter._load_seen_message_ids]  s   	j!7!A!A7!A!S!STTGG  	 	 	FF-. 	 	 	NNRTXTjuyNzzzFF	 7A$6O6OWGKKr222UW	ikk'i&& 	(k(kI(k(k(kGG	4(( 	eey/@/@eeeGGF#
 #
 #
 #
 #
)0#
 #
 #

 E'9'9'9'94HHHI`$J`I`a
#'(<(<#=#= !B!B!B!Bz!B!B!Bs   -3 
A; 7A;:A;c                *    	  j         j                            dd            j         j         d          }d fd|D             i}t           j         |d            d S # t          $ r& t                              d j         d           Y d S w xY w)NT)parentsexist_okr  c                >    i | ]}|j         v |j         |         S rS   )r  )rT   r+  r   s     rW   rX   z;FeishuAdapter._persist_seen_message_ids.<locals>.<dictcomp>  s2    &s&s&sWX\`\rWrWrq$*@*CWrWrWrrY   )indentz,[Feishu] Failed to persist dedup state to %srb  )	r  r  mkdirr  r  r=   rj  ri  r  )r   recentr|  s   `  rW   rc  z'FeishuAdapter._persist_seen_message_idsz  s    	r")//t/LLL-t/E.E.F.FGF$&s&s&s&sV&s&s&stGd4gdKKKKKK 	r 	r 	rNNI4KalpNqqqqqq	rs   AA" ",BBc                <   t          j                     }t          }| j        5  | j                            |          }||dk    s	||z
  |k     r	 d d d            dS || j        |<   | j                            |           t          | j                  | j        k    rR| j        	                    d          }| j        	                    |d            t          | j                  | j        k    R| 
                                 	 d d d            dS # 1 swxY w Y   d S )Nr   TF)r  r  r  r  r  r  rm  r  r  r  rc  )r   r  r`  r  seen_atstales         rW   r  zFeishuAdapter._is_duplicate  s|   ikk' 	 	,00<<G"qC'MC4G4G	 	 	 	 	 	 	 	
 25D":.$++J777d.//$2HHH044Q77&**5$777 d.//$2HHH **,,,	 	 	 	 	 	 	 	 	 	 	 	 	 	 	 	 	 	s   -DB(DDDc                    t                               |          rdt          |          fS d|i}dt          j        |d          fS )Nr  r}   Fr_  )_MARKDOWN_HINT_REr~  re  rb  rc  )r   r~   text_payloads      rW   r{  z%FeishuAdapter._build_outbound_payload  sQ    ##G,, 	A7@@@@(tz,UCCCCCrY   r   )r  r   r  r  c               @  K   | j         st          dd          S t          j                            |          st          dd|           S |pt          j                            |          }|                     ||          \  }	}
	 t          |d          5 }|                     |	||          }| 	                    |          }t          j        | j         j        j        j        j        |           d {V }d d d            n# 1 swxY w Y   |                     |d          }|s|                     |d	d
          S |r<d||d}|                     |d|                     ||          ||           d {V }n6|                     ||
t)          j        d|id          ||           d {V }|                     |d          S # t.          $ rF}t0                              d||d           t          dt5          |                    cY d }~S d }~ww xY w)NFrs  rt  zFile not found: )r  requested_message_typer  	file_typer   r   r   zfile upload failedz#Feishu file upload missing file_keyr  r  )r   r   r   r  r  rv  r_  zfile send failedz#[Feishu] Failed to send file %s: %sTrb  )r  r4   r  r  r  r  _resolve_outbound_file_routingr  _build_file_upload_body_build_file_upload_requestr  r  r  r  r   r  r  r  r|  r  rb  rc  r  rh  ri  rD  r   )r   r   r  ro  r   r  r   r  r  upload_file_typeresolved_message_typer  r*  r  r  r   r  r  rO  s                      rW   r  z)FeishuAdapter._send_uploaded_file_message  s      | 	De?CCCCw~~i(( 	Se3Qi3Q3QRRRR ?BG$4$4Y$?$?262U2U"#8 3V 3
 3
//)	=i&& c(33.*! 4  
 99$??(/(9$,/:L:Q:XZa(b(b"b"b"b"b"b"bc c c c c c c c c c c c c c c 33OZPPH 22#$8#H 3     " (!- 	
 *.)E)E## ::7V_:``%% *F * * $ $ $ $ $ $   *.)E)E#2 J
H'=ERRR%% *F * * $ $ $ $ $ $  --.>@RSSS 	= 	= 	=LL>	3Y]L^^^e3s88<<<<<<<<<	=sJ   
G A"D<G DG D2G B	G 
H;HHHr|  c          	     V  K   t          |pi                     d                    }|r|                     |||t          t	          j                                        }|                     ||          }t          j        | j	        j
        j        j        j        |           d {V S |                     |||t          t	          j                                        }|                     d|          }t          j        | j	        j
        j        j        j        |           d {V S )NrV  r~   r   reply_in_thread
uuid_value
receive_idr   r~   r  r   )r   r  _build_reply_message_bodyr   rp  rq  _build_reply_message_requestr  r  r  r  r  rZ   reply_build_create_message_body_build_create_message_requestr  )	r   r   r   r|  ro  r   r  r*  r  s	            rW   _send_raw_messagezFeishuAdapter._send_raw_message  s*      B33K@@AA 	V11! /tz||,,	 2  D 77$GGG *4<?+=+E+KWUUUUUUUUU..4:<<((	 / 
 
 44YEE&t|'9'A'H'RRRRRRRRRrY   c                T    t          | o t          | dd                                 S )Nru  c                     dS r  rS   rS   rY   rW   rL  z3FeishuAdapter._response_succeeded.<locals>.<lambda>  s    e rY   rA  )r  s    rW   r  z!FeishuAdapter._response_succeeded  s,    HN!L9mm!L!L!N!NOOOrY   
field_namec                    t                               |           sd S t          | dd           }|rt          ||d           nd S )Nr!  )r  r  r  )r  r  r!  s      rW   r  z%FeishuAdapter._extract_response_field  sJ    00:: 	4x..26@wtZ...D@rY   )r  r  r  c                   |rt          d||          S t          |dd          }t          |d|          }t          dd| d| |          S )NF)ru  rD  raw_responser5  rJ  rw  r  z] )r4   r  )r   r  r  r  r5  rw  s         rW   r  z$FeishuAdapter._response_error_result  sk      	Ze>PXYYYYx33h77%/@4/@/@3/@/@xXXXXrY   c                    |                      |          s|                     ||          S t          d|                     |d          |          S )N)r  Tr  )ru  r  r   )r  r  r4   r  )r   r  r  s      rW   r  z#FeishuAdapter._finalize_send_result  sb    ''11 	Z..x.YYY33HlKK!
 
 
 	
rY   c           	       K   t          t                    D ]}	 | j        dk    r|                                  d {V  n|                                  d {V   d S # t
          $ r}d| _        |                                  d | _        | 	                                 d {V  |t          dz
  k    r d|z  }t                              d|dz   t          ||           t          j        |           d {V  Y d }~d }~ww xY wd S )Nr  Fr  rH  z:[Feishu] Connect attempt %d/%d failed; retrying in %ds: %s)range_FEISHU_CONNECT_ATTEMPTSr  _connect_websocket_connect_webhookrh  rX  r[  r  r\  ri  r  r  r  )r   attemptrO  wait_secondss       rW   rH  z!FeishuAdapter._connect_with_retry   si     566 	2 	2G2(K77113333333333//111111111 2 2 2 %66888"&//1111111116::: G|PaK,    mL111111111111112	2 	2s   A A
D'BC<<Dc                B  K   t           st          d          | j        dk    rt          nt          }|                     |          | _        |                                 | _        | j        t          d          | j	        }||
                                rt          d          |                                  d {V  t          | j        | j        t          j        j        | j        |          | _        |                    d t(          | j        |           | _        d S )Nz4websockets not installed; websocket mode unavailablerv   $failed to build Feishu event handlerzadapter loop is not ready)r   r   	log_levelevent_handlerr  )FEISHU_WEBSOCKET_AVAILABLErv  r  r'   r(   _build_lark_clientr  r;  r  r  r]  r  FeishuWSClientr  r  rv   LogLevelINFOr  run_in_executorr  r  )r   r  r  s      rW   r%  z FeishuAdapter._connect_websocket9  s     ) 	WUVVV"&"3v"="=;..v66"7799&EFFFz<4>>++<:;;;((*********(<'m(-
 
 
 ..*O	
 
rY   c                  K   t           st          d          | j        dk    rt          nt          }|                     |          | _        |                                 | _        | j        t          d          | 	                                 d {V  t          j                    }|j                            | j        | j                   t          j        |          | _        | j                                         d {V  t          j        | j        | j        | j                  | _        | j                                         d {V  d S )Nz/aiohttp not installed; webhook mode unavailablerv   r*  )FEISHU_WEBHOOK_AVAILABLErv  r  r'   r(   r.  r  r;  r  r  r   Applicationrouteradd_postr  r  	AppRunnerr  setupTCPSiter  r  r  r  )r   r  r  s      rW   r&  zFeishuAdapter._connect_webhookS  sJ     ' 	RPQQQ"&"3v"="=;..v66"7799&EFFF((*********o
D.0LMMM"}S11"((********* [)=t?QSWSeff &&(((((((((((rY   r  c                ,   t           j                                                            | j                                      | j                                      |                              t           j	        j
                                                  S r   )rv   r-   r&  r   r  r   r  r  r+  r0  WARNINGr9  )r   r  s     rW   r.  z FeishuAdapter._build_lark_clientc  s]    K!!VDL!!Z())VF^^Yt},--UWW	
rY   c          
       K   d }|}t          t                    D ]3}	 |                     |||||           d {V }	|rn|                     |	          sYt	          |	dd           }
|
t
          v r?t                              d||
|           d }|                     |||d |           d {V }	|	c S # t          $ r}|}|dk    r(t          
                    t          |                    r |t          dz
  k    r d|z  }t                              d|dz   t          |||           t          j        |           d {V  Y d }~-d }~ww xY w|pt          d          )	Nrv  r5  uk   [Feishu] Reply to %s failed (code %s — message withdrawn/missing); falling back to new message in chat %sr  r  rH  zC[Feishu] Send attempt %d/%d failed for chat %s; retrying in %ds: %szFeishu send failed)r#  _FEISHU_SEND_ATTEMPTSr  r  r  _FEISHU_REPLY_FALLBACK_CODESri  r  rh  r}  r~  r   r  r  rv  )r   r   r   r|  ro  r   
last_erroractive_reply_tor'  r  r5  rO  r(  s                rW   r|  z%FeishuAdapter._feishu_send_with_retrym  s      +/
"233 -	2 -	2G,2!%!7!7#%#,% "8 " "       # 4+C+CH+M+M "8VT::D;;;E+ #   +/)-)?)?$+%-$+%)%- *@ * * $ $ $ $ $ $   2 2 2 
v%%*B*I*I#c((*S*S%3a777 G|YaK)    mL111111111111112  >L)=>>>s   BB33
E=BEEc                   K   | j         sd S 	 t          t          | j                    n4# t          $ r'}t                              d|d           Y d }~nd }~ww xY wd | _         d S # d | _         w xY w)Nz'[Feishu] Failed to release app lock: %sTrb  )r  r;   rE  rh  ri  r  )r   rO  s     rW   rK  zFeishuAdapter._release_app_lock  s      & 	F	+ 68OPPPP 	Z 	Z 	ZNNDcTXNYYYYYYYY	Z '+D###dD#****s+   ( A% 
AAA% AA% %	A.c                    dt                      v r8t          j                                        |                                           S t          |           S )Nr   r   )globalsr   r&  r   r9  r	   rD  s    rW   r  z%FeishuAdapter._build_get_chat_request  sK    wyy((!)++33G<<BBDDDw////rY   c                    dt                      v r8t          j                                        |                                           S t          |           S )Nr   r  )rE  r   r&  r  r9  r	   rG  s    rW   r[  z(FeishuAdapter._build_get_message_request  sK    '))++$,..99*EEKKMMM*5555rY   c                   dt                      v r^t          j                                        |                               |                              |                                          S t          | ||          S )Nr   )r  r   r   )rE  r   r&  r  r   r   r9  r	   rl  s      rW   rp  z-FeishuAdapter._build_message_resource_request  si    &'))33)133J''(##m$$ *xm\\\\rY   r   r@  c                    dt                      v rKt          j                                        |                               |                                          S t          | |          S )Nr   r  )rE  r   r&  r   r@  r9  r	   r  s     rW   r  z,FeishuAdapter._build_get_application_request  sV    "gii//%-//d	 f48888rY   r  r  c                *   dt                      v rqt          j                                        |                               |                              |                              |                                          S t          | |||          S )Nr"   )r~   r   r  rp  )	rE  r"   r&  r~   r   r  rp  r9  r	   r  s       rW   r  z'FeishuAdapter._build_reply_message_body  s    $		11'/11!!(## 11j!! +	
 
 
 	
rY   r  c                    dt                      v rKt          j                                        |                               |                                          S t          | |          S )Nr!   r  )rE  r!   r&  r  r  r9  r	   r  s     rW   r  z*FeishuAdapter._build_reply_message_request  sZ     GII--#+--J''l++	 *<PPPPrY   c                    dt                      v rKt          j                                        |                               |                                          S t          | |          S )Nr$   r  )rE  r$   r&  r   r~   r9  r	   r  s     rW   r  z(FeishuAdapter._build_update_message_body  sZ    %22(022(##!!	 'BBBBrY   c                    dt                      v rKt          j                                        |                               |                                          S t          | |          S )Nr#   r  )rE  r#   r&  r  r  r9  r	   r  s     rW   r  z+FeishuAdapter._build_update_message_request  sZ    !WYY..$,..J''l++	 *<PPPPrY   r  c                *   dt                      v rqt          j                                        |                               |                              |                              |                                          S t          | |||          S )Nr   )r  r   r~   rp  )	rE  r   r&  r  r   r~   rp  r9  r	   r  s       rW   r  z(FeishuAdapter._build_create_message_body  s    %22(022J''(##!!j!! !	
 
 
 	
rY   receive_id_typec                    dt                      v rKt          j                                        |                               |                                          S t          | |          S )Nr   rO  r  )rE  r   r&  rO  r  r9  r	   rQ  s     rW   r  z+FeishuAdapter._build_create_message_request  sZ    !WYY..$,.. 11l++	 \ZZZZrY   r  r  c                    dt                      v rKt          j                                        |                               |                                          S t          | |          S )Nr   r  )rE  r   r&  r  r  r9  r	   r  s     rW   r  z&FeishuAdapter._build_image_upload_body)  sX    #wyy00&.00J''u	 *EBBBBrY   c                    dt                      v r8t          j                                        |                                           S t          |           S )Nr   r  )rE  r   r&  r  r9  r	   rT  s    rW   r  z)FeishuAdapter._build_image_upload_request4  sK    799,,%-//<<\JJPPRRRL9999rY   r	  c                   dt                      v r^t          j                                        |                               |                              |                                          S t          | ||          S )Nr   r  )rE  r   r&  r	  r   r   r9  r	   r  s      rW   r  z%FeishuAdapter._build_file_upload_body:  sg    "gii//%-//9%%9%%d idSSSSrY   c                    dt                      v r8t          j                                        |                                           S t          |           S )Nr   rT  )rE  r   r&  r  r9  r	   rT  s    rW   r  z(FeishuAdapter._build_file_upload_requestF  sK    '))++$,..;;LIIOOQQQL9999rY   c                     t          |          S r   )re  r  s     rW   _build_post_payloadz!FeishuAdapter._build_post_payloadL  s    +G444rY   r  ro   c                   t          j        |                     |                    }|                    di                               dg           }|                    |g           t          j        |d          S r^  )rb  r  rX  
setdefaultrm  rc  )r   r  r  r|  r~   s        rW   r  z'FeishuAdapter._build_media_post_payloadO  sm    *T55g>>??$$Wb11<<YKK	{###z'6666rY   r  c                    t          |           j                                        }|t          v rdS |t          v rdS |t
          v rt
          |         dfS |dk    r	t          dfS t          dfS )N)opusr  )mp4r  r   )r   r  r  _FEISHU_OPUS_UPLOAD_EXTENSIONS_FEISHU_MEDIA_UPLOAD_EXTENSIONS_FEISHU_DOC_UPLOAD_TYPES_FEISHU_FILE_UPLOAD_TYPE)r  r  rU   s      rW   r
  z,FeishuAdapter._resolve_outbound_file_routingU  s}     9oo$**,,000"?111!>***+C0&88!V+++V33'//rY   )r  r/   )r  r   r   r   )r   r   r   rj  )r   r
   r   r   rq  )r   r   r   rj  )NN)
r   r   r~   r   ro  rp  r   rq  r   r4   )
r   r   r  r   r~   r   r  r   r   r4   )r  N)r   r   r  r   r  r   r   r   r   rq  r   r4   )r  r   r  r   r   r   )NNN)r   r   r  r   r  rp  ro  rp  r   rq  r   r4   )NNNN)r   r   r  r   r  rp  r   rp  ro  rp  r   rq  r   r4   )r   r   r  r   r  rp  ro  rp  r   rq  r   r4   )r   r   r  r   r  rp  ro  rp  r   rq  r   r4   r   )r   r   r   rj  )r   r   r  r   r  rp  ro  rp  r   rq  r   r4   )r   r   r  r   r  rp  ro  rp  r   rq  r   r4   )r   r   r   r   r~   r   r   r   )r!  r
   r   rj  )r!  r
   r   r   )r!  r    r   rj  )r0  r   r!  r
   r   rj  )r!  r
   r   r
   )r  r
   r   r   )r  r
   rB  r
   r   rj  )r  r
   r;  r   r  r
   r   r
   )r  r
   r  r   r  r   r   rj  )r   r   r   r   )r   r   r   rs  )r  r1   r   rj  )r  r   r  r   r   rp  )r  r   r  r   r   r   )r  r   r  r   r   rj  )r  r   r   rp  )r  r1   r  r3   r   rj  )r  r   r  r   r   rj  )r  r   r   rj  )r!  r
   rZ   r
   r  r
   r  r   r  r   r  r   r   rj  )r  r1   r   r   )r  r1   r   r   )rM  r1   r  r1   r   r   )r  r   r   rj  )r  r   r   r   )r  r   r  r   r  r   r   r=  )r   r   rR  r   r   r   )
r  r   r  r   r  r   r  r   r   r   )r   r
   r   r
   )r  r
   r   r
   )r  r
   r  r  r   r   )r  r   r   r   )r@  r   r  r   rA  r
   r   rj  )rZ   r
   r   rJ  )r  r   r
  r   r   rR  )rW  r   rR  r2   r   r2   )r
  r   r  r   r   r2   )r  r   rW  r   r   r   )r  r   r   r   r   r=  )
r  r   r   r   r   r   rT  r   r   r=  )r  r
   r   r  )r  r
   r   r   r   r   )
r  r   r  r   rR  r   ro  r   r   r   )r  r   rR  r   r   r   )r  r   r   r   )r  r   r   r   )r  r   r   r   )rR  r   rS  r   r   r   )r  r
   r  r   r   r  )r  rp  r   rp  )r  rp  r  r   r   rp  )r  r   r   r  )r   r   r  r   r   r  r   rp  )rU   r   r   r   )r
  r
   r   rj  )r   r
   rZ   r
   r   r  )r   r   r   r   )r   )r  r
   r   r   r  r   r   r   )rZ   r
   r   r   )r   r  r   r   )r   r   r   r   )r   r   )r  r   r   r   )r~   r   r   r=  )r   r   r  r   ro  rp  r   rq  r  rp  r   rp  r  r   r   r4   )r   r   r   r   r|  r   ro  rp  r   rq  r   r
   )r  r
   r   r   )r  r
   r  r   r   r
   )r  r
   r  r   r  rp  r   r4   )r  r
   r  r   r   r4   )r  r
   r   r
   )r   r   r   r
   )r  r   r   r
   )r  r   r   r   r   r   r   r
   )r   r   r@  r   r   r
   )
r~   r   r   r   r  r   r  r   r   r
   )r  r   r  r
   r   r
   )r   r   r~   r   r   r
   )
r  r   r   r   r~   r   r  r   r   r
   )rO  r   r  r
   r   r
   )r  r   r  r
   r   r
   )r  r
   r   r
   )r	  r   r   r   r   r
   r   r
   )r  r   r  ro   r   r   )r  r   r  r   r   r=  )r   r   r   r   rz  rF  r  staticmethodr  r  r;  r  rf  rY  rZ  r[  r\  r  r  r  r  r  r  r  r  r  r  r  r  rx  r*  r  r  r  r(  r0  r2  r4  r6  r8  r  r.  r  r=  r<  rH  r8  rl  r>  rv  ra  r  r  r  r  r  r  r  r  r  r!  r  r  r  r  r  r  r  r  r  r  r  r  r   r  r  r  r2  r4  r  r7  r  r?  r8  r  rN  r\  rO  rP  rU  rV  rr  rs  rt  ru  r|  ri  rz  r  r^  r\  rG  r  r  r  r  rv  r  r   r  r  r  r  r  rM  r  r  rc  r  r{  r  r  r  r  r  r  rH  r%  r&  r.  r|  rK  r  r[  rp  r  r  r  r  r  r  r  r  r  r  r  rX  r  r
  __classcell__)r  s   @rW   r  r  C  s       "" /& /& /& /& /& /&b a
 a
 a
 \a
F9 9 9 9>
 
 
 
8+ + + +Z+- +- +- +-Z   , , , ,
# # # #& & & &" #'-17= 7= 7= 7= 7=~ != != != != != !=J /-1D= D= D= D= D=L 
 
 
 \
, "&"&-1
 
 
 
 
. "&#'"&-1
 
 
 
 
0 "&"&-1
 
 
 
 
. "&"&-1;= ;= ;= ;= ;=z     "&"&-1
 
 
 
 
 
 
@ "&"&-1 
  
  
  
  
  
  
D# # # #J   ? ? ? ?0! ! ! !FQ6 Q6 Q6 Q6f
 
 
 
:M M M M1 1 1 11 1 1 1@ @ @ @: : : :? ? ? ?&? ? ? ?@- - - -6 Z Z Z \Z? ? ? ?
   0[ [ [ [ :@ :@ :@ :@x
 
 
 
0@ 0@ 0@ 0@l   
- 
- 
- 
- a a a a& & & &P   <& & & &H H H HH H H HK K K K2C C C C4: : : :  M7 M7 M7 M7 M7 M7^6 6 6 6
 
 
 
A A A A 
 
 
 \
. . . .*
 
 
 
? ? ? ?	6 	6 	6 	6> > > >"% "% "% "%H F F F \F    \    \^; ^; ^; ^;@   *       L
 
 
 
 
 
 
 \
$- $- $- $-L
 
 
 
 ; ; ; \;> > > >,6 6 6 6"V V V V@' ' ' '>    \              >L L L Ld & & & \& l l l \l
    \ % % % \% x x x \x 7 7 7 \7    \    \    \ 	
 
 
 
 
 
B   " 	5 5 5 5 5 5n   :   F -10 0 0 0 0 0$ ? ? ? \? N N N \N" " " "H% % % % )M
 )M )M )M )M )M )MZ< < < <    .0 0 0 0
 
 
 
Ee Ee Ee EeVC C C C:r r r r   (D D D D "&#'%+>= >= >= >= >= >=@S S S S: P P P \P A A A \A )-Y Y Y Y Y Y
 
 
 
2 2 2 22
 
 
 
4) ) ) ) 
 
 
 
9? 9? 9? 9?v+ + + + 0 0 0 \0
 6 6 6 \6
 	] 	] 	] \	] 9 9 9 \9 
 
 
 \
" Q Q Q \Q C C C \C Q Q Q \Q 
 
 
 \
" [ [ [ \[ C C C \C : : : \:
 	T 	T 	T \	T : : : \:
5 5 5 57 7 7 7 0 0 0 \0 0 0 0 0rY   r  r  c                N    t                               | t           d                   S Nru   )_ONBOARD_ACCOUNTS_URLSr  r  s    rW   _accounts_base_urlrj  u  s    !%%f.DX.NOOOrY   c                N    t                               | t           d                   S rg  )_ONBOARD_OPEN_URLSr  ri  s    rW   _onboard_open_base_urlrm  y  s    !!&*<X*FGGGrY   base_urlr*  r   c                >   |  t            }t          |                              d          }t          ||ddi          }	 t	          |t
                    5 }t          j        |                                	                    d                    cddd           S # 1 swxY w Y   dS # t          $ rf}|                                }|rJ	 t          j        |	                    d                    cY d}~S # t          t          j        f$ r |dw xY w d}~ww xY w)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  r  z!application/x-www-form-urlencodedr!  r  rV  N)_REGISTRATION_PATHr   r#  r   r   _ONBOARD_REQUEST_TIMEOUT_Srb  r  r  r  r   rV  r  )rn  r*  r   r!  r  r  rO  r  s           rW   _post_registrationrs  }  sy    
+)
+
+CT??!!'**D
#D>;^*_
`
`
`C
S"<=== 	;:diikk0099::	; 	; 	; 	; 	; 	; 	; 	; 	; 	; 	; 	; 	; 	; 	; 	; 	; 	;   XXZZ
 	$$z*"3"3G"<"<======== 45 $ $ $t#$sT   B, 9BB, B##B, &B#'B, ,
D6D&C93D9DDDru   c                    t          |           }t          |ddi          }|                    d          pg }d|vrt          d|           dS )zcVerify the environment supports client_secret auth.

    Raises RuntimeError if not supported.
    r  initsupported_auth_methodsclient_secretzWFeishu / Lark registration environment does not support client_secret auth. Supported: Nrj  rs  r  rv  )r  rn  resmethodss       rW   _init_registrationr{    ss    
 "&))H
X&'9
:
:Cgg.//52Gg%%$!$ $
 
 	
 &%rY   c                l   t          |           }t          |ddddd          }|                    d          }|st          d          |                    dd	          }d
|v r|dz  }n|dz  }|||                    dd	          |                    d          pd|                    d          pddS )zXStart the device-code flow. Returns device_code, qr_url, user_code, interval, expire_in.beginPersonalAgentrw  r   )r  	archetypeauth_methodrequest_user_infodevice_codez7Feishu / Lark registration did not return a device_codeverification_uri_completer   r  z&from=hermes&tp=hermesz?from=hermes&tp=hermes	user_codeinterval   	expire_inrc   )r  qr_urlr  r  r  rx  )r  rn  ry  r  r  s        rW   _begin_registrationr    s    !&))H
X$&&	( (  C ''-((K VTUUUWW0"55F
f}}****"WW["--GGJ'',1WW[))0S  rY   ri  r  r  r  Optional[dict]c                   t          j                     |z   }|}d}d}t          j                     |k     rt          |          }	 t          |d| dd          }	n6# t          t          t
          j        f$ r t          j        |           Y ow xY w|dz  }|dk    rt          ddd	
           n|dz  dk    rt          ddd	
           |		                    d          pi }
|
	                    d          }|dk    r|sd}d	}|		                    d          rO|		                    d          r:|dk    rt                       |	d         |	d         ||
	                    d          dS |		                    dd          }|dv r1|dk    rt                       t                              d|           dS t          j        |           t          j                     |k     |dk    rt                       t                              d|           dS )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.
    Fr   pollob_app)r  r  tpr  z#  Fetching configuration results...r   Tendflush   r@  	user_infotenant_brandrv   	client_idrw  r   )r   r   r  r   rD  )access_deniedexpired_tokenz [Feishu onboard] Registration %sNz)[Feishu onboard] Poll timed out after %ds)r  rj  rs  r   rj  rb  r  r  printr  ri  r  )r  r  r  r  deadlinecurrent_domaindomain_switched
poll_countrn  ry  r  r  rD  s                rW   _poll_registrationr    sJ    y{{Y&HNOJ
)++
 
 %n55	$X *0 0  CC
 '4#78 	 	 	Jx   H	 	a
??7RtLLLLL!^q  #2T**** GGK((.B	 }}^446!!/!#N"O 77; 	CGGO$<$< 	A~~k*!/2($==33	   $$666A~~NN=uEEE4 	
8] )++
 
 ` A~~
NN>	JJJ4s   A 0BBr   c                    t           dS 	 t          j                    }|                    |            |                    d           |                    d           dS # t
          $ r Y dS w xY w)zDTry to render a QR code in the terminal. Returns True if successful.NFT)fit)invert)_qrcode_modQRCodeadd_datamakeprint_asciirh  )r   qrs     rW   
_render_qrr  
  s    u!!
C
D
d###t   uus   AA! !
A/.A/r   r   c                T    t           rt          | ||          S t          | ||          S )uc  Verify 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)r   r   r  s      rW   	probe_botr    s0      :fj&9996:v666rY   c                @   |dk    rt           nt          }t          j                                                            |                               |                              |                              t          j	        j
                                                  S )z9Build a lark Client for the given credentials and domain.rv   )r(   r'   rv   r-   r&  r   r   r  r+  r0  r<  r9  )r   r   r  
sdk_domains       rW   _build_onboard_clientr  &  sk     && 0 0mJ		J			
			4=(	)	)	rY   r!  c                8   |                      d          dk    rd S |                      d          p*|                      di                                d          pi }|                     d          p|                     d          |                     d          dS )	Nr5  r   r   r!  r  r   r   )r   r   )r  )r!  r   s     rW   r  r  3  s    xx1t
((5//
BTXXfb1155e<<
BCGGJ''>377:+>+>wwy))  rY   c                &   	 t          | ||          }t          j                                        t          j                                      d                              t          j	        h          
                                }|                    |          }t          t          |dd          dd          }|dS t          t          j        |                    S # t           $ r&}t"                              d|           Y d}~dS d}~ww xY w)z#Probe bot info using lark_oapi SDK.r  rF  Nr~   z%[Feishu onboard] SDK probe failed: %s)r  r)   r&  r  r&   r  r  r  r%   r  r9  r  r  r  rb  r  rh  ri  rj  )r   r   r  r  r  r  r~   rO  s           rW   r  r  >  s    &vz6BB!![((S)**[/0122UWW 	 ~~c""'$t44iFF?4"4:g#6#6777   <cBBBttttts   B;C  ? C   
D*DDc                Z   t          |          }	 t          j        | |d                              d          }t	          | d|ddi          }t          |t                    5 }t          j        |                                	                    d                    }ddd           n# 1 swxY w Y   |
                    d	          }|sdS t	          | d
d| dd          }	t          |	t                    5 }t          j        |                                	                    d                    }
ddd           n# 1 swxY w Y   t          |
          S # t          t          t          t          j        f$ r&}t                               d|           Y d}~dS d}~ww xY w)z@Fallback probe using raw HTTP (when lark_oapi is not installed).)r   r   r  z//open-apis/auth/v3/tenant_access_token/internalr  r  rp  rV  Ntenant_access_tokenr  zBearer )Authorizationr  r  z&[Feishu onboard] HTTP probe failed: %s)rm  rb  rc  r#  r   r   rr  r  r  r  r  r  r   rj  KeyErrorr  ri  rj  )r   r   r  rn  
token_data	token_reqr  	token_resaccess_tokenbot_reqbot_resrO  s               rW   r  r  S  sF   %f--HZ6 L LMMTTU\]]
HHH#%78
 
 
	
 Y(BCCC 	@t
499;;#5#5g#>#>??I	@ 	@ 	@ 	@ 	@ 	@ 	@ 	@ 	@ 	@ 	@ 	@ 	@ 	@ 	@ !}}%:;; 	4///!9<!9!9 2 
 
 
 W&@AAA 	>Tj!3!3G!<!<==G	> 	> 	> 	> 	> 	> 	> 	> 	> 	> 	> 	> 	> 	> 	> #7+++gx)=>   =sCCCtttttsf   AE" (:B."E" .B22E" 5B26E" 0E" :E<E" EE" EE" ""F*F%%F*initial_domaintimeout_secondsr  r  c                    	 t          | |          S # t          t          t          t          j        f$ r&}t                              d|           Y d}~dS d}~ww xY w)a  Run the Feishu / Lark scan-to-create QR registration flow.

    Returns on success::

        {
            "app_id": str,
            "app_secret": str,
            "domain": "feishu" | "lark",
            "open_id": str | None,
            "bot_name": str | None,
            "bot_open_id": str | None,
        }

    Returns None on expected failures (network, auth denied, timeout).
    Unexpected errors (bugs, protocol regressions) propagate to the caller.
    r  z([Feishu onboard] Registration failed: %sN)_qr_register_innerrv  r   rj  rb  r  ri  r  )r  r  rO  s      rW   qr_registerr  t  sh    *!Q`aaaa(GT-AB   A3GGGttttts    "AAAc                   t          ddd           t          |            t          |           }t          d           t                       |d         }t          |          rt          d|            n"t          d| d	           t          d
           t                       t	          |d         |d         t          |d         |          |           }|sdS t          |d         |d         |d                   }|r1|                    d          |d<   |                    d          |d<   n
d|d<   d|d<   |S )uI   Run init → begin → poll → probe. Raises on network/protocol errors.z   Connecting to Feishu / Lark...r   Tr  z 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 timer  r  r  )r  r  r  r  Nr   r   r  r   r   )r  r{  r  r  r  minr  r  )r  r  r}  r  rG  bot_infos         rW   r  r    si    

,"DAAAA~&&&//E	(OOO	GGG8_F& ZS6SSTTTTPfPPPQQQXYYY	GGG-(z"eK(/::	  F  t )6,+?AQRRH %%\\*55z (] ; ;}!z $}MrY   )r   r
   r   r   )r   r
   r   r   )r}   r   r   r   )r   r
   r   r   )r  r  r  r   r   r   )r,  r   r   r   )r3  r   r   r   )Nr   )r   r
   rR  r   rS  r   r   r   )r   )r   r
   rR  r   rS  r   r   r   rc  )r~   r   r   rf  )r|  r
   r{  r}  r   r   )r|  r
   r   r   )r  r
   r   r   r   )
r3  r
   r   r   r   r   r{  r}  r   r   )
r   r
   r   r   r   r   r{  r}  r   r   )
r   r   r  r   r   r  r   r   r   r   )r  r   r   r   )r|  r   r   r   )r   r   r|  r   r   r   )r|  r   r   r   )r|  r
   r   r   )r   r
   r  r   r   r   )r|  r   r   r   r   r   )r   r   r   r   )r|  r
   r   r   )r|  r
   r  r'  r   r   )r   r
   )r  r
   r   r   )r}   r   r{  r}  r   r   )r  r   r   r   )r<  r
   r   r=  )r   r  r   r   r   rD  )r   rH  r   r   )r}   r   r   rH  r   r   )rZ  r
   r[  r
   r   rj  rb  )r  r   r   r   )rn  r   r*  ro   r   r   )ru   )r  r   r   rj  )r  r   r   r   )
r  r   r  r   r  r   r  r   r   r  )r   r   r   r   )r   r   r   r   r  r   r   r  )r   r   r   r   r  r   r   r
   )r!  r   r   r  )r  r   r  r   r   r  )r   
__future__r   r  r!  r  r  rb  loggingr  r  r$  r  r  rp  collectionsr   dataclassesr   r   r   pathlibr   typesr	   typingr
   r   r   r   r   r   urllib.errorr   r   urllib.parser   urllib.requestr   r   aiohttpr   ImportErrorr  	lark_oapirv   lark_oapi.api.application.v6r   r  r   r   r   r   r   r   r   r   r   r    r!   r"   r#   r$   lark_oapi.corer%   r&   lark_oapi.core.constr'   r(   lark_oapi.core.modelr)   5lark_oapi.event.callback.model.p2_card_action_triggerr*   r+   "lark_oapi.event.dispatcher_handlerr,   lark_oapi.wsr-   r/  r  r-  r4  gateway.configr.   r/   gateway.platforms.baser0   r1   r2   r3   r4   r5   r6   r7   r8   r9   gateway.statusr:   r;   hermes_constantsr<   utilsr=   	getLoggerr   ri  compilerP  r  rO  ru  rs  _MENTION_REr6  
IGNORECASEr}  r  r  r  r  r{  r  ra  r^  r_  r`  rg  r$  r>  rE  r  r  r  r  r  r  r  r  r  r  r  r*  r-  r.  r  r  r  ri  rp   r   rr   _FEISHU_BOT_MSG_TRACK_SIZEr   r?  r  r  r  rh  rl  rq  rr  r  r  r  r  r  r#  r  r  r4  rP  rQ  r2  r  r  r   r   r   r   r   r   r   r   RejectReasonr  r  r  r  r  r+  r2  r>  rD  rQ  rY  r\  re  ra  r  r  r  r  r  r  r  r  r  r  r  r  r  r  r	  r  r  r  r  r  r  r  r   rC  r  rL  rY  r  r  r  rj  rm  rs  r{  r  r  qrcoder  rU  r  r  r  r  r  r  r  r  rS   rY   rW   <module>r     sg  - - -^ # " " " " "              				 				       # # # # # # ( ( ( ( ( ( ( (             ! ! ! ! ! ! ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? , , , , , , , , " " " " " " + + + + + + + +NNN   G
CCC   JJJ&BBBBBB                                 ;:::::::????????000000        JIIIII555555   DL"&!NMKKK (t3 "$.  3 3 3 3 3 3 3 3                        D C C C C C C C , , , , , , # # # # # #		8	$	$ BJ kL   BJ9:: $"*%9:: %2:k22 bj''L))%2:&UWYWdee 
 GFF WWW MMM UU4R4L4R4T4TUUU % # "('!2 "B"B"B    $   ( $' !#$   $ %( "  #  ) 
 ) ") !0 &( #!$  $ ') $$& !&1 #(/ %  	( (      %$	' '      ! (y&&)9::   ( &  *. & +,  
 '(   2   + 2 * 3  ) 
 ( 'RZ(DEE $"*]33 #)$TUU $9%:;; F##   , $                $        $5 5 5 5 5 5 5 5  $G G G G G G G G $; ; ; ; ; ; ; ; $!! !! !! !! !! !! !! !!H + + + + + + + + 9 9 9 9 9 9 9 9 @ @ @ @
   (9 9 9 9: : : :' ' ' '# # # #B B B B   ,9 9 9 9   $6 6 6 6 61 1 1 1 1	 	 	 	.6 .6 .6 .6h ;?! ! ! ! ! !H, , , ,   $	 	 	 	  ;?	M; M; M; M; M;h ;?	    J )-0022FN FN FN FN FN FNRG G G G   *   8   B#" #" #" #"L@ @ @ @! ! ! !&& & & &Rd d d d_ _ _ _
	4 	4 	4 	4
 
 
 
) ) ) )
 
 
 
( ;?    *       (   ,? ? ? ?&* * * *Z<' <' <' <'~   
f00 f00 f00 f00 f00' f00 f00 f00daP P P PH H H H   .
 
 
 
 
    > D D D D D DN     Y   KKK   7 7 7 7
 
 
 
      *   F #     8& & & & & &sI   
B 	BBB! !B+*B+/AD DD3S8 8	TT