harald/zeroclaw
1
0
Fork 0
Code Issues Pull requests Projects Releases Packages Wiki Activity Actions 3

fix(channels): tighten qq listener lifecycle and english labels

Browse source
This commit is contained in:
Chummy 2026-02-17 22:30:21 +08:00
parent ed71bce447
commit 14d93c075e
1 changed files with 1 additions and 36 deletions
Download patch file Download diff file Expand all files Collapse all files

37
src/channels/qq.rs
View file

@ -11,7 +11,7 @@ use uuid::Uuid;
const QQ_API_BASE: &str = "https://api.sgroup.qq.com"; const QQ_API_BASE: &str = "https://api.sgroup.qq.com";
const QQ_AUTH_URL: &str = "https://bots.qq.com/app/getAppAccessToken"; const QQ_AUTH_URL: &str = "https://bots.qq.com/app/getAppAccessToken";
/// Deduplication set capacity — evict oldest half when full. /// Deduplication set capacity — evict half of entries when full.
const DEDUP_CAPACITY: usize = 10_000; const DEDUP_CAPACITY: usize = 10_000;
/// QQ Official Bot channel — uses Tencent's official QQ Bot API with /// QQ Official Bot channel — uses Tencent's official QQ Bot API with
@ -261,41 +261,6 @@ impl Channel for QQChannel {
} }
}); });
// Spawn token refresh task
let token_cache = Arc::clone(&self.token_cache);
let app_id = self.app_id.clone();
let app_secret = self.app_secret.clone();
let client = self.client.clone();
tokio::spawn(async move {
let mut interval = tokio::time::interval(std::time::Duration::from_secs(6000)); // ~100 min
loop {
interval.tick().await;
let body = json!({
"appId": app_id,
"clientSecret": app_secret,
});
if let Ok(resp) = client.post(QQ_AUTH_URL).json(&body).send().await {
if let Ok(data) = resp.json::<serde_json::Value>().await {
if let Some(new_token) = data.get("access_token").and_then(|t| t.as_str()) {
let expires_in = data
.get("expires_in")
.and_then(|e| e.as_str())
.and_then(|e| e.parse::<u64>().ok())
.unwrap_or(7200);
let now = std::time::SystemTime::now()
.duration_since(std::time::UNIX_EPOCH)
.unwrap_or_default()
.as_secs();
let mut cache = token_cache.write().await;
*cache =
Some((new_token.to_string(), now + expires_in.saturating_sub(60)));
tracing::debug!("QQ: token refreshed");
}
}
}
}
});
loop { loop {
tokio::select! { tokio::select! {
_ = hb_rx.recv() => { _ = hb_rx.recv() => {