i7dZddlmZddlZddlZddlZddlZddlZddlZddl 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%dd l&m'Z'ej(e)Z*Gd de+Z,dZ-dZ.dZ/dZ0dZ1dZ2gdZ3dZ4dZ5dZ6dZ7dZ8dZ9dZ:dZ;dZd Z?dZ@dZAd!ZBd+d$ZCd,d(ZDGd)d*e ZEdS)-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 SendResultcache_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 ?/home/agentuser/.hermes/hermes-agent/gateway/platforms/qqbot.pyr zQQCloseError.__init__Qse!%/CIII4 %+3c&kkk  U49UUt{UUUVVVVV)r)__name__ __module__ __qualname____doc__r __classcell__r"s@r#rrKsQ WWWWWWWWWWr$rzhttps://api.sgroup.qq.comz)https://bots.qq.com/app/getAppAccessTokenz/gateway>@g^@g4@) <dr0g@ii,r,returnboolctotS)z/Check if QQ runtime dependencies are available.)AIOHTTP_AVAILABLEHTTPX_AVAILABLEr$r#check_qq_requirementsr>xs  00r$valuer List[str]cX|gSt|trd|dDSt|ttt fr d|DSt|r"t|gngS)z0Coerce config values into a trimmed string list.Nc^g|]*}||+Sr=)strip.0items r# z _coerce_list..s-JJJTZZ\\J JJJr$,cg|]D}t|#t|ESr=)rrCrDs r#rGz _coerce_list..s=IIIds4yy7H7HID !!IIIr$) isinstancersplitlisttuplesetrC)r?s r# _coerce_listrO}s } %KJJS)9)9JJJJ%$s+,,JIIeIIII#&u::#3#3#5#5 =CJJ      2=r$creZdZdZdZddZeZdfd Zedd Z dd Z ddZ ddZ ddZ ddZddZddZddZddZddZddZddZedZddZdd"Zedd%Zedd'Zdd)Zdd-Zdd.Zdd/Zdd0Z edd4Z!dd6Z"dd:Z#edd<Z$dd>Z%d?d?d@ddCZ&ddFZ'eddHZ(eddIZ)eddLZ*eddMZ+eddNZ,ddPZ-ddQZ.ddSZ/d?e0fddYZ1 ddd`Z2 dddeZ3 dddfZ4 dddhZ5 dddjZ6 dddlZ7dddmZ8 dddpZ9 dddrZ: dddtZ; dddvZ< dddxZ= ddd{Z> ddd~Z?dddZ@ddZAddZBeddZCddZDeddZEddZFddZGeddZHddZIddZJxZKS) QQAdapterzJQQ Bot adapter backed by the official QQ Bot WebSocket Gateway + REST API.Frrr8Nonec|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$configrct|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|_d|_d|_ tCj"|_#i|_$dS)Napp_id QQ_APP_IDr client_secretQQ_CLIENT_SECRETmarkdown_supportT dm_policyopen allow_from allowFrom group_policygroup_allow_fromgroupAllowFromr+)%rr r QQBOTextrargetosgetenvrC_app_id_client_secretr9_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_maprT_seen_messages _access_token_token_expires_atasyncioLock _token_lock _upload_cache)r!r\rlr"s r#r zQQAdapter.__init__s 000 "599X..L")K2L2LMMSSUU !%))O"<"<"a J\^`@a@abbhhjj!%eii0BD&I&I!J!Jeii V<<==CCEEKKMM' ,(?(?(Y599[CYCYZZ >6!B!BCCIIKKQQSS!-eii8J.K.K.juyyYiOjOj!k!k:> >B9=487;*. *.(,.0>@02-1(+"<>>9;r$cdS)NQQBotr=r!s r#namezQQAdapter.nameswr$r9c$Kts=d}|d|dtd|j|dSt s=d}|d|dtd|j|dS|jr|js=d }|d |dtd |j|dS|d |jd sdS tj dd|_ | d{V| d{V}td|j|||d{Vt!j||_t!j||_|td|jdS#t.$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+)timeoutfollow_redirectsNz[%s] Gateway URL: %sz[%s] ConnectedzQQ startup failed: qq_connect_error)exc_info)r;_set_fatal_errorloggerwarningrr<rprq_acquire_platform_lockhttpx AsyncClientrz _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> 7 S S S5 >G  ! !"97d ! S S S NN">??? %%'''''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).r0N)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)rtimerrrzpost TOKEN_URLrprqDEFAULT_API_TIMEOUTraise_for_statusrrrXrmrrrr)r!respdatartokenrs r#rzQQAdapter._ensure_token0s   &$)++0F0K"K"K% %# & & & & & & & &! *dikkD4JR4O&O&O) & & & & & & & & & & & & & & Y!.33#'<ATUU/4 %%'''yy{{ Y Y Y"#N#N#NOOUXX YHH^,,E Z"#XRV#X#XYYYTXXlD99::J!&D %)Y[[:%=D " KKEtyR\ ] ] ]%1 & & & & & & & & & & & & & & & & & & & & & & & & & & & & & &s7-F.>A"C! F.! D+C>>DBF.. F8;F8cK|d{V} |jttdd|it d{V}||}n%#t$r}td||d}~wwxYw|d}|std||S)z2Fetch the WebSocket gateway URL from the REST API.N AuthorizationQQBot )headersrz"Failed to get QQ Bot gateway URL: urlz%QQ Bot gateway response missing url: ) rrzrmAPI_BASEGATEWAY_URL_PATHrrrrrX)r!rrrrrs r#rzQQAdapter._get_gateway_urlOs#((******** T*../-//(*:5*:*:;+/D  ! ! # # #99;;DD T T TICIIJJPS S Thhuoo OMtMMNN N sA#B B$ BB$rcK|jr+|jjs|jd{Vd|_|jr+|jjs|jd{Vd|_t j|_|j|td{V|_t d|j |dS)z2Open a WebSocket connection to the QQ Bot gateway.Nrz[%s] WebSocket connected to %s) ryrrrxaiohttp ClientSession ws_connectCONNECT_TIMEOUT_SECONDSrrr)r!rs r#rzQQAdapter._open_wsfs 8 #DHO #(.."" " " " " " " " = (!5 (-%%'' ' ' ' ' ' ' ' -// 11 +2          4diMMMMMr$c:Kd}d}d}|jr tj}|d{Vd}d}nL#tj$rYdSt $rn}|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}n|dz }Yd}~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 rrjNz([%s] WebSocket closed: code=%s reason=%sr6z([%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-identifyz[%s] WebSocket error: %szConnection interruptedz#[%s] Max reconnect attempts reached)rr monotonic _read_eventsrrrrrrrrQUICK_DISCONNECT_THRESHOLDrMAX_QUICK_DISCONNECT_COUNTrrrr[RATE_LIMIT_DELAYMAX_RECONNECT_ATTEMPTSsleep _reconnectrrr~rr)r! backoff_idx connect_timequick_disconnect_countrrdurationdescs r#rzQQAdapter._listen_loopws  !"m[ %Z %#~// ''))))))))) )*&&)   B %B %B %}FFFFFxI"isz;;; >++l:888\A=M=M*a/*KK J#y(4JLLL-1KKK d I --.CR^b.dddL./*'')))""#6777<''59T\\11xDLL!JDIW[\\\)),,,8H$8H8HTY)ZZZFFFFF4<<KK GTdeee"&<<<!-(8999999999!__[99999999)&' 12..#q( HHHH4<<KK WY]Ybccc)-D&-0D*KKKKK []a]fhlmmm'+D$%)DN55555555%"#K-.**1$K % % %}FFFFF949cJJJ'')))""#;<<<"888LL!F RRRFFFFF55555555%"#K-.**1$K %Ym[ %[ %[ %[ %[ %sX1AN N!K .B?K 3A9K 27K /AK 9B K  NN $A5N %N  NrrcpKtt|ttdz }td|j||dzt j|d{Vd|_ | d{V| d{V}| |d{V| td|jdS#t$r,}td|j|Yd}~dSd}~wwxYw) z 5R]`aRabbbmE"""""""""#'  $$&& & & & & & & & $ 5 5 7 7777777K-- ,, , , , , , , ,  " " " KK*DI 6 6 64    NN6 3 G G G55555 s:BC?? D5 !D00D5cK|jstd|jr#|jr|jjs|jd{V}|jt jjkr2| |j }|r| |n|jt jj fvrnl|jt jj krt|j |j|jt jjt jjfvrtd|jr|jr|jj dSdSdSdSdSdS)z.Read WebSocket frames until connection closes.zWebSocket not connectedNzWebSocket closed)ryrXrrreceivetyper WSMsgTypeTEXT _parse_jsonr_dispatch_payloadPINGCLOSErrlCLOSEDERROR)r!msgpayloads r#rzQQAdapter._read_eventsspx :899 9m 7 7 7((********Cx7,111**38444**7333g/4666W.444"38SY777g/68I8OPPP"#5666m 7 7 7 7 7 7 7 7 7 7 7 7 7 7 7r$cK |jrtj|jd{V|jr |jjr: |jd|jdd{Vn8#t$r+}t d|j |Yd}~nd}~wwxYw|jdSdS#tj $rYdSwxYw)zSend periodic heartbeats (QQ Gateway expects op 1 heartbeat with latest seq). The interval is set from the Hello (op 10) event's heartbeat_interval. QQ's default is ~41s; we send at 80% of the interval to stay safe. Nr6opdz[%s] Heartbeat failed: %s) rrrr}ryr send_jsonrrrdebugrr)r!rs r#rzQQAdapter._heartbeat_loops% - NmD$<=========x48?N(,,ADN-K-KLLLLLLLLLL NNNLL!=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 Nr,riBrr6macOSz hermes-agent)z$osz$browserz$device)rintentsshard propertiesrz[%s] Identify sentz2[%s] Cannot send Identify: WebSocket not connectedz [%s] Failed to send Identify: %s) rryrrrrrrrr)r!ridentify_payloadrs r#_send_identifyzQQAdapter._send_identifys=((********)%))<Q" .-      Mx ` `h(()9::::::::: 0$)<<<<<SUYU^_____ M M M LL;TY L L L L L L L L L MsAB( 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 Nr5r)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) rr~rryrrrrrrrr)r!rresume_payloadrs r# _send_resumezQQAdapter._send_resume:sH ((********)%))".~   "x ^ ^h((888888888 F!Y(8$.JJJJJQSWS\]]]]] " " " LL949c J J J#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_looprrX)coroloops r# _create_taskzQQAdapter._create_taskUsK +--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).rtsrNr.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)rmrJrrdictr}rrrr~r rr _handle_readyrrr _on_message)r!rrrrrd_data interval_mss r#rzQQAdapter._dispatch_payloadbs [[   KK   KK   KK   a   4>#9Q=O=ODN 88$Q--5QQ2F **%95AAK'2V';c'AD $ LL] ;0H J J J 9DN$>!!$"3"3"5"56666!!$"5"5"7"7888 F 77q7G||""1%%%%i 2DI>>>>333#D$4$4Q$:$:;;;; :DIqIII F 88 F *DIr:::::r$rrct|trB|d|_td|j|jdSdS)u7Handle the READY event — store session_id for resume.rz[%s] Ready, session_id=%sN)rJrrmr~rrr)r!rs r#rzQQAdapter._handle_readysW a   R uu\22D  KK3TY@P Q Q Q Q Q R Rr$rawOptional[Dict[str, Any]]c tj|}n-#t$r tdd|YdSwxYwt |t r|ndS)Nz[%s] Failed to parse JSON: %rr)rloadsrrrrJr)rrs r#rzQQAdapter._parse_jsonsj jooGG    LL8'3 G G G44 %Wd33=ww=s&AAmsg_idcttjdz}ttjjddd}||z dzS)z5Generate a message sequence number in 0..65535 range.iNr7i)rruuiduuid4hex)r# time_partrands r# _next_msg_seqzQQAdapter._next_msg_seqsM $$y0 4:<<#BQB',,D E))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) rJrrrm _is_duplicaterrrrC_handle_c2c_message_handle_group_message_handle_guild_message_handle_dm_message)r!r,rr#r/r0r1s r#rzQQAdapter._on_messages!T""  FQUU4__%% ++F33  LLCTYPV W W W 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$r0r1r/c Kt|dd}|sdS||sdS|}|d}td||r |ddnd|r)t |t rt|nddnd |rt |t rt|D]\} } t | trotd | | d dt| d ddd | dd| |d{V} | d} | d} | d}| d}|rEd |}| r|dz|z n|}|r0| r|dz|z n|}tdt| t|| s| sdSd|j |<t|||d||| | ||| | ||}||d{VdS)z%Handle a C2C (private) message event. user_openidrN attachmentsz1[QQ] C2C message: id=%s content=%r attachments=%s2rz itemsrRz9[QQ] attachment[%d]: content_type=%s url=%s filename=%s content_typerPfilename image_urlsimage_media_typesvoice_transcriptsattachment_info  z*[QQ] After processing: images=%d, voice=%dc2cdmchat_iduser_id chat_typesourcetext message_type raw_message message_id media_urls media_typesr/)rrm_is_dm_allowedrrrJrLr enumerater_process_attachmentsjoinrCrr build_source_detect_message_type_parse_qq_timestamphandle_message)r!rr#r0r1r/r8rLattachments_raw_i_att att_resultr>r?r@rA voice_blockevents r#r3zQQAdapter._handle_c2c_messages2&**]B7788   F"";//  F%% .. GG;GCRCLL&3z/4/P/PWs?+++VW____,2 4 4 4  :z/4@@ :%o66 : :DdD)):KK [ "DHH^R$@$@ #DHHUB$7$7 8 8" = $R 8 8:::  44_EEEEEEEE  - &':;&':;$%67  Z))$566K<@JJLLYD6MK/66888kD  b@D aD6MO3::<<r?r@rArBrCgrouprFrJ) rrm_is_group_allowed_strip_at_mentionrTrUrCrrrVrWrXrY)r!rr#r0r1r/rarLr]r>r?r@rAr^r_s r#r4zQQAdapter._handle_group_messages.1554455   F%%lC ?TV8W8W4X4XYY  F%%g..44QUU=5I5IJJJJJJJJ  - &':;&':;$%67  Z))$566K<@JJLLYD6MK/66888kD  b@D aD6MO3::<<r?r@rArBrCguildr.rc)rGrH user_namerIrJ) rrmrJrrTrUrCrrrVrWrXrY)r!rr#r0r1r/rgrhrirLr]r>r?r@rAr^r_s r#r5zQQAdapter._handle_guild_message1sQ|R0011   F$.quuX$E$EMx26::fb))**Mc&**Z2L2L.M.M44QUU=5I5IJJJJJJJJ  - &':;&':;$%67  Z))$566K<@JJLLYD6MK/66888kD  b@D aD6MO3::<<r?r@rArBrCrEr.rFrJ) rrmrTrUrCrrrVrWrXrY)r!rr#r0r1r/rnrLr]r>r?r@rAr^r_s r#r6zQQAdapter._handle_dm_message^squuZ,,--  F44QUU=5I5IJJJJJJJJ  - &':;&':;$%67  Z))$566K<@JJLLYD6MK/66888kD  b@D aD6MO3::<<r?r@rAr;rr=//https:z@[QQ] Processing attachment: content_type=%s, url=%s, filename=%sNr<asr_refer_text voice_wav_urlr}r~z[Voice] z[QQ] Voice transcript: %sz[QQ] Voice STT failed for %sr0u[Voice] [语音识别失败]image/z image/jpegz)[QQ] Cached image path does not exist: %sz[QQ] Failed to cache image: %sz [Attachment: ]z#[QQ] Failed to cache attachment: %srB)rJrLrrrmrCrs startswithrr_is_voice_content_type_stt_voice_attachmentappendrr_download_and_cachernpathisfilerrU)r!r9r>r?r@other_attachmentsattcturl_rawr=r asr_referr~ transcript cached_pathrrAs r#rTzQQAdapter._process_attachmentss+t,, D"$2)+DD D!# ')')'): M: MCc4(( SWW^R00117799??AAB#''%,,--3355G377:r2233H!!$'' (w((  LL[S"Xx 1 1 1**2x88( M"#''*:";";SAAJC 0"5566<<>>>GI "#''/":":C@@IC4455;;===FH $(#=#=X#,#4"/"74$>$$ M%,,-D -D-DEEEKK ;ZHHHHNN#A3ss8LLL%,,-KLLLLx(( MH(,(@(@b(I(I"I"I"I"I"I"IK"arw~~k'B'Ba"))+666)001C|DDDD$a'RT_``` HHHLL!A3GGGGGGGGHM(,(@(@b(I(I"I"I"I"I"I"IK"T)001RR1R1R1RSSS MMMLL!FLLLLLLLLM;LS$))$5666QS$!2!2.    s1)BL22 M"<MM"&9N!! O+O  Orr; Optional[str]cKddlm}||std|dd|jsdS |j|d|d{V}||j}nB#t$r5}t d|j |dd|Yd}~dSd}~wwxYw| d r&tj|pd }t||S|d ks| d r|||d{VSt#t%|jj pd }t)||S)z$Download a URL and cache it locally.r) is_safe_urlzBlocked unsafe URL: Nr<r+)rrz[%s] Download failed for %s: %srz.jpgrqaudio/ qq_attachment)tools.url_safetyr ValueErrorrzrm_qq_media_headersrr0rrrrr mimetypesguess_extensionr_convert_audio_to_wavrr rr) r!rr;rrrrextr=s r#rzQQAdapter._download_and_caches000000{3 @>CH>>?? ?  4 *..T4+A+A+C+C/D  ! ! # # #>>>>>>> >HSMM.//4GH,T8<< z3QQAdapter._is_voice_content_type.. s/==Cr{{3======r$F)rCrsrany)r;r=r_VOICE_EXTENSIONSrs @r#rz QQAdapter._is_voice_content_types   ! ! ' ' ) ) ^^   # # % % ==BMM(33=4h ====+<=== = = 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_headers$s,   D#%Bd.@%B%BC C r$Nrr}r~cK|r%td|dd|S|}d}|r8|drd|}|}d}td |jstd dS|}td |dd |t ||j|d |d d{V} | | j } tdt| | j ddt| dkr*tdt| dS|rxddl } | dd5} | | | j} dddn #1swxYwYtdt| nvtd||| |d{V} | r!t#| stddStd| || d{V} t)j| n#t,$rYnwxYw|r$td|ddntd|S#t.jt.jt4f$r9}tdt7|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%[QQ] STT: using QQ asr_refer_text: %rNr1Fr{r|Tz1[QQ] STT: using voice_wav_url (pre-converted WAV)z[QQ] STT: no HTTP clientz<[QQ] STT: downloading voice from %s (pre_wav=%s, headers=%s)r<r+)rrrz.[QQ] STT: downloaded %d bytes, content_type=%sz content-typeunknownr.z8[QQ] STT: downloaded data too small (%d bytes), skippingrrsuffixdeletez5[QQ] STT: using pre-converted WAV directly (%d bytes)z([QQ] STT: converting to wav, filename=%rz.[QQ] STT: ffmpeg conversion produced no outputzQ] STT: calling ASR on %sz[QQ] STT success: %rz'[QQ] STT: ASR returned empty transcriptz,[QQ] STT failed for voice attachment: %s: %s)rrrrzrrr9rmrr0rrtempfileNamedTemporaryFilewriter_convert_audio_to_wav_filerexists _call_sttrnunlinkOSErrorrHTTPStatusErrorTransportErrorIOErrorrr%)r!rr;r=r}r~ download_url is_pre_wavdownload_headersr audio_datartmpwav_pathrrs r#rzQQAdapter._stt_voice_attachment/s&  " KK?PTQTPTAU V V V! !   M''-- 9 8 8 8 (LJ KKK L L L4 $ 9:::t#5577  KKV$SbS):t'> NN#STTT4 KK5x @ @ @#~~h77777777J  (####     J 2Jtt4DEEEEHIII %u';WE    NNI4PS99K]_b c c c44444 su)!L DLL-G LGLGB L6L7K L KLKAL!M8?.M33M8rbytescKddl}t|jr&t|jn||}t dt|||dd||d5}| ||j }dddn #1swxYwY| dddd z}| ||d{V}|s| ||d{V}|s|||d{V} tj|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[QQ] STT: audio_data size=%d, ext=%r, first_20_bytes=%rFr.r6r)rrrrs_guess_ext_from_datarrrrrrrsplit_convert_silk_to_wav_convert_ffmpeg_to_wav_convert_raw_to_wavrnrr) r!rr=rrtmp_srcsrc_pathrresults r#rz$QQAdapter._convert_audio_to_wav_files /3H~~/Dod8nn#))+++$JcJcdnJoJo M OOS*SbS/ ; ; ; ( (E ( B B $g MM* % % %|H $ $ $ $ $ $ $ $ $ $ $ $ $ $ $??3**1-6008DDDDDDDD K66xJJJJJJJJF J33JIIIIIIIIF  Ih        D  s$CC C  E E-,E-rc6|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_V3r-#!SILKrr,!r7sRIFFrsfLaCr)sssrs0&usOggSrs srr=rs 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.Nr7rr,rrrr=rs r#_looks_like_silkzQQAdapter._looks_like_silks;BQBx9$XRaRH(<XRaRL@XXr$rrctK ddl}n+#t$rtdYdSwxYw |||dt |r~t |jdkrTt dt |j t |j|Sn2#t$r%}t d|Yd}~nd}~wwxYw| d d dd z} ddl}||||||dt |rt |jdkryt d t |j t |j| t!j|S#t$$rYSwxYwn2#t$r%}t d |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[QQ] pilk not installed — cannot decode SILK audio. Run: pip install pilk>)rate,z([QQ] pilk converted %s to wav (%d bytes)z&[QQ] pilk direct conversion failed: %srr6rz3[QQ] pilk converted %s (as .silk) to wav (%d bytes)z%[QQ] pilk .silk conversion failed: %s)pilk ImportErrorrr silk_to_wavrrstatst_sizerrrrrshutilcopy2rnrr)rrrr silk_pathrs r#rzQQAdapter._convert_silk_to_wavs  KKKK    NNh i i i44   H   Xxe  < < <H~~$$&& 4>>+>+>+@+@+H2+M+M F NN/h1D1D1F1F1NPPP H H H LLA3 G G G G G G G G HOOC++A.8   MMM LL9 - - -   Yu  = = =H~~$$&& 4>>+>+>+@+@+H2+M+M Q NN/h1D1D1F1F1NPPP  )$$$$      G G G LL@# F F F F F F F F G  )$$$$      )$$$$    ts $11B6C-- D7DD?CH6H%% H21H25J6 I%I J I%%J)I>> J  J J5J%$J5% J2/J51J22J5c~K ddl}||d5}|d|d|d||dddn #1swxYwY|S#t $r&}td|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. rNwr6r,rz [QQ] raw PCM fallback failed: %s) waverd setnchannels setsampwidth setframerate writeframesrrr)rrrwfrs r#rzQQAdapter._convert_raw_to_wavs   KKK8S)) +R""""""&&&z***  + + + + + + + + + + + + + + + O    LL;S A A A44444 s;B AA?3 B ?BB BB B<B77B<c K tjddd|dddd|tjjtjj d {V}tj|d d {V|jd krt|jr|j d {Vnd }t dt|j |d ddd Sn?#tjt f$r&}t d|Yd }~d Sd }~wwxYwt|r*t|jdkr/t dt|j d Stdt|j t|j|S)z'Convert audio file to WAV using ffmpeg.ffmpegz-yz-iz-ar16000z-ac1)stdoutstderrNr/rrr$z[QQ] ffmpeg failed for %s: %sreplace)errorsz [QQ] ffmpeg conversion error: %srz+[QQ] ffmpeg produced no/small output for %sz*[QQ] ffmpeg converted %s to wav (%d bytes))rcreate_subprocess_exec subprocessDEVNULLPIPEwait_forwait returncoderreadrrrrdecode TimeoutErrorFileNotFoundErrorrrrr)rrprocrrs r#rz QQAdapter._convert_ffmpeg_to_wavs  7$hwsH)1).D "499;;;;; ; ; ; ; ; ; ;!##59[It{//111111111c> NN/1D1DI1D1V1VXXXt $ $&78    NN=s C C C44444 H~~$$&& $x..*=*=*?*?*G2*M*M NNH$x..J] ^ ^ ^4 @NN'h)<)<)>)>)F H H HsC.C55D1 D,,D1Optional[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)rrr providerzaiz+https://open.bigmodel.cn/api/coding/paas/v4zhttps://api.openai.com/v1)r openaiglm)r rzglm-asrQQ_STT_API_KEYQQ_STT_BASE_URL QQ_STT_MODELN)r\rlrmrJrrstriprnro) r!rlstt_cfgrrr r _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@@$,#*!&!dN8R8R99XcY/44  y!=HIni88E$OOC00%  tr$c K|}|stddS|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#tj tf$r0} td||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[QQ] STT not configured (no stt config or QQ_STT_API_KEY)Nrrr rbz/audio/transcriptionsrzBearer filez audio/wavr+)rfilesrrchoicesrrr0rrLz0[QQ] STT API call failed (model=%s, base=%s): %sr:)rrrrdrzrrrrrrmrCrrr) r!rrrrr frrrr0rLrs r#rzQQAdapter._call_sttUsL**,,  NNV W W W4:&)$  h%% !.33666,.A.A.AB!DNN$7K#HI!5) 4                 ! ! # # #YY[[FjjB//G +!!*..B77;;IrJJ==??+"==??*::fb))Dzz|| $zz||#4%w/    NNM (3B3- 6 6 644444 sDFAB1% F1B55F8B59BF=FG*%GG 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)rrrrrrrrFrrr6rrz/[%s] audio conversion failed for %s (format=%s)r0qq_voicez qq_voice.wavz%[%s] Failed to read converted wav: %s)rr rrrrsrrrrrrrrrrrrnrrr read_bytesr) r!rrrrrrris_silkrwav_datars r#rzQQAdapter._convert_audio_to_wavsAI@T@T@Yad8J'',--4::<<<_a 8c!ccc++J77C  ( (E ( B B $g MM* % % %|H $ $ $ $ $ $ $ $ $ $ $ $ $ $ $??3**1-6 WnI(=(=j(I(IG O#888LLLLLLLL#::8XNNNNNNNN OP Iz#2#===0=M=M=MNN  (####     O K K K,Z9IC9I9IJJ J J  (####      K  O  (####      (####     H~~0022H Ih   ,X~FF F    LL@$)S Q Q Q44444 sB00B47B4BF0F FFHG3H5G  GGGH G55 HHH,HH, H)&H,(H))H,0AI55 J+?!J&&J+methodrbodyrfloatc K|jstd|d{V}d|dd} |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-Type)rrrizQQ Bot API error [z] z: rzQQ Bot API timeout [z]: ) rzrXrrequestrr status_codermrTimeoutException) r!r#rr$rrrrrrs r# _api_requestzQQAdapter._api_requestss  QOPP P((********-e--.    O*22#T## 3D99;;D3&&"3)933T33xx 40033K% O O ODdDDsDDEE3 N OsA?B<<C& C!!C& 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<d } td D]} |d || t d {VcS#t$r]} | } t |  t fd dDr| dkr tjd| dzzd {VYd } ~ d } ~ wwxYw| )z"Upload media and return file_info.rD /v2/users//files /v2/groups/)r-r/rr.r0Nr2POSTrc3 K|]}|vV dSrr=)rEkwerr_msgs r#rz*QQAdapter._upload_media..s'__rW}______r$)400401InvalidrTimeoutr,g?r6) MEDIA_TYPE_FILEranger*FILE_UPLOAD_TIMEOUTrXrrrr)r!r+r,r-rr.r/r0rr$last_excattemptrr8s @r# _upload_mediazQQAdapter._upload_mediasz2=1E1E-I----KjYbKjKjKj#(    *DKK  * )D   ' 'I ' )D Qxx = =G =!..vtTK^.___________ = = =c((____/^_____Q;;!-w{(;<<<<<<<<<  =s#A66 CACCrGreply_tometadatarchK~|jstddS|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. F Not connectedsuccessrT)rHz No chunksN) is_connectedrrCformat_messagetruncate_messageMAX_MESSAGE_LENGTH _send_chunkrH) r!rGr0rCrD formattedchunks last_resultchunks r#sendzQQAdapter.sends   De?CCC C ,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.Nr2rDrcrkFzUnknown chat type for rGc3 K|]}|vV dSrr=)rEkerrs r#rz(QQAdapter._send_chunk..-s'^^AqCx^^^^^^r$)invalid forbidden not foundz bad requestr,g?z$[%s] send retry %d/3 after %.1fs: %sr6z Unknown errorz[%s] Send failed: %sc3DK|]}|vVdSr)rs)rErU error_msgs r#rz(QQAdapter._send_chunk..8sNLL !!2!22LLLLLLr$)rWrXrY)rHrr)_guess_chat_typer>_send_c2c_text_send_group_text_send_guild_textrrrrsrrrrrrr) r!rGr0rCr@rIrArrrrVr[s @@r#rMzQQAdapter._send_chunksm)-))'22 Qxx / /G /%%!%!4!4Wgx!P!PPPPPPPPPP'))!%!6!6w!R!RRRRRRRRRR'))!%!6!6w!R!RRRRRRRRRR%e;]T[;];]^^^^^^ / / /#hhnn&&^^^^)]^^^^^EEEEEQ;;1<0ENN#I#'9gk5#GGG!-......... /&.BCMMM?  +TY BBBLLLL%JLLLLLL %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#r5r2 /messagesNr. TrHrO raw_response r+_build_text_bodyr*rrmr&r'r(r)r!r`r0rCmsg_seqr$rr#s r#r]zQQAdapter._send_c2c_text<s$$X%788$$Wh77  &%DN&&v/MF/M/M/MtTTTTTTTTTXXdDJLL$4SbS$9::;;$6MMMMr$racVK||p|}|||}|r||d<|dd|d|d{V}t|dt jjdd}td|| S) z"Send text to a group via REST API.r#r5r4rbNr.rcTrdrf)r!rar0rCrhr$rr#s r#r^zQQAdapter._send_group_textIs$$X%=>>$$Wh77  &%DN&&v/T\/T/T/TVZ[[[[[[[[TXXdDJLL$4SbS$9::;;$6MMMMr$rgcKd|d|ji}|r||d<|dd|d|d{V}t|dt jjdd}td || S) z*Send text to a guild channel via REST API.r0Nr#r5z /channels/rbr.rcTrd)rLr*rrmr&r'r(r)r!rgr0rCr$rr#s r#r_zQQAdapter._send_guild_textVs!*73KD4K3K+LM  &%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.defaultr0N)markdownmsg_typerh)r0rnrhrOmessage_reference)r+rrrLMSG_TYPE_MARKDOWN MSG_TYPE_TEXT)r!r0rCrhr$s r#rgzQQAdapter._build_text_bodybs$$X%:;;  ! &0H1H0H(IJ-"$$DD##;D$;#;<)"D  E) E-98,D() r$ image_urlcaptionc,K~|||td||d{V}|js||s|Std|j|j|r|d|n|}||||d{VS)z-Send an image natively via QQ Bot API upload.rtNz0[%s] Image send failed, falling back to text: %srB)rGr0rC) _send_mediaMEDIA_TYPE_IMAGErH_is_urlrrrrrR)r!rGrrrsrCrDrfallbacks r# send_imagezQQAdapter.send_image~s '' i!8!8 M I49V\Vbccc07Fg,,,,,YYYw8YTTTTTTTTTr$ image_pathcRK~|||td||d{VS)z!Send a local image file natively.rtN)rurv)r!rGrzrsrCkwargss r#send_image_filezQQAdapter.send_image_file> %%gz;KWV]_ghhhhhhhhhr$ audio_pathcRK~|||td||d{VS)zSend a voice message natively.rqN)ruMEDIA_TYPE_VOICE)r!rGrrsrCr|s r# send_voicezQQAdapter.send_voicer~r$ video_pathcRK~|||td||d{VS)zSend a video natively.rsN)ruMEDIA_TYPE_VIDEO)r!rGrrsrCr|s r# send_videozQQAdapter.send_videor~r$ file_pathc VK~|||td|||d{VS)zSend a file/document natively.r)r0N)rur=)r!rGrrsr0rCr|s r# send_documentzQQAdapter.send_documentsW %%gy/6SZ\d1:&<<<<<<<< $>HLLD"+4+G+G--T .F ;//I b!%7`X^7`7`aaaa((11G*%y1"$$D  D")*B4+B*B"CY *!)X"//3<3E3E/W////KkY`KkKkKkI y}}T4:<<3CCRC3HIIJJ&   = = = LL5ty# F F Fe3s88<<< < < < < < < =s,AF=:BF=B:F== H>H H HrKTuple[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_  +C OO<>>GGD   r$cHtt|jdvS)Nr)r rr)rKs r#rwzQQAdapter._is_urlcsF $$+/@@@r$c2||jvr |j|SdS)zDDetermine chat type from stored inbound metadata, fallback to 'c2c'.rD)r)r!rGs r#r\zQQAdapter._guess_chat_typegs# d) ) )&w/ /ur$c`ddl}|dd|}|S)z9Strip the @bot mention prefix from group message content.rNz^@\S+\s*r)resubrC)r0rstrippeds r#rezQQAdapter._strip_at_mentionms/  66+r7==??;;r$rHcl|jdkrdS|jdkr||j|SdSNdisabledF allowlistT)rt_entry_matchesru)r!rHs r#rRzQQAdapter._is_dm_allowedus? ?j ( (5 ?k ) )&&t'7AA Atr$group_idcl|jdkrdS|jdkr||j|SdSr)rvrrw)r!rrHs r#rdzQQAdapter._is_group_allowed|sA   + +5   , ,&&t'=xHH Htr$entriesr@targetct|}|D]D}t|}|dks||krdSEdS)N*TF)rrCrs)rrnormalized_targetentry normalizeds r#rzQQAdapter._entry_matchessKK--//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. )tzr3) rnowrutc fromisoformatr TypeError fromtimestampr)r!rs r#rXzQQAdapter._parse_qq_timestamps  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 ||Sr=r=)rEkeytscutoffs r# z+QQAdapter._is_duplicate..s+####Cb6kkRkkkr$TF)rrrDEDUP_MAX_SIZEDEDUP_WINDOW_SECONDSitems)r!r#rrs @r#r2zQQAdapter._is_duplicatesikk t" # #n 4 4//F####'+':'@'@'B'B###D  T( ( (4&)F#ur$)rrr8rR)r\r)r8rr8r9)r8rR)rrr8rR)rrr8r9)rr r8rR)rrr8rR)rrr8r )r#rr8r)r,rrrr8rR) rr r#rr0rr1r r/rr8rR)rPrLrQrL)r9rr8r )rrr;rr8r)r;rr=rr8r9)r8r) rrr;rr=rr}rr~rr8r)rrr=rr8r)rrr8r)rrr8r9)rrrrr8r)rrrrr8r)r8r)rrr8r)rrrrr8r) r#rrrr$r rr%r8r )NNFN)r+rr,rr-rrrr.rr/r9r0rr8r )NN) rGrr0rrCrrDr r8rr)rGrr0rrCrr8r)r`rr0rrCrr8r)rarr0rrCrr8r)rgrr0rrCrr8r)r0rrCrr8r )NNN) rGrrrrrsrrCrrDr r8r) rGrrzrrsrrCrr8r) rGrrrrsrrCrr8r) rGrrrrsrrCrr8r) rGrrrrsrr0rrCrr8r)rGrrrr-rrrrsrrCrr0rr8r)rKrr0rr8r)rGrr8rR)r0rr8r)rGrr8r )rKrr8r9)rGrr8r)rHrr8r9)rrrHrr8r9)rr@rrr8r9)rrr8r)r#rr8r9)Lr%r&r'r(SUPPORTS_MESSAGE_EDITINGr[rLr propertyrrrrrrrrrrrrr staticmethodr rrrr+rr3r4r5r6rWrTrrrrrrrrrrrrrrr*rBrRrMr]r^r_rgryr}rrrrurrrJrrwr\rerRrdrrXr2r)r*s@r#rQrQsXTT %((((,#;#;#;#;#;#;RX1111f44442((((0&&&&>.NNNN"i%i%i%i%V$7777&&MMMM@""""6  \ +;+;+;+;ZRRRR>>>\>***\*QQQQ2<)<)<)<)|+)+)+)+)Z+)+)+)+)Z')')')')\   \ $Y Y Y Y v====<   \     ")-'+UUUUUUn%%%%N\&YYY\Y(((\(T\$\25555n))))V((((d*., !O!O!O!O!OP"#'"#'%%%%%V#'-1 BEI"O"O"O"O"OJDH N N N N NJN N N N N NHL N N N N N@"&"&-1 UUUUU0"&"& i i i i i "&"& i i i i i "&"& i i i i i "&#'"& < < < < <("&"&#'@=@=@=@=@=F7;"0"0"0"0"0PHHHHH6''''    AAA\A \\----$        r$rQr)r?rr8r@)Fr( __future__rrrrloggingrrnrr&rrpathlibrtypingrrr r r urllib.parser rr;rrr<gateway.configr rgateway.platforms.baserrrrrrgateway.platforms.helpersr getLoggerr%rrrrrrrr?rrrrrrrLrrrqrprrrvrrr=r>rOrQr=r$r#rs>#"""""  ''''''''33333333333333!!!!!!NNNGGGLLLOOO EEE43333333544444  8 $ $ W W W W W9 W W W ' 7 &&&  1111 >>>>\\\\\#\\\\\s$ A AA#A** A65A6