`gj"UdZddlmZddlZddlZddlZddlmZmZm Z m Z m Z eje ZdCdDdZdCdZdEdZdZd d  dFd Zd d  dFd Zd ZdZdZdZdZdZ dGdZdZdZ dHdZ dIdZdd dJdZ dKdZ! dLdZ" dMdZ#dZ$e$fdNdZ% dOdZ&dPd Z'dPd!Z(dQdRd"Z)ddl*Z+e+jXd#Z-d$Z.dSd%Z/ dTd&Z0 dUd'Z1 dQ dVd(Z2d)Z3d*Z4d+Z5e3fdWd,Z6 dXd-Z7 dYd.Z8d/jsZ:d0dd1 dZd2Z;d0d0dd3 d[d4ZZ>ddl?Z@d6ZAd7ZBe>jZDiZEd8eFd9<d]d:ZGd^d;ZHd_d<ZIdQd`d=ZJd>ZKd?d@hZLddA dadBZMy)ba& Feishu/Lark drive document comment handling. Processes ``drive.notice.comment_add_v1`` events and interacts with the Drive v2 comment reaction API. Kept in a separate module so that the main ``feishu.py`` adapter does not grow further and comment-related logic can evolve independently. Flow: 1. Parse event -> extract file_token, comment_id, reply_id, etc. 2. Add OK reaction 3. Parallel fetch: doc meta + comment details (batch_query) 4. Branch on is_whole: Whole -> list whole comments timeline Local -> list comment thread replies 5. Build prompt (local or whole) 6. Create AIAgent with feishu_doc + feishu_drive tools -> agent generates reply 7. Route reply: Whole -> add_whole_comment Local -> reply_to_comment (fallback to add_whole_comment on 1069302) ) annotationsN)AnyDictListOptionalTuplecddlm}ddlm}ddlm}|dk(r |j n |j}|jj|j|j|jh} |r| j|} |r| j|} || j|} | j!S)zBuild a lark_oapi BaseRequest.rAccessTokenType) HttpMethod) BaseRequestGET) lark_oapir lark_oapi.core.enumr !lark_oapi.core.model.base_requestr rPOSTbuilder http_methoduri token_typesTENANTpathsqueriesbodybuild) methodrrrrr r r rrs Z/root/.hermes/venv/lib/python3.12/site-packages/plugins/platforms/feishu/feishu_comment.py_build_requestr%s).=$*eO*..K  [ ! S o,,- .   --&//'* ,,t$ ==?c Ktjd|||||rtj|dddndt |||||}t j |j|d{}t|dd}t|dd} i} t|d d} | r>t| d r2 tj| j} | jd i} | s9t|d d} t| t r| } n| rt| d r t#| } tjd |||| | rt%| j'nd|dk7rzt|d d} d}| rSt| d rGt| jt(t*fr| jddnt)| jdd}tj-d||| | fS7b#tjtf$rYwxYww)z=Execute a lark API request and return (code, msg, data_dict).z:[Feishu-Comment] API >>> %s %s paths=%s queries=%s body=%sF) ensure_asciiNcodemsgrawcontentdata__dict__z:[Feishu-Comment] API <<< %s %s code=%s msg=%s data_keys=%semptyrz*[Feishu-Comment] API FAIL raw response: %s)loggerinfojsondumpsrasyncio to_threadrequestgetattrhasattrloadsr'getJSONDecodeErrorAttributeError isinstancedictvarslistkeysstrbyteswarning)clientrrrrrr1responser#r$r(r& body_json resp_data raw_contents r _exec_requestrE<s KKLeW?CDu5ds;OVS%$?G&&v~~w??H 8VT *D (E2 &CD (E4 (C wsI&  3;;/I==,D Hfd3 i &D 79j9 ?D KKLdCddiik):Q qyht, 73 */9#++U|/T#++ds+Z]^a^i^iZjkoloZpKC[Q d?;@$$n5   s7A)G0+G ,;G0(1GC5G0G-)G0,G--G0ctjdt|jt |dd}|tjdyt |t r|nt|dr t|ni}tjdt|j|jdxsi}t |t st|dr t|ni}|jdxsi}t |t st|dr t|ni}|jd xsi}t |t st|dr t|ni}t|jd xsd t|jd xsd t|jd xsd t|jdt|jdxsd t|jdxsd t|jdxsd t|jdxsd t|jdxsd t|jdxsd d S)aGExtract structured fields from a ``drive.notice.comment_add_v1`` payload. *data* may be a ``CustomizedEvent`` (WebSocket) whose ``.event`` is a dict, or a ``SimpleNamespace`` (Webhook) built from the full JSON body. Returns a flat dict with the relevant fields, or ``None`` when the payload is malformed. z8[Feishu-Comment] parse_drive_comment_event: data type=%seventNzO[Feishu-Comment] parse_drive_comment_event: no .event attribute, returning Noner)z7[Feishu-Comment] parse_drive_comment_event: evt keys=%s notice_meta from_user_id to_user_idevent_idr% comment_idreply_id is_mentioned timestamp file_token file_type notice_typeopen_id) rKrLrMrNrOrPrQrR from_open_id to_open_id)r+debugtype__name__r2r8r9r3r:r;r<r5r=bool)r(rGevtrH from_userto_users rparse_drive_comment_eventr]gs LLKTRVZM`M`a D'4 (E } fg#E40uj1U r LLJDQTQYQYQ[L\]''-(.BK k4 (+2; +Kd;'QS /52I i &'.y*'EDO2 ool+1rG gt $#*7J#?$w-R +1r2#'',/526 +1r2SWW^45-34+//,7=2>5;<;??=9?R@IMM)4:;'++i06B7  rz7/open-apis/drive/v2/files/:file_token/comments/reactionOK) reaction_typec8K ddlm}d||d}t |dt d|id |fg| d {\}}} |dk(} | rtjd ||||| Stjd |||||| S#t$rtj dYywxYw7jw)aAdd an emoji reaction to a document comment reply. Uses the Drive v2 ``update_reaction`` endpoint:: POST /open-apis/drive/v2/files/{file_token}/comments/reaction?file_type=... Returns ``True`` on success, ``False`` on failure (errors are logged). rr z([Feishu-Comment] lark_oapi not availableFaddactionrMr_rrPrQrrrNz9[Feishu-Comment] Reaction '%s' added: file=%s:%s reply=%sH[Feishu-Comment] Reaction API failed: code=%s msg=%s file=%s:%s reply=%s) rr ImportErrorr+errorrE _REACTION_URIr,r?) r@rPrQrMr_r rr#r$_ succeededs radd_comment_reactionrks - & D ' Z(y)*  LD#q I G 9j(    " #y*h ;  ?@s2BA4#BBAB4BBBBcKd||d}t|dtd|id|fg|d{\}}}|dk(} | rtjd ||||| Stj d |||||| S7Fw) usRemove an emoji reaction from a document comment reply. Best-effort — errors are logged but not raised. deleterbrrPrQrdNrz;[Feishu-Comment] Reaction '%s' deleted: file=%s:%s reply=%sre)rErhr+r,r?) r@rPrQrMr_rr#r$rirjs rdelete_comment_reactionrns& D ' Z(y)*  LD#q I I 9j(    " #y*h 's$A/A-AA/z%/open-apis/drive/v1/metas/batch_queryz:/open-apis/drive/v1/files/:file_token/comments/batch_queryz./open-apis/drive/v1/files/:file_token/commentszB/open-apis/drive/v1/files/:file_token/comments/:comment_id/repliesz2/open-apis/drive/v1/files/:file_token/new_commentscK||dgdd}tjd||t|dt|d{\}}}|dk7rtj d ||iS|j d g}tjd t |jt|dd |sLt|j d tr|d j |i}n.tjd iSt|tr|dni}|j dd|j dd|j d|d} tjd| d| dr| ddd| Sd| S79w)zFetch document title and URL via batch_query meta API. Returns ``{"title": "...", "url": "...", "doc_type": "..."}`` or empty dict. ) doc_tokendoc_typeT) request_docswith_urlz@[Feishu-Comment] query_document_meta: file_token=%s file_type=%sr)rNrz8[Feishu-Comment] Meta batch_query failed: code=%s msg=%smetasz@[Feishu-Comment] query_document_meta: raw metas type=%s value=%si,z4[Feishu-Comment] query_document_meta: no metas foundtitler%urlrq)rurvrqz5[Feishu-Comment] query_document_meta: title=%s url=%sP) r+rVrE_BATCH_QUERY_META_URIr?r5rWrXr=r8r9r;r,) r@rPrQrr#r$r(rtmetaresults rquery_document_metar{sx(2yIJ D LLSU_ajk)-DOD#t qyQSWY\] HHWb !E LLSe%%s5z$3'79  dhhw' .=$$Z4D LLO PI%eT2uQx'2&xxr"HHZ3F  KKGwve}s!3N MKMN M7s7E5E2D9E5g?c Ktjd||ttD]}t |dt d|id|fdgd|gid{\}}}|d k(rno|td z krBtj d |d zt||tjtd{tjd t||icSjd g}tjdt|tr t|nd |rt|tr|d } tj d| jd| jddxsdddt| jdtr1t| jdijdg| Sd| Stjdt|j!iS77Cw)zFetch comment details via batch_query comment API. Retries up to 6 times on failure (handles eventual consistency). Returns the comment dict with fields like ``is_whole``, ``quote``, ``reply_list``, etc. Empty dict on failure. zA[Feishu-Comment] batch_query_comment: file_token=%s comment_id=%srrPrQ user_id_typerS comment_idsrdNrz@[Feishu-Comment] batch_query_comment retry %d/%d: code=%s msg=%szM[Feishu-Comment] batch_query_comment failed after %d attempts: code=%s msg=%sitemsz2[Feishu-Comment] batch_query_comment: got %d itemszI[Feishu-Comment] batch_query_comment: is_whole=%s quote=%s reply_count=%sis_wholequoter%< reply_listreplies?zC[Feishu-Comment] batch_query_comment: empty items, raw data keys=%s)r+rVrange_COMMENT_RETRY_LIMITrE_BATCH_QUERY_COMMENT_URIr,r/sleep_COMMENT_RETRY_DELAY_Sr?r5r8r;lenr9r<) r@rPrQrLattemptr#r$r(ritems rbatch_query_commentr0s LLTV`blm-. - F4,i(+ *.!  c4 19  )A- - KKR! 14 -- 67 7 7 NN_$dC I/4 HHWb !E LLEU_`egkUls5zrst E4(Qx _HHZ(XXgr*0b#26JTUYU]U]^jUkmqJrCr266y"EF } y| }  NNXZ^_c_h_h_jZkl IG 8s&A G+ G%AG+%G(&EG+(G+chKtjd|g}d}tdD]}d|fdddg}|r|jd|ft |d t d |i| d {\}}} |d k7rtj d||n| jdg} t| tr:|j| tjdt| t|| jdsn| jdd}|rntjdt||S7έw)z8List all whole-document comments (paginated, up to 500).z3[Feishu-Comment] list_whole_comments: file_token=%sr%rQ)rtrue page_size100r~ page_tokenrrPrrNrz;[Feishu-Comment] List whole comments failed: code=%s msg=%srzA[Feishu-Comment] list_whole_comments: page got %d items, total=%dhas_morezE[Feishu-Comment] list_whole_comments: total %d whole comments fetched) r+rVrappendrE_LIST_COMMENTS_URIr?r5r8r;extendrr,) r@rPrQ all_commentsrrirr#r$r(rs rlist_whole_commentsrcs8 LLF S)+LJ 1X ) $ '    NNL*5 6 - E-,!  c4 19 NNXZ^`c d "% eT "    & LL\US%6 8xx # XXlB/  ;> KKWY\]iYjk - sAD2!D0"B)D2 %D2r%expect_reply_idc bKtjd||ttD][}g}d}d}tdD]} d|fddg} |r| j d|ft |d t ||d | d {\} } } | d k7rtjd| | d}n^| jdg}t|tr|j|| jdsn| jdd}|rnr|sntfd|D}|rnl|tdz krBtjd|dzttjt d {Atjdt^tjdt#|S727Hw)zList all replies in a comment thread (paginated, up to 500). If *expect_reply_id* is set and not found in the first fetch, retries up to 6 times (handles eventual consistency). zB[Feishu-Comment] list_comment_replies: file_token=%s comment_id=%sr%TrrQrr~rrrPrLrNrz4[Feishu-Comment] List replies failed: code=%s msg=%sFrrc3FK|]}|jdk(yw)rMN)r5).0rrs r z'list_comment_replies..sNQAEE*%8Ns!rzI[Feishu-Comment] list_comment_replies: reply_id=%s not found, retry %d/%dzN[Feishu-Comment] list_comment_replies: reply_id=%s not found after %d attemptsz?[Feishu-Comment] list_comment_replies: total %d replies fetched)r+rVrrrrE_LIST_REPLIES_URIr?r5r8r;ranyr,r/rrr)r@rPrQrLrr all_repliesrfetch_okrirr#r$r(rfounds ` rlist_comment_repliesrs LLUWacmn-.2,.  q Ai($+G  j9:$10%/zJ%OD#t qyUW[]`a HHWb)E%&""5)88J',3J7 <h N+NN   )A- - KK[1.B -- 67 7 7 NN`!5 _2h KKQSVWbScd O> 8s-A5F/8F*9BF/z>)replace)texts r_sanitize_comment_textrs- <<W % - -c6 : B B3 OOrc4Kt|}tjd||dddddd|idgii}t|d t||d d |fg| d{\}}}|d k7rtj d|||ntjd||d k(|fS7Cw)zNPost a reply to a local comment thread. Returns ``(success, code)``. z8[Feishu-Comment] reply_to_comment: comment_id=%s text=%sNdr'elementstext_runr)rWrrrrQrdrzF[Feishu-Comment] reply_to_comment FAILED: code=%s msg=%s comment_id=%sz3[Feishu-Comment] reply_to_comment OK: comment_id=%s)rr+r,rE_REPLY_COMMENT_URIr?) r@rPrQrLrrr#r$ris rreply_to_commentrs "$ 'D KKJD#J(  #&$@  D'*'zBy)*  LD#q  qy T #z  I:V 19d?sABBABc$Kt|}tjd||dd|d|dgd}t|dtd|i| d{\}}}|d k7rtj d |||d k(Stjd |d k(S7Cw) zHAdd a new whole-document comment. Returns ``True`` on success. z9[Feishu-Comment] add_whole_comment: file_token=%s text=%sNrr)rWr)rQreply_elementsrrP)rrrz9[Feishu-Comment] add_whole_comment FAILED: code=%s msg=%sz%[Feishu-Comment] add_whole_comment OK)rr+r,rE_ADD_COMMENT_URIr?)r@rPrQrrr#r$ris radd_whole_commentrs "$ 'D KKKD#J(T *  D'(Z( LD#q  qyRTXZ]^ 19  ;< 19sAB B ABict||kr|gSg}|rgt||kr|j| |S|jdd|}|dkr|}|j|d|||djd}|rg|S)z add_whole_comment - Local comment -> reply_to_comment, fallback to add_whole_comment on 1069302 zW[Feishu-Comment] deliver_comment_reply: is_whole=%s comment_id=%s text_len=%d chunks=%dTrzF[Feishu-Comment] deliver_comment_reply: sending chunk %d/%d (%d chars)NiPzO[Feishu-Comment] Reply not allowed (1069302), falling back to add_whole_commentF)rr+r,r enumeraterr) r@rPrQrLrrrall_okichunkoksuccessr#s rdeliver_comment_replyr*s F KKi*c$iV>Ff%5 v;? KK`As6{CJ 8 (YNNB"26:yR\^c"ddMGT mn,VZERRF  M-, M!Od Ss<BDC?D2D37D*D+ D7 DDDc|jdi}t|tr tj|}|jdg}g}|D]}|jddk(r4|jdi}|j|jddK|jddk(r4|jdi}|j|jdd|jdd k(s|jd i}|jd |jd d dj|S#tj t f$r|cYSwxYw) z? @ A 775>$$i0 N sEEEc|jdd}t|tr&|jddxs|jddSt|S)z"Extract user_id from a reply dict.rr%rS)r5r8r9r=)rrs r_get_reply_user_idrrsGii 2&G'4 {{9b)GW[[B-GG w<rc,|jdi}t|tr tj|}|jdg}g}|D]}|jddk(rA|jdi}|jdd}|r||k(rC|jd|X|jddk(r4|jdi}|j|jd d|jdd k(s|jd i} |j| jd dd jdj|jjS#tj t f$r|cYSwxYw) zRExtract semantic text from a reply, stripping self @mentions and extra whitespace.r'rrWrrr%rrrrrv ) r5r8r=r-r4r6rrrsplitstrip) r self_open_idr'rrrruidrrs r_extract_semantic_textrzsaii 2&G'3 jj)G{{:r*H E 3 88F x 'XXh+F**Y+C| 3 LL1SE # XXf  +xx B/H LLfb1 2 XXf  ,b1I LLub1 2 3 88BGGEN((* + 1 1 33'$$i0 N sE55FFz(?:feishu\.cn|larkoffice\.com|larksuite\.com|lark\.suite\.com)/(?Pwiki|doc|docx|sheet|sheets|slides|mindnote|bitable|base|file)/(?P[A-Za-z0-9_-]{10,40})z"/open-apis/wiki/v2/spaces/get_nodeczt}g}|D]}|jdi}t|tr t j |}|jdgD]}|jddvr|jdxs|jdxsi}|jdd}|sTtj|}|sl|jd } |jd } | |vr|j| |j|| | d  |S#tj tf$rY*wxYw) zExtract unique document links from a list of comment replies. Returns list of ``{"url": "...", "doc_type": "...", "token": "..."}`` dicts. r'rrW>linkrrrrvr%rqtoken)rvrqr) setr5r8r=r-r4r6r_FEISHU_DOC_URL_REsearchgrouprar) r seen_tokenslinksrr'r link_datarvmrqrs r_extract_docs_linksrs: %K EM))Ir* gs # **W-KK B/ MDxx'<<-G&1AGRI--r*C"))#.Awwz*HGGG$E # OOE " LL(UK L MM. L%(()4  sDD:9D:cKt|dtd|fd|fgd{\}}}|dk(r*|jdi}|jdd }|r|SdStj d ||||y7Qw) zReverse-lookup: given an obj_token, find its wiki node_token. Returns the wiki_token if the document belongs to a wiki space, or None if it doesn't or the API call fails. rrobj_typerNrnode node_tokenr%zE[Feishu-Comment] Wiki reverse lookup failed: code=%s msg=%s obj=%s:%s)rE_WIKI_GET_NODE_URIr5r+r?)r@r obj_tokenr#r$r(r wiki_tokens r_reverse_lookup_wiki_tokenrs*)9% H'=>OD#t qyxx#XXlB/ 'z1T1 NNZ\`begoqz{ sA3A1AA3cK|Dcgc] }|ddk(s |}}|s|S|D]}|d}t|dtd|fgd{\}}}|dk(rt|jdi} | jd d } | jd d } | r%| r#tj d || | | |d <| |d<tj d|tj d||||Scc}w7w)zResolve wiki links to their underlying document type and token. Mutates entries in *links* in-place: replaces ``doc_type`` and ``token`` with the resolved values for wiki links. Non-wiki links are unchanged. rqwikirrrNrrrr%rz+[Feishu-Comment] Wiki resolved: %s -> %s:%s resolved_typeresolved_tokenz0[Feishu-Comment] Wiki resolve returned empty: %sz=[Feishu-Comment] Wiki resolve failed: code=%s msg=%s token=%s)rErr5r+r,r?) r@rl wiki_linksrrr#r$r(rrrs r_resolve_wiki_nodesrs#>a mv&=!>J>  s'] - E-z*+!  c4 1988FB'D HHZ4M!XXk26N A ~)6_%)7%&QS]^ NNZ\`begq r)s, L5?  s!C' C C )C'C%B#C'c |syddg}|D]Z}|jd|d}|jd|d}||k(}|rdnd}|jd|d ||d |d d d d\dj|S)z4Format resolved document links for prompt embedding.r%z!Referenced documents in comments:rrqrrz (same as current document)z- :z (rvNrw)r)r5rr)rcurrent_file_tokenlinesrrtypertoken is_currentsuffixs r_format_referenced_docsr s  4 5EI$z*:;*DM:11 2<." r%&&DK4D3EQGH I 99U r c2t||kr|S|d|dzS)z#Truncate text for prompt embedding.Nz...)r)rrs r _truncaters$ 4yE <% rc0t|tkr|St|}t}|jd|j|dz d|cxkr|krnn|j|tt|z }|dz |dz}}|dkDrh|dk\s||kr^|dk\r||vr|j||dz}|dz}|dkDr||kr||vr|j||dz}|dz }|dkDr |dk\rX||kr^t |Dcgc]}|| c}Scc}w)z|Select up to _LOCAL_TIMELINE_LIMIT entries centered on target_index. Always keeps first, target, and last entries. rr)r_LOCAL_TIMELINE_LIMITrrasorted)timeline target_indexnselectedbudgetlohirs r_select_local_timeliner"s  8}-- H AuH LLO LLQL1 \" "S] 2F A |a/B 1*"'R!V 7r) LL  aKF a A:"q&Rx%7 LL  aKF a 1*"'R!V"(!1 2AHQK 22 2s Dc<t|tkr|St|}t}d|cxkr|krnn|j|d|cxkr|krnn|j|tt|z }|dz |dz}}|dkDrh|dk\s||kr^|dk\r||vr|j||dz}|dz}|dkDr||kr||vr|j||dz}|dz }|dkDr |dk\rX||kr^|s |t dSt |Dcgc]}|| c}Scc}w)z~Select up to _WHOLE_TIMELINE_LIMIT entries for whole-doc comments. Prioritizes current entry and nearest self reply. rrN)r_WHOLE_TIMELINE_LIMITrrar) r current_indexnearest_self_indexrrrrrrs r_select_whole_timelinerAs5 8}-- H AuHMA ]# "" '( "S] 2F Q   1B 1*"'R!V 7r) LL  aKF a A:"q&Rx%7 LL  aKF a 1*"'R!V ../00!'!1 2AHQK 22 2s Du= This is a Feishu document comment thread, not an IM chat. Do NOT call feishu_drive_add_comment or feishu_drive_reply_comment yourself. Your reply will be posted automatically. Just output the reply text. Use the thread timeline above as the main context. If the quoted content is not enough, use feishu_doc_read to read nearby context. The quoted content is your primary anchor — insert/summarize/explain requests are about it. Do not guess document content you haven't read. Reply in the same language as the user's comment unless they request otherwise. Use plain text only. Do not use Markdown, headings, bullet lists, tables, or code blocks. Do not show your reasoning process. Do not start with "I will", "Let me", or "I'll first". Output only the final user-facing reply. If no reply is needed, output exactly NO_REPLY. )rreferenced_docsc t|| } d|ddt|ddt|ddt|dddd |d d |d |d |ddt| dt|dg } | D].\}}}|rdnd}| jd|dt||0| r| j| | jd| jtdj | S)z3Build the prompt for a local (quoted-text) comment.zThe user added a reply in "".Current user comment text: ""zOriginal comment text: "zQuoted content: "r"GThis comment mentioned you (@mention is for routing, not task content).Document link: Current commented document: - file_type= - file_token=z - comment_id=r%zCurrent comment card timeline (/ entries): <-- YOU[] r)rrrr_COMMON_INSTRUCTIONSr) doc_titledoc_urlrPrQrL quote_textroot_comment_texttarget_reply_textrrrr rrrris_selfmarkers rbuild_local_comment_promptr7ts& &h =H &i[3 &y1B'C&DAF "9->#?"@B Ij#67q9Q '#% yk"  |$  |$ )#h-#h- S E#+?w&B q IdO#4VH=>? _% LL LL%& 99U r)rrr c t|||} d|ddt|dddd|dd |d |d d t| d t|dg } | D].\} } }|rdnd }| jd| dt| |0| r| j| | jd | jtdj | S)z.Build the prompt for a whole-document comment.zThe user added a comment in "r"r#r$z!This is a whole-document comment.r%r&r'r(r)r%z!Whole-document comment timeline (r*r+r,r-r.r)rrrrr/r)r0r1rPrQ comment_textrrrrr rrrrr5r6s rbuild_whole_comment_promptr:s&h ?QRH ( {"5 &y'>&?qA+Q '#% yk"  |$ +CM?!CM?*U E#+?w&B q IdO#4VH=>? _% LL LL%& 99U rcddlm}m}|}||}ddlm}|}|s'|j dr ddlm}||d}||fS||fS#t$rY||fSwxYw)zIResolve model and provider credentials, same as gateway message handling.r)_load_gateway_config_resolve_gateway_model)_resolve_runtime_agent_kwargsprovider)get_default_model_for_provider) gateway.runr<r=r>r5hermes_cli.modelsr@ Exception)r<r= user_configmodelr>runtime_kwargsr@s r_resolve_model_and_runtimerGsH&(K "; /E924N ^'' 3  H2>*3MNE .  5.     .   sA A! A!2izDict[str, Dict]_session_cachecd|d|S)Nz comment-doc:r)rQrPs r _session_keyrLs )Aj\ 22rcZt5tj|}| gcdddStj|dz t kDr(t|=t jd|gcdddStj|d<t|dcdddS#1swYyxYw)z1Load conversation history for a document session.N last_accessz$[Feishu-Comment] Session expired: %smessages) _session_cache_lockrIr5_timetime_SESSION_TTL_Sr+r,r;)keyentrys r_load_session_historyrVs  '""3' = ' ' ::<% . . ?s# KK> D ' ' %zz|mE*%& ' ' 'sB!?B!3$B!!B*c^|Dcgc](}|jddvr|jdr|*}}t|tkDr |t d}t5|t j dt |<tjd|t|dddycc}w#1swYyxYw)zISave conversation history for a document session (keeps last N messages).role>user assistantr'N)rOrNz0[Feishu-Comment] Session saved: %s (%d messages)) r5r_SESSION_MAX_MESSAGESrPrQrRrIr+r,)rTrOrcleaneds r_save_session_historyr]s 55=1 1aeeI6F G  7|++0012 [ ::< s  FSQX\Z [[[[s-B?B##B,cdddlm}tjdddlm}ddlm}|||| t\}}tjd||jd|jdxsdd d |r t|ng}|r tjd t|||||jd|jd |jd|jd |jdddddddg } tjdt|t|| j||xsd } | jdxsdj} | jdd} tjd| t| | d d|r | jdg} | r t|| | |d |d S#t$r0}tjd|Yd }~|d |d yd }~wwxYw#|d |d wxYw)zCreate an AIAgent with feishu tools and run the prompt. If *session_key* is provided, loads/saves conversation history for cross-card memory within the same document. Returns the agent's final response text, or empty string on failure. r)AIAgentzR[Feishu-Comment] _run_comment_agent: injecting lark client into tool thread-locals) set_clientzE[Feishu-Comment] _run_comment_agent: model=%s provider=%s base_url=%sr?base_urlr%NrHzO[Feishu-Comment] _run_comment_agent: loaded %d history messages from session %sapi_keyapi_modecredential_poolT feishu_doc feishu_drive) rErarbr?rcrd quiet_modeskip_context_files skip_memorymax_iterationsenabled_toolsetsz[[Feishu-Comment] _run_comment_agent: calling run_conversation (prompt=%d chars, history=%d))conversation_historyfinal_response api_callszR[Feishu-Comment] _run_comment_agent: done api_calls=%d response_len=%d response=%srOz5[Feishu-Comment] _run_comment_agent: agent failed: %s) run_agentr_r+r,tools.feishu_doc_toolr`tools.feishu_drive_toolrGr5rVrrun_conversationrr]rC exception)promptr@ session_keyr_set_doc_clientset_drive_clientrErFhistoryagentrzrAro new_messageses r_run_comment_agentr~s" KKdeBF6V, : <~ [>--j9N !::j"5L%k<@ t PRSTt  ts*FG!! H*HHHHH/NO_REPLY add_comment add_reply)rcKtjdt|}|tjdytjd|d}|d}|d}|d}|d }|d } |d } |r|r||k(rtj d |y| r|r | |k7rtj d | xsdy| r| t vrtj d| y|r|r|stjdytjd| ||||ddlm} m} m } m }| }| |||}|jdvr+||r#t|||d{}|r | ||||}|jstjd||y| ||s-tjd||j|jytjd||j|j|r#tj t#||||dtjdtj t%|||}tj t'||||}tj(||d{\}}|j+dd}|j+dd}t-|j+d }tjd!||tjd"||rtjd#t/|||d{}g}d}d$}d$}|D]}|j+d%i}t1|t2r t5j6|}|j+d&g} | D]X}!t=|!}"t?|!}#|r|"|k(nd'}$tA|}%|jC|"|#|$f|"|k(rtE|!|}|%}|$sW|%}Z|s1tGtItK|D]\}&\}"}#}$|$r |#}|&}ntjd(tA||||r|dd)ndg}'|D][}|j+d%i}(t1|(t2r t5j6|(}(|'jM|(j+d&g]tO|'})|)rtQ||)d{})tS|)|}*tU||||||||||** }+n{tjd+tW|||||,d{} |j+d-d},g}d}-d}.d$}/tK| D]r\}&}!t=|!}"t?|!}#|r|"|k(nd'}$|jC|"|#|$f|&dk(r tE|!|}-|!j+dd}0|0s_|0|k(setE|!|}.|&}/t|.s6|r4tGtItK|D]\}&\}"}#}$|"|k(s|#}.|&}/ntjd.tA||/|,r|,dd/nd|-r|-dd/nd|.r|.dd/ndtO| })|)rtQ||)d{})tS|)|}*tY||||||,|-|.|||/|*0 }+tjd1tA|+tj d2|+t[||}1tj\}2|2j_dt`|+||1d{}3|3rtb|3vrtjd3ntjd4tA|3|3dd5tjd6||te|||||3|d{}4|4rtjd7ntjgd8|rti||||dd{tjd9y7E77#t4j8t:f$ri}YZwxYw#t4j8t:f$ri}(YpwxYw75777*77uw):aFull orchestration for a drive comment event. 1. Parse event + filter (self-reply, notice_type) 2. Add OK reaction 3. Fetch doc meta + comment details in parallel 4. Branch on is_whole: build timeline 5. Build prompt, run agent 6. Deliver reply zG[Feishu-Comment] ========== handle_drive_comment_event START ==========Nz7[Feishu-Comment] Dropping malformed drive comment eventz5[Feishu-Comment] [Step 0/5] Event parsed successfullyrPrQrLrMrTrUrRz6[Feishu-Comment] Skipping self-authored event: from=%sz<[Feishu-Comment] Skipping event not addressed to self: to=%sz(empty)z([Feishu-Comment] Skipping notice_type=%sz2[Feishu-Comment] Missing required fields, skippingz?[Feishu-Comment] Event: notice=%s file=%s:%s comment=%s from=%sr) load_config resolve_ruleis_user_allowed has_wiki_keys>topwildcard)rz6[Feishu-Comment] Comments disabled for %s:%s, skippingz4[Feishu-Comment] User %s denied (policy=%s, rule=%s)z:[Feishu-Comment] Access granted: user=%s policy=%s rule=%sr^)rPrQrMr_zJ[Feishu-Comment] [Step 2/5] Parallel fetch: doc meta + comment batch_queryruUntitledrvr%rz6[Feishu-Comment] Comment context: title=%s is_whole=%sz;[Feishu-Comment] [Step 3/5] Building timeline (is_whole=%s)zA[Feishu-Comment] Fetching whole-document comments for timeline...rrrFzQ[Feishu-Comment] Whole timeline: %d entries, current_idx=%d, self_idx=%d, text=%srw) r0r1rPrQr9rrrrr z3[Feishu-Comment] Fetching comment thread replies...rrzV[Feishu-Comment] Local timeline: %d entries, target_idx=%d, quote=%s root=%s target=%sr) r0r1rPrQrLr2r3r4rrrr zE[Feishu-Comment] [Step 4/5] Prompt built (%d chars), running agent...z [Feishu-Comment] Full prompt: %sz;[Feishu-Comment] Agent returned NO_REPLY, skipping deliveryz.[Feishu-Comment] Agent response (%d chars): %srpzI[Feishu-Comment] [Step 5/5] Delivering reply (is_whole=%s, comment_id=%s)z-[Feishu-Comment] Reply delivered successfullyz([Feishu-Comment] Failed to deliver replyzE[Feishu-Comment] ========== handle_drive_comment_event END ==========)5r+r,r]r?rV_ALLOWED_NOTICE_TYPES-plugins.platforms.feishu.feishu_comment_rulesrrrr match_sourcerenabledpolicyr/ ensure_futurerkr{rgatherr5rYrr8r=r-r4r6rrrrrrreversedr;rrrrr r:rr7rLget_running_looprun_in_executorr~_NO_REPLY_SENTINELrrgrn)5r@r(rparsedrPrQrLrMrTrUrRrrrr comments_cfgruler meta_task comment_taskdoc_metacomment_detailr0r1rwhole_commentsr current_textrrwcrrrrrr5idxrall_raw_repliesrl doc_links ref_docs_textrvr2 root_text target_textrridsess_keylooprArs5 rhandle_drive_comment_eventr`s0 KKYZ &t ,F ~PQ KKGH %J{#I %Jj!H.)L %J'K )E M|\ ,:+E SU_Ulclm{*?? ?M YjKL KKIY J  xw=L  i M R,,i8$!#J$B,,i8B E& NE2  s E_3^D,_3>^?B_3^3_3^#A*_31_3A_3_/?_3._#/A_3>_&?B_3_3 A_3A_3)_)*B_3_,A1_34_/5A_3;_1<_3_3_3^>:_3=^>>_3_ _3_  _3&_3)_3,_3/_31_3)NNN)rr=rr=)r(rreturnzOptional[Dict[str, Any]]) r@rrPr=rQr=rMr=r_r=rrY)r@rrPr=rQr=rDict[str, Any]) r@rrPr=rQr=rLr=rr)r@rrPr=rQr=rList[Dict[str, Any]]) r@rrPr=rQr=rLr=rr=rr)rr=rr=) r@rrPr=rQr=rLr=rr=rzTuple[bool, int]) r@rrPr=rQr=rr=rrY)rr=rintrz List[str])r@rrPr=rQr=rLr=rr=rrYrrY)rrrr=)r%)rrrr=rr=)rrrList[Dict[str, str]])r@rrr=rr=rz Optional[str])r@rrrrr)rrrr=rr=)rr=rrrr=)rList[Tuple[str, str, bool]]rrrr)rrrrrrrr)r0r=r1r=rPr=rQr=rLr=r2r=r3r=r4r=rrrr=rrr r=rr=)r0r=r1r=rPr=rQr=r9r=rrrr=rrrrr r=rr=)rzTuple[str, dict])rQr=rPr=rr=)rTr=rr)rTr=rOrrNone)rvr=r@rrwr=rr=)r@rr(rrr=rr)N__doc__ __future__rr/r-loggingtypingrrrrr getLoggerrXr+rrEr]rhrkrnrxrrrrrr{rrrrrrrr_REPLY_CHUNK_SIZErrrrrre_recompilerrrrrr _PROMPT_TEXT_LIMITrrrrrrr/r7r:rG threadingrRrQr[rSLockrPrI__annotations__rLrVr]r~rrrrKrrrs@,# 33   8 $.#V+dJ  / // /  /  / /p % %% %  %  % %X@WEXYG' ' '-0''T0 0 0-00>A00f( ( (-0((Z!@ @ @-0@>A@@@FP   -0>AILD  -08; :):$( ((( (  (  ( (`04@!S[[( :B +.*# # ##N<>   58  ('9 3)33!3> 3) 3 3 3! 3F  EG8*** *  *  ********* *l &&& &  &  &*&&&&& &\!2$inn&"$$3 '[$<F ' 446FY FYFY-0FY FYr