ei]dZddlmZddlZddlZddlZddlZddlZddlZddl Z ddl Z ddl m Z m Z ddl mZddlmZmZmZmZmZddlmZ ddlZdZn#e$rd ZdZYnwxYw ddlZdZn#e$rd ZdZYnwxYwdd lmZmZdd lm Z m!Z!m"Z"m#Z#m$Z$m%Z%m&Z&dd l'm(Z(ej)e*Z+Gd de,Z-ddl.m/Z/m0Z0m1Z1m2Z2m3Z3m4Z4m5Z5m6Z6m7Z7m8Z8m9Z9m:Z:m;Z;mZ>m?Z?m@Z@mAZAmBZBmCZCmDZDddlEmFZGmHZHddZIddZJGdde ZKdS)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)AnyDictListOptionalTuple)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 A/home/div/.hermes/hermes-agent/gateway/platforms/qqbot/adapter.pyr!zQQCloseError.__init__Tse!%/CIII4 %+3c&kkk  U49UUt{UUUVVVVV)r)__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_agentreturnboolctotS)z/Check if QQ runtime dependencies are available.)AIOHTTP_AVAILABLEHTTPX_AVAILABLEr%r$check_qq_requirementsrJ|s  00r%valuer List[str]c t|S)z0Coerce config values into a trimmed string list.)_coerce_list_impl)rKs r$ _coerce_listrOs U # ##r%ceZdZdZdZeZdZdZeddZ dd Z dfd Z eddZ ddZ ddZddZddZddZddZddZddZddZddZddZddZedZdd"Zdd%Zedd(Zedd*Zdfd- Zdd/Z dd3Z!dd4Z"dd5Z#dd6Z$edd:Z%dd<Z&dd@Z'eddBZ(ddDZ)dEdEdFddIZ*ddLZ+eddNZ,eddOZ-ddRZ.ddSZ/ddTZ0ddVZ1ddWZ2ddYZ3dEe4fdd_Z5 dddfZ6dgZ7dhZ8ddiZ9 dddnZ: dddoZ; dddqZ< dddsZ= ddduZ> dddvZ? dddyZ@ ddd{ZA ddd}ZB dddZC dddZD dddZE dddZFdddZGddZHddZIeddZJddZKeddZLddZMddZNeddZOddZPddZQxZRS) QQAdapterzJQQ Bot adapter backed by the official QQ Bot WebSocket Gateway + REST API.F<2rDrc6t|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%rNonec|jD]8}|s"|t |9|jdS)z"Fail all pending response futures.N)_pending_responsesvaluesdone set_exception RuntimeErrorclear)r"rfuts r$ _fail_pendingzQQAdapter._fail_pendingsh*1133 8 8C88:: 8!!,v"6"6777 %%'''''r%configrc*t|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|_&dS)NrX QQ_APP_IDr client_secretQQ_CLIENT_SECRETmarkdown_supportT dm_policyopen allow_from allowFrom group_policygroup_allow_fromgroupAllowFrom>@)'r r!r QQBOTextrargetosgetenvstriprU_client_secretrE_markdown_supportlower _dm_policyrO _allow_from _group_policy_group_allow_from_session_ws _http_client _listen_task_heartbeat_task_heartbeat_interval _session_id _last_seq_chat_type_mapr\_seen_messages _last_msg_id_typing_sent_at _access_token_token_expires_atasyncioLock _token_lock _upload_cache)r"rdrtr#s r$r!zQQAdapter.__init__s4 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;r%cdS)NrVrIr"s r$namezQQAdapter.nameswr%rEc6Kts=d}|d|dtd|j|dSt s=d}|d|dtd|j|dS|jr|js=d }|d |dtd |j|dS|d |jd sdS tj dddtgi|_ | d{V|d{V}td|j|||d{Vt#j||_t#j||_|td|jdS#t0$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 IDrqresponse)timeoutfollow_redirects event_hooksNz[%s] Gateway URL: %sz[%s] ConnectedzQQ startup failed: qq_connect_error)exc_info)rG_set_fatal_errorloggerwarningrYrHrUry_acquire_platform_lockhttpx AsyncClientrr _ensure_token_get_gateway_urlinfo_open_wsr create_task _listen_loopr_heartbeat_loopr_mark_connected Exceptionerror_cleanup_release_platform_lock)r"message 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  s5DH JA.JJcKd|_||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_disconnectedrcancelrCancelledErrorrrrrrrYrs r$ disconnectzQQAdapter.disconnectsJ  !!!   %   $ $ & & & ''''''''')     $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) rclosedcloserracloser\r]r^r_r`ra)r"rbs r$rzQQAdapter._cleanup-s. 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).rRN)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)rtimerrrpostr-rUryr/raise_for_statusrrr`rurrrrY)r"respdatartokenrs r$rzQQAdapter._ensure_tokenEs   &$)++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-Agentheadersrz"Failed to get QQ Bot gateway URL: urlz%QQ Bot gateway response missing url: ) rrrur,r.rCr/rrrr`)r"rrrrrs r$rzQQAdapter._get_gateway_urlhs2((******** 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 j|_|j|dtitd{V|_t d|j |dS)z2Open a WebSocket connection to the QQ Bot gateway.Nrrz[%s] WebSocket connected to %s) rrrraiohttp ClientSession ws_connectrCr1rrrY)r"rs r$rzQQAdapter._open_wss 8 #DHO #(.."" " " " " " " " = (!5 (-%%'' ' ' ' ' ' ' ' -// 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 rrrNz([%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_eventsrrrrrrrYrr5rr6rrrrcr4r3sleep _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) rrrrrrrYrrr)r"ridentify_payloadrs r$_send_identifyzQQAdapter._send_identifylsI((********)%)) 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) rrrrrrrrrYrrr)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_looprr`)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| |nu|dkr!t d|jnN|dvr)tj|||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_CREATEz[%s] Unhandled dispatch: %s z[%s] Unknown op: %s)ru isinstancerrdictrrrrYrrr r _handle_readyrrr _on_message)r"rrrrrd_data interval_mss r$rzQQAdapter._dispatch_payloads [[   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$:$:;;;; :DM1MMM F 88 F *DM2>>>>>r%rrct|trB|d|_td|j|jdSdS)u7Handle the READY event — store session_id for resume.rz[%s] Ready, session_id=%sN)rr rurrrrY)r"rs r$r!zQQAdapter._handle_readysW 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)rloadsrrrrr )r&rs r$rzQQAdapter._parse_jsonsh 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)r* time_partrands r$ _next_msg_seqzQQAdapter._next_msg_seqsM $$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"r4r#s r$r9zQQAdapter.handle_messagese   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 timestampcontentauthorr)r)rrr) rr rru _is_duplicaterrrYrx_handle_c2c_message_handle_group_message_handle_guild_message_handle_dm_message)r"r:rr*r=r>r?s r$r"zQQAdapter._on_messages!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%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|| 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=%srSrz itemsrZz7[%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=%dc2cdmr8user_id chat_typer7text message_type raw_messager6 media_urls media_typesr=)rru_is_dm_allowedrrrYrlistr enumerater _process_attachmentsjoinrxrr build_source_detect_message_type_parse_qq_timestampr9)r"rr*r>r?r=rFrWattachments_raw_i_att att_resultrKrLrMrN voice_blockr4s r$rAzQQAdapter._handle_c2c_message4sR&**]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 ! " "    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| }|s| sdSd |j|<t| |t|ddd || | | ||| | | |}| |d{VdS)zHandle a group @-message event. group_openidrN member_openidrGrKrLrMrNrOrPgrouprSrV) rru_is_group_allowed_strip_at_mentionr_r`rxrrrarbrcr9)r"rr*r>r?r=rjrWrgrKrLrMrNrhr4s r$rBzQQAdapter._handle_group_messages@1554455   F%%c&**_b"A"ABB    F%%g..44QUU=5I5IJJJJJJJJ  - &':;&':;$%67  ))$566K9=V,33555;   ::<<%077999$  zz|| J  F,3L)$$$FJJ;;<<!% 22:?PQQ!)..y99    !!%(((((((((((r%c ^Kt|dd}|sdSt|dtr|dni}t|ddp"t|dd}|} ||dd{V} | d} | d } | d } | d }| rEd | }| r| d z|zn|} |r0| r| d z|zn|} | s| sdSd|j|<t| |t|dd|pdd| | | | ||| | | |}| |d{VdS)z%Handle a guild/channel message event. channel_idrNmembernickusernamerGrKrLrMrNrOrPguildr<rl)r8rT user_namerUrV) rrurr r_r`rxrrrarbrcr9)r"rr*r>r?r=rprqrrrWrgrKrLrMrNrhr4s r$rCzQQAdapter._handle_guild_messages]|R0011   F$.quuX$E$EMx26::fb))**Mc&**Z2L2L.M.M44QUU=5I5IJJJJJJJJ  - &':;&':;$%67  ))$566K9=V,33555;   ::<<%077999$  zz|| J  F*1J'$$"FJJtR0011,$! % 22:?PQQ!)..y99   !!%(((((((((((r%c NKt|dd}|sdS|}||dd{V}|d} |d} |d} |d} | rEd | } |r|d z| zn| }| r0|r|d z| zn| }|s| sdSd |j|<t ||t|d dd ||| | ||| | | |}| |d{VdS)z Handle a guild DM message event.guild_idrNrGrKrLrMrNrOrPrRr<rSrV) rrur_r`rxrrrarbrcr9)r"rr*r>r?r=rwrWrgrKrLrMrNrhr4s r$rDzQQAdapter._handle_dm_messagesquuZ,,--  F44QUU=5I5IJJJJJJJJ  - &':;&':;$%67  ))$566K9=V,33555;   ::<<%077999$  zz|| J  F(,H%$$ FJJtR0011% 22:?PQQ!)..y99    !!%(((((((((((r%rZr]r[c<|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)rrPHOTOr{VOICEVIDEOrr)rZr[ first_types r$rbzQQAdapter._detect_message_type6s $# # %$ $/:B[^))+++ j Gz$9$9Vz=Q=Q$ $ j $ $ j Gz$9$9$ $ A    r%rGc 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 | >>"#''/":":C@@C4455;;=== $(#=#=#,#4"/"74 $>$$ M%,,-D -D-DEEELL!rrrrYr mimetypesguess_extensionr_convert_audio_to_wavrr rrr) r"rrHrrrrextrJs r$rzQQAdapter._download_and_caches000000{3 @>CH>>?? ?  4 *....00/D  ! ! # # #>>>>>>> >HSMM.//4GH,T8<< z3QQAdapter._is_voice_content_type..s/==Cr{{3======r%F)rxr{rany)rHrJr_VOICE_EXTENSIONSrs @r$rz QQAdapter._is_voice_content_types   ! ! ' ' ) ) ^^   # # % % ==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: %srIz[%s] STT: no HTTP clientz<[%s] STT: downloading voice from %s (pre_wav=%s, headers=%s)rq)rrrz.[%s] STT: downloaded %d bytes, content_type=%sz content-typeunknownrz8[%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) rrrYrrrrrrrErurr>rrtempfileNamedTemporaryFilewriter_convert_audio_to_wav_filerexists _call_sttrvunlinkOSErrorrHTTPStatusErrorTransportErrorIOErrorrr&)r"rrHrJrr download_url is_pre_wavrdownload_headersr audio_datartmpwav_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<rbytesc 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)rrrr{_guess_ext_from_datarrrYrrrrrsplit_convert_silk_to_wav_convert_ffmpeg_to_wav_convert_raw_to_wavrvrr) r"rrJrrtmp_srcsrc_pathrresults r$rz$QQAdapter._convert_audio_to_wav_filews 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#!SILKrr!r,sRIFFrsfLaCr)sssrs0&usOggSrs srrIrs r$rzQQAdapter._guess_ext_from_datas 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.Nr,rrrrrrIrs r$_looks_like_silkzQQAdapter._looks_like_silks;BQBx9$XRaRH(<XRaRL@XXr%rrcK 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: %srrrz3[%s] pilk converted %s (as .silk) to wav (%d bytes)z%[%s] pilk .silk conversion failed: %s)pilk ImportErrorrrrY silk_to_wavrrstatst_sizerrrrshutilcopy2rvrr)r"rrrr silk_pathrs r$rzQQAdapter._convert_silk_to_wavs&   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. rNwrrrz [%s] raw PCM fallback failed: %s) waverk setnchannels setsampwidth setframerate writeframesrrrrY)r"rrrwfrs r$rzQQAdapter._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: %sreplace)errorsz [%s] ffmpeg conversion error: %srz+[%s] ffmpeg produced no/small output for %sz*[%s] ffmpeg converted %s to wav (%d bytes))rcreate_subprocess_exec subprocessDEVNULLPIPEwait_forwait returncoderreadrrrYrrdecode TimeoutErrorFileNotFoundErrorrrrr)r"rrprocrrs r$rz QQAdapter._convert_ffmpeg_to_wav s4  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)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)rdrtrurr rstriprvrw) r"rtstt_cfgrrrr_PROVIDER_BASE_URLS qq_stt_keys r$_resolve_stt_configzQQAdapter._resolve_stt_config8s !'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)Nrrrrbz/audio/transcriptionsrzBearer filez audio/wavrq)rfilesrrchoicesrrr>rrWz0[%s] STT API call failed (model=%s, base=%s): %srS)r%rrrYrkrrrrrrrurxrrr) r"rr"rrrfrrr*r>rWrs r$rzQQAdapter._call_sttpsb**,,  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)rrrrrrrrFrrrrrz/[%s] audio conversion failed for %s (format=%s)rRqq_voicez qq_voice.wavz%[%s] Failed to read converted wav: %s)rr rrrr{rrrrrrrrrrrYrrvrrr read_bytesr) r"rr,rrrrris_silkrwav_datars r$rzQQAdapter._convert_audio_to_wavs   ##( 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.u.HTTP client not initialized — not connected?Nrzapplication/json)rz Content-Typer)rrrizQQ Bot API error [z] z: rzQQ Bot API timeout [z]: ) rr`rrCrequestr,r status_coderurTimeoutException) r"r2rr3rrrrrrs r$ _api_requestzQQAdapter._api_requests|  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.rQ /v2/users//files /v2/groups/)r<r>rr=r?POSTrNc3 K|]}|vV dSrrI)rkwerr_msgs r$rz*QQAdapter._upload_media..,s;g r%)400401InvalidrTimeoutrg?r) rAranger9r0r`rrrr) r"r:r;r<rr=r>r?rr3attemptrrHs @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)rrNz[%s] Reconnected after %.1fsTz$[%s] Still not connected after %.0fsF) rrrY_RECONNECT_WAIT_SECONDSrr_RECONNECT_POLL_INTERVAL is_connectedr)r"waiteds r$_wait_for_reconnectionz QQAdapter._wait_for_reconnection;s  SM4#? A A At333- =>> > > > > > > > d3 3F   :DM6RRRt t333 =t}dNjkkkur%r8reply_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)r[z No chunksr[r) rSrUrrxformat_messagetruncate_messager7 _send_chunkr[) r"r8r>rVrW formattedchunks last_resultchunks r$sendzQQAdapter.sendQs   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.NrDrQrlrtFzUnknown chat type for r\c3 K|]}|vV dSrrI)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{)rrg error_msgs r$rz(QQAdapter._send_chunk..sC  '(A"" "      r%)rirjrkrZ)_guess_chat_typerM_send_c2c_text_send_group_text_send_guild_textrrrr{rrrrYrrr) r"r8r>rVlast_excrUrNrrrrhrms @@r$r_zQQAdapter._send_chunkrs)-))'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>>EAEEopenidcVK||p|}|||}|r||d<|dd|d|d{V}t|dt jjdd}td|| S) z%Send text to a C2C user via REST API.r*rErA /messagesNr< Tr[r6 raw_response r3_build_text_bodyr9rrur.r/r0r)r"rsr>rVmsg_seqr3rr*s r$rozQQAdapter._send_c2c_texts$$X%788$$Wh77  &%DN&&v/MF/M/M/MtTTTTTTTTTXXdDJLL$4SbS$9::;;$6MMMMr%rjcVK||p|}|||}|r||d<|dd|d|d{V}t|dt jjdd}td|| S) z"Send text to a group via REST API.r*rErCruNr<rvTrwry)r"rjr>rVr{r3rr*s r$rpzQQAdapter._send_group_texts$$X%=>>$$Wh77  &%DN&& 9,9994        TXXdDJLL$4SbS$9::;;$6MMMMr%rpcKd|d|ji}|r||d<|dd|d|d{V}t|dt jjdd}td || S) z*Send text to a guild channel via REST API.r>Nr*rEz /channels/rur<rvTrw)r7r9rrur.r/r0r)r"rpr>rVr3rr*s r$rqzQQAdapter._send_guild_texts!*73LT5L3L+MN  &%DN&&v/QJ/Q/Q/QSWXXXXXXXXTXXdDJLL$4SbS$9::;;$6MMMMr%c||pd}|jrd|d|jit|d}n|d|jt|d}|r|jsd|i|d<|S)z2Build the message body for C2C/group text sending.defaultr>N)markdownmsg_typer{)r>rr{r6message_reference)r3rzr7r;r:)r"r>rVr{r3s r$rzzQQAdapter._build_text_bodys$$X%:;;  ! &0I$2I0I(JK-"$$DD##rV) _send_mediar>r[_is_urlrrrYrrd)r"r8rrrVrWrfallbacks r$ send_imagezQQAdapter.send_images '' Y 0'7H         > i!8!8 M  > M L   18Fg,,,,,YYYw8YTTTTTTTTTr% image_pathcRK~|||td||d{VS)z!Send a local image file natively.r}N)rr>)r"r8rrrVkwargss r$send_image_filezQQAdapter.send_image_fileO %% Z!17GX         r% audio_pathcRK~|||td||d{VS)zSend a voice message natively.rzN)rr@)r"r8rrrVrs r$ send_voicezQQAdapter.send_voicerr% video_pathcRK~|||td||d{VS)zSend a video natively.r|N)rr?)r"r8rrrVrs r$ send_videozQQAdapter.send_video rr% file_pathc VK~|||td|||d{VS)zSend a file/document natively.r()r?N)rrA)r"r8rrr?rVrs r$ send_documentzQQAdapter.send_document.s[ %%      &         r% media_sourcekindc \K|js,|d{VstdddS |||d{V\}} } ||} | dkrd|dnd |d} | d krtdd S|| ||||s|nd||r|ndd|tkr| nd d{V} | d}|stdd|  S| |}td|i|d}|r|d|j |d<|r||d<| d| dkrd|dnd |d|d{V}tdt|dtjjdd|S#t"$rI}t$d|j|tdt| cYd}~Sd}~wwxYw)z*Upload media and send as a native message.NFrYTrZrQrArBrCrtz,Guild media send not supported via this pathr\)r=rr>r? file_infozUpload returned no file_info: )rmediar{r>r*rErur<rvrwz[%s] Media send failed: %s)rSrUr _load_mediarnrOrrArur3r<r7r9rr.r/r0rrrrY)r"r8rr<rrrVr?rrH resolved_namerU target_pathuploadrr{r3 send_datars r$rzQQAdapter._send_mediaCsF  X4466666666 X!%RVWWWWB =6:6F6Fi77111111 -D, --g66I%%-W,,,,27222  G##"!)W  --&*ll<&@&@J$$d$(LL$>$>HLLD"+4+G+G--T.F ;//I !!)R&)R)R ((11G*%y1"$$D  E")*CD,C*C"DY *!)X"//!E))433339w999Iy}}T4:<<3CCRC3HIIJJ&   = = = LL5t}c J J Je3s88<<< < < < < < < =s,AGBGB:G H+">H& H+&H+r7Tuple[str, str, str]cKt|}|stdt|}|jdvr>t 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-streamrXL%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). )rzr)r"r>s r$r]zQQAdapter.format_messages"  ! Ng&&&r%cFK||}||dvrdnddS)z/Return chat info based on chat type heuristics.)rlrtrlrR)rr)rn)r"r8rUs r$ get_chat_infozQQAdapter.get_chat_infos=))'22 (,>>>GGD   r%cHtt|jdvS)Nr)r rr)r7s r$rzQQAdapter._is_url sF $$+/@@@r%c2||jvr |j|SdS)zDDetermine chat type from stored inbound metadata, fallback to 'c2c'.rQ)r)r"r8s r$rnzQQAdapter._guess_chat_type s# d) ) )&w/ /ur%c`ddl}|dd|}|S)z9Strip the @bot mention prefix from group message content.rNz^@\S+\s*r)resubrx)r>rstrippeds r$rnzQQAdapter._strip_at_mention s/  66+r7==??;;r%rTcl|jdkrdS|jdkr||j|SdSNdisabledF allowlistT)r|_entry_matchesr})r"rTs r$r\zQQAdapter._is_dm_allowed s? ?j ( (5 ?k ) )&&t'7AA Atr%group_idcl|jdkrdS|jdkr||j|SdSr)r~rr)r"rrTs r$rmzQQAdapter._is_group_allowed sA   + +5   , ,&&t'=xHH Htr%entriesrLtargetct|}|D]D}t|}|dks||krdSEdS)N*TF)rrxr{)rrnormalized_targetentry normalizeds r$rzQQAdapter._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) rrrutc fromisoformatr TypeError fromtimestampr)r"r&s r$rczQQAdapter._parse_qq_timestamp0 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 ||SrIrI)rkeytscutoffs r$ z+QQAdapter._is_duplicate..F s+####Cb6kkRkkkr%TF)rrrr9r8items)r"r*rrs @r$r@zQQAdapter._is_duplicateB sikk t" # #n 4 4//F####'+':'@'@'B'B###D  T( ( (4&)F#ur%)rDr)rrrDrZ)rdrrDrE)rDrZ)rrrDrZ)rrrDrE)rrrDrZ)rrrDrZ)r&rrDr')r*rrDr)r4rrDrZ)r:rrrrDrZ) rrr*rr>rr?rr=rrDrZ)rZr]r[r])rGrrDr)rrrHrrDr)rHrrJrrDrE)rDr) rrrHrrJrrrrrrDr)rrrJrrDr)rrrDr)rrrDrE)rrrrrDr)rrrrrDr)rDr)rrrDr)rrr,rrDr) r2rrrr3r'rr4rDr)NNFN)r:rr;rr<rrrr=rr>rEr?rrDr)NN) r8rr>rrVrrWr'rDrr)r8rr>rrVrrDr)rsrr>rrVrrDr)rjrr>rrVrrDr)rprr>rrVrrDr)r>rrVrrDr)NNN) r8rrrrrrVrrWr'rDr) r8rrrrrrVrrDr) r8rrrrrrVrrDr) r8rrrrrrVrrDr) r8rrrrrr?rrVrrDr)r8rrrr<rrrrrrVrr?rrDr)r7rr?rrDr)r8rrDrZ)r>rrDr)r8rrDr)r7rrDrE)r8rrDr)rTrrDrE)rrrTrrDrE)rrLrrrDrE)r&rrDr)r*rrDrE)Sr&r'r(r)SUPPORTS_MESSAGE_EDITINGr7rrpropertyrYrcr!rrrrrrrrrrrrr  staticmethodrrr!rr3r9r"rArBrCrDrbr_rrrrrrrrrrr%rrr/r9rOrQrRrUrdr_rorprqrzrrrrrrrrr]rrrnrnr\rmrrcr@r*r+s@r$rQrQsTT %+! X((((.;.;.;.;.;.;hX3333j88882((((0!&!&!&!&F4RRRR(W%W%W%W%r.7777&&$Q$Q$Q$QL""""B  \ 3?3?3?3?jVVVV>>>\>***\*,,,,,, QQQQ6V)V)V)V)p8)8)8)8)t6)6)6)6)p2)2)2)2)p   \ &k k k k Z!=!=!=!=F\*    "-1+/zzzzzzx0000d\&YYY\Y4444l&++++Z6666p1111f;;;;J.20 "O"O"O"O"OR"&'+!&'+,,,,,^#"4'+15 J'+ 0O0O0O0O0OfHL N N N N NNR N N N N N LP N N N N N;?D&*&*15 UUUUU<&*&*      $&*&*      $&*&*      $&*'+&*      6&*&*'+Q=Q=Q=Q=Q=h;?$0$0$0$0$0T&L&L&L&L&LX''''    AAA\A \\----$        r%rQr)rKrrDrL)Lr) __future__rrrrloggingrrvrr.rrpathlibrtypingrrr r r urllib.parser rrGrrrHgateway.configr rgateway.platforms.baserrrrrrrgateway.platforms.helpersr getLoggerr&rrr!gateway.platforms.qqbot.constantsr,r-r.r/r0r1r2r3r4r5r6r7r8r9r:r;r<r=r>r?r@rAgateway.platforms.qqbot.utilsrBrNrCrJrOrQrIr%r$rs>#"""""  ''''''''33333333333333!!!!!!NNNGGGLLLOOO EEE43333333544444  8 $ $ W W W W W9 W W W 0 1111 $$$$A#A#A#A#A##A#A#A#A#A#s$ A AA#A** A65A6