+ kHjB Na0t$Rt^RIHt^RIt^RIt^RIt^RIt^RIt^RI t ^RI t ^RI t ^RI t ^RI t ^RIt^RIt^RIt^RIt^RIHt^RIHt^RIHt^RIHtHtHtHtHtHtHt^RIH t H!t!] PD!]#4t$^xt%^RI&t&]&RJt(^RI)H*t*^R I+H,t,H-t-H.t.],RJt/^R I0H1t1H2t2^R I3H4t4H5t5H6t6^R I7H8t8^R I9H:t:^RI;Ht>H?t?H@t@HAtAHBtBHCtC^RIDHEtEHFtF^RIGHHtH^RIIHJtJ^RIKHLtLHMtNHOtP^RIQHRtRHStSRRRlltTRtURtVRRRutWtXtYRRRutZt[t\RRut]t^R R!ut_t`Rwtatbtctd^^^utetftgRRuthtiR"tjRwtktltmtnRwtotptqtrts^^utttu^^utvtw/txR#]yR$&] P!R%4t{] P!R&4t|] P!R'4t}R(R)lt~R*R+ltR,R-ltR.R/ltR0R1ltR2R3ltRR4R5lltRR6R7lltR8R9ltR:R;ltR<R=ltR>R?ltR@RAltRBR/RCRDlltRERFlt!RGRH4t!RIRJ4tRKRLltRMRNltROR/RPRQlltRRRSltRTRUltRVRWltRXRYltRZR[ltR\R]ltR^R_ltR`RaltRbRc/RdRellt]!0Rm4tRf]yRg&RhRiltRjRkltRlRmltRnRoltRpRqltRrRsltRtRultRvRwltRxRyltRzR{ltRR}R~lltRRRlltRRltR]FEPT3R]FEPV3R]FEPX33tRRltRRltRRltRRltRRltRRRbR/RRllt]rRR3]pRR3]sRR3]qRR3/tR]yR&RRlt]!]]r4]!]]p4utt]!]]s4]!]]q4utt]pRRRRR3]sRRRRR3]rRRcRRR3]qRRcRRR3/tR]yR&]!0Rm4RR3]=RR3]``; stripped.WEIXIN_)r1 _extra_or_envupperstrip)r.r0r2s&&&r6_extra_or_secretr>-s, }U7399;-)@'J K Q Q SSr8zhttps://ilinkai.weixin.qq.comz%https://novac2c.cdn.weixin.qq.com/c2cbotz2.2.0zilink/bot/getupdateszilink/bot/sendmessagezilink/bot/sendtypingzilink/bot/getconfigzilink/bot/getuploadurlzilink/bot/get_bot_qrcodezilink/bot/get_qrcode_statusi,r/_LIVE_ADAPTERSz^(#{1,6})\s+(.+?)\s*$z3^\s*\|?(?:\s*:?-{3,}:?\s*\|)+\s*:?-{3,}:?\s*\|?\s*$z^```([^\n`]*)\s*$c(V^8dQhRRRRRRRR/#)r-retz Optional[int]errcodeerrmsg Optional[str]r3boolr4)r5s"r6r7r7Fs)}}m`dr8cV\8H;'gV\8H;'dT;'gRP4R9#)zRRecognize stale-session variants of iLink's ``-2`` response, not real rate limits.r+> unknown errorprepare failed)RATE_LIMIT_ERRCODElowerrBrCrDs&&&r6_is_stale_session_retrMFsF % % F F4F)F  V\\WYL`L`LbgMr8c(V^8dQhRRRRRRRR/#)r-respr/rBrrCr3rFr4)r5s"r6r7r7Ns.CCnC3CCCr8c\W39;'g5\YVPR4;'gVPR44#)rDmsg)SESSION_EXPIRED_ERRCODErMget)rOrBrCs&&&r6_is_session_expiredrTNs] "sn 4 C C8Mc\`\d\dem\n]B]Brvrzrz|AsB9CCr8c(V^8dQhRRRRRRRR/#)r-rBrrCrDr3 RuntimeErrorr4)r5s"r6r7r7Rs.HH#HHSH\Hr8c @\RT RT RT;'gR R24#)uThe stale-session ``-2`` after the tokenless re-send is exhausted (or with no token to drop): iLink will not prepare a bot-initiated send until this peer messages the bot again. Deterministic, so it is neither retried nor fed to the rate-limit breaker (#80125). The text must not contain "rate limit" — ``classify_send_error`` would route it back into the rate-limited redelivery lane.z)iLink sendmessage session not ready: ret= errcode= errmsg=rHu< — the user must send the bot a message first (or re-pair))rVrLs&&&r6_session_not_ready_errorrZRs:  3C5 '(SYSlSl]lRmF G HHr8cV^8dQhRR/#)r-r3zOptional[aiohttp.TCPConnector]r4)r5s"r6r7r7\s@@;@r8c^RIp^RIHp\'gR#T!4pTfR#\ P !TPTR7^RR7# \dR#i;i)aTCPConnector with certifi's CA bundle (``ilinkai.weixin.qq.com`` fails some system stores, e.g. Homebrew OpenSSL); None when no certifi bundle resolves (absent, or deleted by an install-environment rotation and not re-derivable), so aiohttp's default (honors ``SSL_CERT_FILE`` under trust_env) applies. ``keepalive_timeout=2`` + ``enable_cleanup_closed`` drain idle CLOSE_WAIT sockets behind proxies like Warp. Uses a tight ``keepalive_timeout=2`` (default aiohttp: 30s) so idle connections drain promptly behind proxies like Cloudflare Warp that leave peer-initiated FIN in ``CLOSE_WAIT`` (same class as #18451). ``enable_cleanup_closed=True`` helps the connector clean up sockets that the remote side has already closed. N)certifi_bundle_path)cafileT)sslkeepalive_timeoutenable_cleanup_closed)r_agent.ssl_verifyr] ImportErrorAIOHTTP_AVAILABLEaiohttp TCPConnectorcreate_default_context)r_r]r^s r6_make_ssl_connectorrh\sc8  ! "F ~   C$>$>f$>$Mabz~  s A AAc V^8dQhRRRR/#)r-kwargsrr3aiohttp.ClientSessionr4)r5s"r6r7r7wskk3k#8kr8c V\P!RR\4R\4/VB#) trust_env connectorr4)re ClientSessionrrh)rjs,r6 _new_sessionrpws)  j+<+> jJ]J_ jci jjr8cV^8dQhRR/#r-r3rFr4)r5s"r6r7r7{s2242r8c*\;'d\#N)rdCRYPTO_AVAILABLEr4r8r6check_weixin_requirementsrv{s  1 1!11r8c$V^8dQhRRRRRR/#)r-valuerEkeepintr3r1r4)r5s"r6r7r7s!&&M&&S&r8cf\T;'gR4P4pV'dVRV#R#)r+N?)r1r=)rxryraws&& r6_safe_idr~s. ekkr  "C3u:%#%r8c$V^8dQhRRRRRR/#)r-databytes block_sizerzr3r4)r5s"r6r7r7s!--U--U-r8chV\V4V,, pV\V.V,4,#rt)lenr)rrpad_lens&& r6 _pkcs7_padrs,CI 23G % G+, ,,r8c$V^8dQhRRRRRR/#)r- plaintextrr0r3r4)r5s"r6r7r7s&JJ5JuJJr8c\\P!V4\P!4\ 4R7P 4pVP\V44VP4,#)backend) rrAESrECBr encryptorupdaterfinalize)rr0rs&& r6_aes128_ecb_encryptrsOz~~c*EIIKARS]]_I   Jy1 2Y5G5G5I IIr8c$V^8dQhRRRRRR/#)r- ciphertextrr0r3r4)r5s"r6r7r7s!E%r8c\\P!V4\P!4\ 4R7P 4pVPV4VP4,pV'd VR,M^p^Tu;8:d^8:d3MV#VP\V.4V,4'dVRV)#V#)z[Decrypt and strip PKCS#7 padding when it is well-formed (else return the raw block output).rN) rrrrrr decryptorrrendswithr)rr0rpaddedrs&& r6_aes128_ecb_decryptrsz~~c*EIIKARS]]_I   j )I,>,>,@ @F"fRjGGr M%ooeWI.>.HIIix  Mr8c$V^8dQhRRRRRR/#)r-tokenrEbodyr1r3dict[str, str]r4)r5s"r6r7r7s!Mr8cp\P!\\P \ P !^4R44PR44PR4pRRRRR\\VPR444R VR \R \\4/V'd R R V 2/C#/C#)bigzutf-8ascii Content-Typezapplication/jsonAuthorizationTypeilink_bot_tokenzContent-Lengthz X-WECHAT-UIN iLink-App-IdiLink-App-ClientVersion AuthorizationzBearer ) base64 b64encoder1rz from_bytessecrets token_bytesencodedecoder ILINK_APP_IDILINK_APP_CLIENT_VERSION)rruins&& r6_headersrs   3s~~g.A.A!.DeLMTTU\] ^ e efm nC*,?AR#c$++g"678.# &?E]A^ 49Owug. /  ?A  r8c V^8dQhRRRR/#)r- hermes_homer1r3rr4)r5s"r6r7r7scdr8c^\V4R, R, pVPRRR7V#)weixinaccountsT)parentsexist_ok)rmkdir)rpaths& r6 _account_dirrs+  x '* 4DJJtdJ+ Kr8c V^8dQhRRRR/#)r-rrr3rr4)r5s"r6r7r7sTcr8cVP4'd'\P!VPRR74#R# \dR#i;i) utf-8-sigencodingN)existsjsonloads read_text Exception)rs&r6 _read_jsonrsCCG;;==tzz$..+.>?ZVZZ sA%AA AAuser_idc 0V^8dQhRRRRRRRRRRRR/#) r-rr1 account_idrbase_urlrr3Noner4)r5s"r6r7r7s9SSTWbeosr8c L\V4V R2, p\P!R\P!44p\ VRVRVRVRV/4\ P !\4;_uu_4VPR4RRR4R# +'giR#;i).jsonz%Y-%m-%dT%H:%M:%SZrrrsaved_atiN) rtimestrftimegmtimer% contextlibsuppressOSErrorchmod)rrrrrrrs&$$$$ r6save_weixin_accountrsx  $*U'; ;D}}14;;=AHdWeZ9gWacklm   W % % 5 & % % %s 6B B# c$V^8dQhRRRRRR/#)r-rr1rr3Optional[dict[str, Any]]r4)r5s"r6r7r7s'HHSHcH>VHr8c>\\V4V R2, 4#)r)rr)rrs&&r6load_weixin_accountrs l;/ZL2FF GGr8cl]tRt^tRtRRlt]RRl4tRRltRR lt R R lt R R lt Rt R#)ContextTokenStorez??{{}}  ::dnnknBCD=AJJLeLDAJWXZ]L^/cd/DIIj,a/Le 8$  KKEs8}V^_iVj k    NNPRZ[eRfhk l  fs)&C;)D4D4D4; D1 D,,D1c$V^8dQhRRRRRR/#)r-rr1rr3rEr4)r5s"r6r7rs!??c?C?M?r8c VVPPVPW44#rt)rrSr)rrrs&&&r6rSContextTokenStore.gets{{tyy=>>r8c(V^8dQhRRRRRRRR/#)r-rr1rrr3rr4)r5s"r6r7rs.HHCH#HcHdHr8c "W0PVPW4&VP;_uu_4GRjxL V R2pVPP4UUu/uF-wrVVP V4'gKV\ V4RVbK/ ppp\ P!VPW4GRjxL RRR4GRjxL R#LuuppiLL +GRjxL 'giR#;i5i)Nr) rrrr startswithrr to_thread_persist)rrrrprefixr0rxpayloads&&&& r6setContextTokenStore.sets6; DIIj23%%%%"|1%FBF++BSBSBUpBUJCY\YgYghnYo/s3v;<(%/BUGp##DMM:G G G&%%p G&%%%sn6C9CC9#CC ?C 'C9C:C> C9 C C9CC9C6 "C%# C6 .C6 0 C9c$V^8dQhRRRRRR/#)r-rr1rrr3rr4)r5s"r6r7rs&mm3mmDmr8c \VPV R2, V4R# \d,p\P R\ T4T4Rp?R#Rp?ii;i)rz3weixin: failed to persist context tokens for %s: %sN)r%rrrrr~)rrrrs&&& r6rContextTokenStore._persistsR m djjj\9M+NNPW X m NNPRZ[eRfhk l l ms $ A AA)rrrN) __name__ __module__ __qualname____firstlineno____doc__r staticmethodrrrSrr__static_attributes__r4r8r6rrs;F,)) l?Hmmr8rcB]tRt^tRtR RRlltRRltRRltRtR #) TypingTicketCachez3Short-lived typing ticket cache from ``getconfig``.cV^8dQhRR/#)r- ttl_secondsfloatr4)r5s"r6r7TypingTicketCache.__annotate__s77E7r8c Wn/VnR#rt) _ttl_secondsr)rrs&&r6rTypingTicketCache.__init__s'46 r8c V^8dQhRRRR/#)r-rr1r3rEr4)r5s"r6r7rs3=r8c VPPV4pV'd<\P!4V^,, VP8d V^,#VPP VR4R#)N)rrSrrpop)rrentrys&& r6rSTypingTicketCache.getsQ ( TYY[58+d.?.??8O &r8c$V^8dQhRRRRRR/#)r-rr1ticketr3rr4)r5s"r6r7rs!553555r8c NV\P!43VPV&R#rt)rr)rrr!s&&&r6rTypingTicketCache.sets & 4 Gr8)rrN)g@) r r r r rrrSrrr4r8r6rrs=755r8rc V^8dQhRRRR/#)r- aes_key_b64r1r3rr4)r5s"r6r7r7sRRRRr8cz\P!V4p\V4^8XdV#\V4^ 8XdVPRRR7MRpV'dP\;QJdRV4F 'dK RM RM !RV44'd\ P V4#\R\V4 R 24h) rignore)errorsr+c3*"TF qR9xK R#5i)0123456789abcdefABCDEFNr4).0chs& r6 !_parse_aes_key..sBTr22TsFTzunexpected aes_key format (z decoded bytes))r b64decoderrallrfromhex ValueError)r%decodedtexts& r6_parse_aes_keyr6s{+G 7|r7:7|r7I7>>'(> 3rD BTBBTBBB}}T"" 23w<.P QQr8c$V^8dQhRRRRRR/#)r-messager/rr1r3tuple[str, str]r4)r5s"r6r7r7s!88n8#8/8r8c$\VPR4;'gVPR4;'gR4P4p\VPR4;'gR4P4pV'g-V'd_V'dWW18wdQVPR4^8Xd;RT;'g/T;'g%\VPR4;'gR43#R\VPR4;'gR43#)room_id chat_room_idr+ to_user_idmsg_typegroup from_user_iddm)r1rSr=)r8rr;r=s&& r6_guess_chat_typerBs'++i(MMGKK,GMM2NTTVGW[[.44"5;;=J:*1IgkkZdNeijNjWW:WWW[[5P5V5VTV1WWW W[[066B7 77r8rc8V^8dQhRRRRRRRRRRR R R R R R/#)r-sessionrkmethodr1rendpointheadersr timeout_msrzrrEr3r/r4)r5s"r6r7r7sZ D D " D,/ D>A DMP D[i Dwz DCP D Dr8caaaaaa"RVVVVVV3Rllp\P!V!4VR, R7GRjxL #L5i)cV^8dQhRR/#)r-r3r/r4)r5s"r6r7"_api_request..__annotate__s##~#r8c <"SeRS/M/p\SSP44!SPR4 RS 23RS/VB;_uu_4GRjxL pVP4GRjxL pVP'g)\ RS RS RVP RVR, 24h\P!V4uuRRR4GRjxL #L~LhL +GRjxL 'giR#;i5i) Nr/rGziLink  z HTTP : NN) getattrrKrstripr5okrVstatusrr) rjresponser}rrrFrGrErDs r6_do_api_request.._dos#'#3&$7FLLN3xs7K6LAhZ4XtbitmstttyA 'C;;;"VF81XJfX__DUUWX[\`XaWb#cdd::c? utt'utttsfAC3CC3C)C*C=C= C3 C C3CC3C0 C C0 (C0 * C3itimeoutNrwait_for)rDrErrFrGrHrrWsffddd$d r6 _api_requestr]s2##!!#%d1BC CC Cs6AAAc4V^8dQhRRRRRRRRRR R R R R/#) r-rDrkrr1rFrr/rrErHrzr3r4)r5s"r6r7r7sQVV "V14V@CVN\VerVADVVr8c "\P!/VCRR\//CRRR7p\VRW\ WF4WVR7GRjxL #L5i) base_infochannel_versionF) ensure_ascii separatorsPOST)rrFrGrHrN),r)rdumpsCHANNEL_VERSIONr]r)rDrrFrrrHrs&$$$$$ r6 _api_postrhsb ::TT+0A?/STchu ADgv]efk]r@JV VV VsAA A A c ,V^8dQhRRRRRRRRRR /#) r-rDrkrr1rFrHrzr3r/r4)r5s"r6r7r7&s9||1||s|`c|hv|r8c j"R\R\\4/p\VRWWCR7GRjxL #L5i)rrGET)rrFrGrHN)rr1rr])rDrrFrHrGs&$$$ r6_api_getrl&s2|-FLdHefGgux\c{ {{ {s *313c 0V^8dQhRRRRRRRRRRR R /#) r-rDrkrr1rsync_bufrHrzr3r/r4)r5s"r6r7r7+sGCC 5CCCPSC_bCpsCyGCr8c |"\W\RV/W$R7GRjxL #L \d R^R.RT/u#i;i5i)get_updates_bufrrFrrrHNrBmsgs)rhEP_GET_UPDATES TimeoutError)rDrrrnrHs&$$$$r6 _get_updatesru+s^CwN]npx\yBG__ __ Cq&"&7BBCs(<#!#<#9<9<c8V^8dQhRRRRRRRRRRR R R RR R /#)r-rDrkrr1rto item_listlist[dict[str, Any]] context_tokenrE client_idr3r/r4)r5s"r6r7r72s^SS "S14S=@SFISVjS|ISVYSSr8c "RRRVRVR\R\RV/pV'dWWR&\W\RV/V\R 7GR jxL #L5i) r@r+r=r{ message_type message_staterxrzrQrqN) MSG_TYPE_BOTMSG_STATE_FINISHrhEP_SEND_MESSAGEAPI_TIMEOUT_MS)rDrrrwrxrzr{r8s&$$$$$$ r6 _send_itemsr2sn L"k9nVbdsvFY G#0 7Z_ahYiqvDRS SS SsAA AA c8V^8dQhRRRRRRRRRRRR R RR R /#) r-rDrkrr1rrwr5rzrEr{r3r/r4)r5s"r6r7r7=sZTT "T14T=@TFITQTTerT@CTTr8c "V'dVP4'g \R4hR\RRV//.p\WW#WuVR7GRjxL #L5i)z%_send_message: text must not be emptytype text_itemr5rrrwrxrzr{N)r=r3 ITEM_TEXTr)rDrrrwr5rzr{rxs&$$$$$$ r6 _send_messager=s^ tzz||@AA)[64.ABIWuW`JST TT TsA*A A Ac 0V^8dQhRRRRRRRRRRR R /#) r-rDrkrr1rrrzrEr3r/r4)r5s"r6r7r7FsFKK4K3KsK]`Kq~KDRKr8c l"RV/pV'dWER&\W\WR\R7GRjxL #L5i) ilink_user_idrzrqN)rh EP_GET_CONFIGCONFIG_TIMEOUT_MS)rDrrrrzrs&$$$$ r6 _get_configrFsC.8G#0 7 W^yJK KK Ks +424cDV^8dQhRRRRRRRRRRR RR RR RR RR RRR/ #)r-rDrkrr1rr= media_typerzfilekeyrawsize rawfilemd5filesize aeskey_hexr3r/r4)r5s"r6r7r7MssLL "L14L=@LNQL_bLmpL{~LL"L03LLr8c p"RVRVRVRVRVRVRRRV /p \W\W\R 7GR jxL #L5i) rrr=rrr no_need_thumbTaeskeyrqN)rhEP_GET_UPLOAD_URLr) rDrrr=rrrrrrrs &$$$$$$$$$ r6_get_upload_urlrMsa 7L*lJPY[bdpr|HotXzKG7@Q[b}KL LL Ls -646c(V^8dQhRRRRRRRR/#)r-rDrkrr upload_urlr1r3r4)r5s"r6r7r7Ws+ 6 6&; 6E 6_b 6gj 6r8ctaaa"RVVV3Rllp\P!V!4^xR7GRjxL #L5i)cV^8dQhRR/#)r-r3r1r4)r5s"r6r7(_upload_ciphertext..__annotate__Xsaasar8c<"SPSSRR/R7;_uu_4GRjxL pVP^8XdVPPR4MRpV'd-VP 4GRjxL TuuRRR4GRjxL #VP 4GRjxL R,p\ VP^8Xd RV 24hRVP RV 24hLLnL]LF +GRjxL 'giR#;i5i) rapplication/octet-stream)rrGNzx-encrypted-paramrPz-CDN upload missing x-encrypted-param header: zCDN upload HTTP rO)postrUrGrSreadr5rV)rVencrypted_paramr}rrDrs r6rW_upload_ciphertext.._doXs<< nVpEq<rrrv~KS??^aKah..223FGgkOmmo%%& srr "($/CX`XgXgknXn!NseTa awGHPHWHWGXXZ[^Z_u`a a s&s ) srrrs#DC!D6C)!C)4C#5C): DC%D C) C'!AC)!D#C)%D'C))D /C20 D ;D = DrYNr[)rDrrrWsfdd r6_upload_ciphertextrWs/aa!!#%5 55 5s ,868timeout_secondsgN@c(V^8dQhRRRRRRRR/#) r-rDrkurlr1rrr3rr4)r5s"r6r7r7cs1BB#8B#BX]BinBr8cpaa"RVV3Rllp\P!V!4VR7GRjxL #L5i)cV^8dQhRR/#)r-r3rr4)r5s"r6r7%_download_bytes..__annotate__ds))u)r8c <"SPS4;_uu_4GRjxL pVP4VP4GRjxL uuRRR4GRjxL #L>LL +GRjxL 'giR#;i5irt)rSraise_for_statusr)rVrDrs r6rW_download_bytes.._dodsN;;s###x  % % '!($##($###s\BA B$A& A" A& BA$B"A&$B&B ,A/- B 8B : BrYNr[)rDrrrWsfd$ r6_download_bytesrcs-))!!#%A AA As +646zfrozenset[str]_WEIXIN_CDN_ALLOWLISTc V^8dQhRRRR/#)r-rr1r3rr4)r5s"r6r7r7os | | | |r8c&\V4pVPP4VP;'gRr2TR9d\ RT: R24hT\ 9d\ RT: R24hR# \dp\ RT: 24ThRp?ii;i)r+zUnparseable media URL: Nz Media URL has disallowed scheme z ; only http/https are permitted.zMedia URL host zG is not in the WeChat CDN allowlist. Refusing to fetch to prevent SSRF.>httphttps)rschemerKhostnamerr3r)rparsedrhostrs& r6_assert_weixin_cdn_urlrosE#}}**,foo.C.C&&;F:Eefgg ((?4(2yz{{) E23':;DEs6A0A00 B;B  Bc4V^8dQhRRRRRRRRRRR R R R /#) r-rDrk cdn_base_urlr1encrypted_query_paramrEr%full_urlrrr3rr4)r5s"r6r7r7{sO Y Y " Y58 YQ^ Ymz Y Y.3 Y  Yr8c "V'd#VPR4 R\VRR7 2pM!V'd\V4TpM \R4h\ WVR7GRjxL pV'd\ V\ V44#T#L#5i)rMz /download?encrypted_query_param=r+safez7media item had neither encrypt_query_param nor full_urlrrN)rSr rrVrrr6)rDrrr%rrrr}s&$$$$$ r6_download_and_decrypt_mediar{s}$$S)**J5QfmoKpJqr x(TUU/R RCDO sN;$? @XUXX Ss2B)BB B+BcV^8dQhRR/#)r-contentr1r4)r5s"r6r7r7s..#.r8c#"RpVP4FVpVP4p\\P VP 444pW4V3xV'gKOV'*pKX R#5i)zyYield ``(rstripped line, is_fence, in_code_block)`` per line; ``in_code_block`` is the state *before* a fence toggles it.FN) splitlinesrSrF _FENCE_REmatchr=)r in_code_blockraw_linelineis_fences& r6_walk_markdown_linesrsZM&&(   56m++ 8 --M )s AA1$ A1c V^8dQhRRRR/#r-rr1r3r4)r5s"r6r7r7s % % % %r8cJ.p^p\V4Frwr4pV'gBV'g:VP4'g$V^, pV^8:dVPR4KOV'g V'g^pVPV4Kt RPV4P4#)zKrstrip lines and collapse blank runs to one, leaving fenced code untouched.r+ )rr=appendjoin)rresult blank_runrrrs& r6_normalize_markdown_blocksrsFI)=g)F%  djjll NIA~ b!  =I d*G 99V  " " $$r8c V^8dQhRRRR/#rr4)r5s"r6r7r7s&&#&#&r8c V'gV#.p\V4Fwr#pVP4pT;'gET;'g;\V4\8*;'g!V'*;'gVP R4pV'g\ P V4'dVPV4KTP\P!V\RRRRR7;'gV.4K RPV4P4#)zWWrap long display lines that are hard to copy in WeChat clients (not code/table lines).|FT)widthbreak_long_wordsbreak_on_hyphensreplace_whitespacedrop_whitespacer) rr=rWEIXIN_COPY_LINE_WIDTHr_TABLE_RULE_RErrextendtextwrapwrapr)rwrappedrrrstrippedrys& r6$_wrap_copy_friendly_lines_for_weixinrs G)=g)F% ::<{{={{CI9O,O{{W_S_{{ckcvcvwzc{ >''11 NN4 NN8==2U]bw| $&00*. 1 *G 99W  # # %%r8c V^8dQhRRRR/#r-rr1r3 list[str]r4)r5s"r6r7r7s00C0I0r8c|aa.o.oRVV3Rllp\V4Fwwr#pV'dV'gV!4V'gV'gVP4'dSPV4MV!4V'gKfV'gKpV!4Ky V!4SUu.uFqU'gK VNK up#uupi)cV^8dQhRR/#r-r3rr4)r5s"r6r7,_split_markdown_blocks..__annotate__s4r8c<S'dASPRPS4P44SP4R#R#)rN)rrr=clear)blockscurrentsr6flush%_split_markdown_blocks..flushs2  MM$))G,224 5 MMO r8)rr=r)rrrrrblockrrs& @@r6_split_markdown_blocksrsFG*>g)F% M G } NN4 G 8 G*G G% /veEEv // /s " B90B9c V^8dQhRRRR/#rr4)r5s"r6r7r7s,,c,i,r8c.p\V4EF=p\PVP4^,P 44'dVP V4KU.pVP4FpVP 4pV'dAVP 4'd+VPR4'dVP V4K[VP RPV4P 44VP 4'dV.M.pK VP RPV4P 44EK@ VUu.uFqf'gK VNK up#uupi)zpTop-level lines become units; fenced code stays intact; indented continuation lines attach to the previous line.rrN ) rrrrr=rrSrr)runitsrrrrunits& r6 _split_delivery_units_for_weixinrs E'0 ??5++-a0668 9 9 LL  ((*H??$D4::<-*u【#r)r=rFrrrrre)rrs& r6"_looks_like_chatty_line_for_weixinrszz|H  F FS]b( F F1M-M F FV^ViVikKWLSL F F$$X. . F F79xx@RT\7]3] F Ffhfnfnoz}EgFcF GGr8c V^8dQhRRRR/#)r-rr1r3rFr4)r5s"r6r7r7sKKSKTKr8cVP4Uu.uFqP4'gKVNK pp^\V4u;8:d ^8:gR#R#V^,P4p\P V4'g(\V4^8:dVP R4'dR#\ ;QJdRV4F 'dK R# R#!RV44#uupi)ziSplit only chat-like multiline blocks (2-6 chatty lines, first line not a heading) into separate bubbles.Fc38"TFp\V4xK R#5irt)r)r,rs& r6r.<_should_split_short_chat_block_for_weixin..sJED1$77EsT)ru：)rr=r _HEADER_RErrr1)rrlinesfirsts& r6)_should_split_short_chat_block_for_weixinrs#..0 A0dJJLTT0E A E a   !HNN E3u:#3|8T8T 3JEJ33J3J3JEJ JJ Bs C$C$c$V^8dQhRRRRRR/#)r-rr1 max_lengthrzr3rr4)r5s"r6r7r7s&^^c^s^y^r8cda\V4S8:dV.#V3Rlp\\V4SVR7#)c2<\P!VS4#rt)rtruncate_message)rrs&r62_pack_markdown_blocks_for_weixin..s0AA%Tr8)overflow)rrr)rrrs&f r6 _pack_markdown_blocks_for_weixinrs2 7|z!yTH 4W=zT\ ]]r8Fc(V^8dQhRRRRRRRR/#) r-rr1rrzsplit_per_linerFr3rr4)r5s"r6r7r7s0zzSzczSWzdmzr8cV'g.#V'd\V4V8:d RV9dV.#\V4pVUUu.uF)p\V4V8:dV.M \WA4FqUNK K+ pppVUu.uFqU'gK VNK up;'gV.#\V4V8d\W4;'gV.#\V4'd \V4#V.#uuppiuupi)a Compact (default): one message when it fits, unless it reads as a short chatty exchange (separate bubbles). Per-line (legacy ``extra.split_multiline_messages`` / ``WEIXIN_SPLIT_MULTILINE_MESSAGES``): top-level line breaks become separate messages. Oversized units use block-aware packing.r)rrrr)rrrrrcchunkss&&& r6_split_text_for_weixin_deliveryrs   w<: %$g*=9 09"UCFj4HaSNnopN}-}q!-}!U!'6aQ6'44G94 7|j /DQQ Q8abi8j8j +G 4yqxpyy @'s/C3 C C c$V^8dQhRRRRRR/#)r-rxrr2rFr3r4)r5s"r6r7r7 s&uuududur8cVfV#\V\\34'd \V4#\ V4P 4P 4pVR9dR#VR9dR#T#)zZCoerce a config value to bool, tolerating strings like ``"true"``; unknown -> ``default``.TF>1onyestrue>0noofffalse)rrzrrFr1r=rK)rxr2r5s&& r6 _coerce_boolr* sc }%#u&&E{ u:    # # %D554tDLgDg5tmttr8c V^8dQhRRRR/#)r-rxryr3r1r4)r5s"r6r7r7s1cr8crVEFpVPR4\8XgK \VPR4;'g/PR4;'gR4pVPR4;'g/pVPR4;'g/pVPR4\\\ \ 09dQVPR4;'gRpV'dRV RV 2P4u#R V 2P4u#V'dVPR4'd\VR,4MR\V.43Uu.uFqf'gK VNK ppV'd(R R PV4 RV 2P4u#Vu# VFpVPR4\ 8XgKVPR 4;'g/p\VPR4;'gR4p VPR 4'dKw/'dKV 'gKRV 2u# R#uupi)rrr5r+ref_msg message_itemtitleu[引用媒体: z] u[引用媒体] u [引用: z | voice_itemmediaz)[Voice transcription provided by Weixin] ) rSrr1 ITEM_IMAGE ITEM_VIDEO ITEM_FILE ITEM_VOICEr= _extract_textr) rxitemr5refref_itemr/ppartsr0 voice_texts & r6r6r6s 88F y (-3388@FFBGD((9%++Cww~.44"H||F# J :'VV(..BEJs4&9??AqRbcgbhPiPoPoPqq:=''':J:JSW%6PRTackblTm$nt$nqrs$nt&uzz%'8&9TFCIIKKK 88F z ),/552JZ^^F399r:JNN7++rrzzCJ<PP 'us  H4H4image/video/zaudio/c$V^8dQhRRRRRR/#)r- media_typesrr5r1r3r#r4)r5s"r6r7r76s&vv)v3v;vr8cJa\FJwop\;QJdV3RlV4F 'gK RM RM!V3RlV44'gKHVu# V'd\P#VP R4'd\P #\P #)c3D<"TFqPS4xK R#5irt)r)r,mrs& r6r.+_message_type_from_media..8s9[||F##[s TFrM)_MIME_PREFIX_TYPESanyr#DOCUMENTrCOMMANDTEXT)r@r5r}rs&& @r6_message_type_from_mediarJ6so 2 39[93339[9 9 9 !3$/;  u4??[^K_K_K4G4Guepeueuur8c$V^8dQhRRRRRR/#)r-rr1rr3r4)r5s"r6r7r7=s&MMMMMr8c\\V4V R2, 4p\V\4'dVP RR4#R#) .sync.jsonrpr+)rrrdictrS)rrrs&& r6_load_sync_bufrO=s@ l;/ZL 2KK LD.8t.D.D488%r *L"Lr8c(V^8dQhRRRRRRRR/#)r-rr1rrnr3rr4)r5s"r6r7r7Bs.llllllr8cH\\V4V R2, RV/4R#)rMrpN)r%r)rrrns&&&r6_save_sync_bufrRBs$l;/ZL 2KKN_aiMjkr8c$V^8dQhRRRRRR/#)r-rDrkbot_typer1r3r9r4)r5s"r6r7r7Fs'ZZ2ZcZoZr8c"\V\\ RV 2\R7GRjxL p\ VP R4;'gR4\ VP R4;'gR43#LL5i)z ?bot_type=rrFrHNqrcoder+qrcode_img_content)rlILINK_BASE_URL EP_GET_BOT_QR QR_TIMEOUT_MSr1rS)rDrTqr_resps&& r6 _fetch_qrr]FspW~=/YcdlcmHn|IJJG w{{8$** +S=Q1R1X1XVX-Y YYJs$A5A3 A5"A5+ A5c(V^8dQhRRRRRRRR/#)r- qrcode_valuer1 qrcode_urlreport_render_errorrFr3rr4)r5s"r6r7r7Ks/ m mC mS m$ mSW mr8c@V'd \V4^RIpVP4pTPT;'gT4VP RR7VP RR7R# \ d)pT'd\RT R24Rp?R#Rp?R#Rp?ii;i)zsPrint the QR URL + ASCII render; WeChat must scan the liteapp URL (``qrcode_img_content``), not the bare hex token.NT)fit)invertu （终端二维码渲染失败: u-，请直接打开上面的二维码链接）)printrWQRCodeadd_datamake print_asciir)r_r`rarWqr_qr_excs&&$ r6 _print_qrrlKs jm ]]_ J..,/ D d# m  4WI=jk l l ms'A*+A** B5BBrT3ic(V^8dQhRRRRRRRR/#)r-rr1rTrrzr3zOptional[dict[str, str]]r4)r5s"r6r7r7Zs)777#7c7\t7r8c"\'g \R4h\4;_uu_4GRjxL p\W14GRjxL wrET'g)\ P R4RRR4GRjxL R#\R4\YERR7\P!4T,p\^r\P!4T8EdC\Y8\ RT 2\R7GRjxL p \)T P+R 4;'gR 4p T R 8Xd\R R RR7EMT R8Xd\R4EMT R8Xd&T P+R4'dRT R, 2pEMT R8XdcT ^, p T ^8d\R4RRR4GRjxL R#\RT R24\Y14GRjxL wrE\YERR7EMT R8XEdR\)T P+R4;'gR 4R\)T P+R4;'gR 4R\)T P+R 4;'g\4R!\)T P+R"4;'gR 4/p T R,'dT R,'g)\ P R#4RRR4GRjxL R#\-T3/T B\R$T R, 24T uuRRR4GRjxL #\ P&!^4GRjxL EK]\R%4RRR4GRjxL R#ELEL \d3p\ P RT4Rp?RRR4GRjxL R#Rp?ii;iELEL \dbp\T\ P"4'g\ P%R T4\ P&!^4GRjxL Rp?EK.Rp?ii;iELNEL, \d3p\ P RT4Rp?RRR4GRjxL R#Rp?ii;iEL|ELIEL-EL +GRjxL 'giR#;i5i)&z'aiohttp is required for Weixin QR loginNz#weixin: failed to fetch QR code: %sz"weixin: QR response missing qrcodeu( 请使用微信扫描以下二维码：T)raz?qrcode=rVzweixin: QR poll error: %srUwait.r+)endrscanedu% 已扫码，请在微信里确认...scaned_but_redirect redirect_hosthttps://expiredu1 二维码多次过期，请重新执行登录。u' 二维码已过期，正在刷新... (z/3)Fzweixin: QR refresh failed: %s confirmedr ilink_bot_idr bot_tokenrbaseurlrrz:weixin: QR confirmed but credential payload was incompleteu! 微信连接成功，account_id=u 微信登录超时。)rdrVrpr]rrerrorrerlr monotonicrYrlEP_GET_QR_STATUSr[rrrtrsleepr1rSr) rrTrrDr_r`rdeadlinecurrent_base_url refresh_count status_resprUcredss &$$ r6qr_loginrZs  DEE~~~ -6w-I'I $L LL= >~~ 9:,E>>#o5*8!-nn) $,W]m\nnvxDwE[FS`%aa 2<?00[___5U5U%-k/.J-K#L 9$"  1$NOA~~B@sST 5>w5Q/Q,LlER;& #koon&E&K&K"LgWZ[f[j[jkv[w[}[}{}W~KOOI$>$P$P. QS\^abmbqbqsBcCcIcIGI_JK\**%..LL!]^]~~^$K959:5;N:OPQc~~d--" " " '(i~~'I  LL> D ~~ a !#w';';<<NN#>DmmA&&&  !F0R  LL!@#FO~~J Kd #e~~~s.QL1QP>L7L4L7 P>P>) Q4M75Q;AP>M=0M:1M=5P>AP>"1P> QO,Q%P>5O2O/O2'P>?#P>##P>'P>/P>P>P>+ Q6P27Q="P> Q,P5-Q2P> P8 P> Q*P;+Q4L77 M4M/P> Q'M*(Q/M44P>7Q:M== O)AO$O O$P>$O))P>,Q/O22 P/=P*P> Q"P%#Q*P//P>2Q5Q8P>;Q>Q Q Q Q  Q file_itemc<RVR,R\VR,4/#) file_namefilenamerplaintext_size)r1kws&r6rrsbneSQSTdQeMf(gr8 image_itemcRVR,/#)mid_sizeciphertext_sizer4rs&r6rrs:r:K7L*Mr8 video_itemc `RVR,RVPR^4RVPRR4/#) video_sizer play_length video_md5rr+rSrs&r6rrs8b*+]BFF=RS@c\VR4#).jpg)r!r_names&&r6rrs9UVZ\b9cr8z image/jpegimageg^@c\VR4#)z video.mp4r rs&&r6rrs:YZ^`k:lr8z video/mp4videoc\W4#rtr)rnames&&r6rrs 6UVZ6ar8filec\VR4#).silk)rrs&&r6rrs9UVZ\c9dr8z audio/silkvoicezXdict[int, tuple[str, float, Callable[[bytes, str], Awaitable[str]], Optional[str], str]]_INBOUND_MEDIA send_voice audio_path send_video video_pathsend_image_file image_pathz&tuple[tuple[frozenset, str, str], ...]_OUTBOUND_BY_EXTca]tRtRtRtRtRtRtRtRt RV3Rllt ] R R l4t R R/R R llt RRltRRltRRltRRltRRltRRltRRltRRltRRltR R!ltR"R#ltR$R%ltRGR&R'lltR(R)ltR*R+ltRHR,R-lltR.R/ltRGR0R1lltRIR2R3llt R4R5lt!RJR6R7llt"RIR8R9llt#RIR:R;llt$R<R=lt%RKR>R?llt&RKR@RAllt'RBRClt(RDRElt)RFt*V;t+#)L WeixinAdapteriWEIXINTiFicV^8dQhRR/#)r-configrr4)r5s"r6r7WeixinAdapter.__annotate__s#b#b~#br8c  <\SV`V\P4VP;'g/p\ \ 44;Vnp\V4Vn \4Vn R;Vn Vn RVn\\ R7Vn\%VR4Vn\ VP(;'g&VP+R4;'g \-RR44P/4Vn\%VR\24P5R4Vn\%VR\84P5R4Vn\=\%VR R 44Vn\A\%VR R 44Vn!\=\%VR R44Vn"\FPH!4Vn%\M^\A\%VRR444Vn'\=\%VRR44Vn(\=\%VRR44Vn)R.uVn*Vn+\%VRR4PY4Vn-\%VRR4PY4Vn.VP+R4VP+R4rTTP_Vf \-RR4MT4Vn0TP_Vf \-RR4MT4Vn1\e\%VRR4RR7Vn3VPi4VP&'d(VP0'g\kW0P&4MRpV'd\ VP+R4;'gR4P/4Vn\ VP+R4;'g VP64P/4P5R4VnR#R#) N)rrr WEIXIN_TOKENr+rrMrsend_chunk_delay_secondsz1.5send_chunk_retries4send_chunk_retry_delay_secondsz1.0rate_limit_circuit_thresholdr"!rate_limit_circuit_window_secondsz30.0rate_limit_circuit_open_seconds dm_policypairing group_policydisabled allow_fromgroup_allow_fromWEIXIN_ALLOWED_USERSWEIXIN_GROUP_ALLOWED_USERSsplit_multiline_messagesF)r2)6superrrrr.r1r$ _hermes_homer _token_storer _typing_cache _poll_session _send_session _poll_taskrMESSAGE_DEDUP_TTL_SECONDS_dedupr> _account_idrrS _wx_secretr=_tokenrYrS _base_urlWEIXIN_CDN_BASE_URL _cdn_base_urlr_send_chunk_delay_secondsrz_send_chunk_retries_send_chunk_retry_delay_secondsrr_send_text_gatemax_rate_limit_circuit_threshold"_rate_limit_circuit_window_seconds _rate_limit_circuit_open_seconds_rate_limit_circuit_until_rate_limit_eventsrK _dm_policy _group_policy _coerce_list _allow_from_group_allow_fromr*_split_multiline_messages_configure_text_batch_delaysr)rrr.rrr persisted __class__s&& r6rWeixinAdapter.__init__s 1 ""*-o.?*@@K-k:.0266T/26)6OP +E<@&,,^^%))G*<^^ >[]@^_eeg )%^LSSTWX-e^EXY``ade)./?Gach/i)j&#&'7?SUX'Y#Z /45EeMmot5u/v,&||~-0C8HPnps8t4u-v*278HPsu{8|2}/056FuNoqw6x0y-BEr?&(?*5+yIOOQ-e^ZPVVX',yy'> J\@]$,,WaWiZ8NPR-Soyz!%!2!2csc{:>Z\^3_BR"S)56FuNhjl6mw|)}& ))+JNJZJZJZcgcncncn' 5E5EFtx immG4::;AACDK z!:!L!LdnnMSSU\\]`aDN r8c V^8dQhRRRR/#)r-rxrr3rr4)r5s"r6r7rsJJCJIJr8c FVf.#\V\4'dVPR4M%\V\\\ 34'dTMV.pVUu.uF=p\V4P 4'gK$\V4P 4NK? up#uupi)Nre)rr1splitlisttuplerr=)rxrr7s& r6rWeixinAdapter._coerce_listsx =I$.uc$:$: C TY\`bgil[mInInuzt{.3Ieds4y7H!D !eIIIs !B>B is_reconnectc V^8dQhRRRR/#)r-rrFr3r4)r5s"r6r7rs  T d r8c 0"\4RR3VPRR3VPRR33pVFIwr4pV'dKVPVRV 2RR7\P R VP V4R# VPR VPR 4'gR#\4Vn \\P!R R R R R7R7VnVPP!VP4\"P$!VP'4RR7VnVP+4V\,VP&\P/RVP \1VP4VP24VP4R8wd,\P RVP VP44VP7R 4R# \d-p\PR TP T4R p?ELkR p?ii;i5i)weixin_missing_dependencyz%aiohttp and cryptography are requiredweixin_missing_tokenzWEIXIN_TOKEN is requiredweixin_missing_accountzWEIXIN_ACCOUNT_ID is requiredzWeixin startup failed: F) retryablez[%s] Weixin startup failed: %szweixin-bot-tokenzWeixin bot tokenz+[%s] Token lock unavailable (non-fatal): %sN)totalconnect sock_connect sock_readrYz weixin-poll)rz![%s] Connected account=%s base=%sra[%s] WEIXIN_GROUP_POLICY=%s is set, but QR-login connects an iLink bot identity (e.g. ...@im.bot) which typically cannot be invited into ordinary WeChat groups. iLink usually does not deliver ordinary-group events for these accounts, so group messages may never reach Hermes regardless of this policy. If group delivery doesn't work, the limitation is on the iLink side, not in Hermes.T)rvrr_set_fatal_errorrrr_acquire_platform_lockrdebugrprre ClientTimeoutrrrr create_task _poll_loopr_mark_connectedr@rr~rr_wire_plugin_handlers)rr preflightrTcodereasonrs&$ r6rWeixinAdapter.connects & (*EGn o [[02L M   79X Y[ !* Bf2%%d.EfX,NZ_%`?FS !*  X../A4;;Pbccd*^*'2G2Gd\`os@D3EF !!$"2"23!--doo.?mT &*t{{# 7HTM]M]D^`d`n`no    + NNs 4--  / ""4(' X LLF SV W W Xs58H=H="G D.__annotate__+s > >s >r8c<"S\8p\P!V'd\M\4GRjxL V'd^#S#L5i)zSSleep for the failure streak; returns the new streak count (0 after a full streak).N)MAX_CONSECUTIVE_FAILURESrrBACKOFF_DELAY_SECONDSRETRY_DELAY_SECONDS) streak_doneconsecutive_failuress r6backoff)WeixinAdapter._poll_loop..backoff+s=.2JJK-- 5J]^ ^ ^#1 =)= = _s5A A  A A )rrrnrHlongpolling_timeout_msrBrCz,[%s] Session expired; pausing for 10 minutesiXz:[%s] getUpdates failed ret=%s errcode=%s errmsg=%s (%d/%d)rDr+rrrpz[%s] poll error (%d/%d): %s>N)rrOrrLONG_POLL_TIMEOUT_MSrrurrrSrrzrTrr|rrrrr+r _process_message_safer1rrRCancelledErrorr_recycle_poll_session) rrnrHr0rVsuggested_timeoutrBrCr8rr/s & @r6rWeixinAdapter._poll_loop%s!!---!$"3"3T5E5EF)   > > mmm* 7!-d.@.@4>>aealalw"XX$,LL1I$J!/55:Ka:O!2J'||E15x||Iq7QWi'7)+C*8'BB %SUYU^U^_%mmC000/0, (A-(NN#_aeajajlo#+<<"#=?SUmo18?('($ (||F399r9G''(B(B7(KL :<< 122s8DU;V7W[c7c"8,=#>?H!++NDKdKr8c "VPV4GRjxL R#L \dHp\PRTP\ TP R44TRR7Rp?R#Rp?ii;i5i)Nz([%s] unhandled inbound error from=%s: %sr@Texc_info)_process_messagerrr|rr~rS)rr8rs&& r6r5#WeixinAdapter._process_message_safeism K''0 0 0 K LLCTYYPXY`YdYdesYtPuwzFJL K K Ks6A6!!A6! A3P@!4R7p\PCRVP\EV4VPF\IV 44VPJ\LPN8XdVPQV4R#VPSV4GRjxL R#ELLL 5i)Nr@r+ message_idrxzcontent:rz6[%s] Content-dedup: skipping duplicate message from %sr?rzzgetConfig failedr-r.)chat_id chat_typer user_name)r5r}source raw_messagerG media_urlsr@ timestampz%[%s] inbound from=%s type=%s media=%d)*rr1rSr=rr is_duplicater6hashlibmd5r hexdigestrr rrB_is_group_allowed_is_dm_intake_allowedrrrrrr _fetch_typing_ticketrrN_collect_media build_sourcer"rJrnowrr~rIrr}r#rI_enqueue_text_eventhandle_message)rr8 sender_idrGrxr5rIeffective_chat_idrz media_pathsr@r7r9 candidaterKevents&& r6rCWeixinAdapter._process_messageos.!!--- N399r:@@B \288b9??A I)9)99jT[[MeMefpMqMq KK ,22 Y' DKK,,x {!GKKPTP[P[P]D^DhDhDjCk-lmm LLQSWS\S\^g h '7AQAQ'R$  ))*;<<=++I66 GKK8>>B?EEG ##''(8(8)S S S    $+++d6H6H6L6LY6W6W    9 9$:L:LiYnYnjnqC!D E#%r[D+11r66~FH1;Hd1K1Kd-RVQXX )))+NNNYK ""+<[d"z$<[$OX^!))Tkfnfrfrftv  ;TYYQZH[]c]m]mors~o A   !1!1 1  $ $U +%%e, , ,% TO -s-O=1O="O=?O= O=8O=A,O=?AO=O=1O=O=-)O=O6O=-O=? O= .O=+O=;AO=O9O=O=CO=/O;0O=9O=;O=c(V^8dQhRRRRRRRR/#)r-r7r/r]rr@r3rr4)r5s"r6r7rs*%%%i%^g%lp%r8c "\PVPR44pV'dVPW4GRjxL MRwrVV'd%VPV4VPV4R#R#L65i)rNNr+)rrS_download_mediar)rr7r]r@specrmimes&&&& r6rVWeixinAdapter._collect_mediasc!!$((6"23?C4//;;;     t $   t $  (cached path or None, mime). Voice is always downloaded (never trust Tencent's ``voice_item.text``) so gateway/run.py's central STT re-transcribes.r1rz document.binrrrrrrr)rrr%rrNz[%s] %s download failed: %s)rSr1 mimetypes guess_typerrrr2rrrrrrrr)rr7reitem_keyrcache_fnrflabelrr1rr%rrs&&& r6rdWeixinAdapter._download_mediasv<@885((8$** G$**w{{;/AA>BVVy++H5a8VVAE>AE>#E:$E>3E<4E>9F;:E><E>> F8 $F3-F8.F;3F88F;c ,V^8dQhRRRRRRRRRR/#) r-rDrrr1rzrE failure_labelr3r4)r5s"r6r7rs6  #  Ta ru {H r8c "\WPVPW#R7GRjxL p\VP R4;'gR4pV'dVP P W&4V#R#LP \d8p\PRTPT\T4T4Rp?R#Rp?ii;i5i))rrrrzN typing_ticketr+z[%s] %s for %s: %s) rrrr1rSrrrrr rr~)rrDrrzrqrVrsrs&&&&& r6rU"WeixinAdapter._fetch_typing_tickets a(>>QUQ\Q\fmLLH _ = C CDM""&&w>$$ L  a LL-tyy-RYIZ\_ ` ` asJC%A<A: A< A<A<6C:A<< B>,B93C9B>>Cc V^8dQhRRRR/#rr4)r5s"r6r7rsqq3q9qr8c B\WPVP4#rt)rMAX_MESSAGE_LENGTHrrrs&&r6 _split_textWeixinAdapter._split_texts.w8O8OQUQoQoppr8cV^8dQhRR/#)r-r3rr4)r5s"r6r7rsKKKr8c b\RVP\P!4, 4#)r)rrrr})rs&r6_rate_limit_cooldown_remaining,WeixinAdapter._rate_limit_cooldown_remainings!3669IIJJr8cV^8dQhRR/#rrr4)r5s"r6r7rs99$9r8c \P!4pVPUu.uFq"WP, 8gKVNK upV.,Vn\ VP4VP 8dR#VP ^8d@\VP\P!4VP ,4VnVP4^8#uupiF) rr}rrrrrrrr})rrXtss& r6_record_rate_limit_event&WeixinAdapter._record_rate_limit_eventsnn040G0G"0G"QTW~W~Q~K~220G"DGCH#H t&& '$*L*L L  0 01 4-01O1OQUQ_Q_QadheJeJRJ.KD *224q88 #@s C C c ,V^8dQhRRRRRRRRRR/#) r-rHr1chunkrzrEr{r3rr4)r5s"r6r7rs2:::S:Q^:kn:sw:r8c "VP;_uu_4GRjxL RpRp^pVP4^8d\RVP4R R24h\VPVP VP WW4R7GRjxL pV'd9\V\4'd#VPR4VPR 43MRwrV eV ^8wgV EeV ^8wEdVPR 4;'gVPR 4p \WV 4'dV'gV'd{RRr6VPPPVPPVPV4R4\ P#R VP$\'V44EK\)WV 4'd\+WV 4pEMGV \,8wd*V \,8wd\R T RT RT ;'gR 24h\RT RT RT ;'gR 24pVP/4'd3\RT RT RT ;'gR RVP4R R2 4pMWpP08dMV^, pVP2^,p \ P#RVP$\'V4V 4\4P6!V 4GRjxL EKVP8P;4RVnRRR4GRjxL R#VfQhVhELELLIL \>dp T pYpP08dRp ? K5T^, pTP2T,p \ P#RTP$\'T4YpP0^,Y4T ^8d'\4P6!T 4GRjxL Rp ? EKRp ? EKRp ? ii;i +GRjxL 'giR#;i5i)uSend one text chunk with retry/backoff under the adapter-wide text gate. A stale-session response (``-14``, or ``-2`` with ``prepare failed``/``unknown error``) is re-sent once *without* ``context_token`` — iLink accepts tokenless sends as a degraded fallback, which keeps cron pushes working when no user message refreshed the session. A ``-2`` that survives that fails fast via ``_session_not_ready_error``.NFTz4iLink sendmessage rate limited; cooldown active for z.1fs)rrrwr5rzr{rBrCrDrQz;[%s] session expired for %s; retrying without context_tokeniLink sendmessage error: ret=rXrYrHz$iLink sendmessage rate limited: ret=z rate limitedz$iLink sendmessage rate limited (ret=z); cooldown active for z8[%s] rate limited for %s; backing off %.1fs before retryrzA[%s] send chunk failed to=%s attempt=%d/%d, retrying in %.2fs: %sNN) rr}rVrrrrrrNrSrTrrrrrrrrr~rMrZrJrrrrrrrrr)rrHrrzr{ last_errorretried_without_tokenattemptrOrBrCrDrprs&$$$$ r6_send_text_chunkWeixinAdapter._send_text_chunks ''''.2J$) !G6681<&)]^b_B_B_DEH^IIJ(KLL,2!.**T^^4;;[b&3"JJDNRV`aegkVlVlDHHUOTXXi5H#Ir~LCC1H':MRY]^R^!%(!3!F!Ftxx.t'BBK`erCG= --44889J9J9O9OPTP`P`bi9jlpq"NN+hjnjsjsu}FvGH$0vFF)A#PV)WJ!"44DV9V".1NseS\]d\eemntoHoHyHnI0J#KK%14XY\X]]fgnfoowx~yQyQCQxR3S&T 88::)5"Fse9U\T]]eflf~f~p~e@77;7Z7Z7\]`6aab!d*eJ""&>&>>!1 #CCaG'acgclclnvw~nBFG%mmD111 ++11358D2S(''h) )) k(J:2K(T! 2!$J":"::qLG??'IDNN#f#'99hw.?JbJbefJfhlsax%mmD1111  2U('''s&PL"P;O$1L, L% L,A+L,+L,1L,9A7L,0O$3L,O$*L,>L,L,;L,L,,O$-L,=O$>A L,L(L,#O$&!L, PL*PO$"P%L,(L,*P, O!7O O$A9OO OO$O!!O$$O> *O-+ O> 6O> 8 Pc ,V^8dQhRRRRRRRRRR /#) r-rHr1rreply_torEmetadatarr3rr4)r5s"r6r7r s5==#==}=_w=DN=r8c aa"VP'dVP'g\RRR7#VPP VP V4pRpVP VPVR74;_uu_4VPV4wrxVPVPV4^,4wrVPV4U U u.uF wrWR3NK p p p YPV 4U u.uFqRR3NK up , p RRR4X Fiwpop\V4PP4o\!VV3Rl\"4R4wpp\%VV4!RRVR V/VV/BGRjxL Kk VP/VP1X 44Uu.uF'pV'gK VP34'gK%VNK) pp\5V4FwppR \6P8!4P: 2pVP=VVVVR 7GRjxL TpV\?V4^, 8gK`VP@^8gKs\BPD!VP@4GRjxL K \R VR7#uup p iuup i +'giEL;iEL0 \&d/p\(P+R TP,YT4Rp?EKRp?ii;iuupiLLz \&dLp\(PGRTP,\IT4T4\R\KT4R7uRp?#Rp?ii;i5i)F Not connectedsuccessr|N)rHr1z local filec3R<"TFwrpS'g SV9gKW#3xK R#5irtr4)r,extsrCkextis_voices& r6r.%WeixinAdapter.send..s'#i=MztQY]`dh]hFQF=Ms' 'rHrz"[%s] %s delivery failed for %s: %shermes-weixin-)rHrrzr{TrrGz[%s] send failed to=%s: %s) send_document file_pathr4)&rrrrrSr_media_delivery_scoperW extract_mediaextract_local_filesextract_imagesfilter_media_delivery_pathsfilter_local_delivery_pathsrsuffixrKnextrrRrrrrryformat_messager= enumerateuuiduuid4hexrrrrrr|r~r1)rrHrrrrzlast_message_id media_filescleaned_content local_files final_contentr:v deliveriesrrnsenderr0rrridxrr{rrs&&&&& @@r6sendWeixinAdapter.send s!!!e?C C))--d.>.>H )- ' '(9(9'(9(J K K+/+=+=g+F (K)-)A)A$BUBUVeBfghBi)j &K6:6V6VWb6cd6cda1/6cJd =]=]^i=jk=jul3=jk kJ L  =)3%h4j''--/"#i=M#ilJK f!$/bb(bWZ\`Vabbb *4"&!1!1$2E2Em2T!Ui!UAYZa_`_f_f_haa!UFi'/ U,TZZ\-=-=,>? ++G5Xeqz+{{{"+Vq(T-K-Ka-O!--(F(FGGG 0 dG G#ek L K Kc fNN#GTYadeefi|H = LL5tyy(7BSUX Ye3s8< < =s$MAMAJJ 'J= J JMA K:'J5J2J5&K:- K1<K1K1A K:'K6(K:K:#K:=K8>K:M J J/ ) M2J55 K."K)"K:)K.. K:8K:: MAM MM MMc V^8dQhRRRR/#)r-rHr1r3rEr4)r5s"r6r7r-s{{3{={r8c F"VPPV4pV'g%VP'dVP'g T;'gR#VP VPWP PVP V4R4GRjxL #L5i)uReturn a valid typing ticket, refreshing via getConfig once the 600s TTL evicts it — otherwise ``stop_typing`` no-ops and the WeChat client shows the indicator forever.Nztyping ticket refresh failed)rrSrrrUrr)rrHr!s&& r6_ensure_typing_ticket#WeixinAdapter._ensure_typing_ticket-s##''0 +++4;;;>>T !..   ):):)>)>t?O?OQX)Y[y{{ {{s#5B!B! B!AB!BB!c(V^8dQhRRRRRRRR/#)r-rHr1rUrzrnr3rr4)r5s"r6r7r6s. g g gc g# g$ gr8c r"VPV4GRjxL pV'gR#\VPVP\VP \ RVRVRV/R7GRjxL R#LVL \d8p\PRTPT\T4T4Rp?R#Rp?ii;i5i)NrrsrU)rrFrrHrz [%s] typing %s failed for %s: %s) rrhrrEP_SEND_TYPINGrrrrr rr~)rrHrUrnrsrs&&&& r6 _set_typingWeixinAdapter._set_typing6s"88AA   g""T^^n\`\g\guF('?MS[]cdf f f B f g LL;TYYxX_O`be f f gsPB7A. B7B7AA2'A0(A2,B70A22 B4=,B/)B7/B44B7c$V^8dQhRRRRRR/#)r-rHr1rrr3rr4)r5s"r6r7rAs#???8P?\`?r8c P"VPV\R4GRjxL R#L5i)startN)r TYPING_START)rrHrs&&&r6 send_typingWeixinAdapter.send_typingAsw g>>> &$&c V^8dQhRRRR/#)r-rHr1r3rr4)r5s"r6r7rDs====r8c P"VPV\R4GRjxL R#L5i)stopN)r TYPING_STOPrrHs&&r6 stop_typingWeixinAdapter.stop_typingDsw V<<?DK$55i@@@QZQbQbclnpQq rww}}Y77 2I )++G+cc9 )B)B((11IIi(21*C9w Ad219 )B)B((11IIi(2111*C9ws.GD(G$G4GD?*D*+D?.G>$G#"GD, G*D?, D< 7G?G $G 5"G F7 . G 7 G  G  Gc(V^8dQhRRRRRRRR/#)r-rHr1rrrEr3rr4)r5s"r6r7rSs3ssSscsMsNXsr8c D"VPWW5R7GRjxL #L5i))rHrrrN)r)rrHrrrrrjs&&&&&&,r6rWeixinAdapter.send_image_fileSs"''W^'rrrrs   c 0V^8dQhRRRRRRRRRRRR /#) r-rHr1rrrnrjrr3rr4)r5s"r6r7rVs9==s=#==TW=cf=ku=r8c t"VP'dVP'g\RRR7#\RVP!WV3/VBGRjxL R7#L \dMp\ P RTPT\T4T4\R\T4R7uRp?#Rp?ii;i5i)FrrTNrz[%s] %s failed to=%s: %s) rrr _send_filerrr|rr~r1)rrHrrrnrjrs&&&&&, r6_send_file_resultWeixinAdapter._send_file_resultVs!!!e?C C =dT__W\c=ngm=n7no o7n = LL3TYYxPWGXZ] ^e3s8< < =sL$B8 B8AA AB8A B5)AB0*B5+B80B55B8c4V^8dQhRRRRRRRRRRRR R R /#) r-rHr1rrrErrrrr3rr4)r5s"r6r7r_sS```'*`5B`Vc`wD`*` `r8c X"TPYT;'gRR4GRjxL #L5i)r+rNr)rrHrrrrrrjs&&&&&&&,r6rWeixinAdapter.send_document_s(++G 2____ !*(*c(V^8dQhRRRRRRRR/#)r-rHr1rrrEr3rr4)r5s"r6r7res3^^^^}^I^r8c X"TPYT;'gRR4GRjxL #L5i)r+rNr)rrHrrrrs&&&&&&r6rWeixinAdapter.send_videoes'++GBP\]]]]rc(V^8dQhRRRRRRRR/#)r-rHr1rrrEr3rr4)r5s"r6r7rhs3ssss}sISsr8c "TPYT;'gVP\R44RRR7GRjxL #L5i)z#platform.weixin.voice_as_attachmentrTforce_file_attachmentN)r warning_textr)rrHrrrrrjs&&&&&&,r6rWeixinAdapter.send_voicehsi++GBHBHDL]L]^_aF_GMHJVnr+ss sss;AAAc V^8dQhRRRR/#)r-rr1r3r4)r5s"r6r7rlsr8c "^RIHpV!V4'g\RV 24hVPfQh\ VPV^R7GRjxL p\ P !R\VPR^4^,4P;'gRR7;_uu_4pVPV4VPuuRRR4#L +'giR#;i5i) r3) is_safe_urlz&Blocked unsafe URL (SSRF protection): NrFr|z.bin)deleter) tools.url_safetyrr3rrtempfileNamedTemporaryFilerrrwriter)rrrrhandles&& r6r$WeixinAdapter._download_remote_medials03EcUKL L!!---$T%7%7SRTUU  ( (d399SRSCTUVCW>X>_>_>i>ici j jnt LL ;;k jV j j js1AC'CAC'C')C C' C$  C'c ,V^8dQhRRRRRRRRRR/#)r-rHr1rrrrFr3r4)r5s"r6r7rvs1000300]a0nq0r8c J "VPeVPfQh\V4P4pVP W$R7wrg\ P !^4\ P!^4r\V4\P!V4P4r\VPVPVPWVWV ^,^,^,V P4R7 GRjxL p \V P!R4;'gR4p \#WY4p\V P!R4;'gR4;'gDT ;'d:VP$P'R4 R\)V RR7 R \)VRR7 2pV'g\+R V 24h\-VPWR 7GRjxL pVP.P!VP0V4pR VR \2P4!V P4P7R44P9R4R\V4RV R\V4P:RV /pV\<8Xd,VP?R4'dVPA^R^R7V!R$/VB..pV'd-VPC^R\DRRVPGV4//.4RpVEFpR\HPJ!4P 2p\MVPVPVPVVVVR7GRjxL pV'd9\OV\P4'd#VP!R4VP!R43MR%wppVeV^8XdVeV^8XdK\SVVV4'dV'dzRpVP.PTPWVP.PYVP0V4R4\ZP]RVP:\_V44EK*VP!R4;'gVP!R4p\aVVV4'd\cVVV4h\+R T R!T R"T;'gR# 24h V#ELELELh5i)&Nr) rrr=rrrrrr upload_paramr+upload_full_urlrMz/upload?encrypted_query_param=rz &filekey=z@getUploadUrl returned neither upload_param nor upload_full_url: )rrrrrrrrrri])rrrrrr5rrrBrCzC[%s] session expired for %s; re-sending media without context_tokenrDrQrrXrYrHr4r)2rrr read_bytes_outbound_media_builderr token_hexrrrPrQrRrrrr1rSrrrSr rVrrrrrrrr MEDIA_VOICErrinsertrrrrrrrNrTrrrrrr~rMrZ)rrHrrrrr item_builderrrrrupload_responserrrrrz item_kwargs item_listsrrxrOrBrCrDs&&&&& r6rWeixinAdapter._send_filevsn!!-$++2IIIJ))+ #'#?#?#?#r ",,R0'2E2Eb2I!)ngkk).D.N.N.P /   t{{W^@Gw|PR>RVX=Xelepeper!tt?..~>DD"E (< ,,->?EE2FPP<LOLO!!((-..LUS_fhMiLjjsty{BIKuLtM N !abqarst t&89K9KXb&z z))--d.>.>H  "#8:KVM]M]^e^i^i^k^r^rsz^{M|NDNDELNM s:0@':W[\`WaWfWfhtwAB   $w)?)?   1%QS  T3?3N+3N2O1P    a69kFDL_L_`gLhCi"j!k l#I .tzz|/?/?.@AO(&&t{{W^js"/?LLJNR\]acgRhRh)1DEnz WK3!8'/WPQ\'tS'::}$(M%%,,001B1B1G1GHXHXZa1bdhiNN#hjnjsjsu}FvGH(+>>txx(gv>>23HH"%B3%yQXPYYabhb{b{l{a|#}~~'$(Ut!{LsxCR? R# r) rjrkr MEDIA_IMAGE _image_item MEDIA_VIDEO _video_itemrr _voice_item MEDIA_FILE _file_item)rrrrfs&&& r6r%WeixinAdapter._outbound_media_builders|##D)!,JJ0J ??8 $ $ + + ??8 $ $ + + == ! !*? + +:%%r8c V^8dQhRRRR/#)r-rHr1r3r/r4)r5s"r6r7rsqq3q>qr8c R"RTRVPR4'dRRV/#RRV/#5i)rrz @chatroomr?rArH)rrs&&r6 get_chat_infoWeixinAdapter.get_chat_infos9G4D4D[4Q4Q]fhoppW[]fhopps%'c V^8dQhRRRR/#)r-rrEr3r1r4)r5s"r6r7rsttmttr8c 6VfR#\\V44#rc)rrrxs&&r6rWeixinAdapter.format_messages_rs*NOijqOr*ssr8)rrrrrrrrrrrrrrrrrrrrrrrrrrrrt)NNN)NNNNr),r r r r ALLOW_ALL_ENV_PREFIXsupports_code_blockssplits_long_messagesrwSUPPORTS_MESSAGE_EDITING_SPLIT_THRESHOLDrrrrr$rr7r5rCrVrdrUryr}rrrrrrrrrrrrrrrrrrr __classcell__)rs@r6rrs#$#b#bJJJ E D4&77r WK &-P%2 qK9:x=@{ g?= )s=` ^s0d&qttr8rc 0V^8dQhRRRRRRRRRR R R /#) r-adapterrrHr1r8r Optional[list[tuple[str, bool]]]rzrEr3r/r4)r5s"r6r7r7sHLL L%(L36LEeLwDLLr8c 2"RpVPV4pV'd=VPW4GRjxL pVP'gRRVP 2/#T;'g.F~wrx\ V4P P 4\9d VPM VPp V !W4GRjxL pVP'dKmRRVP 2/u# V'd VPMRp RRRRRVR V R \V4/#LLZ5i) Nr|Weixin send failed: zWeixin media send failed: rTplatformrrHrGcontext_token_used) rrrr|rrrK_DIRECT_IMAGE_EXTSrrrGrF) r$rHr8rrz last_resultcleaned media_path _is_voicerrGs &&&&& r6_deliver_directr/s)-K$$W-G#LL:: """3K4E4E3FGH H!,!2!2!2 ,0,<,C,C,I,I,KOa,a((gng|g|"777 """9+:K:K9LMN N "3 ,7''DJ tZ9g|U_auw{}JxK LL; 8s:0DDD D#AD:D;DD0$DDrc 0V^8dQhRRRRRRRRRR R R/#) r-r.r/rrErHr1r8rr%r3r4)r5s"r6r7r7sD\\\%2\=@\KN\]}\\r8c "\VR4p\VR\4PR4p\VR\4PR4p\ T;'g&VP R4;'g \ RR44P4pV'gRR /#V'gRR /#\\ \444p V PV4V P WR4p \P V4p \V R R 4p V eKV P'g9V P\P !4Jd\#WW4V 4GR jxL #\%4;_uu_4GR jxL p /\'T;'g/4CRVRVRV/Cp\)\+R WR74pV ;VnVnWn\#WW4V 4GR jxL uuR R R 4GR jxL #LLvLL +GR jxL 'giR #;i5i)zqOne-shot send for ``send_message``/cron: reuse the live adapter's session on this loop, else a throwaway adapter.rrrMrrrr+r|zGWeixin token missing. Configure WEIXIN_TOKEN or platforms.weixin.token.z\Weixin account ID missing. Configure WEIXIN_ACCOUNT_ID or platforms.weixin.extra.account_id.rNT)enabledrr.)r>rYrSrr1rSrr=rr$rr@rRr_looprget_running_loopr/rprNrrr_sessionr)r.rrHr8rrrrresolved_token token_storerz live_adapter send_sessionrDmergedr$s$$$$$ r6send_weixin_directr;s"%6Jz>BII#NH#E>;NOVVWZ[LVV%))G"4VV >SU8VW]]_N bcc wxx#C(9$:;K #OOJ8M!%%n5L<$?L (;(;(; @R@RV]VnVnVp@p$\GR_```~~~tD"%t|ZXWegstt> `a3:: 0*$Ww][[ ~~a \ ~~~sA3H 6&H  H )A9H #3H G&H 1G(2H 5AG.G*G. H  G,!H (H *G.,H .H 4G75 H H  H z*Weixin: aiohttp/cryptography not installedWEIXIN_ACCOUNT_IDrc V^8dQhRRRR/#r-rrr3rFr4)r5s"r6r7r7s``c`d`r8c\VPPR4;'d0VP;'gVPPR44#)z``config_connected_fn``: account_id AND token in the merged PlatformConfig; a token alone is not enough, so this platform opts out of the generic ``token or api_key`` shortcut.rr)rFr.rSr)rs&r6_config_connectedr@sB    .^^FLL4]4]FLLDTDTU\D] __r8c V^8dQhRRRR/#r>r4)r5s"r6r7r7s>>#>$>r8c:\VRR4;'g/p\VR4p\\VRR4;'g&VPR4;'g \ RR44P 4p\ T;'dT4;'g \V4#)zAccount ID AND token, from ``config`` or the scoped ``WEIXIN_*`` env (``gateway/config.py``'s Weixin connected check reads the same pair), else ``.env``, which a plain CLI process never loads into the environment (the old static setup row read it).r.Nrrrr+)rRr>r1rSrr=rF_env_configured)rr.accountrs& r6 _is_connectedrEs FGT * 0 0bEul3G .ff%))G2Dff SaceHf g m m oE !!E " = =of&==r8 thread_idforce_documentc4V^8dQhRRRRRRRRRR R R R R /#)r-pconfigrrHr1r8rFrErzOptional[list]rGrFr3r/r4)r5s"r6r7r7sA 6 6C 6# 6 6S` 6(6 6OS 6`n 6r8c."^RIHp\4'g V!R4#\\ VRR4;'g/\ VRR4WVR7GRjxL #L \ d-p\ PRRR 7T!R T 24uRp?#Rp?ii;i5i) a#Out-of-process ``send_message``/cron sender: native text + media via :func:`send_weixin_direct`. ``thread_id``/``force_document`` are signature parity only (iLink has neither). Imports nothing from other plugins, so an unrelated optional SDK (e.g. lark-oapi) can never block Weixin delivery.) send_errorz9Weixin requirements not met. Need aiohttp + cryptography.r.Nr)r.rrHr8rzWeixin standalone send failedTrAr')gateway.platforms._sharedrKrvr;rRrrr )rIrHr8rFrrGrKes&&&$$$ r6_standalone_sendrNs 5 $ & &UVV6'ggw.M.S.SQS[bcjlsuy[z07Vacc cc 6 4t D04556sKBAAAABA B&!B BB BBcV^8dQhRR/#rr4)r5s"r6r7r7 sV/V/4V/r8c^RIHp^RIHpHpHpHpHpV!R4\4VPRRRR4V!RR R 4'gR #\4'g%VPR 4VPR 4R #\4VPRR4'gVPR4R #VPP\!\#VP%4444pT'gTP)R4R #TP-RR4pTP-RR4p TP/R T4TP/R TP-RR44TP-RR4'd#TP/RTP-RR44TP/RTP1R4;'g\24\4.R0Op TP5RT ^4p T ^8Xd1T!RT ;'gR4p T!RRT R7TP7R 4Ml\8P-T \8^,4wrppT!YRR7TR!8Xd TP6M TP(!T4T ^8XdTPR"4\4TP!\;.R1OpTP5R#T^4pT^8XdT!R$RR%7TPR&4MGT^8XdT!R'RR%7TP)R(4M$T!R)R4pT!RTR%7TP7R*4T 'd\4T!R+T R,4\4TP7R-4TPR.T 24T 'dTPR/T 24R #R # \&d \4TP)R4R #\*d pTPRT 24R p?R #R p?ii;i)2a``hermes gateway setup`` flow for Weixin / WeChat personal accounts (QR login via :func:`qr_login`). Helpers resolve through the ``hermes_cli.gateway`` facade so the prompts/output match every other wizard and the facade seams tests patch keep intercepting.)gateway)confirm_reconfigureoffer_home_channelprint_setup_header prompt_csvsave_env_valuesu💬 Weixin / WeChatz> 1. Hermes will open Tencent iLink QR login in this terminal.z0 2. Use WeChat to scan and confirm the QR code.zG 3. Hermes will store the returned account_id/token in ~/.hermes/.env.zL 4. This adapter supports native text, image, video, and document delivery.Weixinr<rNz> Missing dependencies: Weixin needs aiohttp and cryptography.z2 Install them, then rerun `hermes gateway setup`.z Start QR login now?Tz Cancelled.z Weixin setup cancelled.z QR login failed: z QR login did not complete.rr+rrrWEIXIN_BASE_URLrz+ How should direct messages be authorized?z+ Allowed Weixin user IDs (comma-separated) allowlistr))WEIXIN_DM_POLICYWEIXIN_ALLOW_ALL_USERSrz Weixin allowlist saved.rzY Unknown DM users can request access and you approve them with `hermes pairing approve`.z$ How should group chats be handled?r)WEIXIN_GROUP_POLICYrz Group chats disabled.openzM All group chats enabled (only takes effect if iLink delivers group events).z? Allowed group chat IDs (comma-separated, not member user IDs)zK Group allowlist saved (only takes effect if iLink delivers group events).WEIXIN_HOME_CHANNELzyour Weixin user IDzWeixin configured!z Account ID: z User ID: )z%Use DM pairing approval (recommended)zAllow all direct messageszOnly allow listed user IDszDisable direct messages)z!Disable group chats (recommended)zAllow all group chatsz Only allow listed group chat IDs) hermes_clirQhermes_cli.gateway_setup_wizardrRrSrTrUrVre_print_info_linesrv print_error print_info prompt_yes_norrunrr1r$KeyboardInterrupt print_warningrrSsave_env_value get_env_valuer prompt_choice print_success_WEIXIN_DM_POLICIES_WEIXIN_GROUP_NOTE)gwrRrSrTrUrV credentialsrrraccess_choices access_idxrYpolicy allow_alllevelr8 group_choices group_idx allow_groupss r6interactive_setuprx sr)bb-. GH:QV  x)S-T-k-kXkl GN!!"OQ_abcJQLgmmY[\ Wktu 45,?,C,CJPcdePf,g)5'hjk"i/  R5E5E EwO ? MMu v G,-vM  !GXYZIA~JSUV /0 aFrR hi!"cegh KT`a fg 0';PQ G)*MMN:,/0 G9-.s   45  ,SE23s$7;N&O-O- O-O((O-aYou are on Weixin/WeChat. Markdown formatting is supported, so you may use it when it improves readability, but keep the message compact and chat-friendly. You can send media files natively: include MEDIA:/absolute/path/to/file in your response. Images are sent as native photos, videos play inline when supported, and other files arrive as downloadable documents. You can also include image URLs in markdown format ![alt](url) and they will be downloaded and sent as native media when possible.zS^\s*((?:wxid|gh|v\d+|wm|wb)_[A-Za-z0-9_-]+|[A-Za-z0-9._-]+@chatroom|filehelper)\s*$cV^8dQhRR/#rr4)r5s"r6r7r7sTr8c z^RIHpVP!R*/R\\RR7bR\ RRR7bR R bR R bR \ bR\bRRbRRbRRbRR+bR\bRRR.bR\bR\bR\bRRbR\bR ^bR!R"bR#RbR$\bR%R&bR'VPbR(VPbVP BR)#),u:Plugin entry point — called by the Hermes plugin system.) gateway_envtarget_ref_syntax_fnF) thread_groupstandalone_sendrWT)rnr1rrrnzWeixin / WeChatadapter_factorycheck_fndashboard_labelzWeixin / WeChat (Personal)dashboard_descriptionzBConnect a personal WeChat account through Tencent's iLink Bot API.docs_urlzGhttps://hermes-agent.nousresearch.com/docs/user-guide/messaging/weixin/dashboard_env_varsr<r is_connected required_env install_hintconfig_connected_fnsetup_fncron_deliver_env_varr^standalone_sender_fnmax_message_lengthemojiu💬allow_update_command platform_hint display_tierlow env_overridesenv_enable_credentialsNr4)r<rrX)r+r{register_platformr*_SEND_TARGET_REr)rrvrE _INSTALL_HINTr@rxrN_PLATFORM_HINT ENV_OVERRIDESENV_ENABLE_CREDENTIALSAUTHZ)ctxr{s& r6registerrs60uU,84H/ANYr5  c  [ T#3F~1Vfs.#3.CDLRim% !""//#$ +AA[EVEV%r8)r+i)鸈i:i'ri)rr-r)rr-rr))r'> wx.qlogo.cn mmbiz.qpic.cn res.wx.qq.commmbiz.qlogo.cnthirdwx.qlogo.cnilinkai.weixin.qq.comnovac2c.cdn.weixin.qq.comr)T>.m4a.mp3.ogg.wav.flac.opus>.bmp.gifr.png.jpeg.webp)rr)rz DM pairing enabled.)r]r%rz$ Open DM access enabled for Weixin.)rr)rz Direct messages disabled.)zH Note: QR login connects an iLink bot identity (e.g. ...@im.bot), not azM scriptable personal WeChat account. Ordinary WeChat groups typically cannotzN invite an @im.bot identity, and iLink does not deliver ordinary-group eventszI to most bot accounts. The settings below only apply when iLink actuallyuO delivers group events for your account type — otherwise DM remains the onlyz, working channel regardless of this choice.)__conditional_annotations__r __future__rrrrrPrloggingrjrrrrrrrr functoolsrpathlibrtypingrrrr r r r urllib.parser r getLoggerr rrrercrdcryptography.hazmat.backendsr&cryptography.hazmat.primitives.ciphersrrrrugateway.configrrgateway.platforms.helpersrrr%gateway.platforms.access_policy_mixinr agent.i18nrgateway.platforms.baserrrrrrr r!gateway.platforms.eventr"r#hermes_constantsr$utilsr%rLr&r'r;r(rgateway.platforms.send_targetsr)r*r>rYrrrgrrsrrrrrZr~r4rrr[r+r-r,rRrJrrrrrrr2r5r4r3rrrrr@__annotations__compiler rrrMrTrZrhrprvr~rrrrrrrrrrr6rBr]rhrlrurrrrrr frozensetrrrrrrrrrrrrr*r6PHOTOVIDEOVOICErErJrOrRr]rlrrrrrrrrrr*rr/r;rrCr@rErNrlrmrxrrr)rs@r6rsa?#vvvvvvvHHH(   8 $4'9<PP%3ZZF>,#yyTT 1=:?Jb7 o72HJacy/#8:R  "<>[ IgFn&7GH!RD-/D.12++4>1 [*k;H8 :z9j!"A q k!## ZZ0 1 RS JJ+ , CH@6k2& - J  hjH-m-m`55$R8 DSW DV| CSTKL 6B`dB)23Q)R~R | Y. % &"0*,&GK^z"u@ !2!23h @Q@Q5RU]_j_p_pTqrvM lZ m77TW7x ghMN }~ +, S OD "+y97;PZ;[ K"; ;W[R\=] [ t%ceqsz{u&lny|CD T#acgiopt%dfrt{| lhABLR^_, -#\2<8 Hzt(*=ztzL$\AE\@= ##6G` > 6cg 69= 6V[ 6"R]Y[V/v]**stc+G9488O8f8zE9s$PP P PP$#P$