iVdZddlmZddlZddlZddlZddlZddlZddlZddl Z ddl Z ddl m Z m Z ddl mZddlmZmZmZmZmZmZmZddlmZ ddlZdZn#e$rd ZdZYnwxYw ddlZdZn#e$rd ZdZYnwxYwdd lmZm Z dd l!m"Z"m#Z#m$Z$m%Z%m&Z&m'Z'm(Z(dd l)m*Z*ej+e,Z-Gd de.Z/ddl0m1Z1m2Z2m3Z3m4Z4m5Z5m6Z6m7Z7m8Z8m9Z9m:Z:m;Z;mZ>m?Z?m@Z@mAZAmBZBmCZCmDZDmEZEmFZFddlGmHZImJZJddlKmLZLmMZMmNZNddlOmPZPmQZQmRZRmSZSmTZTmUZUmVZVmWZWmXZXddZYddZZGdde"Z[dS)uY 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: "open" # open | allowlist | disabled allow_from: ["openid_1"] group_policy: "open" # open | allowlist | disabled 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|rt|nd|_|rt|nd|_t d|jd|jddS)NrzWebSocket closed (code=z , reason=))intcodestrreasonsuper__init__)selfrr! __class__s D/home/piyush/.hermes/hermes-agent/gateway/platforms/qqbot/adapter.pyr#zQQCloseError.__init__Tse!%/CIII4 %+3c&kkk  U49UUt{UUUVVVVVr)__name__ __module__ __qualname____doc__r# __classcell__r%s@r&rrNsQ WWWWWWWWWWr'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) ApprovalRequestApprovalSenderInlineKeyboardInteractionEventbuild_approval_keyboardbuild_update_prompt_keyboardparse_approval_button_dataparse_interaction_eventparse_update_prompt_button_datareturnboolctotS)z/Check if QQ runtime dependencies are available.)AIOHTTP_AVAILABLEHTTPX_AVAILABLEr'r&check_qq_requirementsrYs  00r'valuer List[str]c t|S)z0Coerce config values into a trimmed string list.)_coerce_list_impl)rZs r& _coerce_listr^s U # ##r'cFeZdZdZdZeZdZdZeddZ dd Z dĈfd Z eddZ ddZ ddZddZddZddZddZddZddZddZddZddZddZedZdd"Zdd%Zedd(Zedd*Zd͈fd- Zdd/Z dd2Z!dd3Z" ddd7Z#d8d9d:d;Z$dd=Z%edddAZ&ddEZ'ddFZ(ddGZ)ddHZ*ddIZ+eddLZ,eddPZ-ddRZ.ddVZ/eddXZ0ddZZ1d[d[d\dd_Z2ddbZ3edddZ4eddeZ5ddhZ6ddiZ7ddjZ8ddlZ9ddmZ:ddoZ;d[ed}Z?d~Z@ddZA dddZB dddZC dddZD dddZE dddZF dddZG dddZH dddZIdZJ dddZK dddZL dddZM dddZN dddZO dddZP dddZQ dddZRddZS dddZTdddZUddZVddZWeddZXddZYeddZZddZ[ddZ\eddZ]ddZ^d dZ_xZ`S(  QQAdapterzJQQ Bot adapter backed by the official QQ Bot WebSocket Gateway + REST API.F<2rSr c6t|dd}|rd|SdS)z>Log prefix including app_id for multi-instance disambiguation._app_idNzQQBot:QQBot)getattr)r$app_ids r&_log_tagzQQAdapter._log_tags0y$//  %$F$$ $wr'r!Nonec|jD]8}|s"|t |9|jdS)z"Fail all pending response futures.N)_pending_responsesvaluesdone set_exception RuntimeErrorclear)r$r!futs r& _fail_pendingzQQAdapter._fail_pendingsh*1133 8 8C88:: 8!!,v"6"6777 %%'''''r'configrcPt|tj|jpi}t |dptjdd |_ t |dptjdd |_ t|dd|_ t |dd  |_t!|d p|d |_t |d d  |_t!|d p|d|_d|_d|_d|_d|_d|_d|_d|_d|_i|_i|_i|_i|_i|_ d|_!d|_"tGj$|_%i|_&d|_'|j(|_'dS)Nrg QQ_APP_IDr client_secretQQ_CLIENT_SECRETmarkdown_supportT dm_policyopen allow_from allowFrom group_policygroup_allow_fromgroupAllowFrom>@))r"r#rQQBOTextrar getosgetenvstriprd_client_secretrT_markdown_supportlower _dm_policyr^ _allow_from _group_policy_group_allow_from_session_ws _http_client _listen_task_heartbeat_task_heartbeat_interval _session_id _last_seq_chat_type_maprk_seen_messages _last_msg_id_typing_sent_at _access_token_token_expires_atasyncioLock _token_lock _upload_cache_interaction_callback_default_interaction_dispatch)r$rsrr%s r&r#zQQAdapter.__init__sN 000 "599X..L")K2L2LMMSSUU ! IIo & & K")4F*K*K  %'' "&eii0BD&I&I!J!Jeii V<<==CCEEKKMM' IIl # # =uyy'='=  !>6!B!BCCIIKKQQSS!- II( ) ) HUYY7G-H-H" "  :> >B9=487;*. *.(,.0>@02-/13-1(+"<>>9;  "&*%G"""r'cdS)NrerXr$s r&namezQQAdapter.nameswr'rTcTKts=d}|d|dtd|j|dSt s=d}|d|dtd|j|dS|jr|js=d }|d |dtd |j|dS|d |jd sdS ddl m }tj dddtgi||_|d{V|d{V}td|j|||d{Vt'j||_t'j||_|td|jdS#t4$ry}d|}|d|dtd |j|d|d{V|Yd}~dSd}~wwxYw)z9Authenticate, obtain gateway URL, and open the WebSocket.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)rV_set_fatal_errorloggerwarningrhrWrdr_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$messager gateway_urlexcs r&connectzQQAdapter.connects  @G  ! !"97d ! S S S NN> w W W W5 >G  ! !"97d ! S S S NN)?@,,.. !!!D $$&& & & & & & & &!% 5 5 7 7777777K KK. { K K K-- ,, , , , , , , ,!( 3D4E4E4G4G H HD #*#6t7K7K7M7M#N#ND  " " " KK($- 8 8 84   1C11G  ! !"4g ! N N N LLDM7TL J J J--// ! ! ! ! ! ! !  ' ' ) ) )55555  s5D-H$$ J'.A.J""J'cKd|_||jrD|j |jd{Vn#tj$rYnwxYwd|_|jrD|j |jd{Vn#tj$rYnwxYwd|_|d{V|t d|j dS)z)Close all connections and stop listeners.FNz[%s] Disconnected) _running_mark_disconnectedrcancelrCancelledErrorrrrrrrhrs r& disconnectzQQAdapter.disconnect8sJ  !!!   %   $ $ & & & ''''''''')     $D    (  ' ' ) ) ) *********)    #'D mmoo ##%%% '77777s# A AA BB*)B*cK|jr+|jjs|jd{Vd|_|jr+|jjs|jd{Vd|_|jr&|jd{Vd|_|jD]8}|s"| td9|j dS)z*Close WebSocket, HTTP session, and client.N Disconnected) rclosedcloserracloserkrlrmrnrorp)r$rqs r&rzQQAdapter._cleanupQs. 8 #DHO #(.."" " " " " " " " = (!5 (-%%'' ' ' ' ' ' ' '   %#**,, , , , , , , , $D *1133 @ @C88:: @!!,~">">??? %%'''''r'cK|jr&tj|jdz kr|jS|j4d{V|jr8tj|jdz kr|jcdddd{VS |jt |j|jdtd{V}| | }n%#t$r}td||d}~wwxYw|d}|std|t|dd }||_tj|z|_t d |j||jcdddd{VS#1d{VswxYwYdS) zFReturn a valid access token, refreshing if needed (with singleflight).raN)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)rtimerrrpostr0rdrr2raise_for_statusrrrorrrrrh)r$respdatartokenrs r&rzQQAdapter._ensure_tokenis   &$)++0F0K"K"K% %# & & & & & & & &! *dikkD4JR4O&O&O) & & & & & & & & & & & & & & Y!.33#'<ATUU/4 %%'''yy{{ Y Y Y"#N#N#NOOUXX YHH^,,E "I4IITXXlD99::J!&D %)Y[[:%=D " KK=t}j   %9 & & & & & & & & & & & & & & & & & & & & & & & & & & & & & &s7-F.>A"C! F.! D+C>>DBF.. F8;F8cK|d{V} |jttd|t dt d{V}||}n%#t$r}td||d}~wwxYw|d}|std||S)z2Fetch the WebSocket gateway URL from the REST API.NQQBot ) Authorization User-Agent)headersrz"Failed to get QQ Bot gateway URL: urlz%QQ Bot gateway response missing url: ) rrrr/r1rFr2rrrro)r$rrrrrs r&rzQQAdapter._get_gateway_urls2((******** T*../-//%5e%5%5"2"4"4, /D  ! ! # # #99;;DD T T TICIIJJPS S Thhuoo OMtMMNN N sA0B B1B,,B1rcK|jr+|jjs|jd{Vd|_|jr+|jjs|jd{Vd|_t jd|_t jdpct jdpOt jdp;t jdp't jdpt jd }|j|d tit| d{V|_t d |j |dS) z2Open a WebSocket connection to the QQ Bot gateway.NT) trust_env WSS_PROXY wss_proxy HTTPS_PROXY https_proxy ALL_PROXY all_proxyr)rrproxyz[%s] WebSocket connected to %s)rrrraiohttp ClientSessionrr ws_connectrFr4rrrh)r$rws_proxys r&rzQQAdapter._open_wss 8 #DHO #(.."" " " " " " " " = (!5 (-%%'' ' ' ' ' ' ' '  -=== Ik " " &y%% &y'' &y'' &y%%  & y%% 11 .00, 2          4dm[QQQQQr'cKd}d}d}|jr tj}|d{Vd}d}n}#tj$rYdSt $r}|jsYd}~dS|j}t d|j ||j tj|z }|tkrw|dkrq|dz }t d|j |||tkr>td|j |dd d Yd}~dSnd}||d |d vrO|dkrdnd}td|j ||d|d|d Yd}~dS|dkrt d|j t&|t(krYd}~dSt jt&d{V||d{Vrd}d}n|dz }Yd}~0|dkr.t d|j d|_d|_|dvr/t d|j |d|_d|_||d{Vrd}d}n6|dz }|t(kr&td|j Yd}~dSYd}~nd}~wt6$r}|jsYd}~dSt d|j |||d|t(kr&td|j Yd}~dS||d{Vrd}d}n|dz }Yd}~nd}~wwxYw|jdSdS)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)2i3rzoffline/sandbox-onlybannedz'[%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)iiii$i%i&i'i(i)i*i+i,i-i.i/i0i1z9[%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)rr monotonic _read_eventsrrrrrrrhr!r8rr9rrrrrr7r6sleep _reconnectrrrrr)r$ backoff_idx connect_timequick_disconnect_countrrdurationdescs r&rzQQAdapter._listen_loops  !"mI %H %#~// ''))))))))) )*&&)   p p p }FFFFFx>MJ  >++l:888\A=M=M*a/*KKB  .  .1KKK d M --1R&*. L./*'')))""#6777<''59T\\11xDLLA4=RV))$d &6&6&6%*FFFFF4<<KK? ( #&<<<!-(8999999999!__[99999999)&' 12..#q( HHHH4<<KKO *.D&-0D*&KKS  (,D$%)DN55555555"#K-.**1$K"&<<< %Y[_[hiii % % %}FFFFF94=#NNN'')))""#;<<<"888LL!F VVVFFFFF55555555%"#K-.**1$K %umI %I %I %I %I %sX1AN? N?!K;.B?K;3A9K;27K;/AK;9B7K;; N?N:A5N:%N::N?rrcpKtt|ttdz }td|j||dzt j|d{Vd|_ | d{V| d{V}| |d{V| td|jdS#t$r,}td|j|Yd}~dSd}~wwxYw) z=B>cK|d{V}dd|dddgdddd d d } |jrN|jjsB|j|d{Vtd |jdStd |jdS#t$r,}t d|j|Yd}~dSd}~wwxYw)aeSend op 2 Identify to authenticate the WebSocket connection. After receiving op 10 Hello, the client must send op 2 Identify with the bot token and intents. On success the server replies with a READY dispatch event. Reference: https://bot.q.qq.com/wiki/develop/api-v2/dev-prepare/interface-framework/reference.html NriBrrmacOSz hermes-agent)z$osz$browserz$device)rintentsshard propertiesrz[%s] Identify sentz2[%s] Cannot send Identify: WebSocket not connectedz [%s] Failed to send Identify: %s) rrrrrrrhrrr)r$ridentify_payloadrs r&_send_identifyzQQAdapter._send_identifysI((********)%)) Q" .-    " Qx  h(()9::::::::: 0$-@@@@@H$- Q Q Q LL;T]C P P P P P P P P P QsAB( B(( C2!CCcK|d{V}dd||j|jdd} |jrZ|jjsN|j|d{Vt d|j|j|jdSt d|jdS#t$r:}t d|j|d|_d|_Yd}~dSd}~wwxYw) zSend op 6 Resume to re-authenticate after a reconnection. Reference: https://bot.q.qq.com/wiki/develop/api-v2/dev-prepare/interface-framework/reference.html Nr)r session_idseqrz([%s] Resume sent (session_id=%s, seq=%s)z0[%s] Cannot send Resume: WebSocket not connectedz[%s] Failed to send Resume: %s) rrrrrrrrrhrrr)r$rresume_payloadrs r& _send_resumezQQAdapter._send_resumesM ((********)%))".~   "x  h((888888888 >M$N F  " " " LL94=# N N N#D !DNNNNNNN  "sAB7 B77 C;/C66C;cv tj}||S#t$rYdSwxYw)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_looprro)coroloops r& _create_taskzQQAdapter._create_tasksK +--D##D)) )   44 s '* 88rDict[str, Any]c|d}|d}|d}|d}t|tr|j ||jkr||_|dkrt|tr|ni}|dd}|d z d z|_t d |j||j|j r/|j(| | n'| | dS|d kr|r|d kr| |n|dkr!t d|jn}|dvr)tj|||nP|dkr)| ||n!t d|j|dS|dkrdSt d|j|dS)zPRoute inbound WebSocket payloads (dispatch synchronously, spawn async handlers).rtsrN heartbeat_intervali0ug@@g?zB[%s] Hello received, heartbeat_interval=%dms (sending every %.1fs)rREADYRESUMEDz[%s] Session resumed)C2C_MESSAGE_CREATEGROUP_AT_MESSAGE_CREATEDIRECT_MESSAGE_CREATEGUILD_MESSAGE_CREATEGUILD_AT_MESSAGE_CREATEINTERACTION_CREATEz[%s] Unhandled dispatch: %s z[%s] Unknown op: %s)r isinstancerrdictrrrrhrr-r(r" _handle_readyrrr _on_message_on_interaction)r$rrr0r1rd_data interval_mss r&rzQQAdapter._dispatch_payloadsF [[   KK   KK   KK   a   4>#9Q=O=ODN 88$Q--5QQ2F **%95AAK'2V';c'AD $ LLT (     9DN$>!!$"3"3"5"56666!!$"5"5"7"7888 F 77q7G||""1%%%%i 2DMBBBB#D$4$4Q$:$:;;;;***!!$"6"6q"9"9:::: :DM1MMM F 88 F *DM2>>>>>r'rrct|trB|d|_td|j|jdSdS)u7Handle the READY event — store session_id for resume.r%z[%s] Ready, session_id=%sN)r=r>rrrrrh)r$rs r&r?zQQAdapter._handle_ready&sW a   V uu\22D  KK3T]DDT U U U U U V Vr'rawOptional[Dict[str, Any]]c tj|}n,#t$rtd|YdSwxYwt |t r|ndS)Nz [QQBot] Failed to parse JSON: %r)rloadsrrrr=r>)rErs r&r zQQAdapter._parse_json0sh jooGG    NN=s C C C44 %Wd33=ww=s%AAmsg_idcttjdz}ttjjddd}||z dzS)z5Generate a message sequence number in 0..65535 range.iNi)rruuiduuid4hex)rI time_partrands r& _next_msg_seqzQQAdapter._next_msg_seq9sM $$y0 4:<<#BQB',,D E))r'eventrcK|jr%|jjr|j|j|jj<t |d{VdS)z:Cache the last message ID per chat, then delegate to base.N) message_idsourcechat_idrr"handle_message)r$rSr%s r&rXzQQAdapter.handle_messageDse   G 4 G6;6FD el2 3gg$$U+++++++++++r' event_typecPKt|tsdSt|dd}|r||r#t d|j|dSt|dd}t|dd}t|dtr|dni}|dkr!| |||||d{VdS|d vr!| |||||d{VdS|d vr!| |||||d{VdS|d kr!| |||||d{VdSdS) z(Process an inbound QQ Bot message event.Nidrz([%s] Duplicate or missing message id: %s timestampcontentauthorr6)r7)r9r:r8) r=r>r r _is_duplicaterrrhr_handle_c2c_message_handle_group_message_handle_guild_message_handle_dm_message)r$rYrrIr\r]r^s r&r@zQQAdapter._on_messageJs!T""  FQUU4__%% ++F33  LL:DM6    Fk2..// aeeIr**++1133$.quuX$E$EMx2 - - -**1fgvyQQ Q Q Q Q Q Q Q Q Q 7 7 7,,QSS S S S S S S S S S N N N,,QSS S S S S S S S S S 2 2 2))!VWfiPP P P P P P P P P P3 2r'callback7Optional[Callable[[InteractionEvent], Awaitable[None]]]c||_dS)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$rds r&set_interaction_callbackz"QQAdapter.set_interaction_callbackis&."""r'c>Kt|tsdS t|}n9#t$r,}td|j|Yd}~dSd}~wwxYw|js"td|jdS ||jd{Vn>#t$r1}td|j|j|Yd}~nd}~wwxYwt d|j|j |j |j |j }|(td|j|j dS ||d{VdS#t$r.}td|j|d Yd}~dSd}~wwxYw) 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=r>rQrrrrhr[_acknowledge_interactionrscene button_dataoperator_openidrrr)r$rrSrrds r&rAzQQAdapter._on_interactionvs5!T""  F +A..EE    NN=t}c    FFFFF   x  NNBDM    F //99 9 9 9 9 9 9 9 9    NN7 ux           C M5;(95;P   -   LL u0    F (5// ! ! ! ! ! ! ! ! !    LL6 sT           sD+ A!!AA! B// C*9'C%%C*E$$ F.#FFrinteraction_idrcbK|jstd|d{V}d|dtd}|jt d||d|it d{V}|jd kr'td |jd |jdd dS) 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 []: ) rrorrFputr/r2 status_codetext)r$rmrrrrs r&riz"QQAdapter._acknowledge_interactions  QOPP P((********-e--.*,,   &** 7 7~ 7 7$' +          s " "%4+;%%9TcT?%%  # "r'oncealwaysdeny)z allow-oncez allow-alwaysr{rMcfK|j}|sdSt|}||\}}|j|}|$td|j||dS ddlm}|||}t d|j||||j n9#t$r,} t d|j|| Yd} ~ nd} ~ wwxYwdSt|} | || |j dStd|j||jdS)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)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: %sz4[%s] Unrecognised button_data %r from interaction %s)rkrP_APPROVAL_BUTTON_TO_CHOICErrrrhtools.approvalr}rrlrrrR_write_update_responserr[) r$rSrkapproval session_keydecisionchoicer}countr update_answers r&rz'QQAdapter._default_interaction_dispatchs&'   F-k::  $, !K488BBF~DM8[ DCCCCC00fEE /M5+v)      MM;  F7 DD  $  ' ' u7L M M M F B M;     s%;B!! C+"CCransweroperatorcR ddlm}|}|dz }|d}||||t d||pddS#t$r&}t d|Yd}~dSd}~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)rrrhome response_pathtmprs r&rz QQAdapter._write_update_responses E 8 8 8 8 8 8"?$$D #55M++F33C NN6 " " " KK & & & KK4/K      E E E LL> D D D D D D D D D EsA2A66 B&B!!B&r]r^r\c Kt|dd}|sdS||sdS|}|d}td|j||r |ddnd|r)t |trt|nddnd |rt |trt|D]\} } t | trutd |j| | d dt| d ddd | dd| |d{V} | d} | d} | d}| d}|rEd |}| r|dz|z n|}|r0| r|dz|z n|}td|jt| t|||d{V}|||d}|dr| |dz} | |dz} | s| sdSd|j|<t#|||d||| | ||| | ||}||d{VdS)z%Handle a C2C (private) message event. user_openidrN attachmentsz1[%s] C2C message: id=%s content=%r attachments=%srbrz itemsriz7[%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_blockc2cdmrWuser_id chat_typerVrx message_type raw_messagerU media_urls media_typesr\)r r_is_dm_allowedrrrhr=listr enumerater>_process_attachmentsjoinr_process_quoted_context_merge_quote_intorr build_source_detect_message_type_parse_qq_timestamprX)r$rrIr]r^r\rrxattachments_raw_i_att att_resultrrrr voice_blockquotedrSs r&r`zQQAdapter._handle_c2c_message-s&**]B7788   F"";//  F%% .. ? M # +GCRCLL#:ot+L+LS3'''RS[[[[   z/4@@ %o66  DdD))KKQ 44DHHUB//00"5R00  44_EEEEEEEE  - &':;&':;$%67  ))$566K9=V,33555;   ::<<%077999$   8 M  OO ! " "    33A66666666%%dF=,ABB ,  P#f\&::J 1F;N4O O zz|| J  F+0K($$##% 22:?PQQ!)..y99    !!%(((((((((((r'c Kt|dd}|sdS||t|ddsdS||}||dd{V}|d} |d} |d} |d } | rEd | } |r|d z| zn| }| r0|r|d z| zn| }||d{V}|||d }|dr| |dz} | |dz} |s| sdSd |j |<t| |t|ddd || | | ||| | | |}||d{VdS)zHandle a group @-message event. group_openidrN member_openidrrrrrrrrgrouprr)r r_is_group_allowed_strip_at_mentionrrrrrrrrrrrX)r$rrIr]r^r\rrxrrrrrrrrSs r&razQQAdapter._handle_group_messages1554455   F%%c&**_b"A"ABB    F%%g..44QUU=5I5IJJJJJJJJ  - &':;&':;$%67  ))$566K9=V,33555;   ::<<%077999$ 33A66666666%%dF=,ABB ,  P#f\&::J 1F;N4O O zz|| J  F,3L)$$$FJJ;;<<!% 22:?PQQ!)..y99    !!%(((((((((((r'c  Kt|dd}|sdSt|dd}t|dd}||p||s$td|j||dSt |dtr|dni} t| ddp"t|d d} |} ||d d{V} | d } | d }| d }| d}|rEd |}| r| dz|z n|} |r0| r| dz|z n|} | |d{V}| | |d} |d r| |d z} ||d z}| s| sdSd|j |<t||t|dd| pdd| || |||| |||}||d{VdS)z%Handle a guild/channel message event. channel_idrNguild_idr[z5[%s] Guild message blocked by ACL: channel=%s user=%smembernickusernamerrrrrrrrguildr)rWr user_namerr)r rrrrrhr=r>rrrrrrrrrrrX)r$rrIr]r^r\rr author_idrrrxrrrrrrrrSs r&rbzQQAdapter._handle_guild_messagesH|R0011   F quuZ,,-- 4,,-- %%h&<*iHH  LLG z9    F$.quuX$E$EMx26::fb))**Mc&**Z2L2L.M.M44QUU=5I5IJJJJJJJJ  - &':;&':;$%67  ))$566K9=V,33555;   ::<<%077999$ 33A66666666%%dF=,ABB ,  P#f\&::J 1F;N4O O zz|| J  F*1J'$$"FJJtR0011,$! % 22:?PQQ!)..y99   !!%(((((((((((r'c Kt|dd}|sdSt|dd}||s$td|j||dS|}||dd{V} | d} | d} | d } | d } | rEd | }|r|d z|zn|}| r0|r|d z| zn| }| |d{V}| ||d }|dr| |dz} | |dz} |s| sdSd|j |<t| |t|ddd||| | ||| | ||}||d{VdS)z Handle a guild DM message event.rrNr[z.[%s] Guild DM blocked by ACL: guild=%s user=%srrrrrrrrrrr)r rrrrrhrrrrrrrrrrrX)r$rrIr]r^r\rrrxrrrrrrrrSs r&rczQQAdapter._handle_dm_messagesquuZ,,--  F  4,,-- ""9--  LL@ x    F44QUU=5I5IJJJJJJJJ  - &':;&':;$%67  ))$566K9=V,33555;   ::<<%077999$ 33A66666666%%dF=,ABB ,  P#f\&::J 1F;N4O O zz|| J  F(,H%$$ FJJtR0011% 22:?PQQ!)..y99    !!%(((((((((((r'c|Kdggd} t|ddpddkr|Sn#ttf$r|cYSwxYw|d}t |t r|s|Sg}g}|D]}t |t st|dd}|r| ||d}t |t r/|D],} t | t r| | -| |d {V} | d pg} | d pd} | d pg} | d pg}g}|r(| d || D]}| || r| | |s| s|S|rdd |z}nd}|| |dS)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_elementsr]rNrrrr z[Quoted message]: rz[Quoted message]: (image)) rr TypeError ValueErrorr=rr>r rappendrr)r$remptyelementsquoted_text_partsall_attachmentselemetexteattsar quoted_voice quoted_info quoted_imagesquoted_image_typeslinesr0rs r&rz!QQAdapter._process_quoted_contextbs@!#    155++0q11S88 9:&   LLL 55(((D))  L (*02 2 2DdD)) B//006688E 0!((///HH]++E%&& 222A!!T**2'..q11144_EEEEEEEE !~~&9::@b  nn%677=2 "|44: '^^,?@@FB  6 LL"344 5 5 5  A LLOOOO  & LL % % % ] L  6/$))E2B2BBKK6K''!3   s*6A  A rxrch|s|S|r|d|S|S)z=Prepend ``quote_block`` to *text*, separated by a blank line.r)r)rxrs r&rzQQAdapter._merge_quote_intosG K ::<< 6!--t--3355 5r'rrrc<|s tjS|s tjS|r|dnd}d|vsd|vsd|vr tjSd|vr tjSd|vsd|vr tjSt d |tjS) z4Determine MessageType from attachment content types.rraudiovoicesilkvideoimagephotoz3Unknown media content_type '%s', defaulting to TEXT)rr PHOTOrVOICEVIDEOrr)rr first_types r&rzQQAdapter._detect_message_types $# # %$ $/:B[^))+++ j Gz$9$9Vz=Q=Q$ $ j $ $ j Gz$9$9$ $ A    r'rc 0Kt|tsgggddSg}g}g}g}|D]}t|tst|dd}t|dd}t|dd} |drd|} n|r|} nd} t d|j || d d | | || r_t|d tr5t|d dnd} t|d tr5t|d dnd} | | || | pd | pd d {V} | r;| d| t d|j | r rrr startswithrrrh_is_voice_content_type_stt_voice_attachmentrr_download_and_cacherpathisfilerr)r$rrrrother_attachmentsattcturl_rawrr asr_referr transcript cached_pathrrs r&rzQQAdapter._process_attachmentss+t,,  %'%'#%  !# ')')')G \G \Cc4(( SWW^R00117799??AAB#''%,,--3355G377:r2233H!!$'' (w((  LLR CRC    **2x880 \"#''*:";";SAAC 0"5566<<>>>"#''/":":C@@C4455;;=== $(#=#=#,#4"/"74 $>$$ M%,,-D -D-DEEELL!CH>>?? ?  4 *....00/D  ! ! # # #>>>>>>> >HSMM.//4GH,T8<< z3QQAdapter._is_voice_content_type..s/==Cr{{3======r'F)rrrany)rrr_VOICE_EXTENSIONSrs @r&rz QQAdapter._is_voice_content_typeqs   ! ! ' ' ) ) ^^   # # % % ==BMM(33=4   ====+<=== = = 4ur'Dict[str, str]c,|jr dd|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)rrs r&rzQQAdapter._qq_media_headerss,   D#%Bd.@%B%BC C r'Nrrrc K|r+td|j|dd|S|}d}|r>|drd|}|}d}td|jd d lm}||s%td |dd dS |js"td |jdS|} td|j|dd |t| |j |d| dd{V} | | j } td|jt| | j ddt| dkr0td|jt| dS|r~d dl} | dd5} | | | j}dddn #1swxYwYtd|jt| ntd|j||| |d{V}|r!t)|s"td|jdStd|j|||d{V} t/j|n#t2$rYnwxYw|r*td|j|ddn td|j|S#t4jt4jt:f$r?}td|jt=|j|Yd}~dSd}~wwxYw)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)rrz[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-typeunknownr2z8[%s] STT: downloaded data too small (%d bytes), skippingrsuffixdeletez5[%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) rrrhrrrrrrrTrrr]rrtempfileNamedTemporaryFilewriter_convert_audio_to_wav_filerexists _call_sttrunlinkOSErrorrHTTPStatusErrorTransportErrorIOErrorr r))r$rrrrr download_url is_pre_wavrdownload_headersr audio_datar#rwav_pathrrs r&rzQQAdapter._stt_voice_attachments&  " LL7W[X[W[H\   " !   ]''-- 9 8 8 8 (LJ LLLdm \ \ \000000{<((  NNO P P P4R $ 94=IIIt#5577  LLN SbS!%&&    *..(!% /D  ! ! # # #J LL@ J   ;;    :##NM OO t 00u0MM(QTIIj)))"xH((((((((((((((( KM OO  > x"&!@!@X!V!VVVVVVV tH~~'<'<'>'> NNH$- 4 LL6 x P P P#~~h77777777J  (####     Y 3T]JtPStDTUUUUH$-XXX %u';WE    NN> S "     44444 su+'NDN*NH0$ N0H44N7H48B2N,=N> M N M  AN!O<=4O77O<r1bytesc Kddl}t|jr&t|jn||}t d|jt|||dd| |d5}| ||j }dddn #1swxYwY| dddd z}| ||d{V}|s|||d{V}|s|||d{V} t!j|n#t$$rYnwxYw|S) 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=%rFr .rr)r#rr!r_guess_ext_from_datarrrhrr$r%rrsplit_convert_silk_to_wav_convert_ffmpeg_to_wav_convert_raw_to_wavrr)r*) r$r1rr#r tmp_srcsrc_pathr2results r&r&z$QQAdapter._convert_audio_to_wav_files H~~$ 7DNN ! ' ' ) ) )**:66  E M  OO  ssO     ( (E ( B B $g MM* % % %|H $ $ $ $ $ $ $ $ $ $ $ $ $ $ $??3**1-6008DDDDDDDD K66xJJJJJJJJF J33JIIIIIIIIF  Ih        D  s$%CCCE&& E32E3rc6|dddks|dddkrdS|dddkrdS|dd d krd S|dd d krd S|dddvrdS|dd dks|dd dkrdS|dd dks|dd dkrdSdS)z&Guess file extension from magic bytes.N #!SILK_V3#!SILKr r!rKsRIFFrsfLaCr)sssr s0&usOggSrs sr rXrs r&r7zQQAdapter._guess_ext_from_data@s 8| # #tBQBx9'<'<7 8x  7 8w  6 8w  7 8> > >6 8* * *d2A2h:M.M.M6 8* * *d2A2h:M.M.M6vr'cV|dddkp|dddkp |dddkS)z+Check if bytes look like a SILK audio file.NrKrCrrDr@rArXrEs r&_looks_like_silkzQQAdapter._looks_like_silkTs;BQBx9$XRaRH(<XRaRL@XXr'r=r2cK ddl}n1#t$r$td|jYdSwxYw |||dt |rt |j dkrZt d|jt |j t |j |Sn8#t$r+}t d|j|Yd}~nd}~wwxYw| d d dd z} ddl}||||||dt |rt |j dkrt d |jt |j t |j | t!j|S#t$$rYSwxYwn8#t$r+}t d |j|Yd}~nd}~wwxYw t!j|n:#t$$rYn.wxYw# t!j|w#t$$rYwwxYwxYwdS)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: %sr6rr z3[%s] pilk converted %s (as .silk) to wav (%d bytes)z%[%s] pilk .silk conversion failed: %s)pilk ImportErrorrrrh silk_to_wavrr'statst_sizerrrr8shutilcopy2rr)r*)r$r=r2rLr silk_pathrQs r&r9zQQAdapter._convert_silk_to_wavYs&   KKKK    NN]    44   W   Xxe  < < <H~~$$&& 4>>+>+>+@+@+H2+M+M >MNN'NN''))1    W W W LLA4=RU V V V V V V V V WOOC++A.8   MMM LL9 - - -   Yu  = = =H~~$$&& 4>>+>+>+@+@+H2+M+M IMNN'NN''))1     )$$$$      V V V LL@$-QT U U U U U U U U V  )$$$$      )$$$$    ts *77B9J,>JJ,J J)(J),K.KK K KKKcK ddl}||d5}|d|d|d||dddn #1swxYwY|S#t $r,}td|j |Yd}~dSd}~wwxYw)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. rNwrrrIz [%s] raw PCM fallback failed: %s) waverz setnchannels setsampwidth setframerate writeframesrrrrh)r$r1r2rVwfrs r&r;zQQAdapter._convert_raw_to_wavs  KKK8S)) +R""""""&&&z***  + + + + + + + + + + + + + + + O    LL;T]C P P P44444 s;B AA?3 B ?BB BB C!B==Cc 4K tjddd|dddd|tjjtjj d {V}tj|d d {V|jd krz|jr|j d {Vnd }t d|j t|j|d ddd SnE#tjt"f$r,}t d|j |Yd }~d Sd }~wwxYwt|r*t|jdkr5t d|j t|jd Std|j t|jt|j|S)z'Convert audio file to WAV using ffmpeg.ffmpegz-yz-iz-ar16000z-ac1)stdoutstderrNrrr'z[%s] ffmpeg failed for %s: %srur)errorsz [%s] ffmpeg conversion error: %srKz+[%s] ffmpeg produced no/small output for %sz*[%s] ffmpeg converted %s to wav (%d bytes))rcreate_subprocess_exec subprocessDEVNULLPIPEwait_forwait returncoderareadrrrhrrdecode TimeoutErrorFileNotFoundErrorr'rOrPr)r$r=r2procrars r&r:z QQAdapter._convert_ffmpeg_to_wavs4  7)1).         D"499;;;;; ; ; ; ; ; ; ;!##59[It{//111111111c3MNN'4C4L''y'99  t$$&78    NN=t}c R R R44444 H~~$$&& $x..*=*=*?*?*G2*M*M NN= X#    4 8 M NN  NN   ! ! )    sC4C;;D=!D88D=Optional[Dict[str, str]]c|jjpi}|d}t|tr|ddur|dp|dd}|dp|dd}|d d}|r|r|d ||pd d S|rB|d d}dddd}||d}|r|||p|dvrdnd d St jdd}|rCt jdd}t jdd}|d ||d SdS)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)rvrxryproviderzaiz+https://open.bigmodel.cn/api/coding/paas/v4zhttps://api.openai.com/v1)r|openaiglm)r|r~zglm-asrQQ_STT_API_KEYQQ_STT_BASE_URL QQ_STT_MODELN)rsrrr=r>rstriprr) r$rstt_cfgrvrxryr{_PROVIDER_BASE_URLS qq_stt_keys r&_resolve_stt_configzQQAdapter._resolve_stt_configs !'R))E"" gt $ $ Y)?)?u)L)L{{9--LZ1L1LHkk(++Iw{{9b/I/IGKK,,E G  ( 4 4&"1k  ";;z599I9H''# /228R@@$,#*!&"_2:n2L2LYYR] Y/44  y!=HIni88E$OOC00%  tr'c K|}|s"td|jdS|d}|d}|d} t |d5}|j|ddd |id t|j|d fid|id d{V}dddn #1swxYwY| | }| dg} | rX| d di dd} | r| S| dd} | r| SdS#tjtf$r6} td|j||dd| Yd} ~ dSd} ~ wwxYw)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)Nrvrxryrbz/audio/transcriptionsrzBearer filez audio/wavr)rfilesrrchoicesrrr]rrxz0[%s] STT API call failed (model=%s, base=%s): %srb)rrrrhrzrrrrrrrrrr+r-) r$r2rrvrxryfrr>rr]rxrs r&r(zQQAdapter._call_sttsb**,,  NNK    4:&)$  h%% !.33666,.A.A.AB!DNN$7K#HI!5) 4                 ! ! # # #YY[[FjjB//G +!!*..B77;;IrJJ==??+"==??*::fb))Dzz|| $zz||#4%w/    NNB "     44444 sDF$AB7+ F7B;;F>B;?BF=FG&0+G!!G& source_urlc\Kddl}t|jr8tt|jjnd}|r|dvr||}||d5}|||j }dddn #1swxYwY| dddd z} |d kp| |}|r| ||d{V} n| ||d{V} | sbtd |j|dd |t#|d | t%j|S#t($rYSwxYwnH#t*$r;t#|d |cY t%j|S#t($rYSwxYwwxYw t%j|n:#t($rYn.wxYw# t%j|w#t($rYwwxYwxYw t|} t%j|t#| dS#t*$r,} td|j| Yd} ~ dSd} ~ wwxYw)zLConvert audio bytes to .wav using pilk (SILK) or ffmpeg, caching the result.rNr)r r r rrrrrFr r6rrr z/[%s] audio conversion failed for %s (format=%s)raqq_voicez qq_voice.wavz%[%s] Failed to read converted wav: %s)r#rrrr!rr7r$r%rr8rGr9r:rrrhrrr)r*r read_bytesr) r$r1rr#r r<r=r2is_silkr>wav_datars r&rzQQAdapter._convert_audio_to_wav:s   ##( D*%%* + + 2 8 8 : : :  8c "   ++J77C  ( (E ( B B $g MM* % % %|H $ $ $ $ $ $ $ $ $ $ $ $ $ $ $??3**1-6 WnI(=(=j(I(IG O#888LLLLLLLL#::8XNNNNNNNN OEMssO  1=M=M=MNN  (####     O K K K,Z9IC9I9IJJ J J  (####      K O  (####      (####     H~~0022H Ih   ,X~FF F    LL@$-QT U U U44444 sB00B47B4BF0F FFHG3H5G  GGGH G55 HHH,HH, H)&H,(H))H,0AI55 J+?!J&&J+methodrbodyrfloatc K|jstd|d{V}d|dtd} |j|t ||||d{V}|}|jdkr1td|jd |d |d ||S#tj $r} td |d | | d} ~ wwxYw)z5Make an authenticated REST API request to QQ Bot API.roNrrprqrrrszQQ Bot API error [z] z: rzQQ Bot API timeout [rt) rrorrFrequestr/rrwrrTimeoutException) r$rrrrrrrrrs r& _api_requestzQQAdapter._api_request{s|  QOPP P((********-e--.*,,    O*22#T## 3D99;;D3&&"3)933T33xx 40033K% O O ODdDDsDDEE3 N Os A?C C3C..C3 target_type target_id file_type file_data srv_send_msg file_namec K|dkrd|dnd|d}||d} |r|| d<n|r|| d<|tkr|r|| d<td D]} |d || t d {VcS#t$r]} t |  t fd dDr| dkr!tjd| dzzd {VnYd } ~ d } ~ wwxYwd S)z"Upload media and return file_info.r /v2/users/z/files /v2/groups/)rrrrrPOSTrcNc3 K|]}|vV dSrrX)rkwerr_msgs r&rz*QQAdapter._upload_media..s;g r')400401InvalidrTimeoutrg?r) rDrangerr3ror rrr) r$rrrrrrrrrattemptrrs @r& _upload_mediazQQAdapter._upload_mediase## + * * * *0y000 #(    *DKK  * )D   ' 'I ' )D Qxx  G !..D$0C/   c(("QQ;;!-w{(;<<<<<<<<<<=<<<<    s#A44 C>ACCg.@g?cxKtd|j|jd}||jkr^t j|jd{V||jz }|jr#td|j|dS||jk^td|j|jdS)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) rrrh_RECONNECT_WAIT_SECONDSrr_RECONNECT_POLL_INTERVAL is_connectedr)r$waiteds r&_wait_for_reconnectionz QQAdapter._wait_for_reconnections  SM4#? A A At333- =>> > > > > > > > d3 3F   :DM6RRRt t333 =t}dNjkkkur'rWreply_tometadatarcK~|js,|d{VstdddS|r|stdS||}|||j}tdd}|D],}||||d{V}|js|cSd}-|S) 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) rrrrformat_messagetruncate_messager: _send_chunkr) r$rWr]rr formattedchunks last_resultchunks r&sendzQQAdapter.sends   X4466666666 X!%RVWWWW ,gmmoo ,d+++ +''00 &&y$2IJJ kBBB   E $ 0 0% J JJJJJJJK& #""""HHr'c  Kd}||}tdD]1} |dkr||||d{VcS|dkr||||d{VcS|dkr||||d{VcSt dd|cS#t $r}|}t| t fd d DrYd}~n\|d krHd d |zz}t d |j |dz||tj|d{VYd}~+d}~wwxYw|rt|nd td|j t fddD } t d | S)z5Send a single chunk with retry + exponential backoff.NrrrrFzUnknown chat type for rc3 K|]}|vV dSrrX)rkerrs r&rz(QQAdapter._send_chunk..# s;Sr')invalid forbidden not foundz bad requestrg?z$[%s] send retry %d/3 after %.1fs: %srz Unknown errorz[%s] Send failed: %sc3DK|]}|vVdSr)r)rr error_msgs r&rz(QQAdapter._send_chunk..6 sC  '(A"" "      r')rrrr)_guess_chat_typer_send_c2c_text_send_group_text_send_guild_textrrr rrrrrhrrr) r$rWr]rlast_excrrrrrrrs @@r&rzQQAdapter._send_chunk s)-))'22 Qxx / /G /%%!%!4!4Wgx!P!PPPPPPPPPP'))!%!6!6w!R!RRRRRRRRRR'))!%!6!6w!R!RRRRRRRRRR% %-Og-O-O / / /#hhnn&&!UEEEEEQ;;1<0ENN> !  "-.........' /*&.BCMMM?  +T]IFFF    ,Q      %yINNNNs0"B4"B49"B4B44 E>>EAEEopenidkeyboardOptional[InlineKeyboard]cK||p||||}|r||d<|||d<|dd|d|d{V}t |dt jjdd}td || S) zzSend text to a C2C user via REST API. :param keyboard: Optional inline keyboard attached to the message. rINrrr /messagesr[ TrrU raw_response rR_build_text_bodyto_dictrr rrMrNrOr)r$rr]rrrrrIs r&rzQQAdapter._send_c2c_text; s 8-v...$$Wh77  &%DN  '//11D &&v/MF/M/M/MtTTTTTTTTTXXdDJLL$4SbS$9::;;$6MMMMr'rcK||p||||}|r||d<|||d<|dd|d|d{V}t |dt jjdd}td || S) zwSend text to a group via REST API. :param keyboard: Optional inline keyboard attached to the message. rINrrrrr[rTrr)r$rr]rrrrrIs r&rzQQAdapter._send_group_textQ s 83|444$$Wh77  &%DN  '//11D && 9,9994        TXXdDJLL$4SbS$9::;;$6MMMMr'rcKd|d|ji}|r||d<|dd|d|d{V}t|dt jjdd}td || S) z*Send text to a guild channel via REST API.r]NrIrz /channels/rr[rTr)r:rr rrMrNrOr)r$rr]rrrrIs r&rzQQAdapter._send_guild_texti s!*73LT5L3L+MN  &%DN&&v/QJ/Q/Q/QSWXXXXXXXXTXXdDJLL$4SbS$9::;;$6MMMMr'rLcJK|js,|d{VstdddS||}||}|d|j} |dkr|||||d{VS|dkr|||||d{VStdd |dS#t$rI}t d |j |tdt| cYd}~Sd}~wwxYw) uSend a single text message with an inline keyboard attached. Unlike :meth:`send`, this does NOT split long content into chunks — a keyboard message has exactly one interactive surface, and splitting would orphan the buttons from the first chunk. Callers should keep approval/update-prompt bodies short. Guild (channel) chats don't support inline keyboards; returns a non-retryable failure for those. NFrTrr)rrz-Inline keyboards not supported for chat_type z"[%s] send_with_keyboard failed: %sr) rrrrrr:rrrrrrhr ) r$rWr]rrrr truncatedrs r&send_with_keyboardzQQAdapter.send_with_keyboardy s"  4466666666 !!D))'22 ''00 7 778  =E!!!00Y81G##!22Y83% %%   = = = LL4dmS   e3s88<<< < < < < < <  =s*0$C$C:C D">DD"D"reqrJcKddlm}||||t|j|d{VS)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_textrN)!gateway.platforms.qqbot.keyboardsrrrNr)r$rWrrrs r&send_approval_requestzQQAdapter.send_approval_request sw JIIIII,,    $ $ #CO 4 4 -         r'dangerous commandcommandr descriptioncK~|j|}t|d|||j}||||d{VS)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`). zExecute this command?)rtitlercommand_preview timeout_secrN)rrrJ_APPROVAL_TIMEOUT_SECONDSr)r$rWrrrrrIrs r&send_exec_approvalzQQAdapter.send_exec_approval s  "&&w//#*##6    // S60         r'i,promptdefaultcK~~|rd|dnd}d||}|j|}|||t|d{VS)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)rrrrO) r$rWrrrr default_hintr]rIs r&send_update_promptzQQAdapter.send_update_prompt s$ 3:B/W//// NN NN"&&w//,,   ( * * -         r'c||pd}|jrd|d|jit|d}n|d|jt|d}|r|jsd|i|d<|S)z2Build the message body for C2C/group text sending.rr]N)markdownmsg_typemsg_seq)r]rrrUmessage_reference)rRrr:r>r=)r$r]rrrs r&rzQQAdapter._build_text_body s$$X%:;;  ! &0I$2I0I(JK-"$$DD##fallbacks r& send_imagezQQAdapter.send_image) s '' Y 0'7H         > i!8!8 M  > M L   18Fg,,,,,YYYw8YTTTTTTTTTr' image_pathcRK~|||td||d{VS)z!Send a local image file natively.rN)rrA)r$rWrrrkwargss r&send_image_filezQQAdapter.send_image_fileC O %% Z!17GX         r' audio_pathcRK~|||td||d{VS)zSend a voice message natively.rN)rrC)r$rWrrrrs r& send_voicezQQAdapter.send_voiceQ rr' video_pathcRK~|||td||d{VS)zSend a video natively.rN)rrB)r$rWr rrrs r& send_videozQQAdapter.send_video_ rr' file_pathc VK~|||td|||d{VS)zSend a file/document natively.r)rN)rrD)r$rWr rrrrs r& send_documentzQQAdapter.send_documentm s[ %%      &         r' media_sourcekindc RK|js,|d{VstdddS||}|dkrtddS ||rY|p't t |jjpd } | ||||d|tkr| nd d{V} n"| |||||d{V\} } | d p*| d ipi d } | stdd | S| |} td | i| d} |r|d|j| d<|r|| d<|d|dkrd|dnd|d| d{V}tdt#| dt%jjdd|S#t*$rY}t,d|j|j|jtdd|jd|jddcYd}~Sd}~wt6$rf}t,d|j|j|j|jtd|jd|jd|jddcYd}~Sd}~wt:$rI}t,d |j|tdt#|cYd}~Sd}~wwxYw)!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: )rrrr]rIrrrrrr[rrz,[%s] Daily upload limit exceeded for %s (%s)z#QQ daily upload limit exceeded for z (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)rrrrrrrrrrrD_upload_local_filerrRr?r:rr rMrNrOrHrrrhrfile_size_humanrI limit_humanrr)r$rWrrrrrrr resolved_nameuploadrrr send_datars r&rzQQAdapter._send_media s*  X4466666666 X!%RVWWWW))'22   D  [ =||L)) H\22788= $11$!&/8O/K/KmmQU 2  /3.E.E  //))))))% v ;// 62&&,"c+  !!C6CC ((11G*%y1"$$D  E")*CD,C*C"DY *!)X"//!E))433339w999Iy}}T4:<<3CCRC3HIIJJ&  -    NN> s}c.A   @#-@@+@@@       '    NNA s}c.A3?   }EE#*=EE14EEE        = = = LL5t}c J J Je3s88<<< < < < < < < =sL#C%H B:H L&AI"L&" L&/AK L& L&>L!L&!L&rTuple[str, Dict[str, Any]]cK|jstdt|}|s(tj|z }|r|sL| dst|dkrtd|td||p|j }t|j|jj|j}|||t'|||d{V} || fS) 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. ro*> K&&s++ st j|dpd}|pt|jj pd}|||fSt| }| s(tj |z }|r|sL|dst#|dkrtd|t%d ||}|p|j }t jt|dpd}t)j|d }|||fS) zSLoad media from URL or local path. Returns (base64_or_url, content_type, filename).zMedia source is requiredhttphttpsrzapplication/octet-streamrrrrrascii)r rrrschemer guess_typerrrr#r$r%r&r'r'rrrorbase64 b64encoderm) r$rVrparsedrrr(rEb64s r& _load_mediazQQAdapter._load_media0 sV""$$ 9788 8&!! =- - -$/77:X>XL%Jfk):):)?J7M<6 6&\\,,.. %%'' =(**z1::<*> K  %% Vq RRR$$IZ$I$IJJ J##%%!4Z_ $S__55a8V!!#D##F,K,K,K,KTRR R R R R R R R,/D  ) ) ) L L L LL6 s K K K K K K K K K LsAC D&!D  Dc2|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$r]s r&rzQQAdapter.format_message s"  ! Ng&&&r'cFK||}||dvrdnddS)z/Return chat info based on chat type heuristics.)rrrr)rr )r)r$rWrs r& get_chat_infozQQAdapter.get_chat_info s=))'22 (,>>>GGD   r'cHtt|jdvS)Nr-)rr r1)rVs r&rzQQAdapter._is_url sF $$+/@@@r'c2||jvr |j|SdS)zDDetermine chat type from stored inbound metadata, fallback to 'c2c'.r)r)r$rWs r&rzQQAdapter._guess_chat_type s# d) ) )&w/ /ur'c`ddl}|dd|}|S)z9Strip the @bot mention prefix from group message content.rNz^@\S+\s*r)resubr)r]rGstrippeds r&rzQQAdapter._strip_at_mention s/  66+r7==??;;r'rcl|jdkrdS|jdkr||j|SdSNdisabledF allowlistT)r_entry_matchesr)r$rs r&rzQQAdapter._is_dm_allowed s? ?j ( (5 ?k ) )&&t'7AA Atr'group_idcl|jdkrdS|jdkr||j|SdSrK)rrNr)r$rOrs r&rzQQAdapter._is_group_allowed sA   + +5   , ,&&t'=xHH Htr'entriesr[targetct|}|D]D}t|}|dks||krdSEdS)N*TF)r rr)rQrRnormalized_targetentry normalizeds r&rNzQQAdapter._entry_matches sKK--//5577  EU))++1133JS  J2C$C$Ctt%Dur'rcj|stjtjS 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) rr>rutc fromisoformatrr fromtimestampr)r$rEs r&rzQQAdapter._parse_qq_timestamp s  1<8<000 0 )#.. .I&    D  )#c((T/hlKKK KI&    D |x|,,,,s!7A  A /A??BBctj}t|jtkr4|tz fd|jD|_||jvrdS||j|<dS)Nc(i|]\}}|k ||SrXrX)rkeytscutoffs r& z+QQAdapter._is_duplicate.. s+####Cb6kkRkkkr'TF)rrrr<r;items)r$rIr>ras @r&r_zQQAdapter._is_duplicate sikk t" # #n 4 4//F####'+':'@'@'B'B###D  T( ( (4&)F#ur')rSr )r!r rSri)rsrrSrT)rSri)rr rSri)rrrSrT)rr.rSri)rrrSri)rErrSrF)rIr rSr)rSrrSri)rYr rrrSri)rdrerSri)r)rmr rrrSri)rSrMrSrir()rr rr rSri) rr.rIr r]r r^r.r\r rSri)rr.rSr.)rxr rr rSr )rrrr)rrrSr.)rr rr rSr)rr rr rSrT)rSr) rr rr rr rrrrrSr)r1r3rr rSr)rr3rSr )rr3rSrT)r=r r2r rSr)r1r3r2r rSr)rSrq)r2r rSr)r1r3rr rSr) rr rr rrFrrrSr.)NNFN)rr rr rrrrrrrrTrrrSr.)NN) rWr r]r rrrrFrSrr)rWr r]r rrrSr) rr r]r rrrrrSr) rr r]r rrrrrSr)rr r]r rrrSr) rWr r]r rrLrrrSr)rWr rrJrrrSr)rN) rWr rr rr rr rrFrSr)rrN) rWr rr rr rr rrFrSr)r]r rrrSr.)NNN) rWr rr rrrrrrFrSr) rWr rr rrrrrSr) rWr rr rrrrrSr) rWr r r rrrrrSr) rWr r r rrrrrrrSr)rWr rr rrrr rrrrrrrSr) rr rWr rr rrrrrSr)rVr rrrSr+)rWr rSri)r]r rSr )rWr rSr.)rVr rSrT)rWr rSr )rr rSrT)rOr rr rSrT)rQr[rRr rSrT)rEr rSr)rIr rSrT)ar)r*r+r,SUPPORTS_MESSAGE_EDITINGr:r=r<propertyrhrrr#rrrrrrrrrrrr"r( staticmethodr-rr?r rRrXr@rgrArir~rrr`rarbrcrrrrrrrrr&r7rGr9r;r:rr(rr2rrrrrrrrrrrrrrrrrrr r rrrr7r@rrCrrrrrrNrr_r-r.s@r&r`r`s" TT %+! X((((>H>H>H>H>H>HHX7777r88882((((0!&!&!&!&F4RRRR>W%W%W%W%r.7777&&$Q$Q$Q$QL""""B  \ 5?5?5?5?nVVVV>>>\>***\*,,,,,, QQQQ> . . . .7777xJ "" ; ; ; ; zEEEE\E,])])])])~?)?)?)?)BI)I)I)I)VD)D)D)D)T\ \ \ \ |\   \ &k k k k Z!=!=!=!=F\*    "-1+/zzzzzzx0000d\&YYY\Y4444l&++++Z6666p1111f;;;;J.20 "O"O"O"O"OR"&'+!&'+,,,,,^#"4'+15 J'+ 0O0O0O0O0Ol'+15 NNNNN4'+15 NNNNN2LP N N N N N*'+ /=/=/=/=/=j'+      J 315      B!$ !15      >;?D&*&*15 UUUUU<&*&*      $&*&*      $&*&*      $&*'+&*      6&*&*'+|=|=|=|=|=|.'.'.'.'b;?$0$0$0$0$0T&L&L&L&L&LX''''    AAA\A \\----$        r'r`rd)rZrrSr[)\r, __future__rrr3rloggingrrrrMrrpathlibrtypingrrr r r r r urllib.parserrrVrMrrWgateway.configrrgateway.platforms.baserrrrrrrgateway.platforms.helpersr getLoggerr)rrr!gateway.platforms.qqbot.constantsr/r0r1r2r3r4r5r6r7r8r9r:r;r<r=r>r?r@rArBrCrDgateway.platforms.qqbot.utilsrEr]rF&gateway.platforms.qqbot.chunked_uploadrGrHrIrrJrKrLrMrNrOrPrQrRrYr^r`rXr'r&rtsJ>#"""""  ''''''''HHHHHHHHHHHHHHHHHH!!!!!!NNNGGGLLLOOO EEE43333333544444  8 $ $ W W W W W9 W W W 0                      1111 $$$$K-K-K-K-K-#K-K-K-K-K-s$A A#"A#'A.. A:9A: