`gjNDdZddlmZddlZddlZddlZddlZddlZddlZddl Z ddl Z ddl m Z m Z ddl mZddlmZmZmZmZmZmZmZddlmZ ddlZdZ ddlZdZdd lmZm Z dd l!m"Z"m#Z#m$Z$m%Z%m&Z&m'Z'm(Z(dd l)m*Z*ejVe,Z-Gd de.Z/ddl0m1Z1m2Z2m3Z3m4Z4m5Z5m6Z6m7Z7m8Z8m9Z9m:Z:m;Z;mZ>m?Z?m@Z@mAZAmBZBmCZCmDZDmEZEmFZFddlGmHZImJZJddlKmLZLmMZMmNZNddlOmPZPmQZQmRZRmSZSmTZTmUZUmVZVmWZWddZXddZYGdde"ZZy#e$rd ZdZYwxYw#e$rd ZdZYwxYw)um QQ Bot platform adapter using the Official QQ Bot API (v2). Connects to the QQ Bot WebSocket Gateway for inbound events and uses the REST API (``api.sgroup.qq.com``) for outbound messages and media uploads. Configuration in config.yaml: platforms: qq: enabled: true extra: app_id: "your-app-id" # or QQ_APP_ID env var client_secret: "your-secret" # or QQ_CLIENT_SECRET env var markdown_support: true # enable QQ markdown (msg_type 2) dm_policy: "pairing" # open | allowlist | disabled | pairing allow_from: ["openid_1"] group_policy: "pairing" # open | allowlist | disabled | pairing group_allow_from: ["group_openid_1"] stt: # Voice-to-text config (optional) provider: "zai" # zai (GLM-ASR), openai (Whisper), etc. baseUrl: "https://open.bigmodel.cn/api/coding/paas/v4" apiKey: "your-stt-api-key" # or set QQ_STT_API_KEY env var model: "glm-asr" # glm-asr, whisper-1, etc. Voice transcription priority: 1. QQ's built-in ``asr_refer_text`` (Tencent ASR — free, always tried first) 2. Configured STT provider via ``stt`` config or ``QQ_STT_*`` env vars Reference: https://bot.q.qq.com/wiki/develop/api-v2/ ) annotationsN)datetimetimezone)Path)Any AwaitableCallableDictListOptionalTuple)urlparseTF)PlatformPlatformConfig)BasePlatformAdapter MessageEvent MessageType SendResult_ssrf_redirect_guardcache_document_from_bytescache_image_from_bytes)strip_markdownc$eZdZdZdfd ZxZS) QQCloseErrorzRaised when QQ WebSocket closes with a specific code. Carries the close code and reason for proper handling in the reconnect loop. c|r t|nd|_|r t|nd|_t|d|jd|jdy)NzWebSocket closed (code=z , reason=))intcodestrreasonsuper__init__)selfrr! __class__s R/root/.hermes/venv/lib/python3.12/site-packages/gateway/platforms/qqbot/adapter.pyr#zQQCloseError.__init__TsG!%CI4 %+c&k  2499+Yt{{mSTUVr)__name__ __module__ __qualname____doc__r# __classcell__r%s@r&rrNs WWr'r)API_BASE TOKEN_URLGATEWAY_URL_PATHDEFAULT_API_TIMEOUTFILE_UPLOAD_TIMEOUTCONNECT_TIMEOUT_SECONDSRECONNECT_BACKOFFMAX_RECONNECT_ATTEMPTSRATE_LIMIT_DELAYQUICK_DISCONNECT_THRESHOLDMAX_QUICK_DISCONNECT_COUNTMAX_MESSAGE_LENGTHDEDUP_WINDOW_SECONDSDEDUP_MAX_SIZE MSG_TYPE_TEXTMSG_TYPE_MARKDOWNMSG_TYPE_MEDIAMSG_TYPE_INPUT_NOTIFYMEDIA_TYPE_IMAGEMEDIA_TYPE_VIDEOMEDIA_TYPE_VOICEMEDIA_TYPE_FILE) coerce_listbuild_user_agent)ChunkedUploaderUploadDailyLimitExceededErrorUploadFileTooLargeError)ApprovalRequestInlineKeyboardInteractionEventbuild_approval_keyboardbuild_update_prompt_keyboardparse_approval_button_dataparse_interaction_eventparse_update_prompt_button_datactxrtS)z/Check if QQ runtime dependencies are available.)AIOHTTP_AVAILABLEHTTPX_AVAILABLEr'r&check_qq_requirementsrVs  00r'ct|S)z0Coerce config values into a trimmed string list.)_coerce_list_impl)values r& _coerce_listrZs U ##r'ceZdZdZdZeZdZdZedgdZ dhdZ didZ edjdZ dkfd Z edgd Zedjd Zdd dld ZdidZdidZdgdZdgdZdmdZdidZdndZdidZdidZdidZdidZedZdodZdpdZedqdZ edrdZ!dsfd Z"dtdZ# dud Z$dpd!Z% dv dwd"Z&d#d$d%d&Z'edxd'Z( dyd(Z) dzd)Z*ed{d|d*Z+ d}d+Z, d}d,Z- d}d-Z. d}d.Z/ d~d/Z0edd0Z1edd1Z2 dd2Z3 d{ dd3Z4edd4Z5dd5Z6d6d6d7 dd8Z7 dd9Z8edd:Z9edd;Z:dd<Z;dd=Z
Z=dd?Z>dd@Z? ddAZ@d6eAf ddBZB d ddCZCdDZDdEZEdjdFZF d ddGZG d ddHZH d ddIZI d ddJZJ d ddKZK d ddLZL d ddMZM d ddNZNdOZO d ddPZP d ddQZQ d ddRZR d ddSZS d ddTZT d ddUZU d ddVZV d ddWZW ddXZX d ddYZYdddZZZdd[Z[dd\Z\edd]Z]dd^Z^edd_Z_djd`Z`ddaZaddbZbddcZcedddZdddeZeddfZfxZgS) QQAdapterzJQQ Bot adapter backed by the official QQ Bot WebSocket Gateway + REST API.F<2c,t|dd}|rd|Sy)z>Log prefix including app_id for multi-instance disambiguation._app_idNzQQBot:QQBot)getattr)r$app_ids r&_log_tagzQQAdapter._log_tags%y$/ F8$ $r'c|jjD]-}|jr|jt |/|jj y)z"Fail all pending response futures.N)_pending_responsesvaluesdone set_exception RuntimeErrorclear)r$r!futs r& _fail_pendingzQQAdapter._fail_pendingsP**113 8C88:!!,v"67 8 %%'r'cH|jry|jddddy)aUMark QQ WS down without stopping the reconnect loop. BasePlatformAdapter uses _running for both process lifecycle and connection status. QQBot needs to keep the listener task alive across transient transport drops so it can continue reconnect attempts after a short-lived gateway or network failure. N disconnected)platform_state error_code error_message)has_fatal_error_write_runtime_status_safer$s r&_mark_transport_disconnectedz&QQAdapter._mark_transport_disconnecteds/     '' ) ( r'czt|jxr%|jxr|jj S)z;Return True only when the QQ WebSocket transport is usable.)bool_running_wsclosedrus r& is_connectedzQQAdapter.is_connecteds,DMMFdhhFtxx3FGGr'ct||tj|jxsi}t |j dxstjddj|_ t |j dxstjddj|_ t|j dd|_ t |j dd jj|_t!|j d xs|j d |_t |j d d jj|_t!|j d xs|j d|_d|_d|_d|_d|_d|_d|_d|_d|_i|_i|_i|_i|_i|_ d|_!d|_"tGjH|_%i|_&d|_'|jP|_'y)Nrc QQ_APP_IDr client_secretQQ_CLIENT_SECRETmarkdown_supportT dm_policypairing allow_from allowFrom group_policygroup_allow_fromgroupAllowFrom>@))r"r#rQQBOTextrar getosgetenvstripr`_client_secretrx_markdown_supportlower _dm_policyrZ _allow_from _group_policy_group_allow_from_sessionrz _http_client _listen_task_heartbeat_task_heartbeat_interval _session_id _last_seq_chat_type_maprf_seen_messages _last_msg_id_typing_sent_at _access_token_token_expires_atasyncioLock _token_lock _upload_cache_interaction_callback_default_interaction_dispatch)r$configrr%s r&r#zQQAdapter.__init__s 0 "599X.L"))K2LMSSU ! IIo & K"))4F*K %' "&eii0BD&I!Jeii Y?@FFHNNP' IIl # =uyy'= !>9!EFLLNTTV!- II( ) HUYY7G-H"  :> >B9=487;*. *.(,.0>@02-/13-1(+"<<>9;  "&*%G%G"r'cy)NrarUrus r&namezQQAdapter.name sr'cy)zAQQBot gates DM/group access at intake via dm_policy/group_policy.TrUrus r&enforces_own_access_policyz$QQAdapter.enforces_own_access_policysr') is_reconnectcKts8d}|jd|dtjd|j|yt s8d}|jd|dtjd|j|y|j r |js8d }|jd |dtjd |j|y|jd |j d sy ddl m }tjdddtgi||_|jd{|j!d{}tj#d|j||j%|d{t'j(|j+|_t'j(|j/|_|j3tj#d|jy777#t4$ro}d|}|jd|dtj7d |j|d|j9d{7|j;Yd}~yd}~wwxYww)aq Authenticate, obtain gateway URL, and open the WebSocket. Args: is_reconnect: False on a cold first boot; True when the reconnect watcher is re-establishing this platform after an outage. QQBot has no server-side update queue so this flag is accepted for interface conformance only. z(QQ startup failed: aiohttp not installedqq_missing_dependencyT retryablez![%s] %s. Run: pip install aiohttpFz&QQ startup failed: httpx not installedz[%s] %s. Run: pip install httpxz>QQ startup failed: QQ_APP_ID and QQ_CLIENT_SECRET are requiredqq_missing_credentialsz[%s] %sz qqbot-appidz QQBot app IDr)platform_httpx_limitsrresponse)timeoutfollow_redirects event_hookslimitsNz[%s] Gateway URL: %sz[%s] ConnectedzQQ startup failed: qq_connect_errorexc_info)rS_set_fatal_errorloggerwarningrdrTr`r_acquire_platform_lock%gateway.platforms._http_client_limitsrhttpx AsyncClientrr _ensure_token_get_gateway_urlinfo_open_wsr create_task _listen_loopr_heartbeat_loopr_mark_connected Exceptionerror_cleanup_release_platform_lock)r$rmessager gateway_urlexcs r&connectzQQAdapter.connects,!@G  ! !"97d ! S NN> w W>G  ! !"97d ! S NN)?@,. !D $$& & &!% 5 5 77K KK. { K-- , , ,!( 3 3D4E4E4G HD #*#6#6t7K7K7M#ND  " KK($-- 8 '8 - +C51G  ! !"4g ! N LLDMM7TL J--/ ! !  ' ' )  suC+J .AH1H 2H H  9HH BHJ  H H H JAJ'I*(J=J JJ cBKd|_|j|jr6|jj |jd{d|_|j r6|j j |j d{d|_|jd{|jtjd|jy7#tj $rYwxYw7o#tj $rYwxYw7kw)z)Close all connections and stop listeners.FNz[%s] Disconnected) ry_mark_disconnectedrcancelrCancelledErrorrrrrrrdrus r& disconnectzQQAdapter.disconnectZs  !       $ $ & ''''!%D      ' ' ) ****$(D mmo ##% '7())  +))   s}>DC)C'C)-DDDDD1D25D'C))C?<D>C??DDDDDDcvK|jr8|jjs"|jjd{d|_|jr8|jjs"|jjd{d|_|jr)|jj d{d|_|j jD]-}|jr|jtd/|j jy777tw)z*Close WebSocket, HTTP session, and client.N Disconnected) rzr{closerracloserfrgrhrirjrk)r$rls r&rzQQAdapter._cleanupss 88DHHOO((.." " " ==!5!5--%%' ' '   ##**, , , $D **113 @C88:!!,~">? @ %%' # ( -s=AD9D3A D9 D54D9D78D9<8D95D97D9cK|jr0tj|jdz kr |jS|j4d{|jrAtj|jdz kr|jcdddd{S |jj t |j|jdtd{}|j|j}|jd}|std|t|jdd }||_tj|z|_t j#d |j$||jcdddd{S7U7 7#t$r}td||d}~wwxYw7-#1d{7swYyxYww) zFReturn a valid access token, refreshing if needed (with singleflight).r]N)appId clientSecret)jsonrz#Failed to get QQ Bot access token: access_tokenz,QQ Bot token response missing access_token: expires_ini z+[%s] Access token refreshed, expires in %ds)rtimerrrpostr0r`rr2raise_for_statusrrrjrrrrrd)r$respdatartokenrs r&rzQQAdapter._ensure_tokens   $))+0F0F0K"K%% %## & &!!diikD4J4JR4O&O)) & & & Y!..33#'<<ATATU/4 %%'yy{HH^,E"B4&ITXXlD9:J!&D %)YY[:%=D " KK=t}}j %%9 & & & &  Y"%H#NOUXX Y & & & &sA G#F$G#yy7#tj $rYyt $r}|jsYd}~y|j}tjd|j||jtj|z }|tkrn|dkDri|dz }tjd|j|||tk\r;tjd|j|j!dd d Yd}~yd}|j#|j%d |d vrbdddddddddd }|j'|d|d}tjd|j||j!d|d|d Yd}~y|dk(rtjd|jt(|t*k\r|j-Yd}~yt j.t(d{7|j1|d{7rd}d}n|dz }Yd}~`|d k(r.tjd!|jd|_d|_|d"vr/tjd#|j|d|_d|_|j1|d{7rd}d}nC|dz }|t*k\r5tjd$|j|j-Yd}~yYd}~d}~wt:$r}|jsYd}~ytjd%|j||j#|j%d&|t*k\r5tjd'|j|j-Yd}~y|j1|d{7rd}d}n|dz }Yd}~d}~wwxYww)(uRead WebSocket events and reconnect on errors. Close code handling follows the OpenClaw qqbot reference implementation: 4004 → invalid token, refresh and reconnect 4006/4007/4009 → session invalid, clear session and re-identify 4008 → rate limited, back off 60s 4914 → bot offline/sandbox, stop reconnecting 4915 → bot banned, stop reconnecting rrNz([%s] WebSocket closed: code=%s reason=%sz([%s] Quick disconnect (%.1fs), count: %dzf[%s] Too many quick disconnects. Check: 1) AppID/Secret correct 2) Bot permissions on QQ Open Platformqq_quick_disconnectu4Too many quick disconnects — check bot permissionsTrzConnection closed> 23zinvalid opcodezinvalid payloadz invalid shardzsharding requiredzinvalid API versionzinvalid intentzintent not authorizedzoffline/sandbox-onlybanned) rrrrrrr rrzfatal error (code=rz'[%s] Bot is %s. Check QQ Open Platform.qq_zBot is Fiz%[%s] Rate limited (4008), waiting %dsiz5[%s] Invalid token (4004), will refresh and reconnect>$%&'()*+,-./01z9[%s] Session error (%d), clearing session for re-identifyz2[%s] Max reconnect attempts reached (QQCloseError)z[%s] WebSocket error: %szConnection interruptedz#[%s] Max reconnect attempts reached)ryr monotonic _read_eventsrrrrrrrdr!r8rr9rrrvrmrr7r6rsleep _reconnectrrrrr) r$ backoff_idx connect_timequick_disconnect_countrrdurationfatal_descriptionsdescs r&rzQQAdapter._listen_loops  !"mma %#~~/ ''))) )*& mm*)) H }}xx>MMJJ  >>+l:88\A=M*a/*KKB  .  .1KK d MM --1R&*. -.*113""#67  //-13.54& *&.11$:LTFRS8TUDLLA4==RV))dV v&6%*4<KK? ( #&<<//1!--(8999!__[999&' 12.#q( 4<KKO *.D&-0D* $KKS  (,D$%)DN555"#K-.*1$K"&<< %Y[_[h[hi//1 %}}94==#N113""#;<"88LL!F V++-555"#K-.*1$K! %sP'AAA PPAP*P, P5 L7PCL7P BL7PAL7PL79H<:L7IL7#P)A:L7#K&$AL7, P7 P O>PA;O>PO>(O+)O>8P>PPcVKtt|ttdz }tj d|j ||dzt j|d{d|_ |jd{|jd{}|j|d{|jtj d|j y77h7R7;#t$r+}tjd|j |Yd}~yd}~wwxYww) zMM$$NN F '+9 " LL94==# N#D !DNN  "sWD"C$D"AC<C=:C7D"8 CD"C D&/DD"DD"cl tj}|j|S#t$rYywxYw)zSchedule a coroutine, silently skipping if no event loop is running. This avoids ``RuntimeError: no running event loop`` when tests call ``_dispatch_payload`` synchronously outside of ``asyncio.run()``. N)rget_running_looprrj)coroloops r& _create_taskzQQAdapter._create_task"s8 ++-D##D) )  s $' 33cf|jd}|jd}|jd}|jd}t|tr"|j||jkDr||_|dk(rt|tr|ni}|jdd}|d z d z|_t jd |j||j |jr,|j |j|jy|j|jy|d k(r|r|d k(r|j|y|dk(r!t jd|jy|dvr&tj |j#||y|dk(r!|j|j%|yt jd|j|y|dk(ry|dk(rlt jd|j|j&r?|j&j(s)|j|j&j+y|dk(r| t-|nd}|s/t jd|jd|_ d|_n t jd|j|j&r?|j&j(s)|j|j&j+yt jd|j|y)zPRoute inbound WebSocket payloads (dispatch synchronously, spawn async handlers).r9tsr:N heartbeat_intervali0ug@@g?zB[%s] Hello received, heartbeat_interval=%dms (sending every %.1fs)rREADYRESUMEDz[%s] Session resumed>C2C_MESSAGE_CREATEGUILD_MESSAGE_CREATEDIRECT_MESSAGE_CREATEGROUP_AT_MESSAGE_CREATEGUILD_AT_MESSAGE_CREATEINTERACTION_CREATEz[%s] Unhandled dispatch: %s z&[%s] Server requested reconnect (op 7) Fz<[%s] Invalid session (op 9, not resumable), clearing sessionz&[%s] Invalid session (op 9, resumable)z[%s] Unknown op: %s)r isinstancerrdictrrr<rdrrOrJrD _handle_readyrrr _on_message_on_interactionrzr{rrx) r$r6r9rQrRr:d_data interval_ms resumables r&r0zQQAdapter._dispatch_payload/s [[  KK  KK  KK  a 4>>#9Q=ODN 8$Q-Q2F **%95AK'2V';c'AD $ LLT ((  DNN$>!!$"3"3"56 !!$"5"5"78  7qG|""1% i 2DMMB ##D$4$4Q$:;  **!!$"6"6q"9:  :DMM1M  8  7 KK@$-- Pxx!!$((.."23  7#$=QeI RMM$( !% DdmmTxx!!$((.."23  *DMM2>r'ct|trB|jd|_tj d|j |jyy)u7Handle the READY event — store session_id for resume.rGz[%s] Ready, session_id=%sN)r`rarrrrrd)r$r:s r&rbzQQAdapter._handle_readys= a  uu\2D  KK3T]]DDTDT U r'c tj|}t |t r|SdS#t$rtj d|YywxYw)Nz [QQBot] Failed to parse JSON: %r)rloadsrrrr`ra)rawr6s r&r/zQQAdapter._parse_jsonsM jjoG%Wd3w==  NN=s C s+A  A cttjdz}ttjjddd}||z dzS)z5Generate a message sequence number in 0..65535 range.iNi)rruuiduuid4hex)msg_id time_partrands r& _next_msg_seqzQQAdapter._next_msg_seqsH $y0 4::<##BQ',D E))r'cK|jrC|jjr-|j|j|jj<t||d{y7w)z:Cache the last message ID per chat, then delegate to base.N) message_idsourcechat_idrr"handle_message)r$eventr%s r&rzzQQAdapter.handle_messagesO    4 46;6F6FD  ell22 3g$U+++sA"A-%A+&A-cKt|tsyt|jdd}|r|j |r"t j d|j|yt|jdd}t|jddj}t|jdtr|jdni}|dk(r|j|||||d{y|d vr|j|||||d{y|d vr|j|||||d{y|d k(r|j|||||d{yy7m7M7-7 w) z(Process an inbound QQ Bot message event.Nidrz([%s] Duplicate or missing message id: %s timestampcontentauthorrW>rZ>rXr[rY) r`rar r _is_duplicaterr<rdr_handle_c2c_message_handle_group_message_handle_guild_message_handle_dm_message)r$ event_typer:rrr~rrs r&rczQQAdapter._on_messagesU!T" QUU4_%++F3 LL:DMM6  k2./ aeeIr*+113$.quuX$Ex2 - -**1fgvyQ Q Q 7 7,,QS S S N N,,QS S S 2 2))!VWfiP P P3 R S S PsHC5E-7E%8!E-E'!E-;E)<"E-E+E-'E-)E-+E-c||_y)a\Register (or clear) the interaction callback. Invoked once per ``INTERACTION_CREATE`` event *after* the adapter has ACKed the interaction. The callback is responsible for routing the button click to the right subsystem (approval resolver, update-prompt resolver, etc.) based on the ``button_data`` payload. N)r)r$callbacks r&set_interaction_callbackz"QQAdapter.set_interaction_callbacks &."r'cnKt|tsy t|}|js!tj d|j y |j|jd{tjd|j |j|j|j|j}|,tjd|j |jy ||d{y#t$r+}tj d|j |Yd}~yd}~wwxYw7#t$r7}tj d|j |j|Yd}~d}~wwxYw7#t$r-}tjd|j |d Yd}~yd}~wwxYww) aZHandle an ``INTERACTION_CREATE`` event. Responsibilities: 1. Parse the raw payload into an :class:`InteractionEvent`. 2. ACK the interaction (``PUT /interactions/{id}``) so the client stops showing a loading indicator on the button. 3. Dispatch to the registered interaction callback, if any. Nz+[%s] Failed to parse INTERACTION_CREATE: %sz0[%s] INTERACTION_CREATE missing id, skipping ACKz%[%s] Failed to ACK interaction %s: %sz5[%s] Interaction: scene=%s button_data=%r operator=%szA[%s] No interaction callback registered; dropping button click %rz$[%s] Interaction callback raised: %sTr)r`rarPrrrrdr}_acknowledge_interactionrscene button_dataoperator_openidrr<r)r$r:r{rrs r&rdzQQAdapter._on_interactions{!T"  +A.Exx NNBDMM   //9 9 9  C MM5;;(9(95;P;P --   LL u00   5/ ! !I  NN=t}}c     :  NN7 uxx   ( "  LL6 sT    sF5 C>-F5D7,D5-D71A;F5- E<8E:9E<=F5> D2!D-(F5-D22F55D77 E7,E2,F52E77F5:E<< F2#F-(F5-F22F5cnK|js td|jd{}d|dtd}|jj t d||d|it d{}|jd k\r(td |jd |jdd y77>w) zACK a button interaction via ``PUT /interactions/{id}``. :param interaction_id: The ``id`` field from the ``INTERACTION_CREATE`` event. :param code: Response code (``0`` = success). .HTTP client not initialized — not connected?Nrapplication/jsonrz Content-Typerz/interactions/rrrrzInteraction ACK failed []: ) rrjrrFputr/r2 status_codetext)r$interaction_idrrrrs r&rz"QQAdapter._acknowledge_interaction s  OP P((**%eW-.*,  &&**j~&6 7$' +     s "*4+;+;*::[:]``.r:ragentrmainNr>rm)platform chat_typeryuser_id)r splitr() session_keypartsparseds r&_parse_gateway_session_keyz$QQAdapter._parse_gateway_session_key3s~K%2&,,S1 u:>U1X0E!H4FaqQx  u:> %aF9  r'c|j|}t|jxsdj}|r|j ddk7s|sy|j dd}|j dd}|dk(rt |xr||k(S|dvrxt|j xs|jxsdj}|r||k7ryt|j d dj}t |xr||k(Sy) zBAuthorize approval/update interactions against session + operator.rrqqbotFrryc2c>groupguildr)rr rrrrx group_openidguild_id) r$r{rroperatorrry event_chat session_users r&&_is_authorized_interaction_for_sessionz0QQAdapter._is_authorized_interaction_for_sessionBs 00=u,,2399;J/7:(JJ{B/ **Y+  =8X%8 8 * *U//G5>>GRHNNPJw!6vzz)R89??AL %B(l*B Br'cK|j}|syt|}||\}}|jj|}|#tj d|j ||y|j||s-tj d|j ||jy ddl m }|||}tjd|j ||||jyt|} | d|jd |j xs|j"xs |j$} |j|| s,tj d |j |jy|j'| |jytj)d |j ||j*y#t$r,} tjd|j || Yd} ~ yd} ~ wwxYww) uRoute ``INTERACTION_CREATE`` button clicks to the right subsystem. - ``approve::`` → :func:`tools.approval.resolve_gateway_approval` (unblocks the agent thread waiting on a dangerous-command approval). - ``update_prompt:`` → writes the answer to ``~/.hermes/.update_response`` for the detached ``hermes update --gateway`` process to consume. - Anything else is logged at DEBUG and ignored. Installed as the adapter's default interaction callback in ``__init__``. Callers can replace via :meth:`set_interaction_callback` to route clicks elsewhere (or pass ``None`` to drop them entirely). Nz.[%s] Unknown approval decision %r (session=%s)zF[%s] Rejected unauthorized approval click for session %s (operator=%s)r)resolve_gateway_approvalzK[%s] Button resolved %d approval(s) for session %s (choice=%s, operator=%s)z7[%s] resolve_gateway_approval failed for session %s: %szagent:main:qqbot:rz<[%s] Rejected unauthorized update prompt click (operator=%s)z4[%s] Unrecognised button_data %r from interaction %s)rrO_APPROVAL_BUTTON_TO_CHOICErrrrdrrtools.approvalrrrrrQrrr user_openid_write_update_responser<r}) r$r{rapprovalrdecisionchoicercountr update_answerupdate_session_keys r&rz'QQAdapter._default_interaction_dispatch[s&''  -k:  $, !K4488BF~DMM8[>>ukR$MM;0E0E  D0fE /MM5+v))  7 D  $#4U[[M5CUCUC|Y^YgYgC|kpk|k|B}!~ >>uFXYRMM5#8#8  ' ' u7L7L M  B MM; '  MMM;   s1B!G'$=F/!CG'/ G$8"GG'G$$G'c ddlm}|}|dz }|jd}|j||j |t j d||xsdy#t$r }t jd|Yd}~yd}~wwxYw) a~Atomically write the update-prompt answer to ``.update_response``. Mirrors the Discord / Telegram / Feishu adapters: the detached ``hermes update --gateway`` watcher polls this file for a ``y``/``n`` response to its interactive prompts (stash-restore, config migration). Writes via ``tmp + rename`` so a partial write can't fool the reader. r)get_hermes_homez.update_responsez.tmpz"QQ update prompt answered %r by %sz (unknown)z#Failed to write update response: %sN) hermes_constantsr with_suffix write_textreplacerrrr)answerrrhome response_pathtmprs r&rz QQAdapter._write_update_responses E 8"$D #55M++F3C NN6 " KK & KK4/K  E LL> D D EsA A## B ,BB c tKt|jdd}|sy|j|sy|}|jd}tj d|j ||r|ddnd|r t |tr t|nddnd |rt |trt|D]v\} } t | tstj d |j | | jd dt| jd ddd | jddx|j|d{} | d} | d} | d}| d}|r9dj|}|jr|dz|zjn|}|r(|jr|dz|zjn|}tj d|j t| t||j|d{}|j||d}|dr| |dz} | |dz} |js| syd|j |<t#|j%||d||j'| | ||| | |j)|}|j+|d{y7u77 w)z%Handle a C2C (private) message event.rrN attachmentsz1[%s] C2C message: id=%s content=%r attachments=%sr^rz itemsNonez7[%s] attachment[%d]: content_type=%s url=%s filename=%s content_typerPfilename image_urlsimage_media_typesvoice_transcriptsattachment_info  z*[%s] After processing: images=%d, voice=%d quote_blockrdmryrrrxr message_type raw_messagerw media_urls media_typesr~)r r_is_dm_intake_allowedrrrdr`listr( enumeratera_process_attachmentsjoinr_process_quoted_context_merge_quote_intorr build_source_detect_message_type_parse_qq_timestamprz)r$r:rrrrr~rrattachments_raw_i_att att_resultrrrr voice_blockquotedr{s r&rzQQAdapter._handle_c2c_messages&**]B78  ))+6 %% . ? MM #GCRL#,6ot+L3'RSTTZ[  z/4@%o6 DdD)KKQ 4DHHUB/0"5R0   44_EE  - &':;&':;$%67 ))$56K9=,335;  ::<0779$   8 MM  O ! "  33A66%%dF=,AB , #f\&::J 1F;N4O O zz|J +0K($$##% 22:?PQ!)..y9  !!%(((iF870 )s?CJ8A6J8<J1=CJ8J4B(J8+J6,J84J86J8c Kt|jdd}|sy|j|t|jddsy|j|}|j |jdd{}|d} |d} |d} |d } | r9d j | } |j r|d z| zj n| }| r(|j r|d z| zj n| }|j|d{}|j||d }|dr| |dz} | |dz} |j s| syd |j|<t|j|t|jddd ||j| | ||| | |j|}|j|d{y7Z77 w)zHandle a group @-message event.rrN member_openidrrrrrrrrrrr)r r_is_group_allowed_strip_at_mentionrrrrrrrrrrrz)r$r:rrrrr~rrrrrrrrrr{s r&rzQQAdapter._handle_group_messages15545  %%c&**_b"AB  %%g.44QUU=5IJJ  - &':;&':;$%67 ))$56K9=,335;  ::<0779$ 33A66%%dF=,AB , #f\&::J 1F;N4O O zz|J ,3L)$$$FJJ;<!% 22:?PQ!)..y9  !!%(((YK(70 )s8A?G"GBG"GCG"G G"G" G"c Kt|jdd}|syt|jdd}t|jdd}|j|xs||s#tj d|j ||yt |jdtr|jdni} t| jddxst|jd d} |} |j|jd d{} | d } | d }| d }| d}|r9dj|}| jr| dz|zjn|} |r(| jr| dz|zjn|} |j|d{}|j| |d} |d r| |d z} ||d z}| js| syd|j|<t|j|t|jdd| xsdd| |j!| |||| ||j#|}|j%|d{y7_77 w)z%Handle a guild/channel message event. channel_idrNrr}z5[%s] Guild message blocked by ACL: channel=%s user=%smembernickusernamerrrrrrrrrr)ryr user_namerr)r rrrr<rdr`rarrrrrrrrrrrz)r$r:rrrrr~rr author_idrrrrrrrrrrr{s r&rzQQAdapter._handle_guild_message]s|R01   quuZ,- 4,- %%h&<*iH LLG z9  $.quuX$Ex26::fb)*Mc&**Z2L.M44QUU=5IJJ  - &':;&':;$%67 ))$56K9=,335;  ::<0779$ 33A66%%dF=,AB , #f\&::J 1F;N4O O zz|J *1J'$$"FJJtR01,$! % 22:?PQ!)..y9 !!%(((YK&72 )s8DJI> BJ1J2CJ8J9JJJc Kt|jdd}|syt|jdd}|j|s#tj d|j ||y|}|j |jdd{} | d} | d} | d } | d } | r9d j| }|jr|d z|zjn|}| r(|jr|d z| zjn| }|j|d{}|j||d }|dr| |dz} | |dz} |js| syd|j|<t|j|t|jddd||j| | ||| | |j|}|j!|d{y7Z77 w)z Handle a guild DM message event.rrNr}z.[%s] Guild DM blocked by ACL: guild=%s user=%srrrrrrrrrrr)r rrrr<rdrrrrrrrrrrrz)r$r:rrrrr~rrrrrrrrrrr{s r&rzQQAdapter._handle_dm_messagesquuZ,-   4,- )))4 LL@ x  44QUU=5IJJ  - &':;&':;$%67 ))$56K9=,335;  ::<0779$ 33A66%%dF=,AB , #f\&::J 1F;N4O O zz|J (,H%$$ FJJtR01% 22:?PQ!)..y9  !!%(((WK&70 )s8BG6G/BG6'G2(CG6)G4*G62G64G6cKdggd} t|jddxsddk7r|S |jd}t |t r|s|Sg}g}|D]}t |t st|jddj}|r|j||jd}t |t sr|D]$} t | t s|j| &|j|d {} | jd xsg} | jd xsd} | jd xsg} | jd xsg}g}|r |jdj|| D]}|j|| r|j| |s| s|S|rddj|z}nd}|| |dS#ttf$r|cYSwxYw7w)u:Process the quoted message a user is replying to. When a user replies while quoting another message, the platform sets ``message_type = 103`` and pushes the referenced message's content and attachments inside ``msg_elements[0]``. The old adapter ignored ``msg_elements`` entirely, so: - Quoted text was surfaced only when the user typed something of their own — bare quote-replies showed nothing. - Quoted attachments (images, voice, files) were never downloaded or described. - Quoted voice messages specifically produced no transcript, so the LLM had no way to see what the user was referring to. This method parses ``msg_elements`` and runs the quoted attachments through the same :meth:`_process_attachments` pipeline as the main message body, so quoted voice messages get STT transcripts and quoted images are cached identically. :param d: Raw inbound message dict (from the WS dispatch payload). :returns: Dict with keys: - ``quote_block``: string to prepend to the user's text body (empty when there's nothing quoted). - ``image_urls``: list of cached quoted-image paths. - ``image_media_types``: parallel list of image MIME types. r)rrrrrg msg_elementsrrNrrrr z[Quoted message]: rz[Quoted message]: (image)) rr TypeError ValueErrorr`rrar rappendrr)r$r:emptyelementsquoted_text_partsall_attachmentselemetexteattsar quoted_voice quoted_info quoted_imagesquoted_image_typeslinesrQrs r&rz!QQAdapter._process_quoted_contexts@!#   155+0q1S8 9 55((D)L (*02 2DdD)B/0668E!((/HH]+E%&2A!!T*'..q12 2 44_EE !~~&9:@b  nn%67=2 "|4: '^^,?@FB  LL"34 5 A LLO   LL %]L /$))E2BBK6K''!3  a:& L 0FsAG1#GBG1 G1")G1 G/ C G1G,)G1+G,,G1cX|s|S|jr|d|jS|S)z=Prepend ``quote_block`` to *text*, separated by a blank line.r)r)rrs r&rzQQAdapter._merge_quote_intoPs5K ::<!]$tf-335 5r'cT|stjS|stjS|r|djnd}d|vsd|vsd|vrtjSd|vrtj Sd|vsd|vrtjSt jd |tjS) z4Determine MessageType from attachment content types.rraudiovoicesilkvideoimagephotoz3Unknown media content_type '%s', defaulting to TEXT)rr.PHOTOrVOICEVIDEOrr<)rr first_types r&rzQQAdapter._detect_message_type]s## #$$ $/:[^))+ j Gz$9Vz=Q$$ $ j $$ $ j Gz$9$$ $ A  r'c Kt|tsgggddSg}g}g}g}|D]}t|tst|j ddj j }t|j ddj }t|j dd} |jdrd|} n|r|} nd} tjd|j|| d d | |j|| r*t|j d tr)t|j d dj nd} t|j d tr)t|j d dj nd} |j| || | xsd | xsd d {} | r7|jd| tjd|j| tjd|j| d d|jd|jdr |j| || d {}|rFt j"j%|r'|j||j|xsdn#|r!tjd|j| |j| || d {}|rH| xs|}|jdr|jd|d|dn|jd|d|d|rdj)|nd}||||dS77#t&$r,}tjd|j|Yd }~fd }~wwxYw7#t&$r,}tjd|j|Yd }~d }~wwxYww)uProcess inbound attachments (all message types). Mirrors OpenClaw's ``processAttachments`` — handles images, voice, and other files uniformly. Returns a dict with: - image_urls: list[str] — cached local image paths - image_media_types: list[str] — MIME types of cached images - voice_transcripts: list[str] — STT transcripts for voice messages - attachment_info: str — text description of non-image, non-voice attachments r)rrrrrrr//https:z@[%s] Processing attachment: content_type=%s, url=%s, filename=%sNrasr_refer_text voice_wav_urlr r!z[Voice] z[%s] Voice transcript: %sz[%s] Voice STT failed for %sr]u[Voice] [语音识别失败]image/z image/jpegz)[%s] Cached image path does not exist: %sz[%s] Failed to cache image: %szvideo/z[video:  (z)]z[file: z#[%s] Failed to cache attachment: %sr)r`rrar rrr startswithrr<rd_is_voice_content_type_stt_voice_attachmentrr_download_and_cacherpathisfilerr)r$rrrrother_attachmentsattcturl_rawrr asr_referr! transcript cached_pathrrrs r&rzQQAdapter._process_attachmentsqs+t, %'%'#%  !# ')')')K \Cc4(SWW^R01779??AB#''%,-335G377:r23H!!$'wi( LLR CR  **2x8"#''*:";SA 0"56<<>"#''/":C@45;;= $(#=#=#,#4"/"74 $>$ %,,x |-DELL!O O  O cKddlm}||std|dd|jsy |jj |d|j d{}|j |j}|jd r%tj|xsd }t||S|d k(s|jd r|j!||d{S|xs,t#t%|j&j(xsd } t+|| S7#t$r/}tjd|j|dd|Yd}~yd}~wwxYw7}w)zDownload a URL and cache it locally. :param original_name: Preferred filename from attachment metadata. Falls back to the URL path basename if empty. r is_safe_urlzBlocked unsafe URL: Nrr)rrz[%s] Download failed for %s: %sr#z.jpgraudio/ qq_attachment)tools.url_safetyr4rrr_qq_media_headersrrrrr<rdr% mimetypesguess_extensionr_convert_audio_to_wavrrr)rr) r$rr original_namer4rrrextrs r&r(zQQAdapter._download_and_cachesc 133CH:>? ?   **....0/D  ! ! #<> ># **+00#"  -T8< <5  LL14==#cr(C   ?sN-E!/D$D" D$A!E!!E"AE!"D$$ E-%EE!EE!c|jj}|jj|dk(s|jdryd}tfd|Dryy)z0Check if an attachment is a voice/audio message.rr5T) .silk.amr.mp3.wav.ogg.m4a.aacz.speex.flacc3@K|]}j|ywN)endswith).0r=fns r& z3QQAdapter._is_voice_content_type..!s=Cr{{3=sF)rrr%any)rrr-_VOICE_EXTENSIONSrKs @r&r&z QQAdapter._is_voice_content_typese   ! ' ' ) ^^  # # % =BMM(3   =+<= =r'c@|jrdd|jiSiS)zReturn Authorization headers for QQ multimedia CDN downloads. QQ's multimedia URLs (multimedia.nt.qq.com.cn) require the bot's access token in an Authorization header, otherwise the download returns a non-200 status. rr)rrus r&r8zQQAdapter._qq_media_headers%s+   #vd.@.@-A%BC C r'Nr"c K|r&tjd|j|dd|S|}d}|r:|jdrd|}|}d}tjd|jd d lm}||stj d |dd y |js!tj d |jy|j} tjd|j|dd |t| |jj|d| dd{} | j| j} tjd|jt| | jjddt| dkr+tj d|jt| y|rhd dl} | j!dd5} | j#| | j$}dddtjd|jt| nwtjd|j||j'| |d{}|rt)|j+s!tj d|jytjd|j|j-|d{} t/j0||r&tjd|j|dd|Stj d|j|S7#1swYIxYw77v#t2$rYiwxYw#t4j6t4j8t:f$r?}tj d|jt=|j>|Yd}~yd}~wwxYww)uDownload a voice attachment, convert to wav, and transcribe. Priority: 1. QQ's built-in ``asr_refer_text`` (Tencent's own ASR — free, no API call). 2. Self-hosted STT on ``voice_wav_url`` (pre-converted WAV from QQ, avoids SILK decoding). 3. Self-hosted STT on the original attachment URL (requires SILK→WAV conversion). Returns the transcript text, or None on failure. z%[%s] STT: using QQ asr_refer_text: %rNdFrrTz1[%s] STT: using voice_wav_url (pre-converted WAV)rr3z[QQ] STT blocked unsafe URL: %srz[%s] STT: no HTTP clientz<[%s] STT: downloading voice from %s (pre_wav=%s, headers=%s)r)rrrz.[%s] STT: downloaded %d bytes, content_type=%sz content-typeunknownrSz8[%s] STT: downloaded data too small (%d bytes), skippingrBsuffixdeletez5[%s] STT: using pre-converted WAV directly (%d bytes)z([%s] STT: converting to wav, filename=%rz.[%s] STT: ffmpeg conversion produced no outputz[%s] STT: calling ASR on %sz[%s] STT success: %rz'[%s] STT: ASR returned empty transcriptz,[%s] STT failed for voice attachment: %s: %s) rr<rdr%r7r4rrr8rxrrrr(rtempfileNamedTemporaryFilewriter_convert_audio_to_wav_filerexists _call_sttrunlinkOSErrorrHTTPStatusErrorTransportErrorIOErrorr,r))r$rrrr r! download_url is_pre_wavr4download_headersr audio_datarVrwav_pathr0rs r&r'zQQAdapter._stt_voice_attachment0sY&  LL7W[X[H\ " !  ''-"( 8 (LJ LLLdmm \0<( NNO PR $$94==I#557  LLN Sb!%&  **..(!% /D  ! ! #J LL@ J   ;  :#NMM O 00u0M(QTIIj)"xxH( KMM O  > x"&!@!@X!VVtH~'<'<'>NNH$--  LL6 x P#~~h77J  (# 3T]]JtPSDTU H$--X y6((W8   %%u';';WE  NN> S ""    sBO ,MO A!M"L<#BMO ML?8A)M!M "?M!O "5MMMM2'MO !M;O <M?M  MM MMMM(O5O<O OO c Kddl}t|jr#t|jjn|j |}t j d|jt|||dd|j|d5}|j||j}dddjdddd z}|j||d{}|s|j||d{}|s|j||d{} t!j"||S#1swYxYw7`7F7,#t$$rY|SwxYww) a"Convert audio bytes to a temp .wav file using pilk (SILK) or ffmpeg. QQ voice messages are typically SILK format which ffmpeg cannot decode. Strategy: always try pilk first, fall back to ffmpeg if pilk fails. Returns the wav file path, or None on failure. rNz7[%s] STT: audio_data size=%d, ext=%r, first_20_bytes=%rFrS.rrB)rVrrTr_guess_ext_from_datarrrdr(rWrXrrsplit_convert_silk_to_wav_convert_ffmpeg_to_wav_convert_raw_to_wavrr\r]) r$rdrrVr=tmp_srcsrc_pathreresults r&rYz$QQAdapter._convert_audio_to_wav_files\ H~$$ N ! ! ' ' )**:6  E MM  O  sO   ( (E ( B $g MM* %||H $??3*1-6008DD66xJJF33JIIF  IIh  / $ $EKJ     srBED:05E%E&EEEE E#E 8E:E?EE E EEEEc|dddk(s|dddk(ry|dddk(ry|dd d k(ry |dd d k(ry |dddvry|dd dk(s|dd dk(ry|dd dk(s|dd dk(ryy)z&Guess file extension from magic bytes.Nr_ #!SILK_V3rF#!SILKr?r>!rmsRIFFrBsfLaCrF>rAs0&usOggSrCs sr@rUrs r&rizQQAdapter._guess_ext_from_datas 8| #tBQx9'< 8x  8w  8w  8> > 8* *d2Ah:M.M 8* *d2Ah:M.Mr'c:|dddk(xs|dddk(xs|dddk(S)z+Check if bytes look like a SILK audio file.NrFrsr>rtr_rrrUrxs r&_looks_like_silkzQQAdapter._looks_like_silks5BQx9$XRaH(<XRaL@XXr'cFK ddl} |j ||dt |jr~t |jjdkDrXtjd|jt |jt |jj|S|jd d dd z} ddl}|j|||j ||dt |jrt |jjdkDrntjd |jt |jt |jj| t!j"|S t!j"|y#t$r#tjd|jYywxYw#t$r,}tjd|j|Yd}~fd}~wwxYw#t$$rYSwxYw#t$r+}tjd |j|Yd}~d}~wwxYw#t$$rYywxYw# t!j"|w#t$$rYwwxYwxYww)zConvert audio file to WAV using the pilk library. Tries the file as-is first, then as .silk if the extension differs. pilk can handle SILK files with various headers (or no header). rNuK[%s] pilk not installed — cannot decode SILK audio. Run: pip install pilk>)rate,z([%s] pilk converted %s to wav (%d bytes)z&[%s] pilk direct conversion failed: %srhrr?z3[%s] pilk converted %s (as .silk) to wav (%d bytes)z%[%s] pilk .silk conversion failed: %s)pilk ImportErrorrrrd silk_to_wavrrZstatst_sizer<rrrjshutilcopy2rr\r])r$rorerr silk_pathrs r&rkzQQAdapter._convert_silk_to_wavs9    W   Xxe  <H~$$&4>+>+>+@+H+H2+M >MMN''N'')11    OOC+A.8    LL9 -   Yu  =H~$$&4>+>+>+@+H+H2+M IMMN''N'')11     )$  )$Y  NN]    $ W LLA4==RU V V W.    V LL@$--QT U U V     )$  sJ!F;B*G*3J! CH1H"#J!%I(:J!;)G'$J!&G''J!* H3!HJ!HJ!" H.+J!-H..J!1 I%:!I I7 I%%I7( I41J!3I44J!7J9JJ JJJJJ!c^K ddl}|j|d5}|jd|jd|j d|j |ddd|S#1swY|SxYw#t $r+}tjd|j|Yd}~yd}~wwxYww)uLast resort: try writing audio data as raw PCM 16-bit mono 16kHz WAV. This will produce garbage if the data isn't raw PCM, but at least the ASR engine won't crash — it'll just return empty. rNwrr>r|z [%s] raw PCM fallback failed: %s) waveopen setnchannels setsampwidth setframerate writeframesrrr<rd)r$rdrerwfrs r&rmzQQAdapter._convert_raw_to_wav-s  8S) +R""&z*  + O  + O  LL;T]]C P sRB-A6AA) A6(B-)A3.A62B-3A66 B*?!B% B-%B**B-c `K tjddd|dddd|tjjtjj d {}tj |j d d {|jd k7ry|jr"|jjd {nd }tjd|jt|j|d djdy t|j%r&t|j'j(dkr5tjd|jt|jy tj+d|jt|jt|j'j(|S77]7##tj t"f$r+}tjd|j|Yd }~y d }~wwxYww)z'Convert audio file to WAV using ffmpeg.ffmpegz-yz-iz-ar16000z-ac1)stdoutstderrNrrr'z[%s] ffmpeg failed for %s: %srr)errorsz [%s] ffmpeg conversion error: %sr~z+[%s] ffmpeg produced no/small output for %sz*[%s] ffmpeg converted %s to wav (%d bytes))rcreate_subprocess_exec subprocessDEVNULLPIPEwait_forwait returncoderreadrrrdrrdecode TimeoutErrorFileNotFoundErrorrZrrr<)r$roreprocrrs r&rlz QQAdapter._convert_ffmpeg_to_wav@s  77))11))..  D""499;; ; ;!#59[[t{{//111c3MMN''4CL''y'9  $H~$$&$x.*=*=*?*G*G2*M NN= X##   8 MM N   N   ! ) )  Q  <1$$&78  NN=t}}c R sgH.AG'G,G'G!|jd d}dddd}|j|d}|r|||xs |dvrdd Sd d St jdd}|rAt jdd}t jdd}|j d ||d Sy)uzResolve STT backend configuration from config/environment. Priority: 1. Plugin-specific: ``channels.qqbot.stt`` in config.yaml → ``self.config.extra["stt"]`` 2. QQ-specific env vars: ``QQ_STT_API_KEY`` / ``QQ_STT_BASE_URL`` / ``QQ_STT_MODEL`` 3. Return None if nothing is configured (STT will be skipped, QQ built-in ASR still works). sttenabledFbaseUrlbase_urlrapiKeyapi_keymodel/z whisper-1)rrrproviderzaiz+https://open.bigmodel.cn/api/coding/paas/v4zhttps://api.openai.com/v1)ropenaiglm>rrzglm-asrQQ_STT_API_KEYQQ_STT_BASE_URL QQ_STT_MODELN)rrrr`rarstriprr) r$rstt_cfgrrrr_PROVIDER_BASE_URLS qq_stt_keys r&_resolve_stt_configzQQAdapter._resolve_stt_configms !!'R))E" gt $Y)?u)L{{9-LZ1LHkk(+Iw{{9b/IGKK,EG ( 4&"1k ";;z59I9H'# /228R@$,#*!&"_2:n2LY S^ YY/4 yy!=HIIni8E$OOC0%  r'c ZK|j}|s!tjd|jy|d}|d}|d} t |d5}|j j |ddd |id t|j|d fid|id d{}dddj|j}|jdg} | rE| djdijdd} | jr| jS|jdd} | jr| jSy7#1swYxYw#tjtf$r0} tjd|j||dd| Yd} ~ yd} ~ wwxYww)aCall an OpenAI-compatible STT API to transcribe a wav file. Uses the provider configured in ``channels.qqbot.stt`` config, falling back to QQ's built-in ``asr_refer_text`` if not configured. Returns None if STT is not configured or the call fails. z9[%s] STT not configured (no stt config or QQ_STT_API_KEY)Nrrrrbz/audio/transcriptionsrzBearer filez audio/wavr)rfilesrrchoicesrrrrrz0[%s] STT API call failed (model=%s, base=%s): %sr^)rrrrdrrrrrrrrrrr^r`) r$rerrrrfrrprrrrs r&r[zQQAdapter._call_stts**, NNK  :&)$  h% !..33j 56,y.AB!DN$7$7K#HI!5) 4   ! ! #YY[FjjB/G!!*..B7;;IrJ==?"==?*::fb)Dzz|zz|#'  *%%w/  NNB "    shAF+ EAEEEBEF+1EF+EEEF(8&F#F+#F((F+cKddl}t|jr6tt|jjj nd}|r|dvr|j |}|j|d5}|j||j}dddjdddd z} |d k(xs|j|}|r|j||d{} n|j||d{} | sJtjd |j |dd |t#|d | t%j&|S t%j&| t|j-} t%j&|t#| dS#1swYxYw77#t($rYSwxYw#t*$r7t#|d |cY t%j&|S#t($rYSwxYwwxYw#t($rYwxYw# t%j&|w#t($rYwwxYwxYw#t*$r+} tj/d|j | Yd} ~ yd} ~ wwxYww)zLConvert audio bytes to .wav using pilk (SILK) or ffmpeg, caching the result.rNr>rEr@rDrArCrBrFr?FrSrhrrBr?z/[%s] audio conversion failed for %s (format=%s)r]qq_voicez qq_voice.wavz%[%s] Failed to read converted wav: %s)rVrr)rrTrrirWrXrrjrzrkrlrrrdrrr\r]r read_bytesr<) r$rd source_urlrVr=rnroreis_silkrpwav_datars r&r;zQQAdapter._convert_audio_to_wavsf   #(( *%** + 2 2 8 8 : c "  ++J7C  ( (E ( B $g MM* %||H $??3*1-6 WnI(=(=j(IG#888LL#::8XNNEMMsO  1xu=MN  (#  (#  H~002H IIh ,X~F FA $ $MN    K,Z8C59IJ J  (#    K     (#    LL@$--QT U s AF* I==/G ,F7-G F99G F;I=H 09I)I=*F4/I=7G 9G ; GI=GI= H "H$G:9I=: HI=HI= H  H HI=HI=IH43I4 I=I?III= I:!I50I=5I::I=c K|js td|jd{}d|dtd} |jj |t ||||d{}|j }|jdk\r.td|jd |d |jd ||S77U#tj$r} td |d | | d} ~ wwxYww)z5Make an authenticated REST API request to QQ Bot API.rNrrrrrzQQ Bot API error [z] z: rzQQ Bot API timeout [r) rrjrrFrequestr/rrrrTimeoutException) r$methodr)bodyrrrrrrs r& _api_requestzQQAdapter._api_request s   OP P((**%eW-.*,   O**22*TF# 3D99;D3&"()9)9(:"TF"xx 4013K++%% O!5dV3seDE3 N OsF+C4CC4+C/C0ACC4CC1C,,C11C4c K|dk(rd|dnd|d}||d} |r|| d<n|r|| d<|tk(r|r|| d<td D]%} |jd || t d {cSy 7#t$rU} t |  t fd dDr| dkr%tjd| dzzd {7nYd } ~ d } ~ wwxYww)z"Upload media and return file_info.r /v2/users/z/files /v2/groups/) file_type srv_send_msgr file_data file_namerPOSTrNc3&K|]}|v ywrHrU)rJkwerr_msgs r&rLz*QQAdapter._upload_media..a sg )400401InvalidrTimeoutr>g?r) rDrangerr3rjr rMrr) r$ target_type target_idrrrrrr)rattemptrrs @r& _upload_mediazQQAdapter._upload_media= se# 6 *yk0 #(  DK  )D   'I )D Qx G !..D$0C/  c("QQ;!--w{(;<<<= sOACA/$A-%A/(C-A// C 8AC;B><CCC  Cg.@g?cKtjd|j|jd}||jkrtt j |j d{||j z }|jr"tjd|j|y||jkrttjd|j|jy7}w)aWait for the WebSocket listener to reconnect. The listener loop (_listen_loop) auto-reconnects on disconnect, but there is a race window where send() is called right after a disconnect and before the reconnect completes. This method polls is_connected for up to _RECONNECT_WAIT_SECONDS. Returns True if reconnected, False if still disconnected. u=[%s] Not connected — waiting for reconnection (up to %.0fs)rNz[%s] Reconnected after %.1fsTz$[%s] Still not connected after %.0fsF) rrrd_RECONNECT_WAIT_SECONDSrr_RECONNECT_POLL_INTERVALr|r)r$waiteds r&_wait_for_reconnectionz QQAdapter._wait_for_reconnectionp s  SMM4#?#? At333-- = => > > d33 3F   :DMM6R t333 =t}}dNjNjk ?sAC!!C"AC!3-C!cK~|js&|jd{stdddS|r|js tdS|j |}|j ||j }tdd}|D]/}|j|||d{}|js|cSd}1|S77w) zSend a text or markdown message to a QQ user or group. Applies format_message(), splits long messages via truncate_message(), and retries transient failures with exponential backoff. NF Not connectedTsuccessrr)rz No chunksrr) r|rrrformat_messagetruncate_messager: _send_chunkr) r$ryrreply_tometadata formattedchunks last_resultchunks r&sendzQQAdapter.send s   44666!%RVWWgmmod+ +''0 &&y$2I2IJ kB  E $ 0 0% JJK&&""H   !7Ks"!CCBC)C*CCc 0 Kd}|j|}tdD]z} |dk(r|j|||d{cS|dk(r|j|||d{cS|dk(r|j |||d{cSt dd|cS|r t|nd tjd|j t fddD } t d | S777p#t $r}|}t|j t fd d DrYd}~|d krLd d |zz}tjd |j|dz||tj|d{7Yd}~kd}~wwxYww)z5Send a single chunk with retry + exponential backoff.NrrrrFzUnknown chat type for rc3&K|]}|v ywrHrU)rJkerrs r&rLz(QQAdapter._send_chunk.. sSr)invalid forbidden not foundz bad requestr>g?z$[%s] send retry %d/3 after %.1fs: %srz Unknown errorz[%s] Send failed: %sc3BK|]}|jvywrH)r)rJr error_msgs r&rLz(QQAdapter._send_chunk.. s" '(A" " s)rrrr)_guess_chat_typer_send_c2c_text_send_group_text_send_guild_textrrr rrMrrrdrrr) r$ryrrlast_excrrrr)rrrs @@r&rzQQAdapter._send_chunk s)-))'2 Qx /G /%!%!4!4Wgx!PPP')!%!6!6w!RRR')!%!6!6w!RRR% %/EgY-O /B&.CM?  +T]]IF ,Q   %yINNGQRR  /#hnn&!UQ;1<0ENN> !  "--...' /s"FC9C3C9F C9$C5%C9(F+C9C7C9 F C9AF3C95C97C99 F/F1F7A FFFFFFcbK|j|xs||j||}|r||d<||j|d<|jdd|d|d{}t |j dt jjdd}td || S7Lw) zzSend text to a C2C user via REST API. :param keyboard: Optional inline keyboard attached to the message. rrNkeyboardrr /messagesr} Trrw raw_response ru_build_text_bodyto_dictrr rrorprqr)r$openidrrrrrrrs r&rzQQAdapter._send_c2c_text s 8-v.$$Wh7 %DN  '//1D &&vF89/MtTTTXXdDJJL$4$4Sb$9:;$6MMUAB/ B-!A B/cbK|j|xs||j||}|r||d<||j|d<|jdd|d|d{}t |j dt jjdd}td || S7Lw) zwSend text to a group via REST API. :param keyboard: Optional inline keyboard attached to the message. rrNrrrrr}rTrr )r$rrrrrrrrs r&rzQQAdapter._send_group_text s 83|4$$Wh7 %DN  '//1D && k,y94  TXXdDJJL$4$4Sb$9:;$6MM  r c Kd|d|ji}|r||d<|jdd|d|d{}t|jdt j j dd}td || S7Lw) z*Send text to a guild channel via REST API.rNrrrz /channels/rr}rTr)r:rr rrorprqr)r$rrrrrrrs r&rzQQAdapter._send_guild_text s!*73LT5L5L+MN %DN&&vJCD C&C'C*D+C;D>CC D  6DD DD  Dc Kddlm}|j|||t|jt |dd|d{S7w)uSend a 3-button approval request (``allow-once / allow-always / deny``). The rendered text comes from :func:`build_approval_text`; callers can override by passing a custom :class:`ApprovalRequest`. Users click the button → ``INTERACTION_CREATE`` fires → the adapter's registered :meth:`set_interaction_callback` handler decodes ``button_data`` via :func:`parse_approval_button_data`. r)build_approval_textallow_permanentT)rrN)!gateway.platforms.qqbot.keyboardsrrrMrrb)r$ryreqrrs r&send_approval_requestzQQAdapter.send_approval_requestH sZ J,,   $ # '-> E -    sAAA Ac K~|r|dz }|jj|}t|d|||j|xr| } |j || |d{S7w)u|Send a button-based exec-approval prompt for a dangerous command. Called by ``gateway/run.py``'s ``_approval_notify_sync`` when the agent is blocked waiting for approval. Button clicks resolve via :func:`tools.approval.resolve_gateway_approval` — dispatched by the adapter's interaction callback (:meth:`_default_interaction_dispatch`). z3 Owner override applies to this one operation only.zExecute this command?)rtitle descriptioncommand_preview timeout_secrrN)rrrJ_APPROVAL_TIMEOUT_SECONDSr) r$rycommandrrrr smart_deniedrrrs r&send_exec_approvalzQQAdapter.send_exec_approvalk s"   P PK ""&&w/#)##66+@L0@  // S60    sAA$A"A$i,cK~~|rd|dnd}d||}|jj|}|j||t|d{S7w)aSend a Yes/No update-confirmation prompt with inline buttons. Matches the cross-adapter contract used by ``gateway/run.py``'s ``hermes update --gateway`` watcher. Button clicks surface as ``INTERACTION_CREATE`` with ``button_data = 'update_prompt:y'`` or ``'update_prompt:n'``; the adapter's interaction callback writes the answer to ``~/.hermes/.update_response`` so the detached update process can read it. z (default: rru!⚕ **Update Needs Your Input** rN)rrrrN) r$rypromptdefaultrr default_hintrrrs r&send_update_promptzQQAdapter.send_update_prompt sv$ 3:WIQ/ 7x ~N""&&w/,,   ( * -    sAAAAc|j|xsd}|jrd|d|jit|d}n|d|jt|d}|r|jsd|i|d<|S)z2Build the message body for C2C/group text sending.r%rN)markdownmsg_typemsg_seq)rr*r+rwmessage_reference)rurr:r>r=)r$rrr+rs r&r zQQAdapter._build_text_body s$$X%:;  ! !&0I$2I2I(JK-"$D##>i!8M  > MM LL 18gYb ,YYYw8YTTT Us"BBA0BBBBcTK~|j||td||d{S7w)z!Send a local image file natively.rN)r.rA)r$ry image_pathr1rkwargss r&send_image_filezQQAdapter.send_image_file 6 %% Z!17GX    (&(cTK~|j||td||d{S7w)zSend a voice message natively.rN)r.rC)r$ry audio_pathr1rr6s r& send_voicezQQAdapter.send_voice r8r9cTK~|j||td||d{S7w)zSend a video natively.rN)r.rB)r$ry video_pathr1rr6s r& send_videozQQAdapter.send_video r8r9c XK~|j||td|||d{S7w)zSend a file/document natively.r)rN)r.rD)r$ry file_pathr1rrr6s r& send_documentzQQAdapter.send_document sB %%      &    s !*(*c NK|js&|jd{stdddS|j|}|dk(r tddS |j |r[|xs,t t |jjxsd } |j||||d|tk(r| nd d{} n |j|||||d{\} } | jd xs%| jd ixsijd } | stdd | S|j|} td | i| d} |r|d|j| d<|r|| d<|j!d|dk(rd|dnd|d| d{}tdt#|jdt%j&j(dd|S7777R#t*$ri}t,j/d|j0|j2|j4tdd|j2d|j4ddcYd}~Sd}~wt6$r}t,j/d|j0|j2|j4|j8td|j2d|j4d|j8ddcYd}~Sd}~wt:$rA}t,j=d |j0|tdt#|cYd}~Sd}~wwxYww)!uUpload media and send as a native message. Upload strategy: - **HTTP(S) URLs** → single ``POST /v2/{users|groups}/{id}/files`` with ``url=...``. The QQ platform fetches the URL directly; fastest path when the source is already hosted. - **Local files** → three-step chunked upload (prepare / PUT parts / complete). Handles files up to the platform's ~100 MB per-file limit without the ~10 MB inline-base64 cap of the old adapter. NFrTrrz,Guild media send not supported via this pathrmedia)rrr file_inforzUpload returned no file_info: )r*rDr+rrrrrrrrr}rrz,[%s] Daily upload limit exceeded for %s (%s)z#QQ daily upload limit exceeded for r$z). Retry tomorrow.z/[%s] File too large: %s (%s, platform limit %s)z() exceeds the QQ per-file upload limit (z).z[%s] Media send failed: %s)r|rrrr/rrr)rrrD_upload_local_filerrur?r:rr rorprqrHrrrdrfile_size_humanrI limit_humanrr)r$ry media_sourcerkindr1rrr resolved_nameuploadrEr+r send_datars r&r.zQQAdapter._send_media( sX*  44666!%RVWW))'2  D  [ =||L)H\2778== $11$!&/8O/KmQU 2 /3.E.E  /)% v ;/ 62&,"c+ !!:6(C ((1G*%y1"$D ")*CD,C,C"DY!)X"//!E)! 3&wiy9Iy}}T4::<3C3CCR3HIJ& G7&):-  NN> s}}c.A.A 9#--9JK++,,>@  '  NNA s}}c.A.A3?? }}'r#*=*=)>?1140AE   = LL5t}}c Je3s8< < =s L%G5L%A&G!?GG!GAG!.L%/AG! G A G!L%G!G!G!! L"*AIL" L% L"A5KL"L% L"!6LL"L%L""L%cpK|js tdt|j}|j s%tj |z j }|jr|js;|jdst|dkrtd|td||xs |j}t|j|jj |j"}|j%||t'|||d{} || fS7w) aNChunked-upload a local file and return ``(resolved_name, complete_response)``. The returned ``complete_response`` contains the ``file_info`` token that goes into the subsequent RichMedia message body. :raises UploadDailyLimitExceededError: On biz_code 40093002. :raises UploadFileTooLargeError: When the file exceeds the platform limit. :raises FileNotFoundError: If the path does not exist. :raises ValueError: If the path looks like a placeholder (````). :raises RuntimeError: If the HTTP client is not initialized. r&&s+shttphttpsrzapplication/octet-streamrDrOrrPrQascii)r rrrschemer9 guess_typerr)rrUrVrWrXrZrYr%r(rrbase64 b64encoder) r$rxrrrrKrZrkb64s r& _load_mediazQQAdapter._load_media sV""$78 8&! ==- -$//7:X>XL%Jfkk):)?)?J7M<6 6&\,,. %%'((*z1::  %Vq GzR$&$>!#D##Fj ,KTR R R,/D  ) S L LL6 s K K LsCBD AC# C! C# D!C## D,!D DDDc4|jr|St|S)zFormat message for QQ. When markdown_support is enabled, content is sent as-is (QQ renders it). When disabled, strip markdown via shared helper (same as BlueBubbles/SMS). )rr)r$rs r&rzQQAdapter.format_message, s  ! !Ng&&r'cFK|j|}||dvrddSddSw)z/Return chat info based on chat type heuristics.>rrrr)rr,)r)r$ryrs r& get_chat_infozQQAdapter.get_chat_info: s;))'2 (,>>G  DH  s!cBtt|jdvS)N>r^r_)rr ra)rxs r&r/zQQAdapter._is_urlF sF $++/@@@r'c>||jvr|j|Sy)zDDetermine chat type from stored inbound metadata, fallback to 'c2c'.r)r)r$rys r&rzQQAdapter._guess_chat_typeJ s$ d)) )&&w/ /r'cPddl}|jdd|j}|S)z9Strip the @bot mention prefix from group message content.rNz^@\S+\s*r)resubr)rrvstrippeds r&rzQQAdapter._strip_at_mentionP s$ 66+r7==?;r'ctjddjdvrytjddjdvS)NGATEWAY_ALLOW_ALL_USERSr>ryestrueTQQ_ALLOW_ALL_USERS)rrrrus r&_open_dm_opted_inzQQAdapter._open_dm_opted_inY sD 99. 3 9 9 ;?S Syy-r288:>RRRr'c|jdk(ry|jdk(r|j|j|S|jdk(r|jSy)NdisabledF allowlistr)r_entry_matchesrr~)r$rs r&_is_dm_allowedzQQAdapter._is_dm_allowed^ sT ??j ( ??k )&&t'7'7A A ??f $))+ +r'ct|xsdj}|sy|jdk(ry|jdk(r|j|j|S|jdk(ry|jdk(r|j Sy)NrFrrrTr)r rrrrr~)r$r principals r&rzQQAdapter._is_dm_intake_allowedg s 2&,,.  ??j ( ??k )&&t'7'7C C ??i ' ??f $))+ +r'c|jdk(ry|jdk(r|j|j|S|jdk(ry|jdk(ryy)NrFrrrT)rrr)r$group_idrs r&rzQQAdapter._is_group_allowedu s_    +    ,&&t'='=xH H    *    'r'ct|jj}|D]5}t|jj}|dk(s||k(s5yy)N*TF)r rr)entriestargetnormalized_targetentry normalizeds r&rzQQAdapter._entry_matches s`K--/557 EU))+113JS J2C$C r'cz|s$tjtjS tj|S#t t f$rYnwxYw tjt|dz tjS#t t f$rYnwxYwtjtjS)zParse QQ API timestamp (ISO 8601 string or integer ms). The QQ API changed from integer milliseconds to ISO 8601 strings. This handles both formats gracefully. )tzi) rrmrutc fromisoformatrr fromtimestampr)r$rks r&rzQQAdapter._parse_qq_timestamp s <<8<<0 0 ))#. .I&    ))#c(T/hllK KI&   ||x||,,s!=AA0BBBc0tj}t|jtkDrB|tz }|jj Dcic]\}}||kDs ||c}}|_||jvry||j|<ycc}}w)NTF)rr(rr<r;items)r$rrrmcutoffkeytss r&rzQQAdapter._is_duplicate siik t"" #n 4//F'+':':'@'@'B##Cb6kR#D  T(( (&)F# #s  B%B)returnr )r!r rr)rrrrx)rr)rrxrrx)rr rr)r rrrx)r6Dict[str, Any]rr)r:rrr)rkrrOptional[Dict[str, Any]])rrr rr)r{rrr)rr r:rrr)rz7Optional[Callable[[InteractionEvent], Awaitable[None]]]rr)r)rr rrrr)rr rOptional[Dict[str, str]])r{rLrr rrx)r{rLrrr()rr rr rr) r:rrrr rr rrr~r rr)r:rrr)rr rr rr )rrrr)rrrr)rr rr r<r r Optional[str])rr rr rrx)rzDict[str, str]) rr rr rr r rr!rrr)rdbytesrr rr)rrrr )rrrrx)ror rer rr)rdrrer rr)rr)rer rr)rdrrr rr) rr r)r rrrfloatrr)NNFN)rr rr rrrrrrrrxrrrr)NN) ryr rr rrrrrrrH)ryr rr rrrr) r r rr rrrOptional[InlineKeyboard]rr) rr rr rrrrrr)rr rr rrrr) ryr rr rrKrrrr)ryr rrJrrrr)zdangerous commandNTF)ryr r r rr rr rrrrxr!rxrr)rrN) ryr r$r r%r rr rrrr)rr rrrr)NNN) ryr r0r r1rrrrrrr) ryr r5r r1rrrrr) ryr r;r r1rrrrr) ryr r>r r1rrrrr) ryr rAr r1rrrrrrr)ryr rIr rrrJr r1rrrrrrr) rr ryr rIr rrrrrzTuple[str, Dict[str, Any]])rxr rrrzTuple[str, str, str])ryr rr)rr rr )ryr rr)rxr rrx)ryr rr )rr rrx)rr rr rrx)r List[str]rr rrx)rkr rr)rrr rrx)hr)r*r+r,SUPPORTS_MESSAGE_EDITINGr:rlrkpropertyrdrmrvr|r#rrrrrrrrrrrrrDrJ staticmethodrOr0rbr/rurzrcrrdrrrrrrrrrrrrrrr(r&r8r'rYrirzrkrmrlrr[r;r2rrrrrrrrrrrrr"rr'r r3r7r<r?rBr.rFrfrorrrr/rrr~rrrrrrr-r.s@r&r\r\s T %+! ( "HH>HH5:?B82(0!&F4R>p%d.72&#QJ"B  O?bV>>**, Q> .I .  .7x  J "   #  2I #I  I VEE,])])]) ]) # ])  ]) ])~?)?)?) ?) # ?)  ?) ?)BI)I)I) I) # I)  I) I)VD)D)D) D) # D)  D) D)T\ \  \ |  &o o  o dEG+=+=*-+=>A+= +=Z* "-1+/zzz z * z)z zx0#0/20 0d&YY4l&+Z6p1f;#;14; ;J.20 "O"O"O+ "O  "O  "OR"&'+!&'+,,, ,  , % ,,%, ,^#"4'+15 $  /   J'+ 0O0O0O$ 0O  0Ol'+15 NNN$ N / N  N4'+15 NNN$ N / N  N2LP N! N,/ N;H N  N*'+ /=/=/=% /= $ /=  /=j'+   ! $    P 315 $"$ $ $  $  $ / $ $ $  $ L!$ !15        /    >;?*7 D&*&*15 UUU# U $ U / U U<&*&*      #  $     $&*&*      #  $     $&*&*      #  $     $&*'+&*    #  %  $    6&*&*'+|=|=|= |=  |= # |=$|=%|= |=|.'.'.' .'  .' % .' $.'b;?$0$0*7$0 $0T&LX' AA S   -$ r'r\r)rYrrr)[r, __future__rrrcrloggingr9rrrorrpathlibrtypingrrr r r r r urllib.parserrrSrrrTgateway.configrrgateway.platforms.baserrrrrrrgateway.platforms.helpersr getLoggerr)rrr!gateway.platforms.qqbot.constantsr/r0r1r2r3r4r5r6r7r8r9r:r;r<r=r>r?r@rArBrCrDgateway.platforms.qqbot.utilsrErXrF&gateway.platforms.qqbot.chunked_uploadrGrHrIrrJrKrLrMrNrOrPrQrVrZr\rUr'r&rs>#  'HHH! O 45   8 $ W9 W 0   1 $K0#K0OGO Es$DD DD DD